This commit is contained in:
邹宗楠
2024-12-09 09:43:55 +08:00
parent bb58149ab7
commit 7e6c5f99e4
3 changed files with 6 additions and 19 deletions

View File

@@ -1903,8 +1903,6 @@ func updateStoresSkusWithoutSync(ctx *jxcontext.Context, db *dao.DaoDB, storeIDs
// if len(storeIDs)*len(skuBindInfos) > maxStoreNameBind2 { // if len(storeIDs)*len(skuBindInfos) > maxStoreNameBind2 {
// return nil, fmt.Errorf("门店商品信息大于%d", maxStoreNameBind2) // return nil, fmt.Errorf("门店商品信息大于%d", maxStoreNameBind2)
// } // }
globals.SugarLogger.Debugf("skuBindInfos--------:= %s", utils.Format4Output(skuBindInfos, false))
storeIDs = uniqueStoreIDs(storeIDs) storeIDs = uniqueStoreIDs(storeIDs)
skuBindInfos = uniqueStoreNameBind(skuBindInfos) skuBindInfos = uniqueStoreNameBind(skuBindInfos)
@@ -2029,7 +2027,6 @@ func updateStoresSkusWithoutSync(ctx *jxcontext.Context, db *dao.DaoDB, storeIDs
} }
} }
unitPrice = int(math.Floor(float64(unitPrice)*scaleFactor/10+0.5)) * 10 //四舍五入 价格为100倍 角分为十位个位 除以10 + 0.5对分位向下取整(完成四舍五入的方法) unitPrice = int(math.Floor(float64(unitPrice)*scaleFactor/10+0.5)) * 10 //四舍五入 价格为100倍 角分为十位个位 除以10 + 0.5对分位向下取整(完成四舍五入的方法)
globals.SugarLogger.Debugf("allBinds--------:= %s", utils.Format4Output(allBinds, false))
for _, v := range allBinds { for _, v := range allBinds {
if v.Stock == 0 { if v.Stock == 0 {
v.Stock = model.MaxStoreSkuStockQty v.Stock = model.MaxStoreSkuStockQty
@@ -2077,14 +2074,12 @@ func updateStoresSkusWithoutSync(ctx *jxcontext.Context, db *dao.DaoDB, storeIDs
setStoreSkuBindStatus(skuBind, model.SyncFlagNewMask) setStoreSkuBindStatus(skuBind, model.SyncFlagNewMask)
dao.WrapAddIDCULDEntity(skuBind, userName) dao.WrapAddIDCULDEntity(skuBind, userName)
if deletedSku := dao.GetDeletedStoreSkuBind(db, skuBind.StoreID, skuBind.SkuID); deletedSku == nil { if deletedSku := dao.GetDeletedStoreSkuBind(db, skuBind.StoreID, skuBind.SkuID); deletedSku == nil {
globals.SugarLogger.Debugf("deletedSku--------1:= %s", utils.Format4Output(deletedSku, false))
if err = dao.CreateEntity(db, skuBind); err != nil { if err = dao.CreateEntity(db, skuBind); err != nil {
dao.Rollback(db, txDB) dao.Rollback(db, txDB)
return nil, err return nil, err
} }
num = 1 num = 1
} else { } else {
globals.SugarLogger.Debugf("deletedSku--------2:= %s", utils.Format4Output(deletedSku, false))
// 需要处理,在删除某个门店商品,同步失败的情况下,又把商品重新关注。 // 需要处理,在删除某个门店商品,同步失败的情况下,又把商品重新关注。
// 所以统一处理成恢复删除的记录,这样避免问题 // 所以统一处理成恢复删除的记录,这样避免问题
skuBind.ID = deletedSku.ID skuBind.ID = deletedSku.ID

View File

@@ -546,21 +546,13 @@ func (c *PurchaseHandler) PickupGoods(order *model.GoodsOrder, isSelfDelivery bo
if err != nil { if err != nil {
return err return err
} }
api := getAPI(order.VendorOrgCode, jxutils.GetSaleStoreIDFromOrder(order), "") err = getAPI(order.VendorOrgCode, jxutils.GetSaleStoreIDFromOrder(order), "").DeliveryFinish(param)
for i := 0; i < 3; i++ { if err != nil {
err2 := api.DeliveryFinish(param) return err
if err2 != nil {
time.Sleep(200 * time.Millisecond)
err = err2
continue
} }
if err2 == nil {
c.postFakeMsg(order.VendorOrderID, tao_vegetable.OrderStatusPickedUp, tao_vegetable.OrderStatusPickedUp) c.postFakeMsg(order.VendorOrderID, tao_vegetable.OrderStatusPickedUp, tao_vegetable.OrderStatusPickedUp)
return nil
}
} }
}
return err return err
} }

View File

@@ -36,7 +36,7 @@ func (c *MtwmController) onCallbackMsg(msgType string) {
vendorStoreId = finishedPickup.AppPoiCode vendorStoreId = finishedPickup.AppPoiCode
} }
if vendorStoreId != "" { if vendorStoreId != "" {
globals.SugarLogger.Debugf("-----饿百订单非菜市消息推送-%s", utils.Format4Output(msg, false)) globals.SugarLogger.Debugf("-----美团订单非菜市消息推送-%s", utils.Format4Output(msg, false))
storeDetail, _ := dao.GetStoreDetailByVendorStoreID(dao.GetDB(), vendorStoreId, model.VendorIDMTWM, "") storeDetail, _ := dao.GetStoreDetailByVendorStoreID(dao.GetDB(), vendorStoreId, model.VendorIDMTWM, "")
if storeDetail == nil { if storeDetail == nil {
switch web.BConfig.RunMode { switch web.BConfig.RunMode {