721 lines
18 KiB
PHP
721 lines
18 KiB
PHP
<?php
|
|
/**
|
|
* Heihe 黑河项目通用类
|
|
*/
|
|
//namespace Heihe;
|
|
|
|
class Heihe
|
|
{
|
|
|
|
private $db;//传入PDO对象
|
|
|
|
//使用到的公共变量
|
|
public $tbl_heiheproject = "heiheproject" ; //黑河项目表
|
|
public $tbl_heiheuser = "heiheuser"; //黑河用户表
|
|
public $project_status; //汇交项目计划状态
|
|
|
|
function __construct($db)
|
|
{
|
|
$this->db = $db;
|
|
|
|
$this->project_status = array(
|
|
0 => "计划未提交",
|
|
1 => "计划未审核",
|
|
2 => "跟踪专家审核",
|
|
3 => "跟踪专家通过",
|
|
4 => "数据委员会通过"
|
|
);
|
|
|
|
}
|
|
|
|
//获取所有计划
|
|
public function fetch()
|
|
{
|
|
$sql = "SELECT * FROM {$this->tbl_heiheproject}
|
|
ORDER BY id ASC";
|
|
$sth = $this->db->query($sql);
|
|
$rows = $sth->fetchAll();
|
|
return $rows;
|
|
}
|
|
|
|
//计划内的yuan数据
|
|
public function metadata($keyword = "")
|
|
{
|
|
if(empty($keyword))
|
|
$wheresql = "";
|
|
|
|
else{
|
|
$wheresql = [];
|
|
|
|
$keyword = trim($keyword);
|
|
$keyword = str_replace("'","''",$keyword);
|
|
|
|
$wheresql[] = " md.title LIKE '%$keyword%' ";
|
|
$wheresql[] = " md.title_en LIKE '%$keyword%'";
|
|
$wheresql[] = " md.description LIKE '%$keyword%' ";
|
|
|
|
$wheresql = " WHERE " . join(" OR ",$wheresql);
|
|
}
|
|
|
|
$sql = "SELECT md.*,s.viewed,g.id as gid,gen.id as genid,st.status as mdstatus,ds.id as datasetid,fund.title as heihe_fund_title FROM metadata md
|
|
LEFT JOIN mdfund mf ON mf.uuid = md.uuid
|
|
RIGHT JOIN fund ON fund.id = mf.fid
|
|
RIGHT JOIN heiheproject hh ON hh.code = fund.fund_id
|
|
LEFT JOIN mdstat s ON md.uuid=s.uuid
|
|
LEFT JOIN geonetworkmetadata g ON g.uuid=md.uuid
|
|
LEFT JOIN mdstatus st ON md.uuid=st.uuid
|
|
LEFT JOIN dataset ds ON md.uuid=ds.uuid
|
|
LEFT JOIN en.geonetworkmetadata gen on gen.uuid=md.uuid
|
|
$wheresql
|
|
ORDER BY md.id";
|
|
|
|
$rs = $this->db->query($sql);
|
|
return $rs->fetchAll(\PDO::FETCH_ASSOC);
|
|
}
|
|
|
|
|
|
//获取汇交状态
|
|
public function getStatus($code){
|
|
|
|
$status = $this->project_status;
|
|
|
|
if(isset($status[$code]))
|
|
{
|
|
return $status[$code];
|
|
}
|
|
|
|
}
|
|
|
|
//改变状态
|
|
public function ChangeStatus($p,$s){
|
|
|
|
$sql = "UPDATE ".$this->tbl_heiheproject." SET status=? WHERE id=?";
|
|
|
|
$sth = $this->db->prepare($sql);
|
|
|
|
$rs = $sth->execute(array($s,$p));
|
|
|
|
return $rs;
|
|
|
|
}
|
|
|
|
//专家激活
|
|
public function expertActive($pid,$code,$email)
|
|
{
|
|
|
|
if(empty($pid))
|
|
{
|
|
return 1;
|
|
}
|
|
|
|
if(!is_numeric($pid))
|
|
{
|
|
return 1;
|
|
}
|
|
|
|
if(!preg_match("/[A-Za-z0-9]/",$code))
|
|
{
|
|
return 1;
|
|
}
|
|
|
|
if(strlen($code) != 12)
|
|
{
|
|
return 1;
|
|
}
|
|
|
|
$validation = $this->makeValidation($email);
|
|
|
|
if($code != $validation)
|
|
{
|
|
return 5;
|
|
}
|
|
|
|
$experts = $this->expertRead($pid);
|
|
|
|
if(!is_array($experts))
|
|
{
|
|
return 10;
|
|
}
|
|
|
|
$matched = false;
|
|
$match_expert = "";
|
|
foreach($experts as $k=>$v)
|
|
{
|
|
if($v['validation'] == $code)
|
|
{
|
|
$matched = true;
|
|
$match_expert = $v;
|
|
unset($experts[$k]);
|
|
break;
|
|
}
|
|
}
|
|
|
|
if($matched != true)
|
|
{
|
|
return 15;
|
|
}
|
|
|
|
if(isset($match_expert['activated']))
|
|
{
|
|
if(strtotime($match_expert['activated']) < time())
|
|
{
|
|
return 20;
|
|
}
|
|
}
|
|
|
|
$match_expert['activated'] = date("Y-m-d H:i:s",time());
|
|
|
|
$experts[] = $match_expert;
|
|
|
|
$experts = json_encode($experts);
|
|
|
|
$this->expertUpdate($pid,$experts);
|
|
|
|
return 200;
|
|
|
|
}
|
|
|
|
public function expertActiveError($level){
|
|
|
|
$errors = array(
|
|
1 => "参数错误",
|
|
5 => "您的验证码不正确",
|
|
10 => "此项目尚未邀请任何专家",
|
|
15 => "您没有被邀请，请联系数据中心进行核实",
|
|
20 => "您的邀请已经激活",
|
|
50 => "服务器错误，请刷新页面重试",
|
|
200 => "激活成功",
|
|
);
|
|
if(isset($errors[$level]))
|
|
return $errors[$level];
|
|
else
|
|
return "发生意外错误，请重试";
|
|
|
|
}
|
|
|
|
//邀请一个专家
|
|
/*
|
|
$data = array(
|
|
"name"=>'', //专家姓名
|
|
"email"=>'', //专家email
|
|
"created"=>'', //邀请时间
|
|
"validation"=>'', //验证码
|
|
"activated"=>'' //激活时间
|
|
)
|
|
*/
|
|
public function expertAdd($pid,$data){
|
|
|
|
if(!is_array($data))
|
|
{
|
|
return 0;
|
|
}
|
|
|
|
$experts = $this->expertRead($pid);
|
|
|
|
if(!is_array($experts))
|
|
{
|
|
$experts = array($data);
|
|
}else{
|
|
foreach($experts as $k=>$v)
|
|
{
|
|
if($v['email'] == $data['email'])
|
|
{
|
|
return -1;
|
|
}
|
|
}
|
|
$experts[] = $data;
|
|
}
|
|
|
|
$experts = json_encode($experts,JSON_NUMERIC_CHECK);
|
|
|
|
return $this->expertUpdate($pid,$experts);
|
|
|
|
}
|
|
|
|
//移除一个专家
|
|
public function expertRemove($pid,$email){
|
|
|
|
if(empty($pid) || empty($email))
|
|
{
|
|
return 0;
|
|
}
|
|
|
|
$experts = $this->expertRead($pid);
|
|
|
|
if(!is_array($experts))
|
|
{
|
|
return -1;
|
|
}else{
|
|
foreach($experts as $k=>$v)
|
|
{
|
|
if(isset($v['email']) && $v['email'] == $email)
|
|
{
|
|
unset($experts[$k]);
|
|
}
|
|
}
|
|
}
|
|
$experts = json_encode($experts);
|
|
|
|
return $this->expertUpdate($pid,$experts);
|
|
}
|
|
|
|
//更新专家
|
|
public function expertUpdate($pid,$obj){
|
|
|
|
$sql = "UPDATE ".$this->tbl_heiheproject." SET expert='$obj' WHERE id=$pid";
|
|
$rs = $this->db->exec($sql);
|
|
return $rs;
|
|
|
|
}
|
|
|
|
//读取已有的专家
|
|
public function expertRead($pid){
|
|
|
|
if(!is_numeric($pid))
|
|
{
|
|
return NULL;
|
|
}
|
|
|
|
$sql = "SELECT expert FROM ".$this->tbl_heiheproject." WHERE id=$pid";
|
|
$rs = $this->db->query($sql);
|
|
$row = $rs->fetch();
|
|
|
|
$expert = $row['expert'];
|
|
|
|
if(empty($expert))
|
|
{
|
|
return NULL;
|
|
}
|
|
|
|
$expert = json_decode($expert,true);
|
|
|
|
if(count($expert)<1)
|
|
{
|
|
return 0;
|
|
}else{
|
|
return $expert;
|
|
}
|
|
|
|
}
|
|
|
|
//邀请码
|
|
public function makeValidation($email){
|
|
return substr(md5($email),5,12);
|
|
}
|
|
|
|
//生成邀请连接
|
|
public function makeInviteLink($pid,$code)
|
|
{
|
|
$http_base = "http://".$_SERVER ['HTTP_HOST'];
|
|
$url = $http_base."/heihe/projects/invite/".$code.'/pid/'.$pid;
|
|
return $url;
|
|
}//生成邀请连接
|
|
|
|
|
|
//从pgsql读取数组并拆分为php数组
|
|
public function getArray($str){
|
|
if(strlen($str)>3)
|
|
{
|
|
return explode(",",substr($str,1,-1));
|
|
}else{
|
|
return NULL;
|
|
}
|
|
}
|
|
|
|
//将php数组组装成pgsql中的数组
|
|
public function mkArray($array){
|
|
if(!is_array($array))
|
|
{
|
|
return "{".$array."}";
|
|
}
|
|
if(count($array)==1)
|
|
{
|
|
$key = max(array_keys($array));
|
|
return "{".$array[$key]."}";
|
|
}
|
|
if(count($array)>1)
|
|
{
|
|
return "{".join(",",$array)."}";
|
|
}
|
|
}
|
|
|
|
//从数组中获得键名
|
|
public function getKey($array,$needle)
|
|
{
|
|
foreach($array as $k=>$v)
|
|
{
|
|
if($v == $needle)
|
|
{
|
|
return $k;
|
|
}
|
|
}
|
|
}
|
|
|
|
}
|
|
|
|
class Status{
|
|
|
|
public $fund_id;
|
|
|
|
function __construct()
|
|
{
|
|
$this->db = \Zend_Registry::get('db');
|
|
}
|
|
|
|
public function makeConditionFound($field)
|
|
{
|
|
if(empty($this->fund_id))
|
|
{
|
|
return null;
|
|
}
|
|
|
|
$str = join("','",$this->fund_id);
|
|
return "$field IN ('". $str . "')";
|
|
}
|
|
|
|
public function makeWhereSql($array)
|
|
{
|
|
if(is_array($array) && count($array) > 0)
|
|
return " WHERE " . join(" AND ",$array);
|
|
else
|
|
return "";
|
|
}
|
|
|
|
//项目总数
|
|
public function projectsCount()
|
|
{
|
|
$fund = $this->makeConditionFound("hh.code");
|
|
if(!empty( $fund ))
|
|
{
|
|
$wheresql = $this->makeWhereSql(array($fund));
|
|
}else{
|
|
$wheresql = "";
|
|
}
|
|
|
|
$sql = "SELECT count(hh.code) as c FROM heiheproject hh $wheresql";
|
|
$rs = $this->db->query($sql);
|
|
return $rs->fetchColumn(0);
|
|
}
|
|
|
|
//数据条数
|
|
public function dataCount()
|
|
{
|
|
$arr = [
|
|
"md.uuid IS NOT NULL",
|
|
];
|
|
|
|
$fund = $this->makeConditionFound("fund.fund_id");
|
|
if(!empty($fund))
|
|
$arr[] = $fund;
|
|
|
|
$wheresql = $this->makeWhereSql($arr);
|
|
|
|
$sql = "SELECT count(md.uuid) as c FROM metadata md
|
|
LEFT JOIN mdfund mf ON mf.uuid = md.uuid
|
|
RIGHT JOIN fund ON fund.id = mf.fid
|
|
RIGHT JOIN heiheproject hh ON hh.code = fund.fund_id
|
|
$wheresql";
|
|
|
|
$rs = $this->db->query($sql);
|
|
return $rs->fetchColumn(0);
|
|
}
|
|
|
|
//数据量
|
|
public function dataSize()
|
|
{
|
|
$arr = [
|
|
"md.uuid IS NOT NULL"
|
|
];
|
|
|
|
$fund = $this->makeConditionFound("fund.fund_id");
|
|
if(!empty($fund))
|
|
$arr[] = $fund;
|
|
|
|
$wheresql = $this->makeWhereSql($arr);
|
|
|
|
$sql = "SELECT SUM(md.filesize) as c FROM metadata md
|
|
LEFT JOIN mdfund mf ON mf.uuid = md.uuid
|
|
RIGHT JOIN fund ON fund.id = mf.fid
|
|
RIGHT JOIN heiheproject hh ON hh.code = fund.fund_id
|
|
$wheresql";
|
|
$rs = $this->db->query($sql);
|
|
return $rs->fetchColumn(0);
|
|
}
|
|
|
|
//文件数
|
|
public function fileCount()
|
|
{
|
|
$arr = [
|
|
"md.uuid IS NOT NULL",
|
|
"df.filename !~ E'[/|\]+$'"
|
|
];
|
|
|
|
$fund = $this->makeConditionFound("fund.fund_id");
|
|
if(!empty($fund))
|
|
$arr[] = $fund;
|
|
|
|
$wheresql = $this->makeWhereSql($arr);
|
|
|
|
$sql = "SELECT count(df.id) FROM metadata md
|
|
LEFT JOIN mdfund mf ON mf.uuid = md.uuid
|
|
RIGHT JOIN fund ON fund.id = mf.fid
|
|
RIGHT JOIN heiheproject hh ON hh.code = fund.fund_id
|
|
RIGHT JOIN dataset ds ON ds.uuid = md.uuid
|
|
RIGHT JOIN datafile df ON ds.id = df.dsid
|
|
$wheresql";
|
|
|
|
$rs = $this->db->query($sql);
|
|
return $rs->fetchColumn(0);
|
|
}
|
|
|
|
//数据申请数量
|
|
public function dataApplyTimes()
|
|
{
|
|
$arr = [
|
|
"md.uuid IS NOT NULL",
|
|
"(o.offlineappid <> -1 OR o.onlineappid <> -1)"
|
|
];
|
|
|
|
$fund = $this->makeConditionFound("fund.fund_id");
|
|
if(!empty($fund))
|
|
$arr[] = $fund;
|
|
|
|
$wheresql = $this->makeWhereSql($arr);
|
|
|
|
$sql = "SELECT count(distinct o.id) as c FROM metadata md
|
|
LEFT JOIN mdfund mf ON mf.uuid = md.uuid
|
|
RIGHT JOIN fund ON fund.id = mf.fid
|
|
RIGHT JOIN heiheproject hh ON hh.code = fund.fund_id
|
|
RIGHT JOIN dataorder o ON o.uuid = md.uuid
|
|
$wheresql";
|
|
$rs = $this->db->query($sql);
|
|
return $rs->fetchColumn(0);
|
|
}
|
|
|
|
//服务人次
|
|
public function applyTimes()
|
|
{
|
|
$arr = [
|
|
"md.uuid IS NOT NULL",
|
|
"(o.offlineappid <> -1 OR o.onlineappid <> -1)"
|
|
];
|
|
|
|
$fund = $this->makeConditionFound("fund.fund_id");
|
|
if(!empty($fund))
|
|
$arr[] = $fund;
|
|
|
|
$wheresql = $this->makeWhereSql($arr);
|
|
|
|
$sql = "SELECT count(distinct o.offlineappid) as c FROM metadata md
|
|
LEFT JOIN mdfund mf ON mf.uuid = md.uuid
|
|
RIGHT JOIN fund ON fund.id = mf.fid
|
|
RIGHT JOIN heiheproject hh ON hh.code = fund.fund_id
|
|
RIGHT JOIN dataorder o ON o.uuid = md.uuid
|
|
$wheresql";
|
|
$rs = $this->db->query($sql);
|
|
return $rs->fetchColumn(0);
|
|
|
|
}
|
|
|
|
//服务人次(用户唯一)
|
|
public function applyTimesDistinct()
|
|
{
|
|
|
|
$arr = [
|
|
"md.uuid IS NOT NULL",
|
|
"(o.offlineappid <> -1 OR o.onlineappid <> -1)"
|
|
];
|
|
|
|
$fund = $this->makeConditionFound("fund.fund_id");
|
|
if(!empty($fund))
|
|
$arr[] = $fund;
|
|
|
|
$wheresql = $this->makeWhereSql($arr);
|
|
|
|
$sql = "SELECT count(distinct o.userid) as c FROM metadata md
|
|
LEFT JOIN mdfund mf ON mf.uuid = md.uuid
|
|
RIGHT JOIN fund ON fund.id = mf.fid
|
|
RIGHT JOIN heiheproject hh ON hh.code = fund.fund_id
|
|
RIGHT JOIN dataorder o ON o.uuid = md.uuid
|
|
$wheresql";
|
|
$rs = $this->db->query($sql);
|
|
return $rs->fetchColumn(0);
|
|
}
|
|
|
|
//每个用户数据申请量
|
|
public function downloadTimesByData()
|
|
{
|
|
$sql = "SELECT o.userid,count(o.id) FROM metadata md
|
|
LEFT JOIN mdfund mf ON mf.uuid = md.uuid
|
|
RIGHT JOIN fund ON fund.id = mf.fid
|
|
RIGHT JOIN heiheproject hh ON hh.code = fund.fund_id
|
|
RIGHT JOIN dataorder o ON o.uuid = md.uuid
|
|
WHERE md.uuid IS NOT NULL AND (o.offlineappid <> -1 OR o.onlineappid <> -1)
|
|
GROUP BY o.userid";
|
|
$rs = $this->db->query($sql);
|
|
return $rs->fetchAll;
|
|
}
|
|
|
|
//详细的用户申请次数统计
|
|
public function downloadTimesByUser()
|
|
{
|
|
$sql = "SELECT u.id,u.username, u.realname ,count(o.id) as c FROM metadata md
|
|
LEFT JOIN mdfund mf ON mf.uuid = md.uuid
|
|
RIGHT JOIN fund ON fund.id = mf.fid
|
|
RIGHT JOIN heiheproject hh ON hh.code = fund.fund_id
|
|
RIGHT JOIN dataorder o ON o.uuid = md.uuid
|
|
LEFT JOIN users u ON u.id = o.userid
|
|
WHERE md.uuid IS NOT NULL AND (o.offlineappid <> -1 OR o.onlineappid <> -1)
|
|
GROUP BY u.id,u.username, u.realname";
|
|
|
|
$rs = $this->db->query($sql);
|
|
return $rs->fetchAll();
|
|
}
|
|
|
|
//为黑河计划项目服务的情况
|
|
public function serviceTimes($type = "offline")
|
|
{
|
|
if($type == 'offline')
|
|
{
|
|
$arr = ['ts_approved IS NOT NULL'];
|
|
}else{
|
|
$arr = [];
|
|
}
|
|
|
|
$fund = $this->makeConditionFound("project_id");
|
|
if(!empty($fund))
|
|
{
|
|
$arr[] = $fund;
|
|
}else{
|
|
$select = "SELECT DISTINCT code FROM heiheproject";
|
|
|
|
$rs = $this->db->query($select);
|
|
|
|
$code_statck = [];
|
|
|
|
while($row = $rs->fetch())
|
|
{
|
|
$code_statck[] = $row['code'];
|
|
}
|
|
|
|
$arr[] = " project_id IN ('".join("','" , $code_statck)."')";
|
|
}
|
|
|
|
$wheresql = $this->makeWhereSql($arr);
|
|
|
|
|
|
if($type == 'offline')
|
|
$sql = "SELECT count(id) FROM offlineapp $wheresql";
|
|
else
|
|
$sql = "SELECT count(id) FROM onlineapp $wheresql";
|
|
|
|
$rs = $this->db->query($sql);
|
|
|
|
return $rs->fetchColumn(0);
|
|
}
|
|
|
|
|
|
//服务数据大小
|
|
public function serviceFilesize($type = "offline")
|
|
{
|
|
if($type == 'offline')
|
|
{
|
|
$arr = ['off.ts_approved IS NOT NULL'];
|
|
}else{
|
|
$arr = [];
|
|
}
|
|
|
|
if($type == 'offline')
|
|
$fund = $this->makeConditionFound("off.project_id");
|
|
else
|
|
$fund = $this->makeConditionFound("ol.project_id");
|
|
|
|
if(!empty($fund))
|
|
{
|
|
$arr[] = $fund;
|
|
}else{
|
|
$select = "SELECT DISTINCT code FROM heiheproject";
|
|
|
|
$rs = $this->db->query($select);
|
|
|
|
$code_statck = [];
|
|
|
|
while($row = $rs->fetch())
|
|
{
|
|
$code_statck[] = $row['code'];
|
|
}
|
|
|
|
if($type == 'offline')
|
|
$arr[] = " off.project_id IN ('".join("','" , $code_statck)."')";
|
|
else
|
|
$arr[] = " ol.project_id IN ('".join("','" , $code_statck)."')";
|
|
}
|
|
|
|
$wheresql = $this->makeWhereSql($arr);
|
|
|
|
if($type == 'offline')
|
|
$sql = "SELECT SUM(md.filesize) /1024 as size FROM metadata md
|
|
LEFT JOIN dataorder o ON o.uuid=md.uuid
|
|
LEFT JOIN offlineapp off ON off.id = o.offlineappid
|
|
$wheresql";
|
|
else
|
|
$sql = "SELECT SUM(md.filesize) /1024 as size FROM metadata md
|
|
LEFT JOIN dataorder o ON o.uuid=md.uuid
|
|
LEFT JOIN onlineapp as ol ON ol.id = o.onlineappid
|
|
$wheresql";
|
|
|
|
$rs = $this->db->query($sql);
|
|
|
|
return $rs->fetchColumn(0);
|
|
}
|
|
|
|
//服务计划内的项目个数
|
|
public function serviceForProjects($type = "offline")
|
|
{
|
|
if($type == 'offline')
|
|
{
|
|
$arr = ['ts_approved IS NOT NULL'];
|
|
}else{
|
|
$arr = [];
|
|
}
|
|
|
|
$fund = $this->makeConditionFound("project_id");
|
|
if(!empty($fund))
|
|
{
|
|
$arr[] = $fund;
|
|
}else{
|
|
$select = "SELECT DISTINCT code FROM heiheproject";
|
|
|
|
$rs = $this->db->query($select);
|
|
|
|
$code_statck = [];
|
|
|
|
while($row = $rs->fetch())
|
|
{
|
|
$code_statck[] = $row['code'];
|
|
}
|
|
|
|
$arr[] = " project_id IN ('".join("','" , $code_statck)."')";
|
|
}
|
|
|
|
$wheresql = $this->makeWhereSql($arr);
|
|
|
|
if($type == 'offline')
|
|
$sql = "SELECT count(DISTINCT project_id) as c FROM offlineapp
|
|
$wheresql";
|
|
elseif($type == "online")
|
|
$sql = "SELECT count(DISTINCT project_id) as c FROM onlineapp
|
|
$wheresql";
|
|
else
|
|
$sql = "SELECT count(DISTINCT project_id) FROM
|
|
(SELECT DISTINCT off.project_id FROM offlineapp off UNION ALL SELECT DISTINCT ol.project_id FROM onlineapp ol) apply
|
|
$wheresql";
|
|
|
|
$rs = $this->db->query($sql);
|
|
|
|
return $rs->fetchColumn(0);
|
|
}
|
|
|
|
|
|
}
|