home_controller.dart 16 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490
  1. import 'dart:async';
  2. import 'dart:io';
  3. import 'package:dart_json_mapper/dart_json_mapper.dart';
  4. import 'package:get/get.dart';
  5. import 'package:naiyouwl/app/common/constants.dart';
  6. import 'package:naiyouwl/app/const/const.dart';
  7. import 'package:naiyouwl/app/controller/GlobalController.dart';
  8. import 'package:naiyouwl/app/controller/controllers.dart';
  9. import 'package:naiyouwl/app/utils/shell.dart';
  10. import 'package:naiyouwl/app/utils/utils.dart';
  11. import 'package:url_launcher/url_launcher.dart';
  12. import '../../../common/LogHelper.dart';
  13. import '../../../common/SharedPreferencesUtil.dart';
  14. import '../../../component/connection_status.dart';
  15. import '../../../data/model/LocalUser.dart';
  16. import '../../../data/model/NodeMode.dart';
  17. import '../../../data/model/SysConfig.dart';
  18. import '../../../data/model/UserMode.dart';
  19. import '../../../network/api_service.dart';
  20. import '../../../routes/app_pages.dart';
  21. import 'package:path/path.dart' as path;
  22. enum ImageType {
  23. CUSTOMER,
  24. PROMOTION,
  25. TUTORIAL,
  26. RENEWAL,
  27. }
  28. class HomeController extends GetxController {
  29. //TODO: Implement HomeController
  30. var isLoading = false.obs;
  31. var sysConfig = SysConfig().obs;
  32. var localUsers = LocalUser().obs;
  33. var userMode = User().obs;
  34. var UsersysConfig = SysConfig().obs;
  35. var serviceStuatus = false.obs;
  36. var coreStuatus = false.obs;
  37. var connectStatus = Rx<ConnectionStatus>(ConnectionStatus.disconnected);
  38. var nodeModes = <NodeMode>[];
  39. var isConnect = false.obs;
  40. var errAdminMsg = false.obs;
  41. var errAdmin = ''.obs;
  42. var isInit = false.obs;
  43. var isServiceInstall = false.obs;
  44. bool get isRunning => connectStatus.value == ConnectionStatus.stopped && controllers.global.allowStatusUpdate;
  45. late final GlobalController globalController = controllers.global;
  46. StreamSubscription<RunningState>? _statusSubscription;
  47. final Map<ImageType, String> imageMap = {
  48. ImageType.CUSTOMER: "assets/images/main/customer.png",
  49. ImageType.PROMOTION: "assets/images/main/promotion.png",
  50. ImageType.TUTORIAL: "assets/images/main/tutorial.png",
  51. ImageType.RENEWAL: "assets/images/main/renewal.png",
  52. };
  53. void onImageTap(ImageType type) async {
  54. if(type == ImageType.CUSTOMER){
  55. await launchUrl(Uri.parse(UsersysConfig.value.userTicket ?? ""));
  56. } else if (type == ImageType.PROMOTION){
  57. await launchUrl(Uri.parse(UsersysConfig.value.affUrl ?? ""));
  58. } else if (type == ImageType.TUTORIAL){
  59. await launchUrl(Uri.parse(UsersysConfig.value.userDownload ?? ""));
  60. } else if (type == ImageType.RENEWAL){
  61. await launchUrl(Uri.parse(UsersysConfig.value.userBuy ?? ""));
  62. }
  63. LogHelper().d("${imageMap[type]} tapped as ${type.toString().split('.').last}");
  64. }
  65. void updateStatus(ConnectionStatus newStatus) {
  66. connectStatus.value = newStatus;
  67. }
  68. void _handleStateChange([dynamic _]) async {
  69. final coreStatus = controllers.service.coreStatus.value;
  70. final isVisible = controllers.window.isVisible.value;
  71. final serviceStatus = controllers.service.serviceStatus.value;
  72. // if(serviceStatus != RunningState.running){
  73. // updateStatus(ConnectionStatus.disconnected);
  74. // return;
  75. // }
  76. if (coreStatus == RunningState.running && isVisible && controllers.global.allowStatusUpdate) {
  77. // if(connectStatus.value == ConnectionStatus.connecting){
  78. // controllers.global.updateMsg("连接完成...");
  79. // }
  80. }
  81. }
  82. Future<void> handleButtonClick() async {
  83. if(userMode.value.enable != 1){
  84. controllers.global.handleApiError("账号禁用,刷新账号状态,或者重启软件");
  85. return;
  86. }
  87. if(connectStatus.value == ConnectionStatus.connecting ){
  88. return;
  89. }
  90. // 如果当前状态是已连接或正在连接,则停止服务
  91. if (connectStatus.value == ConnectionStatus.stopped) {
  92. controllers.global.allowStatusUpdate = false;
  93. await controllers.config.setBreakConnections(true);
  94. // // 停止服务
  95. if(Platform.isWindows)
  96. {
  97. await controllers.service.stopClash();
  98. }
  99. else
  100. {
  101. await controllers.service.fetchStartInit();
  102. }
  103. await controllers.global.systemProxySwitch(false);
  104. updateStatus(ConnectionStatus.disconnected);
  105. return;
  106. } else {
  107. controllers.config.config.value.selected = 'proxy.yaml';
  108. controllers.global.updateMsg("开始连接...");
  109. await controllers.config.setBreakConnections(true);
  110. controllers.global.allowStatusUpdate = true;
  111. var routeModes = controllers.global.routeModesSelect.value;
  112. if(routeModes == "tun"){
  113. controllers.global.updateMsg("正在启动网卡模式...");
  114. controllers.config.clashCoreTunEnable.value = true;
  115. controllers.global.startTunMode();
  116. if(controllers.service.serviceMode.value == false){
  117. if(Platform.isWindows)
  118. {
  119. if(!await isRunningAsAdmin()){
  120. controllers.global.updateMsg("网卡模式需要管理模式运行...");
  121. return;
  122. }
  123. } else {
  124. if(controllers.service.serviceMode.value == false){
  125. controllers.global.updateMsg("需要开启服务,才能使用...");
  126. return;
  127. }
  128. }
  129. //await controllers.service.serviceModeSwitch(true);
  130. serviceStuatus.value = true;
  131. }
  132. final coreStatus = controllers.service.coreStatus.value;
  133. final serverStatus = controllers.service.serviceStatus.value;
  134. if (coreStatus == RunningState.running){
  135. await controllers.service.reloadClashCore();
  136. }
  137. else{
  138. if(serverStatus == RunningState.running){
  139. await controllers.service.reloadClashCore();
  140. }
  141. }
  142. } else {
  143. controllers.global.updateMsg("正在启动系统模式...");
  144. controllers.config.clashCoreTunEnable.value = false;
  145. controllers.global.startSysMode();
  146. final coreStatus = controllers.service.coreStatus.value;
  147. final serverStatus = controllers.service.serviceStatus.value;
  148. if(Platform.isWindows){
  149. if (coreStatus == RunningState.running){
  150. controllers.global.updateMsg("正在重启内核...");
  151. await controllers.service.reloadClashCore();
  152. }
  153. }
  154. else{
  155. controllers.global.updateMsg("正在启动内核...");
  156. if(serverStatus == RunningState.running){
  157. await controllers.service.reloadClashCore();
  158. }
  159. }
  160. }
  161. updateStatus(ConnectionStatus.connecting);
  162. Future.delayed(const Duration(seconds: 5), () async {
  163. updateStatus(ConnectionStatus.stopped);
  164. await controllers.global.updateNode();
  165. //
  166. await controllers.tray.updateTray();
  167. if(routeModes == "tun"){
  168. if(Platform.isMacOS){
  169. await controllers.service.fetchSetDnsProxy();
  170. }
  171. controllers.global.updateMsg("启动tun模式完成...");
  172. }
  173. else{
  174. await controllers.global.systemProxySwitch(true);
  175. controllers.global.updateMsg("设置系统代理完成...");
  176. }
  177. isConnect.value = true;
  178. });
  179. }
  180. }
  181. void SetSysProxy() async{
  182. }
  183. Future<void> stopVpn() async {
  184. controllers.global.updateMsg("正在停止...");
  185. await controllers.global.systemProxySwitch(false);
  186. await controllers.config.setBreakConnections(true);
  187. await controllers.tray.updateTray();
  188. // // 停止服务
  189. await controllers.service.stopClash();
  190. //controllers.global.updateMsg("正在停止....");
  191. Future.delayed(const Duration(seconds: 1), () async {
  192. controllers.global.allowStatusUpdate = false;
  193. isConnect.value = false;
  194. updateStatus(ConnectionStatus.disconnected);
  195. controllers.global.updateMsg("停止完成,点击立即加速");
  196. });
  197. }
  198. Future<void> fetchAuthUser() async {
  199. try {
  200. if(Platform.isWindows)
  201. {
  202. if (!controllers.service.coreIsRuning){
  203. controllers.global.updateMsg("内核没有启动...");
  204. return;
  205. }
  206. }
  207. if(Platform.isMacOS){
  208. if(!controllers.service.serviceIsRuning)
  209. {
  210. controllers.global.updateMsg("服务内核没有启动...");
  211. return;
  212. }
  213. }
  214. if(controllers.global.routeModesSelect.value == "tun")
  215. {
  216. if(Platform.isWindows)
  217. {
  218. if(!await isRunningAsAdmin()){
  219. controllers.global.updateMsg("网卡模式需要管理模式运行...");
  220. errAdminMsg.value = true;
  221. errAdmin.value = "网卡模式需要用户管理员模式去运行,点击确定管理员模式重启如果无法重启,手动重启。";
  222. return;
  223. }
  224. } else {
  225. if(controllers.service.serviceMode.value == false){
  226. controllers.global.updateMsg("需要开启服务,才能使用,记得卸载服务才能卸载软件...");
  227. return;
  228. }
  229. }
  230. }
  231. if(Platform.isMacOS){
  232. if(!controllers.service.serviceMode.value)
  233. {
  234. if(!await controllers.global.onIsRunAdmin()){
  235. errAdminMsg.value = true;
  236. errAdmin.value = "当前用户没有管理员权限。系统代理,可能无法使用,可以安装服务来解决这个问题,或者开启用户的管理员许可";
  237. return;
  238. }
  239. }
  240. }
  241. if (controllers.global.allowStatusUpdate && connectStatus.value == ConnectionStatus.stopped || connectStatus.value == ConnectionStatus.connecting) {
  242. controllers.global.updateMsg("当前连接状态未停止,不要多次启动...");
  243. return;
  244. }
  245. if(isConnect.value == true){
  246. controllers.global.updateMsg("当前连接状态未停止,不要多次启动...");
  247. return;
  248. }
  249. controllers.global.updateMsg("正在身份验证...");
  250. final ret = await ApiService().fetchAuthUser(KAuthUser);
  251. if(controllers.global.selectMageNode.value == false){
  252. controllers.global.selectedNode.value = ret;
  253. controllers.global.selectNode(ret);
  254. controllers.global.updateMsg("获取自动节点完成...");
  255. }
  256. await handleButtonClick();
  257. } catch (e) {
  258. controllers.global.handleApiError(e);
  259. } finally {
  260. }
  261. }
  262. Future<void> fetchSysConfig() async {
  263. try {
  264. String? data = await SharedPreferencesUtil().getString("sysconfig");
  265. if(data != null){
  266. sysConfig.value =JsonMapper.deserialize<SysConfig>(data)!;
  267. }
  268. } catch (e) {
  269. controllers.global.handleApiError(e);
  270. } finally {
  271. }
  272. }
  273. Future<void> fetchUserinfo() async {
  274. try {
  275. isLoading.value = true;
  276. userMode.value = await ApiService().userinfo("/api/client/v4/userinfo");
  277. await globalController.fetchNodes();
  278. await fetchlUserUrl(localUsers.value.email ?? "",localUsers.value.password ?? "");
  279. //await controllers.global.makeProxy();
  280. //await controllers.global.initService();
  281. // //生成配置
  282. // await controllers.global.makeProxy();
  283. // // 开始重启服务
  284. // await controllers.service.reloadClashCore();
  285. } catch (e) {
  286. controllers.global.handleApiError(e);
  287. } finally {
  288. isLoading.value = false;
  289. }
  290. }
  291. Future<void> fetchNode() async {
  292. try {
  293. isLoading.value = true;
  294. await globalController.fetchNodes();
  295. } catch (e) {
  296. controllers.global.handleApiError(e);
  297. } finally {
  298. isLoading.value = false;
  299. }
  300. }
  301. Future<void> outlogin() async {
  302. if(connectStatus.value == ConnectionStatus.connecting || connectStatus.value == ConnectionStatus.stopped){
  303. controllers.global.handleApiError("当前连接状态无法退出(先停止加速)");
  304. return ;
  305. }
  306. await SharedPreferencesUtil().delete("token");
  307. try {
  308. //isLoading.value = true;
  309. await ApiService().fetchLogout(KLogout);
  310. } catch (e) {
  311. //errorMsg.value = e.toString();
  312. } finally {
  313. //isLoading.value = false;
  314. }
  315. Get.offNamed(Routes.LOGIN);
  316. }
  317. //await SharedPreferencesUtil().setObject("localUser", userModes.toJson());
  318. Future<void> fetchlUserUrl(String username,String password) async {
  319. try {
  320. isLoading.value = true;
  321. UsersysConfig.value = await ApiService().fetchUserSysConfig(kSysConfig,{"email":username,"password":password});
  322. } catch (e) {
  323. controllers.global.handleApiError(e);
  324. } finally {
  325. isLoading.value = false;
  326. }
  327. }
  328. Future<void> fetchLocalUser() async {
  329. try {
  330. String? userdata = await SharedPreferencesUtil().getString("localUser");
  331. if(userdata != null){
  332. localUsers.value = JsonMapper.deserialize<LocalUser>(userdata)!;
  333. }
  334. await fetchSysConfig();
  335. } catch (e) {
  336. controllers.global.handleApiError(e);
  337. } finally {
  338. }
  339. }
  340. Future<void> installService() async{
  341. if(serviceStuatus.value == false){
  342. controllers.global.updateMsg("正在安装服务");
  343. await controllers.service.serviceModeSwitch(true);
  344. serviceStuatus.value = true;
  345. }
  346. }
  347. Future<void> UninstallService() async{
  348. if(serviceStuatus.value){
  349. controllers.global.updateMsg("正在卸载服务");
  350. await controllers.service.serviceModeSwitch(false);
  351. serviceStuatus.value = false;
  352. }
  353. }
  354. Future<void> coreRestart() async{
  355. await controllers.service.reloadClashCore();
  356. }
  357. Future<void> coreInit() async{
  358. controllers.global.updateMsg("正在初始化内核");
  359. isInit.value = true;
  360. //controllers.protocol.initProtocol();
  361. await controllers.config.portDetection();
  362. // init clash config
  363. // init config
  364. await controllers.config.initConfig();
  365. await controllers.service.initConfig();
  366. await controllers.global.platformState();
  367. //判断clash 程序是否在启动中,如果是可以先停止
  368. if (Platform.isWindows){
  369. await controllers.global.onIsProcessRunning(path.basename(Files.assetsCCore.path));
  370. }
  371. if(Platform.isWindows){
  372. await controllers.service.initClashCoreConfig();
  373. if (controllers.service.coreStatus.value != RunningState.running) return;
  374. await controllers.core.updateVersion();
  375. final hello = await controllers.core.fetchHello();
  376. print(hello);
  377. } else {
  378. await controllers.service.startService();
  379. if (controllers.service.serviceStatus.value != RunningState.running) return;
  380. if(Platform.isMacOS){
  381. if(!await controllers.global.onIsRunAdmin()){
  382. isServiceInstall.value = true;
  383. }
  384. }
  385. }
  386. controllers.global.updateMsg("初始化内核完成");
  387. isInit.value = false;
  388. }
  389. void init(){
  390. Future.delayed(Duration.zero, () async {
  391. await fetchSysConfig();
  392. await fetchLocalUser();
  393. await fetchUserinfo();
  394. //controllers.global.initService();
  395. await coreInit();
  396. });
  397. }
  398. final count = 0.obs;
  399. @override
  400. void onInit() {
  401. super.onInit();
  402. _statusSubscription = controllers.service.coreStatus.stream.listen(_handleStateChange);
  403. init();
  404. }
  405. @override
  406. void onReady() {
  407. super.onReady();
  408. }
  409. @override
  410. void onClose() {
  411. _statusSubscription?.cancel();
  412. super.onClose();
  413. }
  414. bool GetEnable() => userMode.value.enable == 1;
  415. String GetUserName() => localUsers.value.email.toString();
  416. String GetExpiredAt() => "到期时间:${userMode.value.expiredAt}";
  417. String GetTraffic() => "用户流量:${userMode.value.unusedTraffic}";
  418. String GetNode() => controllers.global.selectedNode.value?.name ?? "未选择节点";
  419. String getHttp() => "http 127.0.0.1:${controllers.config.mixedPort.value}";
  420. String getSocket() => "sock 127.0.0.1:${controllers.config.mixedPort.value}";
  421. String getSerivce() => "${controllers.config.servicePort.value}";
  422. void RouteNode() => Get.toNamed(Routes.NODE);
  423. }