chengsc
2025-04-14 d2588d8d1305171e7716055b23a6b5706e9cc04b
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
// Admin.NET 项目的版权、商标、专利和其他相关权利均受相应法律法规的保护。使用本项目应遵守相关法律法规和许可证的要求。
//
// 本项目主要遵循 MIT 许可证和 Apache 许可证(版本 2.0)进行分发和使用。许可证位于源代码树根目录中的 LICENSE-MIT 和 LICENSE-APACHE 文件。
//
// 不得利用本项目从事危害国家安全、扰乱社会秩序、侵犯他人合法权益等法律法规禁止的活动!任何基于本项目二次开发而产生的一切法律纠纷和责任,我们不承担任何责任!
 
using Admin.NET.Core.Service;
using AngleSharp.Dom;
using Microsoft.AspNetCore.Http;
using WCS.Application.Entity;
namespace WCS.Application;
 
/// <summary>
/// 分拣任务服务
/// </summary>
[ApiDescriptionSettings(ApplicationConst.GroupName, Order = 100)]
public class WcsOderTaskService : IDynamicApiController, ITransient
{
    private readonly SqlSugarRepository<WcsOderTask> _wcsOderTaskRep;
    public WcsOderTaskService(SqlSugarRepository<WcsOderTask> wcsOderTaskRep)
    {
        _wcsOderTaskRep = wcsOderTaskRep;
    }
 
    /// <summary>
    /// 分页查询分拣任务
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [HttpPost]
    [ApiDescriptionSettings(Name = "Page")]
    [DisplayName("分页查询分拣任务")]
    public async Task<SqlSugarPagedList<WcsOderTaskOutput>> Page(PageWcsOderTaskInput input)
    {
        input.SearchKey = input.SearchKey?.Trim();
        var query = _wcsOderTaskRep.AsQueryable()
            .WhereIF(!string.IsNullOrEmpty(input.SearchKey), u =>
                u.OrderNo.Contains(input.SearchKey)
                || u.TaskNo.Contains(input.SearchKey)
                || u.LotNo.Contains(input.SearchKey)
                || u.SkuNo.Contains(input.SearchKey)
                || u.SkuName.Contains(input.SearchKey)
                || u.BoxType.Contains(input.SearchKey)
                || u.Information.Contains(input.SearchKey)
            )
            .WhereIF(!string.IsNullOrWhiteSpace(input.OrderNo), u => u.OrderNo.Contains(input.OrderNo.Trim()))
            .WhereIF(!string.IsNullOrWhiteSpace(input.TaskNo), u => u.TaskNo.Contains(input.TaskNo.Trim()))
            .WhereIF(!string.IsNullOrWhiteSpace(input.LotNo), u => u.LotNo.Contains(input.LotNo.Trim()))
            .WhereIF(!string.IsNullOrWhiteSpace(input.SkuNo), u => u.SkuNo.Contains(input.SkuNo.Trim()))
            .WhereIF(!string.IsNullOrWhiteSpace(input.SkuName), u => u.SkuName.Contains(input.SkuName.Trim()))
            .WhereIF(!string.IsNullOrWhiteSpace(input.BoxType), u => u.BoxType.Contains(input.BoxType.Trim()))
            .WhereIF(input.Qty>0, u => u.Qty == input.Qty)
            .WhereIF(input.TaskType.HasValue, u => u.TaskType == input.TaskType)
            .WhereIF(input.Status.HasValue, u => u.Status == input.Status)
            .WhereIF(input.IsSuccess.HasValue, u => u.IsSuccess == input.IsSuccess)
            .WhereIF(!string.IsNullOrWhiteSpace(input.Information), u => u.Information.Contains(input.Information.Trim()))
            .WhereIF(!string.IsNullOrWhiteSpace(input.CreateUserName), u => u.OrderNo.Contains(input.CreateUserName.Trim()))
            .Select<WcsOderTaskOutput>();
        return await query.OrderBuilder(input).ToPagedListAsync(input.Page, input.PageSize);
    }
 
    /// <summary>
    /// 增加分拣任务
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [HttpPost]
    [ApiDescriptionSettings(Name = "Add")]
    [DisplayName("增加分拣任务")]
    public async Task<long> Add(AddWcsOderTaskInput input)
    {
        var entity = input.Adapt<WcsOderTask>();
        await _wcsOderTaskRep.InsertAsync(entity);
        return entity.Id;
    }
 
    /// <summary>
    /// 删除分拣任务
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [HttpPost]
    [ApiDescriptionSettings(Name = "Delete")]
    [DisplayName("删除分拣任务")]
    public async Task Delete(DeleteWcsOderTaskInput input)
    {
        var entity = await _wcsOderTaskRep.GetFirstAsync(u => u.Id == input.Id) ?? throw Oops.Oh(ErrorCodeEnum.D1002);
        await _wcsOderTaskRep.FakeDeleteAsync(entity);   //假删除
        //await _wcsOderTaskRep.DeleteAsync(entity);   //真删除
    }
 
    /// <summary>
    /// 更新分拣任务
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [HttpPost]
    [ApiDescriptionSettings(Name = "Update")]
    [DisplayName("更新分拣任务")]
    public async Task Update(UpdateWcsOderTaskInput input)
    {
        var entity = input.Adapt<WcsOderTask>();
        await _wcsOderTaskRep.AsUpdateable(entity).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();
    }
 
    /// <summary>
    /// 获取分拣任务
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [HttpGet]
    [ApiDescriptionSettings(Name = "Detail")]
    [DisplayName("获取分拣任务")]
    public async Task<WcsOderTask> Detail([FromQuery] QueryByIdWcsOderTaskInput input)
    {
        return await _wcsOderTaskRep.GetFirstAsync(u => u.Id == input.Id);
    }
 
    /// <summary>
    /// 获取分拣任务列表
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [HttpGet]
    [ApiDescriptionSettings(Name = "List")]
    [DisplayName("获取分拣任务列表")]
    public async Task<List<WcsOderTaskOutput>> List([FromQuery] PageWcsOderTaskInput input)
    {
        return await _wcsOderTaskRep.AsQueryable().Select<WcsOderTaskOutput>().ToListAsync();
    }
}