|
@@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.core.conditions.Wrapper;
|
|
|
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
|
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
|
|
import com.baomidou.mybatisplus.core.toolkit.Constants;
|
|
import com.baomidou.mybatisplus.core.toolkit.Constants;
|
|
|
import com.payment.platform.module.payment.account.entity.TransferEntity;
|
|
import com.payment.platform.module.payment.account.entity.TransferEntity;
|
|
|
|
|
+import org.apache.ibatis.annotations.Insert;
|
|
|
import org.apache.ibatis.annotations.Mapper;
|
|
import org.apache.ibatis.annotations.Mapper;
|
|
|
import org.apache.ibatis.annotations.Param;
|
|
import org.apache.ibatis.annotations.Param;
|
|
|
import org.apache.ibatis.annotations.Select;
|
|
import org.apache.ibatis.annotations.Select;
|
|
@@ -27,6 +28,16 @@ public interface TransferMapper extends BaseMapper<TransferEntity> {
|
|
|
" COALESCE(SUM(CASE WHEN created_time >= #{weekAgo} THEN amount ELSE 0 END), 0) AS amount_of_7days," +
|
|
" COALESCE(SUM(CASE WHEN created_time >= #{weekAgo} THEN amount ELSE 0 END), 0) AS amount_of_7days," +
|
|
|
" COALESCE(SUM(CASE WHEN created_time >= #{today} THEN amount ELSE 0 END), 0) AS amount_of_today " +
|
|
" COALESCE(SUM(CASE WHEN created_time >= #{today} THEN amount ELSE 0 END), 0) AS amount_of_today " +
|
|
|
"FROM pay_transfer ${ew.customSqlSegment}")
|
|
"FROM pay_transfer ${ew.customSqlSegment}")
|
|
|
|
|
+ /** 覆盖基类 insert,payee_info/ext_info 作为 json 列需要显式类型转换 */
|
|
|
|
|
+ @Override
|
|
|
|
|
+ @Insert("INSERT INTO pay_transfer (id, status, out_biz_no, account_book_id, amount, order_title, " +
|
|
|
|
|
+ "payee_info, payee_type, order_no, fund_order_id, error_code, error_msg, remark, " +
|
|
|
|
|
+ "ext_info, retry_count, next_retry_at, enterprise_id, tenant_id, created_time, updated_time) " +
|
|
|
|
|
+ "VALUES (#{id}, #{status}, #{outBizNo}, #{accountBookId}, #{amount}, #{orderTitle}, " +
|
|
|
|
|
+ "#{payeeInfo}::jsonb, #{payeeType}, #{orderNo}, #{fundOrderId}, #{errorCode}, #{errorMsg}, #{remark}, " +
|
|
|
|
|
+ "#{extInfo}::jsonb, #{retryCount}, #{nextRetryAt}, #{enterpriseId}, #{tenantId}, #{createdTime}, #{updatedTime})")
|
|
|
|
|
+ int insert(TransferEntity entity);
|
|
|
|
|
+
|
|
|
Map<String, BigDecimal> statAmounts(
|
|
Map<String, BigDecimal> statAmounts(
|
|
|
@Param("today") OffsetDateTime today,
|
|
@Param("today") OffsetDateTime today,
|
|
|
@Param("weekAgo") OffsetDateTime weekAgo,
|
|
@Param("weekAgo") OffsetDateTime weekAgo,
|