guangzhouyiselie/GDYSL/src/com/kingdee/eas/hr/affair/app/PluralityDelBizBillControllerBeanEx.java

package com.kingdee.eas.hr.affair.app;

import java.sql.Date;
import java.sql.SQLException;
import com.kingdee.bos.BOSException;
import com.kingdee.bos.Context;
import com.kingdee.bos.dao.IObjectPK;
import com.kingdee.bos.dao.IObjectValue;
import com.kingdee.bos.dao.ormapping.ObjectUuidPK;
import com.kingdee.eas.common.EASBizException;
import com.kingdee.eas.framework.CoreBaseCollection;
import com.kingdee.eas.framework.CoreBaseInfo;
import com.kingdee.eas.hr.affair.IPluralityAddBizBillEntry;
import com.kingdee.eas.hr.affair.IPluralityDelBizBill;
import com.kingdee.eas.hr.affair.PluralityAddBizBillEntryFactory;
import com.kingdee.eas.hr.affair.PluralityAddBizBillEntryInfo;
import com.kingdee.eas.hr.affair.PluralityDelBizBillEntryCollection;
import com.kingdee.eas.hr.affair.PluralityDelBizBillEntryInfo;
import com.kingdee.eas.hr.affair.PluralityDelBizBillFactory;
import com.kingdee.eas.hr.affair.PluralityDelBizBillInfo;
import com.kingdee.eas.hr.base.EmpPosOrgRelationFactory;
import com.kingdee.eas.hr.base.EmpPosOrgRelationInfo;
import com.kingdee.eas.hr.base.IEmpPosOrgRelation;
import com.kingdee.eas.util.app.DbUtil;
import com.kingdee.jdbc.rowset.IRowSet;
import com.kingdee.shr.compensation.CmpEmpORelationFactory;
import com.kingdee.shr.compensation.CmpEmpORelationInfo;
import com.kingdee.shr.compensation.ICmpEmpORelation;

/**
 * 扩展了PluralityDelBizBillControllerBean类，增加了在提交单据后的endDate更新逻辑。
 */
public class PluralityDelBizBillControllerBeanEx extends PluralityDelBizBillControllerBean {

    /**
     * 覆盖父类的_submitEffect方法，在提交单据后更新endDate。
     * @param ctx 上下文对象
     * @param model 单据模型
     * @return 单据主键
     * @throws BOSException 业务基础服务异常
     * @throws EASBizException EAS业务异常
     */
    @Override
    protected IObjectPK _submitEffect(Context ctx, CoreBaseInfo model) throws BOSException, EASBizException {
        // 调用父类的_submitEffect方法获取单据主键
        IObjectPK objectPk = super._submitEffect(ctx, model);
        // 更新endDate
        updateEndDate(ctx, model);
        return objectPk;
    }

    
    /**
     * 覆盖父类的_submit方法，在提交单据后更新endDate。
     * @param ctx 上下文对象
     * @param model 单据模型
     * @return 单据主键
     * @throws BOSException 业务基础服务异常
     * @throws EASBizException EAS业务异常
     */
    @Override
    protected IObjectPK _submit(Context ctx, IObjectValue model) throws BOSException, EASBizException {
        // 调用父类的_submit方法获取单据主键
        IObjectPK objectPk = super._submit(ctx, model);
        // 更新endDate
        updateEndDate(ctx, model);
        return objectPk;
    }

    /**
     * 更新单据中的endDate字段。
     * @param ctx 上下文对象
     * @param model 单据模型
     * @throws EASBizException EAS业务异常
     * @throws BOSException 业务基础服务异常
     */
    public void updateEndDate(Context ctx, IObjectValue model) throws EASBizException, BOSException {
        // 将模型转换为PluralityDelBizBillInfo类型
        PluralityDelBizBillInfo billInfo = (PluralityDelBizBillInfo) model;
        // 获取单据ID
        String billId = billInfo.getId().toString();
        // 获取单据条目集合
        PluralityDelBizBillEntryCollection entrys = billInfo.getEntrys();
        // 如果条目集合不为空且大小大于0，则遍历条目集合
        if (null != entrys && entrys.size() > 0) {
            for (int i = 0; i < entrys.size(); i++) {
                // 获取单据条目信息
                PluralityDelBizBillEntryInfo entryInfo = entrys.get(i);
                // 检查并更新添加单据的endDate
                checkAddBill(ctx, entryInfo.getId().toString(),1);
                //更新变更记录
                checkRelation(ctx,entryInfo.getId().toString(),null,1);

            }
        }
    }

    /**
     * 检查并更新添加单据的endDate。
     * @param ctx 上下文对象
     * @param entryId 单据条目ID
     * @param type  1:审核 ; 0:反审核
     * @throws BOSException 业务基础服务异常
     * @throws EASBizException EAS业务异常
     */
    private Date checkAddBill(Context ctx, String entryId, int type) throws BOSException, EASBizException {
//        // 创建删除单据条目集合
//        CoreBaseCollection delEnCol = new CoreBaseCollection();
        // 构建SQL查询语句
        StringBuilder sbu = new StringBuilder();
        sbu.append(" select  bill.fid addId  , entry.fid  addEnId ,entry.fendDate addEndDate  ");
        // SQL语句中重复的select关键字可能是错误，这里假设应该是逗号
        sbu.append(" ,entry.cfoldEndDate oldAddEDate  , delen.fbizDate  newEDate  ");
        sbu.append(" from T_HR_PluralityAddBizBill  bill ");
        sbu.append(" left join  T_HR_PluralityAddBizBillEntry  entry on bill.FId = entry.fbillid ");
        sbu.append(" left join  T_HR_PluralityDelBizBillEntry  delen   ");
        sbu.append(" on  entry.fpersonid = delen.fpersonid   ");
        
        sbu.append(" and  entry.FBizDate = delen.FBeginDate  ");
        sbu.append(" and  entry.fpositionid = delen.FOldPositionID  ");
        sbu.append(" and   (   ");
        sbu.append(" entry.cfpthwage = delen.cfpthwage   ");
        sbu.append(" OR  ( entry.cfpthwage IS NULL AND delen.cfpthwage IS NULL  ) ");
        sbu.append("  )   ");
        sbu.append(" and   (   ");
        sbu.append(" entry.cfptlmanagerid = delen.cfptlmanagerid   ");
        sbu.append(" OR  ( entry.cfptlmanagerid IS NULL AND delen.cfptlmanagerid IS NULL  ) ");
        sbu.append("  )   ");
        sbu.append(" where  bill.fbillstate = '3'  ");
        sbu.append(" and  delen.fid = '" + entryId + "'");
        //反审核
        if( type == 0 ) {
        	return restoreAddBillEndDate(ctx, sbu.toString());
        }else if( type == 1 ) {
            //审核
        	return updateAddBillEndDate(ctx, sbu.toString());
        }
        return null;
    }



    /**
     * 检查并更新变动记录的endDate。
     * @param ctx 上下文对象
     * @param entryId 单据条目ID
     * @param type  1:审核 ; 0:反审核
     * @throws BOSException 业务基础服务异常
     * @throws EASBizException EAS业务异常
     */
    private Date checkRelation(Context ctx, String entryId, Date newDate , int type) throws BOSException, EASBizException {
        // 构建SQL查询语句
        StringBuilder sbu = new StringBuilder();
        sbu.append(" select   bill.fid  billId   ");
        sbu.append(" , cmpBill.FID  cmpBillId  ");
        sbu.append(" , delen.fbizDate  newEDate  ");
        sbu.append(" from T_HR_EmpOrgRelation  bill ");
        sbu.append(" left join T_HR_SCmpEmpORelation  cmpBill ");
        sbu.append(" on  bill.FID = cmpBill.femporgrelationid   ");
        sbu.append(" left join  T_HR_PluralityDelBizBillEntry  delen   ");
        sbu.append(" on  bill.fpersonid = delen.fpersonid   ");
        
        sbu.append(" and  bill.feffdt = delen.FBeginDate  ");
        sbu.append(" and  bill.fpositionid = delen.FOldPositionID  ");
        sbu.append(" and   (   ");
        sbu.append(" bill.CFLineManagerNameI = delen.cfptlmanagerid   ");
        sbu.append(" OR  ( bill.CFLineManagerNameI IS NULL AND delen.cfptlmanagerid IS NULL  ) ");
        sbu.append("  )   ");
        sbu.append(" where    ");
        sbu.append(" delen.fid = '" + entryId + "'");
        //反审核
        if( type == 0 ) {
            return updateRelationEndDate(ctx, sbu.toString(),newDate,type);
        }else if( type == 1 ) {
            //审核
            return updateRelationEndDate(ctx, sbu.toString(),null,type);
        }
        return  null;
    }








    /**
     * 更新变动记录结束日期
     * @param ctx
     * @param sqlStr
     * @param newEDate
     * @param opType 0,反审核;  1,审核
     * @return
     */
    private  Date  updateRelationEndDate(Context ctx, String sqlStr,Date newEDate,int opType ) {
        // 创建添加单据条目集合
        CoreBaseCollection addEnCol = new CoreBaseCollection();
        try {
            // 获取添加单据条目实例
            IEmpPosOrgRelation  billIns = EmpPosOrgRelationFactory.getLocalInstance(ctx);
            ICmpEmpORelation cmpBillIns = CmpEmpORelationFactory.getLocalInstance(ctx);
            // 执行SQL查询
            IRowSet rowSet = DbUtil.executeQuery(ctx, sqlStr);
            // 遍历查询结果
            while (rowSet.next()) {
                // 获取添加单据条目ID
                String billId = rowSet.getString("billId");
                // 获取薪酬档案记录ID
                String cmpBillId = rowSet.getString("cmpBillId");
                // 获取新的endDate 审核的时候;
                if(opType ==  1){
                    newEDate = rowSet.getDate("newEDate");
                }
                // 变动记录
                EmpPosOrgRelationInfo billInfo = billIns.getEmpPosOrgRelationInfo(new ObjectUuidPK(billId));
                //薪酬 记录
                CmpEmpORelationInfo cmpInfo = cmpBillIns.getCmpEmpORelationInfo(new ObjectUuidPK(cmpBillId));
                if ( null != newEDate) {
                    //结束日期 = 单据创建时的结束日期
                    billInfo.setLEFFDT(newEDate);
                    billInfo.setEndDateTime(newEDate);
                    cmpInfo.setLeffectDate(newEDate);
                }
//                addEnCol.add(billInfo);
                billIns.update(new ObjectUuidPK(billId),billInfo);
                cmpBillIns.update(new ObjectUuidPK(cmpBillId),cmpInfo);
            }
            // 更新 集合
//            billIns.update(addEnCol);
        } catch (BOSException | SQLException | EASBizException e) {
            e.printStackTrace();
        }
        return newEDate;
    }





    
    private  Date  updateAddBillEndDate(Context ctx, String sqlStr) {
        Date newEDate = null;
        // 创建添加单据条目集合
        CoreBaseCollection addEnCol = new CoreBaseCollection();
    	try {
            // 获取添加单据条目实例
            IPluralityAddBizBillEntry addEnIns = PluralityAddBizBillEntryFactory.getLocalInstance(ctx);
            // 执行SQL查询
            IRowSet rowSet = DbUtil.executeQuery(ctx, sqlStr);
            // 遍历查询结果
            while (rowSet.next()) {
            	// 获取添加单据条目ID
            	String addEnId = rowSet.getString("addEnId");
            	// 获取 原兼职单上创建时的日期,第一次写兼职结束时是空的;
            	Date oldAddEDate = rowSet.getDate("oldAddEDate");
            	// 获取oldEDate
            	Date addEndDate = rowSet.getDate("addEndDate");
            	// 获取新的endDate
                newEDate = rowSet.getDate("newEDate");
            	// 如果添加单据条目ID为空，则进行更新操作
            	
            	// 获取兼职单据条目信息
            	PluralityAddBizBillEntryInfo addInfo = addEnIns.getPluralityAddBizBillEntryInfo(new ObjectUuidPK(addEnId));
            	if ( null == oldAddEDate) {
            		//原结束日期 = 单据创建时的结束日期
            		addInfo.put("oldEndDate", addEndDate);
            	}
            	// 设置更新前的endDate
            	addInfo.put("endDate", newEDate);
            	addEnCol.add(addInfo);
            }
         // 更新添加单据条目集合
            addEnIns.update(addEnCol);
        } catch (BOSException | SQLException | EASBizException e) {
            e.printStackTrace();
        }
        return newEDate;
        
    	
    }
    
    
    
    
    
    
    
    
    
    /**
     * 反审核后执行
     */
    @Override
    protected void _untiCheckBizBill(Context ctx, String billId) throws BOSException, EASBizException {
    	super._untiCheckBizBill(ctx, billId);
    	
    	IPluralityDelBizBill delIns = PluralityDelBizBillFactory.getLocalInstance(ctx);
    	PluralityDelBizBillInfo delInfo = delIns.getPluralityDelBizBillInfo(new ObjectUuidPK(billId));
    	PluralityDelBizBillEntryCollection entrys = delInfo.getEntrys();
    	for(int i = 0; i < entrys.size(); i++ ) {
    		PluralityDelBizBillEntryInfo entryInfo = entrys.get(i);
            //恢复兼职但上的结束日期
            Date newDate = checkAddBill(ctx, entryInfo.getId().toString(), 0);
            //更新变更记录
            checkRelation(ctx,entryInfo.getId().toString(),newDate,0);
    	}
    }
    
    
    
    
    /**
     * 反审核之后恢复原时间
     * @param ctx
     * @param sqlStr
     */
    private  Date  restoreAddBillEndDate(Context ctx, String sqlStr) {
        Date oldAddEDate = null;
        // 创建添加单据条目集合
        CoreBaseCollection addEnCol = new CoreBaseCollection();
    	try {
            // 获取添加单据条目实例
            IPluralityAddBizBillEntry addEnIns = PluralityAddBizBillEntryFactory.getLocalInstance(ctx);
            // 执行SQL查询
            IRowSet rowSet = DbUtil.executeQuery(ctx, sqlStr);
            // 遍历查询结果
            while (rowSet.next()) {
            	// 获取添加单据条目ID
            	String addEnId = rowSet.getString("addEnId");
            	// 获取 原兼职单上创建时的日期,第一次写兼职结束时是空的;
                oldAddEDate = rowSet.getDate("oldAddEDate");
            	// 获取兼职单据条目信息
            	PluralityAddBizBillEntryInfo addInfo = addEnIns.getPluralityAddBizBillEntryInfo(new ObjectUuidPK(addEnId));
            	if ( null != oldAddEDate) {
            		// 设置更新前的endDate
                	addInfo.put("endDate", oldAddEDate);
            	}
            	addEnCol.add(addInfo);
            }
         // 更新添加单据条目集合
            addEnIns.update(addEnCol);
        } catch (BOSException | SQLException | EASBizException e) {
            e.printStackTrace();
        }
        return oldAddEDate;
    	
    }
    
    
    
}