Merge remote-tracking branch 'origin/master'

jiaosong

2023-12-07 e057cdcd1132081abd02eae587850349d14fb2f7

Merge remote-tracking branch 'origin/master'

 server/dmvisit_admin/src/main/java/com/doumee/api/business/HkSyncController.java

@@ -65,4 +65,12 @@
        String result = hkSyncPrivilegeService.syncHkParks(param);
        return ApiResponse.success(result);
    }
    @PreventRepeat
    @ApiOperation("【海康】事件订阅推送对接处理接口")
    @PostMapping("/push")
//    @RequiresPermissions("business:hksync:privilege")
    public ApiResponse push(@RequestBody ParkListRequest param) {
        String result = hkSyncPrivilegeService.syncHkParks(param);
        return ApiResponse.success(result);
    }
}

 server/dmvisit_service/src/main/java/com/doumee/config/SpringContextUtil.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,33 @@
package com.doumee.config;

import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.stereotype.Component;

@Component
public class SpringContextUtil implements ApplicationContextAware {

    private static ApplicationContext applicationContext;

    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        this.applicationContext = applicationContext;
    }

    public static ApplicationContext getApplicationContext() {
        return applicationContext;
    }

    public static Object getBean(String name) {
        return getApplicationContext().getBean(name);
    }

    public static <T> T getBean(Class<T> clazz) {
        return getApplicationContext().getBean(clazz);
    }

    public static <T> T getBean(String name, Class<T> clazz) {
        return getApplicationContext().getBean(name, clazz);
    }
}

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

