ht

RuoYi-Vue/pom.xml

@@ -228,6 +228,7 @@
         <module>ruoyi-quartz</module>
         <module>ruoyi-generator</module>
         <module>ruoyi-common</module>
+        <module>ruoyi-novel</module>
     </modules>
     <packaging>pom</packaging>
 

RuoYi-Vue/ruoyi-admin/src/main/resources/application.yml

@@ -65,6 +65,8 @@ spring:
     restart:
       # 热部署开关
       enabled: true
+  session:
+    store-type: redis
   # redis 配置
   redis:
     # 地址

RuoYi-Vue/ruoyi-novel/pom.xml

@@ -0,0 +1,44 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>com.ruoyi</groupId>
+        <artifactId>ruoyi</artifactId>
+        <version>3.9.0</version>
+    </parent>
+
+    <artifactId>ruoyi-novel</artifactId>
+
+    <properties>
+        <maven.compiler.source>17</maven.compiler.source>
+        <maven.compiler.target>17</maven.compiler.target>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    </properties>
+    <dependencies>
+        <dependency>
+            <groupId>org.mybatis</groupId>
+            <artifactId>mybatis</artifactId>
+            <version>3.5.3</version>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-context</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-web</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.ruoyi</groupId>
+            <artifactId>ruoyi-common</artifactId>
+        </dependency>
+    </dependencies>
+
+</project>

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/config/PhpDataSyncTask.java

@@ -0,0 +1,36 @@
+package com.ruoyi.novel.config;
+
+import com.ruoyi.novel.domain.RoyaltySummary;
+import com.ruoyi.novel.mapper.RoyaltySummaryMapper;
+import lombok.Value;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+import org.springframework.web.client.RestTemplate;
+
+import java.util.Arrays;
+
+// 定时同步PHP数据任务
+@Component
+public class PhpDataSyncTask {
+
+    @Autowired
+    private RoyaltySummaryMapper royaltySummaryMapper;
+
+    @Value("${php.data.url}")
+    private String phpDataUrl;
+
+    // 每天凌晨2点执行
+    @Scheduled(cron = "0 0 2 * * ?")
+    public void syncRoyaltyData() {
+        RestTemplate restTemplate = new RestTemplate();
+        RoyaltySummary[] summaries = restTemplate.getForObject(
+                phpDataUrl + "/royalty/summary",
+                RoyaltySummary[].class
+        );
+
+        if (summaries != null) {
+            Arrays.stream(summaries).forEach(royaltySummaryMapper::insertOrUpdate);
+        }
+    }
+}

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/config/ScheduledTasks.java

@@ -0,0 +1,58 @@
+package com.ruoyi.novel.config;
+
+import com.ruoyi.novel.service.IAdService;
+import com.ruoyi.novel.service.IFinanceService;
+import com.ruoyi.novel.service.IVoteService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.EnableScheduling;
+import org.springframework.scheduling.annotation.Scheduled;
+
+// ScheduledTasks.java
+@Configuration
+@EnableScheduling
+public class ScheduledTasks {
+
+    @Autowired
+    private IAdService adService;
+
+    @Autowired
+    private IVoteService voteService;
+
+    @Autowired
+    private IFinanceService financeService;
+
+    /**
+     * 每5分钟重试失败的广告同步
+     */
+    @Scheduled(fixedRate = 300000)
+    public void retryAdSync() {
+        adService.retryFailedSyncs();
+    }
+
+    /**
+     * 每10分钟重试失败的PHP通知
+     */
+    @Scheduled(cron = "0 */10 * * * ?")
+    public void retryVoteNotify() {
+        voteService.retryFailedNotifications();
+    }
+
+    /**
+     * 每天凌晨2点同步分账数据
+     */
+    @Scheduled(cron = "0 0 2 * * ?")
+    public void syncRoyaltyData() {
+        financeService.syncRoyaltyData();
+    }
+
+    /**
+     * 每小时刷新投票计数器
+     */
+    @Scheduled(cron = "0 0 * * * ?")
+    public void resetVoteCounters() {
+        // 实际应基于每日重置
+        log.info("Resetting vote counters...");
+        // 计数器重置逻辑
+    }
+}

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/config/ThreadPoolConfig.java

@@ -0,0 +1,4 @@
+package com.ruoyi.novel.config;
+
+public class ThreadPoolConfig {
+}

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/controller/ChapterController.java

@@ -0,0 +1,25 @@
+package com.ruoyi.novel.controller;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+// ChapterController.java
+@RestController
+@RequestMapping("/chapter")
+public class ChapterController {
+
+    @Autowired
+    private ChapterService chapterService;
+
+    @GetMapping("/{novelId}")
+    public AjaxResult getChapters(@PathVariable Long novelId) {
+        List<NovelChapter> chapters = chapterService.selectChapterListByNovelId(novelId);
+        return AjaxResult.success(chapters);
+    }
+
+    @PostMapping("/save")
+    public AjaxResult saveChapter(@RequestBody ChapterDTO dto) {
+        return toAjax(chapterService.saveChapter(dto.getChapter(), dto.getContent()));
+    }
+}

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/controller/NovelAdController.java

@@ -0,0 +1,4 @@
+package com.ruoyi.novel.controller;
+//# 广告计数接口
+public class NovelAdController {
+}

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/controller/NovelController.java

