Merge remote-tracking branch 'origin/develop_dl' into develop_dl

amos-boot-module/amos-boot-module-biz/amos-boot-module-equip-biz/src/main/java/com/yeejoin/equipmanage/controller/BigScreenController.java

@@ -172,6 +172,14 @@ public class BigScreenController extends AbstractBaseController {
     }
 
     @TycloudOperation(ApiLevel = UserType.AGENCY)
+    @ApiOperation(value = "卡片BigSystem报警趋势统计")
+    @GetMapping("/statistic/trend/forSbpt")
+    public ResponseModel getSystemAlarmTrendForSbpt(@RequestParam(value = "systemCode", required = false)String systemCode,
+                                             @RequestParam(value = "updateTime", required = false)String updateTime) {
+        return CommonResponseUtil.success(iFireFightingSystemService.getSystemAlarmTrend(systemCode, updateTime));
+    }
+
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
     @ApiOperation(value = "卡片BigSystem树接口")
     @GetMapping("/system/tree")
     public List<OrgMenuDto> getSystemEquipTree(@RequestParam(value = "systemCode")String systemCode) {

amos-boot-module/amos-boot-module-biz/amos-boot-module-equip-biz/src/main/java/com/yeejoin/equipmanage/controller/EmergencyController.java

@@ -705,7 +705,8 @@ public class EmergencyController extends AbstractBaseController {
 								   @RequestParam(required = false) Integer cleanStatus,
 								   @RequestParam(required = false) Integer handleStatus,
 								   @RequestParam(required = false) String bizOrgCode,
-								   @RequestParam(required = false) String systemCode
+								   @RequestParam(required = false) String systemCode,
+								   @RequestParam(required = false) String createDate
 								   ) {
 		Page<Map<String, Object>> page = new Page<>(pageNumber, pageSize);
 		if (StringUtils.isEmpty(bizOrgCode)) {
@@ -718,7 +719,7 @@ public class EmergencyController extends AbstractBaseController {
 				}
 			}
 		}
-		return CommonResponseUtil.success(iEmergencyService.alarmList(page, bizOrgCode, systemCode, types, emergencyLevels, name, cleanStatus, handleStatus));
+		return CommonResponseUtil.success(iEmergencyService.alarmList(page, bizOrgCode, systemCode, types, emergencyLevels, name, cleanStatus, handleStatus, createDate));
 	}
 
 	@TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)

amos-boot-module/amos-boot-module-biz/amos-boot-module-equip-biz/src/main/java/com/yeejoin/equipmanage/mapper/EmergencyMapper.java

