222
schangxiang@126.com
2025-04-29 4352ad5cbeef498392178655cb367ee38e574178
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
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
using Admin.NET.Core.BasicInformation.Entity;
using Furion.DatabaseAccessor;
using Furion.DependencyInjection;
using Furion.DynamicApiController;
using Furion.Extras.Admin.NET;
using Furion.Extras.Admin.NET.Extension;
using Furion.FriendlyException;
using Mapster;
using Microsoft.AspNetCore.Mvc;
using Microsoft.EntityFrameworkCore;
using Microsoft.EntityFrameworkCore.ChangeTracking;
using PandaWork.Infrastructure;
using System.Data;
using System.Linq.Dynamic.Core;
using Furion.LinqBuilder;
using System.Linq.Expressions;
using Admin.NET.Core.Helper.ExcelHelper;
 
namespace Admin.NET.Application
{
    /// <summary>
    /// $ChinaComment$·þÎñ½Ó¿ÚʵÏÖ
    /// </summary>    
    [ApiDescriptionSettings("$GroupName$", Name = "$ChinaComment$", Order = 100)]
    public class $EntityName$Service : ControllerBase, I$EntityName$Service, IDynamicApiController, ITransient
    {
        private readonly IRepository<$EntityName$, MasterDbContextLocator> _$EntityName_FirstLetterLower$Rep;
        /// <summary>
        /// $ChinaComment$·þÎñ¹¹Ô캯Êý
        /// </summary>
        /// <param name="$EntityName_FirstLetterLower$Rep">$ChinaComment$·þÎñ²Ö´¢¶ÔÏó</param>
        public $EntityName$Service(IRepository<$EntityName$, MasterDbContextLocator> $EntityName_FirstLetterLower$Rep)
        {
             _$EntityName_FirstLetterLower$Rep = $EntityName_FirstLetterLower$Rep;
        }
 
        /// <summary>
        /// ·ÖÒ³²éѯ$ChinaComment$
        /// </summary>
        /// <param name="input">·ÖÒ³²éѯ²ÎÊý</param>
        /// <returns></returns>
        [HttpGet("/$EntityName$/page")]
        [DisableOpLog]
        public async Task<PageResult<$EntityName$Output>> Page([FromQuery] $EntityName$PageInput input)
        {
            if (input == null)
            {
                throw Oops.Oh(ErrorCode.D4008);
            }
 
            #region ¶¯Ì¬¹¹Ôì²éѯÌõ¼þ
 
            //¶¯Ì¬¹¹Ôì²éѯÌõ¼þ
            var whereConditions = DynamicGetQueryParams(input);
 
            #endregion
 
            var pageList= await _$EntityName_FirstLetterLower$Rep.DetachedEntities
                                     .Where(whereConditions.data)
                                     .OrderBy(PageInputOrder.OrderBuilder<$EntityName$PageInput>(input))
                                     .ProjectToType<$EntityName$Output>()
                                     .ToADPagedListAsync(input.PageNo, input.PageSize);
            return pageList;
        }
 
        /// <summary>
        /// Ôö¼Ó$ChinaComment$
        /// </summary>
        /// <param name="input">Ôö¼Ó²ÎÊý</param>
        /// <returns></returns>
        [HttpPost("/$EntityName$/add")]
        public async Task<long> Add([FromBody] Add$EntityName$Input input)
        {
            if (input == null)
            {
                throw Oops.Oh(ErrorCode.D4008);
            }
            var $EntityName_FirstLetterLower$ = input.Adapt<$EntityName$>();
            EntityEntry<$EntityName$> entityEntry = await _$EntityName_FirstLetterLower$Rep.InsertAsync($EntityName_FirstLetterLower$);
            return entityEntry.Entity.Id;
        }
 
        /// <summary>
        /// ¸üÐÂ$ChinaComment$
        /// </summary>
        /// <param name="input">¸üвÎÊý</param>
        /// <returns></returns>
        [HttpPost("/$EntityName$/update")]
        public async Task<long> Update([FromBody] Update$EntityName$Input input)
        {
            if (input == null || (input.Id) <= 0)
            {
                throw Oops.Oh(ErrorCode.D1012);
            }
            var isExist = await _$EntityName_FirstLetterLower$Rep.AnyAsync(u => u.Id == input.Id, false);
            if (!isExist)
            {
                throw Oops.Oh(ErrorCode.D1002);
            }
            var $EntityName_FirstLetterLower$ = input.Adapt<$EntityName$>();
            await _$EntityName_FirstLetterLower$Rep.UpdateAsync($EntityName_FirstLetterLower$, ignoreNullValues: true);
            return input.Id;
        }
 
