799 lines
31 KiB
C#
799 lines
31 KiB
C#
|
using System;
|
|||
|
|
using System.Linq;
|
|||
|
|
using ZR.Model;
|
|||
|
|
using ZR.Model.MES.dev;
|
|||
|
|
using ZR.Model.MES.dev.Dto;
|
|||
|
|
using ZR.Repository;
|
|||
|
|
using ZR.Service.MES.dev.IService;
|
|||
|
|
using Infrastructure.Attribute;
|
|||
|
|
using Infrastructure.Extensions;
|
|||
|
|
using JinianNet.JNTemplate;
|
|||
|
|
using JinianNet.JNTemplate.Nodes;
|
|||
|
|
using Mapster;
|
|||
|
|
using Microsoft.AspNetCore.Authentication;
|
|||
|
|
using Newtonsoft.Json.Linq;
|
|||
|
|
using SqlSugar;
|
|||
|
|
using SqlSugar.IOC;
|
|||
|
|
|
|||
|
|
namespace ZR.Service.MES.dev
|
|||
|
|
{
|
|||
|
|
/// <summary>
|
|||
|
|
/// 任务执行Service业务层处理
|
|||
|
|
/// </summary>
|
|||
|
|
[AppService(
|
|||
|
|
ServiceType = typeof(IDeviceTaskExecuteService),
|
|||
|
|
ServiceLifetime = LifeTime.Transient
|
|||
|
|
)]
|
|||
|
|
public class DeviceTaskExecuteService
|
|||
|
|
: BaseService<DeviceTaskExecute>,
|
|||
|
|
IDeviceTaskExecuteService
|
|||
|
|
{
|
|||
|
|
/// <summary>
|
|||
|
|
/// 查询任务执行列表
|
|||
|
|
/// 附加每个任务是检查还是保养
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="parm"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public PagedInfo<DeviceTaskExecuteDto> GetList(DeviceTaskExecuteQueryDto parm)
|
|||
|
|
{
|
|||
|
|
var predicate = Expressionable
|
|||
|
|
.Create<DeviceTaskExecute>()
|
|||
|
|
.AndIF(
|
|||
|
|
!string.IsNullOrEmpty(parm.TaskName),
|
|||
|
|
it => it.TaskName.Contains(parm.TaskName)
|
|||
|
|
)
|
|||
|
|
.AndIF(
|
|||
|
|
parm.TimeRange != null && (parm.TimeRange[0] > new DateTime(1990, 1, 1)),
|
|||
|
|
it => it.CreatedTime >= parm.TimeRange[0]
|
|||
|
|
)
|
|||
|
|
.AndIF(
|
|||
|
|
parm.TimeRange != null && (parm.TimeRange[1] > new DateTime(1990, 1, 1)),
|
|||
|
|
it => it.CreatedTime <= parm.TimeRange[1]
|
|||
|
|
)
|
|||
|
|
.AndIF(parm.Type > -1, it => it.Type == parm.Type)
|
|||
|
|
.AndIF(parm.Status > -1, it => it.Status == parm.Status);
|
|||
|
|
|
|||
|
|
var response = Queryable()
|
|||
|
|
.OrderByDescending(x => x.Id)
|
|||
|
|
.Where(predicate.ToExpression())
|
|||
|
|
.ToPage<DeviceTaskExecute, DeviceTaskExecuteDto>(parm);
|
|||
|
|
|
|||
|
|
foreach (DeviceTaskExecuteDto item in response.Result)
|
|||
|
|
{
|
|||
|
|
if (item.StartTime > DateTime.MinValue && item.EndTime > DateTime.MinValue)
|
|||
|
|
{
|
|||
|
|
TimeSpan timeDifference = item.EndTime.Value - item.StartTime.Value;
|
|||
|
|
|
|||
|
|
double minutes = timeDifference.TotalMinutes;
|
|||
|
|
double roundedMinutes = Math.Round(minutes, 1);
|
|||
|
|
item.ConsumeTime = roundedMinutes;
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
int InnerType=0;
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return response;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 获取详情
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="Id"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public DeviceTaskExecute GetInfo(string Id)
|
|||
|
|
{
|
|||
|
|
var response = Queryable().Where(x => x.Id == Id).First();
|
|||
|
|
|
|||
|
|
return response;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 添加任务执行
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="model"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public DeviceTaskExecute AddDeviceTaskExecute(DeviceTaskExecute model)
|
|||
|
|
{
|
|||
|
|
model.Id = SnowFlakeSingle.Instance.NextId().ToString();
|
|||
|
|
return Context.Insertable(model).ExecuteReturnEntity();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 修改任务执行
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="model"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public int UpdateDeviceTaskExecute(DeviceTaskExecute model)
|
|||
|
|
{
|
|||
|
|
//var response = Update(w => w.Id == model.Id, it => new DeviceTaskExecute()
|
|||
|
|
//{
|
|||
|
|
// TaskName = model.TaskName,
|
|||
|
|
// Type = model.Type,
|
|||
|
|
// DistributedTime = model.DistributedTime,
|
|||
|
|
// StartTime = model.StartTime,
|
|||
|
|
// EndTime = model.EndTime,
|
|||
|
|
// Status = model.Status,
|
|||
|
|
// Remark = model.Remark,
|
|||
|
|
// CreatedBy = model.CreatedBy,
|
|||
|
|
// CreatedTime = model.CreatedTime,
|
|||
|
|
// UpdatedBy = model.UpdatedBy,
|
|||
|
|
// UpdatedTime = model.UpdatedTime,
|
|||
|
|
//});
|
|||
|
|
//return response;
|
|||
|
|
return Update(model, true);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public int Update_task_status(DeviceTaskExecuteQueryDto2 parm)
|
|||
|
|
{
|
|||
|
|
var response = Update(
|
|||
|
|
w => w.Id == parm.Id,
|
|||
|
|
it => new DeviceTaskExecute()
|
|||
|
|
{
|
|||
|
|
Status = parm.Status,
|
|||
|
|
|
|||
|
|
UpdatedBy = parm.UpdatedBy,
|
|||
|
|
UpdatedTime = parm.UpdatedTime,
|
|||
|
|
}
|
|||
|
|
);
|
|||
|
|
return response;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 清空任务执行
|
|||
|
|
/// </summary>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public bool TruncateDeviceTaskExecute()
|
|||
|
|
{
|
|||
|
|
var newTableName = $"device_task_execute_{DateTime.Now:yyyyMMdd}";
|
|||
|
|
if (Queryable().Any() && !Context.DbMaintenance.IsAnyTable(newTableName))
|
|||
|
|
{
|
|||
|
|
Context.DbMaintenance.BackupTable("device_task_execute", newTableName);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return Truncate();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 导入任务执行
|
|||
|
|
/// </summary>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public (string, object, object) ImportDeviceTaskExecute(List<DeviceTaskExecute> list)
|
|||
|
|
{
|
|||
|
|
var x = Context
|
|||
|
|
.Storageable(list)
|
|||
|
|
.SplitInsert(it => !it.Any())
|
|||
|
|
.SplitError(x => x.Item.Type.IsEmpty(), "任务类型（1是巡检，2是点检）不能为空")
|
|||
|
|
//.WhereColumns(it => it.UserName)//如果不是主键可以这样实现（多字段it=>new{it.x1,it.x2}）
|
|||
|
|
.ToStorage();
|
|||
|
|
var result = x.AsInsertable.ExecuteCommand(); //插入可插入部分;
|
|||
|
|
|
|||
|
|
string msg =
|
|||
|
|
$"插入{x.InsertList.Count} 更新{x.UpdateList.Count} 错误数据{x.ErrorList.Count} 不计算数据{x.IgnoreList.Count} 删除数据{x.DeleteList.Count} 总共{x.TotalList.Count}";
|
|||
|
|
Console.WriteLine(msg);
|
|||
|
|
|
|||
|
|
//输出错误信息
|
|||
|
|
foreach (var item in x.ErrorList)
|
|||
|
|
{
|
|||
|
|
Console.WriteLine("错误" + item.StorageMessage);
|
|||
|
|
}
|
|||
|
|
foreach (var item in x.IgnoreList)
|
|||
|
|
{
|
|||
|
|
Console.WriteLine("忽略" + item.StorageMessage);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return (msg, x.ErrorList, x.IgnoreList);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 任务计划调度 扫描每日巡检任务
|
|||
|
|
/// </summary>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public int ScanEveryTask()
|
|||
|
|
{
|
|||
|
|
int result = 0;
|
|||
|
|
List<DeviceRouteInspectionPlan> InitDataList = DbScoped.SugarScope.CopyNew()
|
|||
|
|
.Queryable<DeviceRouteInspectionPlan>()
|
|||
|
|
.Where(it => it.Status == 1)
|
|||
|
|
.Where(it => it.LifeCycleStart <= DateTime.Now)
|
|||
|
|
.Where(it => it.LifeCycleEnd >= DateTime.Now)
|
|||
|
|
.ToList();
|
|||
|
|
|
|||
|
|
// 今日时间
|
|||
|
|
DateTime CurrentTime = new DateTime(
|
|||
|
|
DateTime.Now.Year,
|
|||
|
|
DateTime.Now.Month,
|
|||
|
|
DateTime.Now.Day,
|
|||
|
|
0,
|
|||
|
|
0,
|
|||
|
|
0
|
|||
|
|
);
|
|||
|
|
//1. 扫描巡检
|
|||
|
|
List<DeviceRouteInspectionPlan> deviceRouteInspectionPlan_execute_List =
|
|||
|
|
new List<DeviceRouteInspectionPlan>();
|
|||
|
|
#region 1.1 每日类型处理
|
|||
|
|
|
|||
|
|
List<DeviceRouteInspectionPlan> RouteInspectionPlan_day_List = InitDataList
|
|||
|
|
.Where(it => it.ExcuteCycleType == 1)
|
|||
|
|
.ToList();
|
|||
|
|
|
|||
|
|
Console.WriteLine("每日类型处理" + RouteInspectionPlan_day_List.Count);
|
|||
|
|
if (RouteInspectionPlan_day_List != null && RouteInspectionPlan_day_List.Count > 0)
|
|||
|
|
{
|
|||
|
|
foreach (var item in RouteInspectionPlan_day_List)
|
|||
|
|
{
|
|||
|
|
//开始日期
|
|||
|
|
DateTime start_cal =item.LifeCycleStart??DateTime.MinValue;
|
|||
|
|
start_cal = new DateTime(
|
|||
|
|
start_cal.Year,
|
|||
|
|
start_cal.Month,
|
|||
|
|
start_cal.Day,
|
|||
|
|
0,
|
|||
|
|
0,
|
|||
|
|
0
|
|||
|
|
);
|
|||
|
|
//循环周期
|
|||
|
|
int cycle_period = (int)item.DayNum;
|
|||
|
|
DateTime date = start_cal;
|
|||
|
|
do
|
|||
|
|
{
|
|||
|
|
date = date.AddDays(cycle_period);
|
|||
|
|
if (date == CurrentTime)
|
|||
|
|
{
|
|||
|
|
//今日要执行任务
|
|||
|
|
deviceRouteInspectionPlan_execute_List.Add(item);
|
|||
|
|
break;
|
|||
|
|
}
|
|||
|
|
} while (date <= CurrentTime);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
#endregion
|
|||
|
|
#region 1.2 每周类型处理
|
|||
|
|
|
|||
|
|
|
|||
|
|
List<DeviceRouteInspectionPlan> DeviceRouteInspectionPlan_week_list = InitDataList
|
|||
|
|
.Where(it => it.ExcuteCycleType == 2)
|
|||
|
|
.ToList();
|
|||
|
|
|
|||
|
|
Console.WriteLine("每周类型处理" + DeviceRouteInspectionPlan_week_list.Count);
|
|||
|
|
int dayofweek = (int)CurrentTime.DayOfWeek;
|
|||
|
|
if (CurrentTime.DayOfWeek == DayOfWeek.Sunday)
|
|||
|
|
{
|
|||
|
|
dayofweek = 7;
|
|||
|
|
}
|
|||
|
|
if (
|
|||
|
|
DeviceRouteInspectionPlan_week_list != null
|
|||
|
|
&& DeviceRouteInspectionPlan_week_list.Count > 0
|
|||
|
|
)
|
|||
|
|
{
|
|||
|
|
foreach (var item in DeviceRouteInspectionPlan_week_list)
|
|||
|
|
{
|
|||
|
|
string[] cycle_period = item.WeekList.Split(",");
|
|||
|
|
if (cycle_period.Length > 0)
|
|||
|
|
{
|
|||
|
|
for (int i = 0; i < cycle_period.Length; i++)
|
|||
|
|
{
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
Console.WriteLine("cycle_period[i]=" + cycle_period[i]);
|
|||
|
|
if (dayofweek == Convert.ToInt32(cycle_period[i]))
|
|||
|
|
{
|
|||
|
|
deviceRouteInspectionPlan_execute_List.Add(
|
|||
|
|
(DeviceRouteInspectionPlan)item
|
|||
|
|
);
|
|||
|
|
break;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
catch (FormatException ex)
|
|||
|
|
{
|
|||
|
|
Console.WriteLine("An error occurred: " + ex.Message);
|
|||
|
|
continue;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
#endregion
|
|||
|
|
#region 1.3 每月类型处理
|
|||
|
|
|
|||
|
|
List<DeviceRouteInspectionPlan> DeviceRouteInspectionPlan_month_list = InitDataList
|
|||
|
|
.Where(it => it.ExcuteCycleType == 3)
|
|||
|
|
.ToList();
|
|||
|
|
|
|||
|
|
Console.WriteLine("每月类型处理" + DeviceRouteInspectionPlan_month_list.Count);
|
|||
|
|
if (
|
|||
|
|
DeviceRouteInspectionPlan_month_list != null
|
|||
|
|
&& DeviceRouteInspectionPlan_month_list.Count > 0
|
|||
|
|
)
|
|||
|
|
{
|
|||
|
|
foreach (var item in DeviceRouteInspectionPlan_month_list)
|
|||
|
|
{
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
if (CurrentTime.Day == Convert.ToInt32(item.MonthDayList))
|
|||
|
|
{
|
|||
|
|
deviceRouteInspectionPlan_execute_List.Add(
|
|||
|
|
(DeviceRouteInspectionPlan)item
|
|||
|
|
);
|
|||
|
|
continue;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
catch (FormatException ex)
|
|||
|
|
{
|
|||
|
|
Console.WriteLine("An error occurred: " + ex.Message);
|
|||
|
|
continue;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
#endregion
|
|||
|
|
// 插入数据库
|
|||
|
|
List<DeviceTaskExecute> executes = new List<DeviceTaskExecute>();
|
|||
|
|
if (deviceRouteInspectionPlan_execute_List.Count > 0)
|
|||
|
|
{
|
|||
|
|
foreach (var item in deviceRouteInspectionPlan_execute_List)
|
|||
|
|
{
|
|||
|
|
DeviceTaskExecute taskExecute = new DeviceTaskExecute();
|
|||
|
|
taskExecute.Id = SnowFlakeSingle.Instance.NextId().ToString();
|
|||
|
|
taskExecute.TaskName = item.Name;
|
|||
|
|
taskExecute.PlanId = item.Id;
|
|||
|
|
taskExecute.Type = 1;
|
|||
|
|
taskExecute.DistributedTime = DateTime.Now;
|
|||
|
|
taskExecute.Status = 0;
|
|||
|
|
taskExecute.CreatedTime = DateTime.Now;
|
|||
|
|
executes.Add(taskExecute);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
if (executes.Count > 0)
|
|||
|
|
{
|
|||
|
|
result = Context.Insertable(executes).ExecuteCommand();
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
return result;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 派发点检任务
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="id"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public int ExecutionTask_point(string id)
|
|||
|
|
{
|
|||
|
|
DevicePointInspectionPlan point = Context
|
|||
|
|
.Queryable<DevicePointInspectionPlan>()
|
|||
|
|
.Where(it => it.Id == id)
|
|||
|
|
.First();
|
|||
|
|
|
|||
|
|
DeviceTaskExecute taskExecute = new DeviceTaskExecute();
|
|||
|
|
taskExecute.Id = SnowFlakeSingle.Instance.NextId().ToString();
|
|||
|
|
taskExecute.TaskName = point.Name;
|
|||
|
|
taskExecute.PlanId = point.Id;
|
|||
|
|
taskExecute.Type = 2;
|
|||
|
|
taskExecute.DistributedTime = DateTime.Now;
|
|||
|
|
taskExecute.Status = 0;
|
|||
|
|
taskExecute.CreatedTime = DateTime.Now;
|
|||
|
|
|
|||
|
|
return Context.Insertable(taskExecute).ExecuteCommand();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 获取任务执行绑定的巡检任务和点检任务绑定的设备
|
|||
|
|
/// </summary>
|
|||
|
|
public List<DeviceAccount> AchieveTaskbindDevice(string id)
|
|||
|
|
{
|
|||
|
|
List<DeviceAccount> resul = null;
|
|||
|
|
DeviceTaskExecute executeTask = Context
|
|||
|
|
.Queryable<DeviceTaskExecute>()
|
|||
|
|
.Where(it => it.Id == id)
|
|||
|
|
.First();
|
|||
|
|
if (executeTask != null)
|
|||
|
|
{
|
|||
|
|
// 类型为巡检
|
|||
|
|
if (executeTask.Type == 1)
|
|||
|
|
{
|
|||
|
|
resul = Context
|
|||
|
|
.Queryable<DeviceRelRpAt>()
|
|||
|
|
.LeftJoin<DeviceAccount>((r, a) => r.FkDeviceAccountId == a.Id)
|
|||
|
|
.Where(r => r.FkRouteInspectionPlanId == executeTask.PlanId)
|
|||
|
|
.Select((r, a) => a)
|
|||
|
|
.ToList();
|
|||
|
|
}
|
|||
|
|
// 类型为点检
|
|||
|
|
else if (executeTask.Type == 2)
|
|||
|
|
{
|
|||
|
|
resul = Context
|
|||
|
|
.Queryable<DeviceRelPpAt>()
|
|||
|
|
.LeftJoin<DeviceAccount>((p, a) => p.FkDeviceAccountId == a.Id)
|
|||
|
|
.Where(p => p.FkPointInspectionPlanId == executeTask.PlanId)
|
|||
|
|
.Select((p, a) => a)
|
|||
|
|
.ToList();
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return resul;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 获取设备绑定的检查项
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="fk_device_id">设备id</param>
|
|||
|
|
/// <param name="fkPlanId">计划id</param>
|
|||
|
|
/// <param name="planType">计划类型</param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public List<DeviceInspect> AchieveDevicebindInspect(int fk_device_id, string fkPlanId, int planType)
|
|||
|
|
{
|
|||
|
|
|
|||
|
|
// 判断是保养/检查吗
|
|||
|
|
int check_type = 1;
|
|||
|
|
if(planType == 1)
|
|||
|
|
{
|
|||
|
|
check_type= Context.Queryable<DeviceRouteInspectionPlan>().Where(it => it.Id == fkPlanId)
|
|||
|
|
.Select(it => it.InnerType.Value).First();
|
|||
|
|
|
|||
|
|
}else if (planType == 2)
|
|||
|
|
{
|
|||
|
|
check_type = Context.Queryable<DevicePointInspectionPlan>().Where(it => it.Id == fkPlanId)
|
|||
|
|
.Select(it => it.InnerType.Value).First();
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
List<DeviceInspect> resul = null;
|
|||
|
|
|
|||
|
|
resul = Context
|
|||
|
|
.Queryable<DeviceRelAccountInspect>()
|
|||
|
|
.LeftJoin<DeviceInspect>((r, i) => r.FkInspectId == i.Id)
|
|||
|
|
.Where(r => r.FkAccountId == fk_device_id)
|
|||
|
|
.Where((r,i)=>i.Type==check_type)
|
|||
|
|
.Select((r, i) => i)
|
|||
|
|
.ToList();
|
|||
|
|
|
|||
|
|
return resul;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 获取检查项绑定的检查表单
|
|||
|
|
/// </summary>
|
|||
|
|
public List<DeviceFormConfig> AchieveInspectbindForm(int fk_device_inspect_id)
|
|||
|
|
{
|
|||
|
|
List<DeviceFormConfig> result = null;
|
|||
|
|
result = Context
|
|||
|
|
.Queryable<DeviceFormConfig>()
|
|||
|
|
.Where(it => it.FkDeviceInspectId == fk_device_inspect_id)
|
|||
|
|
.ToList();
|
|||
|
|
return result;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 获取表单结果
|
|||
|
|
/// </summary>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public List<DeviceTaskExecuteResult1_result> AchieveFormResult(
|
|||
|
|
DeviceTaskExecuteResult1QueryDto_TaskExecute query
|
|||
|
|
)
|
|||
|
|
{
|
|||
|
|
List<DeviceTaskExecuteResult1_result> final_result_list =
|
|||
|
|
new List<DeviceTaskExecuteResult1_result>();
|
|||
|
|
|
|||
|
|
List<DeviceTaskExecuteResult> resultList = Context
|
|||
|
|
.Queryable<DeviceTaskExecuteResult>()
|
|||
|
|
.Where(it => it.PlanType == query.PlanType)
|
|||
|
|
.Where(it => it.FkPlanId == query.FkPlanId)
|
|||
|
|
.Where(it => it.FkDeviceId == query.FkDeviceId)
|
|||
|
|
.Where(it => it.FkInspectId == query.FkInspectId)
|
|||
|
|
.ToList();
|
|||
|
|
|
|||
|
|
if (resultList.Count == 0)
|
|||
|
|
{
|
|||
|
|
//初始化结果表
|
|||
|
|
List<DeviceFormConfig> configlist = Context
|
|||
|
|
.Queryable<DeviceFormConfig>()
|
|||
|
|
.Where(it => it.FkDeviceInspectId == query.FkInspectId)
|
|||
|
|
.ToList();
|
|||
|
|
|
|||
|
|
if (configlist.Count > 0)
|
|||
|
|
{
|
|||
|
|
List<DeviceTaskExecuteResult> addResultList =
|
|||
|
|
new List<DeviceTaskExecuteResult>();
|
|||
|
|
string PlanName = Context
|
|||
|
|
.Queryable<DeviceRouteInspectionPlan>()
|
|||
|
|
.Where(it => it.Id == query.FkPlanId)
|
|||
|
|
.First()
|
|||
|
|
?.Name;
|
|||
|
|
string DeviceName = Context
|
|||
|
|
.Queryable<DeviceAccount>()
|
|||
|
|
.Where(it => it.Id == query.FkDeviceId)
|
|||
|
|
.First()
|
|||
|
|
?.DeviceName;
|
|||
|
|
string InspectName = Context
|
|||
|
|
.Queryable<DeviceInspect>()
|
|||
|
|
.Where(it => it.Id == query.FkInspectId)
|
|||
|
|
.First()
|
|||
|
|
?.Name;
|
|||
|
|
|
|||
|
|
foreach (DeviceFormConfig config in configlist)
|
|||
|
|
{
|
|||
|
|
DeviceTaskExecuteResult result1 = new DeviceTaskExecuteResult();
|
|||
|
|
|
|||
|
|
result1.Id = SnowFlakeSingle.Instance.NextId().ToString();
|
|||
|
|
result1.PlanType = query.PlanType;
|
|||
|
|
result1.FkPlanId = query.FkPlanId;
|
|||
|
|
result1.PlanName = PlanName;
|
|||
|
|
result1.FkDeviceId = query.FkDeviceId;
|
|||
|
|
result1.DeviceName = DeviceName;
|
|||
|
|
result1.FkInspectId = query.FkInspectId;
|
|||
|
|
result1.InspectName = InspectName;
|
|||
|
|
result1.FormType = config.Type;
|
|||
|
|
result1.FormTitle = config.Title;
|
|||
|
|
result1.FormName = config.Content;
|
|||
|
|
|
|||
|
|
addResultList.Add(result1);
|
|||
|
|
//生成返回结果
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
Context.Insertable(addResultList).ExecuteCommand();
|
|||
|
|
// 处理初始化返回
|
|||
|
|
if (addResultList.Count > 0)
|
|||
|
|
{
|
|||
|
|
// 1 取出所有的类别
|
|||
|
|
int?[] FormTypeArray = addResultList
|
|||
|
|
.Select(it => it.FormType)
|
|||
|
|
.Distinct()
|
|||
|
|
.ToArray();
|
|||
|
|
//2. 分别处理类别
|
|||
|
|
for (int i = 0; i < FormTypeArray.Length; i++)
|
|||
|
|
{
|
|||
|
|
var temp = addResultList
|
|||
|
|
.Where(it => it.FormType == FormTypeArray[i])
|
|||
|
|
.ToList();
|
|||
|
|
DeviceTaskExecuteResult1_result item =
|
|||
|
|
new DeviceTaskExecuteResult1_result();
|
|||
|
|
|
|||
|
|
item.Id = temp[0].Id;
|
|||
|
|
item.Title = temp[0].FormTitle;
|
|||
|
|
item.Type = temp[0].FormType;
|
|||
|
|
item.Value = "";
|
|||
|
|
item.Children = addResultList
|
|||
|
|
.Where(it => it.FormType == FormTypeArray[i])
|
|||
|
|
.Select(it => it.FormName)
|
|||
|
|
.Distinct()
|
|||
|
|
.ToArray();
|
|||
|
|
item.Value = item.Children[0];
|
|||
|
|
final_result_list.Add(item);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
else if (resultList.Count > 0)
|
|||
|
|
{
|
|||
|
|
// 直接从结果表中获取
|
|||
|
|
|
|||
|
|
if (resultList.Count > 0)
|
|||
|
|
{
|
|||
|
|
// 1 取出所有的类别
|
|||
|
|
int?[] FormTypeArray = resultList
|
|||
|
|
.Select(it => it.FormType)
|
|||
|
|
.Distinct()
|
|||
|
|
.ToArray();
|
|||
|
|
//2. 分别处理类别
|
|||
|
|
for (int i = 0; i < FormTypeArray.Length; i++)
|
|||
|
|
{
|
|||
|
|
var temp = resultList.Where(it => it.FormType == FormTypeArray[i]).ToList();
|
|||
|
|
DeviceTaskExecuteResult1_result item =
|
|||
|
|
new DeviceTaskExecuteResult1_result();
|
|||
|
|
|
|||
|
|
item.Id = temp[0].Id;
|
|||
|
|
item.Title = temp[0].FormTitle;
|
|||
|
|
item.Type = temp[0].FormType;
|
|||
|
|
item.Value = "";
|
|||
|
|
item.Children = resultList
|
|||
|
|
.Where(it => it.FormType == FormTypeArray[i])
|
|||
|
|
.Select(it => it.FormName)
|
|||
|
|
.Distinct()
|
|||
|
|
.ToArray();
|
|||
|
|
List<DeviceTaskExecuteResult> FormResultArray = resultList
|
|||
|
|
.Where(it => it.FormType == FormTypeArray[i])
|
|||
|
|
.ToList();
|
|||
|
|
|
|||
|
|
if (FormResultArray.Count == 1)
|
|||
|
|
{
|
|||
|
|
item.Value = FormResultArray[0].FormName;
|
|||
|
|
}
|
|||
|
|
else if (FormResultArray.Count > 1)
|
|||
|
|
{
|
|||
|
|
string[] str = new string[FormResultArray.Count];
|
|||
|
|
for (int ii = 0; ii < str.Length; ii++)
|
|||
|
|
{
|
|||
|
|
str[i] = FormResultArray[ii].FormName;
|
|||
|
|
}
|
|||
|
|
item.Value = string.Join(", ", str).ToString();
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
item.Value = item.Children[0];
|
|||
|
|
}
|
|||
|
|
final_result_list.Add(item);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
return final_result_list;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 获取表单结果2
|
|||
|
|
/// 结果表只存选中的结果,多选也只有一个结果
|
|||
|
|
/// </summary>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public List<DeviceTaskExecuteResult1_result> AchieveFormResult2(
|
|||
|
|
DeviceTaskExecuteResult1QueryDto_TaskExecute query
|
|||
|
|
)
|
|||
|
|
{
|
|||
|
|
List<DeviceTaskExecuteResult1_result> final_result_list =
|
|||
|
|
new List<DeviceTaskExecuteResult1_result>();
|
|||
|
|
|
|||
|
|
// 获取 设备检查项 所有表单类型
|
|||
|
|
List<DeviceFormConfig> all_config_list = Context
|
|||
|
|
.Queryable<DeviceFormConfig>()
|
|||
|
|
.Where(it => it.FkDeviceInspectId == query.FkInspectId)
|
|||
|
|
.ToList();
|
|||
|
|
|
|||
|
|
int?[] config_type = all_config_list.Select(it => it.Type).Distinct().ToArray();
|
|||
|
|
DevicePointInspectionPlan handle_point_plan = Context
|
|||
|
|
.Queryable<DevicePointInspectionPlan>()
|
|||
|
|
.Where(it => it.Id == query.FkPlanId)
|
|||
|
|
.First();
|
|||
|
|
DeviceRouteInspectionPlan handle_rounte_plan = Context
|
|||
|
|
.Queryable<DeviceRouteInspectionPlan>()
|
|||
|
|
.Where(it => it.Id == query.FkPlanId)
|
|||
|
|
.First();
|
|||
|
|
DeviceAccount deviceAccount = Context
|
|||
|
|
.Queryable<DeviceAccount>()
|
|||
|
|
.Where(it => it.Id == query.FkDeviceId)
|
|||
|
|
.First();
|
|||
|
|
DeviceInspect inspect = Context
|
|||
|
|
.Queryable<DeviceInspect>()
|
|||
|
|
.Where(it => it.Id == query.FkInspectId)
|
|||
|
|
.First();
|
|||
|
|
if (config_type.Length > 0)
|
|||
|
|
{
|
|||
|
|
for (int i = 0; i < config_type.Length; i++)
|
|||
|
|
{
|
|||
|
|
//在结果表里查看是否有结果
|
|||
|
|
DeviceTaskExecuteResult executeResult = Context
|
|||
|
|
.Queryable<DeviceTaskExecuteResult>()
|
|||
|
|
.Where(it => it.FkTaskId == query.FkTaskId)
|
|||
|
|
.Where(it => it.PlanType == query.PlanType)
|
|||
|
|
.Where(it => it.FkPlanId == query.FkPlanId)
|
|||
|
|
.Where(it => it.FkDeviceId == query.FkDeviceId)
|
|||
|
|
.Where(it => it.FkInspectId == query.FkInspectId)
|
|||
|
|
.Where(it => it.FormType == config_type[i])
|
|||
|
|
.First();
|
|||
|
|
|
|||
|
|
if (executeResult != null)
|
|||
|
|
{
|
|||
|
|
DeviceTaskExecuteResult1_result item =
|
|||
|
|
new()
|
|||
|
|
{
|
|||
|
|
Id = executeResult.Id,
|
|||
|
|
Title = executeResult.FormTitle,
|
|||
|
|
Value = executeResult.FormName,
|
|||
|
|
Type = executeResult.FormType,
|
|||
|
|
Children = all_config_list
|
|||
|
|
.Where(it => it.Type == config_type[i])
|
|||
|
|
.Select(it => it.Content)
|
|||
|
|
.ToArray()
|
|||
|
|
};
|
|||
|
|
final_result_list.Add(item);
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
DeviceTaskExecuteResult insertData =
|
|||
|
|
new()
|
|||
|
|
{
|
|||
|
|
Id = SnowFlakeSingle.Instance.NextId().ToString(),
|
|||
|
|
FkTaskId = query.FkTaskId,
|
|||
|
|
PlanType = query.PlanType,
|
|||
|
|
FkPlanId = query.FkPlanId
|
|||
|
|
};
|
|||
|
|
//点检
|
|||
|
|
if (query.PlanType == 2)
|
|||
|
|
{
|
|||
|
|
insertData.FkPlanId = query.FkPlanId;
|
|||
|
|
insertData.PlanName = handle_point_plan?.Name;
|
|||
|
|
insertData.InnerType = handle_point_plan?.InnerType;
|
|||
|
|
}
|
|||
|
|
else if (query.PlanType == 1)
|
|||
|
|
{
|
|||
|
|
//巡检
|
|||
|
|
insertData.FkPlanId = query.FkPlanId;
|
|||
|
|
insertData.PlanName = handle_rounte_plan?.Name;
|
|||
|
|
insertData.ExcuteCycleType = handle_rounte_plan?.ExcuteCycleType;
|
|||
|
|
|
|||
|
|
insertData.InnerType = handle_rounte_plan?.InnerType;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
insertData.FkDeviceId = query.FkDeviceId;
|
|||
|
|
insertData.DeviceName = deviceAccount.DeviceName;
|
|||
|
|
insertData.FkInspectId = query.FkInspectId;
|
|||
|
|
insertData.InspectName = inspect.Name;
|
|||
|
|
insertData.FormType = config_type[i];
|
|||
|
|
insertData.FormTitle = all_config_list
|
|||
|
|
.Where(it => it.Type == config_type[i])
|
|||
|
|
.Select(it => it.Title)
|
|||
|
|
.First();
|
|||
|
|
|
|||
|
|
Context.Insertable(insertData).ExecuteReturnIdentity();
|
|||
|
|
DeviceTaskExecuteResult1_result item =
|
|||
|
|
new()
|
|||
|
|
{
|
|||
|
|
Id = insertData.Id,
|
|||
|
|
Title = insertData.FormTitle,
|
|||
|
|
Value = "",
|
|||
|
|
Type = insertData.FormType,
|
|||
|
|
Children = all_config_list
|
|||
|
|
.Where(it => it.Type == config_type[i])
|
|||
|
|
.Select(it => it.Content)
|
|||
|
|
.ToArray()
|
|||
|
|
};
|
|||
|
|
final_result_list.Add(item);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return final_result_list;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 更新结果表单
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="result"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public int UpdateFormResult(DeviceTaskExecuteResultDto result)
|
|||
|
|
{
|
|||
|
|
//if (!string.IsNullOrEmpty(result.taskExecute_id))
|
|||
|
|
// Context.Updateable<DeviceTaskExecute>().Where(it => it.Id == result.taskExecute_id).SetColumns(it => it.Person == result.UpdatedBy).ExecuteCommand();
|
|||
|
|
|
|||
|
|
result.Person = result.UpdatedBy;
|
|||
|
|
DeviceTaskExecuteResult item = result.Adapt<DeviceTaskExecuteResult>();
|
|||
|
|
|
|||
|
|
return Context
|
|||
|
|
.Updateable(item)
|
|||
|
|
.IgnoreColumns(true)
|
|||
|
|
.EnableDiffLogEvent("更新结果表单")
|
|||
|
|
.ExecuteCommand();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 增加任务开始时间
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="Id"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public int AddDeviceTaskExecute(string Id, string name)
|
|||
|
|
{
|
|||
|
|
DateTime dateTime = DateTime.Now;
|
|||
|
|
return Context
|
|||
|
|
.Updateable<DeviceTaskExecute>()
|
|||
|
|
.Where(it => it.Id == Id)
|
|||
|
|
.Where(it => it.StartTime == null)
|
|||
|
|
.SetColumns(it => it.StartTime == dateTime)
|
|||
|
|
.SetColumns(it => it.Person == name)
|
|||
|
|
.ExecuteCommand();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 增加任务完成时间
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="Id"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public int AddTaskFinallyTime(string Id)
|
|||
|
|
{
|
|||
|
|
DateTime dateTime = DateTime.Now;
|
|||
|
|
return Context
|
|||
|
|
.Updateable<DeviceTaskExecute>()
|
|||
|
|
.Where(it => it.Id == Id)
|
|||
|
|
.SetColumns(it => it.EndTime == dateTime)
|
|||
|
|
.ExecuteCommand();
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|