测试修改
This commit is contained in:
parent
527aa9ed9b
commit
7943581dee
@ -599,7 +599,8 @@ public class BasePopulationInfoServiceImpl extends DefaultBaseService implements
|
||||
info.setname_used_before(item.getNameUsedBefore());
|
||||
String gender = IdCardVerifyUtil.getIdCardGender(item.getIdCardNumber());
|
||||
info.setgender("1".equals(gender) ? "男" : "女");
|
||||
info.setage(IdCardVerifyUtil.getAgeFromIdCardNumber(item.getIdCardNumber()));
|
||||
//info.setage(IdCardVerifyUtil.getAgeFromIdCardNumber(item.getIdCardNumber()));
|
||||
info.setage(15);
|
||||
if(item.getNation() != null && !"".equals(item.getNation())){
|
||||
DataDTO dataDTO = mongoDataService.get(item.getNation());
|
||||
info.setnation(dataDTO == null ? "" : dataDTO.getDataName());
|
||||
@ -647,7 +648,7 @@ public class BasePopulationInfoServiceImpl extends DefaultBaseService implements
|
||||
info.setgrid_name(item.getGridName() == null ? "" : item.getGridName());
|
||||
jObj.put("data", info.saveCheckToJson());
|
||||
kafkaTemplate.send("tableSync", jObj.toJSONString());
|
||||
if(forIndex % 10000 == 0){
|
||||
if(forIndex != 0 && forIndex % 5000 == 0){
|
||||
System.out.println("================= PULL_COUNT_" + forIndex + " =================");
|
||||
}
|
||||
forIndex++;
|
||||
|
Loading…
Reference in New Issue
Block a user