@RequestMapping(value="order/updateOrder.do")
public String updateOrder(HttpServletRequest request,HttpServletResponse response){
final String ordId =request.getParameter("ordId");
String proDesc =request.getParameter("proDesc");
final String logisticnum =request.getParameter("logisticnum");
final String logisticcompany =request.getParameter("logisticcompany");
String stats =request.getParameter("stats");
final String tranNum =request.getParameter("tranNum");
final String openId =request.getParameter("openId"); System.out.println("订单状态stats:" + stats);
System.out.println("tranNum:" + tranNum);
System.out.println("openId:" + openId);
System.out.println("logisticnum:" + logisticnum);
System.out.println("logisticcompany:" + logisticcompany); GoodsOrder order = new GoodsOrder();
order.setOrdId(ordId);
order.setProDesc(proDesc);
order.setLogisticnum(logisticnum);
order.setLogisticcompany(logisticcompany);
order.setrStatus(stats); //获取当前时间:毫秒
long a = System.currentTimeMillis();
System.out.println("a :" + a); try
{
//更改订单状态
shopService.updateOrder(order); //如果订单状态从 支付成功 改成 已发货,则给用户发送一条微信消息。
if (Integer.parseInt(stats) == 3)
{
//异步发送微信消息
new Thread()
{
public void run()
{
message.sendWxMessage(openId, tranNum, logisticcompany,logisticnum);
}
}.start();
//同步发送微信消息
//message.sendWxMessage(openId, tranNum, logisticcompany,logisticnum);
} }
catch (Exception e)
{
e.printStackTrace();
} //计算 try 内语句的执行时间
long b = System.currentTimeMillis();
System.out.println("b :" + b);
System.out.println(" b - a :" + (b - a));
return "redirect:/order/orderlist.do?currPage=1";
}
package com.starcloud.helpapp.wxMessage.service;/**
*
* 项目名称:eduappweb
* 类名称:
* 类描述:
* 创建人:Administrator
* 创建时间:2016-5-28 下午02:53:01
* @version 1.0
*/
public interface Message
{ /**
*
* [简要描述]:推送微信消息
* [详细描述]:
*
* @param openId
* @param proName
* @param payfee
* @param phoneNum
* @param flag 1:购买成功提示消息 2:代言返利消息
*/
public void sendWxMessage(String openId,String tranNum,String logisticcompany,String logisticnum);
}
package com.starcloud.helpapp.wxMessage.service.impl;import org.springframework.stereotype.Service;import net.sf.json.JSONObject;import com.starcloud.helpapp.common.Loger;
import com.starcloud.helpapp.common.utils.Tools;
import com.starcloud.helpapp.wxMessage.ConnectionUrlUtil;
import com.starcloud.helpapp.wxMessage.beans.MsgTemplateBean;
import com.starcloud.helpapp.wxMessage.common.Constant;
import com.starcloud.helpapp.wxMessage.service.Message;@Service("Message")
public class MessageImpl implements Message
{ /**
*
* [简要描述]:推送微信消息
* [详细描述]: 1:订单状态改成已发货
*
* @param parameter
*/
public void sendWxMessage(String openId,String tranNum,String logisticcompany,String logisticnum)
{
JSONObject parameters = new JSONObject();
MsgTemplateBean bean = MsgTemplateBean.getMsgTemplageBean(tranNum,logisticcompany,logisticnum);
bean.setTouser(openId);
parameters = JSONObject.fromObject(bean);
System.out.println("parameters: " + parameters.toString());
// else
// {
// //proName返利订单
// MsgforDistributeBean bean = MsgforDistributeBean.getMsgTemplageBean(payfee,phoneNum,proName);
// bean.setTouser(openId);
// parameters = JSONObject.fromObject(bean);
// }
Loger.logtxt("WxMessage", "发送消息"+parameters);
String access_token = getAccess_token();
if(null != access_token)
{
String returnstr = ConnectionUrlUtil.sendPost(Constant.SEND_MESSAGEURL+"?access_token="+access_token,parameters.toString());
try
{
JSONObject returnJson = JSONObject.fromObject(returnstr); if(0 == returnJson.getInt("errcode"))
{
Loger.logtxt("WxMessage", "发送消息成功"+parameters);
}
else
{
Loger.logtxt("WxMessage", "发送消息失败"+parameters);
}
}
catch (Exception e)
{
e.printStackTrace();
} }
else
{
//发送失败,获取token失败
Loger.logtxt("WxMessage", "发送消息失败,原因获取access_token失败 ");
} }
/**
*
* [简要描述]:获取到access_token
* [详细描述]:
*
* @return
*/
public String getAccess_token()
{
String access_token = "";//公司的access_token
String access_token_json = ConnectionUrlUtil.sendPost(Constant.TOKEN_URL, "grant_type=client_credential&appid=" + Constant.APP_ID + "&secret="
+ Constant.APP_SECRET);
if(Tools.isNotEmty(access_token_json))
{
JSONObject tokenJson = JSONObject.fromObject(access_token_json);
if(null != tokenJson && null!=tokenJson.get("access_token"))
{
//ACCESS_TOKEN
access_token = tokenJson.getString("access_token");
}
}
return access_token;
}
}