智慧交流-报表统计

app/operation/controller/captureController.go

@@ -198,6 +198,7 @@ func (c captureCtl) PeriodsList(ctx *gin.Context) {
 	ctx.JSON(http.StatusOK, common.SuccessResponse(common.Succeeded, records))
 }
 
+// CarrecordCount 货车统计
 func (c captureCtl) CarrecordCount(ctx *gin.Context) {
 	value, _ := ctx.Get(middleware.Authorization)
 	claims := value.(*middleware.Claims)
@@ -216,3 +217,23 @@ func (c captureCtl) CarrecordCount(ctx *gin.Context) {
 	}
 	ctx.JSON(http.StatusOK, common.SuccessResponse(common.Succeeded, records))
 }
+
+// ReportList 报表统计
+func (c captureCtl) ReportList(ctx *gin.Context) {
+	value, _ := ctx.Get(middleware.Authorization)
+	claims := value.(*middleware.Claims)
+	var req model.RequestCaptureReportFilter
+	err := ctx.ShouldBindQuery(&req)
+	if err != nil {
+		ctx.JSON(http.StatusOK, err)
+		return
+	}
+	var records interface{}
+	err = nil
+	records, err = service.CaptureReportService.GetList(claims.TenantId, req)
+	if err != nil {
+		ctx.JSON(http.StatusOK, err)
+		return
+	}
+	ctx.JSON(http.StatusOK, common.SuccessResponse(common.Succeeded, records))
+}

app/operation/model/captureReport.go

@@ -0,0 +1,23 @@
+package model
+
+type RequestCaptureReportFilter struct {
+	StartTime string `form:"startTime"`
+	EndTime   string `form:"endTime"`
+	CaptureId int    `form:"captureId"` //抓拍单元
+	QueryType int    `form:"queryType"` //1小时统计 2日统计 3月统计
+}
+
+type ResponseCaptureReport struct {
+	CountTime string `json:"time"`    //时间
+	Value1    int    `json:"value1"`  //小型货车
+	Value2    int    `json:"value2"`  //中型货车
+	Value3    int    `json:"value3"`  //大型货车
+	Value4    int    `json:"value4"`  //特大货车
+	Value5    int    `json:"value5"`  //箱式货车
+	Value6    int    `json:"value6"`  //轻型客车
+	Value7    int    `json:"value7"`  //大客车
+	Value8    int    `json:"value8"`  //汽车小计
+	Value9    int    `json:"value9"`  //摩托车
+	Value10   int    `json:"value10"` //拖拉机
+	AllTotal  int    `json:"value11"` //总计
+}

app/operation/service/captureReportService.go

@@ -0,0 +1,104 @@
+package service
+
+import (
+	"iot_manager_service/app/device/dao"
+	"iot_manager_service/app/operation/edge_service"
+	"iot_manager_service/app/operation/model"
+	"iot_manager_service/util/common"
+	"strconv"
+)
+
+// CaptureReportService 报表统计
+var CaptureReportService = new(captureReportService)
+
+type captureReportService struct{}
+
+func (s captureReportService) GetList(tenantId int, req model.RequestCaptureReportFilter) ([]model.ResponseCaptureReport, error) {
+	var list []model.ResponseCaptureReport
+	//按日期  或 时段把每个类型的汇总 展示 出来
+	flag, record, err := s.getData(tenantId, req)
+	nlist := make(map[string]int)
+	allTypes := []int{14, 26, 17, 10, 33, 25, 146, 8, 9}
+	qcTypes := []int{14, 26, 17, 10, 33, 25, 146}
+	allTotal := make(map[string]int)
+	value8Total := make(map[string]int)
+	for _, data := range record {
+		key := data.Time[:10]
+		if flag == 2 {
+			key = data.Time[11:13]
+		}
+		vtype := strconv.Itoa(data.Vtype)
+		nlist[key+vtype] += data.Total
+		if common.InIntArr(data.Vtype, qcTypes) {
+			value8Total[key] += data.Total
+		}
+		if common.InIntArr(data.Vtype, allTypes) {
+			allTotal[key] += data.Total
+		}
+	}
+	var countTimes []string
+	if flag == 0 {
+		//日
+		countTimes = common.GetTimeDays(req.StartTime, req.EndTime) //时间范围 天
+	} else if flag == 2 {
+		for i := 0; i < 24; i++ {
+			ii := strconv.Itoa(i)
+			if len(ii) < 2 {
+				ii = "0" + ii
+			}
+			countTimes = append(countTimes, ii)
+		}
+	}
+	//fmt.Printf("nlist = %v \n", nlist)
+	//fmt.Printf("countTimes = %v \n", countTimes)
+	//	types := []int{14, 26, 17, 10, 33, 25, 146, 8, 9}
+	for _, countTime := range countTimes {
+		list = append(list, model.ResponseCaptureReport{
+			CountTime: countTime,
+			Value1:    nlist[countTime+"14"],
+			Value2:    nlist[countTime+"26"],
+			Value3:    nlist[countTime+"17"],
+			Value4:    nlist[countTime+"10"],
+			Value5:    nlist[countTime+"33"],
+			Value6:    nlist[countTime+"25"],
+			Value7:    nlist[countTime+"146"],
+			Value8:    value8Total[countTime],
+			Value9:    nlist[countTime+"8"],
+			Value10:   nlist[countTime+"9"],
+			AllTotal:  allTotal[countTime],
+		})
+	}
+	return list, err
+}
+
+//得到边缘接口 时间范围数据
+func (s captureReportService) getData(tenantId int, req model.RequestCaptureReportFilter) (int, []edge_service.ForCaptureItsData, error) {
+	//区分按月或按日
+	flag := 1 //月
+	if req.QueryType == 1 {
+		flag = 2 //时
+	}
+	if req.QueryType == 2 {
+		flag = 0 //日
+	}
+
+	//查出抓拍单元sn
+	unit := dao.CaptureUnit{
+		TenantId: tenantId,
+		ID:       req.CaptureId,
+	}
+	unit.GetDevice()
+	var codes []string
+	codes = append(codes, unit.CaptureSn)
+
+	forCaptureIts := edge_service.ForCaptureIts{}
+	var forData []edge_service.ForCaptureItsData
+	var err error
+	forData, err = forCaptureIts.Vehicletypeex(edge_service.ForCaptureItsReq{
+		Codes: codes,
+		Start: req.StartTime,
+		End:   req.EndTime,
+		Flag:  flag,
+	})
+	return flag, forData, err
+}

router/router.go

@@ -625,6 +625,8 @@ func InitRouter(engine *gin.Engine) {
 		captureGroup.GET("periods/list", operation.Capture.PeriodsList)
 		//货车统计
 		captureGroup.GET("carrecord/count", operation.Capture.CarrecordCount)
+		//报表统计
+		captureGroup.GET("report/list", operation.Capture.ReportList)
 	}
 
 }

util/common/common.go

@@ -273,3 +273,12 @@ func Reverse(s []string) []string {
 	}
 	return s
 }
+
+func InIntArr(target int, str_array []int) bool {
+	for _, element := range str_array {
+		if target == element {
+			return true
+		}
+	}
+	return false
+}