ibms-dome/FrontendWebApi/ApiControllers/OperationController.cs
2022-11-05 11:26:34 +08:00

1049 lines
48 KiB
C#

using FrontendWebApi.Models;
using iTextSharp.text;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.AspNetCore.Mvc.Filters;
using Microsoft.Extensions.Logging;
using Newtonsoft.Json;
using NPOI.HPSF;
using NPOI.SS.Formula.Functions;
using NPOI.SS.UserModel;
using NPOI.Util;
using NPOI.XSSF.UserModel;
using Org.BouncyCastle.Crypto.Agreement.JPake;
using Repository.BackendRepository.Interface;
using Repository.FrontendRepository.Interface;
using System;
using System.Collections.Generic;
using System.Drawing.Drawing2D;
using System.IO;
using System.Linq;
using System.Threading.Tasks;
namespace FrontendWebApi.ApiControllers
{
//[Route("api/[controller]")]
//[ApiController]
public class OperationController : MyBaseApiController<OperationController>
{
private readonly IBackendRepository backendRepository;
private string operationFileSaveAsPath = "";
public OperationController(IBackendRepository backendRepository)
{
this.backendRepository = backendRepository;
operationFileSaveAsPath = Path.Combine(Directory.GetCurrentDirectory(), "wwwroot", "upload", "operation");
}
[HttpPost]
public async Task<ApiResult<List<Variable>>> MaiSysList()
{
ApiResult<List<Variable>> apiResult = new ApiResult<List<Variable>>();
List<Variable> main_system_list = new List<Variable>();
try
{
var sqlString = @$"SELECT *
FROM variable
WHERE system_type = @main_system_type AND deleted = 0
ORDER BY system_priority, created_at desc";
var param = new { @main_system_type = main_system_type };
main_system_list = await backendRepository.GetAllAsync<Variable>(sqlString, param);
apiResult.Code = "0000";
apiResult.Data = main_system_list;
}
catch (Exception exception)
{
apiResult.Code = "9999";
apiResult.Msg = "系統內部錯誤,請聯絡管理者。";
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
[HttpPost]
public async Task<ApiResult<List<Variable>>> SubSysList(string main_system_tag)
{
ApiResult<List<Variable>> apiResult = new ApiResult<List<Variable>>();
List<Variable> sub_system_list = new List<Variable>();
try
{
var sqlString = @$"SELECT v2.*
FROM variable v2
JOIN variable v1 ON v2.system_parent_id = v1.id AND v1.system_type = @main_system_type AND v1.deleted = 0
WHERE v2.system_type = @sub_system_type AND v2.deleted = 0 AND v1.system_type = @main_system_tag
ORDER BY v2.system_priority, v2.created_at desc";
var param = new { @main_system_type = main_system_type, @sub_system_type = sub_system_type, @main_system_tag = main_system_tag };
sub_system_list = await backendRepository.GetAllAsync<Variable>(sqlString, param);
apiResult.Code = "0000";
apiResult.Data = sub_system_list;
}
catch (Exception exception)
{
apiResult.Code = "9999";
apiResult.Msg = "系統內部錯誤,請聯絡管理者。";
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
/// <summary>
/// 大樓列表
/// </summary>
/// <returns></returns>
[HttpPost]
public async Task<ApiResult<List<BuildingList>>> BuiList()
{
ApiResult<List<BuildingList>> apiResult = new ApiResult<List<BuildingList>>();
List<BuildingList> bl = new List<BuildingList>();
try
{
var sqlString = @$"select d.device_area_tag, d.device_building_tag, d.device_floor_tag, CONCAT(case when d.device_area_tag='TPE' then '台北市' else '新北市' end, b.full_name, d.device_floor_tag) as full_name
from device d
join building b on d.device_building_tag = b.building_tag
where d.deleted = 0
group by d.device_area_tag, d.device_building_tag, d.device_floor_tag, b.full_name";
bl = await backendRepository.GetAllAsync<BuildingList>(sqlString);
apiResult.Code = "0000";
apiResult.Data = bl;
}
catch (Exception exception)
{
apiResult.Code = "9999";
apiResult.Msg = "系統內部錯誤,請聯絡管理者。";
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
/// <summary>
/// 設備列表
/// </summary>
/// <returns></returns>
[HttpPost]
public async Task<ApiResult<List<Device>>> DevList(BuildingList bl)
{
ApiResult<List<Device>> apiResult = new ApiResult<List<Device>>();
List<Device> d = new List<Device>();
try
{
var sqlString = @$"select device_number, concat(device_floor_tag, ' ', device_last_name, ' ', device_serial_tag) as device_name
from device where deleted = 0 and device_building_tag = @device_building_tag and device_floor_tag = @device_floor_tag";
var param = new { @device_building_tag = bl.device_building_tag, @device_floor_tag = bl.device_floor_tag };
d = await backendRepository.GetAllAsync<Device>(sqlString, param);
apiResult.Code = "0000";
apiResult.Data = d;
}
catch (Exception exception)
{
apiResult.Code = "9999";
apiResult.Msg = "系統內部錯誤,請聯絡管理者。";
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
/// <summary>
/// 汇出excel (work_type: null=廠商, 1=保養, 2=維修)
/// </summary>
/// <returns></returns>
[HttpPost]
public FileResult OpeExportExcel(byte? work_type)
{
var workbook = new XSSFWorkbook();
#region excel設定
IFont font12 = workbook.CreateFont();
font12.FontName = "新細明體";
font12.FontHeightInPoints = 12;
ICellStyle style12 = workbook.CreateCellStyle();
style12.SetFont(font12);
style12.Alignment = HorizontalAlignment.Center;
style12.VerticalAlignment = VerticalAlignment.Center;
IFont font12Times = workbook.CreateFont();
font12Times.FontName = "Times New Roman";
font12Times.FontHeightInPoints = 12;
IFont font18 = workbook.CreateFont();
font18.FontName = "新細明體";
font18.FontHeightInPoints = 18;
font18.IsBold = true;
ICellStyle styleTitle18 = workbook.CreateCellStyle();
styleTitle18.SetFont(font18);
styleTitle18.Alignment = HorizontalAlignment.Center;
styleTitle18.VerticalAlignment = VerticalAlignment.Center;
ICellStyle styleLeft12 = workbook.CreateCellStyle();
styleLeft12.SetFont(font12);
styleLeft12.Alignment = HorizontalAlignment.Left;
styleLeft12.VerticalAlignment = VerticalAlignment.Center;
ICellStyle styleLine12 = workbook.CreateCellStyle();
styleLine12.SetFont(font12);
styleLine12.Alignment = NPOI.SS.UserModel.HorizontalAlignment.Center;
styleLine12.VerticalAlignment = VerticalAlignment.Center;
styleLine12.BorderTop = NPOI.SS.UserModel.BorderStyle.Thin;
styleLine12.BorderBottom = NPOI.SS.UserModel.BorderStyle.Thin;
styleLine12.BorderRight = NPOI.SS.UserModel.BorderStyle.Thin;
styleLine12.BorderLeft = NPOI.SS.UserModel.BorderStyle.Thin;
ICellStyle stylein12 = workbook.CreateCellStyle();
stylein12.SetFont(font12Times);
stylein12.Alignment = NPOI.SS.UserModel.HorizontalAlignment.Left;
stylein12.VerticalAlignment = VerticalAlignment.Center;
stylein12.BorderTop = NPOI.SS.UserModel.BorderStyle.Thin;
stylein12.BorderBottom = NPOI.SS.UserModel.BorderStyle.Thin;
stylein12.BorderRight = NPOI.SS.UserModel.BorderStyle.Thin;
stylein12.BorderLeft = NPOI.SS.UserModel.BorderStyle.Thin;
stylein12.WrapText = true;
#endregion
if (string.IsNullOrEmpty(work_type.ToString()))
{
var sqlString = $@"select of.*, v2.system_key
from operation_firm of
left join variable v1 on of.device_system_category_layer2 = v1.system_value and v1.system_type = @main_system_type and v1.delted = 0
left join variable v2 on v1.id = v2.system_parent_id and of.device_system_category_layer3 = v2.system_value and v2.system_type = @sub_system_type and v2.deleted = 0
where of.deleted = 0";
var sheet = workbook.CreateSheet("廠商資料");
var operation_firm = backendRepository.GetAllAsync<Operation_Firm>(sqlString, null);
int RowPosition = 0;
#region set cell
IRow row = sheet.CreateRow(RowPosition);
sheet.SetColumnWidth(0, 4 * 160 * 12);
sheet.SetColumnWidth(1, 4 * 160 * 12);
sheet.SetColumnWidth(3, 4 * 160 * 12);
sheet.SetColumnWidth(4, 4 * 160 * 12);
sheet.SetColumnWidth(5, 4 * 160 * 12);
sheet.SetColumnWidth(6, 4 * 160 * 12);
sheet.SetColumnWidth(7, 4 * 160 * 12);
ICell cell = row.CreateCell(0);
cell.SetCellValue("廠商類別");
cell.CellStyle = styleLine12;
cell = row.CreateCell(1);
cell.SetCellValue("廠商名稱");
cell.CellStyle = styleLine12;
cell = row.CreateCell(2);
cell.SetCellValue("聯絡人");
cell.CellStyle = styleLine12;
cell = row.CreateCell(3);
cell.SetCellValue("電話");
cell.CellStyle = styleLine12;
cell = row.CreateCell(4);
cell.SetCellValue("郵箱");
cell.CellStyle = styleLine12;
cell = row.CreateCell(5);
cell.SetCellValue("統一編號");
cell.CellStyle = styleLine12;
cell = row.CreateCell(6);
cell.SetCellValue("備注");
cell.CellStyle = styleLine12;
cell = row.CreateCell(7);
cell.SetCellValue("建立時間");
cell.CellStyle = styleLine12;
#endregion
if (operation_firm.Result.Count > 0)
{
foreach (var of in operation_firm.Result)
{
RowPosition += 1;
row = sheet.CreateRow(RowPosition);
for (var i = 0; i < 8; i++)
{
cell = row.CreateCell(i);
if (i == 0)
{
cell.SetCellValue(of.system_key);
}
if (i == 1)
{
cell.SetCellValue(of.name);
}
if (i == 2)
{
cell.SetCellValue(of.contact_person);
}
if (i == 3)
{
cell.SetCellValue(of.phone);
}
if (i == 4)
{
cell.SetCellValue(of.email);
}
if (i == 5)
{
cell.SetCellValue(of.tax_id_number);
}
if (i == 6)
{
cell.SetCellValue(of.remark);
}
if (i == 7)
{
cell.SetCellValue(of.Created_at);
}
cell.CellStyle = style12;
}
}
}
}
else if (work_type == 1)
{
var sqlString = $@"select opr.*, concat(d.device_floor_tag, ' ', d.device_last_name, ' ', d.device_serial_tag) as device_name, ui.full_name as user_full_name
from operation_record opr
left join device d on opr.fix_do_code = d.device_number
left join userinfo ui on opr.work_person_id = ui.id
where opr.deleted = 0 and opr.work_type = 1";
var sheet = workbook.CreateSheet("廠商資料");
var operation_record = backendRepository.GetAllAsync<Operation_Record>(sqlString, null);
List<Operation_Record_File> operation_record_file = new List<Operation_Record_File>();
if (operation_record.Result.Count > 0)
{
foreach (var or in operation_record.Result)
{
sqlString = $@"select * from operation_record_file where record_id = @record_id";
var param = new { @record_id = or.id };
operation_record_file = backendRepository.GetAllAsync<Operation_Record_File>(sqlString, param).Result;
or.lorf = operation_record_file;
}
int RowPosition = 0;
#region set cell
IRow row = sheet.CreateRow(RowPosition);
sheet.SetColumnWidth(0, 4 * 160 * 12);
sheet.SetColumnWidth(1, 4 * 160 * 12);
sheet.SetColumnWidth(2, 4 * 160 * 12);
sheet.SetColumnWidth(3, 4 * 160 * 12);
sheet.SetColumnWidth(4, 4 * 160 * 12);
sheet.SetColumnWidth(5, 4 * 160 * 12);
sheet.SetColumnWidth(6, 4 * 160 * 12);
sheet.SetColumnWidth(7, 4 * 160 * 12);
sheet.SetColumnWidth(8, 4 * 160 * 12);
sheet.SetColumnWidth(9, 4 * 160 * 12);
ICell cell = row.CreateCell(0);
cell.SetCellValue("項目");
cell.CellStyle = styleLine12;
cell = row.CreateCell(1);
cell.SetCellValue("位置");
cell.CellStyle = styleLine12;
cell = row.CreateCell(2);
cell.SetCellValue("表單號");
cell.CellStyle = styleLine12;
cell = row.CreateCell(3);
cell.SetCellValue("設備名稱");
cell.CellStyle = styleLine12;
cell = row.CreateCell(4);
cell.SetCellValue("狀態");
cell.CellStyle = styleLine12;
cell = row.CreateCell(5);
cell.SetCellValue("處理人員");
cell.CellStyle = styleLine12;
cell = row.CreateCell(6);
cell.SetCellValue("預計施工時間");
cell.CellStyle = styleLine12;
cell = row.CreateCell(7);
cell.SetCellValue("檔案上傳");
cell.CellStyle = styleLine12;
cell = row.CreateCell(8);
cell.SetCellValue("完成時間");
cell.CellStyle = styleLine12;
cell = row.CreateCell(9);
cell.SetCellValue("建立時間");
cell.CellStyle = styleLine12;
#endregion
foreach (var or in operation_record.Result)
{
RowPosition += 1;
row = sheet.CreateRow(RowPosition);
for (var i = 0; i < 10; i++)
{
cell = row.CreateCell(i);
if (i == 0)
{
cell.SetCellValue(or.work_type_name);
}
if (i == 1)
{
cell.SetCellValue(or.location);
}
if (i == 2)
{
cell.SetCellValue(or.formId);
}
if (i == 3)
{
cell.SetCellValue(or.device_name);
}
if (i == 4)
{
cell.SetCellValue(or.status_name);
}
if (i == 5)
{
cell.SetCellValue(or.user_full_name);
}
if (i == 6)
{
cell.SetCellValue(or.start_time);
}
if (i == 7)
{
cell.SetCellValue(or.finish_time); // image
}
if (i == 8)
{
cell.SetCellValue(or.finish_time);
}
if (i == 9)
{
cell.SetCellValue(or.Created_at);
}
cell.CellStyle = style12;
}
}
}
}
else if (work_type == 2)
{
var sqlString = $@"select opr.*, concat(d.device_floor_tag, ' ', d.device_last_name, ' ', d.device_serial_tag) as device_name, ui.full_name as user_full_name
from operation_record opr
left join device d on opr.fix_do_code = d.device_number
left join userinfo ui on opr.work_person_id = ui.id
where opr.deleted = 0 and opr.work_type = 2";
var sheet = workbook.CreateSheet("廠商資料");
var operation_record = backendRepository.GetAllAsync<Operation_Record>(sqlString, null);
List<Operation_Record_File> operation_record_file = new List<Operation_Record_File>();
if (operation_record.Result.Count > 0)
{
foreach(var or in operation_record.Result)
{
sqlString = $@"select * from operation_record_file where record_id = @record_id";
var param = new { @record_id = or.id };
operation_record_file = backendRepository.GetAllAsync<Operation_Record_File>(sqlString, param).Result;
or.lorf = operation_record_file;
}
int RowPosition = 0;
#region set cell
IRow row = sheet.CreateRow(RowPosition);
sheet.SetColumnWidth(0, 4 * 160 * 12);
sheet.SetColumnWidth(1, 4 * 160 * 12);
sheet.SetColumnWidth(2, 4 * 160 * 12);
sheet.SetColumnWidth(3, 4 * 160 * 12);
sheet.SetColumnWidth(4, 4 * 160 * 12);
sheet.SetColumnWidth(5, 4 * 160 * 12);
sheet.SetColumnWidth(6, 4 * 160 * 12);
sheet.SetColumnWidth(7, 4 * 160 * 12);
sheet.SetColumnWidth(8, 4 * 160 * 12);
sheet.SetColumnWidth(9, 4 * 160 * 12);
sheet.SetColumnWidth(10, 4 * 160 * 12);
ICell cell = row.CreateCell(0);
cell.SetCellValue("項目");
cell.CellStyle = styleLine12;
cell = row.CreateCell(1);
cell.SetCellValue("位置");
cell.CellStyle = styleLine12;
cell = row.CreateCell(2);
cell.SetCellValue("異常代號");
cell.CellStyle = styleLine12;
cell = row.CreateCell(3);
cell.SetCellValue("表單號");
cell.CellStyle = styleLine12;
cell = row.CreateCell(4);
cell.SetCellValue("設備名稱");
cell.CellStyle = styleLine12;
cell = row.CreateCell(5);
cell.SetCellValue("狀態");
cell.CellStyle = styleLine12;
cell = row.CreateCell(6);
cell.SetCellValue("處理人員");
cell.CellStyle = styleLine12;
cell = row.CreateCell(7);
cell.SetCellValue("預計施工時間");
cell.CellStyle = styleLine12;
cell = row.CreateCell(8);
cell.SetCellValue("檔案上傳");
cell.CellStyle = styleLine12;
cell = row.CreateCell(9);
cell.SetCellValue("完成時間");
cell.CellStyle = styleLine12;
cell = row.CreateCell(10);
cell.SetCellValue("建立時間");
cell.CellStyle = styleLine12;
var j = 0;//row
#endregion
foreach (var or in operation_record.Result)
{
RowPosition += 1;
row = sheet.CreateRow(RowPosition);
for (var i = 0; i < 10; i++)//column
{
cell = row.CreateCell(i);
if (i == 0)
{
cell.SetCellValue(or.work_type_name);
}
if (i == 1)
{
cell.SetCellValue(or.location);
}
if (i == 1)
{
cell.SetCellValue(or.error_code);
}
if (i == 3)
{
cell.SetCellValue(or.formId);
}
if (i == 4)
{
cell.SetCellValue(or.device_name);
}
if (i == 5)
{
cell.SetCellValue(or.status_name);
}
if (i == 6)
{
cell.SetCellValue(or.user_full_name);
}
if (i == 7)
{
cell.SetCellValue(or.start_time);
}
if (i == 8)//image
{
var image = or.lorf.FirstOrDefault().save_file_name;
var extName = "JPG"; //image.Split('.')[1];
var fullPath = Path.Combine(operationFileSaveAsPath, "image1.jpg");
var imageByte = System.IO.File.ReadAllBytes(fullPath);
int format = 0;
var drawing = sheet.CreateDrawingPatriarch();
foreach (var v in Enum.GetNames(typeof(PictureType)))
{
if (v == extName)
format = Convert.ToInt32(Enum.Parse(typeof(PictureType), v));
}
if (format != 0)
{
var pictureIds = workbook.AddPicture(imageByte, format);
XSSFClientAnchor anchor = new XSSFClientAnchor();
anchor.Col1 = i;
anchor.Row1 = j;
var picture = drawing.CreatePicture(anchor, pictureIds);
picture.Resize();
}
}
if (i == 9)
{
cell.SetCellValue(or.finish_time);
}
if (i == 10)
{
cell.SetCellValue(or.Created_at);
}
cell.CellStyle = style12;
j++;
}
}
}
}
var ms = new NpoiMemoryStream
{
AllowClose = false
};
workbook.Write(ms);
ms.Flush();
ms.Seek(0, SeekOrigin.Begin);
return File(ms, "application/vnd.ms-excel", "廠商資料.xlsx");
}
#region
/// <summary>
/// 廠商資料列表(搜寻) / selection列表 ofl = null
/// </summary>
/// <param name="ofl"></param>
/// <returns></returns>
public async Task<ApiResult<List<Operation_Firm>>> OpeFirList(OperationFindList ofl)
{
ApiResult<List<Operation_Firm>> apiResult = new ApiResult<List<Operation_Firm>>();
List<Operation_Firm> opList = new List<Operation_Firm>();
string sWhere = "";
try
{
if (ofl != null)
{
if (ofl.start_created_at != null || ofl.end_created_at != null)
{
sWhere += $@" and (of.created_at >= isnull(@start_created_at, of.created_at) AND of.created_at <= isnull(@end_created_at, of.created_at))";
}
else if (ofl.today)
{
sWhere += $@" and convert(of.created_at, DATE) = convert(NOW(), DATE)";
}
else if (ofl.yesterday)
{
sWhere += $@" and convert(of.created_at, DATE) = convert(ADDDATE(NOW(), -1), DATE)";
}
if (ofl.sub_system_tag != null || ofl.main_system_tag != null)
{
sWhere += $@" and (of.device_system_category_layer2 = isnull(@main_system_tag, device_system_category_layer2) AND of.device_system_category_layer3 = isnull(@sub_system_tag, device_system_category_layer3))";
}
var sqlString = @$"select of.*, v2.system_key
from operation_firm of
left join variable v1 on of.device_system_category_layer2 = v1.system_value and v1.system_type = @main_system_type and v1.delted = 0
left join variable v2 on v1.id = v2.system_parent_id and of.device_system_category_layer3 = v2.system_value and v2.system_type = @sub_system_type and v2.deleted = 0
where of.deleted = 0" + sWhere;
var param = new { @sub_system_type = sub_system_type, @start_created_at = ofl.start_created_at, @end_created_at = ofl.end_created_at, @sub_system_tag = ofl.sub_system_tag, @main_system_tag = ofl.main_system_tag };
opList = await backendRepository.GetAllAsync<Operation_Firm>(sqlString, param);
}
else
{
var sqlString = $@"select of.id, of.name from operation_firm where deleted = 0";
opList = await backendRepository.GetAllAsync<Operation_Firm>(sqlString);
}
apiResult.Code = "0000";
apiResult.Data = opList;
}
catch (Exception exception)
{
apiResult.Code = "9999";
apiResult.Msg = "系統內部錯誤,請聯絡管理者。";
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
/// <summary>
/// 新增一笔廠商資料
/// </summary>
/// <param name="of"></param>
/// <returns></returns>
public async Task<ApiResult<string>> SaveOpeFirm(Operation_Firm of)
{
ApiResult<string> apiResult = new ApiResult<string>();
try
{
if (of.tax_id_number != null)
{
var sWhere = "deleted = 0 AND tax_id_number = @tax_id_number";
var ofo = await backendRepository.GetOneAsync<Operation_Firm>("operation_firm", sWhere, new { @tax_id_number = of.tax_id_number });
if (ofo != null)
{
apiResult.Code = "0002";
apiResult.Data = "已有相同的统一编号";
return apiResult;
}
}
Dictionary<string, object> operation_firm = new Dictionary<string, object>()
{
{ "@deleted", 0 },
{ "@device_system_category_layer2", of.device_system_category_layer2 },
{ "@device_system_category_layer3", of.device_system_category_layer3 },
{ "@name", of.name },
{ "@contact_person", of.contact_person },
{ "@phone", of.phone },
{ "@email", of.email },
{ "@tax_id_number", of.tax_id_number },
{ "@remark", of.remark },
{ "@created_by", myUser.userinfo_guid },
{ "@created_at", DateTime.Now }
};
await backendRepository.AddOneByCustomTable(operation_firm, "operation_firm");
apiResult.Code = "0000";
apiResult.Data = "新增成功";
}
catch (Exception exception)
{
apiResult.Code = "9999";
apiResult.Msg = "系統內部錯誤,請聯絡管理者。";
string json = System.Text.Json.JsonSerializer.Serialize(of);
Logger.LogError("【" + controllerName + "/" + actionName + "】" + json);
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
/// <summary>
/// 编辑一笔廠商資料
/// </summary>
/// <param name="of"></param>
/// <returns></returns>
public async Task<ApiResult<string>> EdtOneOpeFirm(Operation_Firm of)
{
ApiResult<string> apiResult = new ApiResult<string>();
try
{
var sWhere = @$"deleted = 0 and id = @id";
var gm = await backendRepository.GetOneAsync<Operation_Firm>("operation_firm", sWhere, new { @id = of.id });
if (gm == null)
{
apiResult.Code = "0001";
apiResult.Data = "無法找到厂商";
return apiResult;
}
if (of.tax_id_number != null)
{
sWhere = "deleted = 0 AND tax_id_number = @tax_id_number and id != @id";
var ofo = await backendRepository.GetOneAsync<Operation_Firm>("operation_firm", sWhere, new { @tax_id_number = of.tax_id_number, @id = of.id });
if (ofo != null)
{
apiResult.Code = "0002";
apiResult.Data = "已有相同的统一编号";
return apiResult;
}
}
Dictionary<string, object> operation_firm = new Dictionary<string, object>()
{
{ "@device_system_category_layer2", of.device_system_category_layer2 },
{ "@device_system_category_layer3", of.device_system_category_layer3 },
{ "@name", of.name },
{ "@contact_person", of.contact_person },
{ "@phone", of.phone },
{ "@email", of.email },
{ "@tax_id_number", of.tax_id_number },
{ "@remark", of.remark },
{ "updated_by", myUser.userinfo_guid },
{ "updated_at", DateTime.Now }
};
await backendRepository.UpdateOneByCustomTable(operation_firm, "operation_firm", "id = '" + of.id + "'");
apiResult.Code = "0000";
apiResult.Data = "修改成功";
}
catch (Exception exception)
{
apiResult.Code = "9999";
apiResult.Msg = "系統內部錯誤,請聯絡管理者。";
string json = System.Text.Json.JsonSerializer.Serialize(of);
Logger.LogError("【" + controllerName + "/" + actionName + "】" + json);
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
#endregion
#region /
/// <summary>
/// 維修/保養 列表(work_type)
/// </summary>
/// <param name="ofl"></param>
/// <returns></returns>
public async Task<ApiResult<List<Operation_Record>>> OpeRecList(OperationFindList ofl)
{
ApiResult<List<Operation_Record>> apiResult = new ApiResult<List<Operation_Record>>();
List<Operation_Record> orl = new List<Operation_Record>();
string sWhere = "";
try
{
if (ofl.work_type != 1 || ofl.work_type != 2)
{
apiResult.Code = "0001";
apiResult.Msg = "無此項目類別";
return apiResult;
}
if (ofl.start_created_at != null || ofl.end_created_at != null)
{
sWhere += $@" and (opr.created_at >= isnull(@start_created_at, opr.created_at) AND opr.created_at <= isnull(@end_created_at, opr.created_at))";
}
else if (ofl.today)
{
sWhere += $@" and convert(opr.created_at, DATE) = convert(NOW(), DATE)";
}
else if (ofl.yesterday)
{
sWhere += $@" and convert(opr.created_at, DATE) = convert(ADDDATE(NOW(), -1), DATE)";
}
if (ofl.sub_system_tag != null || ofl.main_system_tag != null)
{
sWhere += $@" and (opr.device_system_category_layer2 = isnull(@main_system_tag, opr.device_system_category_layer2) AND opr.device_system_category_layer3 = isnull(@sub_system_tag, opr.device_system_category_layer3))";
}
if (ofl.serial_number != null)
{
sWhere += $@" and opr.formId like '%@formId%'";
}
var sqlString = $@"select opr.*, concat(d.device_floor_tag, ' ', d.device_last_name, ' ', d.device_serial_tag) as device_name, ui.full_name as user_full_name
from operation_record opr
left join device d on opr.fix_do_code = d.device_number
left join userinfo ui on opr.work_person_id = ui.id
where opr.deleted = 0 and opr.work_type = @work_type" + sWhere;
var param = new { @work_type = ofl.work_type, @start_created_at = ofl.start_created_at, @end_created_at = ofl.end_created_at, @sub_system_tag = ofl.sub_system_tag, @main_system_tag = ofl.main_system_tag, @formId = ofl.serial_number };
orl = await backendRepository.GetAllAsync<Operation_Record>(sqlString, param);
if (orl.Count > 0)
{
foreach(var or in orl)
{
sqlString = $@"select * from operation_record_file where record_id = @record_id and deleted = 0";
var oParam = new { @record_id = or.id };
var orfl = await backendRepository.GetAllAsync<Operation_Record_File>(sqlString, oParam);
or.lorf = orfl;
}
}
apiResult.Code = "0000";
apiResult.Data = orl;
}
catch (Exception exception)
{
apiResult.Code = "9999";
apiResult.Msg = "系統內部錯誤,請聯絡管理者。";
string json = System.Text.Json.JsonSerializer.Serialize(ofl);
Logger.LogError("【" + controllerName + "/" + actionName + "】" + json);
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
/// <summary>
/// 維修/保養---新增/編輯
/// </summary>
/// <param name="or"></param>
/// <returns></returns>
public async Task<ApiResult<string>> SavOpeRecord(Operation_Record or)
{
ApiResult<string> apiResult = new ApiResult<string>();
try
{
var sqlString = $@"select * from operation_record where id = @id";
var param = new { @id = or.id };
var ori = await backendRepository.GetOneAsync<Operation_Record>(sqlString, param);
sqlString = $@"select formId from operation_record where convert(created_at, DATE) = convert(NOW(), DATE) order by id desc limit 1";
var formId = await backendRepository.GetOneAsync<string>(sqlString);
formId = formId != null ? "op" + DateTime.Now.ToString("yyyyMMdd") + (Int32.Parse(formId.Substring(10)) + 1) : "op" + DateTime.Now.ToString("yyyyMMdd") + "001";
if (ori == null) //create
{
var new_guid = new Guid();
Dictionary<string, object> operation_record = new Dictionary<string, object>()
{
{ "@deleted", 0},
{ "@formId", formId},
{ "@location", or.location},
{ "@location_code", or.location_code},
{ "@device_system_category_layer2", or.device_system_category_layer2},
{ "@device_system_category_layer3", or.device_system_category_layer3},
{ "@work_type", or.work_type},
{ "@error_code", or.work_type == 2 ? new_guid.ToString() : null},
{ "@fix_do_code", or.fix_do_code },
{ "@fix_firm", or.fix_firm},
{ "@status", or.status},
{ "@work_person_id", or.work_person_id},
{ "@start_time", or.start_time},
{ "@end_time", or.end_time},
{ "@work_time", or.work_time},
{ "@finish_time", or.finish_time},
{ "@notice", or.notice},
{ "@description", or.description},
{ "@created_by", myUser.userinfo_guid},
{ "@created_at", DateTime.Now}
};
await backendRepository.AddOneByCustomTable(operation_record, "operation_record");
if (or.lorf.Count > 0)
{
foreach(var orf in or.lorf)
{
sqlString = $@"select id from operation_record where formId = @formId";
var fParam = new { @formId = formId };
var record_id = await backendRepository.GetOneAsync<int>(sqlString, fParam);
Dictionary<string, object> operation_record_file = new Dictionary<string, object>()
{
{ "@deleted", 0},
{ "@record_id", record_id},
{ "@ori_file_name", orf.ori_file_name},
{ "@save_file_name", orf.save_file_name},
{ "@created_by", myUser.userinfo_guid},
{ "@created_at", DateTime.Now}
};
if (!System.IO.Directory.Exists(operationFileSaveAsPath))
System.IO.Directory.CreateDirectory(operationFileSaveAsPath);
new_guid = new Guid();
var fileName = new_guid + "." + orf.ori_file_name.Split('.')[1];
var fullPath = Path.Combine(operationFileSaveAsPath, fileName);
using (var stream = new FileStream(fullPath, FileMode.Create))
{
orf.file.CopyTo(stream);
}
await backendRepository.AddOneByCustomTable(operation_record_file, "operation_record_file");
}
}
apiResult.Data = "新增成功";
}
else //edit
{
Dictionary<string, object> operation_record = new Dictionary<string, object>()
{
{ "@location", or.location},
{ "@location_code", or.location_code},
{ "@device_system_category_layer2", or.device_system_category_layer2},
{ "@device_system_category_layer3", or.device_system_category_layer3},
{ "@fix_do_code", or.fix_do_code },
{ "@fix_firm", or.fix_firm},
{ "@status", or.status},
{ "@work_person_id", or.work_person_id},
{ "@start_time", or.start_time},
{ "@end_time", or.end_time},
{ "@work_time", or.work_time},
{ "@finish_time", or.finish_time},
{ "@notice", or.notice},
{ "@description", or.description},
{ "@updated_by", myUser.userinfo_guid},
{ "@updated_at", DateTime.Now}
};
await backendRepository.UpdateOneByCustomTable(operation_record , "operation_record", "id = " + or.id + "");
if (or.lorf.Count > 0)
{
foreach(var orf in or.lorf)
{
if (orf.id == 0)//create
{
Dictionary<string, object> operation_record_file = new Dictionary<string, object>()
{
{ "@deleted", 0},
{ "@formId", or.formId},
{ "@ori_file_name", orf.ori_file_name},
{ "@save_file_name", orf.save_file_name},
{ "@created_by", myUser.userinfo_guid},
{ "@created_at", DateTime.Now}
};
if (!System.IO.Directory.Exists(operationFileSaveAsPath))
System.IO.Directory.CreateDirectory(operationFileSaveAsPath);
var new_guid = new Guid();
var fileName = new_guid + "." + orf.ori_file_name.Split('.')[1];
var fullPath = Path.Combine(operationFileSaveAsPath, fileName);
using (var stream = new FileStream(fullPath, FileMode.Create))
{
orf.file.CopyTo(stream);
}
await backendRepository.AddOneByCustomTable(operation_record_file, "operation_record_file");
}
else//delete
{
Dictionary<string, object> operation_record_file = new Dictionary<string, object>()
{
{ "@deleted", 1},
};
await backendRepository.UpdateOneByCustomTable(operation_record_file, "operation_record_file", "id = " + orf.id + "");
}
}
}
apiResult.Data = "修改成功";
}
apiResult.Code = "0000";
}
catch (Exception exception)
{
apiResult.Code = "9999";
apiResult.Msg = "系統內部錯誤,請聯絡管理者。";
string json = System.Text.Json.JsonSerializer.Serialize(or);
Logger.LogError("【" + controllerName + "/" + actionName + "】" + json);
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
/// <summary>
/// 維修/保養---刪除
/// </summary>
/// <param name="or"></param>
/// <returns></returns>
public async Task<ApiResult<string>> DelOpeRecord(Operation_Record or)
{
ApiResult<string> apiResult = new ApiResult<string>();
try
{
var sqlString = $@"select formId from operation_record where id = @id";
var param = new { @id = or.id };
var formId = await backendRepository.GetOneAsync<string>(sqlString, param);
sqlString = @$"UPDATE operation_record_file SET deleted = 1 WHERE formId = @formId";
var dParam = new { @formId = formId };
await backendRepository.ExecuteSql(sqlString, dParam);
sqlString = @$"UPDATE operation_record SET deleted = 1 WHERE id = @id";
param = new { @id = or.id };
await backendRepository.ExecuteSql(sqlString, param);
apiResult.Code = "0000";
apiResult.Data = "刪除成功";
}
catch (Exception exception)
{
apiResult.Code = "9999";
apiResult.Msg = "系統內部錯誤,請聯絡管理者。";
string json = System.Text.Json.JsonSerializer.Serialize(or);
Logger.LogError("【" + controllerName + "/" + actionName + "】" + json);
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
#endregion
}
}