| | |
| | | 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; |
| | |
| | | } |
| | | } |
| | | |
| | | @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); |
| | |
| | | } catch (SQLException e) { |
| | | e.printStackTrace(); |
| | | return AjaxResult.error(); |
| | | } |
| | | }finally { |
| | | try { |
| | | connection.close(); |
| | | } catch (SQLException ignored) { |
| | | } |
| | | } |
| | | return AjaxResult.success(); |
| | | } |
| | |
| | | } |
| | | 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, "); |
| | |
| | | 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; |
| | | } |
| | | } |
| | | |
| | | /** |