diff --git a/business/jxstore/act/act.go b/business/jxstore/act/act.go index 2eafc248f..4ad172187 100644 --- a/business/jxstore/act/act.go +++ b/business/jxstore/act/act.go @@ -1978,7 +1978,7 @@ func RrefreshMtwmVendorAct() (err error) { ) //直接做删除,把新的加进来 dao.ExecuteSQL(db, `TRUNCATE act_mtwm_vendor`) - storeMaps, _ := dao.GetStoresMapList(db, []int{model.VendorIDMTWM}, []int{668023}, []int{model.StoreStatusOpened, model.StoreStatusHaveRest, model.StoreStatusClosed}, + storeMaps, _ := dao.GetStoresMapList(db, []int{model.VendorIDMTWM}, nil, []int{model.StoreStatusOpened, model.StoreStatusHaveRest, model.StoreStatusClosed}, model.StoreStatusAll, model.StoreIsSyncAll, "", "", "") task := tasksch.NewParallelTask("刷新美团活动", tasksch.NewParallelConfig().SetIsContinueWhenError(true), jxcontext.AdminCtx, func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { diff --git a/business/jxstore/misc/misc.go b/business/jxstore/misc/misc.go index 09759cc11..d5bd8caad 100644 --- a/business/jxstore/misc/misc.go +++ b/business/jxstore/misc/misc.go @@ -325,6 +325,10 @@ func Init() { //刷新门店分组管理 cms.RefreshStoreBind(jxcontext.AdminCtx) }, dailyWorkTimeList) + ScheduleTimerFunc("RrefreshMtwmVendorAct", func() { + //刷新美团平台活动 + act.RrefreshMtwmVendorAct() + }, dailyWorkTimeList2) } ScheduleTimerFunc("AutoSaleStoreSku", func() { cms.AutoSaleStoreSku(jxcontext.AdminCtx, nil, false)