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:
邹宗楠
2026-01-29 15:26:49 +08:00
parent f5b33b5c7b
commit a86a0c43db
1 changed files with 53 additions and 47 deletions
Download Patch File Download Diff File Expand all files Collapse all files

100
business/jxstore/cms/sku.go
View File

@@ -4,7 +4,7 @@ import (
"encoding/json"
"errors"
"fmt"
"git.rosy.net.cn/jx-callback/business/partner/purchase/mtwm"
"git.rosy.net.cn/baseapi/platformapi/mtwmapi"
"io"
"math"
"mime/multipart"
@@ -3069,54 +3069,60 @@ func UpdateVendorImg(ctx *jxcontext.Context, i, storeId int, imgWaterMark string
if err != nil {
return nil, err
}
api := mtwm.GetAPI(storeDetail.VendorOrgCode, storeId, storeDetail.VendorStoreID)
//for {
foodList, _ := api.RetailListAll(storeDetail.VendorStoreID, i)
for _, v := range foodList {
skuEx := &model.SkuExinfoMap{
NameID: storeId,
ImgWatermark: v.PictureList[0], // 原图
ImgWatermarkMix: v.AppFoodCode, // 商品ID
ExPrefix: exPrefix,
VendorID: vendorID,
BeginAt: fromTimeP,
EndAt: toTimeP,
BrandID: 0,
}
dao.WrapAddIDCULDEntity(skuEx, ctx.GetUserName())
dao.CreateEntity(db, skuEx)
param := map[string]interface{}{}
qiNiuImg := ""
ImgMix := ""
if imgWaterMark != "" {
qiNiuImg = jxutils.UploadQiNiuImg(v.PictureList[0])
if ImgMix = jxutils.MixWatermarkImg2(imgWaterMark, qiNiuImg, &fromTimeP, &toTimeP); ImgMix != "" {
picture := make([]string, 0, len(v.PictureList))
picture = append(picture, ImgMix)
if len(v.PictureList) > 1 {
picture = append(picture, v.PictureList[1:]...)
}
param["picture"] = strings.Join(picture, ",")
}
}
if exPrefix != "" {
param["name"] = fmt.Sprintf("%s %s", exPrefix, v.Name)
}
if err = api.RetailInitData(utils.GetUUID(), storeDetail.VendorStoreID, v.AppFoodCode, param); err != nil {
globals.SugarLogger.Debugf("------foodCode := %s ,err := %v param := %s", v.AppFoodCode, err, utils.Format4Output(params, false))
}
imgList = append(imgList, qiNiuImg, ImgMix)
time.Sleep(100 * time.Microsecond)
var api *mtwmapi.API //= mtwm.GetAPI(fromStore.VendorOrgCode, fromStore.ID, fromStore.VendorStoreID)
if storeDetail.VendorOrgCode == globals.Mtwm2Code {
api = mtwmapi.New(beego.AppConfig.DefaultString("mtwmAppID2", ""), beego.AppConfig.DefaultString("mtwmSecret2", ""), beego.AppConfig.DefaultString("mtwmCallbackURL2", ""), "")
api.SetToken(storeDetail.MtwmToken)
} else {
api = partner.CurAPIManager.GetAPI(model.VendorIDMTWM, storeDetail.VendorOrgCode).(*mtwmapi.API)
}
for {
foodList, _ := api.RetailListAll(storeDetail.VendorStoreID, i)
for _, v := range foodList {
skuEx := &model.SkuExinfoMap{
NameID: storeId,
ImgWatermark: v.PictureList[0], // 原图
ImgWatermarkMix: v.AppFoodCode, // 商品ID
ExPrefix: exPrefix,
VendorID: vendorID,
BeginAt: fromTimeP,
EndAt: toTimeP,
BrandID: 0,
}
dao.WrapAddIDCULDEntity(skuEx, ctx.GetUserName())
dao.CreateEntity(db, skuEx)
param := map[string]interface{}{}
qiNiuImg := ""
ImgMix := ""
if imgWaterMark != "" {
qiNiuImg = jxutils.UploadQiNiuImg(v.PictureList[0])
if ImgMix = jxutils.MixWatermarkImg2(imgWaterMark, qiNiuImg, &fromTimeP, &toTimeP); ImgMix != "" {
picture := make([]string, 0, len(v.PictureList))
picture = append(picture, ImgMix)
if len(v.PictureList) > 1 {
picture = append(picture, v.PictureList[1:]...)
}
param["picture"] = strings.Join(picture, ",")
}
}
if exPrefix != "" {
param["name"] = fmt.Sprintf("%s %s", exPrefix, v.Name)
}
if err = api.RetailInitData(utils.GetUUID(), storeDetail.VendorStoreID, v.AppFoodCode, param); err != nil {
globals.SugarLogger.Debugf("------foodCode := %s ,err := %v param := %s", v.AppFoodCode, err, utils.Format4Output(params, false))
}
imgList = append(imgList, qiNiuImg, ImgMix)
time.Sleep(100 * time.Microsecond)
}
globals.SugarLogger.Debugf("----i := %d,len := %d", i, len(foodList))
if len(foodList) < 100 {
break
}
i++
}
// globals.SugarLogger.Debugf("----i := %d,len := %d", i, len(foodList))
// if len(foodList) < 100 {
// break
// }
// i++
//}
time.Sleep(1 * time.Second)
for _, v := range imgList {
jxutils.DeleteExportContent(strings.Split(v, "/")[3])
time.Sleep(100 * time.Microsecond)