admin/addon/shopcomponent/model/Category.php

279 lines
11 KiB
PHP

<?php
/**
* ThinkShop商城系统 - 团队十年电商经验汇集巨献!
* =========================================================
* Copy right 2019-2029 成都云之牛科技有限公司, 保留所有权利。
* ----------------------------------------------
* 官方网址: https://www.cdcloudshop.com
* =========================================================
*/
namespace addon\shopcomponent\model;
use app\model\BaseModel;
use think\facade\Cache;
class Category extends BaseModel
{
private $statusName = [
'0' => '待提交',
'1' => '审核成功',
'9' => '审核拒绝'
];
private $type = [
'0' => '不需要',
'1' => '需要',
'2' => '可选'
];
/**
* 获取类目列表
* @param array $condition
* @param bool $field
* @param string $order
* @param int $page
* @param int $list_rows
* @param string $alias
* @param array $join
* @return array
*/
public function getCategoryPageList($condition = [], $field = true, $order = '', $page = 1, $list_rows = PAGE_LIST_ROWS, $alias = 'a', $join = [])
{
$check_condition = array_column($condition, 2, 0);
$site_id = isset($check_condition[ 'site_id' ]) ? $check_condition[ 'site_id' ] : 0;
$site_id_index = array_search('site_id', array_keys(array_column($condition, 2, 0)));
unset($condition[$site_id_index]);
$data = model('shopcompoent_category')->pageList($condition, $field, $order, $page, $list_rows, $alias, $join);
if (!empty($data['list'])) {
foreach ($data['list'] as $k => $item) {
$audit_info = model('shopcompoent_category_audit')->getInfo([ ['site_id', '=', $site_id], ['third_cat_id', '=', $item['third_cat_id'] ] ]);
if (empty($audit_info)) {
$audit_info = [
'certificate' => '',
'qualification_pics' => '',
'audit_id' => '',
'audit_time' => 0,
'status' => 0,
'reject_reason' => ''
];
}
$item = array_merge($item, $audit_info);
$data['list'][$k] = $item;
if($item['audit_time']>0 && $item['status']==0){
$data['list'][$k]['status_name'] = '审核中';
}else if($item['qualification_type']==0 && $item['product_qualification_type']==0){
$data['list'][$k]['status_name'] = '--';
}else{
$data['list'][$k]['status_name'] = $this->statusName[$item['status']] ?? '';
}
$data['list'][$k]['create_time'] = $item['create_time']>0 ? time_to_date($item['create_time']) : '--';
$data['list'][$k]['audit_time'] = $item['audit_time']>0 ? time_to_date($item['audit_time']) : '--';
$data['list'][$k]['leimu'] = $item['first_cat_name'].'>'.$item['second_cat_name'].'>'.$item['third_cat_name'];
$data['list'][$k]['product_qualification_type_name'] = $this->type[$item['product_qualification_type']] ?? '';
$data['list'][$k]['qualification_type_name'] = $this->type[$item['qualification_type']] ?? '';
$data['list'][$k]['license'] = Cache::get('license_'.$item['third_cat_id']);
$data['list'][$k]['reject_reason'] = str_replace('https://developers.weixin.qq.com/miniprogram/dev/framework/ministore/minishopopencomponent2/API/audit/audit_brand.html','',$item['reject_reason']);
}
}
return $this->success($data);
}
/**
* 同步商品类目
*/
public function syncCategory($site_id)
{
$res = (new Weapp($site_id))->getCatList();
if ($res['code'] < 0) return $res;
if (!empty($res['data'])) {
model('shopcompoent_category')->delete([['create_time', '<', time()]]);
$data = [];
foreach ($res['data'] as $item) {
array_push($data, [
'first_cat_id' => $item['first_cat_id'],
'second_cat_id' => $item['second_cat_id'],
'third_cat_id' => $item['third_cat_id'],
'first_cat_name' => $item['first_cat_name'],
'second_cat_name' => $item['second_cat_name'],
'third_cat_name' => $item['third_cat_name'],
'qualification' => $item['qualification'],
'qualification_type'=> $item['qualification_type'],
'product_qualification_type' => $item['product_qualification_type'],
'product_qualification' => $item['product_qualification'],
'create_time' => time(),
]);
}
model('shopcompoent_category')->addList($data);
Cache::tag('wxCategory')->clear();
return $this->success(1);
}
}
/**
* 上传类目资质
*/
public function uploadQualifications($param, $site_id)
{
$category = model('shopcompoent_category')->getInfo([ ['third_cat_id', '=', $param['third_cat_id'] ]]);
$img1 = "";
if(!empty($param['leimu_qualification'])){
$img_info1 = (new Weapp($site_id))->getImg(img($param['leimu_qualification']));
if($img_info1['code'] == 0){
$img1 = $img_info1['data']['img_info']['temp_img_url'];
}
}
$img2 = "";
if(!empty($param['product_qualification'])){
$img_info2 = (new Weapp($site_id))->getImg(img($param['product_qualification']));
if($img_info2['code'] == 0){
$img2 = $img_info2['data']['img_info']['temp_img_url'];
}
}
if ($category['qualification_type'] != 0) {
$zhengshu = "";
if (isset($param['zhengshu'])){
$zhengshu_info = (new Weapp($site_id))->getImg(img($param['zhengshu']));
if($zhengshu_info['code'] == 0){
$zhengshu = $zhengshu_info['data']['img_info']['temp_img_url'];
}
}
$data = [
'license' => $zhengshu ??'',
'category_info'=>[
'level1' => $param['first_cat_id'],
'level2' => $param['second_cat_id'],
'level3' => $param['third_cat_id'],
'certificate' => []
]
];
if (isset($param['leimu_qualification'])){
array_push($data['category_info']['certificate'], $img1);
}
if (isset($param['product_qualification'])){
array_push($data['category_info']['certificate'], $img2);
}
$res = (new Weapp($site_id))->auditCategory($data);
if ($res['code'] < 0 && $res['data'] != '1050003') return $res;
} else {
$res = $this->success();
}
$audit_data = [
'site_id' => $site_id,
'third_cat_id' => $param['third_cat_id'],
'audit_id' => $res['data'],
'audit_time' => time(),
'certificate' => $img1,
'qualification_pics' => $img2,
'status' => 0
];
if ($category['qualification_type'] == 0 || $res['data'] == '1050003') {
$audit_data['status'] = 1;
$audit_data['audit_time'] = time();
}
Cache::set('license_' . $param['third_cat_id'], img($param['zhengshu']));
$is_exit = model('shopcompoent_category_audit')->getCount([ ['site_id', '=', $site_id ], ['third_cat_id', '=', $param['third_cat_id'] ] ]);
if ($is_exit) {
model('shopcompoent_category_audit')->update($audit_data, [ ['site_id', '=', $site_id ], ['third_cat_id', '=', $param['third_cat_id'] ] ]);
} else {
model('shopcompoent_category_audit')->add($audit_data);
}
return $this->success();
}
/**
* 获取类目通过上级类目ID
* @param $level
* @param int $pid
* @return array
*/
public function getCategoryByParent($level, $pid = 0){
$cache = Cache::get("wxCategory_{$level}_{$pid}");
if ($cache) return $cache;
switch ($level) {
case 1:
$list = model('shopcompoent_category')->getList([], '*', '', '', null, 'first_cat_id');
break;
case 2:
$list = model('shopcompoent_category')->getList([ ['first_cat_id', '=', $pid ] ], '*', '', '', null, 'second_cat_id');
break;
case 3:
$list = model('shopcompoent_category')->getList([ ['second_cat_id', '=', $pid ] ], '*', '', '', null, 'third_cat_name');
break;
}
$data = $this->success($list);
Cache::tag('wxCategory')->set("wxCategory_{$level}_{$pid}", $data);
return $data;
}
/**
* 查询分类是否需要上传资质
* @param $param
* @return array
*/
public function isQualifications($param){
$info = model('shopcompoent_category')->getInfo([ ['third_cat_id', '=', $param['third_cat_id']] ], 'qualification_type,product_qualification_type');
if ($info['qualification_type'] != 0 || $info['product_qualification_type'] != 0) {
$audit_info = model('shopcompoent_category_audit')->getInfo([ ['status', '=', 1], ['site_id', '=', $param['site_id'] ], ['third_cat_id', '=', $param['third_cat_id'] ] ]);
if (empty($audit_info)) return $this->error();
}
return $this->success();
}
/**
* 获取分类信息
* @param $third_cat_id
* @param $site_id
*/
public function getCategoryInfo($third_cat_id, $site_id){
$info = model('shopcompoent_category')->getInfo([ ['third_cat_id', '=', $third_cat_id] ]);
if (empty($info)) return $info;
$audit_info = model('shopcompoent_category_audit')->getInfo([ ['site_id', '=', $site_id], ['third_cat_id', '=', $third_cat_id ] ]);
if (empty($audit_info)) {
$audit_info = [
'certificate' => '',
'qualification_pics' => '',
'audit_id' => '',
'audit_time' => 0,
'status' => 0,
'reject_reason' => ''
];
if (($info['qualification_type'] == 0 && $info['product_qualification_type'] == 0) || ($info['qualification_type'] == 2 && $info['product_qualification_type'] == 2)) $audit_info['status'] = 1;
}
return array_merge($info, $audit_info);
}
/**
* 同步类目审核状态
* @param $site_id
*/
public function syncCategoryAuditStatus($site_id){
$audit_list = model('shopcompoent_category_audit')->getList([ ['site_id', '=', $site_id], ['audit_id', '<>', ''], ['status', '=', 0] ]);
if (!empty($audit_list)) {
$weapp = new Weapp($site_id);
foreach ($audit_list as $item) {
$audit_result = $weapp->getAuditResult($item['audit_id']);
if ($audit_result['code'] == 0) {
model('shopcompoent_category_audit')->update([ 'status' => $audit_result['data']['status'], 'audit_time' => time(), 'reject_reason' => $audit_result['data']['reject_reason'] ], [ ['id', '=', $item['id'] ] ]);
}
}
}
}
}