src/Hotline.Application/JudicialManagement/EnforcementApplication.cs

@@ -1,6 +1,7 @@
 using Hotline.Caching.Interfaces;
 using Hotline.JudicialManagement;
 using Hotline.Settings;
+using SqlSugar;
 using XF.Domain.Constants;
 using XF.Domain.Dependency;
 using XF.Domain.Repository;
@@ -55,46 +56,44 @@ namespace Hotline.Application.JudicialManagement
             if (isOpenJudicialManagement != "true")
                 return;
 
-            var orderData = await _enforcementOrdersRepository.GetAsync(p => p.Id == order.Id, cancellationToken);
-            if (orderData == null)
+            bool isAdd = false;
+            //如果是行政执法类工单，写入数据
+            if (order.IsEnforcementOrder.HasValue && order.IsEnforcementOrder.Value)
+                isAdd = true;
+
+            //如果是特定热点写入数据
+            if (await _enforcementHotspotRepository.AnyAsync(p => p.Id == order.HotspotId, cancellationToken))
+                isAdd = true;
+
+            //如果是特定部门办理写入数据
+            var JudicialManagementOrg = _sysDicDataCacheManager.GetSysDicDataCache(SysDicTypeConsts.JudicialManagementOrg).Where(p => p.DicDataValue == order.OrgLevelOneCode);
+
+            if (JudicialManagementOrg != null && JudicialManagementOrg.Any())
+                isAdd = true;
+
+            //需要添加
+            if (isAdd)
             {
-                bool isAdd = false;
-                EnforcementOrders enforcementOrders = new EnforcementOrders()
+                var orderData = await _enforcementOrdersRepository.GetAsync(p => p.Id == order.Id, cancellationToken);
+                if (orderData == null)
                 {
-                    Id = order.Id,
-                    OrderNo = order.No,
-                    IsEnforcementOrder = order.IsEnforcementOrder.HasValue ? order.IsEnforcementOrder.Value : false,
-                    IsTheClueTrue = false,
-                    IsPassTheBuckOrder = false
-                };
-                //如果是行政执法类工单，写入数据
-                if (order.IsEnforcementOrder.HasValue && order.IsEnforcementOrder.Value)
-                    isAdd = true;
+                    EnforcementOrders enforcementOrders = new EnforcementOrders()
+                    {
+                        Id = order.Id,
+                        OrderNo = order.No,
+                        IsEnforcementOrder = order.IsEnforcementOrder.HasValue ? order.IsEnforcementOrder.Value : false,
+                        IsTheClueTrue = false,
+                        IsPassTheBuckOrder = false
+                    };
 
+                    await _enforcementOrdersRepository.AddAsync(enforcementOrders, cancellationToken);
+                }
                 else
                 {
-                    //如果是特定热点写入数据
-                    if (await _enforcementHotspotRepository.AnyAsync(p => p.Id == order.HotspotId, cancellationToken))
-                        isAdd = true;
-
-                    else
-                    {
-                        //如果是特定部门办理写入数据
-                        var JudicialManagementOrg = _sysDicDataCacheManager.GetSysDicDataCache(SysDicTypeConsts.JudicialManagementOrg).Where(p => p.DicDataValue == order.OrgLevelOneCode);
-
-                        if (JudicialManagementOrg != null && JudicialManagementOrg.Any())
-                            isAdd = true;
-                    }
+                    //是否需要更新数据
                 }
-
-                //判断是否写入数据
-                if (isAdd)
-                    await _enforcementOrdersRepository.AddAsync(enforcementOrders, cancellationToken);
-            }
-            else
-            {
-                //是否需要更新数据
             }
+
         }
 
         /// <summary>