<?php
/**
 * Copyright 2012-2026 ShopeX (https://www.shopex.cn)
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

class wap_ctl_logistics extends wap_controller
{
    function __construct($app)
    {
        parent::__construct($app);
    }

    /**
     * 获取运单号
     * @return void
     */
    public function getWaybillNumber()
    {
        if (empty($_POST['delivery_id'])) {
            $this->error('发货单ID参数不能为空');
        }

        $params = [
            'delivery_id' => $_POST['delivery_id'],
            'logi_code' => $_POST['logi_code'],              // 物流公司编码
            'monthly_account' => $_POST['monthly_account'],  // 月结账号， 如果值是default 则默认是小镇月结账号
            'product_type' => $_POST['product_type'],        // 产品类型 0  表示使用默认的产品类型
        ];

        $delivery = app::get('wap')->model('delivery')->dump(array('delivery_id' => $_POST['delivery_id']), 'order_bn,shop_id,shop_type');
        if (!$delivery['shop_type']) {
            $shop = app::get('ome')->model('shop')->dump(array('shop_id'=>$delivery['shop_id']), 'shop_type');
            $shop_type = $shop['shop_type'];
        } else {
            $shop_type = $delivery['shop_type'];
        }

        $params['product_type'] = kernel::single('logisticsmanager_waybill_func')->getCorpProductType($shop_type, $_POST['logi_code'], $_POST['product_type']);

        $result = kernel::single('wap_event_trigger_logistics')->getWaybill($params);
        if ($result['rsp'] == 'fail' || $result['res'] == 'fail') {
            $this->error($result['msg']);
        }
        $this->success('success', $result['data']);
    }

    /**
     * 打印快递单号
     * @return void
     */
    public function doPrint()
    {
        if (empty($_POST['delivery_id'])) {
            $this->error('发货单ID参数不能为空');
        }

        $only_print = (isset($_POST['only_print']) && $_POST['only_print'] == 'true') ? true : false;
        $action = $_POST['action'];
        $this->checkDelivery($action);
        $result = kernel::single('wap_event_trigger_cloudprint')->print($_POST['delivery_id']);
      
        if ($result['rsp'] == 'fail') {
            $this->error('打印失败:' . $result['err_msg']);
        }
        $this->success(empty($result['msg']) ? '打印提交成功' : $result['msg']);
       
    }

    public function checkDelivery($action)
    {
        $delivery_id = $_POST['delivery_id'];
        // 检查发货单是否已撤销

        $msg = '';
        $res = kernel::single("wap_delivery")->checkDeliveryPrint($delivery_id, $action, $msg);
        if (!$res) {
            $result['rsp'] = 'fail';
            $result['msg'] = $msg;
            echo json_encode($result);
            exit;
        }

        return true;
    }

    /**
     * showLogistics
     * @return mixed 返回值
     */
    public function showLogistics()
    {
        $delivery_id = $_REQUEST['delivery_id'];
        $delivery = app::get('wap')->model('delivery')->dump(array('delivery_id' => $delivery_id), '*');

        $omeDeliveryMdl = app::get('ome')->model('delivery');
        $omeDeliveryInfo = $omeDeliveryMdl->dump(array('delivery_bn' => $delivery['outer_delivery_bn']), '*');

        $storeMdl = app::get("o2o")->model("store");
        $storeInfo = $storeMdl->dump(array("branch_id" => $delivery['branch_id']));
        $area_str = '';
        if ($storeInfo['area']) {
            $area = explode(":", $storeInfo['area']);
            $area_str = str_replace("/", "", $area[1]);
            $storeInfo['address'] = $area_str . $storeInfo['addr'];
        }

        $orderId = $omeDeliveryMdl->getOrderIdByDeliveryId($omeDeliveryInfo['delivery_id']);
        $orderInfo = app::get('ome')->model('orders')->dump(array('order_id' => $orderId), '*');

        $waybill = app::get('logisticsmanager')->model('waybill')->dump(array('waybill_number' => $omeDeliveryInfo['logi_no']), 'monthly_account');
        if ($waybill) {
            $delivery['monthly_account'] = $waybill['monthly_account'];
        }

        $deliveryBill = app::get('wap')->model('delivery_bill')->dump(array('delivery_id' => $delivery_id), '*');

        $this->pagedata['title'] = '物流轨迹查询';
        $this->pagedata['orderInfo'] = $orderInfo;
        $this->pagedata['storeInfo'] = $storeInfo;
        $this->pagedata['delivery'] = $delivery;
        $this->pagedata['delivery_bill'] = $deliveryBill;

        if (strpos($omeDeliveryInfo['consignee']['name'], '>>')) {
            $omeDeliveryInfo['consignee']['name'] = substr($omeDeliveryInfo['consignee']['name'], 0, strpos($omeDeliveryInfo['consignee']['name'], '>>'));
        }
        $this->pagedata['omeDeliveryInfo'] = $omeDeliveryInfo;

        $corpMdl = app::get('ome')->model('dly_corp');
        //物流公司信息
        $corpInfo = $corpMdl->dump(array('corp_id' => $delivery['logi_id']), '*');
        //物流渠道类型
        $traceObj = kernel::single('ome_hqepay');

        $rpc_data['order_bn'] = $orderInfo['order_bn'];
        $rpc_data['logi_code'] = $corpInfo['type'];#物流编码
        $rpc_data['company_name'] = $corpInfo['name'];
        $rpc_data['logi_no'] = $omeDeliveryInfo['logi_no'];
        if (strtoupper($corpInfo['type']) == 'SF') {
            $rpc_data['customer_name'] = substr($deliveryBill['consigner_mobile'], -4);
        }
        $rpc_result = [];
        if($traceObj->is_wait_distribute($omeDeliveryInfo['logi_status'])) {
            $msg = '快递未揽收,无物流轨迹';
            $rpc_result['rsp'] = 'fail';
        }else {
            $rpc_result = $traceObj->get_dly_info($rpc_data);
            if ($rpc_result['rsp'] != 'succ') {
                if ($rpc_result['err_msg'] == "'HTTP Error 500: Internal Server Error'") {
                    $msg = '此订单可能缺少物流公司或运单号';
                } else {
                    $msg = $rpc_result['err_msg'];
                    if ($msg == '业务错误[手机尾号不正确]') {
                        $msg = '无法查看物流轨迹，寄件人手机号与快递单号不匹配';
                    }
                }
            } else {
                $msg = $rpc_result['Reason'];
            }
        }

        if ($rpc_result['data']) {
            // 获取第一行的key值
            $this->pagedata['last_logistics_key'] = array_key_first($rpc_result['data']);
        }
        // 物流轨迹
        $this->pagedata['logistics_result'] = array('rsp' => $rpc_result['rsp'], 'msg' => $msg, 'data' => $rpc_result['data']);

        $this->display('order/order_logistics.html');
    }

    /**
     * doAddLogiNo
     * @return mixed 返回值
     */
    public function doAddLogiNo()
    {
        $delivery_id = $_POST['delivery_id'];
        $logi_no = $_POST['logi_no'];
        $logi_code = $_POST['logi_code']; // 物流公司编码

        if (empty($delivery_id) || empty($logi_no) || empty($logi_code)) {
            $this->error('参数不能为空');
        }

        // 验证快递单号:最少8位,只允许字母和数字
        if (!preg_match('/^[a-zA-Z0-9]{8,}$/', $logi_no)) {
            $this->error('快递单号必须至少8位且只能包含字母和数字');
        }

        // 验证快递单号：顺丰:SF+12/13位数字 京东:JD+2位数字/字母+11位数字
//        if($logi_code == 'SF'){
//            if(!preg_match('/^SF[0-9]{12,13}$/', $logi_no)){
//                $this->error('顺丰快递单号必须以SF开头+12/13位数字');
//            }
//        }
//        if($logi_code == 'JD'){
//            if(!preg_match('/^JD[a-zA-Z0-9]{13}$/', $logi_no)){
//                $this->error('京东快递单号必须以JD开头+13位数字/字母');
//            }
//        }
        // 验证圆通快递单号：YT+12/13位数字
        if($logi_code == 'YT'){
            if(!preg_match('/^YT[0-9]{12,13}$/', $logi_no)){
                $this->error('圆通快递单号必须以YT开头+12/13位数字');
            }
        }
        // 验证德邦快递单号：DB+12/13位数字
        if($logi_code == 'DBL'){
            if(!preg_match('/^DP[A-Z]{1}[0-9]{12}$/', $logi_no)){
                $this->error('德邦物流单号必须以DP开头+1位大写字母+12位数字');
            }
        }

        // 验证中通快递单号：7+12至14位数字
        if($logi_code == 'ZTO'){
            if(!preg_match('/^7[0-9]{12,14}$/', $logi_no)){
                $this->error('中通快递单号必须以7开头+12至14位数字');
            }
        }

        $orderBn = app::get("wap")->model('delivery')->dump(array('delivery_id' => $delivery_id), 'order_bn');
        $order = app::get("ome")->model('orders')->dump(array('order_bn' => $orderBn), 'order_id,shop_type');
        if ($order['shop_type'] == 'luban') {
            $jyInfo = kernel::single('ome_bill_label')->getBillLabelInfo($order['order_id'], 'order', 'XJJY');
            if ($jyInfo) {
                $this->error('中转订单请联系客服修改直邮后再进行操作');
            }
        }

        $isCheckStore = kernel::single('wap_delivery_process')->checkDeliveryItemStore($delivery_id);
        if (!$isCheckStore) {
            $this->error('库存不足，请联系库存管理员处理');
        }

        // 补录快递单号
        $this->checkDelivery('offline');

        $msg = '';
        // 补录快递单号
        $data = array('delivery_id' => $delivery_id, 'logi_no' => $logi_no, 'logi_code' => $logi_code);
        $res = kernel::single('wap_delivery_process')->insertExpress($data);
        if ($res['rsp'] == 'succ') {

            $wapDeliveryObj    = app::get('wap')->model('delivery');
            $deliveryInfo      = $wapDeliveryObj->dump(array('delivery_id' => $delivery_id), '*');
            $deliveryInfo['logi_no'] = $logi_no;//执行发货

            $dlyProcessLib  = kernel::single('wap_delivery_process');
            $is_bulu = true;
            $res = $dlyProcessLib->consign($deliveryInfo, $is_bulu);
            //task任务更新统计数据
            $wapDeliveryLib    = kernel::single('wap_delivery');
            $wapDeliveryLib->taskmgr_statistic('consign');
            $this->success('补录快递单号成功');
        } else {
            $this->error($res['msg']);
        }
        exit;
    }

    /**
     * doUpdateLogiNo
     * @return mixed 返回值
     */
    public function doUpdateLogiNo()
    {
        $delivery_id = $_POST['delivery_id'];
        $logi_no = $_POST['logi_no'];
        $wapdeliveryObj = app::get('wap')->model('delivery');

        if (empty($delivery_id) || empty($logi_no)) {
            $this->error('参数不能为空');
        }

        $wap_delivery_info = $wapdeliveryObj->dump(array('delivery_id' => $delivery_id), 'outer_delivery_bn,logi_id,logi_status');
        if(!$wap_delivery_info){
            $this->error('wap 发货单不存在');
        }

        if(!in_array($wap_delivery_info['logi_status'],['1','2','5','6','7'])) {
            $this->error('当前物流状态不允许修改运单号');
        }

        $dlydata = app::get('ome')->model("dly_corp")->dump(array('corp_id' => $wap_delivery_info['logi_id']), '*');
        $logi_code = strtoupper($dlydata['type']);

        // 验证快递单号:最少8位,只允许字母和数字
        if (!preg_match('/^[a-zA-Z0-9]{8,}$/', $logi_no)) {
            $this->error('快递单号必须至少8位且只能包含字母和数字');
        }

        // 验证圆通快递单号：YT+12/13位数字
        if($logi_code == 'YT'){
            if(!preg_match('/^YT[0-9]{12,13}$/', $logi_no)){
                $this->error('圆通快递单号必须以YT开头+12/13位数字');
            }
        }
        // 验证德邦快递单号：DB+12/13位数字
        if($logi_code == 'DBL'){
            if(!preg_match('/^DP[A-Z]{1}[0-9]{12}$/', $logi_no)){
                $this->error('德邦物流单号必须以DP开头+1位大写字母+12位数字');
            }
        }

        // 验证中通快递单号：7+12至14位数字
        if($logi_code == 'ZTO'){
            if(!preg_match('/^7[0-9]{12,14}$/', $logi_no)){
                $this->error('中通快递单号必须以7开头+12至14位数字');
            }
        }

        $orderBn = app::get("wap")->model('delivery')->dump(array('delivery_id' => $delivery_id), 'order_bn');
        $order = app::get("ome")->model('orders')->dump(array('order_bn' => $orderBn), 'order_bn,order_id,shop_type,shop_id');

        if ($order['shop_type'] == 'luban') {
            $jyInfo = kernel::single('ome_bill_label')->getBillLabelInfo($order['order_id'], 'order', 'XJJY');
            if ($jyInfo) {
                $this->error('中转订单请联系客服修改直邮后再进行操作');
            }
        }

        $isCheckStore = kernel::single('wap_delivery_process')->checkDeliveryItemStore($delivery_id);
        if (!$isCheckStore) {
            $this->error('库存不足，请联系库存管理员处理');
        }


        // 修改快递单号
        $update_data = array('logi_no' => $logi_no);

        $wapdeliveryObj = app::get('wap')->model('delivery');
        $omedeliveryObj = app::get('ome')->model('delivery');
        $wmsdeliveryObj = app::get('wms')->model('delivery');
        $wap_delivery_bill_obj = app::get('wap')->model('delivery_bill');
        $ome_delivery_bill_obj = app::get('ome')->model('delivery_bill');
        $wms_delivery_bill_obj = app::get('wms')->model('delivery_bill');
        $ome_delivery_package_obj = app::get('ome')->model('delivery_package');
        $order_obj = app::get('ome')->model('orders');
        $operationLogObj = app::get('ome')->model('operation_log');

        $wap_delivery_info = $wapdeliveryObj->dump(array('delivery_id' => $delivery_id), 'outer_delivery_bn');
        if(!$wap_delivery_info){
            $this->error('wap 发货单不存在');
        }

        $ome_delivery_info = $omedeliveryObj->dump(['delivery_bn'=>$wap_delivery_info['outer_delivery_bn']]);
        if(!$ome_delivery_info){
            $this->error('ome 发货单不存在');
        }

        $wms_delivery_info = $wmsdeliveryObj->dump(array('outer_delivery_bn' => $ome_delivery_info['delivery_bn']), '*');

        //订单数量(抖音和视频号不支持拆单的修改)
        $order_items = app::get('ome')->model('order_items')->getList('*',['order_id'=>$order['order_id'],'delete'=>'false']);
        $goods = [];
        foreach ($order_items as $oinfo){
            $goods[] = ['product_cnt'=>intval($oinfo['nums']),'product_id'=>$oinfo['shop_goods_id'],'sku_id'=>$oinfo['shop_product_id']];
        }

        //如果是商城
        if ($order['shop_type'] == XCXSHOPTYPE) {
            $params = array(
                'order_bn' => $order['order_bn'],
                'shop_id'  => $order['shop_id'],
                'delivery_bn' => $ome_delivery_info['delivery_bn'],
                'delivery_id' => $ome_delivery_info['delivery_id'],
                'old_code' => $ome_delivery_info['logi_no'],
                'new_code' => $logi_no,
            );
            $err_msg = '';
            $res = kernel::single("ome_ecapi_delivery")->update_delivery_code($params, $err_msg);
            if (!$res) {
                $this->error($err_msg?$err_msg:'商城更新物流单号失败');
            }
        }
        else {
            //同步给平台
            $params = array(
                'order_bn' => $order['order_bn'],
                'delivery_bn' => $ome_delivery_info['delivery_bn'],
                'logi_code' => $logi_code,
                'logi_no' => $logi_no,
                'goods' => json_encode($goods)
            );
            $res = kernel::single('erpapi_router_request')->set('shop', $order['shop_id'])->delivery_logistics_edit($params);
            if ($res['rsp'] != 'succ') {
                $this->error($res['err_msg'] ? $res['err_msg'] : $res['error_msg']);
            }
        }

        try {
            kernel::database()->beginTransaction();

            //数据修改
            $wap_delivery_bill_obj->update($update_data,['delivery_id'=>$delivery_id]);
            $omedeliveryObj->update($update_data,['delivery_id'=>$ome_delivery_info['delivery_id']]);
            $ome_delivery_bill_obj->update($update_data,['delivery_id'=>$ome_delivery_info['delivery_id']]);
            $ome_delivery_package_obj->update($update_data,['delivery_id'=>$ome_delivery_info['delivery_id']]);
            $order_obj->update($update_data,['order_id'=>$order['order_id']]);
            $wms_delivery_bill_obj->update($update_data, ['delivery_id' => $wms_delivery_info['delivery_id']]);

            //添加日志
            $memo = "h5修改物流单号为:".$logi_no;
            $operationLogObj->write_log('order_modify@ome',$order['order_id'],$memo);
            $operationLogObj->write_log('delivery_modify@ome',$ome_delivery_info['delivery_id'],$memo);
            //wms
            if($wms_delivery_info) {
                $operationLogObj->write_log('delivery_logi@wms',$wms_delivery_info['delivery_id'],$memo);
            }

            kernel::database()->commit();
        } catch (\Exception $e) {
            kernel::database()->rollBack();
            $this->error('修改运单号失败');
        }

        //重新订阅快递鸟
        kernel::single('ome_event_trigger_shop_hqepay')->hqepay_pub($ome_delivery_info['delivery_id']);

        $this->success('修改快递单号成功');

    }
}