|
@@ -1,18 +1,28 @@
|
1
|
1
|
package com.huiju.estateagents.center.taUser.controller;
|
2
|
2
|
|
|
3
|
+import com.alibaba.fastjson.JSONObject;
|
3
|
4
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
4
|
5
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
5
|
6
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
6
|
7
|
import com.huiju.estateagents.base.BaseController;
|
7
|
8
|
import com.huiju.estateagents.base.ResponseBean;
|
|
9
|
+import com.huiju.estateagents.center.sysUser.entity.SysToken;
|
|
10
|
+import com.huiju.estateagents.center.sysUser.entity.SysUser;
|
|
11
|
+import com.huiju.estateagents.center.sysUser.service.ISysTokenService;
|
8
|
12
|
import com.huiju.estateagents.center.taUser.entity.TaUser;
|
9
|
13
|
import com.huiju.estateagents.center.taUser.service.ITaUserService;
|
10
|
14
|
import com.huiju.estateagents.common.CommConstant;
|
|
15
|
+import com.huiju.estateagents.common.JWTUtils;
|
|
16
|
+import com.huiju.estateagents.common.MD5Utils;
|
|
17
|
+import com.huiju.estateagents.entity.TaPerson;
|
11
|
18
|
import org.slf4j.Logger;
|
12
|
19
|
import org.slf4j.LoggerFactory;
|
13
|
20
|
import org.springframework.beans.factory.annotation.Autowired;
|
14
|
21
|
import org.springframework.web.bind.annotation.*;
|
15
|
22
|
|
|
23
|
+import javax.servlet.http.HttpServletRequest;
|
|
24
|
+import java.time.LocalDateTime;
|
|
25
|
+import java.util.HashMap;
|
16
|
26
|
import java.util.Map;
|
17
|
27
|
|
18
|
28
|
/**
|
|
@@ -31,6 +41,9 @@ public class TaUserController extends BaseController {
|
31
|
41
|
|
32
|
42
|
@Autowired
|
33
|
43
|
public ITaUserService iTaUserService;
|
|
44
|
+
|
|
45
|
+ @Autowired
|
|
46
|
+ private ISysTokenService sysTokenService;
|
34
|
47
|
|
35
|
48
|
|
36
|
49
|
/**
|
|
@@ -125,14 +138,16 @@ public class TaUserController extends BaseController {
|
125
|
138
|
}
|
126
|
139
|
|
127
|
140
|
/**
|
128
|
|
- * 根据id查询对象
|
129
|
|
- * @param id 实体ID
|
|
141
|
+ * 获取当前用户信息
|
130
|
142
|
*/
|
131
|
|
- @RequestMapping(value="/taUser/{id}",method= RequestMethod.GET)
|
132
|
|
- public ResponseBean taUserGet(@PathVariable Integer id){
|
|
143
|
+ @RequestMapping(value="/admin/taUser/current",method= RequestMethod.GET)
|
|
144
|
+ public ResponseBean taUserGet(HttpServletRequest request){
|
133
|
145
|
ResponseBean responseBean = new ResponseBean();
|
|
146
|
+ String userId = JWTUtils.getSubject(request);
|
134
|
147
|
try {
|
135
|
|
- responseBean.addSuccess(iTaUserService.getById(id));
|
|
148
|
+ TaUser taUser = iTaUserService.getById(userId);
|
|
149
|
+ taUser.setLoginPassword("");
|
|
150
|
+ responseBean.addSuccess(taUser);
|
136
|
151
|
}catch (Exception e){
|
137
|
152
|
e.printStackTrace();
|
138
|
153
|
logger.error("taUserDelete -=- {}",e.toString());
|
|
@@ -140,4 +155,52 @@ public class TaUserController extends BaseController {
|
140
|
155
|
}
|
141
|
156
|
return responseBean;
|
142
|
157
|
}
|
|
158
|
+
|
|
159
|
+ /**
|
|
160
|
+ * 用户手机号登录
|
|
161
|
+ * @param paramStr
|
|
162
|
+ * @return
|
|
163
|
+ */
|
|
164
|
+ @PostMapping("/admin/taUser/signin")
|
|
165
|
+ public ResponseBean signin(@RequestBody String paramStr) {
|
|
166
|
+ JSONObject params = JSONObject.parseObject(paramStr);
|
|
167
|
+ if (params == null) {
|
|
168
|
+ return ResponseBean.error("非法参数", ResponseBean.ERROR_MISSING_PARAMS);
|
|
169
|
+ }
|
|
170
|
+
|
|
171
|
+ String userName = params.getString("loginName");
|
|
172
|
+ String userPassword = params.getString("loginPassword");
|
|
173
|
+
|
|
174
|
+ //验证用户名密码是否正确
|
|
175
|
+ QueryWrapper<TaUser> sysUserQueryWrapper = new QueryWrapper<>();
|
|
176
|
+ sysUserQueryWrapper.eq("login_name",userName);
|
|
177
|
+ sysUserQueryWrapper.eq("login_password", MD5Utils.md5(userPassword));
|
|
178
|
+ TaUser taUser = iTaUserService.getOne(sysUserQueryWrapper);
|
|
179
|
+ if (taUser == null) {
|
|
180
|
+ return ResponseBean.error("用户名或密码错误", ResponseBean.ERROR_ILLEGAL_PARAMS);
|
|
181
|
+ }
|
|
182
|
+
|
|
183
|
+ if (taUser.getStatus() != CommConstant.STATUS_NORMAL) {
|
|
184
|
+ return ResponseBean.error("用户状态异常", ResponseBean.ERROR_UNAVAILABLE);
|
|
185
|
+ }
|
|
186
|
+ taUser.setLoginPassword("");
|
|
187
|
+ String token = JWTUtils.newToken(taUser.getUserId().toString());
|
|
188
|
+
|
|
189
|
+ //保存token
|
|
190
|
+ saveToken(token);
|
|
191
|
+
|
|
192
|
+ Map<String, Object> result = new HashMap<>();
|
|
193
|
+ result.put("token", token);
|
|
194
|
+ result.put("user", taUser);
|
|
195
|
+
|
|
196
|
+ return ResponseBean.success(result);
|
|
197
|
+ }
|
|
198
|
+
|
|
199
|
+
|
|
200
|
+ private void saveToken(String token) {
|
|
201
|
+ SysToken sysToken = new SysToken();
|
|
202
|
+ sysToken.setToken(token);
|
|
203
|
+ sysToken.setExpDate(LocalDateTime.now());
|
|
204
|
+ sysTokenService.save(sysToken);
|
|
205
|
+ }
|
143
|
206
|
}
|