这是 小时的异常数据记录

src/main/java/com/cn/esermis/dpld/business/MonitorBusiness.java

@@ -10,6 +10,7 @@ import com.cn.esermis.dpld.service.*;
 import com.cn.esermis.model.CP;
 import com.cn.esermis.model.FactorModel;
 import lombok.extern.log4j.Log4j2;
+import org.apache.logging.log4j.core.util.UuidUtil;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Component;
@@ -41,7 +42,9 @@ public class MonitorBusiness {
     private IExcepLogService excepLogService;
     @Resource
     private IAirMonitorHourRecordService airMonitorHourRecordService;
-    @Autowired
+    @Resource
+    private IPostMarkingService postMarkingService;
+    @Resource
     private RedisTemplate<String, Object> redisTemplate;
 
 
@@ -104,9 +107,9 @@ public class MonitorBusiness {
                             airMonitorMinuteRecord.setIsLose(exceptionDataDispose.LoseData(x.getMax()!=null?x.getMax().doubleValue():0,
                                     x.getMin()!=null?x.getMin().doubleValue():0,
                                     x.getAvg()!=null?x.getAvg().doubleValue():0));
-                            if ((airMonitorMinuteRecord.getIsExceed()!=null && !airMonitorMinuteRecord.getIsExceed().equals("Y") )||
-                                    (airMonitorMinuteRecord.getIsLose()!=null && !airMonitorMinuteRecord.getIsLose().equals("Y") )||
-                                    (airMonitorMinuteRecord.getIsSix()!=null && !airMonitorMinuteRecord.getIsSix().equals("Y"))){
+                            if ((airMonitorMinuteRecord.getIsExceed()!=null && !airMonitorMinuteRecord.getIsExceed().equals("1") )||
+                                    (airMonitorMinuteRecord.getIsLose()!=null && !airMonitorMinuteRecord.getIsLose().equals("1") )||
+                                    (airMonitorMinuteRecord.getIsSix()!=null && !airMonitorMinuteRecord.getIsSix().equals("1"))){
                                 saveExcepLog(x, airMonitorMinuteRecord);
                             }
                         } catch (Exception e) {
@@ -185,15 +188,20 @@ public class MonitorBusiness {
                         airMonitorHourRecord.setZsMin(x.getZsMin());
                         airMonitorHourRecord.setRtd(x.getRtd());
                         try {
+                            airMonitorHourRecord.setWorkCondition(sendHoursMessage(factorModel.getDataTime(),factorModel.getMN()));
+                        } catch (Exception e) {
+                            throw new RuntimeException(e);
+                        }
+                        try {
                             airMonitorHourRecord.setIsExceed(exceptionDataDispose.ExceedData(factorModel.getMN(), x.getFactor(), x.getAvg()!=null?x.getAvg().doubleValue():x.getRtd().doubleValue()));
                             airMonitorHourRecord.setIsLose(exceptionDataDispose.LoseData(x.getMax()!=null?x.getMax().doubleValue():0,
                                     x.getMin()!=null?x.getMin().doubleValue():0,
                                     x.getAvg()!=null?x.getAvg().doubleValue():0));
                             airMonitorHourRecord.setIsSix(exceptionDataDispose.SixData(factorModel.getMN(), x.getFactor(),x.getAvg()!=null?x.getAvg().doubleValue():0, factorModel.getDataTime()));
 //                            if (!airMonitorHourRecord.getIsExceed().equals("Y") || !airMonitorHourRecord.getIsLose().equals("Y") || !airMonitorHourRecord.getIsSix().equals("Y")){
-                            if ((airMonitorHourRecord.getIsExceed()!=null && !airMonitorHourRecord.getIsExceed().equals("Y") )||
-                                    (airMonitorHourRecord.getIsLose()!=null && !airMonitorHourRecord.getIsLose().equals("Y") )||
-                                    (airMonitorHourRecord.getIsSix()!=null && !airMonitorHourRecord.getIsSix().equals("Y"))){
+                            if ((airMonitorHourRecord.getIsExceed()!=null && !airMonitorHourRecord.getIsExceed().equals("1") )||
+                                    (airMonitorHourRecord.getIsLose()!=null && !airMonitorHourRecord.getIsLose().equals("1") )||
+                                    (airMonitorHourRecord.getIsSix()!=null && !airMonitorHourRecord.getIsSix().equals("1"))){
                                 saveExcepLog(x, airMonitorHourRecord);
                             }
                         } catch (Exception e) {
@@ -234,9 +242,9 @@ public class MonitorBusiness {
                             waterMonitorMinuteRecord.setIsLose(exceptionDataDispose.LoseData(x.getMax()!=null?x.getMax().doubleValue():0,
                                     x.getMin()!=null?x.getMin().doubleValue():0,
                                     x.getAvg()!=null?x.getAvg().doubleValue():0));
-                            if ((waterMonitorMinuteRecord.getIsExceed()!=null && !waterMonitorMinuteRecord.getIsExceed().equals("Y") )||
-                                    (waterMonitorMinuteRecord.getIsLose()!=null && !waterMonitorMinuteRecord.getIsLose().equals("Y") )||
-                                    (waterMonitorMinuteRecord.getIsSix()!=null && !waterMonitorMinuteRecord.getIsSix().equals("Y"))){
+                            if ((waterMonitorMinuteRecord.getIsExceed()!=null && !waterMonitorMinuteRecord.getIsExceed().equals("1") )||
+                                    (waterMonitorMinuteRecord.getIsLose()!=null && !waterMonitorMinuteRecord.getIsLose().equals("1") )||
+                                    (waterMonitorMinuteRecord.getIsSix()!=null && !waterMonitorMinuteRecord.getIsSix().equals("1"))){
                                 saveExcepLog(x, waterMonitorMinuteRecord);
                             }
                         } catch (Exception e) {
@@ -311,14 +319,19 @@ public class MonitorBusiness {
                         waterMonitorHourRecord.setFactorFlag(x.getFlag());
                         waterMonitorHourRecord.setRtd(x.getRtd());
                         try {
+                            waterMonitorHourRecord.setWorkCondition(sendHoursMessage(factorModel.getDataTime(),factorModel.getMN()));
+                        } catch (Exception e) {
+                            throw new RuntimeException(e);
+                        }
+                        try {
                             waterMonitorHourRecord.setIsExceed(exceptionDataDispose.ExceedData(factorModel.getMN(), x.getFactor(), x.getAvg()!=null?x.getAvg().doubleValue():x.getRtd().doubleValue()));
                             waterMonitorHourRecord.setIsLose(exceptionDataDispose.LoseData(x.getMax()!=null?x.getMax().doubleValue():0,
                                     x.getMin()!=null?x.getMin().doubleValue():0,
                                     x.getAvg()!=null?x.getAvg().doubleValue():0));
                             waterMonitorHourRecord.setIsSix(exceptionDataDispose.SixData(factorModel.getMN(), x.getFactor(),x.getAvg()!=null?x.getAvg().doubleValue():0, factorModel.getDataTime()));
-                            if ((waterMonitorHourRecord.getIsExceed()!=null && !waterMonitorHourRecord.getIsExceed().equals("Y") )||
-                                    (waterMonitorHourRecord.getIsLose()!=null && !waterMonitorHourRecord.getIsLose().equals("Y") )||
-                                    (waterMonitorHourRecord.getIsSix()!=null && !waterMonitorHourRecord.getIsSix().equals("Y"))){
+                            if ((waterMonitorHourRecord.getIsExceed()!=null && !waterMonitorHourRecord.getIsExceed().equals("1") )||
+                                    (waterMonitorHourRecord.getIsLose()!=null && !waterMonitorHourRecord.getIsLose().equals("1") )||
+                                    (waterMonitorHourRecord.getIsSix()!=null && !waterMonitorHourRecord.getIsSix().equals("1"))){
                                 saveExcepLog(x, waterMonitorHourRecord);
                             }
                         } catch (Exception e) {
@@ -348,7 +361,15 @@ public class MonitorBusiness {
             excepLog.setLoseData(record.getIsLose());
             excepLogService.save(excepLog);
         }
-
+        if (record.getIsLose()!=null && !record.getIsLose().equals("1")){
+            addExcepLog(record.getFactor(), "1");
+        }
+        if (record.getIsSix()!=null && !record.getIsSix().equals("1")){
+            addExcepLog(record.getFactor(), "2");
+        }
+        if (record.getIsExceed()!=null && !record.getIsExceed().equals("1")){
+            addExcepLog(record.getFactor(), "3");
+        }
     }
 
     private void saveExcepLog(CP x, AirMonitorHourRecord record) {
@@ -364,6 +385,15 @@ public class MonitorBusiness {
             excepLog.setLoseData(record.getIsLose());
             excepLogService.save(excepLog);
         }
+        if (record.getIsLose()!=null && !record.getIsLose().equals("1")){
+            addExcepLog(record.getFactor(), "1");
+        }
+        if (record.getIsSix()!=null && !record.getIsSix().equals("1")){
+            addExcepLog(record.getFactor(), "2");
+        }
+        if (record.getIsExceed()!=null && !record.getIsExceed().equals("1")){
+            addExcepLog(record.getFactor(), "3");
+        }
     }
 
     private void saveExcepLog(CP x, WaterMonitorMinuteRecord record) {
@@ -379,6 +409,15 @@ public class MonitorBusiness {
             excepLog.setLoseData(record.getIsLose());
             excepLogService.save(excepLog);
         }
+        if (record.getIsLose()!=null && !record.getIsLose().equals("1")){
+            addExcepLog(record.getFactor(), "1");
+        }
+        if (record.getIsSix()!=null && !record.getIsSix().equals("1")){
+            addExcepLog(record.getFactor(), "2");
+        }
+        if (record.getIsExceed()!=null && !record.getIsExceed().equals("1")){
+            addExcepLog(record.getFactor(), "3");
+        }
     }
     private void saveExcepLog(CP x, WaterMonitorHourRecord record) {
         ExcepLog excepLog = new ExcepLog();
@@ -393,6 +432,15 @@ public class MonitorBusiness {
             excepLog.setLoseData(record.getIsLose());
             excepLogService.save(excepLog);
         }
+        if (record.getIsLose()!=null && !record.getIsLose().equals("1")){
+            addExcepLog(record.getFactor(), "1");
+        }
+        if (record.getIsSix()!=null && !record.getIsSix().equals("1")){
+            addExcepLog(record.getFactor(), "2");
+        }
+        if (record.getIsExceed()!=null && !record.getIsExceed().equals("1")){
+            addExcepLog(record.getFactor(), "3");
+        }
     }
 
     public Integer sendMessage(String time,String mn) throws ParseException {
@@ -407,6 +455,20 @@ public class MonitorBusiness {
         }
         return 1;
     }
+
+    public Integer sendHoursMessage(String time,String mn){
+        SimpleDateFormat formatter = new SimpleDateFormat("yyyyMMddHH");
+        Object o = redisTemplate.opsForValue().get(mn);
+        if (o != null){
+            PreMarking preMarking = JSON.parseObject(o.toString(), PreMarking.class);
+//            Date date = formatter.parse(time);
+            String format = formatter.format(preMarking.getStartTime().getTime());
+            if (time.contains(format)){
+                return preMarking.getWorkingCondition();
+            }
+        }
+        return 1;
+    }
     /**
      * 获取工厂排口信息
      */
@@ -421,5 +483,32 @@ public class MonitorBusiness {
         }
         return dataAcquisitionInstruments;
     }
+    /**
+     * 添加事后处置单信息
+     */
+    public void addExcepLog(String factor,String dataType) {
+        PostMarking postMarking = new PostMarking();
+        Optional<OutletAndFactorVo> first = getloadData().stream().filter(d -> d.getFactor()!=null && d.getFactor().equals(factor)).findFirst();
+        if (first.isPresent()) {
+            postMarking.setOutletName(first.get().getOutletName());
+            postMarking.setOutletNumber(first.get().getOutletCode());
+            postMarking.setManagementNumber(String.valueOf(UuidUtil.getTimeBasedUuid()));
+            switch (dataType){
+                case "1":
+                    //判断是否为负值数据
+                    postMarking.setManagementContent("数据异常:采集数据为负数。");
+                    break;
+                case "2":
+                    // //判断是否为六小时恒值数据
+                    postMarking.setManagementContent("数据异常：6小时恒值异常。");
+                    break;
+                case "3":
+                    //瞬时值是否为超标数据
+                    postMarking.setManagementContent("数据异常：瞬时值超标。");
+                    break;
+            }
+            postMarkingService.save(postMarking);
+        }
+    }
 
 }