1
wankeda
2026-03-05 a03ff104df699229eff31f31890544ccc6a7c8da
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
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
using AutoMapper;
using Magicodes.ExporterAndImporter.Core;
using Magicodes.ExporterAndImporter.Core.Models;
using Magicodes.ExporterAndImporter.Excel;
using MailKit.Search;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc.RazorPages;
using Org.BouncyCastle.Asn1.X509;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Globalization;
using System.Linq;
using System.Reflection;
using System.Reflection.Metadata;
using System.Text;
using System.Threading.Tasks;
using WIDESEA_Core;
using WIDESEA_Core.Attributes;
using WIDESEA_Core.BaseRepository;
using WIDESEA_Core.BaseServices;
using WIDESEA_Core.CodeConfigEnum;
using WIDESEA_Core.Enums;
using WIDESEA_Core.Helper;
using WIDESEA_Core.Utilities;
using WIDESEA_DTO;
using WIDESEA_DTO.Basic;
using WIDESEA_DTO.Inbound;
using WIDESEA_IBasicService;
using WIDESEA_IInboundRepository;
using WIDESEA_IInboundService;
using WIDESEA_IStockService;
using WIDESEA_ITaskInfoRepository;
using WIDESEA_Model.Models;
using OrderByType = SqlSugar.OrderByType;
 
namespace WIDESEA_InboundService
{
    public partial class InboundOrderService : ServiceBase<Dt_InboundOrder, IInboundOrderRepository>, IInboundOrderService
    {
 
        /// <summary>
        /// 根据入库单号获取入库单(含明细)
        /// </summary>
        /// <param name="inboundOrderNo"></param>
        /// <returns></returns>
        public Dt_InboundOrder GetInboundOrder(string inboundOrderNo)
        {
            return BaseDal.Db.Queryable<Dt_InboundOrder>().Includes(x => x.Details).First(x => x.OrderNo == inboundOrderNo); ;
        }
 
        /// <summary>
        /// 组盘数据更新
        /// </summary>
        /// <param name="inboundOrder">入库单</param>
        /// <param name="inboundOrderDetails">入库单明细</param>
        /// <param name="stockInfo">组盘数据</param>
        /// <returns></returns>
        public WebResponseContent MaterielGroupUpdateData(Dt_InboundOrder inboundOrder, List<Dt_InboundOrderDetail> inboundOrderDetails, Dt_StockInfo stockInfo)
        {
            try
            {
                _unitOfWorkManage.BeginTran();
                UpdateData(inboundOrder);
                _inboundOrderDetailService.UpdateData(inboundOrderDetails);
                _stockService.StockInfoService.AddMaterielGroup(stockInfo);
                _unitOfWorkManage.CommitTran();
                return WebResponseContent.Instance.OK();
            }
            catch (Exception ex)
            {
                _unitOfWorkManage.RollbackTran();
                return WebResponseContent.Instance.Error(ex.Message);
            }
        }
 
        /// <summary>
        /// PDA分页查询数据
        /// </summary>
        /// <param name="pageNo">页码</param>
        /// <param name="orderNo">订单号</param>
        /// <returns></returns>
        public WebResponseContent QueryOrderInfo(int pageNo, string orderNo)
        {
            if (string.IsNullOrEmpty(orderNo))
            {
                object obj = Repository.QueryPage(x => true, pageNo, 10, new Dictionary<string, OrderByType> { { nameof(Dt_InboundOrder.CreateDate), OrderByType.Desc } }).Rows.Select(x => new
                {
                    x.OrderNo,
                    x.UpperOrderNo,
                    x.CreateDate,
                    x.Creater
                });
                return WebResponseContent.Instance.OK(data: obj);
            }
            else
            {
                object obj = Repository.QueryPage(x => x.OrderNo == orderNo, pageNo, 10, new Dictionary<string, OrderByType> { { nameof(Dt_InboundOrder.CreateDate), OrderByType.Desc } }).Rows.Select(x => new
                {
                    x.OrderNo,
                    x.UpperOrderNo,
                    x.CreateDate,
                    x.Creater
                });
                return WebResponseContent.Instance.OK(data: obj);
            }
        }
        
