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

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;
import com.happy.Model.weixin.WechatUnifiedOrder;
import com.happy.Model.weixin.WeiXinUtil;
import com.happy.Until.*;
import com.happy.Until.Enum.B;
import com.happy.Until.Enum.OrderEnum;
import com.happy.Until.Enum.PayEnum;
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.http.Message2;
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;
import com.opensymphony.xwork2.ActionSupport;
import net.sf.json.JSONObject;
import org.apache.struts2.ServletActionContext;
import org.apache.struts2.interceptor.ServletRequestAware;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.BufferedReader;
import java.io.PrintWriter;
import java.text.ParseException;
import java.util.*;

/**
 * 订单进去Action请求交互
 */
public class AppBookingAction extends ActionSupport implements ServletRequestAware {

    private HttpServletRequest request;
    public HttpServletResponse response;

    @Resource
    public BookService bookService;
    @Resource
    public UserService userService;
    @Resource
    public AppBookService appBookService;
    @Resource
    public AdminManagerService adminManagerService;

    public int page; // 当前页
    public int rows;// 每页显示的行数rows
    public Integer id;
    public String status;
    public String hotelId; // 酒店id
    public String houseId; // 房型id
    public String startTime; // 订房开始时间
    public String endTime;   // 订房结束时间
    public String houseOrderNumber; // 订房数量
    public String userName; // 住客姓名
    public String userPhone; // 住客联系电话
    public String userId; // 下单人id

    public String getBookingId() {
        return bookingId;
    }

    public void setBookingId(String bookingId) {
        this.bookingId = bookingId;
    }

    private String bookingId; // 订单Id
    private String open_id; // 用户open_Id

    public HttpServletRequest getRequest() {
        return request;
    }

    public void setRequest(HttpServletRequest request) {
        this.request = request;
    }

    public void setServletRequest(HttpServletRequest request) {
        this.request = request;
    }

    public HttpServletResponse getResponse() {
        return response;
    }

    public void setResponse(HttpServletResponse response) {
        this.response = response;
    }

    public int getPage() {
        return page;
    }

    public void setPage(int page) {
        this.page = page;
    }

    public int getRows() {
        return rows;
    }

    public void setRows(int rows) {
        this.rows = rows;
    }

    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public String getStatus() {
        return status;
    }

    public void setStatus(String status) {
        this.status = status;
    }

    /**
     * 定时任务
     * @return
     */
    public String scheduledTasks()
    {
        // 获取所有的订单待支付状态
        StringBuffer strSqlBook = new StringBuffer();
        strSqlBook.append(" and order_status = '").append(PayEnum.ONE.getNum()).append("' ");
        List<Booking> bookingList = bookService.queryList(strSqlBook.toString());
        if (bookingList == null || bookingList.size() <= 0){
            return null;
        }

        try {
            for (Booking booking: bookingList) {
                if (booking == null  || Func.checkNull(booking.getCreateTime()) || Func.checkNull(booking.getLockTime()))
                    continue;

                Date createTime = DateUtil.parseDate(booking.getCreateTime(),DateUtil.Time_Formatter_Second);
                // 对订单时间进行累加
                String lockTime = TimeExchange.TimeRangeM(DateUtil.getFormatPaternDate(createTime),Func.parseInt(booking.getLockTime()));
                // 当前时间 大于 锁定时间 为true
                boolean flag = TimeExchange.CompareDate(lockTime, TimeExchange.getDate());
                if (flag)
                {
                    // 如果超时，则将订单状态修改为已超时
                    booking.setOrderStatus(Func.parseStr(PayEnum.SIX.getNum()));
                    booking.setUpdateTime(TimeExchange.getDate());
                    bookService.updateBooking(booking);
                    System.out.println("已将订单"+booking.getOrderNum()+"标识为支付超时");
                }
            }

        } catch (ParseException e) {
            e.printStackTrace();
        }

        return null;
    }



    /**
     * houseId; // 房型id
     * startTime; // 订房开始时间 2023/08/04
     * endTime;   // 订房结束时间 2023/08/05
     * houseOrderNumber; // 订房数量
     * userName; // 住客姓名
     * userPhone; // 住客联系电话
     * userId; // 下单人id
     * 用户点击订房操作，生成订单
     */
    public String createOrder() {
        // 插入订单数据到表中
        JSONObject jsonObject = new JSONObject();
        if (Func.checkNull(houseId) || Func.checkNull(startTime) || Func.checkNull(endTime)
                || Func.checkNull(houseOrderNumber) || Func.checkNull(userName) || Func.checkNull(userPhone) || Func.checkNull(userId)) {
            jsonObject.put(B.code, ResultStatusCode.BAD_REQUEST.getStatus());
            jsonObject.put(B.message, ResultStatusCode.BAD_REQUEST.getMsg());
            ResponseUtil.writeJson(ServletActionContext.getResponse(), jsonObject.toString());
            return null;
        }

        // 将时间统一转化为 yyyy/MM/dd
        String startDate = DateUtil.parseDateToStr((Func.parseDate(startTime)), DateUtil.Time_Formatter_Day);
        String endDate = DateUtil.parseDateToStr((Func.parseDate(endTime)), DateUtil.Time_Formatter_Day);

        // 创建订单之前，先验证是否有房间
        String backMessage = appBookService.varificationHouse(houseId, startDate, endDate);
        if (!Func.checkNull(backMessage)) {
            jsonObject.put(B.code, ResultStatusCode.CANNTBOOKING.getStatus());
            jsonObject.put(B.message, backMessage);
            ResponseUtil.writeJson(ServletActionContext.getResponse(), jsonObject.toString());
            return null;
        }

        String  bookingId= Func.parseStr(UUIDUtil.generateID());
        String mess = appBookService.createOrder(bookingId, houseId, startDate, endDate, houseOrderNumber, userName, userPhone, userId);
        if (!Func.checkNull(mess)) {
            jsonObject.put(B.code, ResultStatusCode.BAD_REQUEST.getStatus());
            jsonObject.put(B.message, mess);
            ResponseUtil.writeJson(ServletActionContext.getResponse(), jsonObject.toString());
            return null;
        }

        jsonObject.put(B.code, ResultStatusCode.OK.getStatus());
        jsonObject.put(B.message, ResultStatusCode.OK.getMsg());
        jsonObject.put(B.data, bookingId);
        ResponseUtil.writeJson(ServletActionContext.getResponse(), jsonObject.toString());
        return null;
    }

    /**
     * 再次预订
     *
     * @return
     */
    public String reCreateOrder() {
        // 插入订单数据到表中
        JSONObject jsonObject = new JSONObject();
        if (Func.checkNull(houseId) || Func.checkNull(startTime) || Func.checkNull(endTime)
                || Func.checkNull(houseOrderNumber) || Func.checkNull(userName) || Func.checkNull(userPhone) || Func.checkNull(userId)) {
            jsonObject.put(B.code, ResultStatusCode.BAD_REQUEST.getStatus());
            jsonObject.put(B.message, ResultStatusCode.BAD_REQUEST.getMsg());
            ResponseUtil.writeJson(ServletActionContext.getResponse(), jsonObject.toString());
            return null;
        }

        // 将时间统一转化为 yyyy/MM/dd
        String startDate = DateUtil.parseDateToStr((Func.parseDate(startTime)), DateUtil.Time_Formatter_Day);
        String endDate = DateUtil.parseDateToStr((Func.parseDate(endTime)), DateUtil.Time_Formatter_Day);

        // 创建订单之前，先验证是否有房间
        String backMessage = appBookService.varificationHouse(houseId, startDate, endDate);
        if (Func.checkNull(backMessage)) {
            jsonObject.put(B.code, ResultStatusCode.CANNTBOOKING.getStatus());
            jsonObject.put(B.message, backMessage);
            ResponseUtil.writeJson(ServletActionContext.getResponse(), jsonObject.toString());
            return null;
        }

        appBookService.reCreateOrder(houseId, startTime, endTime, houseOrderNumber, userName, userPhone, userId);

        jsonObject.put(B.code, ResultStatusCode.OK.getStatus());
        jsonObject.put(B.message, ResultStatusCode.OK.getMsg());
        ResponseUtil.writeJson(ServletActionContext.getResponse(), jsonObject.toString());
        return null;
    }

