info_admin/app/service/infoService.js

'use strict';

const Service = require('egg').Service;
const gm = require('gm');
const qr = require('qr-image');
const fs = require('fs');
const path = require('path');
const awaitWriteStream = require('await-stream-ready').write;

class InfoService extends Service {
  // 单条查询
  async one(id) {
    const { model } = this.ctx;
    return await model.InfoModel.findById(id);
  }

  // 不分页查询
  async list(data) {
    const { model } = this.ctx;
    return await model.InfoModel.find(data).sort({ time: -1 });
  }

  // 根据户id查询
  async listByFid(data) {
    const { model } = this.ctx;
    return await model.InfoModel.find(data);
  }

  // 根据身份证号查询
  async listByNumber(data) {
    const { model } = this.ctx;
    return await model.InfoModel.find(data);
  }

  // 分页查询
  async listForPage(data) {
    const { model } = this.ctx;
    const page = data.page;
    const rows = Number.parseInt(data.rows) || this.app.config.defaultPageSize;
    delete data.page;
    delete data.rows;

    const where = {};
    if (data.dept1) {
      where.dept1 = data.dept1;// 省
    }
    if (data.dept2) {
      where.dept2 = data.dept2; // 市
    }
    if (data.dept3) {
      where.dept3 = data.dept3; // 区
    }
    if (data.dept4) {
      where.dept4 = data.dept4; // 乡
    }
    if (data.dept5) {
      where.dept5 = data.dept5; // 社区
    }
    // userid.loginName
    if (data.cjname) {
      // where.userName = { $regex: data.cjname }; // 管理员
      // where['userInfo.loginName'] = { $regex: data.cjname };
      const result = await model.SysUserModel.find({ loginName: { $regex: data.cjname } });
      if (result.length > 0) {
        where.userid = result[0]._id;
      } else {
        return '';
      }
    }
    // 状态
    if (data.status) {
      where.status = '' + data.status;
    }
    // 老人常用联系电话
    if (data.phone) {
      where.phone = { $regex: data.phone };
    }
    // 老人姓名
    if (data.name) {
      where.name = { $regex: data.name };
    }
    // 老人年龄
    if (data.age) {
      const myDate = new Date();
      const year = myDate.getFullYear();
      const month = (myDate.getMonth() + 1) > 9 ? (myDate.getMonth() + 1) : '0' + (myDate.getMonth() + 1);
      const day = myDate.getDate() > 9 ? (myDate.getDate()) : '0' + (myDate.getDate());
      if (data.age > 0) {
        where.idNumber = { $ne: '' };
        where.birthday = { $lte: '' + year + month + day - (data.age * 10000) };
      } else {
        where.idNumber = { $ne: '' };
        where.birthday = { $gte: '' + year + month + day - (-data.age * 10000) };
      }
    }
    // 关爱服务需求
    if (data.demand) {
      // console.log('oldtype', data.oldType)
      if (data.demand.indexOf(',') > -1) {
        const ts = data.demand.split(',');
        where.demand = { $in: ts };
      } else {
        where.demand = { $in: data.demand };
      }
    }
    // 老人类别
    if (data.oldType) {
      // console.log('oldtype', data.oldType)
      if (data.oldType.indexOf(',') > -1) {
        const ts = data.oldType.split(',');
        where.oldType = { $in: ts };
      } else {
        where.oldType = { $in: data.oldType };
      }
    }
    // 离线采集
    if (data.online) {
      if (data.online == 'false') {
        where.online = data.online;
      }
      if (data.online == 'true') {
        // where.online = data.online;
        where.$or = [{ online: { $exists: false } }, { online: data.online }];
      }
    }
    // 身份证号码搜索
    if (data.idNumber) {
      where.idNumber = { $regex: data.idNumber };
    }
    // 老年人能力状况
    if (data.ability) {
      where.ability = data.ability;
    }
    // 时间
    if (data.startTime && data.endTime) {
      where.time = { $gte: data.startTime + ' 00:00:00', $lt: data.endTime + ' 23:59:59' };
    }
    // if (data.bind) {
    //   // where['fid.openId'] = { $exists: true, $ne: [] };
    //   where['dept1.name'] = { $regex: '吉林省' };
    // }

    // if (data.demand) {
    //   const demand = data.demand.split(',');
    //   where.$and = [];
    //   demand.forEach(item => {
    //     where.$and.push({ demand: { $regex: item } });
    //   });
    // }
    // if (data.oldType) {
    //   const oldType = data.oldType.split(',');
    //   if (!where.$and) {
    //     where.$and = [];
    //   }
    //   oldType.forEach(item => {
    //     where.$and.push({ oldType: { $regex: item } });
    //   });
    // }

    this.ctx.logger.info('条件', where);


    const pop = [
      {
        path: 'userid',
        select: 'loginName userName',
      },
      {
        path: 'dept1',
        select: 'name',
      },
      {
        path: 'dept2',
        select: 'name',
      },
      {
        path: 'dept3',
        select: 'name',
      },
      {
        path: 'dept4',
        select: 'name',
      },
      {
        path: 'dept5',
        select: 'name',
      },
      // {
      //   path: 'fid',
      //   select: 'openId',
      // },
    ];
    const total = await model.InfoModel.find(where).populate(pop).countDocuments();
    const result = await model.InfoModel.find(where).populate(pop).skip((page - 1) * rows)
      .limit(rows)
      .sort({ time: -1 });
    return {
      count: total,
      list: result,
    };
  }

