index.js 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785
  1. const mongoose = require('mongoose');
  2. const uuidV1 = require('uuid/v1');
  3. const _ = require('lodash');
  4. const scMathUtil = require('../../../public/scMathUtil').getUtil();
  5. const { CRAWL_LOG_KEY, ProcessStatus } = require('../../../public/constants/price_info_constant');
  6. const priceInfoLibModel = mongoose.model('std_price_info_lib');
  7. const priceInfoClassModel = mongoose.model('std_price_info_class');
  8. const priceInfoItemModel = mongoose.model('std_price_info_items');
  9. const priceInfoAreaModel = mongoose.model('std_price_info_areas');
  10. const compilationModel = mongoose.model('compilation');
  11. const importLogsModel = mongoose.model('import_logs');
  12. const priceInfoIndexModel = mongoose.model('std_price_info_index');
  13. const priceInfoSummaryModel = mongoose.model('std_price_info_summary');
  14. const { getWordArray, alias } = require('../../../public/cut_word/segmentit');
  15. const SMS = require('../../users/models/sms');
  16. const sms = new SMS();
  17. async function getLibs(query) {
  18. return await priceInfoLibModel.find(query).lean();
  19. }
  20. async function createLib(name, period, compilationID) {
  21. // 将2020-01变成2020年01月
  22. const reg = /(\d{4})-(\d{2})/;
  23. const formattedPeriod = period.replace(reg, '$1年-$2月');
  24. const lib = {
  25. ID: uuidV1(),
  26. name,
  27. period: formattedPeriod,
  28. compilationID,
  29. createDate: Date.now(),
  30. };
  31. await priceInfoLibModel.create(lib);
  32. return lib;
  33. }
  34. async function updateLib(query, updateData) {
  35. await priceInfoLibModel.update(query, updateData);
  36. }
  37. async function deleteLib(libID) {
  38. await priceInfoClassModel.remove({ libID });
  39. await priceInfoItemModel.remove({ libID });
  40. await priceInfoLibModel.remove({ ID: libID });
  41. }
  42. async function processChecking(key) {
  43. const logData = key
  44. ? await importLogsModel.findOne({ key })
  45. : await importLogsModel.findOne({ key: CRAWL_LOG_KEY });
  46. if (!logData) {
  47. return { status: ProcessStatus.FINISH };
  48. }
  49. if (logData.status === ProcessStatus.FINISH || logData.status === ProcessStatus.ERROR) {
  50. await importLogsModel.remove({ key: logData.key });
  51. }
  52. return { status: logData.status, errorMsg: logData.errorMsg || '', key: logData.key };
  53. }
  54. // 爬取数据
  55. async function crawlDataByCompilation(compilationID, from, to) {
  56. if (!compilationID) {
  57. throw '无有效费用定额。';
  58. }
  59. const compilationData = await compilationModel.findOne({ _id: mongoose.Types.ObjectId(compilationID) }, 'overWriteUrl').lean();
  60. if (!compilationData || !compilationData.overWriteUrl) {
  61. throw '无有效费用定额。';
  62. }
  63. // 从overWriteUrl提取并组装爬虫文件
  64. const reg = /\/([^/]+)\.js/;
  65. const matched = compilationData.overWriteUrl.match(reg);
  66. const crawlURL = `${matched[1]}_price_crawler.js`;
  67. let crawlData;
  68. try {
  69. const crawler = require(`../../../web/over_write/crawler/${crawlURL}`);
  70. crawlData = crawler.crawlData;
  71. } catch (e) {
  72. console.log(e);
  73. throw '该费用定额无可用爬虫方法。'
  74. }
  75. //await crawlData(from, to);
  76. // 异步不等结果,结果由checking来获取
  77. crawlDataByMiddleware(crawlData, from, to, compilationID);
  78. }
  79. // 爬取数据中间件,主要处理checking初始化
  80. async function crawlDataByMiddleware(crawlFunc, from, to, compilationID) {
  81. const logUpdateData = { status: ProcessStatus.FINISH };
  82. try {
  83. const logData = {
  84. key: CRAWL_LOG_KEY,
  85. content: '正在爬取数据,请稍候……',
  86. status: ProcessStatus.START,
  87. create_time: Date.now()
  88. };
  89. await importLogsModel.create(logData);
  90. await crawlFunc(from, to, compilationID);
  91. } catch (err) {
  92. console.log(err);
  93. logUpdateData.errorMsg = String(err);
  94. logUpdateData.status = ProcessStatus.ERROR;
  95. } finally {
  96. await importLogsModel.update({ key: CRAWL_LOG_KEY }, logUpdateData);
  97. }
  98. }
  99. // 导入excel数据,格式如下
  100. // 格式1:
  101. //地区 分类 编码 名称 规格型号 单位 不含税价 含税价
  102. //江北区 黑色及有色金属 热轧光圆钢筋 φ6(6.5) 3566.37 4030
  103. //江北区 木、竹材料及其制品 柏木门套线 60×10 8.76 9.9
  104. // 格式2:
  105. //地区 分类 编码 名称 规格型号 不含税价 含税价
  106. //江北区 黑色及有色金属 热轧光圆钢筋 φ6(6.5) 3566.37 4030
  107. // 柏木门套线 60×10 8.76 9.9
  108. // 沥青混凝土 AC-13 982.3 1110
  109. //
  110. //北碚区 木、竹材料及其制品 热轧光圆钢筋 φ6(6.5) 3566.37 4030
  111. async function importExcelData(libID, sheetData) {
  112. const libs = await getLibs({ ID: libID });
  113. const compilationID = libs[0].compilationID;
  114. // 建立区映射表:名称-ID映射、ID-名称映射
  115. const areaList = await getAreas(compilationID);
  116. const areaMap = {};
  117. areaList.forEach(({ ID, name }) => {
  118. areaMap[name] = ID;
  119. areaMap[ID] = name;
  120. });
  121. // 建立分类映射表:地区名称@分类名称:ID映射
  122. /* const classMap = {};
  123. const classList = await getClassData(libID);
  124. classList.forEach(({ ID, areaID, name }) => {
  125. const areaName = areaMap[areaID] || '';
  126. classMap[`${areaName}@${name}`] = ID;
  127. }); */
  128. // 第一行获取行映射
  129. const colMap = {};
  130. for (let col = 0; col < sheetData[0].length; col++) {
  131. const cellText = sheetData[0][col];
  132. switch (cellText) {
  133. case '地区':
  134. colMap.area = col;
  135. break;
  136. case '分类':
  137. colMap.class = col;
  138. break;
  139. case '编码':
  140. colMap.code = col;
  141. break;
  142. case '名称':
  143. colMap.name = col;
  144. break;
  145. case '规格型号':
  146. colMap.specs = col;
  147. break;
  148. case '单位':
  149. colMap.unit = col;
  150. break;
  151. case '不含税价':
  152. colMap.noTaxPrice = col;
  153. break;
  154. case '含税价':
  155. colMap.taxPrice = col;
  156. break;
  157. }
  158. }
  159. // 提取数据
  160. const data = [];
  161. const classData = [];
  162. const areaClassDataMap = {};
  163. let curAreaName;
  164. let curClassName;
  165. let curClassID;
  166. for (let row = 1; row < sheetData.length; row++) {
  167. const areaName = sheetData[row][colMap.area] || '';
  168. const className = sheetData[row][colMap.class] || '';
  169. const code = sheetData[row][colMap.code] || '';
  170. const name = sheetData[row][colMap.name] || '';
  171. const specs = sheetData[row][colMap.specs] || '';
  172. const unit = sheetData[row][colMap.unit] || '';
  173. const noTaxPrice = sheetData[row][colMap.noTaxPrice] || '';
  174. const taxPrice = sheetData[row][colMap.taxPrice] || '';
  175. if (!className && !code && !name && !specs && !noTaxPrice && !taxPrice) { // 认为是空数据
  176. continue;
  177. }
  178. if (areaName && areaName !== curAreaName) {
  179. curAreaName = areaName;
  180. }
  181. const areaID = areaMap[curAreaName];
  182. if (!areaID) {
  183. continue;
  184. }
  185. if (className && className !== curClassName) {
  186. curClassName = className;
  187. const classItem = {
  188. libID,
  189. areaID,
  190. ID: uuidV1(),
  191. ParentID: '-1',
  192. NextSiblingID: '-1',
  193. name: curClassName
  194. };
  195. curClassID = classItem.ID;
  196. classData.push(classItem);
  197. (areaClassDataMap[areaID] || (areaClassDataMap[areaID] = [])).push(classItem);
  198. const preClassItem = areaClassDataMap[areaID][areaClassDataMap[areaID].length - 2];
  199. if (preClassItem) {
  200. preClassItem.NextSiblingID = classItem.ID;
  201. }
  202. }
  203. if (!curClassID) {
  204. continue;
  205. }
  206. data.push({
  207. ID: uuidV1(),
  208. compilationID,
  209. libID,
  210. areaID,
  211. classID: curClassID,
  212. period: libs[0].period,
  213. code,
  214. name,
  215. specs,
  216. unit,
  217. noTaxPrice,
  218. taxPrice
  219. });
  220. }
  221. if (classData.length) {
  222. await priceInfoClassModel.remove({ libID });
  223. await priceInfoClassModel.insertMany(classData);
  224. }
  225. if (data.length) {
  226. await priceInfoItemModel.remove({ libID });
  227. await priceInfoItemModel.insertMany(data);
  228. } else {
  229. throw 'excel没有有效数据。'
  230. }
  231. }
  232. // 导入excel关键字数据(主表+副表),目前只针对珠海,根据列号导入
  233. /*
  234. 主表:主从对应码 别名编码 材料名称 规格 单位 含税价(元) 除税价(元) 月份备注 计算式
  235. 副表:主从对应码 关键字 单位 关键字效果 组别 选项号
  236. */
  237. async function importMainSubData(libID, areaID, mainData, subData) {
  238. const lib = await priceInfoLibModel.findOne({ ID: libID }).lean();
  239. if (!lib) {
  240. throw new Error('库不存在');
  241. }
  242. /* const zh = await priceInfoAreaModel.findOne({ name: { $regex: '珠海' } }).lean();
  243. if (!zh) {
  244. throw new Error('该库不存在珠海地区');
  245. } */
  246. const area = await priceInfoAreaModel.findOne({ ID: areaID }).lean();
  247. if (!area) {
  248. throw new Error('不存在该地区');
  249. }
  250. // 删除珠海地区所有材料
  251. await priceInfoItemModel.deleteMany({ libID, areaID });
  252. const classItems = await priceInfoClassModel.find({ libID, areaID }).lean();
  253. // 分类树前四位编码 - 分类节点ID映射表
  254. let otherClassID = '';
  255. const classMap = {};
  256. classItems.forEach(item => {
  257. if (item.name) {
  258. if (!otherClassID && /其他/.test(item.name)) {
  259. otherClassID = item.ID;
  260. }
  261. const code = item.name.substr(0, 4);
  262. if (/\d{4}/.test(code)) {
  263. classMap[code] = item.ID;
  264. }
  265. }
  266. });
  267. // 主从对应码 - 关键字数组映射
  268. const keywordMap = {};
  269. for (let row = 1; row < subData.length; row++) {
  270. const rowData = subData[row];
  271. const keywordItem = {
  272. code: rowData[0] ? String(rowData[0]) : '',
  273. keyword: rowData[1] || '',
  274. unit: rowData[2] || '',
  275. coe: rowData[3] || '',
  276. group: rowData[4] || '',
  277. optionCode: rowData[5] || '',
  278. };
  279. if (!keywordItem.code) {
  280. continue;
  281. }
  282. (keywordMap[keywordItem.code] || (keywordMap[keywordItem.code] = [])).push(keywordItem);
  283. }
  284. const priceItems = [];
  285. for (let row = 1; row < mainData.length; row++) {
  286. const rowData = mainData[row];
  287. const code = rowData[0] ? String(rowData[0]) : '';
  288. if (!code) {
  289. continue;
  290. }
  291. const matchCode = code.substring(0, 4);
  292. const classID = classMap[matchCode] || otherClassID;
  293. const priceItem = {
  294. code,
  295. libID,
  296. classID,
  297. ID: uuidV1(),
  298. compilationID: lib.compilationID,
  299. areaID,
  300. period: lib.period,
  301. classCode: rowData[1] || '',
  302. name: rowData[2] || '',
  303. specs: rowData[3] || '',
  304. unit: rowData[4] || '',
  305. taxPrice: rowData[5] || '',
  306. noTaxPrice: rowData[6] || '',
  307. dateRemark: rowData[7] || '',
  308. expString: rowData[8] || '',
  309. keywordList: keywordMap[code] || [],
  310. }
  311. priceItems.push(priceItem);
  312. }
  313. if (priceItems.length) {
  314. await priceInfoItemModel.insertMany(priceItems);
  315. }
  316. }
  317. // 仅导入关键字excel
  318. async function importKeyData(libID, areaID, subData) {
  319. const lib = await priceInfoLibModel.findOne({ ID: libID }).lean();
  320. if (!lib) {
  321. throw new Error('库不存在');
  322. }
  323. /* const zh = await priceInfoAreaModel.findOne({ name: { $regex: '珠海' } }).lean();
  324. if (!zh) {
  325. throw new Error('该库不存在珠海地区');
  326. } */
  327. const area = await priceInfoAreaModel.findOne({ ID: areaID }).lean();
  328. if (!area) {
  329. throw new Error('不存在该地区');
  330. }
  331. // 主从对应码 - 关键字数组映射
  332. const keywordMap = {};
  333. for (let row = 1; row < subData.length; row++) {
  334. const rowData = subData[row];
  335. const keywordItem = {
  336. code: rowData[0] ? String(rowData[0]) : '',
  337. keyword: rowData[1] || '',
  338. unit: rowData[2] || '',
  339. coe: rowData[3] || '',
  340. group: rowData[4] || '',
  341. optionCode: rowData[5] || '',
  342. };
  343. if (!keywordItem.code) {
  344. continue;
  345. }
  346. (keywordMap[keywordItem.code] || (keywordMap[keywordItem.code] = [])).push(keywordItem);
  347. }
  348. const priceItems = await priceInfoItemModel.find({ libID: lib.ID, areaID, period: lib.period, compilationID: lib.compilationID }, '-_id ID code areaID period compilationID classID').lean();
  349. const bulks = [];
  350. priceItems.forEach(item => {
  351. if (item.code && keywordMap[item.code]) {
  352. bulks.push({ updateOne: { filter: { ID: item.ID, areaID: item.areaID, compilationID: item.compilationID, period: item.period, classID: item.classID }, update: { $set: { keywordList: keywordMap[item.code] || [] } } } });
  353. }
  354. });
  355. if (bulks.length) {
  356. await priceInfoItemModel.bulkWrite(bulks);
  357. }
  358. }
  359. // 获取费用定额的地区数据
  360. async function getAreas(compilationID) {
  361. return await priceInfoAreaModel.find({ compilationID }, '-_id ID name serialNo').sort({ serialNo: 1 }).lean();
  362. }
  363. async function updateAres(updateData) {
  364. const bulks = [];
  365. updateData.forEach(({ ID, field, value }) => bulks.push({
  366. updateOne: {
  367. filter: { ID },
  368. update: { [field]: value }
  369. }
  370. }));
  371. if (bulks.length) {
  372. await priceInfoAreaModel.bulkWrite(bulks);
  373. }
  374. }
  375. async function insertAreas(insertData) {
  376. await priceInfoAreaModel.insertMany(insertData);
  377. }
  378. async function deleteAreas(deleteData) {
  379. await priceInfoClassModel.remove({ areaID: { $in: deleteData } });
  380. await priceInfoItemModel.remove({ areaID: { $in: deleteData } });
  381. await priceInfoAreaModel.remove({ ID: { $in: deleteData } });
  382. }
  383. async function getClassData(libID, areaID) {
  384. if (libID && areaID) {
  385. return await priceInfoClassModel.find({ libID, areaID }, '-_id').lean();
  386. }
  387. if (libID) {
  388. return await priceInfoClassModel.find({ libID }, '-_id').lean();
  389. }
  390. if (areaID) {
  391. return await priceInfoClassModel.find({ areaID }, '-_id').lean();
  392. }
  393. }
  394. async function getPriceData(classIDList) {
  395. return await priceInfoItemModel.find({ classID: { $in: classIDList } }, '-_id').lean();
  396. }
  397. const UpdateType = {
  398. UPDATE: 'update',
  399. DELETE: 'delete',
  400. CREATE: 'create',
  401. };
  402. async function editPriceData(postData) {
  403. const bulks = [];
  404. postData.forEach(data => {
  405. const filter = { ID: data.ID };
  406. // 为了命中索引,ID暂时还没添加索引,数据量太大,担心内存占用太多
  407. if (data.areaID) {
  408. filter.areaID = data.areaID;
  409. }
  410. if (data.compilationID) {
  411. filter.compilationID = data.compilationID;
  412. }
  413. if (data.period) {
  414. filter.period = data.period;
  415. }
  416. if (data.type === UpdateType.UPDATE) {
  417. bulks.push({
  418. updateOne: {
  419. filter,
  420. update: { ...data.data }
  421. }
  422. });
  423. } else if (data.type === UpdateType.DELETE) {
  424. bulks.push({
  425. deleteOne: {
  426. filter,
  427. }
  428. });
  429. } else {
  430. bulks.push({
  431. insertOne: {
  432. document: data.data
  433. }
  434. });
  435. }
  436. });
  437. if (bulks.length) {
  438. await priceInfoItemModel.bulkWrite(bulks);
  439. }
  440. }
  441. async function editClassData(updateData) {
  442. const bulks = [];
  443. const deleteIDList = [];
  444. updateData.forEach(({ type, filter, update, document }) => {
  445. if (type === UpdateType.UPDATE) {
  446. bulks.push({
  447. updateOne: {
  448. filter,
  449. update
  450. }
  451. });
  452. } else if (type === UpdateType.DELETE) {
  453. deleteIDList.push(filter.ID);
  454. bulks.push({
  455. deleteOne: {
  456. filter
  457. }
  458. });
  459. } else {
  460. bulks.push({
  461. insertOne: {
  462. document
  463. }
  464. });
  465. }
  466. });
  467. if (deleteIDList.length) {
  468. await priceInfoItemModel.remove({ classID: { $in: deleteIDList } });
  469. }
  470. if (bulks.length) {
  471. await priceInfoClassModel.bulkWrite(bulks);
  472. }
  473. }
  474. //计算指标平均值
  475. function calcIndexAvg(period, areaID, compilationID, preCodeMap) {
  476. const newData = [];
  477. for (const code in preCodeMap) {
  478. const indexArr = preCodeMap[code];
  479. let total = 0;
  480. for (const index of indexArr) {
  481. total = scMathUtil.roundForObj(total + index, 2);
  482. }
  483. const avg = scMathUtil.roundForObj(total / indexArr.length, 2);
  484. newData.push({ ID: uuidV1(), code, period, areaID, compilationID, index: avg })
  485. }
  486. return newData
  487. }
  488. //一个月里有classCode相同,但是价格不同的情况,取平均值
  489. function getClassCodePriceAvgMap(items) {
  490. const classCodeMap = {};
  491. for (const b of items) {
  492. classCodeMap[b.classCode] ? classCodeMap[b.classCode].push(b) : classCodeMap[b.classCode] = [b];
  493. }
  494. for (const classCode in classCodeMap) {
  495. const baseItems = classCodeMap[classCode];
  496. const item = baseItems[0];
  497. if (baseItems.length > 1) {
  498. let sum = 0;
  499. for (const b of baseItems) {
  500. sum += parseFloat(b.noTaxPrice);
  501. }
  502. classCodeMap[classCode] = { code: item.code, name: item.name, price: scMathUtil.roundForObj(sum / baseItems.length, 2) };
  503. } else {
  504. classCodeMap[classCode] = { code: item.code, name: item.name, price: parseFloat(item.noTaxPrice) }
  505. }
  506. }
  507. return classCodeMap
  508. }
  509. async function calcPriceIndex(libID, period, areaID, compilationID) {
  510. const baseItems = await priceInfoItemModel.find({ areaID, period: '2022年-01月' }).lean();//以珠海 22年1月的数据为基准
  511. const currentItems = await priceInfoItemModel.find({ areaID, period }).lean();
  512. const preCodeMap = {};//编码前4位-指数映射
  513. const baseAvgMap = getClassCodePriceAvgMap(baseItems);
  514. const currentAvgMap = getClassCodePriceAvgMap(currentItems);
  515. let message = '';
  516. for (const classCode in currentAvgMap) {
  517. const c = currentAvgMap[classCode];
  518. const preCode = c.code.substr(0, 4);
  519. let index = 1;
  520. const baseItem = baseAvgMap[classCode];
  521. const tem = { index, classCode, name: c.name, code: c.code };
  522. if (baseItem && baseItem.price) {//一个月份里有多个值时,先取平均再计算
  523. index = scMathUtil.roundForObj(c.price / baseItem.price, 2);
  524. tem.baseName = baseItem.name;
  525. }
  526. tem.index = index;
  527. if (Math.abs(index - 1) > 0.2) {
  528. const string = `classCode:${tem.classCode},编号:${tem.code},基础名称:${tem.baseName},当前库中名称:${tem.name},指数:${tem.index};\n`;
  529. message += string;
  530. console.log(string)
  531. }
  532. preCodeMap[preCode] ? preCodeMap[preCode].push(index) : preCodeMap[preCode] = [index];
  533. }
  534. const newIndexData = calcIndexAvg(period, areaID, compilationID, preCodeMap)
  535. //删除旧数据
  536. await priceInfoIndexModel.deleteMany({ areaID, period });
  537. //插入新数据
  538. await priceInfoIndexModel.insertMany(newIndexData);
  539. return message;
  540. }
  541. async function exportExcelData(libID, areaID) {
  542. const area = await priceInfoAreaModel.findOne({ ID: areaID }).lean();
  543. if (!area) {
  544. return [];
  545. }
  546. const priceItems = await priceInfoItemModel.find({ libID, areaID }).lean();
  547. // 整理数据
  548. let priceData = [];
  549. for (const tmp of priceItems) {
  550. const item = [tmp.code || '', tmp.classCode || '', tmp.name || '', tmp.specs || '', tmp.unit || '', tmp.taxPrice || '', tmp.noTaxPrice || '', tmp.dateRemark || '', tmp.expString || ''];
  551. priceData.push(item);
  552. }
  553. const excelData = [['主从对应码', '别名编码', '材料名称', '规格型号', '单位', '含税价(元)', '除税价(元)', '多价备注', '计算式']];
  554. excelData.push.apply(excelData, priceData);
  555. return excelData;
  556. }
  557. // 按库导出信息价库完整数据,不需要带上地区
  558. async function exportInfoPriceByLib(libID) {
  559. const lib = await priceInfoLibModel.findOne({ ID: libID }).lean();
  560. if (!lib) {
  561. throw new Error('不存在该信息价库!');
  562. }
  563. const { compilationID } = lib;
  564. const priceLibs = await priceInfoLibModel.find({ ID: libID }, '-_id').lean();
  565. const priceClasses = await priceInfoClassModel.find({ libID }, '-_id').lean();
  566. const priceItems = await priceInfoItemModel.find({ libID }, '-_id').lean();
  567. const exportData = { compilationID, priceLibs, priceClasses, priceItems };
  568. const str = JSON.stringify(exportData);
  569. exportData.md5 = sms.md5(str);
  570. return { jsonStr: JSON.stringify(exportData), period: lib.period, name: lib.name };
  571. }
  572. // 按编办导出信息价库完整数据,需要带上地区
  573. async function exportInfoPriceByCompilation(compilationID) {
  574. const areas = await priceInfoAreaModel.find({ compilationID }, '-_id').lean();
  575. const priceLibs = await priceInfoLibModel.find({ compilationID }, '-_id').lean();
  576. const libIDs = priceLibs.map(lib => lib.ID);
  577. const priceClasses = await priceInfoClassModel.find({ libID: { $in: libIDs } }, '-_id').lean();
  578. const priceItems = await priceInfoItemModel.find({ libID: { $in: libIDs } }, '-_id').lean();
  579. const exportData = { compilationID, areas, priceLibs, priceClasses, priceItems };
  580. const str = JSON.stringify(exportData);
  581. exportData.md5 = sms.md5(str);
  582. return { jsonStr: JSON.stringify(exportData), period: lib.period, name: lib.name };
  583. }
  584. const getMatchSummaryKey = (item) => {
  585. const props = ['name', 'specs', 'unit'];
  586. return props.map(prop => {
  587. const subKey = item[prop] ? item[prop].trim() : '';
  588. return subKey;
  589. }).join('@');
  590. }
  591. const getSummaryMap = (items) => {
  592. const map = {};
  593. items.forEach(item => {
  594. const key = getMatchSummaryKey(item);
  595. map[key] = item;
  596. });
  597. return map;
  598. }
  599. // 匹配总表
  600. // 按规则匹配信息价的编码、别名编码、计算式
  601. // 匹配规则:名称+规格型号+单位,与总表一致则自动填入编码、别名编码、计算式
  602. const matchSummary = async (compilationID, libID, areaID) => {
  603. const updateBulks = [];
  604. const areaFilter = { compilationID };
  605. if (areaID) {
  606. areaFilter.ID = areaID;
  607. }
  608. const areas = await priceInfoAreaModel.find(areaFilter, '-_id ID name').lean();
  609. const areaNameMap = {};
  610. areas.forEach(area => {
  611. areaNameMap[area.ID] = area.name;
  612. });
  613. const filter = { libID };
  614. if (areaID) {
  615. filter.areaID = areaID;
  616. }
  617. const priceItems = await priceInfoItemModel.find(filter, '-_id ID compilationID name specs unit areaID period').lean();
  618. const summaryItems = await priceInfoSummaryModel.find({}, '-_id ID name specs unit code classCode expString').lean();
  619. const summaryMap = getSummaryMap(summaryItems);
  620. priceItems.forEach(priceItem => {
  621. const key = getMatchSummaryKey(priceItem);
  622. const matched = summaryMap[key];
  623. if (matched) {
  624. const updateObj = {
  625. code: matched.code,
  626. classCode: matched.classCode,
  627. expString: matched.expString,
  628. }
  629. updateBulks.push({
  630. updateOne: {
  631. filter: { ID: priceItem.ID, compilationID: priceItem.compilationID, areaID: priceItem.areaID, period: priceItem.period },
  632. update: updateObj
  633. }
  634. })
  635. }
  636. });
  637. if (updateBulks.length) {
  638. await priceInfoItemModel.bulkWrite(updateBulks);
  639. }
  640. }
  641. // 获取空数据(没有别名编码)
  642. const getPriceEmptyData = async (compilationID, libID, areaID) => {
  643. const lib = await priceInfoLibModel.findOne({ ID: libID }).lean();
  644. if (!lib) {
  645. return [];
  646. }
  647. const filter = { compilationID, libID, period: lib.period };
  648. if (areaID) {
  649. filter.areaID = areaID;
  650. }
  651. const priceItems = await priceInfoItemModel.find(filter).lean();
  652. return priceItems.filter(item => !item.classCode);
  653. };
  654. const getMatchPrice = (allInfoPrice, nameArray, needHandleLongWord = true) => {
  655. let items = [];
  656. let maxNum = 0; // 最大匹配数
  657. const matchMap = {}; // 匹配储存
  658. let handleLongWord = false;
  659. if (needHandleLongWord) {
  660. for (const na of nameArray) {
  661. if (na.length >= 5) handleLongWord = true;
  662. }
  663. }
  664. for (const info of allInfoPrice) {
  665. // specs
  666. const matchString = alias(info.name + info.specs); // 组合名称和规格型号
  667. info.matchString = matchString;
  668. let matchCount = 0;
  669. for (const na of nameArray) {
  670. if (matchString.indexOf(na) !== -1) {
  671. matchCount += 1;
  672. if (needHandleLongWord && na.length >= 5) handleLongWord = false; // 有5个字的,并且匹配上了,这里就为false不用再处理一次了
  673. }
  674. }
  675. if (matchCount > 0) {
  676. if (matchMap[matchCount]) {
  677. matchMap[matchCount].push(info);
  678. } else {
  679. matchMap[matchCount] = [info];
  680. }
  681. if (matchCount > maxNum) maxNum = matchCount;
  682. }
  683. }
  684. if (maxNum > 0) items = matchMap[maxNum];
  685. return { items, handleLongWord };
  686. }
  687. // 获取推荐总表数据
  688. const getRecommendPriceSummaryData = async (keyword) => {
  689. const nameArray = getWordArray(keyword);
  690. console.log(`nameArray`);
  691. console.log(nameArray);
  692. const allItems = await priceInfoSummaryModel.find({}).lean();
  693. let { items } = getMatchPrice(allItems, nameArray);
  694. // 按匹配位置排序 如[ '橡胶', '胶圈', '给水' ] 先显示橡胶
  695. items = _.sortBy(items, item => {
  696. const ms = item.matchString;
  697. for (let i = 0; i < nameArray.length; i += 1) {
  698. if (ms.indexOf(nameArray[i]) !== -1) return i;
  699. }
  700. return 0;
  701. });
  702. return items;
  703. }
  704. module.exports = {
  705. getLibs,
  706. createLib,
  707. updateLib,
  708. deleteLib,
  709. processChecking,
  710. crawlDataByCompilation,
  711. importExcelData,
  712. importMainSubData,
  713. importKeyData,
  714. getAreas,
  715. updateAres,
  716. insertAreas,
  717. deleteAreas,
  718. getClassData,
  719. calcPriceIndex,
  720. getPriceData,
  721. editPriceData,
  722. editClassData,
  723. exportExcelData,
  724. exportInfoPriceByLib,
  725. exportInfoPriceByCompilation,
  726. matchSummary,
  727. getPriceEmptyData,
  728. getRecommendPriceSummaryData,
  729. }