|
|
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.CreateLotMaster; using UFSoft.UBF.Service; using UFSoft.UBF.Util.Context; using www.ufida.org.EntityData;
namespace UFIDA.ISV.CreateBFPMRecede {
public class CustCreateBFPMRecedeSrvSub { public List<rtnRcvInfo> CustCreateBFPMRecede(List<rCVhead> rCVInfoList) { #region 接口传入参数日志
StringBuilder firststrlog = new StringBuilder(); firststrlog.AppendLine("传入数据开始"); firststrlog.AppendLine("*****************************************************"); foreach (var item in rCVInfoList) { firststrlog.AppendLine("来源委外采购订单号:" + item.srcDocPONo); firststrlog.AppendLine("组织编码:" + item.OrgCode); foreach (var line in item.lines) { firststrlog.AppendLine("来源委外采购订单行:" + line.srcDocPOLineNo); firststrlog.AppendLine("料品编码:" + line.ItemCode); firststrlog.AppendLine("料品数量:" + line.ReqQty); firststrlog.AppendLine("批号:" + line.Batch); firststrlog.AppendLine("仓库:" + line.WhCode); } } firststrlog.AppendLine("*****************************************************"); firststrlog.AppendLine("传入数据结束"); Appconfig.WriteLogFile(firststrlog.ToString(), "创建委外退料单"); #endregion
#region 服务调用框架结构
UFIDAU9ISVPMIssueICreatPMRecedeIssueDocSVClient client = new UFIDAU9ISVPMIssueICreatPMRecedeIssueDocSVClient(); //服务返回结果
string[] returnItems; //返回异常信息,目前还没有使用此属性
UFSoft.UBF.Exceptions1.MessageBase[] returnMsg; //上下文信息
object context; //传入 参数
UFIDAU9ISVPMIssuePMRecedeItemAndSnDTOData[] pOList; //空
string[] splitBy = new string[] { };
try { string OrgID = ""; List<rtnRcvInfo> rtnpos = new List<rtnRcvInfo>(); long PickID = 0; long ItemID = 0; if (rCVInfoList == null || rCVInfoList.Count == 0) { StringBuilder errormsg = new StringBuilder(); errormsg.AppendLine("*********************报错记录开始*********************"); errormsg.AppendLine("传入参数不能为空!"); errormsg.AppendLine("*********************报错记录结束*********************"); Appconfig.WriteLogFile(errormsg.ToString(), "创建委外退料单"); 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) { StringBuilder errormsg = new StringBuilder(); errormsg.AppendLine("*********************报错记录开始*********************"); errormsg.AppendLine("传入行信息不能为空!"); errormsg.AppendLine("*********************报错记录结束*********************"); Appconfig.WriteLogFile(errormsg.ToString(), "创建委外退料单"); rtnRcvInfo rtnpo = new rtnRcvInfo(); rtnpo.IsSuccess = false; rtnpo.Message = "传入行信息不能为空"; rtnpos.Add(rtnpo); return rtnpos; } string orgsql = @"select ID from Base_Organization
where Code='{0}'";
orgsql = string.Format(orgsql, item.OrgCode); DataTable orgdt = DBhlper.Query(orgsql, Appconfig.GetU9ConnStr()); if (orgdt.Rows.Count != 0) { OrgID = orgdt.Rows[0]["ID"].ToString(); } else { StringBuilder errormsg = new StringBuilder(); errormsg.AppendLine("*********************报错记录开始*********************"); errormsg.AppendLine("传入组织编码:" + item.OrgCode + "不存在!"); errormsg.AppendLine("*********************报错记录结束*********************"); Appconfig.WriteLogFile(errormsg.ToString(), "创建委外退料单"); rtnRcvInfo rtnpo = new rtnRcvInfo(); rtnpo.IsSuccess = false; rtnpo.Message = "传入组织编码:" + item.OrgCode + "不存在!"; rtnpos.Add(rtnpo); return rtnpos; } foreach (var _item in item.lines) { if (_item.srcDocPOLineNo == 0) { StringBuilder errormsg = new StringBuilder(); errormsg.AppendLine("*********************报错记录开始*********************"); errormsg.AppendLine("请传入来源单据行号!"); errormsg.AppendLine("*********************报错记录结束*********************"); Appconfig.WriteLogFile(errormsg.ToString(), "创建委外退料单"); rtnRcvInfo rtnpo = new rtnRcvInfo(); rtnpo.IsSuccess = false; rtnpo.Message = "请传入来源单据行号"; rtnpos.Add(rtnpo); return rtnpos; } if (_item.ReqQty == 0) { StringBuilder errormsg = new StringBuilder(); errormsg.AppendLine("*********************报错记录开始*********************"); errormsg.AppendLine("传入数量不能为空!"); errormsg.AppendLine("*********************报错记录结束*********************"); Appconfig.WriteLogFile(errormsg.ToString(), "创建委外退料单"); rtnRcvInfo rtnpo = new rtnRcvInfo(); rtnpo.IsSuccess = false; rtnpo.Message = "传入数量不能为空"; rtnpos.Add(rtnpo); return rtnpos; } } } //给传入参数赋值
//pOList = SetrCVDtos(rCVInfoList);
StringBuilder strlog = new StringBuilder(); strlog.AppendLine("创建委外退料单"); strlog.AppendLine("*****************************************************");
List<UFIDAU9ISVPMIssuePMRecedeItemAndSnDTOData> rCVList = new List<UFIDAU9ISVPMIssuePMRecedeItemAndSnDTOData>(); foreach (var rCVhead in rCVInfoList) { strlog.AppendLine("来源委外发料单号:" + rCVhead.srcDocPONo); foreach (rCVLine line in rCVhead.lines) { UFIDAU9ISVPMIssuePMRecedeItemAndSnDTOData rCV = new UFIDAU9ISVPMIssuePMRecedeItemAndSnDTOData();
#region 获取委外发料单ID
string sqlPick = @"select B.ID,B.POPick,B.IsIssued from PM_IssueDoc A
LEFT JOIN PM_IssueDocLine B ON B.PMIssueDoc=A.ID where A.DocNo='" + rCVhead.srcDocPONo + "' AND B.LineNum='" + line.srcDocPOLineNo + "' AND A.Org='" + OrgID + "'";
sqlPick = string.Format(sqlPick); DataTable dtPick = DBhlper.Query(sqlPick, Appconfig.GetU9ConnStr()); if (dtPick.Rows.Count > 0) { if (dtPick.Rows[0]["IsIssued"].ToString() == "0") { rtnRcvInfo rtnpo = new rtnRcvInfo(); rtnpo.IsSuccess = false; rtnpo.Message = "委外发料单" + rCVhead.srcDocPONo + "尚未进行发料确认,无法退料!"; rtnpos.Add(rtnpo); return rtnpos; } else {
rCV.m_pickID = long.Parse(dtPick.Rows[0]["POPick"].ToString()); } } else { rtnRcvInfo rtnpo = new rtnRcvInfo(); rtnpo.IsSuccess = false; rtnpo.Message = "委外发料单行不存在!"; rtnpos.Add(rtnpo); return rtnpos; } #endregion
#region 获取退料料品ID
string sqlitem = @"select ID from CBO_ItemMaster
where Code='" + line.ItemCode + "' AND Org='" + OrgID + "'";
sqlitem = string.Format(sqlitem); DataTable dtitem = DBhlper.Query(sqlitem, Appconfig.GetU9ConnStr()); if (dtitem.Rows.Count > 0) { ItemID = long.Parse(dtitem.Rows[0]["ID"].ToString()); } else { rtnRcvInfo rtnpo = new rtnRcvInfo(); rtnpo.IsSuccess = false; rtnpo.Message = "料品不存在!"; rtnpos.Add(rtnpo); return rtnpos; } #endregion
rCV.m_itemCode = line.ItemCode; rCV.m_recedeQty = line.ReqQty; rCV.m_recedeReason = 1; string sqlWH = @"select ID,Code from CBO_Wh
WHERE Code='" + line.WhCode + "' AND Org='" + OrgID + "' ";
sqlWH = string.Format(sqlWH); DataTable _dtWH = DBhlper.Query(sqlWH, Appconfig.GetU9ConnStr()); string WHCode = string.Empty; long WHID = 0; if (_dtWH != null && _dtWH.Rows.Count > 0) { WHCode = _dtWH.Rows[0]["Code"].ToString(); WHID = long.Parse(_dtWH.Rows[0]["ID"].ToString()); } if (string.IsNullOrWhiteSpace(WHCode)) { rtnRcvInfo rtnpo = new rtnRcvInfo(); rtnpo.IsSuccess = false; rtnpo.Message = "未获取到仓库"; rtnpos.Add(rtnpo); return rtnpos;
} //仓库
rCV.m_whCode = WHCode; rCV.m_wh = WHID; #region 创建批号接口调用
string LotID = ""; if (line.Batch != "") { CustCreateLotMaster LotMasterCreate = new CustCreateLotMaster(); string lotWHCode = line.WhCode; string lotItemCode = line.ItemCode; string LotCode = line.Batch; LotMasterCreate.CustCreateRCVLotMaster(lotWHCode, lotItemCode, LotCode, OrgID, ref LotID); if (LotID != "") { rCV.m_lotMaster = long.Parse(LotID); rCV.m_lotNo = line.Batch; } } else { rCV.m_lotNo = ""; } #endregion
rCVList.Add(rCV); strlog.AppendLine("来源委外发料单号:" + line.ItemCode); strlog.AppendLine("料品编码:" + line.ItemCode); strlog.AppendLine("料品数量:" + line.ReqQty); strlog.AppendLine("退料仓库:" + WHCode); strlog.AppendLine("批号ID:" + LotID);
} } pOList = rCVList.ToArray();
(client.Endpoint.Binding as BasicHttpBinding).MaxReceivedMessageSize = int.MaxValue; (client.Endpoint.Binding as BasicHttpBinding).MaxBufferSize = int.MaxValue; List<string> shDocList = new List<string>(); StringBuilder finalstr = new StringBuilder(); //给上下文信息赋值
context = CreateContextObj(OrgID); returnItems = client.Do(out returnMsg, context, pOList, false, 2); if (returnItems != null || returnItems.Count() > 0) { List<string> DocNoList = new List<string>(); string SqlDocNo = ""; for (int i = 0; i < returnItems.Count(); i++) { if (SqlDocNo == "") { SqlDocNo += "'" + returnItems[i].ToString() + "'"; } else { SqlDocNo += ",'" + returnItems[i].ToString() + "'"; } DocNoList.Add(returnItems[i].ToString()); } #region 审核之前先写入确认时间
string updatesql = @"update PM_IssueDoc set BusinessCreatedOn=GETDATE()
where DocNo IN ({0}) AND IssueOrg='{1}'";
updatesql = string.Format(updatesql, SqlDocNo, OrgID); DBhlper.EXecute(updatesql, Appconfig.GetU9ConnStr()); #endregion
strlog.AppendLine("开始调用审核委外退料单接口------------"); BFPMRecedeApprove.CustApproveBFPMRecede.OperationResult shresult = new BFPMRecedeApprove.CustApproveBFPMRecede.OperationResult(); BFPMRecedeApprove.CustApproveBFPMRecede PMRecedeApprove = new BFPMRecedeApprove.CustApproveBFPMRecede(); shresult = PMRecedeApprove.CustBFPMRecedeApprove(DocNoList, OrgID, "审核"); if (shresult.IsSuccess == true) { rtnRcvInfo rtnpo = new rtnRcvInfo(); rtnpo.IsSuccess = true; rtnpo.Message = "委外退料单审核成功"; rtnpo.DocNo = SqlDocNo; rtnpos.Add(rtnpo); } else { strlog.AppendLine("开始调用删除委外退料单接口------------"); BFPMRecedeDelete.CustDeleteBFPMRecede.CustBFPMRecedeDelete(DocNoList, OrgID); rtnRcvInfo rtnpo = new rtnRcvInfo(); rtnpo.IsSuccess = false; rtnpo.Message = "委外退料单审核失败"; rtnpo.DocNo = shresult.MESSAGE; rtnpos.Add(rtnpo); return rtnpos; } } 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<rtnRcvInfo> rtnpos = new List<rtnRcvInfo>(); 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("返回消息:" + rtnpo.Message); strlog.AppendLine("*****************************************************"); Appconfig.WriteLogFile(strlog.ToString(), "创建委外退料单");
return rtnpos; } #endregion
}
#region 给传入参数赋值
private UFIDAU9ISVPMIssuePMRecedeItemAndSnDTOData[] SetrCVDtos(List<rCVhead> headList) {
List<UFIDAU9ISVPMIssuePMRecedeItemAndSnDTOData> rCVList = new List<UFIDAU9ISVPMIssuePMRecedeItemAndSnDTOData>(); foreach (var rCVhead in headList) { foreach (rCVLine line in rCVhead.lines) { UFIDAU9ISVPMIssuePMRecedeItemAndSnDTOData rCV = new UFIDAU9ISVPMIssuePMRecedeItemAndSnDTOData(); rCV.m_snCode = rCVhead.srcDocPONo;
rCV.m_itemCode = line.ItemCode;
rCV.m_recedeQty = line.ReqQty;
rCV.m_whCode = line.WhCode;
rCVList.Add(rCV); } }
return rCVList.ToArray(); } #endregion
#region 表头类
public class rCVhead { private rCVLine[] _lines; private string _srcDocPONo; private string _OrgCode;
//private string _DocType;
public rCVLine[] lines { get { return _lines; } set { _lines = value; } }
/// <summary>
/// 来源委外采购订单
/// </summary>
public string srcDocPONo { get { return _srcDocPONo; } set { _srcDocPONo = value; } }
/// <summary>
/// 组织编码
/// </summary>
public string OrgCode { get { return _OrgCode; } set { _OrgCode = value; } }
//public string DocType
//{
// get { return _DocType; }
// set { _DocType = value; }
// }
} #endregion
#region 表体类
public class rCVLine { /// <summary>
/// 数量
/// </summary>
public decimal ReqQty { get; set; }
public string WhCode { get; set; }
//public string BinCode { get; set; }
/// <summary>
/// 炉号
/// </summary>
//public string FurnaceNo { get; set; }
/// <summary>
/// 来源委外采购订单料号
/// </summary>
public string ItemCode { get; set; }
/// <summary>
/// 来源委外采购订单行
/// </summary>
public int srcDocPOLineNo { get; set; }
/// <summary>
/// 库存批号
/// </summary>
public string Batch { get; set; } } #endregion
#region 提取异常信息
/// <summary>
/// 提取异常信息
/// </summary>
/// <param name="ex"></param>
private string GetExceptionMessage(Exception ex) { string faultMessage = "未知错误,请查看ERP日志!";
System.TimeoutException timeoutEx = ex as System.TimeoutException; if (timeoutEx != null) { faultMessage = "访问服务超时,请修改配置信息!"; } else { FaultException<ServiceException> faultEx = ex as FaultException<ServiceException>; 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 给上下文信息赋值
/// <summary>
/// 给上下文信息赋值
/// </summary>
/// <returns></returns>
private ThreadContext CreateContextObj(string OrgID) { // 实例化应用上下文对象
ThreadContext thContext = new ThreadContext();
System.Collections.Generic.Dictionary<object, object> ns = new Dictionary<object, object>(); ns.Add("OrgID", OrgID); ns.Add("UserID", ConfigurationManager.AppSettings["userID"].ToString()); ns.Add("UserCode", ConfigurationManager.AppSettings["userCode"].ToString()); 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 contextInfo { private long _OrgID; private string _OrgCode; private long _UserID; private string _UserCode; private DateTime _Datetime; private string _CultureName; private string _EnterpriseID;
/// <summary>
/// 组织ID
/// </summary>
public long OrgID { get { return _OrgID; } set { _OrgID = value; } }
/// <summary>
/// 组织编码
/// </summary>
public string OrgCode { get { return _OrgCode; } set { _OrgCode = value; } }
/// <summary>
/// 操作员ID
/// </summary>
public long UserID { get { return _UserID; } set { _UserID = value; } }
/// <summary>
/// 操作员编码
/// </summary>
public string UserCode { get { return _UserCode; } set { _UserCode = value; } }
/// <summary>
/// 时间
/// </summary>
public DateTime Datetime { get { return _Datetime; } set { _Datetime = value; } }
/// <summary>
/// 语言
/// </summary>
public string CultureName { get { return _CultureName; } set { _CultureName = value; } }
/// <summary>
/// 企业ID号
/// </summary>
public string EnterpriseID { get { return _EnterpriseID; } set { _EnterpriseID = value; } }
public contextInfo() { CultureName = "zh-CN"; Datetime = DateTime.Now; } } #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 rCVLine
//{
// /// <summary>
// /// 来源采购订单
// /// </summary>
// public string srcDocPONo { get; set; }
// private int _srcDocPOLineNo;
// private decimal _reqQty;
// public string WhCode { get; set; }
// /// <summary>
// /// 炉号
// /// </summary>
// public string FurnaceNo { get; set; }
// /// <summary>
// /// 数量
// /// </summary>
// public decimal ReqQty
// {
// get { return _reqQty; }
// set { _reqQty = value; }
// }
// /// <summary>
// /// 来源采购订单行
// /// </summary>
// public int srcDocPOLineNo
// {
// get { return _srcDocPOLineNo; }
// set { _srcDocPOLineNo = value; }
// }
//}
#endregion
}
|