Рефакторинг - переход на один класс с временем.

This commit is contained in:
Danil Kislov
2019-06-27 18:40:42 +03:00
parent 2c1e396502
commit 1488aafcfd
12 changed files with 136 additions and 124 deletions
+2 -2
View File
@@ -127,7 +127,7 @@ namespace JiraTimeBot.JiraIntegration
foreach (var workLog in userWorklogs) foreach (var workLog in userWorklogs)
{ {
var timeSpent = TimeSpan.FromSeconds(workLog.TimeSpentInSeconds); var timeSpent = TimeSpan.FromSeconds(workLog.TimeSpentInSeconds);
var timeDiff = Math.Abs((timeSpent - taskTimeItem.Time).TotalMinutes); var timeDiff = Math.Abs((timeSpent - taskTimeItem.TimeSpent).TotalMinutes);
if (timeDiff > 1 || userWorklogs.Count > 1 || userWorklogs.First().Comment != comment) if (timeDiff > 1 || userWorklogs.Count > 1 || userWorklogs.First().Comment != comment)
{ {
if (timeDiff > 1) if (timeDiff > 1)
@@ -165,7 +165,7 @@ namespace JiraTimeBot.JiraIntegration
if (!hasTodayWorklog) if (!hasTodayWorklog)
{ {
var timeSpentJira = $"{taskTimeItem.Time.TotalMinutes}m"; var timeSpentJira = $"{taskTimeItem.TimeSpent.TotalMinutes}m";
Worklog workLogToAdd = new Worklog(timeSpentJira, date.Value, comment); Worklog workLogToAdd = new Worklog(timeSpentJira, date.Value, comment);
if (!dummy) if (!dummy)
@@ -5,7 +5,8 @@ using System.Threading;
using Atlassian.Jira; using Atlassian.Jira;
using JiraTimeBot.Configuration; using JiraTimeBot.Configuration;
using JiraTimeBot.Mercurial; using JiraTimeBot.Mercurial;
using JiraTimeBot.Mercurial.Objects; using JiraTimeBot.TaskTime.Objects;
namespace JiraTimeBot.JiraIntegration namespace JiraTimeBot.JiraIntegration
{ {
@@ -20,19 +21,19 @@ namespace JiraTimeBot.JiraIntegration
_jiraApi = jiraApi; _jiraApi = jiraApi;
} }
public List<MercurialCommitItem> GetMercurialLog(Settings settings, public List<TaskTimeItem> GetMercurialLog(Settings settings,
DateTime? date = null, DateTime? date = null,
CancellationToken cancellationToken = default(CancellationToken)) CancellationToken cancellationToken = default(CancellationToken))
{ {
date = date.GetValueOrDefault(DateTime.Now.Date); date = date.GetValueOrDefault(DateTime.Now.Date);
var workTasks = new List<MercurialCommitItem>(); var workTasks = new List<TaskTimeItem>();
var issues = _jiraApi.GetIssuesByJQL(settings.JiraQuery, settings, date, cancellationToken); var issues = _jiraApi.GetIssuesByJQL(settings.JiraQuery, settings, date, cancellationToken);
foreach (var issue in issues) foreach (var issue in issues)
{ {
if (cancellationToken.IsCancellationRequested) if (cancellationToken.IsCancellationRequested)
{ {
return new List<MercurialCommitItem>(); return new List<TaskTimeItem>();
} }
var comments = issue.GetCommentsAsync(cancellationToken).Result?.ToList() ?? new List<Comment>(); var comments = issue.GetCommentsAsync(cancellationToken).Result?.ToList() ?? new List<Comment>();
@@ -43,25 +44,27 @@ namespace JiraTimeBot.JiraIntegration
if (userComments.Any()) if (userComments.Any())
{ {
foreach (var comment in userComments) foreach (var comment in userComments.OrderBy(f=>f.CreatedDate))
{ {
workTasks.Add(new MercurialCommitItem workTasks.Add(new TaskTimeItem
{ {
StartTime = issue.Updated.GetValueOrDefault(date.Value),
Description = issue.Summary, Description = issue.Summary,
Time = issue.Updated.GetValueOrDefault(date.Value),
Branch = issue.Key.Value, Branch = issue.Key.Value,
FilesAffected = 1 FilesAffected = 1,
Commits = 1
}); });
} }
} }
else else
{ {
workTasks.Add(new MercurialCommitItem workTasks.Add(new TaskTimeItem
{ {
StartTime = issue.Updated.GetValueOrDefault(date.Value),
Description = issue.Summary, Description = issue.Summary,
Time = issue.Updated.GetValueOrDefault(date.Value),
Branch = issue.Key.Value, Branch = issue.Key.Value,
FilesAffected = 1 FilesAffected = 1,
Commits = 1
}); });
} }
} }
-1
View File
@@ -99,7 +99,6 @@
<DependentUpon>frmMain.cs</DependentUpon> <DependentUpon>frmMain.cs</DependentUpon>
</Compile> </Compile>
<Compile Include="JiraIntegration\JiraApi.cs" /> <Compile Include="JiraIntegration\JiraApi.cs" />
<Compile Include="Mercurial\Objects\MercurialCommitItem.cs" />
<Compile Include="Mercurial\MercurialLog.cs" /> <Compile Include="Mercurial\MercurialLog.cs" />
<Compile Include="Configuration\PasswordEncryptionClass.cs" /> <Compile Include="Configuration\PasswordEncryptionClass.cs" />
<Compile Include="Program.cs" /> <Compile Include="Program.cs" />
+1 -2
View File
@@ -5,7 +5,6 @@ using System.Threading;
using System.Threading.Tasks; using System.Threading.Tasks;
using JiraTimeBot.Configuration; using JiraTimeBot.Configuration;
using JiraTimeBot.Mercurial; using JiraTimeBot.Mercurial;
using JiraTimeBot.Mercurial.Objects;
using JiraTimeBot.TasksProcessors; using JiraTimeBot.TasksProcessors;
using JiraTimeBot.TaskTime; using JiraTimeBot.TaskTime;
using JiraTimeBot.TaskTime.Objects; using JiraTimeBot.TaskTime.Objects;
@@ -79,7 +78,7 @@ namespace JiraTimeBot
_log.Info("Использую Jira как источник информации."); _log.Info("Использую Jira как источник информации.");
mercurial = _mercurialProviders.JiraCommitEmulator; mercurial = _mercurialProviders.JiraCommitEmulator;
} }
List<MercurialCommitItem> commits = mercurial.GetMercurialLog(settings, realDate, cancellationToken); List<TaskTimeItem> commits = mercurial.GetMercurialLog(settings, realDate, cancellationToken);
List<TaskTimeItem> taskTimes = _taskTimeDiscoverer.CalculateTaskTime(commits, settings, cancellationToken); List<TaskTimeItem> taskTimes = _taskTimeDiscoverer.CalculateTaskTime(commits, settings, cancellationToken);
if (cancellationToken.IsCancellationRequested) if (cancellationToken.IsCancellationRequested)
+2 -2
View File
@@ -2,12 +2,12 @@
using System.Collections.Generic; using System.Collections.Generic;
using System.Threading; using System.Threading;
using JiraTimeBot.Configuration; using JiraTimeBot.Configuration;
using JiraTimeBot.Mercurial.Objects; using JiraTimeBot.TaskTime.Objects;
namespace JiraTimeBot.Mercurial namespace JiraTimeBot.Mercurial
{ {
public interface IMercurialLog public interface IMercurialLog
{ {
List<MercurialCommitItem> GetMercurialLog(Settings settings, DateTime? date = null, CancellationToken cancellationToken = default(CancellationToken)); List<TaskTimeItem> GetMercurialLog(Settings settings, DateTime? date = null, CancellationToken cancellationToken = default(CancellationToken));
} }
} }
+12 -11
View File
@@ -6,7 +6,7 @@ using System.Text;
using System.Threading; using System.Threading;
using JiraTimeBot.Configuration; using JiraTimeBot.Configuration;
using JiraTimeBot.Mercurial.Modifiers; using JiraTimeBot.Mercurial.Modifiers;
using JiraTimeBot.Mercurial.Objects; using JiraTimeBot.TaskTime.Objects;
using Mercurial; using Mercurial;
namespace JiraTimeBot.Mercurial namespace JiraTimeBot.Mercurial
@@ -24,22 +24,22 @@ namespace JiraTimeBot.Mercurial
_technicalInfoSkipper = technicalInfoSkipper; _technicalInfoSkipper = technicalInfoSkipper;
} }
public List<MercurialCommitItem> GetMercurialLog(Settings settings, DateTime? date = null, CancellationToken cancellationToken = default(CancellationToken)) public List<TaskTimeItem> GetMercurialLog(Settings settings, DateTime? date = null, CancellationToken cancellationToken = default(CancellationToken))
{ {
if (string.IsNullOrEmpty(settings.RepositoryPath) || !Directory.Exists(settings.RepositoryPath)) if (string.IsNullOrEmpty(settings.RepositoryPath) || !Directory.Exists(settings.RepositoryPath))
{ {
_log.Error("Папка с репо не сушествует."); _log.Error("Папка с репо не сушествует.");
return new List<MercurialCommitItem>(); return new List<TaskTimeItem>();
} }
date = date.GetValueOrDefault(DateTime.Now.Date); date = date.GetValueOrDefault(DateTime.Now.Date);
var workTasks = new List<MercurialCommitItem>(); var workTasks = new List<TaskTimeItem>();
foreach (var repoDirectory in Directory.GetDirectories(settings.RepositoryPath)) foreach (var repoDirectory in Directory.GetDirectories(settings.RepositoryPath))
{ {
if (cancellationToken.IsCancellationRequested) if (cancellationToken.IsCancellationRequested)
{ {
return new List<MercurialCommitItem>(); return new List<TaskTimeItem>();
} }
//var project = new DirectoryInfo(repoDirectory).Name; //var project = new DirectoryInfo(repoDirectory).Name;
@@ -62,7 +62,7 @@ namespace JiraTimeBot.Mercurial
{ {
if (cancellationToken.IsCancellationRequested) if (cancellationToken.IsCancellationRequested)
{ {
return new List<MercurialCommitItem>(); return new List<TaskTimeItem>();
} }
var commitMessage = FixEncoding(changeset.CommitMessage); var commitMessage = FixEncoding(changeset.CommitMessage);
@@ -72,25 +72,26 @@ namespace JiraTimeBot.Mercurial
} }
commitMessage = _technicalInfoSkipper.StripTechnicalInfo(commitMessage); commitMessage = _technicalInfoSkipper.StripTechnicalInfo(commitMessage);
workTasks.Add(new MercurialCommitItem workTasks.Add(new TaskTimeItem
{ {
StartTime = changeset.Timestamp,
Description = commitMessage, Description = commitMessage,
Branch = changeset.Branch, Branch = changeset.Branch,
Time = changeset.Timestamp, FilesAffected = changeset.PathActions.Count,
FilesAffected = changeset.PathActions.Count Commits = 1,
TimeSpent = TimeSpan.Zero
}); });
_log?.Trace($" - Найден changeset: {changeset.Timestamp} - {changeset.Branch} - {changeset.AuthorEmailAddress} - {commitMessage}"); _log?.Trace($" - Найден changeset: {changeset.Timestamp} - {changeset.Branch} - {changeset.AuthorEmailAddress} - {commitMessage}");
} }
} }
if (!workTasks.Any()) if (!workTasks.Any())
{ {
return new List<MercurialCommitItem>(); return new List<TaskTimeItem>();
} }
return workTasks; return workTasks;
} }
private string FixEncoding(string source) private string FixEncoding(string source)
{ {
//перекодируем сообщение - ибо оно криво забирается в 1252 //перекодируем сообщение - ибо оно криво забирается в 1252
@@ -1,12 +0,0 @@
using System;
namespace JiraTimeBot.Mercurial.Objects
{
public class MercurialCommitItem
{
public string Description { get; set; }
public string Branch { get; set; }
public DateTime Time { get; set; }
public int FilesAffected { get; set; }
}
}
@@ -1,13 +1,13 @@
using System.Collections.Generic; using System.Collections.Generic;
using System.Threading; using System.Threading;
using JiraTimeBot.Configuration; using JiraTimeBot.Configuration;
using JiraTimeBot.Mercurial.Objects;
using JiraTimeBot.TaskTime.Objects; using JiraTimeBot.TaskTime.Objects;
namespace JiraTimeBot.TaskTime namespace JiraTimeBot.TaskTime
{ {
public interface ITaskTimeCalculator public interface ITaskTimeCalculator
{ {
List<TaskTimeItem> CalculateTaskTime(List<MercurialCommitItem> commitItems, Settings settings, CancellationToken cancellationToken = default(CancellationToken)); List<TaskTimeItem> CalculateTaskTime(List<TaskTimeItem> commitItems, Settings settings, CancellationToken cancellationToken = default(CancellationToken));
} }
} }
@@ -6,10 +6,9 @@ namespace JiraTimeBot.TaskTime.Objects
{ {
public string Description { get; set; } public string Description { get; set; }
public string Branch { get; set; } public string Branch { get; set; }
public TimeSpan Time { get; set; }
public int Commits { get; set; }
public DateTime StartTime { get; set; } public DateTime StartTime { get; set; }
public DateTime EndTime { get; set; } public TimeSpan TimeSpent { get; set; }
public int Commits { get; set; }
public int FilesAffected { get; set; }
} }
} }
@@ -4,7 +4,7 @@ using System.Linq;
using System.Text; using System.Text;
using System.Threading; using System.Threading;
using JiraTimeBot.Configuration; using JiraTimeBot.Configuration;
using JiraTimeBot.Mercurial.Objects;
using JiraTimeBot.TaskTime.Objects; using JiraTimeBot.TaskTime.Objects;
namespace JiraTimeBot.TaskTime namespace JiraTimeBot.TaskTime
@@ -18,96 +18,119 @@ namespace JiraTimeBot.TaskTime
_log = log; _log = log;
} }
public List<TaskTimeItem> CalculateTaskTime(List<MercurialCommitItem> commits, Settings settings, CancellationToken cancellationToken = default(CancellationToken)) private List<TaskTimeItem> SpreadTime(List<TaskTimeItem> source, int minutes, int roundToMinutes, bool up = false)
{
if (source == null || !source.Any())
{
return new List<TaskTimeItem>();
}
List<TaskTimeItem> newList = new List<TaskTimeItem>();
int remainMinutes = minutes;
//Нам нужно раскидать 480 минут в день.
foreach (var taskGroup in source.GroupBy(f => f.Branch).OrderByDescending(f => f.Count()))
{
int currentTaskCommits = taskGroup.Count();
int currentTaskTime = (int)RoundTo(minutes / source.Count * currentTaskCommits, roundToMinutes, up);
remainMinutes = remainMinutes - currentTaskTime;
var orderedTasks = taskGroup.OrderBy(f => f.StartTime).ToArray();
StringBuilder sb = new StringBuilder();
foreach (var task in orderedTasks)
{
sb.AppendLine($"- {task.Description}");
}
var taskTimeItem = new TaskTimeItem
{
Branch = taskGroup.Key,
TimeSpent = TimeSpan.FromMinutes(taskGroup.Sum(f=>f.TimeSpent.TotalMinutes)) + TimeSpan.FromMinutes(currentTaskTime),
Commits = taskGroup.Sum(f=>f.Commits),
Description = sb.ToString(),
StartTime = taskGroup.Min(f=>f.StartTime),
FilesAffected = taskGroup.Sum(f=>f.FilesAffected)
};
newList.Add(taskTimeItem);
}
newList = newList.OrderByDescending(f => f.TimeSpent).ToList();
return newList;
}
public List<TaskTimeItem> CalculateTaskTime(List<TaskTimeItem> commits, Settings settings, CancellationToken cancellationToken = default(CancellationToken))
{ {
int minutesPerWorkDay = settings.MinuterPerWorkDay + GetRandomMinutes(settings); int minutesPerWorkDay = settings.MinuterPerWorkDay + GetRandomMinutes(settings);
int workHours = (settings.MinuterPerWorkDay / 60); int workHours = (settings.MinuterPerWorkDay / 60);
int totalCommitsCount = commits.Count; int totalCommitsCount = commits.Count;
if (cancellationToken.IsCancellationRequested)
{
return new List<TaskTimeItem>();
}
if (!commits.Any()) if (!commits.Any())
{ {
return new List<TaskTimeItem>(); return new List<TaskTimeItem>();
} }
FixTooBigInterval(settings, workHours, totalCommitsCount);
int remainMinutes = minutesPerWorkDay;
var timeControlTask = GetTimeControlTask(settings, ref remainMinutes);
var workTimeItems = SpreadTime(commits, remainMinutes, settings.RoundToMinutes);
if (timeControlTask != null)
{
workTimeItems.Add(timeControlTask);
}
remainMinutes = minutesPerWorkDay - (int) workTimeItems.Sum(f => f.TimeSpent.TotalMinutes);
if (remainMinutes != 0)
{
_log.Trace($"Погрешность распределения времени: {remainMinutes}. Добавляю к первой задаче.");
}
if ((workTimeItems.First().TimeSpent.TotalMinutes > Math.Abs(remainMinutes) && remainMinutes < 0) || remainMinutes > 0)
{
//если переборщили или не достаточно добавили до 8 часов - скореектируем остаток в первой задаче (она самая трудозатратная).
workTimeItems.First().TimeSpent += TimeSpan.FromMinutes(remainMinutes);
}
PrintTotal(workTimeItems);
return workTimeItems;
}
private TaskTimeItem GetTimeControlTask(Settings settings, ref int minutesPerWorkDay)
{
//Если указана задача контроля времени - то спишем туда 30 минут и вычеркнем их из общего рабочего времени.
if (!string.IsNullOrEmpty(settings.TimeControlTask))
{
minutesPerWorkDay = minutesPerWorkDay - 30;
return new TaskTimeItem
{
TimeSpent = TimeSpan.FromMinutes(30),
Branch = settings.TimeControlTask,
Commits = 1,
Description = "Ведение учета времени"
};
}
return null;
}
private void FixTooBigInterval(Settings settings, int totalCommitsCount, int workHours)
{
//если кол-во коммитов более чем кол-во интервалов - то уменьшим интервал вдвое. //если кол-во коммитов более чем кол-во интервалов - то уменьшим интервал вдвое.
while (totalCommitsCount > (workHours * (60.0 / settings.RoundToMinutes))) while (totalCommitsCount > (workHours * (60.0 / settings.RoundToMinutes)))
{ {
settings.RoundToMinutes = (int)RoundTo((decimal)(settings.RoundToMinutes / 2.0), 5); settings.RoundToMinutes = (int) RoundTo((decimal) (settings.RoundToMinutes / 2.0), 5);
_log.Info($"Слишком много задач - уменьшаю интервал до {settings.RoundToMinutes}."); _log.Info($"Слишком много задач - уменьшаю интервал до {settings.RoundToMinutes}.");
if (settings.RoundToMinutes == 5) if (settings.RoundToMinutes == 5)
{ {
break; break;
} }
} }
List<TaskTimeItem> workTimeItems = new List<TaskTimeItem>();
//Если указана задача контроля времени - то спишем туда 30 минут и вычеркнем их из общего рабочего времени.
if (!string.IsNullOrEmpty(settings.TimeControlTask))
{
minutesPerWorkDay = minutesPerWorkDay - 30;
workTimeItems.Add(new TaskTimeItem
{
Time = TimeSpan.FromMinutes(30),
Branch = settings.TimeControlTask,
Commits = 1,
Description = "Ведение учета времени",
StartTime = DateTime.Now.Date
});
}
int remainMinutes = minutesPerWorkDay;
//Нам нужно раскидать 480 минут в день.
foreach (var taskGroup in commits.GroupBy(f => f.Branch).OrderByDescending(f=>f.Count()))
{
if (cancellationToken.IsCancellationRequested)
{
return new List<TaskTimeItem>();
}
int currentTaskCommits = taskGroup.Count();
int currentTaskTime = (int)RoundTo(minutesPerWorkDay / totalCommitsCount * currentTaskCommits, settings.RoundToMinutes, false);
remainMinutes = remainMinutes - currentTaskTime;
var orderedTasks = taskGroup.OrderBy(f => f.Time).ToArray();
StringBuilder sb = new StringBuilder();
foreach (var task in orderedTasks)
{
sb.AppendLine($"- {task.Description}");
}
var taskTimeItem = new TaskTimeItem
{
Branch = taskGroup.Key,
Time = TimeSpan.FromMinutes(currentTaskTime),
Commits = taskGroup.Count(),
Description = sb.ToString(),
StartTime = orderedTasks.First().Time,
EndTime = orderedTasks.Last().Time
};
workTimeItems.Add(taskTimeItem);
}
if (!workTimeItems.Any())
{
return new List<TaskTimeItem>();
}
workTimeItems = workTimeItems.OrderByDescending(f => f.Time).ToList();
if (remainMinutes != 0)
{
_log.Trace($"Погрешность распределения времени: {remainMinutes}. Добавляю к первой задаче.");
}
if ((workTimeItems.First().Time.TotalMinutes > Math.Abs(remainMinutes) && remainMinutes < 0) || remainMinutes > 0)
{
//если переборщили или не достаточно добавили до 8 часов - скореектируем остаток в первой задаче (она самая трудозатратная).
workTimeItems.First().Time += TimeSpan.FromMinutes(remainMinutes);
}
PrintTotal(workTimeItems);
return workTimeItems;
} }
private int GetRandomMinutes(Settings settings) private int GetRandomMinutes(Settings settings)
@@ -123,7 +146,7 @@ namespace JiraTimeBot.TaskTime
var totalTime = TimeSpan.Zero; var totalTime = TimeSpan.Zero;
foreach (var workTimeItem in workTimeItems) foreach (var workTimeItem in workTimeItems)
{ {
totalTime += workTimeItem.Time; totalTime += workTimeItem.TimeSpent;
} }
_log.Trace($"Итоговое реально проставляемое время: {totalTime}"); _log.Trace($"Итоговое реально проставляемое время: {totalTime}");
@@ -23,10 +23,10 @@ namespace JiraTimeBot.TasksProcessors
{ {
_log.Trace($"На реальную дату {realDate:dd.MM.yyyy} распределение по задачам:"); _log.Trace($"На реальную дату {realDate:dd.MM.yyyy} распределение по задачам:");
foreach (var taskTime in taskTimes.OrderByDescending(f => f.Time)) foreach (var taskTime in taskTimes.OrderByDescending(f => f.TimeSpent))
{ {
var taskName = _jiraApi.GetTaskName(taskTime.Branch, settings); var taskName = _jiraApi.GetTaskName(taskTime.Branch, settings);
_log.Trace($" - [{taskTime.Branch}, коммитов {taskTime.Commits}]: {taskName} - {taskTime.Time}"); _log.Trace($" - [{taskTime.Branch}, коммитов {taskTime.Commits}]: {taskName} - {taskTime.TimeSpent}");
} }
} }
} }
@@ -23,7 +23,7 @@ namespace JiraTimeBot.TasksProcessors
_log.Trace($"На реальную дату {realDate:dd.MM.yyyy} распределение по задачам:"); _log.Trace($"На реальную дату {realDate:dd.MM.yyyy} распределение по задачам:");
foreach (var taskTime in taskTimes) foreach (var taskTime in taskTimes)
{ {
_log.Trace($"- {taskTime.Branch} (коммитов {taskTime.Commits}): {taskTime.Time}"); _log.Trace($"- {taskTime.Branch} (коммитов {taskTime.Commits}): {taskTime.TimeSpent}");
} }
_jiraApi.SetTodayWorklog(taskTimes, settings, date: setForDate, dummy: dummyMode, addCommentsToWorklog: settings.AddCommentsToWorklog, cancellationToken: cancellationToken); _jiraApi.SetTodayWorklog(taskTimes, settings, date: setForDate, dummy: dummyMode, addCommentsToWorklog: settings.AddCommentsToWorklog, cancellationToken: cancellationToken);