添加晋能数据权限过滤

web/health/src/main/java/com/gyee/health/controller/AuthController.java

@@ -0,0 +1,80 @@
+package com.gyee.health.controller;
+
+import com.gyee.common.model.StringUtils;
+import com.gyee.health.dto.AjaxResult;
+import com.gyee.health.dto.AjaxStatus;
+import com.gyee.health.model.vo.TokenVo;
+import com.gyee.health.service.TokenService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.ResponseBody;
+
+import javax.annotation.Resource;
+import java.util.Date;
+
+@Controller
+@RequestMapping("/auth")
+@Api(value = "权限管理", tags = "权限管理")
+public class AuthController {
+
+
+    @Resource
+    private TokenService tokenService;
+
+    @PostMapping("/login")
+    @ResponseBody
+    @ApiOperation(value = "使用账号密码登录")
+    public AjaxResult login(@RequestBody  TokenVo tokenVo) {
+
+        if (StringUtils.notEmp(tokenVo)) {
+
+            if (!tokenService.sessionMap.containsKey(tokenVo.getToken())) {
+                tokenVo.setTime(new Date());
+                tokenService.sessionMap.put(tokenVo.getToken(), tokenVo);
+            }
+
+            tokenService.judegeSession();
+        }
+
+        return AjaxResult.successData(AjaxStatus.success.code, "ok");
+    }
+
+    @PostMapping("/logout")
+    @ApiOperation(value = "登出系统")
+    @ResponseBody
+    public AjaxResult logout(@RequestBody  TokenVo tokenVo) {
+        if (StringUtils.notEmp(tokenVo)) {
+
+            if (tokenService.sessionMap.containsKey(tokenVo.getToken())) {
+                tokenService.sessionMap.remove(tokenVo.getToken());
+            }
+
+            if (tokenService.sessionWtMap.containsKey(tokenVo.getToken())) {
+                tokenService.sessionWtMap.remove(tokenVo.getToken());
+            }
+            if (tokenService.sessionWpMap.containsKey(tokenVo.getToken())) {
+                tokenService.sessionWpMap.remove(tokenVo.getToken());
+
+            }
+            if (tokenService.sessionSubMap.containsKey(tokenVo.getToken())) {
+                tokenService.sessionSubMap.remove(tokenVo.getToken());
+
+            }
+            if (tokenService.sessionWeMap.containsKey(tokenVo.getToken())) {
+                tokenService.sessionWeMap.remove(tokenVo.getToken());
+
+            }
+
+        }
+
+        tokenService.judegeSession();
+
+        return AjaxResult.successData(AjaxStatus.success.code, "ok");
+    }
+
+
+}

web/health/src/main/java/com/gyee/health/controller/health/HealthMainController.java

@@ -9,6 +9,7 @@ import com.gyee.health.model.auto.ProBasicLine;
 import com.gyee.health.model.auto.ProBasicPowerstation;
 import com.gyee.health.model.auto.ProBasicProject;
 import com.gyee.health.model.custom.StopTypeTreeVo;
+import com.gyee.health.service.TokenService;
 import com.gyee.health.service.health.HealthMainService;
 import com.gyee.health.util.StringUtils;
 import io.swagger.annotations.Api;
@@ -20,8 +21,11 @@ import org.springframework.web.bind.annotation.CrossOrigin;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.ResponseBody;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
 
 import javax.annotation.Resource;
