xyzshop/admin/control/refill_order_manual.php

<?php
require_once(BASE_HELPER_PATH . '/refill/util.php');
require_once(BASE_HELPER_PATH . '/algorithm.php');

use refill\util;

class refill_order_manualControl extends SystemControl
{
    public function __construct()
    {
        parent::__construct();
    }

    public function indexOp()
    {
        $model_refill_order = Model('refill_order');
        $condition['inner_status'] = 0;
        $order_list = [];
        if (!empty($_GET['order_sn'])) {
            $condition['refill_order.order_sn'] = $_GET['order_sn'];
            $merchant_list = $this->merchants();
            $order_list = $model_refill_order->getMerchantOrderList($condition, 50,0, 'refill_order.*,vr_order.order_state', 'refill_order.order_time desc','',true);
            $order_list = $this->OrderDataFormat($order_list, $merchant_list);
        }
        Tpl::output('order_list', $order_list);
        Tpl::showpage('refill.order.manual.index');
    }

    public function notify_manual_merchantOp()
    {
        $order_id = $_GET['order_id'];
        $type = $_GET['type'];

        $mod_order = Model('vr_order');
        $order_info = $mod_order->getOrderInfo(['order_id' => $order_id]);
        $mod_refill = Model('refill_order');
        $refill_info = Model('refill_order')->getOrderInfo(['order_id' => $order_id,'inner_status' => 0,'is_retrying' => 0]);
        if(empty($refill_info) || empty($order_info)) {
            showMessage('订单不存在，或不符合条件', '');
        }
        $fetch_order_ids = $this->check_fetch_order($order_id);
        if (in_array($order_id, $fetch_order_ids)) {
            showMessage('此订单不可手动操作，请联系抢单人员操作！');
        }
        $logic_vr_order = Logic("vr_order");
        if ($type == 'success') {
            $logic_vr_order->changeOrderStateSuccess($order_id,true);
        } elseif ($type == 'cancel') {
            $logic_vr_order->changeOrderStateCancel($order_info, '', "充值失败", true, true);
        } else {
            showMessage('手动操作类型错误', 'index.php?act=refill_order&op=index');
        }
        $this->manual_record([$refill_info], $type, $order_id, '手动强制处理');
        if($refill_info['notify_time'] == 0) {
            $mod_refill->edit($order_id, ['notify_state' =>1, 'notify_time' => time()]);
        }
        util::pop_queue_order($refill_info['mchid'],$refill_info['mch_order']);
        QueueClient::push("NotifyMerchantComplete", ['order_id' => $order_id, 'manual' => true]);

        showMessage('操作成功');
    }

