From 7c585586e9bea943161676bd9d127e81123891c3 Mon Sep 17 00:00:00 2001
From: baoshiwei <baoshiwei@shlanbao.cn>
Date: 星期三, 11 十二月 2024 11:01:35 +0800
Subject: [PATCH] Merge branch 'refs/heads/master' into herb

---
 jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/service/impl/DryRealTimeDataServiceImpl.java |  366 +++++++++++++++++++++++++++++++++++++++++++--------
 1 files changed, 305 insertions(+), 61 deletions(-)

diff --git a/jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/service/impl/DryRealTimeDataServiceImpl.java b/jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/service/impl/DryRealTimeDataServiceImpl.java
old mode 100644
new mode 100755
index cb98cfc..8def570
--- a/jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/service/impl/DryRealTimeDataServiceImpl.java
+++ b/jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/service/impl/DryRealTimeDataServiceImpl.java
@@ -1,42 +1,40 @@
 package org.jeecg.modules.dry.service.impl;
 
 import cn.hutool.core.bean.BeanUtil;
+import cn.hutool.core.thread.ThreadUtil;
+import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.alibaba.fastjson.TypeReference;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import lombok.extern.slf4j.Slf4j;
-import org.apache.mina.core.service.IoAcceptor;
-import org.apache.mina.core.service.IoHandler;
+import org.apache.commons.lang3.StringUtils;
 import org.apache.mina.core.session.IoSession;
-import org.jeecg.common.api.CommonAPI;
+import org.eclipse.paho.client.mqttv3.MqttException;
+import org.eclipse.paho.client.mqttv3.MqttMessage;
 import org.jeecg.common.api.vo.Result;
 import org.jeecg.common.config.TenantContext;
-import org.jeecg.common.config.mqtoken.UserTokenContext;
+import org.jeecg.common.constant.CommonCacheConstant;
 import org.jeecg.common.constant.CommonConstant;
+import org.jeecg.common.constant.MqttConstant;
 import org.jeecg.common.system.util.JwtUtil;
+import org.jeecg.common.util.DateUtils;
 import org.jeecg.common.util.RedisUtil;
 import org.jeecg.common.util.SpringContextUtils;
-import org.jeecg.modules.dry.api.JeecgSystemApi;
 import org.jeecg.modules.dry.common.CacheConstants;
 import org.jeecg.modules.dry.entity.*;
+import org.jeecg.modules.dry.mqtt.MqMessage;
+import org.jeecg.modules.dry.mqtt.MqttUtil;
 import org.jeecg.modules.dry.service.*;
 import org.jeecg.modules.dry.socket.ServerHandler;
-import org.jeecg.modules.dry.socket.SocketServerConfig;
-import org.jeecg.modules.dry.util.DryUtil;
 import org.jeecg.modules.dry.vo.*;
-import org.jetbrains.annotations.NotNull;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
-import java.io.IOException;
-import java.io.ObjectOutputStream;
-import java.net.Socket;
 import java.text.DecimalFormat;
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
+import java.util.*;
+import java.util.stream.Collectors;
 
 @Slf4j
 @Service
@@ -50,6 +48,9 @@
     private IDryHerbService herbService;
 
     @Autowired
+    private IDryHerbFormulaService dryHerbFormulaService;
+
+    @Autowired
     private IDryEquipmentService equipmentService;
 
     @Autowired
@@ -59,11 +60,16 @@
     private IDryProdRecordService prodRecordService;
 
     @Autowired
-    private CommonAPI commonAPI;
+    private IDryFaultRecordService faultRecordService;
+
 
     private String token;
 
+    @Value(value = "${jeecg.mqtt.role}")
+    private String role;
 
