zzx/XAJMX
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
tp 2025-05-08 16:13:41 +08:00
commit 0cee5de366
16 changed files with 1443 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

74
Controllers/FortranController.cs Normal file
View File

@ -0,0 +1,74 @@
using Microsoft.AspNetCore.Mvc;
using FortranWebApi.Models;
using FortranWebApi.Services;
using System.Text.Json;
namespace FortranWebApi.Controllers
{
[ApiController]
[Route("[controller]")]
public class FortranCalculateController : ControllerBase
{
private readonly FortranInteropService _fortranService;
private readonly ILogger<FortranCalculateController> _logger;
public FortranCalculateController(FortranInteropService fortranService, ILogger<FortranCalculateController> logger)
{
_fortranService = fortranService;
_logger = logger;
}
[HttpPost]
public IActionResult Post([FromBody] FortranRequestWrapper wrapper)
{
try
{
if (string.IsNullOrEmpty(wrapper.Text))
{
return BadRequest(new
{
message = "请求文本不能为空",
success = false,
data = (object)null
});
}
string result = _fortranService.ProcessFortranRequest(wrapper.Text);
// 使用驼峰命名法解析结果
var options = new JsonSerializerOptions
{
PropertyNamingPolicy = JsonNamingPolicy.CamelCase,
DictionaryKeyPolicy = JsonNamingPolicy.CamelCase,
PropertyNameCaseInsensitive = true,
WriteIndented = true
};
var resultObj = JsonSerializer.Deserialize<FortranRequest>(result, options);
// 返回新的格式
var response = new ApiResponse<FortranRequest>
{
Message = "Success",
Success = true,
Data = new ApiResponseData<FortranRequest>
{
Value = resultObj
}
};
return Ok(response);
}
catch (Exception ex)
{
_logger.LogError(ex, "处理Fortran请求时发生错误");
return StatusCode(500, new
{
message = ex.Message,
success = false,
data = (object)null
});
}
}
}
}

88
Dockerfile Normal file
View File

