From 0bf1c5465f1f3198c53ad02f3209148afabb2038 Mon Sep 17 00:00:00 2001
From: kimi42345 <kimi42345@outlook.com>
Date: 星期二, 17 三月 2020 11:24:45 +0800
Subject: [PATCH] Merge branch 'master' of http://highdatas.com:9000/r/~kimi/srs_spring
---
src/main/java/com/highdatas/srs/task/DelayTimeTask.java | 38 ++++++++++++++++++++++++++++++++++++--
1 files changed, 36 insertions(+), 2 deletions(-)
diff --git a/src/main/java/com/highdatas/srs/task/DelayTimeTask.java b/src/main/java/com/highdatas/srs/task/DelayTimeTask.java
index 61b3623..9872473 100644
--- a/src/main/java/com/highdatas/srs/task/DelayTimeTask.java
+++ b/src/main/java/com/highdatas/srs/task/DelayTimeTask.java
@@ -1,11 +1,45 @@
package com.highdatas.srs.task;
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
+import com.highdatas.srs.entity.Scheme;
+import com.highdatas.srs.entity.SchemeDetail;
+import com.highdatas.srs.service.ISchemeDetailService;
+import com.highdatas.srs.service.ISchemeService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.EnableScheduling;
+import org.springframework.scheduling.annotation.Scheduled;
+
+import java.util.Date;
+import java.util.HashSet;
+import java.util.List;
+
/**
* @author kimi
* @description
* @date 2020-02-12 10:40
*/
-
+@EnableScheduling
public class DelayTimeTask {
-}
+ @Autowired
+ ISchemeService schemeService;
+ @Autowired
+ ISchemeDetailService schemeDetailService;
+
+ @Scheduled(cron = "0 0 0 1/1 * ?")
+ private void delayTask(){
+ Date date = new Date();
+ List<SchemeDetail> schemeDetailList = schemeDetailService.selectList(new EntityWrapper<SchemeDetail>().lt("end_time", date).eq("edit", false));
+ HashSet<String> parentIdSet = new HashSet<>();
+ for (SchemeDetail detail : schemeDetailList) {
+ parentIdSet.add(detail.getParentId());
+ detail.setDelay(true);
+ detail.updateById();
+ }
+ //椤圭洰涓煇涓妭鐐瑰彂鐢熷欢鏈熷垯椤圭洰寤舵湡 鍚庢湡鏍规嵁涓氬姟淇敼
+ List<Scheme> schemes = schemeService.selectBatchIds(parentIdSet);
+ for (Scheme scheme : schemes) {
+ scheme.setStatus("delay").updateById();
+ }
+ }
+ }
--
Gitblit v1.8.0