From 8580866e175ad0050ee9c5ea3f757856fc242c39 Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期五, 09 五月 2025 10:50:17 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'

---
 UserOKTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/UserInfoServiceImpl.java |   85 ++++++++++++++++++++++++++++--------------
 1 files changed, 56 insertions(+), 29 deletions(-)

diff --git a/UserOKTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/UserInfoServiceImpl.java b/UserOKTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/UserInfoServiceImpl.java
index f09cf82..8bc77a0 100644
--- a/UserOKTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/UserInfoServiceImpl.java
+++ b/UserOKTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/UserInfoServiceImpl.java
@@ -32,6 +32,7 @@
 import org.springframework.stereotype.Service;
 import org.springframework.util.LinkedMultiValueMap;
 import org.springframework.util.MultiValueMap;
+import org.springframework.util.StringUtils;
 import org.springframework.web.bind.annotation.ResponseBody;
 import org.springframework.web.client.RestTemplate;
 import org.springframework.web.multipart.MultipartFile;
@@ -88,6 +89,7 @@
 
     @Resource
     private DriverMapper driverMapper;
+
     @Autowired
     private RestTemplate restTemplate;
     @Resource
@@ -146,31 +148,27 @@
         String templateCode = "";
         switch (type){
             case 1:
-                templateCode = "SMS_476880205";//身份验证
+                templateCode = "SMS_482775061";//身份验证
                 break;
             case 2:
-                templateCode = "SMS_476880205";//登录确认
+                templateCode = "SMS_482775061";//登录确认
                 break;
             case 3:
-                templateCode = "SMS_476880205";//用户注册
+                templateCode = "SMS_482775061";//用户注册
                 break;
             case 4:
-                templateCode = "SMS_476880205";//修改密码
+                templateCode = "SMS_482775061";//修改密码
                 break;
         }
-        String sData = aLiSendSms.sendSms(phone, templateCode, "{\"code\":\"" + authCode + "\"}");
-        JSONObject jsonObject = JSON.parseObject(sData);
-        String message = jsonObject.getString("Message");
-        if(!"OK".equals(message)){
-            System.err.println(message);
-            return ResultUtil.error(message);
-        }
+//        String sData = aLiSendSms.sendSms(phone, templateCode, "{\"code\":\"" + authCode + "\"}");
+        SMSUtil.send(phone, "您的验证码:" + authCode + ",您正在进行身份验证,请勿泄露于他人!", "2431012312847");
+//        JSONObject jsonObject = JSON.parseObject(sData);
+//        String message = jsonObject.getString("Message");
+//        if(!"OK".equals(message)){
+//            System.err.println(message);
+//            return ResultUtil.error(message);
+//        }
         System.out.println(sms);
-//        System.err.println("222222");
-//
-//        String s = MsgUtil.Send_Post(phone, authCode);
-//        System.err.println(s);
-
         return ResultUtil.success();
     }
 
