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 更新[采购订单子表]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("ID:" + 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();
        //}
    }

}