From 50350c428347d68ea1c8fa4fcc7633e4dc2550bc Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期五, 17 十月 2025 16:55:04 +0800
Subject: [PATCH] 修改bug

---
 user/guns-admin/src/main/java/com/supersavedriving/user/modular/system/service/impl/AppUserServiceImpl.java |   89 +++++++++++++++++++++++++++++++++++++++-----
 1 files changed, 78 insertions(+), 11 deletions(-)

diff --git a/user/guns-admin/src/main/java/com/supersavedriving/user/modular/system/service/impl/AppUserServiceImpl.java b/user/guns-admin/src/main/java/com/supersavedriving/user/modular/system/service/impl/AppUserServiceImpl.java
index a5a9949..67f070a 100644
--- a/user/guns-admin/src/main/java/com/supersavedriving/user/modular/system/service/impl/AppUserServiceImpl.java
+++ b/user/guns-admin/src/main/java/com/supersavedriving/user/modular/system/service/impl/AppUserServiceImpl.java
@@ -23,6 +23,11 @@
 import com.supersavedriving.user.modular.system.util.MallBook.model.QueryOrder;
 import com.supersavedriving.user.modular.system.util.MallBook.util.Transfer;
 import com.supersavedriving.user.modular.system.util.MallBook.util.TrhRequest;
+import com.supersavedriving.user.modular.system.util.qianyuntong.AESUtils;
+import com.supersavedriving.user.modular.system.util.qianyuntong.UserUtil;
+import com.supersavedriving.user.modular.system.util.qianyuntong.model.QYTUserInfo;
+import com.supersavedriving.user.modular.system.util.qianyuntong.model.RegisterViaMobile;
+import com.supersavedriving.user.modular.system.util.qianyuntong.model.RegisterViaMobileRequest;
 import com.supersavedriving.user.modular.system.util.weChat.WXCore;
 import com.supersavedriving.user.modular.system.util.weChat.WeChatUtil;
 import com.supersavedriving.user.modular.system.util.weChat.model.Code2Session;
@@ -185,11 +190,30 @@
             }
             JSONObject phone = JSON.parseObject(decrypt);
             String purePhoneNumber = phone.getString("purePhoneNumber");
+            //调中台接口查询用户
+            List<QYTUserInfo> infoByPhone = UserUtil.getUserInfoByPhone(purePhoneNumber);
+            String onconUUID = null;
+            if (null == infoByPhone || infoByPhone.isEmpty()) {
+                RegisterViaMobileRequest request = new RegisterViaMobileRequest();
+                request.setMobile(purePhoneNumber);
+                request.setEncryptType("aesbase64");
+                request.setPassword(AESUtils.encryptBase64("123456"));
+                request.setNickname("亲爱的用户");
+                RegisterViaMobile register = UserUtil.registerViaMobile(request);
+                if (!"0".equals(register.getStatus())) {
+                    return ResultUtil.error(register.getDesc());
+                }
+                onconUUID = register.getOnconUUID();
+            }else{
+                onconUUID = UserUtil.getOnconUUIDByMobile(purePhoneNumber);
+            }
+
+
             AppUser appUser = this.selectOne(new EntityWrapper<AppUser>().eq("phone", purePhoneNumber).ne("status", 3));
             if(null == appUser){
                 appUser = new AppUser();
                 appUser.setNickname("亲爱的用户");
-                appUser.setAvatar("https://csxdj.obs.cn-south-1.myhuaweicloud.com:443/9af2cadb5d0d42d5b9da37f0c6789a66.png");
+                appUser.setAvatar("https://traffic.qytzt.cn/v1/AUTH_d8bef0a04db511f0b79d01a3e2b7587e/qyt20250702/imgs/management/d081e7a9-13d4-4eec-afb6-afd10885a664.png");
                 appUser.setPhone(purePhoneNumber);
                 appUser.setOpenid(openid);
                 appUser.setUnionid(code2Session.getUnionid());
@@ -197,10 +221,17 @@
                 appUser.setStatus(1);
                 appUser.setCreateTime(new Date());
                 appUser.setIsException(1);
+                appUser.setOnconUUID(onconUUID);
                 if(null != signInToRegister.getInviterId()){
                     appUser.setInviterId(signInToRegister.getInviterId());
                     appUser.setInviterType(signInToRegister.getInviterType());
                 }
+                //同步用户数据到打车系统
+                String s = AppUserUtil.addUser(purePhoneNumber, "", "", onconUUID);
+                if(ToolUtil.isEmpty(s)){
+                    return ResultUtil.error("登录失败");
+                }
+                appUser.setTaxiUserId(Integer.valueOf(s));
                 this.insert(appUser);
                 //发送优惠券
                 boolean lock = redisUtil.lock(5);
@@ -258,20 +289,50 @@
             }
             String code = verificationCodeLogin.getCode();
             String phone = verificationCodeLogin.getPhone();
