首先是Java中的工具類

import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.UnsupportedEncodingException;
import java.net.ConnectException;
import java.net.HttpURLConnection;
import java.net.URL;
import javax.net.ssl.HttpsURLConnection;
import javax.net.ssl.SSLContext;
import javax.net.ssl.SSLSocketFactory;
import javax.net.ssl.TrustManager; 
import net.sf.json.JSONObject;
 /**
  * https工具類
  * @author Administrator
  *
  */
public class CommonUtil {
	
	public static JSONObject httpsRequest(String requestUrl, String requestMethod, String outputStr) { 
		
        JSONObject jsonObject = null;
        StringBuffer buffer = new StringBuffer();  
        try {  
            // 建立SSLContext物件，並使用我們指定的信任管理器初始化  
            TrustManager[] tm = { new MyX509TrustManager() };  
            SSLContext sslContext = SSLContext.getInstance("SSL", "SunJSSE");  
            sslContext.init(null, tm, new java.security.SecureRandom());  
            // 從上述SSLContext物件中得到SSLSocketFactory物件  
            SSLSocketFactory ssf = sslContext.getSocketFactory();    
            URL url = new URL(requestUrl);  
            HttpsURLConnection httpUrlConn = (HttpsURLConnection) url.openConnection();  
            httpUrlConn.setSSLSocketFactory(ssf);  
            httpUrlConn.setDoOutput(true);  
            httpUrlConn.setDoInput(true);  
            httpUrlConn.setUseCaches(false);  
            // 設定請求方式（GET/POST）  
            httpUrlConn.setRequestMethod(requestMethod);  
            if ("GET".equalsIgnoreCase(requestMethod)) {
            	 httpUrlConn.connect();  
            } 
            // 當有資料需要提交時  
            if (null != outputStr) {  
                OutputStream outputStream = httpUrlConn.getOutputStream();  
                // 注意編碼格式，防止中文亂碼  
                outputStream.write(outputStr.getBytes("UTF-8"));  
                outputStream.close();  
            }  
  
            // 將返回的輸入流轉換成字串  
            InputStream inputStream = httpUrlConn.getInputStream();  
            InputStreamReader inputStreamReader = new InputStreamReader(inputStream, "utf-8");  
            BufferedReader bufferedReader = new BufferedReader(inputStreamReader);    
            String str = null;  
            while ((str = bufferedReader.readLine()) != null) {  
                buffer.append(str);  
            }  
            bufferedReader.close();  
            inputStreamReader.close();  
            // 釋放資源  
            inputStream.close();  
            inputStream = null;  
            httpUrlConn.disconnect();  
            jsonObject = JSONObject.fromObject(buffer.toString());  
        } catch (ConnectException ce) {  
            ce.printStackTrace();
        } catch (Exception e) {  
            e.printStackTrace();
        }  
        return jsonObject;  
    }
	
    public static String httpRequest(String requestUrl, String requestMethod, String outputStr) {         
        StringBuffer buffer = new StringBuffer();  
        try {       
            URL url = new URL(requestUrl);  
            HttpURLConnection httpUrlConn = (HttpURLConnection) url.openConnection();              
            httpUrlConn.setDoOutput(true);  
            httpUrlConn.setDoInput(true);  
            httpUrlConn.setUseCaches(false);  
            // 設定請求方式（GET/POST）  
            httpUrlConn.setRequestMethod(requestMethod);  
            if ("GET".equalsIgnoreCase(requestMethod)) {
            	 httpUrlConn.connect();  
            }              
            // 當有資料需要提交時  
            if (null != outputStr) {  
                OutputStream outputStream = httpUrlConn.getOutputStream();  
                // 注意編碼格式，防止中文亂碼  
                outputStream.write(outputStr.getBytes("UTF-8"));  
                outputStream.close();  
            }  
  
            // 將返回的輸入流轉換成字串  
            InputStream inputStream = httpUrlConn.getInputStream();  
            InputStreamReader inputStreamReader = new InputStreamReader(inputStream, "utf-8");  
            BufferedReader bufferedReader = new BufferedReader(inputStreamReader);    
            String str = null;  
            while ((str = bufferedReader.readLine()) != null) {  
                buffer.append(str);  
            }  
            bufferedReader.close();  
            inputStreamReader.close();  
            // 釋放資源  
            inputStream.close();  
            inputStream = null;  
            httpUrlConn.disconnect();  
            //jsonObject = JSONObject.fromObject(buffer.toString());  
        } catch (ConnectException ce) {  
            ce.printStackTrace();
        } catch (Exception e) {  
            e.printStackTrace();
        }  
        return buffer.toString();  
    }
	public static String urlEncodeUTF8(String source){
		String result = source;
		try {
			result = java.net.URLEncoder.encode(source,"utf-8");
		} catch (UnsupportedEncodingException e) {
			e.printStackTrace();
		}
		return result;
	}
	
