279 lines
10 KiB
PHP
Executable File
279 lines
10 KiB
PHP
Executable File
<?php
|
||
|
||
namespace app\index\controller;
|
||
|
||
use app\common\Model\Areas;
|
||
use app\common\Model\Collection;
|
||
use app\common\Model\Department;
|
||
use app\common\Model\DepartmentMember;
|
||
use app\common\Model\File;
|
||
use app\common\Model\Member;
|
||
use app\common\Model\MemberAccount;
|
||
use app\common\Model\Organization;
|
||
use app\common\Model\Project;
|
||
use app\common\Model\ProjectAuth;
|
||
use app\common\Model\ProjectAuthNode;
|
||
use app\common\Model\ProjectCollection;
|
||
use app\common\Model\ProjectLog;
|
||
use app\common\Model\ProjectMember;
|
||
use app\common\Model\SourceLink;
|
||
use app\common\Model\Task;
|
||
use app\common\Model\TaskLike;
|
||
use app\common\Model\TaskMember;
|
||
use app\common\Model\TaskStages;
|
||
use app\common\Model\Notify;
|
||
use app\common\Model\TaskWorkflowRule;
|
||
use controller\BasicApi;
|
||
use Exception;
|
||
use Firebase\JWT\JWT;
|
||
use PDO;
|
||
use service\JwtService;
|
||
use service\MessageService;
|
||
use think\facade\Request;
|
||
|
||
|
||
/**
|
||
* 应用入口控制器
|
||
* @author Vilson
|
||
*/
|
||
class Index extends BasicApi
|
||
{
|
||
|
||
protected $siteName = 'pearProject';
|
||
|
||
public function index()
|
||
{
|
||
$this->success('后端部署成功');
|
||
}
|
||
|
||
/**
|
||
* 安装
|
||
*/
|
||
public function install()
|
||
{
|
||
|
||
$dataPath = env('root_path') . 'data/';
|
||
//数据库配置文件
|
||
$dbConfigFile = env('config_path') . 'database.php';
|
||
// 锁定的文件
|
||
$lockFile = $dataPath . 'install.lock';
|
||
$err = '';
|
||
|
||
if (is_file($lockFile)) {
|
||
$err = "当前已经安装{$this->siteName}，如果需要重新安装，请手动移除data/install.lock文件";
|
||
} else if (version_compare(PHP_VERSION, '7.0.0', '<')) {
|
||
$err = "当前版本(" . PHP_VERSION . ")过低，请使用PHP7.0以上版本";
|
||
} else if (!extension_loaded("PDO")) {
|
||
$err = "当前未开启PDO，无法进行安装";
|
||
} else if (!is_really_writable($dbConfigFile)) {
|
||
$open_basedir = ini_get('open_basedir');
|
||
if ($open_basedir) {
|
||
$dirArr = explode(PATH_SEPARATOR, $open_basedir);
|
||
if ($dirArr && in_array(__DIR__, $dirArr)) {
|
||
$err = '当前服务器因配置了open_basedir，导致无法读取父目录';
|
||
}
|
||
}
|
||
if (!$err) {
|
||
$err = '当前权限不足，无法写入配置文件application/database.php';
|
||
}
|
||
}
|
||
if ($err) {
|
||
$this->error($err);
|
||
}
|
||
|
||
$initData = isset($_POST['initData']) ? $_POST['initData'] : false;
|
||
// $mysqlHostname = isset($_POST['mysqlHost']) ? $_POST['mysqlHost'] : '127.0.0.1';
|
||
// $mysqlHostport = isset($_POST['mysqlHostport']) ? $_POST['mysqlHostport'] : 3306;
|
||
// $hostArr = explode(':', $mysqlHostname);
|
||
// if (count($hostArr) > 1) {
|
||
// $mysqlHostname = $hostArr[0];
|
||
// $mysqlHostport = $hostArr[1];
|
||
// }
|
||
// $mysqlUsername = isset($_POST['mysqlUsername']) ? $_POST['mysqlUsername'] : 'root';
|
||
// $mysqlPassword = isset($_POST['mysqlPassword']) ? $_POST['mysqlPassword'] : 'root';
|
||
// $mysqlDatabase = isset($_POST['mysqlDatabase']) ? $_POST['mysqlDatabase'] : 'pearProject';
|
||
// $mysqlPrefix = isset($_POST['mysqlPrefix']) ? $_POST['mysqlPrefix'] : 'pear_';
|
||
|
||
$mysqlHostname = config('database.hostname');
|
||
$mysqlHostport = config('database.hostport');
|
||
$mysqlUsername = config('database.username');
|
||
$mysqlPassword = config('database.password');
|
||
$mysqlDatabase = config('database.database');
|
||
$mysqlPrefix = config('database.prefix');
|
||
|
||
try {
|
||
ignore_user_abort();
|
||
set_time_limit(0);
|
||
//检测能否读取安装文件
|
||
$sql = @file_get_contents($dataPath . 'pearproject.sql');
|
||
if (!$sql) {
|
||
throw new Exception("无法读取data/pearproject.sql文件，请检查是否有读权限");
|
||
}
|
||
$sql = str_replace("`pms_", "`{$mysqlPrefix}", $sql);
|
||
$pdo = new PDO("mysql:host={$mysqlHostname};port={$mysqlHostport}", $mysqlUsername, $mysqlPassword, array(
|
||
PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
|
||
PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES utf8mb4"
|
||
));
|
||
|
||
//检测是否支持innodb存储引擎
|
||
$pdoStatement = $pdo->query("SHOW VARIABLES LIKE 'innodb_version'");
|
||
$result = $pdoStatement->fetch();
|
||
if (!$result) {
|
||
throw new Exception("当前数据库不支持innodb存储引擎，请开启后再重新尝试安装");
|
||
}
|
||
|
||
$pdo->query("CREATE DATABASE IF NOT EXISTS `{$mysqlDatabase}` CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci;");
|
||
|
||
$pdo->query("USE `{$mysqlDatabase}`");
|
||
|
||
$pdo->exec($sql);
|
||
|
||
// $config = @file_get_contents($dbConfigFile);
|
||
// $callback = function ($matches) use ($mysqlHostname, $mysqlHostport, $mysqlUsername, $mysqlPassword, $mysqlDatabase, $mysqlPrefix) {
|
||
// $field = ucfirst($matches[1]);
|
||
// $replace = ${"mysql{$field}"};
|
||
// if ($matches[1] == 'hostport' && $mysqlHostport == 3306) {
|
||
// $replace = '';
|
||
// }
|
||
// return "'{$matches[1]}'{$matches[2]}=>{$matches[3]}'{$replace}',";
|
||
// };
|
||
//
|
||
// $config = preg_replace_callback("/'(hostname|database|username|password|hostport|prefix)'(\s+)=>(\s+)(.*),/", $callback, $config);
|
||
// //检测能否成功写入数据库配置
|
||
// $result = @file_put_contents($dbConfigFile, $config);
|
||
//
|
||
// if (!$result) {
|
||
// throw new Exception("无法写入数据库信息到config/database.php文件，请检查是否有写权限");
|
||
// }
|
||
|
||
//检测能否成功写入lock文件
|
||
$result = @file_put_contents($lockFile, 1);
|
||
if (!$result) {
|
||
throw new Exception("无法写入安装锁定到data/install.lock文件，请检查是否有写权限");
|
||
}
|
||
if ($initData) {
|
||
$this->initData();
|
||
}
|
||
$this->success('安装成功，请登录');
|
||
} catch (PDOException $e) {
|
||
$err = $e->getMessage();
|
||
} catch (Exception $e) {
|
||
$err = $e->getMessage();
|
||
}
|
||
if ($err) {
|
||
$this->error($err);
|
||
}
|
||
$this->success('安装成功，请登录');
|
||
|
||
}
|
||
|
||
public function checkInstall()
|
||
{
|
||
$dataPath = env('root_path') . '/data/';
|
||
// 锁定的文件
|
||
$lockFile = $dataPath . '/install.lock';
|
||
if (!is_file($lockFile)) {
|
||
$this->error('', 201);
|
||
}
|
||
$this->success();
|
||
}
|
||
|
||
/**
|
||
* @throws Exception
|
||
*/
|
||
public function initData()
|
||
{
|
||
// $member = Member::where("account = 123456")->find();
|
||
// $memberCode = $member['code'];
|
||
Member::where("account <> '123456'")->delete();
|
||
MemberAccount::where("id > 21")->delete();
|
||
Collection::where("id > 0")->delete();
|
||
Department::where("id > 0")->delete();
|
||
DepartmentMember::where("id > 0")->delete();
|
||
File::where("id > 0")->delete();
|
||
Organization::where("id > 1")->delete();
|
||
Project::where("id > 0")->delete();
|
||
ProjectAuth::where("id > 4")->delete();
|
||
ProjectAuthNode::where("auth not in (1,2,3,4)")->delete();
|
||
ProjectCollection::where("id > 0")->delete();
|
||
ProjectLog::where("id > 0")->delete();
|
||
ProjectMember::where("id > 0")->delete();
|
||
SourceLink::where("id > 0")->delete();
|
||
Task::where("id > 0")->delete();
|
||
TaskLike::where("id > 0")->delete();
|
||
TaskMember::where("id > 0")->delete();
|
||
TaskStages::where("id > 0")->delete();
|
||
Notify::where("id > 0")->delete();
|
||
}
|
||
|
||
/**
|
||
* 刷新token
|
||
*/
|
||
public function refreshAccessToken()
|
||
{
|
||
$refreshToken = Request::param('refreshToken', '');
|
||
$data = JwtService::decodeToken($refreshToken);
|
||
if (isError($data)) {
|
||
$this->error('token过期，请重新登录', 401);
|
||
}
|
||
$accessToken = JwtService::getAccessToken(get_object_vars($data->data));
|
||
$accessTokenExp = JwtService::decodeToken($accessToken)->exp;
|
||
$tokenList['accessTokenExp'] = $accessTokenExp;
|
||
$this->success('', ['accessToken' => $accessToken, 'accessTokenExp' => $accessTokenExp]);
|
||
|
||
}
|
||
|
||
/**
|
||
* 获取行政区划数据
|
||
*/
|
||
public function getAreaData()
|
||
{
|
||
$this->success('', Areas::createJsonForAnt());
|
||
|
||
}
|
||
|
||
/**
|
||
* 将webscoket的client_id和用户id进行绑定
|
||
* @param Request $request
|
||
*/
|
||
public function bindClientId(Request $request)
|
||
{
|
||
$clientId = $request::param('client_id');
|
||
$uid = $request::param('uid');
|
||
if (!$uid) {
|
||
$uid = getCurrentMember()['code'];
|
||
}
|
||
$messageService = new MessageService();
|
||
$messageService->bindUid($clientId, $uid);
|
||
$messageService->joinGroup($clientId, getCurrentOrganizationCode());
|
||
$this->success('', $uid);
|
||
}
|
||
|
||
public function createNotice(Request $request)
|
||
{
|
||
$data = $request::post();
|
||
$notifyModel = new \app\common\Model\Notify();
|
||
$result = $notifyModel->add($data['title'], $data['content'], $data['type'], $data['from'], $data['to'], $data['action'], $data['send_data'], $data['terminal']);
|
||
$messageService = new MessageService();
|
||
$messageService->sendToUid($data['to'], $data, $data['action']);
|
||
$this->success('', $result);
|
||
}
|
||
|
||
public function pushNotice(Request $request)
|
||
{
|
||
$uid = $request::param('uid');
|
||
$messageService = new MessageService();
|
||
$messageService->sendToUid($uid, '888', 'notice');
|
||
$this->success('', $messageService->isUidOnline($uid));
|
||
|
||
}
|
||
|
||
public function pushNoticeGroup(Request $request)
|
||
{
|
||
$group = $request::param('group');
|
||
$messageService = new MessageService();
|
||
$messageService->sendToGroup($group, '999', 'noticeGroup');
|
||
// $this->success('群组消息', $group);
|
||
}
|
||
}
|