wechat.go 19 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614
  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. //新增登录日志
  196. {
  197. loginLog := new(models.WxUserLog)
  198. loginLog.UserId = userId
  199. loginLog.OpenId = wxInfo.OpenID
  200. loginLog.UnionId = wxInfo.UnionID
  201. loginLog.CreateTime = time.Now()
  202. loginLog.Handle = "wechat_login_cygx"
  203. loginLog.Remark = token
  204. go models.AddWxUserLog(loginLog)
  205. }
  206. {
  207. codeLog := new(models.WxUserCode)
  208. codeLog.WxCode = code
  209. codeLog.UserId = userId
  210. codeLog.Code = 0
  211. codeLog.FirstLogin = firstLogin
  212. codeLog.Authorization = token
  213. codeLog.UserPermission = 1
  214. codeLog.CreateTime = time.Now()
  215. models.AddWxUserCode(codeLog)
  216. }
  217. resp := new(models.WxLoginResp)
  218. resp.UserId = userId
  219. resp.FirstLogin = firstLogin
  220. resp.Authorization = token
  221. br.Ret = 200
  222. br.Success = true
  223. br.Msg = "登录成功"
  224. br.Data = resp
  225. }
  226. //
  227. //// @Title 小程序获取用户信息
  228. //// @Description 小程序获取用户信息接口(需要登录)
  229. //// @Param request body models.WxGetUserInfoReq true "type json string"
  230. //// @Success 200 {object} models.WxGetUserInfoResp
  231. //// @router /getUserInfo [post]
  232. //func (this *WechatController) GetUserInfo() {
  233. // br := new(models.BaseResponse).Init()
  234. // defer func() {
  235. // this.Data["json"] = br
  236. // this.ServeJSON()
  237. // }()
  238. // var req models.WxGetUserInfoReq
  239. // err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  240. // if err != nil {
  241. // br.Msg = "参数解析异常!"
  242. // br.ErrMsg = "参数解析失败,Err:" + err.Error()
  243. // return
  244. // }
  245. // if req.RawData == "" || req.EncryptedData == "" || req.Signature == "" || req.Iv == "" {
  246. // br.Msg = "参数错误"
  247. // return
  248. // }
  249. // user := this.User
  250. // if user == nil {
  251. // br.Msg = "请登陆"
  252. // br.Ret = 408
  253. // return
  254. // }
  255. // sessionKey := user.SessionKey
  256. // userInfo, err := weapp.DecryptUserInfo(sessionKey, req.RawData, req.EncryptedData, req.Signature, req.Iv)
  257. // if err != nil {
  258. // br.Msg = "解析用户信息失败"
  259. // br.ErrMsg = "解析用户信息失败,DecryptUserInfo Err:" + err.Error()
  260. // return
  261. // }
  262. // userId := 0
  263. // //修改用户微信信息
  264. // oldUser, err := models.GetWxUserItemByUnionid(userInfo.UnionID)
  265. // if err != nil && err.Error() != utils.ErrNoRow() {
  266. // br.Msg = "获取用户信息失败"
  267. // br.ErrMsg = "获取用户信息失败 Err:" + err.Error()
  268. // return
  269. // }
  270. // if oldUser == nil || (err != nil && err.Error() == utils.ErrNoRow()) {
  271. // err = models.ModifyWxUserInfo(userInfo.UnionID, userInfo.Nickname, userInfo.Province, userInfo.City, userInfo.Country, userInfo.Avatar, userInfo.Gender, user.UserId)
  272. // if err != nil && err.Error() != utils.ErrNoRow() {
  273. // br.Msg = "获取用户信息失败"
  274. // br.ErrMsg = "修改用户信息失败 Err:" + err.Error()
  275. // return
  276. // }
  277. // userId = user.UserId
  278. // } else {
  279. // if user.UserId == oldUser.UserId {
  280. // err = models.ModifyWxUserInfo(userInfo.UnionID, userInfo.Nickname, userInfo.Province, userInfo.City, userInfo.Country, userInfo.Avatar, userInfo.Gender, user.UserId)
  281. // if err != nil && err.Error() != utils.ErrNoRow() {
  282. // br.Msg = "获取用户信息失败"
  283. // br.ErrMsg = "修改用户信息失败 Err:" + err.Error()
  284. // return
  285. // }
  286. // userId = user.UserId
  287. // } else {
  288. // userId = oldUser.UserId
  289. // err = models.ModifyWxUserInfo(userInfo.UnionID, userInfo.Nickname, userInfo.Province, userInfo.City, userInfo.Country, userInfo.Avatar, userInfo.Gender, oldUser.UserId)
  290. // if err != nil && err.Error() != utils.ErrNoRow() {
  291. // br.Msg = "获取用户信息失败"
  292. // br.ErrMsg = "修改用户信息失败 Err:" + err.Error()
  293. // return
  294. // }
  295. // err = models.DeleteWxUserByUserId(user.UserId)
  296. // if err != nil {
  297. // br.Msg = "删除用户信息失败"
  298. // br.ErrMsg = "删除用户信息失败 Err:" + err.Error()
  299. // return
  300. // }
  301. // }
  302. // }
  303. // var token string
  304. // tokenItem, err := models.GetTokenByUid(userId)
  305. // if err != nil && err.Error() != utils.ErrNoRow() {
  306. // br.Msg = "登录失败"
  307. // br.ErrMsg = "登录失败,获取token失败:" + err.Error()
  308. // return
  309. // }
  310. //
  311. // if tokenItem == nil || (err != nil && err.Error() == utils.ErrNoRow()) {
  312. // timeUnix := time.Now().Unix()
  313. // timeUnixStr := strconv.FormatInt(timeUnix, 10)
  314. // token = utils.MD5(strconv.Itoa(userId)) + utils.MD5(timeUnixStr)
  315. // //新增session
  316. // {
  317. // session := new(models.CygxSession)
  318. // session.OpenId = userInfo.OpenID
  319. // session.UnionId = userInfo.UnionID
  320. // session.UserId = userId
  321. // session.CreatedTime = time.Now()
  322. // session.LastUpdatedTime = time.Now()
  323. // session.ExpireTime = time.Now().AddDate(0, 3, 0)
  324. // session.AccessToken = token
  325. // err = models.AddSession(session)
  326. // if err != nil {
  327. // br.Msg = "登录失败"
  328. // br.ErrMsg = "登录失败,新增用户session信息失败:" + err.Error()
  329. // return
  330. // }
  331. // }
  332. // } else {
  333. // token = tokenItem.AccessToken
  334. // }
  335. // resp := new(models.WxGetUserInfoResp)
  336. // resp.Authorization = token
  337. // br.Msg = "获取成功!"
  338. // br.Ret = 200
  339. // br.Success = true
  340. //}
  341. // @Title 小程序获取用户信息
  342. // @Description 小程序获取用户信息接口(需要登录)
  343. // @Param request body models.WxGetUserInfoReq true "type json string"
  344. // @Success 200 {object} models.WxGetUserInfoResp
  345. // @router /getUserInfo [post]
  346. func (this *WechatController) GetUserInfo() {
  347. br := new(models.BaseResponse).Init()
  348. defer func() {
  349. this.Data["json"] = br
  350. this.ServeJSON()
  351. }()
  352. var req models.WxGetUserInfoReq
  353. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  354. if err != nil {
  355. br.Msg = "参数解析异常!"
  356. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  357. return
  358. }
  359. if req.RawData == "" || req.EncryptedData == "" || req.Signature == "" || req.Iv == "" {
  360. br.Msg = "参数错误"
  361. return
  362. }
  363. user := this.User
  364. if user == nil {
  365. br.Msg = "请登陆"
  366. br.Ret = 408
  367. return
  368. }
  369. userId := user.UserId
  370. sessionKey := user.SessionKey
  371. fmt.Println("sessionKey:", sessionKey)
  372. fmt.Println(sessionKey, req.RawData, req.EncryptedData, req.Signature, req.Iv)
  373. userInfo, err := weapp.DecryptUserInfo(sessionKey, req.RawData, req.EncryptedData, req.Signature, req.Iv)
  374. if err != nil {
  375. br.Msg = "解析用户信息失败"
  376. br.ErrMsg = "解析用户信息失败,DecryptUserInfo Err:" + err.Error()
  377. return
  378. }
  379. //修改用户微信信息
  380. err = models.ModifyUserRecordInfo(userInfo.UnionID, userInfo.Nickname, userInfo.Avatar, userInfo.City, userInfo.Province, userInfo.Country, userInfo.Gender, userId)
  381. if err != nil {
  382. br.Msg = "授权失败"
  383. br.ErrMsg = "授权失败,修改用户信息失败:" + err.Error()
  384. return
  385. }
  386. var token string
  387. tokenItem, err := models.GetTokenByOpenId(userInfo.OpenID)
  388. if err != nil && err.Error() != utils.ErrNoRow() {
  389. br.Msg = "授权失败"
  390. br.ErrMsg = "授权失败,获取token失败:" + err.Error()
  391. return
  392. }
  393. if tokenItem == nil || (err != nil && err.Error() == utils.ErrNoRow()) {
  394. timeUnix := time.Now().Unix()
  395. timeUnixStr := strconv.FormatInt(timeUnix, 10)
  396. token = utils.MD5(userInfo.OpenID) + utils.MD5(timeUnixStr)
  397. //新增session
  398. {
  399. session := new(models.CygxSession)
  400. session.OpenId = userInfo.OpenID
  401. session.UnionId = userInfo.UnionID
  402. session.UserId = userId
  403. session.CreatedTime = time.Now()
  404. session.LastUpdatedTime = time.Now()
  405. session.ExpireTime = time.Now().AddDate(0, 3, 0)
  406. session.AccessToken = token
  407. err = models.AddSession(session)
  408. if err != nil {
  409. br.Msg = "授权失败"
  410. br.ErrMsg = "授权失败,新增用户session信息失败:" + err.Error()
  411. return
  412. }
  413. }
  414. } else {
  415. token = tokenItem.AccessToken
  416. }
  417. resp := new(models.WxGetUserInfoResp)
  418. resp.Authorization = token
  419. br.Msg = "获取成功!"
  420. br.Ret = 200
  421. br.Success = true
  422. }
  423. // @Title 小程序获取用户绑定手机号
  424. // @Description 小程序获取用户绑定手机号接口(需要登录)
  425. // @Param request body models.WxGetPhoneNumberReq true "type json string"
  426. // @Success 200 {object} models.WxGetPhoneNumberResp
  427. // @router /getPhoneNumber [post]
  428. func (this *WechatController) GetPhoneNumber() {
  429. br := new(models.BaseResponse).Init()
  430. defer func() {
  431. this.Data["json"] = br
  432. this.ServeJSON()
  433. }()
  434. var req models.WxGetPhoneNumberReq
  435. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  436. if err != nil {
  437. br.Msg = "参数解析异常!"
  438. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  439. return
  440. }
  441. if req.EncryptedData == "" || req.Iv == "" {
  442. br.Msg = "参数错误"
  443. return
  444. }
  445. user := this.User
  446. if user == nil {
  447. br.Msg = "请登陆"
  448. br.Ret = 408
  449. return
  450. }
  451. sessionKey := user.SessionKey
  452. wxMobile, err := weapp.DecryptMobile(sessionKey, req.EncryptedData, req.Iv)
  453. if err != nil {
  454. br.Msg = "解析用户手机号信息失败"
  455. br.ErrMsg = "解析用户手机号信息失败,Err:" + err.Error()
  456. return
  457. }
  458. err = models.ModifyUsersMobile(user.UserId, wxMobile.PurePhoneNumber)
  459. if err != nil {
  460. br.Msg = "获取失败"
  461. br.ErrMsg = "获取失败,Err:" + err.Error()
  462. return
  463. }
  464. resp := new(models.WxGetPhoneNumberResp)
  465. resp.PhoneNumber = wxMobile.PhoneNumber
  466. resp.PurePhoneNumber = wxMobile.PurePhoneNumber
  467. resp.CountryCode = wxMobile.CountryCode
  468. br.Msg = "获取成功!"
  469. br.Ret = 200
  470. br.Success = true
  471. br.Data = resp
  472. }
  473. // @Title 获取短信验证码
  474. // @Description 获取短信验证码接口
  475. // @Param Mobile query string true "手机号码"
  476. // @Param AreaNum query string true "地区编码"
  477. // @Success Ret=200 获取成功
  478. // @router /getSmsCode [get]
  479. func (this *WechatController) GetSmsCode() {
  480. br := new(models.BaseResponse).Init()
  481. defer func() {
  482. this.Data["json"] = br
  483. this.ServeJSON()
  484. }()
  485. mobile := this.GetString("Mobile")
  486. if mobile == "" {
  487. br.Msg = "请输入手机号"
  488. return
  489. }
  490. areaNum := this.GetString("AreaNum")
  491. msgCode := utils.GetRandDigit(4)
  492. var result bool
  493. if areaNum == "86" || areaNum == "" || areaNum == "0" {
  494. result = services.SendSmsCode(mobile, msgCode)
  495. } else {
  496. result = services.SendSmsCodeGj(mobile, msgCode, areaNum)
  497. }
  498. //发送成功
  499. if result {
  500. item := new(models.MsgCode)
  501. item.OpenId = ""
  502. item.Code = msgCode
  503. item.Mobile = mobile
  504. item.ExpiredIn = time.Now().Add(15 * time.Minute).Unix()
  505. item.Enabled = 1
  506. item.CreatedTime = time.Now()
  507. err := models.AddMsgCode(item)
  508. if err != nil {
  509. br.Msg = "发送失败"
  510. br.ErrMsg = "发送失败,Err:" + err.Error()
  511. return
  512. }
  513. br.Msg = "发送成功"
  514. } else {
  515. br.Msg = "发送失败"
  516. }
  517. br.Ret = 200
  518. br.Success = true
  519. }
  520. // @Title 获取邮件验证码
  521. // @Description 获取邮件验证码接口
  522. // @Param Email query string true "邮箱"
  523. // @Success Ret=200 获取成功
  524. // @router /getEmailCode [get]
  525. func (this *WechatController) GetEmailCode() {
  526. br := new(models.BaseResponse).Init()
  527. defer func() {
  528. this.Data["json"] = br
  529. this.ServeJSON()
  530. }()
  531. email := this.GetString("Email")
  532. if email == "" {
  533. br.Msg = "请输入邮箱地址"
  534. return
  535. }
  536. if !utils.ValidateEmailFormatat(email) {
  537. br.Msg = "邮箱格式错误,请重新输入"
  538. return
  539. }
  540. msgCode := utils.GetRandDigit(4)
  541. content := "尊敬的用户:</br>您好,感谢您使用弘则研究,您正在进行邮箱验证,本次请求的验证码为:" + msgCode + "(为了保障您账号的安全性,请在15分钟内完成验证。)</br>弘则研究团队 </br>2019年05月11日"
  542. title := "弘则研究登陆验证"
  543. //发送邮件
  544. result, err := utils.SendEmailByHz(title, content, email)
  545. if err != nil {
  546. br.Msg = "发送失败"
  547. br.ErrMsg = "发送失败,Err:" + err.Error()
  548. return
  549. }
  550. if result {
  551. item := new(models.MsgCode)
  552. item.OpenId = ""
  553. item.Code = msgCode
  554. item.Mobile = email
  555. item.ExpiredIn = time.Now().Add(15 * time.Minute).Unix()
  556. item.Enabled = 1
  557. item.CreatedTime = time.Now()
  558. err := models.AddMsgCode(item)
  559. if err != nil {
  560. br.Msg = "发送失败"
  561. br.ErrMsg = "发送失败,Err:" + err.Error()
  562. return
  563. }
  564. br.Msg = "发送成功"
  565. } else {
  566. br.Msg = "发送失败"
  567. }
  568. br.Ret = 200
  569. br.Success = true
  570. }
  571. //
  572. //func init() {
  573. // fmt.Println("start")
  574. // sessionKey:=`CBDTrqAe0z8uvC8gFd3lJw==`
  575. // rawData:=`{"nickName":"freedom","gender":0,"language":"zh_CN","city":"","province":"","country":"","avatarUrl":"https://thirdwx.qlogo.cn/mmopen/vi_32/RsZCoxzBXkoeKlKjCkWPh8DR88rtD9PlOYLB7NaFsOmwQr2DOic3m9nh2azEnkZD2mzHZ7lf0oJ53Fh8ARQr9vA/132"}`
  576. // encryptedData:=`OuyYSyhocFgQSj68B4MVvJYJdLCJkSdSu0TuCU+nhcRB6Vzji8e7v/5nDJHsRLopEzUvi/fcUdJKoUtDap08kIxfFsvxKTRXn2OeaCams8Wf6dE4N27HaSpq91Ykfq7Zm33WJJi/PK4kn86t/2a1bBe2FQRrcLH40cLveglPn88MDC0N4cJ119Ab8V4OhTzIbeUNWtlD883GQL7saSsPBsiGhd4a8qoHVmQiZGVjjRJ0vH9X2K404MNKi0kmtcmTGTiecTptY/nf2ZOwohnVYFXVg6C2qFwpZw2ozRNRs7mBzBK818SBM8MHvS6gRuTwkc27/Yhn/7SH4Gq/DTDBoseEa/RENZJdYi1OqRSuS9q+qb5kfvf8GB8I6g+rA35oxvwdqhA3iyotzh91znHr1LMyqPg/ol59TL8T1GYh9ppcg5rrkgywmlF9N+YWaSqpruB9VUxoieKjZNtre1aq1GZAnxY7bwoe7a7u1Uu6vVpnP2kScJC2zK4IgmBExV4/`
  577. //
  578. // signature:=`a1a8a81ae75388bcbb66d92a6682ef4d16d4f634`
  579. // iv:=`ibri5rJxiWOT0Ar/6AfUXw==`
  580. // userInfo, err := weapp.DecryptUserInfo(sessionKey, rawData, encryptedData,signature, iv)
  581. // fmt.Println(userInfo)
  582. // fmt.Println(err)
  583. // fmt.Println("end")
  584. //}
  585. //func init() {
  586. // sessionKey:=`zkHYyjTv2kNQgXyIVYC3cQ==`
  587. // rowData:=`{nickName:rdluck,gender:1,language:zh_CN,city:Wuhan,province:Hubei,country:China,avatarUrl:https://thirdwx.qlogo.cn/mmopen/vi_32/Q0j4TwGTfTJGUvpic2UAQC8Zm8WZg5V9xJtdXDLHpS6VMiaxibzDEXyYoDsXa3F2sXiaegd5lhSbcwMHibwXqTzichww/132}`
  588. // encyData:=`3vg6rtKN2oqdOKRi9fV9sUgBQTgA9ndo2WHEtLSmKofLW4BFKr1AQdAeyzNtPNPIr73vt6hVUt2VzMLTeZWlS1CXBVON8xb5heVhF6RUxXtSbPje2BUYZ HjGthXZ1kkiXs89KD/SsZJ7V0YDz7RB9VQwUROLHz8mCXBXvFa j80BIO637M0wIgU1GQ1tlxoVKedV1Z85FMpSuqGEVPRwyzaVkBeSr6o5zhnMF/O2t4sHb2 mHYCh9i1ssPzpygeOsXzaR5IU/a52bDBHYSEhXi4G79dsTvTKPTOEbaeNOosxx aZiG UNDTZ9hI9tJHhdib0QTCtNhIQpgaEzaFSymj0Dnea1LZN/jx4AyiF U6GX7TOkSFyVNECLJ2HofHet3 Kw3eZ9g4SJHIXwmKUoyEXENjeZScXxs llnfskQEsz4Iibss05/23AS7q4hbTeRD0fsf1jU43qEYjvuyXEFQInKO2kmG1fX0QnFE6UsD5BFtjwUX2yhgrWCBdrrdrcnF5JQBDLtMxY8MGprd0A==`
  589. // sign:=`c70a5d08e8aec0b26a80078d1a6d46ae17acb46a`
  590. // iv:=`0 NP9YFMj3gURHG8wwHNgQ==`
  591. // userInfo,err:=weapp.DecryptUserInfo(sessionKey,rowData, encyData, sign, iv)
  592. // fmt.Println(err)
  593. // fmt.Println(userInfo)
  594. //}