From e37cbe8c4d9cdf1f511135d302960faa04e12dd6 Mon Sep 17 00:00:00 2001 From: luxiaotao1123 <t1341870251@163.com> Date: 星期四, 06 四月 2023 10:51:22 +0800 Subject: [PATCH] # --- src/main/java/com/zy/asrs/service/WrkChargeService.java | 6 ++ src/main/java/com/zy/asrs/task/handler/WrkChargeHandler.java | 49 ++++++++++++++++++++++++ src/main/java/com/zy/asrs/task/WrkChargeScheduler.java | 30 +++++++++++++++ src/main/resources/mapper/WrkChargeMapper.xml | 7 +++ src/main/java/com/zy/asrs/service/impl/WrkChargeServiceImpl.java | 6 +++ src/main/java/com/zy/asrs/mapper/WrkChargeMapper.java | 4 ++ 6 files changed, 101 insertions(+), 1 deletions(-) diff --git a/src/main/java/com/zy/asrs/mapper/WrkChargeMapper.java b/src/main/java/com/zy/asrs/mapper/WrkChargeMapper.java index 88d6451..dc30024 100644 --- a/src/main/java/com/zy/asrs/mapper/WrkChargeMapper.java +++ b/src/main/java/com/zy/asrs/mapper/WrkChargeMapper.java @@ -5,8 +5,12 @@ import org.apache.ibatis.annotations.Mapper; import org.springframework.stereotype.Repository; +import java.util.List; + @Mapper @Repository public interface WrkChargeMapper extends BaseMapper<WrkCharge> { + List<WrkCharge> findTimeoutData(); + } diff --git a/src/main/java/com/zy/asrs/service/WrkChargeService.java b/src/main/java/com/zy/asrs/service/WrkChargeService.java index 43c9a52..b78b162 100644 --- a/src/main/java/com/zy/asrs/service/WrkChargeService.java +++ b/src/main/java/com/zy/asrs/service/WrkChargeService.java @@ -1,8 +1,12 @@ package com.zy.asrs.service; -import com.zy.asrs.entity.WrkCharge; import com.baomidou.mybatisplus.service.IService; +import com.zy.asrs.entity.WrkCharge; + +import java.util.List; public interface WrkChargeService extends IService<WrkCharge> { + List<WrkCharge> findTimeoutData(); + } diff --git a/src/main/java/com/zy/asrs/service/impl/WrkChargeServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/WrkChargeServiceImpl.java index 3e23acc..4afacbd 100644 --- a/src/main/java/com/zy/asrs/service/impl/WrkChargeServiceImpl.java +++ b/src/main/java/com/zy/asrs/service/impl/WrkChargeServiceImpl.java @@ -6,7 +6,13 @@ import com.baomidou.mybatisplus.service.impl.ServiceImpl; import org.springframework.stereotype.Service; +import java.util.List; + @Service("wrkChargeService") public class WrkChargeServiceImpl extends ServiceImpl<WrkChargeMapper, WrkCharge> implements WrkChargeService { + @Override + public List<WrkCharge> findTimeoutData() { + return this.baseMapper.findTimeoutData(); + } } diff --git a/src/main/java/com/zy/asrs/task/WrkChargeScheduler.java b/src/main/java/com/zy/asrs/task/WrkChargeScheduler.java new file mode 100644 index 0000000..9e72f3e --- /dev/null +++ b/src/main/java/com/zy/asrs/task/WrkChargeScheduler.java @@ -0,0 +1,30 @@ +package com.zy.asrs.task; + +import com.zy.asrs.task.core.ReturnT; +import com.zy.asrs.task.handler.WrkChargeHandler; +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 WrkChargeScheduler { + + private static final Logger log = LoggerFactory.getLogger(WrkChargeScheduler.class); + + @Autowired + private WrkChargeHandler wrkChargeHandler; + + @Scheduled(cron = "0/3 * * * * ? ") + private void execute(){ + ReturnT<String> returnT = wrkChargeHandler.start(); + if (!returnT.isSuccess()) { + log.error(returnT.getMsg()); + } + } + +} diff --git a/src/main/java/com/zy/asrs/task/handler/WrkChargeHandler.java b/src/main/java/com/zy/asrs/task/handler/WrkChargeHandler.java new file mode 100644 index 0000000..0d6ecf6 --- /dev/null +++ b/src/main/java/com/zy/asrs/task/handler/WrkChargeHandler.java @@ -0,0 +1,49 @@ +package com.zy.asrs.task.handler; + +import com.baomidou.mybatisplus.mapper.EntityWrapper; +import com.core.common.Cools; +import com.zy.asrs.entity.WrkCharge; +import com.zy.asrs.service.WrkChargeService; +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; + +import java.util.List; + +/** + * Created by vincent on 2020/7/7 + */ +@Service +public class WrkChargeHandler extends AbstractHandler<String> { + + @Autowired + private JdbcTemplate jdbcTemplate; + @Autowired + private WrkChargeService wrkChargeService; + + @Transactional + public ReturnT<String> start() { + try { + List<WrkCharge> wrkCharges = wrkChargeService.findTimeoutData(); + if (!Cools.isEmpty(wrkCharges)) { + for (WrkCharge wrkCharge : wrkCharges) { + wrkChargeService.delete(new EntityWrapper<WrkCharge>() + .eq("wrk_no", wrkCharge.getWrkNo()) + .eq("wrk_sts", wrkCharge.getWrkSts()) + .eq("ste_no", wrkCharge.getSteNo()) + ); + } + } + } catch (Exception e) { + e.printStackTrace(); + TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); + return FAIL.setMsg(e.getMessage()); + } + return SUCCESS; + } + +} diff --git a/src/main/resources/mapper/WrkChargeMapper.xml b/src/main/resources/mapper/WrkChargeMapper.xml index 5499e2a..6fe8ce7 100644 --- a/src/main/resources/mapper/WrkChargeMapper.xml +++ b/src/main/resources/mapper/WrkChargeMapper.xml @@ -29,4 +29,11 @@ </resultMap> + <select id="findTimeoutData" resultMap="BaseResultMap"> + select * from asr_wrk_charge + where 1=1 + and dateadd(mi,30,modi_time) <= getdate() + and wrk_sts not in (30, 47) + </select> + </mapper> -- Gitblit v1.9.1