bills_controller.js 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714
  1. /**
  2. * Created by jimiz on 2017/4/7.
  3. */
  4. let mongoose = require('mongoose');
  5. var billsData = require('../models/bills');
  6. let ration_model = require('../models/ration');
  7. let ProjectsData = require('../../pm/models/project_model').project;
  8. let logger = require("../../../logs/log_helper").logger;
  9. let quantity_detail = require("../facade/quantity_detail_facade");
  10. let bill_facade = require("../facade/bill_facade");
  11. let ration_glj = mongoose.model('ration_glj');
  12. let ration_coe = mongoose.model('ration_coe');
  13. let rationInstallationModel = mongoose.model('ration_installation');
  14. let stdBillsModel = mongoose.model('std_bills_lib_bills');
  15. let stdBillJobsModel = mongoose.model('std_bills_lib_jobContent');
  16. let stdBillCharacterModel = mongoose.model('std_bills_lib_itemCharacter');
  17. import fixedFlag from '../../common/const/bills_fixed';
  18. const uuidV1 = require('uuid/v1');
  19. const billType ={
  20. DXFY:1,//大项费用
  21. FB:2,//分部
  22. FX:3,//分项
  23. BILL:4,//清单
  24. BX:5//补项
  25. };
  26. // 上传控件
  27. const multiparty = require("multiparty");
  28. const fs = require("fs");
  29. // excel解析
  30. const excel = require("node-xlsx");
  31. //统一回调函数
  32. var callback = function(req, res, err, message, data){
  33. res.json({error: err, message: message, data: data});
  34. };
  35. module.exports = {
  36. getData: function(req, res){
  37. var data = JSON.parse(req.body.data);
  38. billsData.getData(data.projectId, function(err, message, billsList){
  39. if (err === 0) {
  40. callback(req, res, err, message, billsList);
  41. } else {
  42. callback(req, res, err, message, null);
  43. }
  44. });
  45. },
  46. getItemTemplate: function(req, res){
  47. //var data = JSON.parse(req.body.data);
  48. billsData.getItemTemplate(function(err, message, billsItem){
  49. if (billsItem) {
  50. callback(req, res, err, message, billsItem);
  51. } else {
  52. callback(req, res, err, message, null);
  53. }
  54. });
  55. },
  56. allocIDs: function(req, res){
  57. billsData.allocIDs(function(err, message, data){
  58. if (err) {
  59. callback(req, res, err, message, data);
  60. } else {
  61. callback(req, res, err, message, null);
  62. }
  63. });
  64. },
  65. //zhong 2017-9-1
  66. updateCharacterContent: function (req, res) {
  67. let data = JSON.parse(req.body.data);
  68. let findSet = data.findSet,
  69. updateObj = data.updateObj,
  70. txtObj = data.txtObj;
  71. billsData.updateCharacterContent(findSet, updateObj, txtObj, function (err, message) {
  72. callback(req, res, err, message, null);
  73. });
  74. },
  75. updateBill: async function(request, response) {
  76. const data = JSON.parse(request.body.data);
  77. const findSet = data.findSet;
  78. const updateData = data.updateData;
  79. let settingData = {};
  80. // 筛选出要保存在项目属性的设置
  81. for (const index in updateData) {
  82. if (updateData[index].field === 'addRule') {
  83. settingData = updateData[index].value;
  84. delete updateData[index];
  85. }
  86. }
  87. // 更新项目属性
  88. const propertyUpdateData = {
  89. property: 'addRule',
  90. data: settingData
  91. };
  92. const projectResult = await ProjectsData.updateProjectProperty(findSet.projectID, propertyUpdateData);
  93. const result = await billsData.updateBill(findSet, updateData);
  94. const message = !result || !projectResult ? '修改失败' : '修改成功';
  95. const err = !result || !projectResult ? 1 : 0;
  96. callback(request, response, err, message, null);
  97. },
  98. singleDelete:async function(req, res){
  99. let result={
  100. error:0
  101. }
  102. try {
  103. let data = req.body.data;
  104. data = JSON.parse(data);
  105. let tasks = generateSingleDeleteTasks(data);
  106. let resultData= await billsData.model.bulkWrite(tasks);
  107. //删除工程量明细
  108. await quantity_detail.deleteByQuery({projectID: data.projectID, billID: data.ID}) ;
  109. result.data=resultData;
  110. }catch (err){
  111. logger.err(err);
  112. result.error=1;
  113. result.message = err.message;
  114. }
  115. res.json(result);
  116. },
  117. multiDelete:async function(req, res){
  118. let result={
  119. error:0
  120. };
  121. try {
  122. let data = req.body.data;
  123. data = JSON.parse(data);
  124. result.data=await doBillsOrRationsDelete(data);
  125. }catch (err){
  126. logger.err(err);
  127. result.error=1;
  128. result.message = err.message;
  129. }
  130. res.json(result);
  131. },
  132. getSectionInfo:async function(req, res){
  133. let result={
  134. error:0
  135. }
  136. try {
  137. let data = req.body.data;
  138. data = JSON.parse(data);
  139. let sectionInfo= await bill_facade.getSectionInfo(data);
  140. result.data=sectionInfo;
  141. }catch (err){
  142. logger.err(err);
  143. result.error=1;
  144. result.message = err.message;
  145. }
  146. res.json(result);
  147. },
  148. reorganizeFBFX:async function(req,res){
  149. let result={
  150. error:0
  151. }
  152. try {
  153. let data = req.body.data;
  154. data = JSON.parse(data);
  155. let reorganizeResult= await bill_facade.reorganizeFBFX(data);
  156. result.data=reorganizeResult;
  157. }catch (err){
  158. logger.err(err);
  159. result.error=1;
  160. result.message = err.message;
  161. }
  162. res.json(result);
  163. },
  164. pasteBlock:async function(req,res){
  165. let result={
  166. error:0
  167. };
  168. try {
  169. let data = req.body.data;
  170. data = JSON.parse(data);
  171. let pasteResult = await bill_facade.pasteBlock(data);
  172. result.data = pasteResult;
  173. }catch (err){
  174. logger.err(err);
  175. result.error=1;
  176. result.message = err.message;
  177. }
  178. res.json(result);
  179. },
  180. //下载导入清单示例
  181. downloadExample: async function(request, response) {
  182. try {
  183. const filePath = './public/static/uploadExample.xlsx';
  184. const stats = fs.statSync(filePath);
  185. // 下载相关header
  186. response.set({
  187. 'Content-Type': 'application/octet-stream',
  188. 'Content-Disposition': 'attachment; filename=uploadExample.xlsx',
  189. 'Content-Length': stats.size
  190. });
  191. fs.createReadStream(filePath).pipe(response);
  192. } catch (error) {
  193. response.end(error);
  194. }
  195. },
  196. upload: async function(req, res){
  197. let responseData = {
  198. err: 0,
  199. msg: '',
  200. data: null
  201. };
  202. const allowHeader = ['application/vnd.ms-excel', 'application/vnd.openxmlformats-officedocument.spreadsheetml.sheet'];
  203. const uploadOption = {
  204. uploadDir: './public'
  205. };
  206. const uploadType = {lj: 'lj', gld: 'gld'};
  207. const form = new multiparty.Form(uploadOption);
  208. let uploadFullName;
  209. form.parse(req, async function(err, fields, files) {
  210. try{
  211. const projectID = fields.projectID !== undefined && fields.projectID.length > 0 ?
  212. parseInt(fields.projectID[0]) : 0;
  213. if (projectID <= 0) {
  214. throw '参数错误';
  215. }
  216. const file = files.file !== undefined ? files.file[0] : null;
  217. if (err || file === null) {
  218. throw '上传失败';
  219. }
  220. // 判断类型
  221. if (file.headers['content-type'] === undefined || allowHeader.indexOf(file.headers['content-type']) < 0) {
  222. throw '不支持该类型';
  223. }
  224. //导入表类型(09表lj、广联达gld)
  225. const fileType = fields.fileType !== undefined && fields.fileType.length > 0 ? fields.fileType[0] : uploadType.lj;
  226. //广联达表始终插入到分部分项,将文件名重命名为分部分项触发导入到分部分项部分
  227. if(fileType === uploadType.gld){
  228. file.originalFilename = '广联达分部分项工程';
  229. }
  230. // 重命名文件名
  231. uploadFullName = uploadOption.uploadDir + '/' + file.originalFilename;
  232. fs.renameSync(file.path, uploadFullName);
  233. const sheet = excel.parse(uploadFullName);
  234. if (sheet[0] === undefined || sheet[0].data === undefined) {
  235. throw 'excel没有对应数据';
  236. }
  237. //获取表的列设置确定导入的格式是否合法(09、广联达)
  238. //console.log(sheet[0].data);
  239. let colMapping = getColMapping(sheet[0].data);
  240. console.log(`colMapping`);
  241. console.log(colMapping);
  242. //导入的数据是否含有固定行(分部分项、施工技术措施项目、施工组织措施项目,通过文件名判断)、确定导入位置
  243. let flag = getImportFlag(file.originalFilename);
  244. if(!flag){
  245. throw 'excel数据错误';
  246. }
  247. let fixedBill = await billsData.model.findOne({projectID: projectID, 'flags.flag': flag, deleteInfo: null});
  248. let insertFixedBill = null;
  249. let vData = getValidImportData(colMapping, sheet[0].data, fixedBill);
  250. console.log(`vData`);
  251. console.log(vData);
  252. for(let rData of vData){
  253. let t = {};
  254. t.serialNo = rData[colMapping.serialNo];
  255. t.code = rData[colMapping.code];
  256. t.name = rData[colMapping.name];
  257. t.itemCharacterText = rData[colMapping.itemCharacterText];
  258. t.unit = rData[colMapping.unit];
  259. t.quantity = rData[colMapping.quantity];
  260. console.log(t);
  261. }
  262. // throw 'test';
  263. //导入xx措施项目,若不存在此固定清单,则先插入相关固定清单
  264. if(!fixedBill){
  265. //分部分项工程(不可删除)应存在
  266. if(flag === fixedFlag.SUB_ENGINERRING){
  267. throw '项目不存在分部分项工程'
  268. }
  269. //措施项目是否存在
  270. let csxm = await billsData.model.findOne({projectID: projectID, 'flags.flag': fixedFlag.MEASURE, deleteInfo: null});
  271. if(!csxm){
  272. throw '项目不存在措施项目'
  273. }
  274. //插入清单固定行(施工技术措施项目、施工组织措施项目可删除)
  275. insertFixedBill = {projectID: projectID, name: flag === fixedFlag.CONSTRUCTION_TECH ? '施工技术措施项目' : '施工组织措施项目', code: '1',
  276. ID: uuidV1(), NextSiblingID: -1, ParentID: csxm.ID, flags: [{fieldName: 'fixed', flag: flag}], type: billType.BILL};
  277. //更新前节点
  278. let preDatas = await billsData.model.find({projectID: projectID, ParentID: csxm.ID, deleteInfo: null});
  279. for(let preData of preDatas){
  280. if(preData.NextSiblingID == -1){
  281. await billsData.model.update({ID: preData.ID}, {$set: {NextSiblingID: insertFixedBill.ID}});
  282. break;
  283. }
  284. }
  285. await billsData.model.create(insertFixedBill);
  286. fixedBill = insertFixedBill;
  287. }
  288. console.log(`fixedBill--------------`);
  289. console.log(fixedBill);
  290. //匹配的清单库
  291. const billsLibId = fields.billsLibId !== undefined && fields.billsLibId.length > 0 && fields.billsLibId[0]? parseInt(fields.billsLibId[0]) : null;
  292. let stdBills = [], stdJobs = [], stdCharacters = [];
  293. if(billsLibId){
  294. stdBills = await stdBillsModel.find({billsLibId: billsLibId, deleted: false}, '-_id code jobs items engineering');
  295. stdJobs = await stdBillJobsModel.find({billsLibId: billsLibId, deleted: false});
  296. stdCharacters = await stdBillCharacterModel.find({billsLibId: billsLibId, deleted: false});
  297. }
  298. //将excel数据转换成清单树结构数据
  299. console.log(`sheet[0].data`);
  300. console.log(sheet[0].data);
  301. let insertDatas = parseToBillData(getValidImportData(colMapping, sheet[0].data, fixedBill), colMapping, fixedBill, projectID, {stdBills: stdBills, stdJobs: stdJobs, stdCharacters: stdCharacters});
  302. console.log(`insertDatas`);
  303. console.log(insertDatas);
  304. if(insertDatas.length === 0){
  305. throw 'excel无有效数据';
  306. }
  307. //删除相关数据
  308. let deleteDatas = await billsData.deepDeleteBill([fixedBill], req.session.sessionUser.id);
  309. //新增清单数据
  310. await billsData.importBills(insertDatas);
  311. //返回数据以更新前端
  312. if(insertFixedBill){
  313. insertDatas.push(insertFixedBill);
  314. }
  315. responseData.data = {fixedBill: fixedBill, insert: {bill: insertDatas, ration: []}, remove: {bill: deleteDatas.bill, ration: deleteDatas.ration}};
  316. //删除暂存文件
  317. fs.unlink(uploadFullName);
  318. res.json(responseData);
  319. }
  320. catch (error){
  321. if(fs.existsSync(uploadFullName)){
  322. fs.unlink(uploadFullName);
  323. }
  324. responseData.err = 1;
  325. console.log(error);
  326. responseData.msg = typeof error === 'object' ? '上传失败' : error;
  327. res.json(responseData);
  328. }
  329. });
  330. }
  331. };
  332. //是否是有效的表头列格式
  333. function isValidSheet(sheetData, fileType){
  334. }
  335. //提取excel表头列对应数据
  336. function getColMapping(sheetData){
  337. //获取表头
  338. let headRow = [];
  339. for(let rData of sheetData) {
  340. //寻找含有序号的行,认作表头行
  341. for(let cData of rData){
  342. if (cData && cData.toString().replace(/\s/g, '') === '序号') {
  343. headRow = rData;
  344. break;
  345. }
  346. }
  347. }
  348. //获取需要的表头列与列号对应关系
  349. let colMapping = {};
  350. for(let c = 0; c < headRow.length; c++){
  351. if(headRow[c]){
  352. headRow[c] = headRow[c].toString().replace(/\s/g, '');
  353. //重复的,只取第一个
  354. if(headRow[c] === '序号' && colMapping.serialNo === undefined){
  355. colMapping.serialNo = c;
  356. }
  357. else if((headRow[c] === '编码' || headRow[c] === '项目编码') && colMapping.code === undefined){
  358. colMapping.code = c;
  359. }
  360. else if((headRow[c] === '名称' || headRow[c] === '项目名称') && colMapping.name === undefined){
  361. colMapping.name = c;
  362. }
  363. else if((headRow[c] === '特征' || headRow[c] === '项目特征') && colMapping.itemCharacterText === undefined){
  364. colMapping.itemCharacterText = c;
  365. }
  366. else if((headRow[c] === '单位' || headRow[c] === '计量单位') && colMapping.unit === undefined){
  367. colMapping.unit = c;
  368. }
  369. else if((headRow[c] === '工程量' || headRow[c] === '项目工程量') && colMapping.code === undefined){
  370. colMapping.quantity = c;
  371. }
  372. }
  373. }
  374. return colMapping;
  375. }
  376. function rowExistData(rowData){
  377. for(let cData of rowData){
  378. if(cData !== undefined && cData !== ''){
  379. return true;
  380. }
  381. }
  382. return false;
  383. }
  384. //提取excel表数据中的有效数据(去表头表尾,提取其中的excel数据)(根据fixedBill获取栏头占行数)
  385. function getValidImportData(colMapping, sheetData, fixedBill){
  386. let withingD = false;
  387. let validData = [];
  388. function isHead(rData){
  389. return rData[colMapping.serialNo] && rData[colMapping.serialNo].toString().replace(/\s/g, '') === '序号';
  390. }
  391. function isTail(rData){
  392. for(let cData of rData){
  393. if(cData){
  394. let trimCData = cData.toString().replace(/\s/g, '');
  395. if(trimCData === '本页小计' || trimCData === '本页小计'){
  396. return true;
  397. }
  398. }
  399. }
  400. return false;
  401. }
  402. for(let r = 0; r < sheetData.length; r++){
  403. let rData = sheetData[r];
  404. if(isHead(rData)){
  405. withingD = true;
  406. if(fixedBill.name !== '施工组织措施项目'){
  407. r++;
  408. }
  409. continue;
  410. }
  411. else if(isTail(rData)){
  412. withingD = false;
  413. }
  414. if(withingD && rowExistData(rData)){
  415. validData.push(rData);
  416. }
  417. /*if(rData[0]){
  418. //首列去空格
  419. rData[0] = rData[0].toString().replace(/\s/g, '');
  420. //表头
  421. if(rData[0] === '序号'){
  422. withingD = true;
  423. if(fixedBill.name !== '施工组织措施项目'){
  424. r++;
  425. }
  426. continue;
  427. }
  428. //表尾
  429. else if(rData[0] === '本页小计' || rData[0] === '合计'){
  430. withingD = false;
  431. }
  432. }
  433. if(withingD && rowExistData(rData)){
  434. validData.push(rData);
  435. }*/
  436. }
  437. return validData;
  438. }
  439. function getImportFlag(sheetName){
  440. const fixedItem = {'分部分项': fixedFlag.SUB_ENGINERRING, '施工技术措施项目': fixedFlag.CONSTRUCTION_TECH, '施工组织措施项目': fixedFlag.CONSTRUCTION_ORGANIZATION};
  441. for(let flag in fixedItem){
  442. if(sheetName.includes(flag)){
  443. return fixedItem[flag];
  444. }
  445. }
  446. return null;
  447. }
  448. //excel数据转换成清单数据
  449. function parseToBillData(validData, colMapping, fixedBill, projectID, stdData){
  450. let rst = [];
  451. let billIdx = {};
  452. let preRootID = -1,
  453. preLeafID = -1,
  454. preID = -1;
  455. function isDef(data){
  456. return typeof data !== 'undefined' && data !== null && data !== '';
  457. }
  458. //去除转义字符
  459. function removeESC(data){
  460. return isDef(data) ? data.toString().replace(/[\r,\n,\s,\t]/g, '') : data;
  461. }
  462. //父节点:1.无序号 2有编码
  463. function isRoot(rData){
  464. //序号和编码去除转义字符(有的表格单元格看起来是没数据,实际含有\r,\n等数据)
  465. let serialNo = removeESC(rData[colMapping.serialNo]);
  466. let code = removeESC(rData[colMapping.code]);
  467. return !isDef(serialNo) && isDef(code);
  468. }
  469. //子节点:有序号
  470. function isLeaf(rData){
  471. let serialNo = removeESC(rData[colMapping.serialNo]);
  472. return isDef(serialNo);
  473. }
  474. //续数据:1. 前数据有效 2.无序号 3.无编码 4.有名称或特征
  475. function isExtend(preData, rData){
  476. let serialNo = removeESC(rData[colMapping.serialNo]);
  477. let code = removeESC(rData[colMapping.code]);
  478. let name = rData[colMapping.name];
  479. let itemCharacterText = rData[colMapping.itemCharacterText];
  480. return isDef(preData) && (isRoot(preData) || isLeaf(preData)) && !isDef(serialNo) && !isDef(code) && (isDef(name) || isDef(itemCharacterText));
  481. }
  482. function getBillType(rData, flag){
  483. if(flag === fixedFlag.CONSTRUCTION_TECH || flag === fixedFlag.CONSTRUCTION_ORGANIZATION){
  484. return billType.BILL;
  485. }
  486. else if(flag === fixedFlag.SUB_ENGINERRING){
  487. return isLeaf(rData) ? billType.FX : billType.FB;
  488. }
  489. return null;
  490. }
  491. //excel数据与标准库数据匹配,根据清单前九位编码匹配,匹配成功则获取标准清单对应的工程专业、特征及内容
  492. function matchStdBill(excelBill, stdData){
  493. let isMatch = false;
  494. let regExp = /^\d{12}$/g;
  495. if(regExp.test(excelBill.code)){
  496. let nineCode = excelBill.code.substr(0, 9);
  497. for(let stdBill of stdData.stdBills){
  498. //set programID
  499. if(nineCode == stdBill.code){
  500. isMatch = true;
  501. excelBill.programID = stdBill.engineering ? stdBill.engineering : null;
  502. //set jobContent and itemCharacter
  503. let tempJob = [], tempCharacter = [];
  504. for(let billJob of stdBill.jobs){
  505. for(let stdJob of stdData.stdJobs) {
  506. if (billJob.id == stdJob.id) {
  507. tempJob.push({isChecked: false, serialNo: billJob.serialNo, content: stdJob.content});
  508. }
  509. }
  510. }
  511. for(let billCharacter of stdBill.items){
  512. for(let stdCharacter of stdData.stdCharacters){
  513. if(billCharacter.id == stdCharacter.id){
  514. let eigenvalue = [];
  515. for(let eValue of stdCharacter.itemValue){
  516. eigenvalue.push({isSelected: false, value: eValue.value});
  517. }
  518. tempCharacter.push({isChecked: false, serialNo: billCharacter.serialNo, character: stdCharacter.content, eigenvalue: eigenvalue});
  519. }
  520. }
  521. }
  522. excelBill.jobContent = tempJob;
  523. excelBill.itemCharacter = tempCharacter;
  524. }
  525. }
  526. }
  527. if(!isMatch && excelBill.type === billType.FX){//分项不为空,同时在标准清单中不匹配,则识别为补项
  528. excelBill.type = billType.BX;
  529. }
  530. }
  531. for(let r = 0; r < validData.length; r++){
  532. /* //序号和编码去除转义字符(有的表格单元格看起来是没数据,实际含有\r,\n等数据)
  533. let serialNo = validData[r][colMapping.serialNo];
  534. let code = validData[r][colMapping.code];
  535. if(isDef(serialNo)){
  536. serialNo = removeESC(serialNo);
  537. }
  538. if(isDef(code)){
  539. code = removeESC(code);
  540. }*/
  541. let preData = validData[r-1],
  542. rData = validData[r];
  543. if(fixedBill.flags[0].flag == fixedFlag.CONSTRUCTION_TECH && rData[colMapping.name] === '施工技术措施项目'
  544. || fixedBill.flags[0].flag == fixedFlag.CONSTRUCTION_ORGANIZATION && rData[colMapping.name] === '施工组织措施项目'){
  545. continue;
  546. }
  547. //过滤无效数据
  548. if(!isRoot(rData) && !isLeaf(rData) && !isExtend(preData, rData)){
  549. continue;
  550. }
  551. if(isExtend(preData, rData)){
  552. let preBill = billIdx[preID];
  553. //合并续数据
  554. if(preBill){
  555. preBill.code += rData[colMapping.code] ? rData[colMapping.code] : '';
  556. preBill.name += rData[colMapping.name] ? rData[colMapping.name] : '';
  557. preBill.itemCharacterText += rData[colMapping.itemCharacterText] ? rData[colMapping.itemCharacterText] : '';
  558. preBill.unit += rData[colMapping.unit] ? rData[colMapping.unit] : '';
  559. preBill.quantity += rData[colMapping.quantity] ? rData[colMapping.quantity] : '';
  560. }
  561. }
  562. else {
  563. let newID = uuidV1();
  564. let pID = -1;
  565. let preBill = null;
  566. if(isRoot(rData)){
  567. pID = fixedBill.ID;
  568. preBill = billIdx[preRootID];
  569. }
  570. else if(isLeaf(rData)){
  571. pID = preRootID !== -1 ? preRootID : fixedBill.ID;
  572. preBill = billIdx[preLeafID];
  573. }
  574. //set bill data
  575. billIdx[newID] = {
  576. ID: newID, ParentID: pID, NextSiblingID: -1,
  577. code: rData[colMapping.code] ? rData[colMapping.code] : '',
  578. name: rData[colMapping.name] ? rData[colMapping.name] : '',
  579. itemCharacterText: rData[colMapping.itemCharacterText] ? rData[colMapping.itemCharacterText] : '',
  580. itemCharacter: [],
  581. jobContentText: '',
  582. jobContent: [],
  583. programID: null,
  584. unit: rData[colMapping.unit] ? rData[colMapping.unit] : '',
  585. quantity: rData[colMapping.quantity] ? rData[colMapping.quantity] : '',
  586. //安全文明
  587. flags: fixedBill.flags[0].flag === fixedFlag.CONSTRUCTION_ORGANIZATION && (rData[colMapping.name] === '安全文明施工专项费用' || rData[colMapping.name] === '安全文明施工费') ?
  588. [{fieldName: 'fixed', flag: fixedFlag.SAFETY_CONSTRUCTION}] : [],
  589. fees: [],
  590. projectID: projectID,
  591. type: getBillType(rData, fixedBill.flags[0].flag)};
  592. //match stdBill and reset programID、jobContent、itemCharacter
  593. matchStdBill(billIdx[newID], stdData);
  594. //update preBill NextSibling
  595. if(preBill){
  596. preBill.NextSiblingID = newID;
  597. }
  598. //set new preID
  599. preID = newID;
  600. preRootID = isRoot(rData) ? newID : preRootID;
  601. preLeafID = isLeaf(rData) ? newID : preLeafID;
  602. }
  603. }
  604. for(let i in billIdx){
  605. rst.push(billIdx[i]);
  606. }
  607. return rst;
  608. }
  609. async function doBillsOrRationsDelete(data) {
  610. let billTask = [];
  611. let deleteBillIDs = [];
  612. let rationTask=[];
  613. let deleteRationIDs=[];
  614. let qd_query=null;
  615. let sub_query=null;
  616. if(data['bills']){
  617. billTask = generateUpdateTasks(data['bills'],data.projectID,data.user_id);
  618. for(let b_key in data['bills']){
  619. if(data['bills'][b_key]===true){
  620. deleteBillIDs.push(b_key+'');
  621. }
  622. }
  623. if(deleteBillIDs.length>0){
  624. qd_query={projectID: data.projectID, billID: {"$in": deleteBillIDs}};
  625. }
  626. }
  627. if(data['ration']){
  628. rationTask = generateUpdateTasks(data['ration'],data.projectID,data.user_id);
  629. for(let r_key in data['ration']){
  630. if(data['ration'][r_key]===true){
  631. deleteRationIDs.push(r_key+'');
  632. }
  633. }
  634. if(deleteRationIDs.length>0){
  635. if(qd_query==null){//说明没删除清单
  636. qd_query={projectID: data.projectID, rationID: {"$in": deleteRationIDs}};
  637. }else {
  638. qd_query={
  639. "$or":[
  640. {projectID: data.projectID, billID: {"$in": deleteBillIDs}},
  641. {projectID: data.projectID, rationID: {"$in": deleteRationIDs}}
  642. ]
  643. }
  644. }
  645. sub_query={projectID: data.projectID, rationID: {"$in": deleteRationIDs}};
  646. }
  647. }
  648. //先删除工程量明细
  649. if(qd_query!=null){
  650. await quantity_detail.deleteByQuery(qd_query) ;
  651. }
  652. if(sub_query!=null){
  653. await ration_coe.deleteMany(sub_query);//删除附注条件
  654. await ration_glj.deleteMany(sub_query);//删除定额工料机
  655. await rationInstallationModel.deleteMany(sub_query);//删除安装增加费
  656. }
  657. if(rationTask.length>0){
  658. await ration_model.model.bulkWrite(rationTask);//删除定额
  659. }
  660. if(billTask.length>0){
  661. await billsData.model.bulkWrite(billTask);//删除清单
  662. }
  663. return 'success';
  664. }
  665. function generateSingleDeleteTasks(data) {
  666. let updateData = data.updateData;
  667. updateData[data.ID]=true;
  668. let tasks = generateUpdateTasks(updateData,data.projectID,data.user_id);
  669. return tasks;
  670. }
  671. function generateUpdateTasks(data,projectID,user_id) {
  672. let tasks=[];
  673. let updateData = data;
  674. let deleteInfo={deleted: true, deleteDateTime: new Date(), deleteBy: user_id};
  675. for(let key in updateData){
  676. let task={
  677. updateOne:{
  678. filter:{
  679. ID:key,
  680. projectID:projectID
  681. }
  682. }
  683. };
  684. if(updateData[key]===true){
  685. task.updateOne.update={
  686. deleteInfo:deleteInfo
  687. };
  688. }else {
  689. task.updateOne.update=updateData[key];
  690. }
  691. tasks.push(task);
  692. }
  693. return tasks;
  694. }