Browse Source

更新实体

master
赵新宇 1 week ago
parent
commit
2e6bb8e24c
  1. 10
      API/TaskManager.Entity/Entity.cs
  2. 17
      API/TaskManager.EntityFramework/JobDbContext.cs
  3. 2
      API/Wood.Admin.WebApi/Properties/PublishProfiles/FolderProfile.pubxml.user
  4. 2
      API/Wood.Admin.WebApi/Startup.cs
  5. 2
      API/Wood.Service/Commons/CommonService.cs
  6. 12
      API/Wood.Service/Controllers/CheryRecurringJobInputPageExtendController.cs
  7. 2
      API/Wood.Service/Controllers/CherySupplierSinvDataService.cs
  8. 2
      API/Wood.Service/Controllers/TaskConifgureController.cs

10
API/TaskManager.Entity/Entity.cs

@ -191,16 +191,6 @@ namespace TaskManager.Entity
[ExporterHeader(DisplayName = "任务ID")] [ExporterHeader(DisplayName = "任务ID")]
public Guid TaskId { get; set; } public Guid TaskId { get; set; }
/// <summary>
/// 创建时间
/// </summary>
[ExporterHeader(DisplayName = "创建时间")]
public DateTime? CreationTime { set; get; }
/// <summary>
/// 备注
/// </summary>
[ExporterHeader(DisplayName = "备注")]
public string? Remark { get; set; }
} }

17
API/TaskManager.EntityFramework/JobDbContext.cs

@ -66,7 +66,20 @@ namespace TaskManager.EntityFramework
// // 配置SQL Server连接 // // 配置SQL Server连接
// optionsBuilder.UseSqlServer("Server=192.168.1.228;Database=TaskManager;User ID=sa;Password=ChangkeTec@2021;TrustServerCertificate=True"); // optionsBuilder.UseSqlServer("Server=192.168.1.228;Database=TaskManager;User ID=sa;Password=ChangkeTec@2021;TrustServerCertificate=True");
//} //}
optionsBuilder.UseSqlServer("Server = 192.168.1.228; Database = TaskManager2; User ID = sa; Password = ChangkeTec@2021; TrustServerCertificate = True"); //#if DEBUG
// optionsBuilder.UseSqlServer("Server = 192.168.1.228; Database = TaskManager2; User ID = sa; Password = ChangkeTec@2021; TrustServerCertificate = True");
//#else
// optionsBuilder.UseSqlServer(GlobalContext.SystemConfig.CustomerDb);
//#endif
optionsBuilder.UseSqlServer(GlobalContext.SystemConfig.CustomerDb);
} }
/// <summary> /// <summary>
/// 来料检验数据 /// 来料检验数据
@ -494,7 +507,7 @@ namespace TaskManager.EntityFramework
//控制项代码 //控制项代码
b.Property(e => e.VendorFieldCode).HasColumnType("VARCHAR").HasMaxLength(32).IsRequired(); b.Property(e => e.VendorFieldCode).HasColumnType("VARCHAR").HasMaxLength(32).IsRequired();
//库存有效日期,格式(yyyy-MM-ddHH:mm:ss) //库存有效日期,格式(yyyy-MM-ddHH:mm:ss)
b.Property(e => e.DeadLine).HasColumnType("VARCHAR").HasMaxLength(10).IsRequired(); b.Property(e => e.DeadLine).HasColumnType("VARCHAR").HasMaxLength(30).IsRequired();
b.Property(e => e.UId).HasColumnType("bigint").ValueGeneratedOnAdd().IsRequired(); b.Property(e => e.UId).HasColumnType("bigint").ValueGeneratedOnAdd().IsRequired();
b.Property(e => e.Remark).HasColumnType("NVarchar").HasMaxLength(500).IsRequired(false); b.Property(e => e.Remark).HasColumnType("NVarchar").HasMaxLength(500).IsRequired(false);
b.Property(e => e.ReadState).HasDefaultValue(false); b.Property(e => e.ReadState).HasDefaultValue(false);

2
API/Wood.Admin.WebApi/Properties/PublishProfiles/FolderProfile.pubxml.user

@ -3,7 +3,7 @@
<Project> <Project>
<PropertyGroup> <PropertyGroup>
<_PublishTargetUrl>D:\QRAPI20250528\API\Wood.Admin.WebApi\bin\Release\net8.0\publish\</_PublishTargetUrl> <_PublishTargetUrl>D:\QRAPI20250528\API\Wood.Admin.WebApi\bin\Release\net8.0\publish\</_PublishTargetUrl>
<History>True|2025-06-19T09:18:07.6086155Z||;</History> <History>True|2025-06-23T09:18:30.1990173Z||;True|2025-06-23T17:12:33.6485743+08:00||;True|2025-06-19T17:18:07.6086155+08:00||;</History>
<LastFailureDetails /> <LastFailureDetails />
</PropertyGroup> </PropertyGroup>
</Project> </Project>

2
API/Wood.Admin.WebApi/Startup.cs

@ -139,7 +139,7 @@ namespace Wood.Admin.WebApi
//异常处理 //异常处理
options.Filters.Add(typeof(ApiExceptionFilter)); options.Filters.Add(typeof(ApiExceptionFilter));
//性能记录,日志记录 //性能记录,日志记录
options.Filters.Add(typeof(ApiPerformanceLoggingFilter)); //options.Filters.Add(typeof(ApiPerformanceLoggingFilter));
//结果包装 //结果包装
options.Filters.Add(typeof(ApiResponseWrapperFilter)); options.Filters.Add(typeof(ApiResponseWrapperFilter));
}) })

