});

var voice = { localId: '',   serverId: ''  };//全局变量

var END;
 var START;
 //按下开始录音
 $('#talk_btn').on('touchstart', function(event){
     event.preventDefault();
     START = new Date().getTime();
     recordTimer = setTimeout(function(){
         wx.startRecord({
             success: function(){
        // mui('#talk_btn').button('loading');
                 localStorage.rainAllowRecord = 'true';
             },
             cancel: function () {
                 alert('用户拒绝授权录音');
             }
         });
     },300);

});

//松手结束录音
 $('#talk_btn').on('touchend', function(event){
     event.preventDefault();
//  mui('#talk_btn').button('reset');
     END = new Date().getTime();
     if((END - START) < 1000){
         END = 0;
         START = 0;
         //小于1000ms，不录音
         clearTimeout(recordTimer);
mui.toast('录音时长小于1秒不录音',{ duration:'short', type:'div' }) ;
 var t=setTimeout(function(){wx.stopRecord()},800);//这里设置800毫秒，是因为如果用户录音之后马上松开按钮，会成 wx.stopRecord不起作用的情况，然后会一直录音，所以时间设置长一点
             //clearTimeout(t);
     }else{
         wx.stopRecord({
           success: function (res) {
             voice.localId = res.localId;
             //$("#vo").val(res.localId);
           uploadVoice();
           },
           fail: function (res) {
             alert(JSON.stringify(res));
           }
         });
     }

});

//上传录音
 function uploadVoice(){
     //调用微信的上传录音接口把本地录音先上传到微信的服务器
     //不过，微信只保留3天，而我们需要长期保存，我们需要把资源从微信服务器下载到自己的服务器
     wx.uploadVoice({
         localId: voice.localId, // 需要上传的音频的本地ID，由stopRecord接口获得
         isShowProgressTips: 1, // 默认为1，显示进度提示
         success: function (res) {
         voice.serverId = res.serverId;        
        /* var uu = /restsh/uploadVoice/" + res.serverId;
        $.ajax({//上传到服务器
        url : uu,
        async : true,
        cache : false,
        dataType : 'json',
        type : 'GET',
        data : {},
        success : function(req) {
        voice.serverId = res.serverId;
 
        $.web.RemoveLoading();
        },
        error : function(XMLHttpRequest, textStatus, errorThrown) {
        $.web.RemoveLoading();
        mui.alert("不好意思，出了点小问题","提示","确定");
        }
        });*/
         }
     });

}

// 4.4 监听录音自动停止
 wx.onVoiceRecordEnd({
   complete: function (res) {
     voice.localId = res.localId;
     //uploadVoice();//上传录音到服务器
     alert('录音时间已超过一分钟');
   }

});

document.querySelector('#playVoice').onclick = function () {
   if (voice.localId == '') {
    alert('请先录制一段声音');
     //alert('请先使用 startRecord 接口录制一段声音');
     return;
   }
     wx.playVoice({
         localId: voice.localId
       });

};

// 暂停播放音频
 document.querySelector('#stop_btn').onclick = function () {
   mui('#playVoice').button('reset');
   wx.pauseVoice({
     localId: voice.localId
   });
 };

public class ConfigParam extends HttpServlet {
public void doPost(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
 response.setCharacterEncoding("UTF-8");  
        PrintWriter out = response.getWriter();

String Rurl=java.net.URLDecoder.decode(request.getParameter("Rurl"),"utf-8");
//System.out.println(Rurl);
 Map<String, String> ret= WeixinUtil.getJSSDKData(Rurl,WechatUtil.appId,WechatUtil.appSecret);
 JSONObject json=JSONObject.fromObject(ret);
        //System.out.println(json.toString());
        out.print(json);
}
}

import javax.net.ssl.HttpsURLConnection;
import javax.net.ssl.SSLContext;
import javax.net.ssl.SSLSocketFactory;
import javax.net.ssl.TrustManager;
import net.sf.json.JSONException;
import net.sf.json.JSONObject;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

/**
 * 公众平台通用接口工具类
 * 
 * 
 * 
 */
