fix

netflix-dao/src/main/java/com/cyksj/mapper/corp/kf/CorpKfAccountUserChangeRecordMapper.java

@@ -0,0 +1,13 @@
+package com.cyksj.mapper.corp.kf;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.cyksj.model.entity.CorpKfAccountUserChangeRecord;
+
+/**
+ * 项目名: yhlxj2
+ * 文件名: CorpKfAccountUserChangeRecordMapper
+ * 创建者: JavaZou
+ * 创建时间:2025/1/10 10:27
+ */
+public interface CorpKfAccountUserChangeRecordMapper extends BaseMapper<CorpKfAccountUserChangeRecord> {
+}

netflix-dao/src/main/java/com/cyksj/model/entity/CorpKfAccountUserChangeRecord.java

@@ -0,0 +1,18 @@
+package com.cyksj.model.entity;
+
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * 项目名: yhlxj2
+ * 文件名: CorpKfAccountUserChangeRecord
+ * 创建者: JavaZou
+ * 创建时间:2025/1/10 10:26
+ */
+@Getter
+@Setter
+public class CorpKfAccountUserChangeRecord extends BaseEntity{
+	private Long cmsUserId;
+
+	private String openKfId;
+}

netflix-web/src/main/java/com/cyksj/web/controller/manage/corp/wxkf/CorpKfController.java

@@ -7,6 +7,7 @@ import com.cyksj.dto.Result;
 import com.cyksj.enums.BusinessType;
 import com.cyksj.enums.GatewayResponse;
 import com.cyksj.mapper.corp.CorpFollowMapper;
+import com.cyksj.mapper.corp.kf.CorpKfAccountUserChangeRecordMapper;
 import com.cyksj.model.entity.*;
 import com.cyksj.model.request.CorpKfDutySetReq;
 import com.cyksj.model.request.corp.kf.CorpKfDutyReq;
@@ -22,11 +23,13 @@ import com.ejlchina.searcher.util.MapBuilder;
 import com.ejlchina.searcher.util.MapUtils;
 import lombok.RequiredArgsConstructor;
 import org.apache.commons.lang3.StringUtils;
+import org.springframework.dao.DuplicateKeyException;
 import org.springframework.web.bind.annotation.*;
 
 import javax.servlet.http.HttpServletRequest;
 import java.util.List;
 import java.util.Map;
+import java.util.Optional;
 import java.util.stream.Collectors;
 
 /**
@@ -50,6 +53,8 @@ public class CorpKfController {
 
 	private final CorpFollowMapper corpFollowMapper;
 
+	private final CorpKfAccountUserChangeRecordMapper corpKfAccountUserChangeRecordMapper;
+
 
 	/**
 	 * 添加客服账号
@@ -239,4 +244,39 @@ public class CorpKfController {
 		return GatewayResponse.SUCCESS.newBuilder().toResult(corpKfAccounts);
 	}
 
+	/**
+	 * 记录用户切换客服记录
+	 */
+	@PostMapping("/change/account/record/{openKfId}")
+	public Result<String> recordUserAccountRecord(@PathVariable String openKfId) {
+		long cmsUserId = StpUtil.getLoginIdAsLong();
+		CorpKfAccountUserChangeRecord corpKfAccountUserChangeRecord = Optional.ofNullable(corpKfAccountUserChangeRecordMapper.selectOne(Wrappers.lambdaQuery(CorpKfAccountUserChangeRecord.class)
+				.eq(CorpKfAccountUserChangeRecord::getCmsUserId, cmsUserId)
+				.last("limit 1"))).orElse(new CorpKfAccountUserChangeRecord());
+		corpKfAccountUserChangeRecord.setCmsUserId(cmsUserId);
+		corpKfAccountUserChangeRecord.setOpenKfId(openKfId);
+		if (corpKfAccountUserChangeRecord.getId() == null) {
+			try {
+				corpKfAccountUserChangeRecordMapper.insert(corpKfAccountUserChangeRecord);
+			} catch (DuplicateKeyException e) {
+			}
+		} else {
+			corpKfAccountUserChangeRecordMapper.updateById(corpKfAccountUserChangeRecord);
+		}
+
+		return GatewayResponse.SUCCESS.newBuilder().toResult();
+	}
+
+	/**
+	 * 用户切换德微信账号
+	 */
+	@PostMapping("/get/change/account")
+	public Result<CorpKfAccountUserChangeRecord> getChangeAccount() {
+		long cmsUserId = StpUtil.getLoginIdAsLong();
+		CorpKfAccountUserChangeRecord corpKfAccountUserChangeRecord = Optional.ofNullable(corpKfAccountUserChangeRecordMapper.selectOne(Wrappers.lambdaQuery(CorpKfAccountUserChangeRecord.class)
+				.eq(CorpKfAccountUserChangeRecord::getCmsUserId, cmsUserId)
+				.last("limit 1"))).orElse(new CorpKfAccountUserChangeRecord());
+		return GatewayResponse.SUCCESS.newBuilder().toResult(corpKfAccountUserChangeRecord);
+	}
+
 }