using ICS.WCF.Base; using System; using System.Collections.Generic; using System.Configuration; using System.Data; using System.Linq; using System.ServiceModel; using System.Text; using System.Threading.Tasks; //using UFIDA.ISV.BFRCVApprove; //using UFIDA.ISV.BFRCVDelete; //using UFIDA.ISV.CreateLotMaster; using UFSoft.UBF.Business.BusinessEntity; using UFSoft.UBF.Service; using UFSoft.UBF.Util.Context; using www.ufida.org.EntityData; namespace UFIDA.ISV.CreateSOReturnRCV { public class CustCreateSOReturnRcvSrvSub { public List CustCreateBFRCV(List rCVInfoList) { StringBuilder beginstrlog = new StringBuilder(); beginstrlog.AppendLine("创建销售退货单(传入数据开始)"); beginstrlog.AppendLine("*****************************************************"); foreach (var item in rCVInfoList) { beginstrlog.AppendLine("来源退回处理单号:" + item.srcDocPONo); foreach (var line in item.lines) { //bool isLotCheck = WHLotCheckState(line.WhCode, line.FurnaceNo); //if (isLotCheck == false) //{ // line.RcvLot = ""; //} beginstrlog.AppendLine("来源退回处理单行号:" + line.srcDocPOLineNo); beginstrlog.AppendLine("料品编码:" + line.ItemCode); beginstrlog.AppendLine("料品数量:" + line.ReqQty); beginstrlog.AppendLine("仓库:" + line.WhCode); //beginstrlog.AppendLine("库存批号:" + line.RcvLot); beginstrlog.AppendLine("用户编号:" + line.UserCode); beginstrlog.AppendLine("组织编号:" + line.FurnaceNo); } } beginstrlog.AppendLine("*****************************************************"); Appconfig.WriteLogFile(beginstrlog.ToString(), "创建销售退货单"); #region 服务调用框架结构 UFIDAU9ISVRCVICeateSaleReturnRcvBySrcSRVClient client = new UFIDAU9ISVRCVICeateSaleReturnRcvBySrcSRVClient(); //服务返回结果 EntityKey[] returnItems; //返回异常信息,目前还没有使用此属性 UFSoft.UBF.Exceptions1.MessageBase[] returnMsg; //上下文信息 object context; //传入 参数 UFIDAU9ISVRCVSMToRcvDTOData[] REArray; //空 string[] splitBy = new string[] { }; string UserID = ""; string UserCode = ""; string OrgID = ""; long WHID = 0; try { List rtnpos = new List(); if (rCVInfoList == null || rCVInfoList.Count == 0) { rtnRcvInfo rtnpo = new rtnRcvInfo(); rtnpo.IsSuccess = false; rtnpo.Message = "传入参数不能为空"; rtnpos.Add(rtnpo); return rtnpos; } foreach (var item in rCVInfoList) { if (item.lines == null || item.lines.Count() == 0) { rtnRcvInfo rtnpo = new rtnRcvInfo(); rtnpo.IsSuccess = false; rtnpo.Message = "传入行信息不能为空"; rtnpos.Add(rtnpo); return rtnpos; } foreach (var _item in item.lines) { if (string.IsNullOrWhiteSpace(_item.ItemCode)) { rtnRcvInfo rtnpo = new rtnRcvInfo(); rtnpo.IsSuccess = false; rtnpo.Message = "传入料号不能为空"; rtnpos.Add(rtnpo); return rtnpos; } if (_item.srcDocPOLineNo == 0) { rtnRcvInfo rtnpo = new rtnRcvInfo(); rtnpo.IsSuccess = false; rtnpo.Message = "请传入来源单据行号"; rtnpos.Add(rtnpo); return rtnpos; } if (_item.ReqQty == 0) { rtnRcvInfo rtnpo = new rtnRcvInfo(); rtnpo.IsSuccess = false; rtnpo.Message = "传入数量不能为空"; rtnpos.Add(rtnpo); return rtnpos; } if (string.IsNullOrWhiteSpace(_item.WhCode)) { rtnRcvInfo rtnpo = new rtnRcvInfo(); rtnpo.IsSuccess = false; rtnpo.Message = "传入仓库不能为空"; rtnpos.Add(rtnpo); return rtnpos; } } } //给传入参数赋值 //pOList = SetrCVDtos(rCVInfoList); StringBuilder strlog = new StringBuilder(); bool isNeedContinue = false; strlog.AppendLine("创建销售退货单"); strlog.AppendLine("*****************************************************"); List REList = new List(); foreach (var rCVhead in rCVInfoList) { int Count = 10; strlog.AppendLine("来源退回处理单号:" + rCVhead.srcDocPONo); foreach (rCVLine line in rCVhead.lines) { if (!string.IsNullOrEmpty(line.FurnaceNo)) { string orgsql = @"select ID from Base_Organization where Code='{0}'"; orgsql = string.Format(orgsql, line.FurnaceNo); DataTable orgdt = DBhlper.Query(orgsql, Appconfig.GetU9ConnStr()); if (orgdt.Rows.Count != 0) { OrgID = orgdt.Rows[0]["ID"].ToString(); } else { rtnRcvInfo rtnpo = new rtnRcvInfo(); rtnpo.IsSuccess = false; rtnpo.Message = "未获取到组织"; rtnpos.Add(rtnpo); return rtnpos; } } else { rtnRcvInfo rtnpo = new rtnRcvInfo(); rtnpo.IsSuccess = false; rtnpo.Message = "传入组织不能为空"; rtnpos.Add(rtnpo); return rtnpos; } if (line.UserCode == "") { rtnRcvInfo rtnpo = new rtnRcvInfo(); rtnpo.IsSuccess = false; rtnpo.Message = "用户编码不能为空"; rtnpos.Add(rtnpo); return rtnpos; } if (line.RcvLot == "") { rtnRcvInfo rtnpo = new rtnRcvInfo(); rtnpo.IsSuccess = false; rtnpo.Message = "批号不能为空"; rtnpos.Add(rtnpo); return rtnpos; } else { string usersql = @"select ID from CBO_Operators where Code='{0}'"; usersql = string.Format(usersql, line.UserCode); DataTable userdt = DBhlper.Query(usersql, Appconfig.GetU9ConnStr()); if (userdt.Rows.Count != 0) { UserID = userdt.Rows[0]["ID"].ToString(); UserCode = line.UserCode; } else { rtnRcvInfo rtnpo = new rtnRcvInfo(); rtnpo.IsSuccess = false; rtnpo.Message = "未获取到用户ID"; rtnpos.Add(rtnpo); return rtnpos; } } string sqlShip = @"SELECT B.ID,B.RtnQtyPU,B.DocLineNo,B.ItemInfo_ItemCode,C.ArriveQtyTU FROM SM_RMA A LEFT JOIN SM_RMALine B ON B.RMA=A.ID LEFT JOIN PM_RcvLine C ON C.SrcDoc_SrcDoc_EntityID=B.RMA AND C.SrcDoc_SrcDocLineNo=B.DocLineNo WHERE A.DocNo='{0}' AND B.DocLineNo='{1}' AND B.ItemInfo_ItemCode='{2}' AND A.Status=3"; sqlShip = string.Format(sqlShip, rCVhead.srcDocPONo, line.srcDocPOLineNo, line.ItemCode); DataTable _dtPOShip = DBhlper.Query(sqlShip, Appconfig.GetU9ConnStr()); if (_dtPOShip != null && _dtPOShip.Rows.Count > 0) { foreach (DataRow item in _dtPOShip.Rows) { //Decimal PlanQTY = Decimal.Parse(item["RtnQtyPU"].ToString()); //Decimal HasQTY = Decimal.Parse(item["ArriveQtyTU"].ToString()); //if (line.ReqQty > 0 && line.ReqQty > PlanQTY - HasQTY) //{ #region CRM传入数量超过U9退回处理单剩余可退数量时自动转换成剩余数量计算(已注释,出现这种情况报错) //UFIDAU9ISVRCVSMToRcvDTOData RE = new UFIDAU9ISVRCVSMToRcvDTOData(); //RE.m_srcDocNo = rCVhead.srcDocPONo; //RE.m_srcDocLineNo = line.srcDocPOLineNo.ToString(); //RE.m_businessDate = System.DateTime.Now; ////数量 //RE.m_transQty = new UFIDAU9CBODTOsDoubleQuantityData(); //RE.m_transQty.m_amount1 = PlanQTY - HasQTY; //#region 获取仓库信息 //string sqlWH = @"select ID,Code from CBO_Wh // WHERE Code='" + line.WhCode + "' "; //sqlWH = string.Format(sqlWH); //DataTable _dtWH = DBhlper.Query(sqlWH, Appconfig.GetU9ConnStr()); //string WHCode = string.Empty; //if (_dtWH != null && _dtWH.Rows.Count > 0) //{ // WHID = long.Parse(_dtWH.Rows[0][0].ToString()); // WHCode = _dtWH.Rows[0][1].ToString(); //} //if (string.IsNullOrWhiteSpace(WHCode)) //{ // rtnRcvInfo rtnpo = new rtnRcvInfo(); // rtnpo.IsSuccess = false; // rtnpo.Message = "未获取到仓库"; // rtnpos.Add(rtnpo); // return rtnpos; //} //#endregion ////仓库 //#region 先创建批号 //string LotID = ""; //if (line.RcvLot != "") //{ // CustCreateLotMaster LotMasterCreate = new CustCreateLotMaster(); // string lotWHCode = line.WhCode; // string lotItemCode = line.ItemCode; // string LotCode = line.RcvLot; // LotMasterCreate.CustCreateRCVLotMaster(lotWHCode, lotItemCode, LotCode, line.LotCreateTime, OrgID, ref LotID); // if (LotID == "") // { // rtnRcvInfo rtnpo = new rtnRcvInfo(); // rtnpo.IsSuccess = false; // rtnpo.Message = "批号创建失败"; // rtnpos.Add(rtnpo); // return rtnpos; // } //} //#endregion //RE.m_rcvLineInfoDTO = new UFIDAU9ISVRCVDTORcvLineInfoDTOData(); //RE.m_rcvLineInfoDTO.m_invLotCode = line.RcvLot; //RE.m_rcvLineInfoDTO.m_storageType = 4; //RE.m_rcvLineInfoDTO.m_docLineNo = Count; //RE.m_rcvLineInfoDTO.Wh = WHID; //RE.m_rcvLineInfoDTO.m_whCode = WHCode; ////rCV.m_pOShipLineNo = 10; ////库位 //RE.m_rcvLineInfoDTO.m_lineLocations = new UFIDAU9ISVRCVDTOOBARcvLineLocationDTOData[] { }; //List locationList = new List(); //REList.Add(RE); //Count++; //strlog.AppendLine("来源采购订单行号:" + line.srcDocPOLineNo); //strlog.AppendLine("料品编码:" + line.ItemCode); //strlog.AppendLine("料品数量:" + line.ReqQty); //strlog.AppendLine("仓库:" + WHCode); //strlog.AppendLine("库存批号:" + line.RcvLot); //strlog.AppendLine("用户ID:" + line.UserID); //strlog.AppendLine("用户编号:" + line.UserCode); //strlog.AppendLine("组织编号:" + line.FurnaceNo); //line.ReqQty = line.ReqQty - RE.m_transQty.m_amount1; //continue; #endregion // rtnRcvInfo rtnpo = new rtnRcvInfo(); // rtnpo.IsSuccess = false; // rtnpo.Message = "退货数量不能超出剩余未退数量!"; // rtnpos.Add(rtnpo); // return rtnpos; //} //if (line.ReqQty > 0 && line.ReqQty <= PlanQTY - HasQTY) //{ UFIDAU9ISVRCVSMToRcvDTOData RE = new UFIDAU9ISVRCVSMToRcvDTOData(); RE.m_srcDocType = 8; RE.m_srcDocNo = rCVhead.srcDocPONo; RE.m_srcDocLineNo = line.srcDocPOLineNo.ToString(); RE.m_businessDate = System.DateTime.Now; //数量 RE.m_transQty = new UFIDAU9CBODTOsDoubleQuantityData(); RE.m_transQty.m_amount1 = line.ReqQty; #region 获取仓库信息 string sqlWH = @"select ID,Code from CBO_Wh WHERE Code='" + line.WhCode + "' "; sqlWH = string.Format(sqlWH); DataTable _dtWH = DBhlper.Query(sqlWH, Appconfig.GetU9ConnStr()); string WHCode = string.Empty; if (_dtWH != null && _dtWH.Rows.Count > 0) { WHID = long.Parse(_dtWH.Rows[0][0].ToString()); WHCode = _dtWH.Rows[0][1].ToString(); } if (string.IsNullOrWhiteSpace(WHCode)) { rtnRcvInfo rtnpo = new rtnRcvInfo(); rtnpo.IsSuccess = false; rtnpo.Message = "未获取到仓库"; rtnpos.Add(rtnpo); return rtnpos; } #endregion //仓库 //#region 先创建批号 //string LotID = ""; //if (line.RcvLot != "") //{ // CustCreateLotMaster LotMasterCreate = new CustCreateLotMaster(); // string lotWHCode = line.WhCode; // string lotItemCode = line.ItemCode; // string LotCode = line.RcvLot; // LotMasterCreate.CustCreateRCVLotMaster(lotWHCode, lotItemCode, LotCode, line.LotCreateTime, OrgID, ref LotID); // if (LotID == "") // { // rtnRcvInfo rtnpo = new rtnRcvInfo(); // rtnpo.IsSuccess = false; // rtnpo.Message = "批号创建失败"; // rtnpos.Add(rtnpo); // return rtnpos; // } //} //#endregion RE.m_rcvLineInfoDTO = new UFIDAU9ISVRCVDTORcvLineInfoDTOData(); RE.m_rcvLineInfoDTO.m_invLotCode = line.RcvLot; RE.m_rcvLineInfoDTO.m_storageType = 4; RE.m_rcvLineInfoDTO.m_docLineNo = Count; RE.m_rcvLineInfoDTO.Wh = WHID; RE.m_rcvLineInfoDTO.m_whCode = WHCode; RE.m_rcvLineInfoDTO.m_whManCode = "admin"; //rCV.m_pOShipLineNo = 10; //库位 RE.m_rcvLineInfoDTO.m_lineLocations = new UFIDAU9ISVRCVDTOOBARcvLineLocationDTOData[] { }; List locationList = new List(); REList.Add(RE); Count++; strlog.AppendLine("来源退回处理单行号(srcDocPOLineNo):" + line.srcDocPOLineNo); strlog.AppendLine("料品编码(ItemCode):" + line.ItemCode); strlog.AppendLine("料品数量(ReqQty):" + line.ReqQty); strlog.AppendLine("仓库(WHCode):" + WHCode); strlog.AppendLine("库存批号(RcvLot):" + line.RcvLot); strlog.AppendLine("用户编号(UserCode):" + line.UserCode); strlog.AppendLine("组织编号(FurnaceNo):" + line.FurnaceNo); line.ReqQty = 0; continue; //} } } else { rtnRcvInfo rtnpo = new rtnRcvInfo(); rtnpo.IsSuccess = false; rtnpo.Message = "未查询到相关的退回处理单信息!"; rtnpos.Add(rtnpo); return rtnpos; } } } REArray = REList.ToArray(); //给上下文信息赋值 context = CreateContextObj(UserID, UserCode, OrgID); (client.Endpoint.Binding as BasicHttpBinding).MaxReceivedMessageSize = int.MaxValue; (client.Endpoint.Binding as BasicHttpBinding).MaxBufferSize = int.MaxValue; returnItems = client.Do(out returnMsg, context, splitBy, REArray); foreach (EntityKey returnInfo in returnItems) { strlog.AppendLine("返回信息(returnInfo.ID):" + returnInfo.ID); rtnRcvInfo rtnpo = new rtnRcvInfo(); //行信息 服务不返回 sql查询 string sql = @"select A.DocNo as docNo,A1.DocLineNo as docLineNo,A1.ItemInfo_ItemCode,A1.ID as lineID from PM_Receivement A left join PM_RcvLine A1 on A.ID=A1.Receivement where A.ID='{0}'"; sql = string.Format(sql, returnInfo.ID); DataTable dt = DBhlper.Query(sql, Appconfig.GetU9ConnStr()); if (dt.Rows.Count > 0) { List pOLines = new List(); foreach (DataRow dr in dt.Rows) { rtnpo.DocNo = dr["docNo"].ToString(); rtnpo.IsSuccess = true; rtnRcvLine line = new rtnRcvLine(); line.LineNo = int.Parse(dr["docLineNo"].ToString()); pOLines.Add(line); } rtnpo.rtnLines = pOLines.ToArray(); } rtnpos.Add(rtnpo); } strlog.AppendLine("返回数据:"); foreach (var info in rtnpos) { strlog.AppendLine("单号:" + info.DocNo); strlog.AppendLine("结果:" + info.IsSuccess); strlog.AppendLine("返回消息:" + info.Message); foreach (var _line in info.rtnLines) { strlog.AppendLine("行号:" + _line.LineNo); } } strlog.AppendLine("*****************************************************"); Appconfig.WriteLogFile(strlog.ToString(), "创建销售退货单"); return rtnpos; } catch (Exception ex) { //异常信息捕获 List rtnpos = new List(); rtnRcvInfo rtnpo = new rtnRcvInfo(); rtnpo.IsSuccess = false; rtnpo.Message = GetExceptionMessage(ex); rtnpos.Add(rtnpo); StringBuilder strlog = new StringBuilder(); strlog.AppendLine("创建销售退货单"); strlog.AppendLine("*****************************************************"); foreach (var item in rCVInfoList) { strlog.AppendLine("来源退回处理单号:" + item.srcDocPONo); foreach (var line in item.lines) { strlog.AppendLine("来源退回处理单行号:" + line.srcDocPOLineNo); strlog.AppendLine("料品编码:" + line.ItemCode); strlog.AppendLine("料品数量:" + line.ReqQty); strlog.AppendLine("仓库:" + line.WhCode); strlog.AppendLine("库存批号:" + line.RcvLot); strlog.AppendLine("用户编号:" + line.UserCode); strlog.AppendLine("组织编号:" + line.FurnaceNo); } } strlog.AppendLine("返回消息:" + rtnpo.Message); strlog.AppendLine("*****************************************************"); Appconfig.WriteLogFile(strlog.ToString(), "创建销售退货单"); return rtnpos; } #endregion } #region 判断仓库 public static bool WHLotCheckState(string WHCode, string OrgCode) { string sql = @"select IsLot from CBO_WH A LEFT JOIN Base_Organization B ON B.ID=A.ORG where A.Code='{0}' AND B.CODE='{1}'"; sql = string.Format(sql, WHCode, OrgCode); DataTable dt = DBhlper.Query(sql, Appconfig.GetU9ConnStr()); if (dt.Rows[0]["IsLot"].ToString() == "True") { return true; } else { return false; } } #endregion #region 表头类 public class rCVhead { private rCVLine[] _lines; private string _srcDocPONo; private string _DocType; //private string _ASNNO; public rCVLine[] lines { get { return _lines; } set { _lines = value; } } /// /// 来源采购订单 /// public string srcDocPONo { get { return _srcDocPONo; } set { _srcDocPONo = value; } } //public string ASNNO //{ // get { return _ASNNO; } // set { _ASNNO = value; } //} public string DocType { get { return _DocType; } set { _DocType = value; } } } #endregion #region 表体类 public class rCVLine { /// /// 数量 /// public decimal ReqQty { get; set; } public string WhCode { get; set; } //public string BinCode { get; set; } /// /// 站点 /// public string FurnaceNo { get; set; } /// /// 来源采购订单料号 /// public string ItemCode { get; set; } /// /// 来源采购订单行 /// public int srcDocPOLineNo { get; set; } /// /// 库存批号 /// public string RcvLot { get; set; } /// /// 业务员ID /// public string UserID { get; set; } /// /// 业务员Code /// public string UserCode { get; set; } /// /// 批号创建时间 /// //public DateTime LotCreateTime { get; set; } } #endregion #region 提取异常信息 /// /// 提取异常信息 /// /// private string GetExceptionMessage(Exception ex) { string faultMessage = "未知错误,请查看ERP日志!"; System.TimeoutException timeoutEx = ex as System.TimeoutException; if (timeoutEx != null) { faultMessage = "访问服务超时,请修改配置信息!"; } else { FaultException faultEx = ex as FaultException; if (faultEx == null) { faultMessage = ex.Message; } else { ServiceException serviceEx = faultEx.Detail; if (serviceEx != null && !string.IsNullOrEmpty(serviceEx.Message) && !serviceEx.Message.Equals("fault", StringComparison.OrdinalIgnoreCase)) { // 错误信息在faultEx.Message中,请提取, // 格式为"Fault:料品不能为空,请录入\n 在....." int startIndex = serviceEx.Message.IndexOf(":"); int endIndex = serviceEx.Message.IndexOf("\n"); if (endIndex == -1) endIndex = serviceEx.Message.Length; if (endIndex > 0 && endIndex > startIndex + 1) { faultMessage = serviceEx.Message.Substring(startIndex + 1, endIndex - startIndex - 1); } else { faultMessage = serviceEx.Message; } } } } return faultMessage; } #endregion #region 给上下文信息赋值 /// /// 给上下文信息赋值 /// /// private ThreadContext CreateContextObj(string UserID, string UserCode, string OrgID) { // 实例化应用上下文对象 ThreadContext thContext = new ThreadContext(); System.Collections.Generic.Dictionary ns = new Dictionary(); ns.Add("OrgID", OrgID); ns.Add("UserID", UserID); ns.Add("UserCode", UserCode); ns.Add("Datetime", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")); ns.Add("CultureName", ConfigurationManager.AppSettings["cultureName"].ToString()); ns.Add("EnterpriseID", ConfigurationManager.AppSettings["enterpriseID"].ToString()); ns.Add("DefaultCultureName", ConfigurationManager.AppSettings["cultureName"].ToString()); thContext.nameValueHas = ns; return thContext; } #endregion #region 时间戳方法 private DateTime TimestampToDateTime(long timestamp) { DateTime dateTimeStart = TimeZone.CurrentTimeZone.ToLocalTime(new DateTime(1970, 1, 1)); long lTime = timestamp * 10000000; TimeSpan nowTimeSpan = new TimeSpan(lTime); DateTime resultDateTime = dateTimeStart.Add(nowTimeSpan); return resultDateTime; } #endregion #region 返回信息类 public class rtnRcvInfo { public string DocNo { get; set; } public bool IsSuccess { get; set; } public string Message { get; set; } public rtnRcvLine[] rtnLines { get; set; } } public class rtnRcvLine { public int LineNo { get; set; } //public string srcDocNo { get; set; } //public int srcLineNo { get; set; } //public decimal reqQty { get; set; } //public string proCode { get; set; } } #endregion } #region 上下文类信息 public class contextInfo { private long _OrgID; private string _OrgCode; private long _UserID; private string _UserCode; private DateTime _Datetime; private string _CultureName; private string _EnterpriseID; /// /// 组织ID /// public long OrgID { get { return _OrgID; } set { _OrgID = value; } } /// /// 组织编码 /// public string OrgCode { get { return _OrgCode; } set { _OrgCode = value; } } /// /// 操作员ID /// public long UserID { get { return _UserID; } set { _UserID = value; } } /// /// 操作员编码 /// public string UserCode { get { return _UserCode; } set { _UserCode = value; } } /// /// 时间 /// public DateTime Datetime { get { return _Datetime; } set { _Datetime = value; } } /// /// 语言 /// public string CultureName { get { return _CultureName; } set { _CultureName = value; } } /// /// 企业ID号 /// public string EnterpriseID { get { return _EnterpriseID; } set { _EnterpriseID = value; } } public contextInfo() { CultureName = "zh_CN"; Datetime = DateTime.Now; } } #endregion #region 表体类 //public class rCVLine //{ // /// // /// 来源采购订单 // /// // public string srcDocPONo { get; set; } // private int _srcDocPOLineNo; // private decimal _reqQty; // public string WhCode { get; set; } // /// // /// 炉号 // /// // public string FurnaceNo { get; set; } // /// // /// 数量 // /// // public decimal ReqQty // { // get { return _reqQty; } // set { _reqQty = value; } // } // /// // /// 来源采购订单行 // /// // public int srcDocPOLineNo // { // get { return _srcDocPOLineNo; } // set { _srcDocPOLineNo = value; } // } //} #endregion }