mirror of https://gitee.com/zorlan/skycaiji
83 lines
2.3 KiB
PHP
83 lines
2.3 KiB
PHP
<?php
|
||
/* diy发布设置
|
||
*/
|
||
namespace plugin\release\diy;
|
||
use skycaiji\admin\model\DbCommon;
|
||
abstract class BaseDiy extends \skycaiji\admin\event\ReleaseBase{
|
||
public $release;//发布对象数据
|
||
public $releConfig;//发布配置
|
||
public $connection;//数据库配置
|
||
protected $db;//数据库对象
|
||
public function __construct(){
|
||
parent::__construct();
|
||
if(config('app_debug')!=true){
|
||
config('exception_tmpl',config('app_path').'/public/release_exception.tpl');//定义cms错误模板，ajax出错时方便显示
|
||
}
|
||
}
|
||
public function init($release=null){
|
||
if(empty($release)){
|
||
$release=array();
|
||
}
|
||
if(!empty($release)){
|
||
//通过发布设置加载配置
|
||
$releConfig=$release['config'];
|
||
$this->releConfig=$releConfig;//发布数据库配置
|
||
$this->release=$release;
|
||
}else{
|
||
exception('发布错误：配置加载失败！');
|
||
}
|
||
$this->init_load();
|
||
if(empty($this->connection)){
|
||
exception('发布错误：没有数据库配置');
|
||
}
|
||
if(!isset($this->connection['fields_strict'])){
|
||
//默认允许字段不存在
|
||
$this->connection['fields_strict']=false;
|
||
}
|
||
|
||
//实例化数据库
|
||
try {
|
||
$mdb=new DbCommon($this->connection);
|
||
$this->db=$mdb->db();
|
||
}catch (\Exception $ex){
|
||
exception('发布错误：'.$ex->getMessage());
|
||
}
|
||
$this->init_extend();
|
||
}
|
||
/*初始化载入*/
|
||
public function init_load(){}
|
||
public function init_extend(){}
|
||
/**
|
||
* 参照thinkphp5数据库操作
|
||
* @return Ambigous <\think\db\Query, NULL>
|
||
*/
|
||
public function db(){
|
||
return $this->db;
|
||
}
|
||
/**
|
||
* 导出数据
|
||
* @param string $url 采集的页面网址
|
||
* @param array $fields 采集到的字段数据
|
||
*/
|
||
public function runExport($url,$fields){
|
||
//数据库编码
|
||
$dbCharset=strtolower($this->connection['db_charset']);
|
||
if(empty($dbCharset)||$dbCharset=='utf-8'||$dbCharset=='utf8'){
|
||
//不转码
|
||
$dbCharset=null;
|
||
}
|
||
if(!empty($dbCharset)){
|
||
foreach ($fields as $k=>$v){
|
||
$fields[$k]['value']=$this->utf8_to_charset($dbCharset, $v['value']);//值转码
|
||
}
|
||
}
|
||
return $this->runImport($url,$fields);
|
||
}
|
||
/**
|
||
* 导入数据
|
||
* @param string $url 采集的页面网址
|
||
* @param array $fields 采集到的字段数据
|
||
*/
|
||
public abstract function runImport($url,$fields);
|
||
}
|
||
?>
|