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

1

Browse Source
This commit is contained in:
邹宗楠
2025-12-22 11:48:00 +08:00
parent 91c96218ba
commit 2462c5162a
2 changed files with 23 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
business/partner/purchase/mtwm/callback.go
View File

@@ -46,24 +46,36 @@ func OnCallbackMsg(msg *mtwmapi.CallbackMsg, msgType string) (response *mtwmapi.
return nil return nil
} }
if len(dataMap) != 0 { if len(dataMap) != 0 {
var storeMap = make(map[string]map[int][]string, 0)
var skuStatus = make(map[int][]string, 0)
for _, v := range dataMap { for _, v := range dataMap {
if v.AppFoodCode != "" && v.AppPoiCode != "" { if v.AppFoodCode != "" && v.AppPoiCode != "" {
storeDetail, _ := dao.GetStoreDetailByVendorStoreID(dao.GetDB(), v.AppPoiCode, model.VendorIDMTWM, utils.Int2Str(v.AppId)) skuStatus[v.DiffContents.IsSoldOut.Result] = append(skuStatus[v.DiffContents.IsSoldOut.Result], v.AppFoodCode)
if storeDetail != nil { storeMap[v.AppPoiCode] = skuStatus
param := []interface{}{}
switch v.DiffContents.IsSoldOut.Result {
case 1: // 下架
param = append(param, 0)
case 0: // 上架
param = append(param, 1)
} }
param = append(param, mtwmapi.MsgTypeSkuUpdate, storeDetail.ID, v.AppFoodCode) }
sql := `UPDATE store_sku_bind SET status = ?,last_operator = ? WHERE store_id = ? AND sku_id = ? ` for k, v := range storeMap {
storeDetail, _ := dao.GetStoreDetailByVendorStoreID(dao.GetDB(), k, model.VendorIDMTWM, "")
if storeDetail != nil {
for k2, v2 := range v {
switch k2 {
case 1: // 下架
param := []interface{}{}
param = append(param, 0, mtwmapi.MsgTypeSkuUpdate, storeDetail.ID, v2)
sql := `UPDATE store_sku_bind SET status = ?,last_operator = ? WHERE store_id = ? AND sku_id IN` + "(" + dao.GenQuestionMarks(len(v2)) + ")"
dao.ExecuteSQL(dao.GetDB(), sql, param...)
case 0: // 上架
param := []interface{}{}
param = append(param, 1, mtwmapi.MsgTypeSkuUpdate, storeDetail.ID, v2)
sql := `UPDATE store_sku_bind SET status = ?,last_operator = ? WHERE store_id = ? AND sku_id IN` + "(" + dao.GenQuestionMarks(len(v2)) + ")"
dao.ExecuteSQL(dao.GetDB(), sql, param...) dao.ExecuteSQL(dao.GetDB(), sql, param...)
} }
} }
} }
} }
globals.SugarLogger.Debugf("---------storeMap : %s", utils.Format4Output(storeMap, false))
globals.SugarLogger.Debugf("---------skuStatus : %s", utils.Format4Output(skuStatus, false))
}
return mtwmapi.Err2CallbackResponse(nil, "") return mtwmapi.Err2CallbackResponse(nil, "")
} else { } else {
if orderID := GetOrderIDFromMsg(msg); orderID != "" { if orderID := GetOrderIDFromMsg(msg); orderID != "" {

2
business/partner/purchase/mtwm/store.go
View File

@@ -5,6 +5,7 @@ import (
"errors" "errors"
"fmt" "fmt"
"git.rosy.net.cn/baseapi/platformapi/dingdingapi" "git.rosy.net.cn/baseapi/platformapi/dingdingapi"
"git.rosy.net.cn/jx-callback/business/jxstore/cms"
"git.rosy.net.cn/jx-callback/business/jxutils/ddmsg" "git.rosy.net.cn/jx-callback/business/jxutils/ddmsg"
beego "github.com/astaxie/beego/server/web" beego "github.com/astaxie/beego/server/web"
"math" "math"
@@ -477,6 +478,7 @@ func (c *PurchaseHandler) UpdateStoreOpTime(ctx *jxcontext.Context, vendorOrgCod
err = getAPI(vendorOrgCode, storeID, vendorStoreID).PoiShipTimeUpdate(vendorStoreID, shippingTime) err = getAPI(vendorOrgCode, storeID, vendorStoreID).PoiShipTimeUpdate(vendorStoreID, shippingTime)
} }
} }
cms.AddEventDetail(dao.GetDB(), ctx, model.OperateUpdate, model.VendorIDMTWM, model.ThingTypeStore, storeID, "修改前:", shippingTime)
} }
return err return err
} }