using Microsoft.AspNetCore.Mvc;
|
using System.Net;
|
using System.Net.Http.Headers;
|
using Microsoft.Extensions.Hosting.Internal;
|
using Microsoft.AspNetCore.Http.Extensions;
|
using IStation.Untity;
|
using Furion.DynamicApiController;
|
using System.ComponentModel.DataAnnotations;
|
using Mapster;
|
using Microsoft.AspNetCore.Http;
|
using Furion.DependencyInjection;
|
using Microsoft.AspNetCore.Authorization;
|
using Furion.DataEncryption;
|
using AutoMapper;
|
|
namespace IStation.Application
|
{
|
/// <summary>
|
/// 波形存储接口(城投的航天 市南泵站专用)
|
/// </summary>
|
[AllowAnonymous]
|
[Route("smi/vibration/hangtian")]
|
[ApiDescriptionSettings("Vibration", Name = "城投航天振动", Order = 1000)]
|
public class Smi_HangTian_VibrationController : IDynamicApiController
|
{
|
|
/// <summary>
|
/// 单个添加
|
/// </summary>
|
[Route("SingleInsert")]
|
[HttpPost]
|
public bool SingleInsert([Required]AddSmiHangTianVibartionRecordInput input)
|
{
|
//转化为内部使用对象
|
var model = input.Adapt<AddSmiHangTianVibartionRecordInput, Model.SmiHangTianVibrationRecord>();
|
|
//写redis缓存
|
var redisHelper = new RedisCache.SmiHangTianVibrationRecord();
|
redisHelper.SetLastRecord(model);
|
|
if (ConfigHelper.Smi_HangTian_IsWriteLog)
|
{
|
LogHelper.Info($"航天写入Redis一条振动数据，ObjectId:{model.ObjectId}");
|
}
|
|
//获取配置
|
var configure = new Service.DataDockingConfigure().GetByID(ConfigHelper.Smi_HangTian_CorpID, ConfigHelper.Smi_HangTian_ConfigureID);
|
if (configure != null)
|
{
|
if (configure.Mappers != null && configure.Mappers.Count > 0)
|
{
|
var mapper = configure.Mappers.Find(t=>t.SignId== model.ObjectId);
|
if (mapper != null)
|
{
|
var monitor = new Service.MonitorPoint().GetExSignalWithSignalTypeByID(configure.CorpID, mapper.SysId);
|
if (monitor != null)
|
{
|
if (monitor.MonitorType == Model.eMonitorType.Vibration)
|
{
|
var receive = new Model.MonitorDataDockingReceiveRecord();
|
receive.SysId = monitor.ID;
|
receive.RecordType = monitor.MonitorType;
|
receive.SrcTime = model.SrcTime;
|
receive.DataStatus = model.DataStatus;
|
|
//子项列表
|
var receiveSubList = new List<Model.MonitorDataDockingReceiveSubRecord>();
|
|
//配置
|
var signal_config = monitor.SignalList.Find(t=>t.Flags!=null&&t.Flags.Contains(LogicFlags.配置));
|
if (signal_config != null)
|
{
|
var config = model.Adapt<Model.SmiHangTianVibrationRecord, Model.SmiHangTianVibrationConfig>();
|
var config_json = JsonHelper.Object2Json(config);
|
var config_sub = new Model.MonitorDataDockingReceiveSubRecord();
|
config_sub.SysId = signal_config.ID;
|
config_sub.SrcValue= config_json;
|
receiveSubList.Add(config_sub);
|
}
|
|
//转速
|
var signal_rpm = monitor.SignalList.Find(t=>t.Flags!=null&&t.Flags.Contains(LogicFlags.转速));
|
if (signal_rpm != null)
|
{
|
var rpm_sub = new Model.MonitorDataDockingReceiveSubRecord();
|
rpm_sub.SysId= signal_rpm.ID;
|
rpm_sub.SrcValue = model.Speed.ToString();
|
receiveSubList.Add(rpm_sub);
|
}
|
|
//间歇电压
|
var signal_u = monitor.SignalList.Find(t=>t.Flags!=null&&t.Flags.Contains(LogicFlags.间歇电压));
|
if (signal_u != null)
|
{
|
var u_sub = new Model.MonitorDataDockingReceiveSubRecord();
|
u_sub.SysId = signal_u.ID;
|
u_sub.SrcValue = model.GapValue.ToString();
|
receiveSubList.Add(u_sub);
|
}
|
|
//通频值
|
var signal_tp = monitor.SignalList.Find(t => t.Flags != null && t.Flags.Contains(LogicFlags.通频值));
|
if (signal_tp != null)
|
{
|
var tp_sub = new Model.MonitorDataDockingReceiveSubRecord();
|
tp_sub.SysId = signal_tp.ID;
|
tp_sub.SrcValue = model.OverValue.ToString();
|
receiveSubList.Add(tp_sub);
|
}
|
|
//波形
|
var signal_wave= monitor.SignalList.Find(t => t.Flags != null && t.Flags.Contains(LogicFlags.波形));
|
if (signal_wave != null)
|
{
|
var wave_sub = new Model.MonitorDataDockingReceiveSubRecord();
|
wave_sub.SysId = signal_wave.ID;
|
wave_sub.SrcValue = model.Wave;
|
receiveSubList.Add(wave_sub);
|
}
|
|
receive.SrcValue = Model.MonitorDataDockingReceiveSubRecord.ToJson(receiveSubList);
|
|
var queueHelper = new RabbitMqQueueHelper();
|
var bol= queueHelper.Push(ConfigHelper.DataDockingQueueName,new Model.MonitorDataDockingCorpRecord() {
|
CorpID=configure.CorpID,
|
ConfigureID=configure.ID,
|
Records=new List<Model.MonitorDataDockingReceiveRecord>() { receive}
|
});
|
if (bol)
|
{
|
if (ConfigHelper.Smi_HangTian_IsWriteLog)
|
{
|
LogHelper.Info($"航天推入通道一条振动数据，ObjectId:{model.ObjectId},SysId:{monitor.ID}");
|
}
|
return true;
|
}
|
}
|
}
|
}
|
}
|
}
|
return false;
|
}
|
|
/// <summary>
|
/// 批量添加
|
/// </summary>
|
[Route("BulkInsert")]
|
[HttpPost]
|
public bool BulkInsert([Required]List<AddSmiHangTianVibartionRecordInput> inputList)
|
{
|
if (inputList == null || inputList.Count < 1)
|
return false;
|
//转化为内部使用对象
|
var modelList = inputList.Select(x => x.Adapt<AddSmiHangTianVibartionRecordInput, Model.SmiHangTianVibrationRecord>()).ToList();
|
|
//写redis缓存
|
var redisHelper = new RedisCache.SmiHangTianVibrationRecord();
|
redisHelper.SetLastRecord(modelList);
|
|
if (ConfigHelper.Smi_HangTian_IsWriteLog)
|
{
|
LogHelper.Info($"航天写入Redis {modelList.Count} 条振动数据");
|
}
|
|
//获取配置
|
var configure = new Service.DataDockingConfigure().GetByID(ConfigHelper.Smi_HangTian_CorpID, ConfigHelper.Smi_HangTian_ConfigureID);
|
if (configure != null)
|
{
|
if (configure.Mappers != null && configure.Mappers.Count > 0)
|
{
|
var receiveList = new List<Model.MonitorDataDockingReceiveRecord>();
|
foreach (var model in modelList)
|
{
|
var mapper = configure.Mappers.Find(t => t.SignId == model.ObjectId);
|
if (mapper != null)
|
{
|
var monitor = new Service.MonitorPoint().GetExSignalWithSignalTypeByID(configure.CorpID, mapper.SysId);
|
if (monitor != null)
|
{
|
if (monitor.MonitorType == Model.eMonitorType.Vibration)
|
{
|
var receive = new Model.MonitorDataDockingReceiveRecord();
|
receive.SysId = monitor.ID;
|
receive.RecordType = monitor.MonitorType;
|
receive.SrcTime = model.SrcTime;
|
receive.DataStatus = model.DataStatus;
|
|
//子项列表
|
var receiveSubList = new List<Model.MonitorDataDockingReceiveSubRecord>();
|
|
//配置
|
var signal_config = monitor.SignalList.Find(t => t.Flags != null && t.Flags.Contains(LogicFlags.配置));
|
if (signal_config != null)
|
{
|
var config = model.Adapt<Model.SmiHangTianVibrationRecord, Model.SmiHangTianVibrationConfig>();
|
var config_json = JsonHelper.Object2Json(config);
|
var config_sub = new Model.MonitorDataDockingReceiveSubRecord();
|
config_sub.SysId = signal_config.ID;
|
config_sub.SrcValue = config_json;
|
receiveSubList.Add(config_sub);
|
}
|
|
//转速
|
var signal_rpm = monitor.SignalList.Find(t => t.Flags != null && t.Flags.Contains(LogicFlags.转速));
|
if (signal_rpm != null)
|
{
|
var rpm_sub = new Model.MonitorDataDockingReceiveSubRecord();
|
rpm_sub.SysId = signal_rpm.ID;
|
rpm_sub.SrcValue = model.Speed.ToString();
|
receiveSubList.Add(rpm_sub);
|
}
|
|
//间歇电压
|
var signal_u = monitor.SignalList.Find(t => t.Flags != null && t.Flags.Contains(LogicFlags.间歇电压));
|
if (signal_u != null)
|
{
|
var u_sub = new Model.MonitorDataDockingReceiveSubRecord();
|
u_sub.SysId = signal_u.ID;
|
u_sub.SrcValue = model.GapValue.ToString();
|
receiveSubList.Add(u_sub);
|
}
|
|
//通频值
|
var signal_tp = monitor.SignalList.Find(t => t.Flags != null && t.Flags.Contains(LogicFlags.通频值));
|
if (signal_tp != null)
|
{
|
var tp_sub = new Model.MonitorDataDockingReceiveSubRecord();
|
tp_sub.SysId = signal_tp.ID;
|
tp_sub.SrcValue = model.OverValue.ToString();
|
receiveSubList.Add(tp_sub);
|
}
|
|
//波形
|
var signal_wave = monitor.SignalList.Find(t => t.Flags != null && t.Flags.Contains(LogicFlags.波形));
|
if (signal_wave != null)
|
{
|
var wave_sub = new Model.MonitorDataDockingReceiveSubRecord();
|
wave_sub.SysId = signal_wave.ID;
|
wave_sub.SrcValue = model.Wave;
|
receiveSubList.Add(wave_sub);
|
}
|
|
receive.SrcValue = Model.MonitorDataDockingReceiveSubRecord.ToJson(receiveSubList);
|
receiveList.Add(receive);
|
}
|
}
|
}
|
}
|
if (receiveList.Count > 0)
|
{
|
var queueHelper = new RabbitMqQueueHelper();
|
var bol = queueHelper.Push(ConfigHelper.DataDockingQueueName, new Model.MonitorDataDockingCorpRecord()
|
{
|
CorpID = configure.CorpID,
|
ConfigureID = configure.ID,
|
Records = receiveList
|
});
|
if (bol)
|
{
|
if (ConfigHelper.Smi_HangTian_IsWriteLog)
|
{
|
LogHelper.Info($"航天推入通道 {receiveList.Count} 条振动数据");
|
}
|
return true;
|
}
|
}
|
}
|
}
|
|
return false;
|
|
}
|
|
/// <summary>
|
/// 通过 ObjectId 查询最近一条记录
|
/// </summary>
|
[Route("QueryLastRecordByObjectId")]
|
[HttpGet]
|
public SmiHangTianVibrationRecordDto QueryLastRecordByObjectId([Required, DataValidation(AllowEmptyStrings = false)] string ObjectId)
|
{
|
var redisCacheHelper = new RedisCache.SmiHangTianVibrationRecord();
|
var model = redisCacheHelper.GetLastRecord(ObjectId);
|
if (ConfigHelper.Smi_HangTian_IsWriteLog)
|
{
|
LogHelper.Info($"航天通过ObjectId： {ObjectId} 获取 {(model == null ? 0:1)} 条");
|
}
|
var dto = model?.Adapt<Model.SmiHangTianVibrationRecord, SmiHangTianVibrationRecordDto>();
|
return dto;
|
}
|
|
/// <summary>
|
/// 通过 ObjectId 查询最近
|
/// </summary>
|
[Route("QueryLastRecordByObjectIds")]
|
[HttpGet]
|
public List<SmiHangTianVibrationRecordDto> QueryLastRecordByObjectIds(string ObjectIds)
|
{
|
var ids = StringListHelper.ToList(ObjectIds);
|
if (ids == null || ids.Count() < 1)
|
{
|
return default;
|
}
|
var redisCacheHelper = new RedisCache.SmiHangTianVibrationRecord();
|
var modelList = redisCacheHelper.GetLastRecord(ids);
|
if (ConfigHelper.Smi_HangTian_IsWriteLog)
|
{
|
LogHelper.Info($"航天通过ObjectId： {ObjectIds} 获取 {(modelList == null ? 0 : modelList.Count)} 条");
|
}
|
var dtoList = modelList?.Select(x => x.Adapt<Model.SmiHangTianVibrationRecord, SmiHangTianVibrationRecordDto>()).ToList();
|
return dtoList;
|
}
|
|
/// <summary>
|
/// 通过 ObjectId 查询最近
|
/// </summary>
|
[Route("QueryLastRecordStartWith")]
|
[HttpGet]
|
public List<SmiHangTianVibrationRecordDto> QueryLastRecordStartWith([Required, DataValidation(AllowEmptyStrings = false)] string ObjectId)
|
{
|
var redisCacheHelper = new RedisCache.SmiHangTianVibrationRecord();
|
var modelList = redisCacheHelper.GetLastRecordStartWith(ObjectId);
|
if (ConfigHelper.Smi_HangTian_IsWriteLog)
|
{
|
LogHelper.Info($"航天通过ObjectId： {ObjectId} 获取 {(modelList == null ? 0 : modelList.Count)} 条");
|
}
|
var dtoList = modelList?.Select(x => x.Adapt<Model.SmiHangTianVibrationRecord, SmiHangTianVibrationRecordDto>()).ToList();
|
return dtoList;
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
}
|
}
|
