ball/app/common/logic/ThirdOrderLogic.php

<?php
namespace app\common\logic;


use app\api\logic\LoginLogic;
use app\common\{enum\GoodsEnum,
    enum\PayEnum,
    enum\WorkEnum,
    model\goods\Goods,
    model\orders\RechargeOrder,
    model\recharge\OrderGoods,
    model\setting\PostageRegion,
    model\third\ThirdGoods,
    model\third\ThirdOrders,
    model\user\User,
    model\works\ServiceWork,
    model\works\ServiceWorkAppointmentLog,
    model\works\ServiceWorkLog};
use think\facade\Db;
use app\common\model\service_area\ServiceArea;

/**
 * 第三方平台下单逻辑层
 * Class UserLogic
 * @package app\shopapi\logic
 */
class ThirdOrderLogic extends BaseLogic
{

    protected  const user_token = [
        "accessToken"=>"V2-29d801e316e9ec4eb88b3b9abd8dbda490367af539d97d754420056dc5c1329a2c1aff7d4d54729ff622d96ff7c9910aa930f7b7ad27910d199c15029ffc71aa4a84142d75b60f4a34b71a8390a89d8c01a4dd385232e4e9c9204fb5934eda89",
        "expireIn"=> 2592000,
        "opBizCode"=> "AG5MALO18KG6I5DL8LVONRSRF5G",
        "opBizName"=> "武汉开源节流科技有限公司",
        "refreshToken"=> "ab8d15b4028b7bd6aca383d230b87450436d301a2996b6bb3151d668dd2d015d68d8393e66fb2a59aa10146c70dd30728b473358ec0d156dc0bc5cc5e574a109a5680ab49c393fa9d2693ef5519ff41a16115b81259b58c71a54d79e23f26381",
        "scope"=> "dingdan,generalreserve,merchantreceipt,shangpin"
    ];
    protected const shop_token1 = [
        "accessToken"=> "V2-9667b1ce4ffaabe453d4ce847888c788c9c61762df9230ab342caf33e2b4a735a384288379641f64bb2f4272c88d44db42b080ef237cb0c5e3ae49466d72f5c1b17e8a34991e131e91a24e9947f046027af6bbbbc24e0155f6cd4d738e19b5c0",
        "expireIn"=> 2592000,
        "opBizCode"=> "AH14KGRJ76O8PFH4GCO67F0CUKC",
        "opBizName"=> "众盾闪修 家电清洗 武汉",
        "refreshToken"=> "fd3da11174eed4c3d6b4d117f87ab7b62a72603627d2d597bed82dddb1036943b8e76e2959c0c4b3cf7b33ec4664bedbca3ef14dd070f662582a1b6695077577e2268c6a42ca519fda331c7e1cdbc0919af8052151ce9ae0a658d346307ca0c1",
        "scope"=> "merchantdata,poiqrcode,tuangou,ugc,yuding"
    ];
    protected const shop_token2 = [
        "accessToken"=> "V2-26f91ef8b515c59b97b9b4404e77dc2b2fc14b9715e3be7edb9f3f86178e193ec380e1ef5a9ab7a877120a94bcae4586707c51ab5e56cfeb4cd91d4fb2983babbbfd2fda0f77353eb21b105fd14299aea392a706589a422baec961b6cc255191",
        "expireIn"=> 2592000,
        "opBizCode"=> "AE7MKOJAV67338LIC3UD0K5TGIO",
        "opBizName"=> "众盾闪修 家电维修 武汉",
        "refreshToken"=> "bd57846c8817125f8ad7f4eb4ccad4af80c808f30c8b22e38476fc78c008b568ca8bcd8a027740023f2bcab5c0f6f062fb8a6e8f588cff53512a057c2e97a7b1789fb9fe9dc4b3fc2abf42dd753341c455e6eacb7a5e19dd4894bf1d93db9abf",
        "scope"=> "merchantdata,poiqrcode,tuangou,ugc,yuding"
    ];
    protected const developerId = 114657;

    protected const assessKey = '8471lgvnv0qcjpx6';


