Z四

chengf

2026-01-27 b6184e2ddf3db37a94f7efb3b619bbc64642a292

 service-job/src/main/java/com/java110/job/importData/adapt/ImportOwnerCarQueueV2DataAdapt.java

@@ -11,6 +11,7 @@
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;
@@ -22,6 +23,7 @@
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;
@@ -41,6 +43,7 @@
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;
@@ -88,6 +91,9 @@

    @Autowired
    ICommunityV1InnerServiceSMO communityV1InnerServiceSMOImpl;

    @Autowired
    IOwnerRoomRelInnerServiceSMO ownerRoomRelInnerServiceSMOImpl;
    @Override
    public void importData(List<AssetImportLogDetailDto> assetImportLogDetailDtos) {
        importDatas(assetImportLogDetailDtos);
@@ -121,13 +127,45 @@
        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<RoomDto> 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<OwnerRoomRelDto> ownerRoomRelDtos = ownerRoomRelInnerServiceSMOImpl.queryOwnerRoomRels(ownerRoomRelDto);
                if (ownerRoomRelDtos.isEmpty()) {
                    throw new IllegalArgumentException("未填写业主且该房屋未绑定业主");
                } else {
                    OwnerDto ownerDto = new OwnerDto();
                    ownerDto.setOwnerId(ownerRoomRelDtos.get(0).getOwnerId());
                    List<OwnerDto> 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 = assetImportLogDetailDto.getCommunityId();
        String communityId = ownerCarDto.getCommunityId();
        JSONArray objects = JSONObject.parseArray(otherItem);
        communityDto.setCommunityCode(defaultValue(os[1]));
        communityDto.setName(defaultValue(os[2]));
        List<CommunityDto> communityDtos = communityV1InnerServiceSMOImpl.queryCommunitys(communityDto);
        if (communityDtos.isEmpty()) {
            throw new IllegalArgumentException("不存在小区编码为：" + communityDto.getCommunityCode() + "的小区");
@@ -239,9 +277,9 @@
        if (!defaultValue(objects.get(21)).isEmpty()) {
            ApplyRoomDiscountPo applyRoomDiscountPo = new ApplyRoomDiscountPo();//打折
            applyRoomDiscountPo.setArdId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_ardId));
            applyRoomDiscountPo.setCommunityId(assetImportLogDetailDto.getCommunityId());
            applyRoomDiscountPo.setCommunityId(communityId);
            RoomDto roomDto = new RoomDto();
            roomDto.setCommunityId(assetImportLogDetailDto.getCommunityId());
            roomDto.setCommunityId(communityId);
            roomDto.setRoadName(defaultValue(os[3]));
            roomDto.setFloorNum(defaultValue(os[4]));
            roomDto.setUnitNum(defaultValue(os[5]));
@@ -436,7 +474,7 @@
        //诉讼
        if (!defaultValue(objects.get(69)).isEmpty()) {
            LitigationInfoPo litigationInfoPo = new LitigationInfoPo();
            litigationInfoPo.setLitigationDate(objects.getDate(69));
            litigationInfoPo.setLitigationDate(objects.getString(69));
//            litigationInfoPo.setArrearsPeriod(defaultValue(objects.get(125)));
//            litigationInfoPo.setArrearsAmount(objects.getBigDecimal(126));
//            litigationInfoPo.setLateFee(objects.getBigDecimal(127));