diff --git a/src/main/java/com/cm/population/listener/ImportExcelListener.java b/src/main/java/com/cm/population/listener/ImportExcelListener.java index e67d2ea..d2d2934 100644 --- a/src/main/java/com/cm/population/listener/ImportExcelListener.java +++ b/src/main/java/com/cm/population/listener/ImportExcelListener.java @@ -12,6 +12,7 @@ import com.cm.population.utils.ImportExcelHelper; import java.lang.reflect.Field; import java.util.*; +import java.util.stream.Collectors; /** * 导入excel的监听处理类 @@ -125,7 +126,7 @@ public class ImportExcelListener extends AnalysisEventListener{ if(list.size() > BATCH_COUNT){ try { insertData(); - } catch (NoSuchMethodException e) { + } catch (Exception e) { e.printStackTrace(); } } @@ -143,6 +144,8 @@ public class ImportExcelListener extends AnalysisEventListener{ insertData(); } catch (NoSuchMethodException e) { e.printStackTrace(); + } catch (Exception e) { + e.printStackTrace(); } } } @@ -198,127 +201,127 @@ public class ImportExcelListener extends AnalysisEventListener{ /** * 将数据插入数据库操作 */ - private void insertData() throws NoSuchMethodException { + private void insertData() throws Exception { String value = ""; // 出租房 if(list.get(0) instanceof RentalHousingModel) { - for(int i=0;i rentalHousingModelList = (List) list; + // 用来临时储存数据 + List houseNumber = new ArrayList<>(); + // 过滤去重 + List rentalHousingModelList1 = rentalHousingModelList.stream().filter( + v -> { + boolean flag = !houseNumber.contains(v.getHouseNumber()); + houseNumber.add(v.getHouseNumber()); + if(!flag) { + String msg = "房屋编号重复"; + ImportFailDto importFailDto = new ImportFailDto(v, msg); + importFailDtoList.add(importFailDto); + } + return flag; + } + ).collect(Collectors.toList()); + handleImportExcelService.saveRentalHousing(rentalHousingModelList1, importFailDtoList); } // 户籍信息 if(list.get(0) instanceof CensusMsgModel) { - for(int i=0;i censusMsgModelList = (List) list; + // 用来临时储存数据 + List baseId = new ArrayList<>(); + // 过滤去重 + List censusMsgModelList1 = censusMsgModelList.stream().filter( + v -> { + boolean flag = !baseId.contains(v.getBaseId()); + baseId.add(v.getBaseId()); + if(!flag) { + String msg = "身份证号码重复"; + ImportFailDto importFailDto = new ImportFailDto(v, msg); + importFailDtoList.add(importFailDto); + } + return flag; + } + ).collect(Collectors.toList()); + handleImportExcelService.saveCensusMsg(censusMsgModelList1, importFailDtoList); } // 留守人员 if(list.get(0) instanceof HomePersonModel) { - for(int i=0;i homePersonModelList = (List) list; + // 用来临时储存数据 + List baseId = new ArrayList<>(); + // 过滤去重 + List homePersonModelList1 = homePersonModelList.stream().filter( + v -> { + boolean flag = !baseId.contains(v.getBaseId()); + baseId.add(v.getBaseId()); + if(!flag) { + String msg = "身份证号码重复"; + ImportFailDto importFailDto = new ImportFailDto(v, msg); + importFailDtoList.add(importFailDto); + } + return flag; + } + ).collect(Collectors.toList()); + handleImportExcelService.saveHomePerson(homePersonModelList1, importFailDtoList); } // 流动人口 if(list.get(0) instanceof FloatingPopulationModel) { - for(int i=0;i floatingPopulationModelList = (List) list; + // 用来临时储存数据 + List baseId = new ArrayList<>(); + // 过滤去重 + List floatingPopulationModelList1 = floatingPopulationModelList.stream().filter( + v -> { + boolean flag = !baseId.contains(v.getBaseId()); + baseId.add(v.getBaseId()); + if(!flag) { + String msg = "身份证号码重复"; + ImportFailDto importFailDto = new ImportFailDto(v, msg); + importFailDtoList.add(importFailDto); + } + return flag; + } + ).collect(Collectors.toList()); + handleImportExcelService.saveFloatingPopulation(floatingPopulationModelList1, importFailDtoList); } // 重点青少年 if(list.get(0) instanceof KeyTeenagersModel) { - for(int i=0;i keyTeenagersModelList = (List) list; + // 用来临时储存数据 + List baseId = new ArrayList<>(); + // 过滤去重 + List keyTeenagersModelList1 = keyTeenagersModelList.stream().filter( + v -> { + boolean flag = !baseId.contains(v.getBaseId()); + baseId.add(v.getBaseId()); + if(!flag) { + String msg = "身份证号码重复"; + ImportFailDto importFailDto = new ImportFailDto(v, msg); + importFailDtoList.add(importFailDto); + } + return flag; + } + ).collect(Collectors.toList()); + handleImportExcelService.saveKeyTeenagers(keyTeenagersModelList1, importFailDtoList); } // 境外人员 if(list.get(0) instanceof OverseaspersonnelModel) { - for(int i=0;i overseaspersonnelModelList = (List) list; + // 用来临时储存数据 + List cardNumber = new ArrayList<>(); + // 过滤去重 + List overseaspersonnelModelList1 = overseaspersonnelModelList.stream().filter( + v -> { + boolean flag = !cardNumber.contains(v.getCardNumber()); + cardNumber.add(v.getCardNumber()); + if(!flag) { + String msg = "证件号码重复"; + ImportFailDto importFailDto = new ImportFailDto(v, msg); + importFailDtoList.add(importFailDto); + } + return flag; + } + ).collect(Collectors.toList()); + handleImportExcelService.saveOverseaspersonnel(overseaspersonnelModelList1, importFailDtoList); } listForDistinct.clear(); list.clear(); diff --git a/src/main/java/com/cm/population/pojo/model/RentalHousingModel.java b/src/main/java/com/cm/population/pojo/model/RentalHousingModel.java index fb487ff..1c9b9be 100644 --- a/src/main/java/com/cm/population/pojo/model/RentalHousingModel.java +++ b/src/main/java/com/cm/population/pojo/model/RentalHousingModel.java @@ -48,6 +48,7 @@ public class RentalHousingModel { private String modifier; private String gmtModified; private String isDelete; + private String id; public String getHouseNumber() { return houseNumber == null ? "" : houseNumber; @@ -224,4 +225,12 @@ public class RentalHousingModel { public void setIsDelete(String isDelete) { this.isDelete = isDelete; } + + public String getId() { + return id == null ? "" : id; + } + + public void setId(String id) { + this.id = id; + } } diff --git a/src/main/java/com/cm/population/service/handleimportexcel/IHandleImportExcelService.java b/src/main/java/com/cm/population/service/handleimportexcel/IHandleImportExcelService.java index 83a8414..b6cc0a8 100644 --- a/src/main/java/com/cm/population/service/handleimportexcel/IHandleImportExcelService.java +++ b/src/main/java/com/cm/population/service/handleimportexcel/IHandleImportExcelService.java @@ -1,5 +1,6 @@ package com.cm.population.service.handleimportexcel; +import com.cm.population.pojo.dtos.excel.ImportFailDto; import com.cm.population.pojo.dtos.excel.ImportResultDto; import java.util.List; @@ -38,42 +39,54 @@ public interface IHandleImportExcelService { /** * 批量保存出租房信息 * @param list + * @param importFailDtoList * @param + * @throws Exception */ - public void saveRentalHousing(List list); + public void saveRentalHousing(List list, List importFailDtoList) throws Exception; /** * 批量保存户籍信息 * @param list + * @param importFailDtoList * @param + * @throws Exception */ - public void saveCensusMsg(List list); + public void saveCensusMsg(List list, List importFailDtoList) throws Exception; /** * 批量保存留守人员 * @param list + * @param importFailDtoList * @param + * @throws Exception */ - public void saveHomePerson(List list); + public void saveHomePerson(List list, List importFailDtoList) throws Exception; /** * 批量保存流动人员 * @param list + * @param importFailDtoList * @param + * @throws Exception */ - public void saveFloatingPopulation(List list); + public void saveFloatingPopulation(List list, List importFailDtoList) throws Exception; /** * 批量保存重点青少年 * @param list + * @param importFailDtoList * @param + * @throws Exception */ - public void saveKeyTeenagers(List list); + public void saveKeyTeenagers(List list, List importFailDtoList) throws Exception; /** * 批量保存境外人员 * @param list + * @param importFailDtoList * @param + * @throws Exception */ - public void saveOverseaspersonnel(List list); + public void saveOverseaspersonnel(List list, List importFailDtoList) throws Exception; } diff --git a/src/main/java/com/cm/population/service/handleimportexcel/impl/HandleImportExcelServiceImpl.java b/src/main/java/com/cm/population/service/handleimportexcel/impl/HandleImportExcelServiceImpl.java index 5fc2896..850b990 100644 --- a/src/main/java/com/cm/population/service/handleimportexcel/impl/HandleImportExcelServiceImpl.java +++ b/src/main/java/com/cm/population/service/handleimportexcel/impl/HandleImportExcelServiceImpl.java @@ -1,6 +1,8 @@ package com.cm.population.service.handleimportexcel.impl; +import com.alibaba.excel.util.StringUtils; import com.cm.common.base.AbstractService; +import com.cm.common.utils.HashMapUtil; import com.cm.common.utils.UUIDUtil; import com.cm.population.dao.censusmsg.ICensusMsgDao; import com.cm.population.dao.floatingpopulation.IFloatingPopulationDao; @@ -8,6 +10,7 @@ import com.cm.population.dao.homeperson.IHomePersonDao; import com.cm.population.dao.keyteenagers.IKeyTeenagersDao; import com.cm.population.dao.overseaspersonnel.IOverseasPersonnelDao; import com.cm.population.dao.rentalhousing.IRentalHousingDao; +import com.cm.population.pojo.dtos.excel.ImportFailDto; import com.cm.population.pojo.dtos.excel.ImportResultDto; import com.cm.population.pojo.model.*; import com.cm.population.service.handleimportexcel.IHandleImportExcelService; @@ -57,7 +60,7 @@ public class HandleImportExcelServiceImpl extends AbstractService implements IHa } @Override - public void saveRentalHousing(List list) { + public void saveRentalHousing(List list, List importFailDtoList) throws Exception { List rentalHousingModelList = (List) list; for(RentalHousingModel rentalHousingModel: rentalHousingModelList) { String rentalHousingId = UUIDUtil.getUUID(); @@ -69,12 +72,19 @@ public class HandleImportExcelServiceImpl extends AbstractService implements IHa rentalHousingModel.setModifier(params.get("modifier").toString()); rentalHousingModel.setGmtModified(params.get("gmtModified").toString()); rentalHousingModel.setIsDelete("0"); + Map param = HashMapUtil.beanToMap(rentalHousingModel); + rentalHousingDao.saveRentalHousing(param); + if(StringUtils.isEmpty(param.get("id"))) { + String msg = "该数据已存在"; + ImportFailDto importFailDto = new ImportFailDto(rentalHousingModel, msg); + importFailDtoList.add(importFailDto); + } } - rentalHousingDao.saveRentalHousingList(rentalHousingModelList); + // rentalHousingDao.saveRentalHousingList(rentalHousingModelList); } @Override - public void saveCensusMsg(List list) { + public void saveCensusMsg(List list, List importFailDtoList) throws Exception { List censusMsgModelList = (List) list; for(CensusMsgModel censusMsgModel: censusMsgModelList) { String censusMsgId = UUIDUtil.getUUID(); @@ -86,12 +96,19 @@ public class HandleImportExcelServiceImpl extends AbstractService implements IHa censusMsgModel.setModifier(params.get("modifier").toString()); censusMsgModel.setGmtModified(params.get("gmtModified").toString()); censusMsgModel.setIsDelete("0"); + Map param = HashMapUtil.beanToMap(censusMsgModel); + censusMsgDao.saveCensusMsg(param); + if(StringUtils.isEmpty(param.get("id"))) { + String msg = "该数据已存在"; + ImportFailDto importFailDto = new ImportFailDto(censusMsgModel, msg); + importFailDtoList.add(importFailDto); + } } - censusMsgDao.saveCensusMsgList(censusMsgModelList); + // censusMsgDao.saveCensusMsgList(censusMsgModelList); } @Override - public void saveHomePerson(List list) { + public void saveHomePerson(List list, List importFailDtoList) throws Exception { List homePersonModelList = (List) list; for(HomePersonModel homePersonModel: homePersonModelList) { String homePersonId = UUIDUtil.getUUID(); @@ -103,12 +120,19 @@ public class HandleImportExcelServiceImpl extends AbstractService implements IHa homePersonModel.setModifier(params.get("modifier").toString()); homePersonModel.setGmtModified(params.get("gmtModified").toString()); homePersonModel.setIsDelete("0"); + Map param = HashMapUtil.beanToMap(homePersonModel); + homePersonDao.saveHomePerson(param); + if(StringUtils.isEmpty(param.get("id"))) { + String msg = "该数据已存在"; + ImportFailDto importFailDto = new ImportFailDto(homePersonModel, msg); + importFailDtoList.add(importFailDto); + } } - homePersonDao.saveHomePersonList(homePersonModelList); + // homePersonDao.saveHomePersonList(homePersonModelList); } @Override - public void saveFloatingPopulation(List list) { + public void saveFloatingPopulation(List list, List importFailDtoList) throws Exception { List floatingPopulationModelList = (List) list; for(FloatingPopulationModel floatingPopulationModel: floatingPopulationModelList) { String floatingPopulationId = UUIDUtil.getUUID(); @@ -120,12 +144,19 @@ public class HandleImportExcelServiceImpl extends AbstractService implements IHa floatingPopulationModel.setModifier(params.get("modifier").toString()); floatingPopulationModel.setGmtModified(params.get("gmtModified").toString()); floatingPopulationModel.setIsDelete("0"); + Map param = HashMapUtil.beanToMap(floatingPopulationModel); + floatingPopulationDao.saveFloatingPopulation(param); + if(StringUtils.isEmpty(param.get("id"))) { + String msg = "该数据已存在"; + ImportFailDto importFailDto = new ImportFailDto(floatingPopulationModel, msg); + importFailDtoList.add(importFailDto); + } } - floatingPopulationDao.saveFloatingPopulationList(floatingPopulationModelList); + // floatingPopulationDao.saveFloatingPopulationList(floatingPopulationModelList); } @Override - public void saveKeyTeenagers(List list) { + public void saveKeyTeenagers(List list, List importFailDtoList) throws Exception { List keyTeenagersModelList = (List) list; for(KeyTeenagersModel keyTeenagersModel: keyTeenagersModelList) { String keyTeenagersId = UUIDUtil.getUUID(); @@ -137,12 +168,19 @@ public class HandleImportExcelServiceImpl extends AbstractService implements IHa keyTeenagersModel.setModifier(params.get("modifier").toString()); keyTeenagersModel.setGmtModified(params.get("gmtModified").toString()); keyTeenagersModel.setIsDelete("0"); + Map param = HashMapUtil.beanToMap(keyTeenagersModel); + keyTeenagersDao.saveKeyTeenagers(param); + if(StringUtils.isEmpty(param.get("id"))) { + String msg = "该数据已存在"; + ImportFailDto importFailDto = new ImportFailDto(keyTeenagersModel, msg); + importFailDtoList.add(importFailDto); + } } - keyTeenagersDao.saveKeyTeenagersList(keyTeenagersModelList); + // keyTeenagersDao.saveKeyTeenagersList(keyTeenagersModelList); } @Override - public void saveOverseaspersonnel(List list) { + public void saveOverseaspersonnel(List list, List importFailDtoList) throws Exception { List overseaspersonnelModelList = (List) list; for(OverseaspersonnelModel overseaspersonnelModel: overseaspersonnelModelList) { String overseasPersonnelId = UUIDUtil.getUUID(); @@ -154,8 +192,15 @@ public class HandleImportExcelServiceImpl extends AbstractService implements IHa overseaspersonnelModel.setModifier(params.get("modifier").toString()); overseaspersonnelModel.setGmtModified(params.get("gmtModified").toString()); overseaspersonnelModel.setIsDelete("0"); + Map param = HashMapUtil.beanToMap(overseaspersonnelModel); + overseasPersonnelDao.saveOverseasPersonnel(param); + if(StringUtils.isEmpty(param.get("id"))) { + String msg = "该数据已存在"; + ImportFailDto importFailDto = new ImportFailDto(overseaspersonnelModel, msg); + importFailDtoList.add(importFailDto); + } } - overseasPersonnelDao.saveOverseaspersonnelList(overseaspersonnelModelList); + // overseasPersonnelDao.saveOverseaspersonnelList(overseaspersonnelModelList); } diff --git a/src/main/java/com/cm/population/utils/ImportExcelHelper.java b/src/main/java/com/cm/population/utils/ImportExcelHelper.java index 241d5a9..cf7b977 100644 --- a/src/main/java/com/cm/population/utils/ImportExcelHelper.java +++ b/src/main/java/com/cm/population/utils/ImportExcelHelper.java @@ -105,40 +105,52 @@ public class ImportExcelHelper { */ private static String checkRentalHousingData(RentalHousingModel rentalHousingModel) { if(StringUtils.isEmpty(rentalHousingModel.getHouseNumber())) { - return "房屋编号必填"; + rentalHousingModel.setHouseNumber("" + Math.random() * 1000000); + // return "房屋编号必填"; } if(StringUtils.isEmpty(rentalHousingModel.getHouseAddress())) { - return "房屋地址必填"; + // rentalHousingModel.setHouseAddress("无"); + // return "房屋地址必填"; } if(StringUtils.isEmpty(rentalHousingModel.getCardCode())) { - return "证件代码必填"; + // rentalHousingModel.setCardCode("无"); + // return "证件代码必填"; } if(StringUtils.isEmpty(rentalHousingModel.getCardNumber())) { - return "证件号码必填"; + // rentalHousingModel.setCardNumber("无"); + // return "证件号码必填"; } if(StringUtils.isEmpty(rentalHousingModel.getHouserName())) { - return "房主姓名必填"; + // rentalHousingModel.setHouserName("无"); + // return "房主姓名必填"; } if(StringUtils.isEmpty(rentalHousingModel.getHouserPhone())) { - return "房主联系方式必填"; + // rentalHousingModel.setHouserPhone("无"); + // return "房主联系方式必填"; } if(StringUtils.isEmpty(rentalHousingModel.getHouserAddress())) { - return "房主现居地址必填"; + // rentalHousingModel.setHouserAddress("无"); + // return "房主现居地址必填"; } if(StringUtils.isEmpty(rentalHousingModel.getLeasePurpose())) { - return "出租用途必填"; + // rentalHousingModel.setLeasePurpose("无"); + // return "出租用途必填"; } if(StringUtils.isEmpty(rentalHousingModel.getHiddenDangerType())) { - return "隐患类型必填"; + // rentalHousingModel.setHiddenDangerType("无"); + // return "隐患类型必填"; } if(StringUtils.isEmpty(rentalHousingModel.getLesseeCardNumber())) { - return "承租人身份证号必填"; + // rentalHousingModel.setLesseeCardNumber("无"); + // return "承租人身份证号必填"; } if(StringUtils.isEmpty(rentalHousingModel.getLesseeName())) { - return "承租人姓名必填"; + // rentalHousingModel.setLesseeName("无"); + // return "承租人姓名必填"; } if(StringUtils.isEmpty(rentalHousingModel.getLesseePhone())) { - return "承租人联系方式必填"; + // rentalHousingModel.setLesseePhone("无"); + // return "承租人联系方式必填"; } return ""; } @@ -159,13 +171,13 @@ public class ImportExcelHelper { return "须先完善人员基础信息"; } if(StringUtils.isEmpty(censusMsgModel.getPeopleSameCensus())) { - return "人户一致标识必填"; + // return "人户一致标识必填"; } if(StringUtils.isEmpty(censusMsgModel.getCensusNumber())) { - return "户号必填"; + // return "户号必填"; } if(StringUtils.isEmpty(censusMsgModel.getIdCardOfHouseholder())) { - return "户主公民身份证号必填"; + // return "户主公民身份证号必填"; } if(StringUtils.isEmpty(censusMsgModel.getNameOfHouseholder())) { return "户主姓名必填"; @@ -192,7 +204,7 @@ public class ImportExcelHelper { return "须先完善人员基础信息"; } if(StringUtils.isEmpty(homePersonModel.getPeopleSameCensus())) { - return "人户一致标识必填"; + // return "人户一致标识必填"; } if(StringUtils.isEmpty(homePersonModel.getHomePersonType())) { return "留守人员类型必填"; @@ -224,6 +236,9 @@ public class ImportExcelHelper { if(StringUtils.isEmpty(floatingPopulationModel.getBaseId())) { return "身份证号码必填"; } + if(19 == floatingPopulationModel.getBaseId().length()) { + floatingPopulationModel.setBaseId(floatingPopulationModel.getBaseId().substring(1, 18)); + } Map param = new HashMap<>(); param.put("idCardNumber", floatingPopulationModel.getBaseId()); BasePopulationInfoDTO basePopulationInfoDTO = basePopulationInfoService.getBasePopulationInfo(param); @@ -231,7 +246,7 @@ public class ImportExcelHelper { return "须先完善人员基础信息"; } if(StringUtils.isEmpty(floatingPopulationModel.getInflowReason())) { - return "流入原因必填"; + // return "流入原因必填"; } if(StringUtils.isEmpty(floatingPopulationModel.getResidenceType())) { return "住所类型必填"; @@ -402,7 +417,9 @@ public class ImportExcelHelper { * @param rentalHousingModel */ private static void rentalHousingCheck(RentalHousingModel rentalHousingModel) { - + if(19 == rentalHousingModel.getLesseeCardNumber().length()) { + rentalHousingModel.setLesseeCardNumber(rentalHousingModel.getLesseeCardNumber().substring(1, 18)); + } } /** @@ -416,6 +433,13 @@ public class ImportExcelHelper { if(!StringUtils.isEmpty(basePopulationInfoDTO.getBasePopulationInfoId())) { censusMsgModel.setBaseId(basePopulationInfoDTO.getBasePopulationInfoId()); } + + if(19 == censusMsgModel.getBaseId().length()) { + censusMsgModel.setBaseId(censusMsgModel.getBaseId().substring(1, 18)); + } + if(19 == censusMsgModel.getIdCardOfHouseholder().length()) { + censusMsgModel.setIdCardOfHouseholder(censusMsgModel.getIdCardOfHouseholder().substring(1, 18)); + } } /** @@ -429,6 +453,14 @@ public class ImportExcelHelper { if(!StringUtils.isEmpty(basePopulationInfoDTO.getBasePopulationInfoId())) { homePersonModel.setBaseId(basePopulationInfoDTO.getBasePopulationInfoId()); } + // 身份证号码 + if(19 == homePersonModel.getBaseId().length()) { + homePersonModel.setBaseId(homePersonModel.getBaseId().substring(1, 18)); + } + // 监护人身份证号码 + if(19 == homePersonModel.getLeadingCard().length()) { + homePersonModel.setLeadingCard(homePersonModel.getLeadingCard().substring(1, 18)); + } // 人户一致标识 if("一致".equals(homePersonModel.getPeopleSameCensus())) { homePersonModel.setPeopleSameCensus("01"); @@ -490,6 +522,12 @@ public class ImportExcelHelper { if(!StringUtils.isEmpty(basePopulationInfoDTO.getBasePopulationInfoId())) { floatingPopulationModel.setBaseId(basePopulationInfoDTO.getBasePopulationInfoId()); } + if(19 == floatingPopulationModel.getBaseId().length()) { + floatingPopulationModel.setBaseId(floatingPopulationModel.getBaseId().substring(1, 18)); + } + if(19 == floatingPopulationModel.getCardNumber().length()) { + floatingPopulationModel.setCardNumber(floatingPopulationModel.getCardNumber().substring(1, 18)); + } /*// 办证类型 switch (floatingPopulationModel.getRegistrationType()) { case "居住证": @@ -531,6 +569,12 @@ public class ImportExcelHelper { if(!StringUtils.isEmpty(basePopulationInfoDTO.getBasePopulationInfoId())) { keyTeenagersModel.setBaseId(basePopulationInfoDTO.getBasePopulationInfoId()); } + if(19 == keyTeenagersModel.getBaseId().length()) { + keyTeenagersModel.setBaseId(keyTeenagersModel.getBaseId().substring(1, 18)); + } + if(19 == keyTeenagersModel.getGuardianCard().length()) { + keyTeenagersModel.setGuardianCard(keyTeenagersModel.getGuardianCard().substring(1, 18)); + } /*// 人员类型 switch (keyTeenagersModel.getPersonType()) { case "闲散青少年": @@ -591,6 +635,7 @@ public class ImportExcelHelper { * @param overseaspersonnelModel */ private static void overseaspersonnelCheck(OverseaspersonnelModel overseaspersonnelModel) { + overseaspersonnelModel.setCardNumber(overseaspersonnelModel.getCardNumber().substring(1, overseaspersonnelModel.getCardNumber().length() - 1)); /*// 性别 switch (overseaspersonnelModel.getSex()) { case "未知的性别": diff --git a/src/main/resources/mybatis/mapper/censusmsg/censusmsg-mapper.xml b/src/main/resources/mybatis/mapper/censusmsg/censusmsg-mapper.xml index 136e091..6a9f643 100644 --- a/src/main/resources/mybatis/mapper/censusmsg/censusmsg-mapper.xml +++ b/src/main/resources/mybatis/mapper/censusmsg/censusmsg-mapper.xml @@ -21,8 +21,8 @@ - - INSERT INTO gen_census_msg( + + INSERT IGNORE INTO gen_census_msg( census_msg_id, base_id, name_of_householder, @@ -66,7 +66,7 @@ - INSERT INTO gen_census_msg( + INSERT IGNORE INTO gen_census_msg( census_msg_id, base_id, name_of_householder, diff --git a/src/main/resources/mybatis/mapper/floatingpopulation/floatingpopulation-mapper.xml b/src/main/resources/mybatis/mapper/floatingpopulation/floatingpopulation-mapper.xml index f7082ca..15afe35 100644 --- a/src/main/resources/mybatis/mapper/floatingpopulation/floatingpopulation-mapper.xml +++ b/src/main/resources/mybatis/mapper/floatingpopulation/floatingpopulation-mapper.xml @@ -21,8 +21,8 @@ - - INSERT INTO gen_floating_population( + + INSERT IGNORE INTO gen_floating_population( floating_population_id, base_id, card_expire_date, @@ -68,7 +68,7 @@ - INSERT INTO gen_floating_population( + INSERT IGNORE INTO gen_floating_population( floating_population_id, base_id, card_expire_date, diff --git a/src/main/resources/mybatis/mapper/homeperson/homeperson-mapper.xml b/src/main/resources/mybatis/mapper/homeperson/homeperson-mapper.xml index 7d4f182..0aa28bb 100644 --- a/src/main/resources/mybatis/mapper/homeperson/homeperson-mapper.xml +++ b/src/main/resources/mybatis/mapper/homeperson/homeperson-mapper.xml @@ -28,8 +28,8 @@ - - INSERT INTO gen_home_person( + + INSERT IGNORE INTO gen_home_person( home_person_id, healthy, relationship_with_home_people, @@ -87,7 +87,7 @@ - INSERT INTO gen_home_person( + INSERT IGNORE INTO gen_home_person( home_person_id, healthy, relationship_with_home_people, diff --git a/src/main/resources/mybatis/mapper/keyteenagers/keyteenagers-mapper.xml b/src/main/resources/mybatis/mapper/keyteenagers/keyteenagers-mapper.xml index 1aaaf6d..044a2a2 100644 --- a/src/main/resources/mybatis/mapper/keyteenagers/keyteenagers-mapper.xml +++ b/src/main/resources/mybatis/mapper/keyteenagers/keyteenagers-mapper.xml @@ -28,8 +28,8 @@ - - INSERT INTO gen_key_teenagers( + + INSERT IGNORE INTO gen_key_teenagers( key_teenagers_id, relationship_with_guardian, family_situation, @@ -87,7 +87,7 @@ - INSERT INTO gen_key_teenagers( + INSERT IGNORE INTO gen_key_teenagers( key_teenagers_id, relationship_with_guardian, family_situation, diff --git a/src/main/resources/mybatis/mapper/overseaspersonnel/overseaspersonnel-mapper.xml b/src/main/resources/mybatis/mapper/overseaspersonnel/overseaspersonnel-mapper.xml index be32e85..e94d3de 100644 --- a/src/main/resources/mybatis/mapper/overseaspersonnel/overseaspersonnel-mapper.xml +++ b/src/main/resources/mybatis/mapper/overseaspersonnel/overseaspersonnel-mapper.xml @@ -28,8 +28,8 @@ - - INSERT INTO gen_overseas_personnel( + + INSERT IGNORE INTO gen_overseas_personnel( overseas_personnel_id, to_china_purpose, service_address, @@ -56,7 +56,8 @@ modifier, gmt_modified, is_delete - ) VALUES( + ) + SELECT #{overseasPersonnelId}, #{toChinaPurpose}, #{serviceAddress}, @@ -83,12 +84,23 @@ #{modifier}, #{gmtModified}, #{isDelete} - ) + FROM + DUAL + WHERE + NOT EXISTS ( + SELECT + * + FROM + gen_overseas_personnel + WHERE + card_number = #{cardNumber} + AND is_delete = 0 + ) - INSERT INTO gen_overseas_personnel( + INSERT IGNORE INTO gen_overseas_personnel( overseas_personnel_id, to_china_purpose, service_address, diff --git a/src/main/resources/mybatis/mapper/rentalhousing/rentalhousing-mapper.xml b/src/main/resources/mybatis/mapper/rentalhousing/rentalhousing-mapper.xml index 7bf37e2..76db9d4 100644 --- a/src/main/resources/mybatis/mapper/rentalhousing/rentalhousing-mapper.xml +++ b/src/main/resources/mybatis/mapper/rentalhousing/rentalhousing-mapper.xml @@ -23,8 +23,8 @@ - - INSERT INTO gen_rental_housing( + + INSERT IGNORE INTO gen_rental_housing( rental_housing_id, lessee_name, longitude, @@ -47,7 +47,7 @@ modifier, gmt_modified, is_delete - ) VALUES( + ) SELECT #{rentalHousingId}, #{lesseeName}, #{longitude}, @@ -70,12 +70,23 @@ #{modifier}, #{gmtModified}, #{isDelete} - ) + FROM + DUAL + WHERE + NOT EXISTS ( + SELECT + * + FROM + gen_rental_housing + WHERE + house_number = #{houseNumber} + AND is_delete = 0 + ) - - INSERT INTO gen_rental_housing( + + INSERT IGNORE INTO gen_rental_housing( rental_housing_id, lessee_name, longitude,