ColdVerify_server/controllers/DeviceClass.go

package controllers

import (
	"ColdVerify_server/conf"
	"ColdVerify_server/lib"
	"ColdVerify_server/logs"
	"ColdVerify_server/models/Account"
	"ColdVerify_server/models/Certificate"
	"ColdVerify_server/models/Device"
	"ColdVerify_server/models/System"
	"ColdVerify_server/models/Task"
	"ColdVerify_server/models/VerifyTemplate"
	"fmt"
	"math"
	"strconv"
	"strings"

	beego "github.com/beego/beego/v2/server/web"
)

type DeviceClassController struct {
	beego.Controller
}

// 列表 -
func (c *DeviceClassController) List() {
	// 验证登录 User_is, User_r
	User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
	if !User_is {
		c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
		c.ServeJSON()
		return
	}

	var r_jsons lib.R_JSONS
	page, _ := c.GetInt("page")
	if page < 1 {
		page = 1
	}
	page_z, _ := c.GetInt("page_z")
	if page_z < 1 {
		page_z = conf.Page_size
	}

	T_name := c.GetString("T_name")

	var cnt int64
	List, cnt := Device.Read_DeviceClass_List(User_r.T_uuid, T_name, page, page_z)
	page_size := math.Ceil(float64(cnt) / float64(page_z))
	r_jsons.List = List
	r_jsons.Page = page
	r_jsons.Page_size = int(page_size)
	r_jsons.Pages = lib.Func_page(int64(page), int64(page_size))
	r_jsons.Num = int(cnt)

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
	c.ServeJSON()
	return
}

// 获取-
func (c *DeviceClassController) Get() {
	// 验证登录 User_is, User_r
	_, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
	if !User_is {
		c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
		c.ServeJSON()
		return
	}

	Id, err := c.GetInt("Id")
	if err != nil {
		c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id 错误!"}
		c.ServeJSON()
		return
	}

	r, is := Device.Read_DeviceClass_ById(Id)
	if !is {
		c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id 错误!"}
		c.ServeJSON()
		return
	}

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r}
	c.ServeJSON()
	return
}

// 添加-
func (c *DeviceClassController) Add() {
	// 验证登录 User_is, User_r
	User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
	if !User_is {
		c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
		c.ServeJSON()
		return
	}

	T_name := c.GetString("T_name")

	var_ := Device.DeviceClass{
		T_uuid:  User_r.T_uuid,
		T_name:  T_name,
		T_State: 1,
	}

	Id, is := Device.Add_DeviceClass(var_)
	if !is {
		c.Data["json"] = lib.JSONS{Code: 202, Msg: "添加失败!"}
		c.ServeJSON()
		return
	}
	System.Add_UserLogs_T(User_r.T_uuid, "分类管理", "添加", var_)
	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: Id}
	c.ServeJSON()
	return
}

// 修改-
func (c *DeviceClassController) Up() {
	// 验证登录 User_is, User_r
	User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
	if !User_is {
		c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
		c.ServeJSON()
		return
	}

	T_name := c.GetString("T_name")

	Id, err := c.GetInt("Id")
	if err != nil {
		c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id 错误!"}
		c.ServeJSON()
		return
	}

	r, is := Device.Read_DeviceClass_ById(Id)
	if !is {
		c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id 错误!"}
		c.ServeJSON()
		return
	}

	// .......
	if len(T_name) > 0 {
		r.T_name = T_name
	}

	// .......
	if !Device.Update_DeviceClass(r, "T_name") {
		c.Data["json"] = lib.JSONS{Code: 202, Msg: "修改失败!"}
		c.ServeJSON()
		return
	}
	System.Add_UserLogs_T(User_r.T_uuid, "分类管理", "修改", r)
	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
	c.ServeJSON()
	return
}

// 删除-
func (c *DeviceClassController) Del() {
	// 验证登录 User_is, User_r
	User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
	if !User_is {
		c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
		c.ServeJSON()
		return
	}

	Id, err := c.GetInt("Id")
	if err != nil {
		c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id 错误!"}
		c.ServeJSON()
		return
	}

	if r, is := Device.Read_DeviceClass_ById(Id); is {

		if !Device.Delete_DeviceClass_(r) {
			c.Data["json"] = lib.JSONS{Code: 202, Msg: "删除失败！"}
			c.ServeJSON()
			return
		}
		System.Add_UserLogs_T(User_r.T_uuid, "分类管理", "删除", r)

		c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
		c.ServeJSON()
		return
	}

	c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id 错误!"}
	c.ServeJSON()
	return
}

