RTX Server SDK开发发送消息

package message;

import java.io.ByteArrayInputStream;

import org.dom4j.Document;
import org.dom4j.DocumentException;
import org.dom4j.Element;
import org.dom4j.Node;
import org.dom4j.io.SAXReader;

import rtx.RTXSvrApi;

public class UserManager {
	
	public UserManager(){
		
	}
	
	public static final String NO_SEND_POST_CODE_FLAG = "000000";

	/**
	 * 发送消息
	 * @param receivers
	 * @param title
	 * @param message
	 * @param delayTime
	 * @return
	 */
	public boolean sendMessage(String receivers, String title, String message,
			String delayTime) {
		int iRet = -1;
		boolean result = false;
		RTXSvrApi rtxsApi = new RTXSvrApi();
		if (rtxsApi.Init()) {
			iRet = rtxsApi
					.sendNotify(receivers, title, message, "0", delayTime);
			if (iRet == 0) {
				System.out.println("发送成功");
				result = true;
			} else {
				System.out.println("发送失败");
				result = false;
			}
		}
		rtxsApi.UnInit();
		return result;
	}

	/**
	 * 获取发送的用户（如果postcode为000000 则不发送）
	 * @return
	 */
	public String getSendUsers() {
		String users = getAllUsers();
		if(users.endsWith(",")){
			users = users.substring(0, users.length()-1);
		}
		return users;
	}
	
	public boolean loginUser(String userName,String password){
		RTXSvrApi rtxsApi = new RTXSvrApi();
		String uid = null;
		if (rtxsApi.Init()) {
			String[][] str = rtxsApi.GetUserSimpleInfo(userName);
			for(int i=0;i<str.length;i++){
			    for(int j=0;j<str[i].length;j++){
			    	String pwd = str[i][j];
			    	if("UIN".equals(pwd)){
			    		uid = str[i][j+1];
			    		break;
			    	}
			    }
			}
		}
		rtxsApi.UnInit();
		if(uid==null){
			return false;
		}else{
			
		}
		return true;
	}

	private String getAllUsers() {
		RTXSvrApi rtxsApi = new RTXSvrApi();
		StringBuffer users = new StringBuffer();
		if (rtxsApi.Init()) {
			String xmlData = rtxsApi.exportXmldata();
			System.out.println(xmlData);
			SAXReader saxReader = new SAXReader();
			Document document;
			try {
				document = saxReader.read(new ByteArrayInputStream(xmlData
						.getBytes()));
				Element rl = document.getRootElement();
				getNodeCount(rl,users);
				return users.toString();
			} catch (DocumentException e) {
				e.printStackTrace();
			}
		}
		rtxsApi.UnInit();
		return null;
	}

	public void getNodeCount(Element element,StringBuffer users) {
		for (int i = 0; i < element.nodeCount(); i++) {
			Node node = element.node(i);
			if (node instanceof Element) {
				Element elementTemp = (Element) node;
				String qname = elementTemp.getQName().getName();
				if("user".equals(qname)){
					String uid = elementTemp.attributeValue("uid");
					String postcode = elementTemp.attributeValue("postcode");
					if(!NO_SEND_POST_CODE_FLAG.equals(postcode)){
						users.append(uid).append(",");
					}
				}
				getNodeCount(elementTemp,users);
			}
		}
	}

}