This commit is contained in:
邹宗楠
2025-10-22 14:35:18 +08:00
parent 2d8b978e9b
commit e49a4f6a2e
2 changed files with 27 additions and 8 deletions

View File

@@ -34,10 +34,27 @@ func OnCallbackMsg(msg *mtwmapi.CallbackMsg, msgType string) (response *mtwmapi.
_, err := netprinter.PrintStoreStatus(jxcontext.AdminCtx, storeDetail, model.VendorIDMTWM, -9)
response = mtwmapi.Err2CallbackResponse(err, "")
} else if msg.Cmd == mtwmapi.MsgTypeSkuUpdate {
globals.SugarLogger.Debugf("-----MsgTypeSkuUpdate := %s", utils.Format4Output(msg.FormData.Get("retail_data"), false))
dataMap := make([]*mtwmapi.VendorUpdateSkuCallback, 0, 0)
json.Unmarshal([]byte(msg.FormData.Get("retail_data")), &dataMap)
globals.SugarLogger.Debugf("-----MsgTypeSkuUpdate := %s", utils.Format4Output(dataMap, false))
if len(dataMap) != 0 {
for _, v := range dataMap {
globals.SugarLogger.Debugf("-----MsgTypeSkuUpdate := %s", utils.Format4Output(v, false))
if v.AppFoodCode != "" && v.AppPoiCode != "" {
storeDetail, _ := dao.GetStoreDetailByVendorStoreID(dao.GetDB(), v.AppPoiCode, model.VendorIDMTWM, utils.Int2Str(v.AppId))
if storeDetail != nil {
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)
dao.ExecuteSQL(dao.GetDB(), "UPDATE store_sku_bind SET status = ?,last_operator = ? WHERE store_id = ? AND sku_id = ? ", param...)
}
}
}
}
return mtwmapi.Err2CallbackResponse(nil, "")
} else {
if orderID := GetOrderIDFromMsg(msg); orderID != "" {