Estsh-Yiri/Estsh.Core.Wms/Repositories/SaleDeliveryRepository.cs

using Dapper;
using Estsh.Core.Base;
using Estsh.Core.Dapper;
using Estsh.Core.Model.EnumUtil;
using Estsh.Core.Models;
using Estsh.Core.Repositories;
using Estsh.Core.Wms.IRepositories;
using System.Data;
using System.Text;

namespace Estsh.Core.Wms.Repositories
{
    /// <summary>
    /// 销售发运
    /// </summary>
    public class SaleDeliveryRepository : BaseRepository<BaseEntity>, ISaleDeliveryRepository
    {
        public SaleDeliveryRepository(DapperDbContext _dapperDbContext) : base(_dapperDbContext)
        {

        }
        /// <summary>
        /// 获取销售发运单据信息
        /// </summary>
        /// <param name="orderNo"></param>
        /// <returns></returns>
        public List<WmsOutstock> GetSaleDeliveryOrderList(string orderNo)
        {
            using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
            {
                dbConn.Open();
                StringBuilder SqlStringBuilder = new StringBuilder(1024);
                SqlStringBuilder.Append("SELECT a.order_no,b.enum_desc AS order_type_desc,a.create_time,d.emp_no,a.factory_code,a.enabled,a.order_status  FROM dbo.wms_outstock a (nolock) ");
                SqlStringBuilder.Append("LEFT JOIN dbo.sys_enum b (nolock) ON a.order_type = b.enum_value AND b.enum_type = 'wms_outstock_order_type' ");
                //SqlStringBuilder.Append("LEFT JOIN wms_outstock_detail c (nolock) ON a.order_no = c.order_no ");
                SqlStringBuilder.Append("LEFT JOIN dbo.sys_emp d (nolock) ON a.create_userid = d.emp_id ");
                SqlStringBuilder.Append("WHERE a.order_no like '%" + orderNo + "%' AND order_status in ('10','30') AND (order_type=" + (int)WmsEnumUtil.OutStockType.SALE_SHIPPING + " OR order_type=" + (int)WmsEnumUtil.OutStockType.SALE_SHIPPING_NJIS + ") and a.enabled = 'Y' ");
                SqlStringBuilder.Append("AND order_no IN(SELECT t.order_no FROM wms_outstock_detail t (nolock) WHERE  a.order_no= t.order_no GROUP BY t.order_no HAVING SUM(t.pick_qty)!=0) ");
                SqlStringBuilder.Append("  order by  case when order_status='30' then 0 else 1 end, create_time   ");

                List<WmsOutstock> wmsMoves = dbConn.Query<WmsOutstock>(SqlStringBuilder.ToString()).ToList();
                return wmsMoves;

            }
        }

        /// <summary>
        /// 获取销售发运单据信息通过订单号
        /// </summary>
        /// <param name="orderNo"></param>
        /// <returns></returns>
        public List<WmsOutstock> GetSaleDeliveryOrderListByOrderNo(string orderNo)
        {
            using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
            {
                dbConn.Open();
                StringBuilder SqlStringBuilder = new StringBuilder(1024);
                SqlStringBuilder.Append("SELECT a.order_no,b.enum_desc AS order_type_desc,CONVERT(INT, c.qty) qty,CONVERT(INT, c.pick_qty) pick_qty,CONVERT(INT, c.out_qty) out_qty,c.part_no ,a.create_userid,a.create_time,c.src_zone_id,c.src_zone_name,d.emp_no,a.factory_code,p.part_spec,p.part_spec2,(select top 1 locate_name from sys_stock st (nolock) where st.part_id=c.part_id and st.status=" + (int)WmsEnumUtil.StockStatus.INSTOCKED + " order by st.create_time) as recommend_locate,(select top 1 vendor_name from sys_stock as sb left join sys_vendor as sc on sb.vendor_id = sc.vendor_id where sb.part_no = c.part_no and vendor_name is not null and vendor_name !='' ) as vendor_name  FROM dbo.wms_outstock a (nolock) ");
                SqlStringBuilder.Append("LEFT JOIN dbo.sys_enum b (nolock) ON a.order_type=b.enum_value AND	b.enum_type='wms_outstock_order_type'  ");
                SqlStringBuilder.Append("LEFT JOIN dbo.wms_outstock_detail c (nolock) ON a.order_no=c.order_no ");
                SqlStringBuilder.Append("LEFT JOIN dbo.sys_emp d (nolock) ON a.create_userid=d.emp_id ");
                SqlStringBuilder.Append("LEFT JOIN dbo.sys_part p (nolock) ON c.part_no=p.part_no ");
                SqlStringBuilder.Append("WHERE a.order_no = '" + orderNo + "' AND (order_type=" + (int)WmsEnumUtil.OutStockType.SALE_SHIPPING + " OR order_type=" + (int)WmsEnumUtil.OutStockType.SALE_SHIPPING_NJIS + ") and a.enabled='Y' ");

                List<WmsOutstock> wmsMoves = dbConn.Query<WmsOutstock>(SqlStringBuilder.ToString()).ToList();
                return wmsMoves;
            }
        }

