| | |
|---|
| | | import java.time.LocalDate; |
|---|
| | | import java.time.Period; |
|---|
| | | import java.util.*; |
|---|
| | | import java.util.concurrent.atomic.AtomicInteger; |
|---|
| | | import java.util.stream.Collectors; |
|---|
| | | |
|---|
| | | /** |
|---|
| | |
|---|
| | | } |
|---|
| | | model.addAttribute("allList",list); |
|---|
| | | List<List<String>> list1 = new ArrayList<>(); |
|---|
| | | AtomicInteger count = new AtomicInteger(0); |
|---|
| | | for (TDriver tDriver : onLineDriver) { |
|---|
| | | |
|---|
| | | String value1 = redisUtil.getValue("DRIVER_" + tDriver.getPhone()); |
|---|
| | | String value2 = redisUtil.getValue(value1); |
|---|
| | | if(ToolUtil.isNotEmpty(value2)){ |
|---|
| | | count.addAndGet(1); |
|---|
| | | } |
|---|
| | | |
|---|
| | | List<String> obj = new ArrayList<>(3); |
|---|
| | | String value = redisUtil.getValue("DRIVER" + tDriver.getId()); |
|---|
| | | if(ToolUtil.isEmpty(value)){ |
|---|
| | |
|---|
| | | obj.add(String.valueOf(tDriver.getServerStatus()));// 服务状态 |
|---|
| | | list1.add(obj); |
|---|
| | | } |
|---|
| | | model.addAttribute("onLineDriverCount",list1.size()); |
|---|
| | | model.addAttribute("onLineDriverCount",count.get()); |
|---|
| | | // 拿到所有在线司机地址 |
|---|
| | | model.addAttribute("onLineDriver",list1); |
|---|
| | | return PREFIX + "tHomePageMap.html"; |
|---|
| | |
|---|
| | | @RequestMapping("/getMap") |
|---|
| | | @ResponseBody |
|---|
| | | public Object getMap(Integer agentId,Integer type,Model model) { |
|---|
| | | Integer objectId = ShiroKit.getUser().getObjectId(); |
|---|
| | | Integer objectId = Objects.requireNonNull(ShiroKit.getUser()).getObjectId(); |
|---|
| | | Integer roleType = ShiroKit.getUser().getRoleType(); |
|---|
| | | if(roleType == 3 && Objects.nonNull(objectId)){ |
|---|
| | | agentId = objectId; |
|---|
