pm_facade.js 128 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673267426752676267726782679268026812682268326842685268626872688268926902691269226932694269526962697269826992700270127022703270427052706270727082709271027112712271327142715271627172718271927202721272227232724272527262727272827292730273127322733273427352736273727382739274027412742274327442745274627472748274927502751275227532754275527562757275827592760276127622763276427652766276727682769277027712772277327742775277627772778277927802781278227832784278527862787278827892790279127922793279427952796279727982799280028012802280328042805280628072808280928102811281228132814281528162817281828192820282128222823282428252826282728282829283028312832283328342835283628372838283928402841284228432844284528462847284828492850285128522853285428552856285728582859286028612862286328642865286628672868286928702871287228732874287528762877287828792880288128822883288428852886288728882889289028912892289328942895289628972898289929002901290229032904290529062907290829092910291129122913291429152916291729182919292029212922292329242925292629272928292929302931293229332934293529362937293829392940294129422943294429452946294729482949295029512952295329542955295629572958295929602961296229632964296529662967296829692970297129722973297429752976297729782979298029812982298329842985298629872988298929902991299229932994299529962997299829993000300130023003300430053006300730083009301030113012301330143015301630173018301930203021302230233024302530263027302830293030303130323033303430353036303730383039304030413042304330443045
  1. /**
  2. * Created by zhang on 2018/4/17.
  3. */
  4. const projectType = {
  5. folder: 'Folder',
  6. tender: 'Tender',
  7. project: 'Project',
  8. engineering: 'Engineering',
  9. };
  10. //先导出后require可以解决循环引用问题
  11. module.exports={
  12. prepareShareList,
  13. getShareList,
  14. addShareList,
  15. updateShareList,
  16. deleteShareList,
  17. getShareInfoMap,
  18. getRecentShareList,
  19. getProjectShareList,
  20. getUnreadShareListByCompilation,
  21. getShareTip,
  22. getShareState,
  23. markShareItemsRead,
  24. getShareInfoAfterChangePermission,
  25. moveProject:moveProject,
  26. accessToCopyProject,
  27. copyProject:copyProject,
  28. copyExample: copyExample,
  29. setupSummaryFields: setupSummaryFields,
  30. getSummaryInfo: getSummaryInfo,
  31. getSummaryInfoByTender: getSummaryInfoByTender,
  32. getIndexReportData: getIndexReportData,
  33. getTendersFeeInfo: getTendersFeeInfo,
  34. getConstructionProject: getConstructionProject,
  35. getFullPath: getFullPath,
  36. projectType: projectType,
  37. getPosterityProjects: getPosterityProjects,
  38. isShare: isShare,
  39. isFirst: isFirst,
  40. getShareInfo: getShareInfo,
  41. prepareInitialData: prepareInitialData,
  42. changeFile:changeFile,
  43. getBasicInfo: getBasicInfo,
  44. getProjectFeature: getProjectFeature,
  45. getProjectByGranularity: getProjectByGranularity,
  46. importProject: importProject,
  47. getProjectPlaceholder: getProjectPlaceholder,
  48. exportProject:exportProject,
  49. importProjects:importProjects,//建筑这里重名了,这比养护加多了个s
  50. initOverHeightItems: initOverHeightItems,
  51. uploadToken:uploadToken,
  52. downLoadProjectFile:downLoadProjectFile,
  53. importChongqingProject:importChongqingProject,
  54. importProcessChecking:importProcessChecking,
  55. copyConstructionProject,
  56. importInterface,
  57. isTenderOverrun,
  58. getWelcomeInfo:getWelcomeInfo
  59. };
  60. let mongoose = require('mongoose');
  61. let _ = require("lodash");
  62. let feeRate_facade = require('../../fee_rates/facade/fee_rates_facade');
  63. let glj_facade = require('../../glj/facade/glj_facade');
  64. let project_facade = require('../../main/facade/project_facade');
  65. let logger = require("../../../logs/log_helper").logger;
  66. const uuidV1 = require('uuid/v1');
  67. let projectModel = mongoose.model('projects');
  68. let projectSettingModel = mongoose.model('proj_setting');
  69. let billsModel = mongoose.model('bills');
  70. let rationModel = mongoose.model('ration');
  71. let gljListModel = mongoose.model("glj_list");
  72. let calcProgramsModel = mongoose.model('calc_programs');
  73. let labourCoesModel = mongoose.model('labour_coes');
  74. let feeRateModel = mongoose.model('fee_rates');
  75. let feeRateFileModel = mongoose.model('fee_rate_file');
  76. let unitPriceFileModel = mongoose.model("unit_price_file");
  77. let mixRatioModel = mongoose.model("mix_ratio");
  78. let unitPriceModel = mongoose.model("unit_price");
  79. let installationFeeModel = mongoose.model("installation_fee");
  80. let rationGLJModel = mongoose.model('ration_glj');
  81. let rationCoeModel = mongoose.model('ration_coe');
  82. let rationInstallationModel = mongoose.model('ration_installation');
  83. let quantityDetailModel = mongoose.model('quantity_detail');
  84. let rationTemplateModel = mongoose.model('ration_template');
  85. let userModel = mongoose.model('user');
  86. let compleGljSectionModel = mongoose.model('complementary_glj_section');
  87. let compleGljSectionTModel = mongoose.model('complementary_glj_section_templates');
  88. let compilationModel = mongoose.model('compilation');
  89. let engineeringModel = mongoose.model('engineering_lib');
  90. let basicInfoModel = mongoose.model('std_basic_info_lib');
  91. let projectFeatureModel = mongoose.model('std_project_feature_lib');
  92. let stdRationItemModel = mongoose.model('std_ration_lib_ration_items');
  93. let stdGljItemModel = mongoose.model('std_glj_lib_gljList');
  94. let evaluateListModel = mongoose.model("evaluate_list");
  95. let bidListModel = mongoose.model("bid_evaluation_list");
  96. let contractorListModel = mongoose.model("contractor_list");
  97. let featureLibModel = mongoose.model("std_project_feature_lib");
  98. let importLogsModel = mongoose.model("import_logs");
  99. const overHeightLibModel = mongoose.model('std_over_height_lib');
  100. const shareListModel = mongoose.model('share_list');
  101. let welcomeModel = mongoose.model("welcome_setting");
  102. let scMathUtil = require('../../../public/scMathUtil').getUtil();
  103. let counter = require('../../../public/counter/counter');
  104. const SectionTreeDao = require('../../complementary_ration_lib/models/sectionTreeModel');
  105. let sectionTreeDao = new SectionTreeDao();
  106. const CounterModel = require("../../glj/models/counter_model");
  107. const moment = require('moment-timezone');
  108. const { fixedFlag, SharePermissionChangeType } = require('../../../public/common_constants');
  109. const notDeleted = [{deleteInfo: null}, {'deleteInfo.deleted': false}];
  110. const {
  111. defaultDecimal,
  112. billsQuantityDecimal,
  113. displaySetting,
  114. calcOptions,
  115. tenderSetting
  116. } = require('../models/project_property_template');
  117. let labourCoeFacade = require('../../main/facade/labour_coe_facade');
  118. let calcProgramFacade = require('../../main/facade/calc_program_facade');
  119. let mainColLibModel = mongoose.model('std_main_col_lib');
  120. const EngineeringLibModel = require("../../users/models/engineering_lib_model");
  121. let installationFacade = require('../../main/facade/installation_facade');
  122. let cipher = require('../../../public/cipher');
  123. let index = require("../../system_setting/model/index");
  124. let qiniu = require("qiniu");
  125. let fs = require("fs");
  126. let path = require("path");
  127. let request = require("request");
  128. const systemSettingModel = mongoose.model('system_setting');
  129. let qiniu_config = {
  130. "AccessKey": "_gR1ed4vi1vT2G2YITGSf4_H0fJu_nRS9Tzk3T4z",
  131. "SecretKey": "ty4zd0FHqgEDaiVzSLC8DfHlai99aS7bspLkw6s6",
  132. "Bucket": "yun-update",
  133. "Domain": "http://serverupdate.smartcost.com.cn"
  134. };
  135. let mac = new qiniu.auth.digest.Mac(qiniu_config.AccessKey, qiniu_config.SecretKey);
  136. // 重构了分享的数据结构,原本存在projects表的shareInfo数组中
  137. // 为了更好地适应新功能及以后拓展功能,现将分享信息存放在单独的share_list表中
  138. // 为了适应旧数据,需要在share_list没有数据的时候,将原本的分享信息复制到share_list中,同时生成联系人
  139. // TODO: 上线后这个方法执行过后,应该删除此方法
  140. async function prepareShareList() {
  141. const shareListCount = await shareListModel.count({});
  142. console.log(shareListCount);
  143. if (shareListCount) {
  144. return;
  145. }
  146. logger.info('================================enterPrepareShareList================================================');
  147. // 将项目的shareInfo数据复制到share_list表中
  148. const projects = await projectModel.find({'shareInfo.0': {$exists: true}}, '-_id ID userID shareInfo').lean();
  149. if (!projects.length) {
  150. return;
  151. }
  152. const shareList = [];
  153. const userMap = {}; // 给生成联系人做准备
  154. projects.forEach(project => {
  155. const ownerContacts = userMap[project.userID] || (userMap[project.userID] = []);
  156. project.shareInfo.forEach(shareItem => {
  157. if (!shareItem.shareDate) {
  158. return;
  159. }
  160. const receiverContacts = userMap[shareItem.userID] || (userMap[shareItem.userID] = []);
  161. receiverContacts.push(project.userID);
  162. const newItem = {
  163. ID: uuidV1(),
  164. projectID: project.ID,
  165. owner: project.userID,
  166. receiver: shareItem.userID,
  167. allowCopy: shareItem.allowCopy,
  168. allowCooperate: shareItem.allowCooperate,
  169. shareDate: shareItem.shareDate,
  170. updateDate: shareItem.shareDate
  171. };
  172. ownerContacts.push(shareItem.userID);
  173. shareList.push(newItem);
  174. });
  175. });
  176. // 插入分享信息
  177. const shareListPromise = shareListModel.insertMany(shareList);
  178. const tasks = [shareListPromise];
  179. // 更新用户信息
  180. const userTasks = [];
  181. Object.entries(userMap).forEach(([userID, contacts]) => {
  182. contacts = [...new Set(contacts)]
  183. .map(user => ({ userID: user }));
  184. const task = {
  185. updateOne: {
  186. filter: {
  187. _id: mongoose.Types.ObjectId(userID)
  188. },
  189. update: {
  190. contacts
  191. }
  192. }
  193. };
  194. userTasks.push(task);
  195. });
  196. if (userTasks.length) {
  197. tasks.push(userModel.bulkWrite(userTasks));
  198. }
  199. await Promise.all(tasks);
  200. }
  201. // 获取分享列表
  202. async function getShareList(query) {
  203. return await shareListModel.find(query, '-_id').lean();
  204. }
  205. async function addShareList(docs) {
  206. await shareListModel.insertMany(docs);
  207. }
  208. async function deleteShareList(query) {
  209. await shareListModel.deleteMany(query);
  210. }
  211. async function updateShareList(updateData) {
  212. const bulks = updateData.map(item => (
  213. {
  214. updateOne: {
  215. filter: item.query,
  216. update: item.update
  217. }
  218. }
  219. ));
  220. if (bulks.length) {
  221. await shareListModel.bulkWrite(bulks);
  222. }
  223. }
  224. // 根据项目ID获取项目shareInfo字段的数据映射(前端旧逻辑依赖项目本身的shareInfo字段)
  225. async function getShareInfoMap(projectIDs, shareList = null) {
  226. if (!shareList) {
  227. shareList = await getShareList({projectID: {$in: projectIDs}});
  228. }
  229. // 将相同项目的分享信息进行映射
  230. const map = {};
  231. shareList.forEach(item => {
  232. const shareInfo = map[item.projectID] || (map[item.projectID] = []);
  233. shareInfo.push({
  234. userID: item.receiver,
  235. shareDate: item.shareDate,
  236. updateDate: item.updateDate,
  237. allowCopy: item.allowCopy,
  238. allowCooperate: item.allowCooperate
  239. });
  240. });
  241. return map;
  242. }
  243. // 获取最近分享(只算分享出去的记录)
  244. async function getRecentShareList(userID, count) {
  245. const shareList = await getShareList({owner: userID});
  246. shareList.sort((a, b) => Date.parse(b.shareDate) - Date.parse(a.shareDate));
  247. const set = new Set();
  248. for(const item of shareList) {
  249. if (set.size === count) {
  250. break;
  251. }
  252. set.add(item.receiver);
  253. }
  254. const sortedIDList = [...set];
  255. const userIDList = sortedIDList.map(userID => mongoose.Types.ObjectId(userID));
  256. const users = await userModel.find({_id: {$in: userIDList}}, 'real_name mobile company').lean();
  257. users.sort((a, b) => sortedIDList.indexOf(a._id.toString()) - sortedIDList.indexOf(b._id.toString()));
  258. return users;
  259. }
  260. // 获取某项目的分享记录
  261. async function getProjectShareList(projectID, limit = null) {
  262. const sharedList = limit
  263. ? await shareListModel.find({ projectID }).lean().sort({ shareDate: -1 }).limit(limit)
  264. : await shareListModel.find({ projectID }).lean().sort({ shareDate: -1 });
  265. const userIDs = [];
  266. const userMap = {};
  267. sharedList.forEach((item, index) => {
  268. userIDs.push(item.receiver);
  269. userMap[item.receiver] = item;
  270. userMap[item.receiver].index = index;
  271. });
  272. const userObjectIDs = userIDs.map(userID => mongoose.Types.ObjectId(userID));
  273. const users = await userModel.find({_id: {$in: userObjectIDs}}, 'real_name mobile company').lean();
  274. users.forEach(user => {
  275. const matched = userMap[user._id];
  276. if (matched) {
  277. user.index = matched.index;
  278. user.allowCopy = matched.allowCopy;
  279. user.allowCooperate = matched.allowCooperate;
  280. }
  281. });
  282. users.sort((a, b) => a.index - b.index);
  283. return users;
  284. }
  285. // 获取某用户某费用定额的未读的被分享记录
  286. async function getUnreadShareListByCompilation(userID, compilationID, isGetCount) {
  287. const fields = isGetCount ? '-_id projectID ' : '-_id';
  288. const list = await shareListModel.find({ receiver: userID, isRead: false }, fields);
  289. const idList = list.reduce((acc, cur) => {
  290. acc.push(cur.projectID);
  291. return acc;
  292. }, []);
  293. const notDeleted = [{ deleteInfo: null }, { 'deleteInfo.deleted': false }];
  294. const query = { ID: { $in: idList }, compilation: compilationID, $or: notDeleted };
  295. if (isGetCount) {
  296. return await projectModel.count(query)
  297. }
  298. const items = await projectModel.find(query, '-_id ID').lean();
  299. return items.map(item => item.ID);
  300. }
  301. // 获取分享的提示(造价书分享按钮tooltip使用)
  302. async function getShareTip(projectID, limit) {
  303. const task = [
  304. getProjectShareList(projectID, limit),
  305. shareListModel.count({ projectID })
  306. ];
  307. const [users, count] = await Promise.all(task);
  308. return users.reduce((acc, user, index) => {
  309. if (index === 0) {
  310. acc += '已分享给';
  311. acc += user.real_name;
  312. } else {
  313. acc += ` ${user.real_name}`;
  314. }
  315. if (index === users.length - 1 && count > limit) {
  316. acc += `等${count}人`;
  317. }
  318. return acc;
  319. }, '');
  320. }
  321. // 获取项目的分享状态
  322. // 分享项目的拷贝和编辑性,需要参考父项
  323. // 以项目链上最新更新的分享数据为准
  324. async function getShareState(projectID, receiver) {
  325. const projectIDs = await getUpChainIDs(projectID);
  326. const shareList = await shareListModel.find({ projectID: { $in: projectIDs }, receiver }).lean();
  327. shareList.sort((a, b) => Date.parse(b.updateDate) - Date.parse(a.updateDate));
  328. return {
  329. allowCopy: shareList[0] && shareList[0].allowCopy || false,
  330. allowCooperate: shareList[0] && shareList[0].allowCooperate || false
  331. };
  332. }
  333. // 自身及父链上的分享数据(链距离最近的一个)
  334. async function getUpChainShareData(projectID, receiver) {
  335. while (projectID != -1) {
  336. const shareData = await shareListModel.findOne({ projectID, receiver }).lean();
  337. if (shareData) {
  338. return shareData;
  339. }
  340. const project = await projectModel.findOne({ ID: projectID }, '-_id ParentID').lean();
  341. projectID = project ? project.ParentID : -1;
  342. }
  343. return null;
  344. }
  345. // 标记已读分享条目
  346. // 打开任意的单位工程,都会将其父分享条目标记和自身为已读
  347. // eg:被分享了一个建设项目,和其下一个单位工程,打开该一个单位工程,建设项目标记为已读、该单位工程也标记为已读
  348. async function markShareItemsRead(projectID, userID) {
  349. const upChainIDs = await getUpChainIDs(projectID);
  350. const unreadList = await shareListModel.find({ projectID: { $in: upChainIDs }, receiver: userID, isRead: false }, '-_id ID projectID').lean();
  351. const markReadProjectIDs = [];
  352. const bulks = [];
  353. unreadList.forEach(item => {
  354. markReadProjectIDs.push(item.projectID);
  355. bulks.push({
  356. updateOne: {
  357. filter: { ID: item.ID },
  358. update: { isRead: true }
  359. }
  360. });
  361. });
  362. if (bulks.length) {
  363. await shareListModel.bulkWrite(bulks);
  364. }
  365. return markReadProjectIDs;
  366. }
  367. /**
  368. * 分享权限变更后,根据变更操作,获取相关项目的分享权限信息
  369. * 不能简单根据某个项目的分享信息获得其权限,因为目前的分享可以重复分享(分享单位工程A、分享包含单位工程A的父项)
  370. * 最新的分享权限是由项目链上(所有子项、自身、父项...)最新的分享信息决定的
  371. * @param {Number} permissionType - 分享权限变更类型
  372. * @param {String} receiver - 用户ID
  373. * @param {Number} projectID - 项目ID
  374. */
  375. async function getShareInfoAfterChangePermission(permissionType, receiver, projectID) {
  376. const project = await projectModel.findOne({ ID: projectID }, '-_id ID projType').lean();
  377. if (!project) {
  378. return [];
  379. }
  380. // UPDATE_COPY不触发推送给主页面的消息
  381. const propChange = [SharePermissionChangeType.UPDATE_COOPERATE].includes(permissionType);
  382. const cancelShare = permissionType === SharePermissionChangeType.CANCEL;
  383. // 需要处理的单位工程
  384. if (propChange && project.projType === projectType.tender) {
  385. const shareData = await shareListModel.findOne({ projectID, receiver }, '-_id allowCooperate allowCopy updateDate').lean();
  386. const tender = { ID: projectID };
  387. if (shareData) {
  388. Object.assign(tender, shareData);
  389. }
  390. return [tender];
  391. }
  392. if (propChange && project.projType !== projectType.tender) {
  393. const projects = await getPosterityProjects([projectID], false, '-_id ID projType');
  394. const tenders = projects.filter(p => p.projType === projectType.tender);
  395. const shareData = await shareListModel.findOne({ projectID, receiver }, '-_id allowCooperate allowCopy updateDate').lean();
  396. if (shareData) {
  397. tenders.forEach(tender => Object.assign(tender, shareData));
  398. }
  399. return tenders
  400. }
  401. if (cancelShare && project.projType === projectType.tender) {
  402. const shareData = await getUpChainShareData(projectID, receiver);
  403. return shareData ? [] : [{ ID: projectID }];
  404. }
  405. if (cancelShare && project.projType !== projectType.tender) {
  406. const projects = await getPosterityProjects([projectID], false, '-_id ID projType');
  407. const tenders = [];
  408. for (const p of projects) {
  409. if (p.projType === projectType.tender) {
  410. const shareData = await getUpChainShareData(p.ID, receiver);
  411. if (!shareData) {
  412. tenders.push({ ID: p.ID });
  413. }
  414. }
  415. }
  416. return tenders;
  417. }
  418. return [];
  419. }
  420. //拷贝例题项目
  421. //@param {String}userID {Array}projIDs拷贝的例题项目ID(建设项目、文件夹)@return {Boolean}
  422. async function copyExample(userID, compilation, projIDs,nameMap){
  423. let allProjs = [],
  424. IDMapping = {},
  425. projMapping = {};
  426. //例题项目不可为单项工程、单位工程、只能是建设项目、文件夹,否则不自动新建例题项目(这里不报错,让用户没有感觉)
  427. let parentExample = await projectModel.find({ID: {$in: projIDs}, $or: notDeleted}).lean();
  428. if (parentExample.length === 0) {
  429. return false;
  430. }
  431. allProjs = allProjs.concat(parentExample);
  432. for (let i = 0; i < parentExample.length; i++) {
  433. let data = parentExample[i];
  434. if (data.projType === projectType.tender || data.projType === projectType.engineering) {
  435. return false;
  436. }
  437. //设置成顶节点,最后一个节点设置成末节
  438. data.ParentID = -1;
  439. if (i === parentExample.length - 1) {
  440. data.NextSiblingID = -1;
  441. }
  442. if(nameMap && nameMap[data.ID]) data.name = nameMap[data.ID];
  443. }
  444. //获取所有的子项目
  445. let posterityProjs = await getPosterityProjects(projIDs);
  446. allProjs = allProjs.concat(posterityProjs);
  447. let projCounter = await counter.counterDAO.getIDAfterCountSync(counter.moduleName.project, allProjs.length);
  448. //旧ID与新ID映射
  449. for (let i = 0; i < allProjs.length; i++) {
  450. let data = allProjs[i];
  451. let newID = projCounter.sequence_value - (allProjs.length - 1) + i;
  452. IDMapping[data.ID] = newID;
  453. projMapping[newID] = data;
  454. }
  455. //return;
  456. //设置新的树结构数据
  457. let newDate = new Date(),
  458. parentBulks = [];
  459. const projectMaps = [];
  460. // 传入项目ID的新ID
  461. const newProjIDs = [];
  462. for (let data of allProjs) {
  463. let orgID = data.ID;
  464. data.ID = IDMapping[data.ID];
  465. if (projIDs.indexOf(orgID) >= 0) {
  466. newProjIDs.push(data.ID);
  467. }
  468. data.ParentID = IDMapping[data.ParentID] ? IDMapping[data.ParentID] : -1;
  469. data.NextSiblingID = IDMapping[data.NextSiblingID] ? IDMapping[data.NextSiblingID] : -1;
  470. data.createDateTime = newDate;
  471. data.userID = userID;
  472. data.compilation = compilation;
  473. data.shareInfo = [];
  474. if (data.projType !== projectType.tender) {
  475. let newData = _.cloneDeep(data);
  476. delete newData._id;
  477. // await projectModel.create(newData);
  478. parentBulks.push({insertOne: {document: newData}});
  479. } else {
  480. //拷贝单位工程
  481. let rootProjectID = projMapping[data.ParentID].ParentID;
  482. let projectMap = {
  483. copy: {
  484. document: {userID: userID, ID: orgID, NextSiblingID: data.NextSiblingID, ParentID: data.ParentID, name: data.name, shareInfo: [],
  485. compilation: compilation, fileVer: data.fileVer, projType: data.projType, property: {rootProjectID: rootProjectID}}
  486. }
  487. };
  488. await copyProject(userID, compilation, {projectMap}, data.ID, true);
  489. projectMaps.push(projectMap);
  490. }
  491. }
  492. //最末顶层项目(兼容测试时已存在有项目,正常用户第一次进费用定额,该费用定额不存在项目)
  493. let lastProj = await projectModel.findOne({userID: userID, compilation: compilation, ParentID: -1, NextSiblingID: -1, $or: notDeleted});
  494. if (lastProj) {
  495. parentBulks.push({updateOne: {filter: {ID: lastProj.ID}, update: {$set: {NextSiblingID: parentExample[0].ID}}}});
  496. }
  497. // 处理项目数据
  498. const projectTasks = [projectModel.bulkWrite(parentBulks), createProject(projectMaps)];
  499. await Promise.all(projectTasks);
  500. return newProjIDs;
  501. }
  502. async function accessToCopyProject(userID, compilationID, data, newProjectID) {
  503. const logData = {
  504. key: uuidV1(),
  505. content: '正在拷贝项目,请稍候……',
  506. userID,
  507. compilationID,
  508. status: 'start',
  509. create_time: +new Date()
  510. };
  511. await importLogsModel.create(logData);
  512. handleCopyProject(logData.key, userID, compilationID,data,newProjectID);
  513. return 'copying project';
  514. }
  515. async function handleCopyProject(key, userID, compilationID, data, newProjectID) {
  516. const doc = { status: 'finish' };
  517. try {
  518. const projectMap = await copyProject(userID, compilationID, data, newProjectID);
  519. doc.projectID = [projectMap.copy.document.ID];
  520. } catch (err) {
  521. doc.status = 'error';
  522. doc.errorMsg = String(err);
  523. } finally {
  524. await importLogsModel.update({ key }, doc);
  525. }
  526. }
  527. async function copyProject(userID, compilationID,data,newProjectID = null, delayProjectTask = false) {
  528. let projectMap = data.projectMap;
  529. let originalID = projectMap['copy'].document.ID;
  530. if (!newProjectID) {
  531. newProjectID = await getCounterID("projects");
  532. }
  533. let newFeeName = null,newUnitName = null;
  534. let calcProgramFileID = uuidV1();//新的计算程序文件ID
  535. let labourCoeFileID = uuidV1();//新的人工调整系数文件ID
  536. let feeRateFileID = uuidV1();//新的费率文件ID
  537. let unitPriceFileID = await getCounterID("unit_price_file");//新的单价文件ID
  538. let originalProject = await projectModel.findOne({'ID':originalID});//查找最新的那项目信息,前端缓存的数据有可能不是最新的
  539. if(!originalProject){
  540. throw new Error('没有找到对应的项目,复制失败!');
  541. }
  542. let property = originalProject.property;
  543. if(projectMap['copy'].document.property){//更新项目属性信息
  544. setProperty(property,projectMap['copy'].document.property);
  545. }
  546. let originalProperty = _.cloneDeep(property);
  547. projectMap['copy'].document.property = property;
  548. logger.info("复制项目: 旧项目ID: "+originalID+ " ------- 新项目ID: "+newProjectID);
  549. //费率文件、单价文件重名检查
  550. let feeRate = await feeRateFileModel.findOne({rootProjectID:originalProperty.rootProjectID,name:originalProperty.feeFile.name,deleteInfo:null});
  551. if(feeRate){//存在重名的文件
  552. newFeeName = originalProperty.feeFile.name + '(' + moment(Date.now()).tz("Asia/Shanghai").format('MM-DD HH:mm:ss') + '复制)';
  553. projectMap['copy'].document.property.feeFile.name = newFeeName;
  554. }
  555. let unitPriceFile = await unitPriceFileModel.findOne({root_project_id: originalProperty.rootProjectID,name:originalProperty.unitPriceFile.name,deleteInfo: null});
  556. if(unitPriceFile){//存在重名的文件
  557. newUnitName = originalProperty.unitPriceFile.name + '(' + moment(Date.now()).tz("Asia/Shanghai").format('MM-DD HH:mm:ss') + '复制)';
  558. projectMap['copy'].document.property.unitPriceFile.name = newUnitName;
  559. }
  560. //更新项目的属性;
  561. projectMap['copy'].document.ID = newProjectID;
  562. if(projectMap['copy'].document.property.calcProgramFile){
  563. projectMap['copy'].document.property.calcProgramFile.ID = calcProgramFileID;
  564. }
  565. if(projectMap['copy'].document.property.labourCoeFile){
  566. projectMap['copy'].document.property.labourCoeFile.ID = labourCoeFileID;
  567. }
  568. if(projectMap['copy'].document.property.feeFile){
  569. projectMap['copy'].document.property.feeFile.id = feeRateFileID;
  570. }
  571. if(projectMap['copy'].document.property.unitPriceFile){
  572. projectMap['copy'].document.property.unitPriceFile.id = unitPriceFileID;
  573. }
  574. projectMap['copy'].document.userID = userID;
  575. projectMap['copy'].document.compilation = compilationID;
  576. projectMap['copy'].document.createDateTime = new Date();
  577. //清单、定额ID生成任务
  578. let IDtasks = [
  579. createIDsAndReturn(originalID,billsModel),
  580. createIDsAndReturn(originalID,rationModel),
  581. getProjectGLJIDAndReturn(originalID,newProjectID)
  582. ];
  583. let [billMap,rationMap,projectGLJMap] = await Promise.all(IDtasks);
  584. //所有复制任务异步处理,提升效率 复制清单,定额,4个文件,项目工料机, 定额工料机,人工系数,工程量明细,定额安装增加费,安装增加费
  585. let copyTasks = [
  586. copyProjectSetting(originalID,newProjectID),
  587. copyBills(newProjectID,billMap),
  588. copyRations(newProjectID,billMap.uuidMaping,rationMap,projectGLJMap.IDMap),
  589. copyProjectGLJ(projectGLJMap.datas),
  590. copyInstallFee(originalID,newProjectID),
  591. copyRationSubList(originalID,newProjectID,billMap.uuidMaping,rationMap.uuidMaping,projectGLJMap.IDMap,rationGLJModel),
  592. copyRationSubList(originalID,newProjectID,billMap.uuidMaping,rationMap.uuidMaping,projectGLJMap.IDMap,rationCoeModel),
  593. copyRationSubList(originalID,newProjectID,billMap.uuidMaping,rationMap.uuidMaping,projectGLJMap.IDMap,quantityDetailModel),
  594. copyRationSubList(originalID,newProjectID,billMap.uuidMaping,rationMap.uuidMaping,projectGLJMap.IDMap,rationInstallationModel),
  595. copyRationSubList(originalID,newProjectID,billMap.uuidMaping,rationMap.uuidMaping,projectGLJMap.IDMap,rationTemplateModel),
  596. copyMaterialList(originalID,newProjectID,projectGLJMap.IDMap,evaluateListModel),
  597. copyMaterialList(originalID,newProjectID,projectGLJMap.IDMap,bidListModel),
  598. copyMaterialList(originalID,newProjectID,projectGLJMap.IDMap,contractorListModel),
  599. ];
  600. if(originalProperty.calcProgramFile){
  601. copyTasks.push(commonCopy(newProjectID,originalProperty.calcProgramFile.ID,calcProgramFileID,calcProgramsModel));
  602. }
  603. if(originalProperty.labourCoeFile){
  604. copyTasks.push(commonCopy(newProjectID,originalProperty.labourCoeFile.ID,labourCoeFileID,labourCoesModel));
  605. }
  606. if(originalProperty.feeFile){
  607. copyTasks.push(copyFeeRate(originalProperty.rootProjectID,userID,originalProperty.feeFile.id,feeRateFileID,newFeeName));
  608. }
  609. if(originalProperty.unitPriceFile){
  610. copyTasks.push(copyUnitPriceFile(newProjectID,originalProperty.rootProjectID,userID,originalProperty.unitPriceFile.id,unitPriceFileID,newUnitName));
  611. }
  612. await Promise.all(copyTasks);
  613. // 最后再处理项目数据
  614. // 可能会有最后再在外层方法插入项目数据的需求,如拷贝例题,暂时先不在这里插入项目数据
  615. if (delayProjectTask) {
  616. return [projectMap];
  617. } else {
  618. const projectMaps = await createProject([projectMap]);
  619. return projectMaps[0];
  620. }
  621. }
  622. async function createIDsAndReturn(originalID,model) {
  623. let uuidMaping = {};//做ID映射
  624. let datas = [];
  625. let result = await model.find({"projectID": originalID}, '-_id').lean();
  626. uuidMaping['-1'] = -1;
  627. //建立uuid-ID映射
  628. for(let d of result){
  629. uuidMaping[d.ID] = uuidV1();
  630. datas.push(d);
  631. }
  632. return{uuidMaping:uuidMaping,datas:datas};
  633. }
  634. async function getProjectGLJIDAndReturn(originalID,newProjectID) {
  635. let IDMap = {};
  636. let datas = [];
  637. let result = await gljListModel.find({project_id:originalID}, '-_id').lean();
  638. let gljCount = await counter.counterDAO.getIDAfterCountSync(counter.moduleName.glj_list, result.length);
  639. for(let i = 0; i < result.length; i++){
  640. let d = result[i];
  641. let newID = gljCount.sequence_value - (result.length - 1) + i;
  642. //let newID = await getCounterID("glj_list");
  643. IDMap[d.id] = newID;
  644. d.project_id = newProjectID;
  645. d.id = newID;
  646. datas.push(d);
  647. }
  648. return{IDMap:IDMap,datas:datas};
  649. }
  650. async function createProject(projectMaps) {//复制项目
  651. let tasks = [];
  652. for (const projectMap of projectMaps) {
  653. if(projectMap['update']){//如果复制后存在前一个节点,则更新其NextSiblingID
  654. tasks.push({updateOne:{filter : projectMap['update'].query, update : {NextSiblingID:projectMap['copy'].document.ID}}});
  655. }
  656. tasks.push({insertOne: {document: projectMap['copy'].document}});//复制任务
  657. }
  658. await projectModel.bulkWrite(tasks);
  659. return projectMaps;
  660. }
  661. async function copyProjectSetting(originalID,newProjectID) {
  662. let result = null;
  663. let setting = await projectSettingModel.findOne({"projectID": originalID}, '-_id');
  664. if(setting){
  665. setting._doc.projectID =newProjectID;
  666. result = await projectSettingModel.create(setting._doc);
  667. }
  668. return result;
  669. }
  670. async function copyBills(newProjectID,billMap) {
  671. let uuidMaping = billMap.uuidMaping;//做ID映射
  672. for(let doc of billMap.datas){
  673. doc = getCopyBillDatas(doc,newProjectID,uuidMaping);
  674. }
  675. await insertMany(billMap.datas,billsModel);
  676. return billMap.datas;
  677. }
  678. function getCopyBillDatas(doc,newProjectID,uuidMaping) {
  679. doc.projectID = newProjectID;
  680. doc.ID = uuidMaping[doc.ID] ? uuidMaping[doc.ID] : -1;
  681. doc.ParentID = uuidMaping[doc.ParentID] ? uuidMaping[doc.ParentID] : -1;
  682. doc.NextSiblingID = uuidMaping[doc.NextSiblingID] ? uuidMaping[doc.NextSiblingID] : -1;
  683. //对于有基数计算的节点,需要替换计算基数中引用的ID为新的ID
  684. if(doc.calcBase && doc.calcBase != ""){
  685. let idArr = scMathUtil.getFIDArr(doc.calcBase);
  686. for(let re of idArr){
  687. let oID = re.substr(1);//去掉开头的@字符
  688. if(!uuidMaping[oID]) continue;
  689. doc.calcBase = doc.calcBase.replace(new RegExp(oID, "g"),uuidMaping[oID]);
  690. }
  691. }
  692. return doc;
  693. }
  694. async function copyRations(newProjectID,billsIDMap,rationMap,projectGLJIDMap) {
  695. let uuidMaping = rationMap.uuidMaping;
  696. for(let doc of rationMap.datas){
  697. doc = getCopyRationData(doc,newProjectID,billsIDMap,uuidMaping,projectGLJIDMap);
  698. }
  699. if(rationMap.datas.length > 0){
  700. await insertMany(rationMap.datas,rationModel);
  701. }
  702. return rationMap.datas;
  703. }
  704. function getCopyRationData(doc,newProjectID,billsIDMap,uuidMaping,projectGLJIDMap){
  705. doc.projectID = newProjectID;
  706. doc.ID = uuidMaping[doc.ID] ? uuidMaping[doc.ID] : -1;
  707. if(doc.billsItemID){
  708. doc.billsItemID = billsIDMap[doc.billsItemID]?billsIDMap[doc.billsItemID]:-1;
  709. }
  710. if(doc.referenceRationID) doc.referenceRationID = uuidMaping[doc.referenceRationID]?uuidMaping[doc.referenceRationID]:undefined;
  711. //绑定定类型的工料机 项目工料机ID
  712. doc.type==3&&doc.projectGLJID&&projectGLJIDMap[doc.projectGLJID]?doc.projectGLJID = projectGLJIDMap[doc.projectGLJID]:'';
  713. return doc;
  714. }
  715. async function copyProjectGLJ(gljList) {
  716. await insertMany(gljList,gljListModel);
  717. }
  718. async function commonCopy(newProjectID,oldID,newID,model) { //对于只需更新ID和projectID的文件的复制
  719. let result = null;
  720. let file = await model.findOne({"ID": oldID}, '-_id');
  721. if(file){
  722. file._doc.ID = newID;
  723. file._doc.projectID =newProjectID;
  724. result = await model.create(file._doc);
  725. }
  726. return result;
  727. }
  728. async function copyFeeRate(rootProjectID,userID,originalFeeRateFileID,feeRateFileID,newName) {//复制费率和费率文件
  729. let [feeRateFile,feeRate] =await feeRate_facade.getFeeRateByID(originalFeeRateFileID);
  730. let newFeeRateID = uuidV1();
  731. if(feeRate){
  732. feeRate._doc.ID = newFeeRateID;
  733. await feeRateModel.create(feeRate._doc);
  734. }
  735. if(feeRateFile){
  736. feeRateFile._doc.ID = feeRateFileID;
  737. newName?feeRateFile._doc.name = newName:'';
  738. feeRateFile._doc.userID = userID;
  739. feeRateFile._doc.rootProjectID = rootProjectID;
  740. feeRateFile._doc.feeRateID = newFeeRateID;
  741. await feeRateFileModel.create(feeRateFile._doc);
  742. }
  743. }
  744. async function copyUnitPriceFile(newProjectID,rootProjectID,userID,originaluUnitPriceFileID,unitPriceFileID,newName) {//复制单价文件、组成物
  745. let taskList = [
  746. copyFile(newProjectID,rootProjectID,userID,originaluUnitPriceFileID,unitPriceFileID,newName),
  747. copySubList(originaluUnitPriceFileID,unitPriceFileID,mixRatioModel),
  748. copySubList(originaluUnitPriceFileID,unitPriceFileID,unitPriceModel)
  749. ];
  750. return await Promise.all(taskList);
  751. async function copyFile(newProjectID,rootProjectID,userID,originaluUnitPriceFileID,unitPriceFileID,newName){
  752. let unitPriceFile = await unitPriceFileModel.findOne({id:originaluUnitPriceFileID}, '-_id');
  753. if(unitPriceFile){
  754. unitPriceFile._doc.id = unitPriceFileID;
  755. newName?unitPriceFile._doc.name = newName:'';
  756. unitPriceFile._doc.project_id = newProjectID;
  757. unitPriceFile._doc.user_id = userID;
  758. unitPriceFile._doc.root_project_id = rootProjectID
  759. }
  760. await unitPriceFileModel.create(unitPriceFile._doc);
  761. }
  762. async function copySubList(srcFID,newFID,model) {
  763. let mList = await model.find({unit_price_file_id: srcFID}, '-_id').lean();
  764. let rList = [];
  765. let IDcounter = await counter.counterDAO.getIDAfterCountSync(model.modelName, mList.length);
  766. let firstID = IDcounter.sequence_value - (mList.length - 1);
  767. for(let m of mList){
  768. m.unit_price_file_id = newFID;
  769. m.id = firstID;
  770. firstID+=1
  771. rList.push(m);
  772. }
  773. await insertMany(rList,model)
  774. }
  775. }
  776. async function copyInstallFee(originalPID,newProjectID) {
  777. let result = null;
  778. let installationFee = await installationFeeModel.find({projectID:originalPID}, '-_id');
  779. let newList = [];
  780. for(let i of installationFee ){
  781. i._doc.ID = uuidV1();
  782. i._doc.projectID = newProjectID;
  783. newList.push(i._doc);
  784. }
  785. if(newList.length >0){
  786. result = await installationFeeModel.insertMany(newList);
  787. }
  788. return result;
  789. }
  790. async function copyRationSubList(originalPID,newProjectID,billIDMap,rationIDMap,projectGLJIDMap,model) {// 定额工料机,附注条件,工程量明细,定额安装增加费,模板子目
  791. let first = +new Date();
  792. let subList = await model.find({projectID:originalPID}, '-_id').lean();
  793. let newList =[];
  794. for(let s of subList){
  795. s = getCopyRationSubData(s,newProjectID,billIDMap,rationIDMap,projectGLJIDMap);
  796. newList.push(s);
  797. }
  798. if(newList.length > 0) await insertMany(newList,model);
  799. let last = +new Date();
  800. console.log(model.modelName+"-------"+newList.length+"--copyRationSubList - insert时间为-------------------------------"+(last-first));
  801. }
  802. async function copyMaterialList(originalPID,newProjectID,projectGLJIDMap,model) {//暂估材料等信息
  803. let materialList = await model.find({projectID:originalPID}, '-_id').lean();
  804. let newList = [];
  805. for(let m of materialList){
  806. newList.push(getNewMaterial(m,newProjectID,projectGLJIDMap))
  807. }
  808. await insertMany(newList,model);
  809. }
  810. function getNewMaterial(m,newProjectID,projectGLJIDMap) {
  811. m.ID = uuidV1();
  812. m.projectID = newProjectID;
  813. if(projectGLJIDMap[m.projectGLJID]) m.projectGLJID = projectGLJIDMap[m.projectGLJID];
  814. return m;
  815. }
  816. function getCopyRationSubData(doc,newProjectID,billIDMap,rationIDMap,projectGLJIDMap){
  817. doc.ID = uuidV1();
  818. doc.projectID = newProjectID;
  819. doc.rationID&&rationIDMap[doc.rationID]?doc.rationID = rationIDMap[doc.rationID]:'';
  820. doc.billID&&billIDMap[doc.billID]?doc.billID = billIDMap[doc.billID]:'';
  821. doc.billsItemID&&billIDMap[doc.billsItemID]?doc.billsItemID = billIDMap[doc.billsItemID]:'';
  822. doc.projectGLJID&&projectGLJIDMap[doc.projectGLJID]?doc.projectGLJID = projectGLJIDMap[doc.projectGLJID]:'';
  823. if(doc.templateList && doc.templateList.length > 0 ){
  824. for(let t of doc.templateList){
  825. if(t.billID && billIDMap[t.billID]) t.billID = billIDMap[t.billID];
  826. if(t.fxID && billIDMap[t.fxID]) t.fxID = billIDMap[t.fxID];
  827. }
  828. }
  829. return doc;
  830. }
  831. async function moveProject(data) {
  832. data = JSON.parse(data);
  833. let projectMap = data.projectMap,feeRateMap = data.feeRateMap,unitPriceMap = data.unitPriceMap;
  834. let projectTasks = [],feeRateTask=[],feeRateFileTask=[],unitPriceTask=[],unitPriceFileTask=[],mixRatioTask=[];
  835. let feeUniqMap=[],priceUniqMap={};//费率、单价文件唯一映射表当移动多个项目时,任务有可能出现重复的情况
  836. if(!_.isEmpty(feeRateMap)&&data.rootProjectID){//如果费率有修改
  837. let feeRates =await feeRate_facade.getFeeRatesByProject(data.rootProjectID);//取目标建设项目的所有费率文件,重名检查
  838. for(let projectID in feeRateMap){
  839. let rename = feeRateMap[projectID].name;
  840. let feeRateID = feeRateMap[projectID].query.ID;
  841. let checkFee = _.find(feeRates,{'name':rename});
  842. let newID = feeRateID;
  843. if(checkFee){//说明费率名字已存在,需要重命名
  844. rename = feeUniqMap[feeRateID]?feeUniqMap[feeRateID].name:rename + '(' + new Date().Format('MM-dd hh:mm:ss') + '移动)';
  845. projectMap[projectID]['update']['property.feeFile.name'] = rename;
  846. if(feeRateMap[projectID].action == 'move'){
  847. feeRateMap[projectID].update.name = rename;
  848. }
  849. }
  850. if(feeRateMap[projectID].action == 'copy'){
  851. newID = feeUniqMap[feeRateID]?feeUniqMap[feeRateID].ID:uuidV1();
  852. feeRateMap[projectID].name = rename;
  853. feeRateMap[projectID].ID = newID;
  854. projectMap[projectID]['update']['property.feeFile.id'] = newID;
  855. }
  856. if(!feeUniqMap[feeRateID]){
  857. await generateFeeRateTask(feeRateMap[projectID],feeRateTask,feeRateFileTask);
  858. feeUniqMap[feeRateID] = {name:rename,ID:newID};
  859. }
  860. }
  861. }
  862. if(!_.isEmpty(unitPriceMap)&&data.rootProjectID) {//如果单价文件有修改
  863. let unitPriceFiles = await unitPriceFileModel.find({root_project_id: data.rootProjectID, deleteInfo: null});
  864. for(let projectID in unitPriceMap){
  865. let checkUn = _.find(unitPriceFiles,{'name':unitPriceMap[projectID].name});
  866. let rename = unitPriceMap[projectID].name;
  867. let unitPriceID = unitPriceMap[projectID].query.id;
  868. let newID = unitPriceID;
  869. if(checkUn){//重名检查
  870. rename = priceUniqMap[unitPriceID]?priceUniqMap[unitPriceID].name:rename + '(' + new Date().Format('MM-dd hh:mm:ss') + '移动)';
  871. projectMap[projectID]['update']['property.unitPriceFile.name'] = rename;
  872. if(unitPriceMap[projectID].action =='move'){
  873. unitPriceMap[projectID].update.name = rename;
  874. }
  875. }
  876. if(unitPriceMap[projectID].action =='copy'){
  877. newID = priceUniqMap[unitPriceID]?priceUniqMap[unitPriceID].id: await getCounterID("unit_price_file");
  878. unitPriceMap[projectID].name = rename;
  879. unitPriceMap[projectID].id = newID;
  880. projectMap[projectID]['update']['property.unitPriceFile.id'] = newID;
  881. }
  882. if(!priceUniqMap[unitPriceID]){
  883. await generateUnitPriceTask(unitPriceMap[projectID],projectID,data.user_id,unitPriceTask,unitPriceFileTask,mixRatioTask);
  884. priceUniqMap[unitPriceID] = {name:rename,id:newID};
  885. }
  886. }
  887. }
  888. if(!_.isEmpty(projectMap)){
  889. for(let projectID in projectMap){
  890. projectTasks.push({updateOne:{filter : projectMap[projectID].query, update : projectMap[projectID].update}});
  891. }
  892. }
  893. projectTasks.length>0?await projectModel.bulkWrite(projectTasks):'';
  894. feeRateTask.length>0?await feeRateModel.bulkWrite(feeRateTask):'';
  895. feeRateFileTask.length>0?await feeRateFileModel.bulkWrite(feeRateFileTask):'';
  896. unitPriceFileTask.length>0?await unitPriceFileModel.bulkWrite(unitPriceFileTask):'';
  897. unitPriceTask.length>0?await insertMany(unitPriceTask,unitPriceModel):'';
  898. mixRatioTask.length>0?await insertMany(mixRatioTask,mixRatioModel):'';
  899. return projectMap;
  900. }
  901. async function generateFeeRateTask(data,feeRateTask,feeRateFileTask) {
  902. if(data.action == 'move'){
  903. let task = {
  904. updateOne:{
  905. filter : data.query,
  906. update : data.update
  907. }
  908. };
  909. feeRateFileTask.push(task);
  910. }
  911. if(data.action == 'copy'){//copy 费率的时候用insertOne方法
  912. let [feeRateFile,feeRate] =await feeRate_facade.getFeeRateByID(data.query.ID);
  913. let newFeeRateID = uuidV1();
  914. let newFeeRate = {
  915. ID:newFeeRateID,
  916. rates:feeRate.rates
  917. };
  918. let newFeeRateFile = {
  919. ID:data.ID,
  920. rootProjectID:data.rootProjectID,
  921. userID:feeRateFile.userID,
  922. name:data.name,
  923. libID:feeRateFile.libID,
  924. libName:feeRateFile.libName,
  925. feeRateID:newFeeRateID
  926. };
  927. feeRateTask.push({insertOne :{document:newFeeRate}});
  928. feeRateFileTask.push({insertOne :{document:newFeeRateFile}});
  929. }
  930. }
  931. async function generateUnitPriceTask(data,projectID,user_id,unitPriceTask,unitPriceFileTask,mixRatioTask){
  932. if(data.action == 'move'){
  933. let task = {
  934. updateOne:{
  935. filter : data.query,
  936. update : data.update
  937. }
  938. };
  939. unitPriceFileTask.push(task);
  940. }
  941. if(data.action == 'copy'){
  942. let newUnitFile = {
  943. id:data.id,
  944. name: data.name,
  945. project_id:projectID,
  946. user_id:user_id,
  947. root_project_id: data.rootProjectID
  948. };
  949. unitPriceFileTask.push({insertOne :{document:newUnitFile}});
  950. let mixRatios = await mixRatioModel.find({unit_price_file_id: data.query.id});
  951. mixRatios = JSON.stringify(mixRatios);
  952. mixRatios = JSON.parse(mixRatios);
  953. for(let m of mixRatios){
  954. delete m._id; // 删除原有id信息
  955. delete m.id;
  956. m.unit_price_file_id = data.id;
  957. m.id = await getCounterID('mix_ratio');
  958. mixRatioTask.push(m);
  959. }
  960. let unitPrices = await unitPriceModel.find({unit_price_file_id: data.query.id});//unit_price_file_id
  961. unitPrices = JSON.stringify(unitPrices);
  962. unitPrices = JSON.parse(unitPrices);
  963. for(let u of unitPrices){
  964. delete u._id; // 删除原有id信息
  965. delete u.id;
  966. u.unit_price_file_id = data.id;
  967. u.id = await getCounterID('unit_price');
  968. unitPriceTask.push(u);
  969. }
  970. }
  971. }
  972. async function getCounterID(collectionName){
  973. let counterModel = new CounterModel();
  974. return await counterModel.getId(collectionName);
  975. }
  976. async function insertMany(datas,model) {
  977. /* while (datas.length>1000){//因为mongoose限制了批量插入的条数为1000.所以超出限制后需要分批插入 2020-05-28 测试后发现没有限制,暂时先保留代码
  978. let newList = datas.splice(0,1000);//一次插入1000条
  979. await model.insertMany(newList);
  980. } */
  981. await model.insertMany(datas);
  982. }
  983. function setProperty(Obj,updateData) {
  984. for(let ukey in updateData){
  985. if(_.isObject(updateData[ukey]) && _.isObject(Obj[ukey])){
  986. setProperty(Obj[ukey],updateData[ukey]);
  987. }else {
  988. Obj[ukey] = updateData[ukey];
  989. }
  990. }
  991. }
  992. function isDef(v){
  993. return typeof v !== 'undefined' && v !== null;
  994. }
  995. function getTotalFee(bills, feeName) {
  996. if(!isDef(bills)){
  997. return 0;
  998. }
  999. if(!isDef(bills.fees) || bills.fees.length <= 0){
  1000. return 0;
  1001. }
  1002. for(let fee of bills.fees){
  1003. if(isDef(fee.fieldName) && fee.fieldName === feeName){
  1004. return isDef(fee.tenderTotalFee)
  1005. ? fee.tenderTotalFee
  1006. : isDef(fee.totalFee)
  1007. ? fee.totalFee
  1008. : 0;
  1009. }
  1010. }
  1011. return 0;
  1012. }
  1013. function summarizeToParent(parent, child, fields = null) {
  1014. const decimal = -2;
  1015. if (!fields) {
  1016. fields = ['engineeringCost', 'subEngineering', 'measure', 'safetyConstruction', 'other', 'charge', 'tax', 'estimate'];
  1017. }
  1018. for (let field of fields) {
  1019. parent[field] = scMathUtil.roundTo(parseFloat(parent[field]) + parseFloat(child[field]), decimal);
  1020. }
  1021. }
  1022. function getBuildingArea(projFeature){
  1023. if(!projFeature || projFeature.length === 0){
  1024. return null;
  1025. }
  1026. for(let f of projFeature){
  1027. if(f.key === 'buildingArea'){
  1028. return f.value;
  1029. }
  1030. }
  1031. return null;
  1032. }
  1033. //根据单位工程ID获取经济指标信息
  1034. //@param {Number}prj_id @return {Object}
  1035. async function getIndexReportData(prj_id, filters) {
  1036. return await project_facade.getIndexReportData(prj_id, filters);
  1037. }
  1038. // 根据树结构数据排序
  1039. function getSortedDataByTree(data) {
  1040. // NextSiblingID-数据映射
  1041. const mapping = {};
  1042. data.forEach(item => {
  1043. // 错误数据兼容处理
  1044. // 由于之前的导入建设项目,会导致最后的一个项目的NextSiblingID为空,为非正确的-1
  1045. // 因此把项目中NextSibling为空的数据设置为NextSiblingID为-1
  1046. if (!item.NextSiblingID) {
  1047. item.NextSiblingID = -1;
  1048. }
  1049. mapping[item.NextSiblingID] = item;
  1050. });
  1051. let lastItem = data.find(item => +item.NextSiblingID === -1);
  1052. if (!lastItem) {
  1053. return data;
  1054. }
  1055. const rst = [lastItem];
  1056. let preItem = mapping[lastItem.ID];
  1057. while (preItem) {
  1058. rst.unshift(preItem);
  1059. preItem = mapping[preItem.ID];
  1060. }
  1061. // 根据树结构排序形成的新数组与旧数组项数不同,说明树结构数据有问题(断链),则返回原本数据。
  1062. return rst.length === data.length ? rst : data;
  1063. }
  1064. //根据单位工程ID获取汇总信息
  1065. //@param {Number}tenderID {String}summaryType @return {Object}
  1066. async function getSummaryInfoByTender(tenderID, summaryType) {
  1067. const notDeleted = [{deleteInfo: null}, {'deleteInfo.deleted': false}];
  1068. let tender = await projectModel.findOne({ID: tenderID, $or: notDeleted});
  1069. let parent,
  1070. parentName,
  1071. compilationIllustration;
  1072. let summaryList = [];
  1073. if(!tender){
  1074. return null;
  1075. }
  1076. let engineering = await projectModel.findOne({ID: tender.ParentID, $or: notDeleted});
  1077. if(!engineering){
  1078. return null;
  1079. }
  1080. let project = await projectModel.findOne({ID: engineering.ParentID, $or: notDeleted});
  1081. if(!project){
  1082. return null;
  1083. }
  1084. let summaryInfo = await getSummaryInfo([project.ID]);
  1085. if(summaryType === projectType.engineering){ // 汇总到单项工程级别
  1086. parent = engineering;
  1087. let tenders = await projectModel.find({ParentID: engineering.ID, $or: notDeleted}).lean();
  1088. tenders = getSortedDataByTree(tenders);
  1089. for(let t of tenders){
  1090. if(summaryInfo[t.ID]){
  1091. summaryInfo[t.ID]['name'] = t.name ? t.name : '';
  1092. summaryList.push(summaryInfo[t.ID]);
  1093. }
  1094. }
  1095. } else { // 汇总到建设项目级别
  1096. parent = project;
  1097. let engs = await projectModel.find({ParentID: project.ID, $or: notDeleted}).lean();
  1098. engs = getSortedDataByTree(engs);
  1099. for(let e of engs){
  1100. if(summaryInfo[e.ID]){
  1101. summaryInfo[e.ID]['name'] = e.name ? e.name : '';
  1102. summaryList.push(summaryInfo[e.ID]);
  1103. }
  1104. }
  1105. }
  1106. // 项目名称
  1107. parentName = parent && parent.name
  1108. ? parent.name
  1109. : '';
  1110. // 编制说明
  1111. compilationIllustration = parent && parent.property && parent.property.compilationIllustration
  1112. ? parent.property.compilationIllustration
  1113. : '';
  1114. return {
  1115. parent: {
  1116. name: parentName,
  1117. compilationIllustration: compilationIllustration},
  1118. subList: summaryList
  1119. };
  1120. }
  1121. //获取单位工程的各标段费用信息(不进行汇总)
  1122. async function getTendersFeeInfo(tenders) {
  1123. let IDMapping = {};
  1124. //固定清单类别与汇总金额字段映射
  1125. let flagFieldMapping = {};
  1126. flagFieldMapping[fixedFlag.ENGINEERINGCOST] = 'engineeringCost';
  1127. flagFieldMapping[fixedFlag.SUB_ENGINERRING] = 'subEngineering';
  1128. flagFieldMapping[fixedFlag.MEASURE] = 'measure';
  1129. flagFieldMapping[fixedFlag.SAFETY_CONSTRUCTION] = 'safetyConstruction';
  1130. flagFieldMapping[fixedFlag.OTHER] = 'other';
  1131. flagFieldMapping[fixedFlag.CHARGE] = 'charge';
  1132. flagFieldMapping[fixedFlag.TAX] = 'tax';
  1133. let tenderIDs = [];
  1134. if(tenders.length > 0){
  1135. for(let tender of tenders){
  1136. tenderIDs.push(tender.ID);
  1137. IDMapping[tender.ID] = {engineeringCost: 0, subEngineering: 0, measure: 0, safetyConstruction: 0, other: 0, charge: 0, tax: 0, estimate: 0, rate: 0, buildingArea: '', perCost: ''};
  1138. IDMapping[tender.ID]['buildingArea'] = '';
  1139. }
  1140. //需要获取的清单固定类别综合合价:工程造价、分部分项、措施项目、安全文明施工专项、规费、其他项目、税金
  1141. let needFlags = [fixedFlag.ENGINEERINGCOST, fixedFlag.SUB_ENGINERRING, fixedFlag.MEASURE,
  1142. fixedFlag.SAFETY_CONSTRUCTION, fixedFlag.CHARGE, fixedFlag.OTHER, fixedFlag.TAX];
  1143. //获取单位工程汇总金额需要用到的所有清单
  1144. let allBills = await billsModel.find({projectID: {$in: tenderIDs}, 'flags.flag': {$in: needFlags}, $or: notDeleted},
  1145. '-_id projectID fees flags');
  1146. //进行单位工程级别的汇总
  1147. for(let bills of allBills){
  1148. let billsFlag = bills.flags[0]['flag'];
  1149. let costField = flagFieldMapping[billsFlag];
  1150. IDMapping[bills.projectID][costField] = getTotalFee(bills, 'common');
  1151. //暂估合价(工程造价暂估合价)
  1152. if (billsFlag === fixedFlag.ENGINEERINGCOST){
  1153. IDMapping[bills.projectID]['estimate'] = getTotalFee(bills, 'estimate');
  1154. }
  1155. }
  1156. //占造价比例、单方造价
  1157. for(let tender of tenders){
  1158. let tenderInfo = IDMapping[tender.ID];
  1159. tenderInfo.rate = '';
  1160. //单方造价
  1161. tenderInfo.perCost = '';
  1162. }
  1163. }
  1164. return IDMapping;
  1165. }
  1166. const defaultSummaryField = {
  1167. [fixedFlag.ENGINEERINGCOST]: {
  1168. items: [
  1169. { name: 'engineeringCost', feeName: 'common' },
  1170. { name: 'estimate', feeName: 'estimate' }
  1171. ]
  1172. },
  1173. [fixedFlag.SUB_ENGINERRING]: {
  1174. items: [{ name: 'subEngineering', feeName: 'common' }]
  1175. },
  1176. [fixedFlag.MEASURE]: {
  1177. items: [{ name: 'measure', feeName: 'common' }]
  1178. },
  1179. [fixedFlag.SAFETY_CONSTRUCTION]: {
  1180. items: [{ name: 'safetyConstruction', feeName: 'common' }]
  1181. },
  1182. [fixedFlag.OTHER]: {
  1183. items: [{ name: 'other', feeName: 'common' }]
  1184. },
  1185. [fixedFlag.CHARGE]: {
  1186. items: [{ name: 'charge', feeName: 'common' }]
  1187. },
  1188. [fixedFlag.TAX]: {
  1189. items: [{ name: 'tax', feeName: 'common' }]
  1190. }
  1191. };
  1192. // 项目管理界面需要显示的汇总字段
  1193. function setupSummaryFields(summaryInfo, projects, fields = null) {
  1194. if (!fields) {
  1195. fields = [
  1196. 'engineeringCost',
  1197. 'subEngineering',
  1198. 'measure',
  1199. 'safetyConstruction',
  1200. 'other',
  1201. 'charge',
  1202. 'tax',
  1203. 'rate',
  1204. 'buildingArea',
  1205. 'perCost'
  1206. ];
  1207. }
  1208. for(const proj of projects){
  1209. const summaryProj = summaryInfo[proj.ID];
  1210. if(summaryProj){
  1211. for (const field of fields) {
  1212. proj[field] = summaryProj[field];
  1213. }
  1214. }
  1215. }
  1216. }
  1217. async function getSummaryInfo(projectIDs, summaryField = defaultSummaryField){
  1218. function initFees(target, summaryField) {
  1219. for (const flag in summaryField) {
  1220. const summaryItem = summaryField[flag];
  1221. summaryItem.items.forEach(item => {
  1222. target[item.name] = 0;
  1223. });
  1224. }
  1225. }
  1226. //ID与汇总信息映射
  1227. let IDMapping = {};
  1228. let projects = await projectModel.find({ID: {$in : projectIDs}, projType: projectType.project, $or: [{deleteInfo: null}, {'deleteInfo.deleted': false}]});
  1229. //设置建设项目的总建筑面积
  1230. for(let project of projects){
  1231. let grossArea = '';
  1232. if(project.property && project.property.basicInformation){
  1233. for(let basicInfo of project.property.basicInformation){
  1234. if(basicInfo.key === 'basicInfo'){
  1235. for(let k of basicInfo.items){
  1236. if(k.key === 'grossArea'){
  1237. grossArea = k.value;
  1238. }
  1239. }
  1240. }
  1241. }
  1242. }
  1243. IDMapping[project.ID] = {rate: 0, buildingArea: grossArea, perCost: ''};
  1244. initFees(IDMapping[project.ID], summaryField);
  1245. }
  1246. //单项工程
  1247. let engineerings = await projectModel.find({ParentID: {$in : projectIDs}, projType: projectType.engineering, $or: [{deleteInfo: null}, {'deleteInfo.deleted': false}]});
  1248. let tenders = [];
  1249. let engIDs = [];
  1250. for(let eng of engineerings){
  1251. engIDs.push(eng.ID);
  1252. IDMapping[eng.ID] = {rate: 0, buildingArea: '', perCost: ''};
  1253. initFees(IDMapping[eng.ID], summaryField);
  1254. }
  1255. //单位工程
  1256. if(engIDs.length > 0){
  1257. tenders = await projectModel.find({ParentID: {$in : engIDs}, projType: projectType.tender, $or: [{deleteInfo: null}, {'deleteInfo.deleted': false}]});
  1258. }
  1259. let tenderIDs = [];
  1260. if(tenders.length > 0){
  1261. for(let tender of tenders){
  1262. tenderIDs.push(tender.ID);
  1263. IDMapping[tender.ID] = {rate: 0, buildingArea: '', perCost: '', changeMark:tender.changeMark,property:tender.property};
  1264. initFees(IDMapping[tender.ID], summaryField);
  1265. let buildingArea = getBuildingArea(tender.property.projectFeature);
  1266. if(buildingArea){
  1267. IDMapping[tender.ID]['buildingArea'] = buildingArea;
  1268. }
  1269. }
  1270. //需要获取的清单固定类别综合合价:工程造价、分部分项、措施项目、安全文明施工专项、规费、其他项目、税金...
  1271. let needFlags = Object.getOwnPropertyNames(summaryField);
  1272. //获取单位工程汇总金额需要用到的所有清单
  1273. let allBills = await billsModel.find({projectID: {$in: tenderIDs}, 'flags.flag': {$in: needFlags}, $or: [{deleteInfo: null}, {'deleteInfo.deleted': false}]},
  1274. '-_id projectID fees flags');
  1275. //进行单位工程级别的汇总
  1276. for(let bills of allBills){
  1277. let billsFlag = bills.flags[0]['flag'];
  1278. // 设置上单位工程需要汇总的字段金额
  1279. const summaryItem = summaryField[billsFlag];
  1280. summaryItem.items.forEach(costItem => {
  1281. IDMapping[bills.projectID][costItem.name] = getTotalFee(bills, costItem.feeName);
  1282. });
  1283. }
  1284. const summaryNames = [];
  1285. for (const flag in summaryField) {
  1286. summaryField[flag].items.forEach(item => summaryNames.push(item.name));
  1287. }
  1288. //进行单项工程级别的汇总
  1289. for(let tender of tenders){
  1290. summarizeToParent(IDMapping[tender.ParentID], IDMapping[tender.ID], summaryNames);
  1291. }
  1292. //进行建设项目级别的汇总
  1293. for(let eng of engineerings){
  1294. summarizeToParent(IDMapping[eng.ParentID], IDMapping[eng.ID], summaryNames);
  1295. }
  1296. //占造价比例、单方造价
  1297. const rateDecimal = -2;
  1298. const perCostDecimal = -2;
  1299. for(let tender of tenders){
  1300. let tenderInfo = IDMapping[tender.ID];
  1301. let engInfo = IDMapping[tender.ParentID];
  1302. tenderInfo.rate = engInfo.engineeringCost == 0 ? 0 : scMathUtil.roundTo(tenderInfo.engineeringCost * 100 / engInfo.engineeringCost, rateDecimal);
  1303. //单方造价
  1304. tenderInfo.perCost = tenderInfo.buildingArea.toString().trim() === '' || tenderInfo.buildingArea == 0
  1305. ? tenderInfo.buildingArea.toString().trim()
  1306. : scMathUtil.roundTo(tenderInfo.engineeringCost / tenderInfo.buildingArea, perCostDecimal);
  1307. }
  1308. for(let eng of engineerings){
  1309. let engInfo = IDMapping[eng.ID];
  1310. let projInfo = IDMapping[eng.ParentID];
  1311. engInfo.rate = !isDef(projInfo) || projInfo.engineeringCost == 0 ? 0 : scMathUtil.roundTo(engInfo.engineeringCost * 100 / projInfo.engineeringCost, rateDecimal);
  1312. }
  1313. //建设项目占造价比例及单方造价
  1314. for(let project of projects){
  1315. let projectInfo = IDMapping[project.ID];
  1316. projectInfo.rate = 100;
  1317. projectInfo.perCost = projectInfo.buildingArea.toString().trim() === '' || projectInfo.buildingArea == 0
  1318. ? projectInfo.buildingArea.toString().trim()
  1319. : scMathUtil.roundTo(projectInfo.engineeringCost / projectInfo.buildingArea, perCostDecimal);
  1320. }
  1321. }
  1322. return IDMapping;
  1323. }
  1324. /* async function getSummaryInfo(projectIDs, feeFields = null, engineeringCostFields = null){
  1325. function initFees(obj, feeFields, engineeringCostFields) {
  1326. for (let data of feeFields) {
  1327. obj[data.v] = 0;
  1328. }
  1329. for (let data of engineeringCostFields) {
  1330. obj[data.k] = 0;
  1331. }
  1332. }
  1333. if (!feeFields) {
  1334. feeFields = [
  1335. {k: fixedFlag.ENGINEERINGCOST, v: 'engineeringCost'},
  1336. {k: fixedFlag.SUB_ENGINERRING, v: 'subEngineering'},
  1337. {k: fixedFlag.MEASURE, v: 'measure'},
  1338. {k: fixedFlag.SAFETY_CONSTRUCTION, v: 'safetyConstruction'},
  1339. {k: fixedFlag.OTHER, v: 'other'},
  1340. {k: fixedFlag.CHARGE, v: 'charge'},
  1341. {k: fixedFlag.TAX, v: 'tax'}
  1342. ];
  1343. }
  1344. // 项目总造价的各个费用,k为汇总的字段,v为工程造价的费用字段
  1345. if (!engineeringCostFields) {
  1346. engineeringCostFields = [{ k: 'estimate', v: 'estimate' }];
  1347. }
  1348. //ID与汇总信息映射
  1349. let IDMapping = {};
  1350. //固定清单类别与汇总金额字段映射
  1351. let flagFieldMapping = {};
  1352. for (let data of feeFields) {
  1353. flagFieldMapping[data.k] = data.v;
  1354. }
  1355. let projects = await projectModel.find({ID: {$in : projectIDs}, projType: projectType.project, $or: [{deleteInfo: null}, {'deleteInfo.deleted': false}]});
  1356. //设置建设项目的总建筑面积
  1357. for(let project of projects){
  1358. let grossArea = '';
  1359. if(project.property && project.property.basicInformation){
  1360. for(let basicInfo of project.property.basicInformation){
  1361. if(basicInfo.key === 'basicInfo'){
  1362. for(let k of basicInfo.items){
  1363. if(k.key === 'grossArea'){
  1364. grossArea = k.value;
  1365. }
  1366. }
  1367. }
  1368. }
  1369. }
  1370. IDMapping[project.ID] = {rate: 0, buildingArea: grossArea, perCost: ''};
  1371. initFees(IDMapping[project.ID], feeFields, engineeringCostFields);
  1372. console.log(IDMapping[project.ID]);
  1373. }
  1374. //单项工程
  1375. let engineerings = await projectModel.find({ParentID: {$in : projectIDs}, projType: projectType.engineering, $or: [{deleteInfo: null}, {'deleteInfo.deleted': false}]});
  1376. let tenders = [];
  1377. let engIDs = [];
  1378. for(let eng of engineerings){
  1379. engIDs.push(eng.ID);
  1380. IDMapping[eng.ID] = {rate: 0, buildingArea: '', perCost: ''};
  1381. initFees(IDMapping[eng.ID], feeFields, engineeringCostFields);
  1382. }
  1383. //单位工程
  1384. if(engIDs.length > 0){
  1385. tenders = await projectModel.find({ParentID: {$in : engIDs}, projType: projectType.tender, $or: [{deleteInfo: null}, {'deleteInfo.deleted': false}]});
  1386. }
  1387. let tenderIDs = [];
  1388. if(tenders.length > 0){
  1389. for(let tender of tenders){
  1390. tenderIDs.push(tender.ID);
  1391. IDMapping[tender.ID] = {rate: 0, buildingArea: '', perCost: '', changeMark:tender.changeMark,property:tender.property};
  1392. initFees(IDMapping[tender.ID], feeFields, engineeringCostFields);
  1393. let buildingArea = getBuildingArea(tender.property.projectFeature);
  1394. if(buildingArea){
  1395. IDMapping[tender.ID]['buildingArea'] = buildingArea;
  1396. }
  1397. }
  1398. //需要获取的清单固定类别综合合价:工程造价、分部分项、措施项目、安全文明施工专项、规费、其他项目、税金...
  1399. let needFlags = feeFields.map(data => data.k);
  1400. //获取单位工程汇总金额需要用到的所有清单
  1401. let allBills = await billsModel.find({projectID: {$in: tenderIDs}, 'flags.flag': {$in: needFlags}, $or: [{deleteInfo: null}, {'deleteInfo.deleted': false}]},
  1402. '-_id projectID fees flags');
  1403. //进行单位工程级别的汇总
  1404. for(let bills of allBills){
  1405. let billsFlag = bills.flags[0]['flag'];
  1406. let costField = flagFieldMapping[billsFlag];
  1407. IDMapping[bills.projectID][costField] = getTotalFee(bills, 'common');
  1408. // 工程造价各费用
  1409. if (billsFlag === fixedFlag.ENGINEERINGCOST){
  1410. engineeringCostFields.forEach(({k, v}) => {
  1411. IDMapping[bills.projectID][k] = getTotalFee(bills, v);
  1412. });
  1413. }
  1414. }
  1415. let summaryFields = [...feeFields, ...engineeringCostFields].map(data => data.v);
  1416. //进行单项工程级别的汇总
  1417. for(let tender of tenders){
  1418. summarizeToParent(IDMapping[tender.ParentID], IDMapping[tender.ID], summaryFields);
  1419. }
  1420. //进行建设项目级别的汇总
  1421. for(let eng of engineerings){
  1422. summarizeToParent(IDMapping[eng.ParentID], IDMapping[eng.ID], summaryFields);
  1423. }
  1424. //占造价比例、单方造价
  1425. const rateDecimal = -2;
  1426. const perCostDecimal = -2;
  1427. for(let tender of tenders){
  1428. let tenderInfo = IDMapping[tender.ID];
  1429. let engInfo = IDMapping[tender.ParentID];
  1430. tenderInfo.rate = engInfo.engineeringCost == 0 ? 0 : scMathUtil.roundTo(tenderInfo.engineeringCost * 100 / engInfo.engineeringCost, rateDecimal);
  1431. //单方造价
  1432. tenderInfo.perCost = tenderInfo.buildingArea.toString().trim() === '' || tenderInfo.buildingArea == 0
  1433. ? tenderInfo.buildingArea.toString().trim()
  1434. : scMathUtil.roundTo(tenderInfo.engineeringCost / tenderInfo.buildingArea, perCostDecimal);
  1435. }
  1436. for(let eng of engineerings){
  1437. let engInfo = IDMapping[eng.ID];
  1438. let projInfo = IDMapping[eng.ParentID];
  1439. engInfo.rate = !isDef(projInfo) || projInfo.engineeringCost == 0 ? 0 : scMathUtil.roundTo(engInfo.engineeringCost * 100 / projInfo.engineeringCost, rateDecimal);
  1440. }
  1441. //建设项目占造价比例及单方造价
  1442. for(let project of projects){
  1443. let projectInfo = IDMapping[project.ID];
  1444. projectInfo.rate = 100;
  1445. projectInfo.perCost = projectInfo.buildingArea.toString().trim() === '' || projectInfo.buildingArea == 0
  1446. ? projectInfo.buildingArea.toString().trim()
  1447. : scMathUtil.roundTo(projectInfo.engineeringCost / projectInfo.buildingArea, perCostDecimal);
  1448. }
  1449. }
  1450. return IDMapping;
  1451. } */
  1452. //根据项目ID获取所属建设项目
  1453. //@param {Number}projectID @return {Object}
  1454. async function getConstructionProject(projectID){
  1455. function returnProject(project){
  1456. if(!project || project.projType === projectType.folder){
  1457. return null;
  1458. }
  1459. if(project.projType === projectType.project){
  1460. return project;
  1461. }
  1462. }
  1463. let project = await projectModel.findOne({ID: projectID, $or: notDeleted});
  1464. let returnV = returnProject(project);
  1465. if(returnV !== undefined){
  1466. return returnV;
  1467. }
  1468. let parent = await projectModel.findOne({ID: project.ParentID, $or: notDeleted});
  1469. returnV = returnProject(parent);
  1470. if(returnV !== undefined){
  1471. return returnV;
  1472. }
  1473. let grandParent = await projectModel.findOne({ID: parent.ParentID, $or: notDeleted});
  1474. returnV = returnProject(grandParent);
  1475. return returnV !== undefined ? returnV : null;
  1476. }
  1477. //获取单位工程完整目录结构
  1478. //@param {Number}projectID @return {Arry}
  1479. async function getFullPath(projectID) {
  1480. let fullPath = [];
  1481. let project = await projectModel.findOne({ID: projectID, $or: notDeleted}, '-_id ParentID name');
  1482. if(project){
  1483. fullPath.push(project.name);
  1484. await getParent(project.ParentID);
  1485. }
  1486. fullPath = fullPath.reverse();
  1487. return fullPath;
  1488. async function getParent(ParentID) {
  1489. if(ParentID != -1){
  1490. let parent = await projectModel.findOne({ID: ParentID, $or: notDeleted}, '-_id ParentID name');
  1491. if(parent){
  1492. fullPath.push(parent.name);
  1493. await getParent(parent.ParentID);
  1494. }
  1495. }
  1496. }
  1497. }
  1498. // 获取项目链上,自身、父项、爷爷项...的ID
  1499. async function getUpChainIDs(projectID) {
  1500. const rst = [];
  1501. while (projectID != -1) {
  1502. rst.push(projectID);
  1503. const project = await projectModel.findOne({ ID: projectID }, '-_id ParentID').lean();
  1504. projectID = project ? project.ParentID : -1;
  1505. }
  1506. return rst;
  1507. }
  1508. //获取projectIDs文件下所有子项目(默认不包括projectIDs本身)
  1509. async function getPosterityProjects(projectIDs, includeSelf = false, fields = '-_id') {
  1510. let rst = [];
  1511. if (includeSelf) {
  1512. const projects = await projectModel.find({ID: {$in: projectIDs}, $or: notDeleted}, fields).lean();
  1513. if (projects) {
  1514. rst.push(...projects);
  1515. }
  1516. }
  1517. async function getProjects(parentIDs) {
  1518. if (parentIDs.length > 0) {
  1519. let newIDs = [];
  1520. let projs = await projectModel.find({ParentID: {$in: parentIDs}, $or: notDeleted}, fields).lean();
  1521. for (let proj of projs) {
  1522. // 兼容旧的错误数据,可能ParentID和ID相同
  1523. if (parentIDs.includes(proj.ID)) {
  1524. continue;
  1525. }
  1526. rst.push(proj);
  1527. newIDs.push(proj.ID);
  1528. }
  1529. await getProjects(newIDs);
  1530. }
  1531. }
  1532. await getProjects(projectIDs);
  1533. return rst;
  1534. }
  1535. //根据项目获得分享信息(分享层级不一定在项目级)(以最新为准)
  1536. async function getShareInfo(userID, projectID) {
  1537. // 接受到的分享项目
  1538. const upChainIDs = await getUpChainIDs(projectID);
  1539. const shareList = await getShareList({receiver: userID, projectID: {$in: upChainIDs}});
  1540. // 返回最新的分享
  1541. //return shareList.sort((a, b) => Date.parse(b.shareDate) - Date.parse(a.shareDate))[0];
  1542. return shareList.sort((a, b) => Date.parse(b.updateDate) - Date.parse(a.updateDate))[0];
  1543. }
  1544. //打开的单位工程是否是被分享的.
  1545. async function isShare(userId, project){
  1546. //判断是否是打开分享的项目,属于分享文件的子项也算
  1547. while (project) {
  1548. for(let shareData of project.shareInfo){
  1549. if(shareData.userID === userId){
  1550. return true;
  1551. }
  1552. }
  1553. project = await projectModel.findOne({ID: project.ParentID}, '-_id shareInfo ID ParentID');
  1554. }
  1555. return false;
  1556. }
  1557. //用户是否第一次进入费用定额
  1558. async function isFirst(userId, compilationId) {
  1559. let userData = await userModel.findOne({_id: mongoose.Types.ObjectId(userId)}, '-_id used_list');
  1560. let first = false;
  1561. if (userData) {
  1562. first = !_.find(userData.used_list, function (o) {
  1563. return o.compilationId === compilationId;
  1564. });;
  1565. }
  1566. return first;
  1567. }
  1568. async function copyConstructionProject(data){
  1569. let log_data = {
  1570. key:data.key,
  1571. content: '正在复制建设项目,请稍候……',
  1572. userID:data.user_id,
  1573. compilationID: data.session.sessionCompilation._id,
  1574. status:"start",
  1575. create_time:+new Date()
  1576. };
  1577. await importLogsModel.create(log_data);
  1578. doCopy(data.user_id,data.session.sessionCompilation._id,data.projectID,data.newName,data.key);
  1579. return "start copy";
  1580. async function doCopy(user_id,compilationId,projectID,newName,key) {
  1581. let doc = {status:"finish"};
  1582. try {
  1583. let nameMap={};
  1584. nameMap[projectID] = newName
  1585. let r = await copyExample(user_id,compilationId,[projectID],nameMap);
  1586. if(r == false){
  1587. doc.errorMsg = "复制失败,请检查项目是否存在!";
  1588. doc.status = "error";
  1589. }
  1590. }catch (error){
  1591. console.log(error);
  1592. doc.errorMsg = "复制失败,请检查项目是否存在!";
  1593. doc.status = "error";
  1594. }finally {
  1595. await importLogsModel.update({key:key},doc);
  1596. }
  1597. }
  1598. }
  1599. async function importChongqingProject(data) {
  1600. let log_data = {
  1601. key:data.key,
  1602. content: '正在导入例题,请稍候……',
  1603. userID:data.user_id,
  1604. compilationID: data.session.sessionCompilation._id,
  1605. status:"start",
  1606. create_time:+new Date()
  1607. };
  1608. await importLogsModel.create(log_data);
  1609. doImport(data.user_id,data.session.sessionCompilation._id,data.session.sessionCompilation.adProjects,data.key);
  1610. return "start importing";
  1611. async function doImport(user_id,compilationId,projectIDs,key) {
  1612. let doc = {status:"finish"};
  1613. try {
  1614. let r = await copyExample(user_id,compilationId,projectIDs);
  1615. if(r == false){
  1616. doc.errorMsg = "导入失败,请检查项目是否存在!";
  1617. doc.status = "error";
  1618. } else {
  1619. doc.projectID = r;
  1620. }
  1621. }catch (error){
  1622. console.log(error);
  1623. doc.errorMsg = "导入失败,请检查项目是否存在!";
  1624. doc.status = "error";
  1625. }finally {
  1626. await importLogsModel.update({key:key},doc);
  1627. }
  1628. }
  1629. }
  1630. function testTimeout(time) {
  1631. return new Promise(resolve => setTimeout(resolve, time));
  1632. }
  1633. //用户第一次进入费用定额的数据准备
  1634. async function prepareInitialData(userId, compilation, example) {
  1635. let first = await isFirst(userId, compilation);
  1636. if (first) {
  1637. await updateUsedList(userId, compilation);
  1638. const logData = {
  1639. key: uuidV1(),
  1640. content: '正在加载例题,请稍候……',
  1641. userID: userId,
  1642. compilationID: compilation,
  1643. status: 'start',
  1644. create_time: +new Date()
  1645. };
  1646. await importLogsModel.create(logData);
  1647. initData(logData.key, userId, compilation, example);
  1648. return 'start prepareInitialData';
  1649. }
  1650. async function initData(key, userId, compilation, example) {
  1651. const doc = { status: 'finish' };
  1652. try {
  1653. let prepareTask = [
  1654. copyCompleRationSection(userId, compilation),
  1655. copyCompleGljSection(userId, compilation)
  1656. ];
  1657. if (example && example.length > 0) {
  1658. prepareTask.push(copyExample(userId, compilation, example));
  1659. }
  1660. await Promise.all(prepareTask);
  1661. } catch (error) {
  1662. doc.errorMsg = '加载例题失败,请检查例题项目是否存在!';
  1663. doc.status = 'error';
  1664. } finally {
  1665. await importLogsModel.update({ key }, doc);
  1666. }
  1667. }
  1668. }
  1669. async function updateUsedList(userId, compilation) {
  1670. await userModel.update({_id: mongoose.Types.ObjectId(userId)}, {$push: {used_list: {compilationId: compilation}}});
  1671. }
  1672. //拷贝补充定额章节树
  1673. async function copyCompleRationSection(userId, compilationId) {
  1674. await sectionTreeDao.copyDataFromTemplate(userId, compilationId);
  1675. }
  1676. //拷贝补充人材机分类树
  1677. async function copyCompleGljSection(userId, compilationId) {
  1678. // 如果已有数据则不再生成
  1679. const count = await compleGljSectionModel.count({userId, compilationId});
  1680. if (count) {
  1681. return;
  1682. }
  1683. let templateData = await compleGljSectionTModel.find({compilationId: compilationId});
  1684. if (templateData.length > 0) {
  1685. let insertDatas = [],
  1686. uuidMapping = {};
  1687. //将ID替换成UUID
  1688. for (let temData of templateData) {
  1689. uuidMapping[temData.ID] = uuidV1();
  1690. }
  1691. for(let temData of templateData) {
  1692. let insertD = {
  1693. userId: userId,
  1694. compilationId: compilationId,
  1695. Name: temData.Name,
  1696. ID: uuidMapping[temData.ID],
  1697. ParentID: uuidMapping[temData.ParentID] || -1,
  1698. NextSiblingID: uuidMapping[temData.NextSiblingID] || -1,
  1699. };
  1700. insertDatas.push(insertD);
  1701. }
  1702. //插入数据
  1703. await compleGljSectionModel.insertMany(insertDatas);
  1704. }
  1705. }
  1706. async function changeFile(datas,userID,fileID,name,from,type){//from 费率或单价文件,type从单前建设项目还是从其它建设项目中复制
  1707. let projectIDs = [],newFile = {id:fileID,name:name};//计录从其它项目中复制的文件,选中多个的时候只需复制一次
  1708. let projectUpdateType = from == "feeRateFile"?"feeRate":"unitFile";
  1709. for(let d of datas){
  1710. let tem_file = from == "feeRateFile"? await feeRate_facade.changeFeeRateFile(d, newFile,type,userID):await glj_facade.changeUnitFile(d, newFile,type,userID);
  1711. if(type == 1 && tem_file){//从建设项目复制时,只有第一次需要复制,剩下的就相当于使用同个建设项目的情况了
  1712. let newID = from == "feeRateFile"?tem_file.ID:tem_file.id;
  1713. newFile = {id:newID,name:tem_file.name};
  1714. type = 0;
  1715. }
  1716. projectIDs.push({ID:d.projectID})
  1717. }
  1718. await project_facade.markProjectsToChange(projectIDs,projectUpdateType)//项目标记为待刷新状态
  1719. }
  1720. //获取费用定额绑定的基本信息库数据
  1721. async function getBasicInfo(compilationID, fileKind = null) {
  1722. let compilation = await compilationModel.findOne({_id: mongoose.Types.ObjectId(compilationID)});
  1723. if (!compilation) {
  1724. return null;
  1725. }
  1726. let billValuation = compilation.bill_valuation.find(function (data) {
  1727. return data.enable;
  1728. });
  1729. if (!billValuation) {
  1730. return null;
  1731. }
  1732. let engineerings = await engineeringModel.find({valuationID: billValuation.id});
  1733. let engineering = engineerings.find(function (data) {
  1734. return data.info_lib && data.info_lib.length > 0;
  1735. });
  1736. if (!engineering || !engineering.info_lib || !engineering.info_lib[0]) {
  1737. return null;
  1738. }
  1739. let infoLib = await basicInfoModel.findOne({ID: engineering.info_lib[0].id});
  1740. //提取文件类型中需要的数据 (投标项目可能不需要招标的一些信息)
  1741. if (fileKind && infoLib && infoLib.info && infoLib.info.length) {
  1742. let strMap = {
  1743. 1: '投标', //投标
  1744. 2: '招标', //招标
  1745. 3: '控制价' //控制价
  1746. };
  1747. let needfulData = infoLib.info.filter(data => !data.fileKind || data.fileKind === strMap[fileKind]);
  1748. needfulData.forEach(nData => {
  1749. let needfulSub = nData.items.filter(sData => !sData.fileKind || sData.fileKind === strMap[fileKind]);
  1750. nData.items = needfulSub;
  1751. });
  1752. infoLib.info = needfulData;
  1753. }
  1754. return infoLib;
  1755. }
  1756. async function getProjectFeature(valuationID, engineeringName, feeName) {
  1757. let engineering = await engineeringModel.findOne({valuationID: valuationID, name: engineeringName, feeName: feeName});
  1758. if (!engineering || !engineering.feature_lib || !engineering.feature_lib[0]) {
  1759. return null;
  1760. }
  1761. let featureLib = await projectFeatureModel.findOne({ID: engineering.feature_lib[0].id});
  1762. return featureLib;
  1763. }
  1764. //根据单位工程,获取建设项目-单项工程-单位工程,不包含无单位工程的单项工程
  1765. //@param {Number}tenderID(单位工程ID) {Number}granularity(颗粒度 1:建设项目 2:单项工程 3:单位工程)
  1766. async function getProjectByGranularity(tenderID, granularity, summaryField, userID, versionName) {
  1767. const GRANULARITY = {
  1768. PROJECT: 1,
  1769. ENGINEERING: 2,
  1770. TENDER: 3
  1771. };
  1772. let theTender = await projectModel.findOne({userID: userID, ID: tenderID}).lean(); //加上session的userID,防止tenderID被篡改过
  1773. if (!theTender) {
  1774. return null;
  1775. }
  1776. let theEngineering = await projectModel.findOne({ID: theTender.ParentID}).lean();
  1777. if (!theEngineering) {
  1778. return null;
  1779. }
  1780. let constructionProject = await projectModel.findOne({ID: theEngineering.ParentID}).lean();
  1781. if (!constructionProject) {
  1782. return null;
  1783. }
  1784. let engineerings;
  1785. if (granularity === GRANULARITY.PROJECT) {
  1786. engineerings = await projectModel.find({ParentID: constructionProject.ID, $or: notDeleted}).lean();
  1787. for (let eng of engineerings) {
  1788. eng.children = await projectModel.find({ParentID: eng.ID, $or: notDeleted}).lean();
  1789. }
  1790. } else {
  1791. engineerings = [theEngineering];
  1792. if (granularity === GRANULARITY.ENGINEERING) {
  1793. theEngineering.children = await projectModel.find({ParentID: theEngineering.ID, $or: notDeleted}).lean();
  1794. } else {
  1795. theEngineering.children = [theTender];
  1796. }
  1797. }
  1798. constructionProject.children = engineerings;
  1799. //获取汇总信息
  1800. constructionProject.summaryInfo = await getSummaryInfo([constructionProject.ID], summaryField);
  1801. //获取编制软件信息: 软件公司;软件名;版本号;授权信息; base64
  1802. const systemSetting = await systemSettingModel.findOne({});
  1803. let company = systemSetting.company || '珠海纵横创新软件有限公司',
  1804. version = systemSetting.version || '';
  1805. constructionProject.softInfo = `${company};${versionName};${version};${userID}`;
  1806. return constructionProject;
  1807. }
  1808. //获取项目数据占位ID
  1809. async function getProjectPlaceholder(data) {
  1810. let rst = {};
  1811. //项目本身数据
  1812. if (data.projectCount) {
  1813. let projectCount = await counter.counterDAO.getIDAfterCountSync(counter.moduleName.project, data.projectCount);
  1814. rst.project = projectCount.sequence_value - data.projectCount + 1;
  1815. }
  1816. //项目人材机数据
  1817. if (data.projectGLJCount) {
  1818. let projectGLJCount = await counter.counterDAO.getIDAfterCountSync(counter.moduleName.glj_list, data.projectGLJCount);
  1819. rst.projectGLJ = projectGLJCount.sequence_value - data.projectGLJCount + 1;
  1820. }
  1821. //组成物数据
  1822. if (data.ratioCount) {
  1823. let ratioCount = await counter.counterDAO.getIDAfterCountSync(counter.moduleName.mix_ratio, data.ratioCount);
  1824. rst.ratio = ratioCount.sequence_value - data.ratioCount + 1;
  1825. }
  1826. //单价文件数据
  1827. if (data.unitPriceFileCount) {
  1828. let unitPriceFileCount = await counter.counterDAO.getIDAfterCountSync(counter.moduleName.unit_price_file, data.unitPriceFileCount);
  1829. rst.unitPriceFile = unitPriceFileCount.sequence_value - data.unitPriceFileCount + 1;
  1830. }
  1831. //单价数据
  1832. if (data.unitPriceCount) {
  1833. let unitPriceCount = await counter.counterDAO.getIDAfterCountSync(counter.moduleName.unit_price, data.unitPriceCount);
  1834. rst.unitPrice = unitPriceCount.sequence_value - data.unitPriceCount + 1;
  1835. }
  1836. return rst;
  1837. }
  1838. /*
  1839. * 接口导入 项目详细数据都导入完成了,再生成项目数据(项目管理界面数据)
  1840. * */
  1841. async function importProject(importObj, userID, compilationID, overWriteUrl) {
  1842. let toInsertProjects = [importObj]; //待新增项目数据
  1843. let billsCalcMode = 0;
  1844. if (overWriteUrl) {
  1845. const overWrite = require('../../..' + overWriteUrl);
  1846. if(overWrite.getBillsCalcMode) { // 重写清单计费取费方式
  1847. billsCalcMode = overWrite.getBillsCalcMode();
  1848. }
  1849. }
  1850. await setupProject(importObj);
  1851. //设置项目ID及相关数据
  1852. for (let curEng of importObj.engs) {
  1853. await setupProject(curEng);
  1854. toInsertProjects.push(curEng);
  1855. for (let curTender of curEng.tenders) {
  1856. await setupProject(curTender.tender);
  1857. //插入单位工程的详细数据
  1858. await importTenderDetail(curTender);
  1859. toInsertProjects.push(curTender.tender);
  1860. }
  1861. delete curEng.tenders;
  1862. }
  1863. delete importObj.engs;
  1864. //项目内部数据设置、新增完毕后,插入项目本身的数据,更新前节点数据
  1865. let bulks = [];
  1866. //如果有前节点,更新前节点
  1867. if (importObj.preID !== -1) {
  1868. bulks.push({
  1869. updateOne: {filter: {ID: importObj.preID}, update: {$set: {NextSiblingID: importObj.ID}}}
  1870. });
  1871. }
  1872. for (let insertP of toInsertProjects) {
  1873. bulks.push({
  1874. insertOne: {document: insertP}
  1875. });
  1876. }
  1877. if (bulks.length > 0) {
  1878. await projectModel.bulkWrite(bulks);
  1879. }
  1880. return importObj.ID; // 返回建设项目ID
  1881. // TODO 删除
  1882. let summaryInfo = await getSummaryInfo([importObj.ID]);
  1883. //设置汇总字段
  1884. for(let proj of toInsertProjects){
  1885. let summaryProj = summaryInfo[proj.ID];
  1886. if(summaryProj){
  1887. proj.engineeringCost = summaryProj.engineeringCost;
  1888. proj.subEngineering = summaryProj.subEngineering;
  1889. proj.measure = summaryProj.measure;
  1890. proj.safetyConstruction = summaryProj.safetyConstruction;
  1891. proj.other = summaryProj.other;
  1892. proj.charge = summaryProj.charge;
  1893. proj.tax = summaryProj.tax;
  1894. proj.rate = summaryProj.rate;
  1895. proj.buildingArea = summaryProj.buildingArea;
  1896. proj.perCost = summaryProj.perCost;
  1897. }
  1898. }
  1899. return toInsertProjects;
  1900. //给项目数据设置一些需要的数据
  1901. async function setupProject(data) {
  1902. data.userID = userID;
  1903. data.compilation = compilationID;
  1904. data.fileVer = await index.getVersion();
  1905. data.createDateTime = new Date();
  1906. if (data.projType === 'Project') {
  1907. await setupConstruct(data);
  1908. } else if (data.projType === 'Tender') {
  1909. await setupTender(data);
  1910. }
  1911. }
  1912. //给建设项目设置一些数据
  1913. async function setupConstruct(data) {
  1914. //更新基本信息, 按照key匹配
  1915. let infoLib = await getBasicInfo(data.compilation, data.property.fileKind);
  1916. if (infoLib) {
  1917. //标准基本信息库的数据打平
  1918. let flatDatas = [];
  1919. infoLib.info.forEach(ifData => flatDatas.push(...ifData.items));
  1920. data.basicInformation.forEach(importI => {
  1921. flatDatas.forEach(item => {
  1922. if (item.key === 'engineeringName') {
  1923. item.value = data.name;
  1924. } else if (item.key === 'fileKind') {
  1925. item.value = {'1': '投标', '2': '招标'}[data.property.fileKind]
  1926. } else if (item.key === 'taxModel') {
  1927. item.value = {'1': '一般计税法', '2': '简易计税法'}[data.property.taxType]
  1928. }
  1929. if (item.key === importI.key) {
  1930. item.value = importI.value;
  1931. }
  1932. });
  1933. });
  1934. }
  1935. data.property.basicInformation = infoLib ? infoLib.info : [];
  1936. }
  1937. //给单位工程设置一些数据
  1938. async function setupTender(data) {
  1939. if (!data.property.decimal) {
  1940. //小数位数 需要修改,所以深拷贝
  1941. data.property.decimal = JSON.parse(JSON.stringify(defaultDecimal));
  1942. // 定额工程量、人材机消耗量精度设为最大6
  1943. data.property.decimal.ration.quantity = 6;
  1944. data.property.decimal.glj.quantity = 6;
  1945. }
  1946. //清单工程量精度 需要修改,所以深拷贝
  1947. data.property.billsQuantityDecimal = JSON.parse(JSON.stringify(billsQuantityDecimal));
  1948. // 清单工程量精度默认为4
  1949. const billsQuantityDecimalValue = data.property.billsQuantityDecimalValue || 4;
  1950. data.property.billsQuantityDecimal.forEach(data => data.decimal = billsQuantityDecimalValue);
  1951. //呈现选项
  1952. data.property.displaySetting = displaySetting;
  1953. data.property.billsCalcMode = billsCalcMode;
  1954. data.property.zanguCalcMode = 0;
  1955. //计算选项
  1956. data.property.calcOptions = calcOptions;
  1957. //安装增加费
  1958. if(data.property.isInstall === true || data.property.isInstall === 'true'){//判断是否安装工程
  1959. await installationFacade.copyInstallationFeeFromLib(data.ID, data.property.engineering_id);
  1960. }
  1961. //锁定清单
  1962. data.property.lockBills = true;
  1963. //工料机单价调整系数
  1964. data.property.tenderSetting = tenderSetting;
  1965. //工程特征相关更新 (配对更新+追加)
  1966. let featureLib = await getProjectFeature(data.property.valuation, data.property.engineeringName, data.property.feeStandardName);
  1967. if (featureLib) {
  1968. //把导入的数据设置到默认生成的数据中,按名称匹配 (导入项不确定,因此无法确定获取项的key)
  1969. // 只匹配第一层
  1970. const unmatched = [];
  1971. data.projectFeature.forEach(importF => {
  1972. let matchData = featureLib.feature.find(f => f.dispName === importF.dispName);
  1973. if (matchData) {
  1974. matchData.value = importF.value;
  1975. if (importF.items) {
  1976. matchData.items = importF.items;
  1977. }
  1978. } else {
  1979. unmatched.push(importF);
  1980. }
  1981. });
  1982. featureLib.feature.push(...unmatched);
  1983. featureLib.feature.forEach(f => {
  1984. //设置工程专业的值为费用标准的值..
  1985. if (f.key === 'engineering') {
  1986. f.value = data.property.feeStandardName;
  1987. } else if (f.key === 'projType' && !f.value) {
  1988. const options = f.options && f.options.split('@') || [];
  1989. f.value = options[0] || '';
  1990. }
  1991. });
  1992. }
  1993. data.property.projectFeature = featureLib ? featureLib.feature : [];
  1994. // 指标信息相关设置
  1995. await project_facade.setSEILibData(data.property);
  1996. }
  1997. }
  1998. //插入单位工程内部详细数据
  1999. async function importTenderDetail(tenderData) {
  2000. //单价文件
  2001. let upFile = {
  2002. id: tenderData.tender.property.unitPriceFile.id,
  2003. name: tenderData.tender.name,
  2004. project_id: tenderData.tender.ID,
  2005. user_id: tenderData.tender.userID,
  2006. root_project_id: tenderData.tender.property.rootProjectID
  2007. };
  2008. await unitPriceFileModel.create(upFile);
  2009. //费率文件
  2010. let feeRateFileID = await feeRate_facade.newFeeRateFile(tenderData.tender.userID, tenderData.tender);
  2011. tenderData.tender.property.feeFile = feeRateFileID ? feeRateFileID : -1;
  2012. //人工系数文件
  2013. let lcFile = await labourCoeFacade.newProjectLabourCoe(tenderData.tender);
  2014. tenderData.tender.property.labourCoeFile = lcFile ? lcFile : null;
  2015. let cpFile = await calcProgramFacade.newProjectCalcProgramFile(tenderData.tender);
  2016. tenderData.tender.property.calcProgramFile = cpFile ? cpFile : null;
  2017. //列设置
  2018. let engineeringModel = new EngineeringLibModel();
  2019. let engineering = await engineeringModel.getEngineering(tenderData.tender.property.engineering_id);
  2020. let mainTreeCol = await mainColLibModel.findOne({ID: tenderData.tender.property.colLibID});
  2021. await projectSettingModel.create({projectID: tenderData.tender.ID, main_tree_col: mainTreeCol.main_tree_col, glj_col: engineering.glj_col});
  2022. //清单
  2023. if (tenderData.bills.length) {
  2024. await billsModel.insertMany(tenderData.bills);
  2025. }
  2026. // 工程量明细
  2027. if (tenderData.quantityDetails && tenderData.quantityDetails.length) {
  2028. await quantityDetailModel.insertMany(tenderData.quantityDetails);
  2029. }
  2030. if (enterDetail(tenderData)) {
  2031. //匹配标准数据,更新一些标准数据
  2032. await setupStdData(tenderData);
  2033. }
  2034. let task = [];
  2035. //定额
  2036. if (tenderData.ration.length) {
  2037. task.push(rationModel.insertMany(tenderData.ration))
  2038. }
  2039. //定额人材机
  2040. if (tenderData.rationGLJ.length) {
  2041. task.push(rationGLJModel.insertMany(tenderData.rationGLJ));
  2042. }
  2043. //定额调整系数
  2044. if (tenderData.rationCoe.length) {
  2045. task.push(rationCoeModel.insertMany(tenderData.rationCoe));
  2046. }
  2047. //项目人材机
  2048. if (tenderData.projectGLJ.length) {
  2049. task.push(gljListModel.insertMany(tenderData.projectGLJ));
  2050. }
  2051. // 承包人材料
  2052. if (tenderData.contractorList.length) {
  2053. task.push(contractorListModel.insertMany(tenderData.contractorList));
  2054. }
  2055. // 评标材料表
  2056. if (tenderData.bidEvaluationList.length) {
  2057. task.push(bidListModel.insertMany(tenderData.bidEvaluationList));
  2058. }
  2059. // 暂估价材料表
  2060. if (tenderData.evaluationList.length) {
  2061. task.push(evaluateListModel.insertMany(tenderData.evaluationList));
  2062. }
  2063. //组成物
  2064. if (tenderData.mixRatio.length) {
  2065. task.push(mixRatioModel.insertMany(tenderData.mixRatio));
  2066. }
  2067. //单价文件
  2068. if (tenderData.unitPrice.length) {
  2069. task.push(unitPriceModel.insertMany(tenderData.unitPrice));
  2070. }
  2071. if (task.length) {
  2072. await Promise.all(task);
  2073. }
  2074. //继续处理定额等数据
  2075. function enterDetail(tenderData) {
  2076. return tenderData.ration.length ||
  2077. tenderData.rationGLJ.length ||
  2078. tenderData.projectGLJ.length ||
  2079. tenderData.mixRatio.length ||
  2080. tenderData.unitPrice.length;
  2081. }
  2082. }
  2083. //匹配标准数据,需要匹配标准定额,更新导入的定额人材机的定额消耗量等数据
  2084. async function setupStdData(tenderData) {
  2085. //获取标准定额数据 (定额子目的编码查找)
  2086. let matchRationCodes = [...new Set(tenderData.ration.map(ration => ration.code))];
  2087. if (!matchRationCodes.length) {
  2088. return;
  2089. }
  2090. //限制在当前费用定额可用的定额库里查找
  2091. let stdRations = await stdRationItemModel.find({code: {$in: matchRationCodes}, rationRepId: {$in: tenderData.tender.rationLibIDs}},
  2092. '-_id -rationAssList -rationCoeList -rationInstList');
  2093. //标准定额code - 映射
  2094. let stdRationCodeMap = {};
  2095. stdRations.forEach(stdRation => stdRationCodeMap[stdRation.code] = stdRation);
  2096. //获取标准人材机数据 (人材机汇总的编码查找)
  2097. let matchGLJCodes = [...new Set(tenderData.projectGLJ.map(pGLJ => pGLJ.original_code))];
  2098. if (!matchGLJCodes.length) {
  2099. return;
  2100. }
  2101. //限制在当前费用定额可用的人材机库里查找
  2102. let stdGLJs = await stdGljItemModel.find({code: {$in: matchGLJCodes}, repositoryId: {$in: tenderData.tender.gljLibIDs}},
  2103. '-_id -component -priceProperty');
  2104. //标准人材机code - 映射
  2105. let stdGLJCodeMap = {};
  2106. stdGLJs.forEach(stdGLJ => stdGLJCodeMap[stdGLJ.code] = stdGLJ);
  2107. // 取费ID-计算程序子目映射
  2108. const programIDCalculationMap = {};
  2109. //更新定额数据
  2110. const toSetFakeProgramIDData = [];
  2111. tenderData.ration.forEach(r => {
  2112. if (r.setFakeProgramID) {
  2113. toSetFakeProgramIDData.push(r);
  2114. delete r.setFakeProgramID;
  2115. }
  2116. let stdRation = stdRationCodeMap[r.code];
  2117. if (stdRation) {
  2118. r.caption = stdRation.caption;
  2119. r.from = 'std';
  2120. r.libID = stdRation.rationRepId;
  2121. r.stdID = stdRation.ID;
  2122. r.prefix = stdRation.rationRepId == tenderData.tender.defaultRationLib ? '' : '借';
  2123. r.content = stdRation.jobContent;
  2124. r.manageFeeRate = stdRation.manageFeeRate;
  2125. if (stdRation.feeType) {
  2126. r.programID = stdRation.feeType;
  2127. } else {
  2128. // 是标准定额,但是该标准定额取费专业为空,取定额取费专业(后台配置项)
  2129. r.programID = tenderData.tender.property.engineering;
  2130. }
  2131. } else {
  2132. r.from = 'cpt';
  2133. r.prefix = '补';
  2134. }
  2135. if (r.calculationItems && r.calculationItems.length > 0 && !programIDCalculationMap[r.programID]) {
  2136. programIDCalculationMap[r.programID] = r.calculationItems;
  2137. }
  2138. delete r.calculationItems;
  2139. });
  2140. // 更新计算程序
  2141. const newTemplates = [];
  2142. const calcFileID = tenderData.tender.property.calcProgramFile.ID;
  2143. let calcProgramFile = null;
  2144. if (Object.keys(programIDCalculationMap).length > 0) {
  2145. calcProgramFile = await calcProgramsModel.findOne({ ID: calcFileID }).lean();
  2146. if (calcProgramFile) {
  2147. for (const template of calcProgramFile.templates) {
  2148. const matched = programIDCalculationMap[template.ID];
  2149. if (!matched) {
  2150. newTemplates.push(template);
  2151. continue;
  2152. }
  2153. for (const newCalcItem of matched) {
  2154. for (const oldCalcItem of template.calcItems) {
  2155. if (newCalcItem.fieldName === oldCalcItem.fieldName &&
  2156. !(newCalcItem.feeRate === 100 && !oldCalcItem.feeRateID && !oldCalcItem.feeRate)) {
  2157. oldCalcItem.feeRate = newCalcItem.feeRate;
  2158. oldCalcItem.feeRateID = null; // feeRateID优先级比较高,不赋为空的话为被覆盖
  2159. }
  2160. }
  2161. }
  2162. newTemplates.push(template);
  2163. }
  2164. }
  2165. }
  2166. // 增加假的计算程序
  2167. if (toSetFakeProgramIDData.length) {
  2168. if (!calcProgramFile) {
  2169. calcProgramFile = await calcProgramsModel.findOne({ ID: calcFileID }).lean();
  2170. }
  2171. if (calcProgramFile) {
  2172. const programIDTemplateMap = {};
  2173. const programIDNewTemplateMap = {};
  2174. calcProgramFile.templates.forEach(template => programIDTemplateMap[template.ID] = template);
  2175. let curID = calcProgramFile.templates.length + 1;
  2176. toSetFakeProgramIDData.forEach(r => {
  2177. const matchedNewTempate = programIDNewTemplateMap[r.programID];
  2178. if (matchedNewTempate) {
  2179. r.programID = matchedNewTempate.ID;
  2180. return;
  2181. }
  2182. const matched = programIDTemplateMap[r.programID];
  2183. if (matched) {
  2184. const newData = {
  2185. ID: curID++,
  2186. name: `${matched.name}_1`,
  2187. calcItems: []
  2188. };
  2189. newTemplates.push(newData);
  2190. programIDNewTemplateMap[r.programID] = newData;
  2191. r.programID = newData.ID;
  2192. }
  2193. });
  2194. }
  2195. }
  2196. if (newTemplates.length) {
  2197. await calcProgramsModel.update({ ID: calcFileID }, { $set: { templates: newTemplates } });
  2198. }
  2199. //更新定额人材机数据
  2200. tenderData.rationGLJ.forEach(rGLJ => {
  2201. rGLJ.from = 'cpt';
  2202. //匹配定额
  2203. let stdRation = stdRationCodeMap[rGLJ.rationCode];
  2204. if (stdRation) {
  2205. //根据导入数据的定额人材机编码匹配人材机
  2206. let stdGLJ = stdGLJCodeMap[rGLJ.original_code];
  2207. if (stdGLJ) {
  2208. rGLJ.from = 'std';
  2209. rGLJ.GLJID = stdGLJ.ID;
  2210. rGLJ.type = stdGLJ.gljType;
  2211. rGLJ.shortName = stdGLJ.shortName;
  2212. rGLJ.repositoryId = stdGLJ.repositoryId;
  2213. rGLJ.model = stdGLJ.model;
  2214. rGLJ.adjCoe = stdGLJ.adjCoe;
  2215. //找匹配到的标准定额中定额人材机的相应人材机,更新定额消耗
  2216. let stdRationGLJ = stdRation.rationGljList.find(data => data.gljId === stdGLJ.ID);
  2217. if (stdRationGLJ) {
  2218. rGLJ.rationItemQuantity = stdRationGLJ.consumeAmt;
  2219. }
  2220. }
  2221. }
  2222. });
  2223. //更新人材机汇总数据
  2224. tenderData.projectGLJ.forEach(pGLJ => {
  2225. if (!pGLJ.specs) {
  2226. pGLJ.specs = null;
  2227. }
  2228. let stdGLJ = stdGLJCodeMap[pGLJ.original_code];
  2229. if (stdGLJ) {
  2230. pGLJ.glj_id = stdGLJ.ID;
  2231. pGLJ.model = stdGLJ.model;
  2232. if (pGLJ.type !== stdGLJ.gljType) { //更新组成物connect_key
  2233. let keyStr = [pGLJ.code || 'null', pGLJ.name || 'null', pGLJ.specs || 'null', pGLJ.unit || 'null', pGLJ.type].join('|-|');
  2234. let ratios = tenderData.mixRatio.filter(ratio =>
  2235. ratio.connect_key === keyStr);
  2236. let newKeyStr = [pGLJ.code || 'null', pGLJ.name || 'null', pGLJ.specs || 'null', pGLJ.unit || 'null', stdGLJ.gljType || 'null'].join('|-|');
  2237. ratios.forEach(ratio => ratio.connect_key = newKeyStr);
  2238. }
  2239. pGLJ.type = stdGLJ.gljType; //更新类型,标准的数据类型更准确,导入的类型数据有细分识别不了
  2240. }
  2241. });
  2242. //更新单价文件数据
  2243. tenderData.unitPrice.forEach(up => {
  2244. let stdGLJ = stdGLJCodeMap[up.original_code];
  2245. if (stdGLJ) {
  2246. up.glj_id = stdGLJ.ID;
  2247. up.type = stdGLJ.gljType;
  2248. up.short_name = stdGLJ.shortName;
  2249. if (stdGLJ.taxRate) {
  2250. up.taxRate = stdGLJ.taxRate;
  2251. }
  2252. }
  2253. });
  2254. //更新组成物数据
  2255. tenderData.mixRatio.forEach(ratio => {
  2256. let stdGLJ = stdGLJCodeMap[ratio.code] || stdGLJCodeMap[ratio.original_code];
  2257. if (stdGLJ) {
  2258. ratio.glj_id = stdGLJ.ID;
  2259. ratio.type = stdGLJ.gljType;
  2260. }
  2261. });
  2262. }
  2263. async function exportProject(userID,data){//导出建设项目
  2264. if(data.type == 'main'){
  2265. return await exportMainData(userID,data.projectID);
  2266. }else {
  2267. return await exportTenderData(data);
  2268. }
  2269. }
  2270. async function exportMainData(userID,projectID) {
  2271. let result = {userID:userID,projects:[],type:'Project'};//type 备用属性,表示导出的类型,目前导出的都是整个建设项目
  2272. let tenderIDs = [];
  2273. let project = await projectModel.findOne({ID:projectID});
  2274. if(!project) throw new Error("没有找到该建设项目:"+projectID);
  2275. result['compilationID'] = project.compilation;
  2276. result['from'] = "construction";
  2277. result.projects.push(project);
  2278. let subProjects = await projectModel.find({"$or": [{'ParentID':projectID}, {"property.rootProjectID": projectID}]});
  2279. for(let s of subProjects){
  2280. if(!s.deleteInfo || !s.deleteInfo.deleted){
  2281. result.projects.push(s);
  2282. if(s.projType =="Tender") tenderIDs.push(s.ID);
  2283. }
  2284. }
  2285. let files = {unitFiles:await exportUnitFiles(projectID),feeRateFiles:await exportFeeRateFiles(projectID)};
  2286. result.files = files;
  2287. result = cipher.aesEncrypt(JSON.stringify(result));
  2288. result +="|----|" +JSON.stringify(tenderIDs);
  2289. return result;
  2290. }
  2291. async function exportUnitFiles(rootProjectID){
  2292. let unitFiles = [];
  2293. let files = await unitPriceFileModel.find({root_project_id:rootProjectID});
  2294. for(let f of files){
  2295. if(f.deleteInfo && f.deleteInfo.deleted == true) continue;
  2296. let tem = {unitFile:f};
  2297. tem.unitPrices = await unitPriceModel.find({unit_price_file_id:f.id});
  2298. tem.mixRatios = await mixRatioModel.find({unit_price_file_id:f.id});
  2299. unitFiles.push(tem);
  2300. }
  2301. return unitFiles;
  2302. }
  2303. async function exportFeeRateFiles(rootProjectID) {
  2304. let feeRateFiles = [];
  2305. let files = await feeRateFileModel.find({rootProjectID:rootProjectID});
  2306. for(let f of files){
  2307. if(f.deleteInfo && f.deleteInfo.deleted == true) continue;
  2308. let tem = {feeRateFile:f};
  2309. tem.feeRate = await feeRateModel.findOne({ID:f.feeRateID});
  2310. feeRateFiles.push(tem);
  2311. }
  2312. return feeRateFiles;
  2313. }
  2314. async function exportTenderData(data){
  2315. let result = {};
  2316. let projectSetting = await projectSettingModel.findOne({"projectID": data.projectID}, '-_id');
  2317. if(projectSetting) result['projSetting'] = projectSetting;
  2318. result.bills = await billsModel.find({"projectID": data.projectID});
  2319. result.rations = await rationModel.find({'$or': [{projectID: data.projectID, deleteInfo: null}, {projectID: data.projectID, 'deleteInfo.deleted': {$in: [null, false]}}]});
  2320. result.projectGLJs = await gljListModel.find({'project_id':data.projectID});
  2321. result.installationFees = await installationFeeModel.find({projectID:data.projectID});
  2322. result.rationGLJs = await rationGLJModel.find({projectID:data.projectID});
  2323. result.rationCoes = await rationCoeModel.find({projectID:data.projectID});
  2324. result.quantityDetails = await quantityDetailModel.find({projectID:data.projectID});
  2325. result.rationInstallations = await rationInstallationModel.find({projectID:data.projectID});
  2326. result.rationTemplates = await rationTemplateModel.find({projectID:data.projectID});
  2327. result.calcProgramsFile = await calcProgramsModel.findOne({projectID:data.projectID});
  2328. result.labourCoes = await labourCoesModel.findOne({projectID:data.projectID});
  2329. result.evaluateList = await evaluateListModel.find({projectID:data.projectID}, '-_id').lean();
  2330. result.bidList = await bidListModel.find({projectID:data.projectID}, '-_id').lean();
  2331. result.contractorList = await contractorListModel.find({projectID:data.projectID}, '-_id').lean();
  2332. return cipher.aesEncrypt(JSON.stringify(result));
  2333. }
  2334. async function downLoadProjectFile(info) {
  2335. let result = {error:0};
  2336. let bucketManager2 = new qiniu.rs.BucketManager(mac, null);
  2337. let publicBucketDomain = qiniu_config.Domain;// "http://serverupdate.smartcost.com.cn";//这里不支持https
  2338. let deadline = parseInt(Date.now() / 1000) + 3600; // 1小时过期
  2339. let privateDownloadUrl = bucketManager2.privateDownloadUrl(publicBucketDomain, info.key, deadline);
  2340. console.log(privateDownloadUrl);
  2341. let data = {
  2342. key:info.key,
  2343. content: '正在导入建设项目,请稍候……',
  2344. userID:info.session.sessionUser.id,
  2345. compilationID: info.session.sessionCompilation._id,
  2346. status:"start",
  2347. create_time:+new Date()
  2348. };
  2349. await importLogsModel.create(data);
  2350. doDownLoadAndImport(privateDownloadUrl,info);
  2351. return result;
  2352. }
  2353. async function doDownLoadAndImport(privateDownloadUrl, info) {
  2354. let stream = fs.createWriteStream(path.join(__dirname, "../../../tmp/" + info.key));//
  2355. request(privateDownloadUrl)
  2356. .on('error', async function(err) {
  2357. await importLogsModel.update({ key: info.key }, { status: 'error', errorMsg: err.toString() });
  2358. })
  2359. .pipe(stream)
  2360. .on("close", async function () {
  2361. console.log("文件[" + info.key + "]下载完毕");
  2362. let doc = { status: "finish" };
  2363. try {
  2364. let data = fs.readFileSync(stream.path, 'utf-8');
  2365. let result = await importProjects(data, { session: info.session }, info.updateData);
  2366. if (result.error == 1) {
  2367. doc.errorMsg = result.msg;
  2368. doc.status = "error";
  2369. } else {
  2370. doc.projectID = [result.constructionProjectID];
  2371. }
  2372. } catch (error) {
  2373. console.log(error.message);
  2374. doc.errorMsg = "导入失败,请检查文件!";
  2375. doc.status = "error";
  2376. } finally {
  2377. await importLogsModel.update({ key: info.key }, doc);
  2378. fs.unlinkSync(stream.path);
  2379. }
  2380. })
  2381. .on('error', async function () {
  2382. await importLogsModel.update({ key: info.key }, { status: 'error', errorMsg: `文件[${info.key}]下载失败,请稍后再试。` });
  2383. });
  2384. }
  2385. async function importProcessChecking(data){
  2386. let result = {error:0};
  2387. const query = data.key ? { key: data.key } : { userID: data.userID, compilationID: data.compilationID };
  2388. let log = await importLogsModel.findOne(query);
  2389. if(log){
  2390. if(log.status == "finish"){
  2391. result.status = "complete";
  2392. await importLogsModel.remove(query);
  2393. // 获取导入的项目数据
  2394. if (log.projectID && log.projectID.length > 0) {
  2395. const projects = await getPosterityProjects(log.projectID, true);
  2396. if (!(projects.length === 1 && projects[0].projType === projectType.tender)) { // 处理的是建设项目数据
  2397. const summaryInfo = await getSummaryInfo(log.projectID);
  2398. setupSummaryFields(summaryInfo, projects);
  2399. }
  2400. result.data = projects;
  2401. }
  2402. /* if (log.projectID && log.projectID.length > 0) {
  2403. const projects = await getPosterityProjects([log.projectID], true);
  2404. if (!(projects.length === 1 && projects[0].projType === projectType.tender)) { // 处理的是建设项目数据
  2405. const summaryInfo = await getSummaryInfo([log.projectID]);
  2406. setupSummaryFields(summaryInfo, projects);
  2407. }
  2408. result.data = projects;
  2409. } */
  2410. }else if(log.status == "start"){
  2411. result.status = "processing";
  2412. result.content = log.content;
  2413. }else if(log.status == "error"){
  2414. result.error = 1;
  2415. result.msg = log.errorMsg;
  2416. await importLogsModel.remove(query);
  2417. }
  2418. }else {
  2419. result.status = "complete";
  2420. }
  2421. return result;
  2422. }
  2423. // 从cdn服务器下载文件,key就是文件名
  2424. async function downloadFileSync(key) {
  2425. const filePath = path.join(__dirname, '../../../tmp/', key);
  2426. const bucketManager2 = new qiniu.rs.BucketManager(mac, null);
  2427. const publicBucketDomain = qiniu_config.Domain; // "http://serverupdate.smartcost.com.cn";//这里不支持https
  2428. const deadline = parseInt(Date.now() / 1000) + 3600; // 1小时过期
  2429. const privateDownloadUrl = bucketManager2.privateDownloadUrl(publicBucketDomain, key, deadline);
  2430. const stream = fs.createWriteStream(filePath);
  2431. return new Promise((resolve, reject) => {
  2432. request(privateDownloadUrl)
  2433. .on('error', reject)
  2434. .pipe(stream)
  2435. .on('close', () => {
  2436. // 读取文件返回字符串
  2437. const srcData = fs.readFileSync(stream.path,'utf-8');
  2438. resolve({
  2439. path: stream.path,
  2440. srcData: srcData
  2441. });
  2442. })
  2443. .on('error', reject);
  2444. });
  2445. }
  2446. // 导入接口
  2447. async function importInterface(key, session) {
  2448. const logData = {
  2449. key: key,
  2450. content: '正在导入接口文件,请稍候……',
  2451. userID: session.sessionUser.id,
  2452. compilationID: session.sessionCompilation._id,
  2453. status: 'start',
  2454. create_time: +new Date()
  2455. };
  2456. await importLogsModel.create(logData);
  2457. handleImportInterface(key, session);
  2458. return 'importing interface';
  2459. }
  2460. async function handleImportInterface(key, session) {
  2461. const doc = { status: 'finish' };
  2462. // 源文件内容文本
  2463. let downloadFilePath = '';
  2464. try {
  2465. const { path, srcData } = await downloadFileSync(key);
  2466. downloadFilePath = path;
  2467. if (!srcData) {
  2468. throw '无有效数据';
  2469. }
  2470. const userID = session.sessionUser.id;
  2471. const compilationID = session.sessionCompilation._id;
  2472. const importData = JSON.parse(srcData);
  2473. let tenderCount = 0;
  2474. importData.engs.forEach(eng => {
  2475. eng.tenders.forEach(() => {
  2476. tenderCount += 1;
  2477. });
  2478. });
  2479. if (await isTenderOverrun(tenderCount, session)) {
  2480. throw '您创建的项目个数超限,请联系我们的客服人员,或者导出建设项目保存到本地备份,删除云上数据。';
  2481. }
  2482. const overWriteUrl = session.sessionCompilation.overWriteUrl;
  2483. const projectID = await importProject(importData, userID, compilationID, overWriteUrl);
  2484. doc.projectID = [projectID];
  2485. } catch (err) {
  2486. doc.errorMsg = typeof err === 'string' ? err : err.toString();
  2487. doc.status = 'error';
  2488. } finally {
  2489. await importLogsModel.update({ key }, doc);
  2490. fs.unlinkSync(downloadFilePath);
  2491. }
  2492. }
  2493. /* async function importInterface(key, session) {
  2494. // 源文件内容文本
  2495. let downloadFilePath = '';
  2496. try {
  2497. const { path, srcData } = await downloadFileSync(key);
  2498. downloadFilePath = path;
  2499. if (!srcData) {
  2500. throw '无有效数据';
  2501. }
  2502. const userID = session.sessionUser.id;
  2503. const compilationID = session.sessionCompilation._id;
  2504. const importData = JSON.parse(srcData);
  2505. let tenderCount = 0;
  2506. importData.engs.forEach(eng => {
  2507. eng.tenders.forEach(tender => {
  2508. tenderCount += 1;
  2509. });
  2510. });
  2511. if (await isTenderOverrun(tenderCount, session)) {
  2512. throw '您创建的项目个数超限,请联系我们的客服人员,或者导出建设项目保存到本地备份,删除云上数据。';
  2513. }
  2514. const projectData = await importProject(importData, userID, compilationID);
  2515. return projectData;
  2516. } catch (err) {
  2517. throw err;
  2518. } finally {
  2519. fs.unlinkSync(downloadFilePath);
  2520. }
  2521. } */
  2522. async function importProjects(data,req,updateData) {
  2523. let result = {error:0};
  2524. let stringArr = data.split("|----|");
  2525. let datas = [];
  2526. let first = +new Date();
  2527. for(let s of stringArr){
  2528. datas.push(JSON.parse(cipher.aesDecrypt(s)));
  2529. }
  2530. let mainData = datas.length > 0 ?datas[0]:null;
  2531. if(mainData){
  2532. if(mainData.from && mainData.from != "construction"){
  2533. result.error = 1;
  2534. result.msg = "导入失败:您要导入的文件是由“纵横公路养护云版”导出,当前软件是“大司空云计价”,请选择正确的软件再进行操作!";
  2535. }else if(mainData.compilationID != req.session.sessionCompilation._id){
  2536. const fileCompilation = await compilationModel.findOne({_id: mongoose.Types.ObjectId(mainData.compilationID)}, 'name');
  2537. const fileCompilationName = fileCompilation ? fileCompilation.name : '未知的费用定额';
  2538. const curCompilationName = req.session.sessionCompilation.name;
  2539. result.error = 1;
  2540. result.msg = `导入失败:您要导入的文件是由“${fileCompilationName}”导出,当前软件是“${curCompilationName}”,请选择正确的费用定额再进行操作!`;
  2541. }else {
  2542. const tenders = mainData.projects.filter(item => item.projType === projectType.tender);
  2543. const tenderOverrun = await isTenderOverrun(tenders.length, req.session);
  2544. if (tenderOverrun) {
  2545. result.error = 1;
  2546. result.msg = `您创建的项目个数超限,请联系我们的客服人员,或者导出建设项目保存到本地备份,删除云上数据。`;
  2547. return result;
  2548. }
  2549. let [constructionProjectID,projectIDMap,labourCoeFileIDMap,calcProgramFileIDMap] = await handleMainProjectDatas(mainData,updateData,req.session.sessionUser.id);
  2550. result.constructionProjectID = constructionProjectID;
  2551. if(datas.length > 1 ){
  2552. let newProjectSettings=[],bills=[],rations=[],installationFees=[],projectGLJs=[],rationGLJs=[],rationCoes=[],quantityDetails=[],rationInstallations=[],rationTemplates=[],evaluateList=[],bidList=[],contractorList=[],newCalcProgramsFiles=[],newLabourCoes=[]
  2553. for(let i = 1;i<datas.length;i++){
  2554. let [tnewProjectSetting,tbills,trations,tinstallationFees,tprojectGLJs,trationGLJs,trationCoes,tquantityDetails,trationInstallations,trationTemplates,tevaluateList,tbidList,tcontractorList,tnewCalcProgramsFile,tnewLabourCoe] = await handleEachProject(datas[i],projectIDMap,labourCoeFileIDMap,calcProgramFileIDMap)
  2555. if(tnewProjectSetting) newProjectSettings.push(tnewProjectSetting);
  2556. if(tbills.length > 0) bills = bills.concat(tbills);
  2557. if(trations.length > 0) rations = rations.concat(trations);
  2558. if(tinstallationFees.length > 0) installationFees = installationFees.concat(tinstallationFees);
  2559. if(tprojectGLJs.length > 0) projectGLJs = projectGLJs.concat(tprojectGLJs);
  2560. if(trationGLJs.length > 0) rationGLJs = rationGLJs.concat(trationGLJs);
  2561. if(trationCoes.length > 0) rationCoes = rationCoes.concat(trationCoes);
  2562. if(tquantityDetails.length > 0) quantityDetails = quantityDetails.concat(tquantityDetails);
  2563. if(trationInstallations.length > 0) rationInstallations = rationInstallations.concat(trationInstallations);
  2564. if(trationTemplates.length > 0) rationTemplates = rationTemplates.concat(trationTemplates);
  2565. if(tevaluateList.length > 0) evaluateList = evaluateList.concat(tevaluateList);
  2566. if(tbidList.length > 0) bidList = bidList.concat(tbidList);
  2567. if(tcontractorList.length > 0) contractorList = contractorList.concat(tcontractorList);
  2568. if(tnewCalcProgramsFile) newCalcProgramsFiles.push(tnewCalcProgramsFile);
  2569. if(tnewLabourCoe) newLabourCoes.push(tnewLabourCoe);
  2570. }
  2571. if(newProjectSettings.length > 0) await insertMany(newProjectSettings,projectSettingModel)
  2572. if(bills.length > 0) await insertMany(bills,billsModel);
  2573. if(rations.length > 0) await insertMany(rations,rationModel);
  2574. if(installationFees.length > 0) await insertMany(installationFees,installationFeeModel);
  2575. if(projectGLJs.length > 0) await insertMany(projectGLJs,gljListModel);
  2576. if(rationGLJs.length > 0) await insertMany(rationGLJs,rationGLJModel);
  2577. if(rationCoes.length > 0) await insertMany(rationCoes,rationCoeModel);
  2578. if(quantityDetails.length > 0) await insertMany(quantityDetails,quantityDetailModel);
  2579. if(rationInstallations.length > 0) await insertMany(rationInstallations,rationInstallationModel);
  2580. if(rationTemplates.length > 0) await insertMany(rationTemplates,rationTemplateModel);
  2581. if(evaluateList.length > 0) await insertMany(evaluateList,evaluateListModel);
  2582. if(bidList.length > 0) await insertMany(bidList,bidListModel);
  2583. if(contractorList.length > 0) await insertMany(contractorList,contractorListModel);
  2584. if(newCalcProgramsFiles.length > 0) await insertMany(newCalcProgramsFiles,calcProgramsModel);
  2585. if(newLabourCoes.length > 0) await insertMany(newLabourCoes,labourCoesModel);
  2586. }
  2587. }
  2588. }
  2589. let finish = +new Date();
  2590. console.log("导入操作总时间为-------------------------------"+(finish-first));
  2591. return result;
  2592. }
  2593. async function handleEachProject(data,projectIDMap,labourCoeFileIDMap,calcProgramFileIDMap){
  2594. let bills = [],rations = [],projectGLJs = [],installationFees=[],rationGLJs=[],rationCoes=[],quantityDetails=[],rationInstallations=[],rationTemplates=[],evaluateList=[],bidList=[],contractorList=[];
  2595. let newProjectSetting =null,newCalcProgramsFile = null,newLabourCoe = null;
  2596. let billsIDMap = {},projectGLJIDMap={},rationIDMap = {};
  2597. let newProjectID = projectIDMap[data.projSetting.projectID];
  2598. //生成安装增加费设置
  2599. if(data.installationFees && data.installationFees.length > 0){
  2600. for(let ins of data.installationFees){
  2601. delete ins._id;
  2602. ins.ID = uuidV1();
  2603. ins.projectID = newProjectID;
  2604. installationFees.push(ins);
  2605. }
  2606. }
  2607. //生成新的清单;
  2608. if(data.bills && data.bills.length > 0){
  2609. for(let b of data.bills){
  2610. billsIDMap[b.ID] = uuidV1();
  2611. }
  2612. for(let b of data.bills){
  2613. delete b._id;
  2614. b = getCopyBillDatas(b,newProjectID,billsIDMap);
  2615. bills.push(b);
  2616. }
  2617. }
  2618. //生成项目工料机数据
  2619. if(data.projectGLJs && data.projectGLJs.length > 0){
  2620. let gljCount = await counter.counterDAO.getIDAfterCountSync(counter.moduleName.glj_list, data.projectGLJs.length);
  2621. for(let i = 0; i < data.projectGLJs.length; i++){
  2622. let d = data.projectGLJs[i];
  2623. delete d._id;
  2624. let newID = gljCount.sequence_value - (data.projectGLJs.length - 1) + i;
  2625. projectGLJIDMap[d.id] = newID;
  2626. d.project_id = newProjectID;
  2627. d.id = newID;
  2628. projectGLJs.push(d);
  2629. }
  2630. }
  2631. //生成新的定额
  2632. if(data.rations && data.rations.length > 0){
  2633. for(let r of data.rations){
  2634. rationIDMap[r.ID] = uuidV1();
  2635. }
  2636. for(let r of data.rations){
  2637. delete r._id;
  2638. r = getCopyRationData(r,newProjectID,billsIDMap,rationIDMap,projectGLJIDMap);
  2639. rations.push(r);
  2640. }
  2641. }
  2642. //生成定额下挂的定额工料机等等数据
  2643. if(data.rationGLJs && data.rationGLJs.length > 0) rationGLJs = setRationSubList(data.rationGLJs,newProjectID,billsIDMap,rationIDMap,projectGLJIDMap);
  2644. if(data.rationCoes && data.rationCoes.length > 0) rationCoes = setRationSubList(data.rationCoes,newProjectID,billsIDMap,rationIDMap,projectGLJIDMap);
  2645. if(data.quantityDetails && data.quantityDetails.length > 0) quantityDetails = setRationSubList(data.quantityDetails,newProjectID,billsIDMap,rationIDMap,projectGLJIDMap);
  2646. if(data.rationInstallations && data.rationInstallations.length > 0) rationInstallations = setRationSubList(data.rationInstallations,newProjectID,billsIDMap,rationIDMap,projectGLJIDMap);
  2647. if(data.rationTemplates && data.rationTemplates.length > 0) rationTemplates = setRationSubList(data.rationTemplates,newProjectID,billsIDMap,rationIDMap,projectGLJIDMap);
  2648. if(data.evaluateList && data.evaluateList.length > 0) evaluateList = setMaterialList(data.evaluateList,newProjectID,projectGLJIDMap);
  2649. if(data.bidList && data.bidList.length > 0) bidList = setMaterialList(data.bidList,newProjectID,projectGLJIDMap);
  2650. if(data.contractorList && data.contractorList.length > 0) contractorList = setMaterialList(data.contractorList,newProjectID,projectGLJIDMap);
  2651. //生成projectSetting 文件
  2652. if(data.projSetting){
  2653. data.projSetting.projectID =newProjectID;
  2654. newProjectSetting = data.projSetting;
  2655. delete newProjectSetting._id;
  2656. }
  2657. //生成计算程序文件,系数文件
  2658. if(data.calcProgramsFile && calcProgramFileIDMap[data.calcProgramsFile.ID]){
  2659. data.calcProgramsFile.ID = calcProgramFileIDMap[data.calcProgramsFile.ID];
  2660. data.calcProgramsFile.projectID = newProjectID;
  2661. newCalcProgramsFile = data.calcProgramsFile;
  2662. delete newCalcProgramsFile._id;
  2663. }
  2664. if(data.labourCoes && labourCoeFileIDMap[data.labourCoes.ID]){
  2665. data.labourCoes.ID = labourCoeFileIDMap[data.labourCoes.ID];
  2666. data.labourCoes.projectID = newProjectID;
  2667. newLabourCoe = data.labourCoes;
  2668. delete newLabourCoe._id;
  2669. }
  2670. return [newProjectSetting,bills,rations,installationFees,projectGLJs,rationGLJs,rationCoes,quantityDetails,rationInstallations,rationTemplates,evaluateList,bidList,contractorList,newCalcProgramsFile,newLabourCoe]
  2671. }
  2672. function setMaterialList(datas,newProjectID,projectGLJIDMap){
  2673. let arrs = [];
  2674. for(let d of datas){
  2675. arrs.push(getNewMaterial(d,newProjectID,projectGLJIDMap))
  2676. }
  2677. return arrs
  2678. }
  2679. function setRationSubList(datas,newProjectID,billIDMap,rationIDMap,projectGLJIDMap) {
  2680. let arrs = [];
  2681. for(let d of datas){
  2682. delete d._id;
  2683. d = getCopyRationSubData(d,newProjectID,billIDMap,rationIDMap,projectGLJIDMap);
  2684. arrs.push(d);
  2685. }
  2686. return arrs;
  2687. }
  2688. async function handleMainProjectDatas(mainData,updateData,userID) {
  2689. let mainProjectID = -1;
  2690. let projectIDMap = {},feeRateFileIDMap={},unitPriceFileIDMap={},labourCoeFileIDMap={},calcProgramFileIDMap={};
  2691. let tasks = [];
  2692. projectIDMap[-1] = -1;//最后一个项目的nextID为-1的情况
  2693. let constructionProjectID;
  2694. //生成新的projectID
  2695. for(let p of mainData.projects){
  2696. let newProjectID = await getCounterID("projects");
  2697. projectIDMap[p.ID] = newProjectID;
  2698. if(p.projType == "Project") {
  2699. mainProjectID = newProjectID;
  2700. constructionProjectID = newProjectID;
  2701. }
  2702. if(p.projType == "Tender"){
  2703. if(p.property.calcProgramFile) calcProgramFileIDMap[p.property.calcProgramFile.ID] = uuidV1();//新的计算程序文件ID
  2704. if(p.property.labourCoeFile) labourCoeFileIDMap[p.property.labourCoeFile.ID] = uuidV1();//新的人工调整系数文件ID
  2705. if(p.property.feeFile) feeRateFileIDMap[p.property.feeFile.id] = uuidV1();//新的费率文件ID
  2706. if(p.property.unitPriceFile) unitPriceFileIDMap[p.property.unitPriceFile.id] = await getCounterID("unit_price_file");//新的单价文件ID
  2707. }
  2708. }
  2709. if(mainProjectID == -1) throw new Error("文件里面没包含建设项目信息!");
  2710. //处理项目信息 ----- 费率文件,单价文件ID信息要重新生成----to do
  2711. for(let p of mainData.projects){
  2712. delete p._id;
  2713. delete p.__v;
  2714. p.ID = projectIDMap[p.ID];
  2715. if(p.ID == mainProjectID){//对于建设项目,要父和下一节点ID要使用前端传入的位置ID
  2716. p.ParentID = updateData.self.ParentID;
  2717. p.NextSiblingID = updateData.self.NextSiblingID;
  2718. if(updateData.update){//树节构中的上一节点的下一节点设置为本建设项目ID;
  2719. tasks.push({updateOne:{filter : updateData.update.query, update : {NextSiblingID:mainProjectID}}});
  2720. }
  2721. //查看是否重名;
  2722. let temp = await projectModel.findOne({userID:userID,ParentID:p.ParentID,name:p.name});
  2723. if(temp) p.name = p.name + '(' + moment(Date.now()).tz("Asia/Shanghai").format('MM-DD HH:mm:ss') + '导入)';
  2724. }else {
  2725. p.ParentID = projectIDMap[p.ParentID];
  2726. p.NextSiblingID = projectIDMap[p.NextSiblingID];
  2727. }
  2728. p.userID =userID;
  2729. p.shareInfo=[];
  2730. if(p.projType == "Tender"){
  2731. if(p.property.calcProgramFile) p.property.calcProgramFile.ID = calcProgramFileIDMap[p.property.calcProgramFile.ID];
  2732. if(p.property.labourCoeFile) p.property.labourCoeFile.ID = labourCoeFileIDMap[p.property.labourCoeFile.ID];
  2733. if(p.property.feeFile) p.property.feeFile.id = feeRateFileIDMap[p.property.feeFile.id];
  2734. if(p.property.unitPriceFile) p.property.unitPriceFile.id = unitPriceFileIDMap[p.property.unitPriceFile.id];
  2735. p.property.rootProjectID = mainProjectID
  2736. }
  2737. tasks.push({insertOne: {document: p}})
  2738. }
  2739. //项目树节构数据生成:
  2740. await projectModel.bulkWrite(tasks);
  2741. //生成所有的费率文件
  2742. await importFeeRateFiles(mainData,projectIDMap,feeRateFileIDMap,userID);
  2743. //生成所有的单价文件
  2744. await importUnitPriceFiles(mainData,projectIDMap,unitPriceFileIDMap,userID);
  2745. return [constructionProjectID,projectIDMap,labourCoeFileIDMap,calcProgramFileIDMap]
  2746. }
  2747. async function importUnitPriceFiles(mainData,projectIDMap,unitPriceFileIDMap,userID) {
  2748. if(!mainData.files.unitFiles) return;
  2749. let unitFiles = [],unitPrices =[],mixRatios=[],freights=[],originals=[];
  2750. for(let f of mainData.files.unitFiles){
  2751. let file = f.unitFile,prices = f.unitPrices,mixs = f.mixRatios,fres = f.freights,ors = f.originals;
  2752. //生成单价文件
  2753. delete file._id;
  2754. file.id = unitPriceFileIDMap[file.id]?unitPriceFileIDMap[file.id]:await getCounterID("unit_price_file");
  2755. file.project_id = projectIDMap[file.project_id];
  2756. file.root_project_id = projectIDMap[file.root_project_id];
  2757. file.user_id = userID;
  2758. unitFiles.push(file);
  2759. //生成子数据
  2760. if(prices) await setSubList(prices,unitPrices,file.id,unitPriceModel);
  2761. if(mixs) await setSubList(mixs,mixRatios,file.id,mixRatioModel);
  2762. }
  2763. if(unitFiles.length > 0) await insertMany(unitFiles,unitPriceFileModel);
  2764. if(unitPrices.length > 0) await insertMany(unitPrices,unitPriceModel);
  2765. if(mixRatios.length > 0) await insertMany(mixRatios,mixRatioModel);
  2766. async function setSubList(oList,nList,fileID,model) {
  2767. let IDcounter = await counter.counterDAO.getIDAfterCountSync(model.modelName, oList.length);
  2768. let firstID = IDcounter.sequence_value - (oList.length - 1);
  2769. for(let o of oList){
  2770. delete o._id;
  2771. o.unit_price_file_id = fileID;
  2772. o.id = firstID;
  2773. firstID+=1
  2774. nList.push(o)
  2775. }
  2776. }
  2777. }
  2778. async function importFeeRateFiles(mainData,projectIDMap,feeRateFileIDMap,userID) {
  2779. let feeRateFiles = [], feeRates = [];
  2780. if(!mainData.files.feeRateFiles) return;
  2781. for(let f of mainData.files.feeRateFiles){
  2782. //生成费率记录
  2783. let rate = f.feeRate;
  2784. delete rate._id;
  2785. rate.ID = uuidV1();
  2786. feeRates.push(rate);
  2787. //生成费率文件记录
  2788. let file = f.feeRateFile;
  2789. delete file._id;
  2790. file.ID = feeRateFileIDMap[file.ID]?feeRateFileIDMap[file.ID]:uuidV1();
  2791. file.userID = userID;
  2792. file.rootProjectID = projectIDMap[file.rootProjectID];
  2793. file.feeRateID = rate.ID;
  2794. feeRateFiles.push(file);
  2795. }
  2796. if(feeRateFiles.length > 0) await insertMany(feeRateFiles,feeRateFileModel);
  2797. if(feeRates.length > 0) await insertMany(feeRates,feeRateModel);
  2798. }
  2799. // 初始化
  2800. async function initOverHeightItems(engineeringID) {
  2801. const defaultData = [];
  2802. const engineering = await engineeringModel.findById(engineeringID);
  2803. const overHeightLibs = engineering.over_height_lib;
  2804. if (!overHeightLibs || !overHeightLibs.length) {
  2805. return defaultData;
  2806. }
  2807. const overHeightLibID = overHeightLibs[0].id;
  2808. const overHeightLib = await overHeightLibModel.findOne({ID: overHeightLibID});
  2809. return overHeightLib ? overHeightLib.list : defaultData;
  2810. }
  2811. function uploadToken() {
  2812. let options = {
  2813. scope: qiniu_config.Bucket,
  2814. deleteAfterDays: 1,
  2815. returnBody:
  2816. '{"key":"$(key)","hash":"$(etag)","fsize":$(fsize),"bucket":"$(bucket)","name":"$(x:name)"}'
  2817. };
  2818. let putPolicy = new qiniu.rs.PutPolicy(options);
  2819. let token = putPolicy.uploadToken(mac);
  2820. let result = {
  2821. uptoken: token,
  2822. domain: qiniu_config.Domain
  2823. }
  2824. return result
  2825. }
  2826. // 获取系统设置,这个系统设置正常情况下有存在session中
  2827. async function getSystemSetting() {
  2828. return await systemSettingModel.findOne({}).lean();
  2829. }
  2830. // 有些方法无法通过中间件就检查单位工程数量是否超限
  2831. // 需要到具体的业务代码中进行判断
  2832. // 这个方法就是具体业务代码中,需要检查单位工程数量是否超限用
  2833. async function isTenderOverrun(tenderCount, session) {
  2834. const userID = session.sessionUser.id;
  2835. const compilation = session.sessionCompilation._id;
  2836. const compilationVersion = session.compilationVersion || '免费';
  2837. let systemSetting = session.systemSetting || (session.systemSetting = await getSystemSetting());
  2838. // 这种情况只有在刚上线此功能时会出现,不考虑时间差
  2839. if (!systemSetting) {
  2840. return false;
  2841. }
  2842. const type = compilationVersion.includes('免费') ? 'normal' : 'professional';
  2843. const limit = systemSetting[type].project;
  2844. const curTenderCount = await projectModel.count({userID, compilation, projType: 'Tender', '$or':[{deleteInfo: null}, {'deleteInfo.completeDeleted': false}]});
  2845. return tenderCount + curTenderCount > limit;
  2846. }
  2847. async function getWelcomeInfo(compilationId,sessionUser,isFree=true) {
  2848. let welcom_setting = await welcomeModel.findOne({compilationId:compilationId});
  2849. let isShow = false;
  2850. let context = "";
  2851. let setting = null
  2852. if(welcom_setting){
  2853. setting = isFree? welcom_setting.normal:welcom_setting.professional;//区分专业版和免费版
  2854. }
  2855. if(setting){
  2856. if(setting.showType == 0) return [false,""];//关闭
  2857. context = setting.context;
  2858. if(setting.showType == 1){//每天一次
  2859. let dataString =moment(Date.now()).tz("Asia/Shanghai").format('YYYY-MM-DD');//今天的日期字符串
  2860. let userInfo =await userModel.findOne({_id: mongoose.Types.ObjectId(sessionUser.id)});
  2861. if (dataString != userInfo.welcomeShowTime){//今天没登录过
  2862. isShow = true;
  2863. await userModel.update({_id: mongoose.Types.ObjectId(sessionUser.id)},{welcomeShowTime:dataString})
  2864. }
  2865. }else if(setting.showType == 2){//每次登录显示
  2866. isShow = sessionUser.newLogin?true:false;
  2867. sessionUser.newLogin = false
  2868. }
  2869. }
  2870. return [isShow,context]
  2871. }