        //根据条码号获取条码信息
        public List<SysStock> GetStockInfoByCartonNo(string cartonNo)
        {
            using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
            {
                dbConn.Open();
                StringBuilder stringBuilder = new StringBuilder();
                stringBuilder.Append("SELECT a.vendor_id, a.vendor_code, a.carton_no, a.locate_id, a.locate_name,a.qty, a.status, a.enabled,b.part_id,b.part_no,b.part_spec, b.part_spec, a.warehouse_id,a.warehouse_name,a.zone_id,a.zone_name,c.enum_desc AS stock_status " +
                                          ",a.unit,a.factory_id,a.factory_code,a.group_no FROM sys_stock a (nolock) LEFT JOIN dbo.sys_part b (nolock) ON a.part_no = b.part_no LEFT JOIN dbo.sys_enum c (nolock) ON a.status=c.enum_value AND enum_type LIKE '%sys_stock_status%' WHERE a.carton_no='" + cartonNo + "' ");
                List<SysStock> sysStocks = dbConn.Query<SysStock>(stringBuilder.ToString()).ToList();
                return sysStocks;
            }
        }

        //根据单据号获取销售发运数据
        public List<WmsOutstock> GetOutStockByOrderNo(string orderNo)
        {
            using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
            {
                dbConn.Open();
                StringBuilder stringBuilder = new StringBuilder(1024);
                stringBuilder.Append("SELECT * FROM dbo.wms_outstock (nolock) WHERE order_no = '" + orderNo + "' AND order_status in ('10','30') and (order_type=" + (int)WmsEnumUtil.OutStockType.SALE_SHIPPING + " OR order_type=" + (int)WmsEnumUtil.OutStockType.SALE_SHIPPING_NJIS + ") and enabled='Y'");
                List<WmsOutstock> WmsOutstocks = dbConn.Query<WmsOutstock>(stringBuilder.ToString()).ToList();
                return WmsOutstocks;
            }
        }

        //根据分组号获取库存信息
        public List<SysStock> GetStockByGroupNo(string groupNo)
        {
            using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
            {
                dbConn.Open();
                StringBuilder stringBuilder = new StringBuilder();
                stringBuilder.Append("SELECT * FROM dbo.sys_stock (nolock) WHERE group_no='" + groupNo + "' and status="+ (int)WmsEnumUtil.StockStatus.BATCHED + " and enabled='Y'");
                List<SysStock> sysStocks = dbConn.Query<SysStock>(stringBuilder.ToString()).ToList();
                return sysStocks;
            }
        }

        //根据单号、零件号获取销售发运明细
        public List<WmsOutstockDetail> GetOutStockDetailByOrderPartNo(string orderNo, string partNo)
        {
            using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
            {
                dbConn.Open();
                StringBuilder stringBuilder = new StringBuilder();
                stringBuilder.Append("SELECT * FROM dbo.wms_outstock_detail (nolock) WHERE order_no='" + orderNo + "' and part_no='" + partNo + "' and enabled='Y'");
                List<WmsOutstockDetail> WmsOutstockDetails = dbConn.Query<WmsOutstockDetail>(stringBuilder.ToString()).ToList();
                return WmsOutstockDetails;
            }
        }

        //根据单号获取条码明细
        public List<WmsOutstockSn> GetOutStockSnByOrder(string orderNo)
        {
            using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
            {
                dbConn.Open();
                StringBuilder stringBuilder = new StringBuilder();
                stringBuilder.Append("SELECT * FROM dbo.wms_outstock_sn (nolock) WHERE order_no='" + orderNo + "' and status=" + (int)WmsEnumUtil.MoveOrderSnStatus.BATCHED);
                List<WmsOutstockSn> moveSnCreates = dbConn.Query<WmsOutstockSn>(stringBuilder.ToString()).ToList();
                return moveSnCreates;
            }
        }

        //根据单号、条码号获取销售发运条码数据
        public List<WmsOutstockSn> GetOutStockSnByOrderCartonNo(string orderNo, string cartonNo)
        {
            using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
            {
                dbConn.Open();
                StringBuilder stringBuilder = new StringBuilder();
                stringBuilder.Append("SELECT * FROM dbo.wms_outstock_sn (nolock) WHERE order_no='" + orderNo + "' and status=" + (int)WmsEnumUtil.MoveOrderSnStatus.BATCHED + " and carton_no ='" + cartonNo + "'");
                List<WmsOutstockSn> wmsOutStockSns = dbConn.Query<WmsOutstockSn>(stringBuilder.ToString()).ToList();
                return wmsOutStockSns;
            }
        }

