1.临时账号：两次发送消息

src/main/java/com/rf/AIquantum/dialogue/rest/DialogueController.java

@@ -12,7 +12,9 @@ import com.rf.AIquantum.dialogue.dao.model.DialogueEntity;
 import com.rf.AIquantum.dialogue.service.ChatHistoryService;
 import com.rf.AIquantum.dialogue.service.DialogueService;
 import com.rf.AIquantum.filter.JwtIgnore;
+import com.rf.AIquantum.user.dao.model.TempUserEntity;
 import com.rf.AIquantum.user.dao.model.UserEntity;
+import com.rf.AIquantum.user.service.TempUserService;
 import com.rf.AIquantum.user.service.UserService;
 import com.rf.AIquantum.utils.*;
 import io.swagger.annotations.Api;
@@ -71,14 +73,29 @@ public class DialogueController extends BaseController {
     @Autowired
     private SseEmitterService sseEmitterService;
 
+    @Autowired
+    private TempUserService tempUserService;
+
     @PostMapping("/saveChat")
     @JwtIgnore
     @ApiOperation(value = "保存对话", notes = "参数包括：phone:手机号, dialogueId:对话id（为空时是新建对话）, content:消息内容,image：图片（可以为空）")
     public Result saveChat(MultipartFile image, String phone, String dialogueId, String content) {
-        UserEntity user = this.userService.findUserByPhone(phone);
-        if (user == null) {
-            return fail(null, "用户不存在");
+        TempUserEntity tempUser = this.tempUserService.findByIp(phone);
+        if (tempUser != null) {
+            if (tempUser.getRemainingCount() <= 0) {
+                return fail("体验次数已用完，请注册新账号！");
+            } else {
+                tempUser.setRemainingCount(tempUser.getRemainingCount() - 1);
+                this.tempUserService.save(tempUser);
+            }
+        }else {
+            UserEntity user = this.userService.findUserByPhone(phone);
+            if (user == null) {
+                return fail(null, "用户不存在");
+            }
         }
+
+
         String imageUrl = "";
         if (image != null) {
             if (!image.isEmpty()) {
@@ -220,17 +237,17 @@ public class DialogueController extends BaseController {
                         System.out.println("line==" + line);
                         JSONObject jsonObject = null;
                         try {
-                            if(StringUtils.isNotEmpty(line)){
-                                jsonObject=JSONObject.parseObject(line);
+                            if (StringUtils.isNotEmpty(line)) {
+                                jsonObject = JSONObject.parseObject(line);
                             }
 
                         } catch (Exception e) {
-                            log.error(line+"json解析失败",e);
+                            log.error(line + "json解析失败", e);
                             continue;
 
                         }
                         String event = jsonObject.getString("event");
-                        if(event.equals("error")){
+                        if (event.equals("error")) {
                             if (flag.equals("think")) {
                                 stringBuilder.append("</").append(flag).append(">");
                             }
@@ -239,22 +256,22 @@ public class DialogueController extends BaseController {
                         String data = jsonObject.getString("data");
                         if (StringUtils.isNotEmpty(data)) {
                             stringBuilder.append(data);
-                            if(data.contains("</think>")){
+                            if (data.contains("</think>")) {
                                 flag = "text";
-                                data = data.replace("</think>","");
+                                data = data.replace("</think>", "");
                             }
-                            if(data.contains("<think>")){
-                                data = data.replace("<think>","");
+                            if (data.contains("<think>")) {
+                                data = data.replace("<think>", "");
                             }
                             sseResultDataDto.setContent(data);
-                            log.info("发送消息:{}",sseResultDataDto);
+                            log.info("发送消息:{}", sseResultDataDto);
                             sseEmitterService.sendMessage(dialogueId, sseResultDataDto);
                         }
                         Thread.sleep(5);
                     }
                 } catch (InterruptedException e) {
                     throw new RuntimeException(e);
-                }finally {
+                } finally {
                     bufferedSource.close();
                 }
             }

src/main/java/com/rf/AIquantum/filter/JWTInterceptorConfig.java

@@ -25,7 +25,7 @@ public class JWTInterceptorConfig implements WebMvcConfigurer {
     @Override
     public void addInterceptors(InterceptorRegistry registry) {
         String[] swaggerExcludes = new String[]{"/swagger-ui.html", "/swagger-resources/**", "/csrf", "/webjars/**"};
-        String[] systemApi = new String[]{"/user/addUser","/user/login","/user/show"};
+        String[] systemApi = new String[]{"/user/addUser","/user/login","/user/show","/user/temp/login"};
         registry.addInterceptor(new AuthenticationInterceptor())
                 .addPathPatterns("/**")
                 .excludePathPatterns("/", "/index**", "/error")

src/main/java/com/rf/AIquantum/user/dao/model/TempUserEntity.java

@@ -0,0 +1,36 @@
+package com.rf.AIquantum.user.dao.model;
+
+import com.rf.AIquantum.base.model.BaseEntity;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.NoArgsConstructor;
+
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.persistence.Table;
+
+/**
+ * @Author:zzf
+ * @Date:2025/3/21:16:29
+ * @Description:
+ */
+@Entity
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+@Table(name = "t_temp_user_info")
+@EqualsAndHashCode(callSuper=true)
+@org.hibernate.annotations.Table(appliesTo = "t_temp_user_info", comment = "用户临时信息表")
+public class TempUserEntity extends BaseEntity {
+    @ApiModelProperty(value = "ip",required = true)
+    @Column(name = "ip",columnDefinition = "varchar(100) comment 'ip'")
+    private String ip;
+    @ApiModelProperty("用户名")
+    @Column(name = "username",columnDefinition = "varchar(100) comment '用户名'")
+    private String username;
+    @ApiModelProperty("剩余次数")
+    @Column(name = "remaining_count",columnDefinition = "int comment '剩余次数'")
+    private int remainingCount;
+}

src/main/java/com/rf/AIquantum/user/dao/repository/TempUserRepository.java

@@ -0,0 +1,8 @@
+package com.rf.AIquantum.user.dao.repository;
+
+import com.rf.AIquantum.base.repository.BaseRepository;
+import com.rf.AIquantum.user.dao.model.TempUserEntity;
+
+public interface TempUserRepository extends BaseRepository<TempUserEntity,String> {
+    TempUserEntity findByIp(String ip);
+}

src/main/java/com/rf/AIquantum/user/rest/UserController.java

@@ -3,13 +3,16 @@ package com.rf.AIquantum.user.rest;
 import cn.hutool.core.date.DateUtil;
 import com.alibaba.fastjson.JSONObject;
 import com.rf.AIquantum.base.rest.BaseController;
+import com.rf.AIquantum.user.dao.model.TempUserEntity;
 import com.rf.AIquantum.user.dao.model.UserEntity;
+import com.rf.AIquantum.user.service.TempUserService;
 import com.rf.AIquantum.user.service.UserService;
 import com.rf.AIquantum.utils.Constant;
 import com.rf.AIquantum.utils.JWTUtil;
 import com.rf.AIquantum.utils.Result;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
+import jdk.nashorn.internal.parser.Token;
 import org.apache.commons.io.FileUtils;
 import org.apache.commons.lang.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -38,6 +41,9 @@ public class UserController extends BaseController {
     @Autowired
     private UserService userService;
 
+    @Autowired
+    private TempUserService tempUserService;
+
     @PostMapping("/addUser")
     @ApiOperation(value = "新增用户",notes = "参数包括：userName:用户名, phone：手机号, password:密码(MD5加密后的字符串)")
     public Result addOrUpdateUser(@RequestBody String jsonParam){
@@ -243,4 +249,34 @@ public class UserController extends BaseController {
         }
     }*/
 
+
+    /**
+     * 临时登录
+     */
+    @ApiOperation(value = "临时登录",notes = "json字符串形式传参（加密）,data参数包括:userNo:账号" )
+    @GetMapping("/temp/login")
+    public Result login(@RequestParam String Ip){
+        TempUserEntity tempUserEntity = this.tempUserService.findByIp(Ip);
+        if(tempUserEntity == null){
+            tempUserEntity = new TempUserEntity();
+            tempUserEntity.setIp(Ip);
+            tempUserEntity.setRemainingCount(2);
+            tempUserEntity.setUsername("测试用户");
+            tempUserEntity = this.tempUserService.save(tempUserEntity);
+        }else {
+            if(tempUserEntity.getRemainingCount() == 0){
+                return fail("体验次数已用完，请注册新账号！");
+            }
+        }
+        UserEntity userEntity = new UserEntity();
+        userEntity.setUserName("临时用户");
+        userEntity.setPhone(Ip);
+        String token = JWTUtil.getTokenByUserInfo(userEntity);
+        JSONObject resultJson = new JSONObject();
+        resultJson.put("user", userEntity);
+        resultJson.put("token", token);
+        resultJson.put("remainingCount", tempUserEntity.getRemainingCount());
+        return success(resultJson);
+    }
+
 }

src/main/java/com/rf/AIquantum/user/service/TempUserService.java

@@ -0,0 +1,9 @@
+package com.rf.AIquantum.user.service;
+
+import com.rf.AIquantum.user.dao.model.TempUserEntity;
+
+public interface TempUserService {
+    TempUserEntity findByIp(String ip);
+
+    TempUserEntity save(TempUserEntity tempUserEntity);
+}

src/main/java/com/rf/AIquantum/user/service/impl/TempUserServiceImpl.java

@@ -0,0 +1,27 @@
+package com.rf.AIquantum.user.service.impl;
+
+import com.rf.AIquantum.user.dao.model.TempUserEntity;
+import com.rf.AIquantum.user.dao.repository.TempUserRepository;
+import com.rf.AIquantum.user.service.TempUserService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+/**
+ * @Author:zzf
+ * @Date:2025/3/21:16:32
+ * @Description:
+ */
+@Service
+public class TempUserServiceImpl implements TempUserService {
+    @Autowired
+    private TempUserRepository tempUserRepository;
+    @Override
+    public TempUserEntity findByIp(String ip) {
+        return this.tempUserRepository.findByIp(ip);
+    }
+
+    @Override
+    public TempUserEntity save(TempUserEntity tempUserEntity) {
+        return this.tempUserRepository.save(tempUserEntity);
+    }
+}