tj

RuoYi-Vue/pom.xml

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

RuoYi-Vue/ruoyi-common/src/main/java/com/ruoyi/common/annotation/VipAccess.java

@@ -0,0 +1,4 @@
+package com.ruoyi.common.annotation;
+
+public class VipAccess {
+}

RuoYi-Vue/ruoyi-common/src/main/java/com/ruoyi/common/core/domain/entity/SysUser.java

@@ -91,7 +91,8 @@ public class SysUser extends BaseEntity
 
     /** 角色ID */
     private Long roleId;
-
+    // 添加VIP状态字段
+    private String vipStatus;
     public SysUser()
     {
 
@@ -309,7 +310,14 @@ public class SysUser extends BaseEntity
     {
         this.roleId = roleId;
     }
+    // 添加getter/setter
+    public String getVipStatus() {
+        return vipStatus;
+    }
 
+    public void setVipStatus(String vipStatus) {
+        this.vipStatus = vipStatus;
+    }
     @Override
     public String toString() {
         return new ToStringBuilder(this,ToStringStyle.MULTI_LINE_STYLE)

RuoYi-Vue/ruoyi-system/pom.xml

@@ -7,6 +7,18 @@
         <groupId>com.ruoyi</groupId>
         <version>3.9.0</version>
     </parent>
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <configuration>
+                    <source>17</source>
+                    <target>17</target>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
     <modelVersion>4.0.0</modelVersion>
 
     <artifactId>ruoyi-system</artifactId>
@@ -16,13 +28,60 @@
     </description>
 
     <dependencies>
-
+        <!-- AOP 必须 -->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-aop</artifactId>
+        </dependency>
         <!-- 通用工具-->
         <dependency>
             <groupId>com.ruoyi</groupId>
             <artifactId>ruoyi-common</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-context</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-web</artifactId>
+        </dependency>
+        <!-- Elasticsearch -->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
+        </dependency>
+        <!-- MyBatis-Plus 核心依赖 -->
+        <dependency>
+            <groupId>com.baomidou</groupId>
+            <artifactId>mybatis-plus-boot-starter</artifactId>
+            <version>3.4.1</version> <!-- 2023年稳定版，兼容Spring Boot 2.7.x -->
+        </dependency>
+        <!-- 长文本处理 -->
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+        </dependency>
+        <!-- 注解处理器（避免IDE报错） -->
+        <dependency>
+            <groupId>com.baomidou</groupId>
+            <artifactId>mybatis-plus-annotation</artifactId>
+            <version>3.4.1</version>
+        </dependency>
 
+        <dependency>
+            <groupId>com.google.guava</groupId>
+            <artifactId>guava</artifactId>
+            <version>33.4.0-jre</version> <!-- 使用较新版本 -->
+        </dependency>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.aspectj</groupId>
+            <artifactId>aspectjweaver</artifactId>
+        </dependency>
     </dependencies>
 
 </project>

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

@@ -0,0 +1,16 @@
+package com.ruoyi.novel.config;
+
+import com.baomidou.mybatisplus.extension.plugins.PaginationInterceptor;
+import org.mybatis.spring.annotation.MapperScan;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+@MapperScan("com.ruoyi.novel.mapper")
+public class MybatisPlusConfig {
+
+    @Bean
+    public PaginationInterceptor paginationInterceptor() {
+        return new PaginationInterceptor();
+    }
+}

RuoYi-Vue/ruoyi-system/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 org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+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-system/src/main/java/com/ruoyi/novel/config/RestTemplateConfig.java

@@ -0,0 +1,14 @@
+package com.ruoyi.novel.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.web.client.RestTemplate;
+
+@Configuration
+public class RestTemplateConfig {
+
+    @Bean
+    public RestTemplate restTemplate() {
+        return new RestTemplate();
+    }
+}

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

@@ -0,0 +1,61 @@
+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.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+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 {
+    private static final Logger log = LoggerFactory.getLogger(ScheduledTasks.class);
+    @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-system/src/main/java/com/ruoyi/novel/config/TableSupport.java

@@ -0,0 +1,21 @@
+package com.ruoyi.novel.config;
+
+import com.ruoyi.common.core.page.PageDomain;
+import com.ruoyi.common.utils.ServletUtils;
+import com.ruoyi.novel.utils.Constants;
+
+public class TableSupport {
+
+    public static PageDomain buildPageRequest() {
+        return getPageDomain();
+    }
+
+    public static PageDomain getPageDomain() {
+        PageDomain pageDomain = new PageDomain();
+        pageDomain.setPageNum(ServletUtils.getParameterToInt(Constants.PAGE_NUM));
+        pageDomain.setPageSize(ServletUtils.getParameterToInt(Constants.PAGE_SIZE));
+        pageDomain.setOrderByColumn(ServletUtils.getParameter(Constants.ORDER_BY_COLUMN));
+        pageDomain.setIsAsc(ServletUtils.getParameter(Constants.IS_ASC));
+        return pageDomain;
+    }
+}

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

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

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

@@ -0,0 +1,37 @@
+package com.ruoyi.novel.controller;
+
+import com.ruoyi.common.core.domain.AjaxResult;
+import com.ruoyi.novel.domain.ChapterDTO;
+import com.ruoyi.novel.domain.NovelChapter;
+import com.ruoyi.novel.service.ChapterService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+// ChapterController.java
+@RestController
+@RequestMapping("/chapter")
+public class ChapterController {
+
+    @Autowired
+    private ChapterService chapterService;
+    @GetMapping("/list/{novelId}")
+    public AjaxResult listChapters(@PathVariable Long novelId) {
+        List<NovelChapter> chapters = chapterService.selectChapterListByNovelId(novelId);
+        return AjaxResult.success(chapters);
+    }
+    @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()));
+    }
+    private AjaxResult toAjax(int result) {
+        return result > 0 ? AjaxResult.success() : AjaxResult.error();
+    }
+}

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

@@ -0,0 +1,90 @@
+package com.ruoyi.novel.controller;
+//# 广告计数接口
+
+import com.ruoyi.common.core.domain.AjaxResult;
+import com.ruoyi.novel.domain.AdCountRequest;
+import com.ruoyi.novel.service.AdService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+
+import java.time.Duration;
+import java.util.Arrays;
+import java.util.List;
+
+@RestController
+@RequestMapping("/ad")
+public class NovelAdController {
+
+    private final AdService adService;
+    private final RedisTemplate<String, String> redisTemplate;
+
+    @Autowired
+    public NovelAdController(AdService adService, RedisTemplate<String, String> redisTemplate) {
+        this.adService = adService;
+        this.redisTemplate = redisTemplate;
+    }
+
+    @PostMapping("/count")
+    public ResponseEntity<?> countAdView(
+            @RequestBody AdCountRequest request,
+            @RequestHeader(value = "X-PHP-Session", required = false) String phpSessionId
+    ) {
+        // 验证请求来源
+        if (!isValidSource(request.getSource())) {
+            return ResponseEntity.status(HttpStatus.FORBIDDEN).body("Invalid source");
+        }
+
+        // 会话同步处理
+        String userId = resolveUserId(request, phpSessionId);
+
+        // 防重处理 (5分钟内同一章节只计数一次)
+        String redisKey = String.format("ad:%s:%s:%s",
+                request.getSource(), userId, request.getChapterId());
+
+        if (redisTemplate.hasKey(redisKey)) {
+            return ResponseEntity.ok("Already counted");
+        }
+
+        // 记录广告
+        adService.logAdView(
+                userId,
+                request.getChapterId(),
+                request.getAdType(),
+                request.getSource()
+        );
+
+        // 设置Redis锁
+        redisTemplate.opsForValue().set(redisKey, "1", Duration.ofMinutes(5));
+
+        return ResponseEntity.ok("Ad counted");
+    }
+    @PostMapping("/count")
+    public AjaxResult logAdView(@RequestBody AdCountRequest request) {
+        adService.logAdView(request);
+        return AjaxResult.success("广告计数成功");
+    }
+    private String resolveUserId(AdCountRequest request, String phpSessionId) {
+        // 优先使用PHP会话
+        if (phpSessionId != null) {
+            String sessionKey = "session:" + phpSessionId;
+            String userId = redisTemplate.opsForValue().get(sessionKey + ":user_id");
+            if (userId != null) return userId;
+        }
+
+        // 其次使用请求中的用户ID
+        if (request.getUserId() != null) {
+            return request.getUserId().toString();
+        }
+
+        // 最后使用设备ID
+        return request.getDeviceId();
+    }
+
+    private boolean isValidSource(String source) {
+        List<String> validSources = Arrays.asList("h5", "wechat", "douyin", "app");
+        return validSources.contains(source);
+    }
+}

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

