using Furion.DatabaseAccessor;
|
using Furion.DatabaseAccessor.Extensions;
|
using Furion.FriendlyException;
|
using System.Globalization;
|
using System.Text;
|
using Admin.NET.Core;
|
|
namespace Admin.NET.Application
|
{
|
/// <summary>
|
/// 单据号生成帮助类
|
/// </summary>
|
public class SerialUtil
|
{
|
|
private readonly static object _lockTest = new();
|
private readonly static object _lockPublic = new();
|
/// <summary>
|
/// 生成编号/单据号
|
/// </summary>
|
/// <param name="SerialType"></param>
|
/// <returns></returns>
|
public static async Task<string> GetSerial(EnumSerialType SerialType)
|
{
|
switch (SerialType)
|
{
|
case EnumSerialType.测试编号:
|
lock (_lockTest)
|
{
|
return GetSerialDetails(SerialType).Result;
|
};
|
|
default:
|
lock (_lockPublic)
|
{//为了避免多线程出现编号一致的情况，加上锁，此处为公共锁，只用于不频繁生成编号的，若需要频繁生成，请参考上面Test设置单独锁
|
return GetSerialDetails(SerialType).Result;
|
}
|
}
|
|
}
|
/// <summary>
|
/// 生成编号/单据号
|
/// </summary>
|
/// <param name="SerialType"></param>
|
/// <returns></returns>
|
private static async Task<string> GetSerialDetails(EnumSerialType SerialType)
|
{
|
// 泛型仓储
|
var repositoryBaseSerialRuleDetail = Db.GetRepository<BaseSerialRuleDetail>();
|
var repositoryBaseSerialSN = Db.GetRepository<BaseSerialSN>();
|
|
var lst = repositoryBaseSerialRuleDetail.Where(x => x.SerialType == (int)SerialType)
|
.OrderBy(x => x.ItemNo).ToList();
|
|
string[] strs = new string[lst.Count];
|
|
BaseSerialSN sl = new BaseSerialSN();
|
for (int i = 0; i < lst.Count; i++)
|
{
|
if (lst[i].SourceType.ToUpper() == EnumSerialSourceType.UD.ToString())
|
{
|
strs[i] = lst[i].UserDefine ?? string.Empty;//如果数据源是自定义，则取自定义字段
|
}
|
if (lst[i].SourceType.ToUpper() == EnumSerialSourceType.Y4.ToString())
|
{
|
strs[i] = DateTime.Now.Year.ToString();
|
}
|
if (lst[i].SourceType.ToUpper() == EnumSerialSourceType.Y2.ToString())
|
{
|
strs[i] = DateTime.Now.Year.ToString().Substring(2, 2);
|
}
|
if (lst[i].SourceType.ToUpper() == EnumSerialSourceType.M2.ToString())
|
{
|
strs[i] = DateTime.Now.Month.ToString("00");
|
}
|
if (lst[i].SourceType.ToUpper() == EnumSerialSourceType.D2.ToString())
|
{
|
strs[i] = DateTime.Now.Day.ToString("00");
|
|
}
|
if (lst[i].SourceType.ToUpper() == EnumSerialSourceType.W2.ToString())
|
{
|
GregorianCalendar gc = new GregorianCalendar();
|
int week = gc.GetWeekOfYear(DateTime.Now, CalendarWeekRule.FirstDay, DayOfWeek.Sunday);
|
strs[i] = "W" + week.ToString();
|
|
}
|
if (lst[i].SourceType.ToUpper() == EnumSerialSourceType.SN.ToString())
|
{
|
int cout = lst[i].SerialLength;
|
string c = string.Empty;
|
for (int j = 0; j < cout; j++)
|
{
|
c += "0";
|
}
|
try
|
{
|
if (lst[i].GetData.HasValue && lst[i].GetData == 1)
|
{
|
var sn = repositoryBaseSerialSN.Where(x => x.SerialType == lst[i].SerialType && x.CurrentDate == DateTime.Now.Date)
|
.OrderByDescending(x => x.Sn).First();
|
sl.Sn = sn.Sn + 1;
|
}
|
else
|
{
|
|
var sn = repositoryBaseSerialSN.Where(x => x.SerialType == lst[i].SerialType)
|
.OrderByDescending(x => x.Sn).First();
|
sl.Sn = sn.Sn + 1;
|
}
|
|
strs[i] = sl.Sn.ToString(c);
|
}
|
catch (Exception ex)
|
{
|
strs[i] = 1.ToString(c);
|
sl.Sn = 1;
|
}
|
sl.CurrentDate = DateTime.Now.Date;
|
sl.SerialType = lst[i].SerialType;
|
}
|
}
|
|
StringBuilder BaseSerialSN = new StringBuilder();
|
foreach (var item in strs)
|
{
|
BaseSerialSN.Append(item.ToString());
|
}
|
await sl.InsertAsync();
|
//await repositoryBaseSerialSN.Add(sl);
|
//edm.SaveChanges();
|
|
if (string.IsNullOrEmpty(BaseSerialSN.ToString()))
|
{
|
throw Oops.Oh("生成的编号为空");
|
}
|
|
return BaseSerialSN.ToString();
|
}
|
}
|
}
|
