refactor：定时任务

haoban-manage3-api/src/main/java/com/gic/haoban/manage/api/service/TestApiService.java

@@ -33,7 +33,7 @@ public interface TestApiService {
      * @param methodName
      * @param cron
      */
-    void quartzTaskConvert(String serviceName, String methodName, String cron, String params);
+    void quartzTaskConvert(String serviceName, String methodName, String cron, String params,String referId);
 
 
     /**

haoban-manage3-operation-web/src/main/java/com/gic/haoban/manage/web/controller/test/TestController.java

@@ -70,7 +70,7 @@ public class TestController extends WebBaseController {
         if (null == quartzEnum) {
             return resultResponse(HaoBanErrCode.ERR_0);
         }
-        testApiService.quartzTaskConvert(quartzEnum.getServiceName(), quartzEnum.getMethod(), quartzEnum.getCron(), quartzEnum.getParams());
+        testApiService.quartzTaskConvert(quartzEnum.getServiceName(), quartzEnum.getMethod(), quartzEnum.getCron(), quartzEnum.getParams(), null);
         return resultResponse(HaoBanErrCode.ERR_1);
     }
 
@@ -81,11 +81,11 @@ public class TestController extends WebBaseController {
      */
     @RequestMapping("/create-quarter")
     @ResponseBody
-    public HaobanResponse createQuarter(String serviceName, String methodName, String cron, String params) {
+    public HaobanResponse createQuarter(String serviceName, String methodName, String cron, String params, String referId) {
         if (StringUtils.isAnyBlank(serviceName, methodName, cron)) {
             return resultResponse(HaoBanErrCode.ERR_2);
         }
-        testApiService.quartzTaskConvert(serviceName, methodName, cron, params);
+        testApiService.quartzTaskConvert(serviceName, methodName, cron, params, referId);
         return resultResponse(HaoBanErrCode.ERR_1);
     }
 

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/out/impl/TestServiceImpl.java

@@ -8,6 +8,7 @@ import com.gic.quartz.api.dto.QuartzTaskDTO;
 import com.gic.quartz.api.service.QuartzService;
 import com.gic.wechat.api.dto.qywx.UserDTO;
 import com.gic.wechat.api.service.qywx.QywxUserApiService;
+import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -20,7 +21,7 @@ import java.util.List;
  */
 @Service
 public class TestServiceImpl implements TestApiService {
-    private static final Logger logger= LoggerFactory.getLogger(TestServiceImpl.class);
+    private static final Logger logger = LoggerFactory.getLogger(TestServiceImpl.class);
     @Autowired
     private QywxUserApiService qywxUserApiService;
     @Autowired
@@ -30,45 +31,47 @@ public class TestServiceImpl implements TestApiService {
 
     @Autowired
     private QuartzService quartzService;
-    
+
     @Override
     public String checkThread(String id, Long expireTime) {
-        logger.info("测试-start：{}",id);
-        if (expireTime!=null && expireTime>0) {
-            logger.info("延时：{}",expireTime);
+        logger.info("测试-start：{}", id);
+        if (expireTime != null && expireTime > 0) {
+            logger.info("延时：{}", expireTime);
             try {
                 Thread.sleep(expireTime);
             } catch (InterruptedException e) {
                 e.printStackTrace();
             }
         }
-        logger.info("测试-end：{}",id);
+        logger.info("测试-end：{}", id);
         return id;
     }
-	@Override
-	public String listSelfQywxUser(String corpid,String secretVal, String dataId) {
+
+    @Override
+    public String listSelfQywxUser(String corpid, String secretVal, String dataId) {
         long t = System.currentTimeMillis();
         List<UserDTO> list = this.qywxUserApiService.listSelfDepartmentUser(corpid, secretVal, dataId, 0);
-        logger.info("耗时为===============>{}毫秒",(System.currentTimeMillis()-t));	
+        logger.info("耗时为===============>{}毫秒", (System.currentTimeMillis() - t));
         if (null != list) {
-            logger.info("微信获取部门成员数量为：{}",list.size());
-        }else {
+            logger.info("微信获取部门成员数量为：{}", list.size());
+        } else {
             logger.info("微信获取部门成员数量异常");
         }
         return "";
-	}
-	@Override
-	public String listAllQywxUser(String corpid,String secretVal, String dataId) {
+    }
+
+    @Override
+    public String listAllQywxUser(String corpid, String secretVal, String dataId) {
         long t = System.currentTimeMillis();
         List<UserDTO> list = this.qywxUserApiService.listSelfDepartmentUser(corpid, secretVal, dataId, 1);
-        logger.info("耗时为===============>{}毫秒",(System.currentTimeMillis()-t));	
+        logger.info("耗时为===============>{}毫秒", (System.currentTimeMillis() - t));
         if (null != list) {
-            logger.info("微信获取部门成员数量为：{}",list.size());
-        }else {
+            logger.info("微信获取部门成员数量为：{}", list.size());
+        } else {
             logger.info("微信获取部门成员数量异常");
         }
         return "";
-	}
+    }
 
     /**
      * 调度器DTO参数构造器
@@ -80,9 +83,9 @@ public class TestServiceImpl implements TestApiService {
      */
 
     @Override
-    public void quartzTaskConvert(String serviceName, String methodName, String cron, String param) {
+    public void quartzTaskConvert(String serviceName, String methodName, String cron, String param, String referId) {
         QuartzTaskDTO taskDTO = new QuartzTaskDTO();
-        taskDTO.setReferId("-1");
+        taskDTO.setReferId(StringUtils.isBlank(referId) ? "-1" : referId);
         taskDTO.setTaskService(serviceName);
         taskDTO.setTaskMethod(methodName);
         taskDTO.setTaskParam(param);
@@ -103,7 +106,7 @@ public class TestServiceImpl implements TestApiService {
 
     @Override
     public ServiceResponse listAllQywxUser(String params) {
-        logger.info("JSONOnkec:"+params);
+        logger.info("JSONOnkec:" + params);
         return ServiceResponse.success(params);
     }
 }