lossdal.cs

c#三层架构项目开发的全过程

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using Model;
using System.Data;
using System.Data.SqlClient;

namespace DAL.Loss
{
    public class lossDal
    {
        #region 添加损益单据      
        /// <summary>
        /// 添加损益单据
        /// </summary>
        /// <param name="loss_id">损益单据编号</param>
        /// <param name="loss_name_id">损益填单人编号</param>
        /// <param name="loss_time">损益单填写时间</param>
        /// <param name="loss_shop_id">损益店铺</param>
        /// <param name="loss_advice">损益说明</param>
        /// <param name="loss_state">损益审核状态</param>
        /// <returns>返回填写损益单据影响的行数</returns>
        public int AddLoss(string loss_id, string loss_name_id, DateTime loss_time, int loss_shop_id, string loss_advice, string loss_state)
        {
            string commandtext = "loss_Add";
            SqlParameter id = new SqlParameter("@loss_id", SqlDbType.Char, 20);
            SqlParameter askid = new SqlParameter("@loss_name_id", SqlDbType.Char, 20);
            SqlParameter time = new SqlParameter("@loss_time", SqlDbType.DateTime);
            SqlParameter shopid = new SqlParameter("@loss_shop_id", SqlDbType.Int);
            SqlParameter advice = new SqlParameter("@loss_advice", SqlDbType.VarChar, 10);
            SqlParameter state = new SqlParameter("@loss_state", SqlDbType.VarChar, 10);
            id.Value = loss_id.Trim ();
            askid.Value = loss_name_id.Trim();
            time.Value = loss_time;
            shopid.Value = loss_shop_id;
            advice.Value = loss_advice;
            state.Value = loss_state;
            return SqlHelper.ExecuteNonQuery(SqlHelper.conStr, CommandType.StoredProcedure, commandtext, new SqlParameter[] { id, askid, time, shopid, advice, state });
        }
        #endregion

        #region 查询未通过审核的损益单据
        /// <summary>
       /// 查询未通过审核的损益单据
       /// </summary>
       /// <param name="loss_status">损益审核状态</param>
       /// <returns></returns>
        public List<Model.Loss.lossModel> LossSelectByOK(string loss_status)
        {
            List<Model.Loss.lossModel> list = new List<Model.Loss.lossModel>();
            string commandtext = "lossByStatus_Select";
            SqlParameter ok = new SqlParameter("@loss_state", SqlDbType.VarChar, 10);
            ok.Value = loss_status;
            DataSet ds = new DataSet();
            SqlHelper.FillDataSet(SqlHelper.conStr, CommandType.StoredProcedure, commandtext, ds, new string[] { }, new SqlParameter[] { ok });
            foreach (DataRow item in ds.Tables[0].Rows)
            {
                Model.Loss.lossModel inf = new Model.Loss.lossModel();
                inf.loss_id = item["loss_id"].ToString().Trim();
                list.Add(inf);
            }
            return list;
        }
        #endregion

        #region 通过采购损益单据编号查找损益单据信息
        /// <summary>
        /// 通过采购损益单据编号查找损益单据信息
        /// </summary>
        /// <param name="loss_id">损益单据编号</param>
        /// <returns></returns>
        public Model.Loss.lossModel LossSelectByID(string loss_id)
        {
            string commandtext = "LossByID_Select";
            SqlParameter id = new SqlParameter("@loss_id", SqlDbType.Char, 20);
            id.Value = loss_id;
            DataSet ds = new DataSet();
            SqlHelper.FillDataSet(SqlHelper.conStr, CommandType.StoredProcedure, commandtext, ds, new string[] { }, new SqlParameter[] { id });
            Model.Loss.lossModel inf = new Model.Loss.lossModel();
            foreach (DataRow item in ds.Tables[0].Rows)
            {
                inf.loss_name_id = item["loss_name_id"].ToString().Trim();
                inf.loss_time = (DateTime)item["loss_time"];
                inf.loss_shop_id = (int)item["loss_shop_id"];
            }
            return inf;
        }
        #endregion

