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

billdrtail

Browse Source
This commit is contained in:
苏尹岚
2020-10-22 15:10:06 +08:00
parent 777bdc6d93
commit b9c49f75a5
7 changed files with 105 additions and 166 deletions
Download Patch File Download Diff File Expand all files Collapse all files

143
business/jxstore/cms/user2.go
View File

@@ -8,15 +8,10 @@ import (
"git.rosy.net.cn/jx-callback/business/jxstore/financial"
"git.rosy.net.cn/baseapi"
"git.rosy.net.cn/jx-callback/business/jxutils/excel"
"git.rosy.net.cn/jx-callback/business/jxutils/tasksch"
"git.rosy.net.cn/baseapi/platformapi/dingdingapi"
"git.rosy.net.cn/baseapi/utils"
"git.rosy.net.cn/jx-callback/business/auth2"
"git.rosy.net.cn/jx-callback/business/auth2/authprovider/dingding"
"git.rosy.net.cn/jx-callback/business/authz"
"git.rosy.net.cn/jx-callback/business/jxutils"
"git.rosy.net.cn/jx-callback/business/jxutils/jsonerr"
"git.rosy.net.cn/jx-callback/business/jxutils/jxcontext"
@@ -24,7 +19,6 @@ import (
"git.rosy.net.cn/jx-callback/business/model/dao"
"git.rosy.net.cn/jx-callback/globals"
"git.rosy.net.cn/jx-callback/globals/api"
"git.rosy.net.cn/jx-callback/globals/api2"
)
var (
@@ -123,16 +117,6 @@ func (*UserProvider) UpdateLastLogin(userID string, lastLoginType, fromIP string
return err
}
// func (*UserProvider) CreateUser(userID2, mobile, email, name string) (user auth2.IUser, err error) {
// realUser := &model.User{
// UserID2: userID2,
// Mobile: mobile,
// Email: email,
// Name: name,
// }
// return realUser, CreateUser(realUser)
// }
func init() {
auth2.Init(userProvider)
}
@@ -300,31 +284,6 @@ func GetUsers(ctx *jxcontext.Context, userType int, keyword string, userIDs []st
return pagedInfo, err
}
func GetStoreRoleList(ctx *jxcontext.Context) (roleList []*authz.RoleInfo, err error) {
return authz.StoreRoleList, nil
}
func GetUserRoleList(ctx *jxcontext.Context, userID string) (roleList []*authz.RoleInfo, err error) {
return api2.RoleMan.GetUserRoleList(userID)
}
func GetRoleUserList(ctx *jxcontext.Context, r *authz.RoleInfo) (userIDList []string, err error) {
return api2.RoleMan.GetRoleUserList(r)
}
func GetRolesUserList(ctx *jxcontext.Context, rList []*authz.RoleInfo) (userIDMap map[string][]string, err error) {
userIDMap = make(map[string][]string)
for _, r := range rList {
userIDList, err2 := api2.RoleMan.GetRoleUserList(r)
if err = err2; err == nil {
userIDMap[r.GetFullName()] = userIDList
} else {
break
}
}
return userIDMap, err
}
func checkUserType(userID string, userType int8) (err error) {
userList, _, err := dao.GetUsers(dao.GetDB(), 0, "", []string{userID}, nil, nil, 0, 0)
if err != nil {
@@ -453,108 +412,6 @@ func GetSelfInfo(ctx *jxcontext.Context) (getSelfInfoResult *dao.GetSelfInfoResu
return getSelfInfoResult, err
}
func (d *GetJdUsersStruct) AppendData(jd JdUserStruct) {
d.locker.RLock()
defer d.locker.RUnlock()
d.userMap = append(d.userMap, jd)
}
func WriteToExcelJd(task *tasksch.SeqTask, jd []JdUserStruct) (err error) {
var sheetList []*excel.Obj2ExcelSheetConfig
var downloadURL, fileName string
excelConf := &excel.Obj2ExcelSheetConfig{
Title: "京东用户列表",
Data: jd,
CaptionList: titleListJdUser,
}
sheetList = append(sheetList, excelConf)
if excelConf != nil {
downloadURL, fileName, err = jxutils.UploadExeclAndPushMsg(sheetList, "京东用户列表")
} else {
baseapi.SugarLogger.Debug("WriteToExcel: JdUserStruct is nil!")
}
if err != nil {
baseapi.SugarLogger.Errorf("WriteToExcel:upload %s,failed error:%v", fileName, err)
} else {
noticeMsg := fmt.Sprintf("[详情点我]path=%s, \n", downloadURL)
task.SetNoticeMsg(noticeMsg)
baseapi.SugarLogger.Debugf("WriteToExcel:upload %s, success, downloadURL:%s", fileName, downloadURL)
}
return err
}
func DeleteUserInfo(ctx *jxcontext.Context, userID string) (err error) {
db := dao.GetDB()
sql := `
UPDATE user
SET status = ?
WHERE user_id = ?
`
sqlParams := []interface{}{
model.NO,
userID,
}
_, err = dao.ExecuteSQL(db, sql, sqlParams)
/* 删除离职人员门店市场人员 */
sql2 := `
UPDATE store t1
LEFT JOIN user t2 ON t2.mobile = t1.market_man_phone AND t2.status <> 0
SET t1.market_man_phone = ''
WHERE t2.id IS NULL
`
_, err = dao.ExecuteSQL(db, sql2, nil)
/* 删除离职人员门店运营人员 */
sql3 := `
UPDATE store t1
LEFT JOIN user t2 ON t2.mobile = t1.operator_phone AND t2.status <> 0
SET t1.operator_phone = ''
WHERE t2.id IS NULL
`
_, err = dao.ExecuteSQL(db, sql3, nil)
/* 删除离职人员门店运营人员 */
sql4 := `
UPDATE store t1
LEFT JOIN user t2 ON t2.mobile = t1.operator_phone2 AND t2.status <> 0
SET t1.operator_phone2 = ''
WHERE t2.id IS NULL
`
_, err = dao.ExecuteSQL(db, sql4, nil)
/*删除离职人员的角色信息*/
sql5 := `
DELETE t1
FROM casbin_rule t1
LEFT JOIN user t2 ON t2.user_id = t1.v0 AND t2.status <> 0
WHERE t2.id IS NULL
`
_, err = dao.ExecuteSQL(db, sql5, nil)
//删除token
tokens, err := api.Cacher.Keys("TOKEN.V2." + userID + "*")
for _, v := range tokens {
err = api.Cacher.Del(v)
}
return err
}
func CleanUserOrderSMSMark(ctx *jxcontext.Context) (err error) {
var (
db = dao.GetDB()
)
if time.Now().Day() == 1 {
sql := `
UPDATE user_order_sms
SET sms_mark = ?
`
sqlParams := []interface{}{model.NO}
_, err = dao.ExecuteSQL(db, sql, sqlParams)
}
return err
}
func RefreshUserMemberStatus(ctx *jxcontext.Context) (err error) {
var (
db = dao.GetDB()