桩启动成功回调接口

This commit is contained in:
yuyang 2021-08-18 19:23:05 +08:00
parent 3742c93ff6
commit 7ccad6acbb

View File

@ -2,18 +2,14 @@ package com.xhpc.order.api;
import cn.hutool.core.date.DateTime; import cn.hutool.core.date.DateTime;
import cn.hutool.core.date.DateUtil; import cn.hutool.core.date.DateUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.rabbitmq.client.Channel; import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection; import com.rabbitmq.client.Connection;
import com.xhpc.common.api.PileOrderService; import com.xhpc.common.api.PileOrderService;
import com.xhpc.common.core.domain.R; import com.xhpc.common.core.domain.R;
import com.xhpc.common.core.web.controller.BaseController; import com.xhpc.common.core.web.controller.BaseController;
import com.xhpc.common.core.web.domain.AjaxResult;
import com.xhpc.common.data.redis.CacheOrderData; import com.xhpc.common.data.redis.CacheOrderData;
import com.xhpc.common.data.redis.CacheRealtimeData; import com.xhpc.common.data.redis.CacheRealtimeData;
import com.xhpc.common.dto.PileEndOrder;
import com.xhpc.common.redis.service.RedisService; import com.xhpc.common.redis.service.RedisService;
import com.xhpc.common.util.ConnectionRabbitMQUtil; import com.xhpc.common.util.ConnectionRabbitMQUtil;
import com.xhpc.order.domain.*; import com.xhpc.order.domain.*;
@ -22,8 +18,10 @@ import com.xhpc.order.service.IXhpcHistoryOrderService;
import com.xhpc.order.service.IXhpcRealTimeOrderService; import com.xhpc.order.service.IXhpcRealTimeOrderService;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.util.Date; import java.util.Date;
@ -75,10 +73,9 @@ public class HxpcPileOrderController extends BaseController {
//解析订单编号 //解析订单编号
String s = orderNo.split("\\.")[0]; String s = orderNo.split("\\.")[0];
String s1 = s.split(":")[1]; String s1 = s.split(":")[1];
Long userId; Long userId =0L;
Integer code; Integer code =200;
if (status == 1) { if (status == 1) {
code = 200;
userId = update(0, 0, remark, s1, 0); userId = update(0, 0, remark, s1, 0);
} else { } else {
code = 500; code = 500;
@ -168,14 +165,14 @@ public class HxpcPileOrderController extends BaseController {
if(cacheRealtimeData.getChargingTime()>60){ if(cacheRealtimeData.getChargingTime()>60){
int mins = cacheRealtimeData.getChargingTime() % 60; int mins = cacheRealtimeData.getChargingTime() % 60;
int hours = cacheRealtimeData.getChargingTime() / 60; int hours = cacheRealtimeData.getChargingTime() / 60;
xhpcRealTimeOrder.setChargingTime(mins+""+hours+""); xhpcRealTimeOrder.setChargingTime(hours+""+mins+"");
}else{ }else{
xhpcRealTimeOrder.setChargingTime(cacheRealtimeData.getChargingTime()+""); xhpcRealTimeOrder.setChargingTime(cacheRealtimeData.getChargingTime()+"");
} }
if(cacheRealtimeData.getRemainingTime()>60){ if(cacheRealtimeData.getRemainingTime()>60){
int mins = cacheRealtimeData.getChargingTime() % 60; int mins = cacheRealtimeData.getChargingTime() % 60;
int hours = cacheRealtimeData.getChargingTime() / 60; int hours = cacheRealtimeData.getChargingTime() / 60;
xhpcRealTimeOrder.setRemainingTime(mins+""+hours+""); xhpcRealTimeOrder.setRemainingTime(hours+""+mins+"");
}else{ }else{
xhpcRealTimeOrder.setRemainingTime(cacheRealtimeData.getChargingTime()+""); xhpcRealTimeOrder.setRemainingTime(cacheRealtimeData.getChargingTime()+"");
} }
@ -268,7 +265,14 @@ public class HxpcPileOrderController extends BaseController {
//充电时长 //充电时长
Long tiem = endTime.getTime()-startTime.getTime(); Long tiem = endTime.getTime()-startTime.getTime();
hxpcChargeOrder.setChargingTime(tiem+""); if(tiem>60000){
long mins = tiem % 60000;
long hours = tiem / 60000;
hxpcChargeOrder.setChargingTime(hours+""+mins+"");
}else{
long mins = tiem % 60000;
hxpcChargeOrder.setChargingTime(mins+"");
}
hxpcChargeOrder.setChargingDegree(cacheOrderData.getTotalPowerQuantity().toString()); hxpcChargeOrder.setChargingDegree(cacheOrderData.getTotalPowerQuantity().toString());
hxpcChargeOrder.setAmountCharged(money.toString()); hxpcChargeOrder.setAmountCharged(money.toString());
String stopReason = cacheOrderData.getStopReason(); String stopReason = cacheOrderData.getStopReason();
@ -480,4 +484,12 @@ public class HxpcPileOrderController extends BaseController {
} }
} }
public static void main(String[] args) {
long time = DateUtil.parse("2021-08-18 12:12:12").getTime();
long time1 = DateUtil.parse("2021-08-19 12:12:12").getTime();
System.out.println(time1-time);
}
} }