687 lines
24 KiB
C#
687 lines
24 KiB
C#
using Dapper;
|
||
using SolarPower.Helper;
|
||
using SolarPower.Models;
|
||
using SolarPower.Repository.Interface;
|
||
using System;
|
||
using System.Collections.Generic;
|
||
using System.Data;
|
||
using System.Linq;
|
||
using System.Threading.Tasks;
|
||
|
||
namespace SolarPower.Repository.Implement
|
||
{
|
||
public class OperationRepository : RepositoryBase<Operation>, IOperationRepository
|
||
{
|
||
public OperationRepository(IDatabaseHelper databaseHelper) : base(databaseHelper)
|
||
{
|
||
tableName = "operation_plan_create";
|
||
}
|
||
public async Task<List<PowerStationIdList>> GetPowerStationIdList(int UserId)
|
||
{
|
||
List<PowerStationIdList> result;
|
||
using (IDbConnection conn = this._databaseHelper.GetConnection())
|
||
{
|
||
try
|
||
{
|
||
var sql = @$"SELECT tn.Id AS Value, tn.Name AS Text FROM power_station tn LEFT JOIN power_station_operation_personnel pp
|
||
ON tn.Id=pp.PowerStationId
|
||
WHERE pp.UserId = @userid";
|
||
result = (await conn.QueryAsync<PowerStationIdList>(sql, new { userid = UserId })).ToList();
|
||
}
|
||
catch (Exception exception)
|
||
{
|
||
throw exception;
|
||
}
|
||
return result;
|
||
}
|
||
}
|
||
|
||
public async Task AddOperationPlan(OperationCreatePlan OperationPlan, List<string> properties)
|
||
{
|
||
using (IDbConnection conn = _databaseHelper.GetConnection())
|
||
{
|
||
conn.Open();
|
||
try
|
||
{
|
||
string sql = GenerateInsertQuery(properties);
|
||
|
||
await conn.ExecuteAsync(sql, OperationPlan);
|
||
}
|
||
catch (Exception exception)
|
||
{
|
||
throw exception;
|
||
}
|
||
finally
|
||
{
|
||
conn.Close();
|
||
}
|
||
|
||
}
|
||
}
|
||
public async Task<List<OperationPlanTable>> OperationPlanTable(List<int> id, int Type)
|
||
{
|
||
List<OperationPlanTable> result;
|
||
var count = 0;
|
||
string Wheresql = "oc.PowerStationId = ";
|
||
if (id.Count > 0)
|
||
{
|
||
foreach (int too in id)
|
||
{
|
||
|
||
if (count == id.Count - 1)
|
||
{
|
||
Wheresql += too.ToString();
|
||
}
|
||
else
|
||
{
|
||
Wheresql += too.ToString() + " OR oc.PowerStationId = ";
|
||
}
|
||
count++;
|
||
}
|
||
|
||
}
|
||
else
|
||
{
|
||
Wheresql += "0";
|
||
}
|
||
|
||
using (IDbConnection conn = this._databaseHelper.GetConnection())
|
||
{
|
||
try
|
||
{
|
||
var sql = "";
|
||
if (Type != 9)
|
||
{
|
||
sql = @$"SELECT oc.Id,oc.PlanId,oc.PowerStationId,oc.Type,
|
||
oc.ScheduleNum,oc.ScheduleType,oc.WorkDay,oc.StartTime,
|
||
oc.EmailType,oc.Description,oc.CreatedAt,ps.Name AS PowerStationName ,us.Name AS CreatedPerson FROM operation_plan_create oc LEFT JOIN power_station ps
|
||
ON oc.PowerStationId = ps.Id LEFT JOIN user us
|
||
ON us.Id = oc.CreatedBy WHERE ({Wheresql}) AND oc.Deleted = 0 AND oc.Type = {Type} ORDER BY CreatedAt DESC";
|
||
}
|
||
else
|
||
{
|
||
sql = @$"SELECT oc.Id,oc.PlanId,oc.PowerStationId,oc.Type,
|
||
oc.ScheduleNum,oc.ScheduleType,oc.WorkDay,oc.StartTime,
|
||
oc.EmailType,oc.Description,oc.CreatedAt,ps.Name AS PowerStationName ,us.Name AS CreatedPerson FROM operation_plan_create oc LEFT JOIN power_station ps
|
||
ON oc.PowerStationId = ps.Id LEFT JOIN user us
|
||
ON us.Id = oc.CreatedBy WHERE ({Wheresql}) AND oc.Deleted = 0 ORDER BY CreatedAt DESC";
|
||
}
|
||
|
||
|
||
result = (await conn.QueryAsync<OperationPlanTable>(sql)).ToList();
|
||
}
|
||
catch (Exception exception)
|
||
{
|
||
throw exception;
|
||
}
|
||
return result;
|
||
}
|
||
}
|
||
public async Task<OperationCreatePlan> GetOneOperation(int id)
|
||
{
|
||
OperationCreatePlan result;
|
||
using (IDbConnection conn = _databaseHelper.GetConnection())
|
||
{
|
||
conn.Open();
|
||
try
|
||
{
|
||
var sql = @"SELECT * FROM operation_plan_create WHERE Deleted =0 AND Id = @Id";
|
||
|
||
result = await conn.QueryFirstOrDefaultAsync<OperationCreatePlan>(sql, new { Id = id });
|
||
}
|
||
catch (Exception exception)
|
||
{
|
||
throw exception;
|
||
}
|
||
finally
|
||
{
|
||
conn.Close();
|
||
}
|
||
|
||
return result;
|
||
}
|
||
}
|
||
|
||
public async Task UpdateOperationPlan(OperationCreatePlan OperationPlan, List<string> properties)
|
||
{
|
||
using (IDbConnection conn = _databaseHelper.GetConnection())
|
||
{
|
||
conn.Open();
|
||
var trans = conn.BeginTransaction();
|
||
try
|
||
{
|
||
var sql = GenerateUpdateQuery(properties);
|
||
await conn.ExecuteAsync(sql, OperationPlan, trans);
|
||
|
||
trans.Commit();
|
||
}
|
||
catch (Exception exception)
|
||
{
|
||
trans.Rollback();
|
||
throw exception;
|
||
}
|
||
finally
|
||
{
|
||
conn.Close();
|
||
}
|
||
|
||
}
|
||
}
|
||
|
||
public async Task AddToRecord(PlanToRecord record, List<string> properties2)
|
||
{
|
||
using (IDbConnection conn = _databaseHelper.GetConnection())
|
||
{
|
||
conn.Open();
|
||
var trans = conn.BeginTransaction();
|
||
try
|
||
{
|
||
string sql = GenerateInsertQueryWithCustomTable(properties2, "operation_record");
|
||
await conn.ExecuteAsync(sql, record);
|
||
trans.Commit();
|
||
}
|
||
catch (Exception exception)
|
||
{
|
||
trans.Rollback();
|
||
throw exception;
|
||
}
|
||
finally
|
||
{
|
||
conn.Close();
|
||
}
|
||
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 透過搜尋條件，查詢過濾後的運維作業記錄
|
||
/// </summary>
|
||
/// <param name="filter"></param>
|
||
/// <returns></returns>
|
||
public async Task<List<OperationRecordDataTable>> GetAllRecordByFilterAsync(PostOperationRecordFilter filter)
|
||
{
|
||
List<OperationRecordDataTable> result;
|
||
using (IDbConnection conn = this._databaseHelper.GetConnection())
|
||
{
|
||
try
|
||
{
|
||
var sql = @$"SELECT aa.* FROM (
|
||
SELECT
|
||
opr.*,
|
||
ps.Name AS PowerStationName,
|
||
u.Name AS WorkPersonName
|
||
FROM operation_record opr
|
||
LEFT JOIN power_station ps ON opr.PowerStationId = ps.Id
|
||
LEFT JOIN user u ON opr.WorkPersonId = u.ID
|
||
WHERE opr.Deleted = 0 AND opr.Status = {filter.Status}
|
||
AND ps.Id IN @PowerStationIds";
|
||
|
||
if (!string.IsNullOrEmpty(filter.Range))
|
||
{
|
||
filter.StartTime = filter.Range.Split('-')[0];
|
||
filter.EndTime = filter.Range.Split('-')[1];
|
||
|
||
sql += " AND opr.StartTime <= @EndDate";
|
||
sql += " AND opr.EndTime >= @StartDate";
|
||
}
|
||
|
||
if (filter.WorkType > 0)
|
||
{
|
||
filter.WorkType -= 1;
|
||
sql += @" AND opr.WorkType = @WorkType";
|
||
}
|
||
else
|
||
{
|
||
sql += @" AND opr.WorkType IN (0, 1)";
|
||
sql += @" UNION";
|
||
sql += @$" SELECT
|
||
opr.*,
|
||
ps.Name AS PowerStationName,
|
||
u.Name AS WorkPersonName
|
||
FROM operation_record opr
|
||
LEFT JOIN power_station ps ON opr.PowerStationId = ps.Id
|
||
LEFT JOIN user u ON opr.WorkPersonId = u.ID
|
||
WHERE opr.Deleted = 0 AND opr.Status = {filter.Status}
|
||
AND ps.Id IN @PowerStationIds
|
||
AND opr.WorkType = 2";
|
||
if (!string.IsNullOrEmpty(filter.Range))
|
||
{
|
||
filter.StartTime = filter.Range.Split('-')[0];
|
||
filter.EndTime = filter.Range.Split('-')[1];
|
||
|
||
sql += " AND opr.StartTime <= @EndDate";
|
||
sql += " AND opr.EndTime >= @StartDate";
|
||
}
|
||
else
|
||
{
|
||
var today = DateTime.Now.ToString("yyyy-MM-dd");
|
||
var dateLimit = DateTime.Now.AddDays(-30).ToString("yyyy-MM-dd");
|
||
|
||
sql += $" AND opr.CreatedAt BETWEEN '{dateLimit} 00:00:00' AND '{today} 23:59:59'";
|
||
|
||
//sql += $" AND opr.StartTime <= {today}";
|
||
//sql += $" AND opr.EndTime >= {dateLimit}";
|
||
}
|
||
}
|
||
|
||
sql += " ) aa ORDER BY aa.CreatedAt DESC";
|
||
|
||
result = (await conn.QueryAsync<OperationRecordDataTable>(sql,
|
||
new {
|
||
PowerStationIds = filter.PowerStationIds,
|
||
WorkType = filter.WorkType,
|
||
StartDate = filter.StartTime,
|
||
EndDate = filter.EndTime
|
||
})).ToList();
|
||
|
||
var sql_file = "SELECT * FROM operation_record_file WHERE Deleted = 0 AND RecordId = @RecordId";
|
||
foreach (var x in result)
|
||
{
|
||
x.RecordFiles = (await conn.QueryAsync<OperationRecordFile>(sql_file, new { RecordId = x.Id })).ToList();
|
||
}
|
||
}
|
||
catch (Exception exception)
|
||
{
|
||
throw exception;
|
||
}
|
||
return result;
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 透過Id，取得單一筆運維作業記錄
|
||
/// </summary>
|
||
/// <param name="id"></param>
|
||
/// <returns></returns>
|
||
public async Task<OperationRecord> GetOneOperationRecordAsync(int id)
|
||
{
|
||
OperationRecord result;
|
||
|
||
using (IDbConnection conn = this._databaseHelper.GetConnection())
|
||
{
|
||
conn.Open();
|
||
try
|
||
{
|
||
var sql = @$"SELECT opr.*, ps.Name AS PowerStationName
|
||
FROM operation_record opr
|
||
LEFT JOIN power_station ps ON opr.PowerStationId = ps.Id
|
||
WHERE opr.Deleted = 0 AND opr.Id = @Id";
|
||
|
||
result = await conn.QueryFirstOrDefaultAsync<OperationRecord>(sql, new { Id = id });
|
||
|
||
if (result != null)
|
||
{
|
||
//取得圖片 or 檔案
|
||
var sql_file = @"SELECT * FROM operation_record_file WHERE Deleted = 0 AND RecordId = @RecordId";
|
||
|
||
result.RecordFiles = (await conn.QueryAsync<OperationRecordFile>(sql_file, new { RecordId = result.Id })).ToList();
|
||
|
||
//取得負責人員
|
||
var sql_operation_record_personnel = @"SELECT UserId FROM operation_record_personnel WHERE Deleted = 0 AND OperationRecordId = @OperationRecordId";
|
||
|
||
result.WorkPersonIds = (await conn.QueryAsync<int>(sql_operation_record_personnel, new { OperationRecordId = result.Id })).ToList();
|
||
}
|
||
|
||
|
||
}
|
||
catch (Exception exception)
|
||
{
|
||
throw exception;
|
||
}
|
||
finally
|
||
{
|
||
conn.Close();
|
||
}
|
||
return result;
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 新增一筆運維作業記錄
|
||
/// </summary>
|
||
/// <param name="entity"></param>
|
||
/// <param name="properties"></param>
|
||
/// <returns></returns>
|
||
public async Task<int> AddOneOperationRecordAsync(OperationRecord entity, List<string> properties)
|
||
{
|
||
var id = 0;
|
||
using (IDbConnection conn = _databaseHelper.GetConnection())
|
||
{
|
||
conn.Open();
|
||
using (var trans = conn.BeginTransaction())
|
||
{
|
||
try
|
||
{
|
||
string sql = GenerateInsertQueryWithCustomTable(properties, "operation_record");
|
||
|
||
sql += "SELECT LAST_INSERT_ID();";
|
||
|
||
id = (await conn.QueryAsync<int>(sql, entity, trans)).Single();
|
||
|
||
trans.Commit();
|
||
}
|
||
catch (Exception exception)
|
||
{
|
||
trans.Rollback();
|
||
throw exception;
|
||
}
|
||
finally
|
||
{
|
||
conn.Close();
|
||
}
|
||
}
|
||
|
||
return id;
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 修改運維作業記錄
|
||
/// </summary>
|
||
/// <param name="entity"></param>
|
||
/// <param name="properties"></param>
|
||
/// <param name="db_name"></param>
|
||
/// <returns></returns>
|
||
public async Task UpdateOperationRecordAsync(UpdateOperationRecord entity, List<string> properties)
|
||
{
|
||
using (IDbConnection conn = this._databaseHelper.GetConnection())
|
||
{
|
||
conn.Open();
|
||
using (var trans = conn.BeginTransaction())
|
||
{
|
||
try
|
||
{
|
||
var sql = GenerateUpdateQueryWithCustomTable(properties, "operation_record");
|
||
await conn.ExecuteAsync(sql, entity, trans);
|
||
|
||
trans.Commit();
|
||
}
|
||
catch (Exception exception)
|
||
{
|
||
trans.Rollback();
|
||
throw exception;
|
||
}
|
||
finally
|
||
{
|
||
conn.Close();
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
public async Task DeleteOneOperationRecordAsync(int id)
|
||
{
|
||
using (IDbConnection conn = this._databaseHelper.GetConnection())
|
||
{
|
||
conn.Open();
|
||
using (var trans = conn.BeginTransaction())
|
||
{
|
||
try
|
||
{
|
||
var sql = $"UPDATE operation_record SET deleted = 1 WHERE Id = @Id";
|
||
|
||
await conn.ExecuteAsync(sql, new { Id = id }, trans);
|
||
|
||
trans.Commit();
|
||
}
|
||
catch (Exception exception)
|
||
{
|
||
trans.Rollback();
|
||
throw exception;
|
||
}
|
||
finally
|
||
{
|
||
conn.Close();
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 新增運維作業記錄的檔案
|
||
/// </summary>
|
||
/// <param name="entity"></param>
|
||
/// <param name="properties"></param>
|
||
/// <returns></returns>
|
||
public async Task<int> AddOperationRecordFilesAsync(List<OperationRecordFile> entity, List<string> properties)
|
||
{
|
||
int count;
|
||
using (IDbConnection conn = _databaseHelper.GetConnection())
|
||
{
|
||
conn.Open();
|
||
try
|
||
{
|
||
string sql = GenerateInsertQueryWithCustomTable(properties, "operation_record_file");
|
||
|
||
count = await conn.ExecuteAsync(sql, entity);
|
||
}
|
||
catch (Exception exception)
|
||
{
|
||
throw exception;
|
||
}
|
||
finally
|
||
{
|
||
conn.Close();
|
||
}
|
||
|
||
return count;
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 透過Id，取得單一運維作業記錄檔案
|
||
/// </summary>
|
||
/// <param name="id"></param>
|
||
/// <returns></returns>
|
||
public async Task<OperationRecordFile> GetOneOperationRecordFileAsync(int id)
|
||
{
|
||
OperationRecordFile result;
|
||
|
||
using (IDbConnection conn = this._databaseHelper.GetConnection())
|
||
{
|
||
conn.Open();
|
||
try
|
||
{
|
||
var sql = @$"SELECT *
|
||
FROM operation_record_file
|
||
WHERE Deleted = 0 AND Id = @Id";
|
||
|
||
result = await conn.QueryFirstOrDefaultAsync<OperationRecordFile>(sql, new { Id = id });
|
||
}
|
||
catch (Exception exception)
|
||
{
|
||
throw exception;
|
||
}
|
||
finally
|
||
{
|
||
conn.Close();
|
||
}
|
||
return result;
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 透過Id，軟刪除運維作業記錄檔案
|
||
/// </summary>
|
||
/// <param name="id"></param>
|
||
/// <returns></returns>
|
||
public async Task DeleteOneOperationRecordFile(int id)
|
||
{
|
||
using (IDbConnection conn = this._databaseHelper.GetConnection())
|
||
{
|
||
conn.Open();
|
||
using (var trans = conn.BeginTransaction())
|
||
{
|
||
try
|
||
{
|
||
var sql = $"UPDATE operation_record_file SET deleted = 1 WHERE id = @Id";
|
||
|
||
await conn.ExecuteAsync(sql, new { Id = id }, trans);
|
||
|
||
trans.Commit();
|
||
}
|
||
catch (Exception exception)
|
||
{
|
||
trans.Rollback();
|
||
throw exception;
|
||
}
|
||
finally
|
||
{
|
||
conn.Close();
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
public async Task<List<OperationCreatePlan>> GetOperationSchedules()
|
||
{
|
||
List<OperationCreatePlan> result;
|
||
using (IDbConnection conn = this._databaseHelper.GetConnection())
|
||
{
|
||
try
|
||
{
|
||
var sql = @$"SELECT * FROM operation_plan_create opc
|
||
WHERE opc.Deleted = 0";
|
||
result = (await conn.QueryAsync<OperationCreatePlan>(sql)).ToList();
|
||
}
|
||
catch (Exception exception)
|
||
{
|
||
throw exception;
|
||
}
|
||
return result;
|
||
}
|
||
}
|
||
|
||
|
||
public async Task<List<MyUser>> GetOperationPersonnel(int PowerStationId)
|
||
{
|
||
List<MyUser> result;
|
||
using (IDbConnection conn = this._databaseHelper.GetConnection())
|
||
{
|
||
try
|
||
{
|
||
var sql = @$"SELECT us.* FROM power_station_operation_personnel ps LEFT JOIN user us ON ps.UserId = us.Id WHERE PowerStationId = {PowerStationId}";
|
||
result = (await conn.QueryAsync<MyUser>(sql)).ToList();
|
||
}
|
||
catch (Exception exception)
|
||
{
|
||
throw exception;
|
||
}
|
||
return result;
|
||
}
|
||
}
|
||
|
||
public async Task InsertNoticeSchedule(List<MyUser> personal, string Title, string content)
|
||
{
|
||
using (IDbConnection conn = this._databaseHelper.GetConnection())
|
||
{
|
||
conn.Open();
|
||
using (var trans = conn.BeginTransaction())
|
||
{
|
||
try
|
||
{
|
||
List<string> value = new List<string>() ;
|
||
foreach (MyUser a in personal)
|
||
{
|
||
value.Add($@"(1,'{a.Name}','{a.Email}','{Title}','{content}',{a.Id},3)");
|
||
}
|
||
string values = string.Join(",", value.ToArray());
|
||
|
||
var sql = $"INSERT INTO `notice_schedule` (`Type`, `RecipientName`, `RecipientEmail`, `Subject`, `Content`,`UserId`,`EmailType`) VALUES {values};";
|
||
|
||
await conn.ExecuteAsync(sql,trans);
|
||
|
||
trans.Commit();
|
||
}
|
||
catch (Exception exception)
|
||
{
|
||
trans.Rollback();
|
||
throw exception;
|
||
}
|
||
finally
|
||
{
|
||
conn.Close();
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
public async Task AddOperationRecordPersonnelAsync(List<OperationRecordPersonnel> entity, List<string> properties)
|
||
{
|
||
int count;
|
||
using (IDbConnection conn = _databaseHelper.GetConnection())
|
||
{
|
||
conn.Open();
|
||
try
|
||
{
|
||
string sql = GenerateInsertQueryWithCustomTable(properties, "operation_record_personnel");
|
||
|
||
count = await conn.ExecuteAsync(sql, entity);
|
||
}
|
||
catch (Exception exception)
|
||
{
|
||
throw exception;
|
||
}
|
||
finally
|
||
{
|
||
conn.Close();
|
||
}
|
||
|
||
//return count;
|
||
}
|
||
}
|
||
|
||
public async Task<List<int>> GetOperationRecordPersonnelIdsByOperationRecordId(int operationRecordId)
|
||
{
|
||
List<int> result;
|
||
using (IDbConnection conn = this._databaseHelper.GetConnection())
|
||
{
|
||
conn.Open();
|
||
try
|
||
{
|
||
var sql = @$"SELECT UserId FROM operation_record_personnel WHERE Deleted = 0 AND OperationRecordId = @OperationRecordId";
|
||
|
||
result = (await conn.QueryAsync<int>(sql, new { OperationRecordId = operationRecordId })).ToList();
|
||
}
|
||
catch (Exception exception)
|
||
{
|
||
throw exception;
|
||
}
|
||
finally
|
||
{
|
||
conn.Close();
|
||
}
|
||
return result;
|
||
}
|
||
}
|
||
|
||
public async Task DeleteOperationRecordPersonnel(List<OperationRecordPersonnel> operationPersonnels)
|
||
{
|
||
using (IDbConnection conn = this._databaseHelper.GetConnection())
|
||
{
|
||
conn.Open();
|
||
using (var trans = conn.BeginTransaction())
|
||
{
|
||
try
|
||
{
|
||
var sql = $"UPDATE operation_record_personnel SET Deleted = 1 WHERE OperationRecordId = @OperationRecordId AND UserId = @UserId";
|
||
|
||
await conn.ExecuteAsync(sql, operationPersonnels, trans);
|
||
|
||
trans.Commit();
|
||
}
|
||
catch (Exception exception)
|
||
{
|
||
trans.Rollback();
|
||
throw exception;
|
||
}
|
||
finally
|
||
{
|
||
conn.Close();
|
||
}
|
||
}
|
||
}
|
||
}
|
||
}
|
||
}
|