|
|
using System;
|
|
|
using System.Collections.Generic;
|
|
|
using System.Linq;
|
|
|
using System.Web;
|
|
|
using System.Collections;
|
|
|
using Estsh.Web.Util;
|
|
|
using Estsh.Web.Dal;
|
|
|
using System.Data;
|
|
|
using System.Text;
|
|
|
|
|
|
/***************************************************************************************************
|
|
|
*
|
|
|
* 作者：贾文涛
|
|
|
* 创建时间：2014.07.17
|
|
|
* 描述：成品发运（JIS）业务处理类
|
|
|
* 修改日志：
|
|
|
*
|
|
|
* *************************************************************************************************/
|
|
|
namespace Estsh.Core.Services
|
|
|
{
|
|
|
/// <summary>
|
|
|
/// 成品发运（JIS）业务处理类
|
|
|
/// </summary>
|
|
|
public class ShippingJISService
|
|
|
{
|
|
|
private ShippingJISDal dal = new ShippingJISDal(RemotingProxyProvider._remotingProxy);
|
|
|
|
|
|
#region 成品发运（JIS）
|
|
|
|
|
|
/// <summary>
|
|
|
/// 查询发运数据
|
|
|
/// </summary>
|
|
|
/// <param name="htReq"></param>
|
|
|
/// <returns></returns>
|
|
|
public Hashtable getShippingData(Hashtable htReq)
|
|
|
{
|
|
|
string endCarNo = Convert.ToString(htReq["endCarNo"]);
|
|
|
string endOrderNo = Convert.ToString(htReq["endOrderNo"]);
|
|
|
string endSeq = Convert.ToString(htReq["endSeq"]);
|
|
|
string useNo = Convert.ToString(htReq["useNo"]);
|
|
|
if (useNo != null && useNo.Equals("2"))
|
|
|
{
|
|
|
endCarNo = dal.getCarNobyOrderNo(endOrderNo, endSeq);
|
|
|
}
|
|
|
|
|
|
Hashtable result = new Hashtable();
|
|
|
result.Add("@endCarNo",endCarNo);
|
|
|
if (endCarNo != null && !endCarNo.Equals(""))
|
|
|
{
|
|
|
DataTable retDt = dal.GetShippingJIS(endCarNo, out result);
|
|
|
if (retDt != null)
|
|
|
{
|
|
|
ArrayList dataList = DataTypeConvert.NewObject.DataTableToArrayList(retDt);
|
|
|
result.Add("rows", dataList);
|
|
|
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
result.Add("rows", new ArrayList());
|
|
|
}
|
|
|
if (result.Contains("@startCarNO"))
|
|
|
{
|
|
|
DataTable orderDt = dal.GetOrderNOViaCarNO(result["@startCarNO"].ToString());
|
|
|
if (orderDt != null && orderDt.Rows.Count > 0)
|
|
|
{
|
|
|
result.Add("@startOrderNo", orderDt.Rows[0]["order_no"]);
|
|
|
result.Add("@startSlotNo", orderDt.Rows[0]["slot_no"]);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
result.Add("@retCode","Fail");
|
|
|
result.Add("@retMsg","不能找到此结束单号和序号！");
|
|
|
}
|
|
|
return result;
|
|
|
|
|
|
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 查询车身件订单
|
|
|
/// </summary>
|
|
|
/// <returns></returns>
|
|
|
public Hashtable GetJISCSJOrderNOList()
|
|
|
{
|
|
|
Hashtable result = new Hashtable();
|
|
|
DataTable retDt = dal.QueryCSPartOrder();
|
|
|
if (retDt != null)
|
|
|
{
|
|
|
ArrayList dataList = DataTypeConvert.NewObject.DataTableToArrayList(retDt);
|
|
|
result.Add("list", dataList);
|
|
|
}
|
|
|
return result;
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 查询车身件发运数据
|
|
|
/// </summary>
|
|
|
/// <param name="htReq"></param>
|
|
|
/// <returns></returns>
|
|
|
public Hashtable GetShippingCSJ(Hashtable htReq)
|
|
|
{
|
|
|
string csjOrderNo = Convert.ToString(htReq["csjOrderNo"]);
|
|
|
Hashtable result = new Hashtable();
|
|
|
DataTable retDt = dal.GetShippingCSJ(csjOrderNo, out result);
|
|
|
if (retDt != null)
|
|
|
{
|
|
|
ArrayList dataList = DataTypeConvert.NewObject.DataTableToArrayList(retDt);
|
|
|
result.Add("rows", dataList);
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
result.Add("rows", new ArrayList());
|
|
|
}
|
|
|
return result;
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 提交发运数据
|
|
|
/// </summary>
|
|
|
/// <param name="htReq"></param>
|
|
|
/// <returns></returns>
|
|
|
public Hashtable SubmitShippingData(Hashtable htReq)
|
|
|
{
|
|
|
Hashtable result = new Hashtable();
|
|
|
string chkCarNo = Convert.ToString(htReq["chkCarNo"]);
|
|
|
string plateNumber = Convert.ToString(htReq["plateNumber"]);
|
|
|
string shippingOrder = Convert.ToString(htReq["shippingOrder"]);
|
|
|
string factory = Convert.ToString(htReq["factory"]);
|
|
|
string shippingLocateName = Convert.ToString(htReq["shippingLocateName"]);
|
|
|
string shippingDate = Convert.ToString(htReq["shippingDate"]);
|
|
|
string costomCode = Convert.ToString(htReq["costomCode"]);
|
|
|
string endCarNo = Convert.ToString(htReq["endCarNo"]);
|
|
|
string csjOrderNo = Convert.ToString(htReq["csjOrderNo"]);
|
|
|
string startCarNo = Convert.ToString(htReq["startCarNo"]);
|
|
|
|
|
|
string retMsg = "";
|
|
|
retMsg = dal.CheckParamsValid(factory, shippingLocateName, costomCode);
|
|
|
if (!"PASSED".Equals(retMsg))
|
|
|
{
|
|
|
result.Add("@retCode", "Fail");
|
|
|
result.Add("@retMsg", retMsg);
|
|
|
return result;
|
|
|
}
|
|
|
|
|
|
Hashtable submitData = new Hashtable();
|
|
|
int queryType = 0;
|
|
|
if (chkCarNo != null && chkCarNo.ToLower().Equals("checked"))
|
|
|
{
|
|
|
submitData = GetShippingCSJ(htReq);
|
|
|
queryType = 1;
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
submitData = getShippingData(htReq);
|
|
|
queryType = 0;
|
|
|
}
|
|
|
|
|
|
if (submitData != null && submitData.Contains("rows"))
|
|
|
{
|
|
|
ArrayList submitDataList = (ArrayList)submitData["rows"];
|
|
|
if (submitDataList != null && submitDataList.Count > 0)
|
|
|
{
|
|
|
StringBuilder insertSen = new StringBuilder(409600);
|
|
|
|
|
|
string tabName = "WMS_JIS";
|
|
|
string fields = "ZZ_WMSNUM ,ZZ_CARID ,WERKS ,LGORT ,LFDAT ,KUNNR ,MATNR ,LFIMG ,MEINS,ZPOST,ZTIME";
|
|
|
|
|
|
/*
|
|
|
* ,@retCode VARCHAR(10) OUTPUT -- 存储过程返回代码
|
|
|
,@retMsg VARCHAR(512) OUTPUT -- 存储过程返回信息
|
|
|
*/
|
|
|
insertSen.AppendLine(" DECLARE @retCode VARCHAR(10) ");
|
|
|
insertSen.AppendLine(" DECLARE @retMsg VARCHAR(512) ");
|
|
|
insertSen.AppendLine(" DECLARE @ztime VARCHAR(10) ");
|
|
|
insertSen.AppendLine(" SET @ztime = dbo.get_hms(); ");
|
|
|
insertSen.AppendLine(" BEGIN TRY ");
|
|
|
insertSen.AppendLine(" DECLARE @sretCode VARCHAR(10) ");
|
|
|
insertSen.AppendLine(" DECLARE @sretMsg VARCHAR(512) ");
|
|
|
insertSen.AppendLine(" IF EXISTS (SELECT TOP 1 1 FROM WMS_JIS WHERE ZZ_WMSNUM = '" + plateNumber + "') ");
|
|
|
insertSen.AppendLine(" BEGIN ");
|
|
|
insertSen.AppendLine(" SET @sretCode = 'FAILED'; ");
|
|
|
insertSen.AppendLine(" SET @sretMsg = '此发运单号的数据已经上传过。' ");
|
|
|
insertSen.AppendLine(" SELECT @sretCode AS retCode, @sretMsg AS retMsg ");
|
|
|
insertSen.AppendLine(" RETURN; ");
|
|
|
insertSen.AppendLine(" END ");
|
|
|
insertSen.AppendLine(" BEGIN TRAN ");
|
|
|
Hashtable rows = new Hashtable(); ;
|
|
|
for (int rowIdx = 0; rowIdx < submitDataList.Count; rowIdx++)
|
|
|
{
|
|
|
rows.Clear();
|
|
|
rows = (Hashtable)submitDataList[rowIdx];
|
|
|
if (rows["PartNO"].ToString().Length <= 0)
|
|
|
{
|
|
|
result.Add("@retCode", "Fail");
|
|
|
result.Add("@retMsg", "第" + (rowIdx + 1).ToString() + "行的零件号长度为[0]");
|
|
|
return result;
|
|
|
}
|
|
|
if (rows["Unit"].ToString().Length <= 0)
|
|
|
{
|
|
|
result.Add("@retCode", "Fail");
|
|
|
result.Add("@retMsg", "第" + (rowIdx + 1).ToString() + "行的零件单位长度为[0]");
|
|
|
return result;
|
|
|
}
|
|
|
insertSen.AppendLine(" INSERT INTO " + tabName + " (" + fields + ") VALUES (");
|
|
|
insertSen.Append("'" + shippingOrder + "'");
|
|
|
insertSen.Append(",'" + plateNumber + "'");
|
|
|
insertSen.Append(",'" + factory + "'");
|
|
|
insertSen.Append(",'" + shippingLocateName + "'");
|
|
|
insertSen.Append(",'" + shippingDate + "'");
|
|
|
insertSen.Append(",'" + costomCode + "'");
|
|
|
insertSen.Append(",'" + rows["PartNO"].ToString() + "'"); // part_no
|
|
|
insertSen.Append(",'" + rows["Qty"].ToString() + "'"); // qty
|
|
|
insertSen.Append(",'" + rows["Unit"].ToString() + "'"); // UINT
|
|
|
insertSen.Append(",dbo.wms2sap_ymd(dbo.get_ymd()) "); //DATE
|
|
|
insertSen.Append(",dbo.wms2sap_hms(@ztime) "); //DATE
|
|
|
insertSen.Append("); ");
|
|
|
}
|
|
|
insertSen.AppendLine(" UPDATE sys_sn_seed SET value = value + 1 WHERE sn_name = 'SHIPPING_JIS_WSN' ");
|
|
|
if (queryType == 0)
|
|
|
{
|
|
|
insertSen.AppendLine(" UPDATE sys_base SET param_value = '" + endCarNo + "' WHERE param_name = 'SHIPPING_JIS_LastCarNO' ");
|
|
|
}
|
|
|
insertSen.AppendLine(" COMMIT ");
|
|
|
insertSen.AppendLine(" SET @sretCode = 'PASSED'; ");
|
|
|
insertSen.AppendLine(" SET @sretMsg = '所有语句都已执行' ");
|
|
|
insertSen.AppendLine(" END TRY ");
|
|
|
insertSen.AppendLine(" BEGIN CATCH ");
|
|
|
insertSen.AppendLine(" ROLLBACK ");
|
|
|
insertSen.AppendLine(" SET @sretCode = 'FAILED'; ");
|
|
|
insertSen.AppendLine(" SET @sretMsg = ERROR_MESSAGE(); ");
|
|
|
insertSen.AppendLine(" END CATCH ");
|
|
|
insertSen.AppendLine("SELECT @sretCode AS retCode, @sretMsg AS retMsg ");
|
|
|
|
|
|
DataTable resDT;
|
|
|
result = this.dal.ExecMutilSentenceInBatch(insertSen.ToString(), out resDT);
|
|
|
if (result.Contains("@retCode") && result["@retCode"].Equals("PASSED"))
|
|
|
{
|
|
|
if (resDT != null && resDT.Rows.Count > 0)
|
|
|
{
|
|
|
retMsg = resDT.Rows[0]["retMsg"].ToString();
|
|
|
if (!resDT.Rows[0]["retCode"].ToString().StartsWith("PASSED", StringComparison.CurrentCultureIgnoreCase)) //语句执行出错了
|
|
|
{
|
|
|
result.Add("@retCode", "Fail");
|
|
|
result.Add("@retMsg", retMsg);
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
retMsg= "数据已向SAP提交成功。";
|
|
|
if (queryType == 1)
|
|
|
{
|
|
|
result = this.dal.UpdateCSJStatus(csjOrderNo, "S", "C");
|
|
|
if (result.Contains("@retCode") && result["@retCode"].ToString().ToUpper().Equals("PASSED"))
|
|
|
{
|
|
|
retMsg += ";更新车身件数据成功(" + result["@retMsg"] + ")";
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
retMsg += ";更新车身件数据失败(" + result["@retMsg"] + ")";
|
|
|
}
|
|
|
}
|
|
|
if (queryType == 0)
|
|
|
{
|
|
|
result = this.dal.UpdateZCStatus(startCarNo, endCarNo, "6", "100");
|
|
|
if (result.Contains("@retCode") && result["@retCode"].ToString().ToUpper().Equals("PASSED"))
|
|
|
{
|
|
|
retMsg += ";更新总成发运数据成功(" + result["@retMsg"] + ")";
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
retMsg += ";更新总成发运数据失败(" + result["@retMsg"] + ")";
|
|
|
}
|
|
|
}
|
|
|
if (result.Contains("@retMsg"))
|
|
|
{
|
|
|
result.Remove("@retMsg");
|
|
|
result.Add("@retMsg", retMsg);
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
result.Add("@retMsg", retMsg);
|
|
|
}
|
|
|
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
result.Add("@retCode", "Fail");
|
|
|
result.Add("@retMsg", "已提交完成或待提交的数据为空！请重新查询数据！");
|
|
|
}
|
|
|
}
|
|
|
return result;
|
|
|
}
|
|
|
#endregion
|
|
|
}
|
|
|
} |