@@ -185,7 +183,7 @@
     @Override
     public boolean checkCaptcha(String phone, String code) throws Exception {
         Object value = redisUtil.getValue(phone);
-        if("1234".equals(code)){
+        if("5689".equals(code)){
             return true;
         }
 
@@ -248,11 +246,11 @@
                 invite.setInviteUserId(uid);
                 invite.setUserId(userInfo.getId());
                 invite.setRegisterTime(new Date());
-                invite.setUseType(userType);
+                invite.setUserType(userType);
                 inviteMapper.insert(invite);
                 if (userType==1){
                     // 只有用户邀请用户会获得优惠券
-                    List<Map<String, Object>> query = userActivityInviteMapper.query(userInfo.getCompanyId());
+                    List<Map<String, Object>> query = userActivityInviteMapper.query(1);
                     Date date = new Date();
                     for(Map<String, Object> map : query){
                         Double lavePrice = Double.valueOf(map.get("lavePrice").toString());
@@ -287,7 +285,6 @@
                     }
                 }
             }
-            this.addCoupon(userInfo);//添加优惠券
         }
         if(userInfo.getState() == 2){
             return ResultUtil.error("账号被冻结");
@@ -409,7 +406,7 @@
             }
             if(type == 1){//用户分享
                 UserInfo userInfo = userInfoMapper.selectById(uid);
-                List<Map<String, Object>> query = userActivityInviteMapper.query(userInfo.getCompanyId());
+                List<Map<String, Object>> query = userActivityInviteMapper.query(1);
                 Date date = new Date();
                 for(Map<String, Object> map : query){
                     Double lavePrice = Double.valueOf(map.get("lavePrice").toString());
@@ -507,7 +504,8 @@
     @Override
     public ResultUtil<LoginWarpper> wxLogin(Integer type, String openid, String unionid, String jscode, String registIp,
                                             String registAreaCode, Integer sex, String nickName, String avatar,String loginType,
-                                            Integer uid,Integer userType) throws Exception {
+                                            Integer uid,Integer userType,String phone) throws Exception {
+        System.err.println("手机号+++++"+phone);
         UserInfo userInfo = null;
         if(type == 2){//小程序
             if(ToolUtil.isEmpty(jscode)){
@@ -520,10 +518,19 @@
             System.out.println("unionid===="+unionid);
             userInfo = userInfoMapper.queryByOpenid2(openid);
 
+
         }else{//APP
             userInfo = userInfoMapper.queryByOpenid(openid);
         }
+        if (StringUtils.hasLength(phone)){
+            UserInfo userInfo1 = userInfoMapper.queryByPhone(phone);
+            if (null != userInfo1){
+                userInfo = userInfo1;
+                userInfo.setAppletsOpenId(openid);
+            }
+        }
         if(null == userInfo){
+
             // 如果为空 需要生成小程序二维码并携带用户id
             userInfo = new UserInfo();
             userInfo.setPassWord(ShiroKit.md5("", salt));
@@ -554,11 +561,11 @@
                 invite.setInviteUserId(uid);
                 invite.setUserId(userInfo.getId());
                 invite.setRegisterTime(new Date());
-                invite.setUseType(userType);
+                invite.setUserType(userType);
                 inviteMapper.insert(invite);
                 if (userType==1){
                     // 只有用户邀请用户会获得优惠券
-                    List<Map<String, Object>> query = userActivityInviteMapper.query(userInfo.getCompanyId());
+                    List<Map<String, Object>> query = userActivityInviteMapper.query(1);
                     Date date = new Date();
                     for(Map<String, Object> map : query){
                         Double lavePrice = Double.valueOf(map.get("lavePrice").toString());
@@ -651,7 +658,9 @@
             param.put("check_path", false);
             // 用户id 用于分享
             param.put("scene", "uid="+userInfo.getId()+"userType=1");
-            param.put("env_version", "trial");
+
+//            param.put("env_version", "trial");// 体验版
+            param.put("env_version", "release");// 正式版
             param.put("width", 200); //二维码尺寸
             param.put("is_hyaline", true); // 是否需要透明底色, is_hyaline 为true时,生成透明底色的小程序码 参数仅对小程序码生效
             param.put("auto_color", true); // 自动配置线条颜色,如果颜色依然是黑色,则说明不建议配置主色调 参数仅对小程序码生效
@@ -737,6 +746,7 @@
     }
 
 
+
     /**
      * 设置手机号码操作
      * @param uid
@@ -816,6 +826,18 @@
         this.updateById(userInfo);
 
         smsrecordService.saveData(2, phone, code, "短信验证码【" + code + "】已发到您的手机,验证码将在5分钟后失效,请及时登录!");
+        List<Invite> invites = inviteMapper.selectList(null);
+        List<UserInfo> userInfos = this.selectList(null);
+        List<Integer> integers = new ArrayList<>();
+        for (Invite invite : invites) {
+            UserInfo userInfo2 = userInfos.stream().filter(e -> e.getId().equals(invite.getUserId())).findFirst().orElse(null);
+            if (userInfo2==null){
+                integers.add(invite.getId());
+            }
+        }
+        if (!integers.isEmpty()){
+            inviteMapper.deleteBatchIds(integers);
+        }
         return ResultUtil.success(new LoginWarpper());
     }
 
@@ -1108,6 +1130,11 @@
         }
         jsonObject.put(userId.toString(), openid);
         redisUtil.setStrValue("appletOpenId", jsonObject.toJSONString());
+        UserInfo userInfo = userInfoMapper.selectById(userId);
+        if (userInfo!=null){
+            userInfo.setAppletsOpenId(openid);
+            userInfoMapper.updateById(userInfo);
+        }
         return ResultUtil.success();
     }
 
@@ -1148,7 +1175,7 @@
      * @throws Exception
      */
     public synchronized void addCoupon(Integer userId, Double money, Integer companyId, Integer paymentRecordId) throws Exception{
-        List<Map<String, Object>> query = userActivityBalanceService.query(money, companyId);
+        List<Map<String, Object>> query = userActivityBalanceService.query(money, 1);
         List<UserCouponRecord> list = new ArrayList<>();
         for(Map<String, Object> map : query){
             //添加通用优惠券
@@ -1288,7 +1315,7 @@
      * @return
      */
     public String getDefaultName(){
-        int num = this.selectCount(new EntityWrapper<UserInfo>().ne("flag", 3)) + 1000001;
+        int num = this.selectCount(new EntityWrapper<UserInfo>()) + 1000001;
         return "XN" + String.valueOf(num).substring(1);
     }
 
@@ -1329,7 +1356,7 @@
      */
     private synchronized void addCoupon(UserInfo userInfo) throws Exception{
         //添加优惠券
-        List<Map<String, Object>> list = userActivityRegisteredService.query(userInfo.getCompanyId());
+        List<Map<String, Object>> list = userActivityRegisteredService.query(1);
         int num = 0;
         for(Map<String, Object> map : list){
             if(null != map){
@@ -1377,7 +1404,7 @@
      */
     private synchronized void addInviteCoupon(UserInfo userInfo) throws Exception{
         //添加优惠券
-        List<Map<String, Object>> list = userActivityInviteMapper.query(userInfo.getCompanyId());
+        List<Map<String, Object>> list = userActivityInviteMapper.query(1);
         int num = 0;
         for(Map<String, Object> map : list){
             if(null != map){

--
Gitblit v1.7.1