优化首页数据

liujun001
1 parent 8cd90575
Showing 8 changed files with 480 additions and 4 deletions
Bsth-admin/src/main/java/com/ruoyi/domain/DriverSchedulingV1.java
Bsth-admin/src/main/java/com/ruoyi/in/domain/CalDriverScheduling.java
Bsth-admin/src/main/java/com/ruoyi/in/domain/SignInV1.java
Bsth-admin/src/main/java/com/ruoyi/service/BigViewServiceV1.java
Bsth-admin/src/main/java/com/ruoyi/service/impl/BigViewServiceV1Impl.java
Bsth-admin/src/main/java/com/ruoyi/template/mapper/FleetLineTemplateMapper.java
Bsth-admin/src/main/java/com/ruoyi/template/service/IFleetLineTemplateService.java
Bsth-admin/src/main/java/com/ruoyi/template/service/impl/FleetLineTemplateServiceImpl.java
+package com.ruoyi.domain;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+
+/**
+ * @author liujun
+ * @date 2024年09月23日 15:36
+ */
+@TableName("scheduling")
+public class DriverSchedulingV1 extends DriverScheduling {
+}
+package com.ruoyi.in.domain;
+
+import com.ruoyi.domain.DriverScheduling;
+import lombok.Data;
+
+/**
+ * @author liujun
+ * @date 2024年09月23日 11:29
+ */
+@Data
+public class CalDriverScheduling {
+
+    private Integer index;
+    private DriverScheduling driverScheduling;
+
+    public CalDriverScheduling(Integer index, DriverScheduling driverScheduling) {
+        this.index = index;
+        this.driverScheduling = driverScheduling;
+    }
+}
+package com.ruoyi.in.domain;
+
+import com.alibaba.fastjson2.JSON;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.ruoyi.common.annotation.Excel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import javax.validation.constraints.NotBlank;
+import javax.validation.constraints.NotNull;
+import java.math.BigDecimal;
+import java.util.Date;
+
+/**
+ * @author liujun
+ * @date 2024年09月23日 15:44
+ */
+@Data
+@TableName("sign_in")
+public class SignInV1 {
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 主键
+     */
+    @ApiModelProperty("主键")
+    private Long id;
+
+    /**
+     * 工号
+     */
+    @Excel(name = "工号")
+    @ApiModelProperty("工号")
+    @NotBlank(message = "工号不能为空")
+    @TableField(value = "jobCode")
+    private String jobCode;
+
+    @Excel(name = "设备号")
+    @ApiModelProperty("设备号")
+    @NotBlank(message = "设备号不能为空")
+    private String deviceId;
+    /**
+     * 设备地址
+     */
+    @Excel(name = "设备地址")
+    @ApiModelProperty("设备ip 不用填写")
+    private String ip;
+
+    /**
+     * 图片
+     */
+    @Excel(name = "图片")
+    @ApiModelProperty("图片信息")
+    @NotBlank(message = "图片信息不能为空")
+    private String image;
+
+    /**
+     * 签到结果
+     */
+    @Excel(name = "签到结果")
+    @ApiModelProperty("签到结果 1 成功 2 异常")
+    private Integer status;
+
+    /**
+     * 签到类型
+     */
+    @Excel(name = "签到类型")
+    @ApiModelProperty("签到类型  1 人脸 2 刷卡 3 其他 4 酒精 用可以多选 用,拼接 如 1,2,3,4")
+    @NotBlank(message = "签到类型不能为空")
+    private String singnIn;
+
+    /**
+     * 酒精测试
+     */
+    @Excel(name = "酒精测试")
+    @ApiModelProperty("酒精测试 1 已测试 2 未测试")
+    @NotNull(message = "酒精测试标识不能为空")
+    private Integer alcoholFlag;
+
+    /**
+     * 签到签退
+     */
+    @Excel(name = "签到签退")
+    @ApiModelProperty("签到签退 1 签到成功 2 签退成功")
+    @NotNull(message = "签到类型不能为空")
+    private Integer type;
+
+    /**
+     * 酒精摄入量
+     */
+    @Excel(name = "酒精摄入量")
+    @ApiModelProperty("酒精摄入量 52.12")
+    private BigDecimal alcoholIntake;
+    @Excel(name = "异常类型", readConverterExp = "0=无异常,1=超时异常,2=无排班异常,3=酒精超标异常,200=早签,300=迟到")
+    @ApiModelProperty("异常类型")
+    private Integer exType;
+
+
+    /**
+     * 创建时间
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
+    private Date createTime;
+
+    /**
+     * 更新者
+     */
+    private String updateBy;
+
+    /**
+     * 更新时间
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
+    private Date updateTime;
+
+    /**
+     * 备注
+     */
+    private String remark;
+
+    @TableField(exist = false)
+    private String name;
+    @TableField(exist = false)
+    private String posts;
+    @TableField(exist = false)
+    private String siteName;
+    @TableField(exist = false)
+    private String address;
+
+    @Override
+    public String toString() {
+        return JSON.toJSONString(this);
+    }
+
+}
+package com.ruoyi.service;
+
+import com.ruoyi.common.core.domain.AjaxResult;
+import com.ruoyi.domain.DriverScheduling;
+import com.ruoyi.driver.domain.Driver;
+import com.ruoyi.in.domain.SignIn;
+import com.ruoyi.pojo.vo.bigViewVo.FleetState;
+import com.ruoyi.pojo.vo.bigViewVo.LineInfo;
+
+import java.util.Date;
+
+public interface BigViewServiceV1 {
+
+    void asyncRefreshRedisValue(SignIn signIn, Driver driver, DriverScheduling driverScheduling,String dateStr) throws InterruptedException;
+
+    AjaxResult queryBigViewQueryLineInfo(Date date);
+
+    LineInfo.PersonInfoVo refreshRedisDriver(SignIn signIn, Driver driver);
+
+    FleetState refreshRedisLine(SignIn signIn, DriverScheduling driverScheduling) throws InterruptedException;
+
+    /***
+     * 判断酒测次数
+     * @author liujun
+     * @date 2024/9/25 14:54
+     *
+     * @param signIn
+     * @return com.ruoyi.common.core.domain.AjaxResult
+     */
+    AjaxResult getAjaxResultByDriverSignInfo(SignIn signIn);
+
+    /***
+     *  是否是早签
+     * @author liujun
+     * @date 2024/9/25 14:51
+     *
+     * @param signIn
+     * @return boolean
+     */
+    boolean isEarly(SignIn signIn);
+
+    /***
+     *  是否是酒驾
+     * @author liujun
+     * @date 2024/9/25 14:33
+     *
+     * @param signIn
+     * @return boolean
+     */
+    boolean isSignStatusWineEnum(SignIn signIn);
+
+
+    /***
+     *  迟到
+     * @author liujun
+     * @date 2024/9/25 14:35
+     *
+     * @param signIn
+     * @return boolean
+     */
+    boolean isSignStatusDelayEnum(SignIn signIn);
+
+    /***
+     * 酒测是否正常
+     * @author liujun
+     * @date 2024/9/25 15:15
+     *
+     * @param signIn
+     * @return boolean
+     */
+    boolean isSignStatusZoneEnum(SignIn signIn);
+}
+package com.ruoyi.service.impl;
+
+import com.alibaba.fastjson2.JSON;
+import com.ruoyi.common.SignStatusEnum;
+import com.ruoyi.common.core.domain.AjaxResult;
+import com.ruoyi.common.core.redis.RedisCache;
+import com.ruoyi.domain.DriverScheduling;
+import com.ruoyi.driver.domain.Driver;
+import com.ruoyi.in.domain.SignIn;
+import com.ruoyi.in.domain.SignInV1;
+import com.ruoyi.pojo.vo.bigViewVo.FleetInfoVo;
+import com.ruoyi.pojo.vo.bigViewVo.FleetState;
+import com.ruoyi.pojo.vo.bigViewVo.LineInfo;
+import com.ruoyi.service.BigViewServiceV1;
+import com.ruoyi.template.domain.FleetLineTemplate;
+import com.ruoyi.template.service.IFleetLineTemplateService;
+import com.ruoyi.utils.ConstDateUtil;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.collections4.CollectionUtils;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.EnableAsync;
+import org.springframework.stereotype.Service;
+
+import java.text.MessageFormat;
+import java.util.*;
+import java.util.concurrent.TimeUnit;
+import java.util.stream.Collectors;
+
+import static com.ruoyi.common.ConstSignInConstSignInProperties.SIGN_IN_ERROR_COUNT;
+import static com.ruoyi.common.ErrorTypeProperties.SIGN_IN_ERROR;
+import static com.ruoyi.common.redispre.GlobalRedisPreName.REDIS_SIGN_IN_DRIVER_ALCOHOL_OVERFLOW;
+
+/**
+ * @author liujun
+ * @date 2024年09月25日 14:38
+ */
+@Slf4j
+@Service
+@EnableAsync
+public class BigViewServiceV1Impl implements BigViewServiceV1 {
+    @Autowired
+    private IFleetLineTemplateService fleetLineTemplateService;
+    @Autowired
+    private RedisCache redisCache;
+
+    private static final String DRIVER_SIGN_KEY = "sign:driver:{0}:{1}";
+
+    private static final String LINE_SIGN_KEY = "sign:line:{0}:{1}";
+
+    private static final String LOCK_LINE_SIGN_KEY = "sign:lock:{0}:{1}";
+
+    private static final String SIGN_REPORT_LIST = "sign:report:list:{0}";
+
+    @Override
+    public void asyncRefreshRedisValue(SignIn signIn, Driver driver, DriverScheduling driverScheduling, String dateStr) throws InterruptedException {
+        String key = MessageFormat.format(SIGN_REPORT_LIST, dateStr);
+
+        refreshRedisDriver(signIn, driver);
+        refreshRedisLine(signIn, driverScheduling);
+    }
+
+    @Override
+    public AjaxResult queryBigViewQueryLineInfo(Date date) {
+        return null;
+    }
+
+
+    @Override
+    public LineInfo.PersonInfoVo refreshRedisDriver(SignIn signIn, Driver driver) {
+        LineInfo.PersonInfoVo personInfoVo = new LineInfo.PersonInfoVo();
+        personInfoVo.setName(driver.getPersonnelName());
+
+        if (isSignStatusZoneEnum(signIn)) {
+            personInfoVo.setSignStatus(SignStatusEnum.SIGN_STATUS_ZONE_ENUM);
+        } else if (isSignStatusWineEnum(signIn)) {
+            personInfoVo.setSignStatus(SignStatusEnum.SIGN_STATUS_WINE_ENUM);
+        } else if (isSignStatusDelayEnum(signIn)) {
+            personInfoVo.setSignStatus(SignStatusEnum.SIGN_STATUS_DELAY_ENUM);
+        }
+        personInfoVo.setPosts(driver.getPosts());
+
+        String dateStr = ConstDateUtil.formatDate(signIn.getCreateTime());
+
+        String key = MessageFormat.format(DRIVER_SIGN_KEY, dateStr, driver.getJobCode());
+        redisCache.setCacheObject(key, JSON.toJSONString(personInfoVo), 25, TimeUnit.HOURS);
+
+        return personInfoVo;
+    }
+
+
+    @Override
+    public FleetState refreshRedisLine(SignIn signIn, DriverScheduling driverScheduling) throws InterruptedException {
+        String dateStr = ConstDateUtil.formatDate(signIn.getCreateTime());
+        String key = MessageFormat.format(LINE_SIGN_KEY, dateStr, driverScheduling.getLineName());
+        FleetState source = redisCache.getCacheObject(key);
+
+        FleetState fleetState = new FleetState();
+        fleetState.setLineName(driverScheduling.getLineName());
+
+        if (isSignStatusWineEnum(signIn)) {
+            fleetState.setState(SignStatusEnum.SIGN_STATUS_WINE_ENUM.getStatus());
+        } else if (isSignStatusDelayEnum(signIn)) {
+            fleetState.setState(SignStatusEnum.SIGN_STATUS_DELAY_ENUM.getStatus());
+        } else {
+            fleetState.setState(SignStatusEnum.SIGN_STATUS_ZONE_ENUM.getStatus());
+        }
+
+        if (Objects.isNull(source) || Objects.isNull(source.getState()) || (fleetState.getState() > source.getState())) {
+            boolean flag = true;
+            String lockKey = MessageFormat.format(LOCK_LINE_SIGN_KEY, dateStr, driverScheduling.getLineName());
+            for (int i = 0; i < 10000; i++) {
+                if (redisCache.setNx(lockKey, fleetState, 10L, TimeUnit.SECONDS)) {
+                    try {
+                        redisCache.setCacheObject(key, JSON.toJSONString(fleetState), 25, TimeUnit.HOURS);
+                    } finally {
+                        redisCache.deleteObject(lockKey);
+                    }
+
+                    flag = false;
+                    break;
+                }
+                log.info("redis的[{}]锁已经被占用，1秒钟后再试", key);
+                Thread.sleep(1000);
+            }
+
+            if (flag) {
+                log.warn("redis的[{}]数据没有刷新成功[{}]", key, fleetState);
+            }
+        }
+        return fleetState;
+    }
+
+    @Override
+    public AjaxResult getAjaxResultByDriverSignInfo(SignIn signIn) {
+        String key = StringUtils.join(REDIS_SIGN_IN_DRIVER_ALCOHOL_OVERFLOW, ConstDateUtil.FAST_YYYY_MM_DD.format(new Date()), ":", signIn.getJobCode());
+        // 驾驶员酒精测试连续超标两次则提示换人
+        Integer count = redisCache.getCacheObject(key);
+        if (Objects.isNull(count) || count.equals(0)) {
+            count = 1;
+            redisCache.setCacheObject(key, count, 1, TimeUnit.DAYS);
+        } else {
+            redisCache.setCacheObject(key, ++count, 1, TimeUnit.DAYS);
+        }
+        if (SIGN_IN_ERROR_COUNT.compareTo(count) <= 0) {
+            SignInV1 signInV1 = new SignInV1();
+            BeanUtils.copyProperties(signIn, signInV1);
+            return AjaxResult.success(SIGN_IN_ERROR + ": " + (StringUtils.isEmpty(signIn.getRemark()) ? "" : signIn.getRemark()) + "酒精测试不通过" + count + "次请更换车辆驾驶员。", signIn);
+        }
+        return null;
+    }
+
+
+    @Override
+    public boolean isEarly(SignIn signIn) {
+        return Objects.nonNull(signIn) && signIn.getExType() >= 20 && signIn.getExType() < 30;
+    }
+
+
+    @Override
+    public boolean isSignStatusWineEnum(SignIn signIn) {
+        return Objects.equals(3, signIn.getExType()) || Objects.equals(23, signIn.getExType()) || Objects.equals(33, signIn.getExType());
+    }
+
+
+    @Override
+    public boolean isSignStatusDelayEnum(SignIn signIn) {
+        return Objects.nonNull(signIn.getExType()) && signIn.getExType() >= 30 && signIn.getExType() < 40;
+    }
+
+    @Override
+    public boolean isSignStatusZoneEnum(SignIn signIn) {
+        return Objects.equals(0, signIn.getExType());
+    }
+
+    private boolean chooseRedisData(String key, SignIn signIn, Driver driver, DriverScheduling driverScheduling) {
+        try {
+            String jsonStr = redisCache.getCacheObject(key);
+            if (StringUtils.isEmpty(jsonStr)) {
+                log.info("redis中没有当天的数据[{}],[{}],[{}],[{}]", key, signIn, driver, driverScheduling);
+                return false;
+            }
+
+            List<FleetInfoVo> fleetInfoVos = JSON.parseArray(jsonStr, FleetInfoVo.class);
+            if (CollectionUtils.isEmpty(fleetInfoVos)) {
+                log.info("redis中的数据为空[{}],[{}],[{}],[{}]", key, signIn, driver, driverScheduling);
+                return false;
+            }
+
+
+        } catch (Exception e) {
+            log.error("刷新签到数据异常[{}],[{}],[{}],[{}]", key, signIn, driver, driverScheduling, e);
+        }
+        return false;
+    }
+
+    private List<FleetInfoVo> saveFleetLineTemp() {
+        List<FleetLineTemplate> fleetLineTemplates = fleetLineTemplateService.selectFleetLineTemplateList();
+        if (CollectionUtils.isEmpty(fleetLineTemplates)) {
+            return null;
+        }
+
+        Map<String, List<FleetLineTemplate>> groupFleetLingTemp = fleetLineTemplates.stream().collect(Collectors.groupingBy(FleetLineTemplate::getFleetName, Collectors.toList()));
+
+        List<FleetInfoVo> fleetInfoVos = new ArrayList<>();
+
+        groupFleetLingTemp.forEach((key, vals) -> {
+            FleetInfoVo fleetInfoVo = new FleetInfoVo();
+            fleetInfoVo.setTitle(key);
+
+            if (CollectionUtils.isNotEmpty(vals)) {
+                List<FleetInfoVo.FleetInfo> fleetInfoVoFleetInfos = new ArrayList<>();
+                List<FleetState> fleetStates = new ArrayList<>();
+                vals.stream().forEach(fl -> {
+                    FleetInfoVo.FleetInfo fleetInfo = new FleetInfoVo.FleetInfo();
+                    fleetInfo.setLineName(fl.getLineName());
+                    fleetInfoVoFleetInfos.add(fleetInfo);
+
+                    FleetState fleetState = new FleetState();
+                    fleetState.setLineName(fl.getLineName());
+                    fleetState.setState(0);
+
+                    fleetStates.add(fleetState);
+                });
+                fleetInfoVo.setFleetInfos(fleetInfoVoFleetInfos);
+                fleetInfoVo.setFleetStates(fleetStates);
+            }
+            fleetInfoVos.add(fleetInfoVo);
+        });
+
+        return fleetInfoVos;
+    }
+}
 package com.ruoyi.template.mapper;
