This commit is contained in:
邹宗楠
2025-01-10 16:06:05 +08:00
parent 290cfe926f
commit 235796c353

View File

@@ -1498,21 +1498,21 @@ func (c *OrderManager) AmendMissingOrders(ctx *jxcontext.Context, vendorIDs []in
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
pair := batchItemList[0].(*tOrderVendorPair)
if handler := partner.GetPurchaseOrderHandlerFromVendorID(pair.VendorID); handler != nil {
order, err2 := handler.GetOrder(pair.VendorOrgCode, pair.VendorOrderID, pair.VendorStoreID)
if err = err2; err == nil {
if beego.BConfig.RunMode == model.ServerTypePet {
order.BuyerComment = fmt.Sprintf("定时--:%s", utils.Time2Str(time.Now()))
}
isDuplicated, err2 := c.SaveOrder(order, false, dao.GetDB())
if err2 == nil && !isDuplicated {
retVal = []int{1}
if order.Status == model.OrderStatusNew {
err = handler.AcceptOrRefuseOrder(order, true, ctx.GetUserName())
storeDetail, err := dao.GetStoreDetailByVendorStoreID(dao.GetDB(), pair.VendorStoreID, pair.VendorID, pair.VendorOrgCode)
if err == nil && storeDetail != nil {
order, err2 := handler.GetOrder(pair.VendorOrgCode, pair.VendorOrderID, pair.VendorStoreID)
if err = err2; err == nil {
isDuplicated, err2 := c.SaveOrder(order, false, dao.GetDB())
if err2 == nil && !isDuplicated {
retVal = []int{1}
if order.Status == model.OrderStatusNew {
err = handler.AcceptOrRefuseOrder(order, true, ctx.GetUserName())
}
}
} else if pair.VendorID == model.VendorIDMTWM {
if strings.Contains(err.Error(), "token不存在或已经过期") {
err = nil
}
}
} else if pair.VendorID == model.VendorIDMTWM {
if strings.Contains(err.Error(), "token不存在或已经过期") {
err = nil
}
}
}