update

1 year ago · c8d5316932
13 changed files with 6103 additions and 48 deletions
--- a/code/src/Modules/SettleAccount/host/SettleAccount.HttpApi.Host/wwwroot/models/compare/compare.js
+++ b/code/src/Modules/SettleAccount/host/SettleAccount.HttpApi.Host/wwwroot/models/compare/compare.js
@ -10,6 +10,11 @@ const defaultCompareSchema = {
      title: "发运日期",
      type: "array",
      input: "datetimerange",
+      rules: [
+        {
+          required: true,
+        },
+      ],
    },
    downLineDateTime: {
      title: "下线日期",
--- a/code/src/Modules/SettleAccount/src/SettleAccount.Application/Entities/BQ/Syncs/PendingDeductionService.cs
+++ b/code/src/Modules/SettleAccount/src/SettleAccount.Application/Entities/BQ/Syncs/PendingDeductionService.cs
@ -143,9 +143,7 @@ public class PendingDeductionService : ApplicationService, ITransientDependency,

                        foreach (var item in lst)
                        {
-                            item.SetId(GuidGenerator.Create());
-
-                            var message = new VmiMessage(Guid.NewGuid())
+                            var message = new VmiMessage
                            {
                                Message = System.Text.Json.JsonSerializer.Serialize(item),
                            };
--- a/code/src/Modules/SettleAccount/src/SettleAccount.Application/Entities/BQ/Syncs/SeSyncExtendManager.cs
+++ b/code/src/Modules/SettleAccount/src/SettleAccount.Application/Entities/BQ/Syncs/SeSyncExtendManager.cs
@ -58,7 +58,7 @@ public class SeSyncExtendManager : DomainService
        var returnSeDetails = seDetails.FindAll(t => t.TransType == EnumDelTransType.退货);
        var dateTimeNow = DateTime.Now;

-        var vmiLogList = deliverSeDetails.Select(t => new VmiLog(Guid.NewGuid())
+        var vmiLogList = deliverSeDetails.Select(t => new VmiLog
        {
            LogType = VmiLogType.Type100,
            ChangedQty = t.Qty,
@ -86,7 +86,7 @@ public class SeSyncExtendManager : DomainService
            VinCode = t.VinCode,
            factory = t.Factory
        }).ToList();
-        var returnVmiLogList = returnSeDetails.Select(t => new VmiLog(Guid.NewGuid())
+        var returnVmiLogList = returnSeDetails.Select(t => new VmiLog
        {
            LogType = VmiLogType.Type400,
            ChangedQty = t.Qty,
@ -127,7 +127,7 @@ public class SeSyncExtendManager : DomainService
        var returnSeDetails = seDetails.FindAll(t => t.TransType == EnumDelTransType.退货);
        var dateTimeNow = DateTime.Now;

-        var vmiLogList = deliverSeDetails.Select(t => new VmiLog(Guid.NewGuid())
+        var vmiLogList = deliverSeDetails.Select(t => new VmiLog
        {
            LogType = VmiLogType.Type100,
            ChangedQty = t.Qty,
@ -146,7 +146,7 @@ public class SeSyncExtendManager : DomainService
            ReMark = t.Remark,
            RealPartCode = t.PartCode
        }).ToList();
-        var returnVmiLogList = returnSeDetails.Select(t => new VmiLog(Guid.NewGuid())
+        var returnVmiLogList = returnSeDetails.Select(t => new VmiLog
        {
            LogType = VmiLogType.Type400,
            ChangedQty = t.Qty,
@ -183,7 +183,7 @@ public class SeSyncExtendManager : DomainService
    /// </summary>
    private async Task SaveVmiMessagesAsync(List<VmiLog> vmiLogs)
    {
-        var vmiMessages = vmiLogs.Select(t => new VmiMessage(Guid.NewGuid())
+        var vmiMessages = vmiLogs.Select(t => new VmiMessage
        {
            Message = JsonConvert.SerializeObject(t)
        }).ToList();
--- a/code/src/Modules/SettleAccount/src/SettleAccount.Application/Entities/BQ/VmiAppService.cs
+++ b/code/src/Modules/SettleAccount/src/SettleAccount.Application/Entities/BQ/VmiAppService.cs
@ -34,9 +34,9 @@ using Volo.Abp.Validation;
 using Win.Sfs.BaseData.ImportExcelCommon;
 using Win.Sfs.SettleAccount.Entities.BQ.Dtos;
 using Win.Sfs.SettleAccount.Entities.BQ.Vmi;
+using Win.Sfs.Shared;
 using Win.Sfs.Shared.Filter;
 using Win.Sfs.Shared.RepositoryBase;
-using Win.Sfs.Shared;

 namespace Win.Sfs.SettleAccount.Entities.BQ;

@ -333,7 +333,7 @@ public class VmiAppService : Controller, IApplicationService, IJobService, ITran
            var options = new DbContextOptionsBuilder<SettleAccountDbContext>().UseSqlServer(connection).Options;
            using var context = new SettleAccountDbContext(options);
            context.Database.UseTransaction(transaction);
-            log.SetId(this._guidGenerator.Create());
+            log.ChangedTime = log.Id.ToDateTime().Value;
            if (log.ChangedQty >= decimal.Zero)
            {
                log.Qty = log.ChangedQty;
@ -349,7 +349,7 @@ public class VmiAppService : Controller, IApplicationService, IJobService, ITran
            log.ChangedBy = this._currentUser.UserName;
            log.ChangedTime = DateTime.Now;
            context.Set<VmiLog>().Add(log);
-            context.Set<VmiMessage>().Add(new VmiMessage(this._guidGenerator.Create()) { Message = JsonSerializer.Serialize(log) });
+            context.Set<VmiMessage>().Add(new VmiMessage { Message = JsonSerializer.Serialize(log) });
            context.SaveChanges();
            transaction.Commit();
            return new OkResult();
--- a/code/src/Modules/SettleAccount/src/SettleAccount.Application/Entities/BQ/VmiAsyncBalanceService.cs
+++ b/code/src/Modules/SettleAccount/src/SettleAccount.Application/Entities/BQ/VmiAsyncBalanceService.cs
@ -30,7 +30,7 @@ public class VmiAsyncBalanceService : ApplicationService, IJobService, ITransien

    public async Task Invoke(IServiceProvider serviceProvider)
    {
-        for (var i = 0; i < 50; i++)
+        for (var i = 0; i < 100; i++)
        {
            var connectionString = serviceProvider.GetRequiredService<IConfiguration>().GetConnectionString("SettleAccountService");
            using var connection = new SqlConnection(connectionString);
@ -81,7 +81,7 @@ public class VmiAsyncBalanceService : ApplicationService, IJobService, ITransien
                    o.Configcode == log.Configcode);
                    if (balance == null)
                    {
-                        balance = new VmiBalance(GuidGenerator.Create());
+                        balance = new VmiBalance();
                        balance.InjectFrom(log);
                        await repo.AddAsync(balance).ConfigureAwait(false);
                        log.InjectFrom(balance);
--- a/code/src/Modules/SettleAccount/src/SettleAccount.Domain/Entities/BQ/Vmi/VmiBalance.cs
+++ b/code/src/Modules/SettleAccount/src/SettleAccount.Domain/Entities/BQ/Vmi/VmiBalance.cs
@ -6,6 +6,8 @@ public class VmiBalance : VmiBalanceBase
 {
    public VmiBalance()
    {
+        Id = SequentialGuid.SequentialSqlGuidGenerator.Instance.NewGuid();
+        CreatedTime = Id.ToDateTime().Value;
        ConcurrencyStamp = Guid.NewGuid().ToString("N");
    }

--- a/code/src/Modules/SettleAccount/src/SettleAccount.Domain/Entities/BQ/Vmi/VmiLog.cs
+++ b/code/src/Modules/SettleAccount/src/SettleAccount.Domain/Entities/BQ/Vmi/VmiLog.cs
@ -7,15 +7,12 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Vmi;
 /// <summary>
 /// 库存事务
 /// </summary>
-public class VmiLog : VmiBalanceBase,IValidatableObject
+public class VmiLog : VmiBalanceBase, IValidatableObject
 {
    public VmiLog()
    {
-        ConcurrencyStamp = Guid.NewGuid().ToString("N");
-    }
-    
-    public VmiLog(Guid id) : base(id)
-    {
+        Id = SequentialGuid.SequentialSqlGuidGenerator.Instance.NewGuid();
+        ChangedTime = Id.ToDateTime().Value;
        ConcurrencyStamp = Guid.NewGuid().ToString("N");
    }

@ -26,9 +23,9 @@ public class VmiLog : VmiBalanceBase,IValidatableObject

    public IEnumerable<ValidationResult> Validate(ValidationContext validationContext)
    {
-        if(string.IsNullOrEmpty(this.RealPartCode))
+        if (string.IsNullOrEmpty(this.RealPartCode))
        {
-            yield return new ValidationResult("LU零件号不能为空",new string[] { nameof(this.RealPartCode)});
+            yield return new ValidationResult("LU零件号不能为空", new string[] { nameof(this.RealPartCode) });
        }
        if (string.IsNullOrEmpty(this.ErpToLoc))
        {
@ -47,7 +44,7 @@ public class VmiLog : VmiBalanceBase,IValidatableObject
    public string ChangedNumber { get; set; }

    [Display(Name = "变动时间", Order = 2)]
-    public DateTime ChangedTime { get; set; } = DateTime.Now;
+    public DateTime ChangedTime { get; set; }

    [Display(Name = "变动类型", Order = 3)]
    public VmiType ChangedType { get; set; }
--- a/code/src/Modules/SettleAccount/src/SettleAccount.Domain/Entities/BQ/Vmi/VmiMessage.cs
+++ b/code/src/Modules/SettleAccount/src/SettleAccount.Domain/Entities/BQ/Vmi/VmiMessage.cs
@ -7,16 +7,14 @@ public class VmiMessage : Entity<Guid>
 {
    public VmiMessage()
    {
+        Id = SequentialGuid.SequentialSqlGuidGenerator.Instance.NewGuid();
+        CreatedTime = Id.ToDateTime().Value;
        ConcurrencyStamp = Guid.NewGuid().ToString("N");
    }

-    public VmiMessage(Guid id) : base(id)
-    {
-        ConcurrencyStamp = Guid.NewGuid().ToString("N");
-    }
    public long Number { get; set; }
    public string Message { get; set; }
    public bool isConsumed { get; set; }
-    public DateTime CreatedTime { get; set; } = DateTime.Now;
+    public DateTime CreatedTime { get; set; }
    public string ConcurrencyStamp { get; set; }
 }
--- a/code/src/Modules/SettleAccount/src/SettleAccount.EntityFrameworkCore/EntityFrameworkCore/SettleAccountDbContextModelCreatingExtensions.cs
+++ b/code/src/Modules/SettleAccount/src/SettleAccount.EntityFrameworkCore/EntityFrameworkCore/SettleAccountDbContextModelCreatingExtensions.cs
@ -1326,6 +1326,7 @@ namespace Win.Sfs.SettleAccount
                    o.factory,
                    o.Configcode
                })).IsUnique();
+                b.Property(o => o.RealPartCode).HasMaxLength(50);
            }));

            builder.Entity<VmiLog>(b =>
@ -1336,6 +1337,7 @@ namespace Win.Sfs.SettleAccount
                b.Property(o => o.CreatedTime).HasDefaultValueSql("getdate()").ValueGeneratedOnAdd().Metadata.SetAfterSaveBehavior(PropertySaveBehavior.Ignore);
                b.Property(o => o.UpdatedTime).HasDefaultValueSql("getdate()").ValueGeneratedOnAddOrUpdate().Metadata.SetAfterSaveBehavior(PropertySaveBehavior.Ignore);
                b.HasIndex(o => o.BillTime).IsClustered();
+                b.Property(o => o.RealPartCode).HasMaxLength(50);
            });

            builder.Entity<VmiReplenished>(b =>
@ -1343,6 +1345,7 @@ namespace Win.Sfs.SettleAccount
                b.ToTable($"{options.TablePrefix}_VmiReplenished", options.Schema);
                b.ConfigureByConvention();
                b.HasIndex(o => o.BillTime).IsClustered();
+                b.Property(o => o.RealPartCode).HasMaxLength(50);
            });

            builder.Entity<VmiSnapshot>(b =>
@ -1352,9 +1355,9 @@ namespace Win.Sfs.SettleAccount
            });

            //seed
-            builder.Entity<JobItem>().HasData(new JobItem("vmi".ToGuid()) { Name = "库存快照备份", Cron = "0 0 8 26 *", Service = "Win.Sfs.SettleAccount.Entities.BQ.VmiAppService" });
-            builder.Entity<JobItem>().HasData(new JobItem("vmi.balance".ToGuid()) { Name = "同步结算库存", Cron = "0 0/1 * * * ?", Service = "Win.Sfs.SettleAccount.Entities.BQ.VmiAsyncBalanceService" });
-            builder.Entity<JobItem>().HasData(new JobItem("vmi.message".ToGuid()) { Name = "事务消息监控", Cron = "0 0/1 * * * ?", Service = "Win.Sfs.SettleAccount.Entities.BQ.VmiAsyncMessageService" });
+            builder.Entity<JobItem>().HasData(new JobItem("vmi".ToGuid()) { Name = "时点库存备份", Cron = "0 0 8 26 *", Service = "Win.Sfs.SettleAccount.Entities.BQ.VmiAppService" });
+            builder.Entity<JobItem>().HasData(new JobItem("vmi.balance".ToGuid()) { Name = "库存余额同步", Cron = "0 0/1 * * * ?", Service = "Win.Sfs.SettleAccount.Entities.BQ.VmiAsyncBalanceService" });
+            builder.Entity<JobItem>().HasData(new JobItem("vmi.message".ToGuid()) { Name = "库存事务消息监控", Cron = "0 0/1 * * * ?", Service = "Win.Sfs.SettleAccount.Entities.BQ.VmiAsyncMessageService" });
            builder.Entity<JobItem>().HasData(new JobItem("JisBBACSeSync".ToGuid()) { Name = "JisBBAC发运数据同步", Cron = "0 0/30 * * * ? ", Service = "Win.Sfs.SettleAccount.Entities.BQ.Syncs.JisBBACSeSyncAppService" });
            builder.Entity<JobItem>().HasData(new JobItem("JisHBPOSeSync".ToGuid()) { Name = "JisHBPO发运数据同步", Cron = "0 0/30 * * * ? ", Service = "Win.Sfs.SettleAccount.Entities.BQ.Syncs.JisHBPOSeSyncAppService" });
            builder.Entity<JobItem>().HasData(new JobItem("MaiDanBBACSeSync".ToGuid()) { Name = "买单件BBAC发运数据同步", Cron = "0 0/30 * * * ? ", Service = "Win.Sfs.SettleAccount.Entities.BQ.Syncs.MaiDanBBACSeSyncAppService" });
--- a/code/src/Modules/SettleAccount/src/SettleAccount.EntityFrameworkCore/Migrations/20230831024215_vmi19.Designer.cs
+++ b/code/src/Modules/SettleAccount/src/SettleAccount.EntityFrameworkCore/Migrations/20230831024215_vmi19.Designer.cs
--- a/code/src/Modules/SettleAccount/src/SettleAccount.EntityFrameworkCore/Migrations/20230831024215_vmi19.cs
+++ b/code/src/Modules/SettleAccount/src/SettleAccount.EntityFrameworkCore/Migrations/20230831024215_vmi19.cs
@ -0,0 +1,228 @@
+using System;
+using Microsoft.EntityFrameworkCore.Migrations;
+
+namespace Win.Sfs.SettleAccount.Migrations
+{
+    public partial class vmi19 : Migration
+    {
+        protected override void Up(MigrationBuilder migrationBuilder)
+        {
+            migrationBuilder.AlterColumn<string>(
+                name: "RealPartCode",
+                table: "Set_VmiReplenished",
+                type: "nvarchar(50)",
+                maxLength: 50,
+                nullable: true,
+                oldClrType: typeof(string),
+                oldType: "nvarchar(max)",
+                oldNullable: true);
+
+            migrationBuilder.AlterColumn<string>(
+                name: "RealPartCode",
+                table: "Set_VmiLog",
+                type: "nvarchar(50)",
+                maxLength: 50,
+                nullable: true,
+                oldClrType: typeof(string),
+                oldType: "nvarchar(max)",
+                oldNullable: true);
+
+            migrationBuilder.AlterColumn<string>(
+                name: "RealPartCode",
+                table: "Set_VmiBalance",
+                type: "nvarchar(50)",
+                maxLength: 50,
+                nullable: true,
+                oldClrType: typeof(string),
+                oldType: "nvarchar(450)",
+                oldNullable: true);
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("185c5968-e02b-267e-db2f-225fccfc9716"),
+                columns: new[] { "ConcurrencyStamp", "Name" },
+                values: new object[] { "89ee40808b37440e89bc3e3c9c0312a7", "库存余额同步" });
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("1bb02f67-ed05-6cc1-1507-502e8f6c7a31"),
+                columns: new[] { "ConcurrencyStamp", "Name" },
+                values: new object[] { "b9efd317f87e4288841ddcd9fef8f6a2", "库存事务消息监控" });
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("49b1da12-418c-544d-fe8b-be7e5b572452"),
+                column: "ConcurrencyStamp",
+                value: "862d578df0fe406995bc827f9feaae60");
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("6f68fc8f-b058-c3f4-e07d-722c61f3f7fa"),
+                column: "ConcurrencyStamp",
+                value: "dc1523b4145f4c60a1e9543aa36da361");
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("7a0dc087-a859-5863-eb6e-56f588bd779e"),
+                column: "ConcurrencyStamp",
+                value: "76d675a5b6d644ef8ec3358006afcb36");
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("8f7dc23d-e2e9-3691-cfe9-545bb958e3f2"),
+                column: "ConcurrencyStamp",
+                value: "658f74bf334f4a34a3fb10eaf00a840a");
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("b9b9c79f-4894-474b-4f67-b1ec121c41e5"),
+                column: "ConcurrencyStamp",
+                value: "1f52b09ccce24e3fb30c5549b19b23e4");
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("c09c23ea-815f-1b43-4476-2365a8d9a60b"),
+                column: "ConcurrencyStamp",
+                value: "5ebb150f3f9e4ccd89d5fab0a6dde4e4");
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("c1f71240-1b81-0107-8b23-ddc9811a3efe"),
+                column: "ConcurrencyStamp",
+                value: "71311c84551343b099c049672a4c421f");
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("ef3d8e8a-a88e-ca1f-e615-714c6bc48824"),
+                columns: new[] { "ConcurrencyStamp", "Name" },
+                values: new object[] { "681ede5c262642f1a02d7a67dbd83d1b", "时点库存备份" });
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("f306b380-47e5-5c01-b902-67ca4113a8f4"),
+                column: "ConcurrencyStamp",
+                value: "eb2e56c9379e4cb0b0f0f5f0bc8d4292");
+        }
+
+        protected override void Down(MigrationBuilder migrationBuilder)
+        {
+            migrationBuilder.AlterColumn<string>(
+                name: "RealPartCode",
+                table: "Set_VmiReplenished",
+                type: "nvarchar(max)",
+                nullable: true,
+                oldClrType: typeof(string),
+                oldType: "nvarchar(50)",
+                oldMaxLength: 50,
+                oldNullable: true);
+
+            migrationBuilder.AlterColumn<string>(
+                name: "RealPartCode",
+                table: "Set_VmiLog",
+                type: "nvarchar(max)",
+                nullable: true,
+                oldClrType: typeof(string),
+                oldType: "nvarchar(50)",
+                oldMaxLength: 50,
+                oldNullable: true);
+
+            migrationBuilder.AlterColumn<string>(
+                name: "RealPartCode",
+                table: "Set_VmiBalance",
+                type: "nvarchar(450)",
+                nullable: true,
+                oldClrType: typeof(string),
+                oldType: "nvarchar(50)",
+                oldMaxLength: 50,
+                oldNullable: true);
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("185c5968-e02b-267e-db2f-225fccfc9716"),
+                columns: new[] { "ConcurrencyStamp", "Name" },
+                values: new object[] { "64c6af2dbd034e919161ff37304b57b0", "同步结算库存" });
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("1bb02f67-ed05-6cc1-1507-502e8f6c7a31"),
+                columns: new[] { "ConcurrencyStamp", "Name" },
+                values: new object[] { "087376a7732a4f0caec36a83389a856d", "事务消息监控" });
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("49b1da12-418c-544d-fe8b-be7e5b572452"),
+                column: "ConcurrencyStamp",
+                value: "e6a18e47a9d0467ba66dfb6a70ae8f80");
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("6f68fc8f-b058-c3f4-e07d-722c61f3f7fa"),
+                column: "ConcurrencyStamp",
+                value: "6c08bd3ad65b4d29b613fe0a72015cc2");
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("7a0dc087-a859-5863-eb6e-56f588bd779e"),
+                column: "ConcurrencyStamp",
+                value: "51f7bc3b725847c3b3bc7f1702e775d7");
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("8f7dc23d-e2e9-3691-cfe9-545bb958e3f2"),
+                column: "ConcurrencyStamp",
+                value: "2a423514ae5e4c19a4524fa4b675c28e");
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("b9b9c79f-4894-474b-4f67-b1ec121c41e5"),
+                column: "ConcurrencyStamp",
+                value: "11992367052c4b459c68966b7fab6b13");
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("c09c23ea-815f-1b43-4476-2365a8d9a60b"),
+                column: "ConcurrencyStamp",
+                value: "6c75a4d283954fbc895242d9405340e0");
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("c1f71240-1b81-0107-8b23-ddc9811a3efe"),
+                column: "ConcurrencyStamp",
+                value: "ecb2819e7667499295cea61d7bf4eae3");
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("ef3d8e8a-a88e-ca1f-e615-714c6bc48824"),
+                columns: new[] { "ConcurrencyStamp", "Name" },
+                values: new object[] { "466f09814b2d4da1988a382e45ce2601", "库存快照备份" });
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("f306b380-47e5-5c01-b902-67ca4113a8f4"),
+                column: "ConcurrencyStamp",
+                value: "1d2d6618d5644fafaab03c543f178128");
+        }
+    }
+}
--- a/code/src/Modules/SettleAccount/src/SettleAccount.EntityFrameworkCore/Migrations/SettleAccountDbContextModelSnapshot.cs
+++ b/code/src/Modules/SettleAccount/src/SettleAccount.EntityFrameworkCore/Migrations/SettleAccountDbContextModelSnapshot.cs
@ -4453,37 +4453,37 @@ namespace Win.Sfs.SettleAccount.Migrations
                        new
                        {
                            Id = new Guid("ef3d8e8a-a88e-ca1f-e615-714c6bc48824"),
-                            ConcurrencyStamp = "466f09814b2d4da1988a382e45ce2601",
+                            ConcurrencyStamp = "681ede5c262642f1a02d7a67dbd83d1b",
                            Cron = "0 0 8 26 *",
                            IsDisabled = false,
                            IsRunning = false,
-                            Name = "库存快照备份",
+                            Name = "时点库存备份",
                            Service = "Win.Sfs.SettleAccount.Entities.BQ.VmiAppService"
                        },
                        new
                        {
                            Id = new Guid("185c5968-e02b-267e-db2f-225fccfc9716"),
-                            ConcurrencyStamp = "64c6af2dbd034e919161ff37304b57b0",
+                            ConcurrencyStamp = "89ee40808b37440e89bc3e3c9c0312a7",
                            Cron = "0 0/1 * * * ?",
                            IsDisabled = false,
                            IsRunning = false,
-                            Name = "同步结算库存",
+                            Name = "库存余额同步",
                            Service = "Win.Sfs.SettleAccount.Entities.BQ.VmiAsyncBalanceService"
                        },
                        new
                        {
                            Id = new Guid("1bb02f67-ed05-6cc1-1507-502e8f6c7a31"),
-                            ConcurrencyStamp = "087376a7732a4f0caec36a83389a856d",
+                            ConcurrencyStamp = "b9efd317f87e4288841ddcd9fef8f6a2",
                            Cron = "0 0/1 * * * ?",
                            IsDisabled = false,
                            IsRunning = false,
-                            Name = "事务消息监控",
+                            Name = "库存事务消息监控",
                            Service = "Win.Sfs.SettleAccount.Entities.BQ.VmiAsyncMessageService"
                        },
                        new
                        {
                            Id = new Guid("b9b9c79f-4894-474b-4f67-b1ec121c41e5"),
-                            ConcurrencyStamp = "11992367052c4b459c68966b7fab6b13",
+                            ConcurrencyStamp = "1f52b09ccce24e3fb30c5549b19b23e4",
                            Cron = "0 0/30 * * * ? ",
                            IsDisabled = false,
                            IsRunning = false,
@ -4493,7 +4493,7 @@ namespace Win.Sfs.SettleAccount.Migrations
                        new
                        {
                            Id = new Guid("49b1da12-418c-544d-fe8b-be7e5b572452"),
-                            ConcurrencyStamp = "e6a18e47a9d0467ba66dfb6a70ae8f80",
+                            ConcurrencyStamp = "862d578df0fe406995bc827f9feaae60",
                            Cron = "0 0/30 * * * ? ",
                            IsDisabled = false,
                            IsRunning = false,
@ -4503,7 +4503,7 @@ namespace Win.Sfs.SettleAccount.Migrations
                        new
                        {
                            Id = new Guid("7a0dc087-a859-5863-eb6e-56f588bd779e"),
-                            ConcurrencyStamp = "51f7bc3b725847c3b3bc7f1702e775d7",
+                            ConcurrencyStamp = "76d675a5b6d644ef8ec3358006afcb36",
                            Cron = "0 0/30 * * * ? ",
                            IsDisabled = false,
                            IsRunning = false,
@ -4513,7 +4513,7 @@ namespace Win.Sfs.SettleAccount.Migrations
                        new
                        {
                            Id = new Guid("6f68fc8f-b058-c3f4-e07d-722c61f3f7fa"),
-                            ConcurrencyStamp = "6c08bd3ad65b4d29b613fe0a72015cc2",
+                            ConcurrencyStamp = "dc1523b4145f4c60a1e9543aa36da361",
                            Cron = "0 0/30 * * * ? ",
                            IsDisabled = false,
                            IsRunning = false,
@ -4523,7 +4523,7 @@ namespace Win.Sfs.SettleAccount.Migrations
                        new
                        {
                            Id = new Guid("f306b380-47e5-5c01-b902-67ca4113a8f4"),
-                            ConcurrencyStamp = "1d2d6618d5644fafaab03c543f178128",
+                            ConcurrencyStamp = "eb2e56c9379e4cb0b0f0f5f0bc8d4292",
                            Cron = "0 0/30 * * * ? ",
                            IsDisabled = false,
                            IsRunning = false,
@ -4533,7 +4533,7 @@ namespace Win.Sfs.SettleAccount.Migrations
                        new
                        {
                            Id = new Guid("8f7dc23d-e2e9-3691-cfe9-545bb958e3f2"),
-                            ConcurrencyStamp = "2a423514ae5e4c19a4524fa4b675c28e",
+                            ConcurrencyStamp = "658f74bf334f4a34a3fb10eaf00a840a",
                            Cron = "0 0/30 * * * ? ",
                            IsDisabled = false,
                            IsRunning = false,
@ -4543,7 +4543,7 @@ namespace Win.Sfs.SettleAccount.Migrations
                        new
                        {
                            Id = new Guid("c1f71240-1b81-0107-8b23-ddc9811a3efe"),
-                            ConcurrencyStamp = "ecb2819e7667499295cea61d7bf4eae3",
+                            ConcurrencyStamp = "71311c84551343b099c049672a4c421f",
                            Cron = "0 0/30 * * * ? ",
                            IsDisabled = false,
                            IsRunning = false,
@ -4553,7 +4553,7 @@ namespace Win.Sfs.SettleAccount.Migrations
                        new
                        {
                            Id = new Guid("c09c23ea-815f-1b43-4476-2365a8d9a60b"),
-                            ConcurrencyStamp = "6c75a4d283954fbc895242d9405340e0",
+                            ConcurrencyStamp = "5ebb150f3f9e4ccd89d5fab0a6dde4e4",
                            Cron = "0 0/30 * * * ? ",
                            IsDisabled = false,
                            IsRunning = false,
@ -4655,7 +4655,8 @@ namespace Win.Sfs.SettleAccount.Migrations
                        .HasColumnType("nvarchar(max)");

                    b.Property<string>("RealPartCode")
-                        .HasColumnType("nvarchar(450)");
+                        .HasMaxLength(50)
+                        .HasColumnType("nvarchar(50)");

                    b.Property<string>("Seq")
                        .HasColumnType("nvarchar(max)");
@ -4772,7 +4773,8 @@ namespace Win.Sfs.SettleAccount.Migrations
                        .HasColumnType("nvarchar(max)");

                    b.Property<string>("RealPartCode")
-                        .HasColumnType("nvarchar(max)");
+                        .HasMaxLength(50)
+                        .HasColumnType("nvarchar(50)");

                    b.Property<string>("Seq")
                        .HasColumnType("nvarchar(max)");
@ -4911,7 +4913,8 @@ namespace Win.Sfs.SettleAccount.Migrations
                        .HasColumnType("nvarchar(max)");

                    b.Property<string>("RealPartCode")
-                        .HasColumnType("nvarchar(max)");
+                        .HasMaxLength(50)
+                        .HasColumnType("nvarchar(50)");

                    b.Property<string>("Seq")
                        .HasColumnType("nvarchar(max)");
--- a/code/src/Shared/Win.Sfs.Shared/Win.Sfs.Shared.csproj
+++ b/code/src/Shared/Win.Sfs.Shared/Win.Sfs.Shared.csproj
@ -13,6 +13,7 @@

  <ItemGroup>
    <PackageReference Include="Microsoft.AspNetCore.Mvc" Version="2.2.0" />
+    <PackageReference Include="SequentialGuid" Version="4.0.4" />
    <PackageReference Include="Volo.Abp.Caching" Version="4.3.3" />
    <PackageReference Include="Volo.Abp.Ddd.Application" Version="4.3.3" />
    <PackageReference Include="Volo.Abp.Ddd.Application.Contracts" Version="4.3.3" />