hd/pipe/StaffManage/src/main/java/com/thhy/staff/modules/biz/face/controller/FaceController.java
@@ -5,6 +5,8 @@ import com.thhy.staff.modules.biz.face.entity.FaceResult; import com.thhy.staff.modules.biz.face.service.FaceDeviceService; import com.thhy.staff.modules.biz.face.service.FaceServer; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; @@ -58,4 +60,19 @@ jsonObject.put("success",true); return jsonObject; } @RequestMapping("/queryPer") public BasicResult queryPer(String perId){ faceServer.queryPer(perId); return BasicResult.success(); } @RequestMapping("/getPersonDetail") public BasicResult getPersonDetail(@RequestBody String mess){ Logger logger = LoggerFactory.getLogger(FaceController.class); logger.info("查询结果"+mess); return BasicResult.success(); } } hd/pipe/StaffManage/src/main/java/com/thhy/staff/modules/biz/face/service/FaceServer.java
@@ -14,4 +14,6 @@ void personNotify(String mess); void record(String mess); void queryPer(String perId); } hd/pipe/StaffManage/src/main/java/com/thhy/staff/modules/biz/face/service/impl/FaceServerImpl.java
@@ -12,6 +12,7 @@ import com.thhy.staff.modules.biz.face.service.FaceServer; import com.thhy.staff.modules.biz.platuser.entity.DoorLis; import com.thhy.staff.modules.biz.platuser.mapper.PlatUserMapper; import com.thhy.staff.utils.MqUtils; import org.checkerframework.checker.units.qual.A; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -128,4 +129,17 @@ DoorLis doorLis = new DoorLis(jsonObject); userMapper.insertDoorLis(doorLis); } @Override public void queryPer(String perId) { JSONObject jsonObject = new JSONObject(); jsonObject.put("method","get_person"); jsonObject.put("params",new JSONObject()); JSONObject dataJson = new JSONObject(); dataJson.put("path",vfPrefix+"/"+"getPersonDetail"); dataJson.put("person_id",perId); jsonObject.put("data",dataJson); List<String> sns = faceDeviceMapper.queryDevSn(); MqUtils.createClient(emqxConfig,sns,jsonObject.toJSONString()); } }