最新版本

jiangping

2024-09-26 874056988430ab4eab09a813c7a28d60401bc58f

最新版本

 server/visits/dmvisit_admin/src/main/java/com/doumee/cloud/admin/HkInterfaceTestCloudController.java

@@ -5,6 +5,7 @@
import com.doumee.config.annotation.CloudRequiredPermission;
import com.doumee.config.annotation.LoginNoRequired;
import com.doumee.core.annotation.pr.PreventRepeat;
import com.doumee.core.haikang.model.param.BaseListPageResponse;
import com.doumee.core.haikang.model.param.BaseResponse;
import com.doumee.core.haikang.model.param.request.*;
import com.doumee.core.haikang.model.param.request.event.acs.EventAcsRequest;
@@ -13,12 +14,14 @@
import com.doumee.core.haikang.model.param.request.event.parks.EventPlatformRequest;
import com.doumee.core.haikang.model.param.request.event.visit.EventVisitIccmRequest;
import com.doumee.core.haikang.model.param.request.event.visit.EventVisitRequest;
import com.doumee.core.haikang.model.param.respose.*;
import com.doumee.core.haikang.service.HKService;
import com.doumee.core.model.ApiResponse;
import com.doumee.core.model.LoginUserInfo;
import com.doumee.core.utils.Constants;
import com.doumee.core.utils.DESUtil;
import com.doumee.dao.business.model.Device;
import com.doumee.service.business.DeviceService;
import com.doumee.service.business.impl.hksync.*;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
@@ -30,6 +33,10 @@

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * @author æ±Ÿè¹„蹄
@@ -42,7 +49,39 @@

    @Autowired
    private SystemDictDataBiz systemDictDataBiz;
    @Autowired
    private DeviceService deviceService;

    @ApiOperation("【海康】测试LED显示屏")
    @PostMapping("/testLedAll")
    @LoginNoRequired
    public ApiResponse<List<Map<String,Object>> > testLedAll(@RequestBody TransparentChannelBodyRequest request, HttpServletResponse response) {
        TransparentChannelHeadRequest head = new TransparentChannelHeadRequest();
        head.setAbility("cld");//固定值
        head.setTreatyType("haixuan_led_net");//固定值
        head.setDeviceIndexCode("6a5498e9df924befbb9530e467e5e809");
        Device p = new Device();
        p.setType(Constants.TWO);
        p.setIsdeleted(Constants.ZERO);
        List<Device> list = deviceService.findList(p);
        List<Map<String,Object>> dList = new ArrayList<>();
        String content = request.getParams().getRegions().get(0).getContent();
        if(list!=null){
            for(Device d : list){
                head.setDeviceIndexCode(d.getNo());
                request.getParams().setIndexCode(d.getNo());
                request.getParams().getRegions().get(0).setContent( content+"["+d.getName()+"]");
                BaseResponse res= HKService.transparentchannel(head,request);
                Map<String,Object> dn = new HashMap<>();
                dn.put("name",d.getName());
                dn.put("id",d.getNo());
                dn.put("content",request.getParams().getRegions().get(0).getContent());
                dn.put("result",res);
                dList.add(dn);
            }
        }
        return ApiResponse.success(dList);
    }
    @ApiOperation("【海康】测试LED显示屏")
    @PostMapping("/testLed")
    @LoginNoRequired
