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:
邹宗楠
2022-06-06 09:09:53 +08:00
parent ca60ea6560
commit d203757c8c
3 changed files with 0 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
business/enterprise_session/create_session.go
View File

@@ -89,16 +89,12 @@ func CheckUserExist(store *dao.StoreDetail2) (string, error) {
if err != nil { if err != nil {
return "", err return "", err
} }
fmt.Println("=====================1", parentCityName)
// 查询企业微信所有省份部门分类 // 查询企业微信所有省份部门分类
departmentList, err := api.EnterpriseChatHeadApi.GetAllDepartmentList() departmentList, err := api.EnterpriseChatHeadApi.GetAllDepartmentList()
if err != nil { if err != nil {
return "", err return "", err
} }
for _, v := range departmentList { for _, v := range departmentList {
fmt.Println("1===============", v.Name)
fmt.Println("2===============", parentCityName[:6])
fmt.Println("3===============", !strings.Contains(v.Name, parentCityName[:6]))
if !strings.Contains(v.Name, parentCityName[:6]) { if !strings.Contains(v.Name, parentCityName[:6]) {
continue continue
} }

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

@@ -78,8 +78,6 @@ func SyncStoreCategories(ctx *jxcontext.Context, parentTask tasksch.ITask, vendo
func(rootTask *tasksch.SeqTask, step int, params ...interface{}) (result interface{}, err error) { func(rootTask *tasksch.SeqTask, step int, params ...interface{}) (result interface{}, err error) {
level := step + 1 level := step + 1
catList, err := dao.GetDirtyStoreCategories(db, vendorID, storeID, level, skuIDs) catList, err := dao.GetDirtyStoreCategories(db, vendorID, storeID, level, skuIDs)
globals.SugarLogger.Debug("====================xinzheng22222",len(catList),storeID)
globals.SugarLogger.Debug("====================xinzheng22222",catList,storeID)
if len(catList) > 0 { if len(catList) > 0 {
num += len(catList) num += len(catList)
task := tasksch.NewParallelTask(fmt.Sprintf("%s SyncStoreCategory step2, level=%d", model.VendorChineseNames[vendorID], level), task := tasksch.NewParallelTask(fmt.Sprintf("%s SyncStoreCategory step2, level=%d", model.VendorChineseNames[vendorID], level),
@@ -106,7 +104,6 @@ func SyncStoreCategories(ctx *jxcontext.Context, parentTask tasksch.ITask, vendo
catInfo.Seq = catInfo.StoreCatSeq catInfo.Seq = catInfo.StoreCatSeq
} }
} }
globals.SugarLogger.Debug("====================xinzheng22222",catInfo.CatSyncStatus)
if model.IsSyncStatusDelete(catInfo.CatSyncStatus) { // 删除 4 if model.IsSyncStatusDelete(catInfo.CatSyncStatus) { // 删除 4
if model.IsSyncStatusDelete(catInfo.CatSyncStatus) && !dao.IsVendorThingIDEmpty(catInfo.VendorCatID) { if model.IsSyncStatusDelete(catInfo.CatSyncStatus) && !dao.IsVendorThingIDEmpty(catInfo.VendorCatID) {
err = handler.DeleteStoreCategory(ctx, storeID, vendorStoreID, catInfo.VendorCatID, level) err = handler.DeleteStoreCategory(ctx, storeID, vendorStoreID, catInfo.VendorCatID, level)
@@ -117,7 +114,6 @@ func SyncStoreCategories(ctx *jxcontext.Context, parentTask tasksch.ITask, vendo
} }
} }
} else if model.IsSyncStatusNew(catInfo.CatSyncStatus) { // 新增 2 } else if model.IsSyncStatusNew(catInfo.CatSyncStatus) { // 新增 2
globals.SugarLogger.Debug("====================xinzheng")
err = handler.CreateStoreCategory(ctx, storeID, vendorStoreID, catInfo) err = handler.CreateStoreCategory(ctx, storeID, vendorStoreID, catInfo)
if err != nil && handler.IsErrCategoryExist(err) { if err != nil && handler.IsErrCategoryExist(err) {
if cat, err2 := handler.GetStoreCategory(ctx, storeID, vendorStoreID, catInfo.Name); err2 == nil { if cat, err2 := handler.GetStoreCategory(ctx, storeID, vendorStoreID, catInfo.Name); err2 == nil {
@@ -185,16 +181,12 @@ func SyncStoreSkuNew2(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFla
} }
task := tasksch.NewSeqTask(fmt.Sprintf("SyncStoreSkuNew, storeID:%d", storeID), ctx, task := tasksch.NewSeqTask(fmt.Sprintf("SyncStoreSkuNew, storeID:%d", storeID), ctx,
func(task *tasksch.SeqTask, step int, params ...interface{}) (result interface{}, err error) { func(task *tasksch.SeqTask, step int, params ...interface{}) (result interface{}, err error) {
globals.SugarLogger.Debug("==============step",step)
switch step { switch step {
case 0: case 0:
globals.SugarLogger.Debug("==============step==0",step)
globals.SugarLogger.Debug("==============step==0",singleStoreHandler != nil)
if singleStoreHandler != nil { if singleStoreHandler != nil {
_, err = SyncStoreCategories(ctx, task, vendorID, storeID, vendorStoreID, nameIDs, skuIDs, false, isContinueWhenError) _, err = SyncStoreCategories(ctx, task, vendorID, storeID, vendorStoreID, nameIDs, skuIDs, false, isContinueWhenError)
} }
case 1: case 1:
globals.SugarLogger.Debug("==============step==1",step)
err = syncStoreSkuNew(ctx, task, causeFlag, false, vendorID, storeID, vendorOrgCode, nameIDs, skuIDs, excludeSkuIDs, useVendorPriceDirectly, isContinueWhenError) err = syncStoreSkuNew(ctx, task, causeFlag, false, vendorID, storeID, vendorOrgCode, nameIDs, skuIDs, excludeSkuIDs, useVendorPriceDirectly, isContinueWhenError)
} }
return result, err return result, err

4
business/model/dao/store_sku.go
View File

@@ -532,8 +532,6 @@ func GetStoreCategories2(db *DaoDB, vendorID, storeID int, skuIDs []int, level i
sql += " AND t4.level = ?" sql += " AND t4.level = ?"
sqlParams = append(sqlParams, level) sqlParams = append(sqlParams, level)
} }
globals.SugarLogger.Debug("=================lllllllllllll",fmt.Sprintf(sql, fieldPrefixParams...))
globals.SugarLogger.Debug("=================lllllllllllll",sqlParams)
if err = GetRows(GetDB(), &cats, fmt.Sprintf(sql, fieldPrefixParams...), sqlParams...); err != nil { if err = GetRows(GetDB(), &cats, fmt.Sprintf(sql, fieldPrefixParams...), sqlParams...); err != nil {
return nil, err return nil, err
} }
@@ -682,8 +680,6 @@ func GetStoreSkus2(db *DaoDB, vendorID, storeID int, skuIDs []int, mustDirty boo
sql = fmt.Sprintf(sql, fmtParams...) sql = fmt.Sprintf(sql, fmtParams...)
sql += " ORDER BY t1.price" sql += " ORDER BY t1.price"
// globals.SugarLogger.Debug(sql) // globals.SugarLogger.Debug(sql)
globals.SugarLogger.Debug("sql================",sql)
globals.SugarLogger.Debug("sql================",sqlParams)
if err = GetRows(db, &skus, sql, sqlParams...); err != nil { if err = GetRows(db, &skus, sql, sqlParams...); err != nil {
return nil, err return nil, err
} }