定时修改商品可售状态

business/jxstore/cms/sync.go

@@ -3,6 +3,7 @@ package cms
 import (
 	"errors"
 	"fmt"
+	"time"
 
 	"git.rosy.net.cn/baseapi/utils"
 	"git.rosy.net.cn/jx-callback/business/jxutils"
@@ -653,3 +654,32 @@ func (v *VendorSync) SyncSkuNames(ctx *jxcontext.Context, nameIDs []int, isForce
 	}
 	return v.SyncSkus(ctx, db, nameIDs, nil, isAsync, isContinueWhenError, ctx.GetUserName())
 }
+
+func (v *VendorSync) ChangeStoreSkuSaleStatus(ctx *jxcontext.Context, isAsync, isContinueWhenError bool) (err error) {
+	var (
+		storeIDs  []int
+		skuIDs    []int
+		vendorIDs = []int{0, 1, 3}
+	)
+	db := dao.GetDB()
+	now := time.Now().Hour()*100 + time.Now().Minute()
+	storeSkuList, err := dao.GetStoresSkusInfoBySaleTime(db)
+	for _, v := range storeSkuList {
+		if (now >= v.TimeBegin1 && now <= v.TimeEnd1) || (now >= v.TimeBegin2 && now <= v.TimeEnd2) {
+			skuIDs = append(skuIDs, v.StoreSkuBind.SkuID)
+			storeIDs = append(storeIDs, v.StoreSkuBind.StoreID)
+			v.StoreSkuBind.Status = model.SkuStatusDontSale
+			setStoreSkuBindStatus(&v.StoreSkuBind, model.SyncFlagSaleMask)
+			dao.UpdateEntity(db, &v.StoreSkuBind)
+		} else {
+			v.StoreSkuBind.Status = model.SkuStatusNormal
+			setStoreSkuBindStatus(&v.StoreSkuBind, model.SyncFlagSaleMask)
+			dao.UpdateEntity(db, &v.StoreSkuBind)
+		}
+	}
+	v.SyncStoresSkus(ctx, db, vendorIDs, storeIDs, skuIDs, false, isAsync, isContinueWhenError)
+	if err != nil {
+		return err
+	}
+	return nil
+}