I3_YF_SEAT
/
impp-core
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

完善代码

Browse Source
yun-zuoyi
nies 3 years ago
parent 3f8a2e1233
commit ac474431e5
3 changed files with 290 additions and 289 deletions
Show Stats Download Patch File Download Diff File

568
modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/controller/base/RedisInfoController.java
Unescape Escape View File

@ -1,284 +1,284 @@
package cn.estsh.i3plus.core.apiservice.controller.base;
import cn.estsh.i3plus.platform.common.util.CommonConstWords;
import cn.estsh.i3plus.platform.common.util.PlatformConstWords;
import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil;
import cn.estsh.impp.framework.boot.auth.AuthUtil;
import cn.estsh.impp.framework.boot.exception.ImppExceptionBuilder;
import cn.estsh.impp.framework.boot.util.ImppRedis;
import cn.estsh.impp.framework.boot.util.ResultBean;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.apache.logging.log4j.util.Strings;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
import java.io.UnsupportedEncodingException;
import java.net.URLDecoder;
import java.util.*;
/**
* @Description :获取Redis信息展示，类似RDM
* @Reference :
* @Author : Castle
* @CreateDate : 2022/2/24 9:55
* @Modify:
**/
@Slf4j
@Api(tags = "redis信息")
@RestController
@RequestMapping(PlatformConstWords.BASE_URL + "/redis")
public class RedisInfoController {
/**
* redis db0 resource
*/
@Resource(name = CommonConstWords.IMPP_REDIS_RES)
private ImppRedis redisRes;
/**
* redis db1 sessionDb
*
* @return
*/
@Resource(name = CommonConstWords.IMPP_REDIS_SESSION)
private ImppRedis redisSession;
/**
* redis db2 coreDb
*/
@Resource(name = CommonConstWords.IMPP_REDIS_CORE)
private ImppRedis redisCore;
/**
* redis db3 redisWms
*/
@Resource(name = CommonConstWords.IMPP_REDIS_WMS)
private ImppRedis redisWms;
/**
* redis db4 redisMes
*/
@Resource(name = CommonConstWords.IMPP_REDIS_MES)
private ImppRedis redisMes;
/**
* redis db5 redisMesPcn
*/
@Resource(name = CommonConstWords.IMPP_REDIS_MES_PCN)
private ImppRedis redisMesPcn;
/**
* redis db6 redisMes
*/
@Resource(name = CommonConstWords.IMPP_REDIS_SWEB)
private ImppRedis redisSweb;
/**
* redis db7 redisAndon
*/
@Resource(name = CommonConstWords.IMPP_REDIS_ANDON)
private ImppRedis redisAndon;
/**
* redis db8 lacDb
*/
@Resource(name = CommonConstWords.IMPP_REDIS_LAC)
private ImppRedis redisLac;
/**
* redis db9 blockDb;
*/
@Resource(name = CommonConstWords.IMPP_REDIS_BLOCK)
private ImppRedis redisBlock;
/**
* redis db10 ptl
*/
@Resource(name = CommonConstWords.IMPP_REDIS_PTL)
private ImppRedis redisPtl;
/**
* redis db11 ptl_pcn
*/
@Resource(name = CommonConstWords.IMPP_REDIS_PTL_PCN)
private ImppRedis redisPtlPcn;
/**
* redis db12 mdm
*/
@Resource(name = CommonConstWords.IMPP_REDIS_MDM)
private ImppRedis redisMdm;
/**
* redis db13 eam
*/
@Resource(name = CommonConstWords.IMPP_REDIS_EAM)
private ImppRedis redisEam;
/**
* redis db15 qms
*/
@Resource(name = CommonConstWords.IMPP_REDIS_QMS)
private ImppRedis redisQms;
@ApiOperation(value = "获取redis的keyspace信息", notes = "获取redis的keyspace信息")
@GetMapping("/info")
public ResultBean getInfo() {
Map<String, Integer> keys = new HashMap<>(16);
//获取所有的数据库信息
Properties infos = redisRes.getRedisConnectionInfo("keyspace");
//分解infos信息
for (int i = 0; i < 16; i++) {
// info信息db0=keys=19510,expires=0,avg_ttl=0,
String key = "db" + i;
String info = infos.getProperty(key);
if (Strings.isNotBlank(info)) {
JSONObject infoJson = JSON.parseObject(("{" + info + "}").replaceAll("=", ":"));
keys.put(key, Integer.parseInt(infoJson.get("keys").toString()));
} else {
keys.put(key, 0);
}
}
return ResultBean.success("查询成功").setResultMap(keys);
}
@ApiOperation(value = "获取指定数据库的所有keys", notes = "获取指定数据库的所有keys")
@GetMapping("/db/{id}")
public ResultBean getDbKeys(@PathVariable("id") Integer id) {
//根据id获取所有的key
ImppRedis redis = getRedis(id);
Set<String> keySet = redis.findKeySet("*");
return ResultBean.success("查询成功").setResultList(new ArrayList<>(keySet));
}
@ApiOperation(value = "根据key获取redis对应的值", notes = "根据key获取redis对应的值")
@GetMapping("/get/{id}/{key}")
public ResultBean getValue(@PathVariable("id") Integer id, @PathVariable("key") String key) {
ImppRedis redis = getRedis(id);
try {
key = URLDecoder.decode(key, "UTF-8");
} catch (UnsupportedEncodingException e) {
throw ImppExceptionBuilder.newInstance().setErrorDetail("redisDb:{},key:{}解码失败", id, key).build();
}
String keyType = redis.getKeyType(key).toLowerCase();
Object result;
switch (keyType) {
case "string":
result = redis.getObject(key);
break;
case "hash":
result = redis.getHashMap(key);
break;
case "list":
result = redis.getList(key, 0, -1);
break;
case "set":
result = redis.getSet(key);
break;
case "zset":
result = null;
break;
default:
throw ImppExceptionBuilder.newInstance().setErrorDetail("无效的key类型,请检查传入的key").build();
}
return ResultBean.success("查询成功").setResultObject(result);
}
@ApiOperation(value = "删除对应key的值", notes = "删除对应key的值")
@DeleteMapping("/del/{id}/{key}")
public ResultBean deleteKey(@PathVariable("id") Integer id, @PathVariable("key") String key) {
ImppRedis redis = getRedis(id);
try {
key = URLDecoder.decode(key, "UTF-8");
} catch (UnsupportedEncodingException e) {
throw ImppExceptionBuilder.newInstance().setErrorDetail("redisDb:{},key:{}解码失败", id, key).build();
}
String keyType = redis.getKeyType(key).toLowerCase();
switch (keyType) {
case "string":
redis.deleteKey(key);
break;
case "hash":
redis.deleteHash(key);
break;
case "list":
redis.removeList(key,0,null);
break;
default:
throw ImppExceptionBuilder.newInstance().setErrorDetail("暂不支持的key类型").build();
}
log.info("sysUser:{}, delete key:{}", AuthUtil.getSessionUser().getUserName(), key);
return ResultBean.success("删除成功");
}
/**
* 根据DB选取不同的redis链接实例
*
* @param indexDb
* @return
*/
private ImppRedis getRedis(Integer indexDb) {
ImppRedis redis;
switch (indexDb) {
case 0:
redis = redisRes;
break;
case 1:
redis = redisSession;
break;
case 2:
redis = redisCore;
break;
case 3:
redis = redisWms;
break;
case 4:
redis = redisMes;
break;
case 5:
redis = redisMesPcn;
break;
case 6:
redis = redisSweb;
break;
case 7:
redis = redisAndon;
break;
case 8:
redis = redisLac;
break;
case 9:
redis = redisBlock;
break;
case 10:
redis = redisPtl;
break;
case 11:
redis = redisPtlPcn;
break;
case 12:
redis = redisMdm;
break;
case 13:
redis = redisEam;
break;
case 15:
redis = redisQms;
break;
default:
redis = redisRes;
}
return redis;
}
}
//package cn.estsh.i3plus.core.apiservice.controller.base;
//
//import cn.estsh.i3plus.platform.common.util.CommonConstWords;
//import cn.estsh.i3plus.platform.common.util.PlatformConstWords;
//import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil;
//import cn.estsh.impp.framework.boot.auth.AuthUtil;
//import cn.estsh.impp.framework.boot.exception.ImppExceptionBuilder;
//import cn.estsh.impp.framework.boot.util.ImppRedis;
//import cn.estsh.impp.framework.boot.util.ResultBean;
//import com.alibaba.fastjson.JSON;
//import com.alibaba.fastjson.JSONObject;
//import io.swagger.annotations.Api;
//import io.swagger.annotations.ApiOperation;
//import lombok.extern.slf4j.Slf4j;
//import org.apache.logging.log4j.util.Strings;
//import org.springframework.web.bind.annotation.*;
//
//import javax.annotation.Resource;
//import java.io.UnsupportedEncodingException;
//import java.net.URLDecoder;
//import java.util.*;
//
///**
// * @Description :获取Redis信息展示，类似RDM
// * @Reference :
// * @Author : Castle
// * @CreateDate : 2022/2/24 9:55
// * @Modify:
// **/
//@Slf4j
//@Api(tags = "redis信息")
//@RestController
//@RequestMapping(PlatformConstWords.BASE_URL + "/redis")
//public class RedisInfoController {
// /**
// * redis db0 resource
// */
// @Resource(name = CommonConstWords.IMPP_REDIS_RES)
// private ImppRedis redisRes;
//
// /**
// * redis db1 sessionDb
// *
// * @return
// */
// @Resource(name = CommonConstWords.IMPP_REDIS_SESSION)
// private ImppRedis redisSession;
//
//
// /**
// * redis db2 coreDb
// */
// @Resource(name = CommonConstWords.IMPP_REDIS_CORE)
// private ImppRedis redisCore;
//
// /**
// * redis db3 redisWms
// */
// @Resource(name = CommonConstWords.IMPP_REDIS_WMS)
// private ImppRedis redisWms;
//
// /**
// * redis db4 redisMes
// */
// @Resource(name = CommonConstWords.IMPP_REDIS_MES)
// private ImppRedis redisMes;
// /**
// * redis db5 redisMesPcn
// */
// @Resource(name = CommonConstWords.IMPP_REDIS_MES_PCN)
// private ImppRedis redisMesPcn;
//
// /**
// * redis db6 redisMes
// */
// @Resource(name = CommonConstWords.IMPP_REDIS_SWEB)
// private ImppRedis redisSweb;
//
// /**
// * redis db7 redisAndon
// */
// @Resource(name = CommonConstWords.IMPP_REDIS_ANDON)
// private ImppRedis redisAndon;
//
// /**
// * redis db8 lacDb
// */
//
// @Resource(name = CommonConstWords.IMPP_REDIS_LAC)
// private ImppRedis redisLac;
//
// /**
// * redis db9 blockDb;
// */
//
// @Resource(name = CommonConstWords.IMPP_REDIS_BLOCK)
// private ImppRedis redisBlock;
//
// /**
// * redis db10 ptl
// */
//
// @Resource(name = CommonConstWords.IMPP_REDIS_PTL)
// private ImppRedis redisPtl;
//
// /**
// * redis db11 ptl_pcn
// */
//
// @Resource(name = CommonConstWords.IMPP_REDIS_PTL_PCN)
// private ImppRedis redisPtlPcn;
//
// /**
// * redis db12 mdm
// */
//
// @Resource(name = CommonConstWords.IMPP_REDIS_MDM)
// private ImppRedis redisMdm;
// /**
// * redis db13 eam
// */
//
// @Resource(name = CommonConstWords.IMPP_REDIS_EAM)
// private ImppRedis redisEam;
//
// /**
// * redis db15 qms
// */
//
// @Resource(name = CommonConstWords.IMPP_REDIS_QMS)
// private ImppRedis redisQms;
//
//
// @ApiOperation(value = "获取redis的keyspace信息", notes = "获取redis的keyspace信息")
// @GetMapping("/info")
// public ResultBean getInfo() {
// Map<String, Integer> keys = new HashMap<>(16);
// //获取所有的数据库信息
// Properties infos = redisRes.getRedisConnectionInfo("keyspace");
// //分解infos信息
// for (int i = 0; i < 16; i++) {
// // info信息db0=keys=19510,expires=0,avg_ttl=0,
// String key = "db" + i;
// String info = infos.getProperty(key);
// if (Strings.isNotBlank(info)) {
// JSONObject infoJson = JSON.parseObject(("{" + info + "}").replaceAll("=", ":"));
// keys.put(key, Integer.parseInt(infoJson.get("keys").toString()));
// } else {
// keys.put(key, 0);
// }
// }
// return ResultBean.success("查询成功").setResultMap(keys);
// }
//
// @ApiOperation(value = "获取指定数据库的所有keys", notes = "获取指定数据库的所有keys")
// @GetMapping("/db/{id}")
// public ResultBean getDbKeys(@PathVariable("id") Integer id) {
// //根据id获取所有的key
// ImppRedis redis = getRedis(id);
// Set<String> keySet = redis.findKeySet("*");
// return ResultBean.success("查询成功").setResultList(new ArrayList<>(keySet));
// }
//
// @ApiOperation(value = "根据key获取redis对应的值", notes = "根据key获取redis对应的值")
// @GetMapping("/get/{id}/{key}")
// public ResultBean getValue(@PathVariable("id") Integer id, @PathVariable("key") String key) {
// ImppRedis redis = getRedis(id);
// try {
// key = URLDecoder.decode(key, "UTF-8");
// } catch (UnsupportedEncodingException e) {
// throw ImppExceptionBuilder.newInstance().setErrorDetail("redisDb:{},key:{}解码失败", id, key).build();
// }
// String keyType = redis.getKeyType(key).toLowerCase();
// Object result;
// switch (keyType) {
// case "string":
// result = redis.getObject(key);
// break;
// case "hash":
// result = redis.getHashMap(key);
// break;
// case "list":
// result = redis.getList(key, 0, -1);
// break;
// case "set":
// result = redis.getSet(key);
// break;
// case "zset":
// result = null;
// break;
// default:
// throw ImppExceptionBuilder.newInstance().setErrorDetail("无效的key类型,请检查传入的key").build();
// }
// return ResultBean.success("查询成功").setResultObject(result);
// }
//
// @ApiOperation(value = "删除对应key的值", notes = "删除对应key的值")
// @DeleteMapping("/del/{id}/{key}")
// public ResultBean deleteKey(@PathVariable("id") Integer id, @PathVariable("key") String key) {
// ImppRedis redis = getRedis(id);
// try {
// key = URLDecoder.decode(key, "UTF-8");
// } catch (UnsupportedEncodingException e) {
// throw ImppExceptionBuilder.newInstance().setErrorDetail("redisDb:{},key:{}解码失败", id, key).build();
// }
// String keyType = redis.getKeyType(key).toLowerCase();
// switch (keyType) {
// case "string":
// redis.deleteKey(key);
// break;
// case "hash":
// redis.deleteHash(key);
// break;
// case "list":
// redis.removeList(key,0,null);
// break;
// default:
// throw ImppExceptionBuilder.newInstance().setErrorDetail("暂不支持的key类型").build();
// }
//
// log.info("sysUser:{}, delete key:{}", AuthUtil.getSessionUser().getUserName(), key);
// return ResultBean.success("删除成功");
// }
//
// /**
// * 根据DB选取不同的redis链接实例
// *
// * @param indexDb
// * @return
// */
// private ImppRedis getRedis(Integer indexDb) {
// ImppRedis redis;
// switch (indexDb) {
// case 0:
// redis = redisRes;
// break;
// case 1:
// redis = redisSession;
// break;
// case 2:
// redis = redisCore;
// break;
// case 3:
// redis = redisWms;
// break;
// case 4:
// redis = redisMes;
// break;
// case 5:
// redis = redisMesPcn;
// break;
// case 6:
// redis = redisSweb;
// break;
// case 7:
// redis = redisAndon;
// break;
// case 8:
// redis = redisLac;
// break;
// case 9:
// redis = redisBlock;
// break;
// case 10:
// redis = redisPtl;
// break;
// case 11:
// redis = redisPtlPcn;
// break;
// case 12:
// redis = redisMdm;
// break;
// case 13:
// redis = redisEam;
// break;
// case 15:
// redis = redisQms;
// break;
// default:
// redis = redisRes;
// }
// return redis;
// }
//}

