| | |
| | | import com.baomidou.mybatisplus.core.mapper.BaseMapper; |
| | | import com.tourguide.modules.user.entity.GuideUser; |
| | | import org.apache.ibatis.annotations.Param; |
| | | import org.apache.ibatis.annotations.Select; |
| | | import org.apache.ibatis.annotations.Update; |
| | | |
| | | import java.math.BigDecimal; |
| | | |
| | | public interface GuideUserMapper extends BaseMapper<GuideUser> { |
| | | @Select("SELECT * FROM guide_user WHERE id = #{guideId} AND deleted = 0 FOR UPDATE") |
| | | GuideUser selectForUpdate(@Param("guideId") Long guideId); |
| | | |
| | | @Select("SELECT COALESCE(balance, 0) FROM guide_user WHERE id = #{guideId} AND deleted = 0") |
| | | BigDecimal selectBalance(@Param("guideId") Long guideId); |
| | | |
| | | @Update("UPDATE guide_user SET balance = balance + #{amount}, updated_at = NOW() " + |
| | | "WHERE id = #{guideId} AND deleted = 0") |
| | | int increaseBalance(@Param("guideId") Long guideId, @Param("amount") BigDecimal amount); |
| | | |
| | | @Update("UPDATE guide_user SET balance = balance - #{amount}, updated_at = NOW() " + |
| | | "WHERE id = #{guideId} AND deleted = 0 AND balance >= #{amount}") |
| | | int decreaseBalance(@Param("guideId") Long guideId, @Param("amount") BigDecimal amount); |
| | | |
| | | @Update("UPDATE guide_user SET balance = GREATEST(balance - #{amount}, 0), updated_at = NOW() " + |
| | | "WHERE id = #{guideId} AND deleted = 0") |
| | | int decreaseBalanceForRefund(@Param("guideId") Long guideId, @Param("amount") BigDecimal amount); |
| | | |
| | | @Update("UPDATE guide_user SET accepted_order_count = accepted_order_count + 1, " + |
| | | "current_month_order_count = current_month_order_count + 1, updated_at = NOW() " + |
| | | "WHERE id = #{guideId} AND deleted = 0 AND status = 1") |
| | | int incrementAcceptedOrderCount(Long guideId); |
| | | |
| | | @Update("UPDATE guide_user SET status = 0, updated_at = NOW() " + |
| | | @Update("UPDATE guide_user SET status = 0, auto_disabled = 1, updated_at = NOW() " + |
| | | "WHERE id = #{guideId} AND deleted = 0 AND status = 1 " + |
| | | "AND COALESCE(auto_disable_whitelisted, 0) = 0 " + |
| | | "AND accepted_order_count >= #{orderThreshold} " + |
| | |
| | | int autoDisableIfEligible(@Param("guideId") Long guideId, |
| | | @Param("orderThreshold") Integer orderThreshold, |
| | | @Param("ratingThreshold") BigDecimal ratingThreshold); |
| | | |
| | | @Update("UPDATE guide_user SET status = 1, auto_disabled = 0, updated_at = NOW() " + |
| | | "WHERE deleted = 0 AND status = 0 AND auto_disabled = 1 " + |
| | | "AND (COALESCE(auto_disable_whitelisted, 0) = 1 " + |
| | | "OR COALESCE(accepted_order_count, 0) < #{orderThreshold} " + |
| | | "OR COALESCE(rating, 0) <= 0 OR rating > #{ratingThreshold})") |
| | | int restoreAutoDisabledGuidesNoLongerEligible(@Param("orderThreshold") Integer orderThreshold, |
| | | @Param("ratingThreshold") BigDecimal ratingThreshold); |
| | | } |