物理表异常字段查询和同步 增加_TEMP表

admin-api/src/main/java/com/tbyf/his/web/controller/dataImport/DataTemplateController.java

@@ -57,9 +57,6 @@ public class DataTemplateController {
     private ExcelDataService excelDataService;
 
     @Autowired
-    private JdbcTemplate jdbcTemplate;
-
-    @Autowired
     private MetaFieldMapper metaFieldMapper;
 
     @IgnoreWebSecurity
@@ -87,21 +84,11 @@ public class DataTemplateController {
     @IgnoreWebSecurity
     @PostMapping("/syncFieldError")
     @ApiOperation("物理表异常字段同步")
-    public AjaxResult fieldErrorUpdate(@RequestBody List<FieldErrorVo> fieldErrorVos) {
-        final String alterSql = "ALTER TABLE {} MODIFY ( {} {} )";
+    public AjaxResult syncFieldError(@RequestBody List<FieldErrorVo> fieldErrorVos) {
         try {
             DataSourceUtil.switchDs(DataSourceType.SLAVE.name());
             fieldErrorVos.forEach(item -> {
-                String fieldType = item.getFieldType();
-                String fieldName = item.getFieldName();
-                String tableName = item.getTableName();
-                String sql = StrFormatter.format(alterSql, tableName, fieldName, fieldType);
-                try {
-                    jdbcTemplate.execute(sql);
-                } catch (DataAccessException e) {
-                    log.error("alter table's fieldType error");
-                    e.printStackTrace();
-                }
+                dataTemplateService.syncFieldError(item.getFieldType(), item.getFieldName(), item.getTableName());
             });
         } finally {
             DataSourceUtil.switchDefaultDs();

admin-api/src/main/java/com/tbyf/his/web/dataImport/service/DataTemplateService.java

@@ -52,4 +52,12 @@ public interface DataTemplateService extends IService<DataTemplate> {
      * @return
      */
     public CompletableFuture<List<FieldErrorVo>> getTableFieldError(List<FieldErrorVo> fieldErrorVos, String tableName);
+
+    /**
+     * 同步异常字段
+     * @param fieldType
+     * @param fieldName
+     * @param tableName
+     */
+    public void syncFieldError(String fieldType, String fieldName, String tableName);
 }

admin-api/src/main/java/com/tbyf/his/web/dataImport/service/impl/DataTemplateServiceImpl.java

@@ -3,6 +3,7 @@ package com.tbyf.his.web.dataImport.service.impl;
 import com.baomidou.mybatisplus.annotation.DbType;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.tbyf.his.common.annotation.DataSource;
+import com.tbyf.his.common.core.text.StrFormatter;
 import com.tbyf.his.common.enums.DataSourceType;
 import com.tbyf.his.common.utils.StringUtils;
 import com.tbyf.his.common.utils.bean.BeanUtils;
@@ -18,6 +19,8 @@ import com.tbyf.his.web.dataImport.mapper.MetaFieldMapper;
 import com.tbyf.his.web.dataImport.service.DataTemplateService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.dao.DataAccessException;
+import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 
@@ -40,6 +43,11 @@ public class DataTemplateServiceImpl extends ServiceImpl<DataTemplateMapper, Dat
     @Autowired
     private MetaFieldMapper metaFieldMapper;
 
+    @Autowired
+    private JdbcTemplate jdbcTemplate;
+
+    private static final String alterSql = "ALTER TABLE {} MODIFY ( {} {} )";
+
     @Override
     public List<TemplateVO> queryTemplate(QueryTemplateParam param) {
         return dataTemplateMapper.queryTemplate(param);
@@ -97,6 +105,17 @@ public class DataTemplateServiceImpl extends ServiceImpl<DataTemplateMapper, Dat
         return CompletableFuture.completedFuture(resultList);
     }
 
+    @Async
+    public void syncFieldError(String fieldType, String fieldName, String tableName) {
+        String sql = StrFormatter.format(alterSql, tableName, fieldName, fieldType);
+        try {
+            jdbcTemplate.execute(sql);
+        } catch (DataAccessException e) {
+            log.error("alter table's fieldType error");
+            e.printStackTrace();
+        }
+    }
+
     protected boolean isVarcharLengthEqual(String fieldType, String columnType) {
         return fieldType.contains("VARCHAR") && columnType.contains("VARCHAR") &&
                 fieldType.substring(fieldType.indexOf("(") + 1, fieldType.indexOf(")")).equals(columnType.substring(columnType.indexOf("(") + 1, columnType.indexOf(")")));