京东商城改价修改

This commit is contained in:
苏尹岚
2020-06-10 16:13:50 +08:00
parent f3093a5ebf
commit 8d80a5219b
2 changed files with 269 additions and 29 deletions

View File

@@ -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
}

View File

@@ -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