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;
        }
    
    }
}