1954 lines
80 KiB
C#
1954 lines
80 KiB
C#
using DocumentFormat.OpenXml.EMMA;
|
||
using DocumentFormat.OpenXml.Spreadsheet;
|
||
using Hopetry.App.SugarModel.CommonModel;
|
||
using Infrastructure;
|
||
using Infrastructure.Extensions;
|
||
using Infrastructure.Utilities;
|
||
using Jiguang.JPush;
|
||
using Jiguang.JPush.Model;
|
||
using Microsoft.AspNetCore.Authorization;
|
||
using Microsoft.AspNetCore.Builder.Extensions;
|
||
using Microsoft.AspNetCore.Http;
|
||
using Microsoft.AspNetCore.Mvc;
|
||
using Microsoft.AspNetCore.Mvc.RazorPages;
|
||
using Microsoft.Extensions.Configuration;
|
||
using Microsoft.Extensions.Options;
|
||
using Newtonsoft.Json;
|
||
using NPOI.HSSF.UserModel;
|
||
using NPOI.SS.UserModel;
|
||
using NPOI.XSSF.UserModel;
|
||
using OpenAuth.App.BaseApp.Base;
|
||
using OpenAuth.App.Common;
|
||
using OpenAuth.App.Const;
|
||
using OpenAuth.App.Interface;
|
||
using OpenAuth.App.Response;
|
||
using OpenAuth.App.ServiceApp.FireManagement.Request;
|
||
using OpenAuth.App.ServiceApp.FireManagement.Response;
|
||
using OpenAuth.Repository;
|
||
using OpenAuth.Repository.Domain;
|
||
using OpenAuth.Repository.Domain.FireManagement;
|
||
using Org.BouncyCastle.Ocsp;
|
||
using SqlSugar;
|
||
using System.Net.WebSockets;
|
||
using System.Security.Cryptography;
|
||
using System.Text;
|
||
using Hopetry.App.SugarModel.FeiXianModel.YingJingJu;
|
||
using Infrastructure.Helpers;
|
||
using Yitter.IdGenerator;
|
||
using static Org.BouncyCastle.Math.EC.ECCurve;
|
||
|
||
namespace OpenAuth.App.ServiceApp.FireManagement
|
||
{
|
||
public class FireManagementApp : SqlSugarBaseApp<FmFireclueTask, SugarDbContext>
|
||
{
|
||
private ClientWebSocket _socket;
|
||
private IConfiguration _configuration;
|
||
IOptions<KikvisionConfig> _options;
|
||
IOptions<KikvisionConfig2> _options2;
|
||
IOptions<JPushClientConfig> _jpoptions;
|
||
|
||
public FireManagementApp(IConfiguration configuration, IOptions<KikvisionConfig> options, IOptions<KikvisionConfig2> options2,
|
||
IOptions<JPushClientConfig> jpoptions, ISugarUnitOfWork<SugarDbContext> unitWork,
|
||
ISimpleClient<FmFireclueTask> repository, IAuth auth) : base(unitWork, repository, auth)
|
||
{
|
||
_auth = auth;
|
||
_options = options;
|
||
_options2 = options2;
|
||
_configuration = configuration;
|
||
_jpoptions = jpoptions;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 下发防火线索任务
|
||
/// </summary>
|
||
/// <param name="info"></param>
|
||
/// <returns></returns>
|
||
public async Task<Response<bool>> IssuedFireClueTask(FmFireclueTask info)
|
||
{
|
||
using (var db = base.UnitWork.CreateContext())
|
||
{
|
||
var userId = _auth.GetCurrentUser().User.Id;
|
||
info.Id = YitIdHelper.NextId();
|
||
info.State = (int)TaskState.待接收;
|
||
info.TaskTime = DateTime.Now;
|
||
info.IsDelete = false;
|
||
await db.FmFireclueTask.InsertAsync(info);
|
||
List<FmFireTaskUser> fftuList = new List<FmFireTaskUser>();
|
||
if (info.RecipientUsers == null || info.RecipientUsers.Count == 0)
|
||
{
|
||
var userList = await db.User.AsQueryable().Where(r => r.Status == 0).ToListAsync();
|
||
userList.ForEach(user =>
|
||
{
|
||
FmFireTaskUser fftu = new FmFireTaskUser
|
||
{
|
||
Id = YitIdHelper.NextId(),
|
||
UserId = user.Id.ToString(),
|
||
TaskId = info.Id,
|
||
ReceiveTime = DateTime.Now,
|
||
State = (int)TaskState.待接收
|
||
};
|
||
fftuList.Add(fftu);
|
||
});
|
||
}
|
||
else
|
||
{
|
||
info.RecipientUsers.ForEach(user =>
|
||
{
|
||
FmFireTaskUser fftu = new FmFireTaskUser
|
||
{
|
||
Id = YitIdHelper.NextId(),
|
||
UserId = user,
|
||
TaskId = info.Id,
|
||
ReceiveTime = DateTime.Now,
|
||
State = (int)TaskState.待接收
|
||
};
|
||
fftuList.Add(fftu);
|
||
});
|
||
}
|
||
|
||
await db.FmFireTaskUser.InsertRangeAsync(fftuList);
|
||
await db.FmFireclueinfoLog.InsertAsync(new FmFireclueinfoLog
|
||
{
|
||
Id = YitIdHelper.NextId(),
|
||
Fireclueid = info.Fireclueid,
|
||
Title = "任务下发",
|
||
CreateTime = DateTime.Now,
|
||
CreateId = userId,
|
||
Content = info.Content
|
||
});
|
||
if (db.Commit())
|
||
{
|
||
//// websocket 通讯
|
||
//WebSocketModel wsModel = new WebSocketModel
|
||
//{
|
||
// Module = "任务下发",
|
||
// Data = info
|
||
//};
|
||
//SendSocketMessage(wsModel);
|
||
JPushInfo("任务下发", info.Id);
|
||
return new Response<bool> { Result = true, Message = "操作成功" };
|
||
}
|
||
else
|
||
{
|
||
return new Response<bool> { Result = false, Message = "操作失败" };
|
||
}
|
||
}
|
||
}
|
||
|
||
//删除任务
|
||
public async Task<Response<bool>> DeleteTask(long id)
|
||
{
|
||
using (var db = base.UnitWork.CreateContext())
|
||
{
|
||
var userId = _auth.GetCurrentUser().User.Id;
|
||
var taskinfo = await db.FmFireclueTask.AsQueryable().FirstAsync(r => r.Id == id);
|
||
await db.FmFireclueTask.UpdateAsync(r => new FmFireclueTask
|
||
{
|
||
IsDelete = true
|
||
}, r => r.Id == id);
|
||
await db.FmFireclueinfoLog.InsertAsync(new FmFireclueinfoLog
|
||
{
|
||
Id = YitIdHelper.NextId(),
|
||
Fireclueid = taskinfo.Fireclueid,
|
||
Title = "任务删除",
|
||
CreateTime = DateTime.Now,
|
||
CreateId = userId,
|
||
Content = "删除任务"
|
||
});
|
||
if (db.Commit())
|
||
{
|
||
return new Response<bool> { Result = true, Message = "操作成功" };
|
||
}
|
||
else
|
||
{
|
||
return new Response<bool> { Result = false, Message = "操作失败" };
|
||
}
|
||
}
|
||
}
|
||
|
||
//更新任务状态
|
||
public async Task<Response<bool>> ReceiveFireClueTask(long taskid, int state, string recipient)
|
||
{
|
||
using (var db = base.UnitWork.CreateContext())
|
||
{
|
||
await db.FmFireTaskUser.UpdateAsync(r => new FmFireTaskUser
|
||
{
|
||
State = state,
|
||
ReceiveTime = DateTime.Now,
|
||
}, r => r.TaskId == taskid && r.UserId == recipient);
|
||
if (db.Commit())
|
||
{
|
||
return new Response<bool> { Result = true, Message = "操作成功" };
|
||
}
|
||
else
|
||
{
|
||
return new Response<bool> { Result = false, Message = "操作失败" };
|
||
}
|
||
}
|
||
}
|
||
|
||
//更新任务图片或者新增线索
|
||
public async Task<Response<bool>> ReceiveTaskImage(string info)
|
||
{
|
||
using (var db = base.UnitWork.CreateContext())
|
||
{
|
||
var obj = Newtonsoft.Json.JsonConvert.DeserializeObject<ReciveTaskInfo>(info);
|
||
if (obj != null)
|
||
{
|
||
var fireInfo = await db.FmFireclueTask.GetFirstAsync(r => r.Id == obj.taskid);
|
||
var imagepath = fireInfo.Image == null ? obj.path : fireInfo.Image + "," + obj.path;
|
||
await db.FmFireclueTask.UpdateAsync(r => new FmFireclueTask
|
||
{
|
||
Image = imagepath
|
||
}, r => r.Id == obj.taskid);
|
||
}
|
||
else
|
||
{
|
||
//新增线索信息
|
||
}
|
||
|
||
if (db.Commit())
|
||
{
|
||
return new Response<bool> { Result = true, Message = "操作成功" };
|
||
}
|
||
else
|
||
{
|
||
return new Response<bool> { Result = false, Message = "操作失败" };
|
||
}
|
||
}
|
||
}
|
||
|
||
class ReciveTaskInfo
|
||
{
|
||
public long taskid { get; set; }
|
||
public string path { get; set; }
|
||
}
|
||
|
||
/// <summary>
|
||
/// 查询下发人员
|
||
/// </summary>
|
||
/// <param name="username"></param>
|
||
/// <returns></returns>
|
||
public async Task<Response<List<SysUserResp>>> LoadFireClueUser(string username, string unitname)
|
||
{
|
||
using (var db = base.UnitWork.CreateContext())
|
||
{
|
||
var users = await db.User.AsQueryable()
|
||
.WhereIF(!string.IsNullOrEmpty(username), r => r.Name.Contains(username))
|
||
.WhereIF(!string.IsNullOrEmpty(unitname), r => r.UnitName.Contains(username))
|
||
.Where(r => r.Status == 0)
|
||
.Select(r => new SysUserResp
|
||
{
|
||
Id = r.Id,
|
||
Name = r.Name
|
||
}).ToListAsync();
|
||
return new Response<List<SysUserResp>> { Result = users };
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 查询任务列表--后台使用
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
public async Task<Response<PageInfo<List<FmFireclueTask>>>> GetTaskPageList(FireClueTaskReq req)
|
||
{
|
||
using (var db = base.UnitWork.CreateContext())
|
||
{
|
||
RefAsync<int> totalNumber = 0;
|
||
var tasks = await db.FmFireclueTask.AsQueryable()
|
||
.Where(r => r.IsDelete == false)
|
||
.WhereIF(req.state!=null,r=>r.State==req.state)
|
||
.WhereIF(req.type!=null,r=>r.Type==req.type)
|
||
.WhereIF(req.tasktimebegin!=null&&req.tasktimeend!=null,r=>r.TaskTime>=req.tasktimebegin&&r.TaskTime<=req.tasktimeend)
|
||
.LeftJoin<FmFireclueInfo>((r,f)=>r.Fireclueid==f.Id)
|
||
.WhereIF(!string.IsNullOrEmpty(req.name),(r,f)=>r.Content.Contains(req.name)||f.Describe.Contains(req.name))
|
||
.ToPageListAsync(req.page, req.limit, totalNumber);
|
||
return new Response<PageInfo<List<FmFireclueTask>>>
|
||
{
|
||
Result = new PageInfo<List<FmFireclueTask>> { Items = tasks, Total = totalNumber }
|
||
};
|
||
}
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// 查询任务列表
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
public async Task<Response<List<FmFireclueTask>>> GetTaskList()
|
||
{
|
||
using (var db = base.UnitWork.CreateContext())
|
||
{
|
||
var tasks = await db.FmFireclueTask.AsQueryable()
|
||
.Where(r => r.IsDelete == false)
|
||
.ToListAsync();
|
||
return new Response<List<FmFireclueTask>> { Result = tasks };
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 任务详情
|
||
/// </summary>
|
||
/// <param name="id"></param>
|
||
/// <param name="userid"></param>
|
||
/// <returns></returns>
|
||
public async Task<Response<FireClueTaskResp>> LoadFireTaskInfoById(long id, string userid)
|
||
{
|
||
using (var db = base.UnitWork.CreateContext())
|
||
{
|
||
var info = await db.FmFireclueTask.AsQueryable()
|
||
.LeftJoin<SysUser>((a, b) => a.TaskUser == b.Id.ToString())
|
||
.Where((a, b) => a.Id == id)
|
||
.Select((a, b) => new FireClueTaskResp()
|
||
{
|
||
Id = a.Id,
|
||
Content = a.Content,
|
||
Lat = a.Lat,
|
||
Lng = a.Lng,
|
||
Address = a.Address,
|
||
State = a.State,
|
||
TaskUser = a.TaskUser,
|
||
TaskTime = a.TaskTime,
|
||
CompleteTime = a.CompleteTime,
|
||
TaskUserName = b.Name,
|
||
Audio = a.Audio,
|
||
Image = a.Image,
|
||
})
|
||
.Mapper(a => a.StateName = ((TaskState)a.State).GetDescription())
|
||
.FirstAsync();
|
||
var rep = db.FmFireTaskUser.AsQueryable().Where(r => r.UserId == userid && r.TaskId == id).First();
|
||
if (rep != null)
|
||
{
|
||
info.State = rep.State;
|
||
info.StateName = ((TaskState)rep.State).GetDescription();
|
||
}
|
||
|
||
return new Response<FireClueTaskResp> { Result = info };
|
||
}
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// 查询人员单位信息
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
public async Task<Response<List<FmUserUnit>>> GetUserUnit()
|
||
{
|
||
using (var db = base.UnitWork.CreateContext())
|
||
{
|
||
var userunit = await db.FmUserUnit.AsQueryable().ToListAsync();
|
||
return new Response<List<FmUserUnit>> { Result = userunit };
|
||
}
|
||
}
|
||
|
||
#region 单位管理
|
||
|
||
//添加人员单位
|
||
public async Task<Response<bool>> AddUserUnit(FmUserUnit info)
|
||
{
|
||
using (var db = base.UnitWork.CreateContext())
|
||
{
|
||
info.Id = YitIdHelper.NextId();
|
||
await db.FmUserUnit.InsertAsync(info);
|
||
if (db.Commit())
|
||
{
|
||
return new Response<bool> { Result = true, Message = "操作成功" };
|
||
}
|
||
else
|
||
{
|
||
return new Response<bool> { Result = false, Message = "操作失败" };
|
||
}
|
||
}
|
||
}
|
||
|
||
//编辑人员单位
|
||
public async Task<Response<bool>> EditUserUnit(FmUserUnit info)
|
||
{
|
||
using (var db = base.UnitWork.CreateContext())
|
||
{
|
||
await db.FmUserUnit.UpdateAsync(info);
|
||
if (db.Commit())
|
||
{
|
||
return new Response<bool> { Result = true, Message = "操作成功" };
|
||
}
|
||
else
|
||
{
|
||
return new Response<bool> { Result = false, Message = "操作失败" };
|
||
}
|
||
}
|
||
}
|
||
|
||
//获取单个人员单位
|
||
public async Task<Response<FmUserUnit>> LoadUserUnitById(long id)
|
||
{
|
||
using (var db = base.UnitWork.CreateContext())
|
||
{
|
||
var info = await db.FmUserUnit.AsQueryable().FirstAsync(r => r.Id == id);
|
||
return new Response<FmUserUnit> { Result = info };
|
||
}
|
||
}
|
||
|
||
//删除人员单位
|
||
public async Task<Response<bool>> DeleteUserUnit(long id)
|
||
{
|
||
using (var db = base.UnitWork.CreateContext())
|
||
{
|
||
await db.FmUserUnit.DeleteAsync(r => r.Id == id);
|
||
if (db.Commit())
|
||
{
|
||
return new Response<bool> { Result = true, Message = "操作成功" };
|
||
}
|
||
else
|
||
{
|
||
return new Response<bool> { Result = false, Message = "操作失败" };
|
||
}
|
||
}
|
||
}
|
||
|
||
|
||
public Response<bool> FireUserUnitUpload(IFormFileCollection formFiles)
|
||
{
|
||
var user = _auth.GetCurrentUser().User;
|
||
IFormFile file = formFiles[0];
|
||
Response<bool> response = new Response<bool>();
|
||
try
|
||
{
|
||
//存储文件到服务器
|
||
if (file != null)
|
||
{
|
||
if (file.FileName.IndexOf(".xls") > 0 || file.FileName.IndexOf(".xlsx") > 0)
|
||
{
|
||
//数据库导入
|
||
IWorkbook workbook = null;
|
||
if (file.FileName.IndexOf(".xlsx") > 0)
|
||
{
|
||
using (var stream = file.OpenReadStream())
|
||
{
|
||
workbook = new XSSFWorkbook(stream); //excel的版本2007
|
||
}
|
||
}
|
||
else if (file.FileName.IndexOf(".xls") > 0)
|
||
{
|
||
using (var stream = file.OpenReadStream())
|
||
{
|
||
workbook = new HSSFWorkbook(stream); //excel的版本2003
|
||
}
|
||
}
|
||
|
||
ISheet sheet;
|
||
sheet = workbook.GetSheetAt(0);
|
||
List<FmUserUnit> fulist = new List<FmUserUnit>();
|
||
if (sheet != null)
|
||
{
|
||
IRow firstRow = sheet.GetRow(0);
|
||
string name = firstRow.GetCell(0).ToString();
|
||
//最后一列的标号
|
||
int rowCount = sheet.LastRowNum;
|
||
for (int i = 1; i <= rowCount; i++)
|
||
{
|
||
IRow row = sheet.GetRow(i);
|
||
if (row == null || string.IsNullOrEmpty(row.GetCell(0).ToString())) continue;
|
||
FmUserUnit fu = new FmUserUnit();
|
||
fu.Id = YitIdHelper.NextId();
|
||
fu.UnitName = row.GetCell(1).ToString();
|
||
fu.UnitType = row.GetCell(2).ToString();
|
||
fu.Description = row.GetCell(3).ToString();
|
||
fu.CreateTime = DateTime.Now;
|
||
fu.CreateUserId = user.Id.ToString();
|
||
fulist.Add(fu);
|
||
}
|
||
}
|
||
|
||
using (var db = base.UnitWork.CreateContext())
|
||
{
|
||
db.FmUserUnit.InsertRange(fulist);
|
||
if (db.Commit())
|
||
{
|
||
return new Response<bool> { Result = true, Message = "导入成功" };
|
||
}
|
||
else
|
||
{
|
||
return new Response<bool> { Result = false, Message = "导入失败" };
|
||
}
|
||
}
|
||
}
|
||
else
|
||
{
|
||
response.Result = false;
|
||
response.Message = "上传文件类型错误，请上传Excel文件";
|
||
response.Code = 300;
|
||
}
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
response.Result = false;
|
||
response.Code = 400;
|
||
response.Message = "上传文件类型错误";
|
||
}
|
||
|
||
return response;
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 火情线索
|
||
|
||
public async Task<Response<bool>> AddFireClueInfo(FmFireclueInfo info)
|
||
{
|
||
using (var db = base.UnitWork.CreateContext())
|
||
{
|
||
info.Id = YitIdHelper.NextId();
|
||
info.State = (int)State.上报;
|
||
info.ReportTime = DateTime.Now;
|
||
var today = DateTime.Now.Date;
|
||
var tomorrow = today.AddDays(1);
|
||
var exitinfo = db.FmFireclueInfo
|
||
.AsQueryable()
|
||
.Count(a => a.ReportTime >= today && a.ReportTime < tomorrow);
|
||
string excount = exitinfo.ToString("D3");
|
||
string sourceType = info.SourceType switch
|
||
{
|
||
1 => "R",
|
||
2 => "J",
|
||
3 => "W",
|
||
4 => "R",
|
||
5 => "R",
|
||
6 => "Y",
|
||
_ => "R"
|
||
};
|
||
|
||
// 生成线索编号
|
||
info.ClueNo = $"LH{DateTime.Now:yyyyMMdd}{excount}{sourceType}";
|
||
await db.FmFireclueInfo.InsertAsync(info);
|
||
await db.FmFireclueinfoLog.InsertAsync(new FmFireclueinfoLog
|
||
{
|
||
Id = YitIdHelper.NextId(),
|
||
Fireclueid = info.Id,
|
||
Title = "火情线索上报",
|
||
CreateTime = DateTime.Now,
|
||
CreateId = info.CreateId,
|
||
Content = info.Describe
|
||
});
|
||
if (db.Commit())
|
||
{
|
||
JPushInfo("火情信息", 0);
|
||
return new Response<bool> { Result = true, Message = "操作成功" };
|
||
}
|
||
else
|
||
{
|
||
return new Response<bool> { Result = false, Message = "操作失败" };
|
||
}
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 查询火情线索
|
||
/// </summary>
|
||
/// <param name="id"></param>
|
||
/// <returns></returns>
|
||
public async Task<Response<FmFireclueInfo>> LoadClueInfoById(long id)
|
||
{
|
||
using (var db = base.UnitWork.CreateContext())
|
||
{
|
||
var info = await db.FmFireclueInfo.AsQueryable()
|
||
.FirstAsync(r => r.Id == id);
|
||
return new Response<FmFireclueInfo> { Result = info };
|
||
}
|
||
}
|
||
|
||
public async Task<Response<dynamic>> LoadClueWithInfoById(long id)
|
||
{
|
||
using (var db = base.UnitWork.CreateContext())
|
||
{
|
||
var clueInfo = await db.FmFireclueInfo.AsQueryable()
|
||
.FirstAsync(r => r.Id == id);
|
||
//查找摄像头
|
||
var sqlStr = $@"select ""Id"",""Name"",""SerialNumber"" from fm_camera
|
||
where ST_DWithin(ST_GeographyFromText('POINT({clueInfo.Lng} {clueInfo.Lat})'),
|
||
ST_GeographyFromText('POINT('||""Lng""||' '||""Lat""||')'),1000)=true";
|
||
var cameraInfo = await db.Db.Ado.GetDataTableAsync(sqlStr);
|
||
var endInfo = new
|
||
{
|
||
clueInfo,
|
||
cameraInfo,
|
||
};
|
||
return new Response<dynamic> { Result = endInfo };
|
||
}
|
||
}
|
||
|
||
//查询火情线索列表
|
||
public async Task<Response<List<FmFireclueInfo>>> GetFireClueList()
|
||
{
|
||
using (var db = base.UnitWork.CreateContext())
|
||
{
|
||
var list = await db.FmFireclueInfo.AsQueryable().Where(r => r.State == 1).ToListAsync();
|
||
return new Response<List<FmFireclueInfo>> { Result = list };
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 修改火情线索状态
|
||
/// </summary>
|
||
/// <param name="id"></param>
|
||
/// <param name="state"></param>
|
||
/// <returns></returns>
|
||
public async Task<Response<bool>> UpdatFireState(long id, int state)
|
||
{
|
||
using (var db = base.UnitWork.CreateContext())
|
||
{
|
||
var userId = _auth.GetCurrentUser().User.Id;
|
||
await db.FmFireclueInfo.UpdateAsync(r => new FmFireclueInfo
|
||
{
|
||
State = state,
|
||
ModifyTime = DateTime.Now,
|
||
ModifyId = userId
|
||
}, r => r.Id == id);
|
||
await db.FmFireclueinfoLog.InsertAsync(new FmFireclueinfoLog
|
||
{
|
||
Id = YitIdHelper.NextId(),
|
||
Fireclueid = id,
|
||
Title = "修改火情线索状态",
|
||
CreateTime = DateTime.Now,
|
||
CreateId = userId,
|
||
Content = "火情线索状态变化"
|
||
});
|
||
if (db.Commit())
|
||
{
|
||
return new Response<bool> { Result = true, Message = "操作成功" };
|
||
}
|
||
else
|
||
{
|
||
return new Response<bool> { Result = false, Message = "操作失败" };
|
||
}
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 添加火情日志
|
||
/// </summary>
|
||
/// <param name="info"></param>
|
||
/// <returns></returns>
|
||
public async Task<Response<bool>> AddFireClueLogInfo(FmFireclueinfoLog info)
|
||
{
|
||
using (var db = base.UnitWork.CreateContext())
|
||
{
|
||
var userId = _auth.GetCurrentUser().User.Id;
|
||
info.CreateId = userId;
|
||
info.CreateTime = DateTime.Now;
|
||
await db.FmFireclueinfoLog.InsertAsync(info);
|
||
if (db.Commit())
|
||
{
|
||
return new Response<bool> { Result = true, Message = "操作成功" };
|
||
}
|
||
else
|
||
{
|
||
return new Response<bool> { Result = false, Message = "操作失败" };
|
||
}
|
||
}
|
||
}
|
||
|
||
//按月统计火情线索
|
||
public async Task<Response<List<FireInfoForChart>>> GetFireClueStatistics(int type)
|
||
{
|
||
using (var db = base.UnitWork.CreateContext())
|
||
{
|
||
if (type == 1)
|
||
{
|
||
DateTime firstDayOfMonth = new DateTime(DateTime.Now.Year, DateTime.Now.Month, 1);
|
||
var list = await db.FmFireclueInfo.AsQueryable()
|
||
//.Where(r => r.State == 1)
|
||
.Where(r => r.ReportTime >= firstDayOfMonth)
|
||
.GroupBy(r => new { r.ReportTime.Day })
|
||
.Select(r => new FireInfoForChart
|
||
{
|
||
DateTime = r.ReportTime.Day.ToString() + "日",
|
||
Count = SqlFunc.AggregateCount(r.Id)
|
||
}).ToListAsync();
|
||
return new Response<List<FireInfoForChart>> { Result = list };
|
||
}
|
||
else
|
||
{
|
||
DateTime firstDayOfYear = new DateTime(DateTime.Now.Year, 1, 1);
|
||
var list = await db.FmFireclueInfo.AsQueryable()
|
||
//.Where(r => r.State == 1)
|
||
.Where(r => r.ReportTime >= firstDayOfYear)
|
||
.GroupBy(r => new { r.ReportTime.Month })
|
||
.Select(r => new FireInfoForChart
|
||
{
|
||
DateTime = r.ReportTime.Month.ToString() + "月",
|
||
Count = SqlFunc.AggregateCount(r.Id)
|
||
}).ToListAsync();
|
||
return new Response<List<FireInfoForChart>> { Result = list };
|
||
}
|
||
}
|
||
}
|
||
|
||
public async Task<Response<List<FireInfoStateForChart>>> GetFireClueStatisticsByState(int type)
|
||
{
|
||
using (var db = base.UnitWork.CreateContext())
|
||
{
|
||
//if (type == 1)
|
||
//{
|
||
// DateTime firstDayOfMonth = new DateTime(DateTime.Now.Year, DateTime.Now.Month, 1);
|
||
// var list = await db.FmFireclueInfo.AsQueryable()
|
||
// .Where(r => r.ReportTime >= firstDayOfMonth)
|
||
// .GroupBy(r => new { r.ReportTime.Day })
|
||
// .Select(r => new FireInfoStateForChart
|
||
// {
|
||
// DateTime = r.ReportTime.Day.ToString() + "日",
|
||
// TreatedCount = SqlFunc.AggregateSum(SqlFunc.IIF(r.State >= 3, 1, 0)),
|
||
// UntreatedCount = SqlFunc.AggregateSum(SqlFunc.IIF(r.State < 3, 1, 0))
|
||
// }).ToListAsync();
|
||
// return new Response<List<FireInfoStateForChart>> { Result = list };
|
||
//}
|
||
//else if (type == 2)
|
||
//{
|
||
// DateTime firstDayOfYear = new DateTime(DateTime.Now.Year, 1, 1);
|
||
// var list = await db.FmFireclueInfo.AsQueryable()
|
||
// .Where(r => r.ReportTime >= firstDayOfYear)
|
||
// .GroupBy(r => new { r.ReportTime.Month })
|
||
// .Select(r => new FireInfoStateForChart
|
||
// {
|
||
// DateTime = r.ReportTime.Month.ToString() + "月",
|
||
// TreatedCount = SqlFunc.AggregateSum(SqlFunc.IIF(r.State >= 3, 1, 0)),
|
||
// UntreatedCount = SqlFunc.AggregateSum(SqlFunc.IIF(r.State < 3, 1, 0))
|
||
// }).ToListAsync();
|
||
// return new Response<List<FireInfoStateForChart>> { Result = list };
|
||
//}
|
||
//else
|
||
//{
|
||
// DateTime firstDayOfYear = DateTime.Now.AddYears(-3);
|
||
// var list = await db.FmFireclueInfo.AsQueryable()
|
||
// .Where(r => r.ReportTime >= firstDayOfYear)
|
||
// .GroupBy(r => new { r.ReportTime.Year })
|
||
// .Select(r => new FireInfoStateForChart
|
||
// {
|
||
// DateTime = r.ReportTime.Year.ToString() + "年",
|
||
// TreatedCount = SqlFunc.AggregateSum(SqlFunc.IIF(r.State >= 3, 1, 0)),
|
||
// UntreatedCount = SqlFunc.AggregateSum(SqlFunc.IIF(r.State < 3, 1, 0))
|
||
// }).ToListAsync();
|
||
// return new Response<List<FireInfoStateForChart>> { Result = list };
|
||
//}
|
||
|
||
if (type == 1)
|
||
{
|
||
// 计算14天的日期范围
|
||
DateTime startDate = DateTime.Now.AddDays(-14).Date;
|
||
DateTime endDate = DateTime.Now.Date;
|
||
|
||
// 生成14天的日期列表
|
||
var dateRange = Enumerable.Range(0, (endDate - startDate).Days + 1)
|
||
.Select(offset => startDate.AddDays(offset))
|
||
.Select(date => new
|
||
{
|
||
Date = date,
|
||
DayString = date.Month.ToString() + "." + date.Day.ToString()
|
||
})
|
||
.ToList();
|
||
|
||
// 查询实际数据
|
||
var dataQuery = await db.FmFireclueInfo.AsQueryable()
|
||
.Where(r => r.ReportTime >= startDate && r.ReportTime <= endDate)
|
||
.GroupBy(r => new { r.ReportTime.Date })
|
||
.Select(r => new FireInfoState
|
||
{
|
||
Date = r.ReportTime.Date,
|
||
TreatedCount = SqlFunc.AggregateSum(SqlFunc.IIF(r.State >= 3, 1, 0)),
|
||
UntreatedCount = SqlFunc.AggregateSum(SqlFunc.IIF(r.State < 3, 1, 0))
|
||
}).ToListAsync();
|
||
|
||
// 左连接，确保所有日期都显示
|
||
var list = (from date in dateRange
|
||
join data in dataQuery on date.Date equals data.Date into gj
|
||
from subData in gj.DefaultIfEmpty()
|
||
orderby date.Date ascending
|
||
select new FireInfoStateForChart
|
||
{
|
||
DateTime = date.DayString,
|
||
TreatedCount = subData?.TreatedCount ?? 0,
|
||
UntreatedCount = subData?.UntreatedCount ?? 0
|
||
})
|
||
.ToList();
|
||
|
||
return new Response<List<FireInfoStateForChart>> { Result = list };
|
||
}
|
||
else if (type == 2)
|
||
{
|
||
// 计算日期范围
|
||
var now = DateTime.Now;
|
||
var startDate = new DateTime(now.Year, now.Month, 1).AddMonths(-11);
|
||
var endDate = new DateTime(now.Year, now.Month, 1).AddMonths(1).AddDays(-1);
|
||
|
||
// 生成月份列表
|
||
var months = Enumerable.Range(0, 12)
|
||
.Select(i => new
|
||
{
|
||
Year = startDate.AddMonths(i).Year,
|
||
Month = startDate.AddMonths(i).Month,
|
||
Display = FormatMonthDisplay(startDate.AddMonths(i))
|
||
})
|
||
.ToList();
|
||
|
||
// 查询数据
|
||
var data = await db.FmFireclueInfo.AsQueryable()
|
||
.Where(r => r.ReportTime >= startDate && r.ReportTime <= endDate)
|
||
.GroupBy(r => new { r.ReportTime.Year, r.ReportTime.Month })
|
||
.Select(r => new
|
||
{
|
||
Year = r.ReportTime.Year,
|
||
Month = r.ReportTime.Month,
|
||
TreatedCount = SqlFunc.AggregateSum(SqlFunc.IIF(r.State >= 3, 1, 0)),
|
||
UntreatedCount = SqlFunc.AggregateSum(SqlFunc.IIF(r.State < 3, 1, 0))
|
||
})
|
||
.ToListAsync();
|
||
|
||
// 使用LINQ左连接
|
||
var result = (from month in months
|
||
join d in data
|
||
on new { month.Year, month.Month } equals new { d.Year, d.Month } into gj
|
||
from subData in gj.DefaultIfEmpty()
|
||
orderby month.Year, month.Month
|
||
select new FireInfoStateForChart
|
||
{
|
||
DateTime = month.Display,
|
||
TreatedCount = subData?.TreatedCount ?? 0,
|
||
UntreatedCount = subData?.UntreatedCount ?? 0
|
||
}).ToList();
|
||
return new Response<List<FireInfoStateForChart>> { Result = result };
|
||
}
|
||
else
|
||
{
|
||
// 计算统计年份范围
|
||
int currentYear = DateTime.Now.Year;
|
||
int startYear = currentYear - 5 + 1;
|
||
|
||
// 生成年份范围
|
||
var years = Enumerable.Range(startYear, 5)
|
||
.Select(y => y)
|
||
.ToList();
|
||
|
||
// 查询数据
|
||
var queryData = await db.FmFireclueInfo.AsQueryable()
|
||
.Where(r => r.ReportTime.Year >= startYear && r.ReportTime.Year <= currentYear)
|
||
.GroupBy(r => r.ReportTime.Year)
|
||
.Select(r => new
|
||
{
|
||
Year = r.ReportTime.Year,
|
||
TreatedCount = SqlFunc.AggregateSum(SqlFunc.IIF(r.State >= 3, 1, 0)),
|
||
UntreatedCount = SqlFunc.AggregateSum(SqlFunc.IIF(r.State < 3, 1, 0))
|
||
})
|
||
.ToListAsync();
|
||
|
||
// 生成结果，确保所有年份都有数据
|
||
var result = new List<FireInfoStateForChart>();
|
||
foreach (var year in years)
|
||
{
|
||
var yearData = queryData.FirstOrDefault(d => d.Year == year);
|
||
|
||
result.Add(new FireInfoStateForChart
|
||
{
|
||
DateTime = year.ToString() + "年",
|
||
TreatedCount = yearData?.TreatedCount ?? 0,
|
||
UntreatedCount = yearData?.UntreatedCount ?? 0
|
||
});
|
||
}
|
||
return new Response<List<FireInfoStateForChart>> { Result = result };
|
||
}
|
||
}
|
||
}
|
||
|
||
public async Task<Response<List<FireInfoDegreeForChart>>> GetFireClueStatisticsByDegreeType(int type)
|
||
{
|
||
using (var db = base.UnitWork.CreateContext())
|
||
{
|
||
if (type == 1)
|
||
{
|
||
// 计算14天的日期范围
|
||
DateTime startDate = DateTime.Now.AddDays(-14).Date;
|
||
DateTime endDate = DateTime.Now.Date;
|
||
|
||
// 生成14天的日期列表
|
||
var dateRange = Enumerable.Range(0, (endDate - startDate).Days + 1)
|
||
.Select(offset => startDate.AddDays(offset))
|
||
.Select(date => new
|
||
{
|
||
Date = date,
|
||
DayString =date.Month.ToString()+"." +date.Day.ToString()
|
||
})
|
||
.ToList();
|
||
|
||
// 查询实际数据
|
||
var dataQuery = await db.FmFireclueInfo.AsQueryable()
|
||
.Where(r => r.ReportTime >= startDate && r.ReportTime <= endDate)
|
||
.GroupBy(r => new { r.ReportTime.Date })
|
||
.Select(r => new FireInfoDegree
|
||
{
|
||
Date = r.ReportTime.Date,
|
||
ExtraLargeCount = SqlFunc.AggregateSum(SqlFunc.IIF(r.DegreeType == 1, 1, 0)),
|
||
LargeCount = SqlFunc.AggregateSum(SqlFunc.IIF(r.DegreeType == 2, 1, 0))
|
||
}).ToListAsync();
|
||
|
||
// 左连接，确保所有日期都显示
|
||
var list = (from date in dateRange
|
||
join data in dataQuery on date.Date equals data.Date into gj
|
||
from subData in gj.DefaultIfEmpty()
|
||
select new FireInfoDegreeForChart
|
||
{
|
||
DateTime = date.DayString,
|
||
ExtraLargeCount = subData?.ExtraLargeCount ?? 0,
|
||
LargeCount = subData?.LargeCount ?? 0
|
||
})
|
||
.OrderBy(x => x.DateTime) // 按日期排序
|
||
.ToList();
|
||
|
||
return new Response<List<FireInfoDegreeForChart>> { Result = list };
|
||
}
|
||
else if (type == 2)
|
||
{
|
||
// 计算日期范围
|
||
var now = DateTime.Now;
|
||
var startDate = new DateTime(now.Year, now.Month, 1).AddMonths(-11);
|
||
var endDate = new DateTime(now.Year, now.Month, 1).AddMonths(1).AddDays(-1);
|
||
|
||
// 生成月份列表
|
||
var months = Enumerable.Range(0, 12)
|
||
.Select(i => new
|
||
{
|
||
Year = startDate.AddMonths(i).Year,
|
||
Month = startDate.AddMonths(i).Month,
|
||
Display = FormatMonthDisplay(startDate.AddMonths(i))
|
||
})
|
||
.ToList();
|
||
|
||
// 查询数据
|
||
var data = await db.FmFireclueInfo.AsQueryable()
|
||
.Where(r => r.ReportTime >= startDate && r.ReportTime <= endDate)
|
||
.GroupBy(r => new { r.ReportTime.Year, r.ReportTime.Month })
|
||
.Select(r => new
|
||
{
|
||
Year = r.ReportTime.Year,
|
||
Month = r.ReportTime.Month,
|
||
ExtraLargeCount = SqlFunc.AggregateSum(SqlFunc.IIF(r.DegreeType == 1, 1, 0)),
|
||
LargeCount = SqlFunc.AggregateSum(SqlFunc.IIF(r.DegreeType == 2, 1, 0))
|
||
})
|
||
.ToListAsync();
|
||
|
||
// 使用LINQ左连接
|
||
var result = (from month in months
|
||
join d in data
|
||
on new { month.Year, month.Month } equals new { d.Year, d.Month } into gj
|
||
from subData in gj.DefaultIfEmpty()
|
||
orderby month.Year, month.Month
|
||
select new FireInfoDegreeForChart
|
||
{
|
||
DateTime = month.Display,
|
||
ExtraLargeCount = subData?.ExtraLargeCount ?? 0,
|
||
LargeCount = subData?.LargeCount ?? 0
|
||
}).ToList();
|
||
return new Response<List<FireInfoDegreeForChart>> { Result = result };
|
||
}
|
||
else
|
||
{
|
||
// 计算统计年份范围
|
||
int currentYear = DateTime.Now.Year;
|
||
int startYear = currentYear - 5 + 1;
|
||
|
||
// 生成年份范围
|
||
var years = Enumerable.Range(startYear, 5)
|
||
.Select(y => y)
|
||
.ToList();
|
||
|
||
// 查询数据
|
||
var queryData = await db.FmFireclueInfo.AsQueryable()
|
||
.Where(r => r.ReportTime.Year >= startYear && r.ReportTime.Year <= currentYear)
|
||
.GroupBy(r => r.ReportTime.Year)
|
||
.Select(r => new
|
||
{
|
||
Year = r.ReportTime.Year,
|
||
ExtraLargeCount = SqlFunc.AggregateSum(SqlFunc.IIF(r.DegreeType == 1, 1, 0)),
|
||
LargeCount = SqlFunc.AggregateSum(SqlFunc.IIF(r.DegreeType == 2, 1, 0))
|
||
})
|
||
.ToListAsync();
|
||
|
||
// 生成结果，确保所有年份都有数据
|
||
var result = new List<FireInfoDegreeForChart>();
|
||
foreach (var year in years)
|
||
{
|
||
var yearData = queryData.FirstOrDefault(d => d.Year == year);
|
||
|
||
result.Add(new FireInfoDegreeForChart
|
||
{
|
||
DateTime = year.ToString() + "年",
|
||
ExtraLargeCount = yearData?.ExtraLargeCount ?? 0,
|
||
LargeCount = yearData?.LargeCount ?? 0
|
||
});
|
||
}
|
||
return new Response<List<FireInfoDegreeForChart>> { Result = result };
|
||
}
|
||
}
|
||
}
|
||
|
||
// 格式化月份显示
|
||
private string FormatMonthDisplay(DateTime date)
|
||
{
|
||
var currentYear = DateTime.Now.Year;
|
||
|
||
//if (date.Year == currentYear)
|
||
//{
|
||
// return $"{date.Month}月";
|
||
//}
|
||
//else if (date.Year == currentYear - 1)
|
||
//{
|
||
// return $"去年{date.Month}月";
|
||
//}
|
||
//else
|
||
//{
|
||
// return $"{date.Year % 100}年{date.Month}月";
|
||
//}
|
||
|
||
return $"{date.Year % 100}.{date.Month}";
|
||
}
|
||
|
||
//查询火情和任务列表
|
||
public async Task<Response<List<FmFireclueinfoLog>>> GetFireClueLog(long id)
|
||
{
|
||
using (var db = base.UnitWork.CreateContext())
|
||
{
|
||
var list = await db.FmFireclueinfoLog.AsQueryable()
|
||
.Where(r => r.Fireclueid == id)
|
||
.OrderByDescending(r => r.CreateTime).ToListAsync();
|
||
return new Response<List<FmFireclueinfoLog>> { Result = list };
|
||
}
|
||
}
|
||
|
||
#endregion
|
||
|
||
/// <summary>
|
||
/// 在线情况
|
||
/// </summary>
|
||
/// <param name="pageReq"></param>
|
||
/// <returns></returns>
|
||
public async Task<Response<PageInfo<dynamic>>> GetPointUserOnLine(UserOnLineReq pageReq)
|
||
{
|
||
using (var db = base.UnitWork.CreateContext())
|
||
{
|
||
RefAsync<int> totalNumber = 0;
|
||
var user = _auth.GetCurrentUser().User;
|
||
int level = 0;
|
||
//该用户下包含所有部门
|
||
var orgid = _auth.GetCurrentUser().Orgs;
|
||
level = orgid.Min(r => r.Level);
|
||
var chileorglist = new List<long>();
|
||
if (level != 0 && user.Id != -1)
|
||
{
|
||
foreach (var item in orgid.Where(r => r.Level < 3))
|
||
{
|
||
var chileorg = (await db.SysOrg.AsQueryable().ToChildListAsync(it => it.ParentId, item))
|
||
.Select(it => it.Id).ToList();
|
||
chileorglist.AddRange(chileorg);
|
||
}
|
||
}
|
||
|
||
var userInfoQuery = db.User.AsQueryable()
|
||
.LeftJoin<FmUserPoint>((a, b) => a.Id == b.CreateId)
|
||
.LeftJoin<SysUserOrg>((a, b, c) => a.Id == c.UserId)
|
||
.Where((a, b, c) => a.Status == 0)
|
||
.WhereIF(level != 0, (a, b, c) => chileorglist.Contains(c.UserId));
|
||
var userinfo = await userInfoQuery
|
||
.Select((a, b, c) => new UserOnLineResp
|
||
{
|
||
CreateId = a.Id,
|
||
Name = a.Name,
|
||
Lat = b.Lat,
|
||
Lng = b.Lng,
|
||
CreateTime = b.CreateTime,
|
||
Phone = a.Account,
|
||
State = b.CreateTime.AddMinutes(2) > DateTime.Now ? "在线" : "离线",
|
||
IsIn = b.Intype,
|
||
OnLineTime = SqlFunc.DateDiff(DateType.Minute, b.CreateTime, DateTime.Now),
|
||
TownName = SqlFunc.Subqueryable<SysUserOrg>()
|
||
.Where(sf => sf.UserId == a.Id)
|
||
.LeftJoin<SysOrg>((sf, gs) => sf.OrgId == gs.Id)
|
||
.LeftJoin<SysOrg>((sf, gs, t) => gs.ParentId == t.Id)
|
||
.SelectStringJoin((sf, gs, t) => gs.Name, ",")
|
||
})
|
||
.MergeTable()
|
||
.Distinct()
|
||
.WhereIF(!string.IsNullOrEmpty(pageReq.townname), it => it.TownName.Contains(pageReq.townname))
|
||
.WhereIF(pageReq.isonline != "全部", it => it.State == pageReq.isonline)
|
||
.OrderByDescending(it => it.CreateTime)
|
||
.ToPageListAsync(pageReq.page, pageReq.limit, totalNumber);
|
||
|
||
var onlineCount = await userInfoQuery
|
||
.Where((a, b, c) => b.CreateTime.AddMinutes(2) > DateTime.Now)
|
||
.Select(a => a.Id)
|
||
.Distinct()
|
||
.CountAsync();
|
||
|
||
// 离线人数
|
||
var offlineCount = totalNumber - onlineCount;
|
||
|
||
var enddata = new
|
||
{
|
||
userinfo,
|
||
online = onlineCount,
|
||
offline = offlineCount,
|
||
};
|
||
|
||
|
||
return new Response<PageInfo<dynamic>>
|
||
{
|
||
Result = new PageInfo<dynamic> { Items = enddata, Total = totalNumber }
|
||
};
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 添加实时坐标
|
||
/// </summary>
|
||
/// <param name="userPoint"></param>
|
||
/// <returns></returns>
|
||
public async Task<Response<bool>> AddPointAsync(FmUserPoint userPoint)
|
||
{
|
||
var response = new Response<bool>();
|
||
using var db = Repository.AsSugarClient();
|
||
|
||
var currentUser = _auth.GetCurrentUser();
|
||
userPoint.CreateId = currentUser.User.Id;
|
||
userPoint.Id = YitIdHelper.NextId();
|
||
userPoint.CreateTime = DateTime.Now;
|
||
var userPointHistory = userPoint.MapTo<FmUserPointHistory>();
|
||
|
||
var oldInfo = await db.Queryable<FmUserPoint>()
|
||
.Where(r => r.CreateId == userPoint.CreateId)
|
||
.FirstAsync();
|
||
|
||
//上线弹窗 第一次上报或者上线时间不超过2分钟
|
||
if (oldInfo == null || (oldInfo != null && oldInfo.CreateTime.AddMinutes(2) < DateTime.Now))
|
||
{
|
||
var user = await db.Queryable<SysUser>().Where(r => r.Id == userPoint.CreateId)
|
||
.FirstAsync();
|
||
if (user != null)
|
||
{
|
||
await db.Insertable(new FmOnOffLine
|
||
{
|
||
Id = YitIdHelper.NextId(),
|
||
IdentifyId = user.Id,
|
||
OnOffTime = DateTime.Now,
|
||
Name = user.Name,
|
||
Type = true
|
||
}).ExecuteCommandAsync();
|
||
|
||
WebSocketModel wsModel1 = new WebSocketModel
|
||
{
|
||
Module = "上线",
|
||
Data = user.Name
|
||
};
|
||
sendsocket(wsModel1);
|
||
}
|
||
}
|
||
|
||
|
||
if (oldInfo != null)
|
||
{
|
||
oldInfo.Lat = userPoint.Lat;
|
||
oldInfo.Lng = userPoint.Lng;
|
||
oldInfo.CreateTime = userPoint.CreateTime;
|
||
oldInfo.Intype = userPoint.Intype;
|
||
await db.Updateable(oldInfo).ExecuteCommandAsync();
|
||
}
|
||
else
|
||
{
|
||
await db.Insertable(userPoint).ExecuteCommandAsync();
|
||
}
|
||
|
||
await db.Insertable(userPointHistory).SplitTable().ExecuteCommandAsync();
|
||
response.Code = 200;
|
||
response.Result = true;
|
||
response.Message = "添加成功";
|
||
|
||
return response;
|
||
}
|
||
|
||
public async Task sendsocket(WebSocketModel wsModel1)
|
||
{
|
||
try
|
||
{
|
||
if (_socket == null || _socket.State != WebSocketState.Open)
|
||
{
|
||
string ws = _configuration.GetSection("WebSocket").Value;
|
||
_socket = new ClientWebSocket();
|
||
await _socket.ConnectAsync(new Uri(ws), CancellationToken.None);
|
||
}
|
||
|
||
byte[] data = Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(wsModel1));
|
||
await _socket.SendAsync(new ArraySegment<byte>(data), WebSocketMessageType.Text,
|
||
true, CancellationToken.None);
|
||
await _socket.CloseAsync(WebSocketCloseStatus.NormalClosure, "Closing connection",
|
||
CancellationToken.None);
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 保存地图标绘
|
||
/// </summary>
|
||
/// <param name="req"></param>
|
||
/// <returns></returns>
|
||
public async Task<Response<bool>> SaveMapPlotting(MapPlottingReq req)
|
||
{
|
||
var record = req.MapTo<FmMapPlotting>();
|
||
record.Id = YitIdHelper.NextId();
|
||
using var db = Repository.AsSugarClient();
|
||
await db.Insertable(record).IgnoreColumnsNull().ExecuteCommandAsync();
|
||
return new Response<bool>()
|
||
{
|
||
Result = true,
|
||
Message = "保存成功",
|
||
Code = 200
|
||
};
|
||
}
|
||
|
||
public async Task<Response<PageInfo<dynamic>>> GetMapPlotting(PageReq req)
|
||
{
|
||
using var db = Repository.AsSugarClient();
|
||
RefAsync<int> total = 0;
|
||
var page = await db.Queryable<FmMapPlotting>()
|
||
.OrderByDescending(r => r.CreateTime)
|
||
.ToPageListAsync(req.page, req.limit, total);
|
||
return new Response<PageInfo<dynamic>>
|
||
{
|
||
Code = 200,
|
||
Message = "查询成功",
|
||
Result = new PageInfo<dynamic>
|
||
{
|
||
Items = page,
|
||
Total = total
|
||
}
|
||
};
|
||
}
|
||
|
||
/// <summary>
|
||
/// 查询人员上报的线索
|
||
/// </summary>
|
||
/// <param name="userid"></param>
|
||
/// <returns></returns>
|
||
public async Task<Response<PageInfo<List<FireClueInfoResp>>>> LoadFireClueInfoByUserId(int pageIndex, int state,
|
||
int pageSize, string userid)
|
||
{
|
||
using (var db = base.UnitWork.CreateContext())
|
||
{
|
||
RefAsync<int> total = 0;
|
||
var list = await db.FmFireclueInfo.AsQueryable().Where(a => a.CreateId.ToString() == userid).Select(a =>
|
||
new FireClueInfoResp
|
||
{
|
||
Id = a.Id,
|
||
CreateId = a.CreateId.ToString(),
|
||
ReportPerson = a.ReportPerson,
|
||
Lat = a.Lat,
|
||
Lng = a.Lng,
|
||
Address = a.Address,
|
||
ReportTime = a.ReportTime,
|
||
Describe = a.Describe,
|
||
SourceType = a.SourceType,
|
||
State = a.State,
|
||
AreaName = a.AreaName,
|
||
ClueNo = a.ClueNo,
|
||
}).Mapper(a => a.SourceTypeName = ((SourceType)a.SourceType).GetDescription())
|
||
.Mapper(a => a.StateName = ((State)a.State).GetDescription())
|
||
.OrderBy(a => a.ReportTime, SqlSugar.OrderByType.Desc).ToPageListAsync(pageIndex, pageSize, total);
|
||
return new Response<PageInfo<List<FireClueInfoResp>>>
|
||
{
|
||
Code = 200,
|
||
Message = "查询成功",
|
||
Result = new PageInfo<List<FireClueInfoResp>>
|
||
{
|
||
Items = list,
|
||
Total = total
|
||
}
|
||
};
|
||
}
|
||
}
|
||
|
||
private static readonly string baseUrl =
|
||
"http://10.176.126.121:8766/liveBroadCast/bd/api/v1/device/liveBroadCast";
|
||
|
||
private static readonly string sk = "ba98a152296f13c565d2a6dfd219994f"; // 用户的sk
|
||
private static readonly string account = "AK202006291525121"; // 用户的ak
|
||
|
||
public async Task<string> GetFlvUrlAsync(string deviceCode)
|
||
{
|
||
// 获取当前的时间戳
|
||
var requestTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds().ToString();
|
||
|
||
// 构建请求体
|
||
var requestBody = new
|
||
{
|
||
deviceCode = deviceCode
|
||
};
|
||
|
||
// 序列化请求体
|
||
var jsonBody = JsonConvert.SerializeObject(requestBody);
|
||
|
||
// 计算signature
|
||
var signature = CalculateSignature(requestTime, jsonBody);
|
||
|
||
// 创建 HttpClient 和 HttpRequestMessage
|
||
using (var client = new HttpClient())
|
||
{
|
||
// 创建 HttpRequestMessage 实例
|
||
var requestMessage = new HttpRequestMessage(HttpMethod.Post, baseUrl)
|
||
{
|
||
Content = new StringContent(jsonBody, Encoding.UTF8, "application/json")
|
||
};
|
||
|
||
// 设置请求头（其他类型的请求头设置在这里）
|
||
requestMessage.Headers.Add("account", account);
|
||
requestMessage.Headers.Add("requestTime", requestTime);
|
||
requestMessage.Headers.Add("signature", signature);
|
||
|
||
// 设置 Content-Type 和 Accept 请求头
|
||
requestMessage.Content.Headers.ContentType =
|
||
new System.Net.Http.Headers.MediaTypeHeaderValue("application/json");
|
||
requestMessage.Headers.Accept.Add(
|
||
new System.Net.Http.Headers.MediaTypeWithQualityHeaderValue("application/json"));
|
||
|
||
// 发送请求
|
||
var response = await client.SendAsync(requestMessage);
|
||
if (response.IsSuccessStatusCode)
|
||
{
|
||
// 解析响应
|
||
var responseContent = await response.Content.ReadAsStringAsync();
|
||
dynamic responseData = JsonConvert.DeserializeObject(responseContent);
|
||
|
||
// 检查返回的code是否为0
|
||
if (responseData.code == "0")
|
||
{
|
||
return responseData.data.flvUrl;
|
||
}
|
||
else
|
||
{
|
||
throw new Exception($"API error: {responseData.message}");
|
||
}
|
||
}
|
||
else
|
||
{
|
||
throw new Exception($"HTTP request failed with status code {response.StatusCode}");
|
||
}
|
||
}
|
||
}
|
||
|
||
private string CalculateSignature(string requestTime, string requestBody)
|
||
{
|
||
// 按照要求的计算规则计算signature
|
||
string dataToSign = account + sk + requestTime + requestBody;
|
||
|
||
// 使用SHA256算法计算签名
|
||
using (SHA256 sha256 = SHA256.Create())
|
||
{
|
||
byte[] hashBytes = sha256.ComputeHash(Encoding.UTF8.GetBytes(dataToSign));
|
||
return BitConverter.ToString(hashBytes).Replace("-", "").ToLower();
|
||
}
|
||
}
|
||
|
||
public async Task<string> GetLive(string deviceCode)
|
||
{
|
||
string flvUrl = await GetFlvUrlAsync(deviceCode);
|
||
return flvUrl;
|
||
}
|
||
|
||
#region socket
|
||
|
||
public async Task SendSocketMessage(WebSocketModel wsModel)
|
||
{
|
||
try
|
||
{
|
||
using (var webSocket = new System.Net.WebSockets.ClientWebSocket())
|
||
{
|
||
string ws = _configuration.GetSection("WebSocket").Value;
|
||
await webSocket.ConnectAsync(new Uri(ws), CancellationToken.None);
|
||
byte[] data = Encoding.UTF8.GetBytes(Newtonsoft.Json.JsonConvert.SerializeObject(wsModel));
|
||
await webSocket.SendAsync(new ArraySegment<byte>(data),
|
||
System.Net.WebSockets.WebSocketMessageType.Text, true, CancellationToken.None);
|
||
await webSocket.CloseAsync(System.Net.WebSockets.WebSocketCloseStatus.NormalClosure,
|
||
"Closing connection", CancellationToken.None);
|
||
//webSocket.Dispose();
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 极光推送
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
public string JPushInfo(string info, long infoid)
|
||
{
|
||
using (var db = base.UnitWork.CreateContext())
|
||
{
|
||
int type = info == "任务下发" ? 2 : 3;
|
||
info = info == "任务下发" ? "有新任务，请注意查收" : "有新火点";
|
||
Audience audience = new Audience();
|
||
if (infoid != 0)
|
||
{
|
||
var renwu = db.FmFireTaskUser.AsQueryable().Where(r => r.TaskId == infoid).Select(r => r.UserId)
|
||
.ToList();
|
||
var users = db.User.AsQueryable().Where(r => renwu.Contains(r.Id.ToString())).ToList();
|
||
if (users.Count > 0)
|
||
{
|
||
audience.Alias = users.Select(a => a.Account).ToList();
|
||
}
|
||
}
|
||
else
|
||
{
|
||
var users = db.User.AsQueryable().Where(r => r.UnitName != null).ToList();
|
||
if (users.Count > 0)
|
||
{
|
||
audience.Alias = users.Select(a => a.Account).ToList();
|
||
}
|
||
}
|
||
|
||
PushPayload pushPayload = new PushPayload()
|
||
{
|
||
Platform = new List<string> { "android", "ios" },
|
||
Audience = audience,
|
||
Notification = new Notification
|
||
{
|
||
Alert = info,
|
||
Android = new Android
|
||
{
|
||
Alert = info,
|
||
Title = info,
|
||
Priority = 2,
|
||
Extras = new Dictionary<string, object>
|
||
{
|
||
["infoId"] = type,
|
||
["type"] = type
|
||
}
|
||
}
|
||
},
|
||
};
|
||
JPushClient client = new JPushClient(_jpoptions.Value.AppKey, _jpoptions.Value.MasterSecret);
|
||
var response = client.SendPush(pushPayload);
|
||
return "success";
|
||
}
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 海康设备
|
||
|
||
/// <summary>
|
||
/// 获取单个设备的视频流
|
||
/// </summary>
|
||
/// <param name="cameraIndexCode">视频标识</param>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[AllowAnonymous]
|
||
public string GetPreviewURLs(string cameraIndexCode, string protocol)
|
||
{
|
||
HttpUtillib.SetPlatformInfo(_options.Value.AppKey, _options.Value.SecretKey, _options.Value.Url,
|
||
_options.Value.Port, true);
|
||
|
||
var obj = new
|
||
{
|
||
cameraIndexCode,
|
||
streamType = 0,
|
||
protocol = protocol,
|
||
transmode = 1,
|
||
expand = "transcode=0",
|
||
streamform = "ps"
|
||
};
|
||
string body = JsonConvert.SerializeObject(obj);
|
||
string uri = "/artemis/api/video/v2/cameras/previewURLs";
|
||
byte[] result = HttpUtillib.HttpPost(uri, body, 15, 1);
|
||
if (null != result)
|
||
{
|
||
return Encoding.UTF8.GetString(result);
|
||
}
|
||
|
||
return "fail";
|
||
}
|
||
|
||
/// <summary>
|
||
/// 获取单个设备的视频流---海康平台2
|
||
/// </summary>
|
||
/// <param name="cameraIndexCode">视频标识</param>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[AllowAnonymous]
|
||
public string GetPreviewURLs2(string cameraIndexCode, string protocol)
|
||
{
|
||
HttpUtillib.SetPlatformInfo(_options2.Value.AppKey, _options2.Value.SecretKey, _options2.Value.Url,
|
||
_options2.Value.Port, true);
|
||
|
||
var obj = new
|
||
{
|
||
cameraIndexCode,
|
||
streamType = 0,
|
||
protocol = protocol,
|
||
transmode = 1,
|
||
expand = "transcode=0",
|
||
streamform = "ps"
|
||
};
|
||
string body = JsonConvert.SerializeObject(obj);
|
||
string uri = "/artemis/api/video/v2/cameras/previewURLs";
|
||
byte[] result = HttpUtillib.HttpPost(uri, body, 15, 1);
|
||
if (null != result)
|
||
{
|
||
return Encoding.UTF8.GetString(result);
|
||
}
|
||
|
||
return "fail";
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 人员类型统计
|
||
|
||
/// <summary>
|
||
/// 人员类型统计
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
public async Task<Response<UserTypeStatisticsRes>> GetUserTypeStatistics()
|
||
{
|
||
using var db = Repository.AsSugarClient();
|
||
//护林员
|
||
var hulin = await db.Queryable<SysUserRole>().LeftJoin<SysRole>((s, r) => s.RoleId == r.Id)
|
||
.LeftJoin<SysUser>((s, r, u) => s.UserId == u.Id)
|
||
.Where((s, r, u) => r.Name == "护林员" && u.Id > 0)
|
||
.CountAsync();
|
||
//消防员
|
||
var xiaofang = await db.Queryable<FmFirefighterinfo>().CountAsync();
|
||
//驻防部队
|
||
var zhufang = await db.Queryable<FmZhufangbudui>().CountAsync();
|
||
//林区住户
|
||
var linqu = await db.Queryable<FmLinquzhuhu>().CountAsync();
|
||
//向导
|
||
var xiangdao = await db.Queryable<FmXiangdaouser>().CountAsync();
|
||
//防火驿站
|
||
var yizhan = await db.Queryable<FmFanghuoyizhan>().CountAsync();
|
||
|
||
UserTypeStatisticsRes res = new UserTypeStatisticsRes();
|
||
res.hulinyuan = hulin;
|
||
res.xiaofangyuan = xiaofang;
|
||
res.zhufangduiwu = zhufang;
|
||
res.linquzhuhu = linqu;
|
||
res.xiangdao = xiangdao;
|
||
res.fanghuoyizhan = yizhan;
|
||
|
||
return new Response<UserTypeStatisticsRes>
|
||
{
|
||
Code = 200,
|
||
Message = "查询成功",
|
||
Result = res
|
||
};
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 获取物资相关接口
|
||
|
||
/// <summary>
|
||
/// 获取全部营房信息
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
public dynamic GetAllYingFang()
|
||
{
|
||
string sql =
|
||
@"SELECT ""id"",""dwmc"",""dwzd"",""lsdw"",""dwzdjd"",""dwzdwd"",""dzxm"",""lxfs"",""syrs"",""zbqk"",""tbr"", st_astext(""geom"") as geom FROM ""fm_shp_1692148217"" ";
|
||
|
||
using (var db = Repository.AsSugarClient())
|
||
{
|
||
var list = db.SqlQueryable<dynamic>(sql).ToList();
|
||
return list;
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 获取物资储备信息
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
public TableData Loadwuzichubei(string wuzi, string areaname)
|
||
{
|
||
TableData data = new TableData();
|
||
using (var db = Repository.AsSugarClient())
|
||
{
|
||
string sql = string.Empty;
|
||
if (!string.IsNullOrEmpty(wuzi))
|
||
sql =
|
||
"SELECT \"id\", \"type\",\"name\",info,st_astext(geom) as geom FROM \"fm_shp_1686205187\" WHERE info like '%" +
|
||
wuzi + "%'";
|
||
else
|
||
sql = "SELECT \"id\", \"type\",\"name\",info,st_astext(geom) as geom FROM \"fm_shp_1686205187\" ";
|
||
|
||
var dt = db.Ado.GetDataTable(sql.ToString());
|
||
data.count = dt.Rows.Count;
|
||
data.data = dt;
|
||
}
|
||
|
||
return data;
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 任务相关
|
||
|
||
/// <summary>
|
||
/// 查询我的任务
|
||
/// </summary>
|
||
/// <param name="userid"></param>
|
||
/// <returns></returns>
|
||
public async Task<Response<PageInfo<List<FireClueTaskResp>>>> LoadFireClueTaskByUserId(string userid,
|
||
int pageIndex, int pageSize)
|
||
{
|
||
using (SugarDbContext db = base.UnitWork.CreateContext())
|
||
{
|
||
RefAsync<int> totalNumber = 0;
|
||
var query = await db.FmFireclueTask.AsQueryable()
|
||
.LeftJoin<SysUser>((a, b) => a.TaskUser == b.Id.ToString())
|
||
.LeftJoin<FmFireTaskUser>((a, b, c) => a.Id == c.TaskId)
|
||
.Where((a, b, c) => a.IsDelete == false)
|
||
.Where((a, b, c) => c.UserId == userid)
|
||
.Select((a, b, c) => new FireClueTaskResp()
|
||
{
|
||
Id = a.Id,
|
||
Content = a.Content,
|
||
Lat = a.Lat,
|
||
Lng = a.Lng,
|
||
Address = a.Address,
|
||
State = c.State,
|
||
TaskUserName = b.Name,
|
||
TaskTime = a.TaskTime,
|
||
CompleteTime = a.CompleteTime,
|
||
Audio = a.Audio,
|
||
Image = a.Image,
|
||
}).Mapper(c => c.StateName = ((TaskState)c.State).GetDescription())
|
||
.OrderBy(a => a.TaskTime, OrderByType.Desc)
|
||
.ToPageListAsync(pageIndex, pageSize, totalNumber);
|
||
return new Response<PageInfo<List<FireClueTaskResp>>>
|
||
{
|
||
Result = new PageInfo<List<FireClueTaskResp>> { Items = query, Total = totalNumber }
|
||
};
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 查询所有任务
|
||
/// </summary>
|
||
/// <param name="pageIndex"></param>
|
||
/// <param name="pageSize"></param>
|
||
/// <returns></returns>
|
||
public async Task<Response<PageInfo<List<FireClueTaskResp>>>> LoadAllTask(int pageIndex, int pageSize)
|
||
{
|
||
using (SugarDbContext db = base.UnitWork.CreateContext())
|
||
{
|
||
RefAsync<int> totalNumber = 0;
|
||
var query = await db.FmFireclueTask.AsQueryable()
|
||
.LeftJoin<SysUser>((a, b) => a.TaskUser == b.Id.ToString())
|
||
.Where((a, b) => a.IsDelete == false)
|
||
.Select((a, b) => new FireClueTaskResp()
|
||
{
|
||
Id = a.Id,
|
||
Lat = a.Lat,
|
||
Lng = a.Lng,
|
||
Address = a.Address,
|
||
State = a.State,
|
||
TaskUserName = b.Name,
|
||
Content = a.Content,
|
||
Image = a.Image,
|
||
Audio = a.Audio,
|
||
TaskTime = a.TaskTime,
|
||
RecipientUsers = SqlFunc.Subqueryable<FmFireTaskUser>().Where(r => r.TaskId == a.Id)
|
||
.LeftJoin<SysUser>((r, s) => r.UserId == s.Id.ToString())
|
||
.SelectStringJoin((a, s) => s.Name, ","),
|
||
}).Mapper(c => c.StateName = ((TaskState)c.State).GetDescription())
|
||
.OrderBy(a => a.TaskTime, OrderByType.Desc)
|
||
.ToPageListAsync(pageIndex, pageSize, totalNumber);
|
||
return new Response<PageInfo<List<FireClueTaskResp>>>
|
||
{
|
||
Result = new PageInfo<List<FireClueTaskResp>> { Items = query, Total = totalNumber }
|
||
};
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 查询火情线索
|
||
/// </summary>
|
||
/// <param name="areaname"></param>
|
||
/// <param name="pageIndex"></param>
|
||
/// <param name="pageSize"></param>
|
||
/// <returns></returns>
|
||
public async Task<Response<PageInfo<List<FireClueInfoResp>>>> LoadFireClueInfoByAreaName(string areaname,
|
||
int pageIndex = 1, int pageSize = 10)
|
||
{
|
||
using (SugarDbContext db = base.UnitWork.CreateContext())
|
||
{
|
||
RefAsync<int> totalNumber = 0;
|
||
var query = await db.FmFireclueInfo.AsQueryable()
|
||
.WhereIF(!string.IsNullOrEmpty(areaname), (a) => a.AreaName == areaname)
|
||
.Where(a => a.State == (int)State.上报)
|
||
.Select((a) => new FireClueInfoResp()
|
||
{
|
||
Id = a.Id,
|
||
CreateId = a.CreateId.ToString(),
|
||
ReportPerson = a.ReportPerson,
|
||
Lat = a.Lat,
|
||
Lng = a.Lng,
|
||
Address = a.Address,
|
||
ReportTime = a.ReportTime,
|
||
Describe = a.Describe,
|
||
SourceType = a.SourceType,
|
||
State = a.State,
|
||
AreaName = a.AreaName,
|
||
ClueNo = a.ClueNo,
|
||
Image = a.Image,
|
||
EventId = a.EventId,
|
||
Audio = a.Audio,
|
||
FireType = 1
|
||
})
|
||
.Mapper(a => a.SourceTypeName = ((SourceType)a.SourceType).GetDescription())
|
||
.Mapper(a => a.StateName = ((State)a.State).GetDescription())
|
||
.OrderBy(a => a.ReportTime, SqlSugar.OrderByType.Desc)
|
||
.ToPageListAsync(pageIndex, pageSize, totalNumber);
|
||
return new Response<PageInfo<List<FireClueInfoResp>>>
|
||
{
|
||
Result = new PageInfo<List<FireClueInfoResp>> { Items = query, Total = totalNumber }
|
||
};
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// App获取在线人员实时位置信息
|
||
/// </summary>
|
||
/// <param name="areaname"></param>
|
||
/// <param name="pageIndex"></param>
|
||
/// <param name="pageSize"></param>
|
||
/// <returns></returns>
|
||
public async Task<Response<List<RYResApp>>> GetPointByAPPAsync()
|
||
{
|
||
using (SugarDbContext db = base.UnitWork.CreateContext())
|
||
{
|
||
RefAsync<int> totalNumber = 0;
|
||
var query = await db.FmUserPoint.AsQueryable()
|
||
.LeftJoin<SysUser>((a, b) => a.CreateId == b.Id)
|
||
.Where((a, b) => a.CreateTime.AddMinutes(2) > DateTime.Now)
|
||
.Select((a, b) => new RYResApp
|
||
{
|
||
CreateId = a.CreateId.ToString(),
|
||
Name = b.Name,
|
||
Lat = a.Lat,
|
||
Lng = a.Lng,
|
||
CreateTime = a.CreateTime,
|
||
Type = "人员",
|
||
Phone = b.Account,
|
||
top = a.Top,
|
||
iscontacts = a.IsContacts
|
||
}).ToListAsync();
|
||
return new Response<List<RYResApp>>
|
||
{
|
||
Result = query
|
||
};
|
||
}
|
||
}
|
||
|
||
#endregion
|
||
|
||
public async Task<Response<dynamic>> ListCameraWithInRange(string lng, string lat, int radius)
|
||
{
|
||
// '{lng}', '{lat}'
|
||
var sql =
|
||
@$"WITH reference_point AS ( SELECT ST_SetSRID ( ST_MakePoint ( '{lng}', '{lat}' )::geography, 4326 ) AS geom ) SELECT
|
||
l.*
|
||
FROM
|
||
fm_camera l,
|
||
reference_point r
|
||
WHERE
|
||
ST_DWithin ( ST_SetSRID ( ST_MakePoint ( l.""Lng"" :: FLOAT, l.""Lat"" :: FLOAT )::geography, 4326 ), r.geom, {radius}
|
||
)
|
||
ORDER BY
|
||
ST_Distance ( ST_SetSRID ( ST_MakePoint ( l.""Lng"" :: FLOAT, l.""Lat"" :: FLOAT )::geography, 4326 ), r.geom ) ";
|
||
var x = await Repository.AsSugarClient().SqlQueryable<dynamic>(sql).ToListAsync();
|
||
return new Response<dynamic>
|
||
{
|
||
Result = x
|
||
};
|
||
}
|
||
|
||
public async Task<Response<dynamic>> ListDaHuaCameraInfo(int pageNum, int pageSize, int isOnline)
|
||
{
|
||
var daHuaApi = new DaHuaApi("https://icc-dev.hibetatest.com:4077");
|
||
var channelCategoryRequest = new ChannelCategoryRequest
|
||
{
|
||
pageNum = pageNum,
|
||
pageSize = pageSize,
|
||
isOnline = 1,
|
||
unitTypeList = new List<int> { 1 },
|
||
};
|
||
Console.WriteLine(JsonConvert.SerializeObject(channelCategoryRequest));
|
||
var channelCategoryResponse = await daHuaApi.GetChannelCategoriesAsync(channelCategoryRequest);
|
||
if (channelCategoryResponse.success)
|
||
{
|
||
return new Response<dynamic>
|
||
{
|
||
Result = channelCategoryResponse.data.pageData
|
||
};
|
||
}
|
||
|
||
return new Response<dynamic>
|
||
{
|
||
Code = channelCategoryResponse.code,
|
||
Message = channelCategoryResponse.errMsg
|
||
};
|
||
}
|
||
|
||
public async Task<Response<dynamic>> GetDaHuaRtsp(string channelCode,string streamType)
|
||
{
|
||
var daHuaApi = new DaHuaApi("https://icc-dev.hibetatest.com:4077");
|
||
|
||
var request = new RtspPreviewRequest
|
||
{
|
||
data = new RtspPreviewData
|
||
{
|
||
channelId = channelCode,
|
||
dataType = "1",
|
||
streamType = streamType //主码流
|
||
}
|
||
};
|
||
var y = await daHuaApi.StartRtspPreviewAsync(request);
|
||
if (y.success)
|
||
{
|
||
return new Response<dynamic>
|
||
{
|
||
Result = y.data
|
||
};
|
||
}
|
||
|
||
return new Response<dynamic>
|
||
{
|
||
Code = y.code,
|
||
Message = y.errMsg
|
||
};
|
||
}
|
||
/// <summary>
|
||
/// 获取设备信息
|
||
/// </summary>
|
||
/// <param name="county"></param>
|
||
/// <param name="pageIndex"></param>
|
||
/// <param name="pageSize"></param>
|
||
/// <returns></returns>
|
||
public TableData LoadCameraInfo(string county, int pageIndex, int pageSize)
|
||
{
|
||
TableData data = new TableData();
|
||
ConnectionConfig connectionConfig = new ConnectionConfig
|
||
{
|
||
ConnectionString = "server=10.176.126.121;Port=33066;Database=inspur_ztk;Uid=lyyj;Pwd=Lyyj1024",
|
||
DbType = DbType.MySql,
|
||
IsAutoCloseConnection = true,
|
||
MoreSettings = new ConnMoreSettings()
|
||
{
|
||
PgSqlIsAutoToLower = false,//增删查改支持驼峰表
|
||
}
|
||
};
|
||
using (SqlSugarClient db = new SqlSugarClient(connectionConfig))
|
||
{
|
||
int totalCount = 0;
|
||
var list = db.Queryable<ztk_jcjk_jkdw>()
|
||
.WhereIF(!string.IsNullOrEmpty(county), r => r.qx.Contains(county))
|
||
.Select(r => new ztk_jcjk_jkdw()
|
||
{
|
||
id = r.id.SelectAll(),
|
||
})
|
||
.ToPageList(pageIndex, pageSize, ref totalCount);
|
||
data.data = list;
|
||
data.count = totalCount;
|
||
data.code = 200;
|
||
data.msg = "请求成功";
|
||
}
|
||
return data;
|
||
}
|
||
|
||
|
||
#region 感知中心--摄像头类型
|
||
/// <summary>
|
||
/// 感知中心--摄像头类型数量统计
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
public async Task<Response<List<CameraCountRes>>> GetCameraCountByType()
|
||
{
|
||
using (var db = base.UnitWork.CreateContext())
|
||
{
|
||
var typelist = await db.SysDataItemDetail.AsQueryable()
|
||
.Where(r => r.ItemCode == "FMCamera").ToListAsync();
|
||
|
||
var cameralist = await db.FmCamera.AsQueryable().Select(r => new
|
||
{
|
||
r.Id,
|
||
r.Name,
|
||
r.Manufacturer
|
||
}).ToListAsync();
|
||
|
||
var camerajj = await db.FmCamera_yjj.AsQueryable().Select<dynamic>(r => new
|
||
{
|
||
r.id,
|
||
r.jkdmckjg,
|
||
r.jklx
|
||
}).ToListAsync();
|
||
|
||
List<CameraCountRes> clist = new List<CameraCountRes>();
|
||
foreach (var item in typelist)
|
||
{
|
||
CameraCountRes cs = new CameraCountRes();
|
||
cs.title = item.ItemName;
|
||
if (item.ItemValue == "ShiYingJiReChengXiang")
|
||
{
|
||
cs.num = camerajj.Where(r => r.jklx == "森火-市局").Count().ToString();
|
||
}
|
||
if (item.ItemValue == "ZhiNengYuYinQiaKou")
|
||
{
|
||
cs.num = camerajj.Where(r => r.jklx == "防火卡口").Count().ToString();
|
||
}
|
||
if (item.ItemValue == "ShengTaiLinShiPinJianKong")
|
||
{
|
||
cs.num = camerajj.Where(r => r.jklx == "森火").Count().ToString();
|
||
}
|
||
if (item.ItemValue == "GaoKongLiaoWang")
|
||
{
|
||
cs.num = (camerajj.Where(r => r.jklx == "森火").Count() + 2).ToString();
|
||
}
|
||
if (item.ItemValue == "ShiPinJianKong")
|
||
{
|
||
cs.num = cameralist.Where(r => r.Manufacturer == "海康").Take(458).Count().ToString();
|
||
}
|
||
if (item.ItemValue == "LinQuSheXiangTou")
|
||
{
|
||
cs.num = cameralist.Where(r => r.Manufacturer == "海康").Take(325).Count().ToString();
|
||
}
|
||
if (item.ItemValue == "TieTaJianKong")
|
||
{
|
||
cs.num = cameralist.Where(r => r.Manufacturer == "海康").Take(63).Count().ToString();
|
||
}
|
||
if (item.ItemValue == "WuRenJiJiChang")
|
||
{
|
||
cs.num = "2";
|
||
}
|
||
if (item.ItemValue == "FeiXianXianYouJiZhan")
|
||
{
|
||
cs.num = cameralist.Where(r => r.Manufacturer == "海康2").Count().ToString();
|
||
}
|
||
clist.Add(cs);
|
||
}
|
||
return new Response<List<CameraCountRes>>
|
||
{
|
||
Result = clist
|
||
};
|
||
}
|
||
}
|
||
#endregion
|
||
}
|
||
} |