SHR88
/
guangzhouyiselie


			
				
					
						
						
							123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164
							package com.kingdee.eas.custom.facade.worktime;
import java.io.BufferedInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;  

import java.io.InputStream;  

import java.net.URL;
import java.net.URLConnection;

import org.apache.log4j.Logger;
import javax.ejb.*;
import java.nio.charset.StandardCharsets;  
import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.rmi.RemoteException;
import java.sql.SQLException;
import java.util.HashSet;
import java.util.Set;

import com.kingdee.bos.*;
import com.kingdee.bos.util.BOSObjectType;
import com.kingdee.eas.base.param.IParamControl;
import com.kingdee.eas.base.param.ParamControlFactory;
import com.kingdee.eas.common.EASBizException;
import com.kingdee.eas.custom.utils.SendUtils;
import com.kingdee.eas.mobile.BOSMsgTypeEnum;
import com.kingdee.eas.mobile.MimeTypeEnum;
import com.kingdee.eas.mobile.PriorityEnum;
import com.kingdee.eas.mobile.msg.util.MsgUtil;
import com.kingdee.eas.util.app.DbUtil;
import com.kingdee.jdbc.rowset.IRowSet;
import com.kingdee.shr.base.syssetting.context.SHRContext;
import com.kingdee.bos.metadata.IMetaDataPK;
import com.kingdee.bos.metadata.rule.RuleExecutor;
import com.kingdee.bos.metadata.MetaDataPK;
//import com.kingdee.bos.metadata.entity.EntityViewInfo;
import com.kingdee.bos.framework.ejb.AbstractEntityControllerBean;
import com.kingdee.bos.message.common.KDMemAttachment;
import com.kingdee.bos.message.common.KDMessageAttachment;
import com.kingdee.bos.framework.ejb.AbstractBizControllerBean;
//import com.kingdee.bos.dao.IObjectPK;
import com.kingdee.bos.dao.IObjectValue;
import com.kingdee.bos.dao.IObjectCollection;
import com.kingdee.bos.service.ServiceContext;
import com.kingdee.bos.service.IServiceContext;
import java.util.Base64;  
/**
 * 除转正、加班、提报单以外，其他单据到审批人节点时间（按天）算起，超过两天未审批则提醒当前审批人
 * 
 * @author ISSUSER
 *
 */
public class RemindFacadeControllerBean extends AbstractRemindFacadeControllerBean {

	private static Logger logger = Logger
			.getLogger("com.kingdee.eas.custom.facade.worktime.RemindFacadeControllerBean");

	@Override
	public void _remindWraning(Context ctx) throws BOSException {
		Set<String> appovedSet = new HashSet();
		try {
			IRowSet appovedRowSet = getAppoved(ctx);
			// 获取链接
			IParamControl ipc = ParamControlFactory.getLocalInstance(ctx);
			String shrEnvironmentIP = ipc.getParamValue(null, "shrEnvironmentIP");
			String website = shrEnvironmentIP + "/home.do";
			while (appovedRowSet.next()) {
				// 获取审批人
				String personempId = appovedRowSet.getString("FPERSONEMPID");
				String title = "Reminder: Pending approval workflow";
				//
				if (!appovedSet.contains(personempId)) {
					// 拼接内容
					StringBuffer conteBuffer = new StringBuffer();
					conteBuffer.append("<html><head></head><body>");
					
					conteBuffer.append("<span>Dear " + appovedRowSet.getString("FPERSONEMPNAME_L1") + ":</span><br>");
					conteBuffer.append("<span></span><br>");
					conteBuffer.append(
							"<span>A kind reminder to tasks pending your approval. Please log in to the system to view details in To-Be-Processed in My Tasks and act on pending approval tasks at your earliest convenience.</span><br>");
					conteBuffer.append("<span></span><br>");
					conteBuffer.append("<span><a href=\"" + website + "\">" + website + "</a></span><br>");
					conteBuffer.append("<span></span><br>");
					conteBuffer
							.append("<span>This is an automatic workflow email. Do not reply to this mail.</span><br>");
					conteBuffer.append("<span></span><br>");
					conteBuffer.append("<span>Best regards,</span><br>");
					conteBuffer.append("<span>Human Resources Department</span>");
					conteBuffer.append("</body></html>");
//
					SendUtils.msgSend(ctx, title, PriorityEnum.HIGHT_VALUE, false, conteBuffer.toString(),
							appovedRowSet.getString("FPERSONEMPID"), BOSMsgTypeEnum.V_TYPE_EMAIL, null, null,
							MimeTypeEnum.HTML);
//					SendUtils.msgSend(ctx, title, PriorityEnum.HIGHT_VALUE, false, conteBuffer.toString(),
//							"1CV1Xix+Qua9UEeo/uZ6TIDvfe0=", BOSMsgTypeEnum.V_TYPE_EMAIL, null, null,
//							MimeTypeEnum.HTML);
					appovedSet.add(personempId);
				}
			}
		} catch (SQLException e) {
			e.printStackTrace();
		} catch (EASBizException e) {
			e.printStackTrace();
		}

	}

	/***
	 * 查询除转正、加班、提报单以外，其他单据到审批人节点时间（按天）算起，超过两天未审批 的审批人
	 * @param ctx
	 * @return
	 */
	public IRowSet getAppoved(Context ctx) {
	

		String sql = "SELECT a.* FROM T_WFR_Assign a left join T_BAS_AssignRead b on a.FASSIGNID=b.FASSIGNID where b.FBosType  not in('C46A580E','B11DBA5C','B65CCEF1') and  DATEDIFF(day,a.flaststatetime,  GETDATE()) > 2 ;";
		IRowSet rs = null;
		try {
			rs = DbUtil.executeQuery(ctx, sql);
		} catch (BOSException e) {
			// TODO 自动生成的 catch 块
			e.printStackTrace();
		}

		return rs;

	}

//	 // 拼接的内容
//	 public  KDMemAttachment[] getContent() {
//		 String imageFilePath = "http://119.3.222.91:6888/shr/leaveTemplate/Image_20240118150510.png";
//         KDMemAttachment[] kdments=new KDMemAttachment[1];
//		// 读取图片文件  
//         try {
//        	// 读取本地图片文件  
//             File imageFile = new File("D:/rz/cs.png");  
//             byte[] imageData = new byte[(int) imageFile.length()];  
//             FileInputStream fis = new FileInputStream(imageFile);  
//             BufferedInputStream bis = new BufferedInputStream(fis);  
//             bis.read(imageData, 0, imageData.length);  
//             bis.close();  
//             fis.close();;  
//
//             KDMemAttachment attachment = new KDMemAttachment();
//             attachment.setName("example_image"); // 设置附件名称  
//             attachment.setSize(imageData.length); // 设置附件大小  
//             attachment.setData(imageData); // 设置附件数据   
//
//            kdments[0] = attachment;
//            
//		} catch (IOException e) {
//			// TODO 自动生成的 catch 块
//			e.printStackTrace();
//		}  
//	
//	   return kdments;
//	
//	 }

}