| | |
| | | endTime := cp.EndTime |
| | | queryRes, queryErr := esutil.QueryAnalyServerData(ip, port, config.EsInfo.EsIndex.AiOcean.IndexName, startTime, endTime, analyServerId) |
| | | if queryErr != nil { |
| | | util.ResponseFormat(c, code.InvalidRequest, "校验数据失败") |
| | | util.ResponseFormat(c, code.InvalidRequest, queryErr) |
| | | return |
| | | } |
| | | if queryRes != true { |
| | |
| | | } |
| | | addRes, addErr := esutil.AddDelTask(ip, port, config.BasicFS.IndexName, startTime, endTime, analyServerId) |
| | | if addErr != nil { |
| | | util.ResponseFormat(c, code.InvalidRequest, "追加任务失败") |
| | | util.ResponseFormat(c, code.InvalidRequest, addErr) |
| | | return |
| | | } |
| | | if addRes != true { |
| | |
| | | } |
| | | deleteRes, deleteErr := esutil.DeleteAnalyServerData(ip, port, config.BasicFS.IndexName, startTime, endTime, analyServerId) |
| | | if deleteErr != nil { |
| | | util.ResponseFormat(c, code.InvalidRequest, "数据删除失败") |
| | | util.ResponseFormat(c, code.InvalidRequest, deleteErr) |
| | | return |
| | | } |
| | | if deleteRes != true { |