浏览代码

feature:基点任务变更 添加完整任务ID

liran 1 年之前
父节点
当前提交
25e5a3f53a

+ 7 - 0
src/dashoo.cn/genepoint_srv/business/converseService/converseService.go

@@ -132,6 +132,13 @@ func (this *ConverseService) ScanNewTaskDetail() []Sample_Storage_Task {
 	return tasks
 }
 
+// 查询任务表的完整TaskId
+func (this *ConverseService) GetFullTaskId(TaskId string) (fullTaskId string) {
+	sql := fmt.Sprintf("SELECT Full_task_id FROM %s WHERE TaskId = '%s' ORDER BY id LIMIT 1", TABLE_TAST, TaskId)
+	this.DBE.SQL(sql).Get(&fullTaskId)
+	return
+}
+
 // 更新任务表的完整TaskId
 func (this *ConverseService) UpdateFullTaskId(id int, fullTaskId string) (err error) {
 	updApplySql := fmt.Sprintf("UPDATE %s SET Full_task_id = '%s' WHERE id = %d", TABLE_TAST, fullTaskId, id)

+ 4 - 0
src/dashoo.cn/genepoint_srv/controllers/converse/converse.go

@@ -66,10 +66,14 @@ func (ctrl *ConverseController) SearchDatabase() map[string]*RequestEntity {
 		svc.HandleTaskDetail(value.Task_type, reqMap[value.Task_id], &value)
 
 		// 记录完整的taskId
+		if value.Task_type == 7 {
+			taskid = svc.GetFullTaskId(value.Task_id)
+		}
 		err := svc.UpdateFullTaskId(value.Id, taskid)
 		if err != nil {
 			log.Println("更新完整taskId失败", err)
 		}
+
 	}
 	for _, v := range reqMap {
 		//log.Println("****************************")