BUGFIX:印花优先级不从1开始传导致数组越界

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

@@ -13,8 +13,9 @@ 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;
+    // 单位 秒 7天过期 （todo 测试状态下 3小时过期）
+//    public static final Long REDIS_SET_EXPIRE_TIME = 24 * 60 * 60 * 7L;
+    public static final Long REDIS_SET_EXPIRE_TIME = 3 * 60 * 60L;
 
     public static class Numbers{
         public static final Integer NUMBER_10 =  10;

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

@@ -18,8 +18,8 @@ public class ModelConstants {
 
     // 模型名称常量
     public static final String PRINTBOARD_ADVANCED_T2I = "qwen-image";
-    public static final String MOODBOARD_ADVANCED = "doubao-seedream-3-0-t2i-250415";
-    public static final String PRINTBOARD_HIGH_T2I = "doubao-seedream-3-0-t2i-250415";
+    public static final String MOODBOARD_ADVANCED = "doubao-seedream-4-5-251128";
+    public static final String PRINTBOARD_HIGH_T2I = "doubao-seedream-4-0-250828-high";
     public static final String PRINTBOARD_HIGH_I2I = "doubao-seedream-4-0-250828-fast";
     public static final String PRINTBOARD_ADVANCED_I2I = "doubao-seedream-4-0-250828";
     public static final String IMAGEN_MODEL = "imagen-4.0-generate-001";

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

@@ -17,17 +17,38 @@ import com.tencentcloudapi.ses.v20201002.models.SendEmailRequest;
 import com.tencentcloudapi.ses.v20201002.models.SendEmailResponse;
 import com.tencentcloudapi.ses.v20201002.models.Template;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
 import org.springframework.util.StringUtils;
 
+import jakarta.annotation.PostConstruct;
+
+import java.util.ArrayList;
 import java.util.Base64;
 import java.util.Date;
+import java.util.List;
 import java.util.Objects;
 
 /**
  * 邮件发送类
  */
 @Slf4j
+@Component
 public class SendEmailUtil {
+    @Value("${merchant.email:}")
+    private String merchantEmailInstance;
+    @Value("${developer.email: xupei@code-create.com.hk}")
+    private String developerEmailInstance;
+
+    private static String merchantEmail;
+    private static String developerEmail;
+
+    @PostConstruct
+    public void init() {
+        merchantEmail = merchantEmailInstance;
+        developerEmail = developerEmailInstance;
+    }
+
     /**
      * 秘钥id
      */
@@ -765,9 +786,7 @@ public class SendEmailUtil {
 
     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};
+            String[] receiverEmail = buildMerchantReceiverEmail();
             Credential cred = new Credential(SECRET_ID, SECRET_KEy);
             // 实例化一个http选项，可选的，没有特殊需求可以跳过
             HttpProfile httpProfile = new HttpProfile();
@@ -966,9 +985,7 @@ public class SendEmailUtil {
             // 实例化一个请求对象,每个接口都会对应一个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});
+            req.setDestination(buildMerchantReceiverEmail());
             Template template = new Template();
             req.setSubject("New Credit Purchase Order");
             template.setTemplateID(CREDITS_PURCHASE_MERCHANT);
@@ -1076,4 +1093,25 @@ public class SendEmailUtil {
 
     }
 
+    public static String[] buildMerchantReceiverEmail() {
+        List<String> emails = new ArrayList<>();
+        if (!StringUtils.isEmpty(merchantEmail)) {
+            for (String e : merchantEmail.split(",")) {
+                String trimmed = e.trim();
+                if (!trimmed.isEmpty()) {
+                    emails.add(trimmed);
+                }
+            }
+        }
+        if (!StringUtils.isEmpty(developerEmail)) {
+            for (String e : developerEmail.split(",")) {
+                String trimmed = e.trim();
+                if (!trimmed.isEmpty()) {
+                    emails.add(trimmed);
+                }
+            }
+        }
+        return emails.toArray(new String[0]);
+    }
+
 }

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

@@ -5,6 +5,7 @@ import com.ai.da.model.dto.*;
 import com.ai.da.model.dto.ContestantDTO;
 import com.ai.da.model.vo.CheckOTPVO;
 import com.ai.da.model.vo.ContestantCountVO;
+import com.ai.da.model.vo.PageVisitCountVO;
 import com.ai.da.service.GlobalAwardService;
 import com.ai.da.service.upload.UploadService;
 import com.ai.da.service.upload.UploadTask;
@@ -198,6 +199,19 @@ public class GlobalAwardController {
         return Response.success(globalAwardService.getContestantCount());
     }
 
+    @PostMapping("/page/visit")
+    @ApiOperation(value = "记录比赛页面访问量", notes = "记录比赛页面的访问量，包含两种统计方式：每次访问/刷新计一次，以及5秒内刷新只计一次")
+    public Response<Void> recordPageVisit(@ApiParam(value = "会话ID，用于5秒内去重判断", required = false) @RequestParam(value = "sessionId", required = false) String sessionId) {
+        globalAwardService.recordPageVisit(sessionId);
+        return Response.success();
+    }
+
+    @GetMapping("/page/visit/count")
+    @ApiOperation(value = "获取比赛页面访问量", notes = "获取比赛页面的两种访问量：rawVisitCount（每次访问/刷新计一次）和 uniqueVisitCount（5秒内刷新只计一次）")
+    public Response<PageVisitCountVO> getPageVisitCount() {
+        return Response.success(globalAwardService.getPageVisitCount());
+    }
+
 }
 
 

src/main/java/com/ai/da/model/vo/PageVisitCountVO.java

@@ -0,0 +1,23 @@
+package com.ai.da.model.vo;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class PageVisitCountVO {
+
+    /**
+     * 每次访问或刷新都计一次（不去重）
+     */
+    private Long rawVisitCount;
+
+    /**
+     * 5秒内刷新只算一次（去重后的真实访客数）
+     */
+    private Long uniqueVisitCount;
+}

src/main/java/com/ai/da/python/PythonService.java

@@ -2912,72 +2912,71 @@ public class PythonService {
 
     private PrintToPython resolveDesignSinglePrint(List<DesignSinglePrint> printObject, String partialDesign) {
         PrintToPython printToPython = new PrintToPython();
-//        DesignPythonItemPrint printSingle = new DesignPythonItemPrint();
         DesignPythonItemPrint printOverall = new DesignPythonItemPrint();
-//        printToPython.setSingle(printSingle);
         printToPython.setOverall(printOverall);
         printToPython.setPartial(StringUtil.isNullOrEmpty(partialDesign) ? null : partialDesign);
         if (Objects.isNull(printObject) || printObject.isEmpty()) {
             return printToPython;
         }
 
-        // 没有印花时的参数设置
-//        if (printObject.getIfSingle().equals(Boolean.FALSE) && CollectionUtil.isEmpty(printObject.getPrints())) {
-//            return new DesignPythonItemPrint(new ArrayList<>(), false);
-//        }
-//        DesignPythonItemPrint print = CopyUtil.copyObject(printObject, DesignPythonItemPrint.class);
+        // 1. 先对 printObject 按 priority 排序（升序）
+        List<DesignSinglePrint> sortedPrints = printObject.stream()
+                .sorted(Comparator.comparingInt(DesignSinglePrint::getPriority))
+                .toList();
 
-        int size = printObject.size();
-        // 占位符填充数组
-        List<List<Float>> locationS = new ArrayList<>(Collections.nCopies(size, null));
-        List<List<Float>> scaleS = new ArrayList<>(Collections.nCopies(size, null));
-        List<Double> angleS = new ArrayList<>(Collections.nCopies(size, null));
-        ArrayList<String> pathsS = new ArrayList<>(Collections.nCopies(size, null));
+        // 2. 分别收集单印和非单印的数据
+        List<DesignSinglePrint> singlePrints = sortedPrints.stream()
+                .filter(DesignSinglePrint::getIfSingle)
+                .toList();
 
-        List<List<Float>> locationO = new ArrayList<>(Collections.nCopies(size, null));
-        List<List<Float>> scaleO = new ArrayList<>(Collections.nCopies(size, null));
-        List<Double> angleO = new ArrayList<>(Collections.nCopies(size, null));
-        ArrayList<String> pathsO = new ArrayList<>(Collections.nCopies(size, null));
+        List<DesignSinglePrint> overallPrints = sortedPrints.stream()
+                .filter(p -> !p.getIfSingle())
+                .toList();
 
-        // 设置印花的位置、大小、旋转角度
-        // 优先级越大，越靠近顶层，在传输给python的数组中，越靠前
-//        List<DesignSinglePrint> prints = printObject.getPrints();
-        printObject.forEach(p -> {
-            p.getLocation().set(0, p.getLocation().get(0));
-            p.getLocation().set(1, p.getLocation().get(1));
-            Integer priority = p.getPriority();
-            setUriToMinioPath(p);
-            // todo 下标越界问题
-            if (p.getIfSingle()) {
-                locationS.set(priority - 1, p.getLocation());
-                scaleS.set(priority - 1, p.getScale());
-                angleS.set(priority - 1, p.getAngle());
-                pathsS.set(priority - 1, p.getMinIOPath());
-            } else {
-                locationO.set(priority - 1, p.getLocation());
-                scaleO.set(priority - 1, p.getScale());
-                angleO.set(priority - 1, p.getAngle());
-                pathsO.set(priority - 1, p.getMinIOPath());
+        // 3. 处理单印数据
+        if (!singlePrints.isEmpty()) {
+            List<List<Float>> locationS = new ArrayList<>();
+            List<List<Float>> scaleS = new ArrayList<>();
+            List<Double> angleS = new ArrayList<>();
+            List<String> pathsS = new ArrayList<>();
+
+            for (DesignSinglePrint p : singlePrints) {
+                setUriToMinioPath(p);
+                locationS.add(p.getLocation());
+                scaleS.add(p.getScale());
+                angleS.add(p.getAngle());
+                pathsS.add(p.getMinIOPath());
             }
-//            log.info("本次print打点locations###{}###fileVO{}", p.getLocation(), JSON.toJSONString(fileVO));
-        });
-        /*locationS.removeAll(Collections.singleton(null));
-        scaleS.removeAll(Collections.singleton(null));
-        angleS.removeAll(Collections.singleton(null));
-        pathsS.removeAll(Collections.singleton(null));
-        printSingle.setLocation(locationS);
-        printSingle.setPrint_scale_list(scaleS);
-        printSingle.setPrint_angle_list(angleS);
-        printSingle.setPrint_path_list(pathsS);*/
 
-        locationO.removeAll(Collections.singleton(null));
-        scaleO.removeAll(Collections.singleton(null));
-        angleO.removeAll(Collections.singleton(null));
-        pathsO.removeAll(Collections.singleton(null));
-        printOverall.setLocation(locationO);
-        printOverall.setPrint_scale_list(scaleO);
-        printOverall.setPrint_angle_list(angleO);
-        printOverall.setPrint_path_list(pathsO);
+            // 注意：如果 printOverall 中需要设置单印数据，请在这里添加相应的 setter
+            // 根据您的原始代码，似乎只设置了 overall（非单印）的数据
+            // 如果需要设置单印，请取消下面的注释并添加对应的字段
+            // printOverall.setSingleLocation(locationS);
+            // printOverall.setSingleScale(scaleS);
+            // printOverall.setSingleAngle(angleS);
+            // printOverall.setSinglePath(pathsS);
+        }
+
+        // 4. 处理非单印数据（整体印花）
+        if (!overallPrints.isEmpty()) {
+            List<List<Float>> locationO = new ArrayList<>();
+            List<List<Float>> scaleO = new ArrayList<>();
+            List<Double> angleO = new ArrayList<>();
+            List<String> pathsO = new ArrayList<>();
+
+            for (DesignSinglePrint p : overallPrints) {
+                setUriToMinioPath(p);
+                locationO.add(p.getLocation());
+                scaleO.add(p.getScale());
+                angleO.add(p.getAngle());
+                pathsO.add(p.getMinIOPath());
+            }
+
+            printOverall.setLocation(locationO);
+            printOverall.setPrint_scale_list(scaleO);
+            printOverall.setPrint_angle_list(angleO);
+            printOverall.setPrint_path_list(pathsO);
+        }
 
         return printToPython;
     }

src/main/java/com/ai/da/service/GlobalAwardService.java

@@ -3,6 +3,7 @@ package com.ai.da.service;
 import com.ai.da.model.dto.ContestantDTO;
 import com.ai.da.model.vo.CheckOTPVO;
 import com.ai.da.model.vo.ContestantCountVO;
+import com.ai.da.model.vo.PageVisitCountVO;
 import org.springframework.web.multipart.MultipartFile;
 
 import java.util.Map;
@@ -46,6 +47,22 @@ public interface GlobalAwardService {
      * @return 参赛者数量和最大参赛者编号
      */
     ContestantCountVO getContestantCount();
+
+    /**
+     * 记录比赛页面的访问量
+     * <ul>
+     *   <li>rawVisitCount: 每次访问或刷新都计一次（不去重）</li>
+     *   <li>uniqueVisitCount: 5秒内刷新只算一次（基于会话去重）</li>
+     * </ul>
+     * @param sessionId 会话ID（用于5秒去重判断）
+     */
+    void recordPageVisit(String sessionId);
+
+    /**
+     * 获取比赛页面的两种访问量
+     * @return 原始访问量和去重访问量
+     */
+    PageVisitCountVO getPageVisitCount();
 }
 
 

src/main/java/com/ai/da/service/impl/AccountServiceImpl.java

@@ -3383,12 +3383,14 @@ public class AccountServiceImpl extends ServiceImpl<AccountMapper, Account> impl
         Account account = accountMapper.selectById(accountId);
         if (!Objects.isNull(account.getValidEndTime())
                 && account.getValidEndTime().equals(currentPeriodEnd * 1000)) {
+            log.info("accountId:{}未更新账号有效期。current validEnd:{}, new validEnd:{}", accountId, account.getValidEndTime(), currentPeriodEnd);
             return false;
         } else {
             account.setValidEndTime(currentPeriodEnd * 1000);
             accountMapper.updateById(account);
+            log.info("accountId:{} 将账号有效期更新到 {}", accountId, currentPeriodEnd);
+            return true;
         }
-        return true;
     }
 
     @Override
@@ -3416,13 +3418,14 @@ public class AccountServiceImpl extends ServiceImpl<AccountMapper, Account> impl
             }
             account.setCredits(BigDecimal.valueOf(productCredits));
             accountMapper.updateById(account);
+            log.info("accountId:{},更新用户角色为{}，总积分为{}",  accountId, account.getSystemUser(), productCredits);
 
             CreditsService creditsService = SpringUtils.getBean(CreditsService.class);
-            // 添加积分变更记录(订单续订时的积分变更也需要记录) todo 重置的记录不太准确
+            // 添加积分变更记录(订单续订时的积分变更也需要记录)
             creditsService.insertToCreditsDetail(accountId,
                     description + "--Stripe",
                     String.valueOf(productCredits),
-                    "positive", orderNo);
+                    "set", orderNo);
             /*CreditsDetail creditsDetail = creditsService.queryDetailByTaskId(orderNo);
             if (Objects.isNull(creditsDetail)) {
                 creditsService.insertToCreditsDetail(accountId,

src/main/java/com/ai/da/service/impl/AffiliateServiceImpl.java

@@ -34,7 +34,6 @@ import jakarta.annotation.Resource;
 import java.math.BigDecimal;
 import java.math.RoundingMode;
 import java.time.LocalDateTime;
-import java.util.*;
 import java.time.format.DateTimeFormatter;
 import java.util.*;
 import java.util.function.Function;
@@ -80,9 +79,7 @@ public class AffiliateServiceImpl extends ServiceImpl<AffiliateMapper, Affiliate
             affiliate.setPromotionMethod(promotionMethod);
             baseMapper.insert(affiliate);
             // 邮件通知审批者
-            String merchantEmail = "kimwong@code-create.com.hk";
-            String developer = "xupei3360@163.com";
-            String[] receiverEmail = {/*merchantEmail,*/ developer};
+            String[] receiverEmail = buildMerchantReceiverEmail();
             SendEmailUtil.affiliateEmailReminder(receiverEmail, new AffiliateEmailParamsDTO(userHolder.getUsername(), promotionMethod), "new");
 //            emailService.affiliateEmailReminder(Arrays.asList(/*merchantEmail,*/ developer), new AffiliateEmailParamsDTO(userHolder.getUsername(), promotionMethod), "new");
         }else {
@@ -440,9 +437,7 @@ public class AffiliateServiceImpl extends ServiceImpl<AffiliateMapper, Affiliate
         affiliateEmailParamsDTO.setUnpaidEarnings(String.valueOf(unpaidCommission));
         affiliateEmailParamsDTO.setPaidEarnings(String.valueOf(paidCommission));
 
-        String merchantEmail = "kimwong@code-create.com.hk";
-        String developer = "xupei3360@163.com";
-        String[] receiverEmail = {/*merchantEmail,*/ developer};
+        String[] receiverEmail = buildMerchantReceiverEmail();
         // 邮件通知
         SendEmailUtil.affiliateEmailReminder(receiverEmail, affiliateEmailParamsDTO, "summary");
 //        emailService.affiliateEmailReminder(Arrays.asList(/*merchantEmail,*/ developer), affiliateEmailParamsDTO, "summary");
@@ -607,4 +602,8 @@ public class AffiliateServiceImpl extends ServiceImpl<AffiliateMapper, Affiliate
         coupon.setUnpaidCommission(unpaidCommission);
     }
 
