using Hydro.CommonBase;
|
using Hydro.Core.Model;
|
using Hydro.HydraulicOptimizer;
|
using System;
|
using System.Collections.Generic;
|
using System.IO;
|
using System.Linq;
|
using System.Text;
|
using System.Threading;
|
using System.Threading.Tasks;
|
using System.Windows.Forms;
|
using TimePoint = Hydro.CommonBase.TimePoint;
|
|
namespace Hydro.MapView
|
{
|
public class calc
|
{
|
public WDNModelOptimizer wdo;
|
|
public DateTime time = DateTime.Now;
|
public DateTime T_time = DateTime.Now;
|
public WdnmoParam wParam = null;
|
public List<TimePoint> GetCalcResult(string InpPath, WdnmoParam wP, string configPath = null)
|
{
|
|
string result = null;
|
|
Console.Write("请输入重复计算次数：(默认：1)");
|
string sr;
|
T_time = DateTime.Now;
|
GeneticParams gparam = new GeneticParams(0);
|
|
var wdo = new WDNModelOptimizer(gparam);
|
WdnmoParam param;
|
|
#region bak1
|
|
wParam = wP;
|
|
param = wParam;
|
|
|
|
|
#endregion bak1
|
|
|
|
time = DateTime.Now;
|
if (configPath == null) configPath = System.IO.Directory.GetCurrentDirectory() + "\\" + "config_calc.wdb"; ;
|
string path = configPath;
|
result = wdo.Init(path, InpPath, onFinish, onError, null, param, false);
|
if (result != null)
|
{
|
wdo.Close();
|
throw new Exception(result);
|
|
//return null;
|
//return;
|
}
|
|
result = wdo.Run(param, false);
|
|
while (true)
|
{
|
lock (lockobj)
|
{
|
if (isFinished)
|
{
|
if (wdo != null)
|
wdo.Close();
|
break;
|
|
}
|
}
|
|
}
|
//wParam.ResultPoints.ForEach(p => p.Value = num);
|
return wParam.ResultPoints;
|
|
}
|
object lockobj = new object();
|
public string getStringByJson(string path)
|
{
|
StreamReader sr = new StreamReader(path);
|
string s = sr.ReadToEnd();
|
sr.Close();
|
return s;
|
}
|
|
public bool isFinished = false;
|
public object FOBJ = new object();
|
public void onFinish(dynamic modelParams)
|
{
|
|
var param = modelParams as WdnmoParam;
|
|
|
|
|
new Thread(() =>
|
{
|
Thread.Sleep(100);
|
if (wdo != null)
|
wdo.Close();
|
}).Start();
|
this.wParam = param;
|
lock (lockobj)
|
{
|
isFinished = true;
|
}
|
|
}
|
public void onError(dynamic result)
|
{
|
|
|
//MessageBox.Show("原因：" + result, "计算失败");
|
new Thread(() =>
|
{
|
Thread.Sleep(1000);
|
if (wdo != null)
|
wdo.Close();
|
}).Start();
|
lock (lockobj)
|
{
|
isFinished = true;
|
}
|
throw new Exception("计算失败,原因：" + result);
|
}
|
|
}
|
}
|