@@ -0,0 +1,92 @@
+package com.ruoyi.novel.controller;
+
+import com.github.pagehelper.PageHelper;
+import com.github.pagehelper.PageInfo;
+import com.ruoyi.common.constant.HttpStatus;
+import com.ruoyi.common.core.domain.AjaxResult;
+import com.ruoyi.common.core.page.PageDomain;
+import com.ruoyi.common.core.page.TableDataInfo;
+import com.ruoyi.common.core.page.TableSupport;
+import com.ruoyi.novel.domain.Novel;
+import com.ruoyi.novel.mapper.NovelMapper;
+import com.ruoyi.novel.service.NovelSearchService;
+import com.ruoyi.novel.service.NovelService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+// NovelController.java
+@RestController
+@RequestMapping("/novel")
+public class NovelController {
+
+    @Autowired
+    private NovelService novelService;
+    @Autowired
+    private NovelSearchService searchService;
+    @Autowired
+    private NovelMapper novelMapper;
+    @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));
+    }
+    @DeleteMapping("/{ids}")
+    public AjaxResult remove(@PathVariable Long[] ids) {
+        return toAjax(novelService.deleteNovelByIds(ids));
+    }
+
+    private AjaxResult toAjax(int rows) {
+        return rows > 0 ? AjaxResult.success() : AjaxResult.error();
+    }
+    // 若依框架的分页方法
+    protected void startPage() {
+        PageDomain pageDomain = TableSupport.buildPageRequest();
+        Integer pageNum = pageDomain.getPageNum();
+        Integer pageSize = pageDomain.getPageSize();
+        PageHelper.startPage(pageNum, pageSize);
+    }
+
+    // 若依框架的表格数据封装
+    protected TableDataInfo getDataTable(List<?> list) {
+        TableDataInfo rspData = new TableDataInfo();
+        rspData.setCode(HttpStatus.SUCCESS);
+        rspData.setRows(list);
+        rspData.setTotal(new PageInfo(list).getTotal());
+        return rspData;
+    }
+    // 其他接口...
+    @GetMapping("/search")
+    public AjaxResult searchNovels(@RequestParam String keyword) {
+        List<Novel> novels = searchService.searchNovels(keyword);
+        return AjaxResult.success(novels);
+    }
+
+    @PostMapping
+    public AjaxResult addNovel(@RequestBody Novel novel) {
+        novelMapper.insert(novel);
+        searchService.indexNovel(novel); // 创建索引
+        return AjaxResult.success();
+    }
+
+    @PutMapping
+    public AjaxResult updateNovel(@RequestBody Novel novel) {
+        novelMapper.updateById(novel);
+        searchService.updateNovelIndex(novel); // 更新索引
+        return AjaxResult.success();
+    }
+
+    @DeleteMapping("/{id}")
+    public AjaxResult deleteNovel(@PathVariable Long id) {
+        novelMapper.deleteById(id);
+        searchService.deleteNovelIndex(id); // 删除索引
+        return AjaxResult.success();
+    }
+}

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

@@ -0,0 +1,30 @@
+package com.ruoyi.novel.controller;
+
+import com.ruoyi.common.core.domain.AjaxResult;
+import com.ruoyi.novel.domain.RoyaltyReport;
+import com.ruoyi.novel.service.IFinanceService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.format.annotation.DateTimeFormat;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+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-system/src/main/java/com/ruoyi/novel/controller/NovelVoteController.java

@@ -0,0 +1,54 @@
+package com.ruoyi.novel.controller;
+
+import com.google.common.util.concurrent.RateLimiter;
+import com.ruoyi.common.core.domain.AjaxResult;
+import com.ruoyi.novel.domain.VoteRequest;
+import com.ruoyi.novel.service.IVoteService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.concurrent.ConcurrentHashMap;
+
+//# 剧情投票接口
+// 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)
+        );
+        // 1. 检查用户投票频率
+//        if (!voteService.canUserVote(request.getUserId())) {
+//            return AjaxResult.error("投票过于频繁，请稍后再试");
+//        }
+        if (!rateLimiter.tryAcquire()) {
+            return AjaxResult.error("投票过于频繁，请稍后再试");
+        }
+
+        // 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-system/src/main/java/com/ruoyi/novel/controller/ReadingHistoryController.java

@@ -0,0 +1,28 @@
+package com.ruoyi.novel.controller;
+
+import com.ruoyi.common.core.domain.AjaxResult;
+import com.ruoyi.novel.domain.ReadingRecord;
+import com.ruoyi.novel.service.ReadingHistoryService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+@RestController
+@RequestMapping("/history")
+public class ReadingHistoryController {
+    @Autowired
+    private ReadingHistoryService historyService;
+    @PostMapping("/record")
+    public AjaxResult recordReading(@RequestBody ReadingRecord record) {
+        // 记录用户阅读位置
+        historyService.recordReading(record);
+        return AjaxResult.success("阅读记录已保存");
+    }
+
+    @GetMapping("/last/{userId}/{novelId}")
+    public AjaxResult getLastPosition(
+            @PathVariable Long userId,
+            @PathVariable Long novelId) {
+        ReadingRecord record = historyService.getLastPosition(userId, novelId);
+        return AjaxResult.success(record);
+    }
+}

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

@@ -0,0 +1,27 @@
+package com.ruoyi.novel.domain;
+
+import lombok.Data;
+
+import javax.validation.constraints.NotBlank;
+import javax.validation.constraints.NotNull;
+
+// AdCountRequest.java
+@Data
+public class AdCountRequest {
+    @NotNull(message = "用户ID不能为空")
+    private Long userId;
+
+    @NotNull(message = "章节ID不能为空")
+    private Long chapterId;
+
+    @NotBlank(message = "广告平台不能为空")
+    private String adPlatform;
+
+    @NotBlank(message = "设备ID不能为空")
+    private String deviceId;
+
+    public String source;
+
+    public String adType;
+
+}

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

@@ -0,0 +1,40 @@
+package com.ruoyi.novel.domain;
+
+import com.baomidou.mybatisplus.annotation.*;
+import lombok.Data;
+
+import javax.validation.constraints.NotBlank;
+import javax.validation.constraints.NotNull;
+import javax.validation.constraints.Size;
+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;
+
+    // 确保有默认构造方法
+    public AdLog() {}
+
+    public String deviceId;
+}

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

@@ -0,0 +1,26 @@
+package com.ruoyi.novel.domain;
+
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+@Data
+@TableName("novel_ad_config")
+public class AdPlatformConfig {
+    @TableId
+    private String platformCode;
+
+    private String platformName;
+    private String apiUrl;
+    private String authToken;
+    private String paramsTemplate;
+
+    // 添加带参数的构造方法
+    public AdPlatformConfig(String code, String name, String url, String token, String params) {
+        this.platformCode = code;
+        this.platformName = name;
+        this.apiUrl = url;
+        this.authToken = token;
+        this.paramsTemplate = params;
+    }
+}

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

@@ -0,0 +1,15 @@
+package com.ruoyi.novel.domain;
+
+import lombok.Data;
+
+import javax.validation.constraints.NotBlank;
+import javax.validation.constraints.NotNull;
+
+@Data
+public class ChapterDTO {
+    @NotNull(message = "章节不能为空")
+    private NovelChapter chapter;
+
+    @NotBlank(message = "内容不能为空")
+    private String content;
+}

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

@@ -0,0 +1,39 @@
+package com.ruoyi.novel.domain;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import org.springframework.data.annotation.Id;
+import org.springframework.data.elasticsearch.annotations.Document;
+import org.springframework.data.elasticsearch.annotations.Field;
+import org.springframework.data.elasticsearch.annotations.FieldType;
+
+import java.util.Date;
+
+// Novel.java
+@Data
+@TableName("novel")
+@Document(indexName = "novels")
+public class Novel {
+    @Id
+    @TableId(type = IdType.AUTO)
+    private Long id;
+    @Field(type = FieldType.Text, analyzer = "ik_max_word")
+    private String title;
+    @Field(type = FieldType.Keyword)
+    private String author;
+    private String coverImg;
+    @Field(type = FieldType.Long)
+    private Long categoryId;
+    @Field(type = FieldType.Keyword)
+    private String status;// 连载/完本
+    @Field(type = FieldType.Text, analyzer = "ik_smart")
+    private String description;
+    private Long wordCount;
+    @Field(type = FieldType.Long)
+    private Long readCount;
+    @Field(type = FieldType.Date)
+    private Date createTime;
+    private Date updateTime;
+}

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

@@ -0,0 +1,25 @@
+package com.ruoyi.novel.domain;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.util.Date;
+
+// NovelChapter.java
+@Data
+@TableName("novel_chapter")
+public class NovelChapter {
+    @TableId(type = IdType.AUTO)
+    private Long id;
+    private Long novelId;
+    private String chapterTitle;
+    private Integer chapterOrder;
+    private Date publishTime;
+    private String isVip;
+
+    public Date createTime;
+
+    public Date updateTime;
+}

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

@@ -0,0 +1,14 @@
+package com.ruoyi.novel.domain;
+
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+// NovelContent.java
+@Data
+@TableName("novel_content")
+public class NovelContent {
+    @TableId
+    private Long chapterId;
+    private String content;
+}

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

