285 lines
11 KiB
C#
285 lines
11 KiB
C#
using CloudBuilder.Core.DatabaseAccessor;
|
|
using CloudBuilder.Core.DatabaseAccessor.Entity;
|
|
using CloudBuilder.Core.Extensions;
|
|
using CloudBuilder.Core.Report;
|
|
using CloudBuilder.Core.Service;
|
|
using CloudBuilder.Security.Data;
|
|
using CloudBuilder.Security.Entity;
|
|
using CloudBuilder.Security.Policy;
|
|
using CloudBuilder.Security.SearchCriteria;
|
|
using Microsoft.AspNetCore.Authorization;
|
|
using Microsoft.AspNetCore.Mvc;
|
|
namespace CloudBuilder.Security.Service
|
|
{
|
|
public class SecurityGeneratorNumberService : ISecurityGeneratorNumberService
|
|
{
|
|
private readonly IApplicationService service;
|
|
|
|
private IRepository<SecurityGeneratorNumberEntity> repository;
|
|
public SecurityGeneratorNumberService(IApplicationService service)
|
|
{
|
|
this.service = service;
|
|
repository = service.GetRepository<IRepository<SecurityGeneratorNumberEntity>>();
|
|
}
|
|
|
|
[PermissionOperate(name: SecurityPermissionPolicy.SecurityGeneratorNumber, operate: Operate.Find)]
|
|
public SecurityGeneratorNumberEntity FindByKey(int key)
|
|
{
|
|
return repository.DetachedEntities.Where(x => x.GeneratorId == key).FirstOrDefault()!;
|
|
}
|
|
|
|
[PermissionOperate(name: SecurityPermissionPolicy.SecurityGeneratorNumber, operate: Operate.Find)]
|
|
public SecurityGeneratorNumberResultData FindBySearchCriteria(SecurityGeneratorNumberSearchCriteria criteria)
|
|
{
|
|
SecurityGeneratorNumberResultData data = new SecurityGeneratorNumberResultData();
|
|
SecurityGeneratorNumberEntity[] list = null;
|
|
|
|
int count = 0;
|
|
|
|
string sqlWhere = null;
|
|
|
|
if (criteria.Filter != null && criteria.Filter.Length > 0)
|
|
{
|
|
sqlWhere = SearchFilter.ComposeWhereClause(criteria.Filter);
|
|
}
|
|
|
|
SecurityGeneratorNumberEntity entity = SecurityGeneratorNumberEntity.GetInstance();
|
|
string sql = entity.GetSelectTopFrom(criteria.limit, criteria.page, criteria.orderby.StringToDbField(), criteria.orderbytag, sqlWhere);
|
|
|
|
string err = null;
|
|
try
|
|
{
|
|
list = repository.FromSql(sql).ToArray();
|
|
}
|
|
catch (System.Exception ex)
|
|
{
|
|
err = ex.Message;
|
|
}
|
|
|
|
|
|
if (list != null && list.Length > 0)
|
|
{
|
|
sql = entity.GetSelectCountFrom(sqlWhere);
|
|
count = (int)repository.ExecuteScalar(sql);
|
|
}
|
|
|
|
data.Limit = criteria.limit;
|
|
data.Page = criteria.page;
|
|
data.Datas = list;
|
|
data.Total = count;
|
|
//data.Sql = sql;
|
|
data.ErrorMessage = err;
|
|
return data;
|
|
}
|
|
|
|
[PermissionOperate(name: SecurityPermissionPolicy.SecurityGeneratorNumber, operate: Operate.Print)]
|
|
public dynamic PrintBySearchCriteria(SecurityGeneratorNumberSearchCriteria criteria)
|
|
{
|
|
string sqlWhere = string.Empty;
|
|
List<TemplateHeader> headers = new List<TemplateHeader>();
|
|
|
|
Dictionary<string, Dictionary<string, object>> mappings = new Dictionary<string, Dictionary<string, object>>();
|
|
Dictionary<string, object> validDic = new Dictionary<string, object>();
|
|
foreach (string v in YesNoPolicy.GetInstance().GetValues())
|
|
{
|
|
validDic.Add(v, YesNoPolicy.GetInstance().ComposeMessage(v, service.Locale));
|
|
}
|
|
mappings.Add(SecurityGeneratorNumberEntity.REFRESH_PERIOD, validDic);
|
|
|
|
List<string> searCriteria = criteria.PackSearchCriteriaDisplay(ref headers, ref sqlWhere, mappings);
|
|
|
|
SecurityGeneratorNumberEntity entity = SecurityGeneratorNumberEntity.GetInstance();
|
|
string sql = entity.GetSelectFrom() + " where 1=1 " + sqlWhere;
|
|
|
|
SecurityGeneratorNumberEntity[] list = repository.FromSql(sql).ToArray();
|
|
|
|
return new DataToExcelHelper<SecurityGeneratorNumberEntity>(service).ToExcel(criteria.ReportName, criteria.ReportName, searCriteria, headers.ToArray(), list, mappings);
|
|
|
|
}
|
|
|
|
[PermissionOperate(name: SecurityPermissionPolicy.SecurityGeneratorNumber, operate: Operate.Insert)]
|
|
[UnitOfWork]
|
|
public SecurityGeneratorNumberEntity Insert(SecurityGeneratorNumberEntity data)
|
|
{
|
|
throw new NotImplementedException();
|
|
}
|
|
|
|
[PermissionOperate(name: SecurityPermissionPolicy.SecurityGeneratorNumber, operate: Operate.Update)]
|
|
[UnitOfWork]
|
|
public SecurityGeneratorNumberEntity Update(SecurityGeneratorNumberEntity data)
|
|
{
|
|
SecurityGeneratorNumberEntity entity = repository.Entities.Where(x => x.GeneratorId == data.GeneratorId).FirstOrDefault()!;
|
|
if (entity == null)
|
|
{
|
|
throw new ValidatedException("记录不存在.");
|
|
}
|
|
|
|
entity.RefreshPeriod = data.RefreshPeriod;
|
|
entity.NextId = data.NextId;
|
|
entity.Format = data.Format;
|
|
|
|
repository.UpdateNow(entity);
|
|
|
|
return entity;
|
|
}
|
|
|
|
|
|
[PermissionOperate(name: SecurityPermissionPolicy.SecurityGeneratorNumber, operate: Operate.Delete)]
|
|
[UnitOfWork]
|
|
public void Delete(int key)
|
|
{
|
|
SecurityGeneratorNumberEntity entity = repository.Entities.Where(x => x.GeneratorId == key).FirstOrDefault()!;
|
|
if (entity == null)
|
|
{
|
|
throw new ValidatedException("记录不存在.");
|
|
}
|
|
|
|
repository.DeleteNow(entity);
|
|
}
|
|
|
|
|
|
public string GetNo(string systemId, string subsystemId)
|
|
{
|
|
return GetNo(systemId, subsystemId, null);
|
|
}
|
|
|
|
public string GetNo(string systemId, string subsystemId, string prefix)
|
|
{
|
|
return GetNo(systemId, subsystemId, prefix, null, null);
|
|
}
|
|
|
|
public string GetNo(string systemId, string subsystemId, string prefix, string refreshPeriod, string format)
|
|
{
|
|
SecurityGeneratorNumberEntity number = null;
|
|
|
|
if (!string.IsNullOrEmpty(systemId) && !string.IsNullOrEmpty(subsystemId))
|
|
{
|
|
SecurityGeneratorNumberEntity[] tps = repository.Entities.Where(x => x.SystemId == systemId && x.SubsystemId == subsystemId).ToArray();
|
|
|
|
if (tps != null && tps.Length > 0 && !string.IsNullOrEmpty(prefix))
|
|
{
|
|
tps = tps.Where(x => x.Prefix == prefix).ToArray();
|
|
}
|
|
|
|
if (tps != null && tps.Length > 0) number = tps[0];
|
|
}
|
|
|
|
if (number == null)
|
|
{
|
|
number = new SecurityGeneratorNumberEntity();
|
|
|
|
number.SystemId = string.IsNullOrEmpty(systemId) ? string.Empty : systemId;
|
|
number.SubsystemId = string.IsNullOrEmpty(subsystemId) ? string.Empty : subsystemId;
|
|
|
|
number.Prefix = string.IsNullOrEmpty(prefix) ? string.Empty : prefix;
|
|
number.RefreshPeriod = string.IsNullOrEmpty(refreshPeriod) ? YesNoPolicy.YES : refreshPeriod;
|
|
number.Format = string.IsNullOrEmpty(format) ? "yyMMdd000000" : format;
|
|
number.LastGeneratorDate = DateTime.Now;
|
|
number.NextId = 2;
|
|
|
|
repository.InsertNow(number);
|
|
}
|
|
else
|
|
{
|
|
number.NextId += 1;
|
|
|
|
number.LastGeneratorDate = DateTime.Now;
|
|
repository.UpdateNow(number);
|
|
}
|
|
|
|
format = number.Format;
|
|
|
|
if (number.LastGeneratorDate.Date.Subtract(DateTime.Now.Date).TotalDays != 0 && number.RefreshPeriod == YesNoPolicy.YES)
|
|
{
|
|
number.NextId = 1;
|
|
}
|
|
|
|
string temp = format.Replace("0", "").Replace("yyyy", DateTime.Now.ToString("yyyy"), StringComparison.OrdinalIgnoreCase).Replace("yy", DateTime.Now.ToString("yy"), StringComparison.OrdinalIgnoreCase)
|
|
.Replace("MM", DateTime.Now.ToString("MM"), StringComparison.OrdinalIgnoreCase).Replace("dd", DateTime.Now.ToString("dd"));
|
|
|
|
string zero = format.Replace("y", "").Replace("Y", "").Replace("M", "").Replace("m", "").Replace("d", "").Replace("D", "");
|
|
string code = number.Prefix + temp + string.Format("{0:" + zero + "}", number.NextId - 1);
|
|
|
|
Int64 max = Convert.ToInt64(zero.Replace("0", "9"));
|
|
if (max == number.NextId)
|
|
{
|
|
throw new Exception("系统编号已达到最大值.");
|
|
}
|
|
|
|
return code;
|
|
}
|
|
|
|
public int GetNextId(string systemId, string subsystemId)
|
|
{
|
|
return GetNextId(systemId, subsystemId, null);
|
|
}
|
|
|
|
public int GetNextId(string systemId, string subsystemId, string prefix)
|
|
{
|
|
return GetNextId(systemId, subsystemId, prefix, null);
|
|
}
|
|
|
|
public int GetNextId(string systemId, string subsystemId, string prefix, string format)
|
|
{
|
|
return GetNextId(systemId, subsystemId, prefix, format, 1);
|
|
}
|
|
|
|
public int GetNextId(string systemId, string subsystemId, string prefix, string format, int length)
|
|
{
|
|
SecurityGeneratorNumberEntity number = null;
|
|
|
|
if (!string.IsNullOrEmpty(systemId) && !string.IsNullOrEmpty(subsystemId))
|
|
{
|
|
SecurityGeneratorNumberEntity[] tps = repository.DetachedEntities.Where(x => x.SystemId == systemId && x.SubsystemId == subsystemId).ToArray();
|
|
|
|
if (tps != null && tps.Length > 0 && !string.IsNullOrEmpty(prefix))
|
|
{
|
|
tps = tps.Where(x => x.Prefix == prefix).ToArray();
|
|
}
|
|
|
|
if (tps != null && tps.Length > 0) number = tps[0];
|
|
}
|
|
|
|
if (number == null)
|
|
{
|
|
number = new SecurityGeneratorNumberEntity();
|
|
|
|
number.SystemId = string.IsNullOrEmpty(systemId) ? string.Empty : systemId;
|
|
number.SubsystemId = string.IsNullOrEmpty(subsystemId) ? string.Empty : subsystemId;
|
|
|
|
number.Prefix = string.IsNullOrEmpty(prefix) ? string.Empty : prefix;
|
|
number.Format = string.IsNullOrEmpty(format) ? "yyMMdd000000" : format;
|
|
number.LastGeneratorDate = DateTime.Now;
|
|
number.NextId = 1 + length;
|
|
number.RefreshPeriod = YesNoPolicy.NO;
|
|
|
|
repository.Insert(number);
|
|
}
|
|
else
|
|
{
|
|
|
|
number.NextId = number.NextId + length;
|
|
|
|
if (number.LastGeneratorDate.Date.Subtract(DateTime.Now.Date).TotalDays != 0 && number.RefreshPeriod == YesNoPolicy.YES)
|
|
{
|
|
number.NextId = 1 + length;
|
|
}
|
|
|
|
number.LastGeneratorDate = DateTime.Now;
|
|
repository.Update(number);
|
|
}
|
|
|
|
string zero = number.Format.Replace("y", "").Replace("Y", "").Replace("M", "").Replace("m", "").Replace("d", "").Replace("D", "");
|
|
|
|
Int64 max = Convert.ToInt64(zero.Replace("0", "9"));
|
|
if (max == number.NextId - length)
|
|
{
|
|
throw new Exception("系统编号已达到最大值.");
|
|
}
|
|
|
|
return number.NextId - length - 1;
|
|
}
|
|
|
|
}
|
|
}
|