using DataexchangeServer.Helper;
|
using Newtonsoft.Json;
|
using System;
|
using System.Collections.Generic;
|
using System.Configuration;
|
using System.Data;
|
using System.IO;
|
using System.Linq;
|
using System.Text;
|
using System.Threading;
|
using System.Windows.Forms;
|
|
namespace DataexchangeServer
|
{
|
public delegate void WriteLogHandle(string msg);
|
|
#region 类的状态 enum State
|
/// <summary>
|
/// 类的状态
|
/// </summary>
|
public enum State
|
{
|
Alive, //激活
|
Finish,//完成
|
Sleep //睡眠
|
}
|
#endregion
|
|
public class Allocation
|
{
|
public State state { get; set; }
|
public string Name { get; set; }
|
public string ID { get; set; }
|
public string task_id { get; set; }
|
public DataTable tbQueue;
|
private OracleDb _sqlHelper;
|
private DataSet dsTemp = new DataSet();
|
|
public DateTime strStartTime { get; set; }
|
|
/// <summary>
|
/// 当消息有变化的时候将消息通过事件传输
|
/// </summary>
|
private string ConsoleMessage { get; set; }
|
public event WriteLogHandle WriteLog;
|
public event WriteLogHandle WriteErrorLog;
|
|
#region 线程类Allocation()
|
/// <summary>
|
/// 线程类
|
/// </summary>
|
public Allocation()
|
{
|
string conn = ConfigurationManager.ConnectionStrings["conn"].ConnectionString;
|
conn = SecurityHelper.Decrypt(conn);
|
_sqlHelper = new OracleDb(conn);
|
//_sqlHelper =
|
//new SQLHelper(
|
// Encoding.Default.GetString(
|
// Convert.FromBase64String(ConfigurationManager.ConnectionStrings["conn"].ConnectionString)));
|
tbQueue = new DataTable();
|
string SqlStr = string.Format(@"Select * from SYSDEC where 1<>1");
|
tbQueue = _sqlHelper.ExecuteDataTable(SqlStr);
|
tbQueue.TableName = "SYSDEC";
|
tbQueue.PrimaryKey = new[] { tbQueue.Columns["task_id"] };
|
state = State.Sleep;
|
}
|
#endregion
|
|
#region 执行调用void Execute(object obj)
|
/// <summary>
|
/// 执行调用
|
/// </summary>
|
public void Execute(object obj)
|
{
|
string data = "";
|
string taskId = "";
|
string docType = "";
|
//string inputXml = "";
|
string operatype = "";
|
string msg = "";
|
string data_inserted = "";
|
object data_insertedT = "";
|
//lock (ID) ;
|
try
|
{
|
state = State.Alive;
|
DataRow[] rowArray = tbQueue.Select("", "create_time");
|
if (rowArray.Length == 0) return;
|
AE_MES_ERP Client = new AE_MES_ERP();
|
foreach (DataRow row in rowArray)
|
{
|
if (object.Equals(null, row["data_inserted"]))
|
{
|
row["msg"] = "插入的数据为空，请检查程序！";
|
row["states"] = "FAIL";
|
row["retry_times"] = Convert.ToInt16(row["retry_times"].ToString() == "" ? "0" : row["retry_times"].ToString()) + 15;
|
row["execute_time"] = System.DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
|
continue;
|
}
|
|
taskId = row["task_id"].ToString();
|
data = row["data"].ToString();
|
docType = row["task_name"].ToString();
|
data_inserted = row["data_inserted"].ToString();
|
operatype = row["operatype"].ToString();
|
|
ConsoleMessage = string.Format("线程:{0},{1}执行内容：{2} 推送Data:{3} 执行时间：{4}",
|
Name,
|
row["creator"].ToString(),
|
row["descript"].ToString(),
|
row["data"].ToString(),
|
System.DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
|
if (WriteLog != null) { WriteLog(ConsoleMessage); }
|
|
//DataTable tbTemp = JSONHelper.JsonToDataTable(data_inserted);
|
if (docType.Contains("TB_ERPTOMES"))
|
{
|
dsTemp = JsonConvert.DeserializeObject(data_inserted, typeof(DataSet)) as DataSet;
|
if (dsTemp == null || dsTemp.Tables.Count == 0)
|
{
|
row["msg"] = "接口存在无效字符";
|
row["states"] = "FAIL";
|
row["retry_times"] = Convert.ToInt16(row["retry_times"].ToString() == "" ? "0" : row["retry_times"].ToString()) + 15;
|
row["execute_time"] = System.DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
|
continue;
|
}
|
}
|
//dsTemp.Tables.Clear();
|
//dsTemp.Tables.Add(tbTemp);
|
//inputXml = dsTemp.GetXml();
|
msg = "";
|
//Thread.Sleep(3000);
|
//DataexchangeServer.IMS.WebServiceClient Client = new DataexchangeServer.IMS.WebServiceClient();
|
if (Client.ErpToMesData(docType, dsTemp, operatype, row, ref msg) == true)
|
{
|
if (msg.Length > 1)
|
{
|
row["msg"] = msg;
|
row["states"] = "FAIL";
|
row["retry_times"] = Convert.ToInt16(row["retry_times"].ToString() == "" ? "0" : row["retry_times"].ToString()) + 1;
|
row["execute_time"] = System.DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
|
if (WriteErrorLog != null)
|
{
|
WriteErrorLog(msg);
|
}
|
}
|
else
|
{
|
//row["remark"] = "OK";
|
row["states"] = "SUCCESS";
|
row["execute_time"] = System.DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
|
}
|
}
|
else
|
{
|
row["msg"] = msg;
|
row["states"] = "FAIL";
|
row["retry_times"] = Convert.ToInt16(row["retry_times"].ToString() == "" ? "0" : row["retry_times"].ToString()) + 1;
|
row["execute_time"] = System.DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
|
if (WriteErrorLog != null)
|
{
|
WriteErrorLog(msg);
|
}
|
}
|
|
}
|
_sqlHelper.SaveDataToDB(tbQueue);
|
tbQueue.AcceptChanges();
|
}
|
catch (Exception ex)
|
{
|
//state = State.Finish;
|
//throw (ex);
|
//MessageBox.Show("当前错误信息如下:" + ex);
|
ConsoleMessage = string.Format(@"task_id:{0},{1}异常信息：" + ex.Message, taskId, DateTime.Now.ToString("yyyy-MM-dd HH:mm:sss"));
|
bool result = JSONHelper.WriteToFile(ConsoleMessage);
|
|
ConsoleMessage = string.Format(@"Save {0},ID:{1} 出现异常信息，请在运行目录下查看。\log\", result, data);
|
if (WriteErrorLog != null)
|
{
|
WriteErrorLog(ConsoleMessage);
|
}
|
}
|
finally
|
{
|
state = State.Finish;
|
}
|
if (tbQueue.Rows.Count > 0)
|
{
|
ConsoleMessage = string.Format("线程:{0}任务结束。时间：{1}", Name, System.DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss "));
|
if (WriteLog != null) { WriteLog(ConsoleMessage); }
|
//state = State.Finish;
|
}
|
}
|
#endregion
|
|
}
|
}
|