@@ -0,0 +1,27 @@
+package com.ruoyi.novel.domain;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import javax.validation.constraints.NotNull;
+import java.util.Date;
+
+@Data
+@TableName("reading_history")
+public class ReadingRecord {
+    @TableId(type = IdType.AUTO)
+    private Long id;
+    @NotNull(message = "用户ID不能为空")
+    private Long userId;
+
+    @NotNull(message = "章节ID不能为空")
+    private Long chapterId;
+
+    @NotNull(message = "小说ID不能为空")
+    private Long novelId;
+    private Integer progress;
+    private Long position;
+    private Date lastReadTime;
+}

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

@@ -0,0 +1,30 @@
+package com.ruoyi.novel.domain;
+
+import lombok.Data;
+
+import java.math.BigDecimal;
+
+// 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-system/src/main/java/com/ruoyi/novel/domain/RoyaltySummary.java

@@ -0,0 +1,26 @@
+package com.ruoyi.novel.domain;
+
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.math.BigDecimal;
+import java.util.Date;
+
+// 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;
+
+    public RoyaltySummary(long l, String s, BigDecimal bigDecimal) {
+    }
+}

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

@@ -0,0 +1,26 @@
+package com.ruoyi.novel.domain;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import javax.validation.constraints.NotBlank;
+import javax.validation.constraints.NotNull;
+
+// StoryOption.java
+@Data
+//@TableName("novel_story_option")
+@TableName("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-system/src/main/java/com/ruoyi/novel/domain/VoteRecord.java

@@ -0,0 +1,26 @@
+package com.ruoyi.novel.domain;
+
+import com.baomidou.mybatisplus.annotation.*;
+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;
+
+    private String generatedContent;
+
+    private Integer notifyStatus; // 0-未通知 1-已通知
+}

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

@@ -0,0 +1,18 @@
+package com.ruoyi.novel.domain;
+
+import lombok.Data;
+
+import javax.validation.constraints.NotNull;
+
+// 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-system/src/main/java/com/ruoyi/novel/exception/GlobalExceptionHandler.java

@@ -0,0 +1,44 @@
+package com.ruoyi.novel.exception;
+
+import com.ruoyi.common.core.domain.AjaxResult;
+import com.ruoyi.common.exception.ServiceException;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.web.bind.MethodArgumentNotValidException;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.bind.annotation.RestControllerAdvice;
+
+
+// 新增全局异常处理器
+@RestControllerAdvice
+public class GlobalExceptionHandler {
+
+    private static final Logger logger = LoggerFactory.getLogger(GlobalExceptionHandler.class);
+
+    /**
+     * 业务异常处理
+     */
+    @ExceptionHandler(ServiceException.class)
+    public AjaxResult handleServiceException(ServiceException e) {
+        logger.error(e.getMessage(), e);
+        return AjaxResult.error(e.getMessage());
+    }
+
+    /**
+     * 参数校验异常
+     */
+    @ExceptionHandler(MethodArgumentNotValidException.class)
+    public AjaxResult handleMethodArgumentNotValidException(MethodArgumentNotValidException e) {
+        String message = e.getBindingResult().getFieldError().getDefaultMessage();
+        return AjaxResult.error(message);
+    }
+
+    /**
+     * 系统异常
+     */
+    @ExceptionHandler(Exception.class)
+    public AjaxResult handleException(Exception e) {
+        logger.error(e.getMessage(), e);
+        return AjaxResult.error("系统繁忙，请稍后再试");
+    }
+}

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

@@ -0,0 +1,20 @@
+package com.ruoyi.novel.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.ruoyi.novel.domain.AdLog;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
+
+import java.util.List;
+
+// 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-system/src/main/java/com/ruoyi/novel/mapper/AdPlatformConfigMapper.java

@@ -0,0 +1,8 @@
+package com.ruoyi.novel.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.ruoyi.novel.domain.AdPlatformConfig;
+
+public interface AdPlatformConfigMapper extends BaseMapper<AdPlatformConfig> {
+    // 继承BaseMapper即拥有selectList/insert等方法
+}

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

@@ -0,0 +1,26 @@
+package com.ruoyi.novel.mapper;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.ruoyi.novel.domain.NovelChapter;
+import org.apache.ibatis.annotations.Mapper;
+
+import java.util.List;
+
+// NovelChapterMapper.java
+@Mapper
+public interface NovelChapterMapper {
+    List<NovelChapter> selectChapterListByNovelId(Long novelId);
+    NovelChapter selectChapterById(Long chapterId);
+    int insertChapter(NovelChapter chapter);
+    int updateChapter(NovelChapter chapter);
+
+    List<NovelChapter> selectList(QueryWrapper<NovelChapter> orderByAsc);
+
+    void insert(NovelChapter chapter);
+
+    void updateById(NovelChapter chapter);
+
+    NovelChapter selectById(Long chapterId);
+
+    int deleteBatchIds(List<Long> asList);
+}

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

@@ -0,0 +1,14 @@
+package com.ruoyi.novel.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.ruoyi.novel.domain.NovelContent;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Update;
+
+@Mapper
+public interface NovelContentMapper extends BaseMapper<NovelContent> {
+    // 特殊方法可在此定义
+    @Update("UPDATE novel_content SET content = #{content} WHERE chapter_id = #{chapterId}")
+    int updateContent(@Param("chapterId") Long chapterId, @Param("content") String content);
+}

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

@@ -0,0 +1,32 @@
+package com.ruoyi.novel.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.ruoyi.novel.domain.Novel;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
+import org.apache.ibatis.annotations.Update;
+
+import java.util.List;
+
+// NovelMapper.java
+public interface NovelMapper extends BaseMapper<Novel> {
+    List<Novel> selectNovelList(Novel novel);
+    Novel selectNovelById(Long id);
+    int insertNovel(Novel novel);
+    int updateNovel(Novel novel);
+    int deleteNovelByIds(Long[] ids);
+
+    // 以下方法已由MyBatis-Plus实现，无需额外代码
+    // int updateById(Novel novel);
+    // int deleteBatchIds(@Param("ids") List<Long> ids);
+    // Novel selectById(Long id);
+
+    // 自定义方法：根据分类ID查询小说
+    @Select("SELECT * FROM novel WHERE category_id = #{categoryId}")
+    List<Novel> selectByCategoryId(Long categoryId);
+
+    // 自定义方法：更新阅读量
+    @Update("UPDATE novel SET read_count = read_count + #{increment} WHERE id = #{id}")
+    int incrementReadCount(@Param("id") Long id, @Param("increment") Long increment);
+}
+

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

@@ -0,0 +1,34 @@
+package com.ruoyi.novel.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.ruoyi.novel.domain.ReadingRecord;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
+import org.apache.ibatis.annotations.Update;
+
+// ReadingHistoryMapper.java
+@Mapper
+public interface ReadingHistoryMapper extends BaseMapper<ReadingRecord> {
+
+    // 根据用户和章节查询记录
+    @Select("SELECT * FROM reading_history " +
+            "WHERE user_id = #{userId} AND chapter_id = #{chapterId}")
+    ReadingRecord selectByUserAndChapter(@Param("userId") Long userId,
+                                         @Param("chapterId") Long chapterId);
+
+    // 获取用户最后阅读位置
+    @Select("SELECT * FROM reading_history " +
+            "WHERE user_id = #{userId} AND novel_id = #{novelId} " +
+            "ORDER BY last_read_time DESC LIMIT 1")
+    ReadingRecord selectLastPosition(@Param("userId") Long userId,
+                                     @Param("novelId") Long novelId);
+
+    // 更新阅读进度
+    @Update("UPDATE reading_history SET " +
+            "progress = #{progress}, " +
+            "position = #{position}, " +
+            "last_read_time = NOW() " +
+            "WHERE id = #{id}")
+    int updateReadingProgress(ReadingRecord record);
+}

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

@@ -0,0 +1,33 @@
+package com.ruoyi.novel.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.ruoyi.novel.domain.RoyaltySummary;
+import org.apache.ibatis.annotations.*;
+
+// 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);
+
+
+    // 添加 insertOrUpdate 方法
+    @Insert("<script>" +
+            "INSERT INTO novel_royalty_summary (author_id, month, total_reads, last_sync_time) " +
+            "VALUES (#{authorId}, #{month}, #{totalReads}, NOW()) " +
+            "ON DUPLICATE KEY UPDATE " +
+            "total_reads = VALUES(total_reads), " +
+            "last_sync_time = NOW()" +
+            "</script>")
+    int insertOrUpdate(RoyaltySummary summary);
+}

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

@@ -0,0 +1,40 @@
+package com.ruoyi.novel.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.ruoyi.novel.domain.StoryOption;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
+import org.apache.ibatis.annotations.Update;
+
+import java.util.List;
+
+// StoryOptionMapper.java
+@Mapper
+public interface StoryOptionMapper extends BaseMapper<StoryOption> {
+
+    // 增加选项投票数
+    @Update("UPDATE story_option SET vote_count = vote_count + 1 WHERE id = #{optionId}")
+    int incrementVoteCount(@Param("optionId") Long optionId);
+
+    // 根据章节ID获取选项
+    @Select("SELECT * FROM story_option WHERE chapter_id = #{chapterId} ORDER BY sort_order")
+    List<StoryOption> selectByChapterId(Long chapterId);
+
+    // 批量更新选项投票数
+    @Update("<script>" +
+            "UPDATE story_option SET vote_count = CASE id " +
+            "<foreach collection='options' item='opt'>" +
+            "WHEN #{opt.id} THEN #{opt.voteCount} " +
+            "</foreach>" +
+            "END WHERE id IN " +
+            "<foreach collection='options' item='opt' open='(' separator=',' close=')'>" +
+            "#{opt.id}" +
+            "</foreach>" +
+            "</script>")
+    int batchUpdateVoteCount(@Param("options") List<StoryOption> options);
+
+    @Update("UPDATE story_option SET vote_count = vote_count + 1 WHERE id = #{optionId}")
+    int incrementOptionVote(@Param("optionId") Long optionId);
+
+}

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

@@ -0,0 +1,46 @@
+package com.ruoyi.novel.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.ruoyi.novel.domain.VoteRecord;
+import lombok.Data;
+import org.apache.ibatis.annotations.*;
+
+import java.util.List;
+
+// 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();
+
+
+    // 插入投票记录（带生成内容）
+    @Insert("INSERT INTO vote_record (user_id, story_id, option_id, vote_time, generated_content) " +
+            "VALUES (#{userId}, #{storyId}, #{optionId}, NOW(), #{generatedContent})")
+    @Options(useGeneratedKeys = true, keyProperty = "id")
+    int insertVoteRecord(VoteRecord record);
+
+    // 获取用户投票记录
+    @Select("SELECT * FROM vote_record WHERE user_id = #{userId} ORDER BY vote_time DESC")
+    List<VoteRecord> selectByUserId(Long userId);
+
+    // 获取故事投票统计
+    @Select("SELECT option_id, COUNT(*) AS vote_count FROM vote_record " +
+            "WHERE story_id = #{storyId} GROUP BY option_id")
+    List<VoteStats> getVoteStatsByStory(Long storyId);
+
+    // 投票统计DTO
+    @Data
+    class VoteStats {
+        private Long optionId;
+        private Integer voteCount;
+    }
+}

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

@@ -0,0 +1,10 @@
+package com.ruoyi.novel.service;
+
+import com.ruoyi.novel.domain.AdPlatformConfig;
+
+public interface AdConfigService {
+
+    void refreshConfigCache();
+
+    AdPlatformConfig getConfig(String adPlatform);
+}

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

@@ -0,0 +1,9 @@
+package com.ruoyi.novel.service;
+
+import com.ruoyi.novel.domain.AdLog;
+import org.springframework.transaction.annotation.Transactional;
+
+public interface AdLogService {
+    @Transactional
+    void logAdView(AdLog adLog);
+}

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

@@ -0,0 +1,15 @@
+package com.ruoyi.novel.service;
+
+import com.ruoyi.novel.domain.AdCountRequest;
+import com.ruoyi.novel.domain.AdLog;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+@Service
+// AdService.java
+public interface AdService {
+    void logAdView(AdCountRequest request);
+    List<AdLog> getAdLogsByUser(Long userId);
+
+    void logAdView(String userId, Long chapterId, String adType, String source);
+}

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

@@ -0,0 +1,10 @@
+package com.ruoyi.novel.service;
+
+import com.ruoyi.novel.domain.AdLog;
+import com.ruoyi.novel.domain.AdPlatformConfig;
+
+public interface AdSyncService {
+    void syncToTencent(AdLog adLog, AdPlatformConfig config);
+
+    void syncToPangle(AdLog adLog, AdPlatformConfig config);
+}

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

@@ -0,0 +1,13 @@
+package com.ruoyi.novel.service;
+
+import com.ruoyi.novel.domain.NovelChapter;
+
+import java.util.List;
+
+// ChapterService.java
+public interface ChapterService {
+    List<NovelChapter> selectChapterListByNovelId(Long novelId);
+    int saveChapter(NovelChapter chapter, String content);
+    NovelChapter getChapterById(Long chapterId);
+    int deleteChapters(Long[] ids);
+}

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

@@ -0,0 +1,22 @@
+package com.ruoyi.novel.service;
+
+import com.ruoyi.novel.domain.AdCountRequest;
+import com.ruoyi.novel.domain.AdLog;
+import com.ruoyi.novel.domain.AdPlatformConfig;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+import java.util.Map;
+
+@Service
+public interface IAdService {
+    void logAdView(AdLog adLog);
+
+    void logAdView(AdCountRequest request);
+
+    List<AdLog> getAdLogsByUser(Long userId);
+
+    void syncWithAdPlatform(AdLog adLog);
+    void retryFailedSyncs();
+    Map<String, AdPlatformConfig> loadAdConfigs();
+}

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

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

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

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

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

@@ -0,0 +1,13 @@
+package com.ruoyi.novel.service;
+
+import com.ruoyi.novel.domain.Novel;
+
+import java.util.List;
+
+// NovelSearchService.java
+public interface NovelSearchService {
+    List<Novel> searchNovels(String keyword);
+    void indexNovel(Novel novel);
+    void updateNovelIndex(Novel novel);
+    void deleteNovelIndex(Long id);
+}

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

@@ -0,0 +1,16 @@
+package com.ruoyi.novel.service;
+
+import com.ruoyi.novel.domain.Novel;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+
+public interface NovelService {
+    List<Novel> selectNovelList(Novel novel);
+
+    @Transactional
+    int insertNovel(Novel novel);
+    int updateNovel(Novel novel);
+    int deleteNovelByIds(Long[] ids);
+    Novel selectNovelById(Long id);
+}

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

@@ -0,0 +1,9 @@
+package com.ruoyi.novel.service;
+
+import com.ruoyi.novel.domain.ReadingRecord;
+
+// ReadingHistoryService.java
+public interface ReadingHistoryService {
+    void recordReading(ReadingRecord record);
+    ReadingRecord getLastPosition(Long userId, Long novelId);
+}

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

@@ -0,0 +1,29 @@
+package com.ruoyi.novel.service;
+
+import com.ruoyi.novel.domain.VoteRecord;
+import com.ruoyi.novel.domain.VoteRequest;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.scheduling.annotation.Scheduled;
+
+// VoteService.java
+public interface VoteService {
+    String processVote(VoteRequest request);
+
+    String generateStoryContent(Long storyId, Long optionId);
+
+    @Async("voteTaskExecutor")
+    void generateStoryContent(VoteRecord record);
+
+    void notifyPhpSystem(VoteRequest request, String content);
+
+    // 添加方法实现
+    void incrementOptionVote(Long optionId);
+
+    boolean canUserVote(Long userId);
+
+    @Async("voteTaskExecutor")
+    void notifyPhpSystem(VoteRecord record);
+
+    @Scheduled(cron = "0 */10 * * * ?") // 每10分钟执行一次
+    void retryFailedNotifications();
+}

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

@@ -0,0 +1,69 @@
+package com.ruoyi.novel.service.impl;
+
+import com.ruoyi.novel.domain.AdPlatformConfig;
+import com.ruoyi.novel.mapper.AdPlatformConfigMapper;
+import com.ruoyi.novel.service.AdConfigService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.PostConstruct;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.function.Function;
+import java.util.stream.Collectors;
+
+// AdConfigServiceImpl.java
+@Service
+public class AdConfigServiceImpl implements AdConfigService {
+
+    @Autowired
+    private AdPlatformConfigMapper configMapper;
+
+    private Map<String, AdPlatformConfig> adConfigCache;
+    private final Object lock = new Object();
+
+    @PostConstruct
+    public void init() {
+        refreshConfigCache();
+    }
+
+    @Override
+    public void refreshConfigCache() {
+        synchronized (lock) {
+            adConfigCache = configMapper.selectList(null).stream()
+                    .collect(Collectors.toMap(AdPlatformConfig::getPlatformCode, Function.identity()));
+
+            // 如果数据库为空，初始化默认配置
+            if (adConfigCache.isEmpty()) {
+                initDefaultConfigs();
+            }
+        }
+    }
+
+    private void initDefaultConfigs() {
+        adConfigCache = new HashMap<>();
+        adConfigCache.put("tencent", new AdPlatformConfig(
+                "tencent", "腾讯广告",
+                "https://ad.tencent.com/track",
+                "default_tencent_token",
+                "{\"user_id\":\"${userId}\",\"content_id\":\"${chapterId}\"}"
+        ));
+        adConfigCache.put("pangle", new AdPlatformConfig(
+                "pangle", "穿山甲",
+                "https://ad.pangle.com/api/v1/event",
+                "default_pangle_token",
+                "{\"user\":\"${userId}\",\"content_id\":\"${chapterId}\"}"
+        ));
+
+        // 保存默认配置到数据库
+        adConfigCache.values().forEach(configMapper::insert);
+    }
+
+    @Override
+    public AdPlatformConfig getConfig(String platformCode) {
+        if (adConfigCache == null) {
+            refreshConfigCache();
+        }
+        return adConfigCache.get(platformCode);
+    }
+}

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

