新增天气查询

Author: CLOUDERHEM

.gitignore

@@ -1,4 +1,7 @@
 node_modules
 .vscode
 data
-config.js
+.idea
+package-lock.json
+Dockerfile
+docker-compose.yaml

README.md

@@ -24,7 +24,8 @@
 如果你已经清楚了相关配置，那么启动机器人只需要以下语句：
 
 ```shell
-node main 1770874035 
+node main.js 1770874035
+# 使用node main可能导致无限重启 
 # 后面是机器人的账号，当然你可以结合原项目文档自行配置
 ```
 

config.js

@@ -0,0 +1,41 @@
+"use strict";
+// 将此文件更名为config.js才能生效哦
+
+module.exports = {
+
+    //通用配置
+    general: {
+        platform:           1,      //1:安卓手机 2:aPad 3:安卓手表 4:MacOS 5:iPad
+        debug:              false,  //开启debug
+        use_cqhttp_notice:  true,   //是否使用cqhttp标准的notice事件格式
+
+        host:               "0.0.0.0",  //监听主机名
+        port:               5700,       //端口
+        use_http:           false,      //启用http
+        use_ws:             false,      //启用正向ws，和http使用相同地址和端口
+        access_token:       "",         //访问api的token
+        secret:             "",         //上报数据的sha1签名密钥
+        post_timeout:       30,         //post超时时间(秒)
+        post_message_format:"array",    //"string"或"array"
+        enable_cors:        false,      //是否允许跨域请求
+        enable_heartbeat:   false,      //是否启用ws心跳
+        heartbeat_interval: 15000,      //ws心跳间隔(毫秒)
+        rate_limit_interval:500,        //使用_rate_limited后缀限速调用api的排队间隔时间(毫秒)
+        event_filter:       "",         //json格式的事件过滤器文件路径
+        post_url: [ //上报地址，可以添加多个url
+            // "http://your.address.com:80",
+        ],
+        ws_reverse_url: [ //反向ws地址，可以添加多个url
+            // "ws://your.address.com:8080",
+        ],
+        ws_reverse_reconnect_interval: 3000, //反向ws断线重连间隔(毫秒)，设为负数直接不重连
+        ws_reverse_reconnect_on_code_1000: true, //反向ws是否在关闭状态码为1000的时候重连
+    },
+
+    //每个账号的单独配置(用于覆盖通用配置)
+};
+
+// 安全注意：
+// 监听0.0.0.0表示监听网卡上的所有地址。如果你的机器可以通过公网ip直接访问，同时你也没有设定access_token，则被认为是极不安全的。
+// 你应该知道这样做会导致以下后果：任何人都可以无限制地访问你的Bot的所有API接口。
+// 如果只需要在本地访问，建议将监听地址改为localhost。需要通过公网访问，你最好设定access_token。

lib/core.js

@@ -203,17 +203,9 @@ function createBot() {
             data.message = data.raw_message;
         if (data.message_type === 'group') { // 群聊
             messageHandler.messageGroupHandler(data, bot)
-        } else if (data.message_type === 'private') { // 私聊
-            messageHandler.messagePrivateHandler(data, bot)
-        } 
-        // console.log(data)
+        }
         dipatch(data);
     });
