add：培训时间培训讲师自动填写

Nats/NatsServer/NatsServer.go

@@ -115,6 +115,36 @@ func Read_User(T_uuid string) (user Account.User, err error) {
 	return t_R.Data, nil
 
 }
+func Read_Admin(T_uuid string) (user Account.Admin, err error) {
+	logs.Println("Nats =>", lib.FuncName(), T_uuid)
+
+	msg, err := lib.Nats.Request("ColdVerify_Server_Read_Admin", []byte(T_uuid), 3*time.Second)
+	if err != nil {
+		logs.Error(lib.FuncName(), err.Error())
+		return user, err
+	}
+
+	type T_R struct {
+		Code int16         `xml:"Code"`
+		Msg  string        `xml:"Msg"`
+		Data Account.Admin `xml:"Data"`
+	}
+	var t_R T_R
+
+	err = msgpack.Unmarshal(msg.Data, &t_R)
+	if err != nil {
+		logs.Error(lib.FuncName(), err.Error())
+		return user, err
+	}
+	if t_R.Code != 200 {
+		err = errors.New(t_R.Msg)
+		logs.Error(lib.FuncName(), err.Error())
+		return user, err
+	}
+
+	return t_R.Data, nil
+
+}
 func Device_Class_List(T_task_id string) (list []Device.DeviceClassList, err error) {
 	//logs.Println("Nats =>", lib.FuncName(), T_task_id)
 

controllers/TaskData.go

@@ -2936,6 +2936,8 @@ func (c *TaskDataController) ListJson() {
 		"监测系统配置的测点终端参数及安装位置确认（满载）结束时间",
 		"监测系统配置的测点终端参数及安装位置确认（空载）开始时间",
 		"监测系统配置的测点终端参数及安装位置确认（空载）结束时间",
+		"培训讲师",
+		"培训时间",
 	}
 
 	c.Data["json"] = mySlice
@@ -5876,3 +5878,49 @@ func (c *TaskDataController) A监测系统配置的测点终端参数及安装
 
 	c.Ctx.ResponseWriter.WriteHeader(http.StatusOK)
 }
+func (c *TaskDataController) A培训讲师() {
+
+	T_task_id := c.GetString("T_task_id") //  v26nplogbwt1
+	println("T_task_id:", T_task_id)
+	c.Ctx.ResponseWriter.Header().Set("Content-Type", "text/event-stream")
+	c.Ctx.ResponseWriter.Header().Set("Cache-Control", "no-cache")
+	c.Ctx.ResponseWriter.Header().Set("Connection", "keep-alive")
+
+	Task_r, err := Task.Read_Task(T_task_id)
+	if err != nil {
+		lib.SseWriteJSON(c.Ctx.ResponseWriter, lib.JSONSSE{State: 2, Msg: "获取任务信息失败!"})
+		return
+	}
+
+	// 数据采集工程师
+	user, err := NatsServer.Read_Admin(Task_r.T_collection)
+	if err != nil {
+		lib.SseWriteJSON(c.Ctx.ResponseWriter, lib.JSONSSE{State: 2, Msg: "获取数据采集工程师信息失败!"})
+		return
+	}
+
+	lib.SseWriteJSON(c.Ctx.ResponseWriter, lib.JSONSSE{State: 1, Msg: user.T_name})
+
+	// Close the connection
+	c.Ctx.ResponseWriter.WriteHeader(http.StatusOK)
+}
+func (c *TaskDataController) A培训时间() {
+
+	T_task_id := c.GetString("T_task_id") //  v26nplogbwt1
+	println("T_task_id:", T_task_id)
+	c.Ctx.ResponseWriter.Header().Set("Content-Type", "text/event-stream")
+	c.Ctx.ResponseWriter.Header().Set("Cache-Control", "no-cache")
+	c.Ctx.ResponseWriter.Header().Set("Connection", "keep-alive")
+
+	现场测试开始时间_ := c.GetString("现场测试开始时间") //  v26nplogbwt1
+	现场测试开始时间, err := time.Parse("2006-01-02 15:04", 现场测试开始时间_)
+	if err != nil {
+		lib.SseWriteJSON(c.Ctx.ResponseWriter, lib.JSONSSE{State: 2, Msg: "获取 现场测试开始时间 失败!"})
+		return
+	}
+
+	lib.SseWriteJSON(c.Ctx.ResponseWriter, lib.JSONSSE{State: 1, Msg: 现场测试开始时间.Format("2006年01月")})
+
+	// Close the connection
+	c.Ctx.ResponseWriter.WriteHeader(http.StatusOK)
+}

models/Account/Admin.go

@@ -0,0 +1,18 @@
+package Account
+
+import "time"
+
+type Admin struct {
+	Id       int    `orm:"column(ID);size(11);auto;pk"`
+	T_uuid   string `orm:"size(256);null"`      //
+	T_power  int    `orm:"size(2);;default(0)"` // 权限  0
+	T_name   string `orm:"size(256);null"`      // 姓名
+	T_user   string `orm:"size(256);null"`      // 用户名
+	T_pass   string `orm:"size(256);null"`      // 密码
+	T_wxname string `orm:"size(256);null"`      // 微信name
+
+	T_State          int       `orm:"size(200);default(1)"`                                  //  0删除  1 正常
+	T_Distributor_id string    `orm:"size(256);null"`                                        // 分销商
+	CreateTime       time.Time `orm:"column(create_time);type(timestamp);null;auto_now_add"` //auto_now 每次 model 保存时都会对时间自动更新
+	UpdateTime       time.Time `orm:"column(update_time);type(timestamp);null;auto_now"`     //auto_now_add 第一次保存时才设置时间
+}

routers/TaskData.go

@@ -155,5 +155,7 @@ func init() {
 	beego.Router("/TaskDataContent/SSE_监测系统配置的测点终端参数及安装位置确认满载结束时间", &controllers.TaskDataController{}, "*:A监测系统配置的测点终端参数及安装位置确认满载结束时间")
 	beego.Router("/TaskDataContent/SSE_监测系统配置的测点终端参数及安装位置确认空载开始时间", &controllers.TaskDataController{}, "*:A监测系统配置的测点终端参数及安装位置确认空载开始时间")
 	beego.Router("/TaskDataContent/SSE_监测系统配置的测点终端参数及安装位置确认空载结束时间", &controllers.TaskDataController{}, "*:A监测系统配置的测点终端参数及安装位置确认空载结束时间")
+	beego.Router("/TaskDataContent/SSE_培训讲师", &controllers.TaskDataController{}, "*:A培训讲师")
+	beego.Router("/TaskDataContent/SSE_培训时间", &controllers.TaskDataController{}, "*:A培训时间")
 
 }