@@ -0,0 +1,29 @@
+package com.ruoyi.novel.controller;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+// NovelController.java
+@RestController
+@RequestMapping("/novel")
+public class NovelController {
+
+    @Autowired
+    private NovelService novelService;
+
+    @GetMapping("/list")
+    public TableDataInfo list(Novel novel) {
+        startPage();
+        List<Novel> list = novelService.selectNovelList(novel);
+        return getDataTable(list);
+    }
+
+    @PostMapping
+    public AjaxResult add(@RequestBody Novel novel) {
+        return toAjax(novelService.insertNovel(novel));
+    }
+
+    // 其他接口...
+}

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/controller/NovelFinanceController.java

@@ -0,0 +1,26 @@
+package com.ruoyi.novel.controller;
+
+import com.ruoyi.common.core.domain.AjaxResult;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+//# 分账结算接口
+// NovelFinanceController.java
+@RestController
+@RequestMapping("/finance")
+public class NovelFinanceController {
+
+    @Autowired
+    private IFinanceService financeService;
+
+    @GetMapping("/royalty")
+    public AjaxResult getRoyalty(
+            @RequestParam Long authorId,
+            @RequestParam @DateTimeFormat(pattern="yyyy-MM") String month) {
+
+        RoyaltyReport report = financeService.calculateRoyalty(authorId, month);
+        return AjaxResult.success(report);
+    }
+}

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/controller/NovelVoteController.java

@@ -0,0 +1,43 @@
+package com.ruoyi.novel.controller;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+//# 剧情投票接口
+// NovelVoteController.java
+@RestController
+@RequestMapping("/story/vote")
+public class NovelVoteController {
+
+    @Autowired
+    private IVoteService voteService;
+
+    // 使用Guava RateLimiter限制投票频率
+    private static final ConcurrentHashMap<Long, RateLimiter> userRateLimiters = new ConcurrentHashMap<>();
+    private static final int MAX_VOTES_PER_DAY = 3;
+
+    @PostMapping("/next")
+    public AjaxResult voteForStoryBranch(@RequestBody VoteRequest request) {
+        // 1. 频率限制检查
+        RateLimiter rateLimiter = userRateLimiters.computeIfAbsent(
+                request.getUserId(),
+                k -> RateLimiter.create(MAX_VOTES_PER_DAY)
+        );
+
+        if (!rateLimiter.tryAcquire()) {
+            return AjaxResult.error("Exceeded daily vote limit");
+        }
+
+        // 2. 调用DeepSeek API生成剧情
+        String generatedContent = voteService.generateStoryContent(
+                request.getStoryId(),
+                request.getOptionId()
+        );
+
+        // 3. 异步通知PHP系统
+        voteService.notifyPhpSystem(request, generatedContent);
+
+        return AjaxResult.success("Vote processed", generatedContent);
+    }
+}

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/controller/ReadingHistoryController.java

@@ -0,0 +1,23 @@
+package com.ruoyi.novel.controller;
+
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequestMapping("/history")
+public class ReadingHistoryController {
+
+    @PostMapping("/record")
+    public AjaxResult recordReading(@RequestBody ReadingRecord record) {
+        // 记录用户阅读位置
+    }
+
+    @GetMapping("/last/{userId}/{novelId}")
+    public AjaxResult getLastPosition(
+            @PathVariable Long userId,
+            @PathVariable Long novelId) {
+        // 获取最后阅读位置
+    }
+}

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/domain/AdLog.java

@@ -0,0 +1,31 @@
+package com.ruoyi.novel.domain;
+
+import lombok.Data;
+
+import java.util.Date;
+
+// AdLog.java
+@Data
+@TableName("novel_ad_log")
+public class AdLog {
+    @TableId(type = IdType.AUTO)
+    private Long id;
+
+    @NotNull(message = "用户ID不能为空")
+    private Long userId;
+
+    @NotNull(message = "章节ID不能为空")
+    private Long chapterId;
+
+    @NotBlank(message = "广告平台不能为空")
+    @Size(max = 50, message = "广告平台标识过长")
+    private String adPlatform;
+
+    @TableField(fill = FieldFill.INSERT)
+    private Date viewTime;
+
+    private String deviceInfo;
+
+    // 状态字段：0-未同步 1-已同步
+    private Integer syncStatus;
+}

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/domain/AdPlatformConfig.java

@@ -0,0 +1,13 @@
+package com.ruoyi.novel.domain;
+
+@Data
+@TableName("novel_ad_config")
+public class AdPlatformConfig {
+    @TableId
+    private String platformCode;
+
+    private String platformName;
+    private String apiUrl;
+    private String authToken;
+    private String paramsTemplate;
+}

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/domain/Novel.java

@@ -0,0 +1,21 @@
+package com.ruoyi.novel.domain;
+
+import lombok.Data;
+
+import java.util.Date;
+
+// Novel.java
+@Data
+public class Novel {
+    private Long id;
+    private String title;
+    private String author;
+    private String coverImg;
+    private Long categoryId;
+    private String status;
+    private String description;
+    private Long wordCount;
+    private Long readCount;
+    private Date createTime;
+    private Date updateTime;
+}

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/domain/NovelChapter.java

@@ -0,0 +1,11 @@
+package com.ruoyi.novel.domain;
+// NovelChapter.java
+@Data
+public class NovelChapter {
+    private Long id;
+    private Long novelId;
+    private String chapterTitle;
+    private Integer chapterOrder;
+    private Date publishTime;
+    private String isVip;
+}

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/domain/NovelContent.java

@@ -0,0 +1,7 @@
+package com.ruoyi.novel.domain;
+// NovelContent.java
+@Data
+public class NovelContent {
+    private Long chapterId;
+    private String content;
+}

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/domain/RoyaltyReport.java

