储存超期报警-定时任务

src/main/java/com/chinaitop/depot/tasks/TempWetTask.java

@@ -1,17 +1,13 @@
 package com.chinaitop.depot.tasks;
 
-import com.chinaitop.depot.tempWarn.model.TTempWetThreshold;
+import com.chinaitop.depot.tempWarn.service.StorageThresholdAlarmService;
 import com.chinaitop.depot.tempWarn.service.TTempWetAlarmService;
 import com.chinaitop.depot.tempWarn.service.TTempWetThresholdService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
-import org.springframework.util.CollectionUtils;
 
 import javax.annotation.Resource;
-import java.util.Calendar;
-import java.util.List;
-import java.util.UUID;
 
 /**
  * @author qingsong.han
@@ -25,13 +21,15 @@ public class TempWetTask {
     private TTempWetThresholdService tempWetThresholdService;
     @Resource
     private TTempWetAlarmService tempWetAlarmService;
+    @Resource
+    private StorageThresholdAlarmService thresholdAlarmService;
 
     /**
      * 每年12月1日进行增一条下一年的设置数据,默认值与上一年保持一致
      */
     @Scheduled(cron = "0 0 0 1 12 ?") // 每年12月1号0点0分0秒触发任务
     public void tempWetYear() {
-        log.info("----每年12月1号0点0分0秒触发任务---");
+        log.info("----每年12月1号0点0分0秒触发任务----");
         tempWetThresholdService.saveNextYear();
     }
 
@@ -41,18 +39,18 @@ public class TempWetTask {
 //    @Scheduled(cron = "0 50 16 * * ?") // 测试
     @Scheduled(cron = "0 0 12 * * ?") // 每天中午12点触发任务
     public void tempWetWarning() {
-        log.info("----每天中午12点触发任务---");
+        log.info("----每天中午12点触发任务----");
         tempWetAlarmService.saveTempWetWarning();
     }
 
     /**
      * 每日中午12点，定时任务全平台进行算法计算
      */
-//    @Scheduled(cron = "0 50 16 * * ?") // 测试
-    @Scheduled(cron = "0 0 12 * * ?") // 每天中午12点触发任务
-    public void tempWetWarning1() {
-        log.info("----每天中午12点触发任务---");
-        tempWetAlarmService.saveTempWetWarning();
+    @Scheduled(cron = "0 0 0 11 * *") // 测试
+//    @Scheduled(cron = "0 0 0 1 * *") // 每月1号0点执行一次
+    public void saveAgeWaring() {
+        log.info("----每月1号0点执行一次----");
+        thresholdAlarmService.saveAgeWaring();
     }
 
 }

src/main/java/com/chinaitop/depot/tempWarn/controller/StorageThresholdAlarmController.java

@@ -37,4 +37,13 @@ public class StorageThresholdAlarmController {
             return ResponseEntity.failed("查询失败");
         }
     }
+
+    /**
+     * 测试过滤保存超期数据接口
+     */
+    /*@GetMapping("/saveAgeWaring")
+    @ApiOperation(value = "test", notes = "")
+    public void saveAgeWaring() {
+        thresholdAlarmService.saveAgeWaring();
+    }*/
 }

src/main/java/com/chinaitop/depot/tempWarn/mapper/StorageThresholdSetMapper.java

@@ -1,5 +1,6 @@
 package com.chinaitop.depot.tempWarn.mapper;
 
+import com.chinaitop.depot.tempWarn.model.StorageThresholdAlarm;
 import com.chinaitop.depot.tempWarn.model.StorageThresholdSet;
 import com.chinaitop.depot.tempWarn.model.StorageThresholdSetExample;
 import java.util.List;
@@ -31,4 +32,8 @@ public interface StorageThresholdSetMapper {
     int updateByPrimaryKey(StorageThresholdSet record);
 
     List<StorageThresholdSet> selectByExampleAndKqbm(String kqbm);
+
+    List<StorageThresholdAlarm> selectGrainCardList();
+
+    List<StorageThresholdSet> selectAll();
 }

src/main/java/com/chinaitop/depot/tempWarn/mapper/StorageThresholdSetMapper.xml

@@ -368,4 +368,36 @@
     left join basic_enum be on ts.lypz = be.gbcode
     where ts.kqdm = #{kqbm}
   </select>
+  <select id="selectGrainCardList" parameterType="java.lang.Object" resultType="com.chinaitop.depot.tempWarn.model.StorageThresholdAlarm">
+    select
+        gc.org_id orgId,
+        gc.storehouse_id houseId,
+        sq.quality hwxz,
+        sq.sub_type pz,
+        sq.number_update/1000 kcsl,
+        gc.scnd scnf,
+        be.enumname lypzmc
+    from
+        storage_grain_card gc
+    left join storage_qualitycheck sq on gc.qualitycheck_id = sq.id
+    left join basic_enum be on be.enumid = sq.sub_type
+    where
+        sfgd = '1'
+  </select>
+  <select id="selectAll" parameterType="java.lang.Object" resultType="com.chinaitop.depot.tempWarn.model.StorageThresholdSet">
+    select
+        ts.id,
+        ts.kqdm,
+        ts.lypz,
+        ts.mxpz,
+        ts.ccnx,
+        ts.knccnx,
+        ts.sptccnx,
+        be.enumname lypzmc,
+        oi.org_id orgId
+    from
+        storage_threshold_set ts
+    left join basic_enum be on ts.lypz = be.gbcode
+    left join org_info oi on oi.kqbm = ts.kqdm
+  </select>
 </mapper>

