调整上海省平台财务接口数据

CZT

2024-01-23 53939f30518c0c1d132d1eb3de20e35aa630c781

 src/main/java/com/fzzy/push/sh2023/SH2023PushService14.java

@@ -69,12 +69,14 @@
            log.error("-----上海市平台2023版：未获取到储备规模，不推送-----");
            return;
        }
        param.setInteCategory(Constant.API_CATEGORY_14);
        param.setInteId(SH2023Constant.SH_2023_API_CODE_1401);
        //推送，数据为集合形式
        ResponseDto responseDto = apiRemoteService.pushData(param, list);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
            for (Api1401 data : list) {

        ResponseDto responseDto;
        for (Api1401 data : list) {
            param.setBizId(data.getBizId());
            responseDto = apiRemoteService.pushData(param, data);
            if (responseDto.getSuccess() == 0) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

                    data.setCzbz(Constant.CZBZ_U);
@@ -83,7 +85,6 @@
                }
            }
        }

    }

    /**
@@ -97,21 +98,21 @@
            log.error("-----上海市平台2023版：未获取到储备计划，不推送-----");
            return;
        }
        param.setInteCategory(Constant.API_CATEGORY_14);
        param.setInteId(SH2023Constant.SH_2023_API_CODE_1402);
        //推送，数据为集合形式
        ResponseDto responseDto = apiRemoteService.pushData(param, list);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
            for (Api1402 data : list) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

        ResponseDto responseDto;
        for (Api1402 data : list) {
            param.setBizId(data.getBizId());
            responseDto = apiRemoteService.pushData(param, data);
            if (responseDto.getSuccess() == 0) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {
                    data.setCzbz(Constant.CZBZ_U);
                    //更新状态
                    api1402Rep.save(data);
                }
            }
        }

    }

    /**
@@ -125,12 +126,14 @@
            log.error("-----上海市平台2023版：未获取到轮换计划，不推送-----");
            return;
        }
        param.setInteCategory(Constant.API_CATEGORY_14);
        param.setInteId(SH2023Constant.SH_2023_API_CODE_1403);
        //推送，数据为集合形式
        ResponseDto responseDto = apiRemoteService.pushData(param, list);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
            for (Api1403 data : list) {

        ResponseDto responseDto;
        for (Api1403 data : list) {
            param.setBizId(data.getBizId());
            responseDto = apiRemoteService.pushData(param, data);
            if (responseDto.getSuccess() == 0) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {
                    data.setCzbz(Constant.CZBZ_U);
                    //更新状态
@@ -138,7 +141,6 @@
                }
            }
        }

    }

    /**
@@ -152,21 +154,21 @@
            log.error("-----上海市平台2023版：未获取到轮换计划明细，不推送-----");
            return;
        }
        param.setInteCategory(Constant.API_CATEGORY_14);
        param.setInteId(SH2023Constant.SH_2023_API_CODE_1404);
        //推送，数据为集合形式
        ResponseDto responseDto = apiRemoteService.pushData(param, list);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
            for (Api1404 data : list) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

        ResponseDto responseDto;
        for (Api1404 data : list) {
            param.setBizId(data.getBizId());
            responseDto = apiRemoteService.pushData(param, data);
            if (responseDto.getSuccess() == 0) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {
                    data.setCzbz(Constant.CZBZ_U);
                    //更新状态
                    api1404Rep.save(data);
                }
            }
        }

    }

    /**
@@ -203,28 +205,27 @@
     */
    public void pushData2203(ApiRemoteService apiRemoteService, ApiParam param) {
        //获取交易中心合同
        List<Api1201> list = api1201Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());

        if (null == list || list.isEmpty()) {
            log.error("-----上海市平台2023版：未获取到轮换计划明细，不推送-----");
            return;
        }
        param.setInteId(SH2023Constant.SH_2023_API_CODE_2203);
        //推送，数据为集合形式
        ResponseDto responseDto = apiRemoteService.pushData(param, list);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
            for (Api1201 data : list) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

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


//        List<Api1201> list = api1201Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
//
//        if (null == list || list.isEmpty()) {
//            log.error("-----上海市平台2023版：未获取到轮换计划明细，不推送-----");
//            return;
//        }
//        param.setInteCategory(Constant.API_CATEGORY_14);
//        param.setInteId(SH2023Constant.SH_2023_API_CODE_2203);
//
//        ResponseDto responseDto;
//        for (Api1201 data : list) {
//            param.setBizId(data.getBizId());
//            responseDto = apiRemoteService.pushData(param, data);
//            if (responseDto.getSuccess() == 0) {
//                if (Constant.CZBZ_I.equals(data.getCzbz())) {
//                    data.setCzbz(Constant.CZBZ_U);
//                    //更新状态
//                    api1201Rep.save(data);
//                }
//            }
//        }
    }

    /**
@@ -232,26 +233,27 @@
     */
    public void pushData2204(ApiRemoteService apiRemoteService, ApiParam param) {
        //获取定化水检验
        List<Api1310> list = api1310Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());

        if (null == list || list.isEmpty()) {
            log.error("-----上海市平台2023版：未获取到定化水检验，不推送-----");
            return;
        }
        param.setInteId(SH2023Constant.SH_2023_API_CODE_2204);
        //推送，数据为集合形式
        ResponseDto responseDto = apiRemoteService.pushData(param, list);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
            for (Api1310 data : list) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

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

//        List<Api1310> list = api1310Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
//
//        if (null == list || list.isEmpty()) {
//            log.error("-----上海市平台2023版：未获取到定化水检验，不推送-----");
//            return;
//        }
//        param.setInteCategory(Constant.API_CATEGORY_14);
//        param.setInteId(SH2023Constant.SH_2023_API_CODE_2204);
//
//        ResponseDto responseDto;
//        for (Api1310 data : list) {
//            param.setBizId(data.getBizId());
//            responseDto = apiRemoteService.pushData(param, data);
//            if (responseDto.getSuccess() == 0) {
//                if (Constant.CZBZ_I.equals(data.getCzbz())) {
//
//                    data.setCzbz(Constant.CZBZ_U);
//                    //更新状态
//                    api1310Rep.save(data);
//                }
//            }
//        }
    }
}