11 changed files with 1268 additions and 45 deletions
@ -0,0 +1,415 @@ |
|||
'use strict'; |
|||
const moment = require('moment') |
|||
const request = require('superagent'); |
|||
|
|||
module.exports = function (app, opts) { |
|||
|
|||
async function memberList({ |
|||
keywordTarget, keyword, limit, page, state, |
|||
hiredateStart, hiredateEnd, marital, native, workPlace, |
|||
orderBy, orderDirection, |
|||
nowAttendanceTime, |
|||
overtimeDayStatisticStartDate, overtimeDayStatisticendDate, |
|||
overtimeCountStatistic, overtimeCountStatisticStartDate, overtimeCountStatisticendDate, |
|||
vacateDayStatisticStartDate, vacateDayStatisticendDate, |
|||
vacateDurationStatistic, vacateCountStatistic, vacateCountStatisticStartDate, vacateCountStatisticendDate |
|||
}) { |
|||
//const { judgeHoliday } = app.fs.utils
|
|||
const { clickHouse } = app.fs |
|||
const { database: pepEmis } = clickHouse.pepEmis.opts.config |
|||
|
|||
const curDay = moment().format('YYYY-MM-DD') |
|||
const nowTime = moment() |
|||
let whereOption = [] |
|||
let whereFromSelectOption = [] |
|||
let returnEmpty = false |
|||
if (state == 'inOffice') { |
|||
// 在岗
|
|||
//const holidayJudge = await judgeHoliday(curDay)
|
|||
// if (holidayJudge) {
|
|||
// if (
|
|||
// holidayJudge.workday
|
|||
// && nowTime.isAfter(moment(curDay + ' 08:30'))
|
|||
// && nowTime.isBefore(moment(curDay + ' 17:30'))
|
|||
// ) {
|
|||
// // 在工作日的工作时间范围 无请假记录
|
|||
// whereFromSelectOption.push(`vacateStartTime = '1970-01-01 00:00:00.000000'`)
|
|||
// } else {
|
|||
// returnEmpty = true
|
|||
// }
|
|||
// } else {
|
|||
// returnEmpty = true
|
|||
// }
|
|||
} |
|||
if (state == 'dayoff') { |
|||
// 放假
|
|||
// const holidayJudge = await judgeHoliday(curDay)
|
|||
// if (holidayJudge) {
|
|||
// if (
|
|||
// holidayJudge.dayoff || holidayJudge.festivals
|
|||
// ) {
|
|||
// // 在休息日范围内且无加班申请
|
|||
// whereFromSelectOption.push(`overtimeStartTime = '1970-01-01 00:00:00.000000'`)
|
|||
// } else {
|
|||
// returnEmpty = true
|
|||
// }
|
|||
// } else {
|
|||
// returnEmpty = true
|
|||
// }
|
|||
} |
|||
if (returnEmpty) { |
|||
return { |
|||
count: 0, |
|||
rows: [] |
|||
} |
|||
} |
|||
|
|||
let overtimeDayStatisticWhere = [] |
|||
// if (overtimeDayStatisticStartDate) {
|
|||
// overtimeDayStatisticWhere.push(`overtime_day.day >= '${moment(overtimeDayStatisticStartDate).format('YYYY-MM-DD')}'`)
|
|||
// }
|
|||
// if (overtimeDayStatisticendDate) {
|
|||
// overtimeDayStatisticWhere.push(`overtime_day.day <= '${moment(overtimeDayStatisticendDate).format('YYYY-MM-DD')}'`)
|
|||
// }
|
|||
|
|||
let overtimeCountStatisticWhere = [] |
|||
// if (overtimeCountStatisticStartDate) {
|
|||
// overtimeCountStatisticWhere.push(`overtime.start_time >= '${moment(overtimeCountStatisticStartDate).startOf('day').format('YYYY-MM-DD HH:mm:ss')}'`)
|
|||
// }
|
|||
// if (overtimeCountStatisticendDate) {
|
|||
// overtimeCountStatisticWhere.push(`overtime.end_time <= '${moment(overtimeCountStatisticendDate).endOf('day').format('YYYY-MM-DD HH:mm:ss')}'`)
|
|||
// }
|
|||
|
|||
let vacateDayStatisticWhere = [] |
|||
// if (vacateDayStatisticStartDate) {
|
|||
// vacateDayStatisticWhere.push(`vacate_day.day >= '${moment(vacateDayStatisticStartDate).format('YYYY-MM-DD')}'`)
|
|||
// }
|
|||
// if (vacateDayStatisticendDate) {
|
|||
// vacateDayStatisticWhere.push(`vacate_day.day <= '${moment(vacateDayStatisticendDate).format('YYYY-MM-DD')}'`)
|
|||
// }
|
|||
|
|||
let vacateCountStatisticWhere = [] |
|||
// if (vacateCountStatisticStartDate) {
|
|||
// vacateCountStatisticWhere.push(`vacate.start_time >= '${moment(vacateCountStatisticStartDate).startOf('day').format('YYYY-MM-DD HH:mm:ss')}'`)
|
|||
// }
|
|||
// if (vacateCountStatisticendDate) {
|
|||
// vacateCountStatisticWhere.push(`vacate.end_time <= '${moment(vacateCountStatisticendDate).endOf('day').format('YYYY-MM-DD HH:mm:ss')}'`)
|
|||
// }
|
|||
// CRAZY
|
|||
const innerSelectQuery = ` |
|||
FROM member |
|||
INNER JOIN ${pepEmis}.user AS user |
|||
ON member.pep_user_id = user.id |
|||
${keywordTarget == 'number' && keyword ? ` |
|||
AND user.people_code LIKE '%${keyword}%' |
|||
`: ''}
|
|||
${keywordTarget == 'name' && keyword ? ` |
|||
AND user.name LIKE '%${keyword}%' |
|||
`: ''}
|
|||
|
|||
${nowAttendanceTime ? ` |
|||
${state == 'vacate' ? 'INNER' : 'LEFT'} JOIN ( |
|||
SELECT |
|||
pep_user_id, |
|||
any(start_time) AS vacateStartTime, |
|||
any(end_time) AS vacateEndTime |
|||
FROM vacate |
|||
WHERE |
|||
start_time <= '${nowTime.format('YYYY-MM-DD HH:mm:ss')}' |
|||
AND end_time > '${nowTime.format('YYYY-MM-DD HH:mm:ss')}' |
|||
GROUP BY pep_user_id |
|||
) AS hrVacate |
|||
ON hrVacate.pep_user_id = member.pep_user_id |
|||
`: ''}
|
|||
${nowAttendanceTime ? ` |
|||
LEFT JOIN ( |
|||
SELECT |
|||
pep_user_id, |
|||
any(start_time) AS overtimeStartTime, |
|||
any(end_time) AS overtimeEndTime |
|||
FROM overtime |
|||
WHERE |
|||
start_time <= '${nowTime.format('YYYY-MM-DD HH:mm:ss')}' |
|||
AND end_time > '${nowTime.format('YYYY-MM-DD HH:mm:ss')}' |
|||
GROUP BY pep_user_id |
|||
) AS hrOvertime |
|||
ON hrOvertime.pep_user_id = member.pep_user_id |
|||
`: ''}
|
|||
|
|||
${orderBy == 'overtimeTakeRestSum' || |
|||
orderBy == 'overtimePaySum' || |
|||
orderBy == 'overtimeSum' ? |
|||
`LEFT JOIN (
|
|||
SELECT |
|||
overtime.pep_user_id AS pepUserId, |
|||
sum(overtime_day.duration) AS duration |
|||
FROM overtime_day |
|||
INNER JOIN overtime |
|||
ON overtime.id = overtime_day.overtime_id |
|||
${orderBy == 'overtimeTakeRestSum' ? `AND overtime.compensate = '调休'` : ''} |
|||
${orderBy == 'overtimePaySum' ? `AND overtime.compensate = '发放加班补偿'` : ''} |
|||
${overtimeDayStatisticWhere.length ? ` |
|||
WHERE ${overtimeDayStatisticWhere.join(' AND ')} |
|||
`: ''}
|
|||
GROUP BY overtime.pep_user_id |
|||
) AS overtimeDayStatistic |
|||
ON overtimeDayStatistic.pepUserId = member.pep_user_id`: ''}
|
|||
|
|||
${overtimeCountStatistic ? ` |
|||
LEFT JOIN ( |
|||
SELECT |
|||
overtime.pep_user_id AS pepUserId, |
|||
count(pep_process_story_id) AS count |
|||
FROM overtime |
|||
${overtimeCountStatisticWhere.length ? ` |
|||
WHERE ${overtimeCountStatisticWhere.join(' AND ')} |
|||
`: ''}
|
|||
GROUP BY overtime.pep_user_id |
|||
) AS overtimeCountStatistic |
|||
ON overtimeCountStatistic.pepUserId = member.pep_user_id |
|||
`: ''}
|
|||
|
|||
${vacateDurationStatistic || |
|||
orderBy == 'vacateSum' ? |
|||
`LEFT JOIN (
|
|||
SELECT |
|||
vacate.pep_user_id AS pepUserId, |
|||
sum(vacate_day.duration) AS duration |
|||
FROM vacate_day |
|||
INNER JOIN vacate |
|||
ON vacate.id = vacate_day.vacate_id |
|||
${vacateDayStatisticWhere.length ? ` |
|||
WHERE ${vacateDayStatisticWhere.join(' AND ')} |
|||
`: ''}
|
|||
GROUP BY vacate.pep_user_id |
|||
) AS vacateDayStatistic |
|||
ON vacateDayStatistic.pepUserId = member.pep_user_id`: ''}
|
|||
|
|||
${vacateCountStatistic ? ` |
|||
LEFT JOIN ( |
|||
SELECT |
|||
vacate.pep_user_id AS pepUserId, |
|||
count(pep_process_story_id) AS count |
|||
FROM vacate |
|||
${vacateCountStatisticWhere.length ? ` |
|||
WHERE ${vacateCountStatisticWhere.join(' AND ')} |
|||
`: ''}
|
|||
GROUP BY vacate.pep_user_id |
|||
) AS vacateCountStatistic |
|||
ON vacateCountStatistic.pepUserId = member.pep_user_id |
|||
`: ''}
|
|||
WHERE |
|||
member.del = '0' |
|||
${keywordTarget == 'post' && keyword ? ` |
|||
AND user.post IN ( |
|||
SELECT basicDataPost.id |
|||
FROM ${pepEmis}.basicdata_post AS basicDataPost |
|||
where basicDataPost.name LIKE '%${keyword}%' |
|||
) |
|||
` : ''}
|
|||
${keywordTarget == 'dep' && keyword ? ` |
|||
AND user.id IN ( |
|||
SELECT department_user.user |
|||
FROM ${pepEmis}.department_user AS department_user |
|||
INNER JOIN ${pepEmis}.department AS department |
|||
ON department.id = department_user.department |
|||
AND department.name LIKE '%${keyword}%' |
|||
) |
|||
` : ''}
|
|||
${state == 'dimission' ? `AND member.dimission_date IS NOT null` : ''} |
|||
${state == 'onJob' ? `AND member.dimission_date IS null` : ''} |
|||
${whereFromSelectOption.length && nowAttendanceTime ? `AND ${whereFromSelectOption.join('AND')}` : ''} |
|||
${hiredateStart ? ` |
|||
AND member.hiredate >= '${moment(hiredateStart).format('YYYY-MM-DD')}' |
|||
`: ''}
|
|||
${hiredateEnd ? `
|
|||
AND member.hiredate <= '${moment(hiredateEnd).format('YYYY-MM-DD')}' |
|||
` : ''}
|
|||
${marital ? ` |
|||
AND member.marital = '${marital}' |
|||
`: ''}
|
|||
${native ? ` |
|||
AND member.native_place = '${native}' |
|||
`: ''}
|
|||
${workPlace ? ` |
|||
AND member.work_place = '${workPlace}' |
|||
`: ''}
|
|||
` |
|||
|
|||
const userRes = await clickHouse.hr.query(` |
|||
SELECT |
|||
hrMember."member.pep_user_id" AS pepUserId, |
|||
hrMember.*, |
|||
user.name AS userName, |
|||
user.people_code AS userCode, |
|||
basicDataPost.name AS userPost, |
|||
role.name AS roleName, |
|||
role.id AS roleId, |
|||
department.name AS depName, |
|||
department.id AS depId, |
|||
user.job AS userJob, |
|||
user.active_status AS userActiveStatus, |
|||
user.organization AS userOrganization |
|||
FROM ( |
|||
SELECT |
|||
${orderBy == 'overtimeTakeRestSum' |
|||
|| orderBy == 'overtimePaySum' |
|||
|| orderBy == 'overtimeSum' ? ` |
|||
overtimeDayStatistic.duration AS overtimeDayStatisticDuration, |
|||
`: ''}
|
|||
|
|||
${overtimeCountStatistic ? ` |
|||
overtimeCountStatistic.count AS overtimeCount, |
|||
`: ''}
|
|||
|
|||
${orderBy == 'vacateSum' || vacateDurationStatistic ? ` |
|||
vacateDayStatistic.duration AS vacateDayStatisticDuration, |
|||
`: ''}
|
|||
|
|||
${vacateCountStatistic ? ` |
|||
vacateCountStatistic.count AS vacateCount, |
|||
`: ''}
|
|||
|
|||
${nowAttendanceTime ? ` |
|||
hrVacate.vacateStartTime AS vacateStartTime, |
|||
hrVacate.vacateEndTime AS vacateEndTime, |
|||
hrOvertime.overtimeStartTime AS overtimeStartTime, |
|||
hrOvertime.overtimeEndTime AS overtimeEndTime, |
|||
`: ''}
|
|||
|
|||
member.* |
|||
${innerSelectQuery} |
|||
${limit ? `LIMIT ${limit}` : ''} |
|||
${limit && page ? 'OFFSET ' + parseInt(limit) * parseInt(page) : ''} |
|||
) AS hrMember |
|||
|
|||
LEFT JOIN ${pepEmis}.user AS user |
|||
ON pepUserId = user.id |
|||
LEFT JOIN ${pepEmis}.user_role AS user_role |
|||
ON ${pepEmis}.user_role.user = user.id |
|||
LEFT JOIN ${pepEmis}.role AS role |
|||
ON ${pepEmis}.role.id = user_role.role |
|||
LEFT JOIN ${pepEmis}.basicdata_post AS basicDataPost |
|||
ON ${pepEmis}.basicdata_post.id = user.post |
|||
LEFT JOIN ${pepEmis}.department_user AS department_user |
|||
ON department_user.user = user.id |
|||
LEFT JOIN ${pepEmis}.department AS department |
|||
ON department.id = department_user.department |
|||
${whereOption.length ? `WHERE ${whereOption.join(' AND ')}` : ''} |
|||
ORDER BY ${orderBy == 'code' ? |
|||
'user.people_code' |
|||
: orderBy == 'hiredate' |
|||
? 'hrMember."member.hiredate"' |
|||
: orderBy == 'age' |
|||
? 'hrMember."member.birthday"' |
|||
: orderBy == 'overtimeTakeRestSum' |
|||
|| orderBy == 'overtimePaySum' |
|||
|| orderBy == 'overtimeSum' ? |
|||
'hrMember.overtimeDayStatisticDuration' |
|||
: orderBy == 'overtimeCount' ? |
|||
'hrMember.overtimeCount' |
|||
: orderBy == 'vacateSum' ? |
|||
'hrMember.vacateDayStatisticDuration' |
|||
: orderBy == 'vacateCount' ? |
|||
'hrMember.vacateCount' |
|||
: 'user.people_code'} |
|||
${orderDirection || 'ASC'} |
|||
`).toPromise()
|
|||
|
|||
const countRes = await clickHouse.hr.query(` |
|||
SELECT |
|||
count(member.pep_user_id) AS count |
|||
${innerSelectQuery} |
|||
`).toPromise()
|
|||
|
|||
return { |
|||
count: countRes[0].count, |
|||
rows: userRes |
|||
} |
|||
} |
|||
|
|||
async function packageUserData(userRes, option = {}) { |
|||
|
|||
//const { judgeHoliday, } = app.fs.utils
|
|||
let workTime = false |
|||
let dayoffTime = false |
|||
if (option.state) { |
|||
const curDay = moment().format('YYYY-MM-DD') |
|||
const nowTime = moment() |
|||
//const holidayJudge = await judgeHoliday(curDay)
|
|||
// if (holidayJudge) {
|
|||
// if (
|
|||
// holidayJudge.workday
|
|||
// && nowTime.isAfter(moment(curDay + ' 08:30'))
|
|||
// && nowTime.isBefore(moment(curDay + ' 17:30'))
|
|||
// ) {
|
|||
// workTime = true
|
|||
// } else if (holidayJudge.dayoff || holidayJudge.festivals) {
|
|||
// dayoffTime = true
|
|||
// }
|
|||
// }
|
|||
} |
|||
|
|||
let returnD = [] |
|||
let pepUserIds = [-1] |
|||
userRes.rows.forEach(u => { |
|||
let existUser = returnD.find(r => r.pepUserId == u.pepUserId) |
|||
if (existUser) { |
|||
if (u.depId && !existUser.departmrnt.some(d => d.id == u.depId)) { |
|||
existUser.departmrnt.push({ |
|||
id: u.depId, |
|||
name: u.depName |
|||
}) |
|||
} |
|||
if (u.roleId && !existUser.role.some(r => r.id == u.roleId)) { |
|||
existUser.role.push({ |
|||
id: u.roleId, |
|||
name: u.roleName |
|||
}) |
|||
} |
|||
} else { |
|||
let obj = {} |
|||
for (let k in u) { |
|||
let nextKey = k.replace('hrMember.', '') |
|||
.replace('member.', '') |
|||
if (nextKey.includes('_')) { |
|||
nextKey = nextKey.toLowerCase() |
|||
.replace( |
|||
/(_)[a-z]/g, |
|||
(L) => L.toUpperCase() |
|||
) |
|||
.replace(/_/g, '') |
|||
} |
|||
obj[nextKey] = u[k] == '1970-01-01 00:00:00.000000' || u[k] == '1970-01-01 08:00:00.000000' ? null : u[k] |
|||
} |
|||
pepUserIds.push(u.pepUserId) |
|||
console.log("查询到的用户信息：", obj); |
|||
returnD.push({ |
|||
...obj, |
|||
departmrnt: u.depId ? [{ |
|||
id: u.depId, |
|||
name: u.depName |
|||
}] : [], |
|||
role: u.roleId ? [{ |
|||
id: u.roleId, |
|||
name: u.roleName |
|||
}] : [], |
|||
state: option.state ? |
|||
obj['dimissionDate'] ? 'dimission' : |
|||
obj['vacateStartTime'] ? 'vacate' : |
|||
workTime ? 'inOffice' : |
|||
dayoffTime ? 'dayoff' : 'rest' |
|||
: undefined, |
|||
del: undefined, |
|||
pepuserid: undefined |
|||
}) |
|||
} |
|||
}) |
|||
return { packageUser: returnD, pepUserIds } |
|||
} |
|||
|
|||
return { |
|||
memberList, |
|||
packageUserData |
|||
} |
|||
} |
|||
@ -1,6 +1,7 @@ |
|||
'use strict'; |
|||
import * as reserveItem from './reserve-item'; |
|||
|
|||
import * as salersReport from './salers-report'; |
|||
export default { |
|||
...reserveItem |
|||
...reserveItem, |
|||
...salersReport |
|||
} |
|||
@ -0,0 +1,17 @@ |
|||
'use strict'; |
|||
|
|||
import { ApiTable, basicAction } from '$utils' |
|||
|
|||
export function getSalesList(query) {//查询
|
|||
return (dispatch) => basicAction({ |
|||
type: "get", |
|||
dispatch: dispatch, |
|||
actionType: "GET_SALES_MENBER_LIST", |
|||
query: query, |
|||
url: `${ApiTable.getSalesList}`, |
|||
msg: { option: "查询销售人员列表" }, |
|||
reducer: { name: "SalesMemberList", params: { noClear: true } }, |
|||
}); |
|||
} |
|||
|
|||
|
|||
Loading…
Reference in new issue