@ -18,8 +18,6 @@ using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc ; using Microsoft.AspNetCore.Mvc ;
using Microsoft.AspNetCore.SignalR ; using Microsoft.AspNetCore.SignalR ;
using Microsoft.EntityFrameworkCore ; using Microsoft.EntityFrameworkCore ;
using Microsoft.EntityFrameworkCore.Infrastructure ;
using Microsoft.EntityFrameworkCore.Storage ;
using Microsoft.Extensions.Configuration ; using Microsoft.Extensions.Configuration ;
using Microsoft.Extensions.DependencyInjection ; using Microsoft.Extensions.DependencyInjection ;
using Microsoft.OpenApi.Extensions ; using Microsoft.OpenApi.Extensions ;
@ -35,25 +33,15 @@ using Volo.Abp.Validation;
using Win.Sfs.BaseData.ImportExcelCommon ; using Win.Sfs.BaseData.ImportExcelCommon ;
using Win.Sfs.SettleAccount.Entities.BQ.Dtos ; using Win.Sfs.SettleAccount.Entities.BQ.Dtos ;
using Win.Sfs.SettleAccount.Entities.BQ.Vmi ; using Win.Sfs.SettleAccount.Entities.BQ.Vmi ;
using Win.Sfs.SettleAccount.EntityFrameworkCore ;
using Win.Sfs.SettleAccount.influxdb ; using Win.Sfs.SettleAccount.influxdb ;
using Win.Sfs.Shared.Filter ; using Win.Sfs.Shared.Filter ;
using Win.Sfs.Shared.RepositoryBase ; using Win.Sfs.Shared.RepositoryBase ;
namespace Win.Sfs.SettleAccount.Entities.BQ ; namespace Win.Sfs.SettleAccount.Entities.BQ ;
public interface IVmiService : IApplicationService , ITransientDependency , IJobService
{
Task In ( VmiLogType logType , string changedNumber , VmiBalance data ) ;
Task Out ( VmiLogType logType , string changedNumber , VmiLog data ) ;
//Task UnDo(string groupId);
}
[AllowAnonymous] [AllowAnonymous]
[Route("api/settleaccount/[controller] / [ action ] ")]
[Route("api/settleaccount/[controller] / [ action ] ")]
public class VmiAppService : ApplicationService , IVmiService , I JobService , ITransientDependency public class VmiAppService : ApplicationService , IJobService , ITransientDependency
{ {
public static SemaphoreSlim backupLock = new SemaphoreSlim ( 1 ) ; public static SemaphoreSlim backupLock = new SemaphoreSlim ( 1 ) ;
private readonly IConfiguration _ cfg ; private readonly IConfiguration _ cfg ;
@ -85,6 +73,40 @@ public class VmiAppService : ApplicationService, IVmiService, IJobService, ITran
LinqToDBForEFTools . Initialize ( ) ; LinqToDBForEFTools . Initialize ( ) ;
} }
[HttpPost]
public async Task Test ( List < VmiLog > logs , int size = 1 0 0 0 )
{
using var scope = this . _ serviceProvider . CreateScope ( ) ;
var db = scope . ServiceProvider . GetRequiredService < SettleAccountDbContext > ( ) ;
using var dc = db . CreateLinqToDBConnection ( ) ;
dc . BeginTransaction ( ) ;
try
{
//var skip = 0;
//var count = logs.Count;
//while (count > 0)
//{
// var batchSize = count > size ? size : count;
// var tempLogs = logs.Skip(skip).Take(batchSize);
// var tempMessages = tempLogs.Select(o => new VmiMessage { Message = JsonSerializer.Serialize(o) });
// await dc.BulkCopyAsync(new BulkCopyOptions { TableName = "Set_VmiLog" }, tempLogs).ConfigureAwait(false);
// await dc.BulkCopyAsync(new BulkCopyOptions { TableName = "Set_VmiMessage" }, tempMessages).ConfigureAwait(false);
// count -= batchSize;
// skip += batchSize;
//}
await dc . BulkCopyAsync ( new BulkCopyOptions { TableName = "Set_VmiMessage" , MaxBatchSize = 1 } , new List < VmiMessage > {
new VmiMessage ( Guid . NewGuid ( ) ) { Message = "1" } ,
new VmiMessage ( Guid . NewGuid ( ) ) { Message = "2" }
} ) . ConfigureAwait ( false ) ;
dc . Transaction . Commit ( ) ;
}
catch
{
dc . Transaction . Rollback ( ) ;
throw ;
}
}
/// <summary>
/// <summary>
/// Excel 转 JSON
/// Excel 转 JSON
/// </summary>
/// </summary>
@ -131,60 +153,32 @@ public class VmiAppService : ApplicationService, IVmiService, IJobService, ITran
/// </summary>
/// </summary>
[NonAction] [NonAction]
[DisableValidation] [DisableValidation]
public virtual async Task Invoke ( IServiceProvider serviceProvider ) public virtual Task Invoke ( IServiceProvider serviceProvider )
{
await backupLock . WaitAsync ( ) . ConfigureAwait ( false ) ;
try
{ {
//this._hubContext.Clients.All.ServerToClient("JobItem", "refresh", "");
using var scope = serviceProvider . CreateScope ( ) ;
Directory . CreateDirectory ( Path . Combine ( Directory . GetCurrentDirectory ( ) , "wwwroot/files/vmi" ) ) ; var db = scope . ServiceProvider . GetRequiredService < SettleAccountDbContext > ( ) ;
var date = DateTime . Now . ToString ( "yyyy-MM-dd_HH.mm.ss" ) ; using var transaction = db . Database . BeginTransaction ( ) ;
var connectionString = $"Data Source=wwwroot/files/vmi/{date}.db" ;
using var dbContext = new VmiSqliteContext ( connectionString ) ;
if ( ! dbContext . GetService < IRelationalDatabaseCreator > ( ) . Exists ( ) & & dbContext . Database . EnsureCreated ( ) )
{
var query = serviceProvider . GetRequiredService < SettleAccountDbContext > ( ) . Set < VmiBalance > ( ) . AsNoTracking ( ) ;
var list = new List < VmiBalance > ( ) ;
using var dc = dbContext . CreateLinqToDBConnection ( ) ;
dc . BeginTransaction ( ) ;
try try
{ {
var now = DateTime . Now ; var time = DateTime . Now . ToString ( "yyyy_mm_dd_hh_mm_ss" ) ;
var table = "VmiBalance" ; var table = $"Set_VmiBalance_{time}" ;
foreach ( var item in query ) var snapshot = db . Set < VmiSnapshot > ( ) . Where ( o = > o . Name = = table ) . FirstOrDefault ( ) ;
{ if ( snapshot = = null )
item . BackupTime = now ;
list . Add ( item ) ;
if ( list . Count = = 1 0 0 0 0 )
{
//dbContext.Set<VmiBalance>().AddRange(list);
await dc . BulkCopyAsync ( new BulkCopyOptions { TableName = table } , list ) . ConfigureAwait ( false ) ;
list . Clear ( ) ;
}
}
if ( list . Count > 0 )
{
await dc . BulkCopyAsync ( new BulkCopyOptions { TableName = table } , list ) . ConfigureAwait ( false ) ;
}
dc . Transaction . Commit ( ) ;
var snapshot = new VmiSnapshot { Name = date , Path = connectionString } ;
await _ snapshotRepository . InsertAsync ( snapshot ) . ConfigureAwait ( false ) ;
}
catch
{ {
dc . Transaction . Rollback ( ) ; snapshot = new VmiSnapshot { Name = time , Path = table } ;
throw ; db . Set < VmiSnapshot > ( ) . Add ( snapshot ) ;
} db . SaveChanges ( ) ;
var result = db . Database . ExecuteSqlRaw ( $"select * into {table} from Set_VmiBalance;" ) ;
transaction . Commit ( ) ;
return Task . CompletedTask ;
} }
throw new Exception ( "备份程序正在运行" ) ;
} }
catch catch
{ {
transaction . Rollback ( ) ;
throw ; throw ;
} }
finally
{
backupLock . Release ( ) ;
}
} }
/// <summary>
/// <summary>
@ -192,9 +186,26 @@ public class VmiAppService : ApplicationService, IVmiService, IJobService, ITran
/// </summary>
/// </summary>
[HttpPost("invoke")] [HttpPost("invoke")]
[DisableValidation] [DisableValidation]
public virtual async Task VmiBackup ( ) public virtual async Task < IActionResult > VmiBackup ( )
{
if ( backupLock . CurrentCount = = 1 )
{
return new JsonResult ( new { Code = 5 0 0 , Message = "备份程序正在运行" } ) ;
}
await backupLock . WaitAsync ( ) . ConfigureAwait ( false ) ;
try
{ {
await Invoke ( _ serviceProvider ) . ConfigureAwait ( false ) ; await Invoke ( _ serviceProvider ) . ConfigureAwait ( false ) ;
return new JsonResult ( new { Code = 2 0 0 , Message = "备份成功" } ) ;
}
catch ( Exception ex )
{
return new JsonResult ( new { Code = 5 0 0 , Message = ex . Message , Data = ex . ToString ( ) } ) ;
}
finally
{
backupLock . Release ( ) ;
}
} }
/// <summary>
/// <summary>
@ -216,9 +227,9 @@ public class VmiAppService : ApplicationService, IVmiService, IJobService, ITran
var db = scope . ServiceProvider . GetRequiredService < SettleAccountDbContext > ( ) ; var db = scope . ServiceProvider . GetRequiredService < SettleAccountDbContext > ( ) ;
var balance = db . Set < VmiBalance > ( ) . FirstOrDefault ( var balance = db . Set < VmiBalance > ( ) . FirstOrDefault (
o = > o . BillType = = data . BillType & & o = > o . Deliver BillType= = data . Deliver BillType& &
o . CodeType = = data . CodeType & & o . CodeType = = data . CodeType & &
o . PartCod e= = data . PartCod e& & o . DeliverBillTyp e= = data . DeliverBillTyp e& &
o . VinCode = = data . VinCode & & o . VinCode = = data . VinCode & &
o . ErpToLoc = = data . ErpToLoc & & o . ErpToLoc = = data . ErpToLoc & &
o . OrderNum = = data . OrderNum & & o . OrderNum = = data . OrderNum & &
@ -296,9 +307,9 @@ public class VmiAppService : ApplicationService, IVmiService, IJobService, ITran
using var scope = _ serviceProvider . CreateScope ( ) ; using var scope = _ serviceProvider . CreateScope ( ) ;
var db = scope . ServiceProvider . GetRequiredService < SettleAccountDbContext > ( ) ; var db = scope . ServiceProvider . GetRequiredService < SettleAccountDbContext > ( ) ;
var balance = db . Set < VmiBalance > ( ) . FirstOrDefault ( var balance = db . Set < VmiBalance > ( ) . FirstOrDefault (
o = > o . BillType = = data . BillType & & o = > o . Deliver BillType= = data . Deliver BillType& &
o . CodeType = = data . CodeType & & o . CodeType = = data . CodeType & &
o . PartCod e= = data . PartCod e& & o . DeliverBillTyp e= = data . DeliverBillTyp e& &
o . VinCode = = data . VinCode & & o . VinCode = = data . VinCode & &
o . ErpToLoc = = data . ErpToLoc & & o . ErpToLoc = = data . ErpToLoc & &
o . OrderNum = = data . OrderNum & & o . OrderNum = = data . OrderNum & &
@ -508,11 +519,16 @@ public class VmiAppService : ApplicationService, IVmiService, IJobService, ITran
[HttpPost] [HttpPost]
public async Task < PagedResultDto < VmiBalance > > Backup ( BackupListRequest input ) public async Task < PagedResultDto < VmiBalance > > Backup ( BackupListRequest input )
{ {
var connectionString = $"Data Source=wwwroot/files/vmi/{input.Name}.db" ; using var scope = this . _ serviceProvider . CreateScope ( ) ;
using var dbContext = new VmiSqliteContext ( connectionString ) ; var db = scope . ServiceProvider . GetRequiredService < SettleAccountDbContext > ( ) ;
var repo = dbContext . Set < VmiBalance > ( ) ; var name = input . Name ;
var sql = $"select * from {name}" ;
var query = db . Set < VmiBalance > ( ) . FromSqlRaw ( sql ) ;
var filters = input . Filters . ToLambda < VmiBalance > ( ) ; var filters = input . Filters . ToLambda < VmiBalance > ( ) ;
var query = ( input . Filters . Count > 0 ? repo . Where ( input . Filters . ToLambda < VmiBalance > ( ) ) : repo ) ; if ( input . Filters . Count > 0 )
{
query = query . Where ( input . Filters . ToLambda < VmiBalance > ( ) ) ;
}
var totalCount = query . Count ( ) ; var totalCount = query . Count ( ) ;
query = string . IsNullOrEmpty ( input . Sorting ) ? query : DynamicQueryableExtensions . OrderBy ( query , input . Sorting ) ; query = string . IsNullOrEmpty ( input . Sorting ) ? query : DynamicQueryableExtensions . OrderBy ( query , input . Sorting ) ;
var entities = await query . PageBy ( input . SkipCount , input . MaxResultCount ) . ToListAsync ( ) . ConfigureAwait ( false ) ; var entities = await query . PageBy ( input . SkipCount , input . MaxResultCount ) . ToListAsync ( ) . ConfigureAwait ( false ) ;
@ -525,11 +541,17 @@ public class VmiAppService : ApplicationService, IVmiService, IJobService, ITran
[HttpPost] [HttpPost]
public async Task < string > BackupExport ( BackupListRequest input ) public async Task < string > BackupExport ( BackupListRequest input )
{ {
var connectionString = $"Data Source=wwwroot/files/vmi/{input.Name}.db" ; using var scope = this . _ serviceProvider . CreateScope ( ) ;
using var dbContext = new VmiSqliteContext ( connectionString ) ; var db = scope . ServiceProvider . GetRequiredService < SettleAccountDbContext > ( ) ;
var repo = dbContext . Set < VmiBalance > ( ) ; var name = input . Name ;
var sql = $"select * from {name}" ;
var query = db . Set < VmiBalance > ( ) . FromSqlRaw ( sql ) ;
var filters = input . Filters . ToLambda < VmiBalance > ( ) ; var filters = input . Filters . ToLambda < VmiBalance > ( ) ;
var query = ( input . Filters . Count > 0 ? repo . Where ( input . Filters . ToLambda < VmiBalance > ( ) ) : repo ) ; if ( input . Filters . Count > 0 )
{
query = query . Where ( input . Filters . ToLambda < VmiBalance > ( ) ) ;
}
var totalCount = query . Count ( ) ;
query = string . IsNullOrEmpty ( input . Sorting ) ? query : DynamicQueryableExtensions . OrderBy ( query , input . Sorting ) ; query = string . IsNullOrEmpty ( input . Sorting ) ? query : DynamicQueryableExtensions . OrderBy ( query , input . Sorting ) ;
var entities = await query . ToListAsync ( ) . ConfigureAwait ( false ) ; var entities = await query . ToListAsync ( ) . ConfigureAwait ( false ) ;
var fileName = $"库存备份_{input.Name}.xlsx" ; var fileName = $"库存备份_{input.Name}.xlsx" ;
