Compare commits

...

82 Commits

Author SHA1 Message Date
cb7d154f64 Refactor LicenseManager registration with factory
Replaces transient LicenseManager registration (with per-injection license key retrieval via MediatR) with a singleton LicenseManagerFactory. This centralizes license management and may improve performance and maintainability.
2026-04-14 21:05:21 +02:00
a3f404b9ae Refactor to use LicenseManagerFactory in PDF jobs
Replaced direct LicenseManager dependencies with LicenseManagerFactory in PDFBurner and PDFMerger classes. This change improves license management flexibility and encapsulation, allowing for better handling of license-related logic.
2026-04-14 21:05:08 +02:00
1f7eb5d4ea Add LicenseManagerFactory for GdPicture license caching
Introduced LicenseManagerFactory to create and cache GdPicture14 LicenseManager instances. The factory retrieves the license key via MediatR, caches it using IMemoryCache with NeverRemove priority, and registers it with LicenseManager. Dependencies are injected, and the license key is preloaded on instantiation.
2026-04-14 21:03:54 +02:00
e1ae3ffccb Increase log verbosity; add InitialJobState config
Changed ASP.NET Core log level to Information in development.
Added Worker.InitialJobState setting to control job startup state,
defaulting FinalizeDocumentJob to Running. Added explanatory
comments for job state values.
2026-04-14 14:47:05 +02:00
3e3bfaa904 Remove GdPictureLicenseKey from WorkerOptions
The GdPictureLicenseKey property was removed from the WorkerOptions class as it is no longer needed. This change helps to simplify the configuration and reduce unused properties.
2026-04-14 13:36:54 +02:00
f8422ed94c Remove unused GdPicture license key retrieval
The ExecuteAsync method in FinalizeDocumentJob.cs no longer retrieves the GdPicture license key, as it is not used in this part of the code. This helps clean up unnecessary code and improves maintainability.
2026-04-14 13:36:28 +02:00
c64c63925e Retrieve GdPicture license key via MediatR from database
Refactored LicenseManager registration to fetch the GdPicture license key from the database using MediatR and ReadThirdPartyModuleLicenseQuery, instead of reading from configuration. Updated using statements accordingly.
2026-04-14 13:25:07 +02:00
2c8ae23203 Add ThirdPartyModule DbSet to EGDbContextBase
Added a DbSet property for ThirdPartyModule entities in EGDbContextBase to enable management and querying of third-party modules via Entity Framework.
2026-04-14 13:21:28 +02:00
b4be718994 Add query/handler to fetch third-party module license text
Introduced ReadThirdPartyModuleLicenseQuery and its handler to retrieve the license text of a third-party module by Id or Name (mutually exclusive), with optional filtering for active modules. Includes validation and exception handling for invalid input, not found, or multiple matches.
2026-04-14 12:39:31 +02:00
33bf5b1a51 Add ThirdPartyModule entity with auditing support
Introduced the ThirdPartyModule entity mapped to the TBDD_3RD_PARTY_MODULES table using Entity Framework. The class includes properties for module details and auditing (added/changed by and when), implements IHasChangedWhen and IHasChangedWho interfaces, and uses conditional compilation for .NET Framework and nullable reference types. Data annotations and schema mapping attributes were added for precise database integration.
2026-04-14 12:15:42 +02:00
6a9792bb57 Refactor WorkerController to manage job state via API
Removed endpoints for starting/stopping/restarting the Worker service. Controller now uses JobStateManager to get and set the state of specific jobs (e.g., FinalizeDocumentJob) through new GET and POST endpoints. Focus shifts from service lifecycle control to job state management.
2026-04-13 16:31:54 +02:00
6954a86358 Add job state check and improve Worker options handling
Refactored Worker to inject JobStateManager and use the full
WorkerOptions object. Now, FinalizeDocumentJob only runs if
its state is State.Running. Delay is also read from options,
improving configuration and control over job execution.
2026-04-13 16:31:00 +02:00
d6c5b63c49 Register JobStateManager as singleton in DI container
JobStateManager is now added as a singleton service, initialized with the InitialJobState from WorkerOptions. This enables consistent state management across the application by providing a shared instance via dependency injection.
2026-04-13 16:30:27 +02:00
8ca360d47e Add InitialJobState and GdPictureLicenseKey to WorkerOptions
Added InitialJobState as a Dictionary<string, State> with an empty default, and introduced a non-nullable GdPictureLicenseKey property to the WorkerOptions class. These additions support initial job state configuration and GdPicture licensing.
2026-04-13 16:29:14 +02:00
2dadefecc5 Add JobStateManager for thread-safe job state tracking
Introduced JobStateManager class to manage job states using a ConcurrentDictionary, supporting thread-safe get/set operations per job type. Added State enum with Running and Stopped values. Allows optional initial state dictionary for job states.
2026-04-13 16:28:40 +02:00
162f066b08 Refactor Worker to use IOptions for configuration
Replaced direct IConfiguration usage in Worker with IOptions<WorkerOptions> for strongly-typed configuration access. Updated delay interval assignment and added necessary namespace import.
2026-04-13 15:25:17 +02:00
6592642945 Update WorkerOptions config section to "Worker"
Changed AddFinalizeDocumentJob to bind WorkerOptions from the "Worker" section in configuration instead of "WorkerOptions" for correct settings mapping.
2026-04-13 15:22:55 +02:00
855f22cf87 Add DelayMilliseconds property to WorkerOptions
Introduced a configurable DelayMilliseconds property to the WorkerOptions class with validation to ensure the value is at least 1 millisecond. This allows for customizable delay settings in worker operations.
2026-04-13 15:22:34 +02:00
726673e277 Add Windows Services hosting support to ServiceHost
Added Microsoft.Extensions.Hosting.WindowsServices package (v8.0.1) to EnvelopeGenerator.ServiceHost.csproj to enable hosting the application as a Windows Service. No other changes were made.
2026-04-13 12:00:01 +02:00
65d615f43e Support inline PDF display or download via query param
Add a 'download' query parameter to DocResultController's GetAsync method. This lets clients choose whether to download the PDF or display it inline by setting the 'download' parameter in the request.
2026-04-13 11:57:46 +02:00
f0f92c5400 Ensure DocResult is included in envelope query handling
Set IncludeDocResult to true on the envelope in the query handler to guarantee the document result is included in responses. This prevents missing document data when processing envelope queries.
2026-04-09 17:10:45 +02:00
7e34f01f6a Include doc result in GetDocResultAsync query
Set IncludeDocResult to true in GetDocResultAsync to ensure the document result is included when retrieving envelope data. This change guarantees that the response contains the necessary document information.
2026-04-09 17:10:08 +02:00
f449767bf9 Add [NotMapped] for Envelope property on .NET Framework
Applied the [NotMapped] attribute to a property in the Envelope class when targeting .NET Framework, ensuring it is not mapped to a database column by Entity Framework in that environment. No changes for other frameworks.
2026-04-09 17:09:40 +02:00
f8ec6065c2 Add IncludeDocResult option to EnvelopeQueryBase
Introduced the IncludeDocResult boolean property to EnvelopeQueryBase, allowing queries to optionally include the DocResult field. By default, DocResult is excluded to prevent unnecessary loading of large binary data.
2026-04-09 16:36:30 +02:00
fabfe80666 Change FinalizeDocumentJob to scoped, add ReportCreator
Changed FinalizeDocumentJob DI registration from singleton to scoped for better instance management. Added ReportCreator as a scoped service. Removed unused EnvelopeGenerator.ServiceHost.Jobs.Infrastructure import.
2026-04-09 16:01:51 +02:00
bdb3863c07 Refactor Kestrel config and add exception middleware
Replaced "UseKestrelConfig" with "UseCustomKestrelEndpoints" and renamed the "Kestrel" section to "ServerConfig" in both Program.cs and appsettings.json. Updated Kestrel server configuration to use the new section. Added ExceptionHandlingMiddleware to the pipeline for global exception handling.
2026-04-09 15:54:38 +02:00
e5295b8302 Add global exception handling middleware
Introduced ExceptionHandlingMiddleware to handle exceptions across the ASP.NET Core request pipeline. The middleware logs exceptions and returns JSON error responses with appropriate HTTP status codes for BadRequestException (400), NotFoundException (404), and generic errors (500). Dependency injection is used for RequestDelegate and ILogger.
2026-04-09 14:47:46 +02:00
00a9cf06da Refactor envelope doc query and improve result validation
Refactored ReadSingleEnvelopeDocResultQuery to remove inheritance from EnvelopeQueryBase and introduce an Envelope property. Enhanced the handler to ensure DocResult is a non-empty byte array before returning, throwing NotFoundException otherwise.
2026-04-09 14:46:04 +02:00
1b387238e8 Configure EnvelopeReport as a keyless entity
Added Entity Framework model configuration for EnvelopeReport in EGDbContextBase, specifying it as a keyless entity using HasNoKey(). This allows EnvelopeReport to be used without a primary key in the database context.
2026-04-09 14:30:23 +02:00
bda4f3dbef Add conditional Windows Service & Kestrel config support
The app now checks configuration values to optionally run as a Windows Service ("UseWindowsService") and/or apply custom Kestrel server settings from the "Kestrel" config section ("UseKestrelConfig"). These changes improve deployment flexibility.
2026-04-09 14:20:04 +02:00
2458d0c07a Configure Kestrel endpoint and hosting options in settings
Added "UseWindowsService" and "UseKestrelConfig" flags to appsettings.json. Defined a custom Kestrel HTTP endpoint at http://localhost:1111 to control how the application is hosted and served.
2026-04-09 14:19:36 +02:00
a72cbab195 Add GET endpoint to return envelope PDF by UUID
Added a new HTTP GET action to DocResultController that accepts a ReadSingleEnvelopeDocResultQuery via query string. The endpoint uses MediatR to retrieve the PDF document and returns it as a file response with the envelope's UUID in the filename and the correct content type.
2026-04-09 14:05:54 +02:00
bcf4e63f7c Add distributed cache, localization, and infra services
- Add DigitalData.Core.API and SQL Server distributed cache dependencies
- Register EnvelopeGenerator.Application project reference
- Configure distributed SQL Server cache and memory cache
- Register infrastructure, application, and user management services
- Set up EF Core with SQL Server and detailed logging
- Enable localization with configurable supported cultures
- Improve modularity and extensibility of service registration
2026-04-09 13:36:40 +02:00
5aabeb4510 Update project to net8.0-windows and enable WinForms
Changed target framework to net8.0-windows to specify Windows platform support. Enabled Windows Forms by setting UseWindowsForms to true in the project file.
2026-04-09 13:34:07 +02:00
32edc6474d Add SupportedCultures and DB connection to appsettings.json
Added "SupportedCultures" for localization support and a "ConnectionStrings" section with a default SQL Server connection string. Also reformatted "AllowedHosts" for consistency.
2026-04-09 13:22:59 +02:00
71bfe3b323 Refactor Worker to resolve FinalizeDocumentJob per scope
Refactored Worker to use IServiceScopeFactory instead of directly injecting FinalizeDocumentJob. Now, a new scope is created in each loop iteration, and FinalizeDocumentJob is resolved from the scoped service provider. This enables FinalizeDocumentJob to use scoped dependencies and improves DI flexibility.
2026-04-09 13:20:02 +02:00
089d2bd1cb Add FinalizeDocumentController and refactor query model
Refactored ReadSingleEnvelopeDocResultQuery to use a parameterless constructor and an Envelope property. Introduced FinalizeDocumentController with a GET endpoint to finalize and return envelope documents as PDFs, supporting force regeneration. Added dependency injection for IMediator and FinalizeDocumentJob. Includes a TODO to migrate forceRegenerate logic into the job.
2026-04-09 10:55:13 +02:00
65c72bcf77 Add DocResultController for envelope PDF download
Introduced DocResultController with a GET endpoint to retrieve envelope PDF documents by sending a query via MediatR. The controller returns the PDF as a file response with an appropriate filename and content type. Added necessary using directives for MediatR, ASP.NET Core MVC, and the application query.
2026-04-09 10:30:04 +02:00
2d8375f26a Refactor envelope query to throw on not found or multiple
Refactored ReadSingleEnvelopeQuery and its handler to return EnvelopeDto directly and throw NotFoundException or BadRequestException when no or multiple envelopes are found, instead of returning null. Updated imports to include custom exceptions.
2026-04-09 10:28:13 +02:00
a7cfb099fa Add query/handler for envelope document retrieval
Introduced ReadSingleEnvelopeDocResultQuery and its handler to fetch an envelope's document as a byte array via MediatR. Throws NotFoundException if the document is missing. Includes XML documentation for clarity.
2026-04-09 10:26:44 +02:00
7a0d4e2fa7 Remove MediatorGetOrContext; add ExecuteAsync overloads
Removed MediatorGetOrContext.cs, eliminating the fluent API for handling null or empty MediatR responses with custom exceptions. Added two ExecuteAsync overloads to FinalizeDocumentJob: one for processing a single EnvelopeDto and another for processing all envelopes with the EnvelopeCompletelySigned status.
2026-04-09 10:25:59 +02:00
3955ee9f39 Refactor Mediator GetOr API for naming consistency
Renamed MediatorExtensions to MediatorGetOrContext and GetOrContext<TResponse> to MediatorGetOrContext<TResponse> for consistent naming. Moved the GetOr extension method into the new static class. Updated XML docs and reorganized declarations; no functional changes.
2026-04-08 15:34:39 +02:00
9bdf24d7d5 Refactor MediatorExtensions to fluent GetOr/Throw API
Replaced GetOrThrow methods with a fluent GetOr/Throw pattern for handling null or empty MediatR responses. Introduced GetOrContext<TResponse> struct with Throw, ThrowNotFound, ThrowInvalidOperation, and ThrowBadRequest methods. Updated all tests to use the new API and added coverage for new exception types. Improved XML docs and performed minor code cleanup.
2026-04-08 15:26:23 +02:00
993ca82596 Rename MediatR extensions to GetOrThrow for ISender
Renamed SendOrThrowAsync and SendOrNotFoundAsync extension methods for IMediator to GetOrThrow for ISender, following MediatR best practices. Updated all usages, XML docs, and tests to use ISender and the new method names. Replaced StubMediator with StubSender in tests. Functionality remains the same, but code now aligns with modern MediatR conventions.
2026-04-08 14:01:24 +02:00
ce9958a8b1 Add MediatorExtensions tests and refactor CreateEnvelopeCommand
Introduce MediatorExtensionsTests to cover SendOrThrowAsync and SendOrNotFoundAsync extension methods for IMediator, including edge cases and cancellation. Refactor CreateEnvelopeCommand in Fake.cs to use Authorize(userId) instead of setting UserId directly. Add test stubs for IMediator and IRequest to support isolated testing.
2026-04-08 13:46:27 +02:00
6c54473d5a Refactor MediatorExtensions for flexible exception handling
Generalize null/empty response handling with SendOrThrowAsync<TResponse, TException>, allowing custom exceptions via a factory delegate. SendOrNotFoundAsync now wraps this method for NotFoundException. Improves type safety, flexibility, and XML docs; avoids treating strings as collections.
2026-04-08 13:44:19 +02:00
9ad4352e02 Add MediatorExtensions for not-found handling in MediatR
Introduced MediatorExtensions with SendOrNotFoundAsync methods to enforce non-null and non-empty responses from MediatR requests. These extensions throw NotFoundException when responses are null or empty, centralizing not-found logic and improving error handling.
2026-04-08 13:25:34 +02:00
90031db6a5 Add query/handler for retrieving a single envelope
Introduced ReadSingleEnvelopeQuery and its handler to enable
retrieval of a single envelope with optional user filtering.
Supports filtering by user ID, envelope ID, or UUID, includes
related documents, and maps results to EnvelopeDto using
AutoMapper for secure and flexible access.
2026-04-08 10:49:23 +02:00
bc07af9622 Refactor jobs to use EnvelopeDto/ReceiverDto instead of entities
Refactored ActionService and FinalizeDocumentJob to use EnvelopeDto and ReceiverDto in place of domain entities. Updated method signatures, internal logic, and envelope receiver handling to operate on DTOs. Improved logging, removed obsolete code, and added necessary using statements for DTO namespaces. Also updated document retrieval logic and removed null-conditional operator from actionService calls.
2026-04-01 16:18:17 +02:00
4caf8cd192 Refactor to use EnvelopeDto in report generation
Updated ReportCreator and ReportItem to accept EnvelopeDto
instead of Envelope, promoting better separation of concerns
and improved data handling via DTOs.
2026-04-01 15:32:09 +02:00
5423d5317b Update DI and add EF Core SqlServer for all frameworks
- Bump Microsoft.Extensions.DependencyInjection to 9.0.6 for .NET 9.0
- Add Microsoft.EntityFrameworkCore.SqlServer for .NET 7.0, 8.0, and 9.0
- Improve ItemGroup formatting for clarity and consistency
2026-04-01 15:24:42 +02:00
6c8c8f22a3 Add EnvelopeReceivers to EnvelopeDto
Added EnvelopeReceivers property to EnvelopeDto to support a collection of envelope receiver DTOs. Also included the required using directive for EnvelopeReceiverDto.
2026-04-01 15:22:56 +02:00
5100504f16 Add MinMinutesSinceLastChange filter to envelope query
Introduced an optional MinMinutesSinceLastChange filter to ReadEnvelopeQuery and updated the handler to return only envelopes whose last change was at least the specified number of minutes ago. This enables time-based filtering of envelope results.
2026-04-01 15:06:13 +02:00
15f8baf54c Add WorkerController API to control background Worker service
Introduced a new WorkerController with endpoints to start, stop, and restart the background Worker service via HTTP API. The controller uses dependency injection to locate the Worker instance and logs each operation. Also removed an unused Controllers folder reference from the project file.
2026-04-01 11:52:07 +02:00
4e847fa737 Remove MSSQLServer service registration from DI
The MSSQLServer service is no longer registered in the dependency injection container within DependencyInjection.cs. This change means MSSQLServer will not be available for injection throughout the application. The comment regarding service lifetimes remains for future review.
2026-04-01 11:27:13 +02:00
53ff48dc3c Remove obsolete Debug property from WorkerOptions
The Debug property, previously marked as obsolete in WorkerOptions, has been removed. Debugging should now be managed through ILogger-based logging instead of this flag.
2026-04-01 11:23:29 +02:00
ab67b3fba2 Remove obsolete ReportModel and DI registration
Removed the deprecated ReportModel class and its List method, along with its registration in the dependency injection setup. This cleanup reflects the migration to EnvelopeReport mediator queries.
2026-04-01 11:18:45 +02:00
3855a8fa1e Refactor ReportItem creation and encapsulate mapping
Moved mapping logic from ReportCreator.ToReportItem to a new constructor in ReportItem, improving encapsulation and simplifying report generation. Updated usings to remove unused and add necessary dependencies.
2026-04-01 11:15:33 +02:00
052da02bd0 Refactor ReportCreator: remove logging and simplify logic
Removed ILogger dependency and all related logging from ReportCreator. Inlined DoCreateReport into CreateReportAsync and eliminated the try-catch block, allowing exceptions to propagate naturally. Improved the error message for missing report data. The class is now more focused and streamlined.
2026-04-01 11:15:17 +02:00
53a9a3e3eb Refactor report generation to use async repository access
Replaces obsolete DataTable-based logic in ReportCreator with async repository queries for EnvelopeReport entities. Refactors ReportItem to use explicit header and detail fields, removing legacy Envelope references. Updates report designer bindings to match new ReportItem properties. Improves exception handling and overall type safety.
2026-04-01 10:42:44 +02:00
c2ab18e184 Replace hand-coded envelope report with DevExpress XtraReport
Switch to a designer-generated DevExpress XtraReport for envelope history, replacing the previous manual layout. Added designer (.Designer.cs), resource (.resx), and updated code-behind (.cs) files. Updated the project file to include new report assets. Changed report generation to use the new async API. This modernizes the report, improves maintainability, and enhances appearance.
2026-03-30 16:53:39 +02:00
8f845e8a9a Refactor database namespace for improved modularity
Replaced DigitalData.Modules.Database with EnvelopeGenerator.ServiceHost.Jobs.Infrastructure in using statements and class namespaces. All database operations are now organized under the new namespace for better clarity and project structure.
2026-03-16 16:43:49 +01:00
7af934ea19 Integrate DevExpress Reporting for envelope history
Added DevExpress.Reporting.Core package reference. Refactored rptEnvelopeHistory to inherit from XtraReport and build its layout programmatically using DevExpress bands, tables, and styling. The report now uses A4 paper size, custom margins, and DevExpress UI components for rendering.
2026-03-09 21:27:06 +01:00
b65367fb6d Refactor FinalizeDocumentJob dependencies and method call
Removed unused constructor parameters from FinalizeDocumentJob for cleaner dependency injection. Updated actionService.FinalizeEnvelope to accept a cancellation token. Added missing using directive for Microsoft.Extensions.Options.
2026-03-09 21:26:52 +01:00
25c31108cb Add EnvelopeReport repository dependency to ReportCreator
Updated ReportCreator constructor to require an IRepository<EnvelopeReport> parameter, enabling direct access to envelope report data within the class. This change prepares the class for future data operations involving envelope reports.
2026-03-09 21:26:19 +01:00
4083833b19 Add EnvelopeReports DbSet to EGDbContextBase
Added EnvelopeReports DbSet property to EGDbContextBase, enabling Entity Framework to manage and query EnvelopeReport entities.
2026-03-09 21:25:30 +01:00
f53bc65acf Add EnvelopeReport entity mapped to VWSIG_ENVELOPE_REPORT
Introduced the EnvelopeReport class in the Domain.Entities namespace, mapped to the "VWSIG_ENVELOPE_REPORT" table using EF Core data annotations. The entity includes properties for envelope ID, head UUID, title, message, status, timestamp, and user, with appropriate column mappings and validation attributes.
2026-03-09 21:25:15 +01:00
070d9be00c Remove obsolete State class and DI registration
Removed the deprecated State class and its properties from the codebase. Also removed State from the dependency injection configuration, as it is no longer used.
2026-03-09 16:52:52 +01:00
6f7b04a26e Refactor: remove strict checks and logging in finalization
Removed exception throwing and logging for failed report creation, email sending, and envelope finalization in FinalizeDocumentJob. Now, these methods are called without checking their return values. Also improved exception message for file export to include envelope Id and added null-forgiving operator to _config.ExportPath.
2026-03-09 16:31:31 +01:00
473358e2b9 Make ExportPath non-nullable in ConfigDto
Changed ExportPath from a nullable string to a non-nullable string in ConfigDto and initialized it with the null-forgiving operator. This ensures ExportPath always has a value and cannot be null.
2026-03-09 16:30:39 +01:00
8f3aa69cbf Refactor document save to use async repository update
Replaced manual SQL and file read with async repository update for saving final document bytes. Removed obsolete helper methods and cleaned up unused imports for improved maintainability and testability.
2026-03-09 16:18:20 +01:00
eededeb1f1 Remove SendFinalEmailWithAttachment and related logic
Removed the SendFinalEmailWithAttachment method and all references to it from SendFinalEmailToCreator and SendFinalEmailToReceivers. The logic for determining email attachments based on FinalEmailType is no longer used. Other functionality in these methods remains unchanged.
2026-03-09 15:41:56 +01:00
737774f077 Remove PDF annotation and envelope data methods
Removed BurnAnnotationsToPdf, GetEnvelopeData, and GetAnnotationData from FinalizeDocumentJob. These methods handled document reading, annotation retrieval, and PDF annotation burning. This change reflects a refactor or shift in document processing responsibilities.
2026-03-09 15:34:58 +01:00
69499273cc Refactor FinalizeDocumentJob to async and use docStatusRepo
Refactored FinalizeDocumentJob to make the Finalize method asynchronous and fetch document annotations from docStatusRepo instead of using GetEnvelopeData. Updated constructor to inject IRepository<Domain.Entities.DocumentStatus>. Improved logging and removed obsolete envelopeData checks.
2026-03-09 15:32:32 +01:00
ead33ab2e7 Refactor Envelope properties; add DefaultDocument property
Refactored property declarations in the Envelope class for improved readability by removing unnecessary line breaks and nullable preprocessor directives. Added a [NotMapped] DefaultDocument property to return the first document in the Documents list, or null if none exist.
2026-03-09 15:09:51 +01:00
d1e2840617 Clean up debug logging in FinalizeDocumentJob
Removed numerous debug-level log statements to reduce log verbosity and focus on warnings and information logs. Updated some log messages to use interpolated strings for clarity. Refactored GetAnnotationData to use C# collection expressions for improved code conciseness.
2026-03-09 11:35:49 +01:00
a39ef6a0e2 Improve error handling in FinalizeDocumentJob
Added RethrowOnError property to control exception rethrowing during envelope finalization. Exceptions are now logged as errors and, if RethrowOnError is true, rethrown to enable stricter error handling and halt execution on failure.
2026-03-09 11:30:43 +01:00
7d620988d8 Refactor envelope finalization into a private method
Extracted envelope finalization logic from the foreach loop into a new private Finalize(Envelope envelope) method. This improves code readability and maintainability by encapsulating all steps of the finalization process without changing functionality.
2026-03-09 11:25:36 +01:00
cc4a7d8c20 Refactor ActionService: DI, CancellationToken support
Refactored ActionService to use constructor injection for IRepository<History>. Updated all public methods to accept optional CancellationToken parameters for improved cancellation support. Added necessary using directives. Class remains a placeholder with [Obsolete] attributes and NotImplementedException.
2026-03-09 10:18:53 +01:00
0b8068f926 Add summary comment to ActionService for migration context
Added an XML summary comment to the ActionService class to indicate it is being migrated from EnvelopeGenerator.CommonServices.Services.ActionService. This provides clarity on the class's origin and intended purpose; no functional changes were made.
2026-03-09 10:12:32 +01:00
9fd7a68798 Refactor envelope processing for per-item error handling
Move per-envelope logic in FinalizeDocumentJob into its own try-catch block within the foreach loop. This ensures that exceptions in processing one envelope do not halt the processing of others, improving robustness and fault tolerance. Removed the outer try-catch-finally block and updated logging to reflect per-envelope and overall job status.
2026-03-09 09:42:55 +01:00
d6e2690bb8 Refactor envelope fetch to use EF LINQ instead of SQL
Replaced raw SQL and DataTable usage with Entity Framework LINQ queries for retrieving completed envelopes. The process now works directly with envelope entities, improving code readability, maintainability, and leveraging EF's querying capabilities. Logging and error handling have been updated to use envelope properties directly.
2026-03-09 09:38:08 +01:00
40 changed files with 2054 additions and 510 deletions

