Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- public void retrieveCreateCustomerResponse() {
- List<String> result = new ArrayList<String>();
- InputStream in = null;
- Logging inputLog = new Logging();
- String idinvoice = "";
- String statusSap = "";
- String responMessage = "";
- setForFtp();
- try {
- FTPDownloader ftp = new FTPDownloader(serverAddress, user, pwd, port, isLinux);
- result = ftp.searchFile(pathCreateResponse);
- for(String s : result) {
- if(s.contains("_response_")) {
- System.out.println(s);
- ftp = new FTPDownloader(serverAddress, user, pwd, port, isLinux);
- ftp.changeDir(pathCreateResponse);
- in = ftp.getFileStream(s);
- JAXBContext jaxbContext = JAXBContext.newInstance(CustomerResponse.class);
- Unmarshaller jaxbUnmarshaller = jaxbContext.createUnmarshaller();
- CustomerResponse customer = (CustomerResponse) jaxbUnmarshaller.unmarshal(in);
- CustomerInfo cust = new CustomerInfo();
- CustomerCreateDetailResponse customerResponse = new CustomerCreateDetailResponse();
- customerResponse = customer.getCustomerCreateResponse().getCustomers();
- System.out.println(customerResponse.getResponseMessage());
- cust = customerService.findCustomerInfoById(customerResponse.getDigiCustCode());
- if(cust!=null) {
- if(customerResponse.getResponseStatus().equalsIgnoreCase("0")) {
- cust.setSapStatus(GlobalType.CUST_SUCCESS.getId());
- cust.setReffnumber(customerResponse.getSapCustCode());
- } else if(customerResponse.getResponseStatus().equalsIgnoreCase("1")) {
- if(cust.getSapStatus()==GlobalType.CUST_POSTED_INSERT.getId()) {
- cust.setSapStatus(GlobalType.CUST_FAILED_INSERT_SAP.getId());
- } else if(cust.getSapStatus()==GlobalType.CUST_POSTED_UPDATE.getId()) {
- cust.setSapStatus(GlobalType.CUST_FAILED_UPDATE_SAP.getId());
- }
- } else {
- cust.setSapStatus(GlobalType.CUST_INSERT_REQ.getId());
- }
- idinvoice = cust.getId();
- statusSap = String.valueOf(cust.getSapStatus());
- responMessage = customerResponse.getResponseMessage();
- customerService.updateCustomerInfo(cust);
- }
- //ftp = new FTPDownloader(serverAddress, user, pwd, port);
- ftp.moveFile(pathCreateResponse+s, pathCreateDone+s);
- }
- }
- if(idinvoice!="" && idinvoice!=null){
- System.out.println("id invoice : "+idinvoice+" sap : "+statusSap+" resp mess : "+responMessage);
- inputLog.setIdGeneral(idinvoice);
- inputLog.setIdType("Customer");
- inputLog.setCreatedDate(new Date());
- inputLog.setIsDeleted("N");
- inputLog.setStatusSap(statusSap);
- inputLog.setStatusIntegrasi("Success");
- inputLog.setResponMessage(responMessage);
- // System.out.println("in : "+in);
- String xml = "test";
- System.out.println("xml = "+xml);
- inputLog.setXmlData(xml);
- Logging succesLog = new Logging();
- succesLog = commonService.insertLogging(inputLog);
- if(succesLog.getId().equals("") && succesLog.getId()!=null){
- System.out.println("id : "+succesLog.getId());
- }
- inputLog = new Logging();
- }
- //ftp.disconnect();
- } catch (Exception e) {
- e.printStackTrace();
- inputLog.setStatusIntegrasi("Fail");
- inputLog.setResponMessage(e.getMessage());
- inputLog.setIdGeneral(idinvoice);
- inputLog.setIdType("Customer");
- inputLog.setCreatedDate(new Date());
- inputLog.setIsDeleted("N");
- inputLog.setStatusSap(statusSap);
- Logging succesLog = new Logging();
- succesLog = commonService.insertLogging(inputLog);
- if(succesLog.getId().equals("") && succesLog.getId()!=null){
- System.out.println("id : "+succesLog.getId());
- }
- inputLog = new Logging();
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement