项目中的《访问者模式》

这个模式焦点头脑是将基本的数据对象和对应的操作相互分离。数据对象就只是数据对象，如果想要扩展操作，就扩展对应的visitor。
这种模式下的两次分派

第一次分派，是将对数据对象本身举行分派，可以有差别的实现。
第二次分派，是visitor接收差别的数据对象。
结果就是数据对象接受了visitor，然后visitor中组合了数据对象。
这个项目中的使用场景

对于订单状态，有两个数据载体，一个是数据库已存在的当前的状态，一个是消息推送过来的状态。通过两个载体的状态的组合，能做出响应的动作。
处置惩罚逻辑如下⬇︎⬇︎⬇︎

UML是如许的⬇︎⬇︎⬇︎

现实代码是如许的⬇︎⬇︎⬇︎
DbStatus

1. package com.xxx.sales.saicorder.outerapp.tmall.message.visitor;
3. import com.xxx.sales.saicorder.outerapp.tmall.enums.BusinessStatusEnum;
4. import com.xxx.sales.saicorder.outerapp.tmall.enums.MessageDealWithResultEnum;
6. /**
7. * @author Euler
8. */
9. public abstract class DbStatus {
10.     /**
11.      * 处理结果
12.      */
13.     private Integer businessStatus;
15.     public DbStatus(Integer businessStatus) {
16.         this.businessStatus = businessStatus;
17.     }
19.     private DbStatus() {
20.     }
22.     /**
23.      * 接收天猫状态的visitor
24.      * @param tmallVisitorStatus
25.      * @return
26.      */
27.     public abstract MessageDealWithResultEnum acceptTmallVisitor(TmallVisitorStatus tmallVisitorStatus);
30.     /**
31.      * 将DB记录的处理结果转成BusinessStatusEnum
32.      * @return
33.      */
34.     protected BusinessStatusEnum getBusinessStatus(){
35.         return BusinessStatusEnum.valueOfCode(businessStatus);
36.     }
37. }

复制代码

DbPayedStatus

1. package com.xxx.sales.saicorder.outerapp.tmall.message.visitor;
3. import com.xxx.sales.saicorder.outerapp.tmall.enums.MessageDealWithResultEnum;
5. /**
6. * db记录已支付
7. * @author Euler
8. */
9. public class DbPayedStatus extends DbStatus{
12.     public DbPayedStatus(Integer businessStatus) {
13.         super(businessStatus);
14.     }
16.     /**
17.      * 接收天猫状态的visitor
18.      *
19.      * @param tmallVisitorStatus
20.      *
21.      * @return
22.      */
23.     @Override
24.     public MessageDealWithResultEnum acceptTmallVisitor(TmallVisitorStatus tmallVisitorStatus) {
25.         return tmallVisitorStatus.visitDbStatus(this);
26.     }
27. }

复制代码

DbCloseStatus

1. package com.xxx.sales.saicorder.outerapp.tmall.message.visitor;
3. import com.xxx.sales.saicorder.outerapp.tmall.enums.MessageDealWithResultEnum;
5. /**
6. * db记录已关闭
7. * @author Euler
8. */
9. public class DbCloseStatus extends DbStatus{
10.     public DbCloseStatus(Integer businessStatus) {
11.         super(businessStatus);
12.     }
14.     /**
15.      * 接收天猫状态的visitor
16.      *
17.      * @param tmallVisitorStatus
18.      *
19.      * @return
20.      */
21.     @Override
22.     public MessageDealWithResultEnum acceptTmallVisitor(TmallVisitorStatus tmallVisitorStatus) {
23.         return tmallVisitorStatus.visitDbStatus(this);
24.     }
25. }

复制代码

DbChargeOffStatus

1. package com.xxx.sales.saicorder.outerapp.tmall.message.visitor;
3. import com.xxx.sales.saicorder.outerapp.tmall.enums.MessageDealWithResultEnum;
5. /**
6. * db记录已核销
7. * @author Euler
8. */
9. public class DbChargeOffStatus extends DbStatus{
11.     public DbChargeOffStatus(Integer businessStatus) {
12.         super(businessStatus);
13.     }
15.     /**
16.      * 接收天猫状态的visitor
17.      *
18.      * @param tmallVisitorStatus
19.      *
20.      * @return
21.      */
22.     @Override
23.     public MessageDealWithResultEnum acceptTmallVisitor(TmallVisitorStatus tmallVisitorStatus) {
24.         return tmallVisitorStatus.visitDbStatus(this);
25.     }
27. }

复制代码

TmallVisitorStatus

1. package com.xxx.sales.saicorder.outerapp.tmall.message.visitor;
3. import com.xxx.sales.saicorder.outerapp.tmall.enums.BusinessStatusEnum;
4. import com.xxx.sales.saicorder.outerapp.tmall.enums.MessageDealWithResultEnum;
6. /**
7. * 天猫visitor
8. *
9. * @author Euler
10. */
11. public interface TmallVisitorStatus {
13.     /**
14.      * 判断数据库记录是否处理成功
15.      *
16.      * @param statusEnum
17.      *
18.      * @return
19.      */
20.     default boolean dbRecordIsFail(BusinessStatusEnum statusEnum) {
21.         return BusinessStatusEnum.ABNORMAL.equals(statusEnum) || BusinessStatusEnum.CREATE_ORDER_ABNORMAL.equals(statusEnum);
22.     }
25.     /**
26.      * 访问Db 已支付状态
27.      *
28.      * @param dbPayedStatus
29.      *
30.      * @return
31.      */
32.     MessageDealWithResultEnum visitDbStatus(DbPayedStatus dbPayedStatus);
35.     /**
36.      * 访问Db已核销状态
37.      *
38.      * @param dbChargeOffStatus
39.      *
40.      * @return
41.      */
42.     MessageDealWithResultEnum visitDbStatus(DbChargeOffStatus dbChargeOffStatus);
45.     /**
46.      * 访问Db 已退款状态
47.      *
48.      * @param dbCloseStatus
49.      *
50.      * @return
51.      */
52.     MessageDealWithResultEnum visitDbStatus(DbCloseStatus dbCloseStatus);
55. }

复制代码

TmallVisitorPayedStatus

1. package com.xxx.sales.saicorder.outerapp.tmall.message.visitor;
3. import com.xxx.sales.saicorder.outerapp.tmall.enums.BusinessStatusEnum;
4. import com.xxx.sales.saicorder.outerapp.tmall.enums.MessageDealWithResultEnum;
6. /**
7. * 天猫已支付状态
8. * @author Euler
9. * @date 2022 2022/11/22
10. */
11. public class TmallVisitorPayedStatus implements TmallVisitorStatus {
12.     /**
13.      * 访问Db 已支付状态
14.      *
15.      * @param dbPayedStatus
16.      *
17.      * @return
18.      */
19.     @Override
20.     public MessageDealWithResultEnum visitDbStatus(DbPayedStatus dbPayedStatus) {
21.         BusinessStatusEnum businessStatus = dbPayedStatus.getBusinessStatus();
22.         // 支付处理失败重试
23.         if (dbRecordIsFail(businessStatus)) {
24.             return MessageDealWithResultEnum.NORMAL;
26.         // 支付处理成功，又来支付成功消息，视为重复消息，清除
27.         }else{
28.             return MessageDealWithResultEnum.IS_REPEATED_MESSAGE;
29.         }
30.     }
32.     /**
33.      * 访问Db已核销状态
34.      *
35.      * @param dbChargeOffStatus
36.      *
37.      * @return
38.      */
39.     @Override
40.     public MessageDealWithResultEnum visitDbStatus(DbChargeOffStatus dbChargeOffStatus) {
41.         // 状态已经走到核销，又来已支付的消息。视为延时重复消息，清除
42.         return MessageDealWithResultEnum.IS_REPEATED_MESSAGE;
43.     }
45.     /**
46.      * 访问Db 已退款状态
47.      *
48.      * @param dbCloseStatus
49.      *
50.      * @return
51.      */
52.     @Override
53.     public MessageDealWithResultEnum visitDbStatus(DbCloseStatus dbCloseStatus) {
54.         // 状态已走到关闭，又来已支付消息，视为延时消息，清除
55.         return MessageDealWithResultEnum.IS_REPEATED_MESSAGE;
56.     }
57. }

复制代码

TmallVisitorCloseStatus

1. package com.xxx.sales.saicorder.outerapp.tmall.message.visitor;
3. import com.xxx.sales.saicorder.outerapp.tmall.enums.MessageDealWithResultEnum;
5. /**
6. *
7. * 天猫已退款状态
8. * @author Euler
9. */
10. public class TmallVisitorCloseStatus implements TmallVisitorStatus{
11.     /**
12.      * 访问Db 已支付状态
13.      *
14.      * @param dbPayedStatus
15.      *
16.      * @return
17.      */
18.     @Override
19.     public MessageDealWithResultEnum visitDbStatus(DbPayedStatus dbPayedStatus) {
20.         boolean dbRecordIsFail = dbRecordIsFail(dbPayedStatus.getBusinessStatus());
21.         // 已支付消息处理失败，订单没有创建成功，不能处理退款的消息
22.         if (dbRecordIsFail) {
23.             return MessageDealWithResultEnum.NO_SEQUENCE_MESSAGE;
25.         // 已支付消息处理成功，可以正常处理退款消息
26.         }else{
27.             return MessageDealWithResultEnum.NORMAL;
28.         }
29.     }
31.     /**
32.      * 访问Db已核销状态
33.      *
34.      * @param dbChargeOffStatus
35.      *
36.      * @return
37.      */
38.     @Override
39.     public MessageDealWithResultEnum visitDbStatus(DbChargeOffStatus dbChargeOffStatus) {
40.         // 已核销和已退款是互斥消息，处理了核销，就不能处理退款。（天猫核销后不能在天猫退款）
41.         return MessageDealWithResultEnum.IS_REPEATED_MESSAGE;
42.     }
44.     /**
45.      * 访问Db 已退款状态
46.      *
47.      * @param dbCloseStatus
48.      *
49.      * @return
50.      */
51.     @Override
52.     public MessageDealWithResultEnum visitDbStatus(DbCloseStatus dbCloseStatus) {
53.         boolean dbRecordIsFail = dbRecordIsFail(dbCloseStatus.getBusinessStatus());
54.         // 退款消息处理失败，再来退款重试消息，正常处理
55.         if (dbRecordIsFail) {
56.             return MessageDealWithResultEnum.NORMAL;
58.         // 退款消息处理成功了，再来退款消息，视为延时重复消息，清除
59.         }else {
60.             return MessageDealWithResultEnum.IS_REPEATED_MESSAGE;
61.         }
62.     }
63. }

复制代码

TmallVisitorChargeOffVisitorStatus

1. package com.xxx.sales.saicorder.outerapp.tmall.message.visitor;
3. import com.xxx.sales.saicorder.outerapp.tmall.enums.MessageDealWithResultEnum;
5. /**
6. * 天猫核销完成状态
7. * @author Euler
8. */
9. public class TmallVisitorChargeOffVisitorStatus implements TmallVisitorStatus {
10.     /**
11.      * 访问Db 已支付状态
12.      *
13.      * @param dbPayedStatus
14.      *
15.      * @return
16.      */
17.     @Override
18.     public MessageDealWithResultEnum visitDbStatus(DbPayedStatus dbPayedStatus) {
19.         boolean dbRecordIsFail = dbRecordIsFail(dbPayedStatus.getBusinessStatus());
20.         // 已支付消息处理失败，订单没有创建成功，不能处理核销的消息。消息重回队列
21.         if (dbRecordIsFail) {
22.             return MessageDealWithResultEnum.NO_SEQUENCE_MESSAGE;
24.         // 已支付处理成功，正常处理核销消息
25.         }else{
26.             return MessageDealWithResultEnum.NORMAL;
27.         }
28.     }
30.     /**
31.      * 访问Db已核销状态
32.      *
33.      * @param dbChargeOffStatus
34.      *
35.      * @return
36.      */
37.     @Override
38.     public MessageDealWithResultEnum visitDbStatus(DbChargeOffStatus dbChargeOffStatus) {
39.         boolean dbRecordIsFail = dbRecordIsFail(dbChargeOffStatus.getBusinessStatus());
40.         // 核销处理失败，又来核销重试消息，正常处理
41.         if (dbRecordIsFail) {
42.             return MessageDealWithResultEnum.NORMAL;
44.         // 核销处理成功，又来核销消息，视为重复消息，清除
45.         }else{
46.             return MessageDealWithResultEnum.IS_REPEATED_MESSAGE;
47.         }
48.     }
50.     /**
51.      * 访问Db 已退款状态
52.      *
53.      * @param dbCloseStatus
54.      *
55.      * @return
56.      */
57.     @Override
58.     public MessageDealWithResultEnum visitDbStatus(DbCloseStatus dbCloseStatus) {
59.         // 关闭后不在接收核销消息，清除
60.         return MessageDealWithResultEnum.IS_REPEATED_MESSAGE;
61.     }
62. }

复制代码

复杂的状态对应关系就如许解决了。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。