+    @Autowired
+    private MqttUtil mqttUtil;
 
     public String getTemporaryToken() {
         if (token == null) {
@@ -82,7 +88,7 @@
     @Transactional
     public Result<?> realTimeDataHandle(RealTimeDataVo realTimeDataVo) {
         TenantContext.setTenant(realTimeDataVo.getTenantid()+"");
-        log.info("瀹炴椂鏁版嵁锛�"+realTimeDataVo.toString());
+       // log.info("瀹炴椂鏁版嵁锛�"+realTimeDataVo.toString());
 
 
         // 1 鏌ヨ鎴栧垱寤哄伐鍗�
@@ -97,10 +103,15 @@
             // 鏍规嵁绉熸埛id鍜屽伐鍗曞彿鏌ヨ鏁版嵁搴撴槸鍚︽湁璁板綍锛屾湁鍒欒繑鍥烇紝娌℃湁鍒欐柊澧炰竴鏉″啀杩斿洖
             orderVo = getOrSaveDryOrderVoDB(realTimeDataVo);
         }
+        if (orderVo == null) {
+            log.error("宸ュ崟涓嶅瓨鍦紝宸ュ崟鍙凤細"+realTimeDataVo.getWorkorder()+",璁惧锛�" + realTimeDataVo.getMachineid() +",鑽潗锛�" + realTimeDataVo.getName());
+            return Result.error("宸ュ崟涓嶅瓨鍦�");
+        }
 
         // 2 鏇存柊宸ュ崟瀹炴椂鏁版嵁
         // 2.1 灏嗗伐鍗曚腑鐨勬暟鎹浛鎹负鏈�鏂版暟鎹�
         realTimeDataVo.setOrderId(orderVo.getId());
+
         orderVo.setInitial(realTimeDataVo.getMoisture1());
         orderVo.setDryTime(realTimeDataVo.getTime3());
         orderVo.setDelay(realTimeDataVo.getDelay());
@@ -125,7 +136,7 @@
         orderVo.setState_valve(realTimeDataVo.getState_valve());
         orderVo.setOrderStatus(realTimeDataVo.getWorkorder_status());
         orderVo.setEqp_status(realTimeDataVo.getEqp_status());
-        orderVo.setEqp_state(realTimeDataVo.getEqp_state());
+//        orderVo.setEqp_state(realTimeDataVo.getEqp_state());
         orderVo.setWarning(realTimeDataVo.getEqp_warning());
         orderVo.setFault(realTimeDataVo.getEqp_fault());
         orderVo.setLevel(realTimeDataVo.getLevel());
@@ -187,7 +198,7 @@
         orderVo.getBellowsTemp().put(realTimeDataVo.getTime3(), realTimeDataVo.getTemp2());
         // 2.3 鏇存柊鍒皉edis缂撳瓨
         redisUtil.hset(CacheConstants.RedisKeyEnum.WORK_ORDER.getCode(),
-                realTimeDataVo.getTenantid()+"_"+realTimeDataVo.getMachineid(),orderVo, 600000);
+                realTimeDataVo.getTenantid()+"_"+realTimeDataVo.getMachineid(),orderVo, 60*60);
         return Result.ok();
     }
 
@@ -220,6 +231,7 @@
             }
         // 3 鏁版嵁搴撴病鏈夊垯鏂板涓�鏉℃暟鎹�
         } else {
+
             orderVo = saveNewOrder(realTimeDataVo);
         }
         return orderVo;
@@ -230,17 +242,26 @@
      * @param realTimeDataVo
      * @return
      */
