设备客服用户获取

netflix-service/src/main/java/com/cyksj/redis/RedisService.java

@@ -669,6 +669,7 @@ public class RedisService {
         DOUBLE_VERIFY_CODE_VIEW_MINUTES_KEY("double_verify_code_view_minutes_key","双重验证码查看同时间段人数限制",60),
 
         WX_INDENT_BIND_KEY("wx_indent_bind:key:", "微信身份授权绑定key", 60 * 60 * 24),
+        EQUIPMENT_USER_SERVICE_RECORD("equipment_user_service_record:", "用户设备客服获取记录key", 60 * 60 * 24),
         ;
 
         private String name;

netflix-web/src/main/java/com/cyksj/web/controller/sys/SysConfigController.java

@@ -2,6 +2,8 @@ package com.cyksj.web.controller.sys;
 
 import cn.dev33.satoken.stp.StpUtil;
 import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.date.DateTime;
+import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.StrUtil;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
@@ -21,8 +23,10 @@ import com.cyksj.model.entity.HelpQuestionClassification;
 import com.cyksj.model.entity.SysConfig;
 import com.cyksj.model.entity.SysConfigChangeRecord;
 import com.cyksj.model.views.HelpQuestionClassificationView;
+import com.cyksj.redis.RedisService;
 import com.cyksj.service.sys.SysConfigChangeRecordService;
 import com.cyksj.service.sys.SysConfigService;
+import com.cyksj.web.util.StpUserUtil;
 import com.cyksj.xxljob.XxlJobInfo;
 import com.cyksj.xxljob.XxlJobUtil;
 import com.ejlchina.searcher.BeanSearcher;
@@ -58,6 +62,8 @@ public class SysConfigController {
 
 	private final HttpServletRequest request;
 
+	private final RedisService redisService;
+
 	private final SysConfigChangeRecordService sysConfigChangeRecordService;
 
 	@GetMapping("/get")
@@ -181,4 +187,26 @@ public class SysConfigController {
 				.build());
 		return GatewayResponse.SUCCESS.newBuilder().toResult(search);
 	}
+
+	/**
+	 * 当前用户是否获取了客服
+	 */
+	@GetMapping("/get/service/indx")
+	public Result getServiceIndx() {
+		long userId = StpUserUtil.getLoginIdAsLong();
+		long time = DateUtil.beginOfDay(DateTime.now()).getTime();
+		Object re = redisService.get(RedisService.key.EQUIPMENT_USER_SERVICE_RECORD.getEnvName() + time + userId);
+		return GatewayResponse.SUCCESS.newBuilder().toResult(re);
+	}
+
+	/**
+	 * 记录用户获取的客服
+	 */
+	@PostMapping("/service/record/{indx}")
+	public Result<Integer> serviceRecord(@PathVariable Long indx) {
+		long userId = StpUserUtil.getLoginIdAsLong();
+		long time = DateUtil.beginOfDay(DateTime.now()).getTime();
+		redisService.set(RedisService.key.EQUIPMENT_USER_SERVICE_RECORD.getEnvName() + time + userId, indx, RedisService.key.EQUIPMENT_USER_SERVICE_RECORD.getTimeout());
+		return GatewayResponse.SUCCESS.newBuilder().toResult();
+	}
 }