Skip to content

Z
zhichan
Commit 3294c04c by 王昆
Options

gsb

parent 10b0f014
Showing with 100 additions and 80 deletions
laowubao/app/base/db/impl/operator/taxinfoDao.js
...@@ -111,6 +111,15 @@ class TaxinfoDao extends Dao { ...@@ -111,6 +111,15 @@ class TaxinfoDao extends Dao {
return await this.customQuery(sql.join(" "), params); return await this.customQuery(sql.join(" "), params);
} }
async byIdNo(idNo) {
var sql = [];
sql.push("SELECT");
sql.push("*");
sql.push("FROM `tax_info`");
sql.push("WHERE id_no = :idNo");
return await this.customQuery(sql.join(" "), {idNo: idNo});
}
setCondition(sql, params) { setCondition(sql, params) {
if (params.user_id) { if (params.user_id) {
sql.push("AND user_id = :user_id"); sql.push("AND user_id = :user_id");
......
laowubao/app/base/service/impl/operator/taxinfoSve.js
...@@ -2,98 +2,108 @@ const system = require("../../../system"); ...@@ -2,98 +2,108 @@ const system = require("../../../system");
const ServiceBase = require("../../sve.base"); const ServiceBase = require("../../sve.base");
const settings = require("../../../../config/settings"); const settings = require("../../../../config/settings");
var moment = require('moment'); var moment = require('moment');
class TaxinfoService extends ServiceBase { class TaxinfoService extends ServiceBase {
constructor() { constructor() {
super("operator", ServiceBase.getDaoName(TaxinfoService)); super("operator", ServiceBase.getDaoName(TaxinfoService));
} }
/**
* 按月查询
* @param {*} params
*/
async taxinfoListByMonth(params) {
try {
var currentPage = Number(params.currentPage || 1);
var pageSize = Number(params.pageSize || 10);
if (!params.userId) {
return system.getResult(null, `参数错误 userId不能为空`);
} else {
params.user_id = this.trim(params.userId);
}
var where = {};
/** if (params.curDate) {
* 按月查询 let curDate = this.trim(params.curDate);
* @param {*} params let maxDate = moment(curDate, "YYYY-MM").daysInMonth() // 29
*/
async taxinfoListByMonth(params) {
try {
var currentPage = Number(params.currentPage || 1);
var pageSize = Number(params.pageSize || 10);
if(!params.userId){
return system.getResult(null,`参数错误 userId不能为空`);
}else{
params.user_id = this.trim(params.userId);
}
var where = {};
if(params.curDate){ let beginTime = `${curDate}-01 00:00:00`;
let curDate = this.trim(params.curDate); let endTime = `${curDate}-${maxDate} 23:59:59`;
let maxDate = moment(curDate, "YYYY-MM").daysInMonth() // 29
let beginTime = `${curDate}-01 00:00:00`;
let endTime =`${curDate}-${maxDate} 23:59:59`;
where.tax_time = { where.tax_time = {
[this.db.Op.between]:[beginTime, endTime] [this.db.Op.between]: [beginTime, endTime]
}; };
} }
where.user_id=params.user_id; where.user_id = params.user_id;
var orderby = [ var orderby = [
["id", 'desc'] ["id", 'desc']
]; ];
var page = await this.getPageList(currentPage, pageSize, where, orderby); var page = await this.getPageList(currentPage, pageSize, where, orderby);
if (page && page.rows) { if (page && page.rows) {
for (var row of page.rows) { for (var row of page.rows) {
this.handleDate(row, ["tax_time"],null,-8); this.handleDate(row, ["tax_time"], null, -8);
}
}
return system.getResult(page);
} catch (error) {
console.log(error);
return system.getResult(-1,`系统错误 错误信息 ${error}`);
} }
}
return system.getResult(page);
} catch (error) {
console.log(error);
return system.getResult(-1, `系统错误 错误信息 ${error}`);
} }
}
/** /**
* 按ren查询按照人信息 * 按ren查询按照人信息
* @param {*} params * @param {*} params
*/ */
async taxinfoListByUser(params) { async taxinfoListByUser(params) {
try { try {
params.currentPage = Number(params.currentPage || 1); params.currentPage = Number(params.currentPage || 1);
params.pageSize = Number(params.pageSize || 10); params.pageSize = Number(params.pageSize || 10);
let total = await this.dao.countByUser(params); let total = await this.dao.countByUser(params);
if (total === 0) { if (total === 0) {
return {count: 1, rows: []}; return {count: 1, rows: []};
} }
params.startRow = (params.currentPage - 1) * params.pageSize; params.startRow = (params.currentPage - 1) * params.pageSize;
let list = await this.dao.pageByUser(params); let list = await this.dao.pageByUser(params);
if (list) { if (list) {
for (var item of list) { for (var item of list) {
this.handleDate(row, ["tax_time"],null,-8); this.handleDate(row, ["tax_time"], null, -8);
}
}
return {count: total, rows: list};
return system.getResult(page);
} catch (error) {
console.log(error);
return system.getResult(-1,`系统错误 错误信息 ${error}`);
} }
}
return {count: total, rows: list};
return system.getResult(page);
} catch (error) {
console.log(error);
return system.getResult(-1, `系统错误 错误信息 ${error}`);
} }
}
/** /**
* 查询明细 * 查询明细
* @param {}} params * @param {}} params
*/ */
async taxinfoById(params){ async taxinfoById(params) {
try { try {
if(!params.id){ if (!params.id) {
return system.getResult(-1,`参数错误 ID不能为空`); return system.getResult(-1, `参数错误 ID不能为空`);
} }
let info = await this.findById(this.trim(params.id)); let info = await this.findById(this.trim(params.id));
return system.getResult(info);
} catch (error) { if (!info) {
console.log(error); return system.getResultSuccess([]);
return system.getResult(null,`系统错误 错误信息${error}`); }
}
let list = await this.dao.byIdNo(info.id_no) || [];
for (var row of list) {
this.handleDate(row, ["tax_time"], null, -8);
}
return system.getResultSuccess(list);
} catch (error) {
console.log(error);
return system.getResult(null, `系统错误 错误信息${error}`);
} }
}
} }
module.exports = TaxinfoService; module.exports = TaxinfoService;
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment