init.go 22 KB

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