Compare commits
22 Commits
20250723-0
...
20250806-0
| Author | SHA1 | Date | |
|---|---|---|---|
| f898de515a | |||
| 058b56a348 | |||
| 42dd168c14 | |||
| 4f862caa0b | |||
| ec60074298 | |||
| 006821188d | |||
| 46a305ffe5 | |||
| 5bacdc8585 | |||
| 573aeee8db | |||
| 89797d5bfc | |||
| ba009f4a9d | |||
| ae0d0d83ac | |||
| a1668b60fc | |||
| 356b80a653 | |||
| b8f583bcc7 | |||
| 2f1c7a9b28 | |||
| 66666f4a3a | |||
| bbcc0d054f | |||
| 0a1610fc42 | |||
| a296a30080 | |||
| 4d0e3907b2 | |||
| 408a2bfa2b |
@@ -56,10 +56,10 @@ class ApiReturnAspect extends AbstractAspect
|
||||
$this->writeResponseLog(json_encode($result));
|
||||
|
||||
//正式服加密 测试服不做处理
|
||||
if (SystemUtil::checkProEnv()) {
|
||||
$cryptoFactory = $this->CryptoFactory->cryptoClass('api', json_encode($result['data']));
|
||||
$result['data'] = $cryptoFactory->encrypt();
|
||||
}
|
||||
// if (SystemUtil::checkProEnv()) {
|
||||
// $cryptoFactory = $this->CryptoFactory->cryptoClass('api', json_encode($result['data']));
|
||||
// $result['data'] = $cryptoFactory->encrypt();
|
||||
// }
|
||||
|
||||
return $result;
|
||||
}
|
||||
|
||||
@@ -168,6 +168,7 @@ class GoodCache
|
||||
private function buildData(&$list): mixed
|
||||
{
|
||||
$spuIds = array_column($list, 'id');
|
||||
$spuImage = array_column($list, 'image_id');
|
||||
|
||||
$skuList = $this->skuModel->getListBySpuIds($spuIds);
|
||||
|
||||
@@ -176,10 +177,10 @@ class GoodCache
|
||||
$skuList = $skuList->toArray();
|
||||
|
||||
$imageIdArr = array_column($skuList,'image_ids');
|
||||
$imageList = $this->getOssObjects($imageIdArr);
|
||||
$imageList = $this->getOssObjects(array_merge($spuImage,$imageIdArr));
|
||||
|
||||
$chefIds = array_column($skuList,'chef_id');
|
||||
$chefList = $this->adminUserModel->getDataByIds($chefIds);
|
||||
$chefList = $this->adminUserModel->getChefNameByIds($chefIds);
|
||||
|
||||
$skuListArr = [];
|
||||
$imageArr = [];
|
||||
@@ -209,6 +210,7 @@ class GoodCache
|
||||
|
||||
foreach ($list as &$item) {
|
||||
$item['sku_list'] = $skuListArr[$item['id']] ?? [];
|
||||
$item['spu_image_url'] = $imageList[$item['image_id']] ?? '';
|
||||
$item['image_list'] = $imageArr[$item['id']] ?? [];
|
||||
$item['price'] = !empty($price[$item['id']]) ? (min($price[$item['id']]) ?? 0) : 0;
|
||||
}
|
||||
|
||||
@@ -97,17 +97,17 @@ class SiteCache
|
||||
|
||||
/**
|
||||
* @param int $siteId
|
||||
* @return array|false|\Redis|null
|
||||
* @return array|false|\Redis
|
||||
* @throws ContainerExceptionInterface
|
||||
* @throws NotFoundExceptionInterface
|
||||
*/
|
||||
public function getSiteInfo(int $siteId): false|array|\Redis|null
|
||||
public function getSiteInfo(int $siteId): false|array|\Redis
|
||||
{
|
||||
$siteKey = CommonRedisKey::siteInfoKey($siteId);
|
||||
|
||||
if (!$this->redis->exists($siteKey,RedisCode::SYSTEM_DB)) $this->setSiteInfo($siteId);
|
||||
|
||||
return $this->redis->hGetAll($siteKey,RedisCode::SYSTEM_DB) ?? null;
|
||||
return $this->redis->hGetAll($siteKey,RedisCode::SYSTEM_DB) ?? false;
|
||||
}
|
||||
|
||||
/**
|
||||
|
||||
@@ -107,6 +107,32 @@ class AdminUser extends Model
|
||||
return $res;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param array $ids
|
||||
* @return array
|
||||
*/
|
||||
public function getChefNameByIds(array $ids): array
|
||||
{
|
||||
$data = $this
|
||||
->join('chef', function ($join) use ($ids) {
|
||||
$join->on('chef.user_id', '=', 'admin_user.id')
|
||||
->whereIn('chef.id', $ids)
|
||||
->where('admin_user.is_del',UserCode::IS_NO_DEL)
|
||||
->select([
|
||||
'admin_user.chinese_name',
|
||||
'chef.id',
|
||||
'admin_user.username',
|
||||
]);
|
||||
})
|
||||
->get();
|
||||
|
||||
if ($data->isEmpty()) return [];
|
||||
|
||||
$data = $data->toArray();
|
||||
|
||||
return array_column($data,null,'id');
|
||||
}
|
||||
|
||||
/**
|
||||
* @param array $ids
|
||||
* @return array
|
||||
|
||||
@@ -96,7 +96,7 @@ class Sku extends Model
|
||||
->where('saleable',GoodCode::LISTING)
|
||||
// ->where('is_add_staple_food',GoodCode::IS_NOT_ADD_STAPLE_FOOD)
|
||||
->orderBy('sort')
|
||||
->select(['id','spu_id','title','image_ids','price','param','extra','total_stock','surplus_stock','order_num','is_add_staple_food','occupied','chef_id','origin_sku_id'])
|
||||
->select(['id','spu_id','title','image_ids','price','param','extra','total_stock','surplus_stock','order_num','is_add_staple_food','occupied','chef_id','origin_sku_id','sub_title'])
|
||||
->get();
|
||||
}
|
||||
|
||||
|
||||
@@ -17,6 +17,7 @@ use Hyperf\DbConnection\Model\Model;
|
||||
* @property int $kitchen_id
|
||||
* @property int $chef_id
|
||||
* @property int $caterer_id
|
||||
* @property int $image_id
|
||||
* @property string $title
|
||||
* @property string $sub_title
|
||||
* @property int $category_id
|
||||
@@ -85,7 +86,7 @@ class Spu extends Model
|
||||
->where('type',$type)
|
||||
->where('saleable',GoodCode::LISTING)
|
||||
->orderBy('sort')
|
||||
->select(['id','cycle_id','chef_id','title','title','sub_title','category_id','favorable'])
|
||||
->select(['id','cycle_id','chef_id','title','title','sub_title','category_id','favorable','image_id'])
|
||||
->get();
|
||||
}
|
||||
|
||||
|
||||
@@ -92,7 +92,7 @@ class PrintService extends CateringBaseService
|
||||
*/
|
||||
public function cancel(): array
|
||||
{
|
||||
$service = $this->printOrderFactory->handle($this->request->input('type'));
|
||||
$service = $this->printOrderFactory->handle((int)$this->request->input('type'));
|
||||
$service->printId = (int)$this->request->input('print_id');
|
||||
$service->handle();
|
||||
$service->printCancel();
|
||||
|
||||
@@ -11,6 +11,7 @@ declare(strict_types=1);
|
||||
namespace App\Service\Admin\Catering\Print;
|
||||
|
||||
use App\Exception\ErrException;
|
||||
use App\Lib\Log;
|
||||
use App\Lib\Print\YlyBasicsLib;
|
||||
use App\Model\Printer;
|
||||
use Hyperf\Di\Annotation\Inject;
|
||||
@@ -58,6 +59,12 @@ class YlyPrintService implements PrintOrderInterface
|
||||
#[Inject]
|
||||
protected Printer $printerModel;
|
||||
|
||||
/**
|
||||
* @var Log
|
||||
*/
|
||||
#[Inject]
|
||||
private Log $log;
|
||||
|
||||
/**
|
||||
* @return void
|
||||
* @throws ContainerExceptionInterface
|
||||
@@ -108,9 +115,12 @@ class YlyPrintService implements PrintOrderInterface
|
||||
empty($this->data['order_sno']) ||
|
||||
empty($this->data['username']) ||
|
||||
empty($this->data['mobile']) ||
|
||||
empty($this->data['date']) ||
|
||||
empty($this->data['heapsort'])
|
||||
) throw new ErrException('打印数据丢失');
|
||||
empty($this->data['date'])
|
||||
// empty($this->data['heapsort'])
|
||||
) {
|
||||
$this->log->error('打印数据'.json_encode($this->data));
|
||||
throw new ErrException('打印数据丢失');
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
@@ -126,9 +136,6 @@ class YlyPrintService implements PrintOrderInterface
|
||||
//设置宽度
|
||||
$this->content .= "<PW>048</PW>";
|
||||
|
||||
$this->content .= "\n";
|
||||
$this->content .= "\n";
|
||||
|
||||
//取餐号
|
||||
$this->content .= "<FS3><CA>{$this->data['pickup_code']}</CA></FS3>\n";
|
||||
|
||||
@@ -190,7 +197,7 @@ class YlyPrintService implements PrintOrderInterface
|
||||
$contentEdibleTimeTips = config('print.yly.content_edible_time_tips');
|
||||
$this->content .= "<LR2>保质期,$contentEdibleTimeTips</LR2>";
|
||||
|
||||
$this->content .= "<FS3><CA>{$this->data['heapsort']}</CA></FS3>";
|
||||
$this->content .= "<FS3><CA>{$this->data['pickup_code']}</CA></FS3>\n";
|
||||
}
|
||||
|
||||
/**
|
||||
@@ -231,6 +238,8 @@ class YlyPrintService implements PrintOrderInterface
|
||||
|
||||
/**
|
||||
* @return void
|
||||
* @throws ContainerExceptionInterface
|
||||
* @throws NotFoundExceptionInterface
|
||||
*/
|
||||
private function checkBoxLabelData(): void
|
||||
{
|
||||
@@ -244,7 +253,10 @@ class YlyPrintService implements PrintOrderInterface
|
||||
empty($this->data['driver_name']) ||
|
||||
empty($this->data['current_num']) ||
|
||||
empty($this->data['date_text'])
|
||||
) throw new ErrException('打印数据丢失');
|
||||
) {
|
||||
$this->log->error('打印数据'.json_encode($this->data));
|
||||
throw new ErrException('打印数据丢失-01');
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
|
||||
@@ -261,7 +261,7 @@ class SkuService extends BaseService
|
||||
$spuInfo = $this->spuModel->getInfoById($skuInfo->spu_id);
|
||||
if (empty($spuInfo)) throw new ErrException('数据出错');
|
||||
|
||||
$purchaseInfo = $this->purchaseModel->getListByCycleIdAndKitchenId($skuInfo->cycle_id,$spuInfo->kitchen_id);
|
||||
$purchaseInfo = $this->purchaseModel->getListByCycleIdAndKitchenId($spuInfo->cycle_id,$spuInfo->kitchen_id);
|
||||
$purchaseIds = [];
|
||||
if (!empty($purchaseInfo)) {
|
||||
foreach ($purchaseInfo->toArray() as $one) {
|
||||
|
||||
@@ -88,6 +88,7 @@ class SpuService extends BaseService
|
||||
if (empty($list['data'])) return $this->return->success('success', ['list' => $list]);
|
||||
|
||||
$spuIds = array_column($list['data'], 'id');
|
||||
$spuImageIds = array_column($list['data'], 'image_id');
|
||||
|
||||
$skuList = $this->skuModel
|
||||
->whereIn('spu_id',$spuIds)
|
||||
@@ -99,7 +100,7 @@ class SpuService extends BaseService
|
||||
|
||||
$imageIdArr = array_column($skuList,'image_ids');
|
||||
$imageIds = array_unique(explode(',',implode(',',$imageIdArr)));
|
||||
$imageList = $this->getOssObjects($imageIds);
|
||||
$imageList = $this->getOssObjects(array_merge($imageIds,$spuImageIds));
|
||||
|
||||
$skuListArr = [];
|
||||
foreach ($skuList as $sku) {
|
||||
@@ -126,6 +127,7 @@ class SpuService extends BaseService
|
||||
|
||||
foreach ($list['data'] as &$item) {
|
||||
$item['sku_list'] = $skuListArr[$item['id']] ?? [];
|
||||
$item['image_url'] = $imageList[$item['image_id']] ?? '';
|
||||
}
|
||||
|
||||
return $this->return->success('success', ['list' => $list]);
|
||||
@@ -156,6 +158,9 @@ class SpuService extends BaseService
|
||||
|
||||
if (!empty($info)) throw new ErrException('该菜品在当前城市已存在');
|
||||
|
||||
$imageId = $this->request->input('image_id');
|
||||
|
||||
$this->updateOssObjects([$imageId]);
|
||||
|
||||
$insertModel = new Spu();
|
||||
|
||||
@@ -170,6 +175,7 @@ class SpuService extends BaseService
|
||||
$insertModel->saleable = $this->request->input('saleable');
|
||||
$insertModel->type = $this->request->input('type');
|
||||
$insertModel->sort = $this->request->input('sort');
|
||||
$insertModel->image_id = $imageId;
|
||||
$insertModel->favorable = GoodCode::NOT_FAVORABLE;
|
||||
|
||||
if (!$insertModel->save()) throw new ErrException('添加菜品失败');
|
||||
@@ -233,6 +239,8 @@ class SpuService extends BaseService
|
||||
|
||||
$this->checkInfo();
|
||||
|
||||
|
||||
|
||||
$kitchenId = (int)$this->request->input('kitchen_id');
|
||||
$oldKitchenId = (int)$info->kitchen_id;
|
||||
|
||||
@@ -245,6 +253,12 @@ class SpuService extends BaseService
|
||||
$info->saleable = $this->request->input('saleable');
|
||||
$info->type = $this->request->input('type');
|
||||
$info->sort = $this->request->input('sort');
|
||||
$requestOssId = $this->request->input('image_id',0);
|
||||
if ($requestOssId != $info->image_id) {
|
||||
$info->image_id = $requestOssId;
|
||||
$this->updateOssObjects([$requestOssId]);
|
||||
$this->updateOssObjectsDisable([$info->image_ids]);
|
||||
}
|
||||
|
||||
if (!$info->save()) throw new ErrException('修改菜品失败');
|
||||
|
||||
@@ -311,6 +325,7 @@ class SpuService extends BaseService
|
||||
$info['city_name'] = $this->systemCityModel->getCityNameById((int)$info['city_id']);
|
||||
$info['kitchen_name'] = $this->kitchenModel->getNameById((int)$info['kitchen_id']);
|
||||
// $info['chef_name'] = $this->chefModel->getChineseNameById((int)$info['chef_id']);
|
||||
$info['image_url'] = $this->getOssObjectById((int)$info['image_id']) ?? '';
|
||||
$info['chef_name'] = '';
|
||||
$info['category_name'] = $this->categoryModel->getNameById((int)$info['category_id']);
|
||||
|
||||
|
||||
@@ -41,7 +41,7 @@ class DriverService extends BaseService
|
||||
|
||||
$list = $this->siteDriverStatementModel
|
||||
->when($searchCityId, function ($query) use ($searchCityId) {
|
||||
$query->whereIn('city_id', $searchCityId);
|
||||
$query->where('city_id', $searchCityId);
|
||||
})
|
||||
->when($searchDriverId, function ($query) use ($searchDriverId) {
|
||||
$query->where('driver_id', $searchDriverId);
|
||||
|
||||
@@ -41,7 +41,7 @@ class SiteService extends BaseService
|
||||
|
||||
$list = $this->siteDriverStatementModel
|
||||
->when($searchCityId, function ($query) use ($searchCityId) {
|
||||
$query->whereIn('city_id', $searchCityId);
|
||||
$query->where('city_id', $searchCityId);
|
||||
})
|
||||
->when($searchSiteId, function ($query) use ($searchSiteId) {
|
||||
$query->where('site_id', $searchSiteId);
|
||||
|
||||
@@ -61,7 +61,7 @@ class EmployeeService extends BaseService
|
||||
/**
|
||||
* @var array|string[]
|
||||
*/
|
||||
private array $filed = ['id','username','avatar','chinese_name','mobile','status','last_login_ip','last_login_time','role_id'];
|
||||
private array $filed = ['id','username','avatar','chinese_name','mobile','status','last_login_ip','last_login_time','role_id','bind_user_id'];
|
||||
|
||||
/**
|
||||
* 列表
|
||||
@@ -160,8 +160,8 @@ class EmployeeService extends BaseService
|
||||
|
||||
$bindUserId = (int)$this->request->input('bind_user_id', 0);
|
||||
if ($bindUserId > 0) {
|
||||
$oldBindUserId = $this->adminUserModel->getAdminInfoByBindUserId($bindUserId);
|
||||
if (!empty($oldBindUserId) && $info->bind_user_id != $oldBindUserId) throw new ErrException('绑定用户已存在');
|
||||
$oldInfo = $this->adminUserModel->getAdminInfoByBindUserId($bindUserId);
|
||||
if (!empty($oldBindUserId) && $info->bind_user_id != $oldInfo->bind_user_id) throw new ErrException('绑定用户已存在');
|
||||
}
|
||||
|
||||
|
||||
|
||||
@@ -20,6 +20,7 @@ use App\Constants\ConfigCode;
|
||||
use App\Exception\ErrException;
|
||||
use App\Model\Category;
|
||||
use App\Service\Api\BaseService;
|
||||
use App\Service\ServiceTrait\Api\BannerTrait;
|
||||
use App\Service\ServiceTrait\Common\CycleTrait;
|
||||
use App\Service\ServiceTrait\Common\OssTrait;
|
||||
use Hyperf\Di\Annotation\Inject;
|
||||
@@ -30,6 +31,7 @@ use function Hyperf\Config\config;
|
||||
class OptionalListService extends BaseService
|
||||
{
|
||||
use CycleTrait;
|
||||
use BannerTrait;
|
||||
|
||||
/**
|
||||
* @var GoodCache
|
||||
@@ -55,6 +57,12 @@ class OptionalListService extends BaseService
|
||||
#[Inject]
|
||||
protected Category $categoryModel;
|
||||
|
||||
/**
|
||||
* 默认地址
|
||||
* @var array|false
|
||||
*/
|
||||
private array|false $siteInfo = [];
|
||||
|
||||
/**
|
||||
* @return array
|
||||
* @throws ContainerExceptionInterface
|
||||
@@ -67,18 +75,20 @@ class OptionalListService extends BaseService
|
||||
if (empty($cycleId)) return $this->return->success('success', ['list' => []]);
|
||||
|
||||
$this->goodCache->cycleId = (int)$cycleId;
|
||||
$siteInfo = $this->siteCache->getSiteInfo((int)$this->request->input('site_id'));
|
||||
|
||||
if (empty($siteInfo) || empty($siteInfo['kitchen_id'])) $siteInfo['kitchen_id'] = config('system.kitchen_id');
|
||||
if (!empty($this->request->input('site_id'))){
|
||||
$this->siteInfo = $this->siteCache->getSiteInfo((int)$this->request->input('site_id'));
|
||||
}
|
||||
if (empty($this->siteInfo) || empty($this->siteInfo['kitchen_id'])) $this->siteInfo['kitchen_id'] = config('system.default_kitchen_id');
|
||||
|
||||
$this->goodCache->kitchenId = (int)$siteInfo['kitchen_id'];
|
||||
$this->goodCache->kitchenId = (int)$this->siteInfo['kitchen_id'];
|
||||
$data = $this->goodCache->getOptionalGoodList();
|
||||
|
||||
if (empty($data)) return $this->return->success('success', ['list' => []]);
|
||||
|
||||
$res = $this->buildData($data);
|
||||
|
||||
return $this->return->success('success', ['list' => $res]);
|
||||
return $this->return->success('success', ['list' => $res,'banner' => $this->getBanner((int)$this->request->input('city_id',config('system.default_city_id')))]);
|
||||
}
|
||||
|
||||
use OssTrait;
|
||||
|
||||
@@ -16,6 +16,7 @@ use App\Model\CouponTemplate;
|
||||
use App\Model\UserCoupon;
|
||||
use App\Service\Api\BaseService;
|
||||
use App\Service\ServiceTrait\Admin\Catering\PrintTrait;
|
||||
use App\Service\ServiceTrait\Api\CouponTrait;
|
||||
use App\Service\ServiceTrait\Api\OrderTrait;
|
||||
use App\Service\ServiceTrait\Common\CycleTrait;
|
||||
use Hyperf\Di\Annotation\Inject;
|
||||
@@ -24,7 +25,7 @@ use Psr\Container\NotFoundExceptionInterface;
|
||||
|
||||
abstract class BaseOrderService extends BaseService
|
||||
{
|
||||
use CycleTrait,OrderTrait,PrintTrait;
|
||||
use CycleTrait,OrderTrait,PrintTrait,CouponTrait;
|
||||
|
||||
/**
|
||||
* @var int 周期id
|
||||
@@ -100,7 +101,7 @@ abstract class BaseOrderService extends BaseService
|
||||
* 优惠券id
|
||||
* @var int
|
||||
*/
|
||||
protected int $couponId;
|
||||
protected int $couponId = 0;
|
||||
|
||||
/**
|
||||
* 地点id
|
||||
|
||||
@@ -121,6 +121,7 @@ class PlaceOrderService extends BaseOrderService
|
||||
* @return void
|
||||
* @throws ContainerExceptionInterface
|
||||
* @throws NotFoundExceptionInterface
|
||||
* @throws ErrException
|
||||
*/
|
||||
private function placeOrder(): void
|
||||
{
|
||||
@@ -133,12 +134,16 @@ class PlaceOrderService extends BaseOrderService
|
||||
|
||||
$this->insertOrderGoods();
|
||||
|
||||
$this->couponLock();
|
||||
|
||||
Db::commit();
|
||||
} catch (Exception $e){
|
||||
echo $e->getMessage();
|
||||
//回滚数据库 和 缓存
|
||||
Db::rollBack();
|
||||
$this->rollbackStock();
|
||||
|
||||
// $this->rollbackCouponLock();
|
||||
//意外抛出
|
||||
throw new ErrException($e->getMessage());
|
||||
}
|
||||
@@ -207,7 +212,7 @@ class PlaceOrderService extends BaseOrderService
|
||||
$orderInsertModel->is_refund_all = OrderCode::REFUND_NULL;
|
||||
$orderInsertModel->order_json = json_encode($this->orderRes);
|
||||
|
||||
if (!$orderInsertModel->save()) throw new Exception('下单失败');
|
||||
if (!$orderInsertModel->save()) throw new Exception('下单失败-01');
|
||||
|
||||
$this->orderId = $orderInsertModel->id;
|
||||
}
|
||||
|
||||
@@ -11,6 +11,7 @@ declare(strict_types=1);
|
||||
namespace App\Service\Api\System;
|
||||
|
||||
use App\Cache\Redis\Api\SiteCache;
|
||||
use App\Constants\Common\SiteCode;
|
||||
use App\Extend\SystemUtil;
|
||||
use App\Model\Site;
|
||||
use App\Service\Api\BaseService;
|
||||
@@ -36,6 +37,7 @@ class SiteListService extends BaseService
|
||||
$query->where('name', 'like', "%$name%");
|
||||
})
|
||||
// ->where('name', 'like', '%'.$this->request->input('search_value').'%')
|
||||
->where('is_del',SiteCode::SITE_NO_DEL)
|
||||
->paginate($limit)
|
||||
->toArray();
|
||||
|
||||
|
||||
@@ -34,7 +34,7 @@ class IndexService extends BaseService
|
||||
$avatar = $this->getOssObjectById($userInfo->avatar_id);
|
||||
|
||||
$res = [
|
||||
'banner' => $this->getBanner(),
|
||||
// 'banner' => $this->getBanner(),
|
||||
'nickname' => $userInfo->nickname,
|
||||
'avatar' => $avatar,
|
||||
'point' => 0,
|
||||
|
||||
41
app/Service/ServiceTrait/Api/BannerTrait.php
Normal file
41
app/Service/ServiceTrait/Api/BannerTrait.php
Normal file
@@ -0,0 +1,41 @@
|
||||
<?php
|
||||
|
||||
namespace App\Service\ServiceTrait\Api;
|
||||
|
||||
use App\Constants\Common\BannerCode;
|
||||
use App\Model\Banner;
|
||||
use App\Service\ServiceTrait\Common\OssTrait;
|
||||
use Hyperf\Di\Annotation\Inject;
|
||||
|
||||
trait BannerTrait
|
||||
{
|
||||
use OssTrait;
|
||||
|
||||
/**
|
||||
* @var Banner
|
||||
*/
|
||||
#[Inject]
|
||||
protected Banner $bannerModel;
|
||||
|
||||
/**
|
||||
* @return array
|
||||
*/
|
||||
private function getBanner(int $cityId): array
|
||||
{
|
||||
$res = $this->bannerModel
|
||||
->where('city_id',$cityId)
|
||||
->where('status',BannerCode::DISPLAYED)
|
||||
->orderBy('sort')
|
||||
->get();
|
||||
if ($res->isEmpty()) return [];
|
||||
$res = $res->toArray();
|
||||
|
||||
$imageList = $this->getOssObjects(array_column($res, 'image_id'));
|
||||
|
||||
foreach ($res as &$v) {
|
||||
$v['url'] = $imageList[$v['image_id']]['url'] ?? '';
|
||||
}
|
||||
|
||||
return $res;
|
||||
}
|
||||
}
|
||||
@@ -4,6 +4,7 @@ namespace App\Service\ServiceTrait\Api;
|
||||
|
||||
use App\Constants\Common\CouponCode;
|
||||
use App\Constants\Common\OrderCode;
|
||||
use App\Exception\ErrException;
|
||||
use App\Extend\DateUtil;
|
||||
use App\Model\UserCoupon;
|
||||
use Exception;
|
||||
@@ -40,6 +41,46 @@ trait CouponTrait
|
||||
if (!$couponInfo->save()) throw new Exception('CancelOrderConsumer:error:couponStatusUpdateError:'.json_encode($orderInfo->toArray()));
|
||||
}
|
||||
|
||||
/**
|
||||
* @return void
|
||||
* @throws Exception
|
||||
*/
|
||||
protected function couponLock(): void
|
||||
{
|
||||
if ($this->couponId <= 0) return;
|
||||
|
||||
$couponInfo = $this->userCouponModel->where('id', $this->couponId)->where('user_id',$this->userId)->first();
|
||||
|
||||
if (empty($couponInfo)) return;
|
||||
|
||||
$couponInfo->status = CouponCode::COUPON_STATUS_USED;
|
||||
$couponInfo->use_time = date('Y-m-d H:i:s');
|
||||
|
||||
if (date('Y-m-d H:i:s') > $couponInfo->validity_end_time) throw new Exception('优惠券已过期');
|
||||
|
||||
if (!$couponInfo->save()) throw new Exception('couponLock:error:couponLockUpdateError:'.json_encode($couponInfo->toArray()));
|
||||
}
|
||||
|
||||
/**
|
||||
* @return void
|
||||
* @throws ErrException
|
||||
*/
|
||||
protected function rollbackCouponLock(): void
|
||||
{
|
||||
if ($this->couponId <= 0) return;
|
||||
|
||||
$couponInfo = $this->userCouponModel->where('id', $this->couponId)->where('user_id',$this->userId)->first();
|
||||
|
||||
if (empty($couponInfo)) return;
|
||||
|
||||
if ($couponInfo->status != CouponCode::COUPON_STATUS_USED) return;
|
||||
|
||||
$couponInfo->status = CouponCode::COUPON_STATUS_UNUSED;
|
||||
$couponInfo->use_time = '1970-01-01 00:00:00';
|
||||
|
||||
if (!$couponInfo->save()) throw new ErrException('系统错误-rollback_coupon失败');
|
||||
}
|
||||
|
||||
/**
|
||||
* @param int $type
|
||||
* @param string $value
|
||||
|
||||
@@ -30,5 +30,7 @@ return [
|
||||
// upload_dir
|
||||
'upload_dir' => BASE_PATH.'/uploads/',
|
||||
// 默认的厨房 id
|
||||
'default_kitchen_id' => env('DEFAULT_KITCHEN_ID',''),
|
||||
'default_kitchen_id' => env('DEFAULT_KITCHEN_ID',1),
|
||||
// 默认 城市 id
|
||||
'default_city_id' => env('DEFAULT_CITY_ID',3),
|
||||
];
|
||||
@@ -60,5 +60,5 @@ WX_PAYMENT_MCH_SECRET_KEY=075cf77f5b57cc84ba59e9df3b86eda1
|
||||
WX_PAYMENT_MCH_SECRET_CERT=__DIR__/config/pay/wx/apiclient_key.pem
|
||||
WX_PAYMENT_MCH_PUBLIC_CERT_PATH=__DIR__/config/pay/wx/apiclient_cert.pem
|
||||
WX_PAYMENT_MINI_APP_ID=wx444b711b6101f25b
|
||||
WX_PAYMENT_SUB_MINI_APP_ID=wxc2bc0e47e212d831
|
||||
WX_PAYMENT_SUB_MCH_ID=1656142874
|
||||
WX_PAYMENT_SUB_MINI_APP_ID=wxc0edbbd0ff0fe7ed
|
||||
WX_PAYMENT_SUB_MCH_ID=1723727305
|
||||
@@ -55,5 +55,5 @@ WX_PAYMENT_MCH_SECRET_KEY=075cf77f5b57cc84ba59e9df3b86eda1
|
||||
WX_PAYMENT_MCH_SECRET_CERT=__DIR__/config/pay/wx/apiclient_key.pem
|
||||
WX_PAYMENT_MCH_PUBLIC_CERT_PATH=__DIR__/config/pay/wx/apiclient_cert.pem
|
||||
WX_PAYMENT_MINI_APP_ID=wx444b711b6101f25b
|
||||
WX_PAYMENT_SUB_MINI_APP_ID=wxc2bc0e47e212d831
|
||||
WX_PAYMENT_SUB_MCH_ID=1656142874
|
||||
WX_PAYMENT_SUB_MINI_APP_ID=wxc0edbbd0ff0fe7ed
|
||||
WX_PAYMENT_SUB_MCH_ID=1723727305
|
||||
4
env.pre
4
env.pre
@@ -58,5 +58,5 @@ WX_PAYMENT_MCH_SECRET_KEY=075cf77f5b57cc84ba59e9df3b86eda1
|
||||
WX_PAYMENT_MCH_SECRET_CERT=__DIR__/config/pay/wx/apiclient_key.pem
|
||||
WX_PAYMENT_MCH_PUBLIC_CERT_PATH=__DIR__/config/pay/wx/apiclient_cert.pem
|
||||
WX_PAYMENT_MINI_APP_ID=wx444b711b6101f25b
|
||||
WX_PAYMENT_SUB_MINI_APP_ID=wxc2bc0e47e212d831
|
||||
WX_PAYMENT_SUB_MCH_ID=1656142874
|
||||
WX_PAYMENT_SUB_MINI_APP_ID=wxc0edbbd0ff0fe7ed
|
||||
WX_PAYMENT_SUB_MCH_ID=1723727305
|
||||
6
env.prod
6
env.prod
@@ -1,6 +1,6 @@
|
||||
# [app] -- 集群配置需一致
|
||||
APP_NAME=hhl_meal
|
||||
APP_ENV=dev
|
||||
APP_ENV=prod
|
||||
API_RETURN_KEY=hch@shenzhen
|
||||
JWT_KEY=hch@shenzhen
|
||||
JWT_EXPIRE=2592000
|
||||
@@ -58,5 +58,5 @@ WX_PAYMENT_MCH_SECRET_KEY=075cf77f5b57cc84ba59e9df3b86eda1
|
||||
WX_PAYMENT_MCH_SECRET_CERT=__DIR__/config/pay/wx/apiclient_key.pem
|
||||
WX_PAYMENT_MCH_PUBLIC_CERT_PATH=__DIR__/config/pay/wx/apiclient_cert.pem
|
||||
WX_PAYMENT_MINI_APP_ID=wx444b711b6101f25b
|
||||
WX_PAYMENT_SUB_MINI_APP_ID=wxc2bc0e47e212d831
|
||||
WX_PAYMENT_SUB_MCH_ID=1656142874
|
||||
WX_PAYMENT_SUB_MINI_APP_ID=wxc0edbbd0ff0fe7ed
|
||||
WX_PAYMENT_SUB_MCH_ID=1723727305
|
||||
Reference in New Issue
Block a user