武汉省平台-调整接口上报为单条集合形式上报

CZT

2023-10-24 62b592d65a8c84114b2240ee7ba78c6ae2fe93e6

武汉省平台-调整接口上报为单条集合形式上报

 src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService12.java

@@ -96,10 +96,10 @@
        /*-----各省独有接口信息同步-----*/
        if (StringUtils.isNotEmpty(param.getPushProtocol()) && PushProtocol.SB_SH_2023.getCode().equals(param.getPushProtocol())) {
            //上海市平台2023版，需要同步市储检斤单，同步市储驳运单
            //同步市储检斤单
            fzzySync2101.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
            //同步市储驳运单
            fzzySync2104.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
//            //同步市储检斤单
//            fzzySync2101.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
//            //同步市储驳运单
//            fzzySync2104.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
        }
        //账面库存信息同步  TODO


 src/main/java/com/fzzy/otherview/whhpjl/pr/WhjlApi1102PR.java

@@ -108,7 +108,7 @@
     */
    @Expose
    public String pushData(List<WhjlApi1102> items) {
        ResponseDto responseDto;

        String result = "";

        String kqdm = items.get(0).getKqdm();
@@ -127,12 +127,11 @@
            return "系统没有当前推送协议配置，执行失败";
        }

        //推送，数据为集合形式
        responseDto = apiService.pushData(param, apiConf, items);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
        ResponseDto responseDto;
            ApiInfoData infoData;
            for (WhjlApi1102 data : items) {
            responseDto = apiService.pushData(param, apiConf, data);
            if (responseDto.getSuccess() == 0) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

                    infoData = new ApiInfoData();

 src/main/java/com/fzzy/otherview/whhpjl/pr/WhjlApi1103PR.java

@@ -108,7 +108,7 @@
     */
    @Expose
    public String pushData(List<WhjlApi1103> items) {
        ResponseDto responseDto;

        String result = "";

        String kqdm = items.get(0).getKqdm();
@@ -127,12 +127,11 @@
            return "系统没有当前推送协议配置，执行失败";
        }

        //推送，数据为集合形式
        responseDto = apiService.pushData(param, apiConf, items);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
        ResponseDto responseDto;
            ApiInfoData infoData;
            for (WhjlApi1103 data : items) {
            responseDto = apiService.pushData(param, apiConf, data);
            if (responseDto.getSuccess() == 0) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

                    infoData = new ApiInfoData();

 src/main/java/com/fzzy/otherview/whhpjl/pr/WhjlApi1105PR.java

@@ -108,7 +108,7 @@
     */
    @Expose
    public String pushData(List<WhjlApi1105> items) {
        ResponseDto responseDto;

        String result = "";

        String kqdm = items.get(0).getKqdm();
@@ -127,12 +127,11 @@
            return "系统没有当前推送协议配置，执行失败";
        }

        //推送，数据为集合形式
        responseDto = apiService.pushData(param, apiConf, items);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
        ResponseDto responseDto;
            ApiInfoData infoData;
            for (WhjlApi1105 data : items) {
            responseDto = apiService.pushData(param, apiConf, data);
            if (responseDto.getSuccess() == 0) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

                    infoData = new ApiInfoData();

 src/main/java/com/fzzy/otherview/whhpjl/pr/WhjlApi1106PR.java

@@ -108,7 +108,7 @@
     */
    @Expose
    public String pushData(List<WhjlApi1106> items) {
        ResponseDto responseDto;

        String result = "";

        String kqdm = items.get(0).getKqdm();
@@ -127,12 +127,11 @@
            return "系统没有当前推送协议配置，执行失败";
        }

        //推送，数据为集合形式
        responseDto = apiService.pushData(param, apiConf, items);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
        ResponseDto responseDto;
            ApiInfoData infoData;
            for (WhjlApi1106 data : items) {
            responseDto = apiService.pushData(param, apiConf, data);
            if (responseDto.getSuccess() == 0) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

                    infoData = new ApiInfoData();

 src/main/java/com/fzzy/otherview/whhpjl/pr/WhjlApi1107PR.java

@@ -109,7 +109,7 @@
     */
    @Expose
    public String pushData(List<WhjlApi1107> items) {
        ResponseDto responseDto;

        String result = "";

        String kqdm = items.get(0).getKqdm();
@@ -129,11 +129,14 @@
        }

        //推送，数据为集合形式
        responseDto = apiService.pushData(param, apiConf, items);
        if (responseDto.getSuccess() == 0) {


            //推送成功，更新数据上传状态
            ApiInfoData infoData;
        ResponseDto responseDto;
            for (WhjlApi1107 data : items) {
            responseDto = apiService.pushData(param, apiConf, data);
            if (responseDto.getSuccess() == 0) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

                    infoData = new ApiInfoData();

 src/main/java/com/fzzy/otherview/whhpjl/pr/WhjlApi1111PR.java

@@ -109,7 +109,7 @@
     */
    @Expose
    public String pushData(List<WhjlApi1111> items) {
        ResponseDto responseDto;

        String result = "";

        String kqdm = items.get(0).getKqdm();
@@ -128,12 +128,11 @@
            return "系统没有当前推送协议配置，执行失败";
        }

        //推送，数据为集合形式
        responseDto = apiService.pushData(param, apiConf, items);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
            ApiInfoData infoData;
        ResponseDto responseDto;
            for (WhjlApi1111 data : items) {
            responseDto = apiService.pushData(param, apiConf, data);
            if (responseDto.getSuccess() == 0) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

                    infoData = new ApiInfoData();

 src/main/java/com/fzzy/otherview/whhpjl/pr/WhjlApi1204PR.java

@@ -107,7 +107,7 @@
     */
    @Expose
    public String pushData(List<WhjlApi1204> items) {
        ResponseDto responseDto;

        String result = "";

        String kqdm = items.get(0).getKqdm();
@@ -126,12 +126,11 @@
            return "系统没有当前推送协议配置，执行失败";
        }

        //推送，数据为集合形式
        responseDto = apiService.pushData(param, apiConf, items);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
            ApiInfoData infoData;
        ResponseDto responseDto;
            for (WhjlApi1204 data : items) {
            responseDto = apiService.pushData(param, apiConf, data);
            if (responseDto.getSuccess() == 0) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

                    infoData = new ApiInfoData();

 src/main/java/com/fzzy/otherview/whhpjl/pr/WhjlApi1207PR.java

@@ -132,7 +132,7 @@
     */
    @Expose
    public String pushData(List<WhjlApi1207> items) {
        ResponseDto responseDto;

        String result = "";

        String kqdm = items.get(0).getKqdm();
@@ -151,12 +151,11 @@
            return "系统没有当前推送协议配置，执行失败";
        }

        //推送，数据为集合形式
        responseDto = apiService.pushData(param, apiConf, items);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
            ApiInfoData infoData;
        ResponseDto responseDto;
            for (WhjlApi1207 data : items) {
            responseDto = apiService.pushData(param, apiConf, data);
            if (responseDto.getSuccess() == 0) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

                    infoData = new ApiInfoData();

 src/main/java/com/fzzy/otherview/whhpjl/pr/WhjlApi1214PR.java

@@ -109,7 +109,7 @@
     */
    @Expose
    public String pushData(List<WhjlApi1214> items) {
        ResponseDto responseDto;

        String result = "";

        String kqdm = items.get(0).getKqdm();
@@ -128,12 +128,11 @@
            return "系统没有当前推送协议配置，执行失败";
        }

        //推送，数据为集合形式
        responseDto = apiService.pushData(param, apiConf, items);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
            ApiInfoData infoData;
        ResponseDto responseDto;
            for (WhjlApi1214 data : items) {
            responseDto = apiService.pushData(param, apiConf, data);
            if (responseDto.getSuccess() == 0) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

                    infoData = new ApiInfoData();

 src/main/java/com/fzzy/push/whhpjl/WhjlApiRemoteService.java

@@ -110,8 +110,7 @@
            log.info("身份签名：" + accessToken);
            reqData.setAccesstoken(MyMD5Util.encrypt(accessToken));
            //数据总条数
            List<Object> list  = (List<Object>)data;
            reqData.setDatalength(list.size());
            reqData.setDatalength(1);
            //数据主体，进行SM4加密
            reqData.setData(SM4Util.encryptEcb(conf.getPublicKey(), jsonData));
            //摘要，数据主体的MD5值

 src/main/java/com/fzzy/push/whhpjl/dto/WhjlReqDto.java

@@ -45,7 +45,7 @@
    /**
     * 数据总条数
     */
    private Integer datalength;
    private Integer datalength = 1;

    /**
     * 上传数据(集合形式)