|
|
@@ -129,32 +129,20 @@ async function checkLotteryResult() {
|
|
|
// let htmlContent = await getHtmlContent(htmlUrl, gCommonHeaders);
|
|
|
|
|
|
let nowDate = formatNow();
|
|
|
- let pksPlanListRet = await getPksPlanList(gLotteryCode, nowDate);
|
|
|
- if(!pksPlanListRet){
|
|
|
+ let pksPlanListData = await getPksPlanList(gLotteryCode, nowDate);
|
|
|
+ if(!pksPlanListData){
|
|
|
return;
|
|
|
}
|
|
|
- if(pksPlanListRet.errorCode != 0 || pksPlanListRet.result == void 0){
|
|
|
- return;
|
|
|
- }
|
|
|
- if(pksPlanListRet.result.businessCode != 0){
|
|
|
- return;
|
|
|
- }
|
|
|
- let pksPlanListData = pksPlanListRet.result.data;
|
|
|
+
|
|
|
let isConnectOk = await pingPksPlan(nowDate);
|
|
|
if(!isConnectOk){
|
|
|
return;
|
|
|
}
|
|
|
- let pksPlanItemRet = await getPksPlanItem(gLotteryCode);
|
|
|
- if(!pksPlanItemRet){
|
|
|
- return;
|
|
|
- }
|
|
|
- if(pksPlanItemRet.errorCode != 0 || pksPlanItemRet.result == void 0){
|
|
|
+ let pksPlanItemData = await getPksPlanItem(gLotteryCode);
|
|
|
+ if(!pksPlanItemData){
|
|
|
return;
|
|
|
}
|
|
|
- if(pksPlanItemRet.result.businessCode != 0){
|
|
|
- return;
|
|
|
- }
|
|
|
- let pksPlanItemData = pksPlanItemRet.result.data;
|
|
|
+
|
|
|
if(pksPlanItemData.lotteryStatus != 0){
|
|
|
return;
|
|
|
}
|
|
|
@@ -304,6 +292,15 @@ function checkPlanABuyNotify(pksPlanItemData, pksPlanListData){
|
|
|
}
|
|
|
|
|
|
async function getPksPlanList(lotCode, date, rows=30) {
|
|
|
+ let cacheData = magicJS.data.read('168_PksPlanListDataCache', null);
|
|
|
+ if(cacheData){
|
|
|
+ let preDrawDate = new Date(date + ' ' + cacheData.preDrawTime);
|
|
|
+ if(Date.now() < preDrawDate.getTime()){
|
|
|
+ magicJS.logger.info('PksPlanList缓存数据');
|
|
|
+ return cacheData;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
const url = `https://${gHost}/api/LotteryPlan/getPksPlanList.do?lotCode=${lotCode}&rows=${rows}&date=${date}`;
|
|
|
magicJS.logger.info(url);
|
|
|
const myRequest = {
|
|
|
@@ -333,7 +330,19 @@ async function getPksPlanList(lotCode, date, rows=30) {
|
|
|
const msg = `请求发生异常\n${JSON.stringify(err)}`;
|
|
|
magicJS.logger.error(msg);
|
|
|
});
|
|
|
- return result;
|
|
|
+
|
|
|
+
|
|
|
+ if(!result){
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ if(result.errorCode != 0 || result.result == void 0){
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ if(result.result.businessCode != 0){
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ magicJS.data.write('168_PksPlanListDataCache', JSON.stringify(result.result.data));
|
|
|
+ return result.result.data;
|
|
|
}
|
|
|
|
|
|
async function pingPksPlan(date, rows=30) {
|
|
|
@@ -386,7 +395,16 @@ async function getPksPlanItem(lotCode) {
|
|
|
const msg = `请求发生异常\n${JSON.stringify(err)}`;
|
|
|
magicJS.logger.error(msg);
|
|
|
});
|
|
|
- return result;
|
|
|
+ if(!result){
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ if(result.errorCode != 0 || result.result == void 0){
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ if(result.result.businessCode != 0){
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ return result.result.data;
|
|
|
}
|
|
|
|
|
|
Main().catch((e) => magicJS.logger.log(`-\n ${e}`)).finally(() => magicJS.done());
|