新增日志

controllers/base_auth.go

@@ -23,6 +23,7 @@ func init() {
 type BaseAuthController struct {
 	beego.Controller
 	User *models.WxUserItem
+	Token string
 }
 
 func (this *BaseAuthController) Prepare() {
@@ -38,6 +39,7 @@ func (this *BaseAuthController) Prepare() {
 				utils.FileLog.Info("authorization:%s,cookie:%s", authorization, cookie)
 				authorization = cookie
 			}
+			this.Token=authorization
 			if authorization == "" {
 				this.JSON(models.BaseResponse{Ret: 408, Msg: "请重新授权！", ErrMsg: "请重新授权:Token is empty or account is empty"}, false, false)
 				this.StopRun()

controllers/report.go

@@ -6,6 +6,7 @@ import (
 	"hongze/hongze_api/services"
 	"hongze/hongze_api/utils"
 	"html"
+	"strconv"
 	"strings"
 	"time"
 )
@@ -76,7 +77,7 @@ func (this *ReportController) Detail() {
 		productId = 1
 		maxPermissionCount = 15
 	}
-	utils.FileLog.Info("report.detail %d,%d",user.CompanyId,productId)
+	utils.FileLog.Info("report.detail %d,%d", user.CompanyId, productId)
 	company, err := models.GetCompanyProductById(user.CompanyId, productId)
 	if err != nil {
 		if err.Error() != utils.ErrNoRow() {
@@ -241,6 +242,18 @@ func (this *ReportController) Detail() {
 		br.ErrMsg = "获取详情专栏失败,Err:" + err.Error()
 		return
 	}
+
+	//新增访问日志
+	{
+		record := new(models.UserAccessRecord)
+		record.Uid = user.UserId
+		record.Token = this.Token
+		record.CreateTime = time.Now()
+		record.Remark = strconv.Itoa(status)
+		record.ReportId = reportId
+		go models.AddUserAccessRecord(record)
+	}
+
 	resp.Classify = item
 	br.Ret = 200
 	br.Success = true

controllers/user.go

@@ -52,6 +52,14 @@ func (this *UserController) Detail() {
 	if item.Mobile == "" && item.Email == "" {
 		item.FirstLogin = 1
 	}
+	//新增访问日志
+	{
+		record:=new(models.UserAccessRecord)
+		record.Uid=user.UserId
+		record.Token=this.Token
+		record.CreateTime=time.Now()
+		go models.AddUserAccessRecord(record)
+	}
 	item.UserPermission = userPermission
 	br.Ret = 200
 	br.Success = true
@@ -355,6 +363,20 @@ func (this *UserController) Login() {
 		br.ErrMsg = "登录失败，判断权限失败:" + err.Error()
 		return
 	}
+
+	//新增登录日志
+	{
+		loginLog := new(models.WxUserLog)
+		loginLog.UserId = userId
+		loginLog.OpenId = openId
+		loginLog.Mobile=req.Mobile
+		loginLog.Email=req.Email
+		loginLog.CreateTime = time.Now()
+		loginLog.Handle="wechat_user_login"
+		loginLog.Remark=token
+		go models.AddWxUserLog(loginLog)
+	}
+
 	resp := new(models.LoginResp)
 	resp.UserId = newUserId
 	resp.UserPermission = userPermission
@@ -457,4 +479,4 @@ func (this *UserController) SmallLimit() {
 	br.Ret = 200
 	br.Success = true
 	br.Data = resp
-}
+}

controllers/user_pc.go

@@ -375,6 +375,18 @@ func (this *UserCommonController) PcLogin() {
 			productName = v.ProductName
 		}
 	}
+
+	//新增登录日志
+	{
+		loginLog := new(models.WxUserLog)
+		loginLog.UserId = userId
+		loginLog.Mobile=req.Mobile
+		loginLog.Email=req.Email
+		loginLog.Handle="pc_login"
+		loginLog.CreateTime = time.Now()
+		go models.AddWxUserLog(loginLog)
+	}
+
 	newUser, _ := models.GetWxUserItemByUserId(userId)
 	resp := new(models.LoginResp)
 	resp.UserId = newUser.UserId
@@ -569,6 +581,20 @@ func (this *UserController) PcBind() {
 		return
 	}
 
+	//新增登录日志
+	{
+		loginLog := new(models.WxUserLog)
+		loginLog.UnionId=unionId
+		loginLog.UserId = userId
+		loginLog.Mobile=req.Mobile
+		loginLog.Email=req.Email
+		loginLog.UnionId=unionId
+		loginLog.Handle="pc_bind"
+		loginLog.Remark=strconv.Itoa(newUserId)
+		loginLog.CreateTime = time.Now()
+		go models.AddWxUserLog(loginLog)
+	}
+
 	resp := new(models.LoginResp)
 	resp.UserId = newUserId
 	resp.UserPermission = userPermission

controllers/wechat.go

@@ -164,6 +164,17 @@ func (this *WechatCommonController) WechatLogin() {
 			firstLogin = 1
 		}
 	}
+	//新增登录日志
+	{
+		loginLog := new(models.WxUserLog)
+		loginLog.UserId = userId
+		loginLog.OpenId = openId
+		loginLog.UnionId = unionid
+		loginLog.CreateTime = time.Now()
+		loginLog.Handle="wechat_login"
+		loginLog.Remark=token
+		go models.AddWxUserLog(loginLog)
+	}
 	resp := new(models.WxLoginResp)
 	resp.UserId = userId
 	resp.Code = 0

controllers/wechat_pc.go

@@ -220,6 +220,17 @@ func (this *WechatCommonController) PcWechatLogin() {
 		}
 	}
 
+	//新增登录日志
+	{
+		loginLog := new(models.WxUserLog)
+		loginLog.UserId = userId
+		loginLog.OpenId = openId
+		loginLog.CreateTime = time.Now()
+		loginLog.Handle="wechat_pc_login"
+		loginLog.Remark=token
+		go models.AddWxUserLog(loginLog)
+	}
+
 	resp := new(models.WxLoginResp)
 	resp.UserId = userId
 	resp.Code = 0

models/db.go

@@ -42,5 +42,7 @@ func init() {
 		new(MsgCode),
 		new(GraphicVerifyCode),
 		new(AnnualReport),
+		new(WxUserLog),
+		new(UserAccessRecord),
 	)
 }

models/user_access_record.go

@@ -0,0 +1,22 @@
+package models
+
+import (
+	"rdluck_tools/orm"
+	"time"
+)
+
+type UserAccessRecord struct {
+	Id         int `orm:"column(id);pk"`
+	Uid        int
+	Token      string
+	ReportId   int
+	CreateTime time.Time
+	Remark string
+}
+
+//添加联系人日志信息
+func AddUserAccessRecord(item *UserAccessRecord) (lastId int64, err error) {
+	o := orm.NewOrm()
+	lastId, err = o.Insert(item)
+	return
+}

models/wx_user_log.go

@@ -0,0 +1,25 @@
+package models
+
+import (
+	"rdluck_tools/orm"
+	"time"
+)
+
+type WxUserLog struct {
+	Id         int `orm:"column(id);pk"`
+	UserId     int
+	OpenId     string
+	UnionId    string
+	Mobile     string
+	Email      string
+	Handle     string
+	Remark     string
+	CreateTime time.Time
+}
+
+//添加联系人日志信息
+func AddWxUserLog(item *WxUserLog) (lastId int64, err error) {
+	o := orm.NewOrm()
+	lastId, err = o.Insert(item)
+	return
+}