Commit af72b4e9 by dupengfei

字典管理功能迁移

parent 87bcc3c8
......@@ -86,6 +86,14 @@
<artifactId>ojdbc6</artifactId>
<version>10</version>
</dependency>
<dependency>
<groupId>net.sf.json-lib</groupId>
<artifactId>json-lib</artifactId>
<version>2.4</version>
<classifier>jdk15</classifier>
</dependency>
<!-- velocity 模板引擎, Mybatis Plus 代码生成器需要 -->
<dependency>
<groupId>org.apache.velocity</groupId>
......
package com.founder.zdgl.controller;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.founder.zdgl.entity.SysDictitem;
import com.founder.zdgl.entity.XzxtRestResult;
import com.founder.zdgl.entity.ZTreeNode;
import com.founder.zdgl.service.RedisRefreshService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import javax.servlet.http.HttpServletRequest;
import java.io.*;
import java.util.*;
/*
* @Description TODO
* @Author du_pengfei
* @Date 2021/7/9
* @Version 1.0
*/
@RestController
public class RedisRefreshController {
@Autowired
RedisRefreshService redisRefreshService;
@RequestMapping(value = "/UpdateRedisRest",method = {RequestMethod.POST,RequestMethod.GET})
@ResponseBody
public XzxtRestResult UpdateRedisRestNM(String type) {
//存储redis
String ssdw = "01";
XzxtRestResult result=new XzxtRestResult();
SysDictitem dictitem = new SysDictitem();
//先删除指定key缓存
String keys="";
if(null!=type && "null"!=type){
keys=ssdw+":"+type+"*";
}else{
keys=ssdw+"*";
}
result =redisRefreshService.keysRedisRest(keys);
Set<String> dictitemKeys= (Set<String>) result.getData();
/* String AllKey="";
//删除对应的数据源
if(null!=dictitemKeys){
for (String key : dictitemKeys) {
AllKey+=key+"__";
redisService.DelRedisRest(key);
}
System.out.print("匹配出的AllKey========================="+AllKey);
}*/
dictitemKeys.forEach(p -> {
redisRefreshService.DelRedisRest(p);
});
//存储所有字典------------------------------------------------------
//shiro 单位字典特殊处理
if (null!=type && type.equals("SHIR_UNIT")) {
dictitem.setGroupid("CODE_UNIT");
dictitem.setCode(ssdw + "%");
JSONArray unit = redisRefreshService.selectDictitemByCondition(dictitem);
result = redisRefreshService.SaveRedisRest(ssdw+"_SHIRO_UNIT", unit.toString());
} else {
//传统项目字典特殊处理
if(null!=type && "null"!=type) {
dictitem.setGroupid(type);
}
//List<SysDictitem> SysDictitemList = dictItemService.findCodeAllByType(dictitem);
List<SysDictitem> SysDictitemList = redisRefreshService.findCodeAllByTypeReal(dictitem);
for (SysDictitem node : SysDictitemList) {
String nodeStr = JSON.toJSONString(node);
//String key = ssdw+":"+node.getCodeType()+":"+node.getpId()+":"+node.getId()+":"+node.getName()+":"+node.getId()+"|"+node.getName();
String key = ssdw + ":" + node.getGroupid() + ":" + node.getPid() + ":" + node.getCode() + ":" + node.getName() + ":" + node.getCode() + " | " + node.getName();
result = redisRefreshService.SaveRedisRest(key, nodeStr);
}
}
return result;
}
}
package com.founder.zdgl.controller.baseController;
import java.util.UUID;
public class BaseAction {
private static final long serialVersionUID = -8372406366949487719L;
public String getNextId() {
return UUID.randomUUID().toString();
}
}
\ No newline at end of file
package com.founder.zdgl.entity;
import com.founder.zdgl.entity.base.BaseModel;
import lombok.Data;
import java.util.Date;
/*
* @Description TODO
* @Author du_pengfei
* @Date 2021/7/9
* @Version 1.0
*/
@Data
public class DictItem extends BaseModel {
private String id;
//代码值
private String code;
private String newcode;
//代码中文名称
private String name;
private String newname;
private String namecode;
//代码表名称
private String groupid;
//代码表名称
private String groupname;
private String pid;
private String spell;
private String wbzx;
private String simple;
//子孙编号对应的父编号,位处理案件列别和案件性质的关系而增加
private Object pId1;
//子孙编号对应的父编号
private Object pId2;
//子孙编号对应的父编号
private Object pId3;
//子孙编号对应的父编号
private Object pId4;
//子孙编号对应的父编号
private Object pId5;
//子孙编号对应的父编号
private Object pId6;
//应用场景
private String yycj1;
private String yycj2;
private String yycj3;
private String yycj4;
private String yycj5;
private String yycj6;
private String yycj7;
private String yycj8;
//开始代码
private String startcode;
//结束代码
private String endcode;
//是否是父节点
private String isParent;
//描述
private String description;
private String gxr;
//private Date gxsj;
private String ajs;
//新疆字典维护树节点路径
private String selectPath;
}
package com.founder.zdgl.entity;
/*
* @Description TODO
* @Author du_pengfei
* @Date 2021/7/9
* @Version 1.0
*/
import lombok.Data;
@Data
public class SysDictitem {
private static final long serialVersionUID = 1L;
protected String id;
protected String code;
protected String codeStr;
protected String name;
protected String groupid;
protected String levelid;
protected String spell;
protected String wbzx;
protected String simple;
protected String groupname;
protected String yycj1;
protected String yycj2;
protected String yycj3;
protected String yycj4;
protected String pid;
protected String pName;//父节点名称
protected String isparent;
protected String yycj7;
protected String yycj5;
protected String yycj6;
protected String description;
protected String endcode;
protected String startcode;
protected String yycj8;
protected String sfqybmpdbz;
protected String dmmcbm;
protected String gabxf;
protected long scbz;
protected String lrr;
protected String yycj9;
}
package com.founder.zdgl.entity;
/*
* @Description TODO
* @Author du_pengfei
* @Date 2021/7/9
* @Version 1.0
*/
import com.founder.zdgl.entity.base.BaseModel;
import lombok.Data;
@Data
public class XalbdmSDJoin extends BaseModel {
private String xalbdmbcms;
private String groupid;
private String ajxz;
private String asjfssjRsddm;
private String xztqdm;
private String asjfssjZasjZasjlbdm;
private String asjfsddDylbdm;
private String asjfsddSacsSacslbdm;
private String asjfsddKjbwKjbwlbdm;
private String jrjzkjfsjsdJrjzkjfsjsddm;
private String lkjzkjfsLkjzkjfsdm;
private String xtkjtpsdJssdJssddm;
private String xtkjtpsdXtkjtpsddm;
private String qqsdQqsddm;
private String fzxyrtsxwFzxyrtsxwdm;
private String zagjdm;
private String zazbsdZazbsddm;
private String zazbsdZazbsddm_text;
private String jjsdJjsddm;
private String jjsdJjsddm_text;
private String xcwpfdcdXcwpfdcddm;
private String mcsfMcsfdm;
private String mcsfMcsfdm_text;
private String mcgxrMcgxrdm;
private String mcgxrMcgxrdm_text;
private String mydwmyMcdwmydm;
private String mydwmyMcdwmydm_text;
private String mcmysdMcmysddm;
private String mcmysdMcmysddm_text;
private String sbsdSbsddm;
private String gxr;
private String gxdwdm;
private String lrr;
private String lrdwdm;
private String id;
private String xzqh;
private String glxzqh;
private String xzc;
private String mz;
private String description;
private String jssdJssddm;
private String zpsdZpsddm;
private String zpsdZpsddm_text;
private String xpsdXpsddm;
private String wlzasdWlzasddm;
private String wlzasdWlzasddm_text;
private String grzcsdGrzcsddm;
private String grzcsdGrzcsddm_text;
private String xpsywpSawpdm;
private String ybsddm;
}
package com.founder.zdgl.entity;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
import java.util.List;
/*
* @Description TODO
* @Author du_pengfei
* @Date 2021/7/9
* @Version 1.0
*/
public class XzxtRestResult {
// 定义jackson对象
private static final ObjectMapper MAPPER = new ObjectMapper();
// 响应业务状态
private Integer status;
// 响应消息
private String msg;
// 响应中的数据
private Object data;
public static XzxtRestResult build(Integer status, String msg, Object data) {
return new XzxtRestResult(status, msg, data);
}
public static XzxtRestResult ok(Object data) {
return new XzxtRestResult(data);
}
public static XzxtRestResult ok(int i, String count, List<Object> list) {
return new XzxtRestResult(null);
}
public XzxtRestResult() {
}
public static XzxtRestResult build(Integer status, String msg) {
return new XzxtRestResult(status, msg, null);
}
public XzxtRestResult(Integer status, String msg, Object data) {
this.status = status;
this.msg = msg;
this.data = data;
}
public XzxtRestResult(Object data) {
this.status = 200;
this.msg = "OK";
this.data = data;
}
public Integer getStatus() {
return status;
}
public void setStatus(Integer status) {
this.status = status;
}
public String getMsg() {
return msg;
}
public void setMsg(String msg) {
this.msg = msg;
}
public Object getData() {
return data;
}
public void setData(Object data) {
this.data = data;
}
/**
* 将json结果集转化为Xzxt-Rest对象
*
* @param jsonData json数据
* @param clazz Xzxt-Rest中的object类型
* @return
*/
public static XzxtRestResult formatToPojo(String jsonData, Class<?> clazz) {
try {
if (clazz == null) {
return MAPPER.readValue(jsonData, XzxtRestResult.class);
}
JsonNode jsonNode = MAPPER.readTree(jsonData);
JsonNode data = jsonNode.get("data");
Object obj = null;
if (clazz != null) {
if (data.isObject()) {
obj = MAPPER.readValue(data.traverse(), clazz);
} else if (data.isTextual()) {
obj = MAPPER.readValue(data.asText(), clazz);
}
}
return build(jsonNode.get("status").intValue(), jsonNode.get("msg").asText(), obj);
} catch (Exception e) {
System.out.println(e.getStackTrace());
return new XzxtRestResult();
}
}
/**
* object对象的转化
*
* @param json
* @return
*/
public static XzxtRestResult format(String json) {
try {
return MAPPER.readValue(json, XzxtRestResult.class);
} catch (Exception e) {
e.printStackTrace();
}
return null;
}
/**
* Object是集合转化
*
* @param jsonData json数据
* @param clazz 集合中的类型
* @return
*/
public static XzxtRestResult formatToList(String jsonData, Class<?> clazz) {
try {
JsonNode jsonNode = MAPPER.readTree(jsonData);
JsonNode data = jsonNode.get("data");
Object obj = null;
if (data.isArray() && data.size() > 0) {
obj = MAPPER.readValue(data.traverse(),
MAPPER.getTypeFactory().constructCollectionType(List.class, clazz));
}
return build(jsonNode.get("status").intValue(), jsonNode.get("msg").asText(), obj);
} catch (Exception e) {
return null;
}
}
}
package com.founder.zdgl.entity;
import com.founder.zdgl.entity.base.BaseModel;
import lombok.Getter;
import lombok.Setter;
import java.util.ArrayList;
import java.util.List;
/*
* @Description TODO
* @Author du_pengfei
* @Date 2021/7/9
* @Version 1.0
*/
@Getter
@Setter
public class ZTreeNode extends BaseModel {
//id主键编号
private Object ids;
//代码名称
private String name;
//子孙编号对应的父编号,案件类别等通用表的父子关系
private String pId;
//代码值
private String id;
//应用场景
private String codeType;
private String yycj1;
private String yycj2;
private String yycj3;
private String yycj4;
private String yycj5;
private String yycj6;
private String yycj7;
private String yycj8;
//是否 父级目录
private String isParent;
//是否展开
private boolean open=false;
private String parentFlag = "";
//开始代码
private String startcode;
//结束代码
private String endcode;
//描述
private String description;
private boolean leaf = false;
private List<ZTreeNode> children = new ArrayList<ZTreeNode>();
private boolean checked = false;
public ZTreeNode(Object ids, String name, String pId, String description){
this.ids=ids;
this.name=name;
this.pId=pId;
this.description=description;
}
public ZTreeNode(Object ids, String name, String pId, boolean open, String isParent, String yycj1, String yycj2, String yycj3, String yycj4, String yycj5, String yycj6, String yycj7, String description){
this.ids=ids;
this.name=name;
this.pId=pId;
this.open=open;
this.isParent=isParent;
this.yycj1=yycj1;
this.yycj2=yycj2;
this.yycj3=yycj3;
this.yycj4=yycj4;
this.yycj5=yycj5;
this.yycj6=yycj6;
this.yycj7=yycj7;
this.description=description;
}
public ZTreeNode(){}
}
package com.founder.zdgl.entity.base;
import lombok.Data;
/*
* @Description TODO
* @Author du_pengfei
* @Date 2021/7/9
* @Version 1.0
*/
@Data
public class BaseModel {
protected String modelName;
protected String id = null;
protected String lrr = null;
protected String lrrLxdh = null;
protected String lrsj = null;
protected String gxr = null;
protected String gxrLxdh = null;
protected String gxsj = null;
protected String lrdwdm = null;
protected String lrdwmc = null;
private String scbz = "0";
protected String deleteFlag = "0";
protected String secrecy = null;
protected int functionLevel;
protected int startNum = 0;
protected int endNum = 0;
protected String conditionString = null;
protected String orderString = null;
protected String flag = null;
protected String ip = null;
protected String starttime = "";
protected String endtime = "";
protected String gxdwdm = null;
protected String gxdwmc = null;
private String gxdwdm_text = null;
protected String xxscPdbz = null;
protected String xxdjdwGajgjgdm = null;
protected String xxdjdwGajgmc = null;
protected String xxdjryXm = null;
protected String xxdjryGmsfhm = null;
protected String xxdjryLxdh = null;
protected String djsj = null;
protected String xxczdwGajgjgdm = null;
protected String xxczdwGajgmc = null;
protected String xxczryXm = null;
protected String xxczryGmsfhm = null;
protected String xxlyms = "刑侦信息专业应用系统";
protected String xxrsksj = null;
protected String xxrbksj = null;
protected String xxrskPdbz = null;
protected String xxrbkPdbz = null;
//查询分页开始结束
protected Integer begin = null;
protected Integer end = null;
protected String typeFlag = null;
}
package com.founder.zdgl.mapper;
import com.founder.zdgl.entity.DictItem;
import com.founder.zdgl.entity.XalbdmSDJoin;
import com.founder.zdgl.entity.ZTreeNode;
import org.apache.ibatis.annotations.Mapper;
import java.util.List;
import java.util.Map;
/*
* @Description TODO
* @Author du_pengfei
* @Date 2021/7/9
* @Version 1.0
*/
@Mapper
public interface DictManageMapper {
List<DictItem> queryDictAll(DictItem dictItem);
//字典更新功能
public boolean updateDict(DictItem dictItem);
public boolean updateDictAjxz(DictItem dictItem);
public boolean updateDictXalb(DictItem dictItem);
public boolean deleteDict(DictItem dictItem);
public boolean deleteDictAjxz(DictItem dictItem);
public boolean deleteDictXalb(DictItem dictItem);
public boolean insertDict(DictItem dictItem);
public boolean insertDictAjxz(DictItem dictItem);
public boolean insertDictXalb(DictItem dictItem);
public String getMaxcodeByGroup(DictItem dictItem);
public boolean updateXalbdmSDJoin(XalbdmSDJoin xalbdmSDJoin);
public boolean insertXalbdmSDJoin(XalbdmSDJoin xalbdmSDJoin);
public boolean deleteXalbdmSDJoin(XalbdmSDJoin xalbdmSDJoin);
public List queryXalbdmSDJoin(XalbdmSDJoin xalbdmSDJoin);
public boolean updateAsjSD(XalbdmSDJoin xalbdmSDJoin);
public List<XalbdmSDJoin> queryXalbJoinGWDQ(XalbdmSDJoin xalbdmSDJoin);
public boolean updateAllAsjSD(XalbdmSDJoin xalbdmSDJoin);
public List<DictItem> searchByKeyword(String searchKeyword);
public List searchInSameGPByKeywordGoupid(Map params);
public boolean updateXalbdmGWDQJoin(XalbdmSDJoin xalbdmSDJoin);
public boolean insertXalbdmGWDQJoin(XalbdmSDJoin xalbdmSDJoin);
public boolean deleteXalbdmGWDQJoin(XalbdmSDJoin xalbdmSDJoin);
public List<ZTreeNode> queryDictitemByCode(String code_type);
boolean insertDictSync(DictItem dictItem);
boolean updateDictSync(DictItem dictItem);
boolean insertDictAjxzSync(DictItem dictItem);
boolean insertDictXalbSync(DictItem dictItem);
boolean updateDictXalbSync(DictItem dictItem);
boolean updateDictAjxzSync(DictItem dictItem);
List<DictItem> queryDictAllByCode(DictItem dictItem);
}
package com.founder.zdgl.mapper;
import com.founder.zdgl.entity.SysDictitem;
import org.apache.ibatis.annotations.Mapper;
import java.util.List;
/*
* @Description TODO
* @Author du_pengfei
* @Date 2021/7/9
* @Version 1.0
*/
@Mapper
public interface RedisRefreshMapper {
public List<SysDictitem> selectDictitemByCondition(SysDictitem dictitem) ;
public List<SysDictitem> findCodeAllByTypeReal(SysDictitem dictitem) ;
}
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="com.founder.zdgl.mapper.RedisRefreshMapper">
<select id="findCodeAllByTypeReal" parameterType="com.founder.zdgl.entity.SysDictitem" resultType="com.founder.zdgl.entity.SysDictitem">
select distinct
id,
isparent,
groupid,
code ,
name,
groupname,
pid,
description,
yycj1,
yycj2,
yycj3,
yycj4,
yycj5,
yycj6,
yycj7,
yycj8,
yycj9,
startcode,
endcode
from sys_dictitem
where 1=1 and scbz='0'
<include refid="queryWhere" />
order by code asc
</select>
<sql id="queryWhere">
<if test="groupid != null and groupid!= ''">
AND GROUPID = #{groupid,jdbcType=VARCHAR}
</if>
</sql>
</mapper>
\ No newline at end of file
package com.founder.zdgl.service;
import com.founder.zdgl.entity.DictItem;
import com.founder.zdgl.entity.XalbdmSDJoin;
import com.founder.zdgl.entity.ZTreeNode;
import java.util.List;
import java.util.Map;
/*
* @Description TODO
* @Author du_pengfei
* @Date 2021/7/9
* @Version 1.0
*/
public interface DictManageService {
//查询字典下级类别功能
List<DictItem> queryDictAll(DictItem dictItem);
//字典更新功能
public boolean updateDict(DictItem dictItem);
public boolean updateDictAjxz(DictItem dictItem);
public boolean updateDictXalb(DictItem dictItem);
public boolean deleteDict(DictItem dictItem);
public boolean deleteDictAjxz(DictItem dictItem);
public boolean deleteDictXalb(DictItem dictItem);
public boolean insertDict(DictItem dictItem);
public boolean insertDictAjxz(DictItem dictItem);
public boolean insertDictXalb(DictItem dictItem);
public String getMaxcodeByGroup(DictItem dictItem);
public boolean updateXalbdmSDJoin(XalbdmSDJoin xalbdmSDJoin);
public boolean insertXalbdmSDJoin(XalbdmSDJoin xalbdmSDJoin);
public boolean deleteXalbdmSDJoin(XalbdmSDJoin xalbdmSDJoin);
public List<XalbdmSDJoin> queryXalbdmSDJoin(XalbdmSDJoin xalbdmSDJoin);
public boolean updateAsjSD(XalbdmSDJoin xalbdmSDJoin);
public boolean updateAllAsjSD(XalbdmSDJoin xalbdmSDJoin);
public List<XalbdmSDJoin> queryXalbJoinGWDQ(XalbdmSDJoin xalbdmSDJoin);
public List<DictItem> searchByKeyword(String searchKeyword);
public List searchInSameGPByKeywordGoupid(Map params);
public boolean updateXalbdmGWDQJoin(XalbdmSDJoin xalbdmSDJoin);
public boolean insertXalbdmGWDQJoin(XalbdmSDJoin xalbdmSDJoin);
public boolean deleteXalbdmGWDQJoin(XalbdmSDJoin xalbdmSDJoin);
public List<ZTreeNode> queryDictitemByCode(String code_type);
public boolean insertDictSync(DictItem dictItem);
boolean updateDictSync(DictItem dictItem);
boolean insertDictAjxzSync(DictItem dictItem);
boolean insertDictXalbSync(DictItem dictItem);
boolean updateDictXalbSync(DictItem dictItem);
boolean updateDictAjxzSync(DictItem dictItem);
List<DictItem> queryDictAllByCode(DictItem dictItem);
}
package com.founder.zdgl.service;
import com.alibaba.fastjson.JSONArray;
import com.founder.zdgl.entity.SysDictitem;
import com.founder.zdgl.entity.XzxtRestResult;
import java.util.List;
/*
* @Description TODO
* @Author du_pengfei
* @Date 2021/7/9
* @Version 1.0
*/
public interface RedisRefreshService {
XzxtRestResult SaveRedisRest(String key, String value);
XzxtRestResult DelRedisRest(String key);
XzxtRestResult keysRedisRest(String key);
JSONArray selectDictitemByCondition(SysDictitem dictitem);
List<SysDictitem> findCodeAllByTypeReal(SysDictitem dictitem);
}
package com.founder.zdgl.service.impl;
import com.founder.zdgl.entity.DictItem;
import com.founder.zdgl.entity.XalbdmSDJoin;
import com.founder.zdgl.entity.ZTreeNode;
import com.founder.zdgl.mapper.DictManageMapper;
import com.founder.zdgl.service.DictManageService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.Map;
/*
* @Description TODO
* @Author du_pengfei
* @Date 2021/7/9
* @Version 1.0
*/
@Service
public class DictManageServiceImpl implements DictManageService {
@Autowired
DictManageMapper dictManageMapper;
@Override
public List<DictItem> queryDictAll(DictItem dictItem) {
return dictManageMapper.queryDictAll(dictItem); }
@Override
public boolean updateDict(DictItem dictItem) {
return dictManageMapper.updateDict(dictItem);
}
@Override
public boolean updateDictAjxz(DictItem dictItem) {
return dictManageMapper.updateDictAjxz(dictItem);
}
@Override
public boolean updateDictXalb(DictItem dictItem) {
return dictManageMapper.updateDictXalb(dictItem);
}
@Override
public boolean deleteDict(DictItem dictItem) {
return dictManageMapper.deleteDict(dictItem);
}
@Override
public boolean deleteDictAjxz(DictItem dictItem) {
return dictManageMapper.deleteDictAjxz(dictItem);
}
@Override
public boolean deleteDictXalb(DictItem dictItem) {
return dictManageMapper.deleteDictXalb(dictItem);
}
@Override
public boolean insertDict(DictItem dictItem) {
return dictManageMapper.insertDict(dictItem);
}
@Override
public boolean insertDictAjxz(DictItem dictItem) {
return dictManageMapper.insertDictAjxz(dictItem);
}
@Override
public boolean insertDictXalb(DictItem dictItem) {
return dictManageMapper.insertDictXalb(dictItem);
}
@Override
public String getMaxcodeByGroup(DictItem dictItem) {
return dictManageMapper.getMaxcodeByGroup(dictItem);
}
@Override
public boolean updateXalbdmSDJoin(XalbdmSDJoin xalbdmSDJoin) {
return dictManageMapper.updateXalbdmSDJoin(xalbdmSDJoin);
}
@Override
public boolean insertXalbdmSDJoin(XalbdmSDJoin xalbdmSDJoin) {
return dictManageMapper.insertXalbdmSDJoin(xalbdmSDJoin);
}
@Override
public boolean deleteXalbdmSDJoin(XalbdmSDJoin xalbdmSDJoin) {
return dictManageMapper.deleteXalbdmSDJoin(xalbdmSDJoin);
}
@Override
public List<XalbdmSDJoin> queryXalbdmSDJoin(XalbdmSDJoin xalbdmSDJoin) {
return dictManageMapper.queryXalbdmSDJoin(xalbdmSDJoin);
}
@Override
public boolean updateAsjSD(XalbdmSDJoin xalbdmSDJoin) {
return dictManageMapper.updateAsjSD(xalbdmSDJoin);
}
@Override
public boolean updateAllAsjSD(XalbdmSDJoin xalbdmSDJoin) {
return dictManageMapper.updateAllAsjSD(xalbdmSDJoin);
}
@Override
public List<XalbdmSDJoin> queryXalbJoinGWDQ(XalbdmSDJoin xalbdmSDJoin) {
return dictManageMapper.queryXalbJoinGWDQ(xalbdmSDJoin);
}
@Override
public List<DictItem> searchByKeyword(String searchKeyword) {
return dictManageMapper.searchByKeyword(searchKeyword);
}
@Override
public List searchInSameGPByKeywordGoupid(Map params) {
return dictManageMapper.searchInSameGPByKeywordGoupid(params);
}
@Override
public boolean updateXalbdmGWDQJoin(XalbdmSDJoin xalbdmSDJoin) {
return dictManageMapper.updateXalbdmGWDQJoin(xalbdmSDJoin);
}
@Override
public boolean insertXalbdmGWDQJoin(XalbdmSDJoin xalbdmSDJoin) {
return dictManageMapper.insertXalbdmGWDQJoin(xalbdmSDJoin);
}
@Override
public boolean deleteXalbdmGWDQJoin(XalbdmSDJoin xalbdmSDJoin) {
return dictManageMapper.deleteXalbdmGWDQJoin(xalbdmSDJoin);
}
@Override
public List<ZTreeNode> queryDictitemByCode(String code_type) {
return dictManageMapper.queryDictitemByCode(code_type);
}
@Override
public boolean insertDictSync(DictItem dictItem) {
return dictManageMapper.insertDictSync(dictItem);
}
@Override
public boolean updateDictSync(DictItem dictItem) {
return dictManageMapper.updateDictSync(dictItem);
}
@Override
public boolean insertDictAjxzSync(DictItem dictItem) {
return dictManageMapper.insertDictAjxzSync(dictItem);
}
@Override
public boolean insertDictXalbSync(DictItem dictItem) {
return dictManageMapper.insertDictXalbSync(dictItem);
}
@Override
public boolean updateDictXalbSync(DictItem dictItem) {
return dictManageMapper.updateDictXalbSync(dictItem);
}
@Override
public boolean updateDictAjxzSync(DictItem dictItem) {
return dictManageMapper.updateDictAjxzSync(dictItem);
}
@Override
public List<DictItem> queryDictAllByCode(DictItem dictItem) {
return dictManageMapper.queryDictAllByCode(dictItem);
}
}
package com.founder.zdgl.service.impl;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.founder.zdgl.entity.SysDictitem;
import com.founder.zdgl.entity.XzxtRestResult;
import com.founder.zdgl.mapper.RedisRefreshMapper;
import com.founder.zdgl.service.RedisRefreshService;
import com.founder.zdgl.util.ExceptionUtil;
import com.founder.zdgl.util.RedisUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
/*
* @Description TODO
* @Author du_pengfei
* @Date 2021/7/9
* @Version 1.0
*/
@Service
public class RedisRefreshServiceImpl implements RedisRefreshService {
@Autowired
private RedisUtil redisUtil;
@Autowired
private RedisRefreshMapper redisRefreshMapper;
/**
* 返回状态码:201:成功存入
* 返回状态码:202:成功读取
* 返回状态码:203:成功删除
* 返回状态码:204:获取指定key
* 返回状态码:205:获取指定key对应的value
**/
@Override
public XzxtRestResult SaveRedisRest(String key, String value) {
try {
redisUtil.set(key, value);
} catch (Exception e) {
e.printStackTrace();
return XzxtRestResult.build(500, ExceptionUtil.getStackTrace(e));
}
return XzxtRestResult.build(201,"成功存入redis");
}
@Override
public XzxtRestResult DelRedisRest( String key) {
try {
redisUtil.del(key);
} catch (Exception e) {
e.printStackTrace();
return XzxtRestResult.build(500, ExceptionUtil.getStackTrace(e));
}
return XzxtRestResult.build(203,"删除指定redis");
}
@Override
public XzxtRestResult keysRedisRest(String key) {
Set<String> result=new HashSet<>();
try {
result=redisUtil.keys(key);
} catch (Exception e) {
e.printStackTrace();
return XzxtRestResult.build(500, ExceptionUtil.getStackTrace(e));
}
return XzxtRestResult.build(204,"获取指定key",result);
}
@Override
public JSONArray selectDictitemByCondition(SysDictitem dictitem) {
dictitem.setScbz(0);
List<SysDictitem> dictitems = redisRefreshMapper.selectDictitemByCondition(dictitem);
String jsonString = JSONObject.toJSONString(dictitems);
JSONArray dictitemjson = JSONArray.parseArray(jsonString);
return dictitemjson;
}
@Override
public List<SysDictitem> findCodeAllByTypeReal(SysDictitem dictitem) {
List<SysDictitem> dictitems = redisRefreshMapper.findCodeAllByTypeReal(dictitem);
return dictitems;
}
}
package com.founder.zdgl.util;
import java.io.PrintWriter;
import java.io.StringWriter;
public class ExceptionUtil {
/**
* 获取异常的堆栈信息
*
* @param t
* @return
*/
public static String getStackTrace(Throwable t) {
StringWriter sw = new StringWriter();
PrintWriter pw = new PrintWriter(sw);
try {
t.printStackTrace(pw);
return sw.toString();
} finally {
pw.close();
}
}
}
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