-    @NotNull
     private DryOrderVo saveNewOrder(RealTimeDataVo realTimeDataVo) {
         DryOrderVo orderVo;
-        // 鏌ヨ鑽潗
-        DryHerb herb =  queryHerbByIndexTenant(realTimeDataVo);
+
         // 鏌ヨ璁惧
         DryEquipment equ = queryEquipmentByCodeTenant(realTimeDataVo);
+        if (equ == null) {
+            log.error("鏈壘鍒拌澶囷細"+realTimeDataVo.getIndex() +","+realTimeDataVo.getName() +",鏈哄彴锛�" + realTimeDataVo.getMachineid());
+            return null;
+        }
+        // 鏌ヨ鑽潗
+        DryHerbFormula herbFormula =  queryHerbByIndexTenant(realTimeDataVo);
 
+        if (herbFormula == null) {
+            log.error("鏈壘鍒拌嵂鏉愶細"+realTimeDataVo.getIndex() +","+realTimeDataVo.getName() +",鏈哄彴锛�" + realTimeDataVo.getMachineid());
+            return null;
+        }
         // 鍒涘缓鏂板伐鍗�
         orderVo = new DryOrderVo(realTimeDataVo);
-        orderVo.setHerbId(herb.getId());
+
+        orderVo.setHerbId(herbFormula.getId());
         orderVo.setEquId(equ.getId());
         DryOrder dryOrder = BeanUtil.toBean(orderVo, DryOrder.class);
         boolean save = dryOrderService.save(dryOrder);
@@ -259,8 +280,24 @@
         queryWrapper.eq(DryEquipment::getCode, realTimeDataVo.getMachineid());
         DryEquipment one = equipmentService.getOne(queryWrapper);
         if (one == null) {
-            one = new DryEquipment(realTimeDataVo);
-            equipmentService.save(one);
+            log.error(role+"淇濆瓨瀹炴椂鏁版嵁锛屾湭鎵惧埌璁惧锛�"+realTimeDataVo.getMachineid());
+//            one = new DryEquipment(realTimeDataVo);
+//            equipmentService.save(one);
+            if (MqttConstant.ROLE_ADMIN.equals(role)) {
+                MqttMessage mqttMessage = new MqttMessage();
+                mqttMessage.setQos(0);
+                JSONObject object = new JSONObject();
+                object.put("code", realTimeDataVo.getMachineid());
+                object.put("tenantId", realTimeDataVo.getTenantid());
+                mqttMessage.setPayload(object.toJSONString().getBytes());
+                try {
+                    mqttUtil.getMqttClient().publish(MqttConstant.SERVICE_REQ_PREFIX ,mqttMessage);
+                }catch (MqttException e) {
+                    e.printStackTrace();
+                }
+
+            }
+            return null;
         }
         return one;
     }
@@ -270,14 +307,16 @@
      * @param realTimeDataVo
      * @return
      */