//--------------------------

// 列表 -
func (c *DeviceClassController) List_List() {
	// 验证登录 User_is, User_r
	//_, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
	//if !User_is {
	//	c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
	//	c.ServeJSON()
	//	return
	//}

	var r_jsons lib.R_JSONS
	page, _ := c.GetInt("page")
	if page < 1 {
		page = 1
	}
	page_z, _ := c.GetInt("page_z")
	if page_z < 1 {
		page_z = conf.Page_size
	}

	T_class, _ := c.GetInt("T_class")
	T_sn := c.GetString("T_sn")
	T_remark := c.GetString("T_remark")

	_, is := Device.Read_DeviceClass_ById(T_class)
	if !is {
		c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_class 错误!"}
		c.ServeJSON()
		return
	}

	var cnt int64
	//List, cnt := Device.Read_DeviceClassList_List(T_class, T_sn, page, 9999)
	List, cnt := Device.Read_DeviceClassList_OrderList(T_class, T_sn, "", T_remark, page, 9999)

	page_size := math.Ceil(float64(cnt) / float64(page_z))
	r_jsons.List = List
	r_jsons.Page = page
	r_jsons.Page_size = int(page_size)
	r_jsons.Pages = lib.Func_page(int64(page), int64(page_size))
	r_jsons.Num = int(cnt)

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
	c.ServeJSON()
	return
}

