花城-智慧社区
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
liujie
2 天以前 ee060884a27b901e24e5b532278d040265d5579c 
 springcloud_k8s_panzhihuazhihuishequ/service_sangeshenbian/src/main/java/com/panzhihua/sangeshenbian/api/SystemUserController.java


@@ -1,11 +1,7 @@


package com.panzhihua.sangeshenbian.api;




import cn.hutool.http.HttpRequest;


import cn.hutool.http.HttpResponse;


import cn.hutool.http.HttpUtil;


import com.alibaba.fastjson.JSON;


import com.alibaba.fastjson.JSONObject;


import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;


import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;


import com.baomidou.mybatisplus.core.metadata.IPage;


import com.panzhihua.common.controller.BaseController;


import com.panzhihua.common.interfaces.OperLog;


@@ -13,15 +9,10 @@


import com.panzhihua.common.model.vos.R;


import com.panzhihua.common.model.vos.sangeshenbian.SystemUserVo;


import com.panzhihua.common.service.auth.TokenService;


import com.panzhihua.common.utlis.HttpClientUtil;


import com.panzhihua.common.utlis.ServletUtils;


import com.panzhihua.sangeshenbian.model.entity.SystemMenu;


import com.panzhihua.sangeshenbian.model.entity.SystemRoleMenu;


import com.panzhihua.sangeshenbian.model.entity.SystemUser;


import com.panzhihua.sangeshenbian.annotation.SysLog;


import com.panzhihua.sangeshenbian.model.entity.*;


import com.panzhihua.sangeshenbian.model.vo.RegionVO;


import com.panzhihua.sangeshenbian.service.ISystemMenuService;


import com.panzhihua.sangeshenbian.service.ISystemRoleMenuService;


import com.panzhihua.sangeshenbian.service.ISystemUserService;


import com.panzhihua.sangeshenbian.service.*;


import com.panzhihua.sangeshenbian.utils.SignatureUtil;


import com.panzhihua.sangeshenbian.warpper.*;


import io.swagger.annotations.Api;


@@ -29,19 +20,13 @@


import io.swagger.annotations.ApiImplicitParams;


import io.swagger.annotations.ApiOperation;


import lombok.extern.slf4j.Slf4j;


import org.apache.commons.codec.digest.DigestUtils;


import org.apache.commons.lang.StringUtils;


import org.springframework.beans.BeanUtils;


import org.springframework.data.redis.core.RedisTemplate;


import org.springframework.data.redis.core.StringRedisTemplate;


import org.springframework.util.ObjectUtils;


import org.springframework.web.bind.annotation.*;




import javax.annotation.Resource;


import javax.servlet.http.HttpServletRequest;


import java.io.IOException;


import java.security.MessageDigest;


import java.text.MessageFormat;


import java.text.SimpleDateFormat;


import java.time.LocalDateTime;


import java.util.*;


import java.util.concurrent.TimeUnit;