    public static String httpsRequestForStr(String requestUrl, String requestMethod, String outputStr) { 		
        String result="";
        StringBuffer buffer = new StringBuffer();  
        try {  
            // 建立SSLContext物件，並使用我們指定的信任管理器初始化  
            TrustManager[] tm = { new MyX509TrustManager() };  
            SSLContext sslContext = SSLContext.getInstance("SSL", "SunJSSE");  
            sslContext.init(null, tm, new java.security.SecureRandom());  
            // 從上述SSLContext物件中得到SSLSocketFactory物件  
            SSLSocketFactory ssf = sslContext.getSocketFactory();    
            URL url = new URL(requestUrl);  
            HttpsURLConnection httpUrlConn = (HttpsURLConnection) url.openConnection();  
            httpUrlConn.setSSLSocketFactory(ssf);    
            httpUrlConn.setDoOutput(true);  
            httpUrlConn.setDoInput(true);  
            httpUrlConn.setUseCaches(false);  
            // 設定請求方式（GET/POST）  
            httpUrlConn.setRequestMethod(requestMethod);    
            if ("GET".equalsIgnoreCase(requestMethod)) {
            	 httpUrlConn.connect();  
            }                  
            // 當有資料需要提交時  
            if (null != outputStr) {  
                OutputStream outputStream = httpUrlConn.getOutputStream();  
                // 注意編碼格式，防止中文亂碼  
                outputStream.write(outputStr.getBytes("UTF-8"));  
                outputStream.close();  
            }    
            // 將返回的輸入流轉換成字串  
            InputStream inputStream = httpUrlConn.getInputStream();  
            InputStreamReader inputStreamReader = new InputStreamReader(inputStream, "utf-8");  
            BufferedReader bufferedReader = new BufferedReader(inputStreamReader);    
            String str = null;  
            while ((str = bufferedReader.readLine()) != null) {  
                buffer.append(str);  
            }  
            bufferedReader.close();  
            inputStreamReader.close();  
            // 釋放資源  
            inputStream.close();  
            inputStream = null;  
            httpUrlConn.disconnect();  
            result=buffer.toString();  
        } catch (ConnectException ce) {  
            ce.printStackTrace();
        } catch (Exception e) {  
            e.printStackTrace();
        }  
        return result;  
    }
}

 

因為https請求在上線後不是合法域名，所以只能通過服務端傳送請求

/**
 * @category 得到token
 */
	public Map<String, Object>  getToken(String appId,String secret){	
		 String url="https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=" + appId + "&secret=" +secret;
	      JSONObject jo=JSONObject.fromObject(CommonUtil.httpsRequest(url, "GET",null));
	      Map map=jo; 
	     
		return jo;
		
	}
	/**
	 * @category 得到openid
	 */
	public Map<String, Object> getOpenId(String appId,String secret,String code){
		String url="https://api.weixin.qq.com/sns/jscode2session?appid="+appId+"&secret="+secret+"&js_code="+code+"&grant_type=authorization_code";
	      JSONObject jo=JSONObject.fromObject(CommonUtil.httpsRequest(url, "GET",null));
          Map map=jo; 
		return map;
		
	}
	/**
	 *@category 儲存openid
	 */
	@Override
	public ResultValue<UserVO> saveOpen(Long id, String openid)throws Exception {
		ResultValue<UserVO> rv = new ResultValue<UserVO>();
		UserVO user = userDao.findByIdAndDr(id, BdRefConstant.DR_ACTIVE);
		user.setOpenid(openid);
		user.setTs(TimeUtil.getCurTS());
		userDao.save(user);
		rv.setSuccess(true);
		return rv;	
	}
	
	/**
	 * @category 傳送
	 */
	public Map<String, Object> sendMsg(String token,String msg){		
		String url="https://api.weixin.qq.com/cgi-bin/message/wxopen/template/send?access_token="+token;
	    JSONObject jo=JSONObject.fromObject(CommonUtil.httpsRequest(url, "POST",msg));
        Map map=jo;	
		return map;	
	}
 

通過這幾個方法基本上就可以實現訊息模板的傳送了。
我是直接將formid與openid存入到資料庫表當中。通過改變狀態0，1來判斷是否使用。
傳送訊息模板有許多種方法，我弄了幾天，感覺這個最簡單。還可以存入redis,當然這個我還沒有研究。

package com.yun.service.wxkey;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import org.apache.commons.validator.Var;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import com.yun.dao.pub.DynQryDao;
import com.yun.dao.wxkey.WxKeyDao;
import com.yun.model.pub.result.ResultValue;
import com.yun.model.user.UserVO;
import com.yun.model.wxkey.WxKeyVO;
import com.yun.pub.constant.BdRefConstant;
import com.yun.pub.util.BTool;
import com.yun.pub.util.TimeUtil;
@Transactional
@Service("WxKeyService")
public class WxKeyServiceImp implements WxKeyService {
	@Autowired
	private WxKeyDao wxDao;
	@Autowired
	private DynQryDao dqdao;
	
	private EntityManager entityManager;
	@PersistenceContext
	public void setEntityManager(EntityManager entityManager) {
		this.entityManager = entityManager;
	}
	protected EntityManager getEntityManager() {
		return entityManager;
	}
    /**
     * @category 通過userid查詢formid
     * 	@Override
     */
	public ResultValue<WxKeyVO> findFormId(String userid) {
		ResultValue<WxKeyVO> rt=new ResultValue<WxKeyVO>();	
		String msg="";
		if(BTool.isEmpty(userid)){
			msg += "新增問題資訊不能為空！";
			rt.setMsg(msg);		
			System.out.println(userid);
			return rt;
		}else{
		List<Map<String, Object>> WxBack = dqdao
			.findBySql(wxDao.findSame + " and d.id in (" +userid+") and c.state='"+BdRefConstant.WX_SAVE+"' group by d.id");
		rt.setMapList(WxBack);	
		}
		return rt;
	}
	/**
	 * @category 新增formid
	 * @Override
	 */
	@Transactional(propagation = Propagation.REQUIRED, readOnly = false, rollbackForClassName = "Exception")
	public ResultValue<WxKeyVO> save(WxKeyVO wk) {
		ResultValue<WxKeyVO> rt=new ResultValue<WxKeyVO>();
		String msg="";
		if (BTool.isEmpty(wk)) {
			msg += "新增問題資訊不能為空！";
			rt.setMsg(msg);
			return rt;
		} else {
			msg += "新增成功！";
			wk.setState(BdRefConstant.WX_SAVE);
			wk.setTs(TimeUtil.getCurTS());
			WxKeyVO save = wxDao.save(wk);
			if (!BTool.isEmpty(save)) {
				rt.setSuccess(true);
				rt.setMsg(msg);
			} else {
				rt.setMsg("儲存失敗！");
			}
		}
		return rt;
	}

	/**
	 * @throws Exception 
	 * @category 通過formid刪除
	 * @Override
	 */
	public ResultValue<WxKeyVO> delByFormId(String formid) throws Exception {
		ResultValue<WxKeyVO> rt=new ResultValue<WxKeyVO>();
		String msg="";
		WxKeyVO wk = wxDao.findByFormid(formid);
		
		if(BTool.isEmpty(wk)){
			msg += "刪除失敗！";
			rt.setMsg(msg);
			return rt;
		}else{
			msg+="刪除成功！";
			wk.setState(BdRefConstant.WX_END);
			wk.setTs(TimeUtil.getCurTS());
			WxKeyVO save = wxDao.save(wk);
			if (!BTool.isEmpty(save)) {
				rt.setSuccess(true);
				rt.setMsg(msg);
			} else {
				rt.setMsg("刪除失敗！");
			}
		}
		return rt;
	}
}