    /**
     * bookingId 订单id
     * open_id
     * 取消订单功能：
     * //1待支付,2已支付,3待入住,4已入住,5已消费,6支付超时,7已取消,8已退单,9已退款
     *
     * @return
     */
    public String cancelBooking() throws Exception {
        if (Func.checkNull(getBookingId()))
            return null;

        JSONObject jsonObject = new JSONObject();

        // 取消订单，修改订单的支付状态
        String mess = bookService.cancelBooking(getBookingId());
        if (!Func.checkNull(mess)) {
            jsonObject.put(B.code, ResultStatusCode.BAD_REQUEST.getStatus());
            jsonObject.put(B.message, mess);
            ResponseUtil.writeJson(ServletActionContext.getResponse(), jsonObject.toString());
            return null;
        }

        Booking booking = bookService.getById(Func.parseInt(this.bookingId));
        if (booking == null || Func.checkNull(booking.getRefundWay()))
            return null;

        // 进行判断如果订单是已取消，并且标识字段微信退款，则进入退款流程
        if (Func.parseStr(PayEnum.SEVEN.getNum()).equals(booking.getOrderStatus()) && OrderEnum.微信退款.toString().equals(booking.getRefundWay())) {
            if (Func.checkNull(this.open_id) || Func.checkNull(this.bookingId)) {
                jsonObject.put(B.code, ResultStatusCode.BAD_REQUEST.getStatus());
                jsonObject.put(B.message, ResultStatusCode.BAD_REQUEST.getMsg());
                ResponseUtil.writeJson(ServletActionContext.getResponse(), jsonObject.toString());
                return null;
            }

            Users users = userService.queryByOpenid(open_id); // 用户信息
            if (users == null || booking == null) {
                jsonObject.put(B.code, ResultStatusCode.BAD_REQUEST.getStatus());
                jsonObject.put(B.message, ResultStatusCode.BAD_REQUEST.getMsg());
                ResponseUtil.writeJson(ServletActionContext.getResponse(), jsonObject.toString());
                return null;
            }

            String ip = WeiXinUtil.ip;
            double money = booking.getPayAccount();
            int a = (int) (money * 100);
            WechatUnifiedOrder w = new WechatUnifiedOrder();
            w.setAppid(WeiXinUtil.appid_c);
            w.setAttach("chuanghai");
            w.setBody("chuanghai");
            w.setMch_id(WeiXinUtil.account);
            w.setNonce_str(PayWxUtil.getNonceStr());// 随机支付串
            w.setNotify_url(WeiXinUtil.ip_h + "/appquery_refund.action");// 支付结果回调地址
            w.setOpenid(open_id);
            w.setOut_trade_no(booking.getOrderNum());
            String refund_order = WxUtil.mchOrderNo();
            w.setOut_refund_no(refund_order);   // 退款单号
            w.setSpbill_create_ip(ip);
            w.setTotal_fee(a);
            w.setRefund_fee(a);   // 退款金额
            w.setTrade_type("JSAPI");
            SortedMap<String, String> params = new TreeMap<>();
            params.put("appid", w.getAppid());
            params.put("mch_id", w.getMch_id());
            params.put("nonce_str", w.getNonce_str());
            params.put("notify_url", w.getNotify_url());
            params.put("out_refund_no", w.getOut_refund_no());   // 退款单号
            params.put("out_trade_no", w.getOut_trade_no());
            params.put("refund_fee",w.getRefund_fee()+"");  // 退款金额
            params.put("total_fee", w.getTotal_fee() + "");

            w.setSign(PayWxUtil.getSign(params, WeiXinUtil.key));
            params.put("sign", w.getSign());
            //String retXml = JaxbUtil.getRequestXml(params);
            String xml = "<xml>" +
                    "<appid>" + w.getAppid() + "</appid>" +
                    "<mch_id>" + w.getMch_id() + "</mch_id>" +
                    "<nonce_str>" + w.getNonce_str() + "</nonce_str>" +
                    "<notify_url>" + w.getNotify_url() + "</notify_url>" +
                    "<out_refund_no>" + w.getOut_refund_no() + "</out_refund_no>" +
                    "<out_trade_no>" + w.getOut_trade_no() + "</out_trade_no>"	+
                    "<refund_fee>" + w.getRefund_fee()+"" + "</refund_fee>" +
                    "<total_fee>" + w.getTotal_fee() + "" + "</total_fee>" +
                    "<sign>" + w.getSign() + "</sign>"	+
                    "</xml>";
            //String msg = HttpsClient.sendPost2("https://api.mch.weixin.qq.com/secapi/pay/refund", retXml);
            String msg = HttpUtils.post2("https://api.mch.weixin.qq.com/secapi/pay/refund", xml);
            if (msg.indexOf("FAIL") > -1) {
                jsonObject.put("code", 507);
                jsonObject.put("message", "退款失败");
                ResUtil.writeJson(ServletActionContext.getResponse(), jsonObject.toString());
                return null;
            }

            // 设置订单状态为退款中
            booking.setOrderStatus(Func.parseStr(PayEnum.TEN.getNum()));
            booking.setUpdateTime(DateUtil.parseDateToStr(new Date(),DateUtil.Time_Formatter_Second));
            bookService.updateBooking(booking);  // 退款中

            jsonObject.put("code", 200);
            jsonObject.put("message", "退款申请已提交，请稍候查询");
            ResUtil.writeJson(ServletActionContext.getResponse(), jsonObject.toString());
            return null;
        }

        jsonObject.put(B.code, ResultStatusCode.OK.getStatus());
        jsonObject.put(B.message, ResultStatusCode.OK.getMsg());
        ResponseUtil.writeJson(ServletActionContext.getResponse(), jsonObject.toString());
        return null;
    }

    /**
     * open_id
     * bookingId
     * 微信退款功能
     */
    public String refundBooking() throws Exception {
        JSONObject resultJson = new JSONObject();
        if (Func.checkNull(this.open_id) || Func.checkNull(this.bookingId)) {
            resultJson.put(B.code, ResultStatusCode.BAD_REQUEST.getStatus());
            resultJson.put(B.message, ResultStatusCode.BAD_REQUEST.getMsg());
            ResponseUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
            return null;
        }

        Users users = userService.queryByOpenid(open_id); // 用户信息
        Booking booking = bookService.getById(Func.parseInt(bookingId)); // 订单信息
        if (users == null || booking == null) {
            resultJson.put(B.code, ResultStatusCode.BAD_REQUEST.getStatus());
            resultJson.put(B.message, ResultStatusCode.BAD_REQUEST.getMsg());
            ResponseUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
            return null;
        }

        String ip = WeiXinUtil.ip;
        double money = booking.getPayAccount();
        int a = (int) (money * 100);
        WechatUnifiedOrder w = new WechatUnifiedOrder();
        w.setAppid(WeiXinUtil.appid_c);
        w.setAttach("chuanghai");
        w.setBody("chuanghai");
        w.setMch_id(WeiXinUtil.account);
        w.setNonce_str(PayWxUtil.getNonceStr());// 随机支付串
        w.setNotify_url(WeiXinUtil.ip_h + "/appquery_refund.action");// 支付结果回调地址
        w.setOpenid(open_id);
        w.setOut_trade_no(booking.getOrderNum());
        String refund_order = WxUtil.mchOrderNo();
        w.setOut_refund_no(refund_order);   // 退款单号
        w.setSpbill_create_ip(ip);
        w.setTotal_fee(a);
        w.setRefund_fee(a);   // 退款金额
        w.setTrade_type("JSAPI");
        SortedMap<String, String> params = new TreeMap<>();
        params.put("appid", w.getAppid());
        params.put("mch_id", w.getMch_id());
        params.put("nonce_str", w.getNonce_str());
        params.put("notify_url", w.getNotify_url());
        params.put("out_refund_no", w.getOut_refund_no());   // 退款单号
        params.put("out_trade_no", w.getOut_trade_no());
        params.put("refund_fee",w.getRefund_fee()+"");  // 退款金额
        params.put("total_fee", w.getTotal_fee() + "");

        w.setSign(PayWxUtil.getSign(params, WeiXinUtil.key));
        params.put("sign", w.getSign());
        //String retXml = JaxbUtil.getRequestXml(params);
        String xml = "<xml>" +
                "<appid>" + w.getAppid() + "</appid>" +
                "<mch_id>" + w.getMch_id() + "</mch_id>" +
                "<nonce_str>" + w.getNonce_str() + "</nonce_str>" +
                "<notify_url>" + w.getNotify_url() + "</notify_url>" +
                "<out_refund_no>" + w.getOut_refund_no() + "</out_refund_no>" +
                "<out_trade_no>" + w.getOut_trade_no() + "</out_trade_no>"	+
                "<refund_fee>" + w.getRefund_fee()+"" + "</refund_fee>" +
                "<total_fee>" + w.getTotal_fee() + "" + "</total_fee>" +
                "<sign>" + w.getSign() + "</sign>"	+
                "</xml>";
        //String msg = HttpsClient.sendPost2("https://api.mch.weixin.qq.com/secapi/pay/refund", retXml);
        String msg = HttpUtils.post2("https://api.mch.weixin.qq.com/secapi/pay/refund", xml);
        if (msg.indexOf("FAIL") > -1) {
            resultJson.put("code", 507);
            resultJson.put("message", "退款失败");
            ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
            return null;
        }

        // 设置订单状态为退款中
        booking.setOrderStatus(Func.parseStr(PayEnum.TEN.getNum()));
        booking.setUpdateTime(DateUtil.parseDateToStr(new Date(),DateUtil.Time_Formatter_Second));
        bookService.updateBooking(booking);  // 退款中

        resultJson.put("code", 200);
        resultJson.put("message", "退款申请已提交，请稍候查询");
        ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
        return null;
    }

