1.04

1.04

.gitea/workflows/deploy.yml

@@ -1,9 +1,10 @@
+# 复制到 itfx 仓库 .gitea/workflows/deploy.yml
+# push master → prod；push test → test
 name: Build and Deploy
 
 on:
   push:
-    branches: [master, main]
+    branches: [master, test]
-  workflow_dispatch:
 
 env:
   CSPROJ: src/InterfaceForward.Api/InterfaceForward.Api.csproj
@@ -20,15 +21,47 @@ jobs:
       - name: Build and deploy
         run: |
           set -euxo pipefail
-          export KUBECONFIG=/etc/rancher/k3s/k3s.yaml
+          REF="${{ gitea.ref_name }}"
-          TAG="${{ gitea.sha }}"
+          case "$REF" in
-          IMG="${{ env.TCR_REGISTRY }}/${{ env.TCR_NAMESPACE }}/${{ env.IMAGE_NAME }}:${TAG}"
+            test)   TARGET=test ;;
+            master) TARGET=prod ;;
+            *)      echo "unsupported branch: $REF"; exit 1 ;;
+          esac
+
+          SHA="${{ gitea.sha }}"
           REPO="${{ gitea.repository }}"
-          REPO="${REPO:-${{ github.repository }}}"
           test -n "$REPO" && [[ "$REPO" == */* ]]
-          echo "REPO=$REPO TAG=$TAG host=$(hostname)"
+
+          case "$TARGET" in
+            test) TAG="test-${SHA}" ;;
+            *)    TAG="${SHA}" ;;
+          esac
+
+          IMG="${{ env.TCR_REGISTRY }}/${{ env.TCR_NAMESPACE }}/${{ env.IMAGE_NAME }}:${TAG}"
+          echo "TARGET=$TARGET REF=$REF REPO=$REPO TAG=$TAG host=$(hostname)"
+
+          export KUBECONFIG=/etc/rancher/k3s/k3s.yaml
+          unset NAMESPACE
           cd /data/k3s
           ./scripts/ci-publish-container.sh "$REPO" "${{ env.CSPROJ }}" \
-            "${{ env.IMAGE_NAME }}" "$TAG" "$TAG"
+            "${{ env.IMAGE_NAME }}" "$TAG" "$SHA"
+
+          case "$TARGET" in
+            test)
+              export KUBECONFIG=/etc/rancher/k3s/k3s-test.yaml
+              export NAMESPACE=test
+              export MANIFEST_ROOT=/data/k3s-test
+              ;;
+            *)
+              export KUBECONFIG=/etc/rancher/k3s/k3s.yaml
+              export NAMESPACE=prod
+              export MANIFEST_ROOT=/data/k3s
+              ;;
+          esac
+          if [[ ! -f "$KUBECONFIG" ]]; then
+            echo "FAIL: missing KUBECONFIG=$KUBECONFIG host=$(hostname) uid=$(id -u)"
+            ls -la /etc/rancher/k3s/ /root/.kube/ 2>/dev/null || true
+            exit 1
+          fi
           ./scripts/ci-deploy-api.sh "${{ env.DEPLOY_NAME }}" \
             "${{ env.CONTAINER_NAME }}" "$IMG"

src/InterfaceForward.Api/Program.cs

@@ -3,8 +3,9 @@ using Serilog;
 
 var builder = WebApplication.CreateSlimBuilder(args);
 var configuration = builder.Configuration;
-builder.Configuration.AddConsul("idwms/common", source => source.ReloadOnChange = true);
+var prefix = builder.Environment.EnvironmentName == "Development" ? "dev" : "idwms";
-builder.Configuration.AddConsul("idwms/itfxapi", source => source.ReloadOnChange = true);
+builder.Configuration.AddConsul($"{prefix}/common", source => source.ReloadOnChange = true);
+builder.Configuration.AddConsul($"{prefix}/itfxapi", source => source.ReloadOnChange = true);
 Log.Logger = new LoggerConfiguration()
     .ReadFrom.Configuration(configuration)
     .CreateLogger();

src/InterfaceForward.Api/appsettings.json

@@ -1,7 +1,7 @@
 {
   "UseLocalConfigs": false,
   "Consul": {
-    "Address": "https://consul.nanafa.com",
+    "Address": "http://test.ideship.com:30850",
-    "Token": "97217125-df0b-5c0a-dbfc-8885def5e471"
+    "Token": "c0aea902-dca0-ac29-299b-a0d47e5402aa"
   }
 }

src/InterfaceForward.Application/ForwardCore/DefaultForwardFlow.cs

@@ -421,7 +421,8 @@ public class DefaultForwardFlow : IForwardFlow, ITransientDependency
                 Dictionary<string, string> nameValueCollection;
                 if (context.FormFieldList.Count != 0)
                 {
-                    var field = context.FormFieldList.FirstOrDefault(x => x.Value == GlobalConst.FromMappingBody);
+                    var field = context.FormFieldList.FirstOrDefault(x =>
+                        x.Value is GlobalConst.FromMappingBody or GlobalConst.FromBody);
                     if (field != null) field.Value = body;
                     nameValueCollection = context.FormFieldList.ToDictionary(x => x.Name, x => x.Value);
                 }
@@ -532,17 +533,18 @@ public class DefaultForwardFlow : IForwardFlow, ITransientDependency
         // Query / Header / 表单
         foreach (var item in context.QueryFieldList)
         {
-            item.Value = ReplaceFormPlaceholder(item.Name, item.Value, item.Description);
+            item.Value = ReplaceFormPlaceholder(item.Name, item.Value, item.Description, keepMappingBodyPlaceholder: false);
         }
 
         foreach (var item in context.HeaderFieldList)
         {
-            item.Value = ReplaceFormPlaceholder(item.Name, item.Value, item.Description);
+            item.Value = ReplaceFormPlaceholder(item.Name, item.Value, item.Description, keepMappingBodyPlaceholder: false);
         }
 
         foreach (var item in context.FormFieldList)
         {
-            item.Value = ReplaceFormPlaceholder(item.Name, item.Value, item.Description);
+            // FormUrlEncoded 的 Body KV 保留占位符，交由 SetContentType 用序列化后的 TargetInterfaceInput 填充
+            item.Value = ReplaceFormPlaceholder(item.Name, item.Value, item.Description, keepMappingBodyPlaceholder: true);
         }
 
         // 绑定body部分的字段
@@ -578,7 +580,7 @@ public class DefaultForwardFlow : IForwardFlow, ITransientDependency
             }
         }
 
-        string ReplaceFormPlaceholder(string name, string value, string? description)
+        string ReplaceFormPlaceholder(string name, string value, string? description, bool keepMappingBodyPlaceholder)
         {
             return value switch
             {
@@ -589,9 +591,11 @@ public class DefaultForwardFlow : IForwardFlow, ITransientDependency
                 GlobalConst.DateTime => TurnDate(now, description),
                 GlobalConst.Url => context.TargetInterface.RequestAddress,
                 GlobalConst.FromAccount => context.GetAccountFieldValueOrNull(name) ?? string.Empty,
-                GlobalConst.FromMappingBody => context.TargetInterface.ContentType == ContentType.FormUrlEncoded
+                // Body 表单在 FormUrlEncoded 时保留占位符；Query/Header 必须立刻展开，否则会原样发出
-                    ? GlobalConst.FromMappingBody
+                GlobalConst.FromMappingBody or GlobalConst.FromBody =>
-                    : JsonConvert.SerializeObject(context.OriginalInterfaceMappedInput),
+                    keepMappingBodyPlaceholder && context.TargetInterface.ContentType == ContentType.FormUrlEncoded
+                        ? GlobalConst.FromMappingBody
+                        : JsonConvert.SerializeObject(context.OriginalInterfaceMappedInput),
                 _ => value
             };
         }

src/InterfaceForward.Application/Services/Customized/Shopee.cs

@@ -1,4 +1,5 @@
 using System.ComponentModel.DataAnnotations;
+using Microsoft.AspNetCore.Authorization;
 using Microsoft.AspNetCore.Mvc;
 using Newtonsoft.Json.Linq;
 
@@ -7,6 +8,7 @@ namespace InterfaceForward.Application.Services.Customized;
 [ApiExplorerSettings(GroupName = "接口转发服务")]
 [TypeFilter(typeof(ShopeeForwardAuthorizeFilter))]   
 [TypeFilter(typeof(ShopeeForwardExceptionFilter))]
+[AllowAnonymous]
 public class Shopee(InterfaceForwardCommon forwardCommon): ApplicationService
 {
     /// <summary>

src/InterfaceForward.Application/Services/Interface/InterfaceService.cs

@@ -108,10 +108,7 @@ public class InterfaceService : ApplicationService
 
         // 构造参数
         var paras = await InterfaceRepository.GetParameterListByIdAsync(id);
-        // 入参树形列表
+      
-        res.InParameterList = interfaceEntity.IsUpStream
-            ? paras.Where(x => x.IsInPara && x.ParaKind == ParameterParaKind.Normal).ToList()
-            : [];
         res.RequestBodyParameterList = !interfaceEntity.IsUpStream && interfaceEntity.ContentType is ContentType.Json or ContentType.Xml
             ? paras.Where(x => x.IsInPara && x.ParaKind == ParameterParaKind.Normal).ToList()
             : [];

src/InterfaceForward.Application/Services/InterfaceForwardCommon.cs

@@ -26,9 +26,9 @@ public class InterfaceForwardCommon(
     : ITransientDependency
 {
     /// <summary>
-    /// 缓存数据：映射，账户 默认过期时间
+    /// 缓存数据：映射，账户 默认过期时间s
     /// </summary>
-    public static readonly int DefaultCacheTtl = int.MaxValue;
+    public static readonly int DefaultCacheTtl = 7 * 24 * 60 * 60;
 
     private readonly Dictionary<string, IForwardFlow> _flows = new();
 

tests/InterfaceForward.Application.Tests/DefaultForwardFlowTests.cs

@@ -96,6 +96,69 @@ public class DefaultForwardFlowTests
         Assert.Equal("{\"orderId\":\"A001\"}", Assert.Single(context.QueryFieldList).Value);
     }
 
+    [Fact]
+    public void ReplacePlaceholder_ShouldExpandQueryFromMappingBodyForFormUrlEncoded()
+    {
+        var flow = new TestForwardFlow();
+        var context = new ForwardCoreContext
+        {
+            TargetInterface = new InterfaceDto
+            {
+                ContentType = ContentType.FormUrlEncoded,
+                RequestAddress = "https://example.com/openapi"
+            },
+            OriginalInterfaceMappedInput = new JObject { ["orderId"] = "A001" },
+            QueryFieldList =
+            [
+                new InterfaceFormFieldDto
+                {
+                    Name = "bizData",
+                    Value = GlobalConst.FromMappingBody
+                }
+            ],
+            FormFieldList =
+            [
+                new InterfaceFormFieldDto
+                {
+                    Name = "notifyBizEventDTO",
+                    Value = GlobalConst.FromMappingBody
+                }
+            ]
+        };
+
+        flow.ReplacePlaceholder(context);
+
+        Assert.Equal("{\"orderId\":\"A001\"}", Assert.Single(context.QueryFieldList).Value);
+        Assert.Equal(GlobalConst.FromMappingBody, Assert.Single(context.FormFieldList).Value);
+    }
+
+    [Fact]
+    public void ReplacePlaceholder_ShouldExpandLegacyFromBodyInQuery()
+    {
+        var flow = new TestForwardFlow();
+        var context = new ForwardCoreContext
+        {
+            TargetInterface = new InterfaceDto
+            {
+                ContentType = ContentType.FormUrlEncoded,
+                RequestAddress = "https://example.com/openapi"
+            },
+            OriginalInterfaceMappedInput = new JObject { ["orderId"] = "A001" },
+            QueryFieldList =
+            [
+                new InterfaceFormFieldDto
+                {
+                    Name = "bizData",
+                    Value = GlobalConst.FromBody
+                }
+            ]
+        };
+
+        flow.ReplacePlaceholder(context);
+
+        Assert.Equal("{\"orderId\":\"A001\"}", Assert.Single(context.QueryFieldList).Value);
+    }
+
     class TestForwardFlow : DefaultForwardFlow
     {
         public void SetContentTypeForTest(ForwardCoreContext context, HttpRequestMessage message)