timingTask24.js

/**
	
	每天24时执行脚本
	此脚本用于关闭24小时内没有任何新对话的话题。

*/

var Promise = require("./lib/Promise")
var RoomModel = require("./lib/RoomModel");
var ChatModel = require("./lib/ChatModel");


var promise = new Promise();

//话题查询
promise.then(function(){

	RoomModel.find({"$or":[{status:1},{status:null}]}, function( status ){

		if( status.code == 0 && status.result.length > 0 ){

			promise.ok( status );
		}


	});

});

//时间比较
promise.then(function( status ){

	var list = status.result;
	var i=0;
	var now = parseInt(Date.now()/1000);

	function start(){
		if(++i < list.length){
			console.log("topic, id", list[i].topic, list[i].id);
			compareTime( list[i].id )
		}else{
			console.log("完成");
		}
	}

	function compareTime( id ){
		ChatModel.findSort({roomid:String(id)}, {time:-1}, function( status ){
			//48小时未更新
			if( (status.code == 0 && 
				status.result[0] && 
				now - status.result[0].time > 60*60*24*2) || 
				status.code == 404){
				console.log("close", id);
				RoomModel.update({id:String(id)}, {status:0}, function(){
					start();
				});
			}else{
				start();
			}

		});
	}

	start();
});

promise.start();