+    private String[] buildMerchantReceiverEmail() {
+        return SendEmailUtil.buildMerchantReceiverEmail();
+    }
+
 }

src/main/java/com/ai/da/service/impl/CreditsServiceImpl.java

@@ -83,7 +83,7 @@ public class CreditsServiceImpl extends ServiceImpl<CreditsDetailMapper, Credits
      *
      * @param changeEvent 导致积分变更的事件
      * @param credits     变更的积分
-     * @param changeType  变更类型 ： positive->增  negative->减
+     * @param changeType  变更类型 ： positive->增  negative->减  set->重置
      */
     @Override
     public void insertToCreditsDetail(Long accountId, String changeEvent, String credits, String changeType, String orderNo) {
@@ -94,9 +94,11 @@ public class CreditsServiceImpl extends ServiceImpl<CreditsDetailMapper, Credits
         if ("positive".equals(changeType)) {
 //            finalCredits = account.getCredits().add(new BigDecimal(credits));
             changeCredits = "+" + credits;
-        } else {
+        } else if ("negative".equals(changeType)) {
 //            finalCredits = account.getCredits().subtract(new BigDecimal(credits));
             changeCredits = "-" + credits;
+        } else {
+            changeCredits = credits;
         }
         creditsDetail.setAccountId(accountId);
         creditsDetail.setChangeEvent(changeEvent);
@@ -107,6 +109,7 @@ public class CreditsServiceImpl extends ServiceImpl<CreditsDetailMapper, Credits
         creditsDetail.setCreateTime(LocalDateTime.now());
 
         baseMapper.insert(creditsDetail);
+        log.info("creditsDetail inserted");
     }
 
     @Override

