new-admin-api/app/controller/api/Supplier.php

302 lines
11 KiB
PHP

<?php
namespace app\controller\api;
use app\common\repositories\store\order\StoreCartRepository;
use app\common\repositories\store\product\ProductRepository;
use app\common\repositories\store\product\SupplierProductRepository;
use app\services\supplier\SystemSupplierApplyServices;
use app\services\supplier\SystemSupplierServices;
use crmeb\basic\BaseController;
use think\App;
use think\exception\ValidateException;
class Supplier extends BaseController{
protected $services;
public function __construct(App $app, SystemSupplierServices $services){
parent::__construct($app);
$this->services = $services;
}
/**
* Common: 申请入驻
* Author: wu-hui
* Time: 2024/01/30 14:28
* @return mixed
*/
public function applyJoin(){
// 参数获取
$data = $this->checkParam();
if((int)$data['supplierApplyId'] > 0){
// 编辑账号信息
app()->make(SystemSupplierApplyServices::class)->editApplyInfo((array)$data);
}else{
// 添加账号
app()->make(SystemSupplierApplyServices::class)->createApplyInfo((array)$data);
}
return app('json')->success('操作成功');
}
/**
* Common: 申请信息接收
* Author: wu-hui
* Time: 2024/01/30 14:18
* @return array
*/
private function checkParam():array{
// 接收表单参数
$supplierApplyId = (int)$this->request->param('id');
$applyInfo = $this->request->params([
'invite_agent_id',
'winery_name',
'scale',
'cellar_size',
'corporation_name',
'corporation_phone',
['corporation_id_card',[]],
'chairman_name',
'chairman_phone',
['chairman_id_card',[]],
'contacts_name',
'contacts_phone',
'business_license',
'production_icense',
'circulative_license',
]);
$applyInfo['uid'] = $this->request->uid();
// 数据校验
if (empty($applyInfo['invite_agent_id'])) throw new ValidateException('非法请求,无有效邀请人!');
if (empty($applyInfo['winery_name'])) throw new ValidateException('请输入酒厂名称!');
if (empty($applyInfo['scale'])) throw new ValidateException('请输入年产量多少吨!');
if (empty($applyInfo['cellar_size'])) throw new ValidateException('请输入窖池大小!');
if (empty($applyInfo['corporation_name'])) throw new ValidateException('请输入法人姓名!');
if (empty($applyInfo['corporation_phone'])) throw new ValidateException('请输入法人电话!');
if (isPhone($applyInfo['corporation_phone'])) throw new ValidateException('请输入正确的法人电话!');
if (empty($applyInfo['corporation_id_card'])) throw new ValidateException('请上传法人身份证正反面图片!');
if (empty($applyInfo['chairman_name'])) throw new ValidateException('请输入董事长姓名!');
if (empty($applyInfo['chairman_phone'])) throw new ValidateException('请输入董事长电话!');
if (isPhone($applyInfo['chairman_phone'])) throw new ValidateException('请输入正确的董事长电话!');
if (empty($applyInfo['chairman_id_card'])) throw new ValidateException('请上传董事长身份证正反面图片!');
if (empty($applyInfo['contacts_name'])) throw new ValidateException('请输入联系人姓名!');
if (empty($applyInfo['contacts_phone'])) throw new ValidateException('请输入联系人电话!');
if (isPhone($applyInfo['contacts_phone'])) throw new ValidateException('请输入正确的联系人电话!');
if (empty($applyInfo['business_license'])) throw new ValidateException('请上传营业执照!');
if (empty($applyInfo['production_icense'])) throw new ValidateException('请上传生产许可证!');
if (empty($applyInfo['circulative_license'])) throw new ValidateException('请上传流通许可证!');
// 联系人及联系人手机号
$isHas = app()->make(SystemSupplierApplyServices::class)
->searchModel(['contacts_phone'=>$applyInfo['contacts_phone']])
->when($supplierApplyId > 0,function($query) use ($supplierApplyId){
$query->where('id','<>', $supplierApplyId);
})
->count();
if($isHas >= 1) throw new ValidateException('联系人已经存在,请勿重复申请!');
// 酒厂是否已经存在
$isHas = app()->make(SystemSupplierApplyServices::class)
->searchModel(['winery_name'=>$applyInfo['winery_name']])
->when($supplierApplyId > 0,function($query) use ($supplierApplyId){
$query->where('id','<>', $supplierApplyId);
})
->count();
if($isHas >= 1) throw new ValidateException('酒厂已经存在,请勿重复申请!');
$nameIsHave = $this->services->isHave('supplier_name',$applyInfo['winery_name']);
if($nameIsHave) throw new ValidateException('该酒厂已经入驻,请勿重复申请!');
return compact('supplierApplyId','applyInfo');
}
/**
* Common: 申请记录
* Author: wu-hui
* Time: 2024/01/30 17:11
* @return mixed
*/
public function applyRecord(){
$search = $this->request->params(['winery_name','contacts_name','contacts_phone','invite_agent_id','status']);
$search['uid'] = $this->request->uid();
[$page, $limit] = $this->getPage();
$data = app()->make(SystemSupplierApplyServices::class)->getList($search, $page, $limit);
return app('json')->success($data);
}
/**
* Common: 获取单条申请信息
* Author: wu-hui
* Time: 2024/01/30 17:35
* @return mixed
*/
public function applyInfo(){
$applyId = $this->request->param('apply_id');
$data = app()->make(SystemSupplierApplyServices::class)->getSingleInfo(['id'=>$applyId]);
return app('json')->success($data);
}
/**
* Common: 获取全部供应商商品
* Author: wu-hui
* Time: 2024/02/28 15:50
* @return mixed
*/
public function goodsList(){
// 参数获取
$search = $this->request->params(['store_name']);
[$page, $limit] = $this->getPage();
$data = app()->make(SupplierProductRepository::class)->getList($search, $page, $limit);
// 循环处理列表数据
$data['list'] = array_map(function($item){
if(count($item['attrValue']) > 1) $item['attrValue'] = array_column($item['attrValue'],null,'sku');
return $item;
},$data['list']);
return app('json')->success($data);
}
/**
* Common: 获取当前商户购物车列表
* Author: wu-hui
* Time: 2024/03/01 15:06
* @return mixed
*/
public function cartList(){
// 参数获取
$merId = $this->request->merId();
$list = (array)app()->make(StoreCartRepository::class)
->getSearch([
'is_pay' => 0,
'is_del' => 0,
'is_new' => 0,
'is_fail' => 0,
'product_type' => 35,
'wine_mer_id' => $merId,
])
->field(['cart_id','product_type','product_id','product_attr_unique','cart_num','is_batch','batch_num'])
->with([
'productAttr' => function($query){
$query->field(['product_id','detail','image','price','sku','unique','value_id', 'stock']);
},
'product' => function($query){
$query->field(['product_id','store_name','unit_name','is_batch','batch_num','batch_unit','brand_id'])
->with([
'brand'=>function($query){
$query->bind(['brand_name']);
}
]);
}
])
->select()
->toArray();
return app('json')->success($list);
}
/**
* Common: 获取购物车id列表
* Author: wu-hui
* Time: 2024/03/01 15:39
* @return mixed
*/
public function cartIds(){
// 参数获取
$merId = $this->request->merId();
$ids = (array)app()->make(StoreCartRepository::class)
->getSearch([
'is_pay' => 0,
'is_del' => 0,
'is_new' => 0,
'is_fail' => 0,
'product_type' => 35,
'wine_mer_id' => $merId,
])->column('cart_id');
return app('json')->success($ids);
}
/**
* Common: 商户购物车 - 新增购买商品&修改购买商品数量
* Author: wu-hui
* Time: 2024/03/01 14:24
* @return mixed
*/
public function cartAdd(){
// 参数获取
$data = $this->request->params([
'cart_num',
'product_attr_unique',
'product_id',
'is_batch',
'batch_num',
]);
$data['product_type'] = 35;
$data['source'] = $data['product_type'];
$data['source_id'] = $data['product_id'];
$merId = $this->request->merId();
// 校验数据
$result = app()->make(ProductRepository::class)->supplyCartCheck($data,$merId);
// 添加修改
$cartId = (int)app()->make(StoreCartRepository::class)->getSearch([
'is_pay' => 0,
'is_del' => 0,
'is_new' => 0,
'is_fail' => 0,
'product_type' => 35,
'product_id' => $data['source_id'],
'wine_mer_id' => $merId,
'product_attr_unique' => $data['product_attr_unique'],
])->value('cart_id');
if($cartId > 0){
// 已经存在 修改数量
app()->make(StoreCartRepository::class)->update($cartId,[
'cart_num' => $data['cart_num'],
'is_batch' => $data['is_batch'],
'batch_num' => $data['batch_num']
]);
}else{
// 不存在 添加信息
$data['wine_mer_id'] = $merId;
$data['mer_id'] = $result['product']['mer_id'];
app()->make(StoreCartRepository::class)->create($data);
}
return app('json')->success();
}
/**
* Common: 商户购物车 - 删除购买商品
* Author: wu-hui
* Time: 2024/03/01 14:49
* @return mixed
*/
public function cartDel(){
// 参数获取
$data = $this->request->params([
'product_attr_unique',
'product_id',
]);
$data['product_type'] = 35;
$data['source'] = $data['product_type'];
$data['source_id'] = $data['product_id'];
$merId = $this->request->merId();
// 删除操作
$cartId = (int)app()->make(StoreCartRepository::class)->getSearch([
'is_pay' => 0,
'is_del' => 0,
'is_new' => 0,
'is_fail' => 0,
'product_type' => 35,
'product_id' => $data['source_id'],
'wine_mer_id' => $merId,
'product_attr_unique' => $data['product_attr_unique'],
])->delete();
return app('json')->success();
}
}