tj

RuoYi-Vue/ruoyi-novel/pom.xml

@@ -1,69 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<project xmlns="http://maven.apache.org/POM/4.0.0"
-         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
-    <modelVersion>4.0.0</modelVersion>
-    <parent>
-        <groupId>com.ruoyi</groupId>
-        <artifactId>ruoyi</artifactId>
-        <version>3.9.0</version>
-    </parent>
-
-    <artifactId>ruoyi-novel</artifactId>
-
-    <properties>
-        <maven.compiler.source>17</maven.compiler.source>
-        <maven.compiler.target>17</maven.compiler.target>
-        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
-    </properties>
-    <dependencies>
-        <dependency>
-            <groupId>org.mybatis</groupId>
-            <artifactId>mybatis</artifactId>
-            <version>3.5.3</version>
-            <scope>compile</scope>
-        </dependency>
-        <dependency>
-            <groupId>org.projectlombok</groupId>
-            <artifactId>lombok</artifactId>
-        </dependency>
-        <dependency>
-            <groupId>org.springframework</groupId>
-            <artifactId>spring-context</artifactId>
-        </dependency>
-        <dependency>
-            <groupId>org.springframework</groupId>
-            <artifactId>spring-web</artifactId>
-        </dependency>
-        <dependency>
-            <groupId>com.ruoyi</groupId>
-            <artifactId>ruoyi-common</artifactId>
-        </dependency>
-        <!-- 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>
-        <!-- 长文本处理 -->
-
-        <!-- 注解处理器（避免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>
-    </dependencies>
-
-</project>

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

@@ -1,16 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/config/PhpDataSyncTask.java

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

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

@@ -1,61 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/config/TableSupport.java

@@ -1,21 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/config/ThreadPoolConfig.java

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

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

@@ -1,37 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/controller/NovelAdController.java

@@ -1,90 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/controller/NovelController.java

@@ -1,92 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/controller/NovelFinanceController.java

@@ -1,30 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/controller/NovelVoteController.java

@@ -1,54 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/controller/ReadingHistoryController.java

@@ -1,28 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/domain/AdCountRequest.java

@@ -1,27 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/domain/AdLog.java

@@ -1,40 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/domain/AdPlatformConfig.java

@@ -1,26 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/domain/ChapterDTO.java

@@ -1,15 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/domain/Novel.java

@@ -1,39 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/domain/NovelChapter.java

@@ -1,25 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/domain/NovelContent.java

@@ -1,14 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/domain/ReadingRecord.java

@@ -1,27 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/domain/RoyaltyReport.java

@@ -1,30 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/domain/RoyaltySummary.java

@@ -1,26 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/domain/StoryOption.java

@@ -1,26 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/domain/VoteRecord.java

@@ -1,26 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/domain/VoteRequest.java

@@ -1,18 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/exception/GlobalExceptionHandler.java

@@ -1,45 +0,0 @@
-package com.ruoyi.novel.exception;
-
-import com.ruoyi.common.core.domain.AjaxResult;
-import com.ruoyi.common.exception.ServiceException;
-import com.ruoyi.novel.service.impl.ReadingHistoryServiceImpl;
-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-novel/src/main/java/com/ruoyi/novel/mapper/AdLogMapper.java

@@ -1,20 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/mapper/AdPlatformConfigMapper.java

@@ -1,8 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/mapper/NovelChapterMapper.java

@@ -1,26 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/mapper/NovelContentMapper.java

@@ -1,14 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/mapper/NovelMapper.java

@@ -1,32 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/mapper/ReadingHistoryMapper.java

@@ -1,34 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/mapper/RoyaltySummaryMapper.java

@@ -1,33 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/mapper/StoryOptionMapper.java

@@ -1,40 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/mapper/VoteRecordMapper.java

@@ -1,46 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/service/AdConfigService.java

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

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

@@ -1,9 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/service/AdService.java

@@ -1,15 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/service/AdSyncService.java

@@ -1,10 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/service/ChapterService.java

@@ -1,13 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/service/IAdService.java

@@ -1,22 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/service/IFinanceService.java

@@ -1,13 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/service/IVoteService.java

@@ -1,16 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/service/NovelSearchService.java

@@ -1,13 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/service/NovelService.java

@@ -1,16 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/service/ReadingHistoryService.java

@@ -1,9 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/service/VoteService.java

@@ -1,29 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/service/impl/AdConfigServiceImpl.java

@@ -1,69 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/service/impl/AdLogServiceImpl.java

@@ -1,88 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/service/impl/AdServiceImpl.java

@@ -1,131 +0,0 @@
-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.Async;
-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-novel/src/main/java/com/ruoyi/novel/service/impl/AdSyncServiceImpl.java

@@ -1,82 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/service/impl/ChapterServiceImpl.java

@@ -1,73 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/service/impl/FinanceServiceImpl.java

@@ -1,212 +0,0 @@
-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.ArrayList;
-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-novel/src/main/java/com/ruoyi/novel/service/impl/NovelSearchServiceImpl.java

@@ -1,103 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/service/impl/NovelServiceImpl.java

@@ -1,53 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/service/impl/ReadingHistoryServiceImpl.java

@@ -1,60 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/service/impl/VoteServiceImpl.java

@@ -1,231 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/utils/AdPlatformClient.java

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

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

@@ -1,8 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/utils/JwtUtil.java

@@ -1,72 +0,0 @@
-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-novel/src/main/java/com/ruoyi/novel/utils/NovelUtils.java

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

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

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

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

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

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

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

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

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

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

@@ -1,26 +0,0 @@
-<!-- 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>

RuoYi-Vue/ruoyi-system/src/main/java/com/ruoyi/novel/exception/GlobalExceptionHandler.java

@@ -1,44 +0,0 @@
-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("系统繁忙，请稍后再试");
-    }
-}