智慧交流-车流总览

app/operation/controller/captureController.go

@@ -0,0 +1,58 @@
+package controller
+
+import (
+	"github.com/gin-gonic/gin"
+	"iot_manager_service/app/middleware"
+	"iot_manager_service/app/operation/model"
+	"iot_manager_service/app/operation/service"
+	"iot_manager_service/util/common"
+	"net/http"
+	"strconv"
+)
+
+// Capture 抓拍单元
+var Capture = new(captureCtl)
+
+type captureCtl struct{}
+
+// CountList 取车流量 月日
+func (c captureCtl) CountList(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
+	}
+	var records interface{}
+	err = nil
+	if req.QueryType == "day" {
+		records, err = service.CaptureService.GetDayVehicleTotal(claims.TenantId, req)
+	} else {
+		records, err = service.CaptureService.GetMonthVehicleTotal(claims.TenantId, req)
+	}
+	if err != nil {
+		ctx.JSON(http.StatusOK, err)
+		return
+	}
+	ctx.JSON(http.StatusOK, common.SuccessResponse(common.Succeeded, records))
+}
+
+// SuggestSpeed 取抓拍单元 方位
+func (c captureCtl) SuggestSpeed(ctx *gin.Context) {
+	captureId, err := strconv.Atoi(ctx.Query("captureId"))
+	if err != nil {
+		ctx.JSON(http.StatusOK, err)
+		return
+	}
+	value, _ := ctx.Get(middleware.Authorization)
+	claims := value.(*middleware.Claims)
+	var records interface{}
+	records, err = service.CaptureService.GetSuggestSpeed(claims.TenantId, captureId)
+	if err != nil {
+		ctx.JSON(http.StatusOK, err)
+		return
+	}
+	ctx.JSON(http.StatusOK, common.SuccessResponse(common.Succeeded, records))
+}

app/operation/edge_service/forCaptureItsService.go

@@ -0,0 +1,78 @@
+package edge_service
+
+import (
+	"encoding/json"
+	"io/ioutil"
+	"iot_manager_service/config"
+	"net/http"
+	"strings"
+)
+
+// CaptureIts 获取设备能耗数据
+type ForCaptureIts struct{}
+
+// CaptureItsReq 请求参数
+type ForCaptureItsReq struct {
+	Codes []string `json:"codes"` //抓拍单元 capture_sn列表
+	Start string   `json:"start"`
+	End   string   `json:"end"`
+	Flag  int      `json:"flag"` //0按日 1按月
+}
+
+// ForCaptureItsRes 返回数据
+type ForCaptureItsRes struct {
+	Code int                 `json:"code"`
+	Msg  string              `json:"msg"`
+	Data []ForCaptureItsData `json:"data"`
+}
+type ForCaptureItsData struct {
+	Code  string `json:"code"`  //抓拍单元 capture_sn
+	Time  string `json:"time"`  //时间 2022-05-01  ||2022-05
+	Flag  int    `json:"flag"`  //0:日数据，1：月数据，2:小时数据
+	Sflag int    `json:"sflag"` //车速区间时：
+	Total int    `json:"total"` //数量
+}
+
+// VehicleTotal 统计日 月 车流量 数据
+func (f ForCaptureIts) VehicleTotal(reqPostData ForCaptureItsReq) ([]ForCaptureItsData, error) {
+	api := "/data/v1/its/vehicletotal"
+	return f.pubPost(reqPostData, api)
+}
+
+//公用 post请求
+func (f ForCaptureIts) pubPost(reqPostData ForCaptureItsReq, api string) ([]ForCaptureItsData, error) {
+	cfg := config.Instance()
+	api = cfg.Foreign.IotEdgeUrl + api
+	//fmt.Printf("api = %v \n", api)
+	reqPostData.Start = reqPostData.Start + " 00:00:00"
+	reqPostData.End = reqPostData.End + " 23:59:59"
+	//fmt.Printf("reqPostData = %v \n", reqPostData)
+	method := "POST"
+	client := &http.Client{}
+	marshal, _ := json.Marshal(reqPostData)
+	req, err := http.NewRequest(method, api, strings.NewReader(string(marshal)))
+
+	if err != nil {
+		return nil, err
+	}
+	res, err := client.Do(req)
+	if err != nil {
+		return nil, err
+	}
+	defer res.Body.Close()
+	body, err := ioutil.ReadAll(res.Body)
+	if err != nil {
+		return nil, err
+	}
+	//fmt.Printf("body = %v", string(body))
+	result := ForCaptureItsRes{}
+	err = json.Unmarshal(body, &result)
+	if err != nil {
+		return nil, err
+	}
+	if result.Code != 0 {
+		panic(result.Msg)
+	}
+	//fmt.Printf("result.Data = %v", result.Data)
+	return result.Data, nil
+}

app/operation/model/capture.go

@@ -0,0 +1,19 @@
+package model
+
+type RequestCaptureFilter struct {
+	StartTime string `form:"queryStartDate"`
+	EndTime   string `form:"queryEndDate"`
+	QueryType string `form:"queryType"` //类型 month月 day日
+	CaptureId int    `form:"captureId"` //抓拍单元
+}
+
+type ResponseCaptureVehicleTotal struct {
+	CountTime string `json:"countTime"` //统一时间
+	CountT    int    `json:"countT"`    //总报警
+}
+
+type ResponseCaptureSuggestSpeed struct {
+	ID               int    `json:"id"`
+	CaptureDirection int    `json:"captureDirection"` //方向
+	WayName          string `json:"wayName"`          //名称
+}

app/operation/service/captureService.go

@@ -0,0 +1,81 @@
+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"
+)
+
+var CaptureService = new(captureService)
+
+type captureService struct{}
+
+// GetDayVehicleTotal 车流统计 日
+func (s captureService) GetDayVehicleTotal(tenantId int, req model.RequestCaptureFilter) ([]model.ResponseCaptureVehicleTotal, error) {
+	return s.getVehicleTotalData(0, tenantId, req)
+}
+
+// GetMonthVehicleTotal 车流统计 月
+func (s captureService) GetMonthVehicleTotal(tenantId int, req model.RequestCaptureFilter) ([]model.ResponseCaptureVehicleTotal, error) {
+	return s.getVehicleTotalData(1, tenantId, req)
+}
+
+// 车流统计公用方法
+func (s captureService) getVehicleTotalData(flag int, tenantId int, req model.RequestCaptureFilter) ([]model.ResponseCaptureVehicleTotal, error) {
+	unit := dao.CaptureUnit{
+		TenantId: tenantId,
+		ID:       req.CaptureId,
+	}
+	unit.GetDevice()
+	var codes []string
+	codes = append(codes, unit.CaptureSn)
+	var list []model.ResponseCaptureVehicleTotal
+	forCaptureIts := edge_service.ForCaptureIts{}
+	forData, err := forCaptureIts.VehicleTotal(edge_service.ForCaptureItsReq{
+		Codes: codes,
+		Start: req.StartTime,
+		End:   req.EndTime,
+		Flag:  flag,
+	})
+	//fmt.Printf("forData = %v \n", forData)
+	var countTimes []string
+	if flag == 1 {
+		countTimes = common.GetTimeMonths(req.StartTime, req.EndTime) //时间范围 月
+	} else {
+		countTimes = common.GetTimeDays(req.StartTime, req.EndTime) //时间范围 天
+	}
+	for _, countTime := range countTimes {
+		var countT int
+		for _, datum := range forData {
+			time := datum.Time
+			if flag == 1 {
+				time += "-01"
+			}
+			if time == countTime {
+				countT = datum.Total
+				continue
+			}
+		}
+		list = append(list, model.ResponseCaptureVehicleTotal{
+			CountTime: countTime,
+			CountT:    countT,
+		})
+	}
+	if err != nil {
+		return nil, err
+	}
+	return list, nil
+}
+
+// GetSuggestSpeed 从数据库查抓拍单元风向
+func (s captureService) GetSuggestSpeed(tenantId int, captureId int) (*dao.CaptureUnit, error) {
+	unit := dao.CaptureUnit{
+		TenantId: tenantId,
+		ID:       captureId,
+	}
+	if err := unit.GetDevice(); err != nil {
+		return nil, err
+	}
+	return &unit, nil
+}

app/warn/edge_service/syncAlarmService.go

@@ -35,6 +35,7 @@ type RecordAlarmRecordData struct {
 
 // SyncAlartRecord  同步报警 数据
 func (r *RecordAlarmRecord) SyncAlartRecord(maxId int64, maxUpDateTime string) ([]RecordAlarmRecordData, error) {
+	maxId += 1
 	cfg := config.Instance()
 	api := cfg.Foreign.IotEdgeUrl + "/data/v1/alarm/sync"
 	url := fmt.Sprintf("%v?id=%d&&updatedat=%v", api, maxId, url2.QueryEscape(maxUpDateTime))

router/router.go

@@ -568,7 +568,7 @@ func InitRouter(engine *gin.Engine) {
 	operationGroup.POST("/energy/list", operation.LightingRate.List)
 	//运营统计-告警统计
 	operationGroup.POST("/alarm/list", operation.Alarm.List)
-
+	//告警管理
 	warnGroup := engine.Group("/api/longchi/alarm")
 	{
 		//告警设置
@@ -606,4 +606,11 @@ func InitRouter(engine *gin.Engine) {
 		}
 
 	}
+	//智慧交通
+	captureGroup := operationGroup.Group("/capture")
+	{
+		captureGroup.GET("affiliation/count-list", operation.Capture.CountList)
+		captureGroup.POST("speed/getSuggestSpeed", operation.Capture.SuggestSpeed)
+	}
+
 }