数据同步时，品种处理

czt

2025-06-30 b6faf70a938ca9e014d34b235dec449f2a21abb4

 src/main/java/com/fzzy/push/impl/ComPushService11.java

@@ -45,12 +45,7 @@
    private Api1112Rep api1112Rep;
    @Autowired
    private Api1113Rep api1113Rep;
    @Autowired
    private Api1501Rep api1501Rep;
    @Autowired
    private Api1502Rep api1502Rep;
    @Autowired
    private Api1503Rep api1503Rep;

    /**
     * 1101 单位信息
     */
@@ -100,7 +95,7 @@

            if (responseDto.getSuccess() == 0) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {
                    api1102Rep.updateStatus(data.getDwdm(), Constant.CZBZ_U);
                    api1102Rep.updateStatus(data.getKqdm(), Constant.CZBZ_U);
                }
            }
        }
@@ -379,96 +374,4 @@
        }
    }

    /**
     * 财务报表
     * @param apiRemoteService
     * @param param
     */
    public void pushData1114(ApiRemoteService apiRemoteService, ApiParam param) {
        this.pushData1501(apiRemoteService, param);
        this.pushData1502(apiRemoteService, param);
        this.pushData1503(apiRemoteService, param);

    }
    /**
     * 1501  财务报表-资产负债--单条上传
     */
    public void pushData1501(ApiRemoteService apiRemoteService, ApiParam param) {
        //获取财务报表-资产负债
        List<Api1501> list = api1501Rep.findPushDataTime(param.getKqdm(), param.getStart(), param.getEnd());

        if (null == list || list.isEmpty()) {
            log.error("-----未获取到资产负债信息，不推送-----");
            return;
        }
        param.setInteCategory(Constant.API_CATEGORY_11);
        param.setInteId(Constant.API_CODE_1114_1501);
        ResponseDto responseDto;
        for (Api1501 data : list) {
            responseDto = apiRemoteService.pushData(param, data);
            if (responseDto.getSuccess() == 0) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

                    data.setCzbz(Constant.CZBZ_U);
                    //更新状态
                    api1501Rep.save(data);
                }
            }
        }
    }

    /**
     * 1502  财务报表-现金流
     */
    public void pushData1502(ApiRemoteService apiRemoteService, ApiParam param) {
        //获取财务报表-资产负债
        List<Api1502> list = api1502Rep.findPushDataTime(param.getKqdm(), param.getStart(), param.getEnd());

        if (null == list || list.isEmpty()) {
            log.error("-----未获取到现金流信息，不推送-----");
            return;
        }
        param.setInteCategory(Constant.API_CATEGORY_11);
        param.setInteId(Constant.API_CODE_1114_1502);
        ResponseDto responseDto;
        for (Api1502 data : list) {
            responseDto = apiRemoteService.pushData(param, data);
            if (responseDto.getSuccess() == 0) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

                    data.setCzbz(Constant.CZBZ_U);
                    //更新状态
                    api1502Rep.save(data);
                }
            }
        }
    }

    /**
     * 1503  财务报表-利润信息
     */
    public void pushData1503(ApiRemoteService apiRemoteService, ApiParam param) {
        //获取财务报表-资产负债
        List<Api1503> list = api1503Rep.findPushDataTime(param.getKqdm(), param.getStart(), param.getEnd());

        if (null == list || list.isEmpty()) {
            log.error("-----未获取到利润信息，不推送-----");
            return;
        }
        param.setInteCategory(Constant.API_CATEGORY_11);
        param.setInteId(Constant.API_CODE_1114_1503);
        ResponseDto responseDto;
        Api1503 d;
        for (Api1503 data : list) {
            responseDto = apiRemoteService.pushData(param, data);
            if (responseDto.getSuccess() == 0) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

                    data.setCzbz(Constant.CZBZ_U);
                    //更新状态
                    api1503Rep.save(data);
                }
            }
        }
    }
}