灯控建表

app/controller/lightController.go

@@ -2,6 +2,10 @@ package controller
 
 import (
 	"github.com/gin-gonic/gin"
+	"iot_manager_service/app/service"
+	"iot_manager_service/app/utils"
+	"net/http"
+	"strconv"
 )
 
 // 灯控基本信息管理对象
@@ -10,6 +14,18 @@ var Light = new(lightCtl)
 type lightCtl struct{}
 
 func (c *lightCtl) Detail(ctx *gin.Context) {
+	id, e := strconv.Atoi(ctx.Query("id"))
+	if e != nil {
+		ctx.JSON(http.StatusOK, utils.ParamsInvalidResponse(e.Error(), nil))
+		return
+	}
+
+	device, err := service.LightControlService.Get(id)
+	if err != nil {
+		ctx.JSON(http.StatusOK, err)
+		return
+	}
+	ctx.JSON(http.StatusOK, utils.SuccessResponse(utils.Succeeded, device))
 }
 
 func (c *lightCtl) List(ctx *gin.Context) {

app/dao/common.go

@@ -1,6 +1,7 @@
 package dao
 
 import (
+	"fmt"
 	_ "github.com/go-sql-driver/mysql"
 	"github.com/jinzhu/gorm"
 	"iot_manager_service/config"
@@ -20,6 +21,10 @@ func InitDB() {
 		GDb.DB().SetMaxOpenConns(32)
 		GDb.DB().SetMaxIdleConns(5)
 		GDb.LogMode(false)
-		GDb.AutoMigrate(&LampPoleGroup{}, &LampPole{}, &Gateway{}, &GatewayRelation{}, &Transformer{})
+		err = GDb.AutoMigrate(&LampPoleGroup{}, &LampPole{}, &Gateway{}, &GatewayRelation{}, &Transformer{},
+			&LightControl{}).Error
+		if err != nil {
+			panic(fmt.Sprintf("AutoMigrate err : %v", err))
+		}
 	}
 }

app/dao/lightControlDao.go

@@ -0,0 +1,107 @@
+package dao
+
+import (
+	"github.com/jinzhu/gorm"
+	"time"
+)
+
+//LightControl 灯控
+type LightControl struct {
+	ID               int       `gorm:"primary_key" json:"id"`                       //编号
+	Name             string    `gorm:"type:varchar(64)"  json:"name"`               //名称
+	SN               string    `gorm:"type:varchar(60)" json:"sn"`                  //设备序列号
+	ControlType      int       `gorm:"type:int" json:"controlType"`                 //控制器类型 type：0=485灯控，1=NB-iot箱
+	GroupId          int       `gorm:"type:int" json:"groupId"`                     //所属灯杆分组
+	GatewayId        int       `gorm:"type:varchar(32)" json:"gatewayId"`           //所属网关id
+	LampPoleId       int       `gorm:"type:int" json:"lamp_pole_id"`                //所属灯杆 灯杆ID
+	LampPoleName     string    `gorm:"type:varchar(64)" json:"lamp_pole_name"`      //灯杆名称
+	LampPoleSN       string    `gorm:"type:varchar(64)" json:"lamp_pole_sn"`        //灯杆SN
+	LampPoleLocation string    `gorm:"type:varchar(255)" json:"lamp_pole_location"` //灯杆安装位置
+	LampLat          float64   `gorm:"type:double(17,14)" json:"lampLat"`           //纬度
+	LampLng          float64   `gorm:"type:double(17,14)" json:"lampLng"`           //经度
+	RatedPower       float32   `gorm:"type:double(8,2)" json:"ratedPower"`          //额定功率(LED灯)
+	BrandId          int       `gorm:"type:int" json:"brandId"`                     //设备品牌
+	ModelId          int       `gorm:"type:int" json:"modelId"`                     //设备型号
+	InstallTime      time.Time `gorm:"type:date" json:"installTime"`                //安装时间
+	TenantId         string    `gorm:"type:varchar(12)" json:"tenantId"`            //租户ID
+	CreateTime       time.Time `gorm:"type:datetime" json:"createTime"`             //新增时间
+	CreateUser       string    `gorm:"type:varchar(60)" json:"createUser"`          //新增记录操作用户ID
+	UpdateTime       time.Time `gorm:"type:datetime" json:"updateTime"`             //修改时间
+	UpdateUser       string    `gorm:"type:varchar(60)" json:"updateUser"`          //修改用户
+	IsDeleted        int       `gorm:"type:int;default 0" json:"isDeleted"`         //是否删除 0=未删除,1=删除
+	Status           int       `gorm:"type:int" json:"status"`                      //状态 0=正常,1=异常
+	Tag              string    `gorm:"type:varchar(255)" json:"tag"`                //标签，(备用，逗号区分)
+	ControlNO        string    `gorm:"type:varchar(10)" json:"controlNo"`           //编号
+	ChannelNum       int       `gorm:"type:int" json:"channelNum"`                  //通道号
+	NetworkNum       int       `gorm:"type:int" json:"networkNum"`                  //网络号
+	ZigbeeId         string    `gorm:"type:varchar(10)" json:"zigbeeId"`            //zigbeeID
+	ZigbeeName       string    `gorm:"type:varchar(10)" json:"zigbeeName"`          //zigbee名称
+	ZigbeeSn         string    `gorm:"type:varchar(10)" json:"zigbeeSn"`            //zigbee编码
+	IsEnable         int       `gorm:"type:int" json:"isEnable"`                    //启用禁用：1启用2禁用
+	IsOnDemand       int       `gorm:"type:int" json:"isOnDemand"`                  //灯控类型：0-普通灯控，1-灯随车走灯控
+}
+
+func (LightControl) TableName() string {
+	return "t_dev_light_control"
+}
+
+func (c *LightControl) Delete() error {
+	return GDb.Model(&c).Where("id = ?", c.ID).Updates(map[string]interface{}{"update_time": c.UpdateTime,
+		"update_user": c.UpdateUser, "is_deleted": c.IsDeleted}).Error
+}
+
+func (c LightControl) IsExistedBySN() bool {
+	var count = 0
+	_ = GDb.Model(&c).Where("sn = ? and is_deleted = ?",
+		c.SN, c.IsDeleted).Count(&count).Error
+	return count > 0
+}
+
+func (c LightControl) IsExistedByNameAndCode() bool {
+	var devices []LightControl
+	err := GDb.Model(&c).Where("pole_sn = ? and is_deleted = ?",
+		c.TenantId, c.IsDeleted).Find(&devices).Error
+	if gorm.IsRecordNotFoundError(err) {
+		return false
+	}
+	for _, d := range devices {
+		if d.ID != c.ID {
+			return true
+		}
+	}
+	return false
+}
+
+func (c *LightControl) Create() error {
+	return GDb.Model(&c).Save(&c).Error
+}
+
+func (c *LightControl) Update() error {
+	return GDb.Model(&c).Where(" id = ? ", c.ID).Update(&c).Error
+}
+
+func (c *LightControl) GetDevice() error {
+	err := GDb.Model(&c).Where(" id = ? ", c.ID).First(&c).Error
+	return err
+}
+
+func (c LightControl) GetDevices(offset, limit int) ([]LightControl, error) {
+	var devices []LightControl
+
+	db := GDb.Model(&c)
+	if c.SN != "" {
+		db = db.Where("name like ? or sn like ?", "%"+c.SN+"%", "%"+c.Name+"%")
+	}
+	if c.GroupId != -1 {
+		db = db.Where("group_id = ?", c.GroupId)
+	}
+
+	err := db.Offset(offset).Limit(limit).Find(&devices).Error
+	return devices, err
+}
+
+func (c LightControl) GetAllDevices() ([]*LightControl, error) {
+	var devices []*LightControl
+	err := GDb.Model(&c).Where(" tenant_id = ? and is_deleted = ? ", c.TenantId, c.IsDeleted).Scan(&devices).Error
+	return devices, err
+}

app/model/lightControl.go

@@ -0,0 +1,40 @@
+package model
+
+import (
+	"iot_manager_service/app/dao"
+)
+
+type LightControlDetail struct {
+	dao.LightControl
+	IsCrossName       string          `json:"isCrossName"`           //是否路口名称
+	TagName           string          `json:"tagName"`               //标签(中文)
+	ProvincesName     string          `json:"provincesName"`         //省市区组合地址
+	GatewaySn         string          `json:"gatewaySn"`             //网关编码
+	BoxSn             string          `json:"boxSn"`                 //配电箱编码
+	RunState          string          `json:"runState"`              //运行状态
+	PoleGroupName     string          `json:"poleGroupName"`         //灯杆分组名称
+	BoxName           string          `json:"boxName"`               //配电箱名称
+	AlarmTerminalList []AlarmTerminal `json:"akeyAlarmTerminalList"` //一键告警集合
+	CameraList        []Camera        `json:"cameraList"`            //摄像头集合
+	CaptureUnitList   []CaptureUnit   `json:"captureUnitList"`       //抓拍单元集合
+	GatewayList       []Gateway       `json:"gatewayList"`           //网关集合
+	InfoBoardList     []InfoBoard     `json:"infoBoardList"`         //信息屏集合
+	IpBroadcastList   []IpBroadcast   `json:"ipBroadcastList"`       //IP音柱集合
+	LightControlList  []LightControl  `json:"lightControlList"`      //灯控集合
+	SensorList        []Sensor        `json:"sensorList"`            //环境监测集合
+	ZigbeeList        []Zigbee        `json:"zigbeeList"`            //ZigBee集合
+}
+
+type RspLightControlList struct {
+	Records []LightControlDetail `json:"records"` //记录列表
+	Current int                  `json:"current"` //当前分页
+	Size    int                  `json:"size"`    //每页数量
+	Total   int                  `json:"total"`   //总数
+	Pages   int                  `json:"pages"`   //总页数
+}
+
+type ReqLightControlRemove struct {
+	IDs  int    `json:"ids"`  //分组编码
+	SN   int    `json:"sn"`   //sn
+	Name string `json:"name"` //名称
+}

app/service/lightControlService.go

@@ -0,0 +1,146 @@
+package service
+
+import (
+	"fmt"
+	"iot_manager_service/app/dao"
+	"iot_manager_service/app/model"
+	"iot_manager_service/app/utils"
+	"time"
+)
+
+// 中间件管理服务
+var LightControlService = new(lightControlService)
+
+type lightControlService struct{}
+
+func (s *lightControlService) Get(id int) (*dao.LightControl, *utils.Errors) {
+	// 创建查询实例
+	device := &dao.LightControl{
+		ID: id,
+	}
+	err := device.GetDevice()
+	if err != nil {
+		return nil, utils.FailResponse(err.Error(), nil)
+	}
+	//todo runstate 需要使用各个设备的状态来处理
+	return device, nil
+}
+
+func (s *lightControlService) GetRelevanceDetail(id int) (*model.LightControlDetail, *utils.Errors) {
+	// 创建查询实例
+	device := &dao.LightControl{
+		ID: id,
+	}
+	err := device.GetDevice()
+	if err != nil {
+		return nil, utils.FailResponse(err.Error(), nil)
+	}
+	//todo get gateway ipBroadcast lightcontroller... list
+	return &model.LightControlDetail{
+		LightControl:      *device,
+		AlarmTerminalList: nil,
+		CameraList:        nil,
+		CaptureUnitList:   nil,
+		GatewayList:       nil,
+		InfoBoardList:     nil,
+		IpBroadcastList:   nil,
+		LightControlList:  nil,
+		SensorList:        nil,
+		ZigbeeList:        nil,
+	}, nil
+}
+
+func (s *lightControlService) CreateOrUpdate(req *dao.LightControl) *utils.Errors {
+	device := req
+	if device.TenantId == "" {
+		device.TenantId = "000000" // todo: 使用登录态
+	}
+	device.UpdateUser = "TODO" // todo: 使用登录态
+	device.UpdateTime = time.Now()
+
+	if device.ID == 0 {
+		device.CreateTime = time.Now()
+		device.CreateUser = "TODO" // todo: 使用登录态
+
+		if device.IsExistedBySN() {
+			fmt.Printf("Create IsExistedBySN \n")
+			return utils.ParamsInvalidResponse(model.RepeatedPrompts, nil)
+		}
+		fmt.Printf("device = %+v \n", device)
+		if err := device.Create(); err != nil {
+			fmt.Printf("Create err = %s \n", err.Error())
+			return utils.FailResponse(err.Error(), nil)
+		}
+		return utils.SuccessResponse(utils.Succeeded, nil)
+	}
+
+	if err := device.Update(); err != nil {
+		fmt.Printf("Update err = %s \n", err.Error())
+		return utils.FailResponse(err.Error(), nil)
+	}
+
+	//todo operation record
+	return utils.SuccessResponse(utils.Succeeded, nil)
+}
+
+func (s *lightControlService) List(searchValue, groupId, boxId string, current, size int) ([]dao.LightControl, *utils.Errors) {
+	device := dao.LightControl{}
+	if searchValue != "" {
+		device.SN = searchValue
+	}
+
+	device.GroupId = utils.StringToInt(groupId)
+
+	offset := (current - 1) * size
+	limit := size
+	devices, err := device.GetDevices(offset, limit)
+	if err != nil {
+		return nil, utils.FailResponse(err.Error(), nil)
+	}
+	return devices, nil
+}
+
+func (s *lightControlService) Remove(id int) *utils.Errors {
+	// 创建查询实例
+	device := &dao.LightControl{
+		ID:         id,
+		IsDeleted:  1,
+		UpdateUser: "TODO", // todo 使用登录态
+		UpdateTime: time.Now(),
+	}
+
+	//todo
+	// service.lampPoleService.CountRelation()
+
+	//todo operation record
+	err := device.Delete()
+	if err != nil {
+		return utils.FailResponse(err.Error(), nil)
+	}
+	return nil
+}
+
+func (s *lightControlService) GetList() ([]*dao.LightControl, *utils.Errors) {
+	// todo use redis cache
+	device := &dao.LightControl{
+		TenantId:  "000000", // todo 使用登录态
+		IsDeleted: 0,
+	}
+	devices, err := device.GetAllDevices()
+	if err != nil {
+		return nil, utils.FailResponse(err.Error(), nil)
+	}
+
+	return devices, nil
+}
+
+func (s *lightControlService) GetOne(id int) (*dao.LightControl, *utils.Errors) {
+	device := &dao.LightControl{
+		ID: id,
+	}
+	err := device.GetDevice()
+	if err != nil {
+		return nil, utils.FailResponse(err.Error(), nil)
+	}
+	return device, nil
+}