/**
 * 运维中台售后问题处理工单，根据计划修复时间（pa3aGiey3N），发送企业微信通知，因为不是必填项，没有填写的不推送！！！！
 *1.已完成的工单
 * 根据表单数据中的是否已完成字段（Solution_Status）判断，该单子是否推送通知，
 * 已完成的不推送，未完成的推送通知
 * 推送给处理人（Processing_Personnel）
 * 2.未完成的工单
 * 
 */

const schedule = require('node-schedule')
const moment = require('moment')
const request = require('superagent')
let isDev = false
// isDev = true
const sendType = {
   'mini': 'miniprogram_notice',
}

module.exports = function (app, opts) {
   const workOrderNotice = app.fs.scheduleInit(
      {
         interval: '0 * * * *',//一小时执行一次
         immediate: isDev,
         proRun: !isDev,
      },
      async () => {
         try {
            //前一次执行时间
            console.log('运维中台售后问题处理工单数据抽取开始', moment().format('YYYY-MM-DD HH:mm:ss'))
            const { parseProcessData,getUserId,sendWechat } = app.fs.utils
            const startTime = moment().format('YYYY-MM-DD HH:mm:ss')
            const { models } = app.fs.dc
            const { clickHouse } = app.fs
            const { database: camWorkflow } = clickHouse.camWorkflow.opts.config
            const formRes = await clickHouse.pepEmis.query(
               `SELECT 
                     story.id AS historyId,
                     story.procinst_id as procinstId,
                     story.apply_user AS pepUserId,
                     story.form_data AS formData,
                     story.submit_form_data AS submitFormData,
                     story.create_at as createTime,
                     fform.form_schema AS formSchema,
                     fprocess.name AS processName,
                     procin.state_ AS state,
                     procin.end_time_ as endTime,
                     fform.id AS formId,
                     fversion.id AS versionId,
                     fgroup.name AS groupName 
                  FROM 
                     workflow_process_history AS story
                  INNER JOIN workflow_process_version AS fversion
                     ON fversion.id = story.version_id
                  INNER JOIN workflow_process_form AS fform
                     ON fform.id = fversion.form_id
                     AND fform.form_schema IS NOT NULL
                  INNER JOIN workflow_process AS fprocess
                     ON fprocess.id = fform.process_id
                     AND fprocess.name = '运维中台售后问题处理工单'
                  INNER JOIN workflow_group AS fgroup
                     ON fgroup.id = fprocess.group_id
                  INNER JOIN ${camWorkflow}.act_hi_procinst AS procin
                     ON procin.id_ = story.procinst_id
                     AND procin.state_ in ('COMPLETED','ACTIVE')`
            ).toPromise()
            if (formRes && formRes.length > 0) {
               for (let f of formRes) {
                  let user = {}
                  const parseData = f.formSchema && parseProcessData({
                     formSchema: JSON.parse(f.formSchema),
                     formData: JSON.parse(f.formData)
                  })
                  const rlst = await models.WorkOrderNotice.findOne({
                     where: {
                        procinstId: f.procinstId,
                     }
                  })
                  //没有计划完成时间,没有处理人,没有是否解决，都不推送通知
                  if (parseData.processing_personnel.value && parseData.planTime.value && parseData.solution_status.value) {
                     user = await clickHouse.pepEmis.query(`select * from user where id=${Number(parseData.processing_personnel.value)}`).toPromise()
                     if (!rlst) {
                        await models.WorkOrderNotice.create({
                           procinstId: f.procinstId,
                           planTime: parseData.planTime.value,
                           processingPersonnelId: parseData.processing_personnel.value,
                           processingPersonnelPhone: user && user.length && user[0].phone,
                           isSend: false,
                           haveDone: parseData.solution_status.value === '否' ? false : true,
                        })
                     }
                  } else {
                     console.log('没有对应的处理人', f.procinstId)
                  }

               }


            } else {
               console.log('未查询到数据')
            }
            //数据全部插入完成之后(筛选数据进行发送企业微信通知)
            // 获取当前时间  
            // 计算当前时间之后一天的日期  
            const lastDay = moment().subtract(1, 'days')
            //需要发送提醒的数据
            const sendRslt=await models.WorkOrderNotice.findAll({
               where: {
                  isSend: false,//未发送
                  haveDone: false,//未完成

                  planTime:{
                     $gte: lastDay
                  }
            }
            })
            //发送企业微信通知
            if(sendRslt&&sendRslt.length){
               for (let { dataValues: c } of sendRslt) {
                  //根据电话号码查询企业微信对应的userId
                  //15083558812,兰邦夫的电话号码
                  if(c.processingPersonnelPhone==='15083558812'){
                     const userId=await getUserId(opts,c.processingPersonnelPhone)
                     if(userId){
                        const res= await sendWechat({
                            opts, msgtype: sendType["mini"],
                              data: {  userId:userId, touser: [userId] }
                           })
                           if(res.body.errmsg==='ok'){
                            //将已发送的记录的isSend修改为true（已发送）
                             await models.WorkOrderNotice.update({ isSend: true }, { where: { id: c.id } })
                           }else{
                            console.log('发送消息失败',res.body.errmsg)
                           }
                      }else{
                         console.log('查询不到对应的userId',c.processingPersonnelPhone)
                      }
                  }
                  const userId=await getUserId(opts,c.processingPersonnelPhone)
                  const userLan=await getUserId(opts,'15083558812')
                  //根据查询的userId发送通知
                  if(userId){
                    const res= await sendWechat({
                        opts, msgtype: sendType["mini"],
                          data: {  userId:userId, touser: [userId] }
                       })
                       if(res.body.errmsg==='ok'){
                        //将已发送的记录的isSend修改为true（已发送）
                         await models.WorkOrderNotice.update({ isSend: true }, { where: { id: c.id } })
                       }else{
                        console.log('发送消息失败',res.body.errmsg)
                       }
                  }else{
                     console.log('查询不到对应的userId',c.processingPersonnelPhone)
                  }
                  if(userLan){
                     const res= await sendWechat({
                         opts, msgtype: sendType["mini"],
                           data: {  userId:userLan, touser: [userLan] }
                        })
                        if(res.body.errmsg==='ok'){
                         //将已发送的记录的isSend修改为true（已发送）
                         console.log('已发送给兰邦夫')
                        //   await models.WorkOrderNotice.update({ isSend: true }, { where: { id: c.id } })
                        }else{
                         console.log('发送消息失败',res.body.errmsg)
                        }
                   }else{
                      console.log('查询不到对应的userId','15083558812')
                   }

                 
               }

            }





         } catch (error) {
            console.error('失败原因', error)
         }
      }
   );
   return {
      workOrderNotice,
   }
}