From a7c7bff93a8bf44524314a6d1d986611ce466b2c Mon Sep 17 00:00:00 2001
From: zhubaomin <zhubaomin>
Date: 星期四, 03 四月 2025 15:24:29 +0800
Subject: [PATCH] 发布灌溉计划时延迟1分钟
---
pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/client/ClientCtrl.java | 51 ++++++++++++++++++++++++++++++++++++++++-----------
1 files changed, 40 insertions(+), 11 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 aa43460..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
@@ -8,13 +8,13 @@
import com.dy.pipIrrGlobal.pojoSe.SeCodeVerify;
import com.dy.pipIrrGlobal.pojoSe.SeOpenId;
import com.dy.pipIrrGlobal.voSe.VoClientWechat;
-import com.dy.pipIrrSell.wechatpay.PayInfo;
import com.dy.pipIrrWechat.client.dto.CodeLoginDTO;
import com.dy.pipIrrWechat.client.dto.CodeVerifyDTO;
import com.dy.pipIrrWechat.result.WechatResultCode;
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;
@@ -43,9 +43,8 @@
private final ClientSv clientSv;
private final AliyunSmsSv aliyunSmsSv;
private final RestTemplateUtil restTemplateUtil;
- private final String privateCertFileName = PayInfo.privateCertFileName;
- 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;
@@ -70,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<>();
@@ -112,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());
@@ -179,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<>();
@@ -193,7 +198,7 @@
String sessionKey = job.getString("session_key");
Long clientId = clientSv.getClientIdByPhone(phoneNumber);
- String SessionId = "";
+ String sessionId = "";
if(clientId != null) {
// 娣诲姞寰俊鐢ㄦ埛璐︽埛璁板綍
SeOpenId seOpenId = new SeOpenId();
@@ -204,9 +209,13 @@
//Long SessionId = clientSv.addOpenId(seOpenId);
Long rec = clientSv.addOpenId(seOpenId);
if(rec != null) {
- SessionId = String.valueOf(rec);
+ sessionId = String.valueOf(rec);
}
- return BaseResponseUtils.buildSuccess(SessionId);
+
+ JSONObject job_result = new JSONObject();
+ job_result.put("clientId", String.valueOf(clientId));
+ job_result.put("sessionId", sessionId);
+ return BaseResponseUtils.buildSuccess(job_result);
} else {
return BaseResponseUtils.buildErrorMsg(WechatResultCode.PHONE_NUMBER_IS_ERROR.getMessage());
@@ -214,6 +223,26 @@
}
/**
+ * 瑙ｇ粦鍐滄埛涓庡井淇＄殑缁戝畾锛屾牴鎹畇essionId鍒犻櫎缁戝畾璁板綍
+ * @param sessionId
+ * @return
+ */
+ @PostMapping(path = "unbind")
+ @Transactional(rollbackFor = Exception.class)
+ public BaseResponse<Boolean> unbindWechat(@RequestParam("sessionId")Long sessionId) {
+ if(sessionId == null || sessionId <=0) {
+ return BaseResponseUtils.buildErrorMsg("sessionId鏃犳晥");
+ }
+
+ Integer rec = clientSv.unbindWechat(sessionId);
+ if(rec == null || rec == 0) {
+ return BaseResponseUtils.buildErrorMsg("sessionId閿欒");
+ }
+
+ return BaseResponseUtils.buildSuccess();
+ }
+
+ /**
* 鑾峰彇鍐滄埛鍩烘湰淇℃伅锛屽皬绋嬪簭棣栭〉浣跨敤
* @param sessionId
* @return
--
Gitblit v1.8.0