schangxiang@126.com
2025-09-17 ff43ddf18764629ff875478e4e47a7281cbd230a
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
using Admin.NET.Core.Service;
using Admin.NET.Application.Entity;
using Microsoft.AspNetCore.Http;
namespace Admin.NET.Application;
/// <summary>
/// 容器关系基础表服务
/// </summary>
[ApiDescriptionSettings(ApplicationConst.WmsBaseGroupName, Order = 100)]
public class WmsContainerPackagingService : IDynamicApiController, ITransient
{
    private readonly SqlSugarRepository<WmsBaseContainerPackaging> _rep;
    public WmsContainerPackagingService(SqlSugarRepository<WmsBaseContainerPackaging> rep)
    {
        _rep = rep;
    }
 
    /// <summary>
    /// 分页查询容器关系基础表
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [HttpPost]
    [ApiDescriptionSettings(Name = "Page")]
    public async Task<SqlSugarPagedList<WmsContainerPackagingOutput>> Page(WmsContainerPackagingInput input)
    {
        var query = _rep.AsQueryable()
            .WhereIF(input.ContainerTypeId>0, u => u.ContainerTypeId == input.ContainerTypeId)
            .WhereIF(input.MaterialTypeId>0, u => u.MaterialTypeId == input.MaterialTypeId)
            .Select<WmsContainerPackagingOutput>();
        return await query.OrderBuilder(input).ToPagedListAsync(input.Page, input.PageSize);
    }
 
    /// <summary>
    /// 增加容器关系基础表
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [HttpPost]
    [ApiDescriptionSettings(Name = "Add")]
    public async Task<long> Add(AddWmsContainerPackagingInput input)
    {
        var entity = input.Adapt<WmsBaseContainerPackaging>();
        //验重
        await CheckExisit(entity);
        await _rep.InsertAsync(entity);
        return entity.Id;
    }
 
    /// <summary>
    /// 删除容器关系基础表
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [HttpPost]
    [ApiDescriptionSettings(Name = "Delete")]
    public async Task Delete(DeleteWmsContainerPackagingInput input)
    {
        var entity = await _rep.GetFirstAsync(u => u.Id == input.Id) ?? throw Oops.Oh(ErrorCodeEnum.D1002);
       // await _rep.FakeDeleteAsync(entity);   //假删除
       await _rep.DeleteAsync(entity);   //真删除
    }
 
    /// <summary>
    /// 更新容器关系基础表
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [HttpPost]
    [ApiDescriptionSettings(Name = "Update")]
    public async Task Update(UpdateWmsContainerPackagingInput input)
    {
        var entity = input.Adapt<WmsBaseContainerPackaging>();
        //验重
        await CheckExisit(entity, true);
        await _rep.AsUpdateable(entity).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();
    }
 
    /// <summary>
    /// 获取容器关系基础表
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [HttpGet]
    [ApiDescriptionSettings(Name = "Detail")]
    public async Task<WmsBaseContainerPackaging> Detail([FromQuery] QueryByIdWmsContainerPackagingInput input)
    {
        return await _rep.GetFirstAsync(u => u.Id == input.Id);
    }
 
    /// <summary>
    /// 获取容器关系基础表列表
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [HttpGet]
    [ApiDescriptionSettings(Name = "List")]
    public async Task<List<WmsContainerPackagingOutput>> List([FromQuery] WmsContainerPackagingInput input)
    {
        return await _rep.AsQueryable().Select<WmsContainerPackagingOutput>().ToListAsync();
    }
 
 
 
 
 
    #region 私有方法
 
    /// <summary>
    /// 根据联合主键验证数据是否已存在-数据库
    /// </summary>
    /// <param name="input"></param>
    /// <param name="isEdit"></param>
    /// <returns></returns>
    private async Task CheckExisit(WmsBaseContainerPackaging input, bool isEdit = false)
    {
        //输出数据已存在错误
        ErrorCodeItemMetadataAttribute metadata = ErrorCodeEnum.D1006.GetErrorCodeItemMetadata();
 
 
        WmsBaseContainerPackaging _existItem = null
            ;
        if (!isEdit)//新增
        {
            _existItem = await _rep.GetFirstAsync(u => u.MaterialId.Equals(input.MaterialId) && u.ContainerTypeId.Equals(input.ContainerTypeId));
            if (_existItem != null) throw Oops.Oh($"物料编号[{input.MaterialCode}]容器类型[{input.ContainerTypeName}]已关联{metadata.ErrorMessage}");
 
        }
        else//编辑 
        {
 
            //当前编辑数据以外是否存在重复
            _existItem = await _rep.GetFirstAsync(u => u.Id != input.Id && u.MaterialId.Equals(input.MaterialId) && u.ContainerTypeId.Equals(input.ContainerTypeId));
            if (_existItem != null) throw Oops.Oh($"物料编号[{input.MaterialCode}]容器类型[{input.ContainerTypeName}]已关联{metadata.ErrorMessage}");
 
        }
 
 
 
    }
 
 
 
    #endregion
 
 
 
}