增加合同分析接口

Aaron.Liu
1 parent cd137547
Showing 3 changed files with 27 additions and 0 deletions Show diff stats
app/controller/contract.js
app/router.js
app/service/contract.js
@@ -39,6 +39,22 @@ class ContractController extends Controller {
       };
     }
   }
+  async analysis() {
+    const ctx = this.ctx;
+    const param = qs.parse(this.ctx.query);
+    try {
+      const result = await ctx.service.contract.analysis(param);
+      this.ctx.body = {
+        result,
+        success: true,
+      };
+    } catch (error) {
+      this.ctx.body = {
+        success: false,
+        error,
+      };
+    }
+  }
   async add() {
     const ctx = this.ctx;
     const id = uuid.v4();
@@ -27,6 +27,7 @@ module.exports = app =&gt; {
   router.put('/customer', controller.customer.update);
   router.post('/customer/delete', controller.customer.remove);
   // 合同管理
+  router.get('/contract/analysis', controller.contract.analysis);
   router.get('/contract/list', controller.contract.list);
   router.get('/contract/:id', controller.contract.info);
   router.post('/contract', controller.contract.add);
@@ -5,6 +5,16 @@ const objExclude = require(&#39;../util/common&#39;).objExclude;
 const objToQuery = require('../util/common').objToQuery;
  
 class ContractService extends Service {
+  async analysis(data) {
+    const where = objToQuery(data);
+    const sql = `
+      select * from contract
+      ${where !== '' ? `where ${where}` : ''}
+    `;
+    console.log(sql);
+    const result = await this.app.mysql.query(sql);
+    return result;
+  }
   async count() {
     const result = await this.app.mysql.query('select count(*) as total from contract');
     return result;
...	...	@@ -39,6 +39,22 @@ class ContractController extends Controller {
39	39	};
40	40	}
41	41	}
	42	+ async analysis() {
	43	+ const ctx = this.ctx;
	44	+ const param = qs.parse(this.ctx.query);
	45	+ try {
	46	+ const result = await ctx.service.contract.analysis(param);
	47	+ this.ctx.body = {
	48	+ result,
	49	+ success: true,
	50	+ };
	51	+ } catch (error) {
	52	+ this.ctx.body = {
	53	+ success: false,
	54	+ error,
	55	+ };
	56	+ }
	57	+ }
42	58	async add() {
43	59	const ctx = this.ctx;
44	60	const id = uuid.v4();
...	...
...	...	@@ -27,6 +27,7 @@ module.exports = app => {
27	27	router.put('/customer', controller.customer.update);
28	28	router.post('/customer/delete', controller.customer.remove);
29	29	// 合同管理
	30	+ router.get('/contract/analysis', controller.contract.analysis);
30	31	router.get('/contract/list', controller.contract.list);
31	32	router.get('/contract/:id', controller.contract.info);
32	33	router.post('/contract', controller.contract.add);
...	...
...	...	@@ -5,6 +5,16 @@ const objExclude = require('../util/common').objExclude;
5	5	const objToQuery = require('../util/common').objToQuery;
6	6
7	7	class ContractService extends Service {
	8	+ async analysis(data) {
	9	+ const where = objToQuery(data);
	10	+ const sql = `
	11	+ select * from contract
	12	+ ${where !== '' ? `where ${where}` : ''}
	13	+ `;
	14	+ console.log(sql);
	15	+ const result = await this.app.mysql.query(sql);
	16	+ return result;
	17	+ }
8	18	async count() {
9	19	const result = await this.app.mysql.query('select count(*) as total from contract');
10	20	return result;
...	...