+import javax.servlet.http.HttpServletRequest;
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
@@ -34,7 +38,8 @@ public class HealthMainController {
 
     @Resource
     private HealthMainService healthMainService;
-
+    @Resource
+    private TokenService tokenService;
 
     @GetMapping("/findAllChart")
     @ResponseBody
@@ -140,8 +145,9 @@ public class HealthMainController {
     @ApiOperation(value = "查询风电场数据列表", notes = "查询风电场数据列表")
     public AjaxResult windfarmAjax() {
         List<StopTypeTreeVo> vos = new ArrayList<>();
-
-        for (ProBasicPowerstation station : CacheContext.wpls) {
+        HttpServletRequest request = ((ServletRequestAttributes) (RequestContextHolder.currentRequestAttributes())).getRequest();
+        List<ProBasicPowerstation> wpls = tokenService.getWpls(request);
+        for (ProBasicPowerstation station : wpls) {
             StopTypeTreeVo vo = new StopTypeTreeVo();
             vo.setId(station.getId());
             vo.setName(station.getName());

web/health/src/main/java/com/gyee/health/dto/AjaxStatus.java

@@ -0,0 +1,14 @@
+package com.gyee.health.dto;
+
+
+public enum  AjaxStatus {
+    success(200),
+    error(500),
+    logineroor(501),
+    loginexpire(502);
+
+    public int code;
+    AjaxStatus(int c) {
+        code = c;
+    }
+}

web/health/src/main/java/com/gyee/health/init/CacheContext.java

@@ -150,6 +150,11 @@ public class CacheContext implements CommandLineRunner {
     public static Map<String, Map<Double,ProEconWtPowerCurveFitting>> curveFittingPowerMap = new HashMap<>(); //自算，最优功率
     public static Map<String,List<ProBasicStatusPoint>> statusMap = new HashMap<>();
     public static Map<String, Map<Double, ProEconWtPowerCurveFitting>> wpcmap = new HashMap<String, Map<Double, ProEconWtPowerCurveFitting>>();
+
+
+
+
+
     @Override
     public void run(String... args) throws Exception {
         logger.info("缓存开始------------------------------------------------------------");

web/health/src/main/java/com/gyee/health/mapper/auto/SysUserMapper.java

@@ -0,0 +1,22 @@
+package com.gyee.health.mapper.auto;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.gyee.health.model.auto.SysUser;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
+
+import java.util.List;
+
+/**
+ * <p>
+ * 用户信息表 Mapper 接口
+ * </p>
+ *
+ * @author wang
+ * @since 2023-07-25
+ */
+public interface SysUserMapper extends BaseMapper<SysUser> {
+
+    @Select("SELECT d.nem_code FROM system_dept as d,system_users as u where u.dept_id=d.id and u.id=#{userId} ")
+    public List<String> getUserByuserId(@Param(value = "userId") Long userId);
+}

web/health/src/main/java/com/gyee/health/model/auto/SysUser.java

@@ -0,0 +1,119 @@
+package com.gyee.health.model.auto;
+
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.time.LocalDateTime;
+
+/**
+ * <p>
+ * 用户信息表
+ * </p>
+ *
+ * @author wang
+ * @since 2023-07-25
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+public class SysUser extends Model {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 用户ID
+     */
+    private Long userId;
+
+    /**
+     * 部门ID
+     */
+    private Long deptId;
+
+    /**
+     * 用户账号
+     */
+    private String userName;
+
+    /**
+     * 用户昵称
+     */
+    private String nickName;
+
+    /**
+     * 用户类型（00系统用户）
+     */
+    private String userType;
+
+    /**
+     * 用户邮箱
+     */
+    private String email;
+
+    /**
+     * 手机号码
+     */
+    private String phonenumber;
+
+    /**
+     * 用户性别（0男 1女 2未知）
+     */
+    private String sex;
+
+    /**
+     * 头像地址
+     */
+    private String avatar;
+
+    /**
+     * 密码
+     */
+    private String password;
+
+    /**
+     * 帐号状态（0正常 1停用）
+     */
+    private String status;
+
+    /**
+     * 删除标志（0代表存在 2代表删除）
+     */
+    private String delFlag;
+
+    /**
+     * 最后登录IP
+     */
+    private String loginIp;
+
+    /**
+     * 最后登录时间
+     */
+    private LocalDateTime loginDate;
+
+    /**
+     * 创建者
+     */
+    private String createBy;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createTime;
+
+    /**
+     * 更新者
+     */
+    private String updateBy;
+
+    /**
+     * 更新时间
+     */
+    private LocalDateTime updateTime;
+
+    /**
+     * 备注
+     */
+    private String remark;
+
+
+}

web/health/src/main/java/com/gyee/health/model/vo/TokenVo.java

@@ -0,0 +1,17 @@
+package com.gyee.health.model.vo;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.Date;
+
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+public class TokenVo {
+
+    private String token;
+    private  String userId;
+    private Date time;
+}

web/health/src/main/java/com/gyee/health/service/TokenService.java

@@ -0,0 +1,318 @@
+package com.gyee.health.service;
+
+import com.gyee.common.model.StringUtils;
+import com.gyee.health.init.CacheContext;
+import com.gyee.health.model.auto.*;
+import com.gyee.health.model.vo.TokenVo;
+import com.gyee.health.service.auto.ISysUserService;
+import com.gyee.health.util.DateUtils;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import javax.servlet.http.HttpServletRequest;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+@Service
+public class TokenService {
+    @Resource
+    private ISysUserService sysUserService;
+
+
+    public static Map<String, List<ProBasicEquipment>> sessionWtMap = new ConcurrentHashMap<>();
+    public static Map<String, List<ProBasicPowerstation>> sessionWpMap = new ConcurrentHashMap<>();
+    public static Map<String,  List<ProBasicSubStation> > sessionSubMap = new ConcurrentHashMap<>();
+    public static Map<String, List<ProBasicWeatherStation>> sessionWeMap = new ConcurrentHashMap<>();
+
+    public static Map<String, TokenVo> sessionMap=  new ConcurrentHashMap<>();
+
+
+    public void  judegeSession() {
+
+
+
+        for (Map.Entry <String, TokenVo>  entry : sessionMap.entrySet()) {
+            TokenVo vo=entry.getValue();
+
+            Date begin=vo.getTime();
+            Date end=new Date();
+
+            double value= DateUtils.hoursDiff(begin,end);
+
+            if(value>3)
+            {
+                sessionMap.remove(entry.getKey());
+
+
+
+                if (sessionWtMap.containsKey(entry.getKey())) {
+                    sessionWtMap.remove(entry.getKey());
+                }
+                if (sessionWpMap.containsKey(entry.getKey())) {
+                    sessionWpMap.remove(entry.getKey());
+
+                }
+                if (sessionSubMap.containsKey(entry.getKey())) {
+                    sessionSubMap.remove(entry.getKey());
+
+                }
+                if (sessionWeMap.containsKey(entry.getKey())) {
+                    sessionWeMap.remove(entry.getKey());
+
+                }
+            }
+        }
+
+    }
+    public  List<ProBasicEquipment>  getWtls(HttpServletRequest request ) {
+
+        String token = request.getHeader("token");
+        String userId = request.getHeader("userId");
+
+        List<ProBasicEquipment> wtlist = new ArrayList<>();
+        if (StringUtils.notEmp(token) && StringUtils.notEmp(userId))
+        {
+            if (sessionMap.containsKey(token) && !sessionWtMap.containsKey(token)) {
+
+                List<String> depls = sysUserService.getUserByuserId(Long.valueOf(userId));
+                if (!depls.isEmpty()) {
+                    String depId = depls.get(0);
+
+                    if (CacheContext.wpwtmap.containsKey(depId)) {
+                        wtlist.addAll(CacheContext.wpwtmap.get(depId));
+                    } else if (CacheContext.cmwtlsmap.containsKey(depId)) {
+                        wtlist.addAll(CacheContext.cmwtlsmap.get(depId));
+                    } else if (CacheContext.rgwtlsmap.containsKey(depId)) {
+                        wtlist.addAll(CacheContext.rgwtlsmap.get(depId));
+                    }else  if(depId.equals("0"))
+                    {
+                        wtlist.addAll(CacheContext.wtls);
+                    }
+                }
+                sessionWtMap.put(token,wtlist);
+            } else if (sessionMap.containsKey(token) && sessionWtMap.containsKey(token))
+            {
+                wtlist =sessionWtMap.get(token);
+            }
+        }else
+        {
+            wtlist.addAll(CacheContext.wtls);
+
+        }
+        return wtlist;
+    }
+
+    public  List<ProBasicPowerstation>  getWpls(HttpServletRequest request )
+    {
+        String token = request.getHeader("token");
+        String userId = request.getHeader("userId");
+
+        List<ProBasicPowerstation> wplist=new ArrayList<>();
+        if(StringUtils.notEmp(token)  && StringUtils.notEmp(token))
+        {
+            if(sessionMap.containsKey(token) && !sessionWpMap.containsKey(token))
+            {
+
+                List<String> depls= sysUserService.getUserByuserId(Long.valueOf(userId));
+                if(!depls.isEmpty())
+                {
+                    String depId=depls.get(0);
+
+                    if(CacheContext.wpmap.containsKey(depId))
+                    {
+                        wplist.add(CacheContext.wpmap.get(depId));
+                    }else  if(CacheContext.cpwpmap.containsKey(depId))
+                    {
+                        wplist.addAll(CacheContext.cpwpmap.get(depId));
+                    }else  if(CacheContext.rgmap.containsKey(depId))
+                    {
+                        List<ProBasicCompany> rgcpls= CacheContext.rgcpmap.get(depId);
+                        for(ProBasicCompany cp:rgcpls)
+                        {
+                            wplist.addAll(CacheContext.cpwpmap.get(cp.getId()));
+                        }
+                    }else if(depId.equals("0"))
+                    {
+                        wplist=sessionWpMap.get(token);
+                    }else if(depId.equals("0"))
+                    {
+                        wplist.addAll(CacheContext.wpls);
+                    }
+                }
+                sessionWpMap.put(token,wplist);
+            }else if (sessionMap.containsKey(token) && sessionWpMap.containsKey(token))
+            {
+                wplist=sessionWpMap.get(token);
+            }
+
+        }else
+        {
+            wplist.addAll(CacheContext.wpls);
+        }
+        return wplist;
+    }
+
+    public  List<ProBasicSubStation>  getSubwpls(HttpServletRequest request )
+    {
+        String token = request.getHeader("token");
+        String userId = request.getHeader("userId");
+        List<ProBasicSubStation> wplist=new ArrayList<>();
+        if(StringUtils.notEmp(token) && StringUtils.notEmp(userId))
+        {
+            if(!sessionSubMap.containsKey(token))
+            {
+
+                List<String> depls= sysUserService.getUserByuserId(Long.valueOf(userId));
+                if(!depls.isEmpty())
+                {
+                    String depId=depls.get(0);
+
+                    if(CacheContext.wpmap.containsKey(depId))
+                    {
+                        for(ProBasicSubStation subStation:CacheContext.subwpls)
+                        {
+                            if(subStation.getWindpowerstationId().equals(depId))
+                            {
+                                wplist.add(subStation);
+                            }
+                        }
+                    }else  if(CacheContext.cpwpmap.containsKey(depId))
+                    {
+                        List<ProBasicPowerstation> wpls=CacheContext.cpwpmap.get(depId);
+
+                        for(ProBasicPowerstation wp:wpls)
+                        {
+                            for(ProBasicSubStation subStation:CacheContext.subwpls)
+                            {
+                                if(subStation.getWindpowerstationId().equals(wp.getId()))
+                                {
+                                    wplist.add(subStation);
+                                    break;
+                                }
+                            }
+                        }
+                    }else  if(CacheContext.rgmap.containsKey(depId))
+                    {
+                        List<ProBasicCompany> rgcpls= CacheContext.rgcpmap.get(depId);
+                        for(ProBasicCompany cp:rgcpls)
+                        {
+                            List<ProBasicPowerstation> wpls=CacheContext.cpwpmap.get(cp.getId());
+
+                            for(ProBasicPowerstation wp:wpls)
+                            {
+                                for(ProBasicSubStation subStation:CacheContext.subwpls)
+                                {
+                                    if(subStation.getWindpowerstationId().equals(wp.getId()))
+                                    {
+                                        wplist.add(subStation);
+                                        break;
+                                    }
+                                }
+
+                            }
+                        }
+                    }else if(depId.equals("0"))
+                    {
+                        wplist.addAll(CacheContext.subwpls);
+                    }
+                }
+                sessionSubMap.put(token,wplist);
+            }else  if (sessionMap.containsKey(token) && sessionSubMap.containsKey(token))
+            {
+                wplist=sessionSubMap.get(token);
+
+            }
+        }else
+        {
+            wplist.addAll(CacheContext.subwpls);
+        }
+        return wplist;
+    }
+
+
+    public   List<ProBasicWeatherStation>  getWeawpls (HttpServletRequest request )
+    {
+        String token = request.getHeader("token");
+        String userId = request.getHeader("userId");
+
+        List<ProBasicWeatherStation> wplist=new ArrayList<>();
+        if(StringUtils.notEmp(token) && StringUtils.notEmp(userId))
+        {
+            if(!sessionWeMap.containsKey(token))
+            {
+
+                List<String> depls= sysUserService.getUserByuserId(Long.valueOf(userId));
+                if(!depls.isEmpty())
+                {
+                    String depId=depls.get(0);
+
+                    if(CacheContext.wpmap.containsKey(depId))
+                    {
+                        for(ProBasicWeatherStation weatherStation:CacheContext.weawpls)
+                        {
+                            if(weatherStation.getWindpowerstationId().equals(depId))
+                            {
+                                wplist.add(weatherStation);
+                            }
+                        }
+
+                    }else  if(CacheContext.cpwpmap.containsKey(depId))
+                    {
+                        List<ProBasicPowerstation> wpls=CacheContext.cpwpmap.get(depId);
+
+                        for(ProBasicPowerstation wp:wpls)
+                        {
+                            for(ProBasicWeatherStation weatherStation:CacheContext.weawpls)
+                            {
+                                if(weatherStation.getWindpowerstationId().equals(wp.getId()))
+                                {
+                                    wplist.add(weatherStation);
+                                    break;
+                                }
+                            }
+
+                        }
+                    }else  if(CacheContext.rgmap.containsKey(depId))
+                    {
+                        List<ProBasicCompany> rgcpls= CacheContext.rgcpmap.get(depId);
+                        for(ProBasicCompany cp:rgcpls)
+                        {
+                            List<ProBasicPowerstation> wpls=CacheContext.cpwpmap.get(cp.getId());
+
+                            for(ProBasicPowerstation wp:wpls)
+                            {
+                                for(ProBasicWeatherStation weatherStation:CacheContext.weawpls)
+                                {
+                                    if(weatherStation.getWindpowerstationId().equals(wp.getId()))
+                                    {
+                                        wplist.add(weatherStation);
+                                        break;
+                                    }
+                                }
+
+                            }
+                        }
+
+                    }else if(depId.equals("0"))
+                    {
+                        wplist.addAll(CacheContext.weawpls);
+                    }
+                }
+                sessionWeMap.put(token,wplist);
+            }else  if (sessionMap.containsKey(token) && sessionWeMap.containsKey(token))
+            {
+                wplist=sessionWeMap.get(token);
+            }
+
+        }else
+        {
+
+            wplist.addAll(CacheContext.weawpls);
+
+        }
+        return wplist;
+    }
+}

web/health/src/main/java/com/gyee/health/service/auto/ISysUserService.java

@@ -0,0 +1,19 @@
+package com.gyee.health.service.auto;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.gyee.health.model.auto.SysUser;
+
+import java.util.List;
+
+/**
+ * <p>
+ * 用户信息表 服务类
+ * </p>
+ *
+ * @author wang
+ * @since 2023-07-25
+ */
+public interface ISysUserService extends IService<SysUser> {
+
+    public List<String> getUserByuserId(Long userId);
+}

web/health/src/main/java/com/gyee/health/service/auto/impl/ProBasicEquipmentServiceImpl.java

@@ -4,11 +4,16 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.gyee.health.init.CacheContext;
 import com.gyee.health.mapper.auto.ProBasicEquipmentMapper;
 import com.gyee.health.model.auto.ProBasicEquipment;
+import com.gyee.health.service.TokenService;
 import com.gyee.health.service.auto.IProBasicEquipmentService;
 import com.gyee.health.util.SortUtils;
 import com.gyee.health.util.StringUtils;
 import org.springframework.stereotype.Service;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
 
+import javax.annotation.Resource;
+import javax.servlet.http.HttpServletRequest;
 import java.util.List;
 import java.util.stream.Collectors;
 
@@ -24,12 +29,14 @@ import java.util.stream.Collectors;
 
 public class ProBasicEquipmentServiceImpl extends ServiceImpl<ProBasicEquipmentMapper, ProBasicEquipment> implements IProBasicEquipmentService {
 
-
+    @Resource
+    private TokenService tokenService;
     @Override
     public List<ProBasicEquipment> getProBasicEquipmentList(String companyId, String windpowerstationIds, String projectIds, String lineIds,String  type) {
 
-
-        List<ProBasicEquipment> list = CacheContext.wtls;
+        HttpServletRequest request = ((ServletRequestAttributes) (RequestContextHolder.currentRequestAttributes())).getRequest();
+        List<ProBasicEquipment> wtls = tokenService.getWtls(request);
+        List<ProBasicEquipment> list = wtls;
 
         if (StringUtils.isNotEmpty(type) && !type.equals("0")){
             String finalType  =  type.equals("-1") ? "_FDC" : "_GDC";
@@ -63,6 +70,8 @@ public class ProBasicEquipmentServiceImpl extends ServiceImpl<ProBasicEquipmentM
 
     @Override
     public List<ProBasicEquipment> getProBasicEquipmentList(String wpid) {
-        return CacheContext.wtls.stream().filter(i->i.getWindpowerstationId().equals(wpid)).collect(Collectors.toList());
+        HttpServletRequest request = ((ServletRequestAttributes) (RequestContextHolder.currentRequestAttributes())).getRequest();
+        List<ProBasicEquipment> wtls = tokenService.getWtls(request);
+        return wtls.stream().filter(i->i.getWindpowerstationId().equals(wpid)).collect(Collectors.toList());
     }
 }

web/health/src/main/java/com/gyee/health/service/auto/impl/ProEconEquipmentInfoDayTopServiceImpl.java

@@ -11,10 +11,14 @@ import com.gyee.health.mapper.auto.ProEconEquipmentInfoDayTopMapper;
 import com.gyee.health.model.auto.ProBasicPowerstation;
 import com.gyee.health.model.auto.ProEconEquipmentInfoDayTop;
 import com.gyee.health.model.vo.ShutdowneventType;
+import com.gyee.health.service.TokenService;
 import com.gyee.health.service.auto.IProEconEquipmentInfoDayTopService;
 import org.springframework.stereotype.Service;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
 
 import javax.annotation.Resource;
+import javax.servlet.http.HttpServletRequest;
 import java.util.*;
 import java.util.stream.Collectors;
 
@@ -32,6 +36,9 @@ public class ProEconEquipmentInfoDayTopServiceImpl extends ServiceImpl<ProEconEq
 
     @Resource
     private ProEconEquipmentInfoDayTopMapper proEconEquipmentInfoDayTopMapper;
+
+    @Resource
+    private TokenService tokenService;
     @Override
     public List<ProEconEquipmentInfoDayTop> getEquipmentInfoDayTopList(String companyId, String windpowerstationId, Integer types, String staType, String date) {
 
@@ -39,10 +46,13 @@ public class ProEconEquipmentInfoDayTopServiceImpl extends ServiceImpl<ProEconEq
 
 
         List<String> wpids = new ArrayList<>();
-        List<ProBasicPowerstation> wplist = CacheContext.wpls;
+
+
+        HttpServletRequest request = ((ServletRequestAttributes) (RequestContextHolder.currentRequestAttributes())).getRequest();
+        List<ProBasicPowerstation> wplist = tokenService.getWpls(request);
         //场站模糊查询
         if (StringUtils.isNotEmpty(companyId)) {
-            wplist = CacheContext.wpls.stream().filter(wp -> wp.getRegionId().equals(companyId) || wp.getCompanyId().equals(companyId)).collect(Collectors.toList());
+            wplist = wplist.stream().filter(wp -> wp.getRegionId().equals(companyId) || wp.getCompanyId().equals(companyId)).collect(Collectors.toList());
         }
 
         if (StringUtils.isNotEmpty(staType) && !staType.equals("0")) {

web/health/src/main/java/com/gyee/health/service/auto/impl/ProEconShutdownEventServiceImpl.java

@@ -11,11 +11,15 @@ import com.gyee.health.model.auto.ProBasicProject;
 import com.gyee.health.model.auto.ProEconShutdownEvent;
 import com.gyee.health.model.custom.ShutdowneventVo;
 import com.gyee.health.model.custom.SimpleVo;
+import com.gyee.health.service.TokenService;
 import com.gyee.health.service.auto.IProEconShutdownEventService;
 import com.gyee.health.util.StringUtils;
 import org.springframework.stereotype.Service;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
 
 import javax.annotation.Resource;
+import javax.servlet.http.HttpServletRequest;
 import java.util.*;
 
 /**
@@ -31,7 +35,8 @@ public class ProEconShutdownEventServiceImpl extends ServiceImpl<ProEconShutdown
 
     @Resource
     private ProEconShutdownEventMapper proEconShutdownEventMapper;
-
+    @Resource
+    private TokenService tokenService;
     public List<ShutdowneventVo> queryEvents(String wpId, String wtId, Date beginDate, Date endDate, Integer type) {
 
 
@@ -138,8 +143,9 @@ public class ProEconShutdownEventServiceImpl extends ServiceImpl<ProEconShutdown
             {
                 map.put(vo.getId(),vo);
             }
-
-            for(ProBasicPowerstation wp: CacheContext.wpls)
+            HttpServletRequest request = ((ServletRequestAttributes) (RequestContextHolder.currentRequestAttributes())).getRequest();
+            List<ProBasicPowerstation> wpls = tokenService.getWpls(request);
+            for(ProBasicPowerstation wp: wpls)
             {
                 SimpleVo vo=new SimpleVo();
                 vo.setId(wp.getId());

web/health/src/main/java/com/gyee/health/service/auto/impl/ProEconWarningServiceImpl.java

@@ -6,10 +6,14 @@ import com.gyee.health.mapper.auto.ProEconWarningMapper;
 import com.gyee.health.model.auto.ProBasicPowerstation;
 import com.gyee.health.model.auto.ProEconWarning;
 import com.gyee.health.model.custom.SimpleVo;
+import com.gyee.health.service.TokenService;
 import com.gyee.health.service.auto.IProEconWarningService;
 import org.springframework.stereotype.Service;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
 
 import javax.annotation.Resource;
+import javax.servlet.http.HttpServletRequest;
 import java.text.SimpleDateFormat;
 import java.util.ArrayList;
 import java.util.Calendar;
@@ -29,6 +33,8 @@ public class ProEconWarningServiceImpl extends ServiceImpl<ProEconWarningMapper,
 
     @Resource
     private ProEconWarningMapper proEconWarningMapper;
+    @Resource
+    private TokenService tokenService;
     /**
      * 获取七天内各个风场报警统计
      * @return
@@ -40,8 +46,9 @@ public class ProEconWarningServiceImpl extends ServiceImpl<ProEconWarningMapper,
         SimpleDateFormat sdf_no_underline = new SimpleDateFormat("yyyyMM");
         Calendar cal = Calendar.getInstance();
         Date endDate = cal.getTime();
-
-        for(ProBasicPowerstation wp: CacheContext.wpls)
+        HttpServletRequest request = ((ServletRequestAttributes) (RequestContextHolder.currentRequestAttributes())).getRequest();
+        List<ProBasicPowerstation> wpls = tokenService.getWpls(request);
+        for(ProBasicPowerstation wp: wpls)
         {
 
             if (wp.getId().endsWith("_FDC")) {
@@ -83,8 +90,9 @@ public class ProEconWarningServiceImpl extends ServiceImpl<ProEconWarningMapper,
         SimpleDateFormat sdf_no_underline = new SimpleDateFormat("yyyyMM");
         Calendar cal = Calendar.getInstance();
         Date endDate = cal.getTime();
-
-        for(ProBasicPowerstation wp:CacheContext.wpls)
+        HttpServletRequest request = ((ServletRequestAttributes) (RequestContextHolder.currentRequestAttributes())).getRequest();
+        List<ProBasicPowerstation> wpls = tokenService.getWpls(request);
+        for(ProBasicPowerstation wp:wpls)
         {
 
             if (wp.getId().endsWith("_FDC")) {

web/health/src/main/java/com/gyee/health/service/auto/impl/SysUserServiceImpl.java

@@ -0,0 +1,38 @@
+package com.gyee.health.service.auto.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.gyee.common.model.StringUtils;
+import com.gyee.health.mapper.auto.SysUserMapper;
+import com.gyee.health.model.auto.SysUser;
+import com.gyee.health.service.auto.ISysUserService;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * <p>
+ * 用户信息表 服务实现类
+ * </p>
+ *
+ * @author wang
+ * @since 2023-07-25
+ */
+@Service
+public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> implements ISysUserService {
+
+    @Resource
+    private SysUserMapper sysUserMapper;
+    public List<String> getUserByuserId(Long userId) {
+
+        List<String> list =new ArrayList<>();
+        if(StringUtils.notEmp(userId) )
+        {
+
+            list = sysUserMapper.getUserByuserId(userId);
+        }
+
+        return list;
+    }
+}

web/health/src/main/java/com/gyee/health/service/health/HealthMainService.java

@@ -12,14 +12,18 @@ import com.gyee.health.model.vo.HealthStatusValue;
 import com.gyee.health.model.vo.ShutdowneventType;
 import com.gyee.health.model.vo.StatusDetailValue;
 import com.gyee.health.model.vo.StopType;
+import com.gyee.health.service.TokenService;
 import com.gyee.health.service.auto.IProBasicEquipmentPointService;
 import com.gyee.health.service.auto.IProBasicPowerstationPointService;
 import com.gyee.health.service.auto.IProBasicProjectPlanService;
 import com.gyee.health.service.auto.IProEconShutdownEventService;
 import com.gyee.health.util.*;
 import org.springframework.stereotype.Service;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
 
 import javax.annotation.Resource;
+import javax.servlet.http.HttpServletRequest;
 import java.math.BigDecimal;
 import java.math.RoundingMode;
 import java.text.SimpleDateFormat;
@@ -52,7 +56,8 @@ public class HealthMainService {
 //    private final double YCFDLXS = 1.08;
 
     IRealTimeDataBaseUtil realApiUtil = RealTimeDataBaseFactory.createRealTimeDataBase();
-
+    @Resource
+    private TokenService tokenService;
     /**
      * 健康矩阵
      */
@@ -60,8 +65,9 @@ public class HealthMainService {
 
 
         Map<String, Object> map = new HashMap<>();
-
-        for (ProBasicPowerstation wp : CacheContext.wpls) {
+        HttpServletRequest request = ((ServletRequestAttributes) (RequestContextHolder.currentRequestAttributes())).getRequest();
+        List<ProBasicPowerstation> wpls = tokenService.getWpls(request);
+        for (ProBasicPowerstation wp : wpls) {
 
 
             int ysl = 0;// 优数量
@@ -208,7 +214,9 @@ public class HealthMainService {
             if (CacheContext.wpmap.containsKey(wpId)) {
                 wtls = CacheContext.wpwtmap.get(wpId);
             } else {
-                wtls = new ArrayList<>(CacheContext.wtls);
+                HttpServletRequest request = ((ServletRequestAttributes) (RequestContextHolder.currentRequestAttributes())).getRequest();
+                wtls = tokenService.getWtls(request);
+
             }
 
             List<String> wtidls = new ArrayList<>();
@@ -315,8 +323,11 @@ public class HealthMainService {
 
         List<Map<String, Object>> wpmapls = new ArrayList<>();
         List<Map<String, String>> stoptypels = new ArrayList<>();
+
+        HttpServletRequest request = ((ServletRequestAttributes) (RequestContextHolder.currentRequestAttributes())).getRequest();
+        List<ProBasicPowerstation> wpls = tokenService.getWpls(request);
         // 获得天气预报每小时数据
-        for (ProBasicPowerstation wp : CacheContext.wpls) {
+        for (ProBasicPowerstation wp : wpls) {
 
 
             Map<String, Object> wpmap = new HashMap<>();
@@ -1023,7 +1034,11 @@ public class HealthMainService {
         //        Map<String, List<MatrixVo>> fjmap = new HashMap<>();
         List<List<MatrixVo>> fjvos = new ArrayList<>();
         Map<String, Map<String, Object>> fczbmap = new LinkedHashMap<>();
-        for (ProBasicPowerstation wp : CacheContext.wpls) {
+
+        HttpServletRequest request = ((ServletRequestAttributes) (RequestContextHolder.currentRequestAttributes())).getRequest();
+        List<ProBasicPowerstation> wpls = tokenService.getWpls(request);
+
+        for (ProBasicPowerstation wp : wpls) {
 
             Map<String, Object> jczbmap = new HashMap<>();
 

web/health/src/main/java/com/gyee/health/service/health/HealthOperationService.java

@@ -6,12 +6,16 @@ import com.gyee.health.init.CacheContext;
 import com.gyee.health.model.auto.ProBasicPowerstation;
 import com.gyee.health.model.auto.ProBasicPowerstationPoint;
 import com.gyee.health.model.auto.ProBasicProject;
+import com.gyee.health.service.TokenService;
 import com.gyee.health.service.auto.*;
 import com.gyee.health.util.IRealTimeDataBaseUtil;
 import com.gyee.health.util.RealTimeDataBaseFactory;
 import org.springframework.stereotype.Service;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
 
 import javax.annotation.Resource;
+import javax.servlet.http.HttpServletRequest;
 import java.text.SimpleDateFormat;
 import java.util.*;
 
@@ -28,7 +32,8 @@ public class HealthOperationService {
     private IProEconShutdownEventService proEconShutdownEventService;
     @Resource
     private IProBasicPowerstationPointService proBasicPowerstationPointService;
-
+    @Resource
+    private TokenService tokenService;
     private final String QS = "0";
 
     private final int digit = 2;
@@ -93,7 +98,10 @@ public class HealthOperationService {
         List<Integer> yzList = new ArrayList<Integer>();
         List<String> name = new ArrayList<String>();
         if ("1".equals(type)) {
-            List<ProBasicPowerstation> wpList = CacheContext.wpls;
+
+            HttpServletRequest request = ((ServletRequestAttributes) (RequestContextHolder.currentRequestAttributes())).getRequest();
+            List<ProBasicPowerstation> wpls = tokenService.getWpls(request);
+            List<ProBasicPowerstation> wpList = wpls;
             for (int i = 0; i < wpList.size(); i++) {
 
                 List<String> idls=new ArrayList<>();
@@ -198,7 +206,9 @@ public class HealthOperationService {
         Long end = new Date().getTime();
         List<Map<String,String>> nameList = new ArrayList<>();
         if ("1".equals(type)) {
-            List<ProBasicPowerstation> wpList = CacheContext.wpls;
+            HttpServletRequest request = ((ServletRequestAttributes) (RequestContextHolder.currentRequestAttributes())).getRequest();
+            List<ProBasicPowerstation> wpls = tokenService.getWpls(request);
+            List<ProBasicPowerstation> wpList = wpls;
             Map<String,String> map=new HashMap<>();
             for (int i = 0; i < wpList.size(); i++) {
                 List<Integer> hgList = new ArrayList<>();

web/health/src/main/java/com/gyee/health/service/health/LossPowerRateHealthService.java

@@ -11,13 +11,17 @@ import com.gyee.health.model.auto.ProBasicPowerstation;
 import com.gyee.health.model.custom.HealthmodelrecordsVo;
 import com.gyee.health.model.custom.TotalNumVo;
 import com.gyee.health.model.custom.TotalNumsVo;
+import com.gyee.health.service.TokenService;
 import com.gyee.health.service.auto.IProBasicEquipmentPointService;
 import com.gyee.health.util.IRealTimeDataBaseUtil;
 import com.gyee.health.util.RealTimeDataBaseFactory;
 import com.gyee.health.util.StringUtils;
 import org.springframework.stereotype.Service;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
 
 import javax.annotation.Resource;
+import javax.servlet.http.HttpServletRequest;
 import java.text.SimpleDateFormat;
 import java.util.*;
 
@@ -28,7 +32,8 @@ public class LossPowerRateHealthService {
     private AlarmsnapMapper alarmsnapMapper;
     @Resource
     private IProBasicEquipmentPointService proBasicEquipmentPointService;
-
+    @Resource
+    private TokenService tokenService;
 
     IRealTimeDataBaseUtil realApiUtil = RealTimeDataBaseFactory.createRealTimeDataBase();
     private final int digit = 2;
@@ -190,8 +195,9 @@ public class LossPowerRateHealthService {
         Date endDate = cal.getTime();
         cal.add(Calendar.MINUTE, -3);
         Date beginDate = cal.getTime();
-
-        for (ProBasicPowerstation wp : CacheContext.wpls) {
+        HttpServletRequest request = ((ServletRequestAttributes) (RequestContextHolder.currentRequestAttributes())).getRequest();
+        List<ProBasicPowerstation> wpls = tokenService.getWpls(request);
+        for (ProBasicPowerstation wp : wpls) {
             if (wp.getId().endsWith("_FDC")) {
 
 //                StringBuilder tablename = new StringBuilder();

web/health/src/main/java/com/gyee/health/service/health/PowerToPowerService.java

@@ -4,9 +4,14 @@ package com.gyee.health.service.health;
 import com.gyee.health.init.CacheContext;
 import com.gyee.health.model.auto.ProBasicEquipment;
 import com.gyee.health.model.auto.ProEconWtPowerCurveFitting;
+import com.gyee.health.service.TokenService;
 import com.gyee.health.util.StringUtils;
 import org.springframework.stereotype.Service;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
 
+import javax.annotation.Resource;
+import javax.servlet.http.HttpServletRequest;
 import java.math.BigDecimal;
 import java.math.RoundingMode;
 import java.util.*;
@@ -18,7 +23,8 @@ public class PowerToPowerService {
 	private final String QS = "0";
 	private final String FD = "-1";
 	private final String GF = "-2";
-
+	@Resource
+	private TokenService tokenService;
 	public double getPowerByWp(double speed, String wpId, double step) {
 		double power = 0.0;
 		List<ProBasicEquipment> wtls=new ArrayList<>();
@@ -26,7 +32,10 @@ public class PowerToPowerService {
 		{
 
 		}else if(wpId.equals(FD)) {
-			for(ProBasicEquipment wt: CacheContext.wtls)
+
+			HttpServletRequest request = ((ServletRequestAttributes) (RequestContextHolder.currentRequestAttributes())).getRequest();
+			List<ProBasicEquipment> wtTokenls = tokenService.getWtls(request);
+			for(ProBasicEquipment wt: wtTokenls)
 			{
 				if (wt.getWindpowerstationId().endsWith("FDC"))
 				{
@@ -74,14 +83,19 @@ public class PowerToPowerService {
 	public double getPowerByWp(Map<Double, Integer> speedmap, String wpId, double step) {
 		double power = 0.0;
 		List<ProBasicEquipment> wtls=new ArrayList<>();
+
+		HttpServletRequest request = ((ServletRequestAttributes) (RequestContextHolder.currentRequestAttributes())).getRequest();
+		List<ProBasicEquipment> wtTokenls = tokenService.getWtls(request);
 		if(wpId.equals(QS))
 		{
-			for(ProBasicEquipment wt:CacheContext.wtls)
+
+			for(ProBasicEquipment wt:wtTokenls)
 			{
 				wtls.add(wt);
 			}
 		}else if(wpId.equals(FD)) {
-			for(ProBasicEquipment wt:CacheContext.wtls)
+
+			for(ProBasicEquipment wt:wtTokenls)
 			{
 				if (wt.getWindpowerstationId().endsWith("FDC"))
 				{

web/health/src/main/java/com/gyee/health/service/recommen/RecommenService.java

@@ -8,14 +8,18 @@ import com.gyee.health.model.auto.ProBasicEquipmentPoint;
 import com.gyee.health.model.auto.ProEconRecommenMain;
 import com.gyee.health.model.vo.HealthStatusValue;
 import com.gyee.health.model.vo.ProEconRecommenMainVo;
+import com.gyee.health.service.TokenService;
 import com.gyee.health.service.auto.IProBasicEquipmentPointService;
 import com.gyee.health.service.auto.IProEconRecommenMainService;
 import com.gyee.health.util.IRealTimeDataBaseUtil;
 import com.gyee.health.util.RealTimeDataBaseFactory;
 import com.gyee.health.util.StringUtils;
 import org.springframework.stereotype.Service;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
 
 import javax.annotation.Resource;
+import javax.servlet.http.HttpServletRequest;
 import java.math.BigDecimal;
 import java.math.RoundingMode;
 import java.text.SimpleDateFormat;
@@ -37,7 +41,8 @@ public class RecommenService {
 	private IProEconRecommenMainService proEconRecommenMainService;
 	@Resource
 	private IProBasicEquipmentPointService proBasicEquipmentPointService;
-	
+	@Resource
+	private TokenService tokenService;
 
 	private final String QS = "0";
 	private final String FD = "-1";
@@ -295,7 +300,9 @@ public class RecommenService {
 			List<ProBasicEquipment> wtls = new ArrayList<ProBasicEquipment>();
 
 			if (wpId.equals(QS) || wpId.equals(FD) || wpId.equals(GF)) {
-				for (ProBasicEquipment wt : CacheContext.wtls) {
+				HttpServletRequest request = ((ServletRequestAttributes) (RequestContextHolder.currentRequestAttributes())).getRequest();
+				List<ProBasicEquipment> wtTokenls = tokenService.getWtls(request);
+				for (ProBasicEquipment wt : wtTokenls) {
 					wtls.add(wt);
 				}
 			}else if (CacheContext.wpmap.containsKey(wpId)) {

web/health/src/main/java/com/gyee/health/util/redis/RedisAutoConfiguration.java

@@ -0,0 +1,44 @@
+package com.gyee.health.util.redis;
+
+import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
+import org.springframework.boot.autoconfigure.data.redis.RedisProperties;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.core.RedisOperations;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.core.StringRedisTemplate;
+
+import java.net.UnknownHostException;
+
+@Configuration
+@ConditionalOnClass(RedisOperations.class)
+@EnableConfigurationProperties(RedisProperties.class)
+public class RedisAutoConfiguration {
+
+
+    @Bean
+    @ConditionalOnMissingBean(name = "redisTemplate")
+    public RedisTemplate<Object, Object> redisTemplate(
+            RedisConnectionFactory redisConnectionFactory) throws UnknownHostException {
+        RedisTemplate<Object, Object> template = new RedisTemplate<>();
+        template.setConnectionFactory(redisConnectionFactory);
+        return template;
+
+    }
+
+
+    @Bean
+    @ConditionalOnMissingBean
+    public StringRedisTemplate stringRedisTemplate(
+            RedisConnectionFactory redisConnectionFactory) throws UnknownHostException {
+        StringRedisTemplate template = new StringRedisTemplate();
+        template.setConnectionFactory(redisConnectionFactory);
+        return template;
+
+    }
+
+
+}

web/health/src/main/java/com/gyee/health/util/redis/RedisConfig.java

@@ -0,0 +1,47 @@
+package com.gyee.health.util.redis;
+
+import com.fasterxml.jackson.annotation.JsonAutoDetect;
+import com.fasterxml.jackson.annotation.PropertyAccessor;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
+import org.springframework.data.redis.serializer.StringRedisSerializer;
+
+
+/**
+
+/**
+ *@ClassName RedisConfig
+ *@Description TODO
+ *@Author 谢生杰
+ *@Date 2020/9/14 10:42
+ *@Version 1.0
+ **/
+@Configuration
+public class RedisConfig {
+    @Bean
+    @SuppressWarnings("all")
+    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
+        RedisTemplate<String, Object> template = new RedisTemplate<String, Object>();
+        template.setConnectionFactory(factory);
+        Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
+        ObjectMapper om = new ObjectMapper();
+        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
+        om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
+        jackson2JsonRedisSerializer.setObjectMapper(om);
+        StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
+        // key采用String的序列化方式
+        template.setKeySerializer(stringRedisSerializer);
+        // hash的key也采用String的序列化方式
+        template.setHashKeySerializer(stringRedisSerializer);
+        // value序列化方式采用jackson
+        template.setValueSerializer(jackson2JsonRedisSerializer);
+        // hash的value序列化方式采用jackson
+        template.setHashValueSerializer(jackson2JsonRedisSerializer);
+        template.afterPropertiesSet();
+        return template;
+    }
+}

web/health/src/main/java/com/gyee/health/util/redis/RedisService.java

@@ -0,0 +1,51 @@
+package com.gyee.health.util.redis;
+
+public interface RedisService {
+
+    /**
+     * set存数据
+     * @param key
+     * @param value
+     * @return
+     */
+    boolean set(String key, String value);
+
+
+
+    /**
+     * get获取数据
+     * @param key
+     * @return
+     */
+    String get(String key);
+
+//    void getList(String key,int start,int end);
+
+    /**
+     * 设置有效天数
+     * @param key
+     * @param expire
+     * @return
+     */
+    boolean expire(String key, long expire);
+
+    /**
+     * 移除数据
+     * @param key
+     * @return
+     */
+    boolean remove(String key);
+
+
+    /**
+     * 插入对象
+     */
+    void setObject(Object o);
+
+
+    boolean hasKey(String key);
+
+
+    void select(Integer dbIndex);
+
+}

web/health/src/main/java/com/gyee/health/util/redis/RedisServiceImpl.java

@@ -0,0 +1,125 @@
+package com.gyee.health.util.redis;
+
+import org.springframework.dao.DataAccessException;
+import org.springframework.data.redis.connection.RedisConnection;
+import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
+import org.springframework.data.redis.core.RedisCallback;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.serializer.RedisSerializer;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.lang.reflect.Field;
+import java.util.concurrent.TimeUnit;
+
+@Service("redisService")
+public class RedisServiceImpl implements RedisService {
+
+    @Resource
+    private RedisTemplate<String, ?> redisTemplate;
+
+    @Override
+    public boolean set(final String key, final String value) {;
+        boolean result = redisTemplate.execute(new RedisCallback<Boolean>() {
+            @Override
+            public Boolean doInRedis(RedisConnection connection) throws DataAccessException {
+                RedisSerializer<String> serializer = redisTemplate.getStringSerializer();
+                connection.set(serializer.serialize(key), serializer.serialize(value));
+                return true;
+            }
+        });
+        return result;
+    }
+
+
+    @Override
+    public String get(final String key) {
+        String result = redisTemplate.execute(new RedisCallback<String>() {
+            @Override
+            public String doInRedis(RedisConnection connection) throws DataAccessException {
+                RedisSerializer<String> serializer = redisTemplate.getStringSerializer();
+                byte[] value = connection.get(serializer.serialize(key));
+                return serializer.deserialize(value);
+            }
+        });
+        return result;
+    }
+
+
+
+    @Override
+    public boolean expire(final String key, long expire) {
+        return redisTemplate.expire(key, expire, TimeUnit.SECONDS);
+    }
+
+    @Override
+    public boolean remove(final String key) {
+        boolean result = redisTemplate.execute(new RedisCallback<Boolean>() {
+            @Override
+            public Boolean doInRedis(RedisConnection connection) throws DataAccessException {
+                RedisSerializer<String> serializer = redisTemplate.getStringSerializer();
+                connection.del(key.getBytes());
+                return true;
+            }
+        });
+        return result;
+    }
+
+    @Override
+    public boolean hasKey(final String key) {
+        try {
+            return redisTemplate.hasKey(key);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    @Override
+    public void setObject(Object obj) {
+        Field[] fields = obj.getClass().getDeclaredFields();
+        for(int i = 0 , len = fields.length; i < len; i++) {
+            // 对于每个属性，获取属性名
+            String varName = fields[i].getName();
+            try {
+                // 获取原来的访问控制权限
+                boolean accessFlag = fields[i].isAccessible();
+                // 修改访问控制权限
+                fields[i].setAccessible(true);
+                // 获取在对象f中属性fields[i]对应的对象中的变量
+                Object o;
+                try {
+                    o = fields[i].get(obj);
+                    if (o!=null){
+                        set(varName, String.valueOf(o));
+                    }else {
+                        set(varName,"");
+                    }
+
+                    //System.err.println("传入的对象中包含一个如下的变量：" + varName + " = " + o);
+                } catch (IllegalAccessException e) {
+                    // TODO Auto-generated catch block
+                    e.printStackTrace();
+                }
+                // 恢复访问控制权限
+                fields[i].setAccessible(accessFlag);
+            } catch (IllegalArgumentException ex) {
+                ex.printStackTrace();
+            }
+        }
+
+    }
+
+    public void select(Integer dbIndex) {
+        if (dbIndex == null || dbIndex > 15 || dbIndex < 0) {
+            dbIndex = 0;
+        }
+        LettuceConnectionFactory jedisConnectionFactory = (LettuceConnectionFactory) redisTemplate
+                .getConnectionFactory();
+        jedisConnectionFactory.setDatabase(dbIndex);
+        redisTemplate.setConnectionFactory(jedisConnectionFactory);
+        jedisConnectionFactory.afterPropertiesSet();
+//        jedisConnectionFactory.resetConnection();
+
+    }
+}

web/health/src/main/resources/application-jn.properties

@@ -3,8 +3,8 @@ server.port=8172
 
 #\u670D\u52A1\u540D\u79F0
 spring.application.name=health-hb-provider
-spring.cloud.nacos.discovery.server-addr=10.81.3.155:8848
-#spring.cloud.nacos.discovery.server-addr=127.0.0.1:8870
+#spring.cloud.nacos.discovery.server-addr=10.81.3.155:8848
+spring.cloud.nacos.discovery.server-addr=127.0.0.1:8870
 
 #nacos\u7684\u7528\u6237\u540D\u548C\u5BC6\u7801
 spring.cloud.nacos.username=nacos