glj_calculate_facade.js 18 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464
  1. /**
  2. * Created by chen on 2017/7/12.
  3. */
  4. let mongoose = require('mongoose');
  5. let _=require("lodash");
  6. let ration_glj = mongoose.model('ration_glj');
  7. let ration = mongoose.model('ration');
  8. let ration_coe = mongoose.model('ration_coe');
  9. let std_ration_lib_ration_items = mongoose.model('std_ration_lib_ration_items');
  10. let std_glj_lib_gljList_model = mongoose.model('std_glj_lib_gljList');
  11. let glj_type_util = require('../../../public/cache/std_glj_type_util');
  12. const scMathUtil = require('../../../public/scMathUtil').getUtil();
  13. let decimal_facade = require('../../main/facade/decimal_facade');
  14. let gljUtil = require('../../../public/gljUtil');
  15. module.exports={
  16. calculateQuantity:calculateQuantity,
  17. getGLJTypeByID:getGLJTypeByID
  18. }
  19. //辅助定额调整、替换工料机、标准附注条件调整、添加工料机、自定义消耗量(包括删除工料机)、自定义乘系数、市场单价调整
  20. let stateSeq ={
  21. ass:1,
  22. replace:2,
  23. coe:3,
  24. add:4,
  25. cusQuantity:5,
  26. cusCoe:6,
  27. adjMak:7
  28. };
  29. //自定义乘系数与定额工料机类型映射表
  30. let coeTypeMap = {
  31. "人工":1,
  32. "材料":2,
  33. "机械":3,
  34. "施工机具":3,
  35. "主材":4,
  36. "设备":5
  37. };
  38. async function calculateQuantity(query,noNeedCal,refreshRationName = false){
  39. try {
  40. let result ={
  41. glj_result:[],
  42. rationID:query.rationID
  43. };
  44. let impactRation = await ration.findOne({ID:query.rationID});
  45. let gljList = await ration_glj.find(query);//{projectID:query.projectID,rationID:query.rationID}
  46. let coeList = await ration_coe.find({rationID:query.rationID}).sort('seq').exec();
  47. let assList=[];
  48. let assRation = null;
  49. let adjustState=[];
  50. if(!impactRation){//如果定额不存在或者已删除,返回空
  51. return null;
  52. }
  53. if(impactRation._doc.hasOwnProperty("rationAssList")&&impactRation.rationAssList.length>0){
  54. let temTimes = [];
  55. let thirdRationCodes=[];
  56. for(let i=0;i<impactRation.rationAssList.length;i++){
  57. let times = calculateTimes(impactRation.rationAssList[i]);
  58. if(times!=0){
  59. let thirdRationCode = impactRation.rationAssList[i].thirdRationCode;
  60. if(thirdRationCode && thirdRationCode !=''){
  61. temTimes.push(times);
  62. thirdRationCodes.push(thirdRationCode)
  63. }
  64. assRation = await std_ration_lib_ration_items.findOne({rationRepId:impactRation.libID,code:impactRation.rationAssList[i].assistCode});
  65. assList.push({times:times,assRation:assRation});
  66. adjustState.push({index:stateSeq.ass,content:impactRation.rationAssList[i].name+" "+impactRation.rationAssList[i].actualValue+" : +"+impactRation.rationAssList[i].assistCode+"x"+times});
  67. }
  68. }
  69. if(temTimes.length == 2 &&thirdRationCodes[0] == thirdRationCodes[1] ){ //说明有第三定额
  70. let times_t = temTimes[0] * temTimes[1];
  71. let tration = await std_ration_lib_ration_items.findOne({rationRepId:impactRation.libID,code:thirdRationCodes[0]});
  72. if(tration){
  73. assList.push({times:times_t,assRation:tration});
  74. adjustState.push({index:stateSeq.ass,content:"+"+thirdRationCodes[0]+"x"+times_t});
  75. }
  76. }
  77. }
  78. gljList = sortRationGLJ(gljList);
  79. for(let i =0;i<gljList.length;i++ ){
  80. let r = await calculateQuantityPerGLJ(gljList[i],gljList,coeList,assList,adjustState,noNeedCal);
  81. if(quantityUpdateCheck(gljList[i],r) == true) result.glj_result.push(r);
  82. }
  83. if(noNeedCal==null && result.glj_result.length > 0){
  84. await ration_glj.bulkWrite(generateUpdateTasks(result.glj_result));
  85. }
  86. adjustState= _.sortByOrder(adjustState, ['index'], ['asc']);
  87. adjustState=_.map(adjustState, _.property('content'));
  88. let adjustStateString = adjustState.join(';');
  89. let setData = {adjustState:adjustStateString};
  90. if(refreshRationName == true){//需要更新定额名称
  91. let newName = generateRationName(impactRation,gljList);
  92. setData.name = newName;
  93. result.rationName = newName;
  94. }
  95. await ration.update({ID:query.rationID},setData);
  96. result.adjustState=adjustStateString;
  97. return result;
  98. }catch (err){
  99. console.log(err);
  100. throw err;
  101. }
  102. }
  103. function quantityUpdateCheck(glj,r) {//检查,有改变的才更新
  104. for(let key in r.doc){
  105. if(glj._doc[key] != r.doc[key]) return true
  106. }
  107. return false
  108. }
  109. function generateRationName(ration,gljList) {
  110. let caption = ration.caption ? ration.caption:ration.name;
  111. let replaceList = [];
  112. if(ration.rationAssList && ration.rationAssList.length > 0){//这里要处理第三定额和多辅助定额的情况
  113. let isThird = ration.rationAssList.length == 2 && ration.rationAssList[0].thirdRationCode&&ration.rationAssList[0].thirdRationCode!='';//说明有第三定额的情况
  114. let adjustMatch = "",notAdjust="";
  115. for(let ass of ration.rationAssList){
  116. let tem = "";
  117. if( ass.isAdjust == 1 && ass.actualValue != null && ass.actualValue != undefined ){
  118. tem = ass.actualValue;
  119. adjustMatch = tem;
  120. }else {
  121. tem = ass.stdValue;
  122. notAdjust = tem;
  123. }
  124. if(isThird) replaceList.push(tem);
  125. }
  126. if(replaceList.length == 0){
  127. adjustMatch!=""?replaceList.push(adjustMatch):replaceList.push(notAdjust);
  128. }
  129. for(let r of replaceList){
  130. caption = caption.replace('%s',r);
  131. }
  132. }
  133. let reNameList = [];
  134. for(let g of gljList){
  135. //glj._doc.createType=='replace'&&glj.rcode!=glj.code
  136. if(g.createType=='replace'&&g.rcode!=g.code){ //是替换工料机
  137. let reName = g.name;
  138. if(!_.isEmpty(g.specs)) reName = reName + ' '+g.specs;
  139. reNameList.push(reName);
  140. }
  141. }
  142. if(reNameList.length > 0){
  143. let reNameString = reNameList.join(" ");
  144. caption = caption + " 换为【"+ reNameString + "】";
  145. }
  146. return caption;
  147. }
  148. function generateUpdateTasks(result) {
  149. let tasks = [];
  150. for(let i =0;i<result.length;i++){
  151. let task= {
  152. updateOne: {
  153. filter: result[i].query,
  154. update: result[i].doc
  155. }
  156. }
  157. tasks.push(task);
  158. }
  159. return tasks;
  160. }
  161. function sortRationGLJ(list) {
  162. list = _.sortByAll(list, [function (item) {
  163. return _.indexOf(gljUtil.getGljTypeSeq(),item.type);
  164. }, "code"])
  165. return list;
  166. }
  167. async function calculateQuantityPerGLJ(glj,gljList,coeList,assList,adjustState,noNeedCal) {
  168. let decimalObject =await decimal_facade.getProjectDecimal(glj.projectID);
  169. let decimal = (decimalObject&&decimalObject.glj&&decimalObject.glj.quantity)?decimalObject.glj.quantity:3;
  170. let quantity = scMathUtil.roundTo(parseFloat(glj.quantity),-decimal);
  171. let result={
  172. query:{
  173. ID:glj.ID,
  174. projectID:glj.projectID
  175. },
  176. doc:{
  177. quantity: quantity
  178. }
  179. };
  180. try {
  181. if(noNeedCal==null){
  182. if(!glj._doc.hasOwnProperty('customQuantity')||glj.customQuantity==null||glj.customQuantity==""){
  183. quantity =scMathUtil.roundTo(parseFloat(glj.rationItemQuantity),-decimal);
  184. quantity =scMathUtil.roundTo(await calculateAss(quantity,assList,glj),-decimal);
  185. quantity = calculateQuantityByCoes(quantity,coeList,glj,gljList,decimal);
  186. }else {
  187. quantity = glj.customQuantity;
  188. result.doc.customQuantity = glj.customQuantity;
  189. }
  190. let customerCoe = _.last(coeList);
  191. if(customerCoe&&customerCoe.isAdjust==1){
  192. quantity = scMathUtil.roundToString(quantity,decimal);
  193. quantity = calculateQuantityByCustomerCoes(quantity,customerCoe,glj,decimal);
  194. }
  195. result.doc.quantity =scMathUtil.roundToString(quantity,decimal);
  196. //2019-01-03 需求修改中间过程的价格不参与计算
  197. //glj.quantity = quantity;//这里保存中间过程计算出来的消耗量,后面处理“+*”操作符时要用到
  198. }
  199. generateAdjustState(glj,coeList,adjustState,gljList,result.doc.quantity);
  200. return result;
  201. }catch (err){
  202. throw err;
  203. }
  204. }
  205. async function calculateAss(quantity,assList,glj) {
  206. for(let i=0;i<assList.length;i++){
  207. if(assList[i].assRation){
  208. let assglj = null;
  209. for(let aglj of assList[i].assRation.rationGljList){
  210. if(glj.createType == 'replace'){//如果工料机是替换过的,要用原始的编码来匹配
  211. let std_glj = await std_glj_lib_gljList_model.findOne({'ID':aglj.gljId});
  212. if(glj.rcode == std_glj.code){
  213. assglj = aglj;
  214. break;
  215. }
  216. }else if(aglj.gljId == glj.GLJID){
  217. assglj = aglj;
  218. break;
  219. }
  220. }
  221. if(assglj){
  222. let calQuantity = assglj.consumeAmt*assList[i].times;
  223. quantity += calQuantity
  224. }
  225. }
  226. }
  227. return scMathUtil.roundTo(quantity,-6);
  228. }
  229. function generateAdjustState(glj,coeList,adjustState,gljList,quantity) {
  230. //替换工料机 and 添加工料机
  231. if(glj._doc.createType=='replace'&&glj.rcode!=glj.code){
  232. adjustState.push({index:stateSeq.replace,content:glj.rcode+'换'+glj.code});
  233. }else if(glj._doc.createType=='add'){
  234. let displayQuantity = quantity;
  235. if(glj._doc.hasOwnProperty('customQuantity')&&(glj.customQuantity != null||glj.customQuantity != '')){
  236. displayQuantity = glj.customQuantity;
  237. }
  238. displayQuantity = displayQuantity&&displayQuantity!=""?parseFloat(displayQuantity):0;
  239. adjustState.push({index:stateSeq.add,content:'添'+glj.code+'量'+ displayQuantity,type:"添"+glj.code});
  240. }
  241. // to do
  242. //标准附注条件调整 + 自定义乘系数
  243. if(_.last(gljList).ID == glj.ID){//最后一个工料机的时候才生成,生成一次就可以了
  244. for(let i=0;i<coeList.length;i++){
  245. if(coeList[i].isAdjust==1){
  246. if(i==coeList.length-1){
  247. adjustState.push({index:stateSeq.cusCoe,content:getContent(coeList[i].coes)});//自定义乘系数要去掉倍数为1的
  248. }else {
  249. if(coeList[i].select_code && coeList[i].select_code!=""){
  250. _.remove(adjustState,{'content':coeList[i].original_code+'换'+coeList[i].select_code});//去掉替换工料机自动生成的调整状态
  251. adjustState.push({index:stateSeq.coe,content:"调 : "+coeList[i].original_code+'换'+coeList[i].select_code});
  252. }
  253. for(let c of coeList[i].coes){
  254. if(c.coeType=='单个工料机') _.remove(adjustState,{'type':"添"+c.gljCode});//如果是单个工料机子目换算类型自动添加的,去掉前面手动生成的调整状态
  255. if(c.coeType=='替换人材机') _.remove(adjustState,{'content':c.gljCode+'换'+c.replaceCode});//如果是替换人材机子目换算类型自动添加的,去掉前面手动生成的调整状态
  256. }
  257. if(coeList[i].content) adjustState.push({index:stateSeq.coe,content:"调 : "+coeList[i].content});//coeList[i].content
  258. }
  259. }
  260. }
  261. }
  262. //自定义消耗量
  263. if(glj._doc.createType!='add'&&glj._doc.hasOwnProperty('customQuantity')){
  264. if(glj.customQuantity!==null&&glj.customQuantity!=""){
  265. adjustState.push({index:stateSeq.cusQuantity,content:glj.code+'量'+parseFloat(glj.customQuantity)});
  266. }
  267. }
  268. //市场单价调整
  269. if(glj._doc.hasOwnProperty('marketPriceAdjust')&&glj.marketPriceAdjust&&glj.marketPriceAdjust!=0){
  270. //0101005价66.00
  271. adjustState.push({index:stateSeq.adjMak,content:glj.code+'价'+glj.marketPriceAdjust});
  272. }
  273. return adjustState;
  274. }
  275. function getContent(coes) {
  276. let stringList=[];
  277. let temAmount = null;
  278. let theSame = true;
  279. for(let t of coes){
  280. if(temAmount == null){
  281. temAmount = t.amount;
  282. }else if(temAmount != t.amount){
  283. theSame = false;
  284. break;
  285. }
  286. }
  287. for(let c of coes){
  288. if( c.amount&&c.amount!=1){
  289. let operator = c.operator;
  290. if(c.operator =="*"){
  291. operator = "X";
  292. }
  293. if(theSame == true && c.coeType == "定额"){
  294. stringList.push(c.coeType+operator+c.amount);
  295. break;
  296. }else
  297. if(theSame == false && c.coeType != "定额"){
  298. stringList.push(c.coeType+operator+c.amount);
  299. }
  300. }
  301. }
  302. return stringList.join(",");
  303. }
  304. function prepareAss(assList) {//处理辅助定额,支持多个辅助定额的情况
  305. for(let a of assList){
  306. if(a.groupList && a.groupList.length > 1){//组里有多个定额的情况
  307. let newList = _.sortByAll(a.groupList,['param']);//先按参数排序
  308. for(let n of newList){
  309. if(a.actualValue > n.stdValue && a.actualValue <= parseFloat(n.param)){//落在中间,则用组里的这条定额
  310. a._doc.param = n.param;
  311. a._doc.paramName = n.paramName;
  312. a._doc.assistCode = n.assistCode;
  313. break;
  314. }
  315. }
  316. }
  317. }
  318. }
  319. function calculateTimes(ass){
  320. if(ass.isAdjust == 0) return 0;//打勾辅助定额才计算
  321. let times =(ass.actualValue-ass.stdValue)/ass.stepValue;
  322. let r = false;
  323. if(times<0){
  324. r=true;
  325. times=times*-1;
  326. }
  327. if(ass.carryBit=='四舍五入'){
  328. times = _.round(times,ass.decimal);
  329. }else if (ass.carryBit=='进一'){
  330. times =_.ceil(times,ass.decimal);
  331. }else if(ass.carryBit == '舍一'){
  332. times = _.floor(times,ass.decimal);
  333. }
  334. if(r){
  335. times=times*-1;
  336. }
  337. return scMathUtil.roundTo(times,-6);
  338. }
  339. function calculateQuantityByCoes(quantity,coeList,glj,gljList,decimal){
  340. let coeQuantity = quantity;
  341. if(coeList.length>1){
  342. for(let i=0;i<coeList.length-1;i++){
  343. coeQuantity = everyCoe(coeQuantity,coeList[i],glj,gljList,decimal);
  344. }
  345. }
  346. return scMathUtil.roundTo(coeQuantity,-6);
  347. }
  348. function everyCoe(quantity,coe,glj,gljList,decimal) {
  349. let coeQuantity = quantity;
  350. if(coe.isAdjust==1){
  351. for(let i=0;i<coe.coes.length;i++){
  352. if(coe.coes[i].coeType=='单个工料机' &&coe.coes[i].gljCode==glj.code){//if(coe.coes[i].coeType=='单个工料机'&&coe.coes[i].gljCode==glj.code)
  353. coeQuantity = getCalculateResult(coeQuantity,coe.coes[i],coe,gljList,decimal);
  354. }else if(coe.coes[i].coeType== "替换人材机" && glj.rcode == coe.coes[i].gljCode && glj.code == coe.coes[i].replaceCode){
  355. coeQuantity = getCalculateResult(coeQuantity,coe.coes[i],coe,gljList,decimal);
  356. }else if(coe.coes[i].coeType== "所选人材机" && glj.rcode == coe.original_code && glj.code == coe.select_code ){
  357. coeQuantity = getCalculateResult(coeQuantity,coe.coes[i],coe,gljList,decimal);
  358. } else if(coe.coes[i].coeType=='定额'){
  359. coeQuantity = getCalculateResult(coeQuantity,coe.coes[i],coe,gljList,decimal);
  360. }else if(coeTypeMap[coe.coes[i].coeType]==getRootGLJType(glj.type).ID){
  361. coeQuantity = getCalculateResult(coeQuantity,coe.coes[i],coe,gljList,decimal);
  362. }
  363. }
  364. }
  365. return scMathUtil.roundTo(coeQuantity,-6);
  366. }
  367. function calculateQuantityByCustomerCoes(quantify,coe,glj) {
  368. let rationAmount = coe.coes[0].amount;
  369. if(_.every(coe.coes,'amount',rationAmount)){
  370. return getCalculateResult(quantify, coe.coes[0])
  371. }else {
  372. for(let i=1;i<coe.coes.length;i++){
  373. if(coeTypeMap[coe.coes[i].coeType]==getRootGLJType(glj.type).ID){
  374. return getCalculateResult(quantify,coe.coes[i])
  375. }
  376. }
  377. }
  378. return quantify
  379. }
  380. function getCoeSelectedGLJ(gljList,rcode,code) {
  381. if(gljList&& code && code !=""){
  382. let o_glj = _.find(gljList,{'rcode':rcode,'code':code});
  383. return o_glj;
  384. }
  385. return null;
  386. }
  387. function getCalculateResult(quantify,c,coe,gljList,decimal) {
  388. let q = quantify;
  389. let o_glj = null;
  390. switch (c.operator){
  391. case '+' :
  392. q = q + c.amount;
  393. break;
  394. case '-' :
  395. q = q - c.amount;
  396. break;
  397. case '*' :
  398. q = q * c.amount;
  399. break;
  400. case '/' :
  401. q = q / c.amount;
  402. break;
  403. case '+*' :
  404. o_glj = getCoeSelectedGLJ(gljList,coe.original_code,coe.select_code);
  405. if(o_glj){
  406. q = q + c.amount * scMathUtil.roundForObj(o_glj.rationItemQuantity,decimal);
  407. }
  408. break;
  409. case '-*' :
  410. o_glj = getCoeSelectedGLJ(gljList,coe.original_code,coe.select_code);
  411. if(o_glj){
  412. q = q - c.amount * scMathUtil.roundForObj(o_glj.rationItemQuantity,decimal);
  413. }
  414. break;
  415. case '=' :
  416. q = c.amount;
  417. break;
  418. }
  419. return q;
  420. }
  421. function getRootGLJType(id){
  422. let glj_type_object = glj_type_util.getStdGljTypeCacheObj();
  423. let topTypeId = glj_type_object.getTopParentIdByItemId(id);
  424. let type = glj_type_object.getItemById(topTypeId);
  425. return type;
  426. }
  427. function getGLJTypeByID(id) {
  428. let type = getRootGLJType(id);
  429. if(type!=undefined){
  430. return type.fullName;
  431. }else {
  432. return '';
  433. }
  434. }