bingbo
2023-11-27 75c292340b20e71e30af074e3919e9b2d8d50d5b
hd/pipe/StaffManage/src/main/java/com/thhy/staff/modules/biz/platuser/controller/ExecFaceListener.java
@@ -4,6 +4,7 @@
import com.thhy.general.common.BasicResult;
import com.thhy.general.config.GlobalConfig;
import com.thhy.general.utils.SpringContextUtils;
import com.thhy.staff.modules.biz.platuser.entity.AreaAdmin;
import com.thhy.staff.modules.biz.platuser.service.PlatUserService;
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
@@ -19,6 +20,7 @@
import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.CopyOnWriteArraySet;
@@ -70,8 +72,28 @@
                    dataMapList.add(map);
                    Map<String,Object> map1 = userService.groupUserWork(userToken);
                    Map<String,Object> map2 = userService.faceRecord(userToken);
                    List<HashMap<String,Object>> AudioGroupList = userService.queryGroups();
                    Map<String, Object> map3 = new HashMap<>();
                    map3.put("mod","audioGroup");
                    map3.put("groupList",AudioGroupList);
                    List<HashMap<String,Object>> HelmetWarnList = userService.queryHelmetWarn();
                    Map<String, Object> map4 = new HashMap<>();
                    map4.put("mod","helmetWarn");
                    map4.put("helmetWarnList",HelmetWarnList);
                    List<AreaAdmin> areaAdminList = userService.areaAdminInfo();
                    Map<String, Object> map5 = new HashMap<>();
                    map5.put("mod","areaAdmin");
                    map5.put("areaAdminList",areaAdminList);
                    dataMapList.add(map1);
                    dataMapList.add(map2);
                    dataMapList.add(map3);
                    dataMapList.add(map4);
                    dataMapList.add(map5);
                    try {
                        session.getBasicRemote().sendText(JSON.toJSONString(dataMapList));
                    } catch (IOException e) {