111
fei.wang
2025-04-18 a6686570ac48648e2bf2ec93d27272a4473cac08
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
package com.hxzkappboot.controller;
 
import com.hxzkappboot.pojo.TbUser;
import com.hxzkappboot.service.UserService;
//import com.hxzkappboot.util.JwtUitls;
import com.hxzkappboot.util.JwtUtils;
import com.hxzkappboot.util.R;
import com.hxzkappboot.util.StatusCode;
import com.hxzkappboot.util.WechatLoginRequestDTO;
import com.tencentcloudapi.common.Credential;
import com.tencentcloudapi.common.exception.TencentCloudSDKException;
import com.tencentcloudapi.common.profile.ClientProfile;
import com.tencentcloudapi.common.profile.HttpProfile;
import com.tencentcloudapi.sms.v20210111.SmsClient;
import com.tencentcloudapi.sms.v20210111.models.SendSmsRequest;
import com.tencentcloudapi.sms.v20210111.models.SendSmsResponse;
import org.jetbrains.annotations.NotNull;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import javax.validation.Valid;
 
import java.util.Objects;
 
import static java.lang.Integer.parseInt;
 
@RestController
public class LoginController {
 
    private String SecretId = "AKIDrjZOI4e6KLZu9FAsSRN8eOwSt52lbMBz";
    private String SecretKey = "xnRtHUL3YqdMyOLVSBjKkz1pQoxujS4d";
 
    @Autowired
    UserService userService;
 
    @PostMapping("/api/wx/login")
    public R login(@Valid @RequestBody WechatLoginRequestDTO loginRequest ) {
//            System.out.println("收到微信code:" + loginRequest.getCode());
            R response ;
            try {
                TbUser tbUser = new TbUser();
                tbUser.setPassword(loginRequest.getPassword());
                tbUser.setUsername(loginRequest.getUsername());
                tbUser.setCid(loginRequest.getCid());
                TbUser tbUser1 =  userService.login(tbUser);
 
 
                if (tbUser1!=null){
                    if (Objects.equals(tbUser1.getYanzheng(), "5")){
                        response = new R(StatusCode.Fail);
                        response.setCode(-1);
                        response.setMsg("当前登录失败次数已达上限,请联系管理员解锁!");
                    }else{
                        String token= JwtUtils.createToken(String.valueOf(tbUser1.getUsername()),5*24*60*60*1000);//生成token返回前端
                        response = new R(StatusCode.Success);
                    tbUser1.setToken(token);
                        tbUser1.setTokentype("Bearer");
                        response.setData(tbUser1);
                    }
 
                }else{
                    response = new R(StatusCode.Fail);
                    response.setCode(-1);
                    response.setMsg("用户名密码有误,请重试");
                    TbUser tbUser2 =  userService.findPhoneUser(loginRequest.getUsername());
                    if (tbUser2!=null ){
                        Integer i=0;
                        if (Objects.equals(tbUser2.getYanzheng(), "NaN") || Objects.equals(tbUser2.getYanzheng(), "") || tbUser2.getYanzheng()==null){
                            i=1;
 
                        }else if (tbUser2.getYanzheng().equals("5")){
                            i=5;
                            response.setMsg("当前登录失败次数已达上限,请联系管理员解锁!");
                        }else{
                            i = parseInt(tbUser2.getYanzheng())+1;
                        }
                        tbUser2.setYanzheng(i.toString());
                        userService.upUserJiaYanZheng(tbUser2);
                    }
 
                }
 
            } catch (Exception e) {
                response = new R(StatusCode.Fail.getCode(), e.getMessage());
            }
            return response;
    }
 
    @GetMapping("/api/wx/checkLogin")
    public R checkLogin( String token) {
        System.out.println("收到待校验token:" + token);
        R response ;
        try {
            token = token.substring(7);
            R r=JwtUtils.checkToken(token);
            if (r.getCode()==0){
                response = new R(StatusCode.Success);
            }else{
                response = new R(StatusCode.Fail.getCode(),r.getMsg());
            }
        } catch (Exception e) {
            response = new R(StatusCode.Fail.getCode(), e.getMessage());
        }
        return response;
    }
 
    @PostMapping("/api/wx/getUserCid")
    public R getUserCid( @Valid @RequestBody WechatLoginRequestDTO loginRequest) {
//        System.out.println("收到待校验token:" + token);
        R response ;
        try {
            TbUser tbUser = new TbUser();
            tbUser.setPassword(loginRequest.getPassword());
            tbUser.setUsername(loginRequest.getUsername());
            tbUser.setCid(loginRequest.getCid());
            TbUser tbUser1 =  userService.getUserCid(tbUser);
            if (tbUser1!=null){
 
 
                if (!Objects.equals(tbUser1.getCid(), loginRequest.getCid())) {
                    response = new R(StatusCode.Fail.getCode(),"当前账号已在其他设备登录,当前设备将强制退出!");
                }else{
                    response = new R(StatusCode.Success);
                    response.setData(tbUser1);
                }
 
            }else{
                response = new R(StatusCode.Fail.getCode(),"当前账号已删除,请注册账号后重新的登录");
            }
        } catch (Exception e) {
            response = new R(StatusCode.Fail.getCode(), e.getMessage());
        }
        return response;
    }
 
 
    @GetMapping("upUserJiaYanZheng")
    public int upUserJiaYanZheng(TbUser user){
        return userService.upUserJiaYanZheng(user);
    }
 
    @GetMapping("/api/wx/sms")
    public int sms(String phone, int randomNumber) throws TencentCloudSDKException {
        try {
            System.out.println("生成的随机整数是:" + randomNumber);
            // 实例化一个认证对象,入参需要传入腾讯云账户 SecretId 和 SecretKey,此处还需注意密钥对的保密
            // 代码泄露可能会导致 SecretId 和 SecretKey 泄露,并威胁账号下所有资源的安全性。以下代码示例仅供参考,建议采用更安全的方式来使用密钥,请参见:https://cloud.tencent.com/document/product/1278/85305
            // 密钥可前往官网控制台 https://console.cloud.tencent.com/cam/capi 进行获取
            Credential cred = new Credential(SecretId, SecretKey);
            // 实例化一个http选项,可选的,没有特殊需求可以跳过
            HttpProfile httpProfile = new HttpProfile();
            httpProfile.setEndpoint("sms.tencentcloudapi.com");
            // 实例化一个client选项,可选的,没有特殊需求可以跳过
            ClientProfile clientProfile = new ClientProfile();
            clientProfile.setHttpProfile(httpProfile);
            // 实例化要请求产品的client对象,clientProfile是可选的
            SmsClient client = new SmsClient(cred, "ap-beijing", clientProfile);
            // 实例化一个请求对象,每个接口都会对应一个request对象
            SendSmsRequest req = new SendSmsRequest();
            String[] phoneNumberSet1 = {phone};
            req.setPhoneNumberSet(phoneNumberSet1);
 
            req.setSmsSdkAppId("1400838975");
            req.setSignName("北京华星北斗智控");
            req.setTemplateId("1878379");
 
            String[] templateParamSet1 = {String.valueOf(randomNumber)};
            req.setTemplateParamSet(templateParamSet1);
 
            // 返回的resp是一个SendSmsResponse的实例,与请求对象对应
            SendSmsResponse resp = client.SendSms(req);
            // 输出json格式的字符串回包
            System.out.println(SendSmsResponse.toJsonString(resp));
        } catch (TencentCloudSDKException e) {
            System.out.println(e.toString());
        }
        return randomNumber;
    }
 
}