添加站点功能，更新与骑手有关的接口

db/update_241014.sql

@@ -0,0 +1,12 @@
+-- 创建站点表
+CREATE TABLE rider_station
+(
+    id           INT PRIMARY KEY,
+    station_name VARCHAR(100)
+);
+
+-- 用户表增加站点id字段
+ALTER TABLE tb_user ADD rider_station_id int;
+
+-- 给tb_order添加order_number索引
+ALTER TABLE tb_order ADD INDEX order_number_index (order_number);

src/main/java/com/sqx/config/ShiroConfig.java

@@ -84,6 +84,8 @@ public class ShiroConfig {
 
         filterMap.put("/admin/goods/**","anon");
         filterMap.put("/selfGoodsRule/**","anon");
+//        站点
+        filterMap.put("/admin/riderStation/**","anon");
         //
         filterMap.put("/**", "oauth2");
         filterMap.put("/shop/ordersChat/selectShopAllUnreadCount", "oauth2");

src/main/java/com/sqx/modules/app/entity/UserEntity.java

@@ -14,248 +14,253 @@ import java.math.BigDecimal;
 
 /**
  * 用户
- *
  */
 @Data
 @ApiModel("用户")
 @TableName("tb_user")
 public class UserEntity implements Serializable {
-	private static final long serialVersionUID = 1L;
+    private static final long serialVersionUID = 1L;
 
-	@TableId(type = IdType.AUTO)
+    @TableId(type = IdType.AUTO)
 
-	@ApiModelProperty("用户id")
-	private Long userId;
+    @ApiModelProperty("用户id")
+    private Long userId;
 
 
-	@ApiModelProperty("用户名")
-	private String userName;
+    @ApiModelProperty("用户名")
+    private String userName;
 
 
-	@ApiModelProperty("用户类型 1用户 2骑手师傅")
-	private Integer userType;
+    @ApiModelProperty("用户类型 1用户 2骑手师傅")
+    private Integer userType;
 
 
-	@ApiModelProperty("手机号")
-	private String phone;
+    @ApiModelProperty("手机号")
+    private String phone;
 
 
-	@ApiModelProperty("头像")
-	private String avatar;
+    @ApiModelProperty("头像")
+    private String avatar;
 
 
-	@ApiModelProperty("昵称")
-	private String nickName;
+    @ApiModelProperty("昵称")
+    private String nickName;
 
 
-	@ApiModelProperty("性别 1男 2女")
-	private Integer sex;
+    @ApiModelProperty("性别 1男 2女")
+    private Integer sex;
 
 
-	@ApiModelProperty("年龄")
-	private Integer age;
+    @ApiModelProperty("年龄")
+    private Integer age;
 
 
-	@ApiModelProperty("保证金")
-	private BigDecimal cashDeposit;
+    @ApiModelProperty("保证金")
+    private BigDecimal cashDeposit;
 
 
-	@ApiModelProperty("账户余额")
-	private BigDecimal balance;
+    @ApiModelProperty("账户余额")
+    private BigDecimal balance;
 
 
-	@ApiModelProperty("证件号码")
-	private String identityCardNumber;
+    @ApiModelProperty("证件号码")
+    private String identityCardNumber;
 
 
-	@ApiModelProperty("身份证正面图片")
-	private String identityCardFront;
+    @ApiModelProperty("身份证正面图片")
+    private String identityCardFront;
 
 
-	@ApiModelProperty("身份证反面图片")
-	private String identityCardVerso;
+    @ApiModelProperty("身份证反面图片")
+    private String identityCardVerso;
 
 
-	@ApiModelProperty("手持身份证正面图片")
-	private String selfIdentityCard;
+    @ApiModelProperty("手持身份证正面图片")
+    private String selfIdentityCard;
 
 
-	@ApiModelProperty("实名认证审核状态（0：待审核；1：审核通过；2：审核不通过）")
-	private String checkCertification;
+    @ApiModelProperty("实名认证审核状态（0：待审核；1：审核通过；2：审核不通过）")
+    private String checkCertification;
 
 
-	@ApiModelProperty("实名认证审核说明")
-	private String checkCertificationMessage;
+    @ApiModelProperty("实名认证审核说明")
+    private String checkCertificationMessage;
 
 
-	@ApiModelProperty("邀请码")
-	private String invitationCode;
+    @ApiModelProperty("邀请码")
+    private String invitationCode;
 
 
-	@ApiModelProperty("邀请人邀请码")
-	private String inviterCode;
+    @ApiModelProperty("邀请人邀请码")
+    private String inviterCode;
 
 
-	@ApiModelProperty("微信app openid")
-	private String wxOpenId;
+    @ApiModelProperty("微信app openid")
+    private String wxOpenId;
 
 
-	@ApiModelProperty("rider_wx_open_id")
-	private String riderWxOpenId;
+    @ApiModelProperty("rider_wx_open_id")
+    private String riderWxOpenId;
 
 
-	@ApiModelProperty("普通用户微信小程序openid")
-	private String openId;
+    @ApiModelProperty("普通用户微信小程序openid")
+    private String openId;
 
 
-	@ApiModelProperty("骑手用户微信小程序openid")
-	private String riderOpenId;
+    @ApiModelProperty("骑手用户微信小程序openid")
+    private String riderOpenId;
 
-	@ApiModelProperty("商家用户微信小程序openid")
-	private String shopOpenId;
+    @ApiModelProperty("商家用户微信小程序openid")
+    private String shopOpenId;
 
 
-	@ApiModelProperty("密码")
-	private String password;
+    @ApiModelProperty("密码")
+    private String password;
 
 
-	@ApiModelProperty("苹果id")
-	private String appleId;
+    @ApiModelProperty("苹果id")
+    private String appleId;
 
 
-	@ApiModelProperty("手机类型 1安卓 2ios")
-	private Integer sysPhone;
+    @ApiModelProperty("手机类型 1安卓 2ios")
+    private Integer sysPhone;
 
 
-	@ApiModelProperty("状态 1正常 2禁用")
-	private Integer status;
+    @ApiModelProperty("状态 1正常 2禁用")
+    private Integer status;
 
 
-	@ApiModelProperty("来源 app 小程序 公众号")
-	private String platform;
+    @ApiModelProperty("来源 app 小程序 公众号")
+    private String platform;
 
 
-	@ApiModelProperty("积分")
-	private Integer jifen;
+    @ApiModelProperty("积分")
+    private Integer jifen;
 
 
-	@ApiModelProperty("设备id")
-	private String clientid;
+    @ApiModelProperty("设备id")
+    private String clientid;
 
 
-	@ApiModelProperty("骑手设备id")
-	private String riderClientid;
+    @ApiModelProperty("骑手设备id")
+    private String riderClientid;
 
-	@ApiModelProperty("商家设备id")
-	private String shopClientId;
+    @ApiModelProperty("商家设备id")
+    private String shopClientId;
 
 
-	@ApiModelProperty("支付宝名字")
-	private String zhiFuBaoName;
+    @ApiModelProperty("支付宝名字")
+    private String zhiFuBaoName;
 
 
-	@ApiModelProperty("支付宝账号")
-	private String zhiFuBao;
+    @ApiModelProperty("支付宝账号")
+    private String zhiFuBao;
 
 
-	@ApiModelProperty("创建时间")
-	private String createTime;
+    @ApiModelProperty("创建时间")
+    private String createTime;
 
 
-	@ApiModelProperty("更新时间")
-	private String updateTime;
+    @ApiModelProperty("更新时间")
+    private String updateTime;
 
 
-	@ApiModelProperty("用户类型")
-	private Integer type;
+    @ApiModelProperty("用户类型")
+    private Integer type;
 
 
-	@ApiModelProperty("用户提交实名认证时间")
-	private String auditTime;
+    @ApiModelProperty("用户提交实名认证时间")
+    private String auditTime;
 
 
-	@ApiModelProperty("该用户是否是跑腿新用户 1：是新用户 2：是老用户")
-	private Integer newUserFlag;
+    @ApiModelProperty("该用户是否是跑腿新用户 1：是新用户 2：是老用户")
+    private Integer newUserFlag;
 
 
-	@ApiModelProperty("该用户是否是外卖新用户 1：是新用户 2：是老用户")
-	private Integer newUserFlagWm;
+    @ApiModelProperty("该用户是否是外卖新用户 1：是新用户 2：是老用户")
+    private Integer newUserFlagWm;
 
 
-	@ApiModelProperty("骑手当前经度")
-	private Double stationLng;
+    @ApiModelProperty("骑手当前经度")
+    private Double stationLng;
 
 
-	@ApiModelProperty("骑手当前维度")
-	private Double stationLat;
+    @ApiModelProperty("骑手当前维度")
+    private Double stationLat;
 
 
-	@ApiModelProperty("骑手是否上线 1：上线 2：未上线")
-	private Integer onLineFlag;
+    @ApiModelProperty("骑手是否上线 1：上线 2：未上线")
+    private Integer onLineFlag;
 
 
-	@ApiModelProperty("实名认证支付保证金订单号")
-	private String checkNumber;
+    @ApiModelProperty("实名认证支付保证金订单号")
+    private String checkNumber;
 
 
-	@ApiModelProperty("是否是门店用户 1是")
-	private Integer shopAdminFlag;
+    @ApiModelProperty("是否是门店用户 1是")
+    private Integer shopAdminFlag;
 
 
-	@ApiModelProperty("门店管理员id")
-	private Long adminUserId;
+    @ApiModelProperty("门店管理员id")
+    private Long adminUserId;
 
-	@ApiModelProperty("用户提现二维码")
-	@TableField(value = "cash_qr_code")
-	private String cashQrCode;
+    @ApiModelProperty("用户提现二维码")
+    @TableField(value = "cash_qr_code")
+    private String cashQrCode;
 
-	@ApiModelProperty("是否推送消息")
-	private Integer isSendMsg;
+    @ApiModelProperty("是否推送消息")
+    private Integer isSendMsg;
 
-	private String msg;
+    private String msg;
 
-	@ApiModelProperty("是否是会员 0不是  1是")
-	private Integer isVip;
+    @ApiModelProperty("是否是会员 0不是  1是")
+    private Integer isVip;
 
-	@ApiModelProperty("会员到期时间")
-	private String vipExpirationTime;
+    @ApiModelProperty("会员到期时间")
+    private String vipExpirationTime;
 
-	@TableField(exist = false)
-	private BigDecimal money;
+    @ApiModelProperty("站点id")
+    private Integer riderStationId;
 
-	@TableField(exist = false)
-	private BigDecimal integralNum;
+    @TableField(exist = false)
+    private BigDecimal money;
 
-	//本月下单数量
-	@TableField(exist = false)
-	private Integer orderMonth;
+    @TableField(exist = false)
+    private BigDecimal integralNum;
 
-	//本月接单数量
-	@TableField(exist = false)
-	private Integer joinOrderMonth;
+    //本月下单数量
+    @TableField(exist = false)
+    private Integer orderMonth;
 
-	//本月充值
-	@TableField(exist = false)
-	private BigDecimal topUpMonth;
+    //本月接单数量
+    @TableField(exist = false)
+    private Integer joinOrderMonth;
 
-	//骑手收入
-	@TableField(exist = false)
-	private BigDecimal riderMoney;
+    //本月充值
+    @TableField(exist = false)
+    private BigDecimal topUpMonth;
 
-	//提现金额
-	@TableField(exist = false)
-	private BigDecimal cashMoney;
+    //骑手收入
+    @TableField(exist = false)
+    private BigDecimal riderMoney;
 
-	@TableField(exist = false)
-	private String indentNumber;
+    //提现金额
+    @TableField(exist = false)
+    private BigDecimal cashMoney;
 
-	@TableField(exist = false)
-	private Double distance;
+    @TableField(exist = false)
+    private String indentNumber;
 
-	@TableField(exist = false)
-	private Integer shopStatus;
+    @TableField(exist = false)
+    private Double distance;
 
-	@TableField(exist = false)
-	private Long shopId;
+    @TableField(exist = false)
+    private Integer shopStatus;
 
+    @TableField(exist = false)
+    private Long shopId;
+
+    //	站点名称
+    @TableField(exist = false)
+    private String stationName;
 }

src/main/java/com/sqx/modules/datacentre/controller/DataCentreController.java

@@ -2,6 +2,7 @@ package com.sqx.modules.datacentre.controller;
 
 import com.sqx.common.utils.Result;
 import com.sqx.modules.app.entity.RechargeRecord;
+import com.sqx.modules.app.entity.UserEntity;
 import com.sqx.modules.app.service.RechargeRecordService;
 import com.sqx.modules.app.service.UserMoneyService;
 import com.sqx.modules.coupon.entity.TbCouponUser;
@@ -147,8 +148,8 @@ public class DataCentreController {
 
     @ApiOperation("查看所有实名认证待审核用户")
     @GetMapping(value = "findAllCertification")
-    public Result findAllCertification(Integer page, Integer limit, String userName, String phone, String checkCertification) {
-        return dataCentreService.findAllCertification(page, limit, userName, phone, checkCertification);
+    public Result findAllCertification(Integer page, Integer limit, String userName, String phone, String checkCertification,Integer riderStationId) {
+        return dataCentreService.findAllCertification(page, limit, userName, phone, checkCertification,riderStationId);
     }
 
     @ApiOperation("实名认证审核")
@@ -167,9 +168,9 @@ public class DataCentreController {
 
     @ApiOperation("接单排行榜")
     @GetMapping(value = "rankingList")
-    public Result rankingList(Integer page, Integer limit, String address, String date, String dateType) {
+    public Result rankingList(Integer page, Integer limit, String address, String date, String dateType,Integer riderStationId) {
 
-        return dataCentreService.rankingList(page, limit, address, date, dateType);
+        return dataCentreService.rankingList(page, limit, address, date, dateType,riderStationId);
     }
 
     @ApiOperation("门店统计")
@@ -275,5 +276,11 @@ public class DataCentreController {
         return dataCentreService.presenterVip(userId);
     }
 
+    @ApiOperation("编辑实名认证待审核用户")
+    @PostMapping(value = "updateCertification")
+    public Result updateCertification(@RequestBody UserEntity userEntity) {
+        return dataCentreService.updateCertification(userEntity);
+    }
+
 
 }

src/main/java/com/sqx/modules/datacentre/dao/DataCentreDao.java

@@ -43,13 +43,13 @@ public interface DataCentreDao {
 
     BigDecimal selectTopUpStatistics(@Param("date") String date,@Param("dateType") String dateType);
 
-    IPage<UserEntity> findAllCertification(Page<UserEntity> pages, String userName, String phone, String checkCertification);
+    IPage<UserEntity> findAllCertification(Page<UserEntity> pages, String userName, String phone, String checkCertification,Integer riderStationId);
 
     int checkCertification(@Param("userId") Long userId, @Param("checkCertification") String checkCertification,@Param("checkCertificationMessage") String checkCertificationMessage);
 
     UserEntity findCertification(Long userId);
 
-    IPage<TbIndent> rankingList(Page<TbIndent> pages, String address, String date, String dateType);
+    IPage<TbIndent> rankingList(Page<TbIndent> pages, String address, String date, String dateType,Integer riderStationId);
 
     int selectNewShopCount(@Param("query")ShopCenterQuery query);
 

src/main/java/com/sqx/modules/datacentre/service/DataCentreService.java

@@ -1,6 +1,7 @@
 package com.sqx.modules.datacentre.service;
 
 import com.sqx.common.utils.Result;
+import com.sqx.modules.app.entity.UserEntity;
 import com.sqx.modules.datacentre.query.ShopCenterQuery;
 import com.sqx.modules.pay.controller.query.CashOutQueryDTO;
 import com.sqx.modules.utils.excel.ExcelData;
@@ -19,13 +20,13 @@ public interface DataCentreService {
 
     Result selectTopUpStatistics(String date, String dateType);
 
-    Result findAllCertification(Integer page, Integer limit, String userName, String phone, String checkCertification);
+    Result findAllCertification(Integer page, Integer limit, String userName, String phone, String checkCertification,Integer riderStationId);
 
     Result checkCertification(Long userId, String checkCertification, String checkCertificationMessage);
 
     Result findCertification(Long userId);
 
-    Result rankingList(Integer page, Integer limit, String address, String date, String dateType);
+    Result rankingList(Integer page, Integer limit, String address, String date, String dateType,Integer riderStationId);
 
     Result selectShopCenter(ShopCenterQuery query);
 
@@ -53,4 +54,5 @@ public interface DataCentreService {
 
     Result presenterVip(Long userId);
 
+    Result updateCertification(UserEntity userEntity);
 }

src/main/java/com/sqx/modules/datacentre/service/impl/DataCentreServiceImpl.java

@@ -169,9 +169,9 @@ public class DataCentreServiceImpl implements DataCentreService {
     }
 
     @Override
-    public Result findAllCertification(Integer page,Integer limit,String userName,String phone, String checkCertification) {
+    public Result findAllCertification(Integer page,Integer limit,String userName,String phone, String checkCertification,Integer riderStationId) {
         Page<UserEntity> pages=new Page<>(page,limit);
-        return Result.success().put("data", new PageUtils(dataCentreDao.findAllCertification(pages, userName, phone,checkCertification )));
+        return Result.success().put("data", new PageUtils(dataCentreDao.findAllCertification(pages, userName, phone,checkCertification, riderStationId)));
     }
 
     @Transactional
@@ -226,9 +226,9 @@ public class DataCentreServiceImpl implements DataCentreService {
     }
 
     @Override
-    public Result rankingList(Integer page, Integer limit, String address,String date, String dateType) {
+    public Result rankingList(Integer page, Integer limit, String address,String date, String dateType,Integer riderStationId) {
         Page<TbIndent> pages=new Page<>(page,limit);
-        PageUtils pageUtils = new PageUtils(dataCentreDao.rankingList(pages, address, date, dateType));
+        PageUtils pageUtils = new PageUtils(dataCentreDao.rankingList(pages, address, date, dateType,riderStationId));
         return Result.success().put("data", pageUtils);
     }
 
@@ -413,5 +413,11 @@ public class DataCentreServiceImpl implements DataCentreService {
         return Result.success();
     }
 
+    @Override
+    public Result updateCertification(UserEntity userEntity) {
+        userDao.updateById(userEntity);
+        return Result.success();
+    }
+
 
 }

src/main/java/com/sqx/modules/errand/entity/TbIndent.java

@@ -264,7 +264,9 @@ public class TbIndent implements Serializable {
     @TableField(exist = false)
     private Integer evaluateMessage;
 
-
+    //	站点名称
+    @TableField(exist = false)
+    private String stationName;
 
     public TbIndent() {}
 }

src/main/java/com/sqx/modules/pay/controller/query/CashOutQueryDTO.java

@@ -39,6 +39,9 @@ public class CashOutQueryDTO extends PageQuery {
     @ApiModelProperty("查询结束时间")
     private String endTime;
 
+    @ApiModelProperty("骑手所在站点id")
+    private String riderStationId;
+
     public String toStrCode() {
         return
 //                ","+bankCardNo+

src/main/java/com/sqx/modules/pay/service/impl/WxErrRiderServiceImpl.java

@@ -115,6 +115,9 @@ public class WxErrRiderServiceImpl implements WxErrRiderService {
         }
         userEntity.setUserId(userId);
         userEntity.setCheckNumber(generalOrder);
+//        因为添加站点，所以需要更新tb_user表
+        userDao.updateById(userEntity);
+
         CommonInfo one = commonInfoService.findOne(273);
         double money = Double.parseDouble(one.getValue());
         PayDetails payDetails = new PayDetails();

src/main/java/com/sqx/modules/pay/vo/CashOutVO.java

@@ -14,4 +14,10 @@ public class CashOutVO extends CashOut {
      * 店铺名称
      */
     private String shopName;
+
+    /**
+     * 站点名称
+     */
+    private String stationName;
+
 }

src/main/java/com/sqx/modules/riderStation/controller/AdminRiderStationController.java

@@ -0,0 +1,59 @@
+package com.sqx.modules.riderStation.controller;
+
+import com.sqx.common.utils.Result;
+import com.sqx.modules.goods.service.GoodsShopService;
+import com.sqx.modules.riderStation.entity.RiderStation;
+import com.sqx.modules.riderStation.service.RiderStationService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+@Api(tags={"管理端-骑手站点"})
+@RestController
+@RequestMapping("/admin/riderStation")
+public class AdminRiderStationController {
+
+    @Autowired
+    private RiderStationService riderStationService;
+
+    @ApiOperation("添加站点")
+    @PostMapping(value = "/saveStation")
+    public Result saveStation(@RequestBody RiderStation riderStation){
+        riderStationService.save(riderStation);
+        return Result.success();
+    }
+
+    @ApiOperation("查询站点")
+    @GetMapping(value = "/selectStationList")
+    public Result selectStationList(Integer page,Integer size){
+        return riderStationService.selectStationList(page,size);
+    }
+
+    @ApiOperation("修改站点")
+    @PostMapping(value = "/updateStation")
+    public Result updateStation(@RequestBody RiderStation riderStation){
+        riderStationService.updateById(riderStation);
+        return Result.success();
+    }
+
+    @ApiOperation("删除站点")
+    @GetMapping(value = "/removeStation")
+    public Result removeStation(Integer id){
+        riderStationService.removeById(id);
+        return  Result.success();
+    }
+
+    @ApiOperation("站点下拉框")
+    @GetMapping(value = "/stationList")
+    public Result stationList(){
+        return riderStationService.stationList();
+    }
+
+
+    @ApiOperation("骑手所在站点")
+    @GetMapping(value = "/getRiderStationName")
+    public Result getRiderStationName(Integer userId){
+        return riderStationService.getRiderStationName(userId);
+    }
+}

src/main/java/com/sqx/modules/riderStation/dao/RiderStationDao.java

@@ -0,0 +1,9 @@
+package com.sqx.modules.riderStation.dao;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.sqx.modules.riderStation.entity.RiderStation;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface RiderStationDao extends BaseMapper<RiderStation> {
+}

src/main/java/com/sqx/modules/riderStation/entity/RiderStation.java

@@ -0,0 +1,21 @@
+package com.sqx.modules.riderStation.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+@Data
+@ApiModel("rider_station")
+public class RiderStation {
+    private static final long serialVersionUID = 1L;
+
+    @TableId(type = IdType.AUTO)
+
+    @ApiModelProperty("主键id")
+    private Long id;
+
+    @ApiModelProperty("站点名称")
+    private String stationName;
+}

src/main/java/com/sqx/modules/riderStation/service/RiderStationService.java

@@ -0,0 +1,15 @@
+package com.sqx.modules.riderStation.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.sqx.common.utils.Result;
+import com.sqx.modules.riderStation.controller.AdminRiderStationController;
+import com.sqx.modules.riderStation.entity.RiderStation;
+import com.sqx.modules.shop.entity.SearchHistory;
+
+public interface RiderStationService extends IService<RiderStation> {
+    Result selectStationList(Integer page, Integer size);
+
+    Result stationList();
+
+    Result getRiderStationName(Integer userId);
+}

src/main/java/com/sqx/modules/riderStation/service/impl/RiderStationServiceImpl.java

@@ -0,0 +1,52 @@
+package com.sqx.modules.riderStation.service.impl;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
+import com.baomidou.mybatisplus.extension.api.R;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.sqx.common.utils.PageUtils;
+import com.sqx.common.utils.Result;
+import com.sqx.modules.app.dao.UserDao;
+import com.sqx.modules.app.entity.UserEntity;
+import com.sqx.modules.riderStation.dao.RiderStationDao;
+import com.sqx.modules.riderStation.entity.RiderStation;
+import com.sqx.modules.riderStation.service.RiderStationService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+public class RiderStationServiceImpl extends ServiceImpl<RiderStationDao, RiderStation> implements RiderStationService {
+
+    @Autowired
+    private UserDao userDao;
+
+    @Override
+    public Result selectStationList(Integer page, Integer size) {
+        IPage<RiderStation> riderStationIPage = this.page(new Page<RiderStation>(page, size));
+        PageUtils pageUtils = new PageUtils(riderStationIPage);
+        return Result.success().put("data", pageUtils);
+    }
+
+    @Override
+    public Result stationList() {
+        List<RiderStation> list = this.list();
+        return Result.success().put("data", list);
+    }
+
+    @Override
+    public Result getRiderStationName(Integer userId) {
+        UserEntity userEntity = userDao.selectById(userId);
+        if (ObjectUtils.isEmpty(userEntity)) {
+            return Result.error("用户不存在");
+        }
+        Integer riderStationId = userEntity.getRiderStationId();
+
+        RiderStation riderStation = this.getById(riderStationId);
+
+        return Result.success().put("data",riderStation);
+    }
+
+}

src/main/resources/mapper/dataCentre/dataCenterMapper.xml

@@ -85,7 +85,7 @@
         select count(*)
         from tb_indent
         where rider_user_id = #{userId}
-          and indent_state in (2,3,4,6,11)
+          and indent_state in (2, 3, 4, 6, 11)
           and date_format(create_time, '%Y-%m') = date_format(#{date}, '%Y-%m')
     </select>
 
@@ -126,20 +126,25 @@
     </select>
 
     <select id="findAllCertification" resultType="com.sqx.modules.app.entity.UserEntity">
-        select * from tb_user where 1 = 1
+        select tu.*,rs.station_name AS stationName from tb_user tu
+        left join rider_station rs on tu.rider_station_id=rs.id
+        where 1 = 1
         <if test="phone!=null and phone!=''">
-            and phone=#{phone}
+            and tu.phone=#{phone}
         </if>
         <if test="userName!=null and userName!=''">
-            and user_name = #{userName}
+            and tu.user_name = #{userName}
         </if>
         <if test="checkCertification!=null and checkCertification!='' and checkCertification!='-1' ">
-            and check_certification = #{checkCertification}
+            and tu.check_certification = #{checkCertification}
         </if>
         <if test="checkCertification!=null or checkCertification=='-1'">
-            and check_certification in (0,1,2)
+            and tu.check_certification in (0,1,2)
         </if>
-        order by audit_time desc
+        <if test="riderStationId!=null and riderStationId!=''">
+            and tu.rider_station_id = #{riderStationId}
+        </if>
+        order by tu.audit_time desc
     </select>
 
     <update id="checkCertification">
@@ -164,12 +169,13 @@
         ( SELECT @rank_num := 0 ) r,
         ( SELECT ifnull( sum( rider_money ), 0 ) AS moneyOrder, i.rider_user_id, u.nick_name as nickName, u.avatar as
         avatar,
-        i.user_province as userProvince, i.user_city as userCity, i.user_district as userDistrict
+        i.user_province as userProvince, i.user_city as userCity, i.user_district as userDistrict,rs.station_name as stationName
         FROM tb_indent i left join tb_user u on i.rider_user_id = u.user_id
+        left join rider_station rs on u.rider_station_id=rs.id
         WHERE i.rider_user_id IS NOT NULL
         <if test="address!=null and address!=''">
-            and (i.user_province like concat('%',#{address},'%') or i.user_city like concat('%',#{address},'%') or
-            i.user_district like concat('%',#{address},'%'))
+                and (i.user_province like concat('%',#{address},'%') or i.user_city like concat('%',#{address},'%') or
+                i.user_district like concat('%',#{address},'%'))
         </if>
         <if test="dateType=='day'">
             and date_format(i.create_time,'%Y-%m-%d')=date_format(#{date},'%Y-%m-%d')
@@ -209,9 +215,10 @@
         @rank_num := @rank_num + 1 AS rankNum
         FROM
         ( SELECT @rank_num := 0 ) r,
-        ( SELECT ifnull( sum( pay_money ), 0 ) AS shopMoney, tor.shop_id , u.shop_name,gp.id as shopType,gp.shop_type_name as shopTypeName
+        ( SELECT ifnull( sum( pay_money ), 0 ) AS shopMoney, tor.shop_id , u.shop_name,gp.id as
+        shopType,gp.shop_type_name as shopTypeName
         FROM tb_order tor left join goods_shop u on tor.shop_id = u.shop_id
-        left join shop_type gp on  gp.id=u.shop_type_id
+        left join shop_type gp on gp.id=u.shop_type_id
         WHERE tor.shop_id IS NOT NULL and tor.status = 4
         <if test="query.startTime != null and query.startTime !=''">
             and tor.pay_time >= #{query.startTime}
@@ -241,9 +248,10 @@
         @rank_num := @rank_num + 1 AS Rank
         FROM
         ( SELECT @rank_num := 0 ) r,
-        ( SELECT ifnull( sum( pay_money ), 0 ) AS shopMoney, tor.shop_id , u.shop_name,gp.id as shopType,gp.shop_type_name as shopTypeName
+        ( SELECT ifnull( sum( pay_money ), 0 ) AS shopMoney, tor.shop_id , u.shop_name,gp.id as
+        shopType,gp.shop_type_name as shopTypeName
         FROM tb_order tor left join goods_shop u on tor.shop_id = u.shop_id
-        left join shop_type gp on  gp.id=u.shop_type_id
+        left join shop_type gp on gp.id=u.shop_type_id
         WHERE tor.shop_id IS NOT NULL and tor.status = 4
         <if test="query.startTime != null and query.startTime !=''">
             and tor.pay_time >= #{query.startTime}

src/main/resources/mapper/pay/CashDao.xml

@@ -273,13 +273,18 @@
             <if test="params.openBank != null and params.openBank != '' and params.openBank != 'null'">
                 and co.open_bank = #{params.openBank}
             </if>
+            <if test="params.riderStationId != null">
+                and tu.rider_station_id = #{params.riderStationId}
+            </if>
         </where>
     </sql>
 
     <select id="selectCashOutList" resultType="com.sqx.modules.pay.vo.CashOutVO">
-        select gh.shop_name, co.*
+        select gh.shop_name, co.*,rs.station_name as stationName
         from cash_out co
         left join goods_shop gh on gh.shop_id = co.shop_id
+        left join tb_user tu on tu.user_id=co.user_id
+        left join rider_station rs on tu.rider_station_id=rs.id
         <include refid="cashOutQueryCondition"></include>
         order by id desc
     </select>