|
|
@ -48,7 +48,7 @@ public class ActivityServiceImpl implements ActivityService { |
|
|
|
private IHanHaiMemberService hanHaiMemberService; |
|
|
|
/******************************************************************************************************************/ |
|
|
|
|
|
|
|
//获取活动列表/详情 |
|
|
|
//获取活动列表 |
|
|
|
@Override |
|
|
|
public Result<?> queryActivityList(CommunityActivity communityActivity, PageBean pageBean) { |
|
|
|
log.info("开始查询活动信息"); |
|
|
@ -104,6 +104,32 @@ public class ActivityServiceImpl implements ActivityService { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
//获取活动信息详情 |
|
|
|
@Override |
|
|
|
public Result<?> queryActivityById(String activityId) { |
|
|
|
log.info("开始查询活动信息详情"); |
|
|
|
//返回信息 |
|
|
|
String massege = ""; |
|
|
|
|
|
|
|
try{ |
|
|
|
CommunityActivity one = communityActivityService |
|
|
|
.lambdaQuery() |
|
|
|
.eq(CommunityActivity::getId, activityId) |
|
|
|
.one(); |
|
|
|
if(null == one){ |
|
|
|
log.info("活动信息不存在,请检查活动id:{}", activityId); |
|
|
|
return Result.OK("活动信息不存在,请检查活动id:"+activityId, one); |
|
|
|
} |
|
|
|
|
|
|
|
log.info("活动信息详情查询结束"); |
|
|
|
return Result.OK("活动信息详情", one); |
|
|
|
}catch (Exception e){ |
|
|
|
log.info("活动信息详情查询失败"); |
|
|
|
e.printStackTrace(); |
|
|
|
return Result.error("活动信息详情查询失败"); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
//获取我收藏的活动列表 |
|
|
|
@Override |
|
|
|
public Result<?> queryActivityCollectionList(String token, PageBean pageBean) { |
|
|
@ -121,6 +147,7 @@ public class ActivityServiceImpl implements ActivityService { |
|
|
|
Page<CommunityActivityCollection> pageList = null; |
|
|
|
|
|
|
|
try{ |
|
|
|
//1、获取活动列表 |
|
|
|
//分页 |
|
|
|
page = new Page<CommunityActivityCollection>(pageBean.getPageNo(), pageBean.getPageSize()); |
|
|
|
query = communityActivityCollectionService |
|
|
@ -135,6 +162,15 @@ public class ActivityServiceImpl implements ActivityService { |
|
|
|
//获取活动信息 |
|
|
|
pageList = query.page(page); |
|
|
|
|
|
|
|
//2、添加活动信息至收藏内 |
|
|
|
for (CommunityActivityCollection record : pageList.getRecords()) { |
|
|
|
CommunityActivity one = communityActivityService |
|
|
|
.lambdaQuery() |
|
|
|
.eq(CommunityActivity::getId, record.getActivityId()) |
|
|
|
.one(); |
|
|
|
record.setCommunityActivity(one); |
|
|
|
} |
|
|
|
|
|
|
|
log.info("活动信息查询结束"); |
|
|
|
return Result.OK("活动列表", pageList); |
|
|
|
}catch (Exception e){ |
|
|
@ -161,6 +197,7 @@ public class ActivityServiceImpl implements ActivityService { |
|
|
|
Page<CommunityActivityApply> pageList = null; |
|
|
|
|
|
|
|
try{ |
|
|
|
//1、获取活动列表 |
|
|
|
//分页 |
|
|
|
page = new Page<CommunityActivityApply>(pageBean.getPageNo(), pageBean.getPageSize()); |
|
|
|
query = communityActivityApplyService |
|
|
@ -179,6 +216,15 @@ public class ActivityServiceImpl implements ActivityService { |
|
|
|
//获取活动信息 |
|
|
|
pageList = query.page(page); |
|
|
|
|
|
|
|
//2、添加活动信息至报名活动列表内 |
|
|
|
for (CommunityActivityApply record : pageList.getRecords()) { |
|
|
|
CommunityActivity one = communityActivityService |
|
|
|
.lambdaQuery() |
|
|
|
.eq(CommunityActivity::getId, record.getActivityId()) |
|
|
|
.one(); |
|
|
|
record.setCommunityActivity(one); |
|
|
|
} |
|
|
|
|
|
|
|
log.info("活动信息查询结束"); |
|
|
|
return Result.OK("活动列表", pageList); |
|
|
|
}catch (Exception e){ |
|
|
@ -285,20 +331,31 @@ public class ActivityServiceImpl implements ActivityService { |
|
|
|
log.info("用户已报名过该活动,请勿重复报名"); |
|
|
|
return Result.OK("用户已报名过该活动,请勿重复报名"); |
|
|
|
}else { |
|
|
|
//添加报名信息 |
|
|
|
//3、添加报名信息 |
|
|
|
log.info("添加报名信息"); |
|
|
|
communityActivityApply.setUserId(hanHaiMember.getId()); |
|
|
|
boolean result = communityActivityApplyService.save(communityActivityApply); |
|
|
|
boolean result1 = communityActivityApplyService.save(communityActivityApply); |
|
|
|
|
|
|
|
//4、活动添加报名人数 |
|
|
|
log.info("活动添加报名人数"); |
|
|
|
int oldnum = activity.getNumActivity(); |
|
|
|
int newnum = oldnum + 1; |
|
|
|
activity.setNumActivity(newnum); |
|
|
|
boolean result2 = communityActivityService.updateById(activity); |
|
|
|
|
|
|
|
//判断是否新增成功 |
|
|
|
if(result){ |
|
|
|
if(result1 && result2){ |
|
|
|
log.info("活动报名成功"); |
|
|
|
return Result.OK("活动报名成功"); |
|
|
|
}else { |
|
|
|
log.info("活动报名失败"); |
|
|
|
return Result.error("活动报名失败"); |
|
|
|
} |
|
|
|
} |
|
|
|
}catch (Exception e){ |
|
|
|
log.error("活动报名失败"); |
|
|
|
e.printStackTrace(); |
|
|
|
return Result.error("报名失败"); |
|
|
|
return Result.error("活动报名失败"); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|