| | |
| | | } |
| | | Constants.DEALING_HK_NOTICE_LIST =true; |
| | | try { |
| | | List<String> users = new ArrayList<>(); |
| | | users.add(username); |
| | | List<Integer> userIds = new ArrayList<>(); |
| | | List<Member > userList = memberMapper.selectList(new QueryWrapper<Member>().lambda() |
| | | .in(Member::getPhone,users) |
| | | .eq(Member::getType,Constants.TWO) |
| | | .eq(Member::getIsdeleted,Constants.ZERO)); |
| | | Member tu= getFromUserList(username,userList); |
| | | if(tu!=null){ |
| | | userIds.add(tu.getId()); |
| | | }else{ |
| | | throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "对不起,无效账号~"); |
| | | } |
| | | Date date = new Date(); |
| | | List<GetTodoListResponse> allHkList = new ArrayList<>(); |
| | | boolean hasNext = true; |
| | |
| | | } |
| | | curPage++; |
| | | } |
| | | |
| | | |
| | | if(allHkList!=null && allHkList.size()>0){ |
| | | List<Notices> list = new ArrayList<>(); |
| | | List<String> users = new ArrayList<>(); |
| | | for(GetTodoListResponse data :allHkList){ |
| | | users.add(data.getUserId()); |
| | | } |
| | | List<Integer> userIds = new ArrayList<>(); |
| | | List<Member > userList = memberMapper.selectList(new QueryWrapper<Member>().lambda() |
| | | .in(Member::getPhone,users) |
| | | .eq(Member::getIsdeleted,Constants.ZERO)); |
| | | for(GetTodoListResponse data :allHkList){ |
| | | Member u = getFromUserList(data.getUserId(),userList); |
| | | if(u==null){ |
| | |
| | | list.add(notices); |
| | | } |
| | | if(list.size()>0){ |
| | | noticesJoinMapper.insert(list);//批量插入记录 |
| | | } |
| | | } |
| | | if(userIds.size()>0){ |
| | | //清空海康全部的代办数据 |
| | | noticesJoinMapper.delete(new UpdateWrapper<Notices>().lambda() |
| | | .eq(Notices::getType, Constants.noticesObjectType.hknotice) |
| | | .in(Notices::getUserId, userIds)); |
| | | noticesJoinMapper.insert(list);//批量插入记录 |
| | | } |
| | | } |
| | | |
| | | }catch (Exception e){ |
| | | e.printStackTrace(); |
| | | }finally { |