智慧交流-时段统计

app/operation/controller/captureController.go

@@ -179,3 +179,21 @@ func (c captureCtl) OverSpeedRecordSync(ctx *gin.Context) {
 	}()
 	ctx.JSON(http.StatusOK, common.SuccessResponse(common.Succeeded, nil))
 }
+
+// PeriodsList 时段统计
+func (c captureCtl) PeriodsList(ctx *gin.Context) {
+	value, _ := ctx.Get(middleware.Authorization)
+	claims := value.(*middleware.Claims)
+	var req model.RequestCaptureFilter
+	err := ctx.ShouldBindQuery(&req)
+	if err != nil {
+		ctx.JSON(http.StatusOK, err)
+		return
+	}
+	records, err := service.CapturePeriodsService.GetPeriodsList(claims.TenantId, req)
+	if err != nil {
+		ctx.JSON(http.StatusOK, err)
+		return
+	}
+	ctx.JSON(http.StatusOK, common.SuccessResponse(common.Succeeded, records))
+}

app/operation/edge_service/forCaptureItsService.go

@@ -77,6 +77,12 @@ func (f ForCaptureIts) VehicleOverSpeedTotal(reqPostData ForCaptureItsReq) ([]Fo
 	return f.pubPost(reqPostData, api)
 }
 
+// VehicleHourTotal 小时统计数据
+func (f ForCaptureIts) VehicleHourTotal(reqPostData ForCaptureItsReq) ([]ForCaptureItsData, error) {
+	api := "/data/v1/its/vehiclehourtotal"
+	return f.pubPost(reqPostData, api)
+}
+
 //公用 post请求
 func (f ForCaptureIts) pubPost(reqPostData ForCaptureItsReq, api string) ([]ForCaptureItsData, error) {
 	cfg := config.Instance()

app/operation/model/capturePeriods.go

@@ -0,0 +1,6 @@
+package model
+
+type ResponseCapturePeriods struct {
+	Hours  string `json:"hours"`  //时
+	CountT int    `json:"countT"` //总报警
+}

app/operation/service/capturePeriodsService.go

@@ -0,0 +1,56 @@
+package service
+
+import (
+	"iot_manager_service/app/device/dao"
+	"iot_manager_service/app/operation/edge_service"
+	"iot_manager_service/app/operation/model"
+	"strconv"
+)
+
+// CapturePeriodsService 时段统计
+var CapturePeriodsService = new(capturePeriodsService)
+
+type capturePeriodsService struct{}
+
+func (s capturePeriodsService) GetPeriodsList(tenantId int, req model.RequestCaptureFilter) (interface{}, error) {
+	unit := dao.CaptureUnit{
+		TenantId: tenantId,
+		ID:       req.CaptureId,
+	}
+	unit.GetDevice()
+	var codes []string
+	codes = append(codes, unit.CaptureSn)
+	forCaptureIts := edge_service.ForCaptureIts{}
+	forData, err := forCaptureIts.VehicleHourTotal(edge_service.ForCaptureItsReq{
+		Codes: codes,
+		Start: req.StartTime,
+		End:   req.EndTime,
+	})
+	if err != nil {
+		return nil, err
+	}
+	var hours []string
+	for i := 0; i < 24; i++ {
+		ii := strconv.Itoa(i)
+		if len(ii) < 2 {
+			ii = "0" + ii
+		}
+		hours = append(hours, ii)
+	}
+	datas := make(map[string]int)
+	for _, datum := range forData {
+		timeStr := datum.Time
+		hour := timeStr[11:13]
+		_, ok := datas[(hour)]
+		if ok {
+			datas[(hour)] += datum.Total
+		} else {
+			datas[(hour)] = 0
+		}
+	}
+	var list []model.ResponseCapturePeriods
+	for _, hour := range hours {
+		list = append(list, model.ResponseCapturePeriods{Hours: hour, CountT: datas[hour]})
+	}
+	return list, nil
+}

router/router.go

@@ -622,6 +622,8 @@ func InitRouter(engine *gin.Engine) {
 		captureGroup.GET("speed/list", operation.Capture.SpeedList)
 		captureGroup.GET("speed/over-speed-record", operation.Capture.OverSpeedRecord)
 		captureGroup.GET("speed/over-speed-record-sync", operation.Capture.OverSpeedRecordSync)
+		//时段统计
+		captureGroup.GET("periods/list", operation.Capture.PeriodsList)
 	}
 
 }