修改接入基本表接口

liutongyi-admin/src/main/java/com/citygis/web/domain/TabSystemMsg.java

@@ -1,5 +1,8 @@
 package com.citygis.web.domain;
 
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
@@ -9,7 +12,7 @@ import java.io.Serializable;
 
 /**
  * <p>
- * 
+ *
  * </p>
  *
  * @author citygis
@@ -17,36 +20,55 @@ import java.io.Serializable;
  */
 @Data
 @EqualsAndHashCode(callSuper = false)
-@ApiModel(value="TabSystemMsg对象", description="")
+@ApiModel(value = "TabSystemMsg对象", description = "")
 public class TabSystemMsg implements Serializable {
 
     private static final long serialVersionUID = 1L;
 
+    @ApiModelProperty(value = "id")
+    @TableField("id")
+    @TableId(value = "id", type = IdType.ASSIGN_ID)
     private Integer id;
 
     @ApiModelProperty(value = "数据源应用系统")
+    @TableField("system_name")
     private String systemName;
 
     @ApiModelProperty(value = "表单名称")
+    @TableField("table_name")
     private String tableName;
 
     @ApiModelProperty(value = "表名称")
+    @TableField("table_english_name")
     private String tableEnglishName;
 
     @ApiModelProperty(value = "接入方式")
+    @TableField("access_manner")
     private String accessManner;
 
     @ApiModelProperty(value = "更新方式")
+    @TableField("update_type")
     private String updateType;
 
     @ApiModelProperty(value = "状态：0不正常1正常")
+    @TableField("status")
     private Integer status;
 
     @ApiModelProperty(value = "业务量")
+    @TableField("ps")
     private String ps;
 
     @ApiModelProperty(value = "数量")
+    @TableField("count")
     private String count;
 
+    @ApiModelProperty(value = "数据基本id")
+    @TableField("data_essential_id")
+    private Long dataEssentialId;
+
+    @ApiModelProperty(value = "是否删除：0未删除，1删除")
+    @TableField("is_del")
+    private Integer isDel;
+
 
 }

liutongyi-admin/src/main/java/com/citygis/web/mapper/TabSystemMsgMapper.java

@@ -29,4 +29,6 @@ public interface TabSystemMsgMapper extends BaseMapper<TabSystemMsg> {
 
     List<NewCount> getNew();
 
+    Integer insertTabSystemMsg(TabSystemMsg tabSystemMsg);
+
 }

liutongyi-admin/src/main/java/com/citygis/web/service/ITabSystemMsgService.java

@@ -27,4 +27,5 @@ public interface ITabSystemMsgService extends IService<TabSystemMsg> {
 
     List<NewCount> getNew();
 
+    Boolean insertTabSystemMsg(TabSystemMsg tabSystemMsg);
 }

liutongyi-admin/src/main/java/com/citygis/web/service/impl/TabAccessReadyServiceImpl.java

@@ -80,8 +80,8 @@ public class TabAccessReadyServiceImpl extends ServiceImpl<TabAccessReadyMapper,
         List<TabAccessAndReady> offersList = tabAccessReady.getOffers();
 
         // 给 access 和 offers 设置 ID
-        setAccessAndOfferIds(accessList, id, snowflake,tabAccessReady.getCode());
-        setAccessAndOfferIds(offersList, id, snowflake,tabAccessReady.getCode());
+        setAccessAndOfferIds(accessList, id, snowflake);
+        setAccessAndOfferIds(offersList, id, snowflake);
 
         // 保存 access 和 offers 批量数据
         tabAccessAndReadyService.saveBatch(accessList);
@@ -92,7 +92,7 @@ public class TabAccessReadyServiceImpl extends ServiceImpl<TabAccessReadyMapper,
         Map<Long, TabAccess> offerMap = getAccessInfoMap(offersList);
 
         // 构建反馈信息
-        List<TabAccessFeedback> feedbackList = buildAccessFeedbackList(accessList, offersList, accessMap, offerMap, id);
+        List<TabAccessFeedback> feedbackList = buildAccessFeedbackList(accessList, offersList, accessMap, offerMap, id,tabAccessReady);
 
         return AjaxResult.success(feedbackList);
     }
@@ -147,11 +147,10 @@ public class TabAccessReadyServiceImpl extends ServiceImpl<TabAccessReadyMapper,
     }
 
     // 设置 Access 和 Offer 的 ID
-    private void setAccessAndOfferIds(List<TabAccessAndReady> list, long id, Snowflake snowflake,String code) {
+    private void setAccessAndOfferIds(List<TabAccessAndReady> list, long id, Snowflake snowflake) {
         list.forEach(item -> {
             item.setId(snowflake.nextId());
             item.setAccessOnlyId(id);
-            item.setCode(code);
         });
     }
 
@@ -167,7 +166,7 @@ public class TabAccessReadyServiceImpl extends ServiceImpl<TabAccessReadyMapper,
 
     // 构建 TabAccessFeedback 列表
     private List<TabAccessFeedback> buildAccessFeedbackList(List<TabAccessAndReady> accessList, List<TabAccessAndReady> offersList,
-                                                            Map<Long, TabAccess> accessMap, Map<Long, TabAccess> offerMap, long id) {
+                                                            Map<Long, TabAccess> accessMap, Map<Long, TabAccess> offerMap, long id,TabAccessReady tabAccessReady) {
         List<TabAccessFeedback> feedbackList = new ArrayList<>();
 
         accessList.forEach(accessItem -> {
@@ -178,6 +177,9 @@ public class TabAccessReadyServiceImpl extends ServiceImpl<TabAccessReadyMapper,
                 // 为每个 offer 创建新的 TabAccessFeedback 对象
                 TabAccessFeedback feedback = new TabAccessFeedback();
                 feedback.setAccessOnlyId(id);
+                feedback.setCode(tabAccessReady.getCode());
+                feedback.setOfferType(tabAccessReady.getDataOfferType());
+                feedback.setAccessCode(tabAccessReady.getDataAccessType());
 
                 // 设置 Access 的信息
                 feedback.setAccessName(access.getDept());

liutongyi-admin/src/main/java/com/citygis/web/service/impl/TabDatasourceMsgServiceImpl.java

@@ -1,11 +1,16 @@
 package com.citygis.web.service.impl;
 
+import cn.hutool.core.lang.Snowflake;
+import cn.hutool.core.util.IdUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.citygis.common.annotation.DataSource;
 import com.citygis.common.core.domain.AjaxResult;
+import com.citygis.common.enums.DataSourceType;
+import com.citygis.framework.datasource.DynamicDataSourceContextHolder;
 import com.citygis.web.domain.*;
 import com.citygis.web.mapper.TabDatasourceMsgMapper;
 import com.citygis.web.service.*;
-import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -39,132 +44,265 @@ public class TabDatasourceMsgServiceImpl extends ServiceImpl<TabDatasourceMsgMap
     @Resource
     ITabUrlService tabUrlService;
 
+    @Resource
+    ITabSystemMsgService tabSystemMsgService;
+
     @Override
     @Transactional
     public AjaxResult insertDataSun(DataSun dataSun) {
+        Snowflake snowflake = IdUtil.getSnowflake(1, 1);
 
-        List<TabEtl> etl = dataSun.getEtl();
-        if (etl != null) {
-            etl.forEach(tabEtl -> {
-                tabEtl.setAccessFeedbackId(dataSun.getAccessFeedbackId());
-                tabEtlService.save(tabEtl);
-            });
-        }
+        // 统一处理各类数据
+        saveAndCreateTabSystemMsg(dataSun.getEtl(), "ETL", dataSun.getAccessFeedbackId(), snowflake);
+        saveAndCreateTabSystemMsg(dataSun.getKafka(), "KAFKA", dataSun.getAccessFeedbackId(), snowflake);
+        saveAndCreateTabSystemMsg(dataSun.getKb(), "KB", dataSun.getAccessFeedbackId(), snowflake);
+        saveAndCreateTabSystemMsg(dataSun.getSftp(), "SFTP", dataSun.getAccessFeedbackId(), snowflake);
+        saveAndCreateTabSystemMsg(dataSun.getUrl(), "URL", dataSun.getAccessFeedbackId(), snowflake);
 
-        List<TabKafka> kafka = dataSun.getKafka();
-        if (kafka != null) {
-            kafka.forEach(tabKafka -> {
-                tabKafka.setAccessFeedbackId(dataSun.getAccessFeedbackId());
-                tabKafkaService.save(tabKafka);
-            });
-        }
+        return AjaxResult.success("添加成功");
+    }
+
+    // 通用方法：处理保存和 TabSystemMsg 创建
+    private <T> void saveAndCreateTabSystemMsg(List<T> dataList, String accessManner, Long accessFeedbackId, Snowflake snowflake) {
+        if (dataList != null) {
+            dataList.forEach(data -> {
+                // 设置反馈ID
+                setAccessFeedbackId(data, accessFeedbackId);
+
+                // 根据不同类型的实体进行保存
+                if (data instanceof TabEtl) {
+                    ((TabEtl) data).setId(snowflake.nextId());
+                    tabEtlService.save((TabEtl) data);
+                } else if (data instanceof TabKafka) {
+                    ((TabKafka) data).setId(snowflake.nextId());
+                    tabKafkaService.save((TabKafka) data);
+                } else if (data instanceof TabKb) {
+                    ((TabKb) data).setId(snowflake.nextId());
+                    tabKbService.save((TabKb) data);
+                } else if (data instanceof TabSftp) {
+                    ((TabSftp) data).setId(snowflake.nextId());
+                    tabSftpService.save((TabSftp) data);
+                } else if (data instanceof TabUrl) {
+                    ((TabUrl) data).setId(snowflake.nextId());
+                    tabUrlService.save((TabUrl) data);
+                }
+
+                // 创建并保存 TabSystemMsg
+//                 createTabSystemMsg(data, accessManner, snowflake);
 
-        List<TabKb> kb = dataSun.getKb();
-        if (kb != null) {
-            kb.forEach(tabKb -> {
-                tabKb.setAccessFeedbackId(dataSun.getAccessFeedbackId());
-                tabKbService.save(tabKb);
-            });
-        }
 
-        List<TabSftp> sftp = dataSun.getSftp();
-        if (sftp != null) {
-            sftp.forEach(tabSftp -> {
-                tabSftp.setAccessFeedbackId(dataSun.getAccessFeedbackId());
-                tabSftpService.save(tabSftp);
             });
         }
+    }
 
-        List<TabUrl> url = dataSun.getUrl();
-        if (url != null) {
-            url.forEach(tabUrl -> {
-                tabUrl.setAccessFeedbackId(dataSun.getAccessFeedbackId());
-                tabUrlService.save(tabUrl);
-            });
+
+
+    // 创建 TabSystemMsg
+    @DataSource(DataSourceType.SLAVE)
+    private <T> void createTabSystemMsg(T data, String accessManner, Snowflake snowflake) {
+        TabSystemMsg tsm = new TabSystemMsg();
+        tsm.setId((int) snowflake.nextId());
+
+        if (data instanceof TabEtl) {
+            tsm.setTableEnglishName(((TabEtl) data).getTableEnglishName());
+            tsm.setTableName(((TabEtl) data).getTableName());
+            tsm.setSystemName(((TabEtl) data).getScenario());
+            tsm.setDataEssentialId(((TabEtl) data).getId());
+        } else if (data instanceof TabKafka) {
+            tsm.setTableEnglishName(((TabKafka) data).getTopicEnglishName());
+            tsm.setTableName(((TabKafka) data).getTopicName());
+            tsm.setSystemName(((TabKafka) data).getScenario());
+            tsm.setDataEssentialId(((TabKafka) data).getId());
+        } else if (data instanceof TabKb) {
+            tsm.setTableEnglishName(((TabKb) data).getTableEnglishName());
+            tsm.setTableName(((TabKb) data).getTableName());
+            tsm.setSystemName(((TabKb) data).getScenario());
+            tsm.setDataEssentialId(((TabKb) data).getId());
+        } else if (data instanceof TabSftp) {
+            tsm.setTableEnglishName(((TabSftp) data).getFileEnglishName());
+            tsm.setTableName(((TabSftp) data).getFileName());
+            tsm.setSystemName(((TabSftp) data).getScenario());
+            tsm.setDataEssentialId(((TabSftp) data).getId());
+        } else if (data instanceof TabUrl) {
+            tsm.setTableEnglishName(((TabUrl) data).getOfferUrl());
+            tsm.setTableName(((TabUrl) data).getUrlDetail());
+            tsm.setSystemName(((TabUrl) data).getScenario());
+            tsm.setDataEssentialId(((TabUrl) data).getId());
         }
 
-        return AjaxResult.success("添加成功");
+        tsm.setAccessManner(accessManner);
+        DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.SLAVE.name());
+        boolean b = tabSystemMsgService.save(tsm);
+        DynamicDataSourceContextHolder.clearDataSourceType();;
     }
 
+
     @Override
     @Transactional
     public AjaxResult updateDataSun(DataSun dataSun) {
-        List<TabEtl> etl = dataSun.getEtl();
-        if (etl != null) {
-            etl.forEach(tabEtl -> {
-                tabEtl.setAccessFeedbackId(dataSun.getAccessFeedbackId());
-                tabEtlService.saveOrUpdate(tabEtl);
-            });
-        }
+        updateTabSystemMsg(dataSun.getEtl(), "ETL", dataSun.getAccessFeedbackId());
+        updateTabSystemMsg(dataSun.getKafka(), "KAFKA", dataSun.getAccessFeedbackId());
+        updateTabSystemMsg(dataSun.getKb(), "KB", dataSun.getAccessFeedbackId());
+        updateTabSystemMsg(dataSun.getSftp(), "SFTP", dataSun.getAccessFeedbackId());
+        updateTabSystemMsg(dataSun.getUrl(), "URL", dataSun.getAccessFeedbackId());
 
-        List<TabKafka> kafka = dataSun.getKafka();
-        if (kafka != null) {
-            kafka.forEach(tabKafka -> {
-                tabKafka.setAccessFeedbackId(dataSun.getAccessFeedbackId());
-                tabKafkaService.saveOrUpdate(tabKafka);
-            });
-        }
+        return AjaxResult.success("修改成功");
+    }
 
-        List<TabKb> kb = dataSun.getKb();
-        if (kb != null) {
-            kb.forEach(tabKb -> {
-                tabKb.setAccessFeedbackId(dataSun.getAccessFeedbackId());
-                tabKbService.saveOrUpdate(tabKb);
+    private <T> void updateTabSystemMsg(List<T> dataList, String accessManner, Long accessFeedbackId) {
+        if (dataList != null) {
+            dataList.forEach(data -> {
+                // 设置反馈ID
+                setAccessFeedbackId(data, accessFeedbackId);
+
+                // 根据数据类型保存或更新
+                if (data instanceof TabEtl) {
+                    tabEtlService.saveOrUpdate((TabEtl) data);
+                } else if (data instanceof TabKafka) {
+                    tabKafkaService.saveOrUpdate((TabKafka) data);
+                } else if (data instanceof TabKb) {
+                    tabKbService.saveOrUpdate((TabKb) data);
+                } else if (data instanceof TabSftp) {
+                    tabSftpService.saveOrUpdate((TabSftp) data);
+                } else if (data instanceof TabUrl) {
+                    tabUrlService.saveOrUpdate((TabUrl) data);
+                }
+
+//                // 更新或保存 TabSystemMsg
+//                LambdaQueryWrapper<TabSystemMsg> updateWrapper = new LambdaQueryWrapper<>();
+//                if (data instanceof TabEtl) {
+//                    updateWrapper.eq(TabSystemMsg::getDataEssentialId, ((TabEtl) data).getId());
+//                } else if (data instanceof TabKafka) {
+//                    updateWrapper.eq(TabSystemMsg::getDataEssentialId, ((TabKafka) data).getId());
+//                } else if (data instanceof TabKb) {
+//                    updateWrapper.eq(TabSystemMsg::getDataEssentialId, ((TabKb) data).getId());
+//                } else if (data instanceof TabSftp) {
+//                    updateWrapper.eq(TabSystemMsg::getDataEssentialId, ((TabSftp) data).getId());
+//                } else if (data instanceof TabUrl) {
+//                    updateWrapper.eq(TabSystemMsg::getDataEssentialId, ((TabUrl) data).getId());
+//                }
+//
+//                // 检查是否已经存在
+//                TabSystemMsg one = tabSystemMsgService.getOne(updateWrapper);
+//
+//                // 创建 TabSystemMsg 对象
+//                TabSystemMsg tsm = createTabSystemMsg(data, accessManner);
+//
+//                // 根据是否存在记录决定是插入还是更新
+//                if (one != null) {
+//                    tabSystemMsgService.update(tsm, updateWrapper);
+//                } else {
+//                    tabSystemMsgService.save(tsm);
+//                }
             });
         }
+    }
 
-        List<TabSftp> sftp = dataSun.getSftp();
-        if (sftp != null) {
-            sftp.forEach(tabSftp -> {
-                tabSftp.setAccessFeedbackId(dataSun.getAccessFeedbackId());
-                tabSftpService.saveOrUpdate(tabSftp);
-            });
+    private <T> void setAccessFeedbackId(T data, Long accessFeedbackId) {
+        if (data instanceof TabEtl) {
+            ((TabEtl) data).setAccessFeedbackId(accessFeedbackId);
+        } else if (data instanceof TabKafka) {
+            ((TabKafka) data).setAccessFeedbackId(accessFeedbackId);
+        } else if (data instanceof TabKb) {
+            ((TabKb) data).setAccessFeedbackId(accessFeedbackId);
+        } else if (data instanceof TabSftp) {
+            ((TabSftp) data).setAccessFeedbackId(accessFeedbackId);
+        } else if (data instanceof TabUrl) {
+            ((TabUrl) data).setAccessFeedbackId(accessFeedbackId);
         }
+    }
 
-        List<TabUrl> url = dataSun.getUrl();
-        if (url != null) {
-            url.forEach(tabUrl -> {
-                tabUrl.setAccessFeedbackId(dataSun.getAccessFeedbackId());
-                tabUrlService.saveOrUpdate(tabUrl);
-            });
+    private <T> TabSystemMsg createTabSystemMsg(T data, String accessManner) {
+        TabSystemMsg tsm = new TabSystemMsg();
+
+        if (data instanceof TabEtl) {
+            tsm.setTableEnglishName(((TabEtl) data).getTableEnglishName());
+            tsm.setTableName(((TabEtl) data).getTableName());
+            tsm.setSystemName(((TabEtl) data).getScenario());
+        } else if (data instanceof TabKafka) {
+            tsm.setTableEnglishName(((TabKafka) data).getTopicEnglishName());
+            tsm.setTableName(((TabKafka) data).getTopicName());
+            tsm.setSystemName(((TabKafka) data).getScenario());
+        } else if (data instanceof TabKb) {
+            tsm.setTableEnglishName(((TabKb) data).getTableEnglishName());
+            tsm.setTableName(((TabKb) data).getTableName());
+            tsm.setSystemName(((TabKb) data).getScenario());
+        } else if (data instanceof TabSftp) {
+            tsm.setTableEnglishName(((TabSftp) data).getFileEnglishName());
+            tsm.setTableName(((TabSftp) data).getFileName());
+            tsm.setSystemName(((TabSftp) data).getScenario());
+        } else if (data instanceof TabUrl) {
+            tsm.setTableEnglishName(((TabUrl) data).getOfferUrl());
+            tsm.setTableName(((TabUrl) data).getUrlDetail());
+            tsm.setSystemName(((TabUrl) data).getScenario());
         }
 
-        return AjaxResult.success("修改成功");
-
+        tsm.setAccessManner(accessManner);
+        return tsm;
     }
 
+
     @Override
     @Transactional
     public AjaxResult deleteDataSun(Long id) {
-        TabEtl tabEtl = new TabEtl();
-        tabEtl.setAccessFeedbackId(id);
-        tabEtl.setIsDel(1);
-        tabEtlService.updateById(tabEtl);
-
-        TabKafka tabKafka = new TabKafka();
-        tabKafka.setAccessFeedbackId(id);
-        tabKafka.setIsDel(1);
-        tabKafkaService.updateById(tabKafka);
-
-        TabKb tabKb = new TabKb();
-        tabKb.setAccessFeedbackId(id);
-        tabKb.setIsDel(1);
-        tabKbService.updateById(tabKb);
-
-        TabSftp tabSftp = new TabSftp();
-        tabSftp.setAccessFeedbackId(id);
-        tabSftp.setIsDel(1);
-        tabSftpService.updateById(tabSftp);
-
-        TabUrl tabUrl = new TabUrl();
-        tabUrl.setAccessFeedbackId(id);
-        tabUrl.setIsDel(1);
-        tabUrlService.updateById(tabUrl);
+        // 更新 TabEtl 的删除状态
+        updateTabEntityStatus(TabEtl.class, id);
+
+        // 更新 TabKafka 的删除状态
+        updateTabEntityStatus(TabKafka.class, id);
+
+        // 更新 TabKb 的删除状态
+        updateTabEntityStatus(TabKb.class, id);
+
+        // 更新 TabSftp 的删除状态
+        updateTabEntityStatus(TabSftp.class, id);
+
+        // 更新 TabUrl 的删除状态
+        updateTabEntityStatus(TabUrl.class, id);
 
         return AjaxResult.success("删除成功");
+    }
+
+    // 通用方法：更新 TabEntity 的删除状态，并更新相关的 TabSystemMsg
+    private <T> void updateTabEntityStatus(Class<T> entityClass, Long id) {
+        // 创建对应的实体对象并更新删除状态
+        try {
+            T entity = entityClass.getDeclaredConstructor().newInstance();
+            entityClass.getMethod("setAccessFeedbackId", Long.class).invoke(entity, id);
+            entityClass.getMethod("setIsDel", Integer.class).invoke(entity, 1);
+            Object service = getServiceByEntityClass(entityClass);
+            service.getClass().getMethod("updateById", entityClass).invoke(service, entity);
+
+//            // 查询 TabSystemMsg 相关记录并更新删除状态
+//            LambdaQueryWrapper<TabSystemMsg> queryWrapper = new LambdaQueryWrapper<>();
+//            queryWrapper.eq(TabSystemMsg::getDataEssentialId, id);
+//            TabSystemMsg systemMsg = tabSystemMsgService.getOne(queryWrapper);
+//            if (systemMsg != null) {
+//                systemMsg.setIsDel(1);
+//                tabSystemMsgService.update(systemMsg, queryWrapper);
+//            }
+        } catch (Exception e) {
+            e.printStackTrace(); // 你可以根据需要处理异常
+        }
+    }
 
+    // 根据实体类类型获取对应的服务
+    private Object getServiceByEntityClass(Class<?> entityClass) {
+        if (entityClass.equals(TabEtl.class)) {
+            return tabEtlService;
+        } else if (entityClass.equals(TabKafka.class)) {
+            return tabKafkaService;
+        } else if (entityClass.equals(TabKb.class)) {
+            return tabKbService;
+        } else if (entityClass.equals(TabSftp.class)) {
+            return tabSftpService;
+        } else if (entityClass.equals(TabUrl.class)) {
+            return tabUrlService;
+        }
+        return null;
     }
 
+
     @Override
     public AjaxResult getDataSun(Long id) {
         LambdaQueryWrapper<TabEtl> ql = new LambdaQueryWrapper<>();
@@ -198,5 +336,4 @@ public class TabDatasourceMsgServiceImpl extends ServiceImpl<TabDatasourceMsgMap
     }
 
 
-
 }

liutongyi-admin/src/main/java/com/citygis/web/service/impl/TabSystemMsgServiceImpl.java

@@ -65,4 +65,10 @@ public class TabSystemMsgServiceImpl extends ServiceImpl<TabSystemMsgMapper, Tab
     public List<NewCount> getNew() {
         return tabSystemMsgMapper.getNew();
     }
+
+
+    @DataSource(DataSourceType.SLAVE)
+    public Boolean insertTabSystemMsg(TabSystemMsg tabSystemMsg) {
+        return this.save(tabSystemMsg);
+    }
 }

liutongyi-admin/src/main/resources/mapper/TabSystemMsgMapper.xml

@@ -329,4 +329,30 @@
         操作时间 desc
     </select>
 
+    <insert id="insertTabSystemMsg" parameterType="com.citygis.web.domain.TabSystemMsg">
+        INSERT
+        INTO
+        tab_system_msg
+        (id,
+        system_name,
+        table_name,
+        table_english_name,
+        access_manner,
+        update_type,
+        status,
+        ps,
+        count,
+        data_essential_id)
+        VALUES(#{id},
+        #{systemName]},
+        #{tableName},
+        #{tableEnglishName},
+        #{accessManner},
+        #{updateType},
+        #{status},
+        #{ps},
+        #{count},
+        #{dataEssentialId});
+    </insert>
+
 </mapper>