diff --git a/cloud-modules/cloud-modules-processing/src/main/java/com/muyu/processing/listener/AddDatabaseListener.java b/cloud-modules/cloud-modules-processing/src/main/java/com/muyu/processing/listener/AddDatabaseListener.java new file mode 100644 index 0000000..006d5f2 --- /dev/null +++ b/cloud-modules/cloud-modules-processing/src/main/java/com/muyu/processing/listener/AddDatabaseListener.java @@ -0,0 +1,34 @@ +package com.muyu.processing.listener; + +import cn.hutool.json.JSONObject; +import com.muyu.processing.basic.EventCustom; +import com.muyu.processing.basic.EventListener; + +import java.util.ArrayList; + +/** + * 添加数据库事件 + * @Author:杨鹏 + * @Package:com.muyu.processing.listener + * @Project:car-cloud-server + * @name:AddDatabaseListener + * @Date:2024/9/29 22:25 + */ +public class AddDatabaseListener implements EventListener { + @Override + public void onEvent(EventCustom event) { + JSONObject jsonObject = event.getData(); + ArrayList keys = new ArrayList<>(); + ArrayList values = new ArrayList<>(); + jsonObject.forEach((key, value) ->{ + keys.add(key); + values.add(value); + }); + // 添加数据库 + } + + @Override + public void onApplicationEvent(EventCustom event) { + onEvent(event); + } +}