1298 lines
49 KiB
PHP
1298 lines
49 KiB
PHP
<?php
|
|
/**
|
|
* @copyright Copyright (c) 2021 勾股工作室
|
|
* @license https://opensource.org/licenses/Apache-2.0
|
|
* @link https://blog.gougucms.com
|
|
*/
|
|
|
|
declare (strict_types = 1);
|
|
|
|
namespace app\admin\controller;
|
|
|
|
use app\admin\BaseController;
|
|
use app\admin\model\AdminLog;
|
|
use app\admin\validate\AdminCheck;
|
|
use OSS\Core\OssException;
|
|
use OSS\OssClient;
|
|
use think\exception\ValidateException;
|
|
use think\facade\Cache;
|
|
use think\facade\Db;
|
|
use think\facade\Session;
|
|
use app\admin\model\InformationUserMsg;
|
|
use app\admin\model\InformationUserAddress;
|
|
use app\admin\model\ShopUser;
|
|
use app\admin\model\SupplyBrokerage as SupplyBrokerageModel;
|
|
use app\admin\model\StoreOrder;
|
|
use app\admin\model\StoreCategory as StoreCategoryModel;
|
|
use app\common\controller\FormatList;
|
|
|
|
use app\common\model\merchant\user\UserMerchant;
|
|
class Api extends BaseController
|
|
{
|
|
protected $category;
|
|
public function __construct(StoreCategoryModel $category)
|
|
{
|
|
$this->category = $category;
|
|
}
|
|
/**
|
|
* 平台商品分类
|
|
*
|
|
*/
|
|
public function getAllList()
|
|
{
|
|
$where['mer_id'] = 0;
|
|
$where['is_show'] = 0;
|
|
$data = $this->category->getStoreCategoryList(0,1);
|
|
$list = FormatList::FormatCategory($data,'store_category_id', 'pid', 'cate_name','child', 'id', 'title');
|
|
|
|
return to_assign(0, '', $list);
|
|
}
|
|
|
|
//上传文件
|
|
public function upload()
|
|
{
|
|
$param = get_params();
|
|
//var_dump($param);exit;
|
|
$sourse = 'file';
|
|
if(isset($param['sourse'])){
|
|
$sourse = $param['sourse'];
|
|
}
|
|
if($sourse == 'file' || $sourse == 'tinymce'){
|
|
if(request()->file('file')){
|
|
$file = request()->file('file');
|
|
}
|
|
else{
|
|
return to_assign(1, '没有选择上传文件');
|
|
}
|
|
}
|
|
else{
|
|
if (request()->file('editormd-image-file')) {
|
|
$file = request()->file('editormd-image-file');
|
|
} else {
|
|
return to_assign(1, '没有选择上传文件');
|
|
}
|
|
}
|
|
// 获取上传文件的hash散列值
|
|
$sha1 = $file->hash('sha1');
|
|
$md5 = $file->hash('md5');
|
|
$rule = [
|
|
'image' => 'jpg,png,jpeg,gif',
|
|
'doc' => 'doc,docx,ppt,pptx,xls,xlsx,pdf',
|
|
'file' => 'zip,gz,7z,rar,tar',
|
|
'video' => 'mpg,mp4,mpeg,avi,wmv,mov,flv,m4v',
|
|
];
|
|
$fileExt = $rule['image'] . ',' . $rule['doc'] . ',' . $rule['file'] . ',' . $rule['video'];
|
|
//1M=1024*1024=1048576字节
|
|
$fileSize = 100 * 1024 * 1024;
|
|
if (isset($param['type']) && $param['type']) {
|
|
$fileExt = $rule[$param['type']];
|
|
}
|
|
if (isset($param['size']) && $param['size']) {
|
|
$fileSize = $param['size'];
|
|
}
|
|
$validate = \think\facade\Validate::rule([
|
|
'image' => 'require|fileSize:' . $fileSize . '|fileExt:' . $fileExt,
|
|
]);
|
|
$file_check['image'] = $file;
|
|
if (!$validate->check($file_check)) {
|
|
return to_assign(1, $validate->getError());
|
|
}
|
|
// 日期前綴
|
|
$dataPath = date('Ym');
|
|
$use = 'thumb';
|
|
$accessKeyId = "LTAI5t7mhH3ij2cNWs1zhPmv"; ;
|
|
$accessKeySecret = "gqo2wMpvi8h5bDBmCpMje6BaiXvcPu";
|
|
$endpoint = "oss-cn-chengdu.aliyuncs.com";
|
|
try {
|
|
$ossClient = new OssClient($accessKeyId, $accessKeySecret, $endpoint);
|
|
} catch (OssException $e) {
|
|
return to_assign(1, $e->getMessage());
|
|
}
|
|
$bucket = "lihai001";
|
|
$object = 'storage/'.$dataPath.'/'.$md5.'.jpg';
|
|
// $filename = \think\facade\Filesystem::disk('public')->putFile($dataPath, $file, function () use ($md5) {
|
|
// return $md5;
|
|
// });
|
|
try {
|
|
$filename=$ossClient->uploadFile($bucket, $object,$file);
|
|
} catch (OssException $e) {
|
|
return to_assign(1, $e->getMessage());
|
|
}
|
|
if ($filename) {
|
|
//写入到附件表
|
|
$data = [];
|
|
$path = get_config('filesystem.disks.public.url');
|
|
$data['filepath'] = $filename['info']['url'];
|
|
$data['name'] = $file->getOriginalName();
|
|
$data['mimetype'] = $file->getOriginalMime();
|
|
$data['fileext'] = $file->extension();
|
|
$data['filesize'] = $file->getSize();
|
|
$data['filename'] = $object;
|
|
$data['sha1'] = $sha1;
|
|
$data['md5'] = $md5;
|
|
$data['module'] = \think\facade\App::initialize()->http->getName();
|
|
$data['action'] = app('request')->action();
|
|
$data['uploadip'] = app('request')->ip();
|
|
$data['create_time'] = time();
|
|
$data['user_id'] = get_login_admin('id') ? get_login_admin('id') : 0;
|
|
if ($data['module'] = 'admin') {
|
|
//通过后台上传的文件直接审核通过
|
|
$data['status'] = 1;
|
|
$data['admin_id'] = $data['user_id'];
|
|
$data['audit_time'] = time();
|
|
}
|
|
$data['use'] = request()->has('use') ? request()->param('use') : $use; //附件用处
|
|
$res['id'] = Db::name('file')->insertGetId($data);
|
|
$res['filepath'] = $data['filepath'];
|
|
$res['name'] = $data['name'];
|
|
$res['filename'] = $data['filename'];
|
|
add_log('upload', $data['user_id'], $data);
|
|
if($sourse == 'editormd'){
|
|
//editormd编辑器上传返回
|
|
return json(['success'=>1,'message'=>'上传成功','url'=>$data['filepath']]);
|
|
}
|
|
else if($sourse == 'tinymce'){
|
|
//tinymce编辑器上传返回
|
|
return json(['success'=>1,'message'=>'上传成功','location'=>$data['filepath']]);
|
|
}
|
|
else{
|
|
//普通上传返回
|
|
return to_assign(0, '上传成功', $res);
|
|
}
|
|
} else {
|
|
return to_assign(1, '上传失败，请重试');
|
|
}
|
|
}
|
|
|
|
//上传文件
|
|
public function upload2()
|
|
{
|
|
$param = get_params();
|
|
//var_dump($param);exit;
|
|
$sourse = 'file';
|
|
if(isset($param['sourse'])){
|
|
$sourse = $param['sourse'];
|
|
}
|
|
if($sourse == 'file' || $sourse == 'tinymce'){
|
|
if(request()->file('file')){
|
|
$file = request()->file('file');
|
|
}
|
|
else{
|
|
return to_assign(1, '没有选择上传文件');
|
|
}
|
|
}
|
|
else{
|
|
if (request()->file('editormd-image-file')) {
|
|
$file = request()->file('editormd-image-file');
|
|
} else {
|
|
return to_assign(1, '没有选择上传文件');
|
|
}
|
|
}
|
|
// 获取上传文件的hash散列值
|
|
$sha1 = $file->hash('sha1');
|
|
$md5 = $file->hash('md5');
|
|
$rule = [
|
|
'image' => 'jpg,png,jpeg,gif',
|
|
'doc' => 'doc,docx,ppt,pptx,xls,xlsx,pdf',
|
|
'file' => 'zip,gz,7z,rar,tar',
|
|
'video' => 'mpg,mp4,mpeg,avi,wmv,mov,flv,m4v',
|
|
];
|
|
$fileExt = $rule['image'] . ',' . $rule['doc'] . ',' . $rule['file'] . ',' . $rule['video'];
|
|
//1M=1024*1024=1048576字节
|
|
$fileSize = 100 * 1024 * 1024;
|
|
if (isset($param['type']) && $param['type']) {
|
|
$fileExt = $rule[$param['type']];
|
|
}
|
|
if (isset($param['size']) && $param['size']) {
|
|
$fileSize = $param['size'];
|
|
}
|
|
$validate = \think\facade\Validate::rule([
|
|
'image' => 'require|fileSize:' . $fileSize . '|fileExt:' . $fileExt,
|
|
]);
|
|
$file_check['image'] = $file;
|
|
if (!$validate->check($file_check)) {
|
|
return to_assign(1, $validate->getError());
|
|
}
|
|
// 日期前綴
|
|
$dataPath = date('Ym');
|
|
$use = 'thumb';
|
|
$accessKeyId = "LTAI5t7mhH3ij2cNWs1zhPmv"; ;
|
|
$accessKeySecret = "gqo2wMpvi8h5bDBmCpMje6BaiXvcPu";
|
|
$endpoint = "oss-cn-chengdu.aliyuncs.com";
|
|
try {
|
|
$ossClient = new OssClient($accessKeyId, $accessKeySecret, $endpoint);
|
|
} catch (OssException $e) {
|
|
return to_assign(1, $e->getMessage());
|
|
}
|
|
$bucket = "lihai001";
|
|
$object = 'storage/'.$dataPath.'/'.$md5.'.jpg';
|
|
// $filename = \think\facade\Filesystem::disk('public')->putFile($dataPath, $file, function () use ($md5) {
|
|
// return $md5;
|
|
// });
|
|
try {
|
|
$filename=$ossClient->uploadFile($bucket, $object,$file);
|
|
} catch (OssException $e) {
|
|
return to_assign(1, $e->getMessage());
|
|
}
|
|
if ($filename) {
|
|
//写入到附件表
|
|
$data = [];
|
|
$path = get_config('filesystem.disks.public.url');
|
|
$data['filepath'] = $filename['info']['url'];
|
|
$data['name'] = $file->getOriginalName();
|
|
$data['mimetype'] = $file->getOriginalMime();
|
|
$data['fileext'] = $file->extension();
|
|
$data['filesize'] = $file->getSize();
|
|
$data['filename'] = $object;
|
|
$data['sha1'] = $sha1;
|
|
$data['md5'] = $md5;
|
|
$data['module'] = \think\facade\App::initialize()->http->getName();
|
|
$data['action'] = app('request')->action();
|
|
$data['uploadip'] = app('request')->ip();
|
|
$data['create_time'] = time();
|
|
$data['user_id'] = get_login_admin('id') ? get_login_admin('id') : 0;
|
|
if ($data['module'] = 'admin') {
|
|
//通过后台上传的文件直接审核通过
|
|
$data['status'] = 1;
|
|
$data['admin_id'] = $data['user_id'];
|
|
$data['audit_time'] = time();
|
|
}
|
|
$data['use'] = request()->has('use') ? request()->param('use') : $use; //附件用处
|
|
$res['id'] = Db::name('file')->insertGetId($data);
|
|
$res['url'] = $data['filepath'];
|
|
$res['name'] = $data['name'];
|
|
$res['filename'] = $data['filename'];
|
|
add_log('upload', $data['user_id'], $data);
|
|
if($sourse == 'editormd'){
|
|
//editormd编辑器上传返回
|
|
return json(['success'=>1,'message'=>'上传成功','url'=>$data['filepath']]);
|
|
}
|
|
else if($sourse == 'tinymce'){
|
|
//tinymce编辑器上传返回
|
|
return json(['success'=>1,'message'=>'上传成功','location'=>$data['filepath']]);
|
|
}
|
|
else{
|
|
//普通上传返回
|
|
return to_assign(200, '上传成功', $res);
|
|
}
|
|
} else {
|
|
return to_assign(1, '上传失败，请重试');
|
|
}
|
|
}
|
|
|
|
//获取权限树所需的节点列表
|
|
public function get_rule()
|
|
{
|
|
$rule = get_admin_rule();
|
|
$group = [];
|
|
if (!empty(get_params('id'))) {
|
|
$group = get_admin_group_info(get_params('id'))['rules'];
|
|
}
|
|
$list = create_tree_list(0, $rule, $group);
|
|
return to_assign(0, '', $list);
|
|
}
|
|
|
|
//获取关键字
|
|
public function get_keyword_cate()
|
|
{
|
|
$keyword = get_keywords();
|
|
return to_assign(0, '', $keyword);
|
|
}
|
|
|
|
//获取话题
|
|
public function get_topics_cate()
|
|
{
|
|
$topic = get_topics();
|
|
return to_assign(0, '', $topic);
|
|
}
|
|
|
|
//清空缓存
|
|
public function cache_clear()
|
|
{
|
|
\think\facade\Cache::clear();
|
|
return to_assign(0, '系统缓存已清空');
|
|
}
|
|
|
|
//发送测试邮件
|
|
public function email_to($email)
|
|
{
|
|
$name = empty(get_config('webconfig.admin_title')) ? '系统' : get_config('webconfig.admin_title');
|
|
if (send_email($email, "一封来自{$name}的测试邮件。")) {
|
|
return to_assign(0, '发送成功，请注意查收');
|
|
}
|
|
return to_assign(1, '发送失败');
|
|
}
|
|
|
|
//修改个人信息
|
|
public function edit_personal()
|
|
{
|
|
return view('admin/edit_personal', [
|
|
'admin' => get_login_admin(),
|
|
]);
|
|
}
|
|
|
|
//保存个人信息修改
|
|
public function personal_submit()
|
|
{
|
|
if (request()->isAjax()) {
|
|
$param = get_params();
|
|
try {
|
|
validate(AdminCheck::class)->scene('editPersonal')->check($param);
|
|
} catch (ValidateException $e) {
|
|
// 验证失败 输出错误信息
|
|
return to_assign(1, $e->getError());
|
|
}
|
|
unset($param['username']);
|
|
$uid = get_login_admin('id');
|
|
Db::name('Admin')->where([
|
|
'id' => $uid,
|
|
])->strict(false)->field(true)->update($param);
|
|
$session_admin = get_config('app.session_admin');
|
|
Session::set($session_admin, Db::name('admin')->find($uid));
|
|
return to_assign();
|
|
}
|
|
}
|
|
|
|
//修改密码
|
|
public function edit_password()
|
|
{
|
|
return view('admin/edit_password', [
|
|
'admin' => get_login_admin(),
|
|
]);
|
|
}
|
|
|
|
//保存密码修改
|
|
public function password_submit()
|
|
{
|
|
if (request()->isAjax()) {
|
|
$param = get_params();
|
|
try {
|
|
validate(AdminCheck::class)->scene('editpwd')->check($param);
|
|
} catch (ValidateException $e) {
|
|
// 验证失败 输出错误信息
|
|
return to_assign(1, $e->getError());
|
|
}
|
|
$admin = get_login_admin();
|
|
if (set_password($param['old_pwd'], $admin['salt']) !== $admin['pwd']) {
|
|
return to_assign(1, '旧密码不正确!');
|
|
}
|
|
unset($param['username']);
|
|
$param['salt'] = set_salt(20);
|
|
$param['pwd'] = set_password($param['pwd'], $param['salt']);
|
|
Db::name('Admin')->where([
|
|
'id' => $admin['id'],
|
|
])->strict(false)->field(true)->update($param);
|
|
$session_admin = get_config('app.session_admin');
|
|
Session::set($session_admin, Db::name('admin')->find($admin['id']));
|
|
return to_assign();
|
|
}
|
|
}
|
|
|
|
// 测试邮件发送
|
|
public function email_test()
|
|
{
|
|
$sender = get_params('email');
|
|
//检查是否邮箱格式
|
|
$validate = \think\facade\Validate::rule([
|
|
'email' => 'email'
|
|
]);
|
|
|
|
$data = [
|
|
'email' => $sender
|
|
];
|
|
|
|
if (!$validate->check($data)) {
|
|
return to_assign(1, $validate->getError());
|
|
}
|
|
|
|
$email_config = \think\facade\Db::name('config')->where('name', 'email')->find();
|
|
$config = unserialize($email_config['content']);
|
|
$content = $config['template'];
|
|
//所有项目必须填写
|
|
if (empty($config['smtp']) || empty($config['smtp_port']) || empty($config['smtp_user']) || empty($config['smtp_pwd'])) {
|
|
return to_assign(1, '请完善邮件配置信息！');
|
|
}
|
|
|
|
$send = send_email($sender, '测试邮件', $content);
|
|
if ($send) {
|
|
return to_assign(0, '邮件发送成功！');
|
|
} else {
|
|
return to_assign(1, '邮件发送失败！');
|
|
}
|
|
}
|
|
|
|
//首页获取
|
|
public function get_admin_list()
|
|
{
|
|
$content = Db::name('Admin')
|
|
->where(['status' => 1])
|
|
->order('id desc')
|
|
->limit(10)
|
|
->select()->toArray();
|
|
$res['data'] = $content;
|
|
return table_assign(0, '', $res);
|
|
}
|
|
|
|
//首页获取最新10位用户
|
|
public function get_user_list()
|
|
{
|
|
$list = Db::name('User')
|
|
->where(['status' => 1])
|
|
->order('id desc')
|
|
->limit(10)
|
|
->select()->toArray();
|
|
foreach ($list as $key => $val) {
|
|
$list[$key]['last_login_time'] = date('Y-m-d H:i:s', $val['last_login_time']);
|
|
}
|
|
$res['data'] = $list;
|
|
return table_assign(0, '', $res);
|
|
}
|
|
|
|
//首页文章
|
|
public function get_article_list()
|
|
{
|
|
$list = Db::name('Article')
|
|
->field('a.id,a.title,a.read,a.status,a.create_time,c.title as cate_title')
|
|
->alias('a')
|
|
->join('article_cate c', 'a.cate_id = c.id')
|
|
->where(['a.delete_time' => 0])
|
|
->order('a.id desc')
|
|
->limit(10)
|
|
->select()->toArray();
|
|
foreach ($list as $key => $val) {
|
|
$list[$key]['create_time'] = date('Y-m-d H:i', $val['create_time']);
|
|
}
|
|
$res['data'] = $list;
|
|
return table_assign(0, '', $res);
|
|
}
|
|
|
|
//系统操作日志
|
|
public function log_list()
|
|
{
|
|
return view('admin/log_list');
|
|
}
|
|
|
|
//获取系统操作日志
|
|
public function get_log_list()
|
|
{
|
|
$param = get_params();
|
|
$log = new AdminLog();
|
|
$content = $log->get_log_list($param);
|
|
return table_assign(0, '', $content);
|
|
}
|
|
|
|
public function getbytype(){
|
|
$type = get_params("type");
|
|
$flag = get_params("flag");
|
|
$id = get_params("id");
|
|
if($flag == 'add'){
|
|
$www[] = ['pid','<>',0];
|
|
}
|
|
if($flag == 'edit'){
|
|
$www = [];
|
|
}
|
|
if($id){
|
|
$arr = Db::table('fa_category')->where('id',$id)->find();
|
|
if($arr && $arr['pid']== 0){
|
|
$www[] = ['pid','<>',0];
|
|
}
|
|
$www[] = ['id','<>',$id];
|
|
}
|
|
$where['type'] = $type;
|
|
$where['status'] = 'normal';
|
|
$list = Db::table('fa_category')->field('id,pid,type,name')->where($where)->where($www)->order('weigh asc,id asc')->select()->toArray();
|
|
|
|
// 添加无
|
|
$wu['id'] = 0;
|
|
$wu['pid'] = 0;
|
|
$wu['type'] = 0;
|
|
$wu['name'] = '无';
|
|
array_unshift ($list,$wu);
|
|
// halt($list);
|
|
return to_assign(0, '', $list);
|
|
}
|
|
|
|
public function reply(){
|
|
$data= get_params();
|
|
$this->adminInfo = get_admin($data['admin_id']);
|
|
if ($this->adminInfo['user_id']>0){
|
|
$useraddress = Db::table('fa_szxc_information_useraddress')->where('admin_id',$this->adminInfo['id'])->where('status', 1)->find();
|
|
$input=[];
|
|
if ($useraddress) {
|
|
$input['county'] = $useraddress['area_id'];
|
|
$input['township'] = $useraddress['street_id'];
|
|
$input['village'] = $useraddress['village_id'];
|
|
}
|
|
$input['user_id']=$this->adminInfo['user_id'];
|
|
$input['add_time']=date('Y-m-d H:i:s');
|
|
$input['content']=$data['reply'];
|
|
$input['vote_id']=$data['id'];
|
|
$res=Db::table('fa_article_comment')->strict(false)->field(true)->insert($input);
|
|
if ($res){
|
|
Db::table('fa_article')->where('id',$input['vote_id'])->update(['is_solve'=>1]);
|
|
return to_assign();
|
|
}else{
|
|
return to_assign(1, '操作失败');
|
|
}
|
|
}else{
|
|
return to_assign(1, '没有绑定前端用户,无法回复');
|
|
}
|
|
}
|
|
|
|
public function tongji(){
|
|
$mmm = $www = [];
|
|
$post = get_params();
|
|
|
|
//镇农产品需求量分析（事业单位、企业、居民）
|
|
$date = 'month';
|
|
$num_5 = Db::connect('shop')->table('eb_store_order')
|
|
->field('from_unixtime(unix_timestamp(create_time),\'%m-%d\') as time, count(DISTINCT order_id) as total')
|
|
->group('time')
|
|
->order('time ASC')
|
|
->whereBetween('create_time', [date('Y-m-d H:i:s', strtotime('first Day of this month 00:00:00')), date('Y-m-d H:i:s', strtotime('first Day of next month 00:00:00 -1second'))])
|
|
->select()->toarray();
|
|
$day_time = array_column($num_5,'time');
|
|
$total = array_column($num_5,'total');
|
|
|
|
//农产品市场行情分析、显示
|
|
$list['num_6'] = 6;
|
|
//农产品市内需求量
|
|
$list['num_7'] = 7;
|
|
|
|
$visitUser = $this->dateVisitUserNum($date, '');
|
|
$orderUser = $this->orderUserNum($date, null, '');
|
|
$orderPrice = $this->orderPrice($date, null, '');
|
|
$payOrderUser = $this->orderUserNum($date, 1, '');
|
|
$payOrderPrice = $this->orderPrice($date, 1, '');
|
|
// halt($payOrderUser);
|
|
// $userRate = $payOrderUser ? bcdiv($payOrderPrice, $payOrderUser, 2) : 0;
|
|
// $orderRate = $visitUser ? bcdiv($orderUser, $visitUser, 2) : 0;
|
|
// $payOrderRate = $orderUser ? bcdiv($payOrderUser, $orderUser, 2) : 0;
|
|
|
|
$result = compact('day_time','total','visitUser', 'orderUser', 'orderPrice', 'payOrderUser', 'payOrderPrice');
|
|
$result = ['data' => $result];
|
|
return table_assign(0, '', $result);
|
|
|
|
}
|
|
|
|
public function dateVisitUserNum($date, $merId = null)
|
|
{
|
|
return Db::connect('shop')->table('eb_user_visit')->alias('A')->join('eb_store_product B', 'A.type_id = B.product_id')->when($date, function ($query, $date) {
|
|
getModelTime($query, $date, 'A.create_time');
|
|
})->when($merId, function ($query, $merId) {
|
|
$query->where('B.mer_id', $merId);
|
|
})->where('A.type', 'product')->group('uid')->count();
|
|
}
|
|
|
|
public function orderUserNum($date, $paid = null, $merId = null)
|
|
{
|
|
return Db::connect('shop')->table('eb_store_order')->when($paid, function ($query, $paid) {
|
|
$query->where('paid', $paid);
|
|
})->when($merId, function ($query, $merId) {
|
|
$query->where('mer_id', $merId);
|
|
})->when($date, function ($query, $date) use ($paid) {
|
|
if (!$paid) {
|
|
getModelTime($query, $date);
|
|
// $query->where(function ($query) use ($date) {
|
|
// $query->where(function ($query) use ($date) {
|
|
// $query->where('paid', 1);
|
|
// getModelTime($query, $date, 'pay_time');
|
|
// })->whereOr(function ($query) use ($date) {
|
|
// $query->where('paid', 0);
|
|
// getModelTime($query, $date);
|
|
// });
|
|
// });
|
|
} else
|
|
getModelTime($query, $date, 'pay_time');
|
|
})->group('uid')->count();
|
|
}
|
|
|
|
public function orderPrice($date, $paid = null, $merId = null)
|
|
{
|
|
return Db::connect('shop')->table('eb_store_order')->when($paid, function ($query, $paid) {
|
|
$query->where('paid', $paid);
|
|
})->when($merId, function ($query, $merId) {
|
|
$query->where('mer_id', $merId);
|
|
})->when($date, function ($query, $date) use ($paid) {
|
|
if (!$paid) {
|
|
$query->where(function ($query) use ($date) {
|
|
$query->where(function ($query) use ($date) {
|
|
$query->where('paid', 1);
|
|
getModelTime($query, $date, 'pay_time');
|
|
})->whereOr(function ($query) use ($date) {
|
|
$query->where('paid', 0);
|
|
getModelTime($query, $date);
|
|
});
|
|
});
|
|
} else
|
|
getModelTime($query, $date, 'pay_time');
|
|
})->sum('pay_price');
|
|
}
|
|
|
|
public function streetList(){
|
|
$data= get_params();
|
|
$id = $data['id'];
|
|
$this->adminInfo = get_admin($data['admin_id']);
|
|
if ($this->adminInfo['user_id']>0){//不是超级管理员
|
|
$www['user_id'] = $this->adminInfo['user_id'];
|
|
$user_address = Db::table('fa_szxc_information_useraddress')->where($www)->find();
|
|
if($user_address['auth_range'] == 3 || $user_address['auth_range'] == 4){
|
|
$where = [];
|
|
}else{
|
|
$where['street_code'] = $user_address['street_id'];
|
|
}
|
|
$select= Db::table('fa_geo_street')->where('area_code',$id)->where($where)->field('street_id id,street_code code,street_name name')->select();
|
|
}else{
|
|
$select= Db::table('fa_geo_street')->where('area_code',$id)->field('street_id id,street_code code,street_name name')->select();
|
|
}
|
|
$select = ['data' => $select];
|
|
return table_assign(0, '', $select);
|
|
}
|
|
|
|
|
|
/**
|
|
* 后台首页获取支付等数据
|
|
* @return mixed
|
|
* @author xaboy
|
|
* @day 2020/6/25
|
|
*/
|
|
public function main()
|
|
{
|
|
// 获取当前登录账号
|
|
$adminUserInfo = get_login_admin();
|
|
|
|
$mmm = [];
|
|
|
|
//权限组信息
|
|
if ($adminUserInfo['group_access'] != 1) {
|
|
|
|
$find = InformationUserAddress::where('admin_id', $adminUserInfo['id'])->find();
|
|
if ($find) {
|
|
if ($find['auth_range'] == 1) {
|
|
$mmm['area_id'] = $find['area_id'];
|
|
|
|
$mmm['street_id'] = $find['street_id'];
|
|
$mmm['village_id'] = $find['village_id'];
|
|
} elseif ($find['auth_range'] == 2) {
|
|
$mmm['area_id'] = $find['area_id'];
|
|
$mmm['street_id'] = $find['street_id'];
|
|
}elseif ($find['auth_range'] == 5) {
|
|
$mmm['area_id'] = $find['area_id'];
|
|
$mmm['street_id'] = $find['street_id'];
|
|
$mmm['village_id'] = $find['village_id'];
|
|
$mmm['brigade_id'] = $find['brigade_id'];
|
|
}
|
|
}
|
|
}
|
|
|
|
$res = Cache::store('file')->remember(self::class . '@main', function () use ($mmm){
|
|
$today = $this->mainGroup('today' , $mmm);
|
|
$yesterday = $this->mainGroup('yesterday', $mmm);
|
|
$lastWeek = $this->mainGroup(date('Y-m-d', strtotime('- 7day')), $mmm);
|
|
|
|
$lastWeekRate = [];
|
|
foreach ($lastWeek as $k => $item) {
|
|
$lastWeekRate[$k] = $this->getRate($item, $today[$k], 4);
|
|
}
|
|
return compact('today', 'yesterday', 'lastWeekRate');
|
|
}, 2000 + random_int(600, 1200));
|
|
// $jyq=Db::connect('shop')->table('eb_product_order_log')->where('area_id',510502)->cache(true)->sum('product_price');
|
|
// $lmtq=Db::connect('shop')->table('eb_product_order_log')->where('area_id',510504)->cache(true)->sum('product_price');
|
|
// $region=[
|
|
// 'jyq'=>$jyq,
|
|
// 'lmtq'=>$lmtq,
|
|
// 'nxq'=>0,
|
|
// 'lx'=>0,
|
|
// 'hjx'=>0,
|
|
// 'xyx'=>0,
|
|
// 'glx'=>0,
|
|
// ];
|
|
// $jyq1=Db::connect('shop')->table('eb_product_order_log')->where('area_id',510502)->where('mer_type_id',4)->cache(true)->sum('product_price');
|
|
// $lmtq1=Db::connect('shop')->table('eb_product_order_log')->where('area_id',510504)->where('mer_type_id',4)->cache(true)->sum('product_price');
|
|
|
|
// $personal=[
|
|
// 'jyq'=>$jyq1,
|
|
// 'lmtq'=>$lmtq1,
|
|
// 'nxq'=>0,
|
|
// 'lx'=>0,
|
|
// 'hjx'=>0,
|
|
// 'xyx'=>0,
|
|
// 'glx'=>0,
|
|
// ];
|
|
// $res['region']=$region;
|
|
// $res['personal']=$personal;
|
|
$result = ['data' => $res];
|
|
return table_assign(0, '', $result);
|
|
}
|
|
|
|
/**
|
|
* @param $date
|
|
* @return array
|
|
* @author xaboy
|
|
* @day 2020/6/25
|
|
*/
|
|
protected function mainGroup($date, $mmm)
|
|
{
|
|
// 获取当前地域成员
|
|
$userList = InformationUserMsg::where($mmm)
|
|
->with(['user'])
|
|
->select();
|
|
|
|
// 地域成员ID
|
|
$arrUid = [];
|
|
$arrPhone = [];
|
|
foreach ($userList as $v) {
|
|
|
|
// 如果存在服务小组的话，则取出
|
|
if($v['user']['fa_supply_team_id'])
|
|
{
|
|
$arrUid[] = $v['user']['uid'];
|
|
$arrPhone[] = $v['user']['phone'];
|
|
}
|
|
}
|
|
$merId = null;
|
|
$payPrice = getModelTime(StoreOrder::whereIn('uid', $arrUid)
|
|
->where('paid', 1), $date, 'create_time')
|
|
->sum('pay_price');
|
|
|
|
// $list = SupplyBrokerageModel::whereIn('user_id', $arrUid)
|
|
// ->with(['user', 'merchant', 'supplyChain', 'level'])
|
|
// ->page($params['page'])
|
|
// ->limit($params['limit'])
|
|
// ->select();
|
|
|
|
// $payPrice = getModelTime(Db::connect('shop')->table('eb_store_order')->where('paid', 1)->when($merId, function ($query, $merId) {
|
|
// $query->where('mer_id', $merId);
|
|
// }), $date, 'pay_time')->sum('pay_price');
|
|
|
|
|
|
$payUser = getModelTime(StoreOrder::whereIn('uid', $arrUid)->where('paid', 1), $date, 'pay_time')->group('uid')->count();
|
|
|
|
$userNum = (float)ShopUser::whereIn('uid', $arrUid)->when($date, function ($query, $date) {
|
|
getModelTime($query, $date, 'create_time');
|
|
})->count();
|
|
|
|
// 可能存在问题，待更新
|
|
$storeNum = (float)Db::connect('shop')
|
|
->table('eb_merchant')
|
|
->where('is_del', 0)
|
|
->whereIn('mer_phone', $arrPhone)
|
|
->when($date, function ($query, $date) {
|
|
getModelTime($query, $date);
|
|
})->count();
|
|
|
|
$visitUserNum = (float)Db::connect('shop')
|
|
->table('eb_user_visit')
|
|
->alias('A')
|
|
->whereIn('A.uid', $arrUid)
|
|
->join('eb_store_product B', 'A.type_id = B.product_id')
|
|
->when($date, function ($query, $date) {
|
|
getModelTime($query, $date, 'A.create_time');
|
|
})->when($merId, function ($query, $merId) {
|
|
$query->where('B.mer_id', $merId);
|
|
})->where('A.type', 'product')->group('uid')->count();
|
|
|
|
$visitNum = (float)Db::connect('shop')->table('eb_user_visit')->when($date, function ($query, $date) {
|
|
getModelTime($query, $date, 'create_time');
|
|
})->whereIn('type', ['page', 'smallProgram'])->count();
|
|
|
|
return compact('payPrice','userNum', 'storeNum', 'visitUserNum', 'visitNum','payUser');
|
|
}
|
|
|
|
/**
|
|
* @param $last
|
|
* @param $today
|
|
* @param int $scale
|
|
* @return int|string|null
|
|
* @author xaboy
|
|
* @day 2020/6/25
|
|
*/
|
|
protected function getRate($last, $today, $scale = 2)
|
|
{
|
|
if ($last == $today)
|
|
return 0;
|
|
else if ($last == 0)
|
|
return $today;
|
|
else if ($today == 0)
|
|
return -$last;
|
|
else
|
|
return (float)bcdiv(bcsub((string)$today, (string)$last, $scale), (string)$last, $scale);
|
|
}
|
|
|
|
|
|
/**
|
|
* @param 后台首页获取订单数据
|
|
* @return mixed
|
|
* @author xaboy
|
|
* @day 2020/6/25
|
|
*/
|
|
public function order()
|
|
{
|
|
|
|
$date = get_params('date') ??'lately7';
|
|
$merId = get_params('mer_id') ??'';
|
|
$res = Cache::remember(self::class . '@order' . $merId . $date, function () use ($merId, $date) {
|
|
if ($date == 'year') {
|
|
$m = date('m',time());
|
|
$time[] = $m;
|
|
do{
|
|
$time[] = '0'. ($m - 1);
|
|
$m--;
|
|
}while($m > 1);
|
|
$time = array_reverse($time);
|
|
} else {
|
|
$time = getDatesBetweenTwoDays(getStartModelTime($date), date('Y-m-d'));
|
|
}
|
|
$list = $this->orderGroupNum($date, $merId)->toArray();
|
|
$list = array_combine(array_column($list, 'day'), $list);
|
|
$data = [];
|
|
foreach ($time as $item) {
|
|
$data[] = [
|
|
'day' => $item,
|
|
'total' => $list[$item]['total'] ?? 0,
|
|
'user' => $list[$item]['user'] ?? 0,
|
|
'pay_price' => $list[$item]['pay_price'] ?? 0
|
|
];
|
|
}
|
|
return $data;
|
|
}, 2000 + random_int(600, 1200));
|
|
$result['day'] = array_column($res,'day');
|
|
$result['total'] = array_column($res,'total');
|
|
$result['user'] = array_column($res,'user');
|
|
$result['pay_price'] = array_column($res,'pay_price');
|
|
// halt($result);
|
|
$result = ['data' => $result];
|
|
return table_assign(0, '', $result);
|
|
}
|
|
|
|
public function orderGroupNum($date, $merId = null)
|
|
{
|
|
$field = Db::raw('sum(pay_price) as pay_price,count(*) as total,count(distinct uid) as user,pay_time,from_unixtime(unix_timestamp(pay_time),\'%m-%d\') as `day`');
|
|
if ($date == 'year'){
|
|
$field = Db::raw('sum(pay_price) as pay_price,count(*) as total,count(distinct uid) as user,pay_time,from_unixtime(unix_timestamp(pay_time),\'%m\') as `day`');
|
|
}
|
|
$query = Db::connect('shop')->table('eb_store_order')->field($field)
|
|
->where('paid', 1)->when($date, function ($query, $date) {
|
|
getModelTime($query, $date, 'pay_time');
|
|
})->when($merId, function ($query, $merId) {
|
|
$query->where('mer_id', $merId);
|
|
});
|
|
return $query->order('pay_time ASC')->group('day')->select();
|
|
}
|
|
|
|
|
|
/**
|
|
* @param 后台首页获取用户数据
|
|
* @return \think\response\Json
|
|
* @author xaboy
|
|
* @day 2020/9/24
|
|
*/
|
|
public function user()
|
|
{
|
|
$date = get_params('date') ?? 'today';
|
|
$merId = get_params('mer_id') ??'';
|
|
$res = Cache::store('file')->remember(self::class . '@user' .$merId . $date, function () use ($merId, $date) {
|
|
|
|
$visitUser = Db::connect('shop')->table('eb_user_visit')->alias('A')->join('eb_store_product B', 'A.type_id = B.product_id')->when($date, function ($query, $date) {
|
|
getModelTime($query, $date, 'A.create_time');
|
|
})->when($merId, function ($query, $merId) {
|
|
$query->where('B.mer_id', $merId);
|
|
})->where('A.type', 'product')->group('uid')->count();
|
|
|
|
$paid = 0;
|
|
$orderUser = Db::connect('shop')->table('eb_store_order')->when($paid, function ($query, $paid) {
|
|
$query->where('paid', $paid);
|
|
})->when($merId, function ($query, $merId) {
|
|
$query->where('mer_id', $merId);
|
|
})->when($date, function ($query, $date) use ($paid) {
|
|
if (!$paid) {
|
|
getModelTime($query, $date);
|
|
// $query->where(function ($query) use ($date) {
|
|
// $query->where(function ($query) use ($date) {
|
|
// $query->where('paid', 1);
|
|
// getModelTime($query, $date, 'pay_time');
|
|
// })->whereOr(function ($query) use ($date) {
|
|
// $query->where('paid', 0);
|
|
// getModelTime($query, $date);
|
|
// });
|
|
// });
|
|
} else
|
|
getModelTime($query, $date, 'pay_time');
|
|
})->group('uid')->count();
|
|
|
|
$orderPrice = Db::connect('shop')->table('eb_store_order')->when($paid, function ($query, $paid) {
|
|
$query->where('paid', $paid);
|
|
})->when($merId, function ($query, $merId) {
|
|
$query->where('mer_id', $merId);
|
|
})->when($date, function ($query, $date) use ($paid) {
|
|
if (!$paid) {
|
|
$query->where(function ($query) use ($date) {
|
|
$query->where(function ($query) use ($date) {
|
|
$query->where('paid', 1);
|
|
getModelTime($query, $date, 'pay_time');
|
|
})->whereOr(function ($query) use ($date) {
|
|
$query->where('paid', 0);
|
|
getModelTime($query, $date);
|
|
});
|
|
});
|
|
} else
|
|
getModelTime($query, $date, 'pay_time');
|
|
})->sum('pay_price');
|
|
|
|
$paid = 1;
|
|
$payOrderUser = Db::connect('shop')->table('eb_store_order')->when($paid, function ($query, $paid) {
|
|
$query->where('paid', $paid);
|
|
})->when($merId, function ($query, $merId) {
|
|
$query->where('mer_id', $merId);
|
|
})->when($date, function ($query, $date) use ($paid) {
|
|
if (!$paid) {
|
|
getModelTime($query, $date);
|
|
// $query->where(function ($query) use ($date) {
|
|
// $query->where(function ($query) use ($date) {
|
|
// $query->where('paid', 1);
|
|
// getModelTime($query, $date, 'pay_time');
|
|
// })->whereOr(function ($query) use ($date) {
|
|
// $query->where('paid', 0);
|
|
// getModelTime($query, $date);
|
|
// });
|
|
// });
|
|
} else
|
|
getModelTime($query, $date, 'pay_time');
|
|
})->group('uid')->count();
|
|
|
|
$payOrderPrice = Db::connect('shop')->table('eb_store_order')->when($paid, function ($query, $paid) {
|
|
$query->where('paid', $paid);
|
|
})->when($merId, function ($query, $merId) {
|
|
$query->where('mer_id', $merId);
|
|
})->when($date, function ($query, $date) use ($paid) {
|
|
if (!$paid) {
|
|
$query->where(function ($query) use ($date) {
|
|
$query->where(function ($query) use ($date) {
|
|
$query->where('paid', 1);
|
|
getModelTime($query, $date, 'pay_time');
|
|
})->whereOr(function ($query) use ($date) {
|
|
$query->where('paid', 0);
|
|
getModelTime($query, $date);
|
|
});
|
|
});
|
|
} else
|
|
getModelTime($query, $date, 'pay_time');
|
|
})->sum('pay_price');
|
|
|
|
$userRate = $payOrderUser ? bcdiv((string)$payOrderPrice, (string)$payOrderUser, 2) : 0;
|
|
$orderRate = $visitUser ? bcdiv((string)$orderUser, (string)$visitUser, 2) : 0;
|
|
$payOrderRate = $orderUser ? bcdiv((string)$payOrderUser, (string)$orderUser, 2) : 0;
|
|
|
|
return compact('visitUser', 'orderUser', 'orderPrice', 'payOrderUser', 'payOrderPrice', 'payOrderRate', 'userRate', 'orderRate');
|
|
}, 2000 + random_int(600, 1200));
|
|
|
|
$result = ['data' => $res];
|
|
return table_assign(0, '', $result);
|
|
}
|
|
|
|
/**
|
|
* @param 用户统计饼状图
|
|
* @return mixed
|
|
* @author xaboy
|
|
* @day 2020/6/25
|
|
*/
|
|
public function userRate()
|
|
{
|
|
$date = get_params('date') ?? 'today';
|
|
$merId = get_params('mer_id') ??'';
|
|
|
|
$res = Cache::store('file')->remember(self::class . '@userRate' . $merId . $date, function () use ($merId,$date) {
|
|
$paid = 1;
|
|
$uids = Db::connect('shop')->table('eb_store_order')->when($paid, function ($query, $paid) {
|
|
$query->where('paid', $paid);
|
|
})->when($merId, function ($query, $merId) {
|
|
$query->where('mer_id', $merId);
|
|
})->when($date, function ($query, $date) {
|
|
getModelTime($query, $date, 'pay_time');
|
|
})->group('uid')->field(Db::raw('uid,sum(pay_price) as pay_price,count(order_id) as total'))->select()->toArray();
|
|
|
|
$ids = array_column($uids, 'uid');
|
|
$userPayCount = Db::connect('shop')->table('eb_user')->whereIn('uid', $ids)->column('pay_count', 'uid');
|
|
$user = count($uids);
|
|
$oldUser = 0;
|
|
$totalPrice = 0;
|
|
$oldTotalPrice = 0;
|
|
foreach ($uids as $uid) {
|
|
$totalPrice = bcadd((string)$uid['pay_price'], (string)$totalPrice, 2);
|
|
if (($userPayCount[$uid['uid']] ?? 0) > $uid['total']) {
|
|
$oldUser++;
|
|
$oldTotalPrice = bcadd((string)$uid['pay_price'], (string)$oldTotalPrice, 2);
|
|
}
|
|
}
|
|
$newTotalPrice = bcsub((string)$totalPrice, (string)$oldTotalPrice, 2);
|
|
$newUser = $user - $oldUser;
|
|
return compact('newTotalPrice', 'newUser', 'oldTotalPrice', 'oldUser', 'totalPrice', 'user');
|
|
}, 2000 + random_int(600, 1200));
|
|
|
|
$result = ['data' => $res];
|
|
return table_assign(0, '', $result);
|
|
}
|
|
|
|
/**
|
|
* @param 商品支付排行
|
|
* @return mixed
|
|
* @author xaboy
|
|
* @day 2020/6/25
|
|
*/
|
|
public function product()
|
|
{
|
|
// 获取当前登录账号
|
|
$adminUserInfo = get_login_admin();
|
|
|
|
$mmm = [];
|
|
|
|
//权限组信息
|
|
if ($adminUserInfo['group_access'] != 1) {
|
|
|
|
$find = InformationUserAddress::where('admin_id', $adminUserInfo['id'])->find();
|
|
if ($find) {
|
|
if ($find['auth_range'] == 1) {
|
|
$mmm['area_id'] = $find['area_id'];
|
|
|
|
$mmm['street_id'] = $find['street_id'];
|
|
$mmm['village_id'] = $find['village_id'];
|
|
} elseif ($find['auth_range'] == 2) {
|
|
$mmm['area_id'] = $find['area_id'];
|
|
$mmm['street_id'] = $find['street_id'];
|
|
}elseif ($find['auth_range'] == 5) {
|
|
$mmm['area_id'] = $find['area_id'];
|
|
$mmm['street_id'] = $find['street_id'];
|
|
$mmm['village_id'] = $find['village_id'];
|
|
$mmm['brigade_id'] = $find['brigade_id'];
|
|
}
|
|
}
|
|
}
|
|
|
|
// 获取当前地域成员
|
|
$userList = InformationUserMsg::where($mmm)
|
|
->with(['user'])
|
|
->select();
|
|
|
|
// 地域成员ID
|
|
$arrUid = [];
|
|
$arrPhone = [];
|
|
foreach ($userList as $v) {
|
|
|
|
// 如果存在服务小组的话，则取出
|
|
if($v['user']['fa_supply_team_id'])
|
|
{
|
|
$arrUid[] = $v['user']['uid'];
|
|
$arrPhone[] = $v['user']['phone'];
|
|
}
|
|
}
|
|
|
|
$date = get_params('date') ?? 'today';
|
|
$merId = get_params('mer_id') ??'';
|
|
$www2[] = ['A.uid','in', $arrUid];
|
|
$res = Cache::store('file')->remember(self::class . '@product' . $merId . $date, function () use ($merId, $date, $arrUid,$www2) {
|
|
return Db::connect('shop')->table('eb_store_order_product')
|
|
->alias('A')
|
|
->where($www2)
|
|
->Join('eb_store_order B', 'A.order_id = B.order_id')
|
|
->field(Db::raw('sum(A.product_num) as total,A.product_id,cart_info'))
|
|
->withAttr('cart_info', function ($val) {
|
|
return json_decode($val, true);
|
|
})
|
|
->withAttr('store_name', function ($val,$date) {
|
|
return $date['cart_info']['product']['store_name'];
|
|
})
|
|
->withAttr('image', function ($val,$date) {
|
|
return $date['cart_info']['product']['image'];
|
|
})
|
|
->when($date, function ($query, $date) {
|
|
getModelTime($query, $date, 'B.pay_time');
|
|
})->when($merId, function ($query, $merId) {
|
|
$query->where('B.mer_id', $merId);
|
|
})->where('B.paid', '1')->group('A.product_id')->limit(10)->order('total DESC')->select();
|
|
|
|
}, 2000 + random_int(600, 1200));
|
|
$result = ['data' => $res];
|
|
return table_assign(0, '', $result);
|
|
}
|
|
|
|
//商品访客排行
|
|
public function productVisit()
|
|
{
|
|
// 获取当前登录账号
|
|
$adminUserInfo = get_login_admin();
|
|
|
|
$mmm = [];
|
|
|
|
//权限组信息
|
|
if ($adminUserInfo['group_access'] != 1) {
|
|
|
|
$find = InformationUserAddress::where('admin_id', $adminUserInfo['id'])->find();
|
|
if ($find) {
|
|
if ($find['auth_range'] == 1) {
|
|
$mmm['area_id'] = $find['area_id'];
|
|
|
|
$mmm['street_id'] = $find['street_id'];
|
|
$mmm['village_id'] = $find['village_id'];
|
|
} elseif ($find['auth_range'] == 2) {
|
|
$mmm['area_id'] = $find['area_id'];
|
|
$mmm['street_id'] = $find['street_id'];
|
|
}elseif ($find['auth_range'] == 5) {
|
|
$mmm['area_id'] = $find['area_id'];
|
|
$mmm['street_id'] = $find['street_id'];
|
|
$mmm['village_id'] = $find['village_id'];
|
|
$mmm['brigade_id'] = $find['brigade_id'];
|
|
}
|
|
}
|
|
}
|
|
|
|
// 获取当前地域成员
|
|
$userList = InformationUserMsg::where($mmm)
|
|
->with(['user'])
|
|
->select();
|
|
|
|
// 地域成员ID
|
|
$arrUid = [];
|
|
$arrPhone = [];
|
|
foreach ($userList as $v) {
|
|
|
|
// 如果存在服务小组的话，则取出
|
|
if($v['user']['fa_supply_team_id'])
|
|
{
|
|
$arrUid[] = $v['user']['uid'];
|
|
$arrPhone[] = $v['user']['phone'];
|
|
}
|
|
}
|
|
|
|
$date = get_params('date') ?? 'today';
|
|
$merId = get_params('mer_id') ??'';
|
|
|
|
$res = Cache::store('file')->remember(self::class . '@productVisit' . $merId . $date, function () use ($merId, $date, $arrUid) {
|
|
return Db::connect('shop')
|
|
->table('eb_user_visit')
|
|
->alias('A')
|
|
->whereIn('A.uid', $arrUid)
|
|
->join('eb_store_product B', 'A.type_id = B.product_id')
|
|
->join('eb_merchant C', 'C.mer_id = B.mer_id')
|
|
->field(Db::raw('count(A.type_id) as total,B.image,B.store_name'))
|
|
->when($date, function ($query, $date) {
|
|
getModelTime($query, $date, 'A.create_time');
|
|
})->where('A.type', 'product')->where('B.mer_id', $merId)->group('A.type_id')->order('total DESC')
|
|
->limit(10)->select();
|
|
}, 2000 + random_int(600, 1200));
|
|
$result = ['data' => $res];
|
|
return table_assign(0, '', $result);
|
|
}
|
|
|
|
/**
|
|
* @param 商品加购排行
|
|
* @return mixed
|
|
* @author xaboy
|
|
* @day 2020/6/25
|
|
*/
|
|
public function productCart()
|
|
{
|
|
// 获取当前登录账号
|
|
$adminUserInfo = get_login_admin();
|
|
|
|
$mmm = [];
|
|
|
|
//权限组信息
|
|
if ($adminUserInfo['group_access'] != 1) {
|
|
|
|
$find = InformationUserAddress::where('admin_id', $adminUserInfo['id'])->find();
|
|
if ($find) {
|
|
if ($find['auth_range'] == 1) {
|
|
$mmm['area_id'] = $find['area_id'];
|
|
|
|
$mmm['street_id'] = $find['street_id'];
|
|
$mmm['village_id'] = $find['village_id'];
|
|
} elseif ($find['auth_range'] == 2) {
|
|
$mmm['area_id'] = $find['area_id'];
|
|
$mmm['street_id'] = $find['street_id'];
|
|
}elseif ($find['auth_range'] == 5) {
|
|
$mmm['area_id'] = $find['area_id'];
|
|
$mmm['street_id'] = $find['street_id'];
|
|
$mmm['village_id'] = $find['village_id'];
|
|
$mmm['brigade_id'] = $find['brigade_id'];
|
|
}
|
|
}
|
|
}
|
|
|
|
// 获取当前地域成员
|
|
$userList = InformationUserMsg::where($mmm)
|
|
->with(['user'])
|
|
->select();
|
|
|
|
// 地域成员ID
|
|
$arrMerId = [];
|
|
$mer_id = '';
|
|
foreach ($userList as $v) {
|
|
|
|
// 如果存在服务小组的话，则取出
|
|
if($v['user']['fa_supply_team_id'])
|
|
{
|
|
$mer_id = (float)Db::connect('shop')
|
|
->table('eb_merchant')
|
|
->where('is_del', 0)
|
|
->where('mer_phone', $v['user']['phone'])
|
|
->value('mer_id');
|
|
|
|
if($mer_id)
|
|
{
|
|
$arrMerId[] = $mer_id;
|
|
}
|
|
}
|
|
}
|
|
|
|
$date = get_params('date') ?? 'today';
|
|
$merId = get_params('mer_id') ??'';
|
|
|
|
$res = Cache::store('file')->remember(self::class . '@productCart' . $merId . $date, function () use ($merId, $date, $arrMerId) {
|
|
return Db::connect('shop')
|
|
->table('eb_store_product')
|
|
->alias('A')
|
|
->whereIn('A.mer_id', $arrMerId)
|
|
->Join('eb_store_cart B', 'A.product_id = B.product_id')
|
|
->field(Db::raw('sum(B.cart_num) as total,A.product_id,A.store_name,A.image'))
|
|
->when($date, function ($query, $date) {
|
|
getModelTime($query, $date, 'B.create_time');
|
|
})->when($merId, function ($query, $merId) {
|
|
$query->where('A.mer_id', $merId);
|
|
})->where('B.product_type', 0)->where('B.is_pay', 0)->where('B.is_del', 0)
|
|
->where('B.is_new', 0)->where('B.is_fail', 0)->group('A.product_id')->limit(10)->order('total DESC')->select();
|
|
}, 2000 + random_int(600, 1200));
|
|
|
|
$result = ['data' => $res];
|
|
|
|
return table_assign(0, '', $result);
|
|
}
|
|
|
|
public function changestatus(){
|
|
$data = get_params();
|
|
if($data){
|
|
$where['product_id'] = $data['product_id'];
|
|
$d['is_show'] = $data['is_show'];
|
|
$res = Db::connect('shop')->table('eb_store_product')->where($where)->update($d);
|
|
if($res){
|
|
return to_assign(200, '操作成功');
|
|
}else{
|
|
return to_assign(0, '操作失败');
|
|
}
|
|
}
|
|
return to_assign(0, '操作失败');
|
|
}
|
|
|
|
public function category_arr($id=0){
|
|
$where[]=['is_show','=',1];
|
|
$where[]=['mer_id','=',0];
|
|
if($id!=0){
|
|
$where[1]=['mer_id','=',$id];
|
|
}
|
|
$list=Db::connect('shop')->table('eb_store_category')->where($where)
|
|
->field('store_category_id id,pid,cate_name name')->select();
|
|
$category_arr=create_tree_list(0,$list,0);
|
|
return to_assign(0,'操作成功', $category_arr);
|
|
}
|
|
|
|
}
|