循环水项目
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
lixiaojun
2024-10-12 a8ccc992964272f6a74631e8c164e8c91e5cb6d4 
 Service/HStation.Service.Assets.Core/04-dal/02-postgresql/01-PumpMainManage/PumpMain.cs


@@ -5,7 +5,7 @@


    /// <summary>


    ///


    /// </summary>


    public partial class PumpMain : BaseDAL_Paras_Flags_TagName_Sorter<Entity.PumpMain>, IPumpMain


    public partial class AssetsPumpMain : BaseDAL_Paras_Flags_TagName_Sorter<Entity.AssetsPumpMain>, IAssetsPumpMain


    {


        /// <summary>


        ///


@@ -27,7 +27,7 @@


                try


                {


                    db.BeginTran();


                    var main = db.Queryable<Entity.PumpMain>().ToList().Find(x => x.ID == ID);


                    var main = db.Queryable<Entity.AssetsPumpMain>().ToList().Find(x => x.ID == ID);


                    var result = db.Deleteable(main).ExecuteCommand() > 0;


                    if (!result)


                    {


@@ -36,7 +36,7 @@


                    }


                    else


                    {


                        var map = db.Queryable<Entity.PumpGroupAndMainMap>().ToList().Find(x => x.PumpMainID == ID);


                        var map = db.Queryable<Entity.AssetsPumpGroupAndMainMap>().ToList().Find(x => x.PumpMainID == ID);


                        if (map != null)


                        {


                            var mapresult = db.Deleteable(map).ExecuteCommand() > 0;


@@ -59,9 +59,9 @@


        }




        //插入拓展


        public long InsertsEx(Entity.PumpMain pumpMain, Entity.PumpGroupAndMainMap pumpGroupAndMainMap)


        public long InsertsEx(Entity.AssetsPumpMain AssetsPumpMain, Entity.AssetsPumpGroupAndMainMap AssetsPumpGroupAndMainMap)


        {


            if (pumpMain == null)


            if (AssetsPumpMain == null)


            {


                return default;


            }


@@ -70,7 +70,7 @@


                try


                {


                    db.BeginTran();


                    var result = db.Insertable(pumpMain).ExecuteReturnSnowflakeId();


                    var result = db.Insertable(AssetsPumpMain).ExecuteReturnSnowflakeId();


                    if (result < 0)


                    {


                        db.RollbackTran();


@@ -78,10 +78,10 @@


                    }


                    else


                    {


                        if (pumpGroupAndMainMap != null)


                        if (AssetsPumpGroupAndMainMap != null)


                        {


                            pumpGroupAndMainMap.PumpMainID = result;


                            var mapresult = db.Insertable(pumpGroupAndMainMap).ExecuteReturnSnowflakeId();


                            AssetsPumpGroupAndMainMap.PumpMainID = result;


                            var mapresult = db.Insertable(AssetsPumpGroupAndMainMap).ExecuteReturnSnowflakeId();


                            if (mapresult < 0)


                            {


                                db.RollbackTran();