| | |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | | import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; |
| | | import com.doumee.biz.system.SystemDictDataBiz; |
| | | import com.doumee.core.constants.ResponseStatus; |
| | | import com.doumee.core.exception.BusinessException; |
| | | import com.doumee.core.haikang.model.HKConstants; |
| | |
| | | public class HkSyncNoticeServiceImpl extends HkSyncBaseServiceImpl { |
| | | @Autowired |
| | | private NoticesJoinMapper noticesJoinMapper; |
| | | @Autowired |
| | | private SystemDictDataBiz systemDictDataBiz; |
| | | @Autowired |
| | | private MemberMapper memberMapper; |
| | | |
| | |
| | | while (hasNext){ |
| | | //分页遍历循环查询所有门禁设备数据 |
| | | GetTodoListRequest param = new GetTodoListRequest(); |
| | | param.setComId("dfe"); |
| | | // param.setComId("dfe");//接全部的代办 |
| | | param.setUserId(username); |
| | | param.setStatus(1);//只查待处理的数据 |
| | | param.setPageNo(curPage); |
| | |
| | | } |
| | | curPage++; |
| | | } |
| | | |
| | | |
| | | if(allHkList!=null && allHkList.size()>0){ |
| | | String gotoUrl = systemDictDataBiz.queryByCode(Constants.HK_PARAM,Constants.HK_WEBSITE_DOMAIN_URL).getCode(); |
| | | List<Notices> list = new ArrayList<>(); |
| | | for(GetTodoListResponse data :allHkList){ |
| | | Member u = getFromUserList(data.getUserId(),userList); |
| | |
| | | param.put("componentMenuId", data.getMenuCode()); |
| | | JSONObject c = new JSONObject(); |
| | | c.put("method","dealTlncMsg"); |
| | | c.put("argument",JSONObject.toJSONString(data)); |
| | | c.put("argument", data); |
| | | param.put("callback",c); |
| | | Notices notices = new Notices(); |
| | | notices.setCreateDate(DateUtil.getISO8601DateByStr(data.getMsgCreateTimeIso())); |
| | |
| | | notices.setParam3(data.getMsgCreateTime()); |
| | | notices.setParam5(JSONObject.toJSONString(param)); |
| | | notices.setType(Constants.noticesObjectType.hknotice); |
| | | notices.setRemark(gotoUrl+"dps/web/wxAuth/loginV2?oaId=atwl&redirectId=index"); |
| | | notices.setRemark(gotoUrl+StringUtils.defaultString(data.getSegmentId(),"")+StringUtils.defaultString(data.getH5Url(),"")); |
| | | list.add(notices); |
| | | } |
| | | if(list.size()>0){ |