wip:停留时长

api/personnel/v1/personnel.go

@@ -39,4 +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:"页面停留时长 秒"`
 }

internal/controller/personnel/personnel.go

@@ -98,6 +98,7 @@ func (p *personnel) Statistics(ctx context.Context, req *v1.PersonnelInsertReq)
 	in.MiniProgramCode = g.RequestFromCtx(ctx).GetHeader("miniProgramCode")
 	in.SearchWord = req.SearchWord // 搜索词
 	in.Filter = req.Filter         // 搜索条件
+	in.Duration = req.Duration
 	err = service.Personnel().BatchInsertRecords(ctx, &in)
 	if err != nil {
 		res.Msg = err.Error()
@@ -193,6 +194,7 @@ func (p *personnel) Behaviors(ctx context.Context, req *v1.PersonnelBehaviorReq)
 		in.MiniProgramCode = g.RequestFromCtx(ctx).GetHeader("miniProgramCode")
 		in.SearchWord = b.SearchWord // 搜索词
 		in.Filter = b.Filter         // 搜索条件
+		in.Duration = b.Duration
 		err = service.Personnel().BatchInsertRecords(ctx, &in)
 		if err != nil {
 			res.Msg = err.Error()

internal/dao/internal/personnel.go

@@ -127,6 +127,7 @@ func (dao *PersonnelDao) BatchExecInsert(ctx context.Context, in []*model.Person
 			"break_data":        i.BreakData,
 			"app_version":       i.AppVersion,
 			"mini_program_code": i.MiniProgramCode,
+			"duration":          i.Duration,
 		})
 	}
 	_, err = g.DB().Model(dao.Model()).Data(insertData).Insert()

internal/model/personnel.go

@@ -39,4 +39,5 @@ type PersonnelInsertInput struct {
 	AppId           string // appid"
 	AppVersion      string // 版本号
 	MiniProgramCode string // "来源"`
+	Duration        int64  //页面停留时长 秒
 }