1
modules/i3plus-core-apiservice/src/main/resources/application.properties
Unescape Escape View File

@ -70,3 +70,4 @@ redis.resource.db=0
redis.session.db=1
#\u7CFB\u7EDF\u5168\u5C40\u7F13\u5B58\u5E93\uFF0C\u5B58\u653E\u5E73\u53F0\u6838\u5FC3\u6570\u636E\u7F13\u5B58
redis.core.db=2
wms.redis.open=true

10
pom.xml
Unescape Escape View File

@ -38,7 +38,7 @@
<app.charset>UTF-8</app.charset>
<app.jdk.version>1.8</app.jdk.version>
<project.dependency.version>1.0-TEST-SNAPSHOT</project.dependency.version>
<log4j2.version>2.17.0</log4j2.version>
<log4j2.version>2.17.1</log4j2.version>
</properties>
<dependencies>
@ -251,22 +251,22 @@
<dependency>
<groupId>org.apache.shiro</groupId>
<artifactId>shiro-core</artifactId>
<version>1.4.0</version>
<version>1.8.0</version>
</dependency>
<dependency>
<groupId>org.apache.shiro</groupId>
<artifactId>shiro-web</artifactId>
<version>1.4.0</version>
<version>1.8.0</version>
</dependency>
<dependency>
<groupId>org.apache.shiro</groupId>
<artifactId>shiro-spring</artifactId>
<version>1.4.0</version>
<version>1.8.0</version>
</dependency>
<dependency>
<groupId>org.apache.shiro</groupId>
<artifactId>shiro-ehcache</artifactId>
<version>1.4.0</version>
<version>1.8.0</version>
</dependency>
<!-- json -->

Write Preview
Loading…
Cancel
Save