package daos

import (
	"fmt"
	"gitee.com/aywc_1/aywc_judge/src/models"
	"gitee.com/aywc_1/aywc_judge/src/utils"
	"github.com/jinzhu/gorm"
	"github.com/shenyisyn/goft-gin/goft"
	log "github.com/sirupsen/logrus"
)

type DeviceWarmDao struct {
	Db *gorm.DB `inject:"-"`
}

func NewDeviceWarmDao() *DeviceWarmDao {
	return &DeviceWarmDao{}
}

func (this *DeviceWarmDao) GetDeviceWarmList() goft.SimpleQuery {
	return "select device_id, max(device_name) as device_name, max(create_time) as create_time,group_concat(concat(id,'_',upload_file_name) separator '###') as pictures from device_warm where status=1  group by device_id order by create_time desc"
}

func (this *DeviceWarmDao) GetDeviceWarmById(uid string) goft.Query {
	return goft.SimpleQuery(`SELECT
				*
			FROM
				device_warm 
			WHERE
				id = ?`).WithArgs(uid).WithFirst()
}

func (this *DeviceWarmDao) FindDeviceWarmByDeviceId(uid string) *models.DeviceWarmModel {
	deviceWarm := &models.DeviceWarmModel{}
	this.Db.Table("device_warm").Where("device_id = ?", uid).First(deviceWarm)
	if deviceWarm.Id == "" {
		log.Error("device warm_id %d is not exists", uid)
		panic(fmt.Sprintf("device warm_id %d is not exists", uid))
	}
	return deviceWarm
}

func (this *DeviceWarmDao) IsExistDeviceUser(id string) (int, error) {
	var total int
	err := this.Db.Raw("select count(1) from msys_device_user where device_id = ?  ", id).Count(&total).Error
	//this.Db.LogMode(true)
	if err != nil {
		return 0, err
	}
	return total, nil
}

func (this *DeviceWarmDao) UpdateDeviceUserInfo(form *models.DeviceUserModel) error {

	return nil
}

func (this *DeviceWarmDao) InsertDeviceUserInfo(form *models.DeviceUserModel) error {
	itemId, err := utils.GetID()
	if err != nil {
		log.Errorf("Failed to snowflake GetID,err:%s\n", err.Error())
		panic(fmt.Sprintf("Failed to snowflake GetID,err:%s\n", err.Error()))
	}
	err = this.Db.Exec("insert into msys_device_user (id,device_id,status,rc_id,rc_name,device_name,create_time,create_user_id) VALUES (?,?,?,?,?,?,now(),'-1')", itemId, form.DeviceId, form.Status, form.RcId, form.RcName, form.DeviceName).Error
	//this.Db.LogMode(true)
	if err != nil {
		return err
	}
	return nil
}

func (this *DeviceWarmDao) IsExistDeviceUserPhone(phone string) (int, error) {
	var total int
	err := this.Db.Raw("select count(1) from msys_device_user_phone where  phone =? ", phone).Count(&total).Error
	//this.Db.LogMode(true)
	if err != nil {
		return 0, err
	}
	return total, nil
}

/**
alter table msys_device_user_phone add unique index(device_id,phone);
*/
func (this *DeviceWarmDao) InsertDeviceUserPhoneInfo(form *models.DeviceUserPhoneModel) error {
	itemId, err := utils.GetID()
	if err != nil {
		log.Errorf("Failed to snowflake GetID,err:%s\n", err.Error())
		panic(fmt.Sprintf("Failed to snowflake GetID,err:%s\n", err.Error()))
	}
	err = this.Db.Exec("insert into msys_device_user_phone (id,device_id,status,rc_id,rc_name,phone,create_time,create_user_id) VALUES (?,?,?,?,?,?,now(),'-1')", itemId, form.DeviceId, form.Status, form.RcId, form.RcName, form.Phone).Error
	//this.Db.LogMode(true)
	if err != nil {
		return err
	}
	return nil
}

func (this *DeviceWarmDao) InsertDeviceUserRelationship(deviceId string, bind string) error {
	itemId, err := utils.GetID()
	if err != nil {
		log.Errorf("Failed to snowflake GetID,err:%s\n", err.Error())
		panic(fmt.Sprintf("Failed to snowflake GetID,err:%s\n", err.Error()))
	}
	err = this.Db.Exec("insert into msys_device_user_relationship (id,device_id,rs_device_id,create_user_id,create_time) VALUES (?,?,?,'-1',now())", itemId, deviceId, bind).Error
	//this.Db.LogMode(true)
	if err != nil {
		return err
	}
	return nil
}

func (this *DeviceWarmDao) DeleteDeviceUserRelationship(deviceId string, unbind string) error {

	result := this.Db.Exec("delete from msys_device_user_relationship  where device_id = ? and rs_device_id = ? ", deviceId, unbind)
	//this.Db.LogMode(true)
	var idAff = result.RowsAffected
	if idAff == 0 {
		log.Println("unbind failed:", nil)
		panic(fmt.Sprintf("RowsAffected:", 0))
	}
	if result.Error != nil {
		log.Println("unbind failed:", result.Error)
		return result.Error
	}
	return nil
}

func (this *DeviceWarmDao) IsExistDeviceUserRelationShip(id string, bind string) (int, error) {
	var total int
	err := this.Db.Raw("select count(1) from msys_device_user_relationship where device_id = ? and rs_device_id =? ", id, bind).Count(&total).Error
	//this.Db.LogMode(true)
	if err != nil {
		return 0, err
	}
	return total, nil
}

func (this *DeviceWarmDao) CountDeviceUserList() (int, error) {
	var total int
	err := this.Db.Raw("select count(1) from msys_device_user where status = '1' ").Count(&total).Error
	//this.Db.LogMode(true)
	if err != nil {
		return 0, err
	}
	return total, nil
}

func (this *DeviceWarmDao) CountDeviceUserRelationShipList(deviceId string) (int, error) {
	var total int
	err := this.Db.Raw("select count(1) from msys_device_user_relationship a inner join msys_device_user b on a.rs_device_id=b.device_id where a.device_id= ?  and b.status='1'  ", deviceId).Count(&total).Error
	//this.Db.LogMode(true)
	if err != nil {
		return 0, err
	}
	return total, nil
}