修复camera自增id问题;查询任务关联表增加isai,runtype状态判断;milvus字段精度问题修复

qixiaoning

2025-07-25 86aff69316e2345f742b5e2b5bbab62543cb6e67

 camera-common/models/camera.go

@@ -29,7 +29,8 @@
)

type Camera struct {
   Id          string  `gorm:"primary_key;column:id;type:varchar(100);unique;" json:"id"`
   VideoId     int64   `gorm:"-;primaryKey;autoIncrement"` //摄像机id
   Id          string  `gorm:"column:id;type:varchar(100);unique;" json:"id"`
   Name        string  `gorm:"column:name" json:"name"  bind:"required"`
   Alias       string  `gorm:"column:alias" json:"alias"`               //摄像机的别名
   SnapshotUrl string  `gorm:"column:snapshot_url" json:"snapshot_url"` //快照地址
@@ -56,7 +57,39 @@
   VoiceEnable    bool   `gorm:"column:voiceEnable;default:0" json:"voiceEnable"`
   VoiceId        string `gorm:"column:voiceId" json:"voiceId"`
   CoordTransform string `gorm:"column:coordTransform" json:"coordTransform"` //坐标转换,长春追踪reid用
   VideoId        int    `gorm:"column:video_id" json:"video_id"`             //摄像机id

}

type CameraDto struct {
   VideoId     int64   `gorm:"primaryKey;autoIncrement"` //摄像机id
   Id          string  `gorm:"column:id;type:varchar(100);unique;" json:"id"`
   Name        string  `gorm:"column:name" json:"name"  bind:"required"`
   Alias       string  `gorm:"column:alias" json:"alias"`               //摄像机的别名
   SnapshotUrl string  `gorm:"column:snapshot_url" json:"snapshot_url"` //快照地址
   Type        int     `gorm:"column:type" json:"type" `
   Addr        string  `gorm:"column:addr" json:"addr"`
   Longitude   float32 `gorm:"column:longitude" json:"longitude"`
   Latitude    float32 `gorm:"column:latitude" json:"latitude"`
   Floor       int     `gorm:"column:floor" json:"floor"` //楼层
   Rtsp        string  `gorm:"column:rtsp" json:"rtsp"`
   Ip          string  `gorm:"column:ip" json:"ip"`
   Port        int     `gorm:"column:port" json:"port"`
   Username    string  `gorm:"column:username" json:"username"`
   Password    string  `gorm:"column:password" json:"password"`
   Brand       string  `gorm:"column:brand" json:"brand"`
   Reserved    string  `gorm:"column:reserved" json:"reserved"`
   IsRunning   bool    `gorm:"column:is_running" json:"is_running"`       //是否正在解码
   RunEnable   bool    `gorm:"column:run_enable" json:"run_enable"`       //控制实时处理或轮询处理的开关
   RunType     int     `gorm:"column:run_type" json:"run_type"`           //处理类型：0：轮询，1：实时,-1:无任务，不做分析或者分析任务被关了
   RunServerId string  `gorm:"column:run_server_id" json:"run_server_id"` //当前正在处理的分析服务器id

   ResolutionWidth  int `gorm:"column:resolution_width;default:0" json:"resolution_width"`   //分辨率宽
   ResolutionHeight int `gorm:"column:resolution_height;default:0" json:"resolution_height"` //分辨率高

   VoiceEnable    bool   `gorm:"column:voiceEnable;default:0" json:"voiceEnable"`
   VoiceId        string `gorm:"column:voiceId" json:"voiceId"`
   CoordTransform string `gorm:"column:coordTransform" json:"coordTransform"` //坐标转换,长春追踪reid用

}

func (Camera) TableName() string {
@@ -374,3 +407,27 @@
   }
   pub.AddDbMessage(&dbMsg)
}

type VideoLink struct {
   ID      int    `gorm:"column:id"       json:"id"`
   VideoId string `gorm:"column:video_id" json:"videoId"`
   TaskId  int    `gorm:"column:task_id"  json:"taskId"`
}

func GetTasks() map[string][]interface{} {

   var lists []VideoLink
   sqlStr := `select id,video_id,task_id from mal_task_video_link`
   if err := db.Raw(sqlStr).Scan(&lists).Error; err != nil {
      fmt.Println(err.Error())
      return nil
   }

   checkMap := make(map[string][]interface{})
   for _, d2 := range lists {
      if d2.VideoId != "" {
         checkMap[d2.VideoId] = append(checkMap[d2.VideoId], d2)
      }
   }
   return checkMap
}