package service
|
|
import (
|
"basic.com/pubsub/protomsg.git"
|
"basic.com/valib/bhomeclient.git"
|
"basic.com/valib/bhomedbapi.git"
|
"basic.com/valib/logger.git"
|
"encoding/json"
|
"time"
|
"vamicro/cameraCompose-service/models"
|
"context"
|
)
|
|
type CameraComposeDetail struct {
|
Id string `json:"id"`
|
CameraId string `json:"cameraId"`
|
Status int `json:"status"`
|
Rtsp string `json:"rtsp"`
|
CameraType int `json:"cameraType"`
|
IsAI bool `json:"isAI"`
|
IsRunning bool `json:"isRunning"`
|
Name string `json:"name"`
|
Type string `json:"type"`
|
}
|
|
type CameraComposeMsg struct {
|
CameraId string `json:"cameraId"`
|
Status int `json:"status"`
|
Ids []int64 `json:"ids"`
|
}
|
|
type CameraComposeService struct {
|
}
|
|
func Init(c context.Context, ms *bhomeclient.MicroNode) {
|
tick := time.Tick(15 * time.Second)
|
for {
|
select {
|
case <-c.Done():
|
logger.Info("proc close, self update exit")
|
return
|
case <-tick:
|
var compsoeModel models.CameraCompose
|
api := bhomedbapi.CameraApi{}
|
cameras := api.FindAll("", "", "", "")
|
logger.Debug(cameras)
|
var cameraIds = make([]string, 0)
|
for _, camera := range cameras {
|
compsoeModel.Status = 0
|
compsoeModel.CameraId = camera.Id
|
compsoeModel.Save(false)
|
cameraIds = append(cameraIds, camera.Id)
|
}
|
compsoeModel.DeleteNoExist(cameraIds)
|
}
|
}
|
}
|
|
func (sv CameraComposeService) GetAll() ([]CameraComposeDetail, error) {
|
var compsoeModel models.CameraCompose
|
composeList, err := compsoeModel.FindAll()
|
if nil != err {
|
return nil, err
|
}
|
api := bhomedbapi.CameraApi{}
|
var details []CameraComposeDetail
|
|
var apiRule bhomedbapi.CameraRuleApi
|
b, allCamRules := apiRule.FindAll()
|
|
ruleM := make(map[string]protomsg.CameraAndRules)
|
if b && allCamRules != nil {
|
for _, r := range allCamRules {
|
if r.CameraInfo != nil {
|
ruleM[r.CameraInfo.Id] = r
|
}
|
}
|
}
|
for _, item := range composeList {
|
cam, err := api.GetCameraById(item.CameraId)
|
if nil == err {
|
isAi := false
|
if crInfo, ok := ruleM[item.CameraId]; ok && crInfo.Rules != nil && len(crInfo.Rules) > 0 && (cam.RunType == models.TYPE_RUNTYPE_POLL || cam.RunType == models.TYPE_RUNTYPE_REALTIME) {
|
isAi = true
|
}
|
details = append(details, CameraComposeDetail{CameraId: item.CameraId, Status: item.Status, Rtsp: cam.Rtsp, CameraType: int(cam.Type), IsRunning: cam.IsRunning, IsAI: isAi, Name: cam.Name, Type: "4", Id: item.CameraId})
|
}
|
}
|
return details, nil
|
}
|
|
//同步更新设置
|
func PersistentWrapper(topic string, payloads []byte) {
|
var cameraComposeList []CameraComposeMsg
|
if err := json.Unmarshal(payloads, &cameraComposeList); nil != err {
|
logger.Error("handleSubMsg failed to persistent:", topic, string(payloads))
|
}
|
var cameraCompose models.CameraCompose
|
var cameraPerson models.CameraComposePerson
|
//cameraCompose.Clean()
|
|
for _, item := range cameraComposeList {
|
cameraCompose.CameraId = item.CameraId
|
cameraCompose.Status = item.Status
|
cameraCompose.Save(true)
|
cameraPerson.CameraId = item.CameraId
|
cameraPerson.Clean()
|
for _, personId := range item.Ids {
|
cameraPerson.Status = item.Status
|
cameraPerson.PersonId = int(personId)
|
cameraPerson.Save()
|
}
|
}
|
}
|
