diff --git a/business/jxstore/misc/misc.go b/business/jxstore/misc/misc.go index a3bab591f..369ccca2b 100644 --- a/business/jxstore/misc/misc.go +++ b/business/jxstore/misc/misc.go @@ -287,20 +287,14 @@ func Init() { globals.SugarLogger.Debugf("===============2") syncStoreSkuTao() }, []string{ - "10:05:00", - "12:55:00", - "13:55:00", - "16:05:00", - "18:05:00", - "20:05:00", - "22:05:00", - "00:05:00", - "01:05:00", - "02:05:00", - "04:05:00", - "06:05:00", - "07:05:00", - "08:05:00", + "14:12:00", + "14:15:00", + "14:17:00", + "14:19:00", + "14:21:00", + "14:23:00", + "14:25:00", + "14:28:00", }) } @@ -892,23 +886,25 @@ var beijin = []int{ // syncStoreSkuTao 同步商品到淘鲜达 func syncStoreSkuTao() { - syncFlag := 0 + //syncFlag := 0 globals.SugarLogger.Debugf("=====================================3 %s", utils.Format4Output(beijin, false)) task := tasksch.NewParallelTask("syncStoreSkuTao ", nil, jxcontext.AdminCtx, func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { step := batchItemList[0].(int) errList := errlist.New() - db := dao.GetDB() + //db := dao.GetDB() switch step { case 0: + fmt.Println("111111111111111111111111111") if err := ddmsg.SendUserMessage(dingdingapi.MsgTyeText, "2452A93EEB9111EC9B06525400E86DC0", "淘鲜达消息:", utils.Format4Output(beijin[syncLen:syncLen+5], false)); err != nil { globals.SugarLogger.Debugf("SendUserMessage := %s", utils.Format4Output(err, false)) } enterprise_msg.SendUserMessage("18981810340", "淘鲜达同步消息", utils.Format4Output(beijin[syncLen:syncLen+5], false), utils.Format4Output(beijin[syncLen:syncLen+5], false)) - globals.SugarLogger.Debugf("===============4") - _, 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) + //globals.SugarLogger.Debugf("===============4") + //_, 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) case 1: + fmt.Println("222222222222222222222222") errList.AddErr(err) SaveImportantTaskID(TaskNameSyncStoreSku, SpecialTaskID) } diff --git a/business/jxstore/misc/misc2_test.go b/business/jxstore/misc/misc2_test.go index 685ebaf00..d853217ff 100644 --- a/business/jxstore/misc/misc2_test.go +++ b/business/jxstore/misc/misc2_test.go @@ -15,4 +15,4 @@ func TestStartOrEndOpStore(t *testing.T) { func TestIssny(t *testing.T) { cms.CurVendorSync.SyncStore2(jxcontext.AdminCtx, dao.GetDB(), []int{model.VendorIDMTWM, model.VendorIDJD, model.VendorIDEBAI}, nil, true, true) -} \ No newline at end of file +}