@@ -0,0 +1,26 @@
+package com.ruoyi.novel.domain;
+
+// RoyaltyReport.java
+@Data
+public class RoyaltyReport {
+    private Long authorId;
+    private String authorName;
+    private String month;
+    private BigDecimal totalReads;
+    private BigDecimal royaltyRate;
+    private BigDecimal handlingFeeRate;
+    private BigDecimal handlingFee;
+    private BigDecimal netAmount;
+    private String currency = "CNY";
+
+    // 计算逻辑
+    public void calculate(BigDecimal reads, BigDecimal rate, BigDecimal feeRate) {
+        this.totalReads = reads;
+        this.royaltyRate = rate;
+        this.handlingFeeRate = feeRate;
+
+        BigDecimal rawAmount = reads.multiply(rate);
+        this.handlingFee = rawAmount.multiply(feeRate);
+        this.netAmount = rawAmount.subtract(handlingFee);
+    }
+}

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/domain/RoyaltySummary.java

@@ -0,0 +1,20 @@
+package com.ruoyi.novel.domain;
+
+import lombok.Data;
+
+import java.math.BigDecimal;
+
+// RoyaltySummary.java
+// RoyaltySummary.java
+@Data
+@TableName("novel_royalty_summary")
+public class RoyaltySummary {
+    @TableId
+    private Long authorId;
+
+    @TableId
+    private String month; // yyyy-MM格式
+
+    private BigDecimal totalReads;
+    private Date lastSyncTime;
+}

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/domain/StoryOption.java

@@ -0,0 +1,17 @@
+package com.ruoyi.novel.domain;
+
+// StoryOption.java
+@Data
+@TableName("novel_story_option")
+public class StoryOption {
+    @TableId(type = IdType.AUTO)
+    private Long id;
+
+    @NotNull(message = "故事ID不能为空")
+    private Long storyId;
+
+    @NotBlank(message = "选项内容不能为空")
+    private String optionText;
+
+    private Integer voteCount;
+}

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/domain/VoteRecord.java

@@ -0,0 +1,26 @@
+package com.ruoyi.novel.domain;
+
+import lombok.Data;
+
+import java.util.Date;
+
+// VoteRecord.java
+// VoteRecord.java
+@Data
+@TableName("novel_vote_log")
+public class VoteRecord {
+    @TableId(type = IdType.AUTO)
+    private Long id;
+
+    private Long userId;
+    private Long storyId;
+    private Long optionId;
+
+    @TableField(fill = FieldFill.INSERT)
+    private Date voteTime;
+
+    @Column(typeHandler = LongTextTypeHandler.class)
+    private String generatedContent;
+
+    private Integer notifyStatus; // 0-未通知 1-已通知
+}

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/domain/VoteRequest.java

@@ -0,0 +1,14 @@
+package com.ruoyi.novel.domain;
+
+// VoteRequest.java
+@Data
+public class VoteRequest {
+    @NotNull(message = "用户ID不能为空")
+    private Long userId;
+
+    @NotNull(message = "故事ID不能为空")
+    private Long storyId;
+
+    @NotNull(message = "选项ID不能为空")
+    private Long optionId;
+}

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/mapper/AdLogMapper.java

@@ -0,0 +1,12 @@
+package com.ruoyi.novel.mapper;
+
+// AdLogMapper.java
+@Mapper
+public interface AdLogMapper extends BaseMapper<AdLog> {
+
+    @Select("SELECT COUNT(*) FROM novel_ad_log WHERE user_id = #{userId} AND chapter_id = #{chapterId}")
+    int countByUserAndChapter(@Param("userId") Long userId, @Param("chapterId") Long chapterId);
+
+    @Select("SELECT * FROM novel_ad_log WHERE sync_status = 0 ORDER BY view_time ASC LIMIT 100")
+    List<AdLog> selectUnsyncedLogs();
+}

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/mapper/NovelChapterMapper.java

@@ -0,0 +1,12 @@
+package com.ruoyi.novel.mapper;
+
+import org.apache.ibatis.annotations.Mapper;
+
+// NovelChapterMapper.java
+@Mapper
+public interface NovelChapterMapper {
+    List<NovelChapter> selectChapterListByNovelId(Long novelId);
+    NovelChapter selectChapterById(Long chapterId);
+    int insertChapter(NovelChapter chapter);
+    int updateChapter(NovelChapter chapter);
+}

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/mapper/NovelMapper.java

@@ -0,0 +1,10 @@
+package com.ruoyi.novel.mapper;
+// NovelMapper.java
+public interface NovelMapper {
+    List<Novel> selectNovelList(Novel novel);
+    Novel selectNovelById(Long id);
+    int insertNovel(Novel novel);
+    int updateNovel(Novel novel);
+    int deleteNovelByIds(Long[] ids);
+}
+

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/mapper/RoyaltySummaryMapper.java

@@ -0,0 +1,18 @@
+package com.ruoyi.novel.mapper;
+
+// RoyaltySummaryMapper.java
+@Mapper
+public interface RoyaltySummaryMapper extends BaseMapper<RoyaltySummary> {
+
+    @Select("SELECT * FROM novel_royalty_summary " +
+            "WHERE author_id = #{authorId} AND month = #{month}")
+    RoyaltySummary selectByAuthorAndMonth(
+            @Param("authorId") Long authorId,
+            @Param("month") String month
+    );
+
+    @Update("INSERT INTO novel_royalty_summary (author_id, month, total_reads, last_sync_time) " +
+            "VALUES (#{authorId}, #{month}, #{totalReads}, NOW()) " +
+            "ON DUPLICATE KEY UPDATE total_reads = #{totalReads}, last_sync_time = NOW()")
+    int upsertSummary(RoyaltySummary summary);
+}

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/mapper/VoteRecordMapper.java