src/main/java/com/ai/da/service/impl/EmailServiceImpl.java

@@ -7,6 +7,7 @@ import com.ai.da.common.response.ResultEnum;
 import com.ai.da.common.utils.DateUtil;
 import com.ai.da.common.utils.MailUtil;
 import com.ai.da.common.utils.RedisUtil;
+import com.ai.da.common.utils.SendEmailUtil;
 import com.ai.da.mapper.primary.AccountMapper;
 import com.ai.da.mapper.primary.EmailLogMapper;
 import com.ai.da.mapper.primary.EmailTemplateMapper;
@@ -585,9 +586,7 @@ public class EmailServiceImpl implements EmailService {
 
     public boolean subscriptionEmailReminder(String type, SubscriptionEmailParamsDTO subscriptionEmailParamsDTO, String language, String receiverAddress) {
         try {
-            String merchantEmail = "kimwong@code-create.com.hk";
-            String developer = "xupei3360@163.com";
-            List<String> merchantReceiver = Arrays.asList(/*merchantEmail,*/ developer);
+            List<String> merchantReceiver = buildMerchantReceiverList();
 
             String merchantSubject = null;
             String merchantTemplate = null;
@@ -723,15 +722,13 @@ public class EmailServiceImpl implements EmailService {
 
     private final static String CREDITS_PURCHASE_MERCHANT = "133275_AiDA 积分购买通知-merchant.html";
     public void creditsPurchaseReminder(String username, String quantity, String amount) {
-        String merchantEmail = "kimwong@code-create.com.hk";
-        String developerEmail = "xupei@code-create.com.hk";
         JSONObject jsonObject = new JSONObject();
         // 设置试用订单相关数据
         jsonObject.put("username", username);
         jsonObject.put("quantity", quantity);
         jsonObject.put("totalFee", amount);
 
-        sendEmail(Arrays.asList(/*merchantEmail,*/ developerEmail), jsonObject, CREDITS_PURCHASE_MERCHANT, "New Credit Purchase Order", null, null);
+        sendEmail(buildMerchantReceiverList(), jsonObject, CREDITS_PURCHASE_MERCHANT, "New Credit Purchase Order", null, null);
     }
 
     private final static String COMMON_EXCEPTION_REMINDER = "135279_common-exception-reminder.html";
@@ -742,6 +739,10 @@ public class EmailServiceImpl implements EmailService {
 
         sendEmail(destination, param, COMMON_EXCEPTION_REMINDER, "AiDA发生异常，请及时处理", null, null);
     }
+
+    private List<String> buildMerchantReceiverList() {
+        return Arrays.asList(SendEmailUtil.buildMerchantReceiverEmail());
+    }
 }
 
 

src/main/java/com/ai/da/service/impl/GenerateServiceImpl.java

@@ -1553,11 +1553,11 @@ public class GenerateServiceImpl extends ServiceImpl<GenerateMapper, Generate> i
                 if (imagePath != null) {
                     requestBuilder.image(finalImagePath1);
                 }
-                if (useModel.equals(ModelConstants.PRINTBOARD_HIGH_I2I)) {
+                if (useModel.equals(ModelConstants.PRINTBOARD_HIGH_I2I)|| useModel.equals(ModelConstants.PRINTBOARD_HIGH_T2I)) {
                     GenerateImagesRequest.OptimizePromptOptions optimizePromptOptions = new GenerateImagesRequest.OptimizePromptOptions();
                     optimizePromptOptions.setMode("fast");
                     requestBuilder.optimizePromptOptions(optimizePromptOptions);
-                    //由于PRINTBOARD_HIGH_I2I与PRINTBOARD_ADVANCED_I2I使用模型一致，为了区别积分扣除，PRINTBOARD_HIGH_I2I加入了-fast，但传入模型时需要去掉-fast，用PRINTBOARD_ADVANCED_I2I的常量做替代
+                    //由于PRINTBOARD_HIGH_T2I,PRINTBOARD_HIGH_I2I与PRINTBOARD_ADVANCED_I2I使用模型一致，为了区别积分扣除，PRINTBOARD_HIGH_I2I加入了-fast或者-high，但传入模型时需要去掉-fast或者-high，用PRINTBOARD_ADVANCED_I2I的常量做替代
                     requestBuilder.model(ModelConstants.PRINTBOARD_ADVANCED_I2I);
                 }
 

src/main/java/com/ai/da/service/impl/GlobalAwardServiceImpl.java

@@ -13,6 +13,7 @@ import com.ai.da.model.dto.ContestantDTO;
 import com.ai.da.model.dto.PublishSysNotificationDTO;
 import com.ai.da.model.vo.CheckOTPVO;
 import com.ai.da.model.vo.ContestantCountVO;
+import com.ai.da.model.vo.PageVisitCountVO;
 import com.ai.da.service.GlobalAwardService;
 import com.ai.da.service.MessageCenterService;
 import com.alibaba.fastjson.JSON;
@@ -619,6 +620,37 @@ public class GlobalAwardServiceImpl implements GlobalAwardService {
     private String nullSafe(String value) {
         return value != null ? value : "N/A";
     }
+
+    private static final String RAW_VISIT_COUNT_KEY = "GLOBAL_AWARD:visit:raw";
+    private static final String UNIQUE_VISIT_SET_KEY = "GLOBAL_AWARD:visit:unique";
+    private static final String SESSION_VISIT_KEY_PREFIX = "GLOBAL_AWARD:visit:session:";
+    private static final long SESSION_DEDUP_SECONDS = 5L;
+
+    @Override
+    public void recordPageVisit(String sessionId) {
+        redisUtil.increaseCount(RAW_VISIT_COUNT_KEY);
+
+        if (StringUtils.isNotBlank(sessionId)) {
+            String sessionKey = SESSION_VISIT_KEY_PREFIX + sessionId;
+            if (!redisUtil.hasKey(sessionKey)) {
+                redisUtil.increaseCount(UNIQUE_VISIT_SET_KEY);
+                redisUtil.addToString(sessionKey, "1", SESSION_DEDUP_SECONDS);
+            }
+        } else {
+            redisUtil.increaseCount(UNIQUE_VISIT_SET_KEY);
+        }
+    }
+
+    @Override
+    public PageVisitCountVO getPageVisitCount() {
+        Long raw = redisUtil.getIncrementCount(RAW_VISIT_COUNT_KEY);
+        Long unique = redisUtil.getIncrementCount(UNIQUE_VISIT_SET_KEY);
+        return PageVisitCountVO.builder()
+                .rawVisitCount(raw != null ? raw : 0L)
+                .uniqueVisitCount(unique != null ? unique : 0L)
+                .build();
+    }
+
 }
 
 

src/main/java/com/ai/da/service/impl/StripeServiceImpl.java

@@ -486,7 +486,8 @@ public class StripeServiceImpl implements StripeService {
         emailParamsDTO.setEmail(account.getUserEmail());
         emailParamsDTO.setCountry(paymentInfo.getCountry());
         emailParamsDTO.setOrderId(paymentInfo.getId().toString());
-        emailParamsDTO.setOrderRef("\"" + orderListLink + paymentInfo.getId().toString() + "\"");
+//        emailParamsDTO.setOrderRef("\"" + orderListLink + paymentInfo.getId().toString() + "\"");
+        emailParamsDTO.setOrderRef("\"" + paymentInfo.getHostedInvoiceUrl() + "\"");
         emailParamsDTO.setCreateDate(String.valueOf(paymentInfo.getCreateTime()).replace("T", " "));
         emailParamsDTO.setQuantity(String.valueOf(1));
         emailParamsDTO.setTotalFee(paymentInfo.getPayerTotal().toString());

src/main/java/com/ai/da/service/impl/StripeSubscriptionServiceImpl.java

@@ -84,24 +84,29 @@ public class StripeSubscriptionServiceImpl implements StripeSubscriptionService
                                         SubscriptionInfo passedSubscriptionInfo) {
         SubscriptionInfo subscriptionInfo = resolveSubscriptionInfo(subscription, type, orderNo, passedSubscriptionInfo);
         if (subscriptionInfo == null) {
+            log.info("subscriptionInfo为null，不发送邮件");
             return false;
         }
         OrderInfo orderByOrderNo = orderInfoService.getOrderByOrderNo(subscriptionInfo.getOrderNo());
         if (orderByOrderNo == null) {
+            log.info("orderByOrderNo为null，不发送邮件");
             return false;
         }
         Account account = accountMapper.selectById(subscriptionInfo.getAccountId());
         if (account == null) {
+            log.info("account为null，不发送邮件");
             return false;
         }
 
         PaymentInfo paymentInfo = resolvePaymentInfo(subscriptionInfo, orderNo, type);
         if (paymentInfo == null) {
+            log.info("paymentInfo为null，不发送邮件");
             return false;
         }
 
         String resolvedType = resolveEmailType(type, paymentInfo);
         if (isEmailAlreadySent(subscriptionInfo, resolvedType, paymentInfo)) {
+            log.info("邮件已发送，取消重复发送");
             return true;
         }
 
@@ -130,13 +135,15 @@ public class StripeSubscriptionServiceImpl implements StripeSubscriptionService
         // renewal 场景：从 InvoicePaidHandler 直接传入已更新的 SubscriptionInfo，避免事务未提交导致查询不到
         if (passedInfo != null) {
             long now = Instant.now().getEpochSecond();
-            // 限制当前时间在订阅区间内，避免处理上个周期内的回调而重复发送邮件
-            if (now > passedInfo.getCurrentPeriodStart() && now < passedInfo.getCurrentPeriodEnd()
-                    && "active".equals(passedInfo.getStatus())) {
+            boolean inPeriod = now > passedInfo.getCurrentPeriodStart() && now < passedInfo.getCurrentPeriodEnd();
+            // 续订失败的场景，可能订单状态已被更新为past_due
+            boolean validStatus = "past_due".equals(passedInfo.getStatus()) || "active".equals(passedInfo.getStatus());
+            if (inPeriod && validStatus) {
                 return passedInfo;
             }
             return null;
         }
+
         if (!StringUtil.isNullOrEmpty(orderNo)) {
             long now = Instant.now().getEpochSecond();
             List<SubscriptionInfo> infos = subscriptionInfoMapper.selectList(
@@ -175,7 +182,7 @@ public class StripeSubscriptionServiceImpl implements StripeSubscriptionService
                 .orderByDesc("id")
                 .last("LIMIT 1");
         if (!type.contains("fail")) {
-            last.in("trade_state", "paid", "COMPLETED");
+            last.in("trade_state", "paid", "COMPLETED", "Refunded");
         }
         List<PaymentInfo> infos = paymentInfoMapper.selectList(last);
         return infos.isEmpty() ? null : infos.getFirst();
@@ -348,7 +355,9 @@ public class StripeSubscriptionServiceImpl implements StripeSubscriptionService
         params.setEmail(account.getUserEmail());
         params.setCountry(paymentInfo.getCountry());
         params.setOrderId(paymentInfo.getId().toString());
-        params.setOrderRef("\"" + orderListLink + paymentInfo.getId().toString() + "\"");
+//        params.setOrderRef("\"" + orderListLink + paymentInfo.getId().toString() + "\"");
+        params.setOrderRef("\"" + paymentInfo.getHostedInvoiceUrl() + "\"");
+
         params.setCreateDate(String.valueOf(paymentInfo.getCreateTime()).replace("T", " "));
         params.setQuantity("1");
         params.setTotalFee(paymentInfo.getPayerTotal() != null ? paymentInfo.getPayerTotal().toString() : "0");

src/main/java/com/ai/da/service/stripe/handler/CheckoutSessionCompletedHandler.java

@@ -187,10 +187,13 @@ public class CheckoutSessionCompletedHandler implements StripeEventHandler {
             log.info("[checkout.session.completed] 订阅记录创建完成，orderNo={}，subscriptionId={}，periodEnd={}",
                     orderNo, subscriptionId, periodEnd);
 
-            stripeSubscriptionService.sendSubscriptionEmail(null, "new", orderNo, null);
-
-            log.info("[checkout.session.completed] 邮件通知完成 类型：new");
+            boolean sent = stripeSubscriptionService.sendSubscriptionEmail(null, "new", orderNo, subscriptionInfo);
 
+            if (sent) {
+                log.info("[checkout.session.completed] 邮件通知完成 类型：new");
+            } else {
+                log.info("[checkout.session.completed] 邮件通知未完成");
+            }
         } catch (StripeException e) {
             log.error("[checkout.session.completed] 处理订阅记录失败，orderNo={}，error={}", orderNo, e.getMessage());
         }

src/main/java/com/ai/da/service/stripe/handler/CheckoutSessionExpiredHandler.java

@@ -96,10 +96,6 @@ public class CheckoutSessionExpiredHandler implements StripeEventHandler {
                     // 首次订阅失败
                     stripeSubscriptionService.sendFailedNewOrderEmail(orderNo);
                     log.info("[checkout.session.expired] 首次订阅失败邮件已发送，orderNo={}", orderNo);
-                } else {
-                    // 续费失败 todo 续费不走这里吧？
-                    stripeSubscriptionService.sendSubscriptionEmail(null, "fail_renewal", subInfoList.getFirst().getOrderNo(), null);
-                    log.info("[checkout.session.expired] 续费失败邮件已发送，orderNo={}", orderNo);
                 }
             }
 

src/main/java/com/ai/da/service/stripe/handler/InvoicePaidHandler.java

@@ -90,7 +90,7 @@ public class InvoicePaidHandler implements StripeEventHandler {
             updateSubscriptionPeriod(invoice, subscriptionInfo);
 
             // 更新用户积分、账号到期时间，添加积分详细记录
-            accountService.updateAccountValidity(subscriptionInfo.getAccountId(), invoice.getPeriodEnd());
+            accountService.updateAccountValidity(subscriptionInfo.getAccountId(), subscriptionInfo.getCurrentPeriodEnd());
             accountService.updateUserRoleAndCredits(subscriptionInfo.getAccountId(), subscriptionInfo.getOrderNo());
 
             // 发送通知邮件

src/main/java/com/ai/da/service/stripe/handler/SubscriptionDeletedHandler.java

@@ -67,7 +67,7 @@ public class SubscriptionDeletedHandler implements StripeEventHandler {
 
             // 发送取消订阅通知邮件
             if (subscriptionInfo.getCancelNotified() == 0) {
-                boolean sent = stripeSubscriptionService.sendSubscriptionEmail(null, "cancel", subscriptionInfo.getOrderNo(), null);
+                boolean sent = stripeSubscriptionService.sendSubscriptionEmail(null, "cancel", subscriptionInfo.getOrderNo(), subscriptionInfo);
                 if (sent) {
                     subscriptionInfo.setCancelNotified((byte) 1);
 

src/main/resources/application-dev.properties

@@ -181,4 +181,10 @@ file.upload.max.size.video=104857600
 # 上传任务过期时间（小时）
 file.upload.task.expiry.hours=24
 
-global.award.link=https://aida-global-design-awards.com.hk/contestants?id=
+global.award.link=https://aida-global-design-awards.com.hk/contestants?id=
+
+# merchant email receivers (comma-separated, multiple supported)
+# dev/local: developer.email 不配置，使用默认值 xupei3360@163.com
+# prod: 两个都配置
+merchant.email=
+developer.email=xupei@code-create.com.hk,yizhang@aidlab.hk

src/main/resources/application-prod.properties

@@ -179,4 +179,9 @@ file.upload.max.size.video=104857600
 # 上传任务过期时间（小时）
 file.upload.task.expiry.hours=24
 
-global.award.link=https://aida-global-design-awards.com.hk/contestants?id=
+global.award.link=https://aida-global-design-awards.com.hk/contestants?id=
+
+# merchant email receivers (comma-separated, multiple supported)
+# prod: includes merchant email
+merchant.email=kimwong@code-create.com.hk
+developer.email=xupei3360@163.com

src/main/resources/mapper/primary/PaymentInfoMapper.xml

@@ -51,47 +51,41 @@
         a.user_email email,
         p.payment_type platform,
         p.payer_total,
-        p.type,
+        CASE
+        WHEN o.title LIKE '%Subscription' THEN 'Subscription'
+        ELSE 'Credits'
+        END AS type,
         p.payment_method,
         p.last4,
         p.country,
         p.city,
         p.create_time,
         CASE
-
-        WHEN p.trade_state IN ( 'paid', 'COMPLETED', 'complete', 'liquidated' ) THEN
-        'Success'
-        WHEN p.trade_state IN ( 'failed', 'expired', 'VOIDED', 'void', 'uncollectible' ) THEN
-        'Fail'
-        WHEN p.trade_state IN ( 'Refunded' ) THEN
-        'Refunded'
+        WHEN p.trade_state IN ('paid', 'COMPLETED', 'complete', 'liquidated') THEN 'Success'
+        WHEN p.trade_state IN ('failed', 'expired', 'VOIDED', 'void', 'uncollectible') THEN 'Fail'
+        WHEN p.trade_state IN ('Refunded') THEN 'Refunded'
         ELSE 'Pending'
         END AS status
-        FROM
-        t_payment_info p
-        LEFT JOIN
-        t_order_info o ON p.order_no = o.order_no
-        LEFT JOIN
-        t_account a ON a.id = o.account_id
-        WHERE
-        1 = 1
+        FROM t_payment_info p
+        LEFT JOIN t_order_info o ON p.order_no = o.order_no
+        LEFT JOIN t_account a ON a.id = o.account_id
+        WHERE 1 = 1
         <if test="paymentType != null and paymentType != ''">
             AND p.payment_type = #{paymentType}
         </if>
         <if test="payerTotal != null and payerTotal != ''">
             AND p.payer_total = #{payerTotal}
         </if>
-        <if test="type != null and type != ''">
-            AND p.type = #{type}
-        </if>
+        <!-- 修复1：删除 type 过滤条件，因为 type 是计算字段 -->
         <if test="status != null and status != ''">
-            AND
-            CASE
-            WHEN p.trade_state IN ('paid', 'COMPLETED', 'complete', 'liquidated') THEN 'Success'
-            WHEN p.trade_state IN ('failed', 'expired', 'VOIDED', 'void', 'uncollectible') THEN 'Fail'
-            WHEN p.trade_state IN ('Refunded') THEN 'Refunded'
-            ELSE 'Pending'
-            END = #{status}
+            AND (
+            (p.trade_state IN ('paid', 'COMPLETED', 'complete', 'liquidated') AND #{status} = 'Success')
+            OR (p.trade_state IN ('failed', 'expired', 'VOIDED', 'void', 'uncollectible') AND #{status} = 'Fail')
+            OR (p.trade_state IN ('Refunded') AND #{status} = 'Refunded')
+            OR (p.trade_state NOT IN ('paid', 'COMPLETED', 'complete', 'liquidated',
+            'failed', 'expired', 'VOIDED', 'void', 'uncollectible', 'Refunded')
+            AND #{status} = 'Pending')
+            )
         </if>
         <if test="country != null and country != ''">
             AND p.country = #{country}
@@ -106,9 +100,8 @@
             AND a.user_name = #{payer}
         </if>
         AND p.transaction_id NOT LIKE 'cs_test%'
-        ORDER BY
-        p.id ${order}
-        LIMIT ${limit} OFFSET ${offset}
+        ORDER BY p.id ${order}  <!-- 建议使用白名单校验 -->
+        LIMIT #{limit} OFFSET #{offset}  <!-- 修复：改为 #{} -->
     </select>
 
     <select id="queryPaymentInfoCount" resultType="java.lang.Long">

src/main/resources/mapper/primary/SubscriptionInfoMapper.xml

@@ -1,7 +1,8 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.ai.da.mapper.primary.SubscriptionInfoMapper">
-    <insert id="insertIgnore" parameterType="com.ai.da.mapper.primary.entity.SubscriptionInfo">
+    <insert id="insertIgnore" parameterType="com.ai.da.mapper.primary.entity.SubscriptionInfo"
+            useGeneratedKeys="true" keyProperty="id">
         INSERT IGNORE INTO
                t_subscription_info (account_id, order_no, subscription_id, type, status, cancel_notified,
                                     next_pay_date, current_period_start, current_period_end, create_time)