using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using QMFrameWork.Data;
using QMAPP.FJC.Entity.ProductionPlan;
using System.Data;
using QMAPP.Entity;
using QMAPP.DAL;
using QMFrameWork.Log;
using QMAPP.FJC.Entity.FIS;
namespace QMAPP.FJC.DAL.ProductionPlan
{
/// <summary>
/// 模块名称：派工单
/// 作 者：张鹏
/// 编写日期：2017年10月24日
/// </summary>
public class WorkOrderDAL : BaseDAL
{
#region 获取信息
/// <summary>
/// 获取信息
/// </summary>
/// <param name="">条件</param>
/// <returns>*信息</returns>
public WorkOrder Get(WorkOrder info)
{
try
{
using (IDataSession session = AppDataFactory.CreateMainSession())
{
//获取信息
info = session.Get<WorkOrder>(info);
}
return info;
}
catch (Exception ex)
{
throw ex;
}
}
public WorkOrder GetOne(string ORDERPLANID)
{
string sql = "SELECT * FROM [T_PP_WORKORDER] WITH(NOLOCK) where [ORDERPLANID]='" + ORDERPLANID + "'";
List<DataParameter> parameters = new List<DataParameter>();
try
{
if (BaseSession != null)
{
return BaseSession.GetList<WorkOrder>(sql, parameters.ToArray()).FirstOrDefault();
}
using (IDataSession session = AppDataFactory.CreateMainSession())
{
return session.GetList<WorkOrder>(sql, parameters.ToArray()).FirstOrDefault();
}
}
catch (Exception ex)
{
throw ex;
}
}
public WorkOrder GetOneByID(string id)
{
string sql = "SELECT * FROM [T_PP_WORKORDER] WITH(NOLOCK) where [PID]='" + id + "'";
List<DataParameter> parameters = new List<DataParameter>();
try
{
if (BaseSession != null)
{
return BaseSession.GetList<WorkOrder>(sql, parameters.ToArray()).FirstOrDefault();
}
using (IDataSession session = AppDataFactory.CreateMainSession())
{
return session.GetList<WorkOrder>(sql, parameters.ToArray()).FirstOrDefault();
}
}
catch (Exception ex)
{
throw ex;
}
}
public WorkOrder GetOneByOrderNO(string ORDERPLANNO)
{
string sql = "SELECT * FROM [T_PP_WORKORDER] WITH(NOLOCK) where [ORDERPLAN_NO]='" + ORDERPLANNO + "'";
List<DataParameter> parameters = new List<DataParameter>();
try
{
if (BaseSession != null)
{
return BaseSession.GetList<WorkOrder>(sql, parameters.ToArray()).FirstOrDefault();
}
using (IDataSession session = AppDataFactory.CreateMainSession())
{
return session.GetList<WorkOrder>(sql, parameters.ToArray()).FirstOrDefault();
}
}
catch (Exception ex)
{
throw ex;
}
}
public WorkOrder GetOneByProduct(string productCode)
{
string sql = "SELECT * FROM [T_PP_WORKORDER] WITH(NOLOCK) where [REMARK]='" + productCode + "'";
List<DataParameter> parameters = new List<DataParameter>();
try
{
if (BaseSession != null)
{
return BaseSession.GetList<WorkOrder>(sql, parameters.ToArray()).FirstOrDefault();
}
using (IDataSession session = AppDataFactory.CreateMainSession())
{
return session.GetList<WorkOrder>(sql, parameters.ToArray()).FirstOrDefault();
}
}
catch (Exception ex)
{
throw ex;
}
}
/// <summary>
/// 获取计划单号下所有派工单信息
/// </summary>
/// <param name="ORDERPLANID"></param>
/// <returns></returns>
public int GetAllWorkOrder(string ORDERPLANID)
{
int count = 0;
string sql = "SELECT COUNT(1) FROM [T_PP_WORKORDER] WITH(NOLOCK) where [ORDERPLANID]='" + ORDERPLANID + "' AND STATE<>0";
List<DataParameter> parameters = new List<DataParameter>();
try
{
using (IDataSession session = AppDataFactory.CreateMainSession())
{
count =Convert.ToInt32(session.ExecuteSqlScalar(sql, parameters.ToArray()));
}
}
catch (Exception ex)
{
throw ex;
}
return count;
}
#endregion
#region 获取列表
/// <summary>
/// 获取列表
/// </summary>
/// <param name="condition">条件</param>
/// <param name="page">数据页</param>
/// <returns>数据页</returns>
public DataPage GetList(WorkOrder condition, DataPage page)
{
string sql = null;
List<DataParameter> parameters = new List<DataParameter>();
try
{
sql = this.GetQuerySql(condition, ref parameters);
//分页关键字段及排序
page.KeyName = "PID";
if (string.IsNullOrEmpty(page.SortExpression))
page.SortExpression = "UPDATEDATE DESC";
using (IDataSession session = AppDataFactory.CreateMainSession())
{
page = session.GetDataPage<WorkOrder>(sql, parameters.ToArray(), page);
}
return page;
}
catch (Exception ex)
{
throw ex;
}
}
public List<WorkOrder> GetList(WorkOrder condition)
{
List<WorkOrder> workOrderList = new List<WorkOrder>();
string sql = "select * from T_PP_WORKORDER WITH(NOLOCK) t where 1=1 ";
if (string.IsNullOrEmpty(condition.ORDERPLANID) == false)
{
sql += string.Format(" and ORDERPLANID='{0}'",condition.ORDERPLANID);
}
using (IDataSession session = AppDataFactory.CreateMainSession())
{
workOrderList = session.GetList<WorkOrder>(sql, new List<DataParameter>().ToArray()).ToList<WorkOrder>();
}
return workOrderList;
}
public List<WorkOrder> GetWorkOrderInfo(string planno)
{
try
{
StringBuilder sql = new StringBuilder();
sql.AppendFormat("SELECT W.[PID]");
sql.AppendFormat(" ,W.[ORDERPLANID] ");
sql.AppendFormat(" ,W.[ORDERPLAN_NO] ");
sql.AppendFormat(" ,W.[ORDER_TYPE] ");
sql.AppendFormat(" ,W.[SEQ] ");
sql.AppendFormat(" ,W.[MATERIAL_CODE] ");
sql.AppendFormat(" ,M.[MATERIAL_NAME] ");
sql.AppendFormat(" ,W.[PBOM_CODE] ");
sql.AppendFormat(" ,W.[QTY] ");
sql.AppendFormat(" ,W.[COMPLETE_QTY] ");
sql.AppendFormat(" ,W.[PLAN_DATE] ");
sql.AppendFormat(" ,W.[SHIFT_CODE] ");
sql.AppendFormat(" ,W.[WORKCENTER_CODE] ");
sql.AppendFormat(" ,W.[WORKCENTER_NAME] ");
sql.AppendFormat(" ,W.[WORKCELL_CODE] ");
sql.AppendFormat(" ,W.[WORKCELL_NAME] ");
sql.AppendFormat(" ,W.[WORKLOC_CODE] ");
sql.AppendFormat(" ,W.[REMARK] ");
sql.AppendFormat(" ,W.[EQPT_NAME] ");
sql.AppendFormat(" ,W.[EQPT_CODE] ");
sql.AppendFormat(" ,W.[STATE] ");
sql.AppendFormat(" ,W.[MOULD_CODE] ");
sql.AppendFormat(" ,W.[PRI] ");
sql.AppendFormat(" ,W.[UPDATEDATE] ");
sql.AppendFormat(" ,W.[PRINTED] ");
sql.AppendFormat(" ,P.[IGNORE_FISBREAK] ");
sql.AppendFormat(" ,P.[FIS_ASMSETCODE] ");
sql.AppendFormat(" FROM [T_PP_WORKORDER] AS W WITH(NOLOCK) ");
sql.AppendFormat(" LEFT JOIN [T_PP_ORDERPLAN] AS P WITH(NOLOCK) ");
sql.AppendFormat(" ON P.[PID]=W.[ORDERPLANID] ");
sql.AppendFormat(" LEFT JOIN [T_MD_MATERIAL] AS M WITH(NOLOCK) ");
sql.AppendFormat(" ON W.[MATERIAL_CODE]=M.[MATERIAL_CODE] ");
sql.AppendFormat(" WHERE P.[PLAN_NO]=@planno ");
sql.AppendFormat(" ORDER BY W.[UPDATEDATE],W.[PRI],W.[PLAN_DATE],P.PLAN_SEQ,W.[SEQ],W.[MATERIAL_CODE] ");
List<DataParameter> parameters = new List<DataParameter>();
parameters.Add(new DataParameter("planno", planno));
using (var session = AppDataFactory.CreateMainSession())
{
return session.GetList<WorkOrder>(sql.ToString(), parameters.ToArray()).ToList();
}
}
catch (Exception ex)
{
throw ex;
}
}
/// <summary>
/// 获取指定工序的生产计划清单
/// </summary>
/// <param name="workcellcode">工序编码</param>
/// <param name="count">数量</param>
/// <param name="filter">过滤选项：0全部；1隐藏挂起；2只看挂起</param>
/// <returns></returns>
public List<WorkOrder> GetOrderInCell(string workcellcode,int filter=0, int count = 20)
{
try
{
StringBuilder sql = new StringBuilder();
sql.AppendFormat("SELECT TOP {0} W.[PID]\r\n", count);
sql.AppendFormat(" ,W.[ORDERPLANID] ");
sql.AppendFormat(" ,W.[ORDERPLAN_NO] ");
sql.AppendFormat(" ,W.[ORDER_TYPE] ");
sql.AppendFormat(" ,W.[SEQ] ");
sql.AppendFormat(" ,W.[MATERIAL_CODE] ");
sql.AppendFormat(" ,M.[MATERIAL_NAME] ");
sql.AppendFormat(" ,W.[PBOM_CODE] ");
sql.AppendFormat(" ,W.[QTY] ");
sql.AppendFormat(" ,W.[COMPLETE_QTY] ");
sql.AppendFormat(" ,W.[PLAN_DATE] ");
sql.AppendFormat(" ,W.[SHIFT_CODE] ");
sql.AppendFormat(" ,W.[WORKCENTER_CODE] ");
sql.AppendFormat(" ,W.[WORKCENTER_NAME] ");
sql.AppendFormat(" ,W.[WORKCELL_CODE] ");
sql.AppendFormat(" ,W.[WORKCELL_NAME] ");
sql.AppendFormat(" ,W.[WORKLOC_CODE] ");
sql.AppendFormat(" ,W.[REMARK] ");
sql.AppendFormat(" ,W.[EQPT_NAME] ");
sql.AppendFormat(" ,W.[EQPT_CODE] ");
sql.AppendFormat(" ,W.[STATE] ");
sql.AppendFormat(" ,W.[MOULD_CODE] ");
sql.AppendFormat(" ,W.[PRI] ");
sql.AppendFormat(" ,W.[UPDATEDATE] ");
sql.AppendFormat(" ,P.[IGNORE_FISBREAK] ");
sql.AppendFormat(" ,P.[FIS_ASMSETCODE] ");
sql.AppendFormat(" FROM [T_PP_WORKORDER] AS W WITH(NOLOCK) ");
sql.AppendFormat(" LEFT JOIN [T_PP_ORDERPLAN] AS P WITH(NOLOCK) ");
sql.AppendFormat(" ON P.[PID]=W.[ORDERPLANID] ");
sql.AppendFormat(" LEFT JOIN [T_MD_MATERIAL] AS M WITH(NOLOCK)");
sql.AppendFormat(" ON W.[MATERIAL_CODE]=M.[MATERIAL_CODE] ");
sql.AppendFormat(" WHERE W.[WORKCELL_CODE]=@workcellcode ");
switch (filter)
{
case 1:
{
sql.AppendFormat(" AND W.[STATE]<>4 ");
break;
}
case 2:
{
sql.AppendFormat(" AND W.[STATE]=4 ");
break;
}
}
sql.AppendFormat(" ORDER BY W.[UPDATEDATE],W.[PRI],W.[PLAN_DATE],P.PLAN_SEQ,W.[SEQ],W.[MATERIAL_CODE] ");
List<DataParameter> parameters = new List<DataParameter>();
parameters.Add(new DataParameter("workcellcode", workcellcode));
using (var session = AppDataFactory.CreateMainSession())
{
return session.GetList<WorkOrder>(sql.ToString(), parameters.ToArray()).ToList();
}
}
catch(Exception ex)
{
throw ex;
}
}
/// <summary>
/// 获取指定工序的生产计划清单
/// </summary>
/// <param name="workcellcode">工序编码</param>
/// <param name="count">数量</param>
/// <param name="filter">过滤选项：0全部；1隐藏挂起；2只看挂起</param>
/// <returns></returns>
public List<WorkOrder> GetOrderUnPrinted(string routecode, int filter = 0, int count = 20)
{
try
{
StringBuilder sql = new StringBuilder();
sql.AppendFormat("SELECT TOP {0} W.[PID]\r\n", count);
sql.AppendFormat(" ,W.[ORDERPLANID] ");
sql.AppendFormat(" ,W.[ORDERPLAN_NO] ");
sql.AppendFormat(" ,W.[ORDER_TYPE] ");
sql.AppendFormat(" ,W.[SEQ] ");
sql.AppendFormat(" ,W.[MATERIAL_CODE] ");
sql.AppendFormat(" ,M.[MATERIAL_NAME] ");
sql.AppendFormat(" ,W.[PBOM_CODE] ");
sql.AppendFormat(" ,W.[QTY] ");
sql.AppendFormat(" ,W.[COMPLETE_QTY] ");
sql.AppendFormat(" ,W.[PLAN_DATE] ");
sql.AppendFormat(" ,W.[SHIFT_CODE] ");
sql.AppendFormat(" ,W.[WORKCENTER_CODE] ");
sql.AppendFormat(" ,W.[WORKCENTER_NAME] ");
sql.AppendFormat(" ,W.[WORKCELL_CODE] ");
sql.AppendFormat(" ,W.[WORKCELL_NAME] ");
sql.AppendFormat(" ,W.[WORKLOC_CODE] ");
sql.AppendFormat(" ,W.[REMARK] ");
sql.AppendFormat(" ,W.[EQPT_NAME] ");
sql.AppendFormat(" ,W.[EQPT_CODE] ");
sql.AppendFormat(" ,W.[STATE] ");
sql.AppendFormat(" ,W.[MOULD_CODE] ");
sql.AppendFormat(" ,W.[PRI] ");
sql.AppendFormat(" ,W.[UPDATEDATE] ");
sql.AppendFormat(" ,W.[PRINTED] ");
sql.AppendFormat(" ,P.[IGNORE_FISBREAK] ");
sql.AppendFormat(" ,P.[FIS_ASMSETCODE] ");
sql.AppendFormat(" FROM [T_PP_WORKORDER] AS W WITH(NOLOCK) ");
sql.AppendFormat(" LEFT JOIN [T_PP_ORDERPLAN] AS P WITH(NOLOCK) ");
sql.AppendFormat(" ON P.[PID]=W.[ORDERPLANID] ");
sql.AppendFormat(" LEFT JOIN [T_MD_MATERIAL] AS M WITH(NOLOCK) ");
sql.AppendFormat(" ON W.[MATERIAL_CODE]=M.[MATERIAL_CODE] ");
sql.AppendFormat(" WHERE P.[ROUTE_CODE]=@routecode ");
sql.AppendFormat(" AND W.[PRINTED]='0' ");
switch (filter)
{
case 1:
{
sql.AppendFormat(" AND W.[STATE]<>4 ");
break;
}
case 2:
{
sql.AppendFormat(" AND W.[STATE]=4 ");
break;
}
}
sql.AppendFormat(" ORDER BY W.[UPDATEDATE],W.[PRI],W.[PLAN_DATE],P.PLAN_SEQ,W.[SEQ],W.[MATERIAL_CODE] ");
List<DataParameter> parameters = new List<DataParameter>();
parameters.Add(new DataParameter("routecode", routecode));
using (var session = AppDataFactory.CreateMainSession())
{
return session.GetList<WorkOrder>(sql.ToString(), parameters.ToArray()).ToList();
}
}
catch (Exception ex)
{
throw ex;
}
}
/// <summary>
/// 获取指定工序的待完成计划数量
/// </summary>
/// <param name="workcellcode">工序编码</param>
/// <param name="shift">不指定班次则查询全部计划</param>
/// <param name="date">不指定班次则无需输入日期</param>
/// <returns></returns>
public int GetOrderCountInCell(string workcellcode,string shift,DateTime date)
{
try
{
List<DataParameter> parameters = new List<DataParameter>();
StringBuilder sql = new StringBuilder();
sql.AppendFormat("SELECT COUNT(*) ");
sql.AppendFormat(" FROM [T_PP_WORKORDER] WITH(NOLOCK) ");
sql.AppendFormat(" WHERE [WORKCELL_CODE]=@workcellcode ");
sql.AppendFormat(" AND [STATE]<>4");
if (!string.IsNullOrWhiteSpace(shift))
{
sql.AppendFormat(" AND [SHIFT_CODE]=@shift");
parameters.Add(new DataParameter("shift", shift));
//sql.AppendFormat(" AND DATEDIFF(DAY,[PLAN_DATE],@date)=0");
//parameters.Add(new DataParameter("date", date));
sql.AppendFormat(" AND [PLAN_DATE] BETWEEN @date1 AND @date2");
parameters.Add(new DataParameter("date1", date.Date));
parameters.Add(new DataParameter("date2", date.Date.AddDays(1)));
}
parameters.Add(new DataParameter("workcellcode", workcellcode));
using (var session = AppDataFactory.CreateMainSession())
{
return (int)session.ExecuteSqlScalar(sql.ToString(), parameters.ToArray());
}
}
catch (Exception ex)
{
throw ex;
}
}
#endregion
#region 获取查询语句
/// <summary>
/// 获取查询语句
/// </summary>
/// <param name="user">查询条件</param>
/// <param name="parameters">参数</param>
/// <returns>查询语句</returns>
private string GetQuerySql(WorkOrder condition, ref List<DataParameter> parameters)
{
StringBuilder sqlBuilder = new StringBuilder();
StringBuilder whereBuilder = new StringBuilder();
try
{
//构成查询语句
sqlBuilder.Append("SELECT PID,ORDERPLANID,ORDERPLAN_NO,ORDER_TYPE,SEQ,MATERIAL_CODE,PBOM_CODE,QTY,COMPLETE_QTY,PLAN_DATE,SHIFT_CODE,WORKCENTER_CODE,WORKCENTER_NAME,WORKCELL_CODE,WORKCELL_NAME,WORKLOC_CODE,REMARK,EQPT_NAME,EQPT_CODE,STATE ");
sqlBuilder.Append("FROM T_PP_WORKORDER WITH(NOLOCK) ");
whereBuilder.Append(" AND FLGDEL<> '1' ");
//查询条件
if (whereBuilder.Length > 0)
{
sqlBuilder.Append(" WHERE " + whereBuilder.ToString().Substring(4));
}
return sqlBuilder.ToString();
}
catch (Exception ex)
{
throw ex;
}
}
#endregion
#region 获取导出的数据
/// <summary>
/// 获取导出的数据
/// </summary>
/// <param name="user">查询条件</param>
/// <returns>数据</returns>
public DataTable GetExportData(WorkOrder info)
{
DataTable dt = null;
string sql = null;
List<DataParameter> parameters = new List<DataParameter>();
try
{
//构成查询语句
sql = this.GetQuerySql(info, ref parameters);
using (IDataSession session = AppDataFactory.CreateMainSession())
{
dt = session.GetTable(sql, parameters.ToArray());
dt.TableName = "WorkOrder";
}
return dt;
}
catch (Exception ex)
{
throw ex;
}
}
#endregion
#region 信息是否重复
/// <summary>
/// 判断名称是否存在
/// </summary>
/// <param name="info"></param>
/// <returns>true:已存在；fasel:不存在。</returns>
public bool Exists(WorkOrder info)
{
StringBuilder sqlBuilder = new StringBuilder();
StringBuilder whereBuilder = new StringBuilder();
List<DataParameter> parameters = new List<DataParameter>();
int count = 0;
try
{
sqlBuilder.Append("SELECT COUNT(0) FROM T_PP_WORKORDER WITH(NOLOCK) ");
if (info.PID == null)
{
info.PID = "";
}
whereBuilder.Append(" AND PID <> @PID ");
parameters.Add(new DataParameter { ParameterName = "PID", DataType = DbType.String, Value = info.PID });
//添加进行无重复字段判断代码
if (whereBuilder.Length > 0)
{
sqlBuilder.Append(" WHERE " + whereBuilder.ToString().Substring(4));
}
using (IDataSession session = AppDataFactory.CreateMainSession())
{
count = Convert.ToInt32(session.ExecuteSqlScalar(sqlBuilder.ToString(), parameters.ToArray()));
}
return count > 0;
}
catch (Exception ex)
{
throw ex;
}
}
#endregion
#region 插入信息
/// <summary>
/// 插入信息(单表)
/// </summary>
/// <param name="">信息</param>
/// <returns>插入行数</returns>
public int Insert(WorkOrder info)
{
try
{
if (BaseSession != null)
{
return BaseSession.Insert<WorkOrder>(info);
}
using (IDataSession session = AppDataFactory.CreateMainSession())
{
//插入基本信息
return session.Insert<WorkOrder>(info);
}
}
catch (Exception ex)
{
throw ex;
}
}
#endregion
#region 更新信息
/// <summary>
/// 更新信息
/// </summary>
/// <param name=""></param>
/// <returns>更新行数</returns>
public int Update(WorkOrder info)
{
int count = 0;
try
{
using (IDataSession session = AppDataFactory.CreateMainSession())
{
//更新基本信息
count = session.Update<WorkOrder>(info);
}
return count;
}
catch (Exception ex)
{
throw ex;
}
}
#endregion
#region 逻辑删除
/// <summary>
/// 逻辑删除信息
/// </summary>
/// <param name=""></param>
/// <returns>删除个数</returns>
public int Delete(WorkOrder info)
{
StringBuilder sqlBuilder = new StringBuilder();
List<DataParameter> parameters = new List<DataParameter>();
int count = 0;
try
{
using (IDataSession session = AppDataFactory.CreateMainSession())
{
//删除基本信息
sqlBuilder.Append("UPDATE T_PP_WORKORDER ");
sqlBuilder.Append("SET FLGDEL = '1' ");
sqlBuilder.Append("WHERE PID = @PID ");
parameters.Add(new DataParameter { ParameterName = "PID", DataType = DbType.String, Value = info.PID });
count = session.ExecuteSql(sqlBuilder.ToString(), parameters.ToArray());
}
return count;
}
catch (Exception ex)
{
throw ex;
}
}
#endregion
/// <summary>
/// 删除派工单
/// </summary>
/// <param name="entity"></param>
public void BatchDeleteByOrderPlan(WorkOrder entity)
{
try
{
string deleteSql = string.Format("delete from T_PP_WORKORDER where ORDERPLANID='{0}' ", entity.ORDERPLANID);
this.BaseSession.ExecuteSql(deleteSql, new List<DataParameter>().ToArray());
}
catch (Exception ex)
{
throw ex;
}
}
#region 导入
public ImportMessage GetImportData(List<WorkOrder> list)
{
ImportMessage em = new ImportMessage();
List<DataParameter> parameters = new List<DataParameter>();
try
{
using (IDataSession session = AppDataFactory.CreateMainSession())
{
//设置祖先对象数据会话
session.OpenTs();
foreach (WorkOrder info in list)
{
if (info.IsNewInfo)
{
//插入信息
int count = session.Insert<WorkOrder>(info);
em.insertNum++;
}
else
{
//更新信息
int count = session.Update<WorkOrder>(info);
em.updateNum++;
}
}
session.CommitTs();
}
}
catch (Exception ex)
{
throw ex;
}
return em;
}
#endregion
/// <summary>
/// 获取指定工位正在执行的派工单
/// </summary>
/// <param name="workloccode"></param>
/// <returns></returns>
public WorkOrder GetWorkingOrderInLoc(string workloccode,string mouldcode)
{
try
{
List<DataParameter> parameters = new List<DataParameter>();
StringBuilder sql = new StringBuilder();
sql.AppendLine("SELECT O.* ");
sql.AppendLine(" ,P.[IGNORE_FISBREAK] ");
sql.AppendLine(" ,P.[FIS_ASMSETCODE] ");
sql.AppendLine(" FROM [T_PP_WORKORDER] AS O WITH(NOLOCK) ");
sql.AppendLine(" LEFT JOIN [T_PP_ORDERPLAN] AS P WITH(NOLOCK) ");
sql.AppendLine(" ON P.[PID]=O.[ORDERPLANID] ");
sql.AppendLine(" WHERE O.[WORKLOC_CODE]=@workloccode ");
sql.AppendLine(" AND O.[MOULD_CODE]=@mouldcode ");
sql.AppendLine(" AND O.[STATE]='2' "); //工单状态为执行中
parameters.Add(new DataParameter("workloccode", workloccode));
parameters.Add(new DataParameter("mouldcode", mouldcode));
using (var session = AppDataFactory.CreateMainSession())
{
return session.Get<WorkOrder>(sql.ToString(), parameters.ToArray());
}
}
catch (Exception ex)
{
throw ex;
}
}
/// <summary>
/// 获取第一条匹配的派工单
/// </summary>
/// <param name="workcellcode">工序</param>
/// <param name="productmaterial">产品物料号</param>
/// <returns></returns>
public WorkOrder GetFirstMatchOrder(string workcellcode, string productmaterial,string planpid="")
{
List<DataParameter> parameters = new List<DataParameter>();
StringBuilder sql = new StringBuilder();
sql.AppendLine("SELECT TOP 1 O.* ");
sql.AppendLine(" ,P.[IGNORE_FISBREAK] ");
sql.AppendLine(" ,P.[FIS_ASMSETCODE] ");
sql.AppendLine(" FROM [T_PP_WORKORDER] AS O WITH(NOLOCK) ");
sql.AppendLine(" LEFT JOIN [T_PP_ORDERPLAN] AS P WITH(NOLOCK) ");
sql.AppendLine(" ON P.[PID]=O.[ORDERPLANID] ");
sql.AppendLine(" WHERE O.[WORKCELL_CODE]=@workcellcode ");
if (!string.IsNullOrWhiteSpace(planpid))
{
sql.AppendLine(" AND O.[ORDERPLANID]=@planpid");
parameters.Add(new DataParameter("planpid", planpid));
}
sql.AppendLine(" AND (EXISTS (SELECT 1 ");
sql.AppendLine(" FROM T_MD_PBOM_ITEM AS I ");
sql.AppendLine(" WHERE O.PBOM_CODE = I.PBOM_CODE ");
sql.AppendLine(" AND I.FLGDEL = '0' ");
sql.AppendLine(" AND I.MATERIAL_CODE = @materialcode) ");
sql.AppendLine(" OR O.[MATERIAL_CODE]=@materialcode) ");
sql.AppendLine(" AND (O.[STATE]='0' OR O.[STATE]='1') ");
sql.AppendLine(" ORDER BY O.UPDATEDATE,O.PRI,O.PLAN_DATE,P.PLAN_SEQ,SEQ "); //排序为 FIS优先、日期正序、顺序号正序
parameters.Add(new DataParameter("workcellcode", workcellcode));
parameters.Add(new DataParameter("materialcode", productmaterial));
using (var session = AppDataFactory.CreateMainSession())
{
return session.Get<WorkOrder>(sql.ToString(), parameters.ToArray());
}
}
/// <summary>
/// 获取工序下匹配的派工单
/// </summary>
/// <param name="workcellcode">工序</param>
/// <returns></returns>
public List<WorkOrder> GetMatchOrders(string workcellcode,string planpid="")
{
List<DataParameter> parameters = new List<DataParameter>();
StringBuilder sql = new StringBuilder();
sql.AppendLine("SELECT W.* ");
sql.AppendLine(" ,P.[IGNORE_FISBREAK] ");
sql.AppendLine(" ,P.[FIS_ASMSETCODE] ");
sql.AppendLine(" FROM [T_PP_WORKORDER] AS W WITH(NOLOCK) ");
sql.AppendLine(" LEFT JOIN [T_PP_ORDERPLAN] AS P WITH(NOLOCK) ");
sql.AppendLine(" ON P.[PID]=W.[ORDERPLANID] ");
sql.AppendLine(" WHERE W.SEQ = (SELECT TOP 1 SEQ ");
sql.AppendLine(" FROM [T_PP_WORKORDER] AS O WITH(NOLOCK) ");
sql.AppendLine(" LEFT JOIN [T_PP_ORDERPLAN] AS P1 WITH(NOLOCK) ");
sql.AppendLine(" ON P1.[PID]=O.[ORDERPLANID] ");
sql.AppendLine(" WHERE O.[WORKCELL_CODE]=@workcellcode ");
sql.AppendLine(" AND (O.[STATE]='0' OR O.[STATE]='1') ");
if (!string.IsNullOrWhiteSpace(planpid))
{
sql.AppendLine(" AND O.[ORDERPLANID]=@planpid");
}
sql.AppendLine(" ORDER BY O.UPDATEDATE,O.PRI,O.PLAN_DATE,P1.PLAN_SEQ,SEQ) ");//排序为 FIS优先、日期正序、计划顺序号、工单顺序号正序
sql.AppendLine(" AND W.[WORKCELL_CODE]=@workcellcode ");
sql.AppendLine(" AND (W.[STATE]='0' OR W.[STATE]='1') ");
if (!string.IsNullOrWhiteSpace(planpid))
{
sql.AppendLine(" AND W.[ORDERPLANID]=@planpid");
parameters.Add(new DataParameter("planpid", planpid));
}
parameters.Add(new DataParameter("workcellcode", workcellcode));
using (var session = AppDataFactory.CreateMainSession())
{
return session.GetList<WorkOrder>(sql.ToString(), parameters.ToArray()).ToList();
}
}
#region 改变派工单
/// <summary>
/// 改变派工单
/// </summary>
/// <param name="entity"></param>
public void ChangeByOrderPlan(WorkOrder entity)
{
if (this.BaseSession != null)
{
this.BaseSession.Update<WorkOrder>(entity);
}
else
{
using (IDataSession session = AppDataFactory.CreateMainSession())
{
session.Update<WorkOrder>(entity);
}
}
}
#endregion
/// <summary>
/// 获取派工单
/// </summary>
/// <param name="model"></param>
/// <returns></returns>
public WorkOrder GetworkOrderInfo(WorkOrder model)
{
string sql = null;
List<DataParameter> parameters = new List<DataParameter>();
try
{
sql = "SELECT TOP 1 * FROM T_PP_WORKORDER WITH(NOLOCK) WHERE STATE=0 ";
if (string.IsNullOrEmpty(model.ORDERPLANID) == false)
{
sql += " AND ORDERPLANID = @ORDERPLANID";
parameters.Add(new DataParameter("ORDERPLANID", model.ORDERPLANID));
}
if (BaseSession != null)
{
//获取信息
model = BaseSession.Get<WorkOrder>(sql, parameters.ToArray());
}
else
{
using (IDataSession session = AppDataFactory.CreateMainSession())
{
//获取信息
model = session.Get<WorkOrder>(sql, parameters.ToArray());
}
}
return model;
}
catch (Exception ex)
{
LogManager.LogHelper.Error(new LogInfo()
{
ErrorInfo = ex,
Tag = ex.StackTrace,
Info = "信息数据层-获取信息"
});
throw;
}
}
/// <summary>
/// 获取指定日期前的FIS计划顺序号
/// </summary>
/// <param name="plandate"></param>
/// <param name="workcentercode"></param>
/// <returns></returns>
public string GetLastFISSEQ(DateTime plandate, string workcentercode)
{
StringBuilder sql = new StringBuilder() ;
List<DataParameter> parameters = new List<DataParameter>();
try
{
sql.AppendLine("SELECT TOP 1 [PLAN_SEQ] ");
sql.AppendLine(" FROM [T_PP_ORDERPLAN] WITH(NOLOCK) ");
sql.AppendLine(" WHERE [PLANSOURCE]='0' ");
sql.AppendLine(" AND [PLAN_DATE]<@plandate ");
sql.AppendLine(" AND [WORKCENTER_CODE]=@workcentercode ");
sql.AppendLine(" ORDER BY [PLAN_DATE] DESC ");
parameters.Add(new DataParameter("plandate", plandate));
parameters.Add(new DataParameter("workcentercode", workcentercode));
using (IDataSession session = AppDataFactory.CreateMainSession())
{
//获取信息
var ret= session.ExecuteSqlScalar(sql.ToString(), parameters.ToArray());
if (ret != null)
{
return ret.ToString();
}
else
{
return "";
}
}
}
catch (Exception ex)
{
LogManager.LogHelper.Error(new LogInfo()
{
ErrorInfo = ex,
Tag = ex.StackTrace,
Info = "信息数据层-获取信息"
});
throw;
}
}
/// <summary>
/// 根据模架搜索工单
/// </summary>
/// <param name="mouldcode"></param>
/// <param name="workcellcode"></param>
public WorkOrder SearchByMould(string mouldcode, string workcellcode)
{
try
{
StringBuilder sql = new StringBuilder();
List<DataParameter> parameters = new List<DataParameter>();
sql.AppendLine("SELECT TOP 1 W.* ");
sql.AppendLine(" FROM T_PP_WORKORDER AS W WITH(NOLOCK) ");
sql.AppendLine(" LEFT JOIN [T_PP_ORDERPLAN] AS P WITH(NOLOCK) ");
sql.AppendLine(" ON P.[PID]=W.[ORDERPLANID] ");
sql.AppendLine(" LEFT JOIN T_MD_MATERIAL AS M WITH(NOLOCK) ");
sql.AppendLine(" ON M.MATERIAL_CODE=W.MATERIAL_CODE ");
sql.AppendLine(" LEFT JOIN T_QT_MATERIAL_BINDING AS MB WITH(NOLOCK) ");
sql.AppendLine(" ON MB.MATERIAL_CODE=M.MATERIAL_TYPE_CODE ");
sql.AppendLine(" AND MB.BINDING_TYPE='ASSY' ");
sql.AppendLine(" WHERE MB.TARGET_CODE=@mouldcode ");
sql.AppendLine(" AND W.WORKCELL_CODE=@workcellcode ");
sql.AppendLine(" AND (W.STATE='1' OR W.STATE='0') ");
sql.AppendLine(" ORDER BY W.UPDATEDATE,W.PRI,w.PLAN_DATE,P.PLAN_SEQ,W.SEQ ");
parameters.Add(new DataParameter("mouldcode", mouldcode));
parameters.Add(new DataParameter("workcellcode", workcellcode));
using (IDataSession session = AppDataFactory.CreateMainSession())
{
//获取信息
return session.Get<WorkOrder>(sql.ToString(), parameters.ToArray());
}
}
catch (Exception ex)
{
LogManager.LogHelper.Error(new LogInfo()
{
ErrorInfo = ex,
Tag = ex.StackTrace,
Info = "信息数据层-获取信息"
});
throw;
}
}
public List<WorkOrder> GetListByID(string[] orderid)
{
try
{
StringBuilder sql = new StringBuilder();
List<DataParameter> parameters = new List<DataParameter>();
string ids = string.Join("','", orderid);
sql.AppendFormat("SELECT * FROM T_PP_WORKORDER WITH(NOLOCK) WHERE PID IN ('{0}')", ids);
using (IDataSession session = AppDataFactory.CreateMainSession())
{
//获取信息
return session.GetList<WorkOrder>(sql.ToString(), parameters.ToArray()).ToList();
}
}
catch (Exception ex)
{
LogManager.LogHelper.Error(new LogInfo()
{
ErrorInfo = ex,
Tag = ex.StackTrace,
Info = "信息数据层-获取信息GetListByID"
});
throw;
}
}
/// <summary>
/// 批量更新
/// </summary>
/// <param name="orders"></param>
/// <returns></returns>
public int Update(List<WorkOrder> orders)
{
using (IDataSession session = AppDataFactory.CreateMainSession())
{
//获取信息
return session.Update(orders);
}
}
/// <summary>
/// 批量删除
/// </summary>
/// <param name="orders"></param>
/// <returns></returns>
public int Delete(List<WorkOrder> orders)
{
using (IDataSession session = AppDataFactory.CreateMainSession())
{
//获取信息
return session.Delete(orders);
}
}
public WorkOrder GetWorkingOrderWithProduct(string workcellcode, string productcode, string planpid = "")
{
List<DataParameter> parameters = new List<DataParameter>();
StringBuilder sql = new StringBuilder();
sql.AppendLine("SELECT TOP 1 O.* ");
sql.AppendLine(" ,P.[IGNORE_FISBREAK] ");
sql.AppendLine(" ,P.[FIS_ASMSETCODE] ");
sql.AppendLine(" FROM [T_PP_WORKORDER] AS O WITH(NOLOCK) ");
sql.AppendLine(" LEFT JOIN [T_PP_ORDERPLAN] AS P WITH(NOLOCK) ");
sql.AppendLine(" ON P.[PID]=O.[ORDERPLANID] ");
sql.AppendLine(" WHERE O.[WORKCELL_CODE]=@workcellcode ");
if (!string.IsNullOrWhiteSpace(planpid))
{
sql.AppendLine(" AND O.[ORDERPLANID]=@planpid");
parameters.Add(new DataParameter("planpid", planpid));
}
sql.AppendLine(" AND O.[REMARK]=@productcode");
sql.AppendLine(" AND (O.[STATE]='0' OR O.[STATE]='1') ");
sql.AppendLine(" ORDER BY O.UPDATEDATE,O.PRI,O.PLAN_DATE,P.PLAN_SEQ,SEQ "); //排序为 FIS优先、日期正序、顺序号正序
parameters.Add(new DataParameter("workcellcode", workcellcode));
parameters.Add(new DataParameter("productcode", productcode));
using (var session = AppDataFactory.CreateMainSession())
{
return session.Get<WorkOrder>(sql.ToString(), parameters.ToArray());
}
}
public int GetDayPlanCount(string workcentercode, DateTime date)
{
try
{
List<DataParameter> parameters = new List<DataParameter>();
StringBuilder sql = new StringBuilder();
sql.AppendLine("SELECT ISNULL(SUM(QTY),0) ");
sql.AppendLine(" FROM T_PP_ORDERPLAN WITH(NOLOCK) ");
sql.AppendLine(" WHERE WORKCENTER_CODE=@workcentercode ");
//sql.AppendLine(" AND DATEDIFF(DAY,PLAN_DATE,@date)=0 ");
sql.AppendFormat(" AND [PLAN_DATE] BETWEEN @date1 AND @date2");
parameters.Add(new DataParameter("date1", date.Date));
parameters.Add(new DataParameter("date2", date.Date.AddDays(1)));
parameters.Add(new DataParameter("workcentercode", workcentercode));
//parameters.Add(new DataParameter("date", date));
using (var session = AppDataFactory.CreateMainSession())
{
return (int)session.ExecuteSqlScalar(sql.ToString(), parameters.ToArray());
}
}
catch (Exception ex)
{
throw ex;
}
}
public int SetOrderPrinted(string orderpid)
{
List<DataParameter> parameters = new List<DataParameter>();
StringBuilder sql = new StringBuilder();
sql.AppendLine("UPDATE T_PP_WORKORDER SET PRINTED='1' WHERE PID=@orderpid");
parameters.Add(new DataParameter("orderpid", orderpid));
using (var session = AppDataFactory.CreateMainSession())
{
return session.ExecuteSql(sql.ToString(), parameters.ToArray());
}
}
public List<OrderPlan> GetLastFISPlan(string workcellcode, string routecode)
{
List<DataParameter> parameters = new List<DataParameter>();
StringBuilder sql = new StringBuilder();
sql.AppendLine("SELECT TOP 2 P.* ");
sql.AppendLine(" FROM T_PP_ORDERPLAN AS P WITH(NOLOCK) ");
sql.AppendLine(" LEFT JOIN T_PP_WORKORDER AS W WITH(NOLOCK) ");
sql.AppendLine(" ON W.ORDERPLAN_NO=P.PLAN_NO ");
sql.AppendLine(" WHERE P.PLANSOURCE='0' ");
sql.AppendLine(" AND P.ROUTE_CODE=@routecode ");
sql.AppendLine(" AND ((W.WORKCELL_CODE=@workcellcode ");
sql.AppendLine(" AND W.STATE='4') ");
sql.AppendLine(" OR W.WORKCELL_CODE<>@workcellcode) ");
sql.AppendLine(" ORDER BY P.PLAN_DATE DESC,P.PLAN_SEQ DESC,P.PLAN_NO DESC");
parameters.Add(new DataParameter("workcellcode", workcellcode));
parameters.Add(new DataParameter("routecode", routecode));
using (var session = AppDataFactory.CreateMainSession())
{
return session.GetList<OrderPlan>(sql.ToString(), parameters.ToArray()).ToList();
}
}
}
}