pipIrr-SV.git - Gitblit

			@@ -1,6 +1,8 @@
			package com.dy.rtuMw.server.msCenter;

			import com.dy.common.util.DateTime;
			import org.springframework.scheduling.annotation.Scheduled;
			import org.springframework.stereotype.Component;

			/**
			* @Author: liurunyu
			@@ -8,16 +10,66 @@
			* @Description
			*/
			//使起作用，本类注解@Component，并在PipIrrMwRtuApplication注解@EnableScheduling
			//@Component
			@Component
			public class TestMsResource {

			// 设置定时十秒一次
			@Scheduled(cron = "0/1 * * * * ?")
			public void WsHeartBeat() throws Exception {
			MsObj obj = new MsObj() ;
			obj.put("id", System.currentTimeMillis());
			obj.put("ms", "消息" + System.currentTimeMillis());
			MsCenterUnit.getInstance().pushMs(obj);
			// 设置定时N秒一次
			@Scheduled(cron = "0/4 * * * * ?")
			public void test1() throws Exception {
			MsObj msObj = new MsObj() ;
			setAttr4OpenCloseValve("开阀", msObj) ;
			MsCenterUnit.getInstance().pushMs(msObj);
			}

			// 设置定时N秒一次
			@Scheduled(cron = "0/6 * * * * ?")
			public void test2() throws Exception {
			MsObj msObj = new MsObj() ;
			setAttr4OpenCloseValve("关阀", msObj) ;
			MsCenterUnit.getInstance().pushMs(msObj);
			}

			// 设置定时N秒一次
			@Scheduled(cron = "0/10 * * * * ?")
			public void test4() throws Exception {
			MsObj msObj = new MsObj() ;
			setAttr4StateAlarm("阀态", msObj) ;
			msObj.put("state", 0);
			msObj.put("stateName", "开");
			MsCenterUnit.getInstance().pushMs(msObj);
			}

			// 设置定时N秒一次
			@Scheduled(cron = "0/15 * * * * ?")
			public void test3() throws Exception {
			MsObj msObj = new MsObj() ;
			setAttr4StateAlarm("阀态", msObj) ;
			msObj.put("alarm", "流量计故障报警、漏损报警");
			MsCenterUnit.getInstance().pushMs(msObj);
			}

			private void setAttr4OpenCloseValve(String name, MsObj msObj){
			msObj.put("name", name);
			msObj.put("clientId", clientId);
			msObj.put("clientName", clientName);
			msObj.put("clientAddress", clientAddress);
			msObj.put("icCardNo", icCardNo);
			msObj.put("rtuAddr", rtuAddr);
			msObj.put("intakeId", intakeId);
			msObj.put("dt", DateTime.yyyy_MM_dd_HH_mm_ss());
			}

			private void setAttr4StateAlarm(String name, MsObj msObj){
			msObj.put("name", name);
			msObj.put("rtuAddr", rtuAddr);
			msObj.put("intakeId", intakeId);
			msObj.put("dt", DateTime.yyyy_MM_dd_HH_mm_ss());
			}

			private static final String clientName = "田仁春";
			private static final String clientAddress = "元谋县元马镇清和村委会挨那望村";
			private static final Long clientId = 2024090517284400002L;
			private static final Long intakeId = 2024090517395800007L;
			private static final String rtuAddr = "123456789";
			private static final String icCardNo = "123456789";
			}