package gov.gdlt.ssgly.taxcore.taxblh.xxsx;

import gov.gdlt.ssgly.taxcore.comm.blh.BaseBizLogicHandler;
import gov.gdlt.ssgly.taxcore.comm.event.RequestEvent;
import gov.gdlt.ssgly.taxcore.comm.event.ResponseEvent;
import gov.gdlt.ssgly.taxcore.comm.exception.TaxBaseBizException;
import gov.gdlt.ssgly.taxcore.comm.exception.TaxBaseSystemException;
import gov.gdlt.ssgly.taxcore.taxevent.xxsx.XXSXcxnsrReqEvent;
import gov.gdlt.ssgly.taxcore.taxevent.xxsx.XXSXcxnsrResEvent;
import gov.gdlt.ssgly.taxcore.taxdao.xxsx.XXSXcxnsrDAO;
import gov.gdlt.ssgly.taxcore.taxevent.xxsx.XXSXnsrxxVO;
import gov.gdlt.ssgly.taxcore.comm.log.LogWritter;

import java.util.List;
import java.util.ArrayList;
import java.sql.SQLException;

public class XXSXcxnsrBLH extends BaseBizLogicHandler {
    public XXSXcxnsrBLH() {
    }

    /**
     *
     * @param req RequestEvent
     * @param conn Connection
     * @throws TaxBaseBizException
     * @throws TaxBaseSystemException
     * @return ResponseEvent
     * @todo Implement this gov.gdlt.taxcore.comm.blh.BaseBizLogicHandler
     *   method
     */
    protected ResponseEvent validateData(RequestEvent req) throws
            Exception {
        return null;
    }

    protected ResponseEvent performTask(RequestEvent req) throws
            TaxBaseBizException, TaxBaseSystemException {
        String dealMethod = req.getDealMethod(); //業務處理標志
        ResponseEvent resEvn = new ResponseEvent(); //創建ResponseEvent對象resEvn
        //強制造型轉換
        XXSXcxnsrReqEvent reqEvent = (XXSXcxnsrReqEvent) req;
        if ("cxNsr".equals(dealMethod)) {
            resEvn = this.cxNsr(reqEvent);
        } else if ("cxFromMyNsr".equals(dealMethod)) {
            resEvn = this.cxFromMyNsr(reqEvent);
        } else if("cxByPyjm".equals(dealMethod)){
            resEvn = this.cxByPyjm(reqEvent);
        } else {
//            System.out.print("function not found.");
        }

        return resEvn;
    }

    /**
     *
     * @param req RequestEvent
     * @param conn Connection
     * @throws Exception
     * @return ResponseEvent
     * @todo Implement this gov.gdlt.taxcore.comm.blh.BaseBizLogicHandler
     *   method
     */
    private ResponseEvent cxNsr(RequestEvent req) throws TaxBaseBizException {
        XXSXcxnsrReqEvent cxReq = (XXSXcxnsrReqEvent) req;
        String zbz = cxReq.getZbz().toUpperCase();
        List allNsrList = cxReq.getNsrnbmList();
        StringBuffer sb = new StringBuffer();
        for (int count = 0; count < allNsrList.size(); count++) {
            sb.append(allNsrList.get(count));
            if (count < allNsrList.size() - 1) {
                sb.append(",");
            }
        }
        String nsrString = sb.toString();
        XXSXnsrxxVO nsrxxvo = new XXSXnsrxxVO();
        nsrxxvo.setZbz(zbz);
        nsrxxvo.setNsrnbmList(nsrString);
        List nsrList = new ArrayList();
        XXSXcxnsrDAO cxnsrdao = new XXSXcxnsrDAO();
        XXSXcxnsrResEvent cxres = new XXSXcxnsrResEvent();
        // LogWritter.testDebug("---new cxnsrdao---");
        try {
            nsrList = cxnsrdao.findFromList(nsrxxvo);
            cxres.setRepCode("0");
        } catch (SQLException e) {
            cxres.setRepCode("-1");
            throw new TaxBaseBizException("YCXXSX01001:通過（" + zbz + "）搜尋納稅人異常！");
        }

            cxres.setNsrnbmList(nsrList);
            cxres.setMsg(sb.toString());
            return cxres;
    }

    private ResponseEvent cxFromMyNsr(RequestEvent req)throws TaxBaseBizException {
        XXSXcxnsrReqEvent cxReq = (XXSXcxnsrReqEvent) req;
        String zbz = cxReq.getZbz().toUpperCase();
        String lrry_dm = cxReq.getLrry_dm();
        XXSXnsrxxVO nsrxxvo = new XXSXnsrxxVO();
        nsrxxvo.setLrry_dm(lrry_dm);
        nsrxxvo.setZbz(zbz);
        XXSXcxnsrResEvent cxres = new XXSXcxnsrResEvent();
        XXSXcxnsrDAO cxnsrdao = new XXSXcxnsrDAO();
        //LogWritter.testDebug("---new cxnsrdao---");
        StringBuffer sb = new StringBuffer();
         List nsrList = new ArrayList();
        try{
            nsrList = cxnsrdao.findFromMyNsr(nsrxxvo);
            cxres.setRepCode("0");
        }catch(SQLException e){
            cxres.setRepCode("-1");
          throw new TaxBaseBizException("YCXXSX01002:通過（" + zbz + "）在管戶中搜尋納稅人異常！");
        }
            for (int i = 0; i < nsrList.size(); i++) {
                sb.append(nsrList.get(i))
                        .append("--");
            }

            cxres.setNsrnbmList(nsrList);
            cxres.setMsg(sb.toString());
            return cxres;

    }

    /**
     * 通過拼音簡碼獲取納稅人編碼
     * @param req RequestEvent
     * @return ResponseEvent
     */
    private ResponseEvent cxByPyjm(RequestEvent req)throws TaxBaseBizException{
        XXSXcxnsrReqEvent cxReq = (XXSXcxnsrReqEvent) req;
        String zbz = cxReq.getZbz().toUpperCase();
        String lrry_dm = cxReq.getLrry_dm();
        List nsrbmList = new ArrayList();
        StringBuffer sb = new StringBuffer();
        XXSXnsrxxVO nsrxxvo = new XXSXnsrxxVO();
        nsrxxvo.setLrry_dm(lrry_dm);
        nsrxxvo.setZbz(zbz);
        XXSXcxnsrResEvent cxres = new XXSXcxnsrResEvent();
        XXSXcxnsrDAO cxnsrdao = new XXSXcxnsrDAO();
        try {
            nsrbmList = cxnsrdao.findNsrbmByPyjm(nsrxxvo);
            for (int i = 0; i < nsrbmList.size(); i++) {
                sb.append(nsrbmList.get(i))
                        .append("--");
            }
            cxres.setRepCode("0");
        } catch (SQLException e) {
            cxres.setRepCode("-1");
            throw new TaxBaseBizException("YCXXSX01003:通過拼音簡碼（" + zbz +"）查詢納稅人異常！");
        }
            cxres.setNsrnbmList(nsrbmList);
            cxres.setMsg(sb.toString());
            return cxres;

    }
}