feat:分析

internal/dao/internal/analyzeTask.go

@@ -101,7 +101,7 @@ func (a *AnalyzeTask) Run() {
 						if ui.FormatParam.STime <= p.JgTime && ui.FormatParam.ETime >= p.JgTime {
 							ui.Start()
 							ui.Push(p)
-							//
+							//每4000条数据查看一次 用户是否取消
 							if iterationTimes%20 == 0 {
 								ui.IsCancel = utility.IsAnalyzeCancel(ui.RId)
 							}

internal/dao/internal/userTask.go

@@ -27,7 +27,7 @@ type UserTask struct {
 	StartTime            int64                        //开始时间
 	EndTime              int64                        //结束时间
 	IsEnd                bool                         //是否结束
-	IsCancel             bool                         //是否已取消-----------------待处理
+	IsCancel             bool                         //是否已取消
 	IsFalse              bool                         //是否离线分析成功
 	IsRatio              bool                         //是否需要进行环比
 	PInfo                chan *entity.ProjectInfo     //项目信息
@@ -88,8 +88,6 @@ func (ut *UserTask) Run() {
 			if ut.MatchConditions(info) {
 				//模块计算
 				ut.Calculate(info)
-				//数据整理
-				ut.DataCollation()
 			}
 		case <-ut.Ticker.C:
 			//是否已取消
@@ -97,8 +95,13 @@ func (ut *UserTask) Run() {
 				ut.IsCancel = utility.IsAnalyzeCancel(ut.RId)
 			}
 			if !ut.IsCancel {
+				//数据整理 及 二次计算
+				ut.DataCollation()
+				//结果保存
 				ut.ResultSave()
+				//消息通知
 				ut.SendMsg()
+				//结束
 				ut.IsEnd = true
 			}
 			break