@@ -0,0 +1,16 @@
+package com.ruoyi.novel.mapper;
+
+// VoteRecordMapper.java
+@Mapper
+public interface VoteRecordMapper extends BaseMapper<VoteRecord> {
+
+    @Select("SELECT COUNT(*) FROM novel_vote_log " +
+            "WHERE user_id = #{userId} AND story_id = #{storyId}")
+    int countUserVotesForStory(@Param("userId") Long userId, @Param("storyId") Long storyId);
+
+    @Update("UPDATE novel_vote_log SET notify_status = #{status} WHERE id = #{id}")
+    int updateNotifyStatus(@Param("id") Long id, @Param("status") Integer status);
+
+    @Select("SELECT * FROM novel_vote_log WHERE notify_status = 0 ORDER BY vote_time ASC LIMIT 50")
+    List<VoteRecord> selectUnnotifiedRecords();
+}

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/service/IAdService.java

@@ -0,0 +1,8 @@
+package com.ruoyi.novel.service;
+
+public interface IAdService {
+    void logAdView(AdLog adLog);
+    void syncWithAdPlatform(AdLog adLog);
+    void retryFailedSyncs();
+    Map<String, AdPlatformConfig> loadAdConfigs();
+}

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/service/IFinanceService.java

@@ -0,0 +1,9 @@
+package com.ruoyi.novel.service;
+
+// IFinanceService.java
+public interface IFinanceService {
+    RoyaltyReport calculateRoyalty(Long authorId, String month);
+    void syncRoyaltyData();
+    BigDecimal getRoyaltyRate(Long authorId);
+    BigDecimal getHandlingFeeRate();
+}

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/service/IVoteService.java

@@ -0,0 +1,9 @@
+package com.ruoyi.novel.service;
+
+// IVoteService.java
+public interface IVoteService {
+    String processVote(VoteRequest request);
+    void generateStoryContent(VoteRecord record);
+    void notifyPhpSystem(VoteRecord record);
+    void retryFailedNotifications();
+}

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/service/NovelSearchService.java

@@ -0,0 +1,4 @@
+package com.ruoyi.novel.service;
+
+public class NovelSearchService {
+}

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/service/impl/AdServiceImpl.java

@@ -0,0 +1,92 @@
+package com.ruoyi.novel.service.impl;
+
+import com.ruoyi.novel.service.IAdService;
+
+@Service
+public class AdServiceImpl implements IAdService {
+
+    @Autowired
+    private AdLogMapper adLogMapper;
+
+    @Autowired
+    private AdPlatformClient adPlatformClient;
+
+    private Map<String, AdPlatformConfig> adConfigCache;
+    private final Object lock = new Object();
+    @Override
+    @Transactional
+    public void logAdView(AdLog adLog) {
+        // 防止重复记录
+        int count = adLogMapper.countByUserAndChapter(adLog.getUserId(), adLog.getChapterId());
+        if (count > 0) {
+            log.warn("Duplicate ad log: user={}, chapter={}", adLog.getUserId(), adLog.getChapterId());
+            return;
+        }
+
+        adLog.setSyncStatus(0); // 未同步状态
+        adLogMapper.insert(adLog);
+    }
+
+    @Override
+    @Async("adTaskExecutor")
+    public void syncWithAdPlatform(AdLog adLog) {
+        try {
+            adPlatformClient.syncAdPlatform(adLog);
+            adLog.setSyncStatus(1); // 同步成功
+        } catch (Exception e) {
+            log.error("Ad sync failed: {}", e.getMessage());
+            adLog.setSyncStatus(2); // 同步失败
+        }
+        adLogMapper.updateById(adLog);
+    }
+
+    @Override
+    @Scheduled(fixedRate = 300000) // 每5分钟执行一次
+    public void retryFailedSyncs() {
+        List<AdLog> failedLogs = adLogMapper.selectUnsyncedLogs();
+        failedLogs.forEach(log -> {
+            log.info("Retrying ad sync for log: {}", log.getId());
+            this.syncWithAdPlatform(log);
+        });
+    }
+
+    @Override
+    public Map<String, AdPlatformConfig> loadAdConfigs() {
+        if (adConfigCache == null) {
+            synchronized (lock) {
+                if (adConfigCache == null) {
+                    // 实际应从数据库加载
+                    adConfigCache = new HashMap<>();
+                    adConfigCache.put("tencent", new AdPlatformConfig(
+                            "tencent", "腾讯广告",
+                            "https://ad.tencent.com/track",
+                            "token_123",
+                            "{\"user_id\":\"${userId}\",\"chapter_id\":\"${chapterId}\"}"
+                    ));
+                    // 其他平台配置...
+                }
+            }
+        }
+        return adConfigCache;
+    }
+//    @Override
+//    @Transactional
+//    public void logAdView(AdLog adLog) {
+//        adLogMapper.insertAdLog(adLog);
+//    }
+
+    @Override
+    public void syncWithAdPlatform(AdLog adLog) {
+        // 根据平台选择不同实现
+        switch (adLog.getAdPlatform()) {
+            case "tencent":
+                adPlatformClient.syncTencent(adLog);
+                break;
+            case "pangle":
+                adPlatformClient.syncPangle(adLog);
+                break;
+            default:
+                log.warn("Unknown ad platform: {}", adLog.getAdPlatform());
+        }
+    }
+}

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/service/impl/ChapterServiceImpl.java

