From 445d8c40b387c901bce2c6f0e23f3d3f9dcee45b Mon Sep 17 00:00:00 2001
From: RenCheng <RCMessage@outlook.com>
Date: Sat, 21 Jun 2025 14:15:23 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E4=B8=A4=E4=B8=AA=E6=96=B0?=
 =?UTF-8?q?=E7=9A=84=E6=95=B0=E6=8D=AE=E6=8E=A5=E5=BC=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 public/config.js                     |   3 +-
 src/components/page/GlobalHeader.vue |   1 +
 src/config/index.js                  |   2 +-
 src/views/datalink/shoreGuide.vue    | 253 +++++++++++++++++++++++++++
 src/views/datalink/submarine.vue     | 253 +++++++++++++++++++++++++++
 5 files changed, 510 insertions(+), 2 deletions(-)
 create mode 100644 src/views/datalink/shoreGuide.vue
 create mode 100644 src/views/datalink/submarine.vue

diff --git a/public/config.js b/public/config.js
index 10c53dd..9a36463 100644
--- a/public/config.js
+++ b/public/config.js
@@ -1,3 +1,4 @@
 window.AppConfig = { 
-    systemTitle: '末端数据接入处理系统'
+    systemTitle: '末端数据接入处理系统',
+    apiUrl: 'http://pbl1.natapp1.cc/jeecg-boot'
 }
