NoopDfGroundLockMsgPushService.java
6.96 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
package com.zteits.glockcollect.biz;
import com.zteits.clouds.api.apibase.bean.BizResult;
import com.zteits.clouds.api.apibase.constants.ErrorType;
import com.zteits.clouds.api.dto.datacollect.param.df.DfGroundLockConfigPushRequest;
import com.zteits.clouds.api.dto.datacollect.param.df.DfGroundLockControlPushRequest;
import com.zteits.clouds.api.dto.datacollect.param.df.DfGroundLockOpenByPayPushRequest;
import com.zteits.clouds.api.service.datacollect.DfGroundLockMsgPushService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
/**
* {@link DfGroundLockMsgPushService}（给德飞地锁推送下发任务）的**空实现** —— 临时桥接，不是业务代码。
*
* <h2>为什么需要它</h2>
*
* 老工程里这个接口由**独立 JVM** {@code zteits-glock-collection} 通过 Dubbo 提供。
* 单 Jar 之后没有 Dubbo 了，但调用方还在：
* <ul>
* <li>{@code com.zteits.ipay.service.apppubpay.busigroup.impl.park.notify.impl.DeFeiNotifyServiceImpl}
* （德飞支付成功通知 → 开锁）</li>
* <li>{@code com.zteits.ipay.biz.AliWxPayServiceImpl#openTheDfLockForPaid}（0 元支付/时域卡 → 降锁）</li>
* </ul>
* 两处都是**裸 {@code @Autowired}（required=true）**，缺 Bean 则整个单 Jar 启动失败
* （实测报错：{@code No qualifying bean of type
* 'com.zteits.clouds.api.service.datacollect.DfGroundLockMsgPushService'}，
* 装配链 {@code dealGeoInOutParkDataSchedule → ... → DeFeiNotifyServiceImpl}）。
*
* <h2>为什么不用真实实现</h2>
*
* 真实实现是 {@code zteits-glock-collection/src/main/java/com/zteits/glockcollect/biz/
* DfGroundLockMsgPushServiceImpl.java}，它依赖 {@code DFClientMsgPushService} —— 一条
* **netty 长连接 TCP 客户端**（持有设备 Channel、按设备号找 ChannelHandlerContext）。
* 该工程用的是 {@code netty 5.0.0.Alpha2}，而本工程 Redisson 依赖 netty 4.1.x，
* 两者不能同进程共存（同名 {@code io.netty.*} 类会互相覆盖）。
* 德飞地锁属于**设备网关**范畴，随迁它 = 同时解决 netty 版本冲突 + TCP 客户端生命周期，
* 故整体推迟到设备对接阶段（方案 P5），本轮只保证单 Jar 能起来。
*
* <h2>为什么是「返回失败」而不是「抛异常」</h2>
*
* 三个调用点对异常的容忍度不同，**抛异常会改变既有行为**：
* <ul>
* <li>{@code DeFeiNotifyServiceImpl.notify(...)} 外面有 {@code catch (Exception)}，
* 抛出只被记成 error 日志，不改流程 —— 抛是安全的。</li>
* <li>{@code AliWxPayServiceImpl#openTheDfLockForPaid} 的 3 个调用点**只 catch
* {@code InterruptedException}**，且紧跟其后就要抛
* {@code BizException(NOT_FOUND_PAY_ORDER, "您已经支付，请及时离场")}。
* 这里若抛 RuntimeException/BizException，会把那句**面向用户的业务提示**顶掉，
* 变成一个 500 级错误 —— 属于改动支付链路行为，不可接受。</li>
* </ul>
* 折中：返回 {@code success=false} 的 {@link BizResult} 并**打 error 日志**。
* 三个调用点都只看日志、不判 {@code isSuccess()}，因此**行为与接入真实实现时完全一致**
* （真实实现在消息写成功后同样只返回结果、不做后续判断），同时丢失的链路在日志里一眼可见。
* <p>
* 也**刻意不返回 {@code new BizResult<>(true)}**：那等于谎报「地锁已开」，
* 将来若有调用方开始判返回值，会被静默骗过。
*
* <h2>⚠️ P5 交接（务必执行）</h2>
*
* 搬入 {@code zteits-glock-collection} 的真实实现后，**必须删除本类**：
* 本类的 Bean 名刻意取了真实实现的 {@code @Service} 值
* （{@code com.zteits.glockcollect.biz.DfGroundLockMsgPushServiceImpl}），
* 两者同时存在会以 {@code ConflictingBeanDefinitionException} 启动失败 ——
* 这是刻意留的「别忘了删我」的探针，而不是「自动兜底」。
* 本类所在的 {@code com.zteits.glockcollect} 包已在
* {@code ParkingServerApplication} 的 {@code @ComponentScan} 里，搬入真实实现无需再改扫描配置。
*
* @see com.zteits.clouds.api.service.datacollect.DfGroundLockMsgPushService
*/
@Slf4j
@Service("com.zteits.glockcollect.biz.DfGroundLockMsgPushServiceImpl")
public class NoopDfGroundLockMsgPushService implements DfGroundLockMsgPushService {
/** 错误信息前缀：在日志/返回体里全局可检索，用于区分「地锁未接入」与「地锁真的发失败了」。 */
public static final String NOT_INTEGRATED_PREFIX = "[德飞地锁未接入]";
private static final String NOT_INTEGRATED =
NOT_INTEGRATED_PREFIX + " 单 Jar 未随迁 zteits-glock-collection（netty 5.0.0.Alpha2 与 "
+ "Redisson 的 netty 4.1.x 冲突，见类注释），本次下发已丢弃。";
@Override
public BizResult<Boolean> pushGroundLockConfig(DfGroundLockConfigPushRequest request) throws InterruptedException {
warn("pushGroundLockConfig", "配置下发", request == null ? null : request.getPlNo(),
request == null ? null : request.getEqpNo());
return failure();
}
@Override
public BizResult<Boolean> pushGroundLockOpenByPay(DfGroundLockOpenByPayPushRequest request)
throws InterruptedException {
warn("pushGroundLockOpenByPay", "支付开锁", request == null ? null : request.getPlNo(),
request == null ? null : request.getEqpNo());
return failure();
}
@Override
public BizResult<Boolean> pushGroundLockControl(DfGroundLockControlPushRequest request)
throws InterruptedException {
warn("pushGroundLockControl", "控制指令", request == null ? null : request.getPlNo(),
request == null ? null : request.getEqpNo());
return failure();
}
/**
* 每次下发都按 error 级别记录：这是「地锁不会真的动作」的唯一可见信号，
* 降级成 warn/info 会让线上问题排查时漏掉。
* 用 plNo/eqpNo 定位到具体车场与设备（eqpNo 在存量代码里取的是 {@code orderPark.getCarNumber()}）。
*/
private void warn(String method, String action, String plNo, String eqpNo) {
log.error("{} {}({}) 未真实下发 —— 消息已丢弃。plNo={}, eqpNo={}。"
+ "依赖地锁的链路（德飞支付成功开锁 / 0 元支付降锁 / 地锁配置与控制）都不会生效；"
+ "恢复方式见 NoopDfGroundLockMsgPushService 类注释的 P5 交接。",
NOT_INTEGRATED_PREFIX, method, action, plNo, eqpNo);
}
private BizResult<Boolean> failure() {
// 注意：BizResult(ErrorType,String) 会把 success 置为 false（ResultBean 构造函数），
// 且不设置 data —— 不能改写成 new BizResult<>(Boolean.FALSE)，那会把 success 置为 true。
return new BizResult<>(ErrorType.PARK_SEND_FAIL, NOT_INTEGRATED);
}
}