Inspection/api/app/lib/controllers/patrolManage/patrolRecord.js

'use strict';

const moment = require("moment");

async function findPatrolRecord(ctx, next) {
    let rslt = [];
    let error = { name: 'FindError', message: '获取巡检记录失败' };
    try {
        const models = ctx.fs.dc.models;
        const { startTime, endTime, alarm, patrolPlanId, pointId } = ctx.params;
        // patrolPlanId传all查所有
        let generalInclude = [{
            model: models.PatrolPlan,
            attributes: ['name']
        },
        {
            model: models.PatrolRecordIssueHandle
        }
        ]
        if (patrolPlanId == 'all') {
            /* 如果有startTime && endTime，查询所有符合条件的数据 */
            if (startTime !== 'null' && endTime !== 'null') {
                if (pointId !== 'null') {
                    if (alarm == 'null') {
                        rslt = await models.PatrolRecord.findAll({
                            where: {
                                inspectionTime: { $between: [startTime, endTime] },
                                pointId: { $in: pointId.split(',') }
                            },
                            include: generalInclude
                        });
                    } else {
                        rslt = await models.PatrolRecord.findAll({
                            where: {
                                alarm,
                                inspectionTime: { $between: [startTime, endTime] },
                                pointId: { $in: pointId.split(',') }
                            },
                            include: generalInclude
                        });
                    }
                } else {
                    if (alarm == 'null') {
                        rslt = await models.PatrolRecord.findAll({
                            where: {
                                inspectionTime: { $between: [startTime, endTime] }
                            },
                            include: generalInclude.concat([{
                                model: models.Point,
                                attributes: ['id', 'name']
                            }])
                        });
                    } else {
                        rslt = await models.PatrolRecord.findAll({
                            where: {
                                alarm, inspectionTime: { $between: [startTime, endTime] }
                            },
                            include: generalInclude
                        });
                    }
                }
            } else {
                /* 如果没有startTime && endTime，查询每个点位最新一条符合条件的数据 */
                let a = []
                if (pointId !== 'null') {
                    a = await models.PatrolRecord.findAll({
                        where: { pointId: { $in: pointId.split(',') } },
                        include: generalInclude
                    });

                }
                rslt = pointId.split(',').map(i => {
                    return a.filter(t => t.pointId == i).sort((a, b) => b.id - a.id)[0] || null
                })
            }
        } else {
            if (startTime !== 'null' && endTime !== 'null') {
                if (pointId !== 'null') {
                    rslt = await models.PatrolRecord.findAll({
                        where: {
                            patrolPlanId: { $in: patrolPlanId.split(',') },
                            alarm,
                            inspectionTime: { $between: [startTime, endTime] },
                            pointId: { $in: pointId.split(',') }
                        },
                        include: generalInclude
                    });
                } else {
                    rslt = await models.PatrolRecord.findAll({
                        where: {
                            patrolPlanId: { $in: patrolPlanId.split(',') },
                            alarm,
                            inspectionTime: { $between: [startTime, endTime] }
                        },
                        include: generalInclude
                    });
                }

            } else {
                let a = []
                /* 如果没有startTime && endTime，查询每个点位最新一条符合条件的数据 */
                if (pointId !== 'null') {
                    a = await models.PatrolRecord.findAll({
                        where: {
                            patrolPlanId: { $in: patrolPlanId.split(',') },
                            pointId: { $in: pointId.split(',') }
                        },
                        include: generalInclude
                    });
                } else {
                    a = await models.PatrolRecord.findAll({
                        where: {
                            patrolPlanId: { $in: patrolPlanId.split(',') }
                        },
                        include: generalInclude
                    });
                }

                rslt = pointId.split(',').map(i => {
                    return a.filter(t => t.pointId == i).sort((a, b) => b.id - a.id)[0] || null
                })
            }
        }
        let userInfo = ctx.fs.api.userInfo;
        rslt = rslt.filter(f => f)
        if (userInfo.username != 'SuperAdmin') {
            if (userInfo.structure) {
                rslt = rslt.filter(s => userInfo.structure.find(x => x == s.points.project.id))
            } else {
                rslt = []
            }
        }
        ctx.status = 200;
        ctx.body = rslt;
        error = null
    } catch (error) {
        ctx.fs.logger.error(`path: ${ctx.path}, error: ${error}`);
        ctx.status = 400;
        ctx.body = {
            "message": "获取巡检记录失败"
        }
    }
}

