From a03d12962c4439cce9193f178c02164db20f734c Mon Sep 17 00:00:00 2001 From: czt <czt18638530771@163.com> Date: 星期二, 23 四月 2024 20:30:49 +0800 Subject: [PATCH] 调整指令解析 --- src/main/java/com/fzzy/push/sh2023/SH2023ApiRemoteService.java | 38 +++++++++++++++++++++++++++----------- 1 files changed, 27 insertions(+), 11 deletions(-) diff --git a/src/main/java/com/fzzy/push/sh2023/SH2023ApiRemoteService.java b/src/main/java/com/fzzy/push/sh2023/SH2023ApiRemoteService.java index b6f0cc6..c4f80bd 100644 --- a/src/main/java/com/fzzy/push/sh2023/SH2023ApiRemoteService.java +++ b/src/main/java/com/fzzy/push/sh2023/SH2023ApiRemoteService.java @@ -1,6 +1,7 @@ package com.fzzy.push.sh2023; import com.alibaba.fastjson.JSON; +import com.fzzy.api.Constant; import com.fzzy.api.data.ApiParam; import com.fzzy.api.data.PushProtocol; import com.fzzy.api.dto.ResponseDto; @@ -10,7 +11,7 @@ import com.fzzy.api.service.ApiTriggerService; import com.fzzy.api.utils.*; import com.fzzy.api.view.repository.*; -import com.fzzy.order.data.OrderData; +import com.fzzy.order.common.data.OrderCommonData; import com.fzzy.push.sh2023.dto.*; import lombok.Data; import lombok.extern.slf4j.Slf4j; @@ -92,10 +93,10 @@ apiLog.setId(ContextUtil.getUUID()); //鑻ヤ负璐㈠姟1501銆�1502銆�1503鎺ュ彛锛屽垯鎺ュ彛缂栫爜濉啓1114 - if (SH2023Constant.SH_2023_API_CODE_1114_1501.equals(param.getInteId()) - || SH2023Constant.SH_2023_API_CODE_1114_1502.equals(param.getInteId()) - || SH2023Constant.SH_2023_API_CODE_1114_1503.equals(param.getInteId())) { - inteId = SH2023Constant.SH_2023_API_CODE_1114; + if (Constant.API_CODE_1114_1501.equals(param.getInteId()) + || Constant.API_CODE_1114_1502.equals(param.getInteId()) + || Constant.API_CODE_1114_1503.equals(param.getInteId())) { + inteId = Constant.API_CODE_1114; } apiLog.setInteId(inteId); @@ -123,8 +124,8 @@ //鑾峰彇鎸囦护id String key = RedisConst.buildKey(RedisConst.KYE_ORDER, conf.getKqdm()); - OrderData orderData = (OrderData) redisUtil.get(key); - if (null == orderData || StringUtils.isEmpty(orderData.getOrderid())) { + String orderId = (String) redisUtil.get(key); + if (StringUtils.isEmpty(orderId)) { log.error("鎸囦护id澶辨晥=" + jsonData); ResponseDto responseDto = new ResponseDto(99, "鎸囦护id澶辨晥"); apiLog.setStatus(99); @@ -139,7 +140,7 @@ //鑾峰彇韬唤ID锛屽嵆琛屾斂鍖哄垝鐮� reqData.setUid(conf.getUserName()); //鎸囦护id - reqData.setOrderid(orderData.getOrderid()); + reqData.setOrderid(orderId); //韬唤绛惧悕锛屼娇鐢ㄨ嚜鏈塕SA绉侀挜杩涜鍔犲瘑(鍦板尯琛屾斂鍖哄垝浠g爜_褰撳ぉ鏃ユ湡) reqData.setAccess_token(ShRSAUtils.sign(reqData.getUid() + "_" + DateFormatUtils.format(new Date(), "yyyy-MM-dd"), conf.getPassword())); @@ -447,7 +448,9 @@ //璁剧疆绮杞崲骞村害,鏍规嵁璁″垝鏄庣粏鍙锋煡璇㈣鍒掓槑缁嗭紝鍐嶆牴鎹鍒掓槑缁嗘煡璇㈣疆鎹㈣鍒� List<Api1404> api1404List = api1404Rep.getDataByJhmxdh(apiData.getJhmxh()); if (null != api1404List && api1404List.size() > 0) { - api1202.setShnd(api1404List.get(0).getShnd()); + if(StringUtils.isEmpty(api1202.getShnd())){ + api1202.setShnd(api1404List.get(0).getShnd()); + } List<Api1403> api1403List = api1403Rep.getDataByLhjhdh(api1404List.get(0).getLhjhdh()); if(null != api1403List && api1403List.size() > 0){ if(StringUtils.isNotEmpty(api1403List.get(0).getJhnd())){ @@ -551,6 +554,9 @@ //璁剧疆绮杞崲骞村害 List<Api1404> api1404List = api1404Rep.getDataByJhmxdh(apiData.getJhmxh()); if (null != api1404List && api1404List.size() > 0) { + if(StringUtils.isEmpty(api1205.getShnd())){ + api1205.setShnd(api1404List.get(0).getShnd()); + } List<Api1403> api1403List = api1403Rep.getDataByLhjhdh(api1404List.get(0).getLhjhdh()); if(null != api1403List && api1403List.size() > 0){ if(StringUtils.isNotEmpty(api1403List.get(0).getJhnd())){ @@ -582,6 +588,12 @@ if (null != api1208List && api1208List.size() > 0) { api1206.setPch(api1208List.get(0).getHwdm() + api1208List.get(0).getShnd()); } + } + } + if (StringUtils.isNotEmpty(apiData.getHwdm())) { + List<Api1208> api1208List = api1208Rep.findDataByHwdm(apiData.getHwdm()); + if (null != api1208List && api1208List.size() > 0) { + api1206.setPch(api1208List.get(0).getHwdm() + api1208List.get(0).getShnd()); } } //璁剧疆绌哄睘鎬т负榛樿鍊� @@ -787,10 +799,14 @@ Api1306 apiData = (Api1306) data; BeanUtils.copyProperties(apiData, api1306); api1306.setBjw(ShAreaBjw.getBjw(code)); - api1306.setPch(apiData.getXzzydh().substring(0, 30) + DateFormatUtils.format(apiData.getXzkssj(), "yyyy")); api1306.setAjdm(apiData.getHwdm().substring(0, 28)); //涓婃捣鐔忚捀浣滀笟鍗曞彿锛氳揣浣嶄唬鐮�+yyyyMMdd + 3浣嶉『搴忓彿 api1306.setXzzydh(apiData.getHwdm() + apiData.getBizId()); + //璁剧疆鎵规鍙� + List<Api1208> api1208List = api1208Rep.findDataByHwdm(apiData.getHwdm()); + if (null != api1208List && api1208List.size() > 0) { + api1306.setPch(apiData.getHwdm() + api1208List.get(0).getShnd()); + } if (StringUtils.isEmpty(api1306.getSyff())) { api1306.setSyff("0"); //娼В娉� } @@ -843,7 +859,7 @@ } String lsxzdm = "122"; String pch = ""; - List<Api1208> api1208List = api1208Rep.getDataByHwdm(api1310.getHwdm()); + List<Api1208> api1208List = api1208Rep.findDataByHwdm(api1310.getHwdm()); if (null != api1208List && api1208List.size() > 0) { if (StringUtils.isNotEmpty(api1208List.get(0).getLsxzdm())) { lsxzdm = api1208List.get(0).getLsxzdm(); -- Gitblit v1.9.3