Gsmarket/Sources/GS-MarketMG-2018/DataTransfersLibs/Service/DataUpdateService.cs

using System;
using System.Collections.Generic;
using System.IO;
using System.Text;
using System.Web.UI;
using DataTransfersLibs.Models;
using SysBaseLibs;
using SysDataLibs.TableClass;

namespace DataTransfersLibs.Service
{
	public class DataUpdateService : IErrorMsg
	{ 
		public DataUpdateService(string pcDataXml)
		{
			if (pcDataXml == "")
			{
				pcDataXml = lcTemp;
			}
			try
			{
				rsXmlNode loMainNode = rsXmlNode.ParseGenericXml(pcDataXml);
				ParseCheckData(loMainNode);
			}
			catch (Exception e)
			{
				ErrorMsg = e.Message;
			}
		}

		public DataUpdateService(Page poPage)
		{

			try
			{
				//    System.IO.Stream streamMessage = poPage.Request.InputStream;
				//    Encoding encode = Encoding.GetEncoding("GB2312");
				//    byte[] buff = new byte[4096];
				//    int nBytesRead = 0;
				//    int nBytes = streamMessage.Read(buff, nBytesRead, 4096);
				//    string strRequest = "";
				//    while (nBytes > 0)
				//    {
				//        nBytesRead += nBytes;
				//        strRequest += encode.GetString(buff, 0, nBytes);
				//        nBytes = streamMessage.Read(buff, 0, 4096);
				//    }
				string strRequest;
				Encoding encode = Encoding.GetEncoding("GB2312");
				using (var sr = new StreamReader(poPage.Request.InputStream, encode))
				{
					strRequest = sr.ReadToEnd();
				}
				if (strRequest.Trim().Length > 0)
				{
					try
					{
                        this.LogDebug(strRequest);
						//SysBaseLibs.AppEnv.Log(strRequest);
						rsXmlNode loMainNode = rsXmlNode.ParseGenericXml(strRequest);
						ParseCheckData(loMainNode);
					}
					catch (Exception e)
					{
						this.LogError(e);
						ErrorMsg = e.Message;
					}
				}
			}
			catch (Exception err)
			{ this.LogError(err); }
		}

		#region Properties

	    public int Total => _checkDatas.Count;
	    public int Successed { get; set; } = 0;
	    public int Failed { get; set; } = 0;
        public string ErrorMsg { get; set; } = "";

		string _userId = "";
		private TransDataService _transDataService;
		string _password = "";
		List<SingleCheckData> _checkDatas;
		private DBConnSql DBConn
		{
			get
			{
				DBConnSql loRetVal = new DBConnSql();
				if (loRetVal.Open())
				{

				}
				return loRetVal;
			}
		}

		#endregion

		/// <summary>
		/// 解析数据
		/// </summary>
		/// <param name="poMainNode"></param>
		/// <returns></returns>
		private void ParseCheckData(rsXmlNode poMainNode)
		{
			if (poMainNode != null && poMainNode.Nodes.Count > 0)
			{
				if (poMainNode.Nodes.Count > 0)
				{
					_userId = poMainNode.GetChildValue("UserId");
					_password = poMainNode.GetChildValue("password");
					rsXmlNode loRecords = poMainNode.GetChildNode("results");
					if (loRecords != null && loRecords.Nodes.Count > 0)
					{
                        _checkDatas = new List<SingleCheckData>();
						foreach (rsXmlNode loNode in loRecords.Nodes)
						{
							if (loNode != null && loNode.Nodes.Count > 0)
							{
								SingleCheckData loRecord = new SingleCheckData(loNode);
								_checkDatas.Add(loRecord);
							}
						}
					}
				}
			}
			else
			{
				this.LogError("没有有效数据");
				ErrorMsg = "没有有效数据！";
			}
		}

		/// <summary>
		/// 检查用户合法性
		/// </summary>
		/// <returns></returns>
		public bool CheckUserValid()
		{
			bool lbRetVal = false;
			if (_userId != "" && _password != "" && DBConn != null && DBConn.IsOpened)
			{
				string lcSql = "select * from " + Tn.Sys_Users + " where " + Sys_Users_info.cUserCode + "='" + _userId + "'";
				rsQuery loQuery = DBConn.OpenQuery(lcSql);
				if (loQuery != null && loQuery.IsOpened && loQuery.RecCount == 1)
				{
					loQuery.MoveFirst();
					_transDataService = new TransDataService(loQuery.CurrentRow, DBConn);
					if (_password == _transDataService.Password)
					{
						lbRetVal = true;
						this.LogInfo("检测数据上传用户验证通过:UserID" + _userId);
					}
					else
					{
						this.LogError("检测数据上传用户密码不正确:UserID" + _userId);
						ErrorMsg = "用户密码不正确";
					}
				}
				else
				{
					this.LogError("检测数据上传用户名不正确或该用户已经被锁定:UserID" + _userId);
					ErrorMsg = "用户名不正确或该用户已经被锁定";
				}
			}
			return lbRetVal;
		}

		/// <summary>
		/// 向数据库中插入数据
		/// </summary>
		/// <returns></returns>
		public bool UpdateAllRecords()
		{
			bool lbRetVal = false;

			List<CheckData_info> loCheckDataList = new List<CheckData_info>();
			if (_transDataService != null && _checkDatas.Count > 0)
			{
				ErrorMsg = "";
			    string errorMsg="";
				foreach (SingleCheckData loSingleRecord in _checkDatas)
				{
				    if (loSingleRecord.IsValid)
				    {
                        try
				        {
				            CheckData_info loCheckData = _transDataService.GetCheckDataInfo(loSingleRecord);
				            if (loCheckData != null)
				                loCheckDataList.Add(loCheckData);
				            if (!_transDataService.InsertCheckData(loSingleRecord))
				            {
				                ErrorMsg += (ErrorMsg == "" ? "" : ",") + loSingleRecord.SampleNo;
				                errorMsg += (errorMsg == "" ? "" : ",") + loSingleRecord.SampleNo + "@" +
				                            loSingleRecord.SampleName;
				                Failed++;
				            }
				            else
				            {
				                Successed++;
				                lbRetVal = true;
                            }
                        }
				        catch (Exception e)
				        {
				            Failed++;
				            this.LogError(e);
                        }
                    }
				    else
				    {
				        Failed++;
				        errorMsg += (errorMsg == "" ? "" : ",") + loSingleRecord.SampleNo + "@" +
                                    loSingleRecord.SampleName + "@非法数据";
				    }

                }
                if (ErrorMsg != "")
				{
					lbRetVal = false;
					this.LogInfo(errorMsg);
                }
				
                //ytCheckDataUpload loytCheckDataUpload = new ytCheckDataUpload();
                //loytCheckDataUpload.ExcuteBatchUploadYTThread(loCheckDataList);
			    loCheckDataList.DataPush();

			}
			return lbRetVal;
		}

		string lcTemp = @"<Updatas>
                                  <UserId>shichang12</UserId>
                                  <password>123456</password >
                                  <results>
                                 <record>
                                     <sub_category>100011</sub_category>
                                     <sample>佛手瓜</sample>
                                     <check_method>检测仪</check_method>
                                     <result>合格</result>
                                     <check_org>复淳科技</check_org>
                                     <region>复淳科技</region>
                                      <check_district>北京</check_district>
                                     <produce_org> </produce_org>
                                      <checked_org>东方农场</checked_org>
                                     <checked_org_type></checked_org_type>
                                     <rate>0</rate>
                                     <check_time>2006-11-28</check_time>
                                      <operator>111_111</operator>
                                     <hardware_no>10001</hardware_no>
                                     <sample_no>118</sample_no>
                                     <Check_item>农药残留</Check_item>
                                 </record>
                                 <record>
                                     <sub_category>400006</sub_category>
                                     <sample>豌豆</sample>
                                     <check_method>检测仪</check_method>
                                     <result>合格</result>
                                     <check_org>复淳科技</check_org>
                                     <region>复淳科技</region>
                                      <check_district>北京</check_district>
                                     <produce_org> </produce_org>
                                      <checked_org>东方农场</checked_org>
                                     <checked_org_type></checked_org_type>
                                     <rate>0</rate>
                                     <check_time>2006-11-28</check_time>
                                      <operator>111_111</operator>
                                     <hardware_no>10001</hardware_no>
                                     <sample_no>119</sample_no>
                                     <Check_item>农药残留</Check_item>
                                 </record>
                                 <record>
                                     <sub_category>400001</sub_category>
                                     <sample>毛豆</sample>
                                     <check_method>检测仪</check_method>
                                     <result>合格</result>
                                     <check_org>复淳科技</check_org>
                                     <region>复淳科技</region>
                                      <check_district>北京</check_district>
                                     <produce_org> </produce_org>
                                      <checked_org>东方农场</checked_org>
                                     <checked_org_type></checked_org_type>
                                     <rate>0</rate>
                                     <check_time>2006-11-28</check_time>
                                      <operator>111_111</operator>
                                     <hardware_no>10001</hardware_no>
                                     <sample_no>120</sample_no>
                                     <Check_item>农药残留</Check_item>
                                 </record>
                                 <record>
                                     <sub_category>500005</sub_category>
                                     <sample>花椰菜</sample>
                                     <check_method>检测仪</check_method>
                                     <result>合格</result>
                                     <check_org>复淳科技</check_org>
                                     <region>复淳科技</region>
                                      <check_district>北京</check_district>
                                     <produce_org> </produce_org>
                                      <checked_org>东方农场</checked_org>
                                     <checked_org_type></checked_org_type>
                                     <rate>0</rate>
                                     <check_time>2006-11-28</check_time>
                                      <operator>111_111</operator>
                                     <hardware_no>10001</hardware_no>
                                     <sample_no>122</sample_no>
                                     <Check_item>农药残留</Check_item>
                                 </record>
                                 <record>
                                     <sub_category>500004</sub_category>
                                     <sample>生菜</sample>
                                     <check_method>检测仪</check_method>
                                     <result>合格</result>
                                     <check_org>复淳科技</check_org>
                                     <region>复淳科技</region>
                                      <check_district>北京</check_district>
                                     <produce_org> </produce_org>
                                      <checked_org>东方农场</checked_org>
                                     <checked_org_type></checked_org_type>
                                     <rate>0</rate>
                                     <check_time>2006-11-28</check_time>
                                      <operator>111_111</operator>
                                     <hardware_no>10001</hardware_no>
                                     <sample_no>123</sample_no>
                                     <Check_item>农药残留</Check_item>
                                 </record>
                                 <record>
                                     <sub_category>500006</sub_category>
                                     <sample>甘蓝</sample>
                                     <check_method>检测仪</check_method>
                                     <result>合格</result>
                                     <check_org>复淳科技</check_org>
                                     <region>复淳科技</region>
                                      <check_district>上海</check_district>
                                     <produce_org> </produce_org>
                                      <checked_org>东方农场</checked_org>
                                     <checked_org_type></checked_org_type>
                                     <rate>0</rate>
                                     <check_time>2007-05-12</check_time>
                                      <operator>111_111</operator>
                                     <hardware_no>10001</hardware_no>
                                     <sample_no>127</sample_no>
                                     <Check_item>农药残留</Check_item>
                                 </record>
                                 <record>
                                     <sub_category>500006</sub_category>
                                     <sample>甘蓝</sample>
                                     <check_method>检测仪</check_method>
                                     <result>合格</result>
                                     <check_org>复淳科技</check_org>
                                     <region>复淳科技</region>
                                      <check_district>上海</check_district>
                                     <produce_org> </produce_org>
                                      <checked_org>东方农场</checked_org>
                                     <checked_org_type></checked_org_type>
                                     <rate>0</rate>
                                     <check_time>2007-05-12</check_time>
                                      <operator>111_111</operator>
                                     <hardware_no>10001</hardware_no>
                                     <sample_no>128</sample_no>
                                     <Check_item>农药残留</Check_item>
                                 </record>
                                 <record>
                                     <sub_category>500006</sub_category>
                                     <sample>甘蓝</sample>
                                     <check_method>检测仪</check_method>
                                     <result>合格</result>
                                     <check_org>复淳科技</check_org>
                                     <region>复淳科技</region>
                                      <check_district>上海</check_district>
                                     <produce_org> </produce_org>
                                      <checked_org>东方农场</checked_org>
                                     <checked_org_type></checked_org_type>
                                     <rate>0</rate>
                                     <check_time>2007-05-12</check_time>
                                      <operator>111_111</operator>
                                     <hardware_no>10001</hardware_no>
                                     <sample_no>129</sample_no>
                                     <Check_item>农药残留</Check_item>
                                 </record>
                                 <record>
                                     <sub_category>500006</sub_category>
                                     <sample>甘蓝</sample>
                                     <check_method>检测仪</check_method>
                                     <result>合格</result>
                                     <check_org>复淳科技</check_org>
                                     <region>复淳科技</region>
                                      <check_district>上海</check_district>
                                     <produce_org> </produce_org>
                                      <checked_org>东方农场</checked_org>
                                     <checked_org_type></checked_org_type>
                                     <rate>0</rate>
                                     <check_time>2007-05-12</check_time>
                                      <operator>111_111</operator>
                                     <hardware_no>10001</hardware_no>
                                     <sample_no>130</sample_no>
                                     <Check_item>农药残留</Check_item>
                                 </record>
                                  </results>
                                </Updatas>

                            ";

		string TestData = @" <Updatas>
                                    <UserId>shichang1</UserId>
                                    <password>123456</password>
                                    <results>
                                        <record> 
	                                        <sample_no>0001</sample_no>
                                            <check_method>速测法</check_method>
                                            <sub_category>绿叶菜类</sub_category>
                                            <sample>青菜</sample>
                                            <check_item>残留农药</check_item>
                                            <result>1</result>
                                            <check_org>邻里中心新城大厦</check_org>
                                            <region>上海市</region>
                                            <check_district>上海市</check_district>
                                            <produce_org>农夫果园</produce_org>
                                            <checked_org>第一食品公司</checked_org>
                                            <checked_org_type>公司</checked_org_type>
                                            <rate>88.88</rate>
                                            <check_time>2007-5-12</check_time>
                                            <operator>张三</operator>
                                            <hardware_no>HW12345678</hardware_no>
                                        </record>
                                        <record> 
	                                        <sample_no>0002</sample_no>
                                            <check_method>速测仪</check_method>
                                            <sub_category>绿叶菜类</sub_category>
                                            <sample>青菜</sample>
                                            <check_item>残留农药</check_item>
                                            <result>1</result>
                                            <check_org>邻里中心新城大厦</check_org>
                                            <region>上海市</region>
                                            <check_district>上海市</check_district>
                                            <produce_org>农夫果园</produce_org>
                                            <checked_org>第一食品公司</checked_org>
                                            <checked_org_type>公司</checked_org_type>
                                            <rate>88.88</rate>
                                            <check_time>2007-5-12</check_time>
                                            <operator>张三</operator>
                                            <hardware_no>HW12345678</hardware_no>
                                        </record>
                                    </results>
                               </Updatas>";
	}


}