update：任务-实施方案，模板标签-来源

.gitignore

@@ -123,3 +123,4 @@ fabric.properties
 /logs/Mqtt
 lastupdate.tmp
 ColdVerify_server
+ofile

controllers/Task.go

@@ -41,7 +41,7 @@ func (c *TaskController) List() {
 	AdminMap := Account.AdminListToMap(Account.Read_Admin_List_ALL_1())
 
 	var cnt int
-	List, cnt := Task.Read_UserTask_List(T_uuid, T_name, UserMap, AdminMap, page, page_z)
+	List, cnt := Task.Read_Task_List(T_uuid, T_name, UserMap, AdminMap, page, page_z)
 
 	page_size := math.Ceil(float64(cnt) / float64(page_z))
 	r_jsons.List = List
@@ -132,6 +132,7 @@ func (c *TaskController) Add() {
 	T_uuid := c.GetString("T_uuid") // 用户uuid
 	T_VerifyTemplate_id := c.GetString("T_VerifyTemplate_id")
 	T_deadline := c.GetString("T_deadline")
+	T_scheme := c.GetString("T_T_scheme")
 	T_collection := c.GetString("T_collection")
 	T_reporting := c.GetString("T_reporting")
 	T_delivery := c.GetString("T_delivery")
@@ -141,6 +142,7 @@ func (c *TaskController) Add() {
 		T_name:              T_name,
 		T_VerifyTemplate_id: T_VerifyTemplate_id,
 		T_deadline:          T_deadline,
+		T_scheme:            T_scheme,
 		T_collection:        T_collection,
 		T_reporting:         T_reporting,
 		T_delivery:          T_delivery,
@@ -177,12 +179,14 @@ func (c *TaskController) Up() {
 
 	T_VerifyTemplate_id := c.GetString("T_VerifyTemplate_id")
 	T_deadline := c.GetString("T_deadline")
+	T_scheme := c.GetString("T_scheme")
 	T_collection := c.GetString("T_collection")
-	T_collection_state, T_collection_err := c.GetInt("T_collection_state")
 	T_reporting := c.GetString("T_reporting")
-	T_reporting_state, T_reporting_err := c.GetInt("T_reporting_state")
 	T_delivery := c.GetString("T_delivery")
-	T_delivery_state, T_delivery_err := c.GetInt("T_delivery_state")
+	//T_scheme_state, T_scheme_err := c.GetInt("T_scheme_state")
+	//T_collection_state, T_collection_err := c.GetInt("T_collection_state")
+	//T_reporting_state, T_reporting_err := c.GetInt("T_reporting_state")
+	//T_delivery_state, T_delivery_err := c.GetInt("T_delivery_state")
 	T_doc1 := c.GetString("T_doc1")
 	T_pdf1 := c.GetString("T_pdf1")
 	T_doc2 := c.GetString("T_doc2")
@@ -216,6 +220,10 @@ func (c *TaskController) Up() {
 		r.T_deadline = T_deadline
 		clos = append(clos, "T_deadline")
 	}
+	if len(T_scheme) > 0 {
+		r.T_scheme = T_scheme
+		clos = append(clos, "T_scheme")
+	}
 	if len(T_collection) > 0 {
 		r.T_collection = T_collection
 		clos = append(clos, "T_collection")
@@ -228,26 +236,33 @@ func (c *TaskController) Up() {
 		r.T_delivery = T_delivery
 		clos = append(clos, "T_delivery")
 	}
-	if T_collection_err == nil {
-		r.T_collection_state = T_collection_state
-		clos = append(clos, "T_collection_state")
-	}
-	if T_reporting_err == nil {
-		r.T_reporting_state = T_reporting_state
-		clos = append(clos, "T_reporting_state")
-	}
-	if T_delivery_err == nil {
-		r.T_delivery_state = T_delivery_state
-		clos = append(clos, "T_delivery_state")
-	}
+	//if T_scheme_err == nil {
+	//	r.T_scheme_state = T_scheme_state
+	//	clos = append(clos, "T_scheme_state")
+	//}
+	//if T_collection_err == nil {
+	//	r.T_collection_state = T_collection_state
+	//	clos = append(clos, "T_collection_state")
+	//}
+	//if T_reporting_err == nil {
+	//	r.T_reporting_state = T_reporting_state
+	//	clos = append(clos, "T_reporting_state")
+	//}
+	//if T_delivery_err == nil {
+	//	r.T_delivery_state = T_delivery_state
+	//	clos = append(clos, "T_delivery_state")
+	//}
 
 	if len(T_doc1) > 0 {
 		r.T_doc1 = T_doc1
 		clos = append(clos, "T_doc1")
 	}
+	// 验证报告内容T_pdf1 ，上传后将 当前任务 实施方案 标志 为 1
 	if len(T_pdf1) > 0 {
 		r.T_pdf1 = T_pdf1
 		clos = append(clos, "T_pdf1")
+		r.T_scheme_state = 1
+		clos = append(clos, "T_scheme_state")
 	}
 	if len(T_doc2) > 0 {
 		r.T_doc2 = T_doc2

controllers/TaskData.go

@@ -65,9 +65,14 @@ func (c *TaskDataController) Extract_TaskData() {
 		Task.Import_TaskData(v.T_sn, v.T_id, Task_r.T_task_id, Time_start, Time_end)
 	}
 
-	// 更新任务数据采集的状态
+	// 提取数据后 将 当前任务 数据采集 标志 为 1
 	Task_r.T_collection_state = 1
 	Task.Update_Task(Task_r, "T_collection_state")
+	if !Task.Update_Task(Task_r, "T_collection_state") {
+		c.Data["json"] = lib.JSONS{Code: 202, Msg: "修改失败!"}
+		c.ServeJSON()
+		return
+	}
 	System.Add_UserLogs_T(user_r.T_uuid, "任务", "修改", Task_r)
 
 	System.Add_UserLogs(user_r.T_uuid, "提取数据", "提取数据"+Task_r.T_name, Task_r.T_task_id+"|"+Time_start+"|"+Time_end)

controllers/VerifyTemplate.go

@@ -166,6 +166,7 @@ func (c *VerifyTemplateController) Map_Add() {
 	T_field := c.GetString("T_field")
 	T_text := c.GetString("T_text")
 	T_label, _ := c.GetInt("T_label")
+	T_source, _ := c.GetInt("T_source")
 	T_sort, _ := c.GetInt("T_sort")
 
 	var_ := VerifyTemplate.VerifyTemplateMap{
@@ -174,6 +175,7 @@ func (c *VerifyTemplateController) Map_Add() {
 		T_field:             T_field,
 		T_text:              T_text,
 		T_label:             T_label,
+		T_source:            T_source,
 		T_sort:              T_sort,
 	}
 
@@ -286,6 +288,13 @@ func (c *VerifyTemplateController) Map_Data_List() {
 	}
 
 	T_VerifyTemplate_id := c.GetString("T_VerifyTemplate_id")
+	T_source, T_source_err := c.GetInt("T_source")
+	if T_source_err != nil {
+		c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_source 错误!"}
+		c.ServeJSON()
+		return
+	}
+
 	T_task_id := c.GetString("T_task_id")
 	_, is := Task.Read_Task(T_task_id)
 	if !is {
@@ -294,15 +303,16 @@ func (c *VerifyTemplateController) Map_Data_List() {
 		return
 	}
 
-	Map_List := VerifyTemplate.Read_VerifyTemplateMap_List_1(T_VerifyTemplate_id)
+	Map_List := VerifyTemplate.Read_VerifyTemplateMap_List_For_Data(T_VerifyTemplate_id, T_source)
+	Data := VerifyTemplate.Read_VerifyTemplateMapData_List(T_source, T_task_id, T_VerifyTemplate_id, Map_List)
 
-	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: VerifyTemplate.Read_VerifyTemplateMapData_List(T_task_id, T_VerifyTemplate_id, Map_List)}
+	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: Data}
 	c.ServeJSON()
 	return
 }
 
 // 添加标签数据
-func (c *VerifyTemplateController) Map_Data_Add() {
+func (c *VerifyTemplateController) Map_Data_Pu() {
 	//验证登录 User_is, User_r
 	User_r, User_is := lib.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
 	if !User_is {
@@ -312,6 +322,7 @@ func (c *VerifyTemplateController) Map_Data_Add() {
 	}
 
 	type RequestBody struct {
+		T_source              int
 		T_task_id             string
 		T_VerifyTemplate_id   string
 		VerifyTemplateMapData []VerifyTemplate.VerifyTemplateMapData_R
@@ -338,6 +349,7 @@ func (c *VerifyTemplateController) Map_Data_Add() {
 			continue
 		}
 		val := VerifyTemplate.VerifyTemplateMapData{
+			T_source:               body.T_source,
 			T_task_id:              body.T_task_id,
 			T_VerifyTemplate_id:    body.T_VerifyTemplate_id,
 			T_VerifyTemplateMap_id: v.T_VerifyTemplateMap_id,

models/Task/Task.go

@@ -21,19 +21,21 @@ type Task struct {
 	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);0"`      // 实施方案 状态 0 未完成 1 已完成
 	T_collection_state  int    `orm:"size(2);0"`      // 数据采集 状态 0 未完成 1 已完成
 	T_reporting_state   int    `orm:"size(2);0"`      // 报告编写 状态 0 未完成 1 已完成
 	T_delivery_state    int    `orm:"size(2);0"`      // 交付审核 状态 0 未完成 1 已完成
 
-	T_doc1 string `orm:"size(256);null"` // 封面
-	T_pdf1 string `orm:"size(256);null"` // 封面
-	T_doc2 string `orm:"size(256);null"` // 报告
-	T_pdf2 string `orm:"size(256);null"` // 报告
-	T_doc3 string `orm:"size(256);null"` // 证书
-	T_pdf3 string `orm:"size(256);null"` // 证书
+	T_doc1 string `orm:"type(text);null"` // 封面
+	T_pdf1 string `orm:"type(text);null"` // 封面
+	T_doc2 string `orm:"type(text);null"` // 报告
+	T_pdf2 string `orm:"type(text);null"` // 报告
+	T_doc3 string `orm:"type(text);null"` // 证书
+	T_pdf3 string `orm:"type(text);null"` // 证书
 
 	T_Show     int       `orm:"size(2);1"`                                             // 0 隐藏   1 公开
 	T_Visit    int       `orm:"size(200);0"`                                           // 浏览量
@@ -43,7 +45,7 @@ type Task struct {
 }
 
 type Task_R struct {
-	T_task_id  string // 标题
+	T_task_id  string // id
 	T_name     string // 标题
 	T_doc1     string // 封面
 	T_pdf1     string // 封面
@@ -284,6 +286,8 @@ func Update_Task(m Task, cols ...string) bool {
 		fmt.Println("Number of records updated in database:", num)
 		Redis_Task_Set(m.T_task_id, m)
 		return true
+	} else {
+		fmt.Println(err)
 	}
 	return false
 }
@@ -329,7 +333,7 @@ func Add_Task_Visit(m Task) bool {
 //	return Task_r, cnt
 //}
 
-// 获取列表
+// 获取用户任务列表
 func Read_UserTask_List(T_uuid string, T_name string, userMap, adminMap map[string]string, page int, page_z int) ([]Task_, int) {
 
 	o := orm.NewOrm()
@@ -344,6 +348,38 @@ func Read_UserTask_List(T_uuid string, T_name string, userMap, adminMap map[stri
 	}
 	cond := orm.NewCondition()
 	//cond1 := cond.And("T_name__icontains", T_name).And("T_State", 1)
+	cond1 := cond.And("T_name__icontains", T_name).And("T_Show", 1)
+	if len(T_uuid) > 0 {
+		cond1 = cond1.And("T_uuid", T_uuid)
+	}
+
+	qs.Limit(page_z, offset).SetCond((*orm2.Condition)(cond1)).OrderBy("-Id").All(&r)
+	cnt, _ := qs.SetCond((*orm2.Condition)(cond1)).Count()
+
+	// 转换
+	var TaskList []Task_
+	for _, v := range r {
+		TaskList = append(TaskList, TaskToTask_(v, userMap, adminMap))
+	}
+
+	return TaskList, int(cnt)
+}
+
+// 获取任务列表
+func Read_Task_List(T_uuid string, T_name string, userMap, adminMap map[string]string, page int, page_z int) ([]Task_, int) {
+
+	o := orm.NewOrm()
+
+	qs := o.QueryTable(new(Task))
+	var r []Task
+	var offset int64
+	if page <= 1 {
+		offset = 0
+	} else {
+		offset = int64((page - 1) * page_z)
+	}
+	cond := orm.NewCondition()
+	//cond1 := cond.And("T_name__icontains", T_name).And("T_State", 1)
 	cond1 := cond.And("T_name__icontains", T_name)
 	if len(T_uuid) > 0 {
 		cond1 = cond1.And("T_uuid", T_uuid)

models/VerifyTemplate/VerifyTemplateMap.go

@@ -17,6 +17,7 @@ type VerifyTemplateMap struct {
 	T_id                string `orm:"size(256);null"` // 标题
 	T_VerifyTemplate_id string `orm:"size(256);null"` // 标题
 	T_label             int    `orm:"size(2);1"`      // 数据类型
+	T_source            int    `orm:"size(2);1"`      // 来源
 
 	//1：文本
 	//2：数值
@@ -36,11 +37,12 @@ type VerifyTemplateMap struct {
 }
 
 type VerifyTemplateMap_R struct {
-	T_id    string // 标题
-	T_label int    //
-	T_name  string // 标题
-	T_field string // 标题
-	T_text  string // 标题
+	T_id     string // 标题
+	T_source int    //
+	T_label  int    //
+	T_name   string // 标题
+	T_field  string // 标题
+	T_text   string // 标题
 }
 
 func (t *VerifyTemplateMap) TableName() string {
@@ -57,6 +59,7 @@ func init() {
 // -------------------------------------------------------------
 func VerifyTemplateMapToVerifyTemplateMap_R(T VerifyTemplateMap) (T_r VerifyTemplateMap_R) {
 	T_r.T_id = T.T_id
+	T_r.T_source = T.T_source
 	T_r.T_label = T.T_label
 	T_r.T_name = T.T_name
 	T_r.T_field = T.T_field
@@ -161,15 +164,15 @@ func Read_VerifyTemplateMap_List(T_VerifyTemplate_id string) []VerifyTemplateMap
 	return VerifyTemplateMap_r
 }
 
-func Read_VerifyTemplateMap_List_1(T_VerifyTemplate_id string) []VerifyTemplateMap {
+func Read_VerifyTemplateMap_List_For_Data(T_VerifyTemplate_id string, T_source int) []VerifyTemplateMap {
 
 	o := orm.NewOrm()
 	// 也可以直接使用 Model 结构体作为表名
 	var r []VerifyTemplateMap
 	qs := o.QueryTable(new(VerifyTemplateMap))
-
+	source := []int{0, T_source}
 	cond := orm.NewCondition()
-	cond1 := cond.And("T_VerifyTemplate_id", T_VerifyTemplate_id) // .AndNot("status__in", 1).Or("profile__age__gt", 2000)
+	cond1 := cond.And("T_source__in", source).And("T_VerifyTemplate_id", T_VerifyTemplate_id) // .AndNot("status__in", 1).Or("profile__age__gt", 2000)
 
 	qs.SetCond((*orm2.Condition)(cond1)).OrderBy("-T_sort").All(&r)
 

models/VerifyTemplate/VerifyTemplateMapData.go

@@ -10,8 +10,8 @@ import (
 
 // 模板
 type VerifyTemplateMapData struct {
-	Id int `orm:"column(ID);size(11);auto;pk"`
-
+	Id                     int    `orm:"column(ID);size(11);auto;pk"`
+	T_source               int    `orm:"size(2);1"`       // 来源 1-方案 2-报告
 	T_task_id              string `orm:"size(256);null"`  // 任务id
 	T_VerifyTemplate_id    string `orm:"size(256);null"`  // 模板id
 	T_VerifyTemplateMap_id string `orm:"size(256);null"`  // 标签id
@@ -99,14 +99,14 @@ func AddOrUpdate_VerifyTemplateMapData(List []VerifyTemplateMapData) (ids []int6
 }
 
 // 获取列表
-func Read_VerifyTemplateMapData_List(T_task_id, T_VerifyTemplate_id string, Map_List []VerifyTemplateMap) []VerifyTemplateMapData_R {
+func Read_VerifyTemplateMapData_List(T_source int, T_task_id, T_VerifyTemplate_id string, Map_List []VerifyTemplateMap) []VerifyTemplateMapData_R {
 
 	o := orm.NewOrm()
 	// 也可以直接使用 Model 结构体作为表名
 	var r []VerifyTemplateMapData
 	qs := o.QueryTable(new(VerifyTemplateMapData))
 	cond := orm.NewCondition()
-	cond1 := cond.And("T_task_id", T_task_id).And("T_VerifyTemplate_id", T_VerifyTemplate_id)
+	cond1 := cond.And("T_task_id", T_task_id).And("T_VerifyTemplate_id", T_VerifyTemplate_id).And("T_source", T_source)
 
 	qs.SetCond((*orm2.Condition)(cond1)).All(&r)
 

routers/router.go

@@ -18,5 +18,5 @@ func init() {
 	beego.Router("/VerifyTemplate/Map_Del", &controllers.VerifyTemplateController{}, "*:Map_Del")   // 获取未读消息
 
 	beego.Router("/VerifyTemplateMapData/List", &controllers.VerifyTemplateController{}, "*:Map_Data_List") // 标签数据列表
-	beego.Router("/VerifyTemplateMapData/Add", &controllers.VerifyTemplateController{}, "*:Map_Data_Add")   // 添加标签数据
+	beego.Router("/VerifyTemplateMapData/Pu", &controllers.VerifyTemplateController{}, "*:Map_Data_Pu")     // 添加标签数据
 }