2022-05-31 1.0数据复制到2.0

Nats/NatsServer/NatsLocal.go

@@ -30,7 +30,7 @@ func Import_TaskData(T_uuid, T_task_id string, TaskData_Num int) {
 		logs.Error("Nats =>", lib.FuncName(), err)
 	}
 }
-func Create_Table(T_task_id string) {
+func Create_Local_Table(T_task_id string) {
 	logs.Println("Nats =>", lib.FuncName(), T_task_id)
 
 	err := lib.Nats.Publish("ColdVerify_Local_Create_Table", []byte(T_task_id))
@@ -38,3 +38,13 @@ func Create_Table(T_task_id string) {
 		logs.Error("Nats =>", lib.FuncName(), err)
 	}
 }
+
+// 同步2。8数据
+func Sync1_TaskData(T_task_id string) {
+	logs.Println("Nats =>", lib.FuncName(), T_task_id)
+
+	err := lib.Nats.Publish("ColdVerify_Local_Sync1_TaskData", []byte(T_task_id))
+	if err != nil {
+		logs.Error("Nats =>", lib.FuncName(), err)
+	}
+}

controllers/Task.go

@@ -177,7 +177,7 @@ func (c *TaskController) Add() {
 		c.ServeJSON()
 		return
 	}
-	NatsServer.Create_Table(T_task_id)
+	NatsServer.Create_Local_Table(T_task_id)
 	// 添加任务操作日志
 	Task.Add_TaskLogs_T(User_r.T_uuid, T_task_id, "任务管理", "添加", var_)
 	System.Add_UserLogs_T(User_r.T_uuid, "任务管理", "添加", var_)
@@ -186,6 +186,38 @@ func (c *TaskController) Add() {
 	return
 }
 
+// 添加-
+func (c *TaskController) AddData_Tool() {
+	T_uuid := "9b6b9f9d-f8f2-46fb-82c8-101d4a309c34" // 用户uuid
+
+	T_name := c.GetString("T_name")
+	T_task_id := c.GetString("T_task_id")
+
+	var_ := Task.Task{
+		T_task_id: T_task_id,
+		T_class:   0,
+		T_uuid:    T_uuid,
+		T_name:    T_name,
+		T_Show:    1,
+		T_State:   1,
+	}
+
+	_, is := Task.Add_Task_Tool(var_)
+	if !is {
+		c.Data["json"] = lib.JSONS{Code: 202, Msg: "添加失败!"}
+		c.ServeJSON()
+		return
+	}
+	// 创建本地表
+	NatsServer.Create_Local_Table(T_task_id)
+	// 同步1.0数据
+	NatsServer.Sync1_TaskData(T_task_id)
+
+	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: T_task_id}
+	c.ServeJSON()
+	return
+}
+
 // 修改-
 func (c *TaskController) Up() {
 	// 验证登录 User_is, User_r

models/Task/Task.go

@@ -265,6 +265,15 @@ func Add_Task(r Task) (string, bool) {
 	Redis_Task_Set(r.T_task_id, r)
 	return r.T_task_id, true
 }
+func Add_Task_Tool(r Task) (string, bool) {
+	o := orm.NewOrm()
+	_, err := o.Insert(&r)
+	if err != nil {
+		logs.Error(lib.FuncName(), err)
+		return "", false
+	}
+	return r.T_task_id, true
+}
 
 // 删除
 func Delete_Task(v Task) bool {

routers/Task.go

@@ -9,11 +9,12 @@ func init() {
 
 	beego.Router("/UpFileToken", &controllers.UpFileController{}, "*:ConfigUpFileToken") // 上传文件
 
-	beego.Router("/Task/List", &controllers.TaskController{}, "*:List") // 任务列表
-	beego.Router("/Task/Get", &controllers.TaskController{}, "*:Get")   // 获取任务
-	beego.Router("/Task/Add", &controllers.TaskController{}, "*:Add")   // 添加任务
-	beego.Router("/Task/Up", &controllers.TaskController{}, "*:Up")     // 编辑任务
-	beego.Router("/Task/Del", &controllers.TaskController{}, "*:Del")   // 删除任务
+	beego.Router("/Task/List", &controllers.TaskController{}, "*:List")                 // 任务列表
+	beego.Router("/Task/Get", &controllers.TaskController{}, "*:Get")                   // 获取任务
+	beego.Router("/Task/Add", &controllers.TaskController{}, "*:Add")                   // 添加任务
+	beego.Router("/Task/Up", &controllers.TaskController{}, "*:Up")                     // 编辑任务
+	beego.Router("/Task/Del", &controllers.TaskController{}, "*:Del")                   // 删除任务
+	beego.Router("/Task/AddData_Tool", &controllers.TaskController{}, "*:AddData_Tool") // 1.0 添加任务数据
 
 	// 日志
 	beego.Router("/TaskLogs/List", &controllers.TaskController{}, "*:Logs_List")