Merge remote-tracking branch 'origin/master'

jiangping

2023-12-06 be0e4466c64ab2def5d2f34fd9394927250153ab

Merge remote-tracking branch 'origin/master'

 server/dmvisit_service/src/main/java/com/doumee/dao/admin/request/DeviceEventQuery.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,35 @@
package com.doumee.dao.admin.request;

import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import org.springframework.stereotype.Repository;

import java.util.Date;

/**
 * @author T14
 */
@Data
@ApiModel("设备事件查询")
public class DeviceEventQuery {

    @ApiModelProperty(value = "关键字")
    private String keyWords;

    @ApiModelProperty(value = "公司名称")
    private String companyName;

    @ApiModelProperty(value = "人员类型")
    private String personType;

    @ApiModelProperty(value = "事件类型")
    private String eventType;

    @ApiModelProperty(value = "开始时间")
    private Date startTime;

    @ApiModelProperty(value = "结束时间")
    private Date endTime;

}

 server/dmvisit_service/src/main/java/com/doumee/dao/admin/response/DeviceEventDTO.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,194 @@
package com.doumee.dao.admin.response;

import com.doumee.core.annotation.excel.ExcelColumn;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.util.Date;

/**
 * @author T14
 */
@Data
@ApiModel("门禁事件推送记录表")
public class DeviceEventDTO {



    @ApiModelProperty(value = "创建人编码")
    private Integer creator;

    @ApiModelProperty(value = "创建时间")
    private Date createDate;

    @ApiModelProperty(value = "更新人编码")
    private Integer editor;

    @ApiModelProperty(value = "更新时间")
    private Date editDate;

    @ApiModelProperty(value = "是否删除0否 1是")
    private Integer isdeleted;

    @ApiModelProperty(value = "备注")
    private String remark;

    @ApiModelProperty(value = "事件唯一标识，同一事件若上报多次，则上报事件的eventId相同")
    private String eventId;

    @ApiModelProperty(value = "事件类型")
    private String eventType;

    @ApiModelProperty(value = "事件源类型，如“acsDevice”")
    private String srcType;

    @ApiModelProperty(value = "事件发生时间（设备时间")
    private String happenTime;

    @ApiModelProperty(value = "门禁点唯一接入编码")
    private String srcIndex;

    @ApiModelProperty(value = "门禁名称")
    @ExcelColumn(name="门禁名称")
    private String srcName;

    @ApiModelProperty(value = "事件状态,0-瞬时1-开始2-停止4-事件联动结果更新5-事件图片异步上传")
    private Integer status;

    @ApiModelProperty(value = "脉冲超时时间，单位：秒，瞬时事件此字段填0")
    private Integer timeout;

    @ApiModelProperty(value = "人员通道号")
    private Integer extAccessChannel;

    @ApiModelProperty(value = "报警输入/防区通道")
    private Integer extEventAlarmInID;

    @ApiModelProperty(value = "报警输出通道")
    private Integer extEventAlarmOutID;

    @ApiModelProperty(value = "卡号")
    private String extEventCardNo;

    @ApiModelProperty(value = "事件输入通道")
    private Integer extEventCaseID;

    @ApiModelProperty(value = "事件类型代码")
    private Integer extEventCode;

    @ApiModelProperty(value = "门编号")
    private Integer extEventDoorID;

    @ApiModelProperty(value = "身份证图片URL")
    @ExcelColumn(name="身份证图片URL")
    private String extEventIDCardPictureURL;

    @ApiModelProperty(value = "进出方向 1-进 0-出 -1:未知 è¦æ±‚：进门读卡器拨码设置为1，出门读卡器拨码设置为2")
    private Integer extEventInOut;

    @ApiModelProperty(value = "就地控制器id")
    private Integer extEventLocalControllerID;

    @ApiModelProperty(value = "主设备拨码")
    private Integer extEventMainDevID;

    @ApiModelProperty(value = "人员编号")
    private String extEventPersonNo;

    @ApiModelProperty(value = "公司/组织")
    private String personCompanyName;

    @ApiModelProperty(value = "手机号")
    private String personPhone;

    @ApiModelProperty(value = "人员类型")
    private String personType;

    @ApiModelProperty(value = "人员身份证号")
    private String personIdcardDecode;