        //根据单号获取销售发运单明细
        public List<WmsOutstockDetail> GetOutStockDetailByOrder(string orderNo)
        {
            using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
            {
                dbConn.Open();
                StringBuilder stringBuilder = new StringBuilder(1024);
                stringBuilder.Append("SELECT SUM(CONVERT(INT, c.qty)) qty, SUM(CONVERT(INT, c.pick_qty)) pick_qty,SUM(CONVERT(INT, c.out_qty)) out_qty,c.part_no,c.part_spec,p.part_spec2,(select top 1 locate_name from sys_stock st (nolock) where st.part_id=c.part_id and st.status=" + (int)WmsEnumUtil.StockStatus.INSTOCKED + " order by st.create_time) as recommend_locate,(select top 1 vendor_name from sys_stock as sb left join sys_vendor as sc on sb.vendor_id = sc.vendor_id where sb.part_no = c.part_no and vendor_name is not null and vendor_name !='' ) as vendor_name  FROM dbo.wms_outstock a (nolock) ");
                stringBuilder.Append("LEFT JOIN dbo.wms_outstock_detail c (nolock) ON a.order_no=c.order_no ");
                stringBuilder.Append("LEFT JOIN dbo.sys_part p (nolock) ON c.part_no=p.part_no ");
                stringBuilder.Append(" WHERE a.order_no = '" + orderNo + "' AND order_status in ('30') AND (order_type=" + (int)WmsEnumUtil.OutStockType.SALE_SHIPPING + " OR order_type=" + (int)WmsEnumUtil.OutStockType.SALE_SHIPPING_NJIS + ") and a.enabled='Y' group by c.part_id,c.part_no,c.part_spec,p.part_spec2");

                List<WmsOutstockDetail> wmsMoves1 = dbConn.Query<WmsOutstockDetail>(stringBuilder.ToString()).ToList();
                return wmsMoves1;
            }
        }
        public WmsOutstockDetail GetOutStockDetailQtySumByOrder(string orderNo)
        {
            using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
            {
                dbConn.Open();
                StringBuilder SqlStringBuilder = new StringBuilder(1024);
                SqlStringBuilder.Append("SELECT SUM(pick_qty) pick_qty,SUM(out_qty) out_qty FROM dbo.wms_outstock_detail (nolock) WHERE order_no='" + orderNo + "';");
                WmsOutstockDetail wmsOutstocks = dbConn.QueryFirstOrDefault<WmsOutstockDetail>(SqlStringBuilder.ToString());
                return wmsOutstocks;
            }
        }

        //获取完成信息提交数据
        public List<WmsOutstockDetail> GetFinishOutStockDetailByOrderNo(string orderNo)
        {
            using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
            {
                dbConn.Open();
                StringBuilder SqlStringBuilder = new StringBuilder(1024);
                SqlStringBuilder.Append("SELECT SUM(CONVERT(INT, c.out_qty)) out_qty,c.part_no,c.item_no,src_erp_warehouse,plan_date,plan_time,a.factory_code,customer_code,a.order_no,a.order_type,a.ZVBELN FROM dbo.wms_outstock a (nolock) ");
                SqlStringBuilder.Append("LEFT JOIN dbo.wms_outstock_detail c (nolock) ON a.order_no=c.order_no ");
                SqlStringBuilder.Append(" WHERE a.order_no = '" + orderNo + "' AND order_status <> '40' and a.enabled='Y' group by c.part_no,c.item_no,src_erp_warehouse,plan_date,plan_time,a.factory_code,customer_code,a.order_no,a.order_type,a.ZVBELN");

                List<WmsOutstockDetail> wmsMoves = dbConn.Query<WmsOutstockDetail>(SqlStringBuilder.ToString()).ToList();
                return wmsMoves;
            }
        }

        //获取零件号信息
        public SysPart GetPartNOInfoByPartNo(string partNo)
        {
            using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
            {
                dbConn.Open();
                StringBuilder SqlStringBuilder = new StringBuilder(1024);
                SqlStringBuilder.Append("    SELECT * from sys_part (nolock) where part_no='" + partNo + "' ");
                SysPart sysParts = dbConn.QueryFirstOrDefault<SysPart>(SqlStringBuilder.ToString());
                return sysParts;
            }
        }

        //事务批量执行添加、修改
        public int SQLTransaction(List<string> sqlStrings, List<DynamicParameters> parameterList)
        {
            using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
            {
                if (dbConn.State == ConnectionState.Closed)
                {
                    dbConn.Open();
                }
                //执行事务
                IDbTransaction transaction = dbConn.BeginTransaction();
                if (parameterList == null || parameterList.Count == 0)
                {
                    try
                    {
                        for (int i = 0; i < sqlStrings.Count; i++)
                        {
                            dbConn.Execute(sqlStrings[i], null, transaction);
                        }
                        transaction.Commit();
                        return 1;
                    }
                    catch (Exception exception)
                    {
                        transaction.Rollback();
                        return 0;
                    }
                }
                else
                {
                    try
                    {
                        for (int i = 0; i < sqlStrings.Count; i++)
                        {
                            dbConn.Execute(sqlStrings[i], parameterList[i], transaction);
                        }
                        transaction.Commit();
                        return 1;
                    }
                    catch (Exception exception)
                    {
                        transaction.Rollback();
                        return 0;
                    }
                }
            }
        }
    }
}