function toggleJobStatus(status, on){
  if(!Array.isArray(filters.jobStatus)) filters.jobStatus=[];
  filters.jobStatus=on?filters.jobStatus.concat(status):filters.jobStatus.filter(s=>s!==status);
  pageNo.jobs=1;
  render(false);
}
function jobActions(j){
  const open=j.status==='queued'||j.status==='running'||j.status==='challenge_required';
  return (open?'<button class="btn danger" onclick="cancelJob('+j.id+')">取消</button>':'')+
    (j.status==='failed'||j.status==='cancelled'?'<button class="btn" onclick="retryJob('+j.id+',\''+esc(j.type)+'\')">重试</button>':'')+
    (j.status==='challenge_required'?'<button class="btn pri" onclick="solve('+j.id+')">'+(j.challenge_type==='2sv'?'选择验证':'验证码')+'</button>':'');
}
function jobIsExtend(j){
  const p=jobPayload(j);
  return !!(p && (p.extend_path || p.extend_chain || Number(p.extend_step)>0));
}
function jobIsRotate(j){
  const p=jobPayload(j);
  return !!(p && (p.rotate_device || p.via==='after_rotate'));
}
function jobTypeLabel(j){
  if(jobIsRotate(j)) return '轮换设备';
  if(jobIsExtend(j)) return '加时';
  return typeName(j.type);
}
function viewJobs(){
  const types=['','login','rotate','keepalive','bind_instrument','redeem_gift','sku_details','purchase','sub_renew','extend','sub_refresh','sub_cancel','sub_ack'];
  const statuses=['queued','running','challenge_required','succeeded','failed','cancelled'];
  if(!Array.isArray(filters.jobStatus)) filters.jobStatus=filters.jobStatus?[filters.jobStatus]:[];
  const all=(cache.jobs||[]).filter(j=>{
    if(!j) return false;
    if(filters.jobType==='extend' && !jobIsExtend(j)) return false;
    if(filters.jobType==='rotate' && !jobIsRotate(j)) return false;
    if((filters.jobType==='keepalive' || filters.jobType==='login') && jobIsRotate(j)) return false;
    if(filters.jobType==='sub_renew' && jobIsExtend(j)) return false;
    if(filters.jobType && filters.jobType!=='extend' && filters.jobType!=='rotate' && j.type!==filters.jobType) return false;
    if(!filters.jobStatus.includes(j.status)) return false;
    return matchQ([j.email,j.type,j.status,j.error,String(j.id),String(j.account_id),jobSummary(j),jobTypeLabel(j)]);
  });
  const info=paginate(all,'jobs');
  const typeLabel=t=>t==='extend'?'加时':(t==='rotate'?'轮换设备':typeName(t));
  const chips='<div class="chips">'+types.map(t=>'<button class="btn'+(filters.jobType===t?' on':'')+'" onclick="filters.jobType=\''+t+'\'; pageNo.jobs=1; render._force=true; render(true)">'+(t?esc(typeLabel(t)):'全部')+'</button>').join('')+'</div>';
  const statusPick='<div class="job-statuses">'+statuses.map(s=>'<label><input type="checkbox" '+(filters.jobStatus.includes(s)?'checked':'')+' onchange="toggleJobStatus(\''+s+'\',this.checked)">'+esc(statusName(s))+'</label>').join('')+'</div>';
  const rows=info.slice.map(j=>{
    const open=j.status==='queued'||j.status==='running'||j.status==='challenge_required';
    return '<tr class="clickrow" data-row="job-'+j.id+'" onclick="jobClick(event,'+j.id+')">'+
      '<td class="muted">#'+j.id+'</td>'+
      '<td>'+esc(jobTypeLabel(j))+'</td>'+
      '<td class="clip" title="'+esc(j.email||'')+'">'+esc(j.email||('#'+j.account_id))+'</td>'+
      '<td class="nowrap" data-live="status">'+pill(j.status)+'</td>'+
      '<td class="muted nowrap" data-live="when">创建 '+fmtTime(j.created_at)+'<br>开始 '+fmtTime(j.started_at)+'<br>完成 '+fmtTime(j.finished_at)+'</td>'+
      '<td data-live="summary">'+jobSummaryHTML(j)+'</td>'+
      '<td class="actions nowrap" data-live="act">'+jobActions(j)+'</td></tr>';
  }).join('');
  $('#app').innerHTML=
    '<div class="card"><div class="toolbar job-bar-row">'+chips+'<span class="hint">'+all.length+' / '+(cache.jobs||[]).length+'</span>'+statusPick+'</div></div>'+
    '<div class="table-wrap"><table class="jobs"><colgroup><col class="c-id"><col class="c-type"><col class="c-acc"><col class="c-st"><col class="c-time"><col><col class="c-act"></colgroup><thead><tr><th>ID</th><th>类型</th><th>账号</th><th>状态</th><th>创建 / 开始 / 完成</th><th>摘要</th><th></th></tr></thead><tbody>'+
    (rows||'<tr><td colspan="7" class="empty">没有任务。</td></tr>')+
    '</tbody></table></div>'+pager('jobs', info);
}
async function cancelJob(id){
  const ok=await modal({title:'取消任务', message:'取消任务 #'+id+'？', okText:'取消任务', cancelText:'返回'});
  if(!ok) return;
  const j=await api('/api/jobs/'+id+'/cancel',{method:'POST',body:'{}'});
  if(j.error) return fail('无法取消', j.error);
  notice('已取消', '#'+id);
  render();
}

