DB2接口和单元测试
Change-Id: I62312b94f2e5d8ad8bc2f22b96ceecae32de4bf4
diff --git a/src/main/java/database/Database2.java b/src/main/java/database/Database2.java
index 28a8ac5..8ea93b0 100644
--- a/src/main/java/database/Database2.java
+++ b/src/main/java/database/Database2.java
@@ -3,7 +3,9 @@
import java.util.Calendar;
import java.util.UUID;
import java.util.List;
+import java.util.Map;
import java.util.Date;
+import java.util.HashMap;
import javax.persistence.EntityManager;
import javax.persistence.EntityManagerFactory;
@@ -20,6 +22,7 @@
import entity.Seed;
import entity.User;
import entity.UserPT;
+import entity.config;
import entity.Notice;
import entity.BegInfo;
import entity.Post;
@@ -29,1047 +32,1053 @@
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-// public class Database2 implements DataManagerInterface {
+public class Database2 implements DataManagerInterface {
-// private EntityManagerFactory emf;
-// private static final Logger logger = LoggerFactory.getLogger(Database2.class);
+ private EntityManagerFactory emf;
+ private static final Logger logger = LoggerFactory.getLogger(Database2.class);
-// // 构造函数，初始化EntityManagerFactory
-// public Database2() {
-// this.emf = Persistence.createEntityManagerFactory("myPersistenceUnit"); // 使用 persistence.xml 中定义的持久化单元名称。
-// }
+ // 构造函数，初始化EntityManagerFactory
+ public Database2() {
+ config cfg = new config();
+ Map<String, Object> props = new HashMap<>();
+ props.put("javax.persistence.jdbc.url",
+ "jdbc:mysql://" + cfg.SqlURL + "/" + cfg.Database);
+ props.put("javax.persistence.jdbc.user", cfg.SqlUsername);
+ props.put("javax.persistence.jdbc.password", cfg.SqlPassword);
+ this.emf = Persistence.createEntityManagerFactory("myPersistenceUnit", props);
+ }
-// @Override
-// public int RegisterUser(User userinfo) {
-// return 0;
-// }
+ public Database2(EntityManagerFactory emf) {
+ this.emf = emf;
+ }
-// @Override
-// public int UpdateInformation(User userinfo) {
-// return 0;
-// }
+ @Override
+ public int RegisterUser(User userinfo) {
+ return 0;
+ }
-// @Override
-// public User GetInformation(String userid) {
-// return null;
-// }
+ @Override
+ public int UpdateInformation(User userinfo) {
+ return 0;
+ }
-// @Override
-// public UserPT GetInformationPT(String userid) {
-// return null;
-// }
+ @Override
+ public User GetInformation(String userid) {
+ return null;
+ }
-// @Override
-// public int UpdateInformationPT(UserPT userinfo) {
-// return 0;
-// }
+ @Override
+ public UserPT GetInformationPT(String userid) {
+ return null;
+ }
-// @Override
-// public int RegisterUserPT(UserPT userinfo) {
-// return 0;
-// }
+ @Override
+ public int UpdateInformationPT(UserPT userinfo) {
+ return 0;
+ }
-// @Override
-// public Seed GetSeedInformation(String seedid) {
-// return null;
-// }
+ @Override
+ public int RegisterUserPT(UserPT userinfo) {
+ return 0;
+ }
-// @Override
-// public int RegisterSeed(Seed seedinfo) {
-// return 0;
-// }
+ @Override
+ public Seed GetSeedInformation(String seedid) {
+ return null;
+ }
-// @Override
-// public int UpdateSeed(Seed seedinfo) {
-// return 0;
-// }
+ @Override
+ public int RegisterSeed(Seed seedinfo) {
+ return 0;
+ }
-// @Override
-// public Seed[] SearchSeed(String userQ) {
-// return new Seed[0];
-// }
+ @Override
+ public int UpdateSeed(Seed seedinfo) {
+ return 0;
+ }
-// @Override
-// public int AddNotice(Notice notice) {
-// return 0;
-// }
+ @Override
+ public Seed[] SearchSeed(String userQ) {
+ return new Seed[0];
+ }
-// @Override
-// public boolean UpdateNotice(Notice notice) {
-// return false;
-// }
+ @Override
+ public int AddNotice(Notice notice) {
+ return 0;
+ }
-// @Override
-// public boolean DeleteNotice(String noticeid) {
-// return false;
-// }
+ @Override
+ public boolean UpdateNotice(Notice notice) {
+ return false;
+ }
-// @Override
-// public int GetUserAvailableInviteTimes(String userid) {
-// return 0;
-// }
+ @Override
+ public boolean DeleteNotice(String noticeid) {
+ return false;
+ }
-// @Override
-// public int InviteUser(String inviterid, String inviteemail) {
-// return 0;
-// }
+ @Override
+ public int GetUserAvailableInviteTimes(String userid) {
+ return 0;
+ }
-// @Override
-// public boolean AddCollect(String userid, String postid) {
-// return false;
-// }
+ @Override
+ public int InviteUser(String inviterid, String inviteemail) {
+ return 0;
+ }
-// @Override
-// public boolean DeleteCollect(String userid, String postid) {
-// return false;
-// }
+ @Override
+ public boolean AddCollect(String userid, String postid) {
+ return false;
+ }
-// @Override
-// public int AddBegSeed(BegInfo info) {
-// if (info == null || info.begid == null || info.begid.isEmpty()) {
-// logger.warn("Invalid parameter: info is null or begid is empty");
-// return 2;
-// }
+ @Override
+ public boolean DeleteCollect(String userid, String postid) {
+ return false;
+ }
-// EntityManager em = null;
-// EntityTransaction tx = null;
+ @Override
+ public int AddBegSeed(BegInfo info) {
+ if (info == null || info.begid == null || info.begid.isEmpty()) {
+ logger.warn("Invalid parameter: info is null or begid is empty");
+ return 2;
+ }
-// try {
-// em = emf.createEntityManager();
-// tx = em.getTransaction();
-// tx.begin();
+ EntityManager em = null;
+ EntityTransaction tx = null;
-// // 检查是否重复
-// BegInfo existingBeg = em.find(BegInfo.class, info.begid);
-// if (existingBeg != null) {
-// logger.warn("BegSeed with ID {} already exists", info.begid);
-// return 1;
-// }
+ try {
+ em = emf.createEntityManager();
+ tx = em.getTransaction();
+ tx.begin();
-// // 设置默认值
-// if (info.endtime == null) {
-// // 设置默认14天截止期
-// Calendar calendar = Calendar.getInstance();
-// calendar.add(Calendar.DAY_OF_MONTH, 14);
-// info.endtime = calendar.getTime();
-// }
-// info.hasseed = false;
+ // 检查是否重复
+ BegInfo existingBeg = em.find(BegInfo.class, info.begid);
+ if (existingBeg != null) {
+ logger.warn("BegSeed with ID {} already exists", info.begid);
+ return 1;
+ }
-// // 保存新的求种信息
-// em.persist(info);
-// tx.commit();
+ // 设置默认值
+ if (info.endtime == null) {
+ // 设置默认14天截止期
+ Calendar calendar = Calendar.getInstance();
+ calendar.add(Calendar.DAY_OF_MONTH, 14);
+ info.endtime = calendar.getTime();
+ }
+ info.hasseed = 0;
-// logger.info("Successfully added new BegSeed with ID: {}", info.begid);
-// return 0;
+ // 保存新的求种信息
+ em.persist(info);
+ tx.commit();
-// } catch (Exception e) {
-// if (tx != null && tx.isActive()) {
-// tx.rollback();
-// }
-// logger.error("Error adding BegSeed: {}", e.getMessage());
-// return 2;
-// } finally {
-// if (em != null) {
-// em.close();
-// }
-// }
-// }
+ logger.info("Successfully added new BegSeed with ID: {}", info.begid);
+ return 0;
-// @Override
-// public int UpdateBegSeed(BegInfo info) {
-// if (info == null || info.begid == null || info.begid.isEmpty()) {
-// logger.warn("Invalid parameter: info is null or begid is empty");
-// return 2;
-// }
+ } catch (Exception e) {
+ if (tx != null && tx.isActive()) {
+ tx.rollback();
+ }
+ logger.error("Error adding BegSeed: {}", e.getMessage());
+ return 2;
+ } finally {
+ if (em != null) {
+ em.close();
+ }
+ }
+ }
-// EntityManager em = null;
-// EntityTransaction tx = null;
+ @Override
+ public int UpdateBegSeed(BegInfo info) {
+ if (info == null || info.begid == null || info.begid.isEmpty()) {
+ logger.warn("Invalid parameter: info is null or begid is empty");
+ return 2;
+ }
-// try {
-// em = emf.createEntityManager();
-// tx = em.getTransaction();
-// tx.begin();
+ EntityManager em = null;
+ EntityTransaction tx = null;
-// // 检查是否存在
-// BegInfo existingBeg = em.find(BegInfo.class, info.begid);
-// if (existingBeg == null) {
-// logger.warn("BegSeed with ID {} does not exist", info.begid);
-// return 1;
-// }
+ try {
+ em = emf.createEntityManager();
+ tx = em.getTransaction();
+ tx.begin();
-// // 保持原有值不变的字段
-// info.hasseed = existingBeg.hasseed;
-// if (info.endtime == null) {
-// info.endtime = existingBeg.endtime;
-// }
+ // 检查是否存在
+ BegInfo existingBeg = em.find(BegInfo.class, info.begid);
+ if (existingBeg == null) {
+ logger.warn("BegSeed with ID {} does not exist", info.begid);
+ return 1;
+ }
-// // 更新求种信息
-// em.merge(info);
-// tx.commit();
+ // 保持原有值不变的字段
+ info.hasseed = existingBeg.hasseed;
+ if (info.endtime == null) {
+ info.endtime = existingBeg.endtime;
+ }
-// logger.info("Successfully updated BegSeed with ID: {}", info.begid);
-// return 0;
+ // 更新求种信息
+ em.merge(info);
+ tx.commit();
-// } catch (Exception e) {
-// if (tx != null && tx.isActive()) {
-// tx.rollback();
-// }
-// logger.error("Error updating BegSeed: {}", e.getMessage());
-// return 2;
-// } finally {
-// if (em != null) {
-// em.close();
-// }
-// }
-// }
+ logger.info("Successfully updated BegSeed with ID: {}", info.begid);
+ return 0;
-// @Override
-// public int DeleteBegSeed(String begid) {
-// if (begid == null || begid.isEmpty()) {
-// logger.warn("Invalid parameter: begid is null or empty");
-// return 2;
-// }
+ } catch (Exception e) {
+ if (tx != null && tx.isActive()) {
+ tx.rollback();
+ }
+ logger.error("Error updating BegSeed: {}", e.getMessage());
+ return 2;
+ } finally {
+ if (em != null) {
+ em.close();
+ }
+ }
+ }
-// EntityManager em = null;
-// EntityTransaction tx = null;
+ @Override
+ public int DeleteBegSeed(String begid) {
+ if (begid == null || begid.isEmpty()) {
+ logger.warn("Invalid parameter: begid is null or empty");
+ return 2;
+ }
-// try {
-// em = emf.createEntityManager();
-// tx = em.getTransaction();
-// tx.begin();
+ EntityManager em = null;
+ EntityTransaction tx = null;
-// // 查找要删除的求种信息
-// BegInfo begInfo = em.find(BegInfo.class, begid);
-// if (begInfo == null) {
-// logger.warn("BegSeed with ID {} does not exist", begid);
-// return 1;
-// }
+ try {
+ em = emf.createEntityManager();
+ tx = em.getTransaction();
+ tx.begin();
-// // 删除求种信息
-// em.remove(begInfo);
-// tx.commit();
+ // 查找要删除的求种信息
+ BegInfo begInfo = em.find(BegInfo.class, begid);
+ if (begInfo == null) {
+ logger.warn("BegSeed with ID {} does not exist", begid);
+ tx.rollback();
+ return 1;
+ }
-// logger.info("Successfully deleted BegSeed with ID: {}", begid);
-// return 0;
+ // 删除求种信息
+ em.remove(begInfo);
+ tx.commit();
-// } catch (Exception e) {
-// if (tx != null && tx.isActive()) {
-// tx.rollback();
-// }
-// logger.error("Error deleting BegSeed: {}", e.getMessage());
-// return 2;
-// } finally {
-// if (em != null) {
-// em.close();
-// }
-// }
-// }
+ logger.info("Successfully deleted BegSeed with ID: {}", begid);
+ return 0;
-// @Override
-// public int VoteSeed(String begId, String seedId, String userId) {
-// if (begId == null || seedId == null || userId == null ||
-// begId.isEmpty() || seedId.isEmpty() || userId.isEmpty()) {
-// logger.warn("Invalid parameters: begId, seedId or userId is null or empty");
-// return 2;
-// }
+ } catch (Exception e) {
+ if (tx != null && tx.isActive()) {
+ tx.rollback();
+ }
+ logger.error("Error deleting BegSeed: {}", e.getMessage());
+ return 2;
+ } finally {
+ if (em != null) {
+ em.close();
+ }
+ }
+ }
-// EntityManager em = null;
-// EntityTransaction tx = null;
+ @Override
+ public int VoteSeed(String begId, String seedId, String userId) {
+ if (begId == null || seedId == null || userId == null ||
+ begId.isEmpty() || seedId.isEmpty() || userId.isEmpty()) {
+ logger.warn("Invalid parameters: begId, seedId or userId is null or empty");
+ return 2;
+ }
-// try {
-// em = emf.createEntityManager();
-// tx = em.getTransaction();
-// tx.begin();
+ EntityManager em = null;
+ EntityTransaction tx = null;
-// // 检查求种信息是否存在
-// BegInfo begInfo = em.find(BegInfo.class, begId);
-// if (begInfo == null) {
-// logger.warn("BegSeed with ID {} does not exist", begId);
-// return 2;
-// }
+ try {
+ em = emf.createEntityManager();
+ tx = em.getTransaction();
+ tx.begin();
-// // 检查用户是否已投票
-// QUserVotes uv = QUserVotes.userVotes;
-// Long voteCount = new JPAQuery<>(em)
-// .select(uv.count())
-// .from(uv)
-// .where(uv.user.userid.eq(userId))
-// .where(uv.begInfo.begid.eq(begId))
-// .where(uv.seed.seedid.eq(seedId))
-// .fetchOne();
+ // 检查求种信息是否存在
+ BegInfo begInfo = em.find(BegInfo.class, begId);
+ if (begInfo == null) {
+ logger.warn("BegSeed with ID {} does not exist", begId);
+ return 2;
+ }
-// if (voteCount > 0) {
-// logger.warn("User {} has already voted for seed {} in beg {}", userId,
-// seedId, begId);
-// return 1;
-// }
+ // 检查用户是否已投票
+ Long voteCount = new JPAQuery<>(em)
+ .select(QUserVotes.userVotes.count())
+ .from(QUserVotes.userVotes)
+ .where(QUserVotes.userVotes.id.eq(new entity.UserVotesId(userId, begId, seedId)))
+ .fetchOne();
-// // 创建新的投票记录
-// em.createNativeQuery("INSERT INTO UserVotes (user_id, beg_id, seed_id, created_at) " +
-// "VALUES (?, ?, ?, CURRENT_TIMESTAMP)")
-// .setParameter(1, userId)
-// .setParameter(2, begId)
-// .setParameter(3, seedId)
-// .executeUpdate();
+ if (voteCount != null && voteCount > 0) {
+ logger.warn("User {} has already voted for seed {} in beg {}", userId, seedId, begId);
+ return 1;
+ }
-// // 更新SubmitSeed表中的投票数
-// em.createQuery("UPDATE SubmitSeed s SET s.votes = s.votes + 1 " +
-// "WHERE s.begId = :begId AND s.seedId = :seedId")
-// .setParameter("begId", begId)
-// .setParameter("seedId", seedId)
-// .executeUpdate();
+ // 创建新的投票记录
+ em.createNativeQuery("INSERT INTO UserVotes (user_id, beg_id, seed_id, created_at) " +
+ "VALUES (?, ?, ?, CURRENT_TIMESTAMP)")
+ .setParameter(1, userId)
+ .setParameter(2, begId)
+ .setParameter(3, seedId)
+ .executeUpdate();
-// tx.commit();
-// logger.info("Successfully added vote from user {} for seed {} in beg {}",
-// userId, seedId, begId);
-// return 0;
+ // 更新SubmitSeed表中的投票数
+ em.createQuery("UPDATE SubmitSeed s SET s.votes = s.votes + 1 " +
+ "WHERE s.id.begId = :begId AND s.id.seedId = :seedId")
+ .setParameter("begId", begId)
+ .setParameter("seedId", seedId)
+ .executeUpdate();
-// } catch (Exception e) {
-// if (tx != null && tx.isActive()) {
-// tx.rollback();
-// }
-// logger.error("Error voting for seed: {}", e.getMessage());
-// return 2;
-// } finally {
-// if (em != null) {
-// em.close();
-// }
-// }
-// }
+ tx.commit();
+ logger.info("Successfully added vote from user {} for seed {} in beg {}", userId, seedId, begId);
+ return 0;
-// @Override
-// public int SubmitSeed(String begid, Seed seed) {
-// if (begid == null || seed == null || begid.isEmpty() || seed.seedid == null) {
-// logger.warn("Invalid parameters: begid or seed is null or empty");
-// return 2;
-// }
+ } catch (Exception e) {
+ if (tx != null && tx.isActive()) {
+ tx.rollback();
+ }
+ logger.error("Error voting for seed: {}", e.getMessage());
+ return 2;
+ } finally {
+ if (em != null) {
+ em.close();
+ }
+ }
+ }
-// EntityManager em = null;
-// EntityTransaction tx = null;
+ @Override
+ public int SubmitSeed(String begid, Seed seed) {
+ if (begid == null || seed == null || begid.isEmpty() || seed.seedid == null) {
+ logger.warn("Invalid parameters: begid or seed is null or empty");
+ return 2;
+ }
-// try {
-// em = emf.createEntityManager();
-// tx = em.getTransaction();
-// tx.begin();
+ EntityManager em = null;
+ EntityTransaction tx = null;
-// // 检查求种信息是否存在
-// BegInfo begInfo = em.find(BegInfo.class, begid);
-// if (begInfo == null) {
-// logger.warn("BegSeed with ID {} does not exist", begid);
-// return 2;
-// }
+ try {
+ em = emf.createEntityManager();
+ tx = em.getTransaction();
+ tx.begin();
-// // 检查种子是否已提交过
-// QSubmitSeed ss = QSubmitSeed.submitSeed;
-// Long submitCount = new JPAQuery<>(em)
-// .select(ss.count())
-// .from(ss)
-// .where(ss.begInfo.begid.eq(begid))
-// .where(ss.seed.seedid.eq(seed.seedid))
-// .fetchOne();
+ // 检查求种信息是否存在
+ BegInfo begInfo = em.find(BegInfo.class, begid);
+ if (begInfo == null) {
+ logger.warn("BegSeed with ID {} does not exist", begid);
+ return 2;
+ }
-// if (submitCount > 0) {
-// logger.warn("Seed {} has already been submitted for beg {}", seed.seedid,
-// begid);
-// return 1;
-// }
+ // 检查种子是否已提交过
+ QSubmitSeed ss = QSubmitSeed.submitSeed;
+ Long submitCount = new JPAQuery<>(em)
+ .select(ss.count())
+ .from(ss)
+ .where(ss.begInfo.begid.eq(begid))
+ .where(ss.seed.seedid.eq(seed.seedid))
+ .fetchOne();
-// // 保存种子信息（如果不存在）
-// if (em.find(Seed.class, seed.seedid) == null) {
-// em.persist(seed);
-// }
+ if (submitCount > 0) {
+ logger.warn("Seed {} has already been submitted for beg {}", seed.seedid,
+ begid);
+ return 1;
+ }
-// // 创建提交记录
-// em.createNativeQuery("INSERT INTO SubmitSeed (beg_id, seed_id, votes) VALUES (?, ?, 0)")
-// .setParameter(1, begid)
-// .setParameter(2, seed.seedid)
-// .executeUpdate();
+ // 保存种子信息（如果不存在）
+ if (em.find(Seed.class, seed.seedid) == null) {
+ em.persist(seed);
+ }
-// tx.commit();
-// logger.info("Successfully submitted seed {} for beg {}", seed.seedid, begid);
-// return 0;
+ // 创建提交记录
+ em.createNativeQuery("INSERT INTO SubmitSeed (beg_id, seed_id, votes) VALUES (?, ?, 0)")
+ .setParameter(1, begid)
+ .setParameter(2, seed.seedid)
+ .executeUpdate();
-// } catch (Exception e) {
-// if (tx != null && tx.isActive()) {
-// tx.rollback();
-// }
-// logger.error("Error submitting seed: {}", e.getMessage());
-// return 2;
-// } finally {
-// if (em != null) {
-// em.close();
-// }
-// }
-// }
+ tx.commit();
+ logger.info("Successfully submitted seed {} for beg {}", seed.seedid, begid);
+ return 0;
-// @Override
-// public void SettleBeg() {
-// EntityManager em = null;
-// EntityTransaction tx = null;
+ } catch (Exception e) {
+ if (tx != null && tx.isActive()) {
+ tx.rollback();
+ }
+ logger.error("Error submitting seed: {}", e.getMessage());
+ return 2;
+ } finally {
+ if (em != null) {
+ em.close();
+ }
+ }
+ }
-// try {
-// em = emf.createEntityManager();
-// tx = em.getTransaction();
-// tx.begin();
+ @Override
+ public void SettleBeg() {
+ EntityManager em = null;
+ EntityTransaction tx = null;
-// // 1. 获取所有已过期且未完成的求种信息
-// QBegInfo b = QBegInfo.begInfo;
-// List<BegInfo> expiredBegs = new JPAQuery<>(em)
-// .select(b)
-// .from(b)
-// .where(b.endtime.loe(new Date())
-// .and(b.hasseed.eq(false)))
-// .fetch();
+ try {
+ em = emf.createEntityManager();
+ tx = em.getTransaction();
+ tx.begin();
-// for (BegInfo beg : expiredBegs) {
-// // 2. 查找投票最多的提交任务
-// QSubmitSeed ss = QSubmitSeed.submitSeed;
-// Tuple topSubmission = new JPAQuery<>(em)
-// .select(ss.seed.seedid, ss.votes)
-// .from(ss)
-// .where(ss.begInfo.begid.eq(beg.begid))
-// .orderBy(ss.votes.desc())
-// .limit(1)
-// .fetchOne();
+ // 1. 获取所有已过期且未完成的求种信息
+ QBegInfo b = QBegInfo.begInfo;
+ List<BegInfo> expiredBegs = new JPAQuery<>(em)
+ .select(b)
+ .from(b)
+ .where(b.endtime.loe(new Date())
+ .and(b.hasseed.eq(0)))
+ .fetch();
-// if (topSubmission != null && topSubmission.get(ss.votes) > 0) {
-// String seedId = topSubmission.get(ss.seed.seedid);
+ for (BegInfo beg : expiredBegs) {
+ // 2. 查找投票最多的提交任务
+ QSubmitSeed ss = QSubmitSeed.submitSeed;
+ Tuple topSubmission = new JPAQuery<>(em)
+ .select(ss.seed.seedid, ss.votes)
+ .from(ss)
+ .where(ss.begInfo.begid.eq(beg.begid))
+ .orderBy(ss.votes.desc())
+ .limit(1)
+ .fetchOne();
-// // 3. 获取上传者ID
-// QSeed s = QSeed.seed;
-// String ownerId = new JPAQuery<>(em)
-// .select(s.seeduserid)
-// .from(s)
-// .where(s.seedid.eq(seedId))
-// .fetchOne();
+ if (topSubmission != null && topSubmission.get(ss.votes) > 0) {
+ String seedId = topSubmission.get(ss.seed.seedid);
-// // 4. 获取上传者的PT信息并更新魔力值
-// UserPT ownerPT = em.find(UserPT.class, ownerId);
-// if (ownerPT != null) {
-// // 5. 发放奖励
-// ownerPT.magic += beg.magic;
-// em.merge(ownerPT);
+ // 3. 获取上传者ID
+ QSeed s = QSeed.seed;
+ String ownerId = new JPAQuery<>(em)
+ .select(s.seeduserid)
+ .from(s)
+ .where(s.seedid.eq(seedId))
+ .fetchOne();
-// // 6. 更新求种状态
-// beg.hasseed = true;
-// em.merge(beg);
+ // 4. 获取上传者的PT信息并更新魔力值
+ UserPT ownerPT = em.find(UserPT.class, ownerId);
+ if (ownerPT != null) {
+ // 5. 发放奖励
+ ownerPT.magic += beg.magic;
+ em.merge(ownerPT);
-// logger.info("Reward {} magic points awarded to user {} for beg {}",
-// beg.magic, ownerId, beg.begid);
-// }
-// }
-// }
+ // 6. 更新求种状态
+ beg.hasseed = 1;
+ em.merge(beg);
-// tx.commit();
-// logger.info("Successfully settled {} expired beg requests",
-// expiredBegs.size());
+ logger.info("Reward {} magic points awarded to user {} for beg {}",
+ beg.magic, ownerId, beg.begid);
+ }
+ }
+ }
-// } catch (Exception e) {
-// if (tx != null && tx.isActive()) {
-// tx.rollback();
-// }
-// logger.error("Error settling beg requests: {}", e.getMessage(), e);
-// } finally {
-// if (em != null) {
-// em.close();
-// }
-// }
-// }
+ tx.commit();
+ logger.info("Successfully settled {} expired beg requests",
+ expiredBegs.size());
-// @Override
-// public int AddPost(Post post) {
-// if (post == null || post.postid == null || post.postid.isEmpty()) {
-// logger.warn("Invalid parameter: post is null or postid is empty");
-// return 2;
-// }
+ } catch (Exception e) {
+ if (tx != null && tx.isActive()) {
+ tx.rollback();
+ }
+ logger.error("Error settling beg requests: {}", e.getMessage(), e);
+ } finally {
+ if (em != null) {
+ em.close();
+ }
+ }
+ }
-// EntityManager em = null;
-// EntityTransaction tx = null;
+ @Override
+ public int AddPost(Post post) {
+ if (post == null || post.postid == null || post.postid.isEmpty()) {
+ logger.warn("Invalid parameter: post is null or postid is empty");
+ return 2;
+ }
-// try {
-// em = emf.createEntityManager();
-// tx = em.getTransaction();
-// tx.begin();
+ EntityManager em = null;
+ EntityTransaction tx = null;
-// // 检查是否重复
-// Post existingPost = em.find(Post.class, post.postid);
-// if (existingPost != null) {
-// logger.warn("Post with ID {} already exists", post.postid);
-// return 1;
-// }
+ try {
+ em = emf.createEntityManager();
+ tx = em.getTransaction();
+ tx.begin();
-// // 检查用户是否存在
-// User user = em.find(User.class, post.postuserid);
-// if (user == null) {
-// logger.warn("User with ID {} does not exist", post.postuserid);
-// return 2;
-// }
+ // 检查是否重复
+ Post existingPost = em.find(Post.class, post.postid);
+ if (existingPost != null) {
+ logger.warn("Post with ID {} already exists", post.postid);
+ return 1;
+ }
-// // 设置初始值
-// if (post.posttime == null) {
-// post.posttime = new Date();
-// }
-// post.replytime = 0;
-// post.readtime = 0;
+ // 检查用户是否存在
+ User user = em.find(User.class, post.postuserid);
+ if (user == null) {
+ logger.warn("User with ID {} does not exist", post.postuserid);
+ return 2;
+ }
-// // 保存帖子
-// em.persist(post);
-// tx.commit();
+ // 设置初始值
+ if (post.posttime == null) {
+ post.posttime = new Date();
+ }
+ post.replytime = 0;
+ post.readtime = 0;
-// logger.info("Successfully added new post with ID: {}", post.postid);
-// return 0;
+ // 保存帖子
+ em.persist(post);
+ tx.commit();
-// } catch (Exception e) {
-// if (tx != null && tx.isActive()) {
-// tx.rollback();
-// }
-// logger.error("Error adding post: {}", e.getMessage());
-// return 2;
-// } finally {
-// if (em != null) {
-// em.close();
-// }
-// }
-// }
+ logger.info("Successfully added new post with ID: {}", post.postid);
+ return 0;
-// @Override
-// public int UpdatePost(Post post) {
-// if (post == null || post.postid == null || post.postid.isEmpty()) {
-// logger.warn("Invalid parameter: post is null or postid is empty");
-// return 2;
-// }
+ } catch (Exception e) {
+ if (tx != null && tx.isActive()) {
+ tx.rollback();
+ }
+ logger.error("Error adding post: {}", e.getMessage());
+ return 2;
+ } finally {
+ if (em != null) {
+ em.close();
+ }
+ }
+ }
-// EntityManager em = null;
-// EntityTransaction tx = null;
+ @Override
+ public int UpdatePost(Post post) {
+ if (post == null || post.postid == null || post.postid.isEmpty()) {
+ logger.warn("Invalid parameter: post is null or postid is empty");
+ return 2;
+ }
-// try {
-// em = emf.createEntityManager();
-// tx = em.getTransaction();
-// tx.begin();
+ EntityManager em = null;
+ EntityTransaction tx = null;
-// // 检查帖子是否存在
-// Post existingPost = em.find(Post.class, post.postid);
-// if (existingPost == null) {
-// logger.warn("Post with ID {} does not exist", post.postid);
-// return 1;
-// }
+ try {
+ em = emf.createEntityManager();
+ tx = em.getTransaction();
+ tx.begin();
-// // 保持原有不可修改的字段
-// post.postuserid = existingPost.postuserid;
-// post.posttime = existingPost.posttime;
-// post.replytime = existingPost.replytime;
-// post.readtime = existingPost.readtime;
+ // 检查帖子是否存在
+ Post existingPost = em.find(Post.class, post.postid);
+ if (existingPost == null) {
+ logger.warn("Post with ID {} does not exist", post.postid);
+ return 1;
+ }
-// // 更新帖子
-// em.merge(post);
-// tx.commit();
+ // 保持原有不可修改的字段
+ post.postuserid = existingPost.postuserid;
+ post.posttime = existingPost.posttime;
+ post.replytime = existingPost.replytime;
+ post.readtime = existingPost.readtime;
-// logger.info("Successfully updated post with ID: {}", post.postid);
-// return 0;
+ // 更新帖子
+ em.merge(post);
+ tx.commit();
-// } catch (Exception e) {
-// if (tx != null && tx.isActive()) {
-// tx.rollback();
-// }
-// logger.error("Error updating post: {}", e.getMessage());
-// return 2;
-// } finally {
-// if (em != null) {
-// em.close();
-// }
-// }
-// }
+ logger.info("Successfully updated post with ID: {}", post.postid);
+ return 0;
-// @Override
-// public int DeletePost(String postid) {
-// if (postid == null || postid.isEmpty()) {
-// logger.warn("Invalid parameter: postid is null or empty");
-// return 2;
-// }
+ } catch (Exception e) {
+ if (tx != null && tx.isActive()) {
+ tx.rollback();
+ }
+ logger.error("Error updating post: {}", e.getMessage());
+ return 2;
+ } finally {
+ if (em != null) {
+ em.close();
+ }
+ }
+ }
-// EntityManager em = null;
-// EntityTransaction tx = null;
+ @Override
+ public int DeletePost(String postid) {
+ if (postid == null || postid.isEmpty()) {
+ logger.warn("Invalid parameter: postid is null or empty");
+ return 2;
+ }
-// try {
-// em = emf.createEntityManager();
-// tx = em.getTransaction();
-// tx.begin();
+ EntityManager em = null;
+ EntityTransaction tx = null;
-// // 查找要删除的帖子
-// Post post = em.find(Post.class, postid);
-// if (post == null) {
-// logger.warn("Post with ID {} does not exist", postid);
-// return 1;
-// }
+ try {
+ em = emf.createEntityManager();
+ tx = em.getTransaction();
+ tx.begin();
-// // 删除帖子(由于设置了级联删除，相关的回复会自动删除)
-// em.remove(post);
-// tx.commit();
+ // 查找要删除的帖子
+ Post post = em.find(Post.class, postid);
+ if (post == null) {
+ logger.warn("Post with ID {} does not exist", postid);
+ tx.rollback();
+ return 1;
+ }
-// logger.info("Successfully deleted post with ID: {}", postid);
-// return 0;
+ // 删除帖子(由于设置了级联删除，相关的回复会自动删除)
+ em.remove(post);
+ tx.commit();
-// } catch (Exception e) {
-// if (tx != null && tx.isActive()) {
-// tx.rollback();
-// }
-// logger.error("Error deleting post: {}", e.getMessage());
-// return 2;
-// } finally {
-// if (em != null) {
-// em.close();
-// }
-// }
-// }
+ logger.info("Successfully deleted post with ID: {}", postid);
+ return 0;
-// @Override
-// public int AddComment(String postid, String userid, String comment) {
-// if (postid == null || postid.isEmpty() ||
-// userid == null || userid.isEmpty() ||
-// comment == null || comment.isEmpty()) {
-// logger.warn("Invalid parameters: postid, userid or comment is null or empty");
-// return 2;
-// }
+ } catch (Exception e) {
+ if (tx != null && tx.isActive()) {
+ tx.rollback();
+ }
+ logger.error("Error deleting post: {}", e.getMessage());
+ return 2;
+ } finally {
+ if (em != null) {
+ em.close();
+ }
+ }
+ }
-// EntityManager em = null;
-// EntityTransaction tx = null;
+ @Override
+ public int AddComment(String postid, String userid, String comment) {
+ if (postid == null || postid.isEmpty() ||
+ userid == null || userid.isEmpty() ||
+ comment == null || comment.isEmpty()) {
+ logger.warn("Invalid parameters: postid, userid or comment is null or empty");
+ return 2;
+ }
-// try {
-// em = emf.createEntityManager();
-// tx = em.getTransaction();
-// tx.begin();
+ EntityManager em = null;
+ EntityTransaction tx = null;
-// // 检查帖子是否存在
-// Post post = em.find(Post.class, postid);
-// if (post == null) {
-// logger.warn("Post with ID {} does not exist", postid);
-// return 1;
-// }
+ try {
+ em = emf.createEntityManager();
+ tx = em.getTransaction();
+ tx.begin();
-// // 检查评论用户是否存在
-// User user = em.find(User.class, userid);
-// if (user == null) {
-// logger.warn("User with ID {} does not exist", userid);
-// return 1;
-// }
+ // 检查帖子是否存在
+ Post post = em.find(Post.class, postid);
+ if (post == null) {
+ logger.warn("Post with ID {} does not exist", postid);
+ return 1;
+ }
-// // 创建新的回复
-// PostReply reply = new PostReply();
-// reply.replyid = UUID.randomUUID().toString();
-// reply.postid = postid;
-// reply.content = comment;
-// reply.authorid = userid;
-// reply.createdAt = new Date();
+ // 检查评论用户是否存在
+ User user = em.find(User.class, userid);
+ if (user == null) {
+ logger.warn("User with ID {} does not exist", userid);
+ return 1;
+ }
-// // 保存回复
-// em.persist(reply);
+ // 创建新的回复
+ PostReply reply = new PostReply();
+ reply.replyid = UUID.randomUUID().toString();
+ reply.postid = postid;
+ reply.content = comment;
+ reply.authorid = userid;
+ reply.createdAt = new Date();
-// // 更新帖子的回复数
-// post.replytime += 1;
-// em.merge(post);
+ // 保存回复
+ em.persist(reply);
-// tx.commit();
+ // 更新帖子的回复数
+ post.replytime += 1;
+ em.merge(post);
-// logger.info("Successfully added comment by user {} to post {}, reply ID: {}",
-// userid, postid, reply.replyid);
-// return 0;
+ tx.commit();
-// } catch (Exception e) {
-// if (tx != null && tx.isActive()) {
-// tx.rollback();
-// }
-// logger.error("Error adding comment: {}", e.getMessage());
-// return 2;
-// } finally {
-// if (em != null) {
-// em.close();
-// }
-// }
-// }
+ logger.info("Successfully added comment by user {} to post {}, reply ID: {}",
+ userid, postid, reply.replyid);
+ return 0;
-// @Override
-// public int DeleteComment(String postid, String commentid) {
-// if (postid == null || postid.isEmpty() || commentid == null || commentid.isEmpty()) {
-// logger.warn("Invalid parameters: postid or commentid is null or empty");
-// return 2;
-// }
+ } catch (Exception e) {
+ if (tx != null && tx.isActive()) {
+ tx.rollback();
+ }
+ logger.error("Error adding comment: {}", e.getMessage());
+ return 2;
+ } finally {
+ if (em != null) {
+ em.close();
+ }
+ }
+ }
-// EntityManager em = null;
-// EntityTransaction tx = null;
+ @Override
+ public int DeleteComment(String postid, String commentid) {
+ if (postid == null || postid.isEmpty() || commentid == null || commentid.isEmpty()) {
+ logger.warn("Invalid parameters: postid or commentid is null or empty");
+ return 2;
+ }
-// try {
-// em = emf.createEntityManager();
-// tx = em.getTransaction();
-// tx.begin();
+ EntityManager em = null;
+ EntityTransaction tx = null;
-// // 检查帖子是否存在
-// Post post = em.find(Post.class, postid);
-// if (post == null) {
-// logger.warn("Post with ID {} does not exist", postid);
-// return 1;
-// }
+ try {
+ em = emf.createEntityManager();
+ tx = em.getTransaction();
+ tx.begin();
-// // 检查评论是否存在且属于该帖子
-// PostReply reply = em.find(PostReply.class, commentid);
-// if (reply == null || !reply.postid.equals(postid)) {
-// logger.warn("Comment {} does not exist or does not belong to post {}", commentid, postid);
-// return 1;
-// }
+ // 检查帖子是否存在
+ Post post = em.find(Post.class, postid);
+ if (post == null) {
+ logger.warn("Post with ID {} does not exist", postid);
+ return 1;
+ }
-// // 删除评论
-// em.remove(reply);
+ // 检查评论是否存在且属于该帖子
+ PostReply reply = em.find(PostReply.class, commentid);
+ if (reply == null || !reply.postid.equals(postid)) {
+ logger.warn("Comment {} does not exist or does not belong to post {}", commentid, postid);
+ return 1;
+ }
-// // 更新帖子的回复数
-// post.replytime = Math.max(0, post.replytime - 1);
-// em.merge(post);
+ // 删除评论
+ em.remove(reply);
-// tx.commit();
+ // 更新帖子的回复数
+ post.replytime = Math.max(0, post.replytime - 1);
+ em.merge(post);
-// logger.info("Successfully deleted comment {} from post {}", commentid, postid);
-// return 0;
+ tx.commit();
-// } catch (Exception e) {
-// if (tx != null && tx.isActive()) {
-// tx.rollback();
-// }
-// logger.error("Error deleting comment: {}", e.getMessage());
-// return 2;
-// } finally {
-// if (em != null) {
-// em.close();
-// }
-// }
-// }
+ logger.info("Successfully deleted comment {} from post {}", commentid, postid);
+ return 0;
-// @Override
-// public boolean ExchangeMagicToUpload(String userid, int magic) {
-// if (userid == null || userid.isEmpty() || magic <= 0) {
-// logger.warn("参数无效: userid为空或magic <= 0");
-// return false;
-// }
+ } catch (Exception e) {
+ if (tx != null && tx.isActive()) {
+ tx.rollback();
+ }
+ logger.error("Error deleting comment: {}", e.getMessage());
+ return 2;
+ } finally {
+ if (em != null) {
+ em.close();
+ }
+ }
+ }
-// EntityManager em = null;
-// EntityTransaction tx = null;
+ @Override
+ public boolean ExchangeMagicToUpload(String userid, int magic) {
+ if (userid == null || userid.isEmpty() || magic <= 0) {
+ logger.warn("参数无效: userid为空或magic <= 0");
+ return false;
+ }
-// try {
-// em = emf.createEntityManager();
-// tx = em.getTransaction();
-// tx.begin();
+ EntityManager em = null;
+ EntityTransaction tx = null;
-// UserPT userPT = em.find(UserPT.class, userid);
-// if (userPT == null) {
-// logger.warn("未找到用户 {} 的PT信息", userid);
-// return false;
-// }
+ try {
+ em = emf.createEntityManager();
+ tx = em.getTransaction();
+ tx.begin();
-// if (userPT.magic < magic) {
-// logger.warn("用户 {} 的魔力值不足", userid);
-// return false;
-// }
+ UserPT userPT = em.find(UserPT.class, userid);
+ if (userPT == null) {
+ logger.warn("未找到用户 {} 的PT信息", userid);
+ return false;
+ }
-// // 1:1兑换，直接加上魔力值（假设单位是MB）
-// userPT.magic -= magic;
-// userPT.upload += magic;
+ if (userPT.magic < magic) {
+ logger.warn("用户 {} 的魔力值不足", userid);
+ return false;
+ }
-// // 更新分享率
-// if (userPT.download > 0) {
-// userPT.share = (double) userPT.upload / userPT.download;
-// }
+ // 1:1兑换，直接加上魔力值（假设单位是MB）
+ userPT.magic -= magic;
+ userPT.upload += magic;
-// em.merge(userPT);
-// tx.commit();
+ // 更新分享率
+ if (userPT.download > 0) {
+ userPT.share = (double) userPT.upload / userPT.download;
+ }
-// logger.info("用户 {} 成功将 {} 点魔力值兑换为 {}MB 上传量", userid, magic, magic);
-// return true;
+ em.merge(userPT);
+ tx.commit();
-// } catch (Exception e) {
-// if (tx != null && tx.isActive()) {
-// tx.rollback();
-// }
-// logger.error("魔力值兑换上传量时发生错误: {}", e.getMessage());
-// return false;
-// } finally {
-// if (em != null) {
-// em.close();
-// }
-// }
-// }
+ logger.info("用户 {} 成功将 {} 点魔力值兑换为 {}MB 上传量", userid, magic, magic);
+ return true;
-// @Override
-// public boolean ExchangeMagicToDownload(String userid, int magic) {
-// if (userid == null || userid.isEmpty() || magic <= 0) {
-// logger.warn("参数无效: userid为空或magic <= 0");
-// return false;
-// }
+ } catch (Exception e) {
+ if (tx != null && tx.isActive()) {
+ tx.rollback();
+ }
+ logger.error("魔力值兑换上传量时发生错误: {}", e.getMessage());
+ return false;
+ } finally {
+ if (em != null) {
+ em.close();
+ }
+ }
+ }
-// EntityManager em = null;
-// EntityTransaction tx = null;
+ @Override
+ public boolean ExchangeMagicToDownload(String userid, int magic) {
+ if (userid == null || userid.isEmpty() || magic <= 0) {
+ logger.warn("参数无效: userid为空或magic <= 0");
+ return false;
+ }
-// try {
-// em = emf.createEntityManager();
-// tx = em.getTransaction();
-// tx.begin();
+ EntityManager em = null;
+ EntityTransaction tx = null;
-// UserPT userPT = em.find(UserPT.class, userid);
-// if (userPT == null) {
-// logger.warn("未找到用户 {} 的PT信息", userid);
-// return false;
-// }
+ try {
+ em = emf.createEntityManager();
+ tx = em.getTransaction();
+ tx.begin();
-// if (userPT.magic < magic) {
-// logger.warn("用户 {} 的魔力值不足", userid);
-// return false;
-// }
+ UserPT userPT = em.find(UserPT.class, userid);
+ if (userPT == null) {
+ logger.warn("未找到用户 {} 的PT信息", userid);
+ return false;
+ }
-// // 1:1兑换，直接减去魔力值对应的下载量（假设单位是MB）
-// userPT.magic -= magic;
-// userPT.download = Math.max(0, userPT.download - magic);
+ if (userPT.magic < magic) {
+ logger.warn("用户 {} 的魔力值不足", userid);
+ return false;
+ }
-// // 更新分享率
-// if (userPT.download > 0) {
-// userPT.share = (double) userPT.upload / userPT.download;
-// }
+ // 1:1兑换，直接减去魔力值对应的下载量（假设单位是MB）
+ userPT.magic -= magic;
+ userPT.download = Math.max(0, userPT.download - magic);
-// em.merge(userPT);
-// tx.commit();
+ // 更新分享率
+ if (userPT.download > 0) {
+ userPT.share = (double) userPT.upload / userPT.download;
+ }
-// logger.info("用户 {} 成功将 {} 点魔力值兑换为 {}MB 下载量减免", userid, magic, magic);
-// return true;
+ em.merge(userPT);
+ tx.commit();
-// } catch (Exception e) {
-// if (tx != null && tx.isActive()) {
-// tx.rollback();
-// }
-// logger.error("魔力值兑换下载量时发生错误: {}", e.getMessage());
-// return false;
-// } finally {
-// if (em != null) {
-// em.close();
-// }
-// }
-// }
+ logger.info("用户 {} 成功将 {} 点魔力值兑换为 {}MB 下载量减免", userid, magic, magic);
+ return true;
-// @Override
-// public boolean ExchangeMagicToVip(String userid, int magic) {
-// if (userid == null || userid.isEmpty() || magic <= 0) {
-// logger.warn("参数无效: userid为空或magic <= 0");
-// return false;
-// }
+ } catch (Exception e) {
+ if (tx != null && tx.isActive()) {
+ tx.rollback();
+ }
+ logger.error("魔力值兑换下载量时发生错误: {}", e.getMessage());
+ return false;
+ } finally {
+ if (em != null) {
+ em.close();
+ }
+ }
+ }
-// EntityManager em = null;
-// EntityTransaction tx = null;
+ @Override
+ public boolean ExchangeMagicToVip(String userid, int magic) {
+ if (userid == null || userid.isEmpty() || magic <= 0) {
+ logger.warn("参数无效: userid为空或magic <= 0");
+ return false;
+ }
-// try {
-// em = emf.createEntityManager();
-// tx = em.getTransaction();
-// tx.begin();
+ EntityManager em = null;
+ EntityTransaction tx = null;
-// UserPT userPT = em.find(UserPT.class, userid);
-// if (userPT == null) {
-// logger.warn("未找到用户 {} 的PT信息", userid);
-// return false;
-// }
+ try {
+ em = emf.createEntityManager();
+ tx = em.getTransaction();
+ tx.begin();
-// if (userPT.magic < magic) {
-// logger.warn("用户 {} 的魔力值不足", userid);
-// return false;
-// }
+ UserPT userPT = em.find(UserPT.class, userid);
+ if (userPT == null) {
+ logger.warn("未找到用户 {} 的PT信息", userid);
+ return false;
+ }
-// // 1:1兑换VIP下载次数
-// userPT.magic -= magic;
-// userPT.viptime += magic;
+ if (userPT.magic < magic) {
+ logger.warn("用户 {} 的魔力值不足", userid);
+ return false;
+ }
-// em.merge(userPT);
-// tx.commit();
+ // 1:1兑换VIP下载次数
+ userPT.magic -= magic;
+ userPT.viptime += magic;
-// logger.info("用户 {} 成功将 {} 点魔力值兑换为 {} 次VIP下载次数", userid, magic, magic);
-// return true;
+ em.merge(userPT);
+ tx.commit();
-// } catch (Exception e) {
-// if (tx != null && tx.isActive()) {
-// tx.rollback();
-// }
-// logger.error("魔力值兑换VIP下载次数时发生错误: {}", e.getMessage());
-// return false;
-// } finally {
-// if (em != null) {
-// em.close();
-// }
-// }
-// }
+ logger.info("用户 {} 成功将 {} 点魔力值兑换为 {} 次VIP下载次数", userid, magic, magic);
+ return true;
-// @Override
-// public boolean UploadTransmitProfile(Profile profile) {
-// if (profile == null || profile.profileurl == null || profile.profileurl.isEmpty() ||
-// profile.userid == null || profile.userid.isEmpty()) {
-// logger.warn("参数无效: profile为空或必要字段为空");
-// return false;
-// }
+ } catch (Exception e) {
+ if (tx != null && tx.isActive()) {
+ tx.rollback();
+ }
+ logger.error("魔力值兑换VIP下载次数时发生错误: {}", e.getMessage());
+ return false;
+ } finally {
+ if (em != null) {
+ em.close();
+ }
+ }
+ }
-// EntityManager em = null;
-// EntityTransaction tx = null;
+ @Override
+ public boolean UploadTransmitProfile(Profile profile) {
+ if (profile == null || profile.profileurl == null || profile.profileurl.isEmpty() ||
+ profile.userid == null || profile.userid.isEmpty()) {
+ logger.warn("参数无效: profile为空或必要字段为空");
+ return false;
+ }
-// try {
-// em = emf.createEntityManager();
-// tx = em.getTransaction();
-// tx.begin();
+ EntityManager em = null;
+ EntityTransaction tx = null;
-// // 检查用户是否存在
-// User user = em.find(User.class, profile.userid);
-// if (user == null) {
-// logger.warn("用户 {} 不存在", profile.userid);
-// return false;
-// }
+ try {
+ em = emf.createEntityManager();
+ tx = em.getTransaction();
+ tx.begin();
-// // 检查是否已存在相同的迁移申请
-// Profile existingProfile = em.find(Profile.class, profile.profileurl);
-// if (existingProfile != null) {
-// logger.warn("迁移申请 {} 已存在", profile.profileurl);
-// return false;
-// }
+ // 检查用户是否存在
+ User user = em.find(User.class, profile.userid);
+ if (user == null) {
+ logger.warn("用户 {} 不存在", profile.userid);
+ return false;
+ }
-// // 设置初始值
-// profile.exampass = false;
-// profile.magicgived = "0";
-// profile.uploadgived = "0";
+ // 检查是否已存在相同的迁移申请
+ Profile existingProfile = em.find(Profile.class, profile.profileurl);
+ if (existingProfile != null) {
+ logger.warn("迁移申请 {} 已存在", profile.profileurl);
+ return false;
+ }
-// // 保存迁移申请
-// em.persist(profile);
-// tx.commit();
+ // 设置初始值
+ profile.exampass = false;
+ profile.magicgived = "0";
+ profile.uploadgived = "0";
-// logger.info("成功上传迁移申请 {}", profile.profileurl);
-// return true;
+ // 保存迁移申请
+ em.persist(profile);
+ tx.commit();
-// } catch (Exception e) {
-// if (tx != null && tx.isActive()) {
-// tx.rollback();
-// }
-// logger.error("上传迁移申请时发生错误: {}", e.getMessage());
-// return false;
-// } finally {
-// if (em != null) {
-// em.close();
-// }
-// }
-// }
+ logger.info("成功上传迁移申请 {}", profile.profileurl);
+ return true;
-// @Override
-// public Profile GetTransmitProfile(String profileid) {
-// if (profileid == null || profileid.isEmpty()) {
-// logger.warn("参数无效: profileid为空");
-// return null;
-// }
+ } catch (Exception e) {
+ if (tx != null && tx.isActive()) {
+ tx.rollback();
+ }
+ logger.error("上传迁移申请时发生错误: {}", e.getMessage());
+ return false;
+ } finally {
+ if (em != null) {
+ em.close();
+ }
+ }
+ }
-// EntityManager em = null;
+ @Override
+ public Profile GetTransmitProfile(String profileid) {
+ if (profileid == null || profileid.isEmpty()) {
+ logger.warn("参数无效: profileid为空");
+ return null;
+ }
-// try {
-// em = emf.createEntityManager();
-// Profile profile = em.find(Profile.class, profileid);
-// if (profile == null) {
-// logger.warn("未找到迁移申请 {}", profileid);
-// return null;
-// }
+ EntityManager em = null;
-// logger.info("成功获取迁移申请 {}", profileid);
-// return profile;
+ try {
+ em = emf.createEntityManager();
+ Profile profile = em.find(Profile.class, profileid);
+ if (profile == null) {
+ logger.warn("未找到迁移申请 {}", profileid);
+ return null;
+ }
-// } catch (Exception e) {
-// logger.error("获取迁移申请时发生错误: {}", e.getMessage());
-// return null;
-// } finally {
-// if (em != null) {
-// em.close();
-// }
-// }
-// }
+ logger.info("成功获取迁移申请 {}", profileid);
+ return profile;
-// @Override
-// public boolean ExamTransmitProfile(String profileid, boolean result) {
-// if (profileid == null || profileid.isEmpty()) {
-// logger.warn("参数无效: profileid为空");
-// return false;
-// }
+ } catch (Exception e) {
+ logger.error("获取迁移申请时发生错误: {}", e.getMessage());
+ return null;
+ } finally {
+ if (em != null) {
+ em.close();
+ }
+ }
+ }
-// EntityManager em = null;
-// EntityTransaction tx = null;
+ @Override
+ public boolean ExamTransmitProfile(String profileid, boolean result) {
+ if (profileid == null || profileid.isEmpty()) {
+ logger.warn("参数无效: profileid为空");
+ return false;
+ }
-// try {
-// em = emf.createEntityManager();
-// tx = em.getTransaction();
-// tx.begin();
+ EntityManager em = null;
+ EntityTransaction tx = null;
-// Profile profile = em.find(Profile.class, profileid);
-// if (profile == null) {
-// logger.warn("未找到迁移申请 {}", profileid);
-// return false;
-// }
+ try {
+ em = emf.createEntityManager();
+ tx = em.getTransaction();
+ tx.begin();
-// if (profile.exampass != result) {
-// profile.exampass = result;
+ // 查找迁移申请
+ Profile profile = em.find(Profile.class, profileid);
+ if (profile == null) {
+ logger.warn("未找到迁移申请 {}", profileid);
+ return false;
+ }
-// if (result) {
-// // 如果审核通过，更新用户的PT信息
-// UserPT userPT = em.find(UserPT.class, profile.userid);
-// if (userPT != null) {
-// // 发放魔力值
-// int magicToGive = Integer.parseInt(profile.magictogive);
-// userPT.magic += magicToGive;
-// profile.magicgived = String.valueOf(magicToGive);
+ // 更新审核状态
+ profile.exampass = result;
-// // 发放上传量
-// long uploadToGive = Long.parseLong(profile.uploadtogive);
-// userPT.upload += uploadToGive;
-// profile.uploadgived = String.valueOf(uploadToGive);
+ if (result) {
+ // 如果审核通过，更新用户的PT信息
+ UserPT userPT = em.find(UserPT.class, profile.userid);
+ if (userPT != null) {
+ // 发放魔力值
+ int magicToGive = Integer.parseInt(profile.magictogive);
+ userPT.magic += magicToGive;
+ profile.magicgived = String.valueOf(magicToGive);
-// em.merge(userPT);
-// }
-// }
+ // 发放上传量
+ long uploadToGive = Long.parseLong(profile.uploadtogive);
+ userPT.upload += uploadToGive;
+ profile.uploadgived = String.valueOf(uploadToGive);
-// em.merge(profile);
-// }
+ em.merge(userPT);
+ }
+ }
-// tx.commit();
+ em.merge(profile);
+ tx.commit();
-// logger.info("成功审核迁移申请 {}, 结果: {}", profileid, result);
-// return true;
+ logger.info("成功审核迁移申请 {}, 结果: {}", profileid, result);
+ return true;
-// } catch (Exception e) {
-// if (tx != null && tx.isActive()) {
-// tx.rollback();
-// }
-// logger.error("审核迁移申请时发生错误: {}", e.getMessage());
-// return false;
-// } finally {
-// if (em != null) {
-// em.close();
-// }
-// }
-// }
+ } catch (Exception e) {
+ if (tx != null && tx.isActive()) {
+ tx.rollback();
+ }
+ logger.error("审核迁移申请时发生错误: {}", e.getMessage());
+ return false;
+ } finally {
+ if (em != null) {
+ em.close();
+ }
+ }
+ }
-// @Override
-// public Profile[] GetTransmitProfileList() {
-// EntityManager em = null;
+ @Override
+ public Profile[] GetTransmitProfileList() {
+ EntityManager em = null;
-// try {
-// em = emf.createEntityManager();
+ try {
+ em = emf.createEntityManager();
-// // 获取所有迁移申请
-// QProfile p = QProfile.profile;
-// List<Profile> profiles = new JPAQuery<>(em)
-// .select(p)
-// .from(p)
-// .fetch();
+ // 获取所有迁移申请
+ QProfile p = QProfile.profile;
+ List<Profile> profiles = new JPAQuery<>(em)
+ .select(p)
+ .from(p)
+ .fetch();
-// logger.info("成功获取所有迁移申请，共 {} 条", profiles.size());
-// return profiles.toArray(new Profile[0]);
+ logger.info("成功获取所有迁移申请，共 {} 条", profiles.size());
+ return profiles.toArray(new Profile[0]);
-// } catch (Exception e) {
-// logger.error("获取迁移申请列表时发生错误: {}", e.getMessage());
-// return new Profile[0];
-// } finally {
-// if (em != null) {
-// em.close();
-// }
-// }
-// }
-// }
\ No newline at end of file
+ } catch (Exception e) {
+ logger.error("获取迁移申请列表时发生错误: {}", e.getMessage());
+ return new Profile[0];
+ } finally {
+ if (em != null) {
+ em.close();
+ }
+ }
+ }
+}
\ No newline at end of file