停留时长 类型

api/personnel/v1/personnel.go

@@ -39,5 +39,5 @@ type Statistics struct {
 	AppId           string                 `json:"appId"  dc:"appid"`
 	AppVersion      string                 `json:"appVersion"  dc:"版本号"`
 	MiniProgramCode string                 `json:"miniProgramCode"  dc:"来源"`
-	Duration        int64                  `json:"duration"  dc:"页面停留时长 秒"`
+	Duration        float64                `json:"duration"  dc:"页面停留时长 秒"`
 }

internal/controller/personnel/personnel.go

@@ -54,7 +54,7 @@ func (p *personnel) Statistics(ctx context.Context, req *v1.PersonnelInsertReq)
 	}
 	//匿名用户id
 	in.JYTrustedId = utils.GetTrustedId(g.RequestFromCtx(ctx))
-	in.Date = time.Now().Unix()
+	in.Date = time.Now()
 	//浏览器信息
 	r := g.RequestFromCtx(ctx).Request
 	in.Ip = common.GetIp(r)
@@ -150,7 +150,7 @@ func (p *personnel) Behaviors(ctx context.Context, req *v1.PersonnelBehaviorReq)
 		}
 		//匿名用户id
 		in.JYTrustedId = utils.GetTrustedId(g.RequestFromCtx(ctx))
-		in.Date = time.Now().Unix()
+		in.Date = time.Now()
 		//浏览器信息
 		r := g.RequestFromCtx(ctx).Request
 		in.Ip = common.GetIp(r)

internal/dao/internal/personnel.go

@@ -73,12 +73,12 @@ func (dao *PersonnelDao) BatchExecInsert(ctx context.Context, in []*model.Person
 		return
 	}
 	var (
-		timeNow    = time.Now()
 		insertData []g.Map
 	)
 	for _, i := range in {
 		var (
-			clickTime = timeNow
+			timeNow   = time.Now()
+			clickTime = i.Date
 			orderTIme time.Time
 			payTime   time.Time
 		)

internal/model/personnel.go

@@ -1,5 +1,7 @@
 package model
 
+import "time"
+
 type PersonnelInsertInput struct {
 	ActionId        string
 	ActionType      string
@@ -21,23 +23,23 @@ type PersonnelInsertInput struct {
 	PositionId      int64
 	Phone           string
 	Ip              string
-	Platform        string //平台
-	Os              string //系统
-	OsVersion       string //系统版本
-	Browser         string //浏览器
-	BrowserVersion  string //浏览器版本
-	Date            int64  //访问时间
-	Url             string //页面url
-	UserAgent       string //header 信息
-	JYTrustedId     string //匿名用户id
-	ChainName       string //库信息
-	Port            string //行为端口
-	Refer           string //跳转前页面
-	SearchWord      string //搜索词
-	Filter          string //搜索条件
-	BreakData       string //"额外数据
-	AppId           string // appid"
-	AppVersion      string // 版本号
-	MiniProgramCode string // "来源"`
-	Duration        int64  //页面停留时长 秒
+	Platform        string    //平台
+	Os              string    //系统
+	OsVersion       string    //系统版本
+	Browser         string    //浏览器
+	BrowserVersion  string    //浏览器版本
+	Date            time.Time //访问时间
+	Url             string    //页面url
+	UserAgent       string    //header 信息
+	JYTrustedId     string    //匿名用户id
+	ChainName       string    //库信息
+	Port            string    //行为端口
+	Refer           string    //跳转前页面
+	SearchWord      string    //搜索词
+	Filter          string    //搜索条件
+	BreakData       string    //"额外数据
+	AppId           string    // appid"
+	AppVersion      string    // 版本号
+	MiniProgramCode string    // "来源"`
+	Duration        float64   //页面停留时长 秒
 }

manifest/config/config.yaml

@@ -37,7 +37,7 @@ authcode: "jy_personnel_abc"
 cacheChanInfo:
   name: "人员行为记录"
   dataSize: 10000   #数据缓存通道大小
-  bulkSize: 500     #批次- 每批的数量
+  bulkSize: 2     #批次- 每批的数量
   timeAfter: 2000   # 定时保存 毫秒
   timeout: 10000    # 缓存通道满时，超时丢弃
   sCSize: 3         # 数据库并发存储数据