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

import gov.gdlt.ssgly.taxcore.comm.blh.*;
import gov.gdlt.ssgly.taxcore.comm.event.*;
import gov.gdlt.ssgly.taxcore.comm.exception.*;
import gov.gdlt.ssgly.taxcore.taxevent.rwgl.RWGLwcsqReqEvent;
import gov.gdlt.ssgly.taxcore.taxevent.rwgl.RWGLwcsqResEvent;
import gov.gdlt.ssgly.taxcore.taxdao.rwgl.RWGLwcsqDAO;
import java.util.ArrayList;
import gov.gdlt.ssgly.taxcore.taxdao.qxgl.QXGLswryDAO;
import gov.gdlt.ssgly.taxcore.taxevent.qxgl.QXGLswryVO;

/**
 *
 * <p>Title: 任務(wù)管理的外出授權(quán)的BLH </p>
 *
 * <p>Description: 廣東地稅稅收管理員工作平臺(tái)</p>
 *
 * <p>Copyright: Copyright (c) 2005 廣東省地方稅務(wù)局，廣州市地方稅務(wù)局</p>
 *
 * <p>Company: 廣州地稅</p>
 *
 * @author 黃錦昌
 * @version 1.0
 */

public class RWGLwcsqBLH extends BaseBizLogicHandler {
    private static final String SQZ_NOT_FOUND_EXCEPTION = "YCRWGL01001";
    private static final String DLZ_NOT_FOUND_EXCEPTION = "YCRWGL01002";

    public RWGLwcsqBLH() {
    }

    /**
     * performTask
     *
     * @param req RequestEvent
     * @return ResponseEvent
     * @throws TaxBaseBizException
     * @throws TaxBaseSystemException
     * @todo Implement this
     *   gov.gdlt.ssgly.taxcore.comm.blh.BaseBizLogicHandler method
     */
    protected ResponseEvent performTask(RequestEvent req) throws
            TaxBaseBizException, TaxBaseSystemException {
        RWGLwcsqReqEvent reqEvent = (RWGLwcsqReqEvent) req;
        String dealMethod = req.getDealMethod();
        RWGLwcsqResEvent resEvent = new RWGLwcsqResEvent();

        if ("getDepartmentMembers".equals(dealMethod)) {
            resEvent.setSwryList(this.getDepartmentMembers(reqEvent.getSwryDm()));
        } else if ("addWcsq".equals(dealMethod)) {
            boolean result = this.addWcsq(reqEvent.getSqzDm(), reqEvent.getDlzDm());
            if (!result)
                resEvent.setRepCode("error adding wcsq.");
        } else if ("getSqzListByDlzDm".equals(dealMethod)) {
            resEvent.setSqzList(this.getSqzListByDlzDm(reqEvent.getDlzDm()));
        } else if ("updateDlzReadFlag".equals(dealMethod)) {
            boolean result = this.updateDlzReadFlag(reqEvent.getSqzList(), reqEvent.getGzBj());
            if (!result)
                resEvent.setRepCode("error updating dlz read flag.");
        } else if ("getGetBackSQListByDlzDm".equals(dealMethod)) {
            resEvent.setSqzList(this.getGetBackSQListByDlzDm(reqEvent.getDlzDm()));
        } else if ("getSqzInfoBySqzDm".equals(dealMethod)) {
            resEvent.setSqzList(this.getSqzInfoBySqzDm(reqEvent.getSqzDm()));
        } else if ("getBackSQBySqzDm".equals(dealMethod)) {
            boolean result = this.getBackSQBySqzDm(reqEvent.getSqzDm());
            if (!result)
                resEvent.setRepCode("error get back wcsq.");
        }

        return resEvent;
    }

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

    public ArrayList getDepartmentMembers(String swryDm) {
        RWGLwcsqDAO wcsqDAO = new RWGLwcsqDAO();
        return (ArrayList) wcsqDAO.getDepartmentMembersBySwryDm(swryDm);
    }

    public ArrayList getSqzListByDlzDm(String dlzDm) {
        RWGLwcsqDAO wcsqDAO = new RWGLwcsqDAO();
        return (ArrayList) wcsqDAO.getSqzListByDlzDm(dlzDm);
    }

    public ArrayList getGetBackSQListByDlzDm(String dlzDm) {
        RWGLwcsqDAO wcsqDAO = new RWGLwcsqDAO();
        return (ArrayList) wcsqDAO.getGetBackSQListByDlzDm(dlzDm);
    }

    public ArrayList getSqzInfoBySqzDm(String sqzDm) {
        RWGLwcsqDAO wcsqDAO = new RWGLwcsqDAO();
        return (ArrayList) wcsqDAO.getSqzInfoBySqzDm(sqzDm);
    }

    public boolean addWcsq(String sqzDm, String dlzDm) throws
            TaxBaseBizException {
        RWGLwcsqDAO wcsqDAO = new RWGLwcsqDAO();
        QXGLswryDAO swryDAO = new QXGLswryDAO();
        String sqzMc, dlzMc;
        ArrayList swryList = null;

        // 獲取授權(quán)人名稱(chēng)
        swryList = (ArrayList) swryDAO.getSwryInfoByDm(sqzDm);
        if (swryList == null || swryList.size() == 0) {
            throw new TaxBaseBizException(SQZ_NOT_FOUND_EXCEPTION);
        }
        sqzMc = (String) ((QXGLswryVO)(swryList.get(0))).getMc();
        // 獲取代理者名稱(chēng)
        swryList = (ArrayList) swryDAO.getSwryInfoByDm(dlzDm);
        if (swryList == null || swryList.size() == 0) {
            throw new TaxBaseBizException(DLZ_NOT_FOUND_EXCEPTION);
        }
        dlzMc = (String) ((QXGLswryVO)(swryList.get(0))).getMc();

        wcsqDAO.setSqzDm(sqzDm);
        wcsqDAO.setDlzDm(dlzDm);
        wcsqDAO.setDlzMc(dlzMc + "（代" + sqzMc + "）");
        return wcsqDAO.addWcsq();
    }

    public boolean updateDlzReadFlag(ArrayList sqzList, String gzBj) {
        RWGLwcsqDAO wcsqDAO = new RWGLwcsqDAO();
        return wcsqDAO.updateDlzReadFlag(sqzList, gzBj);
    }

    public boolean getBackSQBySqzDm(String sqzDm) {
        RWGLwcsqDAO wcsqDAO = new RWGLwcsqDAO();
        return wcsqDAO.getBackSQBySqzDm(sqzDm);
    }
}