';
        //print_r($data);
        $this->pagedata['search'] = $search;
        $this->pagedata['count'] = $count;
        $this->pagedata['search_list'] = $search_list;
        $this->pagedata['rows'] = $data;
        $this->pagedata['pager'] = $pager;
        $this->pagedata['wms_id'] = $wms_id;
        $this->pagedata['finder_id'] = $finder_id;
        if($_GET['target'] || $_POST['search'] =='true'){
            return $this->display('admin/goodssync/index.html');
        }
        $this->singlepage('admin/goodssync/index.html');
    }

    function do_save(){
        $wms_id = $_POST['wms_id'];
        $product_ids = $_POST['product_id'];

        $finder_id = $_POST['finder_id'];
        $wfsObj = app::get('console')->model('foreign_sku');
        $db = kernel::database();
        $limit = 50;//设置多少个货品组一个sql语句
        $this->begin();
        //全选时候的处理
        if($_POST['select_all'] == 'true'){
            $search_key = $_POST['search_key'];
            $search_value = $_POST['search_value'];
            if(!empty($search_key) && !empty($search_value)){
                $data = kernel::single("console_goodssync")->get_data_by_search($search_key,$search_value,$wms_id);
            }else{
                $data = kernel::single("console_goodssync")->get_goods_by_wms($wms_id);
            }
        }else{
            $data = kernel::single("console_goodssync")->get_wms_goods($product_ids);
        }


        //标签为全部 表示所有wms都分配商品
        if($wms_id =='0'){
            $all = 'true';
            //$wms = $wmsObj->getList('wms_id',array('connect_type|noequal'=>'omeselfwms'));
            $wms = kernel::single('channel_func')->getWmsChannelList();
            $sdf = array();
            foreach($wms as $wms_id){
                $sdf[] = $this->get_foreign_sku_sdf($data,$wms_id['wms_id']);
            }
        }else{
            $sdf = $this->get_foreign_sku_sdf($data,$wms_id);
        }

        if($all == 'true'){
            foreach($sdf as $value){
                foreach($value as $v){
                    $sql_find = "select inner_product_id from sdb_console_foreign_sku where inner_sku = '".$v['inner_sku']."' and wms_id = '".$v['wms_id']."'";
                    $rs = $db->select($sql_find);
                    if(!$rs){
                        $update_value[] = "('".$v['inner_sku']."','".$v['inner_product_id']."','".$v['wms_id']."')";
                    }
                }
            }
        }else{
            foreach($sdf as $value){
                $update_value[] = "('".$value['inner_sku']."','".$value['inner_product_id']."','".$value['wms_id']."')";
            }
        }
        $count = ceil(count($update_value) / $limit);
        $update_value_tmp = array_chunk($update_value, $limit,true);
        for($i=0;$i<$count;$i++){
            //插入数据
            $update_sql = "insert into sdb_console_foreign_sku (`inner_sku`,`inner_product_id`,`wms_id`) values ".implode($update_value_tmp[$i], ',');

            $db->exec($update_sql);
        }
        $this->end(true,'操作成功');
    }

    function get_foreign_sku_sdf($data,$wms_id){
        $sdf = array();
        foreach($data as $v){
            $sdf[] = array(
                'inner_sku'=>$v['bn'],
                'inner_product_id'=>$v['product_id'],
                'wms_id'=>$wms_id,
            );
        }
        return $sdf;
    }

    function downloadTemplate(){
        header("Content-Type: text/csv");
        header("Content-Disposition: attachment; filename=货品分配模板.csv");
        header('Cache-Control:must-revalidate,post-check=0,pre-check=0');
        header('Expires:0');
        header('Pragma:public');
        $oObj = $this->app->model('foreign_sku');
        $title = $oObj->exportTemplate();
        echo '"'.implode('","',$title).'"';

    }

    /**
     * 追加导出模板内容
     * 
     * @param Array $filter
     */
    public function importTemplate(){
       $wms_id = $_GET['wms_id'];
       if ($wms_id){

            $wms_info = array(
                'wms_name' => kernel::single('channel_func')->getChannelNameById($wms_id),
                'wms_id' => $wms_id
            );
        }else{
            $wms_info = array(
                'wms_name' => '全部',
                'wms_id' => '_ALL_'
            );
        }
        $this->pagedata['wms_name'] = $wms_info['wms_name'];
        $this->pagedata['wms_id'] = $wms_info['wms_id'];

        return $this->page('admin/goodssync/create_import.html');
    }

    //导入（默认当前wms，所有时，所有wms都插）
    public function import(){
        if( $_POST ){
            $this->begin();
            //所有wms 不包括自有仓储
            if($_POST['wms_id']=='0'){
                $wms = kernel::single('channel_func')->getWmsChannelList();
                $wms_id = array();
                foreach($wms as $v){
                    $wms_id[] = $v['wms_id'];
                }
            }else{
                $wms_id = (array)$_POST['wms_id'];
            }
            $files = $_FILES['upload_file'];

            if( $files['name'] == ''){
                $result['status'] = 'fail';
                $result['msg'] = '文件不能为空，请重新选择';
                $this->end(false,'上传失败!','',$result);
                exit;
            }

            $tmp = explode('.',$files['name']);
            $file_type = $tmp[(count($tmp)-1)];
            if( $file_type != 'csv' ){
                $result['status'] = 'fail';
                $result['msg'] = '文件类型错误，请重新选择';
                $this->end(false,'上传失败!','',$result);
                exit;
            }

            $_temp_file = iconv('UTF-8','gb2312',$files['tmp_name']);
            @chmod($_temp_file,0777);
            if(file_exists($_temp_file)){
                $result['status'] = 'success';
                $result['msg'] = '文件已成功上传，并进入导入队列';

                //生成本次导入任务
                $params = app::get('console')->model('foreign_sku')->import_params();
                $params['read_line'] = $params['read_line']>0?$params['read_line']:1000;
                $params['name'] = '导入任务('.$files['name'].')';
                $params['type'] = 'import';
                $params['filetype'] = 'csv';
                $params['file'] = $_temp_file;
                $params['app'] = 'console';
                $params['model'] = 'foreign_sku';
                $public = array(
                    'wms_id' => $wms_id,
                );
                $params['public'] = $public;

                $task = kernel::service('service.queue.ietask');
                $task->create($params);
                $this->end(true,'上传成功!','',$result);
                exit;
            }
        }
        $this->pagedata['wms_id'] = $_GET['_params']['wms_id'];
        $this->display('admin/goodssync/create_import.html');
    }

    /**
     * 奇门同步物料
     * 
     * @return void
     * @author
     * */
    public function batchSyncDialog($wms_id)
    {
        // 根据WMS获取仓库
        $branchMdl = app::get('ome')->model('branch');

        $branchList = $branchMdl->getList('branch_bn,name',array(
            'wms_id'=>$wms_id, 
            'b_type'=>'1',
            'type' => 'main',
        ));

        $branchopts = array();
        foreach ($branchList as $key => $value) {
            $branchopts[$value['branch_bn']] = $value['name'];
        }
        $this->pagedata['branchopts'] = $branchopts;
        $_POST['wms_id'] = $wms_id;

        $this->pagedata['request_url'] = 'index.php?app=console&ctl=admin_goodssync&act=ajaxBatchSync';
        $this->pagedata['custom_html'] = $this->fetch('admin/goodssync/batch_dialog.html');

        parent::dialog_batch('console_mdl_foreign_sku');
    }

        /**
     * ajaxBatchSync
     * @return mixed 返回值
     */
    public function ajaxBatchSync()
    {
        parse_str($_POST['primary_id'], $postdata);

        if (!$postdata) { echo 'Error: 请先选择仓储商品';exit;}

        $materialMdl = app::get('console')->model("foreign_sku");
        $materialMdl->filter_use_like = true;

        $products = $materialMdl->getList('*',$postdata['f'],$postdata['f']['offset'],$postdata['f']['limit']);
        if ($products){
            $product_ids = array();
            foreach ($products as $p){
                $product_ids[] = $p['inner_product_id'];
            }
        }

        $retArr = array(
            'itotal'  => count($product_ids),
            'isucc'   => count($product_ids),
            'ifail'   => 0,
            'err_msg' => array(),
        );

        $products_sdf = kernel::single('console_goodssync')->getProductSdf($product_ids);

        kernel::single('console_goodssync')->syncProduct_notifydata($postdata['f']['wms_id'],$products_sdf,$_POST['branch_bn']);
        echo json_encode($retArr),'ok.';exit;
    }
    
    /**
     * handwork_allot
     * @return mixed 返回值
     */
    public function handwork_allot()
    {
        $product_id = $_POST['product_id'];
        $sm_id = $_POST['good_id'];
        $wms_id     = $_POST['wms_id'];

        if (!$product_id && !$sm_id) $this->splash('error',null,'请先选择商品');
        if (!$wms_id) $this->splash('error',null,'请先选择仓储');
        $data = array();
        if($product_id) {
            $products = app::get('material')->model('basic_material')->getList('bm_id,material_bn,type',array('bm_id'=>$product_id));
            foreach ($products as $key => $value) {
                $data[] = array(
                    'inner_sku'        => $value['material_bn'],
                    'inner_product_id' => $value['bm_id'],
                    'wms_id'           => $wms_id,
                    'inner_type'       => $value['type']=='4' ? '2' : '0', 
                    'combinsync_status'=> $value['type']=='4' ? '0' : '3', 
                );
            }
        }
        if($sm_id) {
            $goods = app::get('material')->model("sales_material")->getList('sm_id,sales_material_name,sales_material_bn',array('sm_id'=>$sm_id));

            foreach ($goods as $key => $value) {
                $data[] = array(
                    'inner_sku'        => $value['sales_material_bn'],
                    'inner_product_id' => $value['sm_id'],
                    'inner_type'       => '1',
                    'wms_id'           => $wms_id,
                );
            }
        }

        if ($data) app::get('console')->model('foreign_sku')->replaceinsert($data);

        $this->splash();
    }

    /**
     * sync_combination
     * @return mixed 返回值
     */
    public function sync_combination()
    {
        $filter = $_REQUEST;
        $filter['inner_type'] = array('1','2');

        $list = app::get('console')->model('foreign_sku')->getList('inner_product_id',$filter);
        $wms_id = $_GET['wms_id'];
        $this->pagedata['material_data'] = $list;
        $this->pagedata['branches'] = app::get('ome')->model('branch')->getList('*',array('wms_id'=>$wms_id));
        $this->display('admin/material/sync_combination.html');
    }

    /**
     * doSyncCombination
     * @return mixed 返回值
     */
    public function doSyncCombination() {
        $branchId = (int) $_POST['branch_id'];
        $id = (int) $_POST['id'];

        $rs = kernel::single('console_event_trigger_goodssync')->syncCombination($id, $branchId);
        echo ($rs['rsp'] == 'succ' ? '' : '同步失败：' . ($rs['err_msg']?$rs['err_msg']:$rs['msg'])) . '|ok.';
        exit();
    }

    /**
     * 同步仓储库存进度条页
     * 
     * @return void
     * @author 
     */
    public function sync_store($wms_id)
    {
        $_POST['wms_id'] = $wms_id;

        $this->pagedata['branches'] = app::get('ome')->model('branch')->getList('*',array('wms_id'=>$wms_id));

        $this->pagedata['request_url'] = 'index.php?app=console&ctl=admin_goodssync&act=ajaxSyncStore';
        $this->pagedata['custom_html'] = $this->fetch('admin/material/sync_store.html');

        parent::dialog_batch('wms_mdl_material');
    }

    /**
     * 同步仓储库存处理逻辑
     * 
     * @return void
     * @author 
     * */
    public function ajaxSyncStore()
    {
        parse_str($_POST['primary_id'], $postdata);

        if (!$postdata) { echo 'Error: 请先选择仓储商品';exit;}

        $retArr = array(
            'itotal'  => 0,
            'isucc'   => 0,
            'ifail'   => 0,
            'err_msg' => array(),
        );

        $materialMdl = app::get('material')->model("basic_material");
        $materialMdl->filter_use_like = true;

        $list = $materialMdl->getList('*',$postdata['f'],$postdata['f']['offset'],$postdata['f']['limit']);

        $branch = app::get('ome')->model('branch')->dump($_POST['branch_id']);

        $object = kernel::single('erpapi_router_request')->set('wms',$postdata['f']['wms_id']);
        foreach ($list as $value) {
            $value['branch_info'] = $branch;

            $rs = $object->goods_syncStore($value);

            if ($rs['rsp'] == 'succ') {
                $retArr['isucc']++;
            } else {
                $retArr['ifail']++;
                $retArr['err_msg'][] = $rs['msg'];
            }
        }

        echo json_encode($retArr),'ok.';exit;
    }

    /**
     * 同步商品进度条页
     * 
     * @return void
     * @author 
     */
    public function goodsGet()
    {
        $wmsId = (int)$_GET['wms_id'];

        $this->pagedata['branches'] = app::get('ome')->model('branch')->getList('*',array('wms_id'=>$wmsId));
        $this->pagedata['pre_time'] = strtotime('-1 month');
        $this->pagedata['now_time'] = time();
        $this->display('admin/material/goods_get.html');
    }

    /**
     * 同步商品处理逻辑
     * 
     * @return void
     * @author 
     * */
    public function ajaxGoodsGet()
    {
        if (!$_POST['branchId']) { echo json_encode(array('err_msg'=>'请先选择仓库'));exit;}

        $retArr = array(
            'itotal'  => 0,
            'ifail'   => 0,
            'total'   => 0,
            'scrollId'   => '',
        );
        $data = [
            'scroll_id' => $_POST['scrollId'],
            'branch_id' => $_POST['branchId'],
            'start_time' => $_POST['startTime'],
            'end_time' => $_POST['endTime'],
        ];
        $rs = kernel::single('console_event_trigger_goodssync')->syncGet($data);
        if($rs['rsp'] == 'succ') {
            $retArr['itotal'] += ($rs['succ'] + $rs['fail']);
            $retArr['ifail'] += $rs['fail'];
            $retArr['total'] = $rs['data']['total'];
            $retArr['scrollId'] = $rs['data']['scrollId'];
        } else {
            $retArr = array('err_msg'=>$rs['msg']);
        }
        echo json_encode($retArr);exit;
    }
    /**
     * 同步价格进度条页
     * 
     * @return void
     * @author 
     */
    public function syncPrice()
    {
        $_POST['wms_id'] = intval($_GET['wms_id']);

        $this->pagedata['branches'] = app::get('ome')->model('branch')->getList('*',array('wms_id'=>$_POST['wms_id']));
        $this->pagedata['request_url'] = 'index.php?app=console&ctl=admin_goodssync&act=ajaxSyncPrice';
        $this->pagedata['custom_html'] = $this->fetch('admin/material/sync_price.html');

        //调用desktop公用进度条(第4个参数是增量传offset,否则默认一直为0)
        parent::dialog_batch('console_mdl_foreign_sku', false, 10, 'incr');
    }

    /**
     * 同步价格处理逻辑
     * 
     * @return void
     * @author 
     * */
    public function ajaxSyncPrice()
    {
        parse_str($_POST['primary_id'], $postdata);

        if (!$postdata) { echo 'Error: 请先选择仓储商品';exit;}

        $retArr = array(
            'itotal'  => 0,
            'isucc'   => 0,
            'ifail'   => 0,
            'err_msg' => array(),
        );

        $foreignMdl = app::get('console')->model("foreign_sku");
        $foreignMdl->filter_use_like = true;
        $list = $foreignMdl->getList('*',$postdata['f'],$postdata['f']['offset'],$postdata['f']['limit']);
        $retArr['itotal'] = count($list);
        $rs = kernel::single('console_event_trigger_goodssync')->syncPrice($list, $_POST['branch_id']);
        if($rs['rsp'] == 'succ') {
            $retArr['isucc'] += $rs['succ'];
            $retArr['err_msg'] = $rs['error_msg'];
        } else {
            $retArr['err_msg'][] = $rs['msg'];
        }
        $retArr['ifail'] = $retArr['itotal'] - $retArr['isucc'];

        echo json_encode($retArr),'ok.';exit;
    }

        /**
     * 查找Material
     * @return mixed 返回结果
     */
    public function findMaterial() {
        $this->view_source = 'dialog';

        //只能选择可售的物料
        $base_filter['visibled'] = 1;

        $base_filter['filter_sql'] = 'bm_id not in (select inner_product_id from sdb_console_foreign_sku where wms_id="'.intval($_GET['wms_id']).'")';

        $params = array(
            'title'                  => '基础物料列表',
            'use_buildin_new_dialog' => false,
            'use_buildin_set_tag'    => false,
            'use_buildin_recycle'    => false,
            'use_buildin_export'     => false,
            'use_buildin_import'     => false,
            'use_buildin_filter'     => true,
            'base_filter'            => $base_filter,
        );
        $this->finder('material_mdl_basic_material', $params);
    }
}