czt
2025-10-31 8172572f01c0baa527085243e010afa4bec5efcc
src/main/java/com/fzzy/push/sx2025/SX2025ApiRemoteService.java
@@ -720,9 +720,96 @@
            }
            return apiData;
        }
        //TODO 新增接口
        //空仓验收表
        if (Constant.API_CODE_1214.equals(inteId)) {
            Api1214 api1214 = (Api1214) data;
            SX2025Api1214 apiData = new SX2025Api1214();
            BeanUtils.copyProperties(api1214, apiData);
            //设置統一货位编码
            if (StringUtils.isEmpty(apiData.getTyhwbm())) {
                String tyhwbm = apiCommonService.getTyhwbm(api1214.getHwdm());
                apiData.setTyhwbm(tyhwbm);
            }
            //设置验收视频照片
            apiData.setYsspzp(FileUtils.fileToByteString(api1214.getWjdz()));
            return apiData;
        }
        //空罐验收表
        if (Constant.API_CODE_1215.equals(inteId)) {
            Api1215 api1215 = (Api1215) data;
            SX2025Api1215 apiData = new SX2025Api1215();
            BeanUtils.copyProperties(api1215, apiData);
            //设置統一货位编码
            if (StringUtils.isEmpty(apiData.getTyygbm())) {
                String tyhwbm = apiCommonService.getTyhwbm(api1215.getHwdm());
                apiData.setTyygbm(tyhwbm);
            }
            //设置验收视频照片
            apiData.setYsspzp(FileUtils.fileToByteString(api1215.getWjdz()));
            return apiData;
        }
        //储备粮倒仓验收表
        if (Constant.API_CODE_1216.equals(inteId)) {
            Api1216 api1216 = (Api1216) data;
            SX2025Api1216 apiData = new SX2025Api1216();
            BeanUtils.copyProperties(api1216, apiData);
            //设置倒出货位统一编码
            if (StringUtils.isEmpty(apiData.getDctyhwbm())) {
                String dchwtybm = apiCommonService.getTyhwbm(api1216.getDchwbm());
                apiData.setDctyhwbm(dchwtybm);
            }
            //设置倒入货位统一编码
            if (StringUtils.isEmpty(apiData.getDrtyhwbm())) {
                String drhwtybm = apiCommonService.getTyhwbm(api1216.getDrhwbm());
                apiData.setDrtyhwbm(drhwtybm);
            }
            //设置验收视频照片
            apiData.setYsspzp(FileUtils.fileToByteString(api1216.getWjdz()));
            return apiData;
        }
        //轮换验收信息
        if (Constant.API_CODE_1217.equals(inteId)) {
            Api1217 api1217 = (Api1217) data;
            SX2025Api1217 apiData = new SX2025Api1217();
            BeanUtils.copyProperties(api1217, apiData);
            //设置倒出货位统一编码
            if (StringUtils.isEmpty(apiData.getDctyhwbm())) {
                String dchwtybm = apiCommonService.getTyhwbm(api1217.getDchwbm());
                apiData.setDctyhwbm(dchwtybm);
            }
            //设置倒入货位统一编码
            if (StringUtils.isEmpty(apiData.getDrtyhwbm())) {
                String drhwtybm = apiCommonService.getTyhwbm(api1217.getDrhwbm());
                apiData.setDrtyhwbm(drhwtybm);
            }
            //设置验收视频照片
            apiData.setYsspzp(FileUtils.fileToByteString(api1217.getWjdz()));
            return apiData;
        }
        //入库成本核定表
        if (Constant.API_CODE_1218.equals(inteId)) {
            Api1218 api1218 = (Api1218) data;
            SX2025Api1218 apiData = new SX2025Api1218();
            BeanUtils.copyProperties(api1218, apiData);
            //设置統一货位编码
            if (StringUtils.isEmpty(apiData.getTyhwbm())) {
                String tyhwbm = apiCommonService.getTyhwbm(api1218.getHwdm());
                apiData.setTyhwbm(tyhwbm);
            }
            return apiData;
        }
        //入库成本核定明细表
        if (Constant.API_CODE_1219.equals(inteId)) {
            Api1219 api1219 = (Api1219) data;
            SX2025Api1219 apiData = new SX2025Api1219();
            BeanUtils.copyProperties(api1219, apiData);
            //设置統一货位编码
            if (StringUtils.isEmpty(apiData.getTyhwbm())) {
                String tyhwbm = apiCommonService.getTyhwbm(api1219.getHwdm());
                apiData.setTyhwbm(tyhwbm);
            }
            return apiData;
        }
        //安全管理信息
        if (Constant.API_CODE_1301.equals(inteId)) {
            Api1301 api1301 = (Api1301) data;
@@ -794,17 +881,11 @@
            }
            return apiData;
        }
        //TODO 待调整
        //通风作业
        if (Constant.API_CODE_1305.equals(inteId)) {
            Api1305 api1305 = (Api1305) data;
            SX2024Api1305 apiData = new SX2024Api1305();
            SX2025Api1305 apiData = new SX2025Api1305();
            BeanUtils.copyProperties(api1305, apiData);
            //设置統一仓房编码
            if (StringUtils.isEmpty(apiData.getTycfbm())) {
                String tycfbm = apiCommonService.getTykqbm(apiData.getCfdm());
                apiData.setTycfbm(tycfbm);
            }
            //设置統一廒间编码
            if (StringUtils.isEmpty(apiData.getTyajbm())) {
                String tyajbm = apiCommonService.getTyajbm(api1305.getHwdm().substring(0, 28));
@@ -816,18 +897,13 @@
                    apiData.setTfzydh(apiData.getTfzydh().replace(api1305.getHwdm(), apiData.getTyajbm()));
                }
            }
            return apiData;
        }
        //熏蒸作业
        if (Constant.API_CODE_1306.equals(inteId)) {
            Api1306 api1306 = (Api1306) data;
            SX2024Api1306 apiData = new SX2024Api1306();
            SX2025Api1306 apiData = new SX2025Api1306();
            BeanUtils.copyProperties(api1306, apiData);
            //设置統一仓房编码
            if (StringUtils.isEmpty(apiData.getTycfbm())) {
                String tycfbm = apiCommonService.getTykqbm(apiData.getCfdm());
                apiData.setTycfbm(tycfbm);
            }
            //设置統一廒间编码
            if (StringUtils.isEmpty(apiData.getTyajbm())) {
                String tyajbm = apiCommonService.getTyajbm(api1306.getHwdm().substring(0, 28));
@@ -835,69 +911,82 @@
            }
            //设置熏蒸作业单号:统一廒间编码+yyyyMMdd+3位顺序号
            if (StringUtils.isNotEmpty(apiData.getXzzydh())) {
                if (apiData.getXzzydh().startsWith(apiData.getCfdm())) {
                    apiData.setXzzydh(apiData.getXzzydh().replace(apiData.getCfdm(), apiData.getTyajbm()));
                if (apiData.getXzzydh().startsWith(api1306.getCfdm())) {
                    apiData.setXzzydh(apiData.getXzzydh().replace(api1306.getCfdm(), apiData.getTyajbm()));
                }
            }
            //设置单号:统一廒间编码+yyyyMMdd+4位顺序号
            if (StringUtils.isNotEmpty(apiData.getHcjcdh())) {
                if (apiData.getHcjcdh().startsWith(api1306.getHwdm())) {
                    apiData.setHcjcdh(apiData.getHcjcdh().replace(api1306.getHwdm(), apiData.getTyajbm()));
                }
            }
            return apiData;
        }
        //仓内视频图像信息
        if (Constant.API_CODE_1307.equals(inteId)) {
            Api1307 api1307 = (Api1307) data;
            SX2024Api1307 apiData = new SX2024Api1307();
            SX2025Api1307 apiData = new SX2025Api1307();
            BeanUtils.copyProperties(api1307, apiData);
            //设置統一库区编码
            if (StringUtils.isEmpty(apiData.getTykqbm())) {
                String tykqbm = apiCommonService.getTykqbm(apiData.getKqdm());
                String tykqbm = apiCommonService.getTykqbm(api1307.getKqdm());
                apiData.setTykqbm(tykqbm);
            }
            //设置統一仓房编码
            if (StringUtils.isEmpty(apiData.getTycfbm())) {
                String tycfbm = apiCommonService.getTykqbm(apiData.getCfdm());
                String tycfbm = apiCommonService.getTykqbm(api1307.getCfdm());
                apiData.setTycfbm(tycfbm);
            }
            //设置統一货位编码
            if (StringUtils.isEmpty(apiData.getTyhwbm())) {
                String tyhwbm = apiCommonService.getTyhwbm(apiData.getHwdm());
                String tyhwbm = apiCommonService.getTyhwbm(api1307.getHwdm());
                apiData.setTyhwbm(tyhwbm);
            }
            //设置文件流
            apiData.setCntxwjl(FileUtils.fileToByteString(api1307.getWjdz()));
            //预置位
            if (StringUtils.isNotEmpty(apiData.getYzwbh())) {
                if (apiData.getYzwbh().startsWith(apiData.getHwdm())) {
                    apiData.setYzwbh(apiData.getYzwbh().replace(apiData.getHwdm(), apiData.getTyhwbm()));
                if (apiData.getYzwbh().startsWith(api1307.getHwdm())) {
                    apiData.setYzwbh(apiData.getYzwbh().replace(api1307.getHwdm(), apiData.getTyhwbm()));
                }
            }
            //设置文件路径
            String cntxwjlj = "V2025/2432/";
            cntxwjlj += apiData.getTykqbm() + "/";
            cntxwjlj += apiData.getYzwbh() + "/";
            cntxwjlj += apiData.getSpjksbid() + "/";
            cntxwjlj += apiData.getTyhwbm() + "_" + DateFormatUtils.format(apiData.getZpsj(),"yyyyMMdd HHmmss") + "." + apiData.getTxwjhzm();
            apiData.setCntxwjlj(cntxwjlj);
            return apiData;
        }
        //视频监控异常事件告警信息
        if (Constant.API_CODE_1308.equals(inteId)) {
            SX2024Api1308 apiData = new SX2024Api1308();
            BeanUtils.copyProperties(data, apiData);
            Api1308 api1308 = (Api1308) data;
            SX2025Api1308 apiData = new SX2025Api1308();
            BeanUtils.copyProperties(api1308, apiData);
            //设置統一库区编码
            if (StringUtils.isEmpty(apiData.getTykqbm())) {
                String tykqbm = apiCommonService.getTykqbm(apiData.getKqdm());
                String tykqbm = apiCommonService.getTykqbm(api1308.getKqdm());
                apiData.setTykqbm(tykqbm);
            }
            //统一库区名称
            apiData.setTykqmc(apiData.getKqmc());
            //视频文件路径
            String spwjlj = "V2025/2433/";
            spwjlj += apiData.getTykqbm() + "/";
            spwjlj += apiData.getSpjksbid() + "/";
            spwjlj += apiData.getSpjksbid() + "/";
            spwjlj += apiData.getTykqbm() + "_" + DateFormatUtils.format(apiData.getGjsj(),"yyyyMMdd HHmmss") + "." + apiData.getSpwjhzm();
            apiData.setSpwjlj(spwjlj);
            return apiData;
        }
        //违规预警信息
        if (Constant.API_CODE_1309.equals(inteId)) {
            Api1309 api1309 = (Api1309) data;
            SX2024Api1309 apiData = new SX2024Api1309();
            SX2025Api1309 apiData = new SX2025Api1309();
            BeanUtils.copyProperties(api1309, apiData);
            //设置违规单位統一编码
            if (StringUtils.isEmpty(apiData.getWgdwtybm())) {
                String tydwbm = apiCommonService.getTydwbm(apiData.getQydm());
                String tydwbm = apiCommonService.getTydwbm(api1309.getQydm());
                apiData.setWgdwtybm(tydwbm);
            }
            //设置预警信息代码:统一库区编码+yyyyMMdd+3位顺序号
@@ -907,22 +996,20 @@
                    apiData.setYjxxdm(apiData.getYjxxdm().replace(api1309.getKqdm(), tykqbm));
                }
            }
            return apiData;
        }
        //质检数据
        if (Constant.API_CODE_1310.equals(inteId)) {
            SX2024Api1310 apiData = new SX2024Api1310();
            BeanUtils.copyProperties(data, apiData);
            Api1310 api1310 = (Api1310) data;
            SX2025Api1310 apiData = new SX2025Api1310();
            BeanUtils.copyProperties(api1310, apiData);
            //设置統一货位编码
            if (StringUtils.isEmpty(apiData.getTyhwbm())) {
                String tyhwbm = apiCommonService.getTyhwbm(apiData.getHwdm());
                String tyhwbm = apiCommonService.getTyhwbm(api1310.getHwdm());
                apiData.setTyhwbm(tyhwbm);
            }
            return apiData;
        }
        //储备规模信息
        if (Constant.API_CODE_1401.equals(inteId)) {
            Api1401 api1401 = (Api1401) data;
@@ -1039,6 +1126,18 @@
                return SX2025Constant.SX_2025_API_ODS_UP_KHXXJK;
            case "1213":
                return SX2025Constant.SX_2025_API_ODS_UP_FCQRDXXJK;
            case "1214":
                return SX2025Constant.SX_2025_API_ODS_UP_KCYSJK;
            case "1215":
                return SX2025Constant.SX_2025_API_ODS_UP_KGYSJK;
            case "1216":
                return SX2025Constant.SX_2025_API_ODS_UP_DCYSJK;
            case "1217":
                return SX2025Constant.SX_2025_API_ODS_UP_LHYSJK;
            case "1218":
                return SX2025Constant.SX_2025_API_ODS_UP_RKCBHDJK;
            case "1219":
                return SX2025Constant.SX_2025_API_ODS_UP_RKCBHDMXJK;
            case "1301":
                return SX2025Constant.SX_2025_API_ODS_UP_AQGLXXJK;
            case "1302":