强制同步上下架暂时关了
This commit is contained in:
@@ -274,9 +274,9 @@ func Init() {
|
|||||||
func syncStoreSku() {
|
func syncStoreSku() {
|
||||||
syncFlag := 0
|
syncFlag := 0
|
||||||
// syncFlag := model.SyncFlagPriceMask
|
// syncFlag := model.SyncFlagPriceMask
|
||||||
if (time.Now().Unix()/24*3600)%10 == 0 {
|
// if (time.Now().Unix()/24*3600)%10 == 0 {
|
||||||
syncFlag |= model.SyncFlagSaleMask
|
// syncFlag |= model.SyncFlagSaleMask
|
||||||
}
|
// }
|
||||||
task := tasksch.NewParallelTask("同步京西与平台数据", nil, jxcontext.AdminCtx,
|
task := tasksch.NewParallelTask("同步京西与平台数据", nil, jxcontext.AdminCtx,
|
||||||
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
|
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
|
||||||
step := batchItemList[0].(int)
|
step := batchItemList[0].(int)
|
||||||
|
|||||||
Reference in New Issue
Block a user