Sfoglia il codice sorgente

【定时任务】统计前一天商品详情访问量

chao 3 anni fa
parent
commit
2595114243

+ 2 - 2
src/main/java/com/caimei365/tools/mapper/BaseMapper.java

@@ -78,7 +78,7 @@ public interface BaseMapper {
      * 统计前一天商品访问量
      * @param productId 商品Id
      * @param views     访问量
-     * @param countTime 访问日期(天)
+     * @param viewTime 访问日期(天)
      */
-    void insertProductViews(Integer productId, Integer views, Date countTime);
+    void insertProductViews(Integer productId, Integer views, Date viewTime);
 }

+ 4 - 3
src/main/java/com/caimei365/tools/task/StatisticsTask.java

@@ -47,8 +47,8 @@ public class StatisticsTask {
             Calendar calendar = Calendar.getInstance();
             calendar.setTime(new Date());
             calendar.add(Calendar.DAY_OF_MONTH, -1);
-            Date countTime = calendar.getTime();
-            String dateStr = new SimpleDateFormat("yyyyMMdd").format(countTime);
+            Date viewTime = calendar.getTime();
+            String dateStr = new SimpleDateFormat("yyyyMMdd").format(viewTime);
             log.info(">>>>>>>>>>>【定时任务】统计前一天商品详情访问量,统计日期(前一天):" + dateStr);
             // 获取Redis的Key: @Statistics(prefix = "statistics_details", field = "productId")
             String redisKey = "statistics_details:productId:" + dateStr;
@@ -62,10 +62,11 @@ public class StatisticsTask {
                     if (null != entry && StringUtils.isNotEmpty(entry.getKey()) && StringUtils.isNotEmpty(entry.getValue())) {
                         Integer productId = Integer.parseInt(entry.getKey());
                         Integer views = Integer.parseInt(entry.getValue());
-                        baseMapper.insertProductViews(productId, views, countTime);
+                        baseMapper.insertProductViews(productId, views, viewTime);
                     }
                 }
             }
+            log.info(">>>>>>>>>>>【定时任务】统计前一天商品详情访问量,统计成功:" + result);
         } catch (Exception e) {
             log.error(">>>>>>>>>>>【定时任务】统计前一天商品详情访问量失败:",e);
         }

+ 2 - 2
src/main/resources/mapper/BaseMapper.xml

@@ -91,8 +91,8 @@
         VALUES (#{markId}, #{shortLink}, #{url},NOW())
     </insert>
     <insert id="insertProductViews">
-        INSERT INTO cm_product_views_record (productId, views, countTime)
-        VALUES (#{productId}, #{views}, #{countTime})
+        INSERT INTO cm_product_views_record (productId, views, viewTime)
+        VALUES (#{productId}, #{views}, #{viewTime})
     </insert>
     <update id="updateSmsSendCount">
         UPDATE cm_sms_statistics SET sendNum = (sendNum + #{count}) WHERE markId = #{markId}