src/main/java/com/chinaitop/depot/tempWarn/model/StorageThresholdAlarm.java

@@ -8,25 +8,29 @@ import java.util.Date;
 public class StorageThresholdAlarm {
     private String id;
 
+    // 仓房id(basic_storehouse.storehouse_id)
     private Integer houseId;
-
+    // 性质id(basic_enum.enumid)
     private Integer hwxz;
-
+    // 品种id(basic_enum.enumid)
     private String pz;
-
+    // 库存数量(吨)
     private String kcsl;
-
+    // 生产年份
     private String scnf;
-
+    // 储备年限(年)
     private Integer knccnx;
-
+    // 储存超限时间
     private Date cccxsj;
-
+    // 报警信息
     private String bjxx;
-
+    // 报警时间
     private Date bjsj;
-
+    // 机构id(org_info.org_id)
     private Integer orgId;
-
+    // 0:市平台预警数据,1:库平台预警数据
     private Integer dataFlag;
+
+    // 业务数据
+    private String lypzmc;// 品种名称
 }

src/main/java/com/chinaitop/depot/tempWarn/model/StorageThresholdAlarmExample.java

@@ -826,6 +826,12 @@ public class StorageThresholdAlarmExample {
             addCriterion("org_id not between", value1, value2, "orgId");
             return (Criteria) this;
         }
+
+        // 后加
+        public Criteria andDataFlagEqualTo(Integer value) {
+            addCriterion("data_flag =", value, "dataFlag");
+            return (Criteria) this;
+        }
     }
 
     /**

src/main/java/com/chinaitop/depot/tempWarn/model/StorageThresholdSet.java

@@ -37,4 +37,5 @@ public class StorageThresholdSet {
 
     // 业务数据
     private String lypzmc;// 品种名称
+    private Integer orgId;// 机构id
 }

src/main/java/com/chinaitop/depot/tempWarn/service/StorageThresholdAlarmService.java

@@ -12,4 +12,6 @@ import java.util.List;
  */
 public interface StorageThresholdAlarmService {
     List<StorageThresholdAlarm> getPageList(StorageThresholdAlarmPageParam pageParam);
+
+    void saveAgeWaring();
 }

src/main/java/com/chinaitop/depot/tempWarn/service/impl/StorageThresholdAlarmServiceImpl.java

@@ -1,34 +1,141 @@
 package com.chinaitop.depot.tempWarn.service.impl;
 
 import com.chinaitop.depot.tempWarn.mapper.StorageThresholdAlarmMapper;
+import com.chinaitop.depot.tempWarn.mapper.StorageThresholdSetMapper;
 import com.chinaitop.depot.tempWarn.model.StorageThresholdAlarm;
 import com.chinaitop.depot.tempWarn.model.StorageThresholdAlarmExample;
+import com.chinaitop.depot.tempWarn.model.StorageThresholdSet;
+import com.chinaitop.depot.tempWarn.model.StorageThresholdSetExample;
 import com.chinaitop.depot.tempWarn.param.StorageThresholdAlarmPageParam;
 import com.chinaitop.depot.tempWarn.service.StorageThresholdAlarmService;
+import com.chinaitop.depot.utils.DateUtil;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
+import org.springframework.util.CollectionUtils;
 import org.springframework.util.ObjectUtils;
 
 import javax.annotation.Resource;
+import java.time.LocalDate;
+import java.time.ZoneId;
+import java.util.Date;
 import java.util.List;
+import java.util.UUID;
 
 /**
  * @author qingsong.han
  * @description:
  * @create 2024-12-09 17:08
  */
