init.go 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608
  1. package apps
  2. import (
  3. "fmt"
  4. "regexp"
  5. "strings"
  6. // "time"
  7. "github.com/astaxie/beego"
  8. "github.com/astaxie/beego/context"
  9. "github.com/user_agent"
  10. // "github.com/uuid"
  11. // "fohow.com/apps/controllers/user_controller"
  12. // "fohow.com/apps/models/balance_model"
  13. "fohow.com/apps/models/channel_gzh_qrcode_model"
  14. "fohow.com/apps/models/user_model"
  15. // "fohow.com/libs/tool"
  16. // "fohow.com/libs/wx_mp"
  17. )
  18. const (
  19. SessionUserKey = "uid"
  20. SessionWxUserKey = "wxuid" //用于小程序
  21. // SessionWxXcxUserKey = "wxxcxuid"
  22. XcxSessionKey = "XcxSessionKey" // 小程序用于加密解密数据的key
  23. )
  24. var (
  25. // 共用
  26. NoCart = []string{"noCart", "请选择您需要结算的产品"}
  27. NoExist = []string{"noExist", "不存在"}
  28. HasOver = []string{"hasOver", "已结束"}
  29. HasPaied = []string{"hasPaied", "已支付"}
  30. AccountError = []string{"accountError", "账户异常"}
  31. GongZhongHaoNoExist = []string{"gongZhongHaoNoExist", "公众号不存在"}
  32. Error = []string{"error", "未知错误"}
  33. TypeError = []string{"error", "类型错误"}
  34. CountError = []string{"countError", "数量错误"}
  35. RegisterUserError = []string{"registerUserError", "注册会员错误"}
  36. BindingWxPhoneError = []string{"bindingWxPhone", "绑定失败"}
  37. XcxAuthorizeError = []string{"XcxAuthorizeError", "授权失败"}
  38. PicVerifyCodeError = []string{"picVerifyCodeError", "图片验证码错误"}
  39. WxUserInfoError = []string{"wxUserInfoError", "微信会员信息错误!"}
  40. ChannelNotMatch = []string{"channelNotMatch", "渠道不匹配"}
  41. ChanneloExist = []string{"channelNoExist", "渠道不存在"}
  42. UploadFileError = []string{"uploadFileError", "上传文件失败!"}
  43. UploadFileTypeInvalid = []string{"uploadFileTypeError", "上传文件类型错误!仅支持以下格式:doc|docx|pdf|ppt|pptx|zip"}
  44. UploadImgTypeInvalid = []string{"uploadImgTypeError", "上传文件类型错误!仅支持以下格式:png|jpg|jpeg"}
  45. // 登录相关
  46. HasLogin = []string{"hasLogin", "已登录"}
  47. HasLogout = []string{"hasLogout", "已登出"}
  48. UserNeedLogin = []string{"userNeedLogin", "需要用户登录"}
  49. UserAuthorizeFailed = []string{"userAuthorizeFailed", "用户授权失败"}
  50. UserNeedTel = []string{"userNeedTel", "需要用户绑定手机"}
  51. UserTelNotMatch = []string{"userTelNotMatch", "手机号码不匹配,请使用当前登录用户的号码"}
  52. WxUserNeedLogin = []string{"wxUserNeedLogin", "需要微信用户登录"}
  53. NotWeixinClient = []string{"notWeixinClient", "不是微信客户端"}
  54. SignupNotOpen = []string{"signupNotOpen", "注册暂未开放,敬请期待"}
  55. // 支付相关
  56. PayWayNoMatch = []string{"payWayNoMatch", "请选择正确的支付方式"}
  57. //请输入充值数额
  58. RechargeCountWrong = []string{"rechargeCountWrong", "请输入充值数额"}
  59. // 关注
  60. WxUserNeedSubscribe = []string{"wxUserNeedSubscribe", "请先关注公众号"}
  61. TGDKjNeedSub = []string{"TGDKjNeedSub", "请先进入公众号领取大刀"}
  62. BlackUser = []string{"blackUser", "对不起,您已被拉黑"}
  63. BlackUrl = []string{"blackUrl", "对不起,网址不允许访问"}
  64. BlackOrder = []string{"blackOrder", "该订单作弊,已被拉黑"}
  65. CreateOrderFail = []string{"createOrderFail", "创建订单失败"}
  66. OnlyPlayInWeixin = []string{"onlyPlayInWeixin", "只能在微信客户端进行"}
  67. OrderNotExist = []string{"orderNotExist", "订单不存在"}
  68. OrderExist = []string{"orderExist", "订单已存在"}
  69. PayFail = []string{"payFail", "支付失败"}
  70. ParamsError = []string{"paramsError", "参数错误"}
  71. ValidParamsError = []string{"validateParamsError", "验证参数错误"}
  72. ParamsRequired = []string{"paramsRequired", "缺少参数"}
  73. ProductStockZero = []string{"productStockZero", "商品库存为零"}
  74. ProductStockNotEnough = []string{"productStockNotEnough", "商品库存不足"}
  75. ProductNotExist = []string{"productNotExist", "产品不存在"}
  76. ProductNotApproved = []string{"productNotApproved", "产品还未上架"}
  77. ProductOffSale = []string{"productOffSale", "产品已经下架"}
  78. OverLimitCount = []string{"overLimitCount", "超过限购数量"}
  79. PurchasedReachLimit = []string{"purchasedReachLimit", "已购买总数已达到限购数量"}
  80. RedirectTo = []string{"redirectTo", "302跳转"}
  81. ReduceFail = []string{"reduceFail", "帮砍失败"}
  82. UserNotExist = []string{"userNotExist", "用户不存在"}
  83. AddressNotExist = []string{"addressNotExist", "地址不存在"}
  84. UserAddressFull = []string{"userAddressFull", "最多添加5条地址"}
  85. UploadUserHeadError = []string{"uploadUserHeadError", "上传头像错误"}
  86. AddressNotMatch = []string{"addressNotMatch", "地址不匹配"}
  87. NotUnPay = []string{"notUnPay", "无法支付,该订单已支付或者已过期"}
  88. NotRightPayWay = []string{"notRightPayWay", "无法支付,该订单只支持微信支付"}
  89. HasAlreadyPay = []string{"hasAlreadyPay", "该订单已支付过"}
  90. NotPayInTime = []string{"notPayInTime", "没在规定时间内完成支付"}
  91. PayWayNotAllow = []string{"payWayNotAllow", "不支持该支付方式"}
  92. PayNoAuthed = []string{"payNoAuthed", "支付未授权"}
  93. PhoneInvalid = []string{"phoneInvalid", "手机号码格式不正确"}
  94. PhoneExist = []string{"phoneExist", "手机号码已被注册,请更换其他号码"}
  95. SMSInvalid = []string{"smsInvalid", "短信验证码不正确"}
  96. CodesSendTooOften = []string{"codesSendTooOften", "短信验证码发送过于频繁,请半小时后重试"}
  97. WxMenusCreatedFailed = []string{"wxMenusCreatedFailed", "微信菜单创建失败"}
  98. //小程序相关
  99. XcxGetSessionKeyError = []string{"xcxGetSessionKeyError", "获取session key失败"}
  100. RailAdminIPReduced = []string{"railsAdminIPReduced", "拒绝此IP访问,权限不够"}
  101. TelCodesError = []string{"telCodeError", "验证码错误"}
  102. TelCodesTypeError = []string{"telCodesTypeError", "验证码类型错误"}
  103. PasswordError = []string{"passwordError", "密码错误"}
  104. LoginPwdSameWithTradePwdError = []string{"loginPwdSameWithTradePwdError", "登录密码与交易密码不能相同,请重新设置"}
  105. OrginalPasswordError = []string{"orginalPasswordError", "原始密码错误"}
  106. TelCodesExpired = []string{"telCodeExpired", "验证码已过期"}
  107. LoginPasswordError = []string{"loginPasswordError", "登录密码错误"}
  108. TradePasswordError = []string{"tradePasswordError", "交易密码错误"}
  109. TradePasswordEmptry = []string{"tradePasswordEmpty", "未设置交易密码"}
  110. UpdatePasswordError = []string{"updatePasswordError", "更新密码出错"}
  111. PasswordLengthError = []string{"passwordLengthError", "密码长度错误,需要6-20位"}
  112. GetCaptchaError = []string{"getCaptchaError", "获取图片验证码错误"}
  113. BindingBankCardEmpty = []string{"bindingBankCardEmpty", "绑定银行卡错误,请完善银行卡信息"}
  114. BindingWxUserError = []string{"bindingWxUserError", "绑定微信错误,请重试"}
  115. BindingUserTelError = []string{"bindingUserTelError", "绑定电话错误,请重试"}
  116. BindingIdCardEmpty = []string{"bindingIdCardEmpty", "绑定身份证错误,请填写真实姓名及身份证号"}
  117. UserHasBindIdCard = []string{"userHasBindIdCard", "该用户已绑定了身份证,请联系客服更改"}
  118. BindingIdCardExist = []string{"bindingIdCardExist", "该身份证已被绑定,请更换其他身份证"}
  119. BindingIdCardLengthError = []string{"bindingIdCardLengthError", "身份证位数不合法"}
  120. BindingTelExisted = []string{"bindingTelExisted", "该号码已绑定了微信用户,请尝试其他号码"}
  121. WxUserHasBindingTel = []string{"wxUserHasBindingTel", "该微信用户已经绑定了手机,请勿重复绑定"}
  122. WxUserHasBindingTelOnD5c = []string{"wxUserHasBindingTelOnD5c", "本次课程仅限新用户参加,老用户可联系专属客服领取资料包~"}
  123. WxUserNotRegistD5c = []string{"wxUserNotRegistD5c", "用户在第五创没有绑定手机号码"}
  124. IdCardAgeNotBeAdult = []string{"idCardAgeNotBeAdult", "未满18岁,身份认证失败"}
  125. // 工具tool相关
  126. DownloadError = []string{"downloadError", "阿里云下载文件错误"}
  127. ConvertToBase64Error = []string{"convertToBase64Error", "转base64错误"}
  128. //资金账户相关
  129. BalanceNotExist = []string{"balanceNotExist", "资金明细不存在"}
  130. BalanceNotEnough = []string{"balanceNotEnough", "余额不足"}
  131. BalanceNotEnoughForCharge = []string{"balanceNotEnoughForCharge", "可提现余额不足支付手续费,无法提现"}
  132. TakeCashAmountLessThanCharge = []string{"balanceAmountLessThanCharge", "提现金额需大于手续费金额"}
  133. TakeCashAmountInvalid = []string{"takeCashAmountInvalid", "提现金额不合法,仅支持小数点后两位。如:88.88"}
  134. RechargeAmountInvalid = []string{"RechargeAmountInvalid", "充值金额不合法,仅支持小数点后两位。如:88.88"}
  135. BankCardNotFound = []string{"bankCardNotFound", "请先绑定银行卡"}
  136. BankCardNoInvalid = []string{"bankCardNoInvalid", "银行卡号不合法,请重新输入"}
  137. BankCardNotMatch = []string{"bankCardNotMatch", "银行卡号不匹配,请使用实名认证的本人银行卡绑定,如认证信息有误,请联系客服更改"}
  138. BankCardHasNoRecordOnLianLianPay = []string{"bankCardHasNoRecordOnLianLianPay", "该银行卡在连连支付无记录,请先充值"}
  139. BankCardCountLimit = []string{"bankCardCountLimit", "银行卡绑定数量限制"}
  140. CanNotDeleteDefaultBankCard = []string{"canNotDeleteDefaultBankCard", "不能删除默认银行卡"}
  141. BankCardHasBound = []string{"bankCardHasBound", "该银行卡已有绑定记录"}
  142. //春节红包
  143. ActivityNotStart = []string{"activityNotStart", "活动尚未开始"}
  144. ActivityIsEnd = []string{"activityIsEnd", "活动已经结束"}
  145. HasGotLuckyMoney = []string{"hasGotLuckyMoney", "你已经拿过红包了"}
  146. //商家
  147. OrderNotBelongToCurrentUser = []string{"orderNotBelongToCurrentUser", "订单不属于当前用户。"}
  148. OrderStatusNotSuit = []string{"orderStatusNotSuit", "只能处理待发货、待收货的订单"}
  149. OrderAlreadyDispatch = []string{"orderAlreadyDispatch", "该订单已经被处理发货"}
  150. OrderAlreadyRefund = []string{"orderAlreadyRefund", "该订单已经被处理退款"}
  151. OrderRefundFaild = []string{"orderRefundFaild", "退款失败,请联系客服"}
  152. CurrentMerIsNotSuperAdminMerchant = []string{"currentMerIsNotSuperAdminMerchant", "当前用户不是商家超级管理员"}
  153. CurrentMerIsNotManageTheProduct = []string{"currentMerIsNotManageTheProduct", "当前用户不负责管理该商品"}
  154. //移动讯兑
  155. DataUnMarsha1Error = []string{"dataUnMarsha1Error", "数据解析错误"}
  156. //项目
  157. ProjectNoExist = []string{"projectNoExist", "项目不存在"}
  158. ProjectInvestWayNoExist = []string{"projectInvestWayNoExist", "该资助方式不存在"}
  159. //微信公众号登录
  160. NetworkBusy = []string{"networkBusy", "对不起,网络繁忙,请稍后再试"}
  161. //秒杀活动
  162. SeckillNotStart = []string{"seckillNotStart", "秒杀活动尚未开始"}
  163. SeckillIsEnd = []string{"seckillIsEnd", "秒杀活动已经结束"}
  164. SeckillNotAllow = []string{"seckillNotAllow", "秒杀商品不允许加入购物车"}
  165. OnlyNew = []string{"onlyNew", "仅限新人购买"}
  166. )
  167. type BaseController struct {
  168. beego.Controller
  169. OnlyCheckUserLoginAction []string
  170. ExceptCheckUserLoginAction []string
  171. OnlyCheckWxUserLoginAction []string
  172. ExceptCheckWxUserLoginAction []string
  173. UserNeedLoginAction []string
  174. }
  175. type Result struct {
  176. Status int `json:"status"`
  177. Result []interface{} `json:"result"`
  178. }
  179. //定义正确结果集
  180. func (self *BaseController) FormatResult(result []interface{}) *Result {
  181. return &Result{
  182. Status: 200,
  183. Result: result,
  184. }
  185. }
  186. func (self *BaseController) GetCurrentUserId() int64 {
  187. uId, _ := self.GetSession(SessionUserKey).(int64)
  188. return uId
  189. }
  190. func (self *BaseController) GetCurrentUser(useCache bool) *user_model.User {
  191. id := self.GetCurrentUserId()
  192. if id <= 0 {
  193. return nil
  194. }
  195. u := user_model.GetUserById(id, useCache)
  196. if u == nil {
  197. beego.BeeLogger.Error("User Not Found, uid=%d", id)
  198. }
  199. return u
  200. }
  201. func (self *BaseController) GetCurrentWxUserId() int64 {
  202. id, _ := self.GetSession(SessionWxUserKey).(int64)
  203. return id
  204. }
  205. func (self *BaseController) GetCurrentWxUser(useCache bool) *user_model.WxUser {
  206. id := self.GetCurrentWxUserId()
  207. if id <= 0 {
  208. return nil
  209. }
  210. u := user_model.GetWxUserById(id, useCache)
  211. if u == nil {
  212. beego.BeeLogger.Error("WxUser Not Found, id=%d", id)
  213. }
  214. return u
  215. }
  216. // //检查是否是邀请注册,绑定上下级关系, 发送微信通知。使用范围:注册、绑定手机、拉新专题
  217. // func (self *BaseController) CheckInviteBinding(user *user_model.User) {
  218. // if user == nil {
  219. // return
  220. // }
  221. // //邀请注册,绑定关系
  222. // inviteKey := beego.AppConfig.String("InviteName")
  223. // inviterId := self.Ctx.GetCookie(inviteKey)
  224. // if inviterId != "" {
  225. // id, err := strconv.ParseInt(inviterId, 10, 64)
  226. // if err == nil {
  227. // inviter := user_model.GetUserById(id, true)
  228. // if inviter != nil && user.InviteId == 0 {
  229. // //绑定关系
  230. // user.InviteId = id
  231. // go user.Save()
  232. // //增加邀请收益统计记录, 记录注册用户的ip
  233. // ip := self.Ctx.Input.IP()
  234. // new(user_model.UserInviteBenefitStat).Create(user.Id, user.InviteId,
  235. // 1, 0, time.Now(), ip)
  236. // //给邀请人发邀请成功的通知
  237. // WxInviter := user_model.GetWxUserByUserId(inviter.Id, true)
  238. // if WxInviter != nil {
  239. // //给邀请人发注册成功通知
  240. // openId := WxInviter.MpOpenid
  241. // url := fmt.Sprintf("%s/v1/cfc/36", beego.AppConfig.String("ApiHost"))
  242. // title := "有人通过您的邀请,并成功注册\n"
  243. // telwStar := tool.ReplaceTelMid4(inviter.Tel)
  244. // nickName, account := telwStar, telwStar
  245. // if user.Nickname != "" {
  246. // nickName = user.Nickname
  247. // }
  248. // cTime := inviter.CreatedAt.Format("2006-01-02 15:04:05")
  249. // remark := "\n点击详情,可以看一看TA"
  250. // wx_mp.TmplmsgInviteSignUp(openId, url, title, nickName, account, cTime, remark)
  251. // }
  252. // //给新人发红包,并发通知
  253. // c := int64(user_model.BenefitNewUser)
  254. // s := balance_model.BALANCE_SOURCE_SIGN_UP_ONLINE
  255. // remark := balance_model.BALANCE_SOURCE_SIGN_UP_ONLINE_NAME
  256. // rId := ""
  257. // balance := new(balance_model.Balance).Create(user.Id, c, s, rId, remark, 1)
  258. // if balance != nil {
  259. // wxUser := user_model.GetWxUserByUserId(user.Id, true)
  260. // //发送红包的通知
  261. // if wxUser != nil {
  262. // openId := wxUser.MpOpenid
  263. // url := fmt.Sprintf("%s/v1/cfc/37", beego.AppConfig.String("ApiHost"))
  264. // first := "注册成功,返现金额已到账\n"
  265. // count := fmt.Sprintf("%0.2f 元", float64(c)/100.0)
  266. // //新用户,余额是0
  267. // leftAmount := c //balance_model.GetUserTotalBalance(user.Id)
  268. // balance := fmt.Sprintf("%0.2f 元", float64(leftAmount)/100.0)
  269. // ctime := time.Now().Format("2006-01-02 15:04:05")
  270. // remark := "\n点击立即提现>"
  271. // wx_mp.TmplmsgBalanceChange(openId, url, first, ctime, count, balance, remark)
  272. // }
  273. // }
  274. // }
  275. // }
  276. // }
  277. // }
  278. //检验是否需要关注
  279. //sceneId, 关注场景id
  280. func (self *BaseController) CheckWxUserSubscribe(sceneId int64) {
  281. beego.BeeLogger.Info("check wx_user subscribe")
  282. ctx := self.Ctx
  283. if !isWxClient(ctx) {
  284. return
  285. }
  286. wxUserId, ok := ctx.Input.Session(SessionWxUserKey).(int64)
  287. if ok {
  288. wxUser := user_model.GetWxUserById(wxUserId, false)
  289. if wxUser == nil {
  290. beego.BeeLogger.Error("WxUser Not Found, id=%d", wxUserId)
  291. } else {
  292. if wxUser.Subscribe == 0 {
  293. qrcode := channel_gzh_qrcode_model.GetBySceneId(sceneId, true)
  294. if qrcode == nil {
  295. //默认二维码
  296. qrcode = channel_gzh_qrcode_model.GetBySceneId(25, true)
  297. }
  298. qrcodeUrl := qrcode.QrcodeImg
  299. errCode := &ErrCode{
  300. Code: WxUserNeedSubscribe[0],
  301. Msg: WxUserNeedSubscribe[1],
  302. Redirect: qrcodeUrl,
  303. Data: nil,
  304. }
  305. ctx.Output.SetStatus(403)
  306. ctx.Output.JSON(errCode, true, true)
  307. self.StopRun()
  308. }
  309. }
  310. } else {
  311. beego.BeeLogger.Error("WxUser Not Login")
  312. }
  313. }
  314. func checkWxUserLogin(ctx *context.Context) {
  315. // TODO : 整个项目也应该更加适合采用 token 机制
  316. beego.BeeLogger.Info("check wx_user login")
  317. if !isWxClient(ctx) {
  318. return
  319. }
  320. wxUserId, ok := ctx.Input.Session(SessionWxUserKey).(int64)
  321. if ok {
  322. _, ok := ctx.Input.Session(SessionUserKey).(int64)
  323. if !ok {
  324. // 如果微信用户登录了,且有绑定了user,则设置用户登录
  325. wxUser := user_model.GetWxUserById(wxUserId, true)
  326. beego.BeeLogger.Warn("wx_user has login, ", wxUser)
  327. if wxUser != nil && int(wxUser.UserId) > 0 {
  328. ctx.Output.Session(SessionUserKey, wxUser.UserId)
  329. }
  330. }
  331. } else {
  332. // beego.BeeLogger.Warn("---------------%v", ctx.Input.IsAjax())
  333. // beego.BeeLogger.Warn("---------------%s", ctx.Input)
  334. // if ctx.Input.IsAjax() {
  335. beego.BeeLogger.Info("show the request : %s from UserAgent: %s", ctx.Input.URI(), ctx.Input.UserAgent())
  336. uri := ctx.Input.URI()
  337. //外链进来需要自动登录
  338. if strings.Contains(uri, "/v1/cfc/") && isWxClient(ctx) {
  339. // 微信用户自动登录
  340. url := fmt.Sprintf("%s/login/mp?cb=%s%s",
  341. beego.AppConfig.String("ApiHost"),
  342. ctx.Input.Site(), ctx.Input.URI())
  343. ctx.Redirect(302, url)
  344. return
  345. } else {
  346. errCode := &ErrCode{
  347. Code: UserNeedLogin[0],
  348. Msg: UserNeedLogin[1],
  349. Redirect: "",
  350. Data: nil,
  351. }
  352. ctx.Output.SetStatus(401)
  353. ctx.Output.JSON(errCode, true, true)
  354. return
  355. }
  356. // } else {
  357. // // FIXME : 这里 IsAjax 判断是否有问题? 微信来的应该属于api请求
  358. // beego.BeeLogger.Debug("WEIXIN user not login", ctx.Input)
  359. // errCode := &ErrCode{
  360. // Code: UserNeedLogin[0], // FIXME : 这里应该 是 WxUserNeedLogin, 因为前端编码用了UserNeedLogin,以后一起修改
  361. // Msg: UserNeedLogin[1],
  362. // Redirect: "",
  363. // Data: nil,
  364. // }
  365. // ctx.Output.SetStatus(401)
  366. // ctx.Output.JSON(errCode, true, true)
  367. // return
  368. // beego.BeeLogger.Warn("this is not a ajax request!")
  369. // 微信用户自动登录
  370. // if isWxClient(ctx) {
  371. // // beego.BeeLogger.Warn("---------------%s", ctx.Input.Site())
  372. // url := fmt.Sprintf("%s/login/mp?cb=%s%s",
  373. // beego.AppConfig.String("ApiHost"),
  374. // ctx.Input.Site(), ctx.Input.URI())
  375. // // beego.BeeLogger.Warn("auto login mp cb url=%s", url)
  376. // ctx.Redirect(302, url)
  377. // return
  378. // }
  379. // }
  380. }
  381. }
  382. func checkUserLogin(ctx *context.Context) {
  383. beego.BeeLogger.Info("check user login")
  384. userId, ok := ctx.Input.Session(SessionUserKey).(int64)
  385. if ok {
  386. _, ok := ctx.Input.Session(SessionWxUserKey).(int64)
  387. if !ok {
  388. beego.BeeLogger.Info("user has login, try to set seesion[wx_user]")
  389. // 如果用户登录了,且有绑定了wx_user,则设置微信用户登录
  390. wxUser := user_model.GetWxUserByUserId(userId, true)
  391. if wxUser != nil {
  392. ctx.Output.Session(SessionWxUserKey, wxUser.Id)
  393. }
  394. }
  395. } else {
  396. _, ok := ctx.Input.Session(SessionWxUserKey).(int64)
  397. if ok {
  398. beego.BeeLogger.Info("user not login, wx_user is login,and try to ask user binding tel.")
  399. // 如果用户没登录了,但采用微信账户登录,则需要微信用户绑定手机从而创建用户记录
  400. errCode := &ErrCode{
  401. Code: UserNeedTel[0],
  402. Msg: UserNeedTel[1],
  403. Redirect: fmt.Sprintf("%s/user/binding/state", beego.AppConfig.String("WWWHost")),
  404. Data: nil,
  405. }
  406. ctx.Output.SetStatus(401)
  407. ctx.Output.JSON(errCode, true, true)
  408. return
  409. }
  410. errCode := &ErrCode{
  411. Code: UserNeedLogin[0],
  412. Msg: UserNeedLogin[1],
  413. Redirect: "",
  414. Data: nil,
  415. }
  416. ctx.Output.SetStatus(401)
  417. ctx.Output.JSON(errCode, true, true)
  418. return
  419. }
  420. }
  421. //检查来自大后台的请求是否为服务器IP
  422. func CheckIsInvokeFromRailsAdmin(ctx *context.Context) {
  423. s := strings.Split(ctx.Request.RemoteAddr, ":")
  424. ip := s[0]
  425. beego.BeeLogger.Debug("railsadmin request ip is: %s", ip)
  426. if ip != beego.AppConfig.String("RailsAdminAddr") {
  427. errCode := &ErrCode{
  428. Code: RailAdminIPReduced[0],
  429. Msg: RailAdminIPReduced[1],
  430. Redirect: "",
  431. Data: nil,
  432. }
  433. ctx.Output.SetStatus(403)
  434. ctx.Output.JSON(errCode, true, true)
  435. }
  436. }
  437. func (self *BaseController) Prepare() {
  438. beego.BeeLogger.Info("invote controller Prepare func")
  439. needChkWxUserLogin := true
  440. needChkUserLogin := true
  441. // needChkWxUserSubscribe := false
  442. _, actionName := self.GetControllerAndAction()
  443. if len(self.ExceptCheckWxUserLoginAction) > 0 {
  444. for _, an := range self.ExceptCheckWxUserLoginAction {
  445. if strings.ToLower(an) == "*" || strings.ToLower(an) == strings.ToLower(actionName) {
  446. needChkWxUserLogin = false
  447. break
  448. }
  449. }
  450. }
  451. if len(self.ExceptCheckUserLoginAction) > 0 {
  452. for _, an := range self.ExceptCheckUserLoginAction {
  453. if strings.ToLower(an) == "*" || strings.ToLower(an) == strings.ToLower(actionName) {
  454. needChkUserLogin = false
  455. break
  456. }
  457. }
  458. }
  459. if needChkWxUserLogin {
  460. checkWxUserLogin(self.Ctx)
  461. }
  462. if needChkUserLogin {
  463. checkUserLogin(self.Ctx)
  464. }
  465. }
  466. type ErrCode struct {
  467. Status int `json:"status"`
  468. Code string `json:"err_code"`
  469. Msg string `json:"err_msg"`
  470. Redirect string `json:"redirect_to"`
  471. Data map[string]string `json:"data"`
  472. }
  473. //定义返回错误信息
  474. func (self *BaseController) ReturnError(status int, code []string, redirect string, data map[string]string) {
  475. errCode := &ErrCode{
  476. Status: status,
  477. Code: code[0],
  478. Msg: code[1],
  479. Redirect: redirect,
  480. Data: data,
  481. }
  482. // jsonErrCode, err := json.Marshal(errCode)
  483. // if err != nil {
  484. // beego.BeeLogger.Error("json encode error=[%s]", err)
  485. // }
  486. self.Ctx.Output.SetStatus(status)
  487. // self.Ctx.Output.Header("Content-Type", "application/json; charset=utf-8")
  488. self.Ctx.Output.JSON(errCode, true, true)
  489. self.StopRun()
  490. // self.ServeJson(status, string(jsonErrCode))
  491. }
  492. //TODO校验是否微信客户端
  493. func (self *BaseController) IsWxClient() bool {
  494. return isWxClient(self.Ctx)
  495. }
  496. //TODO校验是否微信客户端
  497. func isWxClient(ctx *context.Context) bool {
  498. agent := ctx.Input.UserAgent()
  499. b := getRealBrowser(agent)
  500. isWxClient := b == "wx"
  501. return isWxClient
  502. }
  503. // 是否是手机端
  504. func (self *BaseController) IsMobile() bool {
  505. ua := strings.ToLower(self.Ctx.Input.UserAgent())
  506. if ua == "" {
  507. return true
  508. }
  509. ok, _ := regexp.MatchString("iphone|nokia|sony|ericsson|mot|samsung|sgh|lg|philips|panasonic|alcatel|lenovo|cldc|midp|wap|mobile", ua)
  510. return ok
  511. }
  512. // 是否是开发模式
  513. func (self *BaseController) IsDev() bool {
  514. //return beego.BConfig.RunMode == beego.DEV
  515. return beego.AppConfig.String("Env") != "production"
  516. }
  517. func getRealBrowser(ua string) string {
  518. userAgent := user_agent.New(ua)
  519. browser, _ := userAgent.Browser()
  520. browser = strings.ToLower(browser)
  521. if browser == "internet explorer" {
  522. browser = "ie"
  523. }
  524. lowerUa := strings.ToLower(ua)
  525. // beego.BeeLogger.Warning("ua=%s", lowerUa)
  526. if strings.Contains(lowerUa, "micromessenger") {
  527. browser = "wx"
  528. }
  529. if strings.Contains(lowerUa, "wechatdevtools") {
  530. browser = "wx"
  531. }
  532. return browser
  533. }
  534. func (self *BaseController) GetFullImgUrl(img string) string {
  535. if img == "" {
  536. return ""
  537. }
  538. if strings.HasPrefix(img, "http://") || strings.HasPrefix(img, "https://") {
  539. return img
  540. } else {
  541. return fmt.Sprintf("%s/%s", beego.AppConfig.String("AliCDNImgHost"), img)
  542. }
  543. }
  544. func (self *BaseController) GetCdnFullImgUrl(img string) string {
  545. if img == "" {
  546. return ""
  547. }
  548. if strings.HasPrefix(img, "http://") || strings.HasPrefix(img, "https://") {
  549. return img
  550. } else {
  551. return fmt.Sprintf("%s/%s", beego.AppConfig.String("AliCDNImgHost"), img)
  552. }
  553. }