wechat.go 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622
  1. package controllers
  2. import (
  3. "encoding/json"
  4. "fmt"
  5. "github.com/medivhzhan/weapp/v2"
  6. "hongze/hongze_cygx/models"
  7. "hongze/hongze_cygx/services"
  8. "hongze/hongze_cygx/utils"
  9. "strconv"
  10. "time"
  11. )
  12. type WechatController struct {
  13. BaseAuthController
  14. }
  15. type WechatCommonController struct {
  16. BaseCommonController
  17. }
  18. //
  19. //// @Title 微信登录接口
  20. //// @Description 微信登录接口
  21. //// @Param Code query string true "微信唯一编码code"
  22. //// @Success 200 {object} models.WxLoginResp
  23. //// @router /login [get]
  24. //func (this *WechatCommonController) WechatLogin() {
  25. // br := new(models.BaseResponse).Init()
  26. // defer func() {
  27. // this.Data["json"] = br
  28. // this.ServeJSON()
  29. // }()
  30. // code := this.GetString("Code")
  31. // if code == "" {
  32. // br.Msg = "参数错误"
  33. // br.ErrMsg = "Code 为空"
  34. // return
  35. // }
  36. // wxInfo, err := weapp.Login(utils.WxAppId, utils.WxAppSecret, code)
  37. // if err != nil {
  38. // br.Msg = "获取用户信息失败"
  39. // br.ErrMsg = "获取用户信息失败,Err:" + err.Error()
  40. // return
  41. // }
  42. // if err = wxInfo.GetResponseError(); err != nil {
  43. // br.Msg = "获取用户信息失败"
  44. // br.ErrMsg = "获取用户信息失败,code:" + strconv.Itoa(wxInfo.ErrCode) + ",msg:" + wxInfo.ErrMSG
  45. // return
  46. // }
  47. // firstLogin := 1
  48. // userId := 0
  49. // wxUser, err := models.GetWxUserItemByUnionid(wxInfo.UnionID)
  50. // if err != nil && err.Error() != utils.ErrNoRow() {
  51. // br.Msg = "获取用户信息失败"
  52. // br.ErrMsg = "根据openid获取用户信息失败,Eerr:" + err.Error()
  53. // return
  54. // }
  55. // if wxUser == nil || (err != nil && err.Error() == utils.ErrNoRow()) {
  56. // user := new(models.WxUser)
  57. // user.OpenId = wxInfo.OpenID
  58. // user.CompanyId = 1
  59. // user.CreatedTime = time.Now()
  60. // user.UnionId = wxInfo.UnionID
  61. // user.Unionid = wxInfo.UnionID
  62. // user.FirstLogin = 1
  63. // user.Enabled = 1
  64. // user.RegisterPlatform = 1
  65. // user.RegisterTime = time.Now()
  66. // user.SessionKey = wxInfo.SessionKey
  67. // newId, err := models.AddWxUser(user)
  68. // if err != nil {
  69. // br.Msg = "登录失败"
  70. // br.ErrMsg = "登录失败,新增联系人失败,Eerr:" + err.Error()
  71. // return
  72. // }
  73. // userId = int(newId)
  74. // } else {
  75. // firstLogin = wxUser.FirstLogin
  76. // userId = wxUser.UserId
  77. // models.ModifyWxUserSessionKey(wxInfo.SessionKey, userId)
  78. // }
  79. //
  80. // var token string
  81. // tokenItem, err := models.GetTokenByUid(userId)
  82. // if err != nil && err.Error() != utils.ErrNoRow() {
  83. // br.Msg = "登录失败"
  84. // br.ErrMsg = "登录失败,获取token失败:" + err.Error()
  85. // return
  86. // }
  87. //
  88. // if tokenItem == nil || (err != nil && err.Error() == utils.ErrNoRow()) {
  89. // timeUnix := time.Now().Unix()
  90. // timeUnixStr := strconv.FormatInt(timeUnix, 10)
  91. // token = utils.MD5(strconv.Itoa(userId)) + utils.MD5(timeUnixStr)
  92. // //新增session
  93. // {
  94. // session := new(models.CygxSession)
  95. // session.OpenId = wxInfo.OpenID
  96. // session.UnionId = wxInfo.UnionID
  97. // session.UserId = userId
  98. // session.CreatedTime = time.Now()
  99. // session.LastUpdatedTime = time.Now()
  100. // session.ExpireTime = time.Now().AddDate(0, 3, 0)
  101. // session.AccessToken = token
  102. // err = models.AddSession(session)
  103. // if err != nil {
  104. // br.Msg = "登录失败"
  105. // br.ErrMsg = "登录失败,新增用户session信息失败:" + err.Error()
  106. // return
  107. // }
  108. // }
  109. // } else {
  110. // token = tokenItem.AccessToken
  111. // }
  112. // {
  113. // newItem, _ := models.GetWxUserItemByUserId(userId)
  114. // if newItem.Mobile == "" && newItem.Email == "" {
  115. // firstLogin = 1
  116. // }
  117. // }
  118. //
  119. // //新增登录日志
  120. // {
  121. // loginLog := new(models.WxUserLog)
  122. // loginLog.UserId = userId
  123. // loginLog.OpenId = wxInfo.OpenID
  124. // loginLog.UnionId = wxInfo.UnionID
  125. // loginLog.CreateTime = time.Now()
  126. // loginLog.Handle = "wechat_login_cygx"
  127. // loginLog.Remark = token
  128. // go models.AddWxUserLog(loginLog)
  129. // }
  130. //
  131. // {
  132. // codeLog := new(models.WxUserCode)
  133. // codeLog.WxCode = code
  134. // codeLog.UserId = userId
  135. // codeLog.Code = 0
  136. // codeLog.FirstLogin = firstLogin
  137. // codeLog.Authorization = token
  138. // codeLog.UserPermission = 1
  139. // codeLog.CreateTime = time.Now()
  140. // models.AddWxUserCode(codeLog)
  141. // }
  142. //
  143. // resp := new(models.WxLoginResp)
  144. // resp.UserId = userId
  145. // resp.FirstLogin = firstLogin
  146. // resp.Authorization = token
  147. // br.Ret = 200
  148. // br.Success = true
  149. // br.Msg = "登录成功"
  150. // br.Data = resp
  151. //}
  152. // @Title 微信登录接口
  153. // @Description 微信登录接口
  154. // @Param Code query string true "微信唯一编码code"
  155. // @Success 200 {object} models.WxLoginResp
  156. // @router /login [get]
  157. func (this *WechatCommonController) WechatLogin() {
  158. br := new(models.BaseResponse).Init()
  159. defer func() {
  160. this.Data["json"] = br
  161. this.ServeJSON()
  162. }()
  163. code := this.GetString("Code")
  164. if code == "" {
  165. br.Msg = "参数错误"
  166. br.ErrMsg = "Code 为空"
  167. return
  168. }
  169. wxInfo, err := weapp.Login(utils.WxAppId, utils.WxAppSecret, code)
  170. if err != nil {
  171. br.Msg = "获取用户信息失败"
  172. br.ErrMsg = "获取用户信息失败,Err:" + err.Error()
  173. return
  174. }
  175. if err = wxInfo.GetResponseError(); err != nil {
  176. br.Msg = "获取用户信息失败"
  177. br.ErrMsg = "获取用户信息失败,code:" + strconv.Itoa(wxInfo.ErrCode) + ",msg:" + wxInfo.ErrMSG
  178. return
  179. }
  180. wxUserInfo := new(services.WxUserInfo)
  181. wxUserInfo.Unionid = wxInfo.UnionID
  182. wxUserInfo.Openid = wxInfo.OpenID
  183. wxUserInfo.Unionid = wxInfo.UnionID
  184. wxUserInfo.Errcode = wxInfo.ErrCode
  185. wxUserInfo.Errmsg = wxInfo.ErrMSG
  186. wxUserInfo.SessionKey = wxInfo.SessionKey
  187. fmt.Println("openId", wxInfo.OpenID)
  188. fmt.Println("unionId", wxInfo.UnionID)
  189. token, userId, firstLogin, _, err := services.WxLogin(code, wxInfo.OpenID, wxInfo.UnionID, wxUserInfo)
  190. if err != nil && err.Error() != utils.ErrNoRow() {
  191. br.Msg = "微信登录失败"
  192. br.ErrMsg = "微信登录失败,err:" + err.Error()
  193. return
  194. }
  195. if token == "" {
  196. br.Msg = "微信登录失败"
  197. br.ErrMsg = "token:" + token + "" + code + " " + wxInfo.OpenID + " " + wxInfo.UnionID
  198. return
  199. }
  200. //新增登录日志
  201. {
  202. loginLog := new(models.WxUserLog)
  203. loginLog.UserId = userId
  204. loginLog.OpenId = wxInfo.OpenID
  205. loginLog.UnionId = wxInfo.UnionID
  206. loginLog.CreateTime = time.Now()
  207. loginLog.Handle = "wechat_login_cygx"
  208. loginLog.Remark = token
  209. go models.AddWxUserLog(loginLog)
  210. }
  211. {
  212. codeLog := new(models.WxUserCode)
  213. codeLog.WxCode = code
  214. codeLog.UserId = userId
  215. codeLog.Code = 0
  216. codeLog.FirstLogin = firstLogin
  217. codeLog.Authorization = token
  218. codeLog.UserPermission = 1
  219. codeLog.CreateTime = time.Now()
  220. models.AddWxUserCode(codeLog)
  221. }
  222. resp := new(models.WxLoginResp)
  223. resp.UserId = userId
  224. resp.FirstLogin = firstLogin
  225. resp.Authorization = token
  226. br.Ret = 200
  227. br.Success = true
  228. br.Msg = "登录成功"
  229. br.Data = resp
  230. }
  231. //
  232. //// @Title 小程序获取用户信息
  233. //// @Description 小程序获取用户信息接口(需要登录)
  234. //// @Param request body models.WxGetUserInfoReq true "type json string"
  235. //// @Success 200 {object} models.WxGetUserInfoResp
  236. //// @router /getUserInfo [post]
  237. //func (this *WechatController) GetUserInfo() {
  238. // br := new(models.BaseResponse).Init()
  239. // defer func() {
  240. // this.Data["json"] = br
  241. // this.ServeJSON()
  242. // }()
  243. // var req models.WxGetUserInfoReq
  244. // err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  245. // if err != nil {
  246. // br.Msg = "参数解析异常!"
  247. // br.ErrMsg = "参数解析失败,Err:" + err.Error()
  248. // return
  249. // }
  250. // if req.RawData == "" || req.EncryptedData == "" || req.Signature == "" || req.Iv == "" {
  251. // br.Msg = "参数错误"
  252. // return
  253. // }
  254. // user := this.User
  255. // if user == nil {
  256. // br.Msg = "请登陆"
  257. // br.Ret = 408
  258. // return
  259. // }
  260. // sessionKey := user.SessionKey
  261. // userInfo, err := weapp.DecryptUserInfo(sessionKey, req.RawData, req.EncryptedData, req.Signature, req.Iv)
  262. // if err != nil {
  263. // br.Msg = "解析用户信息失败"
  264. // br.ErrMsg = "解析用户信息失败,DecryptUserInfo Err:" + err.Error()
  265. // return
  266. // }
  267. // userId := 0
  268. // //修改用户微信信息
  269. // oldUser, err := models.GetWxUserItemByUnionid(userInfo.UnionID)
  270. // if err != nil && err.Error() != utils.ErrNoRow() {
  271. // br.Msg = "获取用户信息失败"
  272. // br.ErrMsg = "获取用户信息失败 Err:" + err.Error()
  273. // return
  274. // }
  275. // if oldUser == nil || (err != nil && err.Error() == utils.ErrNoRow()) {
  276. // err = models.ModifyWxUserInfo(userInfo.UnionID, userInfo.Nickname, userInfo.Province, userInfo.City, userInfo.Country, userInfo.Avatar, userInfo.Gender, user.UserId)
  277. // if err != nil && err.Error() != utils.ErrNoRow() {
  278. // br.Msg = "获取用户信息失败"
  279. // br.ErrMsg = "修改用户信息失败 Err:" + err.Error()
  280. // return
  281. // }
  282. // userId = user.UserId
  283. // } else {
  284. // if user.UserId == oldUser.UserId {
  285. // err = models.ModifyWxUserInfo(userInfo.UnionID, userInfo.Nickname, userInfo.Province, userInfo.City, userInfo.Country, userInfo.Avatar, userInfo.Gender, user.UserId)
  286. // if err != nil && err.Error() != utils.ErrNoRow() {
  287. // br.Msg = "获取用户信息失败"
  288. // br.ErrMsg = "修改用户信息失败 Err:" + err.Error()
  289. // return
  290. // }
  291. // userId = user.UserId
  292. // } else {
  293. // userId = oldUser.UserId
  294. // err = models.ModifyWxUserInfo(userInfo.UnionID, userInfo.Nickname, userInfo.Province, userInfo.City, userInfo.Country, userInfo.Avatar, userInfo.Gender, oldUser.UserId)
  295. // if err != nil && err.Error() != utils.ErrNoRow() {
  296. // br.Msg = "获取用户信息失败"
  297. // br.ErrMsg = "修改用户信息失败 Err:" + err.Error()
  298. // return
  299. // }
  300. // err = models.DeleteWxUserByUserId(user.UserId)
  301. // if err != nil {
  302. // br.Msg = "删除用户信息失败"
  303. // br.ErrMsg = "删除用户信息失败 Err:" + err.Error()
  304. // return
  305. // }
  306. // }
  307. // }
  308. // var token string
  309. // tokenItem, err := models.GetTokenByUid(userId)
  310. // if err != nil && err.Error() != utils.ErrNoRow() {
  311. // br.Msg = "登录失败"
  312. // br.ErrMsg = "登录失败,获取token失败:" + err.Error()
  313. // return
  314. // }
  315. //
  316. // if tokenItem == nil || (err != nil && err.Error() == utils.ErrNoRow()) {
  317. // timeUnix := time.Now().Unix()
  318. // timeUnixStr := strconv.FormatInt(timeUnix, 10)
  319. // token = utils.MD5(strconv.Itoa(userId)) + utils.MD5(timeUnixStr)
  320. // //新增session
  321. // {
  322. // session := new(models.CygxSession)
  323. // session.OpenId = userInfo.OpenID
  324. // session.UnionId = userInfo.UnionID
  325. // session.UserId = userId
  326. // session.CreatedTime = time.Now()
  327. // session.LastUpdatedTime = time.Now()
  328. // session.ExpireTime = time.Now().AddDate(0, 3, 0)
  329. // session.AccessToken = token
  330. // err = models.AddSession(session)
  331. // if err != nil {
  332. // br.Msg = "登录失败"
  333. // br.ErrMsg = "登录失败,新增用户session信息失败:" + err.Error()
  334. // return
  335. // }
  336. // }
  337. // } else {
  338. // token = tokenItem.AccessToken
  339. // }
  340. // resp := new(models.WxGetUserInfoResp)
  341. // resp.Authorization = token
  342. // br.Msg = "获取成功!"
  343. // br.Ret = 200
  344. // br.Success = true
  345. //}
  346. // @Title 小程序获取用户信息
  347. // @Description 小程序获取用户信息接口(需要登录)
  348. // @Param request body models.WxGetUserInfoReq true "type json string"
  349. // @Success 200 {object} models.WxGetUserInfoResp
  350. // @router /getUserInfo [post]
  351. func (this *WechatController) GetUserInfo() {
  352. br := new(models.BaseResponse).Init()
  353. defer func() {
  354. this.Data["json"] = br
  355. this.ServeJSON()
  356. }()
  357. var req models.WxGetUserInfoReq
  358. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  359. if err != nil {
  360. br.Msg = "参数解析异常!"
  361. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  362. return
  363. }
  364. if req.RawData == "" || req.EncryptedData == "" || req.Signature == "" || req.Iv == "" {
  365. br.Msg = "参数错误"
  366. return
  367. }
  368. user := this.User
  369. if user == nil {
  370. br.Msg = "请登陆"
  371. br.Ret = 408
  372. return
  373. }
  374. userId := user.UserId
  375. sessionKey := user.SessionKey
  376. fmt.Println("sessionKey:", sessionKey)
  377. fmt.Println(sessionKey, req.RawData, req.EncryptedData, req.Signature, req.Iv)
  378. userInfo, err := weapp.DecryptUserInfo(sessionKey, req.RawData, req.EncryptedData, req.Signature, req.Iv)
  379. fmt.Println("weapp.DecryptUserInfo ", err)
  380. if err != nil {
  381. br.Msg = "解析用户信息失败"
  382. br.ErrMsg = "解析用户信息失败,DecryptUserInfo Err:" + err.Error()
  383. return
  384. }
  385. //修改用户微信信息
  386. err = models.ModifyUserRecordByDetail(userInfo.OpenID, userInfo.UnionID, userInfo.Nickname, userInfo.Avatar, userInfo.City, userInfo.Province, userInfo.Country, userInfo.Gender, userId)
  387. if err != nil {
  388. br.Msg = "授权失败"
  389. br.ErrMsg = "授权失败,修改用户信息失败:" + err.Error()
  390. return
  391. }
  392. var token string
  393. tokenItem, err := models.GetTokenByOpenId(userInfo.OpenID)
  394. if err != nil && err.Error() != utils.ErrNoRow() {
  395. br.Msg = "授权失败"
  396. br.ErrMsg = "授权失败,获取token失败:" + err.Error()
  397. return
  398. }
  399. if tokenItem == nil || (err != nil && err.Error() == utils.ErrNoRow()) {
  400. timeUnix := time.Now().Unix()
  401. timeUnixStr := strconv.FormatInt(timeUnix, 10)
  402. token = utils.MD5(userInfo.OpenID) + utils.MD5(timeUnixStr)
  403. //新增session
  404. {
  405. session := new(models.CygxSession)
  406. session.OpenId = userInfo.OpenID
  407. session.UnionId = userInfo.UnionID
  408. session.UserId = userId
  409. session.CreatedTime = time.Now()
  410. session.LastUpdatedTime = time.Now()
  411. session.ExpireTime = time.Now().AddDate(0, 3, 0)
  412. session.AccessToken = token
  413. err = models.AddSession(session)
  414. if err != nil {
  415. br.Msg = "授权失败"
  416. br.ErrMsg = "授权失败,新增用户session信息失败:" + err.Error()
  417. return
  418. }
  419. }
  420. } else {
  421. token = tokenItem.AccessToken
  422. }
  423. resp := new(models.WxGetUserInfoResp)
  424. resp.Authorization = token
  425. br.Msg = "获取成功!"
  426. br.Ret = 200
  427. br.Success = true
  428. }
  429. // @Title 小程序获取用户绑定手机号
  430. // @Description 小程序获取用户绑定手机号接口(需要登录)
  431. // @Param request body models.WxGetPhoneNumberReq true "type json string"
  432. // @Success 200 {object} models.WxGetPhoneNumberResp
  433. // @router /getPhoneNumber [post]
  434. func (this *WechatController) GetPhoneNumber() {
  435. br := new(models.BaseResponse).Init()
  436. defer func() {
  437. this.Data["json"] = br
  438. this.ServeJSON()
  439. }()
  440. var req models.WxGetPhoneNumberReq
  441. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  442. if err != nil {
  443. br.Msg = "参数解析异常!"
  444. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  445. return
  446. }
  447. if req.EncryptedData == "" || req.Iv == "" {
  448. br.Msg = "参数错误"
  449. return
  450. }
  451. user := this.User
  452. if user == nil {
  453. br.Msg = "请登陆"
  454. br.Ret = 408
  455. return
  456. }
  457. sessionKey := user.SessionKey
  458. wxMobile, err := weapp.DecryptMobile(sessionKey, req.EncryptedData, req.Iv)
  459. if err != nil {
  460. br.Msg = "解析用户手机号信息失败"
  461. br.ErrMsg = "解析用户手机号信息失败,Err:" + err.Error()
  462. return
  463. }
  464. err = models.ModifyUsersMobile(user.UserId, wxMobile.PurePhoneNumber)
  465. if err != nil {
  466. br.Msg = "获取失败"
  467. br.ErrMsg = "获取失败,Err:" + err.Error()
  468. return
  469. }
  470. resp := new(models.WxGetPhoneNumberResp)
  471. resp.PhoneNumber = wxMobile.PhoneNumber
  472. resp.PurePhoneNumber = wxMobile.PurePhoneNumber
  473. resp.CountryCode = wxMobile.CountryCode
  474. br.Msg = "获取成功!"
  475. br.Ret = 200
  476. br.Success = true
  477. br.Data = resp
  478. }
  479. // @Title 获取短信验证码
  480. // @Description 获取短信验证码接口
  481. // @Param Mobile query string true "手机号码"
  482. // @Param AreaNum query string true "地区编码"
  483. // @Success Ret=200 获取成功
  484. // @router /getSmsCode [get]
  485. func (this *WechatController) GetSmsCode() {
  486. br := new(models.BaseResponse).Init()
  487. defer func() {
  488. this.Data["json"] = br
  489. this.ServeJSON()
  490. }()
  491. mobile := this.GetString("Mobile")
  492. if mobile == "" {
  493. br.Msg = "请输入手机号"
  494. return
  495. }
  496. areaNum := this.GetString("AreaNum")
  497. msgCode := utils.GetRandDigit(4)
  498. var result bool
  499. if areaNum == "86" || areaNum == "" || areaNum == "0" {
  500. result = services.SendSmsCode(mobile, msgCode)
  501. } else {
  502. result = services.SendSmsCodeGj(mobile, msgCode, areaNum)
  503. }
  504. //发送成功
  505. if result {
  506. item := new(models.MsgCode)
  507. item.OpenId = ""
  508. item.Code = msgCode
  509. item.Mobile = mobile
  510. item.ExpiredIn = time.Now().Add(15 * time.Minute).Unix()
  511. item.Enabled = 1
  512. item.CreatedTime = time.Now()
  513. err := models.AddMsgCode(item)
  514. if err != nil {
  515. br.Msg = "发送失败"
  516. br.ErrMsg = "发送失败,Err:" + err.Error()
  517. return
  518. }
  519. br.Msg = "发送成功"
  520. } else {
  521. br.Msg = "发送失败"
  522. }
  523. br.Ret = 200
  524. br.Success = true
  525. }
  526. // @Title 获取邮件验证码
  527. // @Description 获取邮件验证码接口
  528. // @Param Email query string true "邮箱"
  529. // @Success Ret=200 获取成功
  530. // @router /getEmailCode [get]
  531. func (this *WechatController) GetEmailCode() {
  532. br := new(models.BaseResponse).Init()
  533. defer func() {
  534. this.Data["json"] = br
  535. this.ServeJSON()
  536. }()
  537. email := this.GetString("Email")
  538. if email == "" {
  539. br.Msg = "请输入邮箱地址"
  540. return
  541. }
  542. if !utils.ValidateEmailFormatat(email) {
  543. br.Msg = "邮箱格式错误,请重新输入"
  544. return
  545. }
  546. msgCode := utils.GetRandDigit(4)
  547. content := "尊敬的用户:</br>您好,感谢您使用弘则研究,您正在进行邮箱验证,本次请求的验证码为:" + msgCode + "(为了保障您账号的安全性,请在15分钟内完成验证。)</br>弘则研究团队 </br>2019年05月11日"
  548. title := "弘则研究登陆验证"
  549. //发送邮件
  550. result, err := utils.SendEmailByHz(title, content, email)
  551. if err != nil {
  552. br.Msg = "发送失败"
  553. br.ErrMsg = "发送失败,Err:" + err.Error()
  554. return
  555. }
  556. if result {
  557. item := new(models.MsgCode)
  558. item.OpenId = ""
  559. item.Code = msgCode
  560. item.Mobile = email
  561. item.ExpiredIn = time.Now().Add(15 * time.Minute).Unix()
  562. item.Enabled = 1
  563. item.CreatedTime = time.Now()
  564. err := models.AddMsgCode(item)
  565. if err != nil {
  566. br.Msg = "发送失败"
  567. br.ErrMsg = "发送失败,Err:" + err.Error()
  568. return
  569. }
  570. br.Msg = "发送成功"
  571. } else {
  572. br.Msg = "发送失败"
  573. }
  574. br.Ret = 200
  575. br.Success = true
  576. }
  577. //
  578. //func init() {
  579. // fmt.Println("start")
  580. // sessionKey:=`CBDTrqAe0z8uvC8gFd3lJw==`
  581. // rawData:=`{"nickName":"freedom","gender":0,"language":"zh_CN","city":"","province":"","country":"","avatarUrl":"https://thirdwx.qlogo.cn/mmopen/vi_32/RsZCoxzBXkoeKlKjCkWPh8DR88rtD9PlOYLB7NaFsOmwQr2DOic3m9nh2azEnkZD2mzHZ7lf0oJ53Fh8ARQr9vA/132"}`
  582. // encryptedData:=`OuyYSyhocFgQSj68B4MVvJYJdLCJkSdSu0TuCU+nhcRB6Vzji8e7v/5nDJHsRLopEzUvi/fcUdJKoUtDap08kIxfFsvxKTRXn2OeaCams8Wf6dE4N27HaSpq91Ykfq7Zm33WJJi/PK4kn86t/2a1bBe2FQRrcLH40cLveglPn88MDC0N4cJ119Ab8V4OhTzIbeUNWtlD883GQL7saSsPBsiGhd4a8qoHVmQiZGVjjRJ0vH9X2K404MNKi0kmtcmTGTiecTptY/nf2ZOwohnVYFXVg6C2qFwpZw2ozRNRs7mBzBK818SBM8MHvS6gRuTwkc27/Yhn/7SH4Gq/DTDBoseEa/RENZJdYi1OqRSuS9q+qb5kfvf8GB8I6g+rA35oxvwdqhA3iyotzh91znHr1LMyqPg/ol59TL8T1GYh9ppcg5rrkgywmlF9N+YWaSqpruB9VUxoieKjZNtre1aq1GZAnxY7bwoe7a7u1Uu6vVpnP2kScJC2zK4IgmBExV4/`
  583. //
  584. // signature:=`a1a8a81ae75388bcbb66d92a6682ef4d16d4f634`
  585. // iv:=`ibri5rJxiWOT0Ar/6AfUXw==`
  586. // userInfo, err := weapp.DecryptUserInfo(sessionKey, rawData, encryptedData,signature, iv)
  587. // fmt.Println(userInfo)
  588. // fmt.Println(err)
  589. // fmt.Println("end")
  590. //}
  591. //func init() {
  592. // sessionKey:=`zkHYyjTv2kNQgXyIVYC3cQ==`
  593. // rowData:=`{nickName:rdluck,gender:1,language:zh_CN,city:Wuhan,province:Hubei,country:China,avatarUrl:https://thirdwx.qlogo.cn/mmopen/vi_32/Q0j4TwGTfTJGUvpic2UAQC8Zm8WZg5V9xJtdXDLHpS6VMiaxibzDEXyYoDsXa3F2sXiaegd5lhSbcwMHibwXqTzichww/132}`
  594. // encyData:=`3vg6rtKN2oqdOKRi9fV9sUgBQTgA9ndo2WHEtLSmKofLW4BFKr1AQdAeyzNtPNPIr73vt6hVUt2VzMLTeZWlS1CXBVON8xb5heVhF6RUxXtSbPje2BUYZ HjGthXZ1kkiXs89KD/SsZJ7V0YDz7RB9VQwUROLHz8mCXBXvFa j80BIO637M0wIgU1GQ1tlxoVKedV1Z85FMpSuqGEVPRwyzaVkBeSr6o5zhnMF/O2t4sHb2 mHYCh9i1ssPzpygeOsXzaR5IU/a52bDBHYSEhXi4G79dsTvTKPTOEbaeNOosxx aZiG UNDTZ9hI9tJHhdib0QTCtNhIQpgaEzaFSymj0Dnea1LZN/jx4AyiF U6GX7TOkSFyVNECLJ2HofHet3 Kw3eZ9g4SJHIXwmKUoyEXENjeZScXxs llnfskQEsz4Iibss05/23AS7q4hbTeRD0fsf1jU43qEYjvuyXEFQInKO2kmG1fX0QnFE6UsD5BFtjwUX2yhgrWCBdrrdrcnF5JQBDLtMxY8MGprd0A==`
  595. // sign:=`c70a5d08e8aec0b26a80078d1a6d46ae17acb46a`
  596. // iv:=`0 NP9YFMj3gURHG8wwHNgQ==`
  597. // userInfo,err:=weapp.DecryptUserInfo(sessionKey,rowData, encyData, sign, iv)
  598. // fmt.Println(err)
  599. // fmt.Println(userInfo)
  600. //}