  // 添加
  async add(data) {
    const { model } = this.ctx;
    const result = await model.InfoModel.create(data);
    return result;
  }

  // 修改
  async update(id, data) {
    const { model } = this.ctx;
    const status = data.status;
    delete data.status;
    // console.log('data', data);
    if (data.idNumber && data.idNumber !== '') {
      const birthday = data.idNumber.substr(6, 8);
      data.birthday = birthday;
    }
    // 身份证修改为空时，将birthday置空
    if (data.idNumber == '') {
      data.birthday = '';
    }
    data.time = Date.now();
    if (data.health) {
      data.health = JSON.parse(data.health);
    }
    if (data.disabilityCategory) {
      data.disabilityCategory = JSON.parse(data.disabilityCategory);
    }
    if (data.majorDiseases) {
      data.majorDiseases = JSON.parse(data.majorDiseases);
    }
    if (data.oldType) {
      data.oldType = JSON.parse(data.oldType);
    }
    if (data.demand) {
      data.demand = JSON.parse(data.demand);
    }
    if (data.lookAfter) {
      data.lookAfter = JSON.parse(data.lookAfter);
    }
    if (data.accompany) {
      data.accompany = JSON.parse(data.accompany);
    }
    if (data.rescueState) {
      data.rescueState = JSON.parse(data.rescueState);
    }
    if (data.sourceOfIncome) {
      data.sourceOfIncome = JSON.parse(data.sourceOfIncome);
    }
    const result = await model.InfoModel.updateOne({ _id: id }, data);
    // 修改采集状态
    delete data.time;
    await this.ctx.service.infoService.updateStatus(id, data);
    return result;
  }

