update 平台测试员状态

jsowell-admin/src/main/java/com/jsowell/web/controller/pile/MemberBasicInfoController.java

@@ -1,5 +1,6 @@
 package com.jsowell.web.controller.pile;
 
+import com.alibaba.fastjson2.JSON;
 import com.github.pagehelper.PageHelper;
 import com.google.common.collect.Lists;
 import com.jsowell.common.annotation.Log;
@@ -8,9 +9,11 @@ import com.jsowell.common.core.domain.AjaxResult;
 import com.jsowell.common.core.page.TableDataInfo;
 import com.jsowell.common.enums.BusinessType;
 import com.jsowell.common.enums.uniapp.BalanceChangesEnum;
+import com.jsowell.common.exception.BusinessException;
 import com.jsowell.common.util.StringUtils;
 import com.jsowell.pile.domain.MemberBasicInfo;
 import com.jsowell.pile.domain.MemberPlateNumberRelation;
+import com.jsowell.pile.dto.PlatformTesterDTO;
 import com.jsowell.pile.dto.UniAppQueryMemberBalanceDTO;
 import com.jsowell.pile.service.IMemberBasicInfoService;
 import com.jsowell.pile.service.IMemberPlateNumberRelationService;
@@ -18,6 +21,7 @@ import com.jsowell.pile.service.IMemberTransactionRecordService;
 import com.jsowell.pile.vo.uniapp.MemberVO;
 import com.jsowell.pile.vo.uniapp.MemberWalletLogVO;
 import com.jsowell.pile.vo.web.MemberTransactionVO;
+import com.jsowell.pile.vo.web.PlatformTesterVO;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.security.access.prepost.PreAuthorize;
 import org.springframework.web.bind.annotation.*;