@@ -20,7 +20,9 @@
     * æŽ¥å£åœ°å€é›†åˆ
     */
    public interface InterfacePath{
        String doorEvents = "/api/acs/v2/door/events";//门禁事件查询
//        String doorEvents = "/api/acs/v2/door/events";//门禁事件查询
//        String visitEvents = "/api/visitor/v1/event/turnover/search";//访客事件查询
//        String parkEvents = "/api/pms/v1/crossRecords/page";//停车场事件查询
        String rootOrg = "/api/resource/v1/org/rootOrg";//获取跟组织
        String addBatchOrg = "/api/resource/v1/org/batch/add";//批量新增组织
        String delBatchOrg = "/api/resource/v1/org/batch/delete";//批量删除组织
@@ -45,11 +47,65 @@
        String visitCancel= "/api/visitor/v1/appointment/cancel";//取消访客预约
        String facePicture= "/api/resource/v1/person/picture";//提取用户人脸照片
        String privilegeGroup= "/api/visitor/v1/privilege/group";//查询访客权限组
        String eventSub= "/api/eventService/v1/eventSubscriptionByEventTypes";//事件订阅
    }

    /**
     * é¡”色枚举
     */
    public  enum EventTypes {

        PARK_LINE_IN(771760130, "入场压线事件"  ),
        PARK_PASS_IN(771760131, "入场放行事件"  ),
        PARK_LINE_OUT(771760133, "出场压线事件"  ),
        PARK_PASS_OUT(771760134, "出场放行事件"  ),
        VISIT_SIGN_IN(1392513025, "访客登记"  ),
        VISIT_SIGN_OUT(1392513026, "访客签离"  ),
        DOOR_FACE_AUTH_FAIL(197163, "人脸认证失败"  ),
        DOOR_FACE_AUTH_SUCCESS(196893, "人脸认证通过"  )
        ;
        // æˆå‘˜å˜é‡
        private String name;
        private int key;

        // æž„造方法
        EventTypes(int key, String name ) {
            this.name = name;
            this.key = key;
        }

        // æ™®é€šæ–¹æ³•
        public static String getName(int index) {
            for (Constants.UserType c : Constants.UserType.values()) {
                if (c.getKey() == index) {
                    return c.getName();
                }
            }
            return null;
        }


        // get set æ–¹æ³•
        public String getName() {
            return name;
        }

        public void setName(String name) {
            this.name = name;
        }

        public int getKey() {
            return key;
        }

        public void setKey(int key) {
            this.key = key;
        }

    }
    /**
     * é¡”色枚举
     */
    public  enum Colors {

        SYSTEM(0, "系统用户"  )

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

@@ -1,10 +1,17 @@
package com.doumee.core.haikang.model;

import com.alibaba.fastjson.JSONObject;
import com.doumee.config.SpringContextUtil;
import com.doumee.core.utils.Constants;
import com.doumee.dao.business.model.InterfaceLog;
import com.doumee.service.business.InterfaceLogService;
import com.hikvision.artemis.sdk.ArtemisHttpUtil;
import com.hikvision.artemis.sdk.config.ArtemisConfig;
import lombok.extern.slf4j.Slf4j;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.tomcat.util.bcel.Const;
import org.yaml.snakeyaml.scanner.Constant;

import java.io.IOException;
import java.io.InputStream;
@@ -19,10 +26,24 @@

//    private static final Logger logger = LoggerFactory.getLogger(HKUtil.class);


    public static void main(String[] args) throws ParseException {

    }
    private static void saveInterfaceLog(String s, String result,Map<String, String> path) {
        InterfaceLogService bean = SpringContextUtil.getBean(InterfaceLogService.class);
        if(bean !=null){
            InterfaceLog hkMonitoryLogDO=new InterfaceLog();
            hkMonitoryLogDO.setType(0);
            hkMonitoryLogDO.setCreateDate(new Date());
            hkMonitoryLogDO.setIsdeleted(0);
            hkMonitoryLogDO.setRequest(s);
            hkMonitoryLogDO.setRemark(result);
            hkMonitoryLogDO.setName(path.get(HKConstants.https));
            hkMonitoryLogDO.setUrl(HKConstants.https + ArtemisConfig.host+path.get(HKConstants.https));
            bean.create(hkMonitoryLogDO);
        }
    }

    private static Map<String, String> getPath(String str) {
        final String getCamsApi = HKConstants.ARTEMIS_PATH  + str;
        Map<String, String> path = new HashMap<String, String>(2) {
@@ -40,8 +61,10 @@
    public static String getRootOrg() {
        Map<String, String> path = getPath(HKConstants.InterfacePath.rootOrg);
        String result = ArtemisHttpUtil.doPostStringArtemis(path, "", null, null, "application/json", null);// post请求application/json类型参数
        saveInterfaceLog("",result,path);
        return  result;
    }


    /**
     * æ›´æ–°ç»„织信息
@@ -51,6 +74,7 @@
    public static String editOrg(String body) {
        Map<String, String> path = getPath(HKConstants.InterfacePath.editOrg);
        String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post请求application/json类型参数
        saveInterfaceLog(body,result,path);
        return  result;
    }

@@ -62,6 +86,7 @@
    public static String addBatchOrg(String body) {
        Map<String, String> path = getPath(HKConstants.InterfacePath.addBatchOrg);
        String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post请求application/json类型参数
        saveInterfaceLog(body,result,path);
        return  result;
    }
    /**
@@ -72,6 +97,7 @@
    public static String delOrg(String body) {
        Map<String, String> path = getPath(HKConstants.InterfacePath.delBatchOrg);
        String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post请求application/json类型参数
        saveInterfaceLog(body,result,path);
        return  result;
    }

@@ -83,6 +109,7 @@
    public static String addUser(String body) {
        Map<String, String> path = getPath(HKConstants.InterfacePath.addUser);
        String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post请求application/json类型参数
        saveInterfaceLog(body,result,path);
        return  result;
    }

@@ -95,6 +122,7 @@
    public static String addBatchUser(String body) {
        Map<String, String> path = getPath(HKConstants.InterfacePath.addBatchUser);
        String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post请求application/json类型参数
        saveInterfaceLog(body,result,path);
        return  result;
    }

@@ -106,6 +134,7 @@
    public static String delBatchUser(String body) {
        Map<String, String> path = getPath(HKConstants.InterfacePath.delBatchUser);
        String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post请求application/json类型参数
        saveInterfaceLog(body,result,path);
        return  result;
    }

@@ -117,6 +146,7 @@
    public static String editUser(String body) {
        Map<String, String> path = getPath(HKConstants.InterfacePath.editUser);
        String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post请求application/json类型参数
        saveInterfaceLog(body,result,path);
        return  result;
    }
    /**
@@ -127,6 +157,7 @@
    public static String addFace(String body) {
        Map<String, String> path = getPath(HKConstants.InterfacePath.addFace);
        String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post请求application/json类型参数
        saveInterfaceLog(body,result,path);
        return  result;
    }
    /**
@@ -137,6 +168,7 @@
    public static String editFace(String body) {
        Map<String, String> path = getPath(HKConstants.InterfacePath.editFace);
        String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post请求application/json类型参数
        saveInterfaceLog(body,result,path);
        return  result;
    }
    /**
@@ -147,6 +179,7 @@
    public static String delFace(String body) {
        Map<String, String> path = getPath(HKConstants.InterfacePath.delFace);
        String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post请求application/json类型参数
        saveInterfaceLog(body,result,path);
        return  result;
    }
    /**
@@ -157,6 +190,7 @@
    public static String parkList(String body) {
        Map<String, String> path = getPath(HKConstants.InterfacePath.getParkList);
        String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post请求application/json类型参数
        saveInterfaceLog(body,result,path);
        return  result;
    }
    /**
@@ -167,6 +201,7 @@
    public static String entranceList(String body) {
        Map<String, String> path = getPath(HKConstants.InterfacePath.getEntranceList);
        String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post请求application/json类型参数
        saveInterfaceLog(body,result,path);
        return  result;
    }
    /**
@@ -177,6 +212,7 @@
    public static String parkAddition(String body) {
        Map<String, String> path = getPath(HKConstants.InterfacePath.parkAddition);
        String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post请求application/json类型参数
        saveInterfaceLog(body,result,path);
        return  result;
    }
    /**
@@ -187,6 +223,7 @@
    public static String parkDeletion(String body) {
        Map<String, String> path = getPath(HKConstants.InterfacePath.parkDeletion);
        String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post请求application/json类型参数
        saveInterfaceLog(body,result,path);
        return  result;
    }
    /**
@@ -197,6 +234,7 @@
    public static String carChargeAddtion(String body) {
        Map<String, String> path = getPath(HKConstants.InterfacePath.carChargeAddtion);
        String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post请求application/json类型参数
        saveInterfaceLog(body,result,path);
        return  result;
    }
    /**
@@ -207,6 +245,7 @@
    public static String carChargeDeletion(String body) {
        Map<String, String> path = getPath(HKConstants.InterfacePath.carChargeDeletion);
        String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post请求application/json类型参数
        saveInterfaceLog(body,result,path);
        return  result;
    }

@@ -237,6 +276,7 @@
    public static String acsDeviceList(String body) {
        Map<String, String> path = getPath(HKConstants.InterfacePath.acsDeviceList);
        String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post请求application/json类型参数
        saveInterfaceLog(body,result,path);
        return  result;
    }
    /**
@@ -247,6 +287,7 @@
    public static String acsDeviceTimeRangeList(String body) {
        Map<String, String> path = getPath(HKConstants.InterfacePath.acsDeviceList);
        String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post请求application/json类型参数
        saveInterfaceLog(body,result,path);
        return  result;
    }
    /**
@@ -257,6 +298,7 @@
    public static String visitAppiontment(String body) {
        Map<String, String> path = getPath(HKConstants.InterfacePath.visitAppiontment);
        String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post请求application/json类型参数
        saveInterfaceLog(body,result,path);
        return  result;
    }
    /**
@@ -267,6 +309,7 @@
    public static String visitAppiontmentMDJ(String body) {
        Map<String, String> path = getPath(HKConstants.InterfacePath.visitAppiontmentMDJ);
        String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post请求application/json类型参数
        saveInterfaceLog(body,result,path);
        return  result;
    }

@@ -278,6 +321,7 @@
    public static String visitCancel(String body) {
        Map<String, String> path = getPath(HKConstants.InterfacePath.visitCancel);
        String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post请求application/json类型参数
        saveInterfaceLog(body,result,path);
        return  result;
    }
    /**
@@ -288,6 +332,18 @@
    public static String privilegeGroup(String body) {
        Map<String, String> path = getPath(HKConstants.InterfacePath.privilegeGroup);
        String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post请求application/json类型参数
        saveInterfaceLog(body,result,path);
        return  result;
    }
    /**
     *    äº‹ä»¶è®¢é˜…
     * @param body
     * @return
     */
    public static String eventSub(String body) {
        Map<String, String> path = getPath(HKConstants.InterfacePath.eventSub);
        String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post请求application/json类型参数
        saveInterfaceLog(body,result,path);
        return  result;
    }


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

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

import lombok.Data;

@Data
public class EventSubRequest {

 private String   name    ;//string    False    åç§°ï¼Œæ¨¡ç³Šæœç´¢ï¼Œæœ€å¤§é•¿åº¦32，若包含中文，最大长度指不超过按照指定编码的字节长度，即getBytes(“utf-8”).length
   private Integer[]    eventTypes;//    number[]    True    äº‹ä»¶ç±»åž‹,详见附录D
   private String    eventDest;//    string    True    æŒ‡å®šäº‹ä»¶æŽ¥æ”¶çš„地址，采用restful回调模式，支持http和https，样式如下：http://ip:port/eventRcv或者https://ip:port/eventRcv不超过1024个字符事件接收地址由应用方负责按指定的规范提供，事件接收接口不需要认证三方客户收到消息，请注意立即返回HTTP/1.1 200 OK， å¦åˆ™å› ä¸ºæŽ¥æ”¶å¤ªæ…¢ï¼Œå¯¼è‡´äº‹ä»¶ç§¯åŽ‹
   private Integer[]     subType;//    number    False    è®¢é˜…类型，0-订阅原始事件，1-联动事件，2-原始事件和联动事件，不填使用默认值0
   private Integer[]     eventLvl;//    number[]    False    äº‹ä»¶ç­‰çº§ï¼Œ0-未配置，1-低，2-中，3-高 æ­¤å¤„事件等级是指在事件联动中配置的等级订阅类型为0时，此参数无效，使用默认值0在订阅类型为1时，不填使用默认值[1,2,3]   åœ¨è®¢é˜…类型为2时，不填使用默认值[0,1,2,3]数组大小不超过32，事件等级大小不超过31

}

 server/dmvisit_service/src/main/java/com/doumee/core/haikang/model/param/request/event/EventDeviceDataRequest.java

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

import lombok.Data;

@Data
public class EventDeviceDataRequest<T> {

    private ExtEventIdentityCardInfo ExtEventIdentityCardInfo;//    äººå‘˜èº«ä»½è¯ä¿¡æ¯    å¦    ä¸é™
    private ExtEventIdentityCardInfo  ExtEventCustomerNumInfo;//        é€šé“事件信息    å¦    ä¸é™
    private Integer  ExtAccessChannel    ;//Number    äººå‘˜é€šé“号    å¦    32
    private Integer  ExtEventAlarmInID;//    Number    æŠ¥è­¦è¾“å…¥/防区通道    å¦    32
    private Integer   ExtEventAlarmOutID    ;//Number    æŠ¥è­¦è¾“出通道    å¦    32
    private String   ExtEventCardNo;//String    å¡å·    å¦    32
    private Integer   ExtEventCaseID    ;//Number    äº‹ä»¶è¾“入通道    å¦    32
    private Integer ExtEventCode;//    Number    äº‹ä»¶ç±»åž‹ä»£ç     å¦    32    å‚见附录D.2.1.1 é—¨ç¦äº‹ä»¶ç±»åž‹
    private Integer   ExtEventDoorID;//    Number    é—¨ç¼–号    å¦    32
    private String   ExtEventIDCardPictureURL;//    String    èº«ä»½è¯å›¾ç‰‡URL    å¦    200
    private Integer   ExtEventInOut;//    Number    è¿›å‡ºæ–¹å‘    å¦    32    è¿›å‡ºç±»åž‹1：进0：出-1:未知    è¦æ±‚：进门读卡器拨码设置为1，出门读卡器拨码设置为2
    private Integer  ExtEventLocalControllerID;//    Number    å°±åœ°æŽ§åˆ¶å™¨id    å¦    32    å°±åœ°æŽ§åˆ¶å™¨ç¼–号,0-门禁主机,1-255代表就地控制器
    private Integer   ExtEventMainDevID;//    Number    ä¸»è®¾å¤‡æ‹¨ç     å¦    32
    private String    ExtEventPersonNo;//    String    äººå‘˜ç¼–号    å¦    32    ä»¥äººä¸ºä¸­å¿ƒè®¾å¤‡ä¼šä¸ŠæŠ¥
    private String    ExtEventPictureURL;//    String    å›¾ç‰‡çš„url    å¦    32
    private Integer   ExtEventReaderID;//    Number    è¯»å¡å™¨id    å¦    32
    private Integer     ExtEventReaderKind;//    Number    è¯»å¡å™¨ç±»åˆ«    å¦    32    0-无效1-IC读卡器2-身份证读卡器3-二维码读卡器4-指纹头
    private Integer ExtEventReportChannel;//    Number    æŠ¥å‘Šä¸Šä¼ é€šé“    å¦    32    1-布防上传2-中心组1上传3-中心组2上传0-无效
    private Integer ExtEventRoleID;//    Number    ç¾¤ç»„编号    å¦    32
    private Integer  ExtEventSubDevID;//    Number    åˆ†æŽ§åˆ¶å™¨ç¡¬ä»¶ID    å¦    32
    private Integer    ExtEventSwipNum;//    Number    åˆ·å¡æ¬¡æ•°    å¦    32
    private Integer ExtEventType;//    Number    äº‹ä»¶ç±»åž‹    å¦    32    äº‹ä»¶ç±»åž‹ï¼Œå¦‚普通门禁事件为0,身份证信息事件为1，客流量统计为2
    private Integer   ExtEventVerifyID;//    Number    å¤šé‡è®¤è¯åºå·    å¦    32
    private Integer   ExtEventWhiteListNo;//    Number    ç™½åå•å•å·    å¦    32    1-8，为0无效
    private String   ExtReceiveTime;//    String    äº‹ä»¶ä¸ŠæŠ¥é©±åŠ¨çš„时间    æ˜¯    32    ç”¨äºŽç»Ÿè®¡äº‹ä»¶ä¸ŠæŠ¥å»¶æ—¶ï¼ŒUnix时间戳，精确到微秒，例： "1558576265810000"代表 2019/5/23 9:51:5.000
    private Integer    Seq;//    Number    äº‹ä»¶æµæ°´å·    æ˜¯    32    äº‹ä»¶æµæ°´å·ï¼Œä¸º0无效
    private String     UserType;//    Number ç”¨æˆ·ç±»åž‹    å¦    32    äººå‘˜ç±»åž‹ï¼š0 æœªçŸ¥ï¼Œ1 æ™®é€šï¼Œ2 æ¥å®¾ï¼Œ3 é»‘名单，4 ç®¡ç†å‘˜
    private String    svrIndexCode    ;//String    å›¾ç‰‡æœåŠ¡å™¨å”¯ä¸€ç¼–码    å¦    32

}

 server/dmvisit_service/src/main/java/com/doumee/core/haikang/model/param/request/event/EventParkDataRequest.java

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

import lombok.Data;

@Data
public class EventParkDataRequest {
    private Integer    alarmCar    ;//    Number    æ˜¯å¦é»‘名单标识（1-黑名单 0-非黑名单）    å¦
    private String    cardNo    ;//    String    å¡å·    å¦    16
    private Integer      eventCmd;//        Number    äº‹ä»¶å·    æ˜¯        1:压线事件2:上传图片3:入场4:出场5:车牌矫正6:图片重传
    private String       eventIndex;//        String    äº‹ä»¶ç¼–号    æ˜¯    64
    private String      gateIndex;//        String    å‡ºå…¥å£ç¼–号    æ˜¯    64
    private String     gateName;//        String    å‡ºå…¥å£åç§°    æ˜¯    64
    private Integer      inoutType;//        Number    è¿›å‡ºåœºç±»åž‹ï¼Œ0：进场，1：出场    æ˜¯
    private Integer      mainLogo;//        Number    è½¦è¾†ä¸»å“ç‰Œ    å¦
    private String     parkIndex    ;//    String    åœè½¦åº“编号    æ˜¯    64
    private String      parkName    ;//    String    åœè½¦åº“名称    æ˜¯    64
    private EventParkPicRequest  picUrl    ;//Object        å¦
    private String     svrIndex;//    String    å›¾ç‰‡æœåŠ¡å™¨ç¼–号    å¦    32
    private Integer      plateBelieve    ;//Number    è½¦ç‰Œç½®ä¿¡åº¦    æ˜¯    å–值范围：0—100
    private Integer     plateColor    ;//Number    è½¦ç‰Œé¢œè‰²    æ˜¯    å‚见附录A.15 è½¦ç‰Œé¢œè‰²
    private String      plateNo    ;//String    è½¦ç‰Œå·    æ˜¯    32
    private Integer      plateType;//    Number    è½¦ç‰Œç±»åž‹    æ˜¯    å‚见附录A.14 è½¦ç‰Œç±»åž‹
    private String      roadwayIndex;//    String    è½¦é“编号    æ˜¯    64
    private String     roadwayName;//    String    è½¦é“名称    æ˜¯    64
    private Integer       roadwayType;//    Number    è½¦é“类型    æ˜¯    1：入场车道 2：出场不收费车道 3：出场缴费车道 4：中央缴费车道
    private Integer       subLogo;//    Number    è½¦è¾†å­å“ç‰Œ    å¦
    private Integer      subModel;//    Number    å­å“ç‰Œå¹´æ¬¾    å¦
    private String        time;//    String    æ—¶é—´    æ˜¯    64    ISO格式
    private Integer      vehicleClass;//    Number    è½¦è¾†å±žæ€§    æ˜¯
    private Integer     vehicleColor;//    Number    è½¦è¾†é¢œè‰²    æ˜¯
    private Integer     vehicleType;//    Number    è½¦è¾†ç±»åž‹    æ˜¯
   private EventParkInResultRequest inResult;    //Object    æ”¾è¡Œç»“果数据

}

 server/dmvisit_service/src/main/java/com/doumee/core/haikang/model/param/request/event/EventParkInResultRequest.java

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

import lombok.Data;

@Data
public class EventParkInResultRequest {
    private EventParkRlsRequest    rlsResult    ;//    æ”¾è¡Œç»“果数据    æ˜¯

}

 server/dmvisit_service/src/main/java/com/doumee/core/haikang/model/param/request/event/EventParkPicRequest.java

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

import lombok.Data;

@Data
public class EventParkPicRequest {

    private String    platePicUrl;//    String    è½¦ç‰Œå›¾ç‰‡    å¦    256
    private String    vehiclePicUrl;//    String    è½¦è¾†å›¾ç‰‡    å¦    256

}

 server/dmvisit_service/src/main/java/com/doumee/core/haikang/model/param/request/event/EventParkRlsRequest.java

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

import lombok.Data;

@Data
public class EventParkRlsRequest {
    private Integer   releaseAuth    ;//    Number    æ”¾è¡Œæƒé™    æ˜¯    64    å‚见附录A.65 æ”¾è¡Œæƒé™
    private Integer releaseReason    ;//    Number    æ”¾è¡ŒåŽŸå›     æ˜¯    64    å‚见参见附录A.67 æ”¾è¡ŒåŽŸå› 
    private Integer releaseResult    ;//    Number    æ”¾è¡Œç»“æžœ    æ˜¯    64    å‚见附录A.66 æ”¾è¡Œç»“æžœ
    private Integer releaseResultEx        ;//Number    æ–°ä½“系放行结果    æ˜¯    64    å‚见附录A.68 æ–°ä½“系放行结果
    private Integer releaseWay    ;//    Number    æ”¾è¡Œæ–¹å¼    æ˜¯    64    å‚见附录A.69 æ”¾è¡Œæ–¹å¼

}

 server/dmvisit_service/src/main/java/com/doumee/core/haikang/model/param/request/event/EventPushInfoRequest.java

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

import lombok.Data;

@Data
public class EventPushInfoRequest {

    private String  eventId;//    String    äº‹ä»¶å”¯ä¸€æ ‡è¯†    æ˜¯    64
    private String  srcIndex;//    String    äº‹ä»¶æºç¼–号，物理设备是资源编号    æ˜¯    64
    private String  srcType;//    String    äº‹ä»¶æºç±»åž‹    æ˜¯    16
    private Integer  eventType    ;//Number    äº‹ä»¶ç±»åž‹    æ˜¯
    private String  srcName;//    String    äº‹ä»¶æºåç§°    å¦    64
    private Integer   status    ;//Number    äº‹ä»¶çŠ¶æ€    æ˜¯        0-瞬时1-开始2-停止3-事件脉冲4-事件联动结果更新5-异步图片上传
    private Integer  timeout    ;//Number    è„‰å†²è¶…时时间    æ˜¯        å•ä½ï¼šç§’
    private String  happenTime    ;//String    äº‹ä»¶å‘生时间（设备时间）    æ˜¯    64
    private String   srcParentIndex    ;//String    äº‹ä»¶å‘生的事件源父设备编号    å¦    64
    private EventDeviceDataRequest data;
}

 server/dmvisit_service/src/main/java/com/doumee/core/haikang/model/param/request/event/EventPushParamRequest.java

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

import lombok.Data;

import java.util.List;

@Data
public class EventPushParamRequest {


    private String   sendTime;//    P    String    äº‹ä»¶ä»ŽæŽ¥æ”¶è€…（程序处理后）发出的时间    æ˜¯    32    äº‹ä»¶å‘送时间
    private String    ability;//    P    String    äº‹ä»¶ç±»åˆ«    æ˜¯    64    æ ‡è¯†åœè½¦åœºäº‹ä»¶
    private String[] uids;//    String[]    ç”¨æˆ·id    å¦    ä¸é™
    private String[] clients    ;//String[]    ç»„件标识    å¦    ä¸é™
    private List<EventPushInfoRequest> events;//    P    Events[]    äº‹ä»¶ä¿¡æ¯    æ˜¯    ä¸é™

}

 server/dmvisit_service/src/main/java/com/doumee/core/haikang/model/param/request/event/EventPushRequest.java

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

import lombok.Data;

@Data
public class EventPushRequest {

//    private String  parkIndexCodes    ;//    string    False    åœè½¦åº“唯一标识集合  å¤šä¸ªå€¼ä½¿ç”¨è‹±æ–‡é€—号分隔，不超过1000个

    private String   method    ;//    String    æ–¹æ³•åï¼Œç”¨äºŽæ ‡è¯†æŠ¥æ–‡ç”¨é€”    æ˜¯    16    äº‹ä»¶å›ºå®šOnEventNotify
    private EventPushParamRequest   params    ;//    Params    äº‹ä»¶å‚数信息    æ˜¯    ä¸é™    å…·ä½“参数信息

}

 server/dmvisit_service/src/main/java/com/doumee/core/haikang/model/param/request/event/EventVisitDataRequest.java

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

import lombok.Data;

@Data
public class EventVisitDataRequest {
    private String   visitorId    ;//String    è®¿å®¢id    æ˜¯    64    å¯¹åº”访客来访记录中的orderId字段
    private String   personName;//    String    å§“名    æ˜¯    32
    private Integer  sex;//    Number    æ€§åˆ«    æ˜¯        1-男2-女
    private Integer  idType;//    Number    è¯ä»¶ç±»åž‹    å¦        111：身份证
    private String   idNo;//    String    è¯ä»¶å·ç     å¦    64
    private String   beVisitedPersonName;//    String    è¢«è®¿é—®äººå§“名    æ˜¯    64
    private String   beVisitedPersonOrg    ;//String    è¢«è®¿é—®äººæ‰€å±žç»„织    æ˜¯    64
    private String   visitorWorkUint;//    String    æ¥è®¿å•ä½    å¦    64
    private String   visitorCode;//    String    è®¿å®¢éªŒè¯ç     å¦    64
    private String   purpose;//    String    æ¥è®¿äº‹ç”±    å¦    64
    private String   signOrg;//    String    è¯ä»¶ç­¾å‘机关    å¦    64
    private String   startTime    ;//String    æ¥è®¿æ—¶é—´    å¦        ISO8601格式：yyyy-MM-ddTHH:mm:ss+当前时区    ä¾‹å¦‚北京时间： 2018-07-26T15:00:00+08:00
    private String   endTime;//    String    ç¦»å¼€æ—¶é—´    å¦        ISO8601格式：yyyy-MM-ddTHH:mm:ss+当前时区    ä¾‹å¦‚北京时间： 2018-07-26T15:00:00+08:00
    private String   phone;//    String    æ‰‹æœºå·ç     æ˜¯    64
    private String   carNo;//    String    è½¦ç‰Œå·    å¦
    private String   photoUrl;//    String    ç…§ç‰‡uri    å¦
    private String   captureUrl;//    String    æŠ“拍图片uri    å¦
    private String   svrIndexCode;//    String    å›¾ç‰‡å­˜å‚¨æœåŠ¡å™¨å”¯ä¸€æ ‡è¯†    å¦
    private String   beVisitedPersonId;//    String    è¢«è®¿é—®äººId    æ˜¯
    private String   beVisitedPersonOrgId;//    String    è¢«è®¿é—®äººæ‰€å±žç»„织Id    æ˜¯

}

 server/dmvisit_service/src/main/java/com/doumee/core/haikang/model/param/request/event/ExtEventCustomerNumInfo.java

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

import lombok.Data;

@Data
public class ExtEventCustomerNumInfo<T> {

    private Integer  AccessChannel;//    Number    é€šé“号    å¦    32
    private Integer  EntryTimes    ;//Number    è¿›äººæ•°    å¦    32
    private Integer  ExitTimes    ;//Number    å‡ºäººæ•°    å¦    32
    private Integer  TotalTimes    ;//Number    æ€»é€šè¡Œäººæ•°    å¦    32

}

 server/dmvisit_service/src/main/java/com/doumee/core/haikang/model/param/request/event/ExtEventIdentityCardInfo.java

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

import lombok.Data;

@Data
public class ExtEventIdentityCardInfo {
    private  String Address;//    String    ä½å€    å¦    512
    private  String  Birth;//    String    å‡ºç”Ÿæ—¥æœŸ    å¦    32    ä¾‹ï¼š â€œ1999-6-30”
    private  String  EndDate;//    String    æœ‰æ•ˆæ—¥æœŸç»“束时间    å¦    32    ä¾‹ï¼š â€œ2028-10-12”
    private  String   IdNum    ;//String    èº«ä»½è¯id    å¦    32
    private  String   IssuingAuthority;//    String    ç­¾å‘机关    å¦    32
    private  String   Name;//    String    å§“名    å¦    32
    private Integer Nation    ;//Number        å¦    32    0-未知
    private Integer   Sex;//    Number    æ€§åˆ«    å¦    32    æ€§åˆ«0-未知1-男2-女
    private  String  StartDate;//    String    æœ‰æ•ˆæ—¥æœŸå¼€å§‹æ—¶é—´    å¦    32    ä¾‹ï¼š â€œ2018-10-12”
    private Integer TermOfValidity;//    Number    æ˜¯å¦é•¿æœŸæœ‰æ•ˆ    å¦    32    0-否（有效截止日期有效）            1-是（有效截止日期无效）

}

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

@@ -9,8 +9,11 @@
import com.doumee.core.haikang.model.HKTools;
import com.doumee.core.haikang.model.param.BaseRequst;
import com.doumee.core.haikang.model.param.BaseResponse;
import com.doumee.dao.business.model.InterfaceLog;
import com.doumee.service.business.InterfaceLogService;
import com.hikvision.artemis.sdk.config.ArtemisConfig;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
@@ -20,47 +23,35 @@
import com.alibaba.fastjson.TypeReference;

import java.io.InputStream;
import java.util.Date;
import java.util.List;

@Service
@Slf4j
public class HKService {
    private Logger logger = LoggerFactory.getLogger(HKService.class);
    @Autowired
    private SystemDictDataBiz  systemDictDataBiz;

    @PostConstruct
    public  int  initHkConfig(){
        ArtemisConfig.host = systemDictDataBiz.queryByCode(Constants.HK_PARAM, Constants.HK_HOST).getCode();
        ArtemisConfig.appKey = systemDictDataBiz.queryByCode(Constants.HK_PARAM, Constants.HK_APPKEY).getCode();
        ArtemisConfig.appSecret = systemDictDataBiz.queryByCode(Constants.HK_PARAM, Constants.HK_APPSECRET).getCode();
        HKConstants.https = systemDictDataBiz.queryByCode(Constants.HK_PARAM, Constants.HK_HTTPS).getCode();
        return  0;
    }
    /**
     * èŽ·å–根组织数据
     * @return
     */
    public  BaseResponse<OrgListResponse>  getRootOrg(BaseRequst param){
    public  static  BaseResponse<OrgListResponse>  getRootOrg(BaseRequst param){
        log.error("【海康获取根组织】================开始====");
        try {
            String res = HKTools.getRootOrg ();
            TypeReference typeReference =
                    new TypeReference< BaseResponse<OrgListResponse>>(){};
            BaseResponse<OrgListResponse> result = JSONObject.parseObject(res, typeReference.getType());
            log.error("【海康获取根组织】================成功====\n"+res);
            logResult(result,"海康获取根组织");
            return  result;
        }catch (Exception e){
            log.error("【海康获取根组织】================失败====：\n"+ e.getMessage());
        }
        return  null;

    }
    /**
     * ä¿®æ”¹ç»„织数据
     * @return
     */
    public  BaseResponse editOrg(OrgEditRequest param){
    public  static  BaseResponse editOrg(OrgEditRequest param){
        log.error("【海康修改组织】================开始===="+JSONObject.toJSONString(param));
        try {

@@ -68,7 +59,7 @@
            TypeReference typeReference =
                    new TypeReference< BaseResponse>(){};
            BaseResponse  result = JSONObject.parseObject(res, typeReference.getType());
            log.error("【海康修改组织】================成功====\n"+res);
            logResult(result,"海康修改组织");
            return  result;
        }catch (Exception e){
            log.error("【海康修改组织】================失败====：\n"+ e.getMessage());
@@ -79,7 +70,7 @@
     *批量新增组织数据
     * @return
     */
    public  BaseResponse<OrgOrUserAddResponse>  addBatchOrg(List<OrgAddRequest> param){
    public  static  BaseResponse<OrgOrUserAddResponse>  addBatchOrg(List<OrgAddRequest> param){
        log.error("【海康新增组织】================开始===="+JSONObject.toJSONString(param));
        try {

@@ -87,7 +78,7 @@
            TypeReference typeReference =
                    new TypeReference< BaseResponse<OrgOrUserAddResponse>>(){};
            BaseResponse<OrgOrUserAddResponse> result = JSONObject.parseObject(res, typeReference.getType());
            log.error("【海康新增组织】================成功====\n"+res);
            logResult(result,"海康新增组织");
            return  result;
        }catch (Exception e){
            log.error("【海康新增组织】================失败====：\n"+ e.getMessage());
@@ -98,7 +89,7 @@
     *批量删除组织数据
     * @return
     */
    public  BaseResponse   delBatchOrg(OrgDelRequest param){
    public  static  BaseResponse   delBatchOrg(OrgDelRequest param){
        log.error("【海康删除组织】================开始===="+JSONObject.toJSONString(param));
        try {

@@ -106,7 +97,7 @@
            TypeReference typeReference =
                    new TypeReference< BaseResponse >(){};
            BaseResponse result = JSONObject.parseObject(res, typeReference.getType());
            log.error("【海康删除组织】================成功====\n"+res);
            logResult(result,"海康删除组织");
            return  result;
        }catch (Exception e){
            log.error("【海康删除组织】================失败====：\n"+ e.getMessage());
@@ -117,14 +108,14 @@
     *新增人员信息（支持人脸数据）
     * @return
     */
    public  BaseResponse<UserAddResponse>  addUser(UserAddRequest param){
    public  static  BaseResponse<UserAddResponse>  addUser(UserAddRequest param){
        log.error("【海康新增人员】================开始===="+JSONObject.toJSONString(param));
        try {
            String res = HKTools.addUser(JSONObject.toJSONString(param));
            TypeReference typeReference =
                    new TypeReference< BaseResponse<UserAddResponse>>(){};
            BaseResponse<UserAddResponse> result = JSONObject.parseObject(res, typeReference.getType());
            log.error("【海康新增人员】================成功====\n"+res);
            logResult(result,"海康新增人员");
            return  result;
        }catch (Exception e){
            log.error("【海康新增人员】================失败====：\n"+ e.getMessage());
@@ -135,14 +126,14 @@
     *修改人员信息（不支持人脸数据）
     * @return
     */
    public  BaseResponse editUser(UserAddRequest param){
    public  static  BaseResponse editUser(UserAddRequest param){
        log.error("【海康修改人员】================开始===="+JSONObject.toJSONString(param));
        try {
            String res = HKTools.editUser(JSONObject.toJSONString(param));
            TypeReference typeReference =
                    new TypeReference< BaseResponse<UserAddResponse>>(){};
            BaseResponse<UserAddResponse> result = JSONObject.parseObject(res, typeReference.getType());
            log.error("【海康修改人员】================成功====\n"+res);
            logResult(result,"海康修改人员");
            return  result;
        }catch (Exception e){
            log.error("【海康修改人员】================失败====：\n"+ e.getMessage());
@@ -153,14 +144,14 @@
     *批量新增人员信息(无人脸）
     * @return
     */
    public  BaseResponse<OrgOrUserAddResponse>  addBatchUser(List<UserAddRequest> param){
    public  static  BaseResponse<OrgOrUserAddResponse>  addBatchUser(List<UserAddRequest> param){
        log.error("【海康批量新增人员】================开始===="+JSONObject.toJSONString(param));
        try {
            String res = HKTools.addBatchUser(JSONObject.toJSONString(param));
            TypeReference typeReference =
                    new TypeReference< BaseResponse<OrgOrUserAddResponse>>(){};
            BaseResponse<OrgOrUserAddResponse> result = JSONObject.parseObject(res, typeReference.getType());
            log.error("【海康批量新增人员】================成功====\n"+res);
            logResult(result,"海康批量新增人员");
            return  result;
        }catch (Exception e){
            log.error("【海康批量新增人员】================失败====：\n"+ e.getMessage());
@@ -171,14 +162,14 @@
     *批量删除人员信息
     * @return
     */
    public  BaseResponse<OrgOrUserAddFailureResponse>  delBatchUser(List<UserAddRequest> param){
    public  static  BaseResponse<OrgOrUserAddFailureResponse>  delBatchUser(List<UserAddRequest> param){
        log.error("【海康批量新增人员】================开始===="+JSONObject.toJSONString(param));
        try {
            String res = HKTools.delBatchUser(JSONObject.toJSONString(param));
            TypeReference typeReference =
                    new TypeReference< BaseResponse<OrgOrUserAddFailureResponse>>(){};
            BaseResponse<OrgOrUserAddFailureResponse> result = JSONObject.parseObject(res, typeReference.getType());
            log.error("【海康批量新增人员】================成功====\n"+res);
            logResult(result,"海康批量新增人员");
            return  result;
        }catch (Exception e){
            log.error("【海康批量新增人员】================失败====：\n"+ e.getMessage());
@@ -189,14 +180,14 @@
     *添加人脸信息
     * @return
     */
    public  BaseResponse<FaceAddOrEditesponse>  addFace(List<FaceAddRequest> param){
    public  static  BaseResponse<FaceAddOrEditesponse>  addFace(List<FaceAddRequest> param){
        log.error("【海康添加人脸信息】================开始===="+JSONObject.toJSONString(param));
        try {
            String res = HKTools.addFace(JSONObject.toJSONString(param));
            TypeReference typeReference =
                    new TypeReference< BaseResponse<FaceAddOrEditesponse>>(){};
            BaseResponse<FaceAddOrEditesponse> result = JSONObject.parseObject(res, typeReference.getType());
            log.error("【海康添加人脸信息】================成功====\n"+res);
            logResult(result,"海康添加人脸信息");
            return  result;
        }catch (Exception e){
            log.error("【海康添加人脸信息】================失败====：\n"+ e.getMessage());
@@ -207,14 +198,14 @@
     *编辑人脸信息
     * @return
     */
    public  BaseResponse<FaceAddOrEditesponse>  editFace(List<FaceEditRequest> param){
    public  static  BaseResponse<FaceAddOrEditesponse>  editFace(List<FaceEditRequest> param){
        log.error("【海康编辑人脸信息】================开始===="+JSONObject.toJSONString(param));
        try {
            String res = HKTools.editFace(JSONObject.toJSONString(param));
            TypeReference typeReference =
                    new TypeReference< BaseResponse<FaceAddOrEditesponse>>(){};
            BaseResponse<FaceAddOrEditesponse> result = JSONObject.parseObject(res, typeReference.getType());
            log.error("【海康编辑人脸信息】================成功====\n"+res);
            logResult(result,"海康编辑人脸信息");
            return  result;
        }catch (Exception e){
            log.error("【海康编辑人脸信息】================失败====：\n"+ e.getMessage());
@@ -225,14 +216,14 @@
     *删除人脸信息
     * @return
     */
    public  BaseResponse   delFace(List<FaceEditRequest> param){
    public  static  BaseResponse   delFace(List<FaceEditRequest> param){
        log.error("【海康删除人脸信息】================开始===="+JSONObject.toJSONString(param));
        try {
            String res = HKTools.editFace(JSONObject.toJSONString(param));
            TypeReference typeReference =
                    new TypeReference< BaseResponse>(){};
            BaseResponse  result = JSONObject.parseObject(res, typeReference.getType());
            log.error("【海康删除人脸信息】================成功====\n"+res);
            logResult(result,"海康删除人脸信息");
            return  result;
        }catch (Exception e){
            log.error("【海康删除人脸信息】================失败====：\n"+ e.getMessage());
@@ -259,14 +250,14 @@
     *获取车库列表数据（全量）
     * @return
     */
    public  BaseResponse<List<ParkListResponse>>   parkList(ParkListRequest param){
    public  static  BaseResponse<List<ParkListResponse>>   parkList(ParkListRequest param){
        log.error("【海获取车库列表数据】================开始===="+JSONObject.toJSONString(param));
        try {
            String res = HKTools.parkList(JSONObject.toJSONString(param));
            TypeReference typeReference =
                    new TypeReference< BaseResponse<List<ParkListResponse>>>(){};
            BaseResponse  result = JSONObject.parseObject(res, typeReference.getType());
            log.error("【海康获取车库列表数据】================成功====\n"+res);
            logResult(result,"海康获取车库列表数据");
            return  result;
        }catch (Exception e){
            log.error("【海康获取车库列表数据】================失败====：\n"+ e.getMessage());
@@ -277,14 +268,14 @@
     *获取车库列表数据（全量）
     * @return
     */
    public  BaseResponse<List<EntranceListResponse>>   entranceList(EntranceListRequest param){
    public  static  BaseResponse<List<EntranceListResponse>>   entranceList(EntranceListRequest param){
        log.error("【海获取车库列表数据】================开始===="+JSONObject.toJSONString(param));
        try {
            String res = HKTools.entranceList(JSONObject.toJSONString(param));
            TypeReference typeReference =
                    new TypeReference< BaseResponse<List<EntranceListResponse>>>(){};
            BaseResponse  result = JSONObject.parseObject(res, typeReference.getType());
            log.error("【海康获取车库列表数据】================成功====\n"+res);
            logResult(result,"海康获取车库列表数据");
            return  result;
        }catch (Exception e){
            log.error("【海康获取车库列表数据】================失败====：\n"+ e.getMessage());
@@ -295,14 +286,14 @@
     *固定车辆充值（包期）
     * @return
     */
    public  BaseResponse   carChargeAddtion(CarChargeAddRequest param){
    public  static  BaseResponse   carChargeAddtion(CarChargeAddRequest param){
        log.error("【海康固定车辆充值】================开始===="+JSONObject.toJSONString(param));
        try {
            String res = HKTools.carChargeAddtion(JSONObject.toJSONString(param));
            TypeReference typeReference =
                    new TypeReference< BaseResponse>(){};
            BaseResponse  result = JSONObject.parseObject(res, typeReference.getType());
            log.error("【海康固定车辆充值】================成功====\n"+res);
            logResult(result,"海康固定车辆充值");
            return  result;
        }catch (Exception e){
            log.error("【海康固定车辆充值】================失败====：\n"+ e.getMessage());
@@ -313,14 +304,14 @@
     *固定车辆取消包期
     * @return
     */
    public  BaseResponse   carChargeDeletion(CarChargeDelRequest param){
    public  static  BaseResponse   carChargeDeletion(CarChargeDelRequest param){
        log.error("【海康固定车辆取消包期】================开始===="+JSONObject.toJSONString(param));
        try {
            String res = HKTools.carChargeDeletion(JSONObject.toJSONString(param));
            TypeReference typeReference =
                    new TypeReference< BaseResponse>(){};
            BaseResponse  result = JSONObject.parseObject(res, typeReference.getType());
            log.error("【海康固定车辆取消包期】================成功====\n"+res);
            logResult(result,"海康固定车辆取消包期");
            return  result;
        }catch (Exception e){
            log.error("【海康固定车辆取消包期】================失败====：\n"+ e.getMessage());
@@ -331,14 +322,14 @@
     *车位预约
     * @return
     */
    public  BaseResponse<ParkReservationAddResponse>   parkReservationAddition(ParkReservationAddRequest param){
    public  static  BaseResponse<ParkReservationAddResponse>   parkReservationAddition(ParkReservationAddRequest param){
        log.error("【海康车位预约】================开始===="+JSONObject.toJSONString(param));
        try {
            String res = HKTools.parkAddition(JSONObject.toJSONString(param));
            TypeReference typeReference =
                    new TypeReference< BaseResponse<ParkReservationAddResponse>>(){};
            BaseResponse<ParkReservationAddResponse>  result = JSONObject.parseObject(res, typeReference.getType());
            log.error("【海康车位预约】================成功====\n"+res);
            logResult(result,"海康车位预约");
            return  result;
        }catch (Exception e){
            log.error("【海康车位预约】================失败====：\n"+ e.getMessage());
@@ -349,14 +340,14 @@
     *车位取消预约
     * @return
     */
    public  BaseResponse   parkReservationDeletion(ParkReservationDelRequest param){
    public  static  BaseResponse   parkReservationDeletion(ParkReservationDelRequest param){
        log.error("【海康车位取消预约】================开始===="+JSONObject.toJSONString(param));
        try {
            String res = HKTools.carChargeDeletion(JSONObject.toJSONString(param));
            TypeReference typeReference =
                    new TypeReference< BaseResponse>(){};
            BaseResponse  result = JSONObject.parseObject(res, typeReference.getType());
            log.error("【海康车位取消预约】================成功====\n"+res);
            logResult(result,"海康车位取消预约");
            return  result;
        }catch (Exception e){
            log.error("【海康车位取消预约】================失败====：\n"+ e.getMessage());
@@ -367,14 +358,14 @@
     *访客预约
     * @return
     */
    public  BaseResponse<VisitAppointmentResponse>   visitAppiontment(VisitAppointmentRequest param){
    public  static  BaseResponse<VisitAppointmentResponse>   visitAppiontment(VisitAppointmentRequest param){
        log.error("【海康访客预约】================开始===="+JSONObject.toJSONString(param));
        try {
            String res = HKTools.visitAppiontment(JSONObject.toJSONString(param));
            TypeReference typeReference =
                    new TypeReference< BaseResponse<VisitAppointmentResponse>>(){};
            BaseResponse<VisitAppointmentResponse>  result = JSONObject.parseObject(res, typeReference.getType());
            log.error("【海康访客预约】================成功====\n"+res);
           logResult(result,"海康访客预约");
            return  result;
        }catch (Exception e){
            log.error("【海康访客预约】================失败====：\n"+ e.getMessage());
@@ -385,14 +376,14 @@
     *访客免登记预约
     * @return
     */
    public  BaseResponse<VisitAppointmentVistorResponse>   visitAppiontmentMDJ(VisitAppointmentMDJRequest param){
    public  static  BaseResponse<VisitAppointmentVistorResponse>   visitAppiontmentMDJ(VisitAppointmentMDJRequest param){
        log.error("【海康访客免登记预约】================开始===="+JSONObject.toJSONString(param));
        try {
            String res = HKTools.visitAppiontmentMDJ(JSONObject.toJSONString(param));
            TypeReference typeReference =
                    new TypeReference< BaseResponse<VisitAppointmentVistorResponse> >(){};
            BaseResponse<VisitAppointmentVistorResponse>   result = JSONObject.parseObject(res, typeReference.getType());
            log.error("【海康访客免登记预约】================成功====\n"+res);
            logResult(result,"海康访客免登记预约");
            return  result;
        }catch (Exception e){
            log.error("【海康访客免登记预约】================失败====：\n"+ e.getMessage());
@@ -403,14 +394,14 @@
     *访客权限组列表查询（分页）
     * @return
     */
    public  BaseResponse<PrivilegeGroupListResponse>   privilegeGroup(PrivilegeGroupRequest param){
    public  static  BaseResponse<PrivilegeGroupListResponse>   privilegeGroup(PrivilegeGroupRequest param){
        log.error("【海康访客权限组列表查询】================开始===="+JSONObject.toJSONString(param));
        try {
            String res = HKTools.privilegeGroup(JSONObject.toJSONString(param));
            TypeReference typeReference =
                    new TypeReference< BaseResponse<PrivilegeGroupListResponse> >(){};
            BaseResponse<PrivilegeGroupListResponse>   result = JSONObject.parseObject(res, typeReference.getType());
            log.error("【海康访客权限组列表查询】================成功====\n"+res);
            logResult(result,"海康访客权限组列表查询");
            return  result;
        }catch (Exception e){
            log.error("【海康访客权限组列表查询】================失败====：\n"+ e.getMessage());
@@ -421,20 +412,49 @@
     *门禁设备查询（分页）
     * @return
     */
    public  BaseResponse<AcsDeviceListResponse>   acsDeviceList(AcsDeviceListRequest param){
    public  static  BaseResponse<AcsDeviceListResponse>   acsDeviceList(AcsDeviceListRequest param){
        log.error("【海康门禁设备查询】================开始===="+JSONObject.toJSONString(param));
        try {
            String res = HKTools.acsDeviceList(JSONObject.toJSONString(param));
            TypeReference typeReference =
                    new TypeReference< BaseResponse<AcsDeviceListResponse> >(){};
            BaseResponse<AcsDeviceListResponse>   result = JSONObject.parseObject(res, typeReference.getType());
            log.error("【海康门禁设备查询】================成功====\n"+res);
            logResult(result,"海康门禁设备查询");
            return  result;
        }catch (Exception e){
            log.error("【海康门禁设备查询】================失败====：\n"+ e.getMessage());
        }
        return  null;
    }
    /**
     *事件订阅
     * @return
     */
    public  static  BaseResponse   eventSub(EventSubRequest param){
        log.error("【海康事件订阅】================开始===="+JSONObject.toJSONString(param));
        String res = null;
        try {
            res = HKTools.eventSub(JSONObject.toJSONString(param));
            TypeReference typeReference =
                    new TypeReference< BaseResponse >(){};
            BaseResponse   result = JSONObject.parseObject(res, typeReference.getType());
            logResult(result,"海康事件订阅");
            return  result;
        }catch (Exception e){
            log.error("【海康事件订阅】================失败====：\n"+ e.getMessage());
        }finally {
           // saveInterfaceLog(param,res);
        }
        return  null;
    }

    private static void logResult(BaseResponse res,String name) {
        if(StringUtils.equals(res.getCode(),HKConstants.RESPONSE_SUCCEE)){
            log.info("【"+name+"】================成功====\n"+res);
        }else{
            log.error("【"+name+"】================失败====：\n"+ res);
        }
    }

}


 server/dmvisit_service/src/main/java/com/doumee/core/utils/Constants.java

@@ -19,6 +19,8 @@
    public static final String HK_APPKEY ="HK_APPKEY" ;
    public static final String HK_APPSECRET ="HK_APPSECRET" ;
    public static final String HK_HTTPS ="HK_HTTPS" ;
    public static final String HK_PUSH_URL = "HK_PUSH_URL";
    public static final String HK_ROOTORG_CODE ="HK_ROOTORG_CODE" ;

    /**
     * mq tag

 server/dmvisit_service/src/main/java/com/doumee/dao/business/model/InterfaceLog.java

@@ -61,8 +61,7 @@

    @ApiModelProperty(value = "地址信息")
    @ExcelColumn(name="地址信息")
    @JsonFormat(pattern = "yyyy-MM-dd")
    private Date url;
    private String url;

    @ApiModelProperty(value = "请求参数")
    @ExcelColumn(name="请求参数")

 server/dmvisit_service/src/main/java/com/doumee/service/business/impl/DeviceServiceImpl.java

@@ -40,8 +40,6 @@
    @Autowired
    private DeviceMapper deviceMapper;

    @Autowired
    private HKService hkService;

    @Override
    public Integer create(Device device) {

 server/dmvisit_service/src/main/java/com/doumee/service/business/impl/InterfaceLogServiceImpl.java

@@ -119,8 +119,7 @@
            queryWrapper.lambda().eq(InterfaceLog::getName, pageWrap.getModel().getName());
        }
        if (pageWrap.getModel().getUrl() != null) {
            queryWrapper.lambda().ge(InterfaceLog::getUrl, Utils.Date.getStart(pageWrap.getModel().getUrl()));
            queryWrapper.lambda().le(InterfaceLog::getUrl, Utils.Date.getEnd(pageWrap.getModel().getUrl()));
            queryWrapper.lambda().like(InterfaceLog::getUrl, pageWrap.getModel().getUrl());
        }
        if (pageWrap.getModel().getRequest() != null) {
            queryWrapper.lambda().eq(InterfaceLog::getRequest, pageWrap.getModel().getRequest());

 server/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncBaseServiceImpl.java

@@ -1,10 +1,12 @@
package com.doumee.service.business.impl.hksync;

import com.doumee.biz.system.SystemDictDataBiz;
import com.doumee.core.constants.ResponseStatus;
import com.doumee.core.exception.BusinessException;
import com.doumee.core.haikang.model.HKConstants;
import com.doumee.core.haikang.model.param.BaseResponse;
import com.doumee.core.haikang.model.param.request.AcsDeviceListRequest;
import com.doumee.core.haikang.model.param.request.EventSubRequest;
import com.doumee.core.haikang.model.param.request.ParkListRequest;
import com.doumee.core.haikang.model.param.request.PrivilegeGroupRequest;
import com.doumee.core.haikang.model.param.respose.AcsDeviceInfoResponse;
@@ -18,10 +20,12 @@
import com.doumee.dao.business.model.Device;
import com.doumee.dao.business.model.Parks;
import com.doumee.service.business.HkSyncService;
import com.hikvision.artemis.sdk.config.ArtemisConfig;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.annotation.PostConstruct;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
@@ -33,9 +37,6 @@
 */
@Service
public class HkSyncBaseServiceImpl implements HkSyncService {

    @Autowired
    public HKService hkService;

    /**
     * åŒæ­¥æµ·åº·åœè½¦åº“数据

 server/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncDeviceServiceImpl.java

@@ -58,7 +58,7 @@
            param = new AcsDeviceListRequest();
            param.setPageNo(curPage);
            param.setPageSize(10000);
            BaseResponse<AcsDeviceListResponse> response = hkService.acsDeviceList(param);
            BaseResponse<AcsDeviceListResponse> response = HKService.acsDeviceList(param);
            if(response == null || !StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE)){
                throw  new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "对不起，海康同步数据失败~");
            }

 server/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncEventServiceImpl.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,87 @@
package com.doumee.service.business.impl.hksync;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.doumee.biz.system.SystemDictDataBiz;
import com.doumee.core.constants.ResponseStatus;
import com.doumee.core.exception.BusinessException;
import com.doumee.core.haikang.model.HKConstants;
import com.doumee.core.haikang.model.param.BaseResponse;
import com.doumee.core.haikang.model.param.request.EventSubRequest;
import com.doumee.core.haikang.model.param.request.PrivilegeGroupRequest;
import com.doumee.core.haikang.model.param.respose.OrgListResponse;
import com.doumee.core.haikang.model.param.respose.PrivilegeGroupInfoResponse;
import com.doumee.core.haikang.model.param.respose.PrivilegeGroupListResponse;
import com.doumee.core.haikang.service.HKService;
import com.doumee.core.utils.Constants;
import com.doumee.dao.business.DeviceRoleMapper;
import com.doumee.dao.business.model.DeviceRole;
import com.doumee.dao.system.model.SystemDictData;
import com.hikvision.artemis.sdk.config.ArtemisConfig;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.annotation.PostConstruct;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

/**
 * æµ·åº·äº‹ä»¶è®¢é˜…表Service实现
 * @author æ±Ÿè¹„蹄
 * @date 2023/11/30 15:33
 */
@Service
public class HkSyncEventServiceImpl extends HkSyncBaseServiceImpl {

    @Autowired
    private SystemDictDataBiz systemDictDataBiz;

    @PostConstruct
    public  int  initHkConfig(){
        ArtemisConfig.host = systemDictDataBiz.queryByCode(Constants.HK_PARAM, Constants.HK_HOST).getCode();
        ArtemisConfig.appKey = systemDictDataBiz.queryByCode(Constants.HK_PARAM, Constants.HK_APPKEY).getCode();
        ArtemisConfig.appSecret = systemDictDataBiz.queryByCode(Constants.HK_PARAM, Constants.HK_APPSECRET).getCode();
        HKConstants.https = systemDictDataBiz.queryByCode(Constants.HK_PARAM, Constants.HK_HTTPS).getCode();
        //开始订阅门禁事件、访客事件、和停车场事件
        startHkEventSub();
        //获取根组织编码
        getRootOrgCode();
        return  0;
    }
    /**
     *    èŽ·å–根组织编码
     */
    private void getRootOrgCode() {
        SystemDictData org =  systemDictDataBiz.queryByCode(Constants.HK_PARAM, Constants.HK_ROOTORG_CODE);
        if(org!=null){
            String rootOrgId =org.getCode();
            if(StringUtils.isBlank(rootOrgId)){
                BaseResponse<OrgListResponse> res = HKService.getRootOrg(null);
                if(res !=null && res.getData()!=null && StringUtils.isNotBlank(res.getData().getOrgIndexCode())){
                    org.setCode(res.getData().getOrgIndexCode());
                    org.setUpdateTime(new Date());
                    systemDictDataBiz.updateById( org);
                }
            }
        }

    }

    /**
     * è®¢é˜…门禁事件、访客事件、和停车场事件
     */
    public void startHkEventSub(){
        EventSubRequest param = new EventSubRequest();
        param.setEventDest(systemDictDataBiz.queryByCode(Constants.HK_PARAM, Constants.HK_PUSH_URL).getCode());
        param.setEventTypes(new Integer[]{HKConstants.EventTypes.PARK_LINE_IN.getKey()
                ,HKConstants.EventTypes.PARK_LINE_OUT.getKey()
                ,HKConstants.EventTypes.PARK_PASS_IN.getKey()
                ,HKConstants.EventTypes.PARK_PASS_OUT.getKey()
                ,HKConstants.EventTypes.VISIT_SIGN_OUT.getKey()
                ,HKConstants.EventTypes.VISIT_SIGN_OUT.getKey()
                ,HKConstants.EventTypes.DOOR_FACE_AUTH_SUCCESS.getKey()});
        HKService.eventSub(param);

    }
}

 server/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncParkServiceImpl.java

@@ -51,7 +51,7 @@
        List<Parks> allList = parksMapper.selectList(null);
            //分页遍历循环查询所有门禁设备数据
        param = new ParkListRequest();
        BaseResponse<List<ParkListResponse>> response = hkService.parkList(param);
        BaseResponse<List<ParkListResponse>> response = HKService.parkList(param);
        if(response == null || !StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE)){
            throw  new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "对不起，海康同步数据失败~");
        }

 server/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncPrivilegeServiceImpl.java

@@ -6,13 +6,11 @@
import com.doumee.core.haikang.model.HKConstants;
import com.doumee.core.haikang.model.param.BaseResponse;
import com.doumee.core.haikang.model.param.request.PrivilegeGroupRequest;
import com.doumee.core.haikang.model.param.respose.AcsDeviceInfoResponse;
import com.doumee.core.haikang.model.param.respose.PrivilegeGroupInfoResponse;
import com.doumee.core.haikang.model.param.respose.PrivilegeGroupListResponse;
import com.doumee.core.haikang.service.HKService;
import com.doumee.core.utils.Constants;
import com.doumee.core.utils.DateUtil;
import com.doumee.dao.business.DeviceRoleMapper;
import com.doumee.dao.business.model.Device;
import com.doumee.dao.business.model.DeviceRole;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
@@ -58,7 +56,7 @@
            param = new PrivilegeGroupRequest();
            param.setPageNo(curPage);
            param.setPageSize(10000);
            BaseResponse<PrivilegeGroupListResponse> response = hkService.privilegeGroup(param);
            BaseResponse<PrivilegeGroupListResponse> response = HKService.privilegeGroup(param);
            if(response == null || !StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE)){
                throw  new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "对不起，海康同步数据失败~");
            }