@@ -0,0 +1,22 @@
+package com.ruoyi.novel.service.impl;
+
+// ChapterServiceImpl.java
+@Service
+public class ChapterServiceImpl implements ChapterService {
+
+    @Autowired
+    private NovelChapterMapper chapterMapper;
+
+    @Autowired
+    private NovelContentMapper contentMapper;
+
+    @Override
+    @Transactional
+    public int saveChapter(NovelChapter chapter, String content) {
+        chapterMapper.insertChapter(chapter);
+        NovelContent novelContent = new NovelContent();
+        novelContent.setChapterId(chapter.getId());
+        novelContent.setContent(content);
+        return contentMapper.insertContent(novelContent);
+    }
+}

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/service/impl/FinanceServiceImpl.java

@@ -0,0 +1,110 @@
+package com.ruoyi.novel.service.impl;
+
+import com.ruoyi.novel.domain.RoyaltyReport;
+import com.ruoyi.novel.domain.RoyaltySummary;
+import com.ruoyi.novel.mapper.RoyaltySummaryMapper;
+import com.ruoyi.novel.service.IFinanceService;
+import lombok.Value;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Service;
+
+import java.math.BigDecimal;
+import java.util.ArrayList;
+import java.util.List;
+
+// FinanceServiceImpl.java
+@Service
+public class FinanceServiceImpl implements IFinanceService {
+
+    @Autowired
+    private RoyaltySummaryMapper royaltySummaryMapper;
+    @Value("${royalty.base.rate:0.15}")
+    private BigDecimal baseRoyaltyRate;
+
+    @Value("${handling.fee.rate:0.05}")
+    private BigDecimal handlingFeeRate;
+    @Value("${royalty.rate}")
+    private BigDecimal royaltyRate;
+
+    @Value("${handling.fee.rate}")
+    private BigDecimal handlingFeeRate;
+
+    @Override
+    public RoyaltyReport calculateRoyalty(Long authorId, String month) {
+        // 1. 从PHP主库获取基础数据（假设已通过定时任务同步）
+        RoyaltySummary summary = royaltySummaryMapper.selectByAuthorAndMonth(authorId, month);
+
+//        if (summary == null) {
+//            throw new ServiceException("No data found for author: " + authorId + " in " + month);
+//        }
+        if (summary == null) {
+            throw new ServiceException("未找到分账数据: author=" + authorId + ", month=" + month);
+        }
+        // 2. 计算实际分成比例（可根据作者等级调整）
+        BigDecimal actualRate = getRoyaltyRate(authorId);
+        // 3. 构建报表
+        RoyaltyReport report = new RoyaltyReport();
+        report.setAuthorId(authorId);
+        report.setMonth(month);
+        report.calculate(summary.getTotalReads(), actualRate, handlingFeeRate);
+
+        return report;
+
+        // 2. 计算分账金额
+//        BigDecimal rawAmount = summary.getTotalReads().multiply(royaltyRate);
+//        BigDecimal handlingFee = rawAmount.multiply(handlingFeeRate);
+//        BigDecimal netAmount = rawAmount.subtract(handlingFee);
+//
+//        // 3. 构建报表
+//        return new RoyaltyReport(
+//                authorId,
+//                month,
+//                summary.getTotalReads(),
+//                royaltyRate,
+//                handlingFeeRate,
+//                handlingFee,
+//                netAmount
+//        );
+    }
+
+    @Override
+    @Scheduled(cron = "0 0 2 * * ?") // 每天凌晨2点执行
+    public void syncRoyaltyData() {
+        log.info("开始同步分账数据...");
+        try {
+            // 1. 从PHP主库获取数据
+            List<RoyaltySummary> summaries = fetchFromPhpSystem();
+
+            // 2. 更新到本地数据库
+            summaries.forEach(summary -> {
+                royaltySummaryMapper.upsertSummary(summary);
+            });
+
+            log.info("同步完成: {}条记录", summaries.size());
+        } catch (Exception e) {
+            log.error("分账数据同步失败: {}", e.getMessage());
+        }
+    }
+
+    private List<RoyaltySummary> fetchFromPhpSystem() {
+        // 实现从PHP系统获取数据的逻辑
+        // 返回模拟数据
+        List<RoyaltySummary> list = new ArrayList<>();
+        list.add(new RoyaltySummary(1001L, "2023-10", new BigDecimal("15000.00")));
+        list.add(new RoyaltySummary(1002L, "2023-10", new BigDecimal("8500.00")));
+        return list;
+    }
+
+    @Override
+    public BigDecimal getRoyaltyRate(Long authorId) {
+        // 实际应根据作者等级计算
+        // 这里返回基础比例
+        return baseRoyaltyRate;
+    }
+
+    @Override
+    public BigDecimal getHandlingFeeRate() {
+        return handlingFeeRate;
+    }
+}

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/service/impl/NovelSearchServiceImpl.java

@@ -0,0 +1,16 @@
+package com.ruoyi.novel.service.impl;
+
+// NovelSearchService.java
+@Service
+public class NovelSearchServiceImpl implements NovelSearchService {
+
+    @Autowired
+    private ElasticsearchRestTemplate elasticTemplate;
+
+    public List<Novel> searchNovels(String keyword) {
+        NativeSearchQuery query = new NativeSearchQueryBuilder()
+                .withQuery(QueryBuilders.multiMatchQuery(keyword, "title", "author", "description"))
+                .build();
+        return elasticTemplate.search(query, Novel.class).getContent();
+    }
+}

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/service/impl/NovelServiceImpl.java