  // 检查采集状态
  async checkInfoStatus(id) {
    const ctx = this.ctx;
    const flag = true;
    const oneInfo = await this.ctx.service.infoService.one(id);
    if (oneInfo) {
      // 姓名
      if (oneInfo.name && oneInfo.name !== '') {
      } else {
        ctx.logger.info('name', flag);
        console.log('name', flag);
        return flag;
      }
      // 性别
      if (oneInfo.sex && oneInfo.sex !== '') {
      } else {
        ctx.logger.info('sex', flag);
        console.log('sex', flag);
        return flag;
      }
      // 民族
      if (oneInfo.nation && oneInfo.nation !== '') {
      } else {
        ctx.logger.info('nation', flag);
        console.log('nation', flag);
        return flag;
      }
      // 身份证
      if (oneInfo.idNumber && oneInfo.idNumber !== '') {
      } else {
        ctx.logger.info('idNumber', flag);
        console.log('idNumber', flag);
        return flag;
      }
      // 生日
      if (oneInfo.birthday && oneInfo.birthday !== '') {
      } else {
        ctx.logger.info('birthday', flag);
        console.log('birthday', flag);
        return flag;
      }
      // 电话
      if (oneInfo.phone && oneInfo.phone !== '') {
      } else {
        ctx.logger.info('phone', flag);
        console.log('phone', flag);
        return flag;
      }
      // 户籍地址
      if (oneInfo.nativePlace && oneInfo.nativePlace !== '') {
      } else {
        ctx.logger.info('nativePlace', flag);
        console.log('nativePlace', flag);
        return flag;
      }
      // 现居地址
      if (oneInfo.address && oneInfo.address !== '') {
      } else {
        ctx.logger.info('address', flag);
        console.log('address', flag);
        return flag;
      }
      // 婚姻及配偶情况
      if (oneInfo.partnerState && oneInfo.partnerState !== '') {
        if (oneInfo.partnerState == '已婚') {
          if (oneInfo.partnerName && oneInfo.partnerName !== '') {
          } else {
            ctx.logger.info('partnerName', flag);
            console.log('partnerName', flag);
            return flag;
          }
          if (oneInfo.partnerIdNumber && oneInfo.partnerIdNumber !== '') {
          } else {
            ctx.logger.info('partnerIdNumber', flag);
            console.log('partnerIdNumber', flag);
            return flag;
          }
        }
      } else {
        ctx.logger.info('partnerState', flag);
        console.log('partnerState', flag);
        return flag;
      }
      // 是否为失独家庭
      if (oneInfo.isLoss && oneInfo.isLoss !== '') {
      } else {
        ctx.logger.info('isLoss', flag);
        console.log('isLoss', flag);
        return flag;
      }
      // 老年人能力状况
      if (oneInfo.ability && oneInfo.ability !== '') {
      } else {
        ctx.logger.info('ability', flag);
        console.log('ability', flag);
        return flag;
      }
      // 健康状况
      if (oneInfo.health && oneInfo.health.length > 0) {
        if (oneInfo.health.indexOf('残疾') !== -1) {
          if (oneInfo.disabilityCategory && oneInfo.disabilityCategory.length > 0) {
          } else {
            ctx.logger.info('disabilityCategory', flag);
            console.log('disabilityCategory', flag);
            return flag;
          }
          if (oneInfo.disabilityLevel && oneInfo.disabilityLevel !== '') {
          } else {
            ctx.logger.info('disabilityLevel', flag);
            console.log('disabilityLevel', flag);
            return flag;
          }
        }
        if (oneInfo.health.indexOf('患重特大疾病') !== -1) {
          if (oneInfo.majorDiseases && oneInfo.majorDiseases.length > 0) {
          } else {
            ctx.logger.info('majorDiseases', flag);
            console.log('majorDiseases', flag);
            return flag;
          }
        }
      } else {
        return flag;
      }
      // 生活经济状况
      if (oneInfo.livingCondition && oneInfo.livingCondition !== '') {
      } else {
        ctx.logger.info('livingCondition', flag);
        console.log('livingCondition', flag);
        return flag;
      }
      // 收入来源
      if (oneInfo.sourceOfIncome && oneInfo.sourceOfIncome.length > 0) {
        if (oneInfo.sourceOfIncome.indexOf('其它') !== -1) {
          if (oneInfo.sourceOfIncomeExt && oneInfo.sourceOfIncomeExt !== '') {
          } else {
            ctx.logger.info('sourceOfIncomeExt', flag);
            console.log('sourceOfIncomeExt', flag);
            return flag;
          }
        }
      } else {
        ctx.logger.info('sourceOfIncome', flag);
        console.log('sourceOfIncome', flag);
        return flag;
      }
      // 本人上年度可支配收入
      if (oneInfo.income && oneInfo.income !== '') {
      } else {
        ctx.logger.info('income', flag);
        console.log('income', flag);
        return flag;
      }
      // 家庭救助帮扶情况
      if (oneInfo.rescueState && oneInfo.rescueState.length > 0) {
      } else {
        ctx.logger.info('rescueState', flag);
        console.log('rescueState', flag);
        return flag;
      }
      // 陪伴居住情况
      if (oneInfo.accompany && oneInfo.accompany.length > 0) {
        if (oneInfo.accompany.indexOf('其他情形') !== -1) {
          if (oneInfo.accompanyExt && oneInfo.accompanyExt !== '') {
          } else {
            ctx.logger.info('accompanyExt', flag);
            console.log('accompanyExt', flag);
            return flag;
          }
        }
      } else {
        ctx.logger.info('accompany', flag);
        console.log('accompany', flag);
        return flag;
      }
      // 日常生活照料人
      if (oneInfo.lookAfter && oneInfo.lookAfter.length > 0) {
        if (oneInfo.lookAfter.indexOf('其他人员') !== -1) {
          if (oneInfo.lookAfterExt && oneInfo.lookAfterExt !== '') {
          } else {
            ctx.logger.info('lookAfterExt', flag);
            console.log('lookAfterExt', flag);
            return flag;
          }
        }
        if (oneInfo.lookAfter.indexOf('无人照料') !== -1) {
        } else {
          if (oneInfo.mainLookName && oneInfo.mainLookName !== '') {
          } else {
            ctx.logger.info('mainLookName', flag);
            console.log('mainLookName', flag);
            return flag;
          }
          if (oneInfo.mainLookSex && oneInfo.mainLookSex !== '') {
          } else {
            ctx.logger.info('mainLookSex', flag);
            console.log('mainLookSex', flag);
            return flag;
          }
          if (oneInfo.mainLookPhone && oneInfo.mainLookPhone !== '') {
          } else {
            ctx.logger.info('mainLookPhone', flag);
            console.log('mainLookPhone', flag);
            return flag;
          }
        }
      } else {
        ctx.logger.info('lookAfter', flag);
        console.log('lookAfter', flag);
        return flag;
      }
      // 关爱服务需求
      if (oneInfo.demand && oneInfo.demand.length > 0) {
        if (oneInfo.demand.indexOf('其它') !== -1) {
          if (oneInfo.demandExt && oneInfo.demandExt !== '') {
          } else {
            ctx.logger.info('demandExt', flag);
            console.log('demandExt', flag);
            return flag;
          }
        }
      } else {
        ctx.logger.info('demand', flag);
        console.log('demand', flag);
        return flag;
      }
      // 老年人类别
      if (oneInfo.oldType && oneInfo.oldType.length > 0) {
      } else {
        ctx.logger.info('oldType', flag);
        console.log('oldType', flag);
        return flag;
      }
      // 老年人照片
      if (oneInfo.photo && oneInfo.photo !== '') {
      } else {
        ctx.logger.info('photo', flag);
        console.log('photo', flag);
        return flag;
      }
      // 定位信息
      if (oneInfo.photoAndLocation && oneInfo.photoAndLocation !== '') {
      } else {
        ctx.logger.info('photoAndLocation', flag);
        console.log('photoAndLocation', flag);
        return flag;
      }
      // 子女
      if (oneInfo.childInfo) {
        const childs = JSON.parse(oneInfo.childInfo);
        if (childs.length > 0) {
          // 检查子女信息是否填全
          for (let index = 0; index < childs.length; index++) {
            const child = childs[index];
            if (child.name && child.name !== '') {
            } else {
              ctx.logger.info('childName', flag);
              console.log('childName', flag);
              return flag;
            }
            if (child.phone && child.phone !== '') {
            } else {
              ctx.logger.info('childPhone', flag);
              console.log('childPhone', flag);
              return flag;
            }
            // 子女配偶
            if (child.isHasPartner && child.isHasPartner !== '') {
              if (child.isHasPartner == '是') {
                if (child.name2 && child.name2 !== '') {
                } else {
                  ctx.logger.info('childPartnerName', flag);
                  console.log('childPartnerName', flag);
                  return flag;
                }
                if (child.phone2 && child.phone2 !== '') {
                } else {
                  ctx.logger.info('childPartnerphone2', flag);
                  console.log('childPartnerphone2', flag);
                  return flag;
                }
              }
              // ctx.logger.info('child.isHasPartner == 1', flag);
            } else {
              ctx.logger.info('childisHasPartner', flag);
              console.log('childisHasPartner', flag);
              return flag;
            }
            // 是否外出
            if (child.isHasGoOut && child.isHasGoOut !== '' && child.isHasGoOut == '否') {
              // if (child.isHasGoOut == '是') {
              // }
            } else {
              if (child.outgoingplace && child.outgoingplace !== '') {
              } else {
                ctx.logger.info('child.outgoingplace', flag);
                console.log('child.outgoingplace', flag);
                return flag;
              }
              if (child.outgoingTime && child.outgoingTime !== '') {
              } else {
                ctx.logger.info('child.outgoingTime', flag);
                console.log('child.outgoingTime', flag);
                return flag;
              }
              if (child.outgoingCause && child.outgoingCause !== '') {
              } else {
                ctx.logger.info('child.outgoingCause', flag);
                console.log('child.outgoingCause', flag);
                return flag;
              }
            }
            // if (child.outgoingplace && child.outgoingplace !== '') {
            // } else {
            //   // ctx.logger.info('outgoingplace', flag);
            //   console.log('outgoingplace', flag);
            //   return flag;
            // }
            // if (child.outgoingTime && child.outgoingTime !== '') {
            // } else {
            //   // ctx.logger.info('outgoingTime', flag);
            //   console.log('outgoingTime', flag);
            //   return flag;
            // }
            // if (child.outgoingCause && child.outgoingCause !== '') {
            // } else {
            //   // ctx.logger.info('outgoingCause', flag);
            //   console.log('outgoingCause', flag);
            //   return flag;
            // }
            if (child.visit && child.visit !== '') {
            } else {
              ctx.logger.info('child.visit', flag);
              console.log('child.visit', flag);
              return flag;
            }
          }
        }
      } else {
        return flag;
      }


      // 其他赡养人
      if (oneInfo.otherInfo) {
        const others = JSON.parse(oneInfo.otherInfo);
        if (others) {
          // 检查赡养人信息是否填全
          if (others.name && others.name !== '') {
          } else {
            ctx.logger.info('others.name', flag);
            console.log('others.name', flag);
            return flag;
          }
          if (others.sex && others.sex !== '') {
          } else {
            ctx.logger.info('others.sex', flag);
            console.log('others.sex', flag);
            return flag;
          }
          if (others.phone && others.phone !== '') {
          } else {
            ctx.logger.info('others.phone', flag);
            console.log('others.phone', flag);
            return flag;
          }
          // 与被赡养人关系
          if (others.relation && others.relation !== '') {
            if (others.relation == '其他') {
              if (others.relationExt && others.relationExt !== '') {
              } else {
                ctx.logger.info('others.relationExt', flag);
                console.log('others.relationExt', flag);
                return flag;
              }
            }
          } else {
            ctx.logger.info('others.relation', flag);
            console.log('others.relation', flag);
            return flag;
          }
          // 配偶
          if (others.isHasPartner && others.isHasPartner !== '') {
            if (others.isHasPartner == '是') {
              if (others.name2 && others.name2 !== '') {
              } else {
                ctx.logger.info('others.name2', flag);
                console.log('others.name2', flag);
                return flag;
              }
              if (others.phone2 && others.phone2 !== '') {
              } else {
                ctx.logger.info('others.phone2', flag);
                console.log('others.phone2', flag);
                return flag;
              }
            }
          } else {
            ctx.logger.info('others.isHasPartner', flag);
            console.log('others.isHasPartner', flag);
            return flag;
          }
          // 是否外出
          if (others.isHasGoOut && others.isHasGoOut !== '' && others.isHasGoOut == '否') {
          } else {
            if (others.outgoingplace && others.outgoingplace !== '') {
            } else {
              ctx.logger.info('others.outgoingplace', flag);
              console.log('others.outgoingplace', flag);
              return flag;
            }
            if (others.outgoingTime && others.outgoingTime !== '') {
            } else {
              ctx.logger.info('others.outgoingTime', flag);
              console.log('others.outgoingTime', flag);
              return flag;
            }
            if (others.outgoingCause && others.outgoingCause !== '') {
            } else {
              ctx.logger.info('others.outgoingCause', flag);
              console.log('others.outgoingCause', flag);
              return flag;
            }
          }
          if (others.visit && others.visit !== '') {
          } else {
            ctx.logger.info('others.visit', flag);
            console.log('others.visit', flag);
            return flag;
          }
        }
      }
      // 巡访联系人信息
      if (oneInfo.regularsInfo && oneInfo.regularsInfo !== '') {
        const regulars = JSON.parse(oneInfo.regularsInfo);
        if (regulars) {
          // 检查巡访联系人信息是否填全
          if (regulars.visitMode && regulars.visitMode !== '' && regulars.visitMode !== '[]') {
            if (regulars.visitMode.indexOf('其它') !== -1) {
              if (regulars.visitModeExt && regulars.visitModeExt !== '') {
              } else {
                ctx.logger.info('regulars.visitModeExt', flag);
                console.log('regulars.visitModeExt', flag);
                return flag;
              }
            }
          } else {
            ctx.logger.info('regulars.visitMode', flag);
            console.log('regulars.visitMode', flag);
            return flag;
          }
          if (regulars.visitCount && regulars.visitCount !== '') {
            if (regulars.visitCount == '其它') {
              if (regulars.visitCountExt && regulars.visitCountExt !== '') {
              } else {
                ctx.logger.info('regulars.visitCountExt', flag);
                console.log('regulars.visitCountExt', flag);
                return flag;
              }
            }
          } else {
            ctx.logger.info('regulars.visitCount', flag);
            console.log('regulars.visitCount', flag);
            return flag;
          }
        } else {
          ctx.logger.info('regulars', flag);
          console.log('regulars', flag);
          return flag;
        }
      } else {
        ctx.logger.info('regularsInfo', flag);
        console.log('regularsInfo ', flag);
        return flag;
      }
      ctx.logger.info('false', flag);
      console.log('false', flag);
      return false;
    }
    ctx.logger.info('true', flag);
    console.log('true', flag);
    return flag;
  }

