<?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 wms_ctl_admin_check extends desktop_controller{
    var $name = "货物校验";
    var $workground = "wms_delivery";

    /**
     *
     * 逐单校验/整单校验的入口展示页
     */
    function index(){
        $deliveryObj  = app::get('wms')->model('delivery');

        $numShow = app::get('wms')->getConf('wms.delivery.checknum.show');
        if($numShow == 'false' || (cachecore::fetch('quick_access') !== false)){
            $this->pagedata['num'] = '未知';
        }else{
            $this->pagedata['num'] = $deliveryObj->countNoVerifyDelivery();
        }

        $this->pagedata['checkType'] = $_GET['type'];
        $this->page("admin/delivery/process_check_index.html");
    }

    /**
     *
     * 批量校验的入口展示页
     */
    function batchIndex(){
        $stock_confirm= app::get('ome')->getConf('purchase.stock_confirm');
        $stock_cancel= app::get('ome')->getConf('purchase.stock_cancel');
        $this->pagedata['stock_confirm'] = $stock_confirm;
        $this->pagedata['stock_cancel'] = $stock_cancel;
        $deliveryObj  = app::get('wms')->model('delivery');
        $this->pagedata['num'] = $deliveryObj->countNoVerifyDelivery();
        $this->page("admin/delivery/process_batch_check_index.html");
    }

    /**
     *
     * 分组校验的入口展示页
     */
    function group_check(){
        $deliCfgLib = kernel::single('wms_delivery_cfg');
        $verfy = $deliCfgLib->getValue('verify');
        if($verfy == 1){
            $deliveryObj = app::get('wms')->model('delivery');
            $orderTypeObj = app::get('omeauto')->model('order_type');
            $groupFilter['tid'] = $deliCfgLib->getValue('wms_delivery_verify_group');
            $groupFilter['disabled'] = 'false';
            $groupFilter['delivery_group'] = 'true';
            $orderTypes = $orderTypeObj->getList('*',$groupFilter);

            $filter = array(
                'status'=> 0,
                'process_status'=> 1,
                'disabled'=>'false',
                //'type'=>'normal',
            );

            $oBranch = app::get('ome')->model('branch');
            $is_super = kernel::single('desktop_user')->is_super();
            if (!$is_super) {
                $branch_ids = $oBranch->getBranchByUser(true);
                if ($branch_ids) {
                    $filter['branch_id'] = $branch_ids;
                }
            }

            $deliverys = $deliveryObj->getList('delivery_id,delivery_group',$filter);

            $deliveryGroup = array();
            foreach($orderTypes as $key => $type){
                $deliveryGroup[$type['tid']] = $type;
                $deliveryGroup[$type['tid']]['deliverys'] = array();
                $deliveryGroup[$type['tid']]['dCount'] = 0;
            }

            foreach($deliverys as $key => $value){
                if($value['delivery_group']>0 && $deliveryGroup[$value['delivery_group']]){
                    $deliveryGroup[$value['delivery_group']]['deliverys'][] = $value['delivery_id'];
                    $deliveryGroup[$value['delivery_group']]['dCount']++;
                }
                $deliveryAll[] = $value['delivery_id'];
            }

            /*
            $deliveryGroup[8388607] = array(
                'tid' => 8388607,
                'name' => '全部分组',
                'deliverys' => $deliveryAll,
                'dCount' => count($deliveryAll),
            );
            */

            $this->pagedata['num_available'] = is_array($deliveryAll) ? count($deliveryAll) : 0;
            $this->pagedata['deliveryGroup'] = $deliveryGroup;
            $this->pagedata['jsonDeliveryGroup'] = json_encode($deliveryGroup);

            /* 操作时间间隔 start */
            $lastGroupCalibration = app::get('wms')->getConf('lastGroupCalibration'); //上次获取订单信息(key为execTime表示执行时间，key为pageBn表示页面编号),
            $groupCalibrationIntervalTime = app::get('wms')->getConf('wms.groupCalibration.intervalTime'); //每次操作的时间间隔

            if(($lastGroupCalibration['execTime']+60*$groupCalibrationIntervalTime)<time()){
                $this->pagedata['is_allow'] = true;
            }else{
                $this->pagedata['is_allow'] = false;
            }
            $this->pagedata['lastGroupCalibrationTime'] = !empty($lastGroupCalibration['execTime']) ? date('Y-m-d H:i:s',$lastGroupCalibration['execTime']) : '';
            $this->pagedata['groupCalibrationIntervalTime'] = $groupCalibrationIntervalTime;
            $this->pagedata['currentTime'] = time();
            /* 操作时间间隔 end */

            $this->page("admin/delivery/process_group_check.html");
        }else{
            echo "未开启分组校验！";
        }
    }

    /**
     * @description 校验成功
     * @access public
     * @param void
     * @return void
     */
    public function check_pass()
    {
        $deliveryObj = app::get('wms')->model('delivery');
        $dlyBillMdl = app::get('wms')->model('delivery_bill');
        
        $deliveryBillLib = kernel::single('wms_delivery_bill');
        
        $pass = $_POST['pass'];
        if ($pass == 'false') {
            echo 'check fail!!!'; exit;
        }

        $checkType = $_POST['checkType'];
        $logi_no = $_POST['logi_no'];

        $deliveryBill = $dlyBillMdl->db_dump(['logi_no' => $logi_no]);
        $delivery_id = $deliveryBill ? $deliveryBill['delivery_id'] : 0;
        $bill_id = $deliveryBill ? $deliveryBill['b_id'] : 0;
        
        //[同城配]商家配送支持配送员手机号搜索
        if(empty($deliveryBill) && strlen($logi_no) == 11){
            $deliveryInfo = $deliveryObj->dump(array('deliveryman_mobile'=>$logi_no, 'process_status'=>array(0,1)), '*');
            if($deliveryInfo){
                $delivery_id = $deliveryInfo['delivery_id'];
                
                $deliveryBill = $dlyBillMdl->db_dump(array('delivery_id'=>$delivery_id));
                $bill_id = $deliveryBill['b_id'];
            }
        }
        
        // 箱包裹
        $deliveryBillItems = app::get('wms')->model('delivery_bill_items')->getList('*', ['bill_id' => $bill_id]);
        $deliveryBillItems = array_column($deliveryBillItems, null, 'product_id');

        //参数赋值
        $dly = array(
            'logi_no' => $logi_no,
            'delivery_id' => $delivery_id,
        );

        //捡货绩效开始记录点
        foreach(kernel::servicelist('tgkpi.pick') as $o){
            if(method_exists($o,'begin_check')){
                $o->begin_check($delivery_id);
                $this->pagedata['tgkpi_status'] = 'true';
            }
        }

        //获取相关订单的备注信息，走接口
        $deliveryInfo = $deliveryObj->dump($delivery_id, 'outer_delivery_bn,ship_name,branch_id');
        $res = kernel::single('ome_extint_order')->getMemoByDlyId($deliveryInfo['outer_delivery_bn']);

        $this->pagedata['ship_name'] = $deliveryInfo['consignee']['name'];

        $order_bns = array();
        foreach ($res['mark_text'] as $k =>$v){
            if(!in_array($k, $order_bns)){
                $order_bns[] = $k;
            }
        }

        foreach ($res['custom_mark'] as $k =>$v){
            if(!in_array($k, $order_bns)){
                $order_bns[] = $k;
            }
        }

        foreach ($order_bns as $k => $order_bn){
            $markandtext[$k]['order_bn'] = $order_bn;
            $markandtext[$k]['_mark'] = isset($res['custom_mark'][$order_bn]) ? $res['custom_mark'][$order_bn] : '';
            $markandtext[$k]['_mark_text'] = isset($res['mark_text'][$order_bn]) ? $res['mark_text'][$order_bn] : '';
        }

        $this->pagedata['markandtext']  = $markandtext;

        # 货品名显示方式(stock:后台,front:前台)
        $product_name_show_type = app::get('wms')->getConf('wms.delivery.check_show_type');
        $product_name_show_type = empty($product_name_show_type) ? 'stock' : $product_name_show_type;

        $goods = 0; $newItems = array();

        $basicMaterialLib    = kernel::single('material_basic_material');
        $basicMaterialBarcode    = kernel::single('material_basic_material_barcode');
        $dlyItemsSLObj    = app::get('wms')->model('delivery_items_storage_life');

        $items = $deliveryObj->getItemsByDeliveryId($delivery_id);
        $bm_id = '';
        foreach ($items as $k => $i)
        {
            // 箱包数
            if ($deliveryBillItems) {
                if (!$deliveryBillItems[$i['product_id']]){
                    continue;
                }
                $items[$k]['number'] = $i['number']     = $deliveryBillItems[$i['product_id']]['number'];
                $items[$k]['verify_num'] = $i['verify_num'] = $deliveryBillItems[$i['product_id']]['verify_num'];
            }

            $bm_id = $i['product_id'];
            //查询关联的条形码
            $barcode    = $basicMaterialBarcode->getBarcodeById($i['product_id']);
            $count += $i['number'];
            $goods ++;
            $verify_num += $i['verify_num'];
            $verify += $i['verify_num'];

            $items[$k]['barcode'] = trim($barcode);
            $items[$k]['bn'] = trim($items[$k]['bn']);
            
            $p    = $basicMaterialLib->getBasicMaterialExt($i['product_id']);
            
            $items[$k]['serial_number'] = $p['serial_number'];

            if($i['use_expire'] == 1){
                $item_expire_arr = $dlyItemsSLObj->getList('*',array('delivery_id'=>$delivery_id,'item_id'=>$i['item_id']));
                foreach($item_expire_arr as $item_expire){
                    $strkey = $item_expire['expire_bn'];

                    if($newItems[$strkey] && $newItems[$strkey]['bn'] !=''){
                        $newItems[$strkey]['number'] += $item_expire['number'];
                        $newItems[$strkey]['verify_num'] += $item_expire['verify_num'];
                    }else{
                        $newItems[$strkey] = array(
                            'bn' => $items[$k]['bn'],
                            'product_id' => $items[$k]['product_id'],
                            'product_name' => $items[$k]['product_name'],
                            'barcode' => $strkey,
                            'number' => $item_expire['number'],
                            'verify_num' => $item_expire['verify_num'],
                            'is_expire_bn' => 'true',
                            'serial_number' => $p['serial_number'],
                        );
                    }
                }
            }else{
                $strkey = $i['bn'];

                if($newItems[$strkey] && $newItems[$strkey]['bn'] !=''){
                    $newItems[$strkey]['number'] += $items[$k]['number'];
                    $newItems[$strkey]['verify_num'] += $items[$k]['verify_num'];
                }else{
                    $newItems[$strkey] = $items[$k];
                }
            }
        }

        $items = $newItems;
        //增加发货单校验显示前的扩展
        foreach(kernel::servicelist('ome.delivery') as $o){
            if(method_exists($o,'pre_check_display')){
                $o->pre_check_display($items);
            }
        }

        //增加日志
        $opObj = app::get('ome')->model('operation_log');
        $msg= "发货单开始校验";
        $opObj->write_log('delivery_check@wms', $delivery_id, $msg);

        if($product_name_show_type == 'stock') {
            $this->toGoodsName($items);
        }
        $serial['merge'] = app::get('ome')->getConf('ome.product.serial.merge');
        $serial['separate'] = app::get('ome')->getConf('ome.product.serial.separate');
        $this->pagedata['serial'] = $serial;

        $conf = app::get('wms')->getConf('wms.delivery.check');
        $this->pagedata['normal'] = 0;
        $this->pagedata['conf'] = $conf;
        $this->pagedata['count'] = $count;
        $this->pagedata['number'] = $verify;
        $this->pagedata['goodsNum'] = $goods;
        $this->pagedata['items'] = $items;
        $this->pagedata['dly'] = $dly;
        $this->pagedata['verify_num'] = $verify_num;
        $this->pagedata['remain'] = $count - $verify_num;
        $this->pagedata['userName'] = kernel::single('desktop_user')->get_name();
        $this->pagedata['date'] = date('Y-m-d H:i');
        $this->pagedata['checkType'] = $checkType;
        $this->pagedata['bh_id'] = $deliveryInfo['branch_id'];

        // 特殊扫码配置
        $materialSpecConf = app::get('material')->model('basic_material_conf_special');
        $specialConf = $materialSpecConf->getList('openscan,fromposition,toposition', array('bm_id'=>$bm_id),0,1);

        $this->pagedata['openscan'] = $specialConf[0]['openscan'];
        $this->pagedata['fromposition'] = $specialConf[0]['fromposition'];
        $this->pagedata['toposition'] = $specialConf[0]['toposition'];

        //获取
        if (app::get('tgkpi')->is_installed()) {
            $pickInfo = kernel::database()->selectrow("SELECT pick_owner FROM sdb_tgkpi_pick WHERE delivery_id={$delivery_id}");
            if (!empty($pickInfo['pick_owner'])){
                $pickUser = app::get('desktop')->model('users')->dump(array('op_no'=>$pickInfo['pick_owner']), 'name');
                if ($pickUser) {
                    $this->pagedata['picktName']= $pickUser['name'];
                }
            }
        }

        if ($checkType == 'all') {
            $view = 'admin/delivery/delivery_checkout2.html';
            $delivery_weight =  app::get('wms')->getConf('wms.delivery.weight'); #发货配置，开启称重
            $check_delivery = app::get('wms')->getConf('wms.delivery.check_delivery'); #发货配置，检验完即发货

            #开启称重时，不能使用校验完即发货功能
            if($delivery_weight == 'on'){
                $check_delivery = 'off';
            }
            if(!isset($check_delivery)||empty($check_delivery)){
                $check_delivery = 'off';
            }
            $this->pagedata['check_delivery'] = $check_delivery;
            #逐单发货，如果不称重，且,开启了校验后直接发货
            if($delivery_weight == 'off' && $check_delivery == 'on'){
                $minWeight = app::get('wms')->getConf('wms.delivery.minWeight');
                $this->pagedata['weight'] = $minWeight;
                $this->pagedata['check_delivery'] = $check_delivery;
                #校验后,直接发货的view页面
                $view = 'admin/delivery/delivery_checkout3.html';
            }
        } else {
            $view = 'admin/delivery/delivery_checkout.html';
        }

        $this->display($view);
    }

    /**
     * 校验发货单是否可打印
     *
     */
    function check(){
        if ($_POST['pass'] == 'true') {
            $this->check_pass();exit;
        }
        
        $msg = '';
        $autohide = array('autohide'=>3000);
        $this->begin('index.php?app=wms&ctl=admin_check');
        $checkType = $_POST['checkType'];
        $logi_no = $_POST['delivery']['logi_no'];

        # barcode:逐单 all:整单
        if (!in_array($checkType,array('barcode','all'))) {
            $this->end(false, '参数传递错误', '', $autohide);
        }

        $dlyCheckLib = kernel::single('wms_delivery_check');

        $check_result = $dlyCheckLib->checkAllow($logi_no, $msg, $checkType);
        if (!$check_result){
            $this->end(false, $msg, '', $autohide);
        }else{
            $this->end(true,'快递单合法，开始校验。','',array('pass'=>'true','checkType'=>$checkType,'logi_no'=>$logi_no));
        }
    }

    /**
     *
     * 批量校验的校验验证检查方法
     */
    function batchCheck(){
        $msg = '';
        $ids = urldecode($_POST['delivery_id']);
        if (empty($ids)){
            $tmp = array(array('bn'=>'*','msg'=>'请扫描快递单号'));
            echo json_encode($tmp);die;
        }

        $deliveryObj  = app::get('wms')->model('delivery');
        $dlyCheckLib = kernel::single('wms_delivery_check');
        $delivery_ids = array_unique(explode(',', $ids));
        $tmp = array();
        foreach($delivery_ids as $logi_no){
            if(!$logi_no)continue;

            $delivery = $dlyCheckLib->checkAllow($logi_no, $msg, 'batch');
            if (!$delivery) {
                $tmp[] = array('bn'=>$logi_no,'msg'=>$msg);
                continue;
            }
        }

        if ($tmp){ echo json_encode($tmp);die;}

        echo "";
    }

    private function toGoodsName(& $items)
    {
        $basicMaterialObj = app::get('material')->model('basic_material');

        $bn_string = '';
        foreach($items as $k=>$v)
        {
            $product     = $basicMaterialObj->dump(array('material_bn'=>$items[$k]['bn']), 'material_name');
            if($product)
            {
                $items[$k]['product_name'] = $product['material_name'];
            }
        }
    }

    /**
     *
     * 逐单校验/整单校验提交处理方法
     */
    function doCheck()
    {
        $dlyCheckLib = kernel::single('wms_delivery_check');
    
        $errmsg = '';
        $autohide = array('autohide'=>2000);
        $checkType = in_array($_POST['checkType'],array('barcode','all')) ? $_POST['checkType'] : 'barcode';
        $this->begin('index.php?app=wms&ctl=admin_check&act=index&type='.$checkType);
        if (empty($_POST['delivery_id'])){
            $this->end(false, '发货单ID传入错误', '', $autohide);
        }
        if ($_POST['logi_no'] == ''){
            $this->end(false, '请扫描快递单号', '', $autohide);
        }

        foreach(kernel::servicelist('ome.delivery') as $o){
            if(method_exists($o,'pre_docheck')){
                $message = "";
                $result = $o->pre_docheck($_POST,$message);
                if(!$result){
                    $this->end(false, $message, '', $autohide);
                }
            }
        }

        $dly_id   = $_POST['delivery_id'];
        $count    = $_POST['count'];
        $number   = $_POST['number'];
        $logi_no  = $_POST['logi_no'];

        //检查订单的当前状态
        if(!$dlyCheckLib->checkOrderStatus($dly_id, true, $errmsg)){
            $this->end(false, $errmsg, '', $autohide);
        }

        if ($count == 0 || $number == 0){
            $this->end(false, '对不起，校验提交的数据错误', '', $autohide);
        }

        $deliveryObj  = app::get('wms')->model('delivery');
        $dly          = $deliveryObj->dump($dly_id,'*', array('delivery_items'=>array('*')));

        //filter
        $filter = array(
            'logi_no' => $logi_no,
            'delivery_id' => $dly_id,
        );
        
        //[同城配]商家配送
        if($dly['delivery_model'] == 'seller'){
            $filter = array(
                'delivery_id' => $dly_id,
            );
        }
        
        //检查运单号是否属于同一个处理的发货单
        $deliveryBill = app::get('wms')->model('delivery_bill')->db_dump($filter);
        if (!$deliveryBill){
            $this->end(false, '扫描的快递单号与系统中的快递单号不对应', '', $autohide);
        }

        $deliveryBillItemMdl = app::get('wms')->model('delivery_bill_items');

        if ($dly['logi_number'] > '1' && $_POST['checkType'] == 'all'){
            $basicMaterialBarcode    = kernel::single('material_basic_material_barcode');

            $deliveryBillItems = $deliveryBillItemMdl->getList('*', ['bill_id' => $deliveryBill['b_id']]);
            foreach ($deliveryBillItems as $item) {
                $barcode    = $basicMaterialBarcode->getBarcodeById($item['product_id']);

                $_POST['number_'. $barcode] = $item['number'];
            }
        }

        //合计发货单明细的总数
        // $total = 0;
        // foreach ($dly['delivery_items'] as $i){
        //     $total += $i['number'];
        // }

        $opObj        = app::get('ome')->model('operation_log');
        $deliveryLib = kernel::single('wms_delivery_process');

        // 包裹校验
        if (!$deliveryLib->verifyPackage($deliveryBill['b_id'], $_POST, $_POST['checkType'])){
            $this->end(false, '包裹校验失败', '', $autohide);
        }

        $checkFinish = false;

        // 判断发货单是否全部校验完成
        if ($dly['logi_number'] == '1' && $count == $number){
            $checkFinish = true;
        }


        $packageList =  app::get('wms')->model('delivery_bill')->getList('b_id', [
            'delivery_id' => $dly_id,
        ]);
        $packageId = $packageList ? array_column($packageList, 'b_id') : [0];
        if ($dly['logi_number'] > '1' && 0 == $deliveryBillItemMdl->count(['bill_id' => $packageId, 'filter_sql' => 'number!=verify_num'])) {
            $checkFinish = true;
        }

        if ($checkFinish) {
            //对发货单详情进行校验完成处理
            if ($deliveryLib->verifyDelivery($dly_id)){
                //增加发货单校验把保存后的扩展
                foreach(kernel::servicelist('ome.delivery') as $o){
                    if(method_exists($o,'after_docheck')){
                        $data = $_POST;
                        $o->after_docheck($data);
                    }
                }

                $this->end(true, '发货单校验完成');
            }else {
                $this->end(false, '发货单校验未完成，请重新校验', 'index.php?app=wms&ctl=admin_check', $autohide);
            }
        } else {
            //保存部分校验结果
            $flag = $deliveryLib->verifyItemsByDeliveryIdFromPost($dly_id);
            if ($flag){
                $opObj->write_log('delivery_check@wms', $dly_id, '发货单部分检验数据保存完成');
                
                if ($count != $number){
                    $autohide["logi_no"]        = $logi_no;
                    $autohide["checkType"]      = $checkType;
                    $autohide["pass"]           = "true";
                    $autohide["part_check"]     = "true";
                    $this->end(true, '发货单部分检验数据保存完成', '', $autohide);
                } else {
                    $this->end(true, '发货单部分检验数据保存完成');
                }

                
            }else {
                $this->end(false, '发货单校验未完成，请重新校验', '', $autohide);
            }
        }
    }

    function ajaxDoGroupCheck(){
        $tmp = explode('||', $_POST['ajaxParams']);
        $group = $tmp[0];
        $delivery = explode(';', $tmp[1]);
        $msg = '';
        $failInfo = array();
        
        if($delivery && count($delivery)>0){
            /* 执行时间判断 start */
            $pageBn = intval($_POST['pageBn']);
            $lastGroupCalibration = app::get('wms')->getConf('lastGroupCalibration'); //上次获取订单信息(key为execTime表示执行时间，key为pageBn表示页面编号),
            $groupCalibrationIntervalTime = app::get('wms')->getConf('wms.groupCalibration.intervalTime'); //每次操作的时间间隔

            if($pageBn !=$lastGroupCalibration['pageBn'] && ($lastGroupCalibration['execTime']+60*$groupCalibrationIntervalTime)>time()){
                echo json_encode(array('total' => count($delivery), 'succ' => 0, 'fail' => count($delivery), 'failInfo'=>array('执行时间不合法')));
                exit;
            }
            if($pageBn !=$lastGroupCalibration['pageBn'] && $pageBn<$lastGroupCalibration['execTime']){
                echo json_encode(array('total' => count($delivery), 'succ' => 0, 'fail' => count($delivery), 'failInfo'=>array('提交参数过期')));
                exit;
            }

            //记录本次获取订单时间
            $currentGroupCalibration = array(
                'execTime'=>time(),
                'pageBn'=>$pageBn,
            );
            app::get('ome')->setconf('lastGroupCalibration',$currentGroupCalibration);
            /* 执行时间判断 end */

            $deliveryObj = app::get('wms')->model('delivery');
            $deliveryLib = kernel::single('wms_delivery_process');
            $dlyCheckLib = kernel::single('wms_delivery_check');
            $dlyBillObj = kernel::single('wms_delivery_bill');

            $filter = array(
                'delivery_id'=>$delivery,
            );
            $deliverys = $deliveryObj->getList('delivery_id,delivery_bn',$filter);
            $succ = 0;
            $fail = 0;
            foreach($deliverys as $value){
                $logi_no = $dlyBillObj->getPrimaryLogiNoById($value['delivery_id']);
                $checkInfo = $dlyCheckLib->checkAllow($logi_no, $msg, 'group', true);
                if ($checkInfo){
                    if($deliveryLib->verifyDelivery($value['delivery_id'],true)){
                        $succ++;
                    }else{
                        $fail++;
                        $failInfo[] = $value['delivery_bn'];
                    }
                }else{
                    $fail++;
                    $failInfo[] = $value['delivery_bn'];
                }
                usleep(200000);
            }
            echo json_encode(array('total' => count($delivery), 'succ' => $succ, 'fail' => $fail, 'failInfo'=>$failInfo));
        }else{
            echo json_encode(array('total' => 0, 'succ' => 0, 'fail' => 0, 'failInfo'=>$failInfo));
        }
    }

    /**
     *
     * 获取发货记录历史
     */
    function batchConsignLog(){
        $blObj  = app::get('wms')->model('batch_log');
        $batchLogLib = kernel::single('wms_batch_log');

        $dayBegin = mktime(0,0,0,date("m"),date("d"),date("Y"));//当天开始时间戳
        $dayEnd = mktime(23,59,59,date("m"),date("d"),date("Y"));//当天结束时间戳
        $blResult = $blObj->getList('*', array('log_type'=>'check','createtime|than'=>$dayBegin,'createtime|lthan'=>$dayEnd), 0, -1,'createtime desc');

        foreach($blResult as $k=>$v){
            $blResult[$k]['status_value'] = $batchLogLib->getStatus($v['status']);

            $blResult[$k]['fail_number'] = $v['fail_number'];
            $blResult[$k]['createtime'] = date('Y-m-d H:i:s',$v['createtime']);
        }

        if($blResult){
            echo json_encode($blResult);
        }
    }

    /**
     *
     * 更新处理中发货记录值
     */
    function updateBatchCheckLog(){
        $log_id = $_POST['log_id'];
        if($log_id){
            $status="'0','2'";
            $batchLogLib = kernel::single('wms_batch_log');
            // 处理log_id参数：使用explode分割字符串为数组
            $log_id_param = explode(',', $log_id);
            $blResult = $batchLogLib->get_List('check',$log_id_param,$status);
            foreach($blResult as $k=>$v){
                $blResult[$k]['status_value'] = $batchLogLib->getStatus($v['status']);
                $blResult[$k]['fail_number'] = $v['fail_number'];
                $blResult[$k]['createtime'] = date('Y-m-d H:i:s',$v['createtime']);
            }

            echo json_encode($blResult);
        }

    }

    /**
     *
     * 保存批量发货至记录队列表中
     */
    function saveBatchCheck(){
        $goto_url = 'index.php?app=wms&ctl=admin_check&act=batchIndex';
        $ids = $_POST['delivery_id'];
        $delivery_ids = explode(',', $ids);
        $delivery_ids = array_filter($delivery_ids);

        if ( !$delivery_ids ) {
            $this->splash('success',$goto_url ,'快递单列表为空！');
        }

        $batch_number = count($delivery_ids);
        $blObj  = app::get('wms')->model('batch_log');

        $bldata = array(
            'op_id' => kernel::single('desktop_user')->get_id(),
            'op_name' => kernel::single('desktop_user')->get_name(),
            'createtime' => time(),
            'batch_number' => $batch_number,
            'log_type'=>'check',
            'log_text'=>serialize($delivery_ids)
        );
        $result = $blObj->save($bldata);

        //校验任务加队列
        $push_params = array(
            'data' => array(
                'log_text' => $bldata['log_text'],
                'log_id' => $bldata['log_id'],
                'task_type' => 'autochk'
            ),
            'url' => kernel::openapi_url('openapi.autotask','service')
        );
        kernel::single('taskmgr_interface_connecter')->push($push_params);

        $this->splash('success',$goto_url ,'已提交至队列');
    }

    function batch_log_detail(){
        $log_id = $_GET['log_id'];
        $filter = array('log_id'=>$log_id);
        if ($_GET['status']) {
            $filter['status'] = $_GET['status'];
        }

        $bldObj  = app::get('wms')->model('batch_detail_log');
        $bldData = $bldObj->getList('*',$filter,0,-1);
        foreach($bldData as $k=>$v){
            $bldData[$k]['createtime'] = date('Y-m-d H:i:s',$v['createtime']);
        }
        $this->pagedata['bldData'] = $bldData;
        $this->display('admin/delivery/batch_chklog_detail.html');
    }
}