engineering_lib_model.js 7.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278
  1. /**
  2. * 计价规则标准库业务逻辑
  3. *
  4. * @author CaiAoLin
  5. * @date 2017/8/31
  6. * @version
  7. */
  8. import mongoose from "mongoose";
  9. import BaseModel from "../../common/base/base_model";
  10. import CompilationModel from "./compilation_model";
  11. let stdRationLibModel = mongoose.model("std_ration_lib_map");
  12. import {default as EngineeringConst, List as EngineeringList} from "../../common/const/engineering";
  13. class EngineeringLibModel extends BaseModel {
  14. /**
  15. * 构造函数
  16. *
  17. * @return {void}
  18. */
  19. constructor() {
  20. let parent = super();
  21. parent.model = mongoose.model("engineering_lib");
  22. parent.init();
  23. }
  24. /**
  25. * 获取标准库数据
  26. *
  27. * @param {Object} data
  28. * @param {Number} engineering
  29. * @return {Promise}
  30. */
  31. async getLib(data, engineering) {
  32. let result = {};
  33. if (data.length <= 0) {
  34. return result;
  35. }
  36. let id = '';
  37. for(let tmp of data) {
  38. if (tmp.engineering === engineering) {
  39. id = tmp.engineering_id;
  40. break;
  41. }
  42. }
  43. if (id === '') {
  44. return result;
  45. }
  46. let condition = {_id: id};
  47. return this.findDataByCondition(condition);
  48. }
  49. async getLibsByValuationID(valuationID){
  50. return this.findDataByCondition({valuationID:valuationID},null,false);
  51. }
  52. async deleteByValuationID(valuationID){
  53. return await this.db.delete({valuationID:valuationID});
  54. }
  55. //添加空的默认的所有标准库
  56. /**
  57. * @param valuationID
  58. * @returns {Promise.<*>}
  59. */
  60. async addStdLib(valuationID){
  61. let stdLibs = [];
  62. for(let eng of EngineeringList){
  63. let tem = {
  64. glj_col:{showAdjustPrice:false},
  65. valuationID:valuationID,
  66. name:eng.name,
  67. engineering:eng.value
  68. };
  69. stdLibs.push(tem);
  70. }
  71. let result = await this.db.create(stdLibs);
  72. return result;
  73. }
  74. async addEngineer(data){
  75. data.glj_col = {showAdjustPrice:false};
  76. if(data.compilationId && data.compilationId!=""){
  77. data.ration_lib = [];
  78. let rationList = await stdRationLibModel.find({compilationId:data.compilationId},['ID','dispName']);
  79. for(let i =0;i< rationList.length;i++){
  80. let tem = {
  81. id:rationList[i].ID,
  82. name:rationList[i].dispName,
  83. isDefault:false
  84. };
  85. if(i == 0) tem.isDefault = true;
  86. data.ration_lib.push(tem);
  87. }
  88. }
  89. let result = await this.db.create(data);
  90. return result;
  91. }
  92. /**
  93. * 新增标准库
  94. *
  95. * @param {String} valuationId
  96. * @param {Object} data
  97. * @return {Promise}
  98. */
  99. async addLib(engineerId, data) {
  100. if(data.glj_col){
  101. data.glj_col = JSON.parse(data.glj_col);
  102. }
  103. data.isInstall == 'true'?data.isInstall=true:data.isInstall=false;
  104. let result = false;
  105. data = this.filterLibData(data);
  106. try {
  107. let engineeringLib = await this.findDataByCondition({_id:engineerId});
  108. if(engineeringLib){
  109. // 存在则直接更新
  110. delete data.id;
  111. delete data.section;
  112. let condition = {_id: engineerId};
  113. result = await this.db.update(condition, data);
  114. result = result.ok === 1;
  115. }else {
  116. throw new Error("找不到对应的工程专业");
  117. }
  118. } catch (error) {
  119. console.log(error);
  120. result = false;
  121. }
  122. return result;
  123. }
  124. /**
  125. * 过滤计价数据
  126. *
  127. * @param {Object} data
  128. * @return {Object}
  129. */
  130. filterLibData(data) {
  131. if (Object.keys(data).length <= 0 || data.section === undefined) {
  132. console.log('1');
  133. throw '数据有误';
  134. }
  135. data.engineering = parseInt(data.engineering);
  136. //需求修改,工程专业可以随便输入了
  137. //检测专业工程是否合法
  138. /* let match = false;
  139. for(let index in EngineeringConst) {
  140. if (EngineeringConst[index] === data.engineering) {
  141. match = true;
  142. break;
  143. }
  144. }
  145. if (!match) {
  146. throw '工程专业错误';
  147. }*/
  148. // 判断标准清单
  149. data.bill_lib = this._validLib(data.bill_lib);
  150. // 判断定额库
  151. data.ration_lib = this._validLib(data.ration_lib);
  152. //设置默认定额库
  153. this.setDefaultRation(data);
  154. // 判断工料机库
  155. data.glj_lib = this._validLib(data.glj_lib);
  156. // 判断清单指引库
  157. data.billsGuidance_lib = this._validLib(data.billsGuidance_lib);
  158. /*// 判断费率标准
  159. data.fee_lib = this._validLib(data.fee_lib);*/
  160. // 判断人工系数
  161. data.artificial_lib = this._validLib(data.artificial_lib);
  162. //判断工程特征库
  163. data.feature_lib = this._validLib(data.feature_lib);
  164. //判断累进区间库
  165. data.progressive_lib = this._validLib(data.progressive_lib);
  166. //判断车船税
  167. data.vvTax_lib = this._validLib(data.vvTax_lib);
  168. //计税方式组合
  169. data.tax_group = this._validLib(data.tax_group);
  170. return data;
  171. }
  172. /**
  173. * 校验库数据
  174. *
  175. * @param {Object} libData
  176. * @return {Object}
  177. */
  178. _validLib(libData) {
  179. let result = [];
  180. // 判断标准库
  181. if (libData === undefined || libData ===null ||libData === '') {
  182. return result;//throw '标准库不能为空'; 按新需求,标准库等不做非空判断
  183. }
  184. libData = libData instanceof Array ? libData : [libData];
  185. for(let tmp in libData) {
  186. result[tmp] = JSON.parse(libData[tmp]);
  187. }
  188. return result;
  189. }
  190. //设置默认定额库
  191. setDefaultRation(data){
  192. if(data.ration_lib && data.ration_lib.length>0){
  193. if(data.ration_isDefault && data.ration_isDefault != ""){
  194. for(let r of data.ration_lib){
  195. r.id.toString() == data.ration_isDefault?r.isDefault = true:r.isDefault=false;
  196. }
  197. }else {
  198. data.ration_lib[0].isDefault = true;
  199. }
  200. }
  201. }
  202. /**
  203. * 获取对应标准库数量
  204. *
  205. * @param {Object} valuationData
  206. * @return {Object}
  207. */
  208. async getLibCount(valuationData) {
  209. let result = {};
  210. if (valuationData.engineering_list === undefined || valuationData.engineering_list.length <= 0) {
  211. return result;
  212. }
  213. // 整理需要查找的数据
  214. let findIdList = [];
  215. for(let engineering of valuationData.engineering_list) {
  216. findIdList.push(engineering.engineering_id);
  217. }
  218. let condition = {_id: {$in: findIdList}};
  219. let libData = await this.findDataByCondition(condition, null, false);
  220. if (libData === null) {
  221. return result;
  222. }
  223. // 整理数据
  224. let countData = {};
  225. for(let tmp of libData) {
  226. countData[tmp._id] = {
  227. bill_count: tmp.bill_lib.length,
  228. ration_count: tmp.ration_lib.length,
  229. glj_count: tmp.glj_lib.length,
  230. fee_count: tmp.fee_lib.length,
  231. artificial_count: tmp.artificial_lib.length,
  232. program_count: tmp.program_lib.length,
  233. };
  234. }
  235. for(let engineering of valuationData.engineering_list) {
  236. if (countData[engineering.engineering_id] !== undefined) {
  237. result[engineering.engineering] = countData[engineering.engineering_id];
  238. }
  239. }
  240. return result;
  241. }
  242. }
  243. export default EngineeringLibModel;