<?php
|
|
namespace app\common\model\order;
|
|
use app\common\enum\order\OrderSourceEnum;
|
use app\common\enum\supplier\SupplierType;
|
use app\common\exception\BaseException;
|
use app\common\library\easywechat\AppWx;
|
use app\common\library\easywechat\wx\WxOrder;
|
use app\common\model\BaseModel;
|
use app\common\enum\settings\DeliveryTypeEnum;
|
use app\common\enum\order\OrderPayStatusEnum;
|
use app\common\enum\order\OrderTypeEnum;
|
use app\common\enum\order\OrderPayTypeEnum;
|
use app\common\library\helper;
|
use app\common\model\settings\Express as ExpressModel;
|
use app\common\model\settings\Setting as SettingModel;
|
use app\common\service\order\OrderService;
|
use app\common\service\order\OrderCompleteService;
|
use app\common\model\store\Order as StoreOrderModel;
|
use app\common\service\order\OrderRefundService;
|
use app\common\service\product\factory\ProductFactory;
|
use app\common\model\plus\coupon\UserCoupon as UserCouponModel;
|
use app\common\model\user\User as UserModel;
|
use app\common\service\message\MessageService;
|
use app\shop\model\user\BalanceOrder as BalanceOrderModel;
|
use app\shop\model\user\CardRecord as CardRecordModel;
|
use app\supplier\model\store\Clerk as ClerkModel;
|
use app\supplier\model\store\Store as StoreModel;
|
use app\supplier\model\supplier\Supplier as SupplierModel;
|
use app\common\model\order\OrderSettled as OrderSettledModel;
|
use app\common\model\supplier\Capital as SupplierCapitalModel;
|
use app\common\model\app\AppWx as AppWxModel; //by lyzflash 2024.01.25
|
|
/**
|
* 订单模型模型
|
*/
|
class Order extends BaseModel
|
{
|
protected $pk = 'order_id';
|
protected $name = 'order';
|
|
/**
|
* 追加字段
|
* @var string[]
|
*/
|
protected $append = [
|
'state_text',
|
'order_source_text',
|
'pay_end_time_text',
|
];
|
/**
|
* 关联预售定金订单
|
* @return \think\model\relation\HasOne
|
*/
|
public function advance()
|
{
|
return $this->hasOne('app\\common\\model\\order\\OrderAdvance', 'order_id', 'order_id');
|
}
|
|
/**
|
* 订单商品列表
|
*/
|
public function product()
|
{
|
return $this->hasMany('app\\common\\model\\order\\OrderProduct', 'order_id', 'order_id')->hidden(['content']);
|
}
|
|
|
/**
|
* 关联订单收货地址表
|
*/
|
public function address()
|
{
|
return $this->hasOne('app\\common\\model\\order\\OrderAddress');
|
}
|
|
/**
|
* 关联自提订单联系方式
|
*/
|
public function extract()
|
{
|
return $this->hasOne('app\\common\\model\\order\\OrderExtract');
|
}
|
|
/**
|
* 关联物流公司表
|
*/
|
public function express()
|
{
|
return $this->belongsTo('app\\common\\model\\settings\\Express', 'express_id', 'express_id');
|
}
|
|
/**
|
* 关联自提门店表
|
*/
|
public function extractStore()
|
{
|
return $this->belongsTo('app\\common\\model\\store\\Store', 'extract_store_id', 'store_id');
|
}
|
|
/**
|
* 关联门店店员表
|
*/
|
public function extractClerk()
|
{
|
return $this->belongsTo('app\\common\\model\\store\\Clerk', 'extract_clerk_id');
|
}
|
|
/**
|
* 关联用户表
|
*/
|
public function user()
|
{
|
return $this->belongsTo('app\\common\\model\\user\\User', 'user_id', 'user_id');
|
}
|
|
/**
|
* 关联用户表
|
*/
|
public function room()
|
{
|
return $this->belongsTo('app\\common\\model\\plus\\live\\Room', 'room_id', 'room_id');
|
}
|
|
/**
|
* 关联供应商表
|
*/
|
public function supplier()
|
{
|
return $this->belongsTo('app\\common\\model\\supplier\\Supplier', 'shop_supplier_id', 'shop_supplier_id')->field(['shop_supplier_id', 'name', 'user_id', 'referee_id','supplier_type','gift_type']);
|
}
|
|
/**
|
* 预售结束时间
|
*/
|
public function getPayEndTimeTextAttr($value, $data)
|
{
|
return (isset($data['pay_end_time']) && $data['pay_end_time'] && is_numeric($data['pay_end_time'])) ? date('Y-m-d H:i:s', $data['pay_end_time']) : '';
|
}
|
|
/**
|
* 关联虚拟商品核销信息
|
* @return \think\model\relation\HasOne
|
*/
|
public function verify()
|
{
|
return $this->hasOne('app\\common\\model\\order\\OrderVerify');
|
}
|
|
/**
|
* 订单状态文字描述
|
* @param $value
|
* @param $data
|
* @return string
|
*/
|
public function getStateTextAttr($value, $data)
|
{
|
// 订单状态
|
if (in_array($data['order_status'], [20, 30])) {
|
$orderStatus = [20 => '已取消', 30 => '已完成'];
|
return $orderStatus[$data['order_status']];
|
}
|
// 付款状态
|
if ($data['pay_status'] == 10) {
|
return '待付款';
|
}
|
// 拼团状态
|
if ($data['order_source'] == OrderSourceEnum::ASSEMBLE) {
|
$assemble_status = $this->getAssembleStatus($data);
|
if ($assemble_status != '') {
|
return $assemble_status;
|
}
|
}
|
// 发货状态
|
if ($data['delivery_status'] == 10) {
|
return '已付款，待发货';
|
}
|
if ($data['receipt_status'] == 10) {
|
return '已发货，待收货';
|
}
|
return $value;
|
}
|
|
/**
|
* 拼团订单状态
|
*/
|
private function getAssembleStatus($data)
|
{
|
// 发货状态
|
if ($data['assemble_status'] == 10) {
|
return '已付款，未成团';
|
}
|
if ($data['assemble_status'] == 20 && $data['delivery_status'] == 10) {
|
return '拼团成功，待发货';
|
}
|
if ($data['assemble_status'] == 30) {
|
return '拼团失败';
|
}
|
return '';
|
}
|
|
/**
|
* 付款状态
|
* @param $value
|
* @return array
|
*/
|
public function getPayTypeAttr($value)
|
{
|
return ['text' => OrderPayTypeEnum::data()[$value]['name'], 'value' => $value];
|
}
|
|
/**
|
* 订单来源
|
* @param $value
|
* @return array
|
*/
|
public function getOrderSourceTextAttr($value, $data)
|
{
|
return OrderSourceEnum::data()[$data['order_source']]['name'];
|
}
|
|
/**
|
* 付款状态
|
* @param $value
|
* @return array
|
*/
|
public function getPayStatusAttr($value)
|
{
|
return ['text' => OrderPayStatusEnum::data()[$value]['name'], 'value' => $value];
|
}
|
|
/**
|
* 改价金额（差价）
|
* @param $value
|
* @return array
|
*/
|
public function getUpdatePriceAttr($value)
|
{
|
return [
|
'symbol' => $value < 0 ? '-' : '+',
|
'value' => sprintf('%.2f', abs($value))
|
];
|
}
|
|
/**
|
* 发货状态
|
* @param $value
|
* @return array
|
*/
|
public function getDeliveryStatusAttr($value)
|
{
|
$status = [10 => '待发货', 20 => '已发货'];
|
return ['text' => $status[$value], 'value' => $value];
|
}
|
|
/**
|
* 收货状态
|
* @param $value
|
* @return array
|
*/
|
public function getReceiptStatusAttr($value)
|
{
|
$status = [10 => '待收货', 20 => '已收货'];
|
return ['text' => $status[$value], 'value' => $value];
|
}
|
|
/**
|
* 收货状态
|
* @param $value
|
* @return array
|
*/
|
public function getOrderStatusAttr($value)
|
{
|
$status = [10 => '进行中', 20 => '已取消', 21 => '待取消', 30 => '已完成'];
|
return ['text' => $status[$value], 'value' => $value];
|
}
|
|
/**
|
* 配送方式
|
* @param $value
|
* @return array
|
*/
|
public function getDeliveryTypeAttr($value)
|
{
|
return ['text' => DeliveryTypeEnum::data()[$value]['name'], 'value' => $value];
|
}
|
|
/**
|
* 订单详情
|
* @param $where
|
* @param string[] $with
|
* @return array|\think\Model|null
|
* @throws \think\db\exception\DataNotFoundException
|
* @throws \think\db\exception\DbException
|
* @throws \think\db\exception\ModelNotFoundException
|
*/
|
public static function detail($where, $with = ['user', 'address', 'product' => ['image', 'refund'], 'extract', 'express', 'extractStore.logo', 'extractClerk', 'supplier', 'verify', 'advance'])
|
{
|
is_array($where) ? $filter = $where : $filter['order_id'] = (int)$where;
|
return (new static())->with($with)->where($filter)->find();
|
}
|
|
/**
|
* 订单详情
|
*/
|
public static function detailByNo($order_no, $with = ['user', 'address', 'product' => ['image', 'refund'], 'extract', 'express', 'extractStore.logo', 'extractClerk', 'supplier'])
|
{
|
return (new static())->with($with)->where('order_no', '=', $order_no)->find();
|
}
|
|
/**
|
* 批量获取订单列表
|
*/
|
public function getListByIds($orderIds, $with = [])
|
{
|
$data = $this->getListByInArray('order_id', $orderIds, $with);
|
return helper::arrayColumn2Key($data, 'order_id');
|
}
|
|
/**
|
* 批量更新订单
|
*/
|
public function onBatchUpdate($orderIds, $data)
|
{
|
return $this->where('order_id', 'in', $orderIds)->save($data);
|
}
|
|
/**
|
* 批量获取订单列表
|
*/
|
private function getListByInArray($field, $data, $with = [])
|
{
|
return $this->with($with)
|
->where($field, 'in', $data)
|
->where('is_delete', '=', 0)
|
->select();
|
}
|
|
/**
|
* 生成订单号
|
*/
|
public function orderNo()
|
{
|
return OrderService::createOrderNo();
|
}
|
|
/**
|
* 确认核销（自提订单）
|
*/
|
public function verificationOrder($extractClerkId,$storeId=0,$shop_supplier_id=0)
|
{
|
if (
|
$this['pay_status']['value'] != 20
|
|| ($this['delivery_type']['value'] != DeliveryTypeEnum::EXTRACT && $this['delivery_type']['value'] != DeliveryTypeEnum::NO_EXPRESS && $this['delivery_type']['value'] != DeliveryTypeEnum::STORESS)
|
// || $this['delivery_status']['value'] == 20 // 已发货的也可核销，比如门店配送的 by lyzflash
|
|| $this['receipt_status'] == 20
|
|| in_array($this['order_status']['value'], [20, 21])
|
) {
|
$this->error = '该订单不满足核销条件';
|
return false;
|
}
|
if (empty($extractClerkId)){
|
$this->error = '核销人员不能为空';
|
return false;
|
}
|
//获取核销门店 计算配送点提成（上门自提跟门店配送都有门店提成）
|
$extractStore=StoreModel::detail($this['extract_store_id']);
|
$commission = 0;
|
if(!empty($extractStore)){
|
$commission=$extractStore['commission_rate']>0?$this['order_price']*$extractStore['commission_rate']/100:0;
|
|
$storeMoney=$extractStore['money']+$commission;
|
$storeTotalMoney=$extractStore['total_money']+$commission;
|
$extractStore->save(['money'=>$storeMoney,'total_money'=>$storeTotalMoney]);
|
}
|
|
$delivery_fee=0;
|
if($this['delivery_type']['value']==40){//门店配送订单才有配送费
|
if($extractStore['delivery_type']==0){
|
$delivery_fee=$extractStore['delivery_rate']>0?$this['order_price']*$extractStore['delivery_rate']/100:0;
|
}else{
|
$delivery_fee=$extractStore['delivery_fee'];
|
}
|
$extractClerk=ClerkModel::detail($extractClerkId);
|
$clerkMoney=$extractClerk['money']+$delivery_fee;
|
$clerkTotalMoney=$extractClerk['total_money']+$delivery_fee;
|
$extractClerk->save(['money'=>$clerkMoney,'total_money'=>$clerkTotalMoney]);
|
}
|
|
//判断是否券商品 by yj 2024.1.10
|
$add_supplier_money = 0;
|
$extractSupplier = SupplierModel::detail($shop_supplier_id);//核销的商户
|
if(!empty($this['is_virtual']) && $this['is_virtual'] == 2){
|
|
//优先判断是不是自营商户的券商品
|
$orderSupplier = SupplierModel::detail($this['shop_supplier_id']);//订单的商户
|
//普通商户的券商品
|
if(!empty($orderSupplier["store_type"]) && $orderSupplier["store_type"] == 10 && !empty($extractSupplier) && $orderSupplier["shop_supplier_id"] != $extractSupplier["shop_supplier_id"]){
|
$this->error = '核销失败，您不是该券所属商户的核销员';
|
return false;
|
}
|
|
//自营商户的券商品
|
if(!empty($orderSupplier["store_type"]) && $orderSupplier["store_type"] == 20 && !empty($extractSupplier) && $orderSupplier["shop_supplier_id"] != $extractSupplier["shop_supplier_id"]){
|
//其他商户核销自营商户的券商品,则把券的抵扣金额计算给核销的商户
|
$add_supplier_money = $this["product"][0]["deduction_price"];
|
}
|
|
}
|
|
return $this->transaction(function () use ($extractClerkId,$commission,$delivery_fee,$storeId,$add_supplier_money,$extractSupplier) {
|
// 更新订单状态：已发货、已收货
|
$data = [
|
'extract_clerk_id' => $extractClerkId, // 核销员
|
'delivery_status' => 20,
|
'receipt_status' => 20,
|
'receipt_time' => time(),
|
'order_status' => 30
|
];
|
// 门店配送的订单不需要更新配送时间 by lyzflash
|
if (empty($this['delivery_time'])) {
|
$data['delivery_time'] = time();
|
}
|
$status = $this->save($data);
|
// 新增订单核销记录
|
$extractStoreId = empty($this['extract_store_id']) ? $storeId : $this['extract_store_id'];
|
StoreOrderModel::add(
|
$this['order_id'],
|
$extractStoreId,
|
$this['extract_clerk_id'],
|
$this['shop_supplier_id'],
|
OrderTypeEnum::MASTER,
|
$commission,
|
$delivery_fee
|
);
|
//增加核销券 的抵扣金额 by yj 2024.1.10
|
if(!empty($add_supplier_money) && $add_supplier_money > 0 && !empty($extractSupplier)){
|
$this->addSupplierMoney($this,$add_supplier_money,$extractSupplier);
|
}
|
// 执行订单完成后的操作
|
$OrderCompleteService = new OrderCompleteService(OrderTypeEnum::MASTER);
|
$OrderCompleteService->complete([$this], static::$app_id);
|
return $status;
|
});
|
}
|
|
/**
|
* 供应商金额=券商品的抵扣金额 by yj 2024.1.10
|
*/
|
private function addSupplierMoney($order,$add_supplier_money,$extractSupplier)
|
{
|
|
$orderSettledData = [
|
'order_id' => $order['order_id'],
|
'shop_supplier_id' => $extractSupplier['shop_supplier_id'],//核销的商户
|
'order_money' => $add_supplier_money,
|
'pay_money' => $add_supplier_money,
|
'express_money' => 0,
|
'supplier_money' => $add_supplier_money,
|
'real_supplier_money' => $add_supplier_money,
|
'sys_money' => 0,
|
'real_sys_money' => 0,
|
'agent_money' => 0,
|
'team_money' => 0,
|
'region_money' => 0,
|
'shareholder_money' => 0,
|
'refund_money' => 0,
|
'refund_supplier_money' => 0,
|
'refund_sys_money' => 0,
|
'app_id' => $order['app_id']
|
];
|
// 商家结算记录
|
$supplierCapitalData = [
|
'shop_supplier_id' => $extractSupplier['shop_supplier_id'],
|
'money' => $add_supplier_money,
|
'describe' => '核销券商品结算，订单号：' . $order['order_no'],
|
'app_id' => $order['app_id']
|
];
|
(new supplierModel())->where(['shop_supplier_id' => $extractSupplier['shop_supplier_id']])
|
->inc('total_money', $add_supplier_money)
|
->inc('money', $add_supplier_money)
|
->update();
|
// 修改平台结算金额
|
(new OrderSettledModel())->save($orderSettledData);
|
// 供应商结算明细金额
|
(new SupplierCapitalModel())->save($supplierCapitalData);
|
return true;
|
}
|
|
|
/**
|
* 获取已付款订单总数 (可指定某天)
|
*/
|
public function getOrderData($startDate = null, $endDate = null, $type, $shop_supplier_id = 0)
|
{
|
$model = $this;
|
|
!is_null($startDate) && $model = $model->where('pay_time', '>=', strtotime($startDate));
|
|
if (is_null($endDate)) {
|
!is_null($startDate) && $model = $model->where('pay_time', '<', strtotime($startDate) + 86400);
|
} else {
|
$model = $model->where('pay_time', '<', strtotime($endDate) + 86400);
|
}
|
|
if ($shop_supplier_id > 0) {
|
$model = $model->where('shop_supplier_id', '=', $shop_supplier_id);
|
}
|
|
$model = $model->where('is_delete', '=', 0)
|
->where('pay_status', '=', 20)
|
->where('order_status', '<>', 20);
|
|
|
if ($type == 'order_total') {
|
// 订单数量
|
return $model->count();
|
} else if ($type == 'order_total_price') {
|
// 订单总金额
|
return $model->sum('pay_price');
|
} else if ($type == 'order_user_total') {
|
// 支付用户数
|
return count($model->distinct(true)->column('user_id'));
|
}
|
return 0;
|
}
|
|
/**
|
* 修改订单价格
|
*/
|
public function updatePrice($data)
|
{
|
if ($this['pay_status']['value'] != 10) {
|
$this->error = '该订单不合法';
|
return false;
|
}
|
if ($this['order_source'] != 10) {
|
$this->error = '该订单不合法';
|
return false;
|
}
|
// 实际付款金额
|
$payPrice = bcadd($data['update_price'], $data['update_express_price'], 2);
|
if ($payPrice <= 0) {
|
$this->error = '订单实付款价格不能为0.00元';
|
return false;
|
}
|
return $this->save([
|
'order_no' => $this->orderNo(), // 修改订单号, 否则微信支付提示重复
|
'order_price' => $data['update_price'],
|
'pay_price' => $payPrice,
|
'update_price' => helper::bcsub($data['update_price'], helper::bcsub($this['total_price'], $this['coupon_money'])),
|
'express_price' => $data['update_express_price']
|
]) !== false;
|
}
|
|
/**
|
* 后台取消订单
|
*/
|
public function orderCancel($data)
|
{
|
// 判断订单是否可以取消
|
if ($this['delivery_status']['value'] == 20 || $this['order_status']['value'] != 10 || $this['pay_status']['value'] != 20) {
|
$this->error = "订单不允许取消";
|
return false;
|
}
|
// 订单取消事件
|
$status = $this->transaction(function () use ($data) {
|
// 执行退款操作
|
(new OrderRefundService)->execute($this);
|
// 回退商品库存
|
ProductFactory::getFactory($this['order_source'])->backProductStock($this['product'], true);
|
// 回退用户优惠券
|
$this['coupon_id'] > 0 && UserCouponModel::setIsUse($this['coupon_id'], false);
|
$this['coupon_id_sys'] > 0 && UserCouponModel::setIsUse($this['coupon_id_sys'], false);
|
// 回退用户积分
|
$user = UserModel::detail($this['user_id']);
|
$describe = "订单取消：{$this['order_no']}";
|
$this['points_num'] > 0 && $user->setIncPoints($this['points_num'], $describe);
|
//预售订单
|
if ($this['order_source'] == OrderSourceEnum::ADVANCE) {
|
if ($this['advance']['money_return'] == 1) {//预售订单退定金
|
if ((new OrderRefundService)->execute($this['advance'])) {
|
// 更新订单状态
|
$this['advance']->save([
|
'is_refund' => 1,
|
'refund_money' => $this['advance']['pay_price'],
|
]);
|
}
|
}
|
$this['advance']->save(['order_status' => 20]);
|
}
|
// 减少用户购买商品次数
|
UserModel::decreasePurchaseCount($this['user_id'], $this['product'], $this['app_id']);
|
// 更新订单状态
|
return $this->save(['order_status' => 20,'is_refund' => 1,'refund_money' => $this['pay_price'], 'cancel_remark' => $data['cancel_remark']]);
|
});
|
return $status;
|
}
|
|
/**
|
* 审核：用户取消订单
|
*/
|
public function confirmCancel($data)
|
{
|
// 判断订单是否有效
|
if ($this['pay_status']['value'] != 20) {
|
$this->error = '该订单不合法';
|
return false;
|
}
|
// 订单取消事件
|
$status = $this->transaction(function () use ($data) {
|
if ($data['is_cancel'] == true) {
|
// 执行退款操作
|
(new OrderRefundService)->execute($this);
|
// 回退商品库存
|
ProductFactory::getFactory($this['order_source'])->backProductStock($this['product'], true);
|
// 回退用户优惠券
|
$this['coupon_id'] > 0 && UserCouponModel::setIsUse($this['coupon_id'], false);
|
$this['coupon_id_sys'] > 0 && UserCouponModel::setIsUse($this['coupon_id_sys'], false);
|
// 回退用户积分
|
$user = UserModel::detail($this['user_id']);
|
$describe = "订单取消：{$this['order_no']}";
|
$this['points_num'] > 0 && $user->setIncPoints($this['points_num'], $describe,0,true,($this['supplier']['supplier_type'] == SupplierType::GROUPBUYING?1:0));
|
//预售订单
|
if ($this['order_source'] == OrderSourceEnum::ADVANCE) {
|
if ($this['advance']['money_return'] == 1) {//预售订单退定金
|
if ((new OrderRefundService)->execute($this['advance'])) {
|
// 更新订单状态
|
$this['advance']->save([
|
'is_refund' => 1,
|
'refund_money' => $this['advance']['pay_price'],
|
]);
|
}
|
}
|
$this['advance']->save(['order_status' => 20]);
|
}
|
}
|
// 减少用户购买商品次数
|
UserModel::decreasePurchaseCount($this['user_id'], $this['product'], $this['app_id']);
|
// 更新订单状态
|
//return $this->save(['order_status' => $data['is_cancel'] ? 20 : 10]);
|
return $this->save([
|
'order_status' => $data['is_cancel'] ? 20 : 10,
|
'is_refund' => $data['is_cancel'] ? 1 : 0,
|
'refund_money' => $data['is_cancel'] ? $this['pay_price'] : 0,
|
]);
|
});
|
return $status;
|
}
|
|
/**
|
* 确认发货(单独订单)
|
*/
|
public function delivery($data)
|
{
|
// 转义为订单列表
|
$orderList = [$this];
|
// 验证订单是否满足发货条件
|
if (!$this->verifyDelivery($orderList)) {
|
return false;
|
}
|
// 整理更新的数据
|
$updateList = [[
|
'order_id' => $this['order_id'],
|
'express_id' => $data['express_id'],
|
'express_no' => $data['express_no']
|
]];
|
|
// 更新订单发货状态
|
if ($status = $this->updateToDelivery($updateList)) {
|
// 获取已发货的订单
|
$completed = self::detail($this['order_id'], ['user', 'address', 'product', 'express']);
|
// 发送消息通知
|
$this->sendDeliveryMessage([$completed]);
|
}
|
return $status;
|
}
|
|
/**
|
* 确认发货后发送消息通知
|
*/
|
public function sendDeliveryMessage($orderList)
|
{
|
// 实例化消息通知服务类
|
$Service = new MessageService;
|
foreach ($orderList as $item) {
|
// 获取已发货的订单
|
$order = self::detail($item['order_id'], ['user', 'address', 'product', 'express']);
|
// 原生微信支付时才操作
|
if ($order['wx_delivery_status'] == 10 && $order["transaction_id"]) {
|
$order->sendWxExpress($order['express_id'], $order['express_no']);
|
}
|
// 发送消息通知
|
$Service->delivery($item, OrderTypeEnum::MASTER);
|
}
|
return true;
|
}
|
|
/**
|
* 更新订单发货状态(批量)
|
*/
|
private function updateToDelivery($orderList)
|
{
|
$data = [];
|
foreach ($orderList as $item) {
|
$data[] = [
|
'data' => [
|
'order_id' => $item['order_id'],
|
'express_no' => $item['express_no'],
|
'express_id' => $item['express_id'],
|
'delivery_status' => 20,
|
'delivery_time' => time(),
|
],
|
'where' => [
|
'order_id' => $item['order_id']
|
]
|
];
|
}
|
return $this->updateAll($data);
|
}
|
|
/**
|
* 验证订单是否满足发货条件
|
*/
|
private function verifyDelivery($orderList)
|
{
|
foreach ($orderList as $order) {
|
if (
|
$order['pay_status']['value'] != 20
|
|| ($order['delivery_type']['value'] != DeliveryTypeEnum::EXPRESS
|
&& $order['delivery_type']['value'] != DeliveryTypeEnum::STORESS)
|
|| $order['delivery_status']['value'] != 10
|
) {
|
$this->error = "订单号[{$order['order_no']}] 不满足发货条件!";
|
return false;
|
}
|
}
|
return true;
|
}
|
|
/**
|
* 获取收入概况
|
*/
|
public function getOrderIncome($days,$shop_supplier_id,$postData)
|
{
|
$data = [];
|
$user_ids=[];
|
$in = true;
|
$total_pay_balance=0;
|
$total_pay_wx=0;
|
$total_pay_cash=0;
|
$total_pay_other=0;
|
$total_coupon=0;
|
$total_fullreduce=0;
|
$total_points=0;
|
$total_refund_money=0;
|
$total_wx_refund_money=0;
|
foreach ($days as $day) {
|
//计算微信支付
|
$order_wx = $this->getOrderIncomeByDate($day, $shop_supplier_id,20,"online_money",$user_ids,$in);//订单微信支付
|
$wx_refund_money = $this->getOrderIncomeByDate($day, $shop_supplier_id,20,"refund_money",$user_ids,$in);//微信退款
|
$balance_wx = (new BalanceOrderModel)->getTotalPayByDate($day,$user_ids,$in);//订单余额充值
|
$user_wx = (new CardRecordModel)->getTotalPayByDate($day,$user_ids,$in);//订单会员卡购买支付
|
$pay_wx = $order_wx + $balance_wx + $user_wx - $wx_refund_money;
|
$total_pay_wx += $pay_wx;
|
$total_wx_refund_money +=$wx_refund_money;
|
|
//计算余额支付
|
$order_balance = $this->getOrderIncomeByDate($day, $shop_supplier_id,[30,40],"balance",$user_ids,$in);//订单余额支付
|
$balance_refund_money = $this->getOrderIncomeByDate($day, $shop_supplier_id,10,"refund_money",$user_ids,$in);//余额退款
|
$pay_balance = $order_balance - $balance_refund_money;
|
$total_pay_balance += $pay_balance;
|
|
//计算现金支付
|
$pay_cash = $this->getOrderIncomeByDate($day, $shop_supplier_id,40,"pay_price",$user_ids,$in);
|
$total_pay_cash += $pay_cash;
|
//其他支付
|
$pay_other = $this->getOrderIncomeByDate($day, $shop_supplier_id,[10,20,40],"pay_price",$user_ids,$in);
|
$total_pay_other += $pay_other;
|
//优惠券
|
$coupon = $this->getOrderIncomeByDate($day, $shop_supplier_id,'',"coupon_money",$user_ids,$in);
|
$total_coupon += $coupon;
|
//满减
|
$fullreduce=$this->getOrderIncomeByDate($day, $shop_supplier_id,'',"fullreduce_money",$user_ids,$in);
|
$total_fullreduce += $fullreduce;
|
//积分
|
$points = $this->getOrderIncomeByDate($day, $shop_supplier_id,'',"points_money",$user_ids,$in);
|
$total_points += $points;
|
//余额加微信总退款
|
$refund_money = $this->getOrderIncomeByDate($day, $shop_supplier_id,'',"refund_money",$user_ids,$in);
|
$total_refund_money += $refund_money;
|
$data[] = [
|
'day' => $day,
|
"pay_balance" =>round($pay_balance,2),//余额支付
|
"pay_wx" =>round($pay_wx,2),//微信支付
|
"pay_cash" =>round($pay_cash,2),//现金支付
|
"pay_other" =>round($pay_other,2),//其他支付
|
"coupon" =>$coupon,//优惠券
|
"fullreduce" =>$fullreduce,//满减
|
"points" =>$points,//积分
|
"refund_money" =>round($refund_money,2),//余额加微信退款
|
"wx_refund_money" =>round($wx_refund_money,2),//仅仅微信退款 用于测试
|
];
|
}
|
$data[] = [
|
'day' => '合计',
|
"pay_balance" =>round($total_pay_balance,2),//余额支付
|
"pay_wx" =>round($total_pay_wx,2),//微信支付
|
"pay_cash" =>round($total_pay_cash,2),//现金支付
|
"pay_other" =>round($total_pay_other,2),//其他支付
|
"coupon" =>round($total_coupon,2),//优惠券
|
"fullreduce" =>round($total_fullreduce,2),//满减
|
"points" =>round($total_points,2),//积分
|
"refund_money" =>round($total_refund_money,2),//余额加微信退款
|
"total_wx_refund_money" =>round($total_wx_refund_money,2),//仅仅微信退款 用于测试
|
];
|
return $data;
|
|
}
|
|
/**
|
* 根据时间获取收入概况
|
*/
|
public function getOrderIncomeByDate($day,$shop_supplier_id,$pay_type='',$field="pay_price",$user_ids=[],$in='true')
|
{
|
$model = $this;
|
$start = strtotime($day);
|
$end = strtotime($day) + 86399;
|
if($field == "refund_money"){
|
$model = $model->where('update_time', 'between', "$start,$end");
|
}else{
|
$model = $model->where('pay_time', 'between', "$start,$end");
|
}
|
//$model = $model->where('create_time', 'between', "$start,$end");
|
|
if ($shop_supplier_id) {
|
$model = $model->where('shop_supplier_id', '=', $shop_supplier_id);
|
}
|
if (!empty($user_ids)) {
|
if($in){
|
$model = $model->where('user_id', 'in', $user_ids);
|
}else{
|
$model = $model->where('user_id', 'not in', $user_ids);
|
}
|
}
|
|
if(!empty($pay_type)){
|
if(is_array($pay_type)){
|
$model = $model->where('pay_type', 'not in', $pay_type);
|
}else{
|
$model = $model->where('pay_type', '=', $pay_type);
|
}
|
}
|
$money = $model->where('pay_status', '=', 20)
|
//->where('order_status', '<>', 20)
|
->where('is_delete', '=', 0)
|
->sum($field);
|
|
return $money;
|
}
|
|
/**
|
* 主订单购买的数量 by yj
|
* 未取消的订单
|
*/
|
public static function getHasBuyProductNum($user_id, $product_id, $is_complete = false, $now_order_id = 0)
|
{
|
$model = new static();
|
$model = $model->alias('order')->where('order.user_id', '=', $user_id)
|
->join('order_product', 'order_product.order_id = order.order_id', 'left')
|
->where('order_product.product_id', '=', $product_id)
|
->where('order.order_source', '=', OrderSourceEnum::MASTER);
|
if ($now_order_id) {
|
$model = $model->where('order.order_id', '<>', $now_order_id);
|
}
|
if ($is_complete) {
|
$model = $model->where('order.order_status', '=', 30);
|
} else {
|
$model = $model->where('order.order_status', '<>', 21);
|
}
|
$count = $model->sum('total_num');
|
log_write($user_id.'-'.'$product_id:'.$count);
|
return $count;
|
}
|
|
|
public function sendWxExpress($express_id, $express_no)
|
{
|
//判断后台是否设置了微信发货 by yj 2024.4.10
|
$store_setting = SettingModel::getItem('store');
|
if(empty($store_setting["is_send_wx"])){
|
//后台没有设置微信发货
|
return true;
|
}
|
// 如果是小程序微信支付，则提交
|
if ($this['pay_type']['value'] != 20 || $this['pay_source'] != 'wx' || $this['transaction_id'] == '') {
|
return false;
|
}
|
$express = null;
|
if ($this['delivery_type']['value'] == 10) {
|
$express = ExpressModel::detail($express_id);
|
$logistics_type = 1;
|
if (!$express['wx_code']) {
|
$logistics_type = 4;
|
}
|
} elseif ($this['delivery_type']['value'] == 20) {
|
$logistics_type = 4;
|
} elseif ($this['delivery_type']['value'] == 30) {
|
$logistics_type = 3;
|
}
|
// 请求参数
|
$params_arr = [
|
// 订单，需要上传物流信息的订单
|
'order_key' => [
|
// 订单单号类型，用于确认需要上传详情的订单。枚举值1，使用下单商户号和商户侧单号；枚举值2，使用微信支付单号。
|
"order_number_type" => 2,
|
// 原支付交易对应的微信订单号
|
"transaction_id" => $this['transaction_id']
|
],
|
// 发货模式，发货模式枚举值：1、UNIFIED_DELIVERY（统一发货）2、SPLIT_DELIVERY（分拆发货） 示例值: UNIFIED_DELIVERY
|
"delivery_mode" => 1,
|
// 物流模式，发货方式枚举值：1、实体物流配送采用快递公司进行实体物流配送形式 2、同城配送 3、虚拟商品，虚拟商品，例如话费充值，点卡等，无实体配送形式 4、用户自提
|
"logistics_type" => $logistics_type,//$this->getLogisticsType($this['delivery_type']),
|
// 物流信息列表，发货物流单列表，支持统一发货（单个物流单）和分拆发货（多个物流单）两种模式，多重性: [1, 10]
|
"shipping_list" => [
|
[
|
// 物流单号，物流快递发货时必填，示例值: 323244567777 字符字节限制: [1, 128]
|
"tracking_no" => $this['delivery_type']['value'] == 10 ? $express_no : '',
|
// 物流公司编码，快递公司ID，参见「查询物流公司编码列表」，物流快递发货时必填， 示例值: DHL 字符字节限制: [1, 128]
|
"express_company" => $this['delivery_type']['value'] == 10 ? $express['wx_code'] : '',
|
// 商品信息，例如：微信红包抱枕*1个，限120个字以内
|
"item_desc" => $this['product'][0]['product_name'],
|
// 联系方式，当发货的物流公司为顺丰时，联系方式为必填，收件人或寄件人联系方式二选一
|
"contact" => [
|
// 收件人联系方式，收件人联系方式为，采用掩码传输，最后4位数字不能打掩码 示例值: `189****1234, 021-****1234, ****1234, 0**2-***1234, 0**2-******23-10, ****123-8008` 值限制: 0 ≤ value ≤ 1024
|
"receiver_contact" => $this['delivery_type'] == 10 ? $this->desensitize($this['address']['phone'], 3, 4) : ''
|
]
|
]
|
],
|
// 上传时间，用于标识请求的先后顺序 示例值: `2022-12-15T13:29:35.120+08:00`
|
"upload_time" => $this->getUploadTime(),
|
// 支付者，支付者信息
|
"payer" => [
|
// 用户标识，用户在小程序appid下的唯一标识。 下单前需获取到用户的Openid 示例值: oUpF8uMuAJO_M2pxb1Q9zNjWeS6o 字符字节限制: [1, 128]
|
"openid" => $this['user']['open_id']
|
]
|
];
|
log_write('==sendWxExpress=======================');
|
log_write($params_arr);
|
// 小程序配置信息
|
$app = AppWx::getApp();
|
$model = new WxOrder($app);
|
if ($model->uploadExpress($params_arr)) {
|
$this->save(['wx_delivery_status' => 20]);
|
return true;
|
} else {
|
throw new BaseException($model->getError());
|
}
|
}
|
|
private function getUploadTime()
|
{
|
$microtime = microtime();
|
list($microSeconds, $timeSeconds) = explode(' ', $microtime);
|
$milliseconds = round($microSeconds * 1000);
|
return date('Y-m-d') . 'T' . date('H:i:s') . '.' . $milliseconds . '+08:00';
|
}
|
|
/**
|
* 脱敏
|
*
|
* @authors: Msy
|
* @Created-Time: 2022/10/17 17:54
|
* @param $string 需要脱敏的字符
|
* @param $start 开始位置
|
* @param $length 脱敏长度
|
* @param $re 替换字符
|
* @return string
|
*/
|
public function desensitize($string, $start = 0, $length = 0, $re = '*')
|
{
|
if (empty($string) || empty($length) || empty($re)) return $string;
|
$end = $start + $length;
|
$strlen = mb_strlen($string);
|
$str_arr = array();
|
for ($i = 0; $i < $strlen; $i++) {
|
if ($i >= $start && $i < $end) {
|
$str_arr[] = $re;
|
} else {
|
$str_arr[] = mb_substr($string, $i, 1);
|
}
|
}
|
return implode('', $str_arr);
|
}
|
|
/**
|
* 统计平台的优惠券金额
|
*/
|
public static function getCouponMoneyBySupplier($shop_supplier_id,$create_time='')
|
{
|
$model = new static();
|
//搜索时间段
|
if (!empty($create_time)) {
|
$sta_time = array_shift($create_time);
|
$end_time = array_pop($create_time);
|
$model = $model->whereBetweenTime('settled_time', $sta_time, date('Y-m-d 23:59:59', strtotime($end_time)));
|
}
|
$money = $model->where('pay_status', '=', 20)
|
->where('order_status', '=', 30)
|
->where('is_settled', '=', 1)
|
->where('shop_supplier_id', '=', $shop_supplier_id)
|
->where('is_delete', '=', 0)
|
->sum("coupon_money_sys");
|
|
return $money;
|
}
|
|
/**
|
* 统计平台的优惠券数量
|
*/
|
public static function getCouponNumBySupplier($shop_supplier_id,$create_time='')
|
{
|
$model = new static();
|
//搜索时间段
|
if (!empty($create_time)) {
|
$sta_time = array_shift($create_time);
|
$end_time = array_pop($create_time);
|
$model = $model->whereBetweenTime('settled_time', $sta_time, date('Y-m-d 23:59:59', strtotime($end_time)));
|
}
|
$num = $model->where('pay_status', '=', 20)
|
->where('order_status', '=', 30)
|
->where('is_settled', '=', 1)
|
->where('shop_supplier_id', '=', $shop_supplier_id)
|
->where('is_delete', '=', 0)
|
->count();
|
|
return $num;
|
}
|
|
/**
|
* 获取用户是否购买过指定商品
|
* @param int $user_id 用户ID
|
* @param array $product_ids 商品ID数组
|
* @param bool $is_complete 是否只查询已完成的订单
|
* @return array|bool
|
*/
|
public static function getOrderProductIds($user_id, $product_ids = [], $is_complete = false)
|
{
|
// 构建查询条件
|
$model = (new static())->alias('o')
|
->join('order_product op', 'o.order_id = op.order_id')
|
->where('o.user_id', '=', $user_id)
|
->where('o.order_source', '=', OrderSourceEnum::MASTER)
|
->where('o.is_delete', '=', 0);
|
// 如果指定了商品ID，则只查询这些商品
|
if (!empty($product_ids)) {
|
$model->where('op.product_id', 'in', $product_ids);
|
}
|
|
// 如果只查询已完成的订单
|
if ($is_complete) {
|
$model->where('o.order_status', '=', 30); // 已完成状态
|
} else {
|
// 排除已取消的订单
|
$model->where('o.order_status', '<>', 20);
|
}
|
|
// 查询用户购买过的商品ID
|
$result = $model->group('op.product_id')->column('op.product_id');
|
return $result ?true:false;
|
}
|
}
|