-import java.util.List;
-
 import com.baomidou.mybatisplus.annotation.InterceptorIgnore;
 import com.ruoyi.template.domain.FleetLineTemplate;
 import org.apache.ibatis.annotations.Delete;
 import org.apache.ibatis.annotations.Param;
+import java.util.List;
+
 /**
  * 车队与线路对应模板Mapper接口
  * 
@@ -29,7 +29,7 @@ public interface FleetLineTemplateMapper
      * @param fleetLineTemplate 车队与线路对应模板
      * @return 车队与线路对应模板集合
      */
-    public List<FleetLineTemplate> selectFleetLineTemplateList(FleetLineTemplate fleetLineTemplate);
+     List<FleetLineTemplate> selectFleetLineTemplateList(FleetLineTemplate fleetLineTemplate);
     /**
      * 新增车队与线路对应模板
@@ -35,6 +35,7 @@ public interface IFleetLineTemplateService
      */
      List<FleetLineTemplate> selectFleetLineTemplateList();
+
     /**
      * 新增车队与线路对应模板
      * 
@@ -14,6 +14,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import java.util.List;
+import java.util.concurrent.TimeUnit;
 /**
  * 车队与线路对应模板Service业务层处理
@@ -60,7 +61,7 @@ public class FleetLineTemplateServiceImpl implements IFleetLineTemplateService {
         if (CollectionUtils.isEmpty(fleetLineTemplates)) {
             fleetLineTemplates = selectFleetLineTemplateList(new FleetLineTemplate());
             if (CollectionUtils.isNotEmpty(fleetLineTemplates)) {
-                redisCache.setCacheObject(CONFIG_LINE, JSON.toJSONString(fleetLineTemplates));
+                redisCache.setCacheObject(CONFIG_LINE, JSON.toJSONString(fleetLineTemplates), 25, TimeUnit.HOURS);
             }
         }