From 0a76dacc5d525be4ce1a2dc5e12ddbe44fbddcad Mon Sep 17 00:00:00 2001 From: CZT <czt18638530771@163.com> Date: 星期一, 08 一月 2024 21:24:16 +0800 Subject: [PATCH] 优化上海省平台接口 --- src/main/java/com/fzzy/push/gd2022/GD2022ApiRemoteService2022.java | 266 +++++++++++++++++++++++++++++++++++++++++++++++++---- 1 files changed, 245 insertions(+), 21 deletions(-) diff --git a/src/main/java/com/fzzy/push/gd2022/GD2022ApiRemoteService2022.java b/src/main/java/com/fzzy/push/gd2022/GD2022ApiRemoteService2022.java index 8bfb601..e9ee780 100644 --- a/src/main/java/com/fzzy/push/gd2022/GD2022ApiRemoteService2022.java +++ b/src/main/java/com/fzzy/push/gd2022/GD2022ApiRemoteService2022.java @@ -9,6 +9,9 @@ import com.fzzy.api.service.ApiCommonService; import com.fzzy.api.service.ApiRemoteService; import com.fzzy.api.utils.*; +import com.fzzy.api.view.repository.Api1101Rep; +import com.fzzy.api.view.repository.Api1102Rep; +import com.fzzy.api.view.repository.Api1404Rep; import com.fzzy.api.view.repository.ApiLogRep; import com.fzzy.push.gd2022.dto.*; import com.fzzy.push.gd2022.dto.Gd2022Api1101; @@ -16,7 +19,6 @@ import com.fzzy.push.gd2022.dto.Gd2022Api1208; import com.fzzy.push.gd2022.dto.Gd2022Api1307; import com.fzzy.push.gd2022.dto.Gd2022Api1308; -import com.fzzy.push.sh2023.SH2023Constant; import lombok.Data; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang.StringUtils; @@ -46,7 +48,12 @@ @Autowired private ApiCommonService apiCommonService; - + @Autowired + private Api1404Rep api1404Rep; + @Autowired + private Api1101Rep api1101Rep; + @Autowired + private Api1102Rep api1102Rep; @Autowired private ApiLogRep apiLogRep; @@ -131,6 +138,7 @@ /** * 鎺ㄩ�佽储鍔℃暟鎹帴鍙� + * * @param param * @param conf * @param data @@ -300,26 +308,51 @@ if (Constant.API_CODE_1101.equals(inteId)) { Gd2022Api1101 api1101 = new Gd2022Api1101(); BeanUtils.copyProperties(data, api1101); + api1101.setZhgxsj(new Date()); return JSON.toJSONString(api1101); - } else if (Constant.API_CODE_1102.equals(inteId)) { + } + if (Constant.API_CODE_1102.equals(inteId)) { Gd2022Api1102 api1102 = new Gd2022Api1102(); BeanUtils.copyProperties(data, api1102); + api1102.setZhgxsj(new Date()); return JSON.toJSONString(api1102); - } else if (Constant.API_CODE_1103.equals(inteId)) { + } + if (Constant.API_CODE_1103.equals(inteId)) { Gd2022Api1103 api1103 = new Gd2022Api1103(); BeanUtils.copyProperties(data, api1103); changeObject(api1103); + api1103.setZhgxsj(new Date()); return JSON.toJSONString(api1103); - } else if (Constant.API_CODE_1104.equals(inteId)) { + } + if (Constant.API_CODE_1104.equals(inteId)) { Gd2022Api1104 api1104 = new Gd2022Api1104(); BeanUtils.copyProperties(data, api1104); changeObject(api1104); + api1104.setZhgxsj(new Date()); return JSON.toJSONString(api1104); - } else if (Constant.API_CODE_1105.equals(inteId)) { + } + if (Constant.API_CODE_1105.equals(inteId)) { Gd2022Api1105 api1105 = new Gd2022Api1105(); BeanUtils.copyProperties(data, api1105); + api1105.setZhgxsj(new Date()); return JSON.toJSONString(api1105); - }else if (Constant.API_CODE_1109.equals(inteId)) { + } + if (Constant.API_CODE_1106.equals(inteId)) { + Api1106 api1106 = (Api1106) data; + api1106.setZhgxsj(new Date()); + return JSON.toJSONString(api1106); + } + if (Constant.API_CODE_1107.equals(inteId)) { + Api1107 api1107 = (Api1107) data; + api1107.setZhgxsj(new Date()); + return JSON.toJSONString(api1107); + } + if (Constant.API_CODE_1108.equals(inteId)) { + Api1108 api1108 = (Api1108) data; + api1108.setZhgxsj(new Date()); + return JSON.toJSONString(api1108); + } + if (Constant.API_CODE_1109.equals(inteId)) { //灏佽鏁版嵁 Gd2022Api1109 api1109 = new Gd2022Api1109(); BeanUtils.copyProperties(data, api1109); @@ -332,16 +365,137 @@ System.out.println((String) responseDto.getData()); //璁剧疆涓婁紶鏂囦欢id api1109.setFileStorageId((String) responseDto.getData()); + api1109.setZhgxsj(new Date()); return JSON.toJSONString(api1109); - }else if (Constant.API_CODE_1111.equals(inteId)) { + } + if (Constant.API_CODE_1110.equals(inteId)) { + Api1110 api1110 = (Api1110) data; + api1110.setZhgxsj(new Date()); + return JSON.toJSONString(api1110); + } + if (Constant.API_CODE_1111.equals(inteId)) { Gd2022Api1111 api1111 = new Gd2022Api1111(); BeanUtils.copyProperties(data, api1111); + List<Api1102> api1102List = api1102Rep.findPushData(api1111.getKqdm()); + if(null != api1102List && api1102List.size() > 0){ + api1111.setKqmc(api1102List.get(0).getKqmc()); + } + List<Api1101> api1101List = api1101Rep.findDataByDwdm(api1111.getDwdm()); + if(null != api1101List && api1101List.size() > 0){ + api1111.setDwmc(api1101List.get(0).getDwmc()); + } + api1111.setZhgxsj(new Date()); return JSON.toJSONString(api1111); - } else if (Constant.API_CODE_1208.equals(inteId)) { + } + if (Constant.API_CODE_1112.equals(inteId)) { + Api1112 api1112 = (Api1112) data; + api1112.setZhgxsj(new Date()); + return JSON.toJSONString(api1112); + } + if (Constant.API_CODE_1113.equals(inteId)) { + Api1113 api1113 = (Api1113) data; + api1113.setZhgxsj(new Date()); + return JSON.toJSONString(api1113); + } + if (Constant.API_CODE_1201.equals(inteId)) { + Api1201 apiData = (Api1201) data; + apiData.setZhgxsj(new Date()); + return JSON.toJSONString(apiData); + } + if (Constant.API_CODE_1202.equals(inteId)) { + Api1202 apiData = (Api1202) data; + apiData.setZhgxsj(new Date()); + return JSON.toJSONString(apiData); + } + if (Constant.API_CODE_1203.equals(inteId)) { + Api1203 apiData = (Api1203) data; + apiData.setZhgxsj(new Date()); + return JSON.toJSONString(apiData); + } + if (Constant.API_CODE_1204.equals(inteId)) { + Api1204 apiData = (Api1204) data; + apiData.setZhgxsj(new Date()); + return JSON.toJSONString(apiData); + } + if (Constant.API_CODE_1205.equals(inteId)) { + Api1205 apiData = (Api1205) data; + apiData.setZhgxsj(new Date()); + return JSON.toJSONString(apiData); + } + if (Constant.API_CODE_1206.equals(inteId)) { + Api1206 apiData = (Api1206) data; + apiData.setZhgxsj(new Date()); + return JSON.toJSONString(apiData); + } + if (Constant.API_CODE_1207.equals(inteId)) { + Api1207 apiData = (Api1207) data; + apiData.setZhgxsj(new Date()); + return JSON.toJSONString(apiData); + } + if (Constant.API_CODE_1208.equals(inteId)) { Gd2022Api1208 api1208 = new Gd2022Api1208(); + //鍖呰鍌ㄧ伯鏄紝鏍告煡鍖呭瓨绮寘鏁� + if(null == api1208.getBclbs()){ + api1208.setBclbs(0); + } + if("2".equals(api1208.getClfs()) && api1208.getBclbs() == 0){ + api1208.setBclbs((int)(api1208.getSjsl()/25)); + } BeanUtils.copyProperties(data, api1208); return JSON.toJSONString(api1208); - } else if (Constant.API_CODE_1307.equals(inteId)) { + } + if (Constant.API_CODE_1209.equals(inteId)) { + Api1209 apiData = (Api1209) data; + apiData.setZhgxsj(new Date()); + return JSON.toJSONString(apiData); + } + if (Constant.API_CODE_1210.equals(inteId)) { + Gd2022Api1210 api1210 = new Gd2022Api1210(); + BeanUtils.copyProperties(data, api1210); + api1210.setZhgxsj(new Date()); + return JSON.toJSONString(api1210); + } + if (Constant.API_CODE_1211.equals(inteId)) { + Api1211 apiData = (Api1211) data; + apiData.setZhgxsj(new Date()); + return JSON.toJSONString(apiData); + } + if (Constant.API_CODE_1212.equals(inteId)) { + Api1212 apiData = (Api1212) data; + apiData.setZhgxsj(new Date()); + return JSON.toJSONString(apiData); + } + if (Constant.API_CODE_1301.equals(inteId)) { + Api1301 apiData = (Api1301) data; + apiData.setZhgxsj(new Date()); + return JSON.toJSONString(apiData); + } + if (Constant.API_CODE_1302.equals(inteId)) { + Api1302 apiData = (Api1302) data; + apiData.setZhgxsj(new Date()); + return JSON.toJSONString(apiData); + } + if (Constant.API_CODE_1303.equals(inteId)) { + Api1303 apiData = (Api1303) data; + apiData.setZhgxsj(new Date()); + return JSON.toJSONString(apiData); + } + if (Constant.API_CODE_1304.equals(inteId)) { + Api1304 apiData = (Api1304) data; + apiData.setZhgxsj(new Date()); + return JSON.toJSONString(apiData); + } + if (Constant.API_CODE_1305.equals(inteId)) { + Api1305 apiData = (Api1305) data; + apiData.setZhgxsj(new Date()); + return JSON.toJSONString(apiData); + } + if (Constant.API_CODE_1306.equals(inteId)) { + Api1306 apiData = (Api1306) data; + apiData.setZhgxsj(new Date()); + return JSON.toJSONString(apiData); + } + if (Constant.API_CODE_1307.equals(inteId)) { //灏佽鏁版嵁 Gd2022Api1307 api1307 = new Gd2022Api1307(); BeanUtils.copyProperties(data, api1307); @@ -353,8 +507,10 @@ GD2022ResponseDto responseDto = GD2022HttpClientUtil.postUploadData(url, authToken, api1307.getWjdz()); //璁剧疆涓婁紶鏂囦欢id api1307.setFileStorageId((String) responseDto.getData()); + api1307.setZhgxsj(new Date()); return JSON.toJSONString(api1307); - } else if (Constant.API_CODE_1308.equals(inteId)) { + } + if (Constant.API_CODE_1308.equals(inteId)) { //灏佽鏁版嵁 Gd2022Api1308 api1308 = new Gd2022Api1308(); BeanUtils.copyProperties(data, api1308); @@ -366,11 +522,72 @@ GD2022ResponseDto responseDto = GD2022HttpClientUtil.postUploadData(url, authToken, api1308.getWjdz()); //璁剧疆涓婁紶鏂囦欢id api1308.setFileStorageId((String) responseDto.getData()); + api1308.setZhgxsj(new Date()); return JSON.toJSONString(api1308); - } else { -// changeObject(data); - return JSON.toJSONString(data); } + if (Constant.API_CODE_1309.equals(inteId)) { + Api1309 apiData = (Api1309) data; + apiData.setZhgxsj(new Date()); + return JSON.toJSONString(apiData); + } + if (Constant.API_CODE_1310.equals(inteId)) { + Gd2022Api1310 api1310 = new Gd2022Api1310(); + BeanUtils.copyProperties(data, api1310); + api1310.setZhgxsj(new Date()); + return JSON.toJSONString(api1310); + } + if (Constant.API_CODE_1401.equals(inteId)) { + Api1401 apiData = (Api1401) data; + apiData.setZhgxsj(new Date()); + return JSON.toJSONString(apiData); + } + if (Constant.API_CODE_1402.equals(inteId)) { + Api1402 apiData = (Api1402) data; + apiData.setZhgxsj(new Date()); + return JSON.toJSONString(apiData); + } + if (Constant.API_CODE_1403.equals(inteId)) { + //杞崲璁″垝锛屽崟鐙煡璇㈣疆鎹㈣鍒掓槑缁嗕俊鎭紝缁熶竴灏佽鍚庝笂浼� + Gd2022Api1403 api1403 = new Gd2022Api1403(); + BeanUtils.copyProperties(data, api1403); + List<Api1404> list = api1404Rep.getDataByLhjhdh(api1403.getLhjhdh()); + Gd2022Api1404 gd2022Api1404; + List<Gd2022Api1404> dtls = new ArrayList<>(); + Double lrsl = 0.0, lcsl = 0.0; //鐢ㄤ簬缁熻杞叆鏁伴噺鍜岃疆鍑烘暟閲� + if(null != list && list.size() > 0){ + for (Api1404 api1404 : list) { + gd2022Api1404 = new Gd2022Api1404(); + BeanUtils.copyProperties(api1404, gd2022Api1404); + if(null!= gd2022Api1404.getLhlx() && "2".equals(gd2022Api1404.getLhlx())){ + lrsl += gd2022Api1404.getLhsl(); + } + if(null!= gd2022Api1404.getLhlx() && "1".equals(gd2022Api1404.getLhlx())){ + lcsl += gd2022Api1404.getLhsl(); + } + gd2022Api1404.setZhgxsj(new Date()); + dtls.add(gd2022Api1404); + } + } + api1403.setRotationInQty(lrsl); + api1403.setRotationOutQty(lcsl); + api1403.setDtls(dtls); + //鍏堜笂浼犳枃浠�,鑾峰彇鏂囦欢id + GD2022ResponseDto responseDto = GD2022HttpClientUtil.postUploadData(url, authToken, api1403.getWjdz()); + //璁剧疆涓婁紶鏂囦欢id + api1403.setFileStorageId((String) responseDto.getData()); + api1403.setZhgxsj(new Date()); + return JSON.toJSONString(api1403); + } + if (Constant.API_CODE_1404.equals(inteId)) { + //杞崲璁″垝鏄庣粏锛屼笉鍗曠嫭涓婁紶锛屽湪杞崲璁″垝涓粺涓�涓婁紶 + return null; + } + if (Constant.API_CODE_1405.equals(inteId)) { + Api1405 apiData = (Api1405) data; + apiData.setZhgxsj(new Date()); + return JSON.toJSONString(apiData); + } + return JSON.toJSONString(data); } @@ -383,7 +600,7 @@ gdFinanceDto.setBbsj(DateFormatUtils.format(api1503.getBbsj(), "yyyyMMdd")); gdFinanceDto.setBbm("03"); gdFinanceDto.setCzbz(api1503.getCzbz()); - gdFinanceDto.setZhgxsj(DateFormatUtils.format(api1503.getZhgxsj(), "yyyy-MM-dd HH:mm:ss")); + gdFinanceDto.setZhgxsj(DateFormatUtils.format(new Date(), "yyyy-MM-dd HH:mm:ss")); paddingData(gdFinanceDto, list, 1, "椤圭洰//t", "鏈湡閲戦//t", "鏈勾绱//t"); paddingData(gdFinanceDto, list, 2, "涓�銆佽惀涓氭敹鍏�", api1503.getYyzsrbqye() + "", api1503.getYyzsrbnlj() + ""); @@ -435,7 +652,7 @@ gdFinanceDto.setBbsj(DateFormatUtils.format(api1502.getBbsj(), "yyyyMMdd")); gdFinanceDto.setBbm("02"); gdFinanceDto.setCzbz(api1502.getCzbz()); - gdFinanceDto.setZhgxsj(DateFormatUtils.format(api1502.getZhgxsj(), "yyyy-MM-dd HH:mm:ss")); + gdFinanceDto.setZhgxsj(DateFormatUtils.format(new Date(), "yyyy-MM-dd HH:mm:ss")); paddingData(gdFinanceDto, list, 1, "椤圭洰//t", "鏈湀鏁�//t", "鏈勾绱鏁�//t"); paddingData(gdFinanceDto, list, 2, "涓�銆佺粡钀ユ椿鍔ㄤ骇鐢熺殑鐜伴噾娴侀噺锛�", api1502.getJyhdxjllbys() + "", api1502.getJyhdxjllbnljs() + ""); @@ -488,7 +705,7 @@ gdFinanceDto.setBbsj(DateFormatUtils.format(api1501.getBbsj(), "yyyyMMdd")); gdFinanceDto.setBbm("01"); gdFinanceDto.setCzbz(api1501.getCzbz()); - gdFinanceDto.setZhgxsj(DateFormatUtils.format(api1501.getZhgxsj(), "yyyy-MM-dd HH:mm:ss")); + gdFinanceDto.setZhgxsj(DateFormatUtils.format(new Date(), "yyyy-MM-dd HH:mm:ss")); paddingData(gdFinanceDto, list, 1, "璧勪骇//t", "鏈熸湯浣欓//t", "骞村垵浣欓//t"); paddingData(gdFinanceDto, list, 2, "娴佸姩璧勪骇锛�", api1501.getLdzchjqmye() + "", api1501.getLdzchjncye() + ""); @@ -612,7 +829,7 @@ case "1112": return ApiCodeConstant.API_CODE_RYXX; case "1113": - return ""; + return ApiCodeConstant.API_CODE_QYXYXX; case "1201": return ApiCodeConstant.API_CODE_HTXX; case "1202": @@ -660,11 +877,11 @@ case "1401": return ApiCodeConstant.API_CODE_CBGM; case "1402": - return ApiCodeConstant.API_CODE_CBJHXX; + return ApiCodeConstant.API_CODE_CBJH; case "1403": - return ApiCodeConstant.API_CODE_LHJHXX; + return ApiCodeConstant.API_CODE_LHJH; case "1404": - return ApiCodeConstant.API_CODE_LHJHMXXX; + return null; case "1405": return ""; case "1501": @@ -677,4 +894,11 @@ return inteId; } } + + + @Override + public ResponseDto pullData(ApiParam param, ApiConfs conf) { + //璇ュ崗璁棤姝ゅ疄鐜� + return null; + } } -- Gitblit v1.9.3