project_facade.js 22 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612
  1. /**
  2. * Created by zhang on 2018/1/26.
  3. */
  4. module.exports = {
  5. markUpdateProject:markUpdateProject,
  6. removeProjectMark:removeProjectMark,
  7. updateNodes:updateNodes,
  8. calcInstallationFee:calcInstallationFee,
  9. calcOverHeightFee: calcOverHeightFee,
  10. saveProperty: saveProperty,
  11. getDefaultColSetting: getDefaultColSetting,
  12. markProjectsToChange:markProjectsToChange,
  13. getSEIProjects:getSEIProjects,
  14. loadSEIProjectData:loadSEIProjectData,
  15. setSEILibData:setSEILibData,
  16. getIndexReportData:getIndexReportData
  17. };
  18. let mongoose = require('mongoose');
  19. let logger = require("../../../logs/log_helper").logger;
  20. let projectsModel = mongoose.model('projects');
  21. let async_n = require("async");
  22. let _ = require('lodash');
  23. let ration_model = require('../models/ration');
  24. let bill_model = require('../models/bills');
  25. let consts = require('../models/project_consts');
  26. let projectConsts = consts.projectConst;
  27. let ration_glj_model = mongoose.model('ration_glj');
  28. let rationTemplateModel = mongoose.model('ration_template');
  29. let project_glj_model = mongoose.model('glj_list');
  30. let ration_glj_facade = require("../../ration_glj/facade/ration_glj_facade");
  31. const uuidV1 = require('uuid/v1');
  32. const gljUtil = require('../../../public/gljUtil');
  33. let stdColSettingModel = mongoose.model('std_main_col_lib');
  34. import GLJListModel from "../../glj/models/glj_list_model";
  35. let economicLib = mongoose.model('std_economic_lib');
  36. let engineerFeatureLib = mongoose.model('std_engineer_feature_lib');
  37. let engineerInfoLib = mongoose.model('std_engineer_info_lib');
  38. let mainQuantityLib = mongoose.model('std_main_quantity_lib');
  39. let materialLib = mongoose.model('std_material_lib');
  40. import fixedFlag from '../../common/const/bills_fixed';
  41. const scMathUtil = require('../../../public/scMathUtil').getUtil();
  42. const billsLibDao = require("../../bills_lib/models/bills_lib_interfaces");
  43. async function calcInstallationFee(data) {
  44. let result={};
  45. let billTasks = generateTasks(data.bills,data.useID);
  46. let rationTasks = generateTasks(data.ration,data.useID);
  47. if(billTasks.length>0){
  48. await bill_model.model.bulkWrite(billTasks);
  49. }
  50. console.log(rationTasks);
  51. if(rationTasks.length>0){
  52. await ration_model.model.bulkWrite(rationTasks);
  53. }
  54. //如果删除定额,需要删除对应的工料机
  55. if(data.ration.delete.length>0){
  56. let rationIDS = _.map(data.ration.delete,'ID');
  57. await ration_glj_model.deleteMany({projectID: data.ration.delete[0].projectID, rationID: {"$in": rationIDS}});//删除定额工料机
  58. }
  59. let rationGLJTasks = [];
  60. let updateList = [];
  61. if(data.ration.update.length>0){//如果有需要更新的定额工料机
  62. for(let ur of data.ration.update){
  63. for(let g of ur.glj){
  64. let gTasks = {
  65. updateOne:{
  66. filter:{
  67. ID:g.ID,
  68. projectID:g.projectID
  69. },
  70. update :{
  71. quantity:g.quantity,
  72. rationItemQuantity:g.rationItemQuantity
  73. }
  74. }
  75. };
  76. rationGLJTasks.push(gTasks);
  77. updateList.push(g);
  78. }
  79. }
  80. }
  81. if(rationGLJTasks.length>0){
  82. await ration_glj_model.bulkWrite(rationGLJTasks);
  83. }
  84. let newGljList = [];
  85. if(data.ration.add.length>0){//新增的安装子目要增加对应的工料机
  86. for(let nr of data.ration.add){
  87. for(let tkey in nr.glj){
  88. newGljList.push(await addInstallationGLJ(nr.glj[tkey]));
  89. }
  90. }
  91. }
  92. if(newGljList.length>0){
  93. await ration_glj_model.insertMany(newGljList);
  94. }
  95. result.update = updateList;
  96. result.add = newGljList;
  97. return result;
  98. }
  99. async function addInstallationGLJ(glj) {
  100. glj.ID = uuidV1();
  101. let info = await ration_glj_facade.getInfoFromProjectGLJ(glj);
  102. let newRecode = ration_glj_facade.createNewRecord(info);
  103. return newRecode;
  104. }
  105. function generateTasks(data,userID) {
  106. let tasks=[];
  107. let deleteInfo={deleted: true, deleteDateTime: new Date(), deleteBy: userID};
  108. if(data.delete && data.delete.length > 0){
  109. for(let bd of data.delete){
  110. //原先是假删除,现在改成真删除
  111. let task = {
  112. deleteOne:{
  113. filter:{
  114. ID:bd.ID,
  115. projectID:bd.projectID
  116. }
  117. }
  118. };
  119. /* let task={
  120. updateOne:{
  121. filter:{
  122. ID:bd.ID,
  123. projectID:bd.projectID
  124. },
  125. update :{
  126. deleteInfo:deleteInfo
  127. }
  128. }
  129. };*/
  130. tasks.push(task);
  131. }
  132. }
  133. if(data.add && data.add.length > 0){
  134. for(let n_data of data.add){
  135. let task = {
  136. insertOne :{
  137. document:n_data
  138. }
  139. };
  140. tasks.push(task);
  141. }
  142. }
  143. return tasks;
  144. }
  145. /**
  146. * 计取超高降效费,可能包含更新清单、更新定额、新增清单、新增定额及其子数据、删除定额及其子数据
  147. * @param {Object} data - {updateData: {ration: [],..}, addData: {ration: [],...}, deleteData: {ration: [],...}}
  148. * @return {Object} - {bills: Array, rationGLJ: Array}
  149. */
  150. async function calcOverHeightFee(data) {
  151. // 更新数据
  152. async function update({ project, bills, ration }) {
  153. const tasks = [];
  154. // 更新项目
  155. if (project && project.ID) {
  156. const projectTask = projectsModel.update({ ID: project.ID },
  157. { 'property.overHeightOption': project.overHeightOption, 'property.overHeightSpecificID': project.overHeightSpecificID });
  158. tasks.push(projectTask);
  159. }
  160. // 更新清单和定额的超高降效列
  161. const models = [];
  162. if (bills.length) {
  163. models.push({ model: bill_model.model, items: bills });
  164. }
  165. if (ration.length) {
  166. models.push({ model: ration_model.model, items: ration });
  167. }
  168. models.forEach(modelData => {
  169. const bulkTask = modelData.items.map(item => (
  170. {
  171. updateOne: {
  172. filter: { ID: item.ID },
  173. update: { overHeight: item.overHeight }
  174. }
  175. }));
  176. const task = modelData.model.bulkWrite(bulkTask);
  177. tasks.push(task);;
  178. });
  179. if (!tasks.length) {
  180. return;
  181. }
  182. await Promise.all(tasks);
  183. }
  184. // 插入数据
  185. async function add({ bills, ration, rationGLJ}) {
  186. const tasks = [];
  187. // 匹配标准清单,加上工作内容等数据
  188. for (const billsItem of bills) {
  189. let stdBills = await billsLibDao.getStdBillsByCode(billsItem);
  190. stdBills = stdBills ? stdBills._doc : null;
  191. if (stdBills) {
  192. // 获取项目清单所需要的数据
  193. const projectBillsData = billsLibDao.getDataToProjectBills(stdBills);
  194. Object.assign(billsItem, projectBillsData);
  195. } else {
  196. delete billsItem.billsLibId;
  197. }
  198. billsItem.code += '001';
  199. }
  200. // 新增清单
  201. if (bills.length) {
  202. tasks.push(bill_model.model.insertMany(bills));
  203. }
  204. // 新增定额
  205. if (ration.length) {
  206. tasks.push(ration_model.model.insertMany(ration));
  207. }
  208. // 完整的定额人材机数据
  209. let completeRationGLJList = [];
  210. if (rationGLJ.length) {
  211. // 定额人材机需要新增项目人材机、单价文件、且返回完整的定额人材机数据
  212. const rationGLJTasks = rationGLJ.map(glj => addInstallationGLJ(glj));
  213. completeRationGLJList = await Promise.all(rationGLJTasks);
  214. // 新增定额人材机
  215. tasks.push(ration_glj_model.insertMany(completeRationGLJList));
  216. }
  217. // 返回新的清单和定额人材机数据
  218. const rst = {
  219. bills,
  220. rationGLJ: completeRationGLJList,
  221. }
  222. if (!tasks.length) {
  223. return rst;
  224. }
  225. await Promise.all(tasks);
  226. return rst;
  227. }
  228. // 删除数据
  229. async function del({ ration }) {
  230. const tasks = [];
  231. const rationIDList = ration.map(item => item.ID);
  232. if (!rationIDList.length) {
  233. return;
  234. }
  235. // 删除定额数据
  236. const rationTask = ration_model.model.deleteMany({ ID: {$in: rationIDList} });
  237. tasks.push(rationTask);
  238. // 删除定额人材机数据
  239. const rationGLJTask = ration_glj_model.deleteMany({ rationID: {$in: rationIDList} });
  240. tasks.push(rationGLJTask);
  241. await Promise.all(tasks);
  242. }
  243. // 处理任务
  244. const { updateData, addData, deleteData } = data;
  245. const updateTask = update(updateData);
  246. const addTask = add(addData);
  247. const delTask = del(deleteData);
  248. const [updateRst, addRst, delRst] = await Promise.all([updateTask, addTask, delTask]);
  249. return addRst;
  250. }
  251. async function updateNodes(datas){
  252. let nodeGroups = _.groupBy(datas,'type');
  253. let rationTasks = [];
  254. let billTasks = [];
  255. let rationGLJTasks = [];
  256. let projectGLJTasks = [];
  257. let projectTasks = [];
  258. let rationTemplateTasks = [];
  259. let asyncTasks = [];
  260. for(let type in nodeGroups){
  261. for(let node of nodeGroups[type]){
  262. if(type == projectConsts.BILLS){
  263. billTasks.push(getTask(node));
  264. }else if(type == projectConsts.RATION){
  265. rationTasks.push(getTask(node));
  266. }else if(type == projectConsts.RATION_GLJ){
  267. rationGLJTasks.push(getTask(node));
  268. }else if(type == projectConsts.PROJECTGLJ){
  269. projectGLJTasks.push(getTask(node,'id'));
  270. }else if(type == projectConsts.PROJECT){
  271. projectTasks.push(getTask(node));
  272. }else if(type == projectConsts.RATION_TEMPLATE){
  273. rationTemplateTasks.push(getTask(node))
  274. }
  275. }
  276. }
  277. //test------------------------
  278. if (billTasks.length) {
  279. console.log(`billTasks===============================`);
  280. billTasks.forEach(task => {
  281. if (task.updateOne.update.name === '分部分项工程') {
  282. console.log(`task.updateOne.filter`);
  283. console.log(task.updateOne.filter);
  284. console.log(`task.updateOne.update`);
  285. console.log(task.updateOne.update);
  286. }
  287. /*console.log(`task.updateOne.filter`);
  288. console.log(task.updateOne.filter);
  289. console.log(`task.updateOne.update`);
  290. console.log(task.updateOne.update);*/
  291. });
  292. }
  293. //test------------------------
  294. rationTasks.length>0?asyncTasks.push(ration_model.model.bulkWrite(rationTasks)):'';
  295. billTasks.length>0?asyncTasks.push(bill_model.model.bulkWrite(billTasks)):"";
  296. rationGLJTasks.length>0?asyncTasks.push(ration_glj_model.bulkWrite(rationGLJTasks)):"";
  297. projectGLJTasks.length>0?asyncTasks.push(project_glj_model.bulkWrite(projectGLJTasks)):"";
  298. projectTasks.length>0?asyncTasks.push(projectsModel.bulkWrite(projectTasks)):"";
  299. rationTemplateTasks.length>0?asyncTasks.push(rationTemplateModel.bulkWrite(rationTemplateTasks)):"";
  300. return asyncTasks.length>0?await Promise.all(asyncTasks):"";
  301. function getTask(node,idFiled = 'ID') {
  302. let task={
  303. updateOne:{
  304. filter:{},
  305. update :_.cloneDeep(node.data)
  306. }
  307. };
  308. task.updateOne.filter[idFiled] = node.data[idFiled];//现在复制项目也重新生成一个新的ID了,所以ID是唯一的
  309. delete task.updateOne.update[idFiled];//防止误操作
  310. return task;
  311. }
  312. }
  313. /*function updateNodes(datas,callback) {
  314. let tasks = [];
  315. for(let node of datas){
  316. tasks.push(updateOne(node))
  317. }
  318. async_n.parallel(tasks, function(err, results) {
  319. if (!err){
  320. callback(0, '', results);
  321. }
  322. else{
  323. console.log(err);
  324. callback(1, 'save project failed'+err.message, null);
  325. }
  326. });
  327. function updateOne(node) {
  328. if(node.type == projectConsts.BILLS){
  329. return function (asCallback) {
  330. bill_model.model.findOneAndUpdate({projectID: node.data.projectID, ID: node.data.ID,deleteInfo: null}, node.data,{new: true}, asCallback);
  331. }
  332. }else if(node.type ==projectConsts.RATION){
  333. return function (asCallback) {
  334. ration_model.model.findOneAndUpdate({projectID: node.data.projectID, ID: node.data.ID,deleteInfo: null}, node.data,{new: true}, asCallback);
  335. }
  336. }
  337. }
  338. }*/
  339. //data = {feeRateID:111111,projectID:1245}; type = feeRate
  340. async function markUpdateProject(data,type) {
  341. let query = {deleteInfo:null};
  342. if(type=="feeRate"){//更改了费率
  343. query['property.feeFile.id'] = data.feeRateID;
  344. }
  345. if(type=="unitFile"){//更改了单价文件
  346. query['property.unitPriceFile.id'] = data.unitFileID;//unitPriceFile
  347. }
  348. let projects = await projectsModel.find(query);
  349. return await markProjectsToChange(projects,type,data.projectID);
  350. }
  351. async function markProjectsToChange(projects,type,extProjectID){
  352. let tasks=[];
  353. for(let p of projects){
  354. if(extProjectID && p.ID===extProjectID) continue;//排除当前项目
  355. tasks.push(generateMarkTask(type,p.ID));
  356. }
  357. return tasks.length>0 ? await projectsModel.bulkWrite(tasks):null;
  358. }
  359. async function removeProjectMark(projectID) {
  360. return await projectsModel.findOneAndUpdate({ID:projectID},{"$unset":{"changeMark":1}});
  361. }
  362. function generateMarkTask(value,projectID) {
  363. let task = {
  364. updateOne:{
  365. filter:{
  366. ID:projectID
  367. },
  368. update:{
  369. changeMark:value
  370. }
  371. }
  372. };
  373. return task
  374. }
  375. // {projectID: 5, propertyName: 'aaa', propertyValue: 1}
  376. function saveProperty(data, callback){
  377. let obj = {};
  378. let pn = 'property.' + data.propertyName;
  379. obj[pn] = data.propertyValue;
  380. projectsModel.update({"ID": data.projectID}, obj, function (err) {
  381. if (err) {
  382. logger.err(pn + ' save error: ' + err);
  383. callback(err, null)
  384. } else {
  385. logger.info(pn + ' saved.');
  386. callback('', null);
  387. }}
  388. );
  389. }
  390. async function getDefaultColSetting(libID){
  391. return await stdColSettingModel.findOne({ID: libID, deleted: false}, '-_id main_tree_col');
  392. }
  393. function sortChildren(lists) {
  394. let IDMap ={},nextMap = {}, firstNode = null,newList=[];
  395. for(let l of lists){
  396. if(l.children&&l.children.length > 0) l.children = sortChildren(l.children);//递规排序
  397. IDMap[l.ID] = l;
  398. if(l.NextSiblingID!=-1) nextMap[l.NextSiblingID] = l;
  399. }
  400. for(let t of lists){
  401. if(!nextMap[t.ID]){ //如果在下一节点映射没找到,则是第一个节点
  402. firstNode = t;
  403. break;
  404. }
  405. }
  406. if(firstNode){
  407. newList.push(firstNode);
  408. delete IDMap[firstNode.ID];
  409. setNext(firstNode,newList);
  410. }
  411. //容错处理,如果链断了的情况,直接添加到后面
  412. for(let key in IDMap){
  413. if(IDMap[key]) newList.push(IDMap[key])
  414. }
  415. return newList;
  416. function setNext(node,array) {
  417. if(node.NextSiblingID != -1){
  418. let next = IDMap[node.NextSiblingID];
  419. if(next){
  420. array.push(next);
  421. delete IDMap[next.ID];
  422. setNext(next,array);
  423. }
  424. }
  425. }
  426. }
  427. async function getSEIProjects(projectID) {
  428. let project = await projectsModel.findOne({ID:projectID});
  429. if(!project) throw new Error(`找不到建设项目:${projectID}`);
  430. let tem_e = await projectsModel.find({ParentID:project.ID});
  431. let engineers = [];
  432. for(let e of tem_e){
  433. if(!e.deleteInfo || !e.deleteInfo.deleted){
  434. let tenders = await projectsModel.find({ParentID:e.ID});
  435. let children = [];
  436. for(let t of tenders){
  437. if(!t.deleteInfo || !t.deleteInfo.deleted){
  438. children.push(t);
  439. }
  440. }
  441. e._doc.children = children;
  442. engineers.push(e);
  443. }
  444. }
  445. engineers = sortChildren(engineers);
  446. project._doc.children = engineers;
  447. return project;
  448. }
  449. async function loadSEIProjectData(projectID) {
  450. let gljListModel = new GLJListModel();
  451. let [gljList, mixRatioConnectData,mixRatioMap,unitPriceMap] = await gljListModel.getListByProjectId(projectID);
  452. let rations = await ration_model.getDataSync(projectID);
  453. let bills = await bill_model.getDataSync(projectID);
  454. let ration_gljs = await ration_glj_model.find({projectID:projectID});
  455. let projectGLJs = {
  456. gljList : gljList,
  457. mixRatioConnectData:mixRatioConnectData,
  458. mixRatioMap:mixRatioMap,
  459. unitPriceMap:unitPriceMap
  460. };
  461. return{bills:bills,rations:rations,ration_gljs:ration_gljs,projectGLJs:projectGLJs}
  462. }
  463. async function setSEILibData(property){
  464. if(property.engineerInfoLibID){//工程信息指标
  465. let engineerInfo = await engineerInfoLib.findOne({'ID':property.engineerInfoLibID});
  466. if(engineerInfo) property.engineerInfos = engineerInfo.info;
  467. }
  468. if(property.engineerFeatureLibID){//工程特征指标
  469. let engineerFeature = await engineerFeatureLib.findOne({'ID':property.engineerFeatureLibID});
  470. if(engineerFeature) property.engineerFeatures = engineerFeature.features;
  471. }
  472. if(property.materialLibID){//主要工料指标
  473. let material = await materialLib.findOne({'ID':property.materialLibID});
  474. if(material) property.materials = material.materials;
  475. }
  476. if(property.mainQuantityLibID){//主要工程量指标
  477. let mainQuantity = await mainQuantityLib.findOne({'ID':property.mainQuantityLibID});
  478. if(mainQuantity) property.mainQuantities = mainQuantity.index;
  479. }
  480. if(property.economicLibID){//主要工程量指标
  481. let economic = await economicLib.findOne({'ID':property.economicLibID});
  482. if(economic) property.economics = economic.index;
  483. }
  484. }
  485. async function getIndexReportData(projectID,keyArr) {
  486. let project = await projectsModel.findOne({ID:projectID});
  487. let bills = await bill_model.getDataSync(projectID);
  488. let result = {};
  489. for(let key of keyArr){
  490. switch (key) {
  491. case 'ProjectCostFields':
  492. result[key] =getEngineerCostData(project.property,bills);
  493. break;
  494. case 'ProjectEcoFields':
  495. result[key] = getEconomicDatas(project.property,bills);
  496. break;
  497. case 'ProjectLabMaterialFields':
  498. result[key] = await getMainMaterialDatas(projectID,project.property);
  499. break;
  500. case 'ProjectQtyFields':
  501. result[key] = await getQuantityDatas(project.property,bills);
  502. break;
  503. case 'ProjectInfoFields':
  504. result[key] = getEngineerInfoData(project.property.engineerInfos);
  505. break;
  506. case 'ProjectFeatureFields':
  507. result[key] = getEngineerFeaturesDatas(project.property.engineerFeatures);
  508. break;
  509. }
  510. }
  511. return result
  512. }
  513. function getEngineerInfoData(engineerInfos) {
  514. let datas = [];
  515. for(let info of engineerInfos){
  516. let d = {
  517. name:info.dispName,
  518. value:info.value
  519. };
  520. datas.push(d);
  521. }
  522. return datas;
  523. }
  524. function getEngineerFeaturesDatas(engineerFeatures) {
  525. let datas = [];
  526. if (engineerFeatures !== null && engineerFeatures !== undefined) {
  527. for(let f of engineerFeatures){
  528. let tem = {
  529. ID:f.ID,
  530. name:f.name,
  531. value:f.value,
  532. ParentID:f.ParentID
  533. }
  534. datas.push(tem);
  535. }
  536. }
  537. return datas;
  538. }
  539. function getQuantityDatas(property,bills) {
  540. return gljUtil.getQuantityDatas(property.engineerFeatures,property.mainQuantities,bills,fixedFlag,_,scMathUtil,property.decimal)
  541. }
  542. function getEconomicDatas(property,bills) {
  543. return gljUtil.getEconomicDatas(property.engineerFeatures,property.economics,bills,fixedFlag,_,scMathUtil,property.decimal)
  544. }
  545. function getEngineerCostData(property,bills){
  546. let datas = [];
  547. let priceIndex = gljUtil.getEngineerCostData(property,bills,fixedFlag,scMathUtil);
  548. for(let c of priceIndex.children){
  549. let tem = {
  550. name:c.name,
  551. cost:parseFloat(c.attrs[0].value),
  552. unitCost:parseFloat(c.attrs[1].value),
  553. per:parseFloat(c.attrs[2].value)
  554. };
  555. datas.push(tem);
  556. }
  557. return datas;
  558. }
  559. async function getMainMaterialDatas(projectID,property) {
  560. let gljListModel = new GLJListModel();
  561. let [gljList, mixRatioConnectData,mixRatioMap,unitPriceMap] = await gljListModel.getListByProjectId(projectID, property.unitPriceFile?property.unitPriceFile.id:null);
  562. gljList = JSON.parse(JSON.stringify(gljList));
  563. await calcProjectGLJQuantity(projectID,{gljList:gljList,mixRatioMap:mixRatioMap},property);
  564. return gljUtil.getMainMaterialDatas(property.engineerFeatures,property.materials,{gljList:gljList},property.calcOptions,property.decimal,false,_,scMathUtil)
  565. }
  566. async function calcProjectGLJQuantity(projectID,projectGLJDatas,property){
  567. let q_decimal = property.decimal.glj.quantity;
  568. let rationGLJDatas = await ration_glj_model.find({'projectID':projectID});
  569. let rationDatas = await ration_model.model.find({'projectID':projectID});
  570. gljUtil.calcProjectGLJQuantity(projectGLJDatas,rationGLJDatas,rationDatas,[],q_decimal)
  571. }