| | |
| | | import com.panzhihua.common.model.vos.community.ComActVO; |
| | | import com.panzhihua.common.model.vos.community.ComMngStructOtherBuildVO; |
| | | import com.panzhihua.service_community.dao.ComActDAO; |
| | | import com.panzhihua.service_community.dao.ComActVillageDAO; |
| | | import com.panzhihua.service_community.dao.ComStreetDAO; |
| | | import com.panzhihua.service_community.model.dos.ComActDO; |
| | | import com.panzhihua.service_community.model.dos.ComMngVillageDO; |
| | | import com.panzhihua.service_community.model.dos.ComStreetDO; |
| | | import com.panzhihua.service_community.service.ComActService; |
| | | import org.springframework.beans.BeanUtils; |
| | | import org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.util.ObjectUtils; |
| | | |
| | |
| | | public class ComActServiceImpl implements ComActService { |
| | | @Resource |
| | | private ComActDAO comActDAO; |
| | | @Resource |
| | | private ComStreetDAO comStreetDAO; |
| | | |
| | | /** |
| | | * 新增社区 |
| | | * |
| | |
| | | */ |
| | | @Override |
| | | public R addCommunity(ComActVO comActVO) { |
| | | ComActDO comActDO=new ComActDO(); |
| | | BeanUtils.copyProperties(comActVO,comActDO); |
| | | String password = comActVO.getPassword(); |
| | | String encode = new BCryptPasswordEncoder().encode(password); |
| | | comActVO.setPassword(encode); |
| | | ComStreetDO comStreetDO = comStreetDAO.selectById(comActVO.getStreetId()); |
| | | if (comStreetDO == null) { |
| | | return R.fail("当前街道不存在!"); |
| | | } |
| | | ComActDO comActDO = new ComActDO(); |
| | | Integer integer = comActDAO.selectCount(new QueryWrapper<ComActDO>().lambda().eq(ComActDO::getName, comActVO.getName())); |
| | | if (integer > 0) { |
| | | return R.fail("社区已经存在"); |
| | | } |
| | | BeanUtils.copyProperties(comActVO, comActDO); |
| | | int insert = comActDAO.insert(comActDO); |
| | | if (insert>0) { |
| | | return R.ok(); |
| | | if (insert > 0) { |
| | | ComActDO comActDO1 = comActDAO.selectOne(new QueryWrapper<ComActDO>().lambda().eq(ComActDO::getName, comActVO.getName())); |
| | | BeanUtils.copyProperties(comActDO1, comActVO); |
| | | return R.ok(comActVO); |
| | | } |
| | | return R.fail(); |
| | | } |
| | |
| | | */ |
| | | @Override |
| | | public R putCommunity(ComActVO comActVO) { |
| | | ComActDO comActDO=new ComActDO(); |
| | | BeanUtils.copyProperties(comActVO,comActDO); |
| | | ComActDO comActDO = new ComActDO(); |
| | | String password = comActVO.getPassword(); |
| | | String account = comActVO.getAccount(); |
| | | Long communityId = comActVO.getCommunityId(); |
| | | // String contacts = comActVO.getContacts(); |
| | | int a = 0; |
| | | if (!ObjectUtils.isEmpty(password)) { |
| | | String encode = new BCryptPasswordEncoder().encode(password); |
| | | comActVO.setPassword(encode); |
| | | a = 1; |
| | | } |
| | | ComStreetDO comStreetDO = comStreetDAO.selectById(comActVO.getStreetId()); |
| | | if (comStreetDO == null) { |
| | | return R.fail("当前街道不存在!"); |
| | | } |
| | | // if(!ObjectUtils.isEmpty(account)||!ObjectUtils.isEmpty(contacts)){ |
| | | // a=1; |
| | | // } |
| | | BeanUtils.copyProperties(comActVO, comActDO); |
| | | |
| | | int update = comActDAO.updateById(comActDO); |
| | | if (update>0) { |
| | | if (update > 0) { |
| | | if (a == 1) { |
| | | // 修改登录账户的密码 |
| | | comActDAO.updateAccountPassword(comActVO.getPassword(), account, communityId); |
| | | } |
| | | return R.ok(); |
| | | } |
| | | return R.fail(); |
| | |
| | | */ |
| | | @Override |
| | | public R listCommunity(ComActVO comActVO) { |
| | | List<ComActVO> comActVOS=comActDAO.listCommunity(comActVO); |
| | | List<ComActVO> comActVOS = comActDAO.listCommunity(comActVO); |
| | | return R.ok(comActVOS); |
| | | } |
| | | |
| | |
| | | if (ObjectUtils.isEmpty(comActDO)) { |
| | | return R.fail(); |
| | | } |
| | | ComActVO comActVO=new ComActVO(); |
| | | BeanUtils.copyProperties(comActDO,comActVO); |
| | | ComActVO comActVO = new ComActVO(); |
| | | BeanUtils.copyProperties(comActDO, comActVO); |
| | | comActVO.setAreaName(comActDAO.selectAreaName(comActVO.getAreaCode())); |
| | | return R.ok(comActVO); |
| | | } |
| | |
| | | Page page = new Page<>(); |
| | | Long pageNum = pageComActDTO.getPageNum(); |
| | | Long pageSize = pageComActDTO.getPageSize(); |
| | | if (null==pageNum||0==pageNum) { |
| | | if (null == pageNum || 0 == pageNum) { |
| | | pageNum = 1l; |
| | | } |
| | | if (null==pageSize||0==pageSize) { |
| | | if (null == pageSize || 0 == pageSize) { |
| | | pageSize = 10l; |
| | | } |
| | | page.setSize(pageSize); |
| | |
| | | */ |
| | | @Override |
| | | public R listCommunityAll() { |
| | | List<ComActDO> comActDOS = comActDAO.selectList(new QueryWrapper<ComActDO>().lambda().eq(ComActDO::getState, 0).orderByDesc(ComActDO::getCreateAt)); |
| | | List<ComActVO> comActVOS=new ArrayList<>(); |
| | | List<ComActDO> comActDOS = comActDAO.selectList(new QueryWrapper<ComActDO>().lambda().eq(ComActDO::getState, 0) |
| | | .eq(ComActDO::getCityCode, "510400") |
| | | .orderByDesc(ComActDO::getCreateAt)); |
| | | List<ComActVO> comActVOS = new ArrayList<>(); |
| | | if (!ObjectUtils.isEmpty(comActDOS)) { |
| | | comActDOS.forEach(comActDO -> { |
| | | ComActVO comActVO=new ComActVO(); |
| | | BeanUtils.copyProperties(comActDO,comActVO); |
| | | ComActVO comActVO = new ComActVO(); |
| | | BeanUtils.copyProperties(comActDO, comActVO); |
| | | comActVOS.add(comActVO); |
| | | }); |
| | | } |
| | | return R.ok(comActVOS); |
| | | } |
| | | |
| | | /** |
| | | * 删除社区 |
| | | * |
| | | * @param communityId 社区id |
| | | * @return 删除结果 |
| | | */ |
| | | @Override |
| | | public R delectCommunity(Long communityId) { |
| | | int delete = comActDAO.deleteById(communityId); |
| | | if (delete > 0) { |
| | | return R.ok(); |
| | | } |
| | | return R.fail(); |
| | | } |
| | | |
| | | /** |
| | | * 综治后台-查询社区列表 |
| | | * @return 社区列表 |
| | | */ |
| | | @Override |
| | | public R getCommunityLists(){ |
| | | return R.ok(this.comActDAO.getCommunityLists()); |
| | | } |
| | | |
| | | |
| | | } |