View File

@@ -71,6 +71,7 @@ public class EnvelopeController : ControllerBase
[HttpGet("doc-result")]
public async Task<IActionResult> GetDocResultAsync([FromQuery] ReadEnvelopeQuery query, [FromQuery] bool view = false)
{
query.IncludeDocResult = true;
var envelopes = await _mediator.Send(query.Authorize(User.GetId()));
var envelope = envelopes.FirstOrDefault();

View File

@@ -31,7 +31,7 @@ public class ConfigDto
/// <summary>
/// Gets or sets the path where exports will be saved.
/// </summary>
public string? ExportPath { get; set; }
public string ExportPath { get; set; } = null!;
/// <summary>
/// Gets or sets the creation timestamp.

View File

@@ -1,5 +1,6 @@
using DigitalData.EmailProfilerDispatcher.Abstraction.Attributes;
using DigitalData.UserManager.Application.DTOs.User;
using EnvelopeGenerator.Application.Common.Dto.EnvelopeReceiver;
using EnvelopeGenerator.Domain.Constants;
using EnvelopeGenerator.Domain.Entities;
using EnvelopeGenerator.Domain.Interfaces;
@@ -174,4 +175,9 @@ public record EnvelopeDto : IEnvelope
///
/// </summary>
public IEnumerable<DocumentDto>? Documents { get; set; }
/// <summary>
///
/// </summary>
public IEnumerable<EnvelopeReceiverDto>? EnvelopeReceivers { get; set; }
}

View File

@@ -14,4 +14,10 @@ public record EnvelopeQueryBase
/// Die universell eindeutige Kennung des Umschlags.
/// </summary>
public virtual string? Uuid { get; set; }
/// <summary>
/// Wenn gesetzt, wird das DocResult-Feld in der Abfrage einbezogen.
/// Standardmäßig wird DocResult nicht geladen, um große Binärdaten zu vermeiden.
/// </summary>
public bool IncludeDocResult { get; set; } = false;
}

View File

@@ -41,7 +41,7 @@
</ItemGroup>
<ItemGroup Condition="'$(TargetFramework)' == 'net9.0'">
<PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="9.0.5" />
<PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="9.0.6" />
</ItemGroup>
<ItemGroup>
@@ -78,26 +78,29 @@
</EmbeddedResource>
</ItemGroup>
<ItemGroup Condition="'$(TargetFramework)' == 'net7.0'">
<PackageReference Include="AutoMapper" Version="13.0.1" />
<PackageReference Include="Microsoft.Data.SqlClient" Version="5.2.2" />
<PackageReference Include="CommandDotNet">
<ItemGroup Condition="'$(TargetFramework)' == 'net7.0'">
<PackageReference Include="AutoMapper" Version="13.0.1" />
<PackageReference Include="Microsoft.Data.SqlClient" Version="5.2.2" />
<PackageReference Include="Microsoft.EntityFrameworkCore.SqlServer" Version="7.0.20" />
<PackageReference Include="CommandDotNet">
<Version>7.0.5</Version>
</PackageReference>
</ItemGroup>
</PackageReference>
</ItemGroup>
<ItemGroup Condition="'$(TargetFramework)' == 'net8.0'">
<PackageReference Include="AutoMapper" Version="14.0.0" />
<PackageReference Include="CommandDotNet">
<Version>8.1.1</Version>
</PackageReference>
</ItemGroup>
<ItemGroup Condition="'$(TargetFramework)' == 'net8.0'">
<PackageReference Include="AutoMapper" Version="14.0.0" />
<PackageReference Include="Microsoft.EntityFrameworkCore.SqlServer" Version="8.0.17" />
<PackageReference Include="CommandDotNet">
<Version>8.1.1</Version>
</PackageReference>
</ItemGroup>
<ItemGroup Condition="'$(TargetFramework)' == 'net9.0'">
<PackageReference Include="AutoMapper" Version="14.0.0" />
<PackageReference Include="CommandDotNet">
<Version>8.1.1</Version>
</PackageReference>
</ItemGroup>
<ItemGroup Condition="'$(TargetFramework)' == 'net9.0'">
<PackageReference Include="AutoMapper" Version="14.0.0" />
<PackageReference Include="Microsoft.EntityFrameworkCore.SqlServer" Version="9.0.6" />
<PackageReference Include="CommandDotNet">
<Version>8.1.1</Version>
</PackageReference>
</ItemGroup>
</Project>

View File

@@ -24,6 +24,12 @@ public record ReadEnvelopeQuery : EnvelopeQueryBase, IRequest<IEnumerable<Envelo
/// </summary>
public int? UserId { get; init; }
/// <summary>
/// Optionaler Zeitfilter in Minuten; wenn gesetzt, werden nur Umschläge zurückgegeben,
/// deren letzte Änderung mindestens diese Anzahl an Minuten zurückliegt.
/// </summary>
public int? MinMinutesSinceLastChange { get; init; }
/// <summary>
/// Setzt den Benutzerkontext für die Abfrage.
/// </summary>
@@ -132,6 +138,12 @@ public class ReadEnvelopeQueryHandler : IRequestHandler<ReadEnvelopeQuery, IEnum
query = query.Where(e => !status.Ignore.Contains(e.Status));
}
if (request.MinMinutesSinceLastChange is int minMinutesSinceLastChange)
{
query = query.Where(e => e.ChangedWhen.HasValue
&& EF.Functions.DateDiffMinute(e.ChangedWhen.Value, DateTime.Now) >= minMinutesSinceLastChange);
}
var envelopes = await query
.Include(e => e.Documents)
.ToListAsync(cancel);

View File

@@ -0,0 +1,48 @@
using MediatR;
using EnvelopeGenerator.Application.Common.Dto;
using DigitalData.Core.Exceptions;
namespace EnvelopeGenerator.Application.Envelopes.Queries;
/// <summary>
/// Repräsentiert eine Abfrage für Umschläge.
/// </summary>
public record ReadSingleEnvelopeDocResultQuery() : IRequest<byte[]>
{
/// <summary>
///
/// </summary>
public ReadSingleEnvelopeQuery Envelope { get; set; } = null!;
}
/// <summary>
/// Verarbeitet <see cref="ReadEnvelopeQuery"/> und liefert passende <see cref="EnvelopeDto"/>-Ergebnisse.
/// </summary>
public class ReadSingleEnvelopeDocResultQueryHandler : IRequestHandler<ReadSingleEnvelopeDocResultQuery, byte[]>
{
private readonly IMediator _mediator;
/// <summary>
///
/// </summary>
/// <param name="mediator"></param>
public ReadSingleEnvelopeDocResultQueryHandler(IMediator mediator)
{
_mediator = mediator;
}
/// <summary>
///
/// </summary>
/// <param name="request"></param>
/// <param name="cancellationToken"></param>
/// <returns></returns>
public async Task<byte[]> Handle(ReadSingleEnvelopeDocResultQuery request, CancellationToken cancellationToken)
{
request.Envelope.IncludeDocResult = true;
var result = await _mediator.Send(request.Envelope, cancellationToken);
return result.DocResult is byte[] docResult && docResult.Length > 0
? docResult
: throw new NotFoundException($"Document for Envelope with ID {request.Envelope.Id} not found");
}
}

View File

@@ -0,0 +1,78 @@
using MediatR;
using EnvelopeGenerator.Application.Common.Query;
using EnvelopeGenerator.Application.Common.Dto;
using AutoMapper;
using DigitalData.Core.Abstraction.Application.Repository;
using EnvelopeGenerator.Domain.Entities;
using Microsoft.EntityFrameworkCore;
using DigitalData.Core.Exceptions;
namespace EnvelopeGenerator.Application.Envelopes.Queries;
/// <summary>
/// Repräsentiert eine Abfrage für einen einzelnen Umschlag.
/// </summary>
public record ReadSingleEnvelopeQuery : EnvelopeQueryBase, IRequest<EnvelopeDto>
{
/// <summary>
/// Optionaler Benutzerfilter; wenn gesetzt, werden nur Umschläge des Benutzers geladen.
/// </summary>
public int? UserId { get; init; }
/// <summary>
/// Setzt den Benutzerkontext für die Abfrage.
/// </summary>
public ReadSingleEnvelopeQuery Authorize(int userId) => this with { UserId = userId };
}
/// <summary>
/// Verarbeitet <see cref="ReadSingleEnvelopeQuery"/> und liefert ein einzelnes <see cref="EnvelopeDto"/>-Ergebnis.
/// </summary>
public class ReadSingleEnvelopeQueryHandler : IRequestHandler<ReadSingleEnvelopeQuery, EnvelopeDto>
{
private readonly IRepository<Envelope> _repository;
private readonly IMapper _mapper;
/// <summary>
///
/// </summary>
/// <param name="repository"></param>
/// <param name="mapper"></param>
public ReadSingleEnvelopeQueryHandler(IRepository<Envelope> repository, IMapper mapper)
{
_repository = repository;
_mapper = mapper;
}
/// <summary>
///
/// </summary>
/// <param name="request"></param>
/// <param name="cancel"></param>
/// <returns></returns>
public async Task<EnvelopeDto> Handle(ReadSingleEnvelopeQuery request, CancellationToken cancel)
{
var query = _repository.Query;
if (request.UserId is int userId)
query = query.Where(e => e.UserId == userId);
if (request.Id is int id)
query = query.Where(e => e.Id == id);
if (request.Uuid is string uuid)
query = query.Where(e => e.Uuid == uuid);
var envelopes = await query
.Include(e => e.Documents)
.Take(2)
.ToListAsync(cancel);
if (envelopes.Count > 1)
throw new BadRequestException($"Multiple envelopes found for the given criteria: Id={request.Id}, Uuid={request.Uuid}, UserId={request.UserId}");
return envelopes.SingleOrDefault() is Envelope envelope
? _mapper.Map<EnvelopeDto>(envelope)
: throw new NotFoundException($"Envelope with Id={request.Id}, Uuid={request.Uuid} not found");
}
}

View File

@@ -0,0 +1,92 @@
using DigitalData.Core.Abstraction.Application.Repository;
using DigitalData.Core.Exceptions;
using EnvelopeGenerator.Domain.Entities;
using MediatR;
using Microsoft.EntityFrameworkCore;
namespace EnvelopeGenerator.Application.ThirdPartyModules.Queries;
/// <summary>
/// Query to read the license text of a third-party module.
/// Either <see cref="Id"/> or <see cref="Name"/> must be provided, but not both.
/// </summary>
public record ReadThirdPartyModuleLicenseQuery : IRequest<string>
{
/// <summary>
/// The unique identifier of the third-party module (optional).
/// </summary>
public int? Id { get; init; }
/// <summary>
/// The name of the third-party module (optional).
/// </summary>
public string? Name { get; init; }
/// <summary>
/// Whether to filter only active modules. Defaults to <c>true</c>.
/// </summary>
public bool Active { get; init; } = true;
}
/// <summary>
/// Handles <see cref="ReadThirdPartyModuleLicenseQuery"/> and returns the license text of a third-party module.
/// </summary>
public class ReadThirdPartyModuleLicenseQueryHandler : IRequestHandler<ReadThirdPartyModuleLicenseQuery, string>
{
private readonly IRepository<ThirdPartyModule> _repository;
/// <summary>
/// Initializes a new instance of the <see cref="ReadThirdPartyModuleLicenseQueryHandler"/> class.
/// </summary>
/// <param name="repository">The repository for accessing third-party modules.</param>
public ReadThirdPartyModuleLicenseQueryHandler(IRepository<ThirdPartyModule> repository)
{
_repository = repository;
}
/// <summary>
/// Handles the query by filtering on Id or Name and returning the license text.
/// </summary>
/// <param name="request">The query parameters.</param>
/// <param name="cancel">A cancellation token.</param>
/// <returns>The license text of the matching third-party module.</returns>
/// <exception cref="BadRequestException">
/// Thrown when neither Id nor Name is provided, or when both are provided.
/// </exception>
/// <exception cref="InvalidOperationException">
/// Thrown when multiple modules match the given criteria, indicating a data integrity issue.
/// </exception>
/// <exception cref="NotFoundException">
/// Thrown when no module matches the given criteria.
/// </exception>
public async Task<string> Handle(ReadThirdPartyModuleLicenseQuery request, CancellationToken cancel)
{
if (request.Id is null && request.Name is null)
throw new BadRequestException("Either Id or Name must be provided.");
if (request.Id is not null && request.Name is not null)
throw new BadRequestException("Only one of Id or Name must be provided, not both.");
var query = _repository.Query
.Where(m => m.Active == request.Active);
if (request.Id is int id)
query = query.Where(m => m.Id == id);
if (request.Name is string name)
query = query.Where(m => m.Name == name);
var modules = await query
.Take(2)
.ToListAsync(cancel);
if (modules.Count > 1)
throw new InvalidOperationException(
$"Data integrity violation: multiple third-party modules found for the given criteria (Id={request.Id}, Name={request.Name}, Active={request.Active}).");
return modules.SingleOrDefault() is ThirdPartyModule module
? module.License
: throw new NotFoundException(
$"Third-party module not found for the given criteria (Id={request.Id}, Name={request.Name}, Active={request.Active}).");
}
}

View File

@@ -140,7 +140,9 @@ namespace EnvelopeGenerator.Domain.Entities
= false;
#endif
#if NETFRAMEWORK
[NotMapped]
#endif
[Column("DOC_RESULT")]
public byte[]
#if nullable
@@ -154,8 +156,7 @@ namespace EnvelopeGenerator.Domain.Entities
#if nullable
?
#endif
Type
{ get; set; }
Type { get; set; }
#if NETFRAMEWORK
[NotMapped]
@@ -169,22 +170,26 @@ namespace EnvelopeGenerator.Domain.Entities
#if nullable
?
#endif
Documents
{ get; set; }
Documents { get; set; }
[NotMapped]
public Document
#if nullable
?
#endif
DefaultDocument => Documents?.FirstOrDefault();
public List<History>
#if nullable
?
#endif
Histories
{ get; set; }
Histories { get; set; }
public List<EnvelopeReceiver>
#if nullable
?
#endif
EnvelopeReceivers
{ get; set; }
EnvelopeReceivers { get; set; }
//#if NETFRAMEWORK
/// <summary>

View File

@@ -0,0 +1,36 @@
using System;
using System.ComponentModel.DataAnnotations;
using System.ComponentModel.DataAnnotations.Schema;
namespace EnvelopeGenerator.Domain.Entities
{
[Table("VWSIG_ENVELOPE_REPORT", Schema = "dbo")]
public class EnvelopeReport
{
[Column("ENVELOPE_ID", TypeName = "int")]
[Required]
public int EnvelopeId { get; set; }
[Column("HEAD_UUID", TypeName = "nvarchar(36)")]
[Required]
public string HeadUuid { get; set; }
[Column("HEAD_TITLE", TypeName = "nvarchar(128)")]
public string HeadTitle { get; set; }
[Column("HEAD_MESSAGE", TypeName = "nvarchar(max)")]
[Required]
public string HeadMessage { get; set; }
[Column("POS_STATUS", TypeName = "int")]
[Required]
public int PosStatus { get; set; }
[Column("POS_WHEN", TypeName = "datetime")]
public DateTime? PosWhen { get; set; }
[Column("POS_WHO", TypeName = "nvarchar(128)")]
[Required]
public string PosWho { get; set; }
}
}

View File

@@ -0,0 +1,61 @@
using System.ComponentModel.DataAnnotations;
using System.ComponentModel.DataAnnotations.Schema;
using EnvelopeGenerator.Domain.Interfaces.Auditing;
#if NETFRAMEWORK
using System;
#endif
namespace EnvelopeGenerator.Domain.Entities
{
[Table("TBDD_3RD_PARTY_MODULES", Schema = "dbo")]
public class ThirdPartyModule : IHasChangedWhen, IHasChangedWho
{
[Key]
[DatabaseGenerated(DatabaseGeneratedOption.Identity)]
[Column("GUID")]
public int Id { get; set; }
[Required]
[Column("ACTIVE", TypeName = "bit")]
public bool Active { get; set; }
[Required]
[Column("NAME", TypeName = "varchar(50)")]
public string Name { get; set; }
[Column("DESCRIPTION", TypeName = "varchar(500)")]
public string
#if nullable
?
#endif
Description { get; set; }
[Required]
[Column("LICENSE", TypeName = "varchar(max)")]
public string License { get; set; }
[Required]
[Column("VERSION", TypeName = "varchar(20)")]
public string Version { get; set; }
[Column("ADDED_WHO", TypeName = "varchar(50)")]
public string
#if nullable
?
#endif
AddedWho { get; set; }
[Column("ADDED_WHEN", TypeName = "datetime")]
public DateTime? AddedWhen { get; set; }
[Column("CHANGED_WHO", TypeName = "varchar(50)")]
public string
#if nullable
?
#endif
ChangedWho { get; set; }
[Column("CHANGED_WHEN", TypeName = "datetime")]
public DateTime? ChangedWhen { get; set; }
}
}

View File

@@ -79,6 +79,10 @@ public abstract class EGDbContextBase : DbContext
public DbSet<ClientUser> ClientUsers { get; set; }
public DbSet<EnvelopeReport> EnvelopeReports { get; set; }
public DbSet<ThirdPartyModule> ThirdPartyModules { get; set; }
private readonly DbTriggerParams _triggers;
private readonly ILogger
@@ -200,6 +204,10 @@ public abstract class EGDbContextBase : DbContext
.HasForeignKey(annot => annot.ElementId);
#endregion
#region EnvelopeReport
modelBuilder.Entity<EnvelopeReport>().HasNoKey();
#endregion
#region Trigger
// Configure entities to handle database triggers
void AddTrigger<T>() where T : class => _triggers

View File

@@ -0,0 +1,21 @@
using EnvelopeGenerator.Application.Envelopes.Queries;
using MediatR;
using Microsoft.AspNetCore.Mvc;
namespace EnvelopeGenerator.ServiceHost.Controllers;
[Route("api/[controller]")]
[ApiController]
public class DocResultController(IMediator mediator) : ControllerBase
{
[HttpGet]
public async Task<IActionResult> GetAsync([FromQuery] ReadSingleEnvelopeDocResultQuery query, [FromQuery] bool download = false, CancellationToken cancel = default)
{
var bytes = await mediator.Send(query, cancel);
if (download)
return File(bytes, "application/pdf", $"envelope_{query.Envelope.Uuid}.pdf");
return File(bytes, "application/pdf");
}
}

View File

@@ -0,0 +1,29 @@
using EnvelopeGenerator.Application.Envelopes.Queries;
using EnvelopeGenerator.ServiceHost.Jobs;
using MediatR;
using Microsoft.AspNetCore.Mvc;
namespace EnvelopeGenerator.ServiceHost.Controllers;
/// <summary>
///
/// </summary>
/// <param name="mediator"></param>
/// <param name="job"></param>
[Route("api/[controller]")]
[ApiController]
public class FinalizeDocumentController(IMediator mediator, FinalizeDocumentJob job) : ControllerBase
{
[HttpGet]
public async Task<IActionResult> FinalizeEnvelopeDocument([FromQuery] ReadSingleEnvelopeQuery query, [FromQuery] bool forceRegenerate = false, CancellationToken cancel = default)
{
var envelope = await mediator.Send(query, cancel);
// TODO: migrate forceRegenerate input to FinalizeDocumentJob as property and remove this check from controller
if (envelope.DocResult is null || forceRegenerate)
await job.ExecuteAsync(envelope, cancel);
var docResult = await mediator.Send(new ReadSingleEnvelopeDocResultQuery() { Envelope = query }, cancel);
return File(docResult, "application/pdf", $"envelope_{query.Uuid}.pdf");
}
}

View File

@@ -0,0 +1,21 @@
using EnvelopeGenerator.ServiceHost.Jobs;
using Microsoft.AspNetCore.Mvc;
namespace EnvelopeGenerator.ServiceHost.Controllers;
[Route("api/[controller]")]
[ApiController]
public class WorkerController(JobStateManager jobStateManager) : ControllerBase
{
private readonly JobStateManager _jobStateManager = jobStateManager;
[HttpGet(nameof(FinalizeDocumentJob))]
public IActionResult GetStateOfFinalizeDocumentJob() => Ok(_jobStateManager.GetState<FinalizeDocumentJob>());
[HttpPost(nameof(FinalizeDocumentJob))]
public IActionResult SetStateOfFinalizeDocumentJob([FromQuery] State state)
{
_jobStateManager.SetState<FinalizeDocumentJob>(state);
return Ok();
}
}

View File

@@ -1,12 +1,14 @@
<Project Sdk="Microsoft.NET.Sdk.Web">
<Project Sdk="Microsoft.NET.Sdk.Web">
<PropertyGroup>
<TargetFramework>net8.0</TargetFramework>
<TargetFramework>net8.0-windows</TargetFramework>
<UseWindowsForms>true</UseWindowsForms>
<Nullable>enable</Nullable>
<ImplicitUsings>enable</ImplicitUsings>
</PropertyGroup>
<ItemGroup>
<PackageReference Include="DigitalData.Core.API" Version="2.2.1" />
<PackageReference Include="Swashbuckle.AspNetCore" Version="6.6.2" />
<PackageReference Include="GdPicture" Version="14.3.3" />
<PackageReference Include="Microsoft.Data.SqlClient" Version="6.1.4" />
@@ -17,16 +19,28 @@
<PackageReference Include="System.Collections.Immutable" Version="8.0.0" />
<PackageReference Include="System.Drawing.Common" Version="8.0.16" />
<PackageReference Include="Microsoft.Extensions.Options" Version="8.0.2" />
<PackageReference Include="DevExpress.Reporting.Core" Version="24.2.*" />
<PackageReference Include="Microsoft.Extensions.Caching.SqlServer" Version="8.0.17" />
<PackageReference Include="Microsoft.Extensions.Hosting.WindowsServices" Version="8.0.1" />
</ItemGroup>
<ItemGroup>
<ProjectReference Include="..\EnvelopeGenerator.Application\EnvelopeGenerator.Application.csproj" />
<ProjectReference Include="..\EnvelopeGenerator.Domain\EnvelopeGenerator.Domain.csproj" />
<ProjectReference Include="..\EnvelopeGenerator.Infrastructure\EnvelopeGenerator.Infrastructure.csproj" />
<ProjectReference Include="..\EnvelopeGenerator.PdfEditor\EnvelopeGenerator.PdfEditor.csproj" />
</ItemGroup>
<ItemGroup>
<Folder Include="Controllers\" />
<Compile Update="Jobs\FinalizeDocument\rptEnvelopeHistory.cs">
<SubType>Component</SubType>
</Compile>
<Compile Update="Jobs\FinalizeDocument\rptEnvelopeHistory.Designer.cs">
<DependentUpon>rptEnvelopeHistory.cs</DependentUpon>
</Compile>
<EmbeddedResource Update="Jobs\FinalizeDocument\rptEnvelopeHistory.resx">
<DependentUpon>rptEnvelopeHistory.cs</DependentUpon>
</EmbeddedResource>
</ItemGroup>
</Project>

View File

