package com.sunyard.dataanalyze;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;
import java.util.Map;

public class SendDataPacket {
	public void send(Map map, String tradeNo, String addr, int port){
		if(null != FieldMappingCfg.getFieldMap().get(tradeNo)){
			XMLStringBuilder buider = new XMLStringBuilder();
			String sendStr = buider.getDoc(map, tradeNo);
			InetSocketAddress address = new InetSocketAddress(addr, port);
			try{
				DatagramSocket socket = new DatagramSocket(59999);//發送端口
				byte[] b = sendStr.getBytes();
				DatagramPacket p = new DatagramPacket(b, b.length, address);
				socket.send(p);
				socket.close();
			}catch(IOException e){
				PackageConstants.log.error(e.getMessage());
			}
		}
	}
}