From 06c572ada5080ae8051a7cb943e9723d1e1a4bcf Mon Sep 17 00:00:00 2001
From: 101captain <237651143@qq.com>
Date: 星期四, 31 三月 2022 16:14:02 +0800
Subject: [PATCH] 导入党委 更新志愿者状态

---
 springcloud_k8s_panzhihuazhihuishequ/service_partybuilding/src/main/java/com/panzhihua/service_dangjian/service/impl/ComPbMemberServiceImpl.java |   62 ++++++++++++++++++++++++++++++
 1 files changed, 61 insertions(+), 1 deletions(-)

diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_partybuilding/src/main/java/com/panzhihua/service_dangjian/service/impl/ComPbMemberServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_partybuilding/src/main/java/com/panzhihua/service_dangjian/service/impl/ComPbMemberServiceImpl.java
index a13ffbc..90dbae2 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_partybuilding/src/main/java/com/panzhihua/service_dangjian/service/impl/ComPbMemberServiceImpl.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_partybuilding/src/main/java/com/panzhihua/service_dangjian/service/impl/ComPbMemberServiceImpl.java
@@ -396,6 +396,27 @@
             pbMemberDO.setUpdateAt(nowDate);
             pbMemberDO.setType(ComPbMemberDO.Type.ZSDY);
             comPbMemberDAO.insert(pbMemberDO);
+            //金沙特殊需求
+            if(pbMemberDO.getCommunityId()==2L){
+                ComMngVolunteerMngVO comMngVolunteerMngVO=new ComMngVolunteerMngVO();
+                comMngVolunteerMngVO.setOrgId(53L);
+                comMngVolunteerMngVO.setName(pbMemberDO.getName());
+                comMngVolunteerMngVO.setPhone(pbMemberDO.getPhone());
+                comMngVolunteerMngVO.setIdCard(pbMemberDO.getIdCard());
+                comMngVolunteerMngVO.setState(2);
+                comMngVolunteerMngVO.setCommunityId(2L);
+                R r = communityService.addVolunteer(comMngVolunteerMngVO);
+                // 支援者添加成功,修改小程序用户的志愿者状态    ,通过手机号
+                if (R.isOk(r)) {
+                    String phone = comMngVolunteerMngVO.getPhone();
+                    R r1 = userService.putUserIsVolunteer(phone, 1);
+                    if (R.isOk(r1)) {
+                        log.info("修改手机号【{}】的支援者状态为是", phone);
+                    } else {
+                        log.info("手机号【{}】没有小程序用户", phone);
+                    }
+                }
+            }
         }else{
             //存在则更新党委党员信息
             BeanUtils.copyProperties(partyCommitteeVO, pbMemberDO);
@@ -1072,7 +1093,46 @@
 
         if(saveList.size() > 0){
             saveList.forEach(save -> {
-                comPbMemberRoleDAO.insert(save);
+                int result = comPbMemberRoleDAO.insert(save);
+                if(result>0){
+                    //判断党员信息是否存在党委信息
+                    ComPbMemberDO pbMemberDO = comPbMemberDAO.selectOne(new QueryWrapper<ComPbMemberDO>().lambda()
+                            .eq(ComPbMemberDO::getIdCard,save.getIdCard())
+                            .eq(ComPbMemberDO::getAuditResult,ComPbMemberDO.AuditResult.SHTG)
+                            .eq(ComPbMemberDO::getCommunityId,save.getCommunityId()));
+                    if(pbMemberDO == null){
+                        //不存在则创建党委党员信息
+                        pbMemberDO = new ComPbMemberDO();
+                        BeanUtils.copyProperties(save, pbMemberDO);
+                        pbMemberDO.setAuditResult(ComPbMemberDO.AuditResult.SHTG);
+                        pbMemberDO.setCreateAt(nowDate);
+                        pbMemberDO.setUpdateAt(nowDate);
+                        pbMemberDO.setType(ComPbMemberDO.Type.ZSDY);
+                        comPbMemberDAO.insert(pbMemberDO);
+                        //金沙特殊需求
+                        if(pbMemberDO.getCommunityId()==2L){
+                            ComMngVolunteerMngVO comMngVolunteerMngVO=new ComMngVolunteerMngVO();
+                            comMngVolunteerMngVO.setOrgId(53L);
+                            comMngVolunteerMngVO.setName(pbMemberDO.getName());
+                            comMngVolunteerMngVO.setPhone(pbMemberDO.getPhone());
+                            comMngVolunteerMngVO.setIdCard(pbMemberDO.getIdCard());
+                            comMngVolunteerMngVO.setState(2);
+                            comMngVolunteerMngVO.setCommunityId(2L);
+                            R r = communityService.addVolunteer(comMngVolunteerMngVO);
+                            // 支援者添加成功,修改小程序用户的志愿者状态    ,通过手机号
+                            if (R.isOk(r)) {
+                                String phone = comMngVolunteerMngVO.getPhone();
+                                R r1 = userService.putUserIsVolunteer(phone, 1);
+                                if (R.isOk(r1)) {
+                                    log.info("修改手机号【{}】的支援者状态为是", phone);
+                                } else {
+                                    log.info("手机号【{}】没有小程序用户", phone);
+                                }
+                            }
+                        }
+                    }
+                }
+                userService.updateUserIsPartymember(save.getIdCard());
             });
         }
         if(mistakes.size() > 0){

--
Gitblit v1.7.1