EggPlanet
/
egg_app
3
0
Fork 0
Code Issues 0 Pull Requests 0 Releases 0 Wiki Activity
蛋蛋星球-客户端
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
318 Commits
4 Branches
31 MiB
 
 
 
 
 
Tree: bf3aeb0f03
Branches Tags
${ item.name }
Create branch ${ searchTerm }
from 'bf3aeb0f03'
${ noResults }
egg_app/app/hdl/hdl_user.go

459 lines
14 KiB
Raw Blame History 

  1. package hdl

  2. 

  3. import (

  4. 	"applet/app/db"

  5. 	"applet/app/e"

  6. 	"applet/app/es/hdl"

  7. 	md2 "applet/app/es/md"

  8. 	"applet/app/lib/auth"

  9. 	"applet/app/md"

  10. 	"applet/app/svc"

  11. 	"applet/app/utils"

  12. 	"applet/app/utils/cache"

  13. 	"applet/app/utils/qrcode"

  14. 	"code.fnuoos.com/EggPlanet/egg_models.git/src/implement"

  15. 	"code.fnuoos.com/EggPlanet/egg_models.git/src/model"

  16. 	"code.fnuoos.com/EggPlanet/egg_system_rules.git/aliyun"

  17. 	"code.fnuoos.com/EggPlanet/egg_system_rules.git/kuaizhan"

  18. 	md3 "code.fnuoos.com/EggPlanet/egg_system_rules.git/md"

  19. 	es2 "code.fnuoos.com/EggPlanet/egg_system_rules.git/utils/es"

  20. 	"code.fnuoos.com/go_rely_warehouse/zyos_go_es.git/es"

  21. 	"code.fnuoos.com/go_rely_warehouse/zyos_go_mq.git/rabbit"

  22. 	"context"

  23. 	"encoding/json"

  24. 	"fmt"

  25. 	"github.com/gin-gonic/gin"

  26. 	"github.com/olivere/elastic/v7"

  27. 	"github.com/syyongx/php2go"

  28. 	"github.com/tidwall/gjson"

  29. 	"strings"

  30. 	"time"

  31. )

  32. 

  33. // UserInfo

  34. // @Summary      用户信息

  35. // @Tags         用户信息

  36. // @Description  用户信息

  37. // @Accept       json

  38. // @Produce      json

  39. // @param Authorization header string true "验证参数Bearer和token空格拼接"

  40. // @Success      200   {object}   md.UserInfoResp  	"具体数据"

  41. // @Failure      400   {object}   md.Response              	"具体错误"

  42. // @Router       /api/v1/userInfo [get]

  43. func UserInfo(c *gin.Context) {

  44. 	user := svc.GetUser(c)

  45. 	res := md.UserInfoResp{

  46. 		Id:           utils.Int64ToStr(user.Id),

  47. 		Phone:        user.Phone,

  48. 		Nickname:     user.Phone,

  49. 		InviteCode:   user.SystemInviteCode,

  50. 		IsBindExtend: "0",

  51. 	}

  52. 	if user.Avatar == "" {

  53. 		user.Avatar = svc.GetSysCfgStr("default_avatar")

  54. 	}

  55. 	if user.Avatar != "" {

  56. 		res.HeadImg = svc.GetOssUrl(user.Avatar)

  57. 	}

  58. 	if user.CustomInviteCode != "" {

  59. 		res.InviteCode = user.CustomInviteCode

  60. 	}

  61. 	if user.ParentUid > 0 {

  62. 		res.IsBindExtend = "1"

  63. 	}

  64. 	e.OutSuc(c, res, nil)

  65. 	return

  66. }

  67. 

  68. // InviteCodeUserInfo

  69. // @Summary      邀请码获取用户信息

  70. // @Tags         登录注册

  71. // @Description  邀请码获取用户信息

  72. // @Accept       json

  73. // @Produce      json

  74. // @Param        req 	body      md.InviteCodeUserInfoReq          true   "注册参数"

  75. // @Success      200   {object}   md.InviteCodeUserInfoResp  	"具体数据"

  76. // @Failure      400   {object}   md.Response              	"具体错误"

  77. // @Router       /api/v1/inviteCode/userInfo [post]

  78. func InviteCodeUserInfo(c *gin.Context) {

  79. 	var req md.InviteCodeUserInfoReq

  80. 	err := c.ShouldBindJSON(&req)

  81. 	if err != nil {

  82. 		err = svc.HandleValidateErr(err)

  83. 		err1 := err.(e.E)

  84. 		e.OutErr(c, err1.Code, err1.Error())

  85. 		return

  86. 	}

  87. 	if req.InviteCode == "" {

  88. 		e.OutErr(c, 400, e.NewErr(400, "邀请码不能为空"))

  89. 		return

  90. 	}

  91. 	userDb := implement.NewUserDb(db.Db)

  92. 	user, err := userDb.UserGetOneByParams(map[string]interface{}{

  93. 		"key":   "system_invite_code",

  94. 		"value": req.InviteCode,

  95. 	})

  96. 	if user == nil {

  97. 		user, _ = userDb.UserGetOneByParams(map[string]interface{}{

  98. 			"key":   "custom_invite_code",

  99. 			"value": req.InviteCode,

  100. 		})

  101. 		if user == nil {

  102. 			e.OutErr(c, 400, e.NewErr(400, "用户不存在"))

  103. 			return

  104. 		}

  105. 	}

  106. 	nickname := user.Nickname

  107. 	if nickname == "" {

  108. 		nickname = user.Phone

  109. 	}

  110. 	if php2go.IsNumeric(nickname) {

  111. 		nickname = utils.HideTrueName(user.Nickname)

  112. 	}

  113. 	user = svc.UserImg(user)

  114. 	res := md.InviteCodeUserInfoResp{

  115. 		Nickname: nickname,

  116. 		HeadImg:  user.Avatar,

  117. 	}

  118. 	e.OutSuc(c, res, nil)

  119. 	return

  120. }

  121. 

  122. // UserBindParent

  123. // @Summary      绑定上级-要登陆的

  124. // @Tags         登录注册

  125. // @Description  绑定上级

  126. // @Accept       json

  127. // @Produce      json

  128. // @Param        req 	body      md.InviteCodeUserInfoReq          true   "注册参数"

  129. // @Success      200   {string}     	"具体数据"

  130. // @Failure      400   {object}   md.Response              	"具体错误"

  131. // @Router       /api/v1/memberCenter/bindParent [post]

  132. func UserBindParent(c *gin.Context) {

  133. 	var req md.InviteCodeUserInfoReq

  134. 	err := c.ShouldBindJSON(&req)

  135. 	if err != nil {

  136. 		err = svc.HandleValidateErr(err)

  137. 		err1 := err.(e.E)

  138. 		e.OutErr(c, err1.Code, err1.Error())

  139. 		return

  140. 	}

  141. 	if req.InviteCode == "" {

  142. 		e.OutErr(c, 400, e.NewErr(400, "邀请码不能为空"))

  143. 		return

  144. 	}

  145. 	userDb := implement.NewUserDb(db.Db)

  146. 	user, err := userDb.UserGetOneByParams(map[string]interface{}{

  147. 		"key":   "system_invite_code",

  148. 		"value": req.InviteCode,

  149. 	})

  150. 	if user == nil {

  151. 		user, _ = userDb.UserGetOneByParams(map[string]interface{}{

  152. 			"key":   "custom_invite_code",

  153. 			"value": req.InviteCode,

  154. 		})

  155. 		if user == nil {

  156. 			e.OutErr(c, 400, e.NewErr(400, "用户不存在"))

  157. 			return

  158. 		}

  159. 	}

  160. 	ownUser := svc.GetUser(c)

  161. 	if ownUser.ParentUid > 0 {

  162. 		e.OutErr(c, 400, e.NewErr(400, "已有导师"))

  163. 		return

  164. 	}

  165. 	if user.Id == ownUser.Id {

  166. 		e.OutErr(c, 400, e.NewErr(400, "不能绑定自己"))

  167. 		return

  168. 	}

  169. 	ownUser.ParentUid = user.Id

  170. 	_, err = db.Db.Where("id=?", ownUser.Id).Cols("parent_uid").Update(ownUser)

  171. 	if err != nil {

  172. 		e.OutErr(c, 400, e.NewErr(400, "绑定失败，请重试"))

  173. 		return

  174. 	}

  175. 	initLV := 1

  176. 	ur := new(model.UserRelate)

  177. 	ur.ParentUid = user.Id

  178. 	ur.Uid = ownUser.Id

  179. 	ur.Level = initLV

  180. 	ur.InviteTime = ownUser.CreateAt

  181. 	userRelateDb := implement.NewUserRelateDb(db.Db)

  182. 	_, err = userRelateDb.UserRelateInsert(ur)

  183. 	if err != nil {

  184. 		e.OutErr(c, e.ERR_DB_ORM, err)

  185. 		return

  186. 	}

  187. 	// 插入多级关联

  188. 	go svc.RoutineMultiRelate(ur.ParentUid, ur.Uid, initLV)

  189. 	//TODO 绑定成功后 加群之类的怎么处理

  190. 	e.OutSuc(c, "success", nil)

  191. 	return

  192. }

  193. 

  194. // UpdatePassword

  195. // @Summary      修改密码-不要原密码 换成验证码

  196. // @Tags         账号与安全

  197. // @Description   修改密码

  198. // @Accept       json

  199. // @Produce      json

  200. // @Param        req 	body      md.UpdatePasswordReq          true   "注册参数"

  201. // @Success      200   string   			"登录成功返回"

  202. // @Failure      400   {object}   md.Response              	"具体错误"

  203. // @Router       /api/v1/memberCenter/updatePassword [post]

  204. func UpdatePassword(c *gin.Context) {

  205. 	var req md.UpdatePasswordReq

  206. 	err := c.ShouldBindJSON(&req)

  207. 	if err != nil {

  208. 		err = svc.HandleValidateErr(err)

  209. 		err1 := err.(e.E)

  210. 		e.OutErr(c, err1.Code, err1.Error())

  211. 		return

  212. 	}

  213. 	user := svc.GetUser(c)

  214. 	data := svc.AliyunSmsBase(c, "")

  215. 	//校验短信

  216. 	err = aliyun.AliyunCheckSms(data["aliyun_sms_id"], data["aliyun_sms_secret"], user.Phone, req.Code)

  217. 	if err != nil {

  218. 		e.OutErr(c, 400, e.NewErr(400, "验证码错误,请重试"))

  219. 		return

  220. 	}

  221. 	user.Password = utils.Md5(req.Password)

  222. 	db.Db.Where("id=?", user.Id).Cols("password").Update(user)

  223. 	e.OutSuc(c, "success", nil)

  224. 	return

  225. }

  226. 

  227. // UpdatePasscode

  228. // @Summary      修改支付宝密码

  229. // @Tags         账号与安全

  230. // @Description   修改支付宝密码

  231. // @Accept       json

  232. // @Produce      json

  233. // @Param        req 	body      md.UpdatePasscodeReq          true   "注册参数"

  234. // @Success      200   string   			"登录成功返回"

  235. // @Failure      400   {object}   md.Response              	"具体错误"

  236. // @Router       /api/v1/memberCenter/updatePasscode [post]

  237. func UpdatePasscode(c *gin.Context) {

  238. 	var req md.UpdatePasscodeReq

  239. 	err := c.ShouldBindJSON(&req)

  240. 	if err != nil {

  241. 		err = svc.HandleValidateErr(err)

  242. 		err1 := err.(e.E)

  243. 		e.OutErr(c, err1.Code, err1.Error())

  244. 		return

  245. 	}

  246. 	user := svc.GetUser(c)

  247. 	data := svc.AliyunSmsBase(c, "")

  248. 	//校验短信

  249. 	err = aliyun.AliyunCheckSms(data["aliyun_sms_id"], data["aliyun_sms_secret"], user.Phone, req.Code)

  250. 	if err != nil {

  251. 		e.OutErr(c, 400, e.NewErr(400, "验证码错误,请重试"))

  252. 		return

  253. 	}

  254. 	user.Passcode = utils.Md5(req.PassCode)

  255. 	db.Db.Where("id=?", user.Id).Cols("passcode").Update(user)

  256. 	e.OutSuc(c, "success", nil)

  257. 	return

  258. }

  259. 

  260. // InviteUrl

  261. // @Summary      邀请链接

  262. // @Tags         邀请海报

  263. // @Description   邀请链接

  264. // @Accept       json

  265. // @Produce      json

  266. // @Success      200  {object}   md.InviteUrl		"登录成功返回"

  267. // @Failure      400   {object}   md.Response              	"具体错误"

  268. // @Router       /api/v1/memberCenter/inviteUrl [get]

  269. func InviteUrl(c *gin.Context) {

  270. 	user := svc.GetUser(c)

  271. 

  272. 	link := svc.GetSysCfgStr("kuaizhan_url")

  273. 	res := md.InviteUrl{

  274. 		Link:       "",

  275. 		InviteCode: user.SystemInviteCode,

  276. 	}

  277. 	if user.CustomInviteCode != "" {

  278. 		res.InviteCode = user.CustomInviteCode

  279. 	}

  280. 	link += "?inviteCode=" + res.InviteCode

  281. 	EggUserShortLink := md2.EggUserShortLink

  282. 	boolQueryToItem := elastic.NewBoolQuery()        // 创建bool查询

  283. 	aggsMatch := elastic.NewMatchQuery("link", link) //设置查询条件

  284. 	boolQueryToItem.Must(aggsMatch)

  285. 	result, _ := hdl.EsSelectOne(context.Background(), EggUserShortLink, boolQueryToItem, false)

  286. 	isHas := 0

  287. 	if result != nil && len(result.Hits.Hits) > 0 {

  288. 		for _, hit := range result.Hits.Hits {

  289. 			if hit == nil {

  290. 				continue

  291. 			}

  292. 			jsonByte, _ := hit.Source.MarshalJSON()

  293. 			if gjson.Get(string(jsonByte), "short_link").String() != "" {

  294. 				isHas = 1

  295. 				link = gjson.Get(string(jsonByte), "short_link").String()

  296. 			}

  297. 		}

  298. 	}

  299. 	if isHas == 0 {

  300. 		send, _ := kuaizhan.KuaizhanSend(svc.GetSysCfgStr("kuaizhan_app_key"), svc.GetSysCfgStr("kuaizhan_app_secret"), link)

  301. 		if gjson.Get(send, "url").String() != "" {

  302. 			var uniqueId = php2go.Md5(link)

  303. 			oldLink := link

  304. 			link = gjson.Get(send, "url").String()

  305. 			tmp := map[string]interface{}{

  306. 				"uid":        user.Id,

  307. 				"link":       oldLink,

  308. 				"short_link": link,

  309. 			}

  310. 			doc, _ := es.FirstDoc(EggUserShortLink, uniqueId)

  311. 			if doc == nil {

  312. 				es.CreateDoc(EggUserShortLink, uniqueId, tmp)

  313. 			} else {

  314. 				es.UpdateDoc(EggUserShortLink, uniqueId, tmp)

  315. 			}

  316. 		}

  317. 	}

  318. 	res.Link = link

  319. 	QRcode := qrcode.GetPNGBase64(link)

  320. 	QRcode = strings.ReplaceAll(QRcode, "\u0000", "")

  321. 	res.Qrcode = QRcode

  322. 	e.OutSuc(c, res, nil)

  323. 	return

  324. }

  325. 

  326. // Delete

  327. // @Summary      注销账号操作

  328. // @Tags         账号与安全

  329. // @Description   注销账号操作

  330. // @Accept       json

  331. // @Produce      json

  332. // @Param        req 	body      md.DeleteUserReq          true   "注册参数"

  333. // @Success      200   string   			"登录成功返回"

  334. // @Failure      400   {object}   md.Response              	"具体错误"

  335. // @Router       /api/v1/memberCenter/delete [post]

  336. func Delete(c *gin.Context) {

  337. 	var req md.DeleteUserReq

  338. 	err := c.ShouldBindJSON(&req)

  339. 	if err != nil {

  340. 		err = svc.HandleValidateErr(err)

  341. 		err1 := err.(e.E)

  342. 		e.OutErr(c, err1.Code, err1.Error())

  343. 		return

  344. 	}

  345. 	user := svc.GetUser(c)

  346. 	data := svc.AliyunSmsBase(c, "")

  347. 	//校验短信

  348. 	err = aliyun.AliyunCheckSms(data["aliyun_sms_id"], data["aliyun_sms_secret"], user.Phone, req.Code)

  349. 	if err != nil {

  350. 		e.OutErr(c, 400, e.NewErr(400, "验证码错误,请重试"))

  351. 		return

  352. 	}

  353. 	user.State = 3

  354. 	db.Db.Where("id=?", user.Id).Cols("state").Update(user)

  355. 	tmp := model.UserDeleteInfo{

  356. 		Uid:      int(user.Id),

  357. 		Phone:    user.Phone,

  358. 		CreateAt: time.Now(),

  359. 	}

  360. 	db.Db.Insert(&tmp)

  361. 	ch, err := rabbit.Cfg.Pool.GetChannel()

  362. 	if err == nil {

  363. 		defer ch.Release()

  364. 		err = ch.PublishV2(md.EggUserExchange, md.CommUserId{

  365. 			Uid:       utils.Int64ToStr(user.Id),

  366. 			ParentUid: utils.Int64ToStr(user.ParentUid),

  367. 		}, md.EggUserDelete)

  368. 		if err != nil {

  369. 			ch.PublishV2(md.EggUserExchange, md.CommUserId{

  370. 				Uid:       utils.Int64ToStr(user.Id),

  371. 				ParentUid: utils.Int64ToStr(user.ParentUid),

  372. 			}, md.EggUserDelete)

  373. 		}

  374. 	}

  375. 	// 清掉token

  376. 	cacheKey := fmt.Sprintf(auth.TokenKey, user.Id)

  377. 	_, err = cache.SetEx(cacheKey, "", 1)

  378. 	e.OutSuc(c, "success", nil)

  379. 	return

  380. }

  381. 

  382. // DeleteInfo

  383. // @Summary      注销账号信息

  384. // @Tags         账号与安全

  385. // @Description   注销账号信息

  386. // @Accept       json

  387. // @Produce      json

  388. // @Success      200  {object}   md.UserDeleteInfo		"登录成功返回"

  389. // @Failure      400   {object}   md.Response              	"具体错误"

  390. // @Router       /api/v1/memberCenter/delete/info [get]

  391. func DeleteInfo(c *gin.Context) {

  392. 	user := svc.GetUser(c)

  393. 	resp := md.UserDeleteInfo{

  394. 		Url: fmt.Sprintf("%s%s?id=%s&is_hide=1", svc.GetSysCfgStr("wap_host"), "/#/pages/course-detail-page/course-detail-page", "115"),

  395. 	}

  396. 	extendUserCount, _ := db.Db.Where("parent_uid=?", user.Id).Count(&model.User{})

  397. 	NewUserWalletDb := implement.NewUserWalletDb(db.Db)

  398. 	walletAmount := "0"

  399. 	wallet, _ := NewUserWalletDb.GetUserVirtualWallet(user.Id)

  400. 	if wallet != nil {

  401. 		walletAmount = wallet.Amount

  402. 	}

  403. 	NewUserVirtualAmountDb := implement.NewUserVirtualAmountDb(db.Db)

  404. 	virtualWallet, _ := NewUserVirtualAmountDb.GetUserVirtualAllWallets(user.Id)

  405. 	virtualAmount1 := "0"

  406. 	virtualAmount2 := "0"

  407. 	virtualAmount3 := "0"

  408. 	settingDb := implement.NewEggEnergyBasicSettingDb(db.Db)

  409. 	setting, _ := settingDb.EggEnergyBasicSettingGetOne()

  410. 	if virtualWallet != nil {

  411. 		for _, v := range *virtualWallet {

  412. 			if v.CoinId == setting.PersonEggPointsCoinId {

  413. 				virtualAmount3 = utils.Float64ToStrPrec8(utils.StrToFloat64(v.Amount) + utils.StrToFloat64(virtualAmount3))

  414. 			}

  415. 			if v.CoinId == setting.TeamEggPointsCoinId {

  416. 				virtualAmount3 = utils.Float64ToStrPrec8(utils.StrToFloat64(v.Amount) + utils.StrToFloat64(virtualAmount3))

  417. 			}

  418. 			if v.CoinId == setting.PersonEggEnergyCoinId {

  419. 				virtualAmount2 = utils.Float64ToStrPrec8(utils.StrToFloat64(v.Amount) + utils.StrToFloat64(virtualAmount2))

  420. 			}

  421. 			if v.CoinId == setting.TeamEggEnergyCoinId {

  422. 				virtualAmount2 = utils.Float64ToStrPrec8(utils.StrToFloat64(v.Amount) + utils.StrToFloat64(virtualAmount2))

  423. 			}

  424. 			if v.CoinId == setting.ContributionCoinId {

  425. 				virtualAmount1 = utils.Float64ToStrPrec8(utils.StrToFloat64(v.Amount) + utils.StrToFloat64(virtualAmount1))

  426. 			}

  427. 		}

  428. 	}

  429. 	score := 60.00

  430. 	now := time.Now()

  431. 	esIndex := es2.GetLatestEffectiveIndexFromAlias(now)

  432. 	esIndexName := md3.EggEnergyUserEggScoreEsAlias + "_" + esIndex

  433. 	results, _ := es.FirstDoc(esIndexName, esIndex+"_"+utils.Int64ToStr(user.Id))

  434. 	if results != nil {

  435. 		var doc md.UserEggFlowReqRespList

  436. 		json.Unmarshal(results.Source, &doc)

  437. 		score = doc.ScoreValue

  438. 	}

  439. 	uid := user.Id

  440. 	sql := fmt.Sprintf("SELECT COUNT(*)AS total FROM `public_platoon_user_relation` WHERE father_uid1 = %d OR father_uid2= %d OR father_uid3= %d OR father_uid4= %d OR father_uid5= %d OR father_uid6= %d OR father_uid7= %d OR father_uid8= %d OR father_uid9= %d", uid, uid, uid, uid, uid, uid, uid, uid, uid)

  441. 	nativeString1, _ := db.QueryNativeString(db.Db, sql)

  442. 	hasUserCount := "0"

  443. 	if len(nativeString1) > 0 {

  444. 		hasUserCount = nativeString1[0]["total"]

  445. 	}

  446. 	info := []md.UserDeleteInfoList{

  447. 		{Title: "贡献值", Content: "贡献值 " + virtualAmount1},

  448. 		{Title: "能量值", Content: "能量值 " + virtualAmount2},

  449. 		{Title: "活跃值", Content: "活跃值 " + virtualAmount3},

  450. 		{Title: "蛋蛋分", Content: "蛋蛋分 " + utils.Float64ToStr(score)},

  451. 		{Title: "余额", Content: "余额 " + walletAmount},

  452. 		{Title: "直推好友", Content: "直推好友 " + utils.Int64ToStr(extendUserCount) + " 人"},

  453. 		{Title: "团队", Content: "团队 " + hasUserCount + " 人"},

  454. 	}

  455. 	resp.Info = info

  456. 	e.OutSuc(c, resp, nil)

  457. 	return

  458. }