分支自 ~yxh/smartor
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
liusheng
2024-07-29 75cb81f0b88f313857ea431b46b929bef95d7cc8 
 ruoyi-admin/src/main/java/com/ruoyi/web/task/PhoneTask.java


@@ -1,42 +1,46 @@


package com.ruoyi.web.task;




import com.alibaba.fastjson2.JSON;


import com.fasterxml.jackson.databind.ObjectMapper;


import com.rabbitmq.client.Channel;


import com.ruoyi.common.core.redis.RedisCache;


import com.ruoyi.common.utils.DtoConversionUtils;


import com.ruoyi.common.utils.uuid.IdUtils;


import com.smartor.common.SendService;


import com.smartor.config.PhoneUtils;


import com.smartor.config.RobotPhoneUtils;


import com.smartor.domain.*;


import org.springframework.amqp.core.Message;


import org.springframework.data.convert.Jsr310Converters;


import com.smartor.domain.robot.RobotData;


import com.smartor.domain.robot.RobotDataConfig;


import com.smartor.domain.robot.RobotIdlenumVO;


import com.smartor.domain.robot.RobotScritpTemplateVO;




import java.util.*;


import java.util.concurrent.TimeUnit;




public class PhoneTask implements Runnable {


    private IvrTaskSingle ivrTaskSingle;


    private List<IvrLibaTemplateScriptVO> ivrLibaTemplateScriptVO;


    private ServiceSubtask ivrTaskSingle;


    private List<IvrTaskTemplateScriptVO> ivrTaskTemplateScriptVO;


    private RedisCache redisCache;


    private IvrLibaTemplateVO ivrLibaTemplateVO;


    private Channel channel;


    private Message message;


    private IvrTaskTemplateVO ivrTaskTemplateVO;


    private SendService sendService;


    private String phonePath;


    private RobotPhoneUtils robotPhoneUtils;






    public PhoneTask(IvrTaskSingle ivrTaskSingle, IvrLibaTemplateVO ivrLibaTemplateVO, RedisCache redisCache, Channel channel, Message message, SendService sendService) {


        this.ivrTaskSingle = DtoConversionUtils.sourceToTarget(ivrTaskSingle, IvrTaskSingle.class);


        this.ivrLibaTemplateScriptVO = DtoConversionUtils.sourceToTarget(ivrLibaTemplateVO.getIvrLibaTemplateScriptVOList(), IvrLibaTemplateScriptVO.class);


        this.ivrLibaTemplateVO = DtoConversionUtils.sourceToTarget(ivrLibaTemplateVO, IvrLibaTemplateVO.class);


    public PhoneTask(ServiceSubtask ivrTaskSingle, IvrTaskTemplateVO ivrTaskTemplateVO, RedisCache redisCache, SendService sendService, String phonePath, RobotPhoneUtils robotPhoneUtils) {


        this.ivrTaskSingle = DtoConversionUtils.sourceToTarget(ivrTaskSingle, ServiceSubtask.class);


        this.ivrTaskTemplateScriptVO = DtoConversionUtils.sourceToTarget(ivrTaskTemplateVO.getIvrTaskTemplateScriptVOList(), IvrTaskTemplateScriptVO.class);


        this.ivrTaskTemplateVO = DtoConversionUtils.sourceToTarget(ivrTaskTemplateVO, IvrTaskTemplateVO.class);


        this.redisCache = redisCache;


        this.channel = channel;


        this.message = message;


        this.sendService = sendService;


        this.phonePath = phonePath;


        this.robotPhoneUtils = robotPhoneUtils;


    }




    @Override


    public void run() {


        synchronized (PhoneTask.class) {


        if (phonePath.equals("1")) {


            //上海的电话拨打


            try {


                //获取电话组，查看哪些电话可以使用


                PhoneUtils phoneUtils = new PhoneUtils();


@@ -50,48 +54,93 @@


                        mapList.add(map);


                    }


                    //将模板问题话术里的通配符替换


                    for (IvrLibaTemplateScriptVO ivrLibaTemplateScriptVO : ivrLibaTemplateScriptVO) {


                    for (IvrTaskTemplateScriptVO ivrTaskTemplateScriptVO : ivrTaskTemplateScriptVO) {


                        for (Map<String, String> map : mapList) {


                            for (String key : map.keySet()) {


                                ivrLibaTemplateScriptVO.setQuestionText(ivrLibaTemplateScriptVO.getQuestionText().replace(key, map.get(key)));


                                ivrTaskTemplateScriptVO.setScriptContent(ivrTaskTemplateScriptVO.getScriptContent().replace(key, map.get(key)));


                            }


                        }


                    }


                }


                Map<String, Object> objectMap = new HashMap<>();


                objectMap.put("ivrTaskSingle", ivrTaskSingle);


                objectMap.put("ivrLibaTemplateScriptVO", ivrLibaTemplateScriptVO);


                objectMap.put("ivrTaskTemplateScriptVO", ivrTaskTemplateScriptVO);


                //将数据放到redis中，方便在回调方法里获取


                redisCache.setCacheObject(uuid, objectMap, 120, TimeUnit.MINUTES);




                //记录首次问题


                QuestionMessage returnQues = new QuestionMessage();


                returnQues.setKcb(ivrLibaTemplateVO.getRevisitBefore());


                for (IvrLibaTemplateScriptVO ivrLibaTemplateScriptVO : ivrLibaTemplateScriptVO) {


                    if (ivrLibaTemplateScriptVO.getTargetid() == ivrLibaTemplateVO.getFirstQuestionNum().intValue()) {


                        returnQues.setNowQuestion(ivrLibaTemplateScriptVO);


                returnQues.setKcb(ivrTaskTemplateVO.getRevisitBefore());


                for (IvrTaskTemplateScriptVO ivrTaskTemplateScriptVO : ivrTaskTemplateScriptVO) {


                    if (ivrTaskTemplateScriptVO.getTargetid() == ivrTaskTemplateVO.getFirstQuestionNum().intValue()) {


                        returnQues.setNowQuestion(ivrTaskTemplateScriptVO);


                    }


                }


                returnQues.setQuestionList(ivrLibaTemplateScriptVO);


                returnQues.setQuestionList(ivrTaskTemplateScriptVO);


                //将问题，和模板信息放到redis中


                redisCache.setCacheObject(uuid + "returnQues", returnQues, 120, TimeUnit.MINUTES);


                redisCache.setCacheObject(uuid + "ivrLibaTemplateVO", ivrLibaTemplateVO, 120, TimeUnit.MINUTES);


                redisCache.setCacheObject(uuid + "ivrTaskTemplateVO", ivrTaskTemplateVO, 120, TimeUnit.MINUTES);




                System.out.println("----------------uuID为 ：" + uuid + "       " + ivrTaskSingle.getSendname() + "       " + returnQues.getNowQuestion().getQuestionText() + "     " + ivrTaskSingle.getPhone());


                System.out.println("----------------uuID为 ：" + uuid + "       " + ivrTaskSingle.getSendname() + "       " + returnQues.getNowQuestion().getScriptContent() + "     " + ivrTaskSingle.getPhone());




                //调用机器人电话，开始电话（需要将回调方法传入，这个等”电话方“告诉怎么传，现在先空着,还有第一句问题话术）


                //先将话术放到ob_queue队列中


                IvrTaskcallPhoneMQ ivrTaskcallPhoneMQ = new IvrTaskcallPhoneMQ();


                ivrTaskcallPhoneMQ.setScript(ivrTaskTemplateVO.getRevisitBefore() + returnQues.getNowQuestion().getScriptContent());


                ivrTaskcallPhoneMQ.setType("1");


                ivrTaskcallPhoneMQ.setUuid(uuid);


                String data = JSON.toJSONString(ivrTaskcallPhoneMQ);


//            rabbitMqCallPhoneConfig.sendMessage("phone_exchange", "phone.ob1", data, 0L);




                //调用机器人电话，开始电话


                String ob = phoneUtils.ob("", "", "", "", "", "", "", ivrTaskSingle.getPhone(), uuid, true);


                System.out.println("----------------uuID为 ：" + uuid + "       " + ivrTaskSingle.getSendname() + "       " + returnQues.getNowQuestion().getScriptContent() + "     " + ivrTaskSingle.getPhone() + "----------已经拨打");


                Map<String, String> obMap = objectMapper.readValue(ob, Map.class);


                Thread.sleep(1000);


                redisCache.setCacheObject(uuid + "state_id", "0", 10, TimeUnit.MINUTES);


//                rabbitMqCallPhoneConfig.sendMessage("phone_exchange", "phone.ob1", data, 0L);


//这里先注释，state_id,电话那边，只能返回6，不能返回0，还需要电话那边进行修改，那边修改之后，上面两行可删除，将下面的解开注释


//            if (obMap.get("state_id").equals("0")) {


//                // 说明打通了


//                redisCache.setCacheObject(uuid + "state_id", "0", 10, TimeUnit.MINUTES);


//            } else {


//                while (true) {


//                    Thread.sleep(2000);


//                    redisCache.setCacheObject(uuid + "state_id", "0", 10, TimeUnit.MINUTES);


//                }


//            }


                System.out.println("OB的值为：" + ob);


                //通了之后，立马去调开场白


                System.out.println("问题的值为：" + returnQues.getNowQuestion().getQuestionText() + "       " + uuid);


                phoneUtils.ttsPlayback(ivrLibaTemplateVO.getRevisitBefore() + returnQues.getNowQuestion().getQuestionText(), uuid);




//                //通知 MQ 消息已被接收,可以ACK(从队列中删除)了   （这个需要根据业务再去处理ACK）


//                channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);


            } catch (Exception e) {


                e.printStackTrace();


            }


        }


        } else if (phonePath.equals("2")) {


            //杭州的电话拨打


            RobotScritpTemplateVO robotScritpTemplateVO = new RobotScritpTemplateVO();


            robotScritpTemplateVO.setNotes("aa");


            robotScritpTemplateVO.setBs_uuid(UUID.randomUUID().toString());


            robotScritpTemplateVO.setDnis(ivrTaskSingle.getPhone());


            robotScritpTemplateVO.setSpecify_ch(false);


            robotScritpTemplateVO.setTime_stamp(1566227782278333L);


            robotScritpTemplateVO.setEngine("ali");


            robotScritpTemplateVO.setAsr_sample("8000");


            robotScritpTemplateVO.setAsr_ent("ZurNHpaQLq6P55YS");


            robotScritpTemplateVO.setTts_ent("ZurNHpaQLq6P55YS");


            robotScritpTemplateVO.setTts_vcn("Aixia");


            robotScritpTemplateVO.setTts_volume(100);


            robotScritpTemplateVO.setTts_speed(-300);


            robotScritpTemplateVO.setDial_mode("呼叫对接方式，FS注册到网关、网关注册到FS、IP对接、IP校验账号对接");


            robotScritpTemplateVO.setDial_server("call_out_group,192.168.2.108:5060");


            robotScritpTemplateVO.setOutbound_codes("PCMU,PCMA,OPUS,G722");


            robotScritpTemplateVO.setAuto_test(true);


            RobotData robotData = new RobotData();


            RobotDataConfig robotDataConfig = new RobotDataConfig();


            robotDataConfig.setTemplate_name("inbound_88008001_16k_utf8.json");


            robotData.setConfig(robotDataConfig);


            robotScritpTemplateVO.setData(robotData);




            RobotIdlenumVO robotIdlenumVO = DtoConversionUtils.sourceToTarget(robotScritpTemplateVO, RobotIdlenumVO.class);


//            String idlenum = robotPhoneUtils.idlenum(robotIdlenumVO);


//            System.out.println(idlenum);


            robotPhoneUtils.outbound(robotScritpTemplateVO);


        }


    }


}