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

夸服务调用失败新增 code：3886

Browse Source
This commit is contained in:
yuyang 2022-09-28 13:50:25 +08:00
parent 8a128c37e9
commit e470ce2301
21 changed files with 89 additions and 38 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
xhpc-modules/xhpc-charging-station/src/main/java/com/xhpc/charging/station/controller/XhpcPileEditionController.java
View File

@ -41,4 +41,9 @@ public class XhpcPileEditionController extends BaseController {
return xhpcPileEditionService.status(pileEditionId,status);
}
@GetMapping("/getChargingPileList")
public AjaxResult getChargingPileList(@RequestParam(value = "chargingStationId", required = true)Long chargingStationId) {
return xhpcPileEditionService.getChargingPileList(chargingStationId);
}
}

2
xhpc-modules/xhpc-charging-station/src/main/java/com/xhpc/charging/station/mapper/XhpcPileEditionMapper.java
View File

@ -28,4 +28,6 @@ public interface XhpcPileEditionMapper {
int updatePileEdition(XhpcPileEdition xhpcPileEdition);
XhpcPileEdition getXhpcPileEditionById(@Param("pileEditionId")Long pileEditionId);
List<Map<String, Object>> getChargingPileList(@Param("chargingStationId")Long chargingStationId);
}

3
xhpc-modules/xhpc-charging-station/src/main/java/com/xhpc/charging/station/service/IXhpcPileEditionService.java
View File

@ -20,8 +20,9 @@ public interface IXhpcPileEditionService {
*/
List<Map<String, Object>> list(HttpServletRequest request, Long chargingStationId, String chargingPileIds);
AjaxResult addPileEdition(HttpServletRequest request, XhpcPileEdition xhpcPileEdition);
AjaxResult status(Long pileEditionId,Integer status);
AjaxResult getChargingPileList(Long chargingStationId);
}

5
xhpc-modules/xhpc-charging-station/src/main/java/com/xhpc/charging/station/service/XhpcPileEditionServiceImpl.java
View File

@ -116,5 +116,10 @@ public class XhpcPileEditionServiceImpl extends BaseService implements IXhpcPil
return AjaxResult.success();
}
@Override
public AjaxResult getChargingPileList(Long chargingStationId) {
return AjaxResult.success(xhpcPileEditionMapper.getChargingPileList(chargingStationId));
}
}

31
xhpc-modules/xhpc-charging-station/src/main/resources/mapper/XhpcPileEditionMapper.xml
View File

@ -171,4 +171,35 @@
<select id="getXhpcPileEditionById" resultMap="BaseResultMap">
select * from xhpc_pile_edition where pile_edition_id = #{pileEditionId}
</select>
<select id="getChargingPileList" resultType="map">
SELECT
charging_pile_id as chargingPileName,
concat(name,"号桩") as chargingPileName
FROM
xhpc_charging_pile
WHERE
charging_station_id = #{chargingStationId}
AND charging_pile_id NOT IN (
SELECT
cp.charging_pile_id AS chargingPileId
FROM
xhpc_charging_pile AS cp
WHERE
cp.charging_station_id = #{chargingStationId}
AND find_in_set(
cp.charging_pile_id,
(
SELECT
group_concat(charging_pile_ids)
FROM
xhpc_pile_edition
WHERE
charging_station_id = #{chargingStationId}
AND STATUS = 0
AND del_flag = 0
)
)
)
</select>
</mapper>

4
xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/api/factory/ActivityInternetfAllbackFactory.java
View File

@ -24,12 +24,12 @@ public class ActivityInternetfAllbackFactory implements FallbackFactory<Activity
return new ActivityInternetService() {
@Override
public R<Map<String, Object>> getActivityStationTime(Long internetUserId, String startTime, String endTime, Long chargingStationId, String tenantId) {
return R.fail("获取活动信息失败:" + cause.getMessage());
return R.fail(3886,"获取活动信息失败:" + cause.getMessage());
}
@Override
public R<Map<String, Object>> getActivityFormulaTime(Integer activityId, String startTime, String endTime) {
return R.fail("获取活动时间段信息失败:" + cause.getMessage());
return R.fail(3886,"获取活动时间段信息失败:" + cause.getMessage());
}
};
}

2
xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/api/factory/CardFallbackFactory.java
View File

@ -17,7 +17,7 @@ public class CardFallbackFactory implements FallbackFactory<CardService> {
return new CardService() {
@Override
public R cardStartup(String cardno, String serialNumber,String rateModelId) {
return R.fail("卡启动判断接口失败:" + cause.getMessage());
return R.fail(3886,"卡启动判断接口失败:" + cause.getMessage());
}
};
}

2
xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/api/factory/CardHistoryOrderFactory.java
View File

@ -17,7 +17,7 @@ public class CardHistoryOrderFactory implements FallbackFactory<CardHistoryOrder
return new CardHistoryOrderService() {
@Override
public R cardStartup(Long userId,String serialNumber,Integer userType,String tenantId,Integer type,String grantOperator,String rateModelId) {
return R.fail("服务回滚:" + cause.getMessage());
return R.fail(3886,"服务回滚:" + cause.getMessage());
}
};
}

4
xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/api/factory/ChargingStationPushStatusFallbackFactory.java
View File

@ -29,13 +29,13 @@ public class ChargingStationPushStatusFallbackFactory implements FallbackFactory
@Override
public AjaxResult editStationStatus(Map<String, Object> map) {
return AjaxResult.error("场站编辑回调接口失败:" + cause.getMessage());
return AjaxResult.error(3886,"场站编辑回调接口失败:" + cause.getMessage());
}
@Override
public AjaxResult saveStationStatus(Map<String, Object> map) {
return AjaxResult.error("场站保存回调接口失败:" + cause.getMessage());
return AjaxResult.error(3886,"场站保存回调接口失败:" + cause.getMessage());
}
};
}

2
xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/api/factory/InternetUserFallbackFactory.java
View File

@ -24,7 +24,7 @@ public class InternetUserFallbackFactory implements FallbackFactory<InternetUser
@Override
public R getOperatorIdEvcs(String operatorIdEvcs) {
return R.fail("平台第三方服务发送失败:" + cause.getMessage());
return R.fail(3886,"平台第三方服务发送失败:" + cause.getMessage());
}
};
}

16
xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/api/factory/PileOrderFallbackFactory.java
View File

@ -24,42 +24,40 @@ public class PileOrderFallbackFactory implements FallbackFactory<PileOrderServic
@Override
public R pileStartup(String orderNo, Integer status, String remark) {
return R.fail("桩启动回调接口失败:" + cause.getMessage());
return R.fail(3886,"桩启动回调接口失败:" + cause.getMessage());
}
@Override
public R pileStop(String orderNo, Integer status, String remark) {
return R.fail("桩停止回调接口失败:" + cause.getMessage());
return R.fail(3886,"桩停止回调接口失败:" + cause.getMessage());
}
@Override
public R pileEndOrder(String orderNo) {
return null;
return R.fail(3886,"桩订单结束回调接口失败:" + cause.getMessage());
}
@Override
public R pileRimeOrder(String orderNo) {
return R.fail("桩实时订单回调接口失败:" + cause.getMessage());
return R.fail(3886,"桩实时订单回调接口失败:" + cause.getMessage());
}
@Override
public R abnormalOrder(String orderNo) {
return R.fail("订单异常回调接口失败:" + cause.getMessage());
return R.fail(3886,"订单异常回调接口失败:" + cause.getMessage());
}
@Override
public R pileStartUpBy3rd(String internetSerialNumber, String driverId, Integer chargingAmt, String plateNum, Integer status, String connectorId) {
return R.fail("互联网订单启动失败:" + cause.getMessage());
return R.fail(3886,"互联网订单启动失败:" + cause.getMessage());
}
@Override
public R pileVin(String serialNumber, String vinNumber) {
return R.fail("VIN码启动失败:" + cause.getMessage());
return R.fail(3886,"VIN码启动失败:" + cause.getMessage());
}
};
}

18
xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/api/factory/PowerPileFallbackFactory.java
View File

@ -25,55 +25,55 @@ public class PowerPileFallbackFactory implements FallbackFactory<PowerPileServic
@Override
public R startCharging(StartChargingData startChargingData) {
return R.fail("启动充电失败:" + cause.getMessage());
return R.fail(3886,"启动充电失败:" + cause.getMessage());
}
@Override
public R refreshBalance(StartChargingData balanceRefreshData) {
return R.fail("刷新余额失败:" + cause.getMessage());
return R.fail(3886,"刷新余额失败:" + cause.getMessage());
}
@Override
public R stopCharging(String orderNo, String pileNo, String connectorId, String version) {
return R.fail("停止充电失败:" + cause.getMessage());
return R.fail(3886,"停止充电失败:" + cause.getMessage());
}
@Override
public R addPileWhitelist(Long stationId, String version, Set<String> pileNoSet) {
return R.fail("增加充电桩白名单失败:" + cause.getMessage());
return R.fail(3886,"增加充电桩白名单失败:" + cause.getMessage());
}
@Override
public R deletePileWhitelist(Long stationId, Set<String> pileNoSet) {
return R.fail("删除充电桩白名单失败:" + cause.getMessage());
return R.fail(3886,"删除充电桩白名单失败:" + cause.getMessage());
}
@Override
public R setStationRateModel(Long stationId, Long rateModelId, CacheRateModel rateModel) {
return R.fail("设置电站费率模型失败:" + cause.getMessage());
return R.fail(3886,"设置电站费率模型失败:" + cause.getMessage());
}
@Override
public R configTimeNRateModel(String pileNo) {
return R.fail("校时校费失败:" + cause.getMessage());
return R.fail(3886,"校时校费失败:" + cause.getMessage());
}
@Override
public R pileSoftwareUpgrade(String pileNo) {
return R.fail("更新桩程序失败:" + cause.getMessage());
return R.fail(3886,"更新桩程序失败:" + cause.getMessage());
}
@Override
public R pileReboot(String pileNo) {
return R.fail("重启桩程序失败:" + cause.getMessage());
return R.fail(3886,"重启桩程序失败:" + cause.getMessage());
}
};
}

2
xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/api/factory/RefundOrderFallbackFactory.java
View File

@ -23,7 +23,7 @@ public class RefundOrderFallbackFactory implements FallbackFactory<RefundOrderSe
return new RefundOrderService() {
@Override
public R sendNotice(String amount, String openid, Integer source, String type, String userId,String tenantId,String remark) {
return R.fail("自动申请退款失败:" + cause.getMessage());
return R.fail(3886,"自动申请退款失败:" + cause.getMessage());
}
};

2
xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/api/factory/SettingConfigFactory.java
View File

@ -18,7 +18,7 @@ public class SettingConfigFactory implements FallbackFactory<SettingConfigServic
return new SettingConfigService() {
@Override
public R settingConfig(Integer status, String tenantId) {
return R.fail("获取支付配置信息失败:" + cause.getMessage());
return R.fail(3886,"获取支付配置信息失败:" + cause.getMessage());
}
};
}

2
xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/api/factory/SmsFallbackFactory.java
View File

@ -25,7 +25,7 @@ public class SmsFallbackFactory implements FallbackFactory<SmsService> {
@Override
public R sendNotice(Map<String, String> paramMap) {
return R.fail("短信发送失败:" + cause.getMessage());
return R.fail(3886,"短信发送失败:" + cause.getMessage());
}
};
}

4
xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/api/factory/TenantFallbackFactory.java
View File

@ -16,13 +16,13 @@ public class TenantFallbackFactory implements FallbackFactory<TenantService> {
return new TenantService() {
@Override
public R gettenantIdTime(String tenantId) {
return R.fail("租户服务发送失败:" + cause.getMessage());
return R.fail(3886,"租户服务发送失败:" + cause.getMessage());
}
@Override
public R getTenantDetail(String tenantId) {
return R.fail("租户服务发送失败:" + cause.getMessage());
return R.fail(3886,"租户服务发送失败:" + cause.getMessage());
}
};
}

4
xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/api/factory/UserTypeFallbackFactory.java
View File

@ -23,12 +23,12 @@ public class UserTypeFallbackFactory implements FallbackFactory<UserTypeService>
return new UserTypeService() {
@Override
public R getUser(String phone, Long userId, Integer userType,String serialNumber,String tenantId) {
return R.fail("用户信息获取失败:" + cause.getMessage());
return R.fail(3886,"用户信息获取失败:" + cause.getMessage());
}
@Override
public R insertUserBalance(BigDecimal money,Long userId, Integer userType, String tenantId, Integer type,Integer status,String remark,Long moneyOrderId) {
return R.fail("添加用户金额信息失败:" + cause.getMessage());
return R.fail(3886,"添加用户金额信息失败:" + cause.getMessage());
}
@Override

2
xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/api/factory/WebSocketFallbackFactory.java
View File

@ -23,7 +23,7 @@ public class WebSocketFallbackFactory implements FallbackFactory<WebSocketServic
return new WebSocketService() {
@Override
public R getMessage(String userId, String message) {
return R.fail("消息发送调用失败:" + cause.getMessage());
return R.fail(3886,"消息发送调用失败:" + cause.getMessage());
}
};
}

4
xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/api/factory/WorkOrderFallbackFactory.java
View File

@ -25,12 +25,12 @@ public class WorkOrderFallbackFactory implements FallbackFactory<WorkOrderYuServ
return new WorkOrderYuService() {
@Override
public R addNewOrder(String type, String title, String content, String reason,String stationId,String deviceType,String serialNumber) {
return R.fail("工单生成失败调用失败:" + cause.getMessage());
return R.fail(3886,"工单生成失败调用失败:" + cause.getMessage());
}
@Override
public R workOrderMessage(Integer type, String time) {
return R.fail("工单查询调用失败:" + cause.getMessage());
return R.fail(3886,"工单查询调用失败:" + cause.getMessage());
}
};

3
xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/service/impl/XhpcPileRegularInspectServiceImpl.java
View File

@ -133,7 +133,8 @@ public class XhpcPileRegularInspectServiceImpl extends BaseService implements IX
return AjaxResult.error(500, "请重新登录");
}
}catch (Exception e){
return AjaxResult.error(500, "费率格式不对");
e.printStackTrace();
return AjaxResult.error(500, "服务器开小差了，请联系管理员");
}
}

10
xhpc-modules/xhpc-order/src/main/resources/mapper/XhpcChargeOrderMapper.xml
View File

@ -727,6 +727,14 @@
</select>
<select id="getSerialNumberOrder" resultType="map">
select max(charge_order_id),serial_number serialNumber from xhpc_charge_order where terminal_id = (select terminal_id from xhpc_terminal where serial_number=#{serialNumber} and del_flag =0)
SELECT
serial_number serialNumber
FROM
xhpc_charge_order
WHERE
charge_order_id = (
SELECT MAX(charge_order_id) FROM xhpc_charge_order WHERE terminal_id = (
SELECT terminal_id FROM xhpc_terminal WHERE serial_number =#{serialNumber} AND del_flag = 0 )
)
</select>
</mapper>