告警相关功能

app/warn/controller/noticeRecordController.go

@@ -0,0 +1,52 @@
+package controller
+
+import (
+	"github.com/gin-gonic/gin"
+	"iot_manager_service/app/middleware"
+	"iot_manager_service/app/warn/model"
+	"iot_manager_service/app/warn/service"
+	"iot_manager_service/util/common"
+	"math"
+	"net/http"
+	"strconv"
+)
+
+var NoticeRecord = new(noticeRecordCtl)
+
+type noticeRecordCtl struct {
+}
+
+func (c noticeRecordCtl) List(ctx *gin.Context) {
+	value, _ := ctx.Get(middleware.Authorization)
+	claims := value.(*middleware.Claims)
+	filter := model.RequestNoticeRecordFilter{}
+	current, _ := strconv.Atoi(ctx.Query("current"))
+	size, _ := strconv.Atoi(ctx.Query("size"))
+	if current == 0 {
+		current = 1
+	}
+	if size <= 0 || size > 100 {
+		size = 10
+	}
+	err := ctx.ShouldBind(&filter)
+	if err != nil {
+		ctx.JSON(http.StatusBadRequest, err)
+		return
+	}
+
+	list, total, err := service.NoticeRecordService.List(claims.TenantId, filter)
+	if err != nil {
+		ctx.JSON(http.StatusBadRequest, err)
+		return
+	}
+	pages := math.Ceil(float64((total)) / float64(size))
+	rsp := model.ResposeNoticeRecord{
+		Current: current,
+		Size:    size,
+		Total:   total,
+		Pages:   int(pages),
+		Records: list,
+	}
+	ctx.JSON(http.StatusOK, common.SuccessResponse(common.Succeeded, rsp))
+
+}

app/warn/controller/platformAlarmController.go

@@ -0,0 +1,61 @@
+package controller
+
+import (
+	"github.com/gin-gonic/gin"
+	"iot_manager_service/app/middleware"
+	"iot_manager_service/app/warn/model"
+	"iot_manager_service/app/warn/service"
+	"iot_manager_service/util/common"
+	"math"
+	"net/http"
+	"strconv"
+)
+
+var PlatformAlarm = new(platformAlarmCrl)
+
+type platformAlarmCrl struct {
+}
+
+func (c platformAlarmCrl) List(ctx *gin.Context) {
+	value, _ := ctx.Get(middleware.Authorization)
+	claims := value.(*middleware.Claims)
+	filter := model.RequestPlatFormAlartFilter{}
+	current, _ := strconv.Atoi(ctx.Query("current"))
+	size, _ := strconv.Atoi(ctx.Query("size"))
+	if current == 0 {
+		current = 1
+	}
+	if size <= 0 || size > 100 {
+		size = 10
+	}
+	err := ctx.ShouldBind(&filter)
+	if err != nil {
+		ctx.JSON(http.StatusBadRequest, err)
+		return
+	}
+	list, total, err := service.PlatformAlarmService.GetList(claims.TenantId, filter)
+	if err != nil {
+		ctx.JSON(http.StatusBadRequest, err)
+		return
+	}
+	pages := math.Ceil(float64((total)) / float64(size))
+	rsp := model.ResposePlatFormAlart{
+		Current: current,
+		Size:    size,
+		Total:   total,
+		Pages:   int(pages),
+		Records: list,
+	}
+	ctx.JSON(http.StatusOK, common.SuccessResponse(common.Succeeded, rsp))
+}
+
+func (c platformAlarmCrl) Refresh(ctx *gin.Context) {
+	value, _ := ctx.Get(middleware.Authorization)
+	claims := value.(*middleware.Claims)
+	tenantId := claims.TenantId
+	alarmService := service.PlatformAlarmService
+	go func() {
+		alarmService.Refresh(tenantId)
+	}()
+	ctx.JSON(http.StatusOK, common.SuccessResponse(common.Succeeded, nil))
+}

app/warn/dao/noticeRecordDao.go

@@ -1,17 +1,59 @@
 package dao
 
