| | |
|---|
| | | using System.Reflection; |
|---|
| | | using System.Text; |
|---|
| | | using System.Threading.Tasks; |
|---|
| | | using WIDESEAWCS_Core.Attributes; |
|---|
| | | using WIDESEAWCS_Core.Const; |
|---|
| | | using WIDESEAWCS_Core.DB; |
|---|
| | | using WIDESEAWCS_Core.DB.Models; |
|---|
| | | using WIDESEAWCS_Core.Helper; |
|---|
| | | using WIDESEAWCS_Core.HttpContextUser; |
|---|
| | | using WIDESEAWCS_Core.Seed; |
|---|
| | | using WIDESEAWCS_Core.Tenants; |
|---|
| | | |
|---|
| | | namespace WIDESEAWCS_Core.AOP |
|---|
| | |
|---|
| | | { |
|---|
| | | baseEntity.CreateDate = DateTime.Now; |
|---|
| | | } |
|---|
| | | |
|---|
| | | PropertyInfo propertyInfo = entityInfo.EntityColumnInfo.PropertyInfo; |
|---|
| | | SequenceAttirbute? sequenceAttirbute = propertyInfo.GetCustomAttribute<SequenceAttirbute>(); |
|---|
| | | if (sequenceAttirbute != null) |
|---|
| | | { |
|---|
| | | if (propertyInfo.GetValue(entityInfo.EntityValue)?.ObjToInt() <= 0) |
|---|
| | | { |
|---|
| | | SqlSugarClient sugarClient = new SqlSugarClient(new ConnectionConfig |
|---|
| | | { |
|---|
| | | ConfigId = MainDb.CurrentDbConnId, |
|---|
| | | ConnectionString = DBContext.GetMainConnectionDb().Connection, |
|---|
| | | IsAutoCloseConnection = true, |
|---|
| | | DbType = MainDb.DbType, |
|---|
| | | }); |
|---|
| | | int count = sugarClient.Ado.GetScalar($"SELECT COUNT(*) FROM sys.sequences WHERE name = '{sequenceAttirbute.SequenceName}'").ObjToInt(); |
|---|
| | | if (count == 0) |
|---|
| | | { |
|---|
| | | string sql = $"CREATE SEQUENCE {sequenceAttirbute.SequenceName} AS [int] START WITH {sequenceAttirbute.StartWith} INCREMENT BY {sequenceAttirbute.Increment} MINVALUE {sequenceAttirbute.SeqMinValue} MAXVALUE {sequenceAttirbute.SeqMaxValue} {(sequenceAttirbute.IsCycle ? "CYCLE" : "")} CACHE"; |
|---|
| | | sugarClient.Ado.ExecuteCommand(sql); |
|---|
| | | } |
|---|
| | | int seq = sugarClient.Ado.GetScalar($"SELECT NEXT VALUE FOR {sequenceAttirbute.SequenceName}").ObjToInt(); |
|---|
| | | propertyInfo.SetValue(entityInfo.EntityValue, seq, null); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | else if (entityInfo.OperationType == DataFilterType.UpdateByObject) |
|---|
