lyggkj/gkaq/yjpt-java/trunk/java_src/com/jtgh/yjpt/common/Utils.java

package com.jtgh.yjpt.common;

import java.awt.Color;
import java.awt.Font;
import java.awt.Graphics2D;
import java.awt.Image;
import java.awt.image.BufferedImage;
import java.io.ByteArrayOutputStream;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.PrintWriter;
import java.io.StringWriter;
import java.lang.reflect.Field;
import java.lang.reflect.Modifier;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Locale;
import java.util.ResourceBundle;

import javax.imageio.ImageIO;
import javax.persistence.criteria.CriteriaBuilder;
import javax.persistence.criteria.CriteriaQuery;
import javax.persistence.criteria.Predicate;
import javax.persistence.criteria.Root;
import javax.persistence.criteria.Subquery;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpSession;

import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.support.rowset.SqlRowSet;
import org.springframework.stereotype.Component;
import org.springframework.util.StringUtils;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;

import sun.misc.BASE64Decoder;
import sun.misc.BASE64Encoder;

import com.jtgh.qlyg.entity.ApplyFormItem;
import com.jtgh.yjpt.common.servlet.InitServlet;
import com.jtgh.yjpt.entity.BaseEntity;
import com.jtgh.yjpt.entity.auth.UserEntity;
import com.jtgh.yjpt.entity.common.AccessoryEntity;
import com.jtgh.yjpt.entity.common.CodeEntity;
import com.jtgh.yjpt.entity.common.TaskInfoEntity;
import com.jtgh.yjpt.entity.qlyg.ApplyEntity;
import com.jtgh.yjpt.entity.qlyg.ApplyProcessEntity;
import com.jtgh.yjpt.entity.zysqbp.ZysqbpEntity;
import com.jtgh.yjpt.webService.common.AuthHandler;
import com.swetake.util.Qrcode;

import flex.messaging.FlexContext;

/**
 * 系统静态工具方法类。
 */
@Component
public abstract class Utils {

	/**
	 * 比较密码是否一致
	 * 
	 * @param pwd
	 * @param md5Pwd
	 * @return
	 */
	public static boolean pwdEquals(String pwd, String md5Pwd) {
		if (pwd == null || md5Pwd == null)
			return false;
		return md5Pwd.equals(encrypt(pwd));
	}

	/**
	 * 返回MD5加密后的密码
	 * 
	 * @param pwd
	 * @return
	 */
	public static String encrypt(String password) {
		String str = "";
		try {
			MessageDigest md = MessageDigest.getInstance("MD5");
			md.update(password.getBytes());
			byte b[] = md.digest();
			int i;
			StringBuffer buf = new StringBuffer("");
			for (int offset = 0; offset < b.length; offset++) {
				i = b[offset];
				if (i < 0)
					i += 256;
				if (i < 16)
					buf.append("0");
				buf.append(Integer.toHexString(i));
			}
			str = buf.toString();
		} catch (NoSuchAlgorithmException e) {
			e.printStackTrace();
		}
		return str;
	}

	/**
	 * 二进制流解析为字符串
	 * 
	 * @param content
	 * @return
	 */
	public static String encodeBase64(byte[] content) {
		BASE64Encoder encoder = new BASE64Encoder();
		return encoder.encode(content);
	}

	/**
	 * 字符串解析为二进制流
	 * 
	 * @param content
	 * @return
	 */
	public static byte[] decodeBase64(String content) {
		BASE64Decoder decoder = new BASE64Decoder();
		try {
			return decoder.decodeBuffer(content);
		} catch (IOException e) {
			e.printStackTrace();
		}
		return null;
	}

	/**
	 * 获取资源文件
	 * 
	 * @param bundle
	 *            包名
	 * @param key
	 * @return
	 */
	public static String getResource(String bundle, String key) {
		ResourceBundle resource = ResourceBundle.getBundle(Locale.getDefault()
				.toString() + "/" + bundle, Locale.getDefault(),
				Utils.class.getClassLoader());
		if (resource.containsKey(key))
			return resource.getString(key);
		return key;
	}

	/**
	 * 服务器端判断客户端浏览器类型(IE/FF/SF)
	 * 
	 * @param request
	 * @return
	 */
	public static String getBrowser(HttpServletRequest request) {
		String UserAgent = request.getHeader("USER-AGENT").toLowerCase();
		if (UserAgent != null) {
			if (UserAgent.indexOf("msie") >= 0)
				return "IE";
			if (UserAgent.indexOf("firefox") >= 0)
				return "FF";
			if (UserAgent.indexOf("safari") >= 0)
				return "SF";
		}
		return null;
	}

	/**
	 * 根据开始日期和时间段，得到到期日
	 * 
	 * @param startDate
	 * @param during
	 * @param type
	 *            承诺时限单位（0天/1工作日/2月/3年）
	 * @return
	 */
	public static Date getDueDate(Date startDate, Integer during, String type) {
		if (startDate == null)
			return null;
		JdbcTemplate jdbcTemplate = (JdbcTemplate) ApplicationContextHelper
				.getBean(JdbcTemplate.class);
		if (during == null)
			during = 0;
		Calendar c = Calendar.getInstance();
		c.setTime(startDate);
		if (Constants.QLYG_APPLY_PROMISE_TYPE_DAY.equals(type)) {
			// 按天计算
			c.add(Calendar.DATE, during);
		} else if (Constants.QLYG_APPLY_PROMISE_TYPE_WORKING_DAY.equals(type)) {
			// 按工作日计算
			String sql = "SELECT 1 FROM T_YJPT_WORKING_CALENDAR WHERE WORKING_DATE=? AND IS_WORKING=?";
			SimpleDateFormat sf = new SimpleDateFormat("yyyyMMdd");
			while (during > 0) {
				String date = sf.format(c.getTime());
				if (c.get(Calendar.DAY_OF_WEEK) == Calendar.SATURDAY
						|| c.get(Calendar.DAY_OF_WEEK) == Calendar.SUNDAY) {
					SqlRowSet rs = jdbcTemplate.queryForRowSet(sql, date,
							Constants.YES);
					if (rs.next()) {
						during--;
					}
					c.add(Calendar.DATE, 1);
				} else {
					SqlRowSet rs = jdbcTemplate.queryForRowSet(sql, date,
							Constants.NO);
					if (!rs.next()) {
						during--;
					}
					c.add(Calendar.DATE, 1);
				}
			}
		} else if (Constants.QLYG_APPLY_PROMISE_TYPE_MONTH.equals(type)) {
			// 按月计算
			c.add(Calendar.MONTH, during);
		} else if (Constants.QLYG_APPLY_PROMISE_TYPE_YEAR.equals(type)) {
			// 按年计算
			c.add(Calendar.YEAR, during);
		}
		return c.getTime();
	}

	/**
	 * 根据开始日期和时间段，得到预警日期4/5
	 * 
	 * @param startDate
	 * @param during
	 * @param type
	 *            承诺时限单位（0天/1工作日/2月/3年）
	 * @return
	 */
	public static Date getWarnDate(Date startDate, Integer during, String type) {
		if (startDate == null)
			return null;
		if (during == null)
			during = 0;
		during = BigDecimal.valueOf(during * 0.8)
				.setScale(0, RoundingMode.CEILING).intValue();
		return getDueDate(startDate, during, type);
	}

	/**
	 * 根据配置文件设置办件信息
	 * 
	 * @param entity
	 * @param processKey
	 */
	public static void setApplyProperties(ApplyEntity entity, String processKey) {
		HashMap<String, Object> applyMap = GlobalData.qlygApplyMap
				.get(processKey);
		if (applyMap == null)
			return;
		Iterator<String> it = applyMap.keySet().iterator();
		while (it.hasNext()) {
			String key = it.next();
			try {
				ApplyEntity.class.getMethod(
						"set" + key.toUpperCase().substring(0, 1)
								+ key.substring(1),
						applyMap.get(key).getClass()).invoke(entity,
						applyMap.get(key));
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
		String orgId = Utils.getCurrentUser().getSzd().getByzd4();
		// 部门编码
		entity.setOrgId(orgId + "JT");
		// 权力编码前面10位的部门编号是所在地的备用字段4
		if (!StringUtils.isEmpty(entity.getItemId())) {
			entity.setItemId(orgId + "JT-" + entity.getItemId());
		}
		// 办理处室使用所在地的备用字段5
		entity.setDepartment(getCurrentUser().getSzd().getByzd5());
	}

	/**
	 * 根据配置文件设置办件过程信息
	 * 
	 * @param entity
	 * @param processKey
	 */
	public static void setApplyItemProperties(ApplyProcessEntity entity,
			String processKey, String taskKey) {
		HashMap<String, HashMap<String, Object>> applyMap = GlobalData.qlygApplyItemMap
				.get(processKey);
		if (applyMap == null)
			return;
		HashMap<String, Object> applyItemMap = applyMap.get(taskKey);
		if (applyItemMap == null)
			return;
		Iterator<String> it = applyItemMap.keySet().iterator();
		while (it.hasNext()) {
			String key = it.next();
			try {
				ApplyProcessEntity.class.getMethod(
						"set" + key.toUpperCase().substring(0, 1)
								+ key.substring(1),
						applyItemMap.get(key).getClass()).invoke(entity,
						applyItemMap.get(key));
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
	}

	/**
	 * 根据配置文件生成办件基本信息form
	 * 
	 * @param entity
	 * @param processKey
	 * @return
	 */
	public static String getApplyForm(BaseEntity<?> entity, String processKey) {
		StringBuffer sb = new StringBuffer();
		sb.append("<?XML VERSION=\"1.0\" ENCODING=\"GBK\"?><FORMDATA>");
		if (processKey != null
				&& GlobalData.qlygApplyFormMap.get(processKey) != null) {
			List<ApplyFormItem> list = (List<ApplyFormItem>) GlobalData.qlygApplyFormMap
					.get(processKey);
			if (list != null && list.size() > 0) {
				for (ApplyFormItem formItem : list) {
					sb.append("<DATA>");
					sb.append("<KEY>");
					sb.append(formItem.getKey());
					sb.append("</KEY>");
					sb.append("<NAME>");
					sb.append(formItem.getName());
					sb.append("</NAME>");
					sb.append("<VALUE>");
					try {
						if (formItem.getId() != null) {
							Object parentObj = entity;
							String[] props = formItem.getId().split("\\.");
							for (String prop : props) {
								Object obj = parentObj
										.getClass()
										.getMethod(
												"get"
														+ prop.toUpperCase()
																.substring(0, 1)
														+ prop.substring(1))
										.invoke(parentObj);
								parentObj = obj;
								if (parentObj == null) {
									break;
								}
							}
							if (parentObj == null) {
								// 空值
							} else if ("date".equals(formItem.getType())) {
								Date d = (Date) parentObj;
								sb.append(new SimpleDateFormat(
										"yyyy-MM-dd HH:mm:ss").format(d));
							} else {
								if (!StringUtils.isEmpty(formItem.getLocale())) {
									sb.append(getResource(formItem.getLocale(),
											parentObj.toString()));
								} else {
									sb.append(parentObj.toString());
								}
							}
						}
					} catch (Exception e) {
						e.printStackTrace();
					}
					sb.append("</VALUE>");
					sb.append("</DATA>");
				}
			}
		}
		sb.append("</FORMDATA>");
		return sb.toString();
	}

	/**
	 * 设置对象属性
	 * 
	 * @param obj
	 * @param params
	 * @param name
	 * @param clazz
	 */
	public static void setField(Object obj, Object params, String name,
			Class<?> clazz) {
		try {
			Field fld = clazz.getDeclaredField(name);
			int mod = fld.getModifiers();
			if (null == obj && Modifier.isStatic(mod)) {
				if (!Modifier.isFinal(mod)) {
					if (!fld.isAccessible())
						fld.setAccessible(true);
					fld.set(null, params);
				}
			} else {
				if (!fld.isAccessible())
					fld.setAccessible(true);
				fld.set(obj, params);
			}
		} catch (SecurityException e) {
			e.printStackTrace();
		} catch (NoSuchFieldException e) {
			e.printStackTrace();
		} catch (IllegalArgumentException e) {
			e.printStackTrace();
		} catch (IllegalAccessException e) {
			e.printStackTrace();
		}
	}

	/**
	 * 获取session
	 * 
	 * @return
	 */
	public static HttpSession getSession() {
		if (FlexContext.getHttpRequest() != null) {
			HttpSession session = FlexContext.getHttpRequest().getSession();
			// System.out.println("Flex session id:" + session.getId());
			// flex客户端取session
			return session;
		}
		if (RequestContextHolder.getRequestAttributes() != null) {
			HttpSession session = ((ServletRequestAttributes) RequestContextHolder
					.getRequestAttributes()).getRequest().getSession();
			// System.out.println("Http session id:" + session.getId());
			return session;
		}
		return null;
	}

	public static Long JunitUserId = 1l;

	/**
	 * 获取当前登录人
	 * 
	 * @return
	 */
	public static UserEntity getCurrentUser() {
		if (GlobalData.isJunit) {
			UserEntity testUser = new UserEntity();
			testUser.setId(JunitUserId);
			testUser.setCode("user_junit");
			testUser.setName("junit用户");
			return testUser;
		}
		HttpSession session = getSession();
		if (session == null) {
			if (AuthHandler.getCurrentUser() != null) {
				return AuthHandler.getCurrentUser();
			}
			return null;
		}
		Object user = session.getAttribute(GlobalData.USER_SESSION_KEY);
		return (UserEntity) user;
	}

	/**
	 * WebService登录用户
	 * 
	 * @return
	 */
	public static UserEntity getWebServiceUser() {
		if (AuthHandler.getCurrentUser() != null) {
			return AuthHandler.getCurrentUser();
		}
		return null;
	}

	/**
	 * 获取当前登录人姓名
	 * 
	 * @return
	 */
	public static String getCurrentUserCode() {
		HttpSession session = getSession();
		if (session != null) {
			Object user = session.getAttribute(GlobalData.USER_SESSION_KEY);
			if (user != null)
				return ((UserEntity) user).getCode();
		}
		return "";
	}

	/**
	 * 获取当前登录人姓名
	 * 
	 * @return
	 */
	public static String getCurrentUserName() {
		HttpSession session = getSession();
		if (session != null) {
			Object user = session.getAttribute(GlobalData.USER_SESSION_KEY);
			if (user != null)
				return ((UserEntity) user).getName();
		}
		return "";
	}

	/**
	 * 根据所属区域代码获得webservice的ip
	 * 
	 * @param ssqyId
	 * @return
	 */
	public static String getWsIpBySsqy(Long ssqyId) {
		if (ssqyId == null)
			return "";
		String wsIp = "";
		if (InitServlet.groupcodeMap.get(Constants.GROUP_CODE_SZD_WS_IP) != null) {
			List<CodeEntity> ips = InitServlet.groupcodeMap
					.get(Constants.GROUP_CODE_SZD_WS_IP);
			for (CodeEntity ip : ips) {
				if (ip.getParent() != null
						&& ssqyId.toString().indexOf(
								ip.getParent().getId().toString()) == 0) {
					wsIp = ip.getCode();
					break;
				}
			}
		}
		return wsIp;
	}

	/**
	 * 根据所属区域代码获得webservice的port
	 * 
	 * @param ssqyId
	 * @return
	 */
	public static String getWsPortBySsqy(Long ssqyId) {
		if (ssqyId == null)
			return "";
		String wsPort = "";
		if (InitServlet.groupcodeMap.get(Constants.GROUP_CODE_SZD_WS_PORT) != null) {
			List<CodeEntity> ports = InitServlet.groupcodeMap
					.get(Constants.GROUP_CODE_SZD_WS_PORT);
			for (CodeEntity port : ports) {
				if (port.getParent() != null
						&& ssqyId.toString().indexOf(
								port.getParent().getId().toString()) == 0) {
					wsPort = port.getCode();
					break;
				}
			}
		}
		return wsPort;
	}

	/**
	 * 返回当前角色的上级角色
	 * 
	 * @param currRole
	 * @return
	 */
	public static String getParentRole(String currRole) {
		if (StringUtils.isEmpty(currRole)
				|| currRole.length() <= Constants.ROLE_LENGTH) {
			return "";
		}
		return currRole.substring(0, currRole.length() - Constants.ROLE_LENGTH);
	}

	public static List<Predicate> setWorkflowSpec(List<Predicate> list,
			CriteriaBuilder cb, CriteriaQuery<?> query,
			Root<? extends BaseEntity<?>> root, String lcStatus) {
		// 根据流程状态过滤
		if (null != lcStatus && !"".equals(lcStatus)) {
			if (String.valueOf(BaseEntity.RECORD_STATE_VALID).equals(lcStatus)
					|| String.valueOf(BaseEntity.RECORD_STATE_COMPLETED)
							.equals(lcStatus)) {
				list.add(cb.equal(root.get("recordStatus").as(String.class),
						lcStatus));
			} else {
				Subquery<TaskInfoEntity> subquery = query
						.subquery(TaskInfoEntity.class);
				Root<TaskInfoEntity> taskRoot = subquery
						.from(TaskInfoEntity.class);
				subquery.select(taskRoot);
				List<Predicate> subQueryPredicates = new ArrayList<Predicate>();
				subQueryPredicates.add(cb.equal(
						root.get("id").as(String.class), taskRoot.get("busId")
								.as(String.class)));
				subQueryPredicates.add(cb.equal(
						taskRoot.get("currName").as(String.class), lcStatus));
				subQueryPredicates.add(cb.notEqual(
						taskRoot.get("state").as(Long.class),
						BaseEntity.RECORD_STATE_COMPLETED));
				// List<Predicate> subOrList = new
				// ArrayList<Predicate>();
				// subOrList.add(cb.equal(taskRoot
				// .get("roleCode").as(String.class),
				// getCurrentRoleCode(functionId)));
				// subOrList.add(cb.equal(taskRoot
				// .get("runner").as(UserEntity.class),
				// Utils.getCurrentUser()));
				// subQueryPredicates.add(cb.or(subOrList.toArray(new
				// Predicate[] {})));
				subquery.where(subQueryPredicates.toArray(new Predicate[] {}));
				list.add(cb.exists(subquery));
			}
		}
		return list;
	}
	
	public static List<Predicate> setAuditNameSpec(List<Predicate> list,
			CriteriaBuilder cb, CriteriaQuery<?> query,
			Root<? extends BaseEntity<?>> root, String lcStatus, String name) {
		if(null != name && !"".equals(name)) {
			Subquery<TaskInfoEntity> subquery = query
					.subquery(TaskInfoEntity.class);
			Root<TaskInfoEntity> taskRoot = subquery.from(TaskInfoEntity.class);
			subquery.select(taskRoot);
			List<Predicate> subQueryPredicates = new ArrayList<Predicate>();
			subQueryPredicates.add(cb.equal(root.get("id").as(String.class),
					taskRoot.get("busId").as(String.class)));
			subQueryPredicates.add(cb.or(new Predicate[] {
					cb.equal(taskRoot.get("busKey").as(String.class),
							ZysqbpEntity.AUTO_PROCESS_DEFINITION_KEY),
					cb.equal(taskRoot.get("busKey").as(String.class),
							ZysqbpEntity.PROCESS_DEFINITION_KEY) }));
			subQueryPredicates.add(cb.like(
					taskRoot.get("auditUsername").as(String.class), "%" + name
							+ "%"));
			if (null != lcStatus && !"".equals(lcStatus)) {
				if (String.valueOf(BaseEntity.RECORD_STATE_VALID).equals(
						lcStatus)
						|| String.valueOf(BaseEntity.RECORD_STATE_COMPLETED)
								.equals(lcStatus)) {
					list.add(cb
							.equal(root.get("recordStatus").as(String.class),
									lcStatus));
				} else {
					subQueryPredicates.add(cb.notEqual(
							taskRoot.get("state").as(Long.class),
							BaseEntity.RECORD_STATE_COMPLETED));
				}
			}
			subquery.where(subQueryPredicates.toArray(new Predicate[] {}));			
			list.add(cb.exists(subquery));
		} else {
			// 根据流程状态过滤
			if (null != lcStatus && !"".equals(lcStatus)) {
				if (String.valueOf(BaseEntity.RECORD_STATE_VALID).equals(lcStatus)
						|| String.valueOf(BaseEntity.RECORD_STATE_COMPLETED)
								.equals(lcStatus)) {
					list.add(cb.equal(root.get("recordStatus").as(String.class),
							lcStatus));
				} else {
					Subquery<TaskInfoEntity> subquery = query
							.subquery(TaskInfoEntity.class);
					Root<TaskInfoEntity> taskRoot = subquery
							.from(TaskInfoEntity.class);
					subquery.select(taskRoot);
					List<Predicate> subQueryPredicates = new ArrayList<Predicate>();
					subQueryPredicates.add(cb.equal(
							root.get("id").as(String.class), taskRoot.get("busId")
									.as(String.class)));
					subQueryPredicates.add(cb.equal(
							taskRoot.get("currName").as(String.class), lcStatus));
					subQueryPredicates.add(cb.notEqual(
							taskRoot.get("state").as(Long.class),
							BaseEntity.RECORD_STATE_COMPLETED));
					subquery.where(subQueryPredicates.toArray(new Predicate[] {}));
					list.add(cb.exists(subquery));
				}
			}
		}
		return list;
	}
	

	/**
	 * 将传入的附件拼成固定格式的String返回
	 */
	public static String getWord(List<AccessoryEntity> list) {
		StringBuffer sbf = new StringBuffer();
		String str = "<?XML VERSION=\"1.0\" ENCODING=\"GBK\"?><DOCUMENTDATA>";
		sbf.append(str);
		if (list != null && list.size() > 0) {
			for (AccessoryEntity accessoryEntity : list) {
				sbf.append("<DOCUMENT>");
				sbf.append("<DOCUMENT_ID>").append(accessoryEntity.getId())
						.append("</DOCUMENT_ID>");
				sbf.append("<DOCUMENT_NAME>")
						.append(getResource("fileType", accessoryEntity
								.getType().getName()))
						.append("</DOCUMENT_NAME>");
				sbf.append("<FILE_NAME>").append(accessoryEntity.getName())
						.append("</FILE_NAME>");
				sbf.append("<FILE_CONTENT>")
						.append(encodeBase64(accessoryEntity.getContent()
								.getValue())).append("</FILE_CONTENT>");
				sbf.append("</DOCUMENT>");
			}
		}
		sbf.append("</DOCUMENTDATA>");
		return sbf.toString();
	}

	/**
	 * 该天最早的时候
	 * 
	 * @param date
	 * @return
	 */
	public static Date getDateFirstTime(Date date) {
		if (null == date) {
			return null;
		}
		Calendar c = Calendar.getInstance();
		c.setTime(date);
		c.set(java.util.Calendar.HOUR_OF_DAY, 0);
		c.set(java.util.Calendar.MINUTE, 0);
		c.set(java.util.Calendar.SECOND, 0);
		return c.getTime();
	}

	/**
	 * 该天最迟的时候
	 * 
	 * @param date
	 * @return
	 */
	public static Date getDateLastTime(Date date) {
		if (null == date) {
			return null;
		}
		Calendar c = Calendar.getInstance();
		c.setTime(date);
		c.set(java.util.Calendar.HOUR_OF_DAY, 23);
		c.set(java.util.Calendar.MINUTE, 59);
		c.set(java.util.Calendar.SECOND, 59);
		return c.getTime();
	}

	public static String getExeMsg(Throwable t) {
		StringWriter sw = new StringWriter();
		t.printStackTrace(new PrintWriter(sw));
		return sw.toString();
	}

	public static byte[] getQrcodeImage(int length,int width, String content){
		BufferedImage img = new BufferedImage(length, width,
				BufferedImage.TYPE_INT_RGB);
		for (int i = 0; i < img.getWidth(); i++) {
			for (int j = 0; j < img.getHeight(); j++) {
				img.setRGB(i, j, 0xffffff);
			}
		}
		Graphics2D g = (Graphics2D) img.getGraphics();
		g.rotate(Math.PI / 2, length / 2, length / 2);
		g.setColor(new Color(0, 0, 0));
		g.setFont(new Font("宋体", Font.PLAIN, 14));
		// 二维码
		try {
			// 二维码版本
			int version = 7;
			// 图片尺寸
			int imgSize = 67 + 12 * (version - 1);
			BufferedImage qrImg = new BufferedImage(imgSize, imgSize,
					BufferedImage.TYPE_INT_RGB);
			Graphics2D gs = qrImg.createGraphics();
			gs.setBackground(Color.WHITE);
			gs.clearRect(0, 0, imgSize, imgSize);
			Qrcode qrcodeHandler = new Qrcode();
			// 设置二维码排错率，可选L(7%)、M(15%)、Q(25%)、H(30%)，排错率越高可存储的信息越少，但对二维码清晰度的要求越小
			qrcodeHandler.setQrcodeErrorCorrect('M');
			// N代表数字,A代表字符a-Z,B代表其他字符
			qrcodeHandler.setQrcodeEncodeMode('B');
			// 设置二维码版本，取值范围1-40，值越大尺寸越大，可存储的信息越大
			qrcodeHandler.setQrcodeVersion(version);
			byte[] contentBytes = content.getBytes("gb2312");
			gs.setColor(Color.BLACK);
			// 设置偏移量 不设置可能导致解析出错
			int pixoff = 2;
			// 输出内容> 二维码
			if (contentBytes.length > 0 && contentBytes.length < 120) {
				boolean[][] codeOut = qrcodeHandler
						.calQrcode(contentBytes);
				for (int i = 0; i < codeOut.length; i++) {
					for (int j = 0; j < codeOut.length; j++) {
						if (codeOut[j][i]) {
							gs.fillRect(j * 3 + pixoff, i * 3 + pixoff,
									3, 3);
						}
					}
				}
			} else {
				System.err.println("QRCode content bytes length = "
						+ contentBytes.length + " not in [ 0,120 ]. ");
			}
			// 中间logo
			InputStream imgIn = new FileInputStream(Utils.getSession()
					.getServletContext().getRealPath("/")
					+ "resource/yjpt/login/login_logo.png");
			Image logo = ImageIO.read(imgIn);
			int widthLogo = logo.getWidth(null) > qrImg.getWidth() * 2 / 10 ? (qrImg
					.getWidth() * 2 / 10) : logo.getWidth(null);
			int heightLogo = logo.getHeight(null) > qrImg.getHeight() * 2 / 10 ? (qrImg
					.getHeight() * 2 / 10) : logo.getWidth(null);
			int x = (qrImg.getWidth() - widthLogo) / 2;
			int y = (qrImg.getHeight() - heightLogo) / 2;
			gs.drawImage(logo, x, y, widthLogo, heightLogo, null);
			gs.dispose();
			qrImg.flush();

			g.drawImage(qrImg.getScaledInstance(100, 100,
					Image.SCALE_DEFAULT), 6, 6, null);
		} catch (Exception e) {
			e.printStackTrace();
		}
		g.dispose();
		ByteArrayOutputStream bos = new ByteArrayOutputStream();
		try {
			ImageIO.write(img, "PNG", bos);
			return bos.toByteArray();
		} catch(Exception e){
			e.printStackTrace();
		}
		return null;
	}
			
}