yuyang/XH-Power-Cloud
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

增加，实时数据 BMS定时任务

Browse Source
This commit is contained in:
yuyang 2022-10-20 15:57:24 +08:00
parent 00aee1ccfa
commit 669a33ba34
5 changed files with 171 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/mapper/XhpcRealTimeOrderMapper.java
View File

@ -188,4 +188,17 @@ public interface XhpcRealTimeOrderMapper {
XhpcActivityFormulaDomainDto getActivityFormulaTimeById(@Param("activityId") Integer activityId,@Param("startTime") String startTime, @Param("endTime") String endTime);
void deleteOrderCurrent(@Param("time")String time);
void deleteOrderVoltage(@Param("time")String time);
void deleteOrderSoc(@Param("time")String time);
void deleteRealTimeOrderTime(@Param("time")String time);
void deleteOorderRedisRecord(@Param("time")String time);
void deleteRealTimeOrderBms(@Param("time")String time);
}

24
xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/service/IXhpcRealTimeOrderService.java
View File

@ -170,8 +170,30 @@ public interface IXhpcRealTimeOrderService {
/**
* 添加一条实时订单的BMS
* 添加一条实时订单的BMS,清除一个月半之前的数据
*/
void addRealTimeOrderBms(String orderNo);
/**
* 实时电流定时任务，每天下午2点,清除一个月半之前的数据
*/
void orderCurrent();
/**
* 实时电压定时任务，每天下午3点,清除一个月半之前的数据
*/
void orderVoltage();
/**
* 实时soc定时任务，每天下午2点30,清除一个月半之前的数据
*/
void orderSoc();
//实时充电数据定时任务，每天下午3点30,清除一个月半之前的数据
void realTimeOrder();
//充电结算订单报文定时任务，每天下午4点,清除一个月半之前的数据
void orderRedisRecord();
//充电车辆BMS报文定时任务，每天下午4点30,清除一个月半之前的数据
void realTimeOrderBms();
}

45
xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/service/impl/XhpcRealTimeOrderServiceImpl.java
View File

@ -1703,6 +1703,50 @@ public class XhpcRealTimeOrderServiceImpl extends BaseService implements IXhpcRe
}
@Override
public void orderCurrent() {
String time = monthTime();
xhpcRealTimeOrderMapper.deleteOrderCurrent(time);
}
@Override
public void orderVoltage() {
String time = monthTime();
xhpcRealTimeOrderMapper.deleteOrderVoltage(time);
}
@Override
public void orderSoc() {
String time = monthTime();
xhpcRealTimeOrderMapper.deleteOrderSoc(time);
}
@Override
public void realTimeOrder() {
String time = monthTime();
xhpcRealTimeOrderMapper.deleteRealTimeOrderTime(time);
}
@Override
public void orderRedisRecord() {
String time = monthTime();
xhpcRealTimeOrderMapper.deleteOorderRedisRecord(time);
}
@Override
public void realTimeOrderBms() {
String time = monthTime();
xhpcRealTimeOrderMapper.deleteRealTimeOrderBms(time);
}
//获今天之后一个月半后时间
private String monthTime(){
Date date = new Date();
Date beginOfDay = DateUtil.beginOfDay(date);
return DateUtil.formatDateTime(DateUtil.offsetDay(beginOfDay, -35));
}
private BigDecimal getBigDecimal(Long rateModelId, String startTime, String updateTime, BigDecimal powerPriceTotal, BigDecimal divide) {
if("00:00:00".equals(updateTime)){
@ -1742,7 +1786,6 @@ public class XhpcRealTimeOrderServiceImpl extends BaseService implements IXhpcRe
return bigDecimal;
}
private BigDecimal getRealOrderTime(Long chargingOrderId,String startTime,String endTime){
//结束时间差时间
int differenceEndTime =0;

66
xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/tasks/ScheduledTasks.java Normal file
View File

@ -0,0 +1,66 @@
package com.xhpc.order.tasks;
import com.xhpc.order.service.IXhpcRealTimeOrderService;
import io.swagger.annotations.Api;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
/**
* @author yuyang
* @date 2022/10/20 14:30
*/
@EnableScheduling
@RestController
@RequestMapping("/scheduledTasks")
@Api(value = "定时任务接口", tags = "定时任务接口")
public class ScheduledTasks {
@Resource
IXhpcRealTimeOrderService xhpcRealTimeOrderService;
//实时电流定时任务，每天下午2点,清除一个月半之前的数据
@GetMapping("/orderCurrent")
@Scheduled(cron = "0 0 14 * * ?")
public void orderCurrent(){
xhpcRealTimeOrderService.orderCurrent();
}
//实时电压定时任务，每天下午2点30,清除一个月半之前的数据
@GetMapping("/orderVoltage")
@Scheduled(cron = "0 30 14 * * ?")
public void orderVoltage(){
xhpcRealTimeOrderService.orderVoltage();
}
//实时soc定时任务，每天下午3点,清除一个月半之前的数据
@GetMapping("/orderSoc")
@Scheduled(cron = "0 0 15 * * ?")
public void orderSoc(){
xhpcRealTimeOrderService.orderSoc();
}
//实时充电数据定时任务，每天下午3.30点,清除一个月半之前的数据
@GetMapping("/realTimeOrder")
@Scheduled(cron = "0 30 15 * * ?")
public void realTimeOrder(){
xhpcRealTimeOrderService.realTimeOrder();
}
//充电结算订单报文定时任务，每天下午4点,清除一个月半之前的数据
@GetMapping("/orderRedisRecord")
@Scheduled(cron = "0 0 16 * * ?")
public void orderRedisRecord(){
xhpcRealTimeOrderService.orderRedisRecord();
}
//充电结算订单报文定时任务，每天下午4点30,清除一个月半之前的数据
@GetMapping("/realTimeOrderBms")
@Scheduled(cron = "0 30 16 * * ?")
public void realTimeOrderBms(){
xhpcRealTimeOrderService.realTimeOrderBms();
}
}

25
xhpc-modules/xhpc-order/src/main/resources/mapper/XhpcRealTimeOrderMapper.xml
View File

@ -1009,4 +1009,29 @@
and start_time >= #{startTime} AND end_time <= #{endTime}
</select>
<delete id="deleteOrderCurrent">
delete from xhpc_charge_order_current where create_time &lt;=#{time}
</delete>
<delete id="deleteOrderVoltage">
delete from xhpc_charge_order_voltage where create_time &lt;=#{time}
</delete>
<delete id="deleteOrderSoc">
delete from xhpc_charge_order_soc where create_time &lt;=#{time}
</delete>
<delete id="deleteRealTimeOrderTime">
delete from xhpc_real_time_order where create_time &lt;=#{time}
</delete>
<delete id="deleteOorderRedisRecord">
delete from xhpc_order_redis_record where create_time &lt;=#{time}
</delete>
<delete id="deleteRealTimeOrderBms">
delete from xhpc_real_time_order_bms where create_time &lt;=#{time}
</delete>
</mapper>