package com.ruoyi.account.controller;
|
|
import cn.hutool.core.date.DateTime;
|
import cn.hutool.core.date.DateUtil;
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.ruoyi.account.api.dto.*;
|
import com.ruoyi.account.api.model.*;
|
import com.ruoyi.account.service.*;
|
import com.ruoyi.account.util.*;
|
import com.ruoyi.account.util.carBrand.CarBrandUtil;
|
import com.ruoyi.account.wx.model.WeixinProperties;
|
import com.ruoyi.common.core.constant.Constants;
|
import com.ruoyi.common.core.constant.MsgConstants;
|
import com.ruoyi.common.core.domain.R;
|
import com.ruoyi.common.core.dto.PointChangeDto;
|
import com.ruoyi.common.core.enums.status.AppUserStatusEnum;
|
import com.ruoyi.common.core.utils.*;
|
import com.ruoyi.common.core.utils.bean.BeanUtils;
|
import com.ruoyi.common.core.web.domain.AjaxResult;
|
import com.ruoyi.common.core.web.domain.BasePojo;
|
import com.ruoyi.common.core.web.page.BasePage;
|
import com.ruoyi.common.log.annotation.Log;
|
import com.ruoyi.common.log.enums.BusinessType;
|
import com.ruoyi.common.log.enums.OperatorType;
|
import com.ruoyi.common.redis.service.RedisService;
|
import com.ruoyi.common.security.annotation.Logical;
|
import com.ruoyi.common.security.annotation.RequiresPermissions;
|
import com.ruoyi.common.security.auth.AuthUtil;
|
import com.ruoyi.common.security.service.TokenService;
|
import com.ruoyi.common.security.utils.SecurityUtils;
|
import com.ruoyi.order.api.feignClient.ChargingOrderClient;
|
import com.ruoyi.order.api.feignClient.ExchangeOrderClient;
|
import com.ruoyi.order.api.feignClient.OrderClient;
|
import com.ruoyi.order.api.model.TChargingOrder;
|
import com.ruoyi.order.api.model.TExchangeOrder;
|
import com.ruoyi.order.api.model.TGrantVip;
|
import com.ruoyi.other.api.domain.*;
|
import com.ruoyi.other.api.domain.TCoupon;
|
import com.ruoyi.other.api.domain.TVip;
|
import com.ruoyi.other.api.dto.UnitListQueryDto;
|
import com.ruoyi.other.api.feignClient.IntegralRuleClient;
|
import com.ruoyi.other.api.feignClient.OtherClient;
|
import com.ruoyi.other.api.feignClient.VipClient;
|
import com.ruoyi.system.api.model.LoginUser;
|
import com.ruoyi.system.api.model.LoginUserApplet;
|
import io.swagger.annotations.ApiOperation;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.compress.utils.IOUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.data.redis.core.RedisTemplate;
|
import org.springframework.validation.annotation.Validated;
|
import org.springframework.web.bind.annotation.*;
|
import org.springframework.web.client.RestTemplate;
|
|
import javax.activation.DataHandler;
|
import javax.activation.FileDataSource;
|
import javax.annotation.Resource;
|
import javax.mail.*;
|
import javax.mail.internet.*;
|
import javax.servlet.http.HttpServletRequest;
|
import java.io.File;
|
import java.io.FileOutputStream;
|
import java.io.InputStream;
|
import java.io.UnsupportedEncodingException;
|
import java.math.BigDecimal;
|
import java.net.URL;
|
import java.time.Duration;
|
import java.time.LocalDate;
|
import java.time.LocalDateTime;
|
import java.util.*;
|
import java.util.concurrent.TimeUnit;
|
import java.util.stream.Collectors;
|
|
/**
|
* <p>
|
* 前端控制器
|
* </p>
|
*
|
* @author luodangjia
|
* @since 2024-08-06
|
*/
|
@Slf4j
|
@RestController
|
@RequestMapping("/t-app-user")
|
public class TAppUserController {
|
|
@Resource
|
private OtherClient otherClient;
|
@Resource
|
private TAppUserService appUserService;
|
@Resource
|
private TAppUserTagService appUserTagService;
|
@Resource
|
private OrderClient orderClient;
|
@Resource
|
private TAppUserVipDetailService tAppUserVipDetailService;
|
@Resource
|
private ChargingOrderClient chargingOrderClient;
|
|
@Resource
|
private TAppUserCarService appUserCarService;
|
|
@Resource
|
private TAppUserIntegralChangeService integralChangeService;
|
@Resource
|
private SignDayUtil signDayUtil;
|
|
@Resource
|
private ExchangeOrderClient exchangeOrderClient;
|
@Autowired
|
private TokenService tokenService;
|
@Autowired
|
private RedisService redisService;
|
@Autowired
|
private WeixinProperties wxConfig;
|
@Autowired
|
private RestTemplate wxRestTemplate;
|
@Resource
|
private PointDetailUtil pointDetailUtil;
|
|
@Resource
|
private TAppUserSignService signService;
|
@Resource
|
private TAppCouponService appCouponService;
|
@Resource
|
private TAppUserCarService carService;
|
@Resource
|
private IntegralRuleClient integralRuleClient;
|
|
@Resource
|
private RedisTemplate redisTemplate;
|
|
|
@Resource
|
private VipClient vipClient;
|
@Resource
|
private TInviteUserService inviteUserService;
|
@Resource
|
private GiveVipUtil giveVipUtil;
|
|
/**
|
* 远程调用 发送邮件
|
* @return
|
*/
|
@PostMapping(value = "/uploadPdf")
|
public R uploadPdf(@RequestBody UploadPdfDTO dto) {
|
// 发送邮箱
|
// 收件人电子邮箱,TODO 换成自己的收件箱
|
String to = dto.getMailBox();
|
// 发件人电子邮箱,TODO 换成自己的发件箱
|
String from = "13281306557@163.com";
|
// 指定发送邮件的主机为
|
String host = "smtp.163.com";
|
Properties properties = new Properties();
|
properties.put("mail.smtp.host", host);
|
properties.put("mail.smtp.socketFactory.port", "465");
|
properties.put("mail.smtp.socketFactory.class", "javax.net.ssl.SSLSocketFactory");
|
properties.put("mail.smtp.auth", "true");
|
properties.put("mail.smtp.port", "465");
|
properties.put("mail.smtp.ssl.enable", "true"); // 明确开启SSL
|
// 获取默认session对象
|
Session session = Session.getDefaultInstance(properties,new Authenticator(){
|
@Override
|
public javax.mail.PasswordAuthentication getPasswordAuthentication()
|
{
|
//发件人邮件用户名、授权码，换成自己的发件箱及授权码
|
return new PasswordAuthentication(from, "NUSdxDQqadYvVek2");
|
}
|
});
|
|
try{
|
// 创建默认的 MimeMessage 对象
|
MimeMessage message = new MimeMessage(session);
|
// Set From，设置发件人
|
InternetAddress fromMail = new InternetAddress(from);
|
//设置发件人名称，TODO 换成自己的发件箱
|
fromMail.setPersonal(MimeUtility.encodeText("明星新能源科技有限公司<" + from + ">"));
|
message.setFrom(fromMail);
|
// Set To: 设置收件人
|
InternetAddress toMail = new InternetAddress(to);
|
// TODO 换成自己的收件箱
|
InternetAddress toMail2 = new InternetAddress(to);
|
//发多个邮箱
|
Address[] allRecipients = {toMail, toMail2};
|
message.setRecipients(Message.RecipientType.TO, allRecipients);
|
// Set Subject: 邮件主体
|
message.setSubject("明星电力");
|
// 设置消息体
|
message.setSentDate(new Date());
|
javax.mail.internet.MimeMultipart msgMultipart = new MimeMultipart("mixed");
|
|
// 指定为混合关系
|
message.setContent(msgMultipart);
|
// 邮件信息组装
|
//组装的顺序非常重要，一定要先组装文本域，再组装文件
|
javax.mail.internet.MimeBodyPart htmlPart = new javax.mail.internet.MimeBodyPart();
|
// 组装内容
|
htmlPart.setContent("开票", "text/html;charset=UTF-8");
|
msgMultipart.addBodyPart(htmlPart);
|
|
// 组装附件
|
javax.mail.internet.MimeBodyPart filePart = new MimeBodyPart();
|
String imageUrl = dto.getInvoiceUrl();
|
try {
|
// 下载数据
|
URL url = new URL(imageUrl);
|
InputStream inputStream = url.openStream();
|
byte[] imageBytes = IOUtils.toByteArray(inputStream);
|
|
// 创建临时文件
|
// 截取imageUrl后缀名
|
String fileExtension = imageUrl.substring(imageUrl.lastIndexOf("."));
|
File tempFile = File.createTempFile("tempImage", fileExtension);
|
try (FileOutputStream fos = new FileOutputStream(tempFile)) {
|
fos.write(imageBytes);
|
}
|
|
// 创建 FileDataSource
|
FileDataSource fileDataSource = new FileDataSource(tempFile);
|
System.out.println("FileDataSource created: " + fileDataSource.getName());
|
// 如果需要，可以使用 DataHandler 进行进一步处理
|
DataHandler dh = new DataHandler(fileDataSource);
|
// 清理：删除临时文件（如果不再需要）
|
tempFile.deleteOnExit(); // 可根据需要保留或删除
|
filePart.setDataHandler(dh);
|
// 附件区别内嵌内容的一个特点是有文件名，为防止中文乱码要编码
|
filePart.setFileName(MimeUtility.encodeText(dh.getName()));
|
msgMultipart.addBodyPart(filePart);
|
message.saveChanges();
|
//发送
|
//Transport.send(message, message.getAllRecipients());
|
Transport.send(message);
|
System.out.println("发送成功");
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}catch (MessagingException | UnsupportedEncodingException mex) {
|
mex.printStackTrace();
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return R.ok();
|
}
|
/**
|
* 远程调用 积分兑换订单 退款回退积分
|
* @return
|
*/
|
@PostMapping(value = "/refundPoints/{param}")
|
public R refundPoints(@PathVariable("param")String param) {
|
String[] split = param.split("-");
|
String userId = split[0];
|
String points = split[1];
|
TAppUser byId = appUserService.getById(userId);
|
byId.setPoints(byId.getPoints()+Integer.parseInt(points));
|
appUserService.updateById(byId);
|
return R.ok();
|
}
|
|
|
@ApiOperation(value = "查询当前用户是否为会员 0否1是", tags = {"小程序--查询当前用户是否为会员"})
|
@PostMapping(value = "/getUserInfo")
|
public AjaxResult<Integer> getUserInfo() {
|
TAppUser byId = appUserService.getById(tokenService.getLoginUserApplet().getUserId());
|
if (byId.getVipEndTime() == null){
|
return AjaxResult.ok(0);
|
}else if (byId.getVipEndTime().isAfter(LocalDateTime.now())){
|
return AjaxResult.ok(1);
|
}else{
|
return AjaxResult.ok(0);
|
}
|
}
|
|
@ApiOperation(value = "管理后台-根据手机号查询用户ids", tags = {"管理后台-活动费用统计"})
|
@PostMapping(value = "/user/getUserIdsByPhone")
|
public R<List<Long>> getUserIdsByPhone(@RequestParam("phone") String phone) {
|
return R.ok(appUserService.list(new QueryWrapper<TAppUser>().like("phone",phone)).stream().map(TAppUser::getId).collect(Collectors.toList()));
|
}
|
|
|
@RequiresPermissions(value = {"/company"}, logical = Logical.OR)
|
@ApiOperation(value = "单位管理列表", tags = {"用户管理-单位管理"})
|
@PostMapping(value = "/unit/page")
|
public R<Page<TCompany>> unitPage(@RequestBody UnitListQueryDto unitListQueryDto) {
|
//拿到单位列表
|
R<Page<TCompany>> pageR = otherClient.queryUnitPage(unitListQueryDto);
|
Page<TCompany> data = pageR.getData();
|
//拿到单位的用户数
|
for (TCompany record : data.getRecords()) {
|
record.setUserCount(appUserService.lambdaQuery().eq(TAppUser::getCompanyId, record.getId()).count());
|
}
|
return R.ok(data);
|
}
|
|
|
|
@RequiresPermissions(value = {"/appUser/list", "/appUser/add", "/appUser/update", "/appUser/updateCompany"}, logical = Logical.OR)
|
@ApiOperation(value = "单位下拉框", tags = {"用户管理-单位管理"})
|
@GetMapping(value = "/unit/select")
|
public R<List<TCompany>> unitSelect() {
|
UnitListQueryDto unitListQueryDto = new UnitListQueryDto();
|
unitListQueryDto.setPageCurr(1);
|
unitListQueryDto.setPageSize(9999);
|
//拿到单位列表
|
R<Page<TCompany>> pageR = otherClient.queryUnitPage(unitListQueryDto);
|
|
return R.ok(pageR.getData().getRecords());
|
}
|
|
|
|
@RequiresPermissions(value = {"/company/add", "/company/update"}, logical = Logical.OR)
|
@ApiOperation(value = "单位管理添加或编辑", tags = {"用户管理-单位管理"})
|
@PostMapping(value = "/unit/addOrUpdate")
|
@Log(title = "【单位管理】添加或编辑单位", businessType = BusinessType.INSERT,operatorType = OperatorType.MANAGE)
|
public R add(@RequestBody TCompany tCompany) {
|
//拿到单位列表
|
otherClient.unitAddorUpadate(tCompany);
|
return R.ok();
|
}
|
|
|
|
@RequiresPermissions(value = {"/company/del"}, logical = Logical.OR)
|
@ApiOperation(value = "单位管理删除", tags = {"用户管理-单位管理"})
|
@DeleteMapping(value = "/unit/delete")
|
@Log(title = "【单位管理】删除单位", businessType = BusinessType.DELETE,operatorType = OperatorType.MANAGE)
|
public R add(@RequestParam String ids) {
|
List<TAppUser> list = appUserService.lambdaQuery().in(TAppUser::getCompanyId, Arrays.asList(ids.split(","))).list();
|
if (!list.isEmpty()){
|
return R.fail("当前单位已存在用户，无法删除！");
|
}
|
String[] split = ids.split(",");
|
for (String s : split) {
|
otherClient.unitDelete(Integer.valueOf(s));
|
}
|
return R.ok();
|
|
}
|
|
|
@RequiresPermissions(value = {"/appUser/list"}, logical = Logical.OR)
|
@ApiOperation(value = "用户列表", tags = {"用户管理-用户列表"})
|
@PostMapping(value = "/user/page")
|
public R<Page<TAppUser>> userPage(@RequestBody UserListQueryDto userListQueryDto) {
|
List<Long> userIds = new ArrayList<>();
|
//如果要筛选标签。用标签获取useids
|
if (userListQueryDto.getUserTagId() != null){
|
userIds = appUserTagService.lambdaQuery().eq(TAppUserTag::getUserTagId, userListQueryDto.getUserTagId()).list().stream().map(TAppUserTag::getAppUserId).collect(Collectors.toList());
|
}
|
//列表查询
|
Page<TAppUser> page = appUserService.lambdaQuery()
|
.like(userListQueryDto.getUserPhone() != null && !"".equals(userListQueryDto.getUserPhone()), TAppUser::getPhone, userListQueryDto.getUserPhone())
|
.eq(userListQueryDto.getCompanyId() != null, TAppUser::getCompanyId, userListQueryDto.getCompanyId())
|
.eq(userListQueryDto.getProvinceCode() != null && !"".equals(userListQueryDto.getProvinceCode()), TAppUser::getProvinceCode, userListQueryDto.getProvinceCode())
|
.eq(userListQueryDto.getCityCode() != null && !"".equals(userListQueryDto.getCityCode()), TAppUser::getCityCode, userListQueryDto.getCityCode())
|
.eq(userListQueryDto.getStatus() != null, TAppUser::getStatus, userListQueryDto.getStatus())
|
.eq(userListQueryDto.getVipTypeId() != null, TAppUser::getVipId, userListQueryDto.getVipTypeId())
|
.in(!userIds.isEmpty(),TAppUser::getId,userIds)
|
.orderByDesc(BasePojo::getCreateTime)
|
.page(Page.of(userListQueryDto.getPageCurr(), userListQueryDto.getPageSize()));
|
if (page.getRecords().isEmpty()){
|
return R.ok(page);
|
}
|
List<Integer> vipIds = new ArrayList<>();
|
// vipIds = page.getRecords().stream().map(TAppUser::getVipId).collect(Collectors.toList());
|
//获取会员map
|
R<Map<Integer, String>> vipMap = otherClient.getVipMap(vipIds);
|
//循环处理
|
for (TAppUser appUser : page.getRecords()) {
|
//拿到最新的tagId
|
TAppUserTag one = appUserTagService.lambdaQuery().eq(TAppUserTag::getAppUserId, appUser.getId()).orderByDesc(TAppUserTag::getCreateTime).last("limit 1").one();
|
if (one!=null) {
|
//设置最新的tagName
|
R<TUserTag> byIdTag = otherClient.getByIdTag(one.getUserTagId());
|
if (byIdTag.getData() != null) {
|
appUser.setTagName(byIdTag.getData().getName());
|
}
|
}
|
if (appUser.getVipEndTime()!=null&&appUser.getVipEndTime().isAfter(LocalDateTime.now())) {
|
//匹配vipMap的值
|
appUser.setVipName(vipMap.getData().get(appUser.getVipId()));
|
}
|
//累计充电次数
|
R<Long> useOrderCount = chargingOrderClient.useOrderCount(appUser.getId());
|
appUser.setOrderCount(useOrderCount.getData());
|
appUser.setUid(appUser.getId().toString());
|
if (appUser.getCompanyId()!=null){
|
TCompany data = otherClient.unitDetail(appUser.getCompanyId()).getData();
|
if (data!=null){
|
appUser.setCompanyName(data.getName());
|
}
|
}
|
|
TAppUserCar one1 = appUserCarService.lambdaQuery().eq(TAppUserCar::getAppUserId, appUser.getId()).orderByDesc(BasePojo::getCreateTime).last("limit 1").one();
|
if (one1!=null){
|
CarNumDto carNumDto = CarUtil.carNum(one1.getLicensePlate());
|
appUser.setPlace(carNumDto.getProvince()+carNumDto.getCity());
|
|
}
|
|
|
}
|
return R.ok(page);
|
}
|
|
|
@RequiresPermissions(value = {"/vipList"}, logical = Logical.OR)
|
@ApiOperation(value = "会员列表", tags = {"用户管理-会员列表"})
|
@PostMapping(value = "/user/vip/page")
|
public R<Page<TAppUser>> vipPage(@RequestBody UserListQueryDto userListQueryDto) {
|
List<Long> userIds = new ArrayList<>();
|
//如果要筛选标签。用标签获取useids
|
if (userListQueryDto.getUserTagId() != null){
|
userIds = appUserTagService.lambdaQuery().eq(TAppUserTag::getUserTagId, userListQueryDto.getUserTagId()).list().stream().map(TAppUserTag::getAppUserId).collect(Collectors.toList());
|
}
|
LocalDateTime end1 = null;
|
LocalDateTime end2 = null ;
|
if (userListQueryDto.getVipEndTime1()!=null) {
|
end1 = LocalDateTime.now().plusDays(userListQueryDto.getVipEndTime1());
|
}
|
if (userListQueryDto.getVipEndTime2()!=null){
|
end2 = LocalDateTime.now().plusDays(userListQueryDto.getVipEndTime2());
|
}
|
//列表查询
|
Page<TAppUser> page = appUserService.lambdaQuery()
|
.ge(TAppUser::getVipEndTime, LocalDateTime.now())
|
.like(userListQueryDto.getUserPhone() != null && !"".equals(userListQueryDto.getUserPhone()), TAppUser::getPhone, userListQueryDto.getUserPhone())
|
.eq(userListQueryDto.getCompanyId() != null, TAppUser::getCompanyId, userListQueryDto.getCompanyId())
|
.eq(userListQueryDto.getProvinceCode() != null && !"".equals(userListQueryDto.getProvinceCode()), TAppUser::getProvinceCode, userListQueryDto.getProvinceCode())
|
.eq(userListQueryDto.getCityCode() != null && !"".equals(userListQueryDto.getCityCode()), TAppUser::getCityCode, userListQueryDto.getCityCode())
|
.eq(userListQueryDto.getStatus() != null, TAppUser::getStatus, userListQueryDto.getStatus())
|
.eq(userListQueryDto.getVipTypeId() != null, TAppUser::getVipId, userListQueryDto.getVipTypeId())
|
.ge(userListQueryDto.getVipEndTime1() != null, TAppUser::getVipEndTime, end1 )
|
.le(userListQueryDto.getVipEndTime2() != null, TAppUser::getVipEndTime, end2)
|
.in(!userIds.isEmpty(), TAppUser::getId, userIds)
|
.page(Page.of(userListQueryDto.getPageCurr(), userListQueryDto.getPageSize()));
|
if (page.getRecords().isEmpty()){
|
return R.ok(page);
|
}
|
List<Integer> vipIds = new ArrayList<>();
|
vipIds = page.getRecords().stream().map(TAppUser::getVipId).collect(Collectors.toList());
|
//获取会员map
|
R<Map<Integer, String>> vipMap = otherClient.getVipMap(vipIds);
|
//循环处理
|
for (TAppUser appUser : page.getRecords()) {
|
//拿到最新的tagId
|
TAppUserTag one = appUserTagService.lambdaQuery().eq(TAppUserTag::getAppUserId, appUser.getId()).orderByDesc(TAppUserTag::getCreateTime).last("limit 1").one();
|
//设置最新的tagName
|
if (one!=null) {
|
R<TUserTag> byIdTag = otherClient.getByIdTag(one.getUserTagId());
|
if (byIdTag.getData() != null) {
|
appUser.setTagName(byIdTag.getData().getName());
|
}
|
}
|
//匹配vipMap的值
|
appUser.setVipName(vipMap.getData().get(appUser.getVipId()));
|
//累计充电次数
|
R<Long> useOrderCount = chargingOrderClient.useOrderCount(appUser.getId());
|
appUser.setOrderCount(useOrderCount.getData());
|
appUser.setLastDays( Duration.between(LocalDateTime.now(), appUser.getVipEndTime()).toDays());
|
appUser.setUid(appUser.getId().toString());
|
|
|
TAppUserCar one1 = appUserCarService.lambdaQuery().eq(TAppUserCar::getAppUserId, appUser.getId()).orderByDesc(BasePojo::getCreateTime).last("limit 1").one();
|
if (one1!=null){
|
CarNumDto carNumDto = CarUtil.carNum(one1.getLicensePlate());
|
appUser.setPlace(carNumDto.getProvince()+carNumDto.getCity());
|
|
}
|
}
|
return R.ok(page);
|
}
|
|
|
@RequiresPermissions(value = {"/coupon/send"}, logical = Logical.OR)
|
@ApiOperation(tags = {"管理后台-优惠券管理"},value = "优惠券发放-选择人员")
|
@PostMapping("/choiceUser")
|
public R<Page<TAppUser>> choiceUser(@RequestBody ChoiceUserListQueryDto userListQueryDto) {
|
List<Long> userIds = new ArrayList<>();
|
//如果要筛选标签。用标签获取useids
|
if (userListQueryDto.getUserTagId() != null){
|
String[] split = userListQueryDto.getUserTagId().split(",");
|
userIds = appUserTagService.lambdaQuery().in(TAppUserTag::getUserTagId, Arrays.asList(split)).list().stream().map(TAppUserTag::getAppUserId).collect(Collectors.toList());
|
if (userIds.isEmpty()){
|
userIds.add(-1L);
|
}
|
}
|
//列表查询
|
Page<TAppUser> page = appUserService.lambdaQuery()
|
.like(userListQueryDto.getUserPhone() != null && !"".equals(userListQueryDto.getUserPhone()), TAppUser::getPhone, userListQueryDto.getUserPhone())
|
.eq(userListQueryDto.getCityCode() != null && !"".equals(userListQueryDto.getCityCode()), TAppUser::getCityCode, userListQueryDto.getCityCode())
|
.in(!userIds.isEmpty(),TAppUser::getId,userIds)
|
.eq(TAppUser::getStatus,1)
|
.page(Page.of(userListQueryDto.getPageCurr(), userListQueryDto.getPageSize()));
|
if (page.getRecords().isEmpty()){
|
return R.ok(page);
|
}
|
List<Integer> vipIds = new ArrayList<>();
|
vipIds = page.getRecords().stream().map(TAppUser::getVipId).collect(Collectors.toList());
|
//获取会员map
|
R<Map<Integer, String>> vipMap = otherClient.getVipMap(vipIds);
|
//循环处理
|
for (TAppUser appUser : page.getRecords()) {
|
if (appUser.getProvinceCode()!=null){
|
Region data = otherClient.getRegionBuyCode(appUser.getProvinceCode()).getData();
|
appUser.setProvince(data.getName());
|
}
|
if(appUser.getCityCode()!=null){
|
Region data = otherClient.getRegionBuyCode(appUser.getCityCode()).getData();
|
appUser.setCity(data.getName());
|
}
|
//拿到最新的tagId
|
TAppUserTag one = appUserTagService.lambdaQuery().eq(TAppUserTag::getAppUserId, appUser.getId()).orderByDesc(TAppUserTag::getCreateTime).last("limit 1").one();
|
//设置最新的tagName
|
if (one!=null){
|
R<TUserTag> byIdTag = otherClient.getByIdTag(one.getUserTagId());
|
if (byIdTag.getData()!=null) {
|
appUser.setTagName(byIdTag.getData().getName());
|
}
|
}
|
//匹配vipMap的值
|
appUser.setVipName(vipMap.getData().get(appUser.getVipId()));
|
//累计充电次数
|
R<Long> useOrderCount = chargingOrderClient.useOrderCount(appUser.getId());
|
appUser.setOrderCount(useOrderCount.getData());
|
appUser.setUid(appUser.getId().toString());
|
|
}
|
return R.ok(page);
|
}
|
|
|
@RequiresPermissions(value = {"/appUser/add", "/appUser/update"}, logical = Logical.OR)
|
@ApiOperation(value = "用户添加编辑", tags = {"用户管理-用户列表"})
|
@PostMapping(value = "/user/addOrUpdate")
|
@Log(title = "【用户列表】添加编辑用户", businessType = BusinessType.INSERT,operatorType = OperatorType.MANAGE)
|
public R addOrUpdate(@RequestBody TAppUser tAppUser) {
|
if (tAppUser.getId() != null){
|
//为编辑操作，要进行vip的逻辑处理
|
TAppUser nowUser = appUserService.getById(tAppUser.getId());
|
//会员结束时间不为空
|
if (tAppUser.getVipEndTime()!=null&&tAppUser.getVipEndTime()!=nowUser.getVipEndTime()){
|
//计算改变后的结束时间和当前结束时间差距了多少时间
|
Duration duration = Duration.between(tAppUser.getVipEndTime(), nowUser.getVipEndTime());
|
List<TAppUserVipDetail> detailList = tAppUserVipDetailService.lambdaQuery().eq(TAppUserVipDetail::getAppUserId, tAppUser.getId()).gt(TAppUserVipDetail::getEndTime, LocalDateTime.now()).orderByAsc(TAppUserVipDetail::getStartTime).list();
|
//如果是增加，则将明细表里当前会员的结束时间往后移，并将其余未开始会员的开始时间和结束时间往后移
|
if (tAppUser.getVipEndTime().isAfter(nowUser.getVipEndTime())){
|
for (int i = 0; i < detailList.size(); i++) {
|
TAppUserVipDetail tAppUserVipDetail = detailList.get(i);
|
if (i == 0 ){
|
tAppUserVipDetail.setEndTime(tAppUser.getVipEndTime().plus(duration));
|
}else {
|
tAppUserVipDetail.setStartTime(tAppUserVipDetail.getStartTime().plus(duration));
|
tAppUserVipDetail.setEndTime(tAppUserVipDetail.getEndTime().plus(duration));
|
}
|
}
|
}else {
|
//如果是减少，将当前会员结束时间减少，并将其余会员开始和结束时间都往前移动
|
for (int i = 0; i < detailList.size(); i++) {
|
TAppUserVipDetail tAppUserVipDetail = detailList.get(i);
|
if (i == 0 ){
|
tAppUserVipDetail.setEndTime(tAppUser.getVipEndTime().minus(duration));
|
}else {
|
tAppUserVipDetail.setStartTime(tAppUserVipDetail.getStartTime().minus(duration));
|
tAppUserVipDetail.setEndTime(tAppUserVipDetail.getEndTime().minus(duration));
|
}
|
}
|
}
|
}
|
|
}else {
|
List<TAppUser> list = appUserService.lambdaQuery().eq(TAppUser::getPhone, tAppUser.getPhone()).list();
|
if (!list.isEmpty()){
|
return R.fail("该手机号已注册");
|
}
|
}
|
appUserService.saveOrUpdate(tAppUser);
|
return R.ok();
|
}
|
|
|
@RequiresPermissions(value = {"/appUser/select", "/vipList/select"}, logical = Logical.OR)
|
@ApiOperation(value = "用户详情", tags = {"用户管理-用户列表"})
|
@GetMapping(value = "/user/detail/{id}")
|
public R<UserDetailDto> userDetail(@PathVariable Long id) {
|
TAppUser user = appUserService.getById(id);
|
R<Map<Integer, String>> vipMap = otherClient.getVipMap(Collections.singletonList(user.getVipId()));
|
if (user.getVipEndTime()!=null&&user.getVipEndTime().isAfter(LocalDateTime.now())) {
|
//匹配vipMap的值
|
user.setVipName(vipMap.getData().get(user.getVipId()));
|
}
|
|
|
UserDetailDto userDetailDto = new UserDetailDto();
|
BeanUtils.copyProperties(user,userDetailDto);
|
|
//获取累计充电数量
|
R<Long> useOrderCount = chargingOrderClient.useOrderCount(user.getId());
|
userDetailDto.setOrderCount(useOrderCount.getData());
|
R<TCompany> tCompanyR = otherClient.unitDetail(user.getCompanyId());
|
if (tCompanyR.getData()!=null){
|
userDetailDto.setUnitName(tCompanyR.getData().getName());
|
}
|
List<TAppUserCar> carList = appUserCarService.lambdaQuery().eq(TAppUserCar::getAppUserId, id).orderByDesc(BasePojo::getCreateTime).list();
|
userDetailDto.setCarList(carList);
|
|
List<Integer> tagIds = appUserTagService.lambdaQuery().eq(TAppUserTag::getAppUserId, id).orderByDesc(TAppUserTag::getCreateTime).list().stream().map(TAppUserTag::getUserTagId).collect(Collectors.toList());
|
R<Map<Integer, String>> tagMap = otherClient.getTagMap(tagIds);
|
userDetailDto.setTagName(tagMap.getData().values()
|
.stream()
|
.collect(Collectors.joining(",")));
|
|
|
|
return R.ok(userDetailDto);
|
}
|
|
@RequiresPermissions(value = {"/appUser/select", "/vipList/select"}, logical = Logical.OR)
|
@ApiOperation(value = "用户详情积分明细", tags = {"后台-用户管理-用户列表"})
|
@PostMapping(value = "/user/points/page")
|
public R<Page<TAppUserIntegralChange>> pointsDetail(@RequestBody PointsQueryDto pointsQueryDto) {
|
if (pointsQueryDto.getUserId()==null){
|
pointsQueryDto.setUserId(tokenService.getLoginUserApplet().getUserId());
|
}
|
List<Integer> types = new ArrayList<>();
|
if (pointsQueryDto.getType()==null){
|
types.add(1);
|
types.add(2);
|
types.add(3);
|
types.add(4);
|
types.add(5);
|
types.add(6);
|
}else if (pointsQueryDto.getType()==1){
|
types.add(1);
|
types.add(2);
|
types.add(3);
|
types.add(4);
|
types.add(5);
|
}else if (pointsQueryDto.getType()==2){
|
types.add(6);
|
}
|
Page<TAppUserIntegralChange> page = integralChangeService.lambdaQuery()
|
.eq(TAppUserIntegralChange::getAppUserId, pointsQueryDto.getUserId())
|
.orderByDesc(TAppUserIntegralChange::getCreateTime)
|
.eq(pointsQueryDto.getChangeType() != null, TAppUserIntegralChange::getChangeType, pointsQueryDto.getChangeType())
|
.in(!types.isEmpty(), TAppUserIntegralChange::getChangeType, types).page(Page.of(pointsQueryDto.getPageCurr(), pointsQueryDto.getPageSize()));
|
|
for (TAppUserIntegralChange record : page.getRecords()) {
|
record.setDateTime(record.getCreateTime());
|
record.setUid(record.getId().toString());
|
if (record.getChangeType()==2||record.getChangeType()==3){
|
R<TChargingOrder> tChargingOrderR = chargingOrderClient.orderDetail(Long.valueOf(record.getExtension()));
|
if (tChargingOrderR.getData()!=null) {
|
record.setOrderNum(tChargingOrderR.getData().getCode());
|
}
|
}
|
if (record.getChangeType()==6){
|
R<TExchangeOrder> tExchangeOrderR = exchangeOrderClient.orderDetail(Long.valueOf(record.getExtension()));
|
if (tExchangeOrderR.getData()!=null){
|
record.setOrderNum(tExchangeOrderR.getData().getCode());
|
}
|
}
|
}
|
|
return R.ok(page);
|
|
}
|
|
|
@ApiOperation(value = "用户详情积分明细", tags = {"小程序-个人中心"})
|
@PostMapping(value = "/user/points/page1")
|
public R<Page<TAppUserIntegralChange>> pointsDetail1(@RequestBody PointsQueryDto pointsQueryDto) {
|
if (pointsQueryDto.getUserId()==null){
|
pointsQueryDto.setUserId(tokenService.getLoginUserApplet().getUserId());
|
}
|
List<Integer> types = new ArrayList<>();
|
if (pointsQueryDto.getType()==null){
|
types.add(1);
|
types.add(2);
|
types.add(3);
|
types.add(4);
|
types.add(5);
|
types.add(6);
|
}else if (pointsQueryDto.getType()==1){
|
types.add(1);
|
types.add(2);
|
types.add(3);
|
types.add(4);
|
types.add(5);
|
}else if (pointsQueryDto.getType()==2){
|
types.add(6);
|
}
|
Page<TAppUserIntegralChange> page = integralChangeService.lambdaQuery()
|
.eq(TAppUserIntegralChange::getAppUserId, pointsQueryDto.getUserId())
|
.orderByDesc(TAppUserIntegralChange::getCreateTime)
|
.eq(pointsQueryDto.getChangeType() != null, TAppUserIntegralChange::getChangeType, pointsQueryDto.getChangeType())
|
.in(!types.isEmpty(), TAppUserIntegralChange::getChangeType, types).page(Page.of(pointsQueryDto.getPageCurr(), pointsQueryDto.getPageSize()));
|
|
for (TAppUserIntegralChange record : page.getRecords()) {
|
record.setDateTime(record.getCreateTime());
|
record.setUid(record.getId().toString());
|
if (record.getChangeType()==2||record.getChangeType()==3){
|
R<TChargingOrder> tChargingOrderR = chargingOrderClient.orderDetail(Long.valueOf(record.getExtension()));
|
if (tChargingOrderR.getData()!=null) {
|
record.setOrderNum(tChargingOrderR.getData().getCode());
|
}
|
}
|
if (record.getChangeType()==6){
|
R<TExchangeOrder> tExchangeOrderR = exchangeOrderClient.orderDetail(Long.valueOf(record.getExtension()));
|
if (tExchangeOrderR.getData()!=null){
|
record.setOrderNum(tExchangeOrderR.getData().getCode());
|
}
|
}
|
}
|
|
return R.ok(page);
|
|
}
|
|
@ApiOperation(value = "积分详情", tags = {"小程序-个人中心"})
|
@GetMapping(value = "/user/points/detail")
|
public R<TAppUserIntegralChange> pointsDetail(String id) {
|
TAppUserIntegralChange byId = integralChangeService.getById(id);
|
Long userId = tokenService.getLoginUserApplet().getUserId();
|
if(!byId.getAppUserId().equals(userId)){
|
return R.fail("权限不足");
|
}
|
if (byId.getChangeType()==6) {
|
TExchangeOrder data = exchangeOrderClient.orderDetail(Long.valueOf(byId.getExtension())).getData();
|
if (data != null) {
|
byId.setGoodType(data.getOrderType());
|
}
|
}else if (byId.getChangeType()==4){
|
TAppUser byId1 = appUserService.getById(byId.getExtension());
|
byId.setExtension(byId1.getPhone());
|
}
|
return R.ok(byId);
|
}
|
|
@RequiresPermissions(value = {"/appUser/freeze"}, logical = Logical.OR)
|
@ApiOperation(value = "冻结解冻用户", tags = {"后台-用户管理-用户列表"})
|
@PostMapping(value = "/user/status/change")
|
@Log(title = "【用户列表】冻结解冻用户", businessType = BusinessType.UPDATE,operatorType = OperatorType.MANAGE)
|
public R pointsDetail(@RequestBody UserChangeDto userChangeDto) {
|
TAppUser appUser = appUserService.getById(userChangeDto.getUserId());
|
appUser.setStatus(userChangeDto.getStatus());
|
appUser.setRemark(userChangeDto.getRemark());
|
appUserService.updateById(appUser);
|
return R.ok();
|
}
|
|
|
@RequiresPermissions(value = {"/appUser/updateCompany"}, logical = Logical.OR)
|
@ApiOperation(value = "修改单位", tags = {"后台-用户管理-用户列表"})
|
@PostMapping(value = "/user/unit/change")
|
@Log(title = "【用户列表】修改用户单位", businessType = BusinessType.UPDATE,operatorType = OperatorType.MANAGE)
|
public R unitChange(@RequestBody UnitChangeDto unitChangeDto) {
|
for (String s : unitChangeDto.getIds().split(",")) {
|
TAppUser byId = appUserService.getById(s);
|
byId.setCompanyId(unitChangeDto.getUnitId());
|
appUserService.updateById(byId);
|
}
|
return R.ok();
|
}
|
|
|
@RequiresPermissions(value = {"/appUser/del"}, logical = Logical.OR)
|
@ApiOperation(value = "删除用户", tags = {"后台-用户管理-用户列表"})
|
@DeleteMapping(value = "/user/delete")
|
@Log(title = "【用户列表】删除用户", businessType = BusinessType.DELETE,operatorType = OperatorType.MANAGE)
|
public R userDelete(String ids) {
|
String[] split = ids.split(",");
|
for (String s : split) {
|
appUserService.removeById(s);
|
}
|
return R.ok();
|
|
}
|
@Resource
|
private TAppUserVipDetailService appUserVipDetailService;
|
|
|
@ApiOperation(value = "个人中心信息", tags = {"小程序-个人中心"})
|
@GetMapping(value = "/user/info")
|
public R<AppUserInfoDto> info() {
|
Long userId = tokenService.getLoginUserApplet().getUserId();
|
TAppUser byId = appUserService.getById(userId);
|
AppUserInfoDto appUserInfoDto = new AppUserInfoDto();
|
TVip data = vipClient.getVipInfoByType(2).getData();
|
if(null != data){
|
appUserInfoDto.setMinPrice(data.getMonthlyCard());
|
}
|
|
//判断会员
|
if (byId.getVipEndTime()==null||byId.getVipEndTime().isBefore(LocalDateTime.now())){
|
appUserInfoDto.setIsVip(0);
|
}else {
|
TAppUserVipDetail one = appUserVipDetailService.getOne(new LambdaQueryWrapper<TAppUserVipDetail>()
|
.eq(TAppUserVipDetail::getAppUserId, userId)
|
.eq(TAppUserVipDetail::getVipId, byId.getVipId())
|
.last(" and now() between start_time and end_time"));
|
Long count = appCouponService.lambdaQuery().eq(TAppCoupon::getDetailId, one.getId()).count();
|
appUserInfoDto.setVipCouponNum(count);
|
appUserInfoDto.setIsVip(1);
|
appUserInfoDto.setVipExpireTime(byId.getVipEndTime());
|
}
|
//判断当天是否签到
|
Long count = signService.lambdaQuery().eq(TAppUserSign::getAppUserId,userId).eq(TAppUserSign::getSignDay, LocalDate.now()).count();
|
appUserInfoDto.setIsSign(count>0?1:0);
|
//获取当前拥有的优惠卷数量
|
Long coupons = appCouponService.lambdaQuery().eq(TAppCoupon::getAppUserId, userId).ge(TAppCoupon::getEndTime, LocalDateTime.now()).eq(TAppCoupon::getStatus, 1).count();
|
appUserInfoDto.setCouponNum(Math.toIntExact(coupons));
|
//当前绑定的车辆
|
List<TAppUserCar> list = carService.lambdaQuery().eq(TAppUserCar::getAppUserId, userId).list();
|
for (TAppUserCar tAppUserCar : list) {
|
tAppUserCar.setUid(tAppUserCar.getId().toString());
|
}
|
appUserInfoDto.setUserCars(list);
|
appUserInfoDto.setFirstAdd(byId.getFirstAdd()!=null?byId.getFirstAdd():0);
|
appUserInfoDto.setPoints(byId.getPoints()==null?0:byId.getPoints());
|
return R.ok(appUserInfoDto);
|
}
|
|
|
@Log(title = "【我的】设置头像", businessType = BusinessType.UPDATE,operatorType = OperatorType.MOBILE)
|
@ApiOperation(value = "设置头像", tags = {"小程序-个人中心"})
|
@GetMapping(value = "/user/set/avatar")
|
public R avatar(String url) {
|
Long userId = tokenService.getLoginUserApplet().getUserId();
|
String fileName = redisTemplate.opsForValue().get("file:" + userId).toString();
|
String substring = url.substring(url.lastIndexOf("/") + 1);
|
if(StringUtils.isEmpty(fileName) || fileName.equals(substring)){
|
return R.fail("请重新上传头像");
|
}
|
|
TAppUser byId = appUserService.getById(userId);
|
byId.setAvatar(url);
|
appUserService.updateById(byId);
|
return R.ok();
|
}
|
|
@ApiOperation(value = "优惠卷列表不分页（1可使用2不可用）", tags = {"小程序-个人中心"})
|
@GetMapping(value = "/user/coupon")
|
public R<ListInfoCouponDto> userCoupon(@RequestParam("type") Integer type) {
|
Long userId = tokenService.getLoginUserApplet().getUserId();
|
LocalDateTime now = LocalDateTime.now();
|
|
List<InfoCouponDto> couponDtos1 = new ArrayList<>();
|
|
List<TAppCoupon> list = appCouponService.lambdaQuery().eq(TAppCoupon::getAppUserId, userId).ge(TAppCoupon::getEndTime, now).eq(TAppCoupon::getStatus, 1).list();
|
for (TAppCoupon tAppCoupon : list) {
|
TCoupon coupon = JSON.toJavaObject(JSON.parseObject(tAppCoupon.getCouponJson()), TCoupon.class);
|
InfoCouponDto infoCouponDto = new InfoCouponDto();
|
BeanUtils.copyProperties(coupon, infoCouponDto);
|
infoCouponDto.setId(tAppCoupon.getId().toString());
|
infoCouponDto.setCouponId(coupon.getId());
|
infoCouponDto.setEndTime(tAppCoupon.getEndTime());
|
couponDtos1.add(infoCouponDto);
|
|
}
|
|
List<TAppCoupon> list1 = appCouponService.lambdaQuery().eq(TAppCoupon::getAppUserId, userId).eq(TAppCoupon::getStatus, 2).list();
|
List<TAppCoupon> list2 = appCouponService.lambdaQuery().eq(TAppCoupon::getAppUserId, userId).lt(TAppCoupon::getEndTime, now).list();
|
|
List<InfoCouponDto> couponDtos2 = new ArrayList<>();
|
for (TAppCoupon tAppCoupon : list1) {
|
TCoupon coupon = JSON.toJavaObject(JSON.parseObject(tAppCoupon.getCouponJson()), TCoupon.class);
|
InfoCouponDto infoCouponDto = new InfoCouponDto();
|
BeanUtils.copyProperties(coupon, infoCouponDto);
|
infoCouponDto.setId(tAppCoupon.getId().toString());
|
infoCouponDto.setEndTime(tAppCoupon.getEndTime());
|
couponDtos2.add(infoCouponDto);
|
}
|
for (TAppCoupon tAppCoupon : list2) {
|
TCoupon coupon = JSON.toJavaObject(JSON.parseObject(tAppCoupon.getCouponJson()), TCoupon.class);
|
InfoCouponDto infoCouponDto = new InfoCouponDto();
|
BeanUtils.copyProperties(coupon, infoCouponDto);
|
infoCouponDto.setId(tAppCoupon.getId().toString());
|
infoCouponDto.setEndTime(tAppCoupon.getEndTime());
|
couponDtos2.add(infoCouponDto);
|
}
|
|
|
ListInfoCouponDto listInfoCouponDto = new ListInfoCouponDto();
|
if (type==1){
|
listInfoCouponDto.setInfoCouponDtoList(couponDtos1);
|
}else {
|
listInfoCouponDto.setInfoCouponDtoList(couponDtos2);
|
}
|
listInfoCouponDto.setNum1(couponDtos1.size());
|
listInfoCouponDto.setNum2(couponDtos2.size());
|
return R.ok(listInfoCouponDto);
|
|
}
|
|
|
@ApiOperation(value = "优惠卷详情（1可使用2不可用）", tags = {"小程序-个人中心"})
|
@PostMapping(value = "/user/coupon/getById")
|
public R<TAppCoupon> couponGetById(@RequestParam("id")Long id) {
|
TAppCoupon appCoupon = appCouponService.getById(id);
|
Long userId = tokenService.getLoginUserApplet().getUserId();
|
if(!appCoupon.getAppUserId().equals(userId)){
|
return R.fail("权限不足");
|
}
|
appCoupon.setUid(id.toString());
|
return R.ok(appCoupon);
|
}
|
|
|
|
@RequiresPermissions(value = {"/appUser/giftVip", "/appUser/gift_vip"}, logical = Logical.OR)
|
@ApiOperation(value = "赠送会员", tags = {"用户管理-用户列表"})
|
@PostMapping(value = "/user/give/vip")
|
@Log(title = "【用户列表】赠送会员", businessType = BusinessType.OTHER,operatorType = OperatorType.MANAGE)
|
public R giveVip(@RequestBody GiveVipDto giveVipDto) {
|
String[] split = giveVipDto.getUserIds().split(",");
|
for (String s : split) {
|
TAppUser nowUser = appUserService.getById(s);
|
int plusDay = 0;
|
if (giveVipDto.getType() == 1) {
|
plusDay = 1;
|
} else if (giveVipDto.getType() == 2) {
|
plusDay = 3;
|
} else if (giveVipDto.getType() == 3) {
|
plusDay = 12;
|
}
|
BigDecimal bigDecimal = new BigDecimal("0");
|
TVip info = vipClient.getInfo1(giveVipDto.getVipId()).getData();
|
switch (giveVipDto.getType()){
|
case 1:
|
bigDecimal = bigDecimal.add(info.getMonthlyCard()==null?new BigDecimal(0):info.getMonthlyCard());
|
break;
|
case 2:
|
bigDecimal = bigDecimal.add(info.getSeasonCard()==null?new BigDecimal(0):info.getSeasonCard());
|
break;
|
case 3:
|
bigDecimal = bigDecimal.add(info.getAnnualCard()==null?new BigDecimal(0):info.getAnnualCard());
|
break;
|
}
|
//增加vipDetail
|
giveVipUtil.sendVip(nowUser, giveVipDto.getVipId(),plusDay,giveVipDto.getType());
|
appUserService.updateById(nowUser);
|
// 新增后台赠送记录
|
TGrantVip tGrantVip = new TGrantVip();
|
tGrantVip.setCode(OrderCodeUtil.getOrderCode("ZS"));
|
tGrantVip.setAppUserId(nowUser.getId());
|
tGrantVip.setVipId(giveVipDto.getVipId());
|
tGrantVip.setOrderAmount(bigDecimal);
|
tGrantVip.setCreateTime(LocalDateTime.now());
|
tGrantVip.setAppUserId(nowUser.getId());
|
orderClient.managementGiveVip(tGrantVip);
|
}
|
return R.ok();
|
}
|
|
|
|
@PostMapping(value = "/user/give/vip1")
|
public R giveVip1(@RequestBody GiveVipDto giveVipDto) {
|
String[] split = giveVipDto.getUserIds().split(",");
|
for (String s : split) {
|
TAppUser nowUser = appUserService.getById(s);
|
int plusDay = 0;
|
if (giveVipDto.getType() == 1) {
|
plusDay = 1;
|
} else if (giveVipDto.getType() == 2) {
|
plusDay = 3;
|
} else if (giveVipDto.getType() == 3) {
|
plusDay = 12;
|
}
|
//增加vipDetail
|
giveVipUtil.sendVip(nowUser, giveVipDto.getVipId(),plusDay,giveVipDto.getType());
|
appUserService.updateById(nowUser);
|
}
|
return R.ok();
|
}
|
|
|
@ApiOperation(value = "已赠送列表", tags = {"小程序-个人中心-邀请好友"})
|
@PostMapping(value = "/user/invite/page")
|
public R<Page<TInviteUser>> invitePage(@RequestBody BasePage basePage) {
|
Long userId = tokenService.getLoginUserApplet().getUserId();
|
Page<TInviteUser> page = inviteUserService.lambdaQuery().eq(TInviteUser::getAppUserId, userId).isNotNull(TInviteUser::getAward).orderByDesc(TInviteUser::getCreateTime).page(Page.of(basePage.getPageCurr(), basePage.getPageSize()));
|
for (TInviteUser record : page.getRecords()) {
|
TAppUser byId = appUserService.getById(record.getBeInvitedAppUserId());
|
record.setAvatar(byId.getAvatar());
|
record.setName(byId.getName());
|
}
|
return R.ok(page);
|
}
|
|
@ApiOperation(value = "已赠送列表", tags = {"小程序-个人中心-邀请好友"})
|
@GetMapping(value = "/user/invite/info")
|
public R<InviteInfoDto> inviteInfo() {
|
Long userId = tokenService.getLoginUserApplet().getUserId();
|
Integer point = 0;
|
List<TInviteUser> list = inviteUserService.lambdaQuery().eq(TInviteUser::getAppUserId, userId).isNotNull(TInviteUser::getAward).orderByDesc(TInviteUser::getCreateTime).list();
|
for (TInviteUser tInviteUser : list) {
|
point = point +tInviteUser.getAward();
|
}
|
InviteInfoDto inviteInfoDto = new InviteInfoDto();
|
inviteInfoDto.setPoint(point);
|
inviteInfoDto.setInviteNum(list.size());
|
|
|
return R.ok(inviteInfoDto);
|
}
|
|
|
@Log(title = "【我的】更换手机号", businessType = BusinessType.UPDATE,operatorType = OperatorType.MOBILE)
|
@ApiOperation(value = "更换手机号", tags = {"小程序-用户管理-更换手机号"})
|
@PostMapping(value = "/user/updatePhone")
|
public AjaxResult<String> updatePhone(@Validated @RequestBody UpdatePhoneDTO dto) {
|
String code = redisService.getCacheObject(dto.getPhone() + Constants.UPDATE_PHONE);
|
if(StringUtils.isEmpty(code)){
|
return AjaxResult.error("验证码已过期,请重新获取验证码!");
|
}
|
if(!code.equals(dto.getCode())){
|
return AjaxResult.error("验证码错误!");
|
}
|
// 获取当前用户信息
|
Long userId = tokenService.getLoginUserApplet().getUserId();
|
TAppUser appUser = appUserService.getOne(new LambdaQueryWrapper<TAppUser>().eq(TAppUser::getPhone, dto.getPhone()).eq(TAppUser::getDelFlag, 0).eq(TAppUser::getStatus, 3));
|
if (Objects.nonNull(appUser)){
|
return AjaxResult.error("手机号已使用，请更换其他手机号");
|
}
|
TAppUser appUser1 = appUserService.getById(userId);
|
appUser1.setPhone(dto.getPhone());
|
appUserService.updateById(appUser1);
|
return AjaxResult.success();
|
}
|
|
|
@Log(title = "【我的】注销接口", businessType = BusinessType.DELETE,operatorType = OperatorType.MOBILE)
|
@ApiOperation(value = "注销接口", tags = {"小程序-用户管理-注销账号"})
|
@DeleteMapping("/logoff")
|
public AjaxResult<?> logoff(HttpServletRequest request) {
|
String token = SecurityUtils.getToken(request);
|
if (StringUtils.isNotEmpty(token))
|
{
|
String userId = JwtUtils.getUserId(token);
|
// 账号注销
|
appUserService.update(Wrappers.<TAppUser>lambdaUpdate().set(TAppUser::getStatus, AppUserStatusEnum.LOGOFF.getCode()).eq(TAppUser::getId, userId));
|
// 删除用户缓存记录
|
AuthUtil.logoutByToken(token);
|
}
|
return AjaxResult.success();
|
}
|
|
/**
|
* 根据用户id查询用户信息
|
* @param appUserIds 用户id
|
* @return
|
*/
|
@PostMapping(value = "/user/getUserByIds")
|
public R<List<TAppUser>> getUserByIds(@RequestBody List<Long> appUserIds){
|
return R.ok(appUserService.list(Wrappers.<TAppUser>lambdaQuery().in(TAppUser::getId,appUserIds)));
|
}
|
|
|
/**
|
* 根据用户id获取用户
|
* @param id
|
* @return
|
*/
|
@PostMapping(value = "/user/getUserById/{id}")
|
public R<TAppUser> getUserById(@PathVariable Long id){
|
TAppUser appUser = appUserService.getById(id);
|
return R.ok(appUser);
|
}
|
@PostMapping(value = "/user/getAllUser")
|
public R<List<TAppUser>> getAllUser(){
|
return R.ok(appUserService.list(null));
|
}
|
|
|
/**
|
* 修改用户信息
|
* @param appUser
|
* @return
|
*/
|
@ResponseBody
|
@PostMapping("/user/updateAppUser")
|
public R updateAppUser(@RequestBody TAppUser appUser){
|
appUserService.updateById(appUser);
|
return R.ok();
|
}
|
|
/**
|
* 通过手机号查询用户
|
* @param phone
|
* @return
|
*/
|
@GetMapping("/user/selectByPhone")
|
public R<TAppUser> selectByPhone(@RequestParam("phone") String phone){
|
return R.ok(appUserService.getOne(Wrappers.lambdaQuery(TAppUser.class)
|
.eq(TAppUser::getPhone,phone)
|
.last("LIMIT 1")));
|
}
|
/**
|
* 通过手机号模糊查询用户
|
* @param phone
|
* @return
|
*/
|
@GetMapping("/user/selectByPhoneLike")
|
public R<List<TAppUser>> selectByPhoneLike(@RequestParam("phone") String phone){
|
return R.ok(appUserService.list(Wrappers.lambdaQuery(TAppUser.class)
|
.eq(TAppUser::getPhone,phone)));
|
}
|
|
@Log(title = "【我的】签到", businessType = BusinessType.INSERT,operatorType = OperatorType.MOBILE)
|
@ApiOperation(value = "签到", tags = {"小程序-个人中心-签到"})
|
@GetMapping(value = "/user/sign")
|
public R sign() {
|
LoginUserApplet loginUserApplet = tokenService.getLoginUserApplet();
|
Long userId = loginUserApplet.getUserId();
|
TAppUser byId = appUserService.getById(userId);
|
if (signService.lambdaQuery().eq(TAppUserSign::getSignDay, LocalDate.now()).eq(TAppUserSign::getAppUserId, userId).count()>0){
|
return R.fail("今日已签到");
|
}
|
//判断当前生效的vipDetail
|
TAppUserVipDetail one = tAppUserVipDetailService.lambdaQuery().le(TAppUserVipDetail::getStartTime, LocalDateTime.now()).ge(TAppUserVipDetail::getEndTime, LocalDateTime.now()).eq(TAppUserVipDetail::getAppUserId, userId).last("limit 1").one();
|
boolean doubleVip = false;
|
if (one!=null){
|
TVip tVip = JSONObject.parseObject(one.getVipJson(), TVip.class);
|
if (tVip.getDoubleIntegration()!=null&&tVip.getDoubleIntegration()==1){
|
doubleVip = true;
|
}
|
}
|
|
//签到业务
|
TAppUserSign appUserSign = new TAppUserSign();
|
appUserSign.setSignDay(LocalDate.now());
|
appUserSign.setRewardPoints(2);
|
appUserSign.setCreateTime(LocalDateTime.now());
|
appUserSign.setAppUserId(userId);
|
signService.save(appUserSign);
|
//签到加积分记录
|
R<TIntegralRule> set = integralRuleClient.getSet();
|
TIntegralRule data = set.getData();
|
JSONObject jsonObject = JSON.parseObject(data.getSignInForPoints());
|
//增加每日积分
|
Integer points = 0;
|
Integer point = jsonObject.getInteger("num1");
|
points= points+point;
|
if (doubleVip){
|
points= points+point;
|
}
|
JSONArray num2 = jsonObject.getJSONArray("num2");
|
if (num2!=null) {
|
//获取连续签到的规则放入map
|
Map<Integer,Integer> map = new HashMap<>();
|
for (Object o : num2) {
|
String o1 = (String) o;
|
String[] split = o1.split(",");
|
map.put(Integer.parseInt(split[0]), Integer.parseInt(split[1]));
|
}
|
//加上今日签到，计算连续了多少天，如果到达就增加奖励的分数
|
int days = signDayUtil.calculateContinuousSignDays(userId);
|
Integer i = map.get(days);
|
if (i!=null){
|
points= points+i;
|
if (doubleVip){
|
points= points+i;
|
}
|
appUserSign.setIsGift(1);
|
signService.updateById(appUserSign);
|
}
|
}
|
pointDetailUtil.addDetail(byId.getPoints(),byId.getPoints()+points,1,userId,"每日签到","JF","");
|
byId.setPoints(byId.getPoints()+points);
|
appUserService.updateById(byId);
|
return R.ok();
|
}
|
|
|
@ApiOperation(value = "本月已签到日期", tags = {"小程序-个人中心-签到"})
|
@GetMapping(value = "/user/has/sign")
|
public R<List<TAppUserSign>> hasSign() {
|
Long userId = tokenService.getLoginUserApplet().getUserId();
|
DateTime startOfMonth = DateUtil.beginOfMonth(new Date());
|
DateTime endOfMonth = DateUtil.endOfMonth(new Date());
|
// 获取用户的所有签到记录
|
List<TAppUserSign> signRecords = signService.lambdaQuery()
|
.between(TAppUserSign::getSignDay, startOfMonth, endOfMonth)
|
.eq(TAppUserSign::getAppUserId, userId)
|
.orderByDesc(TAppUserSign::getSignDay)
|
.list();
|
for (TAppUserSign signRecord : signRecords) {
|
int i = signDayUtil.calculateContinuousSignDays1(signRecord.getAppUserId(), signRecord.getSignDay());
|
signRecord.setContinueDays(i);
|
}
|
return R.ok(signRecords);
|
|
}
|
|
|
|
@ApiOperation(value = "本月已连续签到天数", tags = {"小程序-个人中心-签到"})
|
@GetMapping(value = "/user/continue/sign")
|
public R continueSign() {
|
Long userId = tokenService.getLoginUserApplet().getUserId();
|
int days = signDayUtil.calculateContinuousSignDays(userId);
|
return R.ok(days);
|
}
|
|
|
|
//积分变化记录用
|
// @PostMapping(value = "/user/points/change")
|
// public R change(@RequestBody PointChangeDto points) {
|
// TAppUser byId = appUserService.getById(points.getUserId());
|
// pointDetailUtil.addDetail(byId.getPoints(),byId.getPoints()+points.getPoints(),points.getType(),points.getUserId(),points.getRemark(),"JF");
|
// byId.setPoints(byId.getPoints()+points.getPoints());
|
// appUserService.updateById(byId);
|
// return R.ok();
|
// }
|
|
@PostMapping(value = "/user/points/change/down")
|
public R changeDown(@RequestBody PointChangeDto points) {
|
TAppUser byId = appUserService.getById(points.getUserId());
|
pointDetailUtil.addDetail(byId.getPoints(),byId.getPoints()-points.getPoints(),points.getType(),points.getUserId(),points.getRemark(),"JF",points.getCode());
|
byId.setPoints(byId.getPoints()-points.getPoints());
|
appUserService.updateById(byId);
|
return R.ok();
|
}
|
|
|
@Log(title = "【我的】添加编辑车辆", businessType = BusinessType.INSERT,operatorType = OperatorType.MOBILE)
|
@ApiOperation(value = "添加编辑车辆", tags = {"小程序-个人中心-车辆"})
|
@PostMapping(value = "/user/car/addOrUpdate")
|
public R carAdd(@RequestBody TAppUserCar appUserCar) {
|
if(null != appUserCar.getId()){
|
TAppUserCar userCar = appUserCarService.getById(appUserCar.getId());
|
Long userId = tokenService.getLoginUserApplet().getUserId();
|
if(!userCar.getAppUserId().equals(userId)){
|
return R.fail("权限不足");
|
}
|
}
|
LoginUserApplet loginUserApplet = tokenService.getLoginUserApplet();
|
Long userId = loginUserApplet.getUserId();
|
TAppUser byId = appUserService.getById(userId);
|
appUserCar.setAppUserId(userId);
|
|
//判断当前生效的vipDetail
|
TAppUserVipDetail one = tAppUserVipDetailService.lambdaQuery().le(TAppUserVipDetail::getStartTime, LocalDateTime.now()).ge(TAppUserVipDetail::getEndTime, LocalDateTime.now()).eq(TAppUserVipDetail::getAppUserId, userId).last("limit 1").one();
|
boolean doubleVip = false;
|
if (one!=null){
|
TVip tVip = JSONObject.parseObject(one.getVipJson(), TVip.class);
|
if (tVip.getDoubleIntegration()!=null&&tVip.getDoubleIntegration()==1){
|
doubleVip = true;
|
}
|
}
|
|
//如果是第一次添加车辆，增加积分
|
Long count = appUserCarService.lambdaQuery().eq(TAppUserCar::getAppUserId, userId).count();
|
|
|
if (count==0){
|
R<TIntegralRule> set = integralRuleClient.getSet();
|
TIntegralRule data = set.getData();
|
if(null != data){
|
JSONObject jsonObject = JSON.parseObject(data.getAddVehiclesEarnsPoints());
|
Integer point = 0;
|
//增加车牌50分，必填
|
point = point+jsonObject.getInteger("num1");
|
if (doubleVip){
|
point = point+jsonObject.getInteger("num1");
|
}
|
//增加车型分
|
if (StringUtils.isNotEmpty(appUserCar.getVehicleModel())){
|
point = point+jsonObject.getInteger("num2");
|
if (doubleVip){
|
point = point+jsonObject.getInteger("num2");
|
}
|
}
|
//增加车辆用途分
|
if (StringUtils.isNotEmpty(appUserCar.getVehicleUse())){
|
point = point+jsonObject.getInteger("num3");
|
if (doubleVip){
|
point = point+jsonObject.getInteger("num3");
|
}
|
}
|
//增加续航分
|
if (StringUtils.isNotEmpty(appUserCar.getEndurance())){
|
point = point+jsonObject.getInteger("num4");
|
if (doubleVip){
|
point = point+jsonObject.getInteger("num4");
|
}
|
}
|
|
//增加积分记录
|
pointDetailUtil.addDetail(byId.getPoints(),byId.getPoints()+point,5,userId,appUserCar.getLicensePlate(),"","");
|
byId.setPoints(byId.getPoints()+point);
|
}
|
byId.setFirstAdd(1);
|
}
|
CarNumDto carNumDto = CarUtil.carNum(appUserCar.getLicensePlate());
|
if (carNumDto==null){
|
return R.fail("请输入正确的车牌");
|
}
|
|
byId.setCityCode(carNumDto.getAreaCode());
|
byId.setProvinceCode(carNumDto.getAreaCode().substring(0,2)+"0000");
|
appUserService.updateById(byId);
|
|
//
|
appUserCarService.saveOrUpdate(appUserCar);
|
|
return R.ok();
|
}
|
|
@Log(title = "【我的】添加编辑车辆", businessType = BusinessType.INSERT,operatorType = OperatorType.MOBILE)
|
@ApiOperation(value = "添加编辑车辆", tags = {"小程序-个人中心-车辆"})
|
@GetMapping(value = "/user/car/delete")
|
public R carDelete(String id) {
|
TAppUserCar appUserCar = appUserCarService.getById(id);
|
Long userId = tokenService.getLoginUserApplet().getUserId();
|
if(!appUserCar.getAppUserId().equals(userId)){
|
return R.fail("权限不足");
|
}
|
boolean b = appUserCarService.removeById(id);
|
return R.ok();
|
}
|
|
|
@ApiOperation(value = "车辆详情", tags = {"小程序-个人中心-车辆"})
|
@GetMapping(value = "/user/car/detail")
|
public R<TAppUserCar> carDetail(String id) {
|
TAppUserCar byId = appUserCarService.getById(id);
|
Long userId = tokenService.getLoginUserApplet().getUserId();
|
if(!byId.getAppUserId().equals(userId)){
|
return R.fail("权限不足");
|
}
|
return R.ok(byId);
|
}
|
|
@ApiOperation(value = "获取车辆品牌", tags = {"小程序-个人中心-车辆"})
|
@GetMapping(value = "/user/car/getBrands")
|
public R getBrands(String name) throws Exception {
|
String brand = CarBrandUtil.getBrand();
|
JSONObject jsonObject = JSON.parseObject(brand);
|
JSONArray data = jsonObject.getJSONArray("data");
|
JSONArray data1 = new JSONArray();
|
if (name!=null) {
|
for (int i = 0; i < data.size(); i++) {
|
JSONObject brand1 = data.getJSONObject(i);
|
String o = (String) brand1.get("name");
|
if (o.contains(name)) {
|
data1.add(brand1);
|
}
|
}
|
return R.ok(data1);
|
}
|
return R.ok(data);
|
|
}
|
|
|
@ApiOperation(value = "根据品牌获取车系", tags = {"小程序-个人中心-车辆"})
|
@GetMapping(value = "/user/car/getModel")
|
public R getModel(String id) throws Exception {
|
String modelById = CarBrandUtil.getModelById(id);
|
JSONObject jsonObject = JSON.parseObject(modelById);
|
Integer code = jsonObject.getInteger("code");
|
if (code==701){
|
return R.fail("当前品牌暂无分类");
|
}
|
JSONArray data = jsonObject.getJSONArray("data");
|
JSONArray backList = new JSONArray();
|
for (Object datum : data) {
|
JSONObject jsonObject1 = JSON.parseObject(datum.toString());
|
JSONArray list = jsonObject1.getJSONArray("list");
|
backList.addAll(list);
|
}
|
return R.ok(backList);
|
}
|
|
|
@ApiOperation(value = "根据车系获取车型", tags = {"小程序-个人中心-车辆"})
|
@GetMapping(value = "/user/car/getSeries")
|
public R getSeries(String id) throws Exception {
|
String modelById = CarBrandUtil.getSeriesById(id);
|
JSONObject jsonObject = JSON.parseObject(modelById);
|
JSONObject data1 = jsonObject.getJSONObject("data");
|
JSONArray data = data1.getJSONArray("list");
|
// JSONArray data = jsonObject.getJSONArray(data1.get("list").toString());
|
// JSONArray backList = new JSONArray();
|
// for (Object datum : data) {
|
// JSONObject jsonObject1 = JSON.parseObject(datum.toString());
|
// JSONArray list = jsonObject1.getJSONArray("list");
|
// backList.addAll(jsonObject1);
|
// }
|
return R.ok(data);
|
|
}
|
|
|
@ApiOperation(value = "根据车型获取详情", tags = {"小程序-个人中心-车辆"})
|
@GetMapping(value = "/user/car/getDetail")
|
public R getDetail(String id) throws Exception {
|
String detailById = CarBrandUtil.getDetailById(id);
|
JSONObject jsonObject = JSON.parseObject(detailById);
|
|
return R.ok(jsonObject.getJSONObject("data"));
|
}
|
|
|
|
|
@Log(title = "【我的】修改个人信息", businessType = BusinessType.UPDATE,operatorType = OperatorType.MOBILE)
|
@PostMapping(value = "/user/editAppUserInfo")
|
@ApiOperation(value = "修改个人信息", tags = {"小程序-个人中心"})
|
public AjaxResult editAppUserInfo(@RequestBody TAppUser appUser){
|
Long userId = tokenService.getLoginUserApplet().getUserId();
|
appUser.setId(userId);
|
appUserService.updateById(appUser);
|
return AjaxResult.success();
|
}
|
|
@PostMapping("/sendMessage")
|
public R<String> sendMessage(@RequestBody SendMessageDTO sendMessageDTO){
|
switch (sendMessageDTO.getType()){
|
case 1:
|
String reqStr1 = MsgUtil.codeMsg(sendMessageDTO.getPhone(), sendMessageDTO.getCode());
|
String result1 = HttpUtils.post(MsgConstants.SEND_URL, reqStr1);
|
return R.ok(result1);
|
case 2:
|
String reqStr2 = MsgUtil.applyCodeMsg(sendMessageDTO.getPhone(), sendMessageDTO.getCode());
|
String result2 = HttpUtils.post(MsgConstants.SEND_URL, reqStr2);
|
return R.ok(result2);
|
default:
|
String reqStr3 = MsgUtil.faultMsg(sendMessageDTO.getPhone(), sendMessageDTO.getSite(), sendMessageDTO.getChargeGun());
|
String result3 = HttpUtils.post(MsgConstants.SEND_URL, reqStr3);
|
return R.ok(result3);
|
}
|
}
|
|
|
public static void main(String[] args) {
|
// String reqStr1 = MsgUtil.codeMsg("19983174515", "123456");
|
// String result1 = HttpUtils.post(MsgConstants.SEND_URL, reqStr1);
|
|
String reqStr3 = MsgUtil.faultMsg("18398968484", "长河服务区充电站（遂", "123");
|
String result3 = HttpUtils.post(MsgConstants.SEND_URL, reqStr3);
|
System.err.println(result3);
|
}
|
|
|
@Log(title = "【我的】退出登录", businessType = BusinessType.STOP,operatorType = OperatorType.MOBILE)
|
@PostMapping(value = "/user/logOut")
|
@ApiOperation(value = "退出登录", tags = {"小程序-个人中心"})
|
public AjaxResult logOut(){
|
String token = tokenService.getLoginUserApplet().getToken();
|
redisService.deleteObject("login_tokens:" + token);
|
return AjaxResult.success();
|
}
|
|
|
|
@PostMapping("/refresh")
|
@ApiOperation(value = "刷新token过期时间", tags = {"小程序-个人中心"})
|
public R<?> refresh(HttpServletRequest request) {
|
LoginUserApplet loginUser = tokenService.getLoginUserAppletToken(request);
|
if (StringUtils.isNotNull(loginUser)) {
|
// 刷新令牌有效期
|
tokenService.refreshToken1(loginUser);
|
return R.ok();
|
}
|
return R.ok();
|
}
|
|
}
|