    public function refill_order_batchOp()
    {
        $model_refill_order = Model('refill_order');
        $condition = [];
        $orders = [];
        $_GET['query_start_time'] = $_GET['query_start_time'] ?? date("Y-m-d 00:00:00");
        if (in_array($_GET['order_state'], ['0', '10', '20', '30', '40']))
        {
            $condition['vr_order.order_state'] = $_GET['order_state'];
        }
        if (!empty($_GET['mchid'])) {
            $condition['refill_order.mchid'] = $_GET['mchid'];
        }
        if (!empty($_GET['store_id'])) {
            $condition['vr_order.store_id'] = $_GET['store_id'];
        }
        //批量查询，二者都有，以卡号为主
        if(!empty($_GET['card_nos'])) {
            $card_nos = trim($_GET['card_nos'], ',');
            $condition['refill_order.card_no'] = ['in', $card_nos];
        } elseif (!empty($_GET['mch_orders'])) {
            $mch_orders = rtrim($_GET['mch_orders'], ',');
            $condition['refill_order.mch_order'] = ['in', $mch_orders];
        }
        if(!empty($_GET['order_sns'])) {
            $order_sns = trim($_GET['order_sns'], ',');
            $condition['refill_order.order_sn'] = ['in', $order_sns];
        }
        if (!empty($_GET['card_type'])) {
            if (in_array($_GET['card_type'], ['1', '2', '4', '5', '6', '7'])) {
                $condition['refill_order.card_type'] = intval($_GET['card_type']);
            }
        }
        $merchant_list = $this->merchants();
        $provider_list = $this->providers();
        if(!empty($condition)) {
            $condition['refill_order.inner_status'] = 0;
            $start_unixtime = intval(strtotime($_GET['query_start_time']));
            $end_unixtime = intval(strtotime($_GET['query_end_time']));

            if ($start_unixtime > 0 && $end_unixtime > $start_unixtime) {
                $condition['refill_order.order_time'] = [['egt', $start_unixtime], ['lt', $end_unixtime], 'and'];
                $condition['vr_order.add_time'] = [['egt', $start_unixtime],['lt', $end_unixtime], 'and'];
            } elseif ($start_unixtime > 0) {
                $condition['refill_order.order_time'] = ['egt', $start_unixtime];
                $condition['vr_order.add_time'] = ['egt', $start_unixtime];
            } elseif ($end_unixtime > 0) {
                $condition['refill_order.order_time'] = ['lt', $end_unixtime];
            } else {
                $start = strtotime(date('Y-m-d', time()));
                $condition['refill_order.order_time'] = ['egt', $start];
                $condition['vr_order.add_time'] = ['egt', $start];
            }

            $orders = $model_refill_order->getMerchantOrderList($condition, 400, 0,'refill_order.*,vr_order.order_state', 'refill_order.channel_name DESC ');
            $orders = $this->OrderDataFormat($orders, $merchant_list);
            $order_ids = array_column($orders,'order_id');
            $order_ids = $this->unique_array($order_ids);

            $refill_buyback_model = Model('refill_buyback');
            $buybacks = $refill_buyback_model->getList(['order_id' => ['in',$order_ids], 'manual_type' => 'buyback']);
            $buyback_ids = array_column($buybacks, 'order_id');
            $buyback_ids = $this->int_array($buyback_ids);
            $buyback_ids = $this->unique_array($buyback_ids);

            foreach ($orders as $key => $order)
            {
                if($order['order_state'] != ORDER_STATE_SUCCESS) {
                    $order[$key]['buyback'] = false;
                    continue;
                }
                $order_id = intval($order['order_id']);
                if(algorithm::binary_search($buyback_ids,$order_id)) {
                    $orders[$key]['buyback'] = true;
                }else{
                    $orders[$key]['buyback'] = false;
                }
            }
        }
        Tpl::output('merchant_list', $merchant_list);
        Tpl::output('provider_list', $provider_list);
        Tpl::output('order_list', $orders);
        Tpl::output('show_page', $model_refill_order->showpage());
        Tpl::showpage('refill.order.batch');
    }

    public function refill_order_batch_disposeOp()
    {
        $oid_reader = function ($sids) {
            $sids = explode(',',$sids);
            $ids = $this->int_array($sids);
            return $this->unique_array($ids);
        };

        $oper_type = $_GET['type'];
        $order_ids = $oid_reader($_GET['order_id']);

        $cond = [];
        $cond['refill_order.order_id'] = ['in',$order_ids];
        $cond['refill_order.is_retrying'] = 0;

        if ($oper_type == 'success' || $oper_type == 'cancel') {
            $cond['vr_order.order_state'] = ORDER_STATE_SEND;
        } elseif ($oper_type == 'buyback') {
            $cond['vr_order.order_state'] = ORDER_STATE_SUCCESS;
        }

        $model_refill_order = Model('refill_order');
        $orders = $model_refill_order->getMerchantOrderList($cond,'',0,'refill_order.*,vr_order.order_state,vr_order.buyer_id,vr_order.store_id','refill_order.order_id desc',2000);
        if(empty($orders)) {
            showMessage('操作数据为空');
        }
        if($oper_type == 'notify')
        {
            foreach ($orders as $order) {
                if ($order['order_state'] == ORDER_STATE_SEND) {
                    QueueClient::push("QueryRefillState", ['order_id' => $order['order_id']]);
                } else {
                    QueueClient::push("NotifyMerchantComplete", ['order_id' => $order['order_id'], 'manual' => true]);
                }
            }
        }
        elseif(in_array($oper_type, ['success', 'cancel', 'buyback']))
        {
            $res = $this->manual_record($orders, $oper_type, $order_ids, $_GET['bz']);
            if($res == false) {
                showMessage('操作失败');
            }
        }
        else
        {
            showMessage('手动操作类型错误');
        }
        showMessage('操作成功');
    }

