商品定时任务更新修复

lhb-basic/lhb-basic-biz/src/main/java/com/kxs/lhb/basic/biz/service/impl/LhbGoodsServiceImpl.java

@@ -24,6 +24,7 @@ import com.kxs.lhb.basic.biz.service.LhbGoodsSkuService;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.BeanUtils;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -155,6 +156,7 @@ public class LhbGoodsServiceImpl extends MPJBaseServiceImpl<LhbGoodsMapper, LhbG
     }
 
     @Override
+    @Async
     public void goodsInfoTask() {
 
         List<LhbGoods> list = list(Wrappers.lambdaQuery(LhbGoods.class).eq(LhbGoods::getStatus, CommonConstants.SUCCESS));
@@ -198,14 +200,11 @@ public class LhbGoodsServiceImpl extends MPJBaseServiceImpl<LhbGoodsMapper, LhbG
             List<PackagesRes.Activities> activities = goodsChild.getActivities();
             //删除不存在的活动
             goodsActivitiesService.remove(Wrappers.lambdaQuery(LhbGoodsActivities.class)
-                            .eq(LhbGoodsActivities::getSkuId, goodsSku.getId())
+                    .eq(LhbGoodsActivities::getSkuId, goodsSku.getId())
                     .notIn(LhbGoodsActivities::getActivityCode, activities.stream().map(PackagesRes.Activities::getOfferCode).toList()));
 
             for (PackagesRes.Activities activitiesItem : activities) {
 
-                goodsSkuService.remove(Wrappers.lambdaQuery(LhbGoodsSku.class)
-                        .notIn(LhbGoodsSku::getExternalSkuId, goodsChildList.stream().map(PackagesRes.GoodsChild::getId).toList()));
-
                 LhbGoodsActivities goodsActivities = goodsActivitiesService.getOne(Wrappers.lambdaQuery(LhbGoodsActivities.class)
                         .eq(LhbGoodsActivities::getActivityCode, activitiesItem.getOfferCode()));
                 if (goodsActivities == null) {