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;
|
|
namespace RichCreator
|
{
|
public class JobMonitor
|
{
|
private RichCreatorConfig config;
|
private CancellationTokenSource cancelTokenSource;
|
private bool canRun = true;//是否可运行
|
|
private WeGameJob wegameJob;
|
private JobBase dnfJob;
|
|
private Int32 taskIndex;
|
|
public JobMonitor(Int32 taskIndex)
|
{
|
this.config = ConfigHelper.GetInstance<RichCreatorConfig>();
|
this.cancelTokenSource = new CancellationTokenSource();
|
this.taskIndex = taskIndex;
|
}
|
|
/// <summary>
|
/// 开始
|
/// </summary>
|
public void Start()
|
{
|
if (!canRun)
|
{
|
throw new Exception("不能多次运行");
|
}
|
canRun = false;
|
ThreadPool.QueueUserWorkItem(MonitorBusinessThread);
|
}
|
|
//停止
|
public void Stop()
|
{
|
this.cancelTokenSource.Cancel();
|
canRun = true;
|
this.cancelTokenSource = new CancellationTokenSource();
|
}
|
|
private void MonitorBusinessThread(object obj)
|
{
|
Int32 accountCount = GetAccountCount();
|
Int32 runningStep = RunningStep.GetStep();
|
G.Instance.InfoWriter("当前步骤：" + runningStep.ToString());
|
RunningModel runModel = ConfigHelper.GetInstance<RunningModel>();
|
if (runModel.AccountIndex > accountCount)
|
{
|
G.Instance.InfoWriter("开始角色比已配置角色还多，如果没有那么多角色请清空运行模型");
|
return;
|
}
|
|
bool tryAgain = false;
|
int accountIndex = runModel.AccountIndex > 0 ? runModel.AccountIndex - 1 : 0;
|
for (; accountIndex < accountCount; accountIndex++)
|
{
|
RunningModel.UpdateAccountIndex(accountIndex+1);
|
if (runningStep < RunningStep.SelectRole)
|
{
|
string username, password;
|
GetAccount(accountIndex, out username, out password);
|
|
this.wegameJob = new WeGameJob(this.config, username, password);
|
if (!this.wegameJob.DoWork(out tryAgain,this.cancelTokenSource.Token, runningStep))
|
{
|
if (G.Instance.CancelConfirm("需要重试吗?", 8000))
|
{
|
if (config.NotificationWechat)
|
{
|
if (!ServiceMonitor.Instance.NotificationWechat("失败，正在重新尝试"))
|
{
|
ZTImage.Log.Trace.Error("发送消息失败");
|
}
|
}
|
accountIndex--;
|
runningStep = RunningStep.None;
|
ProcessUtils.CloseDnf();
|
ProcessUtils.CloseWeGame();
|
continue;
|
}
|
else
|
{
|
break;
|
}
|
}
|
}
|
|
//设为顶层
|
WindowUtils.SetDnfToTop();
|
this.dnfJob = GetDNFJob();
|
if (this.dnfJob == null)
|
{
|
break;
|
}
|
if (!this.dnfJob.DoWork(out tryAgain,this.cancelTokenSource.Token, runningStep))
|
{
|
if (G.Instance.CancelConfirm("需要重试吗?", 8000))
|
{
|
if (config.NotificationWechat)
|
{
|
if (!ServiceMonitor.Instance.NotificationWechat("失败，正在重新尝试"))
|
{
|
ZTImage.Log.Trace.Error("发送消息失败");
|
}
|
}
|
accountIndex--;
|
runningStep = RunningStep.None;
|
ProcessUtils.CloseDnf();
|
ProcessUtils.CloseWeGame();
|
continue;
|
}
|
else
|
{
|
break;
|
}
|
}
|
runningStep = RunningStep.None;
|
ProcessUtils.CloseDnf();
|
ProcessUtils.CloseWeGame();
|
Thread.Sleep(5000);
|
}
|
|
if (config.NotificationWechat)
|
{
|
if (!ServiceMonitor.Instance.NotificationWechat("任务完成"))
|
{
|
ZTImage.Log.Trace.Error("发送消息失败");
|
}
|
}
|
|
runModel.RoleIndex = 1;
|
runModel.AccountIndex = 1;
|
ConfigHelper.SetInstance<RunningModel>(runModel);
|
this.Stop();
|
G.Instance.StopTaskUI();
|
G.Instance.InfoWriter("任务成功完成");
|
}
|
|
/// <summary>
|
/// 获取配置文件中账号的数量
|
/// </summary>
|
/// <returns></returns>
|
private Int32 GetAccountCount()
|
{
|
Int32 accountCount = 0;
|
if (!string.IsNullOrEmpty(this.config.UserName1))
|
{
|
accountCount = 1;
|
if (!string.IsNullOrEmpty(this.config.UserName2))
|
{
|
accountCount = 2;
|
if (!string.IsNullOrEmpty(this.config.UserName3))
|
{
|
accountCount = 3;
|
}
|
}
|
}
|
|
return accountCount;
|
}
|
|
/// <summary>
|
/// 获取指定编号
|
/// </summary>
|
/// <param name="accountIndex">从0开始</param>
|
/// <param name="username"></param>
|
/// <param name="password"></param>
|
private void GetAccount(Int32 accountIndex, out string username, out string password)
|
{
|
username = this.config.UserName1;
|
password = this.config.Password1;
|
if (accountIndex == 1)
|
{
|
username = this.config.UserName2;
|
password = this.config.Password2;
|
}
|
|
if (accountIndex == 2)
|
{
|
username = this.config.UserName3;
|
password = this.config.Password3;
|
}
|
}
|
|
/// <summary>
|
/// 根据当前选择的地图实例化DNF地图
|
/// </summary>
|
/// <param name="config"></param>
|
/// <returns></returns>
|
private JobBase GetDNFJob()
|
{
|
switch (this.taskIndex)
|
{
|
case 0:
|
return new DNFJob<LindongMap>(this.config);
|
case 1:
|
return new DNFJob<SkillMap>(this.config);
|
case 2:
|
return new DNFJob<GroupMap>(this.config);
|
default:
|
return null;
|
}
|
}
|
}
|
}
|
