using FangYar.Model.TBL;
using MySql.Data.MySqlClient;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace FangYar.OracleDAL.TBL
{
    public class DiaySignDAL : FangYar.IDAL.TBL.DiaySignIDAL
    {

        /// <summary>
        /// DataRow转model实体类对象
        /// </summary>
        /// <param name="dr"></param>
        /// <returns></returns>
        private void DataRowToModel(TBL_DIAY_SIGN model, DataRow dr)
        {
            model.USERS_UID = dr["USERS_UID"] + "";
            model.createtime = dr["createtime"] + "";
            model.EMP_NAME = dr["EMP_NAME"] + "";
            int.TryParse(dr["USERS_UID"] + "", out int idNum);
            model.ID = idNum;
            model.ORG_ID = dr["ORG_ID"] + "";
            model.SIGN_DATE = dr["SIGN_DATE"] + "";


            if (dr["SIGN_IMG"] != null && dr["SIGN_IMG"].ToString() != "")
            {
                model.SIGN_IMG = (byte[])dr["SIGN_IMG"];
            }

            model.updatetime = dr["updatetime"] + "";

        }

        /// <summary>
        /// 查询信息集合
        /// </summary>
        /// <param name="dto">查询数据信息模型</param>
        /// <returns></returns>
        public List<TBL_DIAY_SIGN> Queyr(TBL_DIAY_SIGN dto)
        {
            if (dto == null)
            {
                return new List<TBL_DIAY_SIGN>();
            }

            Model.TBL.TBL_DIAY_SIGN model = null;
            string sql = "select * from tbl_diay_sign where 1=1 ";
            List<MySqlParameter> paraList = new List<MySqlParameter>();

            //用户姓名查询条件
            if (!string.IsNullOrWhiteSpace(dto.EMP_NAME))
            {
                sql += " and  EMP_NAME= @EMP_NAME ";
                paraList.Add(new MySqlParameter("@EMP_NAME", dto.EMP_NAME));
            }

            //信息ID查询条件
            if (dto.ID > 0)
            {
                sql += " and  ID= @ID ";
                paraList.Add(new MySqlParameter("@ID", dto.ID));
            }

            //组织机构查询条件
            if (!string.IsNullOrWhiteSpace(dto.ORG_ID))
            {
                sql += " and  ORG_ID= @ORG_ID ";
                paraList.Add(new MySqlParameter("@ORG_ID", dto.ORG_ID));
            }

            //签名文件日期查询条件
            if (!string.IsNullOrWhiteSpace(dto.SIGN_DATE))
            {
                sql += " and  SIGN_DATE= @SIGN_DATE ";
                paraList.Add(new MySqlParameter("@SIGN_DATE", dto.SIGN_DATE));
            }

            //签名用户登录账号查询条件
            if (!string.IsNullOrWhiteSpace(dto.USERS_UID))
            {
                sql += " and  USERS_UID= @USERS_UID ";
                paraList.Add(new MySqlParameter("@USERS_UID", dto.USERS_UID));
            }

            MySqlParameter[] paras = paraList.ToArray();
            DataTable dt = FangYar.Common.MySqlHelper.QueryTable(sql, paras);

            List<TBL_DIAY_SIGN> retList = new List<TBL_DIAY_SIGN>();
            for (int i = 0; i < dt.Rows.Count; i++)
            {
                model = new Model.TBL.TBL_DIAY_SIGN();
                DataRowToModel(model, dt.Rows[i]);
                retList.Add(model);
            }
            return retList;

        }
        /// <summary>
        /// 查询单个数据模型
        /// </summary>
        /// <param name="dto">查询数据信息模型</param>
        /// <returns></returns>
        public TBL_DIAY_SIGN QueyrObj(TBL_DIAY_SIGN dto)
        {
            return Queyr(dto).FirstOrDefault();
        }
        /// <summary>
        /// 保存信息
        /// </summary>
        /// <param name="model">保存数据信息对象</param>
        /// <returns></returns>
        public bool SaveDB(TBL_DIAY_SIGN model)
        {
            try
            {
                string sqlStr = "";
                List<MySqlParameter> paraList = new List<MySqlParameter>();
                var list = Queyr(model);
                if (list.Count > 0)
                {
                    sqlStr = " update tbl_diay_sign set SIGN_IMG=@SIGN_IMG,EMP_NAME=@EMP_NAME,USERS_UID=@USERS_UID,updatetime=now() " +
                        " where ORG_ID=@ORG_ID and SIGN_DATE=@SIGN_DATE  ";
                    paraList.Add(new MySqlParameter("@USERS_UID", model.USERS_UID));
                    paraList.Add(new MySqlParameter("@EMP_NAME", model.EMP_NAME));
                    paraList.Add(new MySqlParameter("@ORG_ID", model.ORG_ID));
                    paraList.Add(new MySqlParameter("@SIGN_DATE", model.SIGN_DATE));
                    paraList.Add(new MySqlParameter("@SIGN_IMG", model.SIGN_IMG));
                }
                else
                {
                    sqlStr = " insert into tbl_diay_sign (USERS_UID,EMP_NAME,ORG_ID,SIGN_DATE,SIGN_IMG,createtime,updatetime) " +
                        " values (@USERS_UID,@EMP_NAME,@ORG_ID,@SIGN_DATE,@SIGN_IMG,now(),now()) ";
                    paraList.Add(new MySqlParameter("@USERS_UID", model.USERS_UID));
                    paraList.Add(new MySqlParameter("@EMP_NAME", model.EMP_NAME));
                    paraList.Add(new MySqlParameter("@ORG_ID", model.ORG_ID));
                    paraList.Add(new MySqlParameter("@SIGN_DATE", model.SIGN_DATE));
                    paraList.Add(new MySqlParameter("@SIGN_IMG", model.SIGN_IMG));
                }
                MySqlParameter[] paras = paraList.ToArray();
                int i = FangYar.Common.MySqlHelper.ExecuteSql(sqlStr, paras);
                if (i > 0) { return true; }
                else { return false; }
            }
            catch (Exception ex)
            {

            }

            return false;
        }
    }
}