Commit fac36522 authored by maoying's avatar maoying

删除mongo相关代码及配置文件

parent 6943a580
package com.yeejoin.amos.fas.business.dao.mongo; //package com.yeejoin.amos.fas.business.dao.mongo;
import org.springframework.data.mongodb.repository.MongoRepository; //import org.springframework.data.mongodb.repository.MongoRepository;
import org.springframework.stereotype.Repository; //import org.springframework.stereotype.Repository;
//
import com.yeejoin.amos.fas.business.vo.EquipCommunicationData; //import com.yeejoin.amos.fas.business.vo.EquipCommunicationData;
//
@Repository("equipCommunicationDao") //@Repository("equipCommunicationDao")
public interface EquipCommunicationDao extends MongoRepository<EquipCommunicationData, String>{ //public interface EquipCommunicationDao extends MongoRepository<EquipCommunicationData, String>{
//
} //}
...@@ -25,9 +25,6 @@ import org.springframework.data.domain.PageImpl; ...@@ -25,9 +25,6 @@ import org.springframework.data.domain.PageImpl;
import org.springframework.data.domain.Sort; import org.springframework.data.domain.Sort;
import org.springframework.data.domain.Sort.Direction; import org.springframework.data.domain.Sort.Direction;
import org.springframework.data.domain.Sort.Order; import org.springframework.data.domain.Sort.Order;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
...@@ -41,7 +38,6 @@ import com.yeejoin.amos.fas.business.constants.FasConstant; ...@@ -41,7 +38,6 @@ import com.yeejoin.amos.fas.business.constants.FasConstant;
import com.yeejoin.amos.fas.business.dao.mapper.FireEquipMapper; import com.yeejoin.amos.fas.business.dao.mapper.FireEquipMapper;
import com.yeejoin.amos.fas.business.dao.mapper.ImpAndFireEquipMapper; import com.yeejoin.amos.fas.business.dao.mapper.ImpAndFireEquipMapper;
import com.yeejoin.amos.fas.business.dao.mapper.ImpEquipMapper; import com.yeejoin.amos.fas.business.dao.mapper.ImpEquipMapper;
import com.yeejoin.amos.fas.business.dao.mongo.EquipCommunicationDao;
import com.yeejoin.amos.fas.business.dao.repository.IEquipmentDao; import com.yeejoin.amos.fas.business.dao.repository.IEquipmentDao;
import com.yeejoin.amos.fas.business.dao.repository.IEquipmentFireEquipmentDao; import com.yeejoin.amos.fas.business.dao.repository.IEquipmentFireEquipmentDao;
import com.yeejoin.amos.fas.business.dao.repository.IFireEquipmentDao; import com.yeejoin.amos.fas.business.dao.repository.IFireEquipmentDao;
...@@ -101,11 +97,8 @@ public class EquipmentServiceImpl implements IEquipmentService { ...@@ -101,11 +97,8 @@ public class EquipmentServiceImpl implements IEquipmentService {
@Autowired @Autowired
private IFmeaEquipmentPointDao iFmeaEquipmentPointDao; private IFmeaEquipmentPointDao iFmeaEquipmentPointDao;
@Autowired // @Autowired
private MongoTemplate mongoTemplate; // private MongoTemplate mongoTemplate;
@Autowired
private EquipCommunicationDao equipCommunicationDao;
@Value("${windows.img.path}") @Value("${windows.img.path}")
private String winImgPath; private String winImgPath;
...@@ -469,25 +462,22 @@ public class EquipmentServiceImpl implements IEquipmentService { ...@@ -469,25 +462,22 @@ public class EquipmentServiceImpl implements IEquipmentService {
@Override @Override
public EquipCommunicationData findFireEquipmentByPointCode(String code) { public EquipCommunicationData findFireEquipmentByPointCode(String code) {
// EquipCommunicationData data = (EquipCommunicationData) redisTemplate.opsForHash().get("fireEquipData", code);
// if (ObjectUtils.isEmpty(data)) {
EquipCommunicationData data = fireEquipMapper.findOneByPointCode(code); EquipCommunicationData data = fireEquipMapper.findOneByPointCode(code);
// }
return data; return data;
} }
@Override @Override
public EquipCommunicationData findFireEquipDataByPointCode(String code) { public EquipCommunicationData findFireEquipDataByPointCode(String code) {
Query query = new Query(); // Query query = new Query();
query.addCriteria(Criteria.where("pointCode").is(code)).limit(1); // query.addCriteria(Criteria.where("pointCode").is(code)).limit(1);
query.with(new Sort(new Order(Direction.DESC, "recDate"))); // query.with(new Sort(new Order(Direction.DESC, "recDate")));
query.limit(1); // query.limit(1);
List<EquipCommunicationData> data = mongoTemplate.find(query, EquipCommunicationData.class); // List<EquipCommunicationData> data = mongoTemplate.find(query, EquipCommunicationData.class);
if (data.isEmpty()) { // if (data.isEmpty()) {
// return null;
// }
return null; return null;
} }
return data.get(0);
}
@Override @Override
......
...@@ -70,7 +70,6 @@ import com.yeejoin.amos.fas.business.dao.mapper.FmeaMapper; ...@@ -70,7 +70,6 @@ import com.yeejoin.amos.fas.business.dao.mapper.FmeaMapper;
import com.yeejoin.amos.fas.business.dao.mapper.FmeaPointInputitemMapper; import com.yeejoin.amos.fas.business.dao.mapper.FmeaPointInputitemMapper;
import com.yeejoin.amos.fas.business.dao.mapper.ImpAndFireEquipMapper; import com.yeejoin.amos.fas.business.dao.mapper.ImpAndFireEquipMapper;
import com.yeejoin.amos.fas.business.dao.mapper.RiskSourceMapper; import com.yeejoin.amos.fas.business.dao.mapper.RiskSourceMapper;
import com.yeejoin.amos.fas.business.dao.mongo.EquipCommunicationDao;
import com.yeejoin.amos.fas.business.dao.repository.IAlarmDao; import com.yeejoin.amos.fas.business.dao.repository.IAlarmDao;
import com.yeejoin.amos.fas.business.dao.repository.IContingencyOriginalDataDao; import com.yeejoin.amos.fas.business.dao.repository.IContingencyOriginalDataDao;
import com.yeejoin.amos.fas.business.dao.repository.IDictDao; import com.yeejoin.amos.fas.business.dao.repository.IDictDao;
...@@ -214,9 +213,6 @@ public class RiskSourceServiceImpl implements IRiskSourceService { ...@@ -214,9 +213,6 @@ public class RiskSourceServiceImpl implements IRiskSourceService {
private RemoteWebSocketServer remoteWebSocketServer; private RemoteWebSocketServer remoteWebSocketServer;
@Autowired @Autowired
private EquipCommunicationDao equipCommunicationDao;
@Autowired
private IEquipmentService equipmentService; private IEquipmentService equipmentService;
@Autowired @Autowired
...@@ -1269,7 +1265,7 @@ public class RiskSourceServiceImpl implements IRiskSourceService { ...@@ -1269,7 +1265,7 @@ public class RiskSourceServiceImpl implements IRiskSourceService {
return data; return data;
}).filter(param -> !ObjectUtils.isEmpty(param)).collect(Collectors.toList()); }).filter(param -> !ObjectUtils.isEmpty(param)).collect(Collectors.toList());
equipCommunicationDao.saveAll(list); // equipCommunicationDao.saveAll(list);
} }
/** /**
......
...@@ -100,7 +100,6 @@ public interface IEquipmentService { ...@@ -100,7 +100,6 @@ public interface IEquipmentService {
EquipCommunicationData findFireEquipmentByPointCode(String code); EquipCommunicationData findFireEquipmentByPointCode(String code);
EquipCommunicationData findFireEquipDataByPointCode(String code); EquipCommunicationData findFireEquipDataByPointCode(String code);
int countImpEquipByIds(String[] idArray); int countImpEquipByIds(String[] idArray);
int countFemaRelation(String[] idArray); int countFemaRelation(String[] idArray);
......
...@@ -4,10 +4,8 @@ import java.io.Serializable; ...@@ -4,10 +4,8 @@ import java.io.Serializable;
import java.util.Date; import java.util.Date;
import org.springframework.data.annotation.Id; import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.index.Indexed;
import org.springframework.data.mongodb.core.mapping.Document;
@Document(collection = "EquipCommunicationData") //@Document(collection = "EquipCommunicationData")
public class EquipCommunicationData implements Serializable{ public class EquipCommunicationData implements Serializable{
/** /**
* *
...@@ -16,13 +14,13 @@ public class EquipCommunicationData implements Serializable{ ...@@ -16,13 +14,13 @@ public class EquipCommunicationData implements Serializable{
@Id @Id
private String id; private String id;
private String informationAddress; //转发码 private String informationAddress; //转发码
@Indexed // @Indexed
private int soe; private int soe;
private String state; // 值 private String state; // 值
private String unit; private String unit;
private String serviceId; //服务ID private String serviceId; //服务ID
private int isInvalid; // 是否有效 private int isInvalid; // 是否有效
@Indexed // @Indexed
private String pointCode; private String pointCode;
private String pointName; private String pointName;
// @Indexed // @Indexed
...@@ -32,13 +30,13 @@ public class EquipCommunicationData implements Serializable{ ...@@ -32,13 +30,13 @@ public class EquipCommunicationData implements Serializable{
private String type; private String type;
private String alarmType; private String alarmType;
@Indexed // @Indexed
private String fireEquipmentId; private String fireEquipmentId;
private String fireEquipmentName; private String fireEquipmentName;
private String fireEquipmentCode; private String fireEquipmentCode;
@Indexed // @Indexed
private Date recDate; private Date recDate;
public String getInformationAddress() { public String getInformationAddress() {
......
...@@ -21,10 +21,6 @@ spring.datasource.hikari.maximum-pool-size = 10 ...@@ -21,10 +21,6 @@ spring.datasource.hikari.maximum-pool-size = 10
spring.datasource.testWhileIdle = true spring.datasource.testWhileIdle = true
spring.datasource.validationQuery = SELECT 1 spring.datasource.validationQuery = SELECT 1
#mongodb
spring.data.mongodb.uri = mongodb://172.16.11.33:27017/iecmonitor
#rule #rule
#params.remoteRuleUrl=http://172.16.3.3:8080/ #params.remoteRuleUrl=http://172.16.3.3:8080/
params.remoteRuleUrl=http://magintursh.xicp.net:18080/ params.remoteRuleUrl=http://magintursh.xicp.net:18080/
......
security.password=tw123456 security.password=a1234560
security.loginId=tw3 security.loginId=fas_autosys
security.productWeb=CONVERTER_STATION_WEB security.productWeb=STUDIO_APP_WEB
security.appKeyWeb=CONVERTER_STATION security.appKeyWeb=studio_normalapp_2668446
#environment #environment
#spring.profiles.active = dev #spring.profiles.active = dev
...@@ -22,10 +22,6 @@ spring.datasource.hikari.maximum-pool-size = 10 ...@@ -22,10 +22,6 @@ spring.datasource.hikari.maximum-pool-size = 10
spring.datasource.testWhileIdle = true spring.datasource.testWhileIdle = true
spring.datasource.validationQuery = SELECT 1 spring.datasource.validationQuery = SELECT 1
#mongodb
spring.data.mongodb.uri = mongodb://amos-mongo:27017/iecmonitor
#rule #rule
#params.remoteRuleUrl=http://172.16.3.3:8080/ #params.remoteRuleUrl=http://172.16.3.3:8080/
params.remoteRuleUrl=http://station-rule:8080/ params.remoteRuleUrl=http://station-rule:8080/
......
...@@ -22,10 +22,6 @@ spring.datasource.hikari.maximum-pool-size = 10 ...@@ -22,10 +22,6 @@ spring.datasource.hikari.maximum-pool-size = 10
spring.datasource.testWhileIdle = true spring.datasource.testWhileIdle = true
spring.datasource.validationQuery = SELECT 1 spring.datasource.validationQuery = SELECT 1
#mongodb
spring.data.mongodb.uri = mongodb://172.16.11.33:27017/iecmonitor
#rule #rule
#params.remoteRuleUrl=http://172.16.3.3:8080/ #params.remoteRuleUrl=http://172.16.3.3:8080/
params.remoteRuleUrl=http://magintursh.xicp.net:18080/ params.remoteRuleUrl=http://magintursh.xicp.net:18080/
......
...@@ -60,7 +60,6 @@ windows.img.path = E:\\ ...@@ -60,7 +60,6 @@ windows.img.path = E:\\
linux.img.path = / linux.img.path = /
param.safetyIndexChange.cron = 0 0 2 * * ? param.safetyIndexChange.cron = 0 0 2 * * ?
#param.weather.url = http://t.weather.sojson.com/api/weather/city/
param.weather.url = http://wthrcdn.etouch.cn/weather_mini?citykey= param.weather.url = http://wthrcdn.etouch.cn/weather_mini?citykey=
......
...@@ -177,10 +177,6 @@ ...@@ -177,10 +177,6 @@
<dependency> <dependency>
<groupId>org.springframework.boot</groupId> <groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId> <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency> </dependency>
<dependency> <dependency>
......
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