  // 审核成功时，不允许修改为空
  async checkInfoUpdate(oneInfo) {
    const ctx = this.ctx;
    let flag = true;
    Object.keys(oneInfo).forEach(item => {
      if (item == 'childInfo') {
        return flag;
      }
      if (item == 'otherInfo') {
        return flag;
      }
      if (item == 'regularsInfo') {
        return flag;
      }
      if (!oneInfo[item] || oneInfo[item] == '' || oneInfo[item] == '[]') {
      // 当值不存在，为''，为 '[]'时，不可以修改
        flag = false;
      }
    });
    // console.log('完成');
    return flag;// 可以修改
  }

  // 修改采集状态
  async updateStatus(id, data) { // data 修改内容
    const { ctx } = this;
    const { model } = this.ctx;
    const oneInfo = await this.ctx.service.infoService.one(id);
    // 检查采集状态是否完成
    const checkStatus = await this.ctx.service.infoService.checkInfoStatus(id);
    const status = checkStatus ? '0' : '1';
    // ctx.logger.info('status=================', status)

    let query = {};

    // 审核完成后，采集状态不允许修改
    if (oneInfo.status == '3') {
      query = { status: oneInfo.status };
    } else {
      query = { status };
    }

    if (status == '1') {
      if (this.isNoNull(oneInfo, 'pic')) {
        // pic != ''  是否修改了name idNumber
        if (data.name || data.idNumber) {
          // 根据修改的name,idNumber重新生成二维码
          const picUrl = await this.ctx.service.infoService.createImage(oneInfo._id, data.name, data.idNumber);
          // update  图片地址
          query.pic = picUrl;
        }
      } else {
        // 生成二维码
        const picUrl = await this.ctx.service.infoService.createImage(oneInfo._id, oneInfo.name, oneInfo.idNumber);
        // add图片地址
        query.pic = picUrl;
      }
    }
    const result = await model.InfoModel.updateOne({ _id: id }, query);
    return result;
  }

