package mega.loanoncardbulk.process;

import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;

import mega.loanoncardbulk.dao.LoanOnCardDbDao;
import mega.loanoncardbulk.utils.ConfigProperties;
import mega.loanoncardbulk.utils.FileCreateManage;
import mega.loanoncardbulk.utils.HTTPComponentPOST;
import mega.loanoncardbulk.utils.UtilsHelper;

import org.apache.commons.codec.binary.Base64;
import org.apache.commons.lang.StringUtils;
import org.apache.log4j.Logger;
import org.mule.api.MuleContext;
import org.mule.api.MuleEventContext;
import org.mule.api.MuleMessage;
import org.mule.api.lifecycle.Callable;



public class GetBulkDataProcess implements Callable {
	private String code = new String();
	Logger log = Logger.getLogger(LoanOnCardDbDao.class);

	@Override
	public Object onCall(MuleEventContext eventContext) throws Exception {
		// TODO Auto-generated method stub

		try {
			MuleContext muleContext = eventContext.getMuleContext();
			MuleMessage message = eventContext.getMessage();
			UtilsHelper util = new UtilsHelper();
			LoanOnCardDbDao db = (LoanOnCardDbDao) muleContext.getRegistry().lookupObject("mysqlDao");
			ConfigProperties configProperties = (ConfigProperties) muleContext.getRegistry().lookupObject("configProperties");
			FileCreateManage filemanage = new FileCreateManage();

			HashMap<String, String> mftf_header = new HashMap<String, String>();
			mftf_header = db.getMftfHeader();

			String file_code 	= mftf_header.get("name_file");
			String flagFl 		= mftf_header.get("flag");
			String acctdebt 	= mftf_header.get("acct_debt");
			String srcbranch 	= mftf_header.get("src_branch");
			String name_file 	= file_code + util.getDateTimeByFormat("yyyyMMdd", 0);
			String trxdate 		= util.getDateTimeByFormat("ddMMyy", 0);
			String remark3 		= "Upload Testing1";

			// properties
			int maxDataDetail 	= Integer.parseInt(configProperties.getProperties("max_DataDetail"));
			int maxSequenceFile = Integer.parseInt(configProperties.getProperties("max_SequenceFile"));
			String path 		= configProperties.getProperties("file_read_path_done");
			String ext 			= configProperties.getProperties("file_up_format");

			String flag 		= configProperties.getProperties("flag_up");

			int total = db.getTotalLocData(flag);
			// total = 160000;

			log.info("Total perkiraan data = " + total);

			if (total != 0) {
				int perulangan = (total / maxDataDetail) + 1;
				log.info("Total perkiraan perulangan = " + perulangan);

				for (int x = 1; x <= perulangan; x++) {

					String namePartFile = StringUtils.leftPad(Integer.toString(x), 4, "0");

					if(perulangan > maxSequenceFile){

						log.info("GENERATED FILE HAS BEEN STOP, You have reach max file name today = "+namePartFile);
						break;
					}

					namePartFile = name_file + namePartFile;
					String datetime = util.getDateTimeByFormat("yyyyMMdd HHmmss", 0);
					String datetimeall[] = datetime.split(" ");
					String date = datetimeall[0];
					String time = datetimeall[1];


					//created file
					filemanage.generateFile(path, namePartFile, ext);

					try{
					String fullPath = path + namePartFile + "." + ext;

					List<HashMap<String, String>> listresult = new ArrayList<HashMap<String, String>>();

					listresult = db.getLocToLimit(flag, maxDataDetail);

					int totalList = listresult.size();
//					int row = 1;
//					long totalAmount = 0;
					BigDecimal totalAmt = new BigDecimal(0);
					for (HashMap<String, String> result : listresult) {
//						totalAmount = totalAmount + Long.parseLong(result.get("amount"));
						totalAmt = totalAmt.add(new BigDecimal(result.get("amount")));
					}
					log.info("Total List data = " + totalList);

					String dateHeader = date.substring(6, 8)+date.substring(4,6)+date.substring(2, 4);

				StringBuilder sb = new StringBuilder();
				for (int a=1; a<=2; a++){
					String line = new String();


					for (int y = 1; y <= 8; y++) {

						if (y <= 8) {
							if (y == 1) {
								line = "Flag:," + flagFl + ",,,,,,,,,,,,,,,,,,,,";
								writeToFile(a,line, fullPath, "y");
							} else if (y == 2) {
								line = "Account Debit:," + acctdebt + ",,,,,,,,,,,,,,,,,,,,";
								writeToFile(a,line, fullPath, "y");
							} else if (y == 3) {
								line = "Total transaction:," + totalList + ",,,,,,,,,,,,,,,,,,,,";
								writeToFile(a,line, fullPath, "y");
							} else if (y == 4) {
								line = "Total transaction amount:," + totalAmt.toString().trim().replace(".", "") + ",,,,,,,,,,,,,,,,,,,,";
								writeToFile(a,line, fullPath, "y");
							} else if (y == 5) {
								line = "Transaction date:," +dateHeader + ",,,,,,,,,,,,,,,,,,,,";
								writeToFile(a,line, fullPath, "y");
							} else if (y == 6) {
								// line ="User ID:,"+header.getUserId();
								line = "User ID:,,,,,,,,,,,,,,,,,,,,,";
								writeToFile(a,line, fullPath, "y");
							} else if (y == 7) {
								// line ="User ID:,"+header.getUserId();
								if( a==2){
									line = "Code:,"+this.code+",,,,,,,,,,,,,,,,,,,,";
									writeToFile(a,line, fullPath, "y");
								}
								else {
									continue;
								}
							}else if (y == 8) {
								String line1, line2;
								line1 = ",,,,,,,,,,,,,,,,,,,,,";
								writeToFile(a,line1, fullPath, "y");
//								line = "Service code,Source Branch,Date DDMMYY,Reff no,Amount,Remark Line 3,Remark Line 4,REMARK TRX,BIC BANK PENERIMA,NAMA PENGIRIM,REKENING PENGIRIM,CHARGE 1,CHARGE 2,Jenis nasabah penerima,Status penduduk penerima,Account Credit,Account Debit,REKENING PENERIMA SKN,NAMA PENERIMA SKN,REKENING PENERIMA  RTG,NAMA PENERIMA  RTG,Reff User";
								line2 = "Service code,Source Branch,Date DDMMYY,Reff no,Amount,Remark Line 3,Remark Line 4,REMARK TRX,BIC BANK PENERIMA,NAMA PENGIRIM,REKENING PENGIRIM,CHARGE 1,CHARGE 2,Jenis nasabah penerima,Status penduduk penerima,Account Credit,Account Debit,NAMA PENERIMA OVB,REKENING PENERIMA SKN,NAMA PENERIMA SKN,REKENING PENERIMA  RTG,NAMA PENERIMA  RTG,AlAMAT PENERIMA,AlAMAT KOTA PENERIMA,KODE CABANG BANK PENERIMA,Reff User";
								writeToFile(a,line2, fullPath, "y");
								line = line1 + line2;
							}

							//collectline
							sb.append(line);
						}

					}


					for (HashMap<String, String> result : listresult) {
//						String line = new String();

//before..
//						if(result.get("kode_bene").equals("MEGAIDJA")){
//							line = 	"OVB,"
//								+srcbranch+","
//								+trxdate+","
//								+"," //ovb.getReffno()
//								+result.get("amount").trim().replace(".", "")+","
//								+remark3+","
//								+"," //ovb.getRemarkTrx4()
//								+",,,,,,,,"
//								+result.get("rek_bene")+","
//								+acctdebt+","
//								+",,,,"+result.get("id"); //ovb.getReffusr()
//
////							OVB,801,081117,,100000,Upload Testing1,,,,,,,,,,010740020106872,010740012019880,,,,,0
//							filemanage.writeToFile(line, fullPath, "y");
////							row++;
//
//						}

						if(result.get("kode_bene").equals("MEGAIDJA")){
							line = 	"OVB,"
								+srcbranch+","
								+trxdate+","
								+"," //ovb.getReffno()
								+result.get("amount").trim().replace(".", "")+","
								+remark3+","
								+"," //ovb.getRemarkTrx4()
								+",,,,,,,,"
								+result.get("rek_bene")+","
								+acctdebt+","
								+result.get("nama_bene")+","
								+",,,,,,,"+result.get("id"); //ovb.getReffusr()

//							OVB,801,081117,,100000,Upload Testing1,,,,,,,,,,010740020106872,010740012019880,,,,,0
							writeToFile(a,line, fullPath, "y");
//							row++;

						} else if(new BigDecimal(result.get("amount").trim()).compareTo(new BigDecimal(100000000))==1 ){
							line = 	"RTG,"
								+srcbranch+","
								+trxdate+","
								+"," //ovb.getReffno()
								+result.get("amount").trim().replace(".", "")+","
								+remark3+","
								+",,"
								+result.get("kode_bene")+","
								+"BM CARD CENTER"+","
								+acctdebt+","
								+"0"+","
								+",,,"
								+",,,,,"
								+result.get("rek_bene")+","
								+result.get("nama_bene")+","
								+result.get("address_bene1")+","
								+result.get("city_bene")+","
								+result.get("kodebank_bene")+","
								+result.get("id");
							writeToFile(a,line, fullPath, "y");
						} else {
							line = 	"SKN,"
								+srcbranch+","
								+trxdate+","
								+"," //ovb.getReffno()
								+result.get("amount").trim().replace(".", "")+","
								+remark3+","
								+",,"
								+result.get("kode_bene")+","
								+"BM CARD CENTER"+","
								+acctdebt+","
								+"0"+","
								+","
								+"1"+","
								+"1"+","
								+",,,"
								+result.get("rek_bene")+","
								+result.get("nama_bene")+","
								+",,,,,"+result.get("id");
							writeToFile(a,line, fullPath, "y");
						}

						sb.append(line);
					}

					if(a==1){
						String CRC = sb.toString();
						byte[] encodedCRC = Base64.encodeBase64(CRC.getBytes());
						HashMap<String, Object> request = new HashMap<String, Object>();
						request.put("content", encodedCRC);
						//log.info("CRC = " + CRC);

						HTTPComponentPOST post = new HTTPComponentPOST();
						post.setIp("10.11.33.123");
						post.setPort("4747");
						post.setPath("/encryptor");
						post.setCto(2000);
						post.setRto(2000);

						HashMap<String, Object> dataResp = post.sendToHttpPost(request);

						if(dataResp.get("status").equals("00")){
							log.info(dataResp.get("status"));
							this.code = String.valueOf(dataResp.get("data"));
						}
						else{
							System.out.println("Encrypt code error");
							return null;
						}

					}

				}
					db.updateLocToBulkBatch(listresult);
					db.insertFileHistory(namePartFile, date, time);

				}catch (Exception e) {
					// TODO: handle exception
					e.printStackTrace();
				}
				}
			}

		} catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
		}

		return null;
	}


	private void writeToFile (int a, String line, String fullPath, String downline){
		FileCreateManage filemanage = new FileCreateManage();
		if(a==2){
			filemanage.writeToFile(line, fullPath, downline);
		}
		return;
	}
}