diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go index 712d4027a..720ce71e6 100644 --- a/business/jxstore/tempop/tempop.go +++ b/business/jxstore/tempop/tempop.go @@ -1609,28 +1609,269 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) { // continue // } // } - var orders []*model.GoodsOrder - sql := ` - SELECT * FROM goods_order - WHERE order_created_at > '2020-06-10 12:20:00' AND vendor_id <> 5 - ` - dao.GetRows(dao.GetDB(), &orders, sql, nil) - task := tasksch.NewParallelTask("刷新门店价格", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx, - func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { - v := batchItemList[0].(*model.GoodsOrder) - var sumPrice int64 - skus, _ := dao.GetSimpleOrderSkus(dao.GetDB(), v.VendorOrderID) - for _, vv := range skus { - sumPrice += vv.ShopPrice - } - if sumPrice != v.ShopPrice { - v.ShopPrice = sumPrice - dao.UpdateEntity(dao.GetDB(), v, "ShopPrice") - } - return retVal, err - }, orders) - tasksch.HandleTask(task, nil, true).Run() - task.GetID() + var jdsIds = []int64{69355523686, + 69353698875, + 69353633443, + 69353579080, + 69353592976, + 69353575450, + 69353669915, + 69353617240, + 69353711276, + 69355552630, + 69353579078, + 69633169613, + 69353608855, + 69634881612, + 69353634806, + 69353675911, + 69353698186, + 69353698877, + 69607962771, + 69608002604, + 69666543870, + 69353541693, + 69411607058, + 69353594629, + 69353602818, + 69353698187, + 69355538267, + 69353633269, + 69355549016, + 69411607059, + 69593365617, + 69353589341, + 69353618034, + 69353633445, + 69353644658, + 69353644659, + 69353664332, + 69355505481, + 69355531215, + 69355552632, + 69353618035, + 69353619589, + 69353684423, + 69353687174, + 69353722053, + 69355493882, + 69627859883, + 69680935348, + 69353555847, + 69353570677, + 69353589397, + 69353592975, + 69353594611, + 69353602819, + 69353616402, + 69353624528, + 69353654004, + 69353668114, + 69353687173, + 69353701089, + 69353722052, + 69353723922, + 69355527850, + 69355552631, + 69628257042, + 69636525703, + 69680935349, + 69353579081, + 69353589342, + 69353632136, + 69353654006, + 69353726354, + 69355496067, + 69355515747, + 69355516049, + 69355527036, + 69355532703, + 69355558164, + 69355560640, + 69608002434, + 69608089252, + 69626869676, + 69628142211, + 69651275202, + 69665458721, + 69980157422, + 69353511255, + 69353550931, + 69353555846, + 69353579079, + 69353593375, + 69353595563, + 69353603501, + 69353608856, + 69353618036, + 69353628469, + 69353628470, + 69353632137, + 69353633267, + 69353633444, + 69353651935, + 69353668115, + 69353683331, + 69353684157, + 69353701088, + 69353723844, + 69353723845, + 69353726353, + 69355490631, + 69355493881, + 69355493884, + 69355520278, + 69355523687, + 69355532705, + 69355533814, + 69355536851, + 69355538268, + 69355538269, + 69593321185, + 69593321186, + 69607997022, + 69626638026, + 69626638027, + 69626872037, + 69627693305, + 69627954144, + 69628180933, + 69633580083, + 69633580085, + 69634881613, + 69635037810, + 69635204944, + 69636212985, + 69636446354, + 69659137913, + 69659219611, + 69665406179, + 69666460731, + 69673523007, + 69680905913, + 69681869918, + 69821176674, + 69913341309, + 69916445013, + 69353511254, + 69353570678, + 69353581400, + 69353589343, + 69353589398, + 69353593376, + 69353594630, + 69353609816, + 69353616406, + 69353617241, + 69353619591, + 69353633268, + 69353634833, + 69353642793, + 69353647695, + 69353651934, + 69353654005, + 69353664333, + 69353669914, + 69353673334, + 69353684159, + 69353684603, + 69353684604, + 69353684605, + 69353684607, + 69353698876, + 69353701090, + 69353711277, + 69353711278, + 69353713475, + 69353726357, + 69355496066, + 69355520277, + 69355523688, + 69355527851, + 69355533813, + 69355533815, + 69355538270, + 69355559874, + 69355559875, + 69355559876, + 69355560641, + 69607988687, + 69608089253, + 69625036409, + 69625436705, + 69626674146, + 69626756838, + 69626849783, + 69626872040, + 69627211928, + 69627823696, + 69627823697, + 69627824429, + 69627859882, + 69627954146, + 69628055157, + 69628209840, + 69628220046, + 69628244518, + 69628620179, + 69628645373, + 69633038980, + 69633169614, + 69633311068, + 69633433209, + 69634285577, + 69634285578, + 69634566319, + 69634566320, + 69634620948, + 69635037811, + 69635075404, + 69635108188, + 69636525704, + 69636563250, + 69636658901, + 69636658902, + 69651265114, + 69659219612, + 69659883978, + 69662122661, + 69666543871, + 69666543872, + 69666660395, + 69666907986, + 69666931214, + 69673508504, + 69680887348, + 69814931154, + 69818078270, + 69881553035, + 69901783885, + 69913362221, + 69916396643, + 69925717199, + 69933144351, + 69933974117, + 69935756246, + 69935768981, + 69935855227, + 69935915640, + 69937601360, + 69937642148, + 69939562884, + 69939571687, + 69948026907} + db := dao.GetDB() + for _, v := range jdsIds { + var storeSkus *model.StoreSkuBind + sql := ` + SELECT * FROM store_sku_bind WHERE store_id = 102919 AND jds_id = ? + ` + sqlParams := []interface{}{v} + err = dao.GetRow(db, &storeSkus, sql, sqlParams) + if storeSkus != nil { + cms.CurVendorSync.SyncStoresSkus(ctx, nil, 0, db, []int{model.VendorIDJDShop}, []int{model.JdShopMainStoreID}, []int{storeSkus.SkuID}, false, true, true) + } + } return err } diff --git a/business/partner/purchase/jdshop/store_sku.go b/business/partner/purchase/jdshop/store_sku.go index 83d602463..16f3c6ec6 100644 --- a/business/partner/purchase/jdshop/store_sku.go +++ b/business/partner/purchase/jdshop/store_sku.go @@ -271,9 +271,9 @@ func (p *PurchaseHandler) UpdateStoreSkusPrice(ctx *jxcontext.Context, vendorOrg if globals.EnableJdShopWrite && vendorStoreID == model.JdShopMainVendorStoreID { for _, v := range storeSkuList { err = api.JdShopAPI.UpdateSkuJdPrice(utils.Str2Int(v.VendorSkuID), jxutils.IntPrice2Standard(v.VendorPrice)) - } - if err != nil { - failedList = putils.GetErrMsg2FailedSingleList(storeSkuList, err, storeID, model.VendorChineseNames[model.VendorIDJDShop], "修改商品价格") + if err != nil { + failedList = putils.GetErrMsg2FailedSingleList(storeSkuList, err, storeID, model.VendorChineseNames[model.VendorIDJDShop], "修改商品价格") + } } } return failedList, err @@ -670,10 +670,9 @@ func buildCreateWareParam(storeSku *dao.StoreSkuSyncInfo) (createSkuParamWare *j } else { specQuality = utils.Float64ToStr(float64(v.SpecQuality)) + v.SpecUnit } - // specQuality := fmt.Sprintf("%.2f", float64(v.SpecQuality)) + v.SpecUnit - // if v.Comment != "" { - // specQuality += " " + v.Comment - // } + if v.Comment != "" { + specQuality += " " + v.Comment + } for _, v := range valuesSku { if v.Name == specQuality { ggValueID = v.ID