会员管理代码

baqing-shop/src/main/java/com/ruoyi/web/modules/store/mapper/BizShopStatsMapper.java

@@ -0,0 +1,17 @@
+package com.ruoyi.web.modules.store.mapper;
+
+/**
+ * 店铺统计 biz_shop_stats
+ */
+public interface BizShopStatsMapper
+{
+    /**
+     * 为「有评价但尚无统计行」的未删除店铺插入 stats 并写入评分
+     */
+    int insertStatsForShopsWithReviews();
+
+    /**
+     * 按未删除店铺重算 biz_shop_stats.rating（无有效评价则为 NULL）
+     */
+    int updateAllShopRatings();
+}

baqing-shop/src/main/java/com/ruoyi/web/modules/store/service/IShopRatingRefreshService.java

@@ -0,0 +1,14 @@
+package com.ruoyi.web.modules.store.service;
+
+/**
+ * 店铺综合评分刷新
+ */
+public interface IShopRatingRefreshService
+{
+    /**
+     * 重算未删除店铺的综合评分（有效评价平均分）
+     *
+     * @return 受影响行数（插入 + 更新）
+     */
+    int refreshAllShopRatings();
+}

baqing-shop/src/main/java/com/ruoyi/web/modules/store/service/impl/ShopRatingRefreshServiceImpl.java

@@ -0,0 +1,23 @@
+package com.ruoyi.web.modules.store.service.impl;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import com.ruoyi.web.modules.store.mapper.BizShopStatsMapper;
+import com.ruoyi.web.modules.store.service.IShopRatingRefreshService;
+
+@Service
+public class ShopRatingRefreshServiceImpl implements IShopRatingRefreshService
+{
+    @Autowired
+    private BizShopStatsMapper shopStatsMapper;
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public int refreshAllShopRatings()
+    {
+        int inserted = shopStatsMapper.insertStatsForShopsWithReviews();
+        int updated = shopStatsMapper.updateAllShopRatings();
+        return inserted + updated;
+    }
+}

baqing-shop/src/main/java/com/ruoyi/web/modules/store/task/ShopRatingRefreshTask.java

@@ -0,0 +1,28 @@
+package com.ruoyi.web.modules.store.task;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+import com.ruoyi.web.modules.store.service.IShopRatingRefreshService;
+
+/**
+ * 店铺综合评分日终统计：评分 = 有效评价星级之和 / 评价条数
+ */
+@Component
+public class ShopRatingRefreshTask
+{
+    private static final Logger LOGGER = LoggerFactory.getLogger(ShopRatingRefreshTask.class);
+
+    @Autowired
+    private IShopRatingRefreshService shopRatingRefreshService;
+
+    @Scheduled(cron = "0 55 22 * * ?")
+    public void refreshShopRatings()
+    {
+        LOGGER.info("ShopRatingRefreshTask start");
+        int affected = shopRatingRefreshService.refreshAllShopRatings();
+        LOGGER.info("ShopRatingRefreshTask done, affectedRows={}", affected);
+    }
+}

baqing-shop/src/main/resources/mapper/store/BizShopStatsMapper.xml

@@ -0,0 +1,35 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.ruoyi.web.modules.store.mapper.BizShopStatsMapper">
+
+    <insert id="insertStatsForShopsWithReviews">
+        insert into biz_shop_stats (shop_id, rating, fans_count, update_time)
+        select r.shop_id,
+               round(sum(r.score) / count(1), 2),
+               0,
+               now()
+        from biz_goods_review r
+        inner join biz_shop s on r.shop_id = s.shop_id and s.del_flag = '0'
+        left join biz_shop_stats st on st.shop_id = r.shop_id
+        where r.del_flag = '0'
+          and r.score is not null
+          and st.shop_id is null
+        group by r.shop_id
+    </insert>
+
+    <update id="updateAllShopRatings">
+        update biz_shop_stats st
+        inner join biz_shop s on st.shop_id = s.shop_id and s.del_flag = '0'
+        left join (
+            select shop_id,
+                   round(sum(score) / count(1), 2) as avg_rating
+            from biz_goods_review
+            where del_flag = '0'
+              and score is not null
+            group by shop_id
+        ) r on st.shop_id = r.shop_id
+        set st.rating = r.avg_rating,
+            st.update_time = now()
+    </update>
+
+</mapper>

baqing-shop/src/test/java/com/ruoyi/web/modules/store/service/ShopRatingRefreshServiceImplTest.java

@@ -0,0 +1,35 @@
+package com.ruoyi.web.modules.store.service;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
+import org.mockito.InjectMocks;
+import org.mockito.Mock;
+import org.mockito.junit.jupiter.MockitoExtension;
+import com.ruoyi.web.modules.store.mapper.BizShopStatsMapper;
+import com.ruoyi.web.modules.store.service.impl.ShopRatingRefreshServiceImpl;
+
+@ExtendWith(MockitoExtension.class)
+class ShopRatingRefreshServiceImplTest
+{
+    @Mock
+    private BizShopStatsMapper shopStatsMapper;
+
+    @InjectMocks
+    private ShopRatingRefreshServiceImpl shopRatingRefreshService;
+
+    @Test
+    void refreshAllShopRatings_insertsThenUpdates()
+    {
+        when(shopStatsMapper.insertStatsForShopsWithReviews()).thenReturn(1);
+        when(shopStatsMapper.updateAllShopRatings()).thenReturn(5);
+
+        int affected = shopRatingRefreshService.refreshAllShopRatings();
+
+        assertEquals(6, affected);
+        verify(shopStatsMapper).insertStatsForShopsWithReviews();
+        verify(shopStatsMapper).updateAllShopRatings();
+    }
+}