詳解SpringBoot如何實(shí)現(xiàn)一個(gè)實(shí)時(shí)更新的進(jìn)度條

<div class="progress progress-striped active">
  <div class="progress-bar progress-bar-success" role="progressbar"
     aria-valuenow="60" aria-valuemin="0" aria-valuemax="100"
     >
    40%
  </div>
</div>

//點(diǎn)擊確認(rèn)導(dǎo)入執(zhí)行此方法
function bulkImportChanges() {
  //獲取批量操作狀態(tài)文件
  var files = $("#importChanges").prop("files");
  var changesFile = files[0];
  var formData = new FormData();
  formData.append("importFile",changesFile);
  $.ajax({
    type : 'post',
    url : "/risk/bulk***es",
    data : formData,
    processData : false,   //文件ajax上傳要加這兩個(gè)的，要不然上傳不了
    contentType : false,   //
    success : function(obj) {
      //導(dǎo)入成功
      if (obj.rspCode == "00") {
        //定時(shí)任務(wù)獲取redis導(dǎo)入修改進(jìn)度
        var progress = "";
        var timingTask = setInterval(function(){
          $.ajax({
            type: 'post',
            url: "/risk/t***k",
            dataType : 'json',
            success: function(result) {
              progress = result.value;
              if (progress != "error"){
                var date = progress.substring(0,6);
                //這里更新進(jìn)度條的進(jìn)度和數(shù)據(jù)
                $(".progress-bar").width(parseFloat(date)+"%");
                $(".progress-bar").text(parseFloat(date)+"%");
              }
            }
          });
          //導(dǎo)入修改完成或異常（停止定時(shí)任務(wù)）
          if (parseInt(progress)==100 || progress == "error") {
            //清除定時(shí)執(zhí)行
            clearInterval(timingTask);
            $.ajax({
              type: 'post',
              url: "/risk/de***ess",
              dataType : 'json',
              success: function(result) {
                $("#bulkImportChangesProcessor").hide();
                if (parseInt(progress) == 100) {
                  alert("批量導(dǎo)入修改狀態(tài)成功");
                }
                if (progress == "error") {
                  alert("批量導(dǎo)入修改狀態(tài)失敗");
                }
                //獲取最新數(shù)據(jù)
                window.location.href="/risk/re***ByParam" rel="external nofollow" rel="external nofollow" ;
              }
            });
          }
        }, 1000)
      }else {
        $("#bulkImportChangesProcessor").hide();
        alert(obj.rspMsg);
        window.location.href="/risk/re***ByParam" rel="external nofollow" rel="external nofollow" ;
      }
    }
  });
}

