1
This commit is contained in:
@@ -676,6 +676,13 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFlag
|
||||
// api.JdShop2API.SetCookieWithStr(configs[0].Value)
|
||||
// }
|
||||
}
|
||||
if vendorID == model.VendorIDDD {
|
||||
//createList, updateList []*dao.StoreSkuSyncInfo
|
||||
//deleteList, stockList, onlineList, offlineList, priceList []*partner.StoreSkuInfo
|
||||
//updateItems []*dao.KVUpdateItem
|
||||
//reorderSkuMap map[string][]*dao.StoreSkuSyncInfo
|
||||
globals.SugarLogger.Debugf("createList len = %d ", len(createList))
|
||||
}
|
||||
|
||||
task := tasksch.NewParallelTask("syncStoreSkuNew", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(isContinueWhenError2), ctx,
|
||||
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
|
||||
|
||||
@@ -176,19 +176,6 @@ func (c *PurchaseHandler) onOrderInfoChangeMsg(vendorOrgCode string, msg *jdapi.
|
||||
}
|
||||
|
||||
func UpdateOrderBySettleMent(order *model.GoodsOrder, orderSettlement *jdapi.OrderSettlementInfo) {
|
||||
partner.CurOrderManager.OnOrderStatusChanged(order.VendorOrgCode, &model.OrderStatus{
|
||||
VendorOrderID: order.VendorOrderID,
|
||||
VendorID: order.VendorID,
|
||||
OrderType: 0,
|
||||
RefVendorOrderID: order.VendorOrderID,
|
||||
RefVendorID: 0,
|
||||
Status: 50000,
|
||||
VendorStatus: "50000",
|
||||
StatusTime: time.Now(),
|
||||
DuplicatedCount: 0,
|
||||
Remark: "收集京东结算信息推送",
|
||||
ModelTimeInfo: model.ModelTimeInfo{CreatedAt: time.Now(), UpdatedAt: time.Now()},
|
||||
})
|
||||
if orderSettlement != nil {
|
||||
order.TotalShopMoney = orderSettlement.SettlementAmount
|
||||
order.PmSubsidyMoney = orderSettlement.PlatOrderGoodsDiscountMoney + orderSettlement.PlatSkuGoodsDiscountMoney
|
||||
|
||||
Reference in New Issue
Block a user