DaiXianDataUpload/DataUpload/FormMain.cs

using log4net;
using Newtonsoft.Json;
using RDIFramework.Utilities;
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Configuration;
using System.Data;
using System.Drawing;
using System.IO;
using System.Linq;
using System.Net;
using System.Net.Http;
using System.Text;
using System.Windows.Forms;
using System.Xml;
using TimedUpload;

namespace DataUpload
{
    public partial class FormMain : Form
    {
        private readonly ILog log = LogManager.GetLogger(typeof(Form));

        public string dbMeter = ConfigurationManager.AppSettings["DBMeter"];
        public string nbMeter = ConfigurationManager.AppSettings["NBMeter"];
        public string loraMeter = ConfigurationManager.AppSettings["LoraMeter"];
        public string User = ConfigurationManager.AppSettings["UserName"];
        public string Pwd = ConfigurationManager.AppSettings["Pwd"];

        static readonly HttpClient client = new HttpClient();
        public string upDataUrl = ConfigurationManager.AppSettings["upDataUrl"];

        IDbProvider dbHelper
        {
            get
            {
                var DbDefine = DbFactoryProvider.GetProvider(CurrentDbType.Access, dbMeter);
                return DbDefine;
            }
        }

        IDbProvider nbHelper
        {
            get
            {
                var DbDefine = DbFactoryProvider.GetProvider(CurrentDbType.SqlServer, nbMeter);
                return DbDefine;
            }
        }

        IDbProvider loraHelper
        {
            get
            {
                var DbDefine = DbFactoryProvider.GetProvider(CurrentDbType.SqlServer, loraMeter);
                return DbDefine;
            }
        }

        public FormMain()
        {
            InitializeComponent();
        }

        private void btnSearch_Click(object sender, EventArgs e)
        {
            FormSearch form = new FormSearch();
            form.FillListView += form_FillListView;
            form.ShowDialog();
        }

        void form_FillListView(string sql,string type,string start,string end)
        {
            try
            {
                //this.loading.Visible = true;
                //this.loading.Start();
                DataTable dt = dbHelper.Fill(sql);
                this.lstData.Items.Clear();
                this.lstData.BeginUpdate();
                for (int i = 0; i < dt.Rows.Count; i++)
                {
                    ListViewItem item = new ListViewItem();
                    item.Text = (i + 1).ToString();
                    item.SubItems.Add(dt.Rows[i]["小区名称"].ToString());
                    item.SubItems.Add(dt.Rows[i]["楼宇编号"].ToString() + dt.Rows[i]["楼宇名称"].ToString());
                    item.SubItems.Add(dt.Rows[i]["单元编号"].ToString() + dt.Rows[i]["单元名称"].ToString());
                    item.SubItems.Add(dt.Rows[i]["门牌编号"].ToString() + dt.Rows[i]["门牌名称"].ToString());
                    item.SubItems.Add(dt.Rows[i]["UserNo"].ToString());
                    item.SubItems.Add(dt.Rows[i]["表编号"].ToString());
                    string reading = dt.Rows[i]["本次读数"].ToString();
                    item.SubItems.Add(Math.Round(decimal.Parse(reading), MidpointRounding.AwayFromZero).ToString());
                    item.SubItems.Add(dt.Rows[i]["本次抄表日期"].ToString());
                    item.SubItems.Add("");
                    this.lstData.Items.Add(item);
                }
                this.lstData.EndUpdate();
            }
            catch(Exception ex)
            {
                MessageBox.Show(ex.Message);
            }
            finally
            {
                //this.loading.Visible = false;
            }
            
        }

        private void FormMain_Load(object sender, EventArgs e)
        {
            this.lstData.Columns[0].Width = 80;
            int width = this.Width - 10-80;
            int per = width / 9;
            for (int i = 1; i < this.lstData.Columns.Count; i++)
            {
                this.lstData.Columns[i].Width = per;
                
            } 
        }

        private void btnUpload_Click(object sender, EventArgs e)
        {

            if (this.lstData.Items.Count <= 0)
            {
                MessageBox.Show("没有可上传的数据");
            }
            else
            {
                try
                {
                    this.btnSearch.Enabled = false;
                    this.btnUpload.Enabled = false;
                    this.pBar.Visible = true;
                    this.pBar.Maximum = this.lstData.Items.Count;
                    this.pBar.Value = 0;
                    string company = "2971";

                    for (int i = 0; i < this.lstData.Items.Count; i++)
                    {
                        string userNo = this.lstData.Items[i].SubItems[5].Text;
                        string waterMeterNo = this.lstData.Items[i].SubItems[6].Text;
                        string reading = this.lstData.Items[i].SubItems[7].Text;
                        string date = this.lstData.Items[i].SubItems[8].Text;
                        // 解析日期字符串  
                        DateTime dateTime = DateTime.ParseExact(date, "yyyy/M/d H:mm:ss", null);

                        //// 如果日期在每月的24号之后，则设置为下个月的第一天  
                        //if (dateTime.Day > 24)
                        //{
                        //    dateTime = dateTime.AddMonths(1);
                        //    dateTime = new DateTime(dateTime.Year, dateTime.Month, 1);
                        //}

                        // 格式化日期为 "yyyyMM" 格式  
                        string formattedDate = dateTime.ToString("yyyy-MM-dd HH:mm:ss");
                       
                        string result = "";
                        try
                        {
                          
                            string param = "{\"userId\":\""+ userNo + "\",\"waterNum\":"+ reading + ",\"quantity\":0,\"waterMonth\":\""+ formattedDate + "\"}";
                            param = "data=[{\"company\":" + company + ",\"meterdata\":[{\"code\":\"" + userNo + "\",\"watermeter\":\""+ waterMeterNo + "\",\"currentindex\":\"" + reading + "\",\"meterdate\":\"" + formattedDate + "\"}]}]";
                            string resultData = PostWebRequest(upDataUrl, param);
                            // 找到最后一个"}"的位置  
                            int lastBracePosition = resultData.LastIndexOf("}");
                            // 如果找到了"}"，那么删除后面的所有字符  
                            if (lastBracePosition != -1)
                            {
                                resultData = resultData.Remove(lastBracePosition + 1);
                            }
                            var jsonObject = JsonConvert.DeserializeObject<Result>(resultData);
                            int code = jsonObject.errcode;
                            // 成功
                            if (jsonObject.message.Contains("成功"))
                            {
                                log.Info("数据:"+param+ "\n上报成功!");
                                result = "成功!"+jsonObject.message;
                            }
                            // 失败
                            else
                            {
                                log.Info("数据:" + param + "\n上报失败!返回编码:"+ code);
                                // result = "失败!数据:" + param + "code =" + code +";message="+ jsonObject.message;
                                result = "失败!"+jsonObject.message;
                            }
                        }
                        catch (Exception ex)
                        {
                            result = ex.Message;
                            log.Info("失败!出现异常:" + result);

                            //异常保存数据
                            //sql = " insert into Data_temp(userNo,reading,[date]) values('" + userNo + "'," + reading + ",'" + date + "')";
                            //int num = dbHelper.ExecuteNonQuery(sql);
                        }
                        this.lstData.Items[i].SubItems[9].Text = result;
                        this.pBar.Value = i;
                    }
                    this.pBar.Visible = false;
                }
                catch(Exception ex)
                {
                    MessageBox.Show(ex.Message);
                    this.btnSearch.Enabled = true;
                    this.btnUpload.Enabled = true;
                }
                this.btnSearch.Enabled = true;
                this.btnUpload.Enabled = true;
            }
        }

        private void button1_Click(object sender, EventArgs e)
        {
            DataTable dt;
            try
            {
                String sql = "  select * from Bsc_AreaInfo ";
                dt = dbHelper.Fill(sql);
                if (dt != null && dt.Rows.Count > 0)
                {
                    SaveFileDialog savefile = new SaveFileDialog();
                    savefile.Filter = "Excel 99-03文件|*.xls";
                    DialogResult re = savefile.ShowDialog();
                    if (re == DialogResult.OK)
                    {
                        ExcelUtil.Export(dt, null, savefile.FileName);
                        MessageBox.Show("导出完成!");
                    }
                }
            }
            catch (Exception ex)
            {

                MessageBox.Show("导出数据失败");
            }
          





        }

        /// <summary>
        /// Post提交数据
        /// </summary>
        /// <param name="postUrl">URL</param>
        /// <param name="paramData">参数</param>
        /// <returns></returns>
        private string PostWebRequest(string postUrl, string paramData)
        {
            string ret = string.Empty;
            try
            {
                if (!postUrl.StartsWith("http://"))
                    return "";

                byte[] byteArray = Encoding.Default.GetBytes(paramData); //转化 /
                HttpWebRequest webReq = (HttpWebRequest)WebRequest.Create(new Uri(postUrl));
                webReq.Method = "POST";
                webReq.ContentType = "application/x-www-form-urlencoded";

                webReq.ContentLength = byteArray.Length;
                Stream newStream = webReq.GetRequestStream();
                newStream.Write(byteArray, 0, byteArray.Length);//写入参数
                newStream.Close();
                HttpWebResponse response = (HttpWebResponse)webReq.GetResponse();
                StreamReader sr = new StreamReader(response.GetResponseStream(), Encoding.UTF8);
                ret = sr.ReadToEnd();
                sr.Close();
                response.Close();
                newStream.Close();
            }
            catch (Exception ex)
            {
                return ex.Message;
            }
            return ret;
        }

        public class Result
        {
            public int errcode { get; set; }
            public string message { get; set; }
        }

        private void lstData_SelectedIndexChanged(object sender, EventArgs e)
        {

        }

        private void loading_Load(object sender, EventArgs e)
        {

        }

        private void pBar_Click(object sender, EventArgs e)
        {

        }

        private void button2_Click(object sender, EventArgs e)
        {
            NBFormSearch form = new NBFormSearch();
            form.FillListView += form_NBFillListView;
            form.ShowDialog();
        }

        void form_NBFillListView(string sql, string type, string start, string end)
        {
            try
            {
                //this.loading.Visible = true;
                //this.loading.Start();
                DataTable dt = nbHelper.Fill(sql);
                this.lstData.Items.Clear();
                this.lstData.BeginUpdate();
                for (int i = 0; i < dt.Rows.Count; i++)
                {
                    ListViewItem item = new ListViewItem();
                    item.Text = (i + 1).ToString();
                    item.SubItems.Add(dt.Rows[i]["小区名称"] + "");
                    item.SubItems.Add(dt.Rows[i]["楼宇名称"] + "");
                    item.SubItems.Add(dt.Rows[i]["单元名称"] + "");
                    item.SubItems.Add(dt.Rows[i]["门牌名称"] + "");
                    item.SubItems.Add(dt.Rows[i]["UserNo"] + "");
                    item.SubItems.Add(dt.Rows[i]["表编号"] + "");
                    string reading = dt.Rows[i]["本次读数"] + "";
                    item.SubItems.Add(Math.Round(decimal.Parse(reading), MidpointRounding.AwayFromZero).ToString());
                    item.SubItems.Add(dt.Rows[i]["本次抄表日期"] + "");
                    item.SubItems.Add("");
                    this.lstData.Items.Add(item);
                }
                this.lstData.EndUpdate();
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.Message);
            }
            finally
            {
                //this.loading.Visible = false;
            }

        }

        void form_ManyFillListView(string sql, string type, string start, string end)
        {
            try
            {
                //this.loading.Visible = true;
                //this.loading.Start();
                DataTable dt = dbHelper.Fill(sql);
                this.lstData.Items.Clear();
                this.lstData.BeginUpdate();
                for (int i = 0; i < dt.Rows.Count; i++)
                {
                    ListViewItem item = new ListViewItem();
                    item.Text = (i + 1).ToString();
                    item.SubItems.Add(dt.Rows[i]["小区名称"].ToString());
                    item.SubItems.Add(dt.Rows[i]["楼宇编号"].ToString() + dt.Rows[i]["楼宇名称"].ToString());
                    item.SubItems.Add(dt.Rows[i]["单元编号"].ToString() + dt.Rows[i]["单元名称"].ToString());
                    item.SubItems.Add(dt.Rows[i]["门牌编号"].ToString() + dt.Rows[i]["门牌名称"].ToString());
                    item.SubItems.Add(dt.Rows[i]["UserNo"].ToString());
                    item.SubItems.Add(dt.Rows[i]["表编号"].ToString());
                    string reading = dt.Rows[i]["本次读数"].ToString();
                    item.SubItems.Add(Math.Round(decimal.Parse(reading), MidpointRounding.AwayFromZero).ToString());
                    item.SubItems.Add(dt.Rows[i]["本次抄表日期"].ToString());
                    item.SubItems.Add("");
                    this.lstData.Items.Add(item);
                }
                this.lstData.EndUpdate();
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.Message);
            }
            finally
            {
                //this.loading.Visible = false;
            }

        }

        void form_LoraFillListView(string sql, string type, string start, string end)
        {
            try
            {
                //this.loading.Visible = true;
                //this.loading.Start();
                DataTable dt = loraHelper.Fill(sql);
                this.lstData.Items.Clear();
                this.lstData.BeginUpdate();
                for (int i = 0; i < dt.Rows.Count; i++)
                {
                    ListViewItem item = new ListViewItem();
                    item.Text = (i + 1).ToString();
                    item.SubItems.Add(dt.Rows[i]["小区名称"] + "");
                    item.SubItems.Add(dt.Rows[i]["楼宇编号"].ToString() + dt.Rows[i]["楼宇名称"].ToString());
                    item.SubItems.Add(dt.Rows[i]["单元编号"].ToString() + dt.Rows[i]["单元名称"].ToString());
                    item.SubItems.Add(dt.Rows[i]["门牌编号"].ToString() + dt.Rows[i]["门牌名称"].ToString());
                    item.SubItems.Add(dt.Rows[i]["UserNo"] + "");
                    item.SubItems.Add(dt.Rows[i]["表地址"] + "");
                    string reading = dt.Rows[i]["表读数"] + "";
                    item.SubItems.Add(Math.Round(decimal.Parse(reading), MidpointRounding.AwayFromZero).ToString());
                    item.SubItems.Add(dt.Rows[i]["抄表日期"] + "");
                    item.SubItems.Add("");
                    this.lstData.Items.Add(item);
                }
                this.lstData.EndUpdate();
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.Message);
            }
            finally
            {
                //this.loading.Visible = false;
            }

        }


        private void button1_Click_2(object sender, EventArgs e)
        {
            ManyFormSearch form = new ManyFormSearch();
            form.FillListView += form_ManyFillListView;
            form.ShowDialog();
        }

        private void button3_Click(object sender, EventArgs e)
        {
            LoraFormSearch form = new LoraFormSearch();
            form.FillListView += form_LoraFillListView;
            form.ShowDialog();
        }
    }
}