    @ApiModelProperty(value = "人员名称")
    private String personName;

    @ApiModelProperty(value = "读卡器类别0-无效1-IC读卡器2-身份证读卡器3-二维码读卡器4-指纹头")
    private Integer extEventReaderKind;

    @ApiModelProperty(value = "读卡器id")
    private Integer extEventReaderID;

    @ApiModelProperty(value = "图片的url")
    private String extEventPictureURL;

    @ApiModelProperty(value = "图片存储服务器唯一标识")
    private String svrIndexCode;

    @ApiModelProperty(value = "报告上传通道,1-布防int上传2-中心组1上传3-中心组2上传0-无效")
    private Integer extEventReportChannel;

    @ApiModelProperty(value = "群组编号")
    private Integer extEventRoleID;

    @ApiModelProperty(value = "分控制器硬件ID")
    private Integer extEventSubDevID;

    @ApiModelProperty(value = "刷卡次数")
    private Integer extEventSwipNum;

    @ApiModelProperty(value = "门禁事件类型")
    private Integer extEventType;

    @ApiModelProperty(value = "多重认证序号")
    private Long extEventVerifyID;

    @ApiModelProperty(value = "白名单单号")
    private String extEventWhiteListNo;

    @ApiModelProperty(value = "事件上报驱动的时间")
    private String extReceiveTime;

    @ApiModelProperty(value = "事件流水号，为0无效")
    private Integer seq;

    @ApiModelProperty(value = "用户类型，人员类型：0 æœªçŸ¥ï¼Œ1 æ™®é€šï¼Œ2 æ¥å®¾ï¼Œ3 é»‘名单，4 ç®¡ç†å‘˜")
    private Integer userType;

    @ApiModelProperty(value = "身份证住址")
    private String address;

    @ApiModelProperty(value = "身份证出生日期")
    private String birth;

    @ApiModelProperty(value = "身份证有效日期结束时间")
    private String endDate;

    @ApiModelProperty(value = "身份证id")
    private String idNum;

    @ApiModelProperty(value = "身份证签发机关")
    private String issuingAuthority;

    @ApiModelProperty(value = "身份证姓名")
    private String name;

    @ApiModelProperty(value = "身份证性别 0-未知1-男 2-女")
    private Integer sex;

    @ApiModelProperty(value = "身份证有效日期开始时间")
    private String startDate;

    @ApiModelProperty(value = "是否长期有效,0-否（有效截止日期有效）1-是（有效截止日期无效）")
    private Integer termOfValidity;

    @ApiModelProperty(value = "通道号")
    private Integer accessChannel;

    @ApiModelProperty(value = "通道进人数")
    private Integer entryTimes;

    @ApiModelProperty(value = "通道出人数")
    private Integer exitTimes;

    @ApiModelProperty(value = "通道总通行人数")
    private Integer totalTimes;

}

 server/dmvisit_service/src/main/java/com/doumee/dao/business/join/DeviceEventJoinMapper.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,12 @@
package com.doumee.dao.business.join;

import com.doumee.dao.business.model.DeviceEvent;
import com.github.yulichang.base.mapper.MPJJoinMapper;
import org.springframework.stereotype.Repository;

/**
 * @author T14
 */
@Repository
public interface DeviceEventJoinMapper extends MPJJoinMapper<DeviceEvent> {
}

 server/dmvisit_service/src/main/java/com/doumee/dao/business/model/DeviceEvent.java

@@ -1,5 +1,6 @@
package com.doumee.dao.business.model;

import com.baomidou.mybatisplus.annotation.TableField;
import com.doumee.core.annotation.excel.ExcelColumn;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;

 server/dmvisit_service/src/main/java/com/doumee/dao/business/model/DeviceRole.java

@@ -1,5 +1,6 @@
package com.doumee.dao.business.model;

import com.baomidou.mybatisplus.annotation.TableField;
import com.doumee.core.annotation.excel.ExcelColumn;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
@@ -17,7 +18,7 @@
 */
@Data
@ApiModel("门禁角色信息表")
@TableName("`door_role`")
@TableName("`device_role`")
public class DeviceRole {

    @TableId(type = IdType.AUTO)
@@ -96,5 +97,9 @@
    @JsonFormat(pattern = "yyyy-MM-dd")
    private Date hkDate;

    @ApiModelProperty(value = "使用人数")
    @ExcelColumn(name="使用人数")
    @TableField(exist = false)
    private Integer memberNum;

}

 server/dmvisit_service/src/main/java/com/doumee/service/business/DeviceEventService.java

@@ -2,6 +2,8 @@

import com.doumee.core.model.PageData;
import com.doumee.core.model.PageWrap;
import com.doumee.dao.admin.request.DeviceEventQuery;
import com.doumee.dao.admin.response.DeviceEventDTO;
import com.doumee.dao.business.model.DeviceEvent;
import java.util.List;

@@ -14,7 +16,7 @@

    /**
     * åˆ›å»º
     * 
     *
     * @param deviceEvent å®žä½“对象
     * @return Integer
     */
@@ -78,7 +80,7 @@
     * @return List<DeviceEvent>
     */
    List<DeviceEvent> findList(DeviceEvent deviceEvent);
  

    /**
     * åˆ†é¡µæŸ¥è¯¢
     *
@@ -94,4 +96,12 @@
     * @return long
     */
    long count(DeviceEvent deviceEvent);

    /**
     * åˆ†é¡µæŸ¥è¯¢
     *
     * @param pageWrap åˆ†é¡µå¯¹è±¡
     * @return PageData<DeviceEvent>
     */
    PageData<DeviceEventDTO> findDeviceEventDTOPage(PageWrap<DeviceEventQuery> pageWrap);
}

 server/dmvisit_service/src/main/java/com/doumee/service/business/DeviceRoleService.java

@@ -14,7 +14,7 @@

    /**
     * åˆ›å»º
     * 
     *
     * @param deviceRole å®žä½“对象
     * @return Integer
     */
