Merge branch 'dev-2.0.1' of http://120.76.84.145:10101/gitblit/r/java/zhihu...

liujie

2 天以前 ee060884a27b901e24e5b532278d040265d5579c

 springcloud_k8s_panzhihuazhihuishequ/service_sangeshenbian/src/main/java/com/panzhihua/sangeshenbian/api/SystemUserController.java

@@ -1,6 +1,7 @@
package com.panzhihua.sangeshenbian.api;

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;
@@ -68,13 +69,16 @@
   @Resource
   private ISystemLogService systemLogService;

   @Resource
   private ISystemUserLevelService systemUserLevelService;





   @PostMapping("/login")
   @ApiOperation(value = "登录", tags = {"三个身边后台-登录"})
   @SysLog(operatorCategory = "登录")
   @SysLog(operatorCategory = "登录",operId = 1)
   public R<TokenVo> login(@RequestBody LoginVo vo){
      String key = "login:" + vo.getPhone();
      Integer size = (Integer) redisTemplate.opsForValue().get(key);
@@ -205,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("不能添加市级账号");
      }
@@ -240,18 +254,30 @@
         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){
@@ -279,18 +305,28 @@
      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());
   }


@@ -299,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);
   }

@@ -378,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(){
@@ -396,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);