Files
2025-11-21 08:48:01 +08:00

55 lines
1.8 KiB
C#

using CommonEntity;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using MongoDB.Driver;
namespace BLWLogServer.Controllers
{
[Route("api/[controller]/[action]")]
[ApiController]
public class PowerController : ControllerBase
{
public IMongoClient _client;
public PowerController(IMongoClient mongo)
{
this._client = mongo;
}
[HttpPost()]
public ReturnInfo GetPowerAnalysis([FromBody] QueryDate query)
{
ReturnInfo r = new ReturnInfo();
try
{
int size = query.PageSize;
int index = query.PageIndex;
string st = query.Start_Time;
string et = query.End_Time;
DateTime sst = DateTime.Parse(st);
DateTime eet = DateTime.Parse(et);
var collection = _client.GetDatabase("udppackage").GetCollection<NengHao_db>("powermonitor");
//构建查询条件
long code = 0;
long.TryParse(query.HotelCode,out code);
var filter = Builders<NengHao_db>.Filter.And(
Builders<NengHao_db>.Filter.Gt(x => x.ReportTime, sst),
Builders<NengHao_db>.Filter.Lt(x => x.ReportTime, eet),
Builders<NengHao_db>.Filter.Eq(x => x.HotelCode, code)
);
long totalCount = collection.CountDocuments(filter);
var results = collection.Find(filter).ToList(); // 跳过前面的记录
r.isok = true;
r.response = results;
}
catch (Exception ex)
{
r.isok = false;
r.message = ex.Message;
}
return r;
}
}
}