@@ -0,0 +1,25 @@
+package com.ruoyi.novel.service.impl;
+
+import org.springframework.stereotype.Service;
+
+// NovelServiceImpl.java
+@Service
+public class NovelServiceImpl implements NovelService {
+
+    @Autowired
+    private NovelMapper novelMapper;
+
+    @Override
+    public List<Novel> selectNovelList(Novel novel) {
+        return novelMapper.selectNovelList(novel);
+    }
+
+    @Override
+    @Transactional
+    public int insertNovel(Novel novel) {
+        novel.setCreateTime(new Date());
+        return novelMapper.insertNovel(novel);
+    }
+
+    // 其他CRUD方法...
+}

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/service/impl/VoteServiceImpl.java

@@ -0,0 +1,151 @@
+package com.ruoyi.novel.service.impl;
+
+// VoteServiceImpl.java
+@Service
+public class VoteServiceImpl implements IVoteService {
+
+    @Autowired
+    private VoteRecordMapper voteRecordMapper;
+    @Autowired
+    private StoryOptionMapper storyOptionMapper;
+    @Value("${deepseek.api.key}")
+    private String deepSeekApiKey;
+
+    @Value("${php.notify.url}")
+    private String phpNotifyUrl;
+    // 用户投票限流器 <userId, 计数器>
+    private final Map<Long, AtomicInteger> userVoteCounters = new ConcurrentHashMap<>();
+    private static final int DAILY_VOTE_LIMIT = 3;
+
+    @Override
+    public String processVote(VoteRequest request) {
+        // 1. 检查当日投票次数
+        AtomicInteger counter = userVoteCounters.computeIfAbsent(
+                request.getUserId(),
+                k -> new AtomicInteger(0)
+        );
+
+        if (counter.get() >= DAILY_VOTE_LIMIT) {
+            throw new ServiceException("今日投票次数已达上限");
+        }
+
+        // 2. 记录投票
+        VoteRecord record = new VoteRecord();
+        record.setUserId(request.getUserId());
+        record.setStoryId(request.getStoryId());
+        record.setOptionId(request.getOptionId());
+        record.setNotifyStatus(0); // 未通知状态
+        voteRecordMapper.insert(record);
+
+        // 3. 更新选项计数
+        storyOptionMapper.incrementOptionVote(request.getOptionId());
+
+        // 4. 异步生成内容
+        this.generateStoryContent(record);
+
+        counter.incrementAndGet();
+        return "投票成功，剧情生成中...";
+    }
+    @Override
+    @Async("voteTaskExecutor")
+    public void generateStoryContent(VoteRecord record) {
+        try {
+            String content = callDeepSeekApi(record);
+            record.setGeneratedContent(content);
+            voteRecordMapper.updateById(record);
+
+            // 通知PHP系统
+            this.notifyPhpSystem(record);
+        } catch (Exception e) {
+            log.error("AI生成失败: {}", e.getMessage());
+        }
+    }
+    private String callDeepSeekApi(VoteRecord record) {
+        // 实现DeepSeek API调用
+        // 返回生成的剧情内容
+        return "生成的故事内容...";
+    }
+
+//    @Async
+//    @Override
+//    public void generateStoryContent(Long storyId, Long optionId) {
+//        // 调用DeepSeek API
+//        DeepSeekRequest request = new DeepSeekRequest(storyId, optionId);
+//        String apiUrl = "https://api.deepseek.com/v1/story/generate";
+//
+//        RestTemplate restTemplate = new RestTemplate();
+//        HttpHeaders headers = new HttpHeaders();
+//        headers.setBearerAuth(deepSeekApiKey);
+//
+//        HttpEntity<DeepSeekRequest> entity = new HttpEntity<>(request, headers);
+//        ResponseEntity<String> response = restTemplate.exchange(
+//                apiUrl, HttpMethod.POST, entity, String.class);
+//
+//        if (response.getStatusCode() == HttpStatus.OK) {
+//            return parseGeneratedContent(response.getBody());
+//        }
+//        throw new ServiceException("Failed to generate story content");
+//    }
+
+    @Async
+    @Override
+    public void notifyPhpSystem(VoteRequest request, String content) {
+        // 组装通知数据
+        Map<String, Object> payload = new HashMap<>();
+        payload.put("userId", request.getUserId());
+        payload.put("storyId", request.getStoryId());
+        payload.put("optionId", request.getOptionId());
+        payload.put("content", content);
+
+        // 发送异步通知
+        RestTemplate restTemplate = new RestTemplate();
+        restTemplate.postForObject(phpNotifyUrl, payload, String.class);
+
+        // 记录投票日志
+        VoteRecord record = new VoteRecord();
+        record.setUserId(request.getUserId());
+        record.setStoryId(request.getStoryId());
+        record.setOptionId(request.getOptionId());
+        record.setVoteTime(new Date());
+        record.setGeneratedContent(content);
+        voteRecordMapper.insertVoteRecord(record);
+    }
+
+    @Override
+    @Async("voteTaskExecutor")
+    public void notifyPhpSystem(VoteRecord record) {
+        try {
+            // 构建通知数据
+            Map<String, Object> payload = new HashMap<>();
+            payload.put("userId", record.getUserId());
+            payload.put("storyId", record.getStoryId());
+            payload.put("optionId", record.getOptionId());
+            payload.put("content", record.getGeneratedContent());
+
+            // 发送HTTP请求
+            RestTemplate restTemplate = new RestTemplate();
+            ResponseEntity<String> response = restTemplate.postForEntity(
+                    phpNotifyUrl, payload, String.class);
+
+            if (response.getStatusCode() == HttpStatus.OK) {
+                record.setNotifyStatus(1); // 通知成功
+            } else {
+                record.setNotifyStatus(2); // 通知失败
+            }
+        } catch (Exception e) {
+            log.error("通知PHP系统失败: {}", e.getMessage());
+            record.setNotifyStatus(2);
+        }
+        voteRecordMapper.updateById(record);
+    }
+
+    @Override
+    @Scheduled(cron = "0 */10 * * * ?") // 每10分钟执行一次
+    public void retryFailedNotifications() {
+        List<VoteRecord> failedRecords = voteRecordMapper.selectUnnotifiedRecords();
+        failedRecords.forEach(record -> {
+            log.info("重试通知PHP系统: voteId={}", record.getId());
+            this.notifyPhpSystem(record);
+        });
+    }
+}

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/utils/AdPlatformClient.java