// 添加- 旧功能
func (c *DeviceClassController) List_Add1() {
	// 验证登录 User_is, User_r
	User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
	if !User_is {
		c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
		c.ServeJSON()
		return
	}

	T_class, _ := c.GetInt("T_class")
	//方式1：001,002,003,004,005,008
	//方式2：001~005,008
	T_layout_no_list := c.GetString("T_layout_no_list")
	//T_sn := c.GetString("T_sn")
	T_remark := c.GetString("T_remark")

	_, is := Device.Read_DeviceClass_ById(T_class)
	if !is {
		c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_class 错误"}
		c.ServeJSON()
		return
	}

	list := strings.Split(strings.TrimRight(T_layout_no_list, ","), ",")
	snMap := make(map[string]string)
	excludeId := make(map[string]struct{})
	errList := []string{}
	var successNum int // 成功数量
	for _, v := range list {
		if strings.Contains(v, "!") {
			excludeId[fmt.Sprintf("%03d", lib.To_int(strings.TrimLeft(strings.Trim(v, "!"), "0")))] = struct{}{}
			continue
		}
		// 001~005
		if strings.Contains(v, "~") {
			vlist := strings.Split(v, "~")
			if len(vlist) != 2 {
				c.Data["json"] = lib.JSONS{Code: 202, Msg: "布局编号格式错误!"}
				c.ServeJSON()
				return
			}
			vstart, vend := lib.To_int(strings.TrimLeft(vlist[0], "0")), lib.To_int(strings.TrimLeft(vlist[1], "0"))
			for i := vstart; i < vend+1; i++ {
				T_id := fmt.Sprintf("%03d", i)
				cert, is := Certificate.Read_Certificate_ByT_layout_no(T_id)
				if !is {
					//c.Data["json"] = lib.JSONS{Code: 202, Msg: fmt.Sprintf("%s布局编号不存在!", T_id)}
					//c.ServeJSON()
					//return

					errList = append(errList, fmt.Sprintf("%s布局编号不存在!", T_id))
					continue
				}
				snMap[T_id] = cert.T_sn
			}
		} else {
			// 001,002
			cert, is := Certificate.Read_Certificate_ByT_layout_no(v)
			if !is {
				//c.Data["json"] = lib.JSONS{Code: 202, Msg: fmt.Sprintf("%s布局编号不存在!", v)}
				//c.ServeJSON()
				//return

				errList = append(errList, v)
				continue
			}
			snMap[v] = cert.T_sn
		}

	}
	errList2 := []string{}
	succesId := []string{}
	for T_id, T_sn := range snMap {
		if _, ok := excludeId[T_id]; ok {
			continue
		}

		//if _, is = Device.Read_Device(T_sn); !is {
		//	c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_sn 不存在!"}
		//	c.ServeJSON()
		//	return
		//}

		if dc, is := Device.Read_DeviceClassList_T_class_T_sn(T_class, T_sn); is && dc.Id > 0 {
			successNum += 1
			continue
		}

		var pdf Certificate.CertificatePdf
		pdfList, _ := Certificate.Read_CertificatePdf_Newest(T_id)
		if len(pdfList) > 0 {
			pdf = pdfList[0]
		}

		var_ := Device.DeviceClassList{
			T_class:        T_class,
			T_id:           T_id,
			T_sn:           T_sn,
			T_failure_time: pdf.T_failure_time,
			T_pdf:          pdf.T_pdf,
			T_remark:       T_remark,
			T_State:        1,
		}

		_, is = Device.Add_DeviceClassList(var_)
		if !is {
			//c.Data["json"] = lib.JSONS{Code: 202, Msg: "添加失败!"}
			//c.ServeJSON()
			//return

			errList2 = append(errList2, T_id)
			continue
		}
		successNum += 1
		succesId = append(succesId, T_id)
		System.Add_UserLogs_T(User_r.T_uuid, "分类设备管理", "添加", var_)
	}

	if len(errList) == 0 && len(errList2) == 0 {
		c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: successNum}
		c.ServeJSON()
		return
	}
	var errStr string
	if len(errList) > 0 {
		errStr += strings.Join(errList, ",") + "编号不存在"
	}
	if len(errList2) > 0 {
		if len(errStr) > 0 {
			errStr += "，"
		}
		errStr += strings.Join(errList2, ",") + "添加失败"
	}
	//if len(succesId) > 0 {
	//	if len(errStr) > 0 {
	//		errStr += "，"
	//	}
	//	errStr += strings.Join(succesId, ",") + "添加成功"
	//}

	c.Data["json"] = lib.JSONS{Code: 210, Msg: errStr, Data: successNum}
	c.ServeJSON()
	return
}
func (c *DeviceClassController) List_Add() {
	// 验证登录 User_is, User_r
	User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
	if !User_is {
		c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
		c.ServeJSON()
		return
	}

	T_class, _ := c.GetInt("T_class")
	T_sn_id_list := c.GetString("T_sn_id_list")

	// 根据 | 分割数据
	items := strings.Split(T_sn_id_list, "|")

	// 创建一个 map 来去重
	uniqueItems := make(map[string]struct{})

	for _, item := range items {
		// 如果不为空，则添加到 map 中
		if item != "" {
			uniqueItems[item] = struct{}{}
		}
	}

	// 将唯一项拼接成字符串
	result := ""

	for item := range uniqueItems {
		result += item + "|"
	}

	// 移除最后的 | 字符
	if len(result) > 0 {
		result = result[:len(result)-1]
	}
	T_sn_id_list = result

	list := strings.Split(strings.TrimRight(T_sn_id_list, "|"), "|")
	T_remark := c.GetString("T_remark")

	_, is := Device.Read_DeviceClass_ById(T_class)
	if !is {
		c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_class 错误"}
		c.ServeJSON()
		return
	}

	var successNum int // 成功数量
	errList := []string{}
	errList2 := []string{}
	succesId := []string{}
	for _, sn_id := range list {
		T_sn := strings.Split(sn_id, ",")[0]
		if strings.HasPrefix(T_sn, "03") && strings.HasSuffix(T_sn, "000001") {
			T_sn = strings.TrimSuffix(strings.TrimPrefix(T_sn, "03"), "000001")
		}
		T_id := strings.Split(sn_id, ",")[1]
		if len(T_sn) == 0 || len(T_id) == 0 {
			errList = append(errList, sn_id)
			continue
		}
		// 判断是否已存在sn
		dc, is := Device.Read_DeviceClassList_T_class_T_sn(T_class, T_sn)
		// 添加的id和数据库已存在id相同
		if is && dc.T_id == T_id {
			successNum += 1
			continue
		}
		// 添加的id和数据库已存在id不同
		if is && dc.T_id != T_id {
			_, is = Device.Read_DeviceClassList_T_class_T_id(T_class, T_id)
			if is {
				errList2 = append(errList2, sn_id)
				continue
			}
			dc.T_id = T_id
			dc.T_remark = T_remark
			if !Device.Update_DeviceClassList(dc, "T_id", "T_remark") {
				errList = append(errList, sn_id)
			} else {
				successNum += 1
			}
			continue
		}

		if !is {
			_, is = Device.Read_DeviceClassList_T_class_T_id(T_class, T_id)
			if is {
				errList2 = append(errList2, sn_id)
				continue
			}
		}

		var pdf Certificate.CertificatePdf
		//pdfList, _ := Certificate.Read_CertificatePdf_Newest(T_sn)
		pdfList, _ := Certificate.Read_CertificatePdf_T_layout_no(T_id, "")
		if len(pdfList) > 0 {
			pdf = pdfList[0]
		}

		var_ := Device.DeviceClassList{
			T_class:          T_class,
			T_id:             T_id,
			T_sn:             T_sn,
			T_failure_time:   pdf.T_failure_time,
			T_pdf:            pdf.T_pdf,
			T_Certificate_sn: pdf.T_Certificate_sn,
			T_remark:         T_remark,
			T_State:          1,
		}

		_, is = Device.Add_DeviceClassList(var_)
		if !is {
			errList = append(errList, sn_id)
			continue
		}
		successNum += 1
		succesId = append(succesId, sn_id)
		System.Add_UserLogs_T(User_r.T_uuid, "分类设备管理", "添加", var_)
	}

	if len(errList) == 0 && len(errList2) == 0 {
		c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: successNum}
		c.ServeJSON()
		return
	}
	var errStr string
	if len(errList2) > 0 {
		errStr += strings.Join(errList2, "，") + "编号已存在"
	}
	if len(errList) > 0 {
		if len(errStr) > 0 {
			errStr += "，"
		}
		errStr += strings.Join(errList, "，") + "添加失败"
	}

	c.Data["json"] = lib.JSONS{Code: 210, Msg: errStr, Data: successNum}
	c.ServeJSON()
	return
}
func (c *DeviceClassController) List_Copy() {
	// 验证登录 User_is, User_r
	_, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
	if !User_is {
		c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
		c.ServeJSON()
		return
	}

	T_copy_task_id := c.GetString("T_copy_task_id")
	copy_task, is := Task.Read_Task(T_copy_task_id)
	if !is {
		c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_copy_task_id 错误!"}
		c.ServeJSON()
		return
	}
	T_paste_task_id := c.GetString("T_paste_task_id")
	paste_task, is := Task.Read_Task(T_paste_task_id)
	if !is {
		c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_paste_task_id 错误!"}
		c.ServeJSON()
		return
	}
	errList := []string{}
	pasteList, cnt := Device.Read_DeviceClassList_OrderList(paste_task.T_class, "", "", "", 0, 9999)
	for _, ds := range pasteList {
		if !Device.Delete_DeviceClassList_(ds) {
			errList = append(errList, ds.T_id)
			continue
		}
	}

	// 删除旧的设备列表

	copyList, cnt := Device.Read_DeviceClassList_OrderList(copy_task.T_class, "", "", "", 0, 9999)
	var successNum int // 成功数量

	for _, v := range copyList {
		// 不存在则添加
		var pdf Certificate.CertificatePdf
		pdfList, _ := Certificate.Read_CertificatePdf_T_layout_no(v.T_id, "")
		if len(pdfList) > 0 {
			pdf = pdfList[0]
		}

		var_ := Device.DeviceClassList{
			T_class:          paste_task.T_class,
			T_id:             v.T_id,
			T_sn:             v.T_sn,
			T_failure_time:   pdf.T_failure_time,
			T_pdf:            pdf.T_pdf,
			T_Certificate_sn: pdf.T_Certificate_sn,
			T_remark:         v.T_remark,
			T_terminal:       v.T_terminal,
			T_State:          1,
		}

		_, is = Device.Add_DeviceClassList(var_)
		if !is {
			errList = append(errList, v.T_id)
			continue
		}

	}

	// 自动填写备注
	err := AutoFillDeviceClassRemark(T_paste_task_id)
	if err != nil {
		logs.Error("自动填写设备备注失败", err)
	}

	// 自动填写布点
	err = AutoFillDeploy(T_paste_task_id, 0)
	if err != nil {
		logs.Error("自动填写布点失败", err)
	}

	if len(errList) == 0 {
		c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: cnt}
		c.ServeJSON()
		return
	}
	var errStr string
	if len(errList) > 0 {
		if len(errStr) > 0 {
			errStr += "，"
		}
		errStr += strings.Join(errList, "，") + "粘贴失败"
	}

	c.Data["json"] = lib.JSONS{Code: 210, Msg: errStr, Data: successNum}
	c.ServeJSON()
	return
}

func (c *DeviceClassController) List_Add_batch() {
	// 验证登录 User_is, User_r
	User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
	if !User_is {
		c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
		c.ServeJSON()
		return
	}

	T_class, _ := c.GetInt("T_class")

	// 删除之前的设备列表
	pasteList, _ := Device.Read_DeviceClassList_OrderList(T_class, "", "", "", 0, 9999)
	for _, ds := range pasteList {
		Device.Delete_DeviceClassList_(ds)
	}

	T_sn_id_list := c.GetString("T_sn_id_list")

	// 根据 | 分割数据
	items := strings.Split(T_sn_id_list, "|")

	// 创建一个 map 来去重
	uniqueItems := make(map[string]struct{})

	for _, item := range items {
		// 如果不为空，则添加到 map 中
		if item != "" {
			uniqueItems[item] = struct{}{}
		}
	}

	// 将唯一项拼接成字符串
	result := ""

	for item := range uniqueItems {
		result += item + "|"
	}

	// 移除最后的 | 字符
	if len(result) > 0 {
		result = result[:len(result)-1]
	}
	T_sn_id_list = result

	list := strings.Split(strings.TrimRight(T_sn_id_list, "|"), "|")
	T_remark := c.GetString("T_remark")

	_, is := Device.Read_DeviceClass_ById(T_class)
	if !is {
		c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_class 错误"}
		c.ServeJSON()
		return
	}

	var successNum int // 成功数量
	errList := []string{}
	errList2 := []string{}
	succesId := []string{}
	for _, sn_id := range list {
		T_sn := strings.Split(sn_id, ",")[0]
		if strings.HasPrefix(T_sn, "03") && strings.HasSuffix(T_sn, "000001") {
			T_sn = strings.TrimSuffix(strings.TrimPrefix(T_sn, "03"), "000001")
		}
		T_id := strings.Split(sn_id, ",")[1]
		if len(T_sn) == 0 || len(T_id) == 0 {
			errList = append(errList, sn_id)
			continue
		}
		// 判断是否已存在sn
		dc, is := Device.Read_DeviceClassList_T_class_T_sn(T_class, T_sn)
		// 添加的id和数据库已存在id相同
		if is && dc.T_id == T_id {
			successNum += 1
			continue
		}
		// 添加的id和数据库已存在id不同
		if is && dc.T_id != T_id {
			_, is = Device.Read_DeviceClassList_T_class_T_id(T_class, T_id)
			if is {
				errList2 = append(errList2, sn_id)
				continue
			}
			dc.T_id = T_id
			dc.T_remark = T_remark
			if !Device.Update_DeviceClassList(dc, "T_id", "T_remark") {
				errList = append(errList, sn_id)
			} else {
				successNum += 1
			}
			continue
		}

		if !is {
			_, is = Device.Read_DeviceClassList_T_class_T_id(T_class, T_id)
			if is {
				errList2 = append(errList2, sn_id)
				continue
			}
		}

		var pdf Certificate.CertificatePdf
		//pdfList, _ := Certificate.Read_CertificatePdf_Newest(T_sn)
		pdfList, _ := Certificate.Read_CertificatePdf_T_layout_no(T_id, "")
		if len(pdfList) > 0 {
			pdf = pdfList[0]
		}

		var_ := Device.DeviceClassList{
			T_class:          T_class,
			T_id:             T_id,
			T_sn:             T_sn,
			T_failure_time:   pdf.T_failure_time,
			T_pdf:            pdf.T_pdf,
			T_Certificate_sn: pdf.T_Certificate_sn,
			T_remark:         T_remark,
			T_State:          1,
		}

		_, is = Device.Add_DeviceClassList(var_)
		if !is {
			errList = append(errList, sn_id)
			continue
		}
		successNum += 1
		succesId = append(succesId, sn_id)
		System.Add_UserLogs_T(User_r.T_uuid, "分类设备管理", "添加", var_)
	}
	// 通过 T_class 查找任务 id
	task, is := Task.Read_Task_ByT_class(T_class)

	if len(errList) == 0 && len(errList2) == 0 {
		if is && len(task.T_task_id) > 0 {
			// 自动填写备注
			err := AutoFillDeviceClassRemark(task.T_task_id)
			if err != nil {
				logs.Error("自动填写设备备注失败", err)
			}

			// 自动填写布点
			err = AutoFillDeploy(task.T_task_id, 0)
			if err != nil {
				logs.Error("自动填写布点失败", err)
			}
		}
		c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: successNum}
		c.ServeJSON()
		return
	}
	var errStr string
	if len(errList2) > 0 {
		errStr += strings.Join(errList2, "，") + "编号已存在"
	}
	if len(errList) > 0 {
		if len(errStr) > 0 {
			errStr += "，"
		}
		errStr += strings.Join(errList, "，") + "添加失败"
	}

	c.Data["json"] = lib.JSONS{Code: 210, Msg: errStr, Data: successNum}
	c.ServeJSON()
	return
}

