站点账户列表

car-wash-admin/src/main/java/com/kym/admin/controller/FinanceController.java

@@ -2,7 +2,9 @@ package com.kym.admin.controller;
 
 import com.kym.common.R;
 import com.kym.entity.queryParams.SplitRecordQueryParams;
+import com.kym.entity.queryParams.StationQueryParam;
 import com.kym.service.SplitRecordService;
+import com.kym.service.StationAccountService;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
@@ -19,9 +21,22 @@ import org.springframework.web.bind.annotation.RestController;
 public class FinanceController {
 
     private final SplitRecordService splitRecordService;
+    private final StationAccountService stationAccountService;
 
-    public FinanceController(SplitRecordService splitRecordService) {
+    public FinanceController(SplitRecordService splitRecordService, StationAccountService stationAccountService) {
         this.splitRecordService = splitRecordService;
+        this.stationAccountService = stationAccountService;
+    }
+
+    /**
+     * 站点账户列表
+     *
+     * @param params
+     * @return
+     */
+    @PostMapping("/stationAccounts")
+    public R<?> stationAccounts(@RequestBody StationQueryParam params) {
+        return R.success(stationAccountService.listStationAccounts(params));
     }
 
     /**

car-wash-service/src/main/java/com/kym/service/StationAccountService.java

@@ -1,6 +1,8 @@
 package com.kym.service;
 
 import com.kym.entity.StationAccount;
+import com.kym.entity.common.PageBean;
+import com.kym.entity.queryParams.StationQueryParam;
 import com.kym.service.mybatisplus.MyBaseService;
 
 /**
@@ -14,4 +16,6 @@ import com.kym.service.mybatisplus.MyBaseService;
 public interface StationAccountService extends MyBaseService<StationAccount> {
 
     StationAccount getStationAccount(String stationId);
+
+    PageBean<StationAccount> listStationAccounts(StationQueryParam stationId);
 }

car-wash-service/src/main/java/com/kym/service/impl/StationAccountServiceImpl.java

@@ -1,8 +1,14 @@
 package com.kym.service.impl;
 
+import cn.dev33.satoken.stp.StpUtil;
+import com.github.pagehelper.PageHelper;
+import com.kym.common.utils.CommUtil;
 import com.kym.entity.StationAccount;
+import com.kym.entity.common.PageBean;
+import com.kym.entity.queryParams.StationQueryParam;
 import com.kym.mapper.StationAccountMapper;
 import com.kym.service.StationAccountService;
+import com.kym.service.cache.KymCache;
 import com.kym.service.mybatisplus.MyBaseServiceImpl;
 import org.springframework.stereotype.Service;
 
@@ -21,4 +27,23 @@ public class StationAccountServiceImpl extends MyBaseServiceImpl<StationAccountM
     public StationAccount getStationAccount(String stationId) {
         return lambdaQuery().eq(StationAccount::getStationId, stationId).one();
     }
+
+    @Override
+    public PageBean<StationAccount> listStationAccounts(StationQueryParam params) {
+        // 判断数据权限
+        var adminStationIds = KymCache.INSTANCE.getAdminUserStationIds(StpUtil.getLoginIdAsLong());
+        if (CommUtil.isEmptyOrNull(params.getStationId()) && CommUtil.isNotEmptyAndNull(adminStationIds)) {
+            params.setStationId(adminStationIds.get(0));
+        }
+        if (CommUtil.isNotEmptyAndNull(params.getStationId()) && CommUtil.isNotEmptyAndNull(adminStationIds) && !adminStationIds.contains(params.getStationId())) {
+            params.setStationId(adminStationIds.get(0));
+        }
+
+        PageHelper.startPage(params.getPageNum(), params.getPageSize());
+        var res = lambdaQuery()
+                .eq(CommUtil.isNotEmptyAndNull(params.getStationId()), StationAccount::getStationId, params.getStationId())
+                .orderByDesc(StationAccount::getId)
+                .list();
+        return new PageBean<>(res);
+    }
 }