@@ -1,4 +1,3 @@
using DigitalData.Modules.Database;
using EnvelopeGenerator.ServiceHost.Jobs;
using EnvelopeGenerator.ServiceHost.Jobs.FinalizeDocument;
using GdPicture14;
@@ -11,26 +10,23 @@ public static class DependencyInjection
[Obsolete("Check obsoleted services")]
public static IServiceCollection AddFinalizeDocumentJob(this IServiceCollection services, IConfiguration configuration)
{
services.Configure<WorkerOptions>(configuration.GetSection(nameof(WorkerOptions)));
services.AddSingleton<FinalizeDocumentJob>();
services.Configure<WorkerOptions>(configuration.GetSection("Worker"));
services.AddSingleton(provider =>
{
var options = provider.GetRequiredService<IOptions<WorkerOptions>>().Value;
var manager = new JobStateManager(options.InitialJobState);
return manager;
});
services.AddScoped<FinalizeDocumentJob>();
services.AddScoped<ActionService>();
services.AddSingleton<TempFiles>();
services.AddScoped<PDFBurner>();
services.AddScoped<PDFMerger>();
services.AddScoped<ReportModel>();
services.AddSingleton<State>();
services.AddScoped<MSSQLServer>();
services.AddScoped<ReportCreator>();
//TODO: Check lifetime of services. They might be singleton or scoped.
services.AddTransient<GdViewer>();
// Add LicenseManager
services.AddTransient(provider =>
{
var options = provider.GetRequiredService<IOptions<WorkerOptions>>().Value;
var licenseManager = new LicenseManager();
licenseManager.RegisterKEY(options.GdPictureLicenseKey);
return licenseManager;
});
services.AddSingleton<LicenseManagerFactory>();
services.AddTransient<AnnotationManager>();
return services;

View File

@@ -1,30 +1,36 @@
using DigitalData.Core.Abstraction.Application.Repository;
using EnvelopeGenerator.Application.Common.Dto;
using EnvelopeGenerator.Application.Common.Dto.Receiver;
using EnvelopeGenerator.Domain.Entities;
namespace EnvelopeGenerator.ServiceHost.Jobs;
/// <summary>
/// migrate from EnvelopeGenerator.CommonServices.Services.ActionService
/// </summary>
[Obsolete("This is a placeholder service added by copilot. Migrate the actual logic from CommonServices.Jobs")]
public class ActionService
public class ActionService(IRepository<History> histRepo)
{
[Obsolete("This is a placeholder service added by copilot. Migrate the actual logic from CommonServices.Jobs")]
public bool CreateReport(Envelope envelope)
public bool CreateReport(EnvelopeDto envelope, CancellationToken cancel = default)
{
throw new NotImplementedException();
}
[Obsolete("This is a placeholder service added by copilot. Migrate the actual logic from CommonServices.Jobs")]
public bool FinalizeEnvelope(Envelope envelope)
public bool FinalizeEnvelope(EnvelopeDto envelope, CancellationToken cancel = default)
{
throw new NotImplementedException();
}
[Obsolete("This is a placeholder service added by copilot. Migrate the actual logic from CommonServices.Jobs")]
public bool CompleteEnvelope(Envelope envelope)
public bool CompleteEnvelope(EnvelopeDto envelope, CancellationToken cancel = default)
{
throw new NotImplementedException();
}
[Obsolete("This is a placeholder service added by copilot. Migrate the actual logic from CommonServices.Jobs")]
public bool CompleteEnvelope(Envelope envelope, Receiver receiver)
public bool CompleteEnvelope(EnvelopeDto envelope, ReceiverDto receiver, CancellationToken cancel = default)
{
throw new NotImplementedException();
}

View File

@@ -4,6 +4,7 @@ using EnvelopeGenerator.Domain.Entities;
using EnvelopeGenerator.Infrastructure;
using EnvelopeGenerator.PdfEditor;
using EnvelopeGenerator.ServiceHost.Exceptions;
using EnvelopeGenerator.ServiceHost.Jobs;
using GdPicture14;
using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.Options;
@@ -11,16 +12,7 @@ using Newtonsoft.Json;
namespace EnvelopeGenerator.ServiceHost.Jobs.FinalizeDocument;
//TODO: check if licence manager is needed as a dependency to
/// <summary>
///
/// </summary>
/// <param name="workerOptions"></param>
/// <param name="context2"></param>
/// <param name="logger2"></param>
/// <param name="licenseManager"></param>
/// <param name="annotationManager2"></param>
public class PDFBurner(IOptions<WorkerOptions> workerOptions, EGDbContext context, ILogger<PDFBurner> logger, LicenseManager licenseManager, AnnotationManager manager)
public class PDFBurner(IOptions<WorkerOptions> workerOptions, EGDbContext context, ILogger<PDFBurner> logger, LicenseManagerFactory licenseManagerFactory, AnnotationManager manager)
{
private readonly WorkerOptions.PDFBurnerOptions _options = workerOptions.Value.PdfBurner;

View File

@@ -1,4 +1,5 @@
using EnvelopeGenerator.ServiceHost.Exceptions;
using EnvelopeGenerator.ServiceHost.Jobs;
using GdPicture14;
using Microsoft.Extensions.Options;
@@ -7,16 +8,16 @@ namespace EnvelopeGenerator.ServiceHost.Jobs.FinalizeDocument;
public class PDFMerger
{
private readonly AnnotationManager _manager;
private readonly LicenseManager _licenseManager;
private readonly LicenseManagerFactory _licenseManagerFactory;
private const bool AllowRasterization = true;
private const bool AllowVectorization = true;
private readonly PdfConversionConformance _pdfaConformanceLevel = PdfConversionConformance.PDF_A_1b;
public PDFMerger(LicenseManager licenseManager, AnnotationManager annotationManager)
public PDFMerger(LicenseManagerFactory licenseManagerFactory, AnnotationManager annotationManager)
{
_licenseManager = licenseManager;
_licenseManagerFactory = licenseManagerFactory;
_manager = annotationManager;
}

View File

@@ -1,102 +1,30 @@
using System.Data;
using EnvelopeGenerator.Domain.Constants;
using DevExpress.Xpo;
using DigitalData.Core.Abstraction.Application.Repository;
using EnvelopeGenerator.Application.Common.Dto;
using EnvelopeGenerator.Domain.Entities;
using EnvelopeGenerator.ServiceHost.Exceptions;
using EnvelopeGenerator.ServiceHost.Extensions;
namespace EnvelopeGenerator.ServiceHost.Jobs.FinalizeDocument;
[Obsolete("Instead of ReportModel create and use EnvelopeReport mediator queries")]
public class ReportCreator(ReportModel ReportModel, ILogger<ReportCreator> Logger)
public class ReportCreator(IRepository<EnvelopeReport> reportRepo)
{
[Obsolete("Solve the spaghetti...")]
private Envelope? _envelope;
[Obsolete("Instead of ReportModel create and use EnvelopeReport mediator queries and solve this spaghetti...")]
public byte[] CreateReport(Envelope envelope)
public async Task<byte[]> CreateReportAsync(EnvelopeDto envelope, CancellationToken cancel = default)
{
try
{
Logger.LogDebug("Loading report data..");
var table = ReportModel.List(envelope.Id);
var items = GetReportSource(table);
var reports = await reportRepo.Where(r => r.EnvelopeId == envelope.Id).ToListAsync(cancel);
_envelope = envelope;
if (reports.Count == 0)
throw new CreateReportException("Could not prepare report data! No report data found!");
if (items.Count == 0)
{
throw new CreateReportException("No report data found!");
}
Logger.LogDebug("Creating report with [{count}] items..", items.Count);
var buffer = DoCreateReport(items);
Logger.LogDebug("Report created!");
return buffer;
}
catch (Exception ex)
{
Logger.LogError(ex);
throw new CreateReportException("Could not prepare report data!", ex);
}
}
private List<ReportItem> GetReportSource(DataTable dataTable)
{
Logger.LogDebug("Preparing report data");
return dataTable.Rows
.Cast<DataRow>()
.Select(ToReportItem)
var items = reports
.Select(r => new ReportItem(r, envelope))
.OrderByDescending(r => r.ItemDate)
.ToList();
}
private byte[] DoCreateReport(List<ReportItem> reportItems)
{
var items = reportItems.Select(MergeEnvelope).ToList();
var source = new ReportSource { Items = items };
var report = new rptEnvelopeHistory { DataSource = source, DataMember = "Items" };
Logger.LogDebug("Creating report in memory..");
report.CreateDocument();
Logger.LogDebug("Exporting report to stream..");
using var stream = new MemoryStream();
report.ExportToPdf(stream);
Logger.LogDebug("Writing report to buffer..");
return stream.ToArray();
}
[Obsolete("Solve this spaghetti...")]
private ReportItem MergeEnvelope(ReportItem item)
{
if (item.Envelope is null)
{
item.Envelope = _envelope;
}
return item;
}
private ReportItem ToReportItem(DataRow row)
{
try
{
return new ReportItem
{
EnvelopeId = row.ItemEx("ENVELOPE_ID", 0),
EnvelopeTitle = row.ItemEx("HEAD_TITLE", string.Empty),
EnvelopeSubject = row.ItemEx("HEAD_SUBJECT", string.Empty),
ItemDate = row.ItemEx("POS_WHEN", DateTime.MinValue),
ItemStatus = (EnvelopeStatus)row.ItemEx("POS_STATUS", 0),
ItemUserReference = row.ItemEx("POS_WHO", string.Empty)
};
}
catch (Exception ex)
{
Logger.LogError(ex);
throw new CreateReportException("Could not read data from database!", ex);
}
}
}

View File

@@ -1,3 +1,4 @@
using EnvelopeGenerator.Application.Common.Dto;
using EnvelopeGenerator.Domain.Constants;
using EnvelopeGenerator.Domain.Entities;
@@ -5,15 +6,32 @@ namespace EnvelopeGenerator.ServiceHost.Jobs.FinalizeDocument;
public class ReportItem
{
public Envelope? Envelope { get; set; }
public int EnvelopeId { get; set; }
public ReportItem() { }
public ReportItem(EnvelopeReport report, EnvelopeDto envelope)
{
CreatorFullName = envelope.User is not null
? $"{envelope.User.Prename} {envelope.User.Name}".Trim()
: string.Empty;
CreatorEmailAddress = envelope.User?.Email ?? string.Empty;
EnvelopeTitle = report.HeadTitle ?? string.Empty;
EnvelopeUuid = report.HeadUuid ?? string.Empty;
EnvelopeCertificationType = envelope.CertificationType is int certType ? ((CertificationType)certType).ToString() : "null";
ItemStatus = (EnvelopeStatus)report.PosStatus;
ItemUserReference = report.PosWho ?? string.Empty;
ItemDate = report.PosWhen ?? DateTime.MinValue;
}
// Header fields (from Envelope)
public string CreatorFullName { get; set; } = string.Empty;
public string CreatorEmailAddress { get; set; } = string.Empty;
public string EnvelopeTitle { get; set; } = string.Empty;
public string EnvelopeSubject { get; set; } = string.Empty;
public string EnvelopeUuid { get; set; } = string.Empty;
public string EnvelopeCertificationType { get; set; } = string.Empty;
// Detail fields (from EnvelopeReport)
public EnvelopeStatus ItemStatus { get; set; }
public string ItemStatusTranslated => ItemStatus.ToString();
public string ItemUserReference { get; set; } = string.Empty;
public DateTime ItemDate { get; set; }
}

View File

@@ -0,0 +1,736 @@
using System.ComponentModel;
using System.Drawing;
using System.Drawing.Printing;
using DevExpress.DataAccess.ObjectBinding;
using DevExpress.XtraPrinting;
using DevExpress.XtraReports.UI;
namespace EnvelopeGenerator.ServiceHost.Jobs.FinalizeDocument;
public partial class rptEnvelopeHistory : XtraReport
{
/// <summary>
/// Required designer variable.
/// </summary>
private IContainer components = null;
/// <summary>
/// Clean up any resources being used.
/// </summary>
protected override void Dispose(bool disposing)
{
if (disposing && components != null)
{
components.Dispose();
}
base.Dispose(disposing);
}
#region Designer generated code
/// <summary>
/// Required method for Designer support - do not modify
/// the contents of this method with the code editor.
/// </summary>
private void InitializeComponent()
{
this.components = new Container();
var resources = new ComponentResourceManager(typeof(rptEnvelopeHistory));
this.TopMargin = new TopMarginBand();
this.BottomMargin = new BottomMarginBand();
this.XrLabel1 = new XRLabel();
this.pageInfo1 = new XRPageInfo();
this.pageInfo2 = new XRPageInfo();
this.ReportHeader = new ReportHeaderBand();
this.label1 = new XRLabel();
this.XrTable3 = new XRTable();
this.XrTableRow8 = new XRTableRow();
this.XrTableCell13 = new XRTableCell();
this.XrTableCell15 = new XRTableCell();
this.XrTableRow9 = new XRTableRow();
this.XrTableCell14 = new XRTableCell();
this.XrTableCell17 = new XRTableCell();
this.XrTableCell16 = new XRTableCell();
this.XrTableCell18 = new XRTableCell();
this.XrTableRow10 = new XRTableRow();
this.XrTableCell19 = new XRTableCell();
this.XrTableCell20 = new XRTableCell();
this.XrTableCell21 = new XRTableCell();
this.XrTableCell22 = new XRTableCell();
this.XrTableRow11 = new XRTableRow();
this.XrTableCell23 = new XRTableCell();
this.XrTableCell24 = new XRTableCell();
this.XrTableCell25 = new XRTableCell();
this.XrTableCell26 = new XRTableCell();
this.GroupHeader1 = new GroupHeaderBand();
this.table1 = new XRTable();
this.tableRow1 = new XRTableRow();
this.tableCell1 = new XRTableCell();
this.tableCell2 = new XRTableCell();
this.tableCell3 = new XRTableCell();
this.Detail = new DetailBand();
this.table2 = new XRTable();
this.tableRow2 = new XRTableRow();
this.tableCell4 = new XRTableCell();
this.tableCell5 = new XRTableCell();
this.tableCell6 = new XRTableCell();
this.Title = new XRControlStyle();
this.DetailCaption1 = new XRControlStyle();
this.DetailData1 = new XRControlStyle();
this.DetailData3_Odd = new XRControlStyle();
this.PageInfo = new XRControlStyle();
this.ObjectDataSource1 = new ObjectDataSource(this.components);
((ISupportInitialize)this.XrTable3).BeginInit();
((ISupportInitialize)this.table1).BeginInit();
((ISupportInitialize)this.table2).BeginInit();
((ISupportInitialize)this.ObjectDataSource1).BeginInit();
((ISupportInitialize)this).BeginInit();
//
// TopMargin
//
this.TopMargin.Dpi = 254F;
this.TopMargin.HeightF = 190.6042F;
this.TopMargin.Name = "TopMargin";
//
// BottomMargin
//
this.BottomMargin.Controls.AddRange(new XRControl[] { this.XrLabel1, this.pageInfo1, this.pageInfo2 });
this.BottomMargin.Dpi = 254F;
this.BottomMargin.Name = "BottomMargin";
//
// XrLabel1
//
this.XrLabel1.BorderColor = Color.FromArgb(165, 36, 49);
this.XrLabel1.Borders = BorderSide.Top;
this.XrLabel1.Dpi = 254F;
this.XrLabel1.Font = new Font("Arial", 8.25F, FontStyle.Bold);
this.XrLabel1.LocationFloat = new DevExpress.Utils.PointFloat(896.5417F, 0F);
this.XrLabel1.Name = "XrLabel1";
this.XrLabel1.Padding = new PaddingInfo(0, 0, 0, 0, 254F);
this.XrLabel1.SizeF = new SizeF(645.5836F, 58F);
this.XrLabel1.StyleName = "Title";
this.XrLabel1.StylePriority.UseBorderColor = false;
this.XrLabel1.StylePriority.UseBorders = false;
this.XrLabel1.StylePriority.UseFont = false;
this.XrLabel1.StylePriority.UsePadding = false;
this.XrLabel1.Text = "Erstellt mit SignFlow";
//
// pageInfo1
//
this.pageInfo1.BorderColor = Color.FromArgb(165, 36, 49);
this.pageInfo1.Borders = BorderSide.Top;
this.pageInfo1.Dpi = 254F;
this.pageInfo1.LocationFloat = new DevExpress.Utils.PointFloat(0F, 0F);
this.pageInfo1.Name = "pageInfo1";
this.pageInfo1.PageInfo = DevExpress.XtraPrinting.PageInfo.DateTime;
this.pageInfo1.SizeF = new SizeF(896.5417F, 58F);
this.pageInfo1.StyleName = "PageInfo";
this.pageInfo1.StylePriority.UseBorderColor = false;
this.pageInfo1.StylePriority.UseBorders = false;
this.pageInfo1.TextFormatString = "{0:dddd, d. MMMM yyyy HH:mm}";
//
// pageInfo2
//
this.pageInfo2.BorderColor = Color.FromArgb(165, 36, 49);
this.pageInfo2.Borders = BorderSide.Top;
this.pageInfo2.Dpi = 254F;
this.pageInfo2.LocationFloat = new DevExpress.Utils.PointFloat(1542.125F, 0F);
this.pageInfo2.Name = "pageInfo2";
this.pageInfo2.SizeF = new SizeF(357.875F, 58F);
this.pageInfo2.StyleName = "PageInfo";
this.pageInfo2.StylePriority.UseBorderColor = false;
this.pageInfo2.StylePriority.UseBorders = false;
this.pageInfo2.TextAlignment = TextAlignment.TopRight;
this.pageInfo2.TextFormatString = "Seite {0} von {1}";
//
// ReportHeader
//
this.ReportHeader.Controls.AddRange(new XRControl[] { this.label1, this.XrTable3 });
this.ReportHeader.Dpi = 254F;
this.ReportHeader.HeightF = 406.0843F;
this.ReportHeader.Name = "ReportHeader";
//
// label1
//
this.label1.BackColor = Color.FromArgb(224, 224, 224);
this.label1.BorderColor = Color.FromArgb(165, 36, 49);
this.label1.Borders = BorderSide.Bottom;
this.label1.BorderWidth = 2F;
this.label1.Dpi = 254F;
this.label1.Font = new Font("Segoe UI", 14.25F, FontStyle.Bold, GraphicsUnit.Point, 0);
this.label1.ForeColor = Color.Black;
this.label1.LocationFloat = new DevExpress.Utils.PointFloat(0.0002422333F, 0F);
this.label1.Name = "label1";
this.label1.Padding = new PaddingInfo(10, 10, 5, 5, 254F);
this.label1.SizeF = new SizeF(1900F, 77.32857F);
this.label1.StyleName = "Title";
this.label1.StylePriority.UseBackColor = false;
this.label1.StylePriority.UseBorderColor = false;
this.label1.StylePriority.UseBorders = false;
this.label1.StylePriority.UseBorderWidth = false;
this.label1.StylePriority.UseFont = false;
this.label1.StylePriority.UseForeColor = false;
this.label1.StylePriority.UsePadding = false;
this.label1.Text = "Signierungszertifikat";
//
// XrTable3
//
this.XrTable3.Dpi = 254F;
this.XrTable3.LocationFloat = new DevExpress.Utils.PointFloat(0.0002422333F, 96.60422F);
this.XrTable3.Name = "XrTable3";
this.XrTable3.OddStyleName = "DetailData3_Odd";
this.XrTable3.Rows.AddRange(new XRTableRow[] { this.XrTableRow8, this.XrTableRow9, this.XrTableRow10, this.XrTableRow11 });
this.XrTable3.SizeF = new SizeF(1900F, 284.4801F);
//
// XrTableRow8
//
this.XrTableRow8.Cells.AddRange(new XRTableCell[] { this.XrTableCell13, this.XrTableCell15 });
this.XrTableRow8.Dpi = 254F;
this.XrTableRow8.Name = "XrTableRow8";
this.XrTableRow8.Weight = 1D;
//
// XrTableCell13
//
this.XrTableCell13.BackColor = Color.FromArgb(224, 224, 224);
this.XrTableCell13.BorderColor = Color.FromArgb(165, 36, 49);
this.XrTableCell13.Borders = BorderSide.Bottom;
this.XrTableCell13.BorderWidth = 1F;
this.XrTableCell13.Dpi = 254F;
this.XrTableCell13.ForeColor = Color.Black;
this.XrTableCell13.Name = "XrTableCell13";
this.XrTableCell13.StyleName = "DetailCaption1";
this.XrTableCell13.StylePriority.UseBackColor = false;
this.XrTableCell13.StylePriority.UseBorderColor = false;
this.XrTableCell13.StylePriority.UseBorders = false;
this.XrTableCell13.StylePriority.UseBorderWidth = false;
this.XrTableCell13.StylePriority.UseForeColor = false;
this.XrTableCell13.Text = "Ersteller";
this.XrTableCell13.Weight = 0.38139956730411484D;
//
// XrTableCell15
//
this.XrTableCell15.BackColor = Color.FromArgb(224, 224, 224);
this.XrTableCell15.BorderColor = Color.FromArgb(165, 36, 49);
this.XrTableCell15.Borders = BorderSide.Bottom;
this.XrTableCell15.BorderWidth = 1F;
this.XrTableCell15.Dpi = 254F;
this.XrTableCell15.ForeColor = Color.Black;
this.XrTableCell15.Name = "XrTableCell15";
this.XrTableCell15.StyleName = "DetailCaption1";
this.XrTableCell15.StylePriority.UseBackColor = false;
this.XrTableCell15.StylePriority.UseBorderColor = false;
this.XrTableCell15.StylePriority.UseBorders = false;
this.XrTableCell15.StylePriority.UseBorderWidth = false;
this.XrTableCell15.StylePriority.UseForeColor = false;
this.XrTableCell15.Text = "Umschlag";
this.XrTableCell15.Weight = 0.49859081604996847D;
//
// XrTableRow9
//
this.XrTableRow9.Cells.AddRange(new XRTableCell[] { this.XrTableCell14, this.XrTableCell17, this.XrTableCell16, this.XrTableCell18 });
this.XrTableRow9.Dpi = 254F;
this.XrTableRow9.Name = "XrTableRow9";
this.XrTableRow9.Weight = 1D;
//
// XrTableCell14
//
this.XrTableCell14.BackColor = Color.White;
this.XrTableCell14.BorderColor = Color.Empty;
this.XrTableCell14.Borders = BorderSide.None;
this.XrTableCell14.Dpi = 254F;
this.XrTableCell14.Font = new Font("Arial", 8.25F, FontStyle.Bold, GraphicsUnit.Point, 0);
this.XrTableCell14.ForeColor = Color.Black;
this.XrTableCell14.Multiline = true;
this.XrTableCell14.Name = "XrTableCell14";
this.XrTableCell14.StyleName = "DetailCaption1";
this.XrTableCell14.StylePriority.UseBackColor = false;
this.XrTableCell14.StylePriority.UseBorderColor = false;
this.XrTableCell14.StylePriority.UseBorders = false;
this.XrTableCell14.StylePriority.UseFont = false;
this.XrTableCell14.StylePriority.UseForeColor = false;
this.XrTableCell14.Text = "Name";
this.XrTableCell14.Weight = 0.11578820509129036D;
//
// XrTableCell17
//
this.XrTableCell17.BackColor = Color.White;
this.XrTableCell17.BorderColor = Color.Empty;
this.XrTableCell17.Borders = BorderSide.None;
this.XrTableCell17.Dpi = 254F;
this.XrTableCell17.ExpressionBindings.AddRange(new ExpressionBinding[] { new ExpressionBinding("BeforePrint", "Text", "[CreatorFullName]") });
this.XrTableCell17.Font = new Font("Arial", 8.25F, FontStyle.Regular, GraphicsUnit.Point, 0);
this.XrTableCell17.ForeColor = Color.Black;
this.XrTableCell17.Multiline = true;
this.XrTableCell17.Name = "XrTableCell17";
this.XrTableCell17.StyleName = "DetailCaption1";
this.XrTableCell17.StylePriority.UseBackColor = false;
this.XrTableCell17.StylePriority.UseBorderColor = false;
this.XrTableCell17.StylePriority.UseBorders = false;
this.XrTableCell17.StylePriority.UseFont = false;
this.XrTableCell17.StylePriority.UseForeColor = false;
this.XrTableCell17.Text = "XrTableCell17";
this.XrTableCell17.Weight = 0.2656113622128245D;
//
// XrTableCell16
//
this.XrTableCell16.BackColor = Color.White;
this.XrTableCell16.BorderColor = Color.Empty;
this.XrTableCell16.Borders = BorderSide.None;
this.XrTableCell16.Dpi = 254F;
this.XrTableCell16.Font = new Font("Arial", 8.25F, FontStyle.Bold, GraphicsUnit.Point, 0);
this.XrTableCell16.ForeColor = Color.Black;
this.XrTableCell16.Multiline = true;
this.XrTableCell16.Name = "XrTableCell16";
this.XrTableCell16.StyleName = "DetailCaption1";
this.XrTableCell16.StylePriority.UseBackColor = false;
this.XrTableCell16.StylePriority.UseBorderColor = false;
this.XrTableCell16.StylePriority.UseBorders = false;
this.XrTableCell16.StylePriority.UseFont = false;
this.XrTableCell16.StylePriority.UseForeColor = false;
this.XrTableCell16.Text = "Titel";
this.XrTableCell16.Weight = 0.11578821158083684D;
//
// XrTableCell18
//
this.XrTableCell18.BackColor = Color.White;
this.XrTableCell18.BorderColor = Color.Empty;
this.XrTableCell18.Borders = BorderSide.None;
this.XrTableCell18.Dpi = 254F;
this.XrTableCell18.ExpressionBindings.AddRange(new ExpressionBinding[] { new ExpressionBinding("BeforePrint", "Text", "[EnvelopeTitle]") });
this.XrTableCell18.Font = new Font("Arial", 8.25F, FontStyle.Regular, GraphicsUnit.Point, 0);
this.XrTableCell18.ForeColor = Color.Black;
this.XrTableCell18.Multiline = true;
this.XrTableCell18.Name = "XrTableCell18";
this.XrTableCell18.StyleName = "DetailCaption1";
this.XrTableCell18.StylePriority.UseBackColor = false;
this.XrTableCell18.StylePriority.UseBorderColor = false;
this.XrTableCell18.StylePriority.UseBorders = false;
this.XrTableCell18.StylePriority.UseFont = false;
this.XrTableCell18.StylePriority.UseForeColor = false;
this.XrTableCell18.Text = "XrTableCell18";
this.XrTableCell18.Weight = 0.38280260446913167D;
//
// XrTableRow10
//
this.XrTableRow10.Cells.AddRange(new XRTableCell[] { this.XrTableCell19, this.XrTableCell20, this.XrTableCell21, this.XrTableCell22 });
this.XrTableRow10.Dpi = 254F;
this.XrTableRow10.Name = "XrTableRow10";
this.XrTableRow10.Weight = 1D;
//
// XrTableCell19
//
this.XrTableCell19.BackColor = Color.White;
this.XrTableCell19.BorderColor = Color.Empty;
this.XrTableCell19.Borders = BorderSide.None;
this.XrTableCell19.Dpi = 254F;
this.XrTableCell19.Font = new Font("Arial", 8.25F, FontStyle.Bold, GraphicsUnit.Point, 0);
this.XrTableCell19.ForeColor = Color.Black;
this.XrTableCell19.Multiline = true;
this.XrTableCell19.Name = "XrTableCell19";
this.XrTableCell19.StyleName = "DetailCaption1";
this.XrTableCell19.StylePriority.UseBackColor = false;
this.XrTableCell19.StylePriority.UseBorderColor = false;
this.XrTableCell19.StylePriority.UseBorders = false;
this.XrTableCell19.StylePriority.UseFont = false;
this.XrTableCell19.StylePriority.UseForeColor = false;
this.XrTableCell19.Text = "EmailAddress";
this.XrTableCell19.Weight = 0.11578820509129036D;
//
// XrTableCell20
//
this.XrTableCell20.BackColor = Color.White;
this.XrTableCell20.BorderColor = Color.Empty;
this.XrTableCell20.Borders = BorderSide.None;
this.XrTableCell20.Dpi = 254F;
this.XrTableCell20.ExpressionBindings.AddRange(new ExpressionBinding[] { new ExpressionBinding("BeforePrint", "Text", "[CreatorEmailAddress]") });
this.XrTableCell20.Font = new Font("Arial", 8.25F, FontStyle.Regular, GraphicsUnit.Point, 0);
this.XrTableCell20.ForeColor = Color.Black;
this.XrTableCell20.Multiline = true;
this.XrTableCell20.Name = "XrTableCell20";
this.XrTableCell20.StyleName = "DetailCaption1";
this.XrTableCell20.StylePriority.UseBackColor = false;
this.XrTableCell20.StylePriority.UseBorderColor = false;
this.XrTableCell20.StylePriority.UseBorders = false;
this.XrTableCell20.StylePriority.UseFont = false;
this.XrTableCell20.StylePriority.UseForeColor = false;
this.XrTableCell20.Text = "XrTableCell20";
this.XrTableCell20.Weight = 0.2656113622128245D;
//
// XrTableCell21
//
this.XrTableCell21.BackColor = Color.White;
this.XrTableCell21.BorderColor = Color.Empty;
this.XrTableCell21.Borders = BorderSide.None;
this.XrTableCell21.Dpi = 254F;
this.XrTableCell21.Font = new Font("Arial", 8.25F, FontStyle.Bold, GraphicsUnit.Point, 0);
this.XrTableCell21.ForeColor = Color.Black;
this.XrTableCell21.Multiline = true;
this.XrTableCell21.Name = "XrTableCell21";
this.XrTableCell21.StyleName = "DetailCaption1";
this.XrTableCell21.StylePriority.UseBackColor = false;
this.XrTableCell21.StylePriority.UseBorderColor = false;
this.XrTableCell21.StylePriority.UseBorders = false;
this.XrTableCell21.StylePriority.UseFont = false;
this.XrTableCell21.StylePriority.UseForeColor = false;
this.XrTableCell21.Text = "Umschlag-ID";
this.XrTableCell21.Weight = 0.11578821158083684D;
//
// XrTableCell22
//
this.XrTableCell22.BackColor = Color.White;
this.XrTableCell22.BorderColor = Color.Empty;
this.XrTableCell22.Borders = BorderSide.None;
this.XrTableCell22.Dpi = 254F;
this.XrTableCell22.ExpressionBindings.AddRange(new ExpressionBinding[] { new ExpressionBinding("BeforePrint", "Text", "[EnvelopeUuid]") });
this.XrTableCell22.Font = new Font("Arial", 8.25F, FontStyle.Regular, GraphicsUnit.Point, 0);
this.XrTableCell22.ForeColor = Color.Black;
this.XrTableCell22.Multiline = true;
this.XrTableCell22.Name = "XrTableCell22";
this.XrTableCell22.StyleName = "DetailCaption1";
this.XrTableCell22.StylePriority.UseBackColor = false;
this.XrTableCell22.StylePriority.UseBorderColor = false;
this.XrTableCell22.StylePriority.UseBorders = false;
this.XrTableCell22.StylePriority.UseFont = false;
this.XrTableCell22.StylePriority.UseForeColor = false;
this.XrTableCell22.Text = "XrTableCell22";
this.XrTableCell22.Weight = 0.38280260446913167D;
//
// XrTableRow11
//
this.XrTableRow11.Cells.AddRange(new XRTableCell[] { this.XrTableCell23, this.XrTableCell24, this.XrTableCell25, this.XrTableCell26 });
this.XrTableRow11.Dpi = 254F;
this.XrTableRow11.Name = "XrTableRow11";
this.XrTableRow11.Weight = 1D;
//
// XrTableCell23
//
this.XrTableCell23.BackColor = Color.White;
this.XrTableCell23.BorderColor = Color.Empty;
this.XrTableCell23.Borders = BorderSide.None;
this.XrTableCell23.Dpi = 254F;
this.XrTableCell23.Font = new Font("Arial", 8.25F, FontStyle.Bold, GraphicsUnit.Point, 0);
this.XrTableCell23.ForeColor = Color.Black;
this.XrTableCell23.Multiline = true;
this.XrTableCell23.Name = "XrTableCell23";
this.XrTableCell23.StyleName = "DetailCaption1";
this.XrTableCell23.StylePriority.UseBackColor = false;
this.XrTableCell23.StylePriority.UseBorderColor = false;
this.XrTableCell23.StylePriority.UseBorders = false;
this.XrTableCell23.StylePriority.UseFont = false;
this.XrTableCell23.StylePriority.UseForeColor = false;
this.XrTableCell23.Weight = 0.11578820509129036D;
//
// XrTableCell24
//
this.XrTableCell24.BackColor = Color.White;
this.XrTableCell24.BorderColor = Color.Empty;
this.XrTableCell24.Borders = BorderSide.None;
this.XrTableCell24.Dpi = 254F;
this.XrTableCell24.Font = new Font("Arial", 8.25F, FontStyle.Regular, GraphicsUnit.Point, 0);
this.XrTableCell24.ForeColor = Color.Black;
this.XrTableCell24.Multiline = true;
this.XrTableCell24.Name = "XrTableCell24";
this.XrTableCell24.StyleName = "DetailCaption1";
this.XrTableCell24.StylePriority.UseBackColor = false;
this.XrTableCell24.StylePriority.UseBorderColor = false;
this.XrTableCell24.StylePriority.UseBorders = false;
this.XrTableCell24.StylePriority.UseFont = false;
this.XrTableCell24.StylePriority.UseForeColor = false;
this.XrTableCell24.Weight = 0.2656113622128245D;
//
// XrTableCell25
//
this.XrTableCell25.BackColor = Color.White;
this.XrTableCell25.BorderColor = Color.Empty;
this.XrTableCell25.Borders = BorderSide.None;
this.XrTableCell25.Dpi = 254F;
this.XrTableCell25.Font = new Font("Arial", 8.25F, FontStyle.Bold, GraphicsUnit.Point, 0);
this.XrTableCell25.ForeColor = Color.Black;
this.XrTableCell25.Multiline = true;
this.XrTableCell25.Name = "XrTableCell25";
this.XrTableCell25.StyleName = "DetailCaption1";
this.XrTableCell25.StylePriority.UseBackColor = false;
this.XrTableCell25.StylePriority.UseBorderColor = false;
this.XrTableCell25.StylePriority.UseBorders = false;
this.XrTableCell25.StylePriority.UseFont = false;
this.XrTableCell25.StylePriority.UseForeColor = false;
this.XrTableCell25.Text = "Zertifizierung";
this.XrTableCell25.Weight = 0.11578821158083684D;
//
// XrTableCell26
//
this.XrTableCell26.BackColor = Color.White;
this.XrTableCell26.BorderColor = Color.Empty;
this.XrTableCell26.Borders = BorderSide.None;
this.XrTableCell26.Dpi = 254F;
this.XrTableCell26.ExpressionBindings.AddRange(new ExpressionBinding[] { new ExpressionBinding("BeforePrint", "Text", "[EnvelopeCertificationType]") });
this.XrTableCell26.Font = new Font("Arial", 8.25F, FontStyle.Regular, GraphicsUnit.Point, 0);
this.XrTableCell26.ForeColor = Color.Black;
this.XrTableCell26.Multiline = true;
this.XrTableCell26.Name = "XrTableCell26";
this.XrTableCell26.StyleName = "DetailCaption1";
this.XrTableCell26.StylePriority.UseBackColor = false;
this.XrTableCell26.StylePriority.UseBorderColor = false;
this.XrTableCell26.StylePriority.UseBorders = false;
this.XrTableCell26.StylePriority.UseFont = false;
this.XrTableCell26.StylePriority.UseForeColor = false;
this.XrTableCell26.Text = "XrTableCell26";
this.XrTableCell26.Weight = 0.38280260446913161D;
//
// GroupHeader1
//
this.GroupHeader1.Controls.AddRange(new XRControl[] { this.table1 });
this.GroupHeader1.Dpi = 254F;
this.GroupHeader1.GroupUnion = GroupUnion.WithFirstDetail;
this.GroupHeader1.HeightF = 71.12F;
this.GroupHeader1.Name = "GroupHeader1";
//
// table1
//
this.table1.Dpi = 254F;
this.table1.LocationFloat = new DevExpress.Utils.PointFloat(0F, 0F);
this.table1.Name = "table1";
this.table1.Rows.AddRange(new XRTableRow[] { this.tableRow1 });
this.table1.SizeF = new SizeF(1900F, 71.12F);
//
// tableRow1
//
this.tableRow1.Cells.AddRange(new XRTableCell[] { this.tableCell1, this.tableCell2, this.tableCell3 });
this.tableRow1.Dpi = 254F;
this.tableRow1.Name = "tableRow1";
this.tableRow1.Weight = 1D;
//
// tableCell1
//
this.tableCell1.BackColor = Color.FromArgb(224, 224, 224);
this.tableCell1.BorderColor = Color.FromArgb(165, 36, 49);
this.tableCell1.Borders = BorderSide.Bottom;
this.tableCell1.BorderWidth = 1F;
this.tableCell1.Dpi = 254F;
this.tableCell1.ForeColor = Color.Black;
this.tableCell1.Name = "tableCell1";
this.tableCell1.StyleName = "DetailCaption1";
this.tableCell1.StylePriority.UseBackColor = false;
this.tableCell1.StylePriority.UseBorderColor = false;
this.tableCell1.StylePriority.UseBorders = false;
this.tableCell1.StylePriority.UseBorderWidth = false;
this.tableCell1.StylePriority.UseForeColor = false;
this.tableCell1.Text = "Ereignis";
this.tableCell1.Weight = 0.51726482588176181D;
//
// tableCell2
//
this.tableCell2.BackColor = Color.FromArgb(224, 224, 224);
this.tableCell2.BorderColor = Color.FromArgb(165, 36, 49);
this.tableCell2.Borders = BorderSide.Bottom;
this.tableCell2.BorderWidth = 1F;
this.tableCell2.Dpi = 254F;
this.tableCell2.ForeColor = Color.Black;
this.tableCell2.Name = "tableCell2";
this.tableCell2.StyleName = "DetailCaption1";
this.tableCell2.StylePriority.UseBackColor = false;
this.tableCell2.StylePriority.UseBorderColor = false;
this.tableCell2.StylePriority.UseBorders = false;
this.tableCell2.StylePriority.UseBorderWidth = false;
this.tableCell2.StylePriority.UseForeColor = false;
this.tableCell2.Text = "Benutzer";
this.tableCell2.Weight = 0.45140669898958585D;
//
// tableCell3
//
this.tableCell3.BackColor = Color.FromArgb(224, 224, 224);
this.tableCell3.BorderColor = Color.FromArgb(165, 36, 49);
this.tableCell3.Borders = BorderSide.Bottom;
this.tableCell3.BorderWidth = 1F;
this.tableCell3.Dpi = 254F;
this.tableCell3.ForeColor = Color.Black;
this.tableCell3.Name = "tableCell3";
this.tableCell3.StyleName = "DetailCaption1";
this.tableCell3.StylePriority.UseBackColor = false;
this.tableCell3.StylePriority.UseBorderColor = false;
this.tableCell3.StylePriority.UseBorders = false;
this.tableCell3.StylePriority.UseBorderWidth = false;
this.tableCell3.StylePriority.UseForeColor = false;
this.tableCell3.Text = "Zeitstempel";
this.tableCell3.Weight = 0.22479583469004233D;
//
// Detail
//
this.Detail.Controls.AddRange(new XRControl[] { this.table2 });
this.Detail.Dpi = 254F;
this.Detail.HeightF = 86.174F;
this.Detail.HierarchyPrintOptions.Indent = 50.8F;
this.Detail.Name = "Detail";
//
// table2
//
this.table2.Dpi = 254F;
this.table2.LocationFloat = new DevExpress.Utils.PointFloat(0F, 0F);
this.table2.Name = "table2";
this.table2.Rows.AddRange(new XRTableRow[] { this.tableRow2 });
this.table2.SizeF = new SizeF(1900F, 63.42F);
//
// tableRow2
//
this.tableRow2.Cells.AddRange(new XRTableCell[] { this.tableCell4, this.tableCell5, this.tableCell6 });
this.tableRow2.Dpi = 254F;
this.tableRow2.Name = "tableRow2";
this.tableRow2.Weight = 11.683999633789062D;
//
// tableCell4
//
this.tableCell4.Borders = BorderSide.None;
this.tableCell4.Dpi = 254F;
this.tableCell4.ExpressionBindings.AddRange(new ExpressionBinding[] { new ExpressionBinding("BeforePrint", "Text", "[ItemStatusTranslated]") });
this.tableCell4.Name = "tableCell4";
this.tableCell4.StyleName = "DetailData1";
this.tableCell4.StylePriority.UseBorders = false;
this.tableCell4.Weight = 0.51726482142156094D;
//
// tableCell5
//
this.tableCell5.Dpi = 254F;
this.tableCell5.ExpressionBindings.AddRange(new ExpressionBinding[] { new ExpressionBinding("BeforePrint", "Text", "[ItemUserReference]") });
this.tableCell5.Name = "tableCell5";
this.tableCell5.StyleName = "DetailData1";
this.tableCell5.Weight = 0.45140669932916544D;
//
// tableCell6
//
this.tableCell6.Dpi = 254F;
this.tableCell6.ExpressionBindings.AddRange(new ExpressionBinding[] { new ExpressionBinding("BeforePrint", "Text", "[ItemDate]") });
this.tableCell6.Name = "tableCell6";
this.tableCell6.StyleName = "DetailData1";
this.tableCell6.StylePriority.UseTextAlignment = false;
this.tableCell6.TextAlignment = TextAlignment.MiddleRight;
this.tableCell6.Weight = 0.22479581593269077D;
//
// Title
//
this.Title.BackColor = Color.Transparent;
this.Title.BorderColor = Color.Black;
this.Title.Borders = BorderSide.None;
this.Title.BorderWidth = 1F;
this.Title.Font = new Font("Arial", 14.25F);
this.Title.ForeColor = Color.FromArgb(75, 75, 75);
this.Title.Name = "Title";
this.Title.Padding = new PaddingInfo(15, 15, 0, 0, 254F);
//
// DetailCaption1
//
this.DetailCaption1.BackColor = Color.FromArgb(75, 75, 75);
this.DetailCaption1.BorderColor = Color.White;
this.DetailCaption1.Borders = BorderSide.Left;
this.DetailCaption1.BorderWidth = 2F;
this.DetailCaption1.Font = new Font("Arial", 8.25F, FontStyle.Bold);
this.DetailCaption1.ForeColor = Color.White;
this.DetailCaption1.Name = "DetailCaption1";
this.DetailCaption1.Padding = new PaddingInfo(15, 15, 0, 0, 254F);
this.DetailCaption1.TextAlignment = TextAlignment.MiddleLeft;
//
// DetailData1
//
this.DetailData1.BorderColor = Color.Transparent;
this.DetailData1.Borders = BorderSide.Left;
this.DetailData1.BorderWidth = 2F;
this.DetailData1.Font = new Font("Arial", 8.25F);
this.DetailData1.ForeColor = Color.Black;
this.DetailData1.Name = "DetailData1";
this.DetailData1.Padding = new PaddingInfo(15, 15, 0, 0, 254F);
this.DetailData1.TextAlignment = TextAlignment.MiddleLeft;
//
// DetailData3_Odd
//
this.DetailData3_Odd.BackColor = Color.FromArgb(231, 231, 231);
this.DetailData3_Odd.BorderColor = Color.Transparent;
this.DetailData3_Odd.Borders = BorderSide.None;
this.DetailData3_Odd.BorderWidth = 1F;
this.DetailData3_Odd.Font = new Font("Arial", 8.25F);
this.DetailData3_Odd.ForeColor = Color.Black;
this.DetailData3_Odd.Name = "DetailData3_Odd";
this.DetailData3_Odd.Padding = new PaddingInfo(15, 15, 0, 0, 254F);
this.DetailData3_Odd.TextAlignment = TextAlignment.MiddleLeft;
//
// PageInfo
//
this.PageInfo.Font = new Font("Arial", 8.25F, FontStyle.Bold);
this.PageInfo.ForeColor = Color.FromArgb(75, 75, 75);
this.PageInfo.Name = "PageInfo";
this.PageInfo.Padding = new PaddingInfo(15, 15, 0, 0, 254F);
//
// ObjectDataSource1
//
this.ObjectDataSource1.DataMember = "Items";
this.ObjectDataSource1.Name = "ObjectDataSource1";
//
// rptEnvelopeHistory
//
this.Bands.AddRange(new Band[] { this.TopMargin, this.BottomMargin, this.ReportHeader, this.GroupHeader1, this.Detail });
this.ComponentStorage.AddRange(new IComponent[] { this.ObjectDataSource1 });
this.DataSource = this.ObjectDataSource1;
this.Dpi = 254F;
this.Font = new Font("Arial", 9.75F);
this.Margins = new Margins(100, 100, 191, 100);
this.PageHeight = 2970;
this.PageWidth = 2100;
this.PaperKind = (DevExpress.Drawing.Printing.DXPaperKind)System.Drawing.Printing.PaperKind.A4;
this.ReportUnit = ReportUnit.TenthsOfAMillimeter;
this.SnapGridSize = 25F;
this.StyleSheet.AddRange(new XRControlStyle[] { this.Title, this.DetailCaption1, this.DetailData1, this.DetailData3_Odd, this.PageInfo });
this.Version = "24.2";
this.Watermark.ImageSource = new DevExpress.XtraPrinting.Drawing.ImageSource("img", resources.GetString("rptEnvelopeHistory.Watermark.ImageSource"));
this.Watermark.ImageTransparency = 220;
((ISupportInitialize)this.XrTable3).EndInit();
((ISupportInitialize)this.table1).EndInit();
((ISupportInitialize)this.table2).EndInit();
((ISupportInitialize)this.ObjectDataSource1).EndInit();
((ISupportInitialize)this).EndInit();
}
#endregion
private TopMarginBand TopMargin;
private BottomMarginBand BottomMargin;
private XRPageInfo pageInfo1;
private XRPageInfo pageInfo2;
private ReportHeaderBand ReportHeader;
private XRLabel label1;
private GroupHeaderBand GroupHeader1;
private XRTable table1;
private XRTableRow tableRow1;
private XRTableCell tableCell1;
private XRTableCell tableCell2;
private XRTableCell tableCell3;
private DetailBand Detail;
private XRTable table2;
private XRTableRow tableRow2;
private XRTableCell tableCell4;
private XRTableCell tableCell5;
private XRTableCell tableCell6;
private ObjectDataSource ObjectDataSource1;
private XRControlStyle Title;
private XRControlStyle DetailCaption1;
private XRControlStyle DetailData1;
private XRControlStyle DetailData3_Odd;
private XRControlStyle PageInfo;
private XRLabel XrLabel1;
private XRTable XrTable3;
private XRTableRow XrTableRow8;
private XRTableCell XrTableCell13;
private XRTableCell XrTableCell15;
private XRTableRow XrTableRow9;
private XRTableCell XrTableCell14;
private XRTableCell XrTableCell17;
private XRTableCell XrTableCell16;
private XRTableCell XrTableCell18;
private XRTableRow XrTableRow10;
private XRTableCell XrTableCell19;
private XRTableCell XrTableCell20;
private XRTableCell XrTableCell21;
private XRTableCell XrTableCell22;
private XRTableRow XrTableRow11;
private XRTableCell XrTableCell23;
private XRTableCell XrTableCell24;
private XRTableCell XrTableCell25;
private XRTableCell XrTableCell26;
}

View File

@@ -1,18 +1,9 @@
using System.IO;
namespace EnvelopeGenerator.ServiceHost.Jobs.FinalizeDocument;
namespace EnvelopeGenerator.ServiceHost.Jobs.FinalizeDocument;
public class rptEnvelopeHistory
public partial class rptEnvelopeHistory
{
public object? DataSource { get; set; }
public string? DataMember { get; set; }
public void CreateDocument()
public rptEnvelopeHistory()
{
}
public void ExportToPdf(Stream stream)
{
stream.Write(Array.Empty<byte>(), 0, 0);
InitializeComponent();
}
}

File diff suppressed because one or more lines are too long

View File

@@ -1,24 +1,22 @@
using System.Data;
using DigitalData.Modules.Database;
using DigitalData.Core.Abstraction.Application.Repository;
using EnvelopeGenerator.Application.Common.Dto;
using EnvelopeGenerator.Application.Configuration.Queries;
using EnvelopeGenerator.Application.Envelopes.Queries;
using EnvelopeGenerator.Domain.Constants;
using EnvelopeGenerator.Domain.Entities;
using EnvelopeGenerator.ServiceHost.Exceptions;
using EnvelopeGenerator.ServiceHost.Extensions;
using EnvelopeGenerator.ServiceHost.Jobs.FinalizeDocument;
using GdPicture14;
using Microsoft.Data.SqlClient;
using Microsoft.Extensions.Options;
using EnvelopeGenerator.ServiceHost.Extensions;
using MediatR;
using EnvelopeGenerator.Application.Configuration.Queries;
using EnvelopeGenerator.Application.Common.Dto;
using EnvelopeGenerator.Application.Envelopes.Queries;
using DigitalData.Core.Abstraction.Application.Repository;
using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.Options;
using System.Data;
namespace EnvelopeGenerator.ServiceHost.Jobs;
[Obsolete("ActionService is a placeholder service added by copilot. Migrate the actual logic from CommonServices.Jobs")]
public class FinalizeDocumentJob(IOptions<WorkerOptions> options, IConfiguration config, ILogger<FinalizeDocumentJob> logger, TempFiles tempFiles, ActionService actionService, PDFBurner pdfBurner, PDFMerger pdfMerger, ReportCreator reportCreator, ReportModel _reportModel, MSSQLServer _database, GdViewer? _gdViewer, LicenseManager licenseManager, IMediator mediator, IRepository<Envelope> envRepo)
public class FinalizeDocumentJob(IOptions<WorkerOptions> options, ILogger<FinalizeDocumentJob> logger, TempFiles tempFiles, ActionService actionService, PDFBurner pdfBurner, PDFMerger pdfMerger, ReportCreator reportCreator, GdViewer? _gdViewer, LicenseManager licenseManager, IMediator mediator, IRepository<Envelope> envRepo, IRepository<Domain.Entities.DocumentStatus> docStatusRepo)
{
private readonly WorkerOptions _options = options.Value;
@@ -36,329 +34,121 @@ public class FinalizeDocumentJob(IOptions<WorkerOptions> options, IConfiguration
public byte[]? DocAsByte { get; set; }
}
public async Task ExecuteAsync(CancellationToken cancel = default)
public bool RethrowOnError { get; set; } = true;
public async Task ExecuteAsync(IEnumerable<EnvelopeDto> envelopes, CancellationToken cancel = default)
{
var gdPictureKey = _options.GdPictureLicenseKey;
tempFiles.Create();
var jobId = typeof(FinalizeDocumentJob).FullName;
logger.LogDebug("Starting job {jobId}", jobId);
_config = await mediator.Send(new ReadDefaultConfigQuery(), cancel);
foreach (var envelope in envelopes)
{
try
{
await Finalize(envelope, cancel);
}
catch (Exception ex)
{
logger.LogWarning(ex, "An unexpected exception was ignored while processing the envelope with ID [{id}].", envelope.Id);
if(RethrowOnError)
throw;
}
}
}
public Task ExecuteAsync(EnvelopeDto envelope, CancellationToken cancel = default) => ExecuteAsync([envelope], cancel);
public async Task ExecuteAsync(CancellationToken cancel = default)
{
var envelopes = await mediator.Send(new ReadEnvelopeQuery()
{
Status = new () { Include = [EnvelopeStatus.EnvelopeCompletelySigned] },
MinMinutesSinceLastChange = CompleteWaitTime,
}, cancel);
await ExecuteAsync(envelopes, cancel);
}
private async Task Finalize(EnvelopeDto envelope, CancellationToken cancel)
{
var annotations = await docStatusRepo.Where(s => s.EnvelopeId == envelope.Id).Select(s => s.Value).ToListAsync(cancel);
var burnedDocument = pdfBurner!.BurnAnnotsToPDF(envelope.Documents?.FirstOrDefault()?.ByteData!, annotations, envelope.Id)
?? throw new ApplicationException("Document could not be finalized");
actionService.CreateReport(envelope, cancel);
var report = await reportCreator!.CreateReportAsync(envelope, cancel);
var mergedDocument = pdfMerger!.MergeDocuments(burnedDocument, report);
var outputDirectoryPath = Path.Combine(_config!.ExportPath, _parentFolderUid);
if (!Directory.Exists(outputDirectoryPath))
Directory.CreateDirectory(outputDirectoryPath);
var outputFilePath = Path.Combine(outputDirectoryPath, $"{envelope.Uuid}.pdf");
try
{
logger.LogDebug("Loading Configuration..");
_config = await mediator.Send(new ReadDefaultConfigQuery(), cancel);
logger.LogDebug("DocumentPath: [{documentPath}]", _config.DocumentPath);
logger.LogDebug("ExportPath: [{exportPath}]", _config.ExportPath);
var completeStatus = EnvelopeStatus.EnvelopeCompletelySigned;
var sql = $"SELECT * FROM TBSIG_ENVELOPE WHERE STATUS = {completeStatus} AND DATEDIFF(minute, CHANGED_WHEN, GETDATE()) >= {CompleteWaitTime} ORDER BY GUID";
var table = _database.GetDatatable(sql);
var envelopeIds = table.Rows.Cast<DataRow>()
.Select(r => r.Field<int>("GUID"))
.ToList();
if (envelopeIds.Count > 0)
{
logger.LogInformation("Found [{count}] completed envelopes.", envelopeIds.Count);
}
var total = envelopeIds.Count;
var current = 1;
foreach (var id in envelopeIds)
{
logger.LogInformation("Finalizing Envelope [{id}] ({current}/{total})", id, current, total);
try
{
var envelope = await envRepo.Where(e => e.Id == id).SingleOrDefaultAsync(cancel);
if (envelope is null)
{
logger.LogWarning("Envelope could not be loaded for Id [{id}]!", id);
throw new ArgumentNullException(nameof(EnvelopeData));
}
logger.LogDebug("Loading Envelope Data..");
var envelopeData = GetEnvelopeData(id);
if (envelopeData is null)
{
logger.LogWarning("EnvelopeData could not be loaded for Id [{id}]!", id);
throw new ArgumentNullException(nameof(EnvelopeData));
}
logger.LogDebug("Burning Annotations to pdf ...");
var burnedDocument = BurnAnnotationsToPdf(envelopeData);
if (burnedDocument is null)
{
logger.LogWarning("Document could not be finalized!");
throw new ApplicationException("Document could not be finalized");
}
if (actionService?.CreateReport(envelope) == false)
{
logger.LogWarning("Document Report could not be created!");
throw new ApplicationException("Document Report could not be created");
}
logger.LogDebug("Creating report..");
var report = reportCreator!.CreateReport(envelope);
logger.LogDebug("Report created!");
logger.LogDebug("Merging documents ...");
var mergedDocument = pdfMerger!.MergeDocuments(burnedDocument, report);
logger.LogDebug("Documents merged!");
var outputDirectoryPath = Path.Combine(_config.ExportPath, _parentFolderUid);
logger.LogDebug("oOutputDirectoryPath is {outputDirectoryPath}", outputDirectoryPath);
if (!Directory.Exists(outputDirectoryPath))
{
logger.LogDebug("Directory not existing. Creating ... ");
Directory.CreateDirectory(outputDirectoryPath);
}
var outputFilePath = Path.Combine(outputDirectoryPath, $"{envelope.Uuid}.pdf");
logger.LogDebug("Writing finalized Pdf to disk..");
logger.LogInformation("Output path is [{outputFilePath}]", outputFilePath);
try
{
File.WriteAllBytes(outputFilePath, mergedDocument);
}
catch (Exception ex)
{
logger.LogWarning("Could not export final document to disk!");
throw new ExportDocumentException("Could not export final document to disk!", ex);
}
logger.LogDebug("Writing EB-bytes to database...");
UpdateFileDb(outputFilePath, envelope.Id);
if (!SendFinalEmails(envelope))
{
throw new ApplicationException("Final emails could not be sent!");
}
logger.LogInformation("Report-mails successfully sent!");
logger.LogDebug("Setting envelope status..");
if (actionService?.FinalizeEnvelope(envelope) == false)
{
logger.LogWarning("Envelope could not be finalized!");
throw new ApplicationException("Envelope could not be finalized");
}
}
catch (Exception ex)
{
logger.LogError(ex);
logger.LogWarning(ex, "Unhandled exception while working envelope [{id}]", id);
}
current += 1;
logger.LogInformation("Envelope [{id}] finalized!", id);
}
logger.LogDebug("Completed job {jobId} successfully!", jobId);
}
catch (MergeDocumentException ex)
{
logger.LogWarning("Certificate Document job failed at step: Merging documents!");
logger.LogError(ex);
}
catch (ExportDocumentException ex)
{
logger.LogWarning("Certificate Document job failed at step: Exporting document!");
logger.LogError(ex);
File.WriteAllBytes(outputFilePath, mergedDocument);
}
catch (Exception ex)
{
logger.LogWarning("Certificate Document job failed!");
logger.LogError(ex);
}
finally
{
logger.LogDebug("Job execution for [{jobId}] ended", jobId);
throw new ExportDocumentException("Could not export final document to disk. Envelope Id is " + envelope.Id, ex);
}
var outputFile = await File.ReadAllBytesAsync(outputFilePath, cancel);
await envRepo.UpdateAsync(e => e.DocResult = outputFile, e => e.Id == envelope.Id, cancel);
SendFinalEmails(envelope);
actionService.FinalizeEnvelope(envelope, cancel);
}
private void UpdateFileDb(string filePath, long envelopeId)
{
try
{
var imageData = ReadFile(filePath);
if (imageData is null)
{
return;
}
var query = $"UPDATE TBSIG_ENVELOPE SET DOC_RESULT = @ImageData WHERE GUID = {envelopeId}";
using var command = new SqlCommand(query, _database!.GetConnection);
command.Parameters.Add(new SqlParameter("@ImageData", imageData));
command.ExecuteNonQuery();
}
catch (Exception ex)
{
logger?.LogError(ex);
}
}
private static byte[]? ReadFile(string path)
{
var fileInfo = new FileInfo(path);
var numBytes = fileInfo.Length;
using var stream = new FileStream(path, FileMode.Open, FileAccess.Read);
using var reader = new BinaryReader(stream);
return reader.ReadBytes((int)numBytes);
}
private bool SendFinalEmails(Envelope envelope)
private bool SendFinalEmails(EnvelopeDto envelope)
{
var mailToCreator = (FinalEmailType)(envelope.FinalEmailToCreator ?? 0);
var mailToReceivers = (FinalEmailType)(envelope.FinalEmailToReceivers ?? 0);
if (mailToCreator != FinalEmailType.No)
{
logger?.LogDebug("Sending email to creator ...");
SendFinalEmailToCreator(envelope, mailToCreator);
}
else
{
logger?.LogWarning("No SendFinalEmailToCreator - oMailToCreator [{0}] <> [{1}] ", mailToCreator, FinalEmailType.No);
}
logger?.LogWarning("No SendFinalEmailToCreator - oMailToCreator [{mailToCreator}] <> [{noFinalEmailType}] ", mailToCreator, FinalEmailType.No);
if (mailToReceivers != FinalEmailType.No)
{
logger?.LogDebug("Sending emails to receivers..");
SendFinalEmailToReceivers(envelope, mailToReceivers);
}
else
{
logger?.LogWarning("No SendFinalEmailToReceivers - oMailToCreator [{0}] <> [{1}] ", mailToReceivers, FinalEmailType.No);
logger?.LogWarning("No SendFinalEmailToReceivers - oMailToCreator [{mailToReceivers}] <> [{noFinalEmailType}] ", mailToReceivers, FinalEmailType.No);
}
return true;
}
private bool SendFinalEmailToCreator(Envelope envelope, FinalEmailType mailToCreator)
private bool SendFinalEmailToCreator(EnvelopeDto envelope, FinalEmailType mailToCreator)
{
var includeAttachment = SendFinalEmailWithAttachment(mailToCreator);
logger?.LogDebug("Attachment included: [{0}]", includeAttachment);
if (actionService?.CompleteEnvelope(envelope) == false)
if (actionService.CompleteEnvelope(envelope) == false)
{
logger?.LogError(new Exception("CompleteEnvelope failed"), "Envelope could not be completed for receiver [{0}]", envelope.User?.Email);
logger?.LogError(new Exception("CompleteEnvelope failed"), "Envelope could not be completed for receiver [{email}]", envelope.User?.Email);
return false;
}
return true;
}
private bool SendFinalEmailToReceivers(Envelope envelope, FinalEmailType mailToReceivers)
private bool SendFinalEmailToReceivers(EnvelopeDto envelope, FinalEmailType mailToReceivers)
{
var includeAttachment = SendFinalEmailWithAttachment(mailToReceivers);
logger?.LogDebug("Attachment included: [{0}]", includeAttachment);
foreach (var receiver in envelope.EnvelopeReceivers ?? Enumerable.Empty<EnvelopeReceiver>())
foreach (var receiver in envelope.EnvelopeReceivers ?? [])
{
if (actionService?.CompleteEnvelope(envelope, receiver.Receiver) == false)
{
logger?.LogError(new Exception("CompleteEnvelope failed"), "Envelope could not be completed for receiver [{0}]", receiver.Receiver?.EmailAddress);
if (!actionService.CompleteEnvelope(envelope, receiver.Receiver!))
return false;
}
}
return true;
}
private static bool SendFinalEmailWithAttachment(FinalEmailType type)
{
return type == FinalEmailType.YesWithAttachment;
}
private byte[] BurnAnnotationsToPdf(EnvelopeData envelopeData)
{
var envelopeId = envelopeData.EnvelopeId;
logger?.LogInformation("Burning [{0}] signatures", envelopeData.AnnotationData.Count);
var annotations = envelopeData.AnnotationData;
var inputPath = string.Empty;
if (envelopeData.DocAsByte is null)
{
inputPath = envelopeData.DocumentPath;
logger?.LogInformation("Input path: [{0}]", inputPath);
}
else
{
logger?.LogDebug("we got bytes..");
inputPath = _config!.DocumentPath;
logger?.LogDebug("oInputPath: {0}", _config.DocumentPath);
}
if (envelopeData.DocAsByte is null)
{
var directorySource = Path.GetDirectoryName(inputPath) ?? string.Empty;
var split = directorySource.Split('\\');
_parentFolderUid = split[^1];
}
else
{
_parentFolderUid = envelopeData.EnvelopeUuid;
}
logger?.LogInformation("ParentFolderUID: [{0}]", _parentFolderUid);
byte[] inputDocumentBuffer;
if (envelopeData.DocAsByte is not null)
{
inputDocumentBuffer = envelopeData.DocAsByte;
}
else
{
try
{
inputDocumentBuffer = File.ReadAllBytes(inputPath);
}
catch (Exception ex)
{
throw new BurnAnnotationException("Source document could not be read from disk!", ex);
}
}
return pdfBurner!.BurnAnnotsToPDF(inputDocumentBuffer, annotations, envelopeId);
}
private EnvelopeData? GetEnvelopeData(int envelopeId)
{
var sql = $"SELECT T.GUID, T.ENVELOPE_UUID, T.ENVELOPE_TYPE, T2.FILEPATH, T2.BYTE_DATA FROM [dbo].[TBSIG_ENVELOPE] T\n JOIN TBSIG_ENVELOPE_DOCUMENT T2 ON T.GUID = T2.ENVELOPE_ID\n WHERE T.GUID = {envelopeId}";
var table = _database!.GetDatatable(sql);
var row = table.Rows.Cast<DataRow>().SingleOrDefault();
if (row is null)
{
return null;
}
var annotationData = GetAnnotationData(envelopeId);
var data = new EnvelopeData
{
EnvelopeId = envelopeId,
DocumentPath = row.ItemEx("FILEPATH", string.Empty),
AnnotationData = annotationData,
DocAsByte = row.Field<byte[]?>("BYTE_DATA"),
EnvelopeUuid = row.ItemEx("ENVELOPE_UUID", string.Empty)
};
logger?.LogDebug("Document path: [{0}]", data.DocumentPath);
return data;
}
private List<string> GetAnnotationData(int envelopeId)
{
var sql = $"SELECT VALUE FROM TBSIG_DOCUMENT_STATUS WHERE ENVELOPE_ID = {envelopeId}";
var table = _database!.GetDatatable(sql);
return table.Rows.Cast<DataRow>()
.Select(r => r.ItemEx("VALUE", string.Empty))
.ToList();
}
}
}

View File

@@ -1,7 +1,7 @@
using System.Data;
using Microsoft.Data.SqlClient;
namespace DigitalData.Modules.Database;
namespace EnvelopeGenerator.ServiceHost.Jobs.Infrastructure;
public class MSSQLServer(IConfiguration configuration)
{

View File

@@ -0,0 +1,19 @@
using AngleSharp.Common;
using System.Collections.Concurrent;
namespace EnvelopeGenerator.ServiceHost.Jobs;
public class JobStateManager(Dictionary<string, State>? initialState = null)
{
private readonly ConcurrentDictionary<Type, State> _states = new();
public State GetState<TJob>() => _states.GetOrAdd(typeof(TJob), type => initialState?.GetOrDefault(type.Name, State.Stopped) ?? State.Stopped);
public State SetState<TJob>(State state) => _states[typeof(TJob)] = state;
}
public enum State
{
Running,
Stopped
}

View File

@@ -0,0 +1,39 @@
using EnvelopeGenerator.Application.ThirdPartyModules.Queries;
using GdPicture14;
using MediatR;
using Microsoft.Extensions.Caching.Memory;
namespace EnvelopeGenerator.ServiceHost.Jobs;
public class LicenseManagerFactory
{
private static readonly string _cacheKey = Guid.NewGuid().ToString();
private readonly IServiceScopeFactory scopeFactory;
private readonly IMemoryCache cache;
public LicenseManagerFactory(IServiceScopeFactory scopeFactory, IMemoryCache cache)
{
this.scopeFactory = scopeFactory;
this.cache = cache;
_ = CreateAsync(); // Preload the license key into the cache
}
public async Task<LicenseManager> CreateAsync(CancellationToken cancellationToken = default)
{
var key = await GetLicenseKeyAsync(cancellationToken);
var licenseManager = new LicenseManager();
licenseManager.RegisterKEY(key);
return licenseManager;
}
public async Task<string> GetLicenseKeyAsync(CancellationToken cancellationToken = default)
{
return await cache.GetOrCreateAsync(_cacheKey, async entry =>
{
entry.Priority = CacheItemPriority.NeverRemove;
using var scope = scopeFactory.CreateScope();
var mediator = scope.ServiceProvider.GetRequiredService<IMediator>();
return await mediator.Send(new ReadThirdPartyModuleLicenseQuery { Name = "GdPicture", Active =true }, cancellationToken);
}) ?? throw new InvalidOperationException("License key could not be retrieved.");
}
}

View File

@@ -1,15 +0,0 @@
using DigitalData.Modules.Database;
using System.Data;
namespace EnvelopeGenerator.ServiceHost.Jobs;
[Obsolete("Create and use EnvelopeReport mediator queries")]
public class ReportModel(MSSQLServer Database)
{
[Obsolete("Create and use EnvelopeReport mediator queries")]
public DataTable List(int envelopeId)
{
var sql = $"SELECT * FROM VWSIG_ENVELOPE_REPORT WHERE ENVELOPE_ID = {envelopeId}";
return Database.GetDatatable(sql);
}
}

View File

@@ -1,13 +0,0 @@
using DigitalData.Modules.Database;
using EnvelopeGenerator.Domain.Entities;
namespace EnvelopeGenerator.ServiceHost.Jobs;
[Obsolete("Use DbContext")]
public class State
{
public int UserId { get; set; }
public FormUser? User { get; set; }
public Config? Config { get; set; }
public MSSQLServer? Database { get; set; }
}

View File

@@ -1,14 +1,22 @@
using EnvelopeGenerator.ServiceHost.Jobs.FinalizeDocument;
using System.Drawing;
namespace EnvelopeGenerator.ServiceHost.Jobs;
public class WorkerOptions
{
public string GdPictureLicenseKey { get; set; } = null!;
private int _delayMilliseconds = 1000;
[Obsolete("Use ILogger.")]
public bool Debug { get; set; }
public int DelayMilliseconds
{
get => _delayMilliseconds;
set
{
if (value < 1)
throw new ArgumentOutOfRangeException(nameof(value), "Delay must be at least 1 millisecond.");
_delayMilliseconds = value;
}
}
public Dictionary<string, State> InitialJobState { get; set; } = [];
public PDFBurnerOptions PdfBurner { get; set; } = new();

View File

@@ -0,0 +1,75 @@
namespace EnvelopeGenerator.ServiceHost.Middleware;
using DigitalData.Core.Exceptions;
using Microsoft.AspNetCore.Http;
using Microsoft.Extensions.Logging;
using System.Net;
using System.Text.Json;
/// <summary>
/// Middleware for handling exceptions globally in the application.
/// Captures exceptions thrown during the request pipeline execution,
/// logs them, and returns an appropriate HTTP response with a JSON error message.
/// </summary>
/// <remarks>
/// Initializes a new instance of the <see cref="ExceptionHandlingMiddleware"/> class.
/// </remarks>
/// <param name="next">The next middleware in the request pipeline.</param>
/// <param name="logger">The logger instance for logging exceptions.</param>
public class ExceptionHandlingMiddleware(RequestDelegate next, ILogger<ExceptionHandlingMiddleware> logger)
{
/// <summary>
/// Invokes the middleware to handle the HTTP request.
/// </summary>
/// <param name="context">The HTTP context of the current request.</param>
/// <returns>A task that represents the asynchronous operation.</returns>
public async Task InvokeAsync(HttpContext context)
{
try
{
await next(context); // Continue down the pipeline
}
catch (Exception ex)
{
await HandleExceptionAsync(context, ex, logger);
}
}
/// <summary>
/// Handles exceptions by logging them and writing an appropriate JSON response.
/// </summary>
/// <param name="context">The HTTP context of the current request.</param>
/// <param name="exception">The exception that occurred.</param>
/// <param name="logger">The logger instance for logging the exception.</param>
/// <returns>A task that represents the asynchronous operation.</returns>
private static async Task HandleExceptionAsync(HttpContext context, Exception exception, ILogger logger)
{
context.Response.ContentType = "application/json";
string message;
switch (exception)
{
case BadRequestException badRequestEx:
context.Response.StatusCode = (int)HttpStatusCode.BadRequest;
message = badRequestEx.Message;
break;
case NotFoundException notFoundEx:
context.Response.StatusCode = (int)HttpStatusCode.NotFound;
message = notFoundEx.Message;
break;
default:
logger.LogError(exception, "Unhandled exception occurred.");
context.Response.StatusCode = (int)HttpStatusCode.InternalServerError;
message = "An unexpected error occurred.";
break;
}
await context.Response.WriteAsync(JsonSerializer.Serialize(new
{
message
}));
}
}

View File

@@ -1,20 +1,73 @@
using DigitalData.UserManager.DependencyInjection;
using EnvelopeGenerator.Application;
using EnvelopeGenerator.Infrastructure;
using EnvelopeGenerator.ServiceHost;
using EnvelopeGenerator.ServiceHost.Extensions;
using EnvelopeGenerator.ServiceHost.Middleware;
using Microsoft.AspNetCore.Localization;
using Microsoft.EntityFrameworkCore;
using System.Globalization;
var builder = WebApplication.CreateBuilder(args);
// Add services to the container.
#region Kestrel & Windows Service Configuration
if (builder.Configuration.GetValue<bool>("UseWindowsService"))
{
builder.Host.UseWindowsService();
}
if (builder.Configuration.GetValue<bool>("UseCustomKestrelEndpoints"))
{
builder.WebHost.ConfigureKestrel((context, serverOptions) =>
{
var serverConfigSection = context.Configuration.GetSection("ServerConfig");
serverOptions.Configure(serverConfigSection);
});
}
#endregion
var config = builder.Configuration;
var connStr = config.GetConnectionString("Default") ??
throw new InvalidOperationException("Connection string 'Default' is missing in the configuration.");
#region Service configuration
builder.Services.AddControllers();
builder.Services.AddFinalizeDocumentJob(builder.Configuration);
builder.Services.AddHostedService<Worker>();
builder.Services.AddDistributedSqlServerCache(options =>
{
options.ConnectionString = connStr;
options.SchemaName = "dbo";
options.TableName = "TBDD_CACHE";
});
#pragma warning disable CS0618
builder.Services.AddFinalizeDocumentJob(config);
builder.Services.AddEnvelopeGeneratorInfrastructureServices(
opt =>
{
opt.AddDbTriggerParams(config);
opt.AddDbContext((provider, options) =>
{
var logger = provider.GetRequiredService<ILogger<EGDbContext>>();
options.UseSqlServer(connStr)
.LogTo(log => logger.LogInformation("{log}", log), Microsoft.Extensions.Logging.LogLevel.Trace)
.EnableSensitiveDataLogging()
.EnableDetailedErrors();
});
});
builder.Services.AddEnvelopeGeneratorServices(config);
builder.Services.AddMemoryCache();
builder.Services.AddUserManager<EGDbContext>();
#pragma warning restore CS0618
builder.Services.AddLocalization();
#endregion
// Learn more about configuring Swagger/OpenAPI at https://aka.ms/aspnetcore/swashbuckle
builder.Services.AddEndpointsApiExplorer();
builder.Services.AddSwaggerGen();
var app = builder.Build();
app.UseMiddleware<ExceptionHandlingMiddleware>();
// Configure the HTTP request pipeline.
if (app.Environment.IsDevelopment())
{
@@ -22,10 +75,22 @@ if (app.Environment.IsDevelopment())
app.UseSwaggerUI();
}
#region Localizer
var supportedCultureNames = config.GetSection("SupportedCultures").Get<string[]>() ?? ["de-DE", "en-US"];
var supportedCultures = supportedCultureNames.Select(cName => new CultureInfo(cName)).ToList();
var requestLocalizationOptions = new RequestLocalizationOptions
{
SupportedCultures = supportedCultures,
SupportedUICultures = supportedCultures
};
requestLocalizationOptions.RequestCultureProviders.Add(new QueryStringRequestCultureProvider());
app.UseRequestLocalization(requestLocalizationOptions);
#endregion
app.UseHttpsRedirection();
app.UseAuthorization();
app.MapControllers();
app.Run();
app.Run();

View File

@@ -1,18 +1,21 @@
using EnvelopeGenerator.ServiceHost.Jobs;
using Microsoft.Extensions.Options;
namespace EnvelopeGenerator.ServiceHost;
public class Worker : BackgroundService
{
private readonly ILogger<Worker> _logger;
private readonly int _delayMilliseconds;
private readonly FinalizeDocumentJob _finalizeDocumentJob;
private readonly WorkerOptions _options;
private readonly JobStateManager _jobStateManager;
private readonly IServiceScopeFactory _scopeFactory;
public Worker(ILogger<Worker> logger, IConfiguration configuration, FinalizeDocumentJob finalizeDocumentJob)
public Worker(ILogger<Worker> logger, IOptions<WorkerOptions> options, JobStateManager jobStateManager, IServiceScopeFactory scopeFactory)
{
_logger = logger;
_delayMilliseconds = Math.Max(1, configuration.GetValue("Worker:DelayMilliseconds", 1000));
_finalizeDocumentJob = finalizeDocumentJob;
_options = options.Value;
_jobStateManager = jobStateManager;
_scopeFactory = scopeFactory;
}
protected override async Task ExecuteAsync(CancellationToken stoppingToken)
@@ -24,8 +27,14 @@ public class Worker : BackgroundService
_logger.LogInformation("Worker running at: {time}", DateTimeOffset.Now);
}
await _finalizeDocumentJob.ExecuteAsync(stoppingToken);
await Task.Delay(_delayMilliseconds, stoppingToken);
if (_jobStateManager.GetState<FinalizeDocumentJob>() == State.Running)
{
using var scope = _scopeFactory.CreateScope();
var finalizeDocumentJob = scope.ServiceProvider.GetRequiredService<FinalizeDocumentJob>();
await finalizeDocumentJob.ExecuteAsync(stoppingToken);
}
await Task.Delay(_options.DelayMilliseconds, stoppingToken);
}
}
}
}

View File

@@ -2,7 +2,7 @@
"Logging": {
"LogLevel": {
"Default": "Information",
"Microsoft.AspNetCore": "Warning"
"Microsoft.AspNetCore": "Information"
}
}
}