    /* 退款回调 */
    public String query_refund() throws Exception {

        // 查询本地数据库中，正在退款中
        StringBuffer strSqlBook = new StringBuffer();
        strSqlBook.append(" and order_status = '").append(PayEnum.TEN.getNum()).append("' ");
        List<Booking> booking = bookService.queryList(strSqlBook.toString());
        if (booking==null){
            return null;
        }
        WechatUnifiedOrder w = new WechatUnifiedOrder();
        Map<String, String> params = new HashMap<String, String>();
        Booking book = new Booking();
        for (int i = 0; i < booking.size(); i++) {
            if (booking.get(i) == null)
                continue;
            book = booking.get(i);
            w = new WechatUnifiedOrder();
            w.setAppid(WeiXinUtil.appid_c);
            w.setAttach("chuanghai");
            w.setBody("chuanghai");
            w.setMch_id(WeiXinUtil.account);
            w.setNonce_str(PayWxUtil.getNonceStr());// 随机支付串
            w.setOut_trade_no(book.getOrderNum());
            w.setTrade_type("JSAPI");
            params = new HashMap<String, String>();
            params.put("appid", w.getAppid());
            params.put("mch_id", w.getMch_id());
            params.put("out_trade_no", w.getOut_trade_no());
            params.put("nonce_str", w.getNonce_str());
            w.setSign(PayWxUtil.getSign(params, WeiXinUtil.key));
            params.put("sign", w.getSign());
            String retXml = JaxbUtil.getRequestXml(params);
            String msg = HttpUtils.post("https://api.mch.weixin.qq.com/pay/refundquery", retXml);
            if (msg.indexOf("<refund_status_0><![CDATA[SUCCESS]]></refund_status_0>")>0) {
                // 退款成功，将数据写入本地数据库
                book.setRefundTime(DateUtil.parseDateToStr(new Date(),DateUtil.Time_Formatter_Second));
                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>";
        HttpServletResponse response = ServletActionContext.getResponse();
        response.setContentType("text/html;charset=utf-8");
        PrintWriter out = response.getWriter();
        out.println(returnMsg);
        out.flush();
        out.close();

        return null;
    }



    /**
     * bookingId 订单id
     * 删除订单功能(假删除)
     *
     * @return
     */
    public String delBooking() {
        if (Func.checkNull(getBookingId()))
            return null;

        JSONObject jsonObject = new JSONObject();

        String mess = bookService.delBooking(getBookingId());
        if (!Func.checkNull(mess)) {
            jsonObject.put(B.code, ResultStatusCode.BAD_REQUEST.getStatus());
            jsonObject.put(B.message, mess);
            ResponseUtil.writeJson(ServletActionContext.getResponse(), jsonObject.toString());
            return null;
        }

        jsonObject.put(B.code, ResultStatusCode.OK.getStatus());
        jsonObject.put(B.message, ResultStatusCode.OK.getMsg());
        ResponseUtil.writeJson(ServletActionContext.getResponse(), jsonObject.toString());
        return null;
    }


    /**
     * 验证是否有房间
     * houseId, 房型id
     * startTime, 开始时间
     * endTime 结束时间
     *
     * @return
     */
    public String varificationHouse() {
        JSONObject jsonObject = new JSONObject();
        if (Func.checkNull(houseId) || Func.checkNull(startTime) || Func.checkNull(endTime)) {
            jsonObject.put(B.code, ResultStatusCode.BAD_REQUEST.getStatus());
            jsonObject.put(B.message, ResultStatusCode.BAD_REQUEST.getMsg());
            ResponseUtil.writeJson(ServletActionContext.getResponse(), jsonObject.toString());
            return null;
        }

        String backMessage = appBookService.varificationHouse(houseId, startTime, endTime);

        if (!Func.checkNull(backMessage)) {
            jsonObject.put(B.code, ResultStatusCode.BAD_REQUEST.getStatus());
            jsonObject.put(B.message, backMessage);
            ResponseUtil.writeJson(ServletActionContext.getResponse(), jsonObject.toString());
            return null;
        }

        jsonObject.put(B.code, ResultStatusCode.OK.getStatus());
        jsonObject.put(B.message, OrderEnum.有空房.toString());
        ResponseUtil.writeJson(ServletActionContext.getResponse(), jsonObject.toString());
        return null;
    }


    /**
     * open_id
     * bookingId
     * 用户支付操作
     *
     * @return
     */
    public String pay() {
        JSONObject resultjson = new JSONObject();
        if (Func.checkNull(this.open_id) || Func.checkNull(this.bookingId)) {
            resultjson.put(B.code, ResultStatusCode.BAD_REQUEST.getStatus());
            resultjson.put(B.message, ResultStatusCode.BAD_REQUEST.getMsg());
            ResponseUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString());
            return null;
        }

        Users users = userService.queryByOpenid(open_id); // 用户信息
        Booking booking = bookService.getById(Func.parseInt(bookingId)); // 订单信息
        if (users == null || booking == null) {
            resultjson.put(B.code, ResultStatusCode.BAD_REQUEST.getStatus());
            resultjson.put(B.message, ResultStatusCode.BAD_REQUEST.getMsg());
            ResponseUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString());
            return null;
        }

        try {
            // 支付费用
            Double totalPrice = booking.getHouseTotalPrice() * 100;
            int totalfee = Func.parseInt(totalPrice);

            WechatUnifiedOrder w = new WechatUnifiedOrder();
            w.setAppid(WeiXinUtil.appid_c);
            w.setAttach("chuanghai");
            w.setBody("chuanghai");
            w.setMch_id(WeiXinUtil.account);
            w.setNonce_str(PayWxUtil.getNonceStr());// 随机支付串
            w.setNotify_url(WeiXinUtil.ip_h + "/abkpayResulet.action");// 支付结果回调地址
            w.setOpenid(this.open_id);
            String orderNo = booking.getOrderNum(); // 订单编号
            w.setOut_trade_no(orderNo);
            w.setSpbill_create_ip(WeiXinUtil.ip);
            w.setTotal_fee(totalfee);
            w.setTrade_type("JSAPI");
            Map<String, String> params = new HashMap<String, String>();
            params.put("attach", w.getAttach());
            params.put("appid", w.getAppid());
            params.put("mch_id", w.getMch_id());
            params.put("nonce_str", w.getNonce_str());
            params.put("body", w.getBody());
            params.put("out_trade_no", w.getOut_trade_no());
            params.put("total_fee", Func.parseStr(w.getTotal_fee()));
            params.put("spbill_create_ip", w.getSpbill_create_ip());
            params.put("notify_url", w.getNotify_url());
            params.put("trade_type", w.getTrade_type());
            params.put("openid", w.getOpenid());
            w.setSign(PayWxUtil.getSign(params, WeiXinUtil.key));
            params.put("sign", w.getSign());
            String retXml = JaxbUtil.getRequestXml(params);
            String msg = HttpUtils.post("https://api.mch.weixin.qq.com/pay/unifiedorder", retXml);
            System.out.println(msg);
            // 支付失败
            if (msg.indexOf("FAIL") > -1) {
                resultjson.put("code", "205");
                resultjson.put("message", "支付异常205");
                ResUtil.write(resultjson, ServletActionContext.getResponse());
                return null;
            }

            JaxbUtil requestBinder = new JaxbUtil(TongYiReturn.class, JaxbUtil.CollectionWrapper.class);
            TongYiReturn to = requestBinder.fromXml(msg);
            // 支付成功
            if (to.getReturn_code().equals("SUCCESS") && to.getResult_code().equals("SUCCESS")) {
                EndPay pay = new EndPay();
                pay.setAppId(WeiXinUtil.appid_c);
                pay.setSignType("MD5");
                pay.setTimeStamp(System.currentTimeMillis() / 1000 + "");
                pay.setPrepay_id(to.getPrepay_id());
                pay.setNonceStr(PayWxUtil.getNonceStr());
                Map<String, String> requestMap = new HashMap<String, String>();
                requestMap.put("appId", pay.getAppId());
                requestMap.put("timeStamp", pay.getTimeStamp());
                requestMap.put("nonceStr", pay.getNonceStr());
                requestMap.put("package", "prepay_id=" + pay.getPrepay_id());
                requestMap.put("signType", "MD5");
                pay.setPaySign(PayWxUtil.getSign(requestMap, WeiXinUtil.key));
                // 返回支付参数
                resultjson.put("code", 200);
                resultjson.put("message", "返回成功");
                resultjson.put("data", pay);
                ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString());

                // 保存支付信息
                booking.setUpdateTime(DateUtil.getFormatPaternDate(new Date()));
                booking.setOrderStatus(Func.parseStr(PayEnum.ONE.getNum()));
                booking.setPayTime(DateUtil.getFormatPaternDate(new Date()));
                booking.setPayAccount(totalPrice);
                booking.setPayWay(OrderEnum.微信支付.toString());
                bookService.updateBooking(booking);

                resultjson.put(B.code, ResultStatusCode.OK.getStatus());
                resultjson.put(B.message, "支付成功");
                ResponseUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString());
            }
        } catch (Exception e) {
            resultjson.put(B.code, ResultStatusCode.BAD_REQUEST.getStatus());
            resultjson.put(B.message, e.getMessage());
            ResponseUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString());
        }
        return null;
    }

    /**
     *  支付成功后回调,推送消息给商家
     *
     */
    public String payResulet(){
        System.out.println("进入支付回调====");
        JSONObject resultjson = new JSONObject();
        try{
            BufferedReader reader = null;// BufferedReader 字符输入流
            reader = request.getReader();
            String line = "";
            String xmlString = null;
            StringBuilder inputString = new StringBuilder();
            while ((line = reader.readLine()) != null) {
                inputString.append(line);
            }
            xmlString = inputString.toString();
            request.getReader().close();
            JaxbUtil requestBinder = new JaxbUtil(PayResult.class, PayResult.class);
            PayResult result = requestBinder.fromXml(xmlString);// Xml到Java，用fromXML()方法
            String order_num = result.getOut_trade_no();
            System.out.println("支付成功回调，订单号："+order_num);
            Booking booking = bookService.queryByOrder(order_num);
            // 支付成功
            if (result.getResult_code().equals("SUCCESS") && booking!=null && booking.getOrderStatus().equals("1")) {
                // 保存支付信息
                booking.setUpdateTime(DateUtil.getFormatPaternDate(new Date()));
                booking.setOrderStatus(Func.parseStr(PayEnum.TWO.getNum()));
                booking.setPayTime(DateUtil.getFormatPaternDate(new Date()));
                booking.setPayWay(OrderEnum.微信支付.toString());
                // 进行业务判断，如果是商家设定了自动接单，则支付状态直接变为待入住  接单设置（1自动接单 2手动接单）
                if ("1".equals(booking.getHotelIsCanorder()))
                {
                    // 自动接单，订单状态修改为待入住
                    booking.setOrderStatus(Func.parseStr(PayEnum.THREE.getNum()));
//                    String userId = booking.getCreateUserid();
//                    Users users = userService.queryByUserId(userId);
//                    String mess = "您已成功订房，订单号："+order_num;
//                    Message.send(users.getOpenid(),order_num, users.getUser_name(),mess, booking.getPayTime());
                }

                // 手动接单，发消息给商家
                AdminManager adminManager = adminManagerService.getById(Func.parseInt(booking.getHotelManagerId()));
                String live_end = booking.getOrderStartTime() +"~"+  booking.getOrderEndTime();
                String hotelName = "";
                if (Func.checkNull(booking.getHotelName()))
                {
                    hotelName = booking.getHouseName();
                }

                Message2.send(adminManager.getOpenid(),order_num,booking.getHouseName(),live_end,booking.getUserName(),hotelName);

                int m = bookService.updateBooking(booking);
                if (m>0){
                    String returnMsg = "<xml><return_code><![CDATA[SUCCESS]]></return_code><return_msg><![CDATA[OK]]></return_msg></xml>";
                    HttpServletResponse response = ServletActionContext.getResponse();
                    response.setContentType("text/html;charset=utf-8");
                    PrintWriter out = response.getWriter();
                    out.println(returnMsg);
                    out.flush();
                    out.close(); // 发送成功消息给商家
                }
                return null;
            }
        } catch (Exception e){
            resultjson.put("message", "支付失败");
            resultjson.put("code", 205);
            ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString());
            return null;
        }
        resultjson.put("message", "支付失败");
        resultjson.put("code", 205);
        ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString());
        return null;
    }




    public String getOpen_id() {
        return open_id;
    }

    public void setOpen_id(String open_id) {
        this.open_id = open_id;
    }
}