1
This commit is contained in:
@@ -519,7 +519,7 @@ func Init() {
|
||||
}, []string{
|
||||
"18:50:00",
|
||||
"20:50:00",
|
||||
"22:18:00",
|
||||
"22:22:00",
|
||||
"00:50:00",
|
||||
"02:50:00",
|
||||
"04:50:00",
|
||||
@@ -887,6 +887,7 @@ var syncLen = 0
|
||||
// syncStoreSkuTao 同步商品到淘鲜达
|
||||
func syncStoreSkuTao(beijin []int) {
|
||||
syncFlag := 0
|
||||
globals.SugarLogger.Debugf("===========beijin %s", utils.Format4Output(beijin, false))
|
||||
task := tasksch.NewParallelTask("同步京西商品到淘鲜达平台,方案二使用", nil, jxcontext.AdminCtx,
|
||||
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
|
||||
step := batchItemList[0].(int)
|
||||
@@ -894,6 +895,7 @@ func syncStoreSkuTao(beijin []int) {
|
||||
db := dao.GetDB()
|
||||
switch step {
|
||||
case 0:
|
||||
globals.SugarLogger.Debugf("===========beijin %s", utils.Format4Output(beijin, false))
|
||||
ddmsg.SendUserMessage(dingdingapi.MsgTyeText, "2452A93EEB9111EC9B06525400E86DC0", "淘鲜达消息:", utils.Format4Output(beijin[syncLen:syncLen+5], false))
|
||||
_, err = cms.CurVendorSync.SyncStoresSkus2(jxcontext.AdminCtx, nil, 0, db, []int{model.VendorIDTaoVegetable}, beijin[syncLen:syncLen+5], false, nil, nil, syncFlag, true, true)
|
||||
errList.AddErr(err)
|
||||
|
||||
Reference in New Issue
Block a user