Compare commits

...

12 Commits

  1. 19
      pom.xml
  2. 2
      src/main/java/com/palnet/biz/api/anls/smlt/service/AnlsSmltService.java
  3. 29
      src/main/java/com/palnet/biz/api/bas/flight/controller/BasFlightController.java
  4. 15
      src/main/java/com/palnet/biz/api/bas/flight/model/BasFlightCoordModel.java
  5. 59
      src/main/java/com/palnet/biz/api/bas/flight/service/BasFlightService.java
  6. 58
      src/main/java/com/palnet/biz/api/comn/controller/ComnController.java
  7. 12
      src/main/java/com/palnet/biz/api/ctr/cntrl/service/CtrCntrlService.java
  8. 3
      src/main/java/com/palnet/biz/config/WebSecurityConfig.java
  9. 71
      src/main/java/com/palnet/comn/utils/KmlUtils.java
  10. 142
      src/main/java/com/palnet/comn/utils/SftpUtils.java
  11. 12
      src/main/resources/application.properties
  12. 2
      src/main/resources/application.yml

19
pom.xml

@ -192,7 +192,24 @@
<groupId>org.springframework.boot</groupId> <groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-cache</artifactId> <artifactId>spring-boot-starter-cache</artifactId>
</dependency> </dependency>
<!-- https://mvnrepository.com/artifact/javax.xml.bind/jaxb-api -->
<dependency>
<groupId>javax.xml.bind</groupId>
<artifactId>jaxb-api</artifactId>
<version>2.3.1</version>
</dependency>
<!-- https://mvnrepository.com/artifact/com.jcraft/jsch -->
<dependency>
<groupId>com.jcraft</groupId>
<artifactId>jsch</artifactId>
<version>0.1.55</version>
</dependency>
<!-- https://mvnrepository.com/artifact/de.micromata.jak/JavaAPIforKml -->
<dependency>
<groupId>de.micromata.jak</groupId>
<artifactId>JavaAPIforKml</artifactId>
<version>2.2.0</version>
</dependency>
</dependencies> </dependencies>
<build> <build>

2
src/main/java/com/palnet/biz/api/anls/smlt/service/AnlsSmltService.java

