<?php
namespace app\admin\service\order;
use app\model\GoodsRunning;
use app\model\GoodsSku;
use app\model\Member;
use app\model\Order;
use app\model\OrderSheet;
use app\model\PayDetail;
use app\model\SysDept;
use support\Db;
use support\exception\BusinessException;
use support\Redis;
use Yansongda\Pay\Log;
use Yansongda\Pay\Pay;
class OrderService
{
/**
* @Desc 自动确认收货
* @Author Gorden
* @Date 2024/4/11 16:09
*
* @return void
*/
public static function AutomaticReceipt()
{
try {
Db::beginTransaction();
$timeUnix = strtotime("-7 days");
$orders = Order::where('order_status_system', 'SIGNED')
->where('order_addtimes', '<', $timeUnix)
->get();
foreach ($orders as $order) {
// 订单主表
Order::where('order_id', $order->order_id)->update([
'order_is_complete' => 'Y',
'order_status_system' => 'CONFIRM',
'order_status_storage'=> 'DONE'
]);
// 订单详情表
OrderSheet::where('join_sheet_order_id', $order->order_id)->update(['order_sheet_status' => 'DONE']);
// 7天后自动完成 order_is_complete=Y
// $redis = Redis::connection();
// $key = Order::AUTOMATIC_COMPLETE_PREFIX . date('Ymd', strtotime("+7 days"));
// $redis->sadd($key, $order->order_id);
}
Db::commit();
} catch (\Exception $e) {
Db::rollBack();
}
}
/**
* @Desc 自动完成订单
* @Author Gorden
* @Date 2024/7/16 9:37
*
* @return void
*/
public static function AutomaticComplete()
{
Db::beginTransaction();
try {
$redis = Redis::connection();
$key = Order::AUTOMATIC_COMPLETE_PREFIX . date('Ymd');
$orderIds = $redis->smembers($key);
foreach ($orderIds as $orderId){
$order = Order::where('order_id',$orderId)
->select('order_is_complete','order_category','order_status_system')
->first();
if ($order && $order->order_is_complete != 'Y' && $order->order_category != 'RETURN' && in_array($order->order_status_system,['RECVING','SIGNED','CONFIRM'])){
// 更新主表
Order::where('order_id',$orderId)->update(['order_is_complete'=>'Y','order_status_system'=>'CONFIRM','order_status_storage'=>'DONE']);
// sheet表
OrderSheet::where('join_sheet_order_id',$orderId)->update(['order_sheet_status'=>'DONE']);
}
}
$redis->del($key);
Db::commit();
} catch (\Exception $e) {
dump($e->getMessage());
Db::rollBack();
}
}
public static function checkPayingOrder()
{
try {
Db::beginTransaction();
$timeUnix = strtotime("-30 minutes");
$orders = Order::where('order_status_system', 'PAYING')
->where('order_category','<>','DISHES')
->where('order_platform','<>','SYSTEM') // 后台产生的订单不自动取消
->where('order_addtimes', '<', $timeUnix)
->get();
foreach ($orders as $order) {
// 订单主表
Order::where('order_id', $order->order_id)->update([
'order_is_complete' => 'Y',
'order_status_system' => 'CANCEL',
'order_status_payment' => 'CANCEL'
]);
$sheets = OrderSheet::where('join_sheet_order_id', $order->order_id)->get();
foreach ($sheets as $sheet){
// 还原库存
$goodsSku = GoodsSku::where('goods_sku_id',$sheet->join_sheet_goods_sku_id)->first();
if (!empty($goodsSku) && !empty($goodsSku->goods_sku_storage_json)){
$skuStorageJson = json_decode($goodsSku->goods_sku_storage_json,true);
if (isset($skuStorageJson['storage'])){
$skuStorageJson['storage'] = $skuStorageJson['storage'] + $sheet->order_sheet_num;
$goodsSku->goods_sku_storage_json = json_encode($skuStorageJson);
$goodsSku->save();
}
}
$goodsRunning = GoodsRunning::where('join_running_goods_id',$sheet->join_sheet_goods_id)->first();
if(!empty($goodsRunning)){
$goodsRunning->goods_running_storage = $goodsRunning->goods_running_storage + $sheet->order_sheet_num;
$goodsRunning->goods_running_sale = $goodsRunning->goods_running_sale - $sheet->order_sheet_num;
$goodsRunning->save();
}
}
// 订单详情表
OrderSheet::where('join_sheet_order_id', $order->order_id)->update(['order_sheet_status' => 'CANCEL']);
// 支付表
$payDetail = PayDetail::where('join_pay_order_id', $order->order_groupby)->first();
if(!empty($payDetail)){
$payExtendJson = [];
if (!empty($payDetail->pay_extend_json)){
$payExtendJson = json_decode($payDetail->pay_extend_json,true);
}
$payExtendJson['cancel_times'] = date('Y-m-d H:i:s');
PayDetail::where('join_pay_order_id', $order->order_groupby)->update([
'pay_status' => 'CANCEL',
'pay_extend_json' => json_encode($payExtendJson)
]);
}
}
echo date('Y-m-d H:i:s')."执行\n";
Db::commit();
} catch (\Exception $e) {
Db::rollBack();
}
}
public static function generateWriteOffData($params)
{
return [
'charge' => [
'charge_amount' => 1,
'charge_content' => $params['order_remark'] ?? '',
'charge_user_id' => $params['write_off_member_id'],
'charge_premises' => $params['dept_premises_id'],
],
'member_id' => $params['join_order_member_id']
];
}
public static function generateAppointmentApplyData($params)
{
$member = Member::with('cert','info')
->where('member_id',$params['join_order_member_id'])
->first();
$name = '';
if (!empty($member) && !empty($member->cert) && !empty($member->cert->member_cert_name)){
$name = $member->cert->member_cert_name;
}else if (!empty($member) && !empty($member->info) && !empty($member->info->member_info_nickname)){
$name = $member->info->member_info_nickname;
}
return [
'name' => $name,
'times' => '',
'mobile' => !empty($member) ? $member->member_mobile : '',
'person' => $params['order_sheet_num'] ?? '',
'premises' => $params['dept_premises_id'] ?? ''
];
}
/**
* 微信支付宝扫码支付
*/
public static function qrcodePay($params)
{
$params['order_amount_pay'] = floatval($params['order_amount_pay']);
$qrcodeNbr = $params['qrcode_nbr'];
$prefix = substr($qrcodeNbr,0,2);
// 微信支付
if(in_array($prefix,[10,11,12,13,14,15])){
$payData = [
'out_trade_no' => $params['orderGroupId'],
'body' => '万悦康养订单',
'total_fee' => $params['order_amount_pay']*100,
'auth_code' => $params['qrcode_nbr'],
];
try{
$result = Pay::wechat(config('payment.wxpay'))->pos($payData);
}catch(\Exception $e){
Log::error("WXPAY",['msg'=>$e->getMessage()]);
throw new BusinessException("支付失败");
}
Log::info("WXPAY_RETURN",json_decode(json_encode($result),true));
}else if(in_array($prefix,[25,26,27,28,29,30])){
$payData = [
'out_trade_no' => $params['orderGroupId'],
'total_amount' => $params['order_amount_pay'],
'subject' => '万悦康养订单',
'auth_code' => $params['qrcode_nbr'],
];
try{
$result = Pay::alipay(config('payment.alipay'))->pos($payData);
}catch(\Exception $e){
Log::error("ALIPAY",['msg'=>$e->getMessage()]);
throw new BusinessException("支付失败");
}
Log::info("ALIPAY_RETURN",json_decode(json_encode($result),true));
}else{
throw new BusinessException("二维码无效");
}
return $result;
}
}