/**
 * 退單管理批量修改狀態(tài)導(dǎo)入文件
 * @param importFile
 * @return
 */
 @ResponseBody
 @RequestMapping("/bulk***es")
 public Map<String,Object> bulk***es(MultipartFile importFile){
   log.info("退單管理批量修改狀態(tài)導(dǎo)入文件，傳入?yún)?shù)："+importFile);
 Map<String,Object> map = new HashMap<>();
 List<Bulk***esEntity> fromExcel = null;
 try{
      //使用工具類導(dǎo)入轉(zhuǎn)成list
  String[] header = {"sy***um","t***mt","ha***ult","re***nd","sy***nd","r**k"};
  fromExcel = importExcelUtil.importDataFromExcel(importFile, header, BulkImportChangesEntity.class);
  if (fromExcel.size()==0){
  map.put("rspCode","99");
  map.put("rspMsg","導(dǎo)入數(shù)據(jù)不能為空");
  return map;
  }
 }catch (Exception e){
  map.put("rspCode","99");
  map.put("rspMsg","導(dǎo)入操作表失敗,請注意數(shù)據(jù)列格式");
  return map;
 }
 try {
  //這里會對list集合中的數(shù)據(jù)進(jìn)行處理

  log.info("調(diào)用服務(wù)開始，參數(shù)："+JSON.toJSONString(fromExcel));
  //String url = p4_zuul_url+"/***/ri***eat/bu***nges";
  String url = p4_zuul_url+"/***-surpass/ri***eat/bu***nges";
  String result = HttpClientUtil.doPost(url,JSON.toJSONString(fromExcel));
  log.info("調(diào)用服務(wù)結(jié)束，返回?cái)?shù)據(jù)："+result);
  if (result != null){
  map = JSONObject.parseObject(result, Map.class);
  log.info("批量修改狀態(tài)導(dǎo)入："+JSON.toJSONString(map));
  }
 }catch (Exception e){
  map.put("rspCode","99");
  map.put("rspMsg","導(dǎo)入操作表失敗");
  log.info("bu***es exception",e);
  return map;
 }
 return map;
 }

 /**
 * 獲取退單管理批量修改狀態(tài)導(dǎo)入文件進(jìn)度條進(jìn)度
 * @return
 */
 @ResponseBody
 @RequestMapping("/t***sk")
 public Map<String,Object> t***sk(){
 Map<String,Object> map = new HashMap<>();
    //獲取redis值
 String progress = HttpClientUtil.doGet(
  p4_zuul_url + "/" + p4_redis + "/redis***ler/get&#63;key=progressSchedule");
 if (progress != null){
  map = JSONObject.parseObject(progress, Map.class);
  log.info("進(jìn)度條進(jìn)度："+JSON.toJSONString(map));
  map.put("progressSchedule",progress);
 }else {
  HttpClientUtil.doGet(
   p4_zuul_url + "/" + p4_redis + "/redis***ler/del&#63;key=progressSchedule");
 }
 return map;
 }

 /**
 * 清除redis進(jìn)度條進(jìn)度
 * @return
 */
 @ResponseBody
 @RequestMapping("/de***ess")
 public Map<String,Object> de***ess(){
 Map<String,Object> map = new HashMap<>();
 String progress = HttpClientUtil.doGet(
  p4_zuul_url + "/" + p4_redis + "/redis***ler/del&#63;key=progressSchedule");
 if (progress != null){
  map = JSONObject.parseObject(progress, Map.class);
  log.info("返回?cái)?shù)據(jù)："+JSON.toJSONString(map));
 }
 return map;
 }

@Async//開啟異步
 @Transactional(rollbackFor = Exception.class)//事務(wù)回滾級別
 @Override
 public void bulkImportChanges(List<BulkImportChangesParam> list) {
 //初始化進(jìn)度
 Double progressBarSchedule = 0.0;
 redisClient.set("progressSchedule", progressBarSchedule + "");//存redis
 try {
  for (int i = 1; i <= list.size(); i++) {
  RiskRetreatEntity entity = riskRetreatMapper.selectRetreatListBySysRefNum(list.get(i-1).getSysRefNum());
  if (entity == null){
   //查詢結(jié)果為空直接進(jìn)行下次循環(huán)不拋出
   continue;
  }
  //實(shí)體封裝
        ···
        //更新
  riskRetreatMapper.updateRetreatByImport(entity);
  //計(jì)算修改進(jìn)度并存放redis保存(1.0 / list.size())為一條數(shù)據(jù)進(jìn)度
  progressBarSchedule = (1.0 / list.size()) * i*100;
  redisClient.set("progressSchedule", progressBarSchedule+"");
  if (i==list.size()){
   redisClient.set("progressSchedule", "100");
  }
  }
 }catch (Exception e){
  //當(dāng)發(fā)生錯(cuò)誤則清除緩存直接拋出回滾
  redisClient.set("progressSchedule","error");
  log.info("導(dǎo)入更新錯(cuò)誤，回滾");
  log.info("bulkImportChanges exception:",e);
  throw e;
 }
 }

@EnableAsync
···//其他注解
public class Application {
  public static void main(String[] args) {
    SpringApplication.run(Application.class, args);
  }
}