From e430b1641816c9fafcb382cb5fea6864336405f8 Mon Sep 17 00:00:00 2001
From: wenlele <wen.lele@free-sun.com.cn>
Date: Sun, 9 Oct 2022 11:16:56 +0800
Subject: [PATCH] =?UTF-8?q?=E8=A7=86=E9=A2=91=E6=92=AD=E6=94=BE=E5=AE=8C?=
 =?UTF-8?q?=E6=88=90?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 web/client/src/layout/actions/global.js       |  1 +
 web/client/src/layout/reducers/global.js      |  2 ++
 .../src/sections/problem/actions/problem.jsx  | 13 ++++++-
 .../sections/problem/components/tableData.jsx | 25 ++++++-------
 .../sections/problem/containers/dataAlarm.jsx | 36 ++++++++++++-------
 web/client/src/utils/webapi.js                |  1 +
 web/config.js                                 |  6 +++-
 web/package.json                              |  4 +--
 web/routes/attachment/index.js                |  3 +-
 9 files changed, 59 insertions(+), 32 deletions(-)

diff --git a/web/client/src/layout/actions/global.js b/web/client/src/layout/actions/global.js
index 4d019aa..a33064a 100644
--- a/web/client/src/layout/actions/global.js
+++ b/web/client/src/layout/actions/global.js
@@ -38,6 +38,7 @@ export function initApiRoot () {
             type: INIT_API_ROOT,
             payload: {
                apiRoot: res.root,
+               iotVcmpWeb:res.iotVcmpWeb,
             }
          })
       });
diff --git a/web/client/src/layout/reducers/global.js b/web/client/src/layout/reducers/global.js
index 8187eb7..600c572 100644
--- a/web/client/src/layout/reducers/global.js
+++ b/web/client/src/layout/reducers/global.js
@@ -11,6 +11,7 @@ function global (state = {
    clientHeight: 768,
    clientWidth: 1024,
    apiRoot: '',
+   iotVcmpWeb: '',
 }, action) {
    const payload = action.payload;
    switch (action.type) {
@@ -30,6 +31,7 @@ function global (state = {
       case INIT_API_ROOT:
          return Immutable.fromJS(state).merge({
             apiRoot: payload.apiRoot,
+            iotVcmpWeb: payload.iotVcmpWeb
          }).toJS();
       default:
          return state;
diff --git a/web/client/src/sections/problem/actions/problem.jsx b/web/client/src/sections/problem/actions/problem.jsx
index 5004b48..329cca0 100644
--- a/web/client/src/sections/problem/actions/problem.jsx
+++ b/web/client/src/sections/problem/actions/problem.jsx
@@ -34,7 +34,7 @@ export function putAlarmApplicationNoted (data) {   //预览状态
       data,
       actionType: 'PUT-AIARM-APPLICATIO-NNOTED',
       url: `${ApiTable.putAlarmApplicationNoted}`,
-      msg: { option: '预览失败' },
+      msg: { option: '预览' },
       reducer: { name: '' }
    });
 }
@@ -159,3 +159,14 @@ export function putAlarmVideoConfirm (data) {   //确认视频告警
       reducer: { name: '' }
    });
 }
+
+export function getVcmpAuth () {   //获取视频平台应用鉴权token
+   return dispatch => basicAction({
+      type: 'get',
+      dispatch: dispatch,
+      actionType: 'GET_VCMP_AUTH',
+      url: `${ApiTable.getVcmpAuth}`,
+      msg: { option: '获取视频平台应用鉴权token' },
+      reducer: { name: '' }
+   });
+}
diff --git a/web/client/src/sections/problem/components/tableData.jsx b/web/client/src/sections/problem/components/tableData.jsx
index 5a70c70..d560b6b 100644
--- a/web/client/src/sections/problem/components/tableData.jsx
+++ b/web/client/src/sections/problem/components/tableData.jsx
@@ -25,7 +25,6 @@ const TableData = ({ route, dispatch, actions, collectData, setSetup, exhibition
                console.log(res.payload.data)
                if (res.success) {
                   let typeData = { element: "元素异常", apiError: "接口报错 ", timeout: "加载超时" }
-                  setCount(res.payload.data?.count || 0)
                   let tableDatas = res.payload.data?.rows.map(v => ({
                      key: v.id,
                      // serialNumber: v.serialNumber,
@@ -43,14 +42,15 @@ const TableData = ({ route, dispatch, actions, collectData, setSetup, exhibition
                      confirm: v.confirm,
                   }))
                   // console.log(tableDatas);
+                  setCount(tableDatas?.length || 0);
                   setTableData(tableDatas)
                }
             })
             break;
          case 'videoAbnormal':
-            dispatch(problem.getAlarmVideoList({})).then((res) => {
+            dispatch(problem.getAlarmVideoList({ ...search, pepProjectId: '' })).then((res) => {
                if (res.success) {
-                  console.log(res);
+                  // console.log(res);
                   let tableDatas = res.payload.data?.map(v => ({
                      key: v.alarmId,
                      StructureName: v.struc,
@@ -61,12 +61,7 @@ const TableData = ({ route, dispatch, actions, collectData, setSetup, exhibition
                      updateTime: v.updateTime ? moment(v.updateTime).format("YYYY-MM-DD HH:mm:ss") : "",
                      confirmTime: v.confirmTime ? moment(v.confirmTime).format("YYYY-MM-DD HH:mm:ss") : "",
                      SourceName: v.cameraName,
-                     // AlarmGroupUnit: v.AlarmGroupUnit ? genreData.find(r => r.value == v.AlarmGroupUnit)?.name : "",
-                     // Strategy: v.AlarmGroupUnit ? genreData.find(r => r.value == v.AlarmGroupUnit)?.name : "",
-                     // type: v.AlarmGroupUnit ? genreData.find(r => r.value == v.AlarmGroupUnit)?.name : "",
-                     // AlarmCodeName: v.AlarmCodeName,
-                     // CurrentLevel: v.CurrentLevel,
-                     // detailCount: v.detailCount,
+                     yingshiToken: v.yingshiToken,
                      AlarmContent: v.statusDescribe,
                      // State: v.State,
                      station: v.station,
@@ -79,7 +74,7 @@ const TableData = ({ route, dispatch, actions, collectData, setSetup, exhibition
                      confirm: v.confirmedContent,
                      camerOnline: v.camerOnline,
                   }))
-                  console.log(tableDatas);
+                  // console.log(tableDatas);
                   setCount(tableDatas?.length || 0);
                   setTableData(tableDatas)
                }
@@ -180,7 +175,7 @@ const TableData = ({ route, dispatch, actions, collectData, setSetup, exhibition
                                     field={v.field}
                                     placeholder="项目或应用关键字"
                                     showClear
-                                    style={{ width: 115, marginRight: 16, marginBottom: 16 }} />)
+                                    style={{ width: 146, marginRight: 16, marginBottom: 16 }} />)
                               } else {
                                  frame.push(<Form.InputGroup key={v.field} label={v.name + ':'} labelPosition="left" style={{ width: 203, marginRight: 16, marginBottom: 16 }}>
                                     <Form.Select style={{ width: 88 }} field='keywordTarget' initValue='source' rules={[{ required: true, message: '请选择筛选类型' }]} showClear>
@@ -282,7 +277,7 @@ const TableData = ({ route, dispatch, actions, collectData, setSetup, exhibition
             >
                <Table
                   columns={exhibition}
-                  dataSource={route == 'useAbnormal' ? tableData.slice(query.page * query.limit, (query.page + 1) * query.limit) || [] : tableData}
+                  dataSource={route == 'useAbnormal' || route == 'videoAbnormal' ? tableData.slice(query.page * query.limit, (query.page + 1) * query.limit) || [] : tableData}
                   // dataSource={[{ key: '1' }]}
                   bordered={false}
                   empty="暂无数据"
@@ -323,7 +318,7 @@ const TableData = ({ route, dispatch, actions, collectData, setSetup, exhibition
                   <div style={{ display: 'inline-block', lineHeight: '30px', fontSize: 13 }}>勾选<span style={{ fontWeight: 400, color: '#0F7EFB', margin: '0 6px' }}>{selected.length}条</span>问题</div>
                   <Button onClick={() => {
                      if (checkAll) {
-                        setSelected((route == 'useAbnormal' ? tableData.slice(query.page * query.limit, (query.page + 1) * query.limit) || [] : tableData)?.map(v => {
+                        setSelected((route == 'useAbnormal' || route == 'videoAbnormal' ? tableData.slice(query.page * query.limit, (query.page + 1) * query.limit) || [] : tableData)?.map(v => {
                            if (['videoAbnormal', 'useAbnormal'].includes(route)) {
                               if (!v.confirmTime) {
                                  return v.key
@@ -346,11 +341,11 @@ const TableData = ({ route, dispatch, actions, collectData, setSetup, exhibition
                </div>
                {count > 0 ? <div style={{ display: 'flex', }}>
                   <span style={{ lineHeight: "30px", fontSize: 13 }}>
-                     共{route == 'useAbnormal' ? tableData.length : count}个问题
+                     共{count}个问题
                   </span>
                   <Pagination
                      className="22"
-                     total={route == 'useAbnormal' ? tableData.length : count}
+                     total={count}
                      showSizeChanger
                      currentPage={(query?.page || 0) + 1}
                      pageSizeOpts={[10, 20, 30, 40]}
diff --git a/web/client/src/sections/problem/containers/dataAlarm.jsx b/web/client/src/sections/problem/containers/dataAlarm.jsx
index e47cf20..4add6e8 100644
--- a/web/client/src/sections/problem/containers/dataAlarm.jsx
+++ b/web/client/src/sections/problem/containers/dataAlarm.jsx
@@ -14,7 +14,7 @@ import { request } from 'screenfull';
 import { useRef } from 'react';
 import { render } from 'less';
 
-const DataAlarm = ({ match, dispatch, actions, user, loading, socket }) => {
+const DataAlarm = ({ match, dispatch, actions, user, loading, socket, iotVcmpWeb }) => {
    let route = match.url.substring(match.url.lastIndexOf("/") + 1, match.url.length)
 
    const { problem } = actions
@@ -36,6 +36,7 @@ const DataAlarm = ({ match, dispatch, actions, user, loading, socket }) => {
    const [tableData, setTableData] = useState([])  //表格数据
    const [videoModal, setVideoModal] = useState(false)  //视频播放弹框
    const [videoData, setVideoData] = useState({})  //视频播放参数
+   const [videoToken, setVideoToken] = useState()  //视频token
 
 
 
@@ -57,9 +58,14 @@ const DataAlarm = ({ match, dispatch, actions, user, loading, socket }) => {
             : "";
       }
       attribute(tableType[route], route);
+
+      //视频平台token
+      dispatch(problem.getVcmpAuth({})).then((res) => {
+         if (res.success) setVideoToken(res.payload.data?.token)
+      })
    }, [])
 
-   // console.log(selected);
+   // console.log(videoData);
 
    //搜索结构      
    const collectData = {
@@ -277,7 +283,7 @@ const DataAlarm = ({ match, dispatch, actions, user, loading, socket }) => {
       },
       { name: '设备厂家', sort: 10, value: 'venderName', render: (_, r, index) => r.platform ? '未知' : r.venderName },
       { name: '通道号', sort: 10.1, value: 'cameraChannelNo' },
-      { name: '系列号', sort: 10.2, value: 'cameraSerialNo' },
+      { name: '序列号', sort: 10.2, value: 'cameraSerialNo' },
       {
          name: '接入方式', sort: 9, value: 'platform', render: (_, r, index) => {
             let accessType = { yingshi: "萤石云", nvr: "NVR", ipc: "IPC", cascade: "级联" }
@@ -288,7 +294,12 @@ const DataAlarm = ({ match, dispatch, actions, user, loading, socket }) => {
       { name: 'URL地址', sort: 16, value: 'url' },
       { name: '异常类型', sort: 6, value: 'type' },
       { name: '解决方案', sort: 17, value: 'resolve', render: (_, r, index) => r.resolve?.map(v => <div key={v.resolve + v.id} style={{ lineHeight: "22px" }}>{v.resolve}</div>) },
-      { name: '在离线', sort: 18, value: 'camerOnline' },
+      {
+         name: '在离线', sort: 18, value: 'camerOnline', render: (_, r, index) => {
+            let data = { ON: '在线', ONLINE: "在线", OFF: "离线" }
+            return data[r.camerOnline] || '未知'
+         }
+      },
       {
          name: '操作', sort: 25, value: 'text', render: (_, r, index) => {
             return <div style={{ width: 195 }}>
@@ -312,7 +323,7 @@ const DataAlarm = ({ match, dispatch, actions, user, loading, socket }) => {
                      <Button theme='borderless' style={{ width: 65 }} disabled>已派单</Button>
                      <Button theme='borderless' style={{ width: 65 }} onClick={() => {
                         setVideoModal(true)
-                        setVideoData({ channeNo: r.cameraChannelNo, serialNo: r.cameraSerialNo, type: r.platform })
+                        setVideoData({ channeNo: r.cameraChannelNo, serialNo: r.cameraSerialNo, type: r.platform, yingshiToken: r.yingshiToken })
                      }}>播放</Button>
                   </> : ""
                }
@@ -322,7 +333,6 @@ const DataAlarm = ({ match, dispatch, actions, user, loading, socket }) => {
    ]
 
 
-
    const attribute = (name, route) => {
       let arr = localStorage.getItem(name)
          ? JSON.parse(localStorage.getItem(name))
@@ -505,12 +515,13 @@ const DataAlarm = ({ match, dispatch, actions, user, loading, socket }) => {
             <div style={{ width: 918, height: 460, marginLeft: -24 }}>
                <iframe
                   allowFullScreen
-                  src={`https://mediaconsole.ngaiot.com/video_play_cross?slideDown=true&videoObj=${encodeURIComponent(JSON.stringify({
-                     channelNo: 1,
-                     content: ['5442542542', '452345', '234524525'],
-                     serialNo: "F61504020",
-                     type: "yingshi",
-                     yingshiToken: "at.7tj6k9mzcwmn112xag96e23tcdsta8nn-7p2qvqv6zq-1k500nr-tsd9bn01o"
+                  src={`${iotVcmpWeb}/video_play_cross?videoObj=${encodeURIComponent(JSON.stringify({
+                     channelNo: videoData.channeNo,
+                     // content: ['5442542542', '452345', '234524525'],
+                     serialNo: videoData.serialNo,
+                     type: videoData.type,
+                     yingshiToken: videoData.yingshiToken,
+                     videoToken: videoToken,
                      // type: 'cascade',
                      // serialNo: '34020000001310000003', // 设备序列号 必须
                      // topSerialNo: '34020000001110000079', // 设备顶级序列号 必须
@@ -548,6 +559,7 @@ function mapStateToProps (state) {
       // loading: members.isRequesting,
       user: auth.user,
       actions: global.actions,
+      iotVcmpWeb: global.iotVcmpWeb,
       // members: members.data,
       // socket: webSocket.socket
    }
diff --git a/web/client/src/utils/webapi.js b/web/client/src/utils/webapi.js
index 967361b..784a070 100644
--- a/web/client/src/utils/webapi.js
+++ b/web/client/src/utils/webapi.js
@@ -46,6 +46,7 @@ export const ApiTable = {
    getAlarmVideoList: 'alarm/video/list',  //查询视频告警列表
    getAlarmVideoDeviceKind: 'alarm/video/device_kind',  //查询视频设备类型
    putAlarmVideoConfirm: 'alarm/video/confirm',    //确认视频告警信息
+   getVcmpAuth: 'vcmp/auth',         // 获取视频平台应用鉴权token
 
 
 };
diff --git a/web/config.js b/web/config.js
index 8628c0c..2ee97e6 100644
--- a/web/config.js
+++ b/web/config.js
@@ -15,6 +15,8 @@ args.option(['u', 'api-url'], 'webapi的URL');
 args.option('apiPomsUrl', 'webapi的URL 外网可访问');
 args.option('apiAnxinyunUrl', '安心云 api');
 args.option('apiEmisUrl', '企业管理 api');
+args.option('iotVcmpWeb', 'IOT 视频服务');
+
 // 七牛
 args.option('qnak', 'qiniuAccessKey');
 args.option('qnsk', 'qiniuSecretKey');
@@ -27,6 +29,7 @@ const API_URL = process.env.API_URL || flags.apiUrl;
 const API_POMS_URL = process.env.API_POMS_URL || flags.apiPomsUrl;
 const API_EMIS_URL = process.env.API_EMIS_URL || flags.apiEmisUrl;
 const API_ANXINYUN_URL = process.env.API_ANXINYUN_URL || flags.apiAnxinyunUrl;
+const IOT_VIDEO_WEB = process.env.IOT_VIDEO_WEB || flags.iotVcmpWeb;
 
 // 七牛
 const ANXINCLOUD_QINIU_AK = process.env.ANXINCLOUD_QINIU_ACCESSKEY || flags.qnak;
@@ -38,7 +41,7 @@ const ANXINCLOUD_QINIU_DOMAIN_QNDMN_RESOURCE = process.env.ANXINCLOUD_QINIU_DOMA
 if (
    !API_URL
    || !API_ANXINYUN_URL
-   || !ANXINCLOUD_QINIU_AK || !ANXINCLOUD_QINIU_SK || !ANXINCLOUD_QINIU_BUCKET_RESOURCE || !ANXINCLOUD_QINIU_DOMAIN_QNDMN_RESOURCE) {
+   || !ANXINCLOUD_QINIU_AK || !ANXINCLOUD_QINIU_SK || !ANXINCLOUD_QINIU_BUCKET_RESOURCE || !ANXINCLOUD_QINIU_DOMAIN_QNDMN_RESOURCE || !IOT_VIDEO_WEB) {
    console.log('缺少启动参数，异常退出');
    args.showHelp();
    process.exit(-1);
@@ -81,6 +84,7 @@ const product = {
       entry: require('./routes').entry,
       opts: {
          apiUrl: API_POMS_URL,
+         iotVcmpWeb: IOT_VIDEO_WEB,
          staticRoot: './client',
          qiniu: {
             fetchUrl: '/_file-server',
diff --git a/web/package.json b/web/package.json
index 9469652..621c73b 100644
--- a/web/package.json
+++ b/web/package.json
@@ -7,7 +7,7 @@
       "test": "mocha",
       "start-vite": "cross-env NODE_ENV=developmentVite npm run start-params",
       "start": "cross-env NODE_ENV=development npm run start-params",
-      "start-params": "node server -p 5600 -u http://localhost:4600 --apiPomsUrl http://localhost:4600 --apiAnxinyunUrl http://10.8.30.112:4100 --apiEmisUrl http://10.8.30.112:14000  --qnak XuDgkao6cL0HidoMAPnA5OB10Mc_Ew08mpIfRJK5 --qnsk yewcieZLzKZuDfig0wLZ9if9jKp2P_1jd3CMJPSa --qnbkt dev-highways4good --qndmn http://rhvqdivo5.hn-bkt.clouddn.com",
+      "start-params": "node server -p 5600 -u http://localhost:4600 --apiPomsUrl http://localhost:4600 --apiAnxinyunUrl http://10.8.30.112:4100 --apiEmisUrl http://10.8.30.112:14000  --qnak XuDgkao6cL0HidoMAPnA5OB10Mc_Ew08mpIfRJK5 --qnsk yewcieZLzKZuDfig0wLZ9if9jKp2P_1jd3CMJPSa --qnbkt dev-highways4good --qndmn http://rhvqdivo5.hn-bkt.clouddn.com --iotVcmpWeb https://mediaconsole.ngaiot.com",
       "deploy": "export NODE_ENV=production&& npm run build && node server",
       "build-dev": "cross-env NODE_ENV=development&&webpack --config webpack.config.js",
       "build": "cross-env NODE_ENV=production&&webpack --config webpack.config.prod.js"
@@ -81,4 +81,4 @@
       "webpack-dev-server": "^3.11.2",
       "webpack-hot-middleware": "^2.25.0"
    }
-}
+}
\ No newline at end of file
diff --git a/web/routes/attachment/index.js b/web/routes/attachment/index.js
index abe148f..18621d8 100644
--- a/web/routes/attachment/index.js
+++ b/web/routes/attachment/index.js
@@ -19,11 +19,12 @@ module.exports = {
    entry: function (app, router, opts) {
 
       const getApiRoot = async function (ctx) {
-         const { apiUrl, } = opts;
+         const { apiUrl, iotVcmpWeb } = opts;
 
          ctx.status = 200;
          ctx.body = {
             root: apiUrl,
+            iotVcmpWeb: iotVcmpWeb,
          };
       };