async function findPatrolRecordUnlicensed(ctx, next) {
    let rslt = [];
    let error = { name: 'FindError', message: '获取巡检记录失败' };
    try {
        const models = ctx.fs.dc.models;
        const { startTime, endTime } = ctx.query;
        const options = {
            where: {}
        }
        if (startTime && endTime) {
            options.where.inspectionTime = { $between: [startTime, endTime] };
        }
        rslt = await models.PatrolRecord.findAll(options);
        ctx.status = 200;
        ctx.body = rslt;
    } catch (error) {
        ctx.fs.logger.error(`path: ${ctx.path}, error: ${error}`);
        ctx.status = 400;
        ctx.body = {
            "message": "获取巡检记录失败"
        }
    }
}

async function findPointCurPatrolRecord(ctx, next) {
    let rslt = [];
    let error = { name: 'FindError', message: '获取巡检记录失败' };
    try {
        const models = ctx.fs.dc.models;
        const { pointId } = ctx.params;
        const options = {
            where: { pointId },
            order: [['inspectionTime', 'desc']],
            limit: 1,
        }
        rslt = await models.PatrolRecord.findAll(options);
        ctx.status = 200;
        ctx.body = rslt;
    } catch (error) {
        ctx.fs.logger.error(`path: ${ctx.path}, error: ${error}`);
        ctx.status = 400;
        ctx.body = {
            "message": "获取巡检记录失败"
        }
    }
}

async function addPatrolRecord(ctx, next) {
    let error = { name: 'addError', message: '新增巡检记录失败' };
    const transaction = await ctx.fs.dc.orm.transaction();
    try {
        const models = ctx.fs.dc.models;
        const data = ctx.request.body;
        let { patrolPlanId, inspectionTime, points, alarm, pointId, projectId } = data
        const pointRecord = await models.PatrolRecord.findAll({
            where: { pointId: pointId },
            order: [['inspectionTime', 'desc']],
            attributes: ['inspectionTime'],
        });
        const lastInspectionTime = pointRecord.length ? pointRecord[0].dataValues.inspectionTime : null;

        const recordRes = await models.PatrolRecord.create(
            // record
            {
                patrolPlanId: patrolPlanId,
                lastInspectionTime,
                inspectionTime,
                points,
                alarm,
                pointId: pointId,
                projectId
            }
            , {
                transaction
            });

        if (alarm) {
            await models.PatrolRecordIssueHandle.create({
                patrolRecordId: recordRes.id,
                state: 1,
            }, { transaction });
        }
        // 更新巡检次数统计
        const curPlanRecord = await models.PatrolRecord.findAndCountAll({
            where: { patrolPlanId: patrolPlanId }
        });
        const patrolCount = curPlanRecord.count + 1;
        // 更新下次巡检时间
        const curPatrolPlan = await models.PatrolPlan.findOne({
            where: { id: patrolPlanId }
        });
        const frequency = Number(curPatrolPlan.frequency.split('次')[0]);
        const unit = curPatrolPlan.frequency.split('/')[1];
        const sTime = moment().startOf(unit === '天' ? 'day' : unit === '周' ? 'isoWeek' : 'month');
        const eTime = moment().endOf(unit === '天' ? 'day' : unit === '周' ? 'isoWeek' : 'month');
        const filterRecord = curPlanRecord.rows.filter(r => moment(r.inspectionTime).diff(sTime) >= 0 && moment(r.inspectionTime).diff(eTime) <= 0);
        const groupRecord = filterRecord.group(({ pointId }) => pointId);
        let isComplete = true;
        for (const p of curPatrolPlan.points) {
            if (!groupRecord[p.id]) {
                if (pointId === p.id && frequency === 1) {
                    continue;
                } else {
                    isComplete = false;
                    continue;
                }
            } else {
                if ((pointId === p.id ? groupRecord[p.id].length + 1 : groupRecord[p.id].length) < frequency) {
                    isComplete = false;
                    continue;
                }
            }
        }

        await models.PatrolPlan.update({ patrolCount, nextTime: isComplete ? eTime.format() : sTime.format() }, {
            where: { id: patrolPlanId },
            transaction
        })

        await transaction.commit();
        ctx.status = 204;
        error = null
    } catch (error) {
        await transaction.rollback();
        ctx.fs.logger.error(`path: ${ctx.path}, error: ${error}`);
        ctx.status = 400;
        ctx.body = {
            "message": '新增巡检记录失败'
        }
    }
}

