根据门店删活动

business/jxstore/act/act.go

@@ -1057,6 +1057,47 @@ func RefreshPageActs(ctx *jxcontext.Context, vendorIDs []int, createdFrom time.T
 	return hint, err
 }
 
+func DeleteStoresFromAct(ctx *jxcontext.Context, vendorID int, actTypes, storeIDs []int, isAsync, isContinueWhenError bool) (hint string, err error) {
+	db := dao.GetDB()
+	task := tasksch.NewParallelTask("将SKU从所有活动中删除", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(isContinueWhenError), ctx,
+		func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
+			storeID := batchItemList[0].(int)
+			acts, _ := dao.QueryActs(db, 0, 0, 50, 0, "", vendorID, []int{1}, actTypes, nil, storeID, nil, 0, utils.ZeroTimeValue, utils.ZeroTimeValue, time.Now().AddDate(0, -3, 0), time.Now())
+			for _, v := range acts.Data {
+				var actStoreSkuParam []*ActStoreSkuParam
+				_, actStoreSkus, _ := dao.GetActStoreSkuVendorList(db, v.ID, []int{vendorID}, nil, nil, "", 0, 99999)
+				for _, actStoreSku := range actStoreSkus {
+					if actStoreSku.StoreID == storeID {
+						aa := &ActStoreSkuParam{
+							ActStoreSku: model.ActStoreSku{
+								StoreID: storeID,
+								SkuID:   actStoreSku.SkuID,
+								ActID:   v.ID,
+							},
+						}
+						actStoreSkuParam = append(actStoreSkuParam, aa)
+					}
+				}
+				_, err = DeleteActStoreSkuBind(ctx, db, v.ID, actStoreSkuParam)
+				if err == nil {
+					_, err = SyncAct(ctx, nil, v.ID, nil, true)
+				}
+			}
+
+			return retVal, err
+		}, storeIDs)
+	tasksch.HandleTask(task, nil, true).Run()
+	if isAsync {
+		hint = task.GetID()
+	} else {
+		resultList, err2 := task.GetResult(0)
+		if err = err2; err == nil {
+			hint = utils.Int2Str(len(resultList))
+		}
+	}
+	return hint, err
+}
+
 func DeleteSkusFromAct(ctx *jxcontext.Context, vendorID int, actTypes, skuIDs []int, isAsync, isContinueWhenError bool) (hint string, err error) {
 	db := dao.GetDB()
 	actMap := make(map[int]*model.Act)