bills_permissionController.js 8.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235
  1. /**标准清单操作相关
  2. * Created by Zhong on 2017/8/2.
  3. */
  4. let billsController = require("./bills_lib_controllers");
  5. let billsLibDao = require("./../models/bills_lib_interfaces");
  6. import baseController from "../../common/base/base_controller";
  7. import fs from 'fs';
  8. import path from 'path';
  9. import multiparty from 'multiparty';
  10. const excel = require("node-xlsx");
  11. const uuidV1 = require('uuid/v1');
  12. const shareDir = 'public/share/images';
  13. const imgTriggers = ['billsRecharge', 'rationExplanation', 'rationRuleText', 'erratumRecord'];
  14. class billsPermContr extends baseController {
  15. getCurrentUniqId(req, res) {
  16. billsController.getCurrentUniqId(req, res);
  17. }
  18. getBills(req, res) {
  19. billsController.getBills(req, res);
  20. }
  21. createBills(req, res) {
  22. billsController.createBills(req, res);
  23. }
  24. updatePNId(req, res) {
  25. billsController.updatePNId(req, res);
  26. }
  27. upMove(req, res) {
  28. billsController.upMove(req, res);
  29. }
  30. downMove(req, res) {
  31. billsController.downMove(req, res);
  32. }
  33. upLevel(req, res) {
  34. billsController.upLevel(req, res);
  35. }
  36. downLevel(req, res) {
  37. billsController.downLevel(req, res);
  38. }
  39. updateBills(req, res) {
  40. billsController.updateBills(req, res);
  41. }
  42. updateSectionInfo(req, res) {
  43. billsController.updateSectionInfo(req, res);
  44. }
  45. updateBillsArr(req, res) {
  46. billsController.updateBillsArr(req, res);
  47. }
  48. removeTotal(req, res) {
  49. billsController.removeTotal(req, res);
  50. }
  51. updateSerialNo(req, res) {
  52. billsController.updateSerialNo(req, res);
  53. }
  54. pasteBills(req, res) {
  55. billsController.pasteBills(req, res);
  56. }
  57. updateRecharge(req, res) {
  58. billsController.updateRecharge(req, res);
  59. }
  60. pasteRel(req, res) {
  61. billsController.pasteRel(req, res);
  62. }
  63. deleteBills(req, res) {
  64. billsController.deleteBills(req, res);
  65. }
  66. isUsed(req, res) {
  67. billsController.isUsed(req, res);
  68. }
  69. transferRecharge(req, res) {
  70. billsController.transferRecharge(req, res);
  71. }
  72. /*
  73. * 导入标准清单(确定节点结构:深度数组)
  74. * */
  75. importBills(req, res) {
  76. let form = new multiparty.Form({ uploadDir: './public' });
  77. const allowHeader = ['application/vnd.ms-excel', 'application/vnd.openxmlformats-officedocument.spreadsheetml.sheet'];
  78. let uploadFullName;
  79. form.parse(req, async function (err, fields, files) {
  80. try {
  81. const file = typeof files.file !== 'undefined' ? files.file[0] : null;
  82. if (err || !file) {
  83. throw '上传失败。';
  84. }
  85. if (file.headers['content-type'] === undefined || allowHeader.indexOf(file.headers['content-type']) < 0) {
  86. throw '不支持该类型';
  87. }
  88. const billsLibId = typeof fields.billsLibId !== 'undefined' && fields.billsLibId.length > 0 ? fields.billsLibId[0] : null;
  89. if (!billsLibId) {
  90. throw '请选择一个清单库。';
  91. }
  92. let hasData = await billsLibDao.hasData(billsLibId);
  93. if (hasData) {
  94. throw '请新建一个新的清单库,或删除库中的清单后再导入。';
  95. }
  96. // 重命名文件名
  97. uploadFullName = './public/' + file.originalFilename;
  98. fs.renameSync(file.path, uploadFullName);
  99. const sheet = excel.parse(uploadFullName);
  100. if (sheet[0] === undefined || sheet[0].data === undefined || sheet[0].data.length <= 0) {
  101. throw 'excel没有对应数据';
  102. }
  103. //插入清单
  104. await billsLibDao.importBills(billsLibId, sheet[0].data);
  105. // 删除文件
  106. if (uploadFullName && fs.existsSync(uploadFullName)) {
  107. fs.unlinkSync(uploadFullName);
  108. }
  109. res.json({ error: 0, data: null, msg: '' });
  110. } catch (err) {
  111. console.log(err);
  112. // 删除文件
  113. if (uploadFullName && fs.existsSync(uploadFullName)) {
  114. fs.unlinkSync(uploadFullName);
  115. }
  116. res.json({ error: 1, data: null, msg: err });
  117. }
  118. });
  119. }
  120. /*
  121. *上传图片
  122. * */
  123. uploadImg(req, res) {
  124. let uploadDir = path.join(req.app.locals.rootDir, shareDir);
  125. let form = new multiparty.Form({ uploadDir: uploadDir });
  126. form.parse(req, async function (err, fields, files) {
  127. try {
  128. const file = typeof files.file !== 'undefined' ? files.file[0] : null;
  129. if (err || !file) {
  130. throw '上传失败';
  131. }
  132. //触发上传图片的地方
  133. const trigger = typeof fields.trigger !== 'undefined' && fields.trigger.length > 0 ? fields.trigger[0] : null;
  134. if (!trigger || !imgTriggers.includes(trigger)) {
  135. throw '该操作没有上传权限'
  136. }
  137. if (!fs.existsSync(uploadDir)) {
  138. fs.mkdirSync(uploadDir);
  139. }
  140. //根据触发源放置文件到相关文件夹
  141. let triggerPath = path.join(uploadDir, trigger);
  142. if (!fs.existsSync(triggerPath)) {
  143. fs.mkdirSync(triggerPath);
  144. }
  145. //文件后缀
  146. let px = file.originalFilename.split('.').pop();
  147. //时间戳重命名图片并移动文件
  148. let newFileName = Date.now() + '.' + px;
  149. if (fs.existsSync(newPath)) {
  150. newFileName += uuidV1();
  151. }
  152. let newPath = path.join(triggerPath, newFileName);
  153. fs.renameSync(file.path, newPath);
  154. //返回图片域名后的url
  155. res.json({ error: 0, data: `${shareDir}/${trigger}/${newFileName}`, message: 'success' });
  156. } catch (err) {
  157. console.log(err);
  158. res.json({ error: 1, data: null, message: err });
  159. }
  160. });
  161. }
  162. /*
  163. * 删除图片
  164. * */
  165. delImg(req, res) {
  166. try {
  167. let data = JSON.parse(req.body.data),
  168. trigger = data.trigger,
  169. url = data.url;
  170. if (!imgTriggers.includes(trigger)) {
  171. throw '该操作没有权限';
  172. }
  173. //拼接完整的删除路径
  174. let delUrl = path.join(req.app.locals.rootDir, url);
  175. fs.unlinkSync(delUrl);
  176. res.json({ error: 0, data: null, message: 'success' });
  177. } catch (err) {
  178. res.json({ error: 1, data: null, message: err });
  179. }
  180. }
  181. /*
  182. * 根据页码加载图片
  183. * 返回总页码和当前页码的图片信息
  184. * */
  185. loadImgs(req, res) {
  186. try {
  187. let data = JSON.parse(req.body.data),
  188. trigger = data.trigger,
  189. page = data.page;
  190. if (!imgTriggers.includes(trigger)) {
  191. throw '该操作没有权限';
  192. }
  193. //每页显示的图片数
  194. const perImgs = 3;
  195. //总的图片信息
  196. let triggerPath = path.join(req.app.locals.rootDir, shareDir, trigger);
  197. if (!fs.existsSync(triggerPath)) {
  198. fs.mkdirSync(triggerPath);
  199. }
  200. let allImgs = fs.readdirSync(triggerPath);
  201. //将图片按照时间排序,降序
  202. allImgs.sort(function (a, b) {
  203. let aV = a.split('.')[0],
  204. bV = b.split('.')[0];
  205. if (aV > bV) {
  206. return -1;
  207. } else if (aV < bV) {
  208. return 1;
  209. }
  210. return 0;
  211. });
  212. let pageCount = Math.ceil(allImgs.length / perImgs) || 1;
  213. //当前页图片信息
  214. let startIdx = (page - 1) * perImgs,
  215. endIdx = startIdx + 3,
  216. currentPageArr = allImgs.slice(startIdx, endIdx),
  217. currentImgsUrl = [];
  218. for (let img of currentPageArr) {
  219. currentImgsUrl.push(`${shareDir}/${trigger}/${img}`);
  220. }
  221. res.json({ error: 0, data: { pageCount: pageCount, currentImgsUrl: currentImgsUrl }, message: 'success' });
  222. } catch (err) {
  223. console.log(err);
  224. res.json({ error: 1, data: { pageCount: 1, currentImgsUrl: [] }, message: err });
  225. }
  226. }
  227. }
  228. export default billsPermContr;