@@ -0,0 +1,88 @@
+package com.ruoyi.novel.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.ruoyi.common.exception.ServiceException;
+import com.ruoyi.novel.domain.AdLog;
+import com.ruoyi.novel.domain.AdPlatformConfig;
+import com.ruoyi.novel.mapper.AdLogMapper;
+import com.ruoyi.novel.service.AdConfigService;
+import com.ruoyi.novel.service.AdLogService;
+import com.ruoyi.novel.service.AdSyncService;
+import lombok.extern.slf4j.Slf4j;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+
+// AdLogServiceImpl.java
+@Service
+@Slf4j
+public class AdLogServiceImpl implements AdLogService {
+    private static final Logger logger = LoggerFactory.getLogger(AdLogServiceImpl.class);
+
+    @Autowired
+    private AdLogMapper adLogMapper;
+
+    @Autowired
+    private AdConfigService adConfigService;
+
+    @Autowired
+    private AdSyncService adSyncService;
+
+    @Override
+    @Transactional
+    public void logAdView(AdLog adLog) {
+        // 1. 保存到数据库
+        adLog.setSyncStatus(0); // 0=未同步
+        adLogMapper.insert(adLog);
+
+        // 2. 异步同步到广告平台
+        syncAdLogAsync(adLog);
+    }
+
+    @Async
+    public void syncAdLogAsync(AdLog adLog) {
+        try {
+            AdPlatformConfig config = adConfigService.getConfig(adLog.getAdPlatform());
+            if (config == null) {
+                throw new ServiceException("广告平台配置不存在: " + adLog.getAdPlatform());
+            }
+
+            // 根据平台选择同步方式
+            switch (adLog.getAdPlatform()) {
+                case "tencent":
+                    adSyncService.syncToTencent(adLog, config);
+                    break;
+                case "pangle":
+                    adSyncService.syncToPangle(adLog, config);
+                    break;
+                default:
+                    throw new ServiceException("不支持的广告平台: " + adLog.getAdPlatform());
+            }
+
+            // 更新同步状态
+            adLog.setSyncStatus(1); // 1=同步成功
+        } catch (Exception e) {
+            log.error("广告同步失败: {}", e.getMessage());
+            adLog.setSyncStatus(2); // 2=同步失败
+        }
+        adLogMapper.updateById(adLog);
+    }
+
+    @Scheduled(fixedRate = 300000) // 每5分钟执行一次
+    public void retryFailedSyncs() {
+        List<AdLog> failedLogs = adLogMapper.selectList(
+                new QueryWrapper<AdLog>().eq("sync_status", 2)
+        );
+
+        failedLogs.forEach(log -> {
+            logger.info("重试广告同步: ID={}, 平台={}", log.getId(), log.getAdPlatform());
+            syncAdLogAsync(log);
+        });
+    }
+}

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

@@ -0,0 +1,130 @@
+package com.ruoyi.novel.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.ruoyi.novel.domain.AdCountRequest;
+import com.ruoyi.novel.domain.AdLog;
+import com.ruoyi.novel.domain.AdPlatformConfig;
+import com.ruoyi.novel.mapper.AdLogMapper;
+import com.ruoyi.novel.service.IAdService;
+import com.ruoyi.novel.utils.AdPlatformClient;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.Date;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@Service
+public class AdServiceImpl implements IAdService {
+    private static final Logger logger = LoggerFactory.getLogger(AdServiceImpl.class);
+    @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) {
+            logger.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) {
+//            logger.error("Ad sync failed: {}", e.getMessage());
+//            adLog.setSyncStatus(2); // 同步失败
+//        }
+//        adLogMapper.updateById(adLog);
+//    }
+
+    @Override
+    @Scheduled(fixedRateString = "${scheduled.ad-retry-interval:300000}") // 默认5分钟重试
+    public void retryFailedSyncs() {
+        List<AdLog> failedLogs = adLogMapper.selectList(
+                new QueryWrapper<AdLog>().eq("sync_status", 2) // 2=同步失败状态
+        );
+        failedLogs.forEach(adLog -> {
+            try {
+                syncWithAdPlatform(adLog);  // 调用同步方法
+                adLog.setSyncStatus(1);      // 更新为成功状态
+                adLogMapper.updateById(adLog);
+            } catch (Exception e) {
+                logger.error("广告同步重试失败: ID={}", adLog.getId(), e);
+            }
+        });
+    }
+
+    @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
+    public void logAdView(AdCountRequest request) {
+        AdLog log = new AdLog();
+        log.setUserId(request.getUserId());
+        log.setChapterId(request.getChapterId());
+        log.setAdPlatform(request.getAdPlatform());
+        log.setDeviceId(request.getDeviceId());
+        log.setViewTime(new Date());
+        log.setSyncStatus(0); // 未同步
+
+        adLogMapper.insert(log);
+    }
+    @Override
+    public List<AdLog> getAdLogsByUser(Long userId) {
+        return adLogMapper.selectList(
+                new QueryWrapper<AdLog>().eq("user_id", userId)
+        );
+    }
+    @Override
+    public void syncWithAdPlatform(AdLog adLog) {
+        // 根据平台选择不同实现
+        switch (adLog.getAdPlatform()) {
+            case "tencent":
+                adPlatformClient.syncTencent(adLog);
+                adLog.setSyncStatus(1); // 同步成功
+                break;
+            case "pangle":
+                adPlatformClient.syncPangle(adLog);
+                adLog.setSyncStatus(1); // 同步成功
+                break;
+            default:
+                logger.warn("Unknown ad platform: {}", adLog.getAdPlatform());
+        }
+    }
+}

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

@@ -0,0 +1,82 @@
+package com.ruoyi.novel.service.impl;
+
+import com.ruoyi.common.exception.ServiceException;
+import com.ruoyi.novel.domain.AdLog;
+import com.ruoyi.novel.domain.AdPlatformConfig;
+import com.ruoyi.novel.service.AdSyncService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.*;
+import org.springframework.stereotype.Service;
+import org.springframework.web.client.RestTemplate;
+import org.springframework.web.util.UriComponentsBuilder;
+
+// AdSyncServiceImpl.java
+@Service
+@Slf4j
+public class AdSyncServiceImpl implements AdSyncService {
+
+    @Autowired
+    private RestTemplate restTemplate;
+
+    @Override
+    public void syncToTencent(AdLog adLog, AdPlatformConfig config) {
+        // 1. 构建请求参数
+        String payload = buildTencentPayload(adLog, config);
+
+        // 2. 创建请求头
+        HttpHeaders headers = new HttpHeaders();
+        headers.setContentType(MediaType.APPLICATION_JSON);
+        headers.setBearerAuth(config.getAuthToken());
+
+        // 3. 发送请求
+        HttpEntity<String> entity = new HttpEntity<>(payload, headers);
+        ResponseEntity<String> response = restTemplate.postForEntity(
+                config.getApiUrl(), entity, String.class);
+
+        // 4. 处理响应
+        if (response.getStatusCode() != HttpStatus.OK) {
+            throw new ServiceException("腾讯广告同步失败: " + response.getBody());
+        }
+        log.info("腾讯广告同步成功: chapter={}, user={}", adLog.getChapterId(), adLog.getUserId());
+    }
+
+    private String buildTencentPayload(AdLog adLog, AdPlatformConfig config) {
+        // 使用模板生成请求体
+        return config.getParamsTemplate()
+                .replace("${userId}", adLog.getUserId().toString())
+                .replace("${chapterId}", adLog.getChapterId().toString())
+                .replace("${timestamp}", String.valueOf(System.currentTimeMillis()));
+    }
+
+    @Override
+    public void syncToPangle(AdLog adLog, AdPlatformConfig config) {
+        // 1. 构建请求URL
+        String url = buildPangleUrl(adLog, config);
+
+        // 2. 创建请求头
+        HttpHeaders headers = new HttpHeaders();
+        headers.setBearerAuth(config.getAuthToken());
+
+        // 3. 发送请求
+        HttpEntity<?> entity = new HttpEntity<>(headers);
+        ResponseEntity<String> response = restTemplate.exchange(
+                url, HttpMethod.GET, entity, String.class);
+
+        // 4. 处理响应
+        if (response.getStatusCode() != HttpStatus.OK) {
+            throw new ServiceException("穿山甲同步失败: " + response.getBody());
+        }
+        log.info("穿山甲同步成功: chapter={}, user={}", adLog.getChapterId(), adLog.getUserId());
+    }
+
+    private String buildPangleUrl(AdLog adLog, AdPlatformConfig config) {
+        // 构建带参数的URL
+        return UriComponentsBuilder.fromHttpUrl(config.getApiUrl())
+                .queryParam("user", adLog.getUserId())
+                .queryParam("content_id", adLog.getChapterId())
+                .queryParam("event", "ad_view")
+                .queryParam("ts", System.currentTimeMillis())
+                .toUriString();
+    }
+}

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

