refactor: restructure chat flow to better leverage reasoning and acting capabilities

himarket-bootstrap/Dockerfile

@@ -8,4 +8,4 @@ EXPOSE 8080
 # Support reflection in java 17
 ENV JAVA_OPTS="--add-opens java.base/java.util=ALL-UNNAMED --add-opens java.base/java.lang=ALL-UNNAMED --add-opens java.base/java.lang.reflect=ALL-UNNAMED"
 
-ENTRYPOINT ["sh", "-c", "java $JAVA_OPTS -jar app.jar --logging.file.name=/app/logs/himarket-server.log"]
+ENTRYPOINT ["sh", "-c", "java $JAVA_OPTS -jar app.jar --spring.profiles.active=prod"]

himarket-bootstrap/src/main/java/com/alibaba/himarket/config/SwaggerConfig.java

@@ -29,6 +29,10 @@ public class SwaggerConfig {
     @Bean
     public OpenAPI openAPI() {
         return new OpenAPI()
-                .info(new Info().title("开放平台 API").version("1.0.0").description("API 文档描述"));
+                .info(
+                        new Info()
+                                .title("HiMarket Open API")
+                                .version("1.0.0")
+                                .description("API Document"));
     }
 }

himarket-bootstrap/src/main/java/com/alibaba/himarket/config/WebMvcConfig.java

@@ -21,37 +21,43 @@
 
 import java.util.List;
 import org.jetbrains.annotations.NotNull;
-import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.data.domain.PageRequest;
 import org.springframework.data.domain.Sort;
 import org.springframework.data.web.PageableHandlerMethodArgumentResolver;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 import org.springframework.web.method.support.HandlerMethodArgumentResolver;
+import org.springframework.web.servlet.config.annotation.AsyncSupportConfigurer;
 import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
 
 @Configuration
-public class WebMvcConfig {
+public class WebMvcConfig implements WebMvcConfigurer {
 
-    @Bean
-    public PageableHandlerMethodArgumentResolver pageableResolver() {
+    @Override
+    public void configureAsyncSupport(AsyncSupportConfigurer configurer) {
+        // Create a thread pool for async handling
+        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
+        executor.setCorePoolSize(10);
+        executor.setMaxPoolSize(50);
+        executor.setQueueCapacity(100);
+        executor.setThreadNamePrefix("async-");
+        executor.initialize();
+
+        configurer.setTaskExecutor(executor);
+        configurer.setDefaultTimeout(30000);
+    }
+
+    @Override
+    public void addArgumentResolvers(@NotNull List<HandlerMethodArgumentResolver> resolvers) {
+        // Add pageable resolver
         PageableHandlerMethodArgumentResolver resolver =
                 new PageableHandlerMethodArgumentResolver();
         // Default page size is 100
         resolver.setFallbackPageable(
                 PageRequest.of(0, 100, Sort.by(Sort.Direction.DESC, "createAt")));
         // Page index starts from 1
         resolver.setOneIndexedParameters(true);
-        return resolver;
-    }
 
-    @Bean
-    public WebMvcConfigurer webMvcConfigurer() {
-        return new WebMvcConfigurer() {
-            @Override
-            public void addArgumentResolvers(
-                    @NotNull List<HandlerMethodArgumentResolver> resolvers) {
-                resolvers.add(pageableResolver());
-            }
-        };
+        resolvers.add(resolver);
     }
 }

himarket-bootstrap/src/main/resources/logback-spring.xml

@@ -1,21 +1,53 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <configuration>
-    <!-- 控制台输出 -->
+    <!-- Console appender: enabled for all environments -->
     <appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
         <encoder>
-            <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} %magenta([%thread]) %highlight(%-5level) %cyan(%logger{50}) - %msg%n</pattern>
+            <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} %magenta([%thread]) %highlight(%-5level) %cyan(%logger{50}) - %msg%n
+            </pattern>
             <charset>UTF-8</charset>
         </encoder>
     </appender>
 
-    <root level="INFO">
-        <appender-ref ref="CONSOLE"/>
-    </root>
+    <!-- File appender: enabled only in prod profile -->
+    <springProfile name="prod">
+        <appender name="FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
+            <file>/app/logs/himarket-server.log</file>
 
-    <!-- 项目日志级别 -->
+            <encoder>
+                <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern>
+                <charset>UTF-8</charset>
+            </encoder>
+
+            <!-- Rolling policy: by date and size -->
+            <rollingPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
+                <fileNamePattern>/app/logs/archived/himarket-server-%d{yyyy-MM-dd}.%i.log.gz</fileNamePattern>
+                <maxFileSize>100MB</maxFileSize>      <!-- Max size per file -->
+                <maxHistory>30</maxHistory>           <!-- Keep 30 days -->
+                <totalSizeCap>3GB</totalSizeCap>      <!-- Max total size of archived logs -->
+            </rollingPolicy>
+        </appender>
+    </springProfile>
+
+    <!-- Default: console only (local environment) -->
+    <springProfile name="!prod">
+        <root level="INFO">
+            <appender-ref ref="CONSOLE"/>
+        </root>
+    </springProfile>
+
+    <!-- Prod profile: console + file -->
+    <springProfile name="prod">
+        <root level="INFO">
+            <appender-ref ref="CONSOLE"/>
+            <appender-ref ref="FILE"/>
+        </root>
+    </springProfile>
+
+    <!-- Application log levels -->
     <logger name="com.alibaba.himarket" level="INFO"/>