    private function manual_record($orders, $oper_type, $order_ids, $bz)
    {
        $admininfo = $this->getAdminInfo();
        $bz = empty($bz) ? '' : $bz;

        $refill_buyback_model = Model('refill_buyback');
        $buybacks = $refill_buyback_model->getList(['order_id' => ['in',$order_ids], 'manual_type' => $oper_type]);
        $buyback_ids = array_column($buybacks, 'order_id');
        $buyback_ids = $this->int_array($buyback_ids);
        $buyback_ids = $this->unique_array($buyback_ids);

        if($oper_type == 'buyback') {
            $mchids = array_column($orders, 'mchid');
            $mchids = $this->unique_array($mchids);
            $merchant_list = $this->merchants(['mchid' => ['in', $mchids]]);
            foreach ($merchant_list as $merchant) {
                $merchants[$merchant['mchid']] = $merchant;
            }
            $store_ids = array_column($orders, 'store_id');
            $store_ids = $this->unique_array($store_ids);
            $provider_list = $this->providers(['refill_provider.store_id' => ['in', $store_ids]]);
            foreach ($provider_list as $provider) {
                $providers[$provider['store_id']] = $provider;
            }
        }

        $cur_time = time();
        $trans = new trans_wapper($refill_buyback_model, __METHOD__);
        try {
            foreach ($orders as $order) {
                $order_id = intval($order['order_id']);
                //已经找到相同类型的操作记录,不处理.
                if(algorithm::binary_search($buyback_ids,$order_id)) continue;

                if($oper_type == 'buyback')
                {
                    $mchid = $order['mchid'];
                    $merchant_info = $merchants[$mchid];
                    $buyer_id = $order['buyer_id'];
                    if(empty($mchid) || empty($buyer_id)) {
                        Log::record("refill order manual merchant err order_id:{$order_id}, order_sn:{$order['order_sn']}");
                        $trans->rollback();
                        showMessage('机构数据获取失败！');
                    }
                    $merchant_bz = "机构:{$mchid},订单号:{$order['mch_order']},卡号:{$order['card_no']},返销退款:{$order['mch_amount']}";
                    $this->ct_refill_evidence(['mch_amount' => $order['mch_amount'], 'bz' => $merchant_bz], $merchant_info, $cur_time, $admininfo);
                    $this->credit_save_money($order['mch_amount'], 'add', $buyer_id, $merchant_bz);

                    $store_id = $order['store_id'];
                    $provider_info = $providers[$store_id];
                    $account_id = $provider_info['account_id'];
                    if(empty($store_id) || empty($account_id)) {
                        Log::record("refill order manual provider err order_id:{$order_id}, order_sn:{$order['order_sn']}");
                        $trans->rollback();
                        showMessage('通道数据获取失败！');
                    }
                    $provider_bz = "通道:{$store_id},椰子单号:{$order['order_sn']},卡号:{$order['card_no']},返销退款:{$order['channel_amount']}";
                    $this->ct_provider_amount(['channel_amount' => $order['channel_amount']], $provider_info, $cur_time, $admininfo);
                    $this->credit_save_money($order['channel_amount'], 'add', $account_id, $provider_bz);
                }
                elseif ($oper_type == 'success')
                {
                    $fetch_order_ids = $this->check_fetch_order($order_ids);
                    $fetch_order_ids = $this->unique_array($fetch_order_ids);
                    if(algorithm::binary_search($fetch_order_ids,$order_id)) continue;
                    refill\util::manual_success($order_id);
                    if(empty($bz)) {
                        $bz = "批量处理页面，手动成功处理，操作人:{$admininfo['name']}";
                    }
                }
                elseif ($oper_type == 'cancel')
                {
                    $fetch_order_ids = $this->check_fetch_order($order_ids);
                    $fetch_order_ids = $this->unique_array($fetch_order_ids);
                    if(algorithm::binary_search($fetch_order_ids,$order_id)) continue;
                    refill\util::manual_cancel($order_id);
                    if(empty($bz)) {
                        $bz = "批量处理页面，手动失败处理，操作人:{$admininfo['name']}";
                    }
                }
                $ins[] = [
                    'order_id' => $order['order_id'], 'order_sn' => $order['order_sn'],'order_time' => $order['order_time'], 'notify_time' => $order['notify_time'],
                    'manual_type' => $oper_type, 'admin_id' => $admininfo['id'], 'admin_name' => $admininfo['name'], 'act_time' => $cur_time, 'bz' => $bz
                ];
            }
            if(!empty($ins)) {
                $refill_buyback_model->insertAll($ins);
            }
            $trans->commit();
            return true;
        }catch (Exception $e){
            $trans->rollback();
            Log::record("manual_record err: {$e->getMessage()}", Log::ERR);
            return false;
        }
    }

