From ae33fef700e5d2558dffb03c8f66358da2545791 Mon Sep 17 00:00:00 2001 From: huanghongfa <18228131219@163.com> Date: 星期四, 07 一月 2021 16:25:41 +0800 Subject: [PATCH] 通知后台加入代码 --- springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/CommunityApi.java | 30 +++++++++++++++++++++++++++++- 1 files changed, 29 insertions(+), 1 deletions(-) diff --git a/springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/CommunityApi.java b/springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/CommunityApi.java index d75f8e1..6ba63f3 100644 --- a/springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/CommunityApi.java +++ b/springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/CommunityApi.java @@ -1,15 +1,20 @@ package com.panzhihua.applets.api; +import com.alibaba.fastjson.JSONObject; import com.panzhihua.common.controller.BaseController; import com.panzhihua.common.model.dtos.community.PageVolunteerDTO; import com.panzhihua.common.model.vos.R; import com.panzhihua.common.model.vos.community.*; +import com.panzhihua.common.model.vos.partybuilding.PartyBuildingActivityVO; +import com.panzhihua.common.model.vos.user.SysUserNoticeVO; import com.panzhihua.common.service.community.CommunityService; +import com.panzhihua.common.service.user.UserService; import com.panzhihua.common.validated.AddGroup; import com.panzhihua.common.validated.PageGroup; import io.swagger.annotations.Api; import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiOperation; +import lombok.extern.slf4j.Slf4j; import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.*; @@ -21,12 +26,15 @@ * @author: huang.hongfa weixin hhf9596 qq 959656820 * @create: 2020-12-10 10:04 **/ +@Slf4j @RestController @RequestMapping("/community/") @Api(tags = {"社区服务"}) public class CommunityApi extends BaseController { @Resource private CommunityService communityService; + @Resource + private UserService userService; @ApiOperation(value = "分页获取社区动态",response = ComActDynVO.class) @PostMapping("pagedynamic") @@ -65,8 +73,28 @@ @PutMapping("signactivity") public R signActivity(@RequestBody @Validated(AddGroup.class) SignactivityVO signactivityVO){ Long userId = this.getUserId(); + Long activityId = signactivityVO.getActivityId(); signactivityVO.setUserId(userId); - return communityService.signActivity(signactivityVO); + R r = communityService.signActivity(signactivityVO); + if (R.isOk(r)&&signactivityVO.getType().intValue()==1) { + R r2 = communityService.detailActivity(activityId, userId); + ComActActivityVO comActActivityVO= JSONObject.parseObject(JSONObject.toJSONString(r2.getData()),ComActActivityVO.class); + SysUserNoticeVO sysUserNoticeVO=new SysUserNoticeVO(); + sysUserNoticeVO.setUserId(userId); + sysUserNoticeVO.setType(1); + sysUserNoticeVO.setTitle("报名成功"); + sysUserNoticeVO.setBusinessType(1); + sysUserNoticeVO.setBusinessTitle(comActActivityVO.getActivityName()); + sysUserNoticeVO.setBusinessContent(String.format("活动将于%s开始,请按时参加",comActActivityVO.getBeginAt())); + sysUserNoticeVO.setBusinessId(activityId); + sysUserNoticeVO.setStatus(0); + sysUserNoticeVO.setBusinessStatus(2); + R r1 = userService.addNotice(sysUserNoticeVO); + if (R.isOk(r1)) { + log.info("新增用户报名社区活动通知成功【{}】", JSONObject.toJSONString(sysUserNoticeVO)); + } + } + return r; } @ApiOperation(value = "活动人员列表",response = ActivitySignVO.class) -- Gitblit v1.7.1