From e7f03acfa5ee4ad4fd6d1ee9e9ae9a5655488f6d Mon Sep 17 00:00:00 2001
From: 101captain <237651143@qq.com>
Date: 星期二, 09 十一月 2021 17:04:46 +0800
Subject: [PATCH] 1109修改

---
 springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActMicroWishServiceImpl.java |   90 +++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 90 insertions(+), 0 deletions(-)

diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActMicroWishServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActMicroWishServiceImpl.java
index 549105f..73f8308 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActMicroWishServiceImpl.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActMicroWishServiceImpl.java
@@ -6,6 +6,7 @@
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.google.common.base.Joiner;
 import com.panzhihua.common.model.dtos.community.bigscreen.work.ScreenMicroListDTO;
 import com.panzhihua.common.model.vos.R;
 import com.panzhihua.common.model.vos.community.ComActMicroWishFeedbackVO;
@@ -13,7 +14,9 @@
 import com.panzhihua.common.model.vos.community.ComActMicroWishVO;
 import com.panzhihua.common.model.vos.community.TodoEventsVO;
 import com.panzhihua.common.model.vos.community.screen.work.MicroListVO;
+import com.panzhihua.common.model.vos.user.SysUserVO;
 import com.panzhihua.common.utlis.SensitiveUtil;
+import com.panzhihua.common.utlis.StringUtils;
 import com.panzhihua.service_community.dao.ComActMicroWishDAO;
 import com.panzhihua.service_community.dao.ComActMicroWishFeedbackMapper;
 import com.panzhihua.service_community.dao.ComActMicroWishOperationRecordMapper;
@@ -89,6 +92,8 @@
                     }
                 }
                 comActMicroWishVO1.setSponsorPhone(SensitiveUtil.desensitizedPhoneNumber(comActMicroWishVO1.getSponsorPhone()));
+                //查询处理人
+                comActMicroWishVO1.setResponsibleName(this.getWishHandleName(comActMicroWishVO1.getHandleId()));
             });
             iPage.setRecords(records);
         }
@@ -164,6 +169,8 @@
         if(!idList.isEmpty()){
             comActMicroWishVO.setIdList(idList);
         }
+        //查询处理人
+        comActMicroWishVO.setResponsibleName(this.getWishHandleName(comActMicroWishVO.getHandleId()));
         return R.ok(comActMicroWishVO);
     }
 
@@ -228,6 +235,9 @@
                 comActMicroWishDO.setResponsibleId(responsibleId);
                 comActMicroWishDO.setStatus(3);//进行中
                 comActMicroWishDO.setForm(1);
+                if(comActMicroWishVO.getHandleIds() != null && comActMicroWishVO.getHandleIds().size() > 0){
+                    comActMicroWishDO.setHandleId(Joiner.on(",").join(comActMicroWishVO.getHandleIds()));
+                }
                 //添加操作记录
                 comActMicroWishOperationRecordDO.setType(ComActMicroWishOperationRecordDO.type.fp);
                 comActMicroWishOperationRecordDO.setContent("分配心愿");
@@ -241,6 +251,9 @@
                 comActMicroWishDO.setResponsibleId(responsibleId);
                 comActMicroWishDO.setStatus(3);//待确认
                 comActMicroWishDO.setForm(2);
+                if(comActMicroWishVO.getHandleIds() != null && comActMicroWishVO.getHandleIds().size() > 0){
+                    comActMicroWishDO.setHandleId(Joiner.on(",").join(comActMicroWishVO.getHandleIds()));
+                }
                 //添加操作记录
                 comActMicroWishOperationRecordDO.setType(ComActMicroWishOperationRecordDO.type.fp);
                 comActMicroWishOperationRecordDO.setContent("分配心愿");