async function getPatrolRecordIssueHandle(ctx) {
    try {
        const { models } = ctx.fs.dc;
        const { userId, userInfo } = ctx.fs.api

        const { type, pointId, startTime, endTime } = ctx.query

        let findOption = {
            where: {
                $or: []
            },
            include: [{
                model: models.PatrolRecord,
                where: {

                }
            }]
        }

        if (pointId) {
            findOption.include[0].where.pointId = { $in: pointId.split(',') }
        }
        if (startTime && endTime) {
            findOption.where.createTime = {
                $between: [moment(parseInt(startTime)).format(), moment(parseInt(endTime)).format()]
            }
        }

        let isSuperA = userInfo.username == 'SuperAdmin'
        let focusStruct = userInfo.structure || []

        if (!isSuperA) {
            findOption.include[0].where.points = {
                project: {
                    id: { $in: focusStruct }
                }
            }
        }

        if (type == 'backlog') {   // 待办

            if (userInfo && userInfo.userResources.includes('ZHIDINGJIHUA')) {
                findOption.where['$or'].push({ state: 1 })
                findOption.where['$or'].push({ state: 3 })
            }
            // 有审批权限且关注此结构物
            if (userInfo && userInfo.userResources.includes('SHENHE')) {
                findOption.where['$or'].push({ state: 2 })
            }
            findOption.where['$or'].push({ state: 4, repairPerson: { id: userId } })
            findOption.where['$or'].push({ state: 5, checkPerson: { id: userId } })
            findOption.where['$or'].push({ state: 7, repairPerson: { id: userId } })
        } else if (type == 'haveDone') {
            // 已办
            findOption.where['$or'].push({ state: { $notIn: [1, 2] }, creator: { id: userId } })
            findOption.where['$or'].push({ state: { $gt: 2 }, approvePerson: { id: userId } })
            findOption.where['$or'].push({ state: { $gt: 4, $ne: 7 }, repairPerson: { id: userId } })
            findOption.where['$or'].push({ state: { $gt: 5 }, checkPerson: { id: userId } })
        }

        const res = await models.PatrolRecordIssueHandle.findAll(findOption)

        ctx.status = 200;
        ctx.body = res
    } catch (error) {
        ctx.fs.logger.error(`path: ${ctx.path}, error: ${error}`);
        ctx.status = 400;
        ctx.body = {
            message: typeof error == 'string' ? error : undefined
        }
    }
}

async function getPatrolRecordIssueHandleById(ctx) {
    try {
        const { models } = ctx.fs.dc;
        const { id } = ctx.params

        const res = await models.PatrolRecordIssueHandle.findOne({
            where: {
                id
            },
            include: [{
                model: models.PatrolRecord
            }]
        })

        ctx.status = 200;
        ctx.body = res
    } catch (error) {
        ctx.fs.logger.error(`path: ${ctx.path}, error: ${error}`);
        ctx.status = 400;
        ctx.body = {
            message: typeof error == 'string' ? error : undefined
        }
    }
}

// 新建维修处理计划成功
function addPatrolRecordIssueHandle(opts) {
    return async function (ctx, next) {

        const models = ctx.fs.dc.models;
        try {
            let rslt = ctx.request.body;
            await models.PatrolRecordIssueHandle.create(Object.assign({}, rslt))
            ctx.status = 204;
            ctx.body = { message: '新建维修处理计划成功' }
        } catch (error) {
            ctx.fs.logger.error(`path: ${ctx.path}, error: ${error}`);
            ctx.status = 400;
            ctx.body = { message: '新建修处理计划失败' }
        }
    }
}


// 修改维修处理计划
function editPatrolRecordIssueHandle(opts) {
    return async function (ctx, next) {

        try {
            const models = ctx.fs.dc.models;
            const { id } = ctx.params;
            const body = ctx.request.body;
            await models.PatrolRecordIssueHandle.update(
                body,
                { where: { id: id, } }
            )
            ctx.status = 204;
            ctx.body = { message: '修改维修处理计划成功' }
        } catch (error) {
            ctx.fs.logger.error(`path: ${ctx.path}, error: ${error}`);
            ctx.status = 400;
            ctx.body = { message: '修改维修处理计划失败' }
        }
    }
}

Array.prototype.group = function (callback, thisArg = null) {
    // 参数合法性判断
    if (typeof callback !== "function") {
        throw new TypeError(`${callback} is not a function`);
    }
    const arr = this;
    const length = this.length;
    const grouper = Object.create(null);

    for (let i = 0; i < length; i++) {
        const key = callback.call(thisArg, arr[i], i, arr)
        if (!grouper[key]) {
            grouper[key] = [arr[i]]
        } else {
            grouper[key].push(arr[i])
        }
    }
    return grouper;
};

module.exports = {
    findPatrolRecord,
    findPatrolRecordUnlicensed,
    findPointCurPatrolRecord,
    addPatrolRecord,
    getPatrolRecordIssueHandle,
    getPatrolRecordIssueHandleById,
    addPatrolRecordIssueHandle,
    editPatrolRecordIssueHandle
}