|
@@ -13,9 +13,13 @@ import javax.servlet.http.HttpServletResponse;
|
|
|
import com.iamberry.wechat.core.entity.WechatUtils;
|
|
|
import com.iamberry.wechat.core.entity.cart.ShopOrderItemDto;
|
|
|
import com.iamberry.wechat.core.entity.ResultMsg;
|
|
|
+import com.iamberry.wechat.core.entity.eo.Promotions;
|
|
|
+import com.iamberry.wechat.core.entity.ism.IntegralConfig;
|
|
|
import com.iamberry.wechat.core.entity.rent.ReserveOrder;
|
|
|
+import com.iamberry.wechat.face.ism.IntegralLogService;
|
|
|
import com.iamberry.wechat.face.order.AdminOrderService;
|
|
|
import com.iamberry.wechat.face.reserve.ReserveService;
|
|
|
+import com.iamberry.wechat.service.ActivityUtil;
|
|
|
import org.apache.commons.lang3.StringUtils;
|
|
|
import org.jdom.Document;
|
|
|
import org.jdom.Element;
|
|
@@ -131,6 +135,10 @@ public class ResponseWechatPayHandler {
|
|
|
private EfastOrderService efastOrderService;
|
|
|
@Autowired
|
|
|
private AdminOrderService adminOrderService;
|
|
|
+ @Autowired
|
|
|
+ private IntegralLogService integralLogService;
|
|
|
+ @Autowired
|
|
|
+ private ActivityUtil activityUtil;
|
|
|
/**
|
|
|
* 销售订单支付回调方法
|
|
|
*/
|
|
@@ -156,12 +164,11 @@ public class ResponseWechatPayHandler {
|
|
|
resXml = "<xml><return_code><![CDATA[SUCCESS]]></return_code><return_msg><![CDATA[OK]]></return_msg></xml>";
|
|
|
String orderIdMD5 = StaticInfo.orderIdMD5.decrypt(wpr.getAttach());
|
|
|
|
|
|
- //2019-07-29 新增团购功能,查询订单信息,判断是否是团购订单
|
|
|
Order o = new Order();
|
|
|
o.setSalesOrderid(orderIdMD5);
|
|
|
o = cartService.selectOrderInfoById(o);
|
|
|
|
|
|
-//System.out.println("===========pay 117==============");
|
|
|
+// Member member = memberService.getMemberByUserOpenId(o.getSalesOpenid());
|
|
|
|
|
|
if (orderIdMD5.equals(wpr.getOutTradeNo())) {
|
|
|
Date nowDate = new Date();
|
|
@@ -181,13 +188,9 @@ public class ResponseWechatPayHandler {
|
|
|
// 修改订单状态
|
|
|
int count = cartService.updateOrderStatus(order);
|
|
|
|
|
|
-//System.out.println("===========pay 132 修改订单状态==============");
|
|
|
//修改优惠券状态
|
|
|
order=cartService.selectOrderInfoById(order);
|
|
|
-
|
|
|
-//System.out.println("===========pay 136 修改订单状态=============="+order.getSalesOrderid());
|
|
|
String couponId=order.getCouponId();
|
|
|
-
|
|
|
if(couponId!=null && !couponId.equals("")){
|
|
|
CouponItem couponItem=new CouponItem();
|
|
|
couponItem.setCouponItemId(couponId);
|
|
@@ -196,29 +199,29 @@ public class ResponseWechatPayHandler {
|
|
|
couponItemService.updateCouponItemById(couponItem);
|
|
|
}
|
|
|
//更新账户余额
|
|
|
- int balancePayAmount=order.getBalancePayAmount();
|
|
|
- if(balancePayAmount>0){
|
|
|
- Member member=new Member();
|
|
|
- member.setUserOpenid(order.getSalesOpenid());
|
|
|
- member.setUserIncome(-balancePayAmount);
|
|
|
- memberService.updateUserIncomeByOpenId(member);
|
|
|
-
|
|
|
- //现金使用记录
|
|
|
- CashLog log=new CashLog();
|
|
|
- log.setCashLogsIntroduction("订单支出");
|
|
|
- log.setCashLogsNum(balancePayAmount);
|
|
|
- log.setCashLogsOpenid(member.getUserOpenid());
|
|
|
- log.setCashLogsType(2);
|
|
|
- log.setCashLogsResType(3);
|
|
|
- log.setCashLogsOrderid(order.getSalesOrderid());
|
|
|
- log.setCashLogsCreateDate(nowDate);
|
|
|
- count=cashLogService.addCashLog(log);
|
|
|
- }
|
|
|
- if (count < 1) {
|
|
|
- resXml = "<xml><return_code><![CDATA[FAIL]]></return_code><return_msg><![CDATA[报文有误]]></return_msg></xml>";
|
|
|
- }
|
|
|
+// int balancePayAmount=order.getBalancePayAmount();
|
|
|
+// if(balancePayAmount>0){
|
|
|
+// Member member=new Member();
|
|
|
+// member.setUserOpenid(order.getSalesOpenid());
|
|
|
+// member.setUserIncome(-balancePayAmount);
|
|
|
+// memberService.updateUserIncomeByOpenId(member);
|
|
|
+//
|
|
|
+// //现金使用记录
|
|
|
+// CashLog log=new CashLog();
|
|
|
+// log.setCashLogsIntroduction("订单支出");
|
|
|
+// log.setCashLogsNum(balancePayAmount);
|
|
|
+// log.setCashLogsOpenid(member.getUserOpenid());
|
|
|
+// log.setCashLogsType(2);
|
|
|
+// log.setCashLogsResType(3);
|
|
|
+// log.setCashLogsOrderid(order.getSalesOrderid());
|
|
|
+// log.setCashLogsCreateDate(nowDate);
|
|
|
+// count=cashLogService.addCashLog(log);
|
|
|
+// }
|
|
|
+// if (count < 1) {
|
|
|
+// resXml = "<xml><return_code><![CDATA[FAIL]]></return_code><return_msg><![CDATA[报文有误]]></return_msg></xml>";
|
|
|
+// }
|
|
|
|
|
|
- // 给订单的回调修改状态
|
|
|
+ // 批量修改产品销售量
|
|
|
try {
|
|
|
MQMessage message = new MQMessage();
|
|
|
message.setServiceToMessage(orderIdMD5);
|
|
@@ -230,9 +233,29 @@ public class ResponseWechatPayHandler {
|
|
|
message.setServiceType(1);
|
|
|
mQservice.insertMQMessage(message);
|
|
|
} catch (Exception e) {
|
|
|
- // TODO: handle exception
|
|
|
+ e.printStackTrace();
|
|
|
}
|
|
|
- System.out.println("被邀请人订单状态:"+o.getSalesIsSpellOrder()+"------------------------");
|
|
|
+
|
|
|
+ //订单结算获取获取积分
|
|
|
+ try{
|
|
|
+ Integer configId = 2; //日常 - 订单结算获取积分X*0.1
|
|
|
+ Promotions promotions = activityUtil.getAllPromotions();
|
|
|
+ if(promotions != null && promotions.getIntegralConfigList() !=null && promotions.getIntegralConfigList().size() > 0){
|
|
|
+ List<IntegralConfig> integralConfigList = promotions.getIntegralConfigList();
|
|
|
+ configId = integralConfigList.get(0).getInteConfId();
|
|
|
+ }
|
|
|
+
|
|
|
+ //获取积分
|
|
|
+ Integer flag = integralLogService.addOrderChangIntegra(o.getSalesOrderid(),configId);
|
|
|
+ if(flag < 1){
|
|
|
+ logger.info("订单获取积分失败,订单编号:"+o.getSalesOrderid());
|
|
|
+ }
|
|
|
+ }catch (Exception e){
|
|
|
+ logger.info("error+订单获取积分失败,订单编号:"+o.getSalesOrderid());
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
+
|
|
|
+ //RST推送订单
|
|
|
//拼单订单暂时不推送,拼单成功后推送
|
|
|
if(o.getSalesIsSpellOrder() == null || o.getSalesIsSpellOrder() == 2){
|
|
|
// 给rst推送订单
|
|
@@ -250,156 +273,151 @@ public class ResponseWechatPayHandler {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
|
}
|
|
|
+
|
|
|
/*Member members = WechatUtils.getUserBySession(request); */// 当前用户
|
|
|
/**
|
|
|
* 修改拼单信息并推送
|
|
|
*/
|
|
|
- System.out.println("被邀请人订单编号:"+o.getSalesSpellOrderId()+"------------------------");
|
|
|
- if(o.getSalesSpellOrderId() != null && !o.getSalesSpellOrderId().equals("")){
|
|
|
- //邀请人订单修改
|
|
|
- Order or1 = new Order();
|
|
|
- or1.setSalesOrderid(o.getSalesSpellOrderId());
|
|
|
- or1.setSalesStatus(2);
|
|
|
- or1.setSalesSpellOrderId(o.getSalesOrderid());
|
|
|
- cartService.updateOrderSpellOrderId(or1);//修改状态为已支付,待发货,关联拼单订单id
|
|
|
- //邀请人信息state
|
|
|
- Order orderOne = new Order();
|
|
|
- orderOne.setSalesOrderid(o.getSalesSpellOrderId());
|
|
|
- orderOne = cartService.selectOrderInfoById(orderOne);
|
|
|
- List<ShopOrderItemDto> orderItems1 = cartService.selectShopOrderItem(o.getSalesSpellOrderId());
|
|
|
- //邀请人信息end
|
|
|
- //被邀请人信息state
|
|
|
- Order orderTwo = new Order();
|
|
|
- orderTwo.setSalesOrderid(order.getSalesOrderid());
|
|
|
- orderTwo = cartService.selectOrderInfoById(orderTwo);
|
|
|
- List<ShopOrderItemDto> orderItems2 = cartService.selectShopOrderItem(o.getSalesOrderid());
|
|
|
-
|
|
|
- Member memberTwo = memberService.getMemberByUserOpenId(orderTwo.getSalesOpenid());
|
|
|
- //被邀请人信息end
|
|
|
- if(orderOne.getSalesOpenid() != null){
|
|
|
- Member memberOne = memberService.getMemberByUserOpenId(orderOne.getSalesOpenid());
|
|
|
- String name = "我";
|
|
|
- if(memberOne != null && !memberOne.getUserNickname().equals("")){
|
|
|
-
|
|
|
- try {
|
|
|
- name = URLDecoder.decode(memberOne.getUserNickname(),"UTF-8");
|
|
|
- } catch (UnsupportedEncodingException e) {
|
|
|
- e.printStackTrace();
|
|
|
- }
|
|
|
- }
|
|
|
- String names = name +","+(memberTwo.getUserNickname() == null? "微信好友": memberTwo.getUserNickname());
|
|
|
- try {
|
|
|
- names = name +","+(memberTwo.getUserNickname() == null? "微信好友": URLDecoder.decode(memberTwo.getUserNickname(),"UTF-8"));
|
|
|
- } catch (UnsupportedEncodingException e) {
|
|
|
- e.printStackTrace();
|
|
|
- }
|
|
|
- //推送微信模板消息
|
|
|
- try {
|
|
|
- sendMessageUtil.spellPush(
|
|
|
- "恭喜您与"+name+"拼单成功,点击逛逛更多好货吧。",
|
|
|
- orderItems1.get(0).getItemProductName(),
|
|
|
- names,
|
|
|
- "点击查看拼单详情>>",
|
|
|
- orderOne.getSalesOpenid(),
|
|
|
- ResultInfo.ORDER_GUOQI+"?salesStatus=2");
|
|
|
- }catch (Exception e){
|
|
|
- logger.info("推送拼单成功消息失败,失败openId:"+orderOne.getSalesOpenid());
|
|
|
- e.printStackTrace();
|
|
|
- }
|
|
|
- }
|
|
|
- // 给邀请人推送订单
|
|
|
- logger.info("微信账户支付推送拼单成功消息-------------------------------------------------3");
|
|
|
- try {
|
|
|
- MQMessage message = new MQMessage();
|
|
|
- message.setServiceToMessage(o.getSalesSpellOrderId());
|
|
|
- message.setServiceOtherMessage("efast.trade.new.add");
|
|
|
- message.setServiceIsSend(2); // 没有推送的信息
|
|
|
- message.setServiceStatus(1); // 推送成功
|
|
|
- message.setServiceType(1); // 添加订单信息
|
|
|
- message.setServiceHandlerObjectName("efastOrderServiceImpl");
|
|
|
- message.setServiceHandlerMethodName("addOrderInfoToEfast");
|
|
|
- mQservice.insertMQMessage(message);
|
|
|
- } catch (Exception e) {
|
|
|
- e.printStackTrace();
|
|
|
- }
|
|
|
-
|
|
|
-
|
|
|
- //被邀请人(当前)订单修改
|
|
|
- Order or2 = new Order();
|
|
|
- or2.setSalesOrderid(order.getSalesOrderid());
|
|
|
- or2.setSalesStatus(2);
|
|
|
- or2.setSalesSpellOrderId(orderOne.getSalesOrderid());
|
|
|
- cartService.updateOrderSpellOrderId(or2);
|
|
|
-
|
|
|
- if(o.getSalesOpenid() != null){
|
|
|
- Member memberOne = memberService.getMemberByUserOpenId(orderOne.getSalesOpenid());
|
|
|
- String name = "微信好友";
|
|
|
- if(memberOne != null && !memberOne.getUserNickname().equals("")){
|
|
|
- try {
|
|
|
- name = URLDecoder.decode(memberOne.getUserNickname(),"UTF-8");
|
|
|
- } catch (UnsupportedEncodingException e) {
|
|
|
- e.printStackTrace();
|
|
|
- }
|
|
|
- }
|
|
|
- String names = memberTwo.getUserNickname() == null? "我": memberTwo.getUserNickname() +","+name;
|
|
|
- try {
|
|
|
- names = memberTwo.getUserNickname() == null? "我": URLDecoder.decode(memberTwo.getUserNickname(),"UTF-8") +","+name;
|
|
|
- } catch (UnsupportedEncodingException e) {
|
|
|
- e.printStackTrace();
|
|
|
- }
|
|
|
- //推送微信模板消息
|
|
|
- logger.info("微信账户支付推送拼单成功消息-------------------------------------------------4");
|
|
|
- try {
|
|
|
- sendMessageUtil.spellPush(
|
|
|
- "恭喜您与"+name+"拼单成功,点击逛逛更多好货吧。",
|
|
|
- orderItems2.get(0).getItemProductName(),
|
|
|
- names,
|
|
|
- "点击查看拼单详情>>",
|
|
|
- o.getSalesOpenid(),
|
|
|
- ResultInfo.ORDER_GUOQI+"?salesStatus=2");
|
|
|
- }catch (Exception e){
|
|
|
- logger.info("推送拼单成功消息失败,失败openId:"+o.getSalesOpenid());
|
|
|
- e.printStackTrace();
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- // 给被邀请人推送订单
|
|
|
- try {
|
|
|
- MQMessage message = new MQMessage();
|
|
|
- message.setServiceToMessage(order.getSalesOrderid());
|
|
|
- message.setServiceOtherMessage("efast.trade.new.add");
|
|
|
- message.setServiceIsSend(2); // 没有推送的信息
|
|
|
- message.setServiceStatus(1); // 推送成功
|
|
|
- message.setServiceType(1); // 添加订单信息
|
|
|
- message.setServiceHandlerObjectName("efastOrderServiceImpl");
|
|
|
- message.setServiceHandlerMethodName("addOrderInfoToEfast");
|
|
|
- mQservice.insertMQMessage(message);
|
|
|
- } catch (Exception e) {
|
|
|
- e.printStackTrace();
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
-
|
|
|
+// System.out.println("被邀请人订单编号:"+o.getSalesSpellOrderId()+"------------------------");
|
|
|
+// if(o.getSalesSpellOrderId() != null && !o.getSalesSpellOrderId().equals("")){
|
|
|
+// //邀请人订单修改
|
|
|
+// Order or1 = new Order();
|
|
|
+// or1.setSalesOrderid(o.getSalesSpellOrderId());
|
|
|
+// or1.setSalesStatus(2);
|
|
|
+// or1.setSalesSpellOrderId(o.getSalesOrderid());
|
|
|
+// cartService.updateOrderSpellOrderId(or1);//修改状态为已支付,待发货,关联拼单订单id
|
|
|
+// //邀请人信息state
|
|
|
+// Order orderOne = new Order();
|
|
|
+// orderOne.setSalesOrderid(o.getSalesSpellOrderId());
|
|
|
+// orderOne = cartService.selectOrderInfoById(orderOne);
|
|
|
+// List<ShopOrderItemDto> orderItems1 = cartService.selectShopOrderItem(o.getSalesSpellOrderId());
|
|
|
+// //邀请人信息end
|
|
|
+// //被邀请人信息state
|
|
|
+// Order orderTwo = new Order();
|
|
|
+// orderTwo.setSalesOrderid(order.getSalesOrderid());
|
|
|
+// orderTwo = cartService.selectOrderInfoById(orderTwo);
|
|
|
+// List<ShopOrderItemDto> orderItems2 = cartService.selectShopOrderItem(o.getSalesOrderid());
|
|
|
+//
|
|
|
+// Member memberTwo = memberService.getMemberByUserOpenId(orderTwo.getSalesOpenid());
|
|
|
+// //被邀请人信息end
|
|
|
+// if(orderOne.getSalesOpenid() != null){
|
|
|
+// Member memberOne = memberService.getMemberByUserOpenId(orderOne.getSalesOpenid());
|
|
|
+// String name = "我";
|
|
|
+// if(memberOne != null && !memberOne.getUserNickname().equals("")){
|
|
|
+//
|
|
|
+// try {
|
|
|
+// name = URLDecoder.decode(memberOne.getUserNickname(),"UTF-8");
|
|
|
+// } catch (UnsupportedEncodingException e) {
|
|
|
+// e.printStackTrace();
|
|
|
+// }
|
|
|
+// }
|
|
|
+// String names = name +","+(memberTwo.getUserNickname() == null? "微信好友": memberTwo.getUserNickname());
|
|
|
+// try {
|
|
|
+// names = name +","+(memberTwo.getUserNickname() == null? "微信好友": URLDecoder.decode(memberTwo.getUserNickname(),"UTF-8"));
|
|
|
+// } catch (UnsupportedEncodingException e) {
|
|
|
+// e.printStackTrace();
|
|
|
+// }
|
|
|
+// //推送微信模板消息
|
|
|
+// try {
|
|
|
+// sendMessageUtil.spellPush(
|
|
|
+// "恭喜您与"+name+"拼单成功,点击逛逛更多好货吧。",
|
|
|
+// orderItems1.get(0).getItemProductName(),
|
|
|
+// names,
|
|
|
+// "点击查看拼单详情>>",
|
|
|
+// orderOne.getSalesOpenid(),
|
|
|
+// ResultInfo.ORDER_GUOQI+"?salesStatus=2");
|
|
|
+// }catch (Exception e){
|
|
|
+// logger.info("推送拼单成功消息失败,失败openId:"+orderOne.getSalesOpenid());
|
|
|
+// e.printStackTrace();
|
|
|
+// }
|
|
|
+// }
|
|
|
+// // 给邀请人推送订单
|
|
|
+// logger.info("微信账户支付推送拼单成功消息-------------------------------------------------3");
|
|
|
+// try {
|
|
|
+// MQMessage message = new MQMessage();
|
|
|
+// message.setServiceToMessage(o.getSalesSpellOrderId());
|
|
|
+// message.setServiceOtherMessage("efast.trade.new.add");
|
|
|
+// message.setServiceIsSend(2); // 没有推送的信息
|
|
|
+// message.setServiceStatus(1); // 推送成功
|
|
|
+// message.setServiceType(1); // 添加订单信息
|
|
|
+// message.setServiceHandlerObjectName("efastOrderServiceImpl");
|
|
|
+// message.setServiceHandlerMethodName("addOrderInfoToEfast");
|
|
|
+// mQservice.insertMQMessage(message);
|
|
|
+// } catch (Exception e) {
|
|
|
+// e.printStackTrace();
|
|
|
+// }
|
|
|
+//
|
|
|
+//
|
|
|
+// //被邀请人(当前)订单修改
|
|
|
+// Order or2 = new Order();
|
|
|
+// or2.setSalesOrderid(order.getSalesOrderid());
|
|
|
+// or2.setSalesStatus(2);
|
|
|
+// or2.setSalesSpellOrderId(orderOne.getSalesOrderid());
|
|
|
+// cartService.updateOrderSpellOrderId(or2);
|
|
|
+//
|
|
|
+// if(o.getSalesOpenid() != null){
|
|
|
+// Member memberOne = memberService.getMemberByUserOpenId(orderOne.getSalesOpenid());
|
|
|
+// String name = "微信好友";
|
|
|
+// if(memberOne != null && !memberOne.getUserNickname().equals("")){
|
|
|
+// try {
|
|
|
+// name = URLDecoder.decode(memberOne.getUserNickname(),"UTF-8");
|
|
|
+// } catch (UnsupportedEncodingException e) {
|
|
|
+// e.printStackTrace();
|
|
|
+// }
|
|
|
+// }
|
|
|
+// String names = memberTwo.getUserNickname() == null? "我": memberTwo.getUserNickname() +","+name;
|
|
|
+// try {
|
|
|
+// names = memberTwo.getUserNickname() == null? "我": URLDecoder.decode(memberTwo.getUserNickname(),"UTF-8") +","+name;
|
|
|
+// } catch (UnsupportedEncodingException e) {
|
|
|
+// e.printStackTrace();
|
|
|
+// }
|
|
|
+// //推送微信模板消息
|
|
|
+// logger.info("微信账户支付推送拼单成功消息-------------------------------------------------4");
|
|
|
+// try {
|
|
|
+// sendMessageUtil.spellPush(
|
|
|
+// "恭喜您与"+name+"拼单成功,点击逛逛更多好货吧。",
|
|
|
+// orderItems2.get(0).getItemProductName(),
|
|
|
+// names,
|
|
|
+// "点击查看拼单详情>>",
|
|
|
+// o.getSalesOpenid(),
|
|
|
+// ResultInfo.ORDER_GUOQI+"?salesStatus=2");
|
|
|
+// }catch (Exception e){
|
|
|
+// logger.info("推送拼单成功消息失败,失败openId:"+o.getSalesOpenid());
|
|
|
+// e.printStackTrace();
|
|
|
+// }
|
|
|
+// }
|
|
|
+//
|
|
|
+// // 给被邀请人推送订单
|
|
|
+// try {
|
|
|
+// MQMessage message = new MQMessage();
|
|
|
+// message.setServiceToMessage(order.getSalesOrderid());
|
|
|
+// message.setServiceOtherMessage("efast.trade.new.add");
|
|
|
+// message.setServiceIsSend(2); // 没有推送的信息
|
|
|
+// message.setServiceStatus(1); // 推送成功
|
|
|
+// message.setServiceType(1); // 添加订单信息
|
|
|
+// message.setServiceHandlerObjectName("efastOrderServiceImpl");
|
|
|
+// message.setServiceHandlerMethodName("addOrderInfoToEfast");
|
|
|
+// mQservice.insertMQMessage(message);
|
|
|
+// } catch (Exception e) {
|
|
|
+// e.printStackTrace();
|
|
|
+// }
|
|
|
+// }
|
|
|
|
|
|
try { //修改用户购买记录为已购买
|
|
|
memberService.updateIsBaughtByOpenid(wpr.getOpenid(), 2);
|
|
|
//更新用户绑定状态
|
|
|
- Member member = memberService.getMemberByUserOpenId(order.getSalesOpenid());
|
|
|
- if (member.getUserIsFlag()!= null && member.getUserIsFlag() == 1) {
|
|
|
- member.setUserIsFlag(2);//终身绑定
|
|
|
- homeService.updateMemberIsFlagByOpenid(member);
|
|
|
- }
|
|
|
- QrcodeResult qr = temporaryQrcodeService.applyTempQrcode(order.getSalesOpenid());//为用户生成二维码
|
|
|
- logger.info("为用户-->" + order.getSalesOpenid() + ",生成二维码:" + qr.getQroceUrl());
|
|
|
+// Member member = memberService.getMemberByUserOpenId(order.getSalesOpenid());
|
|
|
+// if (member.getUserIsFlag()!= null && member.getUserIsFlag() == 1) {
|
|
|
+// member.setUserIsFlag(2);//终身绑定
|
|
|
+// homeService.updateMemberIsFlagByOpenid(member);
|
|
|
+// }
|
|
|
+// QrcodeResult qr = temporaryQrcodeService.applyTempQrcode(order.getSalesOpenid());//为用户生成二维码
|
|
|
+// logger.info("为用户-->" + order.getSalesOpenid() + ",生成二维码:" + qr.getQroceUrl());
|
|
|
} catch (Exception e) {
|
|
|
System.out.println("修改已购买状态和终身绑定失败!");
|
|
|
e.printStackTrace();
|
|
|
}
|
|
|
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
} else {
|
|
|
resXml = "<xml><return_code><![CDATA[FAIL]]></return_code><return_msg><![CDATA[报文有误]]></return_msg></xml>";
|
|
|
logger.error(this, "订单:" + orderIdMD5 + "支付成功,但是没有通过校验!");
|
|
@@ -1093,29 +1111,113 @@ public class ResponseWechatPayHandler {
|
|
|
* @param orderId
|
|
|
* @return
|
|
|
*/
|
|
|
-// @ResponseBody
|
|
|
-// @RequestMapping(value = "/test_order")
|
|
|
-// public ResultMsg checkOrderPaySuccess(
|
|
|
-// @RequestParam(value = "orderId") String orderId) {
|
|
|
-// ResultMsg msg = new ResultMsg();
|
|
|
-//
|
|
|
-// // 给rst推送订单
|
|
|
+ @ResponseBody
|
|
|
+ @RequestMapping(value = "/test_order")
|
|
|
+ public ResultMsg checkOrderPaySuccess(
|
|
|
+ @RequestParam(value = "orderId") String orderId) {
|
|
|
+ ResultMsg msg = new ResultMsg();
|
|
|
+
|
|
|
+ String orderIdMD5 = orderId;
|
|
|
+
|
|
|
+ Order o = new Order();
|
|
|
+ o.setSalesOrderid(orderIdMD5);
|
|
|
+ o = cartService.selectOrderInfoById(o);
|
|
|
+
|
|
|
+ Date nowDate = new Date();
|
|
|
+ // 组装数据
|
|
|
+ Order order = new Order();
|
|
|
+ order.setSalesOrderid(orderIdMD5);
|
|
|
+ if(o.getSalesIsSpellOrder() != null && o.getSalesIsSpellOrder() == 1){
|
|
|
+ order.setSalesStatus(15); // 正在拼单
|
|
|
+ }else{
|
|
|
+ order.setSalesStatus(2); // 已支付
|
|
|
+ }
|
|
|
+
|
|
|
+ order.setSalesTransactionId("xxxxxxxxxxxxxxxxxx"); // 微信支付ID
|
|
|
+ order.setSalesTransactionDate(new Date()); // 微信支付时间
|
|
|
+ order.setSalesOpenid(o.getSalesOpenid());
|
|
|
+
|
|
|
+ // 修改订单状态
|
|
|
+ int count = cartService.updateOrderStatus(order);
|
|
|
+
|
|
|
+ //修改优惠券状态
|
|
|
+ order=cartService.selectOrderInfoById(order);
|
|
|
+ String couponId=order.getCouponId();
|
|
|
+ if(couponId!=null && !couponId.equals("")){
|
|
|
+ CouponItem couponItem=new CouponItem();
|
|
|
+ couponItem.setCouponItemId(couponId);
|
|
|
+ couponItem.setCouponUseStatus(2);
|
|
|
+ couponItem.setCouponUseDate(new Date());
|
|
|
+ couponItemService.updateCouponItemById(couponItem);
|
|
|
+ }
|
|
|
+ // 批量修改产品销售量
|
|
|
// try {
|
|
|
// MQMessage message = new MQMessage();
|
|
|
-// message.setServiceToMessage(orderId);
|
|
|
-// message.setServiceOtherMessage("efast.trade.new.add");
|
|
|
+// message.setServiceToMessage(orderIdMD5);
|
|
|
+// message.setServiceOtherMessage("xxxxxxxxxxxxxxxx");
|
|
|
// message.setServiceIsSend(2); // 没有推送的信息
|
|
|
// message.setServiceStatus(1); // 推送成功
|
|
|
-// message.setServiceType(1); // 添加订单信息
|
|
|
-// message.setServiceHandlerObjectName("efastOrderServiceImpl");
|
|
|
-// message.setServiceHandlerMethodName("addOrderInfoToEfast");
|
|
|
+// message.setServiceHandlerObjectName("cartServiceImpl");
|
|
|
+// message.setServiceHandlerMethodName("supdateStateByOrderId");
|
|
|
+// message.setServiceType(1);
|
|
|
// mQservice.insertMQMessage(message);
|
|
|
// } catch (Exception e) {
|
|
|
// e.printStackTrace();
|
|
|
// }
|
|
|
-//
|
|
|
-//
|
|
|
-// return msg;
|
|
|
-// }
|
|
|
+
|
|
|
+ //订单结算获取获取积分
|
|
|
+ try{
|
|
|
+ Integer configId = 2; //日常 - 订单结算获取积分X*0.1
|
|
|
+ Promotions promotions = activityUtil.getAllPromotions();
|
|
|
+ if(promotions != null && promotions.getIntegralConfigList() !=null && promotions.getIntegralConfigList().size() > 0){
|
|
|
+ List<IntegralConfig> integralConfigList = promotions.getIntegralConfigList();
|
|
|
+ configId = integralConfigList.get(0).getInteConfId();
|
|
|
+ }
|
|
|
+
|
|
|
+ //获取积分
|
|
|
+ Integer flag = integralLogService.addOrderChangIntegra(o.getSalesOrderid(),configId);
|
|
|
+ if(flag < 1){
|
|
|
+ logger.info("订单获取积分失败,订单编号:"+o.getSalesOrderid());
|
|
|
+ }
|
|
|
+ }catch (Exception e){
|
|
|
+ logger.info("error+订单获取积分失败,订单编号:"+o.getSalesOrderid());
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
+
|
|
|
+ //RST推送订单
|
|
|
+ //拼单订单暂时不推送,拼单成功后推送
|
|
|
+// if(o.getSalesIsSpellOrder() == null || o.getSalesIsSpellOrder() == 2){
|
|
|
+// // 给rst推送订单
|
|
|
+// try {
|
|
|
+// MQMessage message = new MQMessage();
|
|
|
+// message.setServiceToMessage(orderIdMD5);
|
|
|
+// message.setServiceOtherMessage("efast.trade.new.add");
|
|
|
+// message.setServiceIsSend(2); // 没有推送的信息
|
|
|
+// message.setServiceStatus(1); // 推送成功
|
|
|
+// message.setServiceType(1); // 添加订单信息
|
|
|
+// message.setServiceHandlerObjectName("efastOrderServiceImpl");
|
|
|
+// message.setServiceHandlerMethodName("addOrderInfoToEfast");
|
|
|
+// mQservice.insertMQMessage(message);
|
|
|
+// } catch (Exception e) {
|
|
|
+// e.printStackTrace();
|
|
|
+// }
|
|
|
+// }
|
|
|
+
|
|
|
+ try { //修改用户购买记录为已购买
|
|
|
+ memberService.updateIsBaughtByOpenid(o.getSalesOpenid(), 2);
|
|
|
+ //更新用户绑定状态
|
|
|
+// Member member = memberService.getMemberByUserOpenId(order.getSalesOpenid());
|
|
|
+// if (member.getUserIsFlag()!= null && member.getUserIsFlag() == 1) {
|
|
|
+// member.setUserIsFlag(2);//终身绑定
|
|
|
+// homeService.updateMemberIsFlagByOpenid(member);
|
|
|
+// }
|
|
|
+// QrcodeResult qr = temporaryQrcodeService.applyTempQrcode(order.getSalesOpenid());//为用户生成二维码
|
|
|
+// logger.info("为用户-->" + order.getSalesOpenid() + ",生成二维码:" + qr.getQroceUrl());
|
|
|
+ } catch (Exception e) {
|
|
|
+ System.out.println("修改已购买状态和终身绑定失败!");
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
+ return msg;
|
|
|
+ }
|
|
|
|
|
|
}
|