@@ -405,6 +418,8 @@
         List<Long> wishIds = comActMicroWishDAO.getWishAutoConfirmIds();
         wishIds.forEach(wishId -> {
             //需要添加操作记录
+            wishOperationRecordService.addOperationRecord("系统自动确认微心愿",null
+                    ,wishId, ComActMicroWishOperationRecordDO.type.zd,"系统自动确认微心愿",null);
         });
         int num=comActMicroWishDAO.updateStatusAutoConfirm();
         log.info("定时任务--修改待自动确认微心愿状态数量【{}】",num);
@@ -423,4 +438,79 @@
         }
         return R.ok(microListVOIPage);
     }
+
+    /**
+     * 微心愿处理人列表
+     * @param communityId   社区id
+     * @param type  处理人类型(1.后台用户  2.党员  3.志愿者)
+     * @return  处理人列表
+     */
+    @Override
+    public R wishHandleListAdmin(Long communityId,Integer type){
+        return R.ok(comActMicroWishDAO.getWishHandleListAdmin(type,communityId));
+    }
+
+    /**
+     * 拼接处理人
+     * @param handleId  处理人id字符串
+     * @return  处理人名称
+     */
+    private String getWishHandleName(String handleId){
+        StringBuffer sb = new StringBuffer();
+        if(StringUtils.isNotEmpty(handleId)){
+            String []handleIds = handleId.split(",");
+            if(handleIds.length > 0){
+                for (String id : handleIds) {
+                    SysUserVO user = comActMicroWishDAO.getUserByUserId(Long.parseLong(id));
+                    if(user != null){
+                        if(user.getType().equals(SysUserVO.type.xcx)){
+                            if(user.getIsPartymember().equals(SysUserVO.isOk.yes)){
+                                sb.append(user.getName() + "(党员),");
+                            }else if(user.getIsVolunteer().equals(SysUserVO.isOk.yes)){
+                                sb.append(user.getName() + "(志愿者),");
+                            }else{
+                                sb.append(user.getName());
+                            }
+                        }else if(user.getType().equals(SysUserVO.type.sqht)){
+                            sb.append(user.getName() + "(后台用户),");
+                        }
+                    }
+                }
+            }
+        }
+        String result = sb.toString();
+        if(result.length() > 0){
+            result = result.substring(0,result.length()-1);
+        }
+        return result;
+    }
+
+    /**
+     * 社区后台分页查询微心愿
+     * @param comActMicroWishVO 请求参数
+     * @return  微心愿列表
+     */
+    @Override
+    public R pageMicroWishAdmin(ComActMicroWishVO comActMicroWishVO) {
+        Long userId = comActMicroWishVO.getResponsibleId();
+        IPage<ComActMicroWishVO> iPage = comActMicroWishDAO.pageMicroWishAdmin(new Page(comActMicroWishVO.getPageNum()
+                ,comActMicroWishVO.getPageSize()), comActMicroWishVO);
+
+        iPage.getRecords().forEach(comActMicroWishVO1 -> {
+            if(userId != null){
+                Long id = comActMicroWishVO1.getId();
+                ComActMicroWishUserDO comActMicroWishUserDO = comActMicroWishUserDAO.selectOne(new QueryWrapper<ComActMicroWishUserDO>().lambda().eq(ComActMicroWishUserDO::getMicroWishId, id)
+                        .eq(ComActMicroWishUserDO::getUserId, userId));
+                if (ObjectUtils.isEmpty(comActMicroWishUserDO)) {
+                    comActMicroWishVO1.setHaveGiveThumbsUp(0);
+                } else {
+                    comActMicroWishVO1.setHaveGiveThumbsUp(1);
+                }
+            }
+            comActMicroWishVO1.setSponsorPhone(SensitiveUtil.desensitizedPhoneNumber(comActMicroWishVO1.getSponsorPhone()));
+            //查询处理人
+            comActMicroWishVO1.setResponsibleName(this.getWishHandleName(comActMicroWishVO1.getHandleId()));
+        });
+        return R.ok(iPage);
+    }
 }

--
Gitblit v1.7.1