From a8d2cb07f6440dc54dc4005b0b06d5a47cb1517d Mon Sep 17 00:00:00 2001 From: luodangjia <luodangjia> Date: 星期一, 16 十二月 2024 13:34:03 +0800 Subject: [PATCH] 12.16 --- ruoyi-api/ruoyi-api-other/src/main/java/com/ruoyi/other/api/feignClient/ShopClient.java | 4 ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/mapper/UserCancellationLogMapper.java | 6 ruoyi-service/ruoyi-account/src/main/resources/mapper/account/UserCancellationLogMapper.xml | 19 + ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/util/TaskUtil.java | 18 + ruoyi-api/ruoyi-api-account/src/main/java/com/ruoyi/account/api/model/UserCancellationLog.java | 5 ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/UserCancellationLogService.java | 3 ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/controller/UserChangeLogController.java | 16 + ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/controller/ShopController.java | 7 ruoyi-api/ruoyi-api-account/src/main/java/com/ruoyi/account/api/model/UserChangeLog.java | 10 ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/controller/OrderController.java | 5 ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/service/impl/VipSettingServiceImpl.java | 32 +- ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/dto/UserCancelQuery.java | 24 ++ ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/UserCancellationLogServiceImpl.java | 13 + ruoyi-api/ruoyi-api-account/src/main/java/com/ruoyi/account/api/model/AppUser.java | 17 + ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/controller/UserCancellationLogController.java | 20 + ruoyi-api/ruoyi-api-account/src/main/java/com/ruoyi/account/api/model/AgentApplication.java | 7 ruoyi-api/ruoyi-api-order/src/main/java/com/ruoyi/order/feignClient/RemoteOrderGoodsClient.java | 6 ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/dto/UserChangeQuery.java | 26 ++ ruoyi-service/ruoyi-account/src/main/resources/mapper/account/AgentApplicationMapper.xml | 19 + ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/mapper/AgentApplicationMapper.java | 6 ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/UserChangeLogServiceImpl.java | 13 + ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/AgentApplicationServiceImpl.java | 12 + ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/UserChangeLogService.java | 4 ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/controller/AgentApplicationController.java | 57 ++++ ruoyi-api/ruoyi-api-other/src/main/java/com/ruoyi/other/api/factory/ShopClientFallbackFactory.java | 7 ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/dto/AgentQuery.java | 22 + ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/VipSettingServiceImpl.java | 91 +++++++ ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/dto/DangerInfoDto.java | 42 +++ ruoyi-api/ruoyi-api-order/src/main/java/com/ruoyi/order/factory/RemoteOrderGoodsFallbackFactory.java | 5 ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/mapper/UserChangeLogMapper.java | 6 ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/AgentApplicationService.java | 3 ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/VipSettingService.java | 2 ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/controller/AppUserController.java | 135 ++++++++++ ruoyi-service/ruoyi-account/src/main/resources/mapper/account/AppUserMapper.xml | 4 ruoyi-service/ruoyi-account/src/main/resources/mapper/account/UserChangeLogMapper.xml | 19 + 35 files changed, 649 insertions(+), 36 deletions(-) diff --git a/ruoyi-api/ruoyi-api-account/src/main/java/com/ruoyi/account/api/model/AgentApplication.java b/ruoyi-api/ruoyi-api-account/src/main/java/com/ruoyi/account/api/model/AgentApplication.java index 2e4d076..3e7a9b7 100644 --- a/ruoyi-api/ruoyi-api-account/src/main/java/com/ruoyi/account/api/model/AgentApplication.java +++ b/ruoyi-api/ruoyi-api-account/src/main/java/com/ruoyi/account/api/model/AgentApplication.java @@ -80,6 +80,11 @@ @ApiModelProperty(value = "添加时间") @TableField("create_time") private LocalDateTime createTime; - + @ApiModelProperty(value = "用户姓名") + @TableField(exist = false) + private String userName; + @ApiModelProperty(value = "用户电话") + @TableField(exist = false) + private String userPhone; } diff --git a/ruoyi-api/ruoyi-api-account/src/main/java/com/ruoyi/account/api/model/AppUser.java b/ruoyi-api/ruoyi-api-account/src/main/java/com/ruoyi/account/api/model/AppUser.java index 5ef7a2b..a7914ca 100644 --- a/ruoyi-api/ruoyi-api-account/src/main/java/com/ruoyi/account/api/model/AppUser.java +++ b/ruoyi-api/ruoyi-api-account/src/main/java/com/ruoyi/account/api/model/AppUser.java @@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableLogic; import com.baomidou.mybatisplus.annotation.TableName; +import com.fasterxml.jackson.annotation.JsonFormat; import io.swagger.annotations.ApiModel; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @@ -41,6 +42,9 @@ @ApiModelProperty(value = "用户") @TableField("name") private String name; + @ApiModelProperty("会员名称") + @TableField(exist = false) + private String vipName; @ApiModelProperty(value = "手机号") @TableField("phone") @@ -68,6 +72,7 @@ @ApiModelProperty(value = "添加时间") @TableField("create_time") + @JsonFormat(pattern = "yyyy-MM-dd") private LocalDateTime createTime; @ApiModelProperty(value = "删除(0=否,1=是)") @@ -102,6 +107,9 @@ @ApiModelProperty(value = "绑定门店名称") @TableField(exist = false) private String shopName; + @ApiModelProperty(value = "绑定门店列表") + @TableField(exist = false) + private List<String> shopNames; @ApiModelProperty(value = "绑定门店封面") @TableField(exist = false) private String shopCover; @@ -247,6 +255,15 @@ @TableField(exist = false) private Set<Integer> shopIds; + @ApiModelProperty(value = "降级预警") + @TableField("is_danger") + private Integer isDanger; + + @ApiModelProperty(value = "最后下单时间") + @TableField(exist = false) + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") + private LocalDateTime lastOrderTime; + diff --git a/ruoyi-api/ruoyi-api-account/src/main/java/com/ruoyi/account/api/model/UserCancellationLog.java b/ruoyi-api/ruoyi-api-account/src/main/java/com/ruoyi/account/api/model/UserCancellationLog.java index a7871c8..e49f8d6 100644 --- a/ruoyi-api/ruoyi-api-account/src/main/java/com/ruoyi/account/api/model/UserCancellationLog.java +++ b/ruoyi-api/ruoyi-api-account/src/main/java/com/ruoyi/account/api/model/UserCancellationLog.java @@ -49,5 +49,10 @@ @TableField("vip_id") private Integer vipId; + @TableField(exist = false) + private String userName; + @TableField(exist = false) + private String userPhone; + } diff --git a/ruoyi-api/ruoyi-api-account/src/main/java/com/ruoyi/account/api/model/UserChangeLog.java b/ruoyi-api/ruoyi-api-account/src/main/java/com/ruoyi/account/api/model/UserChangeLog.java index 595e10f..7b92a8b 100644 --- a/ruoyi-api/ruoyi-api-account/src/main/java/com/ruoyi/account/api/model/UserChangeLog.java +++ b/ruoyi-api/ruoyi-api-account/src/main/java/com/ruoyi/account/api/model/UserChangeLog.java @@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableLogic; import com.baomidou.mybatisplus.annotation.TableName; +import com.fasterxml.jackson.annotation.JsonFormat; import io.swagger.annotations.ApiModel; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @@ -39,6 +40,7 @@ @ApiModelProperty(value = "添加时间") @TableField("create_time") + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") private LocalDateTime createTime; @ApiModelProperty(value = "用户id") @@ -53,9 +55,15 @@ @TableField("after_vip_id") private Integer afterVipId; - @ApiModelProperty(value = "变更类型") + @ApiModelProperty(value = "变更类型 0降级1升级") @TableField("change_type") private Integer changeType; + @ApiModelProperty("用户姓名") + @TableField(exist = false) + private String userName; + @ApiModelProperty("用户电话") + @TableField(exist = false) + private String userPhone; } diff --git a/ruoyi-api/ruoyi-api-order/src/main/java/com/ruoyi/order/factory/RemoteOrderGoodsFallbackFactory.java b/ruoyi-api/ruoyi-api-order/src/main/java/com/ruoyi/order/factory/RemoteOrderGoodsFallbackFactory.java index 213a063..5818bc6 100644 --- a/ruoyi-api/ruoyi-api-order/src/main/java/com/ruoyi/order/factory/RemoteOrderGoodsFallbackFactory.java +++ b/ruoyi-api/ruoyi-api-order/src/main/java/com/ruoyi/order/factory/RemoteOrderGoodsFallbackFactory.java @@ -52,6 +52,11 @@ public R<Price> getGoodsPrice(Long appUserId, Integer goodsId, Integer shopId) { return R.fail("获取商品价格失败"); } + + @Override + public R<Order> getLastOrder(Long appUserId) { + return R.fail("获取订单失败"); + } }; } diff --git a/ruoyi-api/ruoyi-api-order/src/main/java/com/ruoyi/order/feignClient/RemoteOrderGoodsClient.java b/ruoyi-api/ruoyi-api-order/src/main/java/com/ruoyi/order/feignClient/RemoteOrderGoodsClient.java index 8d1c522..41f8d17 100644 --- a/ruoyi-api/ruoyi-api-order/src/main/java/com/ruoyi/order/feignClient/RemoteOrderGoodsClient.java +++ b/ruoyi-api/ruoyi-api-order/src/main/java/com/ruoyi/order/feignClient/RemoteOrderGoodsClient.java @@ -31,6 +31,10 @@ @PostMapping("/order/getOrderListByIds") public R<List<Order>> getOrderListByIds(@RequestBody List<Long> orderIds); + @PostMapping("/order/byUserId") + public R<List<Order>> byUserId(@RequestParam("appUserId")Long appUserId); + + /** * 根据用户id和商品id查找订单列表 */ @@ -57,4 +61,6 @@ @GetMapping("/shopping-cart/getGoodsPrice") public R<Price> getGoodsPrice(@RequestParam("appUserId") Long appUserId, @RequestParam("goodsId") Integer goodsId, @RequestParam("shopId") Integer shopId); + @PostMapping("/order/getLastOrder") + public R<Order> getLastOrder(@RequestParam("appUserId") Long appUserId); } diff --git a/ruoyi-api/ruoyi-api-other/src/main/java/com/ruoyi/other/api/factory/ShopClientFallbackFactory.java b/ruoyi-api/ruoyi-api-other/src/main/java/com/ruoyi/other/api/factory/ShopClientFallbackFactory.java index 926794a..8319da3 100644 --- a/ruoyi-api/ruoyi-api-other/src/main/java/com/ruoyi/other/api/factory/ShopClientFallbackFactory.java +++ b/ruoyi-api/ruoyi-api-other/src/main/java/com/ruoyi/other/api/factory/ShopClientFallbackFactory.java @@ -18,7 +18,12 @@ public R<Shop> getShopById(Integer id) { return R.fail("根据id获取门店信息失败:" + cause.getMessage()); } - + + @Override + public R<List<Shop>> getShopByUserId(Long id) { + return R.fail("根据用户id集合获取门店数据失败"); + } + @Override public R<Shop> getShopByPhone(String phone) { return R.fail("根据店铺管理员电话获取门店数据失败:" + cause.getMessage()); diff --git a/ruoyi-api/ruoyi-api-other/src/main/java/com/ruoyi/other/api/feignClient/ShopClient.java b/ruoyi-api/ruoyi-api-other/src/main/java/com/ruoyi/other/api/feignClient/ShopClient.java index 2f9f937..cf409f1 100644 --- a/ruoyi-api/ruoyi-api-other/src/main/java/com/ruoyi/other/api/feignClient/ShopClient.java +++ b/ruoyi-api/ruoyi-api-other/src/main/java/com/ruoyi/other/api/feignClient/ShopClient.java @@ -29,7 +29,9 @@ */ @PostMapping("/shop/getShopById") R<Shop> getShopById(@RequestParam("id") Integer id); - + + @PostMapping("/shop/getShopByUserId") + R<List<Shop>> getShopByUserId(@RequestParam("id") Long id); /** * 根据店铺管理员电话获取门店数据 diff --git a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/controller/AgentApplicationController.java b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/controller/AgentApplicationController.java index cb7d138..dac6a7d 100644 --- a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/controller/AgentApplicationController.java +++ b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/controller/AgentApplicationController.java @@ -1,16 +1,22 @@ package com.ruoyi.account.controller; +import java.time.LocalDateTime; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.ruoyi.account.api.model.AgentApplication; +import com.ruoyi.account.api.model.AppUser; +import com.ruoyi.account.api.model.UserChangeLog; +import com.ruoyi.account.dto.AgentQuery; import com.ruoyi.account.service.AgentApplicationService; +import com.ruoyi.account.service.AppUserService; +import com.ruoyi.account.service.UserChangeLogService; import com.ruoyi.common.core.domain.R; import com.ruoyi.common.core.web.controller.BaseController; import com.ruoyi.other.api.domain.VipSetting; import io.swagger.annotations.ApiOperation; -import org.springframework.web.bind.annotation.PostMapping; -import org.springframework.web.bind.annotation.RequestBody; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RestController; +import io.swagger.annotations.ApiParam; +import org.springframework.web.bind.annotation.*; import javax.annotation.Resource; @@ -27,6 +33,8 @@ public class AgentApplicationController extends BaseController { @Resource private AgentApplicationService agentApplicationService; + @Resource + private AppUserService appUserService; @PostMapping("/apply") @ApiOperation(value = "会员申请", tags = {"会员中心-小程序"}) @@ -35,5 +43,46 @@ return R.ok(); } + @PostMapping("/page") + @ApiOperation(value = "会员申请列表", tags = {"后台"}) + public R<IPage<AgentApplication>> page(@RequestBody AgentQuery agentQuery) { + + return R.ok(agentApplicationService.pageList(agentQuery)); + } + @GetMapping("/detail") + @ApiOperation(value = "会员申请详情", tags = {"会员中心-小程序"}) + public R<AgentApplication> detail(@RequestParam Long id) { + + return R.ok(agentApplicationService.getById(id)); + } + @Resource + private UserChangeLogService userChangeLogService; + + @GetMapping("/auth") + @ApiOperation(value = "会员申请审核", tags = {"会员中心-小程序"}) + public R<AgentApplication> auth(@RequestParam Long id, @ApiParam("2'已处理-同意',3'已处理-拒绝")Integer status,@ApiParam("处理意见") String remark) { + AgentApplication byId = agentApplicationService.getById(id); + byId.setStatus(status); + byId.setRemark(remark); + agentApplicationService.updateById(byId); + AppUser byId1 = appUserService.getById(byId.getAppUserId()); + //插入等级变化数据 + UserChangeLog userChangeLog = new UserChangeLog(); + userChangeLog.setCreateTime(LocalDateTime.now()); + userChangeLog.setAppUserId(byId.getAppUserId()); + userChangeLog.setBeforeVipId(byId1.getVipId()); + userChangeLog.setAfterVipId(byId.getApplicationVipId()); + if (userChangeLog.getBeforeVipId()>userChangeLog.getAfterVipId()) { + userChangeLog.setChangeType(0); + }else { + userChangeLog.setChangeType(1); + } + userChangeLogService.save(userChangeLog); + //变更会员等级 + byId1.setVipId(byId.getApplicationVipId()); + return R.ok(byId); + } + + } diff --git a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/controller/AppUserController.java b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/controller/AppUserController.java index c6565e7..f06387c 100644 --- a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/controller/AppUserController.java +++ b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/controller/AppUserController.java @@ -2,19 +2,21 @@ import com.baomidou.mybatisplus.core.metadata.IPage; -import com.ruoyi.account.api.model.AppUser; -import com.ruoyi.account.api.model.UserCancellationLog; -import com.ruoyi.account.api.model.UserCoupon; -import com.ruoyi.account.api.model.UserSignRecord; -import com.ruoyi.account.service.AppUserService; -import com.ruoyi.account.service.UserCancellationLogService; -import com.ruoyi.account.service.UserCouponService; -import com.ruoyi.account.service.UserSignRecordService; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.ruoyi.account.api.model.*; +import com.ruoyi.account.dto.DangerInfoDto; +import com.ruoyi.account.service.*; import com.ruoyi.common.core.domain.R; +import com.ruoyi.common.core.utils.bean.BeanUtils; import com.ruoyi.common.core.web.domain.AjaxResult; import com.ruoyi.common.security.service.TokenService; +import com.ruoyi.order.feignClient.RemoteOrderGoodsClient; +import com.ruoyi.order.model.Order; import com.ruoyi.other.api.domain.Shop; +import com.ruoyi.other.api.domain.VipSetting; +import com.ruoyi.other.api.feignClient.ShopClient; import com.ruoyi.other.api.feignClient.StoreClient; +import com.ruoyi.other.api.feignClient.VipSettingClient; import io.swagger.annotations.*; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestBody; @@ -57,6 +59,12 @@ @Resource private UserSignRecordService userSignRecordService; + @Resource + private VipSettingClient vipSettingClient; + @Resource + private UserPointService userPointService; + @Resource + private VipSettingService vipSettingService; @ResponseBody @@ -354,6 +362,116 @@ return R.ok(appuserPage); } + @GetMapping("/danger/info") + @ApiOperation(value = "用户列表-保级条件详情", tags = {"管理后台"}) + public R<DangerInfoDto> dangerinfo(Long id) + { + AppUser byId = appUserService.getById(id); + LocalDate now = LocalDate.now(); + R<VipSetting> vipSetting = vipSettingClient.getVipSetting(byId.getVipId()); + VipSetting data = vipSetting.getData(); + DangerInfoDto dangerInfoDto = new DangerInfoDto(); + BeanUtils.copyProperties(data,dangerInfoDto); + List<UserPoint> list1 = userPointService.lambdaQuery().eq(UserPoint::getType,1).ge(UserPoint::getCreateTime, now.minusDays(data.getKeepBuyDay())).list(); + List<UserPoint> list2 = userPointService.lambdaQuery().eq(UserPoint::getType,2).ge(UserPoint::getCreateTime, now.minusDays(data.getKeepBuyDay())).list(); + List<UserPoint> list3 = userPointService.lambdaQuery().eq(UserPoint::getType,5).ge(UserPoint::getCreateTime, now.minusDays(data.getKeepBuyDay())).list(); + Integer userKeepBuyPoint = 0; + for (UserPoint userPoint : list1) { + userKeepBuyPoint = userPoint.getVariablePoint()+userKeepBuyPoint; + } + Integer userKeepSharePoint = 0; + for (UserPoint userPoint : list2) { + userKeepSharePoint = userPoint.getVariablePoint()+userKeepSharePoint; + } + Integer userKeepShopPoint = 0; + for (UserPoint userPoint : list3) { + userKeepShopPoint = userPoint.getVariablePoint()+userKeepShopPoint; + } + dangerInfoDto.setUserKeepBuyPoint(userKeepBuyPoint); + dangerInfoDto.setUserKeepSharePoint(userKeepSharePoint); + dangerInfoDto.setUserKeepShopPoint(userKeepShopPoint); + return R.ok(dangerInfoDto); + } + + + @GetMapping("/danger/down") + @ApiOperation(value = "用户列表-保级条件降级", tags = {"管理后台"}) + public R down(Long id) + { + AppUser byId = appUserService.getById(id); + byId.setVipId(byId.getVipId()-1); + appUserService.updateById(byId); + //执行降级标记代码 + new Thread(new Runnable() { + @Override + public void run() { + { + vipSettingService.downUsers(); + } + } + } + ).start(); + return R.ok(); + } + @GetMapping("/frozen") + @ApiOperation(value = "用户列表-冻结解冻", tags = {"管理后台"}) + public R frozen(Long id,@ApiParam("1=正常,2=冻结")Integer status) + { + AppUser byId = appUserService.getById(id); + byId.setStatus(status); + appUserService.updateById(byId); + return R.ok(); + } + @Resource + private ShopClient shopClient; + @Resource + private RemoteOrderGoodsClient remoteOrderGoodsClient; + + @GetMapping("/detail") + @ApiOperation(value = "用户列表-详情", tags = {"管理后台"}) + public R<AppUser> detail(Long id) + { + AppUser byId = appUserService.getById(id); + if (byId.getShopId()!=null) { + R<Shop> shopById = shopClient.getShopById(Integer.parseInt(String.valueOf(byId.getShopId()))); + if (shopById.getData()!=null) { + byId.setShopName(shopById.getData().getName()); + } + } + R<List<Shop>> shopByUserId = shopClient.getShopByUserId(id); + if (shopByUserId.getData()!=null) { + List<String> shopName = new ArrayList<>(); + for (Shop datum : shopByUserId.getData()) { + shopName.add(datum.getName()); + } + byId.setShopNames(shopName); + } + //推广人 + if (byId.getInviteUserId()!=null) { + AppUser byId1 = appUserService.getById(byId.getInviteUserId()); + byId1.setInviteUserName(byId1.getInviteUserName()); + } + //最后下单时间 + R<Order> lastOrder = remoteOrderGoodsClient.getLastOrder(id); + if (lastOrder.getData()!=null){ + byId.setLastOrderTime(lastOrder.getData().getCreateTime()); + } + return R.ok(byId); + } + @GetMapping("/bottom") + @ApiOperation(value = "用户列表-绑定下级列表", tags = {"管理后台"}) + public R<Page<AppUser>> bottom(Long id,Integer pageNum,Integer pageSize) + { + //绑定下级 + Page<AppUser> page = appUserService.lambdaQuery().eq(AppUser::getInviteUserId, id).page(Page.of(pageNum, pageSize)); + return R.ok(page); + + } + + + + + @GetMapping("/getAppUserByPhone") public R<AppUser> getAppUserByPhone(String phone){ @@ -363,5 +481,6 @@ + } diff --git a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/controller/UserCancellationLogController.java b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/controller/UserCancellationLogController.java index ffbcbf7..1e4b35c 100644 --- a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/controller/UserCancellationLogController.java +++ b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/controller/UserCancellationLogController.java @@ -1,8 +1,20 @@ package com.ruoyi.account.controller; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.ruoyi.account.api.model.AgentApplication; +import com.ruoyi.account.api.model.UserCancellationLog; +import com.ruoyi.account.dto.AgentQuery; +import com.ruoyi.account.dto.UserCancelQuery; +import com.ruoyi.account.service.UserCancellationLogService; +import com.ruoyi.common.core.domain.R; +import io.swagger.annotations.ApiOperation; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; + +import javax.annotation.Resource; /** * <p> @@ -15,6 +27,14 @@ @RestController @RequestMapping("/user-cancellation-log") public class UserCancellationLogController { + @Resource + private UserCancellationLogService cancellationLogService; + @PostMapping("/page") + @ApiOperation(value = "注销记录列表", tags = {"后台"}) + public R<IPage<UserCancellationLog>> page(@RequestBody UserCancelQuery agentQuery) { + + return R.ok(cancellationLogService.pageList(agentQuery)); + } } diff --git a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/controller/UserChangeLogController.java b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/controller/UserChangeLogController.java index 3cd25ba..140f7d6 100644 --- a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/controller/UserChangeLogController.java +++ b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/controller/UserChangeLogController.java @@ -1,7 +1,10 @@ package com.ruoyi.account.controller; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.ruoyi.account.api.model.AgentApplication; import com.ruoyi.account.api.model.UserChangeLog; +import com.ruoyi.account.dto.UserChangeQuery; import com.ruoyi.account.service.UserChangeLogService; import com.ruoyi.common.core.domain.R; import org.springframework.web.bind.annotation.PostMapping; @@ -37,9 +40,16 @@ userChangeLogService.save(userChangeLog); return R.ok(); } - - - + + @PostMapping("/page") + public R<IPage<UserChangeLog>> page(@RequestBody UserChangeQuery userChangeLog){ + + return R.ok(userChangeLogService.pageList(userChangeLog)); + } + + + + } diff --git a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/dto/AgentQuery.java b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/dto/AgentQuery.java new file mode 100644 index 0000000..879972c --- /dev/null +++ b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/dto/AgentQuery.java @@ -0,0 +1,22 @@ +package com.ruoyi.account.dto; + +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +@Data +public class AgentQuery { + @ApiModelProperty("用户名称") + private String name; + + @ApiModelProperty("电话") + private String phone; + + @ApiModelProperty("会员等级") + private Integer vipId; + + @ApiModelProperty("1'待处理',2'已处理-同意',3'已处理-拒绝'") + private Integer status; + private Integer pageNum; + private Integer pageSize; + +} diff --git a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/dto/DangerInfoDto.java b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/dto/DangerInfoDto.java new file mode 100644 index 0000000..155bec4 --- /dev/null +++ b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/dto/DangerInfoDto.java @@ -0,0 +1,42 @@ +package com.ruoyi.account.dto; + +import com.baomidou.mybatisplus.annotation.TableField; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +@Data +public class DangerInfoDto { + @ApiModelProperty(value = "消费积分保级周期(天)") + @TableField("keep_buy_day") + private Integer keepBuyDay; + + @ApiModelProperty(value = "消费积分保级的积分阈值(分))") + @TableField("keep_buy_point") + private Integer keepBuyPoint; + + @ApiModelProperty(value = "当前消费积分") + private Integer userKeepBuyPoint; + + @ApiModelProperty(value = "返佣积分保的周期(天)") + @TableField("keep_share_day") + private Integer keepShareDay; + + @ApiModelProperty(value = "返佣积分保级的积分阈值(分)") + @TableField("keep_share_point") + private Integer keepSharePoint; + + @ApiModelProperty(value = "当前返佣积分") + @TableField("keep_share_point") + private Integer userKeepSharePoint; + + @ApiModelProperty(value = "门店业绩积分保级的周期(天)") + @TableField("keep_shop_day") + private Integer keepShopDay; + + @ApiModelProperty(value = "门店业绩积分保级的积分阈值(分)") + @TableField("keep_shop_point") + private Integer keepShopPoint; + + @ApiModelProperty(value = "当前门店业绩积分") + private Integer userKeepShopPoint; +} diff --git a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/dto/UserCancelQuery.java b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/dto/UserCancelQuery.java new file mode 100644 index 0000000..aed5fb8 --- /dev/null +++ b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/dto/UserCancelQuery.java @@ -0,0 +1,24 @@ +package com.ruoyi.account.dto; + +import com.baomidou.mybatisplus.annotation.TableField; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +import java.time.LocalDate; + +@Data +public class UserCancelQuery { + @ApiModelProperty("用户名称") + private String name; + + @ApiModelProperty("电话") + private String phone; + + private Integer vipId; + + private LocalDate localDate1; + private LocalDate localDate2; + private Integer pageNum; + private Integer pageSize; + +} diff --git a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/dto/UserChangeQuery.java b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/dto/UserChangeQuery.java new file mode 100644 index 0000000..b828314 --- /dev/null +++ b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/dto/UserChangeQuery.java @@ -0,0 +1,26 @@ +package com.ruoyi.account.dto; + +import com.baomidou.mybatisplus.annotation.TableField; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +import java.time.LocalDate; + +@Data +public class UserChangeQuery { + @ApiModelProperty("用户名称") + private String name; + + @ApiModelProperty("电话") + private String phone; + + @ApiModelProperty(value = "变更类型 0降级1升级") + @TableField("change_type") + private Integer changeType; + + private LocalDate localDate1; + private LocalDate localDate2; + private Integer pageNum; + private Integer pageSize; + +} diff --git a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/mapper/AgentApplicationMapper.java b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/mapper/AgentApplicationMapper.java index 780fa4e..453f066 100644 --- a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/mapper/AgentApplicationMapper.java +++ b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/mapper/AgentApplicationMapper.java @@ -1,7 +1,12 @@ package com.ruoyi.account.mapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.ruoyi.account.api.model.AgentApplication; +import com.ruoyi.account.dto.AgentQuery; +import com.ruoyi.other.api.domain.Shop; +import org.apache.ibatis.annotations.Param; /** * <p> @@ -13,4 +18,5 @@ */ public interface AgentApplicationMapper extends BaseMapper<AgentApplication> { + IPage<AgentApplication> pageList(@Param("page") Page<Shop> page, @Param("agentQuery") AgentQuery agentQuery); } diff --git a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/mapper/UserCancellationLogMapper.java b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/mapper/UserCancellationLogMapper.java index c19aedc..8fef49e 100644 --- a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/mapper/UserCancellationLogMapper.java +++ b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/mapper/UserCancellationLogMapper.java @@ -1,7 +1,12 @@ package com.ruoyi.account.mapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.ruoyi.account.api.model.UserCancellationLog; +import com.ruoyi.account.dto.UserCancelQuery; +import com.ruoyi.other.api.domain.Shop; +import org.apache.ibatis.annotations.Param; /** * <p> @@ -13,4 +18,5 @@ */ public interface UserCancellationLogMapper extends BaseMapper<UserCancellationLog> { + IPage<UserCancellationLog> pageList(@Param("page")Page<Shop> page, @Param("agentQuery")UserCancelQuery agentQuery); } diff --git a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/mapper/UserChangeLogMapper.java b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/mapper/UserChangeLogMapper.java index 536d2c1..adb5d07 100644 --- a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/mapper/UserChangeLogMapper.java +++ b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/mapper/UserChangeLogMapper.java @@ -1,7 +1,11 @@ package com.ruoyi.account.mapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.ruoyi.account.api.model.UserChangeLog; +import com.ruoyi.account.dto.UserChangeQuery; +import org.apache.ibatis.annotations.Param; /** * <p> @@ -12,5 +16,5 @@ * @since 2024-11-21 */ public interface UserChangeLogMapper extends BaseMapper<UserChangeLog> { - + IPage<UserChangeLog> pageList(@Param("page")Page<UserChangeLog> page, @Param("userChangeLog")UserChangeQuery userChangeLog); } diff --git a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/AgentApplicationService.java b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/AgentApplicationService.java index 61b9a36..0c33822 100644 --- a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/AgentApplicationService.java +++ b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/AgentApplicationService.java @@ -1,7 +1,9 @@ package com.ruoyi.account.service; +import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.service.IService; import com.ruoyi.account.api.model.AgentApplication; +import com.ruoyi.account.dto.AgentQuery; /** * <p> @@ -15,4 +17,5 @@ void apply(AgentApplication agentApplication); + IPage<AgentApplication> pageList(AgentQuery agentQuery); } diff --git a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/UserCancellationLogService.java b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/UserCancellationLogService.java index 20045b8..9ce39bb 100644 --- a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/UserCancellationLogService.java +++ b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/UserCancellationLogService.java @@ -1,7 +1,9 @@ package com.ruoyi.account.service; +import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.service.IService; import com.ruoyi.account.api.model.UserCancellationLog; +import com.ruoyi.account.dto.UserCancelQuery; /** * <p> @@ -13,4 +15,5 @@ */ public interface UserCancellationLogService extends IService<UserCancellationLog> { + IPage<UserCancellationLog> pageList(UserCancelQuery agentQuery); } diff --git a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/UserChangeLogService.java b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/UserChangeLogService.java index 9eeec5a..eb4c795 100644 --- a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/UserChangeLogService.java +++ b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/UserChangeLogService.java @@ -1,7 +1,10 @@ package com.ruoyi.account.service; +import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.service.IService; +import com.ruoyi.account.api.model.AgentApplication; import com.ruoyi.account.api.model.UserChangeLog; +import com.ruoyi.account.dto.UserChangeQuery; /** * <p> @@ -13,4 +16,5 @@ */ public interface UserChangeLogService extends IService<UserChangeLog> { + IPage<UserChangeLog> pageList(UserChangeQuery userChangeLog); } diff --git a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/VipSettingService.java b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/VipSettingService.java index cd40400..d6831ce 100644 --- a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/VipSettingService.java +++ b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/VipSettingService.java @@ -7,4 +7,6 @@ VipSetting getVipSettingById(Integer id); VipSetting getVipSettingByUserId(Long appUserId); + + void downUsers(); } diff --git a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/AgentApplicationServiceImpl.java b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/AgentApplicationServiceImpl.java index aefe7ea..bb93baa 100644 --- a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/AgentApplicationServiceImpl.java +++ b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/AgentApplicationServiceImpl.java @@ -1,9 +1,12 @@ package com.ruoyi.account.service.impl; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.ruoyi.account.api.model.AgentApplication; import com.ruoyi.account.api.model.AppUser; +import com.ruoyi.account.dto.AgentQuery; import com.ruoyi.account.mapper.AgentApplicationMapper; import com.ruoyi.account.service.AgentApplicationService; import com.ruoyi.account.service.AppUserService; @@ -68,4 +71,13 @@ agentApplication.setBindShopNum(shopList.size()); agentApplicationMapper.insert(agentApplication); } + + @Override + public IPage<AgentApplication> pageList(AgentQuery agentQuery) { + Page<Shop> page = new Page<>(); + page.setCurrent(agentQuery.getPageNum()); + page.setSize(agentQuery.getPageSize()); + IPage<AgentApplication> shopIPage = agentApplicationMapper.pageList(page, agentQuery); + return shopIPage; + } } diff --git a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/UserCancellationLogServiceImpl.java b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/UserCancellationLogServiceImpl.java index 3c163fb..42e5dff 100644 --- a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/UserCancellationLogServiceImpl.java +++ b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/UserCancellationLogServiceImpl.java @@ -1,9 +1,14 @@ package com.ruoyi.account.service.impl; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.ruoyi.account.api.model.AgentApplication; +import com.ruoyi.account.dto.UserCancelQuery; import com.ruoyi.account.mapper.UserCancellationLogMapper; import com.ruoyi.account.api.model.UserCancellationLog; import com.ruoyi.account.service.UserCancellationLogService; +import com.ruoyi.other.api.domain.Shop; import org.springframework.stereotype.Service; /** @@ -17,4 +22,12 @@ @Service public class UserCancellationLogServiceImpl extends ServiceImpl<UserCancellationLogMapper, UserCancellationLog> implements UserCancellationLogService { + @Override + public IPage<UserCancellationLog> pageList(UserCancelQuery agentQuery) { + Page<Shop> page = new Page<>(); + page.setCurrent(agentQuery.getPageNum()); + page.setSize(agentQuery.getPageSize()); + IPage<UserCancellationLog> shopIPage = this.baseMapper.pageList(page, agentQuery); + return shopIPage; + } } diff --git a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/UserChangeLogServiceImpl.java b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/UserChangeLogServiceImpl.java index c0b4c02..f44bd64 100644 --- a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/UserChangeLogServiceImpl.java +++ b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/UserChangeLogServiceImpl.java @@ -1,9 +1,14 @@ package com.ruoyi.account.service.impl; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.ruoyi.account.api.model.AgentApplication; +import com.ruoyi.account.dto.UserChangeQuery; import com.ruoyi.account.mapper.UserChangeLogMapper; import com.ruoyi.account.api.model.UserChangeLog; import com.ruoyi.account.service.UserChangeLogService; +import com.ruoyi.other.api.domain.Shop; import org.springframework.stereotype.Service; /** @@ -17,4 +22,12 @@ @Service public class UserChangeLogServiceImpl extends ServiceImpl<UserChangeLogMapper, UserChangeLog> implements UserChangeLogService { + @Override + public IPage<UserChangeLog> pageList(UserChangeQuery userChangeLog) { + Page<UserChangeLog> page = new Page<>(); + page.setCurrent(userChangeLog.getPageNum()); + page.setSize(userChangeLog.getPageSize()); + IPage<UserChangeLog> shopIPage = this.baseMapper.pageList(page, userChangeLog); + return shopIPage; + } } diff --git a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/VipSettingServiceImpl.java b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/VipSettingServiceImpl.java index c770692..cd509c3 100644 --- a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/VipSettingServiceImpl.java +++ b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/VipSettingServiceImpl.java @@ -2,14 +2,22 @@ import com.ruoyi.account.api.feignClient.AppUserClient; import com.ruoyi.account.api.model.AppUser; +import com.ruoyi.account.api.model.UserPoint; +import com.ruoyi.account.service.AppUserService; +import com.ruoyi.account.service.UserPointService; import com.ruoyi.account.service.VipSettingService; import com.ruoyi.common.core.domain.R; import com.ruoyi.common.core.exception.ServiceException; import com.ruoyi.other.api.domain.VipSetting; import com.ruoyi.other.api.feignClient.RemoteVipSettingClient; +import com.ruoyi.other.api.feignClient.VipSettingClient; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import javax.annotation.Resource; +import java.time.LocalDate; +import java.util.ArrayList; +import java.util.List; @Service public class VipSettingServiceImpl implements VipSettingService { @@ -18,6 +26,14 @@ private RemoteVipSettingClient remoteVipSettingClient; @Resource private AppUserClient appUserClient; + @Resource + private AppUserService appUserService; + @Resource + private VipSettingClient vipSettingClient; + @Resource + private UserPointService userPointService; + @Autowired + private PointSettingServiceImpl pointSettingServiceImpl; @Override @@ -37,4 +53,79 @@ } return getVipSettingById(appUser.getVipId()); } + + @Override + public void downUsers() { + //查出可能需要降级的人员 + List<Integer> vipIds = new ArrayList<>(); + vipIds.add(5); + vipIds.add(6); + vipIds.add(7); + List<AppUser> list = appUserService.lambdaQuery().in(AppUser::getVipId, vipIds).list(); + VipSetting vipSetting5 = vipSettingClient.getVipSetting(5).getData(); + VipSetting vipSetting6 = vipSettingClient.getVipSetting(6).getData(); + VipSetting vipSetting7 = vipSettingClient.getVipSetting(7).getData(); + LocalDate now = LocalDate.now(); + //循环判断是否要展示 + if (list.size()>0){ + for (AppUser appUser : list){ + boolean danger = false; + if (appUser.getVipId()==5){ + extracted(vipSetting5, now,danger); + } + if (appUser.getVipId()==6){ + extracted(vipSetting6, now,danger); + } + if (appUser.getVipId()==7){ + extracted(vipSetting7, now,danger); + } + if (danger){ + appUser.setIsDanger(1); + }else { + appUser.setIsDanger(0); + } + } + appUserService.updateBatchById(list); + } + } + + private void extracted(VipSetting vipSetting5, LocalDate now,boolean danger) { + + if (vipSetting5.getKeepBuyPoint()!=null){ + //如果消费不为空,查找对应天数的消费积分 + List<UserPoint> list1 = userPointService.lambdaQuery().eq(UserPoint::getType,1).ge(UserPoint::getCreateTime, now.minusDays(vipSetting5.getKeepBuyDay())).list(); + //如果消费积分小于保级积分,设置用户降级标志并将降级信息 + Integer point = 0; + for (UserPoint userPoint : list1) { + point = point+userPoint.getVariablePoint(); + } + if (point<= vipSetting5.getKeepBuyPoint()){ + danger = true; + } + } + if (vipSetting5.getKeepSharePoint()!=null){ + //如果消费不为空,查找对应天数的消费积分 + List<UserPoint> list1 = userPointService.lambdaQuery().eq(UserPoint::getType,2).ge(UserPoint::getCreateTime, now.minusDays(vipSetting5.getKeepBuyDay())).list(); + //如果消费积分小于保级积分,设置用户降级标志并将降级信息 + Integer point = 0; + for (UserPoint userPoint : list1) { + point = point+userPoint.getVariablePoint(); + } + if (point<= vipSetting5.getKeepBuyPoint()){ + danger = true; + } + } + if (vipSetting5.getKeepShopPoint()!=null){ + //如果消费不为空,查找对应天数的消费积分 + List<UserPoint> list1 = userPointService.lambdaQuery().eq(UserPoint::getType,5).ge(UserPoint::getCreateTime, now.minusDays(vipSetting5.getKeepBuyDay())).list(); + //如果消费积分小于保级积分,设置用户降级标志并将降级信息 + Integer point = 0; + for (UserPoint userPoint : list1) { + point = point+userPoint.getVariablePoint(); + } + if (point<= vipSetting5.getKeepBuyPoint()){ + danger = true; + } + } + } } diff --git a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/util/TaskUtil.java b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/util/TaskUtil.java index b57e53f..dfa513e 100644 --- a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/util/TaskUtil.java +++ b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/util/TaskUtil.java @@ -2,6 +2,7 @@ import com.ruoyi.account.service.AppUserService; +import com.ruoyi.account.service.VipSettingService; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; @@ -16,6 +17,8 @@ @Resource private AppUserService appUserService; + @Resource + private VipSettingService vipSettingService; @@ -29,5 +32,20 @@ appUserService.unbindThePromoter(); } + /** + * 每天的凌晨执行的任务 + */ + @Scheduled(cron = "0 0 0 * * *") + public void taskDay(){ + try { + + + vipSettingService.downUsers(); + }catch (Exception e){ + e.printStackTrace(); + } + } + + } diff --git a/ruoyi-service/ruoyi-account/src/main/resources/mapper/account/AgentApplicationMapper.xml b/ruoyi-service/ruoyi-account/src/main/resources/mapper/account/AgentApplicationMapper.xml index 6be8b7e..e4b75ad 100644 --- a/ruoyi-service/ruoyi-account/src/main/resources/mapper/account/AgentApplicationMapper.xml +++ b/ruoyi-service/ruoyi-account/src/main/resources/mapper/account/AgentApplicationMapper.xml @@ -23,5 +23,24 @@ <sql id="Base_Column_List"> id, app_user_id, application_vip_id, application_time, status, shop_point, share_point, direct_vip_num, direct_agent_num, bind_shop_num, remark, del_flag, create_time </sql> + <select id="pageList" resultType="com.ruoyi.account.api.model.AgentApplication"> + select t1.*,t2.name as userName,t2.phone as userPhone + from t_agent_application t1 + left join t_app_user t2 on t1.app_user_id = t2.id + <where> + <if test="agentQuery.name !=null and agentQuery.name !=''"> + and t2.name like concat('%',#{agentQuery.name},'%') + </if> + <if test="agentQuery.phone !=null and agentQuery.phone !=''"> + and t2.phone like concat('%',#{agentQuery.phone},'%') + </if> + <if test="agentQuery.vipId !=null"> + and t1.applicationVipId = #{agentQuery.vipId} + </if> + <if test="agentQuery.status !=null"> + and t1.status = #{agentQuery.status} + </if> + </where> + </select> </mapper> diff --git a/ruoyi-service/ruoyi-account/src/main/resources/mapper/account/AppUserMapper.xml b/ruoyi-service/ruoyi-account/src/main/resources/mapper/account/AppUserMapper.xml index 6919c53..2e68559 100644 --- a/ruoyi-service/ruoyi-account/src/main/resources/mapper/account/AppUserMapper.xml +++ b/ruoyi-service/ruoyi-account/src/main/resources/mapper/account/AppUserMapper.xml @@ -63,6 +63,9 @@ <if test="null != appUser.phone and '' != appUser.phone"> and ta.phone like CONCAT('%',#{appUser.phone},'%') </if> + <if test="null != appUser.status"> + and ta.status = #{appUser.status} + </if> <if test="null != appUser.vipId"> and ta.vip_id = #{appUser.vipId} </if> @@ -73,6 +76,7 @@ </foreach> </if> </where> + order by ta.is_danger desc </select> </mapper> diff --git a/ruoyi-service/ruoyi-account/src/main/resources/mapper/account/UserCancellationLogMapper.xml b/ruoyi-service/ruoyi-account/src/main/resources/mapper/account/UserCancellationLogMapper.xml index a4902f5..9f83d27 100644 --- a/ruoyi-service/ruoyi-account/src/main/resources/mapper/account/UserCancellationLogMapper.xml +++ b/ruoyi-service/ruoyi-account/src/main/resources/mapper/account/UserCancellationLogMapper.xml @@ -15,5 +15,24 @@ <sql id="Base_Column_List"> id, del_flag, create_time, app_user_id, vip_id </sql> + <select id="pageList" resultType="com.ruoyi.account.api.model.UserCancellationLog"> + select t1.*,t2.name as userName,t2.phone as userPhone + from t_user_cancellation_log t1 + left join t_app_user t2 on t1.app_user_id = t2.id + <where> + <if test="agentQuery.name != null and agentQuery.name != ''"> + and t2.name like concat('%',#{agentQuery.name},'%') + </if> + <if test="agentQuery.phone != null and agentQuery.phone != ''"> + and t2.phone like concat('%',#{agentQuery.phone},'%') + </if> + <if test="agentQuery.vipId != null"> + and t1.vip_id = #{agentQuery.vipId} + </if> + <if test="agentQuery.localDate1 != null"> + and DATE(t1.create_time) between #{agentQuery.localDate1} and #{agentQuery.localDate2} + </if> + </where> + </select> </mapper> diff --git a/ruoyi-service/ruoyi-account/src/main/resources/mapper/account/UserChangeLogMapper.xml b/ruoyi-service/ruoyi-account/src/main/resources/mapper/account/UserChangeLogMapper.xml index 69ed8f7..a3e0623 100644 --- a/ruoyi-service/ruoyi-account/src/main/resources/mapper/account/UserChangeLogMapper.xml +++ b/ruoyi-service/ruoyi-account/src/main/resources/mapper/account/UserChangeLogMapper.xml @@ -17,5 +17,24 @@ <sql id="Base_Column_List"> id, del_flag, create_time, app_user_id, before_vip_id, after_vip_id, change_type </sql> + <select id="pageList" resultType="com.ruoyi.account.api.model.UserChangeLog"> + SELECT t1.*,t2.`name` as userName,t2.phone as userPhone + from t_user_change_log t1 + LEFT JOIN t_app_user t2 on t1.app_user_id = t2.id + <where> + <if test="userChangeLog.name !=null and userChangeLog.name !=''"> + and t2.name like concat('%',#{userChangeLog.name},'%') + </if> + <if test="userChangeLog.phone !=null and userChangeLog.phone !=''"> + and t2.phone like concat('%',#{userChangeLog.phone},'%') + </if> + <if test="userChangeLog.changeType !=null"> + and t1.change_type = #{userChangeLog.phone.changeType} + </if> + <if test="userChangeLog.localDate1 !=null"> + and DATE(t1.create_time) between #{userChangeLog.localDate1} and #{userChangeLog.localDate2} + </if> + </where> + </select> </mapper> diff --git a/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/controller/OrderController.java b/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/controller/OrderController.java index ae6f9d3..05397e6 100644 --- a/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/controller/OrderController.java +++ b/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/controller/OrderController.java @@ -206,6 +206,11 @@ return R.ok(); } + @PostMapping("/getLastOrder") + public R<Order> getLastOrder(@RequestParam("appUserId") Long appUserId){ + Order one = orderService.lambdaQuery().eq(Order::getAppUserId, appUserId).orderByDesc(Order::getCreateTime).last("limit 1").one(); + return R.ok(one); + } } diff --git a/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/controller/ShopController.java b/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/controller/ShopController.java index d7a5156..60c9d7f 100644 --- a/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/controller/ShopController.java +++ b/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/controller/ShopController.java @@ -203,6 +203,13 @@ Shop shop = shopService.getById(id); return R.ok(shop); } + + @ResponseBody + @PostMapping("/getShopByUserId") + public R<List<Shop>> getShopByUserId(@RequestParam("id") Integer id){ + List<Shop> list = shopService.lambdaQuery().eq(Shop::getAppUserId, id).list(); + return R.ok(list); + } /** diff --git a/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/service/impl/VipSettingServiceImpl.java b/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/service/impl/VipSettingServiceImpl.java index dd8c839..99b5c83 100644 --- a/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/service/impl/VipSettingServiceImpl.java +++ b/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/service/impl/VipSettingServiceImpl.java @@ -37,22 +37,22 @@ @Override public void downUsers() { - //查出可能需要降级的人员 - R<List<AppUser>> topUsers = appUserClient.getTopUsers(); - //循环判断是否要展示 - if (topUsers.getData()!=null && topUsers.getData().size()>0){ - for (AppUser appUser : topUsers.getData()){ - if (appUser.getVipId()==5){ - VipSetting vipSetting = this.baseMapper.selectById(5); - if (vipSetting.getKeepBuyPoint()!=null){ - //如果消费不为空,查找对应天数的消费积分 - - //如果消费积分小于保级积分,设置用户降级标志并将降级信息 - } - - } - } - } +// //查出可能需要降级的人员 +// R<List<AppUser>> topUsers = appUserClient.getTopUsers(); +// //循环判断是否要展示 +// if (topUsers.getData()!=null && topUsers.getData().size()>0){ +// for (AppUser appUser : topUsers.getData()){ +// if (appUser.getVipId()==5){ +// VipSetting vipSetting = this.baseMapper.selectById(5); +// if (vipSetting.getKeepBuyPoint()!=null){ +// //如果消费不为空,查找对应天数的消费积分 +// +// //如果消费积分小于保级积分,设置用户降级标志并将降级信息 +// } +// +// } +// } +// } //然后设置降级提示 -- Gitblit v1.7.1