接口调整，增加封仓确认单同步

czt

2024-11-25 eb28cab79dc230ed71771f3984bcab69a435e53b

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

@@ -6,11 +6,9 @@
import com.fzzy.api.entity.*;
import com.fzzy.api.service.ApiRemoteService;
import com.fzzy.api.view.repository.*;
import com.fzzy.push.shjdjw2023.ShjdjwApiRemoteService2023;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

/**
@@ -42,7 +40,37 @@
    private Api1309Rep apiRep1309;
    @Autowired
    private Api1310Rep apiRep1310;
    @Autowired
    private ApiInfoDataRep apiInfoDataRep;


    public void pushData1301(ApiRemoteService apiRemoteService, ApiParam param) {

        //获取需要推送的数据
        List<Api1301> items = apiRep1301.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());

        if (null == items || items.isEmpty()) {
            log.info("-------------没有安全信息数据需要推送-----------");
            return;
        }

        param.setInteCategory(Constant.API_CATEGORY_13);
        param.setInteId(Constant.API_CODE_1301);

        ResponseDto responseDto;

        for (Api1301 data : items) {
            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);
                    apiRep1301.save(data);
                }
            }
        }
    }

    public void pushData1302(ApiRemoteService apiRemoteService, ApiParam param) {

@@ -82,7 +110,7 @@
        }

        param.setInteCategory(Constant.API_CATEGORY_13);
        param.setInteId(Constant.API_CODE_1302);
        param.setInteId(Constant.API_CODE_1303);

        ResponseDto responseDto;

@@ -108,7 +136,7 @@
        }

        param.setInteCategory(Constant.API_CATEGORY_13);
        param.setInteId(Constant.API_CODE_1302);
        param.setInteId(Constant.API_CODE_1304);

        ResponseDto responseDto;