/*
 * To change this license header, choose License Headers in Project Properties.
 * To change this template file, choose Tools | Templates
 * and open the template in the editor.
 */
package com.service.cache;

import GetInfo.GetCacheInfo;
import Lotus.Response;
import static com.sun.org.apache.xalan.internal.lib.ExsltDatetime.date;
import connection.ConnectionDB;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.Date;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.jws.WebService;
import javax.jws.WebMethod;
import javax.jws.WebParam;




@WebService(serviceName = "Cache")
public class Cache {
    
    
//    public static void main(String[] args)
//     {
//        try {
//            Cache cah = new Cache();
//            cah.getComPayList("01.01.2017", "28.11.2017");
//        } catch (SQLException ex) {
//            Logger.getLogger(Cache.class.getName()).log(Level.SEVERE, null, ex);
//        } catch (ClassNotFoundException ex) {
//            Logger.getLogger(Cache.class.getName()).log(Level.SEVERE, null, ex);
//        }
//        
//        
//     }    
    
        
    
 
    private ArrayList<GetCacheInfo> getComPayList(String begin_date, String end_date) throws SQLException, ClassNotFoundException {
        
        ArrayList<GetCacheInfo> al = new ArrayList<GetCacheInfo>();
        
        Connection connect;
    //    PreparedStatement stmt = null;
        connect = null;
        String url = "урлка";
        String name = "иванов";
        String password = "парольский"; 
       
        
         try {
             Class.forName("oracle.jdbc.driver.OracleDriver");   //Загружаем драйвер
             System.out.println("Драйвер подключен");
             connect = DriverManager.getConnection(url, name, password);
             System.out.println("Соединение установлено");
             PreparedStatement stmt=connect.prepareStatement(                     
                            "select " +
                                    "    бла бла бла бла" +
                                    
                            " from таблица  ");  
             
             stmt.setString(1, begin_date);  
             stmt.setString(2, end_date);
             
             ResultSet rs = stmt.executeQuery(); 
             
                       
             
             System.out.println("Выводим statement");
            
             while (rs.next()) 
             {
                GetCacheInfo cmp = new GetCacheInfo();
                cmp.setIdOperation(rs.getString("IdOperation"));
                cmp.setPay_date(rs.getString("pay_date"));
                cmp.setPay_time(rs.getString("pay_time"));
                cmp.setUstroystvo(rs.getString("Ustroystvo"));
                cmp.setAccTerminal(rs.getString("AccTerminal"));
                cmp.setAmountPay(rs.getString("AmountPay"));
                cmp.setAmountCom(rs.getString("AmountCom"));
                cmp.setProvider(rs.getString("Provider"));
                cmp.setTypeOper(rs.getString("TypeOper"));
                cmp.setKod_uslug(rs.getString("Kod_uslug"));
                cmp.setParametrs(rs.getString("Parametrs"));
                al.add(cmp);
                
                
            }
            
            rs.close();
             
        }catch (SQLException e) {

			System.out.println("e.getMessage()=" + e.getMessage());

		} finally {

//			if (null!= stmt) {
//                            stmt.close();
//			}

			if (null != connect) {
				connect.close();
			}
		}     
        
    return al;
    
    }   
    

    /**
     *
     * @param begin_date
     * @param end_date
     * @return
     */

   
    
    @WebMethod(operationName = "hello")
    public String hello(@WebParam(name = "name") String txt) {
        return "Hello " + txt + " !";
    }

    /**
     * Операция веб-службы
     * @param begin_date
     * @param end_date
     * @return 
     */


    /**
     * Операция веб-службы
     */
    @WebMethod(operationName = "GetCacheInfo")
    public ArrayList<GetCacheInfo> GetCacheInfo(@WebParam(name = "begin_date") String begin_date, @WebParam(name = "end_date") String end_date)  
    {
        try {
            ArrayList<GetCacheInfo> arr = getComPayList(begin_date, end_date);
            for(GetCacheInfo c:arr) {
                Lotus.InputCrpt l = new Lotus.InputCrpt();
                l.setIdOperation(c.getIdOperation());
                l.setPayDate(c.getPay_date());
                l.setPayTime(c.getPay_time());
                l.setUstroystvo(c.getUstroystvo());
                l.setAccTerminal(c.getAccTerminal());
                l.setAmountPay(c.getAmountPay());
                l.setAmountCom(c.getAmountCom());
                l.setProvider(c.getProvider());
                l.setTypeOper(c.getTypeOper());
                l.setKodUslug(c.getKod_uslug());
                l.setParametrs(c.getParametrs());                        
                
                Response res = dataForLotus(l);
                String errcode = res.getErrCode();
                
                if (errcode == "0") {
                    System.out.println(c.getIdOperation());
                    continue;
                } else {
                    break;
                }
                
            }
            
           

        } catch (SQLException ex) {
            Logger.getLogger(Cache.class.getName()).log(Level.SEVERE, null, ex);
        }   catch (ClassNotFoundException ex) {
                Logger.getLogger(Cache.class.getName()).log(Level.SEVERE, null, ex);
            }
        return null;
        
        
//    try {
//        //TODO write your implementation code here:
//        return getComPayList(begin_date, end_date);
//    } catch (SQLException ex) {
//        Logger.getLogger(Cache.class.getName()).log(Level.SEVERE, null, ex);
//    }   catch (ClassNotFoundException ex) {
//            Logger.getLogger(Cache.class.getName()).log(Level.SEVERE, null, ex);
//        }
//    return null;
        
    }

    private static Response dataForLotus(Lotus.InputCrpt inputcrpt) 
    {
        Lotus.RetrievalService service = new Lotus.RetrievalService();
        Lotus.Retrieval port = service.getDomino();
        return port.dataForLotus(inputcrpt);
    }



}