个人桩停止充电

This commit is contained in:
Guoqs
2024-07-25 14:09:32 +08:00
parent 180645ffb2
commit 8f14e4e71d
5 changed files with 68 additions and 4 deletions

View File

@@ -117,7 +117,7 @@ public class PersonPileController extends BaseController {
if (StringUtils.isNotBlank(appId)) {
String firstLevelMerchantId = pileMerchantInfoService.getFirstLevelMerchantIdByWxAppId(appId);
if (StringUtils.isNotBlank(firstLevelMerchantId)) {
dto.setMerchantId(firstLevelMerchantId);
dto.setFirstLevelMerchantId(firstLevelMerchantId);
}
}
String memberId = getMemberIdByAuthorization(request);
@@ -135,6 +135,36 @@ public class PersonPileController extends BaseController {
return response;
}
/**
* 个人桩停止充电
* 管理员可以停自己启动的和别人启动的
* 其他人员只能停止自己启动的
*/
@PostMapping("/personPileStopCharging")
public RestApiResponse<?> personPileStopCharging(HttpServletRequest request, PersonPileStopChargingDTO dto) {
RestApiResponse<?> response = null;
try {
String appId = request.getHeader("appId");
if (StringUtils.isNotBlank(appId)) {
String firstLevelMerchantId = pileMerchantInfoService.getFirstLevelMerchantIdByWxAppId(appId);
if (StringUtils.isNotBlank(firstLevelMerchantId)) {
dto.setFirstLevelMerchantId(firstLevelMerchantId);
}
}
String memberId = getMemberIdByAuthorization(request);
dto.setMemberId(memberId);
pileService.personPileStopCharging(dto);
response = new RestApiResponse<>();
} catch (BusinessException e) {
logger.error("个人桩停止充电error", e);
response = new RestApiResponse<>(e.getCode(), e.getMessage());
} catch (Exception e) {
logger.error("个人桩停止充电error", e);
response = new RestApiResponse<>(ReturnCodeEnum.CODE_PERSON_PILE_STOP_CHARGING_ERROR);
}
return response;
}
/**
* 通过memberId查个人桩列表

View File

@@ -339,7 +339,7 @@ public class PileService {
*/
public void adminIssuePile(PileMemberBindingDTO dto) {
// 通过前端传的手机号查询是否有此用户
MemberBasicInfo memberBasicInfo = memberBasicInfoService.selectInfoByMobileNumber(dto.getPhoneNumber(), dto.getMerchantId());
MemberBasicInfo memberBasicInfo = memberBasicInfoService.selectInfoByMobileNumber(dto.getPhoneNumber(), dto.getFirstLevelMerchantId());
if (memberBasicInfo == null) {
// 为空说明此用户未注册平台账号
throw new BusinessException(ReturnCodeEnum.CODE_USER_IS_NOT_REGISTER);
@@ -377,7 +377,7 @@ public class PileService {
PileMemberRelation info = new PileMemberRelation();
info.setPileSn(dto.getPileSn());
info.setMemberId(memberBasicInfo.getMemberId());
info.setType("2");
info.setType(Constants.TWO);
pileMemberRelationService.insertPileMemberRelation(info);
}
}
@@ -656,4 +656,12 @@ public class PileService {
// System.out.println(i);
return String.valueOf(i);
}
/**
* 个人桩停止充电
* @param dto
*/
public void personPileStopCharging(PersonPileStopChargingDTO dto) {
}
}

View File

@@ -179,6 +179,8 @@ public enum ReturnCodeEnum {
CODE_RESERVATION_ALREADY_EXISTS_ERROR("00400017", "已经存在生效中的预约,请关闭后再试"),
CODE_PERSON_PILE_STOP_CHARGING_ERROR("00400018", "个人桩停止充电异常"),
/* 个人桩 end */
CODE_THIS_CARNO_HAS_BEEN_BINDING("00500001", "当前车牌号已经绑定,请检查!"),

View File

@@ -0,0 +1,24 @@
package com.jsowell.pile.dto;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
@Data
@NoArgsConstructor
@AllArgsConstructor
@Builder
public class PersonPileStopChargingDTO {
private String memberId;
private String firstLevelMerchantId;
private String pileSn;
private String ConnectorCode;
/**
* 桩枪口号
*/
private String pileConnectorCode;
}

View File

@@ -38,5 +38,5 @@ public class PileMemberBindingDTO {
/**
* 一级运营商id
*/
private String merchantId;
private String firstLevelMerchantId;
}