Commit 22b9e29c authored by liuChang's avatar liuChang

添加默认监控分批传参

parent 8a8d94fd
......@@ -360,12 +360,12 @@ public class MonitorServiceImpl implements MonitorService {
idList.add(companyId);
}
}
//去除重复企业id
idList = idList.stream().distinct().collect(Collectors.toList());
RedisUtils.setCacheList("monitorCompanyList",idList);
//设置过期时间两天
RedisUtils.expire("monitorCompanyList",172800);
}
//去除重复企业id
idList = idList.stream().distinct().collect(Collectors.toList());
log.info("获取供应商企业id数量:"+idList.size());
PushMonitorCompanyAddVo addVo = new PushMonitorCompanyAddVo();
......@@ -379,7 +379,6 @@ public class MonitorServiceImpl implements MonitorService {
addVo.setCid(idList);
log.info("中建一局用户添加默认监控企业!");
Map<String, Object> map = dskOpenApiUtil.requestBody("/operate/monitor/company/addDefaultCompany", BeanUtil.beanToMap(addVo, false, false));
log.info("addDefaultCompany 返回值map====================》"+map.toString());
}else {
//循环次数
int num = (size+(200-1))/200;
......@@ -394,7 +393,6 @@ public class MonitorServiceImpl implements MonitorService {
addVo.setCid(newList);
log.info("中建一局用户添加默认监控企业------->循环添加:"+i*200+"----"+(i+1)*200);
Map<String, Object> map = dskOpenApiUtil.requestBody("/operate/monitor/company/addDefaultCompany", BeanUtil.beanToMap(addVo, false, false));
log.info("addDefaultCompany 循环添加返回值map====================》"+map.toString());
}
}
return R.ok("默认企业添加中,请稍候");
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment