修改用户信息时同步到Redis中

src/main/java/com/archser/aserver/controller/UserController.java

 package com.archser.aserver.controller;
 
+import java.sql.SQLException;
 import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.Iterator;
 import java.util.List;
+import java.util.Map;
+import java.util.Map.Entry;
+
 import javax.inject.Inject;
 import com.archser.aserver.model.User;
 import com.archser.aserver.service.UserService;
@@ -11,6 +17,7 @@ import com.jfinal.kit.Kv;
 import com.jfinal.kit.Ret;
 import com.jfinal.plugin.activerecord.Db;
 import com.jfinal.plugin.activerecord.Record;
+import com.jfinal.plugin.redis.Redis;
 
 /**
  * 用户相关操作
@@ -34,8 +41,8 @@ public class UserController extends Controller {
   
   /**
    * 修改用户密码
+ * @throws SQLException 
    */
-  @SuppressWarnings("unused")
   public void updatePwd()   {
       String username = this.getAttr("username");
       String password = this.getPara("newPwd");
@@ -43,6 +50,12 @@ public class UserController extends Controller {
       int flag = Db.update(Db.getSql("updatePassword"), password, username);
       if (flag == 0) {
           this.renderJson(Ret.fail("msg","修改失败"));
+          return ;
+      }
+      try {
+    	  Redis.use().hset(username+ "_INFO", "password", password);
+      }catch (Exception e) {
+    	  e.printStackTrace();
 	}
       this.renderJson(Ret.ok("msg","修改成功"));
   }
@@ -58,6 +71,7 @@ public class UserController extends Controller {
 		}
 		boolean flag = user.update();
 		if (flag) {
+			updateUserForRedis(user);
 			renderJson(Ret.ok("msg", "数据修改成功！"));
 			return;
 		} else {
@@ -66,9 +80,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() {
       String username = this.getAttr("username");
       User user = User.dao.template("getUser", username).findFirst();

src/main/resources/config-pro.properties

 
 dbType=DM
-jdbcUrl=jdbc:dm://192.168.31.18:5236
+jdbcUrl=jdbc:dm://39.104.90.66:5236
 jdbc.driver=dm.jdbc.driver.DmDriver
 user=archser
 password=archser_123
-basic.url=http://192.168.31.18:11028
+basic.url=http://39.104.90.66:11028
 
 devMode =true
 engineDevMode=true
 
 
-redis.url=192.168.31.18
+redis.url=39.104.90.66
 redis.password=archser_redis
 
 # --- 消息中心websocket配置 ---
@@ -23,4 +23,4 @@ messageWsTimeout=30000
 ## 是否开启消息中心的websocket
 openMessageWebSocket=true
 
-MyIpAddress=127.0.0.1,192.168.31.18
+MyIpAddress=127.0.0.1,39.104.90.66

src/main/resources/config.properties

-# ---\u5F00\u53D1\u73AF\u5883\u914D\u7F6E\u6587\u4EF6---
 
 #database config
 dbType=DM  
-#jdbcUrl=jdbc:oracle:thin:@db.archser.com:1521:ychy
-#jdbc.driver=oracle.jdbc.driver.OracleDriver
-#user = archser_yz_test
-#password =archser_yz_test
-
-jdbcUrl=jdbc:dm://192.168.31.119:5236
+jdbcUrl=jdbc:dm://39.104.28.145:5236
 jdbc.driver=dm.jdbc.driver.DmDriver
 user=archser
 password=archser_123
-basic.url=http://192.168.31.119:11028
+basic.url=http://39.104.28.145:11028
 
 devMode =true
 engineDevMode=true
 
-redis.url=192.168.31.18
+redis.url=39.104.28.145
 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
-##  \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
-## \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
-## \u662F\u5426\u5F00\u542F\u6D88\u606F\u4E2D\u5FC3\u7684websocket
 ## 是否开启消息中心的websocket
 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