| 104 | } |
| 105 | |
| 106 | function doTask(itemToken,taskToken=null) { |
| 107 | let body = {"itemToken":itemToken} |
| 108 | return new Promise(resolve => { |
| 109 | $.get(taskUrl('doTask', body), async (err, resp, data) => { |
| 110 | try { |
| 111 | if (err) { |
| 112 | console.log(`${JSON.stringify(err)}`) |
| 113 | console.log(`${$.name} API请求失败，请检查网路重试`) |
| 114 | } else { |
| 115 | if (safeGet(data)) { |
| 116 | data = JSON.parse(data); |
| 117 | |
| 118 | if (data.retCode === '200') { |
| 119 | console.log(`任务完成成功`) |
| 120 | if(taskToken) { |
| 121 | await queryTask(taskToken) |
| 122 | await $.wait(5*1000) |
| 123 | await viewTask(taskToken) |
| 124 | await checkTask(itemToken) |
| 125 | } |
| 126 | } else { |
| 127 | console.log(`任务完成失败，${data.retMessage}`) |
| 128 | } |
| 129 | } |
| 130 | } |
| 131 | } catch (e) { |
| 132 | $.logErr(e, resp) |
| 133 | } finally { |
| 134 | resolve(); |
| 135 | } |
| 136 | }) |
| 137 | }) |
| 138 | } |
| 139 | function queryTask(taskToken){ |
| 140 | return new Promise(resolve => { |
| 141 | $.get({ |