package com.java110.job.importData.adapt; 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.fee.FeeConfigDto; import com.java110.dto.fee.FeeDto; import com.java110.dto.importData.*; import com.java110.dto.log.AssetImportLogDetailDto; import com.java110.dto.menu.MenuDto; import com.java110.dto.oweFeeCallable.OweFeeCallableDto; import com.java110.dto.owner.OwnerDto; import com.java110.dto.room.RoomDto; import com.java110.fee.api.ApplyRoomDiscountApi; import com.java110.fee.bmo.fee.IFeeBMO; import com.java110.fee.dao.IApplyRoomDiscountServiceDao; import com.java110.fee.dao.IPayFeeConfigV1ServiceDao; import com.java110.intf.community.ICommunityInnerServiceSMO; import com.java110.intf.community.IImportOwnerRoomInnerServiceSMO; import com.java110.intf.community.IMenuInnerServiceSMO; import com.java110.intf.dev.IDictV1InnerServiceSMO; import com.java110.intf.fee.*; import com.java110.intf.user.IOwnerInnerServiceSMO; import com.java110.intf.user.IOwnerV1InnerServiceSMO; import com.java110.job.importData.DefaultImportData; import com.java110.job.importData.IImportDataAdapt; import com.java110.po.dict.DictPo; import com.java110.po.fee.FeeAttrPo; import com.java110.po.fee.PayFeePo; import com.java110.po.oweFeeCallable.OweFeeCallablePo; import com.java110.po.owner.OwnerPo; import com.java110.po.room.ApplyRoomDiscountPo; import com.java110.po.room.LitigationInfoPo; import com.java110.po.room.PayeeReceiveInfoPo; import com.java110.utils.cache.MappingCache; import com.java110.utils.util.Assert; import com.java110.utils.util.BeanConvertUtil; import com.java110.utils.util.DateUtil; import org.mybatis.spring.SqlSessionTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.math.BigDecimal; import java.text.SimpleDateFormat; import java.util.*; import java.util.stream.Collectors; /** * 房产信息导入 适配器 * 前端请求 时 必须传入 * param.append('importAdapt', "importRoomOwner"); */ @Service("importRoomOwnerV2QueueData") public class ImportRoomOwnerV2QueueDataAdapt extends DefaultImportData implements IImportDataAdapt { @Autowired private IOwnerV1InnerServiceSMO ownerV1InnerServiceSMOImpl; @Autowired private IOweFeeCallableV1InnerServiceSMO oweFeeCallableV1InnerServiceSMOImpl; @Autowired private IImportOwnerRoomInnerServiceSMO importOwnerRoomInnerServiceSMOImpl; @Autowired protected SqlSessionTemplate sqlSessionTemplate; @Autowired private IOwnerInnerServiceSMO ownerInnerServiceSMOImpl; @Autowired private IApplyRoomDiscountServiceDao applyRoomDiscountServiceDaoImpl; @Autowired private IDictV1InnerServiceSMO dictV1InnerServiceSMOImpl; @Autowired private ICommunityInnerServiceSMO communityInnerServiceSMOImpl; @Autowired private IFeeConfigInnerServiceSMO feeConfigInnerServiceSMOImpl; @Autowired private IPayFeeV1InnerServiceSMO payFeeV1InnerServiceSMO; @Autowired private IFeeAttrInnerServiceSMO feeAttrInnerServiceSMO; @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()); try { Thread.sleep(200); } catch (InterruptedException e) { throw new RuntimeException(e); } } catch (Exception e) { e.printStackTrace(); String errorMsg = e.getMessage(); // 先判空，再判断包含关系 if (errorMsg != null && errorMsg.contains("### Error updating database")) { updateImportLogDetailState(assetImportLogDetailDto.getDetailId(), "未知错误，请联系管理员" + errorMsg); } else { // 补充：这里也建议对 e 做兜底处理，避免传递空的异常信息 String finalMsg = errorMsg != null ? errorMsg : e.toString(); updateImportLogDetailState(assetImportLogDetailDto.getDetailId(), finalMsg); // 如果原方法 updateImportLogDetailState 接收 Exception 类型参数，可保留： // updateImportLogDetailState(assetImportLogDetailDto.getDetailId(), e); } } } } /** * 导入数据 * * @param assetImportLogDetailDto */ private void doImportData(AssetImportLogDetailDto assetImportLogDetailDto) { String test = ""; int a = 6; JSONArray objects = JSONObject.parseArray(assetImportLogDetailDto.getContent()); if (Vtil.defaultValue(objects.get(11)) == null) { objects.set(11, "无名"); test = test + "\n业主名称为空"; // throw new IllegalArgumentException("业主名称不能为空"); } if (Vtil.defaultValue(objects.get(16)) == null){ objects.set(16, "0"); test = test + "\n房屋面积为空"; } // if (Vtil.defaultValue(objects.get(54)) == null){ // throw new IllegalArgumentException("性别内容有误!"); // } ImportOwnerRoomDto importOwnerRoomDto = new ImportOwnerRoomDto();//房屋 importOwnerRoomDto.setRoomId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_roomId)); importOwnerRoomDto.setOwnerId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_ownerId)); importOwnerRoomDto.setUserId(objects.getString(169)); importOwnerRoomDto.setLayerCount("0"); importOwnerRoomDto.setLayer("0"); importOwnerRoomDto.setLift("未知"); importOwnerRoomDto.setSection("10102"); importOwnerRoomDto.setOwnerTypeCd("1001"); importOwnerRoomDto.setPersonType(OwnerDto.PERSON_TYPE_PERSON); importOwnerRoomDto.setPersonRole(OwnerDto.PERSON_ROLE_OWNER); importOwnerRoomDto.setMonthlyUnitPrice(objects.getString(23)); importOwnerRoomDto.setPropertyFeeMonth(objects.getString(24)); if (Vtil.defaultValue(objects.get(1)) != null) { //--------设置物业类型 DictDto dictDto = new DictDto(); dictDto.setTableName("building_room"); dictDto.setTableColumns("room_sub_type"); dictDto.setName(Vtil.defaultValue(objects.get(1))); List dictDtos = dictV1InnerServiceSMOImpl.queryDictAndSpecs(dictDto); if (dictDtos.isEmpty()) { DictPo dictPo = new DictPo(); dictPo.setStatusCd(GenerateCodeFactory.getGeneratorId("2")); dictPo.setTableName("building_room"); dictPo.setTableColumns("room_sub_type"); dictPo.setName(Vtil.defaultValue(objects.get(1))); dictV1InnerServiceSMOImpl.saveDict(dictPo); dictDtos = dictV1InnerServiceSMOImpl.queryDictAndSpecs(dictDto); if (dictDtos.isEmpty()) { throw new IllegalArgumentException("导入失败:字典中不存在物业类型:" + Vtil.defaultValue(objects.get(1))); } } importOwnerRoomDto.setRoomSubType(dictDtos.get(0).getStatusCd()); } //---------- importOwnerRoomDto.setPropertyType(Vtil.defaultValue(objects.get(2)));//住宅类型 //--------匹配小区 CommunityDto communityDto = new CommunityDto(); communityDto.setCommunityCode(Vtil.defaultValue(objects.get(3))); communityDto.setName(Vtil.defaultValue(objects.get(4))); if (communityDto.getCommunityCode() == null && communityDto.getName() == null) { throw new IllegalArgumentException("导入失败：小区编码和小区名称都为空"); } List communityDtos = communityInnerServiceSMOImpl.queryCommunitys(communityDto); if (communityDtos.isEmpty()) { throw new IllegalArgumentException("导入失败:小区中不存在小区‘" + Vtil.defaultValue(objects.get(3))+Vtil.defaultValue(objects.get(4)) + "’"); } else if (communityDtos.size() > 1) { String communityNames = communityDtos.stream() .map(CommunityDto::getName) // 提取每个小区的名称 .collect(Collectors.joining(", ")); throw new IllegalArgumentException("导入失败：小区编码（" + communityDto.getCommunityCode() + "） + 小区名称（" + communityDto.getName() + "）条件存在多个小区：" + communityNames); } String communityId = communityDtos.get(0).getCommunityId(); importOwnerRoomDto.setCommunityId(communityId);//小区编号 //--------- importOwnerRoomDto.setRoadName(Vtil.defaultValue(objects.get(5)));//路名 importOwnerRoomDto.setFloorNum(Vtil.defaultValue(objects.get(6)));//弄 importOwnerRoomDto.setUnitNum(Vtil.defaultValue(objects.get(7)));//门 importOwnerRoomDto.setRoomNum(Vtil.defaultValue(objects.get(8)));//室 importOwnerRoomDto.setDoorRoomNum(Vtil.defaultValue(objects.get(9)));//门市号 importOwnerRoomDto.setPropertyAddress(Vtil.defaultValue(objects.get(10)));//业主地址 importOwnerRoomDto.setRoomBuyer(Vtil.defaultValue(objects.get(11) , null) == null ? "房屋：" + importOwnerRoomDto.getPropertyAddress() + "购房人姓名为空，待补全": Vtil.defaultValue(objects.get(11)));//购房人 RoomDto roomDto = new RoomDto(); roomDto.setCommunityId(importOwnerRoomDto.getCommunityId()); roomDto.setRoadName(importOwnerRoomDto.getRoadName()); roomDto.setFloorNum(importOwnerRoomDto.getFloorNum()); roomDto.setUnitNum(importOwnerRoomDto.getUnitNum()); roomDto.setRoomNum(importOwnerRoomDto.getRoomNum()); roomDto.setDoorRoomNum(importOwnerRoomDto.getDoorRoomNum()); roomDto.setPropertyAddress(importOwnerRoomDto.getPropertyAddress()); // if (roomDto.getRoomNum() ==null || roomDto.getRoomNum().equals("")){ // roomDto.setPropertyType("商铺"); // } List objects1 = sqlSessionTemplate.selectList("roomServiceDaoImpl.getRoomInfo", BeanConvertUtil.beanCovertMap(roomDto)); if (!objects1.isEmpty()) { // throw new IllegalArgumentException("重复的房屋:"); test = test + "\n重复的房屋：来自导入记录：" + assetImportLogDetailDto.getLogId() + "\t" + assetImportLogDetailDto.getDetailId(); } List feeDtos = null; if (!importOwnerRoomDto.getCommunityId().isEmpty()){ FeeConfigDto feeConfigDto = new FeeConfigDto(); feeConfigDto.setCommunityId(importOwnerRoomDto.getCommunityId()); if (importOwnerRoomDto.getPropertyType() == null) { // throw new IllegalArgumentException("物业类型为空"); test = test + "\n物业类型为空，无法添加费用"; } else { feeConfigDto.setSecondaryFeeTypeCdName(importOwnerRoomDto.getPropertyType()); feeDtos = feeConfigInnerServiceSMOImpl.queryFeeConfigs(feeConfigDto); if (feeDtos.isEmpty()) { // throw new IllegalArgumentException("物业类型`"+importOwnerRoomDto.getPropertyType()+"`未查询到收费项"); test = test + "\n物业类型`"+importOwnerRoomDto.getPropertyType()+"`未查询到收费项，无法添加费用"; } } } //---------家庭成员、租客 OwnerPo ownerPoTo3 = new OwnerPo();// if (Vtil.defaultValue(objects.get(13)) != null) { String link = Vtil.defaultValue(objects.get(13)); OwnerDto ownerDto = new OwnerDto(); ownerDto.setLink(link); ownerDto.setCommunityId(communityId); List ownerDtos = ownerInnerServiceSMOImpl.queryAllOwners(ownerDto); if (!ownerDtos.isEmpty()) { throw new IllegalArgumentException("导入失败：该小区已存在手机号：" + link + "的业主"); } ownerPoTo3.setOwnerId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_ownerId)); ownerPoTo3.setAge("0"); ownerPoTo3.setState(OwnerDto.STATE_FINISH); ownerPoTo3.setPersonType(OwnerDto.PERSON_TYPE_PERSON); ownerPoTo3.setOwnerTypeCd(OwnerDto.OWNER_TYPE_CD_MEMBER); ownerPoTo3.setName(Vtil.defaultValue(objects.get(12))); ownerPoTo3.setLink(link); ownerPoTo3.setSex("2"); ownerPoTo3.setPersonRole(OwnerDto.PERSON_ROLE_MEMBER); } OwnerPo ownerPoTo2 = new OwnerPo();//TODO 租客未导入 if (Vtil.defaultValue(objects.get(15)) != null) { String link = Vtil.defaultValue(objects.get(15)); OwnerDto ownerDto = new OwnerDto(); ownerDto.setLink(link); ownerDto.setCommunityId(communityId); List ownerDtos = ownerInnerServiceSMOImpl.queryAllOwners(ownerDto); if (!ownerDtos.isEmpty()) { throw new IllegalArgumentException("导入失败：该小区已存在手机号：" + link + "的业主"); } ownerPoTo2.setOwnerId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_ownerId)); ownerPoTo2.setAge("0"); // ownerPo.setUserId(userId); ownerPoTo2.setState(OwnerDto.STATE_FINISH); ownerPoTo2.setPersonType(OwnerDto.PERSON_ROLE_RENT); ownerPoTo2.setOwnerTypeCd(OwnerDto.OWNER_TYPE_CD_MEMBER); ownerPoTo2.setName(Vtil.defaultValue(objects.get(21+a))); ownerPoTo2.setLink(link); ownerPoTo2.setSex("2"); ownerPoTo2.setPersonRole(OwnerDto.PERSON_ROLE_MEMBER); } //--------- importOwnerRoomDto.setBuiltUpArea(Vtil.defaultValue(objects.get(16)));//面积 importOwnerRoomDto.setRoomArea(Vtil.defaultValue(objects.get(16)));//面积 importOwnerRoomDto.setRoomRent(Vtil.defaultValue(objects.get(16)));//面积 importOwnerRoomDto.setBuyDate(Vtil.defaultValueToDate(objects.get(28)));//购入日期 importOwnerRoomDto.setSellDate(Vtil.defaultValueToDate(objects.get(26)));//卖出日期 importOwnerRoomDto.setSellState(Vtil.defaultValue(objects.get(23+a)));//房屋状态 importOwnerRoomDto.setEoc(Vtil.defaultNum(objects.get(24+a)).toString());//设备运行费 //-----TODO 待导入 催缴信息 if (Vtil.defaultValue(objects.get(31)) != null) { OwnerCollectionDto ownerCollection = new OwnerCollectionDto(); ownerCollection.setOwnerId(importOwnerRoomDto.getOwnerId()); ownerCollection.setRoomId(importOwnerRoomDto.getRoomId()); ownerCollection.setCollectionStartDate(Vtil.defaultValueToDate(objects.get(25+a))); ownerCollection.setCollectionEndDate(Vtil.defaultValueToDate(objects.get(26+a))); ownerCollection.setAmount(Vtil.defaultValue(objects.get(27+a))); ownerCollection.setFirstCollector(Vtil.defaultValue(objects.get(28+a))); ownerCollection.setSecondCollectorName(Vtil.defaultValue(objects.get(29+a))); ownerCollection.setSecondCollectorPhone(Vtil.defaultValue(objects.get(30+a))); ownerCollection.setSecondCollectorAddress(Vtil.defaultValue(objects.get(31+a))); ownerCollection.setReceiptNumber(Vtil.defaultValue(objects.get(32+a))); ownerCollection.setReceiptPhotoUrl(Vtil.defaultValue(objects.get(33+a))); ownerCollection.setRemark(Vtil.defaultValue(objects.get(34+a))); } //----- //-----打折信息 TODO 未添加重复校验 if (Vtil.defaultValue(objects.get(42)) != null) { ApplyRoomDiscountPo applyRoomDiscountPo = new ApplyRoomDiscountPo();//打折 applyRoomDiscountPo.setArdId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_ardId)); applyRoomDiscountPo.setCommunityId(importOwnerRoomDto.getCommunityId()); applyRoomDiscountPo.setRoomId(importOwnerRoomDto.getRoomId()); applyRoomDiscountPo.setRoomName(importOwnerRoomDto.getPropertyAddress()); applyRoomDiscountPo.setDiscountId("132025112781200067"); applyRoomDiscountPo.setApplyType("152025112756040048"); applyRoomDiscountPo.setFixedDiscountValue(Vtil.defaultNum(objects.get(36+a))); applyRoomDiscountPo.setDiscountedAmount(Vtil.defaultNum(objects.get(37+a))); applyRoomDiscountPo.setStartTime(Vtil.defaultValueToDate(objects.get(38+a),"start", null)); applyRoomDiscountPo.setEndTime(Vtil.defaultValueToDate(objects.get(39+a), "end", null)); applyRoomDiscountPo.setDiscountArchiveDate(Vtil.defaultValueToDate(objects.get(40+a))); applyRoomDiscountPo.setCreateRemark(Vtil.defaultValue(objects.get(41+a))); applyRoomDiscountPo.setCheckRemark("审批人：" + Vtil.defaultValue(objects.get(42+a))); applyRoomDiscountPo.setReviewRemark("审批人：" + Vtil.defaultValue(objects.get(43+a))); applyRoomDiscountPo.setCreateUserTel("无"); applyRoomDiscountPo.setCreateUserName("由系统导入"); applyRoomDiscountPo.setState("4"); applyRoomDiscountPo.setStatusCd("0"); applyRoomDiscountPo.setInUse("0"); applyRoomDiscountPo.setReturnWay("1001"); applyRoomDiscountPo.setRelatedAttachments(Vtil.defaultValue(objects.get(44+a))); try { applyRoomDiscountServiceDaoImpl.saveApplyRoomDiscountInfo(BeanConvertUtil.beanCovertMap(applyRoomDiscountPo)); }catch (Exception e){ throw new IllegalArgumentException("导入失败:打折信息导入存在错误" + e.getMessage()); } } //-----业主信息 importOwnerRoomDto.setTel(Vtil.defaultValue(objects.get(45+a)));//手机号 importOwnerRoomDto.setIdCard(Vtil.defaultValue(objects.get(46+a)));//身份证 importOwnerRoomDto.setAddress(Vtil.defaultValue(objects.get(47+a)));//TODO 导入逻辑未添加该字段 联络地址 importOwnerRoomDto.setSex(Vtil.defaultValue(objects.get(48+a)) == null ?"2" : Vtil.defaultValue(objects.get(48+a))); importOwnerRoomDto.setOwnerName(Vtil.defaultValue(Vtil.defaultValue(objects.get(11) , null) == null ? "房屋：" + importOwnerRoomDto.getPropertyAddress() + "购房人姓名为空，待补全": Vtil.defaultValue(objects.get(11)))); importOwnerRoomDto.setHouseholdPoliceStation(Vtil.defaultValue(objects.get(50+a))); importOwnerRoomDto.setPropertyCertificateNo(Vtil.defaultValue(objects.get(51+a))); importOwnerRoomDto.setIsEvChargerInstalled(Vtil.defaultValue(objects.get(52+a))); if (Vtil.defaultValue(objects.get(61),null) != null || Vtil.defaultValue(objects.get(141)) == null || Vtil.defaultValue(objects.get(147+a)) == null || Vtil.defaultValue(objects.get(149+a)) == null) { 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(importOwnerRoomDto.getOwnerId()); oweFeeCallablePo.setOwnerName(importOwnerRoomDto.getOwnerName()); oweFeeCallablePo.setPayerObjId(importOwnerRoomDto.getRoomId()); oweFeeCallablePo.setPayerObjName(importOwnerRoomDto.getPropertyAddress()); oweFeeCallablePo.setPayerObjType("3333"); oweFeeCallablePo.setRemark(Vtil.defaultValue(objects.get(57+a)) + "\n\n催收时段：" + Vtil.defaultValueToDate(objects.get(61))); oweFeeCallablePo.setStaffId("302025062612580518"); oweFeeCallablePo.setStaffName("刘志勇"); oweFeeCallablePo.setState(OweFeeCallableDto.STATE_COMPLETE); oweFeeCallablePo.setReceivableAmount(Vtil.defaultValue(objects.get(155+a))); oweFeeCallablePo.setReceivedAmount(Vtil.defaultValue(objects.get(156+a))); // oweFeeCallablePo.setDifferenceReason(Vtil.defaultValue(objects.get(157+a))); // oweFeeCallablePo.setReceiptTime(Vtil.defaultValue(objects.get(158+a))); oweFeeCallablePo.setPayee(Vtil.defaultValue(objects.get(159+a))); if (Vtil.defaultValue(objects.get(160+a), "") != null) { oweFeeCallablePo.setRemark(oweFeeCallablePo.getRemark() + "。备注信息：" + Vtil.defaultValue(objects.get(160+a))); } // oweFeeCallablePo.setStartTime(Vtil.defaultValueToDate(objects.get(61)));//TODO 时间段需要拆分 // oweFeeCallablePo.setEndTime(Vtil.defaultValueToDate(objects.get(61))); oweFeeCallablePo.setCreateTime(Vtil.defaultValueToDate(objects.get(53+a))); int flag = oweFeeCallableV1InnerServiceSMOImpl.saveOweFeeCallable(oweFeeCallablePo); if (flag < 1) { throw new IllegalArgumentException("催收信息导入失败"); } for (int i = 0; i < 5 ; i++) { int index = i*4 + 65; // if(objects.get(index) == null || objects.get(index).equals("")) { // break; // } HouseMailRecord houseMailRecord = new HouseMailRecord(); houseMailRecord.setId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_houseId)); houseMailRecord.setOwnerId(importOwnerRoomDto.getOwnerId()); houseMailRecord.setHouseId(importOwnerRoomDto.getRoomId()); houseMailRecord.setCallableId(oweFeeCallablePo.getOfcId()); houseMailRecord.setSendDate(Vtil.defaultValueToDate(objects.get(index))); houseMailRecord.setMailNo(Vtil.defaultValue(objects.get(index+1))); houseMailRecord.setServiceFee(Vtil.defaultValue(objects.get(index+2))); houseMailRecord.setMailResult(Vtil.defaultValue(objects.get(index+3))); houseMailRecord.setRemark(Vtil.defaultValue(objects.get(79+a))); int save = applyRoomDiscountServiceDaoImpl.saveHouseMailRecord(BeanConvertUtil.beanCovertMap(houseMailRecord)); } //----对方收款单位表 PayeeReceiveInfoPo payeeReceiveInfoPo = new PayeeReceiveInfoPo(); payeeReceiveInfoPo.setCallableId(oweFeeCallablePo.getOfcId()); payeeReceiveInfoPo.setCallerName(Vtil.defaultValue(objects.get(88))); payeeReceiveInfoPo.setContactInfo(Vtil.defaultValue(objects.get(89))); payeeReceiveInfoPo.setPayeeInfo(Vtil.defaultValue(objects.get(90))); payeeReceiveInfoPo.setInvoiceNo(Vtil.defaultValue(objects.get(91))); payeeReceiveInfoPo.setInvoiceDate(objects.getDate(92)); payeeReceiveInfoPo.setReceiptNo(Vtil.defaultValue(objects.get(93))); payeeReceiveInfoPo.setReceiptDate(objects.getDate(94)); payeeReceiveInfoPo.setReceiptNote(Vtil.defaultValue(objects.get(95))); payeeReceiveInfoPo.setReceiptNoteDate(objects.getDate(96)); payeeReceiveInfoPo.setImageFile(Vtil.defaultValue(objects.get(97))); payeeReceiveInfoPo.setOurCompanyReceiveDate(objects.getDate(98)); payeeReceiveInfoPo.setAttachmentFile(Vtil.defaultValue(objects.get(99))); payeeReceiveInfoPo.setOwnerId(importOwnerRoomDto.getOwnerId()); payeeReceiveInfoPo.setRoomId(importOwnerRoomDto.getRoomId()); int insert = sqlSessionTemplate.insert("payeeReceiveInfoServiceDaoImpl.savePayeeReceiveInfo", BeanConvertUtil.beanCovertMap(payeeReceiveInfoPo)); //---- //----法院审理程序 // if (!Vtil.defaultValue(objects.get(141)).isEmpty()) { CourtTrialProcedure courtTrialProcedure = new CourtTrialProcedure(); courtTrialProcedure.setCallableId(oweFeeCallablePo.getOfcId()); courtTrialProcedure.setOwnerId(importOwnerRoomDto.getOwnerId()); courtTrialProcedure.setAcceptCourtName(Vtil.defaultValue(objects.get(132+a))); courtTrialProcedure.setJudgeName(Vtil.defaultValue(objects.get(133+a))); courtTrialProcedure.setJudgeContact(Vtil.defaultValue(objects.get(134+a))); courtTrialProcedure.setJudgeNoticeAcceptDate(Vtil.defaultValueToDate(objects.get(135+a))); courtTrialProcedure.setCourtMediationDate(Vtil.defaultValueToDate(objects.get(136+a))); courtTrialProcedure.setMediationResult(Vtil.defaultValue(objects.get(137+a))); courtTrialProcedure.setSubpoenaSignDate(Vtil.defaultValueToDate(objects.get(138+a))); courtTrialProcedure.setUndeliveredDate(Vtil.defaultValueToDate(objects.get(139+a))); courtTrialProcedure.setCourtSessionDate1(Vtil.defaultValueToDate(objects.get(140+a))); courtTrialProcedure.setCourtSessionDate2(Vtil.defaultValueToDate(objects.get(141+a))); courtTrialProcedure.setCaseNumber(Vtil.defaultValue(objects.get(142+a))); courtTrialProcedure.setCourtSessionResult(Vtil.defaultValue(objects.get(143+a))); courtTrialProcedure.setJudgmentDate(Vtil.defaultValueToDate(objects.get(144+a))); courtTrialProcedure.setJudgmentResult(Vtil.defaultValue(objects.get(145+a))); courtTrialProcedure.setRemark(Vtil.defaultValue(objects.get(146+a))); applyRoomDiscountServiceDaoImpl.saveCourtTrialProcedure(BeanConvertUtil.beanCovertMap(courtTrialProcedure)); // } //----- //法院执行程序 // if (!Vtil.defaultValue(objects.get(147+a)).isEmpty() || !Vtil.defaultValue(objects.get(149+a)).isEmpty()) { CourtExecutionProcedure courtExecutionProcedure = new CourtExecutionProcedure(); courtExecutionProcedure.setCallableId(oweFeeCallablePo.getOfcId()); courtExecutionProcedure.setOwnerId(importOwnerRoomDto.getOwnerId()); courtExecutionProcedure.setApplyTime(Vtil.defaultValueToDate(objects.get(147+a))); courtExecutionProcedure.setJudgmentDocNumber(Vtil.defaultValue(objects.get(148+a))); courtExecutionProcedure.setArrearsPeriod(Vtil.defaultValue(objects.get(149+a))); courtExecutionProcedure.setArrearsAmount(Vtil.defaultValue(objects.get(150+a))); courtExecutionProcedure.setLateFee(Vtil.defaultValue(objects.get(151+a))); courtExecutionProcedure.setAcceptanceFee(Vtil.defaultValue(objects.get(152+a))); courtExecutionProcedure.setOtherFee(Vtil.defaultValue(objects.get(153+a))); courtExecutionProcedure.setTotalAmount(Vtil.defaultValue(objects.get(154+a))); courtExecutionProcedure.setRemark(Vtil.defaultValue(objects.get(160+a))); applyRoomDiscountServiceDaoImpl.saveCourtExecutionProcedure(BeanConvertUtil.beanCovertMap(courtExecutionProcedure)); // } //----添加电联 List mailCallRecords = new ArrayList(); for (int i = 0 ; i < 9 ; i++) { int index = i * 3 + 86; if(Vtil.defaultValue(objects.get(index)) == null){ // 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.setMailId(oweFeeCallablePo.getOfcId()); mailCallRecord.setCallDate(Vtil.defaultValueToDate(objects.get(index + (i == 0 ? 0 : 12)))); mailCallRecord.setCallResult(Vtil.defaultValue(objects.get(index+1 + (i == 0 ? 0 : 12)))); mailCallRecord.setCallContact(Vtil.defaultValue(objects.get(index+2 + 12))); mailCallRecord.setRemark(Vtil.defaultValue(objects.get(125))); mailCallRecords.add(mailCallRecord); } if (mailCallRecords.size() > 0) { Map param = new HashMap<>(); param.put("mailCallRecordList", BeanConvertUtil.beanCovertMapList(mailCallRecords)); sqlSessionTemplate.insert("mailCallRecordServiceDaoImpl.batchSaveMailCallRecord", param); } //---- } //产调日期 // if (!Vtil.defaultValue(objects.get(126)).isEmpty()) { OwnerPropertySurvey ownerPropertySurvey = new OwnerPropertySurvey(); ownerPropertySurvey.setOwnerId(importOwnerRoomDto.getOwnerId()); ownerPropertySurvey.setRoomId(importOwnerRoomDto.getRoomId()); ownerPropertySurvey.setSurveyWarrantApplyDate(Vtil.defaultValueToDate(objects.get(129))); ownerPropertySurvey.setPropertySurveyDate(Vtil.defaultValueToDate(objects.get(126))); ownerPropertySurvey.setName(Vtil.defaultValue(objects.get(127))); ownerPropertySurvey.setExtraDate(Vtil.defaultValueToDate(objects.get(128))); int save = applyRoomDiscountServiceDaoImpl.saveOwnerPropertySurvey(BeanConvertUtil.beanCovertMap(ownerPropertySurvey)); // } //---- //诉讼 LitigationInfoPo litigationInfoPo = new LitigationInfoPo(); litigationInfoPo.setLitigationDate(Vtil.defaultValue(objects.get(130))); litigationInfoPo.setArrearsPeriod(Vtil.defaultValue(objects.get(131))); litigationInfoPo.setArrearsAmount(Vtil.defaultValue(objects.get(132))); litigationInfoPo.setLateFee(Vtil.defaultValue(objects.get(133))); litigationInfoPo.setAcceptanceFee(Vtil.defaultValue(objects.get(134))); litigationInfoPo.setOtherFee(Vtil.defaultValue(objects.get(135))); litigationInfoPo.setTotalAmount(Vtil.defaultValue(objects.get(136))); litigationInfoPo.setSubmitter(Vtil.defaultValue(objects.get(137))); litigationInfoPo.setOwnerId(importOwnerRoomDto.getOwnerId()); sqlSessionTemplate.insert("litigationInfoServiceDaoImpl.saveLitigationInfo", BeanConvertUtil.beanCovertMap(litigationInfoPo)); importOwnerRoomDto.setRoomState(importOwnerRoomDto.getOwnerName() == null ? "2004" : "2001"); importOwnerRoomDto.setRemark(test); importOwnerRoomInnerServiceSMOImpl.saveOwnerRoom(importOwnerRoomDto); OwnerDto ownerDto = new OwnerDto(); ownerDto.setOwnerId(importOwnerRoomDto.getOwnerId()); List ownerDtos = ownerV1InnerServiceSMOImpl.queryOwners(ownerDto); if (ownerDtos.size() == 1) { ownerPoTo2.setUserId(ownerDtos.get(0).getUserId()); ownerPoTo3.setUserId(ownerDtos.get(0).getUserId()); if (ownerPoTo2.getLink() != null) { ownerV1InnerServiceSMOImpl.saveOwner(ownerPoTo2); } if (ownerPoTo2.getLink() != null) { ownerV1InnerServiceSMOImpl.saveOwner(ownerPoTo3); } } for (int i = 0 ; i < feeDtos.size(); i++) { FeeConfigDto feeDto = feeDtos.get(i); PayFeePo payFeePo = new PayFeePo(); payFeePo.setFeeId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_feeId)); payFeePo.setbId("-1"); payFeePo.setFeeTypeCd(feeDto.getFeeTypeCd()); payFeePo.setSecondaryFeeTypeCd(feeDto.getSecondaryFeeTypeCd()); payFeePo.setCommunityId(importOwnerRoomDto.getCommunityId()); payFeePo.setPayerObjId(importOwnerRoomDto.getRoomId()); payFeePo.setIncomeObjId("102025062610470035"); payFeePo.setStartTime(feeDto.getStartTime()); payFeePo.setEndTime(feeDto.getStartTime()); payFeePo.setUserId(importOwnerRoomDto.getUserId()); payFeePo.setStatusCd("0"); payFeePo.setFeeFlag(feeDto.getFeeFlag()); payFeePo.setConfigId(feeDto.getConfigId()); payFeePo.setState("2008001"); payFeePo.setPayerObjType("3333"); payFeePo.setBatchId(assetImportLogDetailDto.getLogId()); payFeeV1InnerServiceSMO.savePayFee(payFeePo); List feeAttrPos = new ArrayList<>(); feeAttrPos.add(new FeeAttrPo(payFeePo.getFeeId(), payFeePo.getCommunityId(), GenerateCodeFactory.getGeneratorId("11"), "390007" , importOwnerRoomDto.getOwnerId())); feeAttrPos.add(new FeeAttrPo(payFeePo.getFeeId(), payFeePo.getCommunityId(), GenerateCodeFactory.getGeneratorId("11"), "390010" , feeDto.getEndTime().split(" ")[0] + " 23:59:59")); feeAttrPos.add(new FeeAttrPo(payFeePo.getFeeId(), payFeePo.getCommunityId(), GenerateCodeFactory.getGeneratorId("11"), "390009" , importOwnerRoomDto.getTel())); feeAttrPos.add(new FeeAttrPo(payFeePo.getFeeId(), payFeePo.getCommunityId(), GenerateCodeFactory.getGeneratorId("11"), "390008" , importOwnerRoomDto.getOwnerName())); feeAttrPos.add(new FeeAttrPo(payFeePo.getFeeId(), payFeePo.getCommunityId(), GenerateCodeFactory.getGeneratorId("11"), "390012" , importOwnerRoomDto.getDoorRoomNum())); int i1 = feeAttrInnerServiceSMO.saveFeeAttrs(feeAttrPos); } } }