刘光辉
5 小时以前 06f314545ac3514d7ce28939920866ae8188d31c
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
package jnpf.dmsMapper;
 
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import jnpf.dmsEntity.permission.entity.DmsPermissionRevisionEntity;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Insert;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;
 
@Mapper
public interface DmsPermissionRevisionMapper extends BaseMapper<DmsPermissionRevisionEntity> {
 
    @Select("SELECT tenant_id, revision, updated_at FROM public.dms_permission_revisions "
            + "WHERE tenant_id = #{tenantId}")
    DmsPermissionRevisionEntity selectByTenant(@Param("tenantId") String tenantId);
 
    @Select("SELECT COALESCE((SELECT revision FROM public.dms_permission_revisions "
            + "WHERE tenant_id = #{tenantId}), 0)")
    long currentRevision(@Param("tenantId") String tenantId);
 
    @Insert("INSERT INTO public.dms_permission_revisions (tenant_id, revision, updated_at) "
            + "VALUES (#{tenantId}, 1, CURRENT_TIMESTAMP) "
            + "ON CONFLICT (tenant_id) DO UPDATE SET revision = dms_permission_revisions.revision + 1, "
            + "updated_at = CURRENT_TIMESTAMP")
    int bump(@Param("tenantId") String tenantId);
}