jobTask.js

var sleep=(t)=>new Promise((y)=>setTimeout(y,t));
var Player=require("./player.js");
var testList=require("./work/testList.js");

class jobTask{
	constructor(classid,chapter,jobs,user,playerspeed,autotest){
		this.user=user;
		this.rawjobs=jobs.concat([]);
		this.jobs=jobs;
		this.taskend=false;
		this.clazzId=classid;
		this.chapter=chapter;
		this.autotest=autotest;

		this.indexes=0;
		this.currentPlayer=undefined;
		this.playerspeed=playerspeed;

		this.workinfo="测验器就绪中...";
		this.eventLoop();
	}
	async wait(timeout){
		let tick=0;
		if(!timeout)timeout=9999999;
		while(true){
			if(this.taskend)
				return;

			if(tick++>timeout)return;
			await sleep(500);
		}
	}
	getJobProgress(){
		return {current:this.rawjobs.length-this.jobs.length,total:this.rawjobs.length};
	}
	getStatusInfo(){
		if(!this.currentPlayer)return "播放器就绪中...\n\n"+this.workinfo+"\n";
		return this.currentPlayer.getStatusInfo()+"\n"+this.workinfo+"\n";

	}
	async doTick(){
		let job=this.jobs.shift();
		if(!job){this.taskend=true;return;}
		

		await this.handleJob(job);
		
		this.indexes++;
	}
	async handleJob(job){
		switch(job.type){
			case "video"://视频任务
				if(job.job){
					let player=new Player(this.clazzId,this.user,job,this.playerspeed);
					this.currentPlayer=player;
					await player.wait();
				}		
			break;
			case "workid"://测验
				let list=new testList(this.chapter.courseid,this.chapter.id,this.clazzId,job,this.user);
				let detail=await list.getDetail();
		

			if(detail.status==0){//还没做,尝试自动查答案过测验
			//	console.log("还没做,尝试自动查答案过测验");
			
		//	console.log(this.autotest);
				if(this.autotest){
					let {answers,count}=await list.queryAnswers(detail,0);

				//	console.log(answers)
					if(answers)
						await list.submitTest(detail,answers,detail.params,1);


					let info=`检测到未完成测验,共${detail.set.length}题,从题库查得答案:${count}题`;
					this.workinfo=info;
				}
			}else if(detail.status==2){
				await list.uploadUserAnswers(detail.set);
			}

		
			break;
		}
	}
	async eventLoop(){
		while(!this.taskend){
			try{
				await this.doTick();
			}catch(e){
				console.log(e);
			}
			await sleep(1000);
		}
	}
}



module.exports=jobTask;