消息推送

mhotel/src/com/happy/action/AppBookingAction.java

@@ -1,5 +1,6 @@
 package com.happy.action;
 
+import com.happy.Model.AdminManager;
 import com.happy.Model.Booking;
 import com.happy.Model.weixin.PayResult;
 import com.happy.Model.weixin.Users;
@@ -13,8 +14,10 @@ import com.happy.Until.weixin.EndPay;
 import com.happy.Until.weixin.JaxbUtil;
 import com.happy.Until.weixin.PayWxUtil;
 import com.happy.Until.weixin.TongYiReturn;
+import com.happy.common.http.Message;
 import com.happy.common.wx.WxUtil;
 import com.happy.constant.ResultStatusCode;
+import com.happy.service.AdminManagerService;
 import com.happy.service.AppBookService;
 import com.happy.service.BookService;
 import com.happy.service.UserService;
@@ -44,6 +47,8 @@ public class AppBookingAction extends ActionSupport implements ServletRequestAwa
     public UserService userService;
     @Resource
     public AppBookService appBookService;
+    @Resource
+    public AdminManagerService adminManagerService;
 
     public int page; // 当前页
     public int rows;// 每页显示的行数rows
@@ -445,6 +450,17 @@ public class AppBookingAction extends ActionSupport implements ServletRequestAwa
                 book.setRefundAmount(book.getHouseTotalPrice());
                 book.setUpdateTime(DateUtil.parseDateToStr(new Date(),DateUtil.Time_Formatter_Second));
                 bookService.updateBooking(book);
+
+
+                // 发送成功消息给商家和用户
+                AdminManager adminManager = adminManagerService.getById(Func.parseInt(book.getHotelManagerId()));
+                Users users = userService.queryByUserId(book.getCreateUserid());
+                String sendMsg = "订单:"+ book.getOrderNum() +"已退款成功，请注意查看";
+                // 推给商家
+                Message.send(adminManager.getOpenid(),book.getOrderNum(),book.getUserName(),sendMsg,book.getCreateTime());
+                // 推给用户
+                Message.send(users.getOpenid(),book.getOrderNum(),book.getUserName(),sendMsg,book.getCreateTime());
+
             }
         }
         String returnMsg = "<xml><return_code><![CDATA[SUCCESS]]></return_code><return_msg><![CDATA[OK]]></return_msg></xml>";
@@ -453,7 +469,8 @@ public class AppBookingAction extends ActionSupport implements ServletRequestAwa
         PrintWriter out = response.getWriter();
         out.println(returnMsg);
         out.flush();
-        out.close(); // 发送成功消息给商家
+        out.close();
+
         return null;
     }
 
@@ -671,7 +688,12 @@ public class AppBookingAction extends ActionSupport implements ServletRequestAwa
                 return null;
             }
 
-            // 推送消息给商家 TODO
+            AdminManager adminManager = adminManagerService.getById(Func.parseInt(booking.getHotelManagerId()));
+            String sendMsg = "订单:"+ order_num +"已支付，请确认是否接单";
+             // 推送消息给商家 TODO
+            Message.send(adminManager.getOpenid(),booking.getOrderNum(),booking.getUserName(),sendMsg,booking.getCreateTime());
+
+
         } catch (Exception e){
             resultjson.put("message", "支付失败");
             resultjson.put("code", 205);

mhotel/src/com/happy/service/BookService.java

@@ -79,7 +79,7 @@ public interface BookService {
      * @param bookingId
      * @return
      */
-    String cancelBooking(String bookingId);
+    String cancelBooking(String bookingId) throws Exception;
 
     /**
      * 删除订单(假删除)

mhotel/src/com/happy/service/impl/BookImplService.java

@@ -1,13 +1,16 @@
 package com.happy.service.impl;
 
+import com.happy.Model.AdminManager;
 import com.happy.Model.Booking;
 import com.happy.Until.DateUtil;
 import com.happy.Until.Enum.OrderEnum;
 import com.happy.Until.Enum.PayEnum;
 import com.happy.Until.Func;
+import com.happy.common.http.Message;
 import com.happy.dao.BookDao;
 import com.happy.dto.BookTypeEto;
 import com.happy.dto.IPage;
+import com.happy.service.AdminManagerService;
 import com.happy.service.BookService;
 import org.springframework.stereotype.Service;
 
@@ -21,6 +24,8 @@ public class BookImplService implements BookService {
 
     @Resource
     public BookDao bookDao;
+    @Resource
+    public AdminManagerService adminManagerService;
 
     @Override
     public int insertBooking(Booking book) {
@@ -78,7 +83,7 @@ public class BookImplService implements BookService {
     }
 
     @Override
-    public String cancelBooking(String bookingId) {
+    public String cancelBooking(String bookingId) throws Exception {
         if (Func.checkNull(bookingId))
             return "未传入订单id";
 
@@ -87,15 +92,22 @@ public class BookImplService implements BookService {
         if (Func.parseInt(book.getHotelIsCanorder()) == 2)
             return "商家设置不可取消订单，请联系商家";
 
-        //1待支付,2已支付,3待入住,4已入住,5已消费,6支付超时,7已取消,8已退单,9已退款
+        AdminManager adminManager = adminManagerService.getById(Func.parseInt(book.getHotelManagerId()));
+        //1待支付,2已支付,3待入住,4已入住,5已消费,6支付超时,7已取消,8已退单,9已退款,10退款中
         int status = Func.parseInt(book.getOrderStatus());
         if (status == 1)
         {
             book.setOrderStatus(Func.parseStr(PayEnum.SEVEN.getNum()));
             book.setUpdateTime(DateUtil.getFormatPaternDate(new Date()));
             bookDao.updateBooking(book);
+
+
+            String sendMsg = "订单:"+ book.getOrderNum() +"已取消";
+            // 推送消息给用户
+            Message.send(adminManager.getOpenid(),book.getOrderNum(),book.getUserName(),sendMsg,book.getCreateTime());
+
             return null;
-        }else if (status == 2 || status == 3)
+        }else if (status == 2)
         {
             book.setOrderStatus(Func.parseStr(PayEnum.SEVEN.getNum()));
             book.setUpdateTime(DateUtil.getFormatPaternDate(new Date()));
@@ -103,6 +115,10 @@ public class BookImplService implements BookService {
             book.setPayWay(OrderEnum.微信退款.toString());
             bookDao.updateBooking(book);
             // 走退款操作
+
+            String sendMsg = "订单:"+ book.getOrderNum() +"已取消";
+            // 推送消息给用户
+            Message.send(adminManager.getOpenid(),book.getOrderNum(),book.getUserName(),sendMsg,book.getCreateTime());
             return null;
         }
         return "不可取消订单";