package com.sunyard.dataanalyze;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;
import java.util.HashMap;
import java.util.Map;

public class ReciveData extends Thread {
	private DatagramSocket socket = null;
	private int port = PackageConstants.LISTEN_PORT;
	
	public ReciveData(){
		try {
			socket = new DatagramSocket(port);
		} catch (SocketException e) {
			e.printStackTrace();
		}
	}
	
	public static void main(String args[]){
		
	}
	
	public void run(){
		DatagramPacket p = null;
		Destination dest = new Destination();
		byte[] bt = new byte[1024*5];
		try{
			byte[] buf = new byte[socket.getReceiveBufferSize()];
			p = new DatagramPacket(buf, buf.length);
		} catch (SocketException e){
			e.printStackTrace();
		}
		while(true){
			try{
				socket.receive(p);
				bt = p.getData();
				String str = new String(bt);
				//System.out.println(str);
				String[] strs = str.split(PackageConstants.PACKAGE_SPLIT_STR);
				//Package pkg = new Package(str);
				Map content = new HashMap();
				String tradeNo = "";
				for(int i=0; i<strs.length; i++){
					if(!strs[i].trim().equals("")){
						Package pkg = new Package(strs[i]);
						//content = pkg.getContent();
						Map tempContent = pkg.getContent();
						
						content.putAll(tempContent);//包體內容
						tradeNo = pkg.getTradeNo();//交易碼
						PackageConstants.log.info("接收數據包---"+"交易碼："+pkg.getTradeNo()+",流水號："+tempContent.get("SerSeqNo"));
					}
				}
				SendDataPacket sdp = new SendDataPacket();
				sdp.send(content, tradeNo, dest.getIp(), dest.getPort());
				//String tradeNo = pkg.getTradeNo();
				InsertAction action = new InsertAction();
				//Map fieldMapping = action.findFieldMapByTradeNo(tradeNo);
				//action.action(tradeNo, content);
				sleep(100);
			}catch(IOException e){
				e.printStackTrace();
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
	}
}