明树Git Lab

Commit 804b2e0c authored by zengfanpei's avatar zengfanpei

update

parent fd8e7f34
...@@ -65,28 +65,22 @@ async function importExcel(req, res, next) { ...@@ -65,28 +65,22 @@ async function importExcel(req, res, next) {
let arr = []; let arr = [];
for (let index = 2; index <= worksheet.actualRowCount; index++) { for (let index = 2; index <= worksheet.actualRowCount; index++) {
let values = worksheet.getRow(index).values; let values = worksheet.getRow(index).values;
console.log(values)
let obj = { let obj = {
creator: req.user._id, creator: req.user._id,
time: values[1], time: values[1],
agrProName: values[2], agrProName: values[2],
name: values[3], empDetails: values[3],
type: values[4], peopleNum: Number(values[4]) || null,
total: values[5], halfDayFee: Number(values[5]) || null,
unit: values[6], laborFee: Number(values[6]) || null,
totalCost: values[7],
dilutionRatio: values[8],
waterConsumption: values[9],
area: values[10],
dosage: values[11],
land: values[12],
notes: values[13],
} }
if(obj.time && obj.agrProName) { if(obj.time) {
arr.push(obj) arr.push(obj)
} }
} }
if(arr.length) { if(arr.length) {
await DB.AgrInputEmploy.insertMany(arr); // await DB.AgrInputEmploy.insertMany(arr);
} }
res.sendData(arr); res.sendData(arr);
} catch (error) { } catch (error) {
......
...@@ -68,20 +68,17 @@ async function importExcel(req, res, next) { ...@@ -68,20 +68,17 @@ async function importExcel(req, res, next) {
let obj = { let obj = {
creator: req.user._id, creator: req.user._id,
time: values[1], time: values[1],
agrProName: values[2], name: values[2],
name: values[3], spec: values[3],
type: values[4], buyNum: Number(values[4]) || null,
total: values[5], buyUnit: values[5],
unit: values[6], unitPrice: Number(values[6]) || null,
totalCost: values[7], taxAmount: Number(values[7]) || null,
dilutionRatio: values[8], totalAmount: Number(values[8]) || null,
waterConsumption: values[9], agent: values[9],
area: values[10], notes: values[10],
dosage: values[11],
land: values[12],
notes: values[13],
} }
if(obj.time && obj.agrProName) { if(obj.time) {
arr.push(obj) arr.push(obj)
} }
} }
......
...@@ -15,6 +15,9 @@ async function list(req, res, next) { ...@@ -15,6 +15,9 @@ async function list(req, res, next) {
let page = req.body.page || 1; let page = req.body.page || 1;
let pageSize = req.body.pageSize || 10; let pageSize = req.body.pageSize || 10;
let skip = (page - 1) * pageSize; let skip = (page - 1) * pageSize;
if (req.body.agrProName) {
search.agrProName = req.body.agrProName;
}
let count = await DB.AgrInputRecord.countDocuments(search) let count = await DB.AgrInputRecord.countDocuments(search)
let list = await DB.AgrInputRecord.find(search).skip(skip).limit(pageSize).lean().exec(); let list = await DB.AgrInputRecord.find(search).skip(skip).limit(pageSize).lean().exec();
res.sendData({ count, list }); res.sendData({ count, list });
...@@ -38,15 +41,16 @@ async function updateOne(req, res, next) { ...@@ -38,15 +41,16 @@ async function updateOne(req, res, next) {
let updateInfo = { let updateInfo = {
...req.body, ...req.body,
} }
let ret = await DB.AgrInputRecord.findOneAndUpdate({_id: req.body._id}, updateInfo); let ret = await DB.AgrInputRecord.findOneAndUpdate({ _id: req.body._id }, updateInfo);
res.sendData(ret); res.sendData(ret);
} catch (error) { } catch (error) {
next(error) next(error)
} }
} }
async function deleteOne(req, res, next) { async function deleteOne(req, res, next) {
try { try {
let ret = await DB.AgrInputRecord.findOneAndUpdate({_id: req.body._id}, {del: 1}); let ret = await DB.AgrInputRecord.findOneAndUpdate({ _id: req.body._id }, { del: 1 });
res.sendData(ret); res.sendData(ret);
} catch (error) { } catch (error) {
next(error) next(error)
...@@ -71,7 +75,7 @@ async function importExcel(req, res, next) { ...@@ -71,7 +75,7 @@ async function importExcel(req, res, next) {
agrProName: values[2], agrProName: values[2],
name: values[3], name: values[3],
type: values[4], type: values[4],
total: values[5], total: Number(values[5]) || 0,
unit: values[6], unit: values[6],
totalCost: values[7], totalCost: values[7],
dilutionRatio: values[8], dilutionRatio: values[8],
...@@ -81,11 +85,11 @@ async function importExcel(req, res, next) { ...@@ -81,11 +85,11 @@ async function importExcel(req, res, next) {
land: values[12], land: values[12],
notes: values[13], notes: values[13],
} }
if(obj.time && obj.agrProName) { if (obj.time && obj.agrProName) {
arr.push(obj) arr.push(obj)
} }
} }
if(arr.length) { if (arr.length) {
await DB.AgrInputRecord.insertMany(arr); await DB.AgrInputRecord.insertMany(arr);
} }
res.sendData(arr); res.sendData(arr);
......
...@@ -91,6 +91,16 @@ async function getDevice(req, res, next) { ...@@ -91,6 +91,16 @@ async function getDevice(req, res, next) {
next(error); next(error);
} }
} }
async function crateDevice(req, res, next) {
try {
let body = req.body;
let ret = await DB.Device.create(body);
res.sendData(ret);
} catch (error) {
next(error);
}
}
async function test(req, res, next) { async function test(req, res, next) {
try { try {
...@@ -207,6 +217,7 @@ module.exports = { ...@@ -207,6 +217,7 @@ module.exports = {
list, list,
updateDevice, updateDevice,
getDevice, getDevice,
crateDevice,
listAttribute, listAttribute,
setThreshold, setThreshold,
......
...@@ -14,37 +14,25 @@ const letianAgrInputEmploySchema = new Schema({ ...@@ -14,37 +14,25 @@ const letianAgrInputEmploySchema = new Schema({
get: v => moment(v).format("YYYY-MM-DD HH:mm:ss"), get: v => moment(v).format("YYYY-MM-DD HH:mm:ss"),
comment: "日期", comment: "日期",
}, },
name: { agrProName: {
type: String, type: String,
commnet: "类别/名称", commnet: "农产品名称",
}, },
spec: { empDetails: {
type: String, type: String,
commnet: "规格", commnet: "用工详情",
}, },
buyNum: { peopleNum: {
type: Number, type: Number,
comment: "数量" comment: "人数"
}, },
unitPrice: { halfDayFee: {
type: Number, type: Number,
comment: "价(元)" comment: "半天工价(元)"
}, },
taxAmount: { laborFee: {
type: Number, type: Number,
comment: "税额(元)" comment: "劳务费(元)"
},
totalAmount: {
type: Number,
comment: "总额(元)"
},
agent: {
type: String,
comment: "代理商/厂家"
},
notes: {
type: String,
comment: "备注"
}, },
creator: { creator: {
......
...@@ -26,6 +26,10 @@ const letianAgrInputOtherSchema = new Schema({ ...@@ -26,6 +26,10 @@ const letianAgrInputOtherSchema = new Schema({
type: Number, type: Number,
comment: "数量" comment: "数量"
}, },
buyUnit: {
type: String,
comment: "单位"
},
unitPrice: { unitPrice: {
type: Number, type: Number,
comment: "单价(元)" comment: "单价(元)"
......
...@@ -10,6 +10,7 @@ const agrInputEmployController = require('../controller/agrInputEmployController ...@@ -10,6 +10,7 @@ const agrInputEmployController = require('../controller/agrInputEmployController
// excel采集信息上传 甲方要求 // excel采集信息上传 甲方要求
//1. 青皮柚农业投入品使用情况 //1. 青皮柚农业投入品使用情况
router.post('/input/list', agrInputRecordController.list); router.post('/input/list', agrInputRecordController.list);
router.post('/inputRecord/list', agrInputRecordController.list);
router.post('/inputRecord/update', agrInputRecordController.updateOne); router.post('/inputRecord/update', agrInputRecordController.updateOne);
router.post('/inputRecord/delete', agrInputRecordController.deleteOne); router.post('/inputRecord/delete', agrInputRecordController.deleteOne);
router.post('/inputRecord/create', agrInputRecordController.create); router.post('/inputRecord/create', agrInputRecordController.create);
......
...@@ -6,7 +6,7 @@ const router = express.Router(); ...@@ -6,7 +6,7 @@ const router = express.Router();
const deviceController = require('../controller/deviceController'); const deviceController = require('../controller/deviceController');
// router.post('/create', deviceController.); router.post('/create', deviceController.crateDevice);
router.post('/info', deviceController.getDevice); router.post('/info', deviceController.getDevice);
router.post('/update', deviceController.updateDevice); router.post('/update', deviceController.updateDevice);
router.post('/list', deviceController.list); //获取平行列表 router.post('/list', deviceController.list); //获取平行列表
......
...@@ -47,13 +47,22 @@ router.post('/batch/upload', upload.array('files'), fileController.batchUpload); ...@@ -47,13 +47,22 @@ router.post('/batch/upload', upload.array('files'), fileController.batchUpload);
/** /**
* excel导入 * excel导入
*/ */
router.post('/:modelName/importExcel', upload.single('file'), async (req, res, next) =>{ router.post('/:modelName/importExcel', upload.single('file'), async (req, res, next) => {
let modelName = req.params.modelName; let modelName = req.params.modelName;
let controller = require(`../controller/${modelName}Controller`); let modelMap = {
'agrInputRecord': "agrInputRecordController",
'agrInputOther': "agrInputOtherController",
'agrInputDetail': "agrInputDetailController",
'agrInputEmploy': "agrInputEmployController",
}
let controller = require(`../controller/${modelMap[modelName]}`);
await controller.importExcel(req, res, next); await controller.importExcel(req, res, next);
}); });
router.post('/:modelName/exportExcel', async (req, res, next) =>{ /**
* excel导出
*/
router.post('/:modelName/exportExcel', async (req, res, next) => {
let modelName = req.params.modelName; let modelName = req.params.modelName;
let modelMap = { let modelMap = {
'IPS': "collectIPSController", 'IPS': "collectIPSController",
......
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