lc_veterans/app/device/dao/intelligentLightingDao.go

package dao

import (
	"fmt"
	"time"
)

type LightrelationVo struct {
	ID                 int    `json:"id"`
	LightID            int    `json:"lightId"`
	RelationType       int    `json:"relationType"`
	Rid                int    `json:"rid"`
	CreateTime         string `json:"createTime"`
	CreateUser         string `json:"createUser"`
	UpdateTime         string `json:"updateTime"`
	UpdateUser         string `json:"updateUser"`
	IsDeleted          int    `json:"isDeleted"`
	TenantID           string `json:"tenantId"`
	IsAutomaticRenewal int    `json:"isAutomaticRenewal"`
	EffectiveDate      string `json:"effectiveDate"`
	EndTime            string `json:"endTime"`
	DeviceSn           string `json:"deviceSn"`
	Location           string `json:"location"`

	LightControlState  string             `json:"lightControlState"`
	IsShowOpts         bool               `json:"isShowOpts"`
	PublicID           int                `json:"publicId"`
	CombinationStrList []interface{}      `gorm:"-" json:"combinationStrList"`
	RunState           string             `json:"runState"`
	Children           *[]LightrelationVo `gorm:"-" json:"children"`
	GroupID            int                `json:"groupId"`
	LampPoleSn         string             `json:"lampPoleSn"`
	LightName          string             `json:"lightName"`
	ControlType        int                `json:"controlType"`
	InstallTime        string             `json:"installTime"`
	LampPoleName       string             `json:"lampPoleName"`
	IsAllYear          int                `json:"isAllYear"`
	PublicName         string             `json:"publicName"`
	StartTime          string             `json:"startTime"`
	LightSn            string             `json:"lightSn"`
	HandSwitch         int                `json:"handSwitch"`
	CombinationStr     string             `json:"combinationStr"`
	LampLng            float64            `json:"lampLng"`
	LampLat            float64            `json:"lampLat"`
}

type IntelligentLightGroupRelation struct {
	IntelligentLight
	LightStrategy
	LightControl
	TimeCondition
	PublicName string `gorm:"_" json:"publicName"`
}

type IntelligentLight struct {
	ID           int       `gorm:"primary key" json:"id"`               //编号
	LightID      int       `gorm:"type:int" json:"lightID"`             //照明策略id
	RelationType int       `gorm:"type:int" json:"relationType"`        //关联类型1=灯控，2=灯杆分组
	Rid          int       `gorm:"type:int" json:"rid"`                 //关联外键ID 根据type类型关联至其表
	TenantId     string    `gorm:"type:varchar(12)" json:"tenantId"`    //租户ID
	CreateTime   time.Time `gorm:"type:datetime" json:"createTime"`     //新增时间
	CreateUser   int       `gorm:"type:int" json:"createUser"`          //新增记录操作用户ID
	UpdateTime   time.Time `gorm:"type:datetime" json:"updateTime"`     //修改时间
	UpdateUser   int       `gorm:"type:int" json:"updateUser"`          //修改用户
	IsDeleted    int       `gorm:"type:int;default 0" json:"isDeleted"` //是否删除 0=未删除,1=删除
}

func (IntelligentLight) TableName() string {
	return "strategy_intelligent_light"
}

// CreateDefaultStrategyByLight 创建默认
func (c *IntelligentLight) CreateDefaultStrategyByLight(rid int, relationType int, lightId int) error {
	var intelligentLights IntelligentLight
	intelligentLights.LightID = lightId
	intelligentLights.RelationType = relationType
	intelligentLights.Rid = rid
	intelligentLights.TenantId = c.TenantId
	intelligentLights.CreateTime = time.Now()
	intelligentLights.UpdateTime = time.Now()
	err := Db.Model(&c).Save(&intelligentLights).Error
	return err
}

// 批量获取
func (c *IntelligentLight) BatchGet(ids []int) ([]IntelligentLight, error) {
	var intelligentLights []IntelligentLight
	err := Db.Model(&c).Where("light_id in ? and is_deleted = 0", ids).Find(&intelligentLights).Error
	return intelligentLights, err
}

func (c *IntelligentLight) GetByRidAndType() ([]IntelligentLight, error) {
	var intelligentLights []IntelligentLight
	db := Db.Model(&c).Where("relation_type = ? and is_deleted = 0 and tenant_id = ?",
		c.RelationType, c.TenantId)
	if c.Rid > 0 {
		db = db.Where("rid = ?", c.Rid)
	}
	err := db.Find(&intelligentLights).Error
	return intelligentLights, err
}

func (c *IntelligentLight) GetByGroup2(searchValue string, current, size,
	groupId int) ([]LightrelationVo, error) {
	var groupRelations []LightrelationVo
	where := "lig.tenant_id = ?"
	if groupId != 0 {
		where += fmt.Sprintf(" AND lig.rid in(%v)", groupId)
	}
	sql := `SELECT lig.*,gro.id public_id,gro.pole_group_name public_name,b.light_name,b.light_sn,b.start_time,b.end_time,b.is_all_year,b.is_automatic_renewal
        FROM strategy_intelligent_light lig
        LEFT JOIN device_lamp_pole_group gro ON lig.rid=gro.id
        LEFT JOIN strategy_light b ON b.id=lig.light_id
        WHERE lig.is_deleted=0 AND lig.relation_type=2 AND gro.is_deleted=0
				and ` + where + `
        ORDER BY lig.create_time desc`
	tx := Db.Raw(sql, c.TenantId).Scan(&groupRelations)
	return groupRelations, tx.Error
}

func (c *IntelligentLight) GetByGroup(searchValue string, current, size,
	groupId int) ([]LightrelationVo, int64, error) {
	var groupRelations []LightrelationVo
	where := " AND con.tenant_id = ?"
	if groupId != 0 {
		where += fmt.Sprintf(" AND con.group_id in(%v)", groupId)
	}
	if searchValue != "" {
		where += fmt.Sprintf(" and (con.sn like '%%v%' or con.name like '%$v%')", searchValue)
	}
	offset := (current - 1) * size
	limit := size

	sql := `SELECT
			lig.*,
			con.control_type,
			con.id public_id,
			con.NAME public_name,
			con.sn device_sn,
			con.lamp_pole_name,
			con.lamp_pole_sn,
			con.group_id,
			con.lamp_lat,
			con.lamp_lng,
			con.id as rid,
		
			b.light_name,
			b.light_sn,
			b.start_time,
			b.end_time,
			is_all_year,
			b.is_automatic_renewal,
			con.lamp_pole_location,
			con.install_time 
		FROM
			device_light_control con
			left  JOIN strategy_intelligent_light lig ON  con.id = lig.rid 
			LEFT JOIN strategy_light b ON b.id = lig.light_id
		WHERE
			con.is_deleted = 0
			
			` + where + `
		ORDER BY
			con.name asc `

	var count int64
	Db.Raw(sql, c.TenantId).Count(&count)
	sql += `limit ?,?`
	tx := Db.Raw(sql, c.TenantId, offset, limit).Scan(&groupRelations)
	return groupRelations, count, tx.Error

}

func (c IntelligentLight) Update() error {
	return Db.Model(&c).Where(" id = ? and is_deleted = 0", c.ID).Updates(&c).Error
}

func (c IntelligentLight) Get() (IntelligentLight, error) {
	var intelligentLight IntelligentLight
	err := Db.Model(&c).Where("is_deleted = 0 and rid = ? and relation_type = ?", c.Rid, c.RelationType).First(&intelligentLight).Error
	return intelligentLight, err
}