合同导出进行中0908

chengf

2025-09-08 064905677e2a78e1a5945d6fd606440fa43d62c0

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

@@ -65,7 +65,7 @@

        try {
            ContractPartyaDto contractPartyaDto = new ContractPartyaDto();
            contractPartyaDto.setPartyA(contractPo.getaPartyaId());
            contractPartyaDto.setIsPartyA(contractPo.getaPartyaId());
            contractPartyaDto.setCommunityId(contractPo.getCommunityId());
            contractPartyaDto.setTypeId("1");
            List<ContractPartyaDto> contractPartyaDtos = contractPartyaInnerServiceSMOImpl.queryContractPartyas(contractPartyaDto);
@@ -84,7 +84,7 @@

        try {
            ContractPartyaDto contractPartyaDto = new ContractPartyaDto();
            contractPartyaDto.setPartyA(contractPo.getbPartyaId());
            contractPartyaDto.setIsPartyA(contractPo.getbPartyaId());
            contractPartyaDto.setCommunityId(contractPo.getCommunityId());
            contractPartyaDto.setTypeId("2");
            List<ContractPartyaDto> contractPartyaDtos = contractPartyaInnerServiceSMOImpl.queryContractPartyas(contractPartyaDto);
@@ -101,24 +101,26 @@
        }


        try {
            ContractPartyaDto contractPartyaDto = new ContractPartyaDto();
            contractPartyaDto.setPartyA(contractPo.getcPartyaId());
            contractPartyaDto.setCommunityId(contractPo.getCommunityId());
            contractPartyaDto.setTypeId("3");
            List<ContractPartyaDto> contractPartyaDtos = contractPartyaInnerServiceSMOImpl.queryContractPartyas(contractPartyaDto);
            if (contractPartyaDtos.size() == 1){
                contractPo.setcPartyaId(contractPartyaDtos.get(0).getPartyaId());
                contractPo.setPartyC(contractPartyaDtos.get(0).getPartyA());
            } else {
        if (contractPo.getcPartyaId() != null) {
            try {
                ContractPartyaDto contractPartyaDto = new ContractPartyaDto();
                contractPartyaDto.setIsPartyA(contractPo.getcPartyaId());
                contractPartyaDto.setCommunityId(contractPo.getCommunityId());
                contractPartyaDto.setTypeId("3");
                List<ContractPartyaDto> contractPartyaDtos = contractPartyaInnerServiceSMOImpl.queryContractPartyas(contractPartyaDto);
                if (contractPartyaDtos.size() == 1){
                    contractPo.setcPartyaId(contractPartyaDtos.get(0).getPartyaId());
                    contractPo.setPartyC(contractPartyaDtos.get(0).getPartyA());
                } else {
                    throw new IllegalArgumentException("不存在或存在多个名为"+contractPo.getcPartyaId()+"的第三方");
                }
            } catch (NullPointerException e){
                e.printStackTrace();
            } catch (IllegalArgumentException e){
                throw new IllegalArgumentException("不存在或存在多个名为"+contractPo.getcPartyaId()+"的第三方");
            } catch (Exception e){
                throw new IllegalArgumentException("第三方主体不存在");
            }
        } catch (NullPointerException e){
            e.printStackTrace();
        } catch (IllegalArgumentException e){
            throw new IllegalArgumentException("不存在或存在多个名为"+contractPo.getcPartyaId()+"的第三方");
        } catch (Exception e){
            throw new IllegalArgumentException("第三方主体不存在");
        }


@@ -182,21 +184,6 @@
        if (flag < 0) {
            throw new IllegalArgumentException("保存失败");
        }
        return  "保存成功";
    }

    private void saveContractAttr(JSONObject jsonObject, ContractPo contractPo) {

        ContractAttrPo contractAttrPo = new ContractAttrPo();
        contractAttrPo.setAttrId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_attrId));
        contractAttrPo.setContractId(contractPo.getContractId());
        contractAttrPo.setSpecCd(jsonObject.getString("specCd"));
        contractAttrPo.setValue(jsonObject.getString("value"));
        contractAttrPo.setStoreId(contractPo.getStoreId());
        int count = contractAttrInnerServiceSMOImpl.saveContractAttr(contractAttrPo);

        if (count < 1) {
            throw new IllegalArgumentException("保存属性失败");
        }
        return "保存成功";
    }
}