明树Git Lab

Skip to content

L
letian_backend
Commit 197ccad1 authored by zengfanpei's avatar zengfanpei
Browse files
Options

update

parent 27254597
Hide whitespace changes
Inline Side-by-side
Showing with 167 additions and 81 deletions
.gitignore
View file @ 197ccad1
......@@ -3,4 +3,5 @@ node_modules/
package-lock.json
.vscode
test/
test.js
public/avatar
\ No newline at end of file
db/models/collectIPS.js
View file @ 197ccad1
......@@ -89,9 +89,10 @@ const collectInsectPestSituationSchema = new Schema({
comment: "上一次标注后的图片(压缩后)",
},
/* 图片识别结果 */
/* 识别结果 不管哪一种形式，只要结果确认有效则写入，为空则表示此条数据无效，后续需要根据业务定期处理这类数据 */
cameraRecognition: {
type: String
type: String,
default: null,
},
createdAt: {
......
ecosystem.config.js 0 → 100644
View file @ 197ccad1
let curDate = new Date();
let curDateStr = curDate.getFullYear() + "" + String(curDate.getMonth() + 1).padStart(2, '0') + "" + curDate.getDate();
module.exports = {
apps: [{
name: "letian",
script: 'server.js',
watch: true,
ignore_watch: ['node_modules', 'logs'],
env_dev: {
NODE_ENV: "dev"
},
log_date_format: "YYYY-MM-DD HH:mm:ss",
out_file: `logs/${curDateStr}.log`,
error_file: `logs/${curDateStr}.log`,
}]
};
module/collectIPSModule.js
View file @ 197ccad1
......@@ -40,66 +40,128 @@ async function insertHQData(data) {
}
}
/**
* 复杂版本 直接上传图片 获取结果
* @param {*} data
*/
// async function handleIPSResult(data) {
// try {
// const url = sysConfig.device.getInsectNewCollectionResult;
// const token = sysConfig.device.token;
// const userName = sysConfig.device.userName;
// // 1. 上传结果照片 获取结果
// let formData = new FormData();
// let imgUrl = sysConfig.device.fileBaseUrl + data.downloadUrl;
// formData.append('token', token);
// formData.append('userName', userName);
// formData.append('deviceNumber', data.deviceNumber);
// let imgStream = await httpRequest({ url: imgUrl, method: 'GET', responseType: "stream" });
// console.log(imgStream)
// if (imgStream.status) {
// formData.append('img', imgStream.data);
// const result = await httpRequest({
// url,
// method: "POST",
// headers: { "Content-Type": "mutipart/form-data" },
// data: formData
// });
// if (result.status) {
// // 需要处理一张识别的种类表 获取其对应的方案 成功
// // await DB.CollectIPS.updateOne({_id: data._id}, {cameraRecognition});
// let retData = result.data && result.data.data || "";
// let retArr = retData && retData.results.split(',') || [];
// for (let index = 0; index < retArr.length; index++) {
// const element = retArr[index];
// let eleArr = element.split(':');
// let name = String(eleArr[0]).trim();
// // 记录虫子类型
// let bugType = await DB.CollectIPSType.findOneAndUpdate({ name }, { name }, { upsert: true });
// //获取防止建议---此处建议不从远端取，在本系统根据虫子种类维护建议即可
// let preInRet = await httpRequest({
// url: sysConfig.device.getPreventionToInsectName,
// method: "GET",
// params: { token, userName, name },
// });
// let plan;
// if (preInRet && preInRet.status) {
// let pData = preInRet.data && preInRet.data.data || [];
// for (let pi = 0; pi < pData.length; pi++) {
// const pir = pData[pi];
// plan = await DB.CollectIPSPlan.findOneAndUpdate({ name }, pir, { upsert: true });
// }
// }
// // 记录识别的每一次识别的 虫子 的种类 和 数量
// // 此处暂时 每一次单独记录 不是对每一天做累加
// await DB.CollectIPSResult.create({
// deviceNumber: data.deviceNumber,
// name,
// // $inc: {count: 11},
// count: element.newCount,
// time: data.time || data.newTime,
// type: bugType && bugType._id,
// plan: plan && plan._id,
// data: data._id,
// });
// }
// await DB.CollectIPS.updateOne({ _id: data._id }, { cameraRecognition: JSON.stringify(result) });
// }
// }
// } catch (error) {
// console.log(error)
// }
// }
/**
* 直接利用硬件的信息结果
* @param {*} data
*/
async function handleIPSResult(data) {
try {
const url = sysConfig.device.getInsectNewCollectionResult;
const token = sysConfig.device.token;
const userName = sysConfig.device.userName;
// 1. 上传结果照片 获取结果
let formData = new FormData();
let imgUrl = sysConfig.device.fileBaseUrl + data.downloadUrl;
formData.append('token', token);
formData.append('userName', userName);
formData.append('deviceNumber', data.deviceNumber);
let imgStream = await httpRequest({ url: imgUrl, method: 'GET', responseType: "stream" });
if (imgStream.status) {
formData.append('img', imgStream);
const result = await httpRequest({
url,
method: "POST",
headers: { "Content-Type": "mutipart/form-data" },
data: formData
});
if (result.status) {
// 需要处理一张识别的种类表 获取其对应的方案 成功
// await DB.CollectIPS.updateOne({_id: data._id}, {cameraRecognition});
let retData = result.data;
let retArr = retData.split(',');
for (let index = 0; index < retArr.length; index++) {
const element = retArr[index];
let eleArr = element.split(':');
let name = String(eleArr[0]).trim();
// 记录虫子类型
let bugType = await DB.CollectIPSType.findOneAndUpdate({ name }, { name }, { upsert: true });
//获取防止建议---此处建议不从远端取，在本系统根据虫子种类维护建议即可
let preInRet = await httpRequest({
url: sysConfig.device.getPreventionToInsectName,
method: "POST",
data: { token, userName, name },
});
let plan;
if (preInRet && preInRet.status) {
preInRet.data = preInRet.data || [];
for (let pi = 0; pi < preInRet.data.length; pi++) {
const pir = preInRet.data[pi];
plan = await DB.CollectIPSPlan.findOneAndUpdate({ name }, pir, { upsert: true });
}
if (data.results != "数据提取成功" && data.results.includes(":")) {
let retArr = data.results.split(',') || [];
for (let index = 0; index < retArr.length; index++) {
const element = retArr[index];
let eleArr = element.split(':');
let name = String(eleArr[0]).trim();
// 记录虫子类型
let bugType = await DB.CollectIPSType.findOneAndUpdate({ name }, { name }, { upsert: true });
//获取防止建议---此处建议不从远端取，在本系统根据虫子种类维护建议即可
let preInRet = await httpRequest({
url: sysConfig.device.getPreventionToInsectName,
method: "GET",
params: { token, userName, name },
});
console.log("000", preInRet)
let plan;
if (preInRet && preInRet.status) {
let pData = preInRet.data && preInRet.data.data || [];
for (let pi = 0; pi < pData.length; pi++) {
const pir = pData[pi];
plan = await DB.CollectIPSPlan.findOneAndUpdate({ name }, pir, { upsert: true });
}
// 记录识别的每一次识别的 虫子 的种类 和 数量
// 此处暂时 每一次单独记录 不是对每一天做累加
await DB.CollectIPSResult.create({
name,
// $inc: {count: 11},
count: element.newCount,
time: data.time || data.newTime,
type: bugType && bugType._id,
plan: plan && plan._id,
data: data._id,
});
}
// 记录识别的每一次识别的 虫子 的种类 和 数量
// 此处暂时 每一次单独记录 不是对每一天做累加
await DB.CollectIPSResult.create({
deviceNumber: data.deviceNumber,
name,
// $inc: {count: 11},
count: element.newCount,
time: data.time || data.newTime,
type: bugType && bugType._id,
plan: plan && plan._id,
data: data._id,
});
}
await DB.CollectIPS.updateOne({ _id: data._id }, { cameraRecognition: data.results });
}
} catch (error) {
console.log(error)
}
......@@ -107,29 +169,30 @@ async function handleIPSResult(data) {
setTimeout(() => {
handleIPSResult({
downloadUrl: 'pictures/FF355138D5C3/2024-05-29-05-59-43.jpg',
taggingImgUrl: 'picturesResult/FF355138D5C3/2024-05-29-05-59-43.jpg',
downloadUrlCompress: 'picturesCompress/FF355138D5C3/orgin_2024-05-29-05-59-43.jpg',
taggingImgUrlCompress: 'picturesCompress/FF355138D5C3/result_2024-05-29-05-59-43.jpg',
deviceNumber: 'FF355138D5C3',
newTime: '2024-05-29 05:59:43',
results: '飞蛾:2',
newCount: 2,
typeCount: 1,
oldCount: 0,
oldTime: null,
oldResults: null,
oldTypeCount: 0,
oldDownloadUrl: 'pictures/FF355138D5C3/2024-05-29-05-59-43.jpg',
oldTaggingImgUrl: 'picturesResult/FF355138D5C3/2024-05-29-05-59-43.jpg',
oldDownloadUrlCompress: null,
oldTaggingImgUrlCompress: 'picturesCompress/FF355138D5C3/result_2024-05-29-05-59-43.jpg',
name: undefined,
time: '2024-05-29 05:59:43'
})
}, 5000)
// setTimeout(() => {
// handleIPSResult({
// downloadUrl: 'pictures/FF355138D5C3/2024-05-29-05-59-43.jpg',
// taggingImgUrl: 'picturesResult/FF355138D5C3/2024-05-29-05-59-43.jpg',
// downloadUrlCompress: 'picturesCompress/FF355138D5C3/orgin_2024-05-29-05-59-43.jpg',
// taggingImgUrlCompress: 'picturesCompress/FF355138D5C3/result_2024-05-29-05-59-43.jpg',
// deviceNumber: 'FF355138D5C3',
// newTime: '2024-05-29 05:59:43',
// results: '飞蛾:2',
// newCount: 2,
// typeCount: 1,
// oldCount: 0,
// oldTime: null,
// oldResults: null,
// oldTypeCount: 0,
// oldDownloadUrl: 'pictures/FF355138D5C3/2024-05-29-05-59-43.jpg',
// oldTaggingImgUrl: 'picturesResult/FF355138D5C3/2024-05-29-05-59-43.jpg',
// oldDownloadUrlCompress: null,
// oldTaggingImgUrlCompress: 'picturesCompress/FF355138D5C3/result_2024-05-29-05-59-43.jpg',
// name: undefined,
// time: '2024-05-29 05:59:43',
// "_id": "66d6d20cdc4220c02affe05d"
// })
// }, 5000)
......
utils/httpRequest.js
View file @ 197ccad1
const axios = require('axios');
const requestLogModule = require("../module/requestLogModule");
async function httpRequest ({url, method, data, params, headers, responseType}) {
console.log(`${url}, ${JSON.stringify(data)}, ${JSON.stringify(params)}`)
async function httpRequest ({url, method, data, params, headers = {}, responseType}) {
try {
let opt = {
url,
......@@ -18,11 +17,13 @@ async function httpRequest ({url, method, data, params, headers, responseType})
requestLogModule.createRequestLog({
url,
method,
params: JSON.stringify(params) + JSON.stringify(data),
params: JSON.stringify(params) + JSON.stringify((headers["Content-Type"] == "mutipart/form-data" ? "" : data)),
headers: JSON.stringify(headers),
type: "device",
status: ret && ret.status,
result: JSON.stringify(ret.data)
result: responseType == 'stream' ? "" : JSON.stringify(ret.data)
}).catch(error => {
console.log(error);
});
if(ret && ret.status == 200) {
......@@ -36,10 +37,12 @@ async function httpRequest ({url, method, data, params, headers, responseType})
requestLogModule.createRequestLog({
url,
method,
params: JSON.stringify(params) + JSON.stringify(data),
params: JSON.stringify(params) + JSON.stringify((headers["Content-Type"] == "mutipart/form-data" ? "" : data)),
headers: JSON.stringify(headers),
type: "device",
msg: error.message,
}).catch(error => {
console.log(error);
});
return {data: null, status: false};
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment