add：关联任务与设备分类

conf/app.conf

@@ -10,16 +10,20 @@ copyrequestbody = true
 
 
 # Mysql
-MysqlServer_UrlPort = "192.168.192.250:3306"
-MysqlServer_Database = "cold_verify"
-MysqlServer_Username = "cold_verify"
-MysqlServer_Password = "Cdac2yEfzNKKMJwy"
+# MysqlServer_UrlPort = "47.111.15.17:3306"
+# MysqlServer_Database = "cold_verify"
+# MysqlServer_Username = "cold_verify"
+# MysqlServer_Password = "kzFbKseJm5GFpPFS"
+MysqlServer_UrlPort = "127.0.0.1:40306"
+MysqlServer_Database = "coldverify"
+MysqlServer_Username = "coldverify"
+MysqlServer_Password = "Bd3d34yJ7aibiEi!"
 MysqlServer_MaxIdleConnections = 100
 MysqlServer_MaxOpenConnections = 200
 
 
 # Redis
-Redis_address = "localhost:6379"
+Redis_address = "127.0.0.1:43379"
 Redis_password = ""
 Redis_dbNum = "2"
 

controllers/Task.go

@@ -4,6 +4,7 @@ import (
 	"ColdVerify_server/conf"
 	"ColdVerify_server/lib"
 	"ColdVerify_server/models/Account"
+	"ColdVerify_server/models/Device"
 	"ColdVerify_server/models/System"
 	"ColdVerify_server/models/Task"
 	beego "github.com/beego/beego/v2/server/web"
@@ -120,6 +121,7 @@ func (c *TaskController) Get() {
 
 // 添加-
 func (c *TaskController) Add() {
+
 	// 验证登录 User_is, User_r
 	User_r, User_is := lib.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
 	if !User_is {
@@ -127,6 +129,17 @@ func (c *TaskController) Add() {
 		c.ServeJSON()
 		return
 	}
+	dc := Device.DeviceClass{
+		T_uuid:  User_r.T_uuid,
+		T_State: 1,
+	}
+	Id, is := Device.Add_DeviceClass(dc)
+	if !is {
+		c.Data["json"] = lib.JSONS{Code: 202, Msg: "添加分类失败!"}
+		c.ServeJSON()
+		return
+	}
+	System.Add_UserLogs_T(User_r.T_uuid, "分类管理", "添加", dc)
 
 	T_name := c.GetString("T_name")
 	T_uuid := c.GetString("T_uuid") // 用户uuid
@@ -138,6 +151,7 @@ func (c *TaskController) Add() {
 	T_delivery := c.GetString("T_delivery")
 
 	var_ := Task.Task{
+		T_class:             int(Id),
 		T_uuid:              T_uuid,
 		T_name:              T_name,
 		T_VerifyTemplate_id: T_VerifyTemplate_id,

controllers/TaskData.go

@@ -42,14 +42,14 @@ func (c *TaskDataController) Extract_TaskData() {
 		return
 	}
 
-	T_Class_id, err := c.GetInt("T_Class_id")
-	if err != nil {
-		c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_Class_id 错误!"}
-		c.ServeJSON()
-		return
-	}
+	//T_Class_id, err := c.GetInt("T_Class_id")
+	//if err != nil {
+	//	c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_Class_id 错误!"}
+	//	c.ServeJSON()
+	//	return
+	//}
 
-	DeviceClass_List := Device.Read_DeviceClassList_List_id(T_Class_id)
+	DeviceClass_List := Device.Read_DeviceClassList_List_id(Task_r.T_class)
 	if len(DeviceClass_List) == 0 {
 		c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_Class_id 分类设备列表 为空!"}
 		c.ServeJSON()

models/Task/Task.go

@@ -16,19 +16,20 @@ import (
 // 模板
 type Task struct {
 	Id                  int    `orm:"column(ID);size(11);auto;pk"`
-	T_task_id           string `orm:"size(256);null"`     // 任务ID
-	T_uuid              string `orm:"size(256);null"`     // 用户 UUID
-	T_name              string `orm:"size(256);null"`     // 标题
-	T_VerifyTemplate_id string `orm:"size(256);null"`     // 模板id
-	T_deadline          string `orm:"size(256);null"`     // 截止时间
-	T_scheme            string `orm:"size(256);null"`     // 实施方案 负责人UUID
-	T_collection        string `orm:"size(256);null"`     // 数据采集 负责人UUID
-	T_reporting         string `orm:"size(256);null"`     // 报告编写 负责人UUID
-	T_delivery          string `orm:"size(256);null"`     // 交付审核 负责人UUID
-	T_scheme_state      int    `orm:"size(2);default(0)"` // 实施方案 状态 0 未完成 1 已完成
-	T_collection_state  int    `orm:"size(2);default(0)"` // 数据采集 状态 0 未完成 1 已完成
-	T_reporting_state   int    `orm:"size(2);default(0)"` // 报告编写 状态 0 未完成 1 已完成
-	T_delivery_state    int    `orm:"size(2);default(0)"` // 交付审核 状态 0 未完成 1 已完成
+	T_class             int    `orm:"size(200);default(0)"` // 分类id
+	T_task_id           string `orm:"size(256);null"`       // 任务ID
+	T_uuid              string `orm:"size(256);null"`       // 用户 UUID
+	T_name              string `orm:"size(256);null"`       // 标题
+	T_VerifyTemplate_id string `orm:"size(256);null"`       // 模板id
+	T_deadline          string `orm:"size(256);null"`       // 截止时间
+	T_scheme            string `orm:"size(256);null"`       // 实施方案 负责人UUID
+	T_collection        string `orm:"size(256);null"`       // 数据采集 负责人UUID
+	T_reporting         string `orm:"size(256);null"`       // 报告编写 负责人UUID
+	T_delivery          string `orm:"size(256);null"`       // 交付审核 负责人UUID
+	T_scheme_state      int    `orm:"size(2);default(0)"`   // 实施方案 状态 0 未完成 1 已完成
+	T_collection_state  int    `orm:"size(2);default(0)"`   // 数据采集 状态 0 未完成 1 已完成
+	T_reporting_state   int    `orm:"size(2);default(0)"`   // 报告编写 状态 0 未完成 1 已完成
+	T_delivery_state    int    `orm:"size(2);default(0)"`   // 交付审核 状态 0 未完成 1 已完成
 
 	T_doc1 string `orm:"type(text);null"` // 封面
 	T_pdf1 string `orm:"type(text);null"` // 封面
@@ -62,6 +63,7 @@ type Task_R struct {
 
 type Task_ struct {
 	Id                  int
+	T_class             int    // 分类ID
 	T_task_id           string // 任务ID
 	T_uuid              string // 用户 UUID
 	T_user_name         string // 用户 UUID
@@ -135,6 +137,7 @@ func TaskToTask_R(T Task) (T_r Task_R) {
 
 func TaskToTask_(T Task, userMap, adminMap map[string]string) (T_ Task_) {
 	T_.Id = T.Id
+	T_.T_class = T.T_class
 	T_.T_task_id = T.T_task_id
 	T_.T_uuid = T.T_uuid
 	T_.T_user_name = userMap[T.T_uuid]
@@ -168,7 +171,7 @@ func TaskToTask_(T Task, userMap, adminMap map[string]string) (T_ Task_) {
 }
 
 // ---------------- Redis -------------------
-//Redis_Set(m.T_sn,m) // Redis 更新缓存
+// Redis_Set(m.T_sn,m) // Redis 更新缓存
 func Redis_Task_Set(key string, r Task) (err error) {
 	//json序列化
 	str, err := json.Marshal(r)
@@ -183,9 +186,9 @@ func Redis_Task_Set(key string, r Task) (err error) {
 	return
 }
 
-//if r,is :=Redis_Get(T_sn);is{
-//return r,nil
-//}
+// if r,is :=Redis_Get(T_sn);is{
+// return r,nil
+// }
 func Redis_Task_Get(key string) (r Task, is bool) {
 	if redisCache_Task.IsExist(key) {
 		logs.Println("找到key:", key)