+@Slf4j
 @Service
 public class StorageThresholdAlarmServiceImpl implements StorageThresholdAlarmService {
     @Resource
     private StorageThresholdAlarmMapper thresholdAlarmMapper;
+    @Resource
+    private StorageThresholdSetMapper thresholdSetMapper;
 
     @Override
     public List<StorageThresholdAlarm> getPageList(StorageThresholdAlarmPageParam pageParam) {
         StorageThresholdAlarmExample example = new StorageThresholdAlarmExample();
         StorageThresholdAlarmExample.Criteria criteria = example.createCriteria();
         criteria.andOrgIdEqualTo(pageParam.getOrgId());
+        criteria.andDataFlagEqualTo(1);
         if (!ObjectUtils.isEmpty(pageParam.getHouseId())) {
             criteria.andHouseIdEqualTo(pageParam.getHouseId());
         }
         return thresholdAlarmMapper.selectByExample(example);
     }
+
+    @Override
+    public void saveAgeWaring() {
+        // 查询库内报警值
+        List<StorageThresholdSet> storageThresholdSets = thresholdSetMapper.selectAll();
+        if (!CollectionUtils.isEmpty(storageThresholdSets)) {
+            // 查询粮情卡数据
+            List<StorageThresholdAlarm> listCar = thresholdSetMapper.selectGrainCardList();
+            if (!CollectionUtils.isEmpty(listCar)) {
+                // 获取当前时间
+                LocalDate now = LocalDate.now();
+                String nowStr = now.toString();
+                log.info("nowStr: {}", nowStr);
+                // 转换为储存超限时间类型
+                Date nowDate = Date.from(now.atStartOfDay(ZoneId.systemDefault()).toInstant());
+                // 比对是否超限
+                storageThresholdSets.forEach(set -> {
+                    // 市平台设置
+                    Integer sptccnx = set.getSptccnx();
+                    // 库内设置
+                    Integer knccnx = set.getKnccnx();
+                    // 任意一个设置都执行过滤报警
+                    if (!ObjectUtils.isEmpty(knccnx) || !ObjectUtils.isEmpty(sptccnx)) {
+                        listCar.forEach(alarm -> {
+                            // 对比品种
+                            if (set.getLypzmc().equals(alarm.getLypzmc())) {
+                                // 生产年份
+                                String scnf = alarm.getScnf();
+                                if (set.getOrgId().equals(alarm.getOrgId())) {
+                                    if (!ObjectUtils.isEmpty(scnf)) {
+                                        // 市平台报警
+                                        if (!ObjectUtils.isEmpty(sptccnx)) {
+                                            // 生产年份+设置超限年份=已储年份
+                                            int sptccnxPK = Integer.parseInt(scnf) + sptccnx;// 到期
+                                            // 计算超期时间
+                                            String cccxsjStr = String.format("%s%s", sptccnxPK, "-01-01");
+                                            Date cccxsj = DateUtil.stringToData(cccxsjStr, "yyyy-MM-dd");
+                                            // 是否超限
+                                            log.info("市平台 cccxsjStr: {} nowStr: {}", cccxsjStr, nowStr);
+                                            if (nowStr.equals(cccxsjStr)) {
+                                                alarm.setId(UUID.randomUUID().toString());
+                                                alarm.setDataFlag(0);
+                                                alarm.setKnccnx(sptccnx);
+                                                alarm.setCccxsj(cccxsj);
+                                                alarm.setBjxx("已超过存储期限要求");
+                                                alarm.setBjsj(nowDate);
+                                                thresholdAlarmMapper.insertSelective(alarm);
+                                            }
+                                        }
+                                        // 库平台报警
+                                        if (!ObjectUtils.isEmpty(knccnx)) {
+                                            // 是否超限
+                                            int knccnxPK = Integer.parseInt(scnf) + knccnx;
+                                            String cccxsjStr = String.format("%s%s", knccnxPK, "-01-01");
+//                                            String cccxsjStr = String.format("%s%s", knccnxPK, "-12-10");// 测试
+                                            // 提前3个月报警
+                                            String localDate_3 = now.minusMonths(3).toString();
+                                            // 提前1个月报警
+                                            String localDate_1 = now.minusMonths(1).toString();
+                                            // 保存
+                                            alarm.setId(UUID.randomUUID().toString());
+                                            alarm.setDataFlag(1);
+                                            alarm.setKnccnx(knccnx);
+                                            alarm.setBjsj(nowDate);
+                                            log.info("库平台 cccxsjStr: {} nowStr: {}", cccxsjStr, nowStr);
+                                            if (nowStr.equals(cccxsjStr)) {
+                                                Date cccxsj = DateUtil.stringToData(cccxsjStr, "yyyy-MM-dd");
+                                                alarm.setCccxsj(cccxsj);
+                                                alarm.setBjxx("已超过存储期限要求");
+                                                thresholdAlarmMapper.insertSelective(alarm);
+                                            } else if (localDate_3.equals(cccxsjStr)) {
+                                                Date cccxsj = DateUtil.stringToData(localDate_3, "yyyy-MM-dd");
+                                                alarm.setCccxsj(cccxsj);
+                                                alarm.setBjxx("距离超过储存期限还有3个月");
+                                                thresholdAlarmMapper.insertSelective(alarm);
+                                            }  else if (localDate_1.equals(cccxsjStr)) {
+                                                Date cccxsj = DateUtil.stringToData(localDate_1, "yyyy-MM-dd");
+                                                alarm.setCccxsj(cccxsj);
+                                                alarm.setBjxx("距离超过储存期限还有1个月");
+                                                thresholdAlarmMapper.insertSelective(alarm);
+                                            }
+                                        }
+                                    }
+                                }
+                            }
+                        });
+                    }
+                });
+            }
+        }
+
+    }
+
 }