Synchronization code

Src/Asp.NetCore2/SqlSugar/Abstract/ExecuteNavProvider/InsertNavProviderManyToMany.cs

@@ -1,4 +1,5 @@
-using System;
+using Newtonsoft.Json;
+using System;
 using System.Collections.Generic;
 using System.Linq;
 using System.Linq.Expressions;
@@ -9,7 +10,8 @@ namespace SqlSugar
     public partial class InsertNavProvider<Root, T> where T : class, new() where Root : class, new()
     {
         private void InsertManyToMany<TChild>(string name, EntityColumnInfo nav) where TChild : class, new()
-        {;
+        {
+            ;
             var parentEntity = _ParentEntity;
             var parentList = _ParentList;
             var parentPkColumn = parentEntity.Columns.FirstOrDefault(it => it.IsPrimarykey == true);
@@ -18,9 +20,9 @@ namespace SqlSugar
             var thisPkColumn = thisEntity.Columns.FirstOrDefault(it => it.IsPrimarykey == true);
             Check.ExceptionEasy(thisPkColumn == null, $"{thisPkColumn.EntityName} need primary key", $"{thisPkColumn.EntityName}需要主键");
             Check.ExceptionEasy(parentPkColumn == null, $"{parentPkColumn.EntityName} need primary key", $"{parentPkColumn.EntityName}需要主键");
-            var mappingType=parentNavigateProperty.Navigat.MappingType;
+            var mappingType = parentNavigateProperty.Navigat.MappingType;
             var mappingEntity = this._Context.EntityMaintenance.GetEntityInfo(mappingType);
-            var mappingA = mappingEntity.Columns.FirstOrDefault(x=>x.PropertyName== parentNavigateProperty.Navigat.MappingAId);
+            var mappingA = mappingEntity.Columns.FirstOrDefault(x => x.PropertyName == parentNavigateProperty.Navigat.MappingAId);
             var mappingB = mappingEntity.Columns.FirstOrDefault(x => x.PropertyName == parentNavigateProperty.Navigat.MappingBId);
             Check.ExceptionEasy(mappingA == null || mappingB == null, $"Navigate property {name} error ", $"导航属性{name}配置错误");
             var mappingPk = mappingEntity.Columns
@@ -37,18 +39,18 @@ namespace SqlSugar
             List<Dictionary<string, object>> mappgingTables = new List<Dictionary<string, object>>();
             foreach (var item in parentList)
             {
-                var items= parentNavigateProperty.PropertyInfo.GetValue(item);
+                var items = parentNavigateProperty.PropertyInfo.GetValue(item);
                 if (items == null)
                 {
                     continue;
                 }
-                var children=((List<TChild>)items);
+                var children = ((List<TChild>)items);
                 InsertDatas(children, thisPkColumn);
                 var parentId = parentPkColumn.PropertyInfo.GetValue(item);
                 foreach (var child in children)
                 {
                     var chidId = thisPkColumn.PropertyInfo.GetValue(child);
-                    Dictionary<string,object> keyValuePairs = new Dictionary<string,object>();
+                    Dictionary<string, object> keyValuePairs = new Dictionary<string, object>();
                     keyValuePairs.Add(mappingA.DbColumnName, parentId);
                     keyValuePairs.Add(mappingB.DbColumnName, chidId);
                     if (mappingOthers != null)
@@ -88,10 +90,62 @@ namespace SqlSugar
             {
                 this._Context.Deleteable<object>().AS(mappingEntity.DbTableName).In(mappingA.DbColumnName, ids).ExecuteCommand();
             }
+            if (HasMappingTemplate(mappingEntity))
+            {
+                InertMappingWithTemplate(mappingEntity, mappingA, mappingB, mappgingTables);
+            }
+            else
+            {
                 this._Context.Insertable(mappgingTables).AS(mappingEntity.DbTableName).ExecuteCommand();
+            }
             SetNewParent<TChild>(thisEntity, thisPkColumn);
         }
 
+        private void InertMappingWithTemplate(EntityInfo mappingEntity, EntityColumnInfo mappingA, EntityColumnInfo mappingB, List<Dictionary<string, object>> mappgingTables)
+        {
+            var template = this._navOptions?.ManyToManySaveMappingTemplate;
+            List<object> mappingObjects = new List<object>();
+            foreach (var item in mappgingTables)
+            {
+                // 序列化模板对象
+                var serializedTemplate = JsonConvert.SerializeObject(template);
+
+                // 反序列化模板对象，创建新的映射对象
+                var mappingObject = JsonConvert.DeserializeObject(serializedTemplate, template.GetType());
+
+                // 获取映射对象的所有字段
+                var fields = mappingEntity.Columns;
+
+                // 遍历字典中的键值对，并将值赋给映射对象的对应字段
+                foreach (var kvp in item)
+                {
+                    var fieldName = kvp.Key;
+                    var fieldValue = kvp.Value;
+
+                    // 查找与字段名匹配的字段
+                    var field = fields.FirstOrDefault(f => f.DbColumnName.EqualCase(fieldName));
+                    // 如果字段存在且值的类型与字段类型匹配，则赋值给字段
+                    if (field != null)
+                    {
+                        var isSetValue = field.IsPrimarykey
+                        || field.DbColumnName == mappingA.DbColumnName
+                        || field.DbColumnName == mappingB.DbColumnName;
+                        if (isSetValue)
+                            field.PropertyInfo.SetValue(mappingObject, fieldValue);
+                    }
+                }
+
+                // 将映射对象添加到列表中
+                mappingObjects.Add(mappingObject);
+            }
+            this._Context.InsertableByObject(mappingObjects).ExecuteCommand();
+        }
+
+        private bool HasMappingTemplate(EntityInfo mappingEntity)
+        {
+            return this._navOptions?.ManyToManySaveMappingTemplate?.GetType() == mappingEntity.Type;
+        }
+
         private void SetMappingTableDefaultValue(EntityColumnInfo mappingPk, Dictionary<string, object> keyValuePairs)
         {
             if (mappingPk.UnderType == UtilConstants.LongType)

Src/Asp.NetCore2/SqlSugar/Abstract/ExecuteNavProvider/UpdateNavManyToMany.cs

@@ -1,4 +1,5 @@
-using System;
+using Newtonsoft.Json;
+using System;
 using System.Collections.Generic;
 using System.Linq;
 using System.Linq.Expressions;
@@ -89,10 +90,62 @@ namespace SqlSugar
                 }
             }
             this._Context.Deleteable<object>().AS(mappingEntity.DbTableName).In(mappingA.DbColumnName, ids).ExecuteCommand();
+            if (HasMappingTemplate(mappingEntity))
+            {
+                InertMappingWithTemplate(mappingEntity, mappingA, mappingB, mappgingTables);
+            }
+            else
+            {
                 this._Context.Insertable(mappgingTables).AS(mappingEntity.DbTableName).ExecuteCommand();
+            }
             _ParentEntity = thisEntity;
         }
 
+        private bool HasMappingTemplate(EntityInfo mappingEntity)
+        {
+            return this._Options?.ManyToManySaveMappingTemplate?.GetType() == mappingEntity.Type;
+        }
+
+        private void InertMappingWithTemplate(EntityInfo mappingEntity, EntityColumnInfo mappingA, EntityColumnInfo mappingB, List<Dictionary<string, object>> mappgingTables)
+        {
+            var template = this._Options?.ManyToManySaveMappingTemplate;
+            List<object> mappingObjects = new List<object>();
+            foreach (var item in mappgingTables)
+            {
+                // 序列化模板对象
+                var serializedTemplate = JsonConvert.SerializeObject(template);
+
+                // 反序列化模板对象，创建新的映射对象
+                var mappingObject = JsonConvert.DeserializeObject(serializedTemplate, template.GetType());
+
+                // 获取映射对象的所有字段
+                var fields = mappingEntity.Columns;
+
+                // 遍历字典中的键值对，并将值赋给映射对象的对应字段
+                foreach (var kvp in item)
+                {
+                    var fieldName = kvp.Key;
+                    var fieldValue = kvp.Value;
+
+                    // 查找与字段名匹配的字段
+                    var field = fields.FirstOrDefault(f => f.DbColumnName.EqualCase(fieldName));
+                    // 如果字段存在且值的类型与字段类型匹配，则赋值给字段
+                    if (field != null)
+                    {
+                        var isSetValue = field.IsPrimarykey
+                        || field.DbColumnName == mappingA.DbColumnName
+                        || field.DbColumnName == mappingB.DbColumnName;
+                        if (isSetValue)
+                            field.PropertyInfo.SetValue(mappingObject, fieldValue);
+                    }
+                }
+
+                // 将映射对象添加到列表中
+                mappingObjects.Add(mappingObject);
+            }
+            this._Context.InsertableByObject(mappingObjects).ExecuteCommand();
+        }
+
         private void SetMappingTableDefaultValue(EntityColumnInfo mappingPk, Dictionary<string, object> keyValuePairs)
         {
             if (mappingPk.UnderType == UtilConstants.LongType)

Src/Asp.NetCore2/SqlSugar/Entities/DeleteNavOptions.cs

@@ -43,6 +43,7 @@ namespace SqlSugar
     {
         public bool ManyToManyIsUpdateA { get; set; }
         public bool ManyToManyIsUpdateB { get; set; }
+        public object ManyToManySaveMappingTemplate { get; set; }
         public bool OneToManyDeleteAll { get;  set; }
         public bool OneToManyEnableLogicDelete { get; set; }
         public Expression RootFunc { get; set; }
@@ -53,5 +54,6 @@ namespace SqlSugar
     {
         public bool OneToManyIfExistsNoInsert { get; set; }
         public bool ManyToManyNoDeleteMap { get; set; }
+        public object ManyToManySaveMappingTemplate { get; set; }
     }
 }