@ -0,0 +1,88 @@
# ===== 第一阶段：构建阶段 =====
FROM mcr.microsoft.com/dotnet/sdk:8.0 AS build
# 配置 NuGet 使用国内镜像源
RUN dotnet nuget add source https://mirrors.cloud.tencent.com/nuget/ \
&& dotnet nuget disable source nuget.org
# 配置 apt-get 使用 apt-cacher-ng 作为代理
RUN echo 'Acquire::http::Proxy "http://192.168.1.140:3142";' > /etc/apt/apt.conf.d/01proxy
# 创建并配置 Debian 镜像源
RUN echo "deb https://mirrors.ustc.edu.cn/debian/ bookworm main contrib non-free non-free-firmware" > /etc/apt/sources.list && \
echo "deb https://mirrors.ustc.edu.cn/debian/ bookworm-updates main contrib non-free non-free-firmware" >> /etc/apt/sources.list && \
echo "deb https://mirrors.ustc.edu.cn/debian-security bookworm-security main contrib non-free non-free-firmware" >> /etc/apt/sources.list
# 允许使用不安全的软件源
RUN echo 'Acquire::AllowInsecureRepositories "true";' > /etc/apt/apt.conf.d/99allow-insecure && \
echo 'Acquire::AllowDowngradeToInsecureRepositories "true";' >> /etc/apt/apt.conf.d/99allow-insecure
WORKDIR /src
# 安装 Fortran 编译器
RUN apt-get update && apt-get install -y --no-install-recommends \
gfortran \
&& rm -rf /var/lib/apt/lists/*
# 复制 Fortran 源文件并编译
COPY Fortran/*.f90 /src/Fortran/
WORKDIR /src/Fortran
# 编译所有 .f90 文件为 .o 文件
RUN for file in *.f90; do gfortran -fPIC -c "$file" -o "${file%.f90}.o"; done
# 链接所有 .o 文件为共享库
RUN gfortran -shared *.o -o libXAJMX.so
# 回到主工作目录
WORKDIR /src
# 只复制项目文件
COPY ["FortranWebApi.csproj", "./"]
RUN dotnet restore
# 复制源代码
COPY . .
# 合并 build 和 publish 命令
RUN dotnet publish -c Release -o /app/publish
# 复制编译好的 .so 文件到发布目录
RUN mkdir -p /app/publish && \
cp /src/Fortran/libXAJMX.so /app/publish/
# ===== 第二阶段：运行阶段 =====
FROM mcr.microsoft.com/dotnet/aspnet:8.0
# 配置 apt-get 使用 apt-cacher-ng 作为代理
RUN echo 'Acquire::http::Proxy "http://192.168.1.140:3142";' > /etc/apt/apt.conf.d/01proxy
# 创建并配置 Debian 镜像源
RUN echo "deb https://mirrors.ustc.edu.cn/debian/ bookworm main contrib non-free non-free-firmware" > /etc/apt/sources.list && \
echo "deb https://mirrors.ustc.edu.cn/debian/ bookworm-updates main contrib non-free non-free-firmware" >> /etc/apt/sources.list && \
echo "deb https://mirrors.ustc.edu.cn/debian-security bookworm-security main contrib non-free non-free-firmware" >> /etc/apt/sources.list
# 允许使用不安全的软件源
RUN echo 'Acquire::AllowInsecureRepositories "true";' > /etc/apt/apt.conf.d/99allow-insecure && \
echo 'Acquire::AllowDowngradeToInsecureRepositories "true";' >> /etc/apt/apt.conf.d/99allow-insecure
# 安装运行时依赖
RUN apt-get update && apt-get install -y --no-install-recommends \
libc6-dev \
libgfortran5 \
&& rm -rf /var/lib/apt/lists/*
WORKDIR /app
COPY --from=build /app/publish .
# 确保 .so 文件的权限正确
RUN chmod 755 /app/libXAJMX.so
# 设置 LD_LIBRARY_PATH
ENV LD_LIBRARY_PATH=/app
# 设置端口和监听地址
ENV ASPNETCORE_URLS=http://+:5000
EXPOSE 5000
ENTRYPOINT ["dotnet", "FortranWebApi.dll"]

120
Fortran/1.json Normal file
View File

@ -0,0 +1,120 @@
{
"fortranSourceFile": "D:\\\u5DE5\u4F5C2025\\\u7B97\u6CD5\u5E73\u53F0\\dll\\\u65B0\u5B89\u6C5F\u6A21\u578B\\XAJMX\\XAJMX\\XAJMX.f90",
"fortranFunctionName": "XAJMX",
"projectName": "FortranWebApi",
"outputDirectory": "D:\\\u5DE5\u4F5C2025\\\u7B97\u6CD5\u5E73\u53F0\\\u8F93\u51FA\u5E93\\\u65B0\u5B89\u6C5F\u6A21\u578B",
"parameters": [
{
"name": "N",
"dataType": "Integer",
"arrayType": "Scalar",
"direction": "Input",
"description": "",
"isSelected": true
},
{
"name": "M",
"dataType": "Integer",
"arrayType": "Scalar",
"direction": "Input",
"description": "",
"isSelected": true
},
{
"name": "PAR",
"dataType": "Float",
"arrayType": "OneDimensional",
"direction": "Input",
"description": "",
"isSelected": true
},
{
"name": "AREA",
"dataType": "Float",
"arrayType": "Scalar",
"direction": "Input",
"description": "",
"isSelected": true
},
{
"name": "UH",
"dataType": "Float",
"arrayType": "OneDimensional",
"direction": "Input",
"description": "",
"isSelected": true
},
{
"name": "DT",
"dataType": "Float",
"arrayType": "Scalar",
"direction": "Input",
"description": "",
"isSelected": true
},
{
"name": "P",
"dataType": "Float",
"arrayType": "OneDimensional",
"direction": "Input",
"description": "",
"isSelected": true
},
{
"name": "EP",
"dataType": "Float",
"arrayType": "OneDimensional",
"direction": "Input",
"description": "",
"isSelected": true
},
{
"name": "W",
"dataType": "Float",
"arrayType": "OneDimensional",
"direction": "Input",
"description": "",
"isSelected": true
},
{
"name": "FR",
"dataType": "Float",
"arrayType": "Scalar",
"direction": "Input",
"description": "",
"isSelected": true
},
{
"name": "S",
"dataType": "Float",
"arrayType": "Scalar",
"direction": "Input",
"description": "",
"isSelected": true
},
{
"name": "QRSS0",
"dataType": "Float",
"arrayType": "Scalar",
"direction": "Input",
"description": "",
"isSelected": true
},
{
"name": "QRG0",
"dataType": "Float",
"arrayType": "Scalar",
"direction": "Input",
"description": "",
"isSelected": true
},
{
"name": "QR",
"dataType": "Float",
"arrayType": "OneDimensional",
"direction": "Output",
"description": "",
"isSelected": true
}
]
}

BIN
Fortran/1.xlsx Normal file
View File

Binary file not shown.

332
Fortran/SUB_XAJMX.f90 Normal file
View File

@ -0,0 +1,332 @@
SUBROUTINE SUB_XAJMX( N ,& ! 单元出流数组大小 //输入变量
M ,& ! 无因次单位数组大小 //输入变量
PAR ,& ! //输入变量
AREA ,& ! 单元面积 //输入变量
UH ,& ! 无因次单位线 //输入变量
DT ,& ! 时段步长 //输入变量
P ,& ! 降雨系列 //输入变量
EP ,& ! 蒸发皿蒸发能力 //输入变量
W ,& ! 土壤含水层 1.上层 2.下层 3.深层 //输入变量
FR ,& ! 初始产流面积 //输入变量
S ,& ! 初始自由水深 //输入变量
QRSS0 ,& ! 初始壤中流流量 //输入变量
QRG0 ,& ! 初始地下水径流量 //输入变量
QR ) ! 单元出流 //输出变量
IMPLICIT NONE
!///////////////////////////////////////变量声明//////////////////////////////////////////////
INTEGER::N !
INTEGER::M !
REAL::PAR(13) ! 1.上层张力水容量wum 2.下层张力水容量wl 3.深层张力水容量wdm
! 4.蒸发能力折算系数KC.深层蒸发系数c 6.张力水蓄水容量系数b
! 7.不透水面积比率imp1 8.自由水蓄水容量sm 9.自由水蓄水容量指数ex
!10.地下水出流系数kg 11.壤中流出流系数kss 12.地下水出流系数kkg
!13.壤中流出流系数kkss
REAL::AREA ! 单元面积
REAL::UH(M) ! 无因次单位线
REAL::DT ! 时段步长
REAL::P(N) ! 降雨系列
REAL::EP(N) ! 蒸发皿蒸发能力
REAL::QR(N) ! 单元出流
REAL::W(3) ! 土壤含水层 1.上层 2.下层 3.深层
REAL::FR ! 初始产流面积
REAL::S ! 初始自由水深
REAL::QRSS0 ! 初始壤中流流量
REAL::QRG0 ! 初始地下水径流量
INTEGER::D
REAL::KSSD
REAL::KGD
REAL::E(3)
REAL::WM(3)
REAL::KC ! 蒸发能力折算系数
REAL::C ! 深层蒸发系数
REAL::B ! 张力水蓄水容量系数
REAL::IMP1 ! 不透水面积比率
REAL::SM ! 自由水蓄水容量
REAL::EX ! 自由水蓄水容量指数
REAL::KG ! 地下水出流系数
REAL::KSS ! 壤中流出流系数
REAL::KKG ! 地下水出流系数
REAL::KKSS ! 壤中流出流系数
!以下变量是原vb程序中未声明的变量
INTEGER::I ! 计数器 //临时变量
INTEGER::J ! 计数器 //临时变量
INTEGER::ICHECK ! 判断计算时段长度是否合适的识别码
INTEGER::NN
REAL(KIND=8),PARAMETER::C5=5.000000000
REAL::U
REAL::CI
REAL::CG
REAL::WM0
REAL::W0
REAL::PE
REAL::R
REAL::RIMP
REAL::WMM
REAL::A
REAL::X
REAL::RS
REAL::RSS
REAL::RGD
REAL::RG
REAL::SS
REAL::Q
REAL::KSSDD
REAL::KGDD
REAL::SMM
REAL::SMMF
REAL::SMF
REAL::AU
REAL::RSD
REAL::RSSD
REAL::QRS
REAL::QRSS
REAL::QRG
REAL::QTR
!///////////////////////////////////////变量声明//////////////////////////////////////////////
!///////////////////////////////////////计算区域//////////////////////////////////////////////
! 赋值
ICHECK = 1
DO I = 1, 3
WM(I) = PAR(I)
END DO
KC = PAR(4)
C = PAR(5)
B = PAR(6)
IMP1 = PAR(7)
SM = PAR(8)
EX = PAR(9)
KG = PAR(10)
KSS = PAR(11)
KKG = PAR(12)
KKSS = PAR(13)
DO I = 1, N
QR(I) = 0.0
END DO
U = AREA / 3.6 / DT
IF( DT.LE.24.0 )THEN
D = 24 / DT
CI = KKSS ** (1.0 / D)
CG = KKG ** (1.0 / D)
KSSD = (1.0 - (1.0 - (KG + KSS)) ** (1.0 / D)) / (1.0 + KG / KSS)
KGD = KSSD * KG / KSS
ELSE
ICHECK = 0
END IF
DO I = 1 , N
IF (EP(I) .LT. 0.0)THEN
EP(I) = 0.0
END IF
IF (P(I) .LT. 0.0)THEN
P(I) = 0.0
END IF
EP(I) = EP(I) * KC
WM0 = WM(1) + WM(2) + WM(3)
W0 = W(1) + W(2) + W(3)
PE = P(I) - EP(I)
! 赋初值
R = 0.0
RIMP = 0.0
IF(PE.GT.0.0)THEN
WMM = (1.0 + B) * WM0 / (1.0 - IMP1)
IF ((WM0 - W0).LE.0.0001)THEN
A = WMM
ELSE
A = WMM * (1.0 - (1.0 - W0 / WM0) ** (1.0 / (1.0 + B)))
END IF
IF ((PE + A) .LT. WMM) THEN
R = PE - WM0 + W0 + WM0 * ((1.0 - (PE + A) / WMM) ** (1.0 + B))
ELSE
R = PE - (WM0 - W0)
END IF
RIMP = PE * IMP1
END IF
IF ((W(1) + P(I)) .GT. EP(I)) THEN
E(1) = EP(I)
E(2) = 0.0
E(3) = 0.0
ELSE
E(1) = W(1) + P(I)
E(2) = (EP(I) - E(1)) * W(2) / WM(2)
IF (W(2) .LE.( C * WM(2))) THEN
E(2) = C * (EP(I) - E(1))
E(3) = 0.0
IF (W(2) .GE. (C * (EP(I) - E(1)))) THEN
E(2) = C * (EP(I) - E(1))
E(3) = 0.0
ELSE
E(2) = W(2)
E(3) = C * (EP(I) - E(1) - E(2))
END IF
END IF
END IF
W(1) = W(1) + P(I) - R - E(1)
W(2) = W(2) - E(2)
W(3) = W(3) - E(3)
IF (W(1) .GT. WM(1)) THEN
W(2) = W(1) - WM(1) + W(2)
W(1) = WM(1)
IF (W(2) .GT. WM(2)) THEN
W(3) = W(3) + W(2) - WM(2)
W(2) = WM(2)
END IF
END IF
X = FR
IF (PE .LE.0.0) THEN
RS = 0.0
RSS = S * KSSD * FR
RGD = S * FR * KGD
S = S - (RSS + RG) / FR
ELSE
FR = R / PE
S = X * S / FR
SS = S
Q = R / FR
NN = INT(Q / C5) + 1 ! 在vb程序中C5是双精度常数5
Q = Q / NN
KSSDD = (1.0 - (1.0 - (KGD + KSSD)) ** (1.0 / NN)) / (1.0 + KGD / KSSD)
KGDD = KSSDD * KGD / KSSD
RS = 0.0
RSS = 0.0
RG = 0.0
SMM = (1 + EX) * SM
IF (EX .LT. 0.001) THEN
SMMF = SMM
ELSE
SMMF = SMM * (1.0 - (1.0 - FR) ** (1.0 / EX))
END IF
SMF = SMMF / (1.0 + EX)
DO J = 1 , NN
IF (S .GT. SMF) THEN
S = SMF
END IF
AU = SMMF * (1.0 - (1.0 - S / SMF) ** (1.0 / (1.0 + EX)))
IF ((Q + AU) .LE. 0.0) THEN
RSD = 0.0
RSSD = 0.0
RGD = 0.0
S = 0.0
ELSE IF ((Q + AU) .GE. SMMF) THEN
RSD = (Q + S - SMF) * FR
RSSD = SMF * KSSDD * FR
RGD = SMF * FR * KGDD
S = SMF - (KSSD + KGD) / FR
ELSE IF ((Q + AU) .LT. SMMF) THEN
RSD = (Q - SMF + S + SMF * (1.0 - (Q + AU) / SMMF) ** (1.0 + EX)) * FR
RSSD = (S + Q - RSD / FR) * KSSDD * FR
RGD = (S + Q - RSD / FR) * KGDD * FR
S = S + Q - (RSD + RSSD + RGD) / FR
END IF
RS = RS + RSD
RSS = RSS + RSSD
RG = RG + RGD
END DO
END IF
RS = RS * (1.0 - IMP1)
RSS = RSS * (1.0 - IMP1)
RG = RG * (1.0 - IMP1)
QRS = (RS + RIMP) * U
QRSS = QRSS0 * CI + RSS * (1.0 - CI) * U
QRG = QRG0 * CG + RG * (1.0 - CG) * U
QTR = QRS + QRSS + QRG
DO J = 1 , M
IF ((I + J - 1) .LE. N) THEN
QR(I + J - 1) = QR(I + J - 1) + QTR * UH(J)
END IF
END DO
QRSS0 = QRSS
QRG0 = QRG
END DO
END SUBROUTINE SUB_XAJMX

63
Fortran/XAJMX.f90 Normal file
View File

@ -0,0 +1,63 @@
subroutine XAJMX( N ,&
M ,&
PAR ,&
AREA ,&
UH ,&
DT ,&
P ,&
EP ,&
W ,&
FR ,&
S ,&
QRSS0 ,&
QRG0 ,&
QR )
!DEC$ ATTRIBUTES DLLEXPORT::XAJMX
IMPLICIT NONE
INTEGER::N ! 单元出流数组大小
INTEGER::M ! 无因次单位数组大小
REAL::PAR(13) ! 1.上层张力水容量wum 2.下层张力水容量wl 3.深层张力水容量wdm
! 4.蒸发能力折算系数kc 5.深层蒸发系数c 6.张力水蓄水容量系数b
! 7.不透水面积比率imp1 8.自由水蓄水容量sm 9.自由水蓄水容量指数ex
!10.地下水出流系数kg 11.壤中流出流系数kss 12.地下水出流系数kkg
!13.壤中流出流系数kkss
REAL::AREA ! 单元面积
REAL::UH(M) ! 无因次单位线
REAL::DT ! 时段步长
REAL::P(N) ! 降雨系列
REAL::EP(N) ! 蒸发皿蒸发能力
REAL::QR(N) ! 单元出流
REAL::W(3) ! 土壤含水层 1.上层 2.下层 3.深层
REAL::FR ! 初始产流面积
REAL::S ! 初始自由水深
REAL::QRSS0 ! 初始壤中流流量
REAL::QRG0 ! 初始地下水径流量
INTEGER::I
INTEGER::YEAR1
INTEGER::IM
INTEGER::ID
INTEGER::IH
INTEGER::EM1
INTEGER::ED
INTEGER::EH
CALL SUB_XAJMX( N ,& ! 单元出流数组大小 //输入变量
M ,& ! 无因次单位数组大小 //输入变量
PAR ,& ! //输入变量
AREA ,& ! 单元面积 //输入变量
UH ,& ! 无因次单位线 //输入变量
DT ,& ! 时段步长 //输入变量
P ,& ! 降雨系列 //输入变量
EP ,& ! 蒸发皿蒸发能力 //输入变量
W ,& ! 土壤含水层 1.上层 2.下层 3.深层 //输入变量
FR ,& ! 初始产流面积 //输入变量
S ,& ! 初始自由水深 //输入变量
QRSS0 ,& ! 初始壤中流流量 //输入变量
QRG0 ,& ! 初始地下水径流量 //输入变量
QR ) ! 单元出流 //输出变量
end subroutine XAJMX

27
FortranWebApi.csproj Normal file
View File

@ -0,0 +1,27 @@
<Project Sdk="Microsoft.NET.Sdk.Web">
<PropertyGroup>
<TargetFramework>net8.0</TargetFramework>
<Nullable>enable</Nullable>
<ImplicitUsings>enable</ImplicitUsings>
<InvariantGlobalization>true</InvariantGlobalization>
</PropertyGroup>
<ItemGroup>
<PackageReference Include="Microsoft.AspNetCore.OpenApi" Version="8.0.0" />
<PackageReference Include="Swashbuckle.AspNetCore" Version="6.4.0" />
<PackageReference Include="Serilog" Version="4.2.0" />
<PackageReference Include="Serilog.AspNetCore" Version="8.0.1" />
<PackageReference Include="Serilog.Extensions.Logging" Version="8.0.0" />
<PackageReference Include="Serilog.Sinks.Console" Version="5.0.1" />
<PackageReference Include="Serilog.Sinks.File" Version="5.0.0" />
<PackageReference Include="Microsoft.Extensions.Logging" Version="8.0.0" />
</ItemGroup>
<ItemGroup>
<None Update="lib{{FortranFunctionName}}.so">
<CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
</None>
</ItemGroup>
</Project>

23
HttpRequests/fortranwebapi.http Normal file
View File

@ -0,0 +1,23 @@
@FortranWebApi_HostAddress = http://localhost:5000
### 测试Fortran请求
POST {{FortranWebApi_HostAddress}}/FortranCalculate
Content-Type: application/json
{
"text": "{\"FuncName\":\"calculate_main\",\"ClassName\":\"\",\"Par\":[ {"Name":"N","DataType":"0","ArrayType":"0","IsOut":"2","Data":0},
{"Name":"M","DataType":"0","ArrayType":"0","IsOut":"2","Data":0},
{"Name":"PAR","DataType":"1","ArrayType":"1","IsOut":"2","Data":[]},
{"Name":"AREA","DataType":"1","ArrayType":"0","IsOut":"2","Data":0},
{"Name":"UH","DataType":"1","ArrayType":"1","IsOut":"2","Data":[]},
{"Name":"DT","DataType":"1","ArrayType":"0","IsOut":"2","Data":0},
{"Name":"P","DataType":"1","ArrayType":"1","IsOut":"2","Data":[]},
{"Name":"EP","DataType":"1","ArrayType":"1","IsOut":"2","Data":[]},
{"Name":"W","DataType":"1","ArrayType":"1","IsOut":"2","Data":[]},
{"Name":"FR","DataType":"1","ArrayType":"0","IsOut":"2","Data":0},
{"Name":"S","DataType":"1","ArrayType":"0","IsOut":"2","Data":0},
{"Name":"QRSS0","DataType":"1","ArrayType":"0","IsOut":"2","Data":0},
{"Name":"QRG0","DataType":"1","ArrayType":"0","IsOut":"2","Data":0},
{"Name":"QR","DataType":"1","ArrayType":"1","IsOut":"1","Data":[]}]}"
}

31
Models/ApiResponse.cs Normal file
View File

@ -0,0 +1,31 @@
using System.Text.Json.Serialization;
namespace FortranWebApi.Models
{
public class ApiResponse<T>
{
[JsonPropertyName("message")]
public string Message { get; set; } = "Success";
[JsonPropertyName("success")]
public bool Success { get; set; } = true;
[JsonPropertyName("data")]
public ApiResponseData<T>? Data { get; set; }
}
public class ApiResponseData<T>
{
[JsonPropertyName("contentType")]
public string? ContentType { get; set; }
[JsonPropertyName("serializerSettings")]
public object? SerializerSettings { get; set; }
[JsonPropertyName("statusCode")]
public int? StatusCode { get; set; }
[JsonPropertyName("value")]
public T? Value { get; set; }
}
}

22
Models/FortranParameter.cs Normal file
View File

@ -0,0 +1,22 @@
using System.Text.Json.Serialization;
namespace FortranWebApi.Models
{
public class FortranParameter
{
[JsonPropertyName("name")]
public string Name { get; set; } = string.Empty;
[JsonPropertyName("dataType")]
public string DataType { get; set; } = "0";
[JsonPropertyName("arrayType")]
public string ArrayType { get; set; } = "0";
[JsonPropertyName("isOut")]
public string IsOut { get; set; } = "2";
[JsonPropertyName("data")]
public object? Data { get; set; }
}
}

13
Models/FortranRequest.cs Normal file
View File

@ -0,0 +1,13 @@
using System.Text.Json.Serialization;
namespace FortranWebApi.Models
{
public class FortranRequest
{
public string FuncName { get; set; } = string.Empty;
public string ClassName { get; set; } = string.Empty;
[JsonPropertyName("par")]
public List<FortranParameter> Parameters { get; set; } = new List<FortranParameter>();
}
}

7
Models/FortranRequestWrapper.cs Normal file
View File

@ -0,0 +1,7 @@
namespace FortranWebApi.Models
{
public class FortranRequestWrapper
{
public string Text { get; set; } = string.Empty;
}
}

80
Program.cs Normal file
View File

@ -0,0 +1,80 @@
using Serilog;
using FortranWebApi.Services;
using System.IO;
using System.Text.Json;
using System.Text.Json.Serialization;
// 设置库搜索路径
string currentDir = Directory.GetCurrentDirectory();
Environment.SetEnvironmentVariable("LD_LIBRARY_PATH",
$"{Environment.GetEnvironmentVariable("LD_LIBRARY_PATH")}:{currentDir}");
var builder = WebApplication.CreateBuilder(args);
// 添加健康检查服务
builder.Services.AddHealthChecks();
// 配置Serilog
Log.Logger = new LoggerConfiguration()
.WriteTo.Console(outputTemplate:
"{Timestamp:yyyy-MM-dd HH:mm:ss.fff zzz} [{Level:u3}] {Message:lj}{NewLine}{Exception}")
.WriteTo.File("logs/log-.txt",
rollingInterval: RollingInterval.Day,
outputTemplate:
"{Timestamp:yyyy-MM-dd HH:mm:ss.fff zzz} [{Level:u3}] {Message:lj}{NewLine}{Exception}")
.CreateLogger();
builder.Host.UseSerilog(); // 将Serilog添加到Host
// 配置JSON序列化选项，使用驼峰命名法
builder.Services.AddControllers().AddJsonOptions(options =>
{
options.JsonSerializerOptions.PropertyNamingPolicy = JsonNamingPolicy.CamelCase;
options.JsonSerializerOptions.DictionaryKeyPolicy = JsonNamingPolicy.CamelCase;
options.JsonSerializerOptions.DefaultIgnoreCondition = JsonIgnoreCondition.WhenWritingNull;
options.JsonSerializerOptions.PropertyNameCaseInsensitive = true;
});
builder.Services.AddEndpointsApiExplorer();
builder.Services.AddSwaggerGen();
builder.Services.AddSingleton<FortranInteropService>();
// 配置CORS
builder.Services.AddCors(options =>
{
options.AddDefaultPolicy(policy =>
{
policy.AllowAnyOrigin()
.AllowAnyMethod()
.AllowAnyHeader();
});
});
var app = builder.Build();
// Configure the HTTP request pipeline.
if (app.Environment.IsDevelopment())
{
app.UseSwagger();
app.UseSwaggerUI();
}
app.UseCors();
app.UseAuthorization();
// 映射健康检查端点
app.MapHealthChecks("/health");
app.MapControllers();
try
{
Log.Information("启动应用程序...");
app.Run();
}
catch (Exception ex)
{
Log.Fatal(ex, "应用程序启动失败");
}
finally
{
Log.CloseAndFlush();
}

14
Properties/launchSettings.json Normal file
View File

@ -0,0 +1,14 @@
{
"profiles": {
"FortranWebApi": {
"commandName": "Project",
"launchBrowser": true,
"launchUrl": "swagger",
"environmentVariables": {
"ASPNETCORE_ENVIRONMENT": "Development"
},
"dotnetRunMessages": true,
"applicationUrl": "http://0.0.0.0:5000"
}
}
}

533
Services/FortranInteropService.cs Normal file
View File

@ -0,0 +1,533 @@
using System.Runtime.InteropServices;
using FortranWebApi.Models;
using System.Text.Json;
using System.Runtime.InteropServices.Marshalling;
using System.IO;
namespace FortranWebApi.Services
{
public class FortranInteropService
{
// 静态构造函数设置DLL导入解析器
static FortranInteropService()
{
// 添加当前目录到库搜索路径
NativeLibrary.SetDllImportResolver(typeof(FortranInteropService).Assembly, (name, assembly, path) =>
{
if (name == "libXAJMX.so")
{
// 尝试从当前目录加载
string currentDir = Directory.GetCurrentDirectory();
string libraryPath = Path.Combine(currentDir, "libXAJMX.so");
if (File.Exists(libraryPath))
{
return NativeLibrary.Load(libraryPath);
}
}
// 回退到默认加载行为
return IntPtr.Zero;
});
}
// DllImport声明
[DllImport("libXAJMX.so", CallingConvention = CallingConvention.Cdecl, EntryPoint = "XAJMX")]
private static extern void XAJMX(
ref int N,
ref int M,
float[] PAR,
ref float AREA,
float[] UH,
ref float DT,
float[] P,
float[] EP,
float[] W,
ref float FR,
ref float S,
ref float QRSS0,
ref float QRG0,
float[] QR
);
public string ProcessFortranRequest(string requestText)
{
try
{
// 解析请求
var options = new JsonSerializerOptions
{
PropertyNamingPolicy = JsonNamingPolicy.CamelCase,
DictionaryKeyPolicy = JsonNamingPolicy.CamelCase,
PropertyNameCaseInsensitive = true,
WriteIndented = true
};
var request = JsonSerializer.Deserialize<FortranRequest>(requestText, options);
if (request == null)
{
throw new ArgumentException("无效的请求格式");
}
// 准备输入参数
var parameters = request.Parameters;
// 提取参数
int N = GetIntParameter(parameters, "N");
int M = GetIntParameter(parameters, "M");
float[] PAR = GetFloatArrayParameter(parameters, "PAR");
float AREA = GetFloatParameter(parameters, "AREA");
float[] UH = GetFloatArrayParameter(parameters, "UH");
float DT = GetFloatParameter(parameters, "DT");
float[] P = GetFloatArrayParameter(parameters, "P");
float[] EP = GetFloatArrayParameter(parameters, "EP");
float[] W = GetFloatArrayParameter(parameters, "W");
float FR = GetFloatParameter(parameters, "FR");
float S = GetFloatParameter(parameters, "S");
float QRSS0 = GetFloatParameter(parameters, "QRSS0");
float QRG0 = GetFloatParameter(parameters, "QRG0");
// 准备数组参数
float[] QR = new float[10000]; // 输出数组，初始大小为10000
// 调用Fortran函数
XAJMX(
ref N,
ref M,
PAR,
ref AREA,
UH,
ref DT,
P,
EP,
W,
ref FR,
ref S,
ref QRSS0,
ref QRG0,
QR
);
// 更新输出参数
UpdateArrayParameter(parameters, "QR", QR);
// 处理输出数组
// 处理输出数组 QR
// 注意：没有找到明确的长度参数，使用非零元素数量
{
int nonZeroCount = 0;
for (int i = 0; i < QR.Length; i++)
{
if (QR[i] != 0) nonZeroCount = i + 1;
}
if (nonZeroCount > 0)
{
float[] resultArray = new float[nonZeroCount];
Array.Copy(QR, resultArray, nonZeroCount);
UpdateArrayParameter(parameters, "QR", resultArray);
}
}
// 返回结果 - 只返回原始请求的结构，但包含更新后的参数
var result = new FortranRequest
{
FuncName = request.FuncName,
ClassName = request.ClassName,
Parameters = parameters
};
return JsonSerializer.Serialize(result, options);
}
catch (Exception ex)
{
return JsonSerializer.Serialize(new { error = ex.Message });
}
}
private float GetFloatParameter(List<FortranParameter> parameters, string name)
{
var param = parameters.FirstOrDefault(p => p.Name == name);
if (param == null || param.Data == null)
{
return 0.0f;
}
if (param.Data is JsonElement element)
{
if (element.ValueKind == JsonValueKind.Number)
{
return element.GetSingle();
}
}
return Convert.ToSingle(param.Data);
}
private double GetDoubleParameter(List<FortranParameter> parameters, string name)
{
var param = parameters.FirstOrDefault(p => p.Name == name);
if (param == null || param.Data == null)
{
return 0.0;
}
if (param.Data is JsonElement element)
{
if (element.ValueKind == JsonValueKind.Number)
{
return element.GetSingle();
}
}
return Convert.ToDouble(param.Data);
}
private int GetIntParameter(List<FortranParameter> parameters, string name)
{
var param = parameters.FirstOrDefault(p => p.Name == name);
if (param == null || param.Data == null)
{
return 0;
}
if (param.Data is JsonElement element)
{
if (element.ValueKind == JsonValueKind.Number)
{
return element.GetInt32();
}
}
return Convert.ToInt32(param.Data);
}
private int[] GetIntArrayParameter(List<FortranParameter> parameters, string name)
{
var param = parameters.FirstOrDefault(p => p.Name == name);
if (param == null || param.Data == null)
{
return Array.Empty<int>();
}
if (param.Data is JsonElement element && element.ValueKind == JsonValueKind.Array)
{
var array = new List<int>();
foreach (var item in element.EnumerateArray())
{
if (item.ValueKind == JsonValueKind.Number)
{
array.Add(item.GetInt32());
}
}
return array.ToArray();
}
if (param.Data is System.Collections.IEnumerable enumerable && !(param.Data is string))
{
var array = new List<int>();
foreach (var item in enumerable)
{
array.Add(Convert.ToInt32(item));
}
return array.ToArray();
}
return Array.Empty<int>();
}
private float[] GetFloatArrayParameter(List<FortranParameter> parameters, string name)
{
var param = parameters.FirstOrDefault(p => p.Name == name);
if (param == null || param.Data == null)
{
return Array.Empty<float>();
}
if (param.Data is JsonElement element && element.ValueKind == JsonValueKind.Array)
{
var array = new List<float>();
foreach (var item in element.EnumerateArray())
{
if (item.ValueKind == JsonValueKind.Number)
{
array.Add(item.GetSingle());
}
}
return array.ToArray();
}
if (param.Data is System.Collections.IEnumerable enumerable && !(param.Data is string))
{
var array = new List<float>();
foreach (var item in enumerable)
{
array.Add(Convert.ToSingle(item));
}
return array.ToArray();
}
return Array.Empty<float>();
}
private double[] GetDoubleArrayParameter(List<FortranParameter> parameters, string name)
{
var param = parameters.FirstOrDefault(p => p.Name == name);
if (param == null || param.Data == null)
{
return Array.Empty<double>();
}
if (param.Data is JsonElement element && element.ValueKind == JsonValueKind.Array)
{
var array = new List<double>();
foreach (var item in element.EnumerateArray())
{
if (item.ValueKind == JsonValueKind.Number)
{
array.Add(item.GetSingle());
}
}
return array.ToArray();
}
if (param.Data is System.Collections.IEnumerable enumerable && !(param.Data is string))
{
var array = new List<double>();
foreach (var item in enumerable)
{
array.Add(Convert.ToSingle(item));
}
return array.ToArray();
}
return Array.Empty<double>();
}
private void UpdateParameter(List<FortranParameter> parameters, string name, object value)
{
var param = parameters.FirstOrDefault(p => p.Name == name);
if (param != null)
{
param.Data = value;
}
}
private void UpdateArrayParameter(List<FortranParameter> parameters, string name, float[] value)
{
var param = parameters.FirstOrDefault(p => p.Name == name);
if (param != null)
{
param.Data = value;
}
}
private void UpdateDoubleArrayParameter(List<FortranParameter> parameters, string name, double[] value)
{
var param = parameters.FirstOrDefault(p => p.Name == name);
if (param != null)
{
param.Data = value;
}
}
private void UpdateIntArrayParameter(List<FortranParameter> parameters, string name, int[] value)
{
var param = parameters.FirstOrDefault(p => p.Name == name);
if (param != null)
{
param.Data = value;
}
}
// 添加新的辅助方法来处理二维数组
private double[,] GetDouble2DArrayParameter(List<FortranParameter> parameters, string name, int rows, int cols)
{
var param = parameters.FirstOrDefault(p => p.Name == name);
if (param == null || param.Data == null)
{
return new double[rows, cols];
}
double[,] result = new double[rows, cols];
if (param.Data is JsonElement element && element.ValueKind == JsonValueKind.Array)
{
int index = 0;
foreach (var item in element.EnumerateArray())
{
if (item.ValueKind == JsonValueKind.Number)
{
int row = index / cols;
int col = index % cols;
if (row < rows && col < cols)
{
result[row, col] = item.GetDouble();
}
index++;
}
}
}
else if (param.Data is System.Collections.IEnumerable enumerable && !(param.Data is string))
{
int index = 0;
foreach (var item in enumerable)
{
int row = index / cols;
int col = index % cols;
if (row < rows && col < cols)
{
result[row, col] = Convert.ToDouble(item);
}
index++;
}
}
return result;
}
// 添加更新二维数组参数的方法
private void UpdateDouble2DArrayParameter(List<FortranParameter> parameters, string name, double[,] value)
{
var param = parameters.FirstOrDefault(p => p.Name == name);
if (param != null)
{
// 将二维数组转换为一维数组以便于JSON序列化
int rows = value.GetLength(0);
int cols = value.GetLength(1);
double[] flatArray = new double[rows * cols];
for (int i = 0; i < rows; i++)
{
for (int j = 0; j < cols; j++)
{
flatArray[i * cols + j] = value[i, j];
}
}
param.Data = flatArray;
}
}
// float版本
private float[,] GetFloat2DArrayParameter(List<FortranParameter> parameters, string name, int rows, int cols)
{
var param = parameters.FirstOrDefault(p => p.Name == name);
if (param == null || param.Data == null)
{
return new float[rows, cols];
}
float[,] result = new float[rows, cols];
if (param.Data is JsonElement element && element.ValueKind == JsonValueKind.Array)
{
int index = 0;
foreach (var item in element.EnumerateArray())
{
if (item.ValueKind == JsonValueKind.Number)
{
int row = index / cols;
int col = index % cols;
if (row < rows && col < cols)
{
result[row, col] = item.GetSingle();
}
index++;
}
}
}
else if (param.Data is System.Collections.IEnumerable enumerable && !(param.Data is string))
{
int index = 0;
foreach (var item in enumerable)
{
int row = index / cols;
int col = index % cols;
if (row < rows && col < cols)
{
result[row, col] = Convert.ToSingle(item);
}
index++;
}
}
return result;
}
private void UpdateFloat2DArrayParameter(List<FortranParameter> parameters, string name, float[,] value)
{
var param = parameters.FirstOrDefault(p => p.Name == name);
if (param != null)
{
int rows = value.GetLength(0);
int cols = value.GetLength(1);
float[] flatArray = new float[rows * cols];
for (int i = 0; i < rows; i++)
{
for (int j = 0; j < cols; j++)
{
flatArray[i * cols + j] = value[i, j];
}
}
param.Data = flatArray;
}
}
// int版本
private int[,] GetInt2DArrayParameter(List<FortranParameter> parameters, string name, int rows, int cols)
{
var param = parameters.FirstOrDefault(p => p.Name == name);
if (param == null || param.Data == null)
{
return new int[rows, cols];
}
int[,] result = new int[rows, cols];
if (param.Data is JsonElement element && element.ValueKind == JsonValueKind.Array)
{
int index = 0;
foreach (var item in element.EnumerateArray())
{
if (item.ValueKind == JsonValueKind.Number)
{
int row = index / cols;
int col = index % cols;
if (row < rows && col < cols)
{
result[row, col] = item.GetInt32();
}
index++;
}
}
}
else if (param.Data is System.Collections.IEnumerable enumerable && !(param.Data is string))
{
int index = 0;
foreach (var item in enumerable)
{
int row = index / cols;
int col = index % cols;
if (row < rows && col < cols)
{
result[row, col] = Convert.ToInt32(item);
}
index++;
}
}
return result;
}
private void UpdateInt2DArrayParameter(List<FortranParameter> parameters, string name, int[,] value)
{
var param = parameters.FirstOrDefault(p => p.Name == name);
if (param != null)
{
int rows = value.GetLength(0);
int cols = value.GetLength(1);
int[] flatArray = new int[rows * cols];
for (int i = 0; i < rows; i++)
{
for (int j = 0; j < cols; j++)
{
flatArray[i * cols + j] = value[i, j];
}
}
param.Data = flatArray;
}
}
}
}

16
appsettings.json Normal file
View File

@ -0,0 +1,16 @@
{
"Logging": {
"LogLevel": {
"Default": "Information",
"Microsoft.AspNetCore": "Warning"
}
},
"AllowedHosts": "*",
"Kestrel": {
"Endpoints": {
"Http": {
"Url": "http://0.0.0.0:5000"
}
}
}
}