运营

.gitignore

@@ -1,4 +1,5 @@
 /build/
 log
 .idea
-go.sum
+go.sum
+main_demo.go

app/device/dao/lightControlDao.go

@@ -133,3 +133,9 @@ func (c LightControl) GetDevicesByLampPole() []LightControl {
 		c.LampPoleId).Find(&devices)
 	return devices
 }
+
+func (c LightControl) GetSnList() ([]string, error) {
+	var sns []string
+	err := Db.Debug().Model(&c).Select("sn").Where(" tenant_id = ? and is_deleted = ? ", c.TenantId, c.IsDeleted).Scan(&sns).Error
+	return sns, err
+}

app/operation/controller/deviceCountController.go

@@ -9,6 +9,7 @@ import (
 	"net/http"
 )
 
+// Device 设备统计
 var Device = new(deviceCtl)
 
 type deviceCtl struct{}

app/operation/service/deviceCoutService.go

@@ -14,7 +14,7 @@ func (s deviceCountService) CountDevice(tenantId int, req model.RequestDeviceCou
 	list := dao.ViewsAllCodeDevice{
 		TenantId: tenantId,
 	}
-	//TODO: 在线数 未做
+	// TODO: 在线数 未做
 	counts, err := list.GetDeviceCount()
 	for i, count := range counts {
 		warnCount, _ := service.PlatformAlarmService.GetWarnCount(tenantId, count.DeviceType)

app/warn/edge_service/syncAlarmService.go

@@ -11,7 +11,7 @@ import (
 
 type RecordAlarmRecord struct{}
 
-type RecordAlarmRecordReq struct {
+type RecordAlarmRecordRes struct {
 	Code int                     `json:"code"`
 	Msg  string                  `json:"msg"`
 	Data []RecordAlarmRecordData `json:"data"`
@@ -56,7 +56,7 @@ func (r *RecordAlarmRecord) SyncAlartRecord(maxId int64, maxUpDateTime string) (
 		return nil, err
 	}
 	//fmt.Printf("body = %v", string(body))
-	result := RecordAlarmRecordReq{}
+	result := RecordAlarmRecordRes{}
 	err = json.Unmarshal(body, &result)
 	if err != nil {
 		return nil, err

go.mod

@@ -44,6 +44,7 @@ require (
 	github.com/mattn/go-isatty v0.0.14 // indirect
 	github.com/minio/md5-simd v1.1.2 // indirect
 	github.com/minio/sha256-simd v1.0.0 // indirect
+	github.com/mitchellh/mapstructure v1.5.0 // indirect
 	github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect
 	github.com/modern-go/reflect2 v1.0.2 // indirect
 	github.com/onsi/ginkgo v1.16.5 // indirect

router/router.go

@@ -564,6 +564,9 @@ func InitRouter(engine *gin.Engine) {
 		operationDeviceGroup.POST("list", operation.Device.MonthList)
 		operationDeviceGroup.POST("year-list", operation.Device.YearList)
 	}
+	//灯控能耗统计
+	operationGroup.POST("/energy/list", operation.LightingRate.List)
+
 	warnGroup := engine.Group("/api/longchi/alarm")
 	{
 		//告警设置

util/common/common.go

@@ -1,6 +1,7 @@
 package common
 
 import (
+	"fmt"
 	"gorm.io/gorm"
 	"math/rand"
 	"strconv"
@@ -211,3 +212,72 @@ func TimeStringToGoTime(tm string) time.Time {
 	}
 	return time.Time{}
 }
+
+// GetTimeDays 时间区间的所有天数
+func GetTimeDays(start_time, stop_time string) []string {
+	tm1, _ := time.Parse("2006-01-02", start_time)
+	tm2, _ := time.Parse("2006-01-02", stop_time)
+	sInt := tm1.Unix()
+	eInt := tm2.Unix()
+	var args []string
+	for {
+		sInt += 86400
+		st := time.Unix(sInt, 0).Format("2006-01-02")
+		args = append(args, st)
+		if sInt > eInt {
+			break
+		}
+	}
+	var days []string
+	for i := 0; i < len(args); i++ {
+		parse, _ := time.Parse("2006-01-02", start_time)
+		date := parse.AddDate(0, 0, i).Format("2006-01-02")
+		days = append(days, date)
+	}
+	return Reverse(days)
+}
+
+// GetTimeMonths 时间区间的所有月份
+func GetTimeMonths(start_time, stop_time string) []string {
+	tm1, _ := time.Parse("2006-01", start_time)
+	tm2, _ := time.Parse("2006-01", stop_time)
+	sInt := tm1.Unix()
+	eInt := tm2.Unix()
+	var args []string
+	for {
+		sInt += 86400
+		st := time.Unix(sInt, 0).Format("20060102")
+		args = append(args, st)
+		if sInt > eInt {
+			break
+		}
+	}
+	var months []string
+	i := 0
+	for {
+		parse, _ := time.Parse("2006-01-02", start_time)
+		endStr, _ := time.Parse("2006-01-02", stop_time)
+		month := parse.AddDate(0, i, 0).Format("2006-01")
+		month = month + "-01"
+		months = append(months, month)
+		if month == endStr.Format("2006-01")+"-01" || i > 24 {
+			break
+		}
+		i++
+	}
+	return Reverse(months)
+}
+
+// Decimal float64 保留2位小数
+func Decimal(value float64) float64 {
+	value, _ = strconv.ParseFloat(fmt.Sprintf("%.2f", value), 64)
+	return value
+}
+
+// Reverse 反转数组
+func Reverse(s []string) []string {
+	for i, j := 0, len(s)-1; i < j; i, j = i+1, j-1 {
+		s[i], s[j] = s[j], s[i]
+	}
+	return s
+}