@ -71,7 +71,7 @@ public class AnlsSmltService {
List<JwtGroupModel> adminAuth = new ArrayList<>(); List<JwtGroupModel> adminAuth = new ArrayList<>();
Integer cstmrSno = jwtTokenUtil.getCstmrSnoByToken(); Integer cstmrSno = jwtTokenUtil.getCstmrSnoByToken();
ComnPagingRs<AnlsHstryModel> response = new ComnPagingRs<>(); ComnPagingRs<AnlsHstryModel> response = new ComnPagingRs<>();
Pageable pageable = PageRequest.of(rq.getPage()-1, rq.getRecord()); Pageable pageable = PageRequest.of(rq.getPage()-1, 5);
PageImpl<AnlsHstryModel> result; PageImpl<AnlsHstryModel> result;
List<AnlsHstryModel>resultList = new ArrayList<>(); List<AnlsHstryModel>resultList = new ArrayList<>();

29
src/main/java/com/palnet/biz/api/bas/flight/controller/BasFlightController.java

@ -6,7 +6,6 @@ import java.io.InputStream;
import java.io.InputStreamReader; import java.io.InputStreamReader;
import java.io.UnsupportedEncodingException; import java.io.UnsupportedEncodingException;
import java.net.URLEncoder; import java.net.URLEncoder;
import java.util.ArrayList;
import java.util.HashMap; import java.util.HashMap;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
@ -15,8 +14,6 @@ import org.json.simple.JSONObject;
import org.json.simple.parser.JSONParser; import org.json.simple.parser.JSONParser;
import org.json.simple.parser.ParseException; import org.json.simple.parser.ParseException;
import org.locationtech.jts.geom.Coordinate; import org.locationtech.jts.geom.Coordinate;
import org.locationtech.proj4j.CRSFactory;
import org.locationtech.proj4j.CoordinateReferenceSystem;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.env.Environment; import org.springframework.core.env.Environment;
import org.springframework.core.io.ClassPathResource; import org.springframework.core.io.ClassPathResource;
@ -35,6 +32,7 @@ import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController; import org.springframework.web.bind.annotation.RestController;
import com.palnet.biz.api.bas.flight.model.BasFlightAprovRq; import com.palnet.biz.api.bas.flight.model.BasFlightAprovRq;
import com.palnet.biz.api.bas.flight.model.BasFlightCoordModel;
import com.palnet.biz.api.bas.flight.model.BasFlightPlanArcrftModel; import com.palnet.biz.api.bas.flight.model.BasFlightPlanArcrftModel;
import com.palnet.biz.api.bas.flight.model.BasFlightPlanAreaModel; import com.palnet.biz.api.bas.flight.model.BasFlightPlanAreaModel;
import com.palnet.biz.api.bas.flight.model.BasFlightPlanListRq; import com.palnet.biz.api.bas.flight.model.BasFlightPlanListRq;
@ -143,8 +141,8 @@ public class BasFlightController {
Map<String, Object> resultMap = new HashMap<String, Object>(); Map<String, Object> resultMap = new HashMap<String, Object>();
try { try {
log.info(">>> rq : {}", rq); log.info(">>> rq : {}", rq);
boolean result = basFlightService.createPlan(rq); basFlightService.createPlan(rq);
resultMap.put("result", result); resultMap.put("result", true);
log.info(">>> resultMap : " , resultMap); log.info(">>> resultMap : " , resultMap);
} catch (CustomException e) { } catch (CustomException e) {
@ -386,15 +384,20 @@ public class BasFlightController {
} }
//test //test
@GetMapping("/test") @PostMapping("/adex/buffer")
public void createCircleTest(@RequestParam double getX, @RequestParam double getY, @RequestParam double buffer) { public List<Coordinate> adexBuffer(@RequestBody BasFlightCoordModel model) {
Coordinate circleCoord = new Coordinate(getY, getX); List<Coordinate> transCoordList = utils.transform(model.getCoordinates(), "EPSG:4326", "EPSG:5181");
List<Coordinate> bufferList = utils.buffer(transCoordList, model.getBuffer()); // buffer 영역 생성
List<Coordinate> transBufferList = utils.transform(bufferList, "EPSG:5181", "EPSG:4326"); // buffer 영역 좌표계 변환
List<Coordinate> coordList = utils.createCircle(circleCoord, buffer); return transBufferList;
for(Coordinate a : coordList) {
System.out.println("["+a.getX() + ", " + a.getY()+"],");
}
} }
public void test3d(@RequestBody Coordinate coord, @RequestParam double buffer) {
}
} }

15
src/main/java/com/palnet/biz/api/bas/flight/model/BasFlightCoordModel.java

@ -0,0 +1,15 @@
package com.palnet.biz.api.bas.flight.model;
import java.util.List;
import org.locationtech.jts.geom.Coordinate;
import lombok.Data;
@Data
public class BasFlightCoordModel {
private List<Coordinate> coordinates;
private Double buffer;
}

59
src/main/java/com/palnet/biz/api/bas/flight/service/BasFlightService.java

@ -13,12 +13,15 @@ import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.stream.Collectors; import java.util.stream.Collectors;
import javax.xml.bind.JAXBException;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.json.simple.JSONObject; import org.json.simple.JSONObject;
import org.json.simple.parser.JSONParser; import org.json.simple.parser.JSONParser;
import org.json.simple.parser.ParseException; import org.json.simple.parser.ParseException;
import org.locationtech.jts.geom.Coordinate; import org.locationtech.jts.geom.Coordinate;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.data.domain.PageImpl; import org.springframework.data.domain.PageImpl;
import org.springframework.data.domain.PageRequest; import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Pageable; import org.springframework.data.domain.Pageable;
@ -57,6 +60,8 @@ import com.palnet.comn.code.ErrorCode;
import com.palnet.comn.exception.CustomException; import com.palnet.comn.exception.CustomException;
import com.palnet.comn.utils.AreaUtils; import com.palnet.comn.utils.AreaUtils;
import com.palnet.comn.utils.EncryptUtils; import com.palnet.comn.utils.EncryptUtils;
import com.palnet.comn.utils.KmlUtils;
import com.palnet.comn.utils.SftpUtils;
import lombok.extern.log4j.Log4j2; import lombok.extern.log4j.Log4j2;
@ -69,6 +74,14 @@ public class BasFlightService {
@Autowired @Autowired
private CtrTrnsLctnService ctrTrnsLctnService; private CtrTrnsLctnService ctrTrnsLctnService;
@Value("${spring.config.activate.on-profile:}")
private String profile;
@Value("${weather.api.url}")
private String weatherUrl;
@Value("${weather.api.key}")
private String weatherKey;
private final FltPlanBasRepository fltPlanBasRepository; private final FltPlanBasRepository fltPlanBasRepository;
private final FltPlanArcrftRepository fltPlanArcrftRepository; private final FltPlanArcrftRepository fltPlanArcrftRepository;
private final FltPlanAreaRepository fltPlanAreaRepository; private final FltPlanAreaRepository fltPlanAreaRepository;
@ -78,7 +91,9 @@ public class BasFlightService {
private final PtyGroupQueryRepository ptyPlanQueryRepository; private final PtyGroupQueryRepository ptyPlanQueryRepository;
private final JwtTokenUtil jwtTokenUtil; private final JwtTokenUtil jwtTokenUtil;
private final AreaUtils areaUtils; private final AreaUtils areaUtils;
private final KmlUtils kmlUtils;
private final SftpUtils sftpUtils;
public BasFlightService(FltPlanBasRepository fltPlanBasRepository, public BasFlightService(FltPlanBasRepository fltPlanBasRepository,
FltPlanArcrftRepository fltPlanArcrftRepository, FltPlanArcrftRepository fltPlanArcrftRepository,
FltPlanAreaRepository fltPlanAreaRepository, FltPlanAreaRepository fltPlanAreaRepository,
@ -87,7 +102,9 @@ public class BasFlightService {
FltPlanQueryRepository fltPlanQueryRepository, FltPlanQueryRepository fltPlanQueryRepository,
PtyGroupQueryRepository ptyPlanQueryRepository, PtyGroupQueryRepository ptyPlanQueryRepository,
JwtTokenUtil jwtTokenUtil, JwtTokenUtil jwtTokenUtil,
AreaUtils areaUtils) { AreaUtils areaUtils,
KmlUtils kmlUtils,
SftpUtils sftpUtils) {
this.fltPlanBasRepository = fltPlanBasRepository; this.fltPlanBasRepository = fltPlanBasRepository;
this.fltPlanArcrftRepository = fltPlanArcrftRepository; this.fltPlanArcrftRepository = fltPlanArcrftRepository;
this.fltPlanAreaRepository = fltPlanAreaRepository; this.fltPlanAreaRepository = fltPlanAreaRepository;
@ -97,6 +114,8 @@ public class BasFlightService {
this.ptyPlanQueryRepository = ptyPlanQueryRepository; this.ptyPlanQueryRepository = ptyPlanQueryRepository;
this.jwtTokenUtil = jwtTokenUtil; this.jwtTokenUtil = jwtTokenUtil;
this.areaUtils = areaUtils; this.areaUtils = areaUtils;
this.kmlUtils = kmlUtils;
this.sftpUtils = sftpUtils;
} }
// 비행계획서 조회 // 비행계획서 조회
@ -289,7 +308,7 @@ public class BasFlightService {
// 비행계획서 등록 // 비행계획서 등록
@Transactional @Transactional
public boolean createPlan(BasFlightPlanModel rq) { public void createPlan(BasFlightPlanModel rq) throws IOException, JAXBException {
// 비행계획서 유효성 검사. // 비행계획서 유효성 검사.
this.planValid(rq); this.planValid(rq);
@ -349,12 +368,27 @@ public class BasFlightService {
fltPlanArcrftRepository.save(arcrftEntity); fltPlanArcrftRepository.save(arcrftEntity);
} }
} }
return true;
List<String> coords = new ArrayList<String>();
for(BasFlightPlanAreaCoordModel coordModel : areaModelList.get(0).getCoordList()) {
coords.add(coordModel.getLon() + "," + coordModel.getLat());
}
log.info("profile >>>>>>>>>>>> : {} " , profile);
if(!("local".equals(profile.toString()))) {
log.info("kml parse");
String kml = kmlUtils.generateKMLFromSimpleKml(coords);
sftpUtils.init(kml, "PLAN-COORDS-" + planSno);
}
// log.info(">>>>>>>>>>>>>> result {}" , result);
} }
// 비행계획서 수정 // 비행계획서 수정
@Transactional @Transactional
public boolean updatePlan(BasFlightPlanModel rq) { public boolean updatePlan(BasFlightPlanModel rq) throws IOException, JAXBException {
// 비행계획서 유효성 검사. // 비행계획서 유효성 검사.
this.planValid(rq); this.planValid(rq);
@ -474,7 +508,18 @@ public class BasFlightService {
}).collect(Collectors.toList()); }).collect(Collectors.toList());
fltPlanArcrftRepository.deleteAll(deleteArcrftEntity); fltPlanArcrftRepository.deleteAll(deleteArcrftEntity);
} }
List<String> coords = new ArrayList<String>();
for(BasFlightPlanAreaCoordModel coordModel : areaModelList.get(0).getCoordList()) {
coords.add(coordModel.getLon() + "," + coordModel.getLat());
}
String kml = kmlUtils.generateKMLFromSimpleKml(coords);
sftpUtils.init(kml, "PLAN-COORDS-" + planSno);
} }
return true; return true;
} }
@ -673,8 +718,8 @@ public class BasFlightService {
return schedule; return schedule;
} }
public JSONObject getWeather(BasFlightWeatherModel rq) throws IOException, ParseException { public JSONObject getWeather(BasFlightWeatherModel rq) throws IOException, ParseException {
StringBuilder urlBuilder = new StringBuilder("http://apis.data.go.kr/1360000/VilageFcstInfoService_2.0/getVilageFcst"); StringBuilder urlBuilder = new StringBuilder(weatherUrl);
urlBuilder.append("?" + URLEncoder.encode("serviceKey","UTF-8") + "=r6RMUsk3Vtama7D6uq7MiWV9dTC9MwfIIr4%2F45y0uVNw6BaYbgpKmL%2BLUDFVTfIYUmEe4K%2FaniEjdV9mg5t82Q%3D%3D"); urlBuilder.append("?" + URLEncoder.encode("serviceKey","UTF-8") + weatherKey);
urlBuilder.append("&" + URLEncoder.encode("pageNo","UTF-8") + "=" + URLEncoder.encode(rq.getPageNo(),"UTF-8")); urlBuilder.append("&" + URLEncoder.encode("pageNo","UTF-8") + "=" + URLEncoder.encode(rq.getPageNo(),"UTF-8"));
urlBuilder.append("&" + URLEncoder.encode("numOfRows","UTF-8") + "=" + URLEncoder.encode(rq.getNumOfRows(), "UTF-8")); /*한 페이지 결과 수*/ urlBuilder.append("&" + URLEncoder.encode("numOfRows","UTF-8") + "=" + URLEncoder.encode(rq.getNumOfRows(), "UTF-8")); /*한 페이지 결과 수*/
urlBuilder.append("&" + URLEncoder.encode("dataType","UTF-8") + "=" + URLEncoder.encode("JSON", "UTF-8")); /*요청자료형식(XML/JSON) Default: XML*/ urlBuilder.append("&" + URLEncoder.encode("dataType","UTF-8") + "=" + URLEncoder.encode("JSON", "UTF-8")); /*요청자료형식(XML/JSON) Default: XML*/

58
src/main/java/com/palnet/biz/api/comn/controller/ComnController.java

@ -0,0 +1,58 @@
package com.palnet.biz.api.comn.controller;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.URLEncoder;
import java.nio.charset.StandardCharsets;
import javax.servlet.http.HttpServletResponse;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
@RestController
@Slf4j
@RequestMapping("/api/comn")
@RequiredArgsConstructor
public class ComnController {
private final HttpServletResponse response;
private final String BASE_URL = "/data/pdf/3-1.paldesign.pdf";
@GetMapping("/pdf-download")
public void pdfDownload(){
log.error("ComnController - pdfDownload()");
try (InputStream inputStream = new FileInputStream(new File(BASE_URL));
OutputStream outputStream = response.getOutputStream()) {
String fileOriName = "3-1.paldesign.pdf";
fileOriName = URLEncoder.encode(fileOriName, StandardCharsets.UTF_8);
response.setContentType(MediaType.APPLICATION_OCTET_STREAM_VALUE);
response.setCharacterEncoding(StandardCharsets.UTF_8.name());
response.setHeader("Content-Disposition", "attachment; filename=\"" + fileOriName + "\"");
byte[] buffer = new byte[1024];
int length;
while ((length = inputStream.read(buffer)) != -1) {
outputStream.write(buffer, 0, length);
}
} catch (IOException e) {
log.error("error -> {}", e.getMessage());
}
}
}

12
src/main/java/com/palnet/biz/api/ctr/cntrl/service/CtrCntrlService.java

@ -24,6 +24,7 @@ import org.json.simple.parser.JSONParser;
import org.json.simple.parser.ParseException; import org.json.simple.parser.ParseException;
import org.locationtech.jts.geom.Coordinate; import org.locationtech.jts.geom.Coordinate;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cache.annotation.Cacheable; import org.springframework.cache.annotation.Cacheable;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
@ -86,7 +87,12 @@ public class CtrCntrlService {
private CtrTrnsLctnService ctrTrnsLctnService; private CtrTrnsLctnService ctrTrnsLctnService;
@Autowired @Autowired
private FltPlanCtrCntrlRelRepository relRepository; private FltPlanCtrCntrlRelRepository relRepository;
@Value("${weather.api.url}")
private String weatherUrl;
@Value("${weather.api.key}")
private String weatherKey;
private final CtrCntrlQueryRepository query; private final CtrCntrlQueryRepository query;
private final CtrCntrlBasRepository cntrlBasRepository; private final CtrCntrlBasRepository cntrlBasRepository;
private final CtrCntrlHstryRepository cntrlHstryRepository; private final CtrCntrlHstryRepository cntrlHstryRepository;
@ -617,7 +623,7 @@ public class CtrCntrlService {
public JSONObject getWeather(CtrCntrlWeatherModel rq) throws IOException, ParseException { public JSONObject getWeather(CtrCntrlWeatherModel rq) throws IOException, ParseException {
StringBuilder urlBuilder = new StringBuilder("http://apis.data.go.kr/1360000/VilageFcstInfoService_2.0/getVilageFcst"); StringBuilder urlBuilder = new StringBuilder(weatherUrl);
SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd"); SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd");
Calendar c1 = Calendar.getInstance(); Calendar c1 = Calendar.getInstance();
@ -697,7 +703,7 @@ public class CtrCntrlService {
String Snx = String.format("%.0f",nx); String Snx = String.format("%.0f",nx);
String Sny = String.format("%.0f",ny); String Sny = String.format("%.0f",ny);
urlBuilder.append("?" + URLEncoder.encode("serviceKey","UTF-8") + "=r6RMUsk3Vtama7D6uq7MiWV9dTC9MwfIIr4%2F45y0uVNw6BaYbgpKmL%2BLUDFVTfIYUmEe4K%2FaniEjdV9mg5t82Q%3D%3D"); urlBuilder.append("?" + URLEncoder.encode("serviceKey","UTF-8") + weatherKey);
urlBuilder.append("&" + URLEncoder.encode("pageNo","UTF-8") + "=" + URLEncoder.encode("1","UTF-8")); urlBuilder.append("&" + URLEncoder.encode("pageNo","UTF-8") + "=" + URLEncoder.encode("1","UTF-8"));
urlBuilder.append("&" + URLEncoder.encode("numOfRows","UTF-8") + "=" + URLEncoder.encode("14", "UTF-8")); /*한 페이지 결과 수*/ urlBuilder.append("&" + URLEncoder.encode("numOfRows","UTF-8") + "=" + URLEncoder.encode("14", "UTF-8")); /*한 페이지 결과 수*/
urlBuilder.append("&" + URLEncoder.encode("dataType","UTF-8") + "=" + URLEncoder.encode("JSON", "UTF-8")); /*요청자료형식(XML/JSON) Default: XML*/ urlBuilder.append("&" + URLEncoder.encode("dataType","UTF-8") + "=" + URLEncoder.encode("JSON", "UTF-8")); /*요청자료형식(XML/JSON) Default: XML*/

3
src/main/java/com/palnet/biz/config/WebSecurityConfig.java

@ -48,7 +48,8 @@ public class WebSecurityConfig extends WebSecurityConfigurerAdapter {
"/webjars/**", "/webjars/**",
/* swagger v3 */ /* swagger v3 */
"/v3/api-docs/**", "/v3/api-docs/**",
"/swagger-ui/**" "/swagger-ui/**",
"/api/comn/pdf-download" // TODO :: 전시회를 위한 임시 허용 URL
}; };
@Autowired @Autowired

71
src/main/java/com/palnet/comn/utils/KmlUtils.java

@ -0,0 +1,71 @@
package com.palnet.comn.utils;
import java.io.IOException;
import java.io.StringWriter;
import java.util.List;
import javax.xml.bind.JAXBContext;
import javax.xml.bind.JAXBException;
import javax.xml.bind.Marshaller;
import org.springframework.context.annotation.Profile;
import org.springframework.stereotype.Component;
import de.micromata.opengis.kml.v_2_2_0.Document;
import de.micromata.opengis.kml.v_2_2_0.Kml;
import de.micromata.opengis.kml.v_2_2_0.Placemark;
import de.micromata.opengis.kml.v_2_2_0.Point;
import lombok.extern.slf4j.Slf4j;
@Component
@Slf4j
public class KmlUtils {
public String generateKMLFromSimpleKml(List<String> coordinates) throws IOException, JAXBException {
Kml kml = new Kml();
Document document = kml.createAndSetDocument();
for (String coordinate : coordinates) {
Placemark placemark = document.createAndAddPlacemark();
placemark.setName("Simple placemark");
placemark.setDescription("Attached to the ground. Intelligently places itself at the height of the underlying terrain.");
Point point = placemark.createAndSetPoint();
point.addToCoordinates(coordinate);
}
StringWriter writer = new StringWriter();
JAXBContext context = JAXBContext.newInstance(Kml.class);
Marshaller marshaller = context.createMarshaller();
marshaller.setProperty(Marshaller.JAXB_FORMATTED_OUTPUT, Boolean.TRUE);
marshaller.marshal(kml, writer);
String kmlString = writer.toString();
return kmlString;
}
// public String generateKMLFromCoordinates(List<String> coordinatesList) {
// StringBuilder kmlBuilder = new StringBuilder();
// kmlBuilder.append("<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n");
// kmlBuilder.append("<kml xmlns=\"http://www.opengis.net/kml/2.2\">\n");
// kmlBuilder.append("<Document>\n");
// for (String coordinates : coordinatesList) {
// kmlBuilder.append("<Placemark>\n");
// kmlBuilder.append("<name>Simple placemark</name>\n");
// kmlBuilder.append("<description>Attached to the ground. Intelligently places itself at the height of the underlying terrain.</description>\n");
// kmlBuilder.append("<Point>\n");
// kmlBuilder.append("<coordinates>").append(coordinates).append("</coordinates>\n");
// kmlBuilder.append("</Point>\n");
// kmlBuilder.append("</Placemark>\n");
// }
// kmlBuilder.append("</Document>\n");
// kmlBuilder.append("</kml>");
//
// log.info("kml>>>>>>>>>>>{}", kmlBuilder);
//
// return kmlBuilder.toString();
// }
}

142
src/main/java/com/palnet/comn/utils/SftpUtils.java

@ -0,0 +1,142 @@
package com.palnet.comn.utils;
import java.io.ByteArrayInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Vector;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import com.jcraft.jsch.Channel;
import com.jcraft.jsch.ChannelSftp;
import com.jcraft.jsch.JSch;
import com.jcraft.jsch.JSchException;
import com.jcraft.jsch.Session;
import com.jcraft.jsch.SftpATTRS;
import com.jcraft.jsch.SftpException;
import lombok.extern.log4j.Log4j2;
@Component
@Log4j2
public class SftpUtils {
private Session session = null;
private Channel channel = null;
private ChannelSftp channelSftp = null;
@Value("${spring.sftp.host}")
private String host;
@Value("${spring.sftp.userName}")
private String userName;
@Value("${spring.sftp.password}")
private String password;
@Value("${spring.sftp.port}")
private int port;
@Value("${spring.sftp.uploadPath}")
private String uploadPath;
private final Date today = new Date();
private final SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd");
public void init(String kmlContent, String fileName) {
JSch jSch = new JSch();
try {
session = jSch.getSession(userName, host, port);
session.setPassword(password);
java.util.Properties config = new java.util.Properties();
config.put("StrictHostKeyChecking", "no");
session.setConfig(config);
session.connect();
channelSftp = (ChannelSftp) session.openChannel("sftp");
channelSftp.connect();
// kmlContent를 ByteArrayInputStream으로 변환
ByteArrayInputStream inputStream = new ByteArrayInputStream(kmlContent.getBytes("UTF-8"));
// 파일 업로드
channelSftp.cd(uploadPath); // 원격 디렉토리로 이동
channelSftp.put(inputStream, fileName); // 파일 업로드
log.info("파일 업로드 완료");
} catch (JSchException | SftpException | UnsupportedEncodingException e) {
e.printStackTrace();
} finally {
if (channelSftp != null && channelSftp.isConnected()) {
channelSftp.disconnect();
}
if (session != null && session.isConnected()) {
session.disconnect();
}
}
}
public boolean exists(String path) {
Vector res = null;
try {
res = channelSftp.ls(path);
} catch (SftpException e) {
if (e.id == ChannelSftp.SSH_FX_NO_SUCH_FILE) {
return false;
}
}
return res != null && !res.isEmpty();
}
public boolean upload(String dir, File file) {
boolean isUpload = false;
SftpATTRS attrs;
FileInputStream in = null;
try {
in = new FileInputStream(file);
channelSftp.cd(dir);
channelSftp.put(in, file.getName());
// 업로드했는지 확인
if (this.exists(dir +"/"+file.getName())) {
isUpload = true;
}
} catch (SftpException e) {
e.printStackTrace();
} catch (FileNotFoundException e) {
e.printStackTrace();
} finally {
try {
in.close();
} catch (IOException e) {
e.printStackTrace();
}
}
return isUpload;
}
// public void sftp(String kml) {
//
// this.init(host, userName, password, port);
//
// // 업로드 테스트
// File uploadfile = new File(uploadPath + "파일명"); // 파일 객체 생성
//
// String mkdirPath = sdf.format(today); //현재날짜 년월일
// boolean isUpload = this.upload(uploadPath+mkdirPath, uploadfile); //업로드
// System.out.println("isUpload -" + isUpload); // 업로드 여부 확인
//
// // 업로드 다운로드 수행 후 꼭 연결을 끊어줘야 한다!!
// channelSftp.quit();
// session.disconnect();
// }
}

12
src/main/resources/application.properties

@ -14,6 +14,9 @@ naver.api.url=https://naveropenapi.apigw.ntruss.com/map-reversegeocode/v2/gc
spring.jwt.secret=jwtsecretkey spring.jwt.secret=jwtsecretkey
spring.jwt.prefix=palnet spring.jwt.prefix=palnet
## Weather key ####
weather.api.url = http://apis.data.go.kr/1360000/VilageFcstInfoService_2.0/getVilageFcst
weather.api.key = =r6RMUsk3Vtama7D6uq7MiWV9dTC9MwfIIr4%2F45y0uVNw6BaYbgpKmL%2BLUDFVTfIYUmEe4K%2FaniEjdV9mg5t82Q%3D%3D
### AWS S3 #### ### AWS S3 ####
#cloud.aws.credentials.accessKey=AKIAW75VMZKFTMBRXK4I #cloud.aws.credentials.accessKey=AKIAW75VMZKFTMBRXK4I
@ -24,4 +27,11 @@ cloud.aws.stack.auto=false
cloud.aws.s3.bucket=palnet-file cloud.aws.s3.bucket=palnet-file
cloud.aws.region.static=ap-northeast-2 cloud.aws.region.static=ap-northeast-2
cloud.aws.s3.bucket.url=https://s3.ap-northeast-2.amazonaws.com/palnet-file cloud.aws.s3.bucket.url=https://s3.ap-northeast-2.amazonaws.com/palnet-file
### sftp info ###
spring.sftp.host=211.253.38.218
spring.sftp.userName=root
spring.sftp.password=palnet!234
spring.sftp.port=3022
spring.sftp.uploadPath=/data/coord

2
src/main/resources/application.yml

@ -50,7 +50,7 @@ spring:
# show_sql: true # show_sql: true
# format_sql: true # format_sql: true
rabbitmq: rabbitmq:
host: 192.168.0.26 host: 192.168.0.45
port: 5672 port: 5672
username: palnet username: palnet
password: palnet!234 password: palnet!234

Loading…
Cancel
Save