Commit 936dbdb4 authored by danfuman's avatar danfuman

Merge branch 'V20231129-中建一局二公司' of http://192.168.60.201/root/dsk-operate-sys...

Merge branch 'V20231129-中建一局二公司' of http://192.168.60.201/root/dsk-operate-sys into V20231129-中建一局二公司
parents d15f1be9 e6aa61e6
...@@ -343,26 +343,27 @@ public class MonitorServiceImpl implements MonitorService { ...@@ -343,26 +343,27 @@ public class MonitorServiceImpl implements MonitorService {
public R addDefaultCompany() { public R addDefaultCompany() {
//获取所有供应商企业名称 //获取所有供应商企业名称
List<Integer> idList = new ArrayList<>(); List<Integer> idList = new ArrayList<>();
idList.add(3068);
//如果没有上一次的企业id数据则直接返回
if (RedisUtils.hasKey("monitorCompanyList")){ // //如果没有上一次的企业id数据则直接返回
log.info("添加默认企业监控:企业id从缓存中取"); // if (RedisUtils.hasKey("monitorCompanyList")){
idList = RedisUtils.getCacheList("monitorCompanyList"); // log.info("添加默认企业监控:企业id从缓存中取");
}else { // idList = RedisUtils.getCacheList("monitorCompanyList");
List<String> list = customerMapper.allSearchCompanyNameList(); // }else {
for (String companyName : list) { // List<String> list = customerMapper.allSearchCompanyNameList();
//循环匹配 得到能关联上的企业id // for (String companyName : list) {
Map<String, Object> map = opportunityRadarService.enterpriseByName(companyName); // //循环匹配 得到能关联上的企业id
if (!ObjectUtils.isEmpty(map.get("data"))) { // Map<String, Object> map = opportunityRadarService.enterpriseByName(companyName);
Map<String, Object> data = BeanUtil.beanToMap(map.get("data")); // if (!ObjectUtils.isEmpty(map.get("data"))) {
Integer companyId = MapUtil.getInt(data, "jskEid"); // Map<String, Object> data = BeanUtil.beanToMap(map.get("data"));
idList.add(companyId); // Integer companyId = MapUtil.getInt(data, "jskEid");
} // idList.add(companyId);
} // }
RedisUtils.setCacheList("monitorCompanyList",idList); // }
//设置过期时间两天 // RedisUtils.setCacheList("monitorCompanyList",idList);
RedisUtils.expire("monitorCompanyList",172800); // //设置过期时间两天
} // RedisUtils.expire("monitorCompanyList",172800);
// }
PushMonitorCompanyAddVo addVo = new PushMonitorCompanyAddVo(); PushMonitorCompanyAddVo addVo = new PushMonitorCompanyAddVo();
addVo.setSystemCode("ZJYJ"); addVo.setSystemCode("ZJYJ");
...@@ -373,6 +374,7 @@ public class MonitorServiceImpl implements MonitorService { ...@@ -373,6 +374,7 @@ public class MonitorServiceImpl implements MonitorService {
} }
log.info("中建一局用户添加默认监控企业!"); log.info("中建一局用户添加默认监控企业!");
Map<String, Object> map = dskOpenApiUtil.requestBody("/operate/monitor/company/addDefaultCompany", BeanUtil.beanToMap(addVo, false, false)); Map<String, Object> map = dskOpenApiUtil.requestBody("/operate/monitor/company/addDefaultCompany", BeanUtil.beanToMap(addVo, false, false));
log.info("----------------------------------"+map.toString());
return BeanUtil.toBean(map, R.class); return BeanUtil.toBean(map, R.class);
} }
} }
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