Skip to content

D
DataPush_shanxi
Commit 76371e62 authored by shiyubin's avatar shiyubin
Browse files
Options

配置修改

parent ab2399da
Hide whitespace changes
Inline Side-by-side
Showing with 80 additions and 82 deletions
src/main/java/com/amqp/shanxi/Sender.java
View file @ 76371e62
......@@ -49,11 +49,11 @@ public class Sender {
resultList.add(dbDeviceInfo);
//对数据加密
String result = JSONUtil.toJsonStr(resultList);
String encrypt = AESUtil.encrypt(result, "4qInuXy6CREhRch7toLcBg==" , "rluhvrn9+EHIodq5Tx86Jg==");
String encrypt = AESUtil.encrypt(result, "aq6Q90xDtIANw7+pwTyECg==" , "ATIjly3q6UWeJoGQh5+msQ==");
Map<String, Object> resultMap = new HashMap<String, Object>();
//荷载消息内容
while(true) {
resultMap.put("tailingNo","1409240055");
resultMap.put("tailingNo","1409230002");
resultMap.put("departmentId","" );
resultMap.put("provinceId", "");
resultMap.put("type","0101");
......
src/main/java/com/amqp/shanxi/ShanxiApplication.java
View file @ 76371e62
......@@ -16,16 +16,14 @@ import org.springframework.context.ConfigurableApplicationContext;
public class ShanxiApplication {
/*
转自 接口：
请上传尾矿库监测数据，以下是上传数据所需的配置信息：
繁峙县鑫丰矿业有限责任公司大李老沟尾矿库
尾矿库编号：1409240055
数据上传IP：192.166.1.253
rbmq账号：fsxfdllg
rbmq密码：TErA18
密钥：4qInuXy6CREhRch7toLcBg==
向量：rluhvrn9+EHIodq5Tx86Jg==
请上传尾矿库监测数据，以下是上传数据所需的配置信息：
代县程林铁矿黑介沟尾矿库
尾矿库编号：1409230002
数据上传IP：192.168.1.253
rbmq账号：dxclhjg
rbmq密码：7G1WJp
密钥：aq6Q90xDtIANw7+pwTyECg==
向量：ATIjly3q6UWeJoGQh5+msQ==
*/
public static void main(String[] args) {
ConfigurableApplicationContext run = SpringApplication.run(ShanxiApplication.class, args);
......@@ -34,13 +32,13 @@ public class ShanxiApplication {
AlarmDataAMQPService alarmDataAMQPService = run.getBean(AlarmDataAMQPService.class);
try{
ConnectionFactory factory = new ConnectionFactory();
//rabbitmq监听IP
factory.setHost("192.166.1.253");
//rabbitmq监听默认端口
// rabbitmq监听IP
factory.setHost("192.168.1.253");
// rabbitmq监听默认端口
factory.setPort(5672);
//设置访问的用户
factory.setUsername("fsxfdllg");
factory.setPassword("TErA18");
// 设置访问的用户
factory.setUsername("dxclhjg");
factory.setPassword("7G1WJp");
factory.setVirtualHost("/");
Connection connection = factory.newConnection();
ThreadService threadService1 = new ThreadService("staticData", connection, deviceStaticDataAMQPService, realTimeDataAMQPService, alarmDataAMQPService);
......
src/main/java/com/amqp/shanxi/service/impl/AlarmDataServiceImpl.java
View file @ 76371e62
......@@ -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("9114092469913874XR");
gantanAlarmInfo.setDepartmentId("91140923751519014N");
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), "4qInuXy6CREhRch7toLcBg==", "rluhvrn9+EHIodq5Tx86Jg=="));
gantanAlarmInfo.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(gantanAlarmData), "aq6Q90xDtIANw7+pwTyECg==", "ATIjly3q6UWeJoGQh5+msQ=="));
}
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("9114092469913874XR");
kswAlarmInfo.setDepartmentId("91140923751519014N");
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), "4qInuXy6CREhRch7toLcBg==", "rluhvrn9+EHIodq5Tx86Jg=="));
kswAlarmInfo.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(kushuiweiAlarmData), "aq6Q90xDtIANw7+pwTyECg==", "ATIjly3q6UWeJoGQh5+msQ=="));
}
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("9114092469913874XR");
bmwyAlarmInfo.setDepartmentId("91140923751519014N");
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), "4qInuXy6CREhRch7toLcBg==", "rluhvrn9+EHIodq5Tx86Jg=="));
bmwyAlarmInfo.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(biaomianweiyiAlarmData), "aq6Q90xDtIANw7+pwTyECg==", "ATIjly3q6UWeJoGQh5+msQ=="));
}
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("9114092469913874XR");
jrxAlarmInfo.setDepartmentId("91140923751519014N");
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), "4qInuXy6CREhRch7toLcBg==", "rluhvrn9+EHIodq5Tx86Jg=="));
jrxAlarmInfo.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(jinrunxianAlarmData), "aq6Q90xDtIANw7+pwTyECg==", "ATIjly3q6UWeJoGQh5+msQ=="));
}
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("9114092469913874XR");
jylAlarmInfo.setDepartmentId("91140923751519014N");
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), "4qInuXy6CREhRch7toLcBg==", "rluhvrn9+EHIodq5Tx86Jg=="));
jylAlarmInfo.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(jylAlarmData), "aq6Q90xDtIANw7+pwTyECg==", "ATIjly3q6UWeJoGQh5+msQ=="));
}
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("9114092469913874XR");
deviceAlarmInfo.setDepartmentId("91140923751519014N");
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), "4qInuXy6CREhRch7toLcBg==", "rluhvrn9+EHIodq5Tx86Jg=="));
deviceAlarmInfo.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(deviceAlarmData), "aq6Q90xDtIANw7+pwTyECg==", "ATIjly3q6UWeJoGQh5+msQ=="));
}
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("9114092469913874XR");
wkkAlarmInfo.setDepartmentId("91140923751519014N");
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), "4qInuXy6CREhRch7toLcBg==", "rluhvrn9+EHIodq5Tx86Jg=="));
wkkAlarmInfo.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(wkkAlarmData), "aq6Q90xDtIANw7+pwTyECg==", "ATIjly3q6UWeJoGQh5+msQ=="));
}
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("9114092469913874XR");
nbwyAlarmInfo.setDepartmentId("91140923751519014N");
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), "4qInuXy6CREhRch7toLcBg==", "rluhvrn9+EHIodq5Tx86Jg=="));
nbwyAlarmInfo.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(neibuchenjiangAlarmData), "aq6Q90xDtIANw7+pwTyECg==", "ATIjly3q6UWeJoGQh5+msQ=="));
}
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("9114092469913874XR");
nbwyAlarmInfo.setDepartmentId("91140923751519014N");
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), "4qInuXy6CREhRch7toLcBg==", "rluhvrn9+EHIodq5Tx86Jg=="));
nbwyAlarmInfo.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(neibuchenjiangAlarmData), "aq6Q90xDtIANw7+pwTyECg==", "ATIjly3q6UWeJoGQh5+msQ=="));
}
return JSONUtil.toJsonStr(nbwyAlarmInfo);
}catch (Exception e) {
......
src/main/java/com/amqp/shanxi/service/impl/DeviceStaticDataInfoServiceImpl.java
View file @ 76371e62
......@@ -37,11 +37,11 @@ public class DeviceStaticDataInfoServiceImpl implements DeviceStaticDataInfoServ
}
staticDataInfoModel.setTailingNo(StaticParamUtils.WKKNO);
staticDataInfoModel.setDepartmentId("9114092469913874XR");
staticDataInfoModel.setDepartmentId("91140923751519014N");
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), "4qInuXy6CREhRch7toLcBg==", "rluhvrn9+EHIodq5Tx86Jg=="));
staticDataInfoModel.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(gantanDeviceInfos), "aq6Q90xDtIANw7+pwTyECg==", "ATIjly3q6UWeJoGQh5+msQ=="));
System.out.println("干滩设备信息===========" + JSONUtil.toJsonStr(staticDataInfoModel));
return staticDataInfoModel;
}catch (Exception e){
......@@ -52,8 +52,8 @@ public class DeviceStaticDataInfoServiceImpl implements DeviceStaticDataInfoServ
/**
* 库水位设备信息
* 密钥：4qInuXy6CREhRch7toLcBg==
* * 向量：rluhvrn9+EHIodq5Tx86Jg==
* 密钥：aq6Q90xDtIANw7+pwTyECg==
* * 向量：ATIjly3q6UWeJoGQh5+msQ==
* @return StaticDataInfoModel
*/
@Override
......@@ -71,11 +71,11 @@ public class DeviceStaticDataInfoServiceImpl implements DeviceStaticDataInfoServ
}
staticDataInfoModel.setTailingNo(StaticParamUtils.WKKNO);
staticDataInfoModel.setDepartmentId("9114092469913874XR");
staticDataInfoModel.setDepartmentId("91140923751519014N");
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), "4qInuXy6CREhRch7toLcBg==", "rluhvrn9+EHIodq5Tx86Jg=="));
staticDataInfoModel.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(kushuiweiDeviceInfo), "aq6Q90xDtIANw7+pwTyECg==", "ATIjly3q6UWeJoGQh5+msQ=="));
System.out.println("库水位设备信息===========" + JSONUtil.toJsonStr(staticDataInfoModel));
return staticDataInfoModel;
}catch (Exception e){
......@@ -102,11 +102,11 @@ public class DeviceStaticDataInfoServiceImpl implements DeviceStaticDataInfoServ
}
staticDataInfoModel.setTailingNo(StaticParamUtils.WKKNO);
staticDataInfoModel.setDepartmentId("9114092469913874XR");
staticDataInfoModel.setDepartmentId("91140923751519014N");
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), "4qInuXy6CREhRch7toLcBg==", "rluhvrn9+EHIodq5Tx86Jg=="));
staticDataInfoModel.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(biaomianweiyiDeviceInfo), "aq6Q90xDtIANw7+pwTyECg==", "ATIjly3q6UWeJoGQh5+msQ=="));
System.out.println("表面位移设备信息===========" + JSONUtil.toJsonStr(staticDataInfoModel));
return staticDataInfoModel;
}catch (Exception e) {
......@@ -136,11 +136,11 @@ public class DeviceStaticDataInfoServiceImpl implements DeviceStaticDataInfoServ
// 经度　纬度
}
staticDataInfoModel.setTailingNo(StaticParamUtils.WKKNO);
staticDataInfoModel.setDepartmentId("9114092469913874XR");
staticDataInfoModel.setDepartmentId("91140923751519014N");
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), "4qInuXy6CREhRch7toLcBg==", "rluhvrn9+EHIodq5Tx86Jg=="));
staticDataInfoModel.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(jinrunxianDeviceInfo), "aq6Q90xDtIANw7+pwTyECg==", "ATIjly3q6UWeJoGQh5+msQ=="));
System.out.println("浸润线加密前============" + JSONUtil.toJsonStr(jinrunxianDeviceInfo));
System.out.println("浸润线设备信息===========" + JSONUtil.toJsonStr(staticDataInfoModel));
return staticDataInfoModel;
......@@ -169,11 +169,11 @@ public class DeviceStaticDataInfoServiceImpl implements DeviceStaticDataInfoServ
}
staticDataInfoModel.setTailingNo(StaticParamUtils.WKKNO);
staticDataInfoModel.setDepartmentId("9114092469913874XR");
staticDataInfoModel.setDepartmentId("91140923751519014N");
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), "4qInuXy6CREhRch7toLcBg==", "rluhvrn9+EHIodq5Tx86Jg=="));
staticDataInfoModel.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(jiangyuliangDeviceInfo), "aq6Q90xDtIANw7+pwTyECg==", "ATIjly3q6UWeJoGQh5+msQ=="));
System.out.println("降雨量设备信息===========" + JSONUtil.toJsonStr(staticDataInfoModel));
return staticDataInfoModel;
}catch (Exception e) {
......@@ -199,11 +199,11 @@ public class DeviceStaticDataInfoServiceImpl implements DeviceStaticDataInfoServ
}
staticDataInfoModel.setTailingNo(StaticParamUtils.WKKNO);
staticDataInfoModel.setDepartmentId("9114092469913874XR");
staticDataInfoModel.setDepartmentId("91140923751519014N");
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), "4qInuXy6CREhRch7toLcBg==", "rluhvrn9+EHIodq5Tx86Jg=="));
staticDataInfoModel.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(neibuweiyiDeviceInfo), "aq6Q90xDtIANw7+pwTyECg==", "ATIjly3q6UWeJoGQh5+msQ=="));
System.out.println("内部位移设备信息===========" + JSONUtil.toJsonStr(staticDataInfoModel));
return staticDataInfoModel;
}catch (Exception e) {
......@@ -218,11 +218,11 @@ public class DeviceStaticDataInfoServiceImpl implements DeviceStaticDataInfoServ
StaticDataInfoModel staticDataInfoModel = new StaticDataInfoModel();
List<WkkBasicInfoModel> wkkBasicInfo = deviceStaticDataInfoDao.findWkkBasicInfo();
staticDataInfoModel.setTailingNo(StaticParamUtils.WKKNO);
staticDataInfoModel.setDepartmentId("9114092469913874XR");
staticDataInfoModel.setDepartmentId("91140923751519014N");
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), "4qInuXy6CREhRch7toLcBg==", "rluhvrn9+EHIodq5Tx86Jg=="));
staticDataInfoModel.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(wkkBasicInfo), "aq6Q90xDtIANw7+pwTyECg==", "ATIjly3q6UWeJoGQh5+msQ=="));
System.out.println("尾矿库基础信息============" + JSONUtil.toJsonStr(staticDataInfoModel));
return staticDataInfoModel;
}catch (Exception e){
......
src/main/java/com/amqp/shanxi/service/impl/RealTimeInfoServiceImpl.java
View file @ 76371e62
......@@ -40,11 +40,11 @@ public class RealTimeInfoServiceImpl implements RealTimeInfoService {
if (gantanRealTimeInfoModelList.size() > 0) {
gantanRealTime.setTailingNo(StaticParamUtils.WKKNO);
gantanRealTime.setDepartmentId("9114092469913874XR");
gantanRealTime.setDepartmentId("91140923751519014N");
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), "4qInuXy6CREhRch7toLcBg==", "rluhvrn9+EHIodq5Tx86Jg=="));
gantanRealTime.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(gantanRealTimeInfoModelList), "aq6Q90xDtIANw7+pwTyECg==", "ATIjly3q6UWeJoGQh5+msQ=="));
}
return JSONUtil.toJsonStr(gantanRealTime);
}catch(Exception e) {
......@@ -69,11 +69,11 @@ public class RealTimeInfoServiceImpl implements RealTimeInfoService {
if (kushuiweiRealTimeData.size() > 0) {
kswRealTimeData.setTailingNo(StaticParamUtils.WKKNO);
kswRealTimeData.setDepartmentId("9114092469913874XR");
kswRealTimeData.setDepartmentId("91140923751519014N");
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), "4qInuXy6CREhRch7toLcBg==", "rluhvrn9+EHIodq5Tx86Jg=="));
kswRealTimeData.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(kushuiweiRealTimeData), "aq6Q90xDtIANw7+pwTyECg==", "ATIjly3q6UWeJoGQh5+msQ=="));
}
return JSONUtil.toJsonStr(kswRealTimeData);
}catch(Exception e) {
......@@ -98,11 +98,11 @@ public class RealTimeInfoServiceImpl implements RealTimeInfoService {
System.out.println("bmwy实时数据=======================" + JSONUtil.toJsonStr(biaomianweiyiRealTimeData));
if (biaomianweiyiRealTimeData.size() > 0) {
bmwyRealTimeData.setTailingNo(StaticParamUtils.WKKNO);
bmwyRealTimeData.setDepartmentId("9114092469913874XR");
bmwyRealTimeData.setDepartmentId("91140923751519014N");
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), "4qInuXy6CREhRch7toLcBg==", "rluhvrn9+EHIodq5Tx86Jg=="));
bmwyRealTimeData.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(biaomianweiyiRealTimeData), "aq6Q90xDtIANw7+pwTyECg==", "ATIjly3q6UWeJoGQh5+msQ=="));
}
return JSONUtil.toJsonStr(bmwyRealTimeData);
}catch (Exception e) {
......@@ -126,11 +126,11 @@ public class RealTimeInfoServiceImpl implements RealTimeInfoService {
System.out.println("jrx实时数据=======================" + JSONUtil.toJsonStr(jinrunxianRealTimeData));
if (jinrunxianRealTimeData.size() > 0) {
jrxRealTimeData.setTailingNo(StaticParamUtils.WKKNO);
jrxRealTimeData.setDepartmentId("9114092469913874XR");
jrxRealTimeData.setDepartmentId("91140923751519014N");
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), "4qInuXy6CREhRch7toLcBg==", "rluhvrn9+EHIodq5Tx86Jg=="));
jrxRealTimeData.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(jinrunxianRealTimeData), "aq6Q90xDtIANw7+pwTyECg==", "ATIjly3q6UWeJoGQh5+msQ=="));
}
return JSONUtil.toJsonStr(jrxRealTimeData);
}catch(Exception e) {
......@@ -154,11 +154,11 @@ public class RealTimeInfoServiceImpl implements RealTimeInfoService {
System.out.println("jyl实时数据=======================" + JSONUtil.toJsonStr(jiangyuliangRealTimeData));
if (jiangyuliangRealTimeData.size() > 0) {
jylRealTimeData.setTailingNo(StaticParamUtils.WKKNO);
jylRealTimeData.setDepartmentId("9114092469913874XR");
jylRealTimeData.setDepartmentId("91140923751519014N");
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), "4qInuXy6CREhRch7toLcBg==", "rluhvrn9+EHIodq5Tx86Jg=="));
jylRealTimeData.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(jiangyuliangRealTimeData), "aq6Q90xDtIANw7+pwTyECg==", "ATIjly3q6UWeJoGQh5+msQ=="));
}
return JSONUtil.toJsonStr(jylRealTimeData);
}catch (Exception e){
......@@ -182,11 +182,11 @@ public class RealTimeInfoServiceImpl implements RealTimeInfoService {
System.out.println("nbcj内部沉降实时数据=======================" + JSONUtil.toJsonStr(neibuChenjiangRealTimeData));
if (neibuChenjiangRealTimeData.size() > 0) {
nbcjRealTimeData.setTailingNo(StaticParamUtils.WKKNO);
nbcjRealTimeData.setDepartmentId("9114092469913874XR");
nbcjRealTimeData.setDepartmentId("91140923751519014N");
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), "4qInuXy6CREhRch7toLcBg==", "rluhvrn9+EHIodq5Tx86Jg=="));
nbcjRealTimeData.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(neibuChenjiangRealTimeData), "aq6Q90xDtIANw7+pwTyECg==", "ATIjly3q6UWeJoGQh5+msQ=="));
}
return JSONUtil.toJsonStr(nbcjRealTimeData);
}catch (Exception e) {
......@@ -211,11 +211,11 @@ public class RealTimeInfoServiceImpl implements RealTimeInfoService {
System.out.println("nbsp内部水平实时数据=======================" + JSONUtil.toJsonStr(neibuShuipingRealTimeData));
if (neibuShuipingRealTimeData.size() > 0) {
nbspRealTimeData.setTailingNo(StaticParamUtils.WKKNO);
nbspRealTimeData.setDepartmentId("9114092469913874XR");
nbspRealTimeData.setDepartmentId("91140923751519014N");
nbspRealTimeData.setProvinceId(StaticParamUtils.PROVINCENO);
nbspRealTimeData.setType(StaticParamUtils.NEIBUWEIYIDATA);
nbspRealTimeData.setSendTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
nbspRealTimeData.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(neibuShuipingRealTimeData), "4qInuXy6CREhRch7toLcBg==", "rluhvrn9+EHIodq5Tx86Jg=="));
nbspRealTimeData.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(neibuShuipingRealTimeData), "aq6Q90xDtIANw7+pwTyECg==", "ATIjly3q6UWeJoGQh5+msQ=="));
}
return JSONUtil.toJsonStr(nbspRealTimeData);
}catch (Exception e) {
......@@ -258,11 +258,11 @@ public class RealTimeInfoServiceImpl implements RealTimeInfoService {
System.out.println("device实时数据=======================" + JSONUtil.toJsonStr(deviceRealTimeData));
if (deviceRealTimeData.size() > 0) {
deviceRealTimeDataModel.setTailingNo(StaticParamUtils.WKKNO);
deviceRealTimeDataModel.setDepartmentId("9114092469913874XR");
deviceRealTimeDataModel.setDepartmentId("91140923751519014N");
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), "4qInuXy6CREhRch7toLcBg==", "rluhvrn9+EHIodq5Tx86Jg=="));
deviceRealTimeDataModel.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(deviceRealTimeData), "aq6Q90xDtIANw7+pwTyECg==", "ATIjly3q6UWeJoGQh5+msQ=="));
}
return JSONUtil.toJsonStr(deviceRealTimeDataModel);
}catch (Exception e) {
......@@ -280,11 +280,11 @@ public class RealTimeInfoServiceImpl implements RealTimeInfoService {
wkkRealTimeData.get(0).setState("1");
wkkRealTimeData.get(0).setCollectdate(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
wkkRealTimeDataModel.setTailingNo(StaticParamUtils.WKKNO);
wkkRealTimeDataModel.setDepartmentId("9114092469913874XR");
wkkRealTimeDataModel.setDepartmentId("91140923751519014N");
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), "4qInuXy6CREhRch7toLcBg==", "rluhvrn9+EHIodq5Tx86Jg=="));
wkkRealTimeDataModel.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(wkkRealTimeData), "aq6Q90xDtIANw7+pwTyECg==", "ATIjly3q6UWeJoGQh5+msQ=="));
System.out.println("wkk实时数据=======================" + JSONUtil.toJsonStr(wkkRealTimeData));
return JSONUtil.toJsonStr(wkkRealTimeDataModel);
} else {
......@@ -294,11 +294,11 @@ public class RealTimeInfoServiceImpl implements RealTimeInfoService {
wkkRealTimeData.add(wkkRealTimeInfoModel);
wkkRealTimeDataModel.setTailingNo(StaticParamUtils.WKKNO);
wkkRealTimeDataModel.setDepartmentId("9114092469913874XR");
wkkRealTimeDataModel.setDepartmentId("91140923751519014N");
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), "4qInuXy6CREhRch7toLcBg==", "rluhvrn9+EHIodq5Tx86Jg=="));
wkkRealTimeDataModel.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(wkkRealTimeData), "aq6Q90xDtIANw7+pwTyECg==", "ATIjly3q6UWeJoGQh5+msQ=="));
System.out.println("wkk实时数据=======================" + JSONUtil.toJsonStr(wkkRealTimeData));
return JSONUtil.toJsonStr(wkkRealTimeDataModel);
}
......@@ -339,11 +339,11 @@ public class RealTimeInfoServiceImpl implements RealTimeInfoService {
}
}
deviceOffLineDataModel.setTailingNo(StaticParamUtils.WKKNO);
deviceOffLineDataModel.setDepartmentId("9114092469913874XR");
deviceOffLineDataModel.setDepartmentId("91140923751519014N");
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), "4qInuXy6CREhRch7toLcBg==", "rluhvrn9+EHIodq5Tx86Jg=="));
deviceOffLineDataModel.setDatas(AESUtil.encrypt(JSONUtil.toJsonStr(deviceOffLineData), "aq6Q90xDtIANw7+pwTyECg==", "ATIjly3q6UWeJoGQh5+msQ=="));
}
System.out.println("离线设备信息数据长度 :" + JSONUtil.toJsonStr(deviceOffLineData));
......
src/main/resources/application.yml
View file @ 76371e62
......@@ -9,17 +9,17 @@ spring:
password: red___
device: # 设备编码 -parameters
gantanno: '140924005501'
kushuiweino: '140924005502'
biaomianweiyino: '140924005503'
neibuweiyino: '140924005504'
jinrunxianno: '140924005505'
jiangyuliangno: '140924005506'
shenliuliangno: '140924005507'
gantanno: '140923000201'
kushuiweino: '140923000202'
biaomianweiyino: '140923000203'
neibuweiyino: '140923000204'
jinrunxianno: '140923000205'
jiangyuliangno: '140923000206'
shenliuliangno: '140923000207'
basic: # 基础信息
provinceno: '14'
wkkno: '1409240055'
wkkno: '1409230002'
datatype:
basicinfo: '0001'
......
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