gandartComposite.js 57 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000
  1. const config = {
  2. "PATH_IMG_V2_PRO": "https://cdn-image.gandart.com/",
  3. "RUN_TYPE": 1,
  4. "BOTTOM_LOAD_MORE_THROTTLE": 100,
  5. "BASE_API": "https://api.gandart.com/base",
  6. "RESALE_API": "https://api.gandart.com/market",
  7. "RESALE_API_V2": "https://api2.gandart.com/market/api/v2",
  8. "RESALE_API_V3": "https://api2.gandart.com/market/api/v3",
  9. "SALE_API": "https://api.gandart.com/read/api",
  10. "ORDER_API": "https://api.gandart.com",
  11. "WALLET_API": "https://api.gandart.com/api",
  12. "HXT_API": "https://api.gandart.com/wallet",
  13. "PATH_IMG_V2": "https://cdn-image.gandart.com/",
  14. "SAND_RECHARGE_ACTION": "https://cap.sandpay.com.cn/v4/front-electrans/ceas.elec.trans.quick.deposit.apply",
  15. "GAME_ElF_API": "https://elf.pentajam.cn/api",
  16. "GAME_ELF_URL": "https://elf.pentajam.cn",
  17. "CORECENTER_URL": "https://api.gandart.com/corecenter"
  18. };
  19. const lk = new ToolKit(`光予合成手`, `GandartCompositor`, `gandartComposite.js`);
  20. const GandartConstKey = {
  21. // -----通用助手相关的-----
  22. Token: 'lkGandartToken',
  23. UserData: 'lkGandartUserData',
  24. PrivCollectionBrief: 'lkGandartPrivCollectionBrief',
  25. PrivCollectionDetail: 'lkGandartPrivCollectionDetail',
  26. CollectionName: 'lkGandartCollectionName',
  27. CastingId: 'lkGandartCastingId',
  28. LimitPrice: 'lkGandartLimitPrice',
  29. TransactionRecordId: 'lkGandartTransactionRecordId',
  30. CollectionCateLst: 'lkGandartCollectionCateLst',
  31. FloatPriceIntaval: 'lkGandartFloatPriceIntaval',
  32. IsCollectionWatchLocked: 'lkIsGandartCollectionWatchLocked',
  33. PrivWalletListInUse: 'lkGandartPrivWalletListInUse',
  34. IsCollectionMaxNumLimit: 'lkGandartIsCollectionMaxNumLimit',
  35. CollectionLockMaxNum: 'lkGandartCollectionLockMaxNum',
  36. // -----合成脚本增加的-----
  37. CompositeFuncEnalbleList: 'lkGandartCompositeFuncEnalbleList',
  38. CompositeTaskList0: 'lkGandartCompositeTaskList0',
  39. CompositeTaskList1: 'lkGandartCompositeTaskList1',
  40. CompositeTaskList2: 'lkGandartCompositeTaskList2',
  41. CompositeTaskId: 'lkGandartCompositeTaskId',
  42. CompositeTaskSearchEnable: 'lkIsCompositeTaskSearchEnable',
  43. CompostieTaskSearchKey: 'lkGandartCompostieTaskSearchKey',
  44. CompositeTaskNameDisplay: 'lkGandartCompositeTaskNameDisplay',
  45. CompositeCountArray: 'lkGandartCompositeCountArray',
  46. CompositeTaskMateList: 'lkGandartCompositeTaskMateList',
  47. CompositeTaskFinalList: 'lkGandartCompositeTaskFinalList',
  48. CompositeTaskListStatus: 'lkGandartCompositeTaskListStatus',
  49. CompositeTaskListCache: 'lkIsCompositeTaskListCache',
  50. CompositeMaterialCache: 'lkIsCompositeMaterialCache',
  51. CompositeTaskMode: 'lkGandartCompositeTaskMode',
  52. };
  53. let gandartToken = lk.getVal(GandartConstKey.Token, '');
  54. let gandartUserAgent = `Mozilla/5.0 (iPhone; CPU iPhone OS 16_3_1 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/16.3 Mobile/15E148 Safari/604.1`;
  55. const GCommonGandartHeads = {
  56. 'Accept': `application/json, text/plain, */*`,
  57. 'Origin': `https://www.gandart.com`,
  58. 'Accept-Encoding': `gzip, deflate, br`,
  59. 'Content-Type': `application/x-www-form-urlencoded;charset=UTF-8`,
  60. 'Connection': `keep-alive`,
  61. 'Host': `api2.gandart.com`,
  62. 'User-Agent': gandartUserAgent,
  63. 'Referer': `https://www.gandart.com/`,
  64. 'Accept-Language': `zh-CN,zh-Hans;q=0.9`,
  65. 'token': gandartToken
  66. };
  67. let gAllMaterialDetails = null;
  68. const gUsedMaterialDetails = {};
  69. let gFuncEnables = lk.getVal(GandartConstKey.CompositeFuncEnalbleList);
  70. if (!lk.isEmpty(gFuncEnables)) {
  71. gFuncEnables = gFuncEnables.split(',');
  72. } else {
  73. gFuncEnables = [];
  74. }
  75. if (!lk.isExecComm) {
  76. if (!lk.isRequest()) {
  77. all();
  78. }
  79. }
  80. async function all() {
  81. let taskLst = [];
  82. if (isGetTaskListEnable()) {
  83. let status = getCompositeTaskListStatus();
  84. let tmpLst = [];
  85. switch (status) {
  86. case 0:
  87. tmpLst = await checkGetCompositeTaskList(status);
  88. if (tmpLst) {
  89. taskLst = taskLst.concat(tmpLst);
  90. }
  91. break;
  92. case 1:
  93. tmpLst = await checkGetCompositeTaskList(status);
  94. if (tmpLst) {
  95. taskLst = taskLst.concat(tmpLst);
  96. }
  97. break;
  98. case 2:
  99. tmpLst = await checkGetCompositeTaskList(status);
  100. if (tmpLst) {
  101. taskLst = taskLst.concat(tmpLst);
  102. }
  103. break;
  104. case 3:
  105. tmpLst = await checkGetCompositeTaskList(1);
  106. if (tmpLst) {
  107. taskLst = taskLst.concat(tmpLst);
  108. }
  109. tmpLst = await checkGetCompositeTaskList(0);
  110. if (tmpLst) {
  111. taskLst = taskLst.concat(tmpLst);
  112. }
  113. break;
  114. default:
  115. break;
  116. }
  117. }
  118. if (taskLst.length == 0) {
  119. lk.log('合成任务列表为空');
  120. }
  121. if (isCaclMateListEnable()) {
  122. let taskId = getWillCompositeTaskId();
  123. if (taskId > 0) {
  124. let found = false;
  125. for (let i = 0; i < taskLst.length; i++) {
  126. let taskInfo = taskLst[i];
  127. if (taskInfo.id == taskId) {
  128. found = true;
  129. lk.setVal(GandartConstKey.CompositeTaskNameDisplay, taskInfo.compositeTaskName);
  130. await tryToExecCompositeTask(taskInfo.id, taskInfo);
  131. break;
  132. }
  133. }
  134. if (!found) {
  135. lk.log(`当前任务列表找不到指定任务[${taskId}]`);
  136. await checkTrySearchToCompositeTask(taskLst);
  137. }
  138. } else {
  139. lk.log('没有设置指定任务ID,检查是否需进行检索合成');
  140. await checkTrySearchToCompositeTask(taskLst);
  141. }
  142. }
  143. lk.msg('');
  144. lk.done();
  145. }
  146. async function checkTrySearchToCompositeTask(taskLst) {
  147. if (!isTaskNameSearchMode()) {
  148. return;
  149. }
  150. lk.log('开始尝试通过名称来检索任务进行合成');
  151. let keyName = lk.getVal(GandartConstKey.CompostieTaskSearchKey);
  152. if (lk.isEmpty(keyName)) {
  153. lk.log(`当前检索关键字为空`);
  154. return;
  155. }
  156. let found = false;
  157. for (let i = 0; i < taskLst.length; i++) {
  158. let taskInfo = taskLst[i];
  159. let taskName = taskInfo.compositeTaskName;
  160. if (taskName.indexOf(keyName) > -1) {
  161. found = true;
  162. lk.log(`检索到相符的任务[${taskName}#${taskInfo.id}]`);
  163. lk.setVal(GandartConstKey.CompositeTaskNameDisplay, taskName);
  164. await tryToExecCompositeTask(taskInfo.id, taskInfo);
  165. }
  166. }
  167. if (!found) {
  168. lk.log(`当前关键字[${keyName}]没有检索到相关的任务`);
  169. }
  170. }
  171. function getCompositeTaskListStatus() {
  172. let val = lk.getVal(GandartConstKey.CompositeTaskListStatus);
  173. if (lk.isEmpty(val)) {
  174. val = 1;
  175. } else {
  176. val = Number(val);
  177. }
  178. return val;
  179. }
  180. function getCompositeTaskMode() {
  181. let val = lk.getVal(GandartConstKey.CompositeTaskMode);
  182. if (lk.isEmpty(val)) {
  183. val = 0;
  184. } else {
  185. val = Number(val);
  186. }
  187. return val;
  188. }
  189. function isGetTaskListEnable() {
  190. if (gFuncEnables.indexOf('TaskList') > -1) {
  191. return true;
  192. }
  193. return false;
  194. }
  195. function isCaclMateListEnable() {
  196. if (gFuncEnables.indexOf('MateList') > -1) {
  197. return true;
  198. }
  199. return false;
  200. }
  201. function isGenFinalLisstEnable() {
  202. if (gFuncEnables.indexOf('DecidedList') > -1) {
  203. return true;
  204. }
  205. return false;
  206. }
  207. function isExecFinalComposite() {
  208. if (gFuncEnables.indexOf('ExecComposite') > -1) {
  209. return true;
  210. }
  211. return false;
  212. }
  213. function getWillCompositeTaskId() {
  214. let val = lk.getVal(GandartConstKey.CompositeTaskId);
  215. if (lk.isEmpty(val)) {
  216. val = 0;
  217. } else {
  218. val = Number(val);
  219. }
  220. return val;
  221. }
  222. function isTaskNameSearchMode() {
  223. let enabled = lk.getVal(GandartConstKey.CompositeTaskSearchEnable);
  224. if (!lk.isEmpty(enabled)) {
  225. enabled = JSON.parse(enabled);
  226. } else {
  227. enabled = true;
  228. }
  229. return enabled;
  230. }
  231. function printMaterialGroupsInfo(materialGroups) {
  232. let detailStr = '组合详情如下:\n';
  233. for (let i = 0; i < materialGroups.length; i++) {
  234. let group = materialGroups[i];
  235. let needStr = '';
  236. for (let j = 0; j < group.length; j++) {
  237. needStr += `${group[j].collectionName}x${group[j].number},`
  238. }
  239. detailStr += `组合${i}:${needStr.substring(0, needStr.length - 1)}\n`;
  240. }
  241. lk.log(detailStr);
  242. }
  243. async function checkGetMaterialDetails(gUsedMaterialDetails, materialDict) {
  244. let useCache = lk.getVal(GandartConstKey.CompositeMaterialCache);
  245. if (!lk.isEmpty(useCache)) {
  246. useCache = JSON.parse(useCache);
  247. } else {
  248. useCache = false;
  249. }
  250. lk.log(`合成材料列表本地缓存:${useCache}`);
  251. let isReqServerData = false;
  252. if (useCache) {
  253. let jsonStr = lk.getVal(GandartConstKey.PrivCollectionDetail);
  254. if (!lk.isEmpty(jsonStr)) {
  255. try {
  256. let data = JSON.parse(jsonStr);
  257. gAllMaterialDetails = data;
  258. for (let k in materialDict) {
  259. gUsedMaterialDetails[k] = data[k];
  260. }
  261. } catch (error) {
  262. lk.logErr(error);
  263. isReqServerData = true;
  264. }
  265. } else {
  266. isReqServerData = true;
  267. }
  268. } else {
  269. isReqServerData = true;
  270. }
  271. if (isReqServerData) {
  272. for (let k in materialDict) {
  273. let mInfo = materialDict[k];
  274. gUsedMaterialDetails[k] = await getDetailByCasting(mInfo.castingId, mInfo.collectionName);
  275. }
  276. }
  277. return gUsedMaterialDetails;
  278. }
  279. function calcBatComposite() {
  280. }
  281. async function tryToExecCompositeTask(taskId, taskInfo = {}) {
  282. if (getCompositeTaskMode() == 1) {
  283. lk.log('开始极速模式执行合成任务');
  284. let data = getCompositeTaskFinalList();
  285. if (data) {
  286. let taskInfo = data.taskInfo;
  287. let finalGroups = data.finalGroups;
  288. if (finalGroups.length == 0) {
  289. lk.log('暂无可行的合成组合,请检查');
  290. lk.appendNotifyInfo('⚠️暂无可行的合成组合');
  291. return;
  292. }
  293. lk.log(`最终选择可执行合成数:${finalGroups.length}`);
  294. let tmpJsonStr = JSON.stringify(finalGroups, null, 2);
  295. lk.log(`详情如下:\n${tmpJsonStr}`);
  296. if (isExecFinalComposite()) {
  297. await doExecFinalComposite(taskInfo.id, taskInfo, finalGroups);
  298. }
  299. }
  300. return;
  301. }
  302. lk.log('开始普通模式执行合成任务');
  303. let materialSelLst = await getCompositeMaterial(taskId, taskInfo);
  304. if (materialSelLst && materialSelLst.length > 0) {
  305. let ret = calcCompositeGroups(materialSelLst);
  306. // 材料排列组合
  307. let materialGroups = ret[0];
  308. lk.log(`排列组合组数:${materialGroups.length}`);
  309. // printMaterialGroupsInfo(materialGroups);
  310. let materialDict = ret[1];
  311. // 获取用户材料拥有详情
  312. await checkGetMaterialDetails(gUsedMaterialDetails, materialDict);
  313. // 找出可行的合成搭配
  314. let validCompositeGroups = findValidGroupMaterialGroups(materialGroups, gUsedMaterialDetails);
  315. setCompositeTaskMateListForDisplay(validCompositeGroups);
  316. // printMaterialGroupsInfo(validCompositeGroups, '预估可行组合数');
  317. if (isGenFinalLisstEnable()) {
  318. let compositeCountDict = getCompositeCountDict();
  319. let finalGroups = [];
  320. for (let k in compositeCountDict) {
  321. let mGroup = validCompositeGroups[k];
  322. if (mGroup) {
  323. let arr = checkPickMaterialForComposite(mGroup, gUsedMaterialDetails, compositeCountDict[k]);
  324. finalGroups = finalGroups.concat(arr);
  325. }
  326. }
  327. lk.log(`最终选择可执行合成数:${finalGroups.length}`);
  328. let tmpJsonStr = JSON.stringify(finalGroups, null, 2);
  329. lk.log(`详情如下:\n${tmpJsonStr}`);
  330. if (isExecFinalComposite()) {
  331. if (finalGroups.length == 0) {
  332. lk.log('暂无可行的合成组合,请检查');
  333. // lk.appendNotifyInfo('⚠️暂无可行的合成组合');
  334. return;
  335. }
  336. await doExecFinalComposite(taskId, taskInfo, finalGroups);
  337. } else {
  338. setCompositeTaskFinalList(taskInfo, finalGroups);
  339. }
  340. } else {
  341. lk.execFail();
  342. lk.appendNotifyInfo('⚠️请设置光予合成任务ID');
  343. }
  344. }
  345. return;
  346. }
  347. function setCompositeTaskMateListForDisplay(validCompositeGroups) {
  348. lk.log(`预估可行组合数:${validCompositeGroups.length}`);
  349. let disText = '';
  350. for (let i = 0; i < validCompositeGroups.length; i++) {
  351. let group = validCompositeGroups[i];
  352. let rowText = `[${i}]`;
  353. for (let j = 0; j < group.length; j++) {
  354. let mInfo = group[j];
  355. rowText += `${mInfo.collectionName}x${mInfo.number},`;
  356. }
  357. disText += rowText.substring(0, rowText.length - 1) + '\n';
  358. }
  359. lk.log(disText);
  360. lk.setVal(GandartConstKey.CompositeTaskMateList, disText);
  361. }
  362. async function doExecFinalComposite(taskId, taskInfo, finalGroups) {
  363. let retOrderLst = [];
  364. let retWillDelLst = [];
  365. for (let i = 0; i < finalGroups.length; i++) {
  366. let idx = i;
  367. let ret = await confirmCompositeV2(taskId, taskInfo, finalGroups[i]);
  368. if (ret) {
  369. retWillDelLst.push(idx);
  370. retOrderLst.push(ret);
  371. }
  372. }
  373. if (retOrderLst.length > 0) {
  374. let successCnt = 0;
  375. let noStockCnt = 0;
  376. for (let i = 0; i < retOrderLst.length; i++) {
  377. const orderNum = retOrderLst[i];
  378. lk.log(`[${i}]单号:${orderNum}`);
  379. if (orderNum.indexOf('#') > -1) {
  380. successCnt += 1;
  381. } else if (orderNum.indexOf('!') > -1) {
  382. noStockCnt += 1;
  383. } else {
  384. successCnt += 1;
  385. await checkCompositeResult(orderNum);
  386. }
  387. }
  388. lk.log(`合成成功单数:${successCnt}`);
  389. lk.log(`库存不足单数:${noStockCnt}`);
  390. // 从高的序号删除
  391. let usedGroups = [];
  392. for (let i = retWillDelLst.length - 1; i >= 0; i--) {
  393. let idx = retWillDelLst[i];
  394. lk.log(`[${id}]编号订单删除`);
  395. usedGroups.push(finalGroups[idx]);
  396. finalGroups.splice(idx, 1);
  397. }
  398. let tmpJsonStr = JSON.stringify(finalGroups, null, 2);
  399. lk.log(`剩余未完成的组合如下:\n${tmpJsonStr}`);
  400. setCompositeTaskFinalList(taskInfo, finalGroups);
  401. refreshMaterialAfterComposite(usedGroups);
  402. } else {
  403. lk.log('合成成功单数:0');
  404. }
  405. }
  406. function setCompositeTaskFinalList(taskInfo, finalGroups) {
  407. let simpleInfo = {
  408. id: taskInfo.id,
  409. compositeLabel: taskInfo.compositeLabel,
  410. compositeTaskName: taskInfo.compositeTaskName,
  411. surplus: taskInfo.surplus,
  412. }
  413. let finalCacheData = {
  414. taskInfo: simpleInfo,
  415. finalGroups: finalGroups,
  416. };
  417. lk.setVal(GandartConstKey.CompositeTaskFinalList, JSON.stringify(finalCacheData, null, 2));
  418. }
  419. function refreshMaterialAfterComposite(usedGroups) {
  420. if (usedGroups.length == 0) {
  421. return;
  422. }
  423. if (!gAllMaterialDetails) {
  424. let jsonStr = lk.getVal(GandartConstKey.PrivCollectionDetail);
  425. if (!lk.isEmpty(jsonStr)) {
  426. try {
  427. let data = JSON.parse(jsonStr);
  428. gAllMaterialDetails = data;
  429. } catch (error) {
  430. lk.logErr(error);
  431. }
  432. for (let group of usedGroups) {
  433. for (let one of group) {
  434. deleteUsedMaterial(one.castingId, one.orderList);
  435. }
  436. }
  437. jsonStr = JSON.stringify(gAllMaterialDetails, null, 2);
  438. lk.setVal(GandartConstKey.PrivCollectionDetail, jsonStr);
  439. }
  440. }
  441. }
  442. function deleteUsedMaterial(castingId, recordIdLst) {
  443. let itemLst = gAllMaterialDetails[castingId];
  444. if (itemLst) {
  445. let remainLst = [];
  446. for (let i = 0; i < itemLst.length; i++) {
  447. if (recordIdLst.indexOf(itemLst[i].id) == -1) {
  448. remainLst.push(itemLst[i]);
  449. }
  450. }
  451. gAllMaterialDetails[castingId] = remainLst;
  452. }
  453. }
  454. function getCompositeTaskFinalList() {
  455. let data;
  456. let jsonStr = lk.getVal(GandartConstKey.CompositeTaskFinalList);
  457. if (!lk.isEmpty(jsonStr)) {
  458. data = JSON.parse(jsonStr);
  459. }
  460. return data;
  461. }
  462. function getCompositeCountDict() {
  463. let str = lk.getVal(GandartConstKey.CompositeCountArray, '0#1');
  464. let arr1 = str.split(',');
  465. let ret = {};
  466. for (let i = 0; i < arr1.length; i++) {
  467. let arr2 = arr1[i].split('#');
  468. let key = arr2[0];
  469. ret[key] = Number(arr2[1] || 1);
  470. }
  471. return ret;
  472. }
  473. function findValidGroupMaterialGroups(materialGroups, materialDetails) {
  474. let validGroups = [];
  475. for (let i = 0; i < materialGroups.length; i++) {
  476. let canCount = checkMaterialEnough(materialGroups[i], materialDetails);
  477. if (canCount > 0) {
  478. validGroups.push(materialGroups[i]);
  479. }
  480. }
  481. return validGroups;
  482. }
  483. function checkMaterialEnough(materialGroup, materialDetails) {
  484. let minCount = 99999;
  485. for (let i = 0; i < materialGroup.length; i++) {
  486. const materialObj = materialGroup[i];
  487. const castingId = materialObj.castingId;
  488. const ownLst = materialDetails[castingId];
  489. if (!ownLst) {
  490. minCount = 0;
  491. break;
  492. }
  493. if (ownLst.length >= materialObj.number) {
  494. let maxCount = Math.floor(ownLst.length / materialObj.number);
  495. if (maxCount < minCount) {
  496. minCount = maxCount;
  497. }
  498. } else {
  499. minCount = 0;
  500. break;
  501. }
  502. }
  503. if (minCount == 99999) {
  504. minCount = 0;
  505. }
  506. return minCount
  507. }
  508. function checkPickMaterialForComposite(materialGroup, materialDetails, wantCount) {
  509. let needNumDict = {};
  510. for (let i = 0; i < materialGroup.length; i++) {
  511. const materialObj = materialGroup[i];
  512. const castingId = materialObj.castingId;
  513. if (!needNumDict[castingId]) {
  514. needNumDict[castingId] = materialObj.number;
  515. } else {
  516. needNumDict[castingId] += materialObj.number;
  517. }
  518. }
  519. let minCount = 99999;
  520. for (let kid in needNumDict) {
  521. const ownLst = materialDetails[kid] || [];
  522. const maxCount = Math.floor(ownLst.length / needNumDict[kid]);
  523. if (maxCount < minCount) {
  524. minCount = maxCount;
  525. }
  526. }
  527. minCount = Math.min(minCount, wantCount);
  528. let nCompositeGroup = [];
  529. for (let n = 0; n < minCount; n++) {
  530. let resultMaterialLst = [];
  531. let interrupt = false;
  532. for (let i = 0; i < materialGroup.length; i++) {
  533. const materialObj = materialGroup[i];
  534. const castingId = materialObj.castingId;
  535. let ownLst = materialDetails[castingId];
  536. let num = materialObj.number;
  537. if (ownLst.length < num) {
  538. interrupt = true;
  539. break;
  540. }
  541. let materialSeries = {
  542. castingId: castingId,
  543. orderList: [],
  544. };
  545. for (let j = ownLst.length - 1; j >= 0; j--) {
  546. num -= 1;
  547. let info = ownLst[j];
  548. materialSeries.orderList.push(info.id);
  549. ownLst.splice(j, 1);
  550. if (num == 0) {
  551. break;
  552. }
  553. }
  554. resultMaterialLst.push(materialSeries);
  555. }
  556. if (interrupt) {
  557. break;
  558. }
  559. nCompositeGroup.push(resultMaterialLst);
  560. }
  561. return nCompositeGroup;
  562. }
  563. function calcCompositeGroups(materialSelLst) {
  564. let materialDict = {};
  565. let materialGroups = [];
  566. function doArrangeMeterialGroup(transArr, index, resultArr, resultTmp) {
  567. for (let i = 0; i < transArr[index].length; i++) {
  568. const materialInfo = transArr[index][i];
  569. resultTmp[index] = materialInfo;
  570. const castingId = materialInfo.castingId;
  571. materialDict[castingId] = materialInfo;
  572. if (index != transArr.length - 1) {
  573. doArrangeMeterialGroup(transArr, index + 1, resultArr, resultTmp);
  574. } else {
  575. resultArr.push([].concat(resultTmp));
  576. }
  577. }
  578. return resultArr;
  579. }
  580. doArrangeMeterialGroup(materialSelLst, 0, materialGroups, []);
  581. return [materialGroups, materialDict];
  582. }
  583. async function checkGetCompositeTaskList(status) {
  584. let taskLst;
  585. let useCache = lk.getVal(GandartConstKey.CompositeTaskListCache);
  586. if (!lk.isEmpty(useCache)) {
  587. useCache = JSON.parse(useCache);
  588. } else {
  589. useCache = false;
  590. }
  591. lk.log(`合成任务列表本地缓存:${useCache}`);
  592. if (useCache) {
  593. taskLst = getCompositeTaskListByCache(status);
  594. } else {
  595. taskLst = await getCompositeTaskListByServer(status);
  596. cacheCompositeTaskList(status, taskLst);
  597. }
  598. return taskLst;
  599. }
  600. function getCompositeTaskListByCache(status, pageSize = 10, page = 1) {
  601. try {
  602. let jsonStr = '';
  603. if (status == 0) {
  604. jsonStr = lk.getVal(GandartConstKey.CompositeTaskList0);
  605. } else if (status == 1) {
  606. jsonStr = lk.getVal(GandartConstKey.CompositeTaskList1);
  607. } else if (status == 2) {
  608. jsonStr = lk.getVal(GandartConstKey.CompositeTaskList2);
  609. }
  610. if (!lk.isEmpty(jsonStr)) {
  611. return JSON.parse(jsonStr);
  612. }
  613. } catch (error) {
  614. lk.logErr(error);
  615. }
  616. }
  617. function cacheCompositeTaskList(status, taskLst) {
  618. // 精简一下内容
  619. let simpleLst = [];
  620. for (let i = 0; i < taskLst.length; i++) {
  621. let info = taskLst[i];
  622. let item = {
  623. id: info.id,
  624. compositeLabel: info.compositeLabel,
  625. compositeTaskName: info.compositeTaskName,
  626. surplus: info.surplus,
  627. startTime: info.startTime,
  628. endTime: info.endTime,
  629. };
  630. simpleLst.push(item);
  631. }
  632. let jsonStr = JSON.stringify(simpleLst, null, 2);
  633. if (status == 0) {
  634. lk.setVal(GandartConstKey.CompositeTaskList0, jsonStr);
  635. } else if (status == 1) {
  636. lk.setVal(GandartConstKey.CompositeTaskList1, jsonStr);
  637. } else if (status == 2) {
  638. lk.setVal(GandartConstKey.CompositeTaskList2, jsonStr);
  639. }
  640. }
  641. async function getCompositeTaskListByServer(status, pageSize = 10, page = 1) {
  642. return new Promise((resolve, _reject) => {
  643. try {
  644. const headers = GCommonGandartHeads;
  645. headers['Host'] = 'api.gandart.com';
  646. headers['Content-Type'] = 'application/x-www-form-urlencoded;charset=UTF-8';
  647. let body = `page=${page}&pageSize=${pageSize}&total=0&status=${status}&labelName=`;
  648. let url = {
  649. url: `${config.WALLET_API}/v2/composite/v3/list/v2`,
  650. headers: headers,
  651. body: body
  652. };
  653. let tagNames = [
  654. '待开始',
  655. '合成中',
  656. '已结束',
  657. ];
  658. lk.log(`获取合成任务[${tagNames[status]}]列表:${body}`);
  659. lk.post(url, async (error, _response, data) => {
  660. let retTaskLst = [];
  661. try {
  662. if (error) {
  663. lk.log(`获取合成任务列表发生错误`);
  664. lk.execFail();
  665. lk.appendNotifyInfo(`❌获取合成任务列表失败,请稍后再试`);
  666. } else {
  667. let ret = JSON.parse(data);
  668. if (ret.rows && ret.rows.length > 0) {
  669. retTaskLst = ret.rows;
  670. }
  671. lk.log(`获取合成任务列表成功`);
  672. }
  673. } catch (e) {
  674. lk.log(`获取合成任务列表发生错误`);
  675. lk.logErr(e);
  676. lk.execFail();
  677. } finally {
  678. resolve(retTaskLst);
  679. }
  680. });
  681. } catch (e) {
  682. lk.log(`获取合成任务列表发生错误`);
  683. lk.logErr(e);
  684. resolve();
  685. }
  686. });
  687. }
  688. async function getCompositeMaterial(taskId, taskInfo) {
  689. return new Promise((resolve, _reject) => {
  690. try {
  691. const headers = GCommonGandartHeads;
  692. headers['Host'] = 'api.gandart.com';
  693. headers['Content-Type'] = 'application/x-www-form-urlencoded;charset=UTF-8';
  694. let body = `taskId=${taskId}`;
  695. let url = {
  696. url: `${config.BASE_API}/v2/composite/v3/compositeMaterial`,
  697. headers: headers,
  698. body: body
  699. };
  700. let taskName = taskInfo.compositeTaskName || ''; //合成标题
  701. lk.log(`获取合成任务[${taskName}#${taskId}]材料详情:${body}`);
  702. lk.post(url, async (error, _response, data) => {
  703. let retItemLst = [];
  704. try {
  705. if (error) {
  706. lk.log(`获取合成任务材料详情发生错误`);
  707. lk.execFail();
  708. lk.appendNotifyInfo(`❌获取合成任务材料详情失败,请稍后再试`);
  709. } else {
  710. let ret = JSON.parse(data);
  711. if (ret.success) {
  712. let obj = ret.obj;
  713. retItemLst = obj;
  714. lk.log(`获取合成任务材料详情成功`);
  715. } else {
  716. lk.log(`获取合成任务材料详情失败,响应:${data}`);
  717. }
  718. }
  719. } catch (e) {
  720. lk.log(`获取合成任务材料详情发生错误`);
  721. lk.logErr(e);
  722. lk.execFail();
  723. } finally {
  724. resolve(retItemLst);
  725. }
  726. });
  727. } catch (e) {
  728. lk.log(`获取合成任务材料详情发生错误`);
  729. lk.logErr(e);
  730. resolve();
  731. }
  732. });
  733. }
  734. async function getDetailByCasting(castingId, collectionName, pageSize = 50, page = 1) {
  735. return new Promise((resolve, _reject) => {
  736. try {
  737. const headers = GCommonGandartHeads;
  738. headers['Host'] = 'api.gandart.com';
  739. headers['Content-Type'] = 'application/x-www-form-urlencoded;charset=UTF-8';
  740. let params = {
  741. castingId: castingId,
  742. page: page,
  743. pageSize: pageSize,
  744. };
  745. let signData = getSign();
  746. signData = Object.assign(signData, params);
  747. let body = lk.objToQueryStr(signData);
  748. let url = {
  749. url: `${config.SALE_API}/composite/getDetailByCasting?${lk.objToQueryStr(params)}`,
  750. headers: headers,
  751. body: body
  752. };
  753. collectionName = collectionName || getCollectionNameById(castingId);
  754. lk.log(`获取个人产品[${collectionName}(${castingId})]拥有详情:${body}`);
  755. lk.post(url, async (error, _response, data) => {
  756. let retItemLst = [];
  757. try {
  758. if (error) {
  759. lk.log(`获取个人产品拥有详情发生错误`);
  760. lk.execFail();
  761. lk.appendNotifyInfo(`❌获取个人产品拥有详情失败,请稍后再试`);
  762. } else {
  763. let ret = JSON.parse(data);
  764. if (ret.success) {
  765. let obj = ret.obj;
  766. retItemLst = obj.list;
  767. lk.log(`获取个人产品拥有详情成功,响应:${data}`);
  768. } else {
  769. lk.log(`获取个人产品拥有详情失败,响应:${data}`);
  770. }
  771. }
  772. } catch (e) {
  773. lk.log(`获取个人产品拥有详情发生错误`);
  774. lk.logErr(e);
  775. lk.execFail();
  776. } finally {
  777. resolve(retItemLst);
  778. }
  779. });
  780. } catch (e) {
  781. lk.log(`获取个人产品拥有详情发生错误`);
  782. lk.logErr(e);
  783. resolve();
  784. }
  785. });
  786. }
  787. async function confirmCompositeV2(taskId, taskInfo, materialDetailList) {
  788. return new Promise((resolve, _reject) => {
  789. try {
  790. const headers = GCommonGandartHeads;
  791. headers['Host'] = 'api.gandart.com';
  792. headers['Content-Type'] = 'application/json';
  793. let data = {
  794. taskId: Number(taskId),
  795. compositeList: [
  796. {
  797. materialDetailList: materialDetailList
  798. }
  799. ],
  800. };
  801. let body = JSON.stringify(data);
  802. let url = {
  803. url: `${config.BASE_API}/v2/composite/v3/confirmCompositeV2`,
  804. headers: headers,
  805. body: body
  806. };
  807. let taskName = taskInfo.compositeTaskName || ''; //合成标题
  808. lk.log(`请求合成任务[${taskName}#${taskId}]:\n${body}`);
  809. lk.post(url, async (error, _response, data) => {
  810. let retOrder;
  811. try {
  812. if (error) {
  813. lk.log(`合成发生错误`);
  814. lk.execFail();
  815. lk.appendNotifyInfo(`❌合成失败,请稍后再试`);
  816. } else {
  817. let ret = JSON.parse(data);
  818. if (ret.success) {
  819. retOrder = ret.obj;
  820. let dismsg = `合成任务[${taskId}]成功,订单号:${retOrder}`;
  821. lk.log(dismsg);
  822. lk.appendNotifyInfo(`🎉${dismsg}`);
  823. } else {
  824. lk.log(`合成失败,响应:${data}`);
  825. let respMsg = ret.msg;
  826. if (respMsg) {
  827. if (respMsg.indexOf('合成中') > -1 || respMsg.indexOf('已合成') > -1) {
  828. lk.appendNotifyInfo(`🎉${respMsg}`);
  829. retOrder = '#HC123456789';
  830. } else if (respMsg.indexOf('不足') > -1) {
  831. lk.appendNotifyInfo(`⚠️${respMsg}`);
  832. retOrder = '!HC123456789';
  833. }
  834. }
  835. }
  836. }
  837. } catch (e) {
  838. lk.log(`合成发生错误`);
  839. lk.logErr(e);
  840. lk.execFail();
  841. } finally {
  842. resolve(retOrder);
  843. }
  844. });
  845. } catch (e) {
  846. lk.log(`合成发生错误`);
  847. lk.logErr(e);
  848. resolve();
  849. }
  850. });
  851. }
  852. async function checkCompositeResult(orderNum) {
  853. return new Promise((resolve, _reject) => {
  854. try {
  855. const headers = GCommonGandartHeads;
  856. headers['Host'] = 'api.gandart.com';
  857. headers['Content-Type'] = 'application/x-www-form-urlencoded;charset=UTF-8';
  858. let body = `orderNum=${orderNum}`;
  859. let url = {
  860. url: `${config.BASE_API}/v2/composite/v3/compositeResult`,
  861. headers: headers,
  862. body: body
  863. };
  864. lk.log(`获取合成结果[${orderNum}]:${body}`);
  865. lk.post(url, async (error, _response, data) => {
  866. let retItemLst;
  867. try {
  868. if (error) {
  869. lk.log(`获取合成结果发生错误`);
  870. lk.execFail();
  871. lk.appendNotifyInfo(`❌获取合成结果失败,请稍后再试`);
  872. } else {
  873. let ret = JSON.parse(data);
  874. if (ret.success) {
  875. lk.log(`获取合成结果成功,响应:${data}`);
  876. retItemLst = ret.obj;
  877. let cName = '';
  878. for (let i = 0; i < retItemLst.length; i++) {
  879. cName += retItemLst[i].collectionName + ",";
  880. }
  881. cName = cName.substring(0, cName.length - 1);
  882. lk.appendNotifyInfo(`🎉合成产品:${cName}`);
  883. } else {
  884. lk.log(`获取合成结果失败,响应:${data}`);
  885. }
  886. }
  887. } catch (e) {
  888. lk.log(`获取合成结果发生错误`);
  889. lk.logErr(e);
  890. lk.execFail();
  891. } finally {
  892. resolve(retItemLst);
  893. }
  894. });
  895. } catch (e) {
  896. lk.log(`获取合成结果发生错误`);
  897. lk.logErr(e);
  898. resolve();
  899. }
  900. });
  901. }
  902. function getCollectionMInfoById(castingId) {
  903. let ret;
  904. try {
  905. let clst = JSON.parse(lk.getVal(GandartConstKey.CollectionCateLst, "[]"));
  906. for (const d of clst) {
  907. if (d.castingId == castingId) {
  908. ret = d;
  909. break;
  910. }
  911. }
  912. } catch (error) {
  913. lk.logErr(error);
  914. }
  915. return ret;
  916. }
  917. function getCollectionNameById(castingId) {
  918. let name = '未获取';
  919. let info = getCollectionMInfoById(castingId);
  920. if (info) {
  921. name = info.collectionName;
  922. }
  923. return name;
  924. }
  925. function getSign() {
  926. const now = new Date().getTime();
  927. let s1 = now - 20000;
  928. let s2 = now;
  929. let s3 = now + 20000;
  930. let s4 = now + 40000;
  931. const sssfffeee = 'e9'; //localStorage.getItem('sssfffeee');
  932. const aggaaa = '9'; //localStorage.getItem('aggaaa');
  933. const yyhhhasdww = '0a';
  934. let arr = [sssfffeee, yyhhhasdww, aggaaa, '29', 'e', 'c', 3];
  935. let crypto = createCrypto();
  936. let s5 = crypto.md5(s3 + arr.join(''));
  937. return {
  938. 's1': s1,
  939. 's2': s2,
  940. 's3': s3,
  941. 's4': s4,
  942. 's5': s5
  943. };
  944. }
  945. //ToolKit-start
  946. function ToolKit(t, s, i) { return new class { constructor(t, s, i) { this.tgEscapeCharMapping = { "&": "&", "#": "#" }, this.userAgent = "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_13_6) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/12.0.2 Safari/605.1.15", this.prefix = "lk", this.name = t, this.id = s, this.data = null, this.dataFile = this.getRealPath("" + this.prefix + this.id + ".dat"), this.boxJsJsonFile = this.getRealPath("" + this.prefix + this.id + ".boxjs.json"), this.options = i, this.isExecComm = !1, this.isEnableLog = this.getVal(this.prefix + "IsEnableLog" + this.id), this.isEnableLog = !!this.isEmpty(this.isEnableLog) || JSON.parse(this.isEnableLog), this.isNotifyOnlyFail = this.getVal(this.prefix + "NotifyOnlyFail" + this.id), this.isNotifyOnlyFail = !this.isEmpty(this.isNotifyOnlyFail) && JSON.parse(this.isNotifyOnlyFail), this.isEnableTgNotify = this.getVal(this.prefix + "IsEnableTgNotify" + this.id), this.isEnableTgNotify = !this.isEmpty(this.isEnableTgNotify) && JSON.parse(this.isEnableTgNotify), this.tgNotifyUrl = this.getVal(this.prefix + "TgNotifyUrl" + this.id), this.isEnableTgNotify = this.isEnableTgNotify && !this.isEmpty(this.tgNotifyUrl), this.costTotalStringKey = this.prefix + "CostTotalString" + this.id, this.costTotalString = this.getVal(this.costTotalStringKey), this.costTotalString = this.isEmpty(this.costTotalString) ? "0,0" : this.costTotalString.replace('"', ""), this.costTotalMs = this.costTotalString.split(",")[0], this.execCount = this.costTotalString.split(",")[1], this.costTotalMs = this.isEmpty(this.costTotalMs) ? 0 : parseInt(this.costTotalMs), this.execCount = this.isEmpty(this.execCount) ? 0 : parseInt(this.execCount), this.logSeparator = "\n██", this.now = new Date, this.startTime = this.now.getTime(), this.node = this.isNode() ? { request: require("request") } : null, this.execStatus = !0, this.notifyInfo = [], this.log(this.name + ", 开始执行!"), this.initCache(), this.checkRecordRequestBody(), this.execComm() } checkRecordRequestBody() { var t, s; this.isRequest() && (t = $request.body) && (s = $request.path, s = this.id + "#" + s.replace("/", "_"), this.isQuanX() && $prefs.setValueForKey(t, s), (this.isLoon() || this.isSurge()) && $persistentStore.write(t, s), this.isNode()) && this.node.fs.writeFileSync(s + ".json", t, { flag: "w" }, t => console.log(t)) } getRequestBody() { var t = $request.path, t = this.id + "#" + t.replace("/", "_"); if (this.isSurge() || this.isLoon()) return $persistentStore.read(t); if (this.isQuanX()) return $prefs.valueForKey(t); if (this.isNode()) { t = t + ".json"; if (!this.node.fs.existsSync(t)) return JSON.parse(this.node.fs.readFileSync(t)) } } initCache() { var t, s = this.getPersistKey(); this.isQuanX() && (this.cache = JSON.parse($prefs.valueForKey(s) || "{}")), (this.isLoon() || this.isSurge()) && (this.cache = JSON.parse($persistentStore.read(s) || "{}")), this.isNode() && (this.node.fs.existsSync(t = "root.json") || this.node.fs.writeFileSync(t, JSON.stringify({}), { flag: "wx" }, t => console.log(t)), this.root = {}, this.node.fs.existsSync(t = s + ".json") ? this.cache = JSON.parse(this.node.fs.readFileSync(s + ".json")) : (this.node.fs.writeFileSync(t, JSON.stringify({}), { flag: "wx" }, t => console.log(t)), this.cache = {})) } getPersistKey() { return this.id + "#privateCache" } persistCache() { var t = this.getPersistKey(), s = JSON.stringify(this.cache, null, 2); this.isQuanX() && $prefs.setValueForKey(s, t), (this.isLoon() || this.isSurge()) && $persistentStore.write(s, t), this.isNode() && (this.node.fs.writeFileSync(t + ".json", s, { flag: "w" }, t => console.log(t)), this.node.fs.writeFileSync("root.json", JSON.stringify(this.root, null, 2), { flag: "w" }, t => console.log(t))) } write(t, s) { if (this.log("SET " + s), -1 !== s.indexOf("#")) { if (s = s.substr(1), isSurge || this.isLoon()) return $persistentStore.write(t, s); if (this.isQuanX()) return $prefs.setValueForKey(t, s); this.isNode() && (this.root[s] = t) } else this.cache[s] = t; this.persistCache() } read(t) { return this.log("READ " + t), -1 !== t.indexOf("#") ? (t = t.substr(1), this.isSurge() || this.isLoon() ? $persistentStore.read(t) : this.isQuanX() ? $prefs.valueForKey(t) : this.isNode() ? this.root[t] : void 0) : this.cache[t] } delete(t) { if (this.log("DELETE " + t), -1 !== t.indexOf("#")) { if (t = t.substr(1), this.isSurge() || this.isLoon()) return $persistentStore.write(null, t); if (this.isQuanX()) return $prefs.removeValueForKey(t); this.isNode() && delete this.root[t] } else delete this.cache[t]; this.persistCache() } getRealPath(t) { var s; return this.isNode() ? ((s = process.argv.slice(1, 2)[0].split("/"))[s.length - 1] = t, s.join("/")) : t } getUrlHost(t) { return t.slice(0, t.indexOf("/", 8)) } getUrlPath(t) { var s = t.lastIndexOf("/") === t.length - 1 ? -1 : void 0; return t.slice(t.indexOf("/", 8), s) } async execComm() { if (this.isNode()) { this.comm = process.argv.slice(1); let t = !1; "p" == this.comm[1] && (this.isExecComm = !0, this.log(`开始执行指令【${this.comm[1]}】=> 发送到手机测试脚本!`), this.isEmpty(this.options) || this.isEmpty(this.options.httpApi) ? (this.log("未设置options,使用默认值"), this.isEmpty(this.options) && (this.options = {}), this.options.httpApi = "[email protected]:6166") : /.*?@.*?:[0-9]+/.test(this.options.httpApi) || (t = !0, this.log("❌httpApi格式错误!格式:[email protected]:6166"), this.done()), t || this.callApi(this.comm[2])) } } callApi(t) { let e = this.comm[0], s = (this.log(`获取【${e}】内容传给手机`), ""); this.fs = this.fs || require("fs"), this.path = this.path || require("path"); var i = this.path.resolve(e), r = this.path.resolve(process.cwd(), e), o = this.fs.existsSync(i), h = !o && this.fs.existsSync(r); if (o || h) { h = o ? i : r; try { s = this.fs.readFileSync(h) } catch (t) { s = "" } } else s = ""; o = { url: `http://${this.options.httpApi.split("@")[1]}/v1/scripting/evaluate`, headers: { "X-Key": "" + this.options.httpApi.split("@")[0] }, body: { script_text: "" + s, mock_type: "cron", timeout: !this.isEmpty(t) && 5 < t ? t : 5 }, json: !0 }; this.post(o, (t, s, i) => { this.log(`已将脚本【${e}】发给手机!`), this.done() }) } getCallerFileNameAndLine() { let s; try { throw Error("") } catch (t) { s = t } var t = s.stack.split("\n")[1]; return this.path = this.path || require("path"), `[${t.substring(t.lastIndexOf(this.path.sep) + 1, t.lastIndexOf(":"))}]` } getFunName(t) { t = t.toString(); return t = (t = t.substr("function ".length)).substr(0, t.indexOf("(")) } boxJsJsonBuilder(s, r) { if (this.isNode()) { let e = "/Users/lowking/Desktop/Scripts/lowking.boxjs.json"; if (r && r.hasOwnProperty("target_boxjs_json_path") && (e = r.target_boxjs_json_path), this.fs.existsSync(e)) if (this.isJsonObject(s) && this.isJsonObject(r)) { this.log("using node"); var o = ["settings", "keys"], h = "https://raw.githubusercontent.com/Orz-3"; let i = {}, t = "#lk{script_url}"; if (r && r.hasOwnProperty("script_url") && (t = this.isEmpty(r.script_url) ? "#lk{script_url}" : r.script_url), i.id = "" + this.prefix + this.id, i.name = this.name, i.desc_html = `⚠️使用说明</br>详情【<a href='${t}?raw=true'><font class='red--text'>点我查看</font></a>】`, i.icons = [h + `/mini/master/Alpha/${this.id.toLocaleLowerCase()}.png`, h + `/mini/master/Color/${this.id.toLocaleLowerCase()}.png`], i.keys = [], i.settings = [{ id: this.prefix + "IsEnableLog" + this.id, name: "开启/关闭日志", val: !0, type: "boolean", desc: "默认开启" }, { id: this.prefix + "NotifyOnlyFail" + this.id, name: "只当执行失败才通知", val: !1, type: "boolean", desc: "默认关闭" }, { id: this.prefix + "IsEnableTgNotify" + this.id, name: "开启/关闭Telegram通知", val: !1, type: "boolean", desc: "默认关闭" }, { id: this.prefix + "TgNotifyUrl" + this.id, name: "Telegram通知地址", val: "", type: "text", desc: "Tg的通知地址,如:https://api.telegram.org/bot-token/sendMessage?chat_id=-100140&parse_mode=Markdown&text=" }], i.author = "#lk{author}", i.repo = "#lk{repo}", i.script = t + "?raw=true", !this.isEmpty(s)) for (var n in o) { var a = o[n]; if (!this.isEmpty(s[a])) { if ("settings" === a) for (let t = 0; t < s[a].length; t++) { var l = s[a][t]; for (let t = 0; t < i.settings.length; t++) { var p = i.settings[t]; l.id === p.id && i.settings.splice(t, 1) } } i[a] = i[a].concat(s[a]) } delete s[a] } if (Object.assign(i, s), this.isNode()) { this.fs = this.fs || require("fs"), this.path = this.path || require("path"); var h = this.path.resolve(this.boxJsJsonFile), u = this.path.resolve(process.cwd(), this.boxJsJsonFile), f = this.fs.existsSync(h), c = !f && this.fs.existsSync(u), d = JSON.stringify(i, null, "\t"), f = (!f && c ? this.fs.writeFileSync(u, d) : this.fs.writeFileSync(h, d), JSON.parse(this.fs.readFileSync(e))); if (f.hasOwnProperty("apps") && Array.isArray(f.apps) && 0 < f.apps.length) { c = f.apps, u = c.indexOf(c.filter(t => t.id == i.id)[0]); 0 <= u ? f.apps[u] = i : f.apps.push(i); let s = JSON.stringify(f, null, 2); if (!this.isEmpty(r)) for (const m in r) { let t = ""; r.hasOwnProperty(m) ? t = r[m] : "author" === m ? t = "@lowking" : "repo" === m && (t = "https://github.com/lowking/Scripts"), s = s.replace(`#lk{${m}}`, t) } for (var g, y = /(?:#lk\{)(.+?)(?=\})/, S = (null !== y.exec(s) && this.log("生成BoxJs还有未配置的参数,请参考https://github.com/lowking/Scripts/blob/master/util/example/ToolKitDemo.js#L17-L18传入参数:\n"), new Set); null !== (g = y.exec(s));)S.add(g[1]), s = s.replace(`#lk{${g[1]}}`, ""); S.forEach(t => { console.log(t + " ") }), this.fs.writeFileSync(e, s) } } } else this.log("构建BoxJsJson传入参数格式错误,请传入json对象") } } isJsonObject(t) { return "object" == typeof t && "[object object]" == Object.prototype.toString.call(t).toLowerCase() && !t.length } appendNotifyInfo(t, s) { 1 == s ? this.notifyInfo = t : this.notifyInfo.push(t) } prependNotifyInfo(t) { this.notifyInfo.splice(0, 0, t) } execFail() { this.execStatus = !1 } isRequest() { return "undefined" != typeof $request } isSurge() { return "undefined" != typeof $httpClient } isQuanX() { return "undefined" != typeof $task } isLoon() { return "undefined" != typeof $loon } isJSBox() { return "undefined" != typeof $app && "undefined" != typeof $http } isStash() { return "undefined" != typeof $environment && $environment["stash-version"] } isNode() { return "function" == typeof require && !this.isJSBox() } sleep(s) { return new Promise(t => setTimeout(t, s)) } log(t) { this.isEnableLog && console.log("" + this.logSeparator + t) } logErr(t) { this.execStatus = !0, this.isEnableLog && (console.log("" + this.logSeparator + this.name + "执行异常:"), console.log(t), console.log("\n" + t.message)) } msg(t, s, i, e) { if ((this.isRequest() || !this.isNotifyOnlyFail || !this.execStatus) && (this.isEmpty(s) && (s = Array.isArray(this.notifyInfo) ? this.notifyInfo.join("\n") : this.notifyInfo), !this.isEmpty(s))) if (this.isEnableTgNotify) { for (var r in this.log(this.name + "Tg通知开始"), this.tgEscapeCharMapping) this.tgEscapeCharMapping.hasOwnProperty(r) && (s = s.replace(r, this.tgEscapeCharMapping[r])); this.get({ url: encodeURI(this.tgNotifyUrl + "📌" + this.name + "\n" + s) }, (t, s, i) => { this.log("Tg通知完毕") }) } else { var o = {}, h = !this.isEmpty(i), n = !this.isEmpty(e); this.isQuanX() && (h && (o["open-url"] = i), n && (o["media-url"] = e), $notify(this.name, t, s, o)), (this.isSurge() || this.isStash()) && (h && (o.url = i), $notification.post(this.name, t, s, o)), this.isNode() && this.log("⭐️" + this.name + "\n" + t + "\n" + s), this.isJSBox() && $push.schedule({ title: this.name, body: t ? t + "\n" + s : s }) } } getVal(t, s = "") { let i; return (i = this.isSurge() || this.isLoon() || this.isStash() ? $persistentStore.read(t) : this.isQuanX() ? $prefs.valueForKey(t) : this.isNode() ? (this.data = this.loadData(), process.env[t] || this.data[t]) : this.data && this.data[t] || null) || s } setVal(t, s) { return this.isSurge() || this.isLoon() || this.isStash() ? $persistentStore.write(s, t) : this.isQuanX() ? $prefs.setValueForKey(s, t) : this.isNode() ? (this.data = this.loadData(), this.data[t] = s, this.writeData(), !0) : this.data && this.data[t] || null } loadData() { if (!this.isNode()) return {}; this.fs = this.fs || require("fs"), this.path = this.path || require("path"); var t = this.path.resolve(this.dataFile), s = this.path.resolve(process.cwd(), this.dataFile), i = this.fs.existsSync(t), e = !i && this.fs.existsSync(s); if (!i && !e) return {}; e = i ? t : s; try { return JSON.parse(this.fs.readFileSync(e)) } catch (t) { return {} } } writeData() { var t, s, i, e, r; this.isNode() && (this.fs = this.fs || require("fs"), this.path = this.path || require("path"), t = this.path.resolve(this.dataFile), s = this.path.resolve(process.cwd(), this.dataFile), e = !(i = this.fs.existsSync(t)) && this.fs.existsSync(s), r = JSON.stringify(this.data), !i && e ? this.fs.writeFileSync(s, r) : this.fs.writeFileSync(t, r)) } adapterStatus(t) { return t && (t.status ? t.statusCode = t.status : t.statusCode && (t.status = t.statusCode)), t } get(t, e = () => { }) { this.isQuanX() && ((t = "string" == typeof t ? { url: t } : t).method = "GET", $task.fetch(t).then(t => { e(null, this.adapterStatus(t), t.body) }, t => e(t.error, null, null))), (this.isSurge() || this.isLoon() || this.isStash()) && $httpClient.get(t, (t, s, i) => { e(t, this.adapterStatus(s), i) }), this.isNode() && this.node.request(t, (t, s, i) => { e(t, this.adapterStatus(s), i) }), this.isJSBox() && ((t = "string" == typeof t ? { url: t } : t).header = t.headers, t.handler = function (t) { let s = t.error, i = (s = s && JSON.stringify(t.error), t.data); "object" == typeof i && (i = JSON.stringify(t.data)), e(s, this.adapterStatus(t.response), i) }, $http.get(t)) } post(t, e = () => { }) { this.isQuanX() && ((t = "string" == typeof t ? { url: t } : t).method = "POST", $task.fetch(t).then(t => { e(null, this.adapterStatus(t), t.body) }, t => e(t.error, null, null))), (this.isSurge() || this.isLoon() || this.isStash()) && $httpClient.post(t, (t, s, i) => { e(t, this.adapterStatus(s), i) }), this.isNode() && this.node.request.post(t, (t, s, i) => { e(t, this.adapterStatus(s), i) }), this.isJSBox() && ((t = "string" == typeof t ? { url: t } : t).header = t.headers, t.handler = function (t) { let s = t.error, i = (s = s && JSON.stringify(t.error), t.data); "object" == typeof i && (i = JSON.stringify(t.data)), e(s, this.adapterStatus(t.response), i) }, $http.post(t)) } put(t, e = () => { }) { this.isQuanX() && ((t = "string" == typeof t ? { url: t } : t).method = "PUT", $task.fetch(t).then(t => { e(null, this.adapterStatus(t), t.body) }, t => e(t.error, null, null))), (this.isSurge() || this.isLoon() || this.isStash()) && (t.method = "PUT", $httpClient.put(t, (t, s, i) => { e(t, this.adapterStatus(s), i) })), this.isNode() && (t.method = "PUT", this.node.request.put(t, (t, s, i) => { e(t, this.adapterStatus(s), i) })), this.isJSBox() && ((t = "string" == typeof t ? { url: t } : t).header = t.headers, t.handler = function (t) { let s = t.error, i = (s = s && JSON.stringify(t.error), t.data); "object" == typeof i && (i = JSON.stringify(t.data)), e(s, this.adapterStatus(t.response), i) }, $http.post(t)) } costTime() { let t = this.name + "执行完毕!"; this.isNode() && this.isExecComm && (t = `指令【${this.comm[1]}】执行完毕!`); var s = (new Date).getTime() - this.startTime, i = s / 1e3; this.execCount++, this.costTotalMs += s, this.log(`${t}耗时【${i}】秒\n总共执行【${this.execCount}】次,平均耗时【${(this.costTotalMs / this.execCount / 1e3).toFixed(4)}】秒`), this.setVal(this.costTotalStringKey, JSON.stringify(this.costTotalMs + "," + this.execCount)) } done(t = {}) { this.costTime(), (this.isSurge() || this.isQuanX() || this.isLoon() || this.isStash()) && $done(t) } getRequestUrl() { return $request.url } getResponseBody() { if ($response) return $response.body } isGetCookie(t) { return !("OPTIONS" == $request.method || !this.getRequestUrl().match(t)) } isEmpty(t) { return void 0 === t || null == t || "" == t || "null" == t || "undefined" == t || 0 === t.length } randomString(s) { s = s || 32; var i = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz1234567890", e = i.length, r = ""; for (let t = 0; t < s; t++)r += i.charAt(Math.floor(Math.random() * e)); return r } autoComplete(s, t, i, e, r, o, h, n, a, l) { if ((s += "").length < r) for (; s.length < r;)0 == o ? s += e : s = e + s; if (h) { let t = ""; for (var p = 0; p < n; p++)t += l; s = s.substring(0, a) + t + s.substring(n + a) } return this.toDBC(s = t + s + i) } customReplace(t, s, i, e) { try { for (var r in this.isEmpty(i) && (i = "#{"), this.isEmpty(e) && (e = "}"), s) t = t.replace("" + i + r + e, s[r]) } catch (t) { this.logErr(t) } return t } toDBC(t) { for (var s = "", i = 0; i < t.length; i++)32 == t.charCodeAt(i) ? s += String.fromCharCode(12288) : t.charCodeAt(i) < 127 && (s += String.fromCharCode(t.charCodeAt(i) + 65248)); return s } hash(t) { let s = 0, i, e; for (i = 0; i < t.length; i++)e = t.charCodeAt(i), s = (s << 5) - s + e, s |= 0; return String(s) } formatDate(t, s) { var i, e = { "M+": t.getMonth() + 1, "d+": t.getDate(), "H+": t.getHours(), "m+": t.getMinutes(), "s+": t.getSeconds(), "q+": Math.floor((t.getMonth() + 3) / 3), S: t.getMilliseconds() }; for (i in /(y+)/.test(s) && (s = s.replace(RegExp.$1, (t.getFullYear() + "").substr(4 - RegExp.$1.length))), e) new RegExp("(" + i + ")").test(s) && (s = s.replace(RegExp.$1, 1 == RegExp.$1.length ? e[i] : ("00" + e[i]).substr(("" + e[i]).length))); return s } objToQueryStr(s, i) { let e = ""; for (const r in s) { let t = s[r]; null != t && "" !== t && ("object" == typeof t ? t = JSON.stringify(t) : i && (t = encodeURIComponent(t)), e += `${r}=${t}&`) } return e = e.substring(0, e.length - 1) } parseQueryStr(t) { var s = {}, i = (t = -1 < t.indexOf("?") ? t.split("?")[1] : t).split("&"); for (let t = 0; t < i.length; t++) { var e = i[t].split("="); s[e[0]] = e[1] } return s } deepClone(t, s) { for (var i in s = s || {}, t) "object" == typeof t[i] ? (s[i] = t[i].constructor === Array ? [] : {}, this.deepClone(t[i], s[i])) : s[i] = t[i]; return s } }(t, s, i) }
  947. //ToolKit-end
  948. //Crypto-start
  949. function createCrypto() { function o(t, n) { var r = c(t[0], o = t[1], u = t[2], e = t[3], n[0], 7, -680876936), e = c(e, r, o, u, n[1], 12, -389564586), u = c(u, e, r, o, n[2], 17, 606105819), o = c(o, u, e, r, n[3], 22, -1044525330); r = c(r, o, u, e, n[4], 7, -176418897), e = c(e, r, o, u, n[5], 12, 1200080426), u = c(u, e, r, o, n[6], 17, -1473231341), o = c(o, u, e, r, n[7], 22, -45705983), r = c(r, o, u, e, n[8], 7, 1770035416), e = c(e, r, o, u, n[9], 12, -1958414417), u = c(u, e, r, o, n[10], 17, -42063), o = c(o, u, e, r, n[11], 22, -1990404162), r = c(r, o, u, e, n[12], 7, 1804603682), e = c(e, r, o, u, n[13], 12, -40341101), u = c(u, e, r, o, n[14], 17, -1502002290), r = i(r, o = c(o, u, e, r, n[15], 22, 1236535329), u, e, n[1], 5, -165796510), e = i(e, r, o, u, n[6], 9, -1069501632), u = i(u, e, r, o, n[11], 14, 643717713), o = i(o, u, e, r, n[0], 20, -373897302), r = i(r, o, u, e, n[5], 5, -701558691), e = i(e, r, o, u, n[10], 9, 38016083), u = i(u, e, r, o, n[15], 14, -660478335), o = i(o, u, e, r, n[4], 20, -405537848), r = i(r, o, u, e, n[9], 5, 568446438), e = i(e, r, o, u, n[14], 9, -1019803690), u = i(u, e, r, o, n[3], 14, -187363961), o = i(o, u, e, r, n[8], 20, 1163531501), r = i(r, o, u, e, n[13], 5, -1444681467), e = i(e, r, o, u, n[2], 9, -51403784), u = i(u, e, r, o, n[7], 14, 1735328473), r = a(r, o = i(o, u, e, r, n[12], 20, -1926607734), u, e, n[5], 4, -378558), e = a(e, r, o, u, n[8], 11, -2022574463), u = a(u, e, r, o, n[11], 16, 1839030562), o = a(o, u, e, r, n[14], 23, -35309556), r = a(r, o, u, e, n[1], 4, -1530992060), e = a(e, r, o, u, n[4], 11, 1272893353), u = a(u, e, r, o, n[7], 16, -155497632), o = a(o, u, e, r, n[10], 23, -1094730640), r = a(r, o, u, e, n[13], 4, 681279174), e = a(e, r, o, u, n[0], 11, -358537222), u = a(u, e, r, o, n[3], 16, -722521979), o = a(o, u, e, r, n[6], 23, 76029189), r = a(r, o, u, e, n[9], 4, -640364487), e = a(e, r, o, u, n[12], 11, -421815835), u = a(u, e, r, o, n[15], 16, 530742520), r = l(r, o = a(o, u, e, r, n[2], 23, -995338651), u, e, n[0], 6, -198630844), e = l(e, r, o, u, n[7], 10, 1126891415), u = l(u, e, r, o, n[14], 15, -1416354905), o = l(o, u, e, r, n[5], 21, -57434055), r = l(r, o, u, e, n[12], 6, 1700485571), e = l(e, r, o, u, n[3], 10, -1894986606), u = l(u, e, r, o, n[10], 15, -1051523), o = l(o, u, e, r, n[1], 21, -2054922799), r = l(r, o, u, e, n[8], 6, 1873313359), e = l(e, r, o, u, n[15], 10, -30611744), u = l(u, e, r, o, n[6], 15, -1560198380), o = l(o, u, e, r, n[13], 21, 1309151649), r = l(r, o, u, e, n[4], 6, -145523070), e = l(e, r, o, u, n[11], 10, -1120210379), u = l(u, e, r, o, n[2], 15, 718787259), o = l(o, u, e, r, n[9], 21, -343485551), t[0] = h(r, t[0]), t[1] = h(o, t[1]), t[2] = h(u, t[2]), t[3] = h(e, t[3]) } function f(t, n, r, e, u, o) { return n = h(h(n, t), h(e, o)), h(n << u | n >>> 32 - u, r) } function c(t, n, r, e, u, o, c) { return f(n & r | ~n & e, t, n, u, o, c) } function i(t, n, r, e, u, o, c) { return f(n & e | r & ~e, t, n, u, o, c) } function a(t, n, r, e, u, o, c) { return f(n ^ r ^ e, t, n, u, o, c) } function l(t, n, r, e, u, o, c) { return f(r ^ (n | ~e), t, n, u, o, c) } function n(t) { /[\x80-\xFF]/.test(t) && (t = unescape(encodeURI(t))), txt = ""; let n = t.length, r = [1732584193, -271733879, -1732584194, 271733878], e; for (e = 64; e <= t.length; e += 64)o(r, function (t) { let n = [], r; for (r = 0; r < 64; r += 4)n[r >> 2] = t.charCodeAt(r) + (t.charCodeAt(r + 1) << 8) + (t.charCodeAt(r + 2) << 16) + (t.charCodeAt(r + 3) << 24); return n }(t.substring(e - 64, e))); t = t.substring(e - 64); var u = [0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0]; for (e = 0; e < t.length; e++)u[e >> 2] |= t.charCodeAt(e) << (e % 4 << 3); if (u[e >> 2] |= 128 << (e % 4 << 3), 55 < e) for (o(r, u), e = 0; e < 16; e++)u[e] = 0; return u[14] = 8 * n, o(r, u), r } let e = "0123456789abcdef".split(""); function r(n) { for (let t = 0; t < n.length; t++)n[t] = function (t) { let n = "", r = 0; for (; r < 4; r++)n += e[t >> 8 * r + 4 & 15] + e[t >> 8 * r & 15]; return n }(n[t]); return n.join("") } function h(t, n) { return t + n & 4294967295 } return { md5: function (t) { return r(n(t)) } } }
  950. //Crypto-end