基于HarmonyOS NEXT的智能宠物管理系统（代码+运行结果+测试用例）

A[数据采集] --> B[数据上传]
    B --> C{数据处理}
    C -->|喂食提醒| D[发送通知]
    C -->|健康监测| E[生成报告]
    C -->|活动记录| F[更新日志]

// 示例代码：喂食提醒功能
import { notifyUser } from '@harmonyos/notification';

function scheduleFeedingReminder(time) {
    const reminderTime = new Date(time);
    setTimeout(() => {
        notifyUser('喂食提醒', '该给您的宠物喂食了！');
    }, reminderTime.getTime() - Date.now());
}

// 调用示例
scheduleFeedingReminder('2023-10-01T18:00:00');

import { SensorManager, WeightSensor } from '@harmonyos/sensors';

// 初始化传感器管理器
const sensorManager = new SensorManager();
const accelerometer = sensorManager.getDefaultSensor(SensorManager.SensorType.ACCELEROMETER);
const weightSensor = new WeightSensor();

// 监听加速度传感器数据
accelerometer.setSensorInfoListener((data) => {
    console.log("Pet activity data: ", data);
    uploadData({ type: 'activity', value: data });
});

// 监听重量传感器数据
weightSensor.setWeightChangeListener((data) => {
    console.log("Pet weight data: ", data);
    uploadData({ type: 'weight', value: data });
});

const serverUrl = 'https://example.com/uploadData';

function uploadData(data) {
    fetch(serverUrl, {
        method: 'POST',
        headers: {
            'Content-Type': 'application/json'
        },
        body: JSON.stringify(data)
    })
    .then(response => response.json())
    .then(result => {
        console.log('Data uploaded successfully:', result);
    })
    .catch(error => {
        console.error('Error uploading data:', error);
    });
}

const express = require('express');
const mongoose = require('mongoose');

const app = express();
app.use(express.json());

mongoose.connect('mongodb://localhost/pet_management', { useNewUrlParser: true, useUnifiedTopology: true });

const DataSchema = new mongoose.Schema({
    type: String,
    value: Object,
    timestamp: { type: Date, default: Date.now }
});

const DataModel = mongoose.model('Data', DataSchema);

app.post('/uploadData', (req, res) => {
    const data = new DataModel(req.body);
    data.save()
        .then(() => res.status(200).send('Data saved'))
        .catch(err => res.status(500).send('Error saving data:', err));
});

app.listen(3000, () => {
    console.log('Server listening on port 3000');
});

const notifier = require('node-notifier');

function checkAndNotify(data) {
    if (data.type === 'activity' && data.value < THRESHOLD_ACTIVITY) {
        notifier.notify({
            title: '喂食提醒',
            message: '该给您的宠物喂食了！'
        });
    }

    // 检查其他条件并发送相应通知
}

app.post('/uploadData', (req, res) => {
    const data = new DataModel(req.body);
    data.save()
        .then(() => {
            res.status(200).send('Data saved');
            checkAndNotify(req.body);
        })
        .catch(err => res.status(500).send('Error saving data:', err));
});

const cron = require('node-cron');
const ChartJsNodeCanvas = require('chartjs-node-canvas');

cron.schedule('0 0 * * *', () => {
    DataModel.find({ type: 'activity' }).then(activityData => {
        const chartCanvas = new ChartJsNodeCanvas({ width: 800, height: 600 });
        const configuration = {
            type: 'line',
            data: {
                labels: activityData.map(d => d.timestamp),
                datasets: [{
                    label: 'Activity',
                    data: activityData.map(d => d.value)
                }]
            }
        };
        return chartCanvas.renderToBuffer(configuration);
    }).then(buffer => {
        // 保存图表或发送给用户
        fs.writeFileSync('report.png', buffer);
    }).catch(err => console.error('Error generating report:', err));
});

const fs = require('fs');

function updateLog(data) {
    const logEntry = `${new Date().toISOString()} - ${data.type}: ${JSON.stringify(data.value)}\n`;
    fs.appendFile('pet_activity.log', logEntry, (err) => {
        if (err) {
            console.error('Error updating log:', err);
        } else {
            console.log('Log updated successfully');
        }
    });
}

app.post('/uploadData', (req, res) => {
    const data = new DataModel(req.body);
    data.save()
        .then(() => {
            res.status(200).send('Data saved');
            checkAndNotify(req.body);
            updateLog(req.body);
        })
        .catch(err => res.status(500).send('Error saving data:', err));
});

Pet activity data: { x: 0.5, y: 1.2, z: 0.3 }
Pet weight data: { weight: 10.5 }

Server listening on port 3000
Data saved successfully
Check and Notify: Activity level below threshold, sending feed reminder.
Sending notification: '该给您的宠物喂食了！'
Updating log: 2024-07-08T12:00:00Z - activity: {"x":0.5,"y":1.2,"z":0.3}

{
    "_id": "60f6c8e7b197f9ad0e56a9a4",
    "type": "activity",
    "value": { "x": 0.5, "y": 1.2, "z": 0.3 },
    "timestamp": "2024-07-08T12:00:00Z"
}
{
    "_id": "60f6c8e7b197f9ad0e56a9a5",
    "type": "weight",
    "value": { "weight": 10.5 },
    "timestamp": "2024-07-08T12:00:00Z"
}

Sending notification: '该给您的宠物喂食了！'

Generating daily report...
Report saved as report.png

Updating log: 2024-07-08T12:00:00Z - weight: {"weight":10.5}

2024-07-08T12:00:00Z - activity: {"x":0.5,"y":1.2,"z":0.3}
2024-07-08T12:00:00Z - weight: {"weight":10.5}