探索php+ajax实现带进度条的大数据排队导出思路

探索php+ajax实现带进度条的大数据排队导出思路

废话不多说,先上效果图:

探索php+ajax实现带进度条的大数据排队导出思路

点击导出,实现

探索php+ajax实现带进度条的大数据排队导出思路

点击导出

探索php+ajax实现带进度条的大数据排队导出思路

统计完成之后

探索php+ajax实现带进度条的大数据排队导出思路

点击确定

探索php+ajax实现带进度条的大数据排队导出思路

下面来谈谈实现的思路:

前面导出操作简单,从第二个导出操作开始:

点击"确定"调用exportCsv函数

代码如下:

<a class="on" href="javascript:exportCsv();"><em>导出</em></a>
exportCvs函数如下
function exportCsv()
{
 //清除等待的转动圈
    $('#loading').html('');
 //弹出统计总数对话框,函数在后面给出定义
    tip();
//ajax请求总数
    $.post("<?php echo WEB_URL;?>/index.php?q=onlinesea/getwherecount"+search_uri, function(json){
        var return_arr = eval('(' + json + ')');
        var num = return_arr['total'];
        var processnum = return_arr['processnum'];
        if(num == 0){
            poptip.title('系统消息');
            poptip.content('查询结果为空,不能进行数据导出');
        }
        else
        {
            poptip.close();
            for (var i in return_arr['cntarr']){
                if (return_arr['cntarr'][i] != 0){
                    count_arr[i] = return_arr['cntarr'][i];
                }
            }
            var ii=0;
            for (var i in count_arr){
                  type_arr[ii]=i;
                  ii++;
            }
//当数据不为空的时候弹出是否到处框
            exportCsvConfirm(num, processnum);
        }
    });
}
 
//弹出确认下载  exportCsvConfirm函数
function exportCsvConfirm(num, processnum)
{
    var msg = '需要导出的数据有 <span style="color: red">' + num + '</span> 行,可能会占用您较多时间来进行导出。<br />您还需要继续吗?';
   // 提示是否继续
    $.dialog.confirm(msg, function () {
        $('#loading').html('');
        processed_count = 0;
        index = 1;
        win.$('#process_bg').hide().width('0%').show();
        win.$('#process_num').html('0');
        $.dialog.through({
            title: '数据导出进度',
            content: win.document.getElementById('processbar'),
            lock: true,
            opacity: '.1'
        },
        function(){
                window.location.reload();
        });
       //当继续的时候
        win.$('#progress_info').show().text('正在导出数据,请耐心等待,请勿关闭窗口...');
      //开始执行导出操作
        excel_export2(num, processnum);
    });
}

关键函数excel_export2队列请求,首先会在前面定义全局变量

代码如下:

var search_uri = "<?php echo $uri;?>";
var event = "<?php echo $event;?>";
var processed_count = 0;    // 已处理的数据条数
var index = 1;
var iii   = 0;
var ajaxmark = 1;
var win = $.dialog.parent;    // 顶层页面window对象
var count_arr = new Array(<?php echo count($this->tables);?>);
var type_arr = new Array();

我们要定义全局变量 index 和iii ,ajaxmark ,index主要用于对一个表数据太多的时候进行分批导出 ,iii用来控制队列循环,ajaxmark用来判断前一个请求是否执行成功了,成功的话在执行下面的请求

代码如下:

function excel_export2(num, processnum){
      //获取tabletype
      tabletype=type_arr[iii];
     //获取总数
      num = count_arr[tabletype];
    //判断是否数组是否执行完毕
      if(typeof(tabletype)=='undefined'&&typeof(num)=='undefined'){
            return false;
      }
     //判断是否有上一个ajax请求是否完成
      if(ajaxmark==1){
            index = 1;
           //将ajax请求标记为未执行完成
ajaxmark=2;
          //执行ajax请求,函数在后面给出
            retrun_var = excel_export_ajax(index, num, processnum, tabletype);
            //判断函数返回
            if(typeof(retrun_var)=='undefined'){           
//将iii自增,执行下一个数组数据
                  iii++;
//递归调用自己
                  excel_export2(num, processnum);
                  if(iii>100){
                        return false;
                  }
//当ajax返回成功的时候,返回。
            }else if(retrun_var=='success'){
                  return false;
            }
            return false;
      }else{
            //setTimeout(excel_export2(num, processnum),3000);
            //setInterval(_excel_export2(num, processnum),3000);
//每隔3秒检查是否ajax请求结束,这里settimeout 不能传递参数,只能通过_excel_export2这种形式
            setTimeout(_excel_export2(num, processnum),3000);
      }
}
function _excel_export2(num, processnum){
       return function(){
             excel_export2(num, processnum);
       }
}
 
//excel_export_ajax函数  执行导出
/* AJAX,递归调用 */
function excel_export_ajax(index, num, processnum, tabletype)
{
    $.ajax({
        url: "<?php echo WEB_URL;?>/index.php?q=onlinesea/exportcsv"+search_uri+"/index/"+index+ "/total/" + num + '/tabletype/' + tabletype,
        type: 'GET',
        success: function(data)
        {
//执行次数自增
            ++processed_count;
//当一个表数据太多,分批导出
            ++index;
            // 更新进度条
//判断进度
            var process_num = parseInt((processed_count / processnum) * 100);

            if (process_num >= 100)
            {
                process_num = 100;
            }
//跟新进度条
            update_process(process_num);
            //alert(processed_count+'--'+processnum);
//当执行结束
            if (processed_count >= processnum)
            {
//压缩文件
                backup_compress();
                return 'success';
            }
            if (data == '0'){
//将ajax请求标记为执行完毕,执行下一个url请求
                ajaxmark=1;
                return false;
            }
            当一个表的数据未导出完成的时候,会循环调用自己去请求, php函数或判断是否到处完成,导出完成返回0  ,未完成返回1
            excel_export_ajax(index, num, processnum, tabletype);
        }
    });
}
/* 备份文件执行压缩 */
function backup_compress()
{
    win.$('#progress_info').text('正在生成压缩文件...');
    $.ajax({
        url: "<?php echo WEB_URL;?>/index.php?q=onlinesea/compress/event/<?php echo $event;?>",
        success: function(msg){
            win.$('#process_bg').show().width('100%');
            win.$('#process_num').html('100');
            win.$('#progress_info').html('导出数据完成。&nbsp;&nbsp;<a href="' + msg + '" style="color: #006699; text-decoration: underline">下载文件</a>');
        }
    });
}
/* 更新进度条 */
function update_process(process_num)
{
    win.$('#process_bg').show().width(process_num + '%');
    win.$('#process_num').html(process_num);
}

下面附上源码,咳咳相关php程序大家自己脑补下吧

代码如下:

<script type="text/javascript" language="javascript">
var search_uri = "<?php echo $uri;?>";
var event = "<?php echo $event;?>";
var processed_count = 0;    // 已处理的数据条数
var index = 1;
var iii   = 0;
var ajaxmark = 1;
var win = $.dialog.parent;    // 顶层页面window对象
var count_arr = new Array(<?php echo count($this->tables);?>);
var type_arr = new Array();
function exportCsv()
{
    $('#loading').html('');
    tip();
    $.post("<?php echo WEB_URL;?>/index.php?q=onlinesea/getwherecount"+search_uri, function(json){
        var return_arr = eval('(' + json + ')');
        var num = return_arr['total'];
        var processnum = return_arr['processnum'];
        if(num == 0){
            poptip.title('系统消息');
            poptip.content('查询结果为空,不能进行数据导出');
        }
        else
        {
            poptip.close();
            for (var i in return_arr['cntarr']){
                if (return_arr['cntarr'][i] != 0){
                    count_arr[i] = return_arr['cntarr'][i];
                }
            }
            var ii=0;
            for (var i in count_arr){
                  type_arr[ii]=i;
                  ii++;
            }
            exportCsvConfirm(num, processnum);
        }
    });
}
function exportCsvConfirm(num, processnum)
{
    var msg = '需要导出的数据有 <span style="color: red">' + num + '</span> 行,可能会占用您较多时间来进行导出。<br />您还需要继续吗?';
    $.dialog.confirm(msg, function () {
        $('#loading').html('');
        processed_count = 0;
        index = 1;
        win.$('#process_bg').hide().width('0%').show();
        win.$('#process_num').html('0');
        $.dialog.through({
            title: '数据导出进度',
            content: win.document.getElementById('processbar'),
            lock: true,
            opacity: '.1'
        },
        function(){
                window.location.reload();
        });
        win.$('#progress_info').show().text('正在导出数据,请耐心等待,请勿关闭窗口...');
        excel_export2(num, processnum);
    });
}
function excel_export2(num, processnum){
      tabletype=type_arr[iii];
      num = count_arr[tabletype];
      if(typeof(tabletype)=='undefined'&&typeof(num)=='undefined'){
            return false;
      }
      if(ajaxmark==1){
            index = 1;
            ajaxmark=2;
            retrun_var = excel_export_ajax(index, num, processnum, tabletype);
            if(typeof(retrun_var)=='undefined'){            
                  iii++;
                  excel_export2(num, processnum);
                  if(iii>100){
                        return false;
                  }
            }else if(retrun_var=='success'){
                  return false;
            }
            return false;
      }else{
            //setTimeout(excel_export2(num, processnum),3000);
            //setInterval(_excel_export2(num, processnum),3000);
            setTimeout(_excel_export2(num, processnum),3000);
      }
}
function _excel_export2(num, processnum){
       return function(){
             excel_export2(num, processnum);
       }
}
/* 执行导出 */
function excel_export(num, processnum){
    var retrun_var = 'ss';
    for (var i in count_arr){
        num = count_arr[i];
        tabletype = i;
        index = 1;
        retrun_var = excel_export_ajax(index, num, processnum, tabletype);
        if(typeof(retrun_var)=='undefined'){
            //alert('xxxx');
            setTimeout(function(){exit;},5000);
        }
        if (retrun_var == 'success')
        {
            return false;
        }
    }
    return false;
}
/* AJAX,递归调用 */
function excel_export_ajax(index, num, processnum, tabletype)
{
    $.ajax({
        url: "<?php echo WEB_URL;?>/index.php?q=onlinesea/exportcsv"+search_uri+"/index/"+index+ "/total/" + num + '/tabletype/' + tabletype,
        type: 'GET',
        success: function(data)
        {
            ++processed_count;
            ++index;
            // 更新进度条
            var process_num = parseInt((processed_count / processnum) * 100);
            if (process_num >= 100)
            {
                process_num = 100;
            }
            update_process(process_num);
            //alert(processed_count+'--'+processnum);
            if (processed_count >= processnum)
            {
                backup_compress();
                return 'success';
            }
            if (data == '0'){
                ajaxmark=1;
                return false;
            }
            excel_export_ajax(index, num, processnum, tabletype);
        }
    });
}
/* 更新进度条 */
function update_process(process_num)
{
    win.$('#process_bg').show().width(process_num + '%');
    win.$('#process_num').html(process_num);
}
/* 备份文件执行压缩 */
function backup_compress()
{
    win.$('#progress_info').text('正在生成压缩文件...');
    $.ajax({
        url: "<?php echo WEB_URL;?>/index.php?q=onlinesea/compress/event/<?php echo $event;?>",
        success: function(msg){
            win.$('#process_bg').show().width('100%');
            win.$('#process_num').html('100');
            win.$('#progress_info').html('导出数据完成。&nbsp;&nbsp;<a href="' + msg + '" style="color: #006699; text-decoration: underline">下载文件</a>');
        }
    });
}
function tip()
{
    poptip = $.dialog.through({
        id: 'tip',
        title: '系统消息',
        content: '正在统计总数,请勿关闭窗口&nbsp;&nbsp;<img src="http://images.cnblogs.com/loading_s.gif" />',
        width: 300,
        height: 100,
        icon: 'system',
        lock: true,
        opacity: .1
    },
    function(){
        window.location.reload();
    });
    poptip.show();
}
function packetDelete(url,msg)
{
    $.dialog.confirm(msg, function () {
        $.post(url, function(data){
          if(data == '1'){
              $.dialog('删除成功', function(){window.location.reload();});
          }
          else if(data == '2'){
            $.dialog('删除失败', function(){window.location.reload();});
          }
          else if(data == '3'){
            $.dialog('文件不存在,或者已删除', function(){window.location.reload();});
          }
      });
     });
}
</script>

关于探索php+ajax实现带进度条的大数据排队导出思路的文章就分享到这,如果对你有帮助欢迎继续关注我们哦

本文来自投稿,不代表重蔚自留地立场,如若转载,请注明出处https://www.cwhello.com/40420.html

如有侵犯您的合法权益请发邮件951076433@qq.com联系删除

(0)
php学习php学习订阅用户
上一篇 2022年6月12日 22:57
下一篇 2022年6月12日 22:57

相关推荐

  • 十个PHP安全的必备技巧

    你好,PHP 开发人员。 在这篇文章中,我将尝试为你提供一些可以提高 PHP 应用程序安全性的具体步骤。我关注的是 PHP 配置本身,所以我们不会讨论 SQL 注入、HTTPS 或其他与 PHP 无关的问题。 我将使用我的docker-en…

    2022年6月21日
    0118
  • PHP中如何进行分布式事务处理?

    随着互联网应用的不断发展,分布式系统已经越来越普遍。在分布式系统中,一个事务可能会涉及多个组件或服务,这就带来了分布式事务处理的问题。PHP作为一门常用的服务器端编程语言,也需要解决分布式事务处理问题。…

    2023年5月17日
    05
  • 聊聊php数组排序的函数有哪些。

    以下是 PHP 数组排序函数的列表:,,- sort() – 对数组进行升序排列,- rsort() – 对数组进行降序排列,- asort() – 根据关联数组的值,对数组进行升序排列,- ksort() – 根据关联数组的…

    2024年7月13日
    00
  • PHP8函数:str_contains()的新用途。

    PHP 8是一款功能更强大的编程语言,它引入了许多新的函数和特性,其中之一就是str_contains()函数。str_contains()函数主要用于检查字符串中是否包含指定的子字符串,它可以用于各种不同的应用程序中,例如搜索引擎…

    2023年5月21日
    04
  • PHP入门指南:计算机网络。

    计算机网络是当今掌握互联网技术必备的基础知识之一。PHP作为一种常用于网站开发的脚本语言,也需要深入理解网络知识。本篇文章将带您一步步了解计算机网络的基础知识与PHP的应用。 一、计算机网络基础知识 网络的…

    2023年5月22日
    00
  • php之管理全局状态

    管理全局状态 在命令式语言中总是需要一些全局空间。在编程 PHP 或扩展时,我们将明确区分我们所称的请求绑定全局变量和真正的全局变量。 请求全局变量是处理请求过程中需要携带和记忆信息的全局变量。一个简单的例…

    2022年6月12日
    0117
  • PHP实现Redis主从复制自动切换的方法。

    Redis是一款非常流行的键值对存储数据库,在现代Web应用中扮演着至关重要的角色。为了保证Redis的高可用性和稳定性,通常需要使用主从复制的技术。同时,由于主节点故障时需要自动切换到备用节点,使得复制集群具有…

    2023年5月21日
    03
  • 初学php,你遇到过这个低级问题吗?

    开发环境: windows7 ,mysql,php5.6,nginx 遇到的问题: 我把php解压到D盘program files中,用php-cgi.exe -b 127.0.0.1:9000 -c d:/Program Files/php/php.ini 将php运行起来。同时用nginx将php的网站发布。 当…

    2022年6月25日
    0120

联系我们

QQ:951076433

在线咨询:点击这里给我发消息邮件:951076433@qq.com工作时间:周一至周五,9:30-18:30,节假日休息