2 Star 8 Fork 4

ZL007/PhoneControl

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
克隆/下载
Program.cs 13.22 KB
一键复制 编辑 原始数据 按行查看 历史
ZL007 提交于 2021-03-09 22:16 . 第一次提交
using System;
using System.Collections.Generic;
using System.Linq;
using DroidLord.Core;
using SharpAdbClient;
using DroidLord.Security;
using System.Windows.Forms;
using DroidLord.Task;
using System.Collections;
using System.Threading;
using System.IO;
using System.Diagnostics;
using System.Text;
using DroidLord.Resource;
using Newtonsoft.Json.Linq;
using MaterialSkin;
using DroidLord.Network;
namespace DroidLord
{
public static class Program
{
public static object JsonParse(string json)
{
try
{
return JObject.Parse(json);
}
catch
{
return null;
}
}
public const string DIR_LIBS = @"\bin\lib\share\";
public const string DIR_EXE = @"\bin\lib\exe\";
public static SecureHash MD5 = new SecureHash("md5");
public static SecureHash SHA256 = new SecureHash("sha256");
public static RSA RSA = new RSA();
public static AES AES = new AES();
public static EventManager Events = new EventManager();
public static SettingManager GlobalSetting;
public static Storage Repository = new Storage();
public static string etcDir = Environment.CurrentDirectory + @"\etc";
public static string varDir = Environment.CurrentDirectory + @"\var";
public static string usrDir = Environment.CurrentDirectory + @"\usr";
public static string CONFIG_FILE = etcDir + @"\default.conf";
public static Dispatcher Worker = new Dispatcher();
public static int ScreenPortBase = 20000;
public static int MonkeyPortBase = 23000;
public static int LocationBase = 19000;
public static int screenFrame = 25;
public static bool isOpenTotalControl = false;
private static Form mainFrm;
public static MainForm mainFrom=null;
/// <summary>
/// 主控操作界面
/// </summary>
public static SlaveViewer totalControlViewer = null;
// 脚本列表
public static ResourceManager Scripts = new ResourceManager();
// 设备列表
public static ResourceManager Slaves = new ResourceManager();
// 设备列表
public static ResourceManager Contents = new ResourceManager();
// 日志列表
public static LogManager Logs = new LogManager();
// tcp服务
public static TcpServer RPCServer;
// 后台持久任务
public static Dispatcher Tasks = new Dispatcher();
// 定时执行
public static Ticker Ticker = new Ticker();
public static bool StorageInited = false;
public static bool isExist = false;
private static string DefaultStorage = varDir + @"\default.storage";
private static string DefaultStorageLock = varDir + @"\default.storage.lock";
public static SaveManager GlobalSave = new SaveManager(DefaultStorage);
/// <summary>
/// 应用程序的主入口点。
/// </summary>
[STAThread]
static void Main()
{
AdbManager.initAdbPath(usrDir + @"\bin\adb.exe");
AdbManager.killServer();
AdbManager.startServer();
AdbServer.Instance.StartServer(AdbManager.adbPath, false);
LoadDefaultStorage();
GlobalSave.Handle("Global", Repository);
GlobalSave.Handle("Contents", Contents);
GlobalSave.Handle("Logs", Logs);
GlobalSetting = new SettingManager();
GlobalSetting.LoadConfig(CONFIG_FILE);
GlobalSave.Handle("Settings", GlobalSetting);
Application.EnableVisualStyles();
Application.ApplicationExit += Application_ApplicationExit;
Application.SetUnhandledExceptionMode(UnhandledExceptionMode.CatchException);
AppDomain.CurrentDomain.UnhandledException += CurrentDomain_UnhandledException;
Application.ThreadException += Application_ThreadException;
Application.SetCompatibleTextRenderingDefault(false);
ScreenPortBase = (int)GlobalSetting.Get("ScreenPortBase").Value;
MonkeyPortBase = (int)GlobalSetting.Get("ManipulatePortBase").Value;
// 全局错误处理器
Events.Register("on_exception", new GlobalEventHandler((_sender, _name, _param) =>
{
var ex = _param as Exception;
checkExcetion(ex);
}));
Repository.Temp["screen"] = new Hashtable();
for (var i = 0; i < 3000; i++)
{
Repository.Temp[ScreenPortBase + i] = true;
Repository.Temp[MonkeyPortBase + i] = true;
Repository.Temp[LocationBase + i] = true;
}
var mymainForm=new MainForm();
mainFrm = mymainForm;
Application.Run(mymainForm);
}
private static void CurrentDomain_UnhandledException(object sender, UnhandledExceptionEventArgs e)
{
var ex = e.ExceptionObject;
File.AppendAllText(varDir + @"\err.log", ex.ToString(), Encoding.UTF8);
}
private static void RPCServer_DataArrived(System.Net.Sockets.Socket client, object ext)
{
Debug.WriteLine(ext as string);
}
static void Init()
{
}
/// <summary>
/// 主线程代理执行
/// </summary>
/// <param name="func"></param>
public static void Invoke(ThreadStart func)
{
mainFrm.Invoke(func);
}
private static void Application_ApplicationExit(object sender, EventArgs e)
{
// UAC.Offline();
SaveStorages();
}
public static void LoadDefaultStorage()
{
if (System.IO.File.Exists(DefaultStorage))
{
GlobalSave.LoadStorage(DefaultStorage);
}
StorageInited = true;
}
public static void SaveStorages()
{
if (StorageInited)
{
GlobalSave.SaveStorage(DefaultStorage);
Log("saved to " + DefaultStorage + ".");
}
}
static void checkExcetion(Exception e)
{
if (e.GetType().Name.ToLower().Contains("adb"))
{
Logs.WriteLog("ADB服务器崩溃...正在重启中...", e.ToString(), Core.LogLevel.Fatal);
Events.Raise(null, "adb_dead", e);
AdbServer.Instance.RestartServer();
// new Thread(() => StartAdbMonitor()) { IsBackground = true }.Start();
}
if (e.InnerException != null)
{
checkExcetion(e.InnerException);
}
Logs.WriteLog("逻辑错误", e.ToString(), Core.LogLevel.Exception);
}
public static void SearchScript()
{
var noConfigfiles = Directory.GetFiles(varDir + @"\script\", "*.lua", SearchOption.TopDirectoryOnly);
foreach (var f in noConfigfiles)
{
var info = new FileInfo(f);
var key = Guid.NewGuid().ToString();
Scripts.Add(key, new Script()
{
FileName = info.Name,
DisplayName = info.Name.Replace(info.Extension, ""),
FullPath = info.FullName,
Content = File.ReadAllText(info.FullName, Encoding.Default)
});
}
var configFiles = Directory.GetFiles(varDir + @"\script\", "*.lua", SearchOption.AllDirectories);
foreach (var f in configFiles)
{
// 已经读过了
if (noConfigfiles.Contains(f)) continue;
var info = new FileInfo(f);
var conf = info.Directory + @"\config.json";
if (!File.Exists(conf))
{
// 没有配置文件
var key = Guid.NewGuid().ToString();
Scripts.Add(key, new Script()
{
FileName = info.Name,
DisplayName = info.Name.Replace(info.Extension, ""),
FullPath = info.FullName,
Content = File.ReadAllText(info.FullName, Encoding.Default)
});
continue;
}
var script = new Script()
{
FileName = info.Name,
FullPath = info.FullName,
Content = File.ReadAllText(info.FullName, Encoding.Default)
};
// 解析配置
script.ParseConfig(conf);
Program.Scripts.Add(Guid.NewGuid().ToString(), script);
}
}
public static void Log(string msg)
{
Debug.WriteLine($"[{DateTime.Now}] {msg}");
}
private static void Application_ThreadException(object sender, ThreadExceptionEventArgs e)
{
Logs.WriteLog("FATAL ERROR", e.ToString(), Core.LogLevel.Fatal);
}
public static void StartAdbMonitor()
{
//AdbServer adbServer = new AdbServer();
var monitor = new DeviceMonitor(new AdbSocket(new System.Net.IPEndPoint(System.Net.IPAddress.Loopback, AdbClient.AdbServerPort)));
monitor.DeviceConnected += Monitor_DeviceConnected;
monitor.DeviceDisconnected += Monitor_DeviceDisconnected;
monitor.DeviceChanged += Monitor_DeviceChanged;
monitor.Start();
}
public static void StartMyAdbMonitor()
{
//AdbServer adbServer = new AdbServer();
while(!isExist)
{
List<DeviceData> devList = AdbDeviceManager.getDevices();
HashSet<string> devset = new HashSet<string>();
if(DeviceManager.mIsFirstScan)
{
DeviceManager.mIsFirstScan = false;
foreach(DeviceData devData in devList)
{
if(isExist)
{
return;
}
DeviceManager.addOnlineDevice(devData.Serial, devData);
DeviceDataEventArgs args = new DeviceDataEventArgs(devData);
Monitor_DeviceChanged(null, args);
}
}
else
{
foreach (DeviceData devData in devList)
{
if (isExist)
{
return;
}
devset.Add(devData.Serial);
DeviceData mydevData = DeviceManager.getDeviceData(devData.Serial);
if (mydevData == null)
{
//说明没有缓存,当成是设备在线
DeviceManager.addOnlineDevice(devData.Serial, devData);
DeviceDataEventArgs args = new DeviceDataEventArgs(devData);
Monitor_DeviceConnected(null, args);
}
}
HashSet<string> cacheDevIds = DeviceManager.getOnlieDeviceIds();
foreach(string sn in cacheDevIds)
{
if (isExist)
{
return;
}
if (!devset.Contains(sn))
{
//不包含,说明设备离线了
DeviceManager.removeDevice(sn);
DeviceData devData = new DeviceData();
devData.Serial = sn;
DeviceDataEventArgs args = new DeviceDataEventArgs(devData);
Monitor_DeviceDisconnected(null, args);
}
}
}
//每隔1秒扫描一次
Thread.Sleep(2 * 1000);
}
}
private static void Monitor_DeviceChanged(object sender, DeviceDataEventArgs e)
{
Events.Raise(sender, "dev_statuschange", e.Device);
}
public static int getFreePort(int Base)
{
for (var i = Base; i < Base + 3000; i++)
{
if ((bool)Repository.Temp[i])
{
Repository.Temp[i] = false;
return i;
}
}
return -1;
}
private static void Monitor_DeviceDisconnected(object sender, DeviceDataEventArgs e)
{
Events.Raise(sender, "adb_disconnect", e.Device);
}
private static void Monitor_DeviceConnected(object sender, DeviceDataEventArgs e)
{
Events.Raise(sender, "adb_connect", e.Device);
}
}
}
Loading...
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
C#
1
https://gitee.com/ZL007/PhoneControl.git
git@gitee.com:ZL007/PhoneControl.git
ZL007
PhoneControl
PhoneControl
master

搜索帮助

0d507c66 1850385 C8b1a773 1850385