Tenlion/wlcb-common-population
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

流动人口推送不成功的问题

Browse Source
This commit is contained in:
wans 2022-01-26 12:29:56 +08:00
parent b870df75e0
commit a75556c788
1 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/main/java/cn/com/tenlion/commonpopulation/service/floatingpopulation/impl/FloatingPopulationServiceImpl.java
View File

@ -351,7 +351,7 @@ public class FloatingPopulationServiceImpl extends DefaultBaseService implements
info.setkey_of_follow("是"); info.setkey_of_follow("是");
} }
jObj.put("data", info.saveCheckToJson()); jObj.put("data", info.saveCheckToJson());
//kafkaTemplate.send("tableSync", jObj.toJSONString()); kafkaTemplate.send("tableSync", jObj.toJSONString());
} }
@Override @Override
@ -360,13 +360,16 @@ public class FloatingPopulationServiceImpl extends DefaultBaseService implements
jObj.put("tableNumber", "C0009"); jObj.put("tableNumber", "C0009");
jObj.put("uid", params.get("floatingPopulationId").toString()); jObj.put("uid", params.get("floatingPopulationId").toString());
jObj.put("action", action); jObj.put("action", action);
Map<String, Object> query = new HashMap<>();
query.put("floatingPopulationId",params.get("floatingPopulationId").toString());
FloatingPopulationDTO floatingPopulation = floatingPopulationDao.getFloatingPopulation(params);
FloatingPopulation info = new FloatingPopulation(); FloatingPopulation info = new FloatingPopulation();
info.setid_card_number(params.get("idCardNumber") == null ? null : params.get("idCardNumber").toString()); info.setid_card_number(params.get("idCardNumber") == null ? null : params.get("idCardNumber").toString());
info.setfull_name(params.get("fullName") == null ? "" : params.get("fullName").toString()); info.setfull_name(params.get("fullName") == null ? "" : params.get("fullName").toString());
info.setlocation_all(params.get("areaNames") == null ? null : params.get("areaNames").toString()); info.setlocation_all(floatingPopulation.getAreaNames());
info.setlocation_code(params.get("areaCode") == null ? null : params.get("areaCode").toString()); info.setlocation_code(floatingPopulation.getAreaCode());
if(params.get("areaCode") != null && !"".equals(params.get("areaCode").toString())){ if(floatingPopulation.getAreaCode() != null && !"".equals(floatingPopulation.getAreaCode())){
AreaDTO areaDTO = areaService.getByCode(params.get("areaCode").toString()); AreaDTO areaDTO = areaService.getByCode(floatingPopulation.getAreaCode());
info.setlocation_area(areaDTO == null ? null : areaDTO.getAreaName()); info.setlocation_area(areaDTO == null ? null : areaDTO.getAreaName());
} }
info.setinflow_reason(params.get("inflowReason") == null ? null : params.get("inflowReason").toString()); info.setinflow_reason(params.get("inflowReason") == null ? null : params.get("inflowReason").toString());