@@ -0,0 +1,73 @@
+package com.ruoyi.novel.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.ruoyi.novel.domain.NovelChapter;
+import com.ruoyi.novel.domain.NovelContent;
+import com.ruoyi.novel.mapper.NovelChapterMapper;
+import com.ruoyi.novel.mapper.NovelContentMapper;
+import com.ruoyi.novel.service.ChapterService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.Arrays;
+import java.util.Date;
+import java.util.List;
+
+// ChapterServiceImpl.java
+@Service
+public class ChapterServiceImpl implements ChapterService {
+
+    @Autowired
+    private NovelChapterMapper chapterMapper;
+
+    @Autowired
+    private NovelContentMapper contentMapper;
+
+    @Override
+    public List<NovelChapter> selectChapterListByNovelId(Long novelId) {
+        return chapterMapper.selectList(
+                new QueryWrapper<NovelChapter>()
+                        .eq("novel_id", novelId)
+                        .orderByAsc("chapter_order")
+        );
+    }
+
+    @Override
+    @Transactional
+    public int saveChapter(NovelChapter chapter, String content) {
+        if (chapter.getId() == null) {
+            // 新增章节
+            chapter.setCreateTime(new Date());
+            chapterMapper.insert(chapter);
+
+            NovelContent novelContent = new NovelContent();
+            novelContent.setChapterId(chapter.getId());
+            novelContent.setContent(content);
+            return contentMapper.insert(novelContent);
+        } else {
+            // 更新章节
+            chapter.setUpdateTime(new Date());
+            chapterMapper.updateById(chapter);
+
+            NovelContent novelContent = new NovelContent();
+            novelContent.setChapterId(chapter.getId());
+            novelContent.setContent(content);
+            return contentMapper.updateById(novelContent);
+        }
+    }
+
+    @Override
+    public NovelChapter getChapterById(Long chapterId) {
+        return chapterMapper.selectById(chapterId);
+    }
+
+    @Override
+    @Transactional
+    public int deleteChapters(Long[] ids) {
+        // 删除章节内容
+        contentMapper.deleteBatchIds(Arrays.asList(ids));
+        // 删除章节
+        return chapterMapper.deleteBatchIds(Arrays.asList(ids));
+    }
+}

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

@@ -0,0 +1,210 @@
+package com.ruoyi.novel.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.ruoyi.common.exception.ServiceException;
+import com.ruoyi.novel.domain.AdLog;
+import com.ruoyi.novel.domain.RoyaltyReport;
+import com.ruoyi.novel.domain.RoyaltySummary;
+import com.ruoyi.novel.mapper.AdLogMapper;
+import com.ruoyi.novel.mapper.RoyaltySummaryMapper;
+import com.ruoyi.novel.service.IAdService;
+import com.ruoyi.novel.service.IFinanceService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.http.*;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Service;
+import org.springframework.web.client.RestTemplate;
+
+import java.math.BigDecimal;
+import java.util.Arrays;
+import java.util.List;
+
+// FinanceServiceImpl.java
+@Service
+public class FinanceServiceImpl implements IFinanceService {
+    private static final Logger logger = LoggerFactory.getLogger(FinanceServiceImpl.class);
+    @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("${php.data.url}")
+    private String phpDataUrl;
+
+    @Autowired
+    private AdLogMapper adLogMapper; // 确保已注入
+
+    @Autowired
+    private IAdService adService; // 确保已注入
+
+    //@Value("${handling.fee.rate}")
+    //private BigDecimal handlingFeeRate;
+
+    @Override
+    public RoyaltyReport calculateRoyalty(Long authorId, String month) {
+        // 1. 从PHP系统拉取数据（补充缺失的调用）
+//        RoyaltySummary summary = phpApiClient.getAuthorRoyaltySummary(authorId, month);
+//        // 2. 计算分成金额（补充业务逻辑）
+//        BigDecimal royaltyRate = getRoyaltyRate(authorId);
+//        BigDecimal grossAmount = summary.getTotalReads().multiply(royaltyRate);
+//        BigDecimal handlingFee = grossAmount.multiply(handlingFeeRate);
+//        BigDecimal netAmount = grossAmount.subtract(handlingFee);
+//        // 3. 构建报表对象
+//        return new RoyaltyReport(authorId, month, summary.getTotalReads(),
+//                royaltyRate, handlingFeeRate, handlingFee, netAmount);
+        // 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() {
+        logger.info("开始同步分账数据...");
+        try {
+            // 1. 从PHP主库获取数据
+            List<RoyaltySummary> summaries = fetchFromPhpSystem();
+
+            // 2. 更新到本地数据库
+            summaries.forEach(summary -> {
+                royaltySummaryMapper.upsertSummary(summary);
+            });
+
+            logger.info("同步完成: {}条记录", summaries.size());
+        } catch (Exception e) {
+            logger.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;
+//    }
+
+    // 在FinanceServiceImpl中补充完整数据同步
+    private List<RoyaltySummary> fetchFromPhpSystem() {
+        try {
+            // 使用RestTemplate从PHP系统获取数据
+            RestTemplate restTemplate = new RestTemplate();
+
+            // 设置认证头
+            HttpHeaders headers = new HttpHeaders();
+            headers.setBasicAuth("api_user", "api_password");
+
+            // 构建请求
+            HttpEntity<String> entity = new HttpEntity<>(headers);
+            ResponseEntity<RoyaltySummary[]> response = restTemplate.exchange(
+                    phpDataUrl + "/royalty/summary",
+                    HttpMethod.GET,
+                    entity,
+                    RoyaltySummary[].class
+            );
+
+            if (response.getStatusCode() == HttpStatus.OK && response.getBody() != null) {
+                return Arrays.asList(response.getBody());
+            }
+            throw new ServiceException("PHP系统返回错误状态码: " + response.getStatusCode());
+        } catch (Exception e) {
+            logger.error("从PHP系统获取分账数据失败: {}", e.getMessage());
+            throw new ServiceException("数据同步服务暂时不可用", e);
+        }
+    }
+
+    // 定时任务重试机制
+    @Scheduled(fixedDelayString = "${scheduled.ad-retry-interval}")
+    public void retryFailedAdSync() {
+        try {
+            List<AdLog> failedLogs = adLogMapper.selectList(
+                    new QueryWrapper<AdLog>().eq("sync_status", 2) // 2=失败
+            );
+
+            for (AdLog log : failedLogs) {
+                logger.info("重试广告同步: ID={}, 平台={}", log.getId(), log.getAdPlatform());
+                adService.syncWithAdPlatform(log);
+            }
+        } catch (Exception e) {
+            logger.error("广告同步重试任务失败: {}", e.getMessage());
+        }
+    }
+    @Override
+    public BigDecimal getRoyaltyRate(Long authorId) {
+        // 实际应根据作者等级计算
+        // 这里返回基础比例
+        return baseRoyaltyRate;
+    }
+
+    @Override
+    public BigDecimal getHandlingFeeRate() {
+        return handlingFeeRate;
+    }
+
+
+//    @Override
+//    public RoyaltyReport calculateRoyalty(Long authorId, String month) {
+//        // 1. 从PHP系统拉取数据（补充缺失的调用）
+//        RoyaltySummary summary = phpApiClient.getAuthorRoyaltySummary(authorId, month);
+//
+//        // 2. 计算分成金额（补充业务逻辑）
+//        BigDecimal royaltyRate = getRoyaltyRate(authorId);
+//        BigDecimal grossAmount = summary.getTotalReads().multiply(royaltyRate);
+//        BigDecimal handlingFee = grossAmount.multiply(handlingFeeRate);
+//        BigDecimal netAmount = grossAmount.subtract(handlingFee);
+//
+//        // 3. 构建报表对象
+//        return new RoyaltyReport(authorId, month, summary.getTotalReads(),
+//                royaltyRate, handlingFeeRate, handlingFee, netAmount);
+//    }
+//
+//    // 补充缺失的辅助方法
+//    private BigDecimal getRoyaltyRate(Long authorId) {
+//        Author author = authorService.getById(authorId);
+//        BigDecimal rate = baseRoyaltyRate;
+//        if (author.isVip()) {
+//            rate = rate.add(vipBonusRate); // VIP作者加成
+//        }
+//        return rate.min(new BigDecimal("0.35")); // 上限35%:cite[4]
+//    }
+}

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

@@ -0,0 +1,103 @@
+package com.ruoyi.novel.service.impl;
+
+import com.ruoyi.novel.domain.Novel;
+import com.ruoyi.novel.mapper.NovelMapper;
+import com.ruoyi.novel.service.NovelSearchService;
+import org.elasticsearch.index.query.QueryBuilders;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.elasticsearch.core.ElasticsearchRestTemplate;
+import org.springframework.data.elasticsearch.core.IndexOperations;
+import org.springframework.data.elasticsearch.core.SearchHit;
+import org.springframework.data.elasticsearch.core.SearchHits;
+import org.springframework.data.elasticsearch.core.document.Document;
+import org.springframework.data.elasticsearch.core.mapping.IndexCoordinates;
+import org.springframework.data.elasticsearch.core.query.*;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.PostConstruct;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+// NovelSearchService.java
+@Service
+public class NovelSearchServiceImpl implements NovelSearchService {
+    private static final Logger logger = LoggerFactory.getLogger(NovelSearchServiceImpl.class);
+
+    @Autowired
+    private ElasticsearchRestTemplate elasticTemplate;
+    @Autowired
+    private NovelMapper novelMapper;
+
+    private static final String INDEX_NAME = "novels";
+
+    @PostConstruct
+    public void createIndexIfNotExists() {
+        IndexOperations indexOps = elasticTemplate.indexOps(IndexCoordinates.of(INDEX_NAME));
+        if (!indexOps.exists()) {
+            // 创建索引
+            indexOps.create();
+
+            // 创建映射
+            Document mapping = indexOps.createMapping(Novel.class);
+            indexOps.putMapping(mapping);
+        }
+//        if (!elasticTemplate.indexExists(INDEX_NAME)) {
+//            elasticTemplate.createIndex(INDEX_NAME);
+//            elasticTemplate.putMapping(Novel.class);
+//        }
+    }
+    public List<Novel> searchNovels(String keyword) {
+        // 构建查询条件
+        NativeSearchQuery query = new NativeSearchQueryBuilder()
+                .withQuery(QueryBuilders.multiMatchQuery(keyword, "title", "author", "description"))
+                .build();
+        // 执行搜索
+        SearchHits<Novel> hits = elasticTemplate.search(query, Novel.class);
+        return hits.stream()
+                .map(SearchHit::getContent)
+                .collect(Collectors.toList());
+
+        //return elasticTemplate.search(query, Novel.class).getContent();
+    }
+
+    @Override
+    public void indexNovel(Novel novel) {
+        IndexQuery indexQuery = new IndexQueryBuilder()
+                .withId(novel.getId().toString())
+                .withObject(novel)
+                .build();
+        elasticTemplate.index(indexQuery, IndexCoordinates.of(INDEX_NAME));
+    }
+    @Override
+    public void updateNovelIndex(Novel novel) {
+        UpdateQuery updateQuery = UpdateQuery.builder(novel.getId().toString())
+                .withDocument(Document.from(convertNovelToMap(novel)))
+                .build();
+        elasticTemplate.update(updateQuery, IndexCoordinates.of(INDEX_NAME));
+    }
+    private Map<String, Object> convertNovelToMap(Novel novel) {
+        Map<String, Object> map = new HashMap<>();
+        map.put("title", novel.getTitle());
+        map.put("author", novel.getAuthor());
+        map.put("description", novel.getDescription());
+        map.put("categoryId", novel.getCategoryId());
+        map.put("status", novel.getStatus());
+        return map;
+    }
+    @Override
+    public void deleteNovelIndex(Long id) {
+        elasticTemplate.delete(id.toString(), IndexCoordinates.of(INDEX_NAME));
+    }
+    // 定时同步数据库数据到ES
+    @Scheduled(fixedRate = 3600000) // 每小时同步一次
+    public void syncDataToEs() {
+        List<Novel> novels = novelMapper.selectList(null);
+        novels.forEach(this::indexNovel);
+        logger.info("同步 {} 条小说数据到ES", novels.size());
+    }
+}

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

@@ -0,0 +1,53 @@
+package com.ruoyi.novel.service.impl;
+
+import com.ruoyi.novel.domain.Novel;
+import com.ruoyi.novel.mapper.NovelMapper;
+import com.ruoyi.novel.service.NovelService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.Arrays;
+import java.util.Date;
+import java.util.List;
+
+// NovelServiceImpl.java
+@Service
+public class NovelServiceImpl implements NovelService {
+    private static final Logger logger = LoggerFactory.getLogger(NovelServiceImpl.class);
+
+    @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);
+    }
+
+    @Override
+    public int updateNovel(Novel novel) {
+        novel.setUpdateTime(new Date());
+        return novelMapper.updateById(novel);
+    }
+
+    @Override
+    public int deleteNovelByIds(Long[] ids) {
+        return novelMapper.deleteBatchIds(Arrays.asList(ids));
+    }
+
+    @Override
+    public Novel selectNovelById(Long id) {
+        return novelMapper.selectById(id);
+    }
+
+    // 其他CRUD方法...
+}

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

