|
|
using ICSSoft.Common;using ICSSoft.Entity;using Newtonsoft.Json;using System;using System.Collections.Generic;using System.Data;using System.Data.SqlClient;using System.Linq;using System.Text;using System.Threading.Tasks;
namespace ICSSoft.DataProject{ /// <summary>
/// 调拨单
/// </summary>
public class TransferDoc { private static log4net.ILog log = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); private static string connString = System.Configuration.ConfigurationManager.AppSettings["ERPConnStr"]; private static string ERPDB = System.Configuration.ConfigurationManager.AppSettings["ERPDB"]; private static string Type = System.Configuration.ConfigurationManager.AppSettings["Type"]; private static string CRNALL = System.Configuration.ConfigurationManager.AppSettings["TransDCRDNAME"]; /// <summary>
/// 审核调拨单
/// </summary>
/// <param name="Bills"></param>
/// <returns></returns>
public bool ConfirmTrans(List<ICSTransferDoc> Bills) { bool ResultFlag = false; string connS = ""; //int num = 0;
SqlConnection conn = new SqlConnection(); SqlCommand cmd = new SqlCommand();
if (Bills.Count <= 0) { throw new Exception("传送数据为空！"); } LogInfo(Bills); List<string> result = Bills.Select(t => t.WorkPoint).Distinct().ToList();
foreach (string WorkPoint in result) { try { connS = string.Format(connString, WorkPoint); conn = new System.Data.SqlClient.SqlConnection(connS); conn.Open(); SqlTransaction sqlTran = conn.BeginTransaction(); cmd = new SqlCommand(); cmd.Transaction = sqlTran; cmd.Connection = conn; foreach (ICSTransferDoc head in Bills) { if (WorkPoint != head.WorkPoint) continue; if (!DBHelper.IsInventoryConsolidation(cmd, head.WorkPoint)) throw new Exception("U8正在整理现存量，请稍后再试");
string[] ss = head.WorkPoint.Split('_'); ERPDB = ss[1]; string sql = ""; ICSUserInfo userInfo = new ICSUserInfo(); userInfo = DBHelper.GetPersonInfo(head.User, cmd); string cIWhCode = string.Empty; string cOWhCode = string.Empty; #region 检查
sql = "select * from dbo.TransVouch where ID='" + head.ID + "';"; DataTable dtCheck = DBHelper.SQlReturnData(sql, cmd); if (dtCheck != null && dtCheck.Rows.Count > 0) { string cHandler = dtCheck.Rows[0]["cVerifyPerson"].ToString(); if (!string.IsNullOrEmpty(cHandler)) { throw new Exception("调拨单ID：" + head.ID + "不是开立状态！"); } cIWhCode = dtCheck.Rows[0]["cIWhCode"].ToString(); cOWhCode = dtCheck.Rows[0]["cOWhCode"].ToString(); sql = string.Format("select * from Warehouse where cWhCode in ('{0}','{1}')", dtCheck.Rows[0]["cOWhCode"].ToString(), dtCheck.Rows[0]["cIWhCode"].ToString()); DataTable dtWh = DBHelper.SQlReturnData(sql, cmd); if (dtWh != null && dtWh.Rows.Count > 1) { } else { throw new Exception("调拨单中转入或者转出仓库不存在！"); } } else { throw new Exception("调拨单ID：" + head.ID + "在U8中不存在！"); } #endregion
#region 审核
sql = "UPDATE dbo.TransVouch SET cVerifyPerson='" + userInfo.UserName + "' ,dVerifyDate=CONVERT(VARCHAR(50),GETDATE(),112),dnverifytime=GETDATE() WHERE ID='" + head.ID + "'"; cmd.CommandText = sql; try { cmd.ExecuteNonQuery(); } catch (Exception ex) { log.Error("审核调拨单失败！异常：" + ex.Message + "；\r\n SQL:" + sql); throw new Exception("程序异常，请联系开发人员！"); } int bodyID = 0; // foreach (ICSTransferDoc body in Bills)
// {
// //回写调出仓库待发数量
// string fOutcBatch = string.Empty;
// //bodyID = Convert.ToInt32(body);
// sql = @"UPDATE a SET fTransOutQuantity=ISNULL(a.fTransOutQuantity,0)-ISNULL(a.iQuantity,0)
// FROM dbo.CurrentStock a
// LEFT JOIN (SELECT a.cOWhCode,a.cIWhCode,b.cInvCode,b.autoID,
// ISNULL(b.cTVBatch,'') AS cTVBatch FROM dbo.TransVouch a
// INNER JOIN dbo.TransVouchs b ON a.cTVCode = b.cTVCode)b
// ON a.cInvCode=b.cInvCode AND a.cBatch=b.cTVBatch and a.cWhCode=b.cOWhCode WHERE b.autoID=@bodyID";
// cmd.Parameters.Clear();
// //cmd.Parameters.Add(new SqlParameter("@Qty", dtCheck.Rows[0]["iQuantity"].ToString()));
// cmd.Parameters.Add(new SqlParameter("@bodyID",body.ID));
// cmd.CommandText = sql;
// try
// {
// cmd.ExecuteNonQuery();
// }
// catch (Exception ex)
// {
// log.Error("回写现存量表 待调拨数量！异常：" + ex.Message + "；\r\n SQL:" + sql);
// throw new Exception("程序异常，请联系开发人员！");
// }
//// #region 判断现存量是否足够
//// sql = @"IF EXISTS(SELECT AutoID FROM dbo.CurrentStock WHERE iQuantity<0 OR iNum<0 OR fTransOutQuantity<0)
//// BEGIN
//// DECLARE @MSG NVARCHAR(100)
//// SELECT @MSG='ERP待调拨出库数量不足！AutoID：'+CAST(AutoID AS NVARCHAR(100)) FROM dbo.CurrentStock WHERE iQuantity<0 OR iNum<0 OR fTransOutQuantity<0
//// RAISERROR(@MSG,16,1)
//// END";
//// cmd.CommandText = sql;
//// cmd.ExecuteNonQuery();
//// #endregion
// //回写调入仓库在途数量
// fOutcBatch = string.Empty;
// sql = @"UPDATE a SET fTransInQuantity=ISNULL(fTransInQuantity,0)-ISNULL(a.iQuantity,0)
// FROM dbo.CurrentStock a
// LEFT JOIN (SELECT a.cOWhCode,a.cIWhCode,b.cInvCode,b.autoID,
// ISNULL(b.cTVBatch,'') AS cTVBatch FROM dbo.TransVouch a
// INNER JOIN dbo.TransVouchs b ON a.cTVCode = b.cTVCode)b
// ON a.cInvCode=b.cInvCode AND a.cBatch=b.cTVBatch and a.cWhCode=b.cIWhCode WHERE b.autoID=@bodyID";
// cmd.Parameters.Clear();
// //cmd.Parameters.Add(new SqlParameter("@Qty", dtCheck.Rows[0]["iQuantity"].ToString()));
// cmd.Parameters.Add(new SqlParameter("@bodyID", body.ID));
// cmd.CommandText = sql;
// try
// {
// cmd.ExecuteNonQuery();
// }
// catch (Exception ex)
// {
// log.Error("回写现存量表在途数量！异常：" + ex.Message + "；\r\n SQL:" + sql);
// throw new Exception("程序异常，请联系开发人员！");
// }
//// #region 判断现存量是否足够
//// sql = @"IF EXISTS(SELECT AutoID FROM dbo.CurrentStock WHERE iQuantity<0 OR iNum<0 OR fTransInQuantity<0)
//// BEGIN
//// DECLARE @MSG NVARCHAR(100)
//// SELECT @MSG='ERP待调拨入库数量不足！AutoID：'+CAST(AutoID AS NVARCHAR(100)) FROM dbo.CurrentStock WHERE iQuantity<0 OR iNum<0 OR fTransInQuantity<0
//// RAISERROR(@MSG,16,1)
//// END";
//// cmd.CommandText = sql;
//// cmd.ExecuteNonQuery();
//// #endregion
// }
#endregion
//0305 形态转换单CartonNum
sql = "select * from dbo.TransVouchs where ID='" + head.ID + "';"; DataTable dtChecks = DBHelper.SQlReturnData(sql, cmd); #region 其他入库单
//取得out库单的默认显示模版
string[] dd = CRNALL.Split('~'); string crdname = dd[2]; string crdname1 = dd[3]; string carname = dd[4]; string carname1 = dd[5]; string surface = dd[6]; string cardnewcode = DBHelper.GetCardNumber(carname, cmd); string cardnewcode1 = DBHelper.GetCardNumber(carname1, cmd);
VouchKey key08 = new VouchKey(); //key08 = U8Helper.GetPrimaryKey("rd", ErpName, 1, cmd);
//// 取得表头单据号
//string Code08 = U8Helper.GetRdrecord08Code(ErpName, "QR", cmd);
var num = dtChecks.Rows.Count; Dictionary<string, int> dic = DBHelper.GetAllCode("" + ERPDB + "", surface, "" + num + "", head.WorkPoint, cmd); int iFatherId = Convert.ToInt32(dic["iFatherId"].ToString()); int iChildId = Convert.ToInt32(dic["iChildId"].ToString()); DateTime date = DateTime.Now; string cRDcode08 = DBHelper.GetRDCode(crdname1, cmd); string iBaseCodeLen = DBHelper.GetAllRDCode(cardnewcode1, "" + date + "", "admin", cRDcode08, head.WorkPoint, cmd);
string DEF_ID08 = DBHelper.GetDefaultTemplate(cardnewcode1, cmd); #region 其他入库单表头
sql = @"INSERT INTO dbo.RdRecord08
(ID,bRdFlag,cVouchType,cBusType,cSource,cBusCode,cWhCode,dDate,cCode,cRdCode, cHandler,cMemo,bTransFlag,cMaker,dVeriDate,bpufirst,biafirst,VT_ID,bIsSTQc,bOMFirst, bFromPreYear,bIsComplement,iDiscountTaxType,ireturncount, iverifystate,iswfcontrolled,dnmaketime,dnverifytime,bredvouch,cSourceLs,cDepCode)
SELECT @ID,'1','08','调拨入库','调拨',a.cTVCode,cIWhCode,CONVERT(NVARCHAR(15),GETDATE(),23),@cCode,@cRdCode, @cHandler,@cMemo,'0',@cMaker,CONVERT(NVARCHAR(15),GETDATE(),23),'0','0', @VT_ID,'0','0','0','0','0','0','0','0',GETDATE(),GETDATE(),'0','1',cIDepCode from dbo.TransVouch a WHERE ID='" + head.ID + "' ";
cmd.Parameters.Clear(); cmd.Parameters.Add(new SqlParameter("@ID", iFatherId)); //cmd.Parameters.Add(new SqlParameter("@cBusCode", head.ID));
cmd.Parameters.Add(new SqlParameter("@cCode", iBaseCodeLen)); cmd.Parameters.Add(new SqlParameter("@cHandler", userInfo.UserName)); cmd.Parameters.Add(new SqlParameter("@cMemo", "")); cmd.Parameters.Add(new SqlParameter("@cMaker", userInfo.UserName)); cmd.Parameters.Add(new SqlParameter("@VT_ID", DEF_ID08)); cmd.Parameters.Add(new SqlParameter("@cRdCode", cRDcode08)); cmd.CommandText = sql; try { cmd.ExecuteNonQuery(); } catch (Exception ex) { log.Error("生成其他入库单表头失败！调拨单ID：" + head.ID + ";异常：" + ex.Message + "；SQL：\r\n" + sql); throw new Exception("程序异常，请联系开发人员！"); } #endregion
#region 3.5 其他入库单表体
for (int i = 0; i < dtChecks.Rows.Count; i++) { #region 3.5.1 表体
sql = @"INSERT INTO dbo.rdrecords08
(AutoID,ID,cInvCode,iQuantity,iSOutQuantity,iSOutNum,iFlag,iTrIds,iNQuantity,iNum, cMassUnit,bLPUseFree,iRSRowNO,iOriTrackID,bCosting,bVMIUsed,iExpiratDateCalcu,iordertype,irowno,cbaccounter,cBatch,iPUnitCost,iPPrice,cFree1,cFree2,cFree3,cFree4,cFree5,cFree6,cFree7,cFree8,cFree9,cFree10) SELECT @AutoID,@ID,cInvCode,a.iTVQuantity,'0','0','0',a.AutoID,iTVQuantity,iTVNum, '0','0','0','0','1','0','0','0',@irowno,null,cTVBatch,iTVPCost,iTVPPrice ,a.cFree1,a.cFree2,a.cFree3,a.cFree4,a.cFree5,a.cFree6,a.cFree7,a.cFree8,a.cFree9,a.cFree10 from TransVouchs a inner join TransVouch b on a.ID=b.ID where a.autoid='" + dtChecks.Rows[i]["AutoID"].ToString() + @"';";
cmd.Parameters.Clear(); cmd.Parameters.Add(new SqlParameter("@AutoID", iChildId)); cmd.Parameters.Add(new SqlParameter("@ID", iFatherId)); cmd.Parameters.Add(new SqlParameter("@irowno", dtChecks.Rows[i]["irowno"].ToString())); cmd.CommandText = sql; try { cmd.ExecuteNonQuery(); } catch (Exception ex) { log.Error("生成其他出库单表体失败！调拨单ID：" + head.ID + "；异常：" + ex.Message + "；SQL：\r\n" + sql); throw new Exception("程序异常，请联系开发人员！"); } #endregion
//更新现存量
key08.cBustypeUN = "调拨入库"; key08.cVouchTypeUN = "08"; key08.TableName = "IA_ST_UnAccountVouch08"; key08.UpdateTodoQuantity = head.UpdateTodoQuantity; //DBHelper.UpdateCurrentStockNEW(cmd, dtChecks.Rows[i]["cInvCode"].ToString(), cIWhCode, dtChecks.Rows[i]["cTVBatch"].ToString(), Convert.ToDecimal(dtChecks.Rows[i]["iTVQuantity"].ToString()), dtChecks.Rows[i]["cFree1"].ToString(), dtChecks.Rows[i]["cFree2"].ToString(), dtChecks.Rows[i]["cFree3"].ToString(), dtChecks.Rows[i]["cFree4"].ToString(), dtChecks.Rows[i]["cFree5"].ToString(), dtChecks.Rows[i]["cFree6"].ToString(), dtChecks.Rows[i]["cFree7"].ToString(), dtChecks.Rows[i]["cFree8"].ToString(), dtChecks.Rows[i]["cFree9"].ToString(), dtChecks.Rows[i]["cFree10"].ToString(), key08);
string inum = dtChecks.Rows[i]["iTVNum"].ToString(); if (inum == "") { inum = "0"; } DBHelper.UpdateCurrentStockCCGC(cmd, dtChecks.Rows[i]["cInvCode"].ToString(), cIWhCode, dtChecks.Rows[i]["cTVBatch"].ToString(), Convert.ToDecimal(dtChecks.Rows[i]["iTVQuantity"].ToString()), Convert.ToDecimal(inum), dtChecks.Rows[i]["cFree1"].ToString(), dtChecks.Rows[i]["cFree2"].ToString(), dtChecks.Rows[i]["cFree3"].ToString(), dtChecks.Rows[i]["cFree4"].ToString(), dtChecks.Rows[i]["cFree5"].ToString(), dtChecks.Rows[i]["cFree6"].ToString(), dtChecks.Rows[i]["cFree7"].ToString(), dtChecks.Rows[i]["cFree8"].ToString(), dtChecks.Rows[i]["cFree9"].ToString(), dtChecks.Rows[i]["cFree10"].ToString(), "", key08, "", "", "", "", 0, 0, 0, 0, head.UpdateTodoQuantity ? (-1 * Convert.ToDecimal(dtChecks.Rows[i]["iTVQuantity"].ToString())) : 0 , head.UpdateTodoQuantity ? (-1 * Convert.ToDecimal(inum)) : 0, 0, 0, iFatherId, iChildId); //DBHelper.UpdateCurrentStock(cmd, dtChecks.Rows[i]["cInvCode"].ToString(), cIWhCode, "", Convert.ToDecimal(dtChecks.Rows[i]["iTVQuantity"].ToString()), key08);
iChildId--; }
#endregion
#endregion
#region 其他出库单
//取得采购入库单单据 表头ID，表体DID
VouchKey key09 = new VouchKey(); //key09 = U8Helper.GetPrimaryKey("rd", ErpName, 1, cmd);
//// 取得表头单据号
//string Code09 = U8Helper.GetRdrecord09Code(ErpName, "QC", cmd);
var nums = dtChecks.Rows.Count; Dictionary<string, int> dics = DBHelper.GetAllCode("" + ERPDB + "", surface, "" + nums + "", head.WorkPoint, cmd); int iFatherIds = Convert.ToInt32(dics["iFatherId"].ToString()); int iChildIds = Convert.ToInt32(dics["iChildId"].ToString()); DateTime dates = DateTime.Now; string cRDcode09 = DBHelper.GetRDCode(crdname, cmd); string iBaseCodeLens = DBHelper.GetAllRDCode(cardnewcode, "" + date + "", "admin", cRDcode09, head.WorkPoint, cmd);
string DEF_ID09 = DBHelper.GetDefaultTemplate(cardnewcode, cmd); #region 其他出库单表头
sql = @"INSERT INTO dbo.RdRecord09
(ID,bRdFlag,cVouchType,cBusType,cSource,cBusCode,cWhCode,dDate,cCode,cRdCode, cHandler,cMemo,bTransFlag,cMaker,dVeriDate,bpufirst,biafirst,VT_ID,bIsSTQc,bOMFirst, bFromPreYear,bIsComplement,iDiscountTaxType,ireturncount, iverifystate,iswfcontrolled,dnmaketime,dnverifytime,bredvouch,cSourceLs,cDepCode)
SELECT @ID,'0','09','调拨出库','调拨',a.cTVCode,cOWhCode,CONVERT(NVARCHAR(15),GETDATE(),23),@cCode,@cRdCode, @cHandler,@cMemo,'0',@cMaker,CONVERT(NVARCHAR(15),GETDATE(),23),'0','0', '85','0','0','0','0','0','0','0','0',GETDATE(),GETDATE(),'0','1',cODepCode from dbo.TransVouch a WHERE ID='" + head.ID + "' ";
cmd.Parameters.Clear(); cmd.Parameters.Add(new SqlParameter("@ID", iFatherIds)); //cmd.Parameters.Add(new SqlParameter("@cBusCode", dtCheck.Rows[0]["cTVCode"].ToString()));
//cmd.Parameters.Add(new SqlParameter("@cWhCode", cOWhCode));
cmd.Parameters.Add(new SqlParameter("@cCode", iBaseCodeLens)); cmd.Parameters.Add(new SqlParameter("@cHandler", userInfo.UserName)); cmd.Parameters.Add(new SqlParameter("@cMemo", "")); cmd.Parameters.Add(new SqlParameter("@cMaker", userInfo.UserName)); cmd.Parameters.Add(new SqlParameter("@VT_ID", DEF_ID09)); cmd.Parameters.Add(new SqlParameter("@cRdCode", cRDcode09)); cmd.CommandText = sql; try { cmd.ExecuteNonQuery(); } catch (Exception ex) { log.Error("生成其他出库单失败！调拨单ID：" + head.ID + "；异常：" + ex.Message + "；SQL：\r\n" + sql); throw new Exception("程序异常，请联系开发人员！"); } #endregion
#region 3.5 其他出库单表体
for (int i = 0; i < dtChecks.Rows.Count; i++) { #region 3.5.1 表体
//判断物料批号与现存量表批号是否一致、数量不能超过现存量物料数量
//sql = @"SELECT cBatch,iQuantity from CurrentStock WHERE cInvCode='" + dtCheck.Rows[0]["cInvCode"].ToString() + "'AND cWhCode='" + dtCheck.Rows[0]["cOWhCode"].ToString() + "'";
//DataTable dtItem = DBHelper.SQlReturnData(sql, cmd);
//if (dtItem != null && dtItem.Rows.Count > 0)
//{
// if (!dtItem.Rows[0]["cBatch"].ToString().Equals(body.cTVBatch))
// {
// throw new Exception("物料条码的批号与U8现存量物料批号不一致,物料:" + body.cInvCode);
// }
// if (Convert.ToDecimal(dtItem.Rows[0]["iQuantity"].ToString()) < body.iQuantity)
// {
// throw new Exception("物料条码的数量大于U8现存量物料数量,物料:" + body.cInvCode);
// }
//}
//else
//{
// throw new Exception("物料:" + body.cInvCode + "在现存量表中不存在!");
//}
//key09.DID += 1;
//Rd09irowno += 1;
sql = @"INSERT INTO dbo.rdrecords09
(AutoID,ID,cInvCode,iQuantity,iSOutQuantity,iSOutNum,iFlag,iTrIds,iNQuantity,iNum, cMassUnit,bLPUseFree,iRSRowNO,iOriTrackID,bCosting,bVMIUsed,iExpiratDateCalcu,iordertype,irowno,cbaccounter,cBatch,iPUnitCost,iPPrice,cFree1,cFree2,cFree3,cFree4,cFree5,cFree6,cFree7,cFree8,cFree9,cFree10) SELECT @AutoID,@ID,cInvCode,a.iTVQuantity,'0','0','0',a.AutoID,iTVQuantity,iTVNum, '0','0','0','0','1','0','0','0',a.irowno,null,cTVBatch,iTVPCost,iTVPPrice ,a.cFree1,a.cFree2,a.cFree3,a.cFree4,a.cFree5,a.cFree6,a.cFree7,a.cFree8,a.cFree9,a.cFree10 from TransVouchs a inner join TransVouch b on a.ID=b.ID where a.autoid='" + dtChecks.Rows[i]["AutoID"].ToString() + @"' ;";
cmd.Parameters.Clear(); cmd.Parameters.Add(new SqlParameter("@AutoID", iChildIds)); cmd.Parameters.Add(new SqlParameter("@ID", iFatherIds));
cmd.CommandText = sql; try { cmd.ExecuteNonQuery(); } catch (Exception ex) { log.Error("生成其他出库单表体失败！调拨单ID：" + head.ID + "；异常：" + ex.Message + "；SQL：\r\n" + sql); throw new Exception("程序异常，请联系开发人员！"); }
sql = @"INSERT INTO dbo.rdrecords09sub
( AutoID , ID ,iBG_Ctrl , iBGSTSum ) values('" + iChildIds + "','" + iFatherIds + "',0,0)";
cmd.CommandText = sql; cmd.ExecuteNonQuery(); #endregion
//更新现存量
key09.cBustypeUN = "调拨出库"; key09.cVouchTypeUN = "09"; key09.TableName = "IA_ST_UnAccountVouch09"; //DBHelper.UpdateCurrentStock(cmd, dtChecks.Rows[i]["cInvCode"].ToString(), cOWhCode, "", -Convert.ToDecimal(dtChecks.Rows[i]["iTVQuantity"].ToString()), key09);
//DBHelper.UpdateCurrentStockNEW(cmd, dtChecks.Rows[i]["cInvCode"].ToString(), cOWhCode, dtChecks.Rows[i]["cTVBatch"].ToString(), -Convert.ToDecimal(dtChecks.Rows[i]["iTVQuantity"].ToString()), dtChecks.Rows[i]["cFree1"].ToString(), dtChecks.Rows[i]["cFree2"].ToString(), dtChecks.Rows[i]["cFree3"].ToString(), dtChecks.Rows[i]["cFree4"].ToString(), dtChecks.Rows[i]["cFree5"].ToString(), dtChecks.Rows[i]["cFree6"].ToString(), dtChecks.Rows[i]["cFree7"].ToString(), dtChecks.Rows[i]["cFree8"].ToString(), dtChecks.Rows[i]["cFree9"].ToString(), dtChecks.Rows[i]["cFree10"].ToString(), key09);
string inum = dtChecks.Rows[i]["iTVNum"].ToString(); if (inum == "") { inum = "0"; } DBHelper.UpdateCurrentStockCCGC(cmd, dtChecks.Rows[i]["cInvCode"].ToString(), cOWhCode, dtChecks.Rows[i]["cTVBatch"].ToString(), -Convert.ToDecimal(dtChecks.Rows[i]["iTVQuantity"].ToString()), -Convert.ToDecimal(inum), dtChecks.Rows[i]["cFree1"].ToString(), dtChecks.Rows[i]["cFree2"].ToString(), dtChecks.Rows[i]["cFree3"].ToString(), dtChecks.Rows[i]["cFree4"].ToString(), dtChecks.Rows[i]["cFree5"].ToString(), dtChecks.Rows[i]["cFree6"].ToString(), dtChecks.Rows[i]["cFree7"].ToString(), dtChecks.Rows[i]["cFree8"].ToString(), dtChecks.Rows[i]["cFree9"].ToString(), dtChecks.Rows[i]["cFree10"].ToString(), "", key09, "", "", "", "", 0, 0, 0, 0, 0, 0, head.UpdateTodoQuantity ? (-1 * Convert.ToDecimal(dtChecks.Rows[i]["iTVQuantity"].ToString())) : 0 , head.UpdateTodoQuantity ? (-1 * Convert.ToDecimal(inum)) : 0, iFatherIds, iChildIds); iChildIds--; }
#endregion
#endregion
cmd.CommandType = CommandType.Text; cmd.Parameters.Clear(); } cmd.Transaction.Commit(); } catch (Exception ex) { if (cmd.Transaction != null) cmd.Transaction.Rollback(); log.Error(ex.Message); throw new Exception(ex.Message); } finally { if (conn.State == ConnectionState.Open) { conn.Close(); } conn.Dispose(); }
} ResultFlag = true; return ResultFlag;
}
/// <summary>
/// 生成无源头调拨单
/// </summary>
/// <param name="Bills"></param>
/// <returns></returns>
public string ConfirmTransIN(List<ICSTransfer> Bills) { string connS = ""; string szJson = ""; DataSet ds = null; string iFatherIdTwo = ""; SqlConnection conn = new SqlConnection(); SqlCommand cmd = new SqlCommand();
if (Bills.Count <= 0) { throw new Exception("传送数据为空！"); } LogInfo1(Bills); //MergeObject(Bills, cmd);
List<string> result = Bills.Select(t => t.WorkPoint).Distinct().ToList();
foreach (string WorkPoint in result) { try { connS = string.Format(connString, WorkPoint); conn = new System.Data.SqlClient.SqlConnection(connS); conn.Open(); SqlTransaction sqlTran = conn.BeginTransaction(); cmd = new SqlCommand(); cmd.Transaction = sqlTran; cmd.Connection = conn; foreach (ICSTransfer head in Bills) { iFatherIdTwo = ""; if (WorkPoint != head.WorkPoint) continue; if (!DBHelper.IsInventoryConsolidation(cmd, head.WorkPoint)) throw new Exception("U8正在整理现存量，请稍后再试");
string[] ss = head.WorkPoint.Split('_'); ERPDB = ss[1];
string[] dd = CRNALL.Split('~'); string crdname = dd[2]; string crdname1 = dd[3]; string carname = dd[4]; string carname1 = dd[5]; string surface = dd[6]; string carname2 = dd[0]; string surface1 = dd[1]; string cardnewcode = DBHelper.GetCardNumber(carname, cmd); string cardnewcode1 = DBHelper.GetCardNumber(carname1, cmd); string cardnewcode2 = DBHelper.GetCardNumber(carname2, cmd); int num = 0; foreach (ICSTransfer nu in Bills) { num = head.details.Count(); }
string sql = ""; ICSUserInfo userInfo = new ICSUserInfo(); userInfo = DBHelper.GetPersonInfo(head.User, cmd); string cIWhCode = string.Empty; string cOWhCode = string.Empty; #region 调拨单
Dictionary<string, int> dic1 = DBHelper.GetAllCode("" + ERPDB + "", surface1, "" + num + "", head.WorkPoint, cmd); int iFather = Convert.ToInt32(dic1["iFatherId"].ToString()); int iChild = Convert.ToInt32(dic1["iChildId"].ToString()); DateTime date = DateTime.Now; string iBaseCode = DBHelper.GetAllRDCode(cardnewcode2, "" + date + "", "admin", "", head.WorkPoint, cmd); string cRDcode2 = DBHelper.GetRDCode(crdname, cmd); string cRDcode1 = DBHelper.GetRDCode(crdname1, cmd); string DEF_ID = DBHelper.GetDefaultTemplate(cardnewcode2, cmd);
sql = @"INSERT INTO dbo.TransVouch
(cTVCode,dTVDate,cOWhCode,cIWhCode,cODepCode,cIDepCode,cIRdCode,cORdCode,cMaker,ID ,VT_ID,itransflag,dnmaketime ,iswfcontrolled,iPrintCount) SELECT @cTVCode,CONVERT(NVARCHAR(15),GETDATE(),23),@cOWhCode,@cIWhCode,@cODepCode,@cIDepCode,@cIRdCode,@cORdCode,@cMaker,@ID ,@VT_ID,'正向',GETDATE() ,0,0
";
cmd.Parameters.Clear(); cmd.Parameters.Add(new SqlParameter("@ID", iFather)); cmd.Parameters.Add(new SqlParameter("@cTVCode", iBaseCode)); cmd.Parameters.Add(new SqlParameter("@cMaker", userInfo.UserName)); cmd.Parameters.Add(new SqlParameter("@VT_ID", DEF_ID)); cmd.Parameters.Add(new SqlParameter("@cIRdCode", cRDcode1)); cmd.Parameters.Add(new SqlParameter("@cORdCode", cRDcode2)); cmd.Parameters.Add(new SqlParameter("@cOWhCode", head.FromWHCode)); cmd.Parameters.Add(new SqlParameter("@cIWhCode", head.ToWHCode)); cmd.Parameters.Add(new SqlParameter("@cODepCode", head.FromDepCode)); cmd.Parameters.Add(new SqlParameter("@cIDepCode", head.ToDepCode)); cmd.CommandText = sql; try { cmd.ExecuteNonQuery(); } catch (Exception ex) { log.Error("生成调拨单表头失败！调拨单：" + iBaseCode + ";异常：" + ex.Message + "；SQL：\r\n" + sql); throw new Exception("程序异常，请联系开发人员！"); } iFatherIdTwo = "'" + iFather + "',"; foreach (ICSTransfers body in head.details) { if (DBHelper.bInvBatch(body.InvCode, cmd) == true) { if (body.BatchCode == "") { log.Error("该物料：" + body.InvCode + "已启用批次，请重新填写！"); throw new Exception("该物料：" + body.InvCode + "已启用批次，请重新填写！"); } } else { if (body.BatchCode != "") { log.Error("该物料：" + body.InvCode + "未启用批次，请重新填写！"); throw new Exception("该物料：" + body.InvCode + "未启用批次，请重新填写！"); } } sql = @" INSERT INTO dbo.TransVouchs
(cTVCode,cInvCode,iTVNum,iTVQuantity,cTVBatch,autoID,ID,bCosting,cItemCode ,iExpiratDateCalcu,irowno,cFree1,cFree2,cFree3,cFree4,cFree5,cFree6,cFree7,cFree8,cFree9,cFree10) SELECT @cTVCode,@cInvCode,@iTVNum,@iTVQuantity,@cTVBatch,@autoID,@ID,1,@cItemCode ,0,@irowno,@cFree1,@cFree2,@cFree3,@cFree4,@cFree5,@cFree6,@cFree7,@cFree8,@cFree9,@cFree10 ";
cmd.Parameters.Clear(); cmd.Parameters.Add(new SqlParameter("@ID", iFather)); cmd.Parameters.Add(new SqlParameter("@cTVCode", iBaseCode)); cmd.Parameters.Add(new SqlParameter("@autoID", iChild)); cmd.Parameters.Add(new SqlParameter("@cInvCode", body.InvCode)); cmd.Parameters.Add(new SqlParameter("@iTVNum", body.Amount.ToString("0.00"))); cmd.Parameters.Add(new SqlParameter("@iTVQuantity", body.Quantity)); cmd.Parameters.Add(new SqlParameter("@irowno", body.Sequence)); cmd.Parameters.Add(new SqlParameter("@cTVBatch", body.BatchCode)); cmd.Parameters.Add(new SqlParameter("@cItemCode", body.ProjectCode)); cmd.Parameters.Add(new SqlParameter("@cFree1", body.cFree1)); cmd.Parameters.Add(new SqlParameter("@cFree2", body.cFree2)); cmd.Parameters.Add(new SqlParameter("@cFree3", body.cFree3)); cmd.Parameters.Add(new SqlParameter("@cFree4", body.cFree4)); cmd.Parameters.Add(new SqlParameter("@cFree5", body.cFree5)); cmd.Parameters.Add(new SqlParameter("@cFree6", body.cFree6)); cmd.Parameters.Add(new SqlParameter("@cFree7", body.cFree7)); cmd.Parameters.Add(new SqlParameter("@cFree8", body.cFree8)); cmd.Parameters.Add(new SqlParameter("@cFree9", body.cFree9)); cmd.Parameters.Add(new SqlParameter("@cFree10", body.cFree10)); cmd.CommandText = sql; iChild--; try { cmd.ExecuteNonQuery(); } catch (Exception ex) { log.Error("生成调拨单子表失败！调拨单：" + iBaseCode + "，行：" + body.Sequence + "；异常：" + ex.Message + "；SQL：\r\n" + sql); throw new Exception("程序异常，请联系开发人员！"); } }
#endregion
#region 检查
sql = "select * from dbo.TransVouch where ID='" + iFather + "';"; DataTable dtCheck = DBHelper.SQlReturnData(sql, cmd); if (dtCheck != null && dtCheck.Rows.Count > 0) { string cHandler = dtCheck.Rows[0]["cVerifyPerson"].ToString(); if (!string.IsNullOrEmpty(cHandler)) { throw new Exception("调拨单：" + iBaseCode + "不是开立状态！"); } cIWhCode = dtCheck.Rows[0]["cIWhCode"].ToString(); cOWhCode = dtCheck.Rows[0]["cOWhCode"].ToString(); sql = string.Format("select * from Warehouse where cWhCode in ('{0}','{1}')", dtCheck.Rows[0]["cOWhCode"].ToString(), dtCheck.Rows[0]["cIWhCode"].ToString()); DataTable dtWh = DBHelper.SQlReturnData(sql, cmd); if (dtWh != null && dtWh.Rows.Count > 1) { } else { throw new Exception("调拨单中转入或者转出仓库不存在！");
} } else { throw new Exception("调拨单：" + iBaseCode + "在U8中不存在！"); } #endregion
#region 审核
sql = "UPDATE dbo.TransVouch SET cVerifyPerson='" + userInfo.UserName + "' ,dVerifyDate=CONVERT(VARCHAR(50),GETDATE(),112),dnverifytime=GETDATE() WHERE cTVCode='" + iBaseCode + "'"; cmd.CommandText = sql; try { cmd.ExecuteNonQuery(); } catch (Exception ex) { log.Error("审核调拨单失败！异常：" + ex.Message + "；\r\n SQL:" + sql); throw new Exception("程序异常，请联系开发人员！"); } int bodyID = 0;
#endregion
sql = "select * from dbo.TransVouchs where ID='" + iFather + "';"; DataTable dtChecks = DBHelper.SQlReturnData(sql, cmd); #region 其他入库单
//取得out库单的默认显示模版
VouchKey key08 = new VouchKey();
num = dtChecks.Rows.Count; Dictionary<string, int> dic = DBHelper.GetAllCode("" + ERPDB + "", surface, "" + num + "", head.WorkPoint, cmd); int iFatherId = Convert.ToInt32(dic["iFatherId"].ToString()); int iChildId = Convert.ToInt32(dic["iChildId"].ToString()); DateTime date1 = DateTime.Now; string cRDcode08 = DBHelper.GetRDCode(crdname1, cmd); string iBaseCodeLen = DBHelper.GetAllRDCode(cardnewcode1, "" + date1 + "", "admin", cRDcode08, head.WorkPoint, cmd);
string DEF_ID08 = DBHelper.GetDefaultTemplate(cardnewcode1, cmd); #region 其他入库单表头
sql = @"INSERT INTO dbo.RdRecord08
(ID,bRdFlag,cVouchType,cBusType,cSource,cBusCode,cWhCode,dDate,cCode,cRdCode, cHandler,cMemo,bTransFlag,cMaker,dVeriDate,bpufirst,biafirst,VT_ID,bIsSTQc,bOMFirst, bFromPreYear,bIsComplement,iDiscountTaxType,ireturncount, iverifystate,iswfcontrolled,dnmaketime,dnverifytime,bredvouch,cSourceLs,cDepCode)
SELECT @ID,'1','08','调拨入库','调拨',a.cTVCode,cIWhCode,CONVERT(NVARCHAR(15),GETDATE(),23),@cCode,@cRdCode, @cHandler,@cMemo,'0',@cMaker,CONVERT(NVARCHAR(15),GETDATE(),23),'0','0', @VT_ID,'0','0','0','0','0','0','0','0',GETDATE(),GETDATE(),'0','1',cIDepCode from dbo.TransVouch a WHERE cTVCode='" + iBaseCode + "' ";
cmd.Parameters.Clear(); cmd.Parameters.Add(new SqlParameter("@ID", iFatherId)); //cmd.Parameters.Add(new SqlParameter("@cBusCode", head.ID));
cmd.Parameters.Add(new SqlParameter("@cCode", iBaseCodeLen)); cmd.Parameters.Add(new SqlParameter("@cHandler", userInfo.UserName)); cmd.Parameters.Add(new SqlParameter("@cMemo", "")); cmd.Parameters.Add(new SqlParameter("@cMaker", userInfo.UserName)); cmd.Parameters.Add(new SqlParameter("@VT_ID", DEF_ID08)); cmd.Parameters.Add(new SqlParameter("@cRdCode", cRDcode08)); cmd.CommandText = sql; try { cmd.ExecuteNonQuery(); } catch (Exception ex) { log.Error("生成其他入库单表头失败！调拨单：" + iBaseCode + ";异常：" + ex.Message + "；SQL：\r\n" + sql); throw new Exception("程序异常，请联系开发人员！"); } #endregion
#region 3.5 其他入库单表体
for (int i = 0; i < dtChecks.Rows.Count; i++) { #region 3.5.1 表体
sql = @"INSERT INTO dbo.rdrecords08
(AutoID,ID,cInvCode,iQuantity,iSOutQuantity,iSOutNum,iFlag,iTrIds,iNQuantity,iNum,cItemCode, cMassUnit,bLPUseFree,iRSRowNO,iOriTrackID,bCosting,bVMIUsed,iExpiratDateCalcu,iordertype,irowno,cbaccounter,cBatch,iPUnitCost,iPPrice,cFree1,cFree2,cFree3,cFree4,cFree5,cFree6,cFree7,cFree8,cFree9,cFree10) SELECT @AutoID,@ID,cInvCode,a.iTVQuantity,'0','0','0',a.AutoID,iTVQuantity,iTVNum,a.cItemCode, '0','0','0','0','1','0','0','0',a.irowno,null,cTVBatch,iTVPCost,iTVPPrice ,a.cFree1,a.cFree2,a.cFree3,a.cFree4,a.cFree5,a.cFree6,a.cFree7,a.cFree8,a.cFree9,a.cFree10 from TransVouchs a inner join TransVouch b on a.ID=b.ID where a.autoid='" + dtChecks.Rows[i]["AutoID"].ToString() + @"';";
cmd.Parameters.Clear(); cmd.Parameters.Add(new SqlParameter("@AutoID", iChildId)); cmd.Parameters.Add(new SqlParameter("@ID", iFatherId));
cmd.CommandText = sql; try { cmd.ExecuteNonQuery(); } catch (Exception ex) { log.Error("生成其他出库单表体失败！调拨单：" + iBaseCode + "；异常：" + ex.Message + "；SQL：\r\n" + sql); throw new Exception("程序异常，请联系开发人员！"); } #endregion
//更新现存量
key08.cBustypeUN = "调拨入库"; key08.cVouchTypeUN = "08"; key08.TableName = "IA_ST_UnAccountVouch08"; key08.UpdateTodoQuantity = head.UpdateTodoQuantity; //DBHelper.UpdateCurrentStockNEW(cmd, dtChecks.Rows[i]["cInvCode"].ToString(), cIWhCode, dtChecks.Rows[i]["cTVBatch"].ToString(), Convert.ToDecimal(dtChecks.Rows[i]["iTVQuantity"].ToString()), dtChecks.Rows[i]["cFree1"].ToString(), dtChecks.Rows[i]["cFree2"].ToString(), dtChecks.Rows[i]["cFree3"].ToString(), dtChecks.Rows[i]["cFree4"].ToString(), dtChecks.Rows[i]["cFree5"].ToString(), dtChecks.Rows[i]["cFree6"].ToString(), dtChecks.Rows[i]["cFree7"].ToString(), dtChecks.Rows[i]["cFree8"].ToString(), dtChecks.Rows[i]["cFree9"].ToString(), dtChecks.Rows[i]["cFree10"].ToString(), key08);
string inum = dtChecks.Rows[i]["iTVNum"].ToString(); if (inum == "") { inum = "0"; }
DBHelper.UpdateCurrentStockCCGC(cmd, dtChecks.Rows[i]["cInvCode"].ToString(), cIWhCode, dtChecks.Rows[i]["cTVBatch"].ToString(), Convert.ToDecimal(dtChecks.Rows[i]["iTVQuantity"].ToString()), Convert.ToDecimal(inum), dtChecks.Rows[i]["cFree1"].ToString(), dtChecks.Rows[i]["cFree2"].ToString(), dtChecks.Rows[i]["cFree3"].ToString(), dtChecks.Rows[i]["cFree4"].ToString(), dtChecks.Rows[i]["cFree5"].ToString(), dtChecks.Rows[i]["cFree6"].ToString(), dtChecks.Rows[i]["cFree7"].ToString(), dtChecks.Rows[i]["cFree8"].ToString(), dtChecks.Rows[i]["cFree9"].ToString(), dtChecks.Rows[i]["cFree10"].ToString(), "", key08, "", "", "", "", 0, 0, 0, 0, 0, 0, 0, 0, iFatherId, iChildId); //DBHelper.UpdateCurrentStock(cmd, dtChecks.Rows[i]["cInvCode"].ToString(), cIWhCode, "", Convert.ToDecimal(dtChecks.Rows[i]["iTVQuantity"].ToString()), key08);
iChildId--; }
#endregion
#endregion
#region 其他出库单
//取得采购入库单单据 表头ID，表体DID
VouchKey key09 = new VouchKey(); //key09 = U8Helper.GetPrimaryKey("rd", ErpName, 1, cmd);
//// 取得表头单据号
//string Code09 = U8Helper.GetRdrecord09Code(ErpName, "QC", cmd);
var nums = dtChecks.Rows.Count + num; Dictionary<string, int> dics = DBHelper.GetAllCode("" + ERPDB + "", surface, "" + nums + "", head.WorkPoint, cmd); int iFatherIds = Convert.ToInt32(dics["iFatherId"].ToString()); int iChildIds = Convert.ToInt32(dics["iChildId"].ToString()); DateTime dates = DateTime.Now; string cRDcode09 = DBHelper.GetRDCode(crdname, cmd); string iBaseCodeLens = DBHelper.GetAllRDCode(cardnewcode, "" + date + "", "admin", cRDcode09, head.WorkPoint, cmd);
string DEF_ID09 = DBHelper.GetDefaultTemplate(cardnewcode, cmd); #region 其他出库单表头
sql = @"INSERT INTO dbo.RdRecord09
(ID,bRdFlag,cVouchType,cBusType,cSource,cBusCode,cWhCode,dDate,cCode,cRdCode, cHandler,cMemo,bTransFlag,cMaker,dVeriDate,bpufirst,biafirst,VT_ID,bIsSTQc,bOMFirst, bFromPreYear,bIsComplement,iDiscountTaxType,ireturncount, iverifystate,iswfcontrolled,dnmaketime,dnverifytime,bredvouch,cSourceLs,cDepCode)
SELECT @ID,'0','09','调拨出库','调拨',a.cTVCode,cOWhCode,CONVERT(NVARCHAR(15),GETDATE(),23),@cCode,@cRdCode, @cHandler,@cMemo,'0',@cMaker,CONVERT(NVARCHAR(15),GETDATE(),23),'0','0', '85','0','0','0','0','0','0','0','0',GETDATE(),GETDATE(),'0','1',cODepCode from dbo.TransVouch a WHERE cTVCode='" + iBaseCode + "' ";
cmd.Parameters.Clear(); cmd.Parameters.Add(new SqlParameter("@ID", iFatherIds)); //cmd.Parameters.Add(new SqlParameter("@cBusCode", dtCheck.Rows[0]["cTVCode"].ToString()));
//cmd.Parameters.Add(new SqlParameter("@cWhCode", cOWhCode));
cmd.Parameters.Add(new SqlParameter("@cCode", iBaseCodeLens)); cmd.Parameters.Add(new SqlParameter("@cHandler", userInfo.UserName)); cmd.Parameters.Add(new SqlParameter("@cMemo", "")); cmd.Parameters.Add(new SqlParameter("@cMaker", userInfo.UserName)); cmd.Parameters.Add(new SqlParameter("@VT_ID", DEF_ID09)); cmd.Parameters.Add(new SqlParameter("@cRdCode", cRDcode09)); cmd.CommandText = sql; try { cmd.ExecuteNonQuery(); } catch (Exception ex) { log.Error("生成其他出库单失败！调拨单：" + iBaseCode + "；异常：" + ex.Message + "；SQL：\r\n" + sql); throw new Exception("程序异常，请联系开发人员！"); } #endregion
#region 3.5 其他出库单表体
for (int i = 0; i < dtChecks.Rows.Count; i++) { #region 3.5.1 表体
//判断物料批号与现存量表批号是否一致、数量不能超过现存量物料数量
//sql = @"SELECT cBatch,iQuantity from CurrentStock WHERE cInvCode='" + dtCheck.Rows[0]["cInvCode"].ToString() + "'AND cWhCode='" + dtCheck.Rows[0]["cOWhCode"].ToString() + "'";
//DataTable dtItem = DBHelper.SQlReturnData(sql, cmd);
//if (dtItem != null && dtItem.Rows.Count > 0)
//{
// if (!dtItem.Rows[0]["cBatch"].ToString().Equals(body.cTVBatch))
// {
// throw new Exception("物料条码的批号与U8现存量物料批号不一致,物料:" + body.cInvCode);
// }
// if (Convert.ToDecimal(dtItem.Rows[0]["iQuantity"].ToString()) < body.iQuantity)
// {
// throw new Exception("物料条码的数量大于U8现存量物料数量,物料:" + body.cInvCode);
// }
//}
//else
//{
// throw new Exception("物料:" + body.cInvCode + "在现存量表中不存在!");
//}
//key09.DID += 1;
//Rd09irowno += 1;
sql = @"INSERT INTO dbo.rdrecords09
(AutoID,ID,cInvCode,iQuantity,iSOutQuantity,iSOutNum,iFlag,iTrIds,iNQuantity,iNum,cItemCode, cMassUnit,bLPUseFree,iRSRowNO,iOriTrackID,bCosting,bVMIUsed,iExpiratDateCalcu,iordertype,irowno,cbaccounter,cBatch,iPUnitCost,iPPrice,cFree1,cFree2,cFree3,cFree4,cFree5,cFree6,cFree7,cFree8,cFree9,cFree10) SELECT @AutoID,@ID,cInvCode,a.iTVQuantity,'0','0','0',a.AutoID,iTVQuantity,iTVNum,a.cItemCode, '0','0','0','0','1','0','0','0',a.irowno,null,cTVBatch,iTVPCost,iTVPPrice ,a.cFree1,a.cFree2,a.cFree3,a.cFree4,a.cFree5,a.cFree6,a.cFree7,a.cFree8,a.cFree9,a.cFree10 from TransVouchs a inner join TransVouch b on a.ID=b.ID where a.autoid='" + dtChecks.Rows[i]["AutoID"].ToString() + @"' ;";
cmd.Parameters.Clear(); cmd.Parameters.Add(new SqlParameter("@AutoID", iChildIds)); cmd.Parameters.Add(new SqlParameter("@ID", iFatherIds));
cmd.CommandText = sql; try { cmd.ExecuteNonQuery(); } catch (Exception ex) { log.Error("生成其他出库单表体失败！调拨单：" + iBaseCode + "；异常：" + ex.Message + "；SQL：\r\n" + sql); throw new Exception("程序异常，请联系开发人员！"); }
sql = @"INSERT INTO dbo.rdrecords09sub
( AutoID , ID ,iBG_Ctrl , iBGSTSum ) values('" + iChildIds + "','" + iFatherIds + "',0,0)";
cmd.CommandText = sql; cmd.ExecuteNonQuery(); #endregion
//更新现存量
key09.cBustypeUN = "调拨出库"; key09.cVouchTypeUN = "09"; key09.TableName = "IA_ST_UnAccountVouch09"; //DBHelper.UpdateCurrentStock(cmd, dtChecks.Rows[i]["cInvCode"].ToString(), cOWhCode, "", -Convert.ToDecimal(dtChecks.Rows[i]["iTVQuantity"].ToString()), key09);
//DBHelper.UpdateCurrentStockNEW(cmd, dtChecks.Rows[i]["cInvCode"].ToString(), cOWhCode, dtChecks.Rows[i]["cTVBatch"].ToString(), -Convert.ToDecimal(dtChecks.Rows[i]["iTVQuantity"].ToString()), dtChecks.Rows[i]["cFree1"].ToString(), dtChecks.Rows[i]["cFree2"].ToString(), dtChecks.Rows[i]["cFree3"].ToString(), dtChecks.Rows[i]["cFree4"].ToString(), dtChecks.Rows[i]["cFree5"].ToString(), dtChecks.Rows[i]["cFree6"].ToString(), dtChecks.Rows[i]["cFree7"].ToString(), dtChecks.Rows[i]["cFree8"].ToString(), dtChecks.Rows[i]["cFree9"].ToString(), dtChecks.Rows[i]["cFree10"].ToString(), key09);
string inum = dtChecks.Rows[i]["iTVNum"].ToString(); if (inum == "") { inum = "0"; }
DBHelper.UpdateCurrentStockCCGC(cmd, dtChecks.Rows[i]["cInvCode"].ToString(), cOWhCode, dtChecks.Rows[i]["cTVBatch"].ToString(), -Convert.ToDecimal(dtChecks.Rows[i]["iTVQuantity"].ToString()), -Convert.ToDecimal(inum), dtChecks.Rows[i]["cFree1"].ToString(), dtChecks.Rows[i]["cFree2"].ToString(), dtChecks.Rows[i]["cFree3"].ToString(), dtChecks.Rows[i]["cFree4"].ToString(), dtChecks.Rows[i]["cFree5"].ToString(), dtChecks.Rows[i]["cFree6"].ToString(), dtChecks.Rows[i]["cFree7"].ToString(), dtChecks.Rows[i]["cFree8"].ToString(), dtChecks.Rows[i]["cFree9"].ToString(), dtChecks.Rows[i]["cFree10"].ToString(), "", key09, "", "", "", "", 0, 0, 0, 0, 0, 0, 0, 0, iFatherIds, iChildIds); iChildIds--; }
#endregion
#endregion
#region 查询
sql = @" select DISTINCT a.ID as ID,a.ID as IDs,a.cTVCode as TransCode,a.cODepCode FromDepCode,c.cDepName FromDepName,a.cOWhCode FromWHCode,e.cWhName FromWHName
,a.cIDepCode ToDepCode,d.cDepName ToDepName,a.cIWhCode ToWHCode,f.cWhName ToWHName ,a.cTranRequestCode as TACode ,a.cMaker as CreateUser ,a.dnmaketime as CreateDateTime ,a.cVerifyPerson as Checker ,a.dnverifytime as CheckDateTime from TransVouch a left join Department c on a.cODepCode=c.cDepCode left join Department d on a.cIDepCode=d.cDepCode left join Warehouse e on a.cOWhCode=e.cWhCode left join Warehouse f on a.cIWhCode=f.cWhCode WHERE A.cVerifyPerson IS NOT NULL AND A.ID in({0})
select DISTINCT a.ID as IDs, b.AutoID as DetailID,b.irowno as Sequence ,b.cInvCode as InvCode , b.iTVQuantity as Quantity ,b.iTVNum as Amount,b.iTRIds as TADetailID,isnull(b.cItemCode,'') ProjectCode,isnull(b.cTVBatch,'') BatchCode,'' version ,'' brand,isnull(b.cFree1,'') as cFree1,isnull(b.cFree2,'') as cFree2,isnull(b.cFree3,'') as cFree3,isnull(b.cFree4,'') as cFree4,isnull(b.cFree5,'') as cFree5,isnull(b.cFree6,'') as cFree6,isnull(b.cFree7,'') as cFree7,isnull(b.cFree8,'') as cFree8,isnull(b.cFree9,'') as cFree9,isnull(b.cFree10,'') as cFree10 from TransVouch a left join TransVouchs b on a.ID=b.ID WHERE A.cVerifyPerson IS NOT NULL AND A.ID in({0}) ";
sql = string.Format(sql, iFatherIdTwo.TrimEnd(',')); if (ds != null) ds.Merge(DBHelper.SQlReturnDataSet(sql, cmd)); else ds = DBHelper.SQlReturnDataSet(sql, cmd);
#endregion
cmd.CommandType = CommandType.Text; cmd.Parameters.Clear(); } cmd.Transaction.Commit(); } catch (Exception ex) { if (cmd.Transaction != null) cmd.Transaction.Rollback(); log.Error(ex.Message); throw new Exception(ex.Message); } finally { if (conn.State == ConnectionState.Open) { conn.Close(); } conn.Dispose(); } } szJson = JSON.DataSetToJson(ds, "details", "IDs"); return szJson;
}
/// <summary>
/// 生成调拨单
/// </summary>
/// <param name="Bills"></param>
/// <returns></returns>
public string ConfirmTrans(List<ICSTransfer> Bills) { string connS = ""; string szJson = ""; DataSet ds = null; string iFatherIdTwo = ""; SqlConnection conn = new SqlConnection(); SqlCommand cmd = new SqlCommand();
if (Bills.Count <= 0) { throw new Exception("传送数据为空！"); }
LogInfo1(Bills); //MergeObject(Bills, cmd);
List<string> result = Bills.Select(t => t.WorkPoint).Distinct().ToList();
foreach (string WorkPoint in result) {
try { connS = string.Format(connString, WorkPoint); conn = new System.Data.SqlClient.SqlConnection(connS); conn.Open(); SqlTransaction sqlTran = conn.BeginTransaction(); cmd = new SqlCommand(); cmd.Transaction = sqlTran; cmd.Connection = conn; foreach (ICSTransfer head in Bills) { iFatherIdTwo = ""; if (WorkPoint != head.WorkPoint) continue; if (!DBHelper.IsInventoryConsolidation(cmd, head.WorkPoint)) throw new Exception("U8正在整理现存量，请稍后再试");
string[] ss = head.WorkPoint.Split('_'); ERPDB = ss[1];
string[] dd = CRNALL.Split('~'); string crdname = dd[2]; string crdname1 = dd[3]; string carname = dd[4]; string carname1 = dd[5]; string surface = dd[6]; string carname2 = dd[0]; string surface1 = dd[1]; string cardnewcode = DBHelper.GetCardNumber(carname, cmd); string cardnewcode1 = DBHelper.GetCardNumber(carname1, cmd); string cardnewcode2 = DBHelper.GetCardNumber(carname2, cmd); int num = 0; foreach (ICSTransfer nu in Bills) { num = head.details.Count(); }
string sql = ""; ICSUserInfo userInfo = new ICSUserInfo(); userInfo = DBHelper.GetPersonInfo(head.User, cmd); string cIWhCode = string.Empty; string cOWhCode = string.Empty; #region 调拨单
sql = "select * from dbo.ST_AppTransVouchs where ID in (select ID from dbo.ST_AppTransVouch where cTVCode='" + head.TACode + "')"; DataTable dtChecks = DBHelper.SQlReturnData(sql, cmd); num = dtChecks.Rows.Count; Dictionary<string, int> dic1 = DBHelper.GetAllCode("" + ERPDB + "", surface1, "" + num + "", head.WorkPoint, cmd); int iFather = Convert.ToInt32(dic1["iFatherId"].ToString()); int iChild = Convert.ToInt32(dic1["iChildId"].ToString()); DateTime date = DateTime.Now; string iBaseCode = DBHelper.GetAllRDCode(cardnewcode2, "" + date + "", "admin", "", head.WorkPoint, cmd); string cRDcode2 = DBHelper.GetRDCode(crdname, cmd); string cRDcode1 = DBHelper.GetRDCode(crdname1, cmd); string DEF_ID = DBHelper.GetDefaultTemplate(cardnewcode2, cmd);
sql = @"INSERT INTO dbo.TransVouch
(cTVCode,dTVDate,cOWhCode,cIWhCode,cODepCode,cIDepCode,cIRdCode,cORdCode,cMaker,ID ,VT_ID,itransflag,dnmaketime ,iswfcontrolled,iPrintCount) SELECT @cTVCode,CONVERT(NVARCHAR(15),GETDATE(),23),@cOWhCode,@cIWhCode,cODepCode,cIDepCode,cIRdCode,cORdCode,@cMaker,@ID ,@VT_ID,'正向',GETDATE() ,0,0 FROM ST_AppTransVouchWHERE cTVCode='" + head.TACode + @"'";
cmd.Parameters.Clear(); cmd.Parameters.Add(new SqlParameter("@ID", iFather)); cmd.Parameters.Add(new SqlParameter("@cTVCode", iBaseCode)); cmd.Parameters.Add(new SqlParameter("@cMaker", userInfo.UserName)); cmd.Parameters.Add(new SqlParameter("@VT_ID", DEF_ID));
cmd.Parameters.Add(new SqlParameter("@cOWhCode", head.FromWHCode)); cmd.Parameters.Add(new SqlParameter("@cIWhCode", head.ToWHCode));
cmd.CommandText = sql; try { cmd.ExecuteNonQuery(); } catch (Exception ex) { log.Error("生成调拨单表头失败！调拨单：" + iBaseCode + ";异常：" + ex.Message + "；SQL：\r\n" + sql); throw new Exception("程序异常，请联系开发人员！"); } iFatherIdTwo += "'" + iFather + "',"; foreach (ICSTransfers body in head.details) { if (DBHelper.bInvBatch(body.InvCode, cmd) == true) { if (body.BatchCode == "") { log.Error("该物料：" + body.InvCode + "已启用批次，请重新填写！"); throw new Exception("该物料：" + body.InvCode + "已启用批次，请重新填写！"); } } else { if (body.BatchCode != "") { log.Error("该物料：" + body.InvCode + "未启用批次，请重新填写！"); throw new Exception("该物料：" + body.InvCode + "未启用批次，请重新填写！"); } } sql = @" INSERT INTO dbo.TransVouchs
(cTVCode,cInvCode,iTVNum,iTVQuantity,cTVBatch,autoID,ID,bCosting,iTRIds,iMPoIds,cmocode,imoseq,cItemCode ,iExpiratDateCalcu,irowno,cFree1,cFree2,cFree3,cFree4,cFree5,cFree6,cFree7,cFree8,cFree9,cFree10) SELECT @cTVCode,@cInvCode,@iTVNum,@iTVQuantity,@cTVBatch,@autoID,@ID,1,autoid,iMPoIds,cmocode,imoseq,@cItemCode ,0,irowno,@cFree1,@cFree2,@cFree3,@cFree4,@cFree5,@cFree6,@cFree7,@cFree8,@cFree9,@cFree10 FROM ST_AppTransVouchs WHERE autoID='" + body.TADetailID + @"'
update A set A.iTvSumQuantity=isnull(A.iTvSumQuantity,0)+B.iTVQuantity,A.iTVSumNum=isnull(A.iTVSumNum,0)+B.iTVNumFROM ST_AppTransVouchs ALEFT JOIN TransVouchs B ON A.autoID=B.iTRIdswhere A.autoID='" + body.TADetailID + @"'";
cmd.Parameters.Clear(); cmd.Parameters.Add(new SqlParameter("@ID", iFather)); cmd.Parameters.Add(new SqlParameter("@cTVCode", iBaseCode)); cmd.Parameters.Add(new SqlParameter("@autoID", iChild)); cmd.Parameters.Add(new SqlParameter("@cInvCode", body.InvCode)); cmd.Parameters.Add(new SqlParameter("@iTVQuantity", body.Quantity)); cmd.Parameters.Add(new SqlParameter("@iTVNum", body.Amount.ToString("0.00"))); cmd.Parameters.Add(new SqlParameter("@cTVBatch", body.BatchCode)); cmd.Parameters.Add(new SqlParameter("@cItemCode", body.ProjectCode)); cmd.Parameters.Add(new SqlParameter("@cFree1", body.cFree1)); cmd.Parameters.Add(new SqlParameter("@cFree2", body.cFree2)); cmd.Parameters.Add(new SqlParameter("@cFree3", body.cFree3)); cmd.Parameters.Add(new SqlParameter("@cFree4", body.cFree4)); cmd.Parameters.Add(new SqlParameter("@cFree5", body.cFree5)); cmd.Parameters.Add(new SqlParameter("@cFree6", body.cFree6)); cmd.Parameters.Add(new SqlParameter("@cFree7", body.cFree7)); cmd.Parameters.Add(new SqlParameter("@cFree8", body.cFree8)); cmd.Parameters.Add(new SqlParameter("@cFree9", body.cFree9)); cmd.Parameters.Add(new SqlParameter("@cFree10", body.cFree10)); cmd.CommandText = sql; iChild--; try { cmd.ExecuteNonQuery(); } catch (Exception ex) { log.Error("生成调拨单子表失败！调拨单：" + iBaseCode + "，行：" + body.Sequence + "；异常：" + ex.Message + "；SQL：\r\n" + sql); throw new Exception("程序异常，请联系开发人员！"); } }
#endregion
#region 检查
sql = "select * from dbo.TransVouch where ID='" + iFather + "';"; DataTable dtCheck = DBHelper.SQlReturnData(sql, cmd); if (dtCheck != null && dtCheck.Rows.Count > 0) { string cHandler = dtCheck.Rows[0]["cVerifyPerson"].ToString(); if (!string.IsNullOrEmpty(cHandler)) { throw new Exception("调拨单：" + iBaseCode + "不是开立状态！"); } cIWhCode = dtCheck.Rows[0]["cIWhCode"].ToString(); cOWhCode = dtCheck.Rows[0]["cOWhCode"].ToString(); sql = string.Format("select * from Warehouse where cWhCode in ('{0}','{1}')", dtCheck.Rows[0]["cOWhCode"].ToString(), dtCheck.Rows[0]["cIWhCode"].ToString()); DataTable dtWh = DBHelper.SQlReturnData(sql, cmd); if (dtWh != null && dtWh.Rows.Count > 1) { } else { throw new Exception("调拨单中转入或者转出仓库不存在！");
} } else { throw new Exception("调拨单：" + iBaseCode + "在U8中不存在！"); } #endregion
#region 审核
sql = "UPDATE dbo.TransVouch SET cVerifyPerson='" + userInfo.UserName + "' ,dVerifyDate=CONVERT(VARCHAR(50),GETDATE(),112),dnverifytime=GETDATE() WHERE cTVCode='" + iBaseCode + "'"; cmd.CommandText = sql; try { cmd.ExecuteNonQuery(); } catch (Exception ex) { log.Error("审核调拨单失败！异常：" + ex.Message + "；\r\n SQL:" + sql); throw new Exception("程序异常，请联系开发人员！"); } int bodyID = 0;
#endregion
sql = "select * from dbo.TransVouchs where ID='" + iFather + "';"; dtChecks = DBHelper.SQlReturnData(sql, cmd); #region 其他入库单
//取得out库单的默认显示模版
VouchKey key08 = new VouchKey();
num = dtChecks.Rows.Count; Dictionary<string, int> dic = DBHelper.GetAllCode("" + ERPDB + "", surface, "" + num + "", head.WorkPoint, cmd); int iFatherId = Convert.ToInt32(dic["iFatherId"].ToString()); int iChildId = Convert.ToInt32(dic["iChildId"].ToString()); DateTime date1 = DateTime.Now; string cRDcode08 = DBHelper.GetRDCode(crdname1, cmd); string iBaseCodeLen = DBHelper.GetAllRDCode(cardnewcode1, "" + date1 + "", "admin", cRDcode08, head.WorkPoint, cmd);
string DEF_ID08 = DBHelper.GetDefaultTemplate(cardnewcode1, cmd); #region 其他入库单表头
sql = @"INSERT INTO dbo.RdRecord08
(ID,bRdFlag,cVouchType,cBusType,cSource,cBusCode,cWhCode,dDate,cCode,cRdCode, cHandler,cMemo,bTransFlag,cMaker,dVeriDate,bpufirst,biafirst,VT_ID,bIsSTQc,bOMFirst, bFromPreYear,bIsComplement,iDiscountTaxType,ireturncount, iverifystate,iswfcontrolled,dnmaketime,dnverifytime,bredvouch,cSourceLs,cDepCode)
SELECT @ID,'1','08','调拨入库','调拨',a.cTVCode,cIWhCode,CONVERT(NVARCHAR(15),GETDATE(),23),@cCode,cIRdCode, @cHandler,@cMemo,'0',@cMaker,CONVERT(NVARCHAR(15),GETDATE(),23),'0','0', @VT_ID,'0','0','0','0','0','0','0','0',GETDATE(),GETDATE(),'0','1',cIDepCode from dbo.TransVouch a WHERE cTVCode='" + iBaseCode + "' ";
cmd.Parameters.Clear(); cmd.Parameters.Add(new SqlParameter("@ID", iFatherId)); //cmd.Parameters.Add(new SqlParameter("@cBusCode", head.ID));
cmd.Parameters.Add(new SqlParameter("@cCode", iBaseCodeLen)); cmd.Parameters.Add(new SqlParameter("@cHandler", userInfo.UserName)); cmd.Parameters.Add(new SqlParameter("@cMemo", "")); cmd.Parameters.Add(new SqlParameter("@cMaker", userInfo.UserName)); cmd.Parameters.Add(new SqlParameter("@VT_ID", DEF_ID08));
cmd.CommandText = sql; try { cmd.ExecuteNonQuery(); } catch (Exception ex) { log.Error("生成其他入库单表头失败！调拨单：" + iBaseCode + ";异常：" + ex.Message + "；SQL：\r\n" + sql); throw new Exception("程序异常，请联系开发人员！"); } #endregion
#region 3.5 其他入库单表体
for (int i = 0; i < dtChecks.Rows.Count; i++) { #region 3.5.1 表体
sql = @"INSERT INTO dbo.rdrecords08
(AutoID,ID,cInvCode,iQuantity,iSOutQuantity,iSOutNum,iFlag,iTrIds,iNQuantity,iNum,cItemCode, cMassUnit,bLPUseFree,iRSRowNO,iOriTrackID,bCosting,bVMIUsed,iExpiratDateCalcu,iordertype,irowno,cbaccounter,cBatch,iPUnitCost,iPPrice,cFree1,cFree2,cFree3,cFree4,cFree5,cFree6,cFree7,cFree8,cFree9,cFree10) SELECT @AutoID,@ID,cInvCode,a.iTVQuantity,'0','0','0',a.AutoID,iTVQuantity,iTVNum,a.cItemCode, '0','0','0','0','1','0','0','0',a.irowno,null,cTVBatch,iTVPCost,iTVPPrice ,a.cFree1,a.cFree2,a.cFree3,a.cFree4,a.cFree5,a.cFree6,a.cFree7,a.cFree8,a.cFree9,a.cFree10 from TransVouchs a inner join TransVouch b on a.ID=b.ID where a.autoid='" + dtChecks.Rows[i]["AutoID"].ToString() + @"';";
cmd.Parameters.Clear(); cmd.Parameters.Add(new SqlParameter("@AutoID", iChildId)); cmd.Parameters.Add(new SqlParameter("@ID", iFatherId));
cmd.CommandText = sql; try { cmd.ExecuteNonQuery(); } catch (Exception ex) { log.Error("生成其他出库单表体失败！调拨单：" + iBaseCode + "；异常：" + ex.Message + "；SQL：\r\n" + sql); throw new Exception("程序异常，请联系开发人员！"); } #endregion
//更新现存量
key08.cBustypeUN = "调拨入库"; key08.cVouchTypeUN = "08"; key08.TableName = "IA_ST_UnAccountVouch08"; key08.UpdateTodoQuantity = head.UpdateTodoQuantity; //DBHelper.UpdateCurrentStockNEW(cmd, dtChecks.Rows[i]["cInvCode"].ToString(), cIWhCode, dtChecks.Rows[i]["cTVBatch"].ToString(), Convert.ToDecimal(dtChecks.Rows[i]["iTVQuantity"].ToString()), dtChecks.Rows[i]["cFree1"].ToString(), dtChecks.Rows[i]["cFree2"].ToString(), dtChecks.Rows[i]["cFree3"].ToString(), dtChecks.Rows[i]["cFree4"].ToString(), dtChecks.Rows[i]["cFree5"].ToString(), dtChecks.Rows[i]["cFree6"].ToString(), dtChecks.Rows[i]["cFree7"].ToString(), dtChecks.Rows[i]["cFree8"].ToString(), dtChecks.Rows[i]["cFree9"].ToString(), dtChecks.Rows[i]["cFree10"].ToString(), key08);
string inum = dtChecks.Rows[i]["iTVNum"].ToString(); if (inum == "") { inum = "0"; } DBHelper.UpdateCurrentStockCCGC(cmd, dtChecks.Rows[i]["cInvCode"].ToString(), cIWhCode, dtChecks.Rows[i]["cTVBatch"].ToString(), Convert.ToDecimal(dtChecks.Rows[i]["iTVQuantity"].ToString()), Convert.ToDecimal(inum), dtChecks.Rows[i]["cFree1"].ToString(), dtChecks.Rows[i]["cFree2"].ToString(), dtChecks.Rows[i]["cFree3"].ToString(), dtChecks.Rows[i]["cFree4"].ToString(), dtChecks.Rows[i]["cFree5"].ToString(), dtChecks.Rows[i]["cFree6"].ToString(), dtChecks.Rows[i]["cFree7"].ToString(), dtChecks.Rows[i]["cFree8"].ToString(), dtChecks.Rows[i]["cFree9"].ToString(), dtChecks.Rows[i]["cFree10"].ToString(), "", key08, "", "", "", "", 0, 0, 0, 0, 0, 0, 0, 0, iFatherId, iChildId); //DBHelper.UpdateCurrentStock(cmd, dtChecks.Rows[i]["cInvCode"].ToString(), cIWhCode, "", Convert.ToDecimal(dtChecks.Rows[i]["iTVQuantity"].ToString()), key08);
iChildId--; }
#endregion
#endregion
#region 其他出库单
//取得采购入库单单据 表头ID，表体DID
VouchKey key09 = new VouchKey(); //key09 = U8Helper.GetPrimaryKey("rd", ErpName, 1, cmd);
//// 取得表头单据号
//string Code09 = U8Helper.GetRdrecord09Code(ErpName, "QC", cmd);
var nums = dtChecks.Rows.Count + num; Dictionary<string, int> dics = DBHelper.GetAllCode("" + ERPDB + "", surface, "" + nums + "", head.WorkPoint, cmd); int iFatherIds = Convert.ToInt32(dics["iFatherId"].ToString()); int iChildIds = Convert.ToInt32(dics["iChildId"].ToString()); DateTime dates = DateTime.Now; string cRDcode09 = DBHelper.GetRDCode(crdname, cmd); string iBaseCodeLens = DBHelper.GetAllRDCode(cardnewcode, "" + date + "", "admin", cRDcode09, head.WorkPoint, cmd);
string DEF_ID09 = DBHelper.GetDefaultTemplate(cardnewcode, cmd); #region 其他出库单表头
sql = @"INSERT INTO dbo.RdRecord09
(ID,bRdFlag,cVouchType,cBusType,cSource,cBusCode,cWhCode,dDate,cCode,cRdCode, cHandler,cMemo,bTransFlag,cMaker,dVeriDate,bpufirst,biafirst,VT_ID,bIsSTQc,bOMFirst, bFromPreYear,bIsComplement,iDiscountTaxType,ireturncount, iverifystate,iswfcontrolled,dnmaketime,dnverifytime,bredvouch,cSourceLs,cDepCode)
SELECT @ID,'0','09','调拨出库','调拨',a.cTVCode,cOWhCode,CONVERT(NVARCHAR(15),GETDATE(),23),@cCode,@cRdCode, @cHandler,@cMemo,'0',@cMaker,CONVERT(NVARCHAR(15),GETDATE(),23),'0','0', '85','0','0','0','0','0','0','0','0',GETDATE(),GETDATE(),'0','1',cODepCode from dbo.TransVouch a WHERE cTVCode='" + iBaseCode + "' ";
cmd.Parameters.Clear(); cmd.Parameters.Add(new SqlParameter("@ID", iFatherIds));
cmd.Parameters.Add(new SqlParameter("@cCode", iBaseCodeLens)); cmd.Parameters.Add(new SqlParameter("@cHandler", userInfo.UserName)); cmd.Parameters.Add(new SqlParameter("@cMemo", "")); cmd.Parameters.Add(new SqlParameter("@cMaker", userInfo.UserName)); cmd.Parameters.Add(new SqlParameter("@VT_ID", DEF_ID09)); cmd.Parameters.Add(new SqlParameter("@cRdCode", cRDcode09)); cmd.CommandText = sql; try { cmd.ExecuteNonQuery(); } catch (Exception ex) { log.Error("生成其他出库单失败！调拨单：" + iBaseCode + "；异常：" + ex.Message + "；SQL：\r\n" + sql); throw new Exception("程序异常，请联系开发人员！"); } #endregion
#region 3.5 其他出库单表体
for (int i = 0; i < dtChecks.Rows.Count; i++) { #region 3.5.1 表体
//判断物料批号与现存量表批号是否一致、数量不能超过现存量物料数量
//sql = @"SELECT cBatch,iQuantity from CurrentStock WHERE cInvCode='" + dtCheck.Rows[0]["cInvCode"].ToString() + "'AND cWhCode='" + dtCheck.Rows[0]["cOWhCode"].ToString() + "'";
//DataTable dtItem = DBHelper.SQlReturnData(sql, cmd);
//if (dtItem != null && dtItem.Rows.Count > 0)
//{
// if (!dtItem.Rows[0]["cBatch"].ToString().Equals(body.cTVBatch))
// {
// throw new Exception("物料条码的批号与U8现存量物料批号不一致,物料:" + body.cInvCode);
// }
// if (Convert.ToDecimal(dtItem.Rows[0]["iQuantity"].ToString()) < body.iQuantity)
// {
// throw new Exception("物料条码的数量大于U8现存量物料数量,物料:" + body.cInvCode);
// }
//}
//else
//{
// throw new Exception("物料:" + body.cInvCode + "在现存量表中不存在!");
//}
//key09.DID += 1;
//Rd09irowno += 1;
sql = @"INSERT INTO dbo.rdrecords09
(AutoID,ID,cInvCode,iQuantity,iSOutQuantity,iSOutNum,iFlag,iTrIds,iNQuantity,iNum,cItemCode, cMassUnit,bLPUseFree,iRSRowNO,iOriTrackID,bCosting,bVMIUsed,iExpiratDateCalcu,iordertype,irowno,cbaccounter,cBatch,iPUnitCost,iPPrice,cFree1,cFree2,cFree3,cFree4,cFree5,cFree6,cFree7,cFree8,cFree9,cFree10) SELECT @AutoID,@ID,cInvCode,a.iTVQuantity,'0','0','0',a.AutoID,iTVQuantity,iTVNum,a.cItemCode, '0','0','0','0','1','0','0','0',a.irowno,null,cTVBatch,iTVPCost,iTVPPrice ,a.cFree1,a.cFree2,a.cFree3,a.cFree4,a.cFree5,a.cFree6,a.cFree7,a.cFree8,a.cFree9,a.cFree10 from TransVouchs a inner join TransVouch b on a.ID=b.ID where a.autoid='" + dtChecks.Rows[i]["AutoID"].ToString() + @"'
update a set a.TransQty=isnull(a.TransQty,0)+b.iTVQuantity from mom_moallocate a left join TransVouchs b on a.AllocateId=b.iMPoIds where b.autoid='" + dtChecks.Rows[i]["AutoID"].ToString() + @"';";
cmd.Parameters.Clear(); cmd.Parameters.Add(new SqlParameter("@AutoID", iChildIds)); cmd.Parameters.Add(new SqlParameter("@ID", iFatherIds));
cmd.CommandText = sql; try { cmd.ExecuteNonQuery(); } catch (Exception ex) { log.Error("生成其他出库单表体失败！调拨单：" + iBaseCode + "；异常：" + ex.Message + "；SQL：\r\n" + sql); throw new Exception("程序异常，请联系开发人员！"); }
sql = @"INSERT INTO dbo.rdrecords09sub
( AutoID , ID ,iBG_Ctrl , iBGSTSum ) values('" + iChildIds + "','" + iFatherIds + "',0,0)";
cmd.CommandText = sql; cmd.ExecuteNonQuery(); #endregion
//更新现存量
key09.cBustypeUN = "调拨出库"; key09.cVouchTypeUN = "09"; key09.TableName = "IA_ST_UnAccountVouch09"; //DBHelper.UpdateCurrentStock(cmd, dtChecks.Rows[i]["cInvCode"].ToString(), cOWhCode, "", -Convert.ToDecimal(dtChecks.Rows[i]["iTVQuantity"].ToString()), key09);
//DBHelper.UpdateCurrentStockNEW(cmd, dtChecks.Rows[i]["cInvCode"].ToString(), cOWhCode, dtChecks.Rows[i]["cTVBatch"].ToString(), -Convert.ToDecimal(dtChecks.Rows[i]["iTVQuantity"].ToString()), dtChecks.Rows[i]["cFree1"].ToString(), dtChecks.Rows[i]["cFree2"].ToString(), dtChecks.Rows[i]["cFree3"].ToString(), dtChecks.Rows[i]["cFree4"].ToString(), dtChecks.Rows[i]["cFree5"].ToString(), dtChecks.Rows[i]["cFree6"].ToString(), dtChecks.Rows[i]["cFree7"].ToString(), dtChecks.Rows[i]["cFree8"].ToString(), dtChecks.Rows[i]["cFree9"].ToString(), dtChecks.Rows[i]["cFree10"].ToString(), key09);
string inum = dtChecks.Rows[i]["iTVNum"].ToString(); if (inum == "") { inum = "0"; } DBHelper.UpdateCurrentStockCCGC(cmd, dtChecks.Rows[i]["cInvCode"].ToString(), cOWhCode, dtChecks.Rows[i]["cTVBatch"].ToString(), -Convert.ToDecimal(dtChecks.Rows[i]["iTVQuantity"].ToString()), Convert.ToDecimal(inum), dtChecks.Rows[i]["cFree1"].ToString(), dtChecks.Rows[i]["cFree2"].ToString(), dtChecks.Rows[i]["cFree3"].ToString(), dtChecks.Rows[i]["cFree4"].ToString(), dtChecks.Rows[i]["cFree5"].ToString(), dtChecks.Rows[i]["cFree6"].ToString(), dtChecks.Rows[i]["cFree7"].ToString(), dtChecks.Rows[i]["cFree8"].ToString(), dtChecks.Rows[i]["cFree9"].ToString(), dtChecks.Rows[i]["cFree10"].ToString(), "", key09, "", "", "", "", 0, 0, 0, 0, 0, 0, 0, 0, iFatherIds, iChildIds); iChildIds--; }
#endregion
#endregion
#region 查询
sql = @" select top 1 a.ID as ID,a.ID as IDs,a.cTVCode as TransCode,a.cODepCode FromDepCode,c.cDepName FromDepName,a.cOWhCode FromWHCode,e.cWhName FromWHName
,a.cIDepCode ToDepCode,d.cDepName ToDepName,a.cIWhCode ToWHCode,f.cWhName ToWHName ,a.cTranRequestCode as TACode ,a.cMaker as CreateUser ,a.dnmaketime as CreateDateTime ,a.cVerifyPerson as Checker ,a.dnverifytime as CheckDateTime from TransVouch a left join Department c on a.cODepCode=c.cDepCode left join Department d on a.cIDepCode=d.cDepCode left join Warehouse e on a.cOWhCode=e.cWhCode left join Warehouse f on a.cIWhCode=f.cWhCode WHERE A.cVerifyPerson IS NOT NULL AND A.ID in({0})
select DISTINCT a.ID as IDs, b.AutoID as DetailID,b.irowno as Sequence ,b.cInvCode as InvCode , b.iTVQuantity as Quantity ,b.iTVNum as Amount,b.iTRIds as TADetailID,isnull(b.cItemCode,'') ProjectCode,isnull(b.cTVBatch,'') BatchCode,'' version ,'' brand,isnull(b.cFree1,'') as cFree1,isnull(b.cFree2,'') as cFree2,isnull(b.cFree3,'') as cFree3,isnull(b.cFree4,'') as cFree4,isnull(b.cFree5,'') as cFree5,isnull(b.cFree6,'') as cFree6,isnull(b.cFree7,'') as cFree7,isnull(b.cFree8,'') as cFree8,isnull(b.cFree9,'') as cFree9,isnull(b.cFree10,'') as cFree10 from TransVouch a left join TransVouchs b on a.ID=b.ID WHERE A.cVerifyPerson IS NOT NULL AND A.ID in({0}) ";
sql = string.Format(sql, iFatherIdTwo.TrimEnd(',')); if (ds != null) ds.Merge(DBHelper.SQlReturnDataSet(sql, cmd)); else ds = DBHelper.SQlReturnDataSet(sql, cmd);
#endregion
cmd.CommandType = CommandType.Text; cmd.Parameters.Clear(); } cmd.Transaction.Commit(); } catch (Exception ex) { if (cmd.Transaction != null) cmd.Transaction.Rollback(); log.Error(ex.Message); throw new Exception(ex.Message); } finally { if (conn.State == ConnectionState.Open) { conn.Close(); } conn.Dispose(); } } szJson = JSON.DataSetToJson(ds, "details", "IDs"); return szJson;
}
/// <summary>
/// 记录日志
/// </summary>
/// <param name="Bills"></param>
private void LogInfo(List<ICSTransferDoc> Bills) { string HeadList = string.Empty; string BodyList = string.Empty; foreach (ICSTransferDoc head in Bills) { HeadList += "\r\n 表头调拨单号：" + head.ID + "，用户：" + head.User + "，站点：" + head.WorkPoint; foreach (ICSTransferDoc body in Bills) { BodyList += "\r\n 表体主键ID： " + body.ID + ""; } } log.Info(HeadList); log.Info(BodyList); }
/// <summary>
/// 记录日志
/// </summary>
/// <param name="Bills"></param>
private void LogInfo1(List<ICSTransfer> Bills) { string HeadList = string.Empty; string BodyList = string.Empty; foreach (ICSTransfer head in Bills) { HeadList += "\r\n 表头调拨单号：" + head.TACode + "，用户：" + head.User + "，站点：" + head.WorkPoint; foreach (ICSTransfer body in Bills) { BodyList += "\r\n 表体主键ID： " + body.TACode + ""; } } log.Info(HeadList); log.Info(BodyList); }
}
}
|
