package com.stylefeng.guns.modular.smallLogistics.server.impl;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
import com.baomidou.mybatisplus.service.impl.ServiceImpl;
|
import com.stylefeng.guns.core.util.ToolUtil;
|
import com.stylefeng.guns.modular.account.controller.AppOrderController;
|
import com.stylefeng.guns.modular.crossCity.dao.OrderCrossCityMapper;
|
import com.stylefeng.guns.modular.crossCity.model.OrderCrossCity;
|
import com.stylefeng.guns.modular.crossCity.server.IOrderCrossCityService;
|
import com.stylefeng.guns.modular.smallLogistics.dao.OrderLogisticsMapper;
|
import com.stylefeng.guns.modular.smallLogistics.model.OrderLogistics;
|
import com.stylefeng.guns.modular.smallLogistics.model.OrderLogisticsSpread;
|
import com.stylefeng.guns.modular.smallLogistics.server.IOrderLogisticsService;
|
import com.stylefeng.guns.modular.smallLogistics.server.IOrderLogisticsSpreadService;
|
import com.stylefeng.guns.modular.specialTrain.dao.OrderPrivateCarMapper;
|
import com.stylefeng.guns.modular.specialTrain.model.OrderPrivateCar;
|
import com.stylefeng.guns.modular.specialTrain.server.IOrderPrivateCarService;
|
import com.stylefeng.guns.modular.system.dao.*;
|
import com.stylefeng.guns.modular.system.model.*;
|
import com.stylefeng.guns.modular.system.service.*;
|
import com.stylefeng.guns.modular.system.util.*;
|
import com.stylefeng.guns.modular.system.warpper.BaseWarpper;
|
import com.stylefeng.guns.modular.system.warpper.CouponsListVo;
|
import com.stylefeng.guns.modular.system.warpper.PreferentialDataVo;
|
import com.stylefeng.guns.modular.taxi.dao.OrderTaxiMapper;
|
import com.stylefeng.guns.modular.taxi.model.OrderTaxi;
|
import com.stylefeng.guns.modular.taxi.model.PaymentRecord;
|
import com.stylefeng.guns.modular.taxi.service.IOrderTaxiService;
|
import com.stylefeng.guns.modular.taxi.service.IPaymentRecordService;
|
import com.stylefeng.guns.modular.taxi.service.ITransactionDetailsService;
|
import com.unionpay.upyzt.exception.UpyztException;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Propagation;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import javax.annotation.Resource;
|
import java.math.BigDecimal;
|
import java.math.MathContext;
|
import java.math.RoundingMode;
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
|
@Service
|
public class OrderLogisticsServiceImpl extends ServiceImpl<OrderLogisticsMapper, OrderLogistics> implements IOrderLogisticsService {
|
|
@Resource
|
private SystemPriceMapper systemPriceMapper;
|
|
@Resource
|
private OrderLogisticsMapper orderLogisticsMapper;
|
|
@Resource
|
private SensitiveWordsMapper sensitiveWordsMapper;
|
|
@Autowired
|
private ICompanyCityService companyCityService;
|
|
@Autowired
|
private GDMapGeocodingUtil gdMapGeocodingUtil;
|
|
@Autowired
|
private DateUtil dateUtil;
|
|
@Autowired
|
private ISystemNoticeService systemNoticeService;
|
|
@Autowired
|
private IPushOrderService pushOrderService;
|
|
@Autowired
|
private IDriverService driverService;
|
|
@Autowired
|
private PushUtil pushUtil;
|
|
@Autowired
|
private IUserInfoService userInfoService;
|
|
@Autowired
|
private IPaymentRecordService paymentRecordService;
|
|
@Resource
|
private SysIntegralMapper sysIntegralMapper;
|
|
@Autowired
|
private ITransactionDetailsService transactionDetailsService;
|
|
@Autowired
|
private ICompanyService companyService;
|
|
@Autowired
|
private IIncomeService incomeService;
|
|
@Autowired
|
private IOrderCancelService orderCancelService;
|
|
@Autowired
|
private IOrderLogisticsSpreadService orderLogisticsSpreadService;
|
|
@Autowired
|
private RedisUtil redisUtil;
|
|
@Resource
|
private RegionMapper regionMapper;
|
|
@Autowired
|
private GDMapElectricFenceUtil gdMapElectricFenceUtil;
|
|
@Autowired
|
private PayMoneyUtil payMoneyUtil;
|
|
@Resource
|
private OrderPrivateCarMapper orderPrivateCarMapper;
|
|
@Resource
|
private OrderCrossCityMapper orderCrossCityMapper;
|
|
@Resource
|
private OrderTaxiMapper orderTaxiMapper;
|
|
@Autowired
|
private IOpenCityService openCityService;
|
|
@Autowired
|
private ITaxiCardPaymentService taxiCardPaymentService;
|
|
@Autowired
|
private IUserCouponRecordService userCouponRecordService;
|
|
@Autowired
|
private ITaxiCardService taxiCardService;
|
|
@Autowired
|
private IUserUserService userUserService;
|
|
@Autowired
|
private IUserTaxiCardService userTaxiCardService;
|
|
@Autowired
|
private IRegionService regionService;
|
|
@Value("${callbackPath}")
|
private String callbackPath;
|
|
private static List<Integer> orderIds = new ArrayList<>();
|
|
|
|
/**
|
* 根据起点和终点坐标判断是不是同一个市内
|
* @param startLonLat
|
* @param endAddress
|
* @return
|
*/
|
@Override
|
public ResultUtil judgingTheCity(String startLonLat, String endAddress) throws Exception {
|
Map<String, String> sgeocode = gdMapGeocodingUtil.geocode(startLonLat.split(",")[0], startLonLat.split(",")[1]);
|
String scityCode = sgeocode.get("cityCode");
|
Map<String, Object> geocoding = gdMapGeocodingUtil.geocoding(endAddress);
|
if(Integer.valueOf(geocoding.get("status").toString()) != 0){
|
return ResultUtil.error("收货地址有误，无法查询具体地址信息");
|
}
|
List<String> list = (List<String>)geocoding.get("data");
|
Map<String, String> egeocode = gdMapGeocodingUtil.geocode(list.get(0).split(",")[0], list.get(0).split(",")[1]);
|
String ecityCode = egeocode.get("cityCode");
|
if(!scityCode.equals(ecityCode)){
|
return ResultUtil.error("已超出服务范围，请重新选择跨城小件物流");
|
}
|
return ResultUtil.success();
|
}
|
|
|
/**
|
* 获取小件物流的单价
|
* @param type
|
* @param startLonLat
|
* @param endAddress
|
* @return
|
* @throws Exception
|
*/
|
@Override
|
public ResultUtil queryLogisticsUnitPrice(Integer type, String startLonLat, String endAddress, Integer uid) throws Exception {
|
Company query = companyCityService.query(startLonLat.split(",")[0], startLonLat.split(",")[1]);
|
if(null == query){
|
return ResultUtil.error("预约取货点暂无企业服务");
|
}
|
Double price1 = 0D;
|
Double price2 = 0D;
|
if(type == 4){//同城
|
Map<String, Object> query1 = systemPriceMapper.query(query.getId(), type, null);
|
if(null == query1){
|
return ResultUtil.error("请先完善价格设定");
|
}
|
String content = String.valueOf(query1.get("content"));
|
JSONObject jsonObject = JSON.parseObject(content);
|
price1 = jsonObject.getDouble("num2");
|
price2 = jsonObject.getDouble("num13");
|
}else{
|
Map<String, Object> query1 = systemPriceMapper.query(query.getId(), type, null);
|
if(null == query1){
|
return ResultUtil.error("请先完善价格设定");
|
}
|
String content = String.valueOf(query1.get("content"));
|
JSONObject jsonObject = JSON.parseObject(content);
|
price1 = jsonObject.getDouble("num1");
|
price2 = jsonObject.getDouble("num2");
|
}
|
int i = this.selectCount(new EntityWrapper<OrderLogistics>().eq("userId", uid).eq("isDelete", 1));
|
Map<String, Object> map = new HashMap<>();
|
map.put("ordinary", price1);
|
map.put("precious", price2);
|
map.put("first", i);
|
return ResultUtil.success(map);
|
}
|
|
|
/**
|
* 获取支付金额
|
* @param type
|
* @param startLonLat
|
* @param endAddress
|
* @return
|
* @throws Exception
|
*/
|
public ResultUtil queryPayMoney(Integer number, Integer type, String startLonLat, String endAddress) throws Exception{
|
Map<String, Object> geocoding = gdMapGeocodingUtil.geocoding(endAddress);
|
if(Integer.valueOf(geocoding.get("status").toString()) != 0){
|
return ResultUtil.error("收货地址有误，无法查询具体地址信息");
|
}
|
String location = ((List<String>)geocoding.get("data")).get(0);
|
ResultUtil<Map<String, Double>> price = this.getPrice(null, type, startLonLat.split(",")[0], startLonLat.split(",")[1], location.split(",")[0], location.split(",")[1]);
|
if(price.getCode() == 200 && type == 5){
|
Map<String, Double> data = price.getData();
|
data.put("ordinary", data.get("ordinary") * number);
|
data.put("precious", data.get("precious") * number);
|
}
|
return price;
|
}
|
|
|
|
|
/**
|
* 小件物流下单操作
|
* @param type
|
* @param cargoType
|
* @param cargoNumber
|
* @param remark
|
* @param placementLon
|
* @param placementLat
|
* @param startLon
|
* @param startLat
|
* @param startAddress
|
* @param recipient
|
* @param recipientPhone
|
* @param endAddress
|
* @param travelTime
|
* @param orderSource
|
* @param uid
|
* @return
|
* @throws Exception
|
*/
|
@Override
|
public ResultUtil smallLogistics(Integer type, Integer cargoType, Integer cargoNumber, String remark, String placementLon, String placementLat, String startLon, String startLat, String startAddress, String recipient,
|
String recipientPhone, String endAddress, Integer urgent, Double tipMoney, Date travelTime, Integer orderSource, Integer uid) throws Exception {
|
/**
|
* 1.出租车、专车、跨城有待支付的订单不能叫车
|
* 2.小件物流有未完成的订单可以下跨城、专车、出租车
|
* 3.出租车、专车、跨城有预约单可以下即时单
|
*/
|
List<OrderPrivateCar> orderPrivateCars = orderPrivateCarMapper.queryByState(uid, null, 1, 7, 12);
|
if(orderPrivateCars.size() > 0){
|
return ResultUtil.error("有未完成的订单");
|
}
|
List<OrderTaxi> list = orderTaxiMapper.queryByState_(uid, null, 1, 7, 12);
|
if(list.size() > 0){
|
return ResultUtil.error("有未完成的订单");
|
}
|
List<OrderCrossCity> orderCrossCities1 = orderCrossCityMapper.queryByState(uid, 7, 12);
|
if(orderCrossCities1.size() > 0){
|
return ResultUtil.error("有未完成的订单");
|
}
|
|
startAddress = startAddress.replaceAll("& #40;", "(");
|
startAddress = startAddress.replaceAll("& #41;", ")");
|
endAddress = endAddress.replaceAll("& #40;", "(");
|
endAddress = endAddress.replaceAll("& #41;", ")");
|
OrderLogistics orderLogistics = new OrderLogistics();
|
Company query = companyCityService.query(placementLon, placementLat);
|
if(null == query){
|
return ResultUtil.error("该地点暂无企业服务");
|
}
|
orderLogistics.setCompanyId(query.getId());
|
orderLogistics.setType(type);
|
orderLogistics.setUserId(uid);
|
orderLogistics.setOrderNum(this.getOrderNum());
|
orderLogistics.setCargoType(cargoType);
|
orderLogistics.setCargoNumber(cargoNumber);
|
orderLogistics.setRemark(remark);
|
orderLogistics.setPlacementLon(Double.valueOf(placementLon));
|
orderLogistics.setPlacementLat(Double.valueOf(placementLat));
|
Map<String, String> geocode = gdMapGeocodingUtil.geocode(placementLon, placementLat);
|
orderLogistics.setPlacementAddress(geocode.get("address"));
|
orderLogistics.setStartLon(Double.valueOf(startLon));
|
orderLogistics.setStartLat(Double.valueOf(startLat));
|
orderLogistics.setStartAddress(startAddress);
|
Map<String, Object> geocoding = gdMapGeocodingUtil.geocoding(endAddress);
|
if(Integer.valueOf(geocoding.get("status").toString()) != 0){
|
return ResultUtil.error("收货地址有误，无法查询具体地址信息");
|
}
|
if(((List<String>)geocoding.get("data")).size() == 0){
|
return ResultUtil.error("无法查询具体地址信息");
|
}
|
String location = ((List<String>)geocoding.get("data")).get(0);
|
orderLogistics.setEndLon(Double.valueOf(location.split(",")[0]));
|
orderLogistics.setEndLat(Double.valueOf(location.split(",")[1]));
|
orderLogistics.setEndAddress(endAddress);
|
orderLogistics.setUrgent(urgent);
|
orderLogistics.setRecipient(recipient);
|
orderLogistics.setRecipientPhone(recipientPhone);
|
orderLogistics.setMileage(0D);
|
orderLogistics.setIsReassign(1);
|
orderLogistics.setReassignNotice(0);
|
ResultUtil<Map<String, Double>> price = this.getPrice(null, type, String.valueOf(startLon), String.valueOf(startLat), location.split(",")[0], location.split(",")[1]);
|
if(price.getCode() != 200){
|
return price;
|
}
|
Map<String, Double> data = price.getData();
|
orderLogistics.setOrderMoney((cargoType == 1 ? data.get("ordinary") : data.get("precious")) + tipMoney);
|
orderLogistics.setTravelMoney(cargoType == 1 ? data.get("ordinary") : data.get("precious"));
|
if(type == 5){
|
orderLogistics.setOrderMoney(((cargoType == 1 ? data.get("ordinary") : data.get("precious")) * cargoNumber) + tipMoney);
|
orderLogistics.setTravelMoney((cargoType == 1 ? data.get("ordinary") : data.get("precious")) * cargoNumber);
|
}
|
orderLogistics.setTipMoney(tipMoney);
|
orderLogistics.setState(7);//待支付
|
orderLogistics.setInsertTime(new Date());
|
orderLogistics.setTravelTime(travelTime);
|
orderLogistics.setOrderSource(orderSource);
|
orderLogistics.setIsDelete(1);
|
this.insert(orderLogistics);
|
|
//添加消息
|
systemNoticeService.addSystemNotice(1, "您的"+ (type == 4 ? "同城" : "跨城") + "小件物流订单已下单成功，我们正在为您指派司机，请稍后！", orderLogistics.getUserId(), 1);
|
|
BaseWarpper baseWarpper = new BaseWarpper();
|
baseWarpper.setId(orderLogistics.getId());
|
return ResultUtil.success(baseWarpper);
|
}
|
|
@Override
|
public ResultUtil smallLogistics1(String arriveTime, Integer type, Integer cargoType, Integer cargoNumber, String remark, String placementLon, String placementLat, String startLon, String startLat, String startAddress, String recipient, String recipientPhone, String endAddress, Integer urgent, Double tipMoney, Date travelTime, Integer orderSource, String userImg, Integer uid) throws Exception {
|
/**
|
* 1.出租车、专车、跨城有待支付的订单不能叫车
|
* 2.小件物流有未完成的订单可以下跨城、专车、出租车
|
* 3.出租车、专车、跨城有预约单可以下即时单
|
*/
|
List<OrderPrivateCar> orderPrivateCars = orderPrivateCarMapper.queryByState(uid, null, 1, 1, 2, 3, 4, 5, 6, 7, 11, 12);
|
if(orderPrivateCars.size() > 0){
|
return ResultUtil.error("有未完成的订单");
|
}
|
List<OrderTaxi> list = orderTaxiMapper.queryByState_(uid, null, 1, 1, 2, 3, 4, 5, 6, 7, 11, 12);
|
if(list.size() > 0){
|
return ResultUtil.error("有未完成的订单");
|
}
|
List<OrderCrossCity> orderCrossCities1 = orderCrossCityMapper.queryByState(uid, 7, 12);
|
if(orderCrossCities1.size() > 0){
|
return ResultUtil.error("有未完成的订单");
|
}
|
|
startAddress = startAddress.replaceAll("& #40;", "(");
|
startAddress = startAddress.replaceAll("& #41;", ")");
|
endAddress = endAddress.replaceAll("& #40;", "(");
|
endAddress = endAddress.replaceAll("& #41;", ")");
|
|
Map<String, Object> geocoding = gdMapGeocodingUtil.geocoding(endAddress);
|
if(Integer.valueOf(geocoding.get("status").toString()) != 0){
|
return ResultUtil.error("收货地址有误，无法查询具体地址信息");
|
}
|
if(((List<String>)geocoding.get("data")).size() == 0){
|
return ResultUtil.error("无法查询具体地址信息");
|
}
|
String location = ((List<String>)geocoding.get("data")).get(0);
|
|
OrderLogistics orderLogistics = new OrderLogistics();
|
Company query = companyCityService.query(placementLon, placementLat);
|
if(null == query){
|
return ResultUtil.error("该地点暂无企业服务");
|
}
|
|
// TODO: 2023/11/4 无法修改
|
Map<String, String> distance = gdMapElectricFenceUtil.getDistance(startLon + "," + startLat, location, 1);
|
double distance1 = new BigDecimal(distance.get("distance")).divide(new BigDecimal(1000)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue();
|
Map<String, Object> query1 = systemPriceMapper.query(query.getId(), type, null);
|
if(null != query1){
|
if(type == 4){
|
JSONObject jsonObject = JSON.parseObject(query1.get("content").toString());
|
if(cargoType == 1){//普通
|
Double num10 = jsonObject.getDouble("num10");
|
if(distance1 > num10){
|
return ResultUtil.error("距离已超出服务距离");
|
}
|
}
|
if(cargoType == 2){//贵重
|
Double num21 = jsonObject.getDouble("num21");
|
if(distance1 > num21){
|
return ResultUtil.error("距离已超出服务距离");
|
}
|
}
|
}
|
}
|
|
|
orderLogistics.setCompanyId(query.getId());
|
orderLogistics.setType(type);
|
orderLogistics.setUserId(uid);
|
orderLogistics.setOrderNum(this.getOrderNum());
|
orderLogistics.setCargoType(cargoType);
|
orderLogistics.setCargoNumber(cargoNumber);
|
orderLogistics.setUserImg(userImg);
|
orderLogistics.setRemark(remark);
|
orderLogistics.setPlacementLon(Double.valueOf(placementLon));
|
orderLogistics.setPlacementLat(Double.valueOf(placementLat));
|
Map<String, String> geocode = gdMapGeocodingUtil.geocode(placementLon, placementLat);
|
orderLogistics.setPlacementAddress(geocode.get("address"));
|
orderLogistics.setStartLon(Double.valueOf(startLon));
|
orderLogistics.setStartLat(Double.valueOf(startLat));
|
orderLogistics.setStartAddress(startAddress);
|
orderLogistics.setEndLon(Double.valueOf(location.split(",")[0]));
|
orderLogistics.setEndLat(Double.valueOf(location.split(",")[1]));
|
orderLogistics.setEndAddress(endAddress);
|
orderLogistics.setUrgent(urgent);
|
orderLogistics.setRecipient(recipient);
|
orderLogistics.setRecipientPhone(recipientPhone);
|
orderLogistics.setMileage(0D);
|
orderLogistics.setIsReassign(1);
|
orderLogistics.setReassignNotice(0);
|
ResultUtil<Map<String, Double>> price = this.getPrice(distance1, type, String.valueOf(startLon), String.valueOf(startLat), location.split(",")[0], location.split(",")[1]);
|
if(price.getCode() != 200){
|
return price;
|
}
|
Map<String, Double> data = price.getData();
|
orderLogistics.setOrderMoney((cargoType == 1 ? data.get("ordinary") : data.get("precious")) + tipMoney);
|
orderLogistics.setTravelMoney(cargoType == 1 ? data.get("ordinary") : data.get("precious"));
|
if(type == 5){
|
orderLogistics.setOrderMoney(((cargoType == 1 ? data.get("ordinary") : data.get("precious")) * cargoNumber) + tipMoney);
|
orderLogistics.setTravelMoney((cargoType == 1 ? data.get("ordinary") : data.get("precious")) * cargoNumber);
|
}
|
orderLogistics.setTipMoney(tipMoney);
|
orderLogistics.setState(7);//待支付
|
orderLogistics.setInsertTime(new Date());
|
orderLogistics.setTravelTime(travelTime);
|
orderLogistics.setOrderSource(orderSource);
|
orderLogistics.setIsDelete(1);
|
|
/// 新增预计送达时间
|
if (ToolUtil.isNotEmpty(arriveTime)){
|
orderLogistics.setArriveTimeExpect(com.stylefeng.guns.core.util.DateUtil.parseTime1(arriveTime));
|
}
|
|
/// 生成取件码
|
String random = "";
|
for(int i = 0; i < 6; i++){
|
random += Double.valueOf(Math.random() * 10).intValue();
|
}
|
orderLogistics.setPickUpCode(random);
|
|
this.insert(orderLogistics);
|
|
//添加消息
|
systemNoticeService.addSystemNotice(1, "您的"+ (type == 4 ? "同城" : "跨城") + "小件物流订单已下单成功，我们正在为您指派司机，请稍后！", orderLogistics.getUserId(), 1);
|
|
BaseWarpper baseWarpper = new BaseWarpper();
|
baseWarpper.setId(orderLogistics.getId());
|
return ResultUtil.success(baseWarpper);
|
}
|
|
/**
|
* 获取价格
|
* @param type
|
* @return
|
* @throws Exception
|
*/
|
public ResultUtil<Map<String, Double>> getPrice(Double dist, Integer type, String startLon, String startLat, String endLon, String endLat) throws Exception{
|
Company query = companyCityService.query(startLon, startLat);
|
if(null == query){
|
return ResultUtil.error("预约取货点暂无企业服务");
|
}
|
Double price1 = 0D;
|
Double price2 = 0D;
|
if(type == 4){//同城
|
Map<String, Object> query1 = systemPriceMapper.query(query.getId(), type, null);
|
// TODO: 2023/11/4 已优化
|
if(null == dist){
|
Map<String, String> distance = gdMapElectricFenceUtil.getDistance(startLon + "," + startLat, endLon + "," + endLat, 1);
|
String distance1 = distance.get("distance");
|
dist = Double.valueOf(distance1) / 1000;
|
}
|
String content = String.valueOf(query1.get("content"));
|
JSONObject jsonObject = JSON.parseObject(content);
|
if(dist.compareTo(0D) >= 0 && dist.compareTo(jsonObject.getDouble("num1")) < 0){
|
price1 = jsonObject.getDouble("num2");
|
}
|
if(dist.compareTo(0D) >= 0 && dist.compareTo(jsonObject.getDouble("num12")) < 0){
|
price2 = jsonObject.getDouble("num13");
|
}
|
|
if(dist.compareTo(jsonObject.getDouble("num3")) >= 0 && dist.compareTo(jsonObject.getDouble("num4")) < 0){
|
price1 = jsonObject.getDouble("num5");
|
}
|
if(dist.compareTo(jsonObject.getDouble("num14")) >= 0 && dist.compareTo(jsonObject.getDouble("num15")) < 0){
|
price2 = jsonObject.getDouble("num16");
|
}
|
|
if(dist.compareTo(jsonObject.getDouble("num6")) >= 0 && dist.compareTo(jsonObject.getDouble("num7")) < 0){
|
price1 = jsonObject.getDouble("num8");
|
}
|
if(dist.compareTo(jsonObject.getDouble("num17")) >= 0 && dist.compareTo(jsonObject.getDouble("num18")) < 0){
|
price2 = jsonObject.getDouble("num19");
|
}
|
|
if(dist.compareTo(jsonObject.getDouble("num9")) >= 0 && dist.compareTo(jsonObject.getDouble("num10")) < 0){
|
price1 = jsonObject.getDouble("num11");
|
}
|
if(dist.compareTo(jsonObject.getDouble("num10")) >= 0){
|
price1 = jsonObject.getDouble("num11");
|
}
|
if(dist.compareTo(jsonObject.getDouble("num20")) >= 0 && dist.compareTo(jsonObject.getDouble("num21")) < 0){
|
price2 = jsonObject.getDouble("num22");
|
}
|
if(dist.compareTo(jsonObject.getDouble("num21")) >= 0){
|
price2 = jsonObject.getDouble("num22");
|
}
|
}else{
|
Map<String, Object> query1 = systemPriceMapper.query(query.getId(), type, null);
|
String content = String.valueOf(query1.get("content"));
|
JSONObject jsonObject = JSON.parseObject(content);
|
price1 = jsonObject.getDouble("num1");
|
price2 = jsonObject.getDouble("num2");
|
}
|
Map<String, Double> map = new HashMap<>();
|
map.put("ordinary", price1);//普通
|
map.put("precious", price2);//贵重
|
return ResultUtil.success(map);
|
}
|
|
|
|
/**
|
* 推送抢单数据
|
* @param orderLogistics
|
* @throws Exception
|
*/
|
public void pushOrder(OrderLogistics orderLogistics) throws Exception{
|
new Thread(new Runnable() {
|
@Override
|
public void run() {
|
try {
|
Integer id = orderLogistics.getId();
|
orderIds.add(orderLogistics.getId());//添加记录，防止调用接口重复提醒无人接单
|
String vehicle = redisUtil.getValue("VEHICLE");
|
List<Integer> integers = new ArrayList<>();
|
if(ToolUtil.isNotEmpty(vehicle)){
|
integers = JSON.parseArray(vehicle).toJavaList(Integer.class);
|
}
|
Company query = companyCityService.query(String.valueOf(orderLogistics.getStartLon()), String.valueOf(orderLogistics.getStartLat()));//获取起点所属分公司
|
List<PushOrder> querys = pushOrderService.querys(null, 1, query.getId());//用专车的推单配置
|
for(int i = 1; i <= querys.size(); i++){
|
// OrderLogistics orderLogistics = orderLogisticsMapper.selectById(id);
|
// if (null == orderLogistics || orderLogistics.getState() > 1) {
|
// break;
|
// }
|
PushOrder pushOrder = pushOrderService.querys(i, 1, query.getId()).get(0);
|
|
int i2 = pushOrder.getPushTime() / 10;
|
if(i2==0){
|
i2=1;
|
}
|
for (int i1 = 0; i1 < i2 ; i1++) {
|
OrderLogistics orderLogistics1 = orderLogisticsMapper.selectById(id);
|
if (orderLogistics1.getState() > 1) {
|
break;
|
}
|
//获取匹配的司机
|
List<Driver> list = driverService.queryIdleDriver1(orderLogistics.getType(), orderLogistics.getStartLon(), orderLogistics.getStartLat(), pushOrder.getPushDistance(), null);//所有附近空闲司机
|
if (list.size() > 0) {
|
double driverProportion = pushOrder.getDriverProportion() / 100;//推送占比计算成小数
|
int lastIndex = Double.valueOf(list.size() * driverProportion).intValue();//计算占比转成整数（下标截取）
|
lastIndex = lastIndex == 0 ? list.size() : lastIndex;
|
list = list.subList(0, lastIndex);//获取空闲司机中占比数据
|
for (Driver driver : list) {//开始进行推送
|
boolean bo = false;
|
for (Integer integer : integers) {
|
if (integer.compareTo(driver.getId()) == 0) {
|
bo = true;
|
break;
|
}
|
}
|
if (bo) {
|
continue;
|
}
|
pushUtil.pushOrderState(2, driver.getId(), orderLogistics.getId(), orderLogistics.getType(), orderLogistics.getState(), pushOrder.getPushTime());
|
}
|
}
|
Thread.sleep(10000);//设置等待时间
|
Integer state = orderLogistics.getState();
|
if (state > 1) {
|
orderIds.remove(orderLogistics.getId());
|
return;
|
}
|
if (i == querys.size() && state == 1) {
|
orderIds.remove(orderLogistics.getId());
|
}
|
}
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
}).start();
|
}
|
|
|
|
|
/**
|
* 订单支付
|
* @param payType
|
* @param orderId
|
* @param type
|
* @return
|
* @throws Exception
|
*/
|
@Override
|
public ResultUtil payLogisticsOrder(Integer payType, Integer orderId, Integer type) throws Exception {
|
OrderLogistics orderLogistics = this.selectById(orderId);
|
if(orderLogistics.getState() != 7){
|
return ResultUtil.error("订单已完成支付，不允许重复支付", "");
|
}
|
Integer uid = orderLogistics.getUserId();
|
Double orderMoney = orderLogistics.getOrderMoney();
|
UserInfo userInfo = userInfoService.selectById(uid);
|
ResultUtil resultUtil = ResultUtil.success(new Object());
|
|
if(payType == 1){//微信支付
|
String app = type == 1 ? "APP" : "JSAPI";
|
resultUtil = payMoneyUtil.weixinpay("小件物流下单支付", "", orderId + "_" + orderLogistics.getType() + "_" + UUIDUtil.getRandomCode(5), orderMoney.toString(), "/base/wxPayOrderTaxi", app, userInfo.getAppletsOpenId());
|
paymentRecordService.saveData(1, orderLogistics.getUserId(), 1, orderId, orderLogistics.getType(), 1, orderMoney, "", 1);//添加预支付数据
|
}
|
if(payType == 2){//支付宝支付
|
resultUtil = payMoneyUtil.alipay("小件物流下单支付", "小件物流下单支付", "", orderId + "_" + orderLogistics.getType() + "_" + UUIDUtil.getRandomCode(5), orderMoney.toString(), "/base/aliPayOrderTaxi");
|
paymentRecordService.saveData(1, orderLogistics.getUserId(), 1, orderId, orderLogistics.getType(), 2, orderMoney, "", 1);//添加预支付数据
|
}
|
if(payType == 3){//余额支付
|
if(userInfo.getBalance() == null || userInfo.getBalance() < orderMoney){
|
return ResultUtil.error("余额不足，无法完成支付", "");
|
}
|
|
userInfo.setBalance(new BigDecimal(userInfo.getBalance()).subtract(new BigDecimal(orderMoney)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
|
|
SysIntegral query1 = sysIntegralMapper.query(orderLogistics.getCompanyId());
|
userInfo.setIntegral(userInfo.getIntegral() + (orderMoney.intValue() * query1.getIntegral()));//积分
|
|
//添加交易明细
|
transactionDetailsService.saveData(uid, (orderLogistics.getType() == 4 ? "同城" : "跨城") + "小件物流下单", orderMoney, 2, 1, 1, 4, orderId);
|
userInfoService.updateById(userInfo);
|
|
orderLogistics.setState(1);//小件物流先支付后司机抢单
|
orderLogistics.setPayType(3);
|
orderLogistics.setPayMoney(orderMoney);
|
|
// TODO: 2020/5/24 这里需要给司机和用户推送订单状态
|
new Thread(new Runnable() {
|
@Override
|
public void run() {
|
pushUtil.pushOrderState(1, orderLogistics.getUserId(), orderLogistics.getId(), orderLogistics.getType(), orderLogistics.getState(), 0);
|
}
|
}).start();
|
|
systemNoticeService.addSystemNotice(1, "您已使用余额成功完成小件物流订单支付，谢谢使用！", uid, 1);
|
|
this.pushOrder(orderLogistics);//推单
|
}
|
|
this.updateById(orderLogistics);
|
return resultUtil;
|
}
|
|
@Override
|
@Transactional(rollbackFor = UpyztException.class,propagation = Propagation.REQUIRES_NEW)
|
public ResultUtil payLogisticsOrder1(Integer payType, Integer orderId, Integer objectId, Integer objectType, Integer type) throws Exception {
|
OrderLogistics orderLogistics = this.selectById(orderId);
|
if(orderLogistics.getState() != 7){
|
return ResultUtil.error("订单已完成支付，不允许重复支付", "");
|
}
|
Integer uid = orderLogistics.getUserId();
|
Double orderMoney = orderLogistics.getOrderMoney();
|
UserInfo userInfo = userInfoService.selectById(uid);
|
ResultUtil resultUtil = ResultUtil.success(new Object());
|
|
orderLogistics.setCouponMoney(0D);//初始化历史数据
|
orderLogistics.setCouponId(null);
|
|
//计算优惠券
|
UserCouponRecord userCouponRecord = null;
|
if(null != objectId && objectType == 1){
|
userCouponRecord = userCouponRecordService.selectById(objectId);
|
if(userCouponRecord.getCompanyId() != orderLogistics.getCompanyId()){
|
return ResultUtil.error("优惠券不能用于此订单", "");
|
}
|
if(userCouponRecord.getState() == 2){
|
return ResultUtil.error("优惠券已使用", "");
|
}
|
if(userCouponRecord.getState() == 3){
|
return ResultUtil.error("优惠券已过期", "");
|
}
|
if(userCouponRecord.getCouponUseType() != 0){
|
return ResultUtil.error("优惠券不能用于此类型订单", "");
|
}
|
if(userCouponRecord.getCouponType() == 2 && orderMoney.compareTo(userCouponRecord.getFullMoney()) < 0){
|
return ResultUtil.error("优惠券不能用于此订单", "");
|
}
|
orderMoney = orderMoney - userCouponRecord.getMoney();
|
orderLogistics.setCouponMoney(userCouponRecord.getMoney());
|
orderLogistics.setCouponId(objectId);
|
}
|
|
//打车卡
|
UserTaxiCard userTaxiCard = null;
|
if(null != objectId && objectType == 2){
|
userTaxiCard = userTaxiCardService.selectById(objectId);
|
TaxiCard taxiCard = taxiCardService.selectById(userTaxiCard.getTaxiCardId());
|
if(taxiCard.getTaxiCardType() == 1 && userTaxiCard.getCompanyId() != orderLogistics.getCompanyId()){
|
return ResultUtil.error("打车卡不能用于此订单", "");
|
}
|
if(System.currentTimeMillis() > userTaxiCard.getEndTime().getTime()){
|
return ResultUtil.error("打车卡已过期", "");
|
}
|
List<Integer> integers = JSON.parseObject(userTaxiCard.getContent()).getJSONArray("businessTypes").toJavaList(Integer.class);
|
if(!integers.contains(orderLogistics.getType())){
|
return ResultUtil.error("打车卡不能用于此类型订单", "");
|
}
|
|
Double yh = 0D;
|
JSONObject jsonObject = JSON.parseObject(userTaxiCard.getContent());
|
if(userTaxiCard.getType() == 5){//{"businessTypes":[4,5],"discount":5}
|
Double discount = jsonObject.getDouble("discount");
|
yh = new BigDecimal(orderLogistics.getOrderMoney()).multiply(new BigDecimal((10 - discount) / 10)).setScale(2, RoundingMode.HALF_EVEN).doubleValue();
|
}
|
|
orderMoney = orderMoney - yh;
|
orderLogistics.setTaxiCardId(userTaxiCard.getTaxiCardId());
|
orderLogistics.setUserTaxiCardId(objectId);
|
orderLogistics.setDiscountAmount(yh);
|
}
|
orderMoney = orderMoney < 0 ? 0 : orderMoney;
|
orderMoney =new BigDecimal(orderMoney).setScale(2,RoundingMode.HALF_UP).doubleValue();
|
if(payType == 1){//微信支付
|
if(orderMoney == 0){
|
return ResultUtil.error("请使用余额支付");
|
}
|
String app = type == 1 ? "APP" : "JSAPI";
|
resultUtil = payMoneyUtil.weixinpay("小件物流下单支付", "", orderId + "_" + orderLogistics.getType() + "_" + UUIDUtil.getRandomCode(5), orderMoney.toString(), "/base/wxPayOrderTaxi", app, userInfo.getAppletsOpenId());
|
paymentRecordService.saveData(1, orderLogistics.getUserId(), 1, orderId, orderLogistics.getType(), 1, orderMoney, "", 1);//添加预支付数据
|
}
|
if(payType == 2){//支付宝支付
|
if(orderMoney == 0){
|
return ResultUtil.error("请使用余额支付");
|
}
|
resultUtil = payMoneyUtil.alipay("小件物流下单支付", "小件物流下单支付", "", orderId + "_" + orderLogistics.getType() + "_" + UUIDUtil.getRandomCode(5), orderMoney.toString(), "/base/aliPayOrderTaxi");
|
paymentRecordService.saveData(1, orderLogistics.getUserId(), 1, orderId, orderLogistics.getType(), 2, orderMoney, "", 1);//添加预支付数据
|
}
|
if(payType == 3){//余额支付
|
if(userInfo.getBalance() == null || userInfo.getBalance() < orderMoney){
|
return ResultUtil.error("余额不足，无法完成支付");
|
}
|
if(orderMoney>0) {
|
// resultUtil = appOrderController.moneyPay(orderId, userInfo.getId(), orderMoney);
|
// if (resultUtil.getCode() == 500) {
|
// return ResultUtil.error("电子余额不足，无法完成支付");
|
// }
|
}
|
userInfo.setBalance(new BigDecimal(userInfo.getBalance()).subtract(new BigDecimal(orderMoney)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
|
|
SysIntegral query1 = sysIntegralMapper.query(orderLogistics.getCompanyId());
|
userInfo.setIntegral(userInfo.getIntegral() + (orderMoney.intValue() * query1.getIntegral()));//积分
|
|
//添加交易明细
|
transactionDetailsService.saveData(uid, (orderLogistics.getType() == 4 ? "同城" : "跨城") + "小件物流下单", orderMoney, 2, 1, 1, 4, orderId);
|
userInfoService.updateById(userInfo);
|
|
orderLogistics.setState(1);//小件物流先支付后司机抢单
|
orderLogistics.setPayType(3);
|
orderLogistics.setPayMoney(orderMoney);
|
|
//处理优惠券和红包
|
if(null != userCouponRecord){
|
userCouponRecord.setState(2);
|
userCouponRecord.setEndTime(new Date());
|
userCouponRecordService.updateById(userCouponRecord);
|
}
|
//处理打车卡
|
if(null != userTaxiCard){
|
userTaxiCardService.updateById(userTaxiCard);
|
}
|
|
//添加已收入明细（司机端完成后添加）
|
|
// TODO: 2020/5/24 这里需要给司机和用户推送订单状态
|
new Thread(new Runnable() {
|
@Override
|
public void run() {
|
pushUtil.pushOrderState(1, orderLogistics.getUserId(), orderLogistics.getId(), orderLogistics.getType(), orderLogistics.getState(), 0);
|
}
|
}).start();
|
|
systemNoticeService.addSystemNotice(1, "您已使用余额成功完成小件物流订单支付，谢谢使用！", uid, 1);
|
this.pushOrder(orderLogistics);//推单
|
|
|
}else if(payType == 4){
|
if(orderMoney == 0){
|
return ResultUtil.error("请使用余额支付");
|
}
|
Double payMoney = orderLogistics.getOrderMoney();
|
Integer integer = paymentRecordService.saveData(1, orderLogistics.getUserId(), 1, orderId, orderLogistics.getType(), 4, orderMoney, "", 1);//添加预支付数据
|
resultUtil = appOrderController.placeAnOrder(new BigDecimal(orderMoney), 4,orderId,5,integer);
|
|
}
|
|
this.updateById(orderLogistics);
|
return resultUtil;
|
}
|
@Autowired
|
private AppOrderController appOrderController;
|
/**
|
* 补差价支付
|
* @param payType
|
* @param orderId
|
* @param type
|
* @return
|
* @throws Exception
|
*/
|
@Override
|
@Transactional(propagation = Propagation.REQUIRES_NEW)
|
public ResultUtil payLogisticsOrder_(Integer payType, Integer orderId, Integer type) throws Exception {
|
OrderLogistics orderLogistics = this.selectById(orderId);
|
Integer uid = orderLogistics.getUserId();
|
OrderLogisticsSpread orderLogisticsSpread = orderLogisticsSpreadService.selectOne(new EntityWrapper<OrderLogisticsSpread>().eq("orderLogisticsId", orderId));
|
Double orderMoney = orderLogisticsSpread.getPrice();
|
UserInfo userInfo = userInfoService.selectById(uid);
|
ResultUtil resultUtil = ResultUtil.success(new Object());
|
|
if(payType == 1){//微信支付
|
String app = type == 1 ? "APP" : "JSAPI";
|
resultUtil = payMoneyUtil.weixinpay("小件物流补差价", "", orderId + "_" + orderLogistics.getType() + "_" + UUIDUtil.getRandomCode(5), orderMoney.toString(), "/base/wxPayOrderLogisticsSpread", app, userInfo.getAppletsOpenId());
|
paymentRecordService.saveData(1, orderLogistics.getUserId(), 1, orderId, orderLogistics.getType(), 1, orderMoney, "", 1);//添加预支付数据
|
}
|
if(payType == 2){//支付宝支付
|
resultUtil = payMoneyUtil.alipay("小件物流补差价", "小件物流补差价", "", orderId + "_" + orderLogistics.getType() + "_" + UUIDUtil.getRandomCode(5), orderMoney.toString(), "/base/aliPayOrderLogisticsSpread");
|
paymentRecordService.saveData(1, orderLogistics.getUserId(), 1, orderId, orderLogistics.getType(), 2, orderMoney, "", 1);//添加预支付数据
|
}
|
if(payType == 3){//余额支付
|
if(userInfo.getBalance() == null || userInfo.getBalance() < orderMoney){
|
return ResultUtil.error("余额不足，无法完成支付");
|
}
|
// resultUtil= appOrderController.moneyPay(orderId,userInfo.getId(),orderMoney);
|
// if(resultUtil.getCode()==500){
|
// return ResultUtil.error("电子余额不足，无法完成支付");
|
// }
|
|
userInfo.setBalance(new BigDecimal(userInfo.getBalance()).subtract(new BigDecimal(orderMoney)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
|
|
SysIntegral query1 = sysIntegralMapper.query(orderLogistics.getCompanyId());
|
userInfo.setIntegral(userInfo.getIntegral() + (orderMoney.intValue() * query1.getIntegral()));//积分
|
|
//添加交易明细
|
transactionDetailsService.saveData(uid, (orderLogistics.getType() == 4 ? "同城" : "跨城") + "小件物流补差价", orderMoney, 2, 1, 1, 4, orderId);
|
userInfoService.updateById(userInfo);
|
|
orderLogistics.setState(12);//已支付差价
|
this.updateById(orderLogistics);
|
|
orderLogistics.setOrderMoney(orderLogistics.getOrderMoney() + orderMoney);
|
orderLogistics.setTravelMoney(orderLogistics.getTravelMoney() + orderMoney);
|
orderLogistics.setPayMoney(orderLogistics.getPayMoney() + orderMoney);
|
|
orderLogisticsSpread.setPayMoney(orderMoney);
|
orderLogisticsSpread.setPayTime(new Date());
|
orderLogisticsSpread.setPayType(3);
|
orderLogisticsSpreadService.updateById(orderLogisticsSpread);
|
|
//添加已收入明细
|
Company company = companyService.selectById(orderLogistics.getCompanyId());
|
Double speMoney = orderLogistics.getType() == 4 ? company.getSameLogisticsMoney() : company.getCrossLogisticsMoney();
|
BigDecimal d = null;
|
BigDecimal c = null;
|
if(company.getIsSpeFixedOrProportional() == 2){//固定
|
d = new BigDecimal(speMoney.compareTo(orderMoney) > 0 ? orderMoney : speMoney);
|
c = new BigDecimal(orderMoney).subtract(d);
|
}
|
if(company.getIsSpeFixedOrProportional() == 1){//比例
|
d = new BigDecimal(orderMoney).multiply(new BigDecimal(speMoney).divide(new BigDecimal(100)), new MathContext(2, RoundingMode.HALF_EVEN));
|
c = new BigDecimal(orderMoney).subtract(d).setScale(2, BigDecimal.ROUND_HALF_EVEN);
|
}
|
|
Income income = incomeService.selectOne(new EntityWrapper<Income>().eq("userType", 1).eq("objectId", orderLogistics.getCompanyId()).eq("type", 2).eq("incomeId", orderLogistics.getId()).eq("orderType", orderLogistics.getType()));
|
income.setMoney(income.getMoney() + d.doubleValue());
|
incomeService.updateById(income);
|
income = incomeService.selectOne(new EntityWrapper<Income>().eq("userType", 2).eq("objectId", orderLogistics.getDriverId()).eq("type", 2).eq("incomeId", orderLogistics.getId()).eq("orderType", orderLogistics.getType()));
|
income.setMoney(income.getMoney() + c.doubleValue());
|
incomeService.updateById(income);
|
Driver driver = driverService.selectById(orderLogistics.getDriverId());
|
driver.setBusinessMoney(new BigDecimal(null != driver.getBusinessMoney() ? driver.getBusinessMoney() : 0).add(c).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
|
driver.setLaveBusinessMoney(new BigDecimal(null != driver.getLaveBusinessMoney() ? driver.getLaveBusinessMoney() : 0).add(c).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
|
driver.setBalance(new BigDecimal(null != driver.getBalance() ? driver.getBalance() : 0).add(c).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
|
driverService.updateById(driver);
|
|
// TODO: 2020/5/24 这里需要给司机和用户推送订单状态
|
new Thread(new Runnable() {
|
@Override
|
public void run() {
|
pushUtil.pushOrderState(1, orderLogistics.getUserId(), orderLogistics.getId(), orderLogistics.getType(), orderLogistics.getState(), 0);
|
pushUtil.pushOrderState(2, orderLogistics.getDriverId(), orderLogistics.getId(), orderLogistics.getType(), orderLogistics.getState(), 0);
|
}
|
}).start();
|
|
systemNoticeService.addSystemNotice(1, "您已使用余额成功完成小件物流订单差价支付，谢谢使用！", uid, 1);
|
|
}
|
|
if(payType==4){
|
Integer integer = paymentRecordService.saveData(1, orderLogistics.getUserId(), 1, orderId, orderLogistics.getType(), 4, orderMoney, "", 1);
|
|
resultUtil = appOrderController.placeAnOrder(new BigDecimal(orderMoney), 4,orderId,13,integer);
|
}
|
|
this.updateById(orderLogistics);
|
return resultUtil;
|
}
|
|
|
|
@Override
|
public void payOrderLogisticsCallback(Integer id, String order_id, Integer type) throws Exception {
|
OrderLogistics orderLogistics = this.selectById(id);
|
PaymentRecord query = paymentRecordService.query(1, orderLogistics.getUserId(), 1, Integer.valueOf(id), orderLogistics.getType(), type, 1);
|
if(null != query){
|
//添加交易明细
|
transactionDetailsService.saveData(orderLogistics.getUserId(), (orderLogistics.getType() == 4 ? "同城" : "跨城") + "小件物流下单", query.getAmount(), 2, 1, 1, orderLogistics.getType(), query.getOrderId());
|
orderLogistics.setState(1);//先支付后抢单
|
orderLogistics.setPayType(type);
|
orderLogistics.setPayMoney(query.getAmount());
|
this.updateById(orderLogistics);
|
|
UserInfo userInfo = userInfoService.selectById(orderLogistics.getUserId());
|
SysIntegral query1 = sysIntegralMapper.query(orderLogistics.getCompanyId());
|
userInfo.setIntegral(userInfo.getIntegral() + (query.getAmount().intValue() * query1.getIntegral()));//积分
|
userInfoService.updateById(userInfo);
|
|
//处理优惠券和红包
|
if(null != orderLogistics.getCouponId()){
|
UserCouponRecord userCouponRecord = userCouponRecordService.selectById(orderLogistics.getCouponId());
|
userCouponRecord.setState(2);
|
userCouponRecord.setEndTime(new Date());
|
userCouponRecordService.updateById(userCouponRecord);
|
}
|
|
//处理打车卡
|
if(null != orderLogistics.getUserTaxiCardId()){
|
UserTaxiCard userTaxiCard = userTaxiCardService.selectById(orderLogistics.getUserTaxiCardId());
|
}
|
|
query.setState(2);
|
query.setCode(order_id);
|
paymentRecordService.updateById(query);
|
|
|
//添加已收入明细（司机端完成后添加）
|
|
|
// TODO: 2020/5/24 这里需要给司机和用户推送订单状态
|
new Thread(new Runnable() {
|
@Override
|
public void run() {
|
pushUtil.pushOrderState(1, orderLogistics.getUserId(), orderLogistics.getId(), orderLogistics.getType(), orderLogistics.getState(), 0);
|
}
|
}).start();
|
|
|
systemNoticeService.addSystemNotice(1, "您已使用" + (type == 1 ? "微信" : (type==2?"支付宝":"云闪付")) + "成功完成小件物流订单支付，谢谢使用！", orderLogistics.getUserId(), 1);
|
|
this.pushOrder(orderLogistics);//推单
|
}else{
|
System.err.println("预支付数据异常（orderId = " + id + ")");
|
}
|
}
|
|
|
|
@Override
|
public void payOrderLogisticsSpreadCallback(Integer id, String order_id, Integer type) throws Exception {
|
OrderLogistics orderLogistics = this.selectById(id);
|
OrderLogisticsSpread orderLogisticsSpread = orderLogisticsSpreadService.selectOne(new EntityWrapper<OrderLogisticsSpread>().eq("orderLogisticsId", id));
|
PaymentRecord query = paymentRecordService.query(1, orderLogistics.getUserId(), 1, Integer.valueOf(id), orderLogistics.getType(), type, 1);
|
if(null != query){
|
//添加交易明细
|
transactionDetailsService.saveData(orderLogistics.getUserId(), (orderLogistics.getType() == 4 ? "同城" : "跨城") + "小件物流补差价", query.getAmount(), 2, 1, 1, 4, query.getOrderId());
|
orderLogistics.setState(12);//待取货
|
|
orderLogistics.setOrderMoney(orderLogistics.getOrderMoney() + query.getAmount());
|
orderLogistics.setTravelMoney(orderLogistics.getTravelMoney() + query.getAmount());
|
orderLogistics.setPayMoney(orderLogistics.getPayMoney() + query.getAmount());
|
|
orderLogisticsSpread.setPayMoney(query.getAmount());
|
orderLogisticsSpread.setPayTime(new Date());
|
orderLogisticsSpread.setPayType(3);
|
orderLogisticsSpreadService.updateById(orderLogisticsSpread);
|
|
UserInfo userInfo = userInfoService.selectById(orderLogistics.getUserId());
|
SysIntegral query1 = sysIntegralMapper.query(orderLogistics.getCompanyId());
|
userInfo.setIntegral(userInfo.getIntegral() + (query.getAmount().intValue() * query1.getIntegral()));//积分
|
userInfoService.updateById(userInfo);
|
|
query.setState(2);
|
query.setCode(order_id);
|
paymentRecordService.updateById(query);
|
|
//添加已收入明细
|
Company company = companyService.selectById(orderLogistics.getCompanyId());
|
Double speMoney = orderLogistics.getType() == 4 ? company.getSameLogisticsMoney() : company.getCrossLogisticsMoney();
|
BigDecimal d = BigDecimal.ZERO;
|
BigDecimal c = BigDecimal.ZERO;
|
if(company.getIsSpeFixedOrProportional() == 2){//固定
|
d = new BigDecimal(speMoney);
|
c = new BigDecimal(query.getAmount()).subtract(d).setScale(2, BigDecimal.ROUND_HALF_EVEN);
|
}
|
if(company.getIsSpeFixedOrProportional() == 1){//比例
|
d = new BigDecimal(query.getAmount()).multiply(new BigDecimal(speMoney).divide(new BigDecimal(100)), new MathContext(2, RoundingMode.HALF_EVEN));
|
c = new BigDecimal(query.getAmount()).subtract(d).setScale(2, BigDecimal.ROUND_HALF_EVEN);
|
}
|
// Income income = incomeService.selectOne(new EntityWrapper<Income>().eq("userType", 1).eq("objectId", orderLogistics.getCompanyId()).eq("type", 2).eq("incomeId", orderLogistics.getId()).eq("orderType", orderLogistics.getType()));
|
// income.setMoney(income.getMoney() + d.doubleValue());
|
// incomeService.updateById(income);
|
// income = incomeService.selectOne(new EntityWrapper<Income>().eq("userType", 2).eq("objectId", orderLogistics.getDriverId()).eq("type", 2).eq("incomeId", orderLogistics.getId()).eq("orderType", orderLogistics.getType()));
|
// income.setMoney(income.getMoney() + c.doubleValue());
|
// incomeService.updateById(income);
|
Driver driver = driverService.selectById(orderLogistics.getDriverId());
|
driver.setBusinessMoney(new BigDecimal(null != driver.getBusinessMoney() ? driver.getBusinessMoney() : 0).add(c).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
|
driver.setLaveBusinessMoney(new BigDecimal(null != driver.getLaveBusinessMoney() ? driver.getLaveBusinessMoney() : 0).add(c).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
|
driver.setBalance(new BigDecimal(null != driver.getBalance() ? driver.getBalance() : 0).add(c).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
|
driverService.updateById(driver);
|
|
// TODO: 2020/5/24 这里需要给司机和用户推送订单状态
|
new Thread(new Runnable() {
|
@Override
|
public void run() {
|
pushUtil.pushOrderState(1, orderLogistics.getUserId(), orderLogistics.getId(), orderLogistics.getType(), orderLogistics.getState(), 0);
|
pushUtil.pushOrderState(2, orderLogistics.getDriverId(), orderLogistics.getId(), orderLogistics.getType(), orderLogistics.getState(), 0);
|
}
|
}).start();
|
|
|
systemNoticeService.addSystemNotice(1, "您已使用" + (type == 1 ? "微信": (type==2?"支付宝":"云闪付")) + "成功完成小件物流订单差价支付，谢谢使用！", orderLogistics.getUserId(), 1);
|
this.updateById(orderLogistics);
|
}else{
|
System.err.println("预支付数据异常（orderId = " + id + ")");
|
}
|
}
|
|
|
|
|
|
/**
|
* 获取首页订单数量
|
* @param uid
|
* @return
|
* @throws Exception
|
*/
|
@Override
|
public int queryLogisticsNumber(Integer uid) throws Exception {
|
return orderLogisticsMapper.queryLogisticsNumber(uid);
|
}
|
|
|
/**
|
* 获取个人中心订单列表
|
* @param uid
|
* @param pageNum
|
* @param size
|
* @return
|
* @throws Exception
|
*/
|
@Override
|
public List<Map<String, Object>> queryMyOrderList(Integer uid, Integer type, Integer pageNum, Integer size) throws Exception {
|
pageNum = (pageNum - 1) * size;
|
List<Map<String, Object>> maps = orderLogisticsMapper.queryMyOrderList(uid, type, pageNum, size);
|
return maps;
|
}
|
|
|
/**
|
* 获取历史消费记录
|
* @param uid
|
* @return
|
*/
|
@Override
|
public List<Map<String, Object>> queryMyTravelRecord(Integer uid) {
|
return orderLogisticsMapper.queryMyTravelRecord(uid);
|
}
|
|
|
@Override
|
public List<Map<String, Object>> queryInvoiceOrder(Integer type, Date startTime, Date endTime, Double startMoney, Double endMoney, Integer uid, Integer orderType) throws Exception {
|
startTime = dateUtil.getStartOrEndDate(startTime, "start");
|
endTime = dateUtil.getStartOrEndDate(endTime, "end");
|
return orderLogisticsMapper.queryInvoiceOrder(type, startTime, endTime, startMoney, endMoney, uid, orderType);
|
}
|
|
|
|
@Override
|
public ResultUtil addCancle(Integer id, String reason, String remark, Integer uid) throws Exception {
|
if(ToolUtil.isNotEmpty(remark)){
|
if(ToolUtil.isNotEmpty(remark)){
|
List<SensitiveWords> sensitiveWords = sensitiveWordsMapper.selectList(null);
|
for(SensitiveWords s : sensitiveWords){
|
remark = remark.replaceAll(s.getContent(), "***");
|
}
|
}
|
}
|
|
OrderLogistics orderLogistics = this.selectById(id);
|
Integer integer = null;
|
if(null == orderLogistics){
|
return ResultUtil.error("取消订单失败，订单信息有误");
|
}
|
if(orderLogistics.getState() >= 5 && orderLogistics.getState() != 7 && orderLogistics.getState() != 8 && orderLogistics.getState() != 11){
|
return ResultUtil.error("取消订单失败，不合法的操作");
|
}
|
|
if(orderLogistics.getState() == 7){
|
integer = orderCancelService.saveData(orderLogistics.getId(), orderLogistics.getType(), reason, remark, null, null, 2, 1, orderLogistics.getUserId());
|
orderLogistics.setState(10);
|
this.updateById(orderLogistics);
|
//添加消息
|
systemNoticeService.addSystemNotice(1, "您已成功取消小件物流订单，谢谢使用！", orderLogistics.getUserId(), 1);
|
Map<String, Object> map = new HashMap<>();
|
map.put("id", integer);
|
return ResultUtil.success(map);
|
}
|
|
// 回退优惠券
|
Integer couponId = orderLogistics.getCouponId();
|
|
//回退支付金额
|
if(null != orderLogistics.getPayType() && null != orderLogistics.getPayMoney()) {//已支付
|
if(orderLogistics.getPayType() == 3){//余额支付
|
UserInfo userInfo = userInfoService.selectById(orderLogistics.getUserId());
|
userInfo.setBalance(userInfo.getBalance() + orderLogistics.getPayMoney());
|
userInfoService.updateById(userInfo);
|
appOrderController.createAllocationReqUser(1, orderLogistics.getUserId(), 1,orderLogistics.getPayMoney());
|
UserCouponRecord userCouponRecord = userCouponRecordService.selectById(couponId);
|
userCouponRecord.setState(1);
|
userCouponRecordService.updateById(userCouponRecord);
|
orderLogistics.setCouponMoney(0.00);
|
}else{
|
//调用回退接口
|
PaymentRecord query = paymentRecordService.query(1, orderLogistics.getUserId(), 1, orderLogistics.getId(), orderLogistics.getType(), orderLogistics.getPayType(), 2);
|
System.out.println(query);
|
boolean b = false;
|
System.out.println("支付方式："+query.getPayType());
|
if(query.getPayType() == 1){//微信
|
Map<String, String> map = payMoneyUtil.wxRefund(query.getCode(), orderLogistics.getId() + "_" + orderLogistics.getType(), query.getAmount().toString(), query.getAmount().toString(), "/base/cancleOrderWXPay");
|
System.out.println("map:"+map);
|
if(!"SUCCESS".equals(map.get("return_code"))){
|
return ResultUtil.error(map.get("return_msg"));
|
}
|
}
|
if(query.getPayType()==4){
|
UserInfo userInfo = userInfoService.selectById(orderLogistics.getUserId());
|
userInfo.setBalance(userInfo.getBalance() + orderLogistics.getPayMoney());
|
userInfoService.updateById(userInfo);
|
appOrderController.createAllocationReqUser(1, orderLogistics.getUserId(), 1,orderLogistics.getPayMoney());
|
// 退款
|
System.out.println("云闪付退款");
|
UserCouponRecord userCouponRecord = userCouponRecordService.selectById(couponId);
|
userCouponRecord.setState(1);
|
userCouponRecordService.updateById(userCouponRecord);
|
orderLogistics.setCouponMoney(0.00);
|
// TODO 设置优惠券id回滚
|
// orderLogistics.setCouponId(null);
|
}else if(query.getPayType()==2){//支付宝
|
Map<String, String> map = payMoneyUtil.aliRefund(query.getCode(), query.getAmount().toString());
|
UserCouponRecord userCouponRecord = userCouponRecordService.selectById(couponId);
|
userCouponRecord.setState(1);
|
userCouponRecordService.updateById(userCouponRecord);
|
orderLogistics.setCouponMoney(0.00);
|
if(!"10000".equals(map.get("code"))){
|
return ResultUtil.error(map.get("msg"));
|
}
|
}
|
|
|
// Map<String, Object> merrefund = icbcPayUtil.merrefund(query.getCode(), "", query.getAmount(), orderLogistics.getId() + "_" + orderLogistics.getType(), orderLogistics.getOrderNum());
|
// if (Integer.valueOf(merrefund.get("code").toString()) == 0) {
|
// Map<String, Object> refundqry = icbcPayUtil.refundqry("", query.getCode(), orderLogistics.getOrderNum());
|
// if (Integer.valueOf(refundqry.get("code").toString()) == 0 && Integer.valueOf(refundqry.get("pay_status").toString()) == 0) {//成功
|
// b = true;
|
// }
|
// if (Integer.valueOf(refundqry.get("code").toString()) == 0 && Integer.valueOf(refundqry.get("pay_status").toString()) == 1) {//失败
|
// return ResultUtil.error("订单取消失败（退款不成功）");
|
// }
|
// if (Integer.valueOf(refundqry.get("code").toString()) == 0 && Integer.valueOf(refundqry.get("pay_status").toString()) == 2) {//未知
|
// return ResultUtil.error("退款返回未知异常");
|
//
|
// }
|
// }
|
if(b){
|
|
}
|
}
|
//添加交易明细
|
transactionDetailsService.saveData(orderLogistics.getUserId(), (orderLogistics.getType() == 4 ? "同城" : "跨城") + "小件物流取消退款", orderLogistics.getPayMoney(), 1, 1, 1, 4, orderLogistics.getId());
|
|
integer = orderCancelService.saveData(orderLogistics.getId(), orderLogistics.getType(), reason, remark, null, null, 2, 1, orderLogistics.getUserId());
|
orderLogistics.setState(10);
|
this.updateById(orderLogistics);
|
|
//添加负的收入明细
|
// List<Income> incomes = incomeService.selectList(new EntityWrapper<Income>().eq("type", 2).eq("incomeId", id).eq("orderType", orderLogistics.getType()));
|
// for(Income income : incomes){
|
// if(income.getUserType() == 2){//处理司机的收入
|
// Driver driver = driverService.selectById(income.getObjectId());
|
// driver.setBalance(driver.getBalance() - income.getMoney());
|
// driver.setBusinessMoney(driver.getBusinessMoney() - income.getMoney());
|
// driver.setLaveBusinessMoney(driver.getLaveBusinessMoney() - income.getMoney());
|
// driverService.updateById(driver);
|
// }
|
// Income income1 = new Income();
|
// BeanUtils.copyProperties(income, income1);
|
// income1.setMoney(income.getMoney() * -1);
|
// income1.setId(null);
|
// income1.setInsertTime(new Date());
|
// incomeService.insert(income1);
|
// }
|
|
}
|
|
if(null != orderLogistics.getDriverId()){
|
new Thread(new Runnable() {
|
@Override
|
public void run() {
|
pushUtil.pushOrderState(2, orderLogistics.getDriverId(), orderLogistics.getId(), orderLogistics.getType(), orderLogistics.getState(), 0);
|
}
|
}).start();
|
}
|
|
//添加消息
|
systemNoticeService.addSystemNotice(1, "您已成功取消小件物流订单，谢谢使用！", orderLogistics.getUserId(), 1);
|
Map<String, Object> map = new HashMap<>();
|
map.put("id", integer);
|
return ResultUtil.success(map);
|
}
|
|
|
/**
|
* 获取行政区域数据
|
* @return
|
* @throws Exception
|
*/
|
@Override
|
public Map<String, Object> queryRegion() throws Exception {
|
Map<String, Object> map = new HashMap<>();
|
List<Region> querys = regionMapper.querys(0);
|
Map<Integer, String> map1 = new HashMap<>();
|
Map<Integer, String> map2 = new HashMap<>();
|
Map<Integer, String> map3 = new HashMap<>();
|
for(Region region : querys){
|
map1.put(Integer.valueOf(region.getCode()), region.getName());
|
|
List<Region> querys1 = regionMapper.querys(region.getId());
|
for(Region region1 : querys1){
|
map2.put(Integer.valueOf(region1.getCode()), region1.getName());
|
|
List<Region> querys2 = regionMapper.querys(region1.getId());
|
for(Region region2 : querys2) {
|
map3.put(Integer.valueOf(region2.getCode()), region2.getName());
|
}
|
}
|
}
|
map.put("province_list", map1);
|
map.put("city_list", map2);
|
map.put("county_list", map3);
|
return map;
|
}
|
|
|
/**
|
* 获取行政区域
|
* @param parentId
|
* @return
|
* @throws Exception
|
*/
|
@Override
|
public List<Region> queryRegions(Integer parentId) throws Exception {
|
return regionMapper.querys(parentId);
|
}
|
|
@Override
|
public Map<String, Object> queryBalance(Integer orderId, Integer uid) throws Exception {
|
Map<String, Object> map = new HashMap<>();
|
UserInfo userInfo = userInfoService.selectById(uid);
|
map.put("balance", userInfo.getBalance());
|
map.put("coupon", 0);
|
return map;
|
}
|
@Resource
|
private UserActivityDiscount1Mapper userActivityDiscount1Mapper;
|
@Autowired
|
private IUserRedPacketRecordService userRedPacketRecordService;
|
@Override
|
public PreferentialDataVo queryBalance1(Integer orderId, Integer uid) throws Exception {
|
UserInfo userInfo = userInfoService.selectById(uid);
|
PreferentialDataVo preferentialDataVo = new PreferentialDataVo();
|
preferentialDataVo.setBalance(userInfo.getBalance());
|
OrderLogistics orderLogistics = this.selectById(orderId);
|
Integer ids = userInfoService.getDiscount();
|
if(ids!=null){
|
List<UserActivityDiscount1> userActivityId = userActivityDiscount1Mapper.selectList(new EntityWrapper<UserActivityDiscount1>().eq("userActivityId", ids));
|
if(userActivityId.size()>0){
|
|
preferentialDataVo.setDiscount(userActivityId.get(0).getLogistics());
|
}
|
}
|
// 查出当前用户的红包 并将订单的修改
|
List<UserRedPacketRecord> userRedPacketRecords = userRedPacketRecordService.selectList(new EntityWrapper<UserRedPacketRecord>().eq("userId", uid).eq("state", 1).le("money",orderLogistics.getOrderMoney()).gt("expirationTime", new Date()).gt("endTime", new Date()));
|
if(userRedPacketRecords.size()>0){
|
|
preferentialDataVo.setRedPacket(userRedPacketRecords.get(0).getMoney());
|
orderLogistics.setRedPacketId(userRedPacketRecords.get(0).getId());
|
orderLogistics.setRedPacketMoney(userRedPacketRecords.get(0).getMoney());
|
this.updateById(orderLogistics);
|
}
|
|
//获取优惠券中最优数据
|
List<UserCouponRecord> list = userCouponRecordService.selectList(new EntityWrapper<UserCouponRecord>().eq("companyId", orderLogistics.getCompanyId()).eq("state", 1).le("money",orderLogistics.getOrderMoney()).in("couponUseType", Arrays.asList(0)).eq("userId", uid).where("now() < expirationTime"));
|
Integer id = null;
|
Double price = 0d;
|
Integer type = 0;
|
for (UserCouponRecord userCouponRecord : list){
|
if(userCouponRecord.getCouponType() == 1){//抵扣券
|
if(price.compareTo(userCouponRecord.getMoney()) < 0){
|
price = userCouponRecord.getMoney();
|
id = userCouponRecord.getId();
|
type = 1;
|
}
|
}else{//满减券
|
if(orderLogistics.getOrderMoney().compareTo(userCouponRecord.getFullMoney()) >= 0 && price.compareTo(userCouponRecord.getMoney()) < 0){
|
price = userCouponRecord.getMoney();
|
id = userCouponRecord.getId();
|
type = 1;
|
}
|
}
|
}
|
|
//获取打车卡中最优数
|
Map<String, String> geocode = gdMapGeocodingUtil.geocode(orderLogistics.getStartLon().toString(), orderLogistics.getStartLat().toString());
|
CompanyCity companyCity = companyCityService.selectOne(new EntityWrapper<CompanyCity>().eq("companyId", orderLogistics.getCompanyId()).eq("areaCode", geocode.get("districtCode")).eq("state", 1));
|
if(null == companyCity){
|
companyCity = companyCityService.selectOne(new EntityWrapper<CompanyCity>().eq("companyId", orderLogistics.getCompanyId()).eq("cityCode", geocode.get("cityCode")).eq("state", 1));
|
}
|
if(null == companyCity){
|
companyCity = companyCityService.selectOne(new EntityWrapper<CompanyCity>().eq("companyId", orderLogistics.getCompanyId()).eq("provinceCode", geocode.get("provinceCode")).eq("state", 1));
|
}
|
List<UserTaxiCard> userTaxiCards = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().like("companyCityId", "%" + companyCity.getId() + "%")
|
.in("type", Arrays.asList(5)).eq("userId", uid).where("now() between startTime and endTime"));
|
|
//全国卡
|
List<TaxiCard> taxiCards = taxiCardService.selectList(new EntityWrapper<TaxiCard>().eq("taxiCardType", 2).in("type", Arrays.asList(1, 2, 3, 4)).eq("state", 1));
|
if(taxiCards.size() > 0) {
|
List<UserTaxiCard> userTaxiCards2 = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().eq("userId", uid)
|
.in("type", Arrays.asList(5)).in("taxiCardId", taxiCards.stream().map(TaxiCard::getId).collect(Collectors.toList())).where("now() between startTime and endTime"));
|
userTaxiCards.addAll(userTaxiCards2);
|
}
|
Map<String, Object> map = getOptimalTaxiCards(orderLogistics, price, id, type, userTaxiCards);
|
price = Double.valueOf(map.get("price").toString());
|
id = null != map.get("id") ? Integer.valueOf(map.get("id").toString()) : null;
|
type = Integer.valueOf(map.get("type").toString());
|
|
//亲密账户
|
List<UserTaxiCard> userTaxiCards_ = new ArrayList<>();
|
List<UserUser> bindUserId = userUserService.selectList(new EntityWrapper<UserUser>().eq("bindUserId", uid));
|
CompanyCity finalCompanyCity = companyCity;
|
bindUserId.forEach(userUser -> {
|
List<UserTaxiCard> userTaxiCards1 = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().in("type", Arrays.asList(5))
|
.like("companyCityId", "%" + finalCompanyCity.getId() + "%").eq("userId", userUser.getUserId()).where("now() between startTime and endTime"));
|
userTaxiCards_.addAll(userTaxiCards1);
|
|
//全国卡
|
if(taxiCards.size() > 0) {
|
List<UserTaxiCard> userTaxiCards2 = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().eq("userId", userUser.getUserId())
|
.in("type", Arrays.asList(5)).in("taxiCardId", taxiCards.stream().map(TaxiCard::getId).collect(Collectors.toList())).where("now() between startTime and endTime"));
|
userTaxiCards_.addAll(userTaxiCards2);
|
}
|
});
|
map = getOptimalTaxiCards(orderLogistics, price, id, type, userTaxiCards_);
|
price = Double.valueOf(map.get("price").toString());
|
id = null != map.get("id") ? Integer.valueOf(map.get("id").toString()) : null;
|
type = Integer.valueOf(map.get("type").toString());
|
|
|
if(price<=orderLogistics.getOrderMoney() || type==2){
|
preferentialDataVo.setObjectId(id);
|
preferentialDataVo.setDiscountAmount(price);
|
preferentialDataVo.setType(type);
|
}
|
return preferentialDataVo;
|
}
|
|
|
public Map<String, Object> getOptimalTaxiCards(OrderLogistics orderLogistics, Double price, Integer id, Integer type, List<UserTaxiCard> userTaxiCards) throws Exception{
|
Map<String, Object> map = new HashMap<>();
|
for(UserTaxiCard t : userTaxiCards){
|
if(t.getType() != 5){//物流打折卡{"businessTypes":[4,5],"discount":5}
|
continue;
|
}
|
JSONObject jsonObject = JSON.parseObject(t.getContent());
|
List<Integer> integers = jsonObject.getJSONArray("businessTypes").toJavaList(Integer.class);
|
if(!integers.contains(orderLogistics.getType())){
|
continue;
|
}
|
Double discount = jsonObject.getDouble("discount");
|
double v = new BigDecimal(orderLogistics.getOrderMoney()).multiply(new BigDecimal((10 - discount) / 10)).setScale(2, RoundingMode.HALF_EVEN).doubleValue();
|
if(price.compareTo(v) < 0){
|
price = v;
|
id = t.getId();
|
type = 2;
|
}
|
}
|
map.put("price", price);
|
map.put("id", id);
|
map.put("type", type);
|
return map;
|
}
|
|
|
|
|
@Override
|
public List<OrderLogistics> queryByState(Integer uid, Integer... state) throws Exception {
|
return this.baseMapper.queryByState(uid, state);
|
}
|
|
|
@Override
|
public List<CouponsListVo> queryCouponList(Integer orderId, Integer uid, Integer pageNum, Integer size) throws Exception {
|
pageNum = (pageNum - 1) * size;
|
OrderLogistics orderLogistics = this.selectById(orderId);
|
List<CouponsListVo> rows = new ArrayList<>();
|
List<UserCouponRecord> list = userCouponRecordService.selectList(new EntityWrapper<UserCouponRecord>().eq("companyId", orderLogistics.getCompanyId())
|
.eq("state", 1).in("couponUseType", Arrays.asList(0)).eq("userId", uid).where("expirationTime >= now()"));
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
for (UserCouponRecord userCouponRecord : list){
|
if(userCouponRecord.getCouponType() == 2){//满减券
|
if(orderLogistics.getOrderMoney().compareTo(userCouponRecord.getFullMoney()) < 0){
|
continue;
|
}
|
}
|
CouponsListVo couponsListVo = new CouponsListVo();
|
couponsListVo.setId(userCouponRecord.getId());
|
couponsListVo.setDataType(1);
|
couponsListVo.setMoney(userCouponRecord.getMoney());
|
couponsListVo.setUserType(userCouponRecord.getCouponUseType());
|
couponsListVo.setTime(sdf.format(userCouponRecord.getExpirationTime()));
|
couponsListVo.setType(userCouponRecord.getCouponType());
|
couponsListVo.setFullMoney(userCouponRecord.getFullMoney());
|
couponsListVo.setState(userCouponRecord.getState());
|
Company company = companyService.selectById(userCouponRecord.getCompanyId());
|
couponsListVo.setCompany(company.getName());
|
rows.add(couponsListVo);
|
}
|
|
Map<String, String> geocode = gdMapGeocodingUtil.geocode(orderLogistics.getStartLon().toString(), orderLogistics.getStartLat().toString());
|
CompanyCity companyCity = companyCityService.selectOne(new EntityWrapper<CompanyCity>().eq("companyId", orderLogistics.getCompanyId()).eq("areaCode", geocode.get("districtCode")).eq("state", 1));
|
if(null == companyCity){
|
companyCity = companyCityService.selectOne(new EntityWrapper<CompanyCity>().eq("companyId", orderLogistics.getCompanyId()).eq("cityCode", geocode.get("cityCode")).eq("state", 1));
|
}
|
if(null == companyCity){
|
companyCity = companyCityService.selectOne(new EntityWrapper<CompanyCity>().eq("companyId", orderLogistics.getCompanyId()).eq("provinceCode", geocode.get("provinceCode")).eq("state", 1));
|
}
|
List<UserTaxiCard> userTaxiCards = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().eq("userId", uid)
|
.in("type", Arrays.asList(5)).like("companyCityId", "%" + companyCity.getId() + "%").where("now() between startTime and endTime"));
|
|
//全国卡
|
List<TaxiCard> taxiCards = taxiCardService.selectList(new EntityWrapper<TaxiCard>().eq("taxiCardType", 2).in("type", Arrays.asList(5)).eq("state", 1));
|
if(taxiCards.size() > 0) {
|
List<UserTaxiCard> userTaxiCards1 = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().eq("userId", uid)
|
.in("type", Arrays.asList(5)).in("taxiCardId", taxiCards.stream().map(TaxiCard::getId).collect(Collectors.toList())).where("now() between startTime and endTime"));
|
userTaxiCards.addAll(userTaxiCards1);
|
}
|
|
|
//亲密账户
|
List<UserUser> bindUserId = userUserService.selectList(new EntityWrapper<UserUser>().eq("bindUserId", uid));
|
CompanyCity finalCompanyCity = companyCity;
|
bindUserId.forEach(userUser -> {
|
List<UserTaxiCard> taxiCardPayments1 = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().in("type", Arrays.asList(5))
|
.like("companyCityId", "%" + finalCompanyCity.getId() + "%").eq("userId", userUser.getUserId()).where("now() between startTime and endTime"));
|
userTaxiCards.addAll(taxiCardPayments1);
|
|
//全国卡
|
if(taxiCards.size() > 0) {
|
List<UserTaxiCard> userTaxiCards1 = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().eq("userId", userUser.getUserId())
|
.in("type", Arrays.asList(5)).in("taxiCardId", taxiCards.stream().map(TaxiCard::getId).collect(Collectors.toList())).where("now() between startTime and endTime"));
|
userTaxiCards.addAll(userTaxiCards1);
|
}
|
});
|
|
for(UserTaxiCard t : userTaxiCards){
|
try {
|
CouponsListVo couponsListVo = new CouponsListVo();
|
couponsListVo.setId(t.getId());
|
couponsListVo.setDataType(2);
|
couponsListVo.setUserType(1);
|
couponsListVo.setTime(sdf.format(t.getEndTime()));
|
couponsListVo.setState(1);
|
couponsListVo.setTaxiCardType(t.getType());
|
Company company = companyService.selectById(t.getCompanyId());
|
couponsListVo.setCompany(company.getName());
|
couponsListVo.setName(taxiCardService.selectById(t.getTaxiCardId()).getName());
|
|
|
JSONObject jsonObject = JSON.parseObject(t.getContent());
|
JSONArray businessTypes = jsonObject.getJSONArray("businessTypes");
|
if(!businessTypes.toJavaList(Integer.class).contains(orderLogistics.getType())){
|
continue;
|
}
|
if(t.getType() == 5){//{"businessTypes":[4,5],"discount":5}
|
couponsListVo.setMoney(jsonObject.getDouble("discount"));
|
couponsListVo.setType(1);
|
}
|
|
String str = "";
|
TaxiCard taxiCard = taxiCardService.selectById(t.getTaxiCardId());
|
if(taxiCard.getTaxiCardType() == 1){
|
String[] split = taxiCard.getCompanyCityId().split(";");
|
for(String c : split){
|
CompanyCity companyCity1 = companyCityService.selectById(c);
|
if(ToolUtil.isNotEmpty(companyCity1.getAreaCode())){
|
Region region = regionService.selectOne(new EntityWrapper<Region>().eq("code", companyCity1.getAreaCode()));
|
str += region.getName() + ";";
|
continue;
|
}
|
if(ToolUtil.isNotEmpty(companyCity1.getCityCode())){
|
Region region = regionService.selectOne(new EntityWrapper<Region>().eq("code", companyCity1.getCityCode()));
|
str += region.getName() + ";";
|
continue;
|
}
|
if(ToolUtil.isNotEmpty(companyCity1.getProvinceCode())){
|
Region region = regionService.selectOne(new EntityWrapper<Region>().eq("code", companyCity1.getProvinceCode()));
|
str += region.getName() + ";";
|
continue;
|
}
|
}
|
}else{
|
str = "全国;";
|
}
|
couponsListVo.setCity(str.substring(0, str.length() - 1));
|
|
rows.add(couponsListVo);
|
}catch (Exception e){
|
e.printStackTrace();
|
}
|
}
|
Collections.sort(rows, new Comparator<CouponsListVo>() {
|
public int compare(CouponsListVo s1, CouponsListVo s2) {
|
return Integer.compare(s1.getId(), s2.getId());
|
}
|
});
|
|
if(rows.size() >= (pageNum + 1) * size){
|
rows = rows.subList(pageNum, pageNum + size);
|
}else if(pageNum < rows.size() && rows.size() < (pageNum + 1) * size){
|
rows = rows.subList(pageNum, rows.size());
|
}else{
|
rows = new ArrayList<>();
|
}
|
rows = rows.stream().filter(e->e.getMoney()<=orderLogistics.getOrderMoney()|| e.getDataType()==2).collect(Collectors.toList());
|
return rows;
|
}
|
|
public synchronized String getOrderNum() throws Exception{
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS");
|
return "LO" + sdf.format(new Date()) + UUIDUtil.getRandomCode(5);
|
}
|
|
@Override
|
@Transactional(propagation = Propagation.REQUIRES_NEW)
|
public ResultUtil payThankYouFee(Integer uid, Integer orderId, Double money, Integer payType, Integer type) throws Exception {
|
UserInfo userInfo = userInfoService.selectById(uid);
|
OrderLogistics orderLogistics = this.selectById(orderId);
|
ResultUtil resultUtil = ResultUtil.success();
|
if(payType == 1){//微信支付
|
String app = type == 1 ? "APP" : "JSAPI";
|
resultUtil = payMoneyUtil.weixinpay("感谢费", "", orderId + "_" + orderLogistics.getType() + "_" + UUIDUtil.getRandomCode(5), money.toString(), "/base/wxPayThankYouFee", app, userInfo.getAppletsOpenId());
|
paymentRecordService.saveData(3, uid, 1, orderId, orderLogistics.getType(), 1, money, "", 1);//添加预支付数据
|
}
|
if(payType == 2){//支付宝支付
|
resultUtil = payMoneyUtil.alipay("感谢费", "感谢费", "", orderId + "_" + orderLogistics.getType() + "_" + UUIDUtil.getRandomCode(5), money.toString(), "/base/aliPayThankYouFee");
|
paymentRecordService.saveData(1, uid, 1, orderId, orderLogistics.getType(), 2, money, "", 1);//添加预支付数据
|
}
|
if(payType == 3){//余额支付
|
if(userInfo.getBalance() == null || userInfo.getBalance() < money){
|
return ResultUtil.error("余额不足，无法完成支付");
|
}
|
// resultUtil= appOrderController.moneyPay(orderId,userInfo.getId(),money);
|
// if(resultUtil.getCode()==500){
|
// return ResultUtil.error("电子余额不足，无法完成支付");
|
// }
|
|
userInfo.setBalance(new BigDecimal(userInfo.getBalance()).subtract(new BigDecimal(money)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
|
|
SysIntegral query1 = sysIntegralMapper.query(orderLogistics.getCompanyId());
|
userInfo.setIntegral(userInfo.getIntegral() + (money.intValue() * query1.getIntegral()));//积分
|
|
//添加交易明细
|
transactionDetailsService.saveData(uid, (orderLogistics.getType() == 4 ? "同城小件物流-" : "跨城小件物流-") + "感谢费", money, 2, 1, 1, orderLogistics.getType(), orderId);
|
userInfoService.updateById(userInfo);
|
|
orderLogistics.setThankYouFee(money);
|
this.updateById(orderLogistics);
|
|
//添加已收入明细
|
incomeService.saveData(2, orderLogistics.getDriverId(), 6, orderLogistics.getId(), orderLogistics.getType(), money);
|
Driver driver = driverService.selectById(orderLogistics.getDriverId());
|
driver.setBusinessMoney(new BigDecimal(null != driver.getBusinessMoney() ? driver.getBusinessMoney() : 0).add(new BigDecimal(money)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
|
driver.setLaveBusinessMoney(new BigDecimal(null != driver.getLaveBusinessMoney() ? driver.getLaveBusinessMoney() : 0).add(new BigDecimal(money)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
|
driver.setBalance(new BigDecimal(null != driver.getBalance() ? driver.getBalance() : 0).add(new BigDecimal(money)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
|
driverService.updateById(driver);
|
systemNoticeService.addSystemNotice(1, "您已使用余额成功完成感谢费支付，谢谢使用！", uid, 1);
|
|
|
}
|
if(payType==4){
|
Double payMoney = orderLogistics.getThankYouFee();
|
Integer integer = paymentRecordService.saveData(1, uid, 1, orderId, orderLogistics.getType(), 4, money, "", 1);
|
resultUtil = appOrderController.placeAnOrder(new BigDecimal(money), 4,orderId,10,integer);
|
}
|
return resultUtil;
|
}
|
|
@Override
|
public void payThankYouFeeCallback(Integer orderId, String order_id, Integer payType) throws Exception {
|
OrderLogistics orderLogistics = this.selectById(orderId);
|
UserInfo userInfo = userInfoService.selectById(orderLogistics.getUserId());
|
PaymentRecord query = paymentRecordService.query(3, userInfo.getId(), 1, orderId, orderLogistics.getType(), payType, 1);
|
query.setState(2);
|
query.setCode(order_id);
|
paymentRecordService.updateById(query);
|
|
SysIntegral query1 = sysIntegralMapper.query(orderLogistics.getCompanyId());
|
userInfo.setIntegral(userInfo.getIntegral() + (query.getAmount().intValue() * query1.getIntegral()));//积分
|
|
//添加交易明细
|
transactionDetailsService.saveData(userInfo.getId(), (orderLogistics.getType() == 4 ? "同城小件物流-" : "跨城小件物流-") + "感谢费", query.getAmount(), 2, 1, 1, orderLogistics.getType(), orderId);
|
userInfoService.updateById(userInfo);
|
|
orderLogistics.setThankYouFee(query.getAmount());
|
this.updateById(orderLogistics);
|
|
//添加已收入明细
|
incomeService.saveData(2, orderLogistics.getDriverId(), 6, orderLogistics.getId(), orderLogistics.getType(), query.getAmount());
|
Driver driver = driverService.selectById(orderLogistics.getDriverId());
|
driver.setBusinessMoney(new BigDecimal(null != driver.getBusinessMoney() ? driver.getBusinessMoney() : 0).add(new BigDecimal(query.getAmount())).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
|
driver.setLaveBusinessMoney(new BigDecimal(null != driver.getLaveBusinessMoney() ? driver.getLaveBusinessMoney() : 0).add(new BigDecimal(query.getAmount())).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
|
driver.setBalance(new BigDecimal(null != driver.getBalance() ? driver.getBalance() : 0).add(new BigDecimal(query.getAmount())).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
|
driverService.updateById(driver);
|
systemNoticeService.addSystemNotice(1, "您已使用" + (payType == 1 ? "微信" : (payType==2?"支付宝":"云闪付")) + "成功完成感谢费支付，谢谢使用！", userInfo.getId(), 1);
|
}
|
}
|
