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
148
149
150
151
152
153
154
155
156
157
158
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 WmsMaterialTypeService : IDynamicApiController, ITransient
{
    private readonly SqlSugarRepository<WmsBaseMaterial> _wmsMaterialRep;
    private readonly SqlSugarRepository<WmsBaseMaterialType> _rep;
    public WmsMaterialTypeService(SqlSugarRepository<WmsBaseMaterialType> rep,
                SqlSugarRepository<WmsBaseMaterial> wmsMaterialRep
)
    {
        _rep = rep;
        _wmsMaterialRep = wmsMaterialRep;
    }
 
    /// <summary>
    /// 分页查询物料类型表
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [HttpPost]
    [ApiDescriptionSettings(Name = "Page")]
    public async Task<SqlSugarPagedList<WmsMaterialTypeOutput>> Page(WmsMaterialTypeInput input)
    {
        var query = _rep.AsQueryable()
            .WhereIF(!string.IsNullOrWhiteSpace(input.SearchKey), u =>
                u.MaterialTypeCode.Contains(input.SearchKey.Trim())
                || u.MaterialTypeName.Contains(input.SearchKey.Trim())
            )
            .WhereIF(input.IsDisabled != null, u => u.IsDisabled == input.IsDisabled) //ly-0612下拉数据用
            .WhereIF(!string.IsNullOrWhiteSpace(input.MaterialTypeCode), u => u.MaterialTypeCode.Contains(input.MaterialTypeCode.Trim()))
            .WhereIF(!string.IsNullOrWhiteSpace(input.MaterialTypeName), u => u.MaterialTypeName.Contains(input.MaterialTypeName.Trim()))
            .Select<WmsMaterialTypeOutput>();
        return await query.OrderBuilder(input).ToPagedListAsync(input.Page, input.PageSize);
    }
 
    /// <summary>
    /// 增加物料类型表
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [ApiDescriptionSettings(Name = "Add")]
    public async Task<long> Add(AddWmsMaterialTypeInput input)
    {
        var entity = input.Adapt<WmsBaseMaterialType>();
        //验重
        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(DeleteWmsMaterialTypeInput input)
    {
        var materialTypeModel = await _rep.AsQueryable().FirstAsync(p =>p.Id == input.Id);
 
        var Model = await _wmsMaterialRep.AsQueryable().FirstAsync(p => p.MaterialTypeCode == materialTypeModel.MaterialTypeCode);
        if (Model != null) throw Oops.Oh("该物料类型有关联物料不可删除");
        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(UpdateWmsMaterialTypeInput input)
    {
        var entity = input.Adapt<WmsBaseMaterialType>();
        //验重
        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<WmsBaseMaterialType> Detail([FromQuery] QueryByIdWmsMaterialTypeInput 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<WmsMaterialTypeOutput>> List([FromQuery] WmsMaterialTypeInput input)
    {
        return await _rep.AsQueryable().Select<WmsMaterialTypeOutput>().ToListAsync();
    }
 
 
 
    #region 私有方法
 
    /// <summary>
    /// 根据联合主键验证数据是否已存在-数据库
    /// </summary>
    /// <param name="input"></param>
    /// <param name="isEdit"></param>
    /// <returns></returns>
    private async Task CheckExisit(WmsBaseMaterialType input, bool isEdit = false)
    {
        //输出数据已存在错误
        ErrorCodeItemMetadataAttribute metadata = ErrorCodeEnum.D1006.GetErrorCodeItemMetadata();
 
        WmsBaseMaterialType _existItem = null;
        if (!isEdit)//新增
        {
            _existItem = await _rep.GetFirstAsync(u => u.MaterialTypeCode.Equals(input.MaterialTypeCode));
            if (_existItem != null) throw Oops.Oh($"类型编号[{input.MaterialTypeCode}]{metadata.ErrorMessage}");
 
            _existItem = await _rep.GetFirstAsync(u => u.MaterialTypeName.Equals(input.MaterialTypeName));
            if (_existItem != null) throw Oops.Oh($"类型名称[{input.MaterialTypeName}]{metadata.ErrorMessage}");
        }
        else//编辑 
        {
 
            //当前编辑数据以外是否存在重复
            _existItem = await _rep.GetFirstAsync(u => u.Id != input.Id && u.MaterialTypeCode.Equals(input.MaterialTypeCode));
            if (_existItem != null) throw Oops.Oh($"类型编号[{input.MaterialTypeCode}]{metadata.ErrorMessage}");
 
            _existItem = await _rep.GetFirstAsync(u => u.Id != input.Id && u.MaterialTypeName.Equals(input.MaterialTypeName));
            if (_existItem != null) throw Oops.Oh($"类型名称[{input.MaterialTypeName}]{metadata.ErrorMessage}");
        }
 
    }
 
    #endregion
 
}