tj

RuoYi-App/components/AdSystem.vue

@@ -0,0 +1,93 @@
+<script>
+export default {
+  data() {
+    return {
+      // 多平台广告配置
+      adConfig: {
+        h5: {
+          adpid: 'AYDZ_H5_MAIN',
+          widescreen: 'AYDZ_H5_WIDE'
+        },
+        wechat: {
+          unitId: 'WECHAT_AD_UNIT_ID'
+        },
+        douyin: {
+          codeId: 'DOUYIN_AD_CODE_ID'
+        }
+      }
+    }
+  },
+  computed: {
+    currentAdConfig() {
+      // #ifdef H5
+      return this.adConfig.h5
+      // #endif
+      // #ifdef MP-WEIXIN
+      return this.adConfig.wechat
+      // #endif
+      // #ifdef MP-TOUTIAO
+      return this.adConfig.douyin
+      // #endif
+      return {}
+    }
+  },
+  methods: {
+    showAd(adType) {
+      // #ifdef H5
+      if(adType === 'feed') {
+        this.showH5FeedAd()
+      } else {
+        this.showH5RewardAd()
+      }
+      // #endif
+      
+      // #ifdef MP-WEIXIN
+      if(adType === 'feed') {
+        this.showWechatBannerAd()
+      } else {
+        this.showWechatRewardAd()
+      }
+      // #endif
+      
+      // #ifdef MP-TOUTIAO
+      if(adType === 'feed') {
+        this.showDouyinBannerAd()
+      } else {
+        this.showDouyinRewardAd()
+      }
+      // #endif
+    },
+    showH5FeedAd() {
+      // 获取DCloud广告实例
+      const ad = plus.ad.createAd({
+        adpid: this.currentAdConfig.adpid,
+        adType: 'feed'
+      })
+      ad.show()
+      
+      // 广告事件监听
+      ad.onLoad(() => console.log('H5广告加载成功'))
+      ad.onClose(res => {
+        if(res && res.isEnded) {
+          this.$emit('ad-completed')
+        }
+      })
+    }
+  }
+}
+</script>
+
+<template>
+  <!-- H5广告组件 -->
+  <view v-if="platform === 'h5'">
+    <ad 
+      v-if="showAd"
+      :adpid="currentAdConfig.adpid"
+      :adpid-widescreen="currentAdConfig.widescreen"
+      @close="onAdClose"
+    ></ad>
+  </view>
+</template>
+
+<style>
+</style>

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

@@ -1,4 +1,75 @@
 package com.ruoyi.novel.controller;
 //# 广告计数接口
+
+import org.springframework.beans.factory.annotation.Autowired;
+
+@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");
+    }
+
+    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();
+        }
+
+        // 最后使用设备ID
+        return request.getDeviceId();
+    }
+
+    private boolean isValidSource(String source) {
+        List<String> validSources = Arrays.asList("h5", "wechat", "douyin", "app");
+        return validSources.contains(source);
+    }
+}