Spring定時(shí)任務(wù)輪詢本地?cái)?shù)據(jù)庫實(shí)現(xiàn)過程解析

@Component
public class SendDataTask {
  
  
  
  @Autowired
  WorkFlowService workFlowServiceImpl;

  
  //首次推送待審
  @Scheduled(cron = "0 */1 * * * ?") // 間隔一分鐘執(zhí)行
  public void taskCycle() throws UnsupportedEncodingException {
    
    

    
    

    //第一次推送任務(wù)(產(chǎn)生任務(wù)),產(chǎn)生新任務(wù)則產(chǎn)生審批人,還需要取消掉沒有認(rèn)領(lǐng)任務(wù)的審批人的消息
    List<ToDoTaskModel> list = workFlowServiceImpl.getToDoTaskInfoBySendStatus("0","100");
    ToDoTaskModel toDoTaskModel = new ToDoTaskModel();
    for (int i = 0; i < list.size(); i++) {
      toDoTaskModel = list.get(i);
      //自拼title
      //根據(jù)workflowID 判斷拼接url
      String taskID = toDoTaskModel.getTaskID();
      String realTaskID = ChangeTaskIDUitl.changeTaskIDUitl(taskID);
      String workflowID = toDoTaskModel.getWorkflowID();
      String docID = toDoTaskModel.getDocID();
      String title = "您有一條新的待審任務(wù)" + toDoTaskModel.getTodoTitle() +"等待審批";
      String taskStatus = "1";
      String submitorID = toDoTaskModel.getSubmitorID();
      String loginName = workFlowServiceImpl.getLoginName(submitorID);
      String submitorName = toDoTaskModel.getSubmitorName();
      String submitDateTime = toDoTaskModel.getSubmitDateTime();
      String openUrl = null;
      String beforeUrl = "http://oa20.cctv.com/";
      String afterUrl = "/myWork/workWait/gwWeChatWait.do?instanceId=";      
      //5合同
      if(workflowID.equals("5")){
        openUrl = beforeUrl + "HT_WeChat" + afterUrl +docID +"&workflowId="+workflowID;
      }else{
        openUrl = beforeUrl + "GW_WeChat" + afterUrl +docID +"&workflowId="+workflowID;
      }    
      String sendStatus = toDoTaskModel.getSendStatus();
      
      //查詢審批人的真實(shí)ID
      //根據(jù)docid 和taskstatus =40 來查審批者的submitorID 然后根據(jù)這個(gè)來查真實(shí)工號
      
      //獲取數(shù)據(jù)庫查詢的 當(dāng)前審批層級信息
      List<ThisLevelInfoModel> tlist = toDoTaskModel.getThisLevelInfoList();
      //new一個(gè)移動端要的格式的模型
      List<ApproverPOJO> approverList = new ArrayList<ApproverPOJO>();
      ApproverPOJO approverPOJO = new ApproverPOJO();
      for (int j = 0; j < tlist.size(); j++) {

        String realApproverID = workFlowServiceImpl.getLoginName(tlist.get(j).getApproverID());
        approverPOJO.setDocID(tlist.get(j).getDocID());
        approverPOJO.setApproverName(tlist.get(j).getApproverName());
        approverPOJO.setApproverID(realApproverID);
        approverList.add(approverPOJO);
      }
      //ToDoTaskPOJO里的最高層對象(list(模型))
      ThisLevelInfoPOJO thisLevelInfoPOJO = new ThisLevelInfoPOJO();
      thisLevelInfoPOJO.setApproverList(approverList);
      
      ToDoTaskPOJO toDoTaskPOJO = new ToDoTaskPOJO(realTaskID,workflowID,docID,title,taskStatus,
          loginName,submitorName,submitDateTime,openUrl,sendStatus,thisLevelInfoPOJO);
      
      JSONObject jsonObject= JSONObject.fromObject(toDoTaskPOJO);
    
      String jsonStr = HttpClinet.doPost(jsonObject);
      JSONObject jsonCode = JSONObject.fromObject(jsonStr);
      
      
      if("0".equals(jsonCode.get("errCode"))) {
        //這要加判斷? 是否是終審人? 條件:提交人工號=審核人工號時(shí) 該審批層級未最終審批????        
        //或者終審層級 有沒有審核人 如果沒有 移動端返回錯(cuò)誤碼 
        if (workFlowServiceImpl.isFirstSend() == 1) {
          workFlowServiceImpl.updateSendStatus("2", taskID);
        }else{
        workFlowServiceImpl.updateSendStatus("1", taskID);}
      }else if("當(dāng)前層級待審人不能為空".equals(jsonCode.get("errDesc"))){
        workFlowServiceImpl.updateSendStatus("1", taskID);
      }
      
  /*_____________________________________________________________________________________*/    
      
      //查詢舊表該docID下的所有taskID 并將(taskID和docID)插入新表
      //先查詢docID下所有的taskID
      List<String> taskIDList = new ArrayList<String>();
        taskIDList = workFlowServiceImpl.selectAllByDocID(docID);
      for (int j = 0; j < taskIDList.size(); j++) {
        //想新表插入所有taskID和docID
        workFlowServiceImpl.creatAllInfo(taskIDList.get(j), docID);  
      }
      
      TaskStatusPOJO taskStatusPOJO = new TaskStatusPOJO();
      
      //查詢新表和舊表 對比 舊表不存在二新表存在的taskID 通過第二個(gè)url推送給WeChat端,刪掉消息
      List<String> invalidList = new ArrayList<String>();
      invalidList = workFlowServiceImpl.SelectInvalidApprover();
      String invalidTaskID = null;
      for (int j = 0; j < invalidList.size(); j++) {
        invalidTaskID = ChangeTaskIDUitl.changeTaskIDUitl(invalidList.get(j));
        taskStatusPOJO.setTaskID(invalidTaskID);
        taskStatusPOJO.setTaskStatus("2");
        JSONObject jsonObj= JSONObject.fromObject(taskStatusPOJO);
        HttpSecondSend.doPost(jsonObj);
      }

      
    }
    
    //第二個(gè)接口 告訴當(dāng)前待辦人審批完結(jié)

    List<TaskStatusPOJO> secondList = workFlowServiceImpl.getNewStatus("1","100");
    TaskStatusPOJO taskStatusPOJO = new TaskStatusPOJO();
    for (int i = 0; i < secondList.size(); i++) {
      String dID = secondList.get(i).getTaskID();
      String docID = secondList.get(i).getOnlyDocID();
      String realTaskID =ChangeTaskIDUitl.changeTaskIDUitl(workFlowServiceImpl.getTrueTaskID(docID));        
        taskStatusPOJO.setTaskID(realTaskID);
        taskStatusPOJO.setTaskStatus("2");
        JSONObject jsonObject= JSONObject.fromObject(taskStatusPOJO);
        String Str = HttpSecondSend.doPost(jsonObject);
        JSONObject json = JSONObject.fromObject(Str);
        if ("0".equals(json.get("errCode"))) {
          workFlowServiceImpl.updateSendStatus("2", dID);      
      }        
    }    
  }
}