Skip to content

D
DataPush_shanxi
Commit 43c07fd4 authored by 史余彬's avatar 史余彬
Browse files
Options

山西数据推送-配置信息修改，类型调整

parent 219582d9
Hide whitespace changes
Inline Side-by-side
Showing with 347 additions and 279 deletions
pom.xml
View file @ 43c07fd4
......@@ -5,7 +5,7 @@
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.3.2.RELEASE</version>
<version>2.3.2.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>com.amqp</groupId>
......@@ -18,6 +18,8 @@
<java.version>1.8</java.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
......@@ -67,7 +69,13 @@
<artifactId>hutool-all</artifactId>
<version>5.3.10</version>
</dependency>
<!-- 数据库加密 -->
<!-- https://mvnrepository.com/artifact/com.github.ulisesbocchio/jasypt-spring-boot-starter -->
<!--<dependency>
<groupId>com.github.ulisesbocchio</groupId>
<artifactId>jasypt-spring-boot-starter</artifactId>
<version>3.0.2</version>
</dependency>-->
</dependencies>
<build>
......
shanxi.iml
View file @ 43c07fd4
......@@ -14,7 +14,7 @@
<sourceFolder url="file://$MODULE_DIR$/src/test/java" isTestSource="true" />
<excludeFolder url="file://$MODULE_DIR$/target" />
</content>
<orderEntry type="inheritedJdk" />
<orderEntry type="jdk" jdkName="1.8" jdkType="JavaSDK" />
<orderEntry type="sourceFolder" forTests="false" />
<orderEntry type="library" name="Maven: org.springframework.boot:spring-boot-starter-amqp:2.3.2.RELEASE" level="project" />
<orderEntry type="library" name="Maven: org.springframework.boot:spring-boot-starter:2.3.2.RELEASE" level="project" />
......
src/main/java/com/amqp/shanxi/Sender.java
View file @ 43c07fd4
......@@ -8,14 +8,12 @@ import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import java.io.IOException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.TimeoutException;
/*
* 生产者消费确认
*/
......@@ -51,11 +49,11 @@ public class Sender {
resultList.add(dbDeviceInfo);
//对数据加密
String result = JSONUtil.toJsonStr(resultList);
String encrypt = AESUtil.encrypt(result, "BRlp%IYyTYFntG!g7oPo$N==" , "wP!n$!ZD%0k2g6Gahpdk6l==");
String encrypt = AESUtil.encrypt(result, "i2MvNzkedPgITpz2UcZS3A==" , "ReQb3Swiz8frJ3+8l9RGvg==");
Map<String, Object> resultMap = new HashMap<String, Object>();
//荷载消息内容
while(true) {
resultMap.put("tailingNo","1409240052");
resultMap.put("tailingNo","1402240003");
resultMap.put("departmentId","" );
resultMap.put("provinceId", "");
resultMap.put("type","0101");
......
src/main/java/com/amqp/shanxi/ShanxiApplication.java
View file @ 43c07fd4
......@@ -6,36 +6,46 @@ import com.amqp.shanxi.service.RealTimeDataAMQPService;
import com.amqp.shanxi.service.ThreadService;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
//import com.ulisesbocchio.jasyptspringboot.annotation.EnableEncryptableProperties;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.ConfigurableApplicationContext;
@SpringBootApplication
//@EnableEncryptableProperties
public class ShanxiApplication {
/*
山西宏伟矿业有限责任公司泽水沟东沟尾矿库
尾矿库编号：1402240003
数据上传IP：192.166.1.253
rbmq账号：hwzsgdg
rbmq密码：7793oa
密钥：i2MvNzkedPgITpz2UcZS3A==
向量：ReQb3Swiz8frJ3+8l9RGvg==
*/
public static void main(String[] args) {
ConfigurableApplicationContext run = SpringApplication.run(ShanxiApplication.class, args);
DeviceStaticDataAMQPService deviceStaticDataAMQPService = run.getBean(DeviceStaticDataAMQPService.class);
RealTimeDataAMQPService realTimeDataAMQPService = run.getBean(RealTimeDataAMQPService.class);
AlarmDataAMQPService alarmDataAMQPService = run.getBean(AlarmDataAMQPService.class);
try{
ConnectionFactory factory = new ConnectionFactory();
//rabbitmq监听IP
factory.setHost("114.115.212.187");
factory.setHost("192.166.1.253");
//rabbitmq监听默认端口
factory.setPort(5672);
//设置访问的用户
factory.setUsername("bhsoft");
factory.setPassword("bhsoft");
factory.setUsername("hwzsgdg");
factory.setPassword("7793oa");
factory.setVirtualHost("/");
Connection connection = factory.newConnection();
ThreadService threadService1 = new ThreadService("staticData", connection, deviceStaticDataAMQPService, realTimeDataAMQPService, alarmDataAMQPService);
ThreadService threadService2 = new ThreadService("realTimeData", connection, deviceStaticDataAMQPService, realTimeDataAMQPService,alarmDataAMQPService);
ThreadService threadService3 = new ThreadService("alarmData", connection, deviceStaticDataAMQPService, realTimeDataAMQPService,alarmDataAMQPService);
//ThreadService threadService3 = new ThreadService("alarmData", connection, deviceStaticDataAMQPService, realTimeDataAMQPService,alarmDataAMQPService);
threadService1.start();
threadService2.start();
threadService3.start();
//threadService3.start();
} catch(Exception e) {
e.printStackTrace();
}
......
src/main/java/com/amqp/shanxi/dao/DeviceStaticDataInfoDao.java
View file @ 43c07fd4
......@@ -3,33 +3,32 @@ package com.amqp.shanxi.dao;
import com.amqp.shanxi.model.*;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Select;
import org.springframework.stereotype.Repository;
import java.util.List;
@Mapper
public interface DeviceStaticDataInfoDao {
@Select("SELECT id AS equipno, name AS equipname FROM tab_sensor WHERE mark = '干滩2'")
@Select("SELECT id AS equipno, name AS equipname, jd AS longitude, wd AS latitude, gaocheng AS altitude FROM tab_sensor WHERE mark = '干滩2'")
List<GantanDeviceInfoModel> findGantanDeviceInfo();
@Select("SELECT id AS equipno, name AS equipname FROM tab_sensor WHERE mark = '库水位'")
@Select("SELECT id AS equipno, name AS equipname, jd AS longitude, wd AS latitude, gaocheng AS altitude, param AS manufacture FROM tab_sensor WHERE mark = '库水位'")
List<KushuiweiDeviceInfoModel> findKushuiweiDeviceInfo();
@Select("SELECT id AS equipno, name AS equipname FROM tab_sensor WHERE mark = '坝体表面位移'")
@Select("SELECT id AS equipno, name AS equipname, jd AS longitude, wd AS latitude, gaocheng AS altitude FROM tab_sensor WHERE mark = '坝体表面位移'")
List<BiaomianweiyiDeviceInfoModel> findBiaomianweiyiDeviceInfo();
@Select("SELECT id AS equipno, name AS equipname FROM tab_sensor WHERE mark = '浸润线'")
@Select("SELECT id AS equipno, name AS equipname, jd AS longitude, wd AS latitude, gaocheng AS altitude, param AS manufacture FROM tab_sensor WHERE mark = '浸润线'")
List<JinrunxianDeviceInfoModel> findJinrunxianDeviceInfo();
@Select("SELECT id AS equipno, name AS equipname FROM tab_sensor WHERE mark = '雨量计'")
List<JinrunxianDeviceInfoModel> findJiangyuliangDeviceInfo();
@Select("SELECT id AS equipno, name AS equipname, jd AS longitude, wd AS latitude, gaocheng AS altitude FROM tab_sensor WHERE mark = '雨量计'")
List<JiangyuliangDeviceInfoModel> findJiangyuliangDeviceInfo();
@Select("SELECT id AS equipno, name AS equipname FROM tab_sensor WHERE mark = '坝体内部水平位移' or mark = '坝体内部沉降'")
@Select("SELECT id AS equipno, name AS equipname, jd AS longitude, wd AS latitude, gaocheng AS altitude FROM tab_sensor WHERE mark = '坝体内部水平位移' or mark = '坝体内部沉降'")
List<NeibuweiyiDeviceInfoModel> findNeibuweiyiDeviceInfo();
@Select("SELECT tailingno, tailingname, unifcreditcode, address, unitname, unitaddress, industrycharacterno, unitperson, unitpersontel, securityofficer, securityofficertel, ondutytel, longitude, latitude, usedate, useyear, operatingstatus, industrytypeno, mineralspecies, top, onlinemonitoringsys, geologicalstructure, topotraphicgradient, standardizationlevel, standardforensicsdate, safetypermitno, safetypermitdate, safetypermitunit, storetypeno, designlevel, grade, designheight, stackheight, plancapability, nowvolume, damstocktypeno, floodequipment, floodmethod, floodfacilitydischarge, waterarea, area, floodcontrolstandard, damtype, initialdamtype, designinitialdamheight, currentinitialdamheight, initialdamlongness, initialdamsloperatio, accumulationdamratio, designsubdamheighta, designsubdamtopwidth, accumulateddamsnumber, earthquake, tailingsstoragemethod, minelaytypeno, upstreamtailings, drystorage, drystoragewaterratio, tailingsparticlesize, tailingsaveparticlesize, depositiondrybeachslope, personnum, buildingnum, emergencyplanfiled, primarysafetyunit, primarysafetylevel, designunit, designunitlevel, constructionunit, constructionlevel, supervisoryunit, supervisorylevel, safetycheckunit, safetychecklevel, safetyacceptancetime, safetyevaluationunit, safetyevaluationlevel, filingperson, filingdate, fillerphone, note, in_use, is_sync, id"+
......
src/main/java/com/amqp/shanxi/dao/SensorDataDao.java
View file @ 43c07fd4
......@@ -9,11 +9,11 @@ import java.util.List;
public interface SensorDataDao {
@Select("select b.mark from (" +
" select mark from tab_sensor where kind not like '%干滩%' and kind not like '%内部位移%'" +
" select mark from tab_sensor where mark not like '%干滩%' and mark not like '%内部%'" +
" union all"+
" select '干滩' as mark from tab_sensor where kind like '%干滩%'"+
" select '干滩' as mark from tab_sensor where mark like '%干滩%'"+
" union all"+
" select '内部位移' as mark from tab_sensor where kind like '%内部位移%'" +
" select '内部位移' as mark from tab_sensor where mark like '%内部%'" +
" ) b group by b.mark")
List<String> findAllSensorData();
......
src/main/java/com/amqp/shanxi/model/BiaomianweiyiDeviceInfoModel.java
View file @ 43c07fd4
......@@ -10,9 +10,9 @@ public class BiaomianweiyiDeviceInfoModel {
private String installationdate;
private String installationlocate;
private String manufacture;
private Double longitude;
private Double latitude;
private Double altitude;
private String longitude;
private String latitude;
private String altitude;
private Double onelevelalarm;
private Double twolevelalarm;
private Double threelevelalarm;
......
src/main/java/com/amqp/shanxi/model/GantanDeviceInfoModel.java
View file @ 43c07fd4
......@@ -13,9 +13,9 @@ public class GantanDeviceInfoModel {
private String installationlocate;
private Double installlocation;
private String manufacture;
private Double longitude;
private Double latitude;
private Double altitude;
private String longitude;
private String latitude;
private String altitude;
private Double onelevelalarm;
private Double twolevelalarm;
private Double threelevelalarm;
......
src/main/java/com/amqp/shanxi/model/JiangyuliangDeviceInfoModel.java
View file @ 43c07fd4
......@@ -10,9 +10,9 @@ public class JiangyuliangDeviceInfoModel {
private String installationdate;
private String installationlocate;
private String manufacture;
private Double longitude;
private Double latitude;
private Double altitude;
private String longitude;
private String latitude;
private String altitude;
private Double onelevelalarm;
private Double twolevelalarm;
private Double threelevelalarm;
......
src/main/java/com/amqp/shanxi/model/JinrunxianDeviceInfoModel.java
View file @ 43c07fd4
......@@ -10,11 +10,11 @@ public class JinrunxianDeviceInfoModel {
private String installationdate;
private String installationlocate;
private String manufacture;
private Double holedepth;
private Double burialdepath;
private Double longitude;
private Double latitude;
private Double altitude;
private String holedepth;
private String burialdepath;
private String longitude;
private String latitude;
private String altitude;
private Double onelevelalarm;
private Double twolevelalarm;
private Double threelevelalarm;
......
src/main/java/com/amqp/shanxi/model/KushuiweiDeviceInfoModel.java
View file @ 43c07fd4
......@@ -9,11 +9,11 @@ public class KushuiweiDeviceInfoModel {
private String equipname;
private String installationdate;
private String installationlocate;
private Double installlocation;
private String installlocation;
private String manufacture;
private Double longitude;
private Double latitude;
private Double altitude;
private String longitude;
private String latitude;
private String altitude;
private Double onelevelalarm;
private Double twolevelalarm;
private Double threelevelalarm;
......
src/main/java/com/amqp/shanxi/model/NeibuweiyiDeviceInfoModel.java
View file @ 43c07fd4
......@@ -10,9 +10,9 @@ public class NeibuweiyiDeviceInfoModel {
private String installationdate;
private String installationlocate;
private String manufacture;
private Double longitude;
private Double latitude;
private Double altitude;
private String longitude;
private String latitude;
private String altitude;
private Double onelevelalarm;
private Double twolevelalarm;
private Double threelevelalarm;
......
src/main/java/com/amqp/shanxi/model/WkkBasicInfoModel.java
View file @ 43c07fd4
......@@ -5,7 +5,6 @@ import lombok.Data;
@Data
public class WkkBasicInfoModel {
private Long id;
private String tailingno;
private String tailingname;
private String unifcreditcode;
......@@ -18,8 +17,8 @@ public class WkkBasicInfoModel {
private String securityofficer;
private String securityofficertel;
private String ondutytel;
private Double longitude;
private Double latitude;
private String longitude;
private String latitude;
private String usedate;
private Double useyear;
private String operatingstatus;
......@@ -37,16 +36,16 @@ public class WkkBasicInfoModel {
private String storetypeno;
private String designlevel;
private String grade;
private Double designheight;
private String designheight;
private Double stackheight;
private Double plancapability;
private String plancapability;
private Double nowvolume;
private String damstocktypeno;
private String floodequipment;
private String floodmethod;
private String floodfacilitydischarge;
private Double waterarea;
private Double area;
private String waterarea;
private String area;
private Double floodcontrolstandard;
private String damtype;
private String initialdamtype;
......@@ -58,7 +57,7 @@ public class WkkBasicInfoModel {
private Double designsubdamheighta;
private Double designsubdamtopwidth;
private Double accumulateddamsnumber;
private Double earthquake;
private String earthquake;
private String tailingsstoragemethod;
private String minelaytypeno;
private String upstreamtailings;
......@@ -67,8 +66,8 @@ public class WkkBasicInfoModel {
private Double tailingsparticlesize;
private Double tailingsaveparticlesize;
private Double depositiondrybeachslope;
private Double personnum;
private Double buildingnum;
private String personnum;
private String buildingnum;
private String emergencyplanfiled;
private String primarysafetyunit;
private String primarysafetylevel;
......
src/main/java/com/amqp/shanxi/service/AlarmDataAMQPService.java
View file @ 43c07fd4
......@@ -50,7 +50,7 @@ public class AlarmDataAMQPService {
, AMQPTopicStaticDataConfig.TOPICQUEUEGANtANALARM
, null
, alarmDataService.gantanAlarm().getBytes());
//消息确认
// 消息确认
channel.confirmSelect();
if (channel.waitForConfirms()) {
System.out.println("干滩报警信息发送成功！");
......@@ -148,9 +148,9 @@ public class AlarmDataAMQPService {
System.out.println("降雨量报警信息发送失败！");
}
channel.close();
} else if ("sll".equals(type)) {
}/* else if ("sll".equals(type)) {
} else if ("device".equals(type)) {
}*/ else if ("device".equals(type)) {
// 监测项数据信息
Channel channel = connection.createChannel();
// channel.exchangeDeclare(AMQPTopicStaticDataConfig.topicExchangeRealTime, "topic", false, true, null);
......@@ -188,11 +188,4 @@ public class AlarmDataAMQPService {
}
}
/*
@RabbitListener(queues ="equipOfflineInfo" )
public void receiveMessage1(String str){
System.out.println("我是监听干滩topic.message的, dataInfo.01: " + str);
}
*/
}
src/main/java/com/amqp/shanxi/service/DeviceStaticDataAMQPService.java
View file @ 43c07fd4
package com.amqp.shanxi.service;
import cn.hutool.json.JSONUtil;
import com.amqp.shanxi.ShanxiApplication;
import com.amqp.shanxi.model.StaticDataInfoModel;
import com.amqp.shanxi.service.impl.DeviceStaticDataInfoServiceImpl;
import com.amqp.shanxi.util.AMQPTopicStaticDataConfig;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
......@@ -43,8 +39,6 @@ public class DeviceStaticDataAMQPService {
this.publish("nbwy", connection);
}
}
}catch(Exception e) {
e.printStackTrace();
}
......@@ -70,6 +64,7 @@ public class DeviceStaticDataAMQPService {
channel.close();
} else if ("gt".equals(type)) {
Channel channel = connection.createChannel();
// channel.queueDeclare("static_gantan", true, false, false, null);
// channel.exchangeDeclare(AMQPTopicStaticDataConfig.TOPIC_EXCHANGE, "topic", false, true, null);
channel.basicPublish(AMQPTopicStaticDataConfig.TOPIC_EXCHANGE
, AMQPTopicStaticDataConfig.TOPIC_ROUTINGKEY_GANTAN
......@@ -85,6 +80,7 @@ public class DeviceStaticDataAMQPService {
channel.close();
} else if ("ksw".equals(type)) {
Channel channel = connection.createChannel();
//channel.queueDeclare("static_kushuiwei", true, false, false, null);
channel.basicPublish(AMQPTopicStaticDataConfig.TOPIC_EXCHANGE
, AMQPTopicStaticDataConfig.TOPIC_ROUTINGKEY_KUSHUIWEI
, null
......@@ -100,6 +96,7 @@ public class DeviceStaticDataAMQPService {
} else if ("bmwy".equals(type)) {
Channel channel = connection.createChannel();
//channel.queueDeclare("static_bmwy", true, false, false, null);
channel.basicPublish(AMQPTopicStaticDataConfig.TOPIC_EXCHANGE
, AMQPTopicStaticDataConfig.TOPIC_ROUTINGKEY_BIAOMIANWEIYI
, null
......@@ -157,40 +154,12 @@ public class DeviceStaticDataAMQPService {
}
channel.close();
} else if ("sll".equals(type)) {
} /*else if ("sll".equals(type)) {
}
}*/
}catch(Exception e) {
e.printStackTrace();
}
}
/**
* 以下是监听，接收队列中消息
*
*/
/* @RabbitListener(queues ="equipInfo.01" )
public void receiveMessage1(String str){
System.out.println("我是监听干滩topic.message的, 消息队列equipInfo.01: " + str);
}
@RabbitListener(queues ="equipInfo.02" )
public void receiveMessage2(String str){
System.out.println("我是监听库水位topic.message的, 消息队列equipInfo.02: " + str);
}
@RabbitListener(queues ="equipInfo.03" )
public void receiveMessage3(String str){
System.out.println("我是监听表面位移topic.message的, 消息队列equipInfo.03: " + str);
}
@RabbitListener(queues ="equipInfo.05" )
public void receiveMessage5(String str){
System.out.println("我是监听浸润线topic.message的, 消息队列equipInfo.05: " + str);
}
@RabbitListener(queues ="equipInfo.06" )
public void receiveMessage6(String str){
System.out.println("我是监听降雨量topic.message的, 消息队列equipInfo.06: " + str);
}*/
}
src/main/java/com/amqp/shanxi/service/RealTimeDataAMQPService.java
View file @ 43c07fd4
package com.amqp.shanxi.service;
import cn.hutool.json.JSONUtil;
import com.amqp.shanxi.util.AMQPTopicStaticDataConfig;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
......@@ -64,7 +63,7 @@ public class RealTimeDataAMQPService {
} else if ("ksw".equals(type)) {
Channel channel = connection.createChannel();
// channel.exchangeDeclare(AMQPTopicStaticDataConfig.topicExchangeRealTime, "topic", false, true, null);
//channel.exchangeDeclare(AMQPTopicStaticDataConfig.topicExchangeRealTime, "topic", false, true, null);
channel.basicPublish(AMQPTopicStaticDataConfig.topicExchangeRealTime
, AMQPTopicStaticDataConfig.TOPICQUEUEKUSHUIWEIREALTIME
, null
......
src/main/java/com/amqp/shanxi/service/ThreadService.java
View file @ 43c07fd4
......@@ -34,7 +34,7 @@ public class ThreadService extends Thread{
while(true) {
deviceStaticDataAMQPService.run(connection);
System.out.println("设备信息发送完成=====================================================================================");
Thread.sleep(360000 * 24);
Thread.sleep(60000 * 5);
}
}else if ("realTimeData".equals(type)) {
while(true) {
......@@ -42,7 +42,7 @@ public class ThreadService extends Thread{
System.out.println("实时数据发送完成======================================================================================");
Thread.sleep(60000 * 5);
}
}else if("alarmData".equals(type)){
}else if("alarmData".equals(type)) {
while(true) {
alarmDataAMQPService.run(connection);
System.out.println("设备报警信息发送完成===================================================================================");
......
src/main/java/com/amqp/shanxi/service/impl/AlarmDataServiceImpl.java
View file @ 43c07fd4
......@@ -40,11 +40,11 @@ public class AlarmDataServiceImpl implements AlarmDataService {
System.out.println("gt报警======================" + JSONUtil.toJsonStr(gantanAlarmData));
if (gantanAlarmData.size() > 0) {
gantanAlarmInfo.setTailingNo(StaticParamUtils.WKKNO);
gantanAlarmInfo.setDepartmentId("123456789");
gantanAlarmInfo.setDepartmentId("911402247485664344");
gantanAlarmInfo.setProvinceId(StaticParamUtils.PROVINCENO);
gantanAlarmInfo.setType(StaticParamUtils.GANTANALARM);
gantanAlarmInfo.setSendTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
gantanAlarmInfo.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(gantanAlarmData), "BRlp%IYyTYFntG!g7oPo$N==", "wP!n$!ZD%0k2g6Gahpdk6l=="));
gantanAlarmInfo.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(gantanAlarmData), "i2MvNzkedPgITpz2UcZS3A==", "ReQb3Swiz8frJ3+8l9RGvg=="));
}
return JSONUtil.toJsonStr(gantanAlarmInfo);
}catch (Exception e) {
......@@ -70,11 +70,11 @@ public class AlarmDataServiceImpl implements AlarmDataService {
System.out.println("ksw报警======================" + JSONUtil.toJsonStr(kushuiweiAlarmData));
if (kushuiweiAlarmData.size() > 0) {
kswAlarmInfo.setTailingNo(StaticParamUtils.WKKNO);
kswAlarmInfo.setDepartmentId("123456789");
kswAlarmInfo.setDepartmentId("911402247485664344");
kswAlarmInfo.setProvinceId(StaticParamUtils.PROVINCENO);
kswAlarmInfo.setType(StaticParamUtils.KUSHUIWEIALARM);
kswAlarmInfo.setSendTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
kswAlarmInfo.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(kushuiweiAlarmData), "BRlp%IYyTYFntG!g7oPo$N==", "wP!n$!ZD%0k2g6Gahpdk6l=="));
kswAlarmInfo.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(kushuiweiAlarmData), "i2MvNzkedPgITpz2UcZS3A==", "ReQb3Swiz8frJ3+8l9RGvg=="));
}
return JSONUtil.toJsonStr(kswAlarmInfo);
}catch (Exception e) {
......@@ -100,11 +100,11 @@ public class AlarmDataServiceImpl implements AlarmDataService {
System.out.println("bmwy报警======================" + JSONUtil.toJsonStr(biaomianweiyiAlarmData));
if (biaomianweiyiAlarmData.size() > 0) {
bmwyAlarmInfo.setTailingNo(StaticParamUtils.WKKNO);
bmwyAlarmInfo.setDepartmentId("123456789");
bmwyAlarmInfo.setDepartmentId("911402247485664344");
bmwyAlarmInfo.setProvinceId(StaticParamUtils.PROVINCENO);
bmwyAlarmInfo.setType(StaticParamUtils.BIAOMIANWEIYIALARM);
bmwyAlarmInfo.setSendTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
bmwyAlarmInfo.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(biaomianweiyiAlarmData), "BRlp%IYyTYFntG!g7oPo$N==", "wP!n$!ZD%0k2g6Gahpdk6l=="));
bmwyAlarmInfo.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(biaomianweiyiAlarmData), "i2MvNzkedPgITpz2UcZS3A==", "ReQb3Swiz8frJ3+8l9RGvg=="));
}
return JSONUtil.toJsonStr(bmwyAlarmInfo);
}catch (Exception e) {
......@@ -130,11 +130,11 @@ public class AlarmDataServiceImpl implements AlarmDataService {
System.out.println("jrx报警======================" + JSONUtil.toJsonStr(jinrunxianAlarmData));
if (jinrunxianAlarmData.size() > 0) {
jrxAlarmInfo.setTailingNo(StaticParamUtils.WKKNO);
jrxAlarmInfo.setDepartmentId("123456789");
jrxAlarmInfo.setDepartmentId("911402247485664344");
jrxAlarmInfo.setProvinceId(StaticParamUtils.PROVINCENO);
jrxAlarmInfo.setType(StaticParamUtils.JINRUNXIANALARM);
jrxAlarmInfo.setSendTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
jrxAlarmInfo.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(jinrunxianAlarmData), "BRlp%IYyTYFntG!g7oPo$N==", "wP!n$!ZD%0k2g6Gahpdk6l=="));
jrxAlarmInfo.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(jinrunxianAlarmData), "i2MvNzkedPgITpz2UcZS3A==", "ReQb3Swiz8frJ3+8l9RGvg=="));
}
return JSONUtil.toJsonStr(jrxAlarmInfo);
}catch (Exception e) {
......@@ -160,11 +160,11 @@ public class AlarmDataServiceImpl implements AlarmDataService {
System.out.println("jyl报警======================" + JSONUtil.toJsonStr(jylAlarmData));
if (jylAlarmData.size() > 0) {
jylAlarmInfo.setTailingNo(StaticParamUtils.WKKNO);
jylAlarmInfo.setDepartmentId("123456789");
jylAlarmInfo.setDepartmentId("911402247485664344");
jylAlarmInfo.setProvinceId(StaticParamUtils.PROVINCENO);
jylAlarmInfo.setType(StaticParamUtils.JIANGYULIANGALARM);
jylAlarmInfo.setSendTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
jylAlarmInfo.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(jylAlarmData), "BRlp%IYyTYFntG!g7oPo$N==", "wP!n$!ZD%0k2g6Gahpdk6l=="));
jylAlarmInfo.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(jylAlarmData), "i2MvNzkedPgITpz2UcZS3A==", "ReQb3Swiz8frJ3+8l9RGvg=="));
}
return JSONUtil.toJsonStr(jylAlarmInfo);
}catch (Exception e) {
......@@ -197,11 +197,11 @@ public class AlarmDataServiceImpl implements AlarmDataService {
System.out.println("device报警============" + JSONUtil.toJsonStr(deviceAlarmData));
if (deviceAlarmData.size() > 0) {
deviceAlarmInfo.setTailingNo(StaticParamUtils.WKKNO);
deviceAlarmInfo.setDepartmentId("123456789");
deviceAlarmInfo.setDepartmentId("911402247485664344");
deviceAlarmInfo.setProvinceId(StaticParamUtils.PROVINCENO);
deviceAlarmInfo.setType(StaticParamUtils.DEVICEALARM);
deviceAlarmInfo.setSendTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
deviceAlarmInfo.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(deviceAlarmData), "BRlp%IYyTYFntG!g7oPo$N==", "wP!n$!ZD%0k2g6Gahpdk6l=="));
deviceAlarmInfo.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(deviceAlarmData), "i2MvNzkedPgITpz2UcZS3A==", "ReQb3Swiz8frJ3+8l9RGvg=="));
}
return JSONUtil.toJsonStr(deviceAlarmInfo);
}catch (Exception e) {
......@@ -221,11 +221,11 @@ public class AlarmDataServiceImpl implements AlarmDataService {
System.out.println("wkk报警=====================" + JSONUtil.toJsonStr(wkkAlarmData));
if (wkkAlarmData.size() > 0) {
wkkAlarmInfo.setTailingNo(StaticParamUtils.WKKNO);
wkkAlarmInfo.setDepartmentId("123456789");
wkkAlarmInfo.setDepartmentId("911402247485664344");
wkkAlarmInfo.setProvinceId(StaticParamUtils.PROVINCENO);
wkkAlarmInfo.setType(StaticParamUtils.WKKALARM);
wkkAlarmInfo.setSendTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
wkkAlarmInfo.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(wkkAlarmData), "BRlp%IYyTYFntG!g7oPo$N==", "wP!n$!ZD%0k2g6Gahpdk6l=="));
wkkAlarmInfo.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(wkkAlarmData), "i2MvNzkedPgITpz2UcZS3A==", "ReQb3Swiz8frJ3+8l9RGvg=="));
}
return JSONUtil.toJsonStr(wkkAlarmInfo);
}catch (Exception e) {
......@@ -255,11 +255,11 @@ public class AlarmDataServiceImpl implements AlarmDataService {
System.out.println("内部沉降报警======================" + JSONUtil.toJsonStr(neibuchenjiangAlarmData));
if (neibuchenjiangAlarmData.size() > 0) {
nbwyAlarmInfo.setTailingNo(StaticParamUtils.WKKNO);
nbwyAlarmInfo.setDepartmentId("123456789");
nbwyAlarmInfo.setDepartmentId("911402247485664344");
nbwyAlarmInfo.setProvinceId(StaticParamUtils.PROVINCENO);
nbwyAlarmInfo.setType(StaticParamUtils.NEIBUWEIYIALARM);
nbwyAlarmInfo.setSendTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
nbwyAlarmInfo.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(neibuchenjiangAlarmData), "BRlp%IYyTYFntG!g7oPo$N==", "wP!n$!ZD%0k2g6Gahpdk6l=="));
nbwyAlarmInfo.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(neibuchenjiangAlarmData), "i2MvNzkedPgITpz2UcZS3A==", "ReQb3Swiz8frJ3+8l9RGvg=="));
}
return JSONUtil.toJsonStr(nbwyAlarmInfo);
}catch (Exception e) {
......@@ -289,11 +289,11 @@ public class AlarmDataServiceImpl implements AlarmDataService {
System.out.println("内部水平报警======================" + JSONUtil.toJsonStr(neibuchenjiangAlarmData));
if (neibuchenjiangAlarmData.size() > 0) {
nbwyAlarmInfo.setTailingNo(StaticParamUtils.WKKNO);
nbwyAlarmInfo.setDepartmentId("123456789");
nbwyAlarmInfo.setDepartmentId("911402247485664344");
nbwyAlarmInfo.setProvinceId(StaticParamUtils.PROVINCENO);
nbwyAlarmInfo.setType(StaticParamUtils.NEIBUWEIYIALARM);
nbwyAlarmInfo.setSendTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
nbwyAlarmInfo.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(neibuchenjiangAlarmData), "BRlp%IYyTYFntG!g7oPo$N==", "wP!n$!ZD%0k2g6Gahpdk6l=="));
nbwyAlarmInfo.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(neibuchenjiangAlarmData), "i2MvNzkedPgITpz2UcZS3A==", "ReQb3Swiz8frJ3+8l9RGvg=="));
}
return JSONUtil.toJsonStr(nbwyAlarmInfo);
}catch (Exception e) {
......
src/main/java/com/amqp/shanxi/service/impl/DeviceStaticDataInfoServiceImpl.java
View file @ 43c07fd4
......@@ -6,8 +6,6 @@ import com.amqp.shanxi.model.*;
import com.amqp.shanxi.service.DeviceStaticDataInfoService;
import com.amqp.shanxi.util.AESUtil;
import com.amqp.shanxi.util.StaticParamUtils;
import com.rabbitmq.client.AMQP;
import com.rabbitmq.client.Channel;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
......@@ -24,26 +22,27 @@ public class DeviceStaticDataInfoServiceImpl implements DeviceStaticDataInfoServ
/**
* 干滩设备信息
* @return
* @return StaticDataInfoModel
*/
@Override
public StaticDataInfoModel gantanDeviceInfo() {
try {
StaticDataInfoModel staticDataInfoModel = new StaticDataInfoModel();
List<GantanDeviceInfoModel> gantanDeviceInfos = deviceStaticDataInfoDao.findGantanDeviceInfo();
for (int i = 0; i < gantanDeviceInfos.size(); i++) {
gantanDeviceInfos.get(i).setEquipno(StaticParamUtils.GANTANNO + (Integer.valueOf(gantanDeviceInfos.get(i).getEquipno()) >= 10 ? gantanDeviceInfos.get(i).getEquipno() : "0" + gantanDeviceInfos.get(i).getEquipno()));
gantanDeviceInfos.get(i).setIs_used("1");
gantanDeviceInfos.get(i).setIs_sync("0");
//　经度　纬度
for (GantanDeviceInfoModel gantanDeviceInfo : gantanDeviceInfos) {
gantanDeviceInfo.setEquipno(StaticParamUtils.GANTANNO + (Integer.parseInt(gantanDeviceInfo.getEquipno()) >= 10 ? gantanDeviceInfo.getEquipno() : "0" + gantanDeviceInfo.getEquipno()));
gantanDeviceInfo.setIs_used("1");
gantanDeviceInfo.setIs_sync("0");
gantanDeviceInfo.setInstallationdate("2019-03-21");
}
staticDataInfoModel.setTailingNo(StaticParamUtils.WKKNO);
staticDataInfoModel.setDepartmentId("123456789");
staticDataInfoModel.setDepartmentId("911402247485664344");
staticDataInfoModel.setProvinceId(StaticParamUtils.PROVINCENO);
staticDataInfoModel.setType(StaticParamUtils.GANTANDEVICE);
staticDataInfoModel.setSendTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
staticDataInfoModel.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(gantanDeviceInfos), "BRlp%IYyTYFntG!g7oPo$N==", "wP!n$!ZD%0k2g6Gahpdk6l=="));
staticDataInfoModel.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(gantanDeviceInfos), "i2MvNzkedPgITpz2UcZS3A==", "ReQb3Swiz8frJ3+8l9RGvg=="));
System.out.println("干滩设备信息===========" + JSONUtil.toJsonStr(staticDataInfoModel));
return staticDataInfoModel;
}catch (Exception e){
......@@ -54,26 +53,31 @@ public class DeviceStaticDataInfoServiceImpl implements DeviceStaticDataInfoServ
/**
* 库水位设备信息
* @return
* 密钥：i2MvNzkedPgITpz2UcZS3A==
* * 向量：ReQb3Swiz8frJ3+8l9RGvg==
* @return StaticDataInfoModel
*/
@Override
public StaticDataInfoModel kushuiweiDeviceInfo() {
try {
StaticDataInfoModel staticDataInfoModel = new StaticDataInfoModel();
List<KushuiweiDeviceInfoModel> kushuiweiDeviceInfo = deviceStaticDataInfoDao.findKushuiweiDeviceInfo();
for (int i = 0; i < kushuiweiDeviceInfo.size(); i++) {
kushuiweiDeviceInfo.get(i).setEquipno(StaticParamUtils.KUSHUIWEINO + (Integer.valueOf(kushuiweiDeviceInfo.get(i).getEquipno()) >= 10 ? kushuiweiDeviceInfo.get(i).getEquipno() : "0" + kushuiweiDeviceInfo.get(i).getEquipno()));
kushuiweiDeviceInfo.get(i).setIs_used("1");
kushuiweiDeviceInfo.get(i).setIs_sync("0");
// 经度　纬度
for (KushuiweiDeviceInfoModel kushuiweiDeviceInfoModel : kushuiweiDeviceInfo) {
kushuiweiDeviceInfoModel.setEquipno(StaticParamUtils.KUSHUIWEINO + (Integer.parseInt(kushuiweiDeviceInfoModel.getEquipno()) >= 10 ? kushuiweiDeviceInfoModel.getEquipno() : "0" + kushuiweiDeviceInfoModel.getEquipno()));
kushuiweiDeviceInfoModel.setIs_used("1");
kushuiweiDeviceInfoModel.setIs_sync("0");
kushuiweiDeviceInfoModel.setInstallationdate("2019-03-21");
kushuiweiDeviceInfoModel.setInstalllocation(kushuiweiDeviceInfoModel.getManufacture());
kushuiweiDeviceInfoModel.setManufacture("");
}
staticDataInfoModel.setTailingNo(StaticParamUtils.WKKNO);
staticDataInfoModel.setDepartmentId("123456789");
staticDataInfoModel.setDepartmentId("911402247485664344");
staticDataInfoModel.setProvinceId(StaticParamUtils.PROVINCENO);
staticDataInfoModel.setType(StaticParamUtils.KUSHUIWEIDEVICE);
staticDataInfoModel.setSendTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
staticDataInfoModel.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(kushuiweiDeviceInfo), "BRlp%IYyTYFntG!g7oPo$N==", "wP!n$!ZD%0k2g6Gahpdk6l=="));
staticDataInfoModel.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(kushuiweiDeviceInfo), "i2MvNzkedPgITpz2UcZS3A==", "ReQb3Swiz8frJ3+8l9RGvg=="));
System.out.println("库水位设备信息===========" + JSONUtil.toJsonStr(staticDataInfoModel));
return staticDataInfoModel;
}catch (Exception e){
......@@ -84,26 +88,27 @@ public class DeviceStaticDataInfoServiceImpl implements DeviceStaticDataInfoServ
/**
* 表面位移设备信息
* @return
* @return StaticDataInfoModel
*/
@Override
public StaticDataInfoModel biaomianweiyiDeviceInfo() {
try {
StaticDataInfoModel staticDataInfoModel = new StaticDataInfoModel();
List<BiaomianweiyiDeviceInfoModel> biaomianweiyiDeviceInfo = deviceStaticDataInfoDao.findBiaomianweiyiDeviceInfo();
for (int i = 0; i < biaomianweiyiDeviceInfo.size(); i++) {
biaomianweiyiDeviceInfo.get(i).setEquipno(StaticParamUtils.KUSHUIWEINO + (Integer.valueOf(biaomianweiyiDeviceInfo.get(i).getEquipno()) >= 10 ? biaomianweiyiDeviceInfo.get(i).getEquipno() : "0" + biaomianweiyiDeviceInfo.get(i).getEquipno()));
biaomianweiyiDeviceInfo.get(i).setIs_used("1");
biaomianweiyiDeviceInfo.get(i).setIs_sync("0");
for (BiaomianweiyiDeviceInfoModel biaomianweiyiDeviceInfoModel : biaomianweiyiDeviceInfo) {
biaomianweiyiDeviceInfoModel.setEquipno(StaticParamUtils.KUSHUIWEINO + (Integer.parseInt(biaomianweiyiDeviceInfoModel.getEquipno()) >= 10 ? biaomianweiyiDeviceInfoModel.getEquipno() : "0" + biaomianweiyiDeviceInfoModel.getEquipno()));
biaomianweiyiDeviceInfoModel.setIs_used("1");
biaomianweiyiDeviceInfoModel.setIs_sync("0");
biaomianweiyiDeviceInfoModel.setInstallationdate("2019-03-21");
// 经度　纬度
}
staticDataInfoModel.setTailingNo(StaticParamUtils.WKKNO);
staticDataInfoModel.setDepartmentId("123456789");
staticDataInfoModel.setDepartmentId("911402247485664344");
staticDataInfoModel.setProvinceId(StaticParamUtils.PROVINCENO);
staticDataInfoModel.setType(StaticParamUtils.BIAOMIANWEIYIDEVICE);
staticDataInfoModel.setSendTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
staticDataInfoModel.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(biaomianweiyiDeviceInfo), "BRlp%IYyTYFntG!g7oPo$N==", "wP!n$!ZD%0k2g6Gahpdk6l=="));
staticDataInfoModel.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(biaomianweiyiDeviceInfo), "i2MvNzkedPgITpz2UcZS3A==", "ReQb3Swiz8frJ3+8l9RGvg=="));
System.out.println("表面位移设备信息===========" + JSONUtil.toJsonStr(staticDataInfoModel));
return staticDataInfoModel;
}catch (Exception e) {
......@@ -114,28 +119,33 @@ public class DeviceStaticDataInfoServiceImpl implements DeviceStaticDataInfoServ
/**
* 浸润线设备信息
* @return
* @return StaticDataInfoModel
*/
@Override
public StaticDataInfoModel jinrunxianDeviceInfo() {
try {
StaticDataInfoModel staticDataInfoModel = new StaticDataInfoModel();
List<JinrunxianDeviceInfoModel> jinrunxianDeviceInfo = deviceStaticDataInfoDao.findJinrunxianDeviceInfo();
for (int i = 0; i < jinrunxianDeviceInfo.size(); i++) {
jinrunxianDeviceInfo.get(i).setEquipno(StaticParamUtils.JINRUNXIANNO + (Integer.valueOf(jinrunxianDeviceInfo.get(i).getEquipno()) >= 10 ? jinrunxianDeviceInfo.get(i).getEquipno() : "0" + jinrunxianDeviceInfo.get(i).getEquipno()));
jinrunxianDeviceInfo.get(i).setIs_used("1");
jinrunxianDeviceInfo.get(i).setIs_sync("0");
for (JinrunxianDeviceInfoModel jinrunxianDeviceInfoModel : jinrunxianDeviceInfo) {
jinrunxianDeviceInfoModel.setEquipno(StaticParamUtils.JINRUNXIANNO + (Integer.parseInt(jinrunxianDeviceInfoModel.getEquipno()) >= 10 ? jinrunxianDeviceInfoModel.getEquipno() : "0" + jinrunxianDeviceInfoModel.getEquipno()));
jinrunxianDeviceInfoModel.setIs_used("1");
jinrunxianDeviceInfoModel.setIs_sync("0");
jinrunxianDeviceInfoModel.setInstallationdate("2019-03-21");
String[] split = jinrunxianDeviceInfoModel.getManufacture().split("//|");
jinrunxianDeviceInfoModel.setHoledepth(split[0]);
jinrunxianDeviceInfoModel.setBurialdepath(split[1]);
jinrunxianDeviceInfoModel.setManufacture("");
// 经度　纬度
}
staticDataInfoModel.setTailingNo(StaticParamUtils.WKKNO);
staticDataInfoModel.setDepartmentId("123456789");
staticDataInfoModel.setDepartmentId("911402247485664344");
staticDataInfoModel.setProvinceId(StaticParamUtils.PROVINCENO);
staticDataInfoModel.setType(StaticParamUtils.JINRUNXIANDEVICE);
staticDataInfoModel.setSendTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
staticDataInfoModel.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(jinrunxianDeviceInfo), "BRlp%IYyTYFntG!g7oPo$N==", "wP!n$!ZD%0k2g6Gahpdk6l=="));
staticDataInfoModel.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(jinrunxianDeviceInfo), "i2MvNzkedPgITpz2UcZS3A==", "ReQb3Swiz8frJ3+8l9RGvg=="));
System.out.println("浸润线设备信息===========" + JSONUtil.toJsonStr(staticDataInfoModel));
return staticDataInfoModel;
}catch (Exception e){
} catch (Exception e) {
e.printStackTrace();
return null;
}
......@@ -143,26 +153,28 @@ public class DeviceStaticDataInfoServiceImpl implements DeviceStaticDataInfoServ
/**
* 降雨量设备信息
* @return
* @return StaticDataInfoModel
*/
@Override
public StaticDataInfoModel jiangyuliangDeviceInfo() {
try {
StaticDataInfoModel staticDataInfoModel = new StaticDataInfoModel();
List<JinrunxianDeviceInfoModel> jiangyuliangDeviceInfo = deviceStaticDataInfoDao.findJiangyuliangDeviceInfo();
for (int i = 0; i < jiangyuliangDeviceInfo.size(); i++) {
jiangyuliangDeviceInfo.get(i).setEquipno(StaticParamUtils.JIANGYULIANGNO + (Integer.valueOf(jiangyuliangDeviceInfo.get(i).getEquipno()) >= 10 ? jiangyuliangDeviceInfo.get(i).getEquipno() : "0" + jiangyuliangDeviceInfo.get(i).getEquipno()));
jiangyuliangDeviceInfo.get(i).setIs_used("1");
jiangyuliangDeviceInfo.get(i).setIs_sync("0");
List<JiangyuliangDeviceInfoModel> jiangyuliangDeviceInfo = deviceStaticDataInfoDao.findJiangyuliangDeviceInfo();
for (JiangyuliangDeviceInfoModel jiangyuliangDeviceInfoModel : jiangyuliangDeviceInfo) {
jiangyuliangDeviceInfoModel.setEquipno(StaticParamUtils.JIANGYULIANGNO + (Integer.parseInt(jiangyuliangDeviceInfoModel.getEquipno()) >= 10 ? jiangyuliangDeviceInfoModel.getEquipno() : "0" + jiangyuliangDeviceInfoModel.getEquipno()));
jiangyuliangDeviceInfoModel.setIs_used("1");
jiangyuliangDeviceInfoModel.setIs_sync("0");
jiangyuliangDeviceInfoModel.setInstallationdate("2019-03-21");
// 经度　纬度
}
staticDataInfoModel.setTailingNo(StaticParamUtils.WKKNO);
staticDataInfoModel.setDepartmentId("123456789");
staticDataInfoModel.setDepartmentId("911402247485664344");
staticDataInfoModel.setProvinceId(StaticParamUtils.PROVINCENO);
staticDataInfoModel.setType(StaticParamUtils.JIANGYULIANGEDEVICE);
staticDataInfoModel.setSendTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
staticDataInfoModel.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(jiangyuliangDeviceInfo), "BRlp%IYyTYFntG!g7oPo$N==", "wP!n$!ZD%0k2g6Gahpdk6l=="));
staticDataInfoModel.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(jiangyuliangDeviceInfo), "i2MvNzkedPgITpz2UcZS3A==", "ReQb3Swiz8frJ3+8l9RGvg=="));
System.out.println("降雨量设备信息===========" + JSONUtil.toJsonStr(staticDataInfoModel));
return staticDataInfoModel;
}catch (Exception e) {
......@@ -173,26 +185,26 @@ public class DeviceStaticDataInfoServiceImpl implements DeviceStaticDataInfoServ
/**
* 内部位移
* @return
* @return StaticDataInfoModel
*/
@Override
public StaticDataInfoModel neibuweiyiDeviceInfo() {
try{
StaticDataInfoModel staticDataInfoModel = new StaticDataInfoModel();
List<NeibuweiyiDeviceInfoModel> neibuweiyiDeviceInfo = deviceStaticDataInfoDao.findNeibuweiyiDeviceInfo();
for (int i = 0; i < neibuweiyiDeviceInfo.size(); i++) {
neibuweiyiDeviceInfo.get(i).setEquipno(StaticParamUtils.NEIBUWEIYINO + (Integer.valueOf(neibuweiyiDeviceInfo.get(i).getEquipno()) >= 10 ? neibuweiyiDeviceInfo.get(i).getEquipno() : "0" + neibuweiyiDeviceInfo.get(i).getEquipno()));
neibuweiyiDeviceInfo.get(i).setIs_used("1");
neibuweiyiDeviceInfo.get(i).setIs_sync("0");
for (NeibuweiyiDeviceInfoModel neibuweiyiDeviceInfoModel : neibuweiyiDeviceInfo) {
neibuweiyiDeviceInfoModel.setEquipno(StaticParamUtils.NEIBUWEIYINO + (Integer.parseInt(neibuweiyiDeviceInfoModel.getEquipno()) >= 10 ? neibuweiyiDeviceInfoModel.getEquipno() : "0" + neibuweiyiDeviceInfoModel.getEquipno()));
neibuweiyiDeviceInfoModel.setIs_used("1");
neibuweiyiDeviceInfoModel.setIs_sync("0");
// 经度　纬度
}
staticDataInfoModel.setTailingNo(StaticParamUtils.WKKNO);
staticDataInfoModel.setDepartmentId("123456789");
staticDataInfoModel.setDepartmentId("911402247485664344");
staticDataInfoModel.setProvinceId(StaticParamUtils.PROVINCENO);
staticDataInfoModel.setType(StaticParamUtils.NEIBUWEIYIDEVICE);
staticDataInfoModel.setSendTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
staticDataInfoModel.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(neibuweiyiDeviceInfo), "BRlp%IYyTYFntG!g7oPo$N==", "wP!n$!ZD%0k2g6Gahpdk6l=="));
staticDataInfoModel.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(neibuweiyiDeviceInfo), "i2MvNzkedPgITpz2UcZS3A==", "ReQb3Swiz8frJ3+8l9RGvg=="));
System.out.println("内部位移设备信息===========" + JSONUtil.toJsonStr(staticDataInfoModel));
return staticDataInfoModel;
}catch (Exception e) {
......@@ -207,12 +219,11 @@ public class DeviceStaticDataInfoServiceImpl implements DeviceStaticDataInfoServ
StaticDataInfoModel staticDataInfoModel = new StaticDataInfoModel();
List<WkkBasicInfoModel> wkkBasicInfo = deviceStaticDataInfoDao.findWkkBasicInfo();
staticDataInfoModel.setTailingNo(StaticParamUtils.WKKNO);
staticDataInfoModel.setDepartmentId("123456789");
staticDataInfoModel.setDepartmentId("911402247485664344");
staticDataInfoModel.setProvinceId(StaticParamUtils.PROVINCENO);
staticDataInfoModel.setType(StaticParamUtils.BASICINFO);
staticDataInfoModel.setSendTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
staticDataInfoModel.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(wkkBasicInfo), "BRlp%IYyTYFntG!g7oPo$N==", "wP!n$!ZD%0k2g6Gahpdk6l=="));
System.out.println("尾矿库基础信息===========" + JSONUtil.toJsonStr(staticDataInfoModel));
staticDataInfoModel.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(wkkBasicInfo), "i2MvNzkedPgITpz2UcZS3A==", "ReQb3Swiz8frJ3+8l9RGvg=="));
return staticDataInfoModel;
}catch (Exception e){
e.printStackTrace();
......
src/main/java/com/amqp/shanxi/service/impl/RealTimeInfoServiceImpl.java
View file @ 43c07fd4
......@@ -38,11 +38,11 @@ public class RealTimeInfoServiceImpl implements RealTimeInfoService {
System.out.println("gt实时数据=======================" + JSONUtil.toJsonStr(gantanRealTimeInfoModelList));
gantanRealTime.setTailingNo(StaticParamUtils.WKKNO);
gantanRealTime.setDepartmentId("123456789");
gantanRealTime.setDepartmentId("911402247485664344");
gantanRealTime.setProvinceId(StaticParamUtils.PROVINCENO);
gantanRealTime.setType(StaticParamUtils.GANTANDATA);
gantanRealTime.setSendTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
gantanRealTime.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(gantanRealTimeInfoModelList), "BRlp%IYyTYFntG!g7oPo$N==", "wP!n$!ZD%0k2g6Gahpdk6l=="));
gantanRealTime.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(gantanRealTimeInfoModelList), "i2MvNzkedPgITpz2UcZS3A==", "ReQb3Swiz8frJ3+8l9RGvg=="));
return JSONUtil.toJsonStr(gantanRealTime);
}catch(Exception e) {
e.printStackTrace();
......@@ -55,7 +55,6 @@ public class RealTimeInfoServiceImpl implements RealTimeInfoService {
try {
List<KushuiweiRealTimeInfoModel> kushuiweiRealTimeData = realTimeInfoDao.findKushuiweiRealTimeData();
StaticDataInfoModel kswRealTimeData = new StaticDataInfoModel();
List<KushuiweiAlarmInfoModel> kswAlarmInfoModelList = null;
for (KushuiweiRealTimeInfoModel kushuiweiRealTimeInfoModel : kushuiweiRealTimeData) {
// 未报警
kushuiweiRealTimeInfoModel.setSensorno(StaticParamUtils.KUSHUIWEINO + (kushuiweiRealTimeInfoModel.getRecordid() >= 10 ? String.valueOf(kushuiweiRealTimeInfoModel.getRecordid()) : "0" + kushuiweiRealTimeInfoModel.getRecordid()));
......@@ -66,11 +65,11 @@ public class RealTimeInfoServiceImpl implements RealTimeInfoService {
System.out.println("ksw实时数据=======================" + JSONUtil.toJsonStr(kushuiweiRealTimeData));
kswRealTimeData.setTailingNo(StaticParamUtils.WKKNO);
kswRealTimeData.setDepartmentId("123456789");
kswRealTimeData.setDepartmentId("911402247485664344");
kswRealTimeData.setProvinceId(StaticParamUtils.PROVINCENO);
kswRealTimeData.setType(StaticParamUtils.KUSHUIWEIDATA);
kswRealTimeData.setSendTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
kswRealTimeData.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(kushuiweiRealTimeData), "BRlp%IYyTYFntG!g7oPo$N==", "wP!n$!ZD%0k2g6Gahpdk6l=="));
kswRealTimeData.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(kushuiweiRealTimeData), "i2MvNzkedPgITpz2UcZS3A==", "ReQb3Swiz8frJ3+8l9RGvg=="));
return JSONUtil.toJsonStr(kswRealTimeData);
}catch(Exception e) {
e.printStackTrace();
......@@ -84,22 +83,21 @@ public class RealTimeInfoServiceImpl implements RealTimeInfoService {
try {
List<BiaomianweiyiRealTimeInfoModel> biaomianweiyiRealTimeData = realTimeInfoDao.findBiaomianweiyiRealTimeData();
StaticDataInfoModel bmwyRealTimeData = new StaticDataInfoModel();
List<BiaomianweiyiAlarmInfoModel> bmwyAlarmInfoModelList = null;
for (int i = 0; i < biaomianweiyiRealTimeData.size(); i++) {
for (BiaomianweiyiRealTimeInfoModel biaomianweiyiRealTimeDatum : biaomianweiyiRealTimeData) {
// 未报警
biaomianweiyiRealTimeData.get(i).setSensorno(StaticParamUtils.BIAOMIANWEIYINO + (biaomianweiyiRealTimeData.get(i).getRecordid() >= 10 ? String.valueOf(biaomianweiyiRealTimeData.get(i).getRecordid()) : "0" + biaomianweiyiRealTimeData.get(i).getRecordid()));
if (biaomianweiyiRealTimeData.get(i).getCollectdate().contains(".")) {
biaomianweiyiRealTimeData.get(i).setCollectdate(biaomianweiyiRealTimeData.get(i).getCollectdate().substring(0, biaomianweiyiRealTimeData.get(i).getCollectdate().indexOf(".")));
biaomianweiyiRealTimeDatum.setSensorno(StaticParamUtils.BIAOMIANWEIYINO + (biaomianweiyiRealTimeDatum.getRecordid() >= 10 ? String.valueOf(biaomianweiyiRealTimeDatum.getRecordid()) : "0" + biaomianweiyiRealTimeDatum.getRecordid()));
if (biaomianweiyiRealTimeDatum.getCollectdate().contains(".")) {
biaomianweiyiRealTimeDatum.setCollectdate(biaomianweiyiRealTimeDatum.getCollectdate().substring(0, biaomianweiyiRealTimeDatum.getCollectdate().indexOf(".")));
}
}
System.out.println("bmwy实时数据=======================" + JSONUtil.toJsonStr(biaomianweiyiRealTimeData));
bmwyRealTimeData.setTailingNo(StaticParamUtils.WKKNO);
bmwyRealTimeData.setDepartmentId("123456789");
bmwyRealTimeData.setDepartmentId("911402247485664344");
bmwyRealTimeData.setProvinceId(StaticParamUtils.PROVINCENO);
bmwyRealTimeData.setType(StaticParamUtils.BIAOMIANWEIYIDATA);
bmwyRealTimeData.setSendTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
bmwyRealTimeData.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(biaomianweiyiRealTimeData), "BRlp%IYyTYFntG!g7oPo$N==", "wP!n$!ZD%0k2g6Gahpdk6l=="));
bmwyRealTimeData.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(biaomianweiyiRealTimeData), "i2MvNzkedPgITpz2UcZS3A==", "ReQb3Swiz8frJ3+8l9RGvg=="));
return JSONUtil.toJsonStr(bmwyRealTimeData);
}catch (Exception e) {
e.printStackTrace();
......@@ -112,22 +110,21 @@ public class RealTimeInfoServiceImpl implements RealTimeInfoService {
try {
List<JinrunxianRealTimeInfoModel> jinrunxianRealTimeData = realTimeInfoDao.findJinrunxianRealTimeData();
StaticDataInfoModel jrxRealTimeData = new StaticDataInfoModel();
List<JinrunxianAlarmInfoModel> jrxAlarmInfoModelList = null;
for (int i = 0; i < jinrunxianRealTimeData.size(); i++) {
for (JinrunxianRealTimeInfoModel jinrunxianRealTimeDatum : jinrunxianRealTimeData) {
// 未报警
jinrunxianRealTimeData.get(i).setSensorno(StaticParamUtils.JINRUNXIANNO + (jinrunxianRealTimeData.get(i).getRecordid() >= 10 ? String.valueOf(jinrunxianRealTimeData.get(i).getRecordid()) : "0" + jinrunxianRealTimeData.get(i).getRecordid()));
if (jinrunxianRealTimeData.get(i).getCollectdate().contains(".")) {
jinrunxianRealTimeData.get(i).setCollectdate(jinrunxianRealTimeData.get(i).getCollectdate().substring(0, jinrunxianRealTimeData.get(i).getCollectdate().indexOf(".")));
jinrunxianRealTimeDatum.setSensorno(StaticParamUtils.JINRUNXIANNO + (jinrunxianRealTimeDatum.getRecordid() >= 10 ? String.valueOf(jinrunxianRealTimeDatum.getRecordid()) : "0" + jinrunxianRealTimeDatum.getRecordid()));
if (jinrunxianRealTimeDatum.getCollectdate().contains(".")) {
jinrunxianRealTimeDatum.setCollectdate(jinrunxianRealTimeDatum.getCollectdate().substring(0, jinrunxianRealTimeDatum.getCollectdate().indexOf(".")));
}
}
System.out.println("jrx实时数据=======================" + JSONUtil.toJsonStr(jinrunxianRealTimeData));
jrxRealTimeData.setTailingNo(StaticParamUtils.WKKNO);
jrxRealTimeData.setDepartmentId("123456789");
jrxRealTimeData.setDepartmentId("911402247485664344");
jrxRealTimeData.setProvinceId(StaticParamUtils.PROVINCENO);
jrxRealTimeData.setType(StaticParamUtils.JINRUNXIANDATA);
jrxRealTimeData.setSendTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
jrxRealTimeData.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(jinrunxianRealTimeData), "BRlp%IYyTYFntG!g7oPo$N==", "wP!n$!ZD%0k2g6Gahpdk6l=="));
jrxRealTimeData.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(jinrunxianRealTimeData), "i2MvNzkedPgITpz2UcZS3A==", "ReQb3Swiz8frJ3+8l9RGvg=="));
return JSONUtil.toJsonStr(jrxRealTimeData);
}catch(Exception e) {
e.printStackTrace();
......@@ -140,22 +137,21 @@ public class RealTimeInfoServiceImpl implements RealTimeInfoService {
try {
List<JiangyuliangRealTimeInfoModel> jiangyuliangRealTimeData = realTimeInfoDao.findJiangyuliangRealTimeData();
StaticDataInfoModel jylRealTimeData = new StaticDataInfoModel();
List<JiangyuliangAlarmInfoModel> jylAlarmInfoModelList = null;
for (int i = 0; i < jiangyuliangRealTimeData.size(); i++) {
for (JiangyuliangRealTimeInfoModel jiangyuliangRealTimeDatum : jiangyuliangRealTimeData) {
// 未报警
jiangyuliangRealTimeData.get(i).setSensorno(StaticParamUtils.JIANGYULIANGNO + (jiangyuliangRealTimeData.get(i).getRecordid() >= 10 ? String.valueOf(jiangyuliangRealTimeData.get(i).getRecordid()) : "0" + jiangyuliangRealTimeData.get(i).getRecordid()));
if (jiangyuliangRealTimeData.get(i).getCollectdate().contains(".")) {
jiangyuliangRealTimeData.get(i).setCollectdate(jiangyuliangRealTimeData.get(i).getCollectdate().substring(0, jiangyuliangRealTimeData.get(i).getCollectdate().indexOf(".")));
jiangyuliangRealTimeDatum.setSensorno(StaticParamUtils.JIANGYULIANGNO + (jiangyuliangRealTimeDatum.getRecordid() >= 10 ? String.valueOf(jiangyuliangRealTimeDatum.getRecordid()) : "0" + jiangyuliangRealTimeDatum.getRecordid()));
if (jiangyuliangRealTimeDatum.getCollectdate().contains(".")) {
jiangyuliangRealTimeDatum.setCollectdate(jiangyuliangRealTimeDatum.getCollectdate().substring(0, jiangyuliangRealTimeDatum.getCollectdate().indexOf(".")));
}
}
System.out.println("jyl实时数据=======================" + JSONUtil.toJsonStr(jiangyuliangRealTimeData));
jylRealTimeData.setTailingNo(StaticParamUtils.WKKNO);
jylRealTimeData.setDepartmentId("123456789");
jylRealTimeData.setDepartmentId("911402247485664344");
jylRealTimeData.setProvinceId(StaticParamUtils.PROVINCENO);
jylRealTimeData.setType(StaticParamUtils.JIANGYULIANGDATA);
jylRealTimeData.setSendTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
jylRealTimeData.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(jiangyuliangRealTimeData), "BRlp%IYyTYFntG!g7oPo$N==", "wP!n$!ZD%0k2g6Gahpdk6l=="));
jylRealTimeData.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(jiangyuliangRealTimeData), "i2MvNzkedPgITpz2UcZS3A==", "ReQb3Swiz8frJ3+8l9RGvg=="));
return JSONUtil.toJsonStr(jylRealTimeData);
}catch (Exception e){
e.printStackTrace();
......@@ -198,11 +194,11 @@ public class RealTimeInfoServiceImpl implements RealTimeInfoService {
System.out.println("device实时数据=======================" + JSONUtil.toJsonStr(deviceRealTimeData));
deviceRealTimeDataModel.setTailingNo(StaticParamUtils.WKKNO);
deviceRealTimeDataModel.setDepartmentId("123456789");
deviceRealTimeDataModel.setDepartmentId("911402247485664344");
deviceRealTimeDataModel.setProvinceId(StaticParamUtils.PROVINCENO);
deviceRealTimeDataModel.setType(StaticParamUtils.DEVICEDATA);
deviceRealTimeDataModel.setSendTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
deviceRealTimeDataModel.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(deviceRealTimeData), "BRlp%IYyTYFntG!g7oPo$N==", "wP!n$!ZD%0k2g6Gahpdk6l=="));
deviceRealTimeDataModel.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(deviceRealTimeData), "i2MvNzkedPgITpz2UcZS3A==", "ReQb3Swiz8frJ3+8l9RGvg=="));
return JSONUtil.toJsonStr(deviceRealTimeDataModel);
}catch (Exception e) {
e.printStackTrace();
......@@ -219,11 +215,11 @@ public class RealTimeInfoServiceImpl implements RealTimeInfoService {
wkkRealTimeData.get(0).setState("1");
wkkRealTimeData.get(0).setCollectdat(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
wkkRealTimeDataModel.setTailingNo(StaticParamUtils.WKKNO);
wkkRealTimeDataModel.setDepartmentId("123456789");
wkkRealTimeDataModel.setDepartmentId("911402247485664344");
wkkRealTimeDataModel.setProvinceId(StaticParamUtils.PROVINCENO);
wkkRealTimeDataModel.setType(StaticParamUtils.WKKDATA);
wkkRealTimeDataModel.setSendTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
wkkRealTimeDataModel.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(wkkRealTimeData), "BRlp%IYyTYFntG!g7oPo$N==", "wP!n$!ZD%0k2g6Gahpdk6l=="));
wkkRealTimeDataModel.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(wkkRealTimeData), "i2MvNzkedPgITpz2UcZS3A==", "ReQb3Swiz8frJ3+8l9RGvg=="));
System.out.println("wkk实时数据=======================" + JSONUtil.toJsonStr(wkkRealTimeData));
return JSONUtil.toJsonStr(wkkRealTimeDataModel);
}else {
......@@ -233,11 +229,11 @@ public class RealTimeInfoServiceImpl implements RealTimeInfoService {
wkkRealTimeData.add(wkkRealTimeInfoModel);
wkkRealTimeDataModel.setTailingNo(StaticParamUtils.WKKNO);
wkkRealTimeDataModel.setDepartmentId("123456789");
wkkRealTimeDataModel.setDepartmentId("911402247485664344");
wkkRealTimeDataModel.setProvinceId(StaticParamUtils.PROVINCENO);
wkkRealTimeDataModel.setType(StaticParamUtils.WKKDATA);
wkkRealTimeDataModel.setSendTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
wkkRealTimeDataModel.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(wkkRealTimeData), "BRlp%IYyTYFntG!g7oPo$N==", "wP!n$!ZD%0k2g6Gahpdk6l=="));
wkkRealTimeDataModel.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(wkkRealTimeData), "i2MvNzkedPgITpz2UcZS3A==", "ReQb3Swiz8frJ3+8l9RGvg=="));
System.out.println("wkk实时数据=======================" + JSONUtil.toJsonStr(wkkRealTimeData));
return JSONUtil.toJsonStr(wkkRealTimeDataModel);
}
......@@ -263,11 +259,11 @@ public class RealTimeInfoServiceImpl implements RealTimeInfoService {
deviceOffLineData.get(i).setCollectdate(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
}
deviceOffLineDataModel.setTailingNo(StaticParamUtils.WKKNO);
deviceOffLineDataModel.setDepartmentId("123456789");
deviceOffLineDataModel.setDepartmentId("911402247485664344");
deviceOffLineDataModel.setProvinceId(StaticParamUtils.PROVINCENO);
deviceOffLineDataModel.setType(StaticParamUtils.DEVICEOFFLINE);
deviceOffLineDataModel.setSendTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
deviceOffLineDataModel.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(deviceOffLineData), "BRlp%IYyTYFntG!g7oPo$N==" , "wP!n$!ZD%0k2g6Gahpdk6l=="));
deviceOffLineDataModel.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(deviceOffLineData), "i2MvNzkedPgITpz2UcZS3A==" , "ReQb3Swiz8frJ3+8l9RGvg=="));
}
return JSONUtil.toJsonStr(deviceOffLineData);
}catch(Exception e) {
......@@ -291,11 +287,11 @@ public class RealTimeInfoServiceImpl implements RealTimeInfoService {
System.out.println("nbcj内部沉降实时数据=======================" + JSONUtil.toJsonStr(neibuChenjiangRealTimeData));
nbcjRealTimeData.setTailingNo(StaticParamUtils.WKKNO);
nbcjRealTimeData.setDepartmentId("123456789");
nbcjRealTimeData.setDepartmentId("911402247485664344");
nbcjRealTimeData.setProvinceId(StaticParamUtils.PROVINCENO);
nbcjRealTimeData.setType(StaticParamUtils.NEIBUWEIYIDATA);
nbcjRealTimeData.setSendTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
nbcjRealTimeData.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(neibuChenjiangRealTimeData), "BRlp%IYyTYFntG!g7oPo$N==", "wP!n$!ZD%0k2g6Gahpdk6l=="));
nbcjRealTimeData.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(neibuChenjiangRealTimeData), "i2MvNzkedPgITpz2UcZS3A==", "ReQb3Swiz8frJ3+8l9RGvg=="));
return JSONUtil.toJsonStr(nbcjRealTimeData);
}catch (Exception e) {
e.printStackTrace();
......@@ -319,11 +315,11 @@ public class RealTimeInfoServiceImpl implements RealTimeInfoService {
System.out.println("nbsp内部水平实时数据=======================" + JSONUtil.toJsonStr(neibuShuipingRealTimeData));
nbcjRealTimeData.setTailingNo(StaticParamUtils.WKKNO);
nbcjRealTimeData.setDepartmentId("123456789");
nbcjRealTimeData.setDepartmentId("911402247485664344");
nbcjRealTimeData.setProvinceId(StaticParamUtils.PROVINCENO);
nbcjRealTimeData.setType(StaticParamUtils.NEIBUWEIYIDATA);
nbcjRealTimeData.setSendTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
nbcjRealTimeData.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(neibuShuipingRealTimeData), "BRlp%IYyTYFntG!g7oPo$N==", "wP!n$!ZD%0k2g6Gahpdk6l=="));
nbcjRealTimeData.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(neibuShuipingRealTimeData), "i2MvNzkedPgITpz2UcZS3A==", "ReQb3Swiz8frJ3+8l9RGvg=="));
return JSONUtil.toJsonStr(nbcjRealTimeData);
}catch (Exception e) {
e.printStackTrace();
......
src/main/java/com/amqp/shanxi/util/Sender.java
View file @ 43c07fd4
......@@ -14,7 +14,7 @@ public class Sender {
private static final String EXCHANGE_NAME = "basicData";
public static void main(String[] argv) throws IOException, TimeoutException {
new ExchangeTopic("equipInfo.#");
new ExchangeTopic("tailingInfo");
}
......@@ -22,7 +22,7 @@ public class Sender {
public ExchangeTopic(final String routingKey) throws IOException, TimeoutException {
ConnectionFactory factory = new ConnectionFactory();
//rabbitmq监听IP
factory.setHost("192.168.100.252");
factory.setHost("192.168.3.252");
//rabbitmq监听默认端口
factory.setPort(5672);
//设置访问的用户
......@@ -46,7 +46,6 @@ public class Sender {
public void handleDelivery(String consumerTag, Envelope envelope,
AMQP.BasicProperties properties, byte[] body) throws IOException {
String message = new String(body, "UTF-8");
System.out.println("[routingKey = "+ routingKey +"] Received msg is '" + message + "'");
}
};
......
src/main/java/com/amqp/shanxi/util/StaticParamUtils.java
View file @ 43c07fd4
......@@ -199,7 +199,7 @@ public class StaticParamUtils {
}
@Value("${datatype.jiangyuliangdata}")
public static void setJIANGYULIANGDATA(String JIANGYULIANGDATA) {
public void setJIANGYULIANGDATA(String JIANGYULIANGDATA) {
StaticParamUtils.JIANGYULIANGDATA = JIANGYULIANGDATA;
}
......@@ -244,27 +244,27 @@ public class StaticParamUtils {
}
@Value("${datatype.jiangyuliangalarm}")
public static void setJIANGYULIANGALARM(String JIANGYULIANGALARM) {
public void setJIANGYULIANGALARM(String JIANGYULIANGALARM) {
StaticParamUtils.JIANGYULIANGALARM = JIANGYULIANGALARM;
}
@Value("${datatype.shenliuliangalarm}")
public static void setSHENLIULIANGALARM(String SHENLIULIANGALARM) {
public void setSHENLIULIANGALARM(String SHENLIULIANGALARM) {
StaticParamUtils.SHENLIULIANGALARM = SHENLIULIANGALARM;
}
@Value("${datatype.devicealarm}")
public static void setDEVICEALARM(String DEVICEALARM) {
public void setDEVICEALARM(String DEVICEALARM) {
StaticParamUtils.DEVICEALARM = DEVICEALARM;
}
@Value("${datatype.wkkalarm}")
public static void setWKKALARM(String WKKALARM) {
public void setWKKALARM(String WKKALARM) {
StaticParamUtils.WKKALARM = WKKALARM;
}
@Value("${datatype.deviceoffline}")
public static void setDEVICEOFFLINE(String DEVICEOFFLINE) {
public void setDEVICEOFFLINE(String DEVICEOFFLINE) {
StaticParamUtils.DEVICEOFFLINE = DEVICEOFFLINE;
}
}
src/main/resources/application.yml
View file @ 43c07fd4
server:
port: 9999
port: 5672
spring:
datasource:
driver-class-name: org.postgresql.Driver
url: jdbc:postgresql://192.168.100.220:5432/MineTRS_hongyun1
url: jdbc:postgresql://localhost:5432/MineTRS_hongwei
username: postgres
password: red___
rabbitmq:
host: 114.115.212.187
port: 5672
username: bhsoft
password: bhsoft
template:
retry:
enabled: true #代理链接丢失，　启动重试AMQPTemplate
initial-interval: 2s
virtual-host: /
publisher-confirms: true
publisher-returns: true
device: # 设备编码
gantanno: '140924005201'
kushuiweino: '140924005202'
biaomianweiyino: '140924005203'
neibuweiyino: '140924005204'
jinrunxianno: '140924005205'
jiangyuliangno: '140924005206'
shenliuliangno: '140924005207'
#password: ENC(MUOMhFvUHg7PHf1SB5lEs7cCgxexl14k)
password: mengzi--
device: # 设备编码 -parameters
gantanno: '140224000301'
kushuiweino: '140224000302'
biaomianweiyino: '140224000303'
neibuweiyino: '140224000304'
jinrunxianno: '140224000305'
jiangyuliangno: '140224000306'
shenliuliangno: '140224000307'
basic: # 基础信息
provinceno: '14'
wkkno: '1409240052'
wkkno: '1402240003'
datatype:
basicinfo: '0001'
......@@ -61,5 +48,9 @@ datatype:
devicealarm: '2003'
wkkalarm: '2103'
deviceoffline: '2202'
#jasypt:
# encryptor:
# password: 71101109104111
# 加密算法设置 3.0.0 以后
# algorithm: PBEWithMD5AndDES
# iv-generator-classname: org.jasypt.iv.NoIvGenerator
src/test/java/com/amqp/shanxi/ShanxiApplicationTests.java
View file @ 43c07fd4
package com.amqp.shanxi;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;
@SpringBootTest
class ShanxiApplicationTests {
@Test
void contextLoads() {
}
......
target/classes/application.yml
View file @ 43c07fd4
server:
port: 9999
port: 5672
spring:
datasource:
driver-class-name: org.postgresql.Driver
url: jdbc:postgresql://192.168.100.220:5432/MineTRS_hongyun1
url: jdbc:postgresql://localhost:5432/MineTRS_hongwei
username: postgres
password: red___
rabbitmq:
host: 114.115.212.187
port: 5672
username: bhsoft
password: bhsoft
template:
retry:
enabled: true #代理链接丢失，　启动重试AMQPTemplate
initial-interval: 2s
virtual-host: /
publisher-confirms: true
publisher-returns: true
device: # 设备编码
gantanno: '140924005201'
kushuiweino: '140924005202'
biaomianweiyino: '140924005203'
neibuweiyino: '140924005204'
jinrunxianno: '140924005205'
jiangyuliangno: '140924005206'
shenliuliangno: '140924005207'
#password: ENC(MUOMhFvUHg7PHf1SB5lEs7cCgxexl14k)
password: mengzi--
device: # 设备编码 -parameters
gantanno: '140224000301'
kushuiweino: '140224000302'
biaomianweiyino: '140224000303'
neibuweiyino: '140224000304'
jinrunxianno: '140224000305'
jiangyuliangno: '140224000306'
shenliuliangno: '140224000307'
basic: # 基础信息
provinceno: '14'
wkkno: '1409240052'
wkkno: '1402240003'
datatype:
basicinfo: '0001'
......@@ -61,5 +48,9 @@ datatype:
devicealarm: '2003'
wkkalarm: '2103'
deviceoffline: '2202'
#jasypt:
# encryptor:
# password: 71101109104111
# 加密算法设置 3.0.0 以后
# algorithm: PBEWithMD5AndDES
# iv-generator-classname: org.jasypt.iv.NoIvGenerator
target/maven-archiver/pom.properties 0 → 100644
View file @ 43c07fd4
artifactId=shanxi
groupId=com.amqp
version=0.0.1-SNAPSHOT
target/maven-status/maven-compiler-plugin/compile/default-compile/createdFiles.lst 0 → 100644
View file @ 43c07fd4
com/amqp/shanxi/util/AESUtil.class
com/amqp/shanxi/util/Sender$ExchangeTopic.class
com/amqp/shanxi/model/GantanRealTimeInfoModel.class
com/amqp/shanxi/util/Sender.class
com/amqp/shanxi/model/NeibuweiyiDeviceInfoModel.class
com/amqp/shanxi/service/RealTimeInfoService.class
com/amqp/shanxi/model/DeviceAlarmInfoModel.class
com/amqp/shanxi/Sender.class
com/amqp/shanxi/model/BiaomianweiyiRealTimeInfoModel.class
com/amqp/shanxi/model/BiaomianweiyiAlarmInfoModel.class
com/amqp/shanxi/model/TabSensorModel.class
com/amqp/shanxi/model/KushuiweiRealTimeInfoModel.class
com/amqp/shanxi/service/DeviceStaticDataAMQPService.class
com/amqp/shanxi/util/AMQPTopicStaticDataConfig.class
com/amqp/shanxi/service/impl/RealTimeInfoServiceImpl.class
com/amqp/shanxi/util/Constants.class
com/amqp/shanxi/dao/RealTimeInfoDao.class
com/amqp/shanxi/model/WkkBasicInfoModel.class
com/amqp/shanxi/model/WkkAlarmTimeInfoModel.class
com/amqp/shanxi/model/KushuiweiDeviceInfoModel.class
com/amqp/shanxi/model/JinrunxianRealTimeInfoModel.class
com/amqp/shanxi/service/impl/SensorDataServiceImpl.class
com/amqp/shanxi/model/JiangyuliangAlarmInfoModel.class
com/amqp/shanxi/service/DeviceStaticDataInfoService.class
com/amqp/shanxi/dao/AlarmInfoDao.class
com/amqp/shanxi/service/ThreadService.class
com/amqp/shanxi/model/DBDeviceInfo.class
com/amqp/shanxi/model/BiaomianweiyiDeviceInfoModel.class
com/amqp/shanxi/model/KushuiweiAlarmInfoModel.class
com/amqp/shanxi/service/SensorDataService.class
com/amqp/shanxi/model/NeibuweiyiAlarmInfoModel.class
com/amqp/shanxi/service/AlarmDataAMQPService.class
com/amqp/shanxi/model/DeviceOffLineInfoModel.class
com/amqp/shanxi/dao/DeviceStaticDataInfoDao.class
com/amqp/shanxi/model/JinrunxianAlarmInfoModel.class
com/amqp/shanxi/util/StaticParamUtils.class
com/amqp/shanxi/model/JiangyuliangDeviceInfoModel.class
com/amqp/shanxi/model/JiangyuliangRealTimeInfoModel.class
com/amqp/shanxi/service/AlarmDataService.class
com/amqp/shanxi/service/impl/DeviceStaticDataInfoServiceImpl.class
com/amqp/shanxi/service/RealTimeDataAMQPService.class
com/amqp/shanxi/model/WkkRealTimeInfoModel.class
com/amqp/shanxi/model/GantanDeviceInfoModel.class
com/amqp/shanxi/dao/SensorDataDao.class
com/amqp/shanxi/model/JinrunxianDeviceInfoModel.class
com/amqp/shanxi/ShanxiApplication.class
com/amqp/shanxi/util/Sender$ExchangeTopic$1.class
com/amqp/shanxi/model/GantanAlarmInfoModel.class
com/amqp/shanxi/model/StaticDataInfoModel.class
com/amqp/shanxi/service/impl/AlarmDataServiceImpl.class
com/amqp/shanxi/model/NeibuweiyiRealTimeInfoModel.class
com/amqp/shanxi/model/DeviceRealTimeInfoModel.class
target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst 0 → 100644
View file @ 43c07fd4
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/model/GantanAlarmInfoModel.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/service/ThreadService.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/model/WkkAlarmTimeInfoModel.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/service/DeviceStaticDataInfoService.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/dao/DeviceStaticDataInfoDao.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/model/NeibuweiyiAlarmInfoModel.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/model/DeviceAlarmInfoModel.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/service/RealTimeDataAMQPService.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/model/DBDeviceInfo.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/model/NeibuweiyiDeviceInfoModel.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/util/Constants.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/model/JiangyuliangAlarmInfoModel.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/service/impl/RealTimeInfoServiceImpl.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/dao/AlarmInfoDao.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/service/AlarmDataService.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/model/JinrunxianRealTimeInfoModel.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/service/impl/AlarmDataServiceImpl.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/model/GantanDeviceInfoModel.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/dao/SensorDataDao.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/service/DeviceStaticDataAMQPService.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/service/impl/DeviceStaticDataInfoServiceImpl.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/model/GantanRealTimeInfoModel.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/model/WkkBasicInfoModel.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/model/NeibuweiyiRealTimeInfoModel.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/util/AMQPTopicStaticDataConfig.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/dao/RealTimeInfoDao.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/util/Sender.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/model/BiaomianweiyiDeviceInfoModel.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/model/WkkRealTimeInfoModel.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/model/StaticDataInfoModel.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/util/AESUtil.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/model/DeviceOffLineInfoModel.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/model/BiaomianweiyiAlarmInfoModel.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/model/DeviceRealTimeInfoModel.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/model/JinrunxianAlarmInfoModel.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/service/impl/SensorDataServiceImpl.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/model/KushuiweiAlarmInfoModel.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/Sender.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/model/JiangyuliangDeviceInfoModel.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/model/JiangyuliangRealTimeInfoModel.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/service/AlarmDataAMQPService.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/model/BiaomianweiyiRealTimeInfoModel.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/util/StaticParamUtils.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/service/SensorDataService.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/model/JinrunxianDeviceInfoModel.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/model/TabSensorModel.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/model/KushuiweiDeviceInfoModel.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/ShanxiApplication.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/model/KushuiweiRealTimeInfoModel.java
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/main/java/com/amqp/shanxi/service/RealTimeInfoService.java
target/maven-status/maven-compiler-plugin/testCompile/default-testCompile/inputFiles.lst 0 → 100644
View file @ 43c07fd4
/Users/shiyubin/ideaProject/gemho/山西数据推送/datapush_shanxi/src/test/java/com/amqp/shanxi/ShanxiApplicationTests.java
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment