3 Commits

Author SHA1 Message Date
jsowell
db544375bd update 打印日志 2026-06-25 17:03:05 +08:00
jsowell
b77ad0d686 update羽信主板预约充电 2026-06-25 16:14:08 +08:00
jsowell
838e37ed03 update 定时任务PRE挡板 2026-06-25 16:13:28 +08:00
5 changed files with 33 additions and 21 deletions

View File

@@ -563,25 +563,25 @@ public class PersonPileController extends BaseController {
} }
/** /**
* 羽信主板取消预约充电 * 羽信主板修改预约充电状态
* http://localhost:8080/uniapp/personalPile/yuxin/cancelReservation * http://localhost:8080/uniapp/personalPile/yuxin/updateReservedStatus
*/ */
@PostMapping("/yuxin/cancelReservation") @PostMapping("/yuxin/updateReservedStatus")
public RestApiResponse<?> cancelYuxinReservation(HttpServletRequest request, @RequestBody YuxinReservationChargingDTO dto) { public RestApiResponse<?> cancelYuxinReservation(HttpServletRequest request, @RequestBody YuxinReservationChargingDTO dto) {
RestApiResponse<?> response = null; RestApiResponse<?> response = null;
try { try {
String memberId = getMemberIdByAuthorization(request); String memberId = getMemberIdByAuthorization(request);
dto.setMemberId(memberId); dto.setMemberId(memberId);
yuxinReservationChargingService.cancelReservation(dto); yuxinReservationChargingService.updateReservedStatus(dto);
response = new RestApiResponse<>(); response = new RestApiResponse<>();
} catch (BusinessException e) { } catch (BusinessException e) {
logger.error("羽信取消预约充电error, params:{}", dto, e); logger.error("羽信修改预约充电状态error, params:{}", dto, e);
response = new RestApiResponse<>(e.getCode(), e.getMessage()); response = new RestApiResponse<>(e.getCode(), e.getMessage());
} catch (Exception e) { } catch (Exception e) {
logger.error("羽信取消预约充电error, params:{}", dto, e); logger.error("羽信修改预约充电状态error, params:{}", dto, e);
response = new RestApiResponse<>(ReturnCodeEnum.CODE_UPDATE_RESERVED_STATUS_ERROR); response = new RestApiResponse<>(ReturnCodeEnum.CODE_UPDATE_RESERVED_STATUS_ERROR);
} }
logger.info("羽信取消预约充电params:{}, result:{}", dto, response); logger.info("羽信修改预约充电状态params:{}, result:{}", dto, response);
return response; return response;
} }

View File

@@ -23,6 +23,11 @@ public class YuxinReservationChargingDTO {
*/ */
private String reservedId; private String reservedId;
/**
* 状态 0-停用1-启用)
*/
private String status;
/** /**
* 充电桩编号 * 充电桩编号
*/ */

View File

@@ -14,4 +14,6 @@ public interface YuxinReservationChargingService {
void deleteReservation(YuxinReservationChargingDTO dto); void deleteReservation(YuxinReservationChargingDTO dto);
PileReservationInfoVO queryReservationInfo(YuxinReservationChargingDTO dto); PileReservationInfoVO queryReservationInfo(YuxinReservationChargingDTO dto);
void updateReservedStatus(YuxinReservationChargingDTO dto);
} }

View File

@@ -181,6 +181,11 @@ public class YuxinReservationChargingServiceImpl implements YuxinReservationChar
.build(); .build();
} }
@Override
public void updateReservedStatus(YuxinReservationChargingDTO dto) {
}
private void fillReservationInfo(PileReservationInfo reservationInfo, YuxinReservationChargingDTO dto) { private void fillReservationInfo(PileReservationInfo reservationInfo, YuxinReservationChargingDTO dto) {
reservationInfo.setMemberId(dto.getMemberId()); reservationInfo.setMemberId(dto.getMemberId());
reservationInfo.setPileSn(dto.getPileSn()); reservationInfo.setPileSn(dto.getPileSn());

View File

@@ -91,8 +91,8 @@ public class JsowellTask {
public void setBarrier() { public void setBarrier() {
String env = SpringUtils.getActiveProfile(); String env = SpringUtils.getActiveProfile();
if (StringUtils.equalsIgnoreCase(env, "pre")) { if (StringUtils.equalsIgnoreCase(env, "pre")) {
log.debug("PRE环境不执行"); log.info("PRE环境不执行");
// return; return;
} }
} }
@@ -103,7 +103,7 @@ public class JsowellTask {
public void close15MinutesOfUnpaidOrders() { public void close15MinutesOfUnpaidOrders() {
String env = SpringUtils.getActiveProfile(); String env = SpringUtils.getActiveProfile();
if (StringUtils.equalsIgnoreCase(env, "pre")) { if (StringUtils.equalsIgnoreCase(env, "pre")) {
log.debug("PRE环境不执行"); log.info("PRE环境不执行关闭15分钟未支付的订单");
return; return;
} }
// log.info("关闭15分钟未支付的订单"); // log.info("关闭15分钟未支付的订单");
@@ -117,8 +117,8 @@ public class JsowellTask {
public void closeStartFailedOrder() { public void closeStartFailedOrder() {
String env = SpringUtils.getActiveProfile(); String env = SpringUtils.getActiveProfile();
if (StringUtils.equalsIgnoreCase(env, "pre")) { if (StringUtils.equalsIgnoreCase(env, "pre")) {
log.debug("PRE环境不执行"); log.info("PRE环境不执行,关闭启动失败的订单");
// return; return;
} }
// 查询出最近2天支付成功并且订单状态为未启动的订单 // 查询出最近2天支付成功并且订单状态为未启动的订单
String startTime = DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD_HH_MM_SS, DateUtils.addDays(new Date(), -2)); String startTime = DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD_HH_MM_SS, DateUtils.addDays(new Date(), -2));
@@ -132,7 +132,7 @@ public class JsowellTask {
public void appointmentOrderStart() { public void appointmentOrderStart() {
String env = SpringUtils.getActiveProfile(); String env = SpringUtils.getActiveProfile();
if (StringUtils.equalsIgnoreCase(env, "pre")) { if (StringUtils.equalsIgnoreCase(env, "pre")) {
log.debug("PRE环境不执行"); log.info("PRE环境不执行,查询预约充电的订单并启动");
return; return;
} }
// 查询出 已支付 设置预约充电 未启动 的订单 // 查询出 已支付 设置预约充电 未启动 的订单
@@ -189,7 +189,7 @@ public class JsowellTask {
public void dailyProofreadTimeForYkcV160(Long intervalMillis) { public void dailyProofreadTimeForYkcV160(Long intervalMillis) {
String env = SpringUtils.getActiveProfile(); String env = SpringUtils.getActiveProfile();
if (StringUtils.equalsIgnoreCase(env, "pre")) { if (StringUtils.equalsIgnoreCase(env, "pre")) {
log.debug("PRE环境不执行"); log.info("PRE环境不执行云快充1.6每日自动对时");
return; return;
} }
@@ -252,7 +252,7 @@ public class JsowellTask {
public void calculateTheSiteOrdersReport() { public void calculateTheSiteOrdersReport() {
String env = SpringUtils.getActiveProfile(); String env = SpringUtils.getActiveProfile();
if (StringUtils.equalsIgnoreCase(env, "pre")) { if (StringUtils.equalsIgnoreCase(env, "pre")) {
log.debug("PRE环境不执行"); log.info("PRE环境不执行,计算站点订单报表");
return; return;
} }
// 查询出所有站点 // 查询出所有站点
@@ -281,7 +281,7 @@ public class JsowellTask {
public void pushToAMap() { public void pushToAMap() {
String env = SpringUtils.getActiveProfile(); String env = SpringUtils.getActiveProfile();
if (StringUtils.equalsIgnoreCase(env, "pre")) { if (StringUtils.equalsIgnoreCase(env, "pre")) {
log.debug("PRE环境不执行"); log.info("PRE环境不执行,站点的枪口数据推送到高德");
return; return;
} }
Set<String> stationIds = redisCache.getCacheSet(CacheConstants.PUSH_STATION_CONNECTOR); Set<String> stationIds = redisCache.getCacheSet(CacheConstants.PUSH_STATION_CONNECTOR);
@@ -306,7 +306,7 @@ public class JsowellTask {
public void pushStationRealTimePowerInfo() { public void pushStationRealTimePowerInfo() {
String env = SpringUtils.getActiveProfile(); String env = SpringUtils.getActiveProfile();
if (StringUtils.equalsIgnoreCase(env, "pre")) { if (StringUtils.equalsIgnoreCase(env, "pre")) {
log.debug("PRE环境不执行"); log.info("PRE环境不执行,贵州省平台推送充电站实时功率");
return; return;
} }
@@ -346,7 +346,7 @@ public class JsowellTask {
public void pushStatisticsInfo() { public void pushStatisticsInfo() {
String env = SpringUtils.getActiveProfile(); String env = SpringUtils.getActiveProfile();
if (StringUtils.equalsIgnoreCase(env, "pre")) { if (StringUtils.equalsIgnoreCase(env, "pre")) {
log.debug("PRE环境不执行"); log.info("PRE环境不执行,推送统计信息 24小时执行一次");
return; return;
} }
@@ -387,7 +387,7 @@ public class JsowellTask {
public void processOrderSplitting() { public void processOrderSplitting() {
String env = SpringUtils.getActiveProfile(); String env = SpringUtils.getActiveProfile();
if (StringUtils.equalsIgnoreCase(env, "pre")) { if (StringUtils.equalsIgnoreCase(env, "pre")) {
log.debug("PRE环境不执行"); log.info("PRE环境不执行,定时任务, 订单分账");
return; return;
} }
// 查询运营商列表 // 查询运营商列表
@@ -426,7 +426,7 @@ public class JsowellTask {
public void generateMerchantBill() { public void generateMerchantBill() {
String env = SpringUtils.getActiveProfile(); String env = SpringUtils.getActiveProfile();
if (StringUtils.equalsIgnoreCase(env, "pre")) { if (StringUtils.equalsIgnoreCase(env, "pre")) {
log.debug("PRE环境不执行"); log.info("PRE环境不执行,生成运营商日报表");
return; return;
} }
// 查询运营商列表 // 查询运营商列表
@@ -455,7 +455,7 @@ public class JsowellTask {
public void automaticPayouts() { public void automaticPayouts() {
String env = SpringUtils.getActiveProfile(); String env = SpringUtils.getActiveProfile();
if (StringUtils.equalsIgnoreCase(env, "pre")) { if (StringUtils.equalsIgnoreCase(env, "pre")) {
log.debug("PRE环境不执行"); log.info("PRE环境不执行,定时任务,自动提现");
return; return;
} }
// 查询开启自动提现运营商列表 // 查询开启自动提现运营商列表