提交冲掉的代码

YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/service/impl/RiskSourceServiceImpl.java

@@ -22,6 +22,7 @@ import java.util.stream.Collectors;
 import javax.annotation.PostConstruct;
 import javax.servlet.http.HttpServletRequest;
 
+import com.yeejoin.amos.fas.business.bo.*;
 import com.yeejoin.amos.fas.business.util.*;
 import com.yeejoin.amos.fas.common.enums.AstDataSyncTopic;
 import org.apache.commons.lang3.ArrayUtils;
@@ -59,13 +60,6 @@ import com.yeejoin.amos.fas.business.action.model.FireEquimentDataRo;
 import com.yeejoin.amos.fas.business.action.model.ProtalDataRo;
 import com.yeejoin.amos.fas.business.action.model.RiskSourceRuleRo;
 import com.yeejoin.amos.fas.business.action.mq.WebMqttComponent;
-import com.yeejoin.amos.fas.business.bo.BindRegionBo;
-import com.yeejoin.amos.fas.business.bo.FireEquipmentBo;
-import com.yeejoin.amos.fas.business.bo.JpushMsgBo;
-import com.yeejoin.amos.fas.business.bo.JpushMsgContentBo;
-import com.yeejoin.amos.fas.business.bo.MsgParamBo;
-import com.yeejoin.amos.fas.business.bo.RiskSourceSynBo;
-import com.yeejoin.amos.fas.business.bo.RpnCalculationBo;
 import com.yeejoin.amos.fas.business.constants.FasConstant;
 import com.yeejoin.amos.fas.business.dao.mapper.FireEquipMapper;
 import com.yeejoin.amos.fas.business.dao.mapper.FireEquipPointMapper;
@@ -798,6 +792,40 @@ public class RiskSourceServiceImpl implements IRiskSourceService {
         webMqttComponent.publish(topicThree, JSON.toJSONString(view3dService.getStatisticsCheck(orgCode)));
     }
 
+    /**
+     * <pre>
+     * @Description: 隐患治理更新State、rpn值
+     * </pre>
+     *
+     * @Throws
+     * @Author keyong
+     * @Date 2021/2/1 19:50
+     */
+    @Override
+    public void processProtalDataFromDanger(DangerResultBo dangerResultBo) {
+        List<FmeaPointInputitem> fmeaPointInputitems = fmeaPointInputitemMapper.listByPointInputItemId(dangerResultBo.getInputItemId());
+        if (0 < fmeaPointInputitems.size()) {
+            Set<Long> fmeaIds = Sets.newHashSet();
+            List<Long> list = Lists.newArrayList();
+            fmeaPointInputitems.forEach(x -> {
+                list.add(x.getId());
+                fmeaIds.add(x.getFmeaId());
+            });
+            fmeaPointInputitemMapper.updateStateByIds(0, list);
+            RsDataQueue rsDataQueue = RsDataQueue.getInstance();
+            fmeaIds.forEach(fmeaId -> rsDataQueue.addPatrolMessage(fmeaId, dangerResultBo.getUserName(), null, "1"));
+            iDataRefreshService.refreshViewData(DataRefreshTypeEum.handleDanger.getCode());
+            // 今日安全
+            SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd");
+            String dateString = formatter.format(new Date());
+            String topicOne = String.format("/%s/%s/%s/%s", serviceName, stationName, "data/refresh", "todaySafetyIndex");
+            webMqttComponent.publish(topicOne, JSON.toJSONString(view3dService.getSafetyIndexInfoByDate(dangerResultBo.getOrgCode(), dateString)));
+
+            // 一周安全趋势
+            String topicThree = String.format("/%s/%s/%s/%s", serviceName, stationName, "data/refresh", "weekSafetyIndex");
+            webMqttComponent.publish(topicThree, JSON.toJSONString(view3dService.getSafetyIndexWeek(dangerResultBo.getOrgCode())));
+        }
+    }
 
     /**
      * 巡检消息规则推送