    /**
     * 处理订单
     * @param array $order
     * @return bool
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public static function orderhandle(array $order)
    {
        $message = json_decode($order['message'], true);
        //查询用户是否存在
        $userName = $message['userName'];
        $mobile = $message['mobile'];
        $userAddress = json_decode($message['userAddress']);
        $user = User::where(['mobile' =>$mobile])->findOrEmpty();
        $product_message = json_decode($message['products'],true);
        if($user->isEmpty()){
            $user = LoginLogic::register([
                'password'=>'123456',
                'account'=>$userName,
                'mobile'=>$mobile,
                'channel'=>1,
                'user_type'=>0
            ]);
        }

        //查询美团商品和平台商品的对应关系
        $productId = $message['productId'];
        $product = ThirdGoods::where(['third_type'=>1,'product_id'=>$productId])->findOrEmpty();

        //生成第三方订单信息
        $orderData = [
            'orderId'=>$message['orderId'],
            'uni_order_id'=>$product_message[0]['uni_order_id'],
            'productId'=>$message['productId'],
            'productName'=>$message['productName'],
            'request_msg'=>json_encode($order,JSON_UNESCAPED_UNICODE),
            'bookStatus'=>1,
            'third_type'=>1,//美团
        ];

        //判断美团的预约订单是否生成
        if(!$product->isEmpty()){
            //查询美团预约订单是否生成
            $thirdOrder = ThirdOrders::where(['uni_order_id'=>$product_message[0]['uni_order_id']])->findOrEmpty();
            if(!$thirdOrder->isEmpty() and $thirdOrder['work_id'] != 0){
                //生成第三方订单信息
                $orderData['sync_status'] = 1;
                $orderData['work_id'] = $thirdOrder['work_id'];
            }
        }
        $thirdOrders = ThirdOrders::where('orderId',$message['orderId'])->findOrEmpty();
        //生成未同步预约订单信息
        if($thirdOrders->isEmpty()){
            $thirdOrders = ThirdOrders::create($orderData);

        }
        if(!$thirdOrders->isEmpty()){
            $orderData['work_id'] = $thirdOrders->work_id;
        }
        if(empty($orderData['work_id']) and !$product->isEmpty() and !empty($product['goods_id'])){
            $goods = Goods::findOrEmpty($product['goods_id']);
            $pattern = '/(?:省|市)([\w\s]+市)/u';
            Db::startTrans();
            try {
                if (preg_match($pattern, $userAddress->receiver_address, $matches)) {
                    $city = $matches[1];
                }
                $area_city = PostageRegion::where(['level'=>2,'name'=>$city])->value('id');

                //生成服务工单
                $work_data = [
                    'work_sn' => generate_sn(ServiceWork::class, 'work_sn'),
                    'real_name' => $userName,
                    'mobile' => $mobile,
                    'address' => $userAddress->receiver_address,
                    'province' => 0,
                    'city' => $area_city??0,
                    'area_name' => $userAddress->receiver_address,
                    'title' => $goods->goods_name,
                    'category_type' => $goods['category_type'],
                    'goods_category_ids' => $goods['goods_category_ids'],
                    'goods_category_id' => $goods['goods_category_id'],
                    'base_service_fee' => $goods['base_service_fee'],
                    'service_fee' => $product['product_price'],
                    'work_pay_status'=>WorkEnum::IS_PAY_STATUS,
                    'appointment_time' => strtotime($message['begintime']),
                    'user_id'=>$user['id'],
                    'lon'=>!empty($userAddress->longitude)?$userAddress->longitude:0,
                    'lat'=>!empty($userAddress->latitude)?$userAddress->latitude:0,
                    'property_activity_id'=>0,
                    'user_equity_id'=>0,
                    'third_type'=>1,
                    'work_total'=>$product['product_price'],
                    'work_amount'=>$product['product_price']
                ];
                $service_area_id = ServiceArea::serviceAreaId(['lon' => $work_data['lon'], 'lat' => $work_data['lat']]);
                $work_data['service_area_id'] = $service_area_id;
                $service_work = ServiceWork::create($work_data);

                //生成服务订单
                $data = [
                    'work_id'=> $service_work['id'],
                    'sn' => generate_sn(RechargeOrder::class, 'sn'),
                    'order_type'=>0,//服务订单
                    'order_terminal' => 1,
                    'payment_type'=>$goods['goods_payment_type']==GoodsEnum::ISGOODS_PAYMENT_TYPE?0:1,
                    'user_id' => $user['id'],
                    'pay_status' => PayEnum::ISPAID,
                    'coupon_id'=>0,
                    'coupon_price'=>0,
                    'pay_way' => 4,
                    'order_total' => $product['product_price'],
                    'order_amount' => $product['product_price'],
                    'paid_amount'=> $product['product_price'],
                ];
                $order = RechargeOrder::create($data);
                //生成订单服务详情
                OrderGoods::create([
                    'sn' => $order['sn'],
                    'goods_id' => $goods['id'],
                    'category_type' => $goods['category_type'],
                    'goods_category_ids' => $goods['goods_category_ids'],
                    'goods_category_id' => $goods['goods_category_id'],
                    'goods_name' => $goods['goods_name'],
                    'goods_image' => $goods['goods_image'],
                    'goods_video' => $goods['goods_video'],
                    'goods_number' => $goods['goods_number'],
                    'good_unit' => $goods['good_unit'],
                    'goods_size' => $goods['goods_size'],
                    'goods_type' => $goods['goods_type'],
                    'goods_brand' => $goods['goods_brand'],
                    'install_guide' => $goods['install_guide'],
                    'goods_payment_type'=>$goods['goods_payment_type'],
                    'base_service_fee' => $goods['base_service_fee'],
                    'service_total' => $goods['service_total'],
                    'service_fee' => $product['product_price'],
                    'service_image' => $goods['service_image'],
                    'warranty_period'=>$goods['warranty_period'],
                    'fee_schedule' => $goods['fee_schedule'],
                    'goods_status' => $goods['goods_status'],
                ]);

                //判断是否是一口价预支付订单，支付成功后生成尾款订单
                if(!$goods->isEmpty() and $goods->goods_payment_type == 3 and bcsub($goods->base_service_fee,$goods->service_fee,2)>=0){
                    //新增待支付尾款
                    $order_weikuan_data = [
                        'order_type'=>$order['order_type'],
                        'sn'=>generate_sn(\app\common\model\orders\RechargeOrder::class, 'sn'),
                        'work_id'=>$order['work_id'],
                        'user_id'=>$order['user_id'],
                        'payment_type'=>2,
                        'order_total'=>bcsub($goods->base_service_fee,$product['product_price'],2),
                        'order_amount'=>bcsub($goods->base_service_fee,$product['product_price'],2),
                        'order_terminal'=>$order['order_terminal']
                    ];
                    \app\common\model\recharge\RechargeOrder::create($order_weikuan_data);
                }

                $thirdOrders->work_id = $service_work->id;
                $thirdOrders->save();

                self::bookresultcallback($order['opBizCode'],$message['orderId'],2);
                Db::commit();
            } catch (\Exception $e) {
                Db::rollback();
                self::setError($e->getMessage());
                return false;
            }
        }
        return true;
    }


    //手动添加订单
    public static function submitOrders(array $message)
    {
        //查询用户是否存在
        $userName = $message['userName'];
        $mobile = $message['mobile'];
        $user = User::where(['mobile' =>$mobile])->findOrEmpty();
        if($user->isEmpty()){
            $user = LoginLogic::register([
                'password'=>'123456',
                'account'=>$userName,
                'mobile'=>$mobile,
                'channel'=>1,
                'user_type'=>0,
            ]);
        }
        $goods = Goods::findOrEmpty($message['goods_id']);
        $pattern = '/(?:省|市)([\w\s]+市)/u';
        Db::startTrans();
        try {
            if (preg_match($pattern, $message['userAddress'], $matches)) {
                $city = $matches[1];
            }
            $area_city = PostageRegion::where(['level'=>2,'name'=>$city])->value('id');

            //生成服务工单
            $work_data = [
                'work_sn' => generate_sn(ServiceWork::class, 'work_sn'),
                'real_name' => $userName,
                'mobile' => $mobile,
                'address' => $message['userAddress'],
                'province' => 0,
                'city' => $area_city??0,
                'area_name' => $area_city??'',
                'title' => $goods->goods_name,
                'category_type' => $goods['category_type'],
                'goods_category_ids' => $goods['goods_category_ids'],
                'goods_category_id' => $goods['goods_category_id'],
                'base_service_fee' => $goods['base_service_fee'],
                'service_fee' => $message['amount'],
                'work_pay_status'=>WorkEnum::IS_PAY_STATUS,
                'appointment_time' => strtotime($message['appointment_time']),
                'user_id'=>$user['id'],
                'lon'=>$message['lon'],
                'lat'=>$message['lat'],
                'property_activity_id'=>0,
                'user_equity_id'=>0,
                'third_type'=>1,
                'work_total'=>$goods['base_service_fee'],
                'work_amount'=>$goods['base_service_fee']
            ];
            $service_area_id = ServiceArea::serviceAreaId(['lon' => $work_data['lon'], 'lat' => $work_data['lat']]);
            $work_data['service_area_id'] = $service_area_id;
            $service_work = ServiceWork::create($work_data);

            //生成服务订单
            $data = [
                'work_id'=> $service_work['id'],
                'sn' => generate_sn(RechargeOrder::class, 'sn'),
                'order_type'=>0,//服务订单
                'order_terminal' => 1,
                'payment_type'=>$goods['goods_payment_type']==GoodsEnum::ISGOODS_PAYMENT_TYPE?0:1,
                'user_id' => $user['id'],
                'pay_status' => PayEnum::ISPAID,
                'coupon_id'=>0,
                'coupon_price'=>0,
                'pay_way' => 4,
                'order_total' => $message['amount'],
                'order_amount' => $message['amount'],
                'paid_amount'=>$message['amount']
            ];
            $order = RechargeOrder::create($data);
            //生成订单服务详情
            OrderGoods::create([
                'sn' => $order['sn'],
                'goods_id' => $goods['id'],
                'category_type' => $goods['category_type'],
                'goods_category_ids' => $goods['goods_category_ids'],
                'goods_category_id' => $goods['goods_category_id'],
                'goods_name' => $goods['goods_name'],
                'goods_image' => $goods['goods_image'],
                'goods_video' => $goods['goods_video'],
                'goods_number' => $goods['goods_number'],
                'good_unit' => $goods['good_unit'],
                'goods_size' => $goods['goods_size'],
                'goods_type' => $goods['goods_type'],
                'goods_brand' => $goods['goods_brand'],
                'install_guide' => $goods['install_guide'],
                'goods_payment_type'=>$goods['goods_payment_type'],
                'base_service_fee' => $goods['base_service_fee'],
                'service_total' => $goods['service_total'],
                'service_fee' => $message['amount'],
                'service_image' => $goods['service_image'],
                'warranty_period'=>$goods['warranty_period'],
                'fee_schedule' => $goods['fee_schedule'],
                'goods_status' => $goods['goods_status'],
            ]);

            //判断是否是一口价预支付订单，支付成功后生成尾款订单
            if(!$goods->isEmpty() and $goods->goods_payment_type == 3 and bcsub($goods->base_service_fee,$goods->service_fee,2)>=0){
                //新增待支付尾款
                $order_weikuan_data = [
                    'order_type'=>$order['order_type'],
                    'sn'=>generate_sn(\app\common\model\orders\RechargeOrder::class, 'sn'),
                    'work_id'=>$order['work_id'],
                    'user_id'=>$order['user_id'],
                    'payment_type'=>2,
                    'order_total'=>bcsub($goods->base_service_fee,$message['amount'],2),
                    'order_amount'=>bcsub($goods->base_service_fee,$message['amount'],2),
                    'order_terminal'=>$order['order_terminal']
                ];
                \app\common\model\recharge\RechargeOrder::create($order_weikuan_data);
            }
            Db::commit();
        } catch (\Exception $e) {
            Db::rollback();
            self::setError($e->getMessage());
            return false;
        }
        return true;
    }

    public static function get_sign($sign_key, $data)
    {
        if ($data == null) {
            return null;
        }
        ksort($data);
        $result_str = "";
        foreach ($data as $key => $val) {
            if ($key != "sign" && $val != null && $val != "") {
                $result_str = $result_str . $key . $val;
            }
        }
        $result_str = $sign_key . $result_str;


        $ret = bin2hex(sha1($result_str, true));

        return $ret;
    }


    /**
     * 商家接单接口
     * @param $orderId
     * @param $bookStatus
     * @return string
     */
    public static function bookresultcallback($opBizCode,$orderId,$bookStatus=2)
    {
        //预订结果，2-预订成功，3-预订失败
        $url = 'https://api-open-cater.meituan.com/ddzh/yuding/bookresultcallback';
        $accessToken = $opBizCode == 'AE7MKOJAV67338LIC3UD0K5TGIO' ? self::shop_token2['accessToken'] : self::shop_token1['accessToken'];
        $data = [
            'timestamp'=>time(),
            'appAuthToken'=>$accessToken,
            'charset'=>'utf-8',
            'version'=>'2',
            'developerId'=>self::developerId,
            'businessId'=>58,
            'biz'=>json_encode([
                'orderId'=>$orderId,
                'bookStatus'=>$bookStatus,
                "code"=>200,
                "type"=>2
            ],JSON_UNESCAPED_UNICODE)
        ];
        $sign_data = self::get_sign(self::assessKey, $data);
        $data['sign'] = $sign_data;
        return http_request($url,http_build_query($data));
    }

