545 lines
22 KiB
C#
545 lines
22 KiB
C#
using Infrastructure;
|
|
using NPOI.HSSF.UserModel;
|
|
using NPOI.SS.UserModel;
|
|
using OpenAuth.App.BaseApp.Base;
|
|
using OpenAuth.App.Interface;
|
|
using OpenAuth.App.ServiceApp.DroneSsnydManage.Export;
|
|
using OpenAuth.App.ServiceApp.DroneSsnydManage.Request;
|
|
using OpenAuth.Repository;
|
|
using OpenAuth.Repository.Domain;
|
|
using SqlSugar;
|
|
|
|
namespace OpenAuth.App.ServiceApp.DroneSsnydManage
|
|
{
|
|
public class DroneSsnyApp : SqlSugarBaseApp<DroneSsnyd, SugarDbContext>
|
|
{
|
|
public DroneSsnyApp(ISugarUnitOfWork<SugarDbContext> unitWork, ISimpleClient<DroneSsnyd> repository, IAuth auth)
|
|
: base(unitWork, repository, auth)
|
|
{
|
|
}
|
|
|
|
/// <summary>
|
|
/// 到期预警
|
|
/// </summary>
|
|
/// <param name="pageIndex"></param>
|
|
/// <param name="pageSize"></param>
|
|
/// <returns></returns>
|
|
public PageInfo<List<DroneSsnyd>> TimeoutWarning(string xiangmumc, string countyid, string streetid, string xiangmuno, string xiangmuyt,
|
|
int pageIndex, int pageSize)
|
|
{
|
|
int totalCount = 0;
|
|
var endTime = DateTime.Now.AddMonths(2);
|
|
|
|
var list = base.Repository.AsQueryable()
|
|
.WhereIF(!string.IsNullOrEmpty(xiangmumc), a => a.xiangmu_name.Contains(xiangmumc))
|
|
.WhereIF(!string.IsNullOrEmpty(countyid), a => a.countyid == countyid)
|
|
.WhereIF(!string.IsNullOrEmpty(streetid), a => a.streetid == streetid)
|
|
.WhereIF(!string.IsNullOrEmpty(xiangmuyt),a=>a.xiangmu_yt== xiangmuyt)
|
|
.WhereIF(!string.IsNullOrEmpty(xiangmuno),a=>a.xiangmu_no==xiangmuno)
|
|
.Where(a => a.end_time <= endTime && a.end_time > DateTime.Now)
|
|
.OrderBy(a => a.end_time, OrderByType.Desc)
|
|
.ToPageList(pageIndex, pageSize, ref totalCount);
|
|
|
|
return new PageInfo<List<DroneSsnyd>>
|
|
{
|
|
Items = list,
|
|
Total = totalCount
|
|
};
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
/// 超期报警
|
|
/// </summary>
|
|
/// <param name="pageIndex"></param>
|
|
/// <param name="pageSize"></param>
|
|
/// <returns></returns>
|
|
public PageInfo<List<DroneSsnyd>> TimeOutAlarmList(string xiangmumc, string countyid, string streetid, string xiangmuno, string xiangmuyt,
|
|
int pageIndex, int pageSize)
|
|
{
|
|
int totalCount = 0;
|
|
var endTime = DateTime.Now;
|
|
|
|
var list = base.Repository.AsQueryable()
|
|
.WhereIF(!string.IsNullOrEmpty(xiangmumc), a => a.xiangmu_name.Contains(xiangmumc))
|
|
.WhereIF(!string.IsNullOrEmpty(countyid), a => a.countyid == countyid)
|
|
.WhereIF(!string.IsNullOrEmpty(streetid), a => a.streetid == streetid)
|
|
.WhereIF(!string.IsNullOrEmpty(xiangmuyt), a => a.xiangmu_yt == xiangmuyt)
|
|
.WhereIF(!string.IsNullOrEmpty(xiangmuno), a => a.xiangmu_no == xiangmuno)
|
|
.Where(a => a.end_time < endTime)
|
|
.OrderBy(a => a.end_time, OrderByType.Desc)
|
|
.ToPageList(pageIndex, pageSize, ref totalCount);
|
|
|
|
return new PageInfo<List<DroneSsnyd>>
|
|
{
|
|
Items = list,
|
|
Total = totalCount
|
|
};
|
|
}
|
|
|
|
/// <summary>
|
|
/// 历史项目
|
|
/// </summary>
|
|
/// <param name="req"></param>
|
|
/// <returns></returns>
|
|
/// <exception cref="NotImplementedException"></exception>
|
|
public PageInfo<List<DroneSsnyd>> HistoryProject(DroneSsnyAppPageReq req)
|
|
{
|
|
var totalCount = 0;
|
|
var list = Repository.AsQueryable()
|
|
.Where(a => a.handle_status_id == 99)
|
|
.WhereIF(!string.IsNullOrEmpty(req.streetid), a => a.streetid == req.streetid)
|
|
.WhereIF(!string.IsNullOrEmpty(req.xiangmu_yt), a => a.xiangmu_yt == req.xiangmu_yt)
|
|
.WhereIF(!string.IsNullOrEmpty(req.xiangmu_no), a => a.xiangmu_no.Contains(req.xiangmu_no))
|
|
.WhereIF(!string.IsNullOrEmpty(req.xiangmu_name), a => a.xiangmu_name.Contains(req.xiangmu_name))
|
|
.OrderBy(a => a.end_time, OrderByType.Desc)
|
|
.ToPageList(req.page, req.limit, ref totalCount);
|
|
return new PageInfo<List<DroneSsnyd>>
|
|
{
|
|
Items = list,
|
|
Total = totalCount
|
|
};
|
|
}
|
|
|
|
/// <summary>
|
|
/// 项目变更
|
|
/// </summary>
|
|
/// <param name="req"></param>
|
|
/// <returns></returns>
|
|
public PageInfo<List<DroneSsnyd>> ProjectChange(DroneSsnyAppPageReq req)
|
|
{
|
|
var totalCount = 0;
|
|
var list = Repository.AsQueryable()
|
|
.Where(a => a.handle_status_id != 99)
|
|
.WhereIF(!string.IsNullOrEmpty(req.streetid), a => a.streetid == req.streetid)
|
|
.WhereIF(!string.IsNullOrEmpty(req.xiangmu_yt), a => a.xiangmu_yt == req.xiangmu_yt)
|
|
.WhereIF(!string.IsNullOrEmpty(req.xiangmu_no), a => a.xiangmu_no.Contains(req.xiangmu_no))
|
|
.WhereIF(!string.IsNullOrEmpty(req.xiangmu_name), a => a.xiangmu_name.Contains(req.xiangmu_name))
|
|
.OrderBy(a => a.end_time, OrderByType.Desc)
|
|
.ToPageList(req.page, req.limit, ref totalCount);
|
|
return new PageInfo<List<DroneSsnyd>>
|
|
{
|
|
Items = list,
|
|
Total = totalCount
|
|
};
|
|
}
|
|
|
|
public List<DroneSsnydExport> HistoryProjectList(DroneSnnyAppReq req)
|
|
{
|
|
var list = Repository.AsQueryable()
|
|
.Where(a => a.handle_status_id == 99)
|
|
.WhereIF(!string.IsNullOrEmpty(req.streetid), a => a.streetid == req.streetid)
|
|
.WhereIF(!string.IsNullOrEmpty(req.xiangmu_yt), a => a.xiangmu_yt == req.xiangmu_yt)
|
|
.WhereIF(!string.IsNullOrEmpty(req.xiangmu_no), a => a.xiangmu_no.Contains(req.xiangmu_no))
|
|
.WhereIF(!string.IsNullOrEmpty(req.xiangmu_name), a => a.xiangmu_name.Contains(req.xiangmu_name))
|
|
.Select(
|
|
a => new DroneSsnydExport()
|
|
{
|
|
xiangmu_no = a.xiangmu_no,
|
|
xiangmu_name = a.xiangmu_name,
|
|
streetname = a.streetname,
|
|
communityname = a.communityname,
|
|
quanliren = a.quanliren,
|
|
xingzhengquhua = a.xingzhengquhua,
|
|
beian_no = a.beian_no,
|
|
start_time = a.start_time,
|
|
end_time = a.end_time,
|
|
xiangmu_yt = a.xiangmu_yt,
|
|
shengchan_area = a.shengchan_area,
|
|
fuzhu_area = a.fuzhu_area,
|
|
shenqing_area = a.shenqing_area,
|
|
handle_status_name = a.handle_status_name,
|
|
xiafatime = a.xiafatime
|
|
})
|
|
.ToList();
|
|
return list;
|
|
}
|
|
|
|
public List<DroneSsnydExport> ProjectChangeExport(DroneSnnyAppReq req)
|
|
{
|
|
var list = Repository.AsQueryable()
|
|
.Where(a => a.handle_status_id != 99)
|
|
.WhereIF(!string.IsNullOrEmpty(req.streetid), a => a.streetid == req.streetid)
|
|
.WhereIF(!string.IsNullOrEmpty(req.xiangmu_yt), a => a.xiangmu_yt == req.xiangmu_yt)
|
|
.WhereIF(!string.IsNullOrEmpty(req.xiangmu_no), a => a.xiangmu_no.Contains(req.xiangmu_no))
|
|
.WhereIF(!string.IsNullOrEmpty(req.xiangmu_name), a => a.xiangmu_name.Contains(req.xiangmu_name))
|
|
.Select(
|
|
a => new DroneSsnydExport()
|
|
{
|
|
xiangmu_no = a.xiangmu_no,
|
|
xiangmu_name = a.xiangmu_name,
|
|
streetname = a.streetname,
|
|
communityname = a.communityname,
|
|
quanliren = a.quanliren,
|
|
xingzhengquhua = a.xingzhengquhua,
|
|
beian_no = a.beian_no,
|
|
start_time = a.start_time,
|
|
end_time = a.end_time,
|
|
xiangmu_yt = a.xiangmu_yt,
|
|
shengchan_area = a.shengchan_area,
|
|
fuzhu_area = a.fuzhu_area,
|
|
shenqing_area = a.shenqing_area,
|
|
handle_status_name = a.handle_status_name,
|
|
xiafatime = a.xiafatime
|
|
})
|
|
.ToList();
|
|
return list;
|
|
}
|
|
|
|
|
|
#region 导出
|
|
|
|
//超期预警
|
|
public List<DroneSsnyd> TimeoutWarningExport(string xiangmumc, string countyid, string streetid,string xiangmuno, string xiangmuyt)
|
|
{
|
|
var endTime = DateTime.Now.AddMonths(2);
|
|
|
|
var list = base.Repository.AsQueryable()
|
|
.WhereIF(!string.IsNullOrEmpty(xiangmumc), a => a.xiangmu_name.Contains(xiangmumc))
|
|
.WhereIF(!string.IsNullOrEmpty(countyid), a => a.countyid == countyid)
|
|
.WhereIF(!string.IsNullOrEmpty(streetid), a => a.streetid == streetid)
|
|
.WhereIF(!string.IsNullOrEmpty(xiangmuyt), a => a.xiangmu_yt == xiangmuyt)
|
|
.WhereIF(!string.IsNullOrEmpty(xiangmuno), a => a.xiangmu_no == xiangmuno)
|
|
.Where(a => a.end_time <= endTime && a.end_time > DateTime.Now)
|
|
.OrderBy(a => a.end_time, OrderByType.Desc)
|
|
.ToList();
|
|
|
|
return list;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 超期报警
|
|
/// </summary>
|
|
/// <param name="pageIndex"></param>
|
|
/// <param name="pageSize"></param>
|
|
/// <returns></returns>
|
|
public List<DroneSsnyd> TimeOutAlarmExport(string xiangmumc, string countyid, string streetid, string xiangmuno, string xiangmuyt)
|
|
{
|
|
var endTime = DateTime.Now;
|
|
|
|
var list = base.Repository.AsQueryable()
|
|
.WhereIF(!string.IsNullOrEmpty(xiangmumc), a => a.xiangmu_name.Contains(xiangmumc))
|
|
.WhereIF(!string.IsNullOrEmpty(countyid), a => a.countyid == countyid)
|
|
.WhereIF(!string.IsNullOrEmpty(streetid), a => a.streetid == streetid)
|
|
.WhereIF(!string.IsNullOrEmpty(xiangmuyt), a => a.xiangmu_yt == xiangmuyt)
|
|
.WhereIF(!string.IsNullOrEmpty(xiangmuno), a => a.xiangmu_no == xiangmuno)
|
|
.Where(a => a.end_time < endTime)
|
|
.OrderBy(a => a.end_time, OrderByType.Desc)
|
|
.ToList();
|
|
|
|
return list;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 导出
|
|
/// </summary>
|
|
/// <param name="list"></param>
|
|
/// <param name="headers"></param>
|
|
/// <returns></returns>
|
|
public Response<MemoryStream> ListToExcel(List<DroneSsnyd> list, List<string> headers)
|
|
{
|
|
Response<MemoryStream> response = new Response<MemoryStream>();
|
|
try
|
|
{
|
|
HSSFWorkbook workbook = new HSSFWorkbook();
|
|
ISheet sheet = workbook.CreateSheet();
|
|
|
|
#region 内容样式
|
|
|
|
IFont font1 = workbook.CreateFont(); //创建一个字体样式对象
|
|
font1.FontName = "Microsoft YaHei"; //和excel里面的字体对应
|
|
//font1.Boldweight = short.MaxValue;//字体加粗
|
|
font1.FontHeightInPoints = 12; //字体大小
|
|
ICellStyle style = workbook.CreateCellStyle(); //创建样式对象
|
|
style.BorderBottom = BorderStyle.Thin;
|
|
style.BorderLeft = BorderStyle.Thin;
|
|
style.BorderRight = BorderStyle.Thin;
|
|
style.BorderTop = BorderStyle.Thin;
|
|
style.Alignment = HorizontalAlignment.Center;
|
|
style.VerticalAlignment = VerticalAlignment.Center;
|
|
style.SetFont(font1); //将字体样式赋给样式对象
|
|
style.WrapText = true;
|
|
|
|
#endregion
|
|
|
|
#region 标题样式
|
|
|
|
IFont font = workbook.CreateFont(); //创建一个字体样式对象
|
|
font.FontName = "Microsoft YaHei"; //和excel里面的字体对应
|
|
font.Boldweight = (short)FontBoldWeight.Bold; //字体加粗
|
|
font.FontHeightInPoints = 12; //字体大小
|
|
ICellStyle style1 = workbook.CreateCellStyle(); //创建样式对象
|
|
style1.BorderBottom = BorderStyle.Thin;
|
|
style1.BorderLeft = BorderStyle.Thin;
|
|
style1.BorderRight = BorderStyle.Thin;
|
|
style1.BorderTop = BorderStyle.Thin;
|
|
style1.Alignment = HorizontalAlignment.Center;
|
|
style1.VerticalAlignment = VerticalAlignment.Center;
|
|
style1.SetFont(font); //将字体样式赋给样式对象
|
|
|
|
#endregion
|
|
|
|
#region 创建表头
|
|
|
|
IRow rowHeader = sheet.CreateRow(0);
|
|
rowHeader.Height = 20 * 30;
|
|
for (int i = 0; i < headers.Count; i++)
|
|
{
|
|
var header = headers[i];
|
|
rowHeader.CreateCell(i);
|
|
rowHeader.Cells[i].CellStyle = style1;
|
|
rowHeader.Cells[i].SetCellValue(header);
|
|
if (i == 0)
|
|
{
|
|
sheet.SetColumnWidth(0, 20 * 200);
|
|
}
|
|
else
|
|
{
|
|
sheet.SetColumnWidth(i, 20 * 350);
|
|
}
|
|
}
|
|
|
|
#endregion
|
|
|
|
#region 填充数据
|
|
|
|
for (int i = 0; i < list.Count; i++) //循环数据
|
|
{
|
|
var item = list[i];
|
|
IRow dataRow = sheet.CreateRow(i + 1);
|
|
//dataRow.Height = 20 * 20;
|
|
var type = item.GetType();
|
|
var props = type.GetProperties();
|
|
for (int j = 0; j < headers.Count; j++)
|
|
{
|
|
dataRow.CreateCell(j);
|
|
dataRow.Cells[j].CellStyle = style;
|
|
}
|
|
|
|
dataRow.Cells[0].SetCellValue(item.xiangmu_no);
|
|
dataRow.Cells[1].SetCellValue(item.xiangmu_name);
|
|
dataRow.Cells[2].SetCellValue(item.streetname);
|
|
dataRow.Cells[3].SetCellValue(item.communityname);
|
|
dataRow.Cells[4].SetCellValue(item.quanliren);
|
|
dataRow.Cells[5].SetCellValue(item.xingzhengquhua);
|
|
dataRow.Cells[6].SetCellValue(item.beian_no);
|
|
dataRow.Cells[7].SetCellValue(item.start_time.ToString());
|
|
dataRow.Cells[8].SetCellValue(item.end_time.ToString());
|
|
dataRow.Cells[9].SetCellValue(item.xiangmu_yt);
|
|
if (item.shenqing_area != null)
|
|
{
|
|
dataRow.Cells[10].SetCellValue(item.shenqing_area.ToString());
|
|
}
|
|
else
|
|
{
|
|
dataRow.Cells[10].SetCellValue("0.00");
|
|
}
|
|
|
|
if (item.shengchan_area != null)
|
|
{
|
|
dataRow.Cells[11].SetCellValue(item.shenqing_area.ToString());
|
|
}
|
|
else
|
|
{
|
|
dataRow.Cells[11].SetCellValue("0.00");
|
|
}
|
|
|
|
if (item.fuzhu_area != null)
|
|
{
|
|
dataRow.Cells[12].SetCellValue(item.fuzhu_area.ToString());
|
|
}
|
|
else
|
|
{
|
|
dataRow.Cells[12].SetCellValue("0.00");
|
|
}
|
|
|
|
dataRow.Cells[13].SetCellValue(item.xiafatime.ToString());
|
|
dataRow.Cells[14].SetCellValue(item.handle_status_name);
|
|
|
|
//if (item.handle_status_id != null)
|
|
//{
|
|
// StatusType status = (StatusType)item.handle_status_id;
|
|
// dataRow.Cells[14].SetCellValue(status.ToString());
|
|
//}
|
|
//else
|
|
//{
|
|
// dataRow.Cells[14].SetCellValue("--");
|
|
//}
|
|
}
|
|
|
|
#endregion
|
|
|
|
response.Result = new MemoryStream();
|
|
|
|
workbook.Write(response.Result);
|
|
workbook = null;
|
|
response.Result.Close();
|
|
response.Result.Dispose();
|
|
response.Code = 200;
|
|
response.Message = "获取成功";
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
response.Code = 500;
|
|
response.Message = ex.Message;
|
|
}
|
|
|
|
return response;
|
|
}
|
|
|
|
#endregion
|
|
|
|
#region 项目列表
|
|
|
|
/// <summary>
|
|
/// 项目列表
|
|
/// </summary>
|
|
/// <param name="pageIndex"></param>
|
|
/// <param name="pageSize"></param>
|
|
/// <returns></returns>
|
|
public PageInfo<List<DroneSsnyd>> GetDronssnydList(string xiangmumc, string countyid, string streetid,
|
|
int pageIndex, int pageSize)
|
|
{
|
|
int totalCount = 0;
|
|
var list = base.Repository.AsQueryable()
|
|
.WhereIF(!string.IsNullOrEmpty(xiangmumc), a => a.xiangmu_name.Contains(xiangmumc))
|
|
.WhereIF(!string.IsNullOrEmpty(countyid), a => a.countyid == countyid)
|
|
.WhereIF(!string.IsNullOrEmpty(streetid), a => a.streetid == streetid)
|
|
.OrderBy(a => a.end_time, OrderByType.Desc)
|
|
.ToPageList(pageIndex, pageSize, ref totalCount);
|
|
|
|
return new PageInfo<List<DroneSsnyd>>
|
|
{
|
|
Items = list,
|
|
Total = totalCount
|
|
};
|
|
}
|
|
|
|
#endregion
|
|
|
|
/// <summary>
|
|
/// 项目编号维护
|
|
/// </summary>
|
|
/// <param name="id"></param>
|
|
/// <param name="newXiangmuNo"></param>
|
|
public async Task MaintainNumber(string id, string newXiangmuNo)
|
|
{
|
|
var project = await Repository.AsQueryable().SingleAsync(a => a.Id == id && a.handle_status_id != 99);
|
|
if (project == null)
|
|
{
|
|
throw new Exception("项目不存在或停止生产");
|
|
}
|
|
|
|
var newProject = new DroneSsnyd()
|
|
{
|
|
Id = project.Id,
|
|
xiangmu_no = newXiangmuNo
|
|
};
|
|
await Repository.AsUpdateable(newProject).IgnoreNullColumns().ExecuteCommandAsync();
|
|
}
|
|
|
|
public async Task MaintainXianmuName(string id, string newXiangmuName)
|
|
{
|
|
var project = await Repository.AsQueryable().SingleAsync(a => a.Id == id && a.handle_status_id != 99);
|
|
if (project == null)
|
|
{
|
|
throw new Exception("项目不存在或停止生产");
|
|
}
|
|
|
|
var newProject = new DroneSsnyd()
|
|
{
|
|
Id = project.Id,
|
|
xiangmu_name = newXiangmuName
|
|
};
|
|
await Repository.AsUpdateable(newProject).IgnoreNullColumns().ExecuteCommandAsync();
|
|
}
|
|
|
|
public async Task ProjectRenewal(string id, DateTime newEndTime)
|
|
{
|
|
var project = await Repository.AsQueryable().SingleAsync(a => a.Id == id && a.handle_status_id != 99);
|
|
if (project == null)
|
|
{
|
|
throw new Exception("项目不存在或停止生产");
|
|
}
|
|
|
|
if (newEndTime < project.end_time)
|
|
{
|
|
throw new Exception("新的结束时间不能早于原结束时间");
|
|
}
|
|
|
|
var newProject = new DroneSsnyd()
|
|
{
|
|
Id = project.Id,
|
|
end_time = newEndTime
|
|
};
|
|
await Repository.AsUpdateable(newProject).IgnoreNullColumns().ExecuteCommandAsync();
|
|
}
|
|
|
|
public async Task CloseProject(string id)
|
|
{
|
|
var project = await Repository.AsQueryable().SingleAsync(a => a.Id == id && a.handle_status_id != 99);
|
|
if (project == null)
|
|
{
|
|
throw new Exception("项目不存在或停止生产");
|
|
}
|
|
|
|
var newProject = new DroneSsnyd()
|
|
{
|
|
Id = project.Id,
|
|
handle_status_id = 99,
|
|
handle_status_name = "项目终止",
|
|
};
|
|
await Repository.AsUpdateable(newProject).IgnoreNullColumns().ExecuteCommandAsync();
|
|
}
|
|
|
|
public DroneSsnyd ProjectDetail(string id)
|
|
{
|
|
var project = Repository.GetById(id);
|
|
if (project == null)
|
|
{
|
|
throw new Exception("项目不存在");
|
|
}
|
|
|
|
project.RcjgList = Repository
|
|
.ChangeRepository<SugarRepositiry<DroneSsnydRcjg>>().AsQueryable()
|
|
.Where(c => c.ssnyd_id == id)
|
|
.ToList();
|
|
return project;
|
|
}
|
|
|
|
public async Task ProjectHandover(ProjectHandoverReq req)
|
|
{
|
|
var project = req.MapTo<DroneSsnyd>();
|
|
await Repository.AsUpdateable(project).IgnoreNullColumns().ExecuteCommandAsync();
|
|
}
|
|
|
|
public async Task ProjectMaintain(DroneSsnydEditReq req)
|
|
{
|
|
// todo shp 解析
|
|
var project = req.MapTo<DroneSsnyd>();
|
|
var oldProject = await Repository.GetByIdAsync(project.Id);
|
|
using var uow = base.UnitWork.CreateContext();
|
|
if (string.IsNullOrEmpty(req.shpPath))
|
|
{
|
|
var geomid = oldProject.geomid;
|
|
var geometry = new DroneShpData()
|
|
{
|
|
gid = int.Parse(geomid),
|
|
geom = ""
|
|
};
|
|
await uow.DroneShpData.AsUpdateable(geometry).IgnoreNullColumns().ExecuteCommandAsync();
|
|
}
|
|
|
|
|
|
var b = await uow.DroneSsnyd.AsUpdateable(project).IgnoreNullColumns().ExecuteCommandAsync();
|
|
if (b > 0)
|
|
{
|
|
uow.Commit();
|
|
}
|
|
else
|
|
{
|
|
throw new Exception("更新失败");
|
|
}
|
|
}
|
|
}
|
|
} |