| | |
| | | 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; |
| | |
| | | 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; |
| | |
| | | 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) { |