using Newtonsoft.Json;
|
using Newtonsoft.Json.Linq;
|
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 SQLHelper _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 SQLHelper(conn);
|
//_sqlHelper =
|
//new SQLHelper(
|
// Encoding.Default.GetString(
|
// Convert.FromBase64String(ConfigurationManager.ConnectionStrings["conn"].ConnectionString)));
|
tbQueue = new DataTable();
|
string SqlStr = string.Format(@"Select top 0 * from SYSDEC (nolock) 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 = "";
|
string flag = "0";
|
//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_MESTOERP")&& (!docType.Contains("XKY"))))
|
{
|
if (operatype!="DELETE")
|
{
|
JsonSerializerSettings settings = new JsonSerializerSettings();
|
settings.Converters.Add(new ReadAheadDataSetConverter());
|
dsTemp = JsonConvert.DeserializeObject<DataSet>(data_inserted, settings);
|
// 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;
|
}
|
}
|
else
|
{
|
operatype = data;
|
}
|
}
|
//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,ref flag, taskId) == true)
|
{
|
if (flag=="0")
|
{
|
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["msg"] = msg;
|
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
|
|
|
|
public class ReadAheadDataSetConverter : JsonConverter
|
{
|
public override bool CanConvert(Type objectType)
|
{
|
return objectType == typeof(DataSet);
|
}
|
|
public override object ReadJson(JsonReader reader, Type objectType, object existingValue, JsonSerializer serializer)
|
{
|
JObject jObject = JObject.Load(reader);
|
return BuildDataSet(jObject);
|
}
|
private DataSet BuildDataSet(JObject jObject)
|
{
|
DataSet dsResult = new DataSet();
|
foreach (JProperty propds in jObject.Properties())
|
{
|
DataTable table = new DataTable(propds.Name);
|
var dataTypes = new Dictionary<string, Type>();
|
foreach (JObject item in propds.Value.Children<JObject>())
|
{
|
foreach (JProperty prop in item.Properties())
|
{
|
Type currentType = GetDataType(prop.Value.Type);
|
if (currentType != null)
|
{
|
Type previousType;
|
if (!dataTypes.TryGetValue(prop.Name, out previousType) ||
|
(previousType == typeof(long) && currentType == typeof(decimal)))
|
{
|
dataTypes[prop.Name] = currentType;
|
}
|
else if (previousType == typeof(decimal) && currentType == typeof(long))
|
{
|
dataTypes[prop.Name] = previousType;
|
}
|
else if (previousType != currentType)
|
{
|
dataTypes[prop.Name] = typeof(string);
|
}
|
}
|
}
|
}
|
foreach (var kvp in dataTypes)
|
{
|
table.Columns.Add(kvp.Key, kvp.Value);
|
}
|
foreach (JObject itemdr in propds.Value.Children<JObject>())
|
{
|
DataRow row = table.NewRow();
|
foreach (JProperty prop in itemdr.Properties())
|
{
|
if (prop.Value.Type != JTokenType.Null)
|
{
|
Type dataType = dataTypes[prop.Name];
|
row[prop.Name] = prop.Value.ToObject(dataType);
|
}
|
}
|
table.Rows.Add(row);
|
}
|
dsResult.Tables.Add(table);
|
}
|
|
return dsResult;
|
}
|
|
private Type GetDataType(JTokenType tokenType)
|
{
|
switch (tokenType)
|
{
|
case JTokenType.Null:
|
return null;
|
case JTokenType.String:
|
return typeof(string);
|
case JTokenType.Integer:
|
return typeof(long);
|
case JTokenType.Float:
|
return typeof(decimal);
|
case JTokenType.Boolean:
|
return typeof(bool);
|
case JTokenType.Date:
|
return typeof(DateTime);
|
case JTokenType.TimeSpan:
|
return typeof(TimeSpan);
|
case JTokenType.Guid:
|
return typeof(Guid);
|
case JTokenType.Bytes:
|
return typeof(byte[]);
|
case JTokenType.Array:
|
case JTokenType.Object:
|
throw new JsonException("This converter does not support complex types");
|
default:
|
return typeof(string);
|
}
|
}
|
|
public override bool CanWrite
|
{
|
get { return false; }
|
}
|
|
public override void WriteJson(JsonWriter writer, object value, JsonSerializer serializer)
|
{
|
throw new NotImplementedException();
|
}
|
}
|
|
}
|
}
|
