' . $label . $output . ''; + + if ($echo) { + echo ($output); + return; + } + + return $output; +} + +/** + * 抛出业务异常 + * + * @param string $msg + * @param integer $code + * @return void + * @throws ErrorMsg + * @date 2022-12-27 + * @example + * @author admin + * @since 1.0.0 + */ +function throwErrorMsg(string $msg, int $code = 1): void +{ + throw new ErrorMsg($msg, $code); +} + +/** + * 计算年龄 + * + * @param string $birthday Y-m-d + * @return int + * @date 2022-03-11 + * @example + * @author admin + * @since 1.0.0 + */ +function sumAge($birthday): int +{ + $age = 0; + try { + if (!is_string($birthday)) { + throw new ErrorMsg("非法日期", 1); + } + $birthday = explode("-", date('Y-m-d', strtotime($birthday))); + $date = explode("-", date('Y-m-d')); + if (count($birthday) === 3) { + list($y, $m, $d) = $birthday; + } else { + list($y, $m, $d) = $date; + } + // list($y, $m, $d) = $birthday; + list($dy, $dm, $dd) = $date; + + $age = $dy - $y; + if ($dm >= $m) { + if ($dm == $m) { + if ($dd >= $d) { + } else { + $age--; + } + } + } else { + $age--; + } + return $age; + } catch (\Throwable $th) { + } + return $age; +} + +Validate::maker(function (ThinkValidate $validate) { + $validate->extend( + 'string', + function ($value) { + return is_string($value); + }, + ':attribute 数据类型非法 不是字符串' + ); +}); + +/** + * 接口返回封装 + */ +function msg(...$arr) +{ + $msg_data = ['code' => 0]; + $default_code_msg = [0 => '操作成功!', 1 => '操作失败!']; + + //data数据构建 + function constructData(&$msg_data, $code, $msg_str, &$arr2) + { + $msg_data['code'] = $code; + $msg_data['msg'] = $msg_str; + if (is_array($arr2)) { //数组 + $msg_data['data'] = $arr2; + } + if (is_object($arr2)) { //查询对象 + $obj = $arr2; + $soft_delete_field = '_delete_time'; //软删除默认后缀 + //模型层 || Db层 + if ($obj instanceof think\db\Query || $obj instanceof think\Collection) { + //join软删除字段过滤补全(暂时只适应软删除为 【前缀名_delete_time】存储为datetime 的设计) + if (isset($obj->getOptions()['join']) && $join_data = $obj->getOptions('join')) { + $join_soft_delete = []; + foreach ($join_data as $key => $join) { + $join_table_name = is_array($join[0]) ? array_keys($join[0])[0] : $join[0]; //联表表名 + $join_soft_delete[] = [$join_table_name . $soft_delete_field, 'NULL', null]; + } + $obj = $obj->where($join_soft_delete); + } + //select()、count()补全 + $msg_data['data'] = $obj->page((int) Request::param('page', 1), (int) Request::param('limit', 10))->select(); + $msg_data['count'] = $obj->count(); + } else { + return ['code' => 444, 'msg' => '对象只允许传递来自think\db\Query类和instanceof think\Collection类的实例!']; + } + } + }; + + switch (count($arr)) { + case 1: //单参数 + constructData($msg_data, 0, '查询成功!', $arr[0],); + if (is_string($arr[0])) $msg_data['msg'] = $arr[0]; + if (is_int($arr[0])) { + $msg_data['code'] = $arr[0]; + $msg_data['msg'] = $default_code_msg[$arr[0]]; + } + break; + case 2: //双参数 + if (is_int($arr[0]) && is_string($arr[1])) { + $msg_data['code'] = $arr[0]; + $msg_data['msg'] = $arr[1]; + } else { + constructData($msg_data, 0, $arr[0], $arr[1]); + } + break; + case 3: //三参数 + $msg_data['code'] = $arr[0]; + $msg_data['msg'] = $arr[1]; + if (is_object($arr[2])) { + $msg_data['data'] = $arr[2]; + } else { + foreach ($arr[2] as $key => $val) + $msg_data[$key] = $val; + } + break; + default: + return ['code' => 444, 'msg' => 'msg()最多参数只允许3个!']; + } + + return $msg_data; +} diff --git a/app/common/arw/adjfut/composer.json b/app/common/arw/adjfut/composer.json new file mode 100644 index 0000000..7991c90 --- /dev/null +++ b/app/common/arw/adjfut/composer.json @@ -0,0 +1,39 @@ +{ + "name": "arw/adjfut", + "type": "library", + "autoload": { + "psr-4": { + "arw\\adjfut\\": "src/" + } + }, + "authors": [{ + "name": "arw", + "email": "2679599887@qq.com" + }], + "require": { + "php": ">=7.1.0", + "phpoffice/phpspreadsheet": "^1.12", + "topthink/framework": "^6.0.0", + "topthink/think-filesystem": "^2.0" + }, + "config": { + "sort-packages": true + }, + "repositories": { + "packagist": { + "type": "composer", + "url": "https://mirrors.aliyun.com/composer/" + } + }, + "extra": { + "think": { + "services": [ + "arw\\adjfut\\Service\\Validate" + ], + "config": { + "wechat": "src/Config/wechat.php", + "chunkUpload": "src/Config/chunkUpload.php" + } + } + } +} diff --git a/app/common/arw/adjfut/src/ArrayFilter.php b/app/common/arw/adjfut/src/ArrayFilter.php new file mode 100644 index 0000000..dcd0ede --- /dev/null +++ b/app/common/arw/adjfut/src/ArrayFilter.php @@ -0,0 +1,170 @@ +data = $data; + } + + /** + * 二维数组排除字段 + * + * @param array $array + * @param array $except + * @return array + * @date 2023-01-13 + * @example + * @author arw + * @since 1.0.0 + */ + public static function exceptFields(array $array, array $except): array + { + foreach ($array as &$value) { + $self = new self($value); + $value = $self->except($except)->toArray(); + unset($value, $self); + } + return $array; + } + + /** + * 二维数组指定字段 + * + * @param array $array + * @param array $only + * @return array + * @date 2023-01-13 + * @example + * @author arw + * @since 1.0.0 + */ + public static function onlyFields(array $array, array $only): array + { + foreach ($array as &$value) { + $self = new self($value); + $value = $self->only($only)->toArray(); + unset($value, $self); + } + return $array; + } + + /** + * 排除某些变量 + * + * @param array $fields + * @return self + * @date 2023-01-13 + * @example + * @author arw + * @since 1.0.0 + */ + public function except(array $fields): self + { + $data = $this->data; + // $fields = [id,name] + foreach ($fields as $field) { + if (isset($data[$field])) { + unset($data[$field]); + } + } + return new self($data); + } + + /** + * 获取部分变量 + * + * @param array $fields + * @return self + * @date 2023-01-13 + * @example + * @author arw + * @since 1.0.0 + */ + public function only(array $fields): self + { + $data = $this->data; + $result = []; + // $fields = [id,name] + // $fields = [id=>0,name=>asdasd] + foreach ($fields as $key => $value) { + if (is_int($key)) { + if (isset($data[$value])) { + $result[$value] = $data[$value]; + } + } else { + $result[$key] = isset($data[$key]) ? $data[$key] : $value; + } + } + return new self($result); + } + + /** + * 获取数据 + * + * @return array + * @date 2023-01-13 + * @example + * @author arw + * @since 1.0.0 + */ + public function toArray(): array + { + return $this->data; + } + + + public function __get($name) + { + return $this->offsetGet($name); + } + + public function __set($name, $value) + { + return $this->offsetSet($name, $value); + } + + public function offsetExists($offset): bool + { + return isset($this->data[$offset]); + } + + public function offsetGet($offset) + { + return $this->data[$offset]; + } + + public function offsetSet($offset, $value): void + { + $this->data[$offset] = $value; + } + + public function offsetUnset($offset): void + { + unset($this->data[$offset]); + } +} diff --git a/app/common/arw/adjfut/src/Base64.php b/app/common/arw/adjfut/src/Base64.php new file mode 100644 index 0000000..4bb6653 --- /dev/null +++ b/app/common/arw/adjfut/src/Base64.php @@ -0,0 +1,174 @@ + 'html', + 'text/css' => 'css', + 'text/javascript' => 'js', + 'image/gif' => 'gif', + 'image/png' => 'png', + 'image/jpeg' => 'jpg', + 'image/x-icon' => 'ico', + ]; + /** + * 实例化 + * + * @param string $base64 + * @date 2023-01-09 + * @example + * @author arw + * @since 1.0.0 + */ + public function __construct(string $base64) + { + $parse = self::parse($base64); + $this->base64 = $base64; + $this->type = $parse['type']; + $this->body = $parse['body']; + } + + /** + * 获取文件后缀 + * + * @return string + * @date 2023-01-09 + * @example + * @author arw + * @since 1.0.0 + */ + public function getFileExt(): string + { + return Arr::get(self::FILE_EXT_MAP, $this->type, ''); + } + + /** + * 判断是否是base64图片字符串 + * + * @return boolean + * @date 2023-01-09 + * @example + * @author arw + * @since 1.0.0 + */ + public function isImage(): bool + { + return in_array($this->type, [ + 'image/gif', + 'image/png', + 'image/jpeg', + 'image/x-icon', + ]); + } + + /** + * 保存base64图片 + * + * @param string $path + * @return void + * @date 2023-01-09 + * @example + * @author arw + * @since 1.0.0 + */ + public function saveImage(string $path): void + { + file_put_contents($path, base64_decode($this->body)); + } + + /** + * 判断是否是base64图片字符串 + * + * @param string $base64 + * @return boolean + * @date 2023-01-09 + * @example + * @author arw + * @since 1.0.0 + */ + public static function isBase64Image(string $base64): bool + { + $ins = new self($base64); + return $ins->isImage(); + } + + /** + * 保存base64图片 + * + * @param string $base64 + * @param string $path + * @return void + */ + public static function saveBase64Image(string $base64, string $path): void + { + $ins = new self($base64); + $ins->saveImage($path); + } + + /** + * 解析base64 + * + * @param string $base64 + * @return array + * @date 2023-01-09 + * @example + * @author arw + * @since 1.0.0 + */ + private static function parse(string $base64): array + { + $prefix = 'data:'; + $validate = substr($base64, 0, strlen($prefix)) === $prefix; + if (!$validate) { + throw new ErrorMsg("非法base64 开头data:", 1); + } + $explode = explode(';base64,', $base64); + if (count($explode) != 2) { + throw new ErrorMsg("非法base64 不存在;base64,", 1); + } + list($type, $body) = $explode; + $type = str_replace('data:', '', $type); + return [ + 'type' => $type, + 'body' => $body + ]; + } +} diff --git a/app/common/arw/adjfut/src/ChunkUpload.php b/app/common/arw/adjfut/src/ChunkUpload.php new file mode 100644 index 0000000..1990fc2 --- /dev/null +++ b/app/common/arw/adjfut/src/ChunkUpload.php @@ -0,0 +1,258 @@ +id = $id; + if (is_string($file)) { + $file = Request::file($file); + } + if (is_array($file)) { + $file = new UploadedFile(...$file); + } + if (!($file instanceof UploadedFile)) { + throw new ErrorMsg("非法文件", 1); + } + $this->file = $file; + } + + /** + * 获取存储配置 + * + * @return Driver + * @date 2022-08-21 + * @example + * @author arw + * @since 1.0.0 + */ + public function getDisk(): Driver + { + return Filesystem::disk(self::$disk); + } + + /** + * 分片是否上传完成 + * + * @return boolean + * @date 2022-08-22 + * @example + * @author arw + * @since 1.0.0 + */ + public function isDone(): bool + { + return $this->isDone; + } + + /** + * 合并文件 + * + * @return self + * @date 2022-08-21 + * @example + * @author arw + * @since 1.0.0 + */ + public function merge(string $name): self + { + if (!$this->isDone()) { + throw new ErrorMsg("文件未上传完成 禁止合并", 1); + } + + $id = $this->id; + + $root = self::getDiskConfig('root'); + + $path = join('', [ + $root, + $id, + '.' . pathinfo($name, PATHINFO_EXTENSION) + ]); + + for ($i = 0; $i <= $this->total; $i++) { + $_path = $root . $id . DIRECTORY_SEPARATOR . $i; + file_put_contents( + $path, + file_get_contents($_path), + FILE_APPEND + ); + unlink($_path); + } + rmdir($root . $id); + $this->mergeFile = new UploadedFile($path, $name); + return $this; + } + + /** + * 获取合并文件 + * + * @return UploadedFile + * @date 2022-08-22 + * @example + * @author arw + * @since 1.0.0 + */ + public function getMergeFile(): UploadedFile + { + if (!$this->mergeFile) { + throw new ErrorMsg("未合并文件", 1); + } + return $this->mergeFile; + } + + /** + * 获取上传文件 + * + * @param string $diskName + * @param string $validate + * @return UploadFile + * @date 2022-08-22 + * @example + * @author arw + * @since 1.0.0 + */ + public function getUploadFile(string $diskName, string $validate = ''): UploadFile + { + return new UploadFile( + $diskName, + $validate, + $this->getMergeFile() + ); + } + + /** + * 保存文件 + * + * @param integer $index + * @param integer $total + * @return self + * @date 2022-08-21 + * @example + * @author arw + * @since 1.0.0 + */ + public function put(int $index, int $total): self + { + $this->total = $total; + $this->getDisk()->putFileAs( + $this->id, + $this->file, + $index + ); + $this->isDone = $index === $total; + return $this; + } + + /** + * 删除文件 + * + * @return void + * @date 2022-08-22 + * @example + * @author arw + * @since 1.0.0 + */ + public function delete(): void + { + $this->getDisk()->delete($this->getMergeFile()->getFilename()); + } + + /** + * 初始化配置 + * + * @param array $config + * @return void + * @date 2022-08-21 + * @example + * @author arw + * @since 1.0.0 + */ + public static function init(array $config): void + { + self::$disk = Arr::get($config, 'disk', ''); + $type = self::getDiskConfig('type'); + if ($type != 'local') { + throw new ErrorMsg("分片上传仅支持 local类型磁盘", 1); + } + } + + /** + * 获取磁盘配置 + * + * @param string $name + * @param mixed $default + * @return mixed + * @date 2022-08-22 + * @example + * @author arw + * @since 1.0.0 + */ + public static function getDiskConfig($name = null, $default = null) + { + return Filesystem::getDiskConfig(self::$disk, $name, $default); + } + + /** + * 生成上传唯一id + * + * @return string + * @date 2022-08-21 + * @example + * @author arw + * @since 1.0.0 + */ + public static function generateUploadId(): string + { + return md5(join('-', [ + Request::ip(), + time() + ])); + } +} diff --git a/app/common/arw/adjfut/src/Config/chunkUpload.php b/app/common/arw/adjfut/src/Config/chunkUpload.php new file mode 100644 index 0000000..6a888bb --- /dev/null +++ b/app/common/arw/adjfut/src/Config/chunkUpload.php @@ -0,0 +1,9 @@ + '' +]; diff --git a/app/common/arw/adjfut/src/Config/wechat.php b/app/common/arw/adjfut/src/Config/wechat.php new file mode 100644 index 0000000..7c798be --- /dev/null +++ b/app/common/arw/adjfut/src/Config/wechat.php @@ -0,0 +1,39 @@ + '', + // 中控层地址 + 'server_base' => 'http://clique.dszjjt.com:7001/', + // 公众号配置 + 'gzh' => [ + // 缓存key + 'cache_key' => 'wechat.gzh', + // 日志通道 + 'log_channel' => 'wechat/gzh', + // 公众号模板推送 + 'template' => [ + // {{first.DATA}} + // 申请人：{{keyword1.DATA}} + // 申请时间：{{keyword2.DATA}} + // 调课时间：{{keyword3.DATA}} + // {{remark.DATA}} + '申请审核通知' => 'iLuqzUrQM8-v_7ilxageUZoi9v-SQWipkTYVZXB1GeI' + ], + 'appid' => 'wx99caf571c9fb1cc5', + 'secret' => '61100d9c4fff5acf97517f0c8799e2e2', + ], + // 小程序配置 + 'xcx' => [ + // 缓存key + 'cache_key' => 'wechat.xcx', + // 日志通道 + 'log_channel' => 'wechat/xcx', + + 'appid' => 'wx2495492e15854b02', + 'secret' => '5b4fcb27324398083fba4a3c39e8a557', + ], +]; diff --git a/app/common/arw/adjfut/src/Curl.php b/app/common/arw/adjfut/src/Curl.php new file mode 100644 index 0000000..22f65f6 --- /dev/null +++ b/app/common/arw/adjfut/src/Curl.php @@ -0,0 +1,790 @@ + [], + /** + * http 超时 + */ + CURLOPT_TIMEOUT => 0, + /** + * http 代理 + */ + CURLOPT_PROXY => '', + /** + * http 代理端口 + */ + CURLOPT_PROXYPORT => '', + /** + * 来源页面 + */ + CURLOPT_REFERER => '', + /** + * 用户代理 + */ + CURLOPT_USERAGENT => '', + /** + * 响应中是否显示header + */ + CURLOPT_HEADER => 0 + ]; + /** + * Get请求参数 + * + * @var null + */ + private $httpParams = null; + /** + * Post请求参数 + * + * @var null + */ + private $httpData = null; + /** + * 异常信息 + * + * @var string + */ + private $error = ''; + /** + * url是否编码 + * + * @var boolean + */ + private $urlEncode = false; + /** + * 验证http请求状态码 + * + * @var boolean + */ + private $httpCode = true; + /** + * 请求路径 + * + * @var string + */ + private $path = ''; + /** + * 请求url + * + * @var string + */ + private $url = ''; + /** + * 请求类型 + * + * @var string + */ + private $method = 'get'; + /** + * 返回内容 + * + * @var string + */ + private $content = ''; + /** + * 请求信息 + * + * @var array + */ + private $status = []; + /** + * 调试模式 + * + * @var boolean + */ + private $debug = false; + /** + * 是否上传文件 + * + * @var boolean + */ + private $isUploadFile = false; + + /** + * 初始化 + * + * @date 2022-03-24 + * @example + * @author arw + * @since 1.0.0 + */ + public function __construct() + { + } + + /** + * 初始化请求 + * + * @return $this + */ + public static function instance() + { + return new self; + } + + /** + * 获取请求url + */ + public function getUrl(): string + { + return $this->url; + } + + /** + * 获取请求路径 + */ + public function getPath(): string + { + return $this->path; + } + + /** + * 获取返回内容 + * + * @return string + */ + public function getContent(): string + { + return $this->content; + } + + /** + * 格式化返回 + * + * @param string $type 返回类型（默认使用 $this->dataType） + * @return mixed + * @date 2022-03-24 + * @example + * @author arw + * @since 1.0.0 + */ + public function formatContent(string $type = '') + { + $content = $this->content; + if (!$type) { + $type = $this->dataType; + } + switch ($type) { + case 'json': + case 'object': + return json_decode($content, $type === 'json'); + break; + default: + return $content; + break; + } + } + + /** + * 获取请求信息 + */ + public function getStatus(): array + { + return $this->status; + } + + /** + * 设置是否上传文件 + */ + public function setIsUploadFile(bool $isUploadFile): self + { + $this->isUploadFile = $isUploadFile; + return $this; + } + + /** + * 设置请求路径 + */ + public function setPath(string $path): self + { + if (count(explode('?', $path)) != 1) { + throw new Exception("请求路径不能携带参数 请使用setParams设置请求参数", 1); + } + $this->path = $path; + return $this; + } + + /** + * 设置调试模式 + */ + public function setDeBug(bool $debug): self + { + $this->debug = $debug; + return $this; + } + + /** + * 验证http状态码 + * + * @param boolean|int $code + */ + public function setHttpCode($code): self + { + $this->httpCode = $code; + return $this; + } + + /** + * 设置url是否编码 + */ + public function setUrlEncode(bool $urlEncode): self + { + $this->urlEncode = $urlEncode; + return $this; + } + + /** + * 设置请求前缀 + */ + public function setBaseUrl(string $baseUrl): self + { + if (count(explode('?', $baseUrl)) != 1) { + throw new Exception("请求前缀不能携带参数 请使用setParams设置请求参数", 1); + } + $this->baseUrl = $baseUrl; + return $this; + } + + /** + * 设置返回数据类型 + */ + public function setDataType(string $dataType): self + { + $this->dataType = $dataType; + return $this; + } + + /** + * 设置http header + */ + public function setHeader(array $header): self + { + $_header = []; + foreach ($header as $key => $value) { + if (is_numeric($key)) { + $_header[] = $value; + } else { + $_header[] = "$key: $value"; + } + } + $this->config[CURLOPT_HTTPHEADER] = array_merge($this->config[CURLOPT_HTTPHEADER], $_header); + return $this; + } + + /** + * 设置http 超时 + */ + public function setTimeout(int $time): self + { + $this->config[CURLOPT_TIMEOUT] = $time <= 0 ? 5 : $time; + return $this; + } + + /** + * 设置http 代理 + */ + public function setProxy(string $proxy): self + { + $this->config[CURLOPT_PROXY] = $proxy; + return $this; + } + + /** + * 设置http 代理端口 + */ + public function setProxyPort(int $port): self + { + $this->config[CURLOPT_PROXYPORT] = $port; + return $this; + } + + /** + * 设置来源页面 + */ + public function setReferer(string $referer = ""): self + { + $this->config[CURLOPT_REFERER] = $referer; + return $this; + } + + /** + * 设置用户代理 + */ + public function setUserAgent(string $agent = ""): self + { + $this->config[CURLOPT_USERAGENT] = $agent; + return $this; + } + + /** + * http响应中是否显示header + */ + public function showResponseHeader(bool $show): self + { + $this->config[CURLOPT_HEADER] = $show ? 1 : 0; + return $this; + } + + /** + * 获取get请求参数 + */ + public function getParams() + { + return $this->httpParams; + } + + /** + * 设置get请求的参数 + */ + public function setParams($params): self + { + $_params = $this->trigger('beforeSetParams', [$params]); + $this->httpParams = $_params ? $_params : $params; + return $this; + } + + /** + * 获取post请求参数 + */ + public function getData() + { + return $this->httpData; + } + + /** + * 设置post请求的参数 + */ + public function setData($data): self + { + $_data = $this->trigger('beforeSetData', [$data]); + $this->httpData = $_data ? $_data : $data; + return $this; + } + + /** + * 设置http请求的cookie信息 + */ + public function setCookie(array $cookie): self + { + $_cookie = []; + foreach ($cookie as $key => $value) { + $_cookie[] = "$key=$value"; + } + $this->config[CURLOPT_COOKIE] = join(';', $_cookie); + return $this; + } + + /** + * 设置证书路径 + */ + public function setCainfo(string $file): self + { + $this->config[CURLOPT_CAINFO] = $file; + return $this; + } + + /** + * 获取请求异常 + */ + public function getError(): string + { + return $this->error; + } + + /** + * 绑定 + * + * @param string $name + * @param callable $cb + * @date 2022-03-26 + * @example + * @author arw + * @since 1.0.0 + */ + public function bind(string $name, callable $cb): self + { + $this->bind[$name] = $cb; + return $this; + } + + /** + * GET请求 + * @param string $path + * @return mixed + */ + public function get(string $path = '') + { + if ($path) { + $this->setPath($path); + } + $this->method = 'get'; + $respone = $this->fetch(); + if (!$path) { + return $this; + } + return $respone; + } + + /** + * POST请求 + * + * @param string $path + * @return mixed + */ + public function post(string $path = '') + { + if ($path) { + $this->setPath($path); + } + $this->method = 'post'; + $respone = $this->fetch(); + if (!$path) { + return $this; + } + return $respone; + } + + /** + * PUT请求 + * + * @param string $path + * @return mixed + */ + public function put(string $path = '') + { + if ($path) { + $this->setPath($path); + } + $this->method = 'put'; + $respone = $this->fetch(); + if (!$path) { + return $this; + } + return $respone; + } + + /** + * DELETE请求 + * + * @param string $path + * @return mixed + */ + public function delete(string $path = '') + { + if ($path) { + $this->setPath($path); + } + $this->method = 'delete'; + $respone = $this->fetch(); + if (!$path) { + return $this; + } + return $respone; + } + + /** + * PATCH请求 + * + * @param string $path + * @return mixed + */ + public function patch(string $path = '') + { + if ($path) { + $this->setPath($path); + } + $this->method = 'patch'; + $respone = $this->fetch(); + if (!$path) { + return $this; + } + return $respone; + } + + /** + * 设置get传参前 + * + * @param callable $cb($params) + * @param mixed $params 参数 + * @date 2022-03-26 + * @example + * @author arw + * @since 1.0.0 + */ + public function onBeforeSetParams(callable $cb): self + { + return $this->event('beforeSetParams', $cb); + } + + /** + * 设置post传参前 + * + * @param callable $cb($data) + * @param mixed $data 参数 + * @date 2022-03-26 + * @example + * @author arw + * @since 1.0.0 + */ + public function onBeforeSetData(callable $cb): self + { + return $this->event('beforeSetData', $cb); + } + + /** + * 请求前 + * + * @param callable $cb($ch) + * @param self $ch + * @date 2022-03-26 + * @example + * @author arw + * @since 1.0.0 + */ + public function onBeforeFetch(callable $cb): self + { + return $this->event('beforeFetch', $cb); + } + + /** + * 请求后 + * + * @param callable $cb($ch,$info) + * @param self $ch + * @param array $info + * @param string $info[url] 请求完整url + * @param string $info[content] 返回信息 + * @param array $info[status] 请求信息 + * @date 2022-03-26 + * @example + * @author arw + * @since 1.0.0 + */ + public function onAfterFetch(callable $cb) + { + return $this->event('afterFetch', $cb); + } + + /** + * 请求异常(返回true阻止抛出异常) + * + * @param callable $cb($ch,$th) + * @param self $ch + * @param \Throwable $th + * @date 2022-03-26 + * @example + * @author arw + * @since 1.0.0 + */ + public function onFetchError(callable $cb) + { + return $this->event('fetchError', $cb); + } + + /** + * 发起请求 + * + * @return mixed + * @date 2022-03-25 + * @example + * @author arw + * @since 1.0.0 + */ + public function fetch() + { + $this->url = $url = $this->baseUrl . $this->path; + + $this->trigger('beforeFetch', [$this]); + + try { + $httpParams = $this->httpParams; + if (!empty($httpParams) && is_array($httpParams)) { + $url .= (strpos($url, '?') === false ? '?' : '') . http_build_query($httpParams); + } + + if ($this->urlEncode === false) { + $url = urldecode($url); + } + + $ch = $this->curlInit($url); + // 设为TRUE把curl_exec()结果转化为字串，而不是直接输出 + curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); + + $this->content = $content = curl_exec($ch); + $this->status = $status = curl_getinfo($ch); + + if ($content === false) { + $this->error = curl_error($ch); + } + + if ($this->debug) { + dump([ + 'ch' => $ch, + 'url' => $url, + 'httpParams' => $this->httpParams, + 'httpData' => $this->httpData, + 'contentArray' => json_decode($content, true), + 'content' => $content, + 'status' => $status + ]); + } + curl_close($ch); + + $httpCode = $this->httpCode; + + if ($httpCode === true) { + $httpCode = 200; + } + if (is_numeric($httpCode)) { + if (!isset($status['http_code'])) { + throw new Exception("服务器未返回状态码", 1); + } + if ($status['http_code'] !== $httpCode) { + throw new Exception(sprintf("服务器返回状态码异常[ %s ]", $status['http_code']), 1); + } + } + + $this->trigger('afterFetch', [$this, [ + 'url' => $url, + 'content' => $content, + 'status' => $status + ]]); + + return $this->formatContent(); + } catch (\Throwable $th) { + if (!$this->trigger('fetchError', [$this, $th])) { + throw $th; + } + } + } + + public function __call($name, $arguments) + { + array_unshift($arguments, $this); + call_user_func_array($this->bind[$name], $arguments); + } + + /** + * 事件 + * + * @param string $type beforeSetParams | beforeSetData | beforeFetch | AfterFetch + * @param callable $cb + */ + private function event(string $type, callable $cb): self + { + $this->event[strtoupper($type)] = $cb; + return $this; + } + + /** + * 事件触发器 + * + * @param string $type + * @return mixed + * @date 2022-03-25 + * @example + * @author arw + * @since 1.0.0 + */ + private function trigger(string $type, array $args = []) + { + $type = strtoupper($type); + if (isset($this->event[$type])) { + return call_user_func_array($this->event[$type], $args); + } + } + + /** + * 初始化请求 + * + * @param string $url + * @return resource|CurlHandle + * @date 2022-04-24 + * @example + * @author arw + * @since 1.0.0 + */ + private function curlInit(string $url) + { + $ch = curl_init($url); + if (stripos($url, 'https://') !== false) { + curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false); + curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false); + curl_setopt($ch, CURLOPT_SSLVERSION, 1); + } + + foreach ($this->config as $option => $value) { + if (!$value && $option != CURLOPT_HEADER) { + continue; + } + curl_setopt($ch, $option, $value); + } + + switch ($this->method) { + case 'get': + break; + case 'post': + curl_setopt($ch, CURLOPT_POST, true); + break; + default: + // delete put patch + curl_setopt($ch, CURLOPT_CUSTOMREQUEST, strtoupper($this->method)); + break; + } + $httpData = $this->httpData; + // 设置post body + if ($httpData) { + $data = null; + if (is_array($httpData)) { + if ($this->isUploadFile) { + $data = $httpData; + } else { + $data = http_build_query($httpData); + } + } else if (is_string($httpData)) { + $data = $httpData; + } + curl_setopt($ch, CURLOPT_POSTFIELDS, $data); + } + return $ch; + } +} diff --git a/app/common/arw/adjfut/src/Excel.php b/app/common/arw/adjfut/src/Excel.php new file mode 100644 index 0000000..51ccaa6 --- /dev/null +++ b/app/common/arw/adjfut/src/Excel.php @@ -0,0 +1,519 @@ +getRealPath(); + } + $this->spreadsheet = self::loadExcel($path); + $this->path = $path; + } else { + $this->spreadsheet = new Spreadsheet(); + } + } + + /** + * 设置工作表样式 + * + * @param array $options + * @param boolean $options[autoBorder] 是否自动添加边框 + * @param boolean $options[freezeLine] 是否自动冻结首行 + * @return self + */ + public function setWorksheetStyle(array $options): self + { + $this->worksheetStyle = $options; + return $this; + } + + /** + * 获取当前Spreadsheet + * + * @return Spreadsheet + * @date 2020-11-23 + * @example + * @author arw + * @since 1.0.0 + */ + public function getSpreadsheet(): Spreadsheet + { + return $this->spreadsheet; + } + + /** + * 读取excel + * + * @param string $path excel路径 + * @return Spreadsheet + */ + public static function loadExcel(string $path): Spreadsheet + { + if (!is_file($path)) { + throw new ErrorMsg("文件不存在 $path", 1); + } + $ext = pathinfo($path, PATHINFO_EXTENSION); + return IOFactory::createReader(ucfirst($ext))->load($path); + } + + /** + * 获取工作表 + * 默认获取当前激活的 + * + * @param string $sheet + * @return Worksheet + */ + public function getWorksheet(string $sheet = 'active'): Worksheet + { + $Spreadsheet = $this->getSpreadsheet(); + if ($sheet === 'active') { + $Worksheet = $Spreadsheet->getActiveSheet(); + } else { + $Worksheet = $Spreadsheet->getSheet($sheet); + } + return $Worksheet; + } + + /** + * 获取excel数据 + * + * @param string $sheet + * @return array + */ + public function getExcelData(string $sheet = 'active'): array + { + return $this->getWorksheet($sheet)->toArray(); + } + + /** + * 解析excel + * + * @param array $rules + * @param string $rules[][title] 表头 + * @param string $rules[][validate] 验证器 + * @param string $rules[][field] 字段名 + * @param string $rules[][type] 数据类型 date:日期格式(Y-m-d H:i:s) + * @param array $options + * @param array $options[titleLine] 表头行 + * @param boolean $options[autoRemove] 解析后移除文件 + * @param boolean $options[ignoreNullRow] 忽略空行 + * @return array + * @date 2022-04-11 + * @example + * @author arw + * @since 1.0.0 + */ + public function parseExcel(array $rules, array $options = []): array + { + $titleLine = Arr::get($options, 'titleLine', [1]); + $autoRemove = Arr::get($options, 'autoRemove', true); + $ignoreNullRow = Arr::get($options, 'ignoreNullRow', true); + + if ($autoRemove) { + if (is_file($this->path)) { + unlink($this->path); + } + } + + $title = []; + $_title = []; + $_field = []; + $_type = []; + $_validate = []; + foreach ($rules as $rule) { + $_title[] = $rule['title']; + if (isset($rule['field'])) { + $_field[] = $rule['field']; + if (isset($rule['validate'])) { + $_validate[join('|', [ + $rule['field'], + $rule['title'] + ])] = $rule['validate']; + } + } else { + $_field[] = ''; + } + if (isset($rule['type'])) { + $_type[] = $rule['type']; + } else { + $_type[] = ''; + } + } + $Worksheet = $this->getWorksheet(); + $data = $Worksheet->toArray(); + // 获取表头 合并复杂表头 + foreach ($titleLine as $line) { + $values = $data[$line - 1]; + foreach ($values as $key => $value) { + if ($value) { + $title[$key] = $value; + } + } + } + // 验证表头 + if ($title != $_title) { + throw new ErrorMsg("表头不一致 请确认excel是否正确", 1); + } + // 去除非数据字段 + $i = max($titleLine) - 1; + do { + unset($data[$i]); + $i--; + } while ($i >= 0); + + $validate = new Validate; + $validate->rule($_validate)->batch(true)->failException(true); + + $result = []; + $error = []; + foreach ($data as $row => $value) { + $index = $row + 1; + $line = "第${index}行"; + $_value = []; + if ($ignoreNullRow && self::isNullRow($value)) { + continue; + } + foreach ($_field as $column => $field) { + if ($field) { + if ($_type[$column]) { + $type = $_type[$column]; + if (Str::startsWith($type, 'date') && $value[$column]) { + $format = 'Y-m-d H:i:s'; + $types = explode(':', $type); + if (isset($types[1])) { + $format = $types[1]; + } + $value[$column] = Tool::conversionDateTime($value[$column], $format); + } + } + $_value[$field] = $value[$column]; + } + } + // 验证数据 + if ($_validate) { + try { + $validate->check($_value); + } catch (\Throwable $th) { + $error[] = $line . '：' . $th->getMessage(); + } + } + + $result[$line] = $_value; + } + + if ($error) { + throw new ErrorMsg(join(PHP_EOL, $error), 1); + } + + return $result; + } + + /** + * 导出excel + * + * @param array $data 数据 + * @param array $options + * @param boolean $options[autoBorder] 是否自动添加边框 + * @param string $options[freezeLine] 是否自动冻结首行 + * @date 2022-04-11 + * @example + * @author arw + * @since 1.0.0 + */ + public static function exportSheet(array $data, array $options = []) + { + $excel = new self; + $excel->setWorksheetStyle($options); + $spreadsheet = $excel->getSpreadsheet(); + $worksheet = $spreadsheet->getActiveSheet(); + $worksheet->fromArray($data); + return $excel; + } + + /** + * 导出处理图片字段 + */ + public static function ExportImgFiled($value) + { + if(strpos($value,"http") !== false){ + $base_url = ""; + }else{ + $base_url = Env::get('APP.DEFAULT_IMG_URL'); + } + return $base_url . $value; + } + + /** + * 导出excel 多sheet + * + * @param array $data 数据 + * @param array $options + * @param boolean $options[autoBorder] 是否自动添加边框 + * @param string $options[freezeLine] 是否自动冻结首行 + * @date 2022-04-11 + * @example + * @author arw + * @since 1.0.0 + */ + public static function exportMoreSheet(array $data, array $options = []) + { + $excel = new self; + $excel->setWorksheetStyle($options); + $spreadsheet = $excel->getSpreadsheet(); + $spreadsheet->removeSheetByIndex(0); + foreach ($data as $key => $value) { + $worksheet = new Worksheet($spreadsheet, $key); + $worksheet->fromArray($value); + $spreadsheet->addSheet($worksheet); + } + $spreadsheet->setActiveSheetIndex(0); + return $excel; + } + + /** + * 保存excel + * + * @param string $name 文件名 + * @param string $save 保存路径 + * @date 2022-04-11 + * @example + * @author arw + * @since 1.0.0 + */ + public function save(string $name, string $save = 'php://output') + { + $spreadsheet = $this->getSpreadsheet(); + $writer = IOFactory::createWriter($spreadsheet, 'Xlsx'); + $_name = $name; + if (!preg_match("/\./", $name)) { + $_name .= '.Xlsx'; + } + $worksheets = $spreadsheet->getAllSheets(); + foreach ($worksheets as $worksheet) { + $this->_setWorksheetStyle($worksheet); + } + // 保存前 + $this->trigger('beforeSave', [$spreadsheet]); + // 浏览器下载 + if ($save === 'php://output') { + Tool::obEndClean(); + header('Content-Type: application/vnd.openxmlformats-officedocument.spreadsheetml.sheet'); + header('Cache-Control: max-age=0'); + header('Content-Disposition:inline;filename="' . $_name . '"'); + $writer->save($save); + } else { + Tool::mkdir($save); + // 保存到本地目录 + $writer->save(join(DIRECTORY_SEPARATOR, [ + $save, $_name, + ])); + } + $spreadsheet->disconnectWorksheets(); + unset($spreadsheet); + // 保存后 + $this->trigger('AfterSave'); + } + + /** + * 保存前 + * + * @param callable $cb + * @date 2022-04-11 + * @example + * @author arw + * @since 1.0.0 + */ + public function onBeforeSave(callable $cb): self + { + return $this->event('beforeSave', $cb); + } + + /** + * 保存后 + * + * @param callable $cb + * @date 2022-04-11 + * @example + * @author arw + * @since 1.0.0 + */ + public function onAfterSave(callable $cb): self + { + return $this->event('afterSave', $cb); + } + + /** + * 判断是否空行 + * + * @param array $rows + * @return boolean + * @date 2021-11-27 + * @example + * @author arw + * @since 1.0.0 + */ + public static function isNullRow(array $rows) + { + $rows = array_unique($rows); + $rows = array_filter($rows, function ($v) { + return !is_null($v); + }); + return count($rows) == 0; + } + + /** + * 快捷设置excel样式 + * 首行冻结 自动添加边框 + * + * @param Worksheet $worksheet + * @return Worksheet $worksheet + * @date 2021-01-25 + * @author arw + * @since 1.0.0 + */ + private function _setWorksheetStyle(Worksheet $worksheet): Worksheet + { + $options = $this->worksheetStyle; + $autoBorder = Arr::get($options, 'autoBorder', true); + $freezeLine = Arr::get($options, 'freezeLine', 'A2'); + $autoBackground = Arr::get($options, 'autoBackground', true); + if ($freezeLine) { + $worksheet->freezePane($freezeLine); + } + if ($autoBorder) { + $worksheet->getStyle(join(':', [ + 'A1', + $worksheet->getHighestDataColumn() . $worksheet->getHighestDataRow() + ]))->applyFromArray([ + 'borders' => [ + 'allBorders' => [ + 'borderStyle' => Border::BORDER_THIN, //细边框 + ], + ], + ]); + } + if($autoBackground){ + $style = join(':', [ + 'A1', + $worksheet->getHighestDataColumn() . "1" + ]); + + // 列宽 + $worksheet -> getDefaultColumnDimension() -> setWidth(25); + // $worksheet -> getColumnDimension('A') -> setWidth(30); //设置A列宽度为30 + //行高 + // $worksheet -> getRowDimension(1) -> setRowHeight(25); + $worksheet -> getDefaultRowDimension() -> setRowHeight(25); + + //样式设置 - 字体 + $worksheet -> getStyle($style) -> getFont() + // -> setBold(true) + ->setName('微软雅黑') + -> setSize(13); + + //样式设置 - 字体颜色 + // $worksheet -> getStyle('A1') -> getFont() + // -> getColor() -> setARGB(\PhpOffice\PhpSpreadsheet\Style\Color::COLOR_RED); //设置单元格A1的字体颜色 + + // $font = $worksheet -> getCell('B1') -> getColor() -> setARGB(\PhpOffice\PhpSpreadsheet\Style\Color::COLOR_RED); + + // if(substr($font,0,1) == "*"){ + + // } + + // $worksheet -> setCellValue('A2', substr($font,0,1) ); + + //样式设置 - 水平、垂直居中 + $styleArray = [ + 'alignment' => [ + 'horizontal' => \PhpOffice\PhpSpreadsheet\Style\Alignment::HORIZONTAL_CENTER, + 'vertical' => \PhpOffice\PhpSpreadsheet\Style\Alignment::VERTICAL_CENTER + ], + ]; + $worksheet -> getStyle($style) -> applyFromArray($styleArray); + + //样式设置 - 单元格背景颜色 + $worksheet->getStyle($style)->getFill()->setFillType(\PhpOffice\PhpSpreadsheet\Style\Fill::FILL_SOLID)->getStartColor()->setARGB('FFFFFF00'); + } + return $worksheet; + } + + /** + * 数字转字母 + * 1 => A + * + * @param integer $index + * @return string + * @date 2021-01-23 + * @author arw + * @since 1.0.0 + */ + public static function stringToIndex(int $index) + { + return Coordinate::stringFromColumnIndex($index); + } + + /** + * 字母转数字 + * A => 1 + * + * @param string $string + * @return int + * @date 2021-01-23 + * @author arw + * @since 1.0.0 + */ + public static function indexToString(string $string) + { + return Coordinate::columnIndexFromString($string); + } +} diff --git a/app/common/arw/adjfut/src/Exception/ErrorMsg.php b/app/common/arw/adjfut/src/Exception/ErrorMsg.php new file mode 100644 index 0000000..437d9ce --- /dev/null +++ b/app/common/arw/adjfut/src/Exception/ErrorMsg.php @@ -0,0 +1,12 @@ +pivotClass = $pivotClass; + $this->masterClass = $masterClass; + $this->subClass = $subClass; + $this->softDelete = $softDelete; + + $this->pivotPk = (new $pivotClass)->getPk(); + $this->masterPk = (new $masterClass)->getPk(); + $this->subPk = (new $subClass)->getPk(); + } + + /** + * 绑定 + * + * @param array|Collection $masters + * @param array|Collection $subs + * @param array $extra 中间表额外数据 + * @return void + * @date 2022-12-29 + * @example + * @author arw + * @since 1.0.0 + */ + public function bind($masters, $subs, array $extra = []): void + { + $this->_bind($masters, $subs, $extra, false); + } + + /** + * 解绑 + * + * @param array|Collection $masters + * @param array|Collection $subs + * @return void + * @date 2022-12-29 + * @example + * @author arw + * @since 1.0.0 + */ + public function unbind(array $masters, array $subs): void + { + $masters = self::formatModel($masters, $this->masterClass); + $subs = self::formatModel($subs, $this->subClass); + + $pivotClass = $this->pivotClass; + + $pivotPk = $this->pivotPk; + $masterPk = $this->masterPk; + $subPk = $this->subPk; + + foreach ($masters as $master) { + // 查询已绑定的数据 + $subPks = $pivotClass::where([ + $masterPk => $master->$masterPk + ])->column($subPk); + foreach ($subs as $sub) { + if (in_array($sub->$subPk, $subPks)) { + $pivotClass::where([ + $subPk => $sub->$subPk, + $masterPk => $master->$masterPk + ])->field([ + $pivotPk + ])->select()->delete(); + } + } + } + } + + /** + * 重新绑定 + * + * @param array|Collection $masters + * @param array|Collection $subs + * @param array $extra 中间表额外数据 + * @return void + * @date 2022-12-29 + * @example + * @author arw + * @since 1.0.0 + */ + public function rebind($masters, $subs, array $extra = []): void + { + $this->_bind($masters, $subs, $extra, true); + } + + /** + * 格式化模型 + * + * @param array|Collection $models + * @param string $class + * @return Collection + * @date 2022-12-29 + * @example + * @author arw + * @since 1.0.0 + */ + private static function formatModel($models, string $class): Collection + { + if ($models instanceof Collection) { + return $models; + } else if (is_array($models)) { + $Collection = new Collection(); + foreach ($models as $model) { + if ($model instanceof $class) { + } else if (is_string($model) || is_numeric($model)) { + $model = $class::find($model); + } + $Collection->push($model); + } + return $Collection; + } else { + throw new ErrorMsg("类型异常", 1); + } + } + + /** + * 绑定数据 + * + * @param array|Collection $masters + * @param array|Collection $subs + * @param array $extra + * @param boolean $rebind + * @return void + * @date 2022-12-29 + * @example + * @author arw + * @since 1.0.0 + */ + private function _bind($masters, $subs, array $extra = [], bool $rebind = false) + { + $masters = self::formatModel($masters, $this->masterClass); + $subs = self::formatModel($subs, $this->subClass); + + $pivotClass = $this->pivotClass; + + $softDelete = $this->softDelete; + + $pivotPk = $this->pivotPk; + $masterPk = $this->masterPk; + $subPk = $this->subPk; + + foreach ($masters as $master) { + if ($rebind) { + $pivots = $pivotClass::where([ + [$masterPk, '=', $master->$masterPk], + [$subPk, 'not in', $subs->column($subPk)], + ])->select(); + if (!$pivots->isEmpty()) { + // 重新绑定 + $this->unbind([$master], $pivots->column($subPk)); + } + } + foreach ($subs as $sub) { + $pivot = null; + if ($softDelete) { + $pivot = $pivotClass::withTrashed()->where([ + $subPk => $sub->$subPk, + $masterPk => $master->$masterPk + ])->find(); + } else { + $pivot = $pivotClass::where([ + $subPk => $sub->$subPk, + $masterPk => $master->$masterPk + ])->find(); + } + if (is_null($pivot) || $pivot->isEmpty()) { + $pivotClass::create($extra + [ + $subPk => $sub->$subPk, + $masterPk => $master->$masterPk + ]); + } else { + if ($softDelete) { + $pivot->restore(); + } + if ($extra) { + $pivotClass::update($extra, [ + $pivotPk => $pivot->$pivotPk + ]); + } + } + } + } + } +} diff --git a/app/common/arw/adjfut/src/PartitionTable.php b/app/common/arw/adjfut/src/PartitionTable.php new file mode 100644 index 0000000..d0e5a71 --- /dev/null +++ b/app/common/arw/adjfut/src/PartitionTable.php @@ -0,0 +1,261 @@ +originTable = $table; + $this->targetTable = join('_', [$table, $suffix]); + + $this->checkTargetTable(); + } + + /** + * 是否锁表 + * + * @param boolean|string $lock + * @return self + * @date 2023-01-04 + * @example + * @author arw + * @since 1.0.0 + */ + public function setLockTable($lock): self + { + $this->lockTable = $lock; + return $this; + } + + /** + * 设置唯一字段（设置后将删除原表数据） + * + * @param string $uniqueField + * @date 2022-03-24 + * @example + * @author arw + * @since 1.0.0 + */ + public function setUniqueField(string $uniqueField): self + { + $this->uniqueField = $uniqueField; + return $this; + } + + /** + * 设置查询条件 + * + * @param callable $cb + * @date 2022-03-24 + * @example + * @author arw + * @since 1.0.0 + */ + public function setQuery(callable $cb): self + { + $this->query = call_user_func($cb, $this->getOriginDb()); + return $this; + } + + /** + * 跨月查询 + * + * @param string $table + * @param string $field 字段 + * @param array $option + * @param array $option[start] 开始时间 Y-m-d H:i:s + * @param array $option[end] 结束时间 Y-m-d H:i:s + * @date 2022-04-06 + * @example + * @author arw + * @since 1.0.0 + */ + public static function queryForMonth(string $table, string $field, array $option): Query + { + $start = Arr::get($option, 'start'); + $end = Arr::get($option, 'end'); + if (!$start || !$end) { + throw new \Exception("缺少时间限制", 1); + } + $result = Db::query("SHOW TABLES LIKE '${table}_%'"); + $tables = []; + foreach ($result as $value) { + $tables = array_merge($tables, array_values($value)); + } + $startYm = date('Ym', strtotime($start)); + $endYm = date('Ym', strtotime($end)); + $months = []; + $months[] = $startYm; + + if ($startYm != $endYm) { + $current = $startYm; + while (true) { + $current = date('Ym', strtotime($current . "01 +1month")); + $months[] = $current; + if ($current === $endYm) { + break; + } + } + // $months[] = $endYm; + } + + $temp = array_filter($tables, function ($v) use ($table, $months) { + return in_array(explode("${table}_", $v)[1], $months); + }); + + $query = Db::table(in_array(date('Ym'), $months) ? $table : array_shift($temp)); + + $query->union(array_map(function ($v) { + return Db::name($v)->fetchSql()->select(); + }, $temp)); + + return Db::table(join(' ', [ + $query->buildSql(), + $table + ]))->whereBetweenTime($field, $start, $end); + } + + /** + * 迁移数据 + * + * @date 2022-03-24 + * @example + * @author arw + * @since 1.0.0 + */ + public function save() + { + Db::startTrans(); + try { + $lockTable = $this->lockTable; + if ($lockTable) { + $this->getOriginDb()->lock($lockTable)->select(); + $this->getTargetDb()->lock($lockTable)->select(); + } + + $target = $this->targetTable; + $originSql = $this->query->fetchSql()->select(); + $result = Db::execute("REPLACE INTO `$target` $originSql;"); + if ($result === false) { + throw new \Exception("迁移数据失败", 1); + } + + $uniqueField = $this->uniqueField; + if ($uniqueField) { + $this->getTargetDb()->field([ + $uniqueField + ])->chunk(500, function (Collection $ids) use ($uniqueField) { + $this->getOriginDb()->whereIn( + $uniqueField, + $ids->column($uniqueField) + )->delete(); + }, $uniqueField); + } + Db::commit(); + } catch (\Throwable $th) { + Db::rollback(); + throw $th; + } + } + + /** + * 获取原始表 + * + * @date 2022-03-24 + * @example + * @author arw + * @since 1.0.0 + */ + private function getOriginDb(): Query + { + return Db::name($this->originTable); + } + + /** + * 获取目标表 + * + * @date 2022-03-24 + * @example + * @author arw + * @since 1.0.0 + */ + private function getTargetDb(): Query + { + return Db::name($this->targetTable); + } + + /** + * 检查目标表 + * + * @return void + * @date 2022-03-24 + * @example + * @author arw + * @since 1.0.0 + */ + private function checkTargetTable(): void + { + if (!in_array($this->targetTable, Db::getTables())) { + $origin = $this->originTable; + $target = $this->targetTable; + $result = Db::execute("CREATE TABLE `$target` LIKE `$origin`"); + if ($result === false) { + throw new \Exception("创建迁移表失败", 1); + } + } + } +} diff --git a/app/common/arw/adjfut/src/ReTry.php b/app/common/arw/adjfut/src/ReTry.php new file mode 100644 index 0000000..58a482a --- /dev/null +++ b/app/common/arw/adjfut/src/ReTry.php @@ -0,0 +1,250 @@ +setHandle($handle); + $ins->setLimit($limit); + return $ins; + } + /** + * 自增 + * + * @param integer $step 步长 + * @return self + * @date 2022-12-28 + * @example + * @author arw + * @since 1.0.0 + */ + public function inc(int $step = 1): self + { + $this->limit += $step; + return $this; + } + /** + * 自减 + * + * @param integer $step + * @return self + * @date 2022-12-28 + * @example + * @author arw + * @since 1.0.0 + */ + public function dec(int $step = 1): self + { + $this->limit -= $step; + return $this; + } + + /** + * 获取执行次数 + * + * @return integer + * @date 2022-12-30 + * @example + * @author arw + * @since 1.0.0 + */ + public function getCount(): int + { + return $this->count; + } + + /** + * 获取执行上限 + * + * @return integer + * @date 2022-12-28 + * @example + * @author arw + * @since 1.0.0 + */ + public function getLimit(): int + { + return $this->limit; + } + + /** + * 设置执行上限 + * + * @param integer $limit + * @return self + * @date 2022-12-28 + * @example + * @author arw + * @since 1.0.0 + */ + public function setLimit(int $limit): self + { + $this->limit = $limit; + $this->last_limit = $limit; + return $this; + } + + /** + * 设置执行器 + * + * @param callable $cb + * @return self + * @date 2022-12-28 + * @example + * @author arw + * @since 1.0.0 + */ + public function setHandle(callable $cb): self + { + $this->handle = $cb; + return $this; + } + + /** + * 执行是否成功 + * + * @param boolean $success + * @return self + * @date 2022-12-28 + * @example + * @author arw + * @since 1.0.0 + */ + public function success(bool $success): self + { + $this->success = $success; + return $this; + } + + /** + * 重试上限 + * + * @param callable $cb + * @return self + * @date 2022-12-28 + * @example + * @author arw + * @since 1.0.0 + */ + public function onRetryMax(callable $cb): self + { + $this->event('reTryMax', $cb); + return $this; + } + + /** + * 执行异常 + * + * @param callable $cb + * @return self + * @date 2022-12-30 + * @example + * @author arw + * @since 1.0.0 + */ + public function onError(callable $cb): self + { + $this->event('error', $cb); + return $this; + } + + /** + * 执行 + * + * @param mixed ...$args + * @return void + * @date 2022-12-30 + * @example + * @author arw + * @since 1.0.0 + */ + public function run(...$args) + { + $this->reset(); + array_unshift($args, $this); + $handle = $this->handle; + $res = null; + while (true) { + try { + $res = call_user_func_array($handle, $args); + } catch (\Throwable $th) { + $this->trigger('error', [$th]); + } + $this->count++; + // 执行成功 + if ($this->success) { + break; + } + // 执行上限 + if ($this->count > $this->limit) { + // 不减1会导致 获取到的执行次数多1 + $this->count--; + $this->trigger('reTryMax'); + break; + } + } + return $res; + } + + /** + * 重置执行器 + * + * @return void + * @date 2022-12-30 + * @example + * @author arw + * @since 1.0.0 + */ + private function reset(): void + { + $this->count = 1; + $this->setLimit($this->last_limit); + } +} diff --git a/app/common/arw/adjfut/src/Service/Validate.php b/app/common/arw/adjfut/src/Service/Validate.php new file mode 100644 index 0000000..514bdf4 --- /dev/null +++ b/app/common/arw/adjfut/src/Service/Validate.php @@ -0,0 +1,68 @@ +extend('string', function ($value) { + return is_string($value); + }, ':attribute 数据类型非法 不是字符串'); + + $validate->extend('json', function ($value) { + try { + $value = json_decode($value, true); + return is_array($value); + } catch (\Throwable $th) { + // throw $th; + } + return false; + }, ':attribute 数据格式错误 不是json字符串'); + + $validate->extend('modelHas', function ($value, $rule) { + $rules = explode(',', $rule); + $class = Arr::get($rules, 0); + $pk = Arr::get($rules, 1); + if (!class_exists($class)) { + throw new ErrorMsg("$class 类不存在"); + } + /** + * @var \think\Model + */ + $model = new $class; + if (!($model instanceof Model)) { + throw new ErrorMsg("$class 该类未继承 \\think\\Model"); + } + if (!$pk) { + $pk = $model->getPk(); + } + return (bool) $model->where($pk, $value)->value($pk); + }, ':attribute 数据不存在'); + }); + } +} diff --git a/app/common/arw/adjfut/src/Tool.php b/app/common/arw/adjfut/src/Tool.php new file mode 100644 index 0000000..10c7770 --- /dev/null +++ b/app/common/arw/adjfut/src/Tool.php @@ -0,0 +1,196 @@ +$type(json_encode($data, JSON_UNESCAPED_UNICODE)); + } + + /** + * 字段映射 + * + * @param array $data + * @param array $map + * @param array $options + * @return array + * @date 2022-06-23 + * @example + * @author arw + * @since 1.0.0 + */ + public static function fieldMap(array $data, array $map, array $options = []): array + { + $prefix = Arr::get($options, 'prefix', ''); + $result = []; + foreach ($data as $key => $value) { + if (isset($map[$key])) { + $key = $map[$key]; + } + if ($prefix) { + $key = $prefix . $key; + } + $result[$key] = $value; + } + return $result; + } + + /** + * 转换日期格式 + * + * @param string $datetime + * @param string $format + * @return string + * @date 2022-04-20 + * @example + * @author arw + * @since 1.0.0 + */ + public static function conversionDateTime($datetime, string $format): string + { + try { + $date = new DateTime($datetime); + return $date->format($format); + } catch (\Throwable $th) { + throw new ErrorMsg('日期格式非法', 1); + } + } + + /** + * 生成唯一id + * + * @param string|array $value + * @return string + * @date 2022-03-24 + * @example + * @author arw + * @since 1.0.0 + */ + public static function generateGuid($value = ''): string + { + $str = ''; + if (is_array($value)) { + $str = json_encode($value); + } + $charid = strtolower(md5($str . uniqid('', true))); + $hyphen = chr(45); // '-' + $uuid = //chr(123)// '{' + substr($charid, 0, 8) . $hyphen + . substr($charid, 8, 4) . $hyphen + . substr($charid, 12, 4) . $hyphen + . substr($charid, 16, 4) . $hyphen + . substr($charid, 20, 12); + //.chr(125);// '}' + return $uuid; + } + + + /** + * 清空（擦除）缓冲区并关闭输出缓冲 + * + * @return void + */ + public static function obEndClean(): void + { + try { + while (ob_get_level() > 0) { + ob_end_clean(); + } + } catch (\Throwable $th) { + //throw $th; + } + } + + /** + * 自动创建文件夹 + * + * @param string $path 文件夹路径 + * @param integer $mode 权限 + * @return boolean + */ + public static function mkdir(string $path, int $mode = 0755): bool + { + $path = str_replace('/', DIRECTORY_SEPARATOR, $path); + $temp = explode(DIRECTORY_SEPARATOR, $path); + if (preg_match("/\./", end($temp))) { + // pathinfo 不支持中文 + // $path = pathinfo($path, PATHINFO_DIRNAME); + array_splice($temp, count($temp) - 1, 1); + $path = join(DIRECTORY_SEPARATOR, $temp); + } + if (!file_exists($path)) { + mkdir($path, $mode, true); + } + chmod($path, $mode); + return true; + } +} diff --git a/app/common/arw/adjfut/src/Traits/Dictionary.php b/app/common/arw/adjfut/src/Traits/Dictionary.php new file mode 100644 index 0000000..2d3ab09 --- /dev/null +++ b/app/common/arw/adjfut/src/Traits/Dictionary.php @@ -0,0 +1,223 @@ + &$dictionary) { + list($field, $title) = self::getDictionaryField($field); + if (in_array($field, $ignoreField)) { + continue; + } + $value = $this->$field; + if (is_null($value) && $ignoreNull) { + continue; + } + $dictionary = self::getDictionaryFieldMap($field); + $keys = array_keys($dictionary); + if (!in_array($value, $keys)) { + $values = array_values($dictionary); + $msg = join(',', $values); + $errors[] = "$title 应在[ $msg ]"; + } + unset($dictionary); + } + if ($errors) { + throw new ValidateException($errors); + } + } + + /** + * 获取字典值 + * + * @param string $field 字段 + * @param mixed $value 设置器内调用无法会无法获取当前值 需要手动传入 + * @return mixed + * @date 2023-01-11 + * @example + * @author arw + * @since 1.0.0 + */ + public function getDictionaryValue(string $field, $value = null) + { + $map = self::getDictionaryFieldMap($field); + if (is_null($value)) { + $value = $this->$field; + } + if (isset($map[$value])) { + return $value; + } + $key = array_search($value, $map); + if ($key === false) { + $msg = join(',', array_values($map)); + throw new ErrorMsg("$field 应在[ $msg ]", 1); + } + return $key; + } + + /** + * 获取字典名称 + * + * @param string $field 字段 + * @param mixed $default 默认值 如果默认值在字典值内 则返回字典名称 + * @return mixed + * @date 2023-01-11 + * @example + * @author arw + * @since 1.0.0 + */ + public function getDictionaryName(string $field, $default = null) + { + $map = self::getDictionaryFieldMap($field); + if (isset($map[$default])) { + $default = $map[$default]; + } + return Arr::get($map, $this->$field, $default); + } + + /** + * 获取字典名称（弃用保留兼容） + * 请调用 getDictionaryName + * + * @param string $field 字段 + * @param mixed $default 默认值 + * @deprecated 1.0.0 + * @return mixed + * @date 2023-01-10 + * @example + * @author arw + * @since 1.0.0 + */ + public function getDictionaryText(string $field, $default = null) + { + return $this->getDictionaryName($field, $default); + } + + /** + * 获取字典字段映射 + * + * @param string $field 字段 + * @return array + * @date 2023-01-10 + * @example + * @author arw + * @since 1.0.0 + */ + public static function getDictionaryFieldMap(string $field): array + { + list($field) = self::getDictionaryField($field); + $cache = Arr::get(self::$dictionaryCache, $field); + if (is_array($cache)) { + return $cache; + } + $map = Arr::get(self::getDictionaryMap(), $field); + if (!$map) { + throw new ErrorMsg("未定义字段映射", 1); + } + if (is_array($map)) { + self::$dictionaryCache[$field] = $map; + return self::$dictionaryCache[$field]; + } + if (is_string($map)) { + self::$dictionaryCache[$field] = self::getDictionaryModelMap($map); + return self::$dictionaryCache[$field]; + } + return []; + } + + /** + * 获取字典映射 + * + * @return array + * @date 2023-01-10 + * @example + * @author arw + * @since 1.0.0 + */ + public static function getDictionaryMap(): array + { + $self = new self; + $exists = property_exists($self, 'dictionaryMap') && isset($self::$dictionaryMap); + return $exists ? $self::$dictionaryMap : []; + } + + /** + * 获取字典字段 + * + * @param string $value + * @return array + * @date 2023-01-13 + * @example + * @author arw + * @since 1.0.0 + */ + private static function getDictionaryField(string $value): array + { + $temp = explode('|', $value); + $field = Arr::get($temp, '0'); + $title = Arr::get($temp, '1', $field); + return [$field, $title]; + } +} diff --git a/app/common/arw/adjfut/src/Traits/Event.php b/app/common/arw/adjfut/src/Traits/Event.php new file mode 100644 index 0000000..fa7c3f0 --- /dev/null +++ b/app/common/arw/adjfut/src/Traits/Event.php @@ -0,0 +1,62 @@ +event[strtoupper($type)] = $cb; + return $this; + } + + /** + * 事件触发器 + * + * @param string $type + * @param array $args + * @param boolean $withThis + * @return mixed + * @date 2022-12-28 + * @example + * @author arw + * @since 1.0.0 + */ + private function trigger(string $type, array $args = [], bool $withThis = true) + { + $type = strtoupper($type); + if (isset($this->event[$type])) { + if ($withThis) { + array_unshift($args, $this); + } + return call_user_func_array($this->event[$type], $args); + } + } +} diff --git a/app/common/arw/adjfut/src/Traverse.php b/app/common/arw/adjfut/src/Traverse.php new file mode 100644 index 0000000..2ceb857 --- /dev/null +++ b/app/common/arw/adjfut/src/Traverse.php @@ -0,0 +1,240 @@ +current = $current; + $this->parent = $parent; + $this->children = $children; + } + + /** + * 获取子集 + * @access public + * @param array $data 要遍历的数组 + * @param integer|string $id 要查找哪个id下的子集 + * @param bool $loop 是否循环遍历 + * @return array + */ + public function next(array $data = [], $id = 0, bool $loop = false): array + { + $this->setData($data); + $this->setLoop($loop); + return $this->generateNext($id); + } + + /** + * 获取父集 + * @access public + * @param array $data 要遍历的数组 + * @param integer|string $id 要查找哪个id下的父集 + * @param bool $loop 是否循环遍历 + * @return array + */ + public function prev(array $data = [], $id = 0, bool $loop = false): array + { + $this->setData($data); + $this->setLoop($loop); + return $this->generatePrev($id); + } + + /** + * 获取无限层级树状图 + * + * @param array $data 要遍历的数组 + * @param integer|string $parent_id 起点id + * @param callable $format 自定义树数据 + * @return array + * @date 2020-04-09 + * @example + * @author arw + * @since 1.0.0 + */ + public function tree(array $data, $parent_id, callable $format): array + { + $this->setData($data); + $this->setFormat($format); + return $this->generateTree($parent_id); + } + + /** + * 获取全部子集数据 + * + * @param integer|string $id + * @return array + * @date 2022-08-08 + * @example + * @author arw + * @since 1.0.0 + */ + public function getCurrentData($id): array + { + $data = array_filter($this->data, function ($v) use ($id) { + return $v[$this->current] == $id; + }); + $data = array_values($data); + return $data; + } + + /** + * 获取全部父集数据 + * + * @param integer|string $id + * @return array + * @date 2022-08-08 + * @example + * @author arw + * @since 1.0.0 + */ + public function getParentData($id): array + { + $data = array_filter($this->data, function ($v) use ($id) { + return $v[$this->parent] == $id; + }); + $data = array_values($data); + return $data; + } + + /** + * 设置循环 + * + * @param boolean $loop + * @return self + * @date 2022-08-08 + * @example + * @author arw + * @since 1.0.0 + */ + public function setLoop(bool $loop): self + { + $this->loop = $loop; + return $this; + } + + /** + * 设置数据 + * + * @param array $data + * @return self + * @date 2022-08-08 + * @example + * @author arw + * @since 1.0.0 + */ + public function setData(array $data): self + { + $this->data = $data; + return $this; + } + + /** + * 设置格式化函数 + * + * @param callable $cb + * @return self + * @date 2022-08-08 + * @example + * @author arw + * @since 1.0.0 + */ + public function setFormat(callable $cb): self + { + $this->format = $cb; + return $this; + } + + /** + * 生成树 + * + * @param integer|string $parent_id + * @return array + * @date 2022-08-08 + * @example + * @author arw + * @since 1.0.0 + */ + public function generateTree($parent_id): array + { + $data = $this->getParentData($parent_id); + foreach ($data as &$value) { + $children = $this->generateTree($value[$this->current]); + $value[$this->children] = $children; + if (is_callable($this->format)) { + $formatReturn = call_user_func($this->format, $value); + if (!isset($formatReturn[$this->children])) { + $formatReturn[$this->children] = $children; + } + if ($formatReturn) { + $value = $formatReturn; + } + } + unset($value); + } + return $data; + } + + /** + * 获取子集 + * + * @param integer|string $id + * @return array + * @date 2022-08-08 + * @example + * @author arw + * @since 1.0.0 + */ + public function generateNext($id): array + { + $re = []; + $data = $this->getParentData($id); + foreach ($data as $value) { + $current = $value[$this->current]; + $re[] = $current; + if ($this->loop) { + $re = array_merge($re, $this->generateNext($current)); + } + } + return array_unique($re); + } + + + /** + * 获取父集 + * + * @param integer|string $id + * @return array + * @date 2022-08-08 + * @example + * @author arw + * @since 1.0.0 + */ + public function generatePrev($id): array + { + $re = []; + $data = $this->getCurrentData($id); + foreach ($data as $value) { + $parent = $value[$this->parent]; + $re[] = $parent; + if ($this->loop) { + $re = array_merge($re, $this->generatePrev($parent)); + } + } + return array_unique($re); + } +} diff --git a/app/common/arw/adjfut/src/Unit/File.php b/app/common/arw/adjfut/src/Unit/File.php new file mode 100644 index 0000000..87c8072 --- /dev/null +++ b/app/common/arw/adjfut/src/Unit/File.php @@ -0,0 +1,86 @@ += self::INTERVAL && $i < 4; $i++) { + $size = bcdiv($size, self::INTERVAL); + } + return round($size, 2) . self::ORDER[$i]; + } + + public static function __callStatic($name, $arguments) + { + $number = Arr::get($arguments, 0, 0); + $scale = Arr::get($arguments, 1, 0); + $name = Str::lower($name); + $a = null; + $b = null; + if (Str::contains($name, 2)) { + list($a, $b) = explode('2', $name); + } else { + list($a, $b) = explode('to', $name); + } + $a_index = array_search($a, self::ORDER); + $b_index = array_search($b, self::ORDER); + $type = $a_index < $b_index; + for ($i = 0; $i < abs(bcsub($a_index, $b_index, 0)); $i++) { + if ($type) { + $number = bcdiv($number, self::INTERVAL, $scale); + } else { + $number = bcmul($number, self::INTERVAL, $scale); + } + } + return $number; + } +} diff --git a/app/common/arw/adjfut/src/UploadFile.php b/app/common/arw/adjfut/src/UploadFile.php new file mode 100644 index 0000000..ccb0ac4 --- /dev/null +++ b/app/common/arw/adjfut/src/UploadFile.php @@ -0,0 +1,289 @@ + $file + ], [ + 'file|文件' => $validate + ]); + } catch (ValidateException $th) { + $this->getDisk()->delete($file->getFilename()); + throw $th; + } + } + + $this->diskName = $diskName; + $this->file = $file; + } + + /** + * 上传base64图片 + * + * @param string $diskName 磁盘 + * @param string $base64 base64 + * @return self + * @date 2023-01-09 + * @example + * @author arw + * @since 1.0.0 + */ + public static function uploadBase64Image( + string $diskName, + string $base64 + ): self { + $Base64 = new Base64($base64); + if (!$Base64->isImage()) { + throw new ErrorMsg("非法图片base64", 1); + } + $path = tempnam(sys_get_temp_dir(), 'saveBase64Image'); + $Base64->saveImage($path); + $name = md5(md5_file($path) . Tool::generateGuid() . time()) . '.' . $Base64->getFileExt(); + return new self($diskName, '', [ + $path, + $name + ]); + } + + /** + * 获取文件 + * + * @return UploadedFile + * @date 2022-07-05 + * @example + * @author arw + * @since 1.0.0 + */ + public function getFile(): UploadedFile + { + return $this->file; + } + + /** + * 获取磁盘名称 + * + * @return string + * @date 2022-07-05 + * @example + * @author arw + * @since 1.0.0 + */ + public function getDiskName(): string + { + return $this->diskName; + } + + /** + * 获取配置项 + * + * @param string $key + * @param mixed $default + * @return mixed + * @date 2022-04-15 + * @example + * @author arw + * @since 1.0.0 + */ + public function getConfig(string $key, $default = null) + { + return Arr::get( + Filesystem::getDiskConfig($this->diskName), + $key, + $default + ); + } + + /** + * 获取文件相对路径 + * + * @date 2022-04-15 + * @example + * @author arw + * @since 1.0.0 + */ + public function getPath(): string + { + if (!$this->path) { + throw new ErrorMsg("请保存文件后使用", 1); + } + return $this->path; + } + + /** + * 获取文件真实路径 + * + * @return string + * @date 2022-07-19 + * @example + * @author arw + * @since 1.0.0 + */ + public function getRealPath(): string + { + $path = $this->getPath(); + if ($this->getConfig('type') != 'local') { + throw new ErrorMsg("非本地文件类型 无法获取真实路径", 1); + } + return str_replace(['\\', '/'], [DIRECTORY_SEPARATOR, DIRECTORY_SEPARATOR], $this->getConfig('root') . DIRECTORY_SEPARATOR . $path); + } + + /** + * 获取文件绝对路径 + * + * @date 2022-04-15 + * @deprecated 1.0.0 + * @example + * @author arw + * @since 1.0.0 + */ + public function getFullPath(): string + { + return $this->getRealPath(); + } + + /** + * 保存文件 + * @param string $path 路径 + * @param null|string|\Closure $rule 文件名规则 + * @param array $options 参数 + * @return string + */ + public function putFile( + string $path, + $rule = null, + array $options = [] + ): string { + $this->path = $this->getDisk()->putFile( + $path, + $this->file, + $rule, + $options + ); + if (!$this->path) { + throw new ErrorMsg("文件保存失败", 1); + } + return $this->path; + } + + /** + * 指定文件名保存文件 + * @param string $path 路径 + * @param string $name 文件名 + * @param array $options 参数 + * @return string + */ + public function putFileAs( + string $path, + string $name = '', + array $options = [] + ): string { + $this->path = $this->getDisk()->putFileAs( + $path, + $this->file, + $name, + $options + ); + if (!$this->path) { + throw new ErrorMsg("文件保存失败", 1); + } + return $this->path; + } + + /** + * 删除文件 + * + * @return void + * @date 2022-08-22 + * @example + * @author arw + * @since 1.0.0 + */ + public function delete(): void + { + $this->getDisk()->delete($this->file->getFilename()); + } + + /** + * 移除文件 + * + * @date 2022-04-15 + * @deprecated 1.0.0 + * @example + * @author arw + * @since 1.0.0 + */ + public function unlink(): void + { + $this->delete(); + } + + /** + * 获取存储配置 + * + * @return Driver + * @date 2022-04-15 + * @example + * @author arw + * @since 1.0.0 + */ + public function getDisk(): Driver + { + return Filesystem::disk($this->diskName); + } +} diff --git a/app/common/arw/adjfut/src/Validate.php b/app/common/arw/adjfut/src/Validate.php new file mode 100644 index 0000000..bd598b8 --- /dev/null +++ b/app/common/arw/adjfut/src/Validate.php @@ -0,0 +1,254 @@ +data = $data; + return $this; + } + + /** + * 当条件满足时 验证 + * + * @param array $when + * @param array $validate + * @param array $message + * @param bool $batch + * @return void + */ + public function when(array $when, array $validate, array $message = [], bool $batch = true): void + { + $data = $this->data; + $whenCount = 0; + foreach ($when as $field => $value) { + if (!isset($data[$field])) { + continue; + } + if ($data[$field] == $value) { + $whenCount++; + } + } + $_validate = $whenCount == count($when); + if ($_validate) { + self::check($data, $validate, $message, $batch); + } + } + + /** + * 验证是否唯一 + * + * @param string $model 模型类 + * @param string|int $id 排除主键id + * @param array $rules[field] => name,validateField,pk|其他规则 + * @param array $message 提示信息 + * @param bool $batch 是否批量验证 + * @return void + * @throws ValidateException + */ + public static function unique( + string $model, + $id, + array $data, + array $rules = [], + array $message = [], + bool $batch = true + ): void { + $_rules = []; + foreach ($rules as $field => $validate) { + $validates = explode('|', $validate); + $_rule = explode(',', $validates[0]); + $name = Arr::get($_rule, 0); + $validateField = Arr::get($_rule, 1); + $pk = Arr::get($_rule, 2); + + $validates[0] = self::createUniqueRule($model, [ + 'field' => $validateField ?: $field, + 'id' => $id, + 'pk' => $pk, + ]); + + $_rules[$field . ($name ? "|$name" : '')] = $validates; + } + self::check($data, $_rules, $message, $batch); + } + + /** + * 创建数据表唯一验证 + * + * @param string $class 模型类 + * @param array $options 配置项 + * @param string $options[field] 字段名 + * @param string $options[id] 排除ID + * @param string $options[pk] 主键名 + * @return string + * @date 2022-04-16 + * @example + * @author arw + * @since 1.0.0 + */ + public static function createUniqueRule(string $class, array $options = []): string + { + $field = Arr::get($options, 'field'); + $id = Arr::get($options, 'id'); + $pk = Arr::get($options, 'pk'); + if (!$field) { + throw new ErrorMsg("字段名不能为空", 1); + } + return 'unique:' . join(',', [ + $class, + $field, + $id, + $pk + ]); + } + + /** + * 类场景验证 + * + * @param string $validate + * @param string $scene + * @param boolean $batch + * @return void + * @throws ValidateException + */ + public static function classScene(array $validate, array $data, bool $batch = true): void + { + list($class, $scene) = $validate; + /** + * @var ThinkValidate + */ + $validate = new $class; + $validate->scene($scene)->batch($batch); + $validate->failException(true)->check($data); + } + + /** + * 类场景验证 param参数 + * + * @param array $validate + * @param boolean $batch + * @return array + * @throws ValidateException + */ + public static function classSceneParam(array $validate, bool $batch = true): array + { + $data = Request::param(); + self::classScene($validate, $data, $batch); + return $data; + } + + + /** + * 类场景验证 get参数 + * + * @param array $validate + * @param boolean $batch + * @return array + * @throws ValidateException + */ + public static function classSceneGet(array $validate, bool $batch = true): array + { + $data = Request::get(); + self::classScene($validate, $data, $batch); + return $data; + } + + /** + * 类场景验证 post参数 + * + * @param array $validate + * @param boolean $batch + * @return array + * @throws ValidateException + */ + public static function classScenePost(array $validate, bool $batch = true): array + { + $data = Request::post(); + self::classScene($validate, $data, $batch); + return $data; + } + + /** + * param参数验证 + * + * @param array $validate 验证规则数组 + * @param array $message 提示信息 + * @param bool $batch 是否批量验证 + * @return array + * @throws ValidateException + */ + public static function param(array $validate, array $message = [], bool $batch = true): array + { + $data = Request::param(); + self::check($data, $validate, $message, $batch); + return $data; + } + + /** + * get参数验证 + * + * @param array $validate 验证规则数组 + * @param array $message 提示信息 + * @param bool $batch 是否批量验证 + * @return array + * @throws ValidateException + */ + public static function get(array $validate, array $message = [], bool $batch = true): array + { + $data = Request::get(); + self::check($data, $validate, $message, $batch); + return $data; + } + + + /** + * post参数验证 + * + * @param array $validate 验证规则数组 + * @param array $message 提示信息 + * @param bool $batch 是否批量验证 + * @return array + * @throws ValidateException + */ + public static function post(array $validate, array $message = [], bool $batch = true): array + { + $data = Request::post(); + self::check($data, $validate, $message, $batch); + return $data; + } + + /** + * 验证数据 + * + * @param array $data 数据 + * @param array $validate 验证规则数组 + * @param array $message 提示信息 + * @param bool $batch 是否批量验证 + * @return void + * @throws ValidateException + */ + public static function check(array $data, array $validate, array $message = [], bool $batch = true): void + { + $v = new ThinkValidate(); + $v->rule($validate); + $v->message($message); + $v->batch($batch); + $v->failException(true)->check($data); + } +} diff --git a/app/common/arw/adjfut/src/WeChat/Config.php b/app/common/arw/adjfut/src/WeChat/Config.php new file mode 100644 index 0000000..3480c6e --- /dev/null +++ b/app/common/arw/adjfut/src/WeChat/Config.php @@ -0,0 +1,123 @@ + '', + 'server_base' => '', + // 小程序配置 + 'xcx' => [ + 'appid' => '', + 'secret' => '', + + 'cache_key' => '', + 'log_channel' => '', + ], + // 公众号配置 + 'gzh' => [ + 'appid' => '', + 'secret' => '', + // 推送模板 + 'template' => [ + '模板名称' => '模板id' + ], + + 'cache_key' => '', + 'log_channel' => '', + ], + ]; + + public function __construct() + { + $setConfig = function (string $key) { + $this->setConfig($key, FacadeConfig::get("wechat.$key")); + }; + foreach ([ + 'access_key', 'server_base', + 'xcx.cache_key', 'xcx.log_channel', + 'xcx.appid', 'xcx.secret', + 'gzh.cache_key', 'gzh.log_channel', + 'gzh.appid', 'gzh.secret', 'gzh.template' + ] as $key) { + $setConfig($key); + } + } + + /** + * 实例 + * + * @return self + * @date 2022-05-19 + * @example + * @author arw + * @since 1.0.0 + */ + public static function instance(): self + { + if (!self::$instance) { + self::$instance = new self; + } + return self::$instance; + } + + /** + * 设置配置项 + * + * @param string $key + * @param mixed $value + * @return void + * @date 2022-05-19 + * @example + * @author arw + * @since 1.0.0 + */ + public function setConfig(string $key, $value) + { + Arr::set($this->config, $key, $value); + } + + /** + * 获取配置项 + * + * @param string $key + * @param mixed $default + * @return mixed + * @date 2022-05-19 + * @example + * @author arw + * @since 1.0.0 + */ + public static function get(string $key, $default = null) + { + return Arr::get( + self::instance()->config, + $key, + $default + ); + } +} diff --git a/app/common/arw/adjfut/src/WeChat/Gzh.php b/app/common/arw/adjfut/src/WeChat/Gzh.php new file mode 100644 index 0000000..2384443 --- /dev/null +++ b/app/common/arw/adjfut/src/WeChat/Gzh.php @@ -0,0 +1,348 @@ +_AccessToken($refresh); + } + + /** + * 获取JsApiTicket + * + * @param boolean $refresh 是否强制刷新 + * @return void + * @date 2020-05-29 + * @example + * @author arw + * @since 1.0.0 + */ + public function GetJsApiTicket($refresh = false) + { + return $this->_JsApiTicket($refresh); + } + + /** + * 网页授权/获取用户基本信息 + * https://developers.weixin.qq.com/doc/offiaccount/OA_Web_Apps/Wechat_webpage_authorization.html + * @param array $config 配置项 [ + * "scope" => "snsapi_base", 应用授权作用域， + * snsapi_base （不弹出授权页面，直接跳转，只能获取用户openid）， + * snsapi_userinfo （弹出授权页面，可通过openid拿到昵称、性别、所在地。并且， 即使在未关注的情况下，只要用户授权，也能获取其信息 ） + * "state" => "", 重定向后会带上state参数，开发者可以填写a-zA-Z0-9的参数值，最多128字节 + * "lang" => "zh_CN", 当scope等于snsapi_userinfo才生效 + * 返回国家地区语言版本，zh_CN 简体，zh_TW 繁体，en 英语 + * ] + * @param callable $success 回调用户授权成功调用函数 ($userinfo,$state) + * @param callable $error 执行错误回调 ($msg) + * @return null + */ + public function authorize(array $config, callable $success, callable $error) + { + try { + $config["scope"] = Arr::get($config, "scope", "snsapi_base"); + $config["state"] = Arr::get($config, "state", ""); + $config["lang"] = Arr::get($config, "lang", "zh_CN"); + + $config["redirect_uri"] = Arr::get($config, "redirect_uri", Request::url(true)); + + $code = Arr::get($_GET, "code"); + + if (!$code) { + $url = "https://open.weixin.qq.com/connect/oauth2/authorize"; + $url .= "?" . http_build_query([ + "appid" => $this->appid, + "redirect_uri" => $config["redirect_uri"], + "response_type" => "code", + "scope" => $config["scope"], + "state" => $config["state"], + ]); + $url .= "#wechat_redirect"; + return Response::create($url, 'redirect', 302); + } + $curl = Curl::instance(); + $param = []; + $param["appid"] = $this->appid; + $param["secret"] = $this->secret; + $param["code"] = $code; + $param["grant_type"] = "authorization_code"; + $url = "https://api.weixin.qq.com/sns/oauth2/access_token"; + $access_token = $curl->setParams($param)->get($url); + + $judge = (Arr::get($access_token, "access_token") && Arr::get($access_token, "openid")); + if (!$judge || !$access_token) { + $this->log([ + 'action' => __FUNCTION__, + 'url' => $curl->getUrl(), + 'params' => $curl->getParams(), + 'content' => $curl->getContent(), + 'msg' => '获取access_token失败', + ], 'error'); + return $error("获取access_token失败"); + } + if ($config["scope"] === "snsapi_userinfo") { + $curl = Curl::instance(); + $url = "https://api.weixin.qq.com/sns/userinfo"; + $param = []; + $param["access_token"] = Arr::get($access_token, "access_token"); + $param["openid"] = Arr::get($access_token, "openid"); + $param["lang"] = $config["lang"]; + $user_info = $curl->setParams($param)->get($url); + $errcode = Arr::get($user_info, "errcode", false); + if ($errcode !== false) { + $this->log([ + 'action' => __FUNCTION__, + 'url' => $curl->getUrl(), + 'params' => $curl->getParams(), + 'result' => $curl->getContent(), + 'msg' => '获取用户信息失败', + ], 'error'); + return $error("获取微信用户信息失败"); + } + $access_token = array_merge($access_token, $user_info); + } + return $success($access_token, $_GET["state"]); + } catch (\Throwable $th) { + $this->log([ + 'action' => __FUNCTION__, + 'msg' => '客户端错误：' . $th->getMessage(), + 'line' => $th->getLine(), + 'file' => $th->getFile(), + ], 'error'); + return $error($th->getMessage()); + } + } + + /** + * 微信模板消息推送 + * 微信返回errcode等于40001会更新缓存AccessToken + * 并重新推送一次 + * https://developers.weixin.qq.com/doc/offiaccount/Message_Management/Template_Message_Interface.html#5 + * @param string $touser 推送给谁 + * @param string $template_id 模板名称 + * @param array $data 推送数据 + * [ + * "touser" => "openid", + * "template_id" => "template_id", + * "url" => "url", + * "miniprogram" => [ + * "appid" => "appid", + * "pagepath" => "pagepath", + * ], + * "data" => [ + * "first" => [ + * "value" => "value", + * "color" => "color", + * ], + * "keyword1" => [ + * "value" => "value", + * "color" => "color", + * ], + * "keyword2" => [ + * "value" => "value", + * "color" => "color", + * ], + * "keyword3" => [ + * "value" => "value", + * "color" => "color", + * ], + * "remark" => [ + * "value" => "value", + * "color" => "color", + * ], + * ], + * ] + * @param boolean $refresh 是否刷新【 access_token 】 + * @param integer $limit 调用上限（允许自动重试次数） + * @return bool + * @date 2020-05-26 + * @example + * @author arw + * @since 1.1.1 + */ + public function TemplateMessageInterface($touser = null, $template_id = null, array $data, $refresh = false, $limit = 3) + { + $this->log([ + 'action' => __FUNCTION__, + 'touser' => $touser, + 'template_id' => $template_id, + 'data' => $data, + ], 'log'); + try { + $template = $this->template; + if (!$touser) { + if (isset($data["touser"])) { + $touser = $data["touser"]; + } + } + if (!$template_id) { + if (isset($data["template_id"])) { + $template_id = $data["template_id"]; + } + } + if (empty($touser)) { + throw new \Exception("data.touser不能为空", 1); + } + if (empty($template_id)) { + throw new \Exception("data.template_id不能为空", 1); + } else { + if (isset($template[$template_id])) { + $template_id = $template[$template_id]; + } + } + $data["touser"] = $touser; + $data["template_id"] = $template_id; + $limit--; + if ($limit <= 0) { + throw new \Exception("超过调用上限", 1); + } + $access_token = $this->_AccessToken($refresh); + if (!$access_token) { + return false; + } + $appid = Arr::get($data, "miniprogram.appid"); + if ($appid == 'APPID') { + Arr::set($data, 'miniprogram.appid', Config::get('xcx.appid')); + } + $param = json_encode($data); + if (!isset(self::$TemplateMessageInterfaceCache[$param])) { + self::$TemplateMessageInterfaceCache[$param] = []; + } + if (in_array($touser, self::$TemplateMessageInterfaceCache[$param])) { + throw new \Exception("重复推送", 1); + } + $url = "https://api.weixin.qq.com/cgi-bin/message/template/send"; + $url .= "?access_token=" . $access_token; + $curl = Curl::instance(); + $send = $curl->setData($param)->post($url); + + $errcode = Arr::get($send, "errcode", false); + if ($errcode === 0) { + self::$TemplateMessageInterfaceCache[$param][] = $touser; + return true; + } + if ($errcode === 40001) { + return $this->TemplateMessageInterface($touser, $template_id, $data, true, $limit); + } + + $this->log([ + 'action' => __FUNCTION__, + 'url' => $curl->getUrl(), + 'params' => $curl->getData(), + 'content' => $curl->getContent(), + 'msg' => '模板消息推送失败', + ], 'error'); + } catch (\Throwable $th) { + $this->log([ + 'action' => __FUNCTION__, + 'msg' => '客户端错误：' . $th->getMessage(), + 'line' => $th->getLine(), + 'file' => $th->getFile(), + ], 'error'); + } + return false; + } + + /** + * Jssdk授权 + * @param string $url 授权url + * @return null + */ + public function JsSdk(string $url = "") + { + $jsapiTicket = $this->_JsApiTicket(); + $protocol = (!empty($_SERVER['HTTPS']) && $_SERVER['HTTPS'] !== 'off' || $_SERVER['SERVER_PORT'] == 443) ? "https://" : "http://"; + if (!$url) { + $url = "$protocol$_SERVER[HTTP_HOST]$_SERVER[REQUEST_URI]"; + } + + $timestamp = time(); + + $chars = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789"; + $nonceStr = ""; + for ($i = 0; $i < 16; $i++) { + $nonceStr .= substr($chars, mt_rand(0, strlen($chars) - 1), 1); + } + + // 这里参数的顺序要按照 key 值 ASCII 码升序排序 + $string = "jsapi_ticket=$jsapiTicket&noncestr=$nonceStr×tamp=$timestamp&url=$url"; + + $signature = sha1($string); + + $signPackage = [ + "appId" => $this->appid, + "nonceStr" => $nonceStr, + "timestamp" => $timestamp, + "url" => $url, + "signature" => $signature, + "rawString" => $string, + ]; + return $signPackage; + } +} diff --git a/app/common/arw/adjfut/src/WeChat/GzhCommon.php b/app/common/arw/adjfut/src/WeChat/GzhCommon.php new file mode 100644 index 0000000..d9cfbca --- /dev/null +++ b/app/common/arw/adjfut/src/WeChat/GzhCommon.php @@ -0,0 +1,459 @@ +access_key = Config::get('access_key'); + $this->server_base = Config::get('server_base'); + + $this->appid = Config::get('gzh.appid'); + $this->secret = Config::get('gzh.secret'); + $this->template = Config::get('gzh.template'); + $this->cache_key = Config::get('gzh.cache_key'); + $this->log_channel = Config::get('gzh.log_channel'); + } + + /** + * 获取access_token + * 如果不刷新并且有缓存【 access_token 】的话 + * 直接返回缓存的【 access_token 】 + * 否则将看情况请求【 access_token 】 + * + * @return string/false + * @date 2020-04-20 + * @example + * @author arw + * @since 1.0.2 + */ + protected function _AccessToken($refresh = false) + { + $cache_key = $this->getAccessTokenCacheKey(); + if ($refresh && $cache_key) { + Cache::delete($cache_key); + } + if ($refresh === false && $this->access_token) { + return $this->access_token; + } + $access_token = $this->_GetAccessToken($refresh); + if ($access_token) { + $this->access_token = $access_token; + return $access_token; + } else { + $access_token = $this->_GetCacheAccessToken(); + if (!$access_token) { + $access_token = $this->_CurlAccessToken(); + } + $this->access_token = $access_token; + return $access_token; + } + return false; + } + + /** + * 获取jsapiticket + * + * @return string/false + * @date 2020-04-20 + * @example + * @author arw + * @since 1.0.0 + */ + protected function _JsApiTicket($refresh = false) + { + $cache_key = $this->getJsApiTicketCacheKey(); + if ($refresh && $cache_key) { + Cache::delete($cache_key); + } + $ticket = $this->_GetJsApiTicket($refresh); + if ($ticket) { + return $ticket; + } else { + $ticket = $this->_GetCacheJsApiTicket(); + if (!$ticket) { + $ticket = $this->_CurlJsApiTicket(); + } + return $ticket; + } + return false; + } + + /** + * 异常记录 + * + * @param array $content + * @param string $level alert | error | warning | notice | info | debug + * @return void + * @date 2020-05-29 + * @example + * @author arw + * @since 1.0.0 + */ + protected function log(array $data, string $level = 'log') + { + $log_channel = $this->log_channel; + if ($log_channel) { + Log::channel($log_channel)->log($level, json_encode($data)); + } + } + + /** + * 请求【中控层服务器】 获取access_token + * @param boolean $refresh + * @return string/false + * @date 2020-04-20 + * @example + * @author arw + * @since 2.0.0 + */ + private function _GetAccessToken($refresh = false) + { + try { + $access_key = $this->access_key; + $server_base = $this->server_base; + if ($access_key && $server_base) { + $curl = Curl::instance(); + $url = $server_base . "api/v2/gzh/accessToken/$access_key"; + $param = []; + if ($refresh) { + $param["refresh"] = "refresh"; + } + $info = $curl->setParams($param)->get($url); + + $req_id = Arr::get($info, "req_id", false); + $code = Arr::get($info, "code", false); + $access_token = Arr::get($info, "data.access_token", false); + + if (!$access_token) { + $this->log([ + 'action' => __FUNCTION__, + 'url' => $curl->getUrl(), + 'params' => $curl->getParams(), + 'content' => $curl->getContent(), + 'msg' => '获取access_token失败', + ], 'error'); + } + return $access_token; + } + } catch (\Throwable $th) { + $this->log([ + 'action' => __FUNCTION__, + 'msg' => '客户端错误：' . $th->getMessage(), + 'line' => $th->getLine(), + 'file' => $th->getFile(), + ], 'error'); + } + return false; + } + + /** + * 获取本地缓存【access_token】 + * + * @return string|false + * @date 2022-12-26 + * @example + * @author arw + * @since 1.0.0 + */ + private function _GetCacheAccessToken() + { + try { + $cache_key = $this->getAccessTokenCacheKey(); + if ($cache_key) { + $access_token = Cache::get($cache_key); + if ($access_token) { + return $access_token; + } + } + } catch (\Throwable $th) { + $this->log([ + 'action' => __FUNCTION__, + 'msg' => '客户端错误：' . $th->getMessage(), + 'line' => $th->getLine(), + 'file' => $th->getFile(), + ], 'error'); + } + return false; + } + + /** + * 获取本地缓存【jsapiticket】 + * + * @return string|false + * @date 2022-12-26 + * @example + * @author arw + * @since 1.0.0 + */ + private function _GetCacheJsApiTicket() + { + try { + $cache_key = $this->getJsApiTicketCacheKey(); + if ($cache_key) { + $ticket = Cache::get($cache_key); + if ($ticket) { + return $ticket; + } + } + } catch (\Throwable $th) { + $this->log([ + 'action' => __FUNCTION__, + 'msg' => '客户端错误：' . $th->getMessage(), + 'line' => $th->getLine(), + 'file' => $th->getFile(), + ], 'error'); + } + return false; + } + + /** + * 请求【微信服务器】 获取access_token + * + * @return string/false + * @date 2020-04-20 + * @example + * @author arw + * @since 1.0.0 + */ + private function _CurlAccessToken() + { + try { + $cache_key = $this->getAccessTokenCacheKey(); + $curl = Curl::instance(); + $url = "https://api.weixin.qq.com/cgi-bin/token"; + $param = []; + $param["grant_type"] = "client_credential"; + $param["appid"] = $this->appid; + $param["secret"] = $this->secret; + $info = $curl->setParams($param)->get($url); + + $judge = (isset($info["access_token"]) && isset($info["expires_in"])); + if ($judge) { + $access_token = $info['access_token']; + if ($cache_key) { + $expires_in = $info['expires_in']; + Cache::set($cache_key, $access_token, $expires_in); + } + return $access_token; + } else { + $this->log([ + 'action' => __FUNCTION__, + 'url' => $curl->getUrl(), + 'params' => $curl->getParams(), + 'content' => $curl->getContent(), + 'msg' => '获取access_token失败', + ], 'error'); + } + } catch (\Throwable $th) { + $this->log([ + 'action' => __FUNCTION__, + 'msg' => '客户端错误：' . $th->getMessage(), + 'line' => $th->getLine(), + 'file' => $th->getFile(), + ], 'error'); + } + return false; + } + + /** + * 请求【中控层服务器】 获取jsapiticket + * @param boolean $refresh + * @return string/false + * @date 2020-04-20 + * @example + * @author arw + * @since 2.0.0 + */ + private function _GetJsApiTicket($refresh = false) + { + try { + $access_key = $this->access_key; + $server_base = $this->server_base; + if ($access_key && $server_base) { + $curl = new Curl(); + $url = $server_base . "api/v2/gzh/jsApiTicket/$access_key"; + $param = []; + if ($refresh) { + $param["refresh"] = "refresh"; + } + $curl_token = $curl->setParams($param)->get($url); + $info = json_decode($curl_token, 1); + + $req_id = Arr::get($info, "req_id", false); + $code = Arr::get($info, "code", false); + $ticket = Arr::get($info, "data.ticket", false); + + if (!$ticket) { + $this->log([ + 'action' => __FUNCTION__, + 'url' => $curl->getUrl(), + 'params' => $curl->getParams(), + 'content' => $curl->getContent(), + 'msg' => '获取jsapiticket失败', + ], 'error'); + } + return $ticket; + } + } catch (\Throwable $th) { + $this->log([ + 'action' => __FUNCTION__, + 'msg' => '客户端错误：' . $th->getMessage(), + 'line' => $th->getLine(), + 'file' => $th->getFile(), + ], 'error'); + } + return false; + } + + /** + * 请求【微信服务器】 获取jsapiticket + * + * @return string/false + * @date 2020-04-20 + * @example + * @author arw + * @since 1.0.0 + */ + private function _CurlJsApiTicket() + { + try { + $cache_key = $this->getJsApiTicketCacheKey(); + $curl = Curl::instance(); + $url = "https://api.weixin.qq.com/cgi-bin/ticket/getticket"; + $param = []; + $param["access_token"] = $this->_AccessToken(); + $param["type"] = "jsapi"; + $info = $curl->setParams($param)->get($url); + + $judge = (isset($info["ticket"]) && isset($info["expires_in"])); + if ($judge) { + $ticket = $info['ticket']; + if ($cache_key) { + $expires_in = $info['expires_in']; + Cache::set($cache_key, $ticket, $expires_in); + } + return $ticket; + } else { + $this->log([ + 'action' => __FUNCTION__, + 'url' => $curl->getUrl(), + 'params' => $curl->getParams(), + 'content' => $curl->getContent(), + 'msg' => '获取jsapiticket失败', + ], 'error'); + } + } catch (\Throwable $th) { + $this->log([ + 'action' => __FUNCTION__, + 'msg' => '客户端错误：' . $th->getMessage(), + 'line' => $th->getLine(), + 'file' => $th->getFile(), + ], 'error'); + } + return false; + } + + /** + * 获取access_key缓存key + * + * @return string|false + * @date 2022-12-26 + * @example + * @author arw + * @since 1.0.0 + */ + private function getAccessTokenCacheKey() + { + if ($this->cache_key) { + return $this->cache_key . '.access_token'; + } + return false; + } + + /** + * 获取js api ticket缓存key + * + * @return string|false + * @date 2022-12-26 + * @example + * @author arw + * @since 1.0.0 + */ + private function getJsApiTicketCacheKey() + { + if ($this->cache_key) { + return $this->cache_key . '.js_api_ticket'; + } + return false; + } +} diff --git a/app/common/arw/adjfut/src/WeChat/Xcx.php b/app/common/arw/adjfut/src/WeChat/Xcx.php new file mode 100644 index 0000000..cc35b30 --- /dev/null +++ b/app/common/arw/adjfut/src/WeChat/Xcx.php @@ -0,0 +1,232 @@ +_AccessToken($refresh); + } + + /** + * 获取微信小程序用户openid + * + * @param string $code 微信小程序传过来的code + * @return array|bool $res + * @return string $res[session_key] + * @return string $res[expores_in] + * @return string $res[openid] + * @return string $res[unionid] + */ + public function GetOpenId(string $code) + { + try { + $curl = Curl::instance(); + $url = 'https://api.weixin.qq.com/sns/jscode2session'; + $param = []; + $param['appid'] = $this->appid; + $param['secret'] = $this->secret; + $param['js_code'] = $code; + $param['grant_type'] = 'authorization_code'; + $res = $curl->setParams($param)->get($url); + $openid = Arr::get($res, 'openid', false); + if ($openid) { + return $res; + } + $this->log([ + 'action' => __FUNCTION__, + 'url' => $curl->getUrl(), + 'params' => $curl->getParams(), + 'content' => $curl->getContent(), + 'msg' => '获取小程序用户openid失败，微信服务器无返回openid', + ], 'error'); + $this->error = '获取用户openid失败'; + return false; + } catch (\Throwable $th) { + $this->log([ + 'action' => __FUNCTION__, + 'msg' => '客户端错误：' . $th->getMessage(), + 'line' => $th->getLine(), + 'file' => $th->getFile(), + ], 'error'); + $this->error = $th->getMessage(); + return false; + } + } + + /** + * 获取微信小程序用户unionid + * @param string $code 微信小程序传过来的wx.login 返回的code + * @param string $encryptedData 微信小程序传过来的wx.getUserInfo 返回的encryptedData + * @param string $iv 微信小程序传过来的wx.getUserInfo 返回的iv + */ + public function GetUnionid(string $code, string $encryptedData, string $iv) + { + try { + $result = $this->GetOpenId($code); + if (!$result) { + return false; + } + $openid = Arr::get($result, 'openid'); + $session_key = Arr::get($result, 'session_key'); + if (!$openid || !$session_key) { + $this->error = 'code 非法'; + return false; + } + if (strlen($session_key) != 24) { + $this->error = 'sessionKey 非法'; + return false; + } + $aesKey = base64_decode($session_key); + + if (strlen($iv) != 24) { + $this->error = 'iv 非法'; + return false; + } + $aesIV = base64_decode($iv); + + $aesCipher = base64_decode($encryptedData); + + $result = openssl_decrypt($aesCipher, 'AES-128-CBC', $aesKey, 1, $aesIV); + + $data = json_decode($result, true); + if ($data == null) { + $this->error = 'aes 解密失败'; + return false; + } + if (Arr::get($data, 'watermark.appid') != $this->appid) { + $this->error = 'appid不一致'; + return false; + } + return $data; + } catch (\Throwable $th) { + $this->log([ + 'action' => __FUNCTION__, + 'msg' => '客户端错误：' . $th->getMessage(), + 'line' => $th->getLine(), + 'file' => $th->getFile(), + ], 'error'); + } + } + + /** + * 生成微信小程序码 + * @param string $type 接口名称 （createQRCode/get/getUnlimited） + * @param array $data 请求参数 + */ + public function QrCode(string $type, array $data) + { + return $this->_QrCode($type, $data); + } + + private function _QrCode(string $type, array $data, bool $refresh = false, int $limit = 3) + { + try { + $limit--; + if ($limit <= 0) { + throw new \Exception('超过调用上限', 1); + } + $urls = [ + 'createQRCode' => 'https://api.weixin.qq.com/cgi-bin/wxaapp/createwxaqrcode', + ]; + $curl = Curl::instance(); + $url = $urls[$type]; + $url .= '?access_token=' . $this->GetAccessToken($refresh); + $param = json_encode($data); + $res = $curl->setParams($param)->post($url); + + $errcode = Arr::get($res, 'errcode', false); + $errmsg = Arr::get($res, 'errmsg', false); + if ($errcode === false && $errmsg === false) { + return base64_encode($res); + } else { + if ($errcode === 40001) { + return $this->_QrCode($type, $data, true, $limit); + } + $this->log([ + 'action' => __FUNCTION__, + 'url' => $curl->getUrl(), + 'params' => $curl->getData(), + 'content' => $curl->getContent(), + 'msg' => '获取小程序二维码失败，微信服务器返回数据异常', + ], 'error'); + $this->error = '获取小程序二维码失败'; + return false; + } + } catch (\Throwable $th) { + $this->log([ + 'action' => __FUNCTION__, + 'msg' => '客户端错误：' . $th->getMessage(), + 'line' => $th->getLine(), + 'file' => $th->getFile(), + ], 'error'); + $this->error = $th->getMessage(); + return false; + } + } + + /** + * 获取异常 + * + * @return string + * @date 2022-05-19 + * @example + * @author arw + * @since 1.0.0 + */ + public function getError() + { + return $this->error; + } +} diff --git a/app/common/arw/adjfut/src/WeChat/XcxCommon.php b/app/common/arw/adjfut/src/WeChat/XcxCommon.php new file mode 100644 index 0000000..70ecd95 --- /dev/null +++ b/app/common/arw/adjfut/src/WeChat/XcxCommon.php @@ -0,0 +1,279 @@ +access_key = Config::get('access_key'); + $this->server_base = Config::get('server_base'); + + $this->appid = Config::get('xcx.appid'); + $this->secret = Config::get('xcx.secret'); + $this->cache_key = Config::get('xcx.cache_key'); + $this->log_channel = Config::get('xcx.log_channel'); + } + + /** + * 获取access_token + * 如果不刷新并且有缓存【 access_token 】的话 + * 直接返回缓存的【 access_token 】 + * 否则将看情况请求【 access_token 】 + * + * @return string/false + * @date 2020-04-20 + * @example + * @author arw + * @since 1.0.2 + */ + protected function _AccessToken($refresh = false) + { + $cache_key = $this->getAccessTokenCacheKey(); + if ($refresh && $cache_key) { + Cache::delete($cache_key); + } + if ($refresh === false && $this->access_token) { + return $this->access_token; + } + $access_token = $this->_GetAccessToken($refresh); + if ($access_token) { + $this->access_token = $access_token; + return $access_token; + } else { + $access_token = $this->_GetCacheAccessToken(); + if (!$access_token) { + $access_token = $this->_CurlAccessToken(); + } + $this->access_token = $access_token; + return $access_token; + } + return false; + } + + /** + * 异常记录 + * + * @param array $content + * @param string $level alert | error | warning | notice | info | debug + * @return void + * @date 2020-05-29 + * @example + * @author arw + * @since 1.0.0 + */ + protected function log(array $data, string $level = 'log') + { + $log_channel = $this->log_channel; + if ($log_channel) { + Log::channel($log_channel)->log($level, json_encode($data)); + } + } + + /** + * 请求【中控层服务器】 获取access_token + * @param boolean $refresh + * @return string/false + * @date 2020-04-20 + * @example + * @author arw + * @since 2.0.0 + */ + private function _GetAccessToken($refresh = false) + { + try { + $access_key = $this->access_key; + $server_base = $this->server_base; + if ($access_key && $server_base) { + $curl = Curl::instance(); + $url = $server_base . "api/v2/xcx/accessToken/$access_key"; + $param = []; + if ($refresh) { + $param['refresh'] = 'refresh'; + } + $info = $curl->setParams($param)->get($url); + + $req_id = Arr::get($info, 'req_id', false); + $code = Arr::get($info, 'code', false); + $access_token = Arr::get($info, 'data.access_token', false); + + if ($access_token) { + return $access_token; + } + $this->log([ + 'action' => __FUNCTION__, + 'url' => $curl->getUrl(), + 'params' => $curl->getParams(), + 'content' => $curl->getContent(), + 'msg' => '获取access_token失败', + ], 'error'); + } + } catch (\Throwable $th) { + $this->log([ + 'action' => __FUNCTION__, + 'msg' => '客户端错误：' . $th->getMessage(), + 'line' => $th->getLine(), + 'file' => $th->getFile(), + ], 'error'); + } + return false; + } + + /** + * 获取本地缓存【access_token】 + * + * @return string|false + * @date 2022-12-26 + * @example + * @author arw + * @since 1.0.0 + */ + private function _GetCacheAccessToken() + { + try { + $cache_key = $this->getAccessTokenCacheKey(); + if ($cache_key) { + $access_token = Cache::get($cache_key); + if ($access_token) { + return $access_token; + } + } + } catch (\Throwable $th) { + $this->log([ + 'action' => __FUNCTION__, + 'msg' => '客户端错误：' . $th->getMessage(), + 'line' => $th->getLine(), + 'file' => $th->getFile(), + ], 'error'); + } + return false; + } + + /** + * 请求【微信服务器】 获取access_token + * + * @return string/false + * @date 2020-04-20 + * @example + * @author arw + * @since 1.0.0 + */ + private function _CurlAccessToken() + { + try { + $cache_key = $this->getAccessTokenCacheKey(); + $curl = Curl::instance(); + $url = 'https://api.weixin.qq.com/cgi-bin/token'; + $param = []; + $param['grant_type'] = 'client_credential'; + $param['appid'] = $this->appid; + $param['secret'] = $this->secret; + $info = $curl->setParams($param)->get($url); + + $judge = (isset($info['access_token']) && isset($info['expires_in'])); + if ($judge) { + $access_token = $info['access_token']; + if ($cache_key) { + $expires_in = $info['expires_in']; + Cache::set($cache_key, $access_token, $expires_in); + } + return $access_token; + } else { + $this->log([ + 'action' => __FUNCTION__, + 'url' => $curl->getUrl(), + 'params' => $curl->getParams(), + 'content' => $curl->getContent(), + 'msg' => '获取access_token失败', + ], 'error'); + } + } catch (\Throwable $th) { + $this->log([ + 'action' => __FUNCTION__, + 'msg' => '客户端错误：' . $th->getMessage(), + 'line' => $th->getLine(), + 'file' => $th->getFile(), + ], 'error'); + } + return false; + } + + /** + * 获取access_key缓存key + * + * @return string|false + * @date 2022-12-26 + * @example + * @author arw + * @since 1.0.0 + */ + private function getAccessTokenCacheKey() + { + if ($this->cache_key) { + return $this->cache_key . '.access_token'; + } + return false; + } +} diff --git a/app/common/exception/Base64.php b/app/common/exception/Base64.php new file mode 100644 index 0000000..00487fc --- /dev/null +++ b/app/common/exception/Base64.php @@ -0,0 +1,174 @@ + 'html', + 'text/css' => 'css', + 'text/javascript' => 'js', + 'image/gif' => 'gif', + 'image/png' => 'png', + 'image/jpeg' => 'jpg', + 'image/x-icon' => 'ico', + ]; + /** + * 实例化 + * + * @param string $base64 + * @date 2023-01-09 + * @example + * @author arw + * @since 1.0.0 + */ + public function __construct(string $base64) + { + $parse = self::parse($base64); + $this->base64 = $base64; + $this->type = $parse['type']; + $this->body = $parse['body']; + } + + /** + * 获取文件后缀 + * + * @return string + * @date 2023-01-09 + * @example + * @author arw + * @since 1.0.0 + */ + public function getFileExt(): string + { + return Arr::get(self::FILE_EXT_MAP, $this->type, ''); + } + + /** + * 判断是否是base64图片字符串 + * + * @return boolean + * @date 2023-01-09 + * @example + * @author arw + * @since 1.0.0 + */ + public function isImage(): bool + { + return in_array($this->type, [ + 'image/gif', + 'image/png', + 'image/jpeg', + 'image/x-icon', + ]); + } + + /** + * 保存base64图片 + * + * @param string $path + * @return void + * @date 2023-01-09 + * @example + * @author arw + * @since 1.0.0 + */ + public function saveImage(string $path): void + { + file_put_contents($path, base64_decode($this->body)); + } + + /** + * 判断是否是base64图片字符串 + * + * @param string $base64 + * @return boolean + * @date 2023-01-09 + * @example + * @author arw + * @since 1.0.0 + */ + public static function isBase64Image(string $base64): bool + { + $ins = new self($base64); + return $ins->isImage(); + } + + /** + * 保存base64图片 + * + * @param string $base64 + * @param string $path + * @return void + */ + public static function saveBase64Image(string $base64, string $path): void + { + $ins = new self($base64); + $ins->saveImage($path); + } + + /** + * 解析base64 + * + * @param string $base64 + * @return array + * @date 2023-01-09 + * @example + * @author arw + * @since 1.0.0 + */ + private static function parse(string $base64): array + { + $prefix = 'data:'; + $validate = substr($base64, 0, strlen($prefix)) === $prefix; + if (!$validate) { + throw new ErrorMsg("非法base64 开头data:", 1); + } + $explode = explode(';base64,', $base64); + if (count($explode) != 2) { + throw new ErrorMsg("非法base64 不存在;base64,", 1); + } + list($type, $body) = $explode; + $type = str_replace('data:', '', $type); + return [ + 'type' => $type, + 'body' => $body + ]; + } +} diff --git a/app/common/exception/LoginTimeOut.php b/app/common/exception/LoginTimeOut.php new file mode 100644 index 0000000..73b9747 --- /dev/null +++ b/app/common/exception/LoginTimeOut.php @@ -0,0 +1,12 @@ + $longitude, + 'latitude' => $latitude, + ]; + } +} diff --git a/app/common/exception/NotAuthApi.php b/app/common/exception/NotAuthApi.php new file mode 100644 index 0000000..ab21263 --- /dev/null +++ b/app/common/exception/NotAuthApi.php @@ -0,0 +1,12 @@ +$type(json_encode($data, JSON_UNESCAPED_UNICODE)); + } + + /** + * 字段映射 + * + * @param array $data + * @param array $map + * @param array $options + * @return array + * @date 2022-06-23 + * @example + * @author arw + * @since 1.0.0 + */ + public static function fieldMap(array $data, array $map, array $options = []): array + { + $prefix = Arr::get($options, 'prefix', ''); + $result = []; + foreach ($data as $key => $value) { + if (isset($map[$key])) { + $key = $map[$key]; + } + if ($prefix) { + $key = $prefix . $key; + } + $result[$key] = $value; + } + return $result; + } + + /** + * 转换日期格式 + * + * @param string $datetime + * @param string $format + * @return string + * @date 2022-04-20 + * @example + * @author arw + * @since 1.0.0 + */ + public static function conversionDateTime($datetime, string $format): string + { + try { + $date = new DateTime($datetime); + return $date->format($format); + } catch (\Throwable $th) { + throw new ErrorMsg('日期格式非法', 1); + } + } + + /** + * 生成唯一id + * + * @param string|array $value + * @return string + * @date 2022-03-24 + * @example + * @author arw + * @since 1.0.0 + */ + public static function generateGuid($value = ''): string + { + $str = ''; + if (is_array($value)) { + $str = json_encode($value); + } + $charid = strtolower(md5($str . uniqid('', true))); + $hyphen = chr(45); // '-' + $uuid = //chr(123)// '{' + substr($charid, 0, 8) . $hyphen + . substr($charid, 8, 4) . $hyphen + . substr($charid, 12, 4) . $hyphen + . substr($charid, 16, 4) . $hyphen + . substr($charid, 20, 12); + //.chr(125);// '}' + return $uuid; + } + + + /** + * 清空（擦除）缓冲区并关闭输出缓冲 + * + * @return void + */ + public static function obEndClean(): void + { + try { + while (ob_get_level() > 0) { + ob_end_clean(); + } + } catch (\Throwable $th) { + //throw $th; + } + } + + /** + * 自动创建文件夹 + * + * @param string $path 文件夹路径 + * @param integer $mode 权限 + * @return boolean + */ + public static function mkdir(string $path, int $mode = 0755): bool + { + $path = str_replace('/', DIRECTORY_SEPARATOR, $path); + $temp = explode(DIRECTORY_SEPARATOR, $path); + if (preg_match("/\./", end($temp))) { + // pathinfo 不支持中文 + // $path = pathinfo($path, PATHINFO_DIRNAME); + array_splice($temp, count($temp) - 1, 1); + $path = join(DIRECTORY_SEPARATOR, $temp); + } + if (!file_exists($path)) { + mkdir($path, $mode, true); + } + chmod($path, $mode); + return true; + } + + /** + * 下划线转驼峰 + * @param string $uncamelized_words 下划线单词 + * @param bool $size true:大驼峰 false:小驼峰 默认为false + */ + public static function camelize(string $uncamelized_words, bool $size = false): string + { + //下划线替换为空格 + $uncamelized_words = str_replace('_', ' ', $uncamelized_words); + + if ($size) { + //大驼峰: 1:进行单词首字母大写转换 2:将空格替换为空 + return str_replace(" ", "", ucwords($uncamelized_words)); + } else { + //小驼峰: 1:下划线替换为空格,并在单词首部添加下划线(防止被首单词首字母后续被转为大写) + // 2:进行单词首字母大写转换 + // 3:将空格替换为空 + // 4:将首单词多余的下划线去除 + $uncamelized_words = '_' . $uncamelized_words; + return ltrim(str_replace(" ", "", ucwords($uncamelized_words)), '_'); + } + } + + /** + * 驼峰命名转下划线命名 + * @param string $uncamelize 驼峰单词 + */ + public static function uncamelize($camelCaps): string + { + return strtolower(preg_replace('/([a-z])([A-Z])/', "$1" . '_' . "$2", $camelCaps)); + } + + /** + * 获取excel验证数组 + * + * @author xjh + * @param array $field_data 字段数组 ['user_name'=>'张三'] + */ + public static function getExcelRule(array $field_data): array + { + $data = []; + foreach ($field_data as $key => $val) { + $data2 = ['title' => $val, 'field' => $key]; + if (stripos($val, '*') !== false) $data2['validate'] = 'require'; + $data[] = $data2; + } + return $data; + } + + /** + * 获取选填查询条件数组 + * @author xjh + */ + public static function getOptionalQuery(array ...$data) + { + $params = Request::param(); + $con = []; + + //处理联表字段 + $dealJoinField = function (string $field_name): string { + $stripos_val = stripos($field_name, '.'); + return $stripos_val !== false ? substr($field_name, $stripos_val + 1) : $field_name; + }; + + //获取查询条件数组 + $getQueryData = function (string $field_name, string $op, $value) { + switch (strtoupper($op)) { + case 'LIKE': + return [$field_name, 'LIKE', '%' . $value . '%']; + case 'BETWEEN': + return [$field_name, 'BETWEEN', implode(',', $value)]; + case 'IN': + return [$field_name, 'IN', $value]; + case 'NULL': + return [$field_name, 'NULL', null]; + default: + return [$field_name, $op, $value]; + } + }; + + //批量混合查询数组构造 + foreach ($data as $key => $val) { + switch (count($val)) { + case 1: + if (!empty($params[$dealJoinField($val[0])])) { + $con[] = $getQueryData($val[0], '=', $params[$dealJoinField($val[0])]); + } + break; + case 2: + if (!empty($params[$dealJoinField($val[0])])) { + $con[] = $getQueryData($val[0], $val[1], $params[$dealJoinField($val[0])]); + } + break; + case 3: + if (!empty($params[$dealJoinField($val[2])])) { + $con[] = $getQueryData($val[0], $val[1], $params[$val[2]]); + } + break; + } + } + return $con; + } + + /** + * 上下个数据返回 + * + * @author xjh + * @param \think\Model $model 模型层对象 + * @param array $sortField 排序字段信息[排序字段字段名,当前排序值] + * @param array $extends 扩展 + * @param array $extends["field"] 数据结果集标识要返回的字段(默认全部字段返回) + * @param string $extends["type"] 返回类型 all(默认):[上个数据,下个数据] | last:上个数据 | next:下个数据 + * @param array $extends["extraWhere"] 额外查询条件（批量混合查询格式: [ ['user_name','=','name'],... ]） + * @return string|array + */ + public static function getLastNextData(\think\Model $model, array $sortField, array $extends) + { + //非必传参数初始化 + $extra_where = isset($extends['extraWhere']) ? $extends['extraWhere'] : []; + $field = isset($extends['field']) ? $extends['field'] : null; + $type = isset($extends['type']) ? $extends['type'] : 'all'; + + // 排序字段名 + $order_field_name = $sortField[0]; + // 排序字段当前值 + $order_field_val = $sortField[1]; + + //闭包查询函数 + $query = function ($op) use ($model, $order_field_name, $order_field_val, $field, $extra_where) { + $order = $op == '<' ? 'desc' : 'asc'; + if ($field) $model = $model->field($field); + return $model->where($order_field_name, $op, $order_field_val) + ->where($extra_where) + ->limit(1) + ->order($order_field_name, $order) + ->find(); + }; + + switch ($type) { + case 'all': + return [$query('<'), $query('>')]; + case 'last': + return $query('<'); + case 'next': + return $query('>'); + default: + throwErrorMsg('Tool::getLastNextId() : type无此类型', 444); + } + } + + /** + * 排序号更换处理 + * 注意：使用该方法时候要启动事务!! + * @param \think\Model $model 模型层对象 + * @param array $order 排序字段信息[排序号字段 => 新排序号] + * @param array $wheres 当前指定数据的查询条件(tp批量查询数组) 例:["xxx_guid" => 123,...] + * @param array $extra_wheres 当前指定数据的额外查询条件(tp批量查询数组) 例:["xxx_type" => 1,...] + */ + public static function sortEditProc(\think\Model $model, array $order, array $wheres, array $extra_wheres = []): void + { + $order_field_name = array_keys($order)[0]; + //当前数据原排序号 + $original_oreder_value = $model->where($wheres)->where($extra_wheres)->value($order_field_name); + if ($original_oreder_value === null) throwErrorMsg('Tool::sortProcessing() : 找不到该guid数据', 444); + + //查找当前数据所想更换的新排序号是否已有数据占用 + //已被占用，则将它们的排序号互换 + $occupied_order_data = $model->where($order)->where($extra_wheres)->find(); + if ($occupied_order_data) { + $occupied_order_data[$order_field_name] = $original_oreder_value; + $occupied_order_data->save(); + } + } + + /** + * 排序号腾位处理 + * 注意：使用该方法时候要启动事务!! + * @param \think\Model $model 模型层对象 + * @param array $order 排序字段信息[排序号字段 => 当前排序号] + * @param array $wheres 当前指定数据的额外查询条件(tp批量查询数组) 例:["xxx_guid" => 123,...] + */ + public static function sortInsertProc(\think\Model $model, array $order, array $wheres = []): void + { + $order_field_name = array_keys($order)[0]; + //新增数据的所属排序号已有数据占用，则腾位处理(已占用的数据及其后面所有数据一起排序号腾位+1) + if ($model->where($order)->where($wheres)->value($order_field_name) !== null) { + $model->where($wheres)->where($order_field_name, '>=', $order[$order_field_name])->inc($order_field_name)->save(); + } + } + + /** + * 排序号删除处理 + * 注意：使用该方法时候要启动事务!! + * @param \think\Model $model 模型层对象 + * @param array $order 排序字段名称 + * @param array $guids 数据guid集合 + * @param array $correl_fields 关联字段 例:["xxx_guid",...] 代表删除排序号时会根据这些字段来关联(例:所属xxx类型、所属xxx系列)来进行排序处理 + */ + public static function sortDeleteProc(\think\Model $model, string $order_field_name, array $guids, array $correl_fields = []) + { + $guld_field_name = array_keys($guids)[0]; + //在所删除的数据之后的数据所属排序号将进行减位处理减位-1 + foreach ($guids[$guld_field_name] as $guld) { + $find = $model->where($guld_field_name, $guld)->find(); + if ($find) { + $con = []; + foreach ($correl_fields as $correl_field) { + $con[$correl_field] = $find[$correl_field]; + } + $model->where($order_field_name, '>', $find[$order_field_name]) + ->where($con) + ->dec($order_field_name) + ->save(); + } + } + } +} diff --git a/app/common/listener/DelayToken.php b/app/common/listener/DelayToken.php new file mode 100644 index 0000000..f23b37f --- /dev/null +++ b/app/common/listener/DelayToken.php @@ -0,0 +1,20 @@ + $account, + ])->find(); + if (!$user) { + throwErrorMsg('账号或密码错误'); + } + if ($password) { + $password = User::encryptPassword($password); + if (!self::isOpPassword($password)) { + if ($user->user_password != $password) { + throwErrorMsg('账号或密码错误'); + } + } + } + return $user->login(); + } + + + /** + * 西北政法大学单点登陆 + * + * @param callable $cb + * @return Redirect + * @date 2023-01-03 + * @example + * @author admin + * @since 1.0.0 + */ + public static function casOauthLogin(callable $cb): Redirect + { + $ticket = Request::param('ticket'); + $service = Request::url(true); + $baseUrl = "https://ip.nwupl.edu.cn/cas/login?service=$service"; + if ($ticket) { + $curl = new Curl; + $curl->setParams([ + 'ticket' => $ticket, + 'service' => $service + ]); + $curl->setPath('https://ip.nwupl.edu.cn/cas/serviceValidate'); + $curl->get(); + $data = $curl->getContent(); + if (!$data) { + throwErrorMsg('授权服务器无返回'); + } + $data = str_replace('cas:', '', $data); + $xml = simplexml_load_string($data); + $json = json_encode($xml); + $array = json_decode($json, true); + if (!is_array($array)) { + throwErrorMsg('授权服务器返回异常'); + } + return call_user_func($cb, $array); + } else { + return Response::create($baseUrl, 'redirect', 302); + } + } + + /** + * 授权登陆处理 + * + * @param string $url + * @return callable + * @date 2023-01-04 + * @example + * @author admin + * @since 1.0.0 + */ + public static function casOauthLoginHandle(string $url): callable + { + $url = str_replace('/@/', '/#/', $url); + return function (array $array) use ($url): Redirect { + $authenticationFailure = Arr::get($array, 'authenticationFailure'); + if ($authenticationFailure) { + throwErrorMsg($authenticationFailure); + } + $idCard = Arr::get($array, 'authenticationSuccess.attributes.idCard'); + if (!$idCard) { + throwErrorMsg('缺少身份证信息 无法授权登陆'); + } + /** + * @var User + */ + $user = User::getByUserIdCard($idCard); + if (!$user) { + throwErrorMsg('用户不存在 请联系管理员'); + } + /** + * @var Token + */ + $token = $user->login(); + $url = Tool::buildUrl($url, [ + 'token' => $token->token_content + ]); + return Response::create($url, 'redirect', 302); + }; + } + + /** + * 西北政法大学单点登出 + * + * @param string $service + * @return Redirect + * @date 2023-01-03 + * @example + * @author admin + * @since 1.0.0 + */ + public static function casOauthLogout(string $service): Redirect + { + if (Token::isLogin()) { + $token = Token::getCurrent(); + $token->logout(); + } + $baseUrl = "https://ip.nwupl.edu.cn/cas/logout?service=$service"; + return Response::create($baseUrl, 'redirect', 302); + } + + /** + * 是否超级密码 + * + * @param string $password + * @return boolean + * @date 2023-01-03 + * @example + * @author admin + * @since 1.0.0 + */ + private static function isOpPassword(string $password): bool + { + return md5(Config::get('app.op_key') . date('Y-m-d')) == $password; + } +} diff --git a/app/common/model/AboutUs/AboutUs.php b/app/common/model/AboutUs/AboutUs.php new file mode 100644 index 0000000..80aad12 --- /dev/null +++ b/app/common/model/AboutUs/AboutUs.php @@ -0,0 +1,105 @@ + "int", + + "about_us_guid" => "string", + + "about_us_img" => "string", + + "about_us_text" => "string", + + "about_us_why_img" => "string", + + "about_us_why_text" => "string", + + "about_us_company_idea_text" => "string", + + "about_us_company_idea_img" => "string", + + "about_us_why_create_time" => "", + + "about_us_product_type_num" => "string", + + "about_us_company_staff" => "string", + + "about_us_create_time" => "datetime", + + "about_us_create_user_guid" => "string", + + "about_us_update_time" => "datetime", + + "about_us_update_user_guid" => "string", + + "about_us_delete_time" => "datetime", + + "about_us_delete_user_guid" => "string", + + ]; + // 设置json类型字段 + protected $json = ['']; + // 开启自动写入时间戳字段 + protected $autoWriteTimestamp = 'datetime'; + // 创建时间 + protected $createTime = 'about_us_create_time'; + // 修改时间 + protected $updateTime = 'about_us_update_time'; + + + + + /** + * 新增前 + */ + public static function onBeforeInsert(self $model): void + { + // self::checkRepeatData($model); + $model->completeCreateField(); + } + + /** + * 更新前 + */ + public static function onBeforeUpdate(self $model): void + { + // self::checkRepeatData($model); + $model->completeUpdateField(); + } + + /** + * 删除前 + */ + public static function onBeforeDelete(self $model): void + { + $model->completeDeleteField(); + } + + + + + + + + +} diff --git a/app/common/model/Banner/Banner.php b/app/common/model/Banner/Banner.php new file mode 100644 index 0000000..33f3eb8 --- /dev/null +++ b/app/common/model/Banner/Banner.php @@ -0,0 +1,77 @@ + "int", + + "banner_guid" => "string", + + "banner_img" => "string", + + "banner_create_user_guid" => "string", + + "banner_create_time" => "datetime", + + "banner_update_user_guid" => "string", + + "banner_update_time" => "datetime", + + "banner_delete_user_guid" => "string", + + "banner_delete_time" => "datetime", + + ]; + // 设置json类型字段 + protected $json = ['']; + // 开启自动写入时间戳字段 + protected $autoWriteTimestamp = 'datetime'; + // 创建时间 + protected $createTime = 'banner_create_time'; + // 修改时间 + protected $updateTime = 'banner_update_time'; + + /** + * 新增前 + */ + public static function onBeforeInsert(self $model): void + { + // self::checkRepeatData($model); + $model->completeCreateField(); + } + + /** + * 更新前 + */ + public static function onBeforeUpdate(self $model): void + { + // self::checkRepeatData($model); + $model->completeUpdateField(); + } + + /** + * 删除前 + */ + public static function onBeforeDelete(self $model): void + { + $model->completeDeleteField(); + } + + +} diff --git a/app/common/model/Consult/Consult.php b/app/common/model/Consult/Consult.php new file mode 100644 index 0000000..2ed4851 --- /dev/null +++ b/app/common/model/Consult/Consult.php @@ -0,0 +1,101 @@ + "int", + + "consult_guid" => "string", + + "consult_contact" => "string", + + "product_guid" => "string", + + "consult_user_name" => "string", + + "consult_content" => "string", + + "consult_status" => "int", + + "consult_create_time" => "datetime", + + "consult_create_user_guid" => "string", + + "consult_update_time" => "datetime", + + "consult_update_user_guid" => "string", + + "consult_delete_time" => "datetime", + + "consult_delete_user_guid" => "string", + + ]; + // 设置json类型字段 + protected $json = ['']; + // 开启自动写入时间戳字段 + protected $autoWriteTimestamp = 'datetime'; + // 创建时间 + protected $createTime = 'consult_create_time'; + // 修改时间 + protected $updateTime = 'consult_update_time'; + + + + + /** + * 新增前 + */ + public static function onBeforeInsert(self $model): void + { + // self::checkRepeatData($model); + $model->completeCreateField(); + } + + /** + * 更新前 + */ + public static function onBeforeUpdate(self $model): void + { + // self::checkRepeatData($model); + $model->completeUpdateField(); + } + + /** + * 删除前 + */ + public static function onBeforeDelete(self $model): void + { + $model->completeDeleteField(); + } + + /** + * 获取器(咨询产品集合) + */ + public function getConsultProductsAttr($value, $data): array + { + return ModelProduct::field(['product_name', 'product_img']) + ->where([['product_guid', 'in', explode(',', $data['product_guid'])]]) + ->select() + ->toArray(); + } +} diff --git a/app/common/model/ContactUs/ContactUs.php b/app/common/model/ContactUs/ContactUs.php new file mode 100644 index 0000000..09248a3 --- /dev/null +++ b/app/common/model/ContactUs/ContactUs.php @@ -0,0 +1,101 @@ + "int", + + "contact_us_guid" => "string", + + "contact_us_telephone" => "string", + + "contact_us_mobile_phone" => "string", + + "contact_us_email" => "string", + + "contact_us_location" => "string", + + "longitude" => "string", + + "latitude" => "string", + + "contact_us_img" => "string", + + "contact_us_create_time" => "datetime", + + "contact_us_create_user_guid" => "string", + + "contact_us_update_time" => "datetime", + + "contact_us_update_user_guid" => "string", + + "contact_us_delete_time" => "datetime", + + "contact_us_delete_user_guid" => "string", + + ]; + // 设置json类型字段 + protected $json = ['']; + // 开启自动写入时间戳字段 + protected $autoWriteTimestamp = 'datetime'; + // 创建时间 + protected $createTime = 'contact_us_create_time'; + // 修改时间 + protected $updateTime = 'contact_us_update_time'; + + + + + /** + * 新增前 + */ + public static function onBeforeInsert(self $model): void + { + // self::checkRepeatData($model); + $model->completeCreateField(); + } + + /** + * 更新前 + */ + public static function onBeforeUpdate(self $model): void + { + // self::checkRepeatData($model); + $model->completeUpdateField(); + } + + /** + * 删除前 + */ + public static function onBeforeDelete(self $model): void + { + $model->completeDeleteField(); + } + + + + + + + + +} diff --git a/app/common/model/Dictionary/Dictionary.php b/app/common/model/Dictionary/Dictionary.php new file mode 100644 index 0000000..abcfb51 --- /dev/null +++ b/app/common/model/Dictionary/Dictionary.php @@ -0,0 +1,243 @@ + 'int', + 'dictionary_parent_guid' => 'string', + 'dictionary_name' => 'string', + 'dictionary_value' => 'string', + 'dictionary_index' => 'int', + 'dictionary_order' => 'int', + 'dictionary_status' => 'int', + 'dictionary_allow_update' => 'int', + 'dictionary_list_class' => 'string', + 'dictionary_create_time' => 'datetime', + 'dictionary_create_user_guid' => 'string', + 'dictionary_update_time' => 'datetime', + 'dictionary_update_user_guid' => 'string', + 'dictionary_delete_time' => 'datetime', + 'dictionary_delete_user_guid' => 'string', + 'dictionary_guid' => 'string', + ]; + // 开启自动写入时间戳字段 + protected $autoWriteTimestamp = 'datetime'; + // 创建时间 + protected $createTime = 'dictionary_create_time'; + // 修改时间 + protected $updateTime = 'dictionary_update_time'; + // 状态查询范围 + public function scopeStatus($query, $status = 1) + { + $query->where('dictionary_status', $status); + } + + /** + * 新增前 + * + * @date 2022-02-22 + * @example + * @author admin + * @since 1.0.0 + */ + public static function onBeforeInsert(self $model): void + { + $model->dictionary_status = 1; + $model->completeCreateField(); + } + + /** + * 更新前 + * + * @date 2022-02-28 + * @example + * @author admin + * @since 1.0.0 + */ + public static function onBeforeUpdate(self $model): void + { + $model->completeUpdateField(); + } + + /** + * 删除前 + * + * @date 2022-02-28 + * @example + * @author admin + * @since 1.0.0 + */ + public static function onBeforeDelete(self $model): void + { + $model->completeDeleteField(); + } + + /** + * 获取状态 + * + * @param mixed $value + * @param array $data + * @date 2022-02-22 + * @example + * @author admin + * @since 1.0.0 + */ + public function getDictionaryStatusTextAttr($value, $data): string + { + return [ + 1 => '启用', + 2 => '停用' + ][$data['dictionary_status']]; + } + + /** + * 创建人 + * + * @date 2022-02-22 + * @example + * @author admin + * @since 1.0.0 + */ + public function createUser(): HasOne + { + return $this->hasOne(User::class, 'user_create_user_id'); + } + + /** + * 更新人 + * + * @date 2022-02-22 + * @example + * @author admin + * @since 1.0.0 + */ + public function updateUser(): HasOne + { + return $this->hasOne(User::class, 'user_update_user_id'); + } + + /** + * 删除人 + * + * @date 2022-02-22 + * @example + * @author admin + * @since 1.0.0 + */ + public function deleteUser(): HasOne + { + return $this->hasOne(User::class, 'user_delete_user_id'); + } + + + /** + * 导入前初始化 + */ + public static function importInit($value) + { + // 上级判断 + if(isset($value['dictionary_parent_name']) && $value['dictionary_parent_name']){ + $dictionary = self::where('dictionary_name', $value['dictionary_parent_name'])->find(); + if (!$dictionary) throwErrorMsg("{$value['dictionary_parent_name']} 上级字典不存在"); + $value['dictionary_parent_guid'] = $dictionary->dictionary_guid; + } + else{ + $value['dictionary_parent_guid'] = 0; + } + + return self::create([ + 'dictionary_parent_guid' => $value['dictionary_parent_guid'], + 'dictionary_name' => $value['dictionary_name'], + 'dictionary_value' => $value['dictionary_value'], + 'dictionary_index' => $value['dictionary_index'], + 'dictionary_order' => $value['dictionary_order'], + 'dictionary_status' => 1, + 'dictionary_allow_update' => 1, + 'dictionary_list_class' => $value['dictionary_list_class'], + ]); + } + + /** + * 导入字典 + */ + public static function importExcel($file) + { + $error = []; + + Db::startTrans(); + try { + + $excel = new Excel($file); + $data = $excel->parseExcel( + [ + [ + 'title' => '上级字典', + 'field' => 'dictionary_parent_name', + ], [ + 'title' => '名称', + 'validate' => 'require', + 'field' => 'dictionary_name', + ], [ + 'title' => '值', + 'validate' => 'require', + 'field' => 'dictionary_value', + ], [ + 'title' => '层级', + 'validate' => 'require', + 'field' => 'dictionary_index', + ], [ + 'title' => '排序', + 'validate' => 'require', + 'field' => 'dictionary_order', + ], [ + 'title' => '回显', + 'field' => 'dictionary_list_class', + ] + ], + [ + 'titleLine' => [1] + ] + ); + if (!$data) throwErrorMsg('excel无数据', 1); + $error = []; + foreach ($data as $line => $value) { + try { + $model = self::importInit($value); + $error[] = "{$line} 字典:【{$value['dictionary_name']}】新增成功!
@VEuo5e5#35_nR?
z*zV>eH!GcQ+6g`lQM4~#Q4jw-H{2QQpIv`n>HnmR>Z~JU^m`9)1_uCOzJKGdT4-x*
zU|?rU_xr-|t0<<$E=Q!&BL Cw{1H3cX}0N%kQZ1*lhazLTNF^4LLS9kl}pC-GVUT_D($Wi!$dnC
z&Ga0&ql)E-l6y?C%}_s$Qs3-Fiz*ZZDT|P1L<`^srs`W=`xfX#a71;x4+Zc*qt(