-    // bot.on('message.private', (data) => {
-    //     if (config.post_message_format === 'string')
-    //         data.message = data.raw_message
-        
-    // })
 }
 
 /**
@@ -320,7 +312,7 @@ function createServer() {
 
 /**
  * ws连接建立
- * @param {WebSocket} ws 
+ * @param {WebSocket} ws
  */
 function onWSOpen(ws) {
     ws.on("message", (data)=>{
@@ -383,7 +375,7 @@ function createWSClient(url, headers) {
 
 /**
  * 收到http响应
- * @param {http.ServerResponse} res 
+ * @param {http.ServerResponse} res
  */
 function onHttpRes(event, res) {
     let data = [];
@@ -400,8 +392,8 @@ function onHttpRes(event, res) {
 
 /**
  * 收到http请求
- * @param {http.ClientRequest} req 
- * @param {http.ServerResponse} res 
+ * @param {http.ClientRequest} req
+ * @param {http.ServerResponse} res
  */
 async function onHttpReq(req, res) {
     res.setHeader("Content-Type", "application/json; charset=utf-8");
@@ -448,7 +440,7 @@ async function onHttpReq(req, res) {
 
 /**
  * 收到ws消息
- * @param {WebSocket} ws 
+ * @param {WebSocket} ws
  */
 async function onWSMessage(ws, data) {
     debug(`收到WS消息: ` + data);

lib/message.js

@@ -1,9 +1,11 @@
+const axios = require("axios");
 // 消息收发功能，分为群发和私聊
 
 // 允许的群组(白名单)
 const groups = [
     '828192817',  // 2022乐程招新群
     '742958634', // 测试群
+    '575626767'// dev
 ]
 
 
@@ -68,13 +70,13 @@ const messageGroupConfig = [
             })
         }
     },
-    {    
+    {
         keywords: '列表',
         reply: [
             {
                 type: "text",
                 data: {
-                    text: `@并回复以下关键字：\n1. 乐程是什么\n2. 丢骰子\n3. 签到`
+                    text: `@并回复以下关键字：\n1. 乐程是什么\n2. 丢骰子\n3. 签到\n4.天气`
                 }
             }
         ]
@@ -85,7 +87,7 @@ const messageGroupConfig = [
             {
                 type: "text",
                 data: {
-                    text: `@并回复以下关键字：\n1. 乐程是什么\n2. 丢骰子\n3. 签到`
+                    text: `@并回复以下关键字：\n1. 乐程是什么\n2. 丢骰子\n3. 签到\n4.天气`
                 }
             }
         ],
@@ -94,18 +96,56 @@ const messageGroupConfig = [
                 // 这里还要处理一下数据，不然有点问题
                 bot.sendGroupMsg(828192817, d.message)
             })
-        } 
+        }
+    },
+    {
+        keywords: '你是谁',
+        reply: [
+            {
+                type: "text",
+                data: {
+                    text: `我是乐程机器人人人人人人人人人人人人人人人人人人人人人人人人人人人人人人人`
+                }
+            }
+        ]
+    },
+    {
+        keywords: '天气',
+        reply: [],
+        callback: (data, bot) => {
+
+            return new Promise((resolve, reject) => {
+
+                axios.get("http://aider.meizu.com/app/weather/listWeather?cityIds=101270101").then(res => {
+                    let s = []
+                    let value = res.data.value[0]
+
+                    s.push(value.city + '气温 ' + value.realtime.temp + ' °C')
+                    value.indexes.forEach(e => {
+                        if (e.content !== '' && e.content !== undefined) {
+                            s.push(e.content)
+                        }
+                    })
+                    console.log(s.join('\n\n'))
+                    resolve(s.join('\n\n'))
+                })
+
+            })
+        }
     }
+
 ]
 
 
 // 处理群发
 function messageGroupHandler(data, bot) {
-    if(data.message[0].type === 'at' && data.atme === true) { // 先要@自己才能触发
-        if(groups.includes(data.group_id.toString())) { // 如果在白名单群组里面
-            for(let one of messageGroupConfig) { // 遍历每个配置，观察里面是否有匹配的关键字
-                if(data.raw_message.trim().indexOf(one.keywords) != -1) { // 匹配成功
-                    if(one.callback) { // callback回调处理数据后回复
+    console.log(data)
+    console.log(bot)
+    if (data.message[0].type === 'at' && data.atme === true) { // 先要@自己才能触发
+        if (groups.includes(data.group_id.toString())) { // 如果在白名单群组里面
+            for (let one of messageGroupConfig) { // 遍历每个配置，观察里面是否有匹配的关键字
+                if (data.raw_message.trim().indexOf(one.keywords) !== -1) { // 匹配成功
+                    if (one.callback) { // callback回调处理数据后回复
                         one.callback(data, bot).then((res) => {
                             data.reply(res)
                         })
@@ -121,13 +161,7 @@ function messageGroupHandler(data, bot) {
     }
 }
 
-// 处理私发
-function messagePrivateHandler(data) {
-
-}
-
 module.exports = {
-    messageGroupHandler,
-    messagePrivateHandler
+    messageGroupHandler
 }
 

main.js

@@ -11,18 +11,16 @@ try {
     require("./config.js");
 } catch (e) {
     console.log(e);
-    console.log(`
-未找到config.js文件或配置有语法错误
-`);
+    console.log(`未找到config.js文件或配置有语法错误`);
     process.exit(0);
 }
 
-try {
-    console.log(`正在检查&更新内核版本..`);
-    require("child_process").execSync("npm up --no-save", {stdio: "ignore"});
-} catch (e) {
-    console.log(`"npm up --no-save"执行失败，你可能需要手动执行。`);
-}
+// try {
+//     console.log(`正在检查&更新内核版本..`);
+//     require("child_process").execSync("npm up --no-save", {stdio: "ignore"});
+// } catch (e) {
+//     console.log(`"npm up --no-save"执行失败，你可能需要手动执行。`);
+// }
 
 // 引入核心依赖
 require("oicq");