inventoryidoc.java

SAP这个系统的一个转换器

          continue;
        }
        if (UpDataDispase1.insertSyInfo("upinventory", store, endtimebak,
                                        maxtime) >
            -1) {
          try {
            if (getData(store, endtimebak, maxtime)) {
              f = buildIDOC();
              try {
                if (f) {
                  suflag = UpDataDispase1.delDatainventory(store, endtimebak,
                      maxtime);
                }
              }
              catch (Exception e) {
                System.out.println("Inventory's disposeIDOC!");
              }
            }
          }
          catch (Exception ex) {
            System.out.println("upinventory's disposeIDOC is Error!");
            ex.printStackTrace();
          }
          finally {
            close();
          }
        }
      }
      disposeNotFilished();
      UpDataDispase1.delSyInfo("upinventory");
    }
    catch (Exception ex) {
      System.out.println("upinventory's disposeIDOC is Error!");
      ex.printStackTrace();
    }
    finally {
      close();
      closeconn(conn);
    }
  }

  public boolean writeidoc(String job) {
    num++;
    Vector log_vec2 = new Vector();
    String idoc_message = "";
    boolean f = false;
    if (Tv.size() > 0) {
      f = writeSAP.writeTxtData(Tv, "inventory" + time + num + ".txt",
                                "inventory");
      log_vec2.add(0, store);
      log_vec2.add(1, "upinventory" + endtimebak);
      log_vec2.add(2, "inventory" + time + num + ".txt");
      log_vec2.add(3, "upinventory");
      log_vec2.add(4, "");
      log_vec2.add(5, "in");
      log_vec2.add(6, "盘点上传文件生成失败！");
      log_vec2.add(7, "getDate()");
      log_vec2.add(8, "1"); // String.valueOf(i));
      log_vec2.add(9, "0");
      log_vec2.add(10, "0");
      if (f) {
        log_vec2.setElementAt("1", 9);
        log_vec2.setElementAt("盘点上传文件生成成功！", 6);
        try {
          log.WriteLog(log_vec2);
        }
        catch (Exception ex) {
          System.out.println("InventoryIDOC's writelog is Error!");
          ex.printStackTrace();
        }
      }
      else {
        try {
          log.WriteLog(log_vec2);
          return false;
        }
        catch (Exception ex) {
          System.out.println("InventoryIDOC's writelog is Error!");
          ex.printStackTrace();
        }
      }

      /*      if (job.equalsIgnoreCase("idoc")) {
              idoc_message = writeSAP.writeSAPIdoc("inventory",
           "inventory" + time + num + ".txt",
                                                   "idoc");
              idoc_message = Operate1.escape(idoc_message);
              log_vec2.setElementAt(idoc_message, 6);
              try {
                log.WriteLog(log_vec2);
           if (idoc_message == null || idoc_message.equalsIgnoreCase("null") ||
                    idoc_message.equalsIgnoreCase("")) {
                  return false;
                }
              }
              catch (Exception ex) {
                System.out.println("inventory's writeidoc is Error!");
                ex.printStackTrace();
              }
            }
            if (job.equalsIgnoreCase("trigger")) {
              idoc_message = writeSAP.writeSAPIdoc("inventory",
           "inventory" + time + num + ".txt",
                                                   "idoc");
              idoc_message = Operate1.escape(idoc_message);
              log_vec2.setElementAt(idoc_message, 6);
              log_vec2.setElementAt("1", 8);
              try {
                log.WriteLog(log_vec2);
           if (idoc_message == null || idoc_message.equalsIgnoreCase("null") ||
                    idoc_message.equalsIgnoreCase("")) {
                  return false;
                }
              }
              catch (Exception ex) {
                System.out.println("inventory's writeidoc is Error!");
                ex.printStackTrace();
              }
              /*
                      idoc_message = writeSAP.writeSAPIdoc("inventory",
                    "inventory" + time + num + ".txt",
                                                           "trigger");
                      idoc_message = Operate1.escape(idoc_message);
                      log_vec2.setElementAt(idoc_message, 6);
                      log_vec2.setElementAt("1", 8);
                      try {
                        log.WriteLog(log_vec2);
                if (idoc_message == null||idoc_message.equalsIgnoreCase("null")||idoc_message.equalsIgnoreCase("")) {
                              return false;
                            }
                      }
                      catch (Exception ex) {
                        System.out.println("inventory's writeidoc is Error!");
                        ex.printStackTrace();
                      }
             }*/
    }
    return f;
  }

