|
|
@ -54,6 +54,12 @@ public class IcEnterpriseExcelImportListener implements ReadListener<EnterpriseI |
|
|
|
this.gridMap=gridMap; |
|
|
|
} |
|
|
|
|
|
|
|
@Override |
|
|
|
public void doAfterAllAnalysed(AnalysisContext context) { |
|
|
|
// 最后几条达不到阈值,这里必须再调用一次
|
|
|
|
execPersist(); |
|
|
|
} |
|
|
|
|
|
|
|
@Override |
|
|
|
public void invoke(EnterpriseImportExcelDTO data, AnalysisContext context) { |
|
|
|
|
|
|
@ -70,9 +76,9 @@ public class IcEnterpriseExcelImportListener implements ReadListener<EnterpriseI |
|
|
|
if(!placeTypeMap.containsKey(data.getPlaceTypeName())){ |
|
|
|
throw new ValidateException(String.format("【%s】场所类型不存在",data.getPlaceTypeName())); |
|
|
|
} |
|
|
|
if(!scaleMap.containsKey(data.getScaleName())){ |
|
|
|
/*if(!scaleMap.containsKey(data.getScaleName())){ |
|
|
|
throw new ValidateException(String.format("【%s】规模不存在",data.getScaleName())); |
|
|
|
} |
|
|
|
}*/ |
|
|
|
IcEnterpriseEntity enterpriseEntity = ConvertUtils.sourceToTarget(data, IcEnterpriseEntity.class); |
|
|
|
enterpriseEntity.setCustomerId(currentCustomerId); |
|
|
|
//网格id
|
|
|
@ -85,7 +91,8 @@ public class IcEnterpriseExcelImportListener implements ReadListener<EnterpriseI |
|
|
|
enterpriseEntity.setLongitude(StrConstant.EPMETY_STR); |
|
|
|
enterpriseEntity.setLatitude(StrConstant.EPMETY_STR); |
|
|
|
//规模
|
|
|
|
enterpriseEntity.setScale(scaleMap.get(data.getScaleName())); |
|
|
|
// enterpriseEntity.setScale(scaleMap.get(data.getScaleName()));
|
|
|
|
enterpriseEntity.setScaleTotal(data.getScaleTotal()); |
|
|
|
enterpriseEntity.setPlaceCategory("九小场所".equals(data.getPlaceCategoryName()) ? "0" : "1"); |
|
|
|
|
|
|
|
//网格id+场所名称
|
|
|
@ -121,7 +128,7 @@ public class IcEnterpriseExcelImportListener implements ReadListener<EnterpriseI |
|
|
|
errorRow.setGridName(data.getGridName()); |
|
|
|
errorRow.setPlaceOrgName(data.getPlaceOrgName()); |
|
|
|
errorRow.setAddress(data.getAddress()); |
|
|
|
errorRow.setScaleName(data.getScaleName()); |
|
|
|
errorRow.setScaleTotal(data.getScaleTotal()); |
|
|
|
errorRow.setPersonInCharge(data.getPersonInCharge()); |
|
|
|
errorRow.setMobile(data.getMobile()); |
|
|
|
errorRow.setErrorInfo(errorMsg); |
|
|
@ -129,12 +136,6 @@ public class IcEnterpriseExcelImportListener implements ReadListener<EnterpriseI |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
@Override |
|
|
|
public void doAfterAllAnalysed(AnalysisContext context) { |
|
|
|
// 最后几条达不到阈值,这里必须再调用一次
|
|
|
|
execPersist(); |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* 执行持久化 |
|
|
|
*/ |
|
|
|