using Hanhe.iWCS.Common;
using HH.AMS.Entitys.AdminUI.Device;
using HH.AMS.Ex.Factroy;
using HH.AMS.Ex.Interface;
using Dapper;
using DapperExtensions;
using DapperExtensions.SqlServerExt;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace HH.AMS.Ex.MSSQLServices
{
    public class AlarmServices : IAlarmInterface
    {
        /// <summary>
        /// 获取分页数据
        /// </summary>
        /// <param name="strWhere"></param>
        /// <returns></returns>
        public List<TN_AM_ALARMEntity> GetList(int pageIndex, int pageSize, string strWhere, string orderBy, out long total, out long totalPage)
        {
            List<TN_AM_ALARMEntity> list = new List<TN_AM_ALARMEntity>();
            try
            {
                using (var dapper = Connections.Instance.GetConnection(DBConnetctionString.GetDBConnetctionString))
                {
                    int iTotal = 0;
                    list = dapper.GetByPage<TN_AM_ALARMEntity>(pageIndex, pageSize, out iTotal, null, strWhere, null, orderBy, null, null).ToList();
                    total = (long)iTotal;
                    if (total <= pageSize)
                        totalPage = 1;
                    else if (total % pageSize > 0)
                        totalPage = (long)Math.Floor(Convert.ToDouble((total / pageSize))) + 1;
                    else
                        totalPage = (long)(Math.Floor(Convert.ToDouble(total / pageSize)));
                    return list;
                }
            }
            catch (Exception ex)
            {
                total = 0;
                totalPage = 0;
                CMMLog.Error("SQL Script ---errMsg=" + ex.ToString());
                return new List<TN_AM_ALARMEntity>();
            }
        }

        /// <summary>
        /// 根据GUID获取数据
        /// </summary>
        /// <param name="guid"></param>
        /// <returns></returns>
        public TN_AM_ALARMEntity GetAlarmData(string guid)
        {
            TN_AM_ALARMEntity entity = null;
            try
            {
                using (var dapper = Connections.Instance.GetConnection(DBConnetctionString.GetDBConnetctionString))
                {
                    entity = dapper.GetByWhereFirst<TN_AM_ALARMEntity>(" CN_S_GUID='" + guid + "'");
                    return entity;
                }
            }
            catch (Exception ex)
            {
                CMMLog.Error("SQL Script ---errMsg=" + ex.ToString());
                return entity;
            }
        }

        /// <summary>
        /// 保存警报处理
        /// </summary>
        /// <param name="entity"></param>
        /// <returns></returns>
        public bool SaveData(TN_AM_ALARMEntity entity)
        {
            bool bResult = false;
            using (var dapper = Connections.Instance.GetConnection(DBConnetctionString.GetDBConnetctionString))
            {
                TN_AM_ALARMEntity model = dapper.GetByWhereFirst<TN_AM_ALARMEntity>(" CN_S_GUID='" + entity.CN_S_GUID + "'");
                entity.CN_S_IS_FINISH = entity.CN_S_IS_FINISH.Equals("checked") ? "Y" : "N";
                entity.CN_S_HANDLE_REMARKS = entity.CN_S_HANDLE_REMARKS;
                entity.CN_T_MODIFY = entity.CN_T_MODIFY;
                entity.CN_S_MODIFY_NAME = entity.CN_S_MODIFY_NAME;
                entity.CN_S_HANDLE_TIME = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");
                int row = dapper.UpdateByWhere<TN_AM_ALARMEntity>(" CN_S_GUID='" + entity.CN_S_GUID + "'", "CN_S_IS_FINISH,CN_S_HANDLE_REMARKS,CN_T_MODIFY,CN_S_MODIFY_NAME,CN_S_HANDLE_TIME", model);
                bResult = row > 0;
            }
            return bResult;
        }
    }
}