瀏覽代碼

feat:会员看课统计定时任务(暂放)

caoliqin 2 月之前
父節點
當前提交
32b2870b7c

+ 4 - 1
fs-qw-task/src/main/java/com/fs/app/task/UserCourseWatchCountTask.java

@@ -29,9 +29,12 @@ public class UserCourseWatchCountTask {
     public void userCourseCountTask() {
         try {
             log.info("会员看课统计任务执行----------开始");
+            long startTime = System.currentTimeMillis();
             //
-
+            // todo
             log.info("会员看课统计任务执行----------结束");
+            long endTime = System.currentTimeMillis();
+            log.info("会员看课统计任务执行----------执行时长:{}", (endTime - startTime));
         } catch (Exception e) {
             log.error("会员看课统计任务执行----------定时任务执行失败", e);
         }

+ 14 - 8
fs-service-system/src/main/java/com/fs/store/mapper/FsUserCourseCountMapper.java

@@ -5,15 +5,15 @@ import com.fs.store.domain.FsUserCourseCount;
 
 /**
  * 用户看课统计Mapper接口
- * 
+ *
  * @author fs
  * @date 2025-04-02
  */
-public interface FsUserCourseCountMapper 
+public interface FsUserCourseCountMapper
 {
     /**
      * 查询用户看课统计
-     * 
+     *
      * @param id 用户看课统计ID
      * @return 用户看课统计
      */
@@ -21,7 +21,7 @@ public interface FsUserCourseCountMapper
 
     /**
      * 查询用户看课统计列表
-     * 
+     *
      * @param fsUserCourseCount 用户看课统计
      * @return 用户看课统计集合
      */
@@ -29,7 +29,7 @@ public interface FsUserCourseCountMapper
 
     /**
      * 新增用户看课统计
-     * 
+     *
      * @param fsUserCourseCount 用户看课统计
      * @return 结果
      */
@@ -37,7 +37,7 @@ public interface FsUserCourseCountMapper
 
     /**
      * 修改用户看课统计
-     * 
+     *
      * @param fsUserCourseCount 用户看课统计
      * @return 结果
      */
@@ -45,7 +45,7 @@ public interface FsUserCourseCountMapper
 
     /**
      * 删除用户看课统计
-     * 
+     *
      * @param id 用户看课统计ID
      * @return 结果
      */
@@ -53,9 +53,15 @@ public interface FsUserCourseCountMapper
 
     /**
      * 批量删除用户看课统计
-     * 
+     *
      * @param ids 需要删除的数据ID
      * @return 结果
      */
     public int deleteFsUserCourseCountByIds(Long[] ids);
+
+    /**
+     * 往看课统计表中插入数据
+     */
+    void insertFsUserCourseCountTask();
+
 }

+ 13 - 8
fs-service-system/src/main/java/com/fs/store/service/IFsUserCourseCountService.java

@@ -5,15 +5,15 @@ import com.fs.store.domain.FsUserCourseCount;
 
 /**
  * 用户看课统计Service接口
- * 
+ *
  * @author fs
  * @date 2025-04-02
  */
-public interface IFsUserCourseCountService 
+public interface IFsUserCourseCountService
 {
     /**
      * 查询用户看课统计
-     * 
+     *
      * @param id 用户看课统计ID
      * @return 用户看课统计
      */
@@ -21,7 +21,7 @@ public interface IFsUserCourseCountService
 
     /**
      * 查询用户看课统计列表
-     * 
+     *
      * @param fsUserCourseCount 用户看课统计
      * @return 用户看课统计集合
      */
@@ -29,7 +29,7 @@ public interface IFsUserCourseCountService
 
     /**
      * 新增用户看课统计
-     * 
+     *
      * @param fsUserCourseCount 用户看课统计
      * @return 结果
      */
@@ -37,7 +37,7 @@ public interface IFsUserCourseCountService
 
     /**
      * 修改用户看课统计
-     * 
+     *
      * @param fsUserCourseCount 用户看课统计
      * @return 结果
      */
@@ -45,7 +45,7 @@ public interface IFsUserCourseCountService
 
     /**
      * 批量删除用户看课统计
-     * 
+     *
      * @param ids 需要删除的用户看课统计ID
      * @return 结果
      */
@@ -53,9 +53,14 @@ public interface IFsUserCourseCountService
 
     /**
      * 删除用户看课统计信息
-     * 
+     *
      * @param id 用户看课统计ID
      * @return 结果
      */
     public int deleteFsUserCourseCountById(Long id);
+
+    /**
+     * 往看课统计表中插入数据
+     */
+    void insertFsUserCourseCountTask();
 }

+ 24 - 8
fs-service-system/src/main/java/com/fs/store/service/impl/FsUserCourseCountServiceImpl.java

@@ -2,6 +2,7 @@ package com.fs.store.service.impl;
 
 import java.util.List;
 import com.fs.common.utils.DateUtils;
+import com.fs.course.mapper.FsCourseWatchLogMapper;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import com.fs.store.mapper.FsUserCourseCountMapper;
@@ -10,19 +11,22 @@ import com.fs.store.service.IFsUserCourseCountService;
 
 /**
  * 用户看课统计Service业务层处理
- * 
+ *
  * @author fs
  * @date 2025-04-02
  */
 @Service
-public class FsUserCourseCountServiceImpl implements IFsUserCourseCountService 
+public class FsUserCourseCountServiceImpl implements IFsUserCourseCountService
 {
     @Autowired
     private FsUserCourseCountMapper fsUserCourseCountMapper;
 
+    @Autowired
+    private FsCourseWatchLogMapper fsCourseWatchLogMapper;
+
     /**
      * 查询用户看课统计
-     * 
+     *
      * @param id 用户看课统计ID
      * @return 用户看课统计
      */
@@ -34,7 +38,7 @@ public class FsUserCourseCountServiceImpl implements IFsUserCourseCountService
 
     /**
      * 查询用户看课统计列表
-     * 
+     *
      * @param fsUserCourseCount 用户看课统计
      * @return 用户看课统计
      */
@@ -46,7 +50,7 @@ public class FsUserCourseCountServiceImpl implements IFsUserCourseCountService
 
     /**
      * 新增用户看课统计
-     * 
+     *
      * @param fsUserCourseCount 用户看课统计
      * @return 结果
      */
@@ -59,7 +63,7 @@ public class FsUserCourseCountServiceImpl implements IFsUserCourseCountService
 
     /**
      * 修改用户看课统计
-     * 
+     *
      * @param fsUserCourseCount 用户看课统计
      * @return 结果
      */
@@ -72,7 +76,7 @@ public class FsUserCourseCountServiceImpl implements IFsUserCourseCountService
 
     /**
      * 批量删除用户看课统计
-     * 
+     *
      * @param ids 需要删除的用户看课统计ID
      * @return 结果
      */
@@ -84,7 +88,7 @@ public class FsUserCourseCountServiceImpl implements IFsUserCourseCountService
 
     /**
      * 删除用户看课统计信息
-     * 
+     *
      * @param id 用户看课统计ID
      * @return 结果
      */
@@ -93,4 +97,16 @@ public class FsUserCourseCountServiceImpl implements IFsUserCourseCountService
     {
         return fsUserCourseCountMapper.deleteFsUserCourseCountById(id);
     }
+
+    @Override
+    public void insertFsUserCourseCountTask() {
+        // 1、获取统计结果
+        // todo
+
+
+        // 2、分批插入数据
+
+
+
+    }
 }

+ 5 - 0
fs-service-system/src/main/resources/mapper/store/FsUserCourseCountMapper.xml

@@ -132,4 +132,9 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         </foreach>
     </delete>
 
+    <insert id="insertFsUserCourseCountTask" useGeneratedKeys="true" keyProperty="id">
+
+    </insert>
+
+
 </mapper>