    /**
     * 取消预订
     * @param array
     * $order
     * @return bool
     */
    public static function cancelOrderHandle(array $order)
    {
        $message = json_decode($order['message'], true);
        Db::startTrans();
        try {
            $thirdOrders = ThirdOrders::where('orderId',$message['orderId'])->findOrEmpty();
            if(!$thirdOrders->isEmpty()){
                $thirdOrders->bookStatus = 3;
                $thirdOrders->save();
                $serviceWorkInfo = ServiceWork::find($thirdOrders->work_id);
                if(!empty($serviceWorkInfo)){
                    $appointment_time = '2099-12-31 23:59:59';
                    ServiceWorkAppointmentLog::create([
                        'work_id'=>$serviceWorkInfo->id,
                        'last_appointment_time'=>strtotime($serviceWorkInfo->appointment_time),
                        'this_appointment_time'=>strtotime($appointment_time),
                    ]);
                    //修改预计完成时间
                    if ($serviceWorkInfo->estimated_finish_time) {
                        $serviceWorkInfo->estimated_finish_time = strtotime($appointment_time) + (strtotime($serviceWorkInfo->estimated_finish_time) - strtotime($serviceWorkInfo->appointment_time));
                    }
                    $serviceWorkInfo->appointment_time = strtotime($appointment_time);
                    $serviceWorkInfo->save();
                }
            }
            Db::commit();
            return true;
        } catch (\Exception $e) {
            Db::rollback();
            self::setError($e->getMessage());
            return false;
        }
    }