2
API/Wood.Service/Commons/CommonService.cs

@ -1,6 +1,7 @@
using Microsoft.AspNetCore.Mvc; using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Configuration; using Microsoft.Extensions.Configuration;
using OfficeOpenXml.FormulaParsing.Excel.Functions.Text; using OfficeOpenXml.FormulaParsing.Excel.Functions.Text;
using SqlSugar;
using System; using System;
using System.Collections.Generic; using System.Collections.Generic;
using System.Linq; using System.Linq;
@ -43,6 +44,7 @@ namespace Wood.Service
TaskSub taskSub = new TaskSub(); TaskSub taskSub = new TaskSub();
taskSub.TableName = taskConfigureObj.TableName; //关联的数据表名称(如:订单表、用户表等,可为空) taskSub.TableName = taskConfigureObj.TableName; //关联的数据表名称(如:订单表、用户表等,可为空)
taskSub.TaskName = taskConfigureObj.TaskName; //任务名称(用于业务层面标识任务,如:数据同步任务、报表生成任务) taskSub.TaskName = taskConfigureObj.TaskName; //任务名称(用于业务层面标识任务,如:数据同步任务、报表生成任务)

12
API/Wood.Service/Controllers/CheryRecurringJobInputPageExtendController.cs

@ -152,7 +152,6 @@ namespace TaskManager.Controllers
var content = await Post(Url, Path, inputjson,taskId,version); var content = await Post(Url, Path, inputjson,taskId,version);
if (!string.IsNullOrEmpty(content)) if (!string.IsNullOrEmpty(content))
{ {
var options = new JsonSerializerOptions var options = new JsonSerializerOptions
{ {
PropertyNamingPolicy = JsonNamingPolicy.CamelCase, PropertyNamingPolicy = JsonNamingPolicy.CamelCase,
@ -174,10 +173,7 @@ namespace TaskManager.Controllers
await _logger.AddError($"调用接口无返回值错误{ex.Message}", TaskName,taskId,version); await _logger.AddError($"调用接口无返回值错误{ex.Message}", TaskName,taskId,version);
return null; return null;
} }
} }
public static string GenerateRandomStringWith8EG() public static string GenerateRandomStringWith8EG()
{ {
const string chars = "ABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789"; const string chars = "ABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789";
@ -266,10 +262,14 @@ namespace TaskManager.Controllers
{ {
TLOGS log = new TLOGS(); TLOGS log = new TLOGS();
log.InjectFrom(itm); log.InjectFrom(itm);
log.RequestDate = requestDate;
log.TaskId = taskId;
log.WriteState = true;
log.ReadState = true;
logs.Add(log); logs.Add(log);
} }
await _jobDbContext.BulkInsertAsync(logs); await _jobDbContext.BulkInsertAsync(logs);
try try
{ {
var createtask = new TaskSub(); var createtask = new TaskSub();
@ -285,6 +285,8 @@ namespace TaskManager.Controllers
createtask.CreateUser = "admin"; createtask.CreateUser = "admin";
createtask.CreationTime = DateTime.Now; createtask.CreationTime = DateTime.Now;
createtask.SyncedPageCount = i; createtask.SyncedPageCount = i;
createtask.ReadState = true;
createtask.WriteState = true;
await _jobDbContext.AddAsync(task); await _jobDbContext.AddAsync(task);
// 提交事务 // 提交事务
await transaction.CommitAsync(); await transaction.CommitAsync();

2
API/Wood.Service/Controllers/CherySupplierSinvDataService.cs

@ -6,7 +6,7 @@ using TaskManager.EntityFramework;
namespace TaskManager.Controllers namespace TaskManager.Controllers
{ {
public class CherySupplierSinvDataService : CheryRecurringJobInputPageExtendController<SUPPLIER_SINV_DATA, SUPPLIER_SINV_DATA_DTO, SUPPLIER_SINV_DATA_LOGS> public class CherySupplierSinvDataService : CheryRecurringJobInputPageController<SUPPLIER_SINV_DATA, SUPPLIER_SINV_DATA_DTO, SUPPLIER_SINV_DATA_LOGS>
{ {
public CherySupplierSinvDataService(HttpClient httpClient, JobDbContext jobDbContext, LogController log, IRepository<SUPPLIER_SINV_DATA> repository) : base(httpClient, jobDbContext, log, repository) public CherySupplierSinvDataService(HttpClient httpClient, JobDbContext jobDbContext, LogController log, IRepository<SUPPLIER_SINV_DATA> repository) : base(httpClient, jobDbContext, log, repository)
{ {

2
API/Wood.Service/Controllers/TaskConifgureController.cs

@ -217,7 +217,7 @@ namespace TaskManager.Controllers
case "物料主数据": case "物料主数据":
BackgroundJob.Schedule<CherySupplierProMaterialDataService>( BackgroundJob.Schedule<CherySupplierProMaterialDataService>(
//"maaterialdata", // 注意:这里可能存在拼写错误,原始代码中也有 //"maaterialdata", // 注意:这里可能存在拼写错误,原始代码中也有
x => x.CustomInvokeAsync(taskName, client, taskId), x => x.CustomInvokeAsync(taskName, client,taskId),
TimeSpan.FromSeconds(10) TimeSpan.FromSeconds(10)
); );
break; break;

Loading…
Cancel
Save