特种设备检验

2023-06-01 15:25:41 +08:00
parent c920a99e8a
commit b8d77e72d9
4 changed files with 260 additions and 0 deletions
--- a/taskschedule/Tnb.TaskScheduler/Listener/GenerateSpEquipCheckPlanTimeWorker.cs
+++ b/taskschedule/Tnb.TaskScheduler/Listener/GenerateSpEquipCheckPlanTimeWorker.cs
@@ -0,0 +1,68 @@
+using JNPF.Common.Security;
+using JNPF.Logging;
+using SqlSugar;
+using Tnb.EquipMgr.Entities;
+
+namespace JNPF.TaskScheduler.Listener
+{
+    /// <summary>
+    /// 生成特种设备检验计划
+    /// </summary>
+    public class GenerateSpEquipCheckPlanTimeWorker : ISpareTimeWorker
+    {
+        private ISqlSugarRepository<EqpSpEquipCheckRecord> _repository => App.GetService<ISqlSugarRepository<EqpSpEquipCheckRecord>>();
+        
+        [SpareTime("0 0 0 * * ?", "生成特种设备检验计划", ExecuteType = SpareTimeExecuteTypes.Serial,StartNow = false)]
+        public void GenerateSpotInspectionPlan(SpareTimer timer, long count)
+        {
+            Log.Information("----------------------开始生成特种设备检验计划----------------------");
+
+            try
+            {
+                var db = _repository.AsSugarClient();
+
+                List<string> ids = _repository.GetList(x => x.status == "0").Select(x => x.equip_id).Distinct()
+                    .ToList();
+                
+                List<EqpSpEquipCheckRecord> list = db.Queryable<EqpSpEquipCheckRecord>().GroupBy(x=>new
+                    {
+                        x.equip_id,
+                    }).Where(x => x.status == "1" && !ids.Contains(x.equip_id))//排除有未检验的
+                    .Select(x=>new
+                    {
+                        equip_id = x.equip_id,
+                        create_time = SqlFunc.AggregateMax(x.create_time),
+                        
+                    })
+                    .MergeTable()
+                    .LeftJoin<EqpSpEquipCheckRecord>((x,y)=>x.equip_id==y.equip_id && x.create_time==y.create_time)
+                    .Select((x,y)=>y)
+                    .ToList();
+
+                List<EqpSpEquipCheckRecord> insertList = new List<EqpSpEquipCheckRecord>();
+                if (list != null && list.Count > 0)
+                {
+                    foreach (var item in list)
+                    {
+                        insertList.Add(new EqpSpEquipCheckRecord()
+                        {
+                            id = SnowflakeIdHelper.NextId(),
+                            equip_id = item.equip_id,
+                            status = "0"
+                        });
+                    }
+
+                    _repository.InsertRange(insertList);
+                }
+            }
+            catch (Exception e)
+            {
+                Console.WriteLine(e.Message);
+                Log.Error(e.Message);
+            }
+
+            
+            Log.Information("----------------------结束生成特种设备检验计划----------------------");
+        }
+    }
+}