From b397edee2be2dfcc3f28eeac50298b4de26b1afa Mon Sep 17 00:00:00 2001 From: liurunyu <lry9898@163.com> Date: 星期五, 13 十二月 2024 16:53:45 +0800 Subject: [PATCH] 取水口日取水量表中,出现一些大数,明显不正确,发析系统日志,发现一些阀控器会上报一些累计流量为0的数据,且无规律,推测是其不能从水表读取到累计流量时会上报0值。如果间歇上报0值,间歇上报一些非0值,非0值减去0值,就会出现大数,一天中出现几次那么会大数进行累加,数值将更大。为此变更算法,规避这种情况,但也会丢失一些流量值。 --- pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/client/ClientCtrl.java | 21 ++++++++++++++------- 1 files changed, 14 insertions(+), 7 deletions(-) diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/client/ClientCtrl.java b/pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/client/ClientCtrl.java index b01084c..b8c2185 100644 --- a/pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/client/ClientCtrl.java +++ b/pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/client/ClientCtrl.java @@ -14,6 +14,7 @@ import com.dy.pipIrrWechat.sms.AliyunSmsSv; import com.dy.pipIrrWechat.sms.RandomCode; import com.dy.pipIrrWechat.util.RestTemplateUtil; +import com.dy.pipIrrWechat.wechatpay.PayInfo; import io.swagger.v3.oas.annotations.tags.Tag; import jakarta.validation.Valid; import lombok.RequiredArgsConstructor; @@ -42,8 +43,8 @@ private final ClientSv clientSv; private final AliyunSmsSv aliyunSmsSv; private final RestTemplateUtil restTemplateUtil; - private final String appid = PayInfo.appid; - private final String secret = PayInfo.secret; + //private final String appid = PayInfo.appid; + //private final String secret = PayInfo.secret; private final String mchid = PayInfo.mchid; private final String schema = PayInfo.schema; private final String signType = PayInfo.signType; @@ -68,8 +69,8 @@ // 鐧诲綍鍑瘉鏍¢獙 Map<String, Object> queryParams = new HashMap<>(); - queryParams.put("appid", appid); - queryParams.put("secret", secret); + queryParams.put("appid", PayInfo.appid); + queryParams.put("secret", PayInfo.secret); queryParams.put("js_code", code); queryParams.put("grant_type", grantType); Map<String, String> headerParams = new HashMap<>(); @@ -110,6 +111,12 @@ if(phoneNumber == null || phoneNumber.length() <= 0) { return BaseResponseUtils.buildErrorMsg(WechatResultCode.PHONE_NUMBER_CANNOT_BE_NULL.getMessage()); } + + Long clientId = clientSv.getClientIdByPhone(phoneNumber); + if(clientId == null) { + return BaseResponseUtils.buildErrorMsg("璇ユ墜鏈哄彿瀵瑰簲鐨勫啘鎴蜂笉瀛樺湪"); + } + // 鐢熸垚6浣嶉獙璇佺爜骞惰浆涓篔son鏍煎紡 String securityCode = String.valueOf(RandomCode.genCode()); @@ -177,8 +184,8 @@ // 鏍¢獙閫氳繃锛岃繘琛岀櫥褰曞嚟璇佹牎楠� Map<String, Object> queryParams = new HashMap<>(); - queryParams.put("appid", appid); - queryParams.put("secret", secret); + queryParams.put("appid", PayInfo.appid); + queryParams.put("secret", PayInfo.secret); queryParams.put("js_code", code); queryParams.put("grant_type", grantType); Map<String, String> headerParams = new HashMap<>(); @@ -206,7 +213,7 @@ } JSONObject job_result = new JSONObject(); - job_result.put("clientId", clientId); + job_result.put("clientId", String.valueOf(clientId)); job_result.put("sessionId", sessionId); return BaseResponseUtils.buildSuccess(job_result); -- Gitblit v1.8.0