示例：hadsky文章 -pg电子试玩免费

 'mysql',
			'db_user'  => $config['username'],
			'db_pwd'   => $config['password'],
			'db_host'  => $config['location'],
			'db_port'  => 3306,
			'db_name'  => $config['database'],
			'db_charset'  => $config['charset'],
			'db_prefix'  => $config['prefix']
		);
		
		return $cmsdb;
	}
	//参数
	public $_params = array (
		'author' => array (
			'name' => '作者账号',
			'require' => 1,
			'tag' => 'text',
		),
		'forum' => array (
			'name' => '版块id',
			'require' => 1,
			'tag' => 'select',
			'option' => 'function:param_option_forum',
		),
		'title' => array (
			'name' => '帖子标题',
			'require' => 1,
			'tag' => 'select',
			'option' => 'function:param_option_fields',
		),
		'content' => array (
			'name' => '帖子内容',
			'require' => 1,
			'tag' => 'select',
			'option' => 'function:param_option_fields',
		),
	);
	/*
	 * 导入数据
	* 必须以数组形式返回：
	* id（必填）表示入库返回的自增id或状态
	* target（可选）记录入库的数据位置（发布的网址等）
	* desc（可选）记录入库的数据位置附加信息
	* error（可选）记录入库失败的错误信息
	* 入库的信息可在“已采集数据”中查看
	* return array('id'=>0,'target'=>'','desc'=>'','error'=>'');
	*/
	public function runimport($params){
		$uid=$this->db()->table('__user__')->where(array('username'=>$params['author']))->find();
		if(!empty($uid)){
			$uid=$uid['id'];
		}else{
			return array('id'=>0,'error'=>'用户不存在');
		}
		
		$newread=array(
			'sortid'=>$params['forum'],
			'uid'=>$uid,
			'title'=>$params['title'],
			'content'=>$params['content'],
			'looknum'=>0,
			'zannum'=>0,
			'posttime'=>time(),
			'readlevel'=>0,
			'replyuid'=>$uid,
			'replycontent'=>null,
			'replytime'=>0,
			'replyip'=>null,
			'postip'=>'',
			'top'=>0,
			'high'=>0,
			'replyafterlook'=>0,
			'data'=>null,
			'del'=>0,
			'activetime'=>time(),
			'replyid'=>0,
			'fs'=>1,
			'label'=>''
		);
		
		$id=$this->db()->table('__read__')->insert($newread,false,true);//添加主题并返回id
		if($id>0){
			return array('id'=>$id,'target'=>'文章：'.$id);
		}else{
			return array('id'=>0,'error'=>'添加文章失败');
		}
	}
	
	/*
	 * 参数选项：版块
	 * 必须返回键值对形式的数组
	 */
	public function param_option_forum(){
		$forumsdb=$this->db()->table('__readsort__')->select();
		$forumlist=array();
		foreach ($forumsdb as $forum){
			$forumlist[$forum['id']]=auto_convert2utf8($forum['title']);
		}
		return $forumlist;
	}
}
?>