From b5636e416a2fe029f96aec6ddfd3489394925b15 Mon Sep 17 00:00:00 2001
From: kimi <kimi42345@gmail.com>
Date: 星期二, 24 三月 2020 19:33:53 +0800
Subject: [PATCH] add 数据权限
---
src/main/java/com/highdatas/mdm/job/XxlJobHandler.java | 31 ++++++++++++++++++++++---------
1 files changed, 22 insertions(+), 9 deletions(-)
diff --git a/src/main/java/com/highdatas/mdm/job/XxlJobHandler.java b/src/main/java/com/highdatas/mdm/job/XxlJobHandler.java
index 8527d0f..3929541 100644
--- a/src/main/java/com/highdatas/mdm/job/XxlJobHandler.java
+++ b/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;
}
--
Gitblit v1.8.0