  // 生成二维码
  async createImage(id, name, idNumber) {
    const { service } = this;
    if (id && name && idNumber && id !== '' && name !== '' && idNumber !== '') {
      // 生成二维码
      const qr_png = qr.image(this.app.config.weiXinUrl + id, { type: 'png' });
      let number = '';
      if (idNumber && idNumber !== '') {
        number = idNumber.substring(0, 4) + 'xxxxxxxxxxx' + idNumber.substring(15, 18);
      }
      // 添加水印
      const fileStream = await service.infoService.handleImage(qr_png, name, number);
      const fileName = name + '_' + (number || '') + '.png';
      // 文件生成绝对路径
      const target = path.join(this.app.config.defaultUploadPath, fileName);// this.config.baseDir,
      // 生成一个文件写入 文件流
      const writeStream = fs.createWriteStream(target);
      // 异步把文件流 写入
      await awaitWriteStream(fileStream.pipe(writeStream));
      const url = this.app.config.defaultWritePathPre + fileName;
      return url;
    }
    return '';
  }

  isNoNull(obj, key) {
    return obj.hasOwnProperty(key) && obj[key];
  }

  // gm 二维码添加文字水印
  async handleImage(qr_png, name, number) {
    return new Promise((resolve, reject) => {
      // 添加水印
      gm(qr_png)
        .font('./app/public/font/msyh.ttf') // 设置字体
        .fill('#000000') // 设置颜色
        .fontSize('12px') // 设置字号
        .drawText(0, 5, name + (number || ''), 'South') // 设定位置
        .stream(function(err, stdout, stderr) {
          if (!err) {
            resolve(stdout);
          } else {
            reject(err.message);
          }
        });
      console.log('done!');
    });
  }

