运行模块中新增业务月统计

lixiaojun

2022-08-17 d3024a7b50b35a8f24c1bfe0f13f4f86cc63a253

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
using Quartz;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using IStation.Calculation;
 
namespace IStation.Server
{
    /// <summary>
    /// 监测波动分析计划任务
    /// </summary>
    [DisallowConcurrentExecution]//此特性标识 必须等待这次任务执行完成后，才能执行下次任务
    public class MonitorFluctAnalyCronJob : IJob
    {
        /// <summary>
        /// 
        /// </summary>
        public Task Execute(IJobExecutionContext context)
        {
            return Task.Run(() =>
            {
                try
                {
 
                    #region 加载目标客户
 
                    var corpIds = CorpHelper.GetCorpIds();
                    if (corpIds == null || corpIds.Count < 1)
                    {
                        LogHelper.Error("监测波动分析计划任务中，未检索到目标客户信息");
                        return;
                    }
 
                    #endregion
 
                    #region 加载监测波动分析配置
 
                    var configure_list = new Service.MonitorFluctConfigure().GetByCorpIds(corpIds);
                    if (configure_list == null || configure_list.Count < 1)
                    {
                        LogHelper.Info($"监测波动分析计划任务中,未检索到监测波动分析配置信息！");
                        return;
                    }
                    configure_list = configure_list.Where(x => x.UseStatus == Model.eUseStatus.Enable).ToList();
                    if (configure_list.Count < 1)
                    {
                        LogHelper.Info($"监测波动分析计划任务中,未检索到有效监测波动分析配置信息");
                        return;
                    }
 
                    #endregion
 
                    #region 遍历分析
 
                    //服务
                    var service_monitor_fluct = new Service.MonitorFluctRecord();
                    var service_monitor_record = new Service.MonitorRealRecord();
 
                    foreach (var configure in configure_list)
                    {
                        var model = new Model.MonitorFluctRecord();
                        model.CorpID = configure.CorpID;
                        model.MonitorPointID = configure.MonitorPointID;
                        model.SignalID = configure.SignalID;
 
                        for (int i = 0; i < configure.ContinueDays; i++)
                        {
                            var day = DateTime.Now.Date.AddDays(-(i + 1));
                            var record_list = service_monitor_record.GetContentBySignalIDOfDay(configure.CorpID, configure.MonitorPointID, configure.SignalID, day);
                            model.Analy(record_list);
                        }
                        var bol = service_monitor_fluct.InsertOrUpdate(model);
                        if (!bol)
                        {
                            LogHelper.Info($"监测波动分析计划任务中,客户标识:{configure.CorpID},测点标识：{configure.MonitorPointID},信号标识：{configure.SignalID},监测波形分析数据保存失败！");
                        }
                    }
 
                    #endregion
 
                }
                catch (Exception ex)
                {
                    LogHelper.Error("监测波动分析计划任务中,出错", ex);
                    var e = new JobExecutionException(ex);
                    throw e;
                }
            });
        }
    }
}