上位机源代码java源代码

上位机源代码java源代码下载 对大桥测得数据进行处理和远程监控

package cn.com.webinfo.action.application;

import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.util.Date;

import cn.com.webinfo.action.applicationlayer.IApplayerHandler;
import cn.com.webinfo.action.dataexchangelayer.ExchangeHandler;
import cn.com.webinfo.action.dataexchangelayer.QueueData;
import cn.com.webinfo.action.sntp.TimeSynchronization;
import cn.com.webinfo.model.Cable;
import cn.com.webinfo.model.Monitordata;
import cn.com.webinfo.service.CableManager;
import cn.com.webinfo.service.MonitordataManager;
import cn.com.webinfo.util.Common;

/* 通信处理程序
 * 发出修改采样间隔指令
 * 接受来自下位机的采集数据，并计算基频，存入数据库
 */

public class ApplayerHandler implements IApplayerHandler {

	private ExchangeHandler exchangeHandler;
	
	private MonitordataManager monitordataManager;	
	
	private CableManager cableManager;	
	
	private byte[] dataFromClient = new byte[1024];

	public ApplayerHandler（） throws InterruptedException {
		exchangeHandler = ExchangeHandler.getInstance（）;
		exchangeHandler.setIAppHandler（this）;
		exchangeHandler.init（）; // 数据交换层初始化
	}

	//发送修改下位机采样时间间隔命令
	public void excuteSendDataCommand（String dataToSend String targetIP） throws IOException InterruptedException {
		// 发送
		QueueData qd = new QueueData（）;
		qd.setNeedPrioritySort（true）;
		qd.setNeedZip（false）;
		qd.setPriority（4）;
		qd.setDestination（targetIP）;
		qd.setMonitorId（2）;
		qd.setQueueModel（1）;
		qd.setmyId（myId）; // I am 1
		qd.setResendCount（0）;
		qd.setNeedReliable（true）;
		qd.setOutData（dataToSend.getBytes（））;
		qd.setLength（dataToSend.getBytes（）.length）;
		exchangeHandler.addToQueue（qd）;
		System.out.println（“Now:“ + System.currentTimeMillis（））;
	}
	
	//发送下位机时间同步广播指令
	public void excuteSendTimeSyncCommand（String dataToSend String targetIP） throws IOException InterruptedException{
		QueueData qd = new QueueData（）;
		qd.setNeedPrioritySort（true）;
		qd.setNeedZip（false）;
		qd.setPriority（7）;
		qd.setDestination（targetIP）;
		qd.setMonitorId（2）;
		qd.setQueueModel（1）;
		qd.setmyId（myId）; // I am 1
		qd.setResendCount（0）;
		qd.setNeedReliable（true）;
		qd.setOutData（dataToSend.getBytes（））;
		qd.setLength（dataToSend.getBytes（）.length）;
		exchangeHandler.addToQueue（qd）;
		System.out.println（“Now:“ + System.currentTimeMillis（））;		
	}

	//通信系统数据接受
	public void setDataFromExchange（byte[] dataFromComm int priority） {
		if （dataFromComm != null） {
			System.out.println（“S:数据交换层上交给应用层的数据长度:“ + dataFromComm.length + “优先级为:“ + priority）;
			try {
				Date rectime = new Date（）;
				System.out.print（“S:“ + new String（dataFromComm “GBK“））;
				System.out.println（““）;
				dataFromClient = dataFromComm;
				String stringFromClient = new String（dataFromClient）;
				// 接受的采样基频数据分解
				// ###########################################
				// #         #索号：时间@1，基频；                 #
				// ###########################################
				if （stringFromClient.indexOf（“#“） != -1） {
					
			

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----

     文件       2682  2009-09-07 10:21  upper-computer\.classpath

     文件        185  2009-09-07 10:21  upper-computer\.hibernateSynchronizer

     文件        589  2009-09-27 10:53  upper-computer\.hibernateSynchronizer3\config.properties

     文件         66  2009-09-07 10:21  upper-computer\.myumldata

     文件        390  2009-09-07 10:21  upper-computer\.project

     文件         86  2009-09-07 10:21  upper-computer\.settings\org.eclipse.core.resources.prefs

     文件        620  2009-09-07 10:21  upper-computer\.settings\org.eclipse.jdt.core.prefs

     文件        179  2009-09-07 10:21  upper-computer\.settings\org.eclipse.jdt.ui.prefs

     文件        272  2009-09-07 10:21  upper-computer\.springBeans

     文件       6630  2009-09-22 14:35  upper-computer\bin\cn\com\webinfo\action\application\ApplayerHandler.class

     文件       3132  2009-09-07 10:21  upper-computer\bin\cn\com\webinfo\action\application\MonitorServer.class

     文件       1052  2009-09-07 10:21  upper-computer\bin\cn\com\webinfo\action\application\Starter.class

     文件       1838  2009-09-07 10:21  upper-computer\bin\cn\com\webinfo\action\application\TestPOJO.class

     文件        676  2009-09-07 10:21  upper-computer\bin\cn\com\webinfo\action\applicationlayer\IApplayerHandler.class

     文件        324  2009-09-07 10:21  upper-computer\bin\cn\com\webinfo\action\communicatelayer\ACKList.class

     文件       2317  2009-09-07 10:21  upper-computer\bin\cn\com\webinfo\action\communicatelayer\ACKPacket.class

     文件       4318  2009-09-07 10:21  upper-computer\bin\cn\com\webinfo\action\communicatelayer\Channel.class

     文件      17530  2009-09-07 10:21  upper-computer\bin\cn\com\webinfo\action\communicatelayer\CommHandler.class

     文件        739  2009-09-07 10:21  upper-computer\bin\cn\com\webinfo\action\communicatelayer\CsDetectTask.class

     文件       3353  2009-09-07 10:21  upper-computer\bin\cn\com\webinfo\action\communicatelayer\DataDePacket.class

     文件       6942  2009-09-07 10:21  upper-computer\bin\cn\com\webinfo\action\communicatelayer\DataPacket.class

     文件       3728  2009-09-07 10:21  upper-computer\bin\cn\com\webinfo\action\communicatelayer\DataRePacket.class

     文件       2355  2009-09-07 10:21  upper-computer\bin\cn\com\webinfo\action\communicatelayer\NACKPacket.class

     文件       1958  2009-09-07 10:21  upper-computer\bin\cn\com\webinfo\action\communicatelayer\NetInterface.class

     文件        715  2009-09-07 10:21  upper-computer\bin\cn\com\webinfo\action\communicatelayer\PDU.class

     文件        324  2009-09-07 10:21  upper-computer\bin\cn\com\webinfo\action\communicatelayer\PDUPool.class

     文件        333  2009-09-07 10:21  upper-computer\bin\cn\com\webinfo\action\communicatelayer\PDUWithSeq.class

     文件       4580  2009-09-07 10:21  upper-computer\bin\cn\com\webinfo\action\communicatelayer\SendACKTask.class

     文件       3898  2009-09-07 10:21  upper-computer\bin\cn\com\webinfo\action\communicatelayer\SendNACKTask.class

     文件        915  2009-09-07 10:21  upper-computer\bin\cn\com\webinfo\action\communicatelayer\SeqmanageTask.class

............此处省略215个文件信息