    /**
     * 美团改约通知
     * @param array $order
     * @return bool
     */
    public static function updateOrderHandle(array $order)
    {
        $message = json_decode($order['message'], true);
        Db::startTrans();
        try {
            $thirdOrders = ThirdOrders::where('orderId',$message['orderId'])->findOrEmpty();
            if(!$thirdOrders->isEmpty()){
                $thirdOrders->bookStatus = 2;
                $thirdOrders->save();
                $serviceWorkInfo = ServiceWork::find($thirdOrders->work_id);
                if(!empty($serviceWorkInfo)){
                    $appointment_time = $message['reserveEndtime'];
                    ServiceWorkAppointmentLog::create([
                        'work_id'=>$serviceWorkInfo->id,
                        'last_appointment_time'=>strtotime($serviceWorkInfo->appointment_time),
                        'this_appointment_time'=>strtotime($appointment_time),
                    ]);
                    //修改预计完成时间
                    if ($serviceWorkInfo->estimated_finish_time) {
                        $serviceWorkInfo->estimated_finish_time = strtotime($appointment_time) + (strtotime($serviceWorkInfo->estimated_finish_time) - strtotime($serviceWorkInfo->appointment_time));
                    }
                    $serviceWorkInfo->appointment_time = strtotime($appointment_time);
                    $serviceWorkInfo->save();
                }
            }
            Db::commit();
            return true;
        } catch (\Exception $e) {
            Db::rollback();
            self::setError($e->getMessage());
            return false;
        }
    }

