소스 검색

基本完成

soft5566 2 년 전
부모
커밋
d34c0aff78
2개의 변경된 파일6개의 추가작업 그리고 4개의 파일을 삭제
  1. 2 2
      src/main/java/com/template/common/utils/QuartzJobUtils.java
  2. 4 2
      src/main/java/com/template/controller/Task.java

+ 2 - 2
src/main/java/com/template/common/utils/QuartzJobUtils.java

@@ -203,9 +203,9 @@ public class QuartzJobUtils {
         JobKey jobKey = JobKey.jobKey(jobName);
         try {
             scheduler.deleteJob(jobKey);
-            return CommonUtil.getReturnMap(String.valueOf(0), "定时任务【" + jobName + "】删除成功!");
+            return CommonUtil.getReturnMap(String.valueOf(0), "定时任务【" + jobName + "】停止成功!");
         } catch (SchedulerException e) {
-            return CommonUtil.getReturnMap(String.valueOf(1), "定时任务【" + jobName + "】删除出错:" + e.getMessage());
+            return CommonUtil.getReturnMap(String.valueOf(1), "定时任务【" + jobName + "】停止出错:" + e.getMessage());
         }
     }
 }

+ 4 - 2
src/main/java/com/template/controller/Task.java

@@ -293,13 +293,15 @@ public class Task extends QuartzJobBean {
 
             // 都没有记录了,则不需要更新
             if (!sourceHashCodeFlag) {
-                String tmp1 = "数据交换完成,共交换数据 " + (totalInsert + totalUpdate) + " 条:插入:" + totalInsert + " 条,更新:" + totalUpdate + " 条";
-                saveErrorMsg(tkId, datetime, tmp1);
                 break;
             }
 
             page++;
         }
+
+        String tmp1 = "数据交换完成,共交换数据 " + (totalInsert + totalUpdate) + " 条:插入:" + totalInsert + " 条,更新:" + totalUpdate + " 条";
+        saveErrorMsg(tkId, datetime, tmp1);
+
         // 关闭数据库连接
         if (destinationConn != null) {
             destinationDbUtil.closeConnection(destinationConn);