puzhibing
2023-08-22 00caef45a8833dc58919e23eb88a3484cfacdaa4
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
package com.stylefeng.guns.modular.system.service.impl;
 
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.stylefeng.guns.core.util.ToolUtil;
import com.stylefeng.guns.modular.crossCity.server.IOrderCrossCityService;
import com.stylefeng.guns.modular.smallLogistics.model.OrderLogistics;
import com.stylefeng.guns.modular.smallLogistics.server.IOrderLogisticsService;
import com.stylefeng.guns.modular.specialTrain.model.OrderPrivateCar;
import com.stylefeng.guns.modular.specialTrain.server.IOrderPrivateCarService;
import com.stylefeng.guns.modular.system.model.Car;
import com.stylefeng.guns.modular.system.model.UserInfo;
import com.stylefeng.guns.modular.system.service.ICarService;
import com.stylefeng.guns.modular.system.service.IOrderService;
import com.stylefeng.guns.modular.system.service.IUserInfoService;
import com.stylefeng.guns.modular.system.util.ChinaMobileUtil;
import com.stylefeng.guns.modular.system.util.GDMapElectricFenceUtil;
import com.stylefeng.guns.modular.system.util.GoogleMap.DistancematrixVo;
import com.stylefeng.guns.modular.system.util.GoogleMap.GoogleMapUtil;
import com.stylefeng.guns.modular.system.util.ResultUtil;
import com.stylefeng.guns.modular.system.warpper.BaseWarpper;
import com.stylefeng.guns.modular.taxi.service.IOrderTaxiService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.stereotype.Service;
import org.springframework.util.LinkedMultiValueMap;
import org.springframework.util.MultiValueMap;
import org.springframework.web.client.RestTemplate;
 
import java.util.HashMap;
import java.util.Map;
 
 
@Service
public class OrderServiceImpl implements IOrderService {
 
    @Autowired
    private IOrderTaxiService orderTaxiService;
 
    @Autowired
    private RestTemplate internalRestTemplate;
 
    @Autowired
    private ChinaMobileUtil chinaMobileUtil;
 
    @Autowired
    private IUserInfoService userInfoService;
 
    @Autowired
    private GDMapElectricFenceUtil gdMapElectricFenceUtil;
 
    @Autowired
    private IOrderCrossCityService orderCrossCityService;
 
    @Autowired
    private IOrderPrivateCarService orderPrivateCarService;
 
    @Autowired
    private IOrderLogisticsService orderLogisticsService;
 
    @Autowired
    private ICarService carService;
 
 
    /**
     * 获取预计行驶时间
     * @param slon  起点经度
     * @param slat  起点纬度
     * @param elon  终点经度
     * @param elat  终点纬度
     * @return
     * @throws Exception
     */
    @Override
    public ResultUtil<BaseWarpper> queryExpectedTime(Double slon, Double slat, Double elon, Double elat) throws Exception {
        DistancematrixVo distancematrix = GoogleMapUtil.getDistancematrix(slat, slon, elat, elon);
        Long duration = distancematrix.getDuration() / 60;
        BaseWarpper baseWarpper = new BaseWarpper();
        baseWarpper.setMinute(duration.intValue());
        return ResultUtil.success(baseWarpper);
    }
 
    /**
     * APP调用微信小程序完成支付
     * @param orderId
     * @param orderType
     * @param type
     * @return
     * @throws Exception
     */
    @Override
    public ResultUtil weChatPay(Integer orderId, Integer orderType, Integer type, Integer userType, Integer uid, String content, Integer language) throws Exception {
        JSONObject jsonObject = JSON.parseObject(content);
        switch (type){
            case 1://订单完成支付
//                switch (orderType){
//                    case 1:
//                        return orderPrivateCarService.payPrivateCarOrder(1, orderId, (null == jsonObject ? null : jsonObject.getIntValue("couponId")), 3, 1);
//                    case 2:
//                        return orderTaxiService.payTaxiOrder(1, orderId, (null == jsonObject ? null : jsonObject.getIntValue("couponId")), 3);
//                    case 3:
//                        return orderCrossCityService.payCrossCityOrder(1, orderId, (null == jsonObject ? null : jsonObject.getIntValue("couponId")), 3);
//                    case 4:
//                        return orderLogisticsService.payLogisticsOrder(1, orderId, 3, 1);
//                    case 5:
//                        return orderLogisticsService.payLogisticsOrder(1, orderId, 3, 1);
//                }
            case 2://订单取消支付
                switch (orderType){
                    case 1:
//                        return orderPrivateCarService.cancleOrderPrivateCar(orderId, 1, null == jsonObject ? null : jsonObject.getIntValue("cancelId"), 3);
                    case 2:
                        return orderTaxiService.cancleOrderTaxi(orderId, 1, null == jsonObject ? null : jsonObject.getIntValue("cancelId"), 3, language);
                    case 3:
                        return orderCrossCityService.cancleOrderCrossCity(orderId, 1, null == jsonObject ? null : jsonObject.getIntValue("cancelId"), 3, language);
                }
 
            case 3://司机端改派支付
                HttpHeaders headers = new HttpHeaders();
                // 以表单的方式提交
                headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
                //将请求头部和参数合成一个请求
                MultiValueMap<String, Object> params = new LinkedMultiValueMap<>();
                params.add("orderId", orderId.toString());
                params.add("orderType", orderType.toString());
                params.add("payType", "1");
                params.add("reason", null == jsonObject ? "" : jsonObject.getString("reason"));
                params.add("remark", null == jsonObject ? "" : jsonObject.getString("remark"));
                params.add("uid", jsonObject.getString("uid"));
                HttpEntity<MultiValueMap<String, Object>> requestEntity = new HttpEntity<>(params, headers);
                String s = internalRestTemplate.postForObject("http://driver-server/base/order/reassign_", requestEntity, String.class);
                JSONObject jsonObject1 = JSON.parseObject(s, JSONObject.class);
                return ResultUtil.success(jsonObject1.getString("msg"), jsonObject1.getString("data"));
            case 4://余额充值
                if(userType == 1){
//                    return userInfoService.depositBalance(1, jsonObject.getDoubleValue("money"), uid, 3, 1);
                }
                if(userType == 2){
 
                }
            case 5://小件物流补差价
//                return orderLogisticsService.payLogisticsOrder_(1, orderId, 3);
        }
        return ResultUtil.success();
    }
 
 
    /**
     * 获取订单车牌信息
     * @param orderType
     * @param orderId
     * @return
     */
    @Override
    public Map<String, Object> queryOrderLicensePlate(Integer orderType, Integer orderId) {
        Map<String, Object> map = new HashMap<>();
        if(orderType == 1){
            OrderPrivateCar orderPrivateCar = orderPrivateCarService.selectById(orderId);
            if(null != orderPrivateCar.getCarId()){
                Car car = carService.selectById(orderPrivateCar.getCarId());
                map.put("licensePlate", car.getCarLicensePlate());
            }
            map.put("userName", orderPrivateCar.getPassengers());
            map.put("phone", orderPrivateCar.getPassengersPhone());
        }
        if(orderType == 4){
            OrderLogistics orderLogistics = orderLogisticsService.selectById(orderId);
            if(null != orderLogistics.getCarId()){
                Car car = carService.selectById(orderLogistics.getCarId());
                map.put("licensePlate", car.getCarLicensePlate());
            }
            if(null != orderLogistics.getUserId()){
                UserInfo userInfo = userInfoService.selectById(orderLogistics.getUserId());
                map.put("userName", ToolUtil.isEmpty(userInfo.getFirstName()) ? userInfo.getNickName() : userInfo.getFirstName() + " " + userInfo.getLastName());
                map.put("phone", userInfo.getPhone());
            }
        }
        return map;
    }
}