From 152f84a5bb7530c705a88086ab2acdb778e86fdd Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Wed, 12 May 2021 10:12:08 +0800
Subject: [PATCH] 20210510 云顶
---
src/main/java/com/xcong/excoin/quartz/job/YdPowerJob.java | 66 +++++++++++++++++++++++++++++++++
1 files changed, 66 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/quartz/job/YdPowerJob.java b/src/main/java/com/xcong/excoin/quartz/job/YdPowerJob.java
new file mode 100644
index 0000000..737e800
--- /dev/null
+++ b/src/main/java/com/xcong/excoin/quartz/job/YdPowerJob.java
@@ -0,0 +1,66 @@
+package com.xcong.excoin.quartz.job;
+
+import cn.hutool.core.collection.CollUtil;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.xcong.excoin.modules.blackchain.service.DateUtil;
+import com.xcong.excoin.modules.yunding.dao.YdOrderDao;
+import com.xcong.excoin.modules.yunding.entity.YdOrderEntity;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+import java.util.Date;
+import java.util.List;
+
+@Slf4j
+@Component
+@ConditionalOnProperty(prefix = "app", name = "loop-job", havingValue = "true")
+public class YdPowerJob {
+
+
+ @Resource
+ private YdOrderDao ydOrderDao;
+
+ /**
+ * 产品生效
+ */
+ @Scheduled(cron = "0/10 * * * * ?")
+ public void orderWork() {
+ QueryWrapper<YdOrderEntity> objectQueryWrapper = new QueryWrapper<>();
+ objectQueryWrapper.eq("",YdOrderEntity.ORDER_STATE_READY);
+ List<YdOrderEntity> ydOrderEntities = ydOrderDao.selectList(objectQueryWrapper);
+ Date date = new Date();
+ if(CollUtil.isNotEmpty(ydOrderEntities)){
+ for(YdOrderEntity ydOrderEntity : ydOrderEntities){
+ Date workTime = ydOrderEntity.getWorkTime();
+ if(DateUtil.compare_date(date.toString(),workTime.toString()) == 1){
+ ydOrderEntity.setState(YdOrderEntity.ORDER_STATE_WORK);
+ ydOrderDao.updateById(ydOrderEntity);
+ }
+ }
+ }
+ }
+
+ /**
+ * 产品终止
+ */
+ @Scheduled(cron = "0/10 * * * * ?")
+ public void orderEnd() {
+ QueryWrapper<YdOrderEntity> objectQueryWrapper = new QueryWrapper<>();
+ objectQueryWrapper.eq("",YdOrderEntity.ORDER_STATE_WORK);
+ List<YdOrderEntity> ydOrderEntities = ydOrderDao.selectList(objectQueryWrapper);
+ Date date = new Date();
+ if(CollUtil.isNotEmpty(ydOrderEntities)){
+ for(YdOrderEntity ydOrderEntity : ydOrderEntities){
+ Date endTime = ydOrderEntity.getEndTime();
+ if(DateUtil.compare_date(date.toString(),endTime.toString()) == 1) {
+ ydOrderEntity.setState(YdOrderEntity.ORDER_STATE_END);
+ ydOrderDao.updateById(ydOrderEntity);
+ }
+ }
+ }
+ }
+
+}
--
Gitblit v1.9.1