    /**
     * 获取美团商品信息
     * @param $offset
     * @return string
     */
    public static function queryshopdeal($offset=1)
    {
        $url = 'https://api-open-cater.meituan.com/ddzh/tuangou/deal/queryshopdeal';
        $data = [
            'timestamp'=>time(),
            'appAuthToken'=>self::shop_token2['accessToken'],
            'charset'=>'utf-8',
            'version'=>'2',
            'developerId'=>self::developerId,
            'businessId'=>58,
            'biz'=>json_encode([
                'offset'=>$offset,
                'limit'=>100,
                "source"=>2,
            ],JSON_UNESCAPED_UNICODE)
        ];
        $sign_data = self::get_sign(self::assessKey, $data);
        $data['sign'] = $sign_data;
        return http_request($url,http_build_query($data));
    }

    /**
     * 获取美团商品信息
     * @param $offset
     * @return string
     */
    public static function queryshopdeal1($offset=1)
    {
        $url = 'https://api-open-cater.meituan.com/ddzh/tuangou/deal/queryshopdeal';
        $data = [
            'timestamp'=>time(),
            'appAuthToken'=>self::shop_token1['accessToken'],
            'charset'=>'utf-8',
            'version'=>'2',
            'developerId'=>self::developerId,
            'businessId'=>58,
            'biz'=>json_encode([
                'offset'=>$offset,
                'limit'=>100,
                "source"=>2,
            ],JSON_UNESCAPED_UNICODE)
        ];
        $sign_data = self::get_sign(self::assessKey, $data);
        $data['sign'] = $sign_data;
        return http_request($url,http_build_query($data));
    }

