| | |
| | | package com.stylefeng.guns.modular.crossCity.server.impl; |
| | | |
| | | import com.alibaba.fastjson.JSON; |
| | | import com.alibaba.fastjson.JSONArray; |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.baomidou.mybatisplus.annotations.TableField; |
| | | import com.baomidou.mybatisplus.mapper.EntityWrapper; |
| | |
| | | import com.stylefeng.guns.modular.crossCity.server.ILineService; |
| | | import com.stylefeng.guns.modular.crossCity.server.IOrderCrossCityService; |
| | | import com.stylefeng.guns.modular.crossCity.warpper.OrderCrossCityWarpper; |
| | | import com.stylefeng.guns.modular.smallLogistics.dao.OrderLogisticsMapper; |
| | | import com.stylefeng.guns.modular.smallLogistics.model.OrderLogistics; |
| | | import com.stylefeng.guns.modular.smallLogistics.server.IOrderLogisticsService; |
| | | 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.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.OrderServerWarpper; |
| | | 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 java.math.RoundingMode; |
| | | import java.text.SimpleDateFormat; |
| | | import java.util.*; |
| | | import java.util.stream.Collectors; |
| | | |
| | | import static com.stylefeng.guns.modular.taxi.service.impl.OrderTaxiServiceImpl.orderIds; |
| | | |
| | |
| | | @Autowired |
| | | private PayMoneyUtil payMoneyUtil; |
| | | |
| | | @Autowired |
| | | private IOrderLogisticsService orderLogisticsService; |
| | | |
| | | @Autowired |
| | | private ITaxiCardPaymentService taxiCardPaymentService; |
| | | |
| | | @Autowired |
| | | private ICompanyService companyService; |
| | | |
| | | @Autowired |
| | | private ITaxiCardService taxiCardService; |
| | | |
| | | @Autowired |
| | | private IUserUserService userUserService; |
| | | |
| | | @Autowired |
| | | private IUserTaxiCardService userTaxiCardService; |
| | | |
| | | @Autowired |
| | | private IRegionService regionService; |
| | | |
| | | |
| | | @Value("${callbackPath}") |
| | | private String callbackPath; |
| | | |
| | |
| | | } |
| | | |
| | | |
| | | @Override |
| | | public PreferentialDataVo queryBalance1(Integer orderId, Integer uid) throws Exception { |
| | | UserInfo userInfo = userInfoService.selectById(uid); |
| | | PreferentialDataVo preferentialDataVo = new PreferentialDataVo(); |
| | | preferentialDataVo.setBalance(userInfo.getBalance()); |
| | | OrderCrossCity orderCrossCity = this.selectById(orderId); |
| | | |
| | | //获取优惠券中最优数据 |
| | | List<UserCouponRecord> list = userCouponRecordService.selectList(new EntityWrapper<UserCouponRecord>().eq("companyId", orderCrossCity.getCompanyId()).eq("state", 1).in("couponUseType", Arrays.asList(0, 3)).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(orderCrossCity.getOrderMoney().compareTo(userCouponRecord.getFullMoney()) >= 0 && price.compareTo(userCouponRecord.getMoney()) < 0){ |
| | | price = userCouponRecord.getMoney(); |
| | | id = userCouponRecord.getId(); |
| | | type = 1; |
| | | } |
| | | } |
| | | } |
| | | |
| | | //获取打车卡中最优数 |
| | | Map<String, String> geocode = gdMapGeocodingUtil.geocode(orderCrossCity.getStartLon().toString(), orderCrossCity.getStartLat().toString()); |
| | | CompanyCity companyCity = companyCityService.selectOne(new EntityWrapper<CompanyCity>().eq("companyId", orderCrossCity.getCompanyId()).eq("areaCode", geocode.get("districtCode")).eq("state", 1)); |
| | | if(null == companyCity){ |
| | | companyCity = companyCityService.selectOne(new EntityWrapper<CompanyCity>().eq("companyId", orderCrossCity.getCompanyId()).eq("cityCode", geocode.get("cityCode")).eq("state", 1)); |
| | | } |
| | | if(null == companyCity){ |
| | | companyCity = companyCityService.selectOne(new EntityWrapper<CompanyCity>().eq("companyId", orderCrossCity.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(1, 2, 3, 4)).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(1, 2, 3, 4)).in("taxiCardId", taxiCards.stream().map(TaxiCard::getId).collect(Collectors.toList())).where("now() between startTime and endTime")); |
| | | userTaxiCards.addAll(userTaxiCards2); |
| | | } |
| | | Map<String, Object> map = getOptimalTaxiCards(orderCrossCity, 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(1, 2, 3, 4)) |
| | | .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(1, 2, 3, 4)).in("taxiCardId", taxiCards.stream().map(TaxiCard::getId).collect(Collectors.toList())).where("now() between startTime and endTime")); |
| | | userTaxiCards_.addAll(userTaxiCards2); |
| | | } |
| | | }); |
| | | map = getOptimalTaxiCards(orderCrossCity, 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()); |
| | | |
| | | preferentialDataVo.setObjectId(id); |
| | | preferentialDataVo.setDiscountAmount(price); |
| | | preferentialDataVo.setType(type); |
| | | return preferentialDataVo; |
| | | } |
| | | |
| | | |
| | | public Map<String, Object> getOptimalTaxiCards(OrderCrossCity orderCrossCity, Double price, Integer id, Integer type, List<UserTaxiCard> userTaxiCards) throws Exception{ |
| | | Map<String, Object> map = new HashMap<>(); |
| | | for(UserTaxiCard t : userTaxiCards){ |
| | | JSONObject jsonObject = JSON.parseObject(t.getContent()); |
| | | List<Integer> integers = jsonObject.getJSONArray("businessTypes").toJavaList(Integer.class); |
| | | if(!integers.contains(3)){ |
| | | continue; |
| | | } |
| | | if(t.getType() == 1){//打折次数卡{"businessTypes":[1,2,3],"time":5,"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"],"discount":5} |
| | | Integer time = jsonObject.getInteger("time"); |
| | | if(time == 0){ |
| | | continue; |
| | | } |
| | | JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum"); |
| | | Double discount = jsonObject.getDouble("discount"); |
| | | SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); |
| | | SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); |
| | | Date date = new Date(); |
| | | for(int i = 0; i < timeQuantum.size(); i++){ |
| | | String[] split = timeQuantum.getString(i).split(" - "); |
| | | Date s = sdf1.parse(sdf.format(date) + " " + split[0]); |
| | | Date e = sdf1.parse(sdf.format(date) + " " + split[1]); |
| | | if(s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()){ |
| | | double v = new BigDecimal(orderCrossCity.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; |
| | | } |
| | | } |
| | | } |
| | | |
| | | } |
| | | if(t.getType() == 2){//优惠卡{"businessTypes":[1,2,3],"fullReduction":[[50,3],[100,5],[150,10]]} |
| | | JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum"); |
| | | JSONArray fullReduction = jsonObject.getJSONArray("fullReduction"); |
| | | SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); |
| | | SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); |
| | | Date date = new Date(); |
| | | for(int i = 0; i < timeQuantum.size(); i++){ |
| | | String[] split = timeQuantum.getString(i).split(" - "); |
| | | Date s = sdf1.parse(sdf.format(date) + " " + split[0]); |
| | | Date e = sdf1.parse(sdf.format(date) + " " + split[1]); |
| | | if(s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()){ |
| | | for(int j = fullReduction.size() - 1; j >= 0; j--){ |
| | | JSONArray jsonArray = fullReduction.getJSONArray(j); |
| | | Double p = jsonArray.getDouble(0);//满金额 |
| | | Double y = jsonArray.getDouble(1);//优惠金额 |
| | | if(orderCrossCity.getOrderMoney().compareTo(p) >= 0 && price.compareTo(y) < 0){ |
| | | price = y; |
| | | id = t.getId(); |
| | | type = 2; |
| | | } |
| | | } |
| | | } |
| | | } |
| | | |
| | | } |
| | | if(t.getType() == 3){//次数卡{"businessTypes":[1,2,3],"time":1,"discountAmount":10} |
| | | Integer time = jsonObject.getInteger("time"); |
| | | if(time == 0){ |
| | | continue; |
| | | } |
| | | JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum"); |
| | | Double discountAmount = jsonObject.getDouble("discountAmount"); |
| | | SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); |
| | | SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); |
| | | Date date = new Date(); |
| | | for(int i = 0; i < timeQuantum.size(); i++){ |
| | | String[] split = timeQuantum.getString(i).split(" - "); |
| | | Date s = sdf1.parse(sdf.format(date) + " " + split[0]); |
| | | Date e = sdf1.parse(sdf.format(date) + " " + split[1]); |
| | | if(s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()){ |
| | | if(price.compareTo(discountAmount) < 0){ |
| | | price = discountAmount; |
| | | id = t.getId(); |
| | | type = 2; |
| | | } |
| | | } |
| | | } |
| | | } |
| | | if(t.getType() == 4){//打折天数卡{"businessTypes":[1,2,3],"discount":5,"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"]} |
| | | Double discount = jsonObject.getDouble("discount");//折扣 |
| | | JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");//使用时间段 |
| | | SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); |
| | | SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); |
| | | Date date = new Date(); |
| | | for(int i = 0; i < timeQuantum.size(); i++){ |
| | | String[] split = timeQuantum.getString(i).split(" - "); |
| | | Date s = sdf1.parse(sdf.format(date) + " " + split[0]); |
| | | Date e = sdf1.parse(sdf.format(date) + " " + split[1]); |
| | | if(s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()){ |
| | | double v = new BigDecimal(orderCrossCity.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; |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * 获取支付页面的优惠券列表 |
| | | * @param orderId |
| | |
| | | } |
| | | |
| | | |
| | | @Override |
| | | public List<CouponsListVo> queryCouponList(Integer orderId, Integer uid, Integer pageNum, Integer size) throws Exception { |
| | | pageNum = (pageNum - 1) * size; |
| | | OrderCrossCity orderCrossCity = this.selectById(orderId); |
| | | List<CouponsListVo> rows = new ArrayList<>(); |
| | | List<UserCouponRecord> list = userCouponRecordService.selectList(new EntityWrapper<UserCouponRecord>().eq("companyId", orderCrossCity.getCompanyId()) |
| | | .eq("state", 1).in("couponUseType", Arrays.asList(0, 3)).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(orderCrossCity.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(orderCrossCity.getStartLon().toString(), orderCrossCity.getStartLat().toString()); |
| | | CompanyCity companyCity = companyCityService.selectOne(new EntityWrapper<CompanyCity>().eq("companyId", orderCrossCity.getCompanyId()).eq("areaCode", geocode.get("districtCode")).eq("state", 1)); |
| | | if(null == companyCity){ |
| | | companyCity = companyCityService.selectOne(new EntityWrapper<CompanyCity>().eq("companyId", orderCrossCity.getCompanyId()).eq("cityCode", geocode.get("cityCode")).eq("state", 1)); |
| | | } |
| | | if(null == companyCity){ |
| | | companyCity = companyCityService.selectOne(new EntityWrapper<CompanyCity>().eq("companyId", orderCrossCity.getCompanyId()).eq("provinceCode", geocode.get("provinceCode")).eq("state", 1)); |
| | | } |
| | | List<UserTaxiCard> userTaxiCards = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().eq("userId", uid) |
| | | .in("type", Arrays.asList(1, 2, 3, 4)).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(1, 2, 3, 4)).eq("state", 1)); |
| | | if(taxiCards.size() > 0){ |
| | | List<UserTaxiCard> userTaxiCards1 = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().eq("userId", uid) |
| | | .in("type", Arrays.asList(1, 2, 3, 4)).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(1, 2, 3, 4)) |
| | | .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(1, 2, 3, 4)).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.setTaxiCardType(t.getType()); |
| | | couponsListVo.setTime(sdf.format(t.getEndTime())); |
| | | couponsListVo.setState(1); |
| | | 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(3)){ |
| | | continue; |
| | | } |
| | | if(t.getType() == 1){//{"businessTypes":[1,2,3],"time":5,"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"],"discount":5} |
| | | Integer time = jsonObject.getInteger("time"); |
| | | if(time == 0){ |
| | | continue; |
| | | } |
| | | JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum"); |
| | | SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd"); |
| | | boolean b = true; |
| | | for(int i = 0; i < timeQuantum.size(); i++){ |
| | | String[] split = timeQuantum.getString(i).split(" - "); |
| | | Date s = sdf.parse(sdf1.format(new Date()) + " " + split[0]); |
| | | Date e = sdf.parse(sdf1.format(new Date()) + " " + split[1]); |
| | | if(s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()){ |
| | | b = false; |
| | | break; |
| | | } |
| | | } |
| | | if(b){ |
| | | continue; |
| | | } |
| | | couponsListVo.setMoney(jsonObject.getDouble("discount")); |
| | | couponsListVo.setType(1); |
| | | } |
| | | if(t.getType() == 2){//{"businessTypes":[1,2,3],"fullReduction":[[50,3],[100,5],[150,10]]} |
| | | JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum"); |
| | | SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd"); |
| | | boolean b = true; |
| | | for(int i = 0; i < timeQuantum.size(); i++){ |
| | | String[] split = timeQuantum.getString(i).split(" - "); |
| | | Date s = sdf.parse(sdf1.format(new Date()) + " " + split[0]); |
| | | Date e = sdf.parse(sdf1.format(new Date()) + " " + split[1]); |
| | | if(s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()){ |
| | | b = false; |
| | | break; |
| | | } |
| | | } |
| | | if(b){ |
| | | continue; |
| | | } |
| | | |
| | | JSONArray fullReduction = jsonObject.getJSONArray("fullReduction"); |
| | | b = true; |
| | | for(int i = fullReduction.size() - 1; i >= 0; i--){ |
| | | Double m = fullReduction.getJSONArray(i).getDouble(0); |
| | | Double y = fullReduction.getJSONArray(i).getDouble(1); |
| | | if(m.compareTo(orderCrossCity.getOrderMoney()) <= 0){ |
| | | couponsListVo.setMoney(y); |
| | | couponsListVo.setFullMoney(m); |
| | | b = false; |
| | | break; |
| | | } |
| | | } |
| | | if(b){ |
| | | continue; |
| | | } |
| | | couponsListVo.setType(2); |
| | | } |
| | | if(t.getType() == 3){//{"businessTypes":[1,2,3],"time":1,"discountAmount":10} |
| | | Integer time = jsonObject.getInteger("time"); |
| | | if(time == 0){ |
| | | continue; |
| | | } |
| | | JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum"); |
| | | SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd"); |
| | | boolean b = true; |
| | | for(int i = 0; i < timeQuantum.size(); i++){ |
| | | String[] split = timeQuantum.getString(i).split(" - "); |
| | | Date s = sdf.parse(sdf1.format(new Date()) + " " + split[0]); |
| | | Date e = sdf.parse(sdf1.format(new Date()) + " " + split[1]); |
| | | if(s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()){ |
| | | b = false; |
| | | break; |
| | | } |
| | | } |
| | | if(b){ |
| | | continue; |
| | | } |
| | | couponsListVo.setMoney(jsonObject.getDouble("discountAmount")); |
| | | couponsListVo.setType(2); |
| | | } |
| | | if(t.getType() == 4){//{"businessTypes":[1,2,3],"discount":5,"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"]} |
| | | JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum"); |
| | | SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd"); |
| | | boolean b = true; |
| | | for(int i = 0; i < timeQuantum.size(); i++){ |
| | | String[] split = timeQuantum.getString(i).split(" - "); |
| | | Date s = sdf.parse(sdf1.format(new Date()) + " " + split[0]); |
| | | Date e = sdf.parse(sdf1.format(new Date()) + " " + split[1]); |
| | | if(s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()){ |
| | | b = false; |
| | | break; |
| | | } |
| | | } |
| | | if(b){ |
| | | continue; |
| | | } |
| | | 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<>(); |
| | | } |
| | | return rows; |
| | | } |
| | | |
| | | /** |
| | | * 订单支付 |
| | | * @param payType |
| | |
| | | public ResultUtil payCrossCityOrder(Integer payType, Integer orderId, Integer couponId, Integer type) throws Exception { |
| | | OrderCrossCity orderCrossCity = this.selectById(orderId); |
| | | if(orderCrossCity.getState() != 7){ |
| | | return ResultUtil.error("订单已完成支付,不允许重复支付", ""); |
| | | return ResultUtil.error("订单已完成支付,不允许重复支付"); |
| | | } |
| | | Integer uid = orderCrossCity.getUserId(); |
| | | Double orderMoney = orderCrossCity.getOrderMoney(); |
| | | UserInfo userInfo = userInfoService.selectById(uid); |
| | | ResultUtil resultUtil = ResultUtil.success(new Object()); |
| | | ResultUtil resultUtil = ResultUtil.success(); |
| | | orderCrossCity.setCouponMoney(0D);//初始化历史数据 |
| | | orderCrossCity.setCouponId(null); |
| | | |
| | |
| | | UserCouponRecord userCouponRecord = null; |
| | | if(null != couponId){ |
| | | userCouponRecord = userCouponRecordService.selectById(couponId); |
| | | if(null != userCouponRecord){ |
| | | if(userCouponRecord.getCompanyId() != orderCrossCity.getCompanyId()){ |
| | | return ResultUtil.error("优惠券不能用于此订单", ""); |
| | | } |
| | | if(userCouponRecord.getState() == 2){ |
| | | return ResultUtil.error("优惠券已使用", ""); |
| | | } |
| | | if(userCouponRecord.getState() == 3){ |
| | | return ResultUtil.error("优惠券已过期", ""); |
| | | } |
| | | if(userCouponRecord.getCouponUseType() != 0 && userCouponRecord.getCouponUseType() != 3){ |
| | | return ResultUtil.error("优惠券不能用于此类型订单", ""); |
| | | } |
| | | if(userCouponRecord.getCouponType() == 2 && orderMoney.compareTo(userCouponRecord.getFullMoney()) < 0){ |
| | | return ResultUtil.error("优惠券不能用于此订单", ""); |
| | | } |
| | | orderMoney = orderMoney - userCouponRecord.getMoney(); |
| | | orderCrossCity.setCouponMoney(userCouponRecord.getMoney()); |
| | | orderCrossCity.setCouponId(couponId); |
| | | } |
| | | } |
| | | |
| | | //计算红包 |
| | | UserRedPacketRecord query = userRedPacketRecordService.query(uid, orderCrossCity.getCompanyId(), 1, 3, orderMoney); |
| | | if(null != query && orderMoney.compareTo(query.getMoney()) > 0){ |
| | | orderMoney = orderMoney - query.getMoney(); |
| | | orderCrossCity.setRedPacketMoney(query.getMoney()); |
| | | orderCrossCity.setRedPacketId(query.getId()); |
| | | } |
| | | |
| | | //计算折扣 |
| | | UserActivityDiscount1 query2 = userActivityDiscount1Mapper.query(orderCrossCity.getCompanyId()); |
| | | if(null != query2){ |
| | | Double special = query2.getSpecial(); |
| | | orderCrossCity.setDiscount(special); |
| | | double v = new BigDecimal(orderMoney).multiply(new BigDecimal(special / 10)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue(); |
| | | if(orderMoney.compareTo(v) > 0){ |
| | | orderCrossCity.setDiscountMoney(orderMoney - v); |
| | | orderCrossCity.setActivityId(query2.getId()); |
| | | orderMoney = v; |
| | | } |
| | | } |
| | | |
| | | if(payType == 1){//微信支付 |
| | | String app = type == 1 ? "APP" : "JSAPI"; |
| | | resultUtil = payMoneyUtil.weixinpay("完成订单", "", orderId + "_3_" + UUIDUtil.getRandomCode(5), orderMoney.toString(), "/base/wxPayOrderTaxi", app, userInfo.getAppletsOpenId()); |
| | | paymentRecordService.saveData(1, orderCrossCity.getUserId(), 1, orderId, 3, 1, orderMoney, "", 1);//添加预支付数据 |
| | | } |
| | | if(payType == 2){//支付宝支付 |
| | | resultUtil = payMoneyUtil.alipay("完成订单", "完成订单", "", orderId + "_3_" + UUIDUtil.getRandomCode(5), orderMoney.toString(), "/base/aliPayOrderTaxi"); |
| | | paymentRecordService.saveData(1, orderCrossCity.getUserId(), 1, orderId, 3, 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(orderCrossCity.getCompanyId()); |
| | | userInfo.setIntegral(userInfo.getIntegral() + (orderMoney.intValue() * query1.getIntegral()));//积分 |
| | | |
| | | //添加交易明细 |
| | | transactionDetailsService.saveData(uid, "跨城出行订单", orderMoney, 2, 1, 1, 3, orderId); |
| | | userInfoService.updateById(userInfo); |
| | | |
| | | orderCrossCity.setState(2);//跨城支付完成后才开始服务 |
| | | orderCrossCity.setPayType(3); |
| | | orderCrossCity.setPayMoney(orderMoney); |
| | | |
| | | //处理优惠券和红包 |
| | | if(null != userCouponRecord){ |
| | | userCouponRecord.setState(2); |
| | | userCouponRecord.setEndTime(new Date()); |
| | | userCouponRecordService.updateById(userCouponRecord); |
| | | } |
| | | if(null != query){ |
| | | query.setState(2); |
| | | query.setEndTime(new Date()); |
| | | userRedPacketRecordService.updateById(query); |
| | | } |
| | | |
| | | //添加已收入明细 |
| | | Line line = lineService.selectById(orderCrossCity.getLineId()); |
| | | Double speMoney = Double.valueOf(line.getRakeRate()); |
| | | BigDecimal d = new BigDecimal(orderCrossCity.getOrderMoney()).multiply(new BigDecimal(speMoney).divide(new BigDecimal(100))).setScale(2, BigDecimal.ROUND_HALF_EVEN);//企业收入 |
| | | BigDecimal c = new BigDecimal(orderCrossCity.getOrderMoney()).subtract(d).setScale(2, BigDecimal.ROUND_HALF_EVEN);//司机收入 |
| | | incomeService.saveData(1, orderCrossCity.getCompanyId(), 2, orderCrossCity.getId(), 3, d.doubleValue()); |
| | | incomeService.saveData(2, orderCrossCity.getDriverId(), 2, orderCrossCity.getId(), 3, c.doubleValue()); |
| | | Driver driver = driverService.selectById(orderCrossCity.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, orderCrossCity.getUserId(), orderCrossCity.getId(), 3, orderCrossCity.getState(), 0); |
| | | pushUtil.pushOrderState(2, orderCrossCity.getDriverId(), orderCrossCity.getId(), 3, orderCrossCity.getState(), 0); |
| | | pushUtil.pushDriverPosition(orderCrossCity.getId(), 3); |
| | | } |
| | | }).start(); |
| | | |
| | | systemNoticeService.addSystemNotice(1, "您已使用余额成功完成出行订单支付,谢谢使用!", uid, 1); |
| | | } |
| | | |
| | | this.updateAllColumnById(orderCrossCity); |
| | | return resultUtil; |
| | | } |
| | | |
| | | |
| | | @Override |
| | | public ResultUtil payCrossCityOrder1(Integer payType, Integer orderId, Integer objectId, Integer objectType, Integer type) throws Exception { |
| | | OrderCrossCity orderCrossCity = this.selectById(orderId); |
| | | if(orderCrossCity.getState() != 7){ |
| | | return ResultUtil.error("订单已完成支付,不允许重复支付", ""); |
| | | } |
| | | Integer uid = orderCrossCity.getUserId(); |
| | | Double orderMoney = orderCrossCity.getOrderMoney(); |
| | | UserInfo userInfo = userInfoService.selectById(uid); |
| | | ResultUtil resultUtil = ResultUtil.success(new Object()); |
| | | orderCrossCity.setCouponMoney(0D);//初始化历史数据 |
| | | orderCrossCity.setCouponId(null); |
| | | |
| | | //计算优惠券 |
| | | UserCouponRecord userCouponRecord = null; |
| | | if(null != objectId && 1 == objectType){ |
| | | userCouponRecord = userCouponRecordService.selectById(objectId); |
| | | if(userCouponRecord.getCompanyId() != orderCrossCity.getCompanyId()){ |
| | | return ResultUtil.error("优惠券不能用于此订单", ""); |
| | | return ResultUtil.error("优惠券不能用于此订单"); |
| | | } |
| | | if(userCouponRecord.getState() == 2){ |
| | | return ResultUtil.error("优惠券已使用", ""); |
| | | return ResultUtil.error("优惠券已使用"); |
| | | } |
| | | if(userCouponRecord.getState() == 3){ |
| | | return ResultUtil.error("优惠券已过期", ""); |
| | | return ResultUtil.error("优惠券已过期"); |
| | | } |
| | | if(userCouponRecord.getCouponUseType() != 0 && userCouponRecord.getCouponUseType() != 3){ |
| | | return ResultUtil.error("优惠券不能用于此类型订单", ""); |
| | | return ResultUtil.error("优惠券不能用于此类型订单"); |
| | | } |
| | | if(userCouponRecord.getCouponType() == 2 && orderMoney.compareTo(userCouponRecord.getFullMoney()) < 0){ |
| | | return ResultUtil.error("优惠券不能用于此订单", ""); |
| | | return ResultUtil.error("优惠券不能用于此订单"); |
| | | } |
| | | orderMoney = orderMoney - userCouponRecord.getMoney(); |
| | | orderCrossCity.setCouponMoney(userCouponRecord.getMoney()); |
| | | orderCrossCity.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() != orderCrossCity.getCompanyId()){ |
| | | return ResultUtil.error("打车卡不能用于此订单", ""); |
| | | } |
| | | if(System.currentTimeMillis() > userTaxiCard.getEndTime().getTime()){ |
| | | return ResultUtil.error("打车卡已过期", ""); |
| | | } |
| | | if(userTaxiCard.getType() == 1 || userTaxiCard.getType() == 3){ |
| | | Integer time = JSON.parseObject(userTaxiCard.getContent()).getInteger("time"); |
| | | if(0 == time){ |
| | | return ResultUtil.error("打车卡已使用完", ""); |
| | | } |
| | | } |
| | | List<Integer> integers = JSON.parseObject(userTaxiCard.getContent()).getJSONArray("businessTypes").toJavaList(Integer.class); |
| | | if(!integers.contains(3)){ |
| | | return ResultUtil.error("打车卡不能用于此类型订单", ""); |
| | | } |
| | | |
| | | Double yh = 0D; |
| | | JSONObject jsonObject = JSON.parseObject(userTaxiCard.getContent()); |
| | | if(userTaxiCard.getType() == 1){//打折次数卡{"businessTypes":[1,2,3],"time":5,"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"],"discount":5} |
| | | JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum"); |
| | | Double discount = jsonObject.getDouble("discount"); |
| | | SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); |
| | | SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); |
| | | Date date = new Date(); |
| | | for(int i = 0; i < timeQuantum.size(); i++){ |
| | | String[] split = timeQuantum.getString(i).split(" - "); |
| | | Date s = sdf1.parse(sdf.format(date) + " " + split[0]); |
| | | Date e = sdf1.parse(sdf.format(date) + " " + split[1]); |
| | | if(s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()){ |
| | | yh = new BigDecimal(orderCrossCity.getOrderMoney()).multiply(new BigDecimal((10 - discount) / 10)).setScale(2, RoundingMode.HALF_EVEN).doubleValue(); |
| | | jsonObject.put("time", jsonObject.getInteger("time") - 1); |
| | | userTaxiCard.setContent(jsonObject.toJSONString()); |
| | | break; |
| | | } |
| | | } |
| | | |
| | | } |
| | | if(userTaxiCard.getType() == 2){//优惠卡{"businessTypes":[1,2,3],"fullReduction":[[50,3],[100,5],[150,10]]} |
| | | JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum"); |
| | | JSONArray fullReduction = jsonObject.getJSONArray("fullReduction"); |
| | | SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); |
| | | SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); |
| | | Date date = new Date(); |
| | | for(int i = 0; i < timeQuantum.size(); i++){ |
| | | String[] split = timeQuantum.getString(i).split(" - "); |
| | | Date s = sdf1.parse(sdf.format(date) + " " + split[0]); |
| | | Date e = sdf1.parse(sdf.format(date) + " " + split[1]); |
| | | if(s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()){ |
| | | for(int j = fullReduction.size() - 1; j >= 0 ; j--){ |
| | | JSONArray jsonArray = fullReduction.getJSONArray(j); |
| | | Double p = jsonArray.getDouble(0);//满金额 |
| | | if(orderCrossCity.getOrderMoney().compareTo(p) >= 0){ |
| | | yh = jsonArray.getDouble(1);//优惠金额 |
| | | break; |
| | | } |
| | | } |
| | | } |
| | | } |
| | | |
| | | } |
| | | if(userTaxiCard.getType() == 3){//次数卡{"businessTypes":[1,2,3],"time":1,"discountAmount":10} |
| | | JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum"); |
| | | SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); |
| | | SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); |
| | | Date date = new Date(); |
| | | for(int i = 0; i < timeQuantum.size(); i++){ |
| | | String[] split = timeQuantum.getString(i).split(" - "); |
| | | Date s = sdf1.parse(sdf.format(date) + " " + split[0]); |
| | | Date e = sdf1.parse(sdf.format(date) + " " + split[1]); |
| | | if(s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()){ |
| | | yh = jsonObject.getDouble("discountAmount"); |
| | | jsonObject.put("time", jsonObject.getInteger("time") - 1); |
| | | userTaxiCard.setContent(jsonObject.toJSONString()); |
| | | } |
| | | } |
| | | } |
| | | if(userTaxiCard.getType() == 4){//打折天数卡{"businessTypes":[1,2,3],"discount":5,"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"]} |
| | | Double discount = jsonObject.getDouble("discount");//折扣 |
| | | JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");//使用时间段 |
| | | SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); |
| | | SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); |
| | | Date date = new Date(); |
| | | for(int i = 0; i < timeQuantum.size(); i++){ |
| | | String[] split = timeQuantum.getString(i).split(" - "); |
| | | Date s = sdf1.parse(sdf.format(date) + " " + split[0]); |
| | | Date e = sdf1.parse(sdf.format(date) + " " + split[1]); |
| | | if(s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()){ |
| | | yh = new BigDecimal(orderCrossCity.getOrderMoney()).multiply(new BigDecimal((10 - discount) / 10)).setScale(2, RoundingMode.HALF_EVEN).doubleValue(); |
| | | break; |
| | | } |
| | | } |
| | | } |
| | | |
| | | orderMoney = orderMoney - yh; |
| | | orderCrossCity.setTaxiCardId(userTaxiCard.getTaxiCardId()); |
| | | orderCrossCity.setUserTaxiCardId(objectId); |
| | | orderCrossCity.setDiscountAmount(yh); |
| | | orderCrossCity.setCouponId(couponId); |
| | | } |
| | | |
| | | //计算红包 |
| | |
| | | orderMoney = v; |
| | | } |
| | | } |
| | | orderMoney = orderMoney < 0 ? 0 : orderMoney; |
| | | |
| | | SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS"); |
| | | String out_trade_no = sdf.format(new Date()) + 3 + orderCrossCity.getId(); |
| | | |
| | | if(payType == 1){//微信支付 |
| | | if(orderMoney == 0){ |
| | | return ResultUtil.error("请使用余额支付"); |
| | | String appletsOpenId = ""; |
| | | String tradeType = "APP"; |
| | | if(type == 3){ |
| | | appletsOpenId = userInfo.getAppletsOpenId(); |
| | | tradeType = "JSAPI"; |
| | | if(ToolUtil.isEmpty(userInfo.getAppletsOpenId())){ |
| | | return ResultUtil.error("支付异常,请重新授权登录小程序"); |
| | | } |
| | | } |
| | | String app = type == 1 ? "APP" : "JSAPI"; |
| | | resultUtil = payMoneyUtil.weixinpay("完成订单", "", orderId + "_3_" + UUIDUtil.getRandomCode(5), orderMoney.toString(), "/base/wxPayOrderTaxi", app, userInfo.getAppletsOpenId()); |
| | | paymentRecordService.saveData(1, orderCrossCity.getUserId(), 1, orderId, 3, 1, orderMoney, "", 1);//添加预支付数据 |
| | | resultUtil = payMoneyUtil.weixinpay("完成订单", "", out_trade_no, orderMoney.toString(), callbackPath + "/base/wxPayOrderTaxi", tradeType, appletsOpenId); |
| | | if(resultUtil.getCode() == 200){ |
| | | paymentRecordService.saveData(1, orderCrossCity.getUserId(), 1, orderId, 3, 1, orderMoney, "", 1);//添加预支付数据 |
| | | } |
| | | } |
| | | if(payType == 2){//支付宝支付 |
| | | if(orderMoney == 0){ |
| | | return ResultUtil.error("请使用余额支付"); |
| | | resultUtil = payMoneyUtil.alipay("订单完成支付", "支付订单", out_trade_no, orderMoney.toString(), callbackPath + "/base/aliPayOrderTaxi"); |
| | | if(resultUtil.getCode() == 200){ |
| | | paymentRecordService.saveData(1, orderCrossCity.getUserId(), 1, orderId, 3, 2, orderMoney, "", 1);//添加预支付数据 |
| | | } |
| | | resultUtil = payMoneyUtil.alipay("完成订单", "完成订单", "", orderId + "_3_" + UUIDUtil.getRandomCode(5), orderMoney.toString(), "/base/aliPayOrderTaxi"); |
| | | paymentRecordService.saveData(1, orderCrossCity.getUserId(), 1, orderId, 3, 2, orderMoney, "", 1);//添加预支付数据 |
| | | } |
| | | if(payType == 3){//余额支付 |
| | | if(userInfo.getBalance() == null || userInfo.getBalance() < orderMoney){ |
| | | return ResultUtil.error("余额不足,无法完成支付", ""); |
| | | return ResultUtil.error("余额不足,无法完成支付"); |
| | | } |
| | | |
| | | userInfo.setBalance(new BigDecimal(userInfo.getBalance()).subtract(new BigDecimal(orderMoney)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); |
| | |
| | | userInfo.setIntegral(userInfo.getIntegral() + (orderMoney.intValue() * query1.getIntegral()));//积分 |
| | | |
| | | //添加交易明细 |
| | | transactionDetailsService.saveData(uid, "跨城出行订单", orderMoney, 2, 1, 1, 3, orderId); |
| | | transactionDetailsService.saveData(uid, "完成订单", orderMoney, 2, 1, 1, 3, orderId); |
| | | userInfoService.updateById(userInfo); |
| | | |
| | | orderCrossCity.setState(2);//跨城支付完成后才开始服务 |
| | |
| | | userCouponRecord.setEndTime(new Date()); |
| | | userCouponRecordService.updateById(userCouponRecord); |
| | | } |
| | | //处理打车卡 |
| | | if(null != userTaxiCard){ |
| | | userTaxiCardService.updateById(userTaxiCard); |
| | | } |
| | | if(null != query){ |
| | | query.setState(2); |
| | | query.setEndTime(new Date()); |
| | | userRedPacketRecordService.updateById(query); |
| | | } |
| | | |
| | | //添加已收入明细 |
| | | // TODO: 2022/3/19 抽成按照订单金额计算,优先保证司机的收入,用户支付金额不够,则在平台收入中补贴司机收入 |
| | | //例如:订单金额10元,优惠3元,司机收入比例80%,平台收入比例20%。 |
| | | //司机收入:10 * 0.8 = 8 |
| | | //平台收入:7 - 8 = -1 |
| | | Line line = lineService.selectById(orderCrossCity.getLineId()); |
| | | Double speMoney = Double.valueOf(line.getRakeRate()); |
| | | BigDecimal c = new BigDecimal(orderCrossCity.getOrderMoney()).multiply(new BigDecimal(1 - (speMoney / 100))).setScale(2, BigDecimal.ROUND_HALF_EVEN);//企业收入 |
| | | BigDecimal d = new BigDecimal(orderCrossCity.getPayMoney()).subtract(c).setScale(2, BigDecimal.ROUND_HALF_EVEN);//司机收入 |
| | | incomeService.saveData(1, orderCrossCity.getCompanyId(), 2, orderCrossCity.getId(), 3, d.doubleValue()); |
| | | incomeService.saveData(2, orderCrossCity.getDriverId(), 2, orderCrossCity.getId(), 3, c.doubleValue()); |
| | | Driver driver = driverService.selectById(orderCrossCity.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() { |
| | |
| | | this.updateAllColumnById(orderCrossCity); |
| | | return resultUtil; |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 支付成功后的回调操作 |
| | |
| | | public void payOrderCrossCityCallback(Integer id, String order_id, Integer type) throws Exception { |
| | | OrderCrossCity orderCrossCity = this.selectById(id); |
| | | PaymentRecord query = paymentRecordService.query(1, orderCrossCity.getUserId(), 1, Integer.valueOf(id), 3, type, 1); |
| | | if(null != query && query.getState() == 1){ |
| | | if(null != query){ |
| | | //添加交易明细 |
| | | transactionDetailsService.saveData(orderCrossCity.getUserId(), "跨城出行订单", query.getAmount(), 2, 1, 1, 3, query.getOrderId()); |
| | | transactionDetailsService.saveData(orderCrossCity.getUserId(), "完成订单", query.getAmount(), 2, 1, 1, 3, query.getOrderId()); |
| | | orderCrossCity.setState(2);//先支付再服务 |
| | | orderCrossCity.setPayType(type); |
| | | orderCrossCity.setPayMoney(query.getAmount()); |
| | |
| | | userCouponRecord.setEndTime(new Date()); |
| | | userCouponRecordService.updateById(userCouponRecord); |
| | | } |
| | | if(null != orderCrossCity.getUserTaxiCardId()){ |
| | | UserTaxiCard userTaxiCard = userTaxiCardService.selectById(orderCrossCity.getUserTaxiCardId()); |
| | | if(userTaxiCard.getType() == 1 || userTaxiCard.getType() == 3){ |
| | | JSONObject jsonObject = JSON.parseObject(userTaxiCard.getContent()); |
| | | jsonObject.put("time", jsonObject.getInteger("time") - 1); |
| | | userTaxiCard.setContent(jsonObject.toJSONString()); |
| | | userTaxiCardService.updateById(userTaxiCard); |
| | | } |
| | | } |
| | | if(null != orderCrossCity.getRedPacketId()){ |
| | | UserRedPacketRecord userRedPacketRecord = userRedPacketRecordService.selectById(orderCrossCity.getRedPacketId()); |
| | | userRedPacketRecord.setState(2); |
| | |
| | | query.setCode(order_id); |
| | | paymentRecordService.updateById(query); |
| | | |
| | | //添加已收入明细 |
| | | // TODO: 2022/3/19 抽成按照订单金额计算,优先保证司机的收入,用户支付金额不够,则在平台收入中补贴司机收入 |
| | | //例如:订单金额10元,优惠3元,司机收入比例80%,平台收入比例20%。 |
| | | //司机收入:10 * 0.8 = 8 |
| | | //平台收入:7 - 8 = -1 |
| | | Line line = lineService.selectById(orderCrossCity.getLineId()); |
| | | Double speMoney = Double.valueOf(line.getRakeRate()); |
| | | BigDecimal c = new BigDecimal(orderCrossCity.getOrderMoney()).multiply(new BigDecimal(1 - (speMoney / 100))).setScale(2, BigDecimal.ROUND_HALF_EVEN);//企业收入 |
| | | BigDecimal d = new BigDecimal(orderCrossCity.getPayMoney()).subtract(c).setScale(2, BigDecimal.ROUND_HALF_EVEN);//司机收入 |
| | | incomeService.saveData(1, orderCrossCity.getCompanyId(), 2, orderCrossCity.getId(), 3, d.doubleValue()); |
| | | incomeService.saveData(2, orderCrossCity.getDriverId(), 2, orderCrossCity.getId(), 3, c.doubleValue()); |
| | | Driver driver = driverService.selectById(orderCrossCity.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 |
| | |
| | | pushUtil.pushDriverPosition(orderCrossCity.getId(), 3); |
| | | } |
| | | }).start(); |
| | | |
| | | |
| | | systemNoticeService.addSystemNotice(1, "您已使用" + (type == 1 ? "微信" : "支付宝") + "成功完成出行订单支付,谢谢使用!", orderCrossCity.getUserId(), 1); |
| | | }else{ |
| | | System.err.println("预支付数据异常(orderId = " + id + ")"); |
| | |
| | | @Override |
| | | public synchronized ResultUtil<BaseWarpper> orderCrossCity(OrderCrossCityWarpper orderCrossCityWarpper, Integer uid) throws Exception { |
| | | /** |
| | | * 1.出租车、专车、跨城有待支付的订单不能叫车 |
| | | * 2.小件物流有未完成的订单可以下跨城、专车、出租车 |
| | | * 3.出租车、专车、跨城有预约单可以下即时单 |
| | | * 1.下了即时单就不能下预约单和即时单 |
| | | * 2.下了预约单和再下一张即时单不能再下预约单 |
| | | */ |
| | | List<OrderPrivateCar> orderPrivateCars = orderPrivateCarMapper.queryByState(uid, null, 1, 7, 12); |
| | | List<OrderPrivateCar> orderPrivateCars = orderPrivateCarMapper.queryByState(uid, 1, 1, 1, 2, 3, 4, 5, 6, 7, 11); |
| | | if(orderPrivateCars.size() > 0){ |
| | | return ResultUtil.error("有未完成的订单"); |
| | | } |
| | | List<OrderTaxi> list = orderTaxiMapper.queryByState_(uid, null, 1, 7, 12); |
| | | List<OrderTaxi> list = orderTaxiMapper.queryByState_(uid, 1, 1, 1, 2, 3, 4, 5, 6, 11); |
| | | if(list.size() > 0){ |
| | | return ResultUtil.error("有未完成的订单"); |
| | | } |
| | | List<OrderCrossCity> orderCrossCities1 = orderCrossCityMapper.queryByState(uid, 1, 2, 3, 4, 5, 7, 11); |
| | | if(orderCrossCities1.size() > 0){ |
| | | return ResultUtil.error("有未完成的订单"); |
| | | } |
| | | |
| | |
| | | orderCrossCity.setIsDelete(1); |
| | | orderCrossCity.setRemark(orderCrossCityWarpper.getRemark()); |
| | | orderCrossCity.setIsReassign(1); |
| | | // //调用高德创建轨迹 |
| | | // String s = gdFalconUtil.selectTerminal(driver.getPhone()); |
| | | // String track = gdFalconUtil.createTrack(s); |
| | | // orderCrossCity.setTrackId(track); |
| | | //调用高德创建轨迹 |
| | | String s = gdFalconUtil.selectTerminal(driver.getPhone()); |
| | | String track = gdFalconUtil.createTrack(s); |
| | | orderCrossCity.setTrackId(track); |
| | | if(orderCrossCity.getTravelMode() == 2){//包车 |
| | | // orderCrossCity.setSeatNumber(lineShiftDriver.getLaveSeatNumber()); |
| | | // orderCrossCity.setPeopleNumber(lineShiftDriver.getLaveSeat()); |
| | | orderCrossCity.setSeatNumber(lineShiftDriver.getLaveSeatNumber()); |
| | | orderCrossCity.setPeopleNumber(lineShiftDriver.getLaveSeat()); |
| | | } |
| | | |
| | | //调用移动的小号接口 |
| | | Map<String, String> map = chinaMobileUtil.midAxbBindSend(orderCrossCity.getPassengersPhone(), driver.getPhone(), (System.currentTimeMillis() + 86400000)); |
| | | Map<String, String> geocode = gdMapGeocodingUtil.geocode(orderCrossCity.getStartLon().toString(), orderCrossCity.getStartLat().toString()); |
| | | Region region = regionMapper.query(geocode.get("districtCode")); |
| | | Map<String, String> map = chinaMobileUtil.midAxbBindSend(orderCrossCity.getPassengersPhone(), driver.getPhone(), Integer.valueOf(region.getCitycode().substring(1))); |
| | | if(String.valueOf(map.get("code")).equals("200")){ |
| | | orderCrossCity.setTelX(map.get("telX")); |
| | | orderCrossCity.setBindId(map.get("bindId")); |
| | |
| | | @Override |
| | | public ResultUtil<BaseWarpper> queryCancleAmount(Integer id) throws Exception { |
| | | OrderCrossCity orderCrossCity = this.selectById(id); |
| | | BaseWarpper baseWarpper = new BaseWarpper(); |
| | | if(null == orderCrossCity){ |
| | | return ResultUtil.error("获取数据失败,订单信息有误"); |
| | | } |
| | |
| | | amount += query.getMoney(); |
| | | } |
| | | } |
| | | BaseWarpper baseWarpper = new BaseWarpper(); |
| | | baseWarpper.setAmount(amount); |
| | | return ResultUtil.success(baseWarpper); |
| | | } |
| | |
| | | OrderCrossCity orderCrossCity = this.selectById(id); |
| | | Integer uid = orderCrossCity.getUserId(); |
| | | UserInfo userInfo = userInfoService.selectById(uid); |
| | | ResultUtil resultUtil = ResultUtil.success(new Object()); |
| | | ResultUtil resultUtil = ResultUtil.success(); |
| | | |
| | | if(null == orderCrossCity){ |
| | | return ResultUtil.error("取消订单失败,订单信息有误", ""); |
| | | return ResultUtil.error("取消订单失败,订单信息有误"); |
| | | } |
| | | if(orderCrossCity.getState() != 12){ |
| | | return ResultUtil.error("取消订单失败,不合法的操作", ""); |
| | | return ResultUtil.error("取消订单失败,不合法的操作"); |
| | | } |
| | | OrderCancel orderCancel = null; |
| | | if(null == cancleId){ |
| | |
| | | |
| | | CancleOrder query = cancleOrderService.query(1, 3, orderCrossCity.getCompanyId()); |
| | | if(null != query){ |
| | | SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS"); |
| | | String out_trade_no = sdf.format(new Date()) + 3 + id; |
| | | if(payType == 1){//微信支付 |
| | | String value = redisUtil.getValue("appletOpenId"); |
| | | String appletsOpenId = null; |
| | | if(ToolUtil.isNotEmpty(value)){ |
| | | JSONObject jsonObject = JSON.parseObject(value); |
| | | appletsOpenId = jsonObject.getString(uid.toString()); |
| | | }else{ |
| | | String appletsOpenId = ""; |
| | | String tradeType = "APP"; |
| | | if(type == 3){ |
| | | appletsOpenId = userInfo.getAppletsOpenId(); |
| | | tradeType = "JSAPI"; |
| | | if(ToolUtil.isEmpty(userInfo.getAppletsOpenId())){ |
| | | return ResultUtil.error("支付异常,请重新授权登录小程序"); |
| | | } |
| | | } |
| | | orderCancel.setPayType(1); |
| | | orderCancelService.updateById(orderCancel); |
| | | |
| | | String app = type == 1 ? "APP" : "JSAPI"; |
| | | resultUtil = payMoneyUtil.weixinpay("订单取消", "", id + "_3_" + UUIDUtil.getRandomCode(5), query.getMoney().toString(), "/base/wxCancelOrderTaxi", app, userInfo.getAppletsOpenId()); |
| | | paymentRecordService.saveData(1, orderCrossCity.getUserId(), 1, id, 3, 1, query.getMoney(), "", 1);//添加预支付数据 |
| | | |
| | | // Map<String, String> map = icbcPayUtil.placeAnOrder(id + ",3", 9, 5, uid.toString(), "订单取消", query.getMoney(), callbackPath + "/base/wxCancelOrderTaxi", "", type, appletsOpenId); |
| | | // if(map.get("code").equals("200")){ |
| | | // paymentRecordService.saveData(1, orderCrossCity.getUserId(), 1, id, 3, 1, query.getMoney(), map.get("order_id"), 1);//添加预支付数据 |
| | | // resultUtil = ResultUtil.success(map.get("data")); |
| | | // }else{ |
| | | // resultUtil = ResultUtil.error(map.get("msg"), ""); |
| | | // } |
| | | resultUtil = payMoneyUtil.weixinpay("订单取消", "", out_trade_no, query.getMoney().toString(), callbackPath + "/base/wxCancelOrderTaxi", tradeType, appletsOpenId); |
| | | if(resultUtil.getCode() == 200){ |
| | | paymentRecordService.saveData(1, orderCrossCity.getUserId(), 1, id, 3, 1, query.getMoney(), "", 1);//添加预支付数据 |
| | | } |
| | | } |
| | | if(payType == 2){//支付宝支付 |
| | | orderCancel.setPayType(2); |
| | | orderCancelService.updateById(orderCancel); |
| | | |
| | | resultUtil = payMoneyUtil.alipay("订单取消", "订单取消", "", id + "_3_" + UUIDUtil.getRandomCode(5), query.getMoney().toString(), "/base/aliCancelOrderTaxi"); |
| | | paymentRecordService.saveData(1, orderCrossCity.getUserId(), 1, id, 3, 2, query.getMoney(), "", 1);//添加预支付数据 |
| | | |
| | | // Map<String, String> map = icbcPayUtil.placeAnOrder(id + ",3", 10, 5, uid.toString(), "订单取消", query.getMoney(), callbackPath + "/base/aliCancelOrderTaxi", "", type, null); |
| | | // if(map.get("code").equals("200")){ |
| | | // paymentRecordService.saveData(1, orderCrossCity.getUserId(), 1, id, 3, 2, query.getMoney(), map.get("order_id"), 1);//添加预支付数据 |
| | | // resultUtil = ResultUtil.success(map.get("data")); |
| | | // }else{ |
| | | // resultUtil = ResultUtil.error(map.get("msg"), ""); |
| | | // } |
| | | resultUtil = payMoneyUtil.alipay("取消订单支付", "取消订单", out_trade_no, query.getMoney().toString(), callbackPath + "/base/aliCancelOrderTaxi"); |
| | | if(resultUtil.getCode() == 200){ |
| | | paymentRecordService.saveData(1, orderCrossCity.getUserId(), 1, id, 3, 2, query.getMoney(), "", 1);//添加预支付数据 |
| | | } |
| | | } |
| | | if(payType == 3){//余额支付 |
| | | if(userInfo.getBalance() != null && userInfo.getBalance() < query.getMoney()){ |
| | | return ResultUtil.error("余额不足,无法完成支付", ""); |
| | | return ResultUtil.error("余额不足,无法完成支付"); |
| | | } |
| | | |
| | | userInfo.setBalance(new BigDecimal(userInfo.getBalance()).subtract(new BigDecimal(query.getMoney())).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); |
| | | //添加交易明细 |
| | | transactionDetailsService.saveData(uid, "跨城出行取消订单", query.getMoney(), 2, 1, 1, 3, id); |
| | | transactionDetailsService.saveData(uid, "取消订单", query.getMoney(), 2, 1, 1, 3, id); |
| | | userInfoService.updateById(userInfo); |
| | | |
| | | //解除小号绑定 |
| | | if(orderCrossCity.getBindId() != null){ |
| | | chinaMobileUtil.midAxbUnBindSend(orderCrossCity.getBindId(), orderCrossCity.getTelX(), (System.currentTimeMillis() + 600000)); |
| | | chinaMobileUtil.midAxbUnBindSend(orderCrossCity.getBindId()); |
| | | } |
| | | |
| | | orderCrossCity.setState(10); |
| | |
| | | |
| | | }else{//浮动计费 |
| | | //计算公式:实际历程 * 基础单价 * (参考费用 / (参考里程 * 基础单价)) + (实际历程 - 参考里程) * 基础单价 * 优惠系数 |
| | | double num1 = Double.valueOf(jsonObject.getString("num1")).doubleValue();//参考价格 |
| | | double num1 = Double.valueOf(jsonObject.getString("num1")).doubleValue();//参考费用 |
| | | double num2 = Double.valueOf(jsonObject.getString("num2")).doubleValue();//参考里程 |
| | | double num3 = Double.valueOf(jsonObject.getString("num3")).doubleValue();//保底价 |
| | | double num4 = Double.valueOf(jsonObject.getString("num4")).doubleValue();//超出参考里程优惠系数 |
| | | double num5 = Double.valueOf(jsonObject.getString("num5")).doubleValue();//低于参考里程优惠系数 |
| | | double num6 = Double.valueOf(jsonObject.getString("num6")).doubleValue();//包车系数 |
| | | double num7 = Double.valueOf(jsonObject.getString("num7")).doubleValue();//五座系数 |
| | | double num8 = Double.valueOf(jsonObject.getString("num8")).doubleValue();//七座系数 |
| | | |
| | | |
| | | /** |
| | | * 1、实际里程>=参考里程 |
| | | * 参考价+((实际里程-参考里程)*(参考价/参考里程)*超出参考里程优惠系数) |
| | | * |
| | | * 2、实际里程<参考里程 |
| | | * 参考价-(参考里程-实际路程)*(参考价/参考里程)*低于参考里程优惠系数 |
| | | */ |
| | | double unitPrice = 0d; |
| | | if(distance1 > num2){//1 |
| | | unitPrice = num1 + ((distance1 - num2) * (num1 / num2) * num4); |
| | | } |
| | | if(distance1 < num2){//2 |
| | | unitPrice = num1 - ((num2 - distance1) * (num1 / num2) * num5); |
| | | } |
| | | if(distance1 == num2){ |
| | | unitPrice = num1; |
| | | } |
| | | double num3 = Double.valueOf(jsonObject.getString("num3")).doubleValue();//基础单价 |
| | | double num4 = Double.valueOf(jsonObject.getString("num4")).doubleValue();//优惠系数 |
| | | double num5 = Double.valueOf(jsonObject.getString("num5")).doubleValue();//包车系数 |
| | | double num6 = Double.valueOf(jsonObject.getString("num6")).doubleValue();//五座系数 |
| | | double num7 = Double.valueOf(jsonObject.getString("num7")).doubleValue();//七座系数 |
| | | if(travelMode == 1){//拼车 |
| | | double unitPrice = (distance1 * num3 * (num1 / (num2 * num3))) + ((distance1 - num2) * num3 * num4); |
| | | String[] split = seatNumber.split(","); |
| | | boolean b = false; |
| | | for(String s : split){ |
| | |
| | | } |
| | | double price1 = 0D; |
| | | if(b){ |
| | | price1 = unitPrice * (totalSeat == 4 ? num7 : num8); |
| | | price1 = unitPrice * (totalSeat == 4 ? num6 : num7); |
| | | peopleNumber -= 1; |
| | | } |
| | | double price = (unitPrice * peopleNumber) + price1; |
| | | map.put("price", new BigDecimal(num3 > price ? num3 : price).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); |
| | | map.put("price", new BigDecimal(price).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); |
| | | }else{ |
| | | double price = unitPrice * totalSeat * num6; |
| | | map.put("price", new BigDecimal(num3 > price ? num3 : price).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); |
| | | double unitPrice = (distance1 * num3 * (num1 / (num2 * num3))) + ((distance1 - num2) * num3 * num5); |
| | | double price = unitPrice * totalSeat; |
| | | map.put("price", new BigDecimal(price).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); |
| | | } |
| | | } |
| | | return ResultUtil.success(map); |
| | |
| | | PaymentRecord query = paymentRecordService.query(1, orderCrossCity.getUserId(), 1, Integer.valueOf(id), 3, type, 1); |
| | | if(null != query){ |
| | | //添加交易明细 |
| | | transactionDetailsService.saveData(orderCrossCity.getUserId(), "跨城出行取消订单", query.getAmount(), 2, 1, 1, 3, query.getOrderId()); |
| | | transactionDetailsService.saveData(orderCrossCity.getUserId(), "取消订单", query.getAmount(), 2, 1, 1, 3, query.getOrderId()); |
| | | orderCrossCity.setState(10); |
| | | //解除小号绑定 |
| | | if(orderCrossCity.getBindId() != null){ |
| | | chinaMobileUtil.midAxbUnBindSend(orderCrossCity.getBindId(), orderCrossCity.getTelX(), (System.currentTimeMillis() + 600000)); |
| | | chinaMobileUtil.midAxbUnBindSend(orderCrossCity.getBindId()); |
| | | } |
| | | orderCrossCity.setBindId(""); |
| | | orderCrossCity.setTelX(""); |
| | |
| | | } |
| | | |
| | | OrderCrossCity orderCrossCity = this.selectById(id); |
| | | if(null == uid){ |
| | | uid = orderCrossCity.getUserId(); |
| | | } |
| | | Integer integer = null; |
| | | if(null == orderCrossCity){ |
| | | return ResultUtil.error("取消订单失败,订单信息有误"); |
| | | } |
| | | if(orderCrossCity.getState() >= 5 && orderCrossCity.getState() != 7 && orderCrossCity.getState() != 11){ |
| | | if(orderCrossCity.getState() > 5 && orderCrossCity.getState() != 7 && orderCrossCity.getState() != 11){ |
| | | return ResultUtil.error("取消订单失败,不合法的操作"); |
| | | } |
| | | |
| | | //还原座位 |
| | | CancleOrder query1 = cancleOrderService.query(1, 3, orderCrossCity.getCompanyId()); |
| | | if (null != query1) { |
| | | if((orderCrossCity.getSnatchOrderTime().getTime() + query1.getMinuteNum() * 60 * 1000) < new Date().getTime() && query1.getMoney().compareTo(0D) > 0){//需要付费的情况 |
| | | integer = orderCancelService.saveData(id, 3, reason, remark, null, query1.getMoney(), 1, 1, uid); |
| | | orderCrossCity.setState(12); |
| | | }else{ |
| | | integer = orderCancelService.saveData(id, 3, reason, remark, null, null, 2, 1, uid); |
| | | orderCrossCity.setState(10); |
| | | } |
| | | integer = orderCancelService.saveData(id, 3, reason, remark, null, null, 2, 1, uid); |
| | | orderCrossCity.setState(10); |
| | | this.updateById(orderCrossCity); |
| | | |
| | | if(orderCrossCity.getState() != 7){//已经支付的情况推送给司机提醒 |
| | |
| | | userInfo.setBalance(userInfo.getBalance() + orderCrossCity.getPayMoney()); |
| | | userInfoService.updateById(userInfo); |
| | | //添加交易明细 |
| | | transactionDetailsService.saveData(orderCrossCity.getUserId(), "跨城出行取消退款", orderCrossCity.getPayMoney(), 1, 1, 1, 3, id); |
| | | transactionDetailsService.saveData(orderCrossCity.getUserId(), "跨城订单取消退款", orderCrossCity.getPayMoney(), 1, 1, 1, 3, id); |
| | | }else{ |
| | | PaymentRecord query = paymentRecordService.query(1, orderCrossCity.getUserId(), 1, id, 3, orderCrossCity.getPayType(), 2); |
| | | if(null == query){ |
| | | return ResultUtil.error("订单还未进行支付"); |
| | | query = paymentRecordService.query(1, orderCrossCity.getDriverId(), 2, id, 3, orderCrossCity.getPayType(), 2); |
| | | if(null == query){ |
| | | return ResultUtil.error("订单还未进行支付"); |
| | | } |
| | | } |
| | | |
| | | SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS"); |
| | | String out_trade_no = sdf.format(new Date()) + 3 + query.getId(); |
| | | |
| | | if(query.getPayType() == 1){//微信 |
| | | Map<String, String> map = payMoneyUtil.wxRefund(query.getCode(), id + "_3", query.getAmount().toString(), query.getAmount().toString(), "/base/cancleOrderWXPay"); |
| | | if(!"SUCCESS".equals(map.get("return_code"))){ |
| | | Map<String, String> map = payMoneyUtil.wxRefund(query.getCode(), out_trade_no, query.getAmount().toString(), query.getAmount().toString(), callbackPath + "/base/wxRefundCallback"); |
| | | String return_code = map.get("return_code"); |
| | | if(!"SUCCESS".equals(return_code)){ |
| | | return ResultUtil.error(map.get("return_msg")); |
| | | } |
| | | }else{//支付宝 |
| | | } |
| | | if(query.getPayType() == 2){//支付宝 |
| | | Map<String, String> map = payMoneyUtil.aliRefund(query.getCode(), query.getAmount().toString()); |
| | | if(!"10000".equals(map.get("code"))){ |
| | | String code = map.get("code"); |
| | | if(!"10000".equals(code)){ |
| | | return ResultUtil.error(map.get("msg")); |
| | | } |
| | | query.setRefundState(2); |
| | | query.setRefundCode(map.get("trade_no")); |
| | | paymentRecordService.updateById(query); |
| | | //添加交易明细 |
| | | transactionDetailsService.saveData(orderCrossCity.getUserId(), "跨城出行取消退款", query.getAmount(), 1, 1, 1, 3, id); |
| | | transactionDetailsService.saveData(orderCrossCity.getUserId(), "跨城订单取消退款", orderCrossCity.getPayMoney(), 1, 1, 1, 3, id); |
| | | } |
| | | } |
| | | |
| | | //添加负的收入明细 |
| | | List<Income> incomes = incomeService.selectList(new EntityWrapper<Income>().eq("type", 2).eq("incomeId", id).eq("orderType", 3)); |
| | | 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 == distance){ |
| | | System.err.println("查询距离出错了"); |
| | | }else{ |
| | | d = new BigDecimal(distance.get("distance")).divide(new BigDecimal(1000)).setScale(2, BigDecimal.ROUND_HALF_EVEN).toString(); |
| | | t = new BigDecimal(distance.get("duration")).divide(new BigDecimal(60),2).setScale(2, BigDecimal.ROUND_HALF_EVEN).intValue() + ""; |
| | | d = new BigDecimal(distance.get("distance")).divide(new BigDecimal(1000), new MathContext(2, RoundingMode.HALF_EVEN)).setScale(2, BigDecimal.ROUND_HALF_EVEN).toString(); |
| | | t = new BigDecimal(distance.get("duration")).divide(new BigDecimal(60), new MathContext(2, RoundingMode.HALF_EVEN)).setScale(2, BigDecimal.ROUND_HALF_EVEN).intValue() + ""; |
| | | } |
| | | OrderServerWarpper orderServerWarpper = new OrderServerWarpper(); |
| | | orderServerWarpper.setOrderId(orderCrossCity.getId()); |
| | |
| | | if(null == distance){ |
| | | System.err.println("查询距离出错了"); |
| | | }else{ |
| | | d = new BigDecimal(distance.get("distance")).divide(new BigDecimal(1000)).setScale(2, BigDecimal.ROUND_HALF_EVEN).toString(); |
| | | t = new BigDecimal(distance.get("duration")).divide(new BigDecimal(60),2).setScale(2, BigDecimal.ROUND_HALF_EVEN).intValue() + ""; |
| | | d = new BigDecimal(distance.get("distance")).divide(new BigDecimal(1000), new MathContext(2, RoundingMode.HALF_EVEN)).setScale(2, BigDecimal.ROUND_HALF_EVEN).toString(); |
| | | t = new BigDecimal(distance.get("duration")).divide(new BigDecimal(60), new MathContext(2, RoundingMode.HALF_EVEN)).setScale(2, BigDecimal.ROUND_HALF_EVEN).intValue() + ""; |
| | | } |
| | | orderServerWarpper.setReservationMileage("0"); |
| | | orderServerWarpper.setReservationTime("0"); |
| | |
| | | orderPrivateCarMapper.insert(orderPrivateCar); |
| | | |
| | | //添加消息 |
| | | systemNoticeService.addSystemNotice(1, "您的快车订单已下单成功,我们正在为您指派司机,请稍后!", orderPrivateCar.getUserId(), 1); |
| | | systemNoticeService.addSystemNotice(1, "您的专车订单已下单成功,我们正在为您指派司机,请稍后!", orderPrivateCar.getUserId(), 1); |
| | | |
| | | BaseWarpper baseWarpper = new BaseWarpper(); |
| | | baseWarpper.setId(orderPrivateCar.getId()); |
| | |
| | | size++; |
| | | } |
| | | |
| | | } |
| | | |
| | | @Override |
| | | public ResultUtil payThankYouFee(Integer uid, Integer orderId, Double money, Integer payType, Integer type) throws Exception { |
| | | UserInfo userInfo = userInfoService.selectById(uid); |
| | | OrderCrossCity orderCrossCity = this.selectById(orderId); |
| | | ResultUtil resultUtil = ResultUtil.success(); |
| | | if(payType == 1){//微信支付 |
| | | String app = type == 1 ? "APP" : "JSAPI"; |
| | | resultUtil = payMoneyUtil.weixinpay("感谢费", "", orderId + "_3_" + UUIDUtil.getRandomCode(5), money.toString(), "/base/wxPayThankYouFee", app, userInfo.getAppletsOpenId()); |
| | | paymentRecordService.saveData(3, uid, 1, orderId, 3, 1, money, "", 1);//添加预支付数据 |
| | | } |
| | | if(payType == 2){//支付宝支付 |
| | | resultUtil = payMoneyUtil.alipay("感谢费", "感谢费", "", orderId + "_3_" + UUIDUtil.getRandomCode(5), money.toString(), "/base/aliPayThankYouFee"); |
| | | paymentRecordService.saveData(1, uid, 1, orderId, 3, 2, money, "", 1);//添加预支付数据 |
| | | } |
| | | if(payType == 3){//余额支付 |
| | | if(userInfo.getBalance() == null || userInfo.getBalance() < money){ |
| | | return ResultUtil.error("余额不足,无法完成支付", ""); |
| | | } |
| | | |
| | | userInfo.setBalance(new BigDecimal(userInfo.getBalance()).subtract(new BigDecimal(money)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); |
| | | |
| | | SysIntegral query1 = sysIntegralMapper.query(orderCrossCity.getCompanyId()); |
| | | userInfo.setIntegral(userInfo.getIntegral() + (money.intValue() * query1.getIntegral()));//积分 |
| | | |
| | | //添加交易明细 |
| | | transactionDetailsService.saveData(uid, "跨城出行-感谢费", money, 2, 1, 1, 3, orderId); |
| | | userInfoService.updateById(userInfo); |
| | | |
| | | orderCrossCity.setThankYouFee(money); |
| | | this.updateById(orderCrossCity); |
| | | |
| | | //添加已收入明细 |
| | | incomeService.saveData(2, orderCrossCity.getDriverId(), 6, orderCrossCity.getId(), 3, money); |
| | | Driver driver = driverService.selectById(orderCrossCity.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); |
| | | } |
| | | return resultUtil; |
| | | } |
| | | |
| | | @Override |
| | | public void payThankYouFeeCallback(Integer orderId, String order_id, Integer payType) throws Exception { |
| | | OrderCrossCity orderCrossCity = this.selectById(orderId); |
| | | UserInfo userInfo = userInfoService.selectById(orderCrossCity.getUserId()); |
| | | PaymentRecord query = paymentRecordService.query(3, userInfo.getId(), 1, orderId, 3, payType, 1); |
| | | query.setState(2); |
| | | query.setCode(order_id); |
| | | paymentRecordService.updateById(query); |
| | | |
| | | SysIntegral query1 = sysIntegralMapper.query(orderCrossCity.getCompanyId()); |
| | | userInfo.setIntegral(userInfo.getIntegral() + (query.getAmount().intValue() * query1.getIntegral()));//积分 |
| | | |
| | | //添加交易明细 |
| | | transactionDetailsService.saveData(userInfo.getId(), "跨城出行-感谢费", query.getAmount(), 2, 1, 1, 3, orderId); |
| | | userInfoService.updateById(userInfo); |
| | | |
| | | orderCrossCity.setThankYouFee(query.getAmount()); |
| | | this.updateById(orderCrossCity); |
| | | |
| | | //添加已收入明细 |
| | | incomeService.saveData(2, orderCrossCity.getDriverId(), 6, orderCrossCity.getId(), 3, query.getAmount()); |
| | | Driver driver = driverService.selectById(orderCrossCity.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 ? "微信" : "支付宝") + "成功完成感谢费支付,谢谢使用!", userInfo.getId(), 1); |
| | | } |
| | | } |