话务量统计

hjzx-api/src/main/java/api/controller/report/WorkReportController.java

 package api.controller.report;
 
 import api.controller.BaseController;
-import api.entity.view.report.OnlineServiceReport;
-import api.entity.view.report.RecordReport;
-import api.entity.view.report.ScreenReport;
-import api.entity.view.report.WorkOrderTypeReport;
+import api.entity.view.report.*;
 import api.model.AjaxResult;
 import api.service.report.IReportBaseService;
 import api.util.annotation.Anonymous;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
+import java.text.ParseException;
+
 @Api(value = "报表",tags = "报表")
 @RestController
 @RequestMapping("/WorkReport")
         var obj =ReportBaseService.selectTrafficMeasurement();
         return Success("成功",obj);
     }
-
+    @ApiOperation("话务量统计")
+    @Log(title = "话务统计",businessType = BusinessType.QUERY)
+    @GetMapping("/selectConnection")
+    public AjaxResult selectConnection(ScreenConnection connection) throws ParseException {
+        var obj =ReportBaseService.selectConnection(connection);
+        return Success("成功",obj);
+    }
 
 }

hjzx-entity/src/main/java/api/entity/view/report/ScreenConnection.java

+package api.entity.view.report;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+@ApiModel(value = "ScreenConnection", description = "筛选项")
+@Data
+public class ScreenConnection {
+    /**开始时间**/
+
+    @ApiModelProperty("开始时间")
+    private String startTime;
+
+
+    /**结束时间**/
+
+    @ApiModelProperty("结束时间")
+    private String endTime;
+    /**开始时间**/
+
+    @ApiModelProperty("分组方式")
+    private String grouping;
+
+    /**工号**/
+    @ApiModelProperty("是否接通")
+    private long isAnswer=-1  ;
+
+}

hjzx-mapper/src/main/java/api/mapper/report/ReportMapper.java

     public SatisfactionView selectSatisfaction();
     /**话务量统计**/
     public  TrafficMeasurement selectTrafficMeasurement(Date beginTime, Date endTime);
+    /**话务量统计**/
+    public  List<HourReport> selectConnection(ScreenConnection Report);
 
 }

hjzx-mapper/src/main/resources/mapper/report/ReportMapper.xml

 
 		FROM `rep_record` a
 		WHERE 1=1 AND `callee_agent`!='' AND `callee_agent` IS NOT NULL
-		AND `call_type`=0
+		AND `call_type`=1
 		<if test="startTime != null and startTime !=''">
 			AND UNIX_TIMESTAMP(`create_time`)>=UNIX_TIMESTAMP(#{startTime})
 		</if>
 		WHERE `create_time`>=#{beginTime}  AND `create_time`<![CDATA[<=]]> #{endTime}
 	</select>
 
-
+	<select id="selectConnection"  parameterType="api.entity.view.report.ScreenConnection" resultMap="SysReportHourResult">
+		select
+		count(1) number,
+		DATE_FORMAT(  `create_time`, #{grouping} ) as DATE
+		from rep_record
+		WHERE `create_time`>=#{startTime}  AND `create_time`<![CDATA[<=]]> #{endTime}
+		and call_type=1
+		<if test="isAnswer >-1  ">
+			AND `is_answer`= #{isAnswer}
+		</if>
+		group by DATE
+		order by DATE
+	</select>
 </mapper> 

hjzx-service/src/main/java/api/service/report/IReportBaseService.java

 
 import api.entity.view.report.*;
 
+import java.text.ParseException;
 import java.util.Date;
 import java.util.HashMap;
 import java.util.List;
     List<HourReport>   selectDealingWithTrends(int Date);
 
     //话务量统计
+    List<HourReport>   selectConnection(ScreenConnection connection) throws ParseException;
+
+    //话务量统计
     List<TrafficView>   selectTraffic();
 
     //满意度统计

hjzx-service/src/main/java/api/service/report/impl/ReportBaseServiceImpl.java

 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.text.ParseException;
 import java.text.SimpleDateFormat;
 import java.util.*;
 
         }
         return Report;
     }
+
+    //话务量统计
+    @Override
+    public List<HourReport>   selectConnection(ScreenConnection connection) throws ParseException {
+        // 定义时间格式
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+        SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+        // 将字符串解析为 Date 对象
+        Date time1 = sdf.parse(connection.getStartTime());
+        Date time2 = sdf.parse(connection.getEndTime());
+        // 计算时间差（单位：毫秒）
+        long difference =time2.getTime()- time1.getTime() ;
+        // 将毫秒转换为小时
+        long hours = difference / (1000 * 60 * 60);
+        String Format="HH";int field=11;
+        if (hours>24)
+        {
+            long day=hours/24;
+            if (day>31)
+            {
+                Format="yyyy-MM";field=2;
+                connection.setGrouping("%Y-%m");
+            }
+            else
+            {
+                Format="yyyy-MM-dd";field=6;
+                connection.setGrouping("%Y-%m-%d");
+            }
+        }
+        else
+        {
+            connection.setGrouping("%H");
+        }
+        Date date=new Date();
+        if (!sdf.format(time2).equals(sdf.format(date)))
+        {
+            Calendar calendar3 = Calendar.getInstance();
+            calendar3.setTime(time2);
+            calendar3.set(Calendar.HOUR_OF_DAY, 23);
+            calendar3.set(Calendar.MINUTE, 59);
+            calendar3.set(Calendar.SECOND, 59);
+            date=calendar3.getTime();
+        }
+        connection.setEndTime(sdf1.format(date));
+
+
+        List<HourReport>  Traffic= reportMapper.selectConnection( connection);
+        List<HourReport> Report=new ArrayList<>();
+        Date temp=time1;
+        SimpleDateFormat formatter = new SimpleDateFormat(Format);
+        while (temp.getTime()<=date.getTime())
+        {
+            Calendar calendar2 = Calendar.getInstance();
+            calendar2.setTime(temp);
+            Date finalTemp =calendar2.getTime();
+            HourReport view=new HourReport();
+            view.setDATE(formatter.format(finalTemp));
+            if (Traffic!=null &&Traffic.size()>0)
+            {
+                if (Traffic.stream().anyMatch(x -> x.getDATE().equals(formatter.format(finalTemp)) ))
+                {
+                    var traffaic=Traffic.stream().filter(x->x.getDATE().equals(formatter.format(finalTemp))).
+                            findFirst().get();
+                    view.setNumber(traffaic.getNumber());
+                }
+            }
+            Report.add(view);
+
+            calendar2.add(field,1);
+            temp=calendar2.getTime();
+        }
+        return Report;
+    }
     //话务量统计
     @Override
     public List<TrafficView>   selectTraffic()  {
                 }
             }
             Report.add(view);
-            calendar2.add(Calendar.HOUR_OF_DAY,1);
+            calendar2.add(Calendar.MONTH,1);
             temp=calendar2.getTime();
         }
         return Report;