    public function set_cancel_orderOp()
    {
        $mod = Model('refill_order');
        $condition = [];
        $order_list = [];
        $mch_orderData = [];
        if(!empty($_GET['mchid'])) {
            $condition['mchid'] = $_GET['mchid'];
        }
        if (!empty($_GET['mch_orders'])) {
            $mch_orders = rtrim($_GET['mch_orders'],',');
            $condition['mch_order'] = ['in', $mch_orders];

        }
        $merchant_list = $this->merchants();
        if(!empty($condition)) {
            $condition['inner_status'] = 0;
            $order_list = $mod->getMerchantOrderList($condition, 200, 0,'refill_order.*,vr_order.order_state', 'refill_order.order_time desc');
            $order_list = $this->OrderDataFormat($order_list, $merchant_list);
            if(empty($mch_orders)) {
                $mch_orderData = [];
            }else{
                $mch_orderData = explode(',',$mch_orders);
            }
            foreach ($order_list as $order_id => $order) {
                $mch_order = $order['mch_order'];
                if(in_array($mch_order, $mch_orderData)) {
                    $key = array_search($mch_order, $mch_orderData);
                    unset($mch_orderData[$key]);
                }
                $order_list[$order_id]['can_cancel'] = $this->can_cancel_order($order);
            }
        }
        Tpl::output('noexist_mch_order', $mch_orderData);
        Tpl::output('merchant_list', $merchant_list);
        Tpl::output('list', $order_list);
        Tpl::output('show_page', $mod->showpage());
        Tpl::showpage('set.cancel.order');
    }

    public function order_cancel_disposeOp()
    {
        $order_id = $_GET['order_id'];
        $condition['refill_order.order_id'] = ['in',$order_id];

        $order_list = Model('refill_order')->getMerchantOrderList($condition,1000,0,'refill_order.*,vr_order.order_state');
        foreach ($order_list as $order) {
            if($this->can_cancel_order($order)) {
                $mchid = $order['mchid'];
                $mch_order = $order['mch_order'];
                refill\util::set_cancel_order($mchid,$mch_order);
                $this->log("拦截订单，订单号:{$order['order_sn']}，商家单号:{$mch_order}，机构编码:{$mchid}", 1);
            }
        }
        showMessage('操作成功');
    }

    private function can_cancel_order($order): bool
    {
        if($order['order_state'] == ORDER_STATE_SUCCESS) {
            return false;
        }
        if($order['order_state'] == ORDER_STATE_CANCEL && $order['is_retrying'] == 0) {
            return false;
        }
        return true;
    }

    public function refill_buybackOp()
    {
        $model_refill_order = Model('refill_order');
        $order_list = [];
        if(!empty($_GET['card_nos'])) {
            $card_nos = trim($_GET['card_nos'], ',');
            $condition['refill_order.card_no'] = ['in', $card_nos];
        }
        if(!empty($_GET['order_sns'])) {
            $order_sns = trim($_GET['order_sns'], ',');
            $condition['refill_order.order_sn'] = ['in', $order_sns];
        }
        if(!empty($condition)) {
            $condition['inner_status'] = 0;
            $merchant_list = $this->merchants();
            $order_list = $model_refill_order->getBuyBackList($condition, 50, 'refill_buyback.*,refill_order.*,vr_order.order_state', 'refill_order.order_time desc','',true);
            $order_list = $this->OrderDataFormat($order_list, $merchant_list);
        }
        Tpl::output('order_list', $order_list);
        Tpl::showpage('refill.buyback.order');
    }

    private function int_array($sids): array
    {
        $result = [];
        foreach ($sids as $sid) {
            $result[] = intval($sid);
        }

        return $result;
    }

    private function unique_array($ids): array
    {
        $ids = array_unique($ids);
        sort($ids);
        return $ids;
    }

    private function ct_provider_amount($params, $provider_info, $cur_time, $admininfo)
    {
        $input['provider_id'] = $provider_info['provider_id'];
        $input['memeber_id'] = $provider_info['account_id'];
        $input['amount'] = $params['channel_amount'];
        $input['operation'] = $admininfo['name'];
        $input['add_time'] = $cur_time;

        return Model('provider_amount')->addAmount($input);
    }

    private function ct_refill_evidence($params, $merchant_info, $cur_time, $admininfo)
    {
        $mem_info = Model('member')->getMemberInfo(['member_id' => $merchant_info['admin_id']], '*', true);

        $input['mchid'] = $merchant_info['mchid'];
        $input['mch_name'] = $merchant_info['name'];
        $input['member_id'] = $merchant_info['admin_id'];
        $input['amount'] = $params['mch_amount'];
        $input['bank_username'] = '椰子';
        $input['bank_name'] = '椰子退款';
        $input['bz'] = $params['bz'];
        $input['voucher_name'] = '/';
        $input['status'] = 2;
        $input['is_operation'] = 2;
        $input['add_time'] = $input['check_time'] = $cur_time;
        $input['after_available'] = ncPriceFormat($mem_info['available_predeposit'] + $params['mch_amount']);
        $input['admin_name'] = $admininfo['name'];
        $input['admin_id'] = $admininfo['id'];
        $input['add_type'] = 3;

        return Model('merchant')->addRefillEvidence($input);
    }
}