2023-06-21

Nats/Nats.go

@@ -300,7 +300,7 @@ func NatsInit() {
 			if err != nil {
 				logs.Error(lib.FuncName(), "开始导出1.0数据失败", err)
 			} else {
-				System.Add_UserLogs_T(T_uuid, "任务数据-导出线上数据", "z_task_data_"+T_task_id, org)
+				System.Add_UserLogs_T(T_uuid, "任务数据-导出1.0数据失败", "z_task_data_"+T_task_id, org)
 				break
 			}
 			i++
@@ -308,29 +308,27 @@ func NatsInit() {
 
 		ChangeTableName(sql_file, T_task_id)
 
-		logs.Info("--------开始导入数据到【本地】---------")
+		logs.Info("--------开始导入数据到2.0【本地】---------")
 		j := 0
 		flag := false
-		// 清空表
-		//Task.CREATE_TaskData(conf.Local_AliasName, T_task_id)
-		//time.Sleep(2 * time.Second)
 		for j < 10 {
+			// 清空表
 			Task.Truncate_TaskData(conf.Local_AliasName, T_task_id)
 			time.Sleep(2 * time.Second)
 			org, err = Task.Insert_TaskData(conf.MysqlServer_Username, conf.MysqlServer_Password, conf.MysqlServer_UrlPort, conf.MysqlServer_Database, sql_file)
 			if err != nil {
-				logs.Error("任务数据-打包本地数据", "z_task_data_"+T_task_id, err.Error())
+				logs.Error("任务数据-导入1.0数据到2.0失败", "z_task_data_"+T_task_id, err.Error())
 			} else {
 				if Task.Check_TaskData_Num_Verify1(T_task_id) {
-					System.Add_UserLogs_T(T_uuid, "任务数据-打包本地数据", "z_task_data_"+T_task_id, org)
+					System.Add_UserLogs_T(T_uuid, "任务数据-导入1.0数据到2.0", "z_task_data_"+T_task_id, org)
 					flag = true
 					break
 				}
 			}
 			j++
 		}
-		// 重试10次后仍然没有成功导入数据
 
+		// 重试10次后仍然没有成功导入数据
 		if !flag {
 			// 清空本地数据
 			Task.Truncate_TaskData(conf.Local_AliasName, T_task_id)
@@ -340,12 +338,12 @@ func NatsInit() {
 			if err != nil {
 				logs.Error(lib.FuncName(), err)
 			}
-			System.Add_UserLogs_T(T_uuid, "任务数据-打包本地数据-失败", "线下导入数据z_task_data_"+T_task_id, "重试10次失败")
+			System.Add_UserLogs_T(T_uuid, "任务数据-导入1.0数据到2.0-失败", "线下导入数据z_task_data_"+T_task_id, "重试10次失败")
 			return
 		}
 
 		//删除导出的sql文件
-		//_ = os.Remove(sql_file)
+		_ = os.Remove(sql_file)
 
 		Task_r.T_collection_state = 1
 		err = NatsServer.Update_Task(Task_r)
@@ -353,8 +351,8 @@ func NatsInit() {
 			logs.Error(lib.FuncName(), err)
 			return
 		}
-		System.Add_UserLogs_T(T_uuid, "任务数据-打包本地数据", "z_task_data_"+T_task_id, "成功")
-		logs.Info("--------导入数据到本地【成功】！---------")
+		System.Add_UserLogs_T(T_uuid, "任务数据-导入1.0数据到2.0", "z_task_data_"+T_task_id, "成功")
+		logs.Info("--------导入1.0数据到2.0【成功】---------")
 
 	})
 }

controllers/TaskData.go

@@ -1323,9 +1323,13 @@ func (c *TaskDataController) CopyFromPositionAverageSN() {
 	sn2, id_str2 := sn_id2[0], sn_id2[1]
 	List1, _ := Task.Read_TaskData_ById_List_AES(Task_r.T_task_id, sn1, id_str1, StartTime, EndTime, 0, 9999)
 	List2, _ := Task.Read_TaskData_ById_List_AES(Task_r.T_task_id, sn2, id_str2, StartTime, EndTime, 0, 9999)
+	num := len(List1)
+	if len(List2) < len(List1) {
+		num = len(List2)
+	}
 	var list []Task.TaskData_
 	ct := copyTime
-	for i := 0; i < len(List1); i++ {
+	for i := 0; i < num; i++ {
 		if List1[i].T_time != List2[i].T_time {
 			ct = ct.Add(time.Second * time.Duration(T_saveT))
 			continue