function outsideVaultCard(job){
  const p=jobPayload(job);
  const order=String((p.old_order_id||p.order_id)||'');
  if(!order) return null;
  const rec=(cache.purchases||[]).find(x=>x && Number(x.account_id)===Number(job.account_id) && String(x.order_id||'')===order);
  let last4=String((rec&&rec.card_last4)||'');
  if(!last4){
    const acc=(cache.accounts||[]).find(a=>a && Number(a.id)===Number(job.account_id));
    const card=((acc&&acc.cards)||[]).find(c=>c && c.last4);
    last4=String((card&&card.last4)||'');
  }
  if(!last4) return null;
  const card=(cache.cards||[]).find(c=>c && String(c.last4||'')===last4);
  if(!card) return last4;
  if(card.no_replay_concurrency) return last4+'（本卡已设置禁止并发）';
  return null;
}
async function retryProxyDialog(outsideLast4){
  let groups=[];
  try{
    const st=await api('/api/settings');
    groups=(st.proxy_groups||[]).filter(g=>g && (g.proxies||[]).length);
  }catch(e){}
  return new Promise(resolve=>{
    const root=$('#modalRoot');
    const rows=groups.map((g,i)=>{
      const n=(g.proxies||[]).length;
      return '<label class="mode-pick"><input type="radio" name="retryProxy" value="'+esc(g.name||'')+'"><span class="mode-copy"><strong>'+esc(g.name||'未命名')+'</strong><span class="muted">'+n+' 条，选中后每次重试随机换一条</span></span><input class="filter retry-egress" data-egress="'+i+'" value="http://127.0.0.1:10808" placeholder="出口中转，空则直连" onclick="event.stopPropagation()"></label>';
    }).join('');
    const outside=!!outsideLast4;
    root.innerHTML='<div class="modal-mask"><div class="modal wide"><h3>重试购买</h3>'+
      (outside?'<div class="warn-note">订单卡尾号 '+esc(outsideLast4)+' 不在本系统卡库。升级重试并发已锁定为 1。<button class="btn" type="button" id="unlockConc" style="margin-left:8px">解除锁定</button></div>':'')+
      '<div class="fields"><label>并发</label><input id="retryConc" type="number" value="'+(outside?1:5)+'" '+(outside?'disabled':'')+'><label>次数</label><input id="retryN" type="number" value="3000"></div>'+
      '<label class="mode-pick" style="margin-top:10px"><input type="checkbox" id="retryNow"><span class="mode-copy"><strong>马上插队执行</strong><span class="muted">默认否。选中后不受队列并发限制，立即开始</span></span></label>'+
      '<label class="mode-pick" style="margin-top:8px"><input type="checkbox" id="retryRotate"><span class="mode-copy"><strong>更换设备指纹登录后再重试</strong><span class="muted">先换设备并登录成功，再开始这次重试</span></span></label>'+
      '<label class="mode-pick" style="margin-top:8px"><input type="checkbox" id="retryPause" checked><span class="mode-copy"><strong>失败后换设备再继续</strong><span class="muted">累计失败达到次数就暂停，换设备指纹并登录成功后继续。0 或不选则不暂停</span></span><input class="filter retry-egress" id="retryPauseN" type="number" value="100" onclick="event.stopPropagation()"></label>'+
      '<div class="modal-sec">代理组</div><div class="muted" style="margin-bottom:8px">不选则沿用账号自己的代理。选中一组后，每次请求随机换 IP。每组后面是出口中转，默认 127.0.0.1:10808，留空则不走中转。</div>'+
      '<div class="mode-picks">'+(rows||'<div class="muted">还没有代理组</div>')+'</div>'+
      '<div class="actions" style="margin-top:14px"><button class="btn" id="mCancel">取消</button><button class="btn pri" id="mOk">重试</button></div></div></div>';
    const finish=v=>{ root.innerHTML=''; resolve(v); };
    let unlocked=!outside;
    const unlock=$('#unlockConc');
    if(unlock) unlock.onclick=async()=>{
      const ok=await modal({title:'解除并发锁定', message:'这张卡不在本系统卡库，并发重试可能打出多笔订单。确定要解除锁定并自行设置并发吗？', okText:'解除锁定', cancelText:'保持锁定', stack:true});
      if(!ok) return;
      unlocked=true;
      const input=$('#retryConc');
      if(input) input.disabled=false;
      unlock.disabled=true;
      unlock.textContent='已解除';
    };
    bindMaskClose(root, ()=>finish(null));
    $('#mCancel').onclick=()=>finish(null);
    $('#mOk').onclick=()=>{
      const radio=root.querySelector('input[name=retryProxy]:checked');
      let egress='';
      if(radio){
        const row=radio.closest('.mode-pick');
        egress=((row.querySelector('.retry-egress')||{}).value||'').trim();
      }
      const pauseOn=!!($('#retryPause')&&$('#retryPause').checked);
      finish({
        concurrency:(outside&&!unlocked)?1:Math.max(1, Number($('#retryConc').value||5)),
        unlock_concurrency:outside&&unlocked,
        attempts:Math.max(1, Number($('#retryN').value||3000)),
        group:radio?radio.value:'',
        egress:egress,
        immediate:!!($('#retryNow')&&$('#retryNow').checked),
        rotate:!!($('#retryRotate')&&$('#retryRotate').checked),
        rotate_every:pauseOn?Math.max(0, Number($('#retryPauseN').value||0)):0
      });
    };
    document.addEventListener('keydown', function onKey(e){
      if(e.key==='Escape'){ document.removeEventListener('keydown', onKey); finish(null); }
    });
  });
}

