FIC_Solar/SolarPower/Repository/Implement/PowerStationRepository.cs

using Dapper;
using SolarPower.Helper;
using SolarPower.Models.PowerStation;
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 PowerStationRepository : RepositoryBase<PowerStation>, IPowerStationRepository
    {
        public PowerStationRepository(IDatabaseHelper databaseHelper) : base(databaseHelper)
        {
            tableName = "power_station";
        }

        /// <summary>
        /// 查詢縣市列表
        /// </summary>
        /// <returns></returns>
        public async Task<List<CitySelectItemList>> GetCitySelectOptionListAsync()
        {
            List<CitySelectItemList> result;
            using (IDbConnection conn = this._databaseHelper.GetConnection())
            {
                try
                {
                    var sql = $"SELECT Id AS Value, Name AS Text FROM city";
                    
                    result = (await conn.QueryAsync<CitySelectItemList>(sql)).ToList();
                }
                catch (Exception exception)
                {
                    throw exception;
                }
                return result;
            }
        }

        /// <summary>
        /// 查詢縣市列表
        /// </summary>
        /// <param name="cityId"></param>
        /// <returns></returns>
        public async Task<List<AreaSelectItemList>> GetAreaSelectOptionListAsync(int cityId)
        {
            List<AreaSelectItemList> result;
            using (IDbConnection conn = this._databaseHelper.GetConnection())
            {
                try
                {
                    var sql = $"SELECT Id AS Value, Name AS Text FROM Area WHERE CityId = @CityId";

                    result = (await conn.QueryAsync<AreaSelectItemList>(sql, new { CityId = cityId })).ToList();
                }
                catch (Exception exception)
                {
                    throw exception;
                }
                return result;
            }
        }

        /// <summary>
        /// 透過編號取得，縣市資訊
        /// </summary>
        /// <param name="cityId"></param>
        /// <returns></returns>
        public async Task<City> GetOneCityByIdAsync(int cityId)
        {
            City result;
            using (IDbConnection conn = this._databaseHelper.GetConnection())
            {
                try
                {
                    var sql = @$"SELECT * FROM city WHERE Id=@Id";

                    result = await conn.QueryFirstOrDefaultAsync<City>(sql, new { Id = cityId });
                }
                catch (Exception exception)
                {
                    throw exception;
                }
                return result;
            }
        }

        /// <summary>
        /// 透過編號取得，地區資訊
        /// </summary>
        /// <param name="areaId"></param>
        /// <returns></returns>
        public async Task<Area> GetOneAreaByIdAsync(int areaId)
        {
            Area result;
            using (IDbConnection conn = this._databaseHelper.GetConnection())
            {
                try
                {
                    var sql = @$"SELECT * FROM area WHERE Id=@Id";

                    result = await conn.QueryFirstOrDefaultAsync<Area>(sql, new { Id = areaId });
                }
                catch (Exception exception)
                {
                    throw exception;
                }
                return result;
            }
        }

        /// <summary>
        /// 取得縣市地區代碼
        /// </summary>
        /// <param name="areaId"></param>
        /// <returns></returns>
        public async Task<Zipcode> GetCityAreaZipcodeAsync(int areaId)
        {
            Zipcode result;
            using (IDbConnection conn = this._databaseHelper.GetConnection())
            {
                try
                {
                    var sql = @$"SELECT a.ZipCode AS Area, c.ZipCode AS City FROM area a
                                    LEFT JOIN city c ON a.cityId = c.Id
                                    WHERE a.Id = @AreaId";

                    result = await conn.QueryFirstOrDefaultAsync<Zipcode>(sql, new { AreaId = areaId });
                }
                catch (Exception exception)
                {
                    throw exception;
                }
                return result;
            }
        }

        /// <summary>
        /// 透過縣市地區編號，取得該縣市地區最後的流水號
        /// </summary>
        /// <param name="cityId"></param>
        /// <param name="areaId"></param>
        /// <returns></returns>
        public async Task<string> GetLastSerialNumberByCityAreaIdAsync(int cityId, int areaId)
        {
            string result;
            using (IDbConnection conn = this._databaseHelper.GetConnection())
            {
                try
                {
                    var sql = @$"SELECT SerialNumber FROM {tableName}
                                    WHERE CityId = @CityId && AreaId = @AreaId ORDER BY SerialNumber DESC";

                    result = await conn.QueryFirstOrDefaultAsync<string>(sql, new { CityId = cityId, AreaId = areaId });
                }
                catch (Exception exception)
                {
                    throw exception;
                }
                return result;
            }
        }


        /// <summary>
        /// 透過電站編號，取得單一電站資訊(覆寫)
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        public override async Task<PowerStation> GetOneAsync(int id)
        {
            //base.GetOneAsync(id);

            PowerStation result;
            using (IDbConnection conn = this._databaseHelper.GetConnection())
            {
                conn.Open();
                try
                {
                    var sql = @$"SELECT ps.*, u.Name AS CreatorName FROM {tableName} ps
                                LEFT JOIN user u ON ps.CreatedBy = u.Id
                                WHERE ps.Deleted = 0 AND ps.Id = @Id";

                    result = await conn.QueryFirstOrDefaultAsync<PowerStation>(sql, new { Id = id});

                    if(result!= null)
                    {
                        var sql_land_building = @$"SELECT lb.*, u.Name AS CreatorName FROM land_building lb
                                                    LEFT JOIN user u ON lb.CreatedBy = u.Id
                                                    WHERE lb.Deleted = 0 AND PowerStationId = @PowerStationId";
                        result.LandBuildings = (await conn.QueryAsync<LandBuilding>(sql_land_building, new { PowerStationId = result.Id })).ToList();
                    }
                }
                catch (Exception exception)
                {
                    throw exception;
                }
                finally
                {
                    conn.Close();
                }
                return result;
            }
        }

        /// <summary>
        /// 修改電站基本資訊
        /// </summary>
        /// <param name="entity"></param>
        /// <returns></returns>
        public async Task UpdatePowerStationInfo(UpdatePowerStationInfo entity, List<string> properties)
        {

            using (IDbConnection conn = this._databaseHelper.GetConnection())
            {
                conn.Open();
                using (var trans = conn.BeginTransaction())
                {
                    try
                    {
                        var sql = GenerateUpdateQuery(properties);

                        await conn.ExecuteAsync(sql, entity, trans);

                        trans.Commit();
                    }
                    catch (Exception exception)
                    {
                        trans.Rollback();
                        throw exception;
                    }
                    finally
                    {
                        conn.Close();
                    }
                }
            }
        }

        /// <summary>
        /// 修改能源局與台電資訊
        /// </summary>
        /// <param name="entity"></param>
        /// <returns></returns>
        public async Task UpdateBoETPCInfo(UpdateBoETPCInfo entity, List<string> properties)
        {

            using (IDbConnection conn = this._databaseHelper.GetConnection())
            {
                conn.Open();
                using (var trans = conn.BeginTransaction())
                {
                    try
                    {
                        var sql = GenerateUpdateQuery(properties);

                        await conn.ExecuteAsync(sql, entity, trans);

                        trans.Commit();
                    }
                    catch (Exception exception)
                    {
                        trans.Rollback();
                        throw exception;
                    }
                    finally
                    {
                        conn.Close();
                    }
                }
            }
        }

        /// <summary>
        /// 新增 土地房屋資訊
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        public async Task<LandBuilding> GetOneLandBuildingInfo(int id)
        {
            LandBuilding result;
            using (IDbConnection conn = _databaseHelper.GetConnection())
            {
                conn.Open();
                try
                {
                    var sql = @"SELECT * FROM land_building WHERE Deleted =0 AND Id = @Id";

                    result = await conn.QueryFirstOrDefaultAsync<LandBuilding>(sql, new { Id = id });
                }
                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> AddOneLandBuildingInfo(LandBuilding entity, List<string> properties)
        {
            int id;
            using (IDbConnection conn = _databaseHelper.GetConnection())
            {
                conn.Open();
                try
                {
                    string sql = GenerateInsertQueryWithCustomTable(properties, "land_building");

                    sql += "SELECT LAST_INSERT_ID();";

                    id = (await conn.QueryAsync<int>(sql, entity)).Single();
                }
                catch (Exception exception)
                {
                    throw exception;
                }
                finally
                {
                    conn.Close();
                }

                return id;
            }
        }

        /// <summary>
        /// 更新 土地房屋資訊
        /// </summary>
        /// <param name="entity"></param>
        /// <param name="properties"></param>
        /// <returns></returns>
        public async Task UpdateLandBuildingInfo(UpdateLandBuilding entity, List<string> properties)
        {
            using (IDbConnection conn = this._databaseHelper.GetConnection())
            {
                conn.Open();
                using (var trans = conn.BeginTransaction())
                {
                    try
                    {
                        var sql = GenerateUpdateQueryWithCustomTable(properties, "land_building");

                        await conn.ExecuteAsync(sql, entity, trans);

                        trans.Commit();
                    }
                    catch (Exception exception)
                    {
                        trans.Rollback();
                        throw exception;
                    }
                    finally
                    {
                        conn.Close();
                    }
                }
            }
        }

        /// <summary>
        /// 軟刪除土地房屋資訊
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        public async Task DeleteOneLandBuildingInfo(int id)
        {
            using (IDbConnection conn = this._databaseHelper.GetConnection())
            {
                conn.Open();
                using (var trans = conn.BeginTransaction())
                {
                    try
                    {
                        var sql = $"UPDATE land_building 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();
                    }
                }
            }
        }
    }
}