This commit is contained in:
邹宗楠
2024-04-19 10:16:00 +08:00
parent 7a3a7d18f8
commit 56728fc32a

View File

@@ -1,7 +1,6 @@
package cms package cms
import ( import (
"encoding/json"
"fmt" "fmt"
"git.rosy.net.cn/baseapi/platformapi/ebaiapi" "git.rosy.net.cn/baseapi/platformapi/ebaiapi"
"git.rosy.net.cn/jx-callback/business/jxutils/tasksch" "git.rosy.net.cn/jx-callback/business/jxutils/tasksch"
@@ -375,61 +374,61 @@ func BatchInitSkuMT2MT(ctx *jxcontext.Context, fromSku []*mtwmapi.AppFood, toApi
//#endregion //#endregion
//#region 同步活动 //#region 同步活动
//
func CopyMtActToMt(ctx *jxcontext.Context, fromStore, toStore *dao.StoreDetail) { //func CopyMtActToMt(ctx *jxcontext.Context, fromStore, toStore *dao.StoreDetail) {
var fromApi *mtwmapi.API // var fromApi *mtwmapi.API
var toApi *mtwmapi.API // var toApi *mtwmapi.API
var errData = make([]error, 0, 0) // var errData = make([]error, 0, 0)
//
if fromStore.VendorOrgCode == globals.Mtwm2Code { // if fromStore.VendorOrgCode == globals.Mtwm2Code {
fromApi = mtwmapi.New(beego.AppConfig.DefaultString("mtwmAppID2", ""), beego.AppConfig.DefaultString("mtwmSecret2", ""), beego.AppConfig.DefaultString("mtwmCallbackURL2", ""), "") // fromApi = mtwmapi.New(beego.AppConfig.DefaultString("mtwmAppID2", ""), beego.AppConfig.DefaultString("mtwmSecret2", ""), beego.AppConfig.DefaultString("mtwmCallbackURL2", ""), "")
fromApi.SetToken(fromStore.MtwmToken) // fromApi.SetToken(fromStore.MtwmToken)
} else { // } else {
fromApi = partner.CurAPIManager.GetAPI(model.VendorIDMTWM, fromStore.VendorOrgCode).(*mtwmapi.API) // fromApi = partner.CurAPIManager.GetAPI(model.VendorIDMTWM, fromStore.VendorOrgCode).(*mtwmapi.API)
} // }
//
if toStore.VendorOrgCode == globals.Mtwm2Code { // if toStore.VendorOrgCode == globals.Mtwm2Code {
toApi = mtwmapi.New(beego.AppConfig.DefaultString("mtwmAppID2", ""), beego.AppConfig.DefaultString("mtwmSecret2", ""), beego.AppConfig.DefaultString("mtwmCallbackURL2", ""), "") // toApi = mtwmapi.New(beego.AppConfig.DefaultString("mtwmAppID2", ""), beego.AppConfig.DefaultString("mtwmSecret2", ""), beego.AppConfig.DefaultString("mtwmCallbackURL2", ""), "")
toApi.SetToken(toStore.MtwmToken) // toApi.SetToken(toStore.MtwmToken)
} else { // } else {
toApi = partner.CurAPIManager.GetAPI(model.VendorIDMTWM, toStore.VendorOrgCode).(*mtwmapi.API) // toApi = partner.CurAPIManager.GetAPI(model.VendorIDMTWM, toStore.VendorOrgCode).(*mtwmapi.API)
} // }
//
// 买赠活动 // // 买赠活动
buyGiftList, err := fromApi.BatchQueryBuyGiftsAll(fromStore.VendorStoreID) // buyGiftList, err := fromApi.BatchQueryBuyGiftsAll(fromStore.VendorStoreID)
if err != nil { // if err != nil {
errData = append(errData, fmt.Errorf("买赠活动异常:%v", errData)) // errData = append(errData, fmt.Errorf("买赠活动异常:%v", errData))
} // }
if len(buyGiftList) == model.NO { // if len(buyGiftList) == model.NO {
errData = append(errData, fmt.Errorf("门店暂无买赠活动")) // errData = append(errData, fmt.Errorf("门店暂无买赠活动"))
} // }
//
param := make([]*mtwmapi.BatchCreateBuyGiftsParam, 0, 0) // param := make([]*mtwmapi.BatchCreateBuyGiftsParam, 0, 0)
for _, v := range buyGiftList { // for _, v := range buyGiftList {
buyGift := &mtwmapi.BatchCreateBuyGiftsParam{ // buyGift := &mtwmapi.BatchCreateBuyGiftsParam{
AppSpuCode: v.AppSpuCode, // AppSpuCode: v.AppSpuCode,
StartTime: v.StartTime, // StartTime: v.StartTime,
EndTime: v.EndTime, // EndTime: v.EndTime,
GiftsType: v.GiftsType, // GiftsType: v.GiftsType,
GiftsName: v.GiftsName, // GiftsName: v.GiftsName,
GiftsAppSpuCode: v.GiftsAppSpuCode, // GiftsAppSpuCode: v.GiftsAppSpuCode,
BuyNum: v.BuyNum, // BuyNum: v.BuyNum,
GiftsNum: v.GiftsNum, // GiftsNum: v.GiftsNum,
GiftsCharge: v.GiftsCharge, // GiftsCharge: v.GiftsCharge,
GiftsDayLimit: v.GiftsDayLimit, // GiftsDayLimit: v.GiftsDayLimit,
} // }
//
// 赠品成本 // // 赠品成本
giftsCharge := &mtwmapi.GiftsChargeObj{} // giftsCharge := &mtwmapi.GiftsChargeObj{}
if err := json.Unmarshal([]byte(v.Charge), giftsCharge); err != nil { // if err := json.Unmarshal([]byte(v.Charge), giftsCharge); err != nil {
return // return
} // }
//
buyGift.GiftsCharge = utils.Str2Float64(fmt.Sprintf("%.2f", utils.Str2Float64(giftsCharge.GiftsCharge))) // buyGift.GiftsCharge = utils.Str2Float64(fmt.Sprintf("%.2f", utils.Str2Float64(giftsCharge.GiftsCharge)))
param = append(param, buyGift) // param = append(param, buyGift)
} // }
toApi.BatchCreateBuyGifts(toStore.VendorStoreID, param) // toApi.BatchCreateBuyGifts(toStore.VendorStoreID, param)
//
} //}
//#endregion //#endregion