@@ -76,7 +80,7 @@ public class MemberBasicInfoController extends BaseController {
 
     @PreAuthorize("@ss.hasPermi('member:info:query')")
     @GetMapping(value = "/getMemberPersonPileInfo/{memberId}")
-	public AjaxResult getMemberPersonPileInfo(@PathVariable("memberId") String memberId){
+    public AjaxResult getMemberPersonPileInfo(@PathVariable("memberId") String memberId) {
         return AjaxResult.success(memberBasicInfoService.getMemberPersonPileInfo(memberId));
     }
 
@@ -156,13 +160,14 @@ public class MemberBasicInfoController extends BaseController {
 
     /**
      * 修改车牌号信息
+     *
      * @param relation
      * @return
      */
     @PreAuthorize("@ss.hasPermi('member:info:edit')")
     @Log(title = "修改车牌号信息", businessType = BusinessType.UPDATE)
     @PostMapping("/updatePlateNumber")
-	public AjaxResult updatePlateNumber(@RequestBody MemberPlateNumberRelation relation){
+    public AjaxResult updatePlateNumber(@RequestBody MemberPlateNumberRelation relation) {
         int i = memberPlateNumberRelationService.updatePlateNumber(relation);
         logger.info("后管修改用户：{} 的车牌号：{}", relation.getMemberId(), relation.getLicensePlateNumber());
         return toAjax(i);
@@ -174,7 +179,7 @@ public class MemberBasicInfoController extends BaseController {
     @PreAuthorize("@ss.hasPermi('member:info:remove')")
     @Log(title = "会员绑定的车牌号信息", businessType = BusinessType.DELETE)
     @PostMapping("/deletePlateNumber")
-	public AjaxResult deletePlateNumber(@RequestBody MemberPlateNumberRelation relation){
+    public AjaxResult deletePlateNumber(@RequestBody MemberPlateNumberRelation relation) {
         int i = memberPlateNumberRelationService.unbindingPlateNumber(relation.getMemberId(), relation.getLicensePlateNumber());
         logger.info("后管解除绑定用户：{} 的车牌号：{}", relation.getMemberId(), relation.getLicensePlateNumber());
         return toAjax(i);
@@ -182,10 +187,35 @@ public class MemberBasicInfoController extends BaseController {
 
     /**
      * 修改平台测试员状态
-	 *
+     * http://localhost:8080/member/info/updatePlatformTester
      */
-	public AjaxResult updatePlatformTester() {
+    @PostMapping("/updatePlatformTester")
-		AjaxResult result = new AjaxResult();
+    public AjaxResult updatePlatformTester(@RequestBody PlatformTesterDTO dto) {
+        AjaxResult result;
+        try {
+            memberBasicInfoService.updatePlatformTester(dto);
+            result = AjaxResult.success();
+        } catch (BusinessException e) {
+            logger.error("修改平台测试员状态error param:{}", JSON.toJSONString(dto), e);
+            result = AjaxResult.error(e.getMessage());
+        }
+        return result;
+    }
+
+    /**
+     * 查询平台测试员状态
+     * http://localhost:8080/member/info/selectPlatformTesterStatus
+     */
+    @PostMapping("/selectPlatformTesterStatus")
+    public AjaxResult selectPlatformTesterStatus(@RequestBody PlatformTesterDTO dto) {
+        AjaxResult result;
+        try {
+            PlatformTesterVO platformTesterVO = memberBasicInfoService.selectPlatformTesterStatus(dto);
+            result = AjaxResult.success(platformTesterVO);
+        } catch (BusinessException e) {
+            logger.error("查询平台测试员状态error param:{}", JSON.toJSONString(dto), e);
+            result = AjaxResult.error(e.getMessage());
+        }
         return result;
     }
 }

jsowell-common/src/main/java/com/jsowell/common/constant/CacheConstants.java

@@ -6,10 +6,6 @@ package com.jsowell.common.constant;
  * @author jsowell
  */
 public class CacheConstants {
-	/**
-	 *
-	 */
-
 
 	public static final int cache_expire_time_1m = 60;
 
@@ -23,6 +19,8 @@ public class CacheConstants {
 
 	public static final int cache_expire_time_1d = 60 * 60 * 24;
 
+	public static final String PLATFORM_TESTER = "platform_tester:";
+
 	public static final String GET_PILE_MODEL_INFO_BY_MODEL_ID = "get_pile_model_info_by_model_id:";
 
 	// 根据站点id查询充电桩列表

jsowell-pile/src/main/java/com/jsowell/pile/dto/PlatformTesterDTO.java

@@ -0,0 +1,21 @@
+package com.jsowell.pile.dto;
+
+import lombok.*;
+
+@Getter
+@Setter
+@NoArgsConstructor
+@AllArgsConstructor
+@Builder
+public class PlatformTesterDTO {
+    /**
+     * 会员id
+     */
+    private String memberId;
+
+    /**
+     * 平台测试员状态
+     * 1-是；0-否
+     */
+    private String status;
+}

jsowell-pile/src/main/java/com/jsowell/pile/service/IMemberBasicInfoService.java

@@ -1,10 +1,11 @@
 package com.jsowell.pile.service;
 
 import com.jsowell.pile.domain.MemberBasicInfo;
-import com.jsowell.pile.dto.BindingCarNoDTO;
+import com.jsowell.pile.dto.PlatformTesterDTO;
 import com.jsowell.pile.vo.uniapp.MemberVO;
 import com.jsowell.pile.vo.uniapp.MemberWalletLogVO;
 import com.jsowell.pile.vo.uniapp.PersonalPileInfoVO;
+import com.jsowell.pile.vo.web.PlatformTesterVO;
 import com.jsowell.pile.vo.web.UpdateMemberBalanceDTO;
 
 import java.util.List;
@@ -117,4 +118,7 @@ public interface IMemberBasicInfoService {
 	 */
 	List<PersonalPileInfoVO> getMemberPersonPileInfo(String memberId);
 
+    void updatePlatformTester(PlatformTesterDTO dto);
+
+	PlatformTesterVO selectPlatformTesterStatus(PlatformTesterDTO dto);
 }

jsowell-pile/src/main/java/com/jsowell/pile/service/impl/MemberBasicInfoServiceImpl.java

@@ -1,12 +1,16 @@
 package com.jsowell.pile.service.impl;
 
 import com.google.common.collect.Lists;
+import com.jsowell.common.constant.CacheConstants;
+import com.jsowell.common.constant.Constants;
+import com.jsowell.common.core.redis.RedisCache;
 import com.jsowell.common.util.DateUtils;
 import com.jsowell.common.util.StringUtils;
 import com.jsowell.pile.domain.MemberBasicInfo;
 import com.jsowell.pile.domain.MemberPlateNumberRelation;
 import com.jsowell.pile.domain.MemberWalletInfo;
 import com.jsowell.pile.domain.MemberWalletLog;
+import com.jsowell.pile.dto.PlatformTesterDTO;
 import com.jsowell.pile.mapper.MemberBasicInfoMapper;
 import com.jsowell.pile.mapper.MemberPlateNumberRelationMapper;
 import com.jsowell.pile.mapper.MemberWalletInfoMapper;
@@ -16,6 +20,7 @@ import com.jsowell.pile.service.IPileBasicInfoService;
 import com.jsowell.pile.vo.uniapp.MemberVO;
 import com.jsowell.pile.vo.uniapp.MemberWalletLogVO;
 import com.jsowell.pile.vo.uniapp.PersonalPileInfoVO;
+import com.jsowell.pile.vo.web.PlatformTesterVO;
 import com.jsowell.pile.vo.web.UpdateMemberBalanceDTO;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
@@ -49,6 +54,9 @@ public class MemberBasicInfoServiceImpl implements IMemberBasicInfoService {
 
 	@Autowired
 	private MemberPlateNumberRelationMapper memberPlateNumberRelationMapper;
+
+	@Autowired
+	private RedisCache redisCache;
 	/**
 	 * 查询会员基础信息
 	 *
@@ -282,5 +290,35 @@ public class MemberBasicInfoServiceImpl implements IMemberBasicInfoService {
 		return pileBasicInfoService.getPileInfoByMemberId(memberId);
 	}
 
+    @Override
+    public void updatePlatformTester(PlatformTesterDTO dto) {
+        if (StringUtils.isBlank(dto.getMemberId()) || StringUtils.isBlank(dto.getStatus())) {
+			return;
+		}
+
+		String redisKey = CacheConstants.PLATFORM_TESTER + dto.getMemberId();
+		if (StringUtils.equals(dto.getStatus(), Constants.ONE)) {
+			// 放缓存
+			redisCache.setCacheObject(redisKey, Constants.ONE);
+		} else {
+			// 清缓存
+			redisCache.deleteObject(redisKey);
+		}
+    }
+
+	@Override
+	public PlatformTesterVO selectPlatformTesterStatus(PlatformTesterDTO dto) {
+		PlatformTesterVO vo = new PlatformTesterVO();
+		String redisKey = CacheConstants.PLATFORM_TESTER + dto.getMemberId();
+		String status = redisCache.getCacheObject(redisKey);
+		if (StringUtils.isNotBlank(status)) {
+			vo.setStatus(status);
+		} else {
+			vo.setStatus(Constants.ZERO);
+		}
+		vo.setMemberId(dto.getMemberId());
+		return vo;
+	}
+
 
 }

jsowell-pile/src/main/java/com/jsowell/pile/vo/web/PlatformTesterVO.java

@@ -0,0 +1,21 @@
+package com.jsowell.pile.vo.web;
+
+import lombok.*;
+
+@Getter
+@Setter
+@NoArgsConstructor
+@AllArgsConstructor
+@Builder
+public class PlatformTesterVO {
+    /**
+     * 会员id
+     */
+    private String memberId;
+
+    /**
+     * 平台测试员状态
+     * 1-是；0-否
+     */
+    private String status;
+}