TASK: 画布数据 回参添加返回crossOrigin

2.优化订阅邮件提醒，向redis存储已发送的邮件类型

pom.xml

@@ -151,9 +151,15 @@
             <version>3.0.3</version>
         </dependency>
 <!--        /**发送邮件**/-->
+<!--        <dependency>-->
+<!--            <groupId>com.tencentcloudapi</groupId>-->
+<!--            <artifactId>tencentcloud-sdk-java-ses</artifactId>-->
+<!--            <version>3.1.572</version>-->
+<!--        </dependency>-->
+
         <dependency>
             <groupId>com.tencentcloudapi</groupId>
-            <artifactId>tencentcloud-sdk-java-ses</artifactId>
+            <artifactId>tencentcloud-sdk-java</artifactId>
             <version>3.1.572</version>
         </dependency>
 
@@ -276,6 +282,40 @@
             <artifactId>gson</artifactId>
             <version>2.10.1</version>
         </dependency>
+
+        <dependency>
+            <groupId>com.itextpdf</groupId>
+            <artifactId>itextpdf</artifactId>
+            <version>5.5.13.2</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-websocket</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>com.google.auth</groupId>
+            <artifactId>google-auth-library-oauth2-http</artifactId>
+            <version>1.8.0</version>
+        </dependency>
+
+        <dependency>
+            <groupId>com.google.api-client</groupId>
+            <artifactId>google-api-client</artifactId>
+            <version>1.32.1</version>
+        </dependency>
+        <dependency>
+            <groupId>com.google.oauth-client</groupId>
+            <artifactId>google-oauth-client</artifactId>
+            <version>1.32.1</version>
+        </dependency>
+        <dependency>
+            <groupId>com.google.http-client</groupId>
+            <artifactId>google-http-client-jackson2</artifactId>
+            <version>1.41.5</version>
+        </dependency>
+
     </dependencies>
 
     <build>

src/main/java/com/ai/da/common/RabbitMQ/GenerateConsumer.java

@@ -6,6 +6,7 @@ import com.ai.da.common.utils.RedisUtil;
 import com.ai.da.model.dto.GenerateThroughImageTextDTO;
 import com.ai.da.model.vo.GenerateResultVO;
 import com.ai.da.service.GenerateService;
+import com.ai.da.service.UserLikeGroupService;
 import com.alibaba.fastjson.JSONObject;
 import com.google.gson.Gson;
 import com.rabbitmq.client.Channel;
@@ -14,8 +15,10 @@ import org.apache.tomcat.jni.Time;
 import org.springframework.amqp.core.Message;
 import org.springframework.amqp.rabbit.annotation.RabbitHandler;
 import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
+import org.springframework.util.StringUtils;
 
 import javax.annotation.Resource;
 import java.io.IOException;