// 修改-
func (c *DeviceClassController) List_Up() {
	// 验证登录 User_is, User_r
	User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
	if !User_is {
		c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
		c.ServeJSON()
		return
	}

	T_id := c.GetString("T_id")
	T_remark := c.GetString("T_remark")

	Id, err := c.GetInt("Id")
	if err != nil {
		c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id 错误!"}
		c.ServeJSON()
		return
	}

	r, is := Device.Read_DeviceClassList_ById(Id)
	if !is {
		c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id 错误!"}
		c.ServeJSON()
		return
	}

	_, is = Device.Read_DeviceClass_ById(r.T_class)
	if !is {
		c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_class 错误!"}
		c.ServeJSON()
		return
	}

	_, is = Device.Read_DeviceClassList_T_class_T_id(r.T_class, T_id)
	if is && T_id != r.T_id {
		c.Data["json"] = lib.JSONS{Code: 202, Msg: T_id + "编号已存在!"}
		c.ServeJSON()
		return
	}

	if len(T_id) > 0 {
		r.T_id = T_id
		// 修改布局编号对应的证书
		var pdf Certificate.CertificatePdf
		pdfList, _ := Certificate.Read_CertificatePdf_T_layout_no(T_id, r.CreateTime.Format("2006-01-02"))
		if len(pdfList) > 0 {
			pdf = pdfList[0]
		}
		r.T_failure_time = pdf.T_failure_time
		r.T_pdf = pdf.T_pdf
		r.T_Certificate_sn = pdf.T_Certificate_sn
	}
	if len(T_remark) > 0 {
		r.T_remark = T_remark
	}

	if !Device.Update_DeviceClassList(r, "T_id", "T_remark", "T_failure_time", "T_pdf", "T_Certificate_sn") {
		c.Data["json"] = lib.JSONS{Code: 202, Msg: "修改失败!"}
		c.ServeJSON()
		return
	}
	System.Add_UserLogs_T(User_r.T_uuid, "分类设备管理", "修改", r)
	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
	c.ServeJSON()
	return
}

