ScheduleService.cs
6.41 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
using NCC.Common.Core.Manager;
using NCC.Common.Enum;
using NCC.Common.Extension;
using NCC.Dependency;
using NCC.DynamicApiController;
using NCC.Extend.Entitys.common_extend;
using NCC.Extend.Entitys.Dto.Schedule;
using NCC.FriendlyException;
using Mapster;
using Microsoft.AspNetCore.Mvc;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Threading.Tasks;
namespace NCC.Extend
{
/// <summary>
/// 项目计划
/// 版 本：V1.20.15
/// 版 权：Wesley（https://www.NCCsoft.com）
/// 作 者：NCC开发平台组
/// 日 期：2022-03-16
/// </summary>
[ApiDescriptionSettings(Tag = "Extend", Name = "Schedule", Order = 600)]
[Route("api/extend/[controller]")]
public class ScheduleService : IDynamicApiController, ITransient
{
private readonly ISqlSugarRepository<ScheduleEntity> _scheduleEntityRepository;
private readonly IUserManager _userManager;
/// <summary>
///
/// </summary>
/// <param name="scheduleEntityRepository"></param>
/// <param name="userManager"></param>
public ScheduleService(ISqlSugarRepository<ScheduleEntity> scheduleEntityRepository, IUserManager userManager)
{
_scheduleEntityRepository = scheduleEntityRepository;
_userManager = userManager;
}
#region GET
/// <summary>
/// 列表
/// </summary>
/// <param name="input">参数</param>
/// <returns></returns>
[HttpGet("")]
public async Task<dynamic> GetList([FromQuery] ScheduleListQuery input)
{
var data = await _scheduleEntityRepository.Entities.Where(x => x.CreatorUserId == _userManager.UserId && x.StartTime >= input.startTime.ToDate() && x.EndTime <= input.endTime.ToDate()&&x.DeleteMark==null).OrderBy(x => x.StartTime,OrderByType.Desc).ToListAsync();
var output = data.Adapt<List<ScheduleListOutput>>();
return new { list = output };
}
/// <summary>
/// 信息
/// </summary>
/// <param name="id">主键值</param>
/// <returns></returns>
[HttpGet("{id}")]
public async Task<dynamic> GetInfo(string id)
{
var data = (await _scheduleEntityRepository.FirstOrDefaultAsync(x=>x.Id==id&&x.DeleteMark==null)).Adapt<ScheduleInfoOutput>();
return data;
}
/// <summary>
/// app
/// </summary>
/// <param name="input"></param>
/// <returns></returns>
[HttpGet("AppList")]
public async Task<dynamic> GetAppList([FromQuery] ScheduleListQuery input)
{
var days = new Dictionary<string, int>();
var data = await _scheduleEntityRepository.Entities.Where(x => x.CreatorUserId == _userManager.UserId && x.StartTime >= input.startTime.ToDate() && x.EndTime <= input.endTime.ToDate() && x.DeleteMark == null).OrderBy(x => x.StartTime, OrderByType.Desc).ToListAsync();
var output = data.Adapt<List<ScheduleListOutput>>();
foreach (var item in GetAllDays(input.startTime.ToDate(), input.endTime.ToDate()))
{
var _startTime = item.ToString("yyyy-MM-dd") + " 23:59";
var _endTime = item.ToString("yyyy-MM-dd") + " 00:00";
var count = output.FindAll(m => m.startTime <= _startTime.ToDate() && m.endTime >= _endTime.ToDate()).Count;
days.Add(item.ToString("yyyyMMdd"), count);
}
var today_startTime = input.dateTime + " 23:59";
var today_endTime = input.dateTime + " 00:00";
return new
{
signList = days,
todayList = output.FindAll(m => m.startTime <= today_startTime.ToDate() && m.endTime >= today_endTime.ToDate())
};
}
#endregion
#region POST
/// <summary>
/// 新建
/// </summary>
/// <param name="input">实体对象</param>
/// <returns></returns>
[HttpPost("")]
public async Task Create([FromBody] ScheduleCrInput input)
{
var entity = input.Adapt<ScheduleEntity>();
var isOk= await _scheduleEntityRepository.Context.Insertable(entity).CallEntityMethod(m => m.Creator()).ExecuteCommandAsync();
if (isOk < 1)
throw NCCException.Oh(ErrorCode.COM1000);
}
/// <summary>
/// 更新
/// </summary>
/// <param name="id">主键值</param>
/// <param name="input">实体对象</param>
/// <returns></returns>
[HttpPut("{id}")]
public async Task Update(string id, [FromBody] ScheduleUpInput input)
{
var entity = input.Adapt<ScheduleEntity>();
var isOk = await _scheduleEntityRepository.Context.Updateable(entity).IgnoreColumns(ignoreAllNullColumns: true).CallEntityMethod(m => m.LastModify()).ExecuteCommandAsync();
if (isOk < 1)
throw NCCException.Oh(ErrorCode.COM1001);
}
/// <summary>
/// 删除
/// </summary>
/// <param name="id">主键值</param>
/// <returns></returns>
[HttpDelete("{id}")]
public async Task Delete(string id)
{
var entity = await _scheduleEntityRepository.FirstOrDefaultAsync(x => x.Id == id && x.DeleteMark == null);
if (entity == null)
throw NCCException.Oh(ErrorCode.COM1005);
var isOk = await _scheduleEntityRepository.Context.Updateable(entity).IgnoreColumns(ignoreAllNullColumns: true).CallEntityMethod(m => m.Delete()).ExecuteCommandAsync(); ;
if (isOk < 1)
throw NCCException.Oh(ErrorCode.COM1002);
}
#endregion
#region PrivateMethod
/// <summary>
/// 获取固定日期范围内的所有日期，以数组形式返回
/// </summary>
/// <param name="startTime"></param>
/// <param name="endTime"></param>
private DateTime[] GetAllDays(DateTime startTime, DateTime endTime)
{
var listDay = new List<DateTime>();
DateTime dtDay = new DateTime();
//循环比较，取出日期；
for (dtDay = startTime; dtDay.CompareTo(endTime) <= 0; dtDay = dtDay.AddDays(1))
{
listDay.Add(dtDay);
}
return listDay.ToArray();
}
#endregion
}
}