3/17 添加 请求log

kimi42345

2020-03-17 6c6fdb4db59a2a2343e43ffd73a07f17b057c4fa

 src/main/java/com/highdatas/mdm/job/XxlJobHandler.java

@@ -1,21 +1,21 @@
package com.highdatas.mdm.job;



import com.highdatas.mdm.entity.SysAssemble;

import com.highdatas.mdm.pojo.Result;

import com.highdatas.mdm.service.ISysAssembleService;

import com.xxl.job.core.biz.model.ReturnT;

import com.xxl.job.core.log.XxlJobLogger;

import lombok.extern.slf4j.Slf4j;

import org.apache.catalina.session.StandardSession;

import org.apache.commons.lang3.StringUtils;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Component;

import com.xxl.job.core.handler.annotation.XxlJob;

import org.springframework.web.context.request.RequestContextHolder;

import org.springframework.web.context.request.ServletRequestAttributes;



import javax.servlet.ServletContext;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpSession;

import javax.servlet.http.HttpSessionContext;

import java.util.Enumeration;





/**

 * @author kimi

@@ -29,18 +29,31 @@
    ISysAssembleService assembleService;



    @XxlJob("assembleJob")

    public ReturnT<String> demoJobHandler(String assembleId) throws Exception {

    public ReturnT<String> assembleJobHandler(String assembleId) throws Exception {

        XxlJobLogger.log("assemble Job start");

        if (StringUtils.isEmpty(assembleId)) {

            XxlJobLogger.log("params: assembleId is null");

        }



        SysAssemble assemble = assembleService.selectById(assembleId);

        if (assemble == null) {

            XxlJobLogger.log("params: assemble is not found");

        }



//        assembleService.run()

        Result run = assembleService.run(assembleId);

        XxlJobLogger.log("log info:" + run.getMessage());

        if (run.getSuccess()) {

            return ReturnT.SUCCESS;

        }else {

            return ReturnT.FAIL;

        }

    }



    @XxlJob("test")

    public ReturnT<String> test(String assembleId) throws Exception {

        XxlJobLogger.log("assemble Job start");

        XxlJobLogger.log("test Job run");

        ServletRequestAttributes requestAttributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();

        HttpServletRequest request = requestAttributes.getRequest();

        HttpSession session = request.getSession();

        session.setAttribute("11", assembleId);

        return ReturnT.SUCCESS;

    }