@@ -0,0 +1,60 @@
+package com.ruoyi.novel.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.ruoyi.novel.domain.ReadingRecord;
+import com.ruoyi.novel.mapper.ReadingHistoryMapper;
+import com.ruoyi.novel.service.ReadingHistoryService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.Date;
+
+// ReadingHistoryServiceImpl.java
+@Service
+public class ReadingHistoryServiceImpl implements ReadingHistoryService {
+    private static final Logger logger = LoggerFactory.getLogger(ReadingHistoryServiceImpl.class);
+
+    @Autowired
+    private ReadingHistoryMapper historyMapper;
+
+    @Override
+    @Transactional
+    public void recordReading(ReadingRecord record) {
+        record.setLastReadTime(new Date());
+
+        // 检查是否已存在记录
+        ReadingRecord existing = historyMapper.selectOne(
+                new QueryWrapper<ReadingRecord>()
+                        .eq("user_id", record.getUserId())
+                        .eq("chapter_id", record.getChapterId())
+        );
+
+        if (existing != null) {
+            // 更新现有记录
+            existing.setProgress(record.getProgress());
+            existing.setPosition(record.getPosition());
+            existing.setLastReadTime(record.getLastReadTime());
+            historyMapper.updateById(existing);
+        } else {
+            // 插入新记录
+            historyMapper.insert(record);
+        }
+    }
+
+
+
+
+    @Override
+    public ReadingRecord getLastPosition(Long userId, Long novelId) {
+        return historyMapper.selectOne(
+                new QueryWrapper<ReadingRecord>()
+                        .eq("user_id", userId)
+                        .eq("novel_id", novelId)
+                        .orderByDesc("last_read_time")
+                        .last("LIMIT 1")
+        );
+    }
+}

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

@@ -0,0 +1,231 @@
+package com.ruoyi.novel.service.impl;
+
+import com.google.common.util.concurrent.RateLimiter;
+import com.ruoyi.common.exception.ServiceException;
+import com.ruoyi.novel.domain.VoteRecord;
+import com.ruoyi.novel.domain.VoteRequest;
+import com.ruoyi.novel.mapper.StoryOptionMapper;
+import com.ruoyi.novel.mapper.VoteRecordMapper;
+import com.ruoyi.novel.service.VoteService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.http.*;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Service;
+import org.springframework.web.client.RestClientException;
+import org.springframework.web.client.RestTemplate;
+
+import java.util.Date;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.atomic.AtomicInteger;
+
+// VoteServiceImpl.java
+@Service
+public class VoteServiceImpl implements VoteService {
+    private static final Logger logger = LoggerFactory.getLogger(VoteServiceImpl.class);
+
+    @Autowired
+    private VoteRecordMapper voteRecordMapper;
+    @Autowired
+    private StoryOptionMapper storyOptionMapper;
+    @Value("${deepseek.api.key}")
+    private String deepSeekApiKey;
+    @Value("${deepseek.api.url}")
+    private String deepSeekApiUrl; // 添加配置项注入
+    @Value("${php.notify.url}")
+    private String phpNotifyUrl;
+    @Autowired
+    private RestTemplate restTemplate; // 确保已注入
+
+    // 使用Guava RateLimiter实现限流
+    private static final ConcurrentHashMap<Long, RateLimiter> userRateLimiters = new ConcurrentHashMap<>();
+
+    // 用户投票限流器 <userId, 计数器>
+    private final Map<Long, AtomicInteger> userVoteCounters = new ConcurrentHashMap<>();
+    private static final int DAILY_VOTE_LIMIT = 3;
+
+    // 添加方法实现
+    @Override
+    public void incrementOptionVote(Long optionId) {
+        storyOptionMapper.incrementVoteCount(optionId);
+    }
+    @Override
+    public boolean canUserVote(Long userId) {
+        RateLimiter rateLimiter = userRateLimiters.computeIfAbsent(
+                userId, k -> RateLimiter.create(3.0) // 每秒3次
+        );
+        return rateLimiter.tryAcquire();
+    }
+
+    @Override
+    public String generateStoryContent(Long storyId, Long optionId) {
+        // 实际应调用AI服务
+        return "生成的故事内容...";
+    }
+    @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) {
+            logger.error("AI生成失败: {}", e.getMessage());
+        }
+    }
+    // 在VoteServiceImpl中补充完整API调用
+    private String callDeepSeekApi(VoteRecord record) {
+        try {
+            // 构建请求体
+            Map<String, Object> requestBody = new HashMap<>();
+            requestBody.put("story_id", record.getStoryId());
+            requestBody.put("option_id", record.getOptionId());
+            requestBody.put("user_id", record.getUserId());
+
+            // 设置请求头
+            HttpHeaders headers = new HttpHeaders();
+            headers.setContentType(MediaType.APPLICATION_JSON);
+            headers.setBearerAuth(deepSeekApiKey);
+
+            // 发送请求
+            HttpEntity<Map<String, Object>> entity = new HttpEntity<>(requestBody, headers);
+            ResponseEntity<Map> response = restTemplate.exchange(
+                    deepSeekApiUrl, HttpMethod.POST, entity, Map.class);
+
+            // 解析响应
+            if (response.getStatusCode() == HttpStatus.OK && response.getBody() != null) {
+                Map<String, Object> body = response.getBody();
+                if (body.containsKey("data") && ((Map)body.get("data")).containsKey("content")) {
+                    return (String) ((Map)body.get("data")).get("content");
+                }
+            }
+            throw new ServiceException("DeepSeek API响应格式错误");
+        } catch (RestClientException e) {
+            logger.error("DeepSeek API调用失败: {}", e.getMessage());
+            throw new ServiceException("AI服务暂时不可用", e);
+        }
+    }
+
+//    @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) {
+            logger.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 -> {
+            logger.info("重试通知PHP系统: voteId={}", record.getId());
+            this.notifyPhpSystem(record);
+        });
+    }
+}

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

