123

.gitignore

@@ -0,0 +1 @@
+nohup.out

src/3collect_and_create_data/collect_and_create_data_server.js

@@ -3,6 +3,7 @@ const video_product_controllers = require("../data_manager/Controllers/video_pro
 const video_applet_product_controllers = require("../data_manager/Controllers/video_applet_product_controllers")
 const axios = require('axios');
 const filter_data_controllers = require('../data_manager/Controllers/filter_data_controllers');
+const tools = require("../../tools");
 const CMD = {}
 const 视频id = 0;
 const 视频链接 = 1;
@@ -73,7 +74,7 @@ CMD.init = function(tg_config){
 
 CMD.finish_create_link = function(data){
     // console.log("finish_create_link:",data)
-    let url = 'https://clipvideoup.hainanmlwl.com/sapi/video_product_material/supdate';
+    let url = tools.getSupdate()+'/sapi/video_product_material/supdate';
     const formData = new FormData();
     // formData.append('dy_id', data.xml[视频id]);
     // formData.append('dy_url', data.xml[视频链接]);

src/data_manager/Controllers/filter_data_controllers.js

@@ -15,7 +15,7 @@ class filter_data_controllers {
             }
 
             const video_id = params.video_id;
-            const filterData = await filter_data_model.findOne({ id: video_id });
+            const filterData = await filter_data_model.findOne({ video_id: video_id });
 
             if (!filterData) {
                 return {

src/data_manager/Database.js

@@ -1,11 +1,6 @@
 const mysql = require('mysql2/promise');
-const config = {
-    host: '127.0.0.1',      // 数据库主机名
-    user: 'root',           // 数据库用户名
-    port: 3306,
-    password: 'p0LTZh&CjMl2023',   // 数据库密码
-    database: 'ml_oceanengine'     // 要连接的数据库名
-};
+const tools = require('../../tools');
+const config = tools.getDataBaseConfig();
 
 class Database {
     constructor() {

src/data_manager/DatabaseTask.js

@@ -1,12 +1,6 @@
 const mysql = require('mysql2/promise');
-const config = {
-    host: '127.0.0.1',      // 数据库主机名
-    user: 'root',           // 数据库用户名
-    port: 3306,
-    password: 'p0LTZh&CjMl2023',   // 数据库密码
-    database: 'video_task'     // 要连接的数据库名
-
-};
+const tools = require('../../tools');
+const config =tools.getTaskDataBaseConfig();
 
 class DatabaseTask {
     constructor() {

src/use_mysql.js

@@ -1,13 +1,8 @@
 const mysql = require("mysql2");
+const tools = require("../tools");
 const sql_help ={}
 const status = false;
-const connection = mysql.createConnection({
-  host: '127.0.0.1',      // 数据库主机名
-  user: 'root',           // 数据库用户名
-  port: 3306,
-  password: 'p0LTZh&CjMl2023',   // 数据库密码
-  database: 'ml_oceanengine'     // 要连接的数据库名
-});
+const connection = mysql.createConnection(tools.getDataBaseConfig());
 
 
 sql_help.isHaveBook=function(book_id,call_back){

src/use_task_mysql.js

@@ -1,13 +1,8 @@
 const mysql = require("mysql2");
+const tools = require("../tools");
 const sql_help ={}
 const status = false;
-const connection = mysql.createConnection({
-  host: '127.0.0.1',      // 数据库主机名
-  user: 'root',           // 数据库用户名
-  port: 3306,
-  password: 'p0LTZh&CjMl2023',   // 数据库密码
-  database: 'video_task'     // 要连接的数据库名
-});
+const connection = mysql.createConnection(tools.getTaskDataBaseConfig());
 
 
 sql_help.isHaveBook=function(book_id,call_back){

tools.js

@@ -2,6 +2,7 @@ const crypto = require('crypto');
 class tools {
     constructor(redis_help){
         this.redis_help = redis_help
+        this.isDebug = false
     }
 
     init(){
@@ -87,6 +88,54 @@ class tools {
     async getHyToken (){
         return await this.redis_help.getKeyValue("hei_yan_token")
     }
+
+    getSupdate(){ //插入素材域名
+        if(this.isDebug){
+            return 'https://clipvideoup.hainanmlwl.com'
+        }else{
+            return 'http://192.168.0.165:9606'
+        }
+    }
+
+    getDataBaseConfig(){
+        if(this.isDebug){
+            return {
+                host: '127.0.0.1',      // 数据库主机名
+                user: 'root',           // 数据库用户名
+                port: 3306,
+                password: 'p0LTZh&CjMl2023',   // 数据库密码
+                database: 'ml_oceanengine'     // 要连接的数据库名
+              }
+        }else{
+            return {
+                host: 'mr-dsq824ev2pqxbr6rhw.rwlb.rds.aliyuncs.com',      // 数据库主机名
+                user: 'zdroot',           // 数据库用户名
+                port: 3306,
+                password: 'p0LTZh&CjMl2023',   // 数据库密码
+                database: 'ml_oceanengine'     // 要连接的数据库名
+              }
+        }
+    }
+
+    getTaskDataBaseConfig(){
+        if(this.isDebug){
+            return {
+                host: '127.0.0.1',      // 数据库主机名
+                user: 'root',           // 数据库用户名
+                port: 3306,
+                password: 'p0LTZh&CjMl2023',   // 数据库密码
+                database: 'ml_oceanengine'     // 要连接的数据库名
+              }
+        }else{
+            return {
+                host: 'mr-dsq824ev2pqxbr6rhw.rwlb.rds.aliyuncs.com',      // 数据库主机名
+                user: 'zdroot',           // 数据库用户名
+                port: 3306,
+                password: 'p0LTZh&CjMl2023',   // 数据库密码
+                database: 'video_task'     // 要连接的数据库名
+              }
+        }
+    }
 }
 
 module.exports = new tools(require('./src/use_redis'));