SongZiDataUpload/TimedUpload/QuartzJobs/DataUploadJob.cs

//using log4net;
//using Newtonsoft.Json;
//using Quartz;
//using RDIFramework.Utilities;
//using System;
//using System.Collections.Generic;
//using System.Configuration;
//using System.Data;
//using System.Globalization;
//using System.IO;
//using System.Linq;
//using System.Net;
//using System.Text;
//using System.Web.Script.Serialization;

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

//        public void Execute(IJobExecutionContext context)
//        {
//            log.Info("抄表数据上传任务开始执行.................\r\n");
//            #region 变量
//            //公司ID 
//            String str_CompanyID = "";
//            String str_Url = "";
//            DataTable dt_MeterInfo = new DataTable();
//            String str_Sql = "";
//            //表地址
//            String str_ElecAddress = "";
//            //水表读数
//            String str_Reading = "";
//            //抄表时间
//            String str_ReadiTime = "";
//            //阀门状态
//            String str_ValveStatus = "";
//            //电源电压
//            String str_PowerVoltage = "";
//            //信号
//            String str_Rsrp = "";
//            List<datalist> l_Data = new List<datalist>();
//            datalist dataList = new datalist();
//            data data = new data();
//            #endregion

//            #region 逻辑
//            try
//            {
//                str_CompanyID = Constants.ComPanyId;
//                str_Url =  Constants.uploadUrl;
//                //GetSecretKey(str_Url, Constants.passWord);
//                //查询水表数据
//                str_Sql = "select ElecAddress as meterAdd,ISNULL(NowReading,0) as collValue,NowRadingDT as collTime,isNULL(Rsrp,'') as Rsrp ,isNULL(ValveStatus,'') as ValveStatus,isNULL(BatteryVoltage,0) as BatteryVoltage from RMRS_MeterInfo where CompanyID ='" + str_CompanyID + "' and DeleteMark =0";

//                dt_MeterInfo = dbHelper.Fill(str_Sql);

//                if (dt_MeterInfo.Rows.Count > 0)
//                {
//                    for (int i = 0; i < dt_MeterInfo.Rows.Count; i++)
//                    {
//                        dataList = new datalist();
//                        str_ElecAddress = dt_MeterInfo.Rows[i]["meterAdd"].ToString();
//                        str_Reading = dt_MeterInfo.Rows[i]["collValue"].ToString();
//                        str_ReadiTime = dt_MeterInfo.Rows[i]["collTime"].ToString();
//                        str_ValveStatus = dt_MeterInfo.Rows[i]["ValveStatus"].ToString();
//                        str_PowerVoltage = dt_MeterInfo.Rows[i]["BatteryVoltage"].ToString();
//                        str_Rsrp = dt_MeterInfo.Rows[i]["Rsrp"].ToString();
//                        //数据处理
//                        dataList.meterAdd = str_ElecAddress.PadLeft(14, '0');
//                        dataList.collValue = str_Reading;
//                        dataList.collTime = Convert.ToDateTime(str_ReadiTime).ToString("yyyyMMddHHmmss");
//                        dataList.conCode = Constants.conCode;//"8888888888";
//                        l_Data.Add(dataList);
//                    }

//                    data.factCode = "WW";
//                    //获取秘钥

//                    data.secretKey = GetSecretKey(str_Url, Constants.passWord);

//                    data.dataList = l_Data;

//                    String str_Param = JsonHelper.ObjectToJSON(data);

//                    String str_Result = WebHelper.HttpWebRequest(str_Url + "/integration/waterMeter/waterMeterReadming", str_Param, "POST", "application/json");

//                    if (str_Result.Contains("success"))
//                    {
//                        log.Info("上传成功" + str_Param);
//                    }
//                }

//                //整理数据格式


//                //调接口上传数据
//            }
//            catch (Exception ex)
//            {
//                log.Error("抄表数据上传任务异常:" + ex.Message);
//            } 
//            #endregion

//            log.InfoFormat("抄表数据上传任务执行结束.................\r\n");
//        }



//        /// <summary>
//        /// 更新配置文件中的更新数据时间
//        /// </summary>
//        /// <param name="time"></param>
//        private void UpdateUploadTime(string time)
//        {
//            var cfg = ConfigurationManager.OpenExeConfiguration(ConfigurationUserLevel.None);
//            cfg.AppSettings.Settings["uploadTime"].Value = time;
//            cfg.Save();
//            ConfigurationManager.RefreshSection("appSettings");

//        }
//        public String GetSecretKey(String str_Url,String str_PassWord)
//        {
//            String str_SecretKey = "";
//            String str = "";
//            result result = new result();

//            str  = WebHelper.HttpWebRequest(str_Url + "/integration/auth/secretKey", "{\"password\":\"" + str_PassWord + "\"}", "POST", "application/json");

//             result = JsonConvert.DeserializeObject<result>(str);

//             if (result.message == "成功")
//             {
//                 str_SecretKey = result.secretKey;
//             }

//             return str_SecretKey;
//        }


//        static IDbProvider dbHelper
//        {
//            get
//            {
//                var DbDefine = DbFactoryProvider.GetProvider(CurrentDbType.SqlServer, Constants.DBUrl);
//                return DbDefine;
//            }
//        }
//    }
//    public class result
//    {
//        public String secretKey { get; set; }
//        public String message { get; set; }

//        public String status { get; set; }
//    }


//    public class data
//    {
//        public String secretKey { get; set; }
//        public String factCode { get; set; }

//        public List<datalist> dataList { get; set; }
//    }
//    public class datalist
//    {
//        //集中器编号
//        public String conCode { get; set; }

//        //表身唯一编号
//        public String meterAdd { get; set; }

//        //水表读数
//        public String collValue { get; set; }

//        //抄表时间20181122100000000(毫秒)
//        public String collTime { get; set; }

//        ////阀控状态 OPEN:开 CLOSE:关
//        //public String valveStatus { get; set; }

//        ////电源电压 单位：V
//        //public String powerVoltage { get; set; }

//        ////信号强度(0:信号强 1:信号良,2:信号一般,3:信号弱,4:信号差,5:无信号)
//        //public String rssi { get; set; }
//    }
//}