From 814b7dfb73f8ae763023a4fd2835bbead8c66a93 Mon Sep 17 00:00:00 2001
From: 101captain <237651143@qq.com>
Date: 星期五, 17 九月 2021 17:53:06 +0800
Subject: [PATCH] 一键报警,物业平台相关功能修改

---
 springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActReserveRecordServiceImpl.java |   50 +++++++++++++++++++++++++++++++++++++++++++-------
 1 files changed, 43 insertions(+), 7 deletions(-)

diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActReserveRecordServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActReserveRecordServiceImpl.java
index 72b059a..d8aab2a 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActReserveRecordServiceImpl.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActReserveRecordServiceImpl.java
@@ -6,15 +6,13 @@
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.panzhihua.common.model.dtos.community.reserve.*;
 import com.panzhihua.common.model.vos.R;
-import com.panzhihua.common.model.vos.community.reserve.ComActReserveMakeDetailAdminVO;
-import com.panzhihua.common.model.vos.community.reserve.ComActReserveMakeOperationAdminVO;
-import com.panzhihua.common.model.vos.community.reserve.ComActReserveRegisterStatisticsAdminVO;
+import com.panzhihua.common.model.vos.community.reserve.*;
 import com.panzhihua.common.utlis.DateUtils;
-import com.panzhihua.service_community.dao.ComActReserveOperationRecordMapper;
+import com.panzhihua.service_community.dao.*;
 import com.panzhihua.common.model.dtos.community.CancelRecordDTO;
 import com.panzhihua.common.model.vos.R;
 import com.panzhihua.service_community.dao.ComActReserveOperationRecordMapper;
-import com.panzhihua.service_community.dao.ComActReserveRecordMapper;
+import com.panzhihua.service_community.model.dos.ComActReserveDO;
 import com.panzhihua.service_community.model.dos.ComActReserveOperationRecordDO;
 import com.panzhihua.service_community.model.dos.ComActReserveRecordDO;
 import com.panzhihua.service_community.service.ComActReserveOperationRecordService;
@@ -44,6 +42,10 @@
     @Resource
     private ComActReserveRecordMapper comActReserveRecordMapper;
     @Resource
+    private ComActReserveMapper comActReserveMapper;
+    @Resource
+    private ComActReserveAnswerContentMapper comActReserveAnswerContentMapper;
+    @Resource
     private ComActReserveOperationRecordMapper comActReserveOperationRecordMapper;
     @Resource
     private ComActReserveOperationRecordService comActReserveOperationRecordService;
@@ -57,10 +59,16 @@
             ComActReserveRecordDO comActReserveRecordDO=comActReserveRecordMapper.selectById(comActReserveRecord.getId());
             if(comActReserveRecordDO!=null&&comActReserveRecordDO.getStatus()!=ComActReserveRecordDO.status.yqx){
                 comActReserveRecordDO.setStatus(ComActReserveRecordDO.status.yqx);
-                comActReserveRecordDO.setContent(comActReserveRecord.getContent());
+                comActReserveRecordDO.setRemark(comActReserveRecord.getContent());
+                comActReserveRecordDO.setReserveTime(DateUtil.date());
                 int result =comActReserveRecordMapper.updateById(comActReserveRecordDO);
                 //判断取消状态并添加操作记录
                 if(result>0){
+                    //更新回答用户数量
+                    ComActReserveDO comActReserveDO=comActReserveMapper.selectById(comActReserveRecordDO.getReserveId());
+                    Integer joinCount = comActReserveDO.getJoinCount();
+                    comActReserveDO.setJoinCount(joinCount != null ? joinCount - 1 : 0);
+                    comActReserveMapper.updateById(comActReserveDO);
                     ComActReserveOperationRecordDO comActReserveOperationRecordDO=new ComActReserveOperationRecordDO();
                     comActReserveOperationRecordDO.setReserveId(comActReserveRecordDO.getReserveId());
                     comActReserveOperationRecordDO.setReserveRecordId(comActReserveRecordDO.getId());
@@ -70,6 +78,7 @@
                     comActReserveOperationRecordDO.setPhone(comActReserveRecordDO.getPhone());
                     comActReserveOperationRecordDO.setStatus(ComActReserveOperationRecordDO.status.qx);
                     comActReserveOperationRecordDO.setUserId(comActReserveRecordDO.getUserId());
+                    comActReserveOperationRecordDO.setReserveTime(DateUtil.date());
                     comActReserveOperationRecordMapper.insert(comActReserveOperationRecordDO);
                     return R.ok();
                 }
@@ -117,13 +126,15 @@
     public R makeCancelAdmin(CancelReserveRecordDTO reserveRecordDTO){
         Integer count = this.baseMapper.getReserveStatusById(reserveRecordDTO.getIds());
         if(count > 0){
-            return R.ok("您选择的记录中存在未预约成功,不可进行批量取消");
+            return R.fail("仅预约成功的可以进行取消操作");
         }
         if(this.baseMapper.editReserveStatusById(reserveRecordDTO.getIds()) > 0){
             Long userId = reserveRecordDTO.getUserId();
             reserveRecordDTO.getIds().forEach(id -> {
                 ComActReserveRecordDO reserveRecordDO = comActReserveRecordMapper.selectById(id);
                 if(reserveRecordDO != null){
+                    //取消预约返还可参加名额
+                    comActReserveMapper.addReserveCountById(reserveRecordDO.getReserveId());
                     //添加操作记录
                     comActReserveOperationRecordService.addReserveOperationRecord(reserveRecordDO.getReserveId()
                             ,reserveRecordDO.getId(),reserveRecordDO.getUserId(),ComActReserveOperationRecordDO.type.sq,null
@@ -252,4 +263,29 @@
         return R.ok(this.baseMapper.exportMakeHandleAdmin(pageMakeHandleDTO));
     }
 
+    @Override
+    public R registerDetailedDetailAdmin(Long reserveRecordId){
+        //查询用户信息
+        ComActReserveRegisterDetailedVO registerDetailedVO = this.baseMapper.getRegisterDetailedByRecordId(reserveRecordId);
+        if(registerDetailedVO != null){
+            //组装用户身份信息
+            StringBuilder sb = new StringBuilder();
+            if(registerDetailedVO.getIsPartymember().equals(1)){
+                sb.append("党员/");
+            }
+            if(registerDetailedVO.getIsVolunteer().equals(1)){
+                sb.append("志愿者/");
+            }
+            if(sb.length() == 0){
+                sb.append("居民/");
+            }
+            String identity = sb.toString();
+            registerDetailedVO.setIdentity(identity.substring(0,identity.length()-1));
+            //查询答题数据
+            List<ComActReserveRegisterDetailedAnswerVO> answerList = comActReserveAnswerContentMapper.getRegisterDetailedAnswerList(reserveRecordId);
+            registerDetailedVO.setAnswerList(answerList);
+        }
+        return R.ok(registerDetailedVO);
+    }
+
 }

--
Gitblit v1.7.1