using iWareSAP.Cache.Entity;
|
using iWareSAP.IDOC.Entity;
|
using iWareSAP.IDOC.EnumType;
|
using iWareSAP.Properties;
|
using iWareSAP.WCF;
|
using System;
|
using System.Collections.Generic;
|
using System.Configuration;
|
using System.Diagnostics;
|
using System.IO;
|
using System.ServiceModel;
|
using System.Threading;
|
using System.Windows.Forms;
|
using UtilDll.UTIL;
|
using System.Linq;
|
using Newtonsoft.Json;
|
|
namespace iWareSAP
|
{
|
public partial class MainForm : Form
|
{
|
//库存盘点 不是立库的数据过滤掉 李翠国2021-9-18 改
|
//库存盘点 取消分批发送数据给wms （每次100条，这样只会盘点最后一次）李翠国2021-9-18
|
private ServiceHost _sapWcfHost = null;
|
private List<Thread> _readFileThreads = null;
|
private string _logDir;
|
|
public MainForm()
|
{
|
|
var proc = new Process();
|
try
|
{
|
InitializeComponent();
|
_logDir = Resources.LogDir + @"\YIRUANTONG";
|
_sapWcfHost = new ServiceHost(typeof(SapWcfService));
|
try
|
{
|
proc.StartInfo.FileName = "cmd.exe";
|
proc.StartInfo.UseShellExecute = false;
|
proc.StartInfo.RedirectStandardInput = true;
|
proc.StartInfo.RedirectStandardOutput = true;
|
proc.StartInfo.RedirectStandardError = true;
|
proc.StartInfo.CreateNoWindow = true;
|
proc.Start();
|
var path = ConfigurationManager.AppSettings["SapDir"].ToString();
|
//var password = ";'QpAlZm1234";
|
//var username = "qian.zhuang.ext@siemens.com";
|
|
var username = ConfigurationManager.AppSettings["SapUsername"].ToString();
|
var password = ConfigurationManager.AppSettings["SapPassword"].ToString();
|
proc.StandardInput.WriteLine("net use {0} {1} /user:{2}", path, password, username);
|
|
|
string dosLine = "net use " + path + " ";
|
proc.StandardInput.WriteLine(dosLine);
|
proc.StandardInput.WriteLine("exit");
|
|
while (!proc.HasExited)
|
{
|
proc.WaitForExit(1000);
|
}
|
string errormsg = proc.StandardError.ReadToEnd();
|
proc.StandardError.Close();
|
if (!string.IsNullOrEmpty(errormsg))
|
{
|
throw new Exception(errormsg);
|
}
|
|
}
|
catch (Exception ex)
|
{
|
LogTextHelper.WriteLog(Resources.LogDir, this.ToString(), "ConnectRemote", "已链接： " + ex.Message);
|
}
|
|
_readFileThreads = new List<Thread>();
|
|
}
|
catch (Exception ex)
|
{
|
LogTextHelper.WriteLog(Resources.LogDir, this.ToString(), "ConnectRemote", ex.Message);
|
}
|
finally
|
{
|
proc.Close();
|
proc.Dispose();
|
}
|
|
}
|
|
private void MainForm_Load(object sender, EventArgs e)
|
{
|
try
|
{
|
foreach (var type in Enum.GetValues(typeof(EDocType)))
|
{
|
var readFileThread = new Thread(new ParameterizedThreadStart(readFile));
|
readFileThread.Name = string.Format("iWareSAP读取共享文件线程,type={0}", type.ToString());
|
_readFileThreads.Add(readFileThread);
|
ThreadHelper.StartThread(readFileThread, (int)type);
|
}
|
_sapWcfHost.Open();
|
CacheEntity.SapncoClient.RegisterRfcDestination();
|
}
|
catch (Exception ex)
|
{
|
LogTextHelper.WriteLog(Resources.LogDir, this.ToString(), "MainForm_Load", ex.Message);
|
}
|
}
|
|
private void MainForm_FormClosing(object sender, FormClosingEventArgs e)
|
{
|
if (_sapWcfHost != null)
|
{
|
_sapWcfHost.Close();
|
}
|
//ThreadHelper.CloseThread(_readFileThread);
|
}
|
|
private void readFile(object obj)
|
{
|
var type = (int)obj;
|
var typeNamedict = new Dictionary<int, string>
|
{
|
{ (int)EDocType.物料, "MATMAS"},
|
{ (int)EDocType.出库单, "PPO"},
|
{ (int)EDocType.对账单, "WMS_STOCK"}
|
};
|
var path = ConfigurationManager.AppSettings["SapDir"].ToString();
|
while (true)
|
{
|
try
|
{
|
var files = Directory.GetFiles(path);
|
|
for (var i = 0; i < files.Length; i++)
|
{
|
try
|
{
|
#region 循环处理
|
var filePath = files[i];
|
var fileName = Path.GetFileName(filePath);
|
|
if (fileName.ToUpper().StartsWith(typeNamedict[type]))
|
{
|
|
var delta = 100.0;
|
LogTextHelper.WriteLine(Resources.LogDir, "正在处理文件{0}", filePath);
|
switch (type)
|
{
|
case (int)EDocType.物料:
|
#region sap物料添加修改
|
var materials = new List<Material>();
|
using (var reader = new StreamReader(filePath))
|
{
|
var line = reader.ReadLine();
|
while (!string.IsNullOrEmpty(line))
|
{
|
materials.Add(new Material(line));
|
line = reader.ReadLine();
|
}
|
}
|
//下面的注释,删除文件操作改为调取服务成功后才删除 【EditBy shaocx,2022-06-17】
|
//File.Delete(filePath);
|
for (var j = 0; j < (int)Math.Ceiling(materials.Count / delta); j++)
|
{
|
var ms = new List<WmsWcfService.Material>();
|
for (var r = j * delta; r < j * delta + delta; r++)
|
{
|
if (r == materials.Count)
|
{
|
break;
|
}
|
//LogTextHelper.WriteLine(_logDir, "material={0}", materials[(int)r]);
|
ms.Add(materials[(int)r].ToWmsMaterial());
|
}
|
|
string result_addMaterial = CacheEntity.WmsWcfServiceClient.addMaterial(ms.ToArray());
|
if (!string.IsNullOrEmpty(result_addMaterial))
|
{//失败
|
|
}
|
else
|
{//成功
|
File.Delete(filePath);//删除文件
|
}
|
}
|
|
break;
|
#endregion
|
|
case (int)EDocType.出库单:
|
#region SAP出库单
|
var pickLists = new List<PickList>();
|
var removepickLists = new List<PickList>();
|
using (var reader = new StreamReader(filePath))
|
{
|
var line = reader.ReadLine();
|
while (!string.IsNullOrEmpty(line))
|
{
|
pickLists.Add(new PickList(line));
|
line = reader.ReadLine();
|
}
|
}
|
// File.Move(filePath,path+@"\old");
|
//下面的注释,删除文件操作改为调取服务成功后才删除 【EditBy shaocx,2022-06-17】
|
//File.Delete(filePath);
|
|
if (pickLists.Count > 0)
|
{
|
int newDate = Convert.ToInt32(pickLists[pickLists.Count - 1].BDTER);//最后一个是最新日期
|
foreach (var item in pickLists)
|
{
|
try
|
{
|
int compareDate = Convert.ToInt32(item.BDTER);
|
if (compareDate == newDate)
|
{
|
removepickLists.Add(item);//把新日期全部加入这个集合
|
}
|
}
|
catch (Exception)
|
{
|
}
|
|
}
|
if (removepickLists.Count > 0)
|
{
|
pickLists = removepickLists;
|
}
|
var saleOrder = pickLists[0].ToWmsSaleOrder();
|
var saleOrderLists = new List<WmsWcfService.SaleOrderList>();
|
foreach (var p in pickLists)
|
{
|
if (string.IsNullOrEmpty(p.MATNR))
|
{
|
continue;
|
}
|
|
//LogTextHelper.WriteLine(_logDir, "saleOrderList={0}", p);
|
saleOrderLists.Add(p.ToWmsSaleOrderList());
|
}
|
saleOrder.saleChild = saleOrderLists.ToArray();
|
|
string result = CacheEntity.WmsWcfServiceClient.pickList(saleOrder);
|
|
if (!string.IsNullOrEmpty(result))
|
{//失败,就拷贝放到服务器的某个文件夹中
|
var path_pickList = "D:\\log_MySAP\\Fail_pickList\\" + fileName;
|
if (!File.Exists(path_pickList))
|
{
|
File.Copy(filePath, path_pickList);
|
}
|
}
|
else
|
{//成功
|
File.Move(filePath, "D:\\log_MySAP\\Success_pickList\\" + fileName);//只有成功后才会移走文件
|
}
|
}
|
break;
|
#endregion
|
|
case (int)EDocType.对账单:
|
//文件放到指定目录中，然后再调用服务siemensSapService的takeStock去处理这些信息
|
//File.Move(filePath, "D:\\log_ShuYing\\" + fileName);
|
File.Move(filePath, "D:\\log_takeStock\\" + fileName);//盘点存放文件改为 log_takeStock 【EditBy shaocx,2022-10-12】
|
var ss = new List<WmsWcfService.ProductStock>();
|
string result_takeStock = CacheEntity.WmsWcfServiceClient.takeStock(ss.ToArray());
|
|
|
#region 旧的
|
|
//var stocks = new List<Stock>();
|
|
//using (var reader = new StreamReader(filePath))
|
//{
|
// var line = reader.ReadLine();
|
// while (!string.IsNullOrEmpty(line))
|
// {
|
// if (!line.StartsWith("MATNR"))
|
// {
|
// stocks.Add(new Stock(line));
|
// }
|
// line = reader.ReadLine();
|
// }
|
//}
|
|
////var delta = 100.0; //取消分批发送 （每次100条，这样只会盘点最后一次）李翠国2021-9-18
|
//#region 拆分发送 每次100条
|
// for (var j = 0; j < (int)Math.Ceiling(stocks.Count / delta); j++)
|
//{
|
// var ss = new List<WmsWcfService.ProductStock>();
|
// for (var r = j * delta; r < j * delta + delta; r++)
|
// {
|
// if (r == stocks.Count)
|
// {
|
// break;
|
// }
|
// //LogTextHelper.WriteLine(_logDir, "stock={0}", stocks[(int)r]);
|
// ss.Add(stocks[(int)r].ToWmsProductStock());
|
// }
|
// CacheEntity.WmsWcfServiceClient.takeStock(ss.ToArray());
|
// // File.Delete(filePath);
|
//#endregion
|
|
// //List<WmsWcfService.ProductStock> ss = new List<WmsWcfService.ProductStock>();
|
// //List<WmsWcfService.ProductStock> mergeed = new List<WmsWcfService.ProductStock>();//根据销售单号 销售项号，物料编号，合并相同项
|
// //for (var r = 0 ; r < stocks.Count; r++)
|
// //{
|
// // if (stocks[(int)r].WERKS=="3TG1")//不是立库的过滤掉 李翠国2021-9-18 改
|
// // {
|
// // ss.Add(stocks[(int)r].ToWmsProductStock());
|
// // }
|
|
// //}
|
// //var merge = ss.GroupBy(x => new { x.SaleCode, x.SaleItem, x.materialCode });
|
// //foreach (var item in merge)
|
// //{
|
// // for (int k = 1; k < item.ToList().Count; k++)
|
// // {
|
// // item.ToList()[0].stockQuantity = item.ToList()[0].stockQuantity + item.ToList()[k].stockQuantity;
|
// // }
|
// // mergeed.Add(item.ToList()[0]);
|
// //}
|
// //if (mergeed.Count>0)
|
// //{
|
// // CacheEntity.WmsWcfServiceClient.takeStock(mergeed.ToArray());
|
// // File.Delete(filePath);
|
// }
|
|
#endregion
|
break;
|
|
}
|
|
break;
|
}
|
#endregion
|
}
|
catch (Exception ex)
|
{
|
LogTextHelper.WriteLog(Resources.LogDir, this.ToString(), "readFile内部循环", ex.Message + ",异常行数:" + ex.StackTrace);
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
//LogTextHelper.WriteLog(Resources.LogDir, this.ToString(), "readFile", ex.Message + ",详细堆栈:" + JsonConvert.SerializeObject(ex));
|
LogTextHelper.WriteLog(Resources.LogDir, this.ToString(), "readFile", ex.Message + ",异常行数:" + ex.StackTrace);
|
}
|
finally
|
{
|
|
Thread.Sleep(1000);
|
}
|
}
|
}
|
|
private void button_Click(object sender, EventArgs e)
|
{
|
try
|
{
|
string msg = "";
|
var btn = sender as Button;
|
switch (btn.Name)
|
{
|
case "button1":
|
textBox1.Text = CacheEntity.SapncoClient.InvokeRFCFunctionGetDate(DateTime.Now.ToString("yyyy-MM-dd"));
|
break;
|
case "button2":
|
var po = CacheEntity.SapncoClient.InvokeRFCFunctionGetPoDetail(textBox2.Text.Trim(), out msg);
|
textBox3.Text = string.IsNullOrEmpty(msg) ? po.ToString() : msg;
|
break;
|
case "button3":
|
var res = CacheEntity.SapncoClient.InvokeRFCFunctionWmsReverser(textBox4.Text.Trim(), out msg);
|
textBox3.Text = string.IsNullOrEmpty(msg) ? res.ToString() : msg;
|
break;
|
}
|
}
|
catch (Exception ex)
|
{
|
LogTextHelper.WriteLog(Resources.LogDir, this.ToString(), "button_Click", ex.Message);
|
MessageBox.Show(ex.Message);
|
}
|
}
|
|
private void MainForm_FormClosing_1(object sender, FormClosingEventArgs e)
|
{
|
Environment.Exit(0);//退出本进程所有线程
|
}
|
}
|
}
|
|
|
|
|
|
|
|
|
|
//case "button3":
|
// var grMaterials = new List<GRMaterial>
|
// {
|
// new GRMaterial
|
// {
|
// EBELN = "4507524081",
|
// EBELP = "00010",
|
// MATNR = "A7EQD-5130003798",
|
// BWART = "101",
|
// WERKS = "3TG1",
|
// LGORT = "G021",
|
// MENGE = 1.0m
|
// }
|
// };
|
// var res = CacheEntity.SapncoClient.InvokeRFCFunctionPoGR(grMaterials, out msg);
|
// textBox4.Text = grMaterials[0].ToString();
|
// textBox5.Text = string.IsNullOrEmpty(msg) ? res : msg;
|
// break;
|
//case "button4":
|
// var giMaterials = new List<GIMaterial>
|
// {
|
// new GIMaterial
|
// {
|
// BWART = "261",
|
// MATNR = "JEGT5007859",
|
// WERKS = "3TG1",
|
// LGORT = "G003",
|
// SOBKZ = "e",
|
// LIFNR = "",
|
// KDAUF = "3005352431",
|
// KDPOS = 10,
|
// ERFMG = 1.0m,
|
// ERFME = "KG",
|
// CHARG = "",
|
// SERNR = "",
|
// AUFNR = "800021122917",
|
// KZEAR = "",
|
// RSNUM = 1179434436,
|
// RSPOS = 3,
|
// BWTAR = ""
|
// }
|
// };
|
// var gi = CacheEntity.SapncoClient.InvokeRFCFunctionWmsGI(giMaterials, out msg);
|
// textBox6.Text = giMaterials[0].ToString();
|
// textBox7.Text = string.IsNullOrEmpty(msg) ? gi : msg;
|
// break;
|
//case "button5":
|
// var movMaterials = new List<MovMaterial>
|
// {
|
// new MovMaterial
|
// {
|
// BWART = "261",
|
// MATNR = "JEGT5007859",
|
// WERKS = "3TG1",
|
// LGORT = "G003",
|
// SOBKZ = "e",
|
// LIFNR = "",
|
// KDAUF = "3005352431",
|
// KDPOS = 10,
|
// ERFMG = 1.0m,
|
// ERFME = "KG",
|
// CHARG = "",
|
// SERNR = "",
|
// UMLGO = "G021",
|
// BWTAR = ""
|
// }
|
// };
|
// var m = CacheEntity.SapncoClient.InvokeRFCFunctionWmsStkMov(movMaterials, out msg);
|
// textBox8.Text = movMaterials[0].ToString();
|
// textBox9.Text = string.IsNullOrEmpty(msg) ? m : msg;
|
// break;
|
