From b265ff9c3dbcee12196985c17cda59191e2fd348 Mon Sep 17 00:00:00 2001
From: 13405411873 <1994398261@qq.com>
Date: Mon, 21 Apr 2025 12:26:34 +0800
Subject: [PATCH] =?UTF-8?q?=E5=8F=91=E5=B8=83=E9=80=9A=E5=91=8A=E5=8A=9F?=
 =?UTF-8?q?=E8=83=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/com/ruoyi/api/WxApi.java    | 61 +++++++++++++++++++
 .../com/ruoyi/busi/utils/WeChatUtils.java     |  4 +-
 .../member/service/IMemberUserService.java    | 10 +++
 .../service/impl/MemberUserServiceImpl.java   | 52 ++++++++++++++++
 .../controller/system/SysLoginController.java | 13 ++--
 .../src/main/resources/application.yml        | 25 +++++++-
 .../core/domain/model/GzhLoginBody.java       | 16 +++++
 .../common/core/domain/model/LoginUser.java   | 17 ++++--
 8 files changed, 186 insertions(+), 12 deletions(-)
 create mode 100644 ruoyi-admin/src/main/java/com/ruoyi/api/WxApi.java
 create mode 100644 ruoyi-common/src/main/java/com/ruoyi/common/core/domain/model/GzhLoginBody.java