// 修改终端
func (c *DeviceClassController) List_Up_terminal() {
	// 验证登录 User_is, User_r
	User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
	if !User_is {
		c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
		c.ServeJSON()
		return
	}

	T_terminal, _ := c.GetInt("T_terminal")
	T_task_id := c.GetString("T_task_id")
	T_id := c.GetString("T_id")

	task, is := Task.Read_Task(T_task_id)
	if !is {
		c.Data["json"] = lib.JSONS{Code: 202, Msg: "获取任务失败!"}
		c.ServeJSON()
		return
	}

	r, is := Device.Read_DeviceClassList_T_class_T_id(task.T_class, T_id)
	if !is {
		c.Data["json"] = lib.JSONS{Code: 202, Msg: "获取设备失败!"}
		c.ServeJSON()
		return
	}

	if T_terminal > 0 {
		r.T_terminal = T_terminal
	}

	if !Device.Update_DeviceClassList(r, "T_terminal") {
		c.Data["json"] = lib.JSONS{Code: 202, Msg: "修改失败!"}
		c.ServeJSON()
		return
	}
	System.Add_UserLogs_T(User_r.T_uuid, "分类设备管理", "修改终端标识", r)
	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
	c.ServeJSON()
	return
}

// 删除-
func (c *DeviceClassController) List_Del() {
	// 验证登录 User_is, User_r
	User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
	if !User_is {
		c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
		c.ServeJSON()
		return
	}

	Id, err := c.GetInt("Id")
	if err != nil {
		c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id 错误!"}
		c.ServeJSON()
		return
	}

	if r, is := Device.Read_DeviceClassList_ById(Id); is {

		_, is = Device.Read_DeviceClass_ById(r.T_class)
		if !is {
			c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_class 错误!"}
			c.ServeJSON()
			return
		}

		if !Device.Delete_DeviceClassList_(r) {
			c.Data["json"] = lib.JSONS{Code: 202, Msg: "删除失败！"}
			c.ServeJSON()
			return
		}
		System.Add_UserLogs_T(User_r.T_uuid, "分类设备管理", "删除", r)

		c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
		c.ServeJSON()
		return
	}

	c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id 错误!"}
	c.ServeJSON()
	return
}

// 添加设备列表。模版下载
func (c *DeviceClassController) List_Template_Download() {

	// 返回生成的 Excel 文件
	c.Ctx.Output.Download("static/添加设备列表模版.xlsx")
}

func (c *DeviceClassController) List_Del_Duplication() {
	// 验证登录 User_is, User_r
	_, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
	if !User_is {
		c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
		c.ServeJSON()
		return
	}

	T_task_id := c.GetString("T_task_id")
	r, is := Task.Read_Task(T_task_id)
	if !is {
		c.Data["json"] = lib.JSONS{Code: 202, Msg: "任务id 错误!"}
		c.ServeJSON()
		return
	}

	Device.Del_DeviceClassList_Duplication(r.T_class)

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
	c.ServeJSON()
	return
}

// 同步证书到设备列表
func (c *DeviceClassController) Sync_CertificatePdf_ToList() {
	// 验证登录 User_is, User_r
	User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
	if !User_is {
		c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
		c.ServeJSON()
		return
	}
	CreateTime := c.GetString("CreateTime")
	list := Device.Read_DeviceClassList_List_ByT_Certificate_sn_null(CreateTime)
	for _, v := range list {
		var pdf Certificate.CertificatePdf
		pdfList, _ := Certificate.Read_CertificatePdf_T_layout_no(v.T_id, v.CreateTime.Format("2006-01-02"))
		if len(pdfList) > 0 {
			pdf = pdfList[0]
		} else {
			continue
		}

		v.T_Certificate_sn = pdf.T_Certificate_sn
		v.T_failure_time = pdf.T_failure_time
		v.T_pdf = pdf.T_pdf
		if !Device.Update_DeviceClassList(v, "T_failure_time", "T_pdf", "T_Certificate_sn") {
			c.Data["json"] = lib.JSONS{Code: 202, Msg: "修改失败!"}
			c.ServeJSON()
			return
		}
	}
	System.Add_UserLogs_T(User_r.T_uuid, "分类设备管理", "同步证书到设备列表", CreateTime)
	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
	c.ServeJSON()
	return
}

