ITSM录音和对接

src/main/java/com/dashitech/businessdata/dao/ICallRecordDAO.java

@@ -0,0 +1,10 @@
+package com.dashitech.businessdata.dao;
+
+import com.dashitech.businessdata.entity.CallRecordEntity;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+/**
+ */
+public interface ICallRecordDAO extends JpaRepository<CallRecordEntity, String> {
+    CallRecordEntity save(CallRecordEntity callLogEntity);
+}

src/main/java/com/dashitech/businessdata/entity/CallRecordEntity.java

@@ -0,0 +1,245 @@
+package com.dashitech.businessdata.entity;
+
+import com.dashitech.utils.I18n;
+
+import javax.persistence.*;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * ITSM通话记录表
+ */
+@Entity
+@Table(name = "itsm_call_record")
+public class CallRecordEntity implements Serializable {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    @Column(name = "id", length = 20)
+    private Long id;
+
+    @Version
+    @Column(name = "VERSION")
+    private Integer version;
+
+    @I18n("通话流水")
+    @Column(name = "call_accept")
+    private String callAccept;
+
+    @I18n("主叫名称")
+    @Column(name = "caller_id_number")
+    private String callerIdNumber;
+
+    @I18n("被叫号码")
+    @Column(name = "destination_number")
+    private String destinationNumber;
+
+    @I18n("话务发起时间")
+    @Column(name = "created_time")
+    private Date createdTime;
+
+    @I18n("话务接听时间，如果电话未接，则为空")
+    @Column(name = "answered_time")
+    private Date answeredTime;
+
+    @I18n("话务结束时间")
+    @Column(name = "over_time")
+    private Date overTime;
+
+    @I18n("话务使用的线路")
+    @Column(name = "gate_way")
+    private String gateWay;
+
+    @I18n("通话录音的绝对地址，如果未接通，则为空")
+    @Column(name = "recording_file_name")
+    private String recordingFileName;
+
+    @I18n("自动外呼的任务id号，如果是点击拨号则为空")
+    @Column(name = "batch_accept")
+    private String batchAccept;
+
+    @I18n("点击拨号客户自定义的标识，不传为空")
+    @Column(name = "other_str")
+    private String otherStr;
+
+    @I18n("1,传入的phone作为主叫(呼出)，2，传入的phone作为被叫（呼入），3批量外呼流水号，不传查全部")
+    @Column(name = "call_type")
+    private String callType;
+
+    @I18n("通话时长")
+    @Column(name = "calltime")
+    private String callTime;
+
+    @I18n("线路或者系统返回的状态，无实际意义")
+    @Column(name = "status")
+    private String status;
+
+    @I18n("挂断方")
+    @Column(name = "hangup_side")
+    private String hangupSide;
+
+
+    @I18n("是否被接听，0未接、1已接")
+    @Column(name = "is_answered")
+    private Integer isAnswered;
+
+    @I18n("用户id")
+    @Column(name = "user_id")
+    private Long userId;
+
+    @I18n("院区id")
+    @Column(name = "branch_id")
+    private Long branch;
+
+    public Long getId() {
+        return id;
+    }
+
+    public void setId(Long id) {
+        this.id = id;
+    }
+
+    public Integer getVersion() {
+        return version;
+    }
+
+    public void setVersion(Integer version) {
+        this.version = version;
+    }
+
+    public Long getBranch() {
+        return branch;
+    }
+
+    public void setBranch(Long branch) {
+        this.branch = branch;
+    }
+
+    public Long getUserId() {
+        return userId;
+    }
+
+    public void setUserId(Long userId) {
+        this.userId = userId;
+    }
+
+    public String getCallAccept() {
+        return callAccept;
+    }
+
+    public void setCallAccept(String callAccept) {
+        this.callAccept = callAccept;
+    }
+
+    public String getCallerIdNumber() {
+        return callerIdNumber;
+    }
+
+    public void setCallerIdNumber(String callerIdNumber) {
+        this.callerIdNumber = callerIdNumber;
+    }
+
+    public String getDestinationNumber() {
+        return destinationNumber;
+    }
+
+    public void setDestinationNumber(String destinationNumber) {
+        this.destinationNumber = destinationNumber;
+    }
+
+    public Date getCreatedTime() {
+        return createdTime;
+    }
+
+    public void setCreatedTime(Date createdTime) {
+        this.createdTime = createdTime;
+    }
+
+    public Date getAnsweredTime() {
+        return answeredTime;
+    }
+
+    public void setAnsweredTime(Date answeredTime) {
+        this.answeredTime = answeredTime;
+    }
+
+    public Date getOverTime() {
+        return overTime;
+    }
+
+    public void setOverTime(Date overTime) {
+        this.overTime = overTime;
+    }
+
+    public String getGateWay() {
+        return gateWay;
+    }
+
+    public void setGateWay(String gateWay) {
+        this.gateWay = gateWay;
+    }
+
+    public String getRecordingFileName() {
+        return recordingFileName;
+    }
+
+    public void setRecordingFileName(String recordingFileName) {
+        this.recordingFileName = recordingFileName;
+    }
+
+    public String getBatchAccept() {
+        return batchAccept;
+    }
+
+    public void setBatchAccept(String batchAccept) {
+        this.batchAccept = batchAccept;
+    }
+
+    public String getOtherStr() {
+        return otherStr;
+    }
+
+    public void setOtherStr(String otherStr) {
+        this.otherStr = otherStr;
+    }
+
+    public String getCallType() {
+        return callType;
+    }
+
+    public void setCallType(String callType) {
+        this.callType = callType;
+    }
+
+    public String getCallTime() {
+        return callTime;
+    }
+
+    public void setCallTime(String callTime) {
+        this.callTime = callTime;
+    }
+
+    public String getStatus() {
+        return status;
+    }
+
+    public void setStatus(String status) {
+        this.status = status;
+    }
+
+    public String getHangupSide() {
+        return hangupSide;
+    }
+
+    public void setHangupSide(String hangupSide) {
+        this.hangupSide = hangupSide;
+    }
+
+    public Integer getIsAnswered() {
+        return isAnswered;
+    }
+
+    public void setIsAnswered(Integer isAnswered) {
+        this.isAnswered = isAnswered;
+    }
+}

src/main/java/com/dashitech/callcenter/socket/HandlerThread.java

@@ -1,19 +1,17 @@
 package com.dashitech.callcenter.socket;
 
-import com.dashitech.businessdata.dao.ICallLogDAO;
-import com.dashitech.businessdata.dao.IDepartmentDAO;
-import com.dashitech.businessdata.dao.IDictionaryDAO;
-import com.dashitech.businessdata.dao.IHospitalConfigDAO;
+import com.dashitech.businessdata.dao.*;
 import com.dashitech.businessdata.entity.CallLogEntity;
-import com.dashitech.businessdata.entity.DictionaryEntity;
+import com.dashitech.businessdata.entity.CallRecordEntity;
 import com.dashitech.businessdata.entity.HospitalConfig;
 import com.dashitech.callcenter.webSocket.service.PhoneWebSocket;
+import com.dashitech.utils.DateUtil2;
 import com.dashitech.utils.JsonUtil;
+import com.dashitech.utils.PropertiesUtil;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import net.sf.json.JSONObject;
 import org.apache.commons.lang.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.context.annotation.Configuration;
 import org.springframework.stereotype.Service;
 
 import java.io.DataInputStream;
@@ -21,10 +19,7 @@ import java.io.DataOutputStream;
 import java.net.Socket;
 import java.text.ParseException;
 import java.text.SimpleDateFormat;
-import java.util.Date;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 
 /**
  * Created by chi on 2020/8/6.
@@ -34,6 +29,14 @@ public class HandlerThread  {
 
     //  这里使用静态，让 service 属于类
     private static ICallLogDAO callLogDAO;
+
+    private static ICallRecordDAO callRecordDAO;
+
+    @Autowired
+    public void setCallRecordDAO(ICallRecordDAO callRecordDAO) {
+        HandlerThread.callRecordDAO = callRecordDAO;
+    }
+
     @Autowired
     public void setCallLogDAO(ICallLogDAO callLogDAO) {
         HandlerThread.callLogDAO = callLogDAO;
@@ -57,6 +60,10 @@ public class HandlerThread  {
         HandlerThread.hospitalConfigDAO = hospitalConfigDAO;
     }
 
+    private static String project;
+    private static String recordNginxPath;
+    private static String recordRegex;
+
     private Socket sc;
 
     private static Map<String,String> phoneMap = new HashMap<>();
@@ -95,6 +102,13 @@ public class HandlerThread  {
                 //将信息流转换为String
                 String data = new String(b1);
                 System.out.println("data:"+data+"his"+his);
+
+                if(project == null) {
+                    project = PropertiesUtil.getProperty("project");
+                    recordNginxPath = PropertiesUtil.getProperty("db.hjzx.record.nginx");
+                    recordRegex = PropertiesUtil.getProperty("db.hjzx.record.path.regex");
+                }
+
                 if (data != null || !data.equals("")&&data.substring(0,1).equals("{")) {
                     if (JsonUtil.toJSONObject(data).containsKey("channelStatusList")){
                         List llist = JsonUtil.toJSONObject(data).optJSONArray("channelStatusList");
@@ -372,6 +386,8 @@ public class HandlerThread  {
                 }
                 callLog.setHosId(Integer.parseInt(his));
                 callLogDAO.save(callLog);
+                //TODO 根据配置文件开关，是否保存到ITSM的通话记录数据
+                saveItsmCallRecord(callLog);
             }
         }
     }
@@ -403,6 +419,59 @@ public class HandlerThread  {
         return "暂无";
     }
 
+    /**
+     * 根据配置文件开关，是否保存到ITSM的通话记录数据
+     */
+    private void saveItsmCallRecord(CallLogEntity callLog) {
+        try {
+            if("ITSM".equals(project)) {
+                CallRecordEntity recordEntity = new CallRecordEntity();
+                String uuid = UUID.randomUUID().toString();
+                recordEntity.setCallAccept(uuid);
+                recordEntity.setVersion(0);
+                recordEntity.setCallerIdNumber(callLog.getdTMFA());
+                recordEntity.setDestinationNumber(callLog.getdTMFB());
+                recordEntity.setCreatedTime(callLog.getResponseTime());
+                recordEntity.setCallTime(callLog.getLongTime());
+                recordEntity.setRecordingFileName(callLog.getPath());
+                recordEntity.setIsAnswered(callLog.getCallState());
+
+                //处理结束时间
+                if(callLog.getResponseTime() != null && callLog.getLongTime() != null) {
+                    Date overTime = DateUtil2.addSeconds(callLog.getResponseTime(), Integer.valueOf(callLog.getLongTime()));
+                    recordEntity.setOverTime(overTime);
+                }
+                //院区
+                if(callLog.getHosId() != null) {
+                    recordEntity.setBranch(callLog.getHosId().longValue());
+                }
+                //呼入呼出，其它
+                if(callLog.getCallType() != null) {
+                    if("1".equals(callLog.getCallType().toString())) {
+                        recordEntity.setCallType("2");
+                    }else if("2".equals(callLog.getCallType().toString())) {
+                        recordEntity.setCallType("1");
+                    }else {
+                        recordEntity.setCallType("3");
+                    }
+                }
+                //处理录音地址
+                if(callLog.getPath() != null) {
+                    String newPath = callLog.getPath();
+                    String[] arr = callLog.getPath().split(recordRegex);
+                    if (arr.length > 1) {
+                        newPath = recordNginxPath + arr[1];
+                    }
+                    recordEntity.setRecordingFileName(newPath);
+                }
+                callRecordDAO.save(recordEntity);
+                System.out.println("ITSM保存通话记录完成："+recordEntity.getCallAccept());
+            }
+        } catch (Exception ex) {
+            ex.printStackTrace();
+        }
+    }
+
     public static void main(String[] args) {
         System.out.println(System.currentTimeMillis() / 1000);
     }

src/main/resources/application.properties

@@ -1,11 +1,11 @@
 mysql2.spring.datasource.type=com.alibaba.druid.pool.DruidDataSource
 #\u8F6C\u8FD0\u4E1A\u52A1\u5E93\u6570\u636E\u6E90
 mysql2.spring.datasource.driver-class-name=com.mysql.jdbc.Driver
-mysql2.spring.datasource.url=jdbc:mysql://localhost:3306/hsms2_1129?autoReconnect=true&useUnicode=true&characterEncoding=utf8
-#mysql2.spring.datasource.url=jdbc:mysql://192.168.3.108:3306/hsms2_tjzy_0622?autoReconnect=true&useUnicode=true&characterEncoding=utf8
+#mysql2.spring.datasource.url=jdbc:mysql://localhost:3306/hsms2_1129?autoReconnect=true&useUnicode=true&characterEncoding=utf8
+mysql2.spring.datasource.url=jdbc:mysql://192.168.3.111:3306/md2?autoReconnect=true&useUnicode=true&characterEncoding=utf8
 mysql2.spring.datasource.username=root
-mysql2.spring.datasource.password=DStech@123
-#mysql2.spring.datasource.password=100100
+#mysql2.spring.datasource.password=DStech@123
+mysql2.spring.datasource.password=100100
 
 
 # \u4E0B\u9762\u4E3A\u8FDE\u63A5\u6C60\u7684\u8865\u5145\u8BBE\u7F6E\uFF0C\u5E94\u7528\u5230\u4E0A\u9762\u6240\u6709\u6570\u636E\u6E90\u4E2D
@@ -25,9 +25,13 @@ mysql2.spring.datasource.testWhileIdle=true
 mysql2.spring.datasource.testOnBorrow=true
 mysql2.spring.datasource.testOnReturn=true
 
+#project=HSMS
+project=ITSM
+db.hjzx.record.nginx=/hjzxRecord
+db.hjzx.record.path.regex=voice
 
-spring.redis.host=192.168.245.108
-#spring.redis.host=localhost
+#spring.redis.host=192.168.245.108
+spring.redis.host=localhost
 spring.redis.port=6379
 spring.redis.password=Redis@#6379pwD
 spring.redis.pool.max-total=100