1、调整动态sql执行方式

src/main/java/com/xjrsoft/module/job/EvaluateTask.java

@@ -1,17 +1,16 @@
 package com.xjrsoft.module.job;
 
-import cn.hutool.db.Db;
-import com.xjrsoft.common.constant.GlobalConstant;
-import com.xjrsoft.common.utils.DatasourceUtil;
+import com.xjrsoft.common.mybatis.SqlRunnerAdapter;
 import com.xjrsoft.common.utils.DateUtils;
+import com.xjrsoft.common.utils.SqlRunnerAdapterUtil;
 import com.xjrsoft.module.evaluate.entity.EvaluateManage;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
-import javax.sql.DataSource;
 import java.util.Date;
 import java.util.List;
+import java.util.Map;
 
 /**
  * 自动生成评价提交记录
@@ -26,13 +25,12 @@ public class EvaluateTask {
     @Scheduled(cron = "0 0 1 * * ?")
     public void addSubmitRecord() {
         System.out.printf("定时新增评价提交记录：%s", DateUtils.format(new Date(), DateUtils.DATE_TIME_PATTERN));
-        DataSource datasource = DatasourceUtil.getDataSource(GlobalConstant.DEFAULT_DATASOURCE_KEY);
         try {
-            Db use = Db.use(datasource);
             //先查出所有进行中的需要重复评价的评价管理
             String listEvaluateManageSql = "select t.id, t.create_frequency from evaluate_manage t where t.is_auto_create = 1 and t.status = 1";
-            List<EvaluateManage> evaluateManageList = use.query(listEvaluateManageSql, EvaluateManage.class);
-            for(EvaluateManage evaluateManage : evaluateManageList){
+            List<Map<String, Object>> evaluateManageList = SqlRunnerAdapter.db().selectList(listEvaluateManageSql, EvaluateManage.class);
+            for(Map<String, Object> evaluateManageMap : evaluateManageList){
+                EvaluateManage evaluateManage = SqlRunnerAdapterUtil.convertMapToEntity(evaluateManageMap, EvaluateManage.class);
                 //TODO 根据评价的频率进行新增
 
                 //默认每天新增根据评价管理id
@@ -50,7 +48,7 @@ public class EvaluateTask {
                         "                      LEFT JOIN evaluate_template t2 ON (t2.id = t1.evaluate_template_id)" +
                         "             WHERE t.delete_mark = 0" +
                         "          AND t.evaluate_manage_id = " + evaluateManage.getId() + ")";
-                use.execute(insertSubmitScoreSql);
+                SqlRunnerAdapter.db().insert(insertSubmitScoreSql);
             }
         } catch (Exception e) {
             log.error(e.getMessage(), "定时新增评价提交记录");