|
@@ -311,10 +311,7 @@ async function getMarketWorksData(seriesId, status, sort, pageSize, pageNum) {
|
|
|
status: status,
|
|
status: status,
|
|
|
};
|
|
};
|
|
|
let result = await hbRequest({ API: '/mall/works/page', METHOD: 'get' }, reqData);
|
|
let result = await hbRequest({ API: '/mall/works/page', METHOD: 'get' }, reqData);
|
|
|
- if (result.code == 200) {
|
|
|
|
|
- return result.data;
|
|
|
|
|
- }
|
|
|
|
|
- return null;
|
|
|
|
|
|
|
+ return result;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
async function filterStableWorksData(seriesId, limitPrice, priceFloatInterval) {
|
|
async function filterStableWorksData(seriesId, limitPrice, priceFloatInterval) {
|
|
@@ -322,12 +319,19 @@ async function filterStableWorksData(seriesId, limitPrice, priceFloatInterval) {
|
|
|
let pageNum = 1;
|
|
let pageNum = 1;
|
|
|
let retMateItem = null;
|
|
let retMateItem = null;
|
|
|
while (pageNum < 100) {
|
|
while (pageNum < 100) {
|
|
|
- let pageData = await getMarketWorksData(seriesId, 1, 1, 50, pageNum);
|
|
|
|
|
- if (!pageData) {
|
|
|
|
|
|
|
+ let pageDataRet = await getMarketWorksData(seriesId, 1, 1, 50, pageNum);
|
|
|
|
|
+ if (!pageDataRet) {
|
|
|
await magicJS.utils.sleep(500);
|
|
await magicJS.utils.sleep(500);
|
|
|
continue;
|
|
continue;
|
|
|
}
|
|
}
|
|
|
- let itemList = pageData.list;
|
|
|
|
|
|
|
+ if(pageDataRet.code == 217){
|
|
|
|
|
+ // token失效
|
|
|
|
|
+ break;
|
|
|
|
|
+ }
|
|
|
|
|
+ if(pageDataRet.code != 200){
|
|
|
|
|
+ break;
|
|
|
|
|
+ }
|
|
|
|
|
+ let itemList = pageDataRet.data.list;
|
|
|
for (let i = 0; i < itemList.length; i++) {
|
|
for (let i = 0; i < itemList.length; i++) {
|
|
|
if (itemList[i].priceCny <= limitPrice + priceFloatInterval && itemList[i].worksStatus == 6) {
|
|
if (itemList[i].priceCny <= limitPrice + priceFloatInterval && itemList[i].worksStatus == 6) {
|
|
|
retMateItem = itemList[i];
|
|
retMateItem = itemList[i];
|