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

aa

Browse Source
This commit is contained in:
苏尹岚
2021-04-06 16:26:45 +08:00
parent 24c4c27efd
commit b84ff3e0f7
1 changed files with 57 additions and 57 deletions
Download Patch File Download Diff File Expand all files Collapse all files

114
business/jxstore/tempop/tempop.go
View File

@@ -1839,45 +1839,45 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
// }, storeMaps) // }, storeMaps)
// tasksch.HandleTask(task, nil, true).Run() // tasksch.HandleTask(task, nil, true).Run()
// task.GetID() // task.GetID()
// var ( var (
// db = dao.GetDB() db = dao.GetDB()
// vendorThingIDs []int64 vendorThingIDs []int64
// ) )
// storeMaps, _ := dao.GetStoresMapList(db, []int{model.VendorIDJD}, nil, []int{model.StoreStatusOpened, model.StoreStatusHaveRest, model.StoreStatusClosed}, model.StoreStatusAll, model.StoreIsSyncAll, "", "", "320406") storeMaps, _ := dao.GetStoresMapList(db, []int{model.VendorIDJD}, nil, nil, model.StoreStatusAll, model.StoreIsSyncAll, "", "", "320406")
// things, _ := dao.GetThingMapList(db, model.ThingTypeSku, []int{model.VendorIDJD}, nil, []string{"320406"}) things, _ := dao.GetThingMapList(db, model.ThingTypeSku, []int{model.VendorIDJD}, nil, []string{"320406"})
// thingIDmap := make(map[int64]string) thingIDmap := make(map[int64]string)
// for _, v := range things { for _, v := range things {
// if v.VendorThingID != "" { if v.VendorThingID != "" {
// // lists = append(lists, &jdapi.SkuIdEntity{ // lists = append(lists, &jdapi.SkuIdEntity{
// // OutSkuId: utils.Int64ToStr(v.ThingID), // OutSkuId: utils.Int64ToStr(v.ThingID),
// // }) // })
// vendorThingIDs = append(vendorThingIDs, utils.Str2Int64(v.VendorThingID)) vendorThingIDs = append(vendorThingIDs, utils.Str2Int64(v.VendorThingID))
// thingIDmap[utils.Str2Int64(v.VendorThingID)] = utils.Int64ToStr(v.ThingID) thingIDmap[utils.Str2Int64(v.VendorThingID)] = utils.Int64ToStr(v.ThingID)
// } }
// } }
// task := tasksch.NewParallelTask("uuuuu", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(true), ctx, task := tasksch.NewParallelTask("uuuuu", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(true), ctx,
// func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
// storeMap := batchItemList[0].(*model.StoreMap) storeMap := batchItemList[0].(*model.StoreMap)
// FreeBatchInfo("uuuuu2", func(task tasksch.ITask, batchedStoreSkuList []int64) (result interface{}, successCount int, err error) { FreeBatchInfo("uuuuu2", func(task tasksch.ITask, batchedStoreSkuList []int64) (result interface{}, successCount int, err error) {
// priceInfo, _ := api.JdAPI.GetStationInfoList(storeMap.VendorStoreID, batchedStoreSkuList) priceInfo, _ := api.JdAPI.GetStationInfoList(storeMap.VendorStoreID, batchedStoreSkuList)
// var list []*jdapi.SkuIdEntity var list []*jdapi.SkuIdEntity
// for _, vv := range priceInfo { for _, vv := range priceInfo {
// if vv.VipPrice != 0 { if vv.VipPrice != 0 {
// fmt.Println("vipPrice uuu", vv.SkuID) // fmt.Println("vipPrice uuu", vv.SkuID)
// list = append(list, &jdapi.SkuIdEntity{ list = append(list, &jdapi.SkuIdEntity{
// OutSkuId: thingIDmap[vv.SkuID], OutSkuId: thingIDmap[vv.SkuID],
// }) })
// } }
// } }
// err = api.JdAPI.DelVipPrice(utils.Int2Str(storeMap.StoreID), list) err = api.JdAPI.DelVipPrice(utils.Int2Str(storeMap.StoreID), list)
// return result, 0, err return result, 0, err
// }, ctx, task, vendorThingIDs, 50, true) }, ctx, task, vendorThingIDs, 50, true)
// return retVal, err return retVal, err
// }, storeMaps) }, storeMaps)
// tasksch.HandleTask(task, nil, true).Run() tasksch.HandleTask(task, nil, true).Run()
// _, err = task.GetResult(0) _, err = task.GetResult(0)
//京东账号更新 //京东账号更新
// var ( // var (
// db = dao.GetDB() // db = dao.GetDB()
@@ -1893,26 +1893,26 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
// } // }
// } // }
// } // }
var ( // var (
db = dao.GetDB() // db = dao.GetDB()
users []*model.User // users []*model.User
) // )
sql := ` // sql := `
SELECT DISTINCT a.* FROM user a // SELECT DISTINCT a.* FROM user a
LEFT JOIN auth_bind b ON a.user_id2 = b.auth_id // LEFT JOIN auth_bind b ON a.user_id2 = b.auth_id
WHERE name IN ( // WHERE name IN (
SELECT name FROM user WHERE deleted_at = '1970-01-01 00:00:00' GROUP BY name HAVING COUNT(*) > 1 ) // SELECT name FROM user WHERE deleted_at = '1970-01-01 00:00:00' GROUP BY name HAVING COUNT(*) > 1 )
AND a.mobile is null AND a.user_id <> b.user_id // AND a.mobile is null AND a.user_id <> b.user_id
ORDER BY a.name // ORDER BY a.name
` // `
dao.GetRows(db, &users, sql, nil) // dao.GetRows(db, &users, sql, nil)
for _, v := range users { // for _, v := range users {
tokens, _ := api.Cacher.Keys(v.UserID) // tokens, _ := api.Cacher.Keys(v.UserID)
for _, vv := range tokens { // for _, vv := range tokens {
api.Cacher.Del(vv) // api.Cacher.Del(vv)
} // }
dao.DeleteEntity(db, v) // dao.DeleteEntity(db, v)
} // }
return err return err
} }