From 4a141a86f571173357812d71358a1173d7457899 Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期二, 07 七月 2020 16:07:41 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/asrs/task/handler/NotifyLogHandler.java | 1
src/main/resources/UpdateThread.cs | 2
src/main/java/com/zy/asrs/task/OverYearLogScheduler.java | 30 +++++++++++++++
src/main/java/com/zy/asrs/task/handler/OverYearLogHandler.java | 37 ++++++++++++++++++
4 files changed, 69 insertions(+), 1 deletions(-)
diff --git a/src/main/java/com/zy/asrs/task/OverYearLogScheduler.java b/src/main/java/com/zy/asrs/task/OverYearLogScheduler.java
new file mode 100644
index 0000000..95a8a29
--- /dev/null
+++ b/src/main/java/com/zy/asrs/task/OverYearLogScheduler.java
@@ -0,0 +1,30 @@
+package com.zy.asrs.task;
+
+import com.zy.asrs.task.core.ReturnT;
+import com.zy.asrs.task.handler.OverYearLogHandler;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+/**
+ * Created by vincent on 2020/7/7
+ */
+@Component
+public class OverYearLogScheduler {
+
+ private static final Logger log = LoggerFactory.getLogger(OverYearLogScheduler.class);
+
+ @Autowired
+ private OverYearLogHandler overYearLogHandler;
+
+ @Scheduled(cron = "0/3 * * * * ? ")
+ private void execute(){
+ ReturnT<String> returnT = overYearLogHandler.start();
+ if (!returnT.isSuccess()) {
+ log.error(returnT.getMsg());
+ }
+ }
+
+}
diff --git a/src/main/java/com/zy/asrs/task/handler/NotifyLogHandler.java b/src/main/java/com/zy/asrs/task/handler/NotifyLogHandler.java
index 2faf072..bc75cb9 100644
--- a/src/main/java/com/zy/asrs/task/handler/NotifyLogHandler.java
+++ b/src/main/java/com/zy/asrs/task/handler/NotifyLogHandler.java
@@ -28,6 +28,7 @@
exceptionHandle("鍏ュ簱閫氱煡妗ｈ浆鍘嗗彶妗ｅけ璐�");
}
}
+ // todo:luxiaotao
// 鍑哄簱閫氱煡妗ｈ浆鍘嗗彶妗�
// 鐩樼偣閫氱煡妗ｈ浆鍘嗗彶妗�
diff --git a/src/main/java/com/zy/asrs/task/handler/OverYearLogHandler.java b/src/main/java/com/zy/asrs/task/handler/OverYearLogHandler.java
new file mode 100644
index 0000000..62b7596
--- /dev/null
+++ b/src/main/java/com/zy/asrs/task/handler/OverYearLogHandler.java
@@ -0,0 +1,37 @@
+package com.zy.asrs.task.handler;
+
+import com.zy.asrs.task.AbstractHandler;
+import com.zy.asrs.task.core.ReturnT;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.transaction.interceptor.TransactionAspectSupport;
+
+/**
+ * Created by vincent on 2020/7/7
+ */
+@Service
+public class OverYearLogHandler extends AbstractHandler<String> {
+
+ @Autowired
+ private JdbcTemplate jdbcTemplate;
+
+ @Transactional
+ public ReturnT<String> start() {
+ try {
+ // 鍒犻櫎鍗婂勾浠ヤ笂鐨勫巻鍙叉。
+ jdbcTemplate.update("delete from asr_stk_hplc where dateadd(day,180,appe_time) <= getdate();");
+ jdbcTemplate.update("delete from asr_wrk_detl_log where dateadd(day,360,appe_time) <= getdate();");
+ jdbcTemplate.update("delete from asr_wrk_mast_log where dateadd(day,360,appe_time) <= getdate();");
+ jdbcTemplate.update("delete from cust_wait_pakin_log where dateadd(day,360,appe_time) <= getdate();");
+
+ } catch (Exception e) {
+ e.printStackTrace();
+ TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
+ return FAIL.setMsg(e.getMessage());
+ }
+ return SUCCESS;
+ }
+
+}
diff --git a/src/main/resources/UpdateThread.cs b/src/main/resources/UpdateThread.cs
index 1c1c891..ed1bb3f 100644
--- a/src/main/resources/UpdateThread.cs
+++ b/src/main/resources/UpdateThread.cs
@@ -1713,7 +1713,7 @@
ProcCheckToWorkData("5");
//杞嚭搴撳畬鎴愬緟鍑哄簱妗ｆ暟鎹埌鍘嗗彶妗�
- ProcWaitOutToLog("6");
+ ProcWaitOutToLog("6"); // done
//鍒犻櫎瓒呰繃鍗婂勾鍘嗗彶妗�
ProcOverYearLog("7");
--
Gitblit v1.9.1