View File

@@ -6,7 +6,24 @@
}
},
"Worker": {
"DelayMilliseconds": 1000
"DelayMilliseconds": 1000,
// InitialJobState: State values are 0 = Running, 1 = Stopped. Defaults to 1 (Stopped) if not specified.
"InitialJobState": {
"FinalizeDocumentJob": 0
}
},
"AllowedHosts": "*"
}
"AllowedHosts": "*",
"SupportedCultures": [ "de-DE", "en-US" ],
"ConnectionStrings": {
"Default": "Server=SDD-VMP04-SQL17\\DD_DEVELOP01;Database=DD_ECM;User Id=sa;Password=dd;Encrypt=false;TrustServerCertificate=True;"
},
"UseWindowsService": false,
"UseCustomKestrelEndpoints": false,
"ServerConfig": {
"Endpoints": {
"Http": {
"Url": "http://localhost:1111"
}
}
}
}

View File

@@ -193,13 +193,17 @@ public static class Extensions
#endregion
#region Envelope
public static CreateEnvelopeCommand CreateEnvelopeCommand(this Faker fake, int userId) => new()
public static CreateEnvelopeCommand CreateEnvelopeCommand(this Faker fake, int userId)
{
Message = fake.Lorem.Paragraph(fake.Random.Number(2, 5)),
Title = fake.Lorem.Words(fake.Random.Number(3, 4)).Join(" "),
UserId = userId,
UseSQLExecutor = false
};
var cmd = new CreateEnvelopeCommand
{
Message = fake.Lorem.Paragraph(fake.Random.Number(2, 5)),
Title = fake.Lorem.Words(fake.Random.Number(3, 4)).Join(" "),
UseSQLExecutor = false
};
cmd.Authorize(userId);
return cmd;
}
public static List<CreateEnvelopeCommand> CreateEnvelopeCommands(this Faker fake, params int[] userIDs)
=> Enumerable.Range(0, userIDs.Length)

