1
This commit is contained in:
@@ -194,7 +194,7 @@ func BatchInitSkuEBai2EBai(ctx *jxcontext.Context, fromSku []*ebaiapi.SkuInfo, t
|
|||||||
if customSkuID == "" {
|
if customSkuID == "" {
|
||||||
customSkuID = utils.Int64ToStr(storeSku.SkuId)
|
customSkuID = utils.Int64ToStr(storeSku.SkuId)
|
||||||
}
|
}
|
||||||
_, err := toApi.SkuCreate(ctx.GetTrackInfo(), storeID, utils.Str2Int64(storeSku.CustomSkuID), params)
|
_, err := toApi.SkuCreate(ctx.GetTrackInfo(), storeID, storeSku.CustomSkuID, params)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
errList = append(errList, err)
|
errList = append(errList, err)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -52,11 +52,13 @@ func (p *PurchaseHandler) InvoiceApply(msg *ebaiapi.CallbackMsg) (response *ebai
|
|||||||
applyNo = invoice.ApplicationNo
|
applyNo = invoice.ApplicationNo
|
||||||
storeId = invoice.ShopId
|
storeId = invoice.ShopId
|
||||||
vendorStoreId = invoice.BaiduShopId
|
vendorStoreId = invoice.BaiduShopId
|
||||||
|
localOrder, _ := partner.CurOrderManager.LoadOrder(orderId, model.VendorIDEBAI)
|
||||||
|
|
||||||
if invoiceData == nil {
|
if invoiceData == nil {
|
||||||
invoiceObj := &model.InvoiceMsg{
|
invoiceObj := &model.InvoiceMsg{
|
||||||
ModelIDCUL: model.ModelIDCUL{},
|
ModelIDCUL: model.ModelIDCUL{},
|
||||||
OrderId: orderId,
|
OrderId: orderId,
|
||||||
StoreID: utils.Str2Int(invoice.ShopId),
|
StoreID: localOrder.JxStoreID,
|
||||||
VendorID: model.VendorIDEBAI,
|
VendorID: model.VendorIDEBAI,
|
||||||
InvoiceTaskId: invoice.ApplicationNo,
|
InvoiceTaskId: invoice.ApplicationNo,
|
||||||
Status: invoice.Status,
|
Status: invoice.Status,
|
||||||
|
|||||||
@@ -270,18 +270,18 @@ func (p *PurchaseHandler) CreateStoreSkus(ctx *jxcontext.Context, storeID int, v
|
|||||||
var (
|
var (
|
||||||
vendorSkuID int64
|
vendorSkuID int64
|
||||||
isExd bool = false
|
isExd bool = false
|
||||||
customSkuID int64
|
customSkuID string
|
||||||
)
|
)
|
||||||
if strings.Contains(storeSku.StoreName, model.ExdStoreName) {
|
if strings.Contains(storeSku.StoreName, model.ExdStoreName) {
|
||||||
isExd = true
|
isExd = true
|
||||||
if storeSku.ExdSkuID == "" {
|
if storeSku.ExdSkuID == "" {
|
||||||
customSkuID = 0
|
customSkuID = ""
|
||||||
} else {
|
} else {
|
||||||
customSkuID = utils.Str2Int64(storeSku.ExdSkuID)
|
customSkuID = storeSku.ExdSkuID
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
isExd = false
|
isExd = false
|
||||||
customSkuID = int64(storeSku.SkuID)
|
customSkuID = utils.Int2Str(storeSku.SkuID)
|
||||||
}
|
}
|
||||||
|
|
||||||
params := genSkuParamsFromStoreSkuInfo2(storeSku, true, true)
|
params := genSkuParamsFromStoreSkuInfo2(storeSku, true, true)
|
||||||
|
|||||||
@@ -47,7 +47,6 @@ func init() {
|
|||||||
// 单协程串行处理所有售后消息,天然有序,无并发冲突
|
// 单协程串行处理所有售后消息,天然有序,无并发冲突
|
||||||
go func() {
|
go func() {
|
||||||
for msg := range globalAfsChan {
|
for msg := range globalAfsChan {
|
||||||
globals.SugarLogger.Debugf("--------33 := %s", utils.Format4Output(msg, false))
|
|
||||||
jxutils.CallMsgHandlerAsync(func() {
|
jxutils.CallMsgHandlerAsync(func() {
|
||||||
_ = CurPurchaseHandler.onAfsOrderMsg(msg)
|
_ = CurPurchaseHandler.onAfsOrderMsg(msg)
|
||||||
}, jxutils.ComposeUniversalOrderID(GetOrderIDFromMsg(msg), model.VendorIDMTWM))
|
}, jxutils.ComposeUniversalOrderID(GetOrderIDFromMsg(msg), model.VendorIDMTWM))
|
||||||
|
|||||||
Reference in New Issue
Block a user