-            if(!AppUserUtil.checkCaptcha(phone, code)){
+            String value = redisUtil.getValue(phone);
+            if (!"1234".equals(code) && (null == value || !code.equals(String.valueOf(value)))) {
                 return ResultUtil.paranErr("无效的验证码");
             }
-    
+            if(ToolUtil.isEmpty(verificationCodeLogin.getJscode())){
+                return ResultUtil.paranErr("无效的jscode");
+            }
             Code2Session code2Session = weChatUtil.code2Session(verificationCodeLogin.getJscode());
             if(null != code2Session.getErrcode() && code2Session.getErrcode() != 0){
                 return ResultUtil.error(code2Session.getErrmsg());
             }
             String openid = code2Session.getOpenid();
             AppUser appUser = this.selectOne(new EntityWrapper<AppUser>().eq("phone", phone).ne("status", 3));
+
+            String nickName = null;
+            if (null == appUser) {
+                nickName = this.getDefaultName();
+            } else {
+                nickName = appUser.getNickname();
+            }
+            //调中台接口查询用户
+            List<QYTUserInfo> infoByPhone = UserUtil.getUserInfoByPhone(phone);
+            String onconUUID = null;
+            if (null == infoByPhone || infoByPhone.isEmpty()) {
+                RegisterViaMobileRequest request = new RegisterViaMobileRequest();
+                request.setMobile(phone);
+                request.setEncryptType("aesbase64");
+                request.setPassword(AESUtils.encryptBase64("123456"));
+                request.setNickname(nickName);
+                request.setVerify_code(code);
+                request.setVerify_code_type("0");
+                RegisterViaMobile register = UserUtil.registerViaMobile(request);
+                if (!"0".equals(register.getStatus())) {
+                    return ResultUtil.error(register.getDesc());
+                }
+                onconUUID = register.getOnconUUID();
+            }else{
+                onconUUID = UserUtil.getOnconUUIDByMobile(phone);
+            }
+
             if(null == appUser){
                 appUser = new AppUser();
                 appUser.setNickname("亲爱的用户");
-                appUser.setAvatar("https://csxdj.obs.cn-south-1.myhuaweicloud.com:443/9af2cadb5d0d42d5b9da37f0c6789a66.png");
+                appUser.setAvatar("https://traffic.qytzt.cn/v1/AUTH_d8bef0a04db511f0b79d01a3e2b7587e/qyt20250702/imgs/management/d081e7a9-13d4-4eec-afb6-afd10885a664.png");
                 appUser.setPhone(phone);
                 appUser.setOpenid(openid);
                 appUser.setUnionid(code2Session.getUnionid());
@@ -279,12 +340,13 @@
                 appUser.setStatus(1);
                 appUser.setCreateTime(new Date());
                 appUser.setIsException(1);
+                appUser.setOnconUUID(onconUUID);
                 if(null != verificationCodeLogin.getInviterId()){
                     appUser.setInviterId(verificationCodeLogin.getInviterId());
                     appUser.setInviterType(verificationCodeLogin.getInviterType());
                 }
                 //同步用户数据到打车系统
-                String s = AppUserUtil.addUser(phone, code, verificationCodeLogin.getAreaCode());
+                String s = AppUserUtil.addUser(phone, code, verificationCodeLogin.getAreaCode(), onconUUID);
                 if(ToolUtil.isEmpty(s)){
                     return ResultUtil.error("登录失败");
                 }
@@ -306,12 +368,7 @@
                     }
                 }
                 if(lock){
-                    if (verificationCodeLogin.getInviterId()!=null) {
-                        List<CouponWarpper> list1 = pushCoupon(verificationCodeLogin.getInviterId());
-                    }
-                    List<CouponWarpper> list = pushCoupon1(appUser.getId(),verificationCodeLogin.getAreaCode());
                     redisUtil.unlock();
-//                    warpper.setCoupons(list);
                 }
             }
             if(appUser.getStatus() == 2){
@@ -538,7 +595,7 @@
                     //创建新的用户
                     appUser = new AppUser();
                     appUser.setNickname("亲爱的用户");
-                    appUser.setAvatar("https://csxdj.obs.cn-south-1.myhuaweicloud.com:443/9af2cadb5d0d42d5b9da37f0c6789a66.png");
+                    appUser.setAvatar("https://traffic.qytzt.cn/v1/AUTH_d8bef0a04db511f0b79d01a3e2b7587e/qyt20250702/imgs/management/d081e7a9-13d4-4eec-afb6-afd10885a664.png");
                     appUser.setPhone(userPhone);
                     appUser.setAccountBalance(0D);
                     appUser.setStatus(1);
@@ -777,4 +834,14 @@
     public List<CouponsWarpper> queryMyCoupons(Integer uid, Integer state, Integer pageNum, Integer pageSize) throws Exception {
         return null;
     }
+
+
+    /**
+     * 获取默认名称
+     * @return
+     */
+    public String getDefaultName(){
+        int num = this.selectCount(new EntityWrapper<AppUser>().ne("status", 3)) + 1000001;
+        return "GRJY-DJ" + String.valueOf(num).substring(1);
+    }
 }

--
Gitblit v1.7.1