        #region 修改损益单据
        /// <summary>
        /// 修改损益单据
        /// </summary>
        /// <param name="loss_id">采购单据编号</param>
        /// <param name="checkid">采购审核人编号</param>
        /// <param name="oktext">会计审核</param>
        /// <returns>返回修改信息影响的行数</returns>
        public List<Model.Loss.lossModel> LossUpdate(string loss_id, string checkid, string oktext)
        {
            List<Model.Loss.lossModel> list = new List<Model.Loss.lossModel>();
            string commandtext = "Loss_Update";
            SqlParameter sid = new SqlParameter("@loss_id", SqlDbType.Char, 20);
            SqlParameter cid = new SqlParameter("@loss_assessor_id", SqlDbType.VarChar, 10);
            SqlParameter ok = new SqlParameter("@loss_state", SqlDbType.Char, 10);
            sid.Value = loss_id;
            cid.Value = checkid;
            ok.Value = oktext;
            SqlHelper.ExecuteNonQuery(SqlHelper.conStr, CommandType.StoredProcedure, commandtext, new SqlParameter[] { sid, cid, ok });
            return list;
        }
        #endregion

        #region 损益单据信息查询
        /// <summary>
        ///  损益单据信息查询
        /// </summary>
        /// <returns></returns>
        public List<Model.Loss.lossModel> LossSelect()
        {
            List<Model.Loss.lossModel> li = new List<Model.Loss.lossModel>();
            string commandtext = "Loss_Select";
            DataSet ds = new DataSet();
            SqlHelper.FillDataSet(SqlHelper.conStr, CommandType.StoredProcedure, commandtext, ds, new string[] { }, null);
            foreach (DataRow item in ds.Tables[0].Rows)
            {
                Model.Loss.lossModel inf = new Model.Loss.lossModel();
                inf.loss_id = item["loss_id"].ToString().Trim();
                inf.loss_name_id = item["loss_name_id"].ToString().Trim();
                inf.loss_time = (DateTime)item["loss_time"];
                inf.loss_shop_id = (int)item["loss_shop_id"];
                inf.loss_assessor_id = item["loss_assessor_id"].ToString ();
                inf.loss_advice = item["loss_advice"].ToString().Trim();
                inf.loss_state = item["loss_state"].ToString ().Trim ();
                li.Add(inf);
            }
            return li;
        }
        #endregion

        #region 找出所有损益编号
        /// <summary>
        /// 找出所有损益编号
        /// </summary>
        /// <returns>返回损益单据编号的数据集</returns>
        public List<Model.Loss.lossModel> SelectLossID(DateTime losstime)
        {
            string commandtext = "LossID_Select";
            SqlParameter time = new SqlParameter("@loss_time",SqlDbType.DateTime);
            time.Value = losstime;
            DataSet ds = new DataSet();
            SqlHelper.FillDataSet(SqlHelper.conStr, CommandType.StoredProcedure, commandtext, ds, new string[] { }, new SqlParameter[]{time});
            List<Model.Loss.lossModel> li = new List<Model.Loss.lossModel>();
            foreach (DataRow dr in ds.Tables[0].Rows)
            {
                Model.Loss.lossModel inf = new Model.Loss.lossModel();
                inf.loss_id = dr["loss_id"].ToString();
                li.Add(inf);
            }
            return li;
        }
        #endregion

        #region 删除未通过审核的损益单据
        /// <summary>
        /// 删除未通过审核的损益单据
        /// </summary>
        /// <param name="stockformid">采购单据编号</param>
        /// <param name="stockstatus">采购状态</param>
        /// <returns>返回删除采购单据影响的行数</returns>
        public int LossDelete(string lossid, string loss_status)
        {
            string com = "Loss_Delete";
            SqlParameter id = new SqlParameter("@loss_id", SqlDbType.Char, 20);
            SqlParameter status = new SqlParameter("@loss_state", SqlDbType.VarChar, 10);
            id.Value = lossid;
            status.Value = loss_status;
            return SqlHelper.ExecuteNonQuery(SqlHelper.conStr, CommandType.StoredProcedure, com, new SqlParameter[] { id, status });
        }
        #endregion
    }
}