@@ -74,13 +59,26 @@


   @Resource


   private ISystemMenuService systemMenuService;




   @Resource


   private IBcRegionService bcRegionService;


   @Resource


   private IComStreetService comStreetService;


   @Resource


   private IComActService comActService;




   @Resource


   private ISystemLogService systemLogService;




   @Resource


   private ISystemUserLevelService systemUserLevelService;












   @PostMapping("/login")


   @ApiOperation(value = "登录", tags = {"三个身边后台-登录"})


   @OperLog(operModul = "三个身边后台",operType = 0,businessType = "登录")


   @SysLog(operatorCategory = "登录",operId = 1)


   public R<TokenVo> login(@RequestBody LoginVo vo){


      String key = "login:" + vo.getPhone();


      Integer size = (Integer) redisTemplate.opsForValue().get(key);


@@ -111,6 +109,7 @@


      LoginReturnVO loginReturnVO = reult.getData();


      TokenVo tokenVo = new TokenVo();


      BeanUtils.copyProperties(loginReturnVO, tokenVo);


      tokenVo.setUserId(Long.valueOf(systemUser.getId()));




      List<SystemRoleMenu> list = systemRoleMenuService.list(new LambdaQueryWrapper<SystemRoleMenu>().eq(SystemRoleMenu::getSystemRoleId, systemUser.getSystemRoleId()));


      List<Integer> collect = list.stream().map(SystemRoleMenu::getSystemMenuId).collect(Collectors.toList());


@@ -210,10 +209,20 @@




   @PostMapping("/add")


   @ApiOperation(value = "添加人员", tags = {"三个身边管理后台-人员管理"})


   @OperLog(operModul = "三个身边后台",operType = 1,businessType = "添加人员")


   @SysLog(operatorCategory = "添加账号",operId = 4)


   public R add(@RequestBody SystemUser systemUser){


      Integer id = this.getLoginUserInfoSanGeShenBian().getId();


      SystemUser user = systemUserService.getById(id);


      List<SystemUserLevel> systemUserLevels = systemUser.getSystemUserLevels();


      if(systemUserLevels==null || systemUserLevels.isEmpty()){


         return R.fail("请选择账号层级");


      }


      // 获取最高层级的用于原来的判断


      systemUserLevels.sort(Comparator.comparing(SystemUserLevel::getLevel));


      Integer level = systemUserLevels.get(0).getLevel();


      user.setAccountLevel(level);






      if(2 == user.getAccountLevel() && 1 == systemUser.getAccountLevel()){


         return R.fail("不能添加市级账号");


      }


@@ -227,37 +236,97 @@


      if(0 < count){


         return R.fail("手机号重复。");


      }




      String districtsCode = systemUser.getDistrictsCode();


      if (!StringUtils.isEmpty(districtsCode)){


         BcRegion bcRegion = bcRegionService.getOne(new LambdaQueryWrapper<BcRegion>().eq(BcRegion::getRegionCode, districtsCode));


         systemUser.setDistricts(bcRegion.getRegionName());


      }




      String streetId = systemUser.getStreetId();


      if (!StringUtils.isEmpty(streetId)){


         ComStreet comStreet = comStreetService.getById(streetId);


         systemUser.setStreet(comStreet.getName());


      }


      Long communityId = systemUser.getCommunityId();


      if (communityId != null){


         ComAct act = comActService.getById(communityId);


         systemUser.setCommunity(act.getName());


      }




      systemUser.setStatus(1);


      systemUser.setCreateTime(LocalDateTime.now());


      // 2.0.1 默认管理员


      systemUser.setIsAdmin(1);


      systemUserService.save(systemUser);




      // 2.0.1添加账号层级


      systemUserLevels.forEach(e->{


         e.setSystemUserId(systemUser.getId());


         e.setStatus(1);


      });


      systemUserLevelService.saveBatch(systemUserLevels);


      return R.ok();


   }






   @PostMapping("/edit")


   @ApiOperation(value = "编辑人员", tags = {"三个身边后台-人员管理"})


   @OperLog(operModul = "三个身边后台",operType = 2,businessType = "编辑人员")


   @SysLog(operatorCategory = "编辑账号",operId = 4)


   public R edit(@RequestBody SystemUser systemUser){


      List<SystemUserLevel> systemUserLevels = systemUser.getSystemUserLevels();


      if(systemUserLevels==null || systemUserLevels.isEmpty()){


         return R.fail("请选择账号层级");


      }


      long count = systemUserService.count(new LambdaQueryWrapper<SystemUser>().eq(SystemUser::getPhone, systemUser.getPhone())


            .ne(SystemUser::getStatus, 3).ne(SystemUser::getId, systemUser.getId()));


      if(0 < count){


         return R.fail("手机号重复。");


      }




      String districtsCode = systemUser.getDistrictsCode();


      if (!StringUtils.isEmpty(districtsCode)){


         BcRegion bcRegion = bcRegionService.getOne(new LambdaQueryWrapper<BcRegion>().eq(BcRegion::getRegionCode, districtsCode));


         systemUser.setDistricts(bcRegion.getRegionName());


      }




      String streetId = systemUser.getStreetId();


      if (!StringUtils.isEmpty(streetId)){


         ComStreet comStreet = comStreetService.getById(streetId);


         systemUser.setStreet(comStreet.getName());


      }


      Long communityId = systemUser.getCommunityId();


      if (communityId != null){


         ComAct act = comActService.getById(communityId);


         systemUser.setCommunity(act.getName());


      }






      systemUser.setStatus(1);


      systemUser.setCreateTime(LocalDateTime.now());


      systemUserService.updateById(systemUser);


      // 移除原来层级 在添加新层级


      systemUserLevelService.remove(new LambdaQueryWrapper<SystemUserLevel>().eq(SystemUserLevel::getSystemUserId, systemUser.getId()));


      systemUserLevels.forEach(e->{


         e.setSystemUserId(systemUser.getId());


         e.setStatus(1);


      });


      systemUserLevelService.saveBatch(systemUserLevels);






      return R.ok();


   }






   @DeleteMapping("/delete/{id}")


   @ApiOperation(value = "删除人员", tags = {"三个身边后台-人员管理"})


   @OperLog(operModul = "三个身边后台",operType = 3,businessType = "删除人员")


   @SysLog(operatorCategory = "删除账号",operId = 4)


   public R delete(@PathVariable("id") Integer id){


      SystemUser systemUser = systemUserService.getById(id);


      systemUser.setStatus(3);


      systemUserService.updateById(systemUser);


      return R.ok();


      systemUserLevelService.update(new LambdaUpdateWrapper<SystemUserLevel>().eq(SystemUserLevel::getSystemUserId, id).set(SystemUserLevel::getStatus,3));


      return R.ok(systemUser.getName());


   }






@@ -266,6 +335,9 @@


   @OperLog(operModul = "三个身边后台",operType = 0,businessType = "查询人员详情")


   public R<SystemUser> getSystemUserInfo(@PathVariable("id") Integer id){


      SystemUser systemUser = systemUserService.getById(id);


      List<SystemUserLevel> listBySystemUserId = systemUserLevelService.getListBySystemUserId(id);


      listBySystemUserId.sort(Comparator.comparing(SystemUserLevel::getLevel));


      systemUser.setSystemUserLevels(listBySystemUserId);


      return R.ok(systemUser);


   }




@@ -345,6 +417,65 @@


      log.info("获取行政区划层级联动数据：{}", list);


      return R.ok(list);


   }






   @GetMapping("/getAdministrativeDivisionTwo")


   @ApiOperation(value = "获取行政区划层级联动数据--2.0.1", tags = {"三个身边后台-人员管理"})


   @ApiImplicitParams({


   })


   @OperLog(operModul = "三个身边后台",operType = 0,businessType = "获取行政区划层级联动数据--2.0.1")


   public R<ArrayList<RegionVO>> getAdministrativeDivisionTwo(){


      ArrayList<RegionVO> regionVOS = new ArrayList<>();




      regionVOS.add(new RegionVO("1","市",new ArrayList<>(),1));


      List<BcRegion> list = bcRegionService.list(new LambdaQueryWrapper<BcRegion>().eq(BcRegion::getDeleteFlag, 0));


      ArrayList<RegionVO> regionList = new ArrayList<>();


      list.forEach(e->{


         RegionVO regionVO = new RegionVO();


         regionVO.setId(e.getRegionCode());


         regionVO.setName(e.getRegionName());


         regionVO.setTier(2);


         regionList.add(regionVO);


      });


      regionVOS.add(new RegionVO("2","区县",regionList,2));


      List<ComStreet> list1 = comStreetService.list(new LambdaQueryWrapper<ComStreet>().in(ComStreet::getAreaCode, regionList.stream().map(RegionVO::getId).collect(Collectors.toList())));




      for (RegionVO regionVO : regionList) {


         ArrayList<RegionVO> list2 = new ArrayList<>();


         List<ComStreet> collect = list1.stream().filter(e -> e.getAreaCode().toString().equals(regionVO.getId())).collect(Collectors.toList());


         collect.forEach(e->{


            RegionVO regionVO1 = new RegionVO();


            regionVO1.setId(e.getStreetId());


            regionVO1.setName(e.getName());


            regionVO1.setTier(3);


            list2.add(regionVO1);


         });


         regionVO.setChildren(list2);


      }


      regionVOS.add(new RegionVO("3","街道",regionList,3));


      List<ComAct> list2 = comActService.list();




      for (RegionVO regionVO : regionList) {


         List<RegionVO> children = regionVO.getChildren();


         for (RegionVO child : children) {


            List<ComAct> collect = list2.stream().filter(e -> e.getStreetId().toString().equals(child.getId())).collect(Collectors.toList());


            ArrayList<RegionVO> list3 = new ArrayList<>();


            collect.forEach(e->{


               RegionVO regionVO2 = new RegionVO();


               regionVO2.setId(e.getCommunityId().toString());


               regionVO2.setName(e.getName());


               regionVO2.setTier(4);


               list3.add(regionVO2);


            });


            child.setChildren(list3);


         }


      }


      regionVOS.add(new RegionVO("4","社区",regionList,4));


      return R.ok(regionVOS);


   }








   @GetMapping("/regionTree")


   @ApiOperation(value = "获取区县-街道-社区树",tags = {"三个身边后台-人员管理"})


   public R<List<RegionVO>> regionTree(){


@@ -363,7 +494,8 @@


        String jsapiTicket = SignatureUtil.getJsApiTicket(accessToken);


        String nonceStr = UUID.randomUUID().toString().replace("-", "");


        String timestamp = String.valueOf(System.currentTimeMillis() / 1000);


        String url = "https://huacheng.psciio.com/web/sangeshenbian/"; // 当前页面的URL，不包含#及其后面部分


//        String url = "https://huacheng.psciio.com/web/sangeshenbian/"; // 当前页面的URL，不包含#及其后面部分


        String url = "http://192.168.110.91:8080/#/pages/Appeal/Appeal/"; // 当前页面的URL，不包含#及其后面部分




        String signature = SignatureUtil.getSignature(jsapiTicket, nonceStr, timestamp, url);