package com.test.service.CORBAService;

import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
import java.util.logging.Logger;

import org.apache.camel.Exchange;
import org.apache.camel.ProducerTemplate;
import com.test.interfaces.test.corba.CorbaParamParameter;
import com.test.interfaces.test.corba.CorbaParamParameterSet;
import com.test.interfaces.test.corba.EmployeeResponse;


@javax.jws.WebService(
        serviceName = "CorbaV01CorbaService",
        portName = "com.test.interfaces.test.corba.CorbaV01CorbaServicePort",
        targetNamespace = "http://test.com/interfaces/test/corba",
        wsdlLocation = "corbaService.wsdl",
        endpointInterface = "com.test.interfaces.test.corba.CorbaV01CorbaService")
public class CorbaServiceImpl {

	 private static final Logger LOG = Logger.getLogger(CorbaServiceImpl.class.getName());
	 private ProducerTemplate producerTemplate;
	 public CorbaServiceImpl (Exchange exchange)
	    {
	    	producerTemplate = exchange.getContext().createProducerTemplate();
	    }
	 
    public int employee(
        java.lang.String param1,
        long param2,
        java.lang.String param3,
        boolean param4,
        com.test.interfaces.test.corba.CorbaParamParameterSet inputParamSet,
        java.lang.String param6,
        javax.xml.ws.Holder<java.lang.Long> param7,
        javax.xml.ws.Holder<java.lang.Long> param8,
        javax.xml.ws.Holder<CorbaParamParameterSet> outputParamSet
    ){
        LOG.info("Executing operation employee");
        Map<String, Object> requestHeaders = new HashMap<String, Object>();
        try {
        	requestHeaders.put("param1", param1);
        	requestHeaders.put("param2", param2);
        	requestHeaders.put("param3", param3);
        	requestHeaders.put("param4", param4);
        	requestHeaders.put("inputParamSet", inputParamSet);
        	requestHeaders.put("erReference", param6);
        	requestHeaders.put("operationName", "employee");
        	if(inputParamSet !=null){
        		LOG.info("inputParamSet!=null"+inputParamSet.getItem().size());
        	Iterator<CorbaParamParameter> inputParamIterator = inputParamSet.getItem().iterator();
        	short parameterID;
        	int value=0;
        	
        	while(inputParamIterator.hasNext()) {
        		CorbaParamParameter corbaParamParameter = ((CorbaParamParameter)inputParamIterator.next());
        		parameterID = corbaParamParameter.getParameterID();
        		LOG.info("Employee_parameterID ::" + parameterID);
        		if(parameterID == 100)
        		{        		
        			LOG.info(" parameterID ::" + parameterID);
        			
        			if (corbaParamParameter.getValue().getIntValue() != null)
        			{
        				value = corbaParamParameter.getValue().getIntValue();        				
        			}
        			else if (corbaParamParameter.getValue().getShortValue() != null)
        			{
        				value=corbaParamParameter.getValue().getShortValue();
        			}        			
        			LOG.info("value ::" + value);
        		}
        		
        		if(parameterID == 200)
        			
        		{
        			LOG.info(" parameterID::" + parameterID);
        			if (corbaParamParameter.getValue().getIntValue() != null)
        			{
        				requestHeaders.put("parameterID", corbaParamParameter.getValue().getIntValue());
        			}
        			else if (corbaParamParameter.getValue().getShortValue() != null)
        			{
        				requestHeaders.put("parameterID", corbaParamParameter.getValue().getShortValue());       				
        			}
        			requestHeaders.put("flag", true);
        		}
        			
        	}}
        	else{
        		LOG.info("inputParamSet is null");
        	}
        	
            EmployeeResponse response = producerTemplate.requestBodyAndHeaders("direct:corbaOperations", "<T/>",requestHeaders,EmployeeResponse.class);
            int responseCode = response.getReturn();
            param7.value = response.getParam7();
            param8.value = response.getParam8();
            outputParamSet.value = response.getOutputParamSet();
            return responseCode;
        } catch (java.lang.Exception ex) {
            ex.printStackTrace();
            throw new RuntimeException(ex);
        }
    }

}