置忙数据

jyxx

@@ -0,0 +1 @@
+OS9NTEFlcDdtcDlsVWdUM2V3anVIeDhpRURRdXdiUjloeHVQbDk3cUt6RitmTThzajZqWksvU0o4dWFhM3MyRg==

midware-api/src/main/resources/application-dev.yml

@@ -5,7 +5,7 @@ spring:
   datasource:
     type: com.alibaba.druid.pool.DruidDataSource
     driver-class-name: com.mysql.cj.jdbc.Driver
-    url: jdbc:mysql://192.168.1.200:3306/hjzx?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull&useSSL=false&serverTimezone=GMT%2B8&autoReconnect=true&rewriteBatchedStatements=true&nullCatalogMeansCurrent=true
+    url: jdbc:mysql://192.168.1.8:3306/hjzx?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull&useSSL=false&serverTimezone=GMT%2B8&autoReconnect=true&rewriteBatchedStatements=true&nullCatalogMeansCurrent=true
     username: root
     password: 800100
 

midware-entity/src/main/java/midware/entity/database/rep/Busy.java

@@ -0,0 +1,29 @@
+package midware.entity.database.rep;
+
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.util.Date;
+
+@Data
+@TableName("rep_busy")
+public class Busy {
+    /** 主键id */
+    @TableId(type = IdType.AUTO)
+    private Long id;
+    /** 坐席工号 */
+    private String agent;
+    /** exten */
+    private String exten;
+    /** 开始时间 */
+    private Date createTime;
+    /** 结束时间 */
+    private Date endTime;
+    /** 置忙时长（秒） */
+    private Long busyDuration;
+    /** 是否推送 */
+    private Long isPush;
+}

midware-mapper/src/main/java/midware/mapper/rep/BusyMapper.java

@@ -0,0 +1,9 @@
+package midware.mapper.rep;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import midware.entity.database.rep.Busy;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface BusyMapper extends BaseMapper<Busy> {
+}

midware-service/src/main/java/midware/service/eslclient/EslCommon.java

@@ -47,6 +47,9 @@ public class EslCommon {
 
     public static List<AgentAction> actions=new ArrayList<>();
     public static List<AgentState> states=new ArrayList<>();
+
+    public static List<Busy> busys=new ArrayList<>();
+
     public static List<ChanEvent> events=new ArrayList<>();
     public static List<Asr> asrs=new ArrayList<>();
 

midware-service/src/main/java/midware/service/eslclient/entity/Agent.java

@@ -5,13 +5,13 @@ import lombok.Data;
 import lombok.Setter;
 import lombok.extern.slf4j.Slf4j;
 import midware.entity.database.rep.AgentState;
+import midware.entity.database.rep.Busy;
 import midware.service.eslclient.EslCommon;
 import midware.service.init.WebSocketService;
 import midware.util.helper.SpringHelper;
 
-import java.util.Date;
-import java.util.HashMap;
-import java.util.Map;
+import java.util.*;
+import java.util.stream.Collectors;
 
 @Slf4j
 @Data
@@ -61,5 +61,53 @@ public class Agent {
         synchronized (EslCommon.states) {
             EslCommon.states.add(as);
         }
+        synchronized (EslCommon.busys) {
+            if (s==5)
+            {
+                handleBusyStateStart(as);
+            }
+            else {
+                handleBusyStateEnd(as);
+            }
+        }
+    }
+    private void handleBusyStateStart(AgentState state) {
+        String agent = state.getAgent();
+        Date currentTime = new Date(); // 当前时间
+        // 检查该坐席是否已经有未结束的忙碌记录
+        boolean hasUnfinishedBusy = EslCommon.busys.stream()
+                .anyMatch(busy -> agent.equals(busy.getAgent()) && busy.getEndTime() == null);
+        if (hasUnfinishedBusy) {
+            // 如果有未结束的记录，先结束它
+            endExistingBusyRecord(agent, currentTime);
+        }
+        // 创建新的忙碌记录
+        Busy newBusy = new Busy();
+        newBusy.setAgent(agent);
+        newBusy.setExten(state.getExten());
+        newBusy.setCreateTime(currentTime);
+        newBusy.setEndTime(null); // 结束时间为空
+        newBusy.setBusyDuration(0L); // 刚开始，时长为0
+        newBusy.setIsPush(0L); // 未推送
+        EslCommon.busys.add(newBusy);
+    }
+    private void handleBusyStateEnd(AgentState state) {
+        String agent = state.getAgent();
+        Date currentTime = new Date();
+        // 结束该坐席所有未结束的忙碌记录
+        endExistingBusyRecord(agent, currentTime);
     }
+    private void endExistingBusyRecord(String agent, Date endTime) {
+        List<Busy> unfinishedRecords = EslCommon.busys.stream()
+                .filter(busy -> agent.equals(busy.getAgent()) && busy.getEndTime() == null)
+                .collect(Collectors.toList());
+        for (Busy busy : unfinishedRecords) {
+            // 计算忙碌时长（秒）
+            long duration = (endTime.getTime() - busy.getCreateTime().getTime()) / 1000;
+            // 更新记录
+            busy.setEndTime(endTime);
+            busy.setBusyDuration(duration);
+        }
+    }
+
 }

midware-service/src/main/java/midware/service/quartz/job/BatchInsertJob.java

@@ -10,6 +10,7 @@ import org.quartz.JobExecutionContext;
 
 import java.util.ArrayList;
 import java.util.List;
+import java.util.stream.Collectors;
 
 //批量插入数据库
 public class BatchInsertJob extends QuartzJob {
@@ -55,5 +56,15 @@ public class BatchInsertJob extends QuartzJob {
             }
             SpringHelper.getBean(IAsrService.class).insert(asrs);
         }
+        if(EslCommon.busys.size()>0) {
+            List<Busy> busyList = new ArrayList<>();
+            synchronized (EslCommon.busys) {
+                busyList = EslCommon.busys.stream()
+                        .filter(busy -> busy.getCreateTime() != null && busy.getEndTime() != null)
+                        .collect(Collectors.toList());
+                EslCommon.busys.removeAll(busyList);
+            }
+            SpringHelper.getBean(IBusyService.class).insert(busyList);
+        }
     }
 }

midware-service/src/main/java/midware/service/rep/IBusyService.java

@@ -0,0 +1,7 @@
+package midware.service.rep;
+
+import midware.entity.database.rep.Busy;
+import midware.service.IBaseService;
+
+public interface IBusyService extends IBaseService<Busy> {
+}

midware-service/src/main/java/midware/service/rep/impl/BusyServiceImpl.java

@@ -0,0 +1,14 @@
+package midware.service.rep.impl;
+
+import midware.entity.database.rep.Busy;
+import midware.mapper.rep.BusyMapper;
+import midware.service.BaseServiceImpl;
+import midware.service.rep.IBusyService;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+@Transactional
+@Service
+public class BusyServiceImpl extends BaseServiceImpl<BusyMapper, Busy> implements IBusyService {
+    public BusyServiceImpl(){ super(false); }
+}