|
|
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 PurchaseReceiveDoc { 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["PurRDCRDNAME"]; /// <summary>
/// 获取采购入库单
/// </summary>
/// <param name="infos">传入参数</param>
/// <returns></returns>
public string Get(List<ICSPurchaseReceiveDoc> infos) { List<ICSPurchaseReceiveDoc> szJson = new List<ICSPurchaseReceiveDoc>(); DataTable dt = null; DataTable dtNEW = null; string json = ""; string connS = ""; if (infos.Count <= 0) { throw new Exception("传送数据为空！"); } string res = string.Empty; SqlConnection conn = new SqlConnection(); SqlCommand cmd = new SqlCommand(); string sql = string.Empty; foreach (ICSPurchaseReceiveDoc info in infos) { try { connS = string.Format(connString, info.WorkPoint); conn = new System.Data.SqlClient.SqlConnection(connS); conn.Open(); SqlTransaction sqlTran = conn.BeginTransaction(); cmd = new SqlCommand(); cmd.Transaction = sqlTran; cmd.Connection = conn;
ICSUserInfo userInfo = new ICSUserInfo(); userInfo = DBHelper.GetPersonInfo(info.User, cmd); if (info.MTime < new DateTime(2000, 01, 01)) throw new Exception("请输入正确的操作时间：" + info.MTime); sql = @"select a.ID,a.cCode,a.cVenCode,''as cVenName,cWhCode,''as cWhName,cARVCode,cMaker,dnmaketime,cHandler,dVeriDate,
AutoID,irowno,cInvCode,iQuantity,iNum,iUnitCost,iArrsId FROM RdRecord01 a LEFT JOIN rdrecords01 b on a.ID=b.ID INNER JOIN DEPARTMENT C ON A.CDEPCODE=C.CDEPCODE INNER JOIN VENDOR D ON A.CVENCODE=D.CVENCODE WHERE 1=1";
if (!string.IsNullOrWhiteSpace(info.RCVTCode)) { sql += " and a.cCode='{0}'"; } if (!string.IsNullOrWhiteSpace(info.MTime.ToString())) { sql += " and ISNULL(a.dnverifytime , ISNULL(a.dnmodifytime , a.dnmaketime ))>='{1}'"; } if (!string.IsNullOrWhiteSpace(info.User)) { sql += "and a.CMAKER='{2}'"; } sql = string.Format(sql, info.RCVTCode, info.MTime, userInfo.UserName); dt = DBHelper.SQlReturnData(sql, cmd); if (dt.Rows.Count <= 0 || dt == null) throw new Exception("采购入库单：" + info.RCVTCode + "，无信息！"); dtNEW.Merge(dt); cmd.Transaction.Commit(); } catch (Exception ex) { cmd.Transaction.Rollback(); log.Error(ex.Message); throw new Exception(ex.Message); } finally { if (conn.State == ConnectionState.Open) { conn.Close(); } conn.Dispose(); } } json = JsonConvert.SerializeObject(dtNEW); return json; } ///<summary>
//创建采购入库单(采购订单)
///</summary>
///<param name="Bills"></param>
///<returns></returns>
public string CreateRdRecord01sByPO(List<ICSPurchaseReceiveDoc> Bills) { string cCode = ""; string szJson = ""; string gys = ""; int isEnable = 0; string connS = ""; string sql = ""; string iFatherIdTwo = ""; DataSet ds = null; decimal iTaxRate = 0; DateTime time = DateTime.Now; int num = 0; VouchKey key = new VouchKey(); List<ICSPOArrive> datas = new List<ICSPOArrive>(); if (Bills.Count <= 0) { throw new Exception("传送数据为空！"); } string res = string.Empty; SqlConnection conn = new SqlConnection(); SqlCommand cmd = new SqlCommand(); 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 (ICSPurchaseReceiveDoc 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]; num = head.details.Count();
ICSUserInfo userInfo = new ICSUserInfo(); userInfo = DBHelper.GetPersonInfo(head.User, cmd);
string[] dd = CRNALL.Split('~'); string crdname = dd[0]; string carname = dd[1]; string surface = dd[2]; string cardnewcode = DBHelper.GetCardNumber(carname, cmd); Dictionary<string, int> dic = DBHelper.GetAllCode("" + ERPDB + "", surface, "" + num + "", head.WorkPoint); int iFatherId = Convert.ToInt32(dic["iFatherId"].ToString()); int iChildId = Convert.ToInt32(dic["iChildId"].ToString()); DateTime date = DateTime.Now; string cRDcode = DBHelper.GetRDCode(crdname, cmd); string iBaseCodeLen = DBHelper.GetAllRDCode(cardnewcode, "" + time + "", "admin", cRDcode, head.WorkPoint); string DEF_ID = DBHelper.GetDefaultTemplate(cardnewcode, cmd);
if (head.MTime < new DateTime(2000, 01, 01)) throw new Exception("请输入正确的操作时间：" + head.MTime);
#region 验证入库数量不能大于采购订单数量
// foreach (ICSPurchaseReceiveDocs body in head.details)
// {
// sql = @"SELECT a.iQuantity,a.ID,isnull(a.iReceivedQTY,0) as iReceivedQTY,isnull(a.freceivedqty,0) as freceivedqty,ISNULL(c.fInExcess,0) AS fInExcess
// FROM dbo.PO_Podetails a
// INNER JOIN dbo.PO_Pomain b ON a.POID=b.POID
// LEFT JOIN PU_ArrivalVouch d ON b.cPOID=d.cpocode
// LEFT JOIN dbo.Inventory c ON a.cInvCode=c.cInvCode
// WHERE d.cCode ='" + head.DNCode + "'";
// cmd.CommandText = sql;
// DataTable dtQty = DBHelper.SQlReturnData(sql, cmd);
// if (dtQty != null && dtQty.Rows.Count > 0)
// {
// decimal fInExcess = decimal.Parse(dtQty.Rows[0]["fInExcess"].ToString());//入库超额上限
// decimal PoQty = decimal.Parse(dtQty.Rows[0]["iQuantity"].ToString());
// decimal iReceicedQty = decimal.Parse(dtQty.Rows[0]["iReceivedQTY"].ToString());//累计到货数量
// decimal freceivedqty = decimal.Parse(dtQty.Rows[0]["freceivedqty"].ToString());//合格品入库数量
// PoQty = PoQty * (1 + fInExcess);
// log.Info("PO数量:" + PoQty.ToString()+ "入库超额上限:" + fInExcess.ToString() + ",累计到货数量:" + iReceicedQty.ToString() + ",合格品入库数量:" + freceivedqty.ToString());
// //2021-11-05 回写字段变更,见行408
// //decimal to = PoQty - iReceicedQty - freceivedqty;
// decimal to = PoQty - freceivedqty;
// if (body.Quantity > to)
// {
// throw new Exception("入库数量" + body.Quantity.ToString("f3") + "大于采购订单可入库数量" + to.ToString("f3")
// );
// }
// }
// }
#endregion
if (head.Enable == true) { sql = @"SELECT a.POID,a.cVenCode FROM PO_Pomain a
LEFT JOIN PU_ArrivalVouch b ON a.cPOID=b.cpocode WHERE a.cBusType='代管采购' and b.cCode ='" + head.DNCode + "' ";
DataTable dtCheck = DBHelper.SQlReturnData(sql, cmd); if (dtCheck != null && dtCheck.Rows.Count > 0) { gys = dtCheck.Rows[0][1].ToString(); isEnable = 0; sql = @"SELECT cWhCode FROM Warehouse WHERE bProxyWh ='1' "; dtCheck = DBHelper.SQlReturnData(sql, cmd); if (dtCheck != null && dtCheck.Rows.Count > 0) { foreach (DataRow item in dtCheck.Rows) { if (head.WHCode == item["cWhCode"].ToString()) { isEnable++; } }
} if (isEnable == 0) { throw new Exception("该仓库：" + head.WHCode + @"不是代管仓，请重新输入！"); }
}
sql = @"SELECT POID FROM PO_Pomain a
LEFT JOIN PU_ArrivalVouch b ON a.cPOID=b.cpocode WHERE a.cBusType='固定资产' and b.cCode ='" + head.DNCode + "' ";
dtCheck = DBHelper.SQlReturnData(sql, cmd); if (dtCheck != null && dtCheck.Rows.Count > 0) { int isZL = 0; sql = @"SELECT cWhCode FROM Warehouse WHERE bWhAsset ='1' "; dtCheck = DBHelper.SQlReturnData(sql, cmd); if (dtCheck != null && dtCheck.Rows.Count > 0) { foreach (DataRow item in dtCheck.Rows) { if (head.WHCode == item["cWhCode"].ToString()) { isZL++; } }
} if (isZL == 0) { throw new Exception("该仓库：" + head.WHCode + @"不是资产仓，请重新输入！"); }
} }
#region 采购入库单表头
string BusType = "";//业务类型
sql = @"select a.POID,a.cPOID,a.cVenCode,a.cDepCode,a.cexch_name,a.iTaxRate,a.cMaker,
a.nflat,a.cPersonCode,a.cptcode,a.cBusType FROM dbo.PO_Pomain a WHERE a.cPOID ='" + head.POCode + "'";
cmd.CommandText = sql; DataTable dtPOMain = DBHelper.SQlReturnData(sql, cmd); if (dtPOMain != null && dtPOMain.Rows.Count > 0) { string cSource = ""; cCode = ""; int bredvouch = 0;
string WHCode = ""; BusType = dtPOMain.Rows[0]["cBusType"].ToString(); //校验采购订单类型是固定资产仓库
if (BusType.Equals("固定资产")) { string sqlwh = @"SELECT bWhAsset FROM Warehouse WHERE cWhCode='" + head.WHCode + "'"; cmd.CommandText = sqlwh; DataTable dtwhcode = DBHelper.SQlReturnData(sqlwh, cmd); log.Info(dtwhcode.Rows[0]["bWhAsset"].ToString()); if (!dtwhcode.Rows[0]["bWhAsset"].ToString().Equals("True")) { throw new Exception("到货单:" + dtPOMain.Rows[0]["cPOID"].ToString() + ",业务类型:固定资产,只能入固定资产仓库!"); } else { WHCode = head.WHCode; } } else { WHCode = head.WHCode; }
cSource = "普通采购"; cCode = dtPOMain.Rows[0]["cPOID"].ToString(); bredvouch = 0;
string cfcode = string.Empty; string zq = string.Empty; string lz = string.Empty; string dz = string.Empty;
sql = @"select a.cCode,a.iLZYJ,a.iLZFS,iPLNum,dblZQNum,c.dDate,
(case when ilzfs=1 then dateadd(day,-day(getdate()),dateadd(month,1,getdate())) else DATEADD(day,isnull(iPLNum,0),c.dDate) end) lz,DATEADD(day,isnull(dblZQNum,0),DATEADD(day,isnull(iPLNum,0),c.dDate)) dz from (select b.cVenPUOMProtocol,a.cvencode,a.dDate,a.cCode from PU_ArrivalVouch a left join Vendor b on a.cvencode=b.cvencode where a.cCode='" + cCode + @"' ) c left join AA_Agreement a on a.cCode=c.cVenPUOMProtocol
";
DataTable dtDisCheck1 = DBHelper.SQlReturnData(sql, cmd); if (dtDisCheck1 != null && dtDisCheck1.Rows.Count > 0) { foreach (DataRow item in dtDisCheck1.Rows) { if (item["iLZYJ"].ToString() == "10" & (item["iLZFS"].ToString() == "0" | item["iLZFS"].ToString() == "1")) { cfcode = item["cCode"].ToString(); zq = item["dblZQNum"].ToString(); lz = item["lz"].ToString(); dz = item["dz"].ToString(); } else { if (item["cCode"].ToString() == "") cfcode = item["cCode"].ToString(); } } }
sql = @"
INSERT INTO dbo.RdRecord01 (ID ,bRdFlag ,cVouchType ,cBusType ,cSource , cWhCode ,dDate ,cCode ,cRdCode ,cDepCode , cPersonCode ,cVenCode ,cOrderCode , cHandler ,bTransFlag ,cMaker,cDefine1,cDefine2, dVeriDate ,bpufirst ,biafirst , dARVDate ,VT_ID , bIsSTQc ,ipurorderid ,iTaxRate ,iExchRate ,cExch_Name , bOMFirst ,bFromPreYear ,bIsComplement ,iDiscountTaxType ,ireturncount , iverifystate ,iswfcontrolled ,cModifyPerson ,dnmaketime ,dnverifytime , bredvouch ,bCredit ,iPrintCount,cPTCode,cVenPUOMProtocol,iCreditPeriod,dCreditStart,dGatheringDate)
SELECT @ID,1,'01',a.cBusType,@cSource, @cWhCode,@dDate,@cCode,@cRdCode,@cDepCode, @cPersonCode,a.cVenCode,a.cPOID, @cHandler,0,@cMaker,a.cDefine1,a.cDefine2, @cVeriDate,0,0,@dARVDate,@VT_ID, 0,@ipurorderid,a.iTaxRate,a.nflat,a.cexch_name, 0,0,0,0,0, 0,0,'',@dnmakertime,@dnverifytime, @bredvouch,0,0,a.cPTCode,@cVenPUOMProtocol,@iCreditPeriod,@dCreditStart,@dGatheringDate FROM dbo.PO_Pomain a --LEFT JOIN PU_ArrivalVouch b ON a.cPOID=b.cpocode WHERE a.cPOID ='" + head.POCode + "'";
cmd.Parameters.Clear(); cmd.Parameters.Add(new SqlParameter("@ID", iFatherId)); cmd.Parameters.Add(new SqlParameter("@cSource", cSource)); cmd.Parameters.Add(new SqlParameter("@cWhCode", WHCode)); cmd.Parameters.Add(new SqlParameter("@dDate", Convert.ToDateTime(DateTime.Now).ToString("yyyy -MM-dd"))); cmd.Parameters.Add(new SqlParameter("@cCode", iBaseCodeLen)); cmd.Parameters.Add(new SqlParameter("@cDepCode", dtPOMain.Rows[0]["cDepCode"].ToString())); cmd.Parameters.Add(new SqlParameter("@cPersonCode", dtPOMain.Rows[0]["cPersonCode"].ToString())); //cmd.Parameters.Add(new SqlParameter("@cARVCode", cCode));
cmd.Parameters.Add(new SqlParameter("@cMaker", userInfo.UserName)); cmd.Parameters.Add(new SqlParameter("@cVeriDate", Convert.ToDateTime(DateTime.Now).ToString("yyyy-MM-dd"))); cmd.Parameters.Add(new SqlParameter("@dARVDate", Convert.ToDateTime(head.MTime))); cmd.Parameters.Add(new SqlParameter("@VT_ID", DEF_ID)); cmd.Parameters.Add(new SqlParameter("@ipurorderid", dtPOMain.Rows[0]["POID"].ToString())); cmd.Parameters.Add(new SqlParameter("@dnmakertime", Convert.ToDateTime(DateTime.Now).ToString())); cmd.Parameters.Add(new SqlParameter("@dnverifytime", Convert.ToDateTime(DateTime.Now).ToString())); cmd.Parameters.Add(new SqlParameter("@bredvouch", bredvouch)); //cmd.Parameters.Add(new SqlParameter("@ipurarriveid", dtPOMain.Rows[0]["ID"].ToString()));
cmd.Parameters.Add(new SqlParameter("@cHandler", userInfo.UserName)); cmd.Parameters.Add(new SqlParameter("@cRdCode", cRDcode)); cmd.Parameters.Add(new SqlParameter("@cVenPUOMProtocol", cfcode)); cmd.Parameters.Add(new SqlParameter("@iCreditPeriod", zq)); cmd.Parameters.Add(new SqlParameter("@dCreditStart", lz)); cmd.Parameters.Add(new SqlParameter("@dGatheringDate", dz));
cmd.CommandText = sql; try { int count = cmd.ExecuteNonQuery(); if (count <= 0) { log.Error("生成采购入库单表头失败，受影响行数<=0；"); throw new Exception("生成采购入库单表头失败，受影响行数<=0；"); } } catch (Exception ex) { log.Error("生成采购入库单表头失败！异常：" + ex.Message + "；SQL：\r\n" + sql, ex); throw new Exception("生成采购入库单表头失败！异常：" + ex.Message + "；SQL：\r\n" + sql, ex); } }
else { throw new Exception("对应采购订单不存在！采购订单号：" + head.POCode); } #endregion
#region 采购入库单表体
foreach (ICSPurchaseReceiveDocs body in head.details) { //if (head.IsReturn == "1")
//{
// body.iQuantity = -body.iQuantity;
//}
sql = @"SELECT a.id,a.cInvCode,a.iUnitPrice ,a.iMoney AS 原币无税金额 ,a.ivouchrowno,
a.iTax AS 原币税额 ,a.iSum AS 原币价税合计 ,a.iNatUnitPrice , a.iNatMoney AS 本币无税金额 ,a.iNatTax AS 本币税额 ,a.iNatSum AS 本币价税合计 , a.iTaxPrice ,a.freceivedqty AS 合格品入库数量 ,a.iPerTaxRate FROM dbo.PO_Podetails a INNER JOIN dbo.PO_Pomain b ON a.POID=b.POID WHERE b.cPOID ='" + head.POCode + "'";
cmd.CommandText = sql; DataTable dtPODetails = DBHelper.SQlReturnData(sql, cmd); decimal iUnitPrice = 0; decimal iNatUnitPrice = 0; decimal iTaxPrice = 0; string id = ""; string code = ""; string dates = "";
if (dtPODetails != null && dtPODetails.Rows.Count > 0) {
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 + "未启用批次，请重新填写！"); } } if (!string.IsNullOrEmpty(dtPODetails.Rows[0]["iUnitPrice"].ToString())) iUnitPrice = decimal.Parse(dtPODetails.Rows[0]["iUnitPrice"].ToString());//原币无税单价
if (!string.IsNullOrEmpty(dtPODetails.Rows[0]["iNatUnitPrice"].ToString())) iNatUnitPrice = decimal.Parse(dtPODetails.Rows[0]["iNatUnitPrice"].ToString());//本币无税单价
if (!string.IsNullOrEmpty(dtPODetails.Rows[0]["iTaxPrice"].ToString())) iTaxPrice = decimal.Parse(dtPODetails.Rows[0]["iTaxPrice"].ToString());//原币含税单价
iTaxRate = Convert.ToDecimal(dtPODetails.Rows[0]["iPerTaxRate"]); sql = @"INSERT INTO dbo.rdrecords01
( AutoID ,ID ,cInvCode ,iNum ,iQuantity ,cItemCode, iUnitCost ,iPrice ,iAPrice ,cBatch ,iFlag , dSDate ,iSQuantity ,iSNum ,iMoney ,iPOsID , fACost ,iNQuantity ,chVencode ,iOriTaxCost ,iOriCost , iOriMoney ,iOriTaxPrice ,ioriSum ,iTaxRate ,iTaxPrice , iSum ,bTaxCost ,cPOID ,iMatSettleState ,iBillSettleCount , bLPUseFree ,iOriTrackID ,cbaccounter ,dbKeepDate ,bCosting , iSumBillQuantity ,bVMIUsed ,iExpiratDateCalcu ,isotype ,irowno, iArrsId,cbarvcode,dbarvdate,cFree1,cFree2,cFree3,cFree4,cFree5, cFree6,cFree7,cFree8,cFree9,cFree10 )
select @AutoID,@ID1,@cInvCode,@iNum,@iQuantity,@cItemCode, @iUnitCost,@iPrice,@iAPrice,@cBatch,0, null,0,0,0,a.ID, @fACost,@iNQuantity,b.cVenCode,@iOriTaxCost,@iOriCost, @iOriMoney,@iOriTaxPrice,@ioriSum,@iTaxRate,@iTaxPrice, @iSum,1,@cPOID,0,0, 0,0,null,null,d.bInCost, null,0,0,0,@irowno, @iArrsId,@cbarvcode,@dbarvdate,@cFree1,@cFree2,@cFree3,@cFree4,@cFree5, @cFree6,@cFree7,@cFree8,@cFree9,@cFree10 FROM dbo.PO_Podetails a INNER JOIN dbo.PO_Pomain b ON a.POID = b.POID INNER JOIN dbo.Warehouse d ON d.cWhCode = '{0}' WHERE a.ID ='" + body.PODetailID + @"'EXEC PROC_Update_PO_RdRecord01 @ID= @ID1";
sql = string.Format(sql, head.WHCode); cmd.Parameters.Clear(); cmd.Parameters.Add(new SqlParameter("@AutoID", iChildId)); cmd.Parameters.Add(new SqlParameter("@ID1", iFatherId)); cmd.Parameters.Add(new SqlParameter("@cInvCode", body.InvCode)); cmd.Parameters.Add(new SqlParameter("@iQuantity", body.Quantity)); cmd.Parameters.Add(new SqlParameter("@iNum", body.Amount.ToString("0.00"))); cmd.Parameters.Add(new SqlParameter("@iUnitCost", iUnitPrice)); cmd.Parameters.Add(new SqlParameter("@iPrice", Math.Round(body.Quantity * iUnitPrice, 2))); cmd.Parameters.Add(new SqlParameter("@iAPrice", Math.Round(body.Quantity * iUnitPrice, 2))); cmd.Parameters.Add(new SqlParameter("@cBatch", body.BatchCode)); cmd.Parameters.Add(new SqlParameter("@cItemCode", body.ProjectCode)); //cmd.Parameters.Add(new SqlParameter("@iSQuantity", 0));
//cmd.Parameters.Add(new SqlParameter("@iMoney", 0));
cmd.Parameters.Add(new SqlParameter("@fACost", iNatUnitPrice)); cmd.Parameters.Add(new SqlParameter("@iNQuantity", body.Quantity)); cmd.Parameters.Add(new SqlParameter("@iOriTaxCost", iTaxPrice)); cmd.Parameters.Add(new SqlParameter("@iOriCost", body.Quantity * iUnitPrice)); cmd.Parameters.Add(new SqlParameter("@iOriMoney", iUnitPrice)); cmd.Parameters.Add(new SqlParameter("@iOriTaxPrice", Math.Round(body.Quantity * iUnitPrice, 2))); cmd.Parameters.Add(new SqlParameter("@ioriSum", Math.Round(Math.Round(iTaxPrice * body.Quantity, 2) - Math.Round(body.Quantity * iUnitPrice, 2), 2))); cmd.Parameters.Add(new SqlParameter("@iTaxRate", Math.Round(iTaxPrice * body.Quantity, 2))); cmd.Parameters.Add(new SqlParameter("@iTaxPrice", iTaxRate)); cmd.Parameters.Add(new SqlParameter("@iSum", Math.Round(Math.Round(iTaxPrice * body.Quantity, 2) - Math.Round(body.Quantity * iUnitPrice, 2), 2))); cmd.Parameters.Add(new SqlParameter("@irowno", body.Sequence)); cmd.Parameters.Add(new SqlParameter("@cPOID", cCode)); cmd.Parameters.Add(new SqlParameter("@iArrsId", id)); cmd.Parameters.Add(new SqlParameter("@cbarvcode", code)); cmd.Parameters.Add(new SqlParameter("@dbarvdate", dates)); 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; try { int count = cmd.ExecuteNonQuery(); if (count <= 0) { log.Error("生成采购入库单表体失败，受影响行数<=0；"); throw new Exception("生成采购入库单表体失败，受影响行数<=0；"); } } catch (Exception ex) { log.Error("生成采购入库单表体失败！异常：" + ex.Message + "；SQL：\r\n" + sql, ex); throw new Exception("生成采购入库单表体失败！异常：" + ex.Message + "；SQL：\r\n" + sql, ex); } #endregion
#region 更新[采购到货单子表]PU_ArrivalVouchs 合格品入库数量20211019
sql = @"UPDATE PU_ArrivalVouchs SET fValidInQuan=ISNULL(fValidInQuan,0)+@iQty WHERE Autoid=@Autoid"; cmd.CommandText = sql; cmd.Parameters.Clear(); cmd.Parameters.Add(new SqlParameter("@iQty", body.Quantity)); cmd.Parameters.Add(new SqlParameter("@Autoid", body.DNDetailID)); try { log.Info("PU_Autoid:" + body.DNDetailID); cmd.ExecuteNonQuery(); } catch (Exception ex) { log.Error("回写采购到货单子表合格品入库数量失败：Autoid：" + body.DNDetailID + ";异常：" + ex.Message); throw new Exception("程序异常，请联系开发人员！"); } #endregion
#region 更新[采购订单子表]PO_PODetails累计到货数量和累计到货金额
//sql = @"Update a set iReceivedQTY =isnull(iReceivedQTY ,0)+ @iQty,iReceivedMoney=isnull(iReceivedMoney,0)+@iMoney FROM dbo.PO_Podetails a where a.ID='" + body.iPOsID + "'";
sql = @"
Update a set iReceivedMoney=isnull(iReceivedMoney,0)+@iMoney ,freceivedqty=isnull(freceivedqty ,0)+ @iQty FROM dbo.PO_Podetails a where a.ID=@ID"
; //2021-11-05
//1.移除 iReceivedQTY =isnull(iReceivedQTY ,0)+ @iQty 由采购到货,创建到货单CreatePU时写入iReceivedQTY,此处不再回写,累计到货数量
//2.加入 freceivedqty =isnull(freceivedqty ,0) + @iQty 合格品入库数量
cmd.CommandText = sql; cmd.Parameters.Clear(); cmd.Parameters.Add(new SqlParameter("@iQty", body.Quantity)); cmd.Parameters.Add(new SqlParameter("@iMoney", body.Quantity * iUnitPrice)); cmd.Parameters.Add(new SqlParameter("@ID", body.PODetailID)); try { log.Info("iPOsID:" + body.PODetailID); int i = cmd.ExecuteNonQuery(); } catch (Exception ex) { log.Error("回写采购订单累计到货数量和累计到货金额失败：采购订单表体行号：" + body.DNDetailID + ";异常：" + ex.Message); throw new Exception("程序异常，请联系开发人员！"); } #endregion
//string sqls = @"SELECT freceivedqty,iQuantity FROM dbo.PO_Podetails WHERE ID={0} ";
//sqls = string.Format(sqls, body.PODetailID);
//DataTable dtPODetailss = DBHelper.SQlReturnData(sqls, cmd);
#region 判断现存量是否超入库
sql = @"IF EXISTS(SELECT ID FROM dbo.PO_Podetails WHERE isnull(freceivedqty,0)>iQuantity AND ID={0} )
BEGIN DECLARE @MSG NVARCHAR(100) SELECT @MSG='ERP入库数量不能大于订单数量！ID：'+CAST(ID AS NVARCHAR(100)) FROM dbo.PO_Podetails WHERE isnull(freceivedqty,0)>iQuantity AND ID={0} RAISERROR(@MSG,16,1) END";
sql = string.Format(sql, body.PODetailID); cmd.CommandText = sql; cmd.ExecuteNonQuery(); #endregion
sql = @"select isnull(fValidInQuan,0)fOutQuantity,isnull(iQuantity,0)iQuantity,ISNULL(iNum, 0)iNum,ISNULL(NiNum, 0)NiNum,ISNULL(iNum, 0)-ISNULL(NiNum, 0) SiNum from PU_ArrivalVouchs a
LEFT JOIN (select sum(iNum) NiNum,iArrsId from rdrecords01 GROUP BY iArrsId) b on a.ID=b.iArrsId where a.Autoid='" + body.PODetailID + "'";
DataTable dtDisCheck = DBHelper.SQlReturnData(sql, cmd); if (dtDisCheck != null && dtDisCheck.Rows.Count > 0) { foreach (DataRow item in dtDisCheck.Rows) { if (Convert.ToDecimal(item["fOutQuantity"].ToString()) == Convert.ToDecimal(item["iQuantity"].ToString())) { if (Convert.ToDecimal(item["iNum"].ToString()) != 0) { if (Convert.ToDecimal(item["SiNum"].ToString()) != 0) { sql = @"Update rdrecords01 set iNum=isnull(iNum,0)+(" + item["SiNum"].ToString() + ") where autoid='" + iChildId + "' "; body.Amount = (Convert.ToDecimal(body.Amount.ToString("0.00"))) + (Convert.ToDecimal(item["SiNum"].ToString())); DBHelper.CmdExecuteNonQuery(sql, cmd, "辅计量余数处理失败！"); } } } }
} //if (isEnable != 0)
//{
// key.cBustypeUN = "普通采购";
// key.cVouchTypeUN = "01";
// key.TableName = "IA_ST_UnAccountVouch01";
// //DBHelper.UpdateCurrentStock(cmd, body.InvCode, head.WHCode, "", body.Quantity, key);
// DBHelper.UpdateCurrentStockNEWDG(cmd, body.InvCode, head.WHCode, body.BatchCode, body.Quantity, body.cFree1, body.cFree2, body.cFree3, body.cFree4, body.cFree5, body.cFree6, body.cFree7, body.cFree8, body.cFree9, body.cFree10, gys, key);
//}
//else
//{
// //更新现存量
// key.cBustypeUN = "普通采购";
// key.cVouchTypeUN = "01";
// key.TableName = "IA_ST_UnAccountVouch01";
// //DBHelper.UpdateCurrentStock(cmd, body.InvCode, head.WHCode, body.InvCode, body.Quantity, key);
// DBHelper.UpdateCurrentStockNEW(cmd, body.InvCode, head.WHCode, body.BatchCode, body.Quantity, body.cFree1, body.cFree2, body.cFree3, body.cFree4, body.cFree5, body.cFree6, body.cFree7, body.cFree8, body.cFree9, body.cFree10, key);
//}
key.cBustypeUN = "普通采购"; key.cVouchTypeUN = "01"; key.TableName = "IA_ST_UnAccountVouch01"; DBHelper.UpdateCurrentStockCCGC(cmd, body.InvCode, head.WHCode, body.BatchCode, body.Quantity, body.Amount, body.cFree1, body.cFree2, body.cFree3, body.cFree4, body.cFree5, body.cFree6, body.cFree7, body.cFree8, body.cFree9, body.cFree10, gys, key, "", "", "", "", 0, 0, 0, 0, 0, 0, 0, 0, iFatherId, iChildId);
////更新主键ID，DID
//DBHelper.UpdateIDandDID("rd", head.list.Count(), cmd);
iFatherIdTwo = "'" + iFatherId + "',"; iChildId--; }
}
#region 查询
sql = @" select top 1 a.ID as ID,a.ID as IDs,a.cCode as RCVTCode,a.cVenCode,D.cVenName,
a.cWhCode,c.cWhName,cARVCode as DNCode,cMaker as CreateUser, dnmaketime as CreateDateTime,cHandler as Checker,dVeriDate as CheckDateTime FROM RdRecord01 a INNER JOIN Warehouse C ON a.cWhCode=C.cWhCode INNER JOIN VENDOR D ON A.CVENCODE=D.CVENCODE WHERE 1=1 and a.ID in ({0})
select DISTINCT a.ID as IDs, AutoID as DetailID,irowno as Sequence, cInvCode as InvCode,iQuantity as Quantity,iNum as Amount,iPOsID as PODetailID,isnull(b.cItemCode,'') ProjectCode,isnull(b.cbatch,'') cBatch,'' 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 RdRecord01 a LEFT JOIN rdrecords01 b on a.ID=b.ID --INNER JOIN DEPARTMENT C ON A.CDEPCODE=C.CDEPCODE --INNER JOIN VENDOR D ON A.CVENCODE=D.CVENCODE WHERE 1=1 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.Transaction.Commit(); } catch (Exception ex) { 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 CreateRdRecord01sByPOArrive(List<ICSPurchaseReceiveDoc> Bills) { string szJson = ""; string connS = ""; string gys = ""; int isEnable = 0; DataSet ds = null; string iFatherIdTwo = ""; decimal iTaxRate = 0; DateTime time = DateTime.Now; int num = 0; string sql = ""; VouchKey key = new VouchKey(); //int iBaseCodeLen = Convert.ToInt32(dic["iBaseCodeLen"].ToString());
//int cVouchCodeBase = Convert.ToInt32(dic["cVouchCodeBase"].ToString());
List<ICSPOArrive> datas = new List<ICSPOArrive>(); if (Bills.Count <= 0) { throw new Exception("传送数据为空！"); } string res = string.Empty; SqlConnection conn = new SqlConnection(); SqlCommand cmd = new SqlCommand();
List<string> result = Bills.Select(t => t.WorkPoint).Distinct().ToList();
foreach (string WorkPoint in result) { iFatherIdTwo = ""; 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 (ICSPurchaseReceiveDoc 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]; num = head.details.Count;
string[] dd = CRNALL.Split('~'); string crdname = dd[0]; string carname = dd[1]; string surface = dd[2]; string cardnewcode = DBHelper.GetCardNumber(carname, cmd); Dictionary<string, int> dic = DBHelper.GetAllCode("" + ERPDB + "", surface, "" + num + "", head.WorkPoint); int iFatherId = Convert.ToInt32(dic["iFatherId"].ToString()); int iChildId = Convert.ToInt32(dic["iChildId"].ToString()); DateTime date = DateTime.Now; string cRDcode = DBHelper.GetRDCode(crdname, cmd); string iBaseCodeLen = DBHelper.GetAllRDCode(cardnewcode, "" + time + "", "admin", cRDcode, head.WorkPoint); string DEF_ID = DBHelper.GetDefaultTemplate(cardnewcode, cmd);
ICSUserInfo userInfo = new ICSUserInfo(); userInfo = DBHelper.GetPersonInfo(head.User, cmd);
if (head.MTime < new DateTime(2000, 01, 01)) throw new Exception("请输入正确的操作时间：" + head.MTime);
#region 验证入库数量不能大于采购订单数量
// foreach (ICSPurchaseReceiveDocs body in head.details)
// {
// sql = @"SELECT a.iQuantity,a.ID,isnull(a.iReceivedQTY,0) as iReceivedQTY,isnull(a.freceivedqty,0) as freceivedqty,ISNULL(c.fInExcess,0) AS fInExcess
// FROM dbo.PO_Podetails a
// INNER JOIN dbo.PO_Pomain b ON a.POID=b.POID
// LEFT JOIN PU_ArrivalVouch d ON b.cPOID=d.cpocode
// LEFT JOIN dbo.Inventory c ON a.cInvCode=c.cInvCode
// WHERE d.cCode ='" + head.DNCode + "'";
// cmd.CommandText = sql;
// DataTable dtQty = DBHelper.SQlReturnData(sql, cmd);
// if (dtQty != null && dtQty.Rows.Count > 0)
// {
// decimal fInExcess = decimal.Parse(dtQty.Rows[0]["fInExcess"].ToString());//入库超额上限
// decimal PoQty = decimal.Parse(dtQty.Rows[0]["iQuantity"].ToString());
// decimal iReceicedQty = decimal.Parse(dtQty.Rows[0]["iReceivedQTY"].ToString());//累计到货数量
// decimal freceivedqty = decimal.Parse(dtQty.Rows[0]["freceivedqty"].ToString());//合格品入库数量
// PoQty = PoQty * (1 + fInExcess);
// log.Info("PO数量:" + PoQty.ToString()+ "入库超额上限:" + fInExcess.ToString() + ",累计到货数量:" + iReceicedQty.ToString() + ",合格品入库数量:" + freceivedqty.ToString());
// //2021-11-05 回写字段变更,见行408
// //decimal to = PoQty - iReceicedQty - freceivedqty;
// decimal to = PoQty - freceivedqty;
// if (body.Quantity > to)
// {
// throw new Exception("入库数量" + body.Quantity.ToString("f3") + "大于采购订单可入库数量" + to.ToString("f3")
// );
// }
// }
// }
#endregion
if (head.Enable == true) { sql = @"SELECT a.POID,a.cVenCode FROM PO_Pomain a
LEFT JOIN PU_ArrivalVouch b ON a.cPOID=b.cpocode WHERE a.cBusType='代管采购' and b.cCode ='" + head.DNCode + "' ";
DataTable dtCheck = DBHelper.SQlReturnData(sql, cmd); if (dtCheck != null && dtCheck.Rows.Count > 0) { gys = dtCheck.Rows[0][1].ToString(); isEnable = 0; sql = @"SELECT cWhCode FROM Warehouse WHERE bProxyWh ='1' "; dtCheck = DBHelper.SQlReturnData(sql, cmd); if (dtCheck != null && dtCheck.Rows.Count > 0) { foreach (DataRow item in dtCheck.Rows) { if (head.WHCode == item["cWhCode"].ToString()) { isEnable++; } }
} if (isEnable == 0) { throw new Exception("该仓库：" + head.WHCode + @"不是代管仓，请重新输入！"); }
}
sql = @"SELECT POID FROM PO_Pomain a
LEFT JOIN PU_ArrivalVouch b ON a.cPOID=b.cpocode WHERE a.cBusType='固定资产' and b.cCode ='" + head.DNCode + "' ";
dtCheck = DBHelper.SQlReturnData(sql, cmd); if (dtCheck != null && dtCheck.Rows.Count > 0) { int isZL = 0; sql = @"SELECT cWhCode FROM Warehouse WHERE bWhAsset ='1' "; dtCheck = DBHelper.SQlReturnData(sql, cmd); if (dtCheck != null && dtCheck.Rows.Count > 0) { foreach (DataRow item in dtCheck.Rows) { if (head.WHCode == item["cWhCode"].ToString()) { isZL++; } }
} if (isZL == 0) { throw new Exception("该仓库：" + head.WHCode + @"不是资产仓，请重新输入！"); }
}
}
#region 采购入库单表头
string BusType = "";//业务类型
sql = @"select a.POID,a.cPOID,a.cVenCode,isnull(a.cDepCode,b.cDepCode) cDepCode,a.cexch_name,a.iTaxRate,a.cMaker,
a.nflat,a.cPersonCode,a.cptcode ,b.ID,b.cCode,a.cBusType FROM dbo.PO_Pomain a LEFT JOIN PU_ArrivalVouch b ON a.cPOID=b.cpocode WHERE b.cCode ='" + head.DNCode + "'";
cmd.CommandText = sql; DataTable dtPOMain = DBHelper.SQlReturnData(sql, cmd); if (dtPOMain != null && dtPOMain.Rows.Count > 0) { string cSource = ""; string cCode = ""; int bredvouch = 0;
string WHCode = ""; BusType = dtPOMain.Rows[0]["cBusType"].ToString(); //校验采购订单类型是固定资产仓库
if (BusType.Equals("固定资产")) { string sqlwh = @"SELECT bWhAsset FROM Warehouse WHERE cWhCode='" + head.WHCode + "'"; cmd.CommandText = sqlwh; DataTable dtwhcode = DBHelper.SQlReturnData(sqlwh, cmd); log.Info(dtwhcode.Rows[0]["bWhAsset"].ToString()); if (!dtwhcode.Rows[0]["bWhAsset"].ToString().Equals("True")) { throw new Exception("到货单:" + dtPOMain.Rows[0]["cPOID"].ToString() + ",业务类型:固定资产,只能入固定资产仓库!"); } else { WHCode = head.WHCode; } } else { WHCode = head.WHCode; }
cSource = "采购到货单"; cCode = dtPOMain.Rows[0]["cCode"].ToString(); bredvouch = 0;
string cfcode = string.Empty; string zq = string.Empty; string lz = string.Empty; string dz = string.Empty;
sql = @"select a.cCode,a.iLZYJ,a.iLZFS,iPLNum,dblZQNum,c.dDate,
(case when ilzfs=1 then dateadd(day,-day(getdate()),dateadd(month,1,getdate())) else DATEADD(day,isnull(iPLNum,0),c.dDate) end) lz,DATEADD(day,isnull(dblZQNum,0),DATEADD(day,isnull(iPLNum,0),c.dDate)) dz from (select b.cVenPUOMProtocol,a.cvencode,a.dDate,a.cCode from PU_ArrivalVouch a left join Vendor b on a.cvencode=b.cvencode where a.cCode='" + cCode + @"' ) c left join AA_Agreement a on a.cCode=c.cVenPUOMProtocol
";
DataTable dtDisCheck1 = DBHelper.SQlReturnData(sql, cmd); if (dtDisCheck1 != null && dtDisCheck1.Rows.Count > 0) { foreach (DataRow item in dtDisCheck1.Rows) { if (item["iLZYJ"].ToString() == "10" & (item["iLZFS"].ToString() == "0" | item["iLZFS"].ToString() == "1")) { cfcode = item["cCode"].ToString(); zq = item["dblZQNum"].ToString(); lz = item["lz"].ToString(); dz = item["dz"].ToString(); } else { if (item["cCode"].ToString() == "") cfcode = item["cCode"].ToString(); } } }
sql = @"
INSERT INTO dbo.RdRecord01 (ID ,bRdFlag ,cVouchType ,cBusType ,cSource , cWhCode ,dDate ,cCode ,cRdCode ,cDepCode , cPersonCode ,cVenCode ,cOrderCode ,cARVCode, cHandler ,bTransFlag ,cMaker,cDefine1,cDefine2, dVeriDate ,bpufirst ,biafirst , dARVDate ,VT_ID , bIsSTQc ,ipurorderid ,iTaxRate ,iExchRate ,cExch_Name , bOMFirst ,bFromPreYear ,bIsComplement ,iDiscountTaxType ,ireturncount , iverifystate ,iswfcontrolled ,cModifyPerson ,dnmaketime ,dnverifytime , bredvouch ,bCredit ,iPrintCount,ipurarriveid,cPTCode,cVenPUOMProtocol,iCreditPeriod,dCreditStart,dGatheringDate)
SELECT @ID,1,'01',a.cBusType,@cSource, @cWhCode,@dDate,@cCode,@cRdCode,@cDepCode, @cPersonCode,a.cVenCode,a.cPOID,@cARVCode, @cHandler,0,@cMaker,a.cDefine1,a.cDefine2, @cVeriDate,0,0,@dARVDate,@VT_ID, 0,@ipurorderid,a.iTaxRate,a.nflat,a.cexch_name, 0,0,0,0,0, 0,0,'',@dnmakertime,@dnverifytime, @bredvouch,0,0,@ipurarriveid,a.cPTCode,@cVenPUOMProtocol,@iCreditPeriod,@dCreditStart,@dGatheringDate FROM dbo.PO_Pomain a LEFT JOIN PU_ArrivalVouch b ON a.cPOID=b.cpocode WHERE b.cCode ='" + head.DNCode + "'";
cmd.Parameters.Clear(); cmd.Parameters.Add(new SqlParameter("@ID", iFatherId)); cmd.Parameters.Add(new SqlParameter("@cSource", cSource)); cmd.Parameters.Add(new SqlParameter("@cWhCode", head.WHCode)); cmd.Parameters.Add(new SqlParameter("@dDate", Convert.ToDateTime(DateTime.Now).ToString("yyyy -MM-dd"))); cmd.Parameters.Add(new SqlParameter("@cCode", iBaseCodeLen)); cmd.Parameters.Add(new SqlParameter("@cDepCode", dtPOMain.Rows[0]["cDepCode"].ToString())); cmd.Parameters.Add(new SqlParameter("@cPersonCode", dtPOMain.Rows[0]["cPersonCode"].ToString())); cmd.Parameters.Add(new SqlParameter("@cARVCode", cCode)); cmd.Parameters.Add(new SqlParameter("@cMaker", userInfo.UserName)); cmd.Parameters.Add(new SqlParameter("@cVeriDate", Convert.ToDateTime(DateTime.Now).ToString("yyyy-MM-dd"))); cmd.Parameters.Add(new SqlParameter("@dARVDate", Convert.ToDateTime(head.MTime))); cmd.Parameters.Add(new SqlParameter("@VT_ID", DEF_ID)); cmd.Parameters.Add(new SqlParameter("@ipurorderid", dtPOMain.Rows[0]["POID"].ToString())); cmd.Parameters.Add(new SqlParameter("@dnmakertime", Convert.ToDateTime(DateTime.Now).ToString())); cmd.Parameters.Add(new SqlParameter("@dnverifytime", Convert.ToDateTime(DateTime.Now).ToString())); cmd.Parameters.Add(new SqlParameter("@bredvouch", bredvouch)); cmd.Parameters.Add(new SqlParameter("@ipurarriveid", dtPOMain.Rows[0]["ID"].ToString())); cmd.Parameters.Add(new SqlParameter("@cHandler", userInfo.UserName)); cmd.Parameters.Add(new SqlParameter("@cRdCode", cRDcode)); cmd.Parameters.Add(new SqlParameter("@cVenPUOMProtocol", cfcode)); cmd.Parameters.Add(new SqlParameter("@iCreditPeriod", zq)); cmd.Parameters.Add(new SqlParameter("@dCreditStart", lz)); cmd.Parameters.Add(new SqlParameter("@dGatheringDate", dz));
cmd.CommandText = sql; try { int count = cmd.ExecuteNonQuery(); if (count <= 0) { log.Error("生成采购入库单表头失败，受影响行数<=0；"); throw new Exception("生成采购入库单表头失败，受影响行数<=0；"); } } catch (Exception ex) { log.Error("生成采购入库单表头失败！异常：" + ex.Message + "；SQL：\r\n" + sql, ex); throw new Exception("生成采购入库单表头失败！异常：" + ex.Message + "；SQL：\r\n" + sql, ex); } }
else { throw new Exception("对应采购订单不存在！采购订单号：" + head.DNCode); } #endregion
#region 采购入库单表体
foreach (ICSPurchaseReceiveDocs body in head.details) {
sql = @"SELECT a.id,a.cInvCode,a.iUnitPrice ,a.iMoney AS 原币无税金额 ,a.ivouchrowno,
a.iTax AS 原币税额 ,a.iSum AS 原币价税合计 ,a.iNatUnitPrice ,c.cBatch, a.iNatMoney AS 本币无税金额 ,a.iNatTax AS 本币税额 ,a.iNatSum AS 本币价税合计 , a.iTaxPrice ,a.freceivedqty AS 合格品入库数量 ,a.iPerTaxRate,c.Autoid,d.cCode,d.dDate FROM dbo.PO_Podetails a INNER JOIN dbo.PO_Pomain b ON a.POID=b.POID LEFT JOIN dbo.PU_ArrivalVouchs c ON a.ID=c.iPOsID LEFT JOIN dbo.PU_ArrivalVouch d ON c.ID=d.ID where c.AutoID='" + body.DNDetailID + "'";
cmd.CommandText = sql; DataTable dtPODetails = DBHelper.SQlReturnData(sql, cmd); decimal iUnitPrice = 0; decimal iNatUnitPrice = 0; decimal iTaxPrice = 0; string id = ""; string code = ""; string dates = ""; string batch = ""; if (dtPODetails != null && dtPODetails.Rows.Count > 0) { 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 + "未启用批次，请重新填写！"); } } if (!string.IsNullOrEmpty(dtPODetails.Rows[0]["iUnitPrice"].ToString())) iUnitPrice = decimal.Parse(dtPODetails.Rows[0]["iUnitPrice"].ToString());//原币无税单价
if (!string.IsNullOrEmpty(dtPODetails.Rows[0]["iNatUnitPrice"].ToString())) iNatUnitPrice = decimal.Parse(dtPODetails.Rows[0]["iNatUnitPrice"].ToString());//本币无税单价
if (!string.IsNullOrEmpty(dtPODetails.Rows[0]["iTaxPrice"].ToString())) iTaxPrice = decimal.Parse(dtPODetails.Rows[0]["iTaxPrice"].ToString());//原币含税单价
iTaxRate = Convert.ToDecimal(dtPODetails.Rows[0]["iPerTaxRate"]); if (!string.IsNullOrEmpty(dtPODetails.Rows[0]["Autoid"].ToString()))//采购退货单字体标识
id = dtPODetails.Rows[0]["Autoid"].ToString(); if (!string.IsNullOrEmpty(dtPODetails.Rows[0]["cCode"].ToString()))//采购退货单号
code = dtPODetails.Rows[0]["cCode"].ToString(); if (!string.IsNullOrEmpty(dtPODetails.Rows[0]["dDate"].ToString()))//采购退货单日期
dates = dtPODetails.Rows[0]["dDate"].ToString(); if (!string.IsNullOrEmpty(dtPODetails.Rows[0]["cBatch"].ToString()))//采购退货单批号
batch = dtPODetails.Rows[0]["cBatch"].ToString(); sql = @"INSERT INTO dbo.rdrecords01
( AutoID ,ID ,cInvCode ,iNum ,iQuantity ,cItemCode, iUnitCost ,iPrice ,iAPrice ,cBatch ,iFlag , dSDate ,iSQuantity ,iSNum ,iMoney ,iPOsID , fACost ,iNQuantity ,chVencode ,iOriTaxCost ,iOriCost , iOriMoney ,iOriTaxPrice ,ioriSum ,iTaxRate ,iTaxPrice , iSum ,bTaxCost ,cPOID ,iMatSettleState ,iBillSettleCount , bLPUseFree ,iOriTrackID ,cbaccounter ,dbKeepDate ,bCosting , iSumBillQuantity ,bVMIUsed ,iExpiratDateCalcu ,isotype ,irowno, iArrsId,cbarvcode,dbarvdate,cFree1,cFree2,cFree3,cFree4,cFree5,cFree6,cFree7,cFree8,cFree9,cFree10 )
select @AutoID,@ID1,@cInvCode,@iNum,@iQuantity,@cItemCode, @iUnitCost,@iPrice,@iAPrice,@cBatch,0, null,0,0,0,a.ID, @fACost,@iNQuantity,b.cVenCode,@iOriTaxCost,@iOriCost, @iOriMoney,@iOriTaxPrice,@ioriSum,@iTaxRate,@iTaxPrice, @iSum,1,@cPOID,0,0, 0,0,null,null,d.bInCost, null,0,0,0,@irowno, @iArrsId,@cbarvcode,@dbarvdate,@cFree1,@cFree2,@cFree3,@cFree4,@cFree5,@cFree6,@cFree7,@cFree8,@cFree9,@cFree10 FROM dbo.PO_Podetails a INNER JOIN dbo.PO_Pomain b ON a.POID = b.POID INNER JOIN dbo.PU_ArrivalVouchs c ON a.ID = c.iPOsID INNER JOIN dbo.Warehouse d ON d.cWhCode = '{0}' WHERE c.Autoid = '{1}'
EXEC PROC_Update_PO_RdRecord01 @ID= @ID1
";
sql = string.Format(sql, head.WHCode, body.DNDetailID); cmd.Parameters.Clear(); cmd.Parameters.Add(new SqlParameter("@AutoID", iChildId)); cmd.Parameters.Add(new SqlParameter("@ID1", iFatherId)); cmd.Parameters.Add(new SqlParameter("@cInvCode", body.InvCode)); cmd.Parameters.Add(new SqlParameter("@iQuantity", body.Quantity)); cmd.Parameters.Add(new SqlParameter("@iNum", body.Amount.ToString("0.00"))); cmd.Parameters.Add(new SqlParameter("@iUnitCost", iUnitPrice)); cmd.Parameters.Add(new SqlParameter("@iPrice", Math.Round(body.Quantity * iUnitPrice, 2))); cmd.Parameters.Add(new SqlParameter("@iAPrice", Math.Round(body.Quantity * iUnitPrice, 2))); cmd.Parameters.Add(new SqlParameter("@cBatch", body.BatchCode)); cmd.Parameters.Add(new SqlParameter("@cItemCode", body.ProjectCode)); //cmd.Parameters.Add(new SqlParameter("@iSQuantity", 0));
//cmd.Parameters.Add(new SqlParameter("@iMoney", 0));
cmd.Parameters.Add(new SqlParameter("@fACost", iNatUnitPrice)); cmd.Parameters.Add(new SqlParameter("@iNQuantity", body.Quantity)); cmd.Parameters.Add(new SqlParameter("@iOriTaxCost", iTaxPrice)); cmd.Parameters.Add(new SqlParameter("@iOriCost", body.Quantity * iUnitPrice)); cmd.Parameters.Add(new SqlParameter("@iOriMoney", iUnitPrice)); cmd.Parameters.Add(new SqlParameter("@iOriTaxPrice", Math.Round(body.Quantity * iUnitPrice, 2))); cmd.Parameters.Add(new SqlParameter("@ioriSum", Math.Round(Math.Round(iTaxPrice * body.Quantity, 2) - Math.Round(body.Quantity * iUnitPrice, 2), 2))); cmd.Parameters.Add(new SqlParameter("@iTaxRate", Math.Round(iTaxPrice * body.Quantity, 2))); cmd.Parameters.Add(new SqlParameter("@iTaxPrice", iTaxRate)); cmd.Parameters.Add(new SqlParameter("@iSum", Math.Round(Math.Round(iTaxPrice * body.Quantity, 2) - Math.Round(body.Quantity * iUnitPrice, 2), 2))); cmd.Parameters.Add(new SqlParameter("@irowno", body.Sequence)); cmd.Parameters.Add(new SqlParameter("@cPOID", dtPODetails.Rows[0]["cCode"].ToString())); cmd.Parameters.Add(new SqlParameter("@iArrsId", id)); cmd.Parameters.Add(new SqlParameter("@cbarvcode", code)); cmd.Parameters.Add(new SqlParameter("@dbarvdate", dates));
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; try { int count = cmd.ExecuteNonQuery(); if (count <= 0) { log.Error("生成采购入库单表体失败，受影响行数<=0；"); throw new Exception("生成采购入库单表体失败，受影响行数<=0；"); } } catch (Exception ex) { log.Error("生成采购入库单表体失败！异常：" + ex.Message + "；SQL：\r\n" + sql, ex); throw new Exception("生成采购入库单表体失败！异常：" + ex.Message + "；SQL：\r\n" + sql, ex); }
#region 更新[采购到货单子表]PU_ArrivalVouchs 合格品入库数量20211019
sql = @"UPDATE PU_ArrivalVouchs SET fValidInQuan=ISNULL(fValidInQuan,0)+@iQty WHERE Autoid=@Autoid"; cmd.CommandText = sql; cmd.Parameters.Clear(); cmd.Parameters.Add(new SqlParameter("@iQty", body.Quantity)); cmd.Parameters.Add(new SqlParameter("@Autoid", body.DNDetailID)); try { log.Info("PU_Autoid:" + body.DNDetailID); cmd.ExecuteNonQuery(); } catch (Exception ex) { log.Error("回写采购到货单子表合格品入库数量失败：单据号：" + head.DNCode + ",行号：" + body.Sequence + ";异常：" + ex.Message); throw new Exception("程序异常，请联系开发人员！"); } #endregion
#region 更新[采购订单子表]PO_PODetails累计到货数量和累计到货金额
//sql = @"Update a set iReceivedQTY =isnull(iReceivedQTY ,0)+ @iQty,iReceivedMoney=isnull(iReceivedMoney,0)+@iMoney FROM dbo.PO_Podetails a where a.ID='" + body.iPOsID + "'";
sql = @"
Update a set iReceivedMoney=isnull(iReceivedMoney,0)+@iMoney ,freceivedqty=isnull(freceivedqty ,0)+ @iQty FROM dbo.PO_Podetails a where a.ID=(select iPOsID from PU_ArrivalVouchs where Autoid= @ID)"
; //2021-11-05
//1.移除 iReceivedQTY =isnull(iReceivedQTY ,0)+ @iQty 由采购到货,创建到货单CreatePU时写入iReceivedQTY,此处不再回写,累计到货数量
//2.加入 freceivedqty =isnull(freceivedqty ,0) + @iQty 合格品入库数量
cmd.CommandText = sql; cmd.Parameters.Clear(); cmd.Parameters.Add(new SqlParameter("@iQty", body.Quantity)); cmd.Parameters.Add(new SqlParameter("@iMoney", body.Quantity * iUnitPrice)); cmd.Parameters.Add(new SqlParameter("@ID", body.DNDetailID)); try { log.Info("PU_Autoid:" + body.DNDetailID); cmd.ExecuteNonQuery(); } catch (Exception ex) { log.Error("回写采购订单累计到货数量和累计到货金额失败：采购订单表体行号：" + body.DNDetailID + ";异常：" + ex.Message); throw new Exception("程序异常，请联系开发人员！"); } #endregion
sql = @"select isnull(fValidInQuan,0)fOutQuantity,isnull(iQuantity,0)iQuantity,ISNULL(iNum, 0)iNum,ISNULL(NiNum, 0)NiNum,ISNULL(iNum, 0)-ISNULL(NiNum, 0) SiNum from PU_ArrivalVouchs a
LEFT JOIN (select sum(iNum) NiNum,iArrsId from rdrecords01 GROUP BY iArrsId) b on a.ID=b.iArrsId where a.Autoid='" + body.PODetailID + "'";
DataTable dtDisCheck = DBHelper.SQlReturnData(sql, cmd); if (dtDisCheck != null && dtDisCheck.Rows.Count > 0) { foreach (DataRow item in dtDisCheck.Rows) { if (Convert.ToDecimal(item["fOutQuantity"].ToString()) == Convert.ToDecimal(item["iQuantity"].ToString())) { if (Convert.ToDecimal(item["iNum"].ToString()) != 0) { if (Convert.ToDecimal(item["SiNum"].ToString()) != 0) { sql = @"Update rdrecords01 set iNum=isnull(iNum,0)+(" + item["SiNum"].ToString() + ") where autoid='" + iChildId + "' "; body.Amount = (Convert.ToDecimal(body.Amount.ToString("0.00"))) + (Convert.ToDecimal(item["SiNum"].ToString())); DBHelper.CmdExecuteNonQuery(sql, cmd, "辅计量余数处理失败！"); } } } }
}
//if (isEnable != 0)
//{
// key.cBustypeUN = "普通采购";
// key.cVouchTypeUN = "01";
// key.TableName = "IA_ST_UnAccountVouch01";
// //DBHelper.UpdateCurrentStock(cmd, body.InvCode, head.WHCode, "", body.Quantity, key);
// DBHelper.UpdateCurrentStockNEWDG(cmd, body.InvCode, head.WHCode, body.BatchCode, body.Quantity, body.cFree1, body.cFree2, body.cFree3, body.cFree4, body.cFree5, body.cFree6, body.cFree7, body.cFree8, body.cFree9, body.cFree10, gys, key);
//}
//else
//{
// //更新现存量
// key.cBustypeUN = "普通采购";
// key.cVouchTypeUN = "01";
// key.TableName = "IA_ST_UnAccountVouch01";
// //DBHelper.UpdateCurrentStock(cmd, body.InvCode, head.WHCode, body.InvCode, body.Quantity, key);
// DBHelper.UpdateCurrentStockNEW(cmd, body.InvCode, head.WHCode, body.BatchCode, body.Quantity, body.cFree1, body.cFree2, body.cFree3, body.cFree4, body.cFree5, body.cFree6, body.cFree7, body.cFree8, body.cFree9, body.cFree10, key);
//}
key.cBustypeUN = "普通采购"; key.cVouchTypeUN = "01"; key.TableName = "IA_ST_UnAccountVouch01"; if (batch!="") { DBHelper.UpdateCurrentStockCCGC(cmd, body.InvCode, head.WHCode, body.BatchCode, body.Quantity, body.Amount, body.cFree1, body.cFree2, body.cFree3, body.cFree4, body.cFree5, body.cFree6, body.cFree7, body.cFree8, body.cFree9, body.cFree10, gys, key, "", "", "", "", 0, 0, -body.Quantity, -body.Amount, 0, 0, 0, 0, iFatherId, iChildId);
} else { DBHelper.UpdateCurrentStockCCGC(cmd, body.InvCode, head.WHCode, "", 0, 0, body.cFree1, body.cFree2, body.cFree3, body.cFree4, body.cFree5, body.cFree6, body.cFree7, body.cFree8, body.cFree9, body.cFree10, gys, key, "", "", "", "", 0, 0, -body.Quantity, -body.Amount, 0, 0, 0, 0, iFatherId, iChildId); DBHelper.UpdateCurrentStockCCGC(cmd, body.InvCode, head.WHCode, body.BatchCode, body.Quantity, body.Amount, body.cFree1, body.cFree2, body.cFree3, body.cFree4, body.cFree5, body.cFree6, body.cFree7, body.cFree8, body.cFree9, body.cFree10, gys, key, "", "", "", "", 0, 0, 0, 0, 0, 0, 0, 0, iFatherId, iChildId); }
iFatherIdTwo = "'" + iFatherId + "',"; iChildId--; }
////更新主键ID，DID
//DBHelper.UpdateIDandDID("rd", head.list.Count(), cmd);
} #endregion
#region 判断现存量是否超入库
sql = @"IF EXISTS(SELECT ID FROM dbo.PO_Podetails WHERE isnull(ireceivedqty,0)+isnull(freceivedqty,0)>iQuantity AND ID>'1000043932')
BEGIN DECLARE @MSG NVARCHAR(100) SELECT @MSG='ERP入库数量不能大于订单数量！ID：'+CAST(ID AS NVARCHAR(100)) FROM dbo.PO_Podetails WHERE isnull(ireceivedqty,0)+isnull(freceivedqty,0)>iQuantity AND ID>'1000043932' RAISERROR(@MSG,16,1) END";
cmd.CommandText = sql; cmd.ExecuteNonQuery();
#endregion
//GetSerialCode(iFatherId.ToString());
#region 查询
sql = @" select DISTINCT a.ID as ID,a.ID as IDs,a.cCode as RCVTCode,a.cVenCode,D.cVenName,
a.cWhCode,c.cWhName,cARVCode as DNCode,cMaker as CreateUser, dnmaketime as CreateDateTime,cHandler as Checker,dVeriDate as CheckDateTime FROM RdRecord01 a INNER JOIN Warehouse C ON a.cWhCode=C.cWhCode INNER JOIN VENDOR D ON A.CVENCODE=D.CVENCODE WHERE 1=1 and a.ID in ({0})
select DISTINCT a.ID as IDs, AutoID as DetailID,irowno as Sequence, cInvCode as InvCode,iQuantity as Quantity,iNum as Amount,iArrsId as DNDetailID,isnull(b.cItemCode,'') ProjectCode,isnull(b.cbatch,'') cBatch,'' 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 RdRecord01 a LEFT JOIN rdrecords01 b on a.ID=b.ID INNER JOIN DEPARTMENT C ON A.CDEPCODE=C.CDEPCODE INNER JOIN VENDOR D ON A.CVENCODE=D.CVENCODE WHERE 1=1 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.Transaction.Commit(); } catch (Exception ex) { 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="infos"></param>
/// <returns></returns>
public string Approve(List<ICSPurchaseReceiveDoc> infos) { List<ICSPurchaseReceiveDoc> szJson = new List<ICSPurchaseReceiveDoc>(); string json = ""; string connS = ""; if (infos.Count <= 0) { throw new Exception("传送数据为空！"); } string res = string.Empty; SqlConnection conn = new SqlConnection(); SqlCommand cmd = new SqlCommand(); string sql = string.Empty; List<string> result = infos.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 (ICSPurchaseReceiveDoc info in infos) { if (WorkPoint != info.WorkPoint) continue;
ICSUserInfo userInfo = new ICSUserInfo(); userInfo = DBHelper.GetPersonInfo(info.User, cmd);
if (info.MTime < new DateTime(2000, 01, 01)) throw new Exception("请输入正确的操作时间：" + info.MTime); sql = @"UPDATE [{0}].dbo.RdRecord01 SET cVerifier ='" + userInfo.UserName + @"' ,
cAuditTime=CONVERT(VARCHAR(50),GETDATE(),112),cAuditDate=GETDATE() WHERE ID='" + info.ID + "'";
sql = string.Format(sql, ERPDB); DBHelper.CmdExecuteNonQuery(sql, cmd, "未查询到对应数据！");
} cmd.Transaction.Commit(); } catch (Exception ex) { cmd.Transaction.Rollback(); log.Error(ex.Message); throw new Exception(ex.Message); } finally { if (conn.State == ConnectionState.Open) { conn.Close(); } conn.Dispose(); } } return json;
} /// <summary>
/// 删除采购入库单
/// </summary>
/// <param name="infos"></param>
/// <returns></returns>
public string Delete(List<ICSPurchaseReceiveDoc> infos) { List<ICSPurchaseReceiveDoc> szJson = new List<ICSPurchaseReceiveDoc>(); if (infos.Count <= 0) { throw new Exception("传送数据为空！"); } string res = string.Empty; string connS = ""; SqlConnection conn = new SqlConnection(); SqlCommand cmd = new SqlCommand(); string sql = string.Empty; List<string> result = infos.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 (ICSPurchaseReceiveDoc info in infos) { if (WorkPoint != info.WorkPoint) continue;
if (info.MTime < new DateTime(2000, 01, 01)) throw new Exception("请输入正确的操作时间：" + info.MTime); sql = @" DELETE [{1}].dbo.RdRecord01 WHERE ID={0}"; sql = string.Format(sql, info.ID, ERPDB); DBHelper.CmdExecuteNonQuery(sql, cmd, "未查询到对应数据！");
} cmd.Transaction.Commit();
} catch (Exception ex) { cmd.Transaction.Rollback(); log.Error(ex.Message); throw new Exception(ex.Message); } finally { if (conn.State == ConnectionState.Open) { conn.Close(); } conn.Dispose(); } } return res;
} //public string GetSerialCode(string ID)
//{
// string sql = "EXEC PROC_Update_PO_RdRecord01 '{0}'";
// sql = string.Format(sql, new object[] { ID });
// return DBHelper.ExecuteScalar(CommandType.Text, sql, connString).ToString();
//}
}
}
|
