user.open.id.set.go 1.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758
  1. package user
  2. import (
  3. "duoduo/apis/pdd"
  4. "duoduo/conf"
  5. "duoduo/models/mysql"
  6. "duoduo/models/user"
  7. "duoduo/tools"
  8. "duoduo/tools/app"
  9. "fmt"
  10. "github.com/gin-gonic/gin"
  11. )
  12. func OpenIdSet(c *gin.Context) {
  13. var inData user.OpenIdSetRequest
  14. var outData user.OpenIdSetResponse
  15. var sqlData mysql.User
  16. err := c.ShouldBindJSON(&inData)
  17. if err != nil {
  18. app.Error(c, 400, err, err.Error())
  19. return
  20. }
  21. confIni, err := conf.ConnIni()
  22. if err != nil {
  23. app.Error(c, 400, err, err.Error())
  24. return
  25. }
  26. url := fmt.Sprintf("https://api.weixin.qq.com/sns/jscode2session?appid=%s&secret=%s&js_code=%s&grant_type=authorization_code", confIni.MustValue("wx", "app_id"), confIni.MustValue("wx", "secret"), inData.Code)
  27. val, err := pdd.DuoDuoGet(url)
  28. if err != nil {
  29. app.Error(c, 500, err, err.Error())
  30. return
  31. }
  32. fmt.Print(val)
  33. err = tools.JsonUnmarshal(val, &outData)
  34. if err != nil {
  35. app.Error(c, 500, err, err.Error())
  36. return
  37. }
  38. if outData.Errcode != 0 {
  39. app.Error(c, outData.Errcode, err, outData.Errmsg)
  40. return
  41. }
  42. //查询数据
  43. sqlData.OpenID = outData.OpenId
  44. num := sqlData.GetNum()
  45. if num == 0 {
  46. sqlData.CreateTime = tools.GetCurrntTimeStr()
  47. sqlData.UpdateTime = tools.GetCurrntTimeStr()
  48. sqlData.Create()
  49. }
  50. app.OK(c, outData, app.Success)
  51. }