1329 lines
56 KiB
C#
1329 lines
56 KiB
C#
using Microsoft.AspNetCore.Hosting;
|
|
using Microsoft.AspNetCore.Mvc;
|
|
using Microsoft.Extensions.Hosting;
|
|
using Microsoft.Extensions.Logging;
|
|
using SolarPower.Models;
|
|
using SolarPower.Models.PowerStation;
|
|
using SolarPower.Models.Role;
|
|
using SolarPower.Repository.Interface;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.IO;
|
|
using System.Linq;
|
|
using System.Threading.Tasks;
|
|
using System.Transactions;
|
|
|
|
namespace SolarPower.Controllers
|
|
{
|
|
public class OperationController : MyBaseController<OperationController>
|
|
{
|
|
private readonly IOperationRepository operationRepository;
|
|
private readonly IPowerStationRepository powerStationRepository;
|
|
private readonly IUserRepository userRepository;
|
|
private readonly INoticeScheduleRepository noticeScheduleRepository;
|
|
private string operationRecordFilePath = "/upload/operation_recode/";
|
|
private string operationRecordSaveAsPath = "";
|
|
|
|
public OperationController(
|
|
IOperationRepository operationRepository, IWebHostEnvironment environment,IPowerStationRepository powerStationRepository,IUserRepository userRepository,INoticeScheduleRepository noticeScheduleRepository) : base()
|
|
{
|
|
this.noticeScheduleRepository = noticeScheduleRepository;
|
|
this.userRepository = userRepository;
|
|
this.powerStationRepository = powerStationRepository;
|
|
this.operationRepository = operationRepository;
|
|
operationRecordSaveAsPath = Path.Combine(Directory.GetCurrentDirectory(), "wwwroot", "upload", "operation_recode");
|
|
}
|
|
|
|
public IActionResult Index()
|
|
{
|
|
return View();
|
|
}
|
|
|
|
public IActionResult Record()
|
|
{
|
|
return View("~/Views/Operation/OperationRecord.cshtml");
|
|
}
|
|
|
|
public ApiResult<List<MyCity>> GetMyCities()
|
|
{
|
|
ApiResult<List<MyCity>> apiResult = new ApiResult<List<MyCity>>();
|
|
try
|
|
{
|
|
apiResult.Code = "0000";
|
|
apiResult.Data = myPowerStationService.GetMyCities(myUser);
|
|
}
|
|
catch (Exception exception)
|
|
{
|
|
apiResult.Code = "9999";
|
|
apiResult.Msg = exception.ToString();
|
|
}
|
|
|
|
return apiResult;
|
|
}
|
|
|
|
public ApiResult<List<PowerStation>> GetPowerStationByFilter(List<int> cityIds)
|
|
{
|
|
ApiResult<List<PowerStation>> apiResult = new ApiResult<List<PowerStation>>();
|
|
try
|
|
{
|
|
|
|
var myPowerStations = myPowerStationService.GetMyPowerStations(myUser,1, cityIds);
|
|
|
|
apiResult.Code = "0000";
|
|
apiResult.Data = myPowerStations;
|
|
}
|
|
catch (Exception exception)
|
|
{
|
|
apiResult.Code = "9999";
|
|
apiResult.Msg = exception.ToString();
|
|
}
|
|
|
|
return apiResult;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 取得電站Option
|
|
/// </summary>
|
|
/// <param name="post"></param>
|
|
/// <returns></returns>
|
|
public async Task<ApiResult<List<PowerStationIdList>>> GetPowerStationSelectOption()
|
|
{
|
|
ApiResult<List<PowerStationIdList>> apiResult = new ApiResult<List<PowerStationIdList>>();
|
|
try
|
|
{
|
|
var PowerStationIdLists = new List<PowerStationIdList>();
|
|
PowerStationIdLists = await operationRepository.GetPowerStationIdList(myUser.Id);
|
|
apiResult.Code = "0000";
|
|
apiResult.Data = PowerStationIdLists;
|
|
}
|
|
catch (Exception exception)
|
|
{
|
|
apiResult.Code = "9999";
|
|
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
|
|
}
|
|
|
|
apiResult.Msg = errorCode.GetString(apiResult.Code);
|
|
return apiResult;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 儲存計畫
|
|
/// </summary>
|
|
/// <param name="post"></param>
|
|
/// <returns></returns>
|
|
public async Task<ApiResult<string>> SaveOperationPlan(OperationCreatePlanModal post)
|
|
{
|
|
ApiResult<string> apiResult = new ApiResult<string>();
|
|
try
|
|
{
|
|
if (Convert.ToDateTime(post.StartTime) < Convert.ToDateTime(DateTime.Now.ToString("yyyy-MM-dd")))
|
|
{
|
|
apiResult.Msg = "開始時間不能選擇過去";
|
|
apiResult.Code = "0099";
|
|
return apiResult;
|
|
}
|
|
|
|
|
|
if (post.Id == 0)
|
|
{
|
|
var now = DateTime.Now.ToString("yyyy-MM-dd");
|
|
var finalid = await operationRepository.GetCurrentSerialNumber("operation_plan_create", $"PowerStationId = {post.PowerStationId} AND CreatedAt LIKE '%{now}%'");
|
|
var newSerialNumber = GetLastSerialNumber(finalid);
|
|
var OperationPlan = new OperationCreatePlan()
|
|
{
|
|
EmailType = post.EmailType,
|
|
ScheduleNum = post.ScheduleNum,
|
|
Description = post.Description,
|
|
WorkDay = post.WorkDay,
|
|
ScheduleType = post.ScheduleType,
|
|
SerialNumber = newSerialNumber,
|
|
StartTime = post.StartTime,
|
|
PowerStationId = post.PowerStationId,
|
|
Type = post.Type,
|
|
PlanId = DateTime.Now.ToString("yyyyMMdd") + newSerialNumber,
|
|
CreatedBy = myUser.Id
|
|
};
|
|
List<string> properties = new List<string>()
|
|
{
|
|
"EmailType",
|
|
"ScheduleNum",
|
|
"Description",
|
|
"WorkDay",
|
|
"ScheduleType",
|
|
"SerialNumber",
|
|
"StartTime",
|
|
"PowerStationId",
|
|
"Type",
|
|
"PlanId",
|
|
"CreatedBy"
|
|
};
|
|
|
|
|
|
|
|
if (post.StartTime == DateTime.Now.ToString("yyyy-MM-dd"))
|
|
{
|
|
string endtime = "";
|
|
switch (post.ScheduleType)
|
|
{
|
|
case 0:
|
|
endtime = (Convert.ToDateTime(post.StartTime).AddDays(post.ScheduleNum)).ToString("yyyy-MM-dd 00:00:00"); break;
|
|
case 1:
|
|
endtime = (Convert.ToDateTime(post.StartTime).AddDays(post.ScheduleNum * 7)).ToString("yyyy-MM-dd 00:00:00"); break;
|
|
case 2:
|
|
endtime = (Convert.ToDateTime(post.StartTime).AddMonths(post.ScheduleNum)).ToString("yyyy-MM-dd 00:00:00"); break;
|
|
case 3:
|
|
endtime = (Convert.ToDateTime(post.StartTime).AddMonths(post.ScheduleNum * 3)).ToString("yyyy-MM-dd 00:00:00"); break;
|
|
case 4:
|
|
endtime = (Convert.ToDateTime(post.StartTime).AddYears(post.ScheduleNum * 3)).ToString("yyyy-MM-dd 00:00:00"); break;
|
|
}
|
|
var record = new PlanToRecord()
|
|
{
|
|
WorkType = post.Type,
|
|
PowerStationId = post.PowerStationId,
|
|
StartTime = post.StartTime,
|
|
CreatedBy = myUser.Id,
|
|
EndTime = endtime
|
|
};
|
|
List<string> properties2 = new List<string>()
|
|
{
|
|
"WorkType",
|
|
"PowerStationId",
|
|
"StartTime",
|
|
"CreatedBy",
|
|
"EndTime"
|
|
};
|
|
OperationPlan.LastCreateTime = DateTime.Now.ToString("yyyy-MM-dd 00:00:00");
|
|
properties.Add("LastCreateTime");
|
|
|
|
await operationRepository.AddToRecord(record, properties2);
|
|
}
|
|
await operationRepository.AddOperationPlan(OperationPlan, properties);
|
|
apiResult.Code = "0000";
|
|
apiResult.Msg = "新增成功";
|
|
}
|
|
else
|
|
{
|
|
var OperationPlan = new OperationCreatePlan()
|
|
{
|
|
Id = post.Id,
|
|
EmailType = post.EmailType,
|
|
ScheduleNum = post.ScheduleNum,
|
|
Description = post.Description,
|
|
WorkDay = post.WorkDay,
|
|
ScheduleType = post.ScheduleType,
|
|
StartTime = post.StartTime,
|
|
PowerStationId = post.PowerStationId,
|
|
Type = post.Type,
|
|
UpdatedBy = myUser.Id
|
|
};
|
|
List<string> properties = new List<string>()
|
|
{
|
|
"Id",
|
|
"EmailType",
|
|
"ScheduleNum",
|
|
"Description",
|
|
"WorkDay",
|
|
"ScheduleType",
|
|
"StartTime",
|
|
"PowerStationId",
|
|
"Type",
|
|
"UpdatedBy"
|
|
};
|
|
if (post.StartTime == DateTime.Now.ToString("yyyy-MM-dd"))
|
|
{
|
|
string endtime = "";
|
|
switch (post.ScheduleType)
|
|
{
|
|
case 0:
|
|
endtime = (Convert.ToDateTime(post.StartTime).AddDays(post.ScheduleNum)).ToString("yyyy-MM-dd 00:00:00"); break;
|
|
case 1:
|
|
endtime = (Convert.ToDateTime(post.StartTime).AddDays(post.ScheduleNum * 7)).ToString("yyyy-MM-dd 00:00:00"); break;
|
|
case 2:
|
|
endtime = (Convert.ToDateTime(post.StartTime).AddMonths(post.ScheduleNum)).ToString("yyyy-MM-dd 00:00:00"); break;
|
|
case 3:
|
|
endtime = (Convert.ToDateTime(post.StartTime).AddMonths(post.ScheduleNum * 3)).ToString("yyyy-MM-dd 00:00:00"); break;
|
|
case 4:
|
|
endtime = (Convert.ToDateTime(post.StartTime).AddYears(post.ScheduleNum * 3)).ToString("yyyy-MM-dd 00:00:00"); break;
|
|
}
|
|
var record = new PlanToRecord()
|
|
{
|
|
WorkType = post.Type,
|
|
PowerStationId = post.PowerStationId,
|
|
StartTime = post.StartTime,
|
|
CreatedBy = myUser.Id,
|
|
EndTime = endtime
|
|
};
|
|
List<string> properties2 = new List<string>()
|
|
{
|
|
"WorkType",
|
|
"PowerStationId",
|
|
"StartTime",
|
|
"CreatedBy",
|
|
"EndTime"
|
|
};
|
|
OperationPlan.LastCreateTime = DateTime.Now.ToString("yyyy-MM-dd 00:00:00");
|
|
properties.Add("LastCreateTime");
|
|
|
|
await operationRepository.AddToRecord(record, properties2);
|
|
}
|
|
|
|
await operationRepository.UpdateOperationPlan(OperationPlan, properties);
|
|
apiResult.Code = "0000";
|
|
apiResult.Msg = "編輯成功";
|
|
}
|
|
|
|
|
|
|
|
}
|
|
catch (Exception exception)
|
|
{
|
|
apiResult.Code = "9999";
|
|
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
|
|
}
|
|
|
|
apiResult.Msg = errorCode.GetString(apiResult.Code);
|
|
return apiResult;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 定時計畫datatable
|
|
/// </summary>
|
|
/// <param name="id"></param>
|
|
/// <returns></returns>
|
|
public async Task<ActionResult> OperationPlanTable(List<int> id, int type)
|
|
{
|
|
List<OperationPlanTable> OperationPlanTable = new List<OperationPlanTable>();
|
|
ApiResult<List<OperationPlanTable>> apiResult = new ApiResult<List<OperationPlanTable>>();
|
|
try
|
|
{
|
|
apiResult.Code = "0000";
|
|
OperationPlanTable = await operationRepository.OperationPlanTable(id, type);
|
|
foreach (OperationPlanTable a in OperationPlanTable)
|
|
{
|
|
if (a.Type == 0)
|
|
{
|
|
a.TypeName = "清洗";
|
|
}
|
|
else
|
|
{
|
|
a.TypeName = "巡檢";
|
|
}
|
|
|
|
if (a.ScheduleType == 0)
|
|
{
|
|
a.Schedule = "每" + a.ScheduleNum.ToString() + "天";
|
|
}
|
|
else if (a.ScheduleType == 1)
|
|
{
|
|
a.Schedule = "每" + a.ScheduleNum.ToString() + "周";
|
|
}
|
|
else if (a.ScheduleType == 2)
|
|
{
|
|
a.Schedule = "每" + a.ScheduleNum.ToString() + "月";
|
|
}
|
|
else if (a.ScheduleType == 3)
|
|
{
|
|
a.Schedule = "每" + a.ScheduleNum.ToString() + "季";
|
|
}
|
|
else if (a.ScheduleType == 4)
|
|
{
|
|
a.Schedule = "每" + a.ScheduleNum.ToString() + "年";
|
|
}
|
|
|
|
a.StartTimeString = a.StartTime;
|
|
var crst = a.CreatedAt.Split(" ");
|
|
a.CreateTimeString = crst[0];
|
|
|
|
if (a.EmailType == 0)
|
|
{
|
|
a.EmailTypeName = "當天";
|
|
}
|
|
else if (a.EmailType == 1)
|
|
{
|
|
a.EmailTypeName = "前一天";
|
|
}
|
|
else if (a.EmailType == 2)
|
|
{
|
|
a.EmailTypeName = "前兩天";
|
|
}
|
|
else if (a.EmailType == 3)
|
|
{
|
|
a.EmailTypeName = "前三天";
|
|
}
|
|
|
|
a.Function = @"
|
|
<button type='button' class='btn btn-primary btn-pills waves-effect waves-themed edit-btn'>修改</button>
|
|
<button type='button' class='btn btn-danger btn-pills waves-effect waves-themed del-btn'>刪除</button>";
|
|
}
|
|
|
|
apiResult.Data = OperationPlanTable;
|
|
|
|
}
|
|
catch (Exception exception)
|
|
{
|
|
apiResult.Code = "9999";
|
|
apiResult.Msg = exception.ToString();
|
|
}
|
|
var result = Json(new
|
|
{
|
|
data = apiResult
|
|
});
|
|
|
|
return result;
|
|
}
|
|
/// <summary>
|
|
/// 刪除定時計畫
|
|
/// </summary>
|
|
/// <param name="Id"></param>
|
|
/// <returns></returns>
|
|
public async Task<ApiResult<string>> DeleteOneOperationPlan(int Id)
|
|
{
|
|
ApiResult<string> apiResult = new ApiResult<string>();
|
|
OperationCreatePlan operation = new OperationCreatePlan();
|
|
try
|
|
{
|
|
operation = await operationRepository.GetOneOperation(Id);
|
|
|
|
if (operation == null)
|
|
{
|
|
apiResult.Code = "9998";
|
|
apiResult.Msg = errorCode.GetString(apiResult.Code);
|
|
return apiResult;
|
|
}
|
|
|
|
await operationRepository.DeleteOneByIdWithCustomTable(Id, "operation_plan_create");
|
|
|
|
apiResult.Code = "0000";
|
|
apiResult.Msg = "刪除成功";
|
|
}
|
|
catch (Exception exception)
|
|
{
|
|
apiResult.Code = "9999";
|
|
apiResult.Msg = errorCode.GetString(apiResult.Code);
|
|
Logger.LogError("【" + controllerName + "/" + actionName + "】" + "Id=" + Id);
|
|
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
|
|
}
|
|
|
|
return apiResult;
|
|
}
|
|
|
|
public async Task<ApiResult<OperationCreatePlan>> GetOneOperationPlan(int Id)
|
|
{
|
|
ApiResult<OperationCreatePlan> apiResult = new ApiResult<OperationCreatePlan>();
|
|
OperationCreatePlan operationCreatePlan = new OperationCreatePlan();
|
|
try
|
|
{
|
|
apiResult.Code = "0000";
|
|
operationCreatePlan = await operationRepository.GetOneOperation(Id);
|
|
apiResult.Data = operationCreatePlan;
|
|
}
|
|
catch (Exception exception)
|
|
{
|
|
apiResult.Code = "9999";
|
|
apiResult.Msg = exception.ToString();
|
|
Logger.LogError("【" + controllerName + "/" + actionName + "】" + "Id=" + Id);
|
|
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
|
|
}
|
|
return apiResult;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 運維作業記錄列表
|
|
/// </summary>
|
|
/// <param name="post"></param>
|
|
/// <returns></returns>
|
|
[HttpPost]
|
|
public async Task<ActionResult> OperationRecordListAsync(PostOperationRecordFilter post)
|
|
{
|
|
ApiResult<List<OperationRecordDataTable>> apiResult = new ApiResult<List<OperationRecordDataTable>>();
|
|
|
|
int totalRecords = 0; //總資料筆數
|
|
int recFilter = 0; //過濾後資料筆數
|
|
|
|
List<OperationRecordDataTable> records = null;
|
|
|
|
try
|
|
{
|
|
|
|
records = await operationRepository.GetAllRecordByFilterAsync(post);
|
|
|
|
foreach (var record in records)
|
|
{
|
|
if(post.Status == 2)
|
|
{
|
|
record.Function = "<button class='btn btn-primary redu-btn'>還原</button>";
|
|
if (string.IsNullOrEmpty(record.FormId))
|
|
{
|
|
record.FormId = "";
|
|
}
|
|
else
|
|
{
|
|
record.FormId = record.FormId;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
|
|
record.Function = "<button class='btn btn-danger del-btn'>刪除</button>";
|
|
if (string.IsNullOrEmpty(record.FormId))
|
|
{
|
|
record.FormId = @$"<a href='javascript:;' class='btn btn-success waves-effect waves-themed mb-3 mr-2 edit-btn'>填寫表單</a>";
|
|
}
|
|
else
|
|
{
|
|
record.FormId = @$"<a href='javascript:;' class='waves-effect waves-themed mb-3 mr-2 edit-btn'>{record.FormId}</a>";
|
|
}
|
|
}
|
|
if (record.RecordFiles != null && record.RecordFiles.Count > 0)
|
|
{
|
|
foreach (var file in record.RecordFiles)
|
|
{
|
|
file.FileName = Path.Combine(operationRecordFilePath, record.Id.ToString()) + "/" + file.FileName;
|
|
}
|
|
}
|
|
|
|
}
|
|
|
|
totalRecords = records.Count();
|
|
recFilter = records.Count();
|
|
|
|
apiResult.Code = "0000";
|
|
apiResult.Data = records;
|
|
}
|
|
catch (Exception exception)
|
|
{
|
|
apiResult.Code = "9999";
|
|
string json = System.Text.Json.JsonSerializer.Serialize(post);
|
|
Logger.LogError("【" + controllerName + "/" + actionName + "】" + json);
|
|
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
|
|
}
|
|
|
|
apiResult.Msg = errorCode.GetString(apiResult.Code);
|
|
var result = Json(new
|
|
{
|
|
recordsTotal = totalRecords,
|
|
recordsFiltered = recFilter,
|
|
data = apiResult
|
|
});
|
|
|
|
return result;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 取得單一運維作業記錄列表
|
|
/// </summary>
|
|
/// <param name="post"></param>
|
|
/// <returns></returns>
|
|
[HttpPost]
|
|
public async Task<ApiResult<OperationRecord>> GetOneOperationRecord(int id)
|
|
{
|
|
ApiResult<OperationRecord> apiResult = new ApiResult<OperationRecord>();
|
|
|
|
OperationRecord operationRecord;
|
|
|
|
try
|
|
{
|
|
|
|
//if (!IsPlatformLayer(myUser.Role.Layer))
|
|
//{ //如果只是身分公司管理員 或 公司使用者，就只能看自己公司的資料
|
|
// post.SelectedCompanyId = myUser.CompanyId;
|
|
//}
|
|
|
|
operationRecord = await operationRepository.GetOneOperationRecordAsync(id);
|
|
|
|
if (operationRecord == null)
|
|
{
|
|
apiResult.Code = "9989";
|
|
apiResult.Msg = errorCode.GetString(apiResult.Code);
|
|
return apiResult;
|
|
}
|
|
|
|
foreach (var recordFile in operationRecord.RecordFiles)
|
|
{
|
|
recordFile.FileName = Path.Combine(operationRecordFilePath, operationRecord.Id.ToString()) + "/" + recordFile.FileName;
|
|
}
|
|
|
|
apiResult.Code = "0000";
|
|
apiResult.Data = operationRecord;
|
|
}
|
|
catch (Exception exception)
|
|
{
|
|
apiResult.Code = "9999";
|
|
apiResult.Msg = errorCode.GetString(apiResult.Code);
|
|
Logger.LogError("【" + controllerName + "/" + actionName + "】" + "Id=" + id);
|
|
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
|
|
}
|
|
|
|
return apiResult;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 新增 維修單 / 修改運維作業記錄
|
|
/// </summary>
|
|
/// <param name="post"></param>
|
|
/// <returns></returns>
|
|
public async Task<ApiResult<int>> SaveOperationRecord([FromForm] PostOperationRecord post)
|
|
{
|
|
ApiResult<int> apiResult = new ApiResult<int>();
|
|
|
|
OperationRecord operationRecord = null;
|
|
var id = 0;
|
|
|
|
try
|
|
{
|
|
operationRecord = await operationRepository.GetOneOperationRecordAsync(post.Id);
|
|
|
|
//取得運維作業記錄最後流水號
|
|
var currentSerialNumber = await operationRepository.GetCurrentSerialNumber("operation_record");
|
|
|
|
if (operationRecord == null)
|
|
{
|
|
if (post.Id != 0)
|
|
{
|
|
apiResult.Code = "9989";
|
|
apiResult.Msg = errorCode.GetString(apiResult.Code);
|
|
return apiResult;
|
|
}
|
|
|
|
#region 新增運維作業記錄 - 維修單
|
|
|
|
var tempSerialNumber = GetLastSerialNumber(currentSerialNumber);
|
|
|
|
var finishTime = string.Empty;
|
|
if (post.Status == (int)OperationRecordStatusEnum.Complete)
|
|
{
|
|
finishTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
|
|
}
|
|
|
|
operationRecord = new OperationRecord()
|
|
{
|
|
FormId = "op" + DateTime.Now.ToString("yyyyMMdd") + tempSerialNumber,
|
|
SerialNumber = tempSerialNumber,
|
|
PowerStationId = post.PowerStationId,
|
|
WorkType = (int)OperationRecordWorkTypeEnum.Fix,
|
|
ErrorCode = post.ErrorCode,
|
|
FixDo = post.FixDo,
|
|
FixFirm = post.FixFirm,
|
|
Status = post.Status,
|
|
//WorkPersonId = post.WorkPersonId,
|
|
FinishTime = finishTime,
|
|
WorkTime = post.WorkTime,
|
|
Notice = post.Notice,
|
|
Description = post.Description,
|
|
CreatedBy = myUser.Id
|
|
};
|
|
|
|
List<string> properties = new List<string>()
|
|
{
|
|
"FormId",
|
|
"SerialNumber",
|
|
"PowerStationId",
|
|
"WorkType",
|
|
"ErrorCode",
|
|
"FixDo",
|
|
"FixFirm",
|
|
"Status",
|
|
//"WorkPersonId",
|
|
"FinishTime",
|
|
"WorkTime",
|
|
"Notice",
|
|
"Description",
|
|
"CreatedBy"
|
|
};
|
|
|
|
id = await operationRepository.AddOneOperationRecordAsync(operationRecord, properties);
|
|
|
|
//加入執行人員
|
|
if (post.WorkPersonIds != null)
|
|
{
|
|
List<OperationRecordPersonnel> insertOperationRecordPersonnels = new List<OperationRecordPersonnel>();
|
|
|
|
foreach (var op in post.WorkPersonIds)
|
|
{
|
|
OperationRecordPersonnel operationRecordPersonnel = new OperationRecordPersonnel();
|
|
operationRecordPersonnel.OperationRecordId = id;
|
|
operationRecordPersonnel.UserId = op;
|
|
operationRecordPersonnel.CreatedBy = myUser.Id;
|
|
insertOperationRecordPersonnels.Add(operationRecordPersonnel);
|
|
}
|
|
|
|
List<string> operationRecordPersonnelProperties = new List<string>()
|
|
{
|
|
"OperationRecordId",
|
|
"UserId",
|
|
"CreatedBy"
|
|
};
|
|
|
|
await operationRepository.AddOperationRecordPersonnelAsync(insertOperationRecordPersonnels, operationRecordPersonnelProperties);
|
|
|
|
|
|
}
|
|
|
|
if(post.Emailcheck == 1)
|
|
{
|
|
if (post.WorkPersonIds != null)
|
|
{
|
|
var powerstations = await powerStationRepository.GetOneAsync(post.PowerStationId);
|
|
List<NoticeSchedule> noticeSchedules = new List<NoticeSchedule>();
|
|
foreach (var person in post.WorkPersonIds)
|
|
{
|
|
var fixtype = post.WorkType switch
|
|
{
|
|
0 => "清洗",
|
|
1 => "巡檢",
|
|
2 => "維修",
|
|
_ => ""
|
|
};
|
|
var user = await userRepository.GetOneAsync(person);
|
|
NoticeSchedule schedule = new NoticeSchedule()
|
|
{
|
|
EmailType = 3,
|
|
Type = 1,
|
|
UserId = person,
|
|
RecipientName = user.Name,
|
|
RecipientEmail = user.Email,
|
|
Subject = powerstations.Name + "-" + fixtype + "-" + post.WorkTime,
|
|
Content = "維修項目" + post.FixDo + "</br>注意事項 :" + post.Notice,
|
|
};
|
|
noticeSchedules.Add(schedule);
|
|
}
|
|
properties = new List<string>()
|
|
{
|
|
"UserId",
|
|
"EmailType",
|
|
"RecipientEmail",
|
|
"Subject",
|
|
"Content",
|
|
"RecipientName",
|
|
"Type",
|
|
"ExceptionId"
|
|
};
|
|
await noticeScheduleRepository.AddAnyThing<List<NoticeSchedule>>(noticeSchedules, properties, "notice_schedule");
|
|
}
|
|
|
|
if (post.FixFirm != 0)
|
|
{
|
|
var powerstations = await powerStationRepository.GetOneAsync(post.PowerStationId);
|
|
var fixtype = operationRecord.WorkType switch
|
|
{
|
|
0 => "清洗",
|
|
1 => "巡檢",
|
|
2 => "維修",
|
|
_ => ""
|
|
};
|
|
var powerstation = await powerStationRepository.GetOneAsync(post.PowerStationId);
|
|
var firm = await operationRepository.GetOneWithCustomDBNameAndTableAsync<OperationInfo>(post.FixFirm, powerstations.SiteDB, "operation_firm");
|
|
NoticeSchedule schedule = new NoticeSchedule()
|
|
{
|
|
EmailType = 3,
|
|
Type = 1,
|
|
RecipientName = firm.Name,
|
|
RecipientEmail = firm.Email,
|
|
Subject = powerstations.Name + "-" + fixtype + "-" + post.WorkTime,
|
|
Content = "維修項目" + post.FixDo + "</br>注意事項 :" + post.Notice,
|
|
};
|
|
properties = new List<string>()
|
|
{
|
|
"UserId",
|
|
"EmailType",
|
|
"RecipientEmail",
|
|
"Subject",
|
|
"Content",
|
|
"RecipientName",
|
|
"Type",
|
|
"ExceptionId"
|
|
};
|
|
await noticeScheduleRepository.AddAnyThing<NoticeSchedule>(schedule, properties, "notice_schedule");
|
|
}
|
|
}
|
|
//using (TransactionScope scope = new TransactionScope(TransactionScopeAsyncFlowOption.Suppress))
|
|
//{
|
|
|
|
// scope.Complete();
|
|
//}
|
|
|
|
apiResult.Code = "0000";
|
|
apiResult.Msg = "儲存成功";
|
|
apiResult.Data = id;
|
|
#endregion
|
|
}
|
|
else
|
|
{
|
|
//var transactionOption = new TransactionOptions();
|
|
//transactionOption.IsolationLevel = IsolationLevel.ReadUncommitted;
|
|
//using (TransactionScope scope = new TransactionScope(TransactionScopeOption.Required, transactionOption, TransactionScopeAsyncFlowOption.Enabled))
|
|
//{
|
|
|
|
// scope.Complete();
|
|
//}
|
|
#region 修改運維作業記錄
|
|
var finishTime = string.Empty;
|
|
if (post.Status == (int)OperationRecordStatusEnum.Complete)
|
|
{
|
|
finishTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
|
|
}
|
|
|
|
if (operationRecord.WorkType != (int)OperationRecordWorkTypeEnum.Fix)
|
|
{ //針對清洗、巡檢
|
|
var now = DateTime.Now;
|
|
|
|
var startTime = DateTime.Parse(post.StartTime + " 00:00:00");
|
|
var endTime = DateTime.Parse(post.EndTime + " 23:59:59");
|
|
|
|
if (now > endTime)
|
|
{
|
|
if (post.Status == (int)OperationRecordStatusEnum.NoneComplete)
|
|
{ //超過時間修改成 未完成-過期
|
|
post.Status = (int)OperationRecordStatusEnum.NoneCompleteExpired;
|
|
}
|
|
else if (post.Status == (int)OperationRecordStatusEnum.Complete)
|
|
{ //超過時間修改成 完成-過期
|
|
post.Status = (int)OperationRecordStatusEnum.CompleteExpired;
|
|
}
|
|
}
|
|
}
|
|
|
|
UpdateOperationRecord update = new UpdateOperationRecord()
|
|
{
|
|
Id = post.Id,
|
|
ErrorCode = post.ErrorCode,
|
|
FixDo = post.FixDo,
|
|
FixFirm = post.FixFirm,
|
|
Status = post.Status,
|
|
FinishTime = !string.IsNullOrEmpty(finishTime) ? finishTime : null,
|
|
//WorkPersonId = post.WorkPersonId,
|
|
WorkTime = post.WorkTime,
|
|
Notice = post.Notice,
|
|
Description = post.Description,
|
|
UpdatedBy = myUser.Id
|
|
};
|
|
|
|
List<string> properties = new List<string>()
|
|
{
|
|
"Id",
|
|
"ErrorCode",
|
|
"FixDo",
|
|
"FixFirm",
|
|
"Status",
|
|
"FinishTime",
|
|
"WorkTime",
|
|
"Notice",
|
|
"Description",
|
|
//"WorkPersonId",
|
|
"UpdatedBy",
|
|
};
|
|
|
|
if (string.IsNullOrEmpty(operationRecord.FormId))
|
|
{
|
|
var tempSerialNumber = GetLastSerialNumber(currentSerialNumber);
|
|
|
|
update.FormId = "op" + DateTime.Now.ToString("yyyyMMdd") + tempSerialNumber;
|
|
update.SerialNumber = tempSerialNumber;
|
|
|
|
properties.Add("FormId");
|
|
properties.Add("SerialNumber");
|
|
}
|
|
|
|
await operationRepository.UpdateOperationRecordAsync(update, properties);
|
|
|
|
List<int> origOperationRecordPersonnels = null; //原先的運維人員
|
|
|
|
origOperationRecordPersonnels = await operationRepository.GetOperationRecordPersonnelIdsByOperationRecordId(operationRecord.Id);
|
|
|
|
//判斷新進來的執行人員是否要歸類到新增 or 刪除
|
|
#region 刪除執行人員編號
|
|
if (post.WorkPersonIds != null && post.WorkPersonIds.Count() > 0)
|
|
{
|
|
//找出要刪除的
|
|
List<int> deleteOperationRecordPersonnelIds = origOperationRecordPersonnels.Where(x => !post.WorkPersonIds.Contains(x)).ToList();
|
|
|
|
List<OperationRecordPersonnel> deleteOperationRecordPersonnels = new List<OperationRecordPersonnel>();
|
|
foreach (var opId in deleteOperationRecordPersonnelIds)
|
|
{
|
|
OperationRecordPersonnel operationRecordPersonnel = new OperationRecordPersonnel();
|
|
operationRecordPersonnel.OperationRecordId = operationRecord.Id;
|
|
operationRecordPersonnel.UserId = opId;
|
|
|
|
deleteOperationRecordPersonnels.Add(operationRecordPersonnel);
|
|
}
|
|
|
|
//刪除執行人員
|
|
await operationRepository.DeleteOperationRecordPersonnel(deleteOperationRecordPersonnels);
|
|
}
|
|
#endregion
|
|
|
|
#region 新增人員
|
|
//找出要新增的
|
|
if (post.WorkPersonIds != null && post.WorkPersonIds.Count() > 0)
|
|
{
|
|
List<int> insertOperationRecordPersonnelIds = post.WorkPersonIds.Where(x => !origOperationRecordPersonnels.Contains(x)).ToList();
|
|
|
|
List<OperationRecordPersonnel> insertOperationRecordPersonnels = new List<OperationRecordPersonnel>();
|
|
|
|
foreach (var op in insertOperationRecordPersonnelIds)
|
|
{
|
|
OperationRecordPersonnel operationPersonnel = new OperationRecordPersonnel();
|
|
operationPersonnel.OperationRecordId = operationRecord.Id;
|
|
operationPersonnel.Deleted = 0;
|
|
operationPersonnel.UserId = op;
|
|
operationPersonnel.CreatedBy = myUser.Id;
|
|
|
|
insertOperationRecordPersonnels.Add(operationPersonnel);
|
|
}
|
|
List<string> operationRecordPersonnelProperties = new List<string>()
|
|
{
|
|
"OperationRecordId",
|
|
"Deleted",
|
|
"UserId",
|
|
"CreatedBy",
|
|
};
|
|
await operationRepository.AddOperationRecordPersonnelAsync(insertOperationRecordPersonnels, operationRecordPersonnelProperties);
|
|
}
|
|
|
|
#endregion
|
|
if (post.Emailcheck == 1)
|
|
{
|
|
if (post.WorkPersonIds != null)
|
|
{
|
|
var powerstations = await powerStationRepository.GetOneAsync(post.PowerStationId);
|
|
List<NoticeSchedule> noticeSchedules = new List<NoticeSchedule>();
|
|
foreach (var person in post.WorkPersonIds)
|
|
{
|
|
var fixtype = operationRecord.WorkType switch
|
|
{
|
|
0 => "清洗",
|
|
1 => "巡檢",
|
|
2 => "維修",
|
|
_ => ""
|
|
};
|
|
var user = await userRepository.GetOneAsync(person);
|
|
NoticeSchedule schedule = new NoticeSchedule()
|
|
{
|
|
EmailType = 3,
|
|
Type = 1,
|
|
UserId = person,
|
|
RecipientName = user.Name,
|
|
RecipientEmail = user.Email,
|
|
Subject = powerstations.Name + "-" + fixtype + "-" + post.WorkTime,
|
|
Content = "維修項目:" + post.FixDo + "</br>注意事項 :" + post.Notice,
|
|
};
|
|
noticeSchedules.Add(schedule);
|
|
}
|
|
properties = new List<string>()
|
|
{
|
|
"UserId",
|
|
"EmailType",
|
|
"RecipientEmail",
|
|
"Subject",
|
|
"Content",
|
|
"RecipientName",
|
|
"Type",
|
|
"ExceptionId"
|
|
};
|
|
await noticeScheduleRepository.AddAnyThing<List<NoticeSchedule>>(noticeSchedules, properties, "notice_schedule");
|
|
}
|
|
if (post.FixFirm != 0)
|
|
{
|
|
var powerstations = await powerStationRepository.GetOneAsync(post.PowerStationId);
|
|
var fixtype = post.WorkType switch
|
|
{
|
|
0 => "清洗",
|
|
1 => "巡檢",
|
|
2 => "維修",
|
|
_ => ""
|
|
};
|
|
var powerstation = await powerStationRepository.GetOneAsync(post.PowerStationId);
|
|
var firm = await operationRepository.GetOneWithCustomDBNameAndTableAsync<OperationInfo>(post.FixFirm, powerstations.SiteDB, "operation_firm");
|
|
NoticeSchedule schedule = new NoticeSchedule()
|
|
{
|
|
EmailType = 3,
|
|
Type = 1,
|
|
RecipientName = firm.Name,
|
|
RecipientEmail = firm.Email,
|
|
Subject = powerstations.Name + "-" + fixtype + "-" + post.WorkTime,
|
|
Content = "維修項目:" + post.FixDo + "</br>注意事項 :" + post.Notice,
|
|
};
|
|
properties = new List<string>()
|
|
{
|
|
"UserId",
|
|
"EmailType",
|
|
"RecipientEmail",
|
|
"Subject",
|
|
"Content",
|
|
"RecipientName",
|
|
"Type",
|
|
"ExceptionId"
|
|
};
|
|
await noticeScheduleRepository.AddAnyThing<NoticeSchedule>(schedule, properties, "notice_schedule");
|
|
|
|
|
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
#endregion
|
|
|
|
apiResult.Code = "0000";
|
|
apiResult.Msg = "儲存成功";
|
|
apiResult.Data = operationRecord.Id;
|
|
|
|
}
|
|
}
|
|
catch (Exception exception)
|
|
{
|
|
apiResult.Code = "9999";
|
|
apiResult.Msg = errorCode.GetString(apiResult.Code);
|
|
string json = System.Text.Json.JsonSerializer.Serialize(post);
|
|
Logger.LogError("【" + controllerName + "/" + actionName + "】" + json);
|
|
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
|
|
}
|
|
|
|
return apiResult;
|
|
}
|
|
|
|
public async Task<ApiResult<string>> DeleteOneOperationRecord(int id)
|
|
{
|
|
ApiResult<string> apiResult = new ApiResult<string>();
|
|
|
|
try
|
|
{
|
|
var operationRecord = await operationRepository.GetOneOperationRecordAsync(id);
|
|
|
|
if (operationRecord == null)
|
|
{
|
|
apiResult.Code = "9989";
|
|
apiResult.Msg = errorCode.GetString(apiResult.Code);
|
|
return apiResult;
|
|
}
|
|
|
|
await operationRepository.DeleteOneOperationRecordAsync(id);
|
|
|
|
apiResult.Code = "0000";
|
|
apiResult.Msg = "刪除成功";
|
|
}
|
|
catch (Exception exception)
|
|
{
|
|
apiResult.Code = "9999";
|
|
apiResult.Msg = errorCode.GetString(apiResult.Code);
|
|
Logger.LogError("【" + controllerName + "/" + actionName + "】" + "Id=" + id);
|
|
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
|
|
}
|
|
|
|
return apiResult;
|
|
}
|
|
|
|
public async Task<ApiResult<string>> ReductionOneOperationRecord(int id)
|
|
{
|
|
ApiResult<string> apiResult = new ApiResult<string>();
|
|
|
|
try
|
|
{
|
|
//var operationRecord = await operationRepository.GetOneOperationRecordAsync(id);
|
|
|
|
//if (operationRecord == null)
|
|
//{
|
|
// apiResult.Code = "9989";
|
|
// apiResult.Msg = errorCode.GetString(apiResult.Code);
|
|
// return apiResult;
|
|
//}
|
|
|
|
await operationRepository.ReductionOneOperationRecordAsync(id);
|
|
|
|
apiResult.Code = "0000";
|
|
apiResult.Msg = "還原成功";
|
|
}
|
|
catch (Exception exception)
|
|
{
|
|
apiResult.Code = "9999";
|
|
apiResult.Msg = errorCode.GetString(apiResult.Code);
|
|
Logger.LogError("【" + controllerName + "/" + actionName + "】" + "Id=" + id);
|
|
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
|
|
}
|
|
|
|
return apiResult;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 儲存運維作業記錄檔案
|
|
/// </summary>
|
|
/// <param name="post"></param>
|
|
/// <returns></returns>
|
|
[HttpPost]
|
|
public async Task<ApiResult<OperationRecord>> SaveOperationRecordFile([FromForm] PostOperationRecord post)
|
|
{
|
|
ApiResult<OperationRecord> apiResult = new ApiResult<OperationRecord>();
|
|
|
|
OperationRecord operationRecord = null;
|
|
|
|
try
|
|
{
|
|
operationRecord = await operationRepository.GetOneOperationRecordAsync(post.Id);
|
|
|
|
if (operationRecord == null)
|
|
{
|
|
apiResult.Code = "9989";
|
|
apiResult.Msg = errorCode.GetString(apiResult.Code);
|
|
return apiResult;
|
|
}
|
|
|
|
#region 新增運維作業記錄檔案
|
|
List<OperationRecordFile> operationRecordFiles;
|
|
|
|
if (post.RecordFiles != null && post.RecordFiles.Length > 0)
|
|
{
|
|
FolderFunction folderFunction = new FolderFunction();
|
|
|
|
var fileSaveAsPath = Path.Combine(operationRecordSaveAsPath, operationRecord.Id.ToString());
|
|
|
|
folderFunction.CreateFolder(fileSaveAsPath, 0);
|
|
|
|
operationRecordFiles = new List<OperationRecordFile>();
|
|
|
|
foreach (var file in post.RecordFiles)
|
|
{
|
|
var split = file.FileName.Split(".");
|
|
|
|
var fileName = Guid.NewGuid() + "." + split[split.Length - 1];
|
|
|
|
var fullPath = Path.Combine(fileSaveAsPath, fileName);
|
|
|
|
using (var stream = new FileStream(fullPath, FileMode.Create))
|
|
{
|
|
file.CopyTo(stream);
|
|
}
|
|
|
|
OperationRecordFile operationRecordFile = new OperationRecordFile()
|
|
{
|
|
RecordId = operationRecord.Id,
|
|
FileName = fileName,
|
|
CreatedBy = myUser.Id
|
|
};
|
|
|
|
operationRecordFiles.Add(operationRecordFile);
|
|
}
|
|
|
|
List<string> fileProperties = new List<string>()
|
|
{
|
|
"RecordId",
|
|
"FileName",
|
|
"CreatedBy"
|
|
};
|
|
|
|
await operationRepository.AddOperationRecordFilesAsync(operationRecordFiles, fileProperties);
|
|
}
|
|
#endregion
|
|
|
|
apiResult.Code = "0000";
|
|
apiResult.Msg = "儲存成功";
|
|
}
|
|
catch (Exception exception)
|
|
{
|
|
apiResult.Code = "9999";
|
|
apiResult.Msg = errorCode.GetString(apiResult.Code);
|
|
string json = System.Text.Json.JsonSerializer.Serialize(post);
|
|
Logger.LogError("【" + controllerName + "/" + actionName + "】" + json);
|
|
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
|
|
}
|
|
|
|
return apiResult;
|
|
}
|
|
|
|
public async Task<ApiResult<string>> DeleteOperationRecordFile(PostOperationRecordIdAndSelectedId post)
|
|
{
|
|
ApiResult<string> apiResult = new ApiResult<string>();
|
|
|
|
OperationRecord operationRecord = null;
|
|
OperationRecordFile operationRecordFile = null;
|
|
|
|
try
|
|
{
|
|
operationRecord = await operationRepository.GetOneOperationRecordAsync(post.ReocdeId);
|
|
|
|
if (operationRecord == null)
|
|
{
|
|
apiResult.Code = "9989";
|
|
apiResult.Msg = errorCode.GetString(apiResult.Code);
|
|
return apiResult;
|
|
}
|
|
|
|
operationRecordFile = await operationRepository.GetOneOperationRecordFileAsync(post.SelectedId);
|
|
|
|
if (operationRecordFile == null)
|
|
{
|
|
apiResult.Code = "9987";
|
|
apiResult.Msg = errorCode.GetString(apiResult.Code);
|
|
return apiResult;
|
|
}
|
|
|
|
await operationRepository.DeleteOneOperationRecordFile(post.SelectedId);
|
|
|
|
apiResult.Code = "0000";
|
|
apiResult.Msg = "刪除成功";
|
|
}
|
|
catch (Exception exception)
|
|
{
|
|
apiResult.Code = "9999";
|
|
apiResult.Msg = errorCode.GetString(apiResult.Code);
|
|
string json = System.Text.Json.JsonSerializer.Serialize(post);
|
|
Logger.LogError("【" + controllerName + "/" + actionName + "】" + json);
|
|
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
|
|
}
|
|
|
|
return apiResult;
|
|
}
|
|
|
|
public async Task<ApiResult<List<OperationRecordDataTable>>> ExportOperationRecordExcel(PostOperationRecordFilter post)
|
|
{
|
|
ApiResult<List<OperationRecordDataTable>> apiResult = new ApiResult<List<OperationRecordDataTable>>();
|
|
|
|
List<OperationRecordDataTable> records = null;
|
|
|
|
try
|
|
{
|
|
|
|
//if (!IsPlatformLayer(myUser.Role.Layer))
|
|
//{ //如果只是身分公司管理員 或 公司使用者，就只能看自己公司的資料
|
|
// post.SelectedCompanyId = myUser.CompanyId;
|
|
//}
|
|
|
|
records = await operationRepository.GetAllRecordByFilterAsync(post);
|
|
|
|
foreach (var record in records)
|
|
{
|
|
record.PowerStationName = !string.IsNullOrEmpty(record.PowerStationName) ? record.PowerStationName : "";
|
|
record.FormId = !string.IsNullOrEmpty(record.FormId) ? record.FormId : "";
|
|
record.FixDo = !string.IsNullOrEmpty(record.FixDo) ? record.FixDo : "";
|
|
record.WorkPersonName = !string.IsNullOrEmpty(record.WorkPersonName) ? record.WorkPersonName : "";
|
|
//record.FinishTime = !string.IsNullOrEmpty(record.FinishTime) ? record.FinishTime : "";
|
|
|
|
if (record.RecordFiles != null && record.RecordFiles.Count > 0)
|
|
{
|
|
foreach (var file in record.RecordFiles)
|
|
{
|
|
var hyperLink = "<a href='" + baseURL + file.FileName + "'>" + file.FileName + "</a>";
|
|
if (record.HyperLinks == null)
|
|
{
|
|
record.HyperLinks = new List<string>();
|
|
}
|
|
record.HyperLinks.Add(hyperLink);
|
|
}
|
|
}
|
|
}
|
|
|
|
apiResult.Code = "0000";
|
|
apiResult.Data = records;
|
|
}
|
|
catch (Exception exception)
|
|
{
|
|
apiResult.Code = "9999";
|
|
string json = System.Text.Json.JsonSerializer.Serialize(post);
|
|
Logger.LogError("【" + controllerName + "/" + actionName + "】" + json);
|
|
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
|
|
}
|
|
|
|
apiResult.Msg = errorCode.GetString(apiResult.Code);
|
|
return apiResult;
|
|
}
|
|
|
|
public async void Schedule()
|
|
{
|
|
try
|
|
{
|
|
var getTime = await operationRepository.GetOperationSchedules();
|
|
foreach (OperationCreatePlanModal a in getTime)
|
|
{
|
|
DateTime Updatedtime;
|
|
if (a.ScheduleType == 0)//日
|
|
{
|
|
Updatedtime = Convert.ToDateTime(a.StartTime).AddDays(a.ScheduleNum);
|
|
}
|
|
else if (a.ScheduleType == 1)//周
|
|
{
|
|
Updatedtime = Convert.ToDateTime(a.StartTime).AddDays(a.ScheduleNum * 7);
|
|
}
|
|
else if (a.ScheduleType == 2)//月
|
|
{
|
|
Updatedtime = Convert.ToDateTime(a.StartTime).AddMonths(a.ScheduleNum);
|
|
}
|
|
else if (a.ScheduleType == 3)//季
|
|
{
|
|
Updatedtime = Convert.ToDateTime(a.StartTime).AddMonths(a.ScheduleNum * 3);
|
|
}
|
|
else // 年
|
|
{
|
|
Updatedtime = Convert.ToDateTime(a.StartTime).AddYears(a.ScheduleNum);
|
|
}
|
|
|
|
if (Updatedtime < DateTime.Now)
|
|
{
|
|
var now = DateTime.Now.ToString("yyyy-MM-dd");
|
|
var finalid = await operationRepository.GetCurrentSerialNumber("operation_plan_create", $"PowerStationId = {a.PowerStationId} AND CreatedAt LIKE '%{now}%'");
|
|
var newSerialNumber = GetLastSerialNumber(finalid);
|
|
var OperationPlan = new OperationCreatePlan()
|
|
{
|
|
EmailType = a.EmailType,
|
|
ScheduleNum = a.ScheduleNum,
|
|
Description = a.Description,
|
|
WorkDay = a.WorkDay,
|
|
ScheduleType = a.ScheduleType,
|
|
SerialNumber = newSerialNumber,
|
|
StartTime = Updatedtime.ToString("yyyy-MM-dd hh:mm:ss"),
|
|
PowerStationId = a.PowerStationId,
|
|
Type = a.Type,
|
|
PlanId = DateTime.Now.ToString("yyyyMMdd") + newSerialNumber,
|
|
CreatedBy = myUser.Id
|
|
};
|
|
List<string> properties = new List<string>()
|
|
{
|
|
"EmailType",
|
|
"ScheduleNum",
|
|
"Description",
|
|
"WorkDay",
|
|
"ScheduleType",
|
|
"SerialNumber",
|
|
"StartTime",
|
|
"PowerStationId",
|
|
"Type",
|
|
"PlanId",
|
|
"CreatedBy"
|
|
};
|
|
await operationRepository.AddOperationPlan(OperationPlan, properties);
|
|
|
|
var record = new PlanToRecord()
|
|
{
|
|
WorkType = a.Type,
|
|
PowerStationId = a.PowerStationId,
|
|
StartTime = Updatedtime.ToString("yyyy-MM-dd hh:mm:ss"),
|
|
CreatedBy = myUser.Id,
|
|
EndTime = Updatedtime.AddDays(a.WorkDay).ToString("yyyy-MM-dd hh:mm:ss")
|
|
};
|
|
List<string> properties2 = new List<string>()
|
|
{
|
|
"WorkType",
|
|
"PowerStationId",
|
|
"StartTime",
|
|
"CreatedBy",
|
|
"EndTime"
|
|
};
|
|
await operationRepository.AddToRecord(record, properties2);
|
|
var operation = await operationRepository.GetOneOperation(a.Id);
|
|
await operationRepository.DeleteOneByIdWithCustomTable(a.Id, "operation_plan_create");
|
|
|
|
}
|
|
|
|
}
|
|
}
|
|
catch (Exception exception)
|
|
{
|
|
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
|
|
}
|
|
}
|
|
|
|
}
|
|
}
|