@@ -0,0 +1,80 @@
+package com.ruoyi.novel.utils;
+
+import com.ruoyi.novel.service.IAdService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import org.springframework.web.client.RestTemplate;
+
+// AdPlatformClient.java
+@Component
+public class AdPlatformClient {
+    @Autowired
+    private IAdService adService;
+
+    @Autowired
+    private RestTemplate restTemplate;
+    @Value("${ad.tencent.url}")
+    private String tencentUrl;
+
+    @Value("${ad.pangle.url}")
+    private String pangleUrl;
+    public void syncAdPlatform(AdLog adLog) {
+        Map<String, AdPlatformConfig> configs = adService.loadAdConfigs();
+        AdPlatformConfig config = configs.get(adLog.getAdPlatform());
+
+        if (config == null) {
+            throw new ServiceException("广告平台配置不存在: " + adLog.getAdPlatform());
+        }
+
+        // 构建请求参数
+        String payload = buildPayload(adLog, config.getParamsTemplate());
+
+        // 设置请求头
+        HttpHeaders headers = new HttpHeaders();
+        headers.setContentType(MediaType.APPLICATION_JSON);
+        headers.setBearerAuth(config.getAuthToken());
+
+        // 发送请求
+        HttpEntity<String> entity = new HttpEntity<>(payload, headers);
+        ResponseEntity<String> response = restTemplate.exchange(
+                config.getApiUrl(), HttpMethod.POST, entity, String.class);
+
+        // 处理响应
+        if (!response.getStatusCode().is2xxSuccessful()) {
+            throw new ServiceException("广告平台同步失败: " + response.getBody());
+        }
+
+        log.info("广告同步成功: logId={}, platform={}", adLog.getId(), adLog.getAdPlatform());
+    }
+    private String buildPayload(AdLog adLog, String template) {
+        // 使用占位符替换实际值
+        return template
+                .replace("${userId}", adLog.getUserId().toString())
+                .replace("${chapterId}", adLog.getChapterId().toString())
+                .replace("${timestamp}", String.valueOf(System.currentTimeMillis()));
+    }
+    public void syncTencent(AdLog adLog) {
+        Map<String, String> params = new HashMap<>();
+        params.put("user_id", adLog.getUserId().toString());
+        params.put("chapter_id", adLog.getChapterId().toString());
+        params.put("event_time", String.valueOf(adLog.getViewTime().getTime()));
+
+        RestTemplate restTemplate = new RestTemplate();
+        restTemplate.postForObject(tencentUrl, params, String.class);
+    }
+
+    public void syncPangle(AdLog adLog) {
+        // 穿山甲平台需要不同的参数格式
+        JSONObject payload = new JSONObject();
+        payload.put("user", adLog.getUserId());
+        payload.put("content_id", adLog.getChapterId());
+        payload.put("timestamp", System.currentTimeMillis());
+
+        RestTemplate restTemplate = new RestTemplate();
+        HttpHeaders headers = new HttpHeaders();
+        headers.setContentType(MediaType.APPLICATION_JSON);
+
+        HttpEntity<String> entity = new HttpEntity<>(payload.toString(), headers);
+        restTemplate.postForObject(pangleUrl, entity, String.class);
+    }
+}

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/utils/JwtUtil.java

@@ -0,0 +1,47 @@
+package com.ruoyi.novel.utils;
+
+import io.jsonwebtoken.Claims;
+import io.jsonwebtoken.Jwts;
+import io.jsonwebtoken.SignatureAlgorithm;
+
+import java.util.Date;
+
+// JwtUtil.java
+public class JwtUtil {
+    private static final String SECRET = "your_jwt_secret_key";
+    private static final long EXPIRE = 86400; // 24小时
+    public static String generateToken(Long userId) {
+        Date now = new Date();
+        Date expire = new Date(now.getTime() + EXPIRE * 1000);
+
+        return Jwts.builder()
+                .setHeaderParam("typ", "JWT")
+                .setSubject(userId.toString())
+                .setIssuedAt(now)
+                .setExpiration(expire)
+                .signWith(SignatureAlgorithm.HS512, SECRET)
+                .compact();
+    }
+
+    public static boolean verifyToken(String token, Long userId) {
+        try {
+            Claims claims = Jwts.parser()
+                    .setSigningKey(SECRET)
+                    .parseClaimsJws(token)
+                    .getBody();
+
+            String subject = claims.getSubject();
+            return userId.toString().equals(subject);
+        } catch (Exception e) {
+            return false;
+        }
+    }
+
+    public static Long getUserIdFromToken(String token) {
+        Claims claims = Jwts.parser()
+                .setSigningKey(SECRET)
+                .parseClaimsJws(token)
+                .getBody();
+        return Long.parseLong(claims.getSubject());
+    }
+}

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/utils/NovelUtils.java