public class WeixinUtil {
private static Log log = LogFactory.getLog(WeixinUtil.class);
// 获取access_token的接口地址（GET） 限200（次/天）
public final static String access_token_url = "https://api.weixin.qq.com/cgi-bin/token?            grant_type=client_credential&appid=APPID&secret=APPSECRET";
private static  Map<String,AccessToken>  tokenMap = new HashMap<String,AccessToken>();

/**
 * 获取access_token
 * 
 * @param appid 凭证
 * @param appsecret 密钥
 * @param flag 是否重新获取
 * @return
 */
public static AccessToken getAccessToken(String appid, String appsecret,boolean flag) {

AccessToken accessToken = null;
log.info("=================getAccessToken-start");
if(!flag){
accessToken = tokenMap.get(appid);
}
long now = System.currentTimeMillis();

if(accessToken != null && !flag){

long lastTime = accessToken.getCreateTime();
//当accessToken还在有效期内
if(now <= (lastTime + accessToken.getExpiresIn() * 1000) ){
log.info("读取缓存accessToken=="+accessToken);
return accessToken;
}
}
String requestUrl = access_token_url.replace("APPID", appid).replace("APPSECRET", appsecret);
JSONObject jsonObject = httpRequest(requestUrl, "GET", null);
// 如果请求成功
if (null != jsonObject) {
try {
accessToken = new AccessToken();
accessToken.setCreateTime(now);
accessToken.setToken(jsonObject.getString("access_token"));
accessToken.setExpiresIn(jsonObject.getInt("expires_in") - 300);
log.info("重新获取accessToken=="+accessToken);
} catch (JSONException e) {
accessToken = null;
// 获取token失败
log.error("获取token失败 errcode:"+jsonObject.getInt("errcode")+" errmsg:{"+ jsonObject.getString("errmsg")+"}" );
}
}
log.info("=================getAccessToken-end");
tokenMap.put(appid, accessToken);

return accessToken;

}

/**
 * 获取access_token
 * 
 * @param appid 凭证
 * @param appsecret 密钥
 * @return
 */
public static AccessToken getAccessToken(String appid, String appsecret ) {
log.info("getAccessToken:重新获取AccessToken");
return getAccessToken(appid, appsecret, true);

}

public static String JS_API_URL =  "https://api.weixin.qq.com/cgi-bin/ticket/getticket?access_token=ACCESS_TOKEN&type=jsapi";

/**
 * 
 * @param accessToken
 * @return
 */
public static String getJsapi_ticket(String accessToken){
log.info("=====================getJsapi_ticket:start");
     String url = JS_API_URL.replace("ACCESS_TOKEN", accessToken);
     JSONObject json = httpRequest(url, "GET", null);
     log.info("getJsapi_ticket:"+json);
        String jsapi_ticket = "";
        try {
jsapi_ticket = json.getString("ticket");

} catch (Exception e) {
log.error("=====================getJsapi_ticket:error"+json);
e.printStackTrace();
}
     log.info("=====================getJsapi_ticket:end");
        return jsapi_ticket;
    }
//JS SDK  中需要的相关的数据
private  static Map<String,String > JsSDKMap = new HashMap<String, String>();

public static String getJsapi_ticket_cache(String accessToken ){

String jsapi = JsSDKMap.get(accessToken);

if(jsapi != null){
log.info("读取jsapi_ticket缓存"+jsapi );
return jsapi;

}else{
jsapi = getJsapi_ticket(accessToken);
log.info("刷新Jsapi_ticket："+jsapi+"===="+accessToken );
JsSDKMap.put(accessToken, jsapi);
}

return jsapi;
    }

//获得jsapi_ticket，noncestr，timestamp   
public static  Map<String ,String> getJSSDKData(String requestUrl,String appid,String appsecret){
log.info("=================getJSSDKData-start");
//1)获取access_token
AccessToken accessToken =  getAccessToken(appid, appsecret,false);
String token = accessToken.getToken();
log.info("accessToken:"+accessToken);
//2)获取jsapi_ticket（有效期7200秒
String jsapi_ticket = getJsapi_ticket_cache(token);
log.info("jsapi_ticket:"+jsapi_ticket);
//3)获取//随机字符串 
String noncestr  = Double.toString(Math.random()).substring(2, 15);//随机字符串

//4）获取 随机时间戳
String timeStamp =((int)(new Date().getTime()/1000))+"";//随机时间戳

//5)获取签名
String str = "jsapi_ticket=" + jsapi_ticket + "&noncestr=" + noncestr + "&timestamp="+ timeStamp +"&url=" + requestUrl;
log.info("str:" + str);
String signature = SHA1Util.Sha1(str); 
    Map<String ,String>  map =  new HashMap<String, String>();
    map.put("ticket", jsapi_ticket);
map.put("noncestr", noncestr);
map.put("timestamp", timeStamp);
map.put("signature", signature);
map.put("url", requestUrl);
map.put("appid", appid);
log.info("=================getJSSDKData-end");
return map;
} 
 
/**
 * 发起https请求并获取结果
 * 
 * @param requestUrl 请求地址
 * @param requestMethod 请求方式（GET、POST）
 * @param outputStr 提交的数据
 * @return JSONObject(通过JSONObject.get(key)的方式获取json对象的属性值)
 */
public static JSONObject httpRequest(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) {
log.error("Weixin server connection timed out.");
} catch (Exception e) {
log.error("https request error:{}", e);
}
return jsonObject;
}

}

