Download功能
Change-Id: Ic96f074ab7026f631348587b6e95332a60e7e6d8
diff --git a/src/main/java/com/pt5/pthouduan/mapper/TorrentMapper.java b/src/main/java/com/pt5/pthouduan/mapper/TorrentMapper.java
index e7ba2a3..2d3e7e3 100644
--- a/src/main/java/com/pt5/pthouduan/mapper/TorrentMapper.java
+++ b/src/main/java/com/pt5/pthouduan/mapper/TorrentMapper.java
@@ -2,9 +2,7 @@
import com.pt5.pthouduan.entity.Torrent;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import org.apache.ibatis.annotations.Mapper;
-import org.apache.ibatis.annotations.Param;
-import org.apache.ibatis.annotations.Select;
+import org.apache.ibatis.annotations.*;
import java.util.List;
import java.util.Map;
@@ -38,4 +36,17 @@
Torrent selectByinfohash(@Param("infohash") String infohash);
List<Torrent> listByCategoryWithFilters(Integer categoryid, Map<String, String> filters, String extendTable);
+
+// void delete(Torrent torrent);
+ @Delete("DELETE FROM torrent WHERE torrentid = #{id}")
+ void deleteById(Long id);
+
+ @Update("UPDATE torrent SET promotionid = #{promotionId} WHERE torrentid = #{torrentid}")
+ void setpromotion(Long torrentid, Long promotionId);
+
+ @Update("UPDATE torrent SET coverImagePath = #{coverImagePath} WHERE torrentid = #{torrentId}")
+ void updateCoverImagePath(Long torrentId, String coverImagePath);
+
+ @Update("UPDATE request_resource SET torrentid = #{torrentid} WHERE rewuestid = #{requestid}")
+ void updaterequest(int requestid,Long torrentid);
}
diff --git a/src/main/java/com/pt5/pthouduan/mapper/UserMapper.java b/src/main/java/com/pt5/pthouduan/mapper/UserMapper.java
index 2f96180..47dcfc9 100644
--- a/src/main/java/com/pt5/pthouduan/mapper/UserMapper.java
+++ b/src/main/java/com/pt5/pthouduan/mapper/UserMapper.java
@@ -1,12 +1,13 @@
package com.pt5.pthouduan.mapper;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.pt5.pthouduan.entity.PeerInfo;
import com.pt5.pthouduan.entity.User;
-import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.*;
import org.springframework.stereotype.Repository;
import java.util.List;
+import java.util.Map;
/**
* <p>
@@ -30,9 +31,24 @@
@Select("SELECT credit FROM User WHERE username = #{username}")
int getcreditByUsername(String username);
+ @Select("SELECT passkey FROM user WHERE userid = #{userid}")
+ String selectPasskeyByUserid(Long userid);
+
+ @Select("SELECT permission FROM user WHERE userid = #{userid}")
+ int getpermissionByUserid(Long userid);
+
+ @Select("SELECT username FROM user WHERE userid = #{userid}")
+ String selectUsernameByUserid(Long userid);
+
+ @Select("SELECT userid FROM user WHERE username = #{username}")
+ String selectUseridByusername(String username);
+
@Update("UPDATE user SET credit = credit - #{price} WHERE username = #{username}")
int deductCreditByUsername(@Param("username") String username, @Param("price") int price);
+ @Update("UPDATE user SET credit = credit + #{price} WHERE username = #{username}")
+ int addCreditByUsername(@Param("username") String username, @Param("price") int price);
+
@Update("UPDATE user SET upload = upload + #{upload} WHERE username = #{username}")
int increaseUploadByUsername(@Param("username") String username, @Param("upload") Integer upload);
@@ -45,13 +61,26 @@
@Update("UPDATE user SET image = #{image} WHERE username = #{username}")
int updateimage(@Param("username") String username, @Param("image") String image);
- @Update("UPDATE user SET gradeId = #{gradeId} WHERE username = #{username}")
+ @Update("UPDATE user SET grade_id = #{gradeId} WHERE username = #{username}")
int updateGrade(@Param("username") String username, @Param("gradeId") Integer gradeId);
@Update("UPDATE user SET decoration = CONCAT(IFNULL(decoration, ''), ' ', #{newDecoration}) WHERE username = #{username}")
int appendUserDecoration(@Param("username") String username, @Param("newDecoration") String newDecoration);
+ @Delete("DELETE FROM user WHERE username = #{username})")
+ int deleteByUsername(@Param("username") String username);
+
+ @Select("SELECT username, passkey, grade_id FROM user")
+ List<Map<String, Object>> selectAllUsersBasicInfo();
+
+ @Select("SELECT * FROM user")
+ List<Map<String, Object>> selectAllUsers();
+
+ @Select("SELECT * FROM user WHERE username REGEXP #{regexPattern}")
+ List<Map<String, Object>> selectUserByFuzzyKeyword(@Param("regexPattern") String regexPattern);
+
boolean existsByPasskey(String passkey);
+
void incrementUserTraffic( @Param("info_hash") String infoHash,@Param("passkey") String passkey, @Param("user_upload") long uploaded, @Param("user_download") long downloaded);
String getUsernameByPasskey(String passkey);