ration_glj_facade.js 15 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507
  1. /**
  2. * Created by chen on 2017/6/29.
  3. */
  4. let mongoose = require('mongoose');
  5. const uuidV1 = require('uuid/v1');
  6. let consts = require('../../main/models/project_consts')
  7. let commonConsts = consts.commonConst;
  8. let _=require("lodash");
  9. let ration_glj = mongoose.model('ration_glj');
  10. import GLJListModel from '../../glj/models/glj_list_model';
  11. let std_glj_lib_gljList_model = mongoose.model('std_glj_lib_gljList');
  12. let async_n = require("async");
  13. let ration = mongoose.model('ration');
  14. let ration_coe_facade = require('./ration_coe_facade');
  15. let ration_coe = mongoose.model('ration_coe');
  16. let std_ration_lib_ration_items = mongoose.model('std_ration_lib_ration_items');
  17. let glj_calculate_facade = require('./glj_calculate_facade');
  18. let quantity_detail_facade = require('./quantity_detail_facade');
  19. let logger = require("../../../logs/log_helper").logger;
  20. module.exports={
  21. save:save,
  22. getData:getData,
  23. deleteByRation:deleteByRation,
  24. getQuantityByProjectGLJ:getQuantityByProjectGLJ
  25. }
  26. let operationMap={
  27. 'ut_create':create_ration_glj,
  28. 'ut_update':update_ration_glj,
  29. 'ut_delete':delete_ration_glj
  30. };
  31. let updateFunctionMap = {
  32. 'normalUpdate':normalUpdate,
  33. 'marketPriceAdjustUpdate':marketPriceAdjustUpdate,
  34. 'customQuantityUpdate':customQuantityUpdate
  35. };
  36. /**
  37. * 根据项目工料机ID和项目ID取消耗量
  38. *
  39. * @param {object} condition
  40. * @return Array
  41. */
  42. async function getQuantityByProjectGLJ(condition) {
  43. let query ={
  44. $and:[
  45. {'projectID':condition.projectID},
  46. {'projectGLJID':{$in:condition.projectGLJIDList}}
  47. ]
  48. }
  49. let results = await ration_glj.find(query,['projectGLJID','quantity']);
  50. return combineQuantity(results);
  51. }
  52. function combineQuantity(results) {
  53. var resultMap = {};
  54. _.forEach(results,function (data) {
  55. if(resultMap.hasOwnProperty(data.projectGLJID)){
  56. resultMap[data.projectGLJID] += data.quantity;
  57. }else {
  58. resultMap[data.projectGLJID] = data.quantity;
  59. }
  60. })
  61. var resultList =[];
  62. for(let key in resultMap){
  63. let newObject = {
  64. 'projectGLJID':key,
  65. 'quantity':resultMap[key]
  66. }
  67. resultList.push(newObject)
  68. }
  69. return resultList;
  70. }
  71. function get_lib_glj_info(ration_glj) {
  72. return function (cb) {
  73. std_glj_lib_gljList_model.findOne({'ID':ration_glj.GLJID},(err,glj)=>{
  74. if(err){
  75. cb(err,'')
  76. }else if(glj){
  77. ration_glj.name = glj.name;
  78. ration_glj.code = glj.code;
  79. ration_glj.unit = glj.unit;
  80. ration_glj.specs = glj.specs;
  81. ration_glj.basePrice = glj.basePrice;
  82. ration_glj.shortName = glj.shortName;
  83. ration_glj.type = glj.gljType;
  84. getInfoFromProjectGLJ(ration_glj).then(function (result) {
  85. if(result){
  86. cb(null,result);
  87. }else {
  88. cb(new Error('get project glj error'),null);
  89. }
  90. });
  91. }else {
  92. cb(null,null);
  93. }
  94. })
  95. }
  96. }
  97. async function getInfoFromProjectGLJ(ration_glj) {
  98. let data = {
  99. glj_id: ration_glj.glj_repository_id,
  100. project_id: ration_glj.projectID,
  101. code: ration_glj.code,
  102. name: ration_glj.name,
  103. specs: ration_glj.specs,
  104. unit: ration_glj.unit,
  105. type: ration_glj.type,
  106. type_of_work: ration_glj.type,
  107. base_price: ration_glj.basePrice,
  108. market_price: ration_glj.basePrice
  109. };
  110. try {
  111. let projectGljModel = new GLJListModel();
  112. let result = await projectGljModel.addList(data);
  113. ration_glj.marketPrice=result.unit_price.market_price;
  114. ration_glj.adjustPrice=result.adjust_price;
  115. ration_glj.projectGLJID=result.id;
  116. ration_glj.isEstimate=result.is_evaluate;
  117. return ration_glj;
  118. } catch (err) {
  119. logger.err(err);
  120. return null;
  121. }
  122. }
  123. function create_ration_glj(user_id,datas) {
  124. return function (callback) {
  125. let ration_glj_list=datas.ration_glj_list;
  126. var tasks=[];
  127. for(let i =0;i<ration_glj_list.length;i++){
  128. ration_glj_list[i].ID = uuidV1();
  129. tasks.push(get_lib_glj_info(ration_glj_list[i]))
  130. }
  131. async_n.parallel(tasks,(err,results)=>{
  132. if(err){
  133. callback(err,results)
  134. }else {
  135. let newRecords =[];
  136. for (let r of results){
  137. if(r){
  138. newRecords.push(r)
  139. }
  140. }
  141. if(newRecords.length>0){
  142. ration_glj.insertMany(newRecords,(err,doc)=>{
  143. if(err){
  144. callback(err,null);
  145. }else {
  146. let returndata ={
  147. updateTpye:commonConsts.UT_CREATE,
  148. moduleName:'ration_glj',
  149. data:newRecords
  150. }
  151. callback(null,returndata)
  152. }
  153. });
  154. }else {
  155. logger.info("can't find gljs")
  156. callback(null,null)
  157. }
  158. }
  159. })
  160. }
  161. }
  162. function update_ration_glj(user_id,datas) {
  163. if(datas.updateFunction){
  164. return updateFunctionMap[datas.updateFunction](user_id,datas);
  165. }else {
  166. return normalUpdate(user_id,datas);
  167. }
  168. }
  169. function normalUpdate(user_id,datas){
  170. return function(callback) {
  171. ration_glj.update(datas.query,datas.doc,(err,result)=>{
  172. if(err){
  173. callback(err,'');
  174. }else {
  175. let returndata ={
  176. moduleName:'ration_glj',
  177. data:{
  178. updateTpye:commonConsts.UT_UPDATE,
  179. query:datas.query,
  180. doc:datas.doc
  181. }
  182. }
  183. callback(null,returndata)
  184. }
  185. })
  186. }
  187. }
  188. function customQuantityUpdate(user_id,datas){
  189. return function(callback) {
  190. doCustomQuantityUpdate(datas).then((result)=>{
  191. if(result.err){
  192. callback(result.err,'');
  193. }else {
  194. let ration_glj_data ={
  195. moduleName:'ration_glj',
  196. data:{
  197. updateTpye:commonConsts.UT_UPDATE,
  198. quantityRefresh:true,
  199. glj_result:result.cal_result.glj_result
  200. }
  201. };
  202. let ration_data ={
  203. moduleName:'ration',
  204. data:{
  205. updateTpye:commonConsts.UT_UPDATE,
  206. stateRefresh:true,
  207. rationID:result.cal_result.rationID,
  208. adjustState:result.cal_result.adjustState
  209. }
  210. };
  211. callback(null,[ration_glj_data,ration_data]);
  212. }
  213. })
  214. }
  215. }
  216. async function doCustomQuantityUpdate(datas){
  217. let result = {
  218. err:null
  219. }
  220. try{
  221. await ration_glj.update(datas.query,datas.doc);
  222. let cal_result = await glj_calculate_facade.calculateQuantity({projectID:datas.query.projectID,rationID:datas.query.rationID});
  223. cal_result.glj_result.forEach(function (item) {
  224. if(!item.doc.hasOwnProperty('customQuantity')){
  225. item.doc.customQuantity=null;
  226. }
  227. });
  228. result.cal_result =cal_result;
  229. console.log(result);
  230. return result;
  231. }catch (err){
  232. result.err = err;
  233. console.log(err);
  234. return result;
  235. }
  236. }
  237. function marketPriceAdjustUpdate(user_id,datas) {
  238. return function (callback) {
  239. updateprojectGljAndRationGLJ(datas.query,datas.doc).then((result)=>{
  240. if(result.err){
  241. callback(result.err,'');
  242. }else {
  243. let returndata ={
  244. moduleName:'ration_glj',
  245. data:{
  246. updateTpye:commonConsts.UT_UPDATE,
  247. query:datas.query,
  248. doc:result.doc
  249. }
  250. };
  251. let ration_data ={
  252. moduleName:'ration',
  253. data:{
  254. updateTpye:commonConsts.UT_UPDATE,
  255. stateRefresh:true,
  256. rationID:datas.query.rationID,
  257. adjustState:result.adjustState
  258. }
  259. }
  260. callback(null,[returndata,ration_data]);
  261. }
  262. })
  263. }
  264. }
  265. async function updateprojectGljAndRationGLJ(query,doc) {
  266. let returnresult={};
  267. try {
  268. let gljListModel = new GLJListModel();
  269. let temp = doc.market_price;
  270. if(doc.market_price==null){
  271. doc.market_price = doc.base_price;
  272. }
  273. delete doc.base_price;
  274. let result = await gljListModel.modifyMarketPrice(doc);
  275. let updateDoc ={
  276. marketPrice:result.unit_price.market_price,
  277. marketPriceAdjust:temp,
  278. projectGLJID:result.id,
  279. isEstimate:result.is_evaluate,
  280. name : result.name,
  281. code:result.code
  282. };
  283. let updateresult = await ration_glj.findOneAndUpdate(query, updateDoc);
  284. let stateResult = await glj_calculate_facade.calculateQuantity({projectID:query.projectID,rationID:query.rationID},true);
  285. returnresult ={
  286. err:null,
  287. doc :updateDoc,
  288. adjustState:stateResult.adjustState
  289. }
  290. return returnresult;
  291. } catch (error) {
  292. returnresult.err = error;
  293. console.log(error);
  294. return returnresult
  295. }
  296. }
  297. function delete_ration_glj(user_id,datas) {
  298. return function (callback) {
  299. if(datas.deleteType=="RATION"){
  300. deleteByRation(datas,callback);
  301. }else if(datas.deleteType=="BILL"){
  302. deleteByBill(user_id,datas,callback);
  303. } else{
  304. deleteByID(datas,callback);
  305. }
  306. }
  307. }
  308. function deleteByRation(datas,callback) {
  309. let data = datas.updateData;
  310. let tasks=[];
  311. tasks.push(deleteGLJList(data));
  312. tasks.push(ration_coe_facade.delete_ration_coe(data));
  313. tasks.push(quantity_detail_facade.deleteByRation(data));
  314. async_n.parallel(tasks,function (err,result) {
  315. commonCallback(callback,result,err)
  316. })
  317. }
  318. function deleteGLJList(data) {
  319. return function (callback) {
  320. ration_glj.deleteMany({projectID: data.projectID, rationID: data.ID},(err,result)=>{
  321. commonCallback(callback,result,err)
  322. });
  323. }
  324. }
  325. function deleteByBill(user_id,datas,callback) {
  326. let tasks = [];
  327. tasks.push(startingTask("deleteByBill"));
  328. tasks.push(getRationsByBill(datas));
  329. tasks.push(deleteRationsbyBill(user_id,datas));
  330. tasks.push(deleteByMultiRations(datas));
  331. async_n.waterfall(tasks,function (err,results) {
  332. if(err){
  333. callback(err,'');
  334. }else {
  335. callback(null,results);
  336. }
  337. })
  338. }
  339. function deleteByID(datas,callback){
  340. ration_glj.deleteOne(datas.query,(err,result)=>{
  341. if(err){
  342. callback(err,'');
  343. }else {
  344. let returndata ={
  345. moduleName:'ration_glj',
  346. data:{
  347. updateTpye:commonConsts.UT_DELETE,
  348. query:datas.query,
  349. }
  350. }
  351. callback(null,returndata)
  352. }
  353. })
  354. }
  355. function startingTask(processName){
  356. return function(asyncCallBack){
  357. var result = {
  358. processName : processName
  359. };
  360. asyncCallBack(null, result);
  361. };
  362. }
  363. function getRationsByBill(datas) {
  364. return function (results,callback) {
  365. ration.find({projectID:datas.updateData.projectID,billsItemID:datas.updateData.ID,deleteInfo: null},function (err,rations) {
  366. if(err){
  367. callback(err,'')
  368. }else {
  369. results.rations=rations;
  370. callback(null,results)
  371. }
  372. })
  373. }
  374. }
  375. function deleteRationsbyBill (user_id,datas){
  376. return function (results,callback) {
  377. let deleteInfo ={
  378. deleteInfo :{deleted: true, deleteDateTime: new Date(), deleteBy: user_id}
  379. };
  380. ration.update({projectID: datas.updateData.projectID, billsItemID:datas.updateData.ID},deleteInfo,{multi: true},(err,deleteresults)=>{
  381. if(err){
  382. callback(err,'');
  383. }else {
  384. callback(null,results);
  385. }
  386. });
  387. }
  388. }
  389. function deleteByMultiRations(datas) {
  390. return function (results,deleteCallBack) {
  391. var delete_tasks = [];
  392. var deleteOne=function (ration) {
  393. return function (callback) {
  394. ration_glj.deleteMany({projectID: ration.projectID, rationID: ration.ID},function (err,result) {
  395. commonCallback(callback,result,err)
  396. });
  397. }
  398. }
  399. let rations = results.rations;
  400. for(let i=0;i<rations.length;i++){
  401. delete_tasks.push(deleteOne(rations[i]._doc));
  402. delete_tasks.push(ration_coe_facade.delete_ration_coe(rations[i]._doc));
  403. delete_tasks.push(quantity_detail_facade.deleteByRation(rations[i]._doc));
  404. }
  405. delete_tasks.push(quantity_detail_facade.deleteByBill(datas.updateData));
  406. async_n.parallel(delete_tasks,(err,results)=>{
  407. if (err){
  408. deleteCallBack(err,'')
  409. }else {
  410. deleteCallBack(null,results)
  411. }
  412. })
  413. }
  414. }
  415. /*
  416. function deleteByRation(doc) {
  417. return function (callback){
  418. ration_glj.deleteMany({projectID: doc.updateData.projectID, rationID: doc.updateData.ID},callback);
  419. }
  420. }
  421. */
  422. function save (user_id, datas, callback) {
  423. let operations=[];
  424. if(_.isArray(datas)){
  425. for(let i=0;i<datas.length;i++){
  426. operations.push(operationMap[datas[i].updateType](user_id,datas[i]));
  427. }
  428. }else {
  429. operations.push(operationMap[datas.updateType](user_id,datas));
  430. }
  431. async_n.parallel(operations,function (err,results) {
  432. if(err){
  433. callback(err,'');
  434. }else {
  435. if(results.length==1){
  436. callback(null,results[0])
  437. }else {
  438. callback(null,results)
  439. }
  440. }
  441. })
  442. }
  443. function getData(projectID, callback) {
  444. ration_glj.find({'projectID':projectID},(err,datas)=>{
  445. if(err){
  446. callback(1, '', null);
  447. }else {
  448. callback(0, consts.projectConst.RATION_GLJ, datas);
  449. }
  450. })
  451. }
  452. function commonCallback(callback,result,err) {
  453. if(err){
  454. callback(err,'');
  455. }else {
  456. callback(null,result);
  457. }
  458. }