修改管理后台登录和鉴权逻辑

Pu Zhibing

2025-02-24 f703e6ebceac409876e6a4af3da436b3b1ec927c

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

@@ -5,6 +5,7 @@
import com.panzhihua.common.interfaces.OperLog;
import com.panzhihua.common.model.vos.R;
import com.panzhihua.sangeshenbian.model.MessageNotification;
import com.panzhihua.sangeshenbian.model.SystemUser;
import com.panzhihua.sangeshenbian.service.IMessageNotificationService;
import com.panzhihua.sangeshenbian.service.ISystemUserService;
import com.panzhihua.sangeshenbian.warpper.MessageNotificationList;
@@ -21,7 +22,7 @@

@Api
@RestController
@RequestMapping("/sangeshenbian/messageNotification")
@RequestMapping("/messageNotification")
public class MessageNotificationController extends BaseController {
   
   @Resource
@@ -30,10 +31,32 @@
   @Resource
   private ISystemUserService systemUserService;
   
	
	
   @GetMapping("/list")
   @ApiOperation(value = "获取消息通知列表", tags = {"三个身边后台-消息通知"})
   @OperLog(operModul = "三个身边后台",operType = 0, businessType = "获取消息通知列表")
   public R<IPage<MessageNotification>> list(MessageNotificationList query) {
      Integer id = this.getLoginUserInfoSanGeShenBian().getId();
      SystemUser systemUser = systemUserService.getById(id);
      switch (systemUser.getAccountLevel()){
         case 1:
            query.setUserId("510400");
            break;
         case 2:
            query.setUserId(systemUser.getDistrictsCode());
            break;
         case 3:
            query.setUserId(systemUser.getStreetId().toString());
            break;
         case 4:
            query.setUserId(systemUser.getCommunityId().toString());
            break;
         case 5:
            query.setUserId(id.toString());
            break;
      }
      query.setUndertakerType(systemUser.getAccountLevel());
      IPage<MessageNotification> page = messageNotificationService.list(query);
      return R.ok(page);
   }
@@ -57,9 +80,30 @@
   @ApiOperation(value = "获取未读数量", tags = {"三个身边后台-消息通知"})
   @OperLog(operModul = "三个身边后台",operType = 0, businessType = "获取未读数量")
   public R unreadCount() {
      Integer id = this.getLoginUserInfoSanGeShenBian().getId();
      SystemUser systemUser = systemUserService.getById(id);
      String userId = null;
      switch (systemUser.getAccountLevel()){
         case 1:
            userId = "510400";
            break;
         case 2:
            userId = systemUser.getDistrictsCode();
            break;
         case 3:
            userId = systemUser.getStreetId().toString();
            break;
         case 4:
            userId = systemUser.getCommunityId().toString();
            break;
         case 5:
            userId = id.toString();
            break;
      }
      Integer count = messageNotificationService.lambdaQuery()
            .eq(MessageNotification::getReadStatus, 0)
            .eq(MessageNotification::getUndertakerUserId, getUserId())
            .eq(MessageNotification::getUndertakerType, systemUser.getAccountLevel())
            .eq(MessageNotification::getUndertakerUserId, userId)
            .count();
      return R.ok(count);
   }