| | |
|---|
| | | req.setBody("充电充值"); |
|---|
| | | AliPaymentResp data = aliPaymentClient.payment(req).getData(); |
|---|
| | | if(null != data){ |
|---|
| | | data.setNotifyUrl(data.getNotifyUrl() + "/t-charging-order/chargingOrderALICallback"); |
|---|
| | | data.setNotifyUrl(data.getNotifyUrl() + "/order/t-charging-order/chargingOrderALICallback"); |
|---|
| | | return AjaxResult.success(data); |
|---|
| | | } |
|---|
| | | } |
|---|
| | |
|---|
| | | //根据当前充值的金额和计费模板算出充电的金额 |
|---|
| | | BigDecimal rechargeAmount = chargingOrder.getRechargeAmount(); |
|---|
| | | BigDecimal rechargeAmount1 = new BigDecimal(rechargeAmount.toString()); |
|---|
| | | Long now = System.currentTimeMillis(); |
|---|
| | | SimpleDateFormat sdf = new SimpleDateFormat("HHmm"); |
|---|
| | | Long now = Long.valueOf(sdf.format(new Date())); |
|---|
| | | Long nowTimeMillis = System.currentTimeMillis(); |
|---|
| | | //根据支付金额，获取出使用的计费策略明细 |
|---|
| | | //计算电费金额和服务费 |
|---|
| | | BigDecimal serviceCharge = BigDecimal.ZERO; |
|---|
| | |
|---|
| | | BigDecimal discount = chargingOrder.getVipDiscount(); |
|---|
| | | //先根据额定功率计算出每秒充电度数，然后计算出支付金额能充多少度电 |
|---|
| | | TChargingGun tChargingGun = chargingGunClient.getChargingGunById(chargingOrder.getChargingGunId()).getData(); |
|---|
| | | BigDecimal s_degrees = tChargingGun.getRatedPower().divide(new BigDecimal(3600)); |
|---|
| | | |
|---|
| | | |
|---|
| | | BigDecimal s_degrees = tChargingGun.getRatedPower().divide(new BigDecimal(3600), 6, RoundingMode.HALF_EVEN); |
|---|
| | | |
|---|
| | | TAppUser appUser = appUserClient.getUserById(chargingOrder.getAppUserId()).getData(); |
|---|
| | | List<AccountingStrategyDetailOrder> list = accountingStrategyDetailOrderClient.getAllAccountingStrategyDetailOrder(chargingOrder.getId()).getData(); |
|---|
| | | for (AccountingStrategyDetailOrder accountingStrategyDetailOrder : list) { |
|---|
| | | AccountingStrategyOrder accountingStrategyOrder = accountingStrategyOrderClient.getAccountingStrategyOrderById(accountingStrategyDetailOrder.getAccountingStrategyOrderId()).getData(); |
|---|
| | | Integer start = Integer.valueOf(accountingStrategyDetailOrder.getStartTime().replaceAll(":", "")); |
|---|
| | | Integer end = Integer.valueOf(accountingStrategyDetailOrder.getEndTime().replaceAll(":", "")); |
|---|
| | | String[] split = accountingStrategyDetailOrder.getEndTime().split(":"); |
|---|
| | | if(now >= start){ |
|---|
| | | if(now >= start && now < end){ |
|---|
| | | Calendar calendar = Calendar.getInstance(); |
|---|
| | | calendar.set(Calendar.HOUR_OF_DAY, Integer.valueOf(split[0])); |
|---|
| | | calendar.set(Calendar.MINUTE, Integer.valueOf(split[1])); |
|---|
| | | //到此策略结束的秒数 |
|---|
| | | long m = (calendar.getTimeInMillis() - now) / 1000; |
|---|
| | | if(null == nowTimeMillis){ |
|---|
| | | String[] split1 = accountingStrategyDetailOrder.getStartTime().split(":"); |
|---|
| | | Calendar calendar1 = Calendar.getInstance(); |
|---|
| | | calendar1.set(Calendar.HOUR_OF_DAY, Integer.valueOf(split1[0])); |
|---|
| | | calendar1.set(Calendar.MINUTE, Integer.valueOf(split1[1])); |
|---|
| | | nowTimeMillis = calendar.getTimeInMillis(); |
|---|
| | | } |
|---|
| | | long m = (calendar.getTimeInMillis() - nowTimeMillis) / 1000; |
|---|
| | | //每度电的单价 |
|---|
| | | BigDecimal total_unit = accountingStrategyDetailOrder.getElectrovalence().add(accountingStrategyDetailOrder.getServiceCharge()); |
|---|
| | | //每秒需要支付的金额 |
|---|
| | |
|---|
| | | serviceCharge = accountingStrategyDetailOrder.getServiceCharge().multiply(s_degrees).multiply(new BigDecimal(m)); |
|---|
| | | discountAmount = discountAmount.add(serviceCharge.multiply((new BigDecimal(10).subtract(discount)).divide(new BigDecimal(10)))); |
|---|
| | | rechargeAmount1 = rechargeAmount1.subtract(multiply.multiply(new BigDecimal(m))); |
|---|
| | | nowTimeMillis = null; |
|---|
| | | }else{ |
|---|
| | | electrovalence = accountingStrategyDetailOrder.getElectrovalence().multiply(s_degrees).multiply(new BigDecimal(times)); |
|---|
| | | serviceCharge = accountingStrategyDetailOrder.getServiceCharge().multiply(s_degrees).multiply(new BigDecimal(times)); |
|---|
| | |
|---|
| | | chargingOrder.setChargeAmount(electrovalence); |
|---|
| | | chargingOrder.setVipDiscountAmount(discountAmount); |
|---|
| | | this.updateById(chargingOrder); |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | TChargingPile chargingPile = chargingPileClient.getChargingPileById(tChargingGun.getChargingPileId()).getData(); |
|---|
| | | //调用远程启动充电消息 |
|---|
| | | PlatformStartCharging platformStartCharging = new PlatformStartCharging(); |
|---|
| | |
|---|
| | | //使用订单id作为逻辑卡号 |
|---|
| | | platformStartCharging.setCard_number(chargingOrder.getId().toString()); |
|---|
| | | platformStartCharging.setAccount_balance(electrovalence); |
|---|
| | | |
|---|
| | | System.err.println("-------------------远程调起开始充电请求-------------------"); |
|---|
| | | System.err.println(platformStartCharging.toString()); |
|---|
| | | |
|---|
| | | sendMessageClient.platformStartCharging(platformStartCharging); |
|---|
| | | //异步线程检测远程启动的应答结果。如果失败，则需要全额退款 |
|---|
| | | String code = chargingOrder.getCode(); |
|---|
| | |
|---|
| | | ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1); |
|---|
| | | scheduler.scheduleAtFixedRate(()->{ |
|---|
| | | List<PlatformStartChargingReply> data = platformStartChargingReplyClient.getPlatformStartChargingReply(code).getData(); |
|---|
| | | System.err.println("-------------------开始检查调起充电结果-------------------"); |
|---|
| | | System.err.println(data.toString()); |
|---|
| | | if(data.size() != 0){ |
|---|
| | | PlatformStartChargingReply platformStartChargingReply = data.get(1); |
|---|
| | | Integer startup_result = platformStartChargingReply.getStartup_result(); |
|---|
