FIC_Solar/SolarPower/Controllers/UserController.cs

748 lines
26 KiB
C#

using Dapper;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.Logging;
using SolarPower.Models;
using SolarPower.Models.PowerStation;
using SolarPower.Models.User;
using SolarPower.Repository.Interface;
using SolarPower.Services.Interface;
using System;
using System.Collections.Generic;
using System.Data;
using System.Data.SqlClient;
using System.IO;
using System.Linq;
using System.Threading.Tasks;
namespace SolarPower.Controllers
{
public class UserController : MyBaseController<UserController>
{
private readonly IUserRepository userRepository;
private readonly ISendEmailService sendEmailService;
private readonly IPowerStationRepository powerStationRepository;
private readonly IRoleRepository roleRepository;
private string logoPath = "/upload/company_logo/";
private string logoSaveAsPath = "";
private string defPasswd = "000000";
public UserController(IUserRepository userRepository,
ISendEmailService sendEmailService,
IPowerStationRepository powerStationRepository,
IRoleRepository roleRepository) : base()
{
this.userRepository = userRepository;
this.sendEmailService = sendEmailService;
this.powerStationRepository = powerStationRepository;
this.roleRepository = roleRepository;
logoSaveAsPath = Path.Combine(Directory.GetCurrentDirectory(), "wwwroot", "upload", "company_logo");
}
public IActionResult Index()
{
return View();
}
/// <summary>
/// 取得個人資訊
/// </summary>
/// <returns></returns>
[HttpPost]
public async Task<ApiResult<User>> GetPersonalInfo()
{
ApiResult<User> apiResult = new ApiResult<User>();
try
{
var user = await userRepository.GetOneAsync(myUser.Id);
apiResult.Code = "0000";
apiResult.Data = user;
}
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>
[HttpPost]
public async Task<ApiResult<string>> SavePersonalInfoAsync(PostPersonalInfo post)
{
ApiResult<string> apiResult = new ApiResult<string>();
User user = null;
try
{
user = await userRepository.GetOneAsync(myUser.Id);
if (user == null)
{
apiResult.Code = "9998";
apiResult.Msg = errorCode.GetString(apiResult.Code);
return apiResult;
}
UpdateUser update = new UpdateUser()
{
Name = post.Name,
Email = post.Email,
Phone = post.Phone,
UpdatedBy = myUser.Id,
Id = user.Id
};
List<string> properties = new List<string>()
{
"Name",
"Email",
"Phone",
"UpdatedBy",
"Id"
};
await userRepository.UpdatePersonInfo(update, properties);
apiResult.Code = "0000";
apiResult.Msg = "修改成功";
}
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);
}
return apiResult;
}
/// <summary>
/// 變更密碼
/// </summary>
/// <param name="post"></param>
/// <returns></returns>
[HttpPost]
public async Task<ApiResult<string>> ChangePasswordAsync(PostChangePassword post)
{
ApiResult<string> apiResult = new ApiResult<string>();
User user = null;
try
{
user = await userRepository.GetOneAsync(myUser.Id);
if (user == null)
{
apiResult.Code = "9998";
apiResult.Msg = errorCode.GetString(apiResult.Code);
return apiResult;
}
EDFunction edFunction = new EDFunction();
if (string.Compare(user.Password, edFunction.GetSHA256Encryption(post.OldPassword)) != 0)
{
apiResult.Code = "0001";
apiResult.Msg = "密碼錯誤,請重新輸入。";
return apiResult;
}
if (string.Compare(post.NewPassword, post.AgainPassword) != 0)
{
apiResult.Code = "0001";
apiResult.Msg = "新密碼輸入不一致,請重新輸入。";
return apiResult;
}
UpdatePassword update = new UpdatePassword()
{
Password = edFunction.GetSHA256Encryption(post.NewPassword),
UpdatedBy = myUser.Id,
Id = user.Id
};
List<string> properties = new List<string>()
{
"Password",
"UpdatedBy",
"Id"
};
await userRepository.UpdatePassword(update, properties);
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 + "】");
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
/// <summary>
/// 帳號管理列表
/// </summary>
/// <param name="post"></param>
/// <returns></returns>
[HttpPost]
public async Task<ActionResult> UserListAsync(PostUserFilter post)
{
ApiResult<List<UserDateTable>> apiResult = new ApiResult<List<UserDateTable>>();
int totalRecords = 0; //總資料筆數
int recFilter = 0; //過濾後資料筆數
List<UserDateTable> users = null;
try
{
users = await userRepository.GetAllByFilterAsync(post);
totalRecords = users.Count();
recFilter = users.Count();
apiResult.Code = "0000";
apiResult.Data = users;
}
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="guid"></param>
/// <returns></returns>
[HttpPost]
public async Task<ApiResult<SimpleUser>> GetOneUser(int id)
{
ApiResult<SimpleUser> apiResult = new ApiResult<SimpleUser>();
SimpleUser simpleUser = null;
try
{
simpleUser = await userRepository.GetOneSimpleUser(id);
if (simpleUser == null)
{
apiResult.Code = "9998";
apiResult.Msg = errorCode.GetString(apiResult.Code);
return apiResult;
}
apiResult.Code = "0000";
apiResult.Data = simpleUser;
}
catch (Exception exception)
{
apiResult.Code = "9999";
Logger.LogError("【" + controllerName + "/" + actionName + "】" + "Id=" + id);
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
apiResult.Msg = errorCode.GetString(apiResult.Code);
return apiResult;
}
/// <summary>
/// 新增 / 修改 使用者
/// </summary>
/// <param name="post"></param>
/// <returns></returns>
[HttpPost]
public async Task<ApiResult<string>> SaveUser(PostUser post)
{
ApiResult<string> apiResult = new ApiResult<string>();
User user = null;
try
{
user = await userRepository.GetOneAsync(post.Id);
if (user == null)
{
if (post.Id != 0)
{
apiResult.Code = "9998";
apiResult.Msg = errorCode.GetString(apiResult.Code);
return apiResult;
}
#region 使
//判斷帳號 是否已存在
var exist = await userRepository.GetOneByAccountAsync(post.Account);
if (exist != null)
{
apiResult.Code = "9986";
apiResult.Msg = errorCode.GetString(apiResult.Code);
return apiResult;
}
EDFunction edFunction = new EDFunction();
//隨機產生亂數密碼
Random random = new Random((int)DateTime.Now.Ticks);
const string chars = "ABCDEFGHJKLMNPQRSTUVWXYZabcdefghjkmnpqrstuvwxyz23456789";
string random_password = new string(Enumerable.Repeat(chars, 8).Select(s => s[random.Next(chars.Length)]).ToArray());
var newPassword = edFunction.GetSHA256Encryption(random_password);
user = new User()
{
CompanyId = post.CompanyId,
Name = post.Name,
Email = post.Email,
Account = post.Account,
Password = newPassword,
RoleId = post.RoleId,
Phone = post.Phone,
CreatedBy = myUser.Id,
};
List<string> properties = new List<string>()
{
"CompanyId",
"Name",
"Email",
"Account",
"Password",
"RoleId",
"Phone",
"CreatedBy",
};
var id = await userRepository.AddOneAsync(user, properties);
#region Logo圖片
if (post.LogoFile != null)
{
var split = post.LogoFile.FileName.Split(".");
var fileName = "user_" + id + "." + split[split.Length - 1];
var fullPath = Path.Combine(logoSaveAsPath, fileName);
using (var stream = new FileStream(fullPath, FileMode.Create))
{
post.LogoFile.CopyTo(stream);
}
UpdateUser updateUser = new UpdateUser()
{
Id = id,
Logo = fileName
};
properties = new List<string>()
{
"Id",
"Logo"
};
await userRepository.UpdatePersonInfo(updateUser, properties);
}
#endregion
var website_url = await powerStationRepository.GetOneVariableByName("WebSiteUrl");
var sendSubject = "新增帳號成功";
var sendContent = $@"您的新密碼為:{random_password}
<br>立即前往:<a href='{website_url}' target='_blank'>{website_url}</a>";
List<string> recipientEmails = new List<string>()
{
user.Email
};
sendEmailService.Send(recipientEmails, sendSubject, sendContent);
apiResult.Code = "0000";
apiResult.Msg = "儲存成功";
#endregion
}
else
{
#region 使
UpdateUser update = new UpdateUser()
{
Id = user.Id,
Name = post.Name,
Email = post.Email,
Phone = post.Phone,
RoleId = post.RoleId,
UpdatedBy = myUser.Id,
};
List<string> properties = new List<string>()
{
"Id",
"Name",
"Email",
"Phone",
"RoleId",
"UpdatedBy",
};
await userRepository.UpdatePersonInfo(update, properties);
#region Logo圖片
if (post.LogoFile != null)
{
var split = post.LogoFile.FileName.Split(".");
var fileName = "user_" + user.Id + "." + split[split.Length - 1];
var fullPath = Path.Combine(logoSaveAsPath, fileName);
using (var stream = new FileStream(fullPath, FileMode.Create))
{
post.LogoFile.CopyTo(stream);
}
UpdateUser updateUser = new UpdateUser()
{
Id = user.Id,
Logo = fileName
};
properties = new List<string>()
{
"Id",
"Logo"
};
await userRepository.UpdatePersonInfo(updateUser, properties);
}
#endregion
apiResult.Code = "0000";
apiResult.Msg = "儲存成功";
#endregion
}
}
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;
}
/// <summary>
/// 軟刪除單一使用者
/// </summary>
/// <param name="id"></param>
/// <returns></returns>
[HttpPost]
public async Task<ApiResult<string>> DeleteOneUser(int id)
{
ApiResult<string> apiResult = new ApiResult<string>();
SimpleUser user = null;
try
{
user = await userRepository.GetOneSimpleUser(id);
if (user == null)
{
apiResult.Code = "9998";
apiResult.Msg = errorCode.GetString(apiResult.Code);
return apiResult;
}
await userRepository.DeleteOne(user.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;
}
[HttpPost]
public async Task<ApiResult<List<UserPowerStation>>> GetUserPowerStation(int id)
{
ApiResult<List<UserPowerStation>> apiResult = new ApiResult<List<UserPowerStation>>();
List<UserPowerStation> userPowerStations = null;
try
{
userPowerStations = await userRepository.GetUserPowerStationAsync(id);
if (userPowerStations == null)
{
apiResult.Code = "9988";
apiResult.Msg = errorCode.GetString(apiResult.Code);
return apiResult;
}
apiResult.Code = "0000";
apiResult.Data = userPowerStations;
}
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;
}
[HttpPost]
public async Task<ApiResult<string>> DeleteOneUserPowerStation(int id)
{
ApiResult<string> apiResult = new ApiResult<string>();
try
{
var userPowerStation = userRepository.GetOneUserPowerStationAsync(id);
if (userPowerStation == null)
{
apiResult.Code = "9988";
apiResult.Msg = errorCode.GetString(apiResult.Code);
return apiResult;
}
await userRepository.DeleteOneUserPowerStationAsync(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;
}
[HttpPost]
public async Task<ApiResult<List<UserPowerStation>>> GetUserCompanyPowerStation(int id)
{
ApiResult<List<UserPowerStation>> apiResult = new ApiResult<List<UserPowerStation>>();
SimpleUser user = null;
try
{
user = await userRepository.GetOneSimpleUser(id);
if (user == null)
{
apiResult.Code = "9998";
apiResult.Msg = errorCode.GetString(apiResult.Code);
return apiResult;
}
var role = await roleRepository.GetOneAsync(user.RoleId);
var companyPowerStation = await userRepository.GetCompanyPowerStationAsync(user.CompanyId, user.Id, IsPlatformLayer(role.Layer));
apiResult.Code = "0000";
apiResult.Data = companyPowerStation;
}
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;
}
[HttpPost]
public async Task<ApiResult<string>> SaveUserPowerStation(PostUserPowerStation post)
{
ApiResult<string> apiResult = new ApiResult<string>();
SimpleUser user = null;
try
{
user = await userRepository.GetOneSimpleUser(post.UserId);
if (user == null)
{
apiResult.Code = "9998";
apiResult.Msg = errorCode.GetString(apiResult.Code);
return apiResult;
}
if (!IsPlatformLayer(myUser.Role.Layer))
{ //如果身分為公司管理員 或 公司使用者,就只能改自己公司的資料
if (user.CompanyId != myUser.CompanyId)
{
apiResult.Code = "9993";
apiResult.Msg = errorCode.GetString(apiResult.Code);
return apiResult;
}
}
List<PowerStationOperationPersonnel> insertOperationPersonnels = new List<PowerStationOperationPersonnel>();
PowerStationOperationPersonnel operationPersonnel = new PowerStationOperationPersonnel();
operationPersonnel.PowerStationId = post.PowerStationId;
operationPersonnel.UserId = post.UserId;
operationPersonnel.CreatedBy = myUser.Id;
insertOperationPersonnels.Add(operationPersonnel);
List<string> operationPersonnelProperties = new List<string>()
{
"PowerStationId",
"UserId",
"CreatedBy",
};
await powerStationRepository.AddOperationPersonnelAsync(insertOperationPersonnels, operationPersonnelProperties);
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;
}
[HttpPost]
public async Task<ApiResult<string>> DeleteOneGetEmail(IdAndTypeByEmail post)
{
ApiResult<string> apiResult = new ApiResult<string>();
try
{
await userRepository.DeleteOneGetEmail(post);
apiResult.Code = "0000";
apiResult.Msg = "更改成功";
}
catch (Exception exception)
{
apiResult.Code = "9999";
apiResult.Msg = errorCode.GetString(apiResult.Code);
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
[HttpPost]
public async Task<ApiResult<string>> DefaultPassword(PostUser post)
{
User user = null;
ApiResult<string> apiResult = new ApiResult<string>();
user = await userRepository.GetOneAsync(post.Id);
if(user != null)
{
EDFunction edFunction = new EDFunction();
var newPassword = edFunction.GetSHA256Encryption(defPasswd);
UpdatePassword update = new UpdatePassword()
{
Password = newPassword,
UpdatedBy = myUser.Id,
Id = user.Id
};
List<string> properties = new List<string>()
{
"Password",
"UpdatedBy",
"Id"
};
await userRepository.UpdatePassword(update, properties);
//var website_url = await powerStationRepository.GetOneVariableByName("WebSiteUrl");
//var sendSubject = "密碼更改成功";
//var sendContent = $@"您的新密碼為: { defPasswd}
// <br>立即前往:<a href='{website_url}' target='_blank'>{website_url}</a>";
//List<string> recipientEmails = new List<string>()
//{
// user.Email
//};
//sendEmailService.Send(recipientEmails, sendSubject, sendContent);
apiResult.Code = "0000";
apiResult.Msg = "密碼重置成功為六個零!";
}
else
{
apiResult.Code = "9999";
apiResult.Msg = "使用者不存在";
}
return apiResult;
}
}
}