@@ -48,6 +48,14 @@
     */
    void updateById(DeviceRole deviceRole);


    /**
     * ä¸»é”®æ›´æ–°
     *
     * @param deviceRole å®žä½“对象
     */
    void updateStatusById(DeviceRole deviceRole);

    /**
     * æ‰¹é‡ä¸»é”®æ›´æ–°
     *
@@ -78,7 +86,7 @@
     * @return List<DeviceRole>
     */
    List<DeviceRole> findList(DeviceRole deviceRole);
  

    /**
     * åˆ†é¡µæŸ¥è¯¢
     *

 server/dmvisit_service/src/main/java/com/doumee/service/business/impl/DeviceEventServiceImpl.java

@@ -1,20 +1,32 @@
package com.doumee.service.business.impl;

import cn.hutool.core.lang.PatternPool;
import cn.hutool.core.lang.Validator;
import cn.hutool.core.util.PhoneUtil;
import cn.hutool.core.util.ReUtil;
import com.doumee.core.model.PageData;
import com.doumee.core.model.PageWrap;
import com.doumee.core.utils.Utils;
import com.doumee.dao.admin.request.DeviceEventQuery;
import com.doumee.dao.admin.response.DeviceEventDTO;
import com.doumee.dao.business.DeviceEventMapper;
import com.doumee.dao.business.join.DeviceEventJoinMapper;
import com.doumee.dao.business.model.Company;
import com.doumee.dao.business.model.DeviceEvent;
import com.doumee.dao.business.model.Member;
import com.doumee.service.business.DeviceEventService;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.github.yulichang.wrapper.MPJLambdaWrapper;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;

import java.util.List;
import java.util.Objects;

/**
 * é—¨ç¦äº‹ä»¶æŽ¨é€è®°å½•è¡¨Service实现
@@ -26,6 +38,10 @@

    @Autowired
    private DeviceEventMapper deviceEventMapper;


    @Autowired
    private DeviceEventJoinMapper deviceEventJoinMapper;

    @Override
    public Integer create(DeviceEvent deviceEvent) {
@@ -83,7 +99,7 @@
        QueryWrapper<DeviceEvent> wrapper = new QueryWrapper<>(deviceEvent);
        return deviceEventMapper.selectList(wrapper);
    }
  

    @Override
    public PageData<DeviceEvent> findPage(PageWrap<DeviceEvent> pageWrap) {
        IPage<DeviceEvent> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
@@ -268,4 +284,47 @@
        QueryWrapper<DeviceEvent> wrapper = new QueryWrapper<>(deviceEvent);
        return deviceEventMapper.selectCount(wrapper);
    }

    @Override
    public PageData<DeviceEventDTO> findDeviceEventDTOPage(PageWrap<DeviceEventQuery> pageWrap) {

        IPage<DeviceEvent> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
        MPJLambdaWrapper<DeviceEvent> queryWrapper = new MPJLambdaWrapper<>();
        Utils.MP.blankToNull(pageWrap.getModel());

        //是否是数字
        boolean number = Validator.isNumber(pageWrap.getModel().getKeyWords());
        //是否包含中文
        boolean b = Validator.hasChinese(pageWrap.getModel().getKeyWords());
        //是否包含英文
        boolean hasWord = ReUtil.contains(PatternPool.WORD, pageWrap.getModel().getKeyWords());
        queryWrapper.leftJoin(Member.class,Member::getId,DeviceEvent::getExtEventPersonNo)
                    .leftJoin(Company.class,Company::getId,Member::getCompanyId)
                    .selectAll(DeviceEvent.class)
                    .selectAs(Member::getName,DeviceEventDTO::getPersonName)
                    .selectAs(Member::getPhone,DeviceEventDTO::getPersonPhone)
                    .selectAs(Member::getIdcardDecode,DeviceEventDTO::getPersonIdcardDecode)
                    .selectAs(Company::getName,DeviceEventDTO::getPersonCompanyName);
        queryWrapper.like(number,
                            Member::getPhone,
                            pageWrap.getModel().getKeyWords())
                    .like((b||hasWord),
                            Member::getName,
                            pageWrap.getModel().getKeyWords())
                    .eq(StringUtils.isNotBlank(pageWrap.getModel().getPersonType()),
                                                Member::getType,
                                                pageWrap.getModel().getPersonType())
                    .eq(StringUtils.isNotBlank(pageWrap.getModel().getEventType()),
                                                DeviceEvent::getEventType,
                                                pageWrap.getModel().getEventType())
                    .ge(Objects.nonNull(pageWrap.getModel().getStartTime()),
                                                DeviceEvent::getCreateDate,
                                                Utils.Date.getStart(pageWrap.getModel().getStartTime()))
                    .le(Objects.nonNull(pageWrap.getModel().getStartTime()),
                                                DeviceEvent::getCreateDate,
                                                Utils.Date.getDayEnd(pageWrap.getModel().getEndTime()));

        IPage<DeviceEventDTO> deviceEventDTOIPage = deviceEventJoinMapper.selectJoinPage(page, DeviceEventDTO.class, queryWrapper);
        return PageData.from(deviceEventDTOIPage);
    }
}

 server/dmvisit_service/src/main/java/com/doumee/service/business/impl/DeviceRoleServiceImpl.java

@@ -1,7 +1,11 @@
package com.doumee.service.business.impl;

import com.doumee.core.constants.ResponseStatus;
import com.doumee.core.exception.BusinessException;
import com.doumee.core.model.LoginUserInfo;
import com.doumee.core.model.PageData;
import com.doumee.core.model.PageWrap;
import com.doumee.core.utils.Constants;
import com.doumee.core.utils.Utils;
import com.doumee.dao.business.DeviceRoleMapper;
import com.doumee.dao.business.model.DeviceRole;
@@ -10,10 +14,13 @@
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import org.apache.commons.collections.CollectionUtils;
import org.apache.shiro.SecurityUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;


import java.util.Date;
import java.util.List;

/**
@@ -29,8 +36,40 @@

    @Override
    public Integer create(DeviceRole deviceRole) {
        deviceRoleMapper.insert(deviceRole);
        return deviceRole.getId();

        QueryWrapper<DeviceRole> query = new QueryWrapper<>();
        query.lambda()
                .eq(DeviceRole::getIsdeleted,Constants.ZERO)
                .eq(DeviceRole::getType,deviceRole.getType())
                .eq(DeviceRole::getStatus,Constants.ONE);
        List<DeviceRole> deviceRoles = deviceRoleMapper.selectList(query);
        if (CollectionUtils.isNotEmpty(deviceRoles) && Constants.equalsInteger(Constants.ONE,deviceRole.getStatus())){
            throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"同一个用户类型，只能有一个默认角色");
        }

        LoginUserInfo loginUserInfo = (LoginUserInfo)SecurityUtils.getSubject().getPrincipal();
        DeviceRole insert = new DeviceRole();

        insert.setCreator(loginUserInfo.getId().toString());
        insert.setCreateDate(new Date());
        insert.setEdirot(loginUserInfo.getId().toString());
        insert.setEditDate(new Date());
        insert.setIsdeleted(Constants.ZERO);
        insert.setRemark(deviceRole.getRemark());
        insert.setName(deviceRole.getName());
        insert.setIsDefault(Constants.equalsInteger(Constants.ONE,deviceRole.getStatus()) ? 0 : 1);
        insert.setType(deviceRole.getType());
        insert.setDoorIds(deviceRole.getDoorIds());
        insert.setDoorNames(deviceRole.getDoorNames());
        insert.setParkIds(deviceRole.getParkIds());
        insert.setParkNames(deviceRole.getParkNames());
        insert.setStatus(deviceRole.getStatus());
        insert.setHkId(deviceRole.getHkId());
        insert.setHkStatus(deviceRole.getHkStatus());
        insert.setHkDate(deviceRole.getHkDate());

        deviceRoleMapper.insert(insert);
        return insert.getId();
    }

    @Override
@@ -54,7 +93,39 @@

    @Override
    public void updateById(DeviceRole deviceRole) {

        QueryWrapper<DeviceRole> query = new QueryWrapper<>();
        query.lambda()
                .eq(DeviceRole::getIsdeleted,Constants.ZERO)
                .eq(DeviceRole::getType,deviceRole.getType())
                .eq(DeviceRole::getStatus,Constants.ONE);
        List<DeviceRole> deviceRoles = deviceRoleMapper.selectList(query);
        if (CollectionUtils.isNotEmpty(deviceRoles) && Constants.equalsInteger(Constants.ONE,deviceRole.getStatus())){
            throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"同一个用户类型，只能有一个默认角色");
        }
        deviceRole.setIsDefault(Constants.equalsInteger(Constants.ONE,deviceRole.getStatus()) ? 0 : 1);
        deviceRoleMapper.updateById(deviceRole);
    }

    @Override
    public void updateStatusById(DeviceRole deviceRole) {
        QueryWrapper<DeviceRole> query = new QueryWrapper<>();
        query.lambda()
                .eq(DeviceRole::getIsdeleted,Constants.ZERO)
                .eq(DeviceRole::getType,deviceRole.getType())
                .eq(DeviceRole::getStatus,Constants.ONE);
        List<DeviceRole> deviceRoles = deviceRoleMapper.selectList(query);
        if (CollectionUtils.isNotEmpty(deviceRoles) && Constants.equalsInteger(Constants.ONE,deviceRole.getStatus())){
            throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"同一个用户类型，只能有一个默认角色");
        }
        LoginUserInfo loginUserInfo = (LoginUserInfo)SecurityUtils.getSubject().getPrincipal();
        DeviceRole update = new DeviceRole();
        update.setEdirot(loginUserInfo.getId().toString());
        update.setEditDate(new Date());
        update.setId(deviceRole.getId());
        update.setStatus(deviceRole.getStatus());
        update.setIsDefault(Constants.equalsInteger(Constants.ONE,deviceRole.getStatus()) ? 0 : 1);
        deviceRoleMapper.updateById(update);
    }

    @Override
@@ -83,7 +154,7 @@
        QueryWrapper<DeviceRole> wrapper = new QueryWrapper<>(deviceRole);
        return deviceRoleMapper.selectList(wrapper);
    }
  

    @Override
    public PageData<DeviceRole> findPage(PageWrap<DeviceRole> pageWrap) {
        IPage<DeviceRole> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
@@ -136,6 +207,9 @@
        if (pageWrap.getModel().getStatus() != null) {
            queryWrapper.lambda().eq(DeviceRole::getStatus, pageWrap.getModel().getStatus());
        }

        queryWrapper.select("t_aa.*," +
                "(SELECT count(DISTINCT `KEY`) FROM `test` WHERE `test`.`key` = `t_aa`.id ) ");
        for(PageWrap.SortData sortData: pageWrap.getSorts()) {
            if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) {
                queryWrapper.orderByDesc(sortData.getProperty());