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-02 09:55:36 +08:00
parent f46afb51ed
commit 04ae92b33c
1 changed files with 29 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -1879,18 +1879,37 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
// tasksch.HandleTask(task, nil, true).Run() // tasksch.HandleTask(task, nil, true).Run()
// _, err = task.GetResult(0) // _, err = task.GetResult(0)
//京东账号更新 //京东账号更新
// var (
// db = dao.GetDB()
// )
// if configs, err := dao.QueryConfigs(dao.GetDB(), "jdConfigCookie", model.ConfigTypeCookie, ""); err == nil {
// api.JdAPI.SetCookieWithStr(configs[0].Value)
// result, _ := api.JdAPI.GetJdAppInfo()
// if result != nil {
// if vocs, _ := dao.GetVendorOrgCode(db, model.VendorIDJD, result.OrgCode, model.VendorOrgTypePlatform); len(vocs) > 0 {
// vocs[0].AppKey = result.AppKey
// vocs[0].AppSecret = result.AppSecret
// dao.UpdateEntity(db, vocs[0], "AppKey", "AppSecret")
// }
// }
// }
var ( var (
db = dao.GetDB() db = dao.GetDB()
users []*model.User
) )
if configs, err := dao.QueryConfigs(dao.GetDB(), "jdConfigCookie", model.ConfigTypeCookie, ""); err == nil { sql := `
api.JdAPI.SetCookieWithStr(configs[0].Value) SELECT DISTINCT a.* FROM user a
result, _ := api.JdAPI.GetJdAppInfo() LEFT JOIN auth_bind b ON a.user_id2 = b.auth_id
if result != nil { WHERE name IN (
if vocs, _ := dao.GetVendorOrgCode(db, model.VendorIDJD, result.OrgCode, model.VendorOrgTypePlatform); len(vocs) > 0 { SELECT name FROM user WHERE deleted_at = '1970-01-01 00:00:00' GROUP BY name HAVING COUNT(*) > 1 )
vocs[0].AppKey = result.AppKey AND a.mobile is null AND a.user_id <> b.user_id
vocs[0].AppSecret = result.AppSecret ORDER BY a.name
dao.UpdateEntity(db, vocs[0], "AppKey", "AppSecret") `
} dao.GetRows(db, &users, sql, nil)
for _, v := range users {
tokens, _ := api.Cacher.Keys(v.UserID)
for _, vv := range tokens {
api.Cacher.Del(vv)
} }
} }
return err return err