|
|
using ICSSoft.Common;using ICSSoft.Entity;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{ public class OutsourcingSevice { private static log4net.ILog log = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); private static string connString = System.Configuration.ConfigurationManager.AppSettings["ConnStr"]; private static string ERPDB = System.Configuration.ConfigurationManager.AppSettings["ERPDB"]; DataTable table = null; DataTable tableInfo = null; SqlConnection conn = new System.Data.SqlClient.SqlConnection(connString); string sql = string.Empty; string sqlInfo = string.Empty; /// <summary>
/// 委外送货单
/// </summary>
/// <param name="JsonData"></param>
/// <returns></returns>
public OutsourcingModelInfo Get(OutsourcingModel model) { conn.Open(); SqlTransaction sqlTran = conn.BeginTransaction(); SqlCommand cmd = new SqlCommand(); cmd.Transaction = sqlTran; cmd.Connection = conn; try { sql = @"
select a.ID, a.OASNCode, b.VenCode , b.VenName, a.MUSER, a.MTIME from ICSOASN a left join ICSVendor b on a.VenCode=b.VenCode where 1=1 ";
if (!string.IsNullOrEmpty(model.OASNCode)) { sql += " and a.OASNCode={0}"; } if (!string.IsNullOrEmpty(model.User)) { sql += " and a.MUSER={1}"; } if (model.MTime > new DateTime(2000, 01, 01)) { //throw new Exception("请输入正确的操作时间：" + model.MTime);
sql += " and a.MTIME={2}"; } sql = string.Format(sql, model.OASNCode, model.User, model.MTime); table = DBHelper.SQlReturnData(sql, cmd);
sqlInfo = @"select
a.Sequence, a.LotNo, a.Quantity, a.Amount, b.InvCode from ICSOASNDetail a left join ICSInventoryLot b on a.LotNo=b.LotNo where 1=1";
if (!string.IsNullOrEmpty(model.OASNCode)) { sqlInfo += " and a.OASNCode=(select OASNCode from ICSOASN where OASNCode={0} )"; } sqlInfo = string.Format(sqlInfo, model.OASNCode); tableInfo = DBHelper.SQlReturnData(sqlInfo, cmd); string json = JsonConvert.SerializeObject(table); string jsonInfo = JsonConvert.SerializeObject(tableInfo); string jsonList = null; if (table.Rows.Count > 0) { foreach (DataRow item in table.Rows) { OutsourcingModelInfo main = new OutsourcingModelInfo(); main.ID = item["ID"].ToString(); main.User = item["MUSER"].ToString(); main.VenName = item["VenName"].ToString(); main.VenCode = item["VenCode"].ToString(); main.MTime = Convert.ToDateTime(item["MTime"]); List<OutsourcingModelInfos> list = new List<OutsourcingModelInfos>(); foreach (DataRow dt in tableInfo.Rows) { OutsourcingModelInfos detail = new OutsourcingModelInfos(); detail.LotNO = dt["LotNO"].ToString(); detail.InvCode = dt["InvCode"].ToString(); detail.Quantity = dt["Quantity"].ToString(); detail.Sequence = dt["Sequence"].ToString(); list.Add(detail); } main.detail = list; jsonList = JsonConvert.SerializeObject(main); } var deliveryNotrModelInfo = JsonConvert.DeserializeObject<OutsourcingModelInfo>(jsonList); cmd.Transaction.Commit(); return deliveryNotrModelInfo; }
return null;
} 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(); }
}
/// <summary>
/// 添加
/// </summary>
/// <param name="model"></param>
/// <returns></returns>
public int Create(List<NoticeCreateIModel> model) { string sqlERP = string.Empty;//ERP的表头
string sqlERPDetil = string.Empty;//ERP的表体
string jsonERP = string.Empty;///erpjson
string IstrErp = string.Empty; string iresult = string.Empty;//接口调用
string WorkPoint = string.Empty; string res = string.Empty; conn.Open(); SqlTransaction sqlTran = conn.BeginTransaction(); SqlCommand cmd = new SqlCommand(); cmd.Transaction = sqlTran; cmd.Connection = conn; int num = 0; Random Rdm = new Random(); int iRdm = Rdm.Next(0, 100); try { foreach (var item in model) { string ISsqlInfos = @"select * from ICSODeliveryNotice where OASNCode='{0}' "; ISsqlInfos = string.Format(ISsqlInfos, item.TransCode); DataTable dataInfos = DBHelper.SQlReturnData(ISsqlInfos, cmd); if (dataInfos.Rows.Count > 0) { throw new Exception("请勿重复到货！"); } foreach (var itemInfo in item.Detail) { WorkPoint = itemInfo.WorkPoint; string ISsql = @"select * from ICSOASN a left join ICSOASNDetail b on a.OASNCode=b.OASNCode where b.LotNo='{0}' and B.WorkPoint='{1}' "; ISsql = string.Format(ISsql, itemInfo.LotNO, itemInfo.WorkPoint); DataTable data = DBHelper.SQlReturnData(ISsql, cmd); if (data.Rows.Count <= 0) { throw new Exception("送货单不存在！"); } else { string ISsqlInfo = @"select * from ICSOASN a left join ICSOASNDetail b on a.OASNCode=b.OASNCode where b.LotNo='{0}' and B.WorkPoint='{1}' and a.Status='2'"; ISsqlInfo = string.Format(ISsqlInfo, itemInfo.LotNO, itemInfo.WorkPoint); DataTable dataInfo = DBHelper.SQlReturnData(ISsqlInfo, cmd); if (dataInfo.Rows.Count <= 0) { throw new Exception("送货单未审核！"); } else {
//修改子表
string sql = @"UPDATE ICSOASNDetail set ODNQuantity=(select sum(ODNQuantity) from ICSOASNDetail where LotNo='{0}' and WorkPoint='{1}') +'{2}' where LotNo='{0}' and WorkPoint='{1}' "; sql = string.Format(sql, itemInfo.LotNO, itemInfo.WorkPoint, itemInfo.Quantity); cmd.CommandText = sql; num = cmd.ExecuteNonQuery();
} } }
string Date = DateTime.Now.ToString("yy"); string Pre = "ODN" + iRdm + Date; ///添加到到货单表
string sqlInfo = @"
INSERT INTO [dbo].[ICSODeliveryNotice]([ID],[ODNCode],[Sequence],[VenCode],[DepCode],[ODNType],[InvCode],[Quantity],[Amount] ,[RCVQuantity],[UnitPrice] ,[Currency],[Status] ,[CreatePerson] ,[CreateDateTime],[POID] ,[PODetailID] ,[ODNID] ,[ODNDetailID] ,[ExtensionID] ,[MUSER] ,[MUSERName] ,[MTIME] ,[WorkPoint] ,[EATTRIBUTE1] ,[OASNCode]) (SELECT NEWID(),'{0}',row_number() OVER (ORDER BY b.InvCode),d.VenCode,d.DepCode,'1',b.InvCode,SUM(a.ODNQuantity),'0','0',d.UnitPrice,d.Currency,'2' ,'{1}',GETDATE(),d.OOID,d.OODetailID,'0','0',b.ExtensionID,'{1}',e.F_RealName,GETDATE(),'{2}','',a.OASNCode FROM ICSOASNDetail a INNER JOIN ICSInventoryLot b ON a.LotNo=b.LotNo AND a.WorkPoint=b.WorkPoint INNER JOIN ICSInventoryLotDetail c ON b.LotNo=c.LotNo AND b.WorkPoint=c.WorkPoint INNER JOIN ICSOutsourcingOrder d ON c.TransCode=d.OOCode AND c.TransSequence=d.Sequence AND c.WorkPoint=d.WorkPoint INNER JOIN Sys_SRM_User e ON e.F_Account='{1}' AND e.F_Location='{2}' WHERE a.OASNCode='{3}' GROUP BY d.OOID,d.OODetailID,d.VenCode,d.UnitPrice,d.Currency,d.DepCode,b.ExtensionID,b.InvCode,a.OASNCode,e.F_RealName) ";
sqlInfo = string.Format(sqlInfo, Pre, item.User, WorkPoint, item.TransCode); //sqlInfo = string.Format(sqlInfo, Pre, item.VenCode, itemInfo.DepCode, itemInfo.Amount, itemInfo.Quantity, itemInfo.UnitPrice, itemInfo.Currency, item.User, DateTime.Now, itemInfo.WorkPoint, item.TransCode, itemInfo.Sequence, itemInfo.InvCode);
cmd.CommandText = sqlInfo; num = cmd.ExecuteNonQuery();
#region ERP
sqlERP = @"select a.VenCode,a.DepCode,b.OOCode,a.MUSER,(getdate())as Mtime from ICSODeliveryNotice a
left join ICSOutsourcingOrder b on a.poid = b.OOID and a.PODetailID = b.OODetailID left join ICSOASNDetail c on c.OASNCode = a.OASNCode where a.OASNCode = '{0}'and A.WorkPoint = '{1}' group by a.VenCode,a.DepCode,b.OOCode,a.MUSER";
sqlERP = string.Format(sqlERP, item.TransCode, WorkPoint); table = DBHelper.SQlReturnData(sqlERP, cmd);
sqlERPDetil = @"select a.Sequence,a.InvCode,sum(a.RCVQuantity) as Quantity ,a.Amount,isnull((a.UnitPrice),0) as UnitPrice,a.Currency,PODetailID ,
cFree1,cFree2,cFree3,cFree4,cFree5,cFree6,cFree7,cFree8,cFree9,cFree10 from ICSODeliveryNotice A left join ICSOutsourcingOrder b on a.poid=b.OOID and a.PODetailID=b.OODetailID left join ICSOASNDetail c on c.OASNCode=a.OASNCode LEFT JOIN ICSExtension d ON A.ExtensionID=B.ID where a.OASNCode='{0}'and A.WorkPoint='{1}' group by a.Sequence,a.InvCode,a.Amount,a.UnitPrice,a.Currency,PODetailID, cFree1,cFree2,cFree3,cFree4,cFree5,cFree6,cFree7,cFree8,cFree9,cFree10 ";
sqlERPDetil = string.Format(sqlERPDetil, item.TransCode, WorkPoint); DataTable ERPtable = DBHelper.SQlReturnData(sqlERPDetil, cmd);
List<ERPDeliveryNotice> docmodel = new List<ERPDeliveryNotice>(); foreach (DataRow dtIn in table.Rows) { ERPDeliveryNotice doc = new ERPDeliveryNotice(); doc.VenCode = dtIn["VenCode"].ToString(); doc.DepCode = dtIn["DepCode"].ToString(); doc.OOCode = dtIn["OOCode"].ToString(); doc.User = dtIn["MUSER"].ToString(); doc.MTime = dtIn["Mtime"].ToString(); List<ERPDeliveryNoticeList> list = new List<ERPDeliveryNoticeList>(); foreach (DataRow dtList in ERPtable.Rows) { ERPDeliveryNoticeList docc = new ERPDeliveryNoticeList(); docc.Sequence = dtList["Sequence"].ToString(); docc.InvCode = dtList["InvCode"].ToString(); docc.Quantity = dtList["Quantity"].ToString(); docc.Amount = dtList["Amount"].ToString(); docc.Currency = dtList["Currency"].ToString(); docc.UnitPrice = dtList["UnitPrice"].ToString(); docc.OODetailID = dtList["PODetailID"].ToString();
docc.cFree1 = dtList["cFree1"].ToString(); docc.cFree2 = dtList["cFree2"].ToString(); docc.cFree3 = dtList["cFree3"].ToString(); docc.cFree4 = dtList["cFree4"].ToString(); docc.cFree5 = dtList["cFree5"].ToString(); docc.cFree6 = dtList["cFree6"].ToString(); docc.cFree7 = dtList["cFree7"].ToString(); docc.cFree8 = dtList["cFree8"].ToString(); docc.cFree9 = dtList["cFree9"].ToString(); docc.cFree10 = dtList["cFree10"].ToString(); list.Add(docc); }
doc.details = list; docmodel.Add(doc); } IstrErp = JsonConvert.SerializeObject(docmodel); log.Info("委外到货ERPJSON" + IstrErp); iresult = HttpPost("委外到货", ERPUrl.ODeliveryNoticeURL, IstrErp); Result OtherOutResult = new Result(); OtherOutResult = JsonConvert.DeserializeObject<Result>(iresult);
if (OtherOutResult.Success == false) { throw new Exception(OtherOutResult.Message); } else { List<ERPJsonRetun> list = new List<ERPJsonRetun>(); //string nn = OtherOutResult.Data.ToString();//LOTStockModel
list = JsonConvert.DeserializeObject<List<ERPJsonRetun>>(OtherOutResult.Data.ToString()); foreach (var items in list) { string ERPupdate = @"update ICSODeliveryNotice set ODNCode='{0}',Sequence='{1}',ODNID='{2}',ODNDetailID='{3}',ODNType='1'
where OASNCode='{4}' ";
ERPupdate = string.Format(ERPupdate, items.ODNCode, items.Sequence, items.ID, items.DetailID, item.TransCode, DateTime.Now); cmd.CommandText = ERPupdate; num = cmd.ExecuteNonQuery(); }
} #endregion
} num = cmd.ExecuteNonQuery(); if (num > 0) { cmd.Transaction.Commit(); } else { cmd.Transaction.Rollback(); }
return num; } 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(); }
}
/// <summary>
/// 删除委外数据(物理删除)
/// </summary>
/// <param name="model"></param>
/// <returns></returns>
public string Delete(NoticeDelete model) { string res = string.Empty; conn.Open(); SqlTransaction sqlTran = conn.BeginTransaction(); SqlCommand cmd = new SqlCommand(); cmd.Transaction = sqlTran; cmd.Connection = conn; try { //委外送货详情表删除
sql = @" DELETE FROM ICSOASNDetail
WHERE OASNCode=(select OASNCode from ICSOASN where id='{0}') ";
sqlInfo = @" DELETE FROM ICSOASN where 1=1 "; if (model.ID != null) { sqlInfo += " and id='{0}'"; } if (model.MTime != null) { sqlInfo += " and MTIME='{1}'"; } if (model.User != null) { sqlInfo += " and MUSER='{2}'"; } sql = string.Format(sql, model.ID); sqlInfo = string.Format(sqlInfo, model.ID, model.MTime, model.User); DBHelper.CmdExecuteNonQuery(sql, cmd, "送货单：" + model.ID + "未查询到对应数据！"); DBHelper.CmdExecuteNonQuery(sqlInfo, cmd, "送货单：" + model.ID + "未查询到对应数据！"); cmd.Transaction.Commit(); return res; } 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(); } }
#region 接口调用
public static string HttpPost(string apiName, string url, string body) { try { Encoding encoding = Encoding.UTF8; System.Net.HttpWebRequest request = (System.Net.HttpWebRequest)System.Net.WebRequest.Create(url); request.Method = "POST"; request.Accept = "application/json, text/javascript, */*"; //"text/html, application/xhtml+xml, */*";
request.ContentType = "application/json; charset=utf-8";
byte[] buffer = encoding.GetBytes(body); request.ContentLength = buffer.Length; request.GetRequestStream().Write(buffer, 0, buffer.Length); System.Net.HttpWebResponse response = (System.Net.HttpWebResponse)request.GetResponse(); using (System.IO.StreamReader reader = new System.IO.StreamReader(response.GetResponseStream(), encoding)) { return reader.ReadToEnd(); } } catch (System.Net.WebException ex) { throw new Exception(apiName + "调用失败," + ex.Message);
} } #endregion
}}
|
