feat: 可视化大屏接口

guzijian
1 parent 2563f78e
Showing 11 changed files with 477 additions and 6 deletions
Bsth-admin/src/main/java/com/ruoyi/common/ConstSignInConstSignInProperties.java
Bsth-admin/src/main/java/com/ruoyi/common/SignStatusEnum.java
Bsth-admin/src/main/java/com/ruoyi/controller/BigViewController.java
Bsth-admin/src/main/java/com/ruoyi/driver/mapper/DriverSchedulingMapper.java
Bsth-admin/src/main/java/com/ruoyi/pojo/vo/bigViewVo/FleetInfoVo.java
Bsth-admin/src/main/java/com/ruoyi/pojo/vo/bigViewVo/LineInfo.java
Bsth-admin/src/main/java/com/ruoyi/service/BigViewService.java
Bsth-admin/src/main/java/com/ruoyi/service/SchedulingService.java
Bsth-admin/src/main/java/com/ruoyi/service/ThreadJobService.java
Bsth-admin/src/main/java/com/ruoyi/service/impl/BigViewServiceImpl.java
Bsth-admin/src/main/java/com/ruoyi/utils/ConstDateUtil.java
@@ -64,10 +64,23 @@ public interface ConstSignInConstSignInProperties {
     Integer ALCOHOL_FLAG_NO = 0;
     String ALCOHOL_FLAG_NO_STRING = "未测试";
+    String DRIVER_STRING = "驾驶员";
+    String SALE_STRING = "售票员";
+
     /**
      * 酒精测试异常指定次数 弹出更换驾驶员提示
      */
     Integer SIGN_IN_ERROR_COUNT = 2;
+    /**
+     * 迟到
+     */
+    String DELAY = "迟到";
+
+    /**
+     * 早签
+     */
+    String EARLY = "早签";
+
 }
+package com.ruoyi.common;
+
+/**
+ * 签到状态枚举
+ * @author 20412
+ */
+public enum SignStatusEnum {
+    SIGN_STATUS_ZONE_ENUM(0,"今日签到正常"),
+    SIGN_STATUS_EMPTY_ENUM(1,"今日打卡未签"),
+    SIGN_STATUS_DELAY_ENUM(2,"今日签到迟到"),
+    SIGN_STATUS_WINE_ENUM(3,"今日酒测异常");
+
+
+    SignStatusEnum(Integer status,String description){
+        this.status = status;
+        this.description = description;
+    }
+    private String description;
+    private Integer status;
+
+    public Integer getStatus() {
+        return status;
+    }
+}
 package com.ruoyi.controller;
 import com.ruoyi.common.global.Result;
+import com.ruoyi.pojo.vo.bigViewVo.FleetInfoVo;
+import com.ruoyi.service.BigViewService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
+import java.util.List;
+
 /**
  * 可视化大屏控制controller
  * @author 20412
@@ -16,11 +22,27 @@ import org.springframework.web.bind.annotation.RestController;
 @Api(tags = "可视化大屏")
 public class BigViewController {
+    @Autowired
+    private BigViewService bigViewService;
+
-    @ApiOperation("获取但当天打卡记录")
-    @GetMapping("/getTodayRecord")
-    public Result<?> getTodayRecord(){
-        return Result.OK();
+    /**
+     * 类型 device 设备数量  line  线路数   car   车辆数
+     * sale  售票员签到数量    driver   驾驶员签到    auxiliary   辅助人员签到数量
+     * @param type
+     * @return
+     */
+    @ApiOperation("根据类型获取数值")
+    @GetMapping("/queryNumberByType/{type}")
+    public Result<Integer> queryNumberByType(@PathVariable("type") String type){
+        return Result.OK(bigViewService.queryNumberByType(type));
     }
+    @ApiOperation("获取车队信息")
+    @GetMapping("/queryLineInfo")
+    public Result<List<FleetInfoVo>> queryFleetInfoByFleetName(){
+        return Result.OK(bigViewService.queryFleetInfoByFleetName());
+    }
+
+
 }
@@ -2,6 +2,7 @@ package com.ruoyi.driver.mapper;
 import com.ruoyi.domain.DriverScheduling;
 import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
 import java.math.BigDecimal;
 import java.util.Date;