        //下载模版
        public virtual WebResponseContent DownLoadTemplate()
        {
            WebResponseContent content = new WebResponseContent();
            IExporter exporter = new ExcelExporter();
            Inbounddaoc inbounddaoc = new Inbounddaoc();
            byte[] data = exporter.ExportHeaderAsByteArray(inbounddaoc).Result;
            string fileName = "";
            fileName ="模板.xlsx";
            string savePath = AppDomain.CurrentDomain.BaseDirectory + $"ExcelImprotTemplate";
            FileHelper.WriteFile(savePath, fileName, data);
 
            content = WebResponseContent.Instance.OK(data: savePath + "\\" + fileName);
            return content;
        }
 
        //导入
        public virtual WebResponseContent Import(List<IFormFile> files)
        {
            try
            {
                if (files == null || files.Count == 0)
                    return new WebResponseContent { Status = true, Message = "请选择上传的文件" };
 
                Microsoft.AspNetCore.Http.IFormFile formFile = files[0];
 
                // 使用Path.Combine,避免硬编码路径分隔符
                string dicPath = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "ExcelImport", DateTime.Now.ToString("yyyyMMdd"));
                if (!Directory.Exists(dicPath))
                    Directory.CreateDirectory(dicPath);
 
                string fileName = $"{Guid.NewGuid()}_{formFile.FileName}";
                string fullPath = Path.Combine(dicPath, fileName);
 
                // 使用FileStream保存文件
                using (FileStream stream = new FileStream(fullPath, FileMode.Create))
                {
                    formFile.CopyTo(stream);
                }
 
                // 初始化Excel导入工具
                ExcelImporter importer = new ExcelImporter();
 
                // 导入Excel数据
                ImportResult<Inbounddaoc> importResult = importer.Import<Inbounddaoc>(fullPath, "").Result;
 
 
                if (importResult.HasError)
                {
                    return WebResponseContent.Instance.Error(importResult.TemplateErrors.Serialize());
                }
                // 假设BaseDal是数据访问层,进行数据存储
                List<Dt_InboundOrder> dt_Inbounds = new List<Dt_InboundOrder>();
                
 
 
                foreach (var item in importResult.Data)
                {
                    int Startingcolumn = 0;
                    int Terminationcolumn = 0;
                    if (item.OrderType == "成品")
                    {
                        if (item.UpperOrderNo.Contains("回料"))
                        {
                            Startingcolumn = 14;
                            Terminationcolumn = 37;
                        }
                    }
 
                    //Dt_InboundOrder dt_2 = new Dt_InboundOrder()
                    //{
                    //    OrderName = item.OrderName,
                    //    UpperOrderNo = item.UpperOrderNo,
                    //    OrderType = item.OrderType == "原材料" ? (int)InventoryMaterialType.原材料 : (int)InventoryMaterialType.成品,
                    //    OrderNo = item.OrderNo,
                    //    CreateType = (int)CreateType.daoru,
                    //    Creater = "导入",
                    //    CreateDate = DateTime.Now,
                    //    Startingcolumn= Startingcolumn,
                    //    Terminationcolumn= Terminationcolumn
                    //};
                    //dt_Inbounds.Add(dt_2);
                }
                BaseDal.AddData(dt_Inbounds);
 
                return WebResponseContent.Instance.OK();
            }
            catch (Exception ex)
            {
                // 捕获异常并返回错误消息
                return WebResponseContent.Instance.Error(ex.Message);
            }
        }
 
        public class Inbounddaoc
        {
            [ImporterHeader(Name = "物料号")]
            [ExporterHeader(DisplayName = "物料号")]
            [SugarColumn(IsNullable = true, ColumnDescription = "物料号", ColumnName = "物料号")]
            public string OrderName { get; set; }
 
            [ImporterHeader(Name = "物料名称")]
            [ExporterHeader(DisplayName = "物料名称")]
            [SugarColumn(IsNullable = true, Length = 50, ColumnDescription = "物料名称", ColumnName = "物料名称")]
            public string UpperOrderNo { get; set; }
 
            [ImporterHeader(Name = "类型")]
            [ExporterHeader(DisplayName = "类型")]
            [SugarColumn(IsNullable = true, ColumnDescription = "类型", ColumnName = "类型")]
            public string OrderType { get; set; }
 
            [ImporterHeader(Name = "物料详情")]
            [ExporterHeader(DisplayName = "物料详情")]
            [SugarColumn(IsNullable = true, Length = 50, ColumnDescription = "物料详情", ColumnName = "物料详情")]
            public string OrderNo { get; set; }
        }
    }
}