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

fk

Browse Source
This commit is contained in:
gazebo
2019-12-11 10:28:38 +08:00
parent a3e1521bb4
commit 73811a7bc6
2 changed files with 34 additions and 35 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
business/jxstore/cms/store_sku.go
View File

@@ -268,10 +268,10 @@ func getGetStoresSkusBaseSQL(db *dao.DaoDB, storeIDs, skuIDs []int, isFocus bool
} }
sql += ")" sql += ")"
} }
if params["jdID"] != nil { // if params["jdID"] != nil {
sql += " AND t1.jd_id = ?" // sql += " AND t1.jd_id = ?"
sqlParams = append(sqlParams, params["jdID"].(int)) // sqlParams = append(sqlParams, params["jdID"].(int))
} // }
if params["name"] != nil { if params["name"] != nil {
sql += " AND t1.name LIKE ?" sql += " AND t1.name LIKE ?"
sqlParams = append(sqlParams, "%"+params["name"].(string)+"%") sqlParams = append(sqlParams, "%"+params["name"].(string)+"%")
@@ -315,7 +315,6 @@ func getGetStoresSkusBaseSQL(db *dao.DaoDB, storeIDs, skuIDs []int, isFocus bool
return "", nil, err return "", nil, err
} }
sql += " AND ( 1 = 0" sql += " AND ( 1 = 0"
// TODO
if params["jdSyncStatus"] != nil && realVendorMap[model.VendorIDJD] == 1 { if params["jdSyncStatus"] != nil && realVendorMap[model.VendorIDJD] == 1 {
sql += " OR (t4.jd_sync_status & ? <> 0 AND t2.jd_id <> 0 AND t1.status = ? AND t2.status = ?)" sql += " OR (t4.jd_sync_status & ? <> 0 AND t2.jd_id <> 0 AND t1.status = ? AND t2.status = ?)"
sqlParams = append(sqlParams, params["jdSyncStatus"], model.SkuStatusNormal, model.SkuStatusNormal) sqlParams = append(sqlParams, params["jdSyncStatus"], model.SkuStatusNormal, model.SkuStatusNormal)

60
business/jxstore/cms/sync.go
View File

@@ -188,9 +188,6 @@ func (v *VendorSync) oldSyncReorderCategories(ctx *jxcontext.Context, db *dao.Da
func (v *VendorSync) SyncStore(ctx *jxcontext.Context, db *dao.DaoDB, vendorID, storeID int, isAsync bool, userName string) (hint string, err error) { func (v *VendorSync) SyncStore(ctx *jxcontext.Context, db *dao.DaoDB, vendorID, storeID int, isAsync bool, userName string) (hint string, err error) {
globals.SugarLogger.Debugf("SyncStore, storeID:%d", storeID) globals.SugarLogger.Debugf("SyncStore, storeID:%d", storeID)
if vendorID == model.VendorIDJX {
return "1", nil
}
var vendorIDs []int var vendorIDs []int
if vendorID != -1 { if vendorID != -1 {
vendorIDs = []int{ vendorIDs = []int{
@@ -200,35 +197,38 @@ func (v *VendorSync) SyncStore(ctx *jxcontext.Context, db *dao.DaoDB, vendorID,
hint, err = v.LoopStoresMap(ctx, db, fmt.Sprintf("同步门店信息:%d", storeID), isAsync, false, vendorIDs, []int{storeID}, func(t *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (resultList interface{}, err error) { hint, err = v.LoopStoresMap(ctx, db, fmt.Sprintf("同步门店信息:%d", storeID), isAsync, false, vendorIDs, []int{storeID}, func(t *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (resultList interface{}, err error) {
loopMapInfo := batchItemList[0].(*LoopStoreMapInfo) loopMapInfo := batchItemList[0].(*LoopStoreMapInfo)
handler := v.GetStoreHandler(loopMapInfo.VendorID) handler := v.GetStoreHandler(loopMapInfo.VendorID)
if len(loopMapInfo.StoreMapList) > 1 { if handler != nil {
loopStoreTask := tasksch.NewParallelTask(fmt.Sprintf("处理平台%s", model.VendorChineseNames[loopMapInfo.VendorID]), nil, ctx, if len(loopMapInfo.StoreMapList) > 1 {
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { loopStoreTask := tasksch.NewParallelTask(fmt.Sprintf("处理平台%s", model.VendorChineseNames[loopMapInfo.VendorID]), nil, ctx,
var resultList []interface{} func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
storeMap := batchItemList[0].(*model.StoreMap) var resultList []interface{}
db2 := db storeMap := batchItemList[0].(*model.StoreMap)
if len(loopMapInfo.StoreMapList) > 1 { db2 := db
db2 = dao.GetDB() if len(loopMapInfo.StoreMapList) > 1 {
} db2 = dao.GetDB()
if err = handler.UpdateStore(db2, storeMap.StoreID, userName); err == nil { }
storeMap.SyncStatus = 0 if err = handler.UpdateStore(db2, storeMap.StoreID, userName); err == nil {
_, err = dao.UpdateEntity(db2, storeMap, model.FieldSyncStatus) storeMap.SyncStatus = 0
resultList = append(resultList, 1) _, err = dao.UpdateEntity(db2, storeMap, model.FieldSyncStatus)
} resultList = append(resultList, 1)
return resultList, err }
}, loopMapInfo.StoreMapList) return resultList, err
t.AddChild(loopStoreTask).Run() }, loopMapInfo.StoreMapList)
resultList, err = loopStoreTask.GetResult(0) t.AddChild(loopStoreTask).Run()
} else { resultList, err = loopStoreTask.GetResult(0)
storeMap := loopMapInfo.StoreMapList[0] } else {
if err = handler.UpdateStore(db, storeMap.StoreID, userName); err == nil { storeMap := loopMapInfo.StoreMapList[0]
storeMap.SyncStatus = 0 if err = handler.UpdateStore(db, storeMap.StoreID, userName); err == nil {
_, err = dao.UpdateEntity(db, storeMap, model.FieldSyncStatus) storeMap.SyncStatus = 0
} _, err = dao.UpdateEntity(db, storeMap, model.FieldSyncStatus)
if err == nil { }
resultList = []interface{}{1} if err == nil {
resultList = []interface{}{1}
}
} }
err = partner.AddVendorInfo2Err(err, loopMapInfo.VendorID)
} }
return resultList, partner.AddVendorInfo2Err(err, loopMapInfo.VendorID) return resultList, err
}, true) }, true)
return hint, makeSyncError(err) return hint, makeSyncError(err)
} }