using System;
using System.Data;
using System.Text;
using System.Collections.Generic;
using System.Data.SqlClient;
using ApServerProvider;
using System.Collections;
using DbCommon;
using Estsh.Web.Util;
/***************************************************************************************************
*
*作者：龚泽宇
* 创建时间：2015.12.21
* 描述：发运管理
* 修改日志：龚泽宇
*
* *************************************************************************************************/
namespace Estsh.Core.Repositories
{
///
/// 数据库访问类，用户管理
///
public class YYBDPrintDal : BaseApp
{
public YYBDPrintDal(RemotingProxy remotingProxy)
: base(remotingProxy)
{
}
public int GetCustPdlineId(int partId)
{
lock (_remotingProxy)
{
string SqlString =
" SELECT top 1 d.cust_pdline_id FROM dbo.sys_part AS a "
+ " LEFT JOIN dbo.sys_model AS b ON a.model_id=b.model_id "
+ " LEFT JOIN dbo.sys_model_type AS c ON b.model_type_id=c.type_id"
+ " LEFT JOIN dbo.sys_cust_pdline AS d ON c.cust_pdline_id=d.cust_pdline_id"
+ " WHERE a.part_type=2 AND a.part_id=" + partId;
//" SELECT (CASE WHEN MAX(order_id) IS NULL THEN '0' ELSE '0' END) +1 as order_id FROM dbo.g_vw_order ";
Hashtable Params = new Hashtable(1);
object obj = _remotingProxy.GetScalar(SqlString, Params);
return obj == null ? 0 : Convert.ToInt32(obj);
}
}
///
/// 根据分页条件获取分页数据列表
///
public Hashtable AA(int PageSize, int PageIndex, string strWhere, string order_no, string txtStartTime, string txtEndTime, string txtStartSeq, string txtEndSeq)
{
lock (_remotingProxy)
{
Hashtable result = new Hashtable();
List parameters = new List();
parameters.Add(new StoreProcedureParameter(DbType.Int32, ParameterDirection.Output, "@TotalCount", 100));
parameters.Add(new StoreProcedureParameter(DbType.Int32, ParameterDirection.Output, "@TotalPage", 100));
parameters.Add(new StoreProcedureParameter(DbType.String, ParameterDirection.Input, "@Table", @" dbo.g_workorder_print_detail AS A
LEFT JOIN dbo.sys_pdline AS b ON a.pdline_id=b.pdline_id
LEFT JOIN dbo.sys_emp AS c ON a.emp_id=c.emp_id "));
parameters.Add(new StoreProcedureParameter(DbType.String, ParameterDirection.Input, "@Column", " a.id,b.pdline_name,a.order_no,a.start_no,a.end_no,a.sort_type,c.emp_name,a.status,a.stortord,a.flag,a.make_print_qty,a.make_print_status,a.create_ymd,a.create_hms "));
parameters.Add(new StoreProcedureParameter(DbType.String, ParameterDirection.Input, "@OrderColumn", " a.id desc"));
parameters.Add(new StoreProcedureParameter(DbType.String, ParameterDirection.Input, "@GroupColumn", ""));
parameters.Add(new StoreProcedureParameter(DbType.Int32, ParameterDirection.Input, "@PageSize", PageSize));
parameters.Add(new StoreProcedureParameter(DbType.Int32, ParameterDirection.Input, "@CurrentPage", PageIndex));
parameters.Add(new StoreProcedureParameter(DbType.Int32, ParameterDirection.Input, "@Group", 0));
parameters.Add(new StoreProcedureParameter(DbType.String, ParameterDirection.Input, "@Condition", strWhere));
Hashtable values = new Hashtable(2);
DataTable dt = new DataTable();
dt = _remotingProxy.ExecuteSotreProcedure("Com_Pagination", parameters, ref values);
ArrayList dataList = DataTypeConvert.NewObject.DataTableToArrayList(dt);
result.Add("dataList", dataList);
result.Add("totalCount", values["@TotalCount"].ToString());
return result;
}
}
public int GetPdlineID(string pdline_name)
{
lock (_remotingProxy)
{
string SqlString = "SELECT pdline_id FROM dbo.sys_pdline WHERE pdline_name=@pdline_name";
Hashtable Params = new Hashtable(1);
Params.Add("@pdline_name", pdline_name);
object obj = _remotingProxy.GetScalar(SqlString, Params);
return obj != null ? Convert.ToInt32(obj) : 0;
}
}
///
/// 未打印
///
///
///
public int stateprint(string id)
{
lock (_remotingProxy)
{
StringBuilder SqlStringBuilder = new StringBuilder(1024);
String delStr = "UPDATE dbo.g_workorder_print_detail SET make_print_status='Y' WHERE id =@id";
Hashtable htparams = new Hashtable();
htparams.Add("@id", id);
return _remotingProxy.ExecuteNonQuery(delStr.ToString(), htparams);
}
}
//public string Getsorttype()
//{
// lock (_remotingProxy)
// {
// StringBuilder SqlStringBuilder = new StringBuilder(1024);
// SqlStringBuilder.Append("SELECT DISTINCT sort_type FROM dbo.sys_part WHERE part_type=0 AND sort_type <>'' AND sort_type IS NOT NULL ");
// object obj = _remotingProxy.GetScalar(SqlStringBuilder.ToString());
// return obj == null ? "" : Convert.ToString(obj);
// }
//}
///
/// 已打印
///
///
///
public int stateChanges1(string order_id)
{
lock (_remotingProxy)
{
String delStr = "UPDATE dbo.g_order SET count='1' WHERE order_id =@order_id";
Hashtable htparams = new Hashtable();
htparams.Add("@order_id", order_id);
return _remotingProxy.ExecuteNonQuery(delStr, htparams);
}
}
///
/// 获取客户产线列表
///
///
public DataTable Getsorttype()
{
lock (_remotingProxy)
{
StringBuilder SqlStringBuilder = new StringBuilder(1024);
SqlStringBuilder.Append("SELECT DISTINCT sort_type as [value],sort_type as [key] FROM dbo.sys_part WHERE part_type=0 AND sort_type <>'' AND sort_type IS NOT NULL ");
return _remotingProxy.GetDataTable(SqlStringBuilder.ToString());
}
}
public bool ifOrderId(string order_seq, int part_id)
{
lock (_remotingProxy)
{
string SqlString =
"select * from g_vw_order where order_seq= @order_seq AND cust_pdline=(SELECT cust_pdline_id FROM sys_part AS A LEFT JOIN sys_model AS B ON A.model_id=B.model_id LEFT JOIN sys_model_type AS C ON B.model_type_id=C.type_id WHERE A.part_id=" + part_id + " ) ";
Hashtable Params = new Hashtable(1);
Params.Add("@order_seq", order_seq);
return _remotingProxy.Exists(SqlString, Params);
}
}
public bool ifOrderId(string order_seq, int part_id, string PackageUnitNumber)
{
lock (_remotingProxy)
{
string SqlString =
"select * from g_vw_order where package_unit_number+order_seq='" + PackageUnitNumber + order_seq + "' AND cust_pdline=(SELECT cust_pdline_id FROM sys_part AS A LEFT JOIN sys_model AS B ON A.model_id=B.model_id LEFT JOIN sys_model_type AS C ON B.model_type_id=C.type_id WHERE A.part_id=" + part_id + " ) ";
Hashtable Params = new Hashtable(1);
return _remotingProxy.Exists(SqlString, Params);
}
}
public bool selectRelationData(int part_id)
{
lock (_remotingProxy)
{
string SqlString =
"select top 1 * from g_part_relation as a left join sys_part as b on a.model_id=b.model_id where b.part_id= " + part_id + "";
Hashtable Params = new Hashtable(1);
return _remotingProxy.Exists(SqlString, Params);
}
}
public bool DeleteData(string order_id)
{
lock (_remotingProxy)
{
string SqlString =
" delete g_ve_order where order_id=@order_id ";
Hashtable Params = new Hashtable(1);
Params.Add("@order_id", order_id);
return _remotingProxy.Exists(SqlString, Params);
}
}
}
}