@@ -107,7 +107,7 @@ public interface EmergencyMapper extends BaseMapper{
      * @param name 设备名称
      * @return
      */
-    Page<Map<String, Object>> alarmList(@Param("page") Page<Map<String, Object>> page, @Param("bizOrgCode") String bizOrgCode, @Param("systemCode") String systemCode, @Param("types") List<String> types, @Param("emergencyLevels") List<String> emergencyLevels, @Param("name") String name, @Param("cleanStatus") Integer cleanStatus, @Param("handleStatus") Integer handleStatus);
+    Page<Map<String, Object>> alarmList(@Param("page") Page<Map<String, Object>> page, @Param("bizOrgCode") String bizOrgCode, @Param("systemCode") String systemCode, @Param("types") List<String> types, @Param("emergencyLevels") List<String> emergencyLevels, @Param("name") String name, @Param("cleanStatus") Integer cleanStatus, @Param("handleStatus") Integer handleStatus , @Param("createDate") String createDate);
 
     IPage<EquipTypeImgAmountVO> getEmergencyEquipList(@Param("page") IPage page, @Param("equipTypeAmountPage") EquipTypeAmountPageDTO equipTypeAmountPage);
 

amos-boot-module/amos-boot-module-biz/amos-boot-module-equip-biz/src/main/java/com/yeejoin/equipmanage/mapper/FireFightingSystemMapper.java

@@ -720,6 +720,8 @@ public interface FireFightingSystemMapper extends BaseMapper<FireFightingSystemE
 
     List<Map<String, Object>> getSystemAlarmTrend(@Param("systemCode") String systemCode, @Param("updateTime") String updateTime);
 
+    List<Map<String, Object>> getSystemAlarmTrendForSbpt(@Param("systemCode") String systemCode, @Param("updateTime") String updateTime);
+
     List<Map<String, Object>> getEquipmentAndEquipSpeTree(@Param("bizOrgCode")String bizOrgCode, @Param("systemCode") String systemCode);
 
     Page<Map<String, Object>> getEquipmentsBySystemInfo(Page page, @Param("bizOrgCode") String bizOrgCode, @Param("systemCode") String systemCode, @Param("equipmentCode") String equipmentCode);

amos-boot-module/amos-boot-module-biz/amos-boot-module-equip-biz/src/main/java/com/yeejoin/equipmanage/service/IEmergencyService.java

@@ -69,7 +69,7 @@ public interface IEmergencyService {
 
     List<Map<String, Object>> getPressurePumpDiagnosticAnalysis(String bizOrgCode);
 
-    Page<Map<String, Object>> alarmList(Page<Map<String, Object>> page,String bizOrgCode, String systemCode, List<String> types, List<String> emergencyLevels, String name, Integer cleanStatus, Integer handleStatus);
+    Page<Map<String, Object>> alarmList(Page<Map<String, Object>> page,String bizOrgCode, String systemCode, List<String> types, List<String> emergencyLevels, String name, Integer cleanStatus, Integer handleStatus,String createDate);
 
     Map<String, List<PressurePumpCountVo>> getPressurePumpDay();
 

amos-boot-module/amos-boot-module-biz/amos-boot-module-equip-biz/src/main/java/com/yeejoin/equipmanage/service/IFireFightingSystemService.java

@@ -342,5 +342,7 @@ public interface IFireFightingSystemService extends IService<FireFightingSystemE
 
     Map<String, Object> getSystemAlarmTrend(String systemCode, String updateTime);
 
+    Map<String, Object> getSystemAlarmTrendForSbpt(String systemCode, String updateTime);
+
     List<OrgMenuDto> getSystemEquipTree(String systemCode);
 }

amos-boot-module/amos-boot-module-biz/amos-boot-module-equip-biz/src/main/java/com/yeejoin/equipmanage/service/impl/EmergencyServiceImpl.java

@@ -622,8 +622,8 @@ public class EmergencyServiceImpl implements IEmergencyService {
 
 
     @Override
-    public Page<Map<String, Object>> alarmList(Page<Map<String, Object>> page, String bizOrgCode, String systemCode, List<String> types, List<String> emergencyLevels, String name, Integer cleanStatus, Integer handleStatus) {
-        return emergencyMapper.alarmList(page, bizOrgCode, systemCode, types, emergencyLevels, name, cleanStatus, handleStatus);
+    public Page<Map<String, Object>> alarmList(Page<Map<String, Object>> page, String bizOrgCode, String systemCode, List<String> types, List<String> emergencyLevels, String name, Integer cleanStatus, Integer handleStatus,String createDate) {
+        return emergencyMapper.alarmList(page, bizOrgCode, systemCode, types, emergencyLevels, name, cleanStatus, handleStatus, createDate);
     }
 
     //稳压泵定时向缓存中存昨日启动次数任务

amos-boot-module/amos-boot-module-biz/amos-boot-module-equip-biz/src/main/java/com/yeejoin/equipmanage/service/impl/FireFightingSystemServiceImpl.java

@@ -2602,6 +2602,31 @@ public class FireFightingSystemServiceImpl extends ServiceImpl<FireFightingSyste
     }
 
     @Override
+    public Map<String, Object> getSystemAlarmTrendForSbpt(String systemCode, String updateTime) {
+        if(!StringUtil.isNotEmpty(updateTime)) {
+            updateTime = new SimpleDateFormat(DateUtils.DATE_PATTERN).format(new Date());
+        }
+        List<Map<String, Object>> result = fireFightingSystemMapper.getSystemAlarmTrendForSbpt(systemCode, updateTime);
+        Map<String, Object> resMap = new HashMap<>();
+        resMap.put("xAxisData", result.stream().map(x -> x.get("date")).collect(Collectors.toList()));
+        List<Map<String, Object>> list = new ArrayList<>();
+        Map<String, Object> entryMap1 = new HashMap<>();
+        entryMap1.put("name", "正常");
+        entryMap1.put("data", result.stream().map(x -> x.get("normalNum")).collect(Collectors.toList()));
+        list.add(entryMap1);
+        Map<String, Object> entryMap2 = new HashMap<>();
+        entryMap2.put("name", "故障");
+        entryMap2.put("data", result.stream().map(x -> x.get("faultNum")).collect(Collectors.toList()));
+        list.add(entryMap2);
+        Map<String, Object> entryMap3 = new HashMap<>();
+        entryMap3.put("name", "告警");
+        entryMap3.put("data", result.stream().map(x -> x.get("alarmNum")).collect(Collectors.toList()));
+        list.add(entryMap3);
+        resMap.put("yAxisData", list);
+        return resMap;
+    }
+
+    @Override
     public List<OrgMenuDto> getSystemEquipTree(String systemCode) {
         // 此卡片在站端使用，由于远程调用jcs耗时，所以暂注释掉
 //        FeignClientResult<List<OrgUsrDto>> feignClientResult = jcsFeignClient.getCompanyDeptListWithAuth(authKey, "COMPANY", "dl");

amos-boot-system-equip/src/main/resources/mapper/EmergencyMapper.xml

@@ -1429,6 +1429,9 @@
             <if test="bizOrgCode != null and bizOrgCode != ''">
                 and wlesal.biz_org_code like concat(#{bizOrgCode},'%')
             </if>
+            <if test='createDate != null and createDate == "1"'>
+                AND wlesal.create_date LIKE CONCAT( DATE_FORMAT( NOW( ), '%Y-%m-%d' ), '%' )
+            </if>
             <if test="systemCode != null and systemCode != ''">
                 and fs.code = #{systemCode}
             </if>

amos-boot-system-equip/src/main/resources/mapper/FireFightingSystemMapper.xml

@@ -6380,6 +6380,54 @@
         s1.date
     </select>
 
+    <select id="getSystemAlarmTrendForSbpt" resultType="Map">
+        SELECT
+        s1.date,
+        IFNULL( s2.normalNum, 0 ) AS normalNum,
+        IFNULL( s2.faultNum, 0 ) AS faultNum,
+        IFNULL( s2.alarmNum, 0 ) AS alarmNum
+        FROM
+        (
+        SELECT
+        @s := @s + 1  AS `index`,
+        DATE_FORMAT( DATE_ADD(( DATE( DATE_ADD(#{updateTime}, INTERVAL - 15 DAY ))), INTERVAL @s DAY ), '%Y-%m-%d' ) AS date
+        FROM
+        mysql.help_topic,
+        ( SELECT @s := - 1 ) temp
+        WHERE
+        @s &lt; 15
+        ) s1
+        LEFT JOIN (
+        SELECT
+        s.*
+        FROM
+        (
+        SELECT
+        IFNULL(SUM(IF(r.`status` = 0, 1, 0)), 0) AS normalNum,
+        IFNULL(SUM(IF((r.type = 'BREAKDOWN' AND r.`status` = 1), 1, 0)), 0) AS faultNum,
+        IFNULL(SUM(IF((r.type = 'FIREALARM' AND r.`status` = 1), 1, 0)), 0) AS alarmNum,
+        DATE_FORMAT( r.update_date, '%Y-%m-%d') AS date
+        FROM
+        wl_equipment_specific_alarm_log r
+        LEFT JOIN f_fire_fighting_system fs ON FIND_IN_SET( fs.id, r.system_ids )
+        <where>
+            r.update_date BETWEEN date_sub( now(), INTERVAL 15 MONTH ) AND now()
+            <if test="systemCode != null and systemCode != ''">
+                AND fs.`code` = #{systemCode}
+            </if>
+        </where>
+        GROUP BY
+        LEFT ( r.update_date, 10 )
+        ORDER BY
+        r.update_date
+        ) s
+        ) s2 ON s2.date = s1.date
+        GROUP BY
+        s1.date
+        ORDER BY
+        s1.date
+    </select>
+
     <select id="getEquipmentAndEquipSpeTree" resultType="java.util.Map">
         SELECT
             a.id,