|
|
@@ -1,4 +1,3 @@
|
|
|
-/*
|
|
|
package com.ruoyi;
|
|
|
|
|
|
import com.agentsflex.core.chain.Chain;
|
|
|
@@ -20,12 +19,18 @@ import com.ruoyi.model.dpp.dal.dataobject.etl.DppEtlTaskDO;
|
|
|
import com.ruoyi.model.etl.mapper.DppEtlTaskMapper;
|
|
|
import dev.tinyflow.core.Tinyflow;
|
|
|
import org.junit.jupiter.api.Test;
|
|
|
+import org.junit.runner.RunWith;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+import org.springframework.boot.test.context.SpringBootTest;
|
|
|
+import org.springframework.test.context.junit4.SpringRunner;
|
|
|
|
|
|
import javax.annotation.Resource;
|
|
|
import java.util.HashMap;
|
|
|
import java.util.Map;
|
|
|
|
|
|
+
|
|
|
+@SpringBootTest(classes = RuoYiApplication.class, webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
|
|
|
+@RunWith(SpringRunner.class)
|
|
|
public class TinyflowTest {
|
|
|
|
|
|
// static String data1 = "";
|
|
|
@@ -35,56 +40,64 @@ public class TinyflowTest {
|
|
|
" {\n" +
|
|
|
" \"id\": \"1\",\n" +
|
|
|
" \"type\": \"startNode\",\n" +
|
|
|
+ " \"initialized\": false,\n" +
|
|
|
+ " \"position\": {\n" +
|
|
|
+ " \"x\": -600,\n" +
|
|
|
+ " \"y\": -300\n" +
|
|
|
+ " },\n" +
|
|
|
" \"data\": {\n" +
|
|
|
- " \"title\": \"开始节点\",\n" +
|
|
|
- " \"description\": \"开始定义输入参数\",\n" +
|
|
|
- " \"expand\": true,\n" +
|
|
|
+ " \"label\": \"开始\",\n" +
|
|
|
" \"parameters\": [\n" +
|
|
|
" {\n" +
|
|
|
- " \"name\": \"year\",\n" +
|
|
|
- " \"dataType\": \"String\",\n" +
|
|
|
- " \"refType\": \"input\",\n" +
|
|
|
- " \"required\": true,\n" +
|
|
|
- " \"description\": \"第一个输入参数\"\n" +
|
|
|
- " },\n" +
|
|
|
- " {\n" +
|
|
|
- " \"name\": \"inputParam2\",\n" +
|
|
|
- " \"dataType\": \"Number\",\n" +
|
|
|
- " \"refType\": \"input\",\n" +
|
|
|
- " \"required\": false,\n" +
|
|
|
- " \"description\": \"第二个输入参数\",\n" +
|
|
|
- " \"defaultValue\": 100\n" +
|
|
|
+ " \"name\": \"beginTm\",\n" +
|
|
|
+ " \"dataType\": \"string\",\n" +
|
|
|
+ " \"refType\": \"input\"\n" +
|
|
|
" }\n" +
|
|
|
- " ]\n" +
|
|
|
- " },\n" +
|
|
|
- " \"position\": {\n" +
|
|
|
- " \"x\": 150,\n" +
|
|
|
- " \"y\": 25\n" +
|
|
|
- " },\n" +
|
|
|
- " \"measured\": {\n" +
|
|
|
- " \"width\": 306,\n" +
|
|
|
- " \"height\": 209\n" +
|
|
|
- " },\n" +
|
|
|
- " \"selected\": false\n" +
|
|
|
+ " ],\n" +
|
|
|
+ " \"loading\": false,\n" +
|
|
|
+ " \"isSuccess\": true,\n" +
|
|
|
+ " \"isFail\": false\n" +
|
|
|
+ " }\n" +
|
|
|
" },\n" +
|
|
|
" {\n" +
|
|
|
" \"id\": \"2\",\n" +
|
|
|
+ " \"type\": \"endNode\",\n" +
|
|
|
+ " \"initialized\": false,\n" +
|
|
|
+ " \"position\": {\n" +
|
|
|
+ " \"x\": 495,\n" +
|
|
|
+ " \"y\": 15\n" +
|
|
|
+ " },\n" +
|
|
|
" \"data\": {\n" +
|
|
|
- " \"title\": \"服务节点\",\n" +
|
|
|
- " \"parameters\": [\n" +
|
|
|
+ " \"label\": \"结束\",\n" +
|
|
|
+ " \"outputDefs\": [\n" +
|
|
|
" {\n" +
|
|
|
- " \"name\": \"year\",\n" +
|
|
|
- " \"dataType\": \"String\",\n" +
|
|
|
- " \"ref\": \"1.year\",\n" +
|
|
|
- " \"refType\": \"ref\"\n" +
|
|
|
+ " \"name\": \"data\",\n" +
|
|
|
+ " \"dataType\": \"array\",\n" +
|
|
|
+ " \"refType\": \"ref\",\n" +
|
|
|
+ " \"ref\": \"1763516549902862.data\"\n" +
|
|
|
" }\n" +
|
|
|
- " ],\n" +
|
|
|
+ " ]\n" +
|
|
|
+ " }\n" +
|
|
|
+ " },\n" +
|
|
|
+ " {\n" +
|
|
|
+ " \"id\": \"1763515700772804\",\n" +
|
|
|
+ " \"type\": \"serviceNode\",\n" +
|
|
|
+ " \"initialized\": false,\n" +
|
|
|
+ " \"position\": {\n" +
|
|
|
+ " \"x\": -240,\n" +
|
|
|
+ " \"y\": -135\n" +
|
|
|
+ " },\n" +
|
|
|
+ " \"data\": {\n" +
|
|
|
+ " \"id\": \"2ae45987679c46248a95bc14432844b1\",\n" +
|
|
|
+ " \"pid\": \"56d0db1d-27fe-4a9c-9060-c1429f3d2c8d\",\n" +
|
|
|
+ " \"label\": \"获取雨量数据列表\",\n" +
|
|
|
+ " \"nodeType\": \"SERVICE\",\n" +
|
|
|
" \"service\": {\n" +
|
|
|
- " \"srvId\": \"634ae1e0ee78e00bd609b85514961373\",\n" +
|
|
|
- " \"mdid\": \"e4dc50dd-c4a9-4639-b43e-62e48314a7e0\",\n" +
|
|
|
- " \"cateCode\": \"S\",\n" +
|
|
|
- " \"name\": \"获取台风信息列表\",\n" +
|
|
|
- " \"intro\": \"获取有台风的编号及名称\",\n" +
|
|
|
+ " \"srvId\": \"2ae45987679c46248a95bc14432844b1\",\n" +
|
|
|
+ " \"mdid\": \"56d0db1d-27fe-4a9c-9060-c1429f3d2c8d\",\n" +
|
|
|
+ " \"cateCode\": \"\",\n" +
|
|
|
+ " \"name\": \"获取雨量数据列表\",\n" +
|
|
|
+ " \"intro\": \"获取雨量数据\",\n" +
|
|
|
" \"serviceSource\": null,\n" +
|
|
|
" \"serviceDept\": null,\n" +
|
|
|
" \"manageName\": null,\n" +
|
|
|
@@ -97,122 +110,292 @@ public class TinyflowTest {
|
|
|
" \"adName\": null,\n" +
|
|
|
" \"dataField\": null,\n" +
|
|
|
" \"dataRange\": null,\n" +
|
|
|
- " \"userId\": null,\n" +
|
|
|
+ " \"userId\": \"1\",\n" +
|
|
|
" \"status\": null,\n" +
|
|
|
" \"note\": null,\n" +
|
|
|
" \"type\": \"HTTP\",\n" +
|
|
|
- " \"url\": \"http://49.4.2.185:2111/RiverStrongAPI2.0/StormSurgeForecast/Typhoon/GetInfos\",\n" +
|
|
|
+ " \"url\": \"/sh-api/getPptnList\",\n" +
|
|
|
" \"rqtype\": \"POST\",\n" +
|
|
|
" \"rptype\": \"1\",\n" +
|
|
|
- " \"rpcontent\": \"{\\n \\\"data\\\": [\\n {\\n \\\"typhoonId\\\": \\\"202317\\\",\\n \\\"typhoonName\\\": \\\"杰拉华\\\",\\n \\\"test\\\": \\\"1123\\\"\\n },\\n {\\n \\\"typhoonId\\\": \\\"202316\\\",\\n \\\"typhoonName\\\": \\\"三巴\\\",\\n \\\"test\\\": \\\"1123\\\"\\n \\n }\\n ],\\n \\\"succeeded\\\": true,\\n \\\"statusCode\\\": 200,\\n \\\"remark\\\": \\\"获取该年台风信息成功\\\"\\n}\",\n" +
|
|
|
+ " \"rpcontent\": \"{\\\"msg\\\":\\\"操作成功\\\",\\\"code\\\":200,\\\"data\\\":[{\\\"stcd\\\":\\\"1111111\\\",\\\"stnm\\\":null,\\\"tm\\\":\\\"2025-11-18 16:29:32\\\",\\\"drp\\\":0.0,\\\"intv\\\":1.0,\\\"pdr\\\":null,\\\"dyp\\\":null,\\\"wth\\\":\\\"\\\",\\\"tmy\\\":null,\\\"lgtd\\\":1.0,\\\"lttd\\\":1.0},{\\\"stcd\\\":\\\"1111111\\\",\\\"stnm\\\":null,\\\"tm\\\":\\\"2025-11-18 16:29:32\\\",\\\"drp\\\":0.0,\\\"intv\\\":1.0,\\\"pdr\\\":null,\\\"dyp\\\":null,\\\"wth\\\":\\\"\\\",\\\"tmy\\\":null,\\\"lgtd\\\":1.0,\\\"lttd\\\":1.0},{\\\"stcd\\\":\\\"1111111\\\",\\\"stnm\\\":null,\\\"tm\\\":\\\"2025-11-18 16:29:32\\\",\\\"drp\\\":0.0,\\\"intv\\\":1.0,\\\"pdr\\\":null,\\\"dyp\\\":null,\\\"wth\\\":\\\"\\\",\\\"tmy\\\":null,\\\"lgtd\\\":1.0,\\\"lttd\\\":1.0},{\\\"stcd\\\":\\\"1111111\\\",\\\"stnm\\\":null,\\\"tm\\\":\\\"2025-11-18 16:29:32\\\",\\\"drp\\\":0.0,\\\"intv\\\":1.0,\\\"pdr\\\":null,\\\"dyp\\\":null,\\\"wth\\\":\\\"\\\",\\\"tmy\\\":null,\\\"lgtd\\\":1.0,\\\"lttd\\\":1.0}]}\",\n" +
|
|
|
" \"proxyAddress\": null,\n" +
|
|
|
- " \"proxyPath\": null,\n" +
|
|
|
+ " \"proxyPath\": \"\",\n" +
|
|
|
+ " \"gatewayId\": \"f9d56764047a49ea957163e87f3492dc\",\n" +
|
|
|
" \"example\": \"\",\n" +
|
|
|
- " \"cnt\": null,\n" +
|
|
|
+ " \"cnt\": 0,\n" +
|
|
|
" \"viewNum\": 0,\n" +
|
|
|
- " \"applyNum\": null,\n" +
|
|
|
- " \"dataNum\": null,\n" +
|
|
|
- " \"tm\": null,\n" +
|
|
|
- " \"uptm\": null,\n" +
|
|
|
- " \"rlstm\": null,\n" +
|
|
|
- " \"releaseTime\": null,\n" +
|
|
|
+ " \"applyNum\": 0,\n" +
|
|
|
+ " \"dataNum\": 0,\n" +
|
|
|
+ " \"tm\": \"2025-11-18\",\n" +
|
|
|
+ " \"uptm\": \"2025-11-18\",\n" +
|
|
|
+ " \"rlstm\": \"2025-11-18\",\n" +
|
|
|
+ " \"releaseTime\": \"2025-11-18\",\n" +
|
|
|
" \"attentionId\": null,\n" +
|
|
|
" \"params\": [\n" +
|
|
|
" {\n" +
|
|
|
- " \"srvId\": \"634ae1e0ee78e00bd609b85514961373\",\n" +
|
|
|
- " \"paramCode\": \"year\",\n" +
|
|
|
- " \"paramName\": \"年份\",\n" +
|
|
|
- " \"paramType\": \"int\",\n" +
|
|
|
- " \"paramValue\": \"2023\",\n" +
|
|
|
+ " \"srvId\": \"2ae45987679c46248a95bc14432844b1\",\n" +
|
|
|
+ " \"paramCode\": \"beginTm\",\n" +
|
|
|
+ " \"paramName\": \"开始时间\",\n" +
|
|
|
+ " \"paramType\": \"string\",\n" +
|
|
|
+ " \"paramValue\": \"\",\n" +
|
|
|
" \"paramFormat\": null,\n" +
|
|
|
- " \"paramNote\": \"\",\n" +
|
|
|
+ " \"paramNote\": null,\n" +
|
|
|
" \"sort\": 0,\n" +
|
|
|
- " \"paramObject\": 2023\n" +
|
|
|
+ " \"paramObject\": \"\"\n" +
|
|
|
+ " },\n" +
|
|
|
+ " {\n" +
|
|
|
+ " \"srvId\": \"2ae45987679c46248a95bc14432844b1\",\n" +
|
|
|
+ " \"paramCode\": \"endTm\",\n" +
|
|
|
+ " \"paramName\": \"结束时间\",\n" +
|
|
|
+ " \"paramType\": \"string\",\n" +
|
|
|
+ " \"paramValue\": null,\n" +
|
|
|
+ " \"paramFormat\": null,\n" +
|
|
|
+ " \"paramNote\": null,\n" +
|
|
|
+ " \"sort\": 1,\n" +
|
|
|
+ " \"paramObject\": null\n" +
|
|
|
" }\n" +
|
|
|
" ],\n" +
|
|
|
+ " \"state\": \"1\",\n" +
|
|
|
" \"sort\": null,\n" +
|
|
|
- " \"audit\": null\n" +
|
|
|
- " }\n" +
|
|
|
- " },\n" +
|
|
|
+ " \"audit\": \"0\",\n" +
|
|
|
+ " \"auditBy\": null,\n" +
|
|
|
+ " \"auditRemark\": null,\n" +
|
|
|
+ " \"auditTime\": null,\n" +
|
|
|
+ " \"publish\": \"0\",\n" +
|
|
|
+ " \"publishBy\": null,\n" +
|
|
|
+ " \"publishTime\": null,\n" +
|
|
|
+ " \"senState\": null,\n" +
|
|
|
+ " \"dataSignature\": \"3045022067c584d2219e519ea682b2d48062f3042b1ed7b72ca485153d8cb9c99b6f30a9022100c565ca82582ad864210782988f9043a815e9778f55a9836d2fcba5cd424bf3f4\"\n" +
|
|
|
+ " },\n" +
|
|
|
+ " \"parameters\": [\n" +
|
|
|
+ " {\n" +
|
|
|
+ " \"name\": \"beginTm\",\n" +
|
|
|
+ " \"ref\": \"1.beginTm\",\n" +
|
|
|
+ " \"dataType\": \"string\",\n" +
|
|
|
+ " \"refType\": \"ref\"\n" +
|
|
|
+ " },\n" +
|
|
|
+ " {\n" +
|
|
|
+ " \"name\": \"endTm\",\n" +
|
|
|
+ " \"ref\": \"1.beginTm\",\n" +
|
|
|
+ " \"dataType\": \"string\",\n" +
|
|
|
+ " \"refType\": \"ref\"\n" +
|
|
|
+ " }\n" +
|
|
|
+ " ],\n" +
|
|
|
+ " \"loading\": false,\n" +
|
|
|
+ " \"isSuccess\": true,\n" +
|
|
|
+ " \"isFail\": false\n" +
|
|
|
+ " }\n" +
|
|
|
+ " },\n" +
|
|
|
+ " {\n" +
|
|
|
+ " \"id\": \"1763516549902862\",\n" +
|
|
|
" \"type\": \"serviceNode\",\n" +
|
|
|
+ " \"initialized\": false,\n" +
|
|
|
" \"position\": {\n" +
|
|
|
- " \"x\": 600,\n" +
|
|
|
- " \"y\": 50\n" +
|
|
|
- " },\n" +
|
|
|
- " \"measured\": {\n" +
|
|
|
- " \"width\": 334,\n" +
|
|
|
- " \"height\": 687\n" +
|
|
|
+ " \"x\": 150,\n" +
|
|
|
+ " \"y\": -60\n" +
|
|
|
" },\n" +
|
|
|
- " \"selected\": false\n" +
|
|
|
- " },\n" +
|
|
|
- " {\n" +
|
|
|
- " \"id\": \"3\",\n" +
|
|
|
- " \"type\": \"endNode\",\n" +
|
|
|
" \"data\": {\n" +
|
|
|
- " \"title\": \"结束节点\",\n" +
|
|
|
- " \"description\": \"结束定义输出参数\",\n" +
|
|
|
- " \"expand\": true,\n" +
|
|
|
- " \"outputDefs\": [\n" +
|
|
|
+ " \"id\": \"c48bb6d3a73f41a19d0eccb33fe34424\",\n" +
|
|
|
+ " \"pid\": \"56d0db1d-27fe-4a9c-9060-c1429f3d2c8d\",\n" +
|
|
|
+ " \"label\": \"等值面数据计算\",\n" +
|
|
|
+ " \"nodeType\": \"SERVICE\",\n" +
|
|
|
+ " \"service\": {\n" +
|
|
|
+ " \"srvId\": \"c48bb6d3a73f41a19d0eccb33fe34424\",\n" +
|
|
|
+ " \"mdid\": \"56d0db1d-27fe-4a9c-9060-c1429f3d2c8d\",\n" +
|
|
|
+ " \"cateCode\": \"\",\n" +
|
|
|
+ " \"name\": \"等值面数据计算\",\n" +
|
|
|
+ " \"intro\": \"\",\n" +
|
|
|
+ " \"serviceSource\": null,\n" +
|
|
|
+ " \"serviceDept\": null,\n" +
|
|
|
+ " \"manageName\": null,\n" +
|
|
|
+ " \"developUnit\": null,\n" +
|
|
|
+ " \"developContacter\": null,\n" +
|
|
|
+ " \"maintainUnit\": null,\n" +
|
|
|
+ " \"maintainContacer\": null,\n" +
|
|
|
+ " \"upCycl\": null,\n" +
|
|
|
+ " \"openCndtn\": null,\n" +
|
|
|
+ " \"adName\": null,\n" +
|
|
|
+ " \"dataField\": null,\n" +
|
|
|
+ " \"dataRange\": null,\n" +
|
|
|
+ " \"userId\": \"1\",\n" +
|
|
|
+ " \"status\": null,\n" +
|
|
|
+ " \"note\": null,\n" +
|
|
|
+ " \"type\": \"HTTP\",\n" +
|
|
|
+ " \"url\": \"/sh-api/getRain\",\n" +
|
|
|
+ " \"rqtype\": \"POST\",\n" +
|
|
|
+ " \"rptype\": \"1\",\n" +
|
|
|
+ " \"rpcontent\": \"{\\n \\\"msg\\\": \\\"操作成功\\\",\\n \\\"code\\\": 200,\\n \\\"data\\\": {\\n \\\"features\\\": [\\n {\\n \\\"type\\\": \\\"Feature\\\",\\n \\\"geometry\\\": {\\n \\\"type\\\": \\\"MultiPolygon\\\",\\n \\\"coordinates\\\": [\\n [\\n [\\n [\\n 106.739,\\n 39.8614\\n ]\\n ]\\n ]\\n ]\\n },\\n \\\"properties\\\": {\\n \\\"lvalue\\\": 0.4,\\n \\\"hvalue\\\": 0.4\\n },\\n \\\"id\\\": \\\"fid-69939b06_19a96366106_-7e6d\\\"\\n }\\n ],\\n \\\"type\\\": \\\"FeatureCollection\\\"\\n }\\n}\",\n" +
|
|
|
+ " \"proxyAddress\": null,\n" +
|
|
|
+ " \"proxyPath\": \"\",\n" +
|
|
|
+ " \"gatewayId\": \"f9d56764047a49ea957163e87f3492dc\",\n" +
|
|
|
+ " \"example\": \"\",\n" +
|
|
|
+ " \"cnt\": 0,\n" +
|
|
|
+ " \"viewNum\": 0,\n" +
|
|
|
+ " \"applyNum\": 0,\n" +
|
|
|
+ " \"dataNum\": 0,\n" +
|
|
|
+ " \"tm\": \"2025-11-18\",\n" +
|
|
|
+ " \"uptm\": \"2025-11-18\",\n" +
|
|
|
+ " \"rlstm\": \"2025-11-18\",\n" +
|
|
|
+ " \"releaseTime\": \"2025-11-18\",\n" +
|
|
|
+ " \"attentionId\": null,\n" +
|
|
|
+ " \"params\": [\n" +
|
|
|
+ " {\n" +
|
|
|
+ " \"srvId\": \"c48bb6d3a73f41a19d0eccb33fe34424\",\n" +
|
|
|
+ " \"paramCode\": \"stPptnRS\",\n" +
|
|
|
+ " \"paramName\": \"降雨量数据列表\",\n" +
|
|
|
+ " \"paramType\": \"array\",\n" +
|
|
|
+ " \"paramValue\": null,\n" +
|
|
|
+ " \"paramFormat\": null,\n" +
|
|
|
+ " \"paramNote\": null,\n" +
|
|
|
+ " \"sort\": 0,\n" +
|
|
|
+ " \"paramObject\": null\n" +
|
|
|
+ " },\n" +
|
|
|
+ " {\n" +
|
|
|
+ " \"srvId\": \"c48bb6d3a73f41a19d0eccb33fe34424\",\n" +
|
|
|
+ " \"paramCode\": \"dataInterval\",\n" +
|
|
|
+ " \"paramName\": \"等级列表\",\n" +
|
|
|
+ " \"paramType\": \"array\",\n" +
|
|
|
+ " \"paramValue\": null,\n" +
|
|
|
+ " \"paramFormat\": null,\n" +
|
|
|
+ " \"paramNote\": null,\n" +
|
|
|
+ " \"sort\": 1,\n" +
|
|
|
+ " \"paramObject\": null\n" +
|
|
|
+ " }\n" +
|
|
|
+ " ],\n" +
|
|
|
+ " \"state\": \"1\",\n" +
|
|
|
+ " \"sort\": null,\n" +
|
|
|
+ " \"audit\": \"0\",\n" +
|
|
|
+ " \"auditBy\": null,\n" +
|
|
|
+ " \"auditRemark\": null,\n" +
|
|
|
+ " \"auditTime\": null,\n" +
|
|
|
+ " \"publish\": \"0\",\n" +
|
|
|
+ " \"publishBy\": null,\n" +
|
|
|
+ " \"publishTime\": null,\n" +
|
|
|
+ " \"senState\": null,\n" +
|
|
|
+ " \"dataSignature\": \"3044022072b3deb5ac7987334ca811e4099f74b56987e21fec2f0fac7639d3d71a449f570220218fe9b942f5a20733988f2225b0096c50b84e127948601c9ecd79ee720791c2\"\n" +
|
|
|
+ " },\n" +
|
|
|
+ " \"parameters\": [\n" +
|
|
|
" {\n" +
|
|
|
- " \"name\": \"data\",\n" +
|
|
|
- " \"dataType\": \"Object\",\n" +
|
|
|
- " \"ref\": \"2.result\",\n" +
|
|
|
+ " \"name\": \"stPptnRS\",\n" +
|
|
|
+ " \"ref\": \"1763515700772804.data\",\n" +
|
|
|
+ " \"dataType\": \"array\",\n" +
|
|
|
" \"refType\": \"ref\"\n" +
|
|
|
+ " },\n" +
|
|
|
+ " {\n" +
|
|
|
+ " \"name\": \"dataInterval\",\n" +
|
|
|
+ " \"value\": \"[0,1,2,3,4,5]\",\n" +
|
|
|
+ " \"dataType\": \"array\",\n" +
|
|
|
+ " \"refType\": \"input\"\n" +
|
|
|
" }\n" +
|
|
|
" ]\n" +
|
|
|
- " },\n" +
|
|
|
- " \"position\": {\n" +
|
|
|
- " \"x\": 994,\n" +
|
|
|
- " \"y\": 218\n" +
|
|
|
- " },\n" +
|
|
|
- " \"measured\": {\n" +
|
|
|
- " \"width\": 334,\n" +
|
|
|
- " \"height\": 209\n" +
|
|
|
- " },\n" +
|
|
|
- " \"selected\": false,\n" +
|
|
|
- " \"dragging\": false\n" +
|
|
|
+ " }\n" +
|
|
|
" }\n" +
|
|
|
" ],\n" +
|
|
|
" \"edges\": [\n" +
|
|
|
" {\n" +
|
|
|
+ " \"id\": \"vueflow__edge-1-1763515700772804\",\n" +
|
|
|
+ " \"type\": \"default\",\n" +
|
|
|
+ " \"source\": \"1\",\n" +
|
|
|
+ " \"target\": \"1763515700772804\",\n" +
|
|
|
+ " \"sourceHandle\": null,\n" +
|
|
|
+ " \"targetHandle\": null,\n" +
|
|
|
+ " \"data\": {},\n" +
|
|
|
+ " \"label\": \"\",\n" +
|
|
|
+ " \"style\": {\n" +
|
|
|
+ " \"stroke\": \"#79bbff\",\n" +
|
|
|
+ " \"strokeWidth\": 2,\n" +
|
|
|
+ " \"type\": \"bezier\",\n" +
|
|
|
+ " \"fill\": \"none\"\n" +
|
|
|
+ " },\n" +
|
|
|
" \"markerEnd\": {\n" +
|
|
|
- " \"type\": \"arrowclosed\",\n" +
|
|
|
- " \"width\": 20,\n" +
|
|
|
- " \"height\": 20\n" +
|
|
|
+ " \"type\": \"arrow\",\n" +
|
|
|
+ " \"color\": \"#79bbff\",\n" +
|
|
|
+ " \"width\": 15,\n" +
|
|
|
+ " \"height\": 15\n" +
|
|
|
" },\n" +
|
|
|
- " \"source\": \"1\",\n" +
|
|
|
- " \"target\": \"2\",\n" +
|
|
|
- " \"id\": \"xy-edge__1-2\"\n" +
|
|
|
+ " \"sourceX\": -362.24219512939453,\n" +
|
|
|
+ " \"sourceY\": -266.32291412353516,\n" +
|
|
|
+ " \"targetX\": -242.9947829012957,\n" +
|
|
|
+ " \"targetY\": -84.27862047636737\n" +
|
|
|
+ " },\n" +
|
|
|
+ " {\n" +
|
|
|
+ " \"id\": \"vueflow__edge-1763515700772804-1763516549902862\",\n" +
|
|
|
+ " \"type\": \"default\",\n" +
|
|
|
+ " \"source\": \"1763515700772804\",\n" +
|
|
|
+ " \"target\": \"1763516549902862\",\n" +
|
|
|
+ " \"sourceHandle\": null,\n" +
|
|
|
+ " \"targetHandle\": null,\n" +
|
|
|
+ " \"data\": {},\n" +
|
|
|
+ " \"label\": \"\",\n" +
|
|
|
+ " \"style\": {\n" +
|
|
|
+ " \"stroke\": \"#79bbff\",\n" +
|
|
|
+ " \"strokeWidth\": 2,\n" +
|
|
|
+ " \"type\": \"bezier\",\n" +
|
|
|
+ " \"fill\": \"none\"\n" +
|
|
|
+ " },\n" +
|
|
|
+ " \"markerEnd\": {\n" +
|
|
|
+ " \"type\": \"arrow\",\n" +
|
|
|
+ " \"color\": \"#79bbff\",\n" +
|
|
|
+ " \"width\": 15,\n" +
|
|
|
+ " \"height\": 15\n" +
|
|
|
+ " },\n" +
|
|
|
+ " \"sourceX\": 40.44016452250668,\n" +
|
|
|
+ " \"sourceY\": -84.27862047636737,\n" +
|
|
|
+ " \"targetX\": 147.0052170987043,\n" +
|
|
|
+ " \"targetY\": -9.27865960748769\n" +
|
|
|
" },\n" +
|
|
|
" {\n" +
|
|
|
+ " \"id\": \"vueflow__edge-1763516549902862-2\",\n" +
|
|
|
+ " \"type\": \"default\",\n" +
|
|
|
+ " \"source\": \"1763516549902862\",\n" +
|
|
|
+ " \"target\": \"2\",\n" +
|
|
|
+ " \"sourceHandle\": null,\n" +
|
|
|
+ " \"targetHandle\": null,\n" +
|
|
|
+ " \"data\": {},\n" +
|
|
|
+ " \"label\": \"\",\n" +
|
|
|
+ " \"style\": {\n" +
|
|
|
+ " \"stroke\": \"#79bbff\",\n" +
|
|
|
+ " \"strokeWidth\": 2,\n" +
|
|
|
+ " \"type\": \"bezier\",\n" +
|
|
|
+ " \"fill\": \"none\"\n" +
|
|
|
+ " },\n" +
|
|
|
" \"markerEnd\": {\n" +
|
|
|
- " \"type\": \"arrowclosed\",\n" +
|
|
|
- " \"width\": 20,\n" +
|
|
|
- " \"height\": 20\n" +
|
|
|
+ " \"type\": \"arrow\",\n" +
|
|
|
+ " \"color\": \"#79bbff\",\n" +
|
|
|
+ " \"width\": 15,\n" +
|
|
|
+ " \"height\": 15\n" +
|
|
|
" },\n" +
|
|
|
- " \"source\": \"2\",\n" +
|
|
|
- " \"target\": \"3\",\n" +
|
|
|
- " \"id\": \"xy-edge__2-3\"\n" +
|
|
|
+ " \"sourceX\": 430.44000799802535,\n" +
|
|
|
+ " \"sourceY\": -9.27865960748769,\n" +
|
|
|
+ " \"targetX\": 492.0052490234375,\n" +
|
|
|
+ " \"targetY\": 48.67706298828125\n" +
|
|
|
" }\n" +
|
|
|
" ],\n" +
|
|
|
+ " \"position\": [\n" +
|
|
|
+ " 53.67420396862019,\n" +
|
|
|
+ " 328.82464236271346\n" +
|
|
|
+ " ],\n" +
|
|
|
+ " \"zoom\": 1.5597600369173974,\n" +
|
|
|
" \"viewport\": {\n" +
|
|
|
- " \"x\": 250,\n" +
|
|
|
- " \"y\": 100,\n" +
|
|
|
- " \"zoom\": 1\n" +
|
|
|
+ " \"x\": 53.67420396862019,\n" +
|
|
|
+ " \"y\": 328.82464236271346,\n" +
|
|
|
+ " \"zoom\": 1.5597600369173974\n" +
|
|
|
" }\n" +
|
|
|
"}";
|
|
|
|
|
|
- public static void main(String[] args) {
|
|
|
- */
|
|
|
-/*System.out.println(data1);
|
|
|
+ @Test
|
|
|
+ public void test1(){
|
|
|
+
|
|
|
+ //public static void main(String[] args) {
|
|
|
+System.out.println(data1);
|
|
|
Tinyflow tinyflow = new Tinyflow(data1);
|
|
|
tinyflow.getChainParser().addNodeParser("printNode",new PrintNodeParser());
|
|
|
tinyflow.getChainParser().addNodeParser("serviceNode",new ServiceNodeParser());
|
|
|
// tinyflow.setLlmProvider(id -> OpenAILlm.of(""));
|
|
|
|
|
|
Map<String, Object> variables = new HashMap<>();
|
|
|
- variables.put("year", "2024");
|
|
|
- variables.put("inputParam2", 2);
|
|
|
+ variables.put("beginTm", "2024");
|
|
|
+ //variables.put("inputParam2", 2);
|
|
|
|
|
|
Chain chain = tinyflow.toChain();
|
|
|
chain.addEventListener(new ChainEventListener() {
|
|
|
@@ -230,16 +413,16 @@ public class TinyflowTest {
|
|
|
}
|
|
|
});
|
|
|
|
|
|
- chain.addOutputListener(new ChainOutputListener() {
|
|
|
+/* chain.addOutputListener(new ChainOutputListener() {
|
|
|
@Override
|
|
|
public void onOutput(Chain chain, ChainNode node, Object outputMessage) {
|
|
|
System.out.println("outputMessage: " + outputMessage);
|
|
|
}
|
|
|
- });
|
|
|
+ });*/
|
|
|
|
|
|
Map<String, Object> result = chain.executeForResult(variables);
|
|
|
|
|
|
- System.out.println("result:" + result);*//*
|
|
|
+ System.out.println("result:" + result);
|
|
|
|
|
|
// TestService testService = new TestService();
|
|
|
// System.out.println(testService.helloTest());
|
|
|
@@ -247,27 +430,4 @@ public class TinyflowTest {
|
|
|
|
|
|
}
|
|
|
|
|
|
- @Resource
|
|
|
- private DppEtlTaskMapper dppEtlTaskMapper ;
|
|
|
-
|
|
|
- @Test
|
|
|
- public void testSelectJoinPage() {
|
|
|
-
|
|
|
- MPJLambdaWrapper<DppEtlTaskDO> wrapper = new MPJLambdaWrapper<>();
|
|
|
- // 添加简单的查询条件
|
|
|
- wrapper.eq(DppEtlTaskDO::getDelFlag, "0");
|
|
|
-
|
|
|
- try {
|
|
|
- IPage<DppEtlTaskDO> result = dppEtlTaskMapper.selectJoinPage(
|
|
|
- new Page<>(1, 10),
|
|
|
- DppEtlTaskDO.class,
|
|
|
- wrapper
|
|
|
- );
|
|
|
- System.out.println("查询成功,结果数量:" + result.getRecords().size());
|
|
|
- } catch (Exception e) {
|
|
|
- System.out.println("查询失败:" + e.getMessage());
|
|
|
- e.printStackTrace();
|
|
|
- }
|
|
|
- }
|
|
|
}
|
|
|
-*/
|