@@ -30,6 +33,12 @@ public class GenerateConsumer {
     @Resource
     private GenerateService generateService;
 
+    @Resource
+    private UserLikeGroupService userLikeGroupService;
+
+    @Autowired
+    private RabbitMQProperties rabbitMQProperties;
+
     @Resource
     private RedisUtil redisUtil;
 
@@ -163,6 +172,9 @@ public class GenerateConsumer {
                 String taskId = generateResult.get("tasks_id");
                 String category = generateResult.get("category");
                 generateService.processToProductImageResult(taskId, url, category);
+            } else if (generateResult.get("status").equals("NO_FACE")) {
+                String taskId = generateResult.get("tasks_id");
+                userLikeGroupService.toProduct(taskId);
             } else {
                 // 修改redis中的数据状态为exception
                 String key = toProductImageResultKey + ":" + generateResult.get("tasks_id");
@@ -210,6 +222,9 @@ public class GenerateConsumer {
                 String taskId = generateResult.get("tasks_id");
                 String category = generateResult.get("category");
                 generateService.processRelightResult(taskId, url, category);
+            } else if (generateResult.get("status").equals("NO_FACE")) {
+                String taskId = generateResult.get("tasks_id");
+                userLikeGroupService.relight(taskId);
             } else {
                 // 修改redis中的数据状态为exception
                 String key = relightResultKey + ":" + generateResult.get("tasks_id");
@@ -243,73 +258,73 @@ public class GenerateConsumer {
         log.info("============ProcessRelightResult End listening==========");
     }
 
-    @RabbitListener(queues = MQConfig.GENERATE_QUEUE)
+    @RabbitListener(queues = "#{rabbitMQProperties.queues.generate}")
     @RabbitHandler
     public void generateConsumer1(Message msg, Channel channel) {
         generate(msg, channel, "consumer 1");
     }
 
-    @RabbitListener(queues = MQConfig.GENERATE_QUEUE)
+    @RabbitListener(queues = "#{rabbitMQProperties.queues.generate}")
     @RabbitHandler
     public void generateConsumer2(Message msg, Channel channel) {
         generate(msg, channel, "consumer 2");
     }
 
-    @RabbitListener(queues = MQConfig.GENERATE_QUEUE)
+    @RabbitListener(queues = "#{rabbitMQProperties.queues.generate}")
     @RabbitHandler
     public void generateConsumer3(Message msg, Channel channel) {
         generate(msg, channel, "consumer 3");
     }
 
-    @RabbitListener(queues = MQConfig.GENERATE_QUEUE)
+    @RabbitListener(queues = "#{rabbitMQProperties.queues.generate}")
     @RabbitHandler
     public void generateConsumer4(Message msg, Channel channel) {
         generate(msg, channel, "consumer 4");
     }
 
-    @RabbitListener(queues = MQConfig.GENERATE_QUEUE)
+    @RabbitListener(queues = "#{rabbitMQProperties.queues.generate}")
     @RabbitHandler
     public void generateConsumer5(Message msg, Channel channel) {
         generate(msg, channel, "consumer 5");
     }
 
-    @RabbitListener(queues = MQConfig.GENERATE_QUEUE)
+    @RabbitListener(queues = "#{rabbitMQProperties.queues.generate}")
     @RabbitHandler
     public void generateConsumer6(Message msg, Channel channel) {
         generate(msg, channel, "consumer 6");
     }
 
-    @RabbitListener(queues = MQConfig.GENERATE_QUEUE)
+    @RabbitListener(queues = "#{rabbitMQProperties.queues.generate}")
     @RabbitHandler
     public void generateConsumer7(Message msg, Channel channel) {
         generate(msg, channel, "consumer 7");
     }
 
-    @RabbitListener(queues = MQConfig.GENERATE_QUEUE)
+    @RabbitListener(queues = "#{rabbitMQProperties.queues.generate}")
     @RabbitHandler
     public void generateConsumer8(Message msg, Channel channel) {
         generate(msg, channel, "consumer 8");
     }
 
-    @RabbitListener(queues = MQConfig.GENERATE_QUEUE)
+    @RabbitListener(queues = "#{rabbitMQProperties.queues.generate}")
     @RabbitHandler
     public void generateConsumer9(Message msg, Channel channel) {
         generate(msg, channel, "consumer 9");
     }
 
-    @RabbitListener(queues = MQConfig.GENERATE_RESULT_QUEUE)
+    @RabbitListener(queues = "#{rabbitMQProperties.queues.generateResult}")
     @RabbitHandler
     public void getGenerateResult(Message msg, Channel channel) {
         processGenerateResult(msg, channel);
     }
 
-    @RabbitListener(queues = MQConfig.TO_PRODUCT_IMAGE_RESULT_QUEUE)
+    @RabbitListener(queues = "#{rabbitMQProperties.queues.toProductImageResult}")
     @RabbitHandler
     public void getToProductImageResult(Message msg, Channel channel) {
         processToProductImageResult(msg, channel);
     }
 
-    @RabbitListener(queues = MQConfig.RELIGHT_RESULT_QUEUE)
+    @RabbitListener(queues = "#{rabbitMQProperties.queues.relightResult}")
     @RabbitHandler
     public void getRelightResult(Message msg, Channel channel) {
         processRelightResult(msg, channel);

src/main/java/com/ai/da/common/RabbitMQ/MQConfig.java

@@ -1,66 +1,43 @@
 package com.ai.da.common.RabbitMQ;
 
 import org.springframework.amqp.core.Queue;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 
 @Configuration
 public class MQConfig {
 
-    public static final String GENERATE_EXCHANGE_FANOUT = "generate-exchange";
-    //    public static final String GENERATE_QUEUE = "generate-queue-prod";
-//    public static final String GENERATE_QUEUE = "generate-queue-test";
-//     ==================================================================
-//    public static final String GENERATE_QUEUE = "generate-queue-local";
-//    public static final String GENERATE_QUEUE = "generate-queue-dev";
-    public static final String GENERATE_QUEUE = "generate-queue-prod";
-//
-//    public static final String SR_QUEUE = "SR-queue-local";
-//    public static final String SR_QUEUE = "SR-queue-dev";
-        public static final String SR_QUEUE = "SR-queue-prod";
-//
-//        public static final String SR_RESULT_QUEUE = "SuperResolution-local";
-//        public static final String SR_RESULT_QUEUE = "SuperResolution-dev";
-    public static final String SR_RESULT_QUEUE = "SuperResolution-prod";
-//
-//    public static final String GENERATE_RESULT_QUEUE = "GenerateImage-local";
-    public static final String GENERATE_RESULT_QUEUE = "GenerateImage-prod";
+    @Autowired
+    private RabbitMQProperties rabbitMQProperties;
 
-    public static final String TO_PRODUCT_IMAGE_RESULT_QUEUE = "ToProductImage-prod";
-
-    public static final String RELIGHT_RESULT_QUEUE = "Relight-prod";
-    public MQConfig() {
-    }
-
-//    @Bean
-//    FanoutExchange fanoutRasaExchange() {
-//        return new FanoutExchange(GENERATE_EXCHANGE_FANOUT);
-//    }
-
-    /**
-     * 创建队列,使用工作模式，不用定义交换机
-     */
     @Bean
     public Queue generateQueue() {
-        return new Queue(GENERATE_QUEUE);
+        return new Queue(rabbitMQProperties.getQueues().getGenerate());
     }
 
     @Bean
     public Queue SRQueue() {
-        return new Queue(SR_QUEUE);
+        return new Queue(rabbitMQProperties.getQueues().getSr());
     }
 
     @Bean
     public Queue SRResultQueue() {
-        return new Queue(SR_RESULT_QUEUE);
+        return new Queue(rabbitMQProperties.getQueues().getSrResult());
     }
 
-    /**
-     * 将队列绑定到交换机上【队列订阅交换机】
-     */
-//    @Bean
-//    Binding bindingExchangeRasa() {
-//        return BindingBuilder.bind(queueRasa()).to(fanoutRasaExchange());
-//    }
-
+    @Bean
+    public Queue generateResultQueue() {
+        return new Queue(rabbitMQProperties.getQueues().getGenerateResult());
+    }
+
+    @Bean
+    public Queue toProductImageResultQueue() {
+        return new Queue(rabbitMQProperties.getQueues().getToProductImageResult());
+    }
+
+    @Bean
+    public Queue relightResultQueue() {
+        return new Queue(rabbitMQProperties.getQueues().getRelightResult());
+    }
 }

src/main/java/com/ai/da/common/RabbitMQ/MQPublisher.java

@@ -2,6 +2,7 @@ package com.ai.da.common.RabbitMQ;
 
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.core.AmqpTemplate;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
@@ -10,19 +11,19 @@ import javax.annotation.Resource;
 @Component
 public class MQPublisher {
 
-//    private final String url = "http://localhost:15672/api/queues/%2f/generate-queue";
+    @Autowired
+    private RabbitMQProperties rabbitMQProperties;
 
-    @Resource
+    @Autowired
     private AmqpTemplate amqpTemplate;
 
     public void sendGenerateMessage(String mm) {
         log.info("send message: " + mm);
-        amqpTemplate.convertAndSend(MQConfig.GENERATE_QUEUE, mm);
+        amqpTemplate.convertAndSend(rabbitMQProperties.getQueues().getGenerate(), mm);
     }
 
     public void sendSRMessage(String mm) {
         log.info("send message: " + mm);
-        amqpTemplate.convertAndSend(MQConfig.SR_QUEUE, mm);
+        amqpTemplate.convertAndSend(rabbitMQProperties.getQueues().getSr(), mm);
     }
-
 }

src/main/java/com/ai/da/common/RabbitMQ/RabbitMQProperties.java

@@ -0,0 +1,30 @@
+package com.ai.da.common.RabbitMQ;
+
+import lombok.Data;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.stereotype.Component;
+
+@Component
+@ConfigurationProperties(prefix = "rabbitmq")
+@Data
+public class RabbitMQProperties {
+
+    private Queues queues;
+    private Exchange exchange;
+
+    @Data
+    public static class Queues {
+        private String generate;
+        private String sr;
+        private String srResult;
+        private String generateResult;
+        private String toProductImageResult;
+        private String relightResult;
+    }
+
+    @Data
+    public static class Exchange {
+        private String generate;
+    }
+}
+

src/main/java/com/ai/da/common/RabbitMQ/SRConsumer.java

@@ -15,6 +15,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.core.Message;
 import org.springframework.amqp.rabbit.annotation.RabbitHandler;
 import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
 
@@ -27,6 +28,9 @@ import java.util.HashMap;
 @Component
 public class SRConsumer {
 
+    @Autowired
+    private RabbitMQProperties rabbitMQProperties;
+
     @Resource
     private RedisUtil redisUtil;
 
@@ -218,14 +222,13 @@ public class SRConsumer {
         taskListService.updateTaskStatusOrOutputRedis(uniqueId, "fail", null);
     }
 
-    @RabbitListener(queues = MQConfig.SR_QUEUE)
+    @RabbitListener(queues = "#{rabbitMQProperties.queues.sr}")
     @RabbitHandler
     public void SRConsumer1(Message msg, Channel channel) {
         superResolution(msg, channel, "consumer 1");
     }
 
-
-    @RabbitListener(queues = MQConfig.SR_RESULT_QUEUE)
+    @RabbitListener(queues = "#{rabbitMQProperties.queues.srResult}")
     @RabbitHandler
     public void SRResultConsumer1(Message msg, Channel channel) {
         getSRResult(msg, channel, "consumer 1");

src/main/java/com/ai/da/common/config/MyTaskScheduler.java

@@ -6,7 +6,10 @@ import com.ai.da.common.utils.SendEmailUtil;
 import com.ai.da.mapper.primary.*;
 import com.ai.da.mapper.primary.entity.*;
 import com.ai.da.mapper.secondary.AttributeRetrievalMapper;
+import com.ai.da.model.enums.StyleEnum;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.ObjectUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.poi.ss.usermodel.Row;
 import org.apache.poi.ss.usermodel.Sheet;
@@ -31,7 +34,7 @@ import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
-
+@Slf4j
 @Component
 public class MyTaskScheduler {
 
@@ -39,6 +42,7 @@ public class MyTaskScheduler {
     public void test() {
 //        clearMinio();
 //        addSystemFileStyle();
+//        sendTrialOrderExcelToManagements();
     }
 
     @Resource
@@ -83,10 +87,11 @@ public class MyTaskScheduler {
             }
         }
     }
-    @Scheduled(cron = "0 0 8 * * ?")
+    @Scheduled(cron = "0 0 9 * * ?")
     public void sendTrialOrderExcelToManagements() {
         // 获取前一天日期
         LocalDate yesterday = LocalDate.now().minusDays(1);
+//        LocalDate before = LocalDate.now().minusDays(4);
 
         // 查询前一天的试用订单
         QueryWrapper<TrialOrder> qw = new QueryWrapper<>();
@@ -126,7 +131,9 @@ public class MyTaskScheduler {
                     row.createCell(6).setCellValue(trialOrder.getCountry());
                     row.createCell(7).setCellValue(trialOrder.getOccupation());
                     row.createCell(8).setCellValue(trialOrder.getCreateTime().format(formatter));
+                    if (!ObjectUtils.isEmpty(trialOrder.getUpdateTime())) {
                         row.createCell(9).setCellValue(trialOrder.getUpdateTime().format(formatter));
+                    }
                     row.createCell(10).setCellValue(trialOrder.getStatus());
                 }
 
@@ -134,19 +141,27 @@ public class MyTaskScheduler {
                 String fileName = "trialOrder-" + yesterday.format(DateTimeFormatter.ofPattern("yyyyMMdd")) + ".xlsx";
                 try (FileOutputStream fileOut = new FileOutputStream(fileName)) {
                     workbook.write(fileOut);
-                    SendEmailUtil.sendExcelEmail("1023316923@qq.com", null, Files.readAllBytes(Paths.get(fileName)), fileName);
+//                    SendEmailUtil.sendExcelEmail("1023316923@qq.com", null, Files.readAllBytes(Paths.get(fileName)), fileName);
                     SendEmailUtil.sendExcelEmail("calvinwong@aidlab.hk", null, Files.readAllBytes(Paths.get(fileName)), fileName);
                     SendEmailUtil.sendExcelEmail("kaicpang.pang@connect.polyu.hk", null, Files.readAllBytes(Paths.get(fileName)), fileName);
                     SendEmailUtil.sendExcelEmail("kimwong@code-create.com.hk", null, Files.readAllBytes(Paths.get(fileName)), fileName);
+//                    SendEmailUtil.sendExcelEmail("ningning@code-create.com.hk", null, Files.readAllBytes(Paths.get(fileName)), fileName);
+                    SendEmailUtil.sendExcelEmail("johnnyho@code-create.com.hk", null, Files.readAllBytes(Paths.get(fileName)), fileName);
+                    SendEmailUtil.sendExcelEmail("ringolau@code-create.com.hk", null, Files.readAllBytes(Paths.get(fileName)), fileName);
+                    SendEmailUtil.sendExcelEmail("chelseayu@code-create.com.hk", null, Files.readAllBytes(Paths.get(fileName)), fileName);
                 }
             } catch (IOException e) {
                 e.printStackTrace();
             }
         }else {
-            SendEmailUtil.sendNoExcelEmail("1023316923@qq.com", null);
+//            SendEmailUtil.sendNoExcelEmail("1023316923@qq.com", null);
             SendEmailUtil.sendNoExcelEmail("calvinwong@aidlab.hk", null);
             SendEmailUtil.sendNoExcelEmail("kaicpang.pang@connect.polyu.hk", null);
             SendEmailUtil.sendNoExcelEmail("kimwong@code-create.com.hk", null);
+//            SendEmailUtil.sendNoExcelEmail("ningning@code-create.com.hk", null);
+            SendEmailUtil.sendNoExcelEmail("johnnyho@code-create.com.hk", null);
+            SendEmailUtil.sendNoExcelEmail("ringolau@code-create.com.hk", null);
+            SendEmailUtil.sendNoExcelEmail("chelseayu@code-create.com.hk", null);
         }
     }
 
@@ -219,29 +234,47 @@ public class MyTaskScheduler {
     private AttributeRetrievalMapper attributeRetrievalMapper;
 
     public void addSystemFileStyle() {
-        ExecutorService executorService = Executors.newFixedThreadPool(5);
+//        ExecutorService executorService = Executors.newFixedThreadPool(5);
 
-        try {
+//        try {
+//            String[] filePaths = {
+//                    "C:\\Users\\10233\\Downloads\\OneDrive_1_2024-10-3\\Mens bottom style output.xlsx",
+//                    "C:\\Users\\10233\\Downloads\\OneDrive_1_2024-10-3\\Mens outer style output.xlsx",
+//                    "C:\\Users\\10233\\Downloads\\OneDrive_1_2024-10-3\\Mens top style output.xlsx"
+////                    "/workspace/shb/Mens_bottom_style_output.xlsx",
+////                    "/workspace/shb/Mens_outer_style_output.xlsx",
+////                    "/workspace/shb/Mens_top_style_output.xlsx"
+//            };
+//
+//            for (String filePath : filePaths) {
+////                executorService.submit(() -> processExcelFile(filePath));
+//                processExcelFile(filePath);
+//            }
+//        }catch (Exception e) {
+//
+//        }
+//        } finally {
+//            executorService.shutdown();
+//            try {
+//                if (!executorService.awaitTermination(60, TimeUnit.MINUTES)) {
+//                    executorService.shutdownNow();
+//                }
+//            } catch (InterruptedException e) {
+//                executorService.shutdownNow();
+//            }
+//        }
         String[] filePaths = {
-                    "C:\\Users\\10233\\Documents\\WeChat Files\\wxid_h7l9im0r8ql922\\FileStorage\\File\\2024-06\\style\\Blouse style output updated25.6.2024.xlsx",
-                    "C:\\Users\\10233\\Documents\\WeChat Files\\wxid_h7l9im0r8ql922\\FileStorage\\File\\2024-06\\style\\Dress style output updated25.6.2024.xlsx",
-                    "C:\\Users\\10233\\Documents\\WeChat Files\\wxid_h7l9im0r8ql922\\FileStorage\\File\\2024-06\\style\\Outerwear style output.xlsx",
-                    "C:\\Users\\10233\\Documents\\WeChat Files\\wxid_h7l9im0r8ql922\\FileStorage\\File\\2024-06\\style\\Skirt style output .xlsx",
-                    "C:\\Users\\10233\\Documents\\WeChat Files\\wxid_h7l9im0r8ql922\\FileStorage\\File\\2024-06\\style\\Trousers style output.xlsx"
+                "C:\\Users\\10233\\Downloads\\OneDrive_1_2024-10-3\\Mens bottom style output.xlsx",
+                "C:\\Users\\10233\\Downloads\\OneDrive_1_2024-10-3\\Mens outer style output.xlsx",
+                "C:\\Users\\10233\\Downloads\\OneDrive_1_2024-10-3\\Mens top style output.xlsx"
+//                    "/workspace/shb/Mens_bottom_style_output.xlsx",
+//                    "/workspace/shb/Mens_outer_style_output.xlsx",
+//                    "/workspace/shb/Mens_top_style_output.xlsx"
         };
 
         for (String filePath : filePaths) {
-                executorService.submit(() -> processExcelFile(filePath));
-            }
-        } finally {
-            executorService.shutdown();
-            try {
-                if (!executorService.awaitTermination(60, TimeUnit.MINUTES)) {
-                    executorService.shutdownNow();
-                }
-            } catch (InterruptedException e) {
-                executorService.shutdownNow();
-            }
+//                executorService.submit(() -> processExcelFile(filePath));
+            processExcelFile(filePath);
         }
     }
 
@@ -263,6 +296,37 @@ public class MyTaskScheduler {
                         attributeRetrievalMapper.updateStyleByFileName("X", prefix + fileName, tableName);
                         System.out.println(fileName);
                     } else {
+//                        if (style.equals("Y2K 风")) {
+//                            StyleEnum.COUNTRY_STYLE
+//                        }else if (style.equals("")) {
+//
+//                        }else if (style.equals("")) {
+//
+//                        }else if (style.equals("")) {
+//
+//                        }else if (style.equals("")) {
+//
+//                        }else if (style.equals("")) {
+//
+//                        }else if (style.equals("")) {
+//
+//                        }else if (style.equals("")) {
+//
+//                        }else if (style.equals("")) {
+//
+//                        }else if (style.equals("")) {
+//
+//                        }else if (style.equals("")) {
+//
+//                        }else if (style.equals("")) {
+//
+//                        }else if (style.equals("")) {
+//
+//                        }else if (style.equals("")) {
+//
+//                        }else if (style.equals("")) {
+//
+//                        }
                         attributeRetrievalMapper.updateStyleByFileName(style, prefix + fileName, tableName);
                         System.out.println(fileName);
                     }
@@ -284,6 +348,12 @@ public class MyTaskScheduler {
             return "female_skirt";
         } else if (filePath.contains("Trousers")) {
             return "female_pants";
+        } else if (filePath.contains("bottom")) {
+            return "male_bottom";
+        } else if (filePath.contains("outer")) {
+            return "male_outwear";
+        } else if (filePath.contains("top")) {
+            return "male_top";
         }
         return "";
     }
@@ -299,6 +369,12 @@ public class MyTaskScheduler {
             return "skirt/";
         } else if (filePath.contains("Trousers")) {
             return "trousers/";
+        } else if (filePath.contains("bottom")) {
+            return "bottom/";
+        } else if (filePath.contains("outer")) {
+            return "outer/";
+        } else if (filePath.contains("top")) {
+            return "top/";
         }
         return "";
     }

src/main/java/com/ai/da/common/config/exception/TokenMissingOrExpiredException.java

@@ -0,0 +1,12 @@
+package com.ai.da.common.config.exception;
+
+public class TokenMissingOrExpiredException extends RuntimeException {
+    public TokenMissingOrExpiredException(String message) {
+        super(message);
+    }
+
+    @Override
+    public Throwable fillInStackTrace() {
+        return this;
+    }
+}

src/main/java/com/ai/da/common/constant/CommonConstant.java

@@ -1,5 +1,8 @@
 package com.ai.da.common.constant;
 
+import java.util.Arrays;
+import java.util.List;
+
 public class CommonConstant {
     // 单位 秒  10分钟过期
 //    public static final Long TASK_EXPIRE_TIME =  24 * 60 * 60L;
@@ -10,6 +13,8 @@ public class CommonConstant {
     public static final Integer MINIO_IMAGE_EXPIRE_TIME = 24 * 60;
     // 单位 秒 一天过期 in redis
     public static final Long GENERATE_RESULT_EXPIRE_TIME = 24 * 60 * 60L;
+    // 单位 秒 7天过期
+    public static final Long REDIS_SET_EXPIRE_TIME = 24 * 60 * 60 * 7L;
 
     public static class Numbers{
         public static final Integer NUMBER_10 =  10;
@@ -31,6 +36,52 @@ public class CommonConstant {
 
     public static final String PYTHON_PORT_9997 = "9997";
 
+    public static final List<String> AGES_EN = Arrays.asList("Below 20", "20-30", "30-40", "40+");
 
+    public static final List<String> AGES_CN = Arrays.asList("20岁以下", "20-30岁", "30-40岁", "40+岁");
+    public static final List<String> IF_HELPFUL_EN = Arrays.asList("Easy to learn and use", "Easy to get trend information",
+            "Lots of creative design proposals","The AIGC functions for moodboard is helpful","The AIGC functions for design sketches is helpful",
+            "Easy to select the right color","The Chatbot function is helpful","The print position function is helpful",
+            "The drawing function is helpful","The export function is useful","Easy to edit the design","Others");
 
+    public static final List<String> IF_HELPFUL_CN = Arrays.asList("易于学习和使用", "容易获取趋势信息",
+            "提供大量创意设计方案","AIGC功能对灵感板有帮助","AIGC功能对设计草图有帮助",
+            "容易选择合适的颜色","聊天机器人功能有帮助","打印位置功能有帮助",
+            "绘图功能有帮助","导出功能有用","设计编辑简单","其他");
+
+    public static final List<String> IF_IMPROVE_EN = Arrays.asList("Proposed designs are boring, need more interesting designs",
+            "Difficult to make changes on design","Only 2D output, no 3D results","Difficult to apply keywords for AIGC generation",
+            "Clothing is not in the right proportion","Not compatible with pattern making solutions","Improved user interface for better navigation",
+            "Lack of responsive customer support","Insufficient tutorial or guidance for new users","Limited personalization options for designs","Others");
+
+    public static final List<String> IF_IMPROVE_CN = Arrays.asList("提供的设计很无聊，需要更多有趣的设计",
+            "设计修改困难","只有2D输出，没有3D结果","难以选择合适的关键词应用于AIGC生成",
+            "服装比例不正确","与打版解决方案不兼容","改进用户界面以便更好导航",
+            "客户支持响应不及时","对新用户的教程或指导不足","设计个性化选项有限","其他");
+
+    public static final List<String> IS_SUBSCRIBE = Arrays.asList("yes", "no");
+
+//    public static final String DEFAULT_AVATAR = "aida-users/87/avatar/default.jpg";
+    public static final String DEFAULT_AVATAR = "aida-users/87/avatar/default.png";
+
+    /* 截止至2024/08/26，在Code-Create DB中pmr_users表中最大的用户id */
+    public static final Long MAXIMUM_USER_ID = 704L;
+//    public static final Long MAXIMUM_USER_ID = 225L;
+
+    // 激活更改邮箱 链接有效期 毫秒 3天
+    public static final Long CHANGE_MAILBOX_LINK_VALIDITY = 259200000L;
+
+    public static final String RCA_WORKSHOP_TAG = "#RCAworkshop_2024";
+
+    public static final String PORTFOLIO_DELETED_EN = "Portfolio has been deleted";
+
+    public static final String PORTFOLIO_DELETED_CN = "作品已删除";
+
+    public static final String TIME_FORMAT_MMM_dd_yyyy_EEEE = "MMM. dd, yyyy, EEEE";
+
+    public static final String TIME_FORMAT_MMM_dd_yyyy = "MMM. dd, yyyy";
+
+    public static final String TIME_FORMAT_yyyy_MM_dd_HH_mm_ss = "yyyy-MM-dd HH:mm:ss";
+
+    public static final String AFFILIATE_LINK = "https://www.aida.com.hk?ref=";
 }

src/main/java/com/ai/da/common/enums/AuthenticationOperationTypeEnum.java

@@ -23,7 +23,17 @@ public enum AuthenticationOperationTypeEnum {
     /**
      * 忘记密码
      */
-    FORGET_PWD;
+    FORGET_PWD,
+    /**
+     * 更改邮箱
+     */
+    CHANGE_MAILBOX,
+    /**
+     * 填写用户国家和职业
+     */
+    UPDATE_USERINFO,
+
+    REGISTER;
 
     public static AuthenticationOperationTypeEnum of(String name) {
         return Stream.of(AuthenticationOperationTypeEnum.values()).filter(v -> v.name().equals(name)).findFirst().orElse(null);

src/main/java/com/ai/da/common/enums/CreditsEventsEnum.java

@@ -8,9 +8,11 @@ import lombok.Getter;
 public enum CreditsEventsEnum {
 
     PRICE("price","6"),
+//    PRICE("price","1"),// for test
 //    PRICE("price","0.1"),
 
     BUY_CREDITS("Buy Credits","60"),
+//    BUY_CREDITS("Buy Credits","10"),// for test
 
     REFUND("Refund","60"),
 //    BUY_CREDITS("Buy Credits","10"),
@@ -20,6 +22,7 @@ public enum CreditsEventsEnum {
     INIT_MONTHLY("init_monthly", "5000"),
     INIT_TRIAL("init_trial", "100"),
     INIT_WEEKLY("init_weekly","6000"),
+    RESET_YEAR_CREDITS("reset_year_credits","6000"),
 
 //    SUPER_RESOLUTION("Super Resolution","30"),
     SUPER_RESOLUTION("Super Resolution","10"),
@@ -31,6 +34,7 @@ public enum CreditsEventsEnum {
     TO_PRODUCT_IMAGE("ToProductImage","5"),
     RELIGHT("Relight","5"),
     QUESTIONNAIRE("Questionnaire","100"),
+    IMAGE_TO_SKETCH("ImageToSketch","5"),
 
     OTHER("Other","5");
 

src/main/java/com/ai/da/common/enums/OrderStatusEnum.java

@@ -10,38 +10,34 @@ public enum OrderStatusEnum {
      * 未支付
      */
     NOT_PAY("未支付"),
-
-
     /**
      * 支付成功
      */
     SUCCESS("支付成功"),
-
+    /**
+     * 支付失败
+     */
+    FAILURE("支付失败"),
     /**
      * 已关闭
      */
     TIMEOUT_CLOSED("超时已关闭"),
-
     /**
      * 已取消
      */
     CANCEL("用户已取消"),
-
     /**
      * 退款中
      */
     REFUND_PROCESSING("退款中"),
-
     /**
      * 已退款
      */
     REFUND_SUCCESS("已退款"),
-
     /**
      * 退款异常
      */
     REFUND_ABNORMAL("退款异常"),
-
     /**
      * paypal订单状态为 APPROVED
      */

src/main/java/com/ai/da/common/enums/ProductEnum.java

@@ -0,0 +1,25 @@
+package com.ai.da.common.enums;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+@Getter
+@AllArgsConstructor
+public enum ProductEnum {
+    // 积分购买
+    CreditsProduct("AiDA credits purchase", 6L),
+    // 年度订阅
+    AnnualSubscription("AiDA Annual Subscription", 5000L),
+    // 月度订阅
+    MonthlySubscription("AiDA Monthly Subscription", 500L),
+    // 测试
+    DailySubscription("AiDA Daily Subscription", 10L),
+    ;
+
+    /**
+     * 类型
+     */
+    private final String name;
+
+    private final Long price;
+}

src/main/java/com/ai/da/common/response/TransactionPageResponse.java

@@ -0,0 +1,15 @@
+package com.ai.da.common.response;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.math.BigDecimal;
+
+@Data
+@NoArgsConstructor
+@ApiModel("交易记录分页响应结果")
+public class TransactionPageResponse<T> extends PageBaseResponse<T> {
+
+    private BigDecimal totalAmount;
+}

src/main/java/com/ai/da/common/security/filter/AuthenticationFilter.java

@@ -1,6 +1,7 @@
 package com.ai.da.common.security.filter;
 
 import cn.hutool.core.util.StrUtil;
+import com.ai.da.common.config.exception.TokenMissingOrExpiredException;
 import com.ai.da.common.context.UserContext;
 import com.ai.da.common.security.config.SecurityProperties;
 import com.ai.da.common.security.jwt.JWTTokenHelper;
@@ -46,11 +47,12 @@ public class AuthenticationFilter extends OncePerRequestFilter {
                     "/webjars/", "/swagger-resources", "/v2/api-docs", "api/account/resetPwd",
                     "/api/python/saveGeneratePicture", "/api/python/getLibraryByUserId",
                     "/api/third/party/addUser","/api/third/party/addTrialUser", "/api/third/party/editUser", "/api/element/initDefaultSysFile",
-                    "/api/third/party/addNoLoginRequiredNew","/api/third/party/deleteNoLoginRequiredNew",
+                    "/api/third/party/addNoLoginRequiredNew","/api/third/party/deleteNoLoginRequiredNew","/api/third/party/updateNoLoginRequiredNew",
                     "/api/third/party/existNoLoginRequired","/api/third/party/getRedirectUrl",
                     "/api/python/flush","/api/account/healthy","/api/ali-pay/trade/notify","/api/paypal/ipn/back","/api/alipay-hk/trade/notify",
                     "/api/portfolio/page", "/api/portfolio/detail", "/api/portfolio/commentPage", "/api/portfolio/viewsIncrease",
-                    "/api/account/designWorksRegister","/api/account/questionnaire","/api/stripe/trade/notify"
+                    "/api/account/designWorksRegister","/api/account/questionnaire","/api/stripe/trade/notify",
+                    "/notification","/api/account/activateNewEmail","/api/third/party/auth/google_callback","/api/third/party/parseGoogleCredential","/api/third/party/receiveDesignResults","/api/third/party/parseWeChatCode"
             );
 
     @Override
@@ -100,7 +102,8 @@ public class AuthenticationFilter extends OncePerRequestFilter {
         if (StrUtil.isBlank(jwtToken)) {
             String ipAddress = RequestInfoUtil.getIpAddress(request);
             log.info("本次请求的ip为 ： " + ipAddress);
-            throw new RuntimeException("请传入token！");
+//            throw new RuntimeException("请传入token！");
+            throw new TokenMissingOrExpiredException("请传入token！");
         }
         if(jwtToken.equals("Bearer-eyJhbGciOiJIUzUxMiJ9.eyJqdGkiOiIyIiwic3ViIjoie1wiaWRcIjoyLFwidXNlcm5hbWVcIjpcImxpcnNcIn0iLCJpYXQiOjE2NjU3NDEwODcsImlzcyI6IkRXSiIsImF1dGhvcml0aWVzIjoiW10iLCJleHAiOjE2NzQzODEwODd9.ShM9R_NNFD7oo1OvxrEgg7PFeWinOuAKkuInUCMQupp66s64Hhv8tN0Wwr83nIN4rHPqtn95wmd4msWcvaFYJA")){
             //写死 暂时放行
@@ -111,7 +114,8 @@ public class AuthenticationFilter extends OncePerRequestFilter {
         if (validate) {
             AuthPrincipalVo principal = jwtTokenHelper.parserToUser(jwtToken);
             if (principal == null) {
-                throw new RuntimeException("TOKEN已过期，请重新登录！");
+//                throw new RuntimeException("TOKEN已过期，请重新登录！");
+                throw new TokenMissingOrExpiredException("TOKEN已过期，请重新登录！(token without userInfo)");
             }
             //先清空当前线程变量,防止上一个线程遗留
             UserContext.delete();
@@ -121,10 +125,12 @@ public class AuthenticationFilter extends OncePerRequestFilter {
             String cacheToken = LocalCacheUtils.getTokenCache(String.valueOf(principal.getId()));
 
             if(StringUtils.isEmpty(cacheToken)){
-                throw new RuntimeException("TOKEN已过期，请重新登录！");
+//                throw new RuntimeException("TOKEN已过期，请重新登录！");
+                throw new TokenMissingOrExpiredException("TOKEN已过期，请重新登录！(local cache empty)");
             }
             if(!cacheToken.equals(jwtToken) ){
-                throw new RuntimeException("TOKEN已过期，请重新登录！");
+//                throw new RuntimeException("TOKEN已过期，请重新登录！");
+                throw new TokenMissingOrExpiredException("TOKEN已过期，请重新登录！(token not match local cache)");
             }
 //                UsernamePasswordAuthenticationToken authentication = new UsernamePasswordAuthenticationToken(null, null);
 //                SecurityContextHolder.getContext().setAuthentication(authentication);

src/main/java/com/ai/da/common/security/jwt/JWTTokenHelper.java

@@ -2,6 +2,7 @@ package com.ai.da.common.security.jwt;
 
 import cn.hutool.core.map.MapUtil;
 import cn.hutool.core.util.StrUtil;
+import com.ai.da.common.constant.CommonConstant;
 import com.ai.da.common.security.config.SecurityProperties;
 import com.ai.da.model.vo.AuthPrincipalVo;
 import com.alibaba.fastjson.JSON;
@@ -30,6 +31,7 @@ public class JWTTokenHelper {
 
     private static final String ISSUER = "DWJ";
     private static final String AUTHORITIES = "authorities";
+    private static final String CHANGE_MAILBOX = "changeMailbox";
 
     public String createToken(AuthPrincipalVo principal) {
         String token = Jwts.builder()
@@ -65,4 +67,21 @@ public class JWTTokenHelper {
         token = token.replaceAll(securityProperties.getJwtTokenPrefix(), "");
         return Jwts.parser().setSigningKey(securityProperties.getJwtSecret()).parseClaimsJws(token).getBody();
     }
+
+    public String createToken(Long userId, String userEmail){
+        String token = Jwts.builder()
+                .setId(String.valueOf(userId))
+                .setSubject(userEmail + "_" + userId)
+                .setIssuedAt(new Date())
+                .setIssuer(ISSUER)
+                .claim(CHANGE_MAILBOX, JSON.toJSONString(new ArrayList<>()))//自定义属性  权限
+                .setExpiration(new Date(System.currentTimeMillis() + CommonConstant.CHANGE_MAILBOX_LINK_VALIDITY))
+                .signWith(SignatureAlgorithm.HS256, securityProperties.getJwtSecret())
+                .compact();
+        return token;
+    }
+
+    public String parseToEmailAndId(String token) {
+        return parser(token).getSubject();
+    }
 }

src/main/java/com/ai/da/common/task/AccountTask.java

@@ -1,11 +1,14 @@
 package com.ai.da.common.task;
 
+import com.ai.da.common.utils.RedisUtil;
+import com.ai.da.mapper.primary.entity.Account;
 import com.ai.da.service.AccountService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
+import java.util.List;
 
 @Component
 @Slf4j
@@ -13,19 +16,68 @@ public class AccountTask {
 
     @Resource
     private AccountService accountService;
+    @Resource
+    private RedisUtil redisUtil;
 
-    /** 每周日晚上刷新 年付用户、月付用户的积分 */
-    @Scheduled(cron = "59 59 23 ? * SUN")
+    /**
+     * 每周日晚上刷新 年付用户、月付用户的积分
+     * 替换为
+     * 每个月月初只刷新年付用户的积分
+     */
 //    @Scheduled(cron = "59 59 23 * * ?")
+    @Scheduled(cron = "0 0 0 1 * ?")
     public void refreshCreditsMonthly() {
-        log.info("每周日晚11：59：59刷新付费用户积分为 6000");
+        log.info("每月1号0点 将年费用户积分重置为 6000");
         accountService.refreshCreditsWeekly();
     }
 
-    // todo 多久执行一次？
     @Scheduled(cron = "0 */5 * * * *") // Run every 5 minutes
     public void getPaidUser() {
         // 获取code-create 表中 指定日期之后 订单状态为wc-processing的订单
         accountService.extendValidityForCC();
     }
+
+    // 每天凌晨0点执行一次
+    @Scheduled(cron = "0 0 0 * * ?")
+    public void cancelActivityBenefits() {
+        // 1、查询当前所有参与了活动且过期的用户
+        List<Account> accountList = accountService.getExpiredUserBySystemUser(4);
+
+        // 2、将到期用户置为游客
+        for (Account account : accountList) {
+            log.info("参与活动的用户{} : {} 于 {} 账号有效期到期，置为游客", account.getId(), account.getUserEmail(), account.getValidEndTime());
+            accountService.toVisitor(account);
+        }
+    }
+
+    // 每天检测正式用户到期情况，每天凌晨0点执行
+    @Scheduled(cron = "0 0 0 * * ?")
+    public void paidUserToVisitor() {
+        // 1、查询当前已过期正式用户或试用用户
+        List<Account> accountList = accountService.getExpiredUserBySystemUser(1);
+        accountList.addAll(accountService.getExpiredUserBySystemUser(2));
+        accountList.addAll(accountService.getExpiredUserBySystemUser(3));
+
+        // 2、将到期用户置为游客
+        for (Account account : accountList) {
+            log.info("用户{} : {} 于 {}账号有效期到期，置为游客", account.getId(), account.getUserEmail(), account.getValidEndTime());
+            accountService.toVisitor(account);
+        }
+    }
+
+    /**
+     * ！！关闭此定时器！！不再从Code-Create上默认创建AiDA游客
+     * 将Code-Create上注册的用户添加为AiDA的游客
+     */
+//    @Scheduled(cron = "0 */5 * * * *") // Run every 5 minutes
+    public void registerUserToVisitor() {
+        accountService.registerUserToVisitor();
+    }
+
+    @Scheduled(cron = "0 0 0 1 * ?")
+    // 每月初刷新所有用户用户名剩余修改次数
+    public void resetUsernameModifyTimes(){
+        log.info("重置所有用户的用户名修改次数");
+        redisUtil.batchDeleteKeysWithSamePrefix(RedisUtil.NICKNAME_MODIFY_TIMES);
+    }
 }

src/main/java/com/ai/da/common/task/AliPayTask.java

@@ -1,42 +0,0 @@
-package com.ai.da.common.task;
-
-import com.ai.da.mapper.primary.entity.OrderInfo;
-import com.ai.da.common.enums.PayTypeEnum;
-import com.ai.da.service.AliPayService;
-import com.ai.da.service.OrderInfoService;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.scheduling.annotation.Scheduled;
-import org.springframework.stereotype.Component;
-
-import javax.annotation.Resource;
-import java.util.List;
-
-@Slf4j
-@Component
-public class AliPayTask {
-
-    @Resource
-    private OrderInfoService orderInfoService;
-
-    @Resource
-    private AliPayService aliPayService;
-
-    /**
-     * 从第0秒开始每隔30秒执行1次，查询创建超过5分钟，并且未支付的订单
-     */
-//    @Scheduled(cron = "0/30 * * * * ?")
-    public void orderConfirm(){
-
-//        log.info("Alipay orderConfirm 被执行......");
-
-        List<OrderInfo> orderInfoList = orderInfoService.getNoPayOrderByDuration(5, PayTypeEnum.ALIPAY.getType());
-
-        for (OrderInfo orderInfo : orderInfoList) {
-            String orderNo = orderInfo.getOrderNo();
-            log.warn("超时订单 ===> {}", orderNo);
-
-            //核实订单状态：调用支付宝查单接口
-            aliPayService.checkOrderStatus(orderNo);
-        }
-    }
-}

src/main/java/com/ai/da/common/task/GenerateTask.java

@@ -1,21 +0,0 @@
-package com.ai.da.common.task;
-
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.scheduling.annotation.Scheduled;
-import org.springframework.stereotype.Component;
-
-@Component
-@Slf4j
-public class GenerateTask {
-
-//    @Scheduled(cron = "0 0 */1 * * ?")
-    public void generateScheduled(){
-        log.info("测试定时器：generate");
-
-        try{
-
-        }catch(Exception e){
-
-        }
-    }
-}

src/main/java/com/ai/da/common/task/MoveDataScheduler.java

@@ -0,0 +1,216 @@
+//package com.ai.da.common.task;
+//
+//import com.ai.da.common.utils.CopyUtil;
+//import com.ai.da.common.utils.ExcelReader;
+//import com.ai.da.common.utils.MinioUtil;
+//import com.ai.da.common.utils.SendEmailUtil;
+//import com.ai.da.mapper.primary.*;
+//import com.ai.da.mapper.primary.entity.*;
+//import com.ai.da.mapper.secondary.AttributeRetrievalMapper;
+//import com.ai.da.mapper.third.*;
+//import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+//import org.apache.commons.lang3.StringUtils;
+//import org.apache.poi.ss.usermodel.Row;
+//import org.apache.poi.ss.usermodel.Sheet;
+//import org.apache.poi.ss.usermodel.Workbook;
+//import org.apache.poi.xssf.usermodel.XSSFWorkbook;
+//import org.springframework.stereotype.Component;
+//import org.springframework.util.CollectionUtils;
+//
+//import javax.annotation.PostConstruct;
+//import javax.annotation.Resource;
+//import java.io.FileOutputStream;
+//import java.io.IOException;
+//import java.nio.file.Files;
+//import java.nio.file.Paths;
+//import java.time.LocalDate;
+//import java.time.format.DateTimeFormatter;
+//import java.util.List;
+//import java.util.concurrent.ExecutorService;
+//import java.util.concurrent.Executors;
+//import java.util.concurrent.TimeUnit;
+//import java.util.stream.Collectors;
+//
+//@Component
+//public class MoveDataScheduler {
+//
+//    @PostConstruct
+//    public void test() {
+//        moveData();
+//    }
+//
+//    @Resource
+//    private UserLikeGroupMapper userLikeGroupMapper;
+//    @Resource
+//    private UserLikeGroupZSMapper userLikeGroupZSMapper;
+//    @Resource
+//    private UserLikeMapper userLikeMapper;
+//    @Resource
+//    private UserLikeZSMapper userLikeZSMapper;
+//    @Resource
+//    private CollectionElementMapper collectionElementMapper;
+//    @Resource
+//    private CollectionElementZSMapper collectionElementZSMapper;
+//
+//    @Resource
+//    private CollectionMapper collectionMapper;
+//
+//    @Resource
+//    private CollectionZSMapper collectionZSMapper;
+//
+//    @Resource
+//    private DesignMapper designMapper;
+//
+//    @Resource
+//    private DesignZSMapper designZSMapper;
+//
+//    @Resource
+//    private DesignItemMapper designItemMapper;
+//
+//    @Resource
+//    private DesignItemZSMapper designItemZSMapper;
+//
+//    @Resource
+//    private TDesignPythonOutfitMapper designPythonOutfitMapper;
+//
+//    @Resource
+//    private TDesignPythonOutfitZSMapper designPythonOutfitZSMapper;
+//
+//    @Resource
+//    private TDesignPythonOutfitDetailMapper designPythonOutfitDetailMapper;
+//
+//    @Resource
+//    private TDesignPythonOutfitDetailZSMapper designPythonOutfitDetailZSMapper;
+//
+//    @Resource
+//    private DesignItemDetailMapper designItemDetailMapper;
+//    @Resource
+//    private DesignItemZSDetailMapper designItemDetailZSMapper;
+//
+//    @Resource
+//    private DesignItemDetailPrintMapper designItemDetailPrintMapper;
+//
+//    @Resource
+//    private DesignItemDetailPrintZSMapper designItemDetailPrintZSMapper;
+//
+//
+//    private void moveData() {
+//        // 查询用户所有history记录
+//        QueryWrapper<UserLikeGroup> userLikeGroupQueryWrapper = new QueryWrapper<>();
+//        userLikeGroupQueryWrapper.lambda().eq(UserLikeGroup::getAccountId, 11411);
+//        List<UserLikeGroup> userLikeGroupList = userLikeGroupMapper.selectList(userLikeGroupQueryWrapper);
+//
+//        for (UserLikeGroup userLikeGroup : userLikeGroupList) {
+//
+//            com.ai.da.mapper.third.entity.UserLikeGroup userLikeGroupZS = CopyUtil.copyObject(userLikeGroup, com.ai.da.mapper.third.entity.UserLikeGroup.class);
+//            userLikeGroupZS.setAccountId(11420L);
+//            userLikeGroupZS.setId(null);
+//            Collection collection = collectionMapper.selectById(userLikeGroup.getCollectionId());
+//            com.ai.da.mapper.third.entity.Collection collectionZS = CopyUtil.copyObject(collection, com.ai.da.mapper.third.entity.Collection.class);
+//            collectionZS.setAccountId(11420L);
+//            collectionZS.setId(null);
+//
+//            if (collection.getMoodTemplateId() != null) {
+//                CollectionElement element = collectionElementMapper.selectById(collection.getMoodTemplateId());
+//                com.ai.da.mapper.third.entity.CollectionElement collectionElementZS = CopyUtil.copyObject(element, com.ai.da.mapper.third.entity.CollectionElement.class);
+//                collectionElementZS.setAccountId(11420L);
+//                collectionElementZS.setId(null);
+//                collectionElementZSMapper.insert(collectionElementZS);
+//                collectionZS.setMoodTemplateId(String.valueOf(collectionElementZS.getId()));
+//            }
+//            collectionZSMapper.insert(collectionZS);
+//            userLikeGroupZS.setCollectionId(collectionZS.getId());
+//            userLikeGroupZSMapper.insert(userLikeGroupZS);
+//
+//            // 生成元素
+//            QueryWrapper<CollectionElement> collectionElementQueryWrapper = new QueryWrapper<>();
+//            collectionElementQueryWrapper.lambda().eq(CollectionElement::getCollectionId, userLikeGroup.getCollectionId());
+//            List<CollectionElement> collectionElements = collectionElementMapper.selectList(collectionElementQueryWrapper);
+//
+//            for (CollectionElement collectionElement : collectionElements) {
+//                com.ai.da.mapper.third.entity.CollectionElement collectionElementZS = CopyUtil.copyObject(collectionElement, com.ai.da.mapper.third.entity.CollectionElement.class);
+//                collectionElementZS.setId(null);
+//                collectionElementZS.setAccountId(11420L);
+//                collectionElementZS.setCollectionId(collectionZS.getId());
+//                collectionElementZSMapper.insert(collectionElementZS);
+//            }
+//
+//            // 查询记录关联
+//            QueryWrapper<UserLike> userLikeQueryWrapper = new QueryWrapper<>();
+//            userLikeQueryWrapper.lambda().eq(UserLike::getUserLikeGroupId, userLikeGroup.getId());
+//            List<UserLike> userLikes = userLikeMapper.selectList(userLikeQueryWrapper);
+//            for (UserLike userLike : userLikes) {
+//                Design design = designMapper.selectById(userLike.getDesignId());
+//                com.ai.da.mapper.third.entity.Design designZS = CopyUtil.copyObject(design, com.ai.da.mapper.third.entity.Design.class);
+//                designZS.setId(null);
+//                designZS.setAccountId(11420L);
+//                designZS.setCollectionId(collectionZS.getId());
+//                designZSMapper.insert(designZS);
+//
+//                com.ai.da.mapper.third.entity.UserLike userLikeZS = CopyUtil.copyObject(userLike, com.ai.da.mapper.third.entity.UserLike.class);
+////                Design design = designMapper.selectById(userLike.getDesignId());
+//                userLikeZS.setId(null);
+//                DesignItem designItem = designItemMapper.selectById(userLike.getDesignItemId());
+//                com.ai.da.mapper.third.entity.DesignItem designItemZS = CopyUtil.copyObject(designItem, com.ai.da.mapper.third.entity.DesignItem.class);
+//                designItemZS.setId(null);
+//                designItemZS.setAccountId(11420L);
+//                designItemZS.setDesignId(designZS.getId());
+//                designItemZSMapper.insert(designItemZS);
+//
+//                QueryWrapper<DesignItemDetail> designItemDetailQueryWrapper = new QueryWrapper<>();
+//                designItemDetailQueryWrapper.lambda().eq(DesignItemDetail::getDesignItemId, designItem.getId());
+//                List<DesignItemDetail> designItemDetails = designItemDetailMapper.selectList(designItemDetailQueryWrapper);
+//                for (DesignItemDetail designItemDetail : designItemDetails) {
+//                    com.ai.da.mapper.third.entity.DesignItemDetail designItemDetailZS = CopyUtil.copyObject(designItemDetail, com.ai.da.mapper.third.entity.DesignItemDetail.class);
+//                    designItemDetailZS.setId(null);
+//                    designItemDetailZS.setDesignItemId(designItemZS.getId());
+//                    designItemDetailZS.setAccountId(11420L);
+//                    designItemDetailZS.setDesignId(designZS.getId());
+//                    designItemDetailZSMapper.insert(designItemDetailZS);
+//
+//                    QueryWrapper<DesignItemDetailPrint> designItemDetailPrintQueryWrapper = new QueryWrapper<>();
+//                    designItemDetailPrintQueryWrapper.lambda().eq(DesignItemDetailPrint::getDesignItemDetailId, designItemDetail.getId());
+//                    List<DesignItemDetailPrint> designItemDetailPrintList = designItemDetailPrintMapper.selectList(designItemDetailPrintQueryWrapper);
+//                    if (!CollectionUtils.isEmpty(designItemDetailPrintList)) {
+//                        for (DesignItemDetailPrint designItemDetailPrint : designItemDetailPrintList) {
+//                            com.ai.da.mapper.third.entity.DesignItemDetailPrint designItemDetailPrintZS = CopyUtil.copyObject(designItemDetailPrint, com.ai.da.mapper.third.entity.DesignItemDetailPrint.class);
+//                            designItemDetailPrintZS.setId(null);
+//                            designItemDetailPrintZS.setDesignItemDetailId(designItemDetailZS.getId());
+//                            designItemDetailPrintZSMapper.insert(designItemDetailPrintZS);
+//                        }
+//                    }
+//                }
+//
+//                userLikeZS.setDesignItemId(designItemZS.getId());
+//                TDesignPythonOutfit tDesignPythonOutfit = designPythonOutfitMapper.selectById(userLike.getDesignOutfitId());
+//                com.ai.da.mapper.third.entity.TDesignPythonOutfit tDesignPythonOutfitZS = CopyUtil.copyObject(tDesignPythonOutfit, com.ai.da.mapper.third.entity.TDesignPythonOutfit.class);
+//                tDesignPythonOutfitZS.setId(null);
+//                tDesignPythonOutfitZS.setDesignItemId(designItemZS.getId());
+//                tDesignPythonOutfitZS.setCollectionId(collectionZS.getId());
+//                tDesignPythonOutfitZS.setUserId(11420L);
+//                tDesignPythonOutfitZS.setDesignId(designZS.getId());
+//                designPythonOutfitZSMapper.insert(tDesignPythonOutfitZS);
+//
+//                userLikeZS.setUserLikeGroupId(userLikeGroupZS.getId());
+//                userLikeZS.setDesignId(designZS.getId());
+//                userLikeZS.setDesignOutfitId(tDesignPythonOutfitZS.getId());
+//                userLikeZSMapper.insert(userLikeZS);
+//
+//                QueryWrapper<TDesignPythonOutfitDetail> designPythonOutfitDetailQueryWrapper = new QueryWrapper<>();
+//                designPythonOutfitDetailQueryWrapper.lambda().eq(TDesignPythonOutfitDetail::getDesignPythonOutfitId, tDesignPythonOutfit.getId());
+//                List<TDesignPythonOutfitDetail> tDesignPythonOutfitDetails = designPythonOutfitDetailMapper.selectList(designPythonOutfitDetailQueryWrapper);
+//                for (TDesignPythonOutfitDetail tDesignPythonOutfitDetail : tDesignPythonOutfitDetails) {
+//                    com.ai.da.mapper.third.entity.TDesignPythonOutfitDetail tDesignPythonOutfitDetailZS = CopyUtil.copyObject(tDesignPythonOutfitDetail, com.ai.da.mapper.third.entity.TDesignPythonOutfitDetail.class);
+//                    tDesignPythonOutfitDetailZS.setDesignPythonOutfitId(tDesignPythonOutfitZS.getId());
+//                    tDesignPythonOutfitDetailZS.setId(null);
+//                    tDesignPythonOutfitDetailZS.setDesignId(designZS.getId());
+//                    designPythonOutfitDetailZSMapper.insert(tDesignPythonOutfitDetailZS);
+//                }
+//            }
+//        }
+//
+//
+//    }
+//
+//
+//}

src/main/java/com/ai/da/common/task/PaymentTask.java

@@ -0,0 +1,123 @@
+package com.ai.da.common.task;
+
+import com.ai.da.common.enums.PayTypeEnum;
+import com.ai.da.mapper.primary.entity.OrderInfo;
+import com.ai.da.service.*;
+import com.paypal.http.exceptions.SerializeException;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+import java.time.LocalDate;
+import java.util.List;
+
+@Slf4j
+@Component
+public class PaymentTask {
+
+    @Resource
+    private OrderInfoService orderInfoService;
+
+    @Resource
+    private StripeService stripeService;
+
+    @Resource
+    private AffiliateService affiliateService;
+
+    // 考虑删除该定时任务（原因：之后的订单列允许用户查看发票，发票未过期时仍可以支付，所以不需要手动使订单过期）
+//    @Scheduled(cron = "0/30 * * * * ?")
+    public void orderConfirmForStripe() throws SerializeException {
+
+        // 查看超过30分钟以上仍未支付的订单 置为超时订单
+        List<OrderInfo> orderInfoList = orderInfoService.getNoPayOrderByDuration(30, PayTypeEnum.STRIPE.getType());
+
+        for (OrderInfo orderInfo : orderInfoList) {
+            String orderNo = orderInfo.getOrderNo();
+            log.warn("超时订单 ===> {}", orderNo);
+
+            //核实订单状态：调用支付宝查单接口
+            stripeService.checkOrderStatus(orderNo);
+
+        }
+    }
+
+    @Resource
+    private PayPalCheckoutService payPalCheckoutService;
+
+    @Scheduled(cron = "0/30 * * * * ?")
+    public void orderConfirmForPaypal() throws SerializeException {
+
+//        log.info("PayPal orderConfirm 被执行......");
+
+        List<OrderInfo> orderInfoList = orderInfoService.getNoPayOrderByDuration(30, PayTypeEnum.PAYPAL.getType());
+
+        for (OrderInfo orderInfo : orderInfoList) {
+            String orderNo = orderInfo.getOrderNo();
+            log.warn("超时订单 ===> {}", orderNo);
+
+            //核实订单状态：调用支付宝查单接口
+            payPalCheckoutService.checkOrderStatus(orderNo);
+
+        }
+    }
+
+    @Resource
+    private AliPayService aliPayService;
+
+    /**
+     * 从第0秒开始每隔30秒执行1次，查询创建超过5分钟，并且未支付的订单
+     */
+//    @Scheduled(cron = "0/30 * * * * ?")
+    public void orderConfirmForAlipay(){
+/*
+        log.info("Alipay orderConfirm 被执行......");
+
+        List<OrderInfo> orderInfoList = orderInfoService.getNoPayOrderByDuration(5, PayTypeEnum.ALIPAY.getType());
+
+        for (OrderInfo orderInfo : orderInfoList) {
+            String orderNo = orderInfo.getOrderNo();
+            log.warn("超时订单 ===> {}", orderNo);
+
+            //核实订单状态：调用支付宝查单接口
+            aliPayService.checkOrderStatus(orderNo);
+        }*/
+    }
+
+    // ！！关闭此定时器，改为提前三天站内信提醒！！
+    // 提前7天向用户发送提醒邮件,每天早上8点执行
+//    @Scheduled(cron = "0 0 8 * * ?")
+    public void subscriptionReminder(){
+        stripeService.subscriptionReminder();
+    }
+
+
+    // 如果有订阅已创建，但是没有发邮件通知的，需要主动获取回调信息并向用户发送邮件
+    public void checkSubscriptionPayment(){
+        //
+    }
+
+    @Scheduled(cron = "0 */5 * * * *") // Run every 5 minutes
+    public void updateAffiliateInfoWithPayment(){
+//        log.info("佣金计算定时器");
+        affiliateService.updateAffiliateInfoWithPayment();
+    }
+
+    @Scheduled(cron = "0 0 8 28-31 * ?")
+    public void commissionSummaryReminder(){
+        // 每个月末的最后一天的早上八点执行
+        LocalDate today = LocalDate.now();
+        // 判断是否为月底
+        if (today.plusDays(1).getDayOfMonth() == 1) {
+            log.info("今天是月底，执行佣金结算提醒任务！");
+            affiliateService.commissionCalculation(null, null);
+        }
+    }
+
+    @Scheduled(cron = "0 */5 * * * *") // Run every 5 minutes
+    public void calcCouponsCommission(){
+//        log.info("优惠券佣金计算定时器");
+        affiliateService.calcCouponsCommission();
+    }
+
+}

src/main/java/com/ai/da/common/task/PaypalTask.java

@@ -1,42 +0,0 @@
-package com.ai.da.common.task;
-
-import com.ai.da.common.enums.PayTypeEnum;
-import com.ai.da.mapper.primary.entity.OrderInfo;
-import com.ai.da.service.OrderInfoService;
-import com.ai.da.service.PayPalCheckoutService;
-import com.paypal.http.exceptions.SerializeException;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.scheduling.annotation.Scheduled;
-import org.springframework.stereotype.Component;
-import org.springframework.stereotype.Service;
-
-import javax.annotation.Resource;
-import java.util.List;
-
-@Slf4j
-@Component
-public class PaypalTask {
-
-    @Resource
-    private OrderInfoService orderInfoService;
-
-    @Resource
-    private PayPalCheckoutService payPalCheckoutService;
-
-    @Scheduled(cron = "0/30 * * * * ?")
-    public void orderConfirm() throws SerializeException {
-
-//        log.info("PayPal orderConfirm 被执行......");
-
-        List<OrderInfo> orderInfoList = orderInfoService.getNoPayOrderByDuration(30, PayTypeEnum.PAYPAL.getType());
-
-        for (OrderInfo orderInfo : orderInfoList) {
-            String orderNo = orderInfo.getOrderNo();
-            log.warn("超时订单 ===> {}", orderNo);
-
-            //核实订单状态：调用支付宝查单接口
-            payPalCheckoutService.checkOrderStatus(orderNo);
-
-        }
-    }
-}

src/main/java/com/ai/da/common/task/StripeTask.java

@@ -1,40 +0,0 @@
-package com.ai.da.common.task;
-
-import com.ai.da.common.enums.PayTypeEnum;
-import com.ai.da.mapper.primary.entity.OrderInfo;
-import com.ai.da.service.OrderInfoService;
-import com.ai.da.service.StripeService;
-import com.paypal.http.exceptions.SerializeException;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.scheduling.annotation.Scheduled;
-import org.springframework.stereotype.Component;
-
-import javax.annotation.Resource;
-import java.util.List;
-
-@Slf4j
-@Component
-public class StripeTask {
-
-    @Resource
-    private OrderInfoService orderInfoService;
-
-    @Resource
-    private StripeService stripeService;
-
-    @Scheduled(cron = "0/30 * * * * ?")
-    public void orderConfirm() throws SerializeException {
-
-        // 查看超过30分钟以上仍未支付的订单 置为超时订单
-        List<OrderInfo> orderInfoList = orderInfoService.getNoPayOrderByDuration(30, PayTypeEnum.STRIPE.getType());
-
-        for (OrderInfo orderInfo : orderInfoList) {
-            String orderNo = orderInfo.getOrderNo();
-            log.warn("超时订单 ===> {}", orderNo);
-
-            //核实订单状态：调用支付宝查单接口
-            stripeService.checkOrderStatus(orderNo);
-
-        }
-    }
-}

src/main/java/com/ai/da/common/utils/ComprehensivePunctuationConverter.java

@@ -0,0 +1,88 @@
+package com.ai.da.common.utils;
+
+import java.util.HashMap;
+import java.util.Map;
+
+public class ComprehensivePunctuationConverter {
+    private static final Map<Character, Character> FULL_TO_HALF_MAP = new HashMap<>();
+
+    static {
+        // 中文标点到英文标点的映射（扩展版）
+        FULL_TO_HALF_MAP.put('，', ',');
+        FULL_TO_HALF_MAP.put('。', '.');
+        FULL_TO_HALF_MAP.put('；', ';');
+        FULL_TO_HALF_MAP.put('：', ':');
+        FULL_TO_HALF_MAP.put('？', '?');
+        FULL_TO_HALF_MAP.put('！', '!');
+        FULL_TO_HALF_MAP.put('（', '(');
+        FULL_TO_HALF_MAP.put('）', ')');
+        FULL_TO_HALF_MAP.put('【', '[');
+        FULL_TO_HALF_MAP.put('】', ']');
+        FULL_TO_HALF_MAP.put('「', '\'');
+        FULL_TO_HALF_MAP.put('」', '\'');
+        FULL_TO_HALF_MAP.put('『', '"');
+        FULL_TO_HALF_MAP.put('』', '"');
+        FULL_TO_HALF_MAP.put('、', '\\');
+        FULL_TO_HALF_MAP.put('～', '~');
+        FULL_TO_HALF_MAP.put('—', '-');
+        FULL_TO_HALF_MAP.put('．', '.');
+        FULL_TO_HALF_MAP.put('〈', '<');
+        FULL_TO_HALF_MAP.put('〉', '>');
+        FULL_TO_HALF_MAP.put('《', '«');
+        FULL_TO_HALF_MAP.put('》', '»');
+        FULL_TO_HALF_MAP.put('〝', '"');
+        FULL_TO_HALF_MAP.put('〞', '"');
+        FULL_TO_HALF_MAP.put('﹁', '"');
+        FULL_TO_HALF_MAP.put('﹂', '"');
+        FULL_TO_HALF_MAP.put('…', '.');
+        FULL_TO_HALF_MAP.put('﹏', '_');
+
+        // 全角字母和数字
+        for (char c = 'Ａ'; c <= 'Ｚ'; c++) {
+            FULL_TO_HALF_MAP.put(c, (char)(c - 'Ａ' + 'A'));
+        }
+        for (char c = 'ａ'; c <= 'ｚ'; c++) {
+            FULL_TO_HALF_MAP.put(c, (char)(c - 'ａ' + 'a'));
+        }
+        for (char c = '０'; c <= '９'; c++) {
+            FULL_TO_HALF_MAP.put(c, (char)(c - '０' + '0'));
+        }
+    }
+
+    /**
+     * 将字符串中的全角字符（包括标点、字母、数字）转换为半角字符
+     */
+    public static String convertToHalfWidth(String input) {
+        if (input == null || input.isEmpty()) {
+            return input;
+        }
+
+        StringBuilder result = new StringBuilder();
+        for (int i = 0; i < input.length(); i++) {
+            char c = input.charAt(i);
+
+            // 检查映射表
+            if (FULL_TO_HALF_MAP.containsKey(c)) {
+                result.append(FULL_TO_HALF_MAP.get(c));
+            }
+            // 处理全角空格（Unicode 12288）
+            else if (c == '　') {
+                result.append(' ');
+            }
+            // 其他字符保持不变
+            else {
+                result.append(c);
+            }
+        }
+
+        return result.toString();
+    }
+
+    public static void main(String[] args) {
+//        String text = "这是一个全角示例，包含：中文标点、全角字母（ＡＢＣ）、全角数字（１２３）　还有全角空格！";
+        String text = "birds，yellow";
+        String converted = convertToHalfWidth(text);
+        System.out.println("原始文本: " + text);
+        System.out.println("转换后: " + converted);
+    }
+}

src/main/java/com/ai/da/common/utils/DateUtil.java

@@ -1,5 +1,6 @@
 package com.ai.da.common.utils;
 
+import com.ai.da.common.constant.CommonConstant;
 import lombok.extern.slf4j.Slf4j;
 
 import java.text.ParseException;
@@ -9,8 +10,8 @@ import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.time.ZoneId;
 import java.time.format.DateTimeFormatter;
-import java.util.Calendar;
 import java.util.Date;
+import java.util.Locale;
 import java.util.TimeZone;
 
 @Slf4j
@@ -18,6 +19,8 @@ public class DateUtil {
     public static final String YYYY_MM_DD_HH_MM_SS = "yyyy-MM-dd HH:mm:ss";
     public static final String YYYYMM = "yyyyMM";
     public static final String YYYY_MM_DD = "yyyyMMdd";
+    public static final String YYYY_MM_DD_HH = "yyyyMMddHH";
+    public static final String YYYY_MM_DD_hh_mm_ss = "yyyyMMddHHMMss";
 
     /**
      * LocalDate -> Date
@@ -81,4 +84,21 @@ public class DateUtil {
         return String.valueOf(epochSecond).substring(0, 10);
     }
 
+    public static String changeTimeStampFormat(Long timeStamp, String type, String format){
+        // 将秒级时间戳转换为毫秒级
+        if (type.equals("seconds")){
+            timeStamp = timeStamp * 1000;
+        }
+        // 输出格式
+        SimpleDateFormat outputFormat = new SimpleDateFormat(format, Locale.ENGLISH);
+        // 创建Date对象
+        Date date = new Date(timeStamp);
+        // 格式化输出
+        return outputFormat.format(date);
+    }
+
+    public static String changeTimeStampFormat(LocalDateTime localDate){
+        return localDate.format(DateTimeFormatter.ofPattern(CommonConstant.TIME_FORMAT_MMM_dd_yyyy_EEEE, Locale.US));
+    }
+
 }

src/main/java/com/ai/da/common/utils/ExcelReader.java

@@ -1,6 +1,7 @@
 package com.ai.da.common.utils;
 
 import lombok.Data;
+import org.apache.poi.ss.usermodel.Cell;
 import org.apache.poi.ss.usermodel.Row;
 import org.apache.poi.ss.usermodel.Sheet;
 import org.apache.poi.ss.usermodel.Workbook;
@@ -23,11 +24,30 @@ public class ExcelReader {
             for (int i = 0; i < numberOfColumns; i++) {
                 List<String> columnData = new ArrayList<>();
                 for (Row row : sheet) {
-                    columnData.add(row.getCell(i).getStringCellValue());
+                    Cell cell = row.getCell(i);
+                    if (cell != null) {
+                        switch (cell.getCellType()) {
+                            case STRING:
+                                columnData.add(cell.getStringCellValue());
+                                break;
+                            case NUMERIC:
+                                columnData.add(String.valueOf(cell.getNumericCellValue()));
+                                break;
+                            case BOOLEAN:
+                                columnData.add(String.valueOf(cell.getBooleanCellValue()));
+                                break;
+                            default:
+                                // 跳过空单元格或其他类型（比如错误类型）
+                                break;
                         }
+                    }
+                }
+                // 只有当这一列有数据时，才添加到结果列表中
+                if (!columnData.isEmpty()) {
                     data.add(columnData);
                 }
             }
+        }
         return data;
     }
 }

src/main/java/com/ai/da/common/utils/LocalCacheUtils.java

@@ -28,7 +28,7 @@ public final class LocalCacheUtils {
     private static LoadingCache<String, String> loadTokenCache() {
         LoadingCache<String, String> tokenCache = CacheBuilder.newBuilder()
                 .concurrencyLevel(10)
-                .expireAfterWrite(24 * 100, TimeUnit.HOURS)
+                .expireAfterWrite(24 * (7 - 1), TimeUnit.HOURS)
                 .initialCapacity(100)
                 .maximumSize(10000)
                 .recordStats()

src/main/java/com/ai/da/common/utils/MinioUtil.java

@@ -14,13 +14,12 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 import org.springframework.web.multipart.MultipartFile;
 
+import javax.imageio.ImageIO;
+import java.awt.image.BufferedImage;
 import java.io.*;
 import java.security.InvalidKeyException;
 import java.security.NoSuchAlgorithmException;
-import java.util.ArrayList;
-import java.util.Base64;
-import java.util.List;
-import java.util.UUID;
+import java.util.*;
 import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
 
@@ -441,6 +440,16 @@ public class MinioUtil {
         return getPreSignedUrl(bucketName, String.valueOf(fileName), expiry);
     }
 
+    public boolean doesObjectExist(String path) {
+        if (!path.contains("/")) {
+            throw new BusinessException("the.path.is.error");
+        }
+        int index = path.indexOf("/");
+        String bucketName = path.substring(0, index);
+        String objectName = path.substring(index + 1);
+        return doesObjectExist(bucketName, objectName);
+    }
+
     public boolean doesObjectExist(String bucketName, String objectName) {
         try {
             minioClient.statObject(
@@ -484,6 +493,83 @@ public class MinioUtil {
             return null; // or throw an exception
         }
     }
+
+    /**
+     * 从 MinIO 下载对象到本地路径
+     *
+     * @param bucketName   存储桶名称
+     * @param objectName   MinIO 上对象的名称
+     * @param localFilePath 本地文件路径
+     */
+    public void downloadMinioObjectToLocal(String bucketName, String objectName, String localFilePath) {
+        File localFile = new File(localFilePath);
+        File parentDir = localFile.getParentFile();
+        if (parentDir != null) {
+            parentDir.mkdirs(); // 创建文件夹，确保路径结构与 MinIO 一致
+        }
+
+        try (InputStream stream = minioClient.getObject(
+                GetObjectArgs.builder().bucket(bucketName).object(objectName).build());
+             FileOutputStream out = new FileOutputStream(localFile)) {
+
+            byte[] buffer = new byte[1024];
+            int bytesRead;
+            while ((bytesRead = stream.read(buffer)) != -1) {
+                out.write(buffer, 0, bytesRead);
+            }
+            log.info("Downloaded object {} to {}", objectName, localFilePath);
+        } catch (Exception e) {
+            log.error("Error while downloading object {}: {}", objectName, e.getMessage());
+        }
+    }
+
+    /**
+     * 从路径中提取存储桶名称
+     *
+     * @param path MinIO 路径
+     * @return 存储桶名称
+     */
+    public String getBucketNameFromPath(String path) {
+        int index = path.indexOf("/");
+        return path.substring(0, index); // 获取第一级路径作为 bucket 名称
+    }
+
+    /**
+     * 从路径中提取对象名称
+     *
+     * @param path MinIO 路径
+     * @return 对象名称
+     */
+    public String getObjectNameFromPath(String path) {
+        int index = path.indexOf("/");
+        return path.substring(index + 1); // 获取路径的其余部分作为对象名称
+    }
+
+    public List<Integer> getImagesWidthAndHeight(String path){
+        int index = path.indexOf("/");
+        String bucketName = path.substring(0, index);
+        String objectName = path.substring(index + 1);
+        try {
+            // 从 MinIO 下载图片
+            GetObjectResponse response = minioClient.getObject(
+                    GetObjectArgs.builder()
+                            .bucket(bucketName)
+                            .object(objectName)
+                            .build()
+            );
+
+            BufferedImage image = ImageIO.read(response);
+            int width = image.getWidth();
+            int height = image.getHeight();
+
+            log.info("Image path {}, Width: {}, Height: {}", path, width, height);
+            response.close();
+            return Arrays.asList(width, height);
+        } catch (MinioException | IOException | NoSuchAlgorithmException | InvalidKeyException e) {
+            log.error("图片:{}, 获取宽高异常", path);
+            throw new BusinessException(e.getMessage());
+        }
+    }
 }
 
 

src/main/java/com/ai/da/common/utils/PantoneUtils.java

@@ -28,4 +28,70 @@ public class PantoneUtils {
         return new int[]{Math.round(hsv[0]), Math.round(hsv[1] * 100), Math.round(hsv[2] * 100)};
     }
 
+    public static int[] hsvToRgb(int h, int s, int v) {
+        // 确保 h 在 [0, 360) 范围内
+        h = h % 360;
+        if (h < 0) {
+            h += 360;
+        }
+
+        // 确保 s 和 v 在 [0, 100] 范围内
+        s = Math.max(0, Math.min(100, s));
+        v = Math.max(0, Math.min(100, v));
+
+        // 将 s 和 v 映射到 [0, 1] 范围
+        float sNorm = s / 100.0f;
+        float vNorm = v / 100.0f;
+
+        // 计算色相所在的区间
+        int hi = (h / 60) % 6;
+        float f = (h / 60.0f) - hi;
+        float p = vNorm * (1 - sNorm);
+        float q = vNorm * (1 - f * sNorm);
+        float t = vNorm * (1 - (1 - f) * sNorm);
+
+        float r, g, b;
+        switch (hi) {
+            case 0:
+                r = vNorm;
+                g = t;
+                b = p;
+                break;
+            case 1:
+                r = q;
+                g = vNorm;
+                b = p;
+                break;
+            case 2:
+                r = p;
+                g = vNorm;
+                b = t;
+                break;
+            case 3:
+                r = p;
+                g = q;
+                b = vNorm;
+                break;
+            case 4:
+                r = t;
+                g = p;
+                b = vNorm;
+                break;
+            case 5:
+                r = vNorm;
+                g = p;
+                b = q;
+                break;
+            default:
+                throw new RuntimeException("Invalid HSV values");
+        }
+
+        // 将 RGB 值从 [0, 1] 转换为 [0, 255]
+        int red = Math.round(r * 255);
+        int green = Math.round(g * 255);
+        int blue = Math.round(b * 255);
+
+        return new int[]{red, green, blue};
+    }
+
 }

src/main/java/com/ai/da/common/utils/RedisUtil.java

@@ -1,16 +1,14 @@
 package com.ai.da.common.utils;
 
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.data.redis.core.HashOperations;
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.data.redis.core.ZSetOperations;
 import org.springframework.stereotype.Component;
 import org.springframework.util.CollectionUtils;
 
 import javax.annotation.Resource;
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
+import java.util.*;
 import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
 
@@ -86,8 +84,10 @@ public class RedisUtil {
     /**
      * 将数据放入set缓存
      */
-    public void addToSet(String key, String value) {
+    public void addToSet(String key, String value, Long expiresIn) {
         redisTemplate.opsForSet().add(key, value);
+        // 设置过期时间
+        redisTemplate.expire(key, expiresIn, TimeUnit.SECONDS);
     }
 
     /**
@@ -154,6 +154,8 @@ public class RedisUtil {
         return redisTemplate.keys(key);
     }
 
+    public Long getSize(String key){return redisTemplate.opsForSet().size(key);}
+
     public List<String> getMultiValue(Set<String> keys){
         return redisTemplate.opsForValue().multiGet(keys);
     }
@@ -216,4 +218,91 @@ public class RedisUtil {
         return redisTemplate.opsForValue().increment(key, 0);
     }
 
+    public Long getViewCount(String key) {
+        Object value = redisTemplate.opsForValue().get(key);
+        if (value instanceof Integer) {
+            return Long.valueOf((Integer) value);
+        } else if (value instanceof Long) {
+            return (Long) value;
+        } else if (value instanceof String) {
+            return Long.valueOf((String) value);
+        } else {
+            throw new IllegalArgumentException("Unexpected value type");
+        }
+    }
+
+    public final static String PERSONAL_HOMEPAGE_VIEW_KEY = "PersonalHomepage:view:";
+
+    public void increasePersonalHomepageViewCount(Long accountId) {
+        String key = PERSONAL_HOMEPAGE_VIEW_KEY + accountId;
+        redisTemplate.opsForValue().increment(key);
+    }
+
+    public Long getPersonalHomepageViewCount(Long accountId) {
+        String key = PERSONAL_HOMEPAGE_VIEW_KEY + accountId;
+        return redisTemplate.opsForValue().increment(key, 0);
+    }
+
+    public final static String MOODBOARD_POSITION_KEY = "moodboard:position:";
+
+    public void saveMoodboardPosition(Long id, String moodboardPosition) {
+        addToString(MOODBOARD_POSITION_KEY + id, moodboardPosition);
+    }
+
+    public String getMoodboardPosition(Long id) {
+        return getFromString(MOODBOARD_POSITION_KEY + id);
+    }
+    public final static String NICKNAME_MODIFY_TIMES = "NicknameModifyTimes:";
+    public void increaseCount(String key) {
+        redisTemplate.opsForValue().increment(key);
+    }
+
+    public Long getIncrementCount(String key) {
+        return redisTemplate.opsForValue().increment(key, 0);
+    }
+
+    public void setKeyExpire(String key, Long expire) {
+        redisTemplate.expire(key, expire, TimeUnit.DAYS);
+    }
+
+    public final static String CHANGE_MAILBOX = "ChangeMailbox:";
+
+    // 每天允许通知3次
+    public final static String UPLOAD_TIMEOUT_REMINDER_COUNTER = "UploadTimeoutReminderCounter";
+
+    public void addProcessId(String processId, int progress) {
+        // Redis 中的键，可以通过 processId 来唯一标识
+        String redisKey = "process:progress:" + processId;
+
+        // 将当前进度存储到 Redis
+        redisTemplate.opsForValue().set(redisKey, String.valueOf(progress));
+
+        // 设置过期时间为 5 分钟（300 秒）
+        redisTemplate.expire(redisKey, 5, TimeUnit.MINUTES);
+    }
+
+    public final static String PAYMENT_INFO_LAST_SCAN_TIME = "PaymentInfoLastScanTime";
+
+    public final static String AFFILIATE_LINK_VIEW_KEY = "AffiliateLink:view:";
+
+    public void increaseAffiliateLinkViewCount(Long accountId) {
+        String key = AFFILIATE_LINK_VIEW_KEY + accountId;
+        redisTemplate.opsForValue().increment(key);
+    }
+
+    public Long getAffiliateLinkViewCount(Long accountId) {
+        String key = AFFILIATE_LINK_VIEW_KEY + accountId;
+        return redisTemplate.opsForValue().increment(key, 0);
+    }
+
+    public void batchDeleteKeysWithSamePrefix(String prefix){
+        Set<String> keys = redisTemplate.keys(prefix + "*");
+        assert keys != null;
+        if (!keys.isEmpty()){
+            redisTemplate.delete(keys);
+        }
+    }
+
+    public final static String STRIPE_EXCEPTION_LOG = "StripeException:";
+    public final static String SUBSCRIPTION_SENT_EMAIL_TYPE = "SubscriptionEmailSentType:";
 }

src/main/java/com/ai/da/common/utils/RequestInfoUtil.java

@@ -1,7 +1,16 @@
 package com.ai.da.common.utils;
 
-import javax.servlet.http.HttpServletRequest;
+import com.alibaba.fastjson.JSONObject;
+import lombok.extern.slf4j.Slf4j;
 
+import javax.servlet.http.HttpServletRequest;
+import java.io.BufferedReader;
+import java.io.InputStreamReader;
+import java.net.HttpURLConnection;
+import java.net.URL;
+import java.util.Map;
+
+@Slf4j
 public class RequestInfoUtil {
 
     /**
@@ -45,4 +54,58 @@ public class RequestInfoUtil {
         return ip;
     }
 
+    /**
+     * 免费 API 服务可能有请求频率限制，如果你需要处理大量 IP 地址，可能需要考虑使用付费服务或购买 IP 地理位置数据库。此外，始终要遵守 API 提供商的使用条款和隐私政策
+     * @param ip https://ip-api.com/docs/api:json 使用的接口api
+     * @return
+     * {
+     *   "query": "24.48.0.1",
+     *   "status": "success",
+     *   "country": "Canada",
+     *   "countryCode": "CA",
+     *   "region": "QC",
+     *   "regionName": "Quebec",
+     *   "city": "Montreal",
+     *   "zip": "H1L",
+     *   "lat": 45.6026,
+     *   "lon": -73.5167,
+     *   "timezone": "America/Toronto",
+     *   "isp": "Le Groupe Videotron Ltee",
+     *   "org": "Videotron Ltee",
+     *   "as": "AS5769 Videotron Ltee"
+     * }
+     */
+    public static Map getIPLocation(String ip) {
+//        String ip = "117.143.125.1"; // 替换为你想查询的 IP 地址
+//        String ip = "194.5.48.180"; // 替换为你想查询的 IP 地址
+        String apiURL = "http://ip-api.com/json/" + ip;
+
+        try {
+            URL url = new URL(apiURL);
+            HttpURLConnection conn = (HttpURLConnection) url.openConnection();
+            conn.setRequestMethod("GET");
+            conn.setRequestProperty("Accept", "application/json");
+
+            if (conn.getResponseCode() != 200) {
+                throw new RuntimeException("Failed : HTTP error code : " + conn.getResponseCode());
+            }
+
+            BufferedReader br = new BufferedReader(new InputStreamReader(conn.getInputStream()));
+            String output;
+            StringBuilder outputBuilder = new StringBuilder();
+//            System.out.println("Output from Server .... \n");
+            while ((output = br.readLine()) != null) {
+                outputBuilder.append(output);
+                System.out.println(output);
+            }
+            conn.disconnect();
+            Map map = JSONObject.parseObject(outputBuilder.toString(), Map.class);
+            log.info("map: {}", map);
+            return map;
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return null;
+    }
+
 }

src/main/java/com/ai/da/common/utils/S3Util.java

@@ -255,6 +255,22 @@ public class S3Util {
         }
     }
 
+    public String getPreSignedUrl(String path, int expiry, boolean resetCache) {
+        if (resetCache || LocalCacheUtils.getPresignedUrlCache(path) == null) {
+            if (!path.contains("/")) {
+                throw new BusinessException("The path is error!");
+            }
+            int index = path.indexOf("/");
+            String bucketName = path.substring(0, index);
+            String fileName = path.substring(index + 1);
+            String presignedUrl = getPreSignatureUrl(bucketName, fileName, expiry);
+            LocalCacheUtils.setPresignedUrlCache(path, presignedUrl);
+            return presignedUrl;
+        } else {
+            return LocalCacheUtils.getPresignedUrlCache(path);
+        }
+    }
+
     /**
      * @param keyName               key名称: test/2022/06/123.pdf
      * @param signatureDurationTime 有效期 单位：秒

src/main/java/com/ai/da/common/utils/SendEmailUtil.java

@@ -2,8 +2,11 @@ package com.ai.da.common.utils;
 
 import com.ai.da.mapper.primary.entity.Account;
 import com.ai.da.mapper.primary.entity.TrialOrder;
+import com.ai.da.model.dto.AffiliateEmailParamsDTO;
+import com.ai.da.model.dto.SubscriptionEmailParamsDTO;
 import com.alibaba.fastjson.JSONObject;
 import com.ai.da.common.config.exception.BusinessException;
+import com.alibaba.fastjson2.JSON;
 import com.tencentcloudapi.common.Credential;
 import com.tencentcloudapi.common.exception.TencentCloudSDKException;
 import com.tencentcloudapi.common.profile.ClientProfile;
@@ -53,6 +56,7 @@ public class SendEmailUtil {
      * 绑定邮箱
      */
     public static String BIND_MAILBOX_SUBJECT = "绑定邮箱";
+    public static String CHANGE_MAILBOX_SUBJECT = "Change Mailbox";
     /**
      * 登入模板id
      */
@@ -69,7 +73,10 @@ public class SendEmailUtil {
     /**
      * 绑定邮箱模板id
      */
-    public static Long BIND_MAILBOX_TEMPLATE_ID = 45619L;
+//    public static Long BIND_MAILBOX_TEMPLATE_ID = 45619L;
+    public static Long BIND_MAILBOX_TEMPLATE_ID = 132754L;
+
+    public static Long CHANGE_MAILBOX_TEMPLATE_ID = 128210L;
 
 
     public static Boolean send(String receiverAddress, String ip, Long templateId, String verifyCode) {
@@ -92,7 +99,8 @@ public class SendEmailUtil {
             req.setDestination(new String[]{receiverAddress});
             String subject = templateId == LOGIN_TEMPLATE_ID ? LOGIN_SUBJECT :
                     templateId == UPDATE_PWD_TEMPLATE_ID ? FORGET_PWD_SUBJECT :
-                            templateId == EXCEPTION_ID_TEMPLATE_ID ? EXCEPTION_ID_SUBJECT : BIND_MAILBOX_SUBJECT;
+                            templateId == EXCEPTION_ID_TEMPLATE_ID ? EXCEPTION_ID_SUBJECT :
+                                    templateId == CHANGE_MAILBOX_TEMPLATE_ID ? CHANGE_MAILBOX_SUBJECT : BIND_MAILBOX_SUBJECT;
             req.setSubject(subject);
             req.setTemplate(contractTemplate(templateId, verifyCode, ip));
 
@@ -264,7 +272,9 @@ public class SendEmailUtil {
             throw new BusinessException("failed.to.send.mail");
         }
     }
+
     private final static Long WILLBEEXPIRED_TEMPLATE_ID = 118178L;
+
     public static void sendWillBeExpiredEmail(Account account, String senderAddress) {
         try {
             // 实例化一个认证对象
@@ -366,6 +376,7 @@ public class SendEmailUtil {
     private final static Long UPGRADE_SUCCESS_NOTIFICATION_ID = 118856L;
     private final static Long UPGRADE_NOTIFICATION_ID_CHINESE = 122898L;
     private final static Long UPGRADE_SUCCESS_NOTIFICATION_ID_CHINESE = 122899L;
+
     public static void sendUpgradeNotification(Account account, String senderAddress, Integer type) {
         try {
             // 实例化一个认证对象
@@ -406,14 +417,17 @@ public class SendEmailUtil {
 
             // 发送邮件
             SendEmailResponse resp = client.SendEmail(req);
+            log.info(senderAddress);
             log.info("短信发送结果res###{}", SendEmailResponse.toJsonString(resp));
         } catch (TencentCloudSDKException e) {
+            log.info(senderAddress);
             log.info("邮件发送失败###{}", e.toString());
             throw new BusinessException("failed.to.send.mail");
         }
     }
 
     private final static Long GENERATE_EXCEPTION_WARNING_ID = 122589L;
+
     public static void sendGenerateExceptionWarning(String message) {
         try {
             // 实例化一个认证对象
@@ -453,6 +467,7 @@ public class SendEmailUtil {
 
     private final static Long QUESTIONNAIRE_FEEDBACK_EN_ID = 124151L;
     private final static Long QUESTIONNAIRE_FEEDBACK_CN_ID = 124156L;
+
     public static void questionnaireRelatedNotify(String userName, String email, String language) {
         try {
             // 实例化一个认证对象
@@ -590,4 +605,475 @@ public class SendEmailUtil {
             throw new BusinessException("failed.to.send.mail");
         }
     }
+
+    private final static Long NEW_USER_REGISTER_NOTIFICATION_EN = 126919L;
+
+    public static void notificationForRegisterUser(String receiverAddress) {
+        try {
+            // 实例化一个认证对象，入参需要传入腾讯云账户 SecretId 和 SecretKey，此处还需注意密钥对的保密
+            // 代码泄露可能会导致 SecretId 和 SecretKey 泄露，并威胁账号下所有资源的安全性。以下代码示例仅供参考，建议采用更安全的方式来使用密钥，请参见：https://cloud.tencent.com/document/product/1278/85305
+            // 密钥可前往官网控制台 https://console.cloud.tencent.com/cam/capi 进行获取
+            Credential cred = new Credential(SECRET_ID, SECRET_KEy);
+            // 实例化一个http选项，可选的，没有特殊需求可以跳过
+            HttpProfile httpProfile = new HttpProfile();
+            httpProfile.setEndpoint("ses.tencentcloudapi.com");
+            // 实例化一个client选项，可选的，没有特殊需求可以跳过
+            ClientProfile clientProfile = new ClientProfile();
+            clientProfile.setHttpProfile(httpProfile);
+            // 实例化要请求产品的client对象,clientProfile是可选的
+            SesClient client = new SesClient(cred, "ap-hongkong", clientProfile);
+            // 实例化一个请求对象,每个接口都会对应一个request对象
+            SendEmailRequest req = new SendEmailRequest();
+            req.setFromEmailAddress(SEND_ADDRESS);
+            req.setDestination(new String[]{receiverAddress});
+
+            req.setSubject("Welcome to AiDa");
+            Template template = new Template();
+            template.setTemplateID(NEW_USER_REGISTER_NOTIFICATION_EN);
+            template.setTemplateData("{\"email\":\" " + receiverAddress + "\"}");
+            req.setTemplate(template);
+
+            // 返回的resp是一个SendEmailResponse的实例，与请求对象对应
+            SendEmailResponse resp = client.SendEmail(req);
+            log.info("短信发送结果res###{}", SendEmailResponse.toJsonString(resp));
+        } catch (TencentCloudSDKException e) {
+            log.info("邮件发送至{} 发送失败###{}", receiverAddress, e.toString());
+            log.error(e.getMessage());
+            // 这里不再抛出异常 失败就不发，保证后续正常运行
+//            throw new BusinessException("failed.to.send.mail");
+        }
+    }
+
+    private final static Long CHANGE_MAILBOX_CONFIRM_CN = 128278L;
+    private final static Long CHANGE_MAILBOX_CONFIRM_EN = 128277L;
+
+    public static void changeMailboxConfirm(String receiverAddress, String language, String name, String link) {
+        try {
+            // 实例化一个认证对象，入参需要传入腾讯云账户 SecretId 和 SecretKey，此处还需注意密钥对的保密
+            // 代码泄露可能会导致 SecretId 和 SecretKey 泄露，并威胁账号下所有资源的安全性。以下代码示例仅供参考，建议采用更安全的方式来使用密钥，请参见：https://cloud.tencent.com/document/product/1278/85305
+            // 密钥可前往官网控制台 https://console.cloud.tencent.com/cam/capi 进行获取
+            Credential cred = new Credential(SECRET_ID, SECRET_KEy);
+            // 实例化一个http选项，可选的，没有特殊需求可以跳过
+            HttpProfile httpProfile = new HttpProfile();
+            httpProfile.setEndpoint("ses.tencentcloudapi.com");
+            // 实例化一个client选项，可选的，没有特殊需求可以跳过
+            ClientProfile clientProfile = new ClientProfile();
+            clientProfile.setHttpProfile(httpProfile);
+            // 实例化要请求产品的client对象,clientProfile是可选的
+            SesClient client = new SesClient(cred, "ap-hongkong", clientProfile);
+            // 实例化一个请求对象,每个接口都会对应一个request对象
+            SendEmailRequest req = new SendEmailRequest();
+            req.setFromEmailAddress(SEND_ADDRESS);
+            req.setDestination(new String[]{receiverAddress});
+            Template template = new Template();
+            if (language.equals("ENGLISH")) {
+                req.setSubject("Change the email address bound to the AiDA account");
+                template.setTemplateID(CHANGE_MAILBOX_CONFIRM_EN);
+            } else {
+                req.setSubject("更换AiDA账号绑定的邮箱地址");
+                template.setTemplateID(CHANGE_MAILBOX_CONFIRM_CN);
+            }
+            JSONObject param = new JSONObject();
+            param.put("userName", name);
+            param.put("link", link);
+
+            template.setTemplateData(param.toJSONString());
+            req.setTemplate(template);
+
+            // 返回的resp是一个SendEmailResponse的实例，与请求对象对应
+            SendEmailResponse resp = client.SendEmail(req);
+            log.info("短信发送结果res###{}", SendEmailResponse.toJsonString(resp));
+        } catch (TencentCloudSDKException e) {
+            log.info("邮件发送失败###{}", e.toString());
+            throw new BusinessException("failed.to.send.mail");
+        }
+    }
+
+    private final static Long UPLOAD_TIMEOUT_REMINDER = 128324L;
+
+    public static void uploadTimeoutReminder(String userName, String time) {
+        String xp = "xupei3360@163.com";
+        String wxd = "X1627315083@163.com";
+        String pkc = "kaicpang.pang@connect.polyu.hk";
+        try {
+            // 实例化一个认证对象，入参需要传入腾讯云账户 SecretId 和 SecretKey，此处还需注意密钥对的保密
+            // 代码泄露可能会导致 SecretId 和 SecretKey 泄露，并威胁账号下所有资源的安全性。以下代码示例仅供参考，建议采用更安全的方式来使用密钥，请参见：https://cloud.tencent.com/document/product/1278/85305
+            // 密钥可前往官网控制台 https://console.cloud.tencent.com/cam/capi 进行获取
+            Credential cred = new Credential(SECRET_ID, SECRET_KEy);
+            // 实例化一个http选项，可选的，没有特殊需求可以跳过
+            HttpProfile httpProfile = new HttpProfile();
+            httpProfile.setEndpoint("ses.tencentcloudapi.com");
+            // 实例化一个client选项，可选的，没有特殊需求可以跳过
+            ClientProfile clientProfile = new ClientProfile();
+            clientProfile.setHttpProfile(httpProfile);
+            // 实例化要请求产品的client对象,clientProfile是可选的
+            SesClient client = new SesClient(cred, "ap-hongkong", clientProfile);
+            // 实例化一个请求对象,每个接口都会对应一个request对象
+            SendEmailRequest req = new SendEmailRequest();
+            req.setFromEmailAddress(SEND_ADDRESS);
+            req.setDestination(new String[]{xp, wxd, pkc});
+            Template template = new Template();
+            req.setSubject("上传图片超时提醒");
+            template.setTemplateID(UPLOAD_TIMEOUT_REMINDER);
+            JSONObject param = new JSONObject();
+            param.put("userName", userName);
+            param.put("time", time);
+
+            template.setTemplateData(param.toJSONString());
+            req.setTemplate(template);
+
+            // 返回的resp是一个SendEmailResponse的实例，与请求对象对应
+            SendEmailResponse resp = client.SendEmail(req);
+            log.info("短信发送结果res###{}", SendEmailResponse.toJsonString(resp));
+        } catch (TencentCloudSDKException e) {
+            log.info("邮件发送失败###{}", e.toString());
+            throw new BusinessException("failed.to.send.mail");
+        }
+    }
+
+    private final static Long HALFPRICEPROMOTION_CN_ID = 128582L;
+    private final static Long HALFPRICEPROMOTION_EN_ID = 128583L;
+
+    public static void halfPricePromotion(Account account, String senderAddress, int type) {
+        try {
+            // 实例化一个认证对象
+            Credential cred = new Credential(SECRET_ID, SECRET_KEy);
+            HttpProfile httpProfile = new HttpProfile();
+            httpProfile.setEndpoint("ses.tencentcloudapi.com");
+            ClientProfile clientProfile = new ClientProfile();
+            clientProfile.setHttpProfile(httpProfile);
+            SesClient client = new SesClient(cred, "ap-hongkong", clientProfile);
+            SendEmailRequest req = new SendEmailRequest();
+            if (StringUtils.isEmpty(senderAddress)) {
+                senderAddress = CODE_CREATE_SEND_ADDRESS;
+            }
+            req.setFromEmailAddress(senderAddress);
+            req.setDestination(new String[]{account.getUserEmail()});
+
+            // 根据邮件类型设置不同的主题和模板
+            String subject = "";
+            Template template = new Template();
+//            if (type == 1) {
+//                subject = "Upcoming System Upgrade for AiDA 3.0";
+//                template.setTemplateID(UPGRADE_NOTIFICATION_ID);
+//            }else {
+//                subject = "即将到来的AiDA 3.0系统升级";
+//                template.setTemplateID(UPGRADE_NOTIFICATION_ID_CHINESE);
+//            }
+            if (type == 1) {
+                subject = "AiDA workshop - Win a trip to Hong Kong！";
+                template.setTemplateID(HALFPRICEPROMOTION_EN_ID);
+            } else {
+                subject = "AiDA workshop - 赢取香港之旅";
+                template.setTemplateID(HALFPRICEPROMOTION_CN_ID);
+            }
+            template.setTemplateData(buildAccountData(account));
+
+            req.setSubject(subject);
+            req.setTemplate(template);
+
+            // 发送邮件
+            SendEmailResponse resp = client.SendEmail(req);
+            log.info("短信发送结果res###{}", SendEmailResponse.toJsonString(resp));
+        } catch (TencentCloudSDKException e) {
+            log.info("邮件发送失败###{}", e.toString());
+            throw new BusinessException("failed.to.send.mail");
+        }
+    }
+    private final static Long SYSTEM_UPGRADE_CN_ID = 131743L;
+    private final static Long SYSTEM_UPGRADE_EN_ID = 131744L;
+    public static void temporaryUpgrade(Account account, String senderAddress, int type) {
+        try {
+            // 实例化一个认证对象
+            Credential cred = new Credential(SECRET_ID, SECRET_KEy);
+            HttpProfile httpProfile = new HttpProfile();
+            httpProfile.setEndpoint("ses.tencentcloudapi.com");
+            ClientProfile clientProfile = new ClientProfile();
+            clientProfile.setHttpProfile(httpProfile);
+            SesClient client = new SesClient(cred, "ap-hongkong", clientProfile);
+            SendEmailRequest req = new SendEmailRequest();
+            if (StringUtils.isEmpty(senderAddress)) {
+                senderAddress = CODE_CREATE_SEND_ADDRESS;
+            }
+            req.setFromEmailAddress(senderAddress);
+            req.setDestination(new String[]{account.getUserEmail()});
+
+            // 根据邮件类型设置不同的主题和模板
+            String subject = "";
+            Template template = new Template();
+            if (type == 1) {
+                subject = "AiDA system upgrade completed";
+                template.setTemplateID(SYSTEM_UPGRADE_EN_ID);
+            }else {
+                subject = "AiDA系统升级完成";
+                template.setTemplateID(SYSTEM_UPGRADE_CN_ID);
+            }
+            template.setTemplateData(buildAccountData(account));
+
+            req.setSubject(subject);
+            req.setTemplate(template);
+
+            // 发送邮件
+            SendEmailResponse resp = client.SendEmail(req);
+            log.info("短信发送结果res###{}", SendEmailResponse.toJsonString(resp));
+        } catch (TencentCloudSDKException e) {
+            log.info("邮件发送失败###{}", e.toString());
+            throw new BusinessException("failed.to.send.mail");
+        }
+    }
+
+    private final static Long CANCEL_MERCHANT_EN = 130720L;
+//    private final static Long NEW_MERCHANT_EN = 130721L;
+//    private final static Long NEW_USER_EN = 130722L;
+//    private final static Long NEW_USER_CN = 130723L;
+    private final static Long NEW_MERCHANT_EN = 140335L;
+//    private final static Long NEW_MERCHANT_EN = 135190L;
+//    private final static Long NEW_USER_EN = 135189L;
+//    private final static Long NEW_USER_CN = 135186L;
+    private final static Long NEW_USER_EN = 140316L;
+    private final static Long NEW_USER_CN = 140317L;
+    private final static Long RENEWAL_MERCHANT_EN = 130724L;
+    private final static Long RENEWAL_USER_EN = 130725L;
+    private final static Long RENEWAL_USER_CN = 130726L;
+    private final static Long RENEWAL_REMINDER_USER_EN = 130727L;
+    private final static Long RENEWAL_REMINDER_USER_CN = 130728L;
+    private final static Long PAYMENT_FAILED_NEW_MERCHANT_EN = 131230L;
+    private final static Long PAYMENT_FAILED_RENEWAL_MERCHANT_EN = 131225L;
+    private final static Long PAYMENT_FAILED_RENEWAL_USER_EN = 131563L;
+    private final static Long PAYMENT_FAILED_RENEWAL_USER_CN = 131564L;
+
+    public static boolean subscriptionEmailReminder(String type, SubscriptionEmailParamsDTO subscriptionEmailParamsDTO, String language, String receiverAddress) {
+        try {
+            String merchantEmail = "kimwong@code-create.com.hk";
+            String developer = "xupei3360@163.com";
+            String[] receiverEmail = {merchantEmail, developer};
+            Credential cred = new Credential(SECRET_ID, SECRET_KEy);
+            // 实例化一个http选项，可选的，没有特殊需求可以跳过
+            HttpProfile httpProfile = new HttpProfile();
+            httpProfile.setEndpoint("ses.tencentcloudapi.com");
+            // 实例化一个client选项，可选的，没有特殊需求可以跳过
+            ClientProfile clientProfile = new ClientProfile();
+            clientProfile.setHttpProfile(httpProfile);
+            // 实例化要请求产品的client对象,clientProfile是可选的
+            SesClient client = new SesClient(cred, "ap-hongkong", clientProfile);
+            // 实例化一个请求对象,每个接口都会对应一个request对象
+            SendEmailRequest user = new SendEmailRequest();
+            user.setFromEmailAddress(SEND_ADDRESS);
+            user.setDestination(new String[]{receiverAddress});
+            SendEmailRequest merchant = new SendEmailRequest();
+            merchant.setFromEmailAddress(SEND_ADDRESS);
+            merchant.setDestination(receiverEmail);
+            Template templateUser = new Template();
+            Template templateMerchant = new Template();
+            switch (type) {
+                case "cancel":
+                    merchant.setSubject("[Code-Create] Subscription Cancelled");
+                    templateMerchant.setTemplateID(CANCEL_MERCHANT_EN);
+                    break;
+                case "fail_new":
+                    merchant.setSubject("[Code-Create] Payment Failed : New Order (" + subscriptionEmailParamsDTO.getOrderId() + ")");
+                    templateMerchant.setTemplateID(PAYMENT_FAILED_NEW_MERCHANT_EN);
+                    break;
+                case "fail_renewal":
+                    merchant.setSubject("[Code-Create] Payment Failed : Renewal Order (" + subscriptionEmailParamsDTO.getOrderId() + ")");
+                    templateMerchant.setTemplateID(PAYMENT_FAILED_RENEWAL_MERCHANT_EN);
+                    // todo to user
+                    if (language.equals("ENGLISH")) {
+                        user.setSubject("[Code-Create] Payment Failed : Renewal Order (" + subscriptionEmailParamsDTO.getOrderId() + ")");
+                        templateUser.setTemplateID(PAYMENT_FAILED_RENEWAL_USER_EN);
+                    } else {
+                        user.setSubject("[Code-Create] 自动续费失败 (" + subscriptionEmailParamsDTO.getOrderId() + ")");
+                        templateUser.setTemplateID(PAYMENT_FAILED_RENEWAL_USER_CN);
+                    }
+                    break;
+                case "new":
+                    merchant.setSubject("[Code-Create] New Order(" + subscriptionEmailParamsDTO.getOrderId() + ")");
+                    templateMerchant.setTemplateID(NEW_MERCHANT_EN);
+                    if (language.equals("ENGLISH")) {
+                        user.setSubject("[Code-Create] You have successfully subscribed to AiDA");
+                        templateUser.setTemplateID(NEW_USER_EN);
+                    } else {
+                        user.setSubject("[Code-Create] 您已成功订阅AiDA");
+                        templateUser.setTemplateID(NEW_USER_CN);
+                    }
+                    break;
+                case "renewal":
+                    merchant.setSubject("[Code-Create] New subscription renewal order (" + subscriptionEmailParamsDTO.getOrderId() + ")");
+                    templateMerchant.setTemplateID(RENEWAL_MERCHANT_EN);
+                    if (language.equals("ENGLISH")) {
+                        user.setSubject("[Code-Create] AiDA Renewal Successful");
+                        templateUser.setTemplateID(RENEWAL_USER_EN);
+                    } else {
+                        user.setSubject("[Code-Create] AiDA续订成功");
+                        templateUser.setTemplateID(RENEWAL_USER_CN);
+                    }
+                    break;
+                case "reminder":
+                    if (language.equals("ENGLISH")) {
+                        user.setSubject("[Code-Create] AiDA Subscription Renewal Reminder");
+                        templateUser.setTemplateID(RENEWAL_REMINDER_USER_EN);
+                    } else {
+                        user.setSubject("[Code-Create] AiDA续订提醒");
+                        templateUser.setTemplateID(RENEWAL_REMINDER_USER_CN);
+                    }
+                    break;
+                default:
+                    log.error("unknown subscription email type");
+                    return false;
+//                    throw new BusinessException("unknown subscription email type");
+            }
+
+            templateUser.setTemplateData(JSON.toJSONString(subscriptionEmailParamsDTO));
+            user.setTemplate(templateUser);
+
+            templateMerchant.setTemplateData(JSON.toJSONString(subscriptionEmailParamsDTO));
+            merchant.setTemplate(templateMerchant);
+
+            if (!type.equals("cancel") && !type.equals("fail_new")) {
+                // 返回的resp是一个SendEmailResponse的实例，与请求对象对应
+                SendEmailResponse respUser = client.SendEmail(user);
+                log.info("邮件主题：{}，发送结果toUser###{}", user.getSubject(), SendEmailResponse.toJsonString(respUser));
+            }
+            if (!type.equals("reminder")) {
+                SendEmailResponse respMerchant = client.SendEmail(merchant);
+                log.info("邮件主题：{}，发送结果toMerchant###{}", merchant.getSubject(), SendEmailResponse.toJsonString(respMerchant));
+            }
+            return true;
+        } catch (TencentCloudSDKException e) {
+            log.info("邮件发送失败###{}", e.toString());
+            return false;
+//            throw new BusinessException("failed.to.send.mail");
+        }
+    }
+
+    private final static Long NEW_REGISTRATION = 132123L;
+    private final static Long AFFILIATE_ACCEPTED = 132124L;
+    private final static Long AFFILIATE_REFUSED = 132125L;
+    private final static Long AFFILIATE_MONTHLY_SUMMARY = 132126L;
+
+    public static void affiliateEmailReminder(String[] receiverAddress, AffiliateEmailParamsDTO paramsDTO, String type) {
+        try {
+            Credential cred = new Credential(SECRET_ID, SECRET_KEy);
+            // 实例化一个http选项，可选的，没有特殊需求可以跳过
+            HttpProfile httpProfile = new HttpProfile();
+            httpProfile.setEndpoint("ses.tencentcloudapi.com");
+            // 实例化一个client选项，可选的，没有特殊需求可以跳过
+            ClientProfile clientProfile = new ClientProfile();
+            clientProfile.setHttpProfile(httpProfile);
+            // 实例化要请求产品的client对象,clientProfile是可选的
+            SesClient client = new SesClient(cred, "ap-hongkong", clientProfile);
+            // 实例化一个请求对象,每个接口都会对应一个request对象
+            SendEmailRequest req = new SendEmailRequest();
+            req.setFromEmailAddress(SEND_ADDRESS);
+            req.setDestination(receiverAddress);
+            Template template = new Template();
+            switch (type) {
+                case "new":
+                    req.setSubject("New Affiliate Registration");
+                    template.setTemplateID(NEW_REGISTRATION);
+                    break;
+                case "accepted":
+                    req.setSubject("Affiliate Application Accepted");
+                    template.setTemplateID(AFFILIATE_ACCEPTED);
+                    break;
+                case "refused":
+                    req.setSubject("Affiliate Application Refused");
+                    template.setTemplateID(AFFILIATE_REFUSED);
+                    break;
+                case "summary":
+                    req.setSubject("Your Monthly AffiliateWP Summary for AiDA");
+                    template.setTemplateID(AFFILIATE_MONTHLY_SUMMARY);
+                    break;
+            }
+
+            template.setTemplateData(JSON.toJSONString(paramsDTO));
+            req.setTemplate(template);
+
+            // 返回的resp是一个SendEmailResponse的实例，与请求对象对应
+            SendEmailResponse resp = client.SendEmail(req);
+            log.info("短信发送结果res###{}", SendEmailResponse.toJsonString(resp));
+        } catch (TencentCloudSDKException e) {
+            log.info("邮件发送失败###{}", e.toString());
+            throw new BusinessException("failed.to.send.mail");
+        }
+    }
+
+    private final static Long CREDITS_PURCHASE_MERCHANT = 133275L;
+
+    public static void creditsPurchaseReminder(String username, String quantity, String amount) {
+        try {
+            Credential cred = new Credential(SECRET_ID, SECRET_KEy);
+            // 实例化一个http选项，可选的，没有特殊需求可以跳过
+            HttpProfile httpProfile = new HttpProfile();
+            httpProfile.setEndpoint("ses.tencentcloudapi.com");
+            // 实例化一个client选项，可选的，没有特殊需求可以跳过
+            ClientProfile clientProfile = new ClientProfile();
+            clientProfile.setHttpProfile(httpProfile);
+            // 实例化要请求产品的client对象,clientProfile是可选的
+            SesClient client = new SesClient(cred, "ap-hongkong", clientProfile);
+            // 实例化一个请求对象,每个接口都会对应一个request对象
+            SendEmailRequest req = new SendEmailRequest();
+            req.setFromEmailAddress(SEND_ADDRESS);
+            String merchantEmail = "kimwong@code-create.com.hk";
+            String developerEmail = "xupei@code-create.com.hk";
+            req.setDestination(new String[]{merchantEmail, developerEmail});
+            Template template = new Template();
+            req.setSubject("New Credit Purchase Order");
+            template.setTemplateID(CREDITS_PURCHASE_MERCHANT);
+            JSONObject jsonObject = new JSONObject();
+            // 设置试用订单相关数据
+            jsonObject.put("username", username);
+            jsonObject.put("quantity", quantity);
+            jsonObject.put("totalFee", amount);
+
+            template.setTemplateData(JSON.toJSONString(jsonObject));
+            req.setTemplate(template);
+
+            // 返回的resp是一个SendEmailResponse的实例，与请求对象对应
+            SendEmailResponse resp = client.SendEmail(req);
+            log.info("短信发送结果res###{}", SendEmailResponse.toJsonString(resp));
+        } catch (TencentCloudSDKException e) {
+            log.info("邮件发送失败###{}", e.toString());
+            throw new BusinessException("failed.to.send.mail");
+        }
+    }
+
+    private final static Long COMMON_EXCEPTION_REMINDER = 135279L;
+    public static void commonExceptionReminder(String functionName, String[] destination) {
+        try {
+            // 实例化一个认证对象，入参需要传入腾讯云账户 SecretId 和 SecretKey，此处还需注意密钥对的保密
+            // 代码泄露可能会导致 SecretId 和 SecretKey 泄露，并威胁账号下所有资源的安全性。以下代码示例仅供参考，建议采用更安全的方式来使用密钥，请参见：https://cloud.tencent.com/document/product/1278/85305
+            // 密钥可前往官网控制台 https://console.cloud.tencent.com/cam/capi 进行获取
+            Credential cred = new Credential(SECRET_ID, SECRET_KEy);
+            // 实例化一个http选项，可选的，没有特殊需求可以跳过
+            HttpProfile httpProfile = new HttpProfile();
+            httpProfile.setEndpoint("ses.tencentcloudapi.com");
+            // 实例化一个client选项，可选的，没有特殊需求可以跳过
+            ClientProfile clientProfile = new ClientProfile();
+            clientProfile.setHttpProfile(httpProfile);
+            // 实例化要请求产品的client对象,clientProfile是可选的
+            SesClient client = new SesClient(cred, "ap-hongkong", clientProfile);
+            // 实例化一个请求对象,每个接口都会对应一个request对象
+            SendEmailRequest req = new SendEmailRequest();
+            req.setFromEmailAddress(SEND_ADDRESS);
+            req.setDestination(destination);
+            Template template = new Template();
+            req.setSubject("AiDA发生异常，请及时处理");
+            template.setTemplateID(COMMON_EXCEPTION_REMINDER);
+            JSONObject param = new JSONObject();
+            param.put("function", functionName);
+
+            // 邮件内容 {{function}}处理异常，请及时查看
+            template.setTemplateData(param.toJSONString());
+            req.setTemplate(template);
+
+            // 返回的resp是一个SendEmailResponse的实例，与请求对象对应
+            SendEmailResponse resp = client.SendEmail(req);
+            log.info("邮件发送结果res###{}", SendEmailResponse.toJsonString(resp));
+        } catch (TencentCloudSDKException e) {
+            log.info("邮件发送失败###{}", e.toString());
+            throw new BusinessException("failed.to.send.mail");
+        }
+    }
+
 }

src/main/java/com/ai/da/common/websocket/NotificationConnection.java

@@ -0,0 +1,115 @@
+package com.ai.da.common.websocket;
+
+import com.alibaba.fastjson.JSONObject;
+import com.alibaba.fastjson2.JSON;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+import org.springframework.web.bind.annotation.RequestParam;
+
+import javax.websocket.*;
+import javax.websocket.server.PathParam;
+import javax.websocket.server.ServerEndpoint;
+import java.io.IOException;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+
+@ServerEndpoint(value = "/notification/{id}")
+@Component
+@Slf4j
+public class NotificationConnection {
+
+    //连接超时
+    public static final long MAX_TIME_OUT = 3 * 60 * 1000;
+
+    private Session session;
+    private Long userId;
+    // 这里用ConcurrentHashMap 因为他是一个线程安全的Map
+    private static ConcurrentHashMap<Long, NotificationConnection> websockets = new ConcurrentHashMap<>();
+
+    @OnOpen
+    public void onOpen(Session session, @PathParam("id") String id) {  // 接收到前端传来的用户ID
+        this.session = session;
+        this.userId = Long.valueOf(id);
+        this.session.setMaxIdleTimeout(MAX_TIME_OUT);
+        websockets.put(Long.parseLong(id), this);  //将ID作为key，当前的对象作为Value
+        log.info("【建立连接】 用户为：{}", this.session);
+        log.info("【建立连接】 用户Id为：{}", id);
+        log.info("【当前连接总数】 为：{}", websockets.size());
+    }
+
+    @OnClose
+    public void onClose(CloseReason reason) {
+        log.info("【连接断开】 用户为：{}, sessionId: {}, 原因为{}", this.userId, this.session.getId(), reason);
+        log.info("【当前连接总数】 为：{}", websockets.size());
+        websockets.remove(this.userId); // 将当前的对象从集合中删除
+    }
+
+    /**
+     * 错误时调用
+     * @param throwable 异常
+     */
+    @OnError
+    public void onError(Throwable throwable) {
+        log.info("【连接异常】 用户为：{} ,  sessionId: {}", this.userId, this.session.getId(), throwable);
+        websockets.remove(this.userId); // 将当前的对象从集合中删除
+        log.info("【当前连接总数】 为：{}", websockets.size());
+    }
+
+    //收到了客户端消息执行的操作
+    @OnMessage
+    public void onMessage(@RequestParam String text){
+        Map<String, String> textMap = JSONObject.parseObject(text, Map.class);
+        log.info("收到了一条来自 {} 的消息：{}， sessionId：{}", this.userId, textMap.get("text"), this.session.getId());
+//        return "已收到你的消息";
+        if (textMap.get("text").equals("PING")){
+            sendMsg(JSON.toJSONString("PONG"), this.userId);
+        }
+    }
+
+    public void sendMsg(String message, Long userId)  {
+        if (userId == null) {  // 如果等于null则证明是群发
+            // 获取当前Map的一个迭代器，遍历Map的方式有很多种，看着来
+            // 这个就是遍历这个集合的过程....
+            for (Map.Entry<Long, NotificationConnection> entry : websockets.entrySet()) {
+                // 获取每一个Entry实例
+                // 获取每一个Value，而这个Value就是WebSocket的实例
+                NotificationConnection webSocket = entry.getValue();
+                // 接下来就是遍历群发
+                log.info("广播消息 【给用户】 ：{}发送消息【{}】", webSocket, message);
+                try {
+                    webSocket.session.getBasicRemote().sendText(message); // 发送！！！！！！！！！
+                } catch (IOException e) {
+                    log.error("Failed to send message to session {}: {}", webSocket.session.getId(), e.getMessage());
+                }
+            }
+        } else {  // 如果不是群发，则判断ID，其余步骤一致
+            // 获取当前Map的一个迭代器，遍历Map的方式有很多种，看着来
+            // 这个就是遍历这个集合的过程....
+            for (Map.Entry<Long, NotificationConnection> entry : websockets.entrySet()) {
+                // 获取每一个Entry实例
+                // 获取每一个Value，而这个Value就是WebSocket的实例
+                NotificationConnection webSocket = entry.getValue();
+                // 获取每一个Key，这个Key就是用户ID
+                Long key = entry.getKey();
+                // 判断用户ID与当前的Key相等
+                if (userId.equals(key)) {
+                    log.info("私发消息 【给用户】 ：{}发送消息【{}】", key, message); // 打印
+                    if (webSocket.session.isOpen()){
+                        // 避免因为网络问题或其他原因导致连接突然关闭而报错
+                        try {
+                            webSocket.session.getBasicRemote().sendText(message);  // 则发送给当前的用户即可
+                        } catch (IOException e) {
+                            log.error("Failed to send message to session {}: {}", webSocket.session.getId(), e.getMessage());
+                            // 这里可以选择移除关闭的 session
+                            websockets.remove(entry.getKey());
+                        }
+                    }else {
+                        log.info("连接已关闭，sessionId:{}, userId:{}", webSocket.session.getId(), key);
+                        websockets.remove(entry.getKey());
+                    }
+                }
+            }
+        }
+    }
+}

src/main/java/com/ai/da/common/websocket/config/WebSocketConfig.java

@@ -0,0 +1,16 @@
+package com.ai.da.common.websocket.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.web.socket.server.standard.ServerEndpointExporter;
+
+/**
+ * Configuration of WebSocket
+ */
+@Configuration
+public class WebSocketConfig {
+    @Bean
+    public ServerEndpointExporter serverEndpointExporter() {
+        return new ServerEndpointExporter();
+    }
+}

src/main/java/com/ai/da/controller/AccountController.java

@@ -1,17 +1,24 @@
 package com.ai.da.controller;
 
+import com.ai.da.common.config.exception.BusinessException;
 import com.ai.da.common.response.PageBaseResponse;
 import com.ai.da.common.response.Response;
+import com.ai.da.mapper.primary.entity.Account;
+import com.ai.da.mapper.primary.entity.AccountExtend;
 import com.ai.da.mapper.primary.entity.TrialOrder;
 import com.ai.da.model.dto.*;
 import com.ai.da.model.vo.AccountLoginVO;
 import com.ai.da.model.vo.AccountPreLoginVO;
+import com.ai.da.model.vo.BindEmailVO;
+import com.ai.da.model.vo.PersonalHomepageVO;
 import com.ai.da.service.AccountService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.http.HttpStatus;
+import org.springframework.util.StringUtils;
 import org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
 
 import javax.annotation.Resource;
 import javax.servlet.http.HttpServletRequest;
@@ -44,8 +51,8 @@ public class AccountController {
 
     @ApiOperation(value = "绑定邮箱")
     @PostMapping("/bindEmail")
-    public Response<Boolean> bindEmail(@Valid @RequestBody AccountBindEmailDTO accountBindEmailDTO) {
-        return Response.success(accountService.bindEmail(accountBindEmailDTO));
+    public Response<BindEmailVO> bindEmail(@Valid @RequestBody AccountBindEmailDTO accountBindEmailDTO, HttpServletRequest request) {
+        return Response.success(accountService.bindEmail(accountBindEmailDTO, request));
     }
 
     @ApiOperation(value = "忘记密码")
@@ -177,4 +184,168 @@ public class AccountController {
     public Response<Boolean> questionnaire(@Valid @RequestBody String questionnaireInfo){
         return Response.success(accountService.collectQuestionnaires(questionnaireInfo));
     }
+
+    /**
+     * 参与活动 获取福利
+     * @return
+     */
+    @ApiOperation(value = "参与活动 获取福利")
+    @GetMapping("/activity")
+    public Response<String> getActivityBenefits(){
+        return Response.success(accountService.getActivityBenefits());
+    }
+
+    @ApiOperation(value = "将用户账号过期时间设置为过期当天的23：59：59")
+    @GetMapping("/setUserValidToDayEnd")
+    public Response<List<Long>> setUserValidToDayEnd(){
+        return Response.success(accountService.setUserValidToDayEnd());
+    }
+
+    // 用户上传头像
+    @ApiOperation(value = "上传头像")
+    @PostMapping(path = "/uploadAvatar")
+    public Response<String> uploadAvatar(@RequestParam("file") MultipartFile file) {
+        if (null == file || StringUtils.isEmpty(file.getOriginalFilename())) {
+            throw new BusinessException("file.cannot.be.empty");
+        }
+        return Response.success(accountService.uploadAvatar(file));
+    }
+
+    @ApiOperation(value = "个人主页浏览量增加")
+    @GetMapping("/viewsIncrease")
+    public Response<Boolean> viewsGet(@RequestParam("id") Long id) {
+        return Response.success(accountService.viewsIncrease(id));
+    }
+
+    @ApiOperation(value = "获取个人主页信息")
+    @GetMapping("/personalHomepage")
+    public Response<PersonalHomepageVO> getPersonalHomepage(@RequestParam("id") Long id){
+        return Response.success(accountService.getPersonalHomepage(id));
+    }
+
+    @ApiOperation(value = "getUsernameModifyTimes")
+    @GetMapping("/getNicknameModifyTimes")
+    public Response<Long> getNicknameModifyTimes(){
+        return Response.success(accountService.getNicknameModifyTimes());
+    }
+
+    @ApiOperation(value = "editUserName")
+    @GetMapping("/editUserName")
+    public Response<String> editUserName(@RequestParam("newUserName") String newUserName){
+        accountService.editUserName(newUserName);
+        return Response.success("success");
+    }
+
+    /*@ApiOperation(value = "verifyUserEmail")
+    @GetMapping("/verifyUserEmail")
+    public Response<String> verifyUserEmail(@RequestParam("verifyCode") String verifyCode){
+        accountService.verifyUserEmail(verifyCode);
+        return Response.success("success");
+    }
+
+    @ApiOperation(value = "changeUserEmail")
+    @GetMapping("/changeUserEmail")
+    public Response<String> changeUserEmail(@RequestParam("newMailbox") String newMailbox){
+        accountService.changeUserEmail(newMailbox);
+        return Response.success("success");
+    }
+
+    @ApiOperation(value = "activateNewEmail")
+    @GetMapping("/activateNewEmail")
+    public Response<String> activateNewEmail(@RequestParam("token") String token){
+        accountService.activateNewEmail(token);
+        return Response.success("success");
+    }*/
+
+    @PostMapping("halfPricePromotion")
+    @ApiOperation(value = "十月半价活动")
+    public Response<Boolean> halfPricePromotion() {
+        accountService.halfPricePromotion();
+        return Response.success(true);
+    }
+
+    @PostMapping("temporaryUpgrade")
+    @ApiOperation(value = "临时升级")
+    public Response<Boolean> temporaryUpgrade() {
+        accountService.temporaryUpgrade();
+        return Response.success(true);
+    }
+
+    @PostMapping("enterpriseLogin")
+    @ApiOperation(value = "企业登录")
+    public Response<AccountLoginVO> enterpriseLogin(@Valid @RequestBody AccountLoginDTO accountDTO) {
+        return Response.success(accountService.enterpriseLogin(accountDTO));
+    }
+
+    @PostMapping("schoolLogin")
+    @ApiOperation(value = "学校登录")
+    public Response<AccountLoginVO> schoolLogin(@Valid @RequestBody AccountLoginDTO accountDTO) {
+        return Response.success(accountService.schoolLogin(accountDTO));
+    }
+
+    @PostMapping("addOrUpdateSubAccount")
+    @ApiOperation(value = "子账号新增")
+    public Response<Boolean> addSubAccount(@Valid @RequestBody AddSubAccountDTO addSubAccountDTO) {
+        return Response.success(accountService.addSubAccount(addSubAccountDTO));
+    }
+
+    @PostMapping("deleteSubAccount")
+    @ApiOperation(value = "子账号删除")
+    public Response<Boolean> deleteSubAccount(@Valid @RequestBody AddSubAccountDTO addSubAccountDTO) {
+        return Response.success(accountService.deleteSubAccount(addSubAccountDTO));
+    }
+
+    @PostMapping("subAccountList")
+    @ApiOperation(value = "子账号查询")
+    public Response<PageBaseResponse<Account>> subAccountList(@Valid @RequestBody SubAccountPageDTO subAccountPageDTO) {
+        return Response.success(accountService.subAccountList(subAccountPageDTO));
+    }
+
+    @GetMapping("accountDetail")
+    @ApiOperation(value = "账号详情")
+    public Response<Account> accountDetail(@RequestParam("id") Long id) {
+        return Response.success(accountService.accountDetail(id));
+    }
+
+    @PostMapping("getAccountDetail")
+    @ApiOperation(value = "获取账户信息")
+    public Response<AccountLoginVO> getAccountDetail() {
+        return Response.success(accountService.getAccountDetail());
+    }
+
+    @GetMapping("/bindGoogle")
+    @ApiOperation(value = "绑定谷歌")
+    public Response<AccountExtend> bindGoogle(@RequestParam("credential") String credential) {
+        return Response.success(accountService.bindGoogle(credential));
+    }
+
+    @GetMapping("/bindWeChat")
+    @ApiOperation(value = "绑定微信")
+    public Response<AccountExtend> bindWeChat(@RequestParam("code") String code) {
+        return Response.success(accountService.bindWeChat(code));
+    }
+
+    @GetMapping("/bindEmail")
+    @ApiOperation(value = "绑定邮箱")
+    public Response<BindEmailVO> bindEmail(@RequestParam("email") String email) {
+        return Response.success(accountService.bindEmail(email));
+    }
+
+    @GetMapping("/unbindWeChat")
+    @ApiOperation(value = "解除绑定微信")
+    public Response<Boolean> unbindWeChat() {
+        return Response.success(accountService.unbindWeChat());
+    }
+
+    @GetMapping("/unbindGoogle")
+    @ApiOperation(value = "解除绑定谷歌")
+    public Response<Boolean> unbindGoogle() {
+        return Response.success(accountService.unbindGoogle());
+    }
+
+    @PostMapping("/updateUserInfo")
+    @ApiOperation(value = "更新用户国家、职业信息")
+    public Response<Boolean> updateUserInfo(@Valid @RequestBody UpdateUserInfoDTO updateUserInfoDTO) {
+        return Response.success(accountService.updateUserInfo(updateUserInfoDTO));
+    }
 }

src/main/java/com/ai/da/controller/AffiliateController.java

@@ -0,0 +1,94 @@
+package com.ai.da.controller;
+
+
+import com.ai.da.common.response.PageBaseResponse;
+import com.ai.da.common.response.Response;
+import com.ai.da.model.dto.AffiliateQueryDTO;
+import com.ai.da.model.vo.AffiliateInvitationDetailsVO;
+import com.ai.da.model.vo.AffiliateVO;
+import com.ai.da.service.AffiliateService;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.web.bind.annotation.*;
+
+import javax.annotation.Resource;
+import javax.validation.Valid;
+
+@Slf4j
+@RestController
+@RequestMapping("/api/affiliate")
+@Api(tags = "Affiliate模块")
+public class AffiliateController {
+
+    @Resource
+    private AffiliateService affiliateService;
+
+    @ApiOperation(value = "注册成为affiliate")
+    @GetMapping("/registration")
+    public Response<Boolean> completeGuidance(@RequestParam(value = "promotionMethod", required = false) String promotionMethod) {
+        return Response.success(affiliateService.registerAsAnAffiliate(promotionMethod));
+    }
+
+    @ApiOperation(value = "获取affiliate列表")
+    @PostMapping("/list")
+    public Response<PageBaseResponse<AffiliateVO>> getAffiliateList(@Valid @RequestBody AffiliateQueryDTO affiliateQueryDTO) {
+        return Response.success(affiliateService.getAffiliateList(affiliateQueryDTO));
+    }
+
+    @ApiOperation(value = "获取affiliate个人中心")
+    @GetMapping("/personalCenter")
+    public Response<AffiliateVO> personalAffiliateCenter() {
+        return Response.success(affiliateService.personalAffiliateCenter());
+    }
+
+    @ApiOperation(value = "获取个人佣金图表数据")
+    @GetMapping("/getPersonalMonthlyIncome")
+    public Response<double[]> getPersonalMonthlyIncome(@RequestParam("year")int year) {
+        return Response.success(affiliateService.getPersonalMonthlyIncome(year));
+    }
+
+    @ApiOperation(value = "审批affiliate申请")
+    @GetMapping("/approval")
+    public Response<Boolean> applicationApproval(@RequestParam("id") Long id,
+                                                 @RequestParam("isApproved")Boolean isApproved,
+                                                 @RequestParam("commission") Float commission) {
+        return Response.success(affiliateService.applicationApproval(id, isApproved, commission));
+    }
+
+    @ApiOperation(value = "更新佣金比例")
+    @GetMapping("/updateCommission")
+    public Response<String> updateCommissionPercentage(@RequestParam("id") Long id, @RequestParam("commission") Float commission) {
+        affiliateService.updateCommissionPercentage(id, commission);
+        return Response.success("success");
+    }
+
+    /*@ApiOperation(value = "定时计算佣金")
+    @GetMapping("/testTask")
+    public Response<String> testTask() {
+        affiliateService.updateAffiliateInfoWithPayment();
+        return Response.success("success ");
+    }*/
+
+    /*@ApiOperation(value = "每月发送结算邮件")
+    @GetMapping("/commissionCalculation")
+    public Response<String> commissionCalculation(@RequestParam("year") Integer year, @RequestParam("month") Integer month) {
+        affiliateService.commissionCalculation(year, month);
+        return Response.success("success ");
+    }*/
+
+    @ApiOperation(value = "affiliate链接浏览量增加")
+    @GetMapping("/viewsIncrease")
+    public Response<Boolean> viewsGet(@RequestParam("id") Long id) {
+        return Response.success(affiliateService.affiliateLinkViewsIncrease(id));
+    }
+
+    @ApiOperation(value = "获取每个affiliate产生的收入")
+    @PostMapping("/getEachAffiliateGeneratedRevenue")
+    public Response<IPage<AffiliateInvitationDetailsVO>> getEachAffiliateGeneratedRevenue(@RequestBody AffiliateQueryDTO affiliateQueryDTO) {
+        return Response.success(affiliateService.getEachAffiliateGeneratedRevenue(affiliateQueryDTO));
+    }
+
+
+}

src/main/java/com/ai/da/controller/AliPayController.java

@@ -1,6 +1,7 @@
 package com.ai.da.controller;
 
 import com.ai.da.common.response.Response;
+import com.ai.da.model.dto.ProductPurchaseDTO;
 import com.ai.da.service.AliPayService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
@@ -8,6 +9,8 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.web.bind.annotation.*;
 
 import javax.annotation.Resource;
+import javax.servlet.http.HttpServletRequest;
+import javax.validation.Valid;
 import java.util.Map;
 
 @CrossOrigin
@@ -21,12 +24,12 @@ public class AliPayController {
     private AliPayService aliPayService;
 
     @ApiOperation("统一收单下单并支付页面接口的调用")
-    @PostMapping("/trade/page/pay/{amount}")
-    public Response<String> tradePagePay(@PathVariable Integer amount, @RequestParam String returnUrl){
+    @PostMapping("/trade/page/pay")
+    public Response<String> tradePagePay(@Valid @RequestBody ProductPurchaseDTO productPurchaseDTO, HttpServletRequest request){
         log.info("统一收单下单并支付页面接口的调用");
         //支付宝开放平台接受 request 请求对象后
         // 会为开发者生成一个html 形式的 form表单，包含自动提交的脚本
-        String formStr = aliPayService.tradeCreate(amount, returnUrl);
+        String formStr = aliPayService.tradeCreate(productPurchaseDTO, request);
         //我们将form表单字符串返回给前端程序，之后前端将会调用自动提交脚本，进行表单的提交
         //此时，表单会自动提交到action属性所指向的支付宝开放平台中，从而为用户展示一个支付页面
         return Response.success(formStr);

src/main/java/com/ai/da/controller/AlipayHKController.java

@@ -1,6 +1,7 @@
 package com.ai.da.controller;
 
 import com.ai.da.common.response.Response;
+import com.ai.da.model.dto.ProductPurchaseDTO;
 import com.ai.da.service.AlipayHKService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
@@ -8,6 +9,8 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.web.bind.annotation.*;
 
 import javax.annotation.Resource;
+import javax.servlet.http.HttpServletRequest;
+import javax.validation.Valid;
 
 @CrossOrigin
 @RestController
@@ -20,9 +23,9 @@ public class AlipayHKController {
     private AlipayHKService alipayHKService;
 
     @ApiOperation(value = "创建订单")
-    @PostMapping(value = "/createOrder/{wallet}/{amount}")
-    public Response<String> createOrder(@PathVariable Integer amount, @PathVariable String wallet) {
-        String order = alipayHKService.createOrder(amount, wallet);
+    @PostMapping(value = "/createOrder")
+    public Response<String> createOrder(@Valid @RequestBody ProductPurchaseDTO productPurchaseDTO, HttpServletRequest request) {
+        String order = alipayHKService.createOrder(productPurchaseDTO, request);
         return Response.success(order);
     }
 

src/main/java/com/ai/da/controller/ConvenientInquiryController.java

@@ -2,41 +2,60 @@ package com.ai.da.controller;
 
 
 import com.ai.da.common.context.UserContext;
+import com.ai.da.common.response.PageBaseResponse;
 import com.ai.da.common.response.Response;
 import com.ai.da.mapper.primary.DesignMapper;
-import com.ai.da.mapper.primary.TrialOrderMapper;
+import com.ai.da.mapper.primary.entity.Account;
 import com.ai.da.mapper.primary.entity.TrialOrder;
+import com.ai.da.model.dto.AccountAddDTO;
+import com.ai.da.model.dto.QueryPaymentInfoDTO;
 import com.ai.da.model.dto.UserDesignStatisticDTO;
+import com.ai.da.model.vo.PaymentInfoVO;
+import com.ai.da.model.vo.QuestionnaireFeedbackVO;
+import com.ai.da.model.vo.QuestionnaireVO;
+import com.ai.da.model.vo.QueryUserConditionsVO;
+import com.ai.da.service.AccountService;
+import com.ai.da.service.ConvenientInquiryService;
+import com.baomidou.mybatisplus.core.metadata.IPage;
 import io.netty.util.internal.StringUtil;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
+import io.swagger.annotations.ApiParam;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.web.bind.annotation.*;
 
+import javax.annotation.Nullable;
 import javax.annotation.Resource;
+import javax.servlet.http.HttpServletResponse;
+import javax.validation.Valid;
 import java.text.SimpleDateFormat;
-import java.util.Date;
-import java.util.List;
+import java.util.*;
 
 @Api(tags = "便利查询")
 @Slf4j
 @RestController
 @RequestMapping("/api/inquiry")
 public class ConvenientInquiryController {
-
-    @Resource
-    private TrialOrderMapper trialOrderMapper;
-
     @Resource
     private DesignMapper designMapper;
+    @Resource
+    private ConvenientInquiryService convenientInquiryService;
+    @Resource
+    private AccountService accountService;
+
 
     @ApiOperation("获取当前所有试用用户")
-    @GetMapping("/getTrial")
-    public Response<List<TrialOrder>> getTrial(){
+    @PostMapping("/getTrial")
+    public Response<IPage<TrialOrder>> getTrial(@Valid @RequestBody QueryUserConditionsVO queryUserConditionsVO) {
         Long accountId = UserContext.getUserHolder().getId();
-        if (accountId.equals(31L) || accountId.equals(87L) || accountId.equals(83L) || accountId.equals(6L) || accountId.equals(4L) || accountId.equals(73L)){
-            List<TrialOrder> trialOrders = trialOrderMapper.selectList(null);
-            return Response.success(trialOrders);
+        String userEmail = accountService.getById(accountId).getUserEmail();
+        if (accountId.equals(31L) || accountId.equals(87L) || accountId.equals(83L)
+                || accountId.equals(6L) || accountId.equals(4L) || accountId.equals(73L)
+                || userEmail.equals("joho8228@hotmail.com")
+                || userEmail.equals("chelseayu@code-create.com.hk")
+                || userEmail.equals("cheungzt007@gmail.com")
+        ) {
+            return Response.success(convenientInquiryService.getTrial(queryUserConditionsVO));
         } else {
             return Response.fail("Sorry, you don't have permission");
         }
@@ -44,20 +63,162 @@ public class ConvenientInquiryController {
 
     @ApiOperation("获取指定时间区间内所有用户design的使用情况")
     @GetMapping("/getDesignStatistic")
-    public Response<List<UserDesignStatisticDTO>> getDesignStatistic(@RequestParam String startTime,@RequestParam String endTime){
+    public Response<List<UserDesignStatisticDTO>> getDesignStatistic(@RequestParam(required = false) String startTime, @RequestParam(required = false) String endTime,
+                                                                     @RequestParam(required = false) List<Long> ids, @RequestParam(required = false) String email) {
         Long accountId = UserContext.getUserHolder().getId();
-        if (accountId.equals(31L) || accountId.equals(87L) || accountId.equals(83L) || accountId.equals(6L) || accountId.equals(4L) || accountId.equals(73L)){
+        String userEmail = accountService.getById(accountId).getUserEmail();
+        if (accountId.equals(31L) || accountId.equals(87L) || accountId.equals(83L)
+                || accountId.equals(6L) || accountId.equals(4L) || accountId.equals(73L)
+                || userEmail.equals("joho8228@hotmail.com")
+                || userEmail.equals("chelseayu@code-create.com.hk")
+                || userEmail.equals("cheungzt007@gmail.com")
+        ) {
             if (StringUtil.isNullOrEmpty(startTime)) startTime = "2024-02-01 00:00:00";
             if (StringUtil.isNullOrEmpty(endTime)) {
                 SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
                 Date date = new Date();
                 endTime = simpleDateFormat.format(date);
             }
-            List<UserDesignStatisticDTO> designStatistic = designMapper.getDesignStatistic(startTime, endTime);
+            if (!StringUtil.isNullOrEmpty(email)){
+                email = email.trim();
+            }
+            List<UserDesignStatisticDTO> designStatistic = designMapper.getDesignStatistic(startTime, endTime, ids, email);
             return Response.success(designStatistic);
         } else {
             return Response.fail("Sorry, you don't have permission");
         }
     }
 
+
+    //调查问卷
+    @ApiOperation("获取调查问卷统计详情")
+    @GetMapping("/getQuestionnaireStatistic")
+    public Response<QuestionnaireFeedbackVO> getQuestionnaire() {
+        return Response.success(convenientInquiryService.getQuestionnaireInfo());
+    }
+
+    @ApiOperation("获取所有调查问卷")
+    @GetMapping("/getAllQuestionnaire")
+    public Response<List<QuestionnaireVO>> getAllQuestionnaire() {
+        return Response.success(convenientInquiryService.getAllQuestionnaire());
+    }
+
+    @ApiOperation("获取近期新用户")
+    @PostMapping("/recentNewUser")
+    public Response<IPage<Account>> recentNewUser(@Valid @RequestBody QueryUserConditionsVO queryUserConditionsVO) {
+        return Response.success(convenientInquiryService.recentNewUser(queryUserConditionsVO));
+    }
+
+    @ApiOperation("获取近期新用户图表数据")
+    @GetMapping("/recentNewUserChart")
+    public Response<Map<String, Object>> recentNewUserChart(@ApiParam(value = "startTime") @RequestParam @Nullable String startTime,
+                                                            @ApiParam(value = "endTime") @RequestParam @Nullable String endTime,
+                                                            @ApiParam("userType") @RequestParam Integer userType) {
+        return Response.success(convenientInquiryService.recentNewUserChart(startTime, endTime, userType));
+    }
+
+    @ApiOperation("获取近期活跃用户")
+    @PostMapping("/recentActiveUser")
+    public Response<IPage<Account>> recentActiveUser(@Valid @RequestBody QueryUserConditionsVO queryUserConditionsVO) {
+        return Response.success(convenientInquiryService.recentActiveUser(queryUserConditionsVO));
+    }
+
+    @ApiOperation("获取近期活跃用户图表数据")
+    @GetMapping("/recentActiveUserChart")
+    public Response<Integer> recentActiveUserChart(@ApiParam(value = "startTime") @RequestParam @Nullable String startTime,
+                                                   @ApiParam(value = "endTime") @RequestParam @Nullable String endTime) {
+        return Response.success(convenientInquiryService.recentActiveUserChart(startTime, endTime));
+    }
+
+    @ApiOperation("获取用户的各模块功能使用详情")
+    @GetMapping("/getActiveUserFunc")
+    public Response<Map<String, List<Object>>> getActiveUserFunc(@ApiParam(value = "startTime") @RequestParam @Nullable String startTime,
+                                                                 @ApiParam(value = "endTime") @RequestParam @Nullable String endTime,
+                                                                 @ApiParam("userIdList") @RequestParam @Nullable List<Long> userIdList) {
+        return Response.success(convenientInquiryService.getActiveUserFunc(startTime, endTime, userIdList));
+    }
+
+    @ApiOperation("试用用户到正式用户的转化率")
+    @GetMapping("/conversionRate")
+    public Response<Map<String, Object>> conversionRate(@ApiParam(value = "startTime") @RequestParam(required = false) @Nullable String startTime,
+                                                        @ApiParam(value = "endTime") @RequestParam(required = false) @Nullable String endTime) {
+        return Response.success(convenientInquiryService.conversionRate(startTime, endTime));
+    }
+
+    @ApiOperation("试用用户国家/城市分布")
+    @GetMapping("/trialUserCountry")
+    public Response<Map<String, List<Object>>> trialUserCountry(@ApiParam(value = "startTime") @RequestParam(required = false) @Nullable String startTime,
+                                                                @ApiParam(value = "endTime") @RequestParam(required = false) @Nullable String endTime) {
+        return Response.success(convenientInquiryService.trialUserCountry(startTime, endTime));
+    }
+
+    @ApiOperation("添加用户")
+    @PostMapping("/addUser")
+    public Response<Boolean> addUser(@Valid @RequestBody AccountAddDTO accountAddDTO) {
+        Long userAccountId = UserContext.getUserHolder().getId();
+        if (userAccountId.equals(31L) || userAccountId.equals(87L) || userAccountId.equals(83L)
+                || userAccountId.equals(6L) || userAccountId.equals(4L) || userAccountId.equals(73L)
+        ) {
+            return Response.success(convenientInquiryService.addUser(accountAddDTO));
+        } else {
+            return Response.fail("Sorry, you don't have permission");
+        }
+    }
+
+    @ApiOperation("修改用户信息")
+    @PostMapping("/modifyUser")
+    public Response<Boolean> modifyUser(@ApiParam(value = "用户id") @RequestParam @Nullable Long accountId,
+                                        @ApiParam(value = "有效期截止时间的毫秒级unix格式") @RequestParam @Nullable Long validEndTime,
+                                        @ApiParam(value = "用户类型 1/2/3/0 -> yearly/monthly/trial/visitor") @RequestParam @Nullable Integer systemUser,
+                                        @ApiParam("积分") @RequestParam @Nullable Long credits) {
+        Long userAccountId = UserContext.getUserHolder().getId();
+        if (userAccountId.equals(31L) || userAccountId.equals(87L) || userAccountId.equals(83L)
+                || userAccountId.equals(6L) || userAccountId.equals(4L) || userAccountId.equals(73L)
+        ) {
+            return Response.success(convenientInquiryService.modifyUser(accountId, validEndTime, systemUser, credits));
+        } else {
+            return Response.fail("Sorry, you don't have permission");
+        }
+    }
+
+    @ApiOperation("获取用户信息")
+    @PostMapping("/getUserInfo")
+    public Response<IPage<Account>> getUserInfo(@Valid @RequestBody QueryUserConditionsVO queryUserConditionsVO) {
+        Long accountId = UserContext.getUserHolder().getId();
+        String userEmail = accountService.getById(accountId).getUserEmail();
+        if (accountId.equals(31L) || accountId.equals(87L) || accountId.equals(83L)
+                || accountId.equals(6L) || accountId.equals(4L) || accountId.equals(73L)
+                || userEmail.equals("joho8228@hotmail.com")
+                || userEmail.equals("chelseayu@code-create.com.hk")
+                || userEmail.equals("cheungzt007@gmail.com")
+        ) {
+            return Response.success(convenientInquiryService.getUserInfo(queryUserConditionsVO));
+        } else {
+            return Response.fail("Sorry, you don't have permission");
+        }
+    }
+
+    @ApiOperation("获取所有用户id")
+    @GetMapping("/getAllUserId")
+    public Response<List<Map<String, Object>>> getAllUsrIdList() {
+        return Response.success(convenientInquiryService.getAllUserIdList());
+    }
+
+    @ApiOperation("获取所有交易信息")
+    @PostMapping("/queryTransaction")
+    public Response<PageBaseResponse<PaymentInfoVO>>  queryTransactionRecords(@Valid @RequestBody QueryPaymentInfoDTO queryPaymentInfoDTO){
+        return Response.success(convenientInquiryService.queryTransactionRecords(queryPaymentInfoDTO));
+    }
+
+    @ApiOperation("获取所有国家、城市")
+    @GetMapping("/getCities")
+    public Response<Map<String, List<String>>> getCities(){
+        return Response.success(convenientInquiryService.getCities());
+    }
+
+    @ApiOperation("下载交易记录")
+    @PostMapping("/queryTransaction/download")
+    public Response<String> exportTransactionRecords(@Valid @RequestBody QueryPaymentInfoDTO queryPaymentInfoDTO, HttpServletResponse response){
+        return Response.success(convenientInquiryService.exportTransactionRecords(queryPaymentInfoDTO, response));
+    }
 }

src/main/java/com/ai/da/controller/DesignController.java

@@ -31,7 +31,7 @@ public class DesignController {
     @ApiOperation(value = "设计 Conllection")
     @PostMapping("/designCollection")
     @CrossOrigin
-    public Response<DesignCollectionVO> designCollection(@Valid @RequestBody DesignCollectionDTO designDTO) {
+    public Response<String> designCollection(@Valid @RequestBody DesignCollectionDTO designDTO) {
         return Response.success(designService.designCollection(designDTO));
     }
 
@@ -43,7 +43,7 @@ public class DesignController {
 
     @ApiOperation(value = "重新设计 Collection")
     @PostMapping("/reDesignCollection")
-    public Response<DesignCollectionVO> reDesignCollection(@Valid @RequestBody ReDesignCollectionDTO reDesignDTO) {
+    public Response<String> reDesignCollection(@Valid @RequestBody ReDesignCollectionDTO reDesignDTO) {
         return Response.success(designService.reDesignCollection(reDesignDTO));
     }
 
@@ -71,10 +71,16 @@ public class DesignController {
         return Response.success(designService.dislike(disDesignLikeDTO));
     }
 
+    @ApiOperation(value = "Design sort")
+    @PostMapping("/sort")
+    public Response<Boolean> sort(@Valid @RequestBody UserLikeSortDTO userLikeSortDTO) {
+        return Response.success(designService.sort(userLikeSortDTO));
+    }
+
     @ApiOperation(value = "sketchBoard upload generate design前裁剪")
     @PostMapping("/sketchBoardsBoundingBox")
-    public Response<List<CollectionSketchVO>> sketchesBoundingBox(@Valid @RequestBody SketchesBoundingBoxDTO sketchesBoundingBoxDTO) {
-        return Response.success(designService.sketchesBoundingBox(sketchesBoundingBoxDTO));
+    public Response<List<CollectionSketchVO>> sketchesBoundingBox(@Valid @RequestBody ReDesignCollectionDTO reDesignCollectionDTO) {
+        return Response.success(designService.sketchesBoundingBox(reDesignCollectionDTO));
     }
 
     @ApiOperation(value = "通过designItemId获取模特图")
@@ -83,4 +89,16 @@ public class DesignController {
         return Response.success(designService.getModel(designItemIdList));
     }
 
+    @ApiOperation(value = "获取design结果")
+    @GetMapping("/getDesignResult")
+    public Response<DesignCollectionVO> getDesignResult(@RequestParam("requestId") String requestId, @RequestParam("objectSignList") List<String> objectSignList){
+        return Response.success(designService.getDesignResult(requestId, objectSignList));
+    }
+
+    @ApiOperation(value = "云生成")
+    @PostMapping("/designCloud")
+    @CrossOrigin
+    public Response<String> designCloud(@Valid @RequestBody DesignCollectionDTO designDTO) {
+        return Response.success(designService.designCloud(designDTO));
+    }
 }

src/main/java/com/ai/da/controller/DesignDetailController.java

@@ -77,4 +77,18 @@ public class DesignDetailController {
     public Response<ComposeLayersVO> editPositionAndScale(@Valid @RequestBody EditLayersPositionAndScaleVO positionAndScaleVO) throws IOException {
         return Response.success(designItemService.editLayersPositionAndScale(positionAndScaleVO));
     }
+
+    @ApiOperation(value = "mask数据兼容")
+    @GetMapping("/convertWithoutGradient")
+    public Response<String> convertHistoryMaskWithoutGradient(){
+        designItemService.convertHistoryMaskWithoutGradient();
+        return Response.success("success");
+    }
+
+    @ApiOperation(value = "mask数据库路径更新")
+    @GetMapping("/updateMaskUrl")
+    public Response<String> updateMaskUrl(){
+        designItemService.updateMaskUrl();
+        return Response.success("success");
+    }
 }

src/main/java/com/ai/da/controller/ElementController.java

@@ -66,6 +66,8 @@ public class ElementController {
         return Response.success();
     }
 
+    /** 该功能已删除  */
+    @Deprecated
     @ApiOperation(value = "生成印花")
     @PostMapping("/generatePrint")
     public Response<GenerateCollectionItemVO> generatePrint(@Valid @RequestBody CollectionGeneratePrintDTO generatePrintDTO) {

src/main/java/com/ai/da/controller/GenerateController.java

@@ -2,7 +2,9 @@ package com.ai.da.controller;
 
 import com.ai.da.common.response.Response;
 import com.ai.da.model.dto.GenerateLikeDTO;
+import com.ai.da.model.dto.GenerateModifyDTO;
 import com.ai.da.model.dto.GenerateThroughImageTextDTO;
+import com.ai.da.model.dto.ImageToSketchDTO;
 import com.ai.da.model.vo.*;
 import com.ai.da.service.GenerateService;
 import io.swagger.annotations.Api;
@@ -83,5 +85,17 @@ public class GenerateController {
         return Response.success(generateResult);
     }
 
+    @ApiOperation(value = "imageToSketch")
+    @PostMapping("/imageToSketch")
+    public Response<GenerateResultVO> imageToSketch(@Valid @RequestBody ImageToSketchDTO imageToSketchDTO) {
+        return Response.success(generateService.imageToSketch(imageToSketchDTO));
+    }
+
+    // modifySketch
+    @ApiOperation(value = "modifySketch")
+    @PostMapping("/modifySketch")
+    public Response<GenerateResultVO> modifySketch(@Valid @RequestBody GenerateModifyDTO generateModifyDTO) {
+        return Response.success(generateService.modifySketch(generateModifyDTO));
+    }
 
 }

src/main/java/com/ai/da/controller/MessageCenterController.java

@@ -0,0 +1,63 @@
+package com.ai.da.controller;
+
+import com.ai.da.common.response.PageBaseResponse;
+import com.ai.da.common.response.Response;
+import com.ai.da.model.dto.GetNotificationDTO;
+import com.ai.da.model.vo.NotificationVO;
+import com.ai.da.model.dto.PublishSysNotificationDTO;
+import com.ai.da.service.MessageCenterService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.web.bind.annotation.*;
+
+import javax.annotation.Resource;
+import javax.validation.Valid;
+import java.util.List;
+import java.util.Map;
+
+@Api(tags = "消息中心模块")
+@Slf4j
+@RestController
+@RequestMapping("/api/message")
+public class MessageCenterController {
+
+    @Resource
+    private MessageCenterService messageCenterService;
+
+    // 获取未读消息总数
+    @ApiOperation(value = "获取未读消息数")
+    @GetMapping("/getUnreadCount")
+    public Response<Map<String, Long>> getUnreadMessage(){
+        return Response.success(messageCenterService.getAllTypeMessageUnreadCount());
+    }
+
+    // 获取历史消息
+    @ApiOperation(value = "获取历史消息")
+    @PostMapping("/getHistoryNotification")
+    public Response<PageBaseResponse<NotificationVO>> getHistoryNotification(@Valid @RequestBody GetNotificationDTO getNotificationDTO) {
+        return Response.success(messageCenterService.getHistoryNotification(getNotificationDTO));
+    }
+
+    // 已读消息
+    @ApiOperation(value = "设置消息状态为已读")
+    @PostMapping("/setReadStatus")
+    public Response<Boolean> setReadStatus(@RequestParam("notificationIdList") List<Long> notificationIdList, @RequestParam("type") String type) {
+        return Response.success(messageCenterService.setReadStatus(notificationIdList, type));
+    }
+
+    // 发布系统消息
+    @ApiOperation(value = "发布系统消息")
+    @PostMapping("/publishSysMessage")
+    public Response<String> publishSysMessage(@Valid @RequestBody PublishSysNotificationDTO message) {
+        messageCenterService.publishSystemNotification(message);
+        return Response.success("success");
+    }
+
+    @ApiOperation(value = "一键已读")
+    @PostMapping("/oneClickRead")
+    public Response<String> setReadAll(@RequestParam("type") String type) {
+        messageCenterService.setReadAll(type);
+        return Response.success("success");
+    }
+}

src/main/java/com/ai/da/controller/OrderInfoController.java

@@ -3,9 +3,10 @@ package com.ai.da.controller;
 import com.ai.da.common.enums.OrderStatusEnum;
 import com.ai.da.common.response.PageBaseResponse;
 import com.ai.da.common.response.Response;
-import com.ai.da.mapper.primary.entity.OrderInfo;
 import com.ai.da.model.dto.QueryPageByTimeDTO;
+import com.ai.da.model.vo.OrderListVO;
 import com.ai.da.service.OrderInfoService;
+import com.ai.da.service.PaymentInfoService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import org.springframework.web.bind.annotation.*;
@@ -22,10 +23,13 @@ public class OrderInfoController {
     @Resource
     private OrderInfoService orderInfoService;
 
+    @Resource
+    private PaymentInfoService paymentInfoService;
+
     @ApiOperation("订单列表")
     @PostMapping("/list")
-    public Response<PageBaseResponse<OrderInfo>> list(@Valid @RequestBody QueryPageByTimeDTO queryPageByTimeDTO){
-        PageBaseResponse<OrderInfo> orderByAccountId = orderInfoService.getOrderByPage(queryPageByTimeDTO);
+    public Response<PageBaseResponse<OrderListVO>> list(@Valid @RequestBody QueryPageByTimeDTO queryPageByTimeDTO){
+        PageBaseResponse<OrderListVO> orderByAccountId = paymentInfoService.getPaymentInfo(queryPageByTimeDTO);
 //        List<OrderInfo> list = orderInfoService.listOrderByCreateTimeDesc();
         return Response.success(orderByAccountId);
     }

src/main/java/com/ai/da/controller/PayPalCheckoutController.java

@@ -1,6 +1,7 @@
 package com.ai.da.controller;
 
 import com.ai.da.common.response.Response;
+import com.ai.da.model.dto.ProductPurchaseDTO;
 import com.ai.da.service.PayPalCheckoutService;
 import com.paypal.http.HttpResponse;
 import com.paypal.http.exceptions.SerializeException;
@@ -14,6 +15,7 @@ import javax.annotation.Resource;
 import javax.servlet.ServletException;
 import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;
+import javax.validation.Valid;
 import java.io.IOException;
 import java.util.HashMap;
 
@@ -26,9 +28,9 @@ public class PayPalCheckoutController {
     private PayPalCheckoutService payPalCheckoutService;
 
     @ApiOperation(value = "创建订单")
-    @PostMapping(value = "/trade/{amount}")
-    public Response<HashMap<String, String>> createOrder(@PathVariable Integer amount, @RequestParam String returnUrl) throws SerializeException {
-        HashMap<String, String> approvalUrl = payPalCheckoutService.createOrder(amount,returnUrl);
+    @PostMapping(value = "/trade")
+    public Response<HashMap<String, String>> createOrder(@Valid @RequestBody ProductPurchaseDTO productPurchaseDTO, HttpServletRequest request) throws SerializeException {
+        HashMap<String, String> approvalUrl = payPalCheckoutService.createOrder(productPurchaseDTO, request);
         return Response.success(approvalUrl);
     }
 

src/main/java/com/ai/da/controller/PortfolioController.java

@@ -1,12 +1,14 @@
 package com.ai.da.controller;
 
+import com.ai.da.common.config.exception.BusinessException;
 import com.ai.da.common.response.PageBaseResponse;
 import com.ai.da.common.response.Response;
+import com.ai.da.mapper.primary.entity.Account;
 import com.ai.da.model.dto.*;
+import com.ai.da.model.vo.*;
 import com.ai.da.model.vo.CommentVO;
 import com.ai.da.model.vo.PortfolioVO;
 import com.ai.da.model.vo.UserLikeChooseVO;
-import com.ai.da.model.vo.UserLikeGroupVO;
 import com.ai.da.service.PortfolioService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
@@ -16,6 +18,7 @@ import org.springframework.web.multipart.MultipartFile;
 
 import javax.annotation.Resource;
 import javax.validation.Valid;
+import java.util.List;
 
 @Api(tags = "Portfolio模块")
 @Slf4j
@@ -28,7 +31,7 @@ public class PortfolioController {
 
     @ApiOperation(value = "发布作品集")
     @PostMapping("/publish")
-    public Response<Boolean> preLogin(@RequestParam("file") MultipartFile canvas, @RequestParam("data") String data) {
+    public Response<Long> preLogin(@RequestParam("file") MultipartFile canvas, @RequestParam("data") String data) {
         return Response.success(portfolioService.publish(canvas, data));
     }
 
@@ -117,4 +120,38 @@ public class PortfolioController {
     public Response<Boolean> commentDelete(@Valid @RequestBody CommentDTO commentDTO) {
         return Response.success(portfolioService.commentDelete(commentDTO));
     }
+
+    @ApiOperation(value = "关注")
+    @GetMapping("/follow")
+    public Response<String> follow(@RequestParam("followeeId") Long followeeId) {
+        portfolioService.follow(followeeId);
+        return Response.success(BusinessException.getMessageFromResource("subscription.success"));
+    }
+
+    @ApiOperation(value = "取消关注")
+    @GetMapping("/cancelFollow")
+    public Response<String> cancelFollow(@RequestParam("followeeId") Long followeeId) {
+        portfolioService.cancelFollow(followeeId);
+        return Response.success(BusinessException.getMessageFromResource("unsubscribe.success"));
+    }
+
+    @ApiOperation(value = "获取关注列表")
+    @PostMapping("/getFolloweeList")
+    public Response<List<AccountFollowVO>> getFolloweeList(@Valid @RequestBody GetFollowListDTO getFollowListDTO) {
+        return Response.success(portfolioService.getFolloweeList(getFollowListDTO));
+    }
+
+    @ApiOperation(value = "获取粉丝列表")
+    @PostMapping("/getFollowerList")
+    public Response<List<AccountFollowVO>> getFollowerList(@Valid @RequestBody GetFollowListDTO getFollowListDTO) {
+        return Response.success(portfolioService.getFollowerList(getFollowListDTO));
+    }
+
+
+/*    @ApiOperation(value = "按标签名查询作品")
+    @GetMapping("/queryPortfolioByTag")
+    public Response<List<PortfolioVO>> queryPortfolioByTag(@RequestParam(value = "tagName", required = false) String tagName,
+                                                           @RequestParam(value = "tagId", required = false) Long tagId) {
+        return Response.success(portfolioService.queryPortfolioByTag(tagName, tagId));
+    }*/
 }

src/main/java/com/ai/da/controller/SavedCollectionController.java

@@ -104,9 +104,9 @@ public class SavedCollectionController {
         }
         List<Long> groupIds = page.getRecords().stream().map(UserLikeGroup::getId).collect(Collectors.toList());
         List<UserLikeVO> groupDetails = userLikeService.getGroupDetails(groupIds);
-        if (CollectionUtils.isEmpty(groupDetails)) {
-            throw new BusinessException("groupDetails.not.found");
-        }
+//        if (CollectionUtils.isEmpty(groupDetails)) {
+//            throw new BusinessException("groupDetails.not.found");
+//        }
         Map<Long, List<UserLikeVO>> groupDetailMap = groupDetails.stream()
                 .collect(Collectors.groupingBy(UserLikeVO::getUserLikeGroupId));
 
@@ -117,6 +117,7 @@ public class SavedCollectionController {
                 userLikeGroupVO.setUpdateDate(group.getUpdateDate().getTime());
                 userLikeGroupVO.setAuthor(account.getUserName());
                 //count 和detail
+                if (groupDetailMap.keySet().contains(group.getId())) {
                     List<UserLikeVO> details = groupDetailMap.get(group.getId());
                     for (UserLikeVO detail : details) {
                         TDesignPythonOutfit tDesignPythonOutfit = designPythonOutfitMapper.selectById(detail.getDesignOutfitId());
@@ -124,6 +125,9 @@ public class SavedCollectionController {
                     }
                     userLikeGroupVO.setGroupDetails(details);
                     userLikeGroupVO.setSketchCount(CollectionUtils.isEmpty(details) ? 0 : details.size());
+                }else {
+                    userLikeGroupVO.setSketchCount(0);
+                }
                 if (userLikeGroupVO.getOriginal() == 0) {
                     userLikeGroupVO.setOriginalAccountName(accountService.getById(userLikeGroupVO.getOriginalAccountId()).getUserName());
                     Portfolio byId = portfolioService.getByIdAll(userLikeGroupVO.getOriginalPortfolioId());
@@ -235,4 +239,22 @@ public class SavedCollectionController {
         List<MagicToolResultVO> magicToolResultVOList = userLikeGroupService.getRelightResult(taskIdList);
         return Response.success(magicToolResultVOList);
     }
+
+    @ApiOperation(value = "likeHistoryRelSketch")
+    @PostMapping("/likeHistoryRelSketch")
+    public Response<String> likeHistoryRelSketch() {
+        return Response.success(userLikeGroupService.likeHistoryRelSketch());
+    }
+
+    @ApiOperation(value = "download")
+    @PostMapping("/download")
+    public Response<String> download() {
+        return Response.success(userLikeGroupService.download());
+    }
+
+    @ApiOperation(value = "productImageInitialize")
+    @PostMapping("/productImageInitialize")
+    public Response<Boolean> productImageUpload(@Valid @RequestBody ProductImageInitializeDTO productImageInitializeDTO) {
+        return Response.success(userLikeGroupService.productImageInitialize(productImageInitializeDTO));
+    }
 }

src/main/java/com/ai/da/controller/StripeController.java

@@ -1,47 +1,84 @@
 package com.ai.da.controller;
 
 import com.ai.da.common.response.Response;
+import com.ai.da.common.utils.DateUtil;
+import com.ai.da.common.utils.RedisUtil;
+import com.ai.da.common.utils.SendEmailUtil;
+import com.ai.da.mapper.primary.entity.ProductCoupons;
+import com.ai.da.model.dto.CreateCouponDTO;
+import com.ai.da.model.dto.ProductPurchaseDTO;
+import com.ai.da.model.dto.QueryCouponsPageDTO;
+import com.ai.da.model.vo.CheckCouponsVO;
 import com.ai.da.service.StripeService;
+import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.paypal.http.HttpResponse;
 import com.paypal.payments.Refund;
+import com.stripe.exception.StripeException;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.web.bind.annotation.*;
+import springfox.documentation.annotations.ApiIgnore;
 
 import javax.annotation.Resource;
 import javax.servlet.ServletException;
 import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import javax.validation.Valid;
 import java.io.IOException;
+import java.util.Date;
+import java.util.List;
 
 @Api(tags = "Stripe模块")
 @Slf4j
 @RestController
 @RequestMapping("/api/stripe")
+@ApiIgnore
 public class StripeController {
 
     @Resource
     private StripeService stripeService;
+    @Resource
+    private RedisUtil redisUtil;
 
     @ApiOperation("创建支付链接")
-    @PostMapping("/createOrder/{amount}")
-    public Response<String> pay(@PathVariable Integer amount, @RequestParam String returnUrl) {
-        return Response.success(stripeService.pay(amount, returnUrl));
+    @PostMapping("/createOrder")
+    public Response<String> pay(@Valid @RequestBody ProductPurchaseDTO productPurchaseDTO, HttpServletRequest request) {
+        return Response.success(stripeService.pay(productPurchaseDTO, request));
     }
 
+    @Value("${stripe.webhook.fail.reminder}")
+    private String webhookReminderFlag;
+
     @ApiOperation("支付通知")
     @PostMapping("/trade/notify")
-    public Response<String> callback(HttpServletRequest request) throws ServletException, IOException {
+    public void callback(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
+        try{
             Boolean result =  stripeService.notify(request);
             if (result){
-            return Response.success(200,"success");
+                response.setStatus(HttpServletResponse.SC_OK);
             }else {
-            return Response.fail(400,"failure");
+                response.setStatus(HttpServletResponse.SC_INTERNAL_SERVER_ERROR);
+            }
+        }catch (Exception e){
+            log.error("Stripe Controller层异常捕捉, {}", e.getMessage());
+            e.printStackTrace();
+            String key_1 = RedisUtil.STRIPE_EXCEPTION_LOG + DateUtil.dateToStr(new Date(), DateUtil.YYYY_MM_DD_HH);
+            String key_2 = key_1 + ":" + DateUtil.dateToStr(new Date(), DateUtil.YYYY_MM_DD_hh_mm_ss);
+            String stackTrace = stripeService.getStackTrace(e, 10);
+            redisUtil.addToString(key_2, stackTrace);
+            Long size = redisUtil.getSize(key_1);
+            // 给我发送邮件
+            if (webhookReminderFlag.equals("1") && size == 3){
+                SendEmailUtil.commonExceptionReminder("Stripe Webhook 回调", new String[]{"xupei3360@163.com"});
+            }
+            response.setStatus(HttpServletResponse.SC_INTERNAL_SERVER_ERROR);
         }
     }
 
     @ApiOperation("申请退款")
-    @PostMapping("/trade/refund/{orderNo}/{reason}")
+    @GetMapping("/trade/refund/{orderNo}/{reason}")
     public Response<HttpResponse<Refund>> refund(@PathVariable String orderNo, @PathVariable String reason) throws IOException {
         String response = stripeService.refund(null,orderNo,reason);
         if (response.equals("退款成功")){
@@ -51,4 +88,105 @@ public class StripeController {
         }
     }
 
+    @ApiOperation("获取订阅")
+    @GetMapping("/getSubscription")
+    public Response<List<String>> getSubscription(@RequestParam String name, @RequestParam String email) {
+        try {
+            return Response.success(stripeService.getSubscriptionIds(name, email));
+        } catch (StripeException e) {
+            throw new RuntimeException(e);
+        }
+    }
+
+    @ApiOperation("取消订阅")
+    @GetMapping("/cancelSubscription")
+    public Response<String> cancelSubscription(@RequestParam String subscriptionId, @RequestParam(required = false) String reason) {
+        stripeService.cancelSubscription(subscriptionId, reason);
+        return Response.success("success");
+    }
+
+    @ApiOperation("创建推广码")
+    @PostMapping("/createCoupon")
+    public Response<String> createCoupon(@Valid @RequestBody CreateCouponDTO createCouponDTO){
+        return Response.success(stripeService.createCoupon(createCouponDTO));
+    }
+
+    @ApiOperation("检查推广码")
+    @GetMapping("/checkCoupon")
+    public Response<CheckCouponsVO> checkCoupon(@RequestParam String promotionCode, @RequestParam Long price){
+        return Response.success(stripeService.checkProductCoupon(promotionCode, price));
+    }
+
+    @ApiOperation("获取所有推广码")
+    @PostMapping("/getAllCoupons")
+    public Response<IPage<ProductCoupons>> getAllCoupons(@RequestBody QueryCouponsPageDTO queryCouponsPageDTO){
+        return Response.success(stripeService.getAllCoupons(queryCouponsPageDTO));
+    }
+
+    @ApiOperation("检索优惠券")
+    @GetMapping("/retrieveCoupon")
+    public Response<String> retrieveCoupon(@RequestParam String couponId){
+        return Response.success(stripeService.retrieveCoupon(couponId));
+    }
+
+    @ApiOperation("检索推广码")
+    @GetMapping("/retrievePromotionCode")
+    public Response<String> retrievePromotionCode(@RequestParam String retrievePromotionCode){
+        return Response.success(stripeService.retrievePromotionCode(retrievePromotionCode));
+    }
+
+    @ApiOperation("更新推广码信息")
+    @GetMapping("/updatePromCodeInfo")
+    public Response<ProductCoupons> updateCouponsInfo(@RequestParam Long id, @RequestParam(required = false) String paidCommission,
+                                                      @RequestParam(required = false) String cooperator,
+                                                      @RequestParam(required = false) String remark,
+                                                      @RequestParam(required = false) Long startTime){
+        return Response.success(stripeService.updateCouponsInfo(id, paidCommission, cooperator, remark, startTime));
+    }
+
+    @ApiOperation("删除推广码")
+    @GetMapping("/deletePromCode")
+    public Response<String> deleteCoupon(@RequestParam Long id){
+        stripeService.deleteCoupon(id);
+        return Response.success("success");
+    }
+
+    /*@ApiOperation("临时 取消订阅")
+    @GetMapping("/cancelSubscriptionTemp")
+    public Response<String> cancelSubscriptionTemp(@RequestParam String subscriptionId) {
+        stripeService.cancelSubscriptionTemp(subscriptionId);
+        return Response.success("success");
+    }
+
+    @ApiOperation("创建订阅 临时")
+    @GetMapping("/createSubscriptionTemp")
+    public Response<String> createSubscriptionTemp(@RequestParam String name, @RequestParam String email) {
+        return Response.success(stripeService.createSubscriptionTemp(name, email));
+    }
+
+    @ApiOperation("修改用户默认支付方式 临时")
+    @GetMapping("/changeCustomerPayment")
+    public Response<String> changeCustomerPayment(@RequestParam String name, @RequestParam String email) {
+        return Response.success(stripeService.changeCustomerPayment(name, email));
+    }
+
+    @ApiOperation("临时 发送续订失败邮件")
+    @GetMapping("/sendRenewalFailEmail")
+    public Response<Boolean> sendRenewalFailEmail(@RequestParam String invoiceId, @RequestParam String subscriptionId, @RequestParam String orderNo) {
+        return Response.success(stripeService.sendRenewalFailEmail(invoiceId, subscriptionId,orderNo));
+    }
+
+    @ApiOperation("临时 查询指定用户绑定的付款方式")
+    @GetMapping("/getCustomerPaymentMethod")
+    public Response<List<Map<String,String>>> getCustomerPaymentMethod(@RequestParam String name, @RequestParam String email) {
+        return Response.success(stripeService.getCustomerPaymentMethod(name, email));
+    }
+
+    @ApiOperation("临时 解绑指定用户绑定的所有付款方式")
+    @GetMapping("/detachCustomerAllPaymentMethod")
+    public Response<String> detachCustomerAllPaymentMethod(@RequestParam String name, @RequestParam String email) {
+        return Response.success(stripeService.detachCustomerAllPaymentMethod(name, email));
+    }*/
+
+
 }

src/main/java/com/ai/da/controller/TagsController.java

@@ -0,0 +1,31 @@
+package com.ai.da.controller;
+
+
+import com.ai.da.common.response.Response;
+import com.ai.da.mapper.primary.entity.Product;
+import com.ai.da.mapper.primary.entity.Tags;
+import com.ai.da.service.ProductService;
+import com.ai.da.service.TagsService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.web.bind.annotation.*;
+
+import javax.annotation.Resource;
+import java.util.Date;
+import java.util.List;
+
+@CrossOrigin //开放前端的跨域访问
+@Api(tags = "标签管理")
+@RestController
+@RequestMapping("/api/tags")
+public class TagsController {
+
+    @Resource
+    private TagsService tagsService;
+
+    @ApiOperation("获取标签")
+    @GetMapping("/getTags")
+    public Response<List<Tags>> getTags(@RequestParam(value = "userInput", required = false) String userInput) {
+        return Response.success(tagsService.getTags(userInput));
+    }
+}

src/main/java/com/ai/da/controller/ThirdPartyController.java

@@ -1,9 +1,13 @@
 package com.ai.da.controller;
 
 import com.ai.da.common.response.Response;
+import com.ai.da.mapper.primary.entity.GoogleUser;
 import com.ai.da.model.dto.*;
 import com.ai.da.model.vo.AccountLoginVO;
+import com.ai.da.model.vo.DesignCollectionVO;
 import com.ai.da.service.AccountService;
+import com.ai.da.service.DesignService;
+import com.alibaba.fastjson.JSONObject;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import lombok.extern.slf4j.Slf4j;
@@ -14,6 +18,7 @@ import org.springframework.web.bind.annotation.*;
 
 import javax.annotation.Resource;
 import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpSession;
 import javax.validation.Valid;
 import java.security.cert.X509Certificate;
 
@@ -27,6 +32,9 @@ public class ThirdPartyController {
     @Resource
     private AccountService accountService;
 
+    @Resource
+    private DesignService designService;
+
     /*@ApiOperation(value = "Add user information")
     @PostMapping("/addUser")
     public Response<Boolean> addUser(@Valid @RequestBody AccountAddDTO accountAddDTO) {
@@ -107,4 +115,35 @@ public class ThirdPartyController {
     public Response<String> getRedirectUrl() {
         return Response.success(REDIRECT_URL);
     }
+
+    @CrossOrigin
+    @ApiOperation(value = "updateNoLoginRequiredNew")
+    @PostMapping("/updateNoLoginRequiredNew")
+    public Response<String> updateNoLoginRequiredNew(@RequestBody NoLoginRequiredDTO noLoginRequiredDTO, HttpServletRequest request) {
+        return Response.success(accountService.updateNoLoginRequiredNew(noLoginRequiredDTO, request));
+    }
+
+    @CrossOrigin
+    @GetMapping("/auth/google_callback")
+    public Response<String> googleCallback(@RequestParam("code") String code, HttpSession session) {
+        return Response.success(accountService.googleCallback(code, session));
+    }
+    @CrossOrigin
+    @GetMapping("/parseGoogleCredential")
+    public Response<AccountLoginVO> parseGoogleCredential(@RequestParam("credential") String credential, @RequestParam("type") Integer type) {
+        return Response.success(accountService.parseGoogleCredential(credential, type));
+    }
+
+    @CrossOrigin
+    @GetMapping("/parseWeChatCode")
+    public Response<AccountLoginVO> parseWeChatCode(@RequestParam("code") String code, @RequestParam("type") Integer type) {
+        return Response.success(accountService.parseWeChatCode(code, type));
+    }
+
+    @ApiOperation(value = "接收Design结果")
+    @PostMapping("/receiveDesignResults")
+    @CrossOrigin
+    public Response<Boolean> receiveDesignResults(@Valid @RequestBody JSONObject responseObject) {
+        return Response.success(designService.receiveDesignResults(responseObject));
+    }
 }

src/main/java/com/ai/da/mapper/primary/AccountExtendMapper.java

@@ -0,0 +1,18 @@
+package com.ai.da.mapper.primary;
+
+import com.ai.da.common.config.mybatis.plus.CommonMapper;
+import com.ai.da.mapper.primary.entity.AccountExtend;
+
+import java.util.Date;
+import java.util.List;
+
+/**
+ * Mapper 接口
+ *
+ * @author easy-generator
+ * @since 2022-06-13
+ */
+public interface AccountExtendMapper extends CommonMapper<AccountExtend> {
+
+
+}

src/main/java/com/ai/da/mapper/primary/AccountMapper.java

@@ -3,6 +3,7 @@ package com.ai.da.mapper.primary;
 import com.ai.da.common.config.mybatis.plus.CommonMapper;
 import com.ai.da.mapper.primary.entity.Account;
 
+import java.util.Date;
 import java.util.List;
 
 /**
@@ -29,4 +30,6 @@ public interface AccountMapper extends CommonMapper<Account> {
      */
 //    Account findById(String id);
 
+    void toVisitor(Long id);
+
 }

src/main/java/com/ai/da/mapper/primary/AffiliateIncomeMapper.java

@@ -0,0 +1,14 @@
+package com.ai.da.mapper.primary;
+
+import com.ai.da.mapper.primary.entity.AffiliateIncome;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+import java.util.List;
+import java.util.Map;
+
+public interface AffiliateIncomeMapper extends BaseMapper<AffiliateIncome> {
+
+    List<Map<String, Object>> getPersonalMonthlyIncome(Long affiliateAccountId, int year);
+
+    List<Map<String, Object>> getMonthlyAffiliateIncome(int year, int month);
+}

src/main/java/com/ai/da/mapper/primary/AffiliateMapper.java

@@ -0,0 +1,19 @@
+package com.ai.da.mapper.primary;
+
+import com.ai.da.mapper.primary.entity.Affiliate;
+import com.ai.da.model.vo.AffiliateVO;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+import java.util.List;
+import java.util.Map;
+
+public interface AffiliateMapper extends BaseMapper<Affiliate> {
+
+    Map<String, Long> getMonthlyApprovedAffiliate(int year, int month);
+
+    List<AffiliateVO> getAffiliateList(String status, String startTime, String endTime,
+                                       String order, Long affiliateId, int size, int offset);
+
+    int queryAffiliateTotalCount(String status, String startTime, String endTime, Long affiliateId);
+
+}

src/main/java/com/ai/da/mapper/primary/DesignBatchMapper.java

@@ -0,0 +1,16 @@
+package com.ai.da.mapper.primary;
+
+import com.ai.da.common.config.mybatis.plus.CommonMapper;
+import com.ai.da.mapper.primary.entity.AccountExtend;
+import com.ai.da.mapper.primary.entity.DesignBatch;
+
+/**
+ * Mapper 接口
+ *
+ * @author easy-generator
+ * @since 2022-06-13
+ */
+public interface DesignBatchMapper extends CommonMapper<DesignBatch> {
+
+
+}

src/main/java/com/ai/da/mapper/primary/DesignMapper.java

@@ -18,5 +18,5 @@ public interface DesignMapper extends CommonMapper<Design> {
     //返回插入数据后生成的主键
     Long insertDesign(Design design);
 
-    List<UserDesignStatisticDTO> getDesignStatistic(String startTime, String endTime);
+    List<UserDesignStatisticDTO> getDesignStatistic(String startTime, String endTime, List<Long> ids, String email);
 }

src/main/java/com/ai/da/mapper/primary/GenerateMapper.java

@@ -3,5 +3,10 @@ package com.ai.da.mapper.primary;
 import com.ai.da.common.config.mybatis.plus.CommonMapper;
 import com.ai.da.mapper.primary.entity.Generate;
 
+import java.util.List;
+import java.util.Map;
+
 public interface GenerateMapper extends CommonMapper<Generate> {
+
+    List<Map<String, Object>> getByTypeAndTime(String startTime, String endTime, List<Long> accountIdList);
 }

src/main/java/com/ai/da/mapper/primary/MoodboardPositionMapper.java

@@ -0,0 +1,7 @@
+package com.ai.da.mapper.primary;
+
+import com.ai.da.common.config.mybatis.plus.CommonMapper;
+import com.ai.da.mapper.primary.entity.MoodboardPosition;
+
+public interface MoodboardPositionMapper extends CommonMapper<MoodboardPosition> {
+}

src/main/java/com/ai/da/mapper/primary/NotificationMapper.java

@@ -0,0 +1,24 @@
+package com.ai.da.mapper.primary;
+
+import com.ai.da.common.config.mybatis.plus.CommonMapper;
+import com.ai.da.mapper.primary.entity.Notification;
+
+import java.time.LocalDateTime;
+import java.util.List;
+import java.util.Map;
+
+public interface NotificationMapper extends CommonMapper<Notification> {
+
+    List<Map<String, Object>> getTypeCount(Long receiverId);
+
+    /** 解决mybatis-plus自动过滤 is_deleted为1的数据 问题 */
+    Notification getUniqueLikeAndFollow(String type, Long senderId, Long receiverId, Long portfolioId);
+
+    void updateUniqueLikeAndFollow(Long id, LocalDateTime time);
+
+    void deleteNotification(Long id, LocalDateTime time);
+
+    void setPersonalNotificationAllRead(String type, Long receiverId, LocalDateTime time);
+
+    List<Long> getUnreadSysNotification(Long accountId);
+}

src/main/java/com/ai/da/mapper/primary/PaymentInfoMapper.java

@@ -1,7 +1,39 @@
 package com.ai.da.mapper.primary;
 
 import com.ai.da.mapper.primary.entity.PaymentInfo;
+import com.ai.da.model.vo.OrderListVO;
+import com.ai.da.model.vo.PaymentInfoVO;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.math.BigDecimal;
+import java.util.List;
+import java.util.Map;
 
 public interface PaymentInfoMapper extends BaseMapper<PaymentInfo> {
+
+    List<OrderListVO> selectPageOrderList(Long accountId, String startTime, String endTime, int offset, int pageSize, Long id);
+
+    int queryOrderListTotalCount(Long accountId, String startTime, String endTime, Long id);
+
+    List<PaymentInfoVO> queryPaymentInfo(String paymentType,String payerTotal, String type, String status,
+                                         String country, String city, String startTime, String endTime,
+                                         int limit, int offset, String order, String payer
+    );
+
+    Long queryPaymentInfoCount(String paymentType,String payerTotal, String type, String status,
+                                         String country, String city, String startTime, String endTime, String payer
+    );
+
+    BigDecimal queryTotalPaymentAmount(String paymentType,String payerTotal, String type, String status,
+                                       String country, String city, String startTime, String endTime, String payer
+    );
+
+    List<Map<String, String>> getCities();
+
+    List<Map<String, String>> getCountries();
+
+    int insertIgnore(@Param("paymentInfo")PaymentInfo paymentInfo);
+
+    List<PaymentInfo> selectPaidPaymentsByAccountAndPromotion(Long accountId, String promotionCode);
 }

src/main/java/com/ai/da/mapper/primary/PortfolioMapper.java

@@ -3,6 +3,10 @@ package com.ai.da.mapper.primary;
 import com.ai.da.common.config.mybatis.plus.CommonMapper;
 import com.ai.da.mapper.primary.entity.Portfolio;
 
+import java.util.List;
+
 public interface PortfolioMapper extends CommonMapper<Portfolio> {
     Portfolio getByIdAll(Long originalPortfolioId);
+
+    List<Portfolio> getByTag(Long accountId, String tagName);
 }

src/main/java/com/ai/da/mapper/primary/PortfolioTagsMapper.java

@@ -0,0 +1,15 @@
+package com.ai.da.mapper.primary;
+
+import com.ai.da.common.config.mybatis.plus.CommonMapper;
+import com.ai.da.mapper.primary.entity.PortfolioTags;
+
+import java.time.LocalDateTime;
+
+public interface PortfolioTagsMapper extends CommonMapper<PortfolioTags> {
+
+    void deleteByPortfolioId(Long portfolioId);
+
+    // portfolioId与tagId建立唯一约束， 如果组合 portfolio_id 和 tag_id 已经存在，插入操作会被忽略。
+    void insertIgnore(Long portfolioId, Long tagId, LocalDateTime time);
+
+}

src/main/java/com/ai/da/mapper/primary/ProductCouponsMapper.java

@@ -0,0 +1,8 @@
+package com.ai.da.mapper.primary;
+
+import com.ai.da.common.config.mybatis.plus.CommonMapper;
+import com.ai.da.mapper.primary.entity.ProductCoupons;
+
+public interface ProductCouponsMapper extends CommonMapper<ProductCoupons> {
+
+}

src/main/java/com/ai/da/mapper/primary/ProductImageAttributeMapper.java

@@ -0,0 +1,7 @@
+package com.ai.da.mapper.primary;
+
+import com.ai.da.common.config.mybatis.plus.CommonMapper;
+import com.ai.da.mapper.primary.entity.ProductImageAttribute;
+
+public interface ProductImageAttributeMapper extends CommonMapper<ProductImageAttribute> {
+}

src/main/java/com/ai/da/mapper/primary/SubscriptionInfoMapper.java

@@ -0,0 +1,9 @@
+package com.ai.da.mapper.primary;
+
+import com.ai.da.mapper.primary.entity.SubscriptionInfo;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Param;
+
+public interface SubscriptionInfoMapper extends BaseMapper<SubscriptionInfo> {
+    int insertIgnore(@Param("subscriptionInfo") SubscriptionInfo subscriptionInfo);
+}

src/main/java/com/ai/da/mapper/primary/SysNotificationReadStatusMapper.java

@@ -0,0 +1,7 @@
+package com.ai.da.mapper.primary;
+
+import com.ai.da.common.config.mybatis.plus.CommonMapper;
+import com.ai.da.mapper.primary.entity.SysNotificationReadStatus;
+
+public interface SysNotificationReadStatusMapper extends CommonMapper<SysNotificationReadStatus> {
+}

src/main/java/com/ai/da/mapper/primary/TDesignPythonOutfitDetailMapper.java

@@ -4,6 +4,8 @@ import com.ai.da.common.config.mybatis.plus.CommonMapper;
 import com.ai.da.mapper.primary.entity.TDesignPythonOutfitDetail;
 import com.ai.da.model.vo.TDesignPythonOutfitDetailVO;
 import com.baomidou.mybatisplus.core.metadata.IPage;
+import io.lettuce.core.dynamic.annotation.Param;
+import org.apache.ibatis.annotations.Delete;
 
 import java.util.List;
 
@@ -24,4 +26,7 @@ public interface TDesignPythonOutfitDetailMapper extends CommonMapper<TDesignPyt
      */
     List<TDesignPythonOutfitDetailVO> selectTDesignPythonOutfitDetailPage(IPage page, TDesignPythonOutfitDetailVO tDesignPythonOutfitDetail);
 
+    @Delete("DELETE FROM t_design_python_outfit_detail WHERE design_python_outfit_id = #{designPythonOutfitId}")
+    void deleteByDesignPythonOutfitIdPhysical(@Param("designPythonOutfitId") Long designPythonOutfitId);
+
 }

src/main/java/com/ai/da/mapper/primary/TagsMapper.java

@@ -0,0 +1,17 @@
+package com.ai.da.mapper.primary;
+
+import com.ai.da.common.config.mybatis.plus.CommonMapper;
+import com.ai.da.mapper.primary.entity.Tags;
+import com.ai.da.model.dto.TagsDTO;
+
+import java.util.List;
+import java.util.Map;
+
+
+public interface TagsMapper extends CommonMapper<Tags> {
+
+    List<Map<String, String>> getMatchingTags(String userInput);
+
+    List<TagsDTO> getTagByPortfolioId(Long portfolioId);
+
+}

src/main/java/com/ai/da/mapper/primary/ToProductImageResultMapper.java

@@ -3,5 +3,10 @@ package com.ai.da.mapper.primary;
 import com.ai.da.common.config.mybatis.plus.CommonMapper;
 import com.ai.da.mapper.primary.entity.ToProductImageResult;
 
+import java.util.List;
+import java.util.Map;
+
 public interface ToProductImageResultMapper extends CommonMapper<ToProductImageResult> {
+
+    List<Map<String, Object>> getByTypeAndTime(String startTime, String endTime, List<Long> accountIdList);
 }

src/main/java/com/ai/da/mapper/primary/TrialOrderMapper.java

@@ -3,6 +3,9 @@ package com.ai.da.mapper.primary;
 import com.ai.da.common.config.mybatis.plus.CommonMapper;
 import com.ai.da.mapper.primary.entity.TrialOrder;
 
+import java.util.List;
+import java.util.Map;
+
 /**
  * Mapper 接口
  *
@@ -11,6 +14,6 @@ import com.ai.da.mapper.primary.entity.TrialOrder;
  */
 public interface TrialOrderMapper extends CommonMapper<TrialOrder> {
 
-
+    Map<String, Long> countOfficialUser();
 
 }

src/main/java/com/ai/da/mapper/primary/UserFollowMapper.java

@@ -0,0 +1,19 @@
+package com.ai.da.mapper.primary;
+
+import com.ai.da.common.config.mybatis.plus.CommonMapper;
+import com.ai.da.mapper.primary.entity.UserFollow;
+import com.ai.da.model.vo.AccountFollowVO;
+
+import java.util.List;
+
+
+public interface UserFollowMapper extends CommonMapper<UserFollow> {
+    List<AccountFollowVO> getFolloweeListByFollower(Long followerAccountId, Integer limit, Integer offset, String order);
+
+    List<AccountFollowVO> getFollowerListByFollowee(Long followeeAccountId, Integer limit, Integer offset, String order);
+
+    List<AccountFollowVO> getFolloweeListByName(String name, Long followerId);
+
+    List<AccountFollowVO> getFollowerListByName(String name, Long followeeId);
+
+}

src/main/java/com/ai/da/mapper/primary/UserLikeMapper.java

@@ -3,6 +3,9 @@ package com.ai.da.mapper.primary;
 import com.ai.da.common.config.mybatis.plus.CommonMapper;
 import com.ai.da.mapper.primary.entity.UserLike;
 
+import java.util.List;
+import java.util.Map;
+
 /**
  * Mapper 接口
  *

src/main/java/com/ai/da/mapper/primary/UserLikeSortMapper.java

@@ -0,0 +1,7 @@
+package com.ai.da.mapper.primary;
+
+import com.ai.da.common.config.mybatis.plus.CommonMapper;
+import com.ai.da.mapper.primary.entity.UserLikeSort;
+
+public interface UserLikeSortMapper extends CommonMapper<UserLikeSort> {
+}

src/main/java/com/ai/da/mapper/primary/entity/Account.java

@@ -3,6 +3,8 @@ package com.ai.da.mapper.primary.entity;
 import com.baomidou.mybatisplus.annotation.IdType;
 import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.annotation.TableName;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 import lombok.experimental.Accessors;
@@ -56,6 +58,11 @@ public class Account implements Serializable {
      */
     private String country;
 
+    /**
+     * 职业
+     */
+    private String occupation;
+
     /**
      * 账户有效期开始时间
      */
@@ -69,11 +76,13 @@ public class Account implements Serializable {
     /**
      * 创建时间
      */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone="GMT+8")
     private Date createDate;
 
     /**
      * 更新时间
      */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone="GMT+8")
     private Date updateDate;
 
     private Integer isTrial;
@@ -93,6 +102,37 @@ public class Account implements Serializable {
      * 1 ： 年付用户
      * 2 ： 月付用户
      * 3 ： 试用用户
+     * 4 ： 参加活动获取30天有效期和6000个积分的用户
+     * 5 ： 企业管理员账号
+     * 6 ： 企业子账号
+     * 7 ： 学校管理员
+     * 8 ： 学校子账号
      */
     private Integer systemUser;
+
+    /**
+     * 头像
+     */
+    private String avatar;
+
+    private String organizationName;
+
+    private Long parentId;
+
+    private Integer isAdmin;
+
+    private BigDecimal shareCredits;
+
+    private Integer subAccountNum;
+
+    private String invitationCode;
+
+    @ApiModelProperty("title")
+    private String title;
+
+    @ApiModelProperty("surname")
+    private String surname;
+
+    @ApiModelProperty("givenName")
+    private String givenName;
 }

src/main/java/com/ai/da/mapper/primary/entity/AccountExtend.java

@@ -0,0 +1,35 @@
+package com.ai.da.mapper.primary.entity;
+
+import com.ai.da.common.response.PageResponse;
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@TableName("account_extend")
+public class AccountExtend implements Serializable {
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * ID
+     */
+    @TableId(value = "id", type = IdType.AUTO)
+    private Long id;
+
+    private Long accountId;
+
+    private String authType;
+
+    private String headImgUrl;
+
+    private String name;
+
+    private String auth;
+}

src/main/java/com/ai/da/mapper/primary/entity/Affiliate.java

@@ -0,0 +1,32 @@
+package com.ai.da.mapper.primary.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+@EqualsAndHashCode(callSuper = true)
+@Data
+@TableName("t_affiliate")
+public class Affiliate extends BaseEntity{
+
+    private Long accountId;
+
+    // Active（活跃） || Inactive（过期） || Pending（待审批） || Refused(拒绝)
+    private String status;
+
+    private Float commissionPercent;
+
+    private Float totalEarnings = 0.00F;
+
+    private Float monthlyEarnings = 0.00F;
+
+    private Float unpaidEarnings = 0.00F;
+
+    private Integer visits = 0;
+
+    private Boolean approved = false;
+
+    private String link;
+
+    private String promotionMethod;
+}

src/main/java/com/ai/da/mapper/primary/entity/AffiliateIncome.java

@@ -0,0 +1,28 @@
+package com.ai.da.mapper.primary.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.time.LocalDateTime;
+
+@EqualsAndHashCode(callSuper = true)
+@Data
+@TableName("t_affiliate_income")
+public class AffiliateIncome extends BaseEntity {
+
+    private Long affiliateId;
+
+    private Long affiliateAccountId;
+
+    private Long inviteeAccountId;
+
+    private Float amount;
+
+    private Long paymentInfoId;
+
+    private LocalDateTime paymentTime;
+
+    private Float commission;
+
+}

src/main/java/com/ai/da/mapper/primary/entity/Collection.java

@@ -40,6 +40,8 @@ public class Collection implements Serializable {
      */
     private String moodTemplateId;
 
+    private String moodboardPosition;
+
     /**
      * 创建时间
      */

src/main/java/com/ai/da/mapper/primary/entity/DesignBatch.java

@@ -0,0 +1,44 @@
+package com.ai.da.mapper.primary.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import io.swagger.models.auth.In;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@TableName("design_batch")
+public class DesignBatch implements Serializable {
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * ID
+     */
+    @TableId(value = "id", type = IdType.AUTO)
+    private Long id;
+
+    private Long accountId; // account_id
+
+    private Long designId; // design_id
+
+    private Long collectionId; // collection_id
+
+    private Integer status; // status
+
+    private LocalDateTime createTime; // create_time
+
+    private LocalDateTime updateTime; // update_time
+
+    private String taskId; // task_id
+
+    private Integer totalNum; // total_num
+
+    private Integer completedNum; // completed_num
+}

src/main/java/com/ai/da/mapper/primary/entity/DesignItemDetailPrint.java

@@ -41,7 +41,7 @@ public class DesignItemDetailPrint {
     /**
      * 印花缩放比例
      */
-    private Double scale;
+    private String scale;
     /**
      * 印花旋转角度
      */

src/main/java/com/ai/da/mapper/primary/entity/Generate.java

@@ -72,6 +72,19 @@ public class Generate {
      */
     private String seed;
 
+    /**
+     * 1 -> 粗
+     * 2 -> 中
+     * 3 -> 细
+     * custom -> 自定义
+     */
+    private String sketchStyle;
+
+    /**
+     * sketch 风格参考图的collection_element_id
+     */
+    private Long styleImageElementId;
+
     /**
      * 创建时间
      */

src/main/java/com/ai/da/mapper/primary/entity/GoogleUser.java

@@ -0,0 +1,14 @@
+package com.ai.da.mapper.primary.entity;
+
+import lombok.Data;
+
+@Data
+public class GoogleUser {
+    private String sub;  // 用户唯一标识
+    private String email;
+    private String name;
+    private String picture;
+    private boolean emailVerified;
+    private String givenName;
+    private String familyName;
+}

src/main/java/com/ai/da/mapper/primary/entity/Library.java

@@ -80,4 +80,18 @@ public class Library implements Serializable {
     private Date updateDate;
 
 //    private Integer isCopy;
+
+
+    public Library() {
+    }
+
+    public Library(Long accountId, String level1Type, String level2Type, String level3Type, String url, String md5, Date createDate) {
+        this.accountId = accountId;
+        this.level1Type = level1Type;
+        this.level2Type = level2Type;
+        this.level3Type = level3Type;
+        this.url = url;
+        this.md5 = md5;
+        this.createDate = createDate;
+    }
 }

src/main/java/com/ai/da/mapper/primary/entity/MoodboardPosition.java

@@ -0,0 +1,29 @@
+package com.ai.da.mapper.primary.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@TableName("moodboard_position")
+public class MoodboardPosition implements Serializable {
+    private static final long serialVersionUID = 1L;
+    @TableId(value = "id", type = IdType.AUTO)
+    private Long id;
+    private Long moodboardId;
+    private Long collectionId;
+    private String type;
+    private String styleData;
+    private Integer sequence;
+    private LocalDateTime createTime;
+    private LocalDateTime updateTime;
+
+}

src/main/java/com/ai/da/mapper/primary/entity/Notification.java

@@ -0,0 +1,73 @@
+package com.ai.da.mapper.primary.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+@EqualsAndHashCode(callSuper = true)
+@TableName("t_notification")
+@Data
+public class Notification extends BaseEntity{
+    /**
+     * 操作类型 system/like/comment/follow
+     */
+    private String type;
+    /**
+     * 发起操作者用户id
+     */
+    private Long senderId;
+    /**
+     * 被操作对象用户id
+     */
+    private Long receiverId;
+    /**
+     * 点赞评论时的作品id
+     */
+    private Long portfolioId;
+    /**
+     * 消息内容
+     */
+    private String content;
+    /**
+     * 评论id
+     */
+    private Long commentId;
+    /**
+     * 个人消息已读状态
+     */
+    private Integer isRead;
+    /**
+     * 系统消息发布状态
+     */
+    private Integer publishFlag;
+
+    /**
+     * 是否被删除
+     */
+    private Integer isDeleted;
+
+    public Notification() {
+    }
+
+    public Notification(String type, Long senderId, Long receiverId) {
+        this.type = type;
+        this.senderId = senderId;
+        this.receiverId = receiverId;
+    }
+
+    public Notification(String type, Long senderId, Long receiverId, Long portfolioId) {
+        this.type = type;
+        this.senderId = senderId;
+        this.receiverId = receiverId;
+        this.portfolioId = portfolioId;
+    }
+
+    public Notification(String type, Long senderId, Long receiverId, Long portfolioId, String content, Long commentId) {
+        this.type = type;
+        this.senderId = senderId;
+        this.receiverId = receiverId;
+        this.portfolioId = portfolioId;
+        this.content = content;
+        this.commentId = commentId;
+    }
+}

src/main/java/com/ai/da/mapper/primary/entity/OrderInfo.java

@@ -21,5 +21,20 @@ public class OrderInfo  extends BaseEntity{
 
     private String orderStatus;//订单状态
 
+    private String note;
+
+    private byte autoRenewal;
+
     private String paymentType;//支付方式
+
+    // 可用于标记用户订单是否首次订阅
+    private byte isFirstSubscription = 0;
+
+    private byte isCommissionCalculated = 0;
+
+    private String ipAddress;
+
+    private String country;
+
+    private String city;
 }

src/main/java/com/ai/da/mapper/primary/entity/PaymentInfo.java

@@ -2,7 +2,9 @@ package com.ai.da.mapper.primary.entity;
 
 import com.baomidou.mybatisplus.annotation.TableName;
 import lombok.Data;
+import lombok.EqualsAndHashCode;
 
+@EqualsAndHashCode(callSuper = true)
 @Data
 @TableName("t_payment_info")
 public class PaymentInfo extends BaseEntity{
@@ -13,11 +15,38 @@ public class PaymentInfo extends BaseEntity{
 
     private String paymentType;//支付类型
 
-    private String tradeType;//交易类型
-
+    /**
+     * PayPal 订单状态：CREATED/SAVED/APPROVED/VOIDED/COMPLETED/PAYER_ACTION_REQUIRED
+     * Stripe 订单状态： 原 session 状态：open/completed/expired ; 现 invoice 状态：draft/open/paid/uncollectible/void
+     * Alipay-HK 订单状态：wait, paid, expired, liquidated
+     *  paid and liquidated means the refund request has been executed.
+     *  expired means the request has been rejected.
+     *  wait means the request is still under processing.
+     */
     private String tradeState;//交易状态
 
     private Float payerTotal;//支付金额(元)
 
     private String content;//通知参数
+
+    // 支付类型  new || renewal || credits
+    private String type;
+
+    // 当前支付是否已邮件通知  0 || 1
+    private Integer notified;
+
+    private String paymentMethod;
+
+    private String last4;
+
+    // 发票托管页面
+    private String hostedInvoiceUrl;
+
+    private String ipAddress;
+
+    private String country;
+
+    private String city;
+
+    private String promotionCode;
 }

src/main/java/com/ai/da/mapper/primary/entity/PortfolioTags.java

@@ -0,0 +1,14 @@
+package com.ai.da.mapper.primary.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+@EqualsAndHashCode(callSuper = true)
+@TableName("t_portfolio_tags")
+@Data
+public class PortfolioTags extends BaseEntity{
+    private Long portfolioId;
+
+    private Long tagId;
+}

src/main/java/com/ai/da/mapper/primary/entity/ProductCoupons.java

@@ -0,0 +1,60 @@
+package com.ai.da.mapper.primary.entity;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableLogic;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.NoArgsConstructor;
+
+import java.math.BigDecimal;
+
+@EqualsAndHashCode(callSuper = true)
+@Data
+@TableName("t_product_coupons")
+@NoArgsConstructor
+public class ProductCoupons extends BaseEntity{
+    // 优惠券id
+    private String couponId;
+    // 优惠券有效期的截止日期
+    private Long redeemBy;
+    // 绑定的推广码id
+    private String promotionCodeId;
+    // 对应的推广码
+    private String promotionCode;
+    // 优惠券有效期开始时间
+    private Long startTime;
+    // 最大兑换次数
+    private Long maxRedemptions;
+    // 优惠券的折扣
+    private float percentOff;
+    // 佣金比例
+    private float commissionRate;
+    // 合作者
+    private String cooperator;
+    // 使用了该优惠券支付的总金额
+    private BigDecimal  totalEarnings = BigDecimal.ZERO;
+    // 佣金
+    private BigDecimal commission = BigDecimal.ZERO;
+    // 已付佣金
+    private BigDecimal  paidCommission = BigDecimal.ZERO;
+    // 未付佣金
+    private BigDecimal  unpaidCommission = BigDecimal.ZERO;
+    // 备注
+    private String remark;
+
+    @TableLogic
+    private Integer isDeleted;
+
+    public ProductCoupons(String couponId, Long redeemBy, String promotionCodeId, String promotionCode, Long maxRedemptions, float percentOff, float commissionRate, String cooperator, String remark) {
+        this.couponId = couponId;
+        this.redeemBy = redeemBy;
+        this.promotionCodeId = promotionCodeId;
+        this.promotionCode = promotionCode;
+        this.maxRedemptions = maxRedemptions;
+        this.percentOff = percentOff;
+        this.cooperator = cooperator;
+        this.remark = remark;
+        this.commissionRate = commissionRate;
+    }
+}

src/main/java/com/ai/da/mapper/primary/entity/ProductImageAttribute.java

@@ -0,0 +1,35 @@
+package com.ai.da.mapper.primary.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@TableName("product_image_attribute")
+public class ProductImageAttribute implements Serializable {
+    private static final long serialVersionUID = 1L;
+
+    @TableId(value = "id", type = IdType.AUTO)
+    private Long id;
+    private String imgName;
+    private String length;
+    private String sleeveLength;
+    private String sleeveShape;
+    private String sleeveShoulder;
+    private String neckline;
+    private String collar;
+    private String design;
+    private String silhouette;
+    private String type;
+    private String openingType;
+    private String subtype;
+
+    private String style;
+}

src/main/java/com/ai/da/mapper/primary/entity/SubscriptionInfo.java

@@ -0,0 +1,39 @@
+package com.ai.da.mapper.primary.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+@EqualsAndHashCode(callSuper = true)
+@Data
+@TableName("t_subscription_info")
+public class SubscriptionInfo extends BaseEntity{
+
+    private Long accountId;
+
+    private String orderNo;
+
+    // stripe || paypal 平台生成的id
+    private String subscriptionId;
+
+    // month || year
+    private String type;
+
+    // active || canceled
+    private String status = "active";
+
+    private byte cancelNotified = (byte)0;
+
+    // 续订的下一个付款日
+    private String nextPayDate;
+
+    // 当前订阅订单有效期开始时间
+    private Long currentPeriodStart;
+
+    // 当前订阅订单有效期结束时间
+    private Long currentPeriodEnd;
+
+    // 取消订阅原因
+    private String cancelReason;
+
+}

src/main/java/com/ai/da/mapper/primary/entity/SysNotificationReadStatus.java

@@ -0,0 +1,26 @@
+package com.ai.da.mapper.primary.entity;
+
+import com.baomidou.mybatisplus.annotation.FieldStrategy;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.NoArgsConstructor;
+
+@EqualsAndHashCode(callSuper = true)
+@TableName("t_sys_notification_read_status")
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+public class SysNotificationReadStatus extends BaseEntity{
+    /**
+     * 系统消息id
+     */
+    private Long system_notification_id;
+
+    /**
+     * 已读当前消息的用户id将被存储
+     */
+    private Long account_id;
+}

src/main/java/com/ai/da/mapper/primary/entity/Tags.java

@@ -0,0 +1,16 @@
+package com.ai.da.mapper.primary.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+@EqualsAndHashCode(callSuper = true)
+@TableName("t_tags")
+@Data
+public class Tags extends BaseEntity{
+
+    private String tagName;
+
+    // 表示标签是否正在活动中 0->不在活动中 1->在活动中
+    private byte active = (byte)0;
+}

src/main/java/com/ai/da/mapper/primary/entity/ToProductImageResult.java

@@ -6,6 +6,7 @@ import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
 
 import java.io.Serializable;
+import java.math.BigDecimal;
 import java.time.LocalDateTime;
 
 @Data
@@ -42,4 +43,10 @@ public class ToProductImageResult implements Serializable {
 
     @ApiModelProperty(value = "generate 结果类型")
     private String resultType;
+
+    private Double brightenValue;
+
+    private BigDecimal imageStrength;
+
+    private String direction;
 }

src/main/java/com/ai/da/mapper/primary/entity/TrialOrder.java

@@ -3,6 +3,7 @@ package com.ai.da.mapper.primary.entity;
 import com.baomidou.mybatisplus.annotation.IdType;
 import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.annotation.TableName;
+import com.fasterxml.jackson.annotation.JsonFormat;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
@@ -49,11 +50,13 @@ public class TrialOrder implements Serializable {
     /**
      * 创建时间
      */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone="GMT+8")
     private LocalDateTime createTime;
 
     /**
      * 更新时间
      */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone="GMT+8")
     private LocalDateTime updateTime;
 
 

src/main/java/com/ai/da/mapper/primary/entity/UserFollow.java

@@ -0,0 +1,26 @@
+package com.ai.da.mapper.primary.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.NoArgsConstructor;
+
+@EqualsAndHashCode(callSuper = true)
+@TableName("t_user_follow")
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class UserFollow extends BaseEntity{
+
+    /**
+     * 被关注者用户id
+     */
+    private Long followeeId;
+    /**
+     * 关注者用户id
+     */
+    private Long followerId;
+
+
+}

src/main/java/com/ai/da/mapper/primary/entity/UserLike.java

@@ -59,4 +59,9 @@ public class UserLike implements Serializable {
      * 更新时间
      */
     private Date updateDate;
+
+    /**
+     * design对应的mask是否已替换为最新的
+     */
+    private Integer converted;
 }

src/main/java/com/ai/da/mapper/primary/entity/UserLikeSort.java

@@ -0,0 +1,24 @@
+package com.ai.da.mapper.primary.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+import java.util.Date;
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@TableName("user_like_sort")
+public class UserLikeSort implements Serializable {
+    private static final long serialVersionUID = 1L;
+
+    @TableId(value = "id", type = IdType.AUTO)
+    private Long id;
+    private Long userLikeGroupId;
+    private Long userLikeId;
+    private Integer sort;
+}