You cannot select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

234 lines
8.8 KiB
C#

This file contains ambiguous Unicode characters!

This file contains ambiguous Unicode characters that may be confused with others in your current locale. If your use case is intentional and legitimate, you can safely ignore this warning. Use the Escape button to highlight these characters.

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
{
/// <summary>
/// 数据库访问类,用户管理
/// </summary>
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);
}
}
/// <summary>
/// 根据分页条件获取分页数据列表
/// </summary>
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<StoreProcedureParameter> parameters = new List<StoreProcedureParameter>();
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;
}
}
/// <summary>
/// 未打印
/// </summary>
/// <param name="order_id"></param>
/// <returns></returns>
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);
// }
//}
/// <summary>
/// 已打印
/// </summary>
/// <param name="order_id"></param>
/// <returns></returns>
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);
}
}
/// <summary>
/// 获取客户产线列表
/// </summary>
/// <returns></returns>
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);
}
}
}
}