From 9b7c85ff184840e8a9d6329384a01c2f9aca8a5d Mon Sep 17 00:00:00 2001
From: alwaysfrin <39822157+alwaysfrin@users.noreply.github.com>
Date: Fri, 28 Dec 2018 20:00:51 +0800
Subject: [PATCH] =?UTF-8?q?redis=E4=BC=9A=E8=AF=9D=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../controller/DemoRedisMqController.java          | 39 ++++++++++++++++++++++
 1 file changed, 39 insertions(+)

diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/controller/DemoRedisMqController.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/controller/DemoRedisMqController.java
index 66c918e..2001c43 100644
--- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/controller/DemoRedisMqController.java
+++ b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/controller/DemoRedisMqController.java
@@ -2,8 +2,11 @@ package cn.estsh.i3plus.core.apiservice.controller;
 
 import cn.estsh.i3plus.core.apiservice.mq.I3CoreQueueConfig;
 import cn.estsh.i3plus.platform.common.util.PlatformConstWords;
+import cn.estsh.i3plus.pojo.base.common.Pager;
 import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil;
+import cn.estsh.i3plus.pojo.platform.bean.SessionUser;
 import cn.estsh.impp.framework.base.controller.CoreBaseController;
+import cn.estsh.impp.framework.boot.auth.AuthUtil;
 import cn.estsh.impp.framework.boot.util.ResultBean;
 import cn.estsh.i3plus.pojo.mes.MachineFactory;
 import cn.estsh.impp.framework.boot.exception.ImppExceptionBuilder;
@@ -233,4 +236,40 @@ public class DemoRedisMqController extends CoreBaseController{
 
         return new ResultBean(true,"操作成功 ： " + locale.getLanguage() + "  " + locale.getCountry());
     }
+
+    @Resource(name="redisSession")
+    private ImppRedis redisSession;
+
+    @GetMapping(value="/set-redis")
+    @ApiOperation(value="setredis")
+    public ResultBean setRedis(String key,String value) {
+        //redisSession.putObject(key,value);
+        //redisCore.putObject(key,value);
+
+
+        ResultBean rs = new ResultBean(true,"yes");
+        rs.setPager(new Pager(100));
+        redisSession.putObject("rs",rs);
+        redisCore.putObject("rs",rs);
+
+        return new ResultBean(true,"操作成功 ： " + key + " : " + value);
+    }
+
+    @GetMapping(value="/get-redis")
+    @ApiOperation(value="getredis")
+    public ResultBean getRedis(String key) {
+        Object  d1 = redisSession.getObject(key);
+        System.out.println("redisSession-d1==" + d1);
+        Object d2 = redisCore.getObject(key);
+
+        if(d1 != null) {
+            SessionUser sessionUser = AuthUtil.getSessionUser();
+            System.out.println(sessionUser.toString());
+        }
+
+        System.out.println("redisCore-d2==" + d2);
+        System.out.println(d1 == null?"null":d1.toString());
+        System.out.println(d2 == null?"null":d2.toString());
+        return new ResultBean(true,"操作成功 ： " + d1 + " : " + d2);
+    }
 }