123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800 |
- /**
- * 工料机相关控制器
- *
- * @author CaiAoLin
- * @date 2017/6/22
- * @version
- */
- import BaseController from "../../common/base/base_controller";
- import GLJTypeConst from "../../common/const/glj_type_const";
- import GLJListModel from "../models/glj_list_model";
- import UnitPriceModel from "../models/unit_price_model";
- import MixRatioModel from "../models/mix_ratio_model";
- import UnitPriceFileModel from "../models/unit_price_file_model";
- let logger = require("../../../logs/log_helper").logger;
- let consts = require('../../main/models/project_consts');
- let glj_type_util = require('../../../public/cache/std_glj_type_util');
- let ration_glj_facade = require('../../ration_glj/facade/ration_glj_facade');
- let mongoose = require('mongoose');
- let ration = mongoose.model('ration');
- let projectModel = mongoose.model('projects');
- let _ = require('lodash');
- let glj_facade = require('../facade/glj_facade');
- const ProjectModel = require('../../pm/models/project_model').project;
- class GLJController extends BaseController {
- /**
- * 构造函数
- *
- * @return {void}
- */
- constructor() {
- let parent = super();
- parent.title = '工料机';
- }
- /**
- * 获取工料机相关数据
- *
- * @param {object} request
- * @param {object} response
- * @return {void}
- */
- async getGljList(request, response) {
- // 标段id
- let projectId = request.body.project_id;
- projectId = parseInt(projectId);
- let responseData = await getGLJListByProjectID(projectId);
- responseData.hostname = request.hostname;
- response.json(responseData);
- }
- /**
- * project getData 接口
- * @param projectID
- * @param callback
- */
- getData(projectID, callback){
- let start = +new Date();
- getGLJListByProjectID(projectID).then(function(result){
- let end = +new Date();
- console.log("项目工料机模块取数据总时间-----"+(end - start));
- callback(result.err,consts.projectConst.PROJECTGLJ,result.data);
- })
- }
- /**
- * 更新数据
- *
- * @param {object} request
- * @param {object} response
- * @return {void}
- */
- async updateData(request, response) {
- let field = request.body.field;
- let value = request.body.value;
- let extend = request.body.extend;
- value = value === 'true' ? 1 : value;
- value = value === 'false' ? 0 : value;
- let id = request.body.id;
- let responseData = {
- err: 0,
- msg: ''
- };
- try {
- // 可编辑的字段
- let editableField = ['is_evaluate', 'unit_price.market_price', 'is_adjust_price', 'mix_ratio.consumption','is_eval_material','no_tax_eqp','is_coe_adjust','is_info_adjust','FI','FO','standardPrice','riskCoe',
- 'supply', 'supply_quantity','delivery_address','delivery','materialType','materialCoe','is_main_material','originPlace','vender','qualityGrace','brand','remark'];
- if (editableField.indexOf(field) < 0) {
- throw '对应字段不能编辑';
- }
- let modelString = 'glj';
- // 切割字段
- let fieldArray = field.split('.');
- modelString = fieldArray.length > 1 ? fieldArray[0] : modelString;
- field = fieldArray.length > 1 ? fieldArray[1] : field;
- // 组合数据
- let updateData = new Object();
- updateData[field] = value;
- let result = false;
- let model = null;
- switch (modelString) {
- case 'glj':
- if (extend&&extend !== '') {
- extend = JSON.parse(extend);
- for (let code in extend) {
- updateData[code] = extend[code];
- }
- }
- console.log(updateData);
- model = new GLJListModel();
- // 更新数据
- result = await model.updateById(id, updateData);
- break;
- case 'unit_price':
- model = new UnitPriceModel();
- // 更新数据
- result = await model.updatePrice({id: id}, updateData, extend);
- break;
- case 'mix_ratio':
- let marketPrice = request.body.market_price;
- let basePrice = request.body.base_price;
- model = new MixRatioModel();
- result = await model.updateById(id, updateData);
- if (result && marketPrice && basePrice) {
- // 修改后更新父节点的项目工料机市场单价
- let mixRatioData = await model.findDataByCondition({id: id});
- if (mixRatioData.length <= 0) {
- break;
- }
- let indexList = ['code','name','specs','unit','type'];
- let keyList = mixRatioData.connect_key.split("|-|");
- // 更新市场单价和基价单价
- let condition = {unit_price_file_id: mixRatioData.unit_price_file_id};
- for(let i = 1;i<keyList.length;i++){
- if(keyList[i]!='null'){
- condition[indexList[i]]=keyList[i];
- }
- }
- let unitPriceUpdate = {
- base_price: basePrice,
- market_price: marketPrice
- };
- let unitPriceModel = new UnitPriceModel();
- let unitPriceResult = await unitPriceModel.updatePrice(condition, unitPriceUpdate);
- if (!unitPriceResult) {
- throw '更新单价数据失败';
- }
- }
- break;
- }
- if (!result) {
- throw '更新失败';
- }
- } catch (error) {
- console.log('error:' + error);
- responseData.err = 1;
- }
- response.json(responseData);
- }
- /**
- * 加载配合比相关数据
- *
- * @return {void}
- */
- async getRatio(request, response) {
- let projectGLJId = request.body.id;
- let projectId = request.body.project_id;
- let responseData = {
- err: 0,
- data: null
- };
- try {
- // 获取标段对应的单价文件id
- let unitPriceFileId = await ProjectModel.getUnitPriceFileId(projectId);
- if (unitPriceFileId <= 0) {
- throw '没有对应的单价文件';
- }
- let gljListModel = new GLJListModel();
- let result = await gljListModel.getCompositionList(projectGLJId, unitPriceFileId);
- if (result.length <= 0) {
- throw '没有找到数据';
- }
- responseData.data = JSON.stringify(result);
- } catch (error) {
- console.log(error);
- responseData.err = 1;
- }
- response.json(responseData);
- }
- /**
- * 删除配合比数据
- *
- * @param {object} request
- * @param {object} response
- * @return {void}
- */
- async deleteMixRatio(request, response) {
- let id = request.body.id;
- id = parseInt(id);
- let responseData = {
- err: 0,
- msg: ''
- };
- try {
- if (isNaN(id) || id <= 0) {
- throw '参数错误';
- }
- let mixRatioModel = new MixRatioModel();
- let result = await mixRatioModel.deleteById(id);
- if (!result) {
- throw '删除失败';
- }
- } catch (error) {
- responseData.err = 1;
- responseData.msg = error;
- }
- response.json(responseData);
- }
- //添加组成物
- async addMixRatio(request,response){
- let result={
- error:0
- };
- try {
- let data = request.body.data;
- data = JSON.parse(data);
- let gljList = data.gljList, parentInfo = data.parentInfo,mixRatios = [];
- let projectGljModel = new GLJListModel();
- let mixRatioModel = new MixRatioModel();
- if(gljList.length > 0){
- let [unitFileId,ext] = await ration_glj_facade.prepareExtData(gljList[0].project_id,request.session.sessionCompilation);
- console.log(ext);
- for(let g of gljList){
- let newProjectGLJ = await projectGljModel.addList(g,unitFileId,ext);
- let mixRatio = {
- glj_id:newProjectGLJ.glj_id,
- consumption:0,
- unit_price_file_id:unitFileId,
- connect_key:parentInfo.connect_key,
- type: newProjectGLJ.type,
- code: newProjectGLJ.code,
- specs:newProjectGLJ.specs,
- name:newProjectGLJ.name,
- unit:newProjectGLJ.unit,
- model:newProjectGLJ.model
- };
- newProjectGLJ.ratio_data = await mixRatioModel.add(mixRatio);
- mixRatios.push(newProjectGLJ);
- }
- }
- result.data = mixRatios;
- }catch (err){
- logger.err(err);
- result.error=1;
- result.message = err.message;
- }
- response.json(result);
- }
- /**
- * 获取项目与单价文件对应的数据
- *
- * @param {object} request
- * @param {object} response
- * @return {void}
- */
- async getProjectInfo(request, response) {
- if(typeof request.body.data == "string"){
- request.body = JSON.parse(request.body.data)
- }
- let projectId = request.body.project_id;
- let rootProjectID = request.body.rootProjectID;
- projectId = parseInt(projectId);
- const notDeleted = [{deleteInfo: null}, {'deleteInfo.deleted': false}];
- let responseData = {
- err: 0,
- data: null
- };
- try {
- let sessionUserData = request.session.sessionUser;
- //获取当前单位工程
- let currentTender = await projectModel.findOne({ID: projectId, $or: notDeleted});
- // 获取对应用户所有的建设项目数据
- let projectList = await ProjectModel.getUserProjectData(sessionUserData.id,request.session.sessionCompilation._id);
- //获取对应用户所有文件夹
- let folders = await projectModel.find({userID: sessionUserData.id, $or: notDeleted, projType: 'Folder'}, {_id: 0, name: 1, ID: 1, NextSiblingID: 1, ParentID: 1});
- if(currentTender === null){
- throw '当前单位工程不存在';
- }
- if (projectList === null) {
- throw '没有找到对应的项目数据';
- }
- // 转换mongoose数据
- projectList = JSON.stringify(projectList);
- projectList = JSON.parse(projectList);
- let result = {
- self: [],
- other: [],
- treeData: []
- };
- for (let index in projectList) {
- // 获取对应的单价文件
- let unitPriceFileModel = new UnitPriceFileModel();
- let unitPriceFileData = await unitPriceFileModel.getDataByRootProject(projectList[index].ID);
- projectList[index].unitPriceList = unitPriceFileData;
- // 归类
- if (rootProjectID == projectList[index].ID) {
- //剔除自身
- let currentUsedUF = currentTender.property.unitPriceFile.id;
- result.self = _.filter(unitPriceFileData, function (uf) {
- return uf.id !== currentUsedUF;
- });
- result.currentProjectName = projectList[index].name;
- } else {
- result.other.push(projectList[index]);
- }
- result.treeData.push({name: projectList[index].name, ID: projectList[index].ID, NextSiblingID: projectList[index].NextSiblingID, ParentID: projectList[index].ParentID});
- }
- result.treeData = result.treeData.concat(folders);
- responseData.data = result;
- response.json(responseData);
- } catch (error) {
- responseData.err = 1;
- response.json(responseData);
- }
- }
- /**
- * 更改单价文件
- *
- * @param {object} request
- * @param {object} response
- * @return {void}
- */
- async changeUnitPriceFile(request, response) {
- let projectId = request.body.project_id;
- let changeUnitPriceId = request.body.change_id;
- let newName = request.body.newName;
- let type = request.body.type;
- type = parseInt(type);
- let responseData = {
- err: 0,
- msg: ''
- };
- try {
- responseData.unitFile = await glj_facade.changeUnitFile({projectID:projectId}, {id:changeUnitPriceId,name:newName},type,request.session.sessionUser.id);
- } catch (error) {
- console.log(error);
- responseData.err = 1;
- responseData.msg = error;
- }
- response.json(responseData);
- }
- async checkUnitFileName(request, response){
- let result={
- error:0
- }
- try {
- let data = request.body.data;
- let nameExist = false;
- data = JSON.parse(data);
- let unitPriceFileModel = new UnitPriceFileModel();
- let count = await unitPriceFileModel.model.count({root_project_id:data.rootProjectID,name:data.name,deleteInfo:null});
- if(count>0){
- nameExist = true;
- }else {
- nameExist = false;
- }
- result.data= nameExist;
- }catch (err){
- console.log(err);
- result.error=1;
- result.message = err.message;
- }
- response.json(result);
- }
- /**
- * 单价文件另存为
- *
- * @param {object} request
- * @param {object} response
- * @return {void}
- */
- async unitPriceSaveAs(request, response) {
- let responseData = {
- err: 0,
- msg: ''
- };
- let projectId = request.body.project_id;
- let name = request.body.name;
- try {
- // 当前单价文件id
- let currentUnitPriceId = await ProjectModel.getUnitPriceFileId(projectId);
- // 获取当前项目的rootProjectId
- let projectData = await ProjectModel.getProject(projectId);
- let rootProjectId = projectData.property.rootProjectID !== undefined ? projectData.property.rootProjectID : 0;
- // 新增单价文件信息
- let unitPriceFileModel = new UnitPriceFileModel();
- let insertData = {
- name: name,
- project_id: projectId,
- user_id: request.session.sessionUser.id,
- root_project_id: rootProjectId
- };
- let addResult = await unitPriceFileModel.add(insertData);
- if (!addResult) {
- throw '单价文件另存为失败';
- }
- // 查找对应单价文件的项目工料机数据
- let unitPriceModel = new UnitPriceModel();
- let copyResult = await unitPriceModel.copyNotExist(currentUnitPriceId, addResult.id,projectId);
- // 复制成功后更改project数据
- if (!copyResult) {
- throw '复制数据失败';
- }
- await ProjectModel.updateUnitFileToProject(projectId,{id:addResult.id,name:addResult.name});
- responseData.data = addResult;
- } catch (error) {
- responseData.err = 1;
- responseData.msg = error;
- }
- response.json(responseData);
- }
- /**
- * 获取项目中所有组成物数据(用户缓存到前端变量)
- *
- * @param {object} request
- * @param {object} response
- * @return {void}
- */
- async getComposition(request, response) {
- let projectId = request.body.project_id;
- projectId = parseInt(projectId);
- let responseData = {
- err: 0,
- data: null
- };
- try {
- // 当前单价文件id
- let currentUnitPriceId = await ProjectModel.getUnitPriceFileId(projectId);
- if (currentUnitPriceId <= 0) {
- throw '没有找到对应的单价文件';
- }
- // 获取组成物数据
- let mixRatioModel = new MixRatioModel();
- let compositionData = await mixRatioModel.findDataByCondition({unit_price_file_id: currentUnitPriceId}, null, false);
- if (compositionData === null) {
- throw '没有找到组成物数据';
- }
- compositionData = JSON.parse(JSON.stringify(compositionData));
- // 查找对应的单价数据
- let unitPriceModel = new UnitPriceModel();
- let unitPriceData = await unitPriceModel.findDataByCondition({unit_price_file_id: currentUnitPriceId}, null, false, 'glj_id');
- // 整理数据
- let result = {};
- for(let composition of compositionData) {
- let tmpId = composition.glj_id !== undefined ? composition.glj_id : -1;
- let tmpData = {
- market_price: unitPriceData[tmpId] !== undefined ?
- unitPriceData[tmpId].market_price : 0,
- base_price: unitPriceData[tmpId] !== undefined ?
- unitPriceData[tmpId].base_price : 0,
- consumption: composition.consumption,
- glj_type: composition.glj_type,
- connect_code: composition.connect_code
- };
- if (result[tmpId] === undefined) {
- result[tmpId] = [];
- }
- result[tmpId].push(tmpData);
- }
- responseData.data = result;
- } catch (error) {
- responseData.err = 1;
- responseData.data = null;
- }
- response.json(responseData);
- }
- /**
- * 模拟定额插入
- *
- * @param {object} request
- * @param {object} response
- * @return {void}
- */
- async test(request, response) {
- // 从定额库获取的数据
- let data = {
- glj_id: 17,
- project_id: 1,
- code: '00010201',
- name: '土石方综合工日',
- specs: '',
- unit: '工日',
- type: GLJTypeConst.LABOUR,
- base_price: 50,
- market_price: 50
- };
- try {
- let gljListModel = new GLJListModel();
- let result = await gljListModel.addList(data);
- } catch (error) {
- console.log(error);
- }
- response.end('success');
- }
- /**
- * 模拟定额修改单价
- *
- * @param {object} request
- * @param {object} response
- * @return {void}
- */
- async testModify(request, response) {
- let projectId = request.query.project;
- // 修改数据
- let updateData = {
- code: '36290101',
- market_price: '13',
- name: '水(10)',
- project_id: projectId
- };
- try {
- let gljListModel = new GLJListModel();
- let result = await gljListModel.modifyMarketPrice(updateData);
- console.log(result);
- } catch (error) {
- console.log(error);
- }
- response.end('success');
- }
- /**
- * 测试删除
- *
- * @param {object} request
- * @param {object} response
- * @return {void}
- */
- async delete(request, response) {
- try {
- let gljListModel = new GLJListModel();
- let result = await gljListModel.deleteById(63);
- console.log(result);
- } catch (error) {
- console.log(error);
- }
- response.end('success');
- }
- async updateUnitPrice(req, res){
- let result={
- error:0
- }
- try {
- let data = req.body.data;
- data = JSON.parse(data);
- let unitPriceModel = new UnitPriceModel();
- // 更新数据
- let datas = await unitPriceModel.updateUnitPrice(data);
- result.data=datas;
- }catch (err){
- logger.err(err);
- result.error=1;
- result.message = err.message;
- }
- res.json(result);
- }
- async batchUpdatePrices(req, res){
- let result={
- error:0
- }
- try {
- let data = req.body.data;
- data = JSON.parse(data);
- let unitPriceModel = new UnitPriceModel();
- // 更新数据
- let datas = await unitPriceModel.batchUpdatePrices(data);
- result.data=datas;
- }catch (err){
- logger.err(err);
- result.error=1;
- result.message = err.message;
- }
- res.json(result);
- }
- async batchUpdateGLJProperty(req, res){
- let result={
- error:0
- };
- try {
- let data = req.body.data;
- data = JSON.parse(data);
- let tasks = [];
- for(let key in data){
- let doc = data[key];
- let query = {id:parseInt(key)};
- let task = {updateOne:{filter:query, update :doc}};
- tasks.push(task);
- }
- if(tasks.length > 0){
- let gljModel = new GLJListModel().model;
- await gljModel.bulkWrite(tasks);
- }
- result.data=data;
- }catch (err){
- logger.err(err);
- result.error=1;
- result.message = err.message;
- }
- res.json(result);
- }
- async batchUpdateConsumption(req,res){
- let result={
- error:0
- };
- try {
- let data = req.body.data;
- data = JSON.parse(data);
- let mixTasks = [],parent = null;
- for(let d of data){
- if(d.type == 'mix_ratio'){
- let task = {updateOne:{filter:d.query, update :d.doc}};
- mixTasks.push(task);
- }else if(d.type =='parent'){
- parent = d;
- }
- }
- if(mixTasks.length > 0){
- let mixRatioModel = new MixRatioModel().model;
- await mixRatioModel.bulkWrite(mixTasks);
- }
- if(parent){
- let indexList = ['code','name','specs','unit','type'];
- let keyList = parent.connect_key.split("|-|");
- let condition = {unit_price_file_id: parent.unit_price_file_id};
- for(let i = 1;i<keyList.length;i++){
- if(keyList[i]!='null'){
- condition[indexList[i]]=keyList[i];
- }
- }
- let unitPriceUpdate = {
- base_price: parent.base_price,
- market_price: parent.market_price
- };
- let unitPriceModel = new UnitPriceModel();
- let unitPriceResult = await unitPriceModel.updatePrice(condition, unitPriceUpdate);
- if (!unitPriceResult) {
- throw '更新单价数据失败';
- }
- }
- result.data = "ok";
- }catch (err){
- logger.err(err);
- result.error=1;
- result.message = err.message;
- }
- res.json(result);
- }
- async updateEvaluateMaterial(request, response){
- let result={error:0};
- try {
- let data = JSON.parse(request.body.data);
- result.data = await glj_facade.updateEvaluateMaterial(data);
- }catch (err){
- logger.err(err);
- result.error=1;
- result.message = err.message;
- }
- response.json(result);
- }
- async modifyKeyValue(req,res){//修改工料机关键的属性:名称、类型、规格、型号等
- let result={
- error:0
- }
- try {
- let data = req.body.data;
- data = JSON.parse(data);
- let gljListModel = new GLJListModel();
- let ration_data = await ration.findOne(data.ration);
- // 修改项目工料机
- let projcetGLJ = await gljListModel.modifyGLJ(data.updateData,ration_data);
- // let datas = await gljListModel.addList(data);
- result.data=projcetGLJ;
- }catch (err){
- logger.err(err);
- result.error=1;
- result.message = err.message;
- }
- res.json(result);
- }
- async getProjectGLJsByProjectID(projectId){
- return await getGLJListByProjectID(projectId)
- }
- }
- /**
- * 取项目工料机列表
- * @param projectId
- * @returns {Promise.<void>}
- */
- async function getGLJListByProjectID(projectId){
- let responseData = {
- err: 0,
- msg: '',
- data: {}
- };
- try {
- if (isNaN(projectId) || projectId <= 0) {
- throw '标段id有误';
- }
- // 获取标段对应的单价文件id
- let unitPriceFileId = await ProjectModel.getUnitPriceFileId(projectId);
- if (unitPriceFileId <= 0) {
- throw '没有对应的单价文件';
- }
- // 获取使用该单价文件的项目数据
- let tenderData = await ProjectModel.getTenderByUnitPriceFileId(unitPriceFileId);
- let usedTenderList = [];
- let usedUnitPriceInfo = {};
- if (tenderData !== null) {
- for (let tmp of tenderData) {
- usedTenderList.push(tmp.name);
- usedUnitPriceInfo.name = tmp.property.unitPriceFile.name;
- usedUnitPriceInfo.id = tmp.property.unitPriceFile.id;
- }
- }
- responseData.data.gljList = gljList;
- // 先获取对应标段的项目工料机数据
- let gljListModel = new GLJListModel();
- let [gljList, mixRatioConnectData,mixRationMap,unitPriceMap] = await gljListModel.getListByProjectId(projectId, unitPriceFileId);
- responseData.data.gljList = gljList;
- responseData.data.mixRatioConnectData = mixRatioConnectData;
- responseData.data.mixRatioMap = mixRationMap;
- responseData.data.usedTenderList = usedTenderList;
- responseData.data.unitPriceMap = unitPriceMap;
- let gljTypeMap = glj_type_util.getStdGljTypeCacheObj().innerGljTypeObj;
- responseData.data.constData = {
- materialIdList: gljListModel.materialIdList,
- ownCompositionTypes: gljListModel.ownCompositionTypes,
- roomId: unitPriceFileId,
- GLJTypeConst: JSON.stringify(GLJTypeConst),
- usedUnitPriceInfo: usedUnitPriceInfo,
- gljTypeMap:gljTypeMap
- };
- } catch (error) {
- console.log(error);
- responseData.err = 1;
- responseData.msg = error;
- }
- return responseData;
- }
- export default GLJController;
|