adicn/phpcms/model/queue_model.class.php

<?php
defined('IN_PHPCMS') or exit('No permission resources.');
pc_base::load_sys_class('model', '', 0);
class queue_model extends model {
	public function __construct() {
		$this->db_config = pc_base::load_config('database');
		$this->db_setting = 'default';
		$this->table_name = 'queue';
		parent::__construct();
	}
		
	/**
	 * 添加同步队列
	 * @param string $type  操作类型{add:添加,edit:修改,del:删除}
	 * @param string $path 文档地址
	 * @param integer $siteid 站点ID
	 */
	final public function add_queue($type = 'add', $path, $siteid = '') {
		if (empty($siteid)) $siteid = get_siteid();
		$sites = pc_base::load_app_class('sites', 'admin');
		$site = $sites->get_by_id($siteid);
		if (empty($site['release_point'])) return false;
		
		if ($r = $this->get_one(array('type'=>$type, 'path'=>$path, 'siteid'=>$siteid), 'id')) {
			if ($this->update(array('status1'=>'0', 'status2'=>'0', 'status3'=>'0', 'status4'=>'0', 'times'=>SYS_TIME), array('id'=>$r['id']))) {
				return true;
			} else {
				return false;
			}
		} else {
			if ($this->insert(array('type'=>$type, 'path'=>$path, 'siteid'=>$siteid, 'times'=>SYS_TIME))) {
					return true;
				} else {
					return false;
			}
		}
	}
	
}
?>