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

取消打印

Browse Source
This commit is contained in:
邹宗楠
2022-03-25 09:38:37 +08:00
parent f8c576d750
commit b87ca81722
2 changed files with 21 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
business/jxstore/cms/store.go
View File

@@ -1952,13 +1952,13 @@ func updateCourierStores(ctx *jxcontext.Context, storeID int) (err error) {
db := dao.GetDB() db := dao.GetDB()
errList := errlist.New() errList := errlist.New()
for k, v := range partner.DeliveryPlatformHandlers { for k, v := range partner.DeliveryPlatformHandlers {
fmt.Println("k===================", k) //fmt.Println("k===================", k)
if v.Use4CreateWaybill { if v.Use4CreateWaybill {
if _, ok := v.Handler.(partner.IDeliveryUpdateStoreHandler); ok { if _, ok := v.Handler.(partner.IDeliveryUpdateStoreHandler); ok {
storeDetail, err2 := dao.GetStoreDetail2(db, storeID, "", k) storeDetail, err2 := dao.GetStoreDetail2(db, storeID, "", k)
fmt.Println("storeDetail.VendorID===================", storeDetail.VendorID) //fmt.Println("storeDetail.VendorID===================", storeDetail.VendorID)
fmt.Println("storeDetail.AuditStatus===================", storeDetail.AuditStatus) //fmt.Println("storeDetail.AuditStatus===================", storeDetail.AuditStatus)
fmt.Println("storeDetail.VendorStoreID===================", storeDetail.VendorStoreID) //fmt.Println("storeDetail.VendorStoreID===================", storeDetail.VendorStoreID)
if err = err2; err2 == nil { if err = err2; err2 == nil {
if storeDetail.VendorStoreID != "" && storeDetail.AuditStatus == model.StoreAuditStatusOnline { if storeDetail.VendorStoreID != "" && storeDetail.AuditStatus == model.StoreAuditStatusOnline {
// 同步更新门店信息 // 同步更新门店信息

34
business/jxstore/cms/sync2.go
View File

@@ -150,36 +150,36 @@ func SyncCategories(ctx *jxcontext.Context, parentTask tasksch.ITask, vendorIDs
} }
func SyncSkus(ctx *jxcontext.Context, parentTask tasksch.ITask, vendorIDs []int, appOrgCodes []string, nameIDs, skuIDs []int, isAsync bool) (hint string, err error) { func SyncSkus(ctx *jxcontext.Context, parentTask tasksch.ITask, vendorIDs []int, appOrgCodes []string, nameIDs, skuIDs []int, isAsync bool) (hint string, err error) {
globals.SugarLogger.Debugf("SyncSkus============= vendorIDs:%v, appOrgCodes:%v, nameIDs:%v, skuIDs:%v", vendorIDs, appOrgCodes, nameIDs, skuIDs) //globals.SugarLogger.Debugf("SyncSkus============= vendorIDs:%v, appOrgCodes:%v, nameIDs:%v, skuIDs:%v", vendorIDs, appOrgCodes, nameIDs, skuIDs)
db := dao.GetDB() db := dao.GetDB()
skuList, err := dao.GetSkusWithVendor(db, vendorIDs, appOrgCodes, nameIDs, skuIDs, true) skuList, err := dao.GetSkusWithVendor(db, vendorIDs, appOrgCodes, nameIDs, skuIDs, true)
globals.SugarLogger.Debugf("skuList============= skuList:%v", len(skuList)) //globals.SugarLogger.Debugf("skuList============= skuList:%v", len(skuList))
cc := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { cc := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
globals.SugarLogger.Debugf("batchItemList============DeleteSku2:%v", batchItemList) //globals.SugarLogger.Debugf("batchItemList============DeleteSku2:%v", batchItemList)
skuVendorInfo := batchItemList[0].(*dao.StoreSkuSyncInfo) skuVendorInfo := batchItemList[0].(*dao.StoreSkuSyncInfo)
globals.SugarLogger.Debugf("skuVendorInfo============skuVendorInfo:%v", skuVendorInfo) //globals.SugarLogger.Debugf("skuVendorInfo============skuVendorInfo:%v", skuVendorInfo)
globals.SugarLogger.Debugf("skuVendorInfo============skuVendorInfo:%v", &skuVendorInfo) //globals.SugarLogger.Debugf("skuVendorInfo============skuVendorInfo:%v", &skuVendorInfo)
var failedList []*partner.StoreSkuInfoWithErr var failedList []*partner.StoreSkuInfoWithErr
// if skuVendorInfo.VendorCatID == "" { // if skuVendorInfo.VendorCatID == "" {
// return nil, fmt.Errorf("商品:%d的商家分类没有同步", skuVendorInfo.SkuID) // return nil, fmt.Errorf("商品:%d的商家分类没有同步", skuVendorInfo.SkuID)
// } // }
globals.SugarLogger.Debugf("步骤1============= DeleteSku2:%v", skuVendorInfo.BindID) //globals.SugarLogger.Debugf("步骤1============= DeleteSku2:%v", skuVendorInfo.BindID)
if skuVendorInfo.BindID == 0 { if skuVendorInfo.BindID == 0 {
return nil, fmt.Errorf("商品:%d的数据异常", skuVendorInfo.SkuID) return nil, fmt.Errorf("商品:%d的数据异常", skuVendorInfo.SkuID)
} }
globals.SugarLogger.Debugf("步骤2============= DeleteSku2:%v", skuVendorInfo.ExdSkuID) //globals.SugarLogger.Debugf("步骤2============= DeleteSku2:%v", skuVendorInfo.ExdSkuID)
if skuVendorInfo.ExdSkuID != "" { if skuVendorInfo.ExdSkuID != "" {
return nil, err return nil, err
} }
globals.SugarLogger.Debugf("步骤3============= DeleteSku2:%v", skuVendorInfo.VendorSkuID) //globals.SugarLogger.Debugf("步骤3============= DeleteSku2:%v", skuVendorInfo.VendorSkuID)
globals.SugarLogger.Debugf("步骤3============= DeleteSku2:%v", !model.IsSyncStatusNew(skuVendorInfo.SkuSyncStatus)) //globals.SugarLogger.Debugf("步骤3============= DeleteSku2:%v", !model.IsSyncStatusNew(skuVendorInfo.SkuSyncStatus))
globals.SugarLogger.Debugf("步骤TTTTT============ DeleteSku2:%v", skuVendorInfo.SkuSyncStatus) //globals.SugarLogger.Debugf("步骤TTTTT============ DeleteSku2:%v", skuVendorInfo.SkuSyncStatus)
//todo 暂时注释 //todo 暂时注释
if !model.IsSyncStatusNew(skuVendorInfo.SkuSyncStatus) && skuVendorInfo.VendorSkuID == "" { if !model.IsSyncStatusNew(skuVendorInfo.SkuSyncStatus) && skuVendorInfo.VendorSkuID == "" {
return nil, err return nil, err
} }
globals.SugarLogger.Debugf("步骤4============= DeleteSku2:%v", skuVendorInfo.SkuVendorMapCatID) //globals.SugarLogger.Debugf("步骤4============= DeleteSku2:%v", skuVendorInfo.SkuVendorMapCatID)
if skuVendorInfo.SkuVendorMapCatID != "" { if skuVendorInfo.SkuVendorMapCatID != "" {
skuVendorInfo.VendorVendorCatID = utils.Str2Int64(skuVendorInfo.SkuVendorMapCatID) skuVendorInfo.VendorVendorCatID = utils.Str2Int64(skuVendorInfo.SkuVendorMapCatID)
} }
@@ -190,27 +190,27 @@ func SyncSkus(ctx *jxcontext.Context, parentTask tasksch.ITask, vendorIDs []int,
skuVendorInfo.ImgMix = jxutils.MixWatermarkImg(downLoad, skuVendorInfo.Img, skuVendorInfo.ExPrefixBegin, skuVendorInfo.ExPrefixEnd) skuVendorInfo.ImgMix = jxutils.MixWatermarkImg(downLoad, skuVendorInfo.Img, skuVendorInfo.ExPrefixBegin, skuVendorInfo.ExPrefixEnd)
} }
skuVendorInfo.MergedStatus = jxutils.MergeSkuStatus(skuVendorInfo.Status, skuVendorInfo.NameStatus) skuVendorInfo.MergedStatus = jxutils.MergeSkuStatus(skuVendorInfo.Status, skuVendorInfo.NameStatus)
globals.SugarLogger.Debugf("步骤1============= last1:%v", *skuVendorInfo) //globals.SugarLogger.Debugf("步骤1============= last1:%v", *skuVendorInfo)
globals.SugarLogger.Debugf("步骤1============= last2:%v", &skuVendorInfo) //globals.SugarLogger.Debugf("步骤1============= last2:%v", &skuVendorInfo)
globals.SugarLogger.Debugf("步骤1============= last3:%v", skuVendorInfo) //globals.SugarLogger.Debugf("步骤1============= last3:%v", skuVendorInfo)
if multiStoresHandler, ok := partner.GetPurchasePlatformFromVendorID(skuVendorInfo.VendorID).(partner.IMultipleStoresHandler); ok { if multiStoresHandler, ok := partner.GetPurchasePlatformFromVendorID(skuVendorInfo.VendorID).(partner.IMultipleStoresHandler); ok {
if model.IsSyncStatusDelete(skuVendorInfo.SkuSyncStatus) { //删除 if model.IsSyncStatusDelete(skuVendorInfo.SkuSyncStatus) { //删除
if !dao.IsVendorThingIDEmpty(skuVendorInfo.VendorSkuID) && if !dao.IsVendorThingIDEmpty(skuVendorInfo.VendorSkuID) &&
model.IsSyncStatusNeedDelete(skuVendorInfo.SkuSyncStatus) { model.IsSyncStatusNeedDelete(skuVendorInfo.SkuSyncStatus) {
globals.SugarLogger.Debugf("CreateSku2============= DeleteSku2:%v", model.IsSyncStatusNew(skuVendorInfo.SkuSyncStatus)) //globals.SugarLogger.Debugf("CreateSku2============= DeleteSku2:%v", model.IsSyncStatusNew(skuVendorInfo.SkuSyncStatus))
err = multiStoresHandler.DeleteSku2(ctx, skuVendorInfo.VendorOrgCode, storeSkuSyncInfo2Bare(skuVendorInfo)) err = multiStoresHandler.DeleteSku2(ctx, skuVendorInfo.VendorOrgCode, storeSkuSyncInfo2Bare(skuVendorInfo))
if err != nil { if err != nil {
failedList = putils.GetErrMsg2FailedSingleList(skuVendorInfo, err, 0, model.VendorChineseNames[skuVendorInfo.VendorID], "删除商品") failedList = putils.GetErrMsg2FailedSingleList(skuVendorInfo, err, 0, model.VendorChineseNames[skuVendorInfo.VendorID], "删除商品")
} }
} }
} else if model.IsSyncStatusNew(skuVendorInfo.SkuSyncStatus) { // 新增 } else if model.IsSyncStatusNew(skuVendorInfo.SkuSyncStatus) { // 新增
globals.SugarLogger.Debugf("CreateSku2============= CreateSku2:%v", model.IsSyncStatusNew(skuVendorInfo.SkuSyncStatus)) //globals.SugarLogger.Debugf("CreateSku2============= CreateSku2:%v", model.IsSyncStatusNew(skuVendorInfo.SkuSyncStatus))
err = multiStoresHandler.CreateSku2(ctx, skuVendorInfo) err = multiStoresHandler.CreateSku2(ctx, skuVendorInfo)
if err != nil { if err != nil {
failedList = putils.GetErrMsg2FailedSingleList(skuVendorInfo, err, 0, model.VendorChineseNames[skuVendorInfo.VendorID], "新增商品") failedList = putils.GetErrMsg2FailedSingleList(skuVendorInfo, err, 0, model.VendorChineseNames[skuVendorInfo.VendorID], "新增商品")
} }
} else if model.IsSyncStatusUpdate(skuVendorInfo.SkuSyncStatus) { // 修改 } else if model.IsSyncStatusUpdate(skuVendorInfo.SkuSyncStatus) { // 修改
globals.SugarLogger.Debugf("UpdateSku2============= UpdateSku2:%v", model.IsSyncStatusNew(skuVendorInfo.SkuSyncStatus)) //globals.SugarLogger.Debugf("UpdateSku2============= UpdateSku2:%v", model.IsSyncStatusNew(skuVendorInfo.SkuSyncStatus))
err = multiStoresHandler.UpdateSku2(ctx, skuVendorInfo) err = multiStoresHandler.UpdateSku2(ctx, skuVendorInfo)
if err != nil { if err != nil {
failedList = putils.GetErrMsg2FailedSingleList(skuVendorInfo, err, 0, model.VendorChineseNames[skuVendorInfo.VendorID], "修改商品") failedList = putils.GetErrMsg2FailedSingleList(skuVendorInfo, err, 0, model.VendorChineseNames[skuVendorInfo.VendorID], "修改商品")