From c1c37067a3ffbcb430b96f393778901a4ef6dcc4 Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Thu, 13 May 2021 19:37:02 +0800
Subject: [PATCH] modify
---
src/main/java/com/xcong/excoin/quartz/job/YdPowerJob.java | 23 ++++++++++++-----------
1 files changed, 12 insertions(+), 11 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
index 737e800..2706aa5 100644
--- a/src/main/java/com/xcong/excoin/quartz/job/YdPowerJob.java
+++ b/src/main/java/com/xcong/excoin/quartz/job/YdPowerJob.java
@@ -1,8 +1,9 @@
package com.xcong.excoin.quartz.job;
import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.date.DateUtil;
+import cn.hutool.core.util.ObjectUtil;
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;
@@ -16,7 +17,7 @@
@Slf4j
@Component
-@ConditionalOnProperty(prefix = "app", name = "loop-job", havingValue = "true")
+@ConditionalOnProperty(prefix = "app", name = "xch-job", havingValue = "true")
public class YdPowerJob {
@@ -26,18 +27,18 @@
/**
* 产品生效
*/
- @Scheduled(cron = "0/10 * * * * ?")
+ @Scheduled(cron = "0 0/1 * * * ?")
public void orderWork() {
QueryWrapper<YdOrderEntity> objectQueryWrapper = new QueryWrapper<>();
- objectQueryWrapper.eq("",YdOrderEntity.ORDER_STATE_READY);
+ objectQueryWrapper.eq("state",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);
+ if(ObjectUtil.isNotEmpty(workTime) && DateUtil.compare(date, workTime) > -1){
+ Long id = ydOrderEntity.getId();
+ ydOrderDao.UpdateByIdAndState(id,YdOrderEntity.ORDER_STATE_WORK);
}
}
}
@@ -46,7 +47,7 @@
/**
* 产品终止
*/
- @Scheduled(cron = "0/10 * * * * ?")
+ @Scheduled(cron = "0 0/1 * * * ?")
public void orderEnd() {
QueryWrapper<YdOrderEntity> objectQueryWrapper = new QueryWrapper<>();
objectQueryWrapper.eq("",YdOrderEntity.ORDER_STATE_WORK);
@@ -55,9 +56,9 @@
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);
+ if(ObjectUtil.isNotEmpty(endTime) && DateUtil.compare(date, endTime) > -1) {
+ Long id = ydOrderEntity.getId();
+ ydOrderDao.UpdateByIdAndState(id,YdOrderEntity.ORDER_STATE_END);
}
}
}
--
Gitblit v1.9.1