人脸通过 gengdidi

danger-manage-admin/src/main/java/com/zehong/web/controller/videomonitor/SubscriptionEventController.java

@@ -6,6 +6,7 @@ import com.alibaba.fastjson.JSONObject;
 import com.github.pagehelper.util.StringUtil;
 import com.zehong.common.core.domain.AjaxResult;
 import com.zehong.common.core.redis.RedisCache;
+import com.zehong.common.utils.StringUtils;
 import com.zehong.system.domain.TDeviceAlarmInfo;
 import com.zehong.system.domain.TEntranceGuardPersonInfo;
 import com.zehong.system.domain.vo.ArtemisPerson;
@@ -20,6 +21,7 @@ import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
+import java.text.ParseException;
 import java.text.SimpleDateFormat;
 import java.util.Date;
 import java.util.HashMap;
@@ -100,13 +102,28 @@ public class SubscriptionEventController {
             throw new Exception("订阅信息有误不包含events信息");
         }
         for(JSONObject event : events){
+            Date happenTime = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSS'+'").parse((String)event.get("happenTime"));
+            if((System.currentTimeMillis() - happenTime.getTime()) /(1000 * 3600) > 1){
+                throw new Exception("事件超过一小时，数据丢弃");
+            }
             JSONObject data = (JSONObject)JSON.toJSON(event.get("data"));
             String personNo = (String)data.get("ExtEventPersonNo");
             //获取人员信息
+            String extEventInOut = String.valueOf(data.get("ExtEventInOut"));
             ArtemisPerson artemisPerson = new ArtemisPerson();
             artemisPerson.setPageNo(1);
             artemisPerson.setPageSize(1000);
-            artemisPerson.setCertificateNo(personNo);
+            if(StringUtils.isNotEmpty(personNo)){
+                artemisPerson.setPersonIds(personNo);
+            }else {
+                String cardNo = (String)data.get("ExtEventCardNo");
+                if(StringUtils.isNotEmpty(cardNo)){
+                    artemisPerson.setCardNo(cardNo);
+                }else {
+                    throw new Exception("人员和卡信息不全！");
+                }
+            }
+
             String personInfoStr = ArtemisUtils.personList(artemisPerson);
             JSONObject personInfo = JSON.parseObject(personInfoStr);
             if(!"0".equals(personInfo.get("code"))){
@@ -121,11 +138,10 @@ public class SubscriptionEventController {
             TEntranceGuardPersonInfo tEntranceGuardPersonInfo = new TEntranceGuardPersonInfo();
             tEntranceGuardPersonInfo.setPersonName(personName);
             tEntranceGuardPersonInfo.setPersonNum((String)list.get(0).get("certificateNo"));
-            String extEventInOut = String.valueOf(data.get("ExtEventInOut"));
             if("0".equals(extEventInOut) || "1".equals(extEventInOut)){
                 tEntranceGuardPersonInfo.setActionType("0".equals(extEventInOut) ? "1" : "0");
             }
-            tEntranceGuardPersonInfo.setActionTime(new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSS'+'").parse((String)event.get("happenTime")));
+            tEntranceGuardPersonInfo.setActionTime(happenTime);
             tEntranceGuardPersonInfoService.insertTEntranceGuardPersonInfo(tEntranceGuardPersonInfo);
         }
     }

danger-manage-system/src/main/resources/mapper/system/TEntranceGuardPersonInfoMapper.xml

@@ -158,7 +158,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
                 *
             FROM
                 t_entrance_guard_person_info
-            ORDER BY action_time DESC
+            ORDER BY action_time DESC LIMIT 10000
         )present
         GROUP BY
             present.action_type