@@ -0,0 +1,96 @@
+package com.ruoyi.novel.utils;
+
+import com.alibaba.fastjson2.JSONObject;
+import com.ruoyi.common.exception.ServiceException;
+import com.ruoyi.novel.domain.AdLog;
+import com.ruoyi.novel.domain.AdPlatformConfig;
+import com.ruoyi.novel.service.IAdService;
+
+import com.ruoyi.novel.service.impl.NovelSearchServiceImpl;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.http.*;
+import org.springframework.stereotype.Component;
+import org.springframework.web.client.RestTemplate;
+import java.util.HashMap;
+import java.util.Map;
+
+// AdPlatformClient.java
+@Component
+public class AdPlatformClient {
+    private static final Logger logger = LoggerFactory.getLogger(AdPlatformClient.class);
+
+    @Autowired
+    @Qualifier("adServiceImpl")
+    private IAdService iAdService;
+
+    @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 = iAdService.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());
+        }
+
+        logger.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-system/src/main/java/com/ruoyi/novel/utils/Constants.java

@@ -0,0 +1,8 @@
+package com.ruoyi.novel.utils;
+
+public class Constants {
+    public static final String PAGE_NUM = "pageNum";
+    public static final String PAGE_SIZE = "pageSize";
+    public static final String ORDER_BY_COLUMN = "orderByColumn";
+    public static final String IS_ASC = "isAsc";
+}

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

@@ -0,0 +1,71 @@
+package com.ruoyi.novel.utils;
+
+import io.jsonwebtoken.Claims;
+import io.jsonwebtoken.Jwts;
+import io.jsonwebtoken.SignatureAlgorithm;
+import org.springframework.beans.factory.annotation.Value;
+
+import java.nio.charset.StandardCharsets;
+import java.util.Date;
+
+// JwtUtil.java
+public class JwtUtil {
+    private static String SECRET = "your_jwt_secret_key";
+    @Value("${jwt.secret}")
+    public void setSecret(String secret) {
+        SECRET = secret;
+    }
+
+    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());
+    }
+
+    // 补充Token解析方法
+    public static Claims parseToken(String token) {
+        return Jwts.parser()
+                .setSigningKey(SECRET.getBytes(StandardCharsets.UTF_8))
+                .parseClaimsJws(token)
+                .getBody();
+    }
+
+    // 补充缺失的Token生成方法
+//    public static String generateToken(Long userId) {
+//        return Jwts.builder()
+//                .setSubject(userId.toString())
+//                .setExpiration(new Date(System.currentTimeMillis() + 86400 * 1000))
+//                .signWith(SignatureAlgorithm.HS512, SECRET)
+//                .compact();
+//    }
+}

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

@@ -0,0 +1,80 @@
+package com.ruoyi.novel.utils;
+
+import java.util.HashSet;
+import java.util.Set;
+
+// NovelUtils.java
+public class NovelUtils {
+    
+    // 初始化敏感词库（实际项目中应从数据库或配置文件加载）
+    private static final Set<String> SENSITIVE_WORDS = new HashSet<>();
+
+    static {
+        // 添加敏感词示例
+        SENSITIVE_WORDS.add("暴力");
+        SENSITIVE_WORDS.add("色情");
+        SENSITIVE_WORDS.add("赌博");
+        SENSITIVE_WORDS.add("毒品");
+        // 可以添加更多敏感词...
+    }
+    // 敏感词过滤
+    public static String filterSensitiveWords(String content) {
+        // 实现敏感词过滤逻辑
+        if (content == null || content.isEmpty()) {
+            return content;  // 返回空内容
+        }
+
+        // 创建过滤后的字符串
+        StringBuilder filteredContent = new StringBuilder();
+
+        // 遍历每个字符
+        for (int i = 0; i < content.length(); i++) {
+            // 检查是否包含敏感词
+            boolean isSensitive = false;
+
+            // 检查当前字符开始的每个可能子串
+            for (int j = i + 1; j <= content.length(); j++) {
+                String sub = content.substring(i, j);
+                if (SENSITIVE_WORDS.contains(sub)) {
+                    // 替换敏感词为星号
+                    filteredContent.append("*".repeat(sub.length()));
+                    i = j - 1;  // 跳过已处理的敏感词
+                    isSensitive = true;
+                    break;
+                }
+            }
+
+            // 如果不是敏感词，添加原始字符
+            if (!isSensitive) {
+                filteredContent.append(content.charAt(i));
+            }
+        }
+
+        return filteredContent.toString();  // 返回过滤后的内容
+    }
+
+    // 自动生成章节序号
+    // 自动生成章节序号 - 完善版本
+    public static Integer generateChapterOrder(Long novelId) {
+        // 1. 验证输入
+        if (novelId == null || novelId <= 0) {
+            throw new IllegalArgumentException("无效的小说ID");
+        }
+
+        // 2. 查询数据库获取最新章节序号
+        try {
+            Integer latestOrder = chapterService.findLatestChapterOrder(novelId);
+
+            // 3. 如果还没有章节，从1开始
+            if (latestOrder == null) {
+                return 1;
+            }
+
+            // 4. 返回最新序号+1
+            return latestOrder + 1;
+        } catch (Exception e) {
+            // 5. 处理异常情况
+            throw new RuntimeException("生成章节序号失败: " + e.getMessage(), e);
+        }
+    }
+}

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

@@ -0,0 +1,43 @@
+package com.ruoyi.novel.vip;
+
+
+import com.ruoyi.common.annotation.VipAccess;
+import com.ruoyi.common.exception.ServiceException;
+import com.ruoyi.common.utils.SecurityUtils;
+import com.ruoyi.system.service.ISysUserService;
+import org.aspectj.lang.JoinPoint;
+import org.aspectj.lang.annotation.Aspect;
+import org.aspectj.lang.annotation.Before;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+@Aspect
+@Component
+public class VipAccessAspect {
+
+    // 修复1：添加@Autowired注解注入服务
+    @Autowired
+    private ISysUserService userService;
+
+    // 修复2：添加JoinPoint参数并修正注解表达式
+    @Before("@annotation(vipAccess)")
+    public void checkVipAccess(JoinPoint joinPoint, VipAccess vipAccess) {
+        // 修复3：完整路径引用SecurityUtils
+        Long userId = SecurityUtils.getUserId();
+
+        // 修复4：添加空值检查防止NPE
+        if (userId == null) {
+            throw new ServiceException("用户未登录，无法访问VIP功能");
+        }
+
+        // 修复5：添加服务空值检查
+        if (userService == null) {
+            throw new ServiceException("用户服务未初始化");
+        }
+
+        // 修复6：添加详细的错误信息
+        if (!userService.isVip(userId)) {
+            throw new ServiceException("仅VIP用户可访问此功能，当前用户ID: " + userId);
+        }
+    }
+}

RuoYi-Vue/ruoyi-system/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-system/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-system/src/main/resources/mapper/novel/VoteRecordMapper.xml

@@ -0,0 +1,26 @@
+<!-- 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>
+
+    <update id="updateNotifyStatus">
+        UPDATE novel_vote_log
+        SET notify_status = #{status}
+        WHERE id = #{id}
+    </update>
+</mapper>