using Common;
|
using Newtonsoft.Json;
|
using Newtonsoft.Json.Linq;
|
using System;
|
using System.Collections.Generic;
|
using System.Data;
|
using System.Data.OracleClient;
|
using System.Data.SqlClient;
|
using System.Linq;
|
using System.Web;
|
using System.Web.Services;
|
using System.Xml.Linq;
|
|
namespace WebserviceGS
|
{
|
/// <summary>
|
/// WebService1 的摘要说明
|
/// </summary>
|
[WebService(Namespace = "http://tempuri.org/")]
|
[WebServiceBinding(ConformsTo = WsiProfiles.BasicProfile1_1)]
|
[System.ComponentModel.ToolboxItem(false)]
|
// 若要允许使用 ASP.NET AJAX 从脚本中调用此 Web 服务，请取消注释以下行。
|
// [System.Web.Script.Services.ScriptService]
|
public class WebService1 : System.Web.Services.WebService
|
{
|
|
|
[WebMethod]
|
public string ERP_TO_MES_DataTransport(string task_name,string create_time, string creator, string operatype,
|
string version, string imagenumber, string imagenumnew, string baseimage)
|
{
|
SQLHelperClass SQLHelper = new SQLHelperClass();
|
|
SQLHelper.connectionString = "Data Source=192.168.1.198;Initial Catalog=CSFrameworkV5_Normal;User Id=sa;Password=Weaver@2001;Pooling=False;Pooling=true;Min Pool Size=10;Max Pool Size=50;Connect Timeout=500";
|
string res = "";
|
string sql = "";
|
if (task_name == null || create_time == null || creator == null || operatype == null || version == null || imagenumber == null )
|
{
|
res = "ERROR:输入参数不能为空";
|
|
return res;
|
}
|
if (operatype!="INSERT"&& operatype != "UPDATE" && operatype != "DELETE")
|
{
|
res = "ERROR:操作类型operatype错误";
|
|
return res;
|
}
|
//对JSON格式判断正确性 都以DataSet作序列化来传值
|
//DataSet ds=new DataSet();
|
//JsonConvert.SerializeObject(ds, new DataSetConverter());
|
//DataSet api_DatSet = JsonConvert.DeserializeObject(data, typeof(DataSet)) as DataSet;
|
//if (api_DatSet == null || api_DatSet.Tables.Count == 0)
|
//{
|
// res = "ERROR:数据无效，或者JSON格式有误，请查证！";
|
// return res;
|
//}
|
|
//将数据存入数据中间表中
|
|
try
|
{
|
// sql = string.Format(@"
|
//insert into sysdec(task_id,task_name,descript,create_time,creator,operatype,source_table,target_table,data,data_inserted,data_deleted,states)
|
// values(newid(),'{0}','{1}','{2}','{3}','{4}','{5}','{6}','{7}','{8}','{9}','NEW')",
|
// task_name, descript, create_time, creator, operatype, source_table, target_table, data, data_inserted, data_deleted);
|
// int i = SQLHelper.ExecuteNonQuery(sql);
|
// res = i > 0 ? "OK" : "ERROR";
|
string currentTime = DateTime.Now.ToString();
|
List<SqlParameter> list = new List<SqlParameter>();
|
list.Add(new SqlParameter("@task_name", task_name));
|
list.Add(new SqlParameter("@create_time", create_time));
|
list.Add(new SqlParameter("@down_time", currentTime));
|
list.Add(new SqlParameter("@creator", creator));
|
list.Add(new SqlParameter("@operatype", operatype));
|
list.Add(new SqlParameter("@version", version));
|
|
list.Add(new SqlParameter("@imagenumnew", imagenumnew));
|
list.Add(new SqlParameter("@imagenumber", imagenumber));
|
list.Add(new SqlParameter("@baseimage", baseimage));
|
|
|
sql = string.Format(@"
|
insert into sysdectu(task_id,task_name,create_time,down_time,creator,operatype,version,imagenumber,imagenumnew,baseimage,states)
|
values(newid(),@task_name,@create_time,@down_time,@creator,@operatype,@version,@imagenumber,@imagenumnew,@baseimage,'NEW')");
|
int i = SQLHelper.ExecuteNonQuery(sql, CommandType.Text, list.ToArray());
|
res = i > 0 ? "OK" : "ERROR";
|
}
|
catch (Exception ex)
|
{
|
res = "ERROR:" + ex.Message;
|
}
|
return res;
|
}
|
|
}
|
}
|
