using RichCreator.Utility;
|
using RichCreator.Utility.Captures;
|
using RichCreator.Utility.CV;
|
using RichCreator.Utility.InputControl;
|
using RichCreator.Utility.Structs;
|
using RichCreator.Utility.Utilitys;
|
using Emgu.CV;
|
using Emgu.CV.Structure;
|
using RichCreator.Jobs;
|
using RichCreator.Models;
|
using RichCreator.Utilitys;
|
using System;
|
using System.Collections.Generic;
|
using System.Diagnostics;
|
using System.Linq;
|
using System.Text;
|
using System.Threading;
|
using System.Threading.Tasks;
|
using ZTImage.Configuration;
|
using RichCreator.Maps;
|
using RichCreator.Utility.Maps;
|
|
namespace RichCreator
|
{
|
public class JobMonitor
|
{
|
private RichCreatorConfig config;
|
private CancellationTokenSource cancelTokenSource;
|
private bool canRun = true;//是否可运行
|
|
private WeGameJob wegameJob;
|
private JobBase dnfJob;
|
|
private MapType mapType;
|
|
Int32 runningStep = RunningStep.None;
|
|
public JobMonitor(MapType maptype)
|
{
|
this.config = ConfigHelper.GetInstance<RichCreatorConfig>();
|
this.cancelTokenSource = new CancellationTokenSource();
|
this.mapType = maptype;
|
}
|
|
/// <summary>
|
/// 开始
|
/// </summary>
|
public void Start()
|
{
|
if (!canRun)
|
{
|
throw new Exception("不能多次运行");
|
}
|
canRun = false;
|
Thread thread = new Thread(MonitorBusinessThread);
|
thread.IsBackground = true;
|
thread.Start();
|
|
|
|
//ThreadPool.QueueUserWorkItem(MonitorBusinessThread);
|
}
|
|
//停止
|
public void Stop()
|
{
|
this.cancelTokenSource.Cancel();
|
canRun = true;
|
this.cancelTokenSource = new CancellationTokenSource();
|
}
|
|
/// <summary>
|
/// 业务逻辑线程
|
/// </summary>
|
/// <param name="obj"></param>
|
private void MonitorBusinessThread(object obj)
|
{
|
Int32 accountCount = this.config.GetAccountCount();
|
runningStep = RunningStep.GetStep();
|
G.Instance.InfoWriter("当前步骤：" + runningStep.ToString());
|
RunningModel runModel = ConfigHelper.GetInstance<RunningModel>();
|
if (runModel.AccountIndex > accountCount)
|
{
|
G.Instance.InfoWriter("开始角色比已配置角色还多，如果没有那么多角色请清空运行模型");
|
return;
|
}
|
|
|
int accountIndex = runModel.AccountIndex > 0 ? runModel.AccountIndex - 1 : 0;
|
ZTResult jobResult = ZTResult.Success;
|
for (; accountIndex < accountCount; accountIndex++)
|
{
|
RunningModel.UpdateAccountIndex(accountIndex+1);
|
|
if (runningStep < RunningStep.SelectRole)
|
{
|
string username, password;
|
this.config.GetAccount(accountIndex, out username, out password);
|
|
this.wegameJob = new WeGameJob(this.config, username, password);
|
jobResult = this.wegameJob.Do(this.cancelTokenSource.Token, runningStep);
|
if (jobResult != ZTResult.Success)
|
{
|
if (jobResult != ZTResult.Cancel)
|
{
|
if (G.Instance.CancelConfirm("需要重试吗?", 8000))
|
{
|
ServiceProvider.Instance.NotificationWechat("失败，正在重新尝试");
|
accountIndex--;
|
ShutdownGameProgram();
|
continue;
|
}
|
}
|
break;
|
}
|
}
|
|
//设为顶层
|
WindowUtils.SetDnfToTop();
|
this.dnfJob = new DNFJob(this.mapType, this.config);
|
jobResult = this.dnfJob.Do(this.cancelTokenSource.Token, runningStep);
|
if (jobResult != ZTResult.Success)
|
{
|
if (jobResult != ZTResult.Cancel)
|
{
|
if (G.Instance.CancelConfirm("需要重试吗?", 8000))
|
{
|
ServiceProvider.Instance.NotificationWechat("失败，正在重新尝试");
|
accountIndex--;
|
ShutdownGameProgram();
|
continue;
|
}
|
}
|
break;
|
}
|
|
ShutdownGameProgram();
|
Thread.Sleep(5000);
|
}
|
|
if (jobResult == ZTResult.Success)
|
{
|
G.Instance.InfoWriter("任务完成");
|
ServiceProvider.Instance.NotificationWechat("任务完成");
|
runModel.RoleIndex = 1;
|
runModel.AccountIndex = 1;
|
ConfigHelper.SetInstance<RunningModel>(runModel);
|
}
|
else
|
{
|
G.Instance.InfoWriter("任务中止");
|
}
|
|
this.Stop();
|
G.Instance.StopTaskUI();
|
|
}
|
|
/// <summary>
|
/// 关闭游戏程序
|
/// </summary>
|
private void ShutdownGameProgram()
|
{
|
runningStep = RunningStep.None;
|
ProcessUtils.CloseDnf();
|
ProcessUtils.CloseWeGame();
|
}
|
|
}
|
}
|
