termtaskdataanalys.java

通讯采集软件

package collector.gui.model;

import java.util.*;

import collector.common.*;
import pbs.service.vo.*;

/**
 *
 * @author  dljf
 */
/*
 *                    "终端号","终端名","任务类型","当前通道类型","当前状态","机器名","追补电量类型",
                     "追补信息","功能码","操作类型","任务起始时间","任务结束时间","计量终端类型",
                    "任务优先级","任务绑定前置机","网络地址","当前通道","任务序号"
 */

public class TermTaskDataAnalys {
  public TermTaskDataAnalys() {
  }

  public Object[] AnalysTermTaskData(Object p_Object) {
    if (! (p_Object instanceof TermTaskInfo)) {
      return null;
    }

    TermTaskInfo m_TermTaskInfo = (TermTaskInfo) p_Object;
    Object[] m_Object = new Object[18];
    m_Object[0] = new Integer(m_TermTaskInfo.getTerminalNo());
    m_Object[1] = m_TermTaskInfo.getTerminalName();
    int tasktype = m_TermTaskInfo.getTaskType();
    switch (tasktype) {
      case CollectorDefine.ONTIME_TASK:
        m_Object[2] = "定时任务";
        break;
      case CollectorDefine.SERVER_TASK:
        m_Object[2] = "召唤任务";
        break;
      case CollectorDefine.ONTIME_SERVER_TASK:
        m_Object[2] = "定时召唤任务";
        break;
      default:
        m_Object[2] = "未定";
        break;
    }

    int m_ChannelType = m_TermTaskInfo.getCurChannelType();
    m_Object[3] = CFunction.getChannelTypeName(m_ChannelType);

    switch (m_TermTaskInfo.getStatus()) {
      case CollectorDefine.TASK_FREE:
        m_Object[4] = "任务空闲";
        break;

      case CollectorDefine.TASK_USED:
        m_Object[4] = "任务执行中";
        break;

      case CollectorDefine.TASK_READY_DEL:
        m_Object[4] = "任务准备删除";
        break;

      case CollectorDefine.TASK_READY:
        m_Object[4] = "准备执行";
        break;

      case CollectorDefine.TASK_FINISH:
        m_Object[4] = "任务完成";
        break;

      case CollectorDefine.TASK_ASSIGN_READY:
        m_Object[4] = "任务准备分配";
        break;

      case CollectorDefine.TASK_ASSIGNED:
        m_Object[4] = "任务已分配";
        break;

      case CollectorDefine.TASK_RECEIVED:
        m_Object[4] = "任务已收到";
        break;

      case CollectorDefine.TASK_RETURN_READY:
        m_Object[4] = "任务准备返回";
        break;

      case CollectorDefine.TASK_SWITCHED:
        m_Object[4] = "任务切换中";
        break;

      default:
        m_Object[4] = (new Long(m_TermTaskInfo.getStatus())).toString();
        break;
    }

    String m_HostName = m_TermTaskInfo.getHostName();
    m_Object[5] = m_HostName;

    switch (m_TermTaskInfo.getServerType()) {
      case CollectorDefine.SWITCH_TASK:
        m_Object[6] = "切换任务";
        break;

      case CollectorDefine.NO_SWITCH_TASK:
        m_Object[6] = "  ";
        break;

      default:
        m_Object[6] = new Integer(m_TermTaskInfo.getServerType()).toString();
        break;

    }

    m_Object[7] = "";
    if (m_TermTaskInfo.getPurseDetails() != null) {
      for (int i = 0; i < m_TermTaskInfo.getPurseDetails().size(); i++) {
        PurseDetailInfo m_PurseDetailInfo = (PurseDetailInfo) m_TermTaskInfo.
            getPurseDetails().get(i);
        m_Object[7] = m_Object[7] + m_PurseDetailInfo.toString();
      }
    }

    m_Object[8] = "";
    long m_FuncCode = m_TermTaskInfo.getFuncCode();
    m_Object[8] = CFunction.getFuncCodeName(m_FuncCode);
    int m_OperCode = m_TermTaskInfo.getOperCode();
    m_Object[9] = new Integer(m_OperCode).toString();

    if (m_TermTaskInfo.getStartTaskTime() <= 0) {
      m_Object[10] = "";
    }
    else {
      m_Object[10] = CFunction.TransTimeString(m_TermTaskInfo.getStartTaskTime());

    }
    if (m_TermTaskInfo.getLastTaskTime() <= 0) {
      m_Object[11] = "";
    }
    else {
      m_Object[11] = CFunction.TransTimeString(m_TermTaskInfo.getLastTaskTime());

    }

    //System.out.println("m_TermTaskInfo.getTerminalType() = "+m_TermTaskInfo.getTerminalType());
    if (m_TermTaskInfo.getTerminalType() == CollectorDefine.TERMINAL_TYPE) {
      m_Object[12] = "终端类型";
    }
    else if (m_TermTaskInfo.getTerminalType() == CollectorDefine.DIR_METER_TYPE) {
      m_Object[12] = "直连电表类型";
    }
    else if (m_TermTaskInfo.getTerminalType() == CollectorDefine.TS_TYPE) {
      m_Object[12] = "终端服务器类型";
    }
    else {
      m_Object[12] = "未定";
    }

    switch (m_TermTaskInfo.getPri()) {
      case 0x01:
        m_Object[13] = "低优先级";
        break;
      case 0x02:
        m_Object[13] = "中优先级";
        break;
      case 0x03:
        m_Object[13] = "高优先级";
        break;
      default:
        m_Object[13] = "未定";
    }
    ArrayList m_computers = m_TermTaskInfo.getComputers();
    StringBuffer m_buffer = new StringBuffer(" ");
    if (m_computers != null) {
      Object[] computers = m_computers.toArray();
      for (int i = 0; i < computers.length; i++) {
        Long coumputer_id = (Long) (computers[i]);
        computer m_computer = (computer) (CollectorDefine.m_HashComputer.get(
            coumputer_id));
        m_buffer.append(m_computer.getComputerName());
        if (i < (computers.length - 1)) {
          m_buffer.append(", ");
        }
      }
      m_Object[14] = m_buffer.toString();
    }

    String m_ip = m_TermTaskInfo.getIpAddress();
    if (m_ip == null) {
      m_Object[15] = "";
    }
    else {
      m_Object[15] = m_ip;
    }

    long computer_id = m_TermTaskInfo.getChannelId();
    channel m_channel = (channel) (CollectorDefine.m_HashChannel.get(new Long(
        computer_id)));
    if (m_channel != null) {
      m_Object[16] = m_channel.getChannelName();
    }

    long report_id = m_TermTaskInfo.getReportId();
    m_Object[17] = new Long(report_id);

    return m_Object;
  }
}