\ No newline at end of file
diff --git a/src/components/page/GlobalHeader.vue b/src/components/page/GlobalHeader.vue
index d56ea76..fd92e20 100644
--- a/src/components/page/GlobalHeader.vue
+++ b/src/components/page/GlobalHeader.vue
@@ -120,6 +120,7 @@ export default {
   },
   created() {
     this.sysTitle = window.AppConfig.systemTitle
+    this.apiUrl = window.AppConfig.apiUrl
   },
   methods: {
     handleScroll() {
diff --git a/src/config/index.js b/src/config/index.js
index 6601609..3604ff7 100644
--- a/src/config/index.js
+++ b/src/config/index.js
@@ -2,7 +2,7 @@
 import Vue from 'vue'
 //设置全局API_BASE_URL
 Vue.prototype.API_BASE_URL = process.env.VUE_APP_API_BASE_URL
-window._CONFIG['domianURL'] = Vue.prototype.API_BASE_URL
+window._CONFIG['domianURL'] = window.AppConfig.apiUrl
 //单点登录地址
 window._CONFIG['casPrefixUrl'] = process.env.VUE_APP_CAS_BASE_URL
 window._CONFIG['onlinePreviewDomainURL'] =  process.env.VUE_APP_ONLINE_BASE_URL
diff --git a/src/views/datalink/shoreGuide.vue b/src/views/datalink/shoreGuide.vue
new file mode 100644
index 0000000..e332f30
--- /dev/null
+++ b/src/views/datalink/shoreGuide.vue
@@ -0,0 +1,253 @@
+<template>
+  <a-card :bordered="false">
+
+    <!-- 查询区域 -->
+    <div class="table-page-search-wrapper">
+      <a-form layout="inline" @keyup.enter.native="searchQuery">
+        <a-row :gutter="24">
+          <a-col :md="6" :sm="8">
+            <a-form-item label="模式名称">
+              <a-input placeholder="请输入搜索关键词" v-model="queryParam.schemaName"></a-input>
+            </a-form-item>
+          </a-col>
+          <a-col :md="6" :sm="8">
+            <a-form-item label="表名">
+              <a-input placeholder="请输入搜索关键词" v-model="queryParam.tableName"></a-input>
+            </a-form-item>
+          </a-col>
+          <span style="float: left;overflow: hidden;" class="table-page-search-submitButtons">
+            <a-col :md="6" :sm="24" >
+                <a-button type="primary"  style="left: 10px" @click="loadData" icon="search">查询</a-button>
+                <a-button type="primary"  @click="searchReset" icon="reload" style="margin-left: 8px;left: 10px">重置</a-button>
+                <a-button type="primary"  @click="handleAdd" icon="upload" style="margin-left: 8px;left: 10px">上传</a-button>
+                <a-button type="primary"  @click="allprocess" icon="upload" style="margin-left: 8px;left: 10px">全部解析</a-button>
+            </a-col>
+          </span>
+
+        </a-row>
+      </a-form>
+    </div>
+    <!-- table区域-begin -->
+    <div style="height:900px;overflow-y:auto;background: #e6e9f1;">
+      <a-table
+        ref="table"
+        size="middle"
+        bordered
+        rowKey="id"
+        :columns="columns"
+        :dataSource="dataSource"
+        :pagination="ipagination"
+        :loading="loading"
+        :rowSelection="{selectedRowKeys: selectedRowKeys,onChange: onSelectChange}"
+        @change="handleTableChange">
+<!--        :locale="myLocale"-->
+
+        <!-- 字符串超长截取省略号显示-->
+        <template slot="parseStatus" slot-scope="text">
+            <span style="color:black;" v-if="text === 0" >未解析</span>
+            <span style="color:darkorange;" v-if="text === 1">解析中</span>
+            <span style="color:#87d068;" v-if="text === 2">解析完成</span>
+            <span style="color:red;" v-if="text === 3">解析失败</span>
+            <span style="color:royalblue;" v-if="text === 4">等待中</span>
+        </template>
+        <span slot="action" slot-scope="text, record">
+          <a @click="processFile(record)"  >解析</a>
+          <a-divider type="vertical"/>
+          <a @click="clearTableData(record.id)">卸载</a>
+          <a-divider type="vertical"  />
+          <a-popconfirm title="确定删除吗?" @confirm="() => handleDelete(record.id)">
+            <a>删除</a>
+          </a-popconfirm>
+        </span>
+      </a-table>
+    </div>
+    <!-- table区域-end -->
+
+    <!-- 表单区域 -->
+    <uploadModal ref="modalForm" @ok="loadData"></uploadModal>
+  </a-card>
+</template>
+
+<script>
+  import uploadModal from './modules/uploadModal'
+  import { getFileLinkInfo,processFile,fileDataLinkDelete,isDataLinkFileParsed } from '@/api/fileDataLink'
+  import { JeecgListMixin } from '@/mixins/JeecgListMixin'
+  import JEllipsis from "@/components/jeecg/JEllipsis";
+  import {deleteAction, postAction,getAction} from '@/api/manage'
+  export default {
+    name: "waterDocuments",
+    mixins:[JeecgListMixin],
+    components: {
+      uploadModal,
+      JEllipsis,
+      VNodes: {
+        functional: true,
+        render: (h, ctx) => ctx.props.vnodes,
+      },
+    },
+    data () {
+      return {
+        description: '文件接引',
+        dataSources: [],
+        queryParam: {
+          pageNum :1,
+          pageSize:20,
+          schemaName:'',
+          tableName:'',
+          dataLinkType:'5'
+        },
+        schemaName:"",
+        columns: [
+          {
+            title: '#',
+            dataIndex: '',
+            key:'id',
+            width:60,
+            align:"id",
+            customRender:function (t,r,index) {
+              return parseInt(index)+1;
+            }
+          },
+          {
+            title: '文件名称',
+            align:"fileName",
+            dataIndex: 'fileName',
+          },
+          {
+            title: '模式名称',
+            align:"schemaName",
+            dataIndex: 'schemaName'
+          },
+          {
+            title: '表名',
+            align:"tableName",
+            dataIndex: 'tableName',
+          },
+          {
+            title: '创建时间',
+            align:"createTime",
+            dataIndex: 'createTime'
+          },
+          {
+            title: '状态',
+            align:"center",
+            dataIndex: 'parseStatus',
+            scopedSlots: { customRender: 'parseStatus' },
+          },
+          {
+            title: '解析进度',
+            align:"center",
+            dataIndex: 'percent',
+          },
+          {
+            title: '解析时间开始',
+            align:"analyzeStartTime",
+            dataIndex: 'analyzeStartTime',
+          },
+          {
+            title: '解析时间完成',
+            align:"analyzeEndTime",
+            dataIndex: 'analyzeEndTime',
+          },
+          {
+            title: '操作',
+            dataIndex: 'action',
+            align:"center",
+            width:180,
+            scopedSlots: { customRender: 'action' },
+          }
+        ]
+      }
+    },
+    computed: {
+    },
+    created () {
+      this.loadData();
+    },
+    methods: {
+      //筛选需要重写handleTableChange
+      handleTableChange(pagination, filters, sorter) {
+        //分页、排序、筛选变化时触发
+        //TODO 筛选
+        if (Object.keys(sorter).length > 0) {
+          this.isorter.column = sorter.field;
+          this.isorter.order = "ascend" == sorter.order ? "asc" : "desc"
+        }
+        this.ipagination = pagination;
+        this.loadData();
+      },
+      loadData() {
+        getFileLinkInfo(this.queryParam).then((res) => {
+            if (res.success) {
+                this.dataSource = res.result.records;
+                setTimeout(()=>{
+                  this.loadData();
+                },5000)
+                if(res.result.total)
+                {
+                  this.ipagination.total = res.result.total;
+                }
+            } else {
+                this.$message.warning(res.message);
+            }
+        });
+      },
+      allprocess:function(){
+        postAction("/fileDataLink/processAllFile?dataLinkType=1",{}).then((res) => {
+            if (res.success) {
+                this.$message.success(res.message);
+            } else {
+                this.$message.warning(res.message);
+            }
+        });
+      },
+      clearTableData:function (id){
+        var that = this;
+        deleteAction("/fileDataLink/clearTableData?id="+id,{}).then((res) => {
+            if (res.code == 200) {
+              this.$message.success(res.result);
+            }else{
+              this.$message.warning(res.message)
+            }
+            that.loadData();
+        });
+      },
+      handleDelete: function (id) {
+        var that = this;
+        deleteAction("/fileDataLink/delete?id="+id,{}).then((res) => {
+            if (res.success) {
+                this.$message.success(res.message);
+                that.loadData();
+            } else {
+                this.$message.warning(res.message);
+            }
+        });
+      },
+      processFile: function (record) {
+        var that = this;
+        isDataLinkFileParsed({fileId:record.fileId}).then((res) => {
+            if (res) {
+              postAction("/fileDataLink/processFile?dataLinkId="+record.id,{}).then((res) => {
+                  if (res.success) {
+                      this.$message.success(res.message);
+                      that.loadData();
+                  } else {
+                      this.$message.warning(res.message);
+                  }
+              });
+            } else {
+                this.$message.warning("解析中请勿重复点击");
+            }
+        });
+      },
+      handleAdd() {
+        this.$refs.modalForm.add();
+        this.$refs.modalForm.title = "文件上传";
+        this.$refs.modalForm.dataLinkType=this.queryParam.dataLinkType;
+      },
+    }
+  }
+</script>
+<style scoped>
+  @import '~@assets/less/common.less';
+</style>
\ No newline at end of file
diff --git a/src/views/datalink/submarine.vue b/src/views/datalink/submarine.vue
new file mode 100644
index 0000000..4971213
--- /dev/null
+++ b/src/views/datalink/submarine.vue
@@ -0,0 +1,253 @@
+<template>
+  <a-card :bordered="false">
+
+    <!-- 查询区域 -->
+    <div class="table-page-search-wrapper">
+      <a-form layout="inline" @keyup.enter.native="searchQuery">
+        <a-row :gutter="24">
+          <a-col :md="6" :sm="8">
+            <a-form-item label="模式名称">
+              <a-input placeholder="请输入搜索关键词" v-model="queryParam.schemaName"></a-input>
+            </a-form-item>
+          </a-col>
+          <a-col :md="6" :sm="8">
+            <a-form-item label="表名">
+              <a-input placeholder="请输入搜索关键词" v-model="queryParam.tableName"></a-input>
+            </a-form-item>
+          </a-col>
+          <span style="float: left;overflow: hidden;" class="table-page-search-submitButtons">
+            <a-col :md="6" :sm="24" >
+                <a-button type="primary"  style="left: 10px" @click="loadData" icon="search">查询</a-button>
+                <a-button type="primary"  @click="searchReset" icon="reload" style="margin-left: 8px;left: 10px">重置</a-button>
+                <a-button type="primary"  @click="handleAdd" icon="upload" style="margin-left: 8px;left: 10px">上传</a-button>
+                <a-button type="primary"  @click="allprocess" icon="upload" style="margin-left: 8px;left: 10px">全部解析</a-button>
+            </a-col>
+          </span>
+
+        </a-row>
+      </a-form>
+    </div>
+    <!-- table区域-begin -->
+    <div style="height:900px;overflow-y:auto;background: #e6e9f1;">
+      <a-table
+        ref="table"
+        size="middle"
+        bordered
+        rowKey="id"
+        :columns="columns"
+        :dataSource="dataSource"
+        :pagination="ipagination"
+        :loading="loading"
+        :rowSelection="{selectedRowKeys: selectedRowKeys,onChange: onSelectChange}"
+        @change="handleTableChange">
+<!--        :locale="myLocale"-->
+
+        <!-- 字符串超长截取省略号显示-->
+        <template slot="parseStatus" slot-scope="text">
+            <span style="color:black;" v-if="text === 0" >未解析</span>
+            <span style="color:darkorange;" v-if="text === 1">解析中</span>
+            <span style="color:#87d068;" v-if="text === 2">解析完成</span>
+            <span style="color:red;" v-if="text === 3">解析失败</span>
+            <span style="color:royalblue;" v-if="text === 4">等待中</span>
+        </template>
+        <span slot="action" slot-scope="text, record">
+          <a @click="processFile(record)"  >解析</a>
+          <a-divider type="vertical"/>
+          <a @click="clearTableData(record.id)">卸载</a>
+          <a-divider type="vertical"  />
+          <a-popconfirm title="确定删除吗?" @confirm="() => handleDelete(record.id)">
+            <a>删除</a>
+          </a-popconfirm>
+        </span>
+      </a-table>
+    </div>
+    <!-- table区域-end -->
+
+    <!-- 表单区域 -->
+    <uploadModal ref="modalForm" @ok="loadData"></uploadModal>
+  </a-card>
+</template>
+
+<script>
+  import uploadModal from './modules/uploadModal'
+  import { getFileLinkInfo,processFile,fileDataLinkDelete,isDataLinkFileParsed } from '@/api/fileDataLink'
+  import { JeecgListMixin } from '@/mixins/JeecgListMixin'
+  import JEllipsis from "@/components/jeecg/JEllipsis";
+  import {deleteAction, postAction,getAction} from '@/api/manage'
+  export default {
+    name: "waterDocuments",
+    mixins:[JeecgListMixin],
+    components: {
+      uploadModal,
+      JEllipsis,
+      VNodes: {
+        functional: true,
+        render: (h, ctx) => ctx.props.vnodes,
+      },
+    },
+    data () {
+      return {
+        description: '文件接引',
+        dataSources: [],
+        queryParam: {
+          pageNum :1,
+          pageSize:20,
+          schemaName:'',
+          tableName:'',
+          dataLinkType:'4'
+        },
+        schemaName:"",
+        columns: [
+          {
+            title: '#',
+            dataIndex: '',
+            key:'id',
+            width:60,
+            align:"id",
+            customRender:function (t,r,index) {
+              return parseInt(index)+1;
+            }
+          },
+          {
+            title: '文件名称',
+            align:"fileName",
+            dataIndex: 'fileName',
+          },
+          {
+            title: '模式名称',
+            align:"schemaName",
+            dataIndex: 'schemaName'
+          },
+          {
+            title: '表名',
+            align:"tableName",
+            dataIndex: 'tableName',
+          },
+          {
+            title: '创建时间',
+            align:"createTime",
+            dataIndex: 'createTime'
+          },
+          {
+            title: '状态',
+            align:"center",
+            dataIndex: 'parseStatus',
+            scopedSlots: { customRender: 'parseStatus' },
+          },
+          {
+            title: '解析进度',
+            align:"center",
+            dataIndex: 'percent',
+          },
+          {
+            title: '解析时间开始',
+            align:"analyzeStartTime",
+            dataIndex: 'analyzeStartTime',
+          },
+          {
+            title: '解析时间完成',
+            align:"analyzeEndTime",
+            dataIndex: 'analyzeEndTime',
+          },
+          {
+            title: '操作',
+            dataIndex: 'action',
+            align:"center",
+            width:180,
+            scopedSlots: { customRender: 'action' },
+          }
+        ]
+      }
+    },
+    computed: {
+    },
+    created () {
+      this.loadData();
+    },
+    methods: {
+      //筛选需要重写handleTableChange
+      handleTableChange(pagination, filters, sorter) {
+        //分页、排序、筛选变化时触发
+        //TODO 筛选
+        if (Object.keys(sorter).length > 0) {
+          this.isorter.column = sorter.field;
+          this.isorter.order = "ascend" == sorter.order ? "asc" : "desc"
+        }
+        this.ipagination = pagination;
+        this.loadData();
+      },
+      loadData() {
+        getFileLinkInfo(this.queryParam).then((res) => {
+            if (res.success) {
+                this.dataSource = res.result.records;
+                setTimeout(()=>{
+                  this.loadData();
+                },5000)
+                if(res.result.total)
+                {
+                  this.ipagination.total = res.result.total;
+                }
+            } else {
+                this.$message.warning(res.message);
+            }
+        });
+      },
+      allprocess:function(){
+        postAction("/fileDataLink/processAllFile?dataLinkType=1",{}).then((res) => {
+            if (res.success) {
+                this.$message.success(res.message);
+            } else {
+                this.$message.warning(res.message);
+            }
+        });
+      },
+      clearTableData:function (id){
+        var that = this;
+        deleteAction("/fileDataLink/clearTableData?id="+id,{}).then((res) => {
+            if (res.code == 200) {
+              this.$message.success(res.result);
+            }else{
+              this.$message.warning(res.message)
+            }
+            that.loadData();
+        });
+      },
+      handleDelete: function (id) {
+        var that = this;
+        deleteAction("/fileDataLink/delete?id="+id,{}).then((res) => {
+            if (res.success) {
+                this.$message.success(res.message);
+                that.loadData();
+            } else {
+                this.$message.warning(res.message);
+            }
+        });
+      },
+      processFile: function (record) {
+        var that = this;
+        isDataLinkFileParsed({fileId:record.fileId}).then((res) => {
+            if (res) {
+              postAction("/fileDataLink/processFile?dataLinkId="+record.id,{}).then((res) => {
+                  if (res.success) {
+                      this.$message.success(res.message);
+                      that.loadData();
+                  } else {
+                      this.$message.warning(res.message);
+                  }
+              });
+            } else {
+                this.$message.warning("解析中请勿重复点击");
+            }
+        });
+      },
+      handleAdd() {
+        this.$refs.modalForm.add();
+        this.$refs.modalForm.title = "文件上传";
+        this.$refs.modalForm.dataLinkType=this.queryParam.dataLinkType;
+      },
+    }
+  }
+</script>
+<style scoped>
+  @import '~@assets/less/common.less';
+</style>
\ No newline at end of file