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

kafka无法删除的问题

Browse Source
This commit is contained in:
wans 2022-01-26 12:50:05 +08:00
parent a75556c788
commit f5b3d49573
3 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/cn/com/tenlion/commonpopulation/service/basepopulationinfo/impl/BasePopulationInfoServiceImpl.java
View File

@ -526,6 +526,10 @@ public class BasePopulationInfoServiceImpl extends DefaultBaseService implements
jObj.put("tableNumber", "C0007"); jObj.put("tableNumber", "C0007");
jObj.put("uid", params.get("idCardNumber").toString()); jObj.put("uid", params.get("idCardNumber").toString());
jObj.put("action", action); jObj.put("action", action);
if("delete".equals(action)){
kafkaTemplate.send("tableSync", jObj.toJSONString());
return;
}
PopulationInfo info = new PopulationInfo(); PopulationInfo info = new PopulationInfo();
info.setfull_name(params.get("fullName") == null ? null : params.get("fullName").toString()); info.setfull_name(params.get("fullName") == null ? null : params.get("fullName").toString());
info.setname_used_before(params.get("nameUsedBefore") == null ? null : params.get("nameUsedBefore").toString()); info.setname_used_before(params.get("nameUsedBefore") == null ? null : params.get("nameUsedBefore").toString());

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

@ -360,6 +360,10 @@ 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);
if("delete".equals(action)){
kafkaTemplate.send("tableSync", jObj.toJSONString());
return;
}
Map<String, Object> query = new HashMap<>(); Map<String, Object> query = new HashMap<>();
query.put("floatingPopulationId",params.get("floatingPopulationId").toString()); query.put("floatingPopulationId",params.get("floatingPopulationId").toString());
FloatingPopulationDTO floatingPopulation = floatingPopulationDao.getFloatingPopulation(params); FloatingPopulationDTO floatingPopulation = floatingPopulationDao.getFloatingPopulation(params);

4
src/main/java/cn/com/tenlion/commonpopulation/service/overseaspersonnel/impl/OverseasPersonnelServiceImpl.java
View File

@ -327,6 +327,10 @@ public class OverseasPersonnelServiceImpl extends DefaultBaseService implements
jObj.put("tableNumber", "C0008"); jObj.put("tableNumber", "C0008");
jObj.put("uid", params.get("overseasPersonnelId").toString()); jObj.put("uid", params.get("overseasPersonnelId").toString());
jObj.put("action", action); jObj.put("action", action);
if("delete".equals(action)){
kafkaTemplate.send("tableSync", jObj.toJSONString());
return;
}
OverseasPersonnel info = new OverseasPersonnel(); OverseasPersonnel info = new OverseasPersonnel();
info.setlocation_all(params.get("areaNames") == null ? null : params.get("areaNames").toString()); info.setlocation_all(params.get("areaNames") == null ? null : params.get("areaNames").toString());
info.setlocation_code(params.get("areaCode") == null ? null : params.get("areaCode").toString()); info.setlocation_code(params.get("areaCode") == null ? null : params.get("areaCode").toString());