wechat.go 19 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616
  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. fmt.Println("weapp.DecryptUserInfo ", err)
  375. if err != nil {
  376. br.Msg = "解析用户信息失败"
  377. br.ErrMsg = "解析用户信息失败,DecryptUserInfo Err:" + err.Error()
  378. return
  379. }
  380. //修改用户微信信息
  381. err = models.ModifyUserRecordByDetail(userInfo.OpenID, userInfo.UnionID, userInfo.Nickname, userInfo.Avatar, userInfo.City, userInfo.Province, userInfo.Country, userInfo.Gender, userId)
  382. if err != nil {
  383. br.Msg = "授权失败"
  384. br.ErrMsg = "授权失败,修改用户信息失败:" + err.Error()
  385. return
  386. }
  387. var token string
  388. tokenItem, err := models.GetTokenByOpenId(userInfo.OpenID)
  389. if err != nil && err.Error() != utils.ErrNoRow() {
  390. br.Msg = "授权失败"
  391. br.ErrMsg = "授权失败,获取token失败:" + err.Error()
  392. return
  393. }
  394. if tokenItem == nil || (err != nil && err.Error() == utils.ErrNoRow()) {
  395. timeUnix := time.Now().Unix()
  396. timeUnixStr := strconv.FormatInt(timeUnix, 10)
  397. token = utils.MD5(userInfo.OpenID) + utils.MD5(timeUnixStr)
  398. //新增session
  399. {
  400. session := new(models.CygxSession)
  401. session.OpenId = userInfo.OpenID
  402. session.UnionId = userInfo.UnionID
  403. session.UserId = userId
  404. session.CreatedTime = time.Now()
  405. session.LastUpdatedTime = time.Now()
  406. session.ExpireTime = time.Now().AddDate(0, 3, 0)
  407. session.AccessToken = token
  408. err = models.AddSession(session)
  409. if err != nil {
  410. br.Msg = "授权失败"
  411. br.ErrMsg = "授权失败,新增用户session信息失败:" + err.Error()
  412. return
  413. }
  414. }
  415. } else {
  416. token = tokenItem.AccessToken
  417. }
  418. resp := new(models.WxGetUserInfoResp)
  419. resp.Authorization = token
  420. br.Msg = "获取成功!"
  421. br.Ret = 200
  422. br.Success = true
  423. }
  424. // @Title 小程序获取用户绑定手机号
  425. // @Description 小程序获取用户绑定手机号接口(需要登录)
  426. // @Param request body models.WxGetPhoneNumberReq true "type json string"
  427. // @Success 200 {object} models.WxGetPhoneNumberResp
  428. // @router /getPhoneNumber [post]
  429. func (this *WechatController) GetPhoneNumber() {
  430. br := new(models.BaseResponse).Init()
  431. defer func() {
  432. this.Data["json"] = br
  433. this.ServeJSON()
  434. }()
  435. var req models.WxGetPhoneNumberReq
  436. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  437. if err != nil {
  438. br.Msg = "参数解析异常!"
  439. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  440. return
  441. }
  442. if req.EncryptedData == "" || req.Iv == "" {
  443. br.Msg = "参数错误"
  444. return
  445. }
  446. user := this.User
  447. if user == nil {
  448. br.Msg = "请登陆"
  449. br.Ret = 408
  450. return
  451. }
  452. sessionKey := user.SessionKey
  453. wxMobile, err := weapp.DecryptMobile(sessionKey, req.EncryptedData, req.Iv)
  454. if err != nil {
  455. br.Msg = "解析用户手机号信息失败"
  456. br.ErrMsg = "解析用户手机号信息失败,Err:" + err.Error()
  457. return
  458. }
  459. err = models.ModifyUsersMobile(user.UserId, wxMobile.PurePhoneNumber)
  460. if err != nil {
  461. br.Msg = "获取失败"
  462. br.ErrMsg = "获取失败,Err:" + err.Error()
  463. return
  464. }
  465. resp := new(models.WxGetPhoneNumberResp)
  466. resp.PhoneNumber = wxMobile.PhoneNumber
  467. resp.PurePhoneNumber = wxMobile.PurePhoneNumber
  468. resp.CountryCode = wxMobile.CountryCode
  469. br.Msg = "获取成功!"
  470. br.Ret = 200
  471. br.Success = true
  472. br.Data = resp
  473. }
  474. // @Title 获取短信验证码
  475. // @Description 获取短信验证码接口
  476. // @Param Mobile query string true "手机号码"
  477. // @Param AreaNum query string true "地区编码"
  478. // @Success Ret=200 获取成功
  479. // @router /getSmsCode [get]
  480. func (this *WechatController) GetSmsCode() {
  481. br := new(models.BaseResponse).Init()
  482. defer func() {
  483. this.Data["json"] = br
  484. this.ServeJSON()
  485. }()
  486. mobile := this.GetString("Mobile")
  487. if mobile == "" {
  488. br.Msg = "请输入手机号"
  489. return
  490. }
  491. areaNum := this.GetString("AreaNum")
  492. msgCode := utils.GetRandDigit(4)
  493. var result bool
  494. if areaNum == "86" || areaNum == "" || areaNum == "0" {
  495. result = services.SendSmsCode(mobile, msgCode)
  496. } else {
  497. result = services.SendSmsCodeGj(mobile, msgCode, areaNum)
  498. }
  499. //发送成功
  500. if result {
  501. item := new(models.MsgCode)
  502. item.OpenId = ""
  503. item.Code = msgCode
  504. item.Mobile = mobile
  505. item.ExpiredIn = time.Now().Add(15 * time.Minute).Unix()
  506. item.Enabled = 1
  507. item.CreatedTime = time.Now()
  508. err := models.AddMsgCode(item)
  509. if err != nil {
  510. br.Msg = "发送失败"
  511. br.ErrMsg = "发送失败,Err:" + err.Error()
  512. return
  513. }
  514. br.Msg = "发送成功"
  515. } else {
  516. br.Msg = "发送失败"
  517. }
  518. br.Ret = 200
  519. br.Success = true
  520. }
  521. // @Title 获取邮件验证码
  522. // @Description 获取邮件验证码接口
  523. // @Param Email query string true "邮箱"
  524. // @Success Ret=200 获取成功
  525. // @router /getEmailCode [get]
  526. func (this *WechatController) GetEmailCode() {
  527. br := new(models.BaseResponse).Init()
  528. defer func() {
  529. this.Data["json"] = br
  530. this.ServeJSON()
  531. }()
  532. email := this.GetString("Email")
  533. if email == "" {
  534. br.Msg = "请输入邮箱地址"
  535. return
  536. }
  537. if !utils.ValidateEmailFormatat(email) {
  538. br.Msg = "邮箱格式错误,请重新输入"
  539. return
  540. }
  541. msgCode := utils.GetRandDigit(4)
  542. content := "尊敬的用户:</br>您好,感谢您使用弘则研究,您正在进行邮箱验证,本次请求的验证码为:" + msgCode + "(为了保障您账号的安全性,请在15分钟内完成验证。)</br>弘则研究团队 </br>2019年05月11日"
  543. title := "弘则研究登陆验证"
  544. //发送邮件
  545. result, err := utils.SendEmailByHz(title, content, email)
  546. if err != nil {
  547. br.Msg = "发送失败"
  548. br.ErrMsg = "发送失败,Err:" + err.Error()
  549. return
  550. }
  551. if result {
  552. item := new(models.MsgCode)
  553. item.OpenId = ""
  554. item.Code = msgCode
  555. item.Mobile = email
  556. item.ExpiredIn = time.Now().Add(15 * time.Minute).Unix()
  557. item.Enabled = 1
  558. item.CreatedTime = time.Now()
  559. err := models.AddMsgCode(item)
  560. if err != nil {
  561. br.Msg = "发送失败"
  562. br.ErrMsg = "发送失败,Err:" + err.Error()
  563. return
  564. }
  565. br.Msg = "发送成功"
  566. } else {
  567. br.Msg = "发送失败"
  568. }
  569. br.Ret = 200
  570. br.Success = true
  571. }
  572. //
  573. //func init() {
  574. // fmt.Println("start")
  575. // sessionKey:=`CBDTrqAe0z8uvC8gFd3lJw==`
  576. // rawData:=`{"nickName":"freedom","gender":0,"language":"zh_CN","city":"","province":"","country":"","avatarUrl":"https://thirdwx.qlogo.cn/mmopen/vi_32/RsZCoxzBXkoeKlKjCkWPh8DR88rtD9PlOYLB7NaFsOmwQr2DOic3m9nh2azEnkZD2mzHZ7lf0oJ53Fh8ARQr9vA/132"}`
  577. // encryptedData:=`OuyYSyhocFgQSj68B4MVvJYJdLCJkSdSu0TuCU+nhcRB6Vzji8e7v/5nDJHsRLopEzUvi/fcUdJKoUtDap08kIxfFsvxKTRXn2OeaCams8Wf6dE4N27HaSpq91Ykfq7Zm33WJJi/PK4kn86t/2a1bBe2FQRrcLH40cLveglPn88MDC0N4cJ119Ab8V4OhTzIbeUNWtlD883GQL7saSsPBsiGhd4a8qoHVmQiZGVjjRJ0vH9X2K404MNKi0kmtcmTGTiecTptY/nf2ZOwohnVYFXVg6C2qFwpZw2ozRNRs7mBzBK818SBM8MHvS6gRuTwkc27/Yhn/7SH4Gq/DTDBoseEa/RENZJdYi1OqRSuS9q+qb5kfvf8GB8I6g+rA35oxvwdqhA3iyotzh91znHr1LMyqPg/ol59TL8T1GYh9ppcg5rrkgywmlF9N+YWaSqpruB9VUxoieKjZNtre1aq1GZAnxY7bwoe7a7u1Uu6vVpnP2kScJC2zK4IgmBExV4/`
  578. //
  579. // signature:=`a1a8a81ae75388bcbb66d92a6682ef4d16d4f634`
  580. // iv:=`ibri5rJxiWOT0Ar/6AfUXw==`
  581. // userInfo, err := weapp.DecryptUserInfo(sessionKey, rawData, encryptedData,signature, iv)
  582. // fmt.Println(userInfo)
  583. // fmt.Println(err)
  584. // fmt.Println("end")
  585. //}
  586. //func init() {
  587. // sessionKey:=`zkHYyjTv2kNQgXyIVYC3cQ==`
  588. // rowData:=`{nickName:rdluck,gender:1,language:zh_CN,city:Wuhan,province:Hubei,country:China,avatarUrl:https://thirdwx.qlogo.cn/mmopen/vi_32/Q0j4TwGTfTJGUvpic2UAQC8Zm8WZg5V9xJtdXDLHpS6VMiaxibzDEXyYoDsXa3F2sXiaegd5lhSbcwMHibwXqTzichww/132}`
  589. // encyData:=`3vg6rtKN2oqdOKRi9fV9sUgBQTgA9ndo2WHEtLSmKofLW4BFKr1AQdAeyzNtPNPIr73vt6hVUt2VzMLTeZWlS1CXBVON8xb5heVhF6RUxXtSbPje2BUYZ HjGthXZ1kkiXs89KD/SsZJ7V0YDz7RB9VQwUROLHz8mCXBXvFa j80BIO637M0wIgU1GQ1tlxoVKedV1Z85FMpSuqGEVPRwyzaVkBeSr6o5zhnMF/O2t4sHb2 mHYCh9i1ssPzpygeOsXzaR5IU/a52bDBHYSEhXi4G79dsTvTKPTOEbaeNOosxx aZiG UNDTZ9hI9tJHhdib0QTCtNhIQpgaEzaFSymj0Dnea1LZN/jx4AyiF U6GX7TOkSFyVNECLJ2HofHet3 Kw3eZ9g4SJHIXwmKUoyEXENjeZScXxs llnfskQEsz4Iibss05/23AS7q4hbTeRD0fsf1jU43qEYjvuyXEFQInKO2kmG1fX0QnFE6UsD5BFtjwUX2yhgrWCBdrrdrcnF5JQBDLtMxY8MGprd0A==`
  590. // sign:=`c70a5d08e8aec0b26a80078d1a6d46ae17acb46a`
  591. // iv:=`0 NP9YFMj3gURHG8wwHNgQ==`
  592. // userInfo,err:=weapp.DecryptUserInfo(sessionKey,rowData, encyData, sign, iv)
  593. // fmt.Println(err)
  594. // fmt.Println(userInfo)
  595. //}