You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
389 lines
15 KiB
389 lines
15 KiB
using System;
|
|
using System.Collections.Generic;
|
|
using System.ComponentModel.DataAnnotations;
|
|
using System.Globalization;
|
|
using System.IO;
|
|
using System.Linq;
|
|
using System.Linq.Dynamic.Core;
|
|
using System.Reflection;
|
|
using System.Threading.Tasks;
|
|
using ClosedXML.Excel;
|
|
using Flurl;
|
|
using Flurl.Http;
|
|
using InfluxDB.LineProtocol.Client;
|
|
using Magicodes.ExporterAndImporter.Core.Extension;
|
|
using Microsoft.AspNetCore.Authorization;
|
|
using Microsoft.AspNetCore.Mvc;
|
|
using Microsoft.AspNetCore.SignalR;
|
|
using Microsoft.EntityFrameworkCore;
|
|
using Microsoft.EntityFrameworkCore.Infrastructure;
|
|
using Microsoft.EntityFrameworkCore.Storage;
|
|
using Microsoft.Extensions.Configuration;
|
|
using Microsoft.Extensions.DependencyInjection;
|
|
using Microsoft.OpenApi.Extensions;
|
|
using SettleAccount.Job.SignalR;
|
|
using Volo.Abp.Application.Dtos;
|
|
using Volo.Abp.Application.Services;
|
|
using Volo.Abp.BlobStoring;
|
|
using Volo.Abp.DependencyInjection;
|
|
using Volo.Abp.Uow;
|
|
using Volo.Abp.Validation;
|
|
using Win.Sfs.BaseData.ImportExcelCommon;
|
|
using Win.Sfs.SettleAccount.Entities.BQ.Dtos;
|
|
using Win.Sfs.SettleAccount.Entities.BQ.Vmi;
|
|
using Win.Sfs.SettleAccount.EntityFrameworkCore;
|
|
using Win.Sfs.SettleAccount.influxdb;
|
|
using Win.Sfs.Shared.Filter;
|
|
using Win.Sfs.Shared.RepositoryBase;
|
|
|
|
namespace Win.Sfs.SettleAccount.Entities.BQ;
|
|
|
|
public interface IVmiService : IApplicationService, ITransientDependency, IJobService
|
|
{
|
|
void In(VmiCategory category, string erpToLoc, string partCode, string lu, decimal count, object message);
|
|
|
|
void Out(VmiCategory category, string erpToLoc, string partCode, string lu, decimal count, object message);
|
|
|
|
void Run(string logGroupId, VmiType type);
|
|
}
|
|
|
|
[AllowAnonymous]
|
|
[Route("api/settleaccount/[controller]/[action]")]
|
|
public class VmiAppService : ApplicationService, IVmiService, IJobService, ITransientDependency
|
|
{
|
|
private readonly IConfiguration _cfg;
|
|
private readonly INormalEfCoreRepository<VmiBalance, Guid> _balanceRepository;
|
|
private readonly INormalEfCoreRepository<VmiLog, Guid> _logRepository;
|
|
private readonly INormalEfCoreRepository<VmiSnapshot, Guid> _snapshotRepository;
|
|
private readonly IBlobContainer<MyFileContainer> _fileContainer;
|
|
private readonly IHubContext<PageHub> _hubContext;
|
|
|
|
public VmiAppService(IConfiguration cfg,
|
|
INormalEfCoreRepository<VmiBalance, Guid> balanceRepository,
|
|
INormalEfCoreRepository<VmiLog, Guid> logRepository,
|
|
INormalEfCoreRepository<VmiSnapshot, Guid> snapshotRepository,
|
|
IBlobContainer<MyFileContainer> fileContainer,
|
|
IHubContext<PageHub> hubContext)
|
|
{
|
|
this._cfg = cfg;
|
|
this._balanceRepository = balanceRepository;
|
|
this._logRepository = logRepository;
|
|
this._snapshotRepository = snapshotRepository;
|
|
this._fileContainer = fileContainer;
|
|
this._hubContext = hubContext;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 定时备份:0 0 8 26 * ?
|
|
/// </summary>
|
|
[HttpPost]
|
|
[DisableValidation]
|
|
public virtual async Task Invoke(IServiceProvider serviceProvider)
|
|
{
|
|
this._hubContext.Clients.All.ServerToClient("JobItem", "refresh", "");
|
|
Directory.CreateDirectory(Path.Combine(Directory.GetCurrentDirectory(), "wwwroot/files/vmi"));
|
|
var date = DateTime.Now.ToString("yyyyMMddHH");
|
|
var connectionString = $"Data Source=wwwroot/files/vmi/{date}.db";
|
|
using var dbContext = new VmiSqliteContext(connectionString);
|
|
if (!dbContext.GetService<IRelationalDatabaseCreator>().Exists() && dbContext.Database.EnsureCreated())
|
|
{
|
|
var list = await serviceProvider.GetRequiredService<SettleAccountDbContext>().Set<VmiBalance>().AsNoTracking().ToListAsync().ConfigureAwait(false);
|
|
foreach (var item in list)
|
|
{
|
|
dbContext.Set<VmiBalance>().Add(item);
|
|
}
|
|
dbContext.SaveChanges();
|
|
var snapshot = new VmiSnapshot { Name = date, Path = connectionString };
|
|
this._snapshotRepository.InsertAsync(snapshot).Wait();
|
|
}
|
|
this._hubContext.Clients.All.ServerToClient("JobItem", "refresh", "");
|
|
}
|
|
|
|
/// <summary>
|
|
/// 入库
|
|
/// </summary>
|
|
[HttpPost]
|
|
public void In(VmiCategory category, string erpToLoc, string partCode, string lu, decimal count, object message)
|
|
{
|
|
}
|
|
|
|
/// <summary>
|
|
/// 出库
|
|
/// </summary>
|
|
[HttpPost]
|
|
public void Out(VmiCategory category, string erpToLoc, string partCode, string lu, decimal count, object message)
|
|
{
|
|
}
|
|
|
|
/// <summary>
|
|
/// 库存事务重放
|
|
/// </summary>
|
|
/// <param name="logGroupId"></param>
|
|
/// <param name="type"></param>
|
|
[NonAction]
|
|
public void Run(string logGroupId, VmiType type)
|
|
{
|
|
}
|
|
|
|
/// <summary>
|
|
/// InfluxDB Query Test
|
|
/// </summary>
|
|
/// <param name="q"></param>
|
|
/// <returns></returns>
|
|
[HttpPost]
|
|
public async Task<dynamic> influxdb(string q)
|
|
{
|
|
var helper = new InfluxHelper(_cfg);
|
|
return await helper.GetUrl().AppendPathSegment("query").SetQueryParam("q", q).SetQueryParam("db", "vmi").GetJsonAsync().ConfigureAwait(false);
|
|
}
|
|
|
|
/// <summary>
|
|
/// 库存余额查询
|
|
/// </summary>
|
|
/// <param name="input"></param>
|
|
/// <returns></returns>
|
|
[HttpPost]
|
|
public async Task<PagedResultDto<VmiBalance>> Balance(RequestDto input)
|
|
{
|
|
var entities = await _balanceRepository.GetListByFilterAsync(input.Filters, input.Sorting, input.MaxResultCount, input.SkipCount, true).ConfigureAwait(false);
|
|
var totalCount = await _balanceRepository.GetCountByFilterAsync(input.Filters).ConfigureAwait(false);
|
|
return new PagedResultDto<VmiBalance>(totalCount, entities);
|
|
}
|
|
|
|
/// <summary>
|
|
/// 库存余额导出
|
|
/// </summary>
|
|
[HttpPost]
|
|
public async Task<string> BalanceExport(RequestDto input)
|
|
{
|
|
var entities = await _balanceRepository.WhereIf(input.Filters?.Count != 0, input.Filters.ToLambda<VmiBalance>())
|
|
.ToListAsync().ConfigureAwait(false);
|
|
var fileName = $"库存余额_{DateTime.Now.ToString("yyyy-MM-dd_HH:mm:ss")}.xlsx";
|
|
var content = this.GetContent<VmiBalance>(entities, "库存备份");
|
|
await _fileContainer.SaveAsync(fileName, content, true).ConfigureAwait(false);
|
|
return fileName;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 库存事务查询
|
|
/// </summary>
|
|
/// <param name="input"></param>
|
|
/// <returns></returns>
|
|
[HttpPost]
|
|
public async Task<PagedResultDto<VmiLog>> Log(RequestDto input)
|
|
{
|
|
var type = typeof(VmiLog);
|
|
var querySql = $"select * from {typeof(VmiLog).Name}";
|
|
var countSql = $"select count(*) from {typeof(VmiLog).Name}";
|
|
var where = "";
|
|
if (input.Filters.Any())
|
|
{
|
|
foreach (var item in input.Filters)
|
|
{
|
|
var property = type.GetProperties().FirstOrDefault(p => p.Name.ToLowerInvariant() == item.Column.ToLowerInvariant());
|
|
if (property != null)
|
|
{
|
|
var @operator = GetOperator(item.Action);
|
|
var value = GetValue(property, item.Value);
|
|
where += $" {(string.IsNullOrEmpty(where) ? "where" : "and")} {property.Name}{string.Format(GetOperator(item.Action), item.Value)}";
|
|
}
|
|
}
|
|
}
|
|
var herlper = new InfluxHelper(_cfg);
|
|
var countResult = await herlper.Query(countSql + where).ConfigureAwait(false);
|
|
var count = Convert.ToInt32(countResult.results.FirstOrDefault()?.series.FirstOrDefault()?.values.FirstOrDefault()?.LastOrDefault());
|
|
where += $" order by time desc limit {input.MaxResultCount} offset {input.SkipCount} ";
|
|
var result = await herlper.Query(querySql + where).ConfigureAwait(false);
|
|
var entities = new List<VmiLog>();
|
|
result.results.FirstOrDefault()?.series.FirstOrDefault()?.values.ForEach(v =>
|
|
{
|
|
var entity = Activator.CreateInstance<VmiLog>();
|
|
entities.Add(entity);
|
|
var i = 0;
|
|
result.results.FirstOrDefault().series.FirstOrDefault().columns.ForEach(c =>
|
|
{
|
|
var property = type.GetProperty(c);
|
|
if (property != null)
|
|
{
|
|
this.SetPropertyValue(property, entity, v[i]);
|
|
i++;
|
|
}
|
|
});
|
|
});
|
|
return new PagedResultDto<VmiLog>(count, entities);
|
|
}
|
|
|
|
/// <summary>
|
|
/// 快照列表
|
|
/// </summary>
|
|
[HttpPost]
|
|
public async Task<ListResultDto<VmiSnapshot>> Snapshot()
|
|
{
|
|
var list = await _snapshotRepository.GetListAsync().ConfigureAwait(false);
|
|
return new ListResultDto<VmiSnapshot>(list);
|
|
}
|
|
|
|
/// <summary>
|
|
/// 时点库存查询
|
|
/// </summary>
|
|
[HttpPost]
|
|
public async Task<PagedResultDto<VmiBalance>> Backup(BackupListRequest input)
|
|
{
|
|
var connectionString = $"Data Source=wwwroot/files/vmi/{input.Name}.db";
|
|
using var dbContext = new VmiSqliteContext(connectionString);
|
|
var repo = dbContext.Set<VmiBalance>();
|
|
var filters = input.Filters.ToLambda<VmiBalance>();
|
|
var query = (input.Filters.Count > 0 ? repo.Where(input.Filters.ToLambda<VmiBalance>()) : repo);
|
|
var totalCount = query.Count();
|
|
query = string.IsNullOrEmpty(input.Sorting) ? query : DynamicQueryableExtensions.OrderBy(query, input.Sorting);
|
|
var entities = await query.PageBy(input.SkipCount, input.MaxResultCount).ToListAsync().ConfigureAwait(false);
|
|
return new PagedResultDto<VmiBalance>(totalCount, entities);
|
|
}
|
|
|
|
/// <summary>
|
|
/// 时点库存导出
|
|
/// </summary>
|
|
[HttpPost]
|
|
public async Task<string> BackupExport(BackupListRequest input)
|
|
{
|
|
var connectionString = $"Data Source=wwwroot/files/vmi/{input.Name}.db";
|
|
using var dbContext = new VmiSqliteContext(connectionString);
|
|
var repo = dbContext.Set<VmiBalance>();
|
|
var filters = input.Filters.ToLambda<VmiBalance>();
|
|
var query = (input.Filters.Count > 0 ? repo.Where(input.Filters.ToLambda<VmiBalance>()) : repo);
|
|
query = string.IsNullOrEmpty(input.Sorting) ? query : DynamicQueryableExtensions.OrderBy(query, input.Sorting);
|
|
var entities = await query.ToListAsync().ConfigureAwait(false);
|
|
var fileName = $"库存备份_{input.Name}.xlsx";
|
|
var content = this.GetContent(entities, "库存备份");
|
|
await _fileContainer.SaveAsync(fileName, content, true).ConfigureAwait(false);
|
|
return fileName;
|
|
}
|
|
|
|
private byte[] GetContent<TExport>(List<TExport> entities, string name = "sheet1")
|
|
{
|
|
using var workbook = new XLWorkbook();
|
|
var ws = workbook.Worksheets.Add(name);
|
|
var type = typeof(TExport);
|
|
var properties = type.GetProperties(BindingFlags.Instance | BindingFlags.Public | BindingFlags.GetProperty)
|
|
.Where(o => o.GetAttributes<DisplayAttribute>().Any())
|
|
.ToList();
|
|
var rowIndex = 1;
|
|
for (var i = 0; i < properties.Count; i++)
|
|
{
|
|
var property = properties[i];
|
|
var columnIndex = i + 1;
|
|
var cell = ws.Cell(1, columnIndex);
|
|
cell.Value = property.GetAttributes<DisplayAttribute>().Any() ? property.GetAttribute<DisplayAttribute>().Name : property.Name;
|
|
}
|
|
foreach (var item in entities)
|
|
{
|
|
rowIndex++;
|
|
for (var i = 0; i < properties.Count; i++)
|
|
{
|
|
var property = properties[i];
|
|
var columnIndex = i + 1;
|
|
var cell = ws.Cell(rowIndex, columnIndex);
|
|
SetCell(item, cell, property);
|
|
}
|
|
}
|
|
ws.RangeUsed().Style.Border.TopBorder =
|
|
ws.RangeUsed().Style.Border.RightBorder =
|
|
ws.RangeUsed().Style.Border.BottomBorder =
|
|
ws.RangeUsed().Style.Border.LeftBorder = XLBorderStyleValues.Thin;
|
|
ws.RangeUsed().Style.Border.TopBorderColor =
|
|
ws.RangeUsed().Style.Border.RightBorderColor =
|
|
ws.RangeUsed().Style.Border.BottomBorderColor =
|
|
ws.RangeUsed().Style.Border.LeftBorderColor = XLColor.Black;
|
|
ws.RangeUsed().SetAutoFilter();
|
|
ws.ColumnsUsed().AdjustToContents();
|
|
ws.RowsUsed().AdjustToContents();
|
|
using var stream = new MemoryStream();
|
|
workbook.SaveAs(stream);
|
|
stream.Seek(0, SeekOrigin.Begin);
|
|
return stream.ToArray();
|
|
}
|
|
|
|
[HttpGet]
|
|
public async Task<LineProtocolWriteResult> InfluxInsertTest(string q)
|
|
{
|
|
return await new InfluxHelper(_cfg).Insert(new VmiLog()).ConfigureAwait(false);
|
|
}
|
|
|
|
private static void SetCell<TExportModel>(TExportModel? model, IXLCell cell, PropertyInfo property)
|
|
{
|
|
var propertyType = property.PropertyType;
|
|
var value = property.GetValue(model)?.ToString()?.Trim();
|
|
if (string.IsNullOrEmpty(value))
|
|
{
|
|
return;
|
|
}
|
|
if (propertyType == typeof(bool))
|
|
{
|
|
cell.Value = (bool)property.GetValue(model)! ? "是" : "否";
|
|
}
|
|
else if (propertyType.IsEnum)
|
|
{
|
|
cell.Value = (Enum.Parse(propertyType, value) as Enum)?.GetDisplayName();
|
|
|
|
}
|
|
else if (propertyType == typeof(DateTime))
|
|
{
|
|
cell.Value = ((DateTime)property.GetValue(model)!).ToString("yyyy-MM-dd HH:mm:ss", CultureInfo.InvariantCulture);
|
|
}
|
|
else
|
|
{
|
|
cell.Value = value;
|
|
}
|
|
|
|
}
|
|
|
|
private void SetPropertyValue(PropertyInfo property, VmiLog entity, string value)
|
|
{
|
|
try
|
|
{
|
|
object propertyValue = null;
|
|
if (!string.IsNullOrEmpty(value))
|
|
{
|
|
propertyValue = Convert.ChangeType(value, property.PropertyType);
|
|
}
|
|
property.SetValue(entity, propertyValue, null);
|
|
}
|
|
catch (Exception)
|
|
{
|
|
throw;
|
|
}
|
|
}
|
|
|
|
private string GetOperator(EnumFilterAction action)
|
|
{
|
|
var dictonary = new Dictionary<EnumFilterAction, string>() {
|
|
{EnumFilterAction.Equal,"={0}"},
|
|
{EnumFilterAction.NotEqual,"!={0}"},
|
|
{EnumFilterAction.SmallThanOrEqual,"<={0}"},
|
|
{EnumFilterAction.Like,"~/{0}/"},
|
|
{EnumFilterAction.NotLike,"!~/{0}/"},
|
|
{EnumFilterAction.BiggerThan,">{0}"},
|
|
{EnumFilterAction.BiggerThanOrEqual,">={0}"},
|
|
{EnumFilterAction.SmallThan,"<{0}"},
|
|
};
|
|
return dictonary[action];
|
|
}
|
|
|
|
private object GetValue(PropertyInfo property, string value)
|
|
{
|
|
if (property.PropertyType == typeof(int) ||
|
|
property.PropertyType == typeof(long) ||
|
|
property.PropertyType == typeof(float) ||
|
|
property.PropertyType == typeof(double) ||
|
|
property.PropertyType == typeof(decimal) ||
|
|
property.PropertyType == typeof(bool))
|
|
{
|
|
return value;
|
|
}
|
|
return $"'{value}'";
|
|
}
|
|
}
|
|
|
|
public class BackupListRequest : RequestDto
|
|
{
|
|
[Required]
public string Name { get; set; }
}
|
|
|