twong329/crmeb/repositories/OrderRepository.php

<?php

namespace crmeb\repositories;

use app\models\store\StoreOrder;
use app\models\user\User;
use app\models\user\UserBill;
use app\models\user\WechatUser;
use app\admin\model\order\StoreOrder as AdminStoreOrder;
use app\models\store\StoreOrderBatch;
use crmeb\services\MiniProgramService;
use crmeb\services\WechatService;

/**
 * Class OrderRepository
 * @package crmeb\repositories
 */
class OrderRepository
{

    /**
     * TODO 小程序JS支付
     * @param $orderId
     * @param string $field
     * @return array|string
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public static function jsPay($orderId, $field = 'order_id')
    {
        if (is_string($orderId))
            $orderInfo = StoreOrder::where($field, $orderId)->find();
        else
            $orderInfo = $orderId;
        if (!$orderInfo || !isset($orderInfo['paid'])) exception('支付订单不存在!');
        if ($orderInfo['paid']) exception('支付已支付!');
        if ($orderInfo['pay_price'] <= 0) exception('该支付无需支付!');
        $openid = WechatUser::getOpenId($orderInfo['uid']);
        $bodyContent = StoreOrder::getProductTitle($orderInfo['cart_id']);
        $site_name = sys_config('site_name');
        if (!$bodyContent && !$site_name) exception('缺少支付参数');
        return MiniProgramService::jsPay($openid, $orderInfo['order_id'], $orderInfo['pay_price'], 'product', StoreOrder::getSubstrUTf8($site_name . ' - ' . $bodyContent, 30));
    }

        /**
     * TODO 小程序JS支付
     * @param $orderId
     * @param string $field
     * @return array|string
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public static function jsPayBatch($porderId, $field = 'porder_id')
    {
        if (is_string($porderId))
            $porderInfo = StoreOrderBatch::where($field, $porderId)->find();
        else
            $porderInfo = $porderId;
        $subOrders = StoreOrderBatch::getAllSubOrders($porderId);
        if (!$subOrders) exception('支付订单不存在!');
        $fieldValues = StoreOrderBatch::sumFields($subOrders, ['paid', 'pay_price']);
        if ($fieldValues['paid']) exception('支付已支付!');
        if ($fieldValues['pay_price'] <= 0) exception('该支付无需支付!');
        $openid = WechatUser::getOpenId($porderInfo['uid']);
        $bodyContent = StoreOrderBatch::getProductTitleBatch($subOrders);
        $site_name = sys_config('site_name');
        if (!$bodyContent && !$site_name) exception('缺少支付参数');
        return MiniProgramService::jsPay($openid, $porderInfo['porder_id'], $fieldValues['pay_price'], 'product', StoreOrder::getSubstrUTf8($site_name . ' - ' . $bodyContent, 30));
    }

    /**
     * 微信公众号JS支付
     * @param $orderId
     * @param string $field
     * @return array|string
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public static function wxPay($orderId, $field = 'order_id')
    {
        if (is_string($orderId))
            $orderInfo = StoreOrder::where($field, $orderId)->find();
        else
            $orderInfo = $orderId;
        if (!$orderInfo || !isset($orderInfo['paid'])) exception('支付订单不存在!');
        if ($orderInfo['paid']) exception('支付已支付!');
        if ($orderInfo['pay_price'] <= 0) exception('该支付无需支付!');
        $openid = WechatUser::uidToOpenid($orderInfo['uid'], 'openid');
        $bodyContent = StoreOrder::getProductTitle($orderInfo['cart_id']);
        $site_name = sys_config('site_name');
        if (!$bodyContent && !$site_name) exception('缺少支付参数');
        return WechatService::jsPay($openid, $orderInfo['porder_id'], $orderInfo['total_price'], 'product', StoreOrder::getSubstrUTf8($site_name . ' - ' . $bodyContent, 30));
    }

    /**
     * 微信公众号JS支付
     * @param $orderId
     * @param string $field
     * @return array|string
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public static function wxPayBatch($porderId, $field = 'porder_id')
    {
        if (is_string($porderId))
            $porderInfo = StoreOrderBatch::where($field, $porderId)->find();
        else
            $porderInfo = $porderId;
        
        $subOrders = StoreOrderBatch::getAllSubOrders($porderId);
        if (!$subOrders) exception('支付订单不存在!');
        $fieldValues = StoreOrderBatch::sumFields($subOrders, ['paid', 'pay_price']);
        if ($fieldValues['paid']) exception('支付已支付!');
        if ($fieldValues['pay_price'] <= 0) exception('该支付无需支付!');
        $openid = WechatUser::uidToOpenid($porderInfo['uid'], 'openid');
        $bodyContent = StoreOrderBatch::getProductTitleBatch($subOrders);
        $site_name = sys_config('site_name');
        if (!$bodyContent && !$site_name) exception('缺少支付参数');
        return WechatService::jsPay($openid, $porderInfo['porder_id'], $porderInfo['total_price'], 'product', StoreOrder::getSubstrUTf8($site_name . ' - ' . $bodyContent, 30));
    }

    /**
     * 微信h5支付
     * @param $orderId
     * @param string $field
     * @return array|string
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public static function h5Pay($orderId, $field = 'order_id')
    {
        if (is_string($orderId))
            $orderInfo = StoreOrder::where($field, $orderId)->find();
        else
            $orderInfo = $orderId;
        if (!$orderInfo || !isset($orderInfo['paid'])) exception('支付订单不存在!');
        if ($orderInfo['paid']) exception('支付已支付!');
        if ($orderInfo['pay_price'] <= 0) exception('该支付无需支付!');
        $bodyContent = StoreOrder::getProductTitle($orderInfo['cart_id']);
        $site_name = sys_config('site_name');
        if (!$bodyContent && !$site_name) exception('缺少支付参数');
        return WechatService::paymentPrepare(null, $orderInfo['order_id'], $orderInfo['pay_price'], 'product', StoreOrder::getSubstrUTf8($site_name . ' - ' . $bodyContent, 30), '', 'MWEB');
    }

    /**
     * 微信h5支付
     * @param $orderId
     * @param string $field
     * @return array|string
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public static function h5PayBatch($porderId, $field = 'porder_id')
    {
        if (is_string($porderId))
            $porderInfo = StoreOrderBatch::where($field, $porderId)->find();
        else
            $porderInfo = $porderId;
        $subOrders = StoreOrderBatch::getAllSubOrders($porderId);
        if (!$subOrders) exception('支付订单不存在!');
        $fieldValues = StoreOrderBatch::sumFields($subOrders, ['paid', 'pay_price']);
        if ($fieldValues['paid']) exception('支付已支付!');
        if ($fieldValues['pay_price'] <= 0) exception('该支付无需支付!');
        $bodyContent = StoreOrderBatch::getProductTitleBatch($subOrders);
        $site_name = sys_config('site_name');
        if (!$bodyContent && !$site_name) exception('缺少支付参数');
        return WechatService::paymentPrepare(null, $porderInfo['porder_id'], $porderInfo['total_price'], 'product', StoreOrder::getSubstrUTf8($site_name . ' - ' . $bodyContent, 30), '', 'MWEB');
    }

    /**
     * 微信 app 支付
     * @param $orderId
     * @param string $field
     * @return array|string
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public static function wxAppPay($orderId, $field = 'order_id')
    {
        if (is_string($orderId))
            $orderInfo = StoreOrder::where($field, $orderId)->find();
        else
            $orderInfo = $orderId;
        if (!$orderInfo || !isset($orderInfo['paid'])) {
            exception('支付订单不存在!');
        }
        if ($orderInfo['paid']) exception('订单已支付');
        if ($orderInfo['pay_price'] <= 0) exception('该订单无需支付');
        $bodyContent = StoreOrder::getProductTitle($orderInfo['cart_id']);
        $site_name = sys_config('site_name');
        if (!$bodyContent && !$site_name) exception('缺少支付参数');
        return WechatService::appPay(null, $orderInfo['order_id'], $orderInfo['pay_price'], 'product', StoreOrder::getSubstrUTf8($site_name . ' - ' . $bodyContent, 30));
    }    

    /**
     * 微信 app 支付
     * @param $orderId
     * @param string $field
     * @return array|string
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public static function wxAppPayBatch($porderId, $field = 'porder_id')
    {
        if (is_string($porderId))
            $porderInfo = StoreOrderBatch::where($field, $porderId)->find();
        else
            $porderInfo = $porderId;
        $subOrders = StoreOrderBatch::getAllSubOrders($porderId);
        if (!$subOrders) exception('支付订单不存在!');
        $fieldValues = StoreOrderBatch::sumFields($subOrders, ['paid', 'pay_price']);
        if ($fieldValues['paid']) exception('支付已支付!');
        if ($fieldValues['pay_price'] <= 0) exception('该支付无需支付!');
        $bodyContent = StoreOrderBatch::getProductTitleBatch($subOrders);
        $site_name = sys_config('site_name');
        if (!$bodyContent && !$site_name) exception('缺少支付参数');
        return WechatService::appPay(null, $porderInfo['porder_id'], $porderInfo['total_price'], 'product', StoreOrder::getSubstrUTf8($site_name . ' - ' . $bodyContent, 30));
    }

    /**
     * 用户确认收货
     * @param $order
     * @param $uid
     * @throws \think\Exception
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public static function storeProductOrderUserTakeDelivery($order, $uid)
    {
        $res1 = StoreOrder::gainUserIntegral($order);
        $res2 = User::backOrderBrokerage($order);
        StoreOrder::orderTakeAfter($order);
        //满赠优惠券
        WechatUser::userTakeOrderGiveCoupon($uid, $order['pay_price']);
        if (!($res1 && $res2)) exception('收货失败!');
    }

    /**
     * 修改状态 为已收货  admin模块
     * @param $order
     * @throws \Exception
     */
    public static function storeProductOrderTakeDeliveryAdmin($order)
    {
        $res1 = AdminStoreOrder::gainUserIntegral($order);
        $res2 = User::backOrderBrokerage($order);
        AdminStoreOrder::orderTakeAfter($order);
        //满赠优惠券
        WechatUser::userTakeOrderGiveCoupon($order['uid'], $order['pay_price']);
        UserBill::where('uid', $order['uid'])->where('link_id', $order['id'])->where('type', 'pay_money')->update(['take' => 1]);
        if (!($res1 && $res2)) exception('收货失败!');
    }

    /**
     * 修改状态 为已收货  定时任务使用
     * @param $order
     * @throws \Exception
     */
    public static function storeProductOrderTakeDeliveryTimer($order)
    {
        $res1 = AdminStoreOrder::gainUserIntegral($order, false);
        $res2 = User::backOrderBrokerage($order, false);
        AdminStoreOrder::orderTakeAfter($order);
        UserBill::where('uid', $order['uid'])->where('link_id', $order['id'])->where('type', 'pay_money')->update(['take' => 1]);
        if (!($res1 && $res2)) exception('收货失败!');
    }


    /**
     * 修改状态为  已退款  admin模块
     * @param $data
     * @param $oid
     * @return bool|mixed
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public static function storeProductOrderRefundY($data, $oid)
    {
        $order = AdminStoreOrder::where('id', $oid)->find();
        if ($order['is_channel'] == 1)
            return AdminStoreOrder::refundRoutineTemplate($oid); //TODO 小程序余额退款模板消息
        else
            return AdminStoreOrder::refundTemplate($data, $oid);//TODO 公众号余额退款模板消息
    }


    /**
     * TODO  后台余额退款
     * @param $product
     * @param $refund_data
     * @throws \Exception
     */
    public static function storeOrderYueRefund($product, $refund_data)
    {
        $res = AdminStoreOrder::integralBack($product['id']);
        if (!$res) exception('退积分失败!');
    }

    /**
     * 订单退积分
     * @param $product $product 商品信息
     * @param $back_integral $back_integral 退多少积分
     */
    public static function storeOrderIntegralBack($product, $back_integral)
    {

    }

}