package jnpf.elnMapper;
|
|
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
import jnpf.elnEntity.runtime.ElnSharedFillOperationEntity;
|
import org.apache.ibatis.annotations.Insert;
|
import org.apache.ibatis.annotations.Mapper;
|
import org.apache.ibatis.annotations.Param;
|
import org.apache.ibatis.annotations.Update;
|
|
@Mapper
|
public interface ElnSharedFillOperationMapper
|
extends BaseMapper<ElnSharedFillOperationEntity> {
|
|
@Insert("INSERT INTO eln_shared_fill_operation "
|
+ "(operation_code, request_digest, operation_status, operator_user_id, "
|
+ "f_id, f_tenant_id, f_version, f_creator_user_id, f_creator_time, "
|
+ "f_delete_mark) VALUES "
|
+ "(#{value.operationCode}, #{value.requestDigest}, 'OPEN', "
|
+ "#{value.operatorUserId}, #{value.id}, #{value.fTenantId}, 0, "
|
+ "#{value.operatorUserId}, CURRENT_TIMESTAMP, 0) "
|
+ "ON CONFLICT (f_tenant_id, operation_code) DO NOTHING")
|
int insertIgnore(@Param("value") ElnSharedFillOperationEntity value);
|
|
@Update("UPDATE eln_shared_fill_operation SET operation_status = 'COMPLETED', "
|
+ "result_json = #{resultJson}, f_version = f_version + 1, "
|
+ "f_last_modify_user_id = #{userId}, f_last_modify_time = CURRENT_TIMESTAMP "
|
+ "WHERE f_tenant_id = #{tenantId} AND operation_code = #{operationCode} "
|
+ "AND request_digest = #{requestDigest} AND operation_status = 'OPEN' "
|
+ "AND COALESCE(f_delete_mark, 0) = 0")
|
int complete(@Param("tenantId") String tenantId,
|
@Param("operationCode") String operationCode,
|
@Param("requestDigest") String requestDigest,
|
@Param("resultJson") String resultJson,
|
@Param("userId") String userId);
|
|
@Update("UPDATE eln_shared_fill_operation SET result_json = #{resultJson}, "
|
+ "f_version = f_version + 1, f_last_modify_user_id = #{userId}, "
|
+ "f_last_modify_time = CURRENT_TIMESTAMP "
|
+ "WHERE f_tenant_id = #{tenantId} AND operation_code = #{operationCode} "
|
+ "AND request_digest = #{requestDigest} AND operation_status = 'OPEN' "
|
+ "AND result_json IS NULL AND COALESCE(f_delete_mark, 0) = 0")
|
int prepareResult(@Param("tenantId") String tenantId,
|
@Param("operationCode") String operationCode,
|
@Param("requestDigest") String requestDigest,
|
@Param("resultJson") String resultJson,
|
@Param("userId") String userId);
|
|
@Update("UPDATE eln_shared_fill_operation SET operation_status = 'COMPLETED', "
|
+ "f_version = f_version + 1, f_last_modify_user_id = #{userId}, "
|
+ "f_last_modify_time = CURRENT_TIMESTAMP "
|
+ "WHERE f_tenant_id = #{tenantId} AND operation_code = #{operationCode} "
|
+ "AND operator_user_id = #{userId} AND operation_status = 'OPEN' "
|
+ "AND result_json IS NOT NULL AND COALESCE(f_delete_mark, 0) = 0")
|
int confirmPrepared(@Param("tenantId") String tenantId,
|
@Param("operationCode") String operationCode,
|
@Param("userId") String userId);
|
}
|
