HQPT / order · 提交

转到一个项目

作者 xudada
提交 83abd3a2a5f27958b8eb31119866c30b84399fca 1 个父辈 eb931914

websocket

内嵌 并排对比
正在显示 9 个修改的文件 包含 1069 行增加 和 2 行删除
... ... @@ -37,6 +37,16 @@
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>2.1.1</version>
</dependency>
<dependency>
<groupId>cn.hutool</groupId>
<artifactId>hutool-all</artifactId>
<version>4.0.12</version>
</dependency>
<!--websocket-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-websocket</artifactId>
</dependency>
<!--clound-->
<dependency>
<groupId>org.springframework.cloud</groupId>
... ... @@ -198,5 +208,35 @@
</plugin>
</plugins>
</build>
<repositories>
<repository>
<id>spring-snapshots</id>
<name>Spring Snapshots</name>
<url>https://repo.spring.io/snapshot</url>
<snapshots>
<enabled>true</enabled>
</snapshots>
</repository>
<repository>
<id>spring-milestones</id>
<name>Spring Milestones</name>
<url>https://repo.spring.io/milestone</url>
</repository>
</repositories>
<pluginRepositories>
<pluginRepository>
<id>spring-snapshots</id>
<name>Spring Snapshots</name>
<url>https://repo.spring.io/snapshot</url>
<snapshots>
<enabled>true</enabled>
</snapshots>
</pluginRepository>
<pluginRepository>
<id>spring-milestones</id>
<name>Spring Milestones</name>
<url>https://repo.spring.io/milestone</url>
</pluginRepository>
</pluginRepositories>
</project>
... ...
... ... @@ -8,6 +8,7 @@ import com.sunyo.customer.order.activity.dao.JOBMapper;
import com.sunyo.customer.order.activity.dao.ProcessFormMapper;
import com.sunyo.customer.order.activity.model.JOB;
import com.sunyo.customer.order.activity.model.ProcessForm;
import com.sunyo.customer.order.websocket.WebSocketServer;
import org.activiti.engine.*;
import org.activiti.engine.repository.DeploymentBuilder;
import org.activiti.engine.repository.ProcessDefinition;
... ... @@ -56,10 +57,11 @@ public class ProcessController {
public ResultJson<PageInfo> startActivityDemo(@RequestParam(value = "pageNum",required = false,defaultValue = "1")
int pageNum,
@RequestParam(value = "pageSize",required = false,defaultValue = "5")
int pageSize){
int pageSize)throws Exception{
Page<ProcessForm> page = PageHelper.startPage(pageNum,pageSize);
List<ProcessForm> list= processFormMapper.selectAllWithUser();
PageInfo<ProcessForm> result = new PageInfo<ProcessForm>(list);
return new ResultJson("200","success",result);
}
... ...
package com.sunyo.customer.order.activity.controller;
import com.sunyo.customer.order.activity.controller.response.ResultJson;
import com.sunyo.customer.order.websocket.WebSocketServer;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.servlet.ModelAndView;
import java.io.IOException;
/**
* Created by XYH on 2019/12/24.
*/
@RestController
@RequestMapping("/checkcenter")
public class WebSocketController {
//页面请求
@GetMapping("/socket/{cid}")
public ResultJson socket(@PathVariable String cid) {
return new ResultJson("200","success",cid);
}
//推送数据接口
/*@ResponseBody
@RequestMapping("/socket/push/{cid}")
public ResultJson pushToWeb(@PathVariable String cid,String message) {
try {
WebSocketServer.sendInfo(message,cid);
} catch (IOException e) {
e.printStackTrace();
return new ResultJson("200","success",cid+"#"+e.getMessage());
}
return new ResultJson("200","success",cid);
}*/
}
... ...
package com.sunyo.customer.order.mydemo;
import phonicapi.PhonicConst;
import phonicapi.PhonicHandler;
import phonicapi.PhonicNative;
/**
* Created by XYH on 2020/1/8.
*/
public class IncomingCall implements PhonicHandler {
private int uBoxHndOne = 0; //线路1操作句柄
private int uBoxHndTwo = 0; //线路2操作句柄
private int uBoxId = 0;// 设备类型
private boolean bHookOff = false;
private String strDir = "C:\\";
//打开设备
public boolean openUBox()
{
PhonicNative.ubox_open_logfile(0);
int nOpen = PhonicNative.ubox_open(this, PhonicConst.WORK_MODE_RECORD);
System.out.println("ubox_open="+nOpen);
if(nOpen == 0)
{
return true;
}
return false;
}
//关闭设备
public boolean closeUBox()
{
uBoxHndOne = 0;
uBoxHndTwo = 0;
PhonicNative.ubox_close();
return true;
}
//设备事件
public void event(int uboxHnd, int eventID, int param1, int param2, int param3, int param4) {
switch (eventID)
{
case UBOX_EVENT_DEVICE_PLUG_IN:
{
//检测型号正确
//if(1 == PhonicNative.ubox_get_product_ID(uboxHnd))
{
if(0 == uBoxHndOne)
{
uBoxHndOne = uboxHnd;
uBoxId = PhonicNative.ubox_get_product_ID(uboxHnd);
System.out.println(PhonicNative.ubox_get_device_versionnum(uboxHnd));
System.out.println(PhonicNative.ubox_get_product_name(uboxHnd));
if(uBoxId == 8) //无线设备
{
PhonicNative.ubox_set_gsm_work_mode(uboxHnd, 1, 0); //如果不用电话机，关闭电话机模式，否则振铃的时候，戴着耳麦会听到很大的给电话机送来电号码声音，体验效果不好。
}
}
else if(0 == uBoxHndTwo)
{
uBoxHndTwo = uboxHnd;
}
else
{
uBoxHndOne = uboxHnd;
uBoxHndTwo = 0;
}
}
System.out.println("收到设备插入事件:" + uboxHnd);
}
break;
case UBOX_EVENT_DEVICE_PLUG_OUT:
{
System.out.println("收到设备拔出事件:" + uboxHnd);
}
break;
case UBOX_EVENT_LINE_HOOK_UP:
{
if(uBoxId == 8)
{
if(param1 == 1)
{
System.out.println("收到GSM模块挂机:" + uboxHnd);
PhonicNative.ubox_set_talk_link(uboxHnd, EARPHONE_TO_GSM, 0); //被叫能够听不到耳麦说话的声音
}
else if(param1 == 2)
{
System.out.println("收到电话机挂机:" + uboxHnd);
}
else if(param1 == 3)
{
System.out.println("收到耳麦挂机:" + uboxHnd);
}
}
else
{
System.out.println("收到设备挂机事件:" + uboxHnd);
}
}
break;
case UBOX_EVENT_LINE_HOOK_OFF:
{
if(uBoxId == 8)
{
if(param1 == 0)
{
System.out.println("收到电话机摘机:" + uboxHnd);
}
else if(param1 == 2)
{
System.out.println("收到耳麦摘机:" + uboxHnd);
}
else if(param1 == 6)
{
System.out.println("收到GSM模块摘机:" + uboxHnd);
PhonicNative.ubox_set_talk_link(uboxHnd, EARPHONE_TO_GSM, 1); //被叫能够听到耳麦说话的声音
}
}
else
{
System.out.println("收到设备摘机事件:" + uboxHnd);
}
}
break;
case UBOX_EVENT_LINE_RINGING:
{
System.out.println("收到设备检测线路振铃开始事件:" + uboxHnd);
}
break;
case UBOX_EVENT_DEVICE_PLAY_END:
{
System.out.println("收到放音结束事件：" + uboxHnd);
}
break;
case UBOX_EVENT_RING_CANCEL:
{
System.out.println("收到设备检测线路振铃停止事件:" + uboxHnd);
}
break;
case UBOX_EVENT_DEVICE_BUSY_TONE:
{
System.out.println("收到设备检测线路忙音事件:" + uboxHnd);
}
break;
case UBOX_EVENT_ALARM:
{
System.out.println("收到设备工作警告事件：" + uboxHnd);
}
break;
case UBOX_EVENT_DEVICE_ERROR:
{
System.out.println("收到设备错误事件：" + uboxHnd);
}
break;
case UBOX_EVENT_LINE_RING_STOP:
{
System.out.println("收到设备检测线路振铃闪停事件:" + uboxHnd);
}
break;
case UBOX_EVENT_LINE_HANG:
{
System.out.println("收到设备悬空事件：" + uboxHnd);
}
break;
case UBOX_EVENT_LINE_VOLTAGE:
{
System.out.println("收到设备线路当前电压事件：" + uboxHnd);
}
break;
case UBOX_EVENT_STREAM_VOICE:
{
System.out.println("收到流式录音数据包事件：" + uboxHnd);
}
break;
case UBOX_EVENT_DTMF_DOWN:
{
//System.out.println("按键事件：" + uboxHnd);
}
break;
case UBOX_EVENT_DTMF_UP:
{
System.out.println("收到按键释放事件：" + uboxHnd);
}
break;
case UBOX_EVENT_DEVICE_PLAY_ERROR:
{
System.out.println("收到放音错误事件：" + uboxHnd);
}
break;
case UBOX_EVENT_CALLOUTFINISH:
{
System.out.println("收到软件拨号完成事件：" + uboxHnd);
}
break;
case UBOX_EVENT_POLARITY:
{
System.out.println("收到检测极性反转事件：" + uboxHnd);
}
break;
case UBOX_EVENT_SIM_STATE:
{
if(param2 == 1)
{
System.out.println("卡状态事件, 当前选择sim卡" + param1);
}
else if(param2 == 2)
{
System.out.println("卡状态事件, sim卡" + param1 +" GSM 模块检查Sim卡未插入");
}
else if(param2 == 3)
{
System.out.println("卡状态事件, sim卡" + param1 +" 检测到卡存在，并且是插好的");
}
else if(param2 > 3)
{
System.out.println("卡状态事件, sim卡" + param1 +" 检测到卡有错误，错误值:"+param2);
}
}
break;
case UBOX_EVENT_ANSWER:
{
System.out.println(" 被叫已经应答了");
PhonicNative.ubox_set_talk_link(uboxHnd, EARPHONE_TO_GSM, 1); //被叫能够听到耳麦说话的声音
}
break;
case UBOX_EVENT_SIGNALE_SIZE:
{
System.out.println(" 信号大小："+param1);
}
break;
case UBOX_EVENT_SHORT_MSG_SIZE:
{
System.out.println(" 被叫已经应答了");
}
break;
case UBOX_EVENT_SIM_REG:
{
if(param2 == 0)
{
System.out.println("sim卡" + param1+1 + " 网络未注册，当前没有搜索到要注册业务的新营运商 ");
}
else if(param2 == 1)
{
System.out.println("sim卡" + param1+1 + " 网络已注册");
//btnCall.setEnabled(true); //网络已经注册好了，可以拨打电话和发短信
//btnSendMsg.setEnabled(true);
}
else if(param2 == 2)
{
System.out.println("sim卡" + param1+1 + " 网络未注册，正在搜索要注册业务的新营运商");
}
else if(param2 == 3)
{
System.out.println("sim卡" + param1+1 + " 注册被拒绝");
}
else if(param2 == 4)
{
System.out.println("sim卡" + param1+1 + " 未注册， 未知原因");
}
else if(param2 == 5)
{
System.out.println("sim卡" + param1+1 + " 已注册，漫游");
}
}
break;
case UBOX_EVENT_SHORT_MSG_SEND_REPORT:
{
if(param1 == 0)
{
System.out.println("短信发送失败");
}
else if(param1 == 1)
{
System.out.println("短信发送成功");
}
else if(param1 == 2)
{
System.out.println("短信发送超时");
}
}
break;
default:
{
System.out.println("未知事件[uboxHnd=" + uboxHnd + "][eventID=" + eventID
+ "][param1=" + param1 + "][param2=" + param2 + "][param3="
+ param3 + "][param4=" + param4 + "]");
}
break;
}
}
public void callInNumber(int uboxHnd, String number) {
System.out.println("收到主叫号码[uboxHnd=" + uboxHnd + "][number=" + number + "]");
}
public void ShortMsg(int uboxHnd, String PhoneNumber, String stTime, String msg, String strDived) {
System.out.println("收到短信[uboxHnd=" + uboxHnd + "][发件人=" + PhoneNumber + "]" + ", 时间："+stTime +", 内容：" +msg+ " "+strDived);
}
public void CmdMsg(int uboxHnd, String cmd) {
System.out.println("收到消息[uboxHnd=" + uboxHnd + "][内容=" + cmd + "]");
}
public static void main(String[] args){
IncomingCall call=new IncomingCall();
call.openUBox();
}
}
... ...
package com.sunyo.customer.order.mydemo;
import phonicapi.PhonicConst;
import phonicapi.PhonicHandler;
import phonicapi.PhonicNative;
import javax.swing.*;
import java.awt.*;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
import java.io.File;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Date;
public class MainFrame extends JFrame implements PhonicHandler{
private JButton btnHookOff = new JButton("摘机");
private JButton btnHookOn = new JButton("挂机");
private JButton btnCall = new JButton("拨号");
private JButton btnSendMsg = new JButton("发送短信");
private JTextField txtNumb = new JTextField();
private JComboBox cbxLine = new JComboBox();
private JTextField txtShortMsgNumber = new JTextField();
private JTextField txtShortMsg = new JTextField();
private int uBoxHndOne = 0; //线路1操作句柄
private int uBoxHndTwo = 0; //线路2操作句柄
private int uBoxId = 0;// 设备类型
private boolean bHookOff = false;
private String strDir = "C:\\";
MainFrame ()
{
try{
File directory = new File("");
strDir = directory.getAbsolutePath();
System.out.println(strDir);
}catch(Exception e){}
//线路
cbxLine.setBounds(20, 20, 160, 20);
cbxLine.addItem("线路1");
cbxLine.addItem("线路2");
cbxLine.setSelectedItem("线路1");
//摘机
btnHookOff.setBounds(20, 60, 60, 20);
btnHookOff.addActionListener(new ActionListener() {
public void actionPerformed(ActionEvent e) {
int uBoxHnd = cbxLine.getSelectedIndex()==0?uBoxHndOne:uBoxHndTwo;
int nResult = PhonicNative.ubox_soft_hook_off(uBoxHnd);
System.out.println(nResult);
if(0 == nResult)
{
bHookOff = true;
cbxLine.setEnabled(false);
btnHookOff.setEnabled(false);
btnHookOn.setEnabled(true);
btnCall.setEnabled(true);
txtNumb.setEnabled(true);
//开始录音
Date nowDate = new Date();
DateFormat dfDate = new SimpleDateFormat("yyyy_MM_dd_HH_mm_ss");
String strPath = strDir+"\\"+dfDate.format(nowDate)+".wav";
System.out.println(strPath);
PhonicNative.ubox_record_file(uBoxHnd, strPath, CODER_ALAW);
}
}
});
//挂机
btnHookOn.setEnabled(false);
btnHookOn.setBounds(120, 60, 60, 20);
btnHookOn.addActionListener(new ActionListener() {
public void actionPerformed(ActionEvent e) {
int uBoxHnd = cbxLine.getSelectedIndex()==0?uBoxHndOne:uBoxHndTwo;
int nResult = PhonicNative.ubox_soft_hook_on(uBoxHnd);
System.out.println(nResult);
if(0 == nResult)
{
bHookOff = false;
cbxLine.setEnabled(true);
btnHookOff.setEnabled(true);
btnHookOn.setEnabled(false);
btnCall.setEnabled(true);
txtNumb.setEnabled(true);
//停止录音
PhonicNative.ubox_stop_record(uBoxHnd);
}
}
});
//拨号
btnCall.setBounds(120, 100, 60, 20);
btnCall.addActionListener(new ActionListener() {
public void actionPerformed(ActionEvent e) {
if(uBoxId == 8)
{
if(txtNumb.getText().length() > 0)
{
cbxLine.setEnabled(false);
btnHookOff.setEnabled(false);
btnHookOn.setEnabled(true);
btnCall.setEnabled(true);
txtNumb.setEnabled(true);
int uBoxHnd = cbxLine.getSelectedIndex()==0?uBoxHndOne:uBoxHndTwo;
int nResult = PhonicNative.ubox_makecall(uBoxHnd, txtNumb.getText());
System.out.println(nResult);
}
}
else
{
//摘机
if(!bHookOff)
{
int uBoxHnd = cbxLine.getSelectedIndex()==0?uBoxHndOne:uBoxHndTwo;
int nResult = PhonicNative.ubox_soft_hook_off(uBoxHnd);
System.out.println(nResult);
if(0 == nResult)
{
bHookOff = true;
cbxLine.setEnabled(false);
btnHookOff.setEnabled(false);
btnHookOn.setEnabled(true);
btnCall.setEnabled(true);
txtNumb.setEnabled(true);
//开始录音
Date nowDate = new Date();
DateFormat dfDate = new SimpleDateFormat("yyyy_MM_dd_HH_mm_ss");
String strPath = strDir+"\\"+dfDate.format(nowDate)+".wav";
System.out.println(strPath);
PhonicNative.ubox_record_file(uBoxHnd, strPath, CODER_ALAW);
}
//等待0.5秒再拨号
try{
Thread.sleep(500);
}catch(Exception ee){
ee.printStackTrace();
}
}
if(txtNumb.getText().length() > 0)
{
btnCall.setEnabled(false);
txtNumb.setEnabled(false);
int uBoxHnd = cbxLine.getSelectedIndex()==0?uBoxHndOne:uBoxHndTwo;
int nResult = PhonicNative.ubox_send_dtmf(uBoxHnd, txtNumb.getText());
System.out.println(nResult);
}
}
}
});
btnCall.setEnabled(false);
btnSendMsg.setEnabled(false);
//号码输入框
txtNumb.setBounds(20, 100, 80, 20);
txtNumb.setText("910000");
txtShortMsgNumber.setBounds(20, 140, 80, 20); //收件号码
txtShortMsgNumber.setText("8615907558923");//发短信，需要在号码前加国际区号 ,中国"86"
txtShortMsg.setBounds(120, 140, 200, 20); //短信内容
txtShortMsg.setText("");//发短信，需要在号码前加国际区号 ,中国"86"
//发送短信
btnSendMsg.setBounds(340, 140, 120, 20);
btnSendMsg.addActionListener(new ActionListener() {
public void actionPerformed(ActionEvent e) {
if(uBoxId == 8)
{
if(txtShortMsgNumber.getText().length() > 0 && txtShortMsg.getText().length() > 0)
{
int uBoxHnd = cbxLine.getSelectedIndex()==0?uBoxHndOne:uBoxHndTwo;
int nResult = PhonicNative.ubox_send_gsm_msg(uBoxHnd, 1, txtShortMsgNumber.getText(), txtShortMsg.getText(),txtShortMsg.getText().length());
System.out.println(nResult);
}
}
}
});
//添加控件
add(cbxLine);
add(btnHookOff);
add(btnHookOn);
add(btnCall);
add(txtNumb);
add(txtShortMsgNumber);
add(txtShortMsg);
add(btnSendMsg);
//初始化
openUBox();
}
//打开设备
public boolean openUBox()
{
PhonicNative.ubox_open_logfile(0);
int nOpen = PhonicNative.ubox_open(this, PhonicConst.WORK_MODE_RECORD);
System.out.println("ubox_open="+nOpen);
if(nOpen == 0)
{
return true;
}
return false;
}
//关闭设备
public boolean closeUBox()
{
uBoxHndOne = 0;
uBoxHndTwo = 0;
PhonicNative.ubox_close();
return true;
}
//设备事件
public void event(int uboxHnd, int eventID, int param1, int param2, int param3, int param4) {
switch (eventID)
{
case UBOX_EVENT_DEVICE_PLUG_IN:
{
//检测型号正确
//if(1 == PhonicNative.ubox_get_product_ID(uboxHnd))
{
if(0 == uBoxHndOne)
{
uBoxHndOne = uboxHnd;
uBoxId = PhonicNative.ubox_get_product_ID(uboxHnd);
System.out.println(PhonicNative.ubox_get_device_versionnum(uboxHnd));
System.out.println(PhonicNative.ubox_get_product_name(uboxHnd));
if(uBoxId == 8) //无线设备
{
PhonicNative.ubox_set_gsm_work_mode(uboxHnd, 1, 0); //如果不用电话机，关闭电话机模式，否则振铃的时候，戴着耳麦会听到很大的给电话机送来电号码声音，体验效果不好。
}
}
else if(0 == uBoxHndTwo)
{
uBoxHndTwo = uboxHnd;
}
else
{
uBoxHndOne = uboxHnd;
uBoxHndTwo = 0;
}
}
System.out.println("收到设备插入事件:" + uboxHnd);
}
break;
case UBOX_EVENT_DEVICE_PLUG_OUT:
{
System.out.println("收到设备拔出事件:" + uboxHnd);
}
break;
case UBOX_EVENT_LINE_HOOK_UP:
{
if(uBoxId == 8)
{
if(param1 == 1)
{
System.out.println("收到GSM模块挂机:" + uboxHnd);
PhonicNative.ubox_set_talk_link(uboxHnd, EARPHONE_TO_GSM, 0); //被叫能够听不到耳麦说话的声音
}
else if(param1 == 2)
{
System.out.println("收到电话机挂机:" + uboxHnd);
}
else if(param1 == 3)
{
System.out.println("收到耳麦挂机:" + uboxHnd);
}
}
else
{
System.out.println("收到设备挂机事件:" + uboxHnd);
}
}
break;
case UBOX_EVENT_LINE_HOOK_OFF:
{
if(uBoxId == 8)
{
if(param1 == 0)
{
System.out.println("收到电话机摘机:" + uboxHnd);
}
else if(param1 == 2)
{
System.out.println("收到耳麦摘机:" + uboxHnd);
}
else if(param1 == 6)
{
System.out.println("收到GSM模块摘机:" + uboxHnd);
PhonicNative.ubox_set_talk_link(uboxHnd, EARPHONE_TO_GSM, 1); //被叫能够听到耳麦说话的声音
}
}
else
{
System.out.println("收到设备摘机事件:" + uboxHnd);
}
}
break;
case UBOX_EVENT_LINE_RINGING:
{
System.out.println("收到设备检测线路振铃开始事件:" + uboxHnd);
}
break;
case UBOX_EVENT_DEVICE_PLAY_END:
{
System.out.println("收到放音结束事件：" + uboxHnd);
}
break;
case UBOX_EVENT_RING_CANCEL:
{
System.out.println("收到设备检测线路振铃停止事件:" + uboxHnd);
}
break;
case UBOX_EVENT_DEVICE_BUSY_TONE:
{
System.out.println("收到设备检测线路忙音事件:" + uboxHnd);
}
break;
case UBOX_EVENT_ALARM:
{
System.out.println("收到设备工作警告事件：" + uboxHnd);
}
break;
case UBOX_EVENT_DEVICE_ERROR:
{
System.out.println("收到设备错误事件：" + uboxHnd);
}
break;
case UBOX_EVENT_LINE_RING_STOP:
{
System.out.println("收到设备检测线路振铃闪停事件:" + uboxHnd);
}
break;
case UBOX_EVENT_LINE_HANG:
{
System.out.println("收到设备悬空事件：" + uboxHnd);
}
break;
case UBOX_EVENT_LINE_VOLTAGE:
{
System.out.println("收到设备线路当前电压事件：" + uboxHnd);
}
break;
case UBOX_EVENT_STREAM_VOICE:
{
System.out.println("收到流式录音数据包事件：" + uboxHnd);
}
break;
case UBOX_EVENT_DTMF_DOWN:
{
//System.out.println("按键事件：" + uboxHnd);
}
break;
case UBOX_EVENT_DTMF_UP:
{
System.out.println("收到按键释放事件：" + uboxHnd);
}
break;
case UBOX_EVENT_DEVICE_PLAY_ERROR:
{
System.out.println("收到放音错误事件：" + uboxHnd);
}
break;
case UBOX_EVENT_CALLOUTFINISH:
{
System.out.println("收到软件拨号完成事件：" + uboxHnd);
}
break;
case UBOX_EVENT_POLARITY:
{
System.out.println("收到检测极性反转事件：" + uboxHnd);
}
break;
case UBOX_EVENT_SIM_STATE:
{
if(param2 == 1)
{
System.out.println("卡状态事件, 当前选择sim卡" + param1);
}
else if(param2 == 2)
{
System.out.println("卡状态事件, sim卡" + param1 +" GSM 模块检查Sim卡未插入");
}
else if(param2 == 3)
{
System.out.println("卡状态事件, sim卡" + param1 +" 检测到卡存在，并且是插好的");
}
else if(param2 > 3)
{
System.out.println("卡状态事件, sim卡" + param1 +" 检测到卡有错误，错误值:"+param2);
}
}
break;
case UBOX_EVENT_ANSWER:
{
System.out.println(" 被叫已经应答了");
PhonicNative.ubox_set_talk_link(uboxHnd, EARPHONE_TO_GSM, 1); //被叫能够听到耳麦说话的声音
}
break;
case UBOX_EVENT_SIGNALE_SIZE:
{
System.out.println(" 信号大小："+param1);
}
break;
case UBOX_EVENT_SHORT_MSG_SIZE:
{
System.out.println(" 被叫已经应答了");
}
break;
case UBOX_EVENT_SIM_REG:
{
if(param2 == 0)
{
System.out.println("sim卡" + param1+1 + " 网络未注册，当前没有搜索到要注册业务的新营运商 ");
}
else if(param2 == 1)
{
System.out.println("sim卡" + param1+1 + " 网络已注册");
btnCall.setEnabled(true); //网络已经注册好了，可以拨打电话和发短信
btnSendMsg.setEnabled(true);
}
else if(param2 == 2)
{
System.out.println("sim卡" + param1+1 + " 网络未注册，正在搜索要注册业务的新营运商");
}
else if(param2 == 3)
{
System.out.println("sim卡" + param1+1 + " 注册被拒绝");
}
else if(param2 == 4)
{
System.out.println("sim卡" + param1+1 + " 未注册， 未知原因");
}
else if(param2 == 5)
{
System.out.println("sim卡" + param1+1 + " 已注册，漫游");
}
}
break;
case UBOX_EVENT_SHORT_MSG_SEND_REPORT:
{
if(param1 == 0)
{
System.out.println("短信发送失败");
}
else if(param1 == 1)
{
System.out.println("短信发送成功");
}
else if(param1 == 2)
{
System.out.println("短信发送超时");
}
}
break;
default:
{
System.out.println("未知事件[uboxHnd=" + uboxHnd + "][eventID=" + eventID
+ "][param1=" + param1 + "][param2=" + param2 + "][param3="
+ param3 + "][param4=" + param4 + "]");
}
break;
}
}
public void callInNumber(int uboxHnd, String number) {
System.out.println("收到主叫号码[uboxHnd=" + uboxHnd + "][number=" + number + "]");
}
public void ShortMsg(int uboxHnd, String PhoneNumber, String stTime, String msg, String strDived) {
System.out.println("收到短信[uboxHnd=" + uboxHnd + "][发件人=" + PhoneNumber + "]" + ", 时间："+stTime +", 内容：" +msg+ " "+strDived);
}
public void CmdMsg(int uboxHnd, String cmd) {
System.out.println("收到消息[uboxHnd=" + uboxHnd + "][内容=" + cmd + "]");
}
public static void main(String[] args)
{
final MainFrame myFrame = new MainFrame();
myFrame.setTitle("电话示例");
myFrame.setSize(800, 600);
myFrame.setLayout(null);
Dimension screenSize = Toolkit.getDefaultToolkit().getScreenSize();
Dimension frameSize = myFrame.getSize();
myFrame.setLocation((screenSize.width-frameSize.width)/2, (screenSize.height-frameSize.height)/2);
myFrame.setDefaultCloseOperation(EXIT_ON_CLOSE);
myFrame.addWindowListener(new WindowAdapter(){
public void windowClosing(WindowEvent e){
myFrame.closeUBox();
}
});
myFrame.setVisible(true);
System.out.println("退出");
}
}
... ...
package com.sunyo.customer.order.websocket;
import org.springframework.beans.BeansException;
import org.springframework.beans.factory.BeanFactory;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import javax.websocket.server.ServerEndpointConfig;
/**
* Created by XYH on 2019/12/24.
*/
public class MySpringConfigurator extends ServerEndpointConfig.Configurator implements ApplicationContextAware {
private static volatile BeanFactory context;
@Override
public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
MySpringConfigurator.context = applicationContext;
}
@Override
public <T> T getEndpointInstance(Class<T> clazz) throws InstantiationException {
return context.getBean(clazz);
}
}
... ...
package com.sunyo.customer.order.websocket;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.socket.server.standard.ServerEndpointExporter;
/**
* Created by XYH on 2019/12/23.
*/
@Configuration
public class WebSocketConfig {
@Bean
public ServerEndpointExporter serverEndpointExporter() {
return new ServerEndpointExporter();
}
@Bean
public MySpringConfigurator mySpringConfigurator() {
return new MySpringConfigurator();
}
}
... ...
package com.sunyo.customer.order.websocket;
import cn.hutool.log.Log;
import cn.hutool.log.LogFactory;
import org.springframework.stereotype.Component;
import javax.websocket.*;
import javax.websocket.server.PathParam;
import javax.websocket.server.ServerEndpoint;
import java.io.IOException;
import java.util.concurrent.CopyOnWriteArraySet;
/**
* Created by XYH on 2019/12/23.
*/
@ServerEndpoint(value="/websocket",configurator = MySpringConfigurator.class)
@Component
public class WebSocketServer {
static Log log= LogFactory.get(WebSocketServer.class);
//静态变量，用来记录当前在线连接数。应该把它设计成线程安全的。
private static int onlineCount = 0;
//concurrent包的线程安全Set，用来存放每个客户端对应的MyWebSocket对象。
private static CopyOnWriteArraySet<WebSocketServer> webSocketSet = new CopyOnWriteArraySet<WebSocketServer>();
//与某个客户端的连接会话，需要通过它来给客户端发送数据
private Session session;
//接收sid
private String sid="";
/**
* 连接建立成功调用的方法*/
@OnOpen
public void onOpen(Session session,@PathParam("sid") String sid) {
this.session = session;
webSocketSet.add(this); //加入set中
addOnlineCount(); //在线数加1
log.info("有新窗口开始监听:"+sid+",当前在线人数为" + getOnlineCount());
this.sid=sid;
try {
sendMessage("连接成功");
} catch (IOException e) {
log.error("websocket IO异常");
}
}
/**
* 连接关闭调用的方法
*/
@OnClose
public void onClose() {
webSocketSet.remove(this); //从set中删除
subOnlineCount(); //在线数减1
log.info("有一连接关闭！当前在线人数为" + getOnlineCount());
}
/**
* 收到客户端消息后调用的方法
*
* @param message 客户端发送过来的消息*/
@OnMessage
public void onMessage(String message, Session session) {
log.info("收到来自窗口"+sid+"的信息:"+message);
//群发消息
for (WebSocketServer item : webSocketSet) {
try {
item.sendMessage(message);
} catch (IOException e) {
e.printStackTrace();
}
}
}
/**
*
* @param session
* @param error
*/
@OnError
public void onError(Session session, Throwable error) {
log.error("发生错误");
error.printStackTrace();
}
/**
* 实现服务器主动推送
*/
public void sendMessage(String message) throws IOException {
this.session.getBasicRemote().sendText(message);
}
/**
* 群发自定义消息
* */
public static void sendInfo(String message,@PathParam("sid") String sid) throws IOException {
//log.info("推送消息到窗口"+sid+"，推送内容:"+message);
for (WebSocketServer item : webSocketSet) {
try {
//这里可以设定只推送给这个sid的，为null则全部推送
if(sid==null) {
item.sendMessage(message);
}else if(item.sid.equals(sid)){
item.sendMessage(message);
}
} catch (IOException e) {
continue;
}
}
}
public static synchronized int getOnlineCount() {
return onlineCount;
}
public static synchronized void addOnlineCount() {
WebSocketServer.onlineCount++;
}
public static synchronized void subOnlineCount() {
WebSocketServer.onlineCount--;
}
}
... ...
... ... @@ -32,7 +32,7 @@ spring:
ddl-auto: update
show-sql: true
resources:
static-locations: classpath:/META-INF/resources/,classpath:/static,classpath:/resources/,classpath:/public/,file:${web.upload-path}
static-locations: classpath:/META-INF/resources/,classpath:/bin,classpath:/static,classpath:/resources/,classpath:/public/,file:${web.upload-path}
application:
name: HQPT-PROCESS
... ...