  // 删除
  async dele(id) {
    const { model } = this.ctx;
    const result = await model.InfoModel.deleteOne({ _id: id });
    return result;
  }

  // 审批
  async approval(id, data) {
    const { model } = this.ctx;
    const status = data.status;
    if (id) {
      const oneInfo = await this.ctx.service.infoService.one(id);
      if (oneInfo) {
        if (oneInfo.status == '2') {
          if (status == '3') {
            // 审批成功  修改状态==3
            const result = await model.InfoModel.updateOne({ _id: id }, data);
            // 判断是否是离线采集，离线采集没有积分
            if (oneInfo.online && oneInfo.online == 'false') {
              // 无积分
            } else {
              // 添加积分记录
              const oneValue = await this.ctx.service.valueService.list({ fid: oneInfo.fid });
              if (oneValue.length <= 0) {
                const addQuery = {};
                addQuery.dept1 = oneInfo.dept1;
                addQuery.dept2 = oneInfo.dept2;
                addQuery.dept3 = oneInfo.dept3;
                addQuery.dept4 = oneInfo.dept4;
                addQuery.dept5 = oneInfo.dept5;
                // addQuery.dept1 = this.app.mongoose.Types.ObjectId(oneInfo.dept1);
                // addQuery.dept2 = this.app.mongoose.Types.ObjectId(oneInfo.dept2);
                // addQuery.dept3 = this.app.mongoose.Types.ObjectId(oneInfo.dept3);
                // addQuery.dept4 = this.app.mongoose.Types.ObjectId(oneInfo.dept4);
                // addQuery.dept5 = this.app.mongoose.Types.ObjectId(oneInfo.dept5);
                addQuery.type = '0';
                addQuery.fid = oneInfo.fid;
                addQuery.userid = oneInfo.userid;
                // addQuery.userName = oneInfo.userName;
                addQuery.infoId = oneInfo._id;
                await model.ValueModel.create(addQuery);
              }
              return result;
            }
          } else if (status == '4') {
            // 修改状态==4  审核失败
            const result = await model.InfoModel.updateOne({ _id: id }, data);
            return result;
          }
        }
        if (oneInfo.status == '1') {
          if (status == '2') {
            //  修改状态==2   审批中
            const result = await model.InfoModel.updateOne({ _id: id }, data);
            return result;
          } else if (status == '4') {
            // 修改状态==4
            const result = await model.InfoModel.updateOne({ _id: id }, data);
            return result;
          }
        }
      }
    }
    return '';
  }

  // 修改离线状态
  // async updateOffLine(id, offLineStatus) {
  //   const { model } = this.ctx;
  //   const result = await model.InfoModel.updateOne({ _id: id }, { offLine: offLineStatus });
  //   return result;
  // }

  /**
   * 筛选----身份证重复录入
   * */
  async groupByNumber(data) {
    const { model } = this.ctx;
    const page = data.page || 1;
    const rows = Number.parseInt(data.rows) || this.app.config.defaultPageSize;
    delete data.page;
    delete data.rows;
    const where = {};
    if (data.dept1) {
      where.dept1 = this.app.mongoose.Types.ObjectId(data.dept1);// 省
    }
    if (data.dept2) {
      where.dept2 = this.app.mongoose.Types.ObjectId(data.dept2); // 市
    }
    if (data.dept3) {
      where.dept3 = this.app.mongoose.Types.ObjectId(data.dept3); // 区
    }
    if (data.dept4) {
      where.dept4 = this.app.mongoose.Types.ObjectId(data.dept4); // 乡
    }
    if (data.dept5) {
      where.dept5 = this.app.mongoose.Types.ObjectId(data.dept5); // 社区
    }
    where.$and = [{ idNumber: { $exists: true } }, { idNumber: { $ne: '' } }];
    const countResult = await model.InfoModel.aggregate([
      { $match: where },
      { $group: {
        _id: '$idNumber',
        count: { $sum: 1 },
      } },
      { $match: { count: { $gt: 1 } } },
      {
        $count: 'count', // 总数
      },
    ]);
    const result = await model.InfoModel.aggregate([
      { $match: where },
      { $group: {
        _id: '$idNumber',
        count: { $sum: 1 },
      } },
      { $match: { count: { $gt: 1 } } },
      {
        $sort: { time: -1 },
      },
      {
        $skip: rows * (parseInt(page) - 1),
      },
      {
        $limit: rows,
      },
    ]).allowDiskUse(true);
    const returmData = {};
    returmData.list = result;
    returmData.count = 0;
    if (countResult.length > 0) {
      returmData.count = countResult[0].count;
    }
    returmData.page = data.page;
    returmData.pageSize = data.rows;

    return returmData;
  }

