From c1a537aaa86fbb878cea6ab29a2df41ae15a4c48 Mon Sep 17 00:00:00 2001 From: puzhibing <393733352@qq.com> Date: 星期日, 18 二月 2024 16:22:35 +0800 Subject: [PATCH] 修改bug --- UserIGOTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/smallLogistics/server/impl/OrderLogisticsServiceImpl.java | 944 ++++++++++++++++++++++++++++++---------------------------- 1 files changed, 486 insertions(+), 458 deletions(-) diff --git a/UserIGOTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/smallLogistics/server/impl/OrderLogisticsServiceImpl.java b/UserIGOTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/smallLogistics/server/impl/OrderLogisticsServiceImpl.java index 59f16db..9c3b445 100644 --- a/UserIGOTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/smallLogistics/server/impl/OrderLogisticsServiceImpl.java +++ b/UserIGOTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/smallLogistics/server/impl/OrderLogisticsServiceImpl.java @@ -11,13 +11,19 @@ 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.model.OrderPrivateCar; 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.util.GoogleMap.*; import com.stylefeng.guns.modular.system.util.Tingg.TinggPayUtil; +import com.stylefeng.guns.modular.system.util.Tingg.TinggPayoutUtil; +import com.stylefeng.guns.modular.system.util.Tingg.model.AuthStatus; import com.stylefeng.guns.modular.system.util.Tingg.model.CheckoutRequest; +import com.stylefeng.guns.modular.system.util.Tingg.model.PayoutResponse; +import com.stylefeng.guns.modular.system.util.Tingg.model.Results; +import com.stylefeng.guns.modular.system.util.itextpdf.HtmlToPdfUtils; import com.stylefeng.guns.modular.system.warpper.BaseWarpper; import com.stylefeng.guns.modular.taxi.model.PaymentRecord; import com.stylefeng.guns.modular.taxi.service.IPaymentRecordService; @@ -25,12 +31,17 @@ import org.jsoup.Jsoup; import org.jsoup.nodes.Document; import org.jsoup.nodes.Element; +import org.jsoup.nodes.FormElement; +import org.jsoup.select.Elements; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; import javax.annotation.Resource; import java.io.File; +import java.io.FileInputStream; +import java.io.FileOutputStream; +import java.io.FileWriter; import java.math.BigDecimal; import java.math.MathContext; import java.math.RoundingMode; @@ -73,12 +84,10 @@ @Autowired private IUserInfoService userInfoService; - + @Resource + private UserActivityDiscount1Mapper userActivityDiscount1Mapper; @Autowired private IPaymentRecordService paymentRecordService; - - /* @Autowired - private ICBCPayUtil icbcPayUtil;*/ @Autowired private PayMoneyUtil payMoneyUtil; @@ -113,11 +122,11 @@ @Autowired private IUserCouponRecordService userCouponRecordService; - @Resource - private CarMapper carMapper; + @Autowired + private IBankCardService bankCardService; @Autowired - private IOrderEvaluateService orderEvaluateService; + private TinggPayoutUtil tinggPayoutUtil; @Value("${callbackPath}") private String callbackPath; @@ -125,7 +134,13 @@ @Value("${spring.mail.template-path}") private String templatePath; + @Autowired + private TEmailService emailService; + private static List<Integer> orderIds = new ArrayList<>(); + + @Autowired + private IPhoneService phoneService; @@ -162,19 +177,16 @@ * @throws Exception */ @Override - public ResultUtil queryLogisticsUnitPrice(Integer type, String startLonLat, String endAddress, Integer uid, Integer language) throws Exception { - FindPlaceFromTextVo findplacefromtext = GoogleMapUtil.textsearch(endAddress); - if(null == findplacefromtext){ - return ResultUtil.error(language == 1 ? "收货地址有误,无法查询具体地址信息" : language == 2 ? "The delivery address is incorrect, and the specific address information cannot be queried" : "L’adresse de livraison est incorrecte, impossible de vérifier l’adresse spécifique"); - } - Double lng = findplacefromtext.getLng(); - Double lat = findplacefromtext.getLat(); - ResultUtil<Map<String, Double>> price = this.getPrice1(type, startLonLat.split(",")[0], startLonLat.split(",")[1], lng.toString(), lat.toString(), language); + public ResultUtil queryLogisticsUnitPrice(Integer type, String startLonLat, String endLonLat, String endAddress, Integer uid, Integer language) throws Exception { + String[] split = endLonLat.split(","); + Double lng = Double.valueOf(split[0]); + Double lat = Double.valueOf(split[1]); + ResultUtil<Map<String, Object>> price = this.getPrice1(type, startLonLat.split(",")[0], startLonLat.split(",")[1], lng.toString(), lat.toString(), language); if(price.getCode() != 200){ return price; } Integer i = this.selectCount(new EntityWrapper<OrderLogistics>().eq("userId", uid).eq("isDelete", 1)); - Map<String, Double> map = price.getData(); + Map<String, Object> map = price.getData(); map.put("first", i.doubleValue()); return price; } @@ -188,18 +200,25 @@ * @return * @throws Exception */ - public ResultUtil queryPayMoney(Integer number, Integer type, String startLonLat, String endAddress, Integer language) throws Exception{ - FindPlaceFromTextVo findplacefromtext = GoogleMapUtil.textsearch(endAddress); - if(null == findplacefromtext){ - return ResultUtil.error(language == 1 ? "收货地址有误,无法查询具体地址信息" : language == 2 ? "The delivery address is incorrect, and the specific address information cannot be queried" : "L’adresse de livraison est incorrecte, impossible de vérifier l’adresse spécifique"); - } - Double lng = findplacefromtext.getLng(); - Double lat = findplacefromtext.getLat(); - ResultUtil<Map<String, Double>> price = this.getPrice1(type, startLonLat.split(",")[0], startLonLat.split(",")[1], lng.toString(), lat.toString(), language); + public ResultUtil queryPayMoney(Integer number, Integer type, String startLonLat, String endLonLat, String endAddress, Integer language) throws Exception{ + String[] split = endLonLat.split(","); + Double lng = Double.valueOf(split[0]); + Double lat = Double.valueOf(split[1]); + ResultUtil<Map<String, Object>> price = this.getPrice1(type, startLonLat.split(",")[0], startLonLat.split(",")[1], lng.toString(), lat.toString(), language); 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); + Map<String, Object> data = price.getData(); + Double ordinary = Double.valueOf(data.get("ordinary").toString()); + Double precious = Double.valueOf(data.get("precious").toString()); + data.put("ordinary", ordinary * number); + data.put("precious", precious * number); + } + if(price.getCode() == 200){ + Map<String, Object> data = price.getData(); + Double ordinary = Double.valueOf(data.get("ordinary").toString()); + Double precious = Double.valueOf(data.get("precious").toString()); + Double discountMoney = Double.valueOf(data.get("discountMoney").toString()); + data.put("ordinary", ordinary - discountMoney); + data.put("precious", precious - discountMoney); } return price; } @@ -229,7 +248,7 @@ */ @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, Integer language) throws Exception { + String recipientPhone, String endLonLat, String endAddress, Integer urgent, Double tipMoney, Date travelTime, Integer orderSource, Integer uid, Integer language) throws Exception { startAddress = startAddress.replaceAll("& #40;", "("); startAddress = startAddress.replaceAll("& #41;", ")"); endAddress = endAddress.replaceAll("& #40;", "("); @@ -237,7 +256,7 @@ OrderLogistics orderLogistics = new OrderLogistics(); Company query = companyCityService.query1(placementLon, placementLat); if(null == query){ - return ResultUtil.error(language == 1 ? "该地点暂无企业服务" : language == 2 ? "No corporate services are available at this location" : "Aucun service d’entreprise n’est disponible pour cet emplacement"); + return ResultUtil.error(language == 1 ? "该地点暂无企业服务" : language == 2 ? "No service yet at this area" : "Pas encore de service dans cette zone"); } orderLogistics.setCompanyId(query.getId()); orderLogistics.setType(type); @@ -250,7 +269,7 @@ orderLogistics.setPlacementLat(Double.valueOf(placementLat)); ReverseGeocodeVo reverseGeocode = GoogleMapUtil.getReverseGeocode(Double.valueOf(placementLat), Double.valueOf(placementLon)); if(null == reverseGeocode){ - return ResultUtil.error(language == 1 ? "解析地址出错" : language == 2 ? "Resolve address error" : "Erreur dans la résolution de l’adresse"); + return ResultUtil.error(language == 1 ? "解析地址出错" : language == 2 ? "Address resolution error" : "Erreur de résolution d’adresse"); } String address = reverseGeocode.getAddress(); @@ -258,12 +277,10 @@ orderLogistics.setStartLon(Double.valueOf(startLon)); orderLogistics.setStartLat(Double.valueOf(startLat)); orderLogistics.setStartAddress(startAddress); - FindPlaceFromTextVo findplacefromtext = GoogleMapUtil.textsearch(endAddress); - if(null == findplacefromtext){ - return ResultUtil.error(language == 1 ? "收货地址有误,无法查询具体地址信息" : language == 2 ? "The delivery address is incorrect, and the specific address information cannot be queried" : "L’adresse de livraison est incorrecte, impossible de vérifier l’adresse spécifique"); - } - Double lng = findplacefromtext.getLng(); - Double lat = findplacefromtext.getLat(); + + String[] split = endLonLat.split(","); + Double lng = Double.valueOf(split[0]); + Double lat = Double.valueOf(split[1]); orderLogistics.setEndLon(lng); orderLogistics.setEndLat(lat); orderLogistics.setEndAddress(endAddress); @@ -273,17 +290,31 @@ orderLogistics.setMileage(0D); orderLogistics.setIsReassign(1); orderLogistics.setReassignNotice(0); - ResultUtil<Map<String, Double>> price = this.getPrice1(type, String.valueOf(startLon), String.valueOf(startLat), lng.toString(), lat.toString(), language); + ResultUtil<Map<String, Object>> price = this.getPrice1(type, String.valueOf(startLon), String.valueOf(startLat), lng.toString(), lat.toString(), language); 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); + Map<String, Object> data = price.getData(); + Double ordinary = Double.valueOf(data.get("ordinary").toString()); + Double precious = Double.valueOf(data.get("precious").toString()); + Double discount = null; + if(null != data.get("discount")){ + discount = Double.valueOf(data.get("discount").toString()); } + Double discountMoney = Double.valueOf(data.get("discountMoney").toString()); + Integer activityId = null; + if(null != data.get("activityId")){ + activityId = Integer.valueOf(data.get("activityId").toString()); + } + orderLogistics.setOrderMoney((cargoType == 1 ? ordinary : precious) + tipMoney); + orderLogistics.setTravelMoney((cargoType == 1 ? ordinary : precious)); + if(type == 5){ + orderLogistics.setOrderMoney(((cargoType == 1 ? ordinary : precious) * cargoNumber) + tipMoney); + orderLogistics.setTravelMoney((cargoType == 1 ? ordinary : precious) * cargoNumber); + } + orderLogistics.setDiscount(discount); + orderLogistics.setDiscountMoney(discountMoney); + orderLogistics.setActivityId(activityId); orderLogistics.setTipMoney(tipMoney); orderLogistics.setState(7);//待支付 orderLogistics.setInsertTime(new Date()); @@ -293,8 +324,9 @@ this.insert(orderLogistics); //添加消息 - systemNoticeService.addSystemNotice(1, language == 1 ? "您的市内小件物流订单已下单成功,我们正在为您指派司机,请稍后!" : - language == 2 ? "Your local small parts logistics order has been successfully placed, we are assigning you a driver, please wait!" : "Votre commande de city small pieces logistics a été passée avec succès. Nous vous assignons un chauffeur. Plus tard!", orderLogistics.getUserId(), 1); + systemNoticeService.addSystemNotice(1, language == 1 ? "您的市内包裹订单已下单成功,我们正在为您指派司机,请稍后!" : + language == 2 ? "You've placed the delivery order successfully, we are assigning you a driver, please wait." + : "Vous avez passé la commande de livraison avec succès, nous vous attribuons un chauffeur, veuillez patienter.", orderLogistics.getUserId(), 1); BaseWarpper baseWarpper = new BaseWarpper(); baseWarpper.setId(orderLogistics.getId()); @@ -352,22 +384,25 @@ - public ResultUtil<Map<String, Double>> getPrice1(Integer type, String startLon, String startLat, String endLon, String endLat, Integer language) throws Exception{ + public ResultUtil<Map<String, Object>> getPrice1(Integer type, String startLon, String startLat, String endLon, String endLat, Integer language) throws Exception{ Company query = companyCityService.query1(startLon, startLat); if(null == query){ return ResultUtil.error(language == 1 ? "预约取货点暂无企业服务" : language == 2 ? - "There is no enterprise service at the reservation pickup point" : "Prise de rendez-vous point de collecte pas encore disponible pour les entreprises"); + "No service yet at the reserved pickup point." : "Les points de ramassage prévus ne sont pas disponibles pour le moment."); } Double price1 = 0D; Double price2 = 0D; + Double discount = null; + Double discountMoney = 0D; + Integer activityId = null; if(type == 4){//同城 Map<String, Object> query1 = systemPriceMapper.query(query.getId(), type, null); DistancematrixVo distancematrix = GoogleMapUtil.getDistancematrix(Double.valueOf(startLat), Double.valueOf(startLon), Double.valueOf(endLat), Double.valueOf(endLon)); if(null == distancematrix){ - return ResultUtil.error(language == 1 ? "计算距离出错" : language == 2 ? "Error in distance calculation" : "Erreur de calcul des distances"); + return ResultUtil.error(language == 1 ? "计算距离出错" : language == 2 ? "Errors in computing distance" : "Erreurs dans le calcul de la distance"); } if(distancematrix.getDistance() == 0){ - return ResultUtil.error(language == 1 ? "未获取到有效的距离" : language == 2 ? "A valid distance was not obtained" : "La distance effective n’est pas acquise"); + return ResultUtil.error(language == 1 ? "未获取到有效的距离" : language == 2 ? "Not obtaining available distance" : "Ne pas obtenir la distance disponible"); } String content = String.valueOf(query1.get("content")); JSONObject jsonObject = JSON.parseObject(content); @@ -386,7 +421,7 @@ price1 = jsonObject.getDouble("num11"); } if(dist.compareTo(jsonObject.getDouble("num10")) > 0){ - return ResultUtil.error(language == 1 ? "超出可服务范围" : language == 2 ? "Out of service range" : "Au-delà du service disponible"); + return ResultUtil.error(language == 1 ? "超出可服务范围" : language == 2 ? "Beyond service range" : "Au-delà de la portée de service"); } }else{ Map<String, Object> query1 = systemPriceMapper.query(query.getId(), type, null); @@ -395,9 +430,23 @@ price1 = jsonObject.getDouble("num1"); price2 = jsonObject.getDouble("num2"); } - Map<String, Double> map = new HashMap<>(); + + //计算折扣 + UserActivityDiscount1 query2 = userActivityDiscount1Mapper.query(query.getId()); + if(null != query2){ + activityId = query2.getId(); + discount = query2.getLogistics(); + if(null != discount){ + discountMoney = new BigDecimal(price1).multiply(new BigDecimal(discount / 10)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue(); + } + } + + Map<String, Object> map = new HashMap<>(); map.put("ordinary", price1);//普通 map.put("precious", price2);//贵重 + map.put("discount", discount);//折扣 + map.put("discountMoney", discountMoney);//折扣金额 + map.put("activityId", activityId);//折扣活动id return ResultUtil.success(map); } @@ -425,6 +474,7 @@ PushOrder pushOrder = pushOrderService.querys(i, 1, query.getId()).get(0); //获取空闲司机 List<Driver> list = driverService.queryIdleDriver(orderLogistics.getType(), null, orderLogistics.getStartLon(), orderLogistics.getStartLat(), pushOrder.getPushDistance(), null);//所有附近空闲司机 + System.err.println("【" + orderLogistics.getId() + "】空闲司机:" + JSON.toJSONString(list)); if(list.size() > 0){ double driverProportion = pushOrder.getDriverProportion() / 100;//推送占比计算成小数 int lastIndex = Double.valueOf(list.size() * driverProportion).intValue();//计算占比转成整数(下标截取) @@ -472,10 +522,10 @@ * @throws Exception */ @Override - public ResultUtil payLogisticsOrder(Integer payType, String accountNumber, Integer orderId, Integer type, Integer language) throws Exception { + public ResultUtil payLogisticsOrder(Integer payType, Integer bankCardId, Integer orderId,Integer couponId, Integer type, Integer language) throws Exception { OrderLogistics orderLogistics = this.selectById(orderId); if(orderLogistics.getState() != 7){ - return ResultUtil.error("订单已完成支付,不允许重复支付"); + return ResultUtil.error(language == 1 ? "订单已完成支付,不允许重复支付" : language == 2 ? "The order has been paid, recurring payments is not allowed." : "La commande a été payée, les paiements récurrents ne sont pas autorisés.", ""); } Integer uid = orderLogistics.getUserId(); Double orderMoney = orderLogistics.getOrderMoney(); @@ -483,7 +533,37 @@ orderMoney += null != orderLogistics.getTipMoney() ? orderLogistics.getTipMoney() : 0; } UserInfo userInfo = userInfoService.selectById(uid); - ResultUtil resultUtil = ResultUtil.success(); + ResultUtil resultUtil = ResultUtil.success(""); + orderLogistics.setCouponMoney(0D);//初始化历史数据 + orderLogistics.setCouponId(null); + //计算优惠券 + UserCouponRecord userCouponRecord = null; + if(null != couponId){ + userCouponRecord = userCouponRecordService.selectById(couponId); + if(userCouponRecord.getCompanyId() != orderLogistics.getCompanyId()){ + return ResultUtil.error(language == 1 ? "优惠券不能用于此订单" : language == 2 ? "Coupon cannot be used for this order." : "Le coupon ne peut pas être utilisé pour cette commande.", ""); + } + if(userCouponRecord.getState() == 2){ + return ResultUtil.error(language == 1 ? "优惠券已使用" : language == 2 ? "Coupon has been used." : "Le coupon a été utilisé.", ""); + } + if(userCouponRecord.getState() == 3){ + return ResultUtil.error(language == 1 ? "优惠券已过期" : language == 2 ? "Coupon is expired." : "Le coupon a expiré.", ""); + } + if(userCouponRecord.getCouponUseType() != 0 && userCouponRecord.getCouponUseType() != 4){ + return ResultUtil.error(language == 1 ? "优惠券不能用于此订单" : language == 2 ? "Coupon cannot be used for this order." : "Le coupon ne peut pas être utilisé pour cette commande.", ""); + } + if(userCouponRecord.getCouponType() == 2 && orderMoney.compareTo(userCouponRecord.getFullMoney()) < 0){ + return ResultUtil.error(language == 1 ? "优惠券不能用于此订单" : language == 2 ? "Coupon cannot be used for this order." : "Le coupon ne peut pas être utilisé pour cette commande.", ""); + } + orderMoney = orderMoney - userCouponRecord.getMoney(); + orderLogistics.setCouponMoney(userCouponRecord.getMoney()); + orderLogistics.setCouponId(couponId); + } + //折扣 + if(null != orderLogistics.getActivityId()){ + orderMoney = orderMoney - orderLogistics.getDiscount(); + } + orderMoney=new BigDecimal(orderMoney).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue(); if(payType == 1) {//手机支付 SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS"); @@ -491,7 +571,7 @@ CheckoutRequest checkoutRequest = new CheckoutRequest(); checkoutRequest.setMsisdn(Long.valueOf(userInfo.getPhone())); checkoutRequest.setCustomerEmail(userInfo.getEmail()); - checkoutRequest.setAccountNumber(accountNumber); + checkoutRequest.setAccountNumber(userInfo.getPhone()); checkoutRequest.setCustomerFirstName(userInfo.getFirstName()); checkoutRequest.setCustomerLastName(userInfo.getLastName()); checkoutRequest.setRequestAmount(orderMoney); @@ -499,14 +579,47 @@ checkoutRequest.setRequestDescription("Travel completion payment"); checkoutRequest.setCallbackUrl(callbackPath + "/base/wxPayOrderTaxi"); checkoutRequest.setPendingRedirectUrl(""); - checkoutRequest.setSuccessRedirectUrl("https://10pz685243.zicp.fun"); - checkoutRequest.setFailRedirectUrl("https://www.baidu.com"); - return TinggPayUtil.checkoutRequest(checkoutRequest); + checkoutRequest.setSuccessRedirectUrl("http://182.160.16.251:81/payMoney/pages/success.html"); + checkoutRequest.setFailRedirectUrl("http://182.160.16.251:81/payMoney/pages/fail.html"); + resultUtil = TinggPayUtil.checkoutRequest(checkoutRequest); + if(resultUtil.getCode()==200){ + paymentRecordService.saveData(1, null, null, orderId, 4, 1, orderMoney, null, 1);//添加预支付数据 + }else{ + resultUtil = ResultUtil.error(language == 1 ? "支付失败" : language == 2 ? "Payment failure" : "Paiement échoué", ""); + } + return resultUtil; + } + + if(payType == 2) {//银行卡支付 + BankCard bankCard = bankCardService.selectById(bankCardId); + SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS"); + String merchantTransactionId = sdf.format(new Date()) + "4" + language + orderId; + CheckoutRequest checkoutRequest = new CheckoutRequest(); + checkoutRequest.setMsisdn(Long.valueOf(bankCard.getCode())); + checkoutRequest.setCustomerEmail(userInfo.getEmail()); + checkoutRequest.setAccountNumber(bankCard.getCode()); + checkoutRequest.setCustomerFirstName(bankCard.getFirstName()); + checkoutRequest.setCustomerLastName(bankCard.getLastName()); + checkoutRequest.setRequestAmount(orderMoney); + checkoutRequest.setMerchantTransactionId(merchantTransactionId); + checkoutRequest.setRequestDescription("Travel completion payment"); + checkoutRequest.setCallbackUrl(callbackPath + "/base/wxPayOrderTaxi"); + checkoutRequest.setPendingRedirectUrl(""); + checkoutRequest.setSuccessRedirectUrl("http://182.160.16.251:81/payMoney/pages/success.html"); + checkoutRequest.setFailRedirectUrl("http://182.160.16.251:81/payMoney/pages/fail.html"); + resultUtil = TinggPayUtil.checkoutRequest(checkoutRequest); + + if(resultUtil.getCode()==200){ + paymentRecordService.saveData(1, null, null, orderId, 4, 2, orderMoney, null, 1);//添加预支付数据 + }else{ + resultUtil = ResultUtil.error(language == 1 ? "支付失败" : language == 2 ? "Payment failure" : "Paiement échoué", ""); + } + return resultUtil; } if(payType == 3){//余额支付 if(userInfo.getBalance() == null || userInfo.getBalance() < orderMoney){ - return ResultUtil.error(language == 1 ? "账户余额不足" : language == 2 ? "Insufficient account balance" : "Solde de compte insuffisant"); + return ResultUtil.error(language == 1 ? "账户余额不足" : language == 2 ? "Insufficient balance" : "Solde insuffisant", ""); } userInfo.setBalance(new BigDecimal(userInfo.getBalance()).subtract(new BigDecimal(orderMoney)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); @@ -514,84 +627,20 @@ SysIntegral query1 = sysIntegralMapper.query(orderLogistics.getCompanyId()); userInfo.setIntegral(userInfo.getIntegral() + (orderMoney.intValue() * query1.getIntegral()));//积分 + //处理优惠券 + if(null != userCouponRecord){ + userCouponRecord.setState(2); + userCouponRecord.setEndTime(new Date()); + userCouponRecordService.updateById(userCouponRecord); + } + //添加交易明细 - transactionDetailsService.saveData(uid, "小件物流下单支付", orderMoney, 2, 1, 1, 4, orderId); + transactionDetailsService.saveData(uid, "包裹下单支付", orderMoney, 2, 1, 1, 4, orderId); userInfoService.updateById(userInfo); orderLogistics.setState(1);//小件物流先支付后司机抢单 orderLogistics.setPayType(3); orderLogistics.setPayMoney(orderMoney); - - - - if(ToolUtil.isNotEmpty(userInfo.getEmail())){ - String path = templatePath + "user/receiptLogistics.html"; - Document document = Jsoup.parse(new File(path), "UTF-8"); - SimpleDateFormat sdf2 = new SimpleDateFormat("yyyy年MM月dd日"); - SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy/MM/dd HH:mm"); - if(1 == language){ - document.getElementById("english").attr("style", "display: none;"); - document.getElementById("french").attr("style", "display: none;"); - Element title_chinese = document.getElementById("title_chinese"); - title_chinese.text(sdf2.format(orderLogistics.getTravelTime()) + ",您在I-GO1个订单消费GHS " + orderLogistics.getPayMoney()); - Element xcf_chinese = document.getElementById("xcf_chinese"); - xcf_chinese.text("GHS " + orderLogistics.getOrderMoney()); - Element xj_chinese = document.getElementById("xj_chinese"); - xj_chinese.text("GHS " + orderLogistics.getOrderMoney()); - Element pay_type_chinese = document.getElementById("pay_type_chinese"); - pay_type_chinese.text("余额"); - Element pay_money_chinese = document.getElementById("pay_money_chinese"); - pay_money_chinese.text("GHS " + orderLogistics.getPayMoney()); - Element pay_time_chinese = document.getElementById("pay_time_chinese"); - pay_time_chinese.text(sdf1.format(orderLogistics.getTravelTime())); - Element start_address_chinese = document.getElementById("start_address_chinese"); - start_address_chinese.text(orderLogistics.getStartAddress()); - Element end_address_chinese = document.getElementById("end_address_chinese"); - end_address_chinese.text(orderLogistics.getEndAddress()); - } - if(2 == language){ - document.getElementById("chinese").attr("style", "display: none;"); - document.getElementById("french").attr("style", "display: none;"); - Element title_english = document.getElementById("title_english"); - title_english.text(sdf2.format(orderLogistics.getTravelTime()) + ",You spent GHS " + orderLogistics.getPayMoney() + " on the trip "); - Element xcf_english = document.getElementById("xcf_english"); - xcf_english.text("GHS " + orderLogistics.getOrderMoney()); - Element xj_english = document.getElementById("xj_english"); - xj_english.text("GHS " + orderLogistics.getOrderMoney()); - Element pay_type_english = document.getElementById("pay_type_english"); - pay_type_english.text("balance"); - Element pay_money_english = document.getElementById("pay_money_english"); - pay_money_english.text("GHS " + orderLogistics.getPayMoney()); - Element pay_time_english = document.getElementById("pay_time_english"); - pay_time_english.text(sdf1.format(orderLogistics.getTravelTime())); - Element start_address_english = document.getElementById("start_address_english"); - start_address_english.text(orderLogistics.getStartAddress()); - Element end_address_english = document.getElementById("end_address_english"); - end_address_english.text(orderLogistics.getEndAddress()); - } - if(3 == language){ - document.getElementById("chinese").attr("style", "display: none;"); - document.getElementById("english").attr("style", "display: none;"); - Element title_french = document.getElementById("title_french"); - title_french.text(sdf2.format(orderLogistics.getTravelTime()) + ",Vous consommez GHS " + orderLogistics.getPayMoney() + " sur votre commande i-go1 le "); - Element xcf_french = document.getElementById("xcf_french"); - xcf_french.text("GHS " + orderLogistics.getOrderMoney()); - Element xj_french = document.getElementById("xj_french"); - xj_french.text("GHS " + orderLogistics.getOrderMoney()); - Element pay_type_french = document.getElementById("pay_type_french"); - pay_type_french.text("Le solde"); - Element pay_money_french = document.getElementById("pay_money_french"); - pay_money_french.text("GHS " + orderLogistics.getPayMoney()); - Element pay_time_french = document.getElementById("pay_time_french"); - pay_time_french.text(sdf1.format(orderLogistics.getTravelTime())); - Element start_address_french = document.getElementById("start_address_french"); - start_address_french.text(orderLogistics.getStartAddress()); - Element end_address_french = document.getElementById("end_address_french"); - end_address_french.text(orderLogistics.getEndAddress()); - } - - EmailUtil.send(userInfo.getEmail(), language == 1 ? "市内小件物流收据" : language == 2 ? "Reset password" : "Réinitialiser le mot de passe", document.html()); - } // TODO: 2020/5/24 这里需要给司机和用户推送订单状态 new Thread(new Runnable() { @@ -600,9 +649,10 @@ pushUtil.pushOrderState(1, orderLogistics.getUserId(), orderLogistics.getId(), orderLogistics.getType(), orderLogistics.getState(), 0); } }).start(); - systemNoticeService.addSystemNotice(1, language == 1 ? "您已使用余额成功完成小件物流订单支付,谢谢使用!" : language == 2 - ? "You have successfully used the balance to complete the small logistics order payment, thank you for using!" - : "Vous avez utilisé le solde pour compléter avec succès le paiement de la commande logistique de petites pièces. Merci d’utiliser!", uid, 1); + + systemNoticeService.addSystemNotice(1, language == 1 ? "您已成功完成包裹订单支付,谢谢使用!" : language == 2 + ? "You've paid for the delivery order successfully, thank you for using I-GO" : + "Vous avez payé la commande de livraison avec succès, merci d’utiliser I-GO", uid, 1); this.pushOrder(orderLogistics);//推单 } @@ -610,84 +660,21 @@ SysIntegral query1 = sysIntegralMapper.query(orderLogistics.getCompanyId()); userInfo.setIntegral(userInfo.getIntegral() + (orderMoney.intValue() * query1.getIntegral()));//积分 + //处理优惠券和红包 + if(null != userCouponRecord){ + userCouponRecord.setState(2); + userCouponRecord.setEndTime(new Date()); + userCouponRecordService.updateById(userCouponRecord); + } + //添加交易明细 - transactionDetailsService.saveData(uid, "小件物流下单支付", orderMoney, 2, 1, 1, 4, orderId); + transactionDetailsService.saveData(uid, "包裹下单支付", orderMoney, 2, 1, 1, 4, orderId); userInfoService.updateById(userInfo); orderLogistics.setState(1);//小件物流先支付后司机抢单 orderLogistics.setDriverPay(1); orderLogistics.setPayType(4); orderLogistics.setPayMoney(orderMoney); - - if(ToolUtil.isNotEmpty(userInfo.getEmail())){ - String path = templatePath + "user/receiptLogistics.html"; - Document document = Jsoup.parse(new File(path), "UTF-8"); - SimpleDateFormat sdf2 = new SimpleDateFormat("yyyy年MM月dd日"); - SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy/MM/dd HH:mm"); - if(1 == language){ - document.getElementById("english").attr("style", "display: none;"); - document.getElementById("french").attr("style", "display: none;"); - Element title_chinese = document.getElementById("title_chinese"); - title_chinese.text(sdf2.format(orderLogistics.getTravelTime()) + ",您在I-GO1个订单消费GHS " + orderLogistics.getPayMoney()); - Element xcf_chinese = document.getElementById("xcf_chinese"); - xcf_chinese.text("GHS " + orderLogistics.getOrderMoney()); - Element xj_chinese = document.getElementById("xj_chinese"); - xj_chinese.text("GHS " + orderLogistics.getOrderMoney()); - Element pay_type_chinese = document.getElementById("pay_type_chinese"); - pay_type_chinese.text("现金"); - Element pay_money_chinese = document.getElementById("pay_money_chinese"); - pay_money_chinese.text("GHS " + orderLogistics.getPayMoney()); - Element pay_time_chinese = document.getElementById("pay_time_chinese"); - pay_time_chinese.text(sdf1.format(orderLogistics.getTravelTime())); - Element start_address_chinese = document.getElementById("start_address_chinese"); - start_address_chinese.text(orderLogistics.getStartAddress()); - Element end_address_chinese = document.getElementById("end_address_chinese"); - end_address_chinese.text(orderLogistics.getEndAddress()); - } - if(2 == language){ - document.getElementById("chinese").attr("style", "display: none;"); - document.getElementById("french").attr("style", "display: none;"); - Element title_english = document.getElementById("title_english"); - title_english.text(sdf2.format(orderLogistics.getTravelTime()) + ",You spent GHS " + orderLogistics.getPayMoney() + " on the trip "); - Element xcf_english = document.getElementById("xcf_english"); - xcf_english.text("GHS " + orderLogistics.getOrderMoney()); - Element xj_english = document.getElementById("xj_english"); - xj_english.text("GHS " + orderLogistics.getOrderMoney()); - Element pay_type_english = document.getElementById("pay_type_english"); - pay_type_english.text("cash"); - Element pay_money_english = document.getElementById("pay_money_english"); - pay_money_english.text("GHS " + orderLogistics.getPayMoney()); - Element pay_time_english = document.getElementById("pay_time_english"); - pay_time_english.text(sdf1.format(orderLogistics.getTravelTime())); - Element start_address_english = document.getElementById("start_address_english"); - start_address_english.text(orderLogistics.getStartAddress()); - Element end_address_english = document.getElementById("end_address_english"); - end_address_english.text(orderLogistics.getEndAddress()); - } - if(3 == language){ - document.getElementById("chinese").attr("style", "display: none;"); - document.getElementById("english").attr("style", "display: none;"); - Element title_french = document.getElementById("title_french"); - title_french.text(sdf2.format(orderLogistics.getTravelTime()) + ",Vous consommez GHS " + orderLogistics.getPayMoney() + " sur votre commande i-go1 le "); - Element xcf_french = document.getElementById("xcf_french"); - xcf_french.text("GHS " + orderLogistics.getOrderMoney()); - Element xj_french = document.getElementById("xj_french"); - xj_french.text("GHS " + orderLogistics.getOrderMoney()); - Element pay_type_french = document.getElementById("pay_type_french"); - pay_type_french.text("espèces"); - Element pay_money_french = document.getElementById("pay_money_french"); - pay_money_french.text("GHS " + orderLogistics.getPayMoney()); - Element pay_time_french = document.getElementById("pay_time_french"); - pay_time_french.text(sdf1.format(orderLogistics.getTravelTime())); - Element start_address_french = document.getElementById("start_address_french"); - start_address_french.text(orderLogistics.getStartAddress()); - Element end_address_french = document.getElementById("end_address_french"); - end_address_french.text(orderLogistics.getEndAddress()); - } - - EmailUtil.send(userInfo.getEmail(), language == 1 ? "市内小件物流收据" : language == 2 ? "Reset password" : "Réinitialiser le mot de passe", document.html()); - } - // TODO: 2020/5/24 这里需要给司机和用户推送订单状态 new Thread(new Runnable() { @@ -698,9 +685,9 @@ } }).start(); - systemNoticeService.addSystemNotice(1, language == 1 ? "您已使用现金成功完成小件物流订单支付,谢谢使用!" : language == 2 - ? "You have successfully completed the payment of small logistics order with cash, thank you for using!" : - "Vous avez utilisé de l’argent pour compléter avec succès le paiement de la commande small pieces logistics. Merci d’utiliser!", uid, 1); + systemNoticeService.addSystemNotice(1, language == 1 ? "您已成功完成包裹订单支付,谢谢使用!" : language == 2 + ? "You've paid for the delivery order successfully, thank you for using I-GO" : + "Vous avez payé la commande de livraison avec succès, merci d’utiliser I-GO", uid, 1); this.pushOrder(orderLogistics);//推单 } @@ -721,36 +708,54 @@ * @throws Exception */ @Override - public ResultUtil payLogisticsOrder_(Integer payType, String accountNumber, Integer orderId, Integer type, Integer language) throws Exception { + public ResultUtil payLogisticsOrder_(Integer payType, Integer bankCardId, Integer orderId, Integer type, Integer language) 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(""); - if(payType == 1){//线上支付 + if(payType == 1){//手机支付 SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS"); String merchantTransactionId = sdf.format(new Date()) + "4" + language + orderId; CheckoutRequest checkoutRequest = new CheckoutRequest(); checkoutRequest.setMsisdn(Long.valueOf(userInfo.getPhone())); checkoutRequest.setCustomerEmail(userInfo.getEmail()); - checkoutRequest.setAccountNumber(accountNumber); + checkoutRequest.setAccountNumber(userInfo.getPhone()); checkoutRequest.setCustomerFirstName(userInfo.getFirstName()); checkoutRequest.setCustomerLastName(userInfo.getLastName()); checkoutRequest.setRequestAmount(orderMoney); checkoutRequest.setMerchantTransactionId(merchantTransactionId); checkoutRequest.setRequestDescription("Travel completion payment"); - checkoutRequest.setCallbackUrl(callbackPath + "/base/wxPayOrderTaxi"); + checkoutRequest.setCallbackUrl(callbackPath + "/base/wxPayOrderLogisticsSpread"); checkoutRequest.setPendingRedirectUrl(""); - checkoutRequest.setSuccessRedirectUrl("https://10pz685243.zicp.fun"); - checkoutRequest.setFailRedirectUrl("https://www.baidu.com"); + checkoutRequest.setSuccessRedirectUrl("http://182.160.16.251:81/payMoney/pages/success.html"); + checkoutRequest.setFailRedirectUrl("http://182.160.16.251:81/payMoney/pages/fail.html"); return TinggPayUtil.checkoutRequest(checkoutRequest); - - } + if(payType == 2){//银行卡支付 + BankCard bankCard = bankCardService.selectById(bankCardId); + SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS"); + String merchantTransactionId = sdf.format(new Date()) + "4" + language + orderId; + CheckoutRequest checkoutRequest = new CheckoutRequest(); + checkoutRequest.setMsisdn(Long.valueOf(bankCard.getCode())); + checkoutRequest.setCustomerEmail(userInfo.getEmail()); + checkoutRequest.setAccountNumber(bankCard.getCode()); + checkoutRequest.setCustomerFirstName(bankCard.getFirstName()); + checkoutRequest.setCustomerLastName(bankCard.getLastName()); + checkoutRequest.setRequestAmount(orderMoney); + checkoutRequest.setMerchantTransactionId(merchantTransactionId); + checkoutRequest.setRequestDescription("Travel completion payment"); + checkoutRequest.setCallbackUrl(callbackPath + "/base/wxPayOrderLogisticsSpread"); + checkoutRequest.setPendingRedirectUrl(""); + checkoutRequest.setSuccessRedirectUrl("http://182.160.16.251:81/payMoney/pages/success.html"); + checkoutRequest.setFailRedirectUrl("http://182.160.16.251:81/payMoney/pages/fail.html"); + return TinggPayUtil.checkoutRequest(checkoutRequest); + } + if(payType == 3){//余额支付 if(userInfo.getBalance() == null || userInfo.getBalance() < orderMoney){ - return ResultUtil.error(language == 1 ? "账户余额不足" : language == 2 ? "Insufficient account balance" : "Solde de compte insuffisant"); + return ResultUtil.error(language == 1 ? "账户余额不足" : language == 2 ? "Insufficient balance" : "Solde insuffisant"); } userInfo.setBalance(new BigDecimal(userInfo.getBalance()).subtract(new BigDecimal(orderMoney)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); @@ -759,7 +764,7 @@ userInfo.setIntegral(userInfo.getIntegral() + (orderMoney.intValue() * query1.getIntegral()));//积分 //添加交易明细 - transactionDetailsService.saveData(uid, "小件物流补差价", orderMoney, 2, 1, 1, 4, orderId); + transactionDetailsService.saveData(uid, "包裹补差价", orderMoney, 2, 1, 1, 4, orderId); userInfoService.updateById(userInfo); orderLogistics.setState(12);//已支付差价 @@ -805,9 +810,9 @@ } }).start(); - systemNoticeService.addSystemNotice(1, language == 1 ? "您已使用余额成功完成小件物流订单差价支付,谢谢使用!" : language == 2 - ? "You have successfully completed the price difference payment of small logistics order with the balance, thank you for using!" - : "Vous avez utilisé le solde pour compléter avec succès le paiement de la différence de prix de la commande de petites pièces logistiques. Merci d’utiliser!", uid, 1); + systemNoticeService.addSystemNotice(1, language == 1 ? "您已成功完成包裹订单差价支付,谢谢使用!" : language == 2 + ? "You've paid for the difference of delivery order successfully, thank you for using I-GO" + : "Vous avez payé la différence de commande de livraison avec succès, merci d’utiliser I-GO", uid, 1); } if(payType == 4){//现金支付 @@ -815,7 +820,7 @@ userInfo.setIntegral(userInfo.getIntegral() + (orderMoney.intValue() * query1.getIntegral()));//积分 //添加交易明细 - transactionDetailsService.saveData(uid, "小件物流补差价", orderMoney, 2, 1, 1, 4, orderId); + transactionDetailsService.saveData(uid, "包裹补差价", orderMoney, 2, 1, 1, 4, orderId); userInfoService.updateById(userInfo); orderLogistics.setState(12);//已支付差价 @@ -826,6 +831,132 @@ orderLogisticsSpread.setPayType(4); orderLogisticsSpread.setDriverPay(1); orderLogisticsSpreadService.updateById(orderLogisticsSpread); + + //添加已收入明细 +// 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(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.getCompanyId()).eq("type", 2).eq("incomeId", orderLogistics.getId()).eq("orderType", orderLogistics.getType())); +// System.out.println("小件物流补差价income======"+income); +// 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, language == 1 ? "您已成功完成包裹订单差价支付,谢谢使用!" : language == 2 + ? "You've paid for the difference of delivery order successfully, thank you for using I-GO" + : "Vous avez payé la différence de commande de livraison avec succès, merci d’utiliser I-GO", uid, 1); + } + + + this.updateById(orderLogistics); + return resultUtil; + } + + + + @Override + public void payOrderLogisticsCallback(Integer id, String order_id, Integer language) throws Exception { + OrderLogistics orderLogistics = this.selectById(id); + PaymentRecord query = paymentRecordService.query(1, null, null, Integer.valueOf(id), orderLogistics.getType(), null, 1); + if(null != query){ + //添加交易明细 + transactionDetailsService.saveData(orderLogistics.getUserId(), "完成订单", query.getAmount(), 2, 1, 1, orderLogistics.getType(), query.getOrderId()); + orderLogistics.setState(1);//先支付后抢单 + orderLogistics.setPayType(query.getPayType()); + 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); + } + + 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, language == 1 ? "您已成功完成包裹订单支付,谢谢使用!" : language == 2 + ? "You've paid for the delivery order successfully, thank you for using I-GO" : + "Vous avez payé la commande de livraison avec succès, merci d’utiliser I-GO", orderLogistics.getUserId(), 1); + + this.pushOrder(orderLogistics);//推单 + }else{ + System.err.println("预支付数据异常(orderId = " + id + ")"); + } + } + + + + @Override + public void payOrderLogisticsSpreadCallback(Integer id, String order_id, Integer language) throws Exception { + OrderLogistics orderLogistics = this.selectById(id); + OrderLogisticsSpread orderLogisticsSpread = orderLogisticsSpreadService.selectOne(new EntityWrapper<OrderLogisticsSpread>().eq("orderLogisticsId", id)); + PaymentRecord query = paymentRecordService.query(1, null, null, Integer.valueOf(id), orderLogistics.getType(), null, 1); + if(null != query){ + Double orderMoney = query.getAmount(); + query.setState(2); + query.setCode(order_id); + paymentRecordService.updateById(query); + + orderLogisticsSpread.setPayMoney(query.getAmount()); + orderLogisticsSpread.setPayTime(new Date()); + orderLogisticsSpread.setPayType(query.getPayType()); + orderLogisticsSpread.setDriverPay(1); + orderLogisticsSpreadService.updateById(orderLogisticsSpread); + + UserInfo userInfo = userInfoService.selectById(orderLogistics.getUserId()); + SysIntegral query1 = sysIntegralMapper.query(orderLogistics.getCompanyId()); + userInfo.setIntegral(userInfo.getIntegral() + (orderMoney.intValue() * query1.getIntegral()));//积分 + + //添加交易明细 + transactionDetailsService.saveData(orderLogistics.getUserId(), "包裹补差价", orderMoney, 2, 1, 1, 4, id); + userInfoService.updateById(userInfo); + + orderLogistics.setState(12);//已支付差价 + this.updateById(orderLogistics); //添加已收入明细 Company company = companyService.selectById(orderLogistics.getCompanyId()); @@ -862,190 +993,9 @@ } }).start(); - systemNoticeService.addSystemNotice(1, language == 1 ? "您已使用现金成功完成小件物流订单差价支付,谢谢使用!" : language == 2 - ? "You have successfully completed the price difference payment of small logistics order with cash, thank you for using!" - : "Vous avez utilisé de l’argent pour compléter avec succès le paiement de la différence de prix de la commande de petites pièces logistiques. Merci d’utiliser!", uid, 1); - } - - - this.updateById(orderLogistics); - return resultUtil; - } - - - - @Override - public void payOrderLogisticsCallback(Integer id, String order_id, Integer type, Integer language) throws Exception { - OrderLogistics orderLogistics = this.selectById(id); - PaymentRecord query = paymentRecordService.query(1, null, null, Integer.valueOf(id), orderLogistics.getType(), type, 1); - if(null != query){ - //添加交易明细 - transactionDetailsService.saveData(orderLogistics.getUserId(), "完成订单", 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); - - query.setState(2); - query.setCode(order_id); - paymentRecordService.updateById(query); - - if(ToolUtil.isNotEmpty(userInfo.getEmail())){ - String path = templatePath + "user/receiptLogistics.html"; - Document document = Jsoup.parse(new File(path), "UTF-8"); - SimpleDateFormat sdf = new SimpleDateFormat("yyyy年MM月dd日"); - SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy/MM/dd HH:mm"); - if(1 == language){ - document.getElementById("english").attr("style", "display: none;"); - document.getElementById("french").attr("style", "display: none;"); - Element title_chinese = document.getElementById("title_chinese"); - title_chinese.text(sdf.format(orderLogistics.getTravelTime()) + ",您在I-GO1个订单消费GHS " + orderLogistics.getPayMoney()); - Element xcf_chinese = document.getElementById("xcf_chinese"); - xcf_chinese.text("GHS " + orderLogistics.getOrderMoney()); - Element xj_chinese = document.getElementById("xj_chinese"); - xj_chinese.text("GHS " + orderLogistics.getOrderMoney()); - Element pay_type_chinese = document.getElementById("pay_type_chinese"); - pay_type_chinese.text("余额"); - Element pay_money_chinese = document.getElementById("pay_money_chinese"); - pay_money_chinese.text("GHS " + orderLogistics.getPayMoney()); - Element pay_time_chinese = document.getElementById("pay_time_chinese"); - pay_time_chinese.text(sdf1.format(orderLogistics.getTravelTime())); - Element start_address_chinese = document.getElementById("start_address_chinese"); - start_address_chinese.text(orderLogistics.getStartAddress()); - Element end_address_chinese = document.getElementById("end_address_chinese"); - end_address_chinese.text(orderLogistics.getEndAddress()); - } - if(2 == language){ - document.getElementById("chinese").attr("style", "display: none;"); - document.getElementById("french").attr("style", "display: none;"); - Element title_english = document.getElementById("title_english"); - title_english.text(sdf.format(orderLogistics.getTravelTime()) + ",You spent GHS " + orderLogistics.getPayMoney() + " on the trip "); - Element xcf_english = document.getElementById("xcf_english"); - xcf_english.text("GHS " + orderLogistics.getOrderMoney()); - Element xj_english = document.getElementById("xj_english"); - xj_english.text("GHS " + orderLogistics.getOrderMoney()); - Element pay_type_english = document.getElementById("pay_type_english"); - pay_type_english.text("balance"); - Element pay_money_english = document.getElementById("pay_money_english"); - pay_money_english.text("GHS " + orderLogistics.getPayMoney()); - Element pay_time_english = document.getElementById("pay_time_english"); - pay_time_english.text(sdf1.format(orderLogistics.getTravelTime())); - Element start_address_english = document.getElementById("start_address_english"); - start_address_english.text(orderLogistics.getStartAddress()); - Element end_address_english = document.getElementById("end_address_english"); - end_address_english.text(orderLogistics.getEndAddress()); - } - if(3 == language){ - document.getElementById("chinese").attr("style", "display: none;"); - document.getElementById("english").attr("style", "display: none;"); - Element title_french = document.getElementById("title_french"); - title_french.text(sdf.format(orderLogistics.getTravelTime()) + ",Vous consommez GHS " + orderLogistics.getPayMoney() + " sur votre commande i-go1 le "); - Element xcf_french = document.getElementById("xcf_french"); - xcf_french.text("GHS " + orderLogistics.getOrderMoney()); - Element xj_french = document.getElementById("xj_french"); - xj_french.text("GHS " + orderLogistics.getOrderMoney()); - Element pay_type_french = document.getElementById("pay_type_french"); - pay_type_french.text("Le solde"); - Element pay_money_french = document.getElementById("pay_money_french"); - pay_money_french.text("GHS " + orderLogistics.getPayMoney()); - Element pay_time_french = document.getElementById("pay_time_french"); - pay_time_french.text(sdf1.format(orderLogistics.getTravelTime())); - Element start_address_french = document.getElementById("start_address_french"); - start_address_french.text(orderLogistics.getStartAddress()); - Element end_address_french = document.getElementById("end_address_french"); - end_address_french.text(orderLogistics.getEndAddress()); - } - - EmailUtil.send(userInfo.getEmail(), language == 1 ? "市内小件物流收据" : language == 2 ? "Reset password" : "Réinitialiser le mot de passe", document.html()); - } - - - - // 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 ? "微信" : "支付宝") + "成功完成小件物流订单支付,谢谢使用!", 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, null, null, Integer.valueOf(id), orderLogistics.getType(), type, 1); - if(null != query){ - //添加交易明细 - transactionDetailsService.saveData(orderLogistics.getUserId(), "小件物流补差价", query.getAmount(), 2, 1, 1, 4, query.getOrderId()); - orderLogistics.setState(4);//待取货 - this.updateById(orderLogistics); - - 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 = null; - BigDecimal c = null; - 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.getCompanyId()).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 ? "微信" : "支付宝") + "成功完成小件物流订单差价支付,谢谢使用!", orderLogistics.getUserId(), 1); + systemNoticeService.addSystemNotice(1, language == 1 ? "您已成功完成包裹订单差价支付,谢谢使用!" : language == 2 + ? "You've paid for the difference of delivery order successfully, thank you for using I-GO" + : "Vous avez payé la différence de commande de livraison avec succès, merci d’utiliser I-GO", orderLogistics.getUserId(), 1); }else{ System.err.println("预支付数据异常(orderId = " + id + ")"); } @@ -1076,9 +1026,31 @@ * @throws Exception */ @Override - public List<Map<String, Object>> queryMyOrderList(Integer uid, Integer pageNum, Integer size) throws Exception { + public List<Map<String, Object>> queryMyOrderList(Integer uid, Integer pageNum, Integer size, Integer language) throws Exception { pageNum = (pageNum - 1) * size; - List<Map<String, Object>> maps = orderLogisticsMapper.queryMyOrderList(uid, pageNum, size); + List<Map<String, Object>> maps = orderLogisticsMapper.queryMyOrderList(uid, pageNum, size, language); + for (Map<String, Object> map : maps) { + if(null != map.get("orderTime")){ + String orderTime = map.get("orderTime").toString(); + map.put("orderTime", DateUtil.conversionFormat(language, orderTime)); + } + if(null != map.get("time")){ + String time = map.get("time").toString(); + map.put("time", DateUtil.conversionFormat(language, time)); + } + Integer orderId = Integer.valueOf(String.valueOf(map.get("orderId"))); + Integer state = Integer.valueOf(String.valueOf(map.get("state"))); + if(state == 6){ + map.put("receipt", "http://182.160.16.251:81/files/html/parcel_receipt_" + orderId + ".html"); + }else{ + map.put("receipt", ""); + } + if(state == 7){ + Double discountMoney = Double.valueOf(map.get("discountMoney").toString()); + Double orderMoney = Double.valueOf(map.get("orderMoney").toString()); + map.put("orderMoney", orderMoney - discountMoney); + } + } return maps; } @@ -1089,16 +1061,31 @@ * @return */ @Override - public List<Map<String, Object>> queryMyTravelRecord(Integer uid) { - return orderLogisticsMapper.queryMyTravelRecord(uid); + public List<Map<String, Object>> queryMyTravelRecord(Integer language, Integer uid) { + List<Map<String, Object>> list = orderLogisticsMapper.queryMyTravelRecord(uid); + for (Map<String, Object> map : list) { + if(null != map.get("time")){ + String time = map.get("time").toString(); + map.put("time", DateUtil.conversionFormat(language, time)); + } + } + return list; } @Override - public List<Map<String, Object>> queryInvoiceOrder(Integer type, Date startTime, Date endTime, Double startMoney, Double endMoney, Integer uid, Integer orderType) throws Exception { + public List<Map<String, Object>> queryInvoiceOrder(Integer language, 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); + List<Map<String, Object>> list = orderLogisticsMapper.queryInvoiceOrder(type, startTime, endTime, startMoney, endMoney, uid, orderType); + for (Map<String, Object> map : list) { + map.put("orderName", language == 1 ? "包裹订单" : language == 2 ? "Delivery" : "Livraison"); + if(null != map.get("time")){ + String time = map.get("time").toString(); + map.put("time", DateUtil.conversionFormat(language, time)); + } + } + return list; } @@ -1118,10 +1105,10 @@ OrderLogistics orderLogistics = this.selectById(id); Integer integer = null; if(null == orderLogistics){ - return ResultUtil.error(language == 1 ? "取消订单失败,订单信息有误" : language == 2 ? "Failed to cancel the order, the order information is incorrect" : "Échec de l'annulation de la commande, les informations de la commande sont incorrectes"); + return ResultUtil.error(language == 1 ? "取消订单失败,订单信息有误" : language == 2 ? "Failed to cancel order, order-information error." : "Échec de l’annulation de la commande, erreur d’information de commande."); } if(orderLogistics.getState() > 5 && orderLogistics.getState() != 7 && orderLogistics.getState() != 11){ - return ResultUtil.error(language == 1 ? "取消订单失败,不合法的操作" : language == 2 ? "Cancel order failed, illegal operation" : "Échec de l'annulation de la commande, opération illégale"); + return ResultUtil.error(language == 1 ? "取消订单失败,不合法的操作" : language == 2 ? "Failed to cancel order, illegal operation." : "Échec de l’annulation de la commande, opération illégale."); } if(orderLogistics.getState() == 7){ @@ -1153,24 +1140,24 @@ orderCancelService.insert(orderCancel); orderLogistics.setState(10); this.updateById(orderLogistics); - integer = orderCancel.getId(); //调用回退接口 PaymentRecord query = paymentRecordService.query(1, orderLogistics.getUserId(), 1, orderLogistics.getId(), orderLogistics.getType(), 1, 2); - Map<String, String> merrefund = payMoneyUtil.wxRefund(query.getCode(),orderLogistics.getId() + "," + orderLogistics.getType(),query.getAmount()+"",query.getAmount()+"",""); - //Map<String, Object> merrefund = icbcPayUtil.merrefund(query.getCode(), "", query.getAmount(), orderLogistics.getId() + "_" + orderLogistics.getType(), orderLogistics.getOrderNum()); - if ("SUCCESS".equals(merrefund.get("return_code"))) {//成功 - //添加交易明细 - transactionDetailsService.saveData(orderLogistics.getUserId(), "小件物流取消退款", query.getAmount(), 1, 1, 1, 4, orderLogistics.getId()); - }else{ - return ResultUtil.error("退款返回未知异常"); + if(null == query){ + return ResultUtil.error("支付数据异常,无法完成退款"); } - /*if (Integer.valueOf(refundqry.get("code").toString()) == 0 && Integer.valueOf(refundqry.get("pay_status").toString()) == 1) {//失败 - return ResultUtil.error("订单取消失败(退款不成功)"); + UserInfo userInfo = userInfoService.selectById(orderLogistics.getUserId()); + SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS"); + String payerTransactionID = sdf.format(new Date()) + orderCancel.getId(); + PayoutResponse payoutResponse = tinggPayoutUtil.sendPayout(userInfo.getPhoneOperator(), "+" + userInfo.getPhone(), payerTransactionID, query.getAmount().doubleValue(), callbackPath + "/base/orderCancelRefundCallback", "取消订单退款"); + AuthStatus authStatus = payoutResponse.getAuthStatus(); + Results results = payoutResponse.getResults().get(0); + String statusCode = results.getStatusCode(); + if(!"131".equals(authStatus.getAuthStatusCode())){ + return ResultUtil.error(authStatus.getAuthStatusDescription()); } - if (Integer.valueOf(refundqry.get("code").toString()) == 0 && Integer.valueOf(refundqry.get("pay_status").toString()) == 2) {//未知 - - - }*/ + if(!"139".equals(statusCode)){ + return ResultUtil.error(results.getStatusDescription()); + } } if(null != orderLogistics.getPayType() && orderLogistics.getPayType() == 2){//支付宝 OrderCancel orderCancel = new OrderCancel(); @@ -1187,28 +1174,21 @@ integer = orderCancel.getId(); //调用回退接口 PaymentRecord query = paymentRecordService.query(1, orderLogistics.getUserId(), 1, orderLogistics.getId(), orderLogistics.getType(), 2, 2); - /*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) {//成功 - //添加交易明细 - transactionDetailsService.saveData(orderLogistics.getUserId(), "小件物流取消退款", query.getAmount(), 1, 1, 1, 4, orderLogistics.getId()); - } - 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("退款返回未知异常"); - - } - }*/ - Map<String, String> merrefund = payMoneyUtil.aliRefund(query.getCode(),query.getAmount()+""); - //Map<String, Object> merrefund = icbcPayUtil.merrefund(query.getCode(), "", query.getAmount(), orderLogistics.getId() + "_" + orderLogistics.getType(), orderLogistics.getOrderNum()); - if ("SUCCESS".equals(merrefund.get("return_code"))) {//成功 - //添加交易明细 - transactionDetailsService.saveData(orderLogistics.getUserId(), "小件物流取消退款", query.getAmount(), 1, 1, 1, 4, orderLogistics.getId()); - }else{ - return ResultUtil.error("退款返回未知异常"); + if(null == query){ + return ResultUtil.error("支付数据异常,无法完成退款"); + } + UserInfo userInfo = userInfoService.selectById(orderLogistics.getUserId()); + SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS"); + String payerTransactionID = sdf.format(new Date()) + orderCancel.getId(); + PayoutResponse payoutResponse = tinggPayoutUtil.sendPayout(userInfo.getPhoneOperator(), "+" + userInfo.getPhone(), payerTransactionID, query.getAmount().doubleValue(), callbackPath + "/base/orderCancelRefundCallback", "取消订单退款"); + AuthStatus authStatus = payoutResponse.getAuthStatus(); + Results results = payoutResponse.getResults().get(0); + String statusCode = results.getStatusCode(); + if(!"131".equals(authStatus.getAuthStatusCode())){ + return ResultUtil.error(authStatus.getAuthStatusDescription()); + } + if(!"139".equals(statusCode)){ + return ResultUtil.error(results.getStatusDescription()); } } if(null != orderLogistics.getPayType() && orderLogistics.getPayType() == 3){//余额 @@ -1230,7 +1210,30 @@ integer = orderCancel.getId(); //添加交易明细 - transactionDetailsService.saveData(orderLogistics.getUserId(), "小件物流取消退款", orderLogistics.getPayMoney(), 1, 1, 1, 4, orderLogistics.getId()); + transactionDetailsService.saveData(orderLogistics.getUserId(), "包裹取消退款", orderLogistics.getPayMoney(), 1, 1, 1, 4, orderLogistics.getId()); + } + + + if(null != orderLogistics.getPayType() && orderLogistics.getPayType() == 4){//现金 +// UserInfo userInfo = userInfoService.selectById(orderLogistics.getUserId()); +// userInfo.setBalance(userInfo.getBalance() + orderLogistics.getPayMoney()); +// userInfoService.updateById(userInfo); + OrderCancel orderCancel = new OrderCancel(); + orderCancel.setOrderId(id); + orderCancel.setOrderType(orderLogistics.getType()); + orderCancel.setReason(reason); + orderCancel.setRemark(remark); + orderCancel.setState(2); + orderCancel.setInsertTime(new Date()); + orderCancel.setUserType(1); + orderCancelService.insert(orderCancel); + + orderLogistics.setState(10); + this.updateById(orderLogistics); + integer = orderCancel.getId(); + + //添加交易明细 + transactionDetailsService.saveData(orderLogistics.getUserId(), "包裹取消退款", orderLogistics.getPayMoney(), 1, 1, 1, 4, orderLogistics.getId()); } if(null != orderLogistics.getDriverId()){ @@ -1243,7 +1246,8 @@ } //添加消息 - systemNoticeService.addSystemNotice(1, language == 1 ? "您已成功取消小件物流订单,谢谢使用!" : language == 2 ? "You have successfully cancelled the small logistics order, thank you for using" : "Vous avez annulé avec succès la petite commande logistique, merci d'utiliser", orderLogistics.getUserId(), 1); + systemNoticeService.addSystemNotice(1, language == 1 ? "您已成功取消包裹订单,谢谢使用!" : language == 2 ? "You've cancelled the delivery order successfully, thank you for using I-GO " + : "Vous avez annulé la commande de livraison avec succès, merci d’utiliser I-GO", orderLogistics.getUserId(), 1); Map<String, Object> map = new HashMap<>(); map.put("id", integer); return ResultUtil.success(map); @@ -1298,19 +1302,38 @@ Map<String, Object> map = new HashMap<>(); UserInfo userInfo = userInfoService.selectById(uid); map.put("balance", userInfo.getBalance()); - map.put("coupon", 0); + OrderLogistics orderLogistics = this.selectById(orderId); + UserActivityDiscount1 query2 = userActivityDiscount1Mapper.query(orderLogistics.getCompanyId()); + double v = orderLogistics.getOrderMoney(); + if(null != query2){ + Integer orderNum=this.selectCount(new EntityWrapper<OrderLogistics>().eq("userId",orderLogistics.getUserId()).eq("activityId",query2.getId()).last(" and to_days(getoffTime) = to_days(now())")); + if(query2.getDistance()*1000>orderLogistics.getMileage() && query2.getOrderNum()>orderNum){ + Double special = query2.getSpecial(); + orderLogistics.setDiscount(special); + Double orderMoney = orderLogistics.getOrderMoney(); + v = new BigDecimal(orderMoney).multiply(new BigDecimal(special / 10)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue(); + } + } + int i = userCouponRecordService.queryAvailable(uid, orderLogistics.getCompanyId(), 1, 4, v); + i = i + userCouponRecordService.queryAvailable(uid, orderLogistics.getCompanyId(), 1, 0, v); + map.put("coupon", i); return map; } @Override - public Map<String, Object> queryOrderInfo(Integer orderId) throws Exception { + public Map<String, Object> queryOrderInfo(Integer language, Integer orderId) throws Exception { Map<String, Object> map = orderLogisticsMapper.queryOrderInfo(orderId); + if(null != map.get("travelTime")){ + String travelTime = map.get("travelTime").toString(); + map.put("travelTime", DateUtil.conversionFormat1(language, travelTime)); + } + Integer state = Integer.valueOf(String.valueOf(map.get("state"))); OrderLogistics orderLogistics = this.selectById(orderId); if(null != map.get("reassignNotice") && Integer.valueOf(String.valueOf(map.get("reassignNotice"))) == 2){//改派完成,重新获取了新的司机数据,开始修改数据防止继续调用 orderLogistics.setReassignNotice(0); this.updateById(orderLogistics); } - if(Integer.valueOf(String.valueOf(map.get("state"))) == 11){ + if(state == 11){ map.put("state", map.get("oldState")); } Map<String, String> geocode = gdMapGeocodingUtil.geocode(map.get("startLon").toString(), map.get("startLat").toString()); @@ -1321,6 +1344,11 @@ String driverId = redisUtil.getValue("DEVICE_" + map.get("driverId")); map.put("device", ToolUtil.isNotEmpty(driverId) ? 2 : 1); map.put("orderType", orderLogistics.getType()); + if(state == 6){ + map.put("receipt", "http://182.160.16.251:81/files/html/parcel_receipt_" + orderId + ".html"); + }else{ + map.put("receipt", ""); + } return map; } @@ -1331,10 +1359,10 @@ @Override - public List<Map<String, Object>> queryCoupon(Integer orderId, Integer uid, Integer pageNum, Integer size) throws Exception { + public List<Map<String, Object>> queryCoupon(Integer language, Integer orderId, Integer uid, Integer pageNum, Integer size) throws Exception { OrderLogistics orderLogistics = this.selectById(orderId); - List<Map<String, Object>> list = userCouponRecordService.queryCoupon(uid, orderLogistics.getCompanyId(), 1, 4, orderLogistics.getOrderMoney(), pageNum, size); - List<Map<String, Object>> list1 = userCouponRecordService.queryCoupon(uid, orderLogistics.getCompanyId(), 1, 0, orderLogistics.getOrderMoney(), pageNum, size); + List<Map<String, Object>> list = userCouponRecordService.queryCoupon(language, uid, orderLogistics.getCompanyId(), 1, 4, orderLogistics.getOrderMoney() - orderLogistics.getDiscountMoney(), pageNum, size); + List<Map<String, Object>> list1 = userCouponRecordService.queryCoupon(language, uid, orderLogistics.getCompanyId(), 1, 0, orderLogistics.getOrderMoney() - orderLogistics.getDiscountMoney(), pageNum, size); list.addAll(list1); return list; } -- Gitblit v1.7.1