@@ -20,4 +21,11 @@ public interface DriverSchedulingMapper {
     void updateRoster(@Param("scheduling") DriverScheduling scheduling, @Param("signInId") Long id, @Param("exType") Integer exType, @Param("signTime")Date signTime, @Param("remark") String remark, @Param("signType") Integer signType, @Param("alcoholFlag") Integer alcoholFlag, @Param("alcoholIntake")BigDecimal alcoholIntake);
+    /**
+     * 查询设备数量
+     * @return
+     */
+    @Select("select count(*) from equipment")
+    Integer queryNumberByDevice();
+
 }
+package com.ruoyi.pojo.vo.bigViewVo;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @author 20412
+ */
+@Data
+@ApiModel("车队信息对象")
+public class FleetInfoVo {
+    /**
+     * 车队名称
+     */
+    @ApiModelProperty("车队名称")
+    private String title;
+    @ApiModelProperty("车队信息")
+    private List<FleetInfo> fleetInfos;
+
+    @Data
+    public static class FleetInfo{
+        private String lineName;
+        private List<LineInfo> lineInfos;
+    }
+
+}
+package com.ruoyi.pojo.vo.bigViewVo;
+
+import com.ruoyi.common.SignStatusEnum;
+import lombok.Data;
+
+/**
+ * 有销售人员
+ *
+ * @author 20412
+ */
+@Data
+public class LineInfo {
+    private String nbbm;
+    private PersonInfoVo driverInfoVo;
+    private PersonInfoVo saleInfoVo;
+    @Data
+    public static class PersonInfoVo {
+        private String jobCode;
+        private String name;
+        private Integer signStatus;
+
+        public void setSignStatus(SignStatusEnum statusEnum) {
+            this.signStatus = statusEnum.getStatus();
+        }
+        public void setSignStatus(Integer status) {
+            this.signStatus = status;
+        }
+    }
+}
+package com.ruoyi.service;
+
+import com.ruoyi.pojo.vo.bigViewVo.FleetInfoVo;
+
+import java.util.List;
+
+/**
+ * 可视化大屏服务
+ * @author 20412
+ */
+public interface BigViewService {
+
+    /**
+     * 根据类型获取数量
+     * @param type
+     * @return
+     */
+    Integer queryNumberByType(String type);
+
+    /**
+     * 获取车队信息
+     * @return
+     */
+    List<FleetInfoVo> queryFleetInfoByFleetName();
+
+}
@@ -144,9 +144,9 @@ public class SchedulingService {
         long nowBetween = ChronoUnit.MINUTES.between(ConstDateUtil.getLocalDateTimeByLongTime(date), ConstDateUtil.getLocalDateTimeByLongTime(signIn.getCreateTime().getTime()));
         if (checkTimerSign(nowBetween, scheduling.getBcType())) {
             if (nowBetween < -60L) {
-                sb.append("早签");
+                sb.append(EARLY);
             } else {
-                sb.append("迟到");
+                sb.append(DELAY);
             }
             // 在规定时间就还原remark
         }else {
@@ -48,6 +48,7 @@ import java.io.*;
 import java.math.BigDecimal;
 import java.time.LocalDate;
 import java.util.*;
+import java.util.concurrent.CompletableFuture;
 import java.util.stream.Collectors;
 import static com.ruoyi.common.ConstDriverProperties.BC_TYPE_IN;
+package com.ruoyi.service.impl;
+
+import cn.hutool.core.collection.CollectionUtil;
+import com.ruoyi.common.SignStatusEnum;
+import com.ruoyi.common.cache.NowSchedulingCache;
+import com.ruoyi.domain.DriverScheduling;
+import com.ruoyi.driver.mapper.DriverMapper;
+import com.ruoyi.driver.mapper.DriverSchedulingMapper;
+import com.ruoyi.pojo.vo.bigViewVo.FleetInfoVo;
+import com.ruoyi.pojo.vo.bigViewVo.LineInfo;
+import com.ruoyi.service.BigViewService;
+import com.ruoyi.service.ThreadJobService;
+import com.ruoyi.utils.ConstDateUtil;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.*;
+import java.util.stream.Collectors;
+
+import static com.ruoyi.common.ConstDriverProperties.BC_TYPE_OUT;
+import static com.ruoyi.common.ConstSignInConstSignInProperties.*;
+
+/**
+ * @author 20412
+ */
+@Service
+public class BigViewServiceImpl implements BigViewService {
+
+    private static final Logger log = LoggerFactory.getLogger(BigViewServiceImpl.class);
+
+    @Resource
+    private ThreadJobService threadJobService;
+    @Autowired
+    private DriverSchedulingMapper schedulingMapper;
+
+    @Autowired
+    private DriverMapper driverMapper;
+
+    @Resource
+    private NowSchedulingCache cache;
+
+    @Override
+    public Integer queryNumberByType(String type) {
+        Integer x = handleType(type);
+        if (x != null) return x;
+        return 0;
+    }
+
+    @Override
+    public List<FleetInfoVo> queryFleetInfoByFleetName() {
+        // 从缓存中读取数据，但是调度表中还好包含飞司售人员信息  需要过滤一下  非司售人员nbbm不会存在
+        String key = ConstDateUtil.getStringNowLocalDate("-");
+        Map<String, List<DriverScheduling>> map = cache.getCacheScheduling(key);
+
+        Map<String, LineInfo> matchMap = transformMapByMacheList(map);
+        // 车队和线路 车队为key
+        Map<String, Map<String, List<String>>> mapVo = new HashMap<>(4);
+
+        // 记录所有得签到数据  以车队 -》 线路 -》 人员信息 层次
+        handleFleetWithLine(map, mapVo);
+        // 进一步处理人员信息
+        List<FleetInfoVo> fleetInfoVos = handleFleetWithLinePersonInfo(matchMap, mapVo);
+        return fleetInfoVos;
+    }
+
+    private List<FleetInfoVo> handleFleetWithLinePersonInfo(Map<String, LineInfo> map, Map<String, Map<String, List<String>>> mapVo) {
+        List<FleetInfoVo> vos = new ArrayList<>(4);
+        for (Map.Entry<String, Map<String, List<String>>> entry : mapVo.entrySet()) {
+            Map<String, List<String>> value = entry.getValue();
+            String fleetName = entry.getKey();
+            FleetInfoVo vo = new FleetInfoVo();
+            vo.setTitle(fleetName);
+            vo.setFleetInfos(handleLineInfos(value, map));
+            vos.add(vo);
+        }
+
+        return vos;
+    }
+
+    /**
+     * 信息拼接
+     *
+     * @param value
+     * @param map
+     * @return
+     */
+    private List<FleetInfoVo.FleetInfo> handleLineInfos(Map<String, List<String>> value, Map<String, LineInfo> map) {
+        List<FleetInfoVo.FleetInfo> fleetInfos = new ArrayList<>();
+        for (Map.Entry<String, List<String>> entry : value.entrySet()) {
+            String lineName = entry.getKey();
+            List<String> nbbms = entry.getValue();
+            FleetInfoVo.FleetInfo fleetInfo = new FleetInfoVo.FleetInfo();
+            fleetInfo.setLineName(lineName);
+            List<LineInfo> lineInfos = new ArrayList<>();
+            for (String nbbm : nbbms) {
+                LineInfo info = map.get(nbbm);
+                lineInfos.add(info);
+            }
+            lineInfos.sort(Comparator.comparing(LineInfo::getNbbm).reversed());
+            fleetInfo.setLineInfos(lineInfos);
+            fleetInfos.add(fleetInfo);
+        }
+        return fleetInfos;
+    }
+
+    /**
+     * 设置车队和线路 以车队为key
+     */
+    private void handleFleetWithLine(Map<String, List<DriverScheduling>> map, Map<String, Map<String, List<String>>> mapVo) {
+        // 整合车队
+        for (Map.Entry<String, List<DriverScheduling>> entry : map.entrySet()) {
+            // 过滤进场   系统设置出场为签到  进场为签退
+            List<DriverScheduling> value = entry.getValue().stream().filter(item -> BC_TYPE_OUT.equals(item.getBcType()) && !Objects.isNull(item.getNbbm())).collect(Collectors.toList());
+            if (CollectionUtil.isNotEmpty(value)) {
+                String fleetName = value.get(0).getFleetName();
+                Map<String, List<String>> distinctMap = mapVo.get(fleetName);
+                if (CollectionUtil.isEmpty(distinctMap)) {
+                    distinctMap = new HashMap<>(value.size());
+                    //  线路去重
+                    for (DriverScheduling scheduling : value) {
+                        handleDistinctMap(distinctMap, scheduling);
+                    }
+                    // 把线路和自编号放入集合
+                    mapVo.put(fleetName, distinctMap);
+                } else {
+                    for (DriverScheduling scheduling : value) {
+                        handleDistinctMap(distinctMap, scheduling);
+                    }
+                    mapVo.put(fleetName, distinctMap);
+                }
+            }
+        }
+        // 对自编号进行去重
+        for (Map.Entry<String, Map<String, List<String>>> entry : mapVo.entrySet()) {
+            Map<String, List<String>> value = entry.getValue();
+            for (Map.Entry<String, List<String>> listEntry : value.entrySet()) {
+                listEntry.setValue(listEntry.getValue().stream().distinct().collect(Collectors.toList()));
+            }
+        }
+    }
+
+    private void handleDistinctMap(Map<String, List<String>> distinctMap, DriverScheduling scheduling) {
+        List<String> distinct = distinctMap.get(scheduling.getLineName());
+        if (CollectionUtil.isEmpty(distinct)) {
+            distinctMap.put(scheduling.getLineName(), new ArrayList<>(Arrays.asList(scheduling.getNbbm())));
+        } else {
+            distinct.add(scheduling.getNbbm());
+        }
+    }
+
+
+    /**
+     * 自编号为key 存储人员信息
+     *
+     * @param map
+     * @return
+     */
+    private Map<String, LineInfo> transformMapByMacheList(Map<String, List<DriverScheduling>> map) {
+        Map<String, LineInfo> matchMap = new HashMap<>();
+        for (Map.Entry<String, List<DriverScheduling>> entry : map.entrySet()) {
+            List<DriverScheduling> value = entry.getValue();
+            List<DriverScheduling> list = value.stream().filter(item -> BC_TYPE_OUT.equals(item.getBcType()) && !Objects.isNull(item.getNbbm())).sorted(Comparator.comparing(DriverScheduling::getFcsjT)).collect(Collectors.toList());
+            for (DriverScheduling scheduling : list) {
+                // 把每辆车的人员信息收集起来
+                String nbbm = scheduling.getNbbm();
+                LineInfo lineInfoList = matchMap.get(nbbm);
+                if (Objects.isNull(lineInfoList)) {
+                    LineInfo lineInfo = new LineInfo();
+                    lineInfo.setNbbm(nbbm);
+                    LineInfo.PersonInfoVo personInfoVo = getPersonInfoVo(scheduling);
+                    if (DRIVER_STRING.equals(scheduling.getPosts())) {
+                        lineInfo.setDriverInfoVo(personInfoVo);
+                    } else {
+                        lineInfo.setSaleInfoVo(personInfoVo);
+                    }
+                    matchMap.put(nbbm, lineInfo);
+                } else {
+                    LineInfo.PersonInfoVo personInfoVo = getPersonInfoVo(scheduling);
+                    handleMoreStatus(matchMap, scheduling, nbbm, personInfoVo, scheduling);
+                }
+            }
+        }
+        return matchMap;
+    }
+
+    /**
+     * 判断是否有多次签到，且签到时间未到
+     *
+     * @param matchMap
+     * @param scheduling
+     * @param nbbm
+     * @param personInfoVo
+     * @param driverScheduling
+     */
+    private void handleMoreStatus(Map<String, LineInfo> matchMap, DriverScheduling scheduling, String nbbm, LineInfo.PersonInfoVo personInfoVo, DriverScheduling driverScheduling) {
+        long time = System.currentTimeMillis();
+        if (DRIVER_STRING.equals(scheduling.getPosts())) {
+            LineInfo.PersonInfoVo driverInfoVo = matchMap.get(nbbm).getDriverInfoVo();
+            // 第二次签到时间未到不记录状态
+            if (!Objects.isNull(driverInfoVo) && time - scheduling.getFcsjT() < 0) {
+                return;
+            }
+                matchMap.get(nbbm).setDriverInfoVo(personInfoVo);
+        } else {
+            LineInfo.PersonInfoVo saleInfoVo = matchMap.get(nbbm).getSaleInfoVo();
+            // 第二次签到时间未到不记录状态
+            if (!Objects.isNull(saleInfoVo) && time - scheduling.getFcsjT() < 0) {
+                return;
+            }
+            matchMap.get(nbbm).setSaleInfoVo(personInfoVo);
+        }
+    }
+
+    private LineInfo.PersonInfoVo getPersonInfoVo(DriverScheduling scheduling) {
+        LineInfo.PersonInfoVo personInfoVo = new LineInfo.PersonInfoVo();
+        if (Objects.isNull(scheduling.getExType())) {
+            personInfoVo.setSignStatus(SignStatusEnum.SIGN_STATUS_EMPTY_ENUM);
+        } else {
+            switch (scheduling.getExType()) {
+                case 0:
+                    personInfoVo.setSignStatus(SignStatusEnum.SIGN_STATUS_ZONE_ENUM);
+                    break;
+                case 1:
+                    // 不在规定范围内  早签不算迟到
+                    if (EARLY.equals(scheduling.getRemark())) {
+                        personInfoVo.setSignStatus(SignStatusEnum.SIGN_STATUS_DELAY_ENUM);
+                    }
+                    break;
+                case 3:
+                    personInfoVo.setSignStatus(SignStatusEnum.SIGN_STATUS_WINE_ENUM);
+                    break;
+            }
+        }
+        personInfoVo.setJobCode(scheduling.getJobCode());
+        personInfoVo.setName(scheduling.getName());
+        return personInfoVo;
+    }
+
+    private Integer handleType(String type) {
+        String key = ConstDateUtil.getStringNowLocalDate("-");
+        Map<String, List<DriverScheduling>> map = cache.getCacheScheduling(key);
+        Map<String, Object> typeMap = new HashMap<>(map.size());
+        switch (type) {
+            case "device":
+                return schedulingMapper.queryNumberByDevice();
+            case "line":
+                for (Map.Entry<String, List<DriverScheduling>> entry : map.entrySet()) {
+                    for (DriverScheduling scheduling : entry.getValue()) {
+                        typeMap.put(scheduling.getLineName(), "");
+                    }
+                }
+                return typeMap.size();
+            case "car":
+                for (Map.Entry<String, List<DriverScheduling>> entry : map.entrySet()) {
+                    for (DriverScheduling scheduling : entry.getValue()) {
+                        typeMap.put(scheduling.getNbbm(), "");
+                    }
+                }
+                return typeMap.size();
+            case "sale":
+                for (Map.Entry<String, List<DriverScheduling>> entry : map.entrySet()) {
+                    for (DriverScheduling scheduling : entry.getValue()) {
+                        if (SALE_STRING.equals(scheduling.getPosts()) && BC_TYPE_OUT.equals(scheduling.getBcType()) && !Objects.isNull(scheduling.getNbbm()) && !Objects.isNull(scheduling.getSignInId())) {
+                            typeMap.put(scheduling.getJobCode() + scheduling.getBcType(), "");
+                        }
+                    }
+                }
+                return typeMap.size();
+            case "driver":
+                for (Map.Entry<String, List<DriverScheduling>> entry : map.entrySet()) {
+                    for (DriverScheduling scheduling : entry.getValue()) {
+                        if (DRIVER_STRING.equals(scheduling.getPosts()) && BC_TYPE_OUT.equals(scheduling.getBcType()) && !Objects.isNull(scheduling.getNbbm()) && !Objects.isNull(scheduling.getSignInId())) {
+                            typeMap.put(scheduling.getJobCode() + scheduling.getBcType(), "");
+                        }
+                    }
+                }
+                return typeMap.size();
+            case "auxiliary":
+                for (Map.Entry<String, List<DriverScheduling>> entry : map.entrySet()) {
+                    for (DriverScheduling scheduling : entry.getValue()) {
+                        if (Objects.isNull(scheduling.getNbbm()) && BC_TYPE_OUT.equals(scheduling.getBcType())) {
+                            typeMap.put(scheduling.getJobCode() + scheduling.getBcType(), "");
+                        }
+                    }
+                }
+                return typeMap.size();
+            default:
+                return 0;
+        }
+    }
+}
@@ -11,6 +11,31 @@ import java.util.List;
 public class ConstDateUtil {
+    public static String getStringNowLocalDate(){
+        // 指定当前日期和时间
+        LocalDate currentDate = LocalDate.now();
+        LocalTime timeRange = LocalTime.of(2, 50);
+        LocalTime now = LocalTime.now();
+        if (now.isBefore(timeRange)){
+            // 在日期的前一天
+            currentDate = currentDate.minusDays(1);
+        }
+        return currentDate.toString();
+    }
+
+    public static String getStringNowLocalDate(String delStr){
+        // 指定当前日期和时间
+        LocalDate currentDate = LocalDate.now();
+        LocalTime timeRange = LocalTime.of(2, 50);
+        LocalTime now = LocalTime.now();
+        if (now.isBefore(timeRange)){
+            // 在日期的前一天
+            currentDate = currentDate.minusDays(1);
+        }
+        return currentDate.toString().replaceAll(delStr,"");
+    }
+
+
     public static LocalDateTime stringTransformLocalDateTime(String dateString, String pattern){
         DateTimeFormatter formatter = DateTimeFormatter.ofPattern(pattern);
         return LocalDateTime.parse(dateString,formatter);