From a63751400e4a3415326b0bb4302e6d55ea4826bf Mon Sep 17 00:00:00 2001
From: 刘小明 <liuxm_a@163.com>
Date: 星期四, 25 七月 2024 15:13:14 +0800
Subject: [PATCH] 定时任务修改

---
 pms-parent/pms-web-product/src/main/java/com/dy/pmsProduct/taskPlan/AssemblyPlanTask.java |   30 +++++++++++++++++-------------
 1 files changed, 17 insertions(+), 13 deletions(-)

diff --git a/pms-parent/pms-web-product/src/main/java/com/dy/pmsProduct/taskPlan/AssemblyPlanTask.java b/pms-parent/pms-web-product/src/main/java/com/dy/pmsProduct/taskPlan/AssemblyPlanTask.java
index 0be004a..553b033 100644
--- a/pms-parent/pms-web-product/src/main/java/com/dy/pmsProduct/taskPlan/AssemblyPlanTask.java
+++ b/pms-parent/pms-web-product/src/main/java/com/dy/pmsProduct/taskPlan/AssemblyPlanTask.java
@@ -22,20 +22,24 @@
     @Override
     public void execute(JobExecutionContext ctx) {
         log.info("寮�濮嬫墽琛� 缁勮璁″垝浠诲姟瀹氭椂妫�鏌�");
-        PrAssemblyPlanMapper assemblyDao = SpringContextUtil.getBean(PrAssemblyPlanMapper.class);
-        PrDeviceMapper deviceDao = SpringContextUtil.getBean(PrDeviceMapper.class);
-        Map<String,Object> planParams = new HashMap<>();
-        planParams.put("status",PlanStatusEnum.NORMAL.getCode());
-        List<PrAssemblyPlan> list = assemblyDao.selectSome(planParams);
-        for (PrAssemblyPlan plan : list) {
-            HashMap<String, Object> deviceParams = new HashMap<>();
-            deviceParams.put("batchId", plan.getBatchId());
-            deviceParams.put("status", DeviceStatus.COMPLETED.getCode());
-            Long count = deviceDao.selectSomeCount(deviceParams);
-            if(count>plan.number && DateUtil.between(DateUtil.parse(plan.endDate), DateUtil.date(), DateUnit.DAY)>3){
-                plan.setStatus(PlanStatusEnum.END.getCode());
-                assemblyDao.updateByPrimaryKeySelective(plan);
+        try{
+            PrAssemblyPlanMapper assemblyDao = SpringContextUtil.getBean(PrAssemblyPlanMapper.class);
+            PrDeviceMapper deviceDao = SpringContextUtil.getBean(PrDeviceMapper.class);
+            Map<String,Object> planParams = new HashMap<>();
+            planParams.put("status",PlanStatusEnum.NORMAL.getCode());
+            List<PrAssemblyPlan> list = assemblyDao.selectSome(planParams);
+            for (PrAssemblyPlan plan : list) {
+                HashMap<String, Object> deviceParams = new HashMap<>();
+                deviceParams.put("batchId", plan.getBatchId());
+                deviceParams.put("status", DeviceStatus.COMPLETED.getCode());
+                Long count = deviceDao.selectSomeCount(deviceParams);
+                if(count>plan.number && DateUtil.between(DateUtil.parse(plan.endDate), DateUtil.date(), DateUnit.DAY)>3){
+                    plan.setStatus(PlanStatusEnum.END.getCode());
+                    assemblyDao.updateByPrimaryKeySelective(plan);
+                }
             }
+        }catch (Exception e){
+            log.error("缁勮璁″垝浠诲姟瀹氭椂妫�鏌ュ紓甯�",e);
         }
         log.info("瀹屾垚 缁勮璁″垝浠诲姟瀹氭椂妫�鏌�");
     }

--
Gitblit v1.8.0