View File

@@ -0,0 +1,308 @@
using DigitalData.Core.Exceptions;
using EnvelopeGenerator.Application.Common.Extensions;
using MediatR;
namespace EnvelopeGenerator.Tests.Application;
[TestFixture]
public class MediatorExtensionsTests
{
#region Stub infrastructure
private sealed class StubRequest<TResponse> : IRequest<TResponse?> { }
/// <summary>
/// Minimal <see cref="ISender"/> stub that returns a pre-configured response for any <see cref="ISender.Send{TResponse}"/> call.
/// </summary>
private sealed class StubSender : ISender
{
private readonly object? _response;
public StubSender(object? response) => _response = response;
public Task<TResponse> Send<TResponse>(IRequest<TResponse> request, CancellationToken cancellationToken = default)
{
cancellationToken.ThrowIfCancellationRequested();
return Task.FromResult((TResponse)_response!);
}
public Task Send<TRequest>(TRequest request, CancellationToken cancellationToken = default) where TRequest : IRequest
{
cancellationToken.ThrowIfCancellationRequested();
return Task.CompletedTask;
}
public Task<object?> Send(object request, CancellationToken cancellationToken = default)
{
cancellationToken.ThrowIfCancellationRequested();
return Task.FromResult(_response);
}
public IAsyncEnumerable<TResponse> CreateStream<TResponse>(IStreamRequest<TResponse> request, CancellationToken cancellationToken = default)
=> throw new NotImplementedException();
public IAsyncEnumerable<object?> CreateStream(object request, CancellationToken cancellationToken = default)
=> throw new NotImplementedException();
}
private static ISender CreateSender<T>(T? response) => new StubSender(response);
#endregion
#region Throw non-null scalar
[Test]
public async Task Throw_WithNonNullResponse_ReturnsResponse()
{
var sender = CreateSender<string>("hello");
var request = new StubRequest<string?>();
var result = await sender.GetOr(request).Throw(() => new InvalidOperationException());
Assert.That(result, Is.EqualTo("hello"));
}
#endregion
#region Throw null response
[Test]
public void Throw_WithNullResponse_ThrowsCustomException()
{
var sender = CreateSender<string>(null);
var request = new StubRequest<string?>();
var ex = Assert.ThrowsAsync<InvalidOperationException>(
() => sender.GetOr(request).Throw(() => new InvalidOperationException("custom")));
Assert.That(ex!.Message, Is.EqualTo("custom"));
}
#endregion
#region Throw empty collection
[Test]
public void Throw_WithEmptyList_ThrowsCustomException()
{
var sender = CreateSender<List<string>>(new List<string>());
var request = new StubRequest<List<string>?>();
Assert.ThrowsAsync<ArgumentException>(
() => sender.GetOr(request).Throw(() => new ArgumentException("empty")));
}
#endregion
#region Throw non-empty collection
[Test]
public async Task Throw_WithNonEmptyList_ReturnsResponse()
{
var expected = new List<int> { 1, 2 };
var sender = CreateSender<List<int>>(expected);
var request = new StubRequest<List<int>?>();
var result = await sender.GetOr(request).Throw(() => new InvalidOperationException());
Assert.That(result, Is.EqualTo(expected));
}
#endregion
#region Throw string edge case (string implements IEnumerable)
[Test]
public async Task Throw_WithEmptyString_ReturnsEmptyString()
{
var sender = CreateSender<string>("");
var request = new StubRequest<string?>();
var result = await sender.GetOr(request).Throw(() => new InvalidOperationException("should not throw"));
Assert.That(result, Is.EqualTo(""));
}
#endregion
#region ThrowNotFound non-null scalar
[Test]
public async Task ThrowNotFound_WithNonNullResponse_ReturnsResponse()
{
var sender = CreateSender<string>("hello");
var request = new StubRequest<string?>();
var result = await sender.GetOr(request).ThrowNotFound();
Assert.That(result, Is.EqualTo("hello"));
}
[Test]
public async Task ThrowNotFound_WithExceptionMessage_AndNonNullResponse_ReturnsResponse()
{
var sender = CreateSender<int>(42);
var request = new StubRequest<int?>();
var result = await sender.GetOr(request).ThrowNotFound("not found");
Assert.That(result, Is.EqualTo(42));
}
#endregion
#region ThrowNotFound null response
[Test]
public void ThrowNotFound_WithNullResponse_ThrowsNotFoundException()
{
var sender = CreateSender<string>(null);
var request = new StubRequest<string?>();
Assert.ThrowsAsync<NotFoundException>(() => sender.GetOr(request).ThrowNotFound());
}
[Test]
public void ThrowNotFound_WithNullResponse_AndCustomMessage_ContainsMessage()
{
const string message = "Entity not found";
var sender = CreateSender<string>(null);
var request = new StubRequest<string?>();
var ex = Assert.ThrowsAsync<NotFoundException>(
() => sender.GetOr(request).ThrowNotFound(message));
Assert.That(ex!.Message, Does.Contain(message));
}
[Test]
public void ThrowNotFound_WithNullResponse_HasDefaultMessageWithTypeName()
{
var sender = CreateSender<string>(null);
var request = new StubRequest<string?>();
var ex = Assert.ThrowsAsync<NotFoundException>(() => sender.GetOr(request).ThrowNotFound());
Assert.That(ex!.Message, Does.Contain(nameof(String)));
}
#endregion
#region ThrowNotFound empty collection
[Test]
public void ThrowNotFound_WithEmptyList_ThrowsNotFoundException()
{
var sender = CreateSender<List<string>>(new List<string>());
var request = new StubRequest<List<string>?>();
Assert.ThrowsAsync<NotFoundException>(() => sender.GetOr(request).ThrowNotFound());
}
[Test]
public void ThrowNotFound_WithEmptyArray_ThrowsNotFoundException()
{
var sender = CreateSender<int[]>(Array.Empty<int>());
var request = new StubRequest<int[]?>();
Assert.ThrowsAsync<NotFoundException>(() => sender.GetOr(request).ThrowNotFound());
}
[Test]
public void ThrowNotFound_WithEmptyCollection_AndCustomMessage_ContainsMessage()
{
const string message = "No items found";
var sender = CreateSender<List<int>>(new List<int>());
var request = new StubRequest<List<int>?>();
var ex = Assert.ThrowsAsync<NotFoundException>(
() => sender.GetOr(request).ThrowNotFound(message));
Assert.That(ex!.Message, Does.Contain(message));
}
#endregion
#region ThrowNotFound non-empty collection
[Test]
public async Task ThrowNotFound_WithNonEmptyList_ReturnsResponse()
{
var expected = new List<string> { "a", "b" };
var sender = CreateSender<List<string>>(expected);
var request = new StubRequest<List<string>?>();
var result = await sender.GetOr(request).ThrowNotFound();
Assert.That(result, Is.EqualTo(expected));
}
[Test]
public async Task ThrowNotFound_WithNonEmptyArray_ReturnsResponse()
{
var expected = new[] { 1, 2, 3 };
var sender = CreateSender<int[]>(expected);
var request = new StubRequest<int[]?>();
var result = await sender.GetOr(request).ThrowNotFound();
Assert.That(result, Is.EqualTo(expected));
}
#endregion
#region ThrowInvalidOperation null response
[Test]
public void ThrowInvalidOperation_WithNullResponse_ThrowsInvalidOperationException()
{
var sender = CreateSender<string>(null);
var request = new StubRequest<string?>();
Assert.ThrowsAsync<InvalidOperationException>(
() => sender.GetOr(request).ThrowInvalidOperation());
}
[Test]
public void ThrowInvalidOperation_WithNullResponse_AndCustomMessage_ContainsMessage()
{
const string message = "Something went wrong";
var sender = CreateSender<string>(null);
var request = new StubRequest<string?>();
var ex = Assert.ThrowsAsync<InvalidOperationException>(
() => sender.GetOr(request).ThrowInvalidOperation(message));
Assert.That(ex!.Message, Does.Contain(message));
}
#endregion
#region CancellationToken
[Test]
public void Throw_WithCancelledToken_ThrowsOperationCanceledException()
{
var sender = CreateSender<string>("value");
var request = new StubRequest<string?>();
var cts = new CancellationTokenSource();
cts.Cancel();
Assert.ThrowsAsync<OperationCanceledException>(
() => sender.GetOr(request, cts.Token).Throw(() => new InvalidOperationException()));
}
[Test]
public void ThrowNotFound_WithCancelledToken_ThrowsOperationCanceledException()
{
var sender = CreateSender<string>("value");
var request = new StubRequest<string?>();
var cts = new CancellationTokenSource();
cts.Cancel();
Assert.ThrowsAsync<OperationCanceledException>(
() => sender.GetOr(request, cts.Token).ThrowNotFound());
}
#endregion
}