fee_rates_facade.js 13 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403
  1. /**
  2. * Created by chen on 2017/8/2.
  3. */
  4. let async_n = require("async");
  5. let mongoose = require('mongoose');
  6. let feeRateModel = mongoose.model('fee_rates');
  7. let feeRateFileModel = mongoose.model('fee_rate_file');
  8. let std_fee_rate_lib_model = mongoose.model('std_fee_rate_libs');
  9. let billModel=require('../../main/models/bills');//mongoose.model('bills');
  10. let projectsModel = require("../../pm/models/project_schema");
  11. let consts = require('../../main/models/project_consts');
  12. let _=require("lodash");
  13. let template = require('../controllers/feerate_template');
  14. let logger = require("../../../logs/log_helper").logger;
  15. const uuidV1 = require('uuid/v1');
  16. let EngineeringLibModel = require("../../users/models/engineering_lib_model");
  17. module.exports={
  18. save:save,
  19. getData:getData,
  20. getFeeRateStandardsByProjectID:getFeeRateStandardsByProjectID,
  21. changeFeeRateStandard:changeFeeRateStandard,
  22. checkFeeRateName:checkFeeRateName,
  23. getChangeInfo:getChangeInfo,
  24. changeFeeRateFileFromCurrent:changeFeeRateFileFromCurrent,
  25. changeFeeRateFileFromOthers:changeFeeRateFileFromOthers,
  26. newFeeRateFile:newFeeRateFile,
  27. getFeeRatesByProject:getFeeRatesByProject,
  28. getGCFeeRateFiles: getGCFeeRateFiles ,
  29. setFeeRateToBill:setFeeRateToBill,
  30. updateFeeRate:updateFeeRate
  31. };
  32. let operationMap={
  33. 'ut_create':create_fee_rate,
  34. 'ut_update':update_fee_rate,
  35. 'ut_delete':delete_fee_rate
  36. };
  37. let updateFunctionMap = {
  38. 'normalUpdate':normalUpdate,
  39. 'update_rates':update_rates,
  40. 'updateStatusBySelected':updateStatusBySelected,
  41. 'feeRateFileSaveAs':feeRateFileSaveAs
  42. }
  43. function create_fee_rate() {
  44. }
  45. function update_fee_rate(user_id,datas) {
  46. if(datas.updateFunction){
  47. return updateFunctionMap[datas.updateFunction](user_id,datas);
  48. }else {
  49. return normalUpdate(user_id,datas);
  50. }
  51. }
  52. function updateStatusBySelected(user_id,datas) {
  53. return function(callback){
  54. feeRateModel.bulkWrite(generateUpdateTaks(datas.tasks),function (err,data) {
  55. console.log(data);
  56. commonCallback(callback,data,err);
  57. })
  58. }
  59. }
  60. function feeRateFileSaveAs(user_id,datas) {
  61. return function(callback){
  62. let doc = datas.doc;
  63. let projectID=datas.query.projectID;
  64. let feeRate={
  65. ID:doc.feeRateID,
  66. rates:doc.rates
  67. };
  68. delete doc._id;
  69. delete doc.rates;
  70. creatFeeRateFile(doc,feeRate,projectID).then(function (result) {
  71. commonCallback(callback,result,result.err);
  72. })
  73. }
  74. }
  75. async function creatFeeRateFile(feeRateFile,feeRate,projectID) {//预留projectID
  76. let result={
  77. err:null
  78. }
  79. try {
  80. let feeFile={
  81. id:feeRateFile.ID,
  82. name:feeRateFile.name
  83. }
  84. await projectsModel.findOneAndUpdate({ID:projectID},{'property.feeFile':feeFile});
  85. await feeRateFileModel.create(feeRateFile);
  86. await feeRateModel.create(feeRate);
  87. }catch (err){
  88. console.log(err);
  89. result.err=err;
  90. }
  91. return result;
  92. }
  93. function normalUpdate(user_id,datas) {
  94. return function(callback){
  95. console.log(datas)
  96. callback(null,'');
  97. }
  98. }
  99. function generateUpdateTaks(updateTasks) {
  100. var tasks=[];
  101. for(let u of updateTasks){
  102. let t ={
  103. updateOne:{
  104. filter:u.query,
  105. update: u.doc
  106. }
  107. }
  108. tasks.push(t);
  109. }
  110. return tasks;
  111. }
  112. function update_rates(user_id,datas) {
  113. return function(callback){
  114. feeRateModel.findOne(datas.query,['rates'],function(err, data){
  115. let doc = datas.doc;
  116. if(_.isArray(doc)){
  117. _.forEach(doc,function (item) {
  118. data.rates[item.rateIndex]=item.rate;
  119. })
  120. }else {
  121. data.rates[doc.rateIndex]=doc.rate;
  122. }
  123. data.save(function (err) {
  124. commonCallback(callback,'',err);
  125. });
  126. })
  127. }
  128. }
  129. function delete_fee_rate() {
  130. }
  131. function save (user_id, datas, callback) {
  132. let operations=[];
  133. if(_.isArray(datas)){
  134. for(let i=0;i<datas.length;i++){
  135. operations.push(operationMap[datas[i].updateType](user_id,datas[i]));
  136. }
  137. }else {
  138. operations.push(operationMap[datas.updateType](user_id,datas));
  139. }
  140. async_n.parallel(operations,function (err,results) {
  141. if(err){
  142. callback(err,'');
  143. }else {
  144. if(results.length==1){
  145. callback(null,results[0])
  146. }else {
  147. callback(null,results)
  148. }
  149. }
  150. })
  151. }
  152. function getData(projectID, callback) {
  153. getFeeRateData(projectID).then(function (result) {
  154. if(result.err){
  155. callback(1, '', null);
  156. }else {
  157. //feeRateModel
  158. callback(0, consts.projectConst.FEERATE, result.datas);
  159. }
  160. })
  161. }
  162. async function getFeeRateData(projectID) {
  163. let result={
  164. err:null
  165. }
  166. try {
  167. //
  168. let project = await projectsModel.findOne({ID:projectID});
  169. if (project&&project.property&&project.property.feeFile){
  170. let feeRateData = await feeRateFileModel.findOne({'ID':project.property.feeFile.id,deleteInfo:null});
  171. if(feeRateData===null){
  172. result.datas=[];
  173. }else {
  174. let feeRate = await feeRateModel.findOne({ID:feeRateData.feeRateID});
  175. feeRateData._doc.rates = feeRate?feeRate.rates:[];
  176. //
  177. feeRateData._doc.usageProjects=await getUsageProjects(feeRateData.ID);
  178. result.datas = feeRateData;
  179. }
  180. }else {
  181. result.datas=[];
  182. }
  183. logger.info("get fee rate data");
  184. }catch (err){
  185. console.log(err);
  186. result.err=err;
  187. }
  188. return result;
  189. }
  190. async function getUsageProjects(feeRateID){
  191. let projects = await projectsModel.find({'property.feeFile.id':feeRateID,'deleteInfo':null});
  192. return projects;
  193. }
  194. function commonCallback(callback,result,err) {
  195. if(err){
  196. callback(err,'');
  197. }else {
  198. callback(null,result);
  199. }
  200. }
  201. async function getFeeRateStandardsByProjectID(projectID) {
  202. logger.info("get feeRate standard, projectID:"+projectID)
  203. let feeRateStandards=[];
  204. let project = await projectsModel.findOne({ID:projectID});
  205. let engineeringLibModel = new EngineeringLibModel();
  206. let engineeringInfo = project !== null && project.property.engineering_id !== undefined ?
  207. await engineeringLibModel.getEngineering(project.property.engineering_id) : null;
  208. if(engineeringInfo!=null){
  209. let fee_lib = engineeringInfo.fee_lib;
  210. for(let lib of fee_lib){
  211. feeRateStandards.push({ID:lib.id,libName:lib.name});
  212. }
  213. }
  214. return feeRateStandards;
  215. }
  216. async function changeFeeRateStandard(jdata){
  217. let data = JSON.parse(jdata);
  218. let template = await std_fee_rate_lib_model.findOne({"ID":data.newLibID});
  219. let newFeeRate = {};
  220. newFeeRate.ID =uuidV1();
  221. newFeeRate.rates=template.rates;
  222. await feeRateModel.create(newFeeRate);
  223. let doc={
  224. libID:data.newLibID,
  225. libName:template.libName,
  226. feeRateID: newFeeRate.ID
  227. };
  228. let deleteInfo = {deleted: true, deleteDateTime: new Date(), deleteBy: data.user_id};
  229. await feeRateFileModel.findOneAndUpdate({ID:data.feeRateFileID,deleteInfo:null},doc);
  230. await feeRateModel.findOneAndUpdate({ID:data.feeRateID},{deleteInfo:deleteInfo});
  231. doc.rates=newFeeRate.rates;
  232. return doc;
  233. }
  234. async function newFeeRateFile(updateData){
  235. if(updateData.property !== null){
  236. let property = updateData.property;
  237. logger.info("Create new feeRate file for project :"+updateData.ID);
  238. let feeFile = property.feeFile;
  239. let rootProjectID = property.rootProjectID;
  240. let name = updateData.name;
  241. let newFeeRate = {};
  242. if(feeFile.id.indexOf("newFeeRate")!=-1){
  243. let temFee = await feeRateFileModel.findOne({rootProjectID:rootProjectID,name:name,deleteInfo:null});
  244. if(temFee){
  245. newFeeRate.id=temFee.ID;
  246. newFeeRate.name = temFee.name;
  247. return newFeeRate;
  248. }
  249. let temA = feeFile.id.split("-");
  250. let libID = temA[1];
  251. let doc={
  252. rootProjectID:rootProjectID,
  253. name:name
  254. };
  255. if(libID!== ''){
  256. let template = await std_fee_rate_lib_model.findOne({"ID":libID});
  257. let newFeeRate = {};
  258. newFeeRate.ID =uuidV1();
  259. newFeeRate.rates=template.rates;
  260. await feeRateModel.create(newFeeRate);
  261. doc.libID = libID;
  262. doc.libName = template.libName;
  263. doc.feeRateID = newFeeRate.ID;
  264. }
  265. doc.ID = uuidV1();
  266. await feeRateFileModel.create(doc);
  267. newFeeRate.id = doc.ID;
  268. newFeeRate.name =doc.name;
  269. return newFeeRate;
  270. }else {
  271. return feeFile
  272. }
  273. }
  274. return null;
  275. }
  276. async function checkFeeRateName(jdata) {
  277. let data = JSON.parse(jdata);
  278. let count = await feeRateFileModel.count({rootProjectID:data.rootProjectID,name:data.name,deleteInfo:null});
  279. if(count>0){
  280. return true;
  281. }
  282. return false;
  283. }
  284. async function getChangeInfo(jdata){
  285. let data = JSON.parse(jdata);
  286. //{ rootProjectID: 99, user_id: '76075' }
  287. let result={};
  288. let currentProject = await projectsModel.findOne({'ID':data.rootProjectID},['ID','name']); //{projectID:99,name:'建设项目1'};//dummy 数据
  289. if(currentProject){
  290. currentProject._doc.currentOptions=await getFeeRatesByProject(data.rootProjectID);
  291. }
  292. //根据用户ID 找除了当前项目的其它建设项目;
  293. let others =await projectsModel.find({'$and': [
  294. {'$or':[{'userID': data.user_id,'projType':'Project', 'deleteInfo': null}, {'userID': data.user_id,'projType':'Project', 'deleteInfo.deleted': {'$in': [null, false]}}]},
  295. { 'ID':{'$nin':[data.rootProjectID]}}
  296. ]},['ID','name']);
  297. for(let o of others){
  298. o._doc.optionList = await getFeeRatesByProject(o.ID);
  299. }
  300. result.currentProject=currentProject;
  301. result.others = others;
  302. return result;
  303. }
  304. async function getFeeRatesByProject(rootProjectID) {
  305. let feeRates = await feeRateFileModel.find({rootProjectID:rootProjectID,deleteInfo:null},['ID','name']);
  306. return feeRates;
  307. }
  308. async function setFeeRateToBill(data){
  309. data=JSON.parse(data);
  310. if(data.hasOwnProperty('bills')){
  311. await billModel.model.findOneAndUpdate(data.bills.query,data.bills.doc);
  312. }
  313. if(data.hasOwnProperty('feeRate')){
  314. await feeRateModel.findOneAndUpdate(data.feeRate.query,data.feeRate.doc);
  315. }
  316. return "ok";
  317. }
  318. async function updateFeeRate(data) {
  319. data=JSON.parse(data);
  320. return await feeRateModel.findOneAndUpdate(data.query,data.doc);
  321. }
  322. async function changeFeeRateFileFromCurrent(jdata){
  323. let data = JSON.parse(jdata);
  324. let newFeeRateFile=data.newFeeRateFile;
  325. let result = await projectsModel.findOneAndUpdate({ID:data.projectID},{'property.feeFile':newFeeRateFile});
  326. let feeRateData = await feeRateFileModel.findOne({'ID':newFeeRateFile.id});
  327. if(feeRateData!==null){
  328. let feeRate = await feeRateModel.findOne({ID:feeRateData.feeRateID});
  329. feeRateData._doc.rates = feeRate.rates;
  330. }
  331. //
  332. feeRateData._doc.usageProjects=await getUsageProjects(feeRateData.ID);
  333. return feeRateData;
  334. }
  335. async function changeFeeRateFileFromOthers(jdata) {
  336. let data = JSON.parse(jdata);
  337. console.log(data);
  338. let feeRateFile = await feeRateFileModel.findOne({'ID':data.feeRateFileID});
  339. let feeRate = await feeRateModel.findOne({ID:feeRateFile.feeRateID});
  340. let newFeeRate={};
  341. newFeeRate.ID=uuidV1();
  342. newFeeRate.rates =feeRate.rates;
  343. let newFeeRateFile = {};
  344. newFeeRateFile.ID = uuidV1();
  345. newFeeRateFile.name = data.name;
  346. newFeeRateFile.libName = feeRateFile.libName;
  347. newFeeRateFile.libID=feeRateFile.libID;
  348. newFeeRateFile.rootProjectID = data.rootProjectID;
  349. newFeeRateFile.feeRateID =newFeeRate.ID;
  350. await feeRateModel.create(newFeeRate);
  351. await feeRateFileModel.create(newFeeRateFile);
  352. let feeFile={
  353. id:newFeeRateFile.ID,
  354. name:data.name
  355. }
  356. await projectsModel.findOneAndUpdate({ID:data.projectID},{'property.feeFile':feeFile});
  357. newFeeRateFile.rates=newFeeRate.rates;
  358. newFeeRateFile.usageProjects=await getUsageProjects(newFeeRateFile.ID);
  359. return newFeeRateFile;
  360. }
  361. async function getGCFeeRateFiles(userID){
  362. return await feeRateFileModel.find({userID: userID, 'deleteInfo.deleted': true});
  363. }