update

src/main/java/com/gogirl/application/order/pay/impl/OrderIncomeFlowServiceImpl.java

@@ -8,7 +8,7 @@ import org.springframework.stereotype.Service;
 
 /**
  * <p>
- *  服务实现类
+ * 服务实现类
  * </p>
  *
  * @author robbendev

src/main/java/com/gogirl/domain/product/serve/BaseProduce.java

@@ -31,6 +31,7 @@ public class BaseProduce implements Serializable {
     private Integer serviceId;
 
     @ApiModelProperty("款式标签id")
+    @Deprecated
     private Integer produceLabelId;
 
     @ApiModelProperty("款式名称")
@@ -75,6 +76,8 @@ public class BaseProduce implements Serializable {
     @TableField(exist = false)
     private BigDecimal price;
 
+    @TableField(exist = false)
+    @Deprecated
     @ApiModelProperty("款式销量 定时任务统计")
     private Integer salesNum;
 

src/main/java/com/gogirl/infrastructure/mapper/product/serve/BaseProduceMapper.java

@@ -22,6 +22,7 @@ public interface BaseProduceMapper extends BaseMapper<BaseProduce> {
      */
     BaseProduce getProduceForDetail(Integer id);
 
+
     /**
      * 分页查询款式
      *
@@ -41,4 +42,9 @@ public interface BaseProduceMapper extends BaseMapper<BaseProduce> {
      * 同步款式服务类型id
      */
     void syncProduceServeTypeId();
+
+    /**
+     * 同步款式销量
+     */
+    void syncSalesNum();
 }

src/main/java/com/gogirl/infrastructure/schedule/Schedule.java

@@ -113,6 +113,7 @@ public class Schedule {
     private OrderManageMapper orderManageMapper;
     private final MallProductMapper mallProductMapper;
     private final MallCategoryMapper mallCategoryMapper;
+    private final BaseProduceMapper baseProduceMapper;
 
     /**
      * config
@@ -348,6 +349,8 @@ public class Schedule {
             produceSalesService.remove(new LambdaQueryWrapper<>());
             produceSalesService.saveBatch(produceSalesList);
 
+            baseProduceMapper.syncSalesNum();
+
         }
         log.debug("同步商品销量** 任务结束");
     }
@@ -680,10 +683,6 @@ public class Schedule {
         mallProductMapper.syncMallProductIndexTitle(mallCategory.getId());
     }
 
-
-    private final BaseProduceMapper baseProduceMapper;
-
-
     /**
      * 每天凌晨3点同步款式的服务类型id
      */

src/main/resources/mapper/product/BaseProduceMapper.xml

@@ -77,6 +77,17 @@
           and t2.id is not null
     </update>
 
+    <update id="syncSalesNum">
+        update (select t1.produce_id, count(t1.id) as sales
+                from order_serve t1
+                         left join order_manage t2 on t1.order_id = t2.id
+                where (t2.status = 3 or t2.status = 4)
+                  and t1.produce_id is not null
+                group by t1.produce_id) a
+            LEFT JOIN base_produce b on a.produce_id = b.id
+        set b.sales_num = a.sales
+    </update>
+
     <select id="getProduceForDetail" resultMap="produceResultMap">
         select
         <include refid="serveSql"/>,