mingQuanJiTuan/src/com/kingdee/eas/custom/calcdailypay/task/AutoSubDayDetailFacadeControllerBean.java

package com.kingdee.eas.custom.calcdailypay.task;

import com.kingdee.bos.metadata.entity.*;
import com.kingdee.bos.metadata.query.util.CompareType;
import com.kingdee.bos.util.EASResource;
import com.kingdee.shr.base.syssetting.exception.SHRWebException;
import com.kingdee.shr.base.syssetting.exception.ShrWebBizException;
import com.kingdee.shr.compensation.app.integrate.*;
import com.kingdee.shr.compensation.app.utils.SubConstants;
import com.kingdee.shr.compensation.integrate.verify.CycleVerify;
import com.kingdee.shr.compensation.integrate.verify.ISubmitBillVerifyInterface;
import com.kingdee.shr.compensation.integrate.verify.SubmitBillDisableElementVerify;
import com.kingdee.shr.compensation.integrate.verify.SubmitBillEnableElementVerify;
import com.kingdee.shr.compensation.util.budget.BudgetUtil;
import com.google.common.collect.Maps;
import org.apache.log4j.Logger;
import com.kingdee.bos.*;
import com.kingdee.bos.dao.ormapping.ObjectUuidPK;

import java.sql.SQLException;
import java.time.LocalDate;
import java.time.format.DateTimeFormatter;
import java.util.Date;
import java.util.Map;

import com.kingdee.eas.common.EASBizException;
import com.kingdee.eas.framework.CoreBaseInfo;
import com.kingdee.eas.hr.base.HRBillStateEnum;
import com.kingdee.eas.util.app.DbUtil;
import com.kingdee.jdbc.rowset.IRowSet;


/**
 * 自动提交日提报单
 * @author coyle
 * 2025-05-25
 */
public class AutoSubDayDetailFacadeControllerBean extends AbstractAutoSubDayDetailFacadeControllerBean
{
    private static Logger logger =
        Logger.getLogger("com.kingdee.eas.custom.calcdailypay.task.AutoSubDayDetailFacadeControllerBean");




    /**
     *
     * @param ctx
     * @param preCalcDays 日期偏移量，正数表示向后推，负数表示向前推
     * @throws BOSException
     * @throws EASBizException
     */
    public void _autoSubDayDetail(Context ctx, int preCalcDays) throws BOSException, EASBizException {
        // 获取当前日期
        LocalDate currentDate = LocalDate.now();
        // 根据preCalcDays计算起始日期和结束日期
     
        LocalDate startDate = currentDate.minusDays( Math.abs(preCalcDays));
        LocalDate endDate = currentDate;

        // 如果preCalcDays是正数，调整startDate和endDate的顺序
//        if (preCalcDays > 0) {
//            LocalDate temp = startDate;
//            startDate = endDate;
//            endDate = temp;
//        }

        // 在日期范围内每天执行一次executeSubmit方法
        while (!startDate.isAfter(endDate)) {
            try {
				executeSubmit(ctx, startDate);
			} catch (SQLException e) {
				logger.error("日提报自动提交sql执行异常"+e);
				e.printStackTrace();
			}
            startDate = startDate.plusDays(1);
        }
    }

    private void executeSubmit(Context ctx, LocalDate date) throws BOSException, EASBizException, SQLException {
        // 这里是executeSubmit的具体实现
    	String field1 = "S64";
		CalSubmitItemCollection subColl = CalSubmitItemFactory.getLocalInstance(ctx)
				.getCalSubmitItemCollection("SELECT ID,FieldSn,number  where  number = '"+SubConstants.COMRATE+"'");
		if(subColl.size()>0) {
			CalSubmitItemInfo calSubmitItemInfo = subColl.get(0);
			int fieldSn = calSubmitItemInfo.getFieldSn();
			field1 = "S"+fieldSn ;
		}else{
			field1 = "S64";
			logger.error("查询薪酬项目编码,没有找到"+SubConstants.COMRATE+"字段数据");
		}
        // 假设你需要将日期格式化为特定格式
        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");
        String formattedDate = date.format(formatter);
        //业务逻辑
		IBatchSubmitShemeBill billIns = BatchSubmitShemeBillFactory.getLocalInstance(ctx);
        FilterInfo filter = new FilterInfo();
        filter.getFilterItems().add(new FilterItemInfo("billState", HRBillStateEnum.SAVED_VALUE, CompareType.EQUALS));
        
        //提报方案时日提报的;
        filter.getFilterItems().add(new FilterItemInfo("submitScheme.submitSchemeType", SubmitSchemeType.TIMEPIECE_VALUE, CompareType.EQUALS));
        filter.getFilterItems().add(new FilterItemInfo("applyDate",  formattedDate , CompareType.LESS_EQUALS));
        filter.getFilterItems().add(new FilterItemInfo("applyDate",  formattedDate , CompareType.GREATER_EQUALS  ));

        EntityViewInfo viewInfo = new EntityViewInfo();
        viewInfo.setFilter(filter);
        try {
        	BatchSubmitShemeBillCollection batchSubmitShemeBillCollection = billIns.getBatchSubmitShemeBillCollection(viewInfo);
        	if (!batchSubmitShemeBillCollection.isEmpty()) {
        		for (int i = 0; i < batchSubmitShemeBillCollection.size(); ++i) {
        			BatchSubmitShemeBillInfo model = batchSubmitShemeBillCollection.get(i);
//        			BatchSubmitShemeBillControllerBeanEx batchSubmitShemeBillControllerBeanEx = new BatchSubmitShemeBillControllerBeanEx();
//        			batchSubmitShemeBillControllerBeanEx._save(ctx,model);
        			billIns.save(new ObjectUuidPK(model.getId()),model);
        			String checkSql = "SELECT "+field1 +"  FROM  T_HR_TimepieceBillEntry  WHERE  FBillID  = '"+model.getId().toString()+"'   ";
        			IRowSet executeQuery = DbUtil.executeQuery(ctx, checkSql);
					boolean isOk = true;
        			while(executeQuery.next()) {
        				String value = executeQuery.getString(field1);
						if(value == null ) {
							logger.error("日提报单"+model.getNumber()+"的"+field1+"字段值为空，无法提交");
							isOk = false;
							break;
						}
        			}
					if(!isOk) {
						continue;
					}
					beforeSubmit(ctx, model);
					billIns.submitEffect(model);
        		}
        	}
        } catch (SHRWebException e) {
        	logger.error(e);
        }
    }
    

    
    ////////////DefaultSubmitShemeBillListHandler_beforeSubmit////////////
    protected void beforeSubmit( Context ctx,CoreBaseInfo model)
    		throws SHRWebException {
    	BatchSubmitShemeBillInfo info = (BatchSubmitShemeBillInfo) model;
    	this.reAssembleModel(ctx, info);
    	this.verifyIsBillEntryEmpty(ctx, info);
    	
    	try {
    		ISubmitBillVerifyInterface verifyInstance = this.getVerifyInstance(ctx, info);
    		verifyInstance.verify(ctx, info, this.getVerifyParams());
    		BudgetUtil.verifyBudget(ctx, info);

    		model.setInt("billState", 1);
    	} catch (BOSException var8) {
    		throw new SHRWebException(var8.getMessage(), var8);
    	} catch (EASBizException var9) {
    		throw new ShrWebBizException(var9.getMessage(), var9);
    	}
    	
    	try {
    		this.udpSubmitTime(ctx, info.getId().toString());
    	} catch (BOSException var7) {
    		throw new SHRWebException(var7.getMessage(), var7);
    	}
    }
    
    protected void reAssembleModel(Context ctx, BatchSubmitShemeBillInfo model) throws SHRWebException {
    	String oql = "select *, entry.*,submitScheme.id,entry.submitElement.name,entry.person.name,entry.person.number where id = '%s'";
		try {
			BatchSubmitShemeBillInfo info = BatchSubmitShemeBillFactory.getLocalInstance(ctx).getBatchSubmitShemeBillInfo(String.format(oql, model.getId().toString()));
			model.clear();
	    	model.putAll(info);
		} catch (EASBizException e) {
			e.printStackTrace();
		} catch (BOSException e) {
			e.printStackTrace();
		}
    
    }
    
    
    protected void verifyIsBillEntryEmpty(Context ctx, BatchSubmitShemeBillInfo info) throws SHRWebException {
    	if (info.getEntry() == null || info.getEntry().isEmpty()) {
    		throw new ShrWebBizException(EASResource.getString(
    				"com.kingdee.shr.compensation.resource.SubmitShemeBillResource", "label19", ctx.getLocale()));
    	}
    }
    
    
    protected ISubmitBillVerifyInterface getVerifyInstance(Context ctx, BatchSubmitShemeBillInfo info)
    		throws SHRWebException {
    	if (null == info) {
    		throw new ShrWebBizException("model can not be null.");
    	} else {
    		try {
    			CalSubmitSchemeInfo calSubmitSchemeInfo = CalSubmitSchemeFactory.getLocalInstance(ctx)
    					.getCalSubmitSchemeInfo(new ObjectUuidPK(info.getSubmitScheme().getId().toString()));
    			ISubmitBillVerifyInterface instance = this
    					.createVerifyInstance(calSubmitSchemeInfo.isIsEnableSubmitElement());
    			if (calSubmitSchemeInfo.isIscycle()) {
    				instance = new CycleVerify((ISubmitBillVerifyInterface) instance);
    			}
    			
    			return (ISubmitBillVerifyInterface) instance;
    		} catch (EASBizException var5) {
    			throw new ShrWebBizException(var5.getMessage(), var5);
    		} catch (BOSException var6) {
    			throw new SHRWebException(var6.getMessage(), var6);
    		}
    	}
    }
    
    protected ISubmitBillVerifyInterface createVerifyInstance(boolean isEnableSubmitElement) {
    	return (ISubmitBillVerifyInterface) (isEnableSubmitElement
    			? new SubmitBillEnableElementVerify()
    					: new SubmitBillDisableElementVerify());
    }
    
    
    protected Map<String, Object> getVerifyParams() {
    	return Maps.newHashMap();
    }
    
    
    
//  protected void udpSubmitTime(Context ctx, String billId) throws BOSException {
//		String sql = "update T_HR_SBatchSubmitShemeBill set FSubmitTime = ? where FID = ?";
//		Object[] param = new Object[]{new Date((new Date()).getTime()), billId};
//		DbUtil.execute(ctx, sql, param);
//	}

	protected void udpSubmitTime(Context ctx, String billId) throws BOSException {
		String sql = "update T_HR_SBatchSubmitShemeBill set FSubmitTime = ? where FID = ?";
		// 使用java.sql.Timestamp替代java.util.Date
		Object[] param = new Object[]{new java.sql.Timestamp(System.currentTimeMillis()), billId};
		DbUtil.execute(ctx, sql, param);
	}


}