1

src/main/java/com/fdkankan/task/jobhandler/sale/SaleXxlJob.java

@@ -3,6 +3,7 @@ package com.fdkankan.task.jobhandler.sale;
 import com.fdkankan.dingtalk.DingTalkSendUtils;
 import com.fdkankan.task.entity.Repair;
 import com.fdkankan.task.mapper.RepairMapper;
+import com.mybatisflex.core.datasource.DataSourceKey;
 import com.mybatisflex.core.query.QueryWrapper;
 import com.xxl.job.core.handler.annotation.XxlJob;
 import org.slf4j.Logger;
@@ -40,6 +41,7 @@ public class SaleXxlJob {
         String taskId = UUID.randomUUID().toString().replace("-", "");
         logger.info("saleRepairStatus---------------start,taskId:{}",taskId);
         try {
+            //DataSourceKey.use("sale");
             HashMap<Integer,HashMap<String,Integer>> resultMap = new HashMap<>();
             QueryWrapper queryWrapper = QueryWrapper.create()
                     .where("rec_status = 'A' and `status` <80");
@@ -68,7 +70,7 @@ public class SaleXxlJob {
             msg = msg.replaceAll("}", "");
             msg = msg.replaceAll("=", "：");
             logger.info(msg);
-            dingTalkSendUtils.sendActioncardMsgToDingRobot(msg, "场景计算统计");
+            //dingTalkSendUtils.sendActioncardMsgToDingRobot(msg, "场景计算统计");
 
         }catch (Exception e){
             logger.info("saleRepairStatus-error,taskId:{},{}",taskId,e);

src/main/java/com/fdkankan/task/jobhandler/zfb/GenSceneNumService.java

@@ -37,7 +37,6 @@ public class GenSceneNumService {
     TbSceneProMapper tbSceneProMapper;
 
 
-    @UseDataSource("old-zfb")
     public void genOldCode(){
         QueryWrapper queryWrapper = QueryWrapper.create()
                 .where("used =0");

src/main/java/com/fdkankan/task/jobhandler/zfb/ZfbXxlJob.java

@@ -7,6 +7,7 @@ import com.fdkankan.task.jobhandler.sale.SaleXxlJobUtil;
 import com.fdkankan.task.mapper.RepairMapper;
 import com.fdkankan.task.mapper.TbSceneNumMapper;
 import com.mybatisflex.annotation.UseDataSource;
+import com.mybatisflex.core.datasource.DataSourceKey;
 import com.mybatisflex.core.query.QueryWrapper;
 import com.xxl.job.core.handler.annotation.XxlJob;
 import org.slf4j.Logger;
@@ -45,6 +46,7 @@ public class ZfbXxlJob {
         String taskId = UUID.randomUUID().toString().replace("-", "");
         logger.info("oldZfbGenOldCode---------------start,taskId:{}",taskId);
         try {
+            DataSourceKey.use("old-zfb");
             genSceneNumService.genOldCode();
         }catch (Exception e){
             logger.info("oldZfbGenOldCode-error,taskId:{},{}",taskId,e);
@@ -60,6 +62,7 @@ public class ZfbXxlJob {
         String taskId = UUID.randomUUID().toString().replace("-", "");
         logger.info("newZfbGenOldCode---------------start,taskId:{}",taskId);
         try {
+            DataSourceKey.use("new-zfb");
             genSceneNumService.genOldCode();
         }catch (Exception e){
             logger.info("newZfbGenOldCode-error,taskId:{},{}",taskId,e);
@@ -76,6 +79,7 @@ public class ZfbXxlJob {
         String taskId = UUID.randomUUID().toString().replace("-", "");
         logger.info("newZfbGenNewCode---------------start,taskId:{}",taskId);
         try {
+            DataSourceKey.use("new-zfb");
             genSceneNumService.genNewCode();
         }catch (Exception e){
             logger.info("newZfbGenNewCode-error,taskId:{},{}",taskId,e);