async function redeemRetryDialog(){
  return new Promise(resolve=>{
    const root=$('#modalRoot');
    root.innerHTML='<div class="modal-mask"><div class="modal"><h3>重试兑换</h3>'+
      '<div class="fields"><label>并发</label><input id="retryConc" type="number" value="30"><label>次数</label><input id="retryN" type="number" value="3000"></div>'+
      '<div class="muted" style="margin-top:8px">沿用账号自己的代理。兑换成功，或提示卡已被兑换，就停止。</div>'+
      '<label class="mode-pick" style="margin-top:10px"><input type="checkbox" id="retryNow"><span class="mode-copy"><strong>马上插队执行</strong><span class="muted">默认否。选中后不受队列并发限制，立即开始</span></span></label>'+
      '<div class="actions" style="margin-top:14px"><button class="btn" id="mCancel">取消</button><button class="btn pri" id="mOk">重试</button></div></div></div>';
    const finish=v=>{ root.innerHTML=''; resolve(v); };
    bindMaskClose(root, ()=>finish(null));
    $('#mCancel').onclick=()=>finish(null);
    $('#mOk').onclick=()=>finish({
      concurrency:Math.max(1, Number($('#retryConc').value||30)),
      attempts:Math.max(1, Number($('#retryN').value||3000)),
      immediate:!!($('#retryNow')&&$('#retryNow').checked)
    });
  });
}

async function retryJob(id, type){
  let body={};
  if(type==='purchase' || type==='sub_renew' || type==='extend' || type==='redeem_gift'){
    const job=(cache.jobs||[]).find(j=>j && Number(j.id)===Number(id));
    const outside=type==='redeem_gift'?null:(job?outsideVaultCard(job):null);
    const picked=type==='redeem_gift'?await redeemRetryDialog():await retryProxyDialog(outside);
    if(!picked) return;
    body={concurrency:picked.concurrency, attempts:picked.attempts, proxy_group:picked.group, proxy_egress:picked.egress, immediate:!!picked.immediate, rotate_device:!!picked.rotate, rotate_every:Number(picked.rotate_every||0), unlock_concurrency:!!picked.unlock_concurrency};
  }else{
    const ok=await modal({title:'重试任务', message:'重新入队任务 #'+id+'？', okText:'重试', cancelText:'取消'});
    if(!ok) return;
  }
  const j=await api('/api/jobs/'+id+'/retry',{method:'POST',body:JSON.stringify(body)});
  if(j.error) return fail('无法重试', j.error);
  notice('已重新入队', '#'+(j.job_id||id));
  refreshList();
}