@@ -75,26 +114,32 @@
    @ApiOperation("【海康】分页查询消防传感器部件状态")
    @PostMapping("/sensorStatusSearch")
    @LoginNoRequired
    public ApiResponse<BaseResponse> sensorStatusSearch(@RequestBody SensorStatusListRequest param, HttpServletResponse response) {
    public ApiResponse<BaseResponse<BaseListPageResponse<SensorStatusListResponse>>> sensorStatusSearch(@RequestBody SensorStatusListRequest param, HttpServletResponse response) {
        return ApiResponse.success(  HKService.sensorStatusSearch(param));
    }
    @ApiOperation("【海康】查询消防传感器列表")
    @PostMapping("/fireChannelSearch")
    @LoginNoRequired
    public ApiResponse<BaseResponse> fireChannelSearch(@RequestBody FireChannelListRequest param, HttpServletResponse response) {
    public ApiResponse<BaseResponse<BaseListPageResponse<FireChannelListResponse>>> fireChannelSearch(@RequestBody FireChannelListRequest param, HttpServletResponse response) {
        return ApiResponse.success(  HKService.fireChannelSearch(param));
    }
    @ApiOperation("【海康】海康询消防设备列表")
    @PostMapping("/fireDeviceSearch")
    @LoginNoRequired
    public ApiResponse<BaseResponse> fireDeviceSearch(@RequestBody FireDeviceListRequest param, HttpServletResponse response) {
    public ApiResponse<BaseResponse<BaseListPageResponse<FireDeviceListResponse>> > fireDeviceSearch(@RequestBody FireDeviceListRequest param, HttpServletResponse response) {
        return ApiResponse.success(  HKService.fireDeviceSearch(param));
    }
    @ApiOperation("【海康】分页查询消防设备部件状态")
    @PostMapping("/fireDeviceStatusSearch")
    @LoginNoRequired
    public ApiResponse<BaseResponse> fireDeviceStatusSearch(@RequestBody FireDeviceStatuslListRequest param, HttpServletResponse response) {
    public ApiResponse<BaseResponse<BaseListPageResponse<FireDeviceStatusListResponse>>> fireDeviceStatusSearch(@RequestBody FireDeviceStatuslListRequest param, HttpServletResponse response) {
        return ApiResponse.success(  HKService.fireDeviceStatusSearch(param));
    }
    @ApiOperation("【海康】分页查询设备下的所有报警记录")
    @PostMapping("/findDeviceAlarmPage")
    @LoginNoRequired
    public ApiResponse<BaseResponse<BaseListPageResponse<FindDeviceAlarmListResponse>> > findDeviceAlarmPage(@RequestBody FindDeviceAlarmListRequest param, HttpServletResponse response) {
        return ApiResponse.success(  HKService.findDeviceAlarmPage(param));
    }

}

 server/visits/dmvisit_service/src/main/java/com/doumee/core/haikang/model/HKConstants.java

@@ -133,9 +133,10 @@
        String[] nhRegionDataRanking= new String[]{"/api/ecm/v1/energy/regionDataRanking","根据时间维度获取区域用量排名"};//1.8.5根据时间维度获取区域用量排名
        String[] nhEnergyDistribution= new String[]{"/api/ecm/v1/energy/energyDistribution","根据时间维度获取能耗分布"};// æ ¹æ®æ—¶é—´ç»´åº¦èŽ·å–能耗分布
        String[] fireDeviceSearch= new String[]{"/api/resource/v1/fireDevice/search","询消防设备列表"};// 1.12.1.1询消防设备列表
        String[] fireChannelSearch= new String[]{"/api/resource/v1/fireChannel/search","查询消防传感器列表"};// æŸ¥è¯¢æ¶ˆé˜²ä¼ æ„Ÿå™¨åˆ—表
        String[] sensorStatusSearch= new String[]{"/api/fpnms/v2/sensor/status/search","分页查询消防传感器部件状态"};// åˆ†é¡µæŸ¥è¯¢æ¶ˆé˜²ä¼ æ„Ÿå™¨éƒ¨ä»¶çŠ¶æ€
        String[] fireDeviceStatusSearch= new String[]{"/api/fpnms/v2/device/status/search","查询消防设备部件状态"};// æŸ¥è¯¢æ¶ˆé˜²è®¾å¤‡éƒ¨ä»¶çŠ¶æ€
        String[] fireChannelSearch= new String[]{"/api/resource/v1/fireChannel/search","查询消防传感器列表"};//查询消防传感器列表
        String[] sensorStatusSearch= new String[]{"/api/fpnms/v2/sensor/status/search","分页查询消防传感器部件状态"};//分页查询消防传感器部件状态
        String[] fireDeviceStatusSearch= new String[]{"/api/fpnms/v2/device/status/search","查询消防设备部件状态"};//查询消防设备部件状态
        String[] findDeviceAlarmPage= new String[]{"/api/v1/alarm/findDeviceAlarmPage","分页查询设备下的所有报警记录"};//分页查询设备下的所有报警记录
    }

    /**

 server/visits/dmvisit_service/src/main/java/com/doumee/core/haikang/model/HKTools.java

@@ -597,7 +597,7 @@
        return startDoPostStringArtemis(HKConstants.InterfacePath.fireDeviceStatusSearch,body);
    }
    /**
     *    åˆ†é¡µæŸ¥è¯¢æ¶ˆé˜²ä¼ æ„Ÿå™¨éƒ¨ä»¶çŠ¶æ€
     * åˆ†é¡µæŸ¥è¯¢æ¶ˆé˜²ä¼ æ„Ÿå™¨éƒ¨ä»¶çŠ¶æ€
     * @param body
     * @return
     */
@@ -605,6 +605,14 @@
        return startDoPostStringArtemis(HKConstants.InterfacePath.sensorStatusSearch,body);
    }
    /**
     * åˆ†é¡µæŸ¥è¯¢è®¾å¤‡ä¸‹çš„所有报警记录
     * @param body
     * @return
     */
    public static String findDeviceAlarmPage(String body) {
        return startDoPostStringArtemis(HKConstants.InterfacePath.findDeviceAlarmPage,body);
    }
    /**
     *    è¯¢æ¶ˆé˜²è®¾å¤‡åˆ—表
     * @param body
     * @return

 server/visits/dmvisit_service/src/main/java/com/doumee/core/haikang/model/param/request/FindDeviceAlarmListRequest.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,21 @@
package com.doumee.core.haikang.model.param.request;

import lombok.Data;

import java.util.List;

@Data
public class FindDeviceAlarmListRequest {
   private String deviceIndexCode;//    String    false    æ‰€å±žè®¾å¤‡id
   private String resourceIndexCodes    ;//String    false    è®¾å¤‡/传感器id
   private String searchName    ;//String    false    åç§°/编号
   private String alarmTypes    ;//String    false    æŠ¥è­¦ç±»åž‹
   private String resSubTypes    ;//String    false    è®¾å¤‡/传感器类型
   private String partNos    ;//String    false    åˆ†åŒº/回路
   private List<String> subareaNos;//    Array    false    åˆ†åŒºå· ç­‰
   private  List<String> loopNos    ;//Array    false    å›žè·¯å· ç­‰
   private String alarmStartTime;//    String    false    æŠ¥è­¦å¼€å§‹æ—¶é—´
   private String alarmEndTime    ;//String    false    æŠ¥è­¦ç»“束时间
   private int pageNo;//    Number    true    å½“前页码
   private int pageSize;//    Number    true    åˆ†é¡µå¤§å°
}

 server/visits/dmvisit_service/src/main/java/com/doumee/core/haikang/model/param/respose/FindDeviceAlarmListResponse.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,27 @@
package com.doumee.core.haikang.model.param.respose;

import lombok.Data;

@Data
public class FindDeviceAlarmListResponse {
     private String id    ;//String    false    æŠ¥è­¦ID
     private String resourceId    ;//String    false    æŠ¥è­¦æºæ‰€å±žèµ„源id
     private String resourceName;//    String    false    æŠ¥è­¦æºèµ„源名称
     private String resourceCode;//    String    false    æŠ¥è­¦æºèµ„源编号
     private Integer alarmType    ;//Number    false    æŠ¥è­¦ç±»åž‹
     private String alarmTypeName;//    String    false    æŠ¥è­¦ç±»åž‹åç§°
     private String equipTypeCode    ;//String    false    è®¾å¤‡/传感器 ç±»åž‹ç 
     private String loopNo    ;//String    false    å›žè·¯å·
     private String loopName;//    String    false    å›žè·¯åç§°
     private String subarea;//    String    false    åˆ†åŒºå·
     private String subareaName;//    String    false    åˆ†åŒºåç§°
     private String regionIndexCode    ;//String    false    åŒºåŸŸç¼–码
     private String regionName    ;//String    false    åŒºåŸŸåç§°
     private String regionPath    ;//String    false    åŒºåŸŸè·¯å¾„
     private String location    ;//String    false    æŠ¥è­¦æºè¯¦ç»†åœ°å€
     private String alarmTime;//    String    false    æŠ¥è­¦æ—¶é—´ æ—¶é—´æ ¼å¼yyyy/MM/dd HH:mm:ss
     private String recoverAlarmTime    ;//String    false    æŠ¥è­¦æ¢å¤æ—¶é—´ æ—¶é—´æ ¼å¼yyyy/MM/dd HH:mm:ss
     private Integer alarmLevel;//    Number    false    æŠ¥è­¦ç­‰çº§
     private String parentResourceId;//    String    false    æŠ¥è­¦æºæ‰€å±žè®¾å¤‡id
     private String parentResourceName;//    String    false    æŠ¥è­¦æºæ‰€å±žè®¾å¤‡åç§°
}

 server/visits/dmvisit_service/src/main/java/com/doumee/core/haikang/service/HKService.java

@@ -975,6 +975,24 @@
        return  null;
    }
    /**
     *分页查询设备下的所有报警记录
     * @return
     */
    public  static  BaseResponse<BaseListPageResponse<FindDeviceAlarmListResponse>>   findDeviceAlarmPage(FindDeviceAlarmListRequest param){
        log.info("【海康分页查询设备下的所有报警记录】================开始===="+JSONObject.toJSONString(param));
        try {
            String res = HKTools.findDeviceAlarmPage(JSONObject.toJSONString(param));
            TypeReference typeReference =
                    new TypeReference<BaseResponse<BaseListPageResponse<FindDeviceAlarmListResponse>>>(){};
            BaseResponse<BaseListPageResponse<FindDeviceAlarmListResponse>>   result = JSONObject.parseObject(res, typeReference.getType());
            logResult(result,"海康分页查询设备下的所有报警记录");
            return  result;
        }catch (Exception e){
            log.error("【海康分页查询设备下的所有报警记录】================失败====：\n"+ e.getMessage());
        }
        return  null;
    }
    /**
     *询消防设备列表
     * @return
     */