ALD自动小车搬运项目
blame | 历史 | 补丁 | 提交 | 提交对比 | 显示空白
heshaofeng
2025-11-26 ad72c566847c2370958b6811363545ff6019a001 
 ÏîÄ¿´úÂë/WMSÎÞ²Ö´¢°æ/WIDESEA_WMSServer/WIDESEA_BasicService/DailySequenceService.cs


@@ -10,6 +10,7 @@


using System.Threading.Tasks;


using WIDESEA_Core.BaseRepository;


using WIDESEA_Core.BaseServices;


using WIDESEA_Core.Seed;


using WIDESEA_IBasicService;


using WIDESEA_Model.Models;


using WIDESEA_Model.Models.Basic;


@@ -193,29 +194,44 @@




        private async Task UpdateSequenceInDatabase(DateTime date, string sequenceKey, int value)


        {


            var sequence = await Repository.Db.Queryable<DT_DailySequence>()


                .Where(x => x.SequenceDate == date && x.SequenceKey == sequenceKey)


                .FirstAsync();




            if (sequence != null)


            try


            {


                sequence.CurrentValue = value;




                await Repository.Db.Updateable(sequence).ExecuteCommandAsync();


            }


            else


                using SqlSugarClient sugarClient = new SqlSugarClient(new ConnectionConfig


            {


                // å¦‚果数据库记录不存在，则创建


                sequence = new DT_DailySequence


                    IsAutoCloseConnection = true,


                    DbType = DbType.SqlServer,


                    ConnectionString = DBContext.ConnectionString


                });


                var result = await sugarClient.Updateable<DT_DailySequence>()


                    .SetColumns(it => new DT_DailySequence()


                {


                    SequenceDate = date,


                    SequenceKey = sequenceKey,


                    CurrentValue = value,


                    })


                    .Where(it => it.SequenceDate == date && it.SequenceKey == sequenceKey)


                    .ExecuteCommandAsync();




                if (result == 0)


                {


                    // å¦‚果没有更新到记录，可能是首次使用，插入新记录


                    var newSequence = new DT_DailySequence


                    {


                        SequenceKey = sequenceKey,


                        SequenceDate = date,


                        CurrentValue = value,


                        Creater="admin",


                        CreateDate=DateTime.Now,


                };


                await Repository.Db.Insertable(sequence).ExecuteCommandAsync();


                    await sugarClient.Insertable(newSequence).ExecuteCommandAsync();


            }


        }


            catch (Exception ex)


            {


                // è®°å½•æ—¥å¿—并重新抛出异常


                Console.WriteLine($"更新序列失败: {ex.Message}");


                throw;


            }                       




        }




        public async Task CleanOldSequencesAsync(int keepDays = 30)


        {