// 自动填写设备备注
func (c *DeviceClassController) Auto_fill_Remark() {
	// 验证登录 User_is, User_r
	User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
	if !User_is {
		c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
		c.ServeJSON()
		return
	}

	T_task_id := c.GetString("T_task_id")
	task, is := Task.Read_Task(T_task_id)
	if !is {
		c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id 错误!"}
		c.ServeJSON()
		return
	}

	verifyTemplate, is := VerifyTemplate.Read_VerifyTemplate(task.T_VerifyTemplate_id)
	verifyTemplate_R := VerifyTemplate.VerifyTemplateToVerifyTemplate_R(verifyTemplate)
	T_deploy_list := verifyTemplate_R.T_deploy_list

	// 循环查询布点
	deviceClassRemarkMap := make(map[int][]string)
	deviceClassList := Device.Read_DeviceClassList_List_id_By_Terminal(task.T_class, false)
	for _, deploy := range T_deploy_list {
		if len(deploy.T_scope) > 0 {
			dcl := FilterByRange(deviceClassList, deploy.T_scope)
			for _, dc := range dcl {
				deviceClassRemarkMap[dc.Id] = append(deviceClassRemarkMap[dc.Id], deploy.T_name)

			}
		}
	}

	for _, deviceClass := range deviceClassList {
		if remark, ok := deviceClassRemarkMap[deviceClass.Id]; ok {
			deviceClass.T_remark = strings.Join(remark, "|")
			if !Device.Update_DeviceClassList(deviceClass, "T_remark") {
				c.Data["json"] = lib.JSONS{Code: 200, Msg: "修改备注失败!"}
				c.ServeJSON()
				return
			}

		}
	}

	System.Add_UserLogs_T(User_r.T_uuid, "设备备注", "自动填写", T_task_id)

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
	c.ServeJSON()
	return
}

func (c *DeviceClassController) List_Maximum() {

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: conf.DeviceListMaximum}
	c.ServeJSON()
	return
}

func FilterByRange(data []Device.DeviceClassList, condition string) []Device.DeviceClassList {
	var result []Device.DeviceClassList
	parts := strings.Split(condition, ",")

	for _, part := range parts {
		if strings.Contains(part, "-") {
			// 处理范围 如1-16
			rangeParts := strings.Split(part, "-")
			if len(rangeParts) != 2 {
				continue
			}
			start, err1 := strconv.Atoi(rangeParts[0])
			end, err2 := strconv.Atoi(rangeParts[1])
			if err1 != nil || err2 != nil || start > end {
				continue
			}

			// 转换为0-based索引
			startIdx := start - 1
			endIdx := end - 1

			// 确保索引在有效范围内
			if startIdx < 0 {
				startIdx = 0
			}
			if endIdx >= len(data) {
				endIdx = len(data) - 1
			}

			for i := startIdx; i <= endIdx; i++ {
				result = append(result, data[i])
			}
		} else {
			// 处理单个数字 如2,5
			num, err := strconv.Atoi(part)
			if err != nil {
				continue
			}

			// 转换为0-based索引
			idx := num - 1

			// 确保索引在有效范围内
			if idx >= 0 && idx < len(data) {
				result = append(result, data[idx])
			}
		}
	}

	return result
}

// 验证工具统计
func (c *DeviceClassController) Stat() {
	// 验证登录 User_is, User_r
	_, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
	if !User_is {
		c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
		c.ServeJSON()
		return
	}

	var r_jsons lib.R_JSONS
	page, _ := c.GetInt("page")
	if page < 1 {
		page = 1
	}
	page_z, _ := c.GetInt("page_z")
	if page_z < 1 {
		page_z = conf.Page_size
	}

	T_company := c.GetString("T_company") // 公司名称
	var T_company_list []string
	if len(T_company) > 0 {
		T_company_list = Account.Read_User_T_uuid_ListByT_name(T_company)
	}

	Time_start := c.GetString("Time_start")
	Time_end := c.GetString("Time_end")
	T_name := c.GetString("T_name")
	T_sn := c.GetString("T_sn")
	T_distinct, _ := c.GetBool("T_distinct")
	UserMap := Account.UserListToMap(Account.Read_User_List_ALL_1())

	var cnt int64
	List, cnt := Device.Read_DeviceClass_Stat(T_company_list, T_name, T_sn, Time_start, Time_end, T_distinct, UserMap, page, page_z)
	page_size := math.Ceil(float64(cnt) / float64(page_z))
	r_jsons.List = List
	r_jsons.Page = page
	r_jsons.Page_size = int(page_size)
	r_jsons.Pages = lib.Func_page(int64(page), int64(page_size))
	r_jsons.Num = int(cnt)

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
	c.ServeJSON()
	return
}