//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 l_Data = new List(); // 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"); // } // /// // /// 更新配置文件中的更新数据时间 // /// // /// // 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(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 { 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; } // } //}