  async exportData(data) {
    const { model } = this.ctx;
    const where = {};
    if (data.dept1) {
      where.dept1 = data.dept1;// 省
    }
    if (data.dept2) {
      where.dept2 = data.dept2; // 市
    }
    if (data.dept3) {
      where.dept3 = data.dept3; // 区
    }
    if (data.dept4) {
      where.dept4 = data.dept4; // 乡
    }
    if (data.dept5) {
      where.dept5 = data.dept5; // 社区
    }
    // userid.loginName
    if (data.cjname) {
      // where.userName = { $regex: data.cjname }; // 管理员
      // where['userInfo.loginName'] = { $regex: data.cjname };
      const result = await model.SysUserModel.find({ loginName: { $regex: data.cjname } });
      if (result.length > 0) {
        where.userid = result[0]._id;
      } else {
        return '';
      }
    }
    // 状态
    where.status = '3';
    // 老人常用联系电话
    if (data.phone) {
      where.phone = { $regex: data.phone };
    }
    // 老人姓名
    if (data.name) {
      where.name = { $regex: data.name };
    }
    // 老人年龄
    if (data.age) {
      const myDate = new Date();
      const year = myDate.getFullYear();
      const month = (myDate.getMonth() + 1) > 9 ? (myDate.getMonth() + 1) : '0' + (myDate.getMonth() + 1);
      const day = myDate.getDate() > 9 ? (myDate.getDate()) : '0' + (myDate.getDate());
      if (data.age > 0) {
        where.idNumber = { $ne: '' };
        where.birthday = { $lte: '' + year + month + day - (data.age * 10000) };
      } else {
        where.idNumber = { $ne: '' };
        where.birthday = { $gte: '' + year + month + day - (-data.age * 10000) };
      }
    }
    // 关爱服务需求
    if (data.demand) {
      // console.log('oldtype', data.oldType)
      if (data.demand.indexOf(',') > -1) {
        const ts = data.demand.split(',');
        where.demand = { $in: ts };
      } else {
        where.demand = { $in: data.demand };
      }
    }
    // 老人类别
    if (data.oldType) {
      // console.log('oldtype', data.oldType)
      if (data.oldType.indexOf(',') > -1) {
        const ts = data.oldType.split(',');
        where.oldType = { $in: ts };
      } else {
        where.oldType = { $in: data.oldType };
      }
    }
    // 离线采集
    if (data.online) {
      if (data.online == 'false') {
        where.online = data.online;
      }
      if (data.online == 'true') {
        // where.online = data.online;
        where.$or = [{ online: { $exists: false } }, { online: data.online }];
      }
    }
    // 身份证号码搜索
    if (data.idNumber) {
      where.idNumber = { $regex: data.idNumber };
    }
    // 老年人能力状况
    if (data.ability) {
      where.ability = data.ability;
    }
    this.ctx.logger.info('条件', where);
    const pop = [
      {
        path: 'userid',
        select: 'loginName userName',
      },
      {
        path: 'dept1',
        select: 'name',
      },
      {
        path: 'dept2',
        select: 'name',
      },
      {
        path: 'dept3',
        select: 'name',
      },
      {
        path: 'dept4',
        select: 'name',
      },
      {
        path: 'dept5',
        select: 'name',
      },
    ];
    const result = await model.InfoModel.find(where,{"dept1":1,"dept2":1,"dept3":1,"dept4":1,"dept5":1,"name":1,"sex":1,"nation":1,"idNumber":1,
      "nativePlace":1,"address":1,"userid":1,"status":1,"phone":1,"ability":1,"demand":1,"birthday":1,"oldType":1}).sort({ time: -1 });

    return result;
  }

  async yestdayNum(data,user) {
    const { model } = this.ctx;
    const level = user.dept.level;
    const match = {};
    match.time = data.yestday;
    // admin的dept 存在冲突，所以它不需要结合
    if (user.role._id != this.app.config.defaultAdminRoleId) {
      match['dept'+level]= user.dept._id;
    }
    this.ctx.logger.info('条件', match);
    const res = await model.InfoModel.aggregate([
      { $project: { time: { $dateToString: { format: '%Y-%m-%d', date: '$time' } },_id:1,dept1:1,dept2:1,dept3:1,dept4:1,dept5:1,status:1  } },
      { $match: match},
      { $group:
            { _id: '$time', sumnum : {$sum : 1},
              nodone: { $sum: {$cond: [{ $eq: [ '$status', '0' ] }, 1, 0 ]} },
              writenostu: { $sum: {$cond: [{ $eq: [ '$status', '1' ] }, 1, 0 ]} },
              stuing: { $sum: {$cond: [{ $eq: [ '$status', '2' ] }, 1, 0 ]} },
              stued: { $sum: {$cond: [{ $eq: [ '$status', '3' ] }, 1, 0 ]} },
              fullstu: { $sum: {$cond: [{ $eq: [ '$status', '4' ] }, 1, 0 ]} },
            }
      }
    ]);

    return res;
  }

}
module.exports = InfoService;