//处理配置表中所有未完成的记录
  /**@todo Implement this com.idoc.face.InterfaceIDOC method*/
  public void disposeNotFilished() {
    boolean suflag = false;
    String endtime = "";
    String[][] str = UpDataDispase1.getNotFilishedSyInfo("upinventory");
    try {
      for (int j = 0; j < str.length; j++) {
        store = str[j][0];
        time = str[j][1];
        endtime = str[j][2];
        endtimebak = time;
        if (endtime == null || endtime.equalsIgnoreCase("null") ||
            endtime.equalsIgnoreCase("")) {
          continue;
        }
        try {
          if (getData(store, endtimebak, endtime)) {
            if (this.buildIDOC()) {
              suflag = UpDataDispase1.delDatainventory(store, endtimebak,
                  endtime);
            }
          }
        }
        catch (Exception e) {
          System.out.println("disposeNotFilished's writelog is Error!");
          e.printStackTrace();
        }
        finally {
          close();
        }
      }
    }
    catch (Exception e) {
      System.out.println("disposeNotFilished's writelog is Error!");
      e.printStackTrace();
    }
  }

  public boolean getData(String storecode, String startime, String endtime) {
    LogManager log = new LogManager();
    Vector log_vec2 = new Vector();
    String wheresql = "";
    String invsql = "";
    if (startime.equalsIgnoreCase("") || startime.equalsIgnoreCase("null")) {
      wheresql = " where STORECODE='" + storecode +
          "' and convert(bigint,update_time)<='" + endtime + "' ";
    }
    else {
      wheresql = " where STORECODE='" + storecode + "' and  '" + startime +
          "'< convert(bigint,update_time) and convert(bigint,update_time)<='" +
          endtime + "'";
    }
    try {
      stmt1 = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,
                                   ResultSet.CONCUR_READ_ONLY);
      invsql = "select Check_voucher_Code,Check_year,Check_time,Check_SAP_No,STORECODE,Storage_Site,Merch_CODE,"
          +
          "Merch_type,Stock_Amount,Fact_Amount,COMP_UNIT from sapout_sy_checklist_down" +
          wheresql;
      rowSet1 = stmt1.executeQuery(invsql);
      rowSet1.last();
      int num = rowSet1.getRow();
      rowSet1.beforeFirst();
      log_vec2.add(0, storecode);
      log_vec2.add(1, "upinventory" + startime);
      log_vec2.add(2, "");
      log_vec2.add(3, "upinventory");
      log_vec2.add(4, "sapout_sy_checklist_down");
      log_vec2.add(5, "in");
      log_vec2.add(6, "从表sapout_sy_checklist_down中取数成功");
      log_vec2.add(7, "getDate()");
      log_vec2.add(8, String.valueOf(num));
      log_vec2.add(9, "1");
      log_vec2.add(10, "0");
      log.WriteLog(log_vec2);
    }
    catch (Exception e) {
      close();
      e.printStackTrace();
      log_vec2.setElementAt(
          "从表sapout_sy_checklist_down中取数失败！", 6);
      log_vec2.setElementAt("0", 9);
      log.WriteLog(log_vec2);

      return false;
    }
    return true;
  }

  public void close() {
    try {
      if (rowSet1 != null) {
        rowSet1.close();
        rowSet1 = null;
      }
      if (stmt1 != null) {
        stmt1.close();
        stmt1 = null;
      }

    }
    catch (Exception e) {
      System.out.println("close");
      e.printStackTrace();
    }
  }

  private void closeconn(Connection conn) {
    try {
      if (conn != null) {
        conn.close();
        conn = null;
      }
    }
    catch (Exception ex) {
      System.out.println("closeconn");
      ex.printStackTrace();
    }
  }

}