/** 
 * 微信通用接口凭证 
 *  
 * 
 * 
 */  
public class AccessToken {  
    // 获取到的凭证  
    private String token;  
    // 凭证有效时间，单位：秒  
    private int expiresIn; 
    
    private long createTime;
  
    public String getToken() {  
        return token;  
    }  
  
    public void setToken(String token) {  
        this.token = token;  
    }  
 
    public int getExpiresIn() {  
        return expiresIn;  
    }  
 
    public void setExpiresIn(int expiresIn) {  
        this.expiresIn = expiresIn;  
    }
public long getCreateTime() {
return createTime;
}

public void setCreateTime(long createTime) {
this.createTime = createTime;
}  
}

}

 //  static {  
     //   FFMPEG_PATH =DloadImgUtil.class.getResource("ffmpeg").getFile(); //linux使用
    //}  

public static String downloadMedia(String mediaId, String savePath,String out,String type) {
String filePath = null;
AccessToken accessToken = WeixinUtil.getAccessToken(WechatUtil.appId,
WechatUtil.appSecret, false);
// 拼接请求地址
String requestUrl = "https://api.weixin.qq.com/cgi-bin/media/get?access_token=ACCESS_TOKEN&media_id=MEDIA_ID";
requestUrl = requestUrl.replace("ACCESS_TOKEN", accessToken.getToken())
.replace("MEDIA_ID", mediaId);
String returnstr="0";
BufferedInputStream bis = null;
FileOutputStream fos = null;
HttpsURLConnection conn = null;
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(null,requestUrl,new
// sun.net.www.protocol.https.Handler());
// URL url = new URL(requestUrl);
URL url = new URL(requestUrl);
conn = (HttpsURLConnection) url.openConnection();
conn.setSSLSocketFactory(ssf);

conn.setDoOutput(true);
conn.setDoInput(true);
conn.setUseCaches(false);
// 设置请求方式（GET/POST）
conn.setRequestMethod("GET");

// 根据内容类型获取扩展名
// String fileExt = DloadImgUtil
// .getFileexpandedName(conn.getHeaderField("Content-Type"));
// 将mediaId作为文件名
filePath = savePath;
bis = new BufferedInputStream(conn.getInputStream());
fos = new FileOutputStream(new File(filePath));
byte[] buf = new byte[8096];
int size = 0;
while ((size = bis.read(buf)) != -1)
fos.write(buf, 0, size);
amr2mp3(savePath,out);
  } catch (Exception e) {
  returnstr="-1";
  e.printStackTrace();

} finally {
// 释放资源
conn.disconnect();
try {
// 关闭流，释放资源
if (fos != null) {
fos.close();
}
if (bis != null) {
bis.close();
}

} catch (Exception e) {
e.getStackTrace();
}

}

return returnstr;

}

/** 
     * 将一个amr文件转换成mp3文件 
     * @param amrFile  
     * @param mp3File  
     * @throws IOException  
     *    -i ：指定输入文件-ar ： 指定sampling rate(采样率)，它的单位是HZ
     *  -ac：指定声道，1表示双声道，0表示单声道-ab：指定转换后的比特率
* @throws InterruptedException 
     */  
    public static void amr2mp31(String amrFileName, String mp3FileName) throws IOException, InterruptedException {  
        Runtime runtime = Runtime.getRuntime();  
        Process process = runtime.exec(FFMPEG_PATH + " -i "+amrFileName+" -ar 8000 -ac 1 -y -ab 12.5k " + mp3FileName); //12.4
        InputStream in = process.getErrorStream();  
        BufferedReader br = new BufferedReader(new InputStreamReader(in));  
        try {  
            String line = null;  
            while((line = br.readLine())!=null) {  
           //     System.out.println(line);  
            }  
            while((line = br.readLine())!=null){  
                    System.out.println("</ERROR>");  
                    int exitValue =process.waitFor();  
                    System.out.println("Process exitValue="+exitValue);  
            }  
        } finally {  
            //为了避免这里抛出的异常会覆盖上面抛出的异常，这里需要用捕获异常。  
            try {  
                in.close();  
            } catch (Exception e) {  
                e.printStackTrace();  
            }  
        }  
    }