package com.java110.job.importData.adapt; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.java110.core.factory.GenerateCodeFactory; import com.java110.dto.community.CommunityDto; import com.java110.dto.dict.DictDto; import com.java110.dto.importData.*; import com.java110.dto.log.AssetImportLogDetailDto; import com.java110.dto.oweFeeCallable.OweFeeCallableDto; import com.java110.dto.owner.OwnerCarDto; import com.java110.dto.owner.OwnerDto; import com.java110.dto.owner.OwnerRoomRelDto; import com.java110.dto.parking.ParkingAreaDto; import com.java110.dto.parking.ParkingSpaceDto; import com.java110.dto.room.RoomDto; import com.java110.fee.dao.IApplyRoomDiscountServiceDao; import com.java110.intf.community.ICommunityV1InnerServiceSMO; import com.java110.intf.community.IParkingAreaV1InnerServiceSMO; import com.java110.intf.community.IParkingSpaceV1InnerServiceSMO; import com.java110.intf.community.IRoomInnerServiceSMO; import com.java110.intf.dev.IDictV1InnerServiceSMO; import com.java110.intf.fee.IOweFeeCallableV1InnerServiceSMO; import com.java110.intf.user.IOwnerCarV1InnerServiceSMO; import com.java110.intf.user.IOwnerRoomRelInnerServiceSMO; import com.java110.intf.user.IOwnerV1InnerServiceSMO; import com.java110.job.importData.DefaultImportData; import com.java110.job.importData.IImportDataAdapt; import com.java110.po.car.OwnerCarPo; import com.java110.po.dict.DictPo; import com.java110.po.oweFeeCallable.OweFeeCallablePo; import com.java110.po.owner.OwnerPo; import com.java110.po.parking.ParkingAreaPo; import com.java110.po.parking.ParkingSpacePo; import com.java110.po.room.ApplyRoomDiscountPo; import com.java110.po.room.LitigationInfoPo; import com.java110.utils.util.BeanConvertUtil; import com.java110.utils.util.ListUtil; import com.java110.utils.util.StringUtil; import org.mybatis.spring.SqlSessionTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.math.BigDecimal; import java.security.acl.Owner; import java.text.SimpleDateFormat; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; /** * 车辆导入 适配器 * 前端请求 时 必须传入 * param.append('importAdapt', "importRoomOwner"); */ @Service("importOwnerCarV2QueueData") public class ImportOwnerCarQueueV2DataAdapt extends DefaultImportData implements IImportDataAdapt { @Autowired private IOwnerCarV1InnerServiceSMO ownerCarV1InnerServiceSMOImpl; @Autowired private IApplyRoomDiscountServiceDao applyRoomDiscountServiceDaoImpl; @Autowired protected SqlSessionTemplate sqlSessionTemplate; @Autowired private IDictV1InnerServiceSMO dictV1InnerServiceSMOImpl; @Autowired private IOwnerV1InnerServiceSMO ownerV1InnerServiceSMOImpl; @Autowired private IParkingSpaceV1InnerServiceSMO parkingSpaceV1InnerServiceSMOImpl; @Autowired private IParkingAreaV1InnerServiceSMO parkingAreaV1InnerServiceSMOImpl; @Autowired private IOweFeeCallableV1InnerServiceSMO oweFeeCallableV1InnerServiceSMOImpl; @Autowired private IRoomInnerServiceSMO iroomInnerServiceSMOImpl; @Autowired ICommunityV1InnerServiceSMO communityV1InnerServiceSMOImpl; @Autowired IOwnerRoomRelInnerServiceSMO ownerRoomRelInnerServiceSMOImpl; @Override public void importData(List assetImportLogDetailDtos) { importDatas(assetImportLogDetailDtos); } private void importDatas(List infos) { String state = ""; String msg = ""; for (AssetImportLogDetailDto assetImportLogDetailDto : infos) { try { doImportData(assetImportLogDetailDto); updateImportLogDetailState(assetImportLogDetailDto.getDetailId()); } catch (Exception e) { e.printStackTrace(); updateImportLogDetailState(assetImportLogDetailDto.getDetailId(), e); } } } /** * 导入数据 * * @param assetImportLogDetailDto */ private void doImportData(AssetImportLogDetailDto assetImportLogDetailDto) { JSONObject data = JSONObject.parseObject(assetImportLogDetailDto.getContent()); String[] o = JSON.parseObject(data.getString("otherItem"), String[].class); String otherItem = data.getString("otherItem"); data.put("otherItem", null); OwnerCarDto ownerCarDto = BeanConvertUtil.covertBean(data, OwnerCarDto.class); if (ownerCarDto.getOwnerName() == null || "".equals(ownerCarDto.getOwnerName())) { RoomDto roomDto = new RoomDto(); roomDto.setRoadName(ownerCarDto.getRoadName()); roomDto.setFloorNum(ownerCarDto.getFloorNum()); roomDto.setCommunityId(ownerCarDto.getCommunityId()); roomDto.setUnitNum(ownerCarDto.getUnitNum()); roomDto.setRoomNum(ownerCarDto.getRoomNum()); List roomDtos = iroomInnerServiceSMOImpl.queryRooms(roomDto); if (roomDtos.isEmpty()) { throw new IllegalArgumentException("未填写业主且房屋不存在"); } else if (roomDtos.size() > 1) { throw new IllegalArgumentException("该房屋存在多个业主"); } else { OwnerRoomRelDto ownerRoomRelDto = new OwnerRoomRelDto(); ownerRoomRelDto.setRoomId(roomDtos.get(0).getRoomId()); List ownerRoomRelDtos = ownerRoomRelInnerServiceSMOImpl.queryOwnerRoomRels(ownerRoomRelDto); if (ownerRoomRelDtos.isEmpty()) { throw new IllegalArgumentException("未填写业主且该房屋未绑定业主"); } else { OwnerDto ownerDto = new OwnerDto(); ownerDto.setOwnerId(ownerRoomRelDtos.get(0).getOwnerId()); List ownerDtos = ownerV1InnerServiceSMOImpl.queryOwners(ownerDto); if (ownerDtos.isEmpty()) { throw new IllegalArgumentException("未知错误：00022"); } else { ownerCarDto.setOwnerName(ownerDtos.get(0).getName()); } } } } ownerCarDto.setOtherItem(o); ownerCarDto.setLeaseType("H"); CommunityDto communityDto = new CommunityDto(); Object[] os = ownerCarDto.getOtherItem(); String communityId = ownerCarDto.getCommunityId(); JSONArray objects = JSONObject.parseArray(otherItem); communityDto.setCommunityCode(defaultValue(os[1])); communityDto.setName(defaultValue(os[2])); List communityDtos = communityV1InnerServiceSMOImpl.queryCommunitys(communityDto); if (communityDtos.isEmpty()) { throw new IllegalArgumentException("不存在小区编码为：" + communityDto.getCommunityCode() + "的小区"); } assetImportLogDetailDto.setCommunityId(communityDtos.get(0).getCommunityId()); ownerCarDto.setCommunityId(communityDtos.get(0).getCommunityId()); communityDto.setCommunityId(communityDtos.get(0).getCommunityId()); //todo 导入业主信息 importOwnerData(ownerCarDto, os); OwnerCarPo ownerCarPo = BeanConvertUtil.covertBean(ownerCarDto, OwnerCarPo.class); ownerCarPo.setStartTime(ownerCarDto.getLogStartTime()); ownerCarPo.setEndTime(ownerCarDto.getLogEndTime()); //获取房屋名称 String carTypeCd = defaultValue(os[13]); if (!carTypeCd.equals("")){ DictDto dictDto = new DictDto(); dictDto.setTableName("owner_car"); dictDto.setTableColumns("car_type_cd"); dictDto.setName(carTypeCd); List dictDtos = dictV1InnerServiceSMOImpl.queryDicts(dictDto); if (dictDtos.isEmpty()) { dictDto.setName(null); List dictDtos1 = dictV1InnerServiceSMOImpl.queryDicts(dictDto); DictPo dictPo = new DictPo(); dictPo.setTableName("owner_car"); dictPo.setTableColumns("car_type_cd"); dictPo.setName(carTypeCd); dictPo.setDescription(carTypeCd); dictPo.setStatusCd(dictDtos1.get(dictDtos1.size() - 1).getStatusCd() + 100); int i = dictV1InnerServiceSMOImpl.saveDict(dictPo); if (i == 0) { throw new IllegalArgumentException("添加字典失败!"); } } else { ownerCarPo.setCarTypeCd(dictDtos.get(0).getStatusCd()); } } else { ownerCarPo.setCarTypeCd("1001"); //默认主车辆 } ParkingAreaDto parkingAreaDto = new ParkingAreaDto(); parkingAreaDto.setNum(ownerCarDto.getAreaNum()); parkingAreaDto.setTypeCd(ownerCarDto.getTypeCd()); parkingAreaDto.setCommunityId(ownerCarDto.getCommunityId()); //查询停车场 List parkingAreaDtos = parkingAreaV1InnerServiceSMOImpl.queryParkingAreas(parkingAreaDto); //Assert.listOnlyOne(parkingAreaDtos, "查询停车场错误！"); String paId = ""; if (ListUtil.isNull(parkingAreaDtos)) { paId = GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_paId); ParkingAreaPo parkingAreaPo = new ParkingAreaPo(); parkingAreaPo.setCommunityId(ownerCarDto.getCommunityId()); parkingAreaPo.setNum(ownerCarDto.getAreaNum()); parkingAreaPo.setPaId(paId); parkingAreaPo.setTypeCd(ownerCarDto.getTypeCd()); parkingAreaPo.setRemark("导入数据"); parkingAreaV1InnerServiceSMOImpl.saveParkingArea(parkingAreaPo); } else { paId = parkingAreaDtos.get(0).getPaId(); } ParkingSpaceDto parkingSpaceDto = new ParkingSpaceDto(); parkingSpaceDto.setNum(ownerCarDto.getNum()); parkingSpaceDto.setPaId(paId); parkingSpaceDto.setCommunityId(ownerCarDto.getCommunityId()); //查询停车位 List parkingSpaceDtos = parkingSpaceV1InnerServiceSMOImpl.queryParkingSpaces(parkingSpaceDto); String state = ""; String psId = ""; if (ListUtil.isNull(parkingSpaceDtos)) { psId = GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_psId); ParkingSpacePo parkingSpacePo = new ParkingSpacePo(); parkingSpacePo.setCommunityId(ownerCarDto.getCommunityId()); parkingSpacePo.setNum(ownerCarDto.getNum()); parkingSpacePo.setPaId(paId); parkingSpacePo.setParkingType(ParkingSpaceDto.TYPE_CD_COMMON); parkingSpacePo.setState(ParkingSpaceDto.STATE_FREE); parkingSpacePo.setArea("1"); parkingSpacePo.setPsId(psId); parkingSpacePo.setRemark("导入数据"); parkingSpaceV1InnerServiceSMOImpl.saveParkingSpace(parkingSpacePo); state = ParkingSpaceDto.STATE_FREE; } else { psId = parkingSpaceDtos.get(0).getPsId(); //获取停车位状态(出售 S，出租 H ，空闲 F) state = parkingSpaceDtos.get(0).getState(); } if (!StringUtil.isEmpty(state) && !state.equals("F")) { // throw new IllegalArgumentException(ownerCarDto.getAreaNum() + "停车场-" + ownerCarDto.getNum() + "停车位不是空闲状态！"); } ownerCarPo.setPsId(psId); ownerCarPo.setOwnerId(ownerCarDto.getOwnerId()); ownerCarPo.setCommunityId(ownerCarDto.getCommunityId()); ownerCarPo.setCarId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_carId)); ownerCarPo.setMemberId(ownerCarPo.getCarId()); ownerCarPo.setState("1001"); //1001 正常状态，2002 车位释放欠费状态，3003 车位释放 ownerCarPo.setLeaseType(ownerCarDto.getLeaseType()); ownerCarPo.setFirstPaymentDate(defaultValue(os[16])); ownerCarPo.setPaymentDeadlineDate(defaultValue(os[17])); ownerCarPo.setUnitPricePerMonth(defaultValue(os[18])); ownerCarPo.setAnnualReceivableAmount(defaultValue(os[19])); //-----打折信息 TODO 未添加重复校验 if (!defaultValue(objects.get(21)).isEmpty()) { ApplyRoomDiscountPo applyRoomDiscountPo = new ApplyRoomDiscountPo();//打折 applyRoomDiscountPo.setArdId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_ardId)); applyRoomDiscountPo.setCommunityId(communityId); RoomDto roomDto = new RoomDto(); roomDto.setCommunityId(communityId); roomDto.setRoadName(defaultValue(os[3])); roomDto.setFloorNum(defaultValue(os[4])); roomDto.setUnitNum(defaultValue(os[5])); roomDto.setRoomNum(defaultValue(os[6])); List roomDtos = iroomInnerServiceSMOImpl.queryRooms(roomDto); if (ListUtil.isNull(roomDtos)) { throw new IllegalArgumentException("未查询到房间"); } applyRoomDiscountPo.setRoomId(roomDtos.get(0).getRoomId()); applyRoomDiscountPo.setRoomName(roomDtos.get(0).getPropertyAddress()); applyRoomDiscountPo.setDiscountId("132025112781200067"); applyRoomDiscountPo.setApplyType("152025112756040048"); // applyRoomDiscountPo.setFixedDiscountValue(defaultNum(objects.get(36))); // applyRoomDiscountPo.setDiscountedAmount(defaultNum(objects.get(37))); // 2. 定义格式化器（注意：SimpleDateFormat 线程不安全，每次使用新建实例） SimpleDateFormat sdf = new SimpleDateFormat("yyyy/M"); try { SimpleDateFormat outputSdf = new SimpleDateFormat("yyyy-MM-dd"); applyRoomDiscountPo.setStartTime(outputSdf.format(sdf.parse(defaultValue(objects.get(21))))); applyRoomDiscountPo.setEndTime(outputSdf.format(sdf.parse(defaultValue(objects.get(22))))); }catch (Exception e){ throw new IllegalArgumentException("导入失败：处理折扣日期区间时出错"); } applyRoomDiscountPo.setDiscountArchiveDate(defaultValue(objects.get(24))); applyRoomDiscountPo.setCreateRemark(defaultValue(objects.get(25))); applyRoomDiscountPo.setCheckRemark("审批人：" + defaultValue(objects.get(26))); applyRoomDiscountPo.setReviewRemark("审批人：" + defaultValue(objects.get(27))); applyRoomDiscountPo.setCreateUserName("由系统导入"); applyRoomDiscountPo.setState("4"); applyRoomDiscountPo.setStatusCd("0"); applyRoomDiscountPo.setInUse("0"); applyRoomDiscountPo.setReturnWay("1001"); applyRoomDiscountPo.setRelatedAttachments(defaultValue(objects.get(29))); try { applyRoomDiscountServiceDaoImpl.saveApplyRoomDiscountInfo(BeanConvertUtil.beanCovertMap(applyRoomDiscountPo)); }catch (Exception e){ throw new IllegalArgumentException("导入失败"); } } //催收情况 if (!defaultValue(objects.get(35)).isEmpty()) { OweFeeCallablePo oweFeeCallablePo = new OweFeeCallablePo(); oweFeeCallablePo.setOfcId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_attrId)); oweFeeCallablePo.setAmountdOwed("0"); oweFeeCallablePo.setCallableWay(OweFeeCallableDto.CALLABLE_WAY_PRINT); oweFeeCallablePo.setOfcId(GenerateCodeFactory.getGeneratorId("11")); oweFeeCallablePo.setFeeId(""); oweFeeCallablePo.setFeeName("导入催收信息"); oweFeeCallablePo.setCommunityId(communityId); oweFeeCallablePo.setConfigId(""); oweFeeCallablePo.setOwnerId(ownerCarDto.getOwnerId()); oweFeeCallablePo.setOwnerName(ownerCarDto.getOwnerName()); oweFeeCallablePo.setPayerObjId(""); oweFeeCallablePo.setPayerObjName(ownerCarDto.getCarNum()); oweFeeCallablePo.setPayerObjType("3333"); oweFeeCallablePo.setRemark(defaultValue(objects.get(39))); oweFeeCallablePo.setStaffId("302025062612580518"); oweFeeCallablePo.setStaffName("刘志勇"); oweFeeCallablePo.setState(OweFeeCallableDto.STATE_COMPLETE); oweFeeCallablePo.setStartTime(defaultValueToDate(objects.get(37)));//TODO 时间段需要拆分 oweFeeCallablePo.setEndTime(defaultValueToDate(objects.get(37))); oweFeeCallablePo.setCreateTime(defaultValueToDate(objects.get(35))); int flag = oweFeeCallableV1InnerServiceSMOImpl.saveOweFeeCallable(oweFeeCallablePo); if (flag < 1) { throw new IllegalArgumentException("催收信息导入失败"); } //中国邮政挂号信 for (int i = 0; i < 5 ; i++) { int sum = 41; if (i > 3) { sum ++; } int index = i*2 + sum; if(objects.get(index) == null){ break; } HouseMailRecord houseMailRecord = new HouseMailRecord(); houseMailRecord.setId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_houseId)); houseMailRecord.setOwnerId(ownerCarDto.getOwnerId()); houseMailRecord.setHouseId(ownerCarDto.getCarId()); houseMailRecord.setCallableId(oweFeeCallablePo.getOfcId()); houseMailRecord.setCreateTime(defaultValueToDate(objects.get(index))); houseMailRecord.setMailNo(defaultValue(objects.get(index+1))); houseMailRecord.setServiceFee("0"); houseMailRecord.setMailResult(defaultValue(objects.get(index+2))); houseMailRecord.setRemark(defaultValue(objects.get(53))); int save = applyRoomDiscountServiceDaoImpl.saveHouseMailRecord(BeanConvertUtil.beanCovertMap(houseMailRecord)); if (save < 1) { throw new IllegalArgumentException("电联信息导入失败"); } } //----添加电联 List mailCallRecords = new ArrayList(); for (int i = 0 ; i < 5 ; i++) { int index = i * 2 + 54; if(defaultValue(objects.get(index)).isEmpty()){ // if (i == 0){ // MailCallRecord mailCallRecord = new MailCallRecord(); // mailCallRecord.setRemark(objects.get(115).toString()); // // int save = applyRoomDiscountServiceDaoImpl.saveMailCallRecord(BeanConvertUtil.beanCovertMap(mailCallRecord)); // } break; } MailCallRecord mailCallRecord = new MailCallRecord(); mailCallRecord.setCallDate(defaultValueToDate(objects.get(index))); mailCallRecord.setCallResult(defaultValue(objects.get(index+1))); // mailCallRecord.setCallContact(defaultValue(objects.get(index+2))); mailCallRecord.setRemark(defaultValue(objects.get(64))); mailCallRecords.add(mailCallRecord); } if (mailCallRecords.size() > 0) { Map param = new HashMap<>(); param.put("payeeReceiveList", BeanConvertUtil.beanCovertMap(mailCallRecords)); int insert = sqlSessionTemplate.insert("payeeReceiveInfoServiceDaoImpl.batchSavePayeeReceiveInfo", param); if (insert < 1) { throw new IllegalArgumentException("添加电联记录失败"); } } //---- //----法院审理程序72 if (!defaultValue(objects.get(72)).isEmpty()) { CourtTrialProcedure courtTrialProcedure = new CourtTrialProcedure(); courtTrialProcedure.setCallableId(oweFeeCallablePo.getOfcId()); courtTrialProcedure.setOwnerId(ownerCarDto.getOwnerId()); courtTrialProcedure.setAcceptCourtName(defaultValue(objects.get(72)));//受理法院名称 courtTrialProcedure.setJudgeName(defaultValue(objects.get(73)));//法官姓名 courtTrialProcedure.setJudgeContact(defaultValue(objects.get(74)));//法官联系方式 courtTrialProcedure.setJudgeNoticeAcceptDate(defaultValueToDate(objects.get(75)));//法官通知受理日期 courtTrialProcedure.setCourtMediationDate(defaultValueToDate(objects.get(76)));//法院调解日期 courtTrialProcedure.setMediationResult(defaultValue(objects.get(77)));//调解结果 courtTrialProcedure.setSubpoenaSignDate(defaultValueToDate(objects.get(78)));//传票签收日 courtTrialProcedure.setUndeliveredDate(defaultValueToDate(objects.get(79)));//未送达日期 courtTrialProcedure.setCourtSessionDate1(defaultValueToDate(objects.get(80)));//开庭日期1 courtTrialProcedure.setCourtSessionDate2(defaultValueToDate(objects.get(81)));//开庭日期2 courtTrialProcedure.setCaseNumber(defaultValue(objects.get(82)));//案号 courtTrialProcedure.setCourtSessionResult(defaultValue(objects.get(83)));//开庭结果 courtTrialProcedure.setJudgmentDate(defaultValueToDate(objects.get(84)));//判决日期 courtTrialProcedure.setJudgmentResult(defaultValue(objects.get(85)));//判决结果 courtTrialProcedure.setRemark(defaultValue(objects.get(86)));//备注 int i = applyRoomDiscountServiceDaoImpl.saveCourtTrialProcedure(BeanConvertUtil.beanCovertMap(courtTrialProcedure)); if (i < 1) { throw new IllegalArgumentException("法院审理程序导入失败"); } } //----- //法院执行程序 if (!defaultValue(objects.get(87)).isEmpty()) { CourtExecutionProcedure courtExecutionProcedure = new CourtExecutionProcedure(); courtExecutionProcedure.setCallableId(oweFeeCallablePo.getOfcId()); courtExecutionProcedure.setOwnerId(ownerCarDto.getOwnerId()); courtExecutionProcedure.setApplyTime(defaultValueToDate(objects.get(87))); // courtExecutionProcedure.setJudgmentDocNumber(defaultValue(objects.get(88))); courtExecutionProcedure.setArrearsPeriod(defaultValue(objects.get(88))); courtExecutionProcedure.setArrearsAmount(defaultValue(objects.get(89))); courtExecutionProcedure.setLateFee(defaultValue(objects.get(90))); courtExecutionProcedure.setAcceptanceFee(defaultValue(objects.get(91))); courtExecutionProcedure.setOtherFee(defaultValue(objects.get(92))); courtExecutionProcedure.setTotalAmount(defaultValue(objects.get(93))); courtExecutionProcedure.setRemark(defaultValue(objects.get(99))); applyRoomDiscountServiceDaoImpl.saveCourtExecutionProcedure(BeanConvertUtil.beanCovertMap(courtExecutionProcedure)); } } //产调日期 if (!defaultValue(objects.get(65)).isEmpty()) { OwnerPropertySurvey ownerPropertySurvey = new OwnerPropertySurvey(); ownerPropertySurvey.setOwnerId(ownerCarDto.getOwnerId()); ownerPropertySurvey.setRoomId(ownerCarDto.getCarId()); ownerPropertySurvey.setSurveyWarrantApplyDate(defaultValueToDate(objects.get(68))); ownerPropertySurvey.setPropertySurveyDate(defaultValueToDate(objects.get(65))); ownerPropertySurvey.setName(defaultValue(objects.get(66))); ownerPropertySurvey.setExtraDate(defaultValueToDate(objects.get(67))); int save = applyRoomDiscountServiceDaoImpl.saveOwnerPropertySurvey(BeanConvertUtil.beanCovertMap(ownerPropertySurvey)); } //---- //诉讼 if (!defaultValue(objects.get(69)).isEmpty()) { LitigationInfoPo litigationInfoPo = new LitigationInfoPo(); litigationInfoPo.setLitigationDate(objects.getString(69)); // litigationInfoPo.setArrearsPeriod(defaultValue(objects.get(125))); // litigationInfoPo.setArrearsAmount(objects.getBigDecimal(126)); // litigationInfoPo.setLateFee(objects.getBigDecimal(127)); // litigationInfoPo.setAcceptanceFee(objects.getBigDecimal(128)); // litigationInfoPo.setOtherFee(objects.getBigDecimal(129)); // litigationInfoPo.setTotalAmount(objects.getBigDecimal(130)); litigationInfoPo.setSubmitter(defaultValue(objects.get(70))); int insert = sqlSessionTemplate.insert("litigationInfoServiceDaoImpl.saveLitigationInfo", BeanConvertUtil.beanCovertMap(litigationInfoPo)); if (insert < 1) { throw new IllegalArgumentException("诉讼记录导入失败"); } } //---- //导入车辆 ownerCarV1InnerServiceSMOImpl.saveOwnerCar(ownerCarPo); ParkingSpacePo parkingSpacePo = new ParkingSpacePo(); parkingSpacePo.setPsId(psId); //车位id parkingSpacePo.setState(ownerCarDto.getSpaceSate()); parkingSpaceV1InnerServiceSMOImpl.updateParkingSpace(parkingSpacePo); } private String defaultValueToDate(Object o) { return o == null ? null : o.toString(); } public String defaultValue(Object o) { return o == null ? "" : o.toString(); } public BigDecimal defaultNum(Object o) { return o == null ? new BigDecimal(0) : new BigDecimal(o.toString()); } private void importOwnerData(OwnerCarDto ownerCarDto, Object[] os) { OwnerDto ownerDto = new OwnerDto(); ownerDto.setName(ownerCarDto.getOwnerName()); ownerDto.setLink(ownerCarDto.getLink()); ownerDto.setCommunityId(ownerCarDto.getCommunityId()); //查询业主 List ownerDtos = ownerV1InnerServiceSMOImpl.queryOwners(ownerDto); //Assert.listOnlyOne(ownerDtos, ownerCarDto.getCarNum() + "查询业主信息错误！"); if (ListUtil.isNull(ownerDtos)) { OwnerPo ownerPo = new OwnerPo(); ownerPo.setUserId("-1"); ownerPo.setAge("1"); ownerPo.setCommunityId(ownerCarDto.getCommunityId()); ownerPo.setIdCard(""); ownerPo.setLink(ownerCarDto.getLink()); ownerPo.setSex("1"); ownerPo.setMemberId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_ownerId)); ownerPo.setName(ownerCarDto.getOwnerName()); ownerPo.setOwnerId(ownerPo.getMemberId()); //业主 所以和成员ID需要一样 ownerPo.setOwnerTypeCd(OwnerDto.OWNER_TYPE_CD_OWNER); ownerPo.setRemark("导入车辆导入"); ownerPo.setState(OwnerDto.STATE_FINISH); ownerPo.setAddress("无"); ownerPo.setOwnerFlag(OwnerDto.OWNER_FLAG_TRUE); ownerPo.setPersonType(OwnerDto.PERSON_TYPE_PERSON); ownerPo.setPersonRole(OwnerDto.PERSON_ROLE_OWNER); ownerPo.setConcactPerson(ownerCarDto.getOwnerName()); ownerPo.setConcactLink(ownerCarDto.getLink()); ownerPo.setLink(defaultValue(os[29])); ownerPo.setIdCard(defaultValue(os[31])); ownerPo.setAddress(defaultValue(os[32])); ownerPo.setPropertyCertificateNo(defaultValue(os[33])); ownerPo.setIsEvChargerInstalled(defaultValue(os[52])); int flag = ownerV1InnerServiceSMOImpl.saveOwner(ownerPo); if (flag < 1) { throw new IllegalArgumentException("保存业主失败"); } ownerCarDto.setOwnerId(ownerPo.getOwnerId()); }else{ ownerCarDto.setOwnerId(ownerDtos.get(0).getOwnerId()); } } }