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:
邹宗楠
2024-01-25 11:37:20 +08:00
parent d967e67601
commit a2c3bf2238
4 changed files with 157 additions and 154 deletions
Download Patch File Download Diff File Expand all files Collapse all files

272
business/jxstore/cms/system_store_sku.go
View File

@@ -1,155 +1,149 @@
package cms
import (
"fmt"
"git.rosy.net.cn/baseapi/platformapi/ebaiapi"
"git.rosy.net.cn/jx-callback/business/model"
"git.rosy.net.cn/jx-callback/business/partner"
"git.rosy.net.cn/jx-callback/globals"
beego "github.com/astaxie/beego/server/web"
"time"
"git.rosy.net.cn/baseapi/platformapi/mtwmapi"
"git.rosy.net.cn/baseapi/utils"
"git.rosy.net.cn/jx-callback/business/jxutils/jxcontext"
"git.rosy.net.cn/jx-callback/business/jxutils/tasksch"
"git.rosy.net.cn/jx-callback/business/model/dao"
)
// CopyOnStoreSkuToOther 将一个美团门店分类和商品复制到另一个门店
func CopyOnStoreSkuToOther(ctx *jxcontext.Context, fromStoreId, toStoreId string, vendorId int, isAsync bool, offSet int) (hint string, err error) {
var (
db = dao.GetDB()
)
fromStoreDetail, _ := dao.GetStoreDetailByVendorStoreID(db, fromStoreId, vendorId, "")
if fromStoreDetail == nil {
return "", fmt.Errorf("%s,平台门店id未获取到", fromStoreId)
}
if fromStoreDetail.VendorOrgCode == globals.Mtwm2Code {
fromAPI := partner.CurAPIManager.GetAPI(vendorId, fromStoreDetail.VendorOrgCode).(*mtwmapi.API)
fromAPI.SetToken(fromStoreDetail.MtwmToken)
} else {
switch vendorId {
case model.VendorIDMTWM:
fromAPI = partner.CurAPIManager.GetAPI(vendorId, fromStoreDetail.VendorOrgCode).(*mtwmapi.API)
case model.VendorIDEBAI:
fromAPI = partner.CurAPIManager.GetAPI(vendorId, fromStoreDetail.VendorOrgCode).(*ebaiapi.API)
}
}
toStoreDetail, _ := dao.GetStoreDetailByVendorStoreID(db, toStoreId, vendorId, "")
if toStoreDetail == nil {
return "", fmt.Errorf("%s,平台门店id未获取到", fromStoreId)
}
if toStoreDetail.VendorOrgCode == globals.Mtwm2Code {
toAPI := partner.CurAPIManager.GetAPI(vendorId, toStoreDetail.VendorOrgCode).(*mtwmapi.API)
toAPI.SetToken(fromStoreDetail.MtwmToken)
}
apiObj := partner.CurAPIManager.GetAPI(vendorId, appOrgCode).(*mtwmapi.API)
if appOrgCode == globals.Mtwm2Code {
var storeDetail *dao.StoreDetail
if storeID != 0 {
storeDetail, _ = dao.GetStoreDetail(db, storeID, vendorId, appOrgCode)
} else if vendorStoreID != "" {
storeDetail, _ = dao.GetStoreDetailByVendorStoreID(db, vendorStoreID, vendorId, appOrgCode)
}
if storeDetail != nil {
apiObj.SetToken(storeDetail.MtwmToken)
}
}
// 门店api加载
toStore, err := dao.GetStoreDetailByVendorStoreID(db, toStoreId, vendorId, "")
if err != nil {
return "", err
}
toApi := mtwmapi.New(beego.AppConfig.DefaultString("mtwmAppID2", ""), beego.AppConfig.DefaultString("mtwmSecret2", ""), beego.AppConfig.DefaultString("mtwmCallbackURL2", ""), "")
toApi.SetToken(toStore.MtwmToken)
fromStore, err := dao.GetStoreDetailByVendorStoreID(db, fromStoreId, vendorId, "")
if err != nil {
return "", err
}
fromApi := mtwmapi.New(beego.AppConfig.DefaultString("mtwmAppID2", ""), beego.AppConfig.DefaultString("mtwmSecret2", ""), beego.AppConfig.DefaultString("mtwmCallbackURL2", ""), "")
fromApi.SetToken(fromStore.MtwmToken)
taskName := fmt.Sprintf("将平台门店[%s],分类和商品复制到[%s]", fromStoreId, toStoreId)
config := tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(false)
work := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
step := batchItemList[0].(int)
switch step {
// case 1:
// 1.加载门店商品,删除商品.当分类下没有商品时.删除分类
// errs := LoadingStoreSkuList(ctx, toApi, toStore.VendorStoreID)
//if errs != nil && len(errs) > 0 {
// return nil, errs[0]
//}
case 1:
handler, _ := partner.GetPurchasePlatformFromVendorID(vendorId).(partner.ISingleStoreStoreSkuHandler)
if handler == nil {
return nil, fmt.Errorf(model.VendorChineseNames[vendorId] + ":不存在此平台")
}
fromCategory, err := handler.GetStoreAllCategories(ctx, fromStore.ID, fromStore.VendorStoreID)
// 同步分类
fromCategoryList, err := fromApi.RetailCatList(utils.Int2Str(fromVendorStoreId))
//globals.SugarLogger.Debugf("err ============ %v", err)
//for _, v := range fromCategoryList {
// categoryErr := toApi.RetailCatUpdate(toStore.VendorStoreID, v.Name, &mtwmapi.Param4UpdateCat{
// CategoryCode: v.Code,
// Sequence: v.Sequence,
// })
// if categoryErr != nil {
// globals.SugarLogger.Debugf("err := RetailCatUpdate : %v", categoryErr)
// }
// if v.Children != nil && len(v.Children) != 0 {
// for _, c := range v.Children {
// if err3 := toApi.RetailCatUpdate(toStore.VendorStoreID, v.Name, &mtwmapi.Param4UpdateCat{
// CategoryNameOrigin: v.Name,
// //CategoryCodeOrigin: v.Code,
// //CategoryCode: v.Code,
// SecondaryCategoryCode: c.Code,
// SecondaryCategoryName: c.Name,
// Sequence: c.Sequence,
// }); err3 != nil {
// globals.SugarLogger.Debugf("err := RetailCatUpdate Children : %v", err3)
// }
// }
// }
//}
case 2:
i := offSet
for {
// 同步商品
fromFoodList, err1 := fromApi.RetailListAll(fromStoreId, i)
if len(fromFoodList) == 0 || fromFoodList == nil {
return nil, fmt.Errorf("fromFoodList 为空 %s ,i:= %d", utils.Format4Output(err1, false), i)
}
if err := BatchInitData(ctx, fromFoodList, toApi, toStore.VendorStoreID, i); err != nil {
globals.SugarLogger.Debugf("BatchInitData : %s", utils.Format4Output(err, false))
}
if len(fromFoodList) < 100 {
break
}
i++
}
}
return
}
task := tasksch.NewParallelTask(taskName, config, ctx, work, []int{1, 2})
tasksch.HandleTask(task, nil, true).Run()
if !isAsync {
_, err = task.GetResult(0)
hint = "1"
} else {
hint = task.ID
}
return hint, err
return "", err
//var (
// db = dao.GetDB()
//)
//
//fromStoreDetail, _ := dao.GetStoreDetailByVendorStoreID(db, fromStoreId, vendorId, "")
//if fromStoreDetail == nil {
// return "", fmt.Errorf("%s,平台门店id未获取到", fromStoreId)
//}
//if fromStoreDetail.VendorOrgCode == globals.Mtwm2Code {
// fromAPI := partner.CurAPIManager.GetAPI(vendorId, fromStoreDetail.VendorOrgCode).(*mtwmapi.API)
// fromAPI.SetToken(fromStoreDetail.MtwmToken)
//} else {
// switch vendorId {
// case model.VendorIDMTWM:
// fromAPI = partner.CurAPIManager.GetAPI(vendorId, fromStoreDetail.VendorOrgCode).(*mtwmapi.API)
// case model.VendorIDEBAI:
// fromAPI = partner.CurAPIManager.GetAPI(vendorId, fromStoreDetail.VendorOrgCode).(*ebaiapi.API)
// }
//}
//
//toStoreDetail, _ := dao.GetStoreDetailByVendorStoreID(db, toStoreId, vendorId, "")
//if toStoreDetail == nil {
// return "", fmt.Errorf("%s,平台门店id未获取到", fromStoreId)
//}
//if toStoreDetail.VendorOrgCode == globals.Mtwm2Code {
// toAPI := partner.CurAPIManager.GetAPI(vendorId, toStoreDetail.VendorOrgCode).(*mtwmapi.API)
// toAPI.SetToken(fromStoreDetail.MtwmToken)
//}
//
//apiObj := partner.CurAPIManager.GetAPI(vendorId, appOrgCode).(*mtwmapi.API)
//if appOrgCode == globals.Mtwm2Code {
// var storeDetail *dao.StoreDetail
// if storeID != 0 {
// storeDetail, _ = dao.GetStoreDetail(db, storeID, vendorId, appOrgCode)
// } else if vendorStoreID != "" {
// storeDetail, _ = dao.GetStoreDetailByVendorStoreID(db, vendorStoreID, vendorId, appOrgCode)
// }
// if storeDetail != nil {
// apiObj.SetToken(storeDetail.MtwmToken)
// }
//}
//
//// 门店api加载
//toStore, err := dao.GetStoreDetailByVendorStoreID(db, toStoreId, vendorId, "")
//if err != nil {
// return "", err
//}
//toApi := mtwmapi.New(beego.AppConfig.DefaultString("mtwmAppID2", ""), beego.AppConfig.DefaultString("mtwmSecret2", ""), beego.AppConfig.DefaultString("mtwmCallbackURL2", ""), "")
//toApi.SetToken(toStore.MtwmToken)
//
//fromStore, err := dao.GetStoreDetailByVendorStoreID(db, fromStoreId, vendorId, "")
//if err != nil {
// return "", err
//}
//fromApi := mtwmapi.New(beego.AppConfig.DefaultString("mtwmAppID2", ""), beego.AppConfig.DefaultString("mtwmSecret2", ""), beego.AppConfig.DefaultString("mtwmCallbackURL2", ""), "")
//fromApi.SetToken(fromStore.MtwmToken)
//
//taskName := fmt.Sprintf("将平台门店[%s],分类和商品复制到[%s]", fromStoreId, toStoreId)
//config := tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(false)
//work := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
// step := batchItemList[0].(int)
// switch step {
// // case 1:
// // 1.加载门店商品,删除商品.当分类下没有商品时.删除分类
// // errs := LoadingStoreSkuList(ctx, toApi, toStore.VendorStoreID)
// //if errs != nil && len(errs) > 0 {
// // return nil, errs[0]
// //}
// case 1:
// handler, _ := partner.GetPurchasePlatformFromVendorID(vendorId).(partner.ISingleStoreStoreSkuHandler)
// if handler == nil {
// return nil, fmt.Errorf(model.VendorChineseNames[vendorId] + ":不存在此平台")
// }
// fromCategory, err := handler.GetStoreAllCategories(ctx, fromStore.ID, fromStore.VendorStoreID)
//
// // 同步分类
// fromCategoryList, err := fromApi.RetailCatList(utils.Int2Str(fromVendorStoreId))
// //globals.SugarLogger.Debugf("err ============ %v", err)
// //for _, v := range fromCategoryList {
// // categoryErr := toApi.RetailCatUpdate(toStore.VendorStoreID, v.Name, &mtwmapi.Param4UpdateCat{
// // CategoryCode: v.Code,
// // Sequence: v.Sequence,
// // })
// // if categoryErr != nil {
// // globals.SugarLogger.Debugf("err := RetailCatUpdate : %v", categoryErr)
// // }
// // if v.Children != nil && len(v.Children) != 0 {
// // for _, c := range v.Children {
// // if err3 := toApi.RetailCatUpdate(toStore.VendorStoreID, v.Name, &mtwmapi.Param4UpdateCat{
// // CategoryNameOrigin: v.Name,
// // //CategoryCodeOrigin: v.Code,
// // //CategoryCode: v.Code,
// // SecondaryCategoryCode: c.Code,
// // SecondaryCategoryName: c.Name,
// // Sequence: c.Sequence,
// // }); err3 != nil {
// // globals.SugarLogger.Debugf("err := RetailCatUpdate Children : %v", err3)
// // }
// // }
// // }
// //}
//
// case 2:
// i := offSet
// for {
// // 同步商品
// fromFoodList, err1 := fromApi.RetailListAll(fromStoreId, i)
// if len(fromFoodList) == 0 || fromFoodList == nil {
// return nil, fmt.Errorf("fromFoodList 为空 %s ,i:= %d", utils.Format4Output(err1, false), i)
// }
//
// if err := BatchInitData(ctx, fromFoodList, toApi, toStore.VendorStoreID, i); err != nil {
// globals.SugarLogger.Debugf("BatchInitData : %s", utils.Format4Output(err, false))
// }
// if len(fromFoodList) < 100 {
// break
// }
// i++
// }
//
// }
// return
//}
//task := tasksch.NewParallelTask(taskName, config, ctx, work, []int{1, 2})
//tasksch.HandleTask(task, nil, true).Run()
//if !isAsync {
// _, err = task.GetResult(0)
// hint = "1"
//} else {
// hint = task.ID
//}
//return hint, err
}
func LoadingStoreSkuList(ctx *jxcontext.Context, api *mtwmapi.API, poiCode string) (err []error) {

3
business/partner/purchase/mtwm/order.go
View File

@@ -537,7 +537,7 @@ func (c *PurchaseHandler) PickupGoods(order *model.GoodsOrder, isSelfDelivery bo
// 美团专送、快送、混合送、美团企客
logisticsCode := utils.Interface2String(orderDetail["logistics_code"])
isSelfDelivery = logisticsCode == mtwmapi.PeiSongTypeMTZSJM || logisticsCode == mtwmapi.PeiSongTypeMTZSZJ || logisticsCode == mtwmapi.PeiSongTypeKuaiDi || logisticsCode == mtwmapi.PeiSongTypeMixed || logisticsCode == mtwmapi.PeiSongTypeQiKe
isSelfDelivery = logisticsCode == mtwmapi.PeiSongTypeMTZSJM || logisticsCode == mtwmapi.PeiSongTypeMTZSZJ || logisticsCode == mtwmapi.PeiSongTypeKuaiDi || logisticsCode == mtwmapi.PeiSongTypeMixed || logisticsCode == mtwmapi.PeiSongTypeQiKe || logisticsCode == mtwmapi.PeiSongTypeMixedExpressQiKe
//1001-专送（加盟）；1002-专送（自建）
//2002-快送；3001-混合送（专送+快送)
//4015-企客远距离配送
@@ -554,6 +554,7 @@ func (c *PurchaseHandler) PickupGoods(order *model.GoodsOrder, isSelfDelivery bo
//PeiSongTypeKuaiDi = "2002" // 快送
//PeiSongTypeWholeCity = "2010" // 全城送
//PeiSongTypeMixed = "3001" // 混合送（即美团专送+快送）
//PeiSongTypeMixedExpressQiKe // 混合快送
if isSelfDelivery {
err = api.PreparationMealComplete(utils.Str2Int64(order.VendorOrderID))
}