-    
-    <!-- 框架日志级别调整 -->
+
+    <!-- Framework log levels -->
     <logger name="org.springframework" level="INFO"/>
     <logger name="org.hibernate" level="INFO"/>
     <logger name="org.hibernate.SQL" level="INFO"/>

himarket-dal/src/main/java/com/alibaba/himarket/entity/Administrator.java

@@ -20,15 +20,8 @@
 package com.alibaba.himarket.entity;
 
 import jakarta.persistence.*;
-import lombok.AllArgsConstructor;
-import lombok.Builder;
-import lombok.Data;
-import lombok.NoArgsConstructor;
+import lombok.*;
 
-@Data
-@NoArgsConstructor
-@AllArgsConstructor
-@Builder
 @Entity
 @Table(
         name = "administrator",
@@ -40,6 +33,11 @@
                     columnNames = {"username"},
                     name = "uk_username")
         })
+@Data
+@EqualsAndHashCode(callSuper = true)
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
 public class Administrator extends BaseEntity {
     @Id
     @GeneratedValue(strategy = GenerationType.IDENTITY)

himarket-dal/src/main/java/com/alibaba/himarket/entity/Chat.java

@@ -26,8 +26,7 @@
 import com.alibaba.himarket.support.enums.ChatStatus;
 import jakarta.persistence.*;
 import java.util.List;
-import lombok.Data;
-import lombok.experimental.Accessors;
+import lombok.*;
 
 @Entity
 @Table(
@@ -38,7 +37,10 @@
                     name = "uk_chat_id")
         })
 @Data
-@Accessors(chain = true)
+@EqualsAndHashCode(callSuper = true)
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
 public class Chat extends BaseEntity {
 
     @Id
@@ -74,6 +76,7 @@ public class Chat extends BaseEntity {
      */
     @Column(name = "status", length = 32)
     @Enumerated(EnumType.STRING)
+    @Builder.Default
     private ChatStatus status = ChatStatus.INIT;
 
     /**

himarket-dal/src/main/java/com/alibaba/himarket/entity/ChatAttachment.java

@@ -21,8 +21,7 @@
 
 import com.alibaba.himarket.support.enums.ChatAttachmentType;
 import jakarta.persistence.*;
-import lombok.Data;
-import lombok.experimental.Accessors;
+import lombok.*;
 import org.hibernate.annotations.ColumnDefault;
 
 @Entity
@@ -34,7 +33,10 @@
                     name = "uk_attachment_id")
         })
 @Data
-@Accessors(chain = true)
+@EqualsAndHashCode(callSuper = true)
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
 public class ChatAttachment extends BaseEntity {
 
     @Id

himarket-dal/src/main/java/com/alibaba/himarket/entity/ChatSession.java

@@ -22,8 +22,7 @@
 import com.alibaba.himarket.converter.ListJsonConverter;
 import jakarta.persistence.*;
 import java.util.List;
-import lombok.Data;
-import lombok.experimental.Accessors;
+import lombok.*;
 
 @Entity
 @Table(
@@ -34,7 +33,10 @@
                     name = "uk_session_id")
         })
 @Data
-@Accessors(chain = true)
+@EqualsAndHashCode(callSuper = true)
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
 public class ChatSession extends BaseEntity {
 
     @Id

himarket-dal/src/main/java/com/alibaba/himarket/entity/Consumer.java

@@ -20,8 +20,7 @@
 package com.alibaba.himarket.entity;
 
 import jakarta.persistence.*;
-import lombok.Data;
-import lombok.EqualsAndHashCode;
+import lombok.*;
 
 @Entity
 @Table(
@@ -36,6 +35,9 @@
         })
 @Data
 @EqualsAndHashCode(callSuper = true)
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
 public class Consumer extends BaseEntity {
 
     @Id

himarket-dal/src/main/java/com/alibaba/himarket/entity/ConsumerCredential.java

@@ -26,7 +26,7 @@
 import com.alibaba.himarket.support.consumer.HmacConfig;
 import com.alibaba.himarket.support.consumer.JwtConfig;
 import jakarta.persistence.*;
-import lombok.Data;
+import lombok.*;
 
 @Entity
 @Table(
@@ -37,6 +37,10 @@
                     name = "uk_consumer_id")
         })
 @Data
+@EqualsAndHashCode(callSuper = true)
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
 public class ConsumerCredential extends BaseEntity {
 
     @Id

himarket-dal/src/main/java/com/alibaba/himarket/entity/ConsumerRef.java

@@ -28,10 +28,10 @@
 @Entity
 @Table(name = "consumer_ref")
 @Data
+@EqualsAndHashCode(callSuper = true)
 @Builder
-@AllArgsConstructor
 @NoArgsConstructor
-@EqualsAndHashCode(callSuper = true)
+@AllArgsConstructor
 public class ConsumerRef extends BaseEntity {
 
     @Id

himarket-dal/src/main/java/com/alibaba/himarket/entity/Developer.java

@@ -22,15 +22,8 @@
 import com.alibaba.himarket.support.enums.DeveloperAuthType;
 import com.alibaba.himarket.support.enums.DeveloperStatus;
 import jakarta.persistence.*;
-import lombok.AllArgsConstructor;
-import lombok.Builder;
-import lombok.Data;
-import lombok.NoArgsConstructor;
+import lombok.*;
 
-@Data
-@NoArgsConstructor
-@AllArgsConstructor
-@Builder
 @Entity
 @Table(
         name = "developer",
@@ -42,6 +35,11 @@
                     columnNames = {"portalId", "username"},
                     name = "uk_portal_username")
         })
+@Data
+@EqualsAndHashCode(callSuper = true)
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
 public class Developer extends BaseEntity {
 
     @Id