wangrong
2022-03-28 95f56ca3c417424a826740eecddec0c9d3fdb17f
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
import { Inject, Provide } from '@midwayjs/decorator';
import { BaseService, ICoolCache, } from '@cool-midway/core';
import * as _ from 'lodash';
import { MysqlUtil } from '../../utils/mysqlutil';
// 引入读写核心模块
 
 
/**
 * 系统用户
 */
@Provide()
export class DataService extends BaseService {
 
  @Inject('cool:cache')
  coolCache: ICoolCache;
 
  @Inject()
  mysqlUtil: MysqlUtil;
 
  /**
   * 分页查询
   * @param query
   */
  async getData(query) {
    // const { keyWord, status, departmentIds = [] } = query;
    // const permsDepartmentArr = await this.baseSysPermsService.departmentIds(
    //   this.ctx.admin.userId
    // ); // 部门权限
    const bidsql = `select * from t_sys_business_config where id_='${query.bid}' limit 0,1`;    
    const bid_obj_ = await this.nativeQuery(bidsql);
    console.log(bid_obj_)
    let sqlObj = this.mysqlUtil.create_sql(bid_obj_[0], query?.pageindex || null , query?.pagesize || null, query);
    if (sqlObj?.status == 0) {
        return sqlObj?.msg;
    }
    return this.nativeQuery(sqlObj?.sql, query);
  }
 
 
  /**
   * 分页查询
   * @param query
   */
   async getDataByNative(query) {
    // const { keyWord, status, departmentIds = [] } = query;
    // const permsDepartmentArr = await this.baseSysPermsService.departmentIds(
    //   this.ctx.admin.userId
    // ); // 部门权限
    const bidsql = `select * from t_sys_business_config where id_='${query.bid}' limit 0,1`;    
    const bid_obj_ = await this.nativeQuery(bidsql);
    console.log(bid_obj_)
    let sqlObj = this.mysqlUtil.create_sql(bid_obj_[0], query?.pageindex || null , query?.pagesize || null, query);
    if (sqlObj?.status == 0) {
        return sqlObj?.msg;
    }
    return this.nativeQuery(sqlObj?.sql)
  }  
 
  /**
   * 分页查询
   * @param query
   */
   async updateData(query) {
    // const { keyWord, status, departmentIds = [] } = query;
    // const permsDepartmentArr = await this.baseSysPermsService.departmentIds(
    //   this.ctx.admin.userId
    // ); // 部门权限
    const bidsql = `select * from t_sys_business_config where id_='${query.bid}' limit 0,1`;    
    const bid_obj_ = await this.nativeQuery(bidsql);
    let sqlObj = this.mysqlUtil.create_sql(bid_obj_[0], query?.pageindex || null , query?.pagesize || null, query);
    if (sqlObj?.status == 0) {
        return sqlObj?.msg;
    }
    return this.sqlRenderPage(sqlObj?.sql, query);
  }
 
}