-import "gorm.io/gorm"
+import (
+	"gorm.io/gorm"
+	"iot_manager_service/app/warn/model"
+	"iot_manager_service/util/common"
+)
 
 // NoticeRecord 告警通知记录
 type NoticeRecord struct {
 	gorm.Model
-	NoticeSetId int `gorm:"comment:告警通知设置ID;" json:"noticeSetId"`
-	NoticeSet   NoticeSet
-	ArmClassify int    `gorm:"comment:告警类型：1运维，2业务;" json:"classify"`
-	Content     string `gorm:"comment:发送内容;" json:"content"`
-	Status      int    `gorm:"comment:发送状态;" json:"status"`
+	NoticeSetId  int `gorm:"comment:告警通知设置ID;" json:"noticeSetId"`
+	NoticeSet    NoticeSet
+	ArmClassify  int    `gorm:"comment:告警类型：1运维，2业务;" json:"classify"`
+	Content      string `gorm:"comment:发送内容;" json:"content"`
+	Status       int    `gorm:"comment:发送状态;" json:"status"`
+	SendType     int    `gorm:"comment:发送方式1短信2邮件" json:"sendType"`
+	SendTypeName string `gorm:"comment:发送方式" json:"SendTypeName"`
+	SendValue    int    `gorm:"comment:手机号或邮件" json:"sendValue"`
+	SendName     string `gorm:"comment:收件人" json:"sendName"`
 }
 
 func (NoticeRecord) TableName() string {
 	return "warn_notice_record"
 }
+
+func (r NoticeRecord) GetList(filter model.RequestNoticeRecordFilter) ([]NoticeRecord, int64, error) {
+	var list []NoticeRecord
+	var total int64
+	db := Db.Debug().Model(&r)
+	db = db.Scopes(common.Paginate(filter.Current, filter.Size)).Preload("NoticeSet")
+	// 告警类型
+	if filter.ClassifyName != 0 {
+		db = db.Where(&NoticeRecord{ArmClassify: filter.ClassifyName})
+	}
+	//发送状态
+	if filter.SendValue != 0 {
+		if filter.SendValue == 2 { //1成功 2为失败
+			filter.SendValue = 0
+		}
+		db = db.Where(&NoticeRecord{Status: filter.SendValue})
+	}
+	//发送方式
+	if filter.SendType != 0 {
+		db = db.Where(&NoticeRecord{SendType: filter.SendType})
+	}
+	//时间范围
+	if filter.StartTime != "" {
+		db = db.Where("created_at>=? and created_at<=?", filter.StartTime, filter.EndTime)
+	}
+	//发送人
+	if filter.SendName != "" {
+		db = db.Where("send_name=?", filter.SendName)
+	}
+	err := db.Find(&list).Error
+	db.Count(&total)
+	//fmt.Printf("total = %v", total)
+	return list, total, err
+}

app/warn/dao/platformAlarmDao.go

@@ -1,15 +1,16 @@
 package dao
 
 import (
-	"gorm.io/gorm"
+	"iot_manager_service/app/warn/model"
 	"iot_manager_service/util/common"
 )
 
 // PlatformAlarm 平台所有告警-来源边缘端接口
 type PlatformAlarm struct {
-	gorm.Model
-	ArmClassify       int         `gorm:"column:arm_classify;type:int(11);comment:告警分类1运维2业务" json:"armClassify"`           // 告警分类 1运维 2业务
-	ArmDeviceType     int         `gorm:"column:arm_device_type;type:int(11);comment:设备类型1" json:"armDeviceType"`           // 告警设备类型1摄像头2网关3灯控4配电5信息屏...15
+	ID                int         `gorm:"comment:ID" json:"ID"`
+	ArmClassify       int         `gorm:"column:arm_classify;type:int(11);comment:告警分类1运维2业务" json:"armClassify"` // 告警分类 1运维 2业务
+	ArmDeviceType     int         `gorm:"column:arm_device_type;type:int(11);comment:设备类型1" json:"armDeviceType"` // 告警设备类型1摄像头2网关3灯控4配电5信息屏...15
+	ArmDeviceTypeName string      `gorm:";comment:设备类型1" json:"armDeviceTypeName"`
 	ArmDeviceId       int         `gorm:"column:arm_device_id;type:int(11);comment:设备id" json:"armDeviceId"`                // 告警设备id
 	ArmDeviceName     string      `gorm:"column:arm_device_name;type:varchar(64);comment:设备名称" json:"armDeviceName"`        // 告警设备名称
 	ArmDeviceSn       string      `gorm:"column:arm_device_sn;type:varchar(60);comment:设备编码" json:"armDeviceSn"`            // 告警设备编码
@@ -27,17 +28,53 @@ type PlatformAlarm struct {
 	ArmHandleTime     common.Time `gorm:"column:arm_handle_time;type:datetime" json:"armHandleTime"`                        // 告警处理时间
 	Status            int         `gorm:"column:status;type:int(11);comment:告警状态 1处理完成2待处理3无需处理" json:"status"`             // 告警状态 1处理完成2待处理3无需处理
 	NoticeRecordId    int         `gorm:"comment:发送通知ID" json:"noticeRecordId"`
-	TenantId          string      `gorm:"column:tenant_id;type:varchar(12);comment:租户ID" json:"tenantId"`                       // 租户ID
-	ProcessInstanceId string      `gorm:"column:process_instance_id;type:varchar(255);comment:流程实例主键" json:"processInstanceId"` // 流程实例主键
-	BusinessId        string      `gorm:"column:business_id;type:varchar(64);comment:流程实例主键ID" json:"businessId"`               // 流程实例主键ID
-	Threshold         float64     `gorm:"column:threshold;type:float(11,2);comment:阈值-业务告警" json:"threshold"`                   // 阈值-业务告警
-	Value             float64     `gorm:"column:value;type:float(11,2);comment:告警时的值-业务告警" json:"value"`                        // 告警时的值-业务告警
-	Sid               int         `gorm:"column:sid;type:int(11);comment:物模型sid" json:"sid"`                                    // 物模型sid
-	Cid               uint        `gorm:"column:cid;type:int(10) unsigned;comment:告警策略编号" json:"cid"`                           // 告警策略编号
-	Cname             string      `gorm:"column:cname;type:varchar(100);comment:告警策略名称" json:"cname"`                           // 告警策略名称
-	ExtendId          int         `gorm:"column:extend_id;type:int(11);comment:扩展id"json:"extendId"`                            // 扩展id
+	NoticeRecord      NoticeRecord
+	TenantId          string  `gorm:"column:tenant_id;type:varchar(12);comment:租户ID" json:"tenantId"`                       // 租户ID
+	ProcessInstanceId string  `gorm:"column:process_instance_id;type:varchar(255);comment:流程实例主键" json:"processInstanceId"` // 流程实例主键
+	BusinessId        string  `gorm:"column:business_id;type:varchar(64);comment:流程实例主键ID" json:"businessId"`               // 流程实例主键ID
+	Threshold         float64 `gorm:"column:threshold;type:float(11,2);comment:阈值-业务告警" json:"threshold"`                   // 阈值-业务告警
+	Value             float64 `gorm:"column:value;type:float(11,2);comment:告警时的值-业务告警" json:"value"`                        // 告警时的值-业务告警
+	Sid               int     `gorm:"column:sid;type:int(11);comment:物模型sid" json:"sid"`                                    // 物模型sid
+	Cid               uint    `gorm:"column:cid;type:int(10) unsigned;comment:告警策略编号" json:"cid"`                           // 告警策略编号
+	Cname             string  `gorm:"column:cname;type:varchar(100);comment:告警策略名称" json:"cname"`                           // 告警策略名称
+	ExtendId          int     `gorm:"column:extend_id;type:int(11);comment:扩展id"json:"extendId"`                            // 扩展id
 }
 
 func (PlatformAlarm) TableName() string {
 	return "warn_platform_alarm"
 }
+
+func (a PlatformAlarm) Gets(filter model.RequestPlatFormAlartFilter) ([]PlatformAlarm, int64, error) {
+	var list []PlatformAlarm
+	db := Db.Debug().Model(&a).Where(&PlatformAlarm{TenantId: a.TenantId})
+	db = db.Scopes(common.Paginate(filter.Current, filter.Size))
+	if filter.ArmHandle > 0 {
+		handle := filter.ArmHandle
+		status := 2
+		if handle == 1 {
+
+		}
+		db = db.Where(&PlatformAlarm{Status: status})
+	}
+	if filter.ArmDeviceType > 0 {
+		db = db.Where(&PlatformAlarm{ArmDeviceType: filter.ArmDeviceType})
+	}
+	if filter.ArmDeviceName != "" {
+		db = db.Where(&PlatformAlarm{ArmDeviceName: filter.ArmDeviceName})
+	}
+	err := db.Preload("NoticeRecord").Order("id desc").Find(&list).Error
+	var count int64
+	db.Count(&count)
+	//fmt.Printf("count = %v", count)
+	return list, count, err
+}
+
+func (a PlatformAlarm) GetMaxIdAndUpDateTime() (int64, string) {
+	var platformAlarm PlatformAlarm
+	Db.Debug().Where(&PlatformAlarm{TenantId: a.TenantId}).Order("id desc").First(&platformAlarm)
+	return int64(platformAlarm.ID), platformAlarm.ArmTime.String()
+}
+
+func (a PlatformAlarm) BatchCreate(his []PlatformAlarm) error {
+	return Db.Debug().CreateInBatches(his, 1000).Error
+}

app/warn/edge_service/syncAlarmService.go

@@ -0,0 +1,69 @@
+package edge_service
+
+import (
+	"encoding/json"
+	"fmt"
+	"io/ioutil"
+	"iot_manager_service/config"
+	"net/http"
+	url2 "net/url"
+)
+
+type RecordAlarmRecord struct{}
+
+type RecordAlarmRecordReq struct {
+	Code int                     `json:"code"`
+	Msg  string                  `json:"msg"`
+	Data []RecordAlarmRecordData `json:"data"`
+}
+
+type RecordAlarmRecordData struct {
+	ID        int    `json:"id"`
+	Code      string `json:"code"`
+	Tstart    string `json:"tstart"`
+	Tend      string `json:"tend"`
+	Content   string `json:"content"`
+	Alarmtype int    `json:"alarmtype"`
+	Level     int    `json:"level"`
+	Threshold int    `json:"threshold"`
+	Value     int    `json:"value"`
+	Sid       int    `json:"sid"`
+	Cid       int    `json:"cid"`
+	Cname     string `json:"cname"`
+	Updatedat string `json:"updatedat"`
+}
+
+// SyncAlartRecord  同步报警 数据
+func (r *RecordAlarmRecord) SyncAlartRecord(maxId int64, maxUpDateTime string) ([]RecordAlarmRecordData, error) {
+	cfg := config.Instance()
+	api := cfg.Foreign.IotEdgeUrl + "/data/v1/alarm/sync"
+	url := fmt.Sprintf("%v?id=%d&&updatedat=%v", api, maxId, url2.QueryEscape(maxUpDateTime))
+	//fmt.Printf("url = %v", url)
+	method := "GET"
+	client := &http.Client{}
+	req, err := http.NewRequest(method, url, nil)
+
+	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 := RecordAlarmRecordReq{}
+	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/warn/model/noticeRecordModel.go

@@ -0,0 +1,36 @@
+package model
+
+type ResposeNoticeRecord struct {
+	Records []ResposeNoticeRecordData `json:"records"` //记录列表
+	Current int                       `json:"current"` //当前分页
+	Size    int                       `json:"size"`    //每页数量
+	Total   int64                     `json:"total"`   //总数
+	Pages   int                       `json:"pages"`   //总页数
+}
+
+type ResposeNoticeRecordData struct {
+	ID             int    `json:"id"`
+	RecordID       int    `json:"recordId"`
+	SendUser       string `json:"sendUser"`
+	SendTime       string `json:"sendTime"`
+	SendType       int    `json:"sendType"`
+	SendValue      int    `json:"sendValue"`
+	CreateTime     string `json:"createTime"`
+	TenantID       string `json:"tenantId"`
+	ArmContend     string `json:"armContend"`
+	SendName       string `json:"sendName"`
+	SendTypeName   string `json:"sendTypeName"`
+	ClassifyName   string `json:"classifyName"`
+	SendStatusName string `json:"sendStatusName"`
+}
+type RequestNoticeRecordFilter struct {
+	StartTime    string `form:"startTime"`    //开始时间
+	EndTime      string `form:"endTime"`      //结束时间
+	ClassifyName int    `form:"classifyName"` //告警类型 1运维 2业务
+	SendName     string `form:"sendName"`     //发送人
+	SendValue    int    `form:"sendValue"`    //发送方式 1短信 2邮件
+	SendType     int    `form:"sendType"`     //发送状态
+
+	Current int `form:"current"` //当前分页
+	Size    int `form:"size"`    //每页数量
+}

app/warn/model/platformAlarmModel.go

@@ -0,0 +1,64 @@
+package model
+
+type RequestPlatFormAlartFilter struct {
+	ArmDeviceType int    `form:"armDeviceType"` //告警类型
+	ArmDeviceName string `form:"armDeviceName"` //告警设备名称
+	ArmHandle     int    `form:"armHandle"`     //是否处理
+
+	Current int `form:"current"` //当前分页
+	Size    int `form:"size"`    //每页数量
+}
+
+type PlatFormAlartData struct {
+	ID                  int    `json:"id"`
+	ArmClassify         int    `json:"armClassify"`
+	ArmDeviceType       int    `json:"armDeviceType"`
+	ArmDeviceID         int    `json:"armDeviceId"`
+	ArmDeviceName       string `json:"armDeviceName"`
+	ArmDeviceSn         string `json:"armDeviceSn"`
+	LampPoleID          int    `json:"lampPoleId"`
+	LampPoleName        string `json:"lampPoleName"`
+	LampPoleSn          string `json:"lampPoleSn"`
+	LampPoleLocation    string `json:"lampPoleLocation"`
+	ArmSource           int    `json:"armSource"`
+	ArmTime             string `json:"armTime"`
+	ArmEndTime          string `json:"armEndTime"`
+	ArmHandle           int    `json:"armHandle"`
+	ArmLevel            int    `json:"armLevel"`
+	ArmContent          string `json:"armContent"`
+	ArmURL              string `json:"armUrl"`
+	Status              int    `json:"status"`
+	ArmNotificationType string `json:"armNotificationType"`
+	ArmHandleTime       string `json:"armHandleTime"`
+	CreateTime          string `json:"createTime"`
+	CreateUser          string `json:"createUser"`
+	UpdateTime          string `json:"updateTime"`
+	UpdateUser          string `json:"updateUser"`
+	IsDeleted           int    `json:"isDeleted"`
+	TenantID            string `json:"tenantId"`
+	ProcessInstanceID   string `json:"processInstanceId"`
+	BusinessID          string `json:"businessId"`
+	Threshold           int    `json:"threshold"`
+	Value               int    `json:"value"`
+	Sid                 int    `json:"sid"`
+	Cid                 int    `json:"cid"`
+	Cname               string `json:"cname"`
+	ExtendID            int    `json:"extendId"`
+	GroupID             int    `json:"groupId"`
+	UserID              string `json:"userId"`
+	IsMonitoring        bool   `json:"isMonitoring"`
+	IsWorkOrder         bool   `json:"isWorkOrder"`
+	OpsStatus           int    `json:"opsStatus"`
+	Remark              string `json:"remark"`
+	ArmSourceName       string `json:"armSourceName"`
+	ArmDeviceTypeName   string `json:"armDeviceTypeName"`
+	ArmLevelName        string `json:"armLevelName"`
+}
+
+type ResposePlatFormAlart struct {
+	Records []PlatFormAlartData `json:"records"` //记录列表
+	Current int                 `json:"current"` //当前分页
+	Size    int                 `json:"size"`    //每页数量
+	Total   int64               `json:"total"`   //总数
+	Pages   int                 `json:"pages"`   //总页数
+}

app/warn/service/noticeRecordService.go

@@ -0,0 +1,47 @@
+package service
+
+import (
+	"iot_manager_service/app/warn/dao"
+	"iot_manager_service/app/warn/model"
+)
+
+var NoticeRecordService = new(noticeRecordService)
+
+type noticeRecordService struct{}
+
+func (s noticeRecordService) List(tenantId int, filter model.RequestNoticeRecordFilter) ([]model.ResposeNoticeRecordData, int64, error) {
+	var list []model.ResposeNoticeRecordData
+	dao := dao.NoticeRecord{}
+	records, total, err := dao.GetList(filter)
+	for _, record := range records {
+		//fmt.Printf("record = %v", record)
+		var SendUser, ArmClassifyName string
+		if record.ArmClassify == 1 {
+			SendUser = record.NoticeSet.DevUserIdsName
+			ArmClassifyName = "运维"
+		} else {
+			SendUser = record.NoticeSet.BusinessUserIdsName
+			ArmClassifyName = "业务"
+		}
+		status := record.Status
+		sendStatusName := "失败"
+		if status == 1 {
+			sendStatusName = "成功"
+		}
+		list = append(list, model.ResposeNoticeRecordData{
+			ID:             int(record.ID),
+			RecordID:       int(record.ID),
+			SendUser:       SendUser,
+			SendTime:       record.CreatedAt.Format("2006-01-02 15:04:05"),
+			SendType:       record.SendType,
+			SendValue:      record.SendValue,
+			ClassifyName:   ArmClassifyName,
+			TenantID:       record.NoticeSet.TenantId,
+			ArmContend:     record.Content,
+			SendName:       record.SendName,
+			SendTypeName:   record.SendTypeName,
+			SendStatusName: sendStatusName,
+		})
+	}
+	return list, total, err
+}

app/warn/service/platformAlarmService.go

@@ -0,0 +1,100 @@
+package service
+
+import (
+	"iot_manager_service/app/warn/dao"
+	edgeService "iot_manager_service/app/warn/edge_service"
+	"iot_manager_service/app/warn/model"
+	"iot_manager_service/util/common"
+	"strconv"
+)
+
+var PlatformAlarmService = new(platformAlarmService)
+
+type platformAlarmService struct{}
+
+func (s platformAlarmService) GetList(tenantId int, filter model.RequestPlatFormAlartFilter) ([]model.PlatFormAlartData, int64, error) {
+	var list []model.PlatFormAlartData
+	dao := dao.PlatformAlarm{
+		TenantId: strconv.Itoa(tenantId),
+	}
+	levelArr := make(map[int]string)
+	levelArr[1] = "紧急"
+	levelArr[2] = "严重"
+	levelArr[3] = "普通"
+	gets, i, err := dao.Gets(filter)
+	for _, alart := range gets {
+		list = append(list, model.PlatFormAlartData{
+			ID:                alart.ID,
+			ArmDeviceName:     alart.ArmDeviceName,
+			ArmDeviceSn:       alart.ArmDeviceSn,
+			ArmDeviceTypeName: alart.ArmDeviceTypeName,
+			ArmContent:        alart.ArmContent,
+			LampPoleName:      alart.LampPoleName,
+			LampPoleSn:        alart.LampPoleSn,
+			ArmTime:           alart.ArmTime.String(),
+			ArmEndTime:        alart.ArmEndTime.String(),
+			ArmLevel:          alart.ArmLevel,
+			ArmLevelName:      levelArr[alart.ArmLevel],
+			LampPoleLocation:  alart.LampPoleLocation,
+		})
+	}
+	return list, i, err
+}
+
+func (s platformAlarmService) Refresh(tenantId int) error {
+	viewDao := dao.ViewsAllCode{TenantId: tenantId}
+	alls, err := viewDao.GetAlls()
+
+	if err != nil {
+		return err
+	}
+	newAllCode := make(map[string]dao.ViewsAllCode)
+	for _, viewsAllCode := range alls {
+		if viewsAllCode.Sn != "" {
+			newAllCode[viewsAllCode.Sn] = viewsAllCode
+		}
+	}
+	//fmt.Printf("newAllCode = %v", newAllCode)
+	edgeService := edgeService.RecordAlarmRecord{}
+	maxId, maxUpDateTime := dao.PlatformAlarm{}.GetMaxIdAndUpDateTime()
+	//fmt.Printf("maxId = %v", maxId)
+
+	list, err := edgeService.SyncAlartRecord(maxId, maxUpDateTime)
+	if err != nil {
+		return err
+	}
+	alarms := []dao.PlatformAlarm{}
+	for _, data := range list {
+		viewInfo := newAllCode[data.Code]
+		parse := common.TimeStringToGoTime(data.Tend)
+		ArmTime := common.TimeStringToGoTime(data.Updatedat)
+		alarms = append(alarms, dao.PlatformAlarm{
+			ID:                data.ID,
+			TenantId:          strconv.Itoa(tenantId),
+			ArmDeviceType:     viewInfo.DeviceType,
+			ArmDeviceTypeName: viewInfo.DeviceTypeName,
+			ArmDeviceId:       viewInfo.DeviceId,
+			ArmDeviceName:     viewInfo.DeviceName,
+			ArmDeviceSn:       data.Code,
+			LampPoleId:        viewInfo.LampPoleId,
+			LampPoleName:      viewInfo.LampPoleName,
+			LampPoleSn:        viewInfo.LampPoleSn,
+			LampPoleLocation:  viewInfo.Address,
+			ArmSource:         1,
+			ArmEndTime:        common.Time(parse),
+			ArmTime:           common.Time(ArmTime),
+			ArmHandle:         1,
+			ArmLevel:          data.Level,
+			ArmContent:        data.Content,
+			Status:            2,
+			NoticeRecordId:    2222,
+			Cid:               uint(data.Cid),
+			Cname:             data.Cname,
+			Sid:               data.Sid,
+			Threshold:         float64(data.Threshold),
+		})
+	}
+	err = dao.PlatformAlarm{}.BatchCreate(alarms)
+	return err
+
+}

main.go

@@ -40,6 +40,7 @@ func main() {
 	minio.InitMinio()
 	controller.CalcTask()
 	engine := gin.Default()
+
 	router.InitRouter(engine)
 	if isDevEnv() {
 		println(gin.DebugMode + "当前为开发环境，会产生较多调试日志")

router/router.go

@@ -570,7 +570,12 @@ func InitRouter(engine *gin.Engine) {
 		}
 		sendrecordGroup := warnGroup.Group("sendrecord")
 		{
-			sendrecordGroup.GET("/list", warn.NoticeSet.List)
+			sendrecordGroup.GET("/list", warn.NoticeRecord.List)
+		}
+		alarmGroup := warnGroup.Group("alarm")
+		{
+			alarmGroup.GET("/list", warn.PlatformAlarm.List)
+			alarmGroup.GET("/refresh", warn.PlatformAlarm.Refresh)
 		}
 	}
 }

util/common/common.go

@@ -1,6 +1,7 @@
 package common
 
 import (
+	"gorm.io/gorm"
 	"math/rand"
 	"strconv"
 	"strings"
@@ -172,3 +173,41 @@ func MultimediaEfficacyTime(stime Time, etime Time, time2 string) bool {
 	}
 	return true
 }
+
+// Paginate 翻页
+func Paginate(page int, size int) func(db *gorm.DB) *gorm.DB {
+	return func(db *gorm.DB) *gorm.DB {
+		page := page
+		if page == 0 {
+			page = 1
+		}
+		pageSize := size
+		switch {
+		case pageSize > 100:
+			pageSize = 100
+		case pageSize <= 0:
+			pageSize = 10
+		}
+		offset := (page - 1) * pageSize
+		return db.Offset(offset).Limit(pageSize)
+	}
+}
+
+var timeTemplates = []string{
+	"2006-01-02 15:04:05", //常规类型
+	"2006/01/02 15:04:05",
+	"2006-01-02",
+	"2006/01/02",
+	"15:04:05",
+}
+
+/* 时间格式字符串转换 */
+func TimeStringToGoTime(tm string) time.Time {
+	for i := range timeTemplates {
+		t, err := time.ParseInLocation(timeTemplates[i], tm, time.Local)
+		if nil == err && !t.IsZero() {
+			return t
+		}
+	}
+	return time.Time{}
+}