liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/mark' into su

Browse Source
This commit is contained in:
苏尹岚
2019-12-03 11:30:40 +08:00
parent 7ec9a99cfb e7199741a4
commit 2b979a4f68
42 changed files with 667 additions and 2419 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
business/partner/purchase/jd/act.go
View File

@@ -262,9 +262,9 @@ func (c *PurchaseHandler) SyncAct(ctx *jxcontext.Context, parentTask tasksch.ITa
}
}
for _, actStoreSkuList := range vendorActInfoMap {
updateItems = append(updateItems, partner.ActStoreSku2Update(actStoreSkuList, model.SyncFlagModifiedMask)...)
updateItems = append(updateItems, partner.ActStoreSku2Update(ctx, actStoreSkuList, model.SyncFlagModifiedMask)...)
}
updateItems = append(updateItems, partner.Act2Update(act, model.SyncFlagModifiedMask))
updateItems = append(updateItems, partner.Act2Update(ctx, act, model.SyncFlagModifiedMask))
} else if model.IsSyncStatusNew(act.SyncStatus) {
if act.VendorActID, err = createSkuAct(ctx, act, actStoreSkuList4Create); err != nil {
if act.VendorActID != "" {
@@ -273,15 +273,15 @@ func (c *PurchaseHandler) SyncAct(ctx *jxcontext.Context, parentTask tasksch.ITa
}
return err
}
updateItems = append(updateItems, partner.ActStoreSku2Update(actStoreSkuList4Create, model.SyncFlagNewMask)...)
updateItems = append(updateItems, partner.Act2Update(act, model.SyncFlagNewMask))
updateItems = append(updateItems, partner.ActStoreSku2Update(ctx, actStoreSkuList4Create, model.SyncFlagNewMask)...)
updateItems = append(updateItems, partner.Act2Update(ctx, act, model.SyncFlagNewMask))
} else if model.IsSyncStatusUpdate(act.SyncStatus) {
// globals.SugarLogger.Debug(utils.Format4Output(updateItems, false))
if len(actStoreSkuList4Create) > 0 {
if _, err = createSkuAct(ctx, act, actStoreSkuList4Create); err != nil {
return err
}
updateItems = append(updateItems, partner.ActStoreSku2Update(actStoreSkuList4Create, model.SyncFlagNewMask)...)
updateItems = append(updateItems, partner.ActStoreSku2Update(ctx, actStoreSkuList4Create, model.SyncFlagNewMask)...)
}
for vendorActID := range deleteActInfoMap {
if vendorActID != "" {
@@ -295,10 +295,10 @@ func (c *PurchaseHandler) SyncAct(ctx *jxcontext.Context, parentTask tasksch.ITa
return err
}
}
updateItems = append(updateItems, partner.ActStoreSku2Update(deleteActInfoMap[vendorActID], model.SyncFlagDeletedMask)...)
updateItems = append(updateItems, partner.ActStoreSku2Update(ctx, deleteActInfoMap[vendorActID], model.SyncFlagDeletedMask)...)
}
if err == nil {
updateItems = append(updateItems, partner.Act2Update(act, model.SyncFlagModifiedMask))
updateItems = append(updateItems, partner.Act2Update(ctx, act, model.SyncFlagModifiedMask))
}
}
return err

191
business/partner/purchase/jd/store_sku.go
View File

@@ -1,191 +0,0 @@
package jd
// // 京东到家，以有库存表示关注（认领）
// func (p *PurchaseHandler) syncStoreSkus(ctx *jxcontext.Context, parentTask tasksch.ITask, db *dao.DaoDB, storeID int, storeSkus []*dao.StoreSkuSyncInfo, isAsync, isContinueWhenError bool) (hint string, err error) {
// globals.SugarLogger.Debugf("jd syncStoreSkus, storeID:%d", storeID)
// storeDetail, err := dao.GetStoreDetail(db, storeID, model.VendorIDJD)
// if err != nil {
// return "", err
// }
// batchSize := jdapi.MaxStoreSkuBatchSize
// // storeSkusLen := len(storeSkus)
// // if storeSkusLen < jdapi.MaxStoreSkuBatchSize/2 {
// // batchSize = 1
// // } else if storeSkusLen < jdapi.MaxStoreSkuBatchSize {
// // batchSize = (storeSkusLen + 1) / 2
// // } else if storeSkusLen < jdapi.MaxStoreSkuBatchSize*2 {
// // batchSize = (storeSkusLen + 2) / 3
// // }
// task := tasksch.NewParallelTask("syncStoreSkus京东", tasksch.NewParallelConfig().SetBatchSize(batchSize).SetIsContinueWhenError(isContinueWhenError), ctx,
// func(t *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
// doWork := func(batchItemList []interface{}) (isPartialFailed bool, err error) {
// var skuPriceInfoList []*jdapi.SkuPriceInfo
// var skuVendibilityList []*jdapi.StockVendibility
// var skuStockList []*jdapi.SkuStock
// vendorSkuID4Price := ""
// vendorSkuID4Qty := ""
// stationNo := storeDetail.VendorStoreID
// var batchBindIDs []int
// for _, v := range batchItemList {
// storeSku := v.(*dao.StoreSkuSyncInfo)
// alreadyAddStock := false
// if storeSku.StoreSkuSyncStatus&model.SyncFlagChangedMask != 0 || storeSku.BindID == 0 || storeSku.NameID == 0 {
// if storeSku.BindID > 0 {
// batchBindIDs = append(batchBindIDs, storeSku.BindID)
// }
// if storeSku.StoreSkuSyncStatus&(model.SyncFlagDeletedMask|model.SyncFlagNewMask) != 0 || storeSku.BindID == 0 || storeSku.NameID == 0 { // 关注或取消关注
// stock := &jdapi.SkuStock{
// OutSkuId: utils.Int2Str(storeSku.SkuID),
// StockQty: model.MaxStoreSkuStockQty,
// }
// if storeSku.StoreSkuSyncStatus&model.SyncFlagDeletedMask != 0 || storeSku.DeletedAt != utils.DefaultTimeValue || storeSku.BindID == 0 || storeSku.NameID == 0 {
// stock.StockQty = 0
// } else {
// alreadyAddStock = true
// }
// if stock.StockQty != 0 || !storeskulock.IsJdStoreSkuLocked(stationNo, storeSku.JdID) {
// vendorSkuID4Qty = storeSku.VendorSkuID
// skuStockList = append(skuStockList, stock)
// }
// }
// if storeSku.StoreSkuSyncStatus&(model.SyncFlagPriceMask|model.SyncFlagNewMask) != 0 {
// vendorSkuID4Price = storeSku.VendorSkuID
// pricePercentage := jxutils.GetPricePercentage(storeDetail.PricePercentagePackObj, int(storeSku.Price), int(storeDetail.PricePercentage))
// skuPriceInfoList = append(skuPriceInfoList, &jdapi.SkuPriceInfo{
// OutSkuId: utils.Int2Str(storeSku.SkuID),
// Price: constrainPrice(jxutils.CaculateSkuVendorPrice(int(storeSku.Price), pricePercentage, storeSku.CatPricePercentage)),
// })
// }
// if storeSku.StoreSkuSyncStatus&(model.SyncFlagSaleMask|model.SyncFlagNewMask) != 0 {
// vendibility := &jdapi.StockVendibility{
// OutSkuId: utils.Int2Str(storeSku.SkuID),
// DoSale: true,
// }
// if storeSku.StoreSkuStatus != model.StoreSkuBindStatusNormal {
// vendibility.DoSale = false
// } else if !alreadyAddStock { // 如果是设置可售则自动将库存加满
// stock := &jdapi.SkuStock{
// OutSkuId: utils.Int2Str(storeSku.SkuID),
// StockQty: model.MaxStoreSkuStockQty,
// }
// vendorSkuID4Qty = storeSku.VendorSkuID
// skuStockList = append(skuStockList, stock)
// }
// if vendibility.DoSale || !storeskulock.IsJdStoreSkuLocked(stationNo, storeSku.JdID) {
// skuVendibilityList = append(skuVendibilityList, vendibility)
// }
// }
// }
// }
// syncMask := 0
// errList := []error{}
// if globals.EnableJdStoreWrite {
// // todo 以下可以优化为并行操作
// // globals.SugarLogger.Debug(utils.Format4Output(skuVendibilityList, false), utils.Format4Output(skuPriceInfoList, false), utils.Format4Output(skuStockList, false))
// if len(skuVendibilityList) > 0 {
// if _, err = getAPI("").BatchUpdateVendibility(ctx.GetTrackInfo(), "", stationNo, skuVendibilityList, ctx.GetUserName()); err == nil {
// syncMask |= model.SyncFlagSaleMask
// } else {
// if !isPartialFailed {
// isPartialFailed = isErrPartialFailed(err)
// }
// errList = append(errList, err)
// }
// }
// if (err == nil || isContinueWhenError) && len(skuStockList) > 0 {
// if len(skuStockList) == 1 {
// err = getAPI("").UpdateCurrentQty(ctx.GetTrackInfo(), stationNo, utils.Str2Int64WithDefault(vendorSkuID4Qty, 0), skuStockList[0].StockQty)
// } else {
// _, err = getAPI("").BatchUpdateCurrentQtys(ctx.GetTrackInfo(), "", stationNo, skuStockList, ctx.GetUserName())
// }
// if err == nil {
// syncMask |= model.SyncFlagNewMask | model.SyncFlagDeletedMask
// } else {
// if !isPartialFailed {
// isPartialFailed = isErrPartialFailed(err)
// }
// errList = append(errList, err)
// }
// }
// if (err == nil || isContinueWhenError) && len(skuPriceInfoList) > 0 {
// if len(skuPriceInfoList) == 1 {
// _, err = getAPI("").UpdateStationPrice(ctx.GetTrackInfo(), utils.Str2Int64WithDefault(vendorSkuID4Price, 0), stationNo, skuPriceInfoList[0].Price)
// } else {
// _, err = getAPI("").UpdateVendorStationPrice(ctx.GetTrackInfo(), "", stationNo, skuPriceInfoList)
// }
// if err == nil {
// syncMask |= model.SyncFlagPriceMask
// } else {
// if !isPartialFailed {
// isPartialFailed = isErrPartialFailed(err)
// }
// // errList = append(errList, partner.NewErrorCode(err.Error(), partner.ErrCodeChangePriceFailed, model.VendorIDJD))
// errList = append(errList, err)
// }
// }
// }
// if len(errList) == 0 {
// syncMask = -1
// }
// if syncMask != 0 && len(batchBindIDs) > 0 {
// // db := dao.GetDB() // 多线程问题
// sql := `
// UPDATE store_sku_bind t1
// SET t1.jd_sync_status = t1.jd_sync_status & ?
// WHERE t1.id IN (` + dao.GenQuestionMarks(len(batchBindIDs)) + ")"
// if _, err = dao.ExecuteSQL(db, sql, ^syncMask, batchBindIDs); err != nil {
// errList = append(errList, err)
// }
// }
// if len(errList) == 1 {
// err = errList[0]
// } else if len(errList) > 1 {
// err = fmt.Errorf("%v", errList)
// }
// return isPartialFailed, err
// }
// isErrPartialFailed, err := doWork(batchItemList)
// if isErrPartialFailed && len(batchItemList) > 1 {
// for _, v := range batchItemList {
// doWork([]interface{}{v})
// }
// }
// return nil, err
// }, storeSkus)
// tasksch.HandleTask(task, parentTask, false).Run()
// if !isAsync {
// _, err = task.GetResult(0)
// }
// return task.ID, err
// }
// func (p *PurchaseHandler) SyncStoreSkus(ctx *jxcontext.Context, parentTask tasksch.ITask, storeID int, skuIDs []int, isAsync, isContinueWhenError bool) (hint string, err error) {
// globals.SugarLogger.Debugf("jd SyncStoresSkus, storeID:%d, skuIDs:%v", storeID, skuIDs)
// db := dao.GetDB()
// storeSkus, err := dao.GetStoreSkus(db, model.VendorIDJD, storeID, skuIDs)
// if err != nil {
// return "", err
// }
// return p.syncStoreSkus(ctx, parentTask, db, storeID, storeSkus, isAsync, isContinueWhenError)
// }
// func (p *PurchaseHandler) FullSyncStoreSkus(ctx *jxcontext.Context, parentTask tasksch.ITask, storeID int, isAsync, isContinueWhenError bool) (hint string, err error) {
// globals.SugarLogger.Debugf("jd FullSyncStoreSkus, storeID:%d", storeID)
// db := dao.GetDB()
// _, err = dao.SetStoreSkuSyncStatus(db, model.VendorIDJD, []int{storeID}, nil, model.SyncFlagStoreSkuOnlyMask)
// if err != nil {
// return "", err
// }
// storeSkus, err := dao.GetFullStoreSkus(db, model.VendorIDJD, storeID)
// if err != nil {
// return "", err
// }
// return p.syncStoreSkus(ctx, parentTask, db, storeID, storeSkus, isAsync, isContinueWhenError)
// }
// func constrainPrice(price int) int {
// if price <= 0 {
// price = 1
// }
// return price
// }