contrast_ai/framework/model/job.mod.php

<?php
/**
 * [WeEngine System] Copyright (c) 2014 WE7.CC
 * WeEngine is NOT a free software, it under the license terms, visited http://www.we7.cc/ for more details.
 */
defined('IN_IA') or exit('Access Denied');



function job_list($uid, $isfounder = false) {
	$table = table('core_job')->where('isdeleted',0);
	if (!$isfounder) {
		
		$table->where('uid', $uid);
	}
	return $table->getall('id');
}



function job_single($id) {
	return table('core_job')->getById($id);
}



function job_create_delete_account($uniacid, $accountName, $uid) {
	$core_count = table('core_attachment')->where('uniacid', $uniacid)->count();
	$wechat_count = table('wechat_attachment')->where('uniacid', $uniacid)->count();
	$total = $core_count + intval($wechat_count);
	return table('core_job')->createDeleteAccountJob($uniacid, $accountName, $total, $uid);
}

function job_execute($id) {
	$job = job_single($id);

	$type = $job['type'];
	if (intval($job['status']) == 1) {
		return error(1, '任务已结束');
	}
	$result = null;
	switch ($type) {
		case $type : $result = job_execute_delete_account($job); break;
	}
	return $result;
}


function job_execute_delete_account($job) {
	$uniacid = $job['uniacid'];
	
	$core_attchments = table('core_attachment')
		->where('uniacid', $uniacid)
		->searchWithPage(1, 10)
		->getall('id');
	$wechat_attachments = table('wechat_attachment')
		->where('uniacid', $uniacid)
		->searchWithPage(1, 10)
		->getall('id');
	
	if (count($core_attchments) == 0 && count($wechat_attachments) == 0) {
		table('core_attachment_group')->where('uniacid', $uniacid)->delete();
		table('core_job')
			->where('id', $job['id'])
			->fill('status', 1)
			->fill('endtime', TIMESTAMP)
			->save();
		return error(0,  array('finished' => 1, 'progress' => 100, 'id' => $job['id'], 'endtime' => TIMESTAMP));
	}

	array_walk($core_attchments, function($item) {
		$path = $item['attachment'];
		file_delete($path);
	});

	array_walk($wechat_attachments, function($item) {
		$path = $item['attachment'];
		file_delete($path);
	});

	
	$core_ids = array_keys($core_attchments);
	$wechat_ids = array_keys($wechat_attachments);

	if (count($core_ids) > 0) {
		table('core_attachment')->deleteById($core_ids);
	}
	if (count($wechat_ids) > 0) {
		table('wechat_attachment')->deleteById($wechat_ids);
	}

	$handled = count($core_ids) + count($wechat_ids);
	table('core_job')
		->where('id', $job['id'])
		->fill('handled', $handled)
		->fill('status', 1)
		->fill('endtime', TIMESTAMP)
		->fill('updatetime',TIMESTAMP)
		->save();
	return error(0, array('finished' => 1, 'progress' => 100, 'id'=>$job['id'], 'endtime' => TIMESTAMP));

}


function job_clear($uid, $isfounder = false) {
	return table('core_job')->clear($uid, $isfounder);
}