    /**
     * 商家改约
     * @param $offset
     * @return string
     */
    public static function merchantmodify($data)
    {
        $url = 'https://api-open-cater.meituan.com/ddzh/yuding/lifereserve/merchantmodify';
        $opBizCode = !empty($data['request_msg'])?json_decode($data['request_msg'],true)['opBizCode']:'';
        $accessToken = $opBizCode == 'AE7MKOJAV67338LIC3UD0K5TGIO' ? self::shop_token2['accessToken'] : self::shop_token1['accessToken'];
        $data = [
            'timestamp'=>time(),
            'appAuthToken'=>$accessToken,
            'charset'=>'utf-8',
            'version'=>'2',
            'developerId'=>self::developerId,
            'businessId'=>58,
            'biz'=>json_encode([
                'reserveOrderId'=>$data['reserveOrderId'],
                'reserveUserName'=>$data['reserveUserName'],
                "reservePhone"=>$data['reservePhone'],
                "reserveAddress"=>$data['reserveAddress'],
                "bookStartTime"=>$data['bookStartTime'],
                "bookEndTime"=>$data['bookEndTime'],
            ],JSON_UNESCAPED_UNICODE)
        ];
        $sign_data = self::get_sign(self::assessKey, $data);
        $data['sign'] = $sign_data;
        return http_request($url,http_build_query($data));
    }

    /**
     * 商家取消预定
     * @param $params
     * @return string|true
     */
    public static function merchantcancelorder($work_id)
    {
        $third_order = ThirdOrders::where('work_id',$work_id)->findOrEmpty();
        if(!$third_order->isEmpty() && !empty($third_order['request_msg'])){
            $third_order->bookStatus = 3;
            $third_order->save();
            $url = 'https://api-open-cater.meituan.com/ddzh/yuding/merchantcancelorder';
            $opBizCode = !empty($third_order['request_msg'])?json_decode($third_order['request_msg'],true)['opBizCode']:'';
            $accessToken = $opBizCode == 'AE7MKOJAV67338LIC3UD0K5TGIO' ? self::shop_token2['accessToken'] : self::shop_token1['accessToken'];
            $data = [
                'timestamp'=>time(),
                'appAuthToken'=>$accessToken,
                'charset'=>'utf-8',
                'version'=>'2',
                'developerId'=>self::developerId,
                'businessId'=>58,
                'biz'=>json_encode([
                    'orderId'=>$third_order['orderId'],
                    'cancelReason'=>'取消预定',
                    "type"=>2,
                ],JSON_UNESCAPED_UNICODE)
            ];
            $sign_data = self::get_sign(self::assessKey, $data);
            $data['sign'] = $sign_data;
            return http_request($url,http_build_query($data));
        }
        return true;


    }

}