-    private DryHerb queryHerbByIndexTenant(RealTimeDataVo realTimeDataVo) {
-        LambdaQueryWrapper<DryHerb> queryWrapper = new LambdaQueryWrapper<>();
-        queryWrapper.eq(DryHerb::getTenantId, realTimeDataVo.getTenantid());
-        queryWrapper.eq(DryHerb::getCode, realTimeDataVo.getIndex());
-        DryHerb one = herbService.getOne(queryWrapper);
+    private DryHerbFormula queryHerbByIndexTenant(RealTimeDataVo realTimeDataVo) {
+        LambdaQueryWrapper<DryHerbFormula> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(DryHerbFormula::getTenantId, realTimeDataVo.getTenantid());
+        queryWrapper.eq(DryHerbFormula::getName, realTimeDataVo.getName());
+        DryHerbFormula one = dryHerbFormulaService.getOne(queryWrapper);
         if (one == null) {
-            one = new DryHerb(realTimeDataVo);
-            herbService.save(one);
+            one = new DryHerbFormula(realTimeDataVo);
+            DryEquipment dryEquipment = equipmentService.selectByTenantIdEquipmentId(realTimeDataVo.getTenantid() + "", realTimeDataVo.getMachineid());
+            one.setEqpType(dryEquipment.getType());
+            dryHerbFormulaService.save(one);
         }
         return one;
     }
@@ -289,8 +328,8 @@
      */
     private void saveOrderTrendVo(DryOrderTrendVo trendVo, DryOrderVo orderVo) {
         //鍒ゆ柇 瀹炴椂鍚按鐜� 鎴� 瀹炴椂閲嶉噺鏈夋病鏈夊彉鍖栵紝鏈夊彉鍖栧垯鏇存柊
-        if(orderVo.getTrendVo() == null
-                || trendVo.getWeight() < orderVo.getTrendVo().getWeight()
+        if(orderVo.getTrendVo() == null && trendVo != null && trendVo.getWeight() > 0
+                || orderVo.getTrendVo()!=null &&  trendVo.getWeight() < orderVo.getTrendVo().getWeight()
                 ) {
             DryOrder byId = dryOrderService.getById(orderVo.getId());
             // 灏嗘渶鏂扮粨鏋滄洿鏂板埌宸ュ崟
@@ -316,43 +355,57 @@
     public Result<?> queryMachineRealTImeData(RealTimeDataVo realTimeDataVo) {
         TenantContext.setTenant(realTimeDataVo.getTenantid()+"");
 
-
+        // 鏌ヨ鎵�鏈夋満鍙�,鏌ヨ璇彞缁勮
         LambdaQueryWrapper<DryEquipment> queryWrapper = new LambdaQueryWrapper<>();
-
         queryWrapper.eq(DryEquipment::getTenantId, realTimeDataVo.getTenantid());
         queryWrapper.eq(DryEquipment::getEnable, "Y");
-
+        queryWrapper.orderByAsc(DryEquipment::getCode);
+        // 鏌ヨ鎵�鏈夋満鍙�
         List<DryEquipment> dryEquipments = equipmentService.list(queryWrapper);
+        // 鏈哄彴鍒楄〃锛岀敤浜庢晥鐜囧姣�
         List<String> list = new ArrayList<>();
-
+        // 鏁堢巼鍒楄〃锛岀敤浜庢晥鐜囧姣�
         List<Double> dList = new ArrayList<>();
+        // 鏌ヨ褰撳墠鏈哄彴宸ュ崟
         DryOrderVo orderVo = (DryOrderVo) redisUtil.hget(CacheConstants.RedisKeyEnum.WORK_ORDER.getCode(), realTimeDataVo.getTenantid() + "_" + realTimeDataVo.getMachineid());
-            try {
+        try {
+            // 濡傛灉鏈夊彲鐢ㄦ満鍙�
+            if (dryEquipments != null && dryEquipments.size() > 0) {
+                // 鏌ヨ鍏跺畠鏈哄彴宸ュ崟
+                dryEquipments.stream().forEach(item -> {
+                    // 鑾峰彇宸ュ崟
+                    DryOrderVo order = (DryOrderVo) redisUtil.hget(CacheConstants.RedisKeyEnum.WORK_ORDER.getCode(), realTimeDataVo.getTenantid() + "_" + item.getCode());
+                    list.add(item.getName().substring(0, item.getName().indexOf('#')+1));
+                    if (order != null) {
+                        // 璁$畻骞茬嚗鏁堢巼锛岀敤浜庡姣�
+                        DryOrderTrendVo dryOrderTrendVo = order.getDetailList().get(order.getDetailList().size() - 1);
+                        double v = order.getOriginWeight() - dryOrderTrendVo.getWeight();
 
-
-                if (dryEquipments != null && dryEquipments.size() > 0) {
-                    dryEquipments.stream().forEach(item -> {
-                        DryOrderVo order = (DryOrderVo) redisUtil.hget(CacheConstants.RedisKeyEnum.WORK_ORDER.getCode(), realTimeDataVo.getTenantid() + "_" + item.getCode());
-                        if (order != null) {
-                            double v = order.getOriginWeight() - order.getYield();
-                            list.add(item.getName().substring(0, item.getName().indexOf('#')+1));
-                            if (v > 0 && order.getDryTime()>0) {
-                                DecimalFormat df = new DecimalFormat("#.00");
-                                dList.add(Double.valueOf(df.format(v / order.getDryTime() * 60)));
-                            } else {
-                                dList.add(50d);
-                            }
-
+                        if (v > 0 && dryOrderTrendVo.getTotalTime()>0) {
+                            DecimalFormat df = new DecimalFormat("#.00");
+                            dList.add(Double.valueOf(df.format(v / dryOrderTrendVo.getTotalTime() * 60)));
+                        } else {
+                            dList.add(50d);
                         }
-                    });
-                }
-                if (orderVo != null) {
-                    orderVo.setCompEqpNum(list);
-                    orderVo.setCompEqpEffic(dList);
-                }
-            }catch (Exception e) {
-                e.printStackTrace();
+
+                    } else {
+                        // 濡傛灉娌℃湁鐢熶骇锛屾晥鐜囩疆0
+                        dList.add(0d);
+                    }
+
+                });
             }
+
+            if (orderVo != null) {
+                // 灏嗘晥鐜囧姣旀暟鎹斁鍏ュ綋鍓嶆満鍙板疄鏃舵暟鎹腑杩斿洖
+                orderVo.setCompEqpNum(list);
+                orderVo.setCompEqpEffic(dList);
+                // 鏌ヨ杩戝崄娆℃晥鐜囧拰鑳借兘鑰楀钩鍧�
+                dryOrderService.queryRecentOrderAvg(orderVo);
+            }
+        }catch (Exception e) {
+            e.printStackTrace();
+        }
         return Result.ok(orderVo);
     }
 
@@ -387,4 +440,195 @@
      //   });
         return Result.OK();
     }
+
+
+    @Override
+    public Result<?> queryWorkshopStatistics(RealTimeDataVo realTimeDataVo) {
+        LambdaQueryWrapper<DryEquipment> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(DryEquipment::getTenantId, realTimeDataVo.getTenantid());
+        queryWrapper.eq(DryEquipment::getEnable, "Y");
+        List<DryEquipment> dryEquipments = equipmentService.list(queryWrapper);
+        DryOrderVo orderVo = new DryOrderVo();
+        if (dryEquipments != null && dryEquipments.size() > 0) {
+            dryEquipments.stream().forEach(item -> {
+                DryOrderVo order = (DryOrderVo) redisUtil.hget(CacheConstants.RedisKeyEnum.WORK_ORDER.getCode(), realTimeDataVo.getTenantid() + "_" + item.getCode());
+                if (order != null) {
+                    orderVo.setEnvHum(order.getEnvHum());
+                    orderVo.setEnvTemp(order.getEnvTemp());
+                    double watt = order.getWatt() - order.getDetailList().get(0).getWatt();
+                    orderVo.setWatt(orderVo.getWatt()==null? watt : orderVo.getWatt() + watt);
+                    double steam = order.getSteam() - order.getDetailList().get(0).getSteam();
+                    orderVo.setSteam(orderVo.getSteam()==null? steam : orderVo.getSteam() + steam);
+                    orderVo.setOriginWeight(orderVo.getOriginWeight()==null? order.getOriginWeight(): orderVo.getOriginWeight() + order.getOriginWeight());
+
+                    double yield = order.getOriginWeight()*(1-(order.getInitial()/100))/(1-(order.getTarget()/100));
+                    orderVo.setYield(orderVo.getYield()==null? yield: orderVo.getYield() + yield);
+                    double sub = order.getOriginWeight() - order.getYield();
+                    orderVo.setReduce(orderVo.getReduce()==null? sub: orderVo.getReduce() + sub);
+
+
+                }
+            });
+        }
+        //redisUtil.get(CacheConstants.RedisKeyEnum.WORK_ORDER.getCode()
+        return Result.OK(orderVo);
+    }
+
+    @Override
+    public Result<?> statisticsDataHandle(StatisticsDataVo statsDataVo) {
+        return null;
+    }
+
+    @Override
+    public Result<?> fitFultRecord(RealTimeDataVo vo) {
+        TenantContext.setTenant(vo.getTenantid()+"");
+        ThreadUtil.execute(() -> {
+            try {
+                //瑙f瀽瀛樺偍鎶ヨ鏁版嵁
+                List<DryFaultRecord> faultRecords1 = fitFault(vo.getEqp_fault(), vo.getWorkorder(), vo.getTenantid(), vo.getMachineid(), 1);
+                List<DryFaultRecord> faultRecords2 = fitFault(vo.getEqp_warning(), vo.getWorkorder(), vo.getTenantid(), vo.getMachineid(), 2);
+                faultRecords1.addAll(faultRecords2);
+
+
+                //澶勭悊缁撴潫鍚庯紝灏唕edis涓疄鏃舵暟鎹彂閫佽嚦浜戞湇鍔″櫒
+                    Map<Object, Object> toCloudFaultMap = redisUtil.hmget(MqttConstant.MQTT_REAL_FAULT);
+                    if(!toCloudFaultMap.isEmpty()){
+                        MqMessage< Map<Object, Object>> message = new MqMessage<>();
+                        message.setData(toCloudFaultMap);
+                        message.setTentId(vo.getTenantid()+"");
+                        MqttMessage mqttMessage = new MqttMessage();
+                        mqttMessage.setQos(0);
+                        mqttMessage.setPayload(JSON.toJSONString(message).getBytes());
+                        mqttUtil.getMqttClient().publish(MqttConstant.TENANT_UP_PREFIX_REAL_FAULT_DATA,mqttMessage);
+                    }
+
+
+                //瑕佷繚瀛樼殑鍘嗗彶鏁呴殰
+                if(!faultRecords1.isEmpty()){
+                    MqMessage<List<DryFaultRecord>> message = new MqMessage<>();
+                    message.setData(faultRecords1);
+                    message.setTentId(vo.getTenantid()+"");
+                    MqttMessage mqttMessage = new MqttMessage();
+                    mqttMessage.setQos(0);
+                    mqttMessage.setPayload((JSON.toJSONString(message).getBytes()));
+                    mqttUtil.getMqttClient().publish(MqttConstant.TENANT_UP_PREFIX_FAULT_DATA,mqttMessage);
+                }
+
+
+
+
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+        });
+
+        return null;
+    }
+
+
+    /**
+     * 瑙f瀽瀛樺偍鏁呴殰鏁版嵁
+     * TODO 淇濊瘉鍘熷瓙鎬�
+     * @param fault 鏁呴殰鏁版嵁
+     * @param orderId 宸ュ崟
+     * @param tenantId 绉熸埛
+     * @param machineId 璁惧
+     * @param faultType 鏁呴殰绫诲瀷
+     * @return 缁勮濂芥晠闅滄暟鎹�
+     */
+    private List<DryFaultRecord> fitFault(String fault, String orderId,Integer tenantId,String machineId,Integer faultType){
+        List<DryFaultRecord> result = new ArrayList<>();
+        //鏁版嵁鏍锋湰锛�"eqp_fault": "婊氱瓛闄嶈秴鏃�-鎶ヨ,椋庢満杩囨祦鎶ヨ,婊氱瓛鍗囪秴鏃�-鎶ヨ,椋庣鍗囨姤璀�",
+        System.err.println((faultType == 1 ? "绫诲瀷锛氭晠闅�" : "绫诲瀷锛氭姤璀�") +  DateUtils.formatDateTime()+"--"+fault);
+        //redis涓殑鏁呴殰
+        Map<Object, Object> rFauMap = redisUtil.hmget(MqttConstant.MQTT_REAL_FAULT);
+        Map<String, Object> redFauMap = rFauMap.entrySet().stream()
+                .collect(Collectors.toMap(
+                        entry -> entry.getKey().toString(),  // 閿浆鎹负瀛楃涓�
+                        entry -> entry.getValue()
+                ));
+
+        //娌℃湁鐢熸垚宸ュ崟鐨勬晠闅滄暟鎹笉瀛樺偍
+        if(StringUtils.isEmpty(orderId)){
+            return result;
+        }
+
+        if(StringUtils.isEmpty(fault) && rFauMap.isEmpty()){
+            return result;
+        }
+        //1.瑙f瀽鏁版嵁
+        String[] eqpFaults = fault.split(",");
+        Map<String,DryFaultRecord> addFauMap = new HashMap<>();
+        Map<String,DryFaultRecord> realFauMap = new HashMap<>();
+        for (int i = 0; i < eqpFaults.length; i++) {
+            String eqpFault = eqpFaults[i];
+            //閬垮厤绌哄瓧绗︿覆
+            if(StringUtils.isEmpty(eqpFault.trim())) continue;
+            //1.1妫�鏌qtt涓槸鍚﹀凡瀛樺湪杩欎釜鏁呴殰
+            String redisKey = String.format("%s_%s_%s", tenantId, machineId,eqpFault).trim();
+
+
+            realFauMap.put(redisKey, new DryFaultRecord());
+            DryFaultRecordVo  rFault = (DryFaultRecordVo) redisUtil.hget(MqttConstant.MQTT_REAL_FAULT,redisKey);
+            //1.2濡傛灉redis涓嶅瓨鍦ㄥ垯瀛樺叆锛堝瓨鏁呴殰寮�濮嬶級
+            if(rFault ==null){
+                //缁勮缂撳瓨鏁版嵁
+//                DryFaultRecord faultRecord = new DryFaultRecord(orderId,tenantId,eqpFault,faultType,new Date(),null);
+//                addFauMap.put(redisKey,faultRecord);
+                Map<String, DryEquipment> equipmentMap = equipmentService.queryEquByTenantId(tenantId);
+                String tenantName = (String) redisUtil.hget(CommonCacheConstant.SYS_CACHE_TENANT, tenantId + "");
+                DryFaultRecordVo vo = new DryFaultRecordVo(orderId,tenantId,eqpFault,faultType,new Date(),null,1,equipmentMap.get(machineId).getName(),tenantName);
+                addFauMap.put(redisKey,vo);
+            }else {
+                //濡傛灉鏁版嵁宸插瓨鍦紝涓旇鏁板ぇ浜�1灏遍噸缃鏁帮紙璁℃暟3娆″悗鍒ゅ畾鏁呴殰缁撴潫锛�3娆′箣鍓嶉噸鏂颁笂鎶ユ晠闅滆鏄庢晠闅滆繕鍦ㄦ寔缁� 闇�瑕侀噸鏂拌鏁帮級
+                if(rFault.getECount()!=null && rFault.getECount() > 1){
+                    rFault.setECount(1);
+                    redisUtil.hset(MqttConstant.MQTT_REAL_FAULT,redisKey,rFault);
+                    System.err.println("鎶ヨ娆℃暟閲嶇疆 clear clear 锛宬ey-"+redisKey);
+                }
+
+            }
+
+        }
+
+        //1.3缂撳瓨鑷硆edis
+        //鍚堝苟鏁版嵁
+        addFauMap.forEach((key, value) -> redFauMap.putIfAbsent(key, value));
+        //娌℃湁鏂版晠闅滄暟鎹笉鐢ㄨ鐩�
+        if(!addFauMap.isEmpty()){
+            redisUtil.hmset(MqttConstant.MQTT_REAL_FAULT,redFauMap);
+        }
+
+        //2妫�娴嬪凡缁撴潫鐨勬晠闅�
+        //2.1濡傛灉瀹炴椂鏁版嵁涓嶅瓨鍦╮edis瀛樺湪鍒欎唬琛ㄦ晠闅滅粨鏉燂紝瀛樺叆鏁版嵁搴�
+        Map<Object, Object> curFauMap = redisUtil.hmget(MqttConstant.MQTT_REAL_FAULT);
+        curFauMap.keySet().stream()
+                //鐗瑰埆娉ㄦ剰锛屽涓姤璀︾被鍨嬪叡鐢ㄦ柟娉曢渶瑕佸尯鍒嗙被鍨�
+                .filter(key -> !realFauMap.containsKey(key) && ((DryFaultRecordVo)curFauMap.get(key)).getFaultType() == faultType)
+                .forEach(key -> {
+                    DryFaultRecordVo vo = (DryFaultRecordVo)redFauMap.get(key);
+                    vo.setECount(vo.getECount()+1);
+                    if(redisUtil.hget(MqttConstant.MQTT_REAL_FAULT,key.toString())!=null){
+                        //鏇存柊娆℃暟
+                        redisUtil.hset(MqttConstant.MQTT_REAL_FAULT,key.toString(),vo);
+                        System.err.println("鎶ヨ娆℃暟鏇存柊锛宬ey-"+key);
+                    }
+
+                    if(vo.getECount()>=3){
+                        vo.setEndTime(new Date());
+                        //TODO 缁撴潫瓒呰繃鏌愪釜鏃堕棿鍖洪棿鍒ゅ畾涓洪敊璇暟鎹�
+                        faultRecordService.save(vo);
+                        redisUtil.hdel(MqttConstant.MQTT_REAL_FAULT,key);
+                        result.add(vo);
+                        System.err.println((faultType == 1 ? "绫诲瀷锛氭晠闅�" : "绫诲瀷锛氭姤璀�") +  DateUtils.formatDateTime()+"瀛樺叆鏁版嵁搴�");
+                    }
+                });
+
+
+
+        return result;
+    }
+
+
+
 }

--
Gitblit v1.9.3