BaLinYouQiDataUpload/TimedUpload/QuartzJobs/ValveControlJob.cs

using log4net;
using Newtonsoft.Json.Linq;
using Quartz;
using RDIFramework.Utilities;
using System;
using System.Collections.Generic;
using System.Data;
using System.IO;
using System.Linq;
using System.Net;
using System.Text;
using TimedUpload.WebReference;

namespace TimedUpload.QuartzJobs
{
   [DisallowConcurrentExecution]
   public class ValveControlJob : IJob
    {
        private readonly ILog log = LogManager.GetLogger(typeof(ValveControlJob));

        public void Execute(IJobExecutionContext context)
        {
            try
            {
                log.Info("控阀接口开始执行.................\r\n");
                //2021-12-24 开关控阀
                UpdateValveControl();
            }
            catch (Exception ex)
            {
                log.Error("任务上传异常:" + ex.Message);
            }

            log.InfoFormat("控阀接口执行结束.................\r\n");
        }


        #region 开关控阀
        private void UpdateValveControl()
        {
            String result;
            //远传表厂家编号
            String metersortId = "13";
            //远传水表阀控接口url
             String serviceAddress = "http://47.105.45.253:1943/WebServices/ExternalValueControlApi.ashx";
         //   String serviceAddress = "http://localhost:2801/WebServices/ExternalValueControlApi.ashx";
            String Code = null;
            String Message = null;
            try
            {
                WebReference.MeterReadingImplService wm = new WebReference.MeterReadingImplService();

                valveControlList[] vcList = wm.ValveControl(metersortId);
                StringBuilder valveControlInfo = new StringBuilder();

                
                //测试
                /*result = postSend(serviceAddress, "");
                log.Debug("上传结果---------》"  + "," + result);*/

                log.Debug("~~~~~~~~~~~开始下达开阀指令~~~~~~~~~~~~~");
                if (vcList != null)
                {
                    foreach (var vc in vcList)
                    { 
                        valveControlInfo.Clear();

                        valveControlInfo.Append("ManufacturerCode=6e50093a-2b74-4e3e-9993-c3bd1f23979a&");
                        valveControlInfo.Append("MeterAddress=" + vc.meteraddress + "&");
                        valveControlInfo.Append("CommandType=Valve&");
                        //WebHeaderCollection headers = new WebHeaderCollection();
                        //headers.Add("ManufacturerCode", "6e50093a-2b74-4e3e-9993-c3bd1f23979a");
                        //headers.Add("MeterAddress", vc.meteraddress);
                        //headers.Add("CommandType","Valve");

                        //获取开阀或关阀指令
                        if (vc.valveState == "0")
                        {
                            log.Debug("控阀指令---------》" + vc.meteraddress + "," + "开阀");
                            valveControlInfo.Append("ValueState=open");
                        }
                        else
                        {
                            log.Debug("控阀指令---------》" + vc.meteraddress + "," + "关阀");

                            valveControlInfo.Append("ValueState=close");
                        }
                        result = WebHelper.HttpWebRequest(serviceAddress, valveControlInfo.ToString());
                        log.Debug("上传结果---------》" + vc.meteraddress + "," + result);
                        //插入指令临时表
                        //String sql = " select * from TempValveControlData where id="+vc.id +" and ";
                        //DataTable dt = dbHelperNB.Fill(sql);
                        //if (dt !=null && dt.Rows.Count>0)
                        //{
                        //    continue;
                        //}
                       String sql = "insert into TempValveControlData(id,meteraddress,valveState,updateTime,Message)   values(" + vc.id + ",'" + vc.meteraddress + "','" + vc.valveState + "','" + vc.controlTime + "','"+result+"')";

                       dbHelperNB.ExecuteNonQuery(sql);

                      

                        //if (!String.IsNullOrEmpty(result))
                        //{
                        //    var dicRes = JObject.Parse(result); 
                        //    if (dicRes != null)
                        //    {
                        //        if (dicRes["Code"].ToString() == "SUCCESS")
                        //        {
                        //            Code = "success";
                        //            Message = dicRes["Message"].ToString();
                        //            log.Debug(vc.meteraddress + "开阀成功");
                        //        }
                        //        else
                        //        {
                        //            Code = "Error";
                        //            Message = dicRes["Message"].ToString();
                        //            log.Debug(vc.meteraddress + "开阀失败");
                        //        }
                        //        sql = " update TempValveControlData set Code='"+Code+"',[Message]='"+Message+"'  where id="+vc.id;
                        //        dbHelperNB.ExecuteNonQuery(sql);
                        //    }
                        //}
                      
                        
                        valveControlInfo.Clear();
                    }
                }
            }
            catch (Exception ex)
            {
                log.Debug("上传数据失败:" + ex.ToString());
            }
        }
        #endregion


        #region 请求接口
        /// <summary>
        /// 
        /// </summary>
        /// <param name="url"></param>
        /// <param name="param"></param>
        /// <param name="type"></param>
        /// <param name="webHeader">请求头携带请求权限</param>
        /// <returns></returns>
        public string postSend(string url, WebHeaderCollection webHeader, String param,String type = "POST")
        {
            string strResult = "";
            Encoding myEncode = Encoding.GetEncoding("UTF-8");
            HttpWebRequest req = (HttpWebRequest)HttpWebRequest.Create(url);
            
            req.Method = type;
            req.ContentType = "application/x-www-form-urlencoded";
            req.Headers=webHeader;
            //req.ContentLength = 100;


            if (param != null)
            {
                byte[] postBytes = Encoding.UTF8.GetBytes(param);
                req.ContentLength = postBytes.Length;
                using (Stream reqStream = req.GetRequestStream())
                {
                    reqStream.Write(postBytes, 0, postBytes.Length);
                }
            }


            try
            {

                using (WebResponse res = req.GetResponse())
                {
                    using (StreamReader sr = new StreamReader(res.GetResponseStream(), myEncode))
                    {
                        strResult = sr.ReadToEnd();
                        return strResult;
                    }
                }
            }
            catch (WebException ex)
            {
                log.Error("Post数据出错:" + ex.Message);
                return "";
            }
        }
        #endregion

        static IDbProvider dbHelperNB
        {
            get
            {
                var DbDefine = DbFactoryProvider.GetProvider(CurrentDbType.SqlServer, Constants.DBUrlNbYd);
                return DbDefine;
            }
        }
    }

    public class  TempValveControlData
    {
        /// <summary>
        /// Id
        /// </summary>
        public Guid dataId { get; set; } = Guid.NewGuid();
        /// <summary>
        /// 指令编号
        /// </summary>
        public int id { get; set; }
        /// <summary>
        /// 表地址
        /// </summary>
        public String meteraddress { get; set; }
        /// <summary>
        /// 指令状态 0:开阀 其他 ：关阀
        /// </summary>
        public String valveState { get; set; }
        /// <summary>
        /// 接口返回的结果
        /// </summary>
        public String Code { get; set; }
        /// <summary>
        /// 失败时返回具体错误原因
        /// </summary>
        public String Message { get; set; }
        /// <summary>
        /// 更新时间
        /// </summary>
        public DateTime updateTime { get; set; } = DateTime.Now;
        /// <summary>
        /// 逻辑删除
        /// </summary>
        public String isRemove { get; set; } = "false";

    }


    
}