@@ -0,0 +1,15 @@
+package com.ruoyi.novel.utils;
+
+// NovelUtils.java
+public class NovelUtils {
+
+    // 敏感词过滤
+    public static String filterSensitiveWords(String content) {
+        // 实现敏感词过滤逻辑
+    }
+
+    // 自动生成章节序号
+    public static Integer generateChapterOrder(Long novelId) {
+        // 查询最新章节序号+1
+    }
+}

RuoYi-Vue/ruoyi-novel/src/main/java/com/ruoyi/novel/vip/VipAccessAspect.java

@@ -0,0 +1,15 @@
+package com.ruoyi.novel.vip;
+
+// VipAccessAspect.java
+@Aspect
+@Component
+public class VipAccessAspect {
+
+    @Before("@annotation(vipAccess)")
+    public void checkVipAccess(JoinPoint joinPoint, VipAccess vipAccess) {
+        // 校验用户VIP状态
+        if(!userService.isVip(SecurityUtils.getUserId())) {
+            throw new ServiceException("请开通VIP后阅读此章节");
+        }
+    }
+}

RuoYi-Vue/ruoyi-novel/src/main/resources/application.yml

@@ -0,0 +1,26 @@
+# 广告平台配置
+ad:
+  tencent:
+    url: https://ad.tencent.com/track
+  pangle:
+    url: https://ad.pangle.com/api/v1/event
+
+# DeepSeek API配置
+deepseek:
+  api:
+    key: your_deepseek_api_key
+    url: https://api.deepseek.com/v1/story/generate
+
+# PHP系统配置
+php:
+  notify:
+    url: http://php-system.com/api/vote/notify
+  data:
+    url: http://php-system.com/api/data
+
+# 分账规则
+royalty:
+  rate: 0.15   # 15%分成比例
+handling:
+  fee:
+    rate: 0.05  # 5%提现手续费

RuoYi-Vue/ruoyi-novel/src/main/resources/mapper/novel/AdLogMapper.xml

@@ -0,0 +1,27 @@
+<!-- AdLogMapper.xml -->
+<mapper namespace="com.ruoyi.novel.mapper.AdLogMapper">
+
+    <resultMap id="AdLogResult" type="AdLog">
+        <id property="id" column="id" />
+        <result property="userId" column="user_id" />
+        <result property="chapterId" column="chapter_id" />
+        <result property="adPlatform" column="ad_platform" />
+        <result property="viewTime" column="view_time" />
+        <result property="deviceInfo" column="device_info" />
+        <result property="syncStatus" column="sync_status" />
+    </resultMap>
+
+    <sql id="selectAdLogVo">
+        SELECT id, user_id, chapter_id, ad_platform, view_time, device_info, sync_status
+        FROM novel_ad_log
+    </sql>
+
+    <update id="updateSyncStatus">
+        UPDATE novel_ad_log
+        SET sync_status = #{status}
+        WHERE id IN
+        <foreach item="id" collection="ids" open="(" separator="," close=")">
+            #{id}
+        </foreach>
+    </update>
+</mapper>

RuoYi-Vue/ruoyi-novel/src/main/resources/mapper/novel/RoyaltySummaryMapper.xml

@@ -0,0 +1,17 @@
+<!-- RoyaltySummaryMapper.xml -->
+<mapper namespace="com.ruoyi.novel.mapper.RoyaltySummaryMapper">
+
+    <resultMap id="RoyaltySummaryResult" type="RoyaltySummary">
+        <id property="authorId" column="author_id" />
+        <id property="month" column="month" />
+        <result property="totalReads" column="total_reads" />
+        <result property="lastSyncTime" column="last_sync_time" />
+    </resultMap>
+
+    <select id="selectMonthlySummary" resultMap="RoyaltySummaryResult">
+        SELECT author_id, month, SUM(total_reads) AS total_reads
+        FROM novel_royalty_detail
+        WHERE month = #{month}
+        GROUP BY author_id
+    </select>
+</mapper>

RuoYi-Vue/ruoyi-novel/src/main/resources/mapper/novel/VoteRecordMapper.xml

@@ -0,0 +1,20 @@
+<!-- VoteRecordMapper.xml -->
+<mapper namespace="com.ruoyi.novel.mapper.VoteRecordMapper">
+
+    <resultMap id="VoteRecordResult" type="VoteRecord">
+        <id property="id" column="id" />
+        <result property="userId" column="user_id" />
+        <result property="storyId" column="story_id" />
+        <result property="optionId" column="option_id" />
+        <result property="voteTime" column="vote_time" />
+        <result property="generatedContent" column="generated_content"
+                typeHandler="com.baomidou.mybatisplus.extension.handlers.JacksonTypeHandler"/>
+        <result property="notifyStatus" column="notify_status" />
+    </resultMap>
+
+    <update id="incrementOptionVote">
+        UPDATE novel_story_option
+        SET vote_count = vote_count + 1
+        WHERE id = #{optionId}
+    </update>
+</mapper>