smi 南市水厂eta

ningshuxia

2022-10-08 afedb8fd4e17a5a911deee3dae04a10a93e6a39a

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
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
 
namespace IStation.Server
{
    /// <summary>
    /// 监测任务辅助类
    /// </summary>
    public class MonitorJobHelper : IJobHelper
    {
        private readonly RabbitMqQueueHelper _queueHelper = new RabbitMqQueueHelper(); 
 
        /// <summary>
        /// 开始任务
        /// </summary>
        public void StartJob()
        {
            _queueHelper.Receive<Model.MonitorStoreCorpRecord>(ConfigHelper.QueueName, (data) =>
            {
 
                try
                {
                    if (data == null)
                    {
                        LogHelper.Error("监测数据存储服务中，数据序列化失败，自动跳过当前数据！");
                        return true;
                    }
                    if (data.Records == null || data.Records.Count < 1)
                    {
                        LogHelper.Error($"监测数据存储服务中，客户标识：{data.CorpID},数据记录为空，自动跳过当前数据！");
                        return true;
                    }
 
                    #region 写日志
 
                    if (ConfigHelper.IsWriteLog)
                    {
                        LogHelper.Info($"监测数据存储服务中，客户标识：{data.CorpID}，数据数量-{data.Records.Count}!");
                    }
 
                    #endregion
 
 
                    var result = new Service.MonitorRealRecord().Insert(data.CorpID, data.Records);
                    if (!result)
                    {
                        LogHelper.Error($"监测数据存储服务中,客户标识：{data.CorpID},当前通道处于阻塞状态 ！");
                    }
                    else
                    {
                        var flow_record = new Model.MonitorStoreFlowRecord();
                        flow_record.CorpID = data.CorpID;
                        flow_record.StoreTime = DateTime.Now;
                        flow_record.StoreCount = data.Records.Count;
                        flow_record.StoreContent = data.Records.Select(x => x.MonitorPointID).Distinct().ToList();
                        new RedisCache.MonitorStoreFlowRecordCacheHelper().SetLastRecord(flow_record);
                    }
                    return result;
                }
                catch (Exception ex)
                {
                    LogHelper.Error("监测数据存储服务中,数据消息队列出错，自动跳过该条数据", ex);
                    return true;
                }
            });
        }
 
        /// <summary>
        /// 取消任务
        /// </summary>
        public void CancelJob()
        {
            if (_queueHelper == null)
                return;
            _queueHelper.Close();
        }
 
 
    }
}