zjh
2024-07-31 6cfbce38436435f574680c0b1e58342e4a2ac444
zjh 2024/07/31-1
2个文件已修改
21 ■■■■ 已修改文件
ltkj-admin/src/main/java/com/ltkj/web/controller/his/HisApiGetMethodService.java 19 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
ltkj-admin/src/main/resources/application.yml 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
ltkj-admin/src/main/java/com/ltkj/web/controller/his/HisApiGetMethodService.java
@@ -14,6 +14,7 @@
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import java.io.FileInputStream;
@@ -202,7 +203,7 @@
        }
    }
    @Transactional
    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public AjaxResult getHISDataNew(String type, Map<String, Object> params){
        LambdaQueryWrapper<HisApiConfig> lambdaQueryWrapper = new LambdaQueryWrapper<>();
        lambdaQueryWrapper.eq(HisApiConfig::getApiMethod, type);
@@ -264,10 +265,11 @@
        } catch (SQLException e) {
            e.printStackTrace();
            return AjaxResult.error();
        }
        }finally {
        try {
            connection.close();
        } catch (SQLException ignored) {
            }
        }
        return AjaxResult.success();
    }
@@ -407,9 +409,9 @@
        }
        deleteSqlBuilder.delete(deleteSqlBuilder.length() - 5, deleteSqlBuilder.length());
        Statement statement = connection.prepareStatement(deleteSqlBuilder.toString());
//        log.info("执行删除 ->{}",deleteSqlBuilder.toString());
        log.info("HIS数据保存类 执行删除 ->{}",deleteSqlBuilder.toString());
        int i = statement.executeUpdate(deleteSqlBuilder.toString());
//        log.info("删除条数 ->{}",i);
        log.info("HIS数据保存类 删除条数 ->{}",i);
        statement.close();
        insertSqlBuilder.append("insert_time, ");
        insertSqlBuilder.append("request_params, ");
@@ -436,9 +438,16 @@
        insertSqlBuilder.append(") values (").append(valueBuilder).append(")");
//        log.info("执行插入 ->{}",insertSqlBuilder.toString());
        // 插入数据
//        boolean execute = statement.execute(insertSqlBuilder.toString());
        for (int j = 0; j < 10; j++) {
        statement = connection.createStatement();
        statement.execute(insertSqlBuilder.toString());
            log.info("HIS数据保存类 执行插入 ->{}",insertSqlBuilder.toString());
            boolean execute = statement.execute(insertSqlBuilder.toString());
            log.info("HIS数据保存类 执行插入状态 ->{},次数->{}",execute,(j+1));
        statement.close();
            if (execute)
                break;
        }
    }
    /**
ltkj-admin/src/main/resources/application.yml
@@ -5,4 +5,4 @@
#xiaochengxu 泾川县部署小程序环境使用
spring:
  profiles:
    active: prod
    active: dev