From c4778e30c9160bc2b35b30e9417303db4c8ea80d Mon Sep 17 00:00:00 2001
From: guo <guo@guo>
Date: Thu, 14 Mar 2024 13:50:57 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B5=B7=E5=BA=B7=E9=97=A8=E7=A6=81sdk?=
 =?UTF-8?q?=E5=AF=B9=E6=8E=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../impl/ProjectUfaceConfigServiceImpl.java   |  4 +--
 .../zhgd/xmgl/util/HikvisionUfaceUtil.java    | 36 +++++++++++++++++++
 2 files changed, 38 insertions(+), 2 deletions(-)
 create mode 100644 src/main/java/com/zhgd/xmgl/util/HikvisionUfaceUtil.java

diff --git a/src/main/java/com/zhgd/xmgl/modules/project/service/impl/ProjectUfaceConfigServiceImpl.java b/src/main/java/com/zhgd/xmgl/modules/project/service/impl/ProjectUfaceConfigServiceImpl.java
index 3ba6d22ed..f89f72713 100644
--- a/src/main/java/com/zhgd/xmgl/modules/project/service/impl/ProjectUfaceConfigServiceImpl.java
+++ b/src/main/java/com/zhgd/xmgl/modules/project/service/impl/ProjectUfaceConfigServiceImpl.java
@@ -331,8 +331,8 @@ public class ProjectUfaceConfigServiceImpl extends ServiceImpl<ProjectUfaceConfi
             //佳信捷新设备
             JxjNewUfaceDevUtil.addOrUpdatePerson(workerInfo, tempProjectUfaceConfig, basePath, devSn, jxjDevImageType);
         } else if (tempProjectUfaceConfig.getSupplierType() == 7) {
-            //海康门禁
-            //JxjNewUfaceDevUtil.addOrUpdatePerson(workerInfo,devSn);
+            //海康门禁sdk
+            HikvisionUfaceUtil.addOrUpdatePerson(workerInfo, tempProjectUfaceConfig, devSn);
         }
     }
 
diff --git a/src/main/java/com/zhgd/xmgl/util/HikvisionUfaceUtil.java b/src/main/java/com/zhgd/xmgl/util/HikvisionUfaceUtil.java
new file mode 100644
index 000000000..812874abb
--- /dev/null
+++ b/src/main/java/com/zhgd/xmgl/util/HikvisionUfaceUtil.java
@@ -0,0 +1,36 @@
+package com.zhgd.xmgl.util;
+
+import cn.hutool.core.bean.BeanUtil;
+import cn.hutool.core.map.MapUtil;
+import cn.hutool.core.util.StrUtil;
+import com.alibaba.fastjson.JSON;
+import com.zhgd.jeecg.common.util.SpringContextUtils;
+import com.zhgd.mqtt.server.IMqttSender;
+import com.zhgd.xmgl.modules.bigdevice.entity.dto.LifterDataInfoDTO;
+import com.zhgd.xmgl.modules.project.entity.ProjectUfaceConfig;
+import com.zhgd.xmgl.modules.worker.entity.WorkerInfo;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import java.util.Map;
+
+/**
+ * 海康门禁sdk
+ */
+@Slf4j
+public class HikvisionUfaceUtil {
+
+    public static void addOrUpdatePerson(WorkerInfo workerInfo, ProjectUfaceConfig tempProjectUfaceConfig, String devSn) {
+        if (StrUtil.isNotBlank(devSn)) {
+            Map<String, Object> map = BeanUtil.beanToMap(workerInfo);
+            map.put("isDelete", false);
+            String payload = JSON.toJSONString(map);
+            String topic = "";
+            log.info("发送主题信息：{}，主题为：{}", payload, topic);
+            IMqttSender mqttSender = SpringContextUtils.getBean(IMqttSender.class);
+            mqttSender.sendToMqtt(topic, 2, payload);
+        } else {
+            log.error("海康门禁sdk，未查询到设备sn");
+        }
+    }
+}