        /// <summary>
        /// É¾³ý$ChinaComment$
        /// </summary>
        /// <param name="input">ɾ³ý²ÎÊý</param>
        /// <returns></returns>
        [HttpPost("/$EntityName$/delete")]
        public async Task<int> Delete([FromBody] Delete$EntityName$Input input)
        {
            if (input == null || input.Id.Count == 0)
            {
                throw Oops.Oh(ErrorCode.D4008);
            }
            List<$EntityName$> list = new();
            foreach (var item in input.Id)
            {
                list.Add(new $EntityName$() { Id = item });
            }
            await _$EntityName_FirstLetterLower$Rep.DeleteAsync(list);
            return input.Id.Count;
        }
 
        /// <summary>
        /// »ñÈ¡$ChinaComment$
        /// </summary>
        /// <param name="input">»ñÈ¡¶ÔÏó²ÎÊý</param>
        /// <returns></returns>
        [HttpGet("/$EntityName$/detail")]
        [DisableOpLog]
        public async Task<$EntityName$Output> Get([FromQuery] Query$EntityName$Input input)
        {
            if (input == null || input.Id <= 0)
            {
                throw Oops.Oh(ErrorCode.D1012);
            }
            return (await _$EntityName_FirstLetterLower$Rep.DetachedEntities.FirstOrDefaultAsync(u => u.Id == input.Id)).Adapt<$EntityName$Output>();
        }
 
        /// <summary>
        /// µ¼³ö$ChinaComment$Excel
        /// </summary>
        /// <param name="input">ɸѡÌõ¼þ</param>
        /// <returns></returns>
        [HttpPost("/$EntityName$/export")]
        [DisableOpLog]
        public async Task<ActionResult> Export([FromQuery] $EntityName$PageInput input)
        {
            if (input == null)
            {
                throw Oops.Oh(ErrorCode.D4008);
            }
 
            #region ¶¯Ì¬¹¹Ôì²éѯÌõ¼þ
 
            //¶¯Ì¬¹¹Ôì²éѯÌõ¼þ
            var whereConditions = DynamicGetQueryParams(input);
 
            #endregion
 
            var deliveryOrderExportExcel = await _$EntityName_FirstLetterLower$Rep.DetachedEntities
                .Where(whereConditions.data)
                .ProjectToType<Export$EntityName$Output>()
               .ToListAsync();
            var excelBaseResult = new Excel2003Result<Export$EntityName$Output>(deliveryOrderExportExcel, "$ChinaComment$¼Ç¼" + DateTime.Now.ToString("yyyyMMdd"), false, "$ChinaComment$¼Ç¼");
            return File(excelBaseResult.GetExcelStream(), "application/vnd.ms-excel");
        }
 
         /// <summary>
        /// ¶¯Ì¬¹¹Ôì²éѯÌõ¼þ
        /// </summary>
        /// <param name="input">ÊäÈë²ÎÊý</param>
        /// <returns></returns>
        private FunReturnResultModel<Expression<Func<$EntityName$, bool>>> DynamicGetQueryParams($EntityName$PageInput input)
        {
            //¶¯Ì¬¹¹Ôì²éѯÌõ¼þ
            var whereConditions = WhereConditionsExtensions.GetWhereConditions<$EntityName$, $EntityName$PageInput>(input);
            if (!whereConditions.IsSuccess)
            {
                throw Oops.Oh("¶¯Ì¬¹¹Ôì²éѯÌõ¼þʧ°Ü:" + whereConditions.ErrMsg);
            }
 
            //Ò²¿ÉÔÙ´Î×Ô¶¨Òå¹¹½¨²éѯÌõ¼þ
            Expression<Func<$EntityName$, bool>> extendExpression = a => a.IsDeleted == false;
            whereConditions.data = whereConditions.data.And(extendExpression);
 
            return whereConditions;
        }
    }
}