diff --git a/ruoyi-admin/src/main/java/com/ruoyi/api/WxApi.java b/ruoyi-admin/src/main/java/com/ruoyi/api/WxApi.java
new file mode 100644
index 0000000..2b1134f
--- /dev/null
+++ b/ruoyi-admin/src/main/java/com/ruoyi/api/WxApi.java
@@ -0,0 +1,61 @@
+package com.ruoyi.api;
+
+
+import cn.hutool.json.JSONObject;
+import cn.hutool.json.JSONUtil;
+import com.ruoyi.busi.utils.WeChatUtils;
+import com.ruoyi.common.annotation.Anonymous;
+import com.ruoyi.common.constant.Constants;
+import com.ruoyi.common.core.domain.AjaxResult;
+import com.ruoyi.common.core.domain.model.GzhLoginBody;
+import com.ruoyi.common.utils.StringUtils;
+import com.ruoyi.member.service.IMemberUserService;
+import com.wechat.pay.contrib.apache.httpclient.util.AesUtil;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.io.IOException;
+import java.nio.charset.StandardCharsets;
+import java.security.GeneralSecurityException;
+import java.util.HashMap;
+import java.util.Map;
+
+@RestController
+@RequestMapping("/wxApi")
+public class WxApi {
+    @Autowired
+    private WeChatUtils weChatUtils;
+    @Autowired
+    private IMemberUserService memberUserService;
+
+
+
+    @GetMapping("/getCodeUrl")
+    @Anonymous
+    public Map<String, String> getCodeUrl(String userType) {
+        Map<String, String> res = new HashMap<>();
+        res.put("codeUrl", weChatUtils.getCodeUrl("https://www.nuoyunr.com/#/pages/mine/member/member-card", userType));
+        return  res;
+    }
+
+    @GetMapping("/getWebAccessTokenAndOpenid")
+    @Anonymous
+    public JSONObject getWebAccessTokenAndOpenid(String code) {
+        return weChatUtils.getWebAccessTokenAndOpenid(code);
+    }
+
+    @PostMapping("/gzhLogin")
+    @Anonymous
+    public AjaxResult gzhLogin(@RequestBody GzhLoginBody gzhLoginBody)
+    {
+        JSONObject userInfo = weChatUtils.getUserInfo(gzhLoginBody.getAccess_token(), gzhLoginBody.getOpenid());
+        //如果解析成功,获取token
+        String token = memberUserService.gzhLogin(gzhLoginBody.getOpenid(),userInfo);
+        AjaxResult ajax = AjaxResult.success();
+        ajax.put(Constants.TOKEN, token);
+        return ajax;
+
+    }
+
+}
diff --git a/ruoyi-admin/src/main/java/com/ruoyi/busi/utils/WeChatUtils.java b/ruoyi-admin/src/main/java/com/ruoyi/busi/utils/WeChatUtils.java
index c1ffe68..b9ef4be 100644
--- a/ruoyi-admin/src/main/java/com/ruoyi/busi/utils/WeChatUtils.java
+++ b/ruoyi-admin/src/main/java/com/ruoyi/busi/utils/WeChatUtils.java
@@ -66,7 +66,7 @@ public class WeChatUtils {
      */
     public JSONObject getWebAccessTokenAndOpenid(String code) {
         String requestUrl = WEB_ACCESS_TOKEN_URL.replace("APPID", wechatPayConfig.getAppId())
-                .replace("APPSECRET", wechatPayConfig.getAppSecret())
+                .replace("APPSECRET", wechatPayConfig.getWxAppSecret())
                 .replace("CODE", code);
         String response = HttpUtil.get(requestUrl);
         return JSONUtil.parseObj(response);
@@ -105,7 +105,7 @@ public class WeChatUtils {
 
         // 如果Redis中没有或者强制刷新，则从微信获取
         String requestUrl = ACCESS_TOKEN_URL.replace("APPID", wechatPayConfig.getAppId())
-                .replace("APPSECRET", wechatPayConfig.getAppSecret());
+                .replace("APPSECRET", wechatPayConfig.getWxAppSecret());
         String response = HttpUtil.get(requestUrl);
         JSONObject jsonObject = JSONUtil.parseObj(response);
         accessToken = jsonObject.getStr("access_token");
diff --git a/ruoyi-admin/src/main/java/com/ruoyi/member/service/IMemberUserService.java b/ruoyi-admin/src/main/java/com/ruoyi/member/service/IMemberUserService.java
index 7c641ec..12129c0 100644
--- a/ruoyi-admin/src/main/java/com/ruoyi/member/service/IMemberUserService.java
+++ b/ruoyi-admin/src/main/java/com/ruoyi/member/service/IMemberUserService.java
@@ -2,6 +2,7 @@ package com.ruoyi.member.service;
 
 import java.util.List;
 
+import cn.hutool.json.JSONObject;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.IService;
@@ -76,4 +77,13 @@ public interface IMemberUserService extends IService<MemberUser> {
     **/
     void uniSaveMember(MemberUserVO memberUser);
 
+    /**
+     * 微信授权登陆
+     *
+     * @return java.lang.String
+     * @author vinjor-M
+     * @date 15:55 2025/3/26
+     **/
+    String gzhLogin(String wxOpenId,  JSONObject userInfo);
+
 }
diff --git a/ruoyi-admin/src/main/java/com/ruoyi/member/service/impl/MemberUserServiceImpl.java b/ruoyi-admin/src/main/java/com/ruoyi/member/service/impl/MemberUserServiceImpl.java
index 21bc757..afd64f6 100644
--- a/ruoyi-admin/src/main/java/com/ruoyi/member/service/impl/MemberUserServiceImpl.java
+++ b/ruoyi-admin/src/main/java/com/ruoyi/member/service/impl/MemberUserServiceImpl.java
@@ -16,6 +16,7 @@ import com.ruoyi.common.core.domain.model.LoginUser;
 import com.ruoyi.common.exception.ServiceException;
 import com.ruoyi.common.utils.DateUtils;
 import com.ruoyi.common.utils.SecurityUtils;
+import com.ruoyi.common.utils.StringUtils;
 import com.ruoyi.constant.DictConstants;
 import com.ruoyi.framework.web.service.TokenService;
 import com.ruoyi.member.domain.MemberUser;
@@ -234,4 +235,55 @@ public class MemberUserServiceImpl extends ServiceImpl<MemberUserMapper, MemberU
         BeanUtils.copyProperties(memberUser,member);
         updateById(member);
     }
+
+    @Override
+    public String gzhLogin(String wxOpenId, cn.hutool.json.JSONObject userInfo) {
+        //根据openid判断数据库中是否有该用户
+        //根据openid查询用户信息
+        SysUser wxUser = userMapper.selectWxUserByOpenIdOrPhone(null,null,wxOpenId,null);
+        if(null==wxUser&& StringUtils.isNotEmpty((String) userInfo.get("unionid"))){
+            //根据openId没查到，再根据unionid查
+            wxUser = userMapper.selectWxUserByOpenIdOrPhone(null,null,null,(String) userInfo.get("unionid"));
+        }
+        //如果查不到，则新增，查到了，则更新
+        SysUser user = new SysUser();
+        if (wxUser == null) {
+            // 新增
+            // 设置姓名 ，默认使用昵称+随机数，防止重复姓名的发生 数据库中把username的长度修改的长一点
+            user.setUserName((String) userInfo.get("openid"));
+            user.setNickName((String) userInfo.get("nickname"));
+            user.setWxOpenId((String) userInfo.get("openid"));
+            user.setUnionId((String) userInfo.get("unionid"));
+            user.setSex( userInfo.get("sex").equals("1")?"0":"1");
+            user.setCreateTime(DateUtils.getNowDate());
+            //新增 用户
+            userMapper.insertUser(user);
+            //插入用户扩展信息表数据
+            this.save(new MemberUser(DictConstants.USER_TYPE_TGZ,user,dlRightsConfig.getAddNotice()));
+            this.save(new MemberUser(DictConstants.USER_TYPE_BZ,user,null));
+            //开通会员卡
+            cardService.dealMemberCard(user.getUserId(),"01","67def5ba1e4c60754e68defb3fb027a5","04",null);
+            cardService.dealMemberCard(user.getUserId(),"02","7530cf7b7a5d0100a7b41605d1642ef1","04",null);
+        }else {
+            //,查到了
+            if(!"0".equals(wxUser.getStatus())){
+                //非正常状态，无法登录
+                throw new ServiceException("账号状态异常");
+            }
+            // 更新
+            user = wxUser;
+            if(!userInfo.get("openid").equals(user.getOpenId())){
+                user.setWxOpenId((String) userInfo.get("openid"));
+                user.setUpdateTime(DateUtils.getNowDate());
+                userMapper.updateUser(user);
+            }
+        }
+        //组装token信息
+        LoginUser loginUser = new LoginUser();
+        loginUser.setWxOpenId((String) userInfo.get("openid"));
+        loginUser.setUser(user);
+        loginUser.setUserId(user.getUserId());
+        // 生成token
+        return tokenService.createToken(loginUser);
+    }
 }
diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/system/SysLoginController.java b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/system/SysLoginController.java
index 2153b75..fbe81e0 100644
--- a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/system/SysLoginController.java
+++ b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/system/SysLoginController.java
@@ -11,6 +11,7 @@ import java.util.Set;
 
 import com.alibaba.fastjson2.JSONObject;
 import com.ruoyi.common.config.WxAppConfig;
+import com.ruoyi.common.core.domain.model.GzhLoginBody;
 import com.ruoyi.common.core.domain.model.WxLoginBody;
 import com.ruoyi.common.utils.StringUtils;
 import com.ruoyi.member.service.IMemberCardService;
@@ -43,7 +44,7 @@ import javax.crypto.spec.SecretKeySpec;
 
 /**
  * 登录验证
- * 
+ *
  * @author ruoyi
  */
 @RestController
@@ -109,9 +110,13 @@ public class SysLoginController
         }
     }
 
+
+
+
+
     /**
      * 登录方法
-     * 
+     *
      * @param loginBody 登录信息
      * @return 结果
      */
@@ -128,7 +133,7 @@ public class SysLoginController
 
     /**
      * 获取用户信息
-     * 
+     *
      * @return 用户信息
      */
     @GetMapping("getInfo")
@@ -155,7 +160,7 @@ public class SysLoginController
 
     /**
      * 获取路由信息
-     * 
+     *
      * @return 路由信息
      */
     @GetMapping("getRouters")
diff --git a/ruoyi-admin/src/main/resources/application.yml b/ruoyi-admin/src/main/resources/application.yml
index 98323bf..b96116a 100644
--- a/ruoyi-admin/src/main/resources/application.yml
+++ b/ruoyi-admin/src/main/resources/application.yml
@@ -16,7 +16,7 @@ ruoyi:
 # 开发环境配置
 server:
   # 服务器的HTTP端口，默认为8080
-  port: 8081
+  port: 8099
   servlet:
     # 应用的访问路径
     context-path: /
@@ -147,8 +147,29 @@ xss:
 wx-app:
   appId: wxd8ef44a8268672e4
   appSecret: 30c18855ceb0ab0f9801407c998199c2
+wxpay:
+  #微信公众号appid
+  appId: wx7d10b0fa4886a583
+  #商户号
+  mchId: 1712447936
+  # APIv3密钥
+  apiV3Key: ab94673dd0cca78abd0a453d0aac9f98
+  # 微信支付V3-url前缀
+  baseUrl: https://api.mch.weixin.qq.com/v3
+  # 支付通知回调, pjm6m9.natappfree.cc 为内网穿透地址
+  notifyUrl: https://www.nuoyunr.com/notice/notify/payNotify
+  # 退款通知回调, pjm6m9.natappfree.cc 为内网穿透地址
+  refundNotifyUrl: https://www.nuoyunr.com/notice/notify/refundNotify
+  # 密钥路径,resources根目录下
+  privateKeyPath: D:/任务平台项目/dl_admin/ruoyi-admin/src/main/resources/apiclient_key.pem
+  publicKeyPath: D:/任务平台项目/dl_admin/ruoyi-admin/src/main/resources/public_key.pem
+  #商户证书序列号
+  serialNo: 7FCDB0E72D6A928013361ACB77FA3F0DCBD370E3
+  publicKeyId: PUB_KEY_ID_0117124479362025041500321584003200
+  wxAppSecret: 1515e5d055e8dabf5b30faad14ccbc8d
+
 #  普通用户权益值
 dl-rights:
 #  每月发布通告额度
   addNotice: 3
-  report: 5
\ No newline at end of file
+  report: 5
diff --git a/ruoyi-common/src/main/java/com/ruoyi/common/core/domain/model/GzhLoginBody.java b/ruoyi-common/src/main/java/com/ruoyi/common/core/domain/model/GzhLoginBody.java
new file mode 100644
index 0000000..0bb422a
--- /dev/null
+++ b/ruoyi-common/src/main/java/com/ruoyi/common/core/domain/model/GzhLoginBody.java
@@ -0,0 +1,16 @@
+package com.ruoyi.common.core.domain.model;
+
+import lombok.Data;
+
+@Data
+public class GzhLoginBody {
+    /** 临时登录凭证 code 只能使用一次 */
+    private String access_token;
+
+    /** 偏移量 */
+    private String expires_in;
+
+    /** 加密数据 */
+    private String openid;
+
+}
diff --git a/ruoyi-common/src/main/java/com/ruoyi/common/core/domain/model/LoginUser.java b/ruoyi-common/src/main/java/com/ruoyi/common/core/domain/model/LoginUser.java
index c648ea9..2e0aa1d 100644
--- a/ruoyi-common/src/main/java/com/ruoyi/common/core/domain/model/LoginUser.java
+++ b/ruoyi-common/src/main/java/com/ruoyi/common/core/domain/model/LoginUser.java
@@ -9,7 +9,7 @@ import java.util.Set;
 
 /**
  * 登录用户身份权限
- * 
+ *
  * @author ruoyi
  */
 public class LoginUser implements UserDetails
@@ -73,6 +73,7 @@ public class LoginUser implements UserDetails
 
     /** openId */
     private String openId;
+    private String wxOpenId;
 
     public LoginUser()
     {
@@ -155,7 +156,7 @@ public class LoginUser implements UserDetails
 
     /**
      * 指定用户是否解锁,锁定的用户无法进行身份验证
-     * 
+     *
      * @return
      */
     @JSONField(serialize = false)
@@ -167,7 +168,7 @@ public class LoginUser implements UserDetails
 
     /**
      * 指示是否已过期的用户的凭据(密码),过期的凭据防止认证
-     * 
+     *
      * @return
      */
     @JSONField(serialize = false)
@@ -179,7 +180,7 @@ public class LoginUser implements UserDetails
 
     /**
      * 是否可用 ,禁用的用户不能身份验证
-     * 
+     *
      * @return
      */
     @JSONField(serialize = false)
@@ -274,4 +275,12 @@ public class LoginUser implements UserDetails
     {
         return null;
     }
+
+    public String getWxOpenId() {
+        return wxOpenId;
+    }
+
+    public void setWxOpenId(String wxOpenId) {
+        this.wxOpenId = wxOpenId;
+    }
 }