Commit b3f67c6b authored by 陈勇's avatar 陈勇

Merge branch 'updateRedisUser' into 'master'

修改用户信息时同步到Redis中 See merge request common/aserver!14
parents 04dba454 ebdc4af3
package com.archser.aserver.controller; package com.archser.aserver.controller;
import java.sql.SQLException;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List; import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
import javax.inject.Inject; import javax.inject.Inject;
import com.archser.aserver.model.User; import com.archser.aserver.model.User;
import com.archser.aserver.service.UserService; import com.archser.aserver.service.UserService;
...@@ -11,6 +17,7 @@ import com.jfinal.kit.Kv; ...@@ -11,6 +17,7 @@ import com.jfinal.kit.Kv;
import com.jfinal.kit.Ret; import com.jfinal.kit.Ret;
import com.jfinal.plugin.activerecord.Db; import com.jfinal.plugin.activerecord.Db;
import com.jfinal.plugin.activerecord.Record; import com.jfinal.plugin.activerecord.Record;
import com.jfinal.plugin.redis.Redis;
/** /**
* 用户相关操作 * 用户相关操作
...@@ -22,6 +29,9 @@ public class UserController extends Controller { ...@@ -22,6 +29,9 @@ public class UserController extends Controller {
@Inject @Inject
UserService userService; UserService userService;
private static final String _INFO = "_INFO";
/** /**
* 获取用户信息 * 获取用户信息
*/ */
...@@ -34,8 +44,8 @@ public class UserController extends Controller { ...@@ -34,8 +44,8 @@ public class UserController extends Controller {
/** /**
* 修改用户密码 * 修改用户密码
* @throws SQLException
*/ */
@SuppressWarnings("unused")
public void updatePwd() { public void updatePwd() {
String username = this.getAttr("username"); String username = this.getAttr("username");
String password = this.getPara("newPwd"); String password = this.getPara("newPwd");
...@@ -43,6 +53,12 @@ public class UserController extends Controller { ...@@ -43,6 +53,12 @@ public class UserController extends Controller {
int flag = Db.update(Db.getSql("updatePassword"), password, username); int flag = Db.update(Db.getSql("updatePassword"), password, username);
if (flag == 0) { if (flag == 0) {
this.renderJson(Ret.fail("msg","修改失败")); this.renderJson(Ret.fail("msg","修改失败"));
return ;
}
try {
Redis.use().hset(username+ _INFO, "password", password);
}catch (Exception e) {
e.printStackTrace();
} }
this.renderJson(Ret.ok("msg","修改成功")); this.renderJson(Ret.ok("msg","修改成功"));
} }
...@@ -58,6 +74,7 @@ public class UserController extends Controller { ...@@ -58,6 +74,7 @@ public class UserController extends Controller {
} }
boolean flag = user.update(); boolean flag = user.update();
if (flag) { if (flag) {
updateUserForRedis(user);
renderJson(Ret.ok("msg", "数据修改成功!")); renderJson(Ret.ok("msg", "数据修改成功!"));
return; return;
} else { } else {
...@@ -66,9 +83,32 @@ public class UserController extends Controller { ...@@ -66,9 +83,32 @@ public class UserController extends Controller {
} }
/** /**
* 修改Redis中的用户信息
*@Time:2020年7月10日 - 上午8:48:48
* @author:李德才
* @param: @param user
* @return: void
* @throws
*/
public void updateUserForRedis(User user) {
try {
Iterator<Entry<String, Object>> userIterator = user._getAttrsEntrySet().iterator();
Map<Object, Object> userMap = new HashMap<>();
Entry<String, Object> userAttr = null;
while (userIterator.hasNext()) {
userAttr = userIterator.next();
userMap.put(userAttr.getKey().toString().trim().toLowerCase(), userAttr.getValue());
}
Redis.use().hmset(user.getUsername() + _INFO, userMap);
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 查询角色 * 查询角色
*/ */
@SuppressWarnings("unused")
public void getRoleData() { public void getRoleData() {
String username = this.getAttr("username"); String username = this.getAttr("username");
User user = User.dao.template("getUser", username).findFirst(); User user = User.dao.template("getUser", username).findFirst();
......
dbType=DM dbType=DM
jdbcUrl=jdbc:dm://192.168.31.18:5236 jdbcUrl=jdbc:dm://39.104.90.66:5236
jdbc.driver=dm.jdbc.driver.DmDriver jdbc.driver=dm.jdbc.driver.DmDriver
user=archser user=archser
password=archser_123 password=archser_123
basic.url=http://192.168.31.18:11028 basic.url=http://39.104.90.66:11028
devMode =true devMode =true
engineDevMode=true engineDevMode=true
redis.url=192.168.31.18 redis.url=39.104.90.66
redis.password=archser_redis redis.password=archser_redis
# --- 消息中心websocket配置 --- # --- 消息中心websocket配置 ---
...@@ -23,4 +23,4 @@ messageWsTimeout=30000 ...@@ -23,4 +23,4 @@ messageWsTimeout=30000
## 是否开启消息中心的websocket ## 是否开启消息中心的websocket
openMessageWebSocket=true openMessageWebSocket=true
MyIpAddress=127.0.0.1,192.168.31.18 MyIpAddress=127.0.0.1,39.104.90.66
# ---\u5F00\u53D1\u73AF\u5883\u914D\u7F6E\u6587\u4EF6---
#database config #database config
dbType=DM dbType=DM
#jdbcUrl=jdbc:oracle:thin:@db.archser.com:1521:ychy jdbcUrl=jdbc:dm://39.104.28.145:5236
#jdbc.driver=oracle.jdbc.driver.OracleDriver
#user = archser_yz_test
#password =archser_yz_test
jdbcUrl=jdbc:dm://192.168.31.119:5236
jdbc.driver=dm.jdbc.driver.DmDriver jdbc.driver=dm.jdbc.driver.DmDriver
user=archser user=archser
password=archser_123 password=archser_123
basic.url=http://192.168.31.119:11028 basic.url=http://39.104.28.145:11028
devMode =true devMode =true
engineDevMode=true engineDevMode=true
redis.url=192.168.31.18 redis.url=39.104.28.145
redis.password=archser_redis redis.password=archser_redis
# --- \u6D88\u606F\u4E2D\u5FC3websocket\u914D\u7F6E ---
## \u5B9A\u65F6\u53D1\u9001\u6D88\u606F\u7684\u5468\u671F \u5355\u4F4D\u6BEB\u79D2
messageWsDelay=50000 messageWsDelay=50000
## \u5EF6\u671F\uFF0C\u7B2C\u4E8C\u6B21\u53D1\u9001\u6D88\u606F\u7684\u5EF6\u671F\u65F6\u95F4\uFF0C\u7B2C\u4E00\u6B21\u53D1\u9001\u5728\u5F00\u59CB\u8FDE\u63A5\u65F6\u5C31\u4F1A\u53D1\u9001 \u5355\u4F4D\u6BEB\u79D2
messageWsPeriod=50000 messageWsPeriod=50000
## \u6D88\u606F\u53D1\u9001\u6210\u529F\u540E\uFF0C\u7B49\u5F85\u5BA2\u6237\u7AEF\u53CD\u9988\u65F6\u95F4\uFF0C\u8D85\u51FA\u6B64\u65F6\u95F4\u8868\u793A\u8FDE\u63A5\u5DF2\u7ECF\u65AD\u5F00\uFF0C\u4F1A\u5173\u95ED\u8FDE\u63A5 \u5355\u4F4D\u6BEB\u79D2
messageWsTimeout=30000 messageWsTimeout=30000
## \u662F\u5426\u5F00\u542F\u6D88\u606F\u4E2D\u5FC3\u7684websocket
## 是否开启消息中心的websocket ## 是否开启消息中心的websocket
openMessageWebSocket=true openMessageWebSocket=true
MyIpAddress=127.0.0.1,192.168.31.192,192.168.31.119 MyIpAddress=127.0.0.1,192.168.31.192,39.104.28.145
# -------############------------------
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment