RecruitmentApi/src/main/java/com/wechat/common/CommonHelper.java

package com.wechat.common;

import java.io.UnsupportedEncodingException;
import java.util.Calendar;
import java.util.Date;
import java.util.regex.Matcher;
import java.util.regex.Pattern;

import javax.servlet.http.HttpServletRequest;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

import com.auth0.jwt.JWT;
import com.auth0.jwt.algorithms.Algorithm;
import com.auth0.jwt.exceptions.JWTCreationException;
import com.wechat.activerequests.responses.MessageIdResponse;
import com.wechat.common.utils.AESUtil;
import com.wechat.common.utils.JacksonUtils;
import com.wechat.common.utils.MessageUtils;
import com.wechat.common.utils.NetworkUtils;
import com.wechat.common.utils.NumberUtils;
import com.wechat.common.utils.StringsUtils;
import com.wechat.model.dbEntity.MdeLoginHis;
import com.wechat.model.requestDto.TMsgSendBaseReq;
import com.wechat.service.WeiXinService;

import nl.basjes.parse.useragent.UserAgent;
import nl.basjes.parse.useragent.UserAgentAnalyzer;


/**
 * The common method shared in all project
 * 
 * @author Administrator
 */
@Component
public class CommonHelper {
	// url根目录
	@Value("#{configProperties['hostPort']}")
	private String urlBase;

	// 模板消息发送用url
	@Value("#{configProperties['weixin.tmsg.send']}")
	private String tmsgSendUrl;

	// token过期时间
	@Value("#{configProperties['token.expire.minute']}")
	private String tokenExpireTime;

	private static final Log log = LogFactory.getLog(CommonHelper.class);

	public String getIRealIPAddr(HttpServletRequest request) {
		String ip = request.getHeader("x-forwarded-for");
		if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip) || "null".equalsIgnoreCase(ip)) {
			ip = request.getHeader("Proxy-Client-IP");
		}
		if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip) || "null".equalsIgnoreCase(ip)) {
			ip = request.getHeader("WL-Proxy-Client-IP");
		}
		if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip) || "null".equalsIgnoreCase(ip)) {
			ip = request.getRemoteAddr();
		}

		// 如果通过多级反向代理，X-Forwarded-For的值不止一个，而是一串用逗号分隔的IP值，此时取X-Forwarded-For中第一个非unknown的有效IP字符串
		if ((ip.indexOf(",") > -1)) {
			ip = ip.split(",")[0];
		}
		return ip;
	}

	/**
	 * 验证是否是手机号码
	 * 
	 * @param mobile
	 * @return
	 */
	public boolean isMobile(String mobile) {
		Pattern p = null;
		Matcher m = null;
		p = Pattern.compile("^[1][3,4,5,7,8][0-9]{9}$"); // 验证手机号
		m = p.matcher(mobile);
		return m.matches();
	}

	/**
	 * 取得完整的图片访问url
	 * 
	 * @param mobile
	 * @return
	 */
	public String getImgUrl(String urlChild) {
		return urlBase + urlChild;
	}

	/**
	 * 模板消息推送
	 * 
	 * @param keyWord
	 *            用户发送的信息
	 * @return
	 */
	public String send(TMsgSendBaseReq req) {
		String url = MessageUtils.getText(tmsgSendUrl, WeiXinService.getInstance().getAccessToken());
		MessageIdResponse response = NetworkUtils.getRemoteResponseAsJson(url, req, MessageIdResponse.class);
		log.debug("Responded: " + JacksonUtils.beautifulSerialize(response));

		// 模板消息推送出错
		if (!StringsUtils.isEqual(Constants.STR_OK, Long.toString(response.getErrorCode()))) {
			log.error("模板消息推送异常：ErrorMsg=" + response.getErrorMsg() + "; ErrorCode=" + response.getErrorCode()
					+ "; MessageId=" + response.getMessageId());
			// 40001 的情况下强制重取token
			if (StringsUtils.isEqual(Constants.STR_TOKEN_ERO, Long.toString(response.getErrorCode()))) {
				WeiXinService.getInstance().updAccessTokenInfo();
				url = MessageUtils.getText(tmsgSendUrl, WeiXinService.getInstance().getAccessToken());
			}
			// 重新发送
			response = NetworkUtils.getRemoteResponseAsJson(url, req, MessageIdResponse.class);
			log.error("模板消息重发：ErrorMsg=" + response.getErrorMsg() + "; ErrorCode=" + response.getErrorCode()
					+ "; MessageId=" + response.getMessageId());
		}

		return response.getErrorCode().toString();
	}

	/**
	 * token生成
	 * 
	 * @param userCode 用户code          
	 * @param req
	 * @param identityFlag 个人企业区分
	 * @param creatDate    用户注册日期
	 * @return
	 * @throws IllegalArgumentException
	 * @throws JWTCreationException
	 * @throws UnsupportedEncodingException
	 */
	public String getToken(String userCode, String identityFlag, String creatDate)
			throws IllegalArgumentException, JWTCreationException, UnsupportedEncodingException {
		Calendar calendar = Calendar.getInstance();
		calendar.add(Calendar.MINUTE, NumberUtils.stringToInt(tokenExpireTime, 120));
		// 生成token 用户code拼上随机字符串进行md5加密
		String token = JWT.create().withClaim(Constants.TOKEN_USER_ID, userCode).withClaim(Constants.TOKEN_IDENTITY_FLAG, identityFlag).withClaim(Constants.TOKEN_CREATDATE, creatDate).withExpiresAt(calendar.getTime())
				.sign(Algorithm.HMAC512(Constants.TOKEN_KEY));
		return token;
	}

	/**
	 * ActivationToken生成 邮箱激活token
	 * 
	 * @param userCode
	 *            用户code
	 * @return token
	 * @throws UnsupportedEncodingException
	 * @throws JWTCreationException
	 * @throws IllegalArgumentException
	 */
	public String getActivationToken(String userCode)
			throws IllegalArgumentException, JWTCreationException, UnsupportedEncodingException {
		Calendar calendar = Calendar.getInstance();
		calendar.add(Calendar.DAY_OF_YEAR, 5);
		// 生成token 用户code拼上随机字符串进行md5加密
		String token = JWT.create().withClaim(Constants.ACTIVATION_TOKEN, userCode).withExpiresAt(calendar.getTime())
				.sign(Algorithm.HMAC512(Constants.TOKEN_KEY));
		return token;
	}
	
	
	/**
	 * 获取客户端信息
	 * @param request
	 * @return
	 */
	public MdeLoginHis getDeviceType(HttpServletRequest request) {
		MdeLoginHis his = new MdeLoginHis();
        String agentString = request.getHeader("User-Agent");
        
        UserAgentAnalyzer a = UserAgentAnalyzer.newBuilder().hideMatcherLoadStats().delayInitialization().build();
        UserAgent userAgent = a.parse(agentString);

        // 浏览器信息
        his.setBrowser(userAgent.getValue(UserAgent.AGENT_NAME));
        his.setBrowserVersion(userAgent.getValue(UserAgent.AGENT_NAME_VERSION));
        his.setIp(getIRealIPAddr(request));
        // 设备信息
        String deviceName = userAgent.getValue(UserAgent.DEVICE_NAME);

    	String lower = agentString.toLowerCase();
    	if(lower.contains("devtool") || lower.contains("postman") || lower.contains("request") || lower.contains("debug") || lower.contains("api")) {
    		deviceName = "IT人员！";
    	}
        his.setOperating(deviceName);
        
        // 设备类型
        his.setDeviceClass(userAgent.getValue(UserAgent.DEVICE_CLASS));
    	
    	// 操作系统信息
        his.setSystem(userAgent.getValue(UserAgent.OPERATING_SYSTEM_NAME_VERSION));
      
        his.setRemarks(agentString);

        return his;
    }
	
	/**
	 * 根据shareJob 获取jobid
	 * @param request
	 * @return
	 */
	public int getJobId(String shareJob) {
		String jobId = shareJob.substring(10);
        return NumberUtils.stringToInt(jobId, 0);
    }
	
	
	
	/**
	 * 获取分享用-用户code
	 * Aes加密
	 * @param request
	 * @return
	 */
	public String getShareCodeAes(String userCode, Date creatTime) {
		String shareCode = AESUtil.encrypt(userCode+Constants.UNDER_LINE+String.valueOf(creatTime.getTime()), Constants.AES_PASSWORD);
        return shareCode;
    }
	
	/**
	 * 获取分享用-用户code
	 * Aes解密
	 * @param request
	 * @return
	 */
	public String[] getUserCodeAes(String shareCode) {
		/*
		 * try { shareCode = URLDecoder.decode(shareCode,"utf-8"); } catch
		 * (UnsupportedEncodingException e) { // TODO Auto-generated catch block
		 * e.printStackTrace(); }
		 */
		String shareCodeStr = AESUtil.decryptStr(shareCode, Constants.AES_PASSWORD);
        return shareCodeStr.split(Constants.UNDER_LINE);
    }

}