Browse Source

socket 주석처리

feature/auth
노승철 2 years ago
parent
commit
854dc74243
  1. 2
      src/main/java/com/palnet/comn/model/GPModel.java
  2. 8
      src/main/java/com/palnet/server/command/SocketCommand.java
  3. 6
      src/main/java/com/palnet/server/task/ctr/CtrCntrlTask.java
  4. 136
      src/main/java/com/palnet/server/task/ctr/service/CtrCntrlTaskService.java

2
src/main/java/com/palnet/comn/model/GPModel.java

@ -67,6 +67,6 @@ public class GPModel {
private List<GPHistoryModel> postionHistory;
// 비정상 상황 식별 코드
private boolean controlWarnCd = true; // 정상: true, 비정상: 비정상
private boolean controlWarnCd;
}

8
src/main/java/com/palnet/server/command/SocketCommand.java

@ -61,8 +61,8 @@ public class SocketCommand {
dataList.add(model);
}
collection.putData(dataList);
logger.debug("SIZE :: " +collection.getData().size() );
// collection.putData(dataList);
// logger.debug("SIZE :: " +collection.getData().size() );
}
@ -134,8 +134,8 @@ public class SocketCommand {
}
}
collection.putData(dataList);
logger.debug("SIZE :: " +collection.getData().size() );
// collection.putData(dataList);
// logger.debug("SIZE :: " +collection.getData().size() );
}

6
src/main/java/com/palnet/server/task/ctr/CtrCntrlTask.java

@ -25,9 +25,9 @@ public class CtrCntrlTask implements Runnable{
try {
// logger.info("=========== [Channel Size : " + cc.getAllChannels().size() + "]");
cc.getAllChannels().stream().forEach(c -> { // 접속되어 있는 모든 사용자에게 전달 처리
c.writeAndFlush(new TextWebSocketFrame(JsonUtils.toJson(service.getList())));
});
// cc.getAllChannels().stream().forEach(c -> { // 접속되어 있는 모든 사용자에게 전달 처리
// c.writeAndFlush(new TextWebSocketFrame(JsonUtils.toJson(service.getList())));
// });
}catch(Exception e) {
e.printStackTrace();
}

136
src/main/java/com/palnet/server/task/ctr/service/CtrCntrlTaskService.java

@ -39,75 +39,75 @@ public class CtrCntrlTaskService {
*/
public ArrayList<CtrCntrlModel> getList(){
Map<String , GPModel> cicData = cic.getData();
ArrayList<CtrCntrlModel> list = new ArrayList<CtrCntrlModel>();
CtrCntrlModel model;
GPModel dataInfo;
for(Entry<String, GPModel> data : cicData.entrySet()) {
// List<Map<String , Double>> historyList = new ArrayList<Map<String , Double>>();
model = new CtrCntrlModel();
// dataInfo = new GroundPositionInfoModel();
dataInfo = data.getValue();
model.setObjectId(dataInfo.getObjectId());
model.setControlId(dataInfo.getControlId());
model.setControlStartDt(dataInfo.getControlStartDt());
model.setObjectTypeCd(dataInfo.getObjectType());
model.setLat(dataInfo.getLat());
model.setLng(dataInfo.getLng());
model.setElevType(dataInfo.getElevType());
model.setElev(dataInfo.getElev());
model.setSpeedType(dataInfo.getSpeedType());
model.setSpeed(dataInfo.getSpeed());
model.setBetteryLevel(dataInfo.getBetteryLevel());
model.setBetteryVoltage(dataInfo.getBetteryVoltage());
model.setDronStatus(dataInfo.getDronStatus());
model.setHeading(dataInfo.getHeading());
model.setMoveDistance(dataInfo.getMoveDistance());
model.setMoveDistanceType(dataInfo.getMoveDistanceType());
model.setServerRcvDt(dataInfo.getServerRcvDt());
// 환경 데이터 필드 추가
model.setSensorCo(dataInfo.getSensorCo());
model.setSensorSo2(dataInfo.getSensorSo2());
model.setSensorNo2(dataInfo.getSensorNo2());
model.setSensorO3(dataInfo.getSensorO3());
model.setSensorDust(dataInfo.getSensorDust());
//마지막 5개 좌표를 넣기
// if(dataInfo.getPostionHistory() != null) {
// int listSize = dataInfo.getPostionHistory().size();
// int limitSize = 10;
//
// if(limitSize >= listSize) {
// limitSize = listSize;
// }
// List<GroundPositionHistoryModel> tempHistoryList = new ArrayList<GroundPositionHistoryModel>();
//
// tempHistoryList = dataInfo.getPostionHistory().subList(listSize - limitSize , listSize);
//
//
// //뒤집기
// Collections.reverse(tempHistoryList);
//
// for(GroundPositionHistoryModel historyData : tempHistoryList) {
// Map<String, Double> addDate = new HashMap<String,Double>();
// addDate.put("lat", historyData.getLat());
// addDate.put("lng", historyData.getLng());
//
// historyList.add(addDate);
// }
// }
// model.setLastHistory(historyList);
list.add(model);
}
//=== 정렬 처리 ==
//기준 : 관제 시작일이 가장 느린순으로 상단에 올린다.
list.sort(Comparator.reverseOrder());
// Map<String , GPModel> cicData = cic.getData();
//
// CtrCntrlModel model;
// GPModel dataInfo;
//
// for(Entry<String, GPModel> data : cicData.entrySet()) {
//// List<Map<String , Double>> historyList = new ArrayList<Map<String , Double>>();
// model = new CtrCntrlModel();
//// dataInfo = new GroundPositionInfoModel();
// dataInfo = data.getValue();
//
// model.setObjectId(dataInfo.getObjectId());
// model.setControlId(dataInfo.getControlId());
// model.setControlStartDt(dataInfo.getControlStartDt());
// model.setObjectTypeCd(dataInfo.getObjectType());
// model.setLat(dataInfo.getLat());
// model.setLng(dataInfo.getLng());
// model.setElevType(dataInfo.getElevType());
// model.setElev(dataInfo.getElev());
// model.setSpeedType(dataInfo.getSpeedType());
// model.setSpeed(dataInfo.getSpeed());
// model.setBetteryLevel(dataInfo.getBetteryLevel());
// model.setBetteryVoltage(dataInfo.getBetteryVoltage());
// model.setDronStatus(dataInfo.getDronStatus());
// model.setHeading(dataInfo.getHeading());
// model.setMoveDistance(dataInfo.getMoveDistance());
// model.setMoveDistanceType(dataInfo.getMoveDistanceType());
//
// model.setServerRcvDt(dataInfo.getServerRcvDt());
//
// // 환경 데이터 필드 추가
// model.setSensorCo(dataInfo.getSensorCo());
// model.setSensorSo2(dataInfo.getSensorSo2());
// model.setSensorNo2(dataInfo.getSensorNo2());
// model.setSensorO3(dataInfo.getSensorO3());
// model.setSensorDust(dataInfo.getSensorDust());
//
// //마지막 5개 좌표를 넣기
//// if(dataInfo.getPostionHistory() != null) {
//// int listSize = dataInfo.getPostionHistory().size();
//// int limitSize = 10;
////
//// if(limitSize >= listSize) {
//// limitSize = listSize;
//// }
//// List<GroundPositionHistoryModel> tempHistoryList = new ArrayList<GroundPositionHistoryModel>();
////
//// tempHistoryList = dataInfo.getPostionHistory().subList(listSize - limitSize , listSize);
////
////
//// //뒤집기
//// Collections.reverse(tempHistoryList);
////
//// for(GroundPositionHistoryModel historyData : tempHistoryList) {
//// Map<String, Double> addDate = new HashMap<String,Double>();
//// addDate.put("lat", historyData.getLat());
//// addDate.put("lng", historyData.getLng());
////
//// historyList.add(addDate);
//// }
//// }
//// model.setLastHistory(historyList);
// list.add(model);
// }
//
// //=== 정렬 처리 ==
// //기준 : 관제 시작일이 가장 느린순으로 상단에 올린다.
// list.sort(Comparator.reverseOrder());
return list;
}

Loading…
Cancel
Save