C# と VB.NET の質問掲示板

C# Windowsフォームアプリケーション .NetFramework

宜しくお願い致します

form1で1秒毎に外部機器からデータを呼び出して折れ線グラフで表示しています。
そしてそのデータを日付のファイルにcsvで書き込んでいます（1秒毎ですので1日約９万件)

それをform3で１週間分の棒グラフを表示させています(form1は表示したまま)

データの保存、表示は出来ているのですが、作り方を分かっていなかったので
form3のグラフを集計、表示させている間にform1の折れ線グラフが止まっていました

調べましてform3の集計を非同期で処理させようと思ったのですがうまくいかず
何かいい方法はありましたら教えて頂けないでしょうか
宜しくお願い致します


using System;
using System.Collections.Generic;
using System.Drawing;
using System.Threading.Tasks;
using System.Windows.Forms;
using System.Windows.Forms.DataVisualization.Charting;
using System.IO;

using System.Globalization;


namespace グラフ表示
{
    public partial class Form3 : Form
    {

        private Form1 form1Instance;

        private Dictionary<DateTime, double> dailyTotals;

        public Form3(Form1 form1)
        {
            InitializeComponent();
            
            form1Instance = form1;

            timer1 = new Timer();
            timer1.Interval = 1000; 
            timer1.Tick += timer1_Tick;
            timer1.Start();
        }

        private void Form3_Load(object sender, EventArgs e)
        {

            day7();
            line7();

            lblDate.Text = "2000/00/00";
            lblTime.Text = "00:00:00";
        }

        private void btnMainMenu_Click(object sender, EventArgs e)
        {  
            var form2 = new Form2(new Form1());
            form2.Show();
            this.Close();
        }

        private void timer1_Tick(object sender, EventArgs e)
        {
            lblDate.Text = DateTime.Now.ToString("yyyy/M/d");
            lblTime.Text = DateTime.Now.ToString("HH:mm:ss");

        }
  
        private Dictionary<DateTime, double> AggregateDailyTotals(string inputDirectory)
        {
            Dictionary<DateTime, double> dailyTotals = new Dictionary<DateTime, double>();

            foreach (string filePath in Directory.GetFiles(inputDirectory, "*.csv"))
            {
                ParseCSVFile(filePath, dailyTotals);
            }
            return dailyTotals;
        }

        
        private void ParseCSVFile(string filePath, Dictionary<DateTime, double> dailyTotals)
        {
            try
            {
                foreach (string line in File.ReadLines(filePath))
                {
                    string[] fields = line.Split(','); // カンマで分割
                    string dateString = fields[0];// 日付を取得します（日付がA列にある）
                    DateTime date;

                    if (DateTime.TryParseExact(dateString, "yyyy/M/d", CultureInfo.InvariantCulture, DateTimeStyles.None, out date))
                    {
                        double value;
                        if (double.TryParse(fields[2], out value)) // C列値
                        {

                            if (dailyTotals.ContainsKey(date))// 日付毎に集計
                            {
                                dailyTotals[date] += value;
                              
                            }
                            else
                            {
                                dailyTotals[date] = value;
                            }
                            
                        }
                    }
                }
                
            }
            catch (Exception ex) 
            {
                MessageBox.Show("以下の理由でファイルが開けません。\n" + ex.Message);
            }
        }

        private void day7()
        {
            string inputDirectory = G.csvDataFilePath;// 入力ディレクトリのパスを指定
            dailyTotals = AggregateDailyTotals(inputDirectory);// 集計結果を取得

            Dictionary<DateTime, double> last7DaysTotals = GetLast7DaysTotals();// 過去7日間の集計結果を取得
            dataGridView1.Rows.Clear();                         // DataGridViewに結果を表示

            foreach (DateTime date in GetLast7DaysDates())
            {
                double total = last7DaysTotals.ContainsKey(date) ? last7DaysTotals[date] : 0.0;
                dataGridView1.Rows.Add(date.ToString("yyyy/M/d"), total);
            }
        }

        private Dictionary<DateTime, double> GetLast7DaysTotals()
        {
            DateTime currentDate = DateTime.Now.Date;
            DateTime sevenDaysAgo = currentDate.AddDays(-7);

            Dictionary<DateTime, double> last7DaysTotals = new Dictionary<DateTime, double>();

            foreach (var entry in dailyTotals)
            {
                if (entry.Key >= sevenDaysAgo && entry.Key <= currentDate)
                {
                    last7DaysTotals[entry.Key] = entry.Value;
                }
            }
            return last7DaysTotals;
        }

        private IEnumerable<DateTime> GetLast7DaysDates()
        {
            DateTime currentDate = DateTime.Now.Date;

            for (int i = 7; i >= 0; i--)
            {
                yield return currentDate.AddDays(-i);
            }
        }
        
        private void line7()
        {                                                       // 7日前から本日までの日ごとの集計結果を取得
            Dictionary<DateTime, double> last7DaysTotals = GetLast7DaysTotals();

            chart1.Series.Clear();                              // グラフを初期化
            chart1.Titles.Clear();

            Series series = new Series("過去８日間の合計");
            series.ChartType = SeriesChartType.Column;

            foreach (DateTime date in GetLast7DaysDates())
            {
                double total = last7DaysTotals.ContainsKey(date) ? last7DaysTotals[date] : 0.0;

                DataPoint dataPoint = new DataPoint();
                dataPoint.SetValueXY(date.ToString("yyyy/M/d"), (total/60));//60
                dataPoint.Label = (total/60).ToString("0.0");             
                series.Points.Add(dataPoint);
            }
	
	//グラフ表示
            chart1.Series.Add(series);                         
            Title title=chart1.Titles.Add("過去８日間の合計");  
            chart1.Visible = true;                             
            title.Font = new Font("Arial", 20, FontStyle.Bold);
            //chart1.Update();
        }
    }
}

■No102812 (とっちゃん さん) に返信
> ■No102807 (まさ さん) に返信
>>C# Windowsフォームアプリケーション .NetFramework
ありがとうございます
 form1で1秒毎にデータを読込み折れ線グラフを表示させている時
form3を走らせるとform1の折れ線グラフが止まってしまします
form1をどのように変更させて頂けばよろしいでしょうか

using Opc.UaFx.Client;
using System;
using System.Collections.Generic;
using System.Drawing;
using System.IO;
using System.Linq;
using System.Windows.Forms;
using System.Windows.Forms.DataVisualization.Charting;
using static System.Windows.Forms.DataFormats;
using System.Threading.Tasks;


namespace グラフ表示
{
    public partial class Form1 : Form
    {

        private Timer dataLoadTimer;
        private int dataCounter;

        private OpcClient client;
        private DateTime startTime;

        private Timer timer;
        private Random random;
        private Chart upperChart;
        private Chart lowerChart;

        string currentDate = DateTime.Now.ToString("yyyyMd");

        int cycletime;

        private List<double> upperList;
        private List<double> lowerList;
        
        public Form1()
        {
            InitializeComponent();
            cycletime = 300;

            random = new Random();
            CreateChart();
        }

        private void CreateChart() 
        {
            IEnumerable<double> doubles = Enumerable.Repeat(double.NaN, cycletime + 1);

            upperChart = CreateChart(upperList = new List<double>(doubles));
            upperChart.Location = new System.Drawing.Point(280, 180);
            this.Controls.Add(upperChart);

            lowerChart = CreateChart(lowerList = new List<double>(doubles));
            lowerChart.Location = new System.Drawing.Point(280, 490);
            this.Controls.Add(lowerChart);
        }

        private void Form1_Load(object sender, EventArgs e)
        {
            string csvFilePath = G.priceDataFilePath;
            ReadValueAndDisplayInLabel(csvFilePath);
        }

        private void ReadValueAndDisplayInLabel(string filePath)
        {
            try
            {
                G.priceData = ReadValueFromCSV(filePath);
                label11.Text = G.priceData.ToString();
            }
            catch (Exception ex)
            {
                MessageBox.Show("エラー: " + ex.Message, "エラー", MessageBoxButtons.OK, MessageBoxIcon.Error);
            }
        }

        private int ReadValueFromCSV(string filePath)
        {
            int result = 0;

            try
            {
                string[] lines = File.ReadAllLines(filePath);

                if (lines.Length > 0)
                {
                    if (int.TryParse(lines[0], out result))
                    {
                        Console.WriteLine("CSVファイルから数値を正しく読み取りました。");
                    }
                    else
                    {
                        Console.WriteLine("CSVファイルの最初の行が数値ではありません。");
                    }
                }
                else
                {
                    Console.WriteLine("CSVファイルが空です。");
                }
            }
            catch (Exception ex)
            {
                Console.WriteLine("エラー: " + ex.Message);
            }
            return result;
        }

       private void btnHome_Click(object sender, EventArgs e)
        {
            Form2 form2 = new Form2(this);
            form2.Show();
        }

        private void btnStart1_Click(object sender, EventArgs e)
        {
            if (chkRandom.Checked) {}
            else 
            { 
                if (client == null || client.State != OpcClientState.Connecting)
                {
                    try
                    {
                        string url = "opc.tcp://192.168.0.1:4840";
                        string user = "admin";
                        string password = "admin";

                        client = new OpcClient(url);
                        client.Security.UserIdentity = new OpcClientIdentity(user, password);
                        lbltext.Text = "通信開始";

                        client.Connect();
                        
                        lbltext.Text = "通信ＯＫ";
                    }
                    catch (Exception ex)
                    { 
                        lbltext.Text = "通信ＮＧ";
                    }
                }
            }
            
            startTime = DateTime.UtcNow;
           
            dataLoadTimer = new Timer();
            dataLoadTimer.Interval = 1000; 
            dataLoadTimer.Tick += (s, a) => DataLoadTimer_Tick();//////　a でいいのか❓
            dataLoadTimer.Start();

        }

        private void DataLoadTimer_Tick()
        {
            
            LoadData();
        }

        private void btnStop1_Click(object sender, EventArgs e)
        {
            dataLoadTimer.Stop();
        }

        private void btnClose_Click(object sender, EventArgs e)
        {
            Application.Exit();
        }

        private Chart CreateChart(IList<double> doubles)
        {

            Chart chart = new Chart();
            chart.Size = new System.Drawing.Size(980, 300);
            chart.ChartAreas.Add(new ChartArea());
            chart.Series.Add("DataSeries");
            chart.Series["DataSeries"].ChartType = SeriesChartType.Line;
            chart.Series["DataSeries"].BorderWidth = 2; 

                    chart.ChartAreas[0].AxisX.LabelStyle.Enabled = true;
                    for (int i = 0; i < doubles.Count; i++)
                    {
                        chart.Series["DataSeries"].Points.AddXY(i, doubles[i]);
                    }

            chart.ChartAreas[0].AxisX.Minimum = 0;    
            chart.ChartAreas[0].AxisX.Maximum = doubles.Count - 1;

            return chart;
        }


        private void SlideData(Chart chart, List<double> list, double newData)
        {
            list.Add(newData);
            list.RemoveAt(0);

            chart.Series["DataSeries"].Points.Clear();
            for (int x = 0; x < list.Count; x++)
            {
                chart.Series["DataSeries"].Points.AddXY(x, list[x]);
            }
        }

        private void LoadData()
        {
            
                try
                {
                    var currentTime = DateTime.UtcNow;
                    var elapsedTime = currentTime - startTime;

                    var flowNode = "ns=3;i=16844032";
                    var accumflowNode = "ns=3;i=16843776";
                    var pressureNode = "ns=3;i=16844544";
                    var tempNode = "ns=3;i=16844288";

                    var flow = client.ReadNode(flowNode);
                    var accumFlow = client.ReadNode(accumflowNode);
                    var pressure = client.ReadNode(pressureNode);
                    var temp = client.ReadNode(tempNode);

                    double flowData = Convert.ToInt32(flow.Value) / 1000.0;
                    double accumeData = Convert.ToInt32(accumFlow.Value) / 1000.0;
                    double pressureData = Convert.ToInt32(pressure.Value) / 1000.0;
                    double tempData = Convert.ToInt32(temp.Value) / 10.0;

                   
                    SlideData(upperChart, upperList, pressureData);
                    SlideData(lowerChart, lowerList, tempData);


                    //-------保存内容--------
                    DateTime dt = DateTime.Now;
                    string date = dt.ToString("yyyy/M/d");
                    string time = dt.ToString("HH:mm:ss");

                    string data1 = flowData.ToString();
                    string data2 = tempData.ToString();
                    string data3 = pressureData.ToString();
                    string data4 = accumeData.ToString();

                    string price = G.priceData.ToString();


                    SaveDataToCSV(date, time, data1, data2,data3,data4,price);

                    upperChart.ChartAreas[0].AxisX.Minimum = dataCounter >= cycletime ? dataCounter - cycletime : 0;
                    upperChart.ChartAreas[0].AxisX.Maximum = dataCounter;

                    lowerChart.ChartAreas[0].AxisX.Minimum = dataCounter >= cycletime ? dataCounter - cycletime : 0;
                    lowerChart.ChartAreas[0].AxisX.Maximum = dataCounter;


                    while (upperChart.Series["DataSeries"].Points.Count > 0 && upperChart.Series["DataSeries"].Points[0].XValue < dataCounter - cycletime)
                    {
                        upperChart.Series["DataSeries"].Points.RemoveAt(0);
                        lowerChart.Series["DataSeries"].Points.RemoveAt(0);

                        upperChart.ChartAreas[0].AxisX.Maximum = dataCounter;
                        lowerChart.ChartAreas[0].AxisX.Maximum = dataCounter;
                    }
                    
                    lbltext.Text = "通信中";
                }
                catch (Exception ex)
                {
                    lbltext.Text = ex.Message;
                    lbltext.Text = ex.StackTrace;
                }
        }


        private void SaveDataToCSV(string date, string time, string data1,string data2, string data3, string data4, string price)
        {
            try
            {
                string filePath = G.csvDataFilePath + DateTime.Now.ToString(@"yyyy\-M\-d") + ".csv";
               
                using (StreamWriter sw = File.AppendText(filePath))
                {
                    sw.WriteLine($"{date},{time},{data1},{data2},{data3},{data4},{price}");
                }
            }
            catch (Exception ex)
            {
                timer.Enabled = false;
                MessageBox.Show("以下の理由でファイルが開けません。\n" + ex.Message);
                timer.Enabled = true;
            }
        }
    }
}

■No102815 (furu さん) に返信
> ■No102813 (まさ さん) に返信
>> form1で1秒毎にデータを読込み折れ線グラフを表示させている時
>>form3を走らせるとform1の折れ線グラフが止まってしまします
> form3を走らせるところがありませんが
> どう走らせていますか？
> 
> form1を表示中form3を走らせるのに
> なぜform3でform1を作成（new Form1()）しているのですか？


説明不足ですみません
form1からボタンでform2(メニュー画面)を表示させてグラフ表示のform3を選択しています
form3はグラフを作るためにデータを900万件読み込んでいます
そのデータを読み込んでいる為20秒前後かかってしまい、その間form1の棒グラフが動かなく
なってしまいました

form3はform2から下記で開いています
         private void btnForm3_Click(object sender, EventArgs e)
        {
            Form3 form3 = new Form3();
            form3.Show();
            this.Close();
        }

■No102848 (takahiro さん) に返信
> ありがとうございました
> 色々付けたしながら作ったプログラムで
> よくわからなくなってきましたので
> 一旦整理させて頂いて宜しいでしょうか
> 
> 1秒毎にデータを読み込んできて折れ線グラフで表示します
> その間にdatagridviewなどを使うと折れ線グラフが止まってしまうので
> 集計だけ非同期でして集計結果を保存します
> その集計結果をもとに棒グラフを書く
> という流れではおかしいでしょうか

おそらくとっちゃんさんの■No102820の回答が
難しすぎて理解できないのではないかと想像しました。
回答の後半の方に具体的にどうすれば良いかも書かれてはいるのですが
もしかするとそこまで到達せずに、断念しているのではと思います。

単刀直入に質問者さんに実施して欲しいことだけを書くと
下記変更前のコードを、下記変更後コードに修正して
結果をこの掲示板に書いて欲しいです。
そうすれば回答が付くと思います。

・変更前コード
private void Form3_Load(object sender, EventArgs e)
        {
            day7();
            line7();
            lblDate.Text = "2000/00/00";
            lblTime.Text = "00:00:00";
        }

・変更後コード（修正箇所は２か所です。注意）
private async void Form3_Load(object sender, EventArgs e)
        {
            await Task.Factory.StartNew( () => day7() );
            line7();
            lblDate.Text = "2000/00/00";
            lblTime.Text = "00:00:00";
        }