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.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.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.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;
|
@Override
|
public void importData(List<AssetImportLogDetailDto> assetImportLogDetailDtos) {
|
importDatas(assetImportLogDetailDtos);
|
}
|
|
private void importDatas(List<AssetImportLogDetailDto> 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);
|
ownerCarDto.setOtherItem(o);
|
ownerCarDto.setLeaseType("H");
|
CommunityDto communityDto = new CommunityDto();
|
Object[] os = ownerCarDto.getOtherItem();
|
String communityId = assetImportLogDetailDto.getCommunityId();
|
JSONArray objects = JSONObject.parseArray(otherItem);
|
communityDto.setCommunityCode(defaultValue(os[1]));
|
List<CommunityDto> 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<DictDto> dictDtos = dictV1InnerServiceSMOImpl.queryDicts(dictDto);
|
if (dictDtos.isEmpty()) {
|
dictDto.setName(null);
|
List<DictDto> 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<ParkingAreaDto> 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<ParkingSpaceDto> 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(assetImportLogDetailDto.getCommunityId());
|
RoomDto roomDto = new RoomDto();
|
roomDto.setCommunityId(assetImportLogDetailDto.getCommunityId());
|
roomDto.setRoadName(defaultValue(os[3]));
|
roomDto.setFloorNum(defaultValue(os[4]));
|
roomDto.setUnitNum(defaultValue(os[5]));
|
roomDto.setRoomNum(defaultValue(os[6]));
|
List<RoomDto> 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<MailCallRecord> mailCallRecords = new ArrayList<MailCallRecord>();
|
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<String, Object> 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.getDate(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<OwnerDto> 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());
|
}
|
|
}
|
|
|
}
|
