From f10a7c29f1a3748b28d2809335625c7888473b26 Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期一, 22 九月 2025 22:21:19 +0800
Subject: [PATCH] Merge branch '2.0' of http://120.76.84.145:10101/gitblit/r/java/HongRuiTang into 2.0
---
ruoyi-modules/ruoyi-member/src/main/java/com/ruoyi/member/service/impl/member/MemberServiceImpl.java | 64 +++++++++++++++++++++++++++-----
1 files changed, 54 insertions(+), 10 deletions(-)
diff --git a/ruoyi-modules/ruoyi-member/src/main/java/com/ruoyi/member/service/impl/member/MemberServiceImpl.java b/ruoyi-modules/ruoyi-member/src/main/java/com/ruoyi/member/service/impl/member/MemberServiceImpl.java
index c8a2f2e..12f1569 100644
--- a/ruoyi-modules/ruoyi-member/src/main/java/com/ruoyi/member/service/impl/member/MemberServiceImpl.java
+++ b/ruoyi-modules/ruoyi-member/src/main/java/com/ruoyi/member/service/impl/member/MemberServiceImpl.java
@@ -31,6 +31,7 @@
import com.ruoyi.member.service.member.MemberTotalService;
import com.ruoyi.member.util.HttpUtils;
import com.ruoyi.member.util.MsgUtils;
+import com.ruoyi.member.util.OBSUploadUtils;
import com.ruoyi.system.api.constant.AppErrorConstant;
import com.ruoyi.system.api.constant.SecurityConstant;
import com.ruoyi.system.api.domain.dto.*;
@@ -51,6 +52,7 @@
import org.apache.http.HttpResponse;
import org.apache.http.util.EntityUtils;
import org.springframework.stereotype.Service;
+import org.springframework.util.Base64Utils;
import org.springframework.util.FileCopyUtils;
import org.springframework.web.multipart.MultipartFile;
@@ -283,10 +285,10 @@
member.setCreateTime(new Date());
member.setMobile(mobile);
initMemberTotal(memberId);
- log.info("sysUser01-----------------" + sysUser.toString());
+// log.info("sysUser01-----------------" + sysUser.toString());
} else {
sysUser = sysUserService.getSysUser(member.getUserId()).getData();
- log.info("sysUser02-----------------" + sysUser.toString());
+// log.info("sysUser02-----------------" + sysUser.toString());
}
member.setWxUnionid(appUserRegisterDto.getWxUnionid());
member.setMiniOpenid(appUserRegisterDto.getMiniOpenid());
@@ -431,6 +433,40 @@
merMemberPageDto.setSurpStartNum(10);
merMemberPageDto.setSurpEndNum(999999999);
}
+ }
+ //今日到店用户
+ if(null != merMemberPageDto.getIsTodayStore() && 1 == merMemberPageDto.getIsTodayStore()){
+ List<Integer> data = remoteOrderService.countShopServicePerson(merMemberPageDto.getShopId()).getData();
+ if(data.isEmpty()){
+ data.add(-1);
+ }
+ merMemberPageDto.setUserIds(data);
+ }
+ //有未跟进的任务用户
+ if(null != merMemberPageDto.getIsTask() && 1 == merMemberPageDto.getIsTask()){
+ List<Integer> data = remoteShopService.getMemberIngTotal(merMemberPageDto.getShopId()).getData();
+ if(data.isEmpty()){
+ data.add(-1);
+ }
+ merMemberPageDto.setUserIds(data);
+ }
+ //剩余周期人数
+ if(null != merMemberPageDto.getResiduePeriod() && 1 == merMemberPageDto.getResiduePeriod()){
+ Set<Long> data = remoteOrderService.getConsumerGoodsResidueUserId(merMemberPageDto.getShopId(), 1).getData();
+ List<Integer> collect = data.stream().map(s -> Integer.valueOf(s.intValue())).collect(Collectors.toList());
+ if(collect.isEmpty()){
+ collect.add(-1);
+ }
+ merMemberPageDto.setUserIds(collect);
+ }
+ //剩余体验人数
+ if(null != merMemberPageDto.getResidueExperience() && 1 == merMemberPageDto.getResidueExperience()){
+ Set<Long> data = remoteOrderService.getConsumerGoodsResidueUserId(merMemberPageDto.getShopId(), 3).getData();
+ List<Integer> collect = data.stream().map(s -> Integer.valueOf(s.intValue())).collect(Collectors.toList());
+ if(collect.isEmpty()){
+ collect.add(-1);
+ }
+ merMemberPageDto.setUserIds(collect);
}
List<MerMemberPageVo> merMemberPageVoList = memberMapper.pageMerMember(page, merMemberPageDto);
//处理活跃度返回
@@ -950,7 +986,8 @@
merMemberPageDto.setStartBirthday(startBirthday.format(formatter));
}
// 获取当前登陆人的可视权限
- SysUser sysUser = SecurityUtils.getSysUser();
+ SysUser sysUserId = SecurityUtils.getSysUser();
+ SysUser sysUser = sysUserService.getSysUser(sysUserId.getUserId()).getData();
// 店铺ids
List<Long> scope = new ArrayList<>();
if (sysUser!=null){
@@ -2171,7 +2208,7 @@
integralRecord.setUserId(integralChangeDto.getUserId());
integralRecord.setChangeType(integralType);
integralRecord.setCreateTime(new Date());
- //1分享获取2平台建议获取3门店建议获取4每日签到5消费得积分
+ //1分享获取2平台建议获取3门店建议获取4每日签到5消费得积分6抽奖获得积分
switch(integralType){
case 1:
changeIntegral = appOtherConfigGetVo.getShareIntegral();
@@ -2213,6 +2250,16 @@
integralRecord.setChangeIntegral(changeIntegral);
integralRecord.setSurpIntegral(memberTotal.getUseableIntegral()+changeIntegral);
integralRecord.setChangeReason("订单【"+integralChangeDto.getOrderNo()+"】获得积分");
+ integralRecord.setOrderId(integralChangeDto.getOrderId());
+ integralRecord.setOrderNo(integralChangeDto.getOrderNo());
+ memberTotal.setTotalIntegral(memberTotal.getTotalIntegral()+changeIntegral);
+ memberTotal.setUseableIntegral(memberTotal.getUseableIntegral()+changeIntegral);
+ memberTotal.setBuyFlag(1);
+ break;
+ case 6:
+ integralRecord.setChangeIntegral(changeIntegral);
+ integralRecord.setSurpIntegral(memberTotal.getUseableIntegral()+changeIntegral);
+ integralRecord.setChangeReason("抽奖获得积分");
integralRecord.setOrderId(integralChangeDto.getOrderId());
integralRecord.setOrderNo(integralChangeDto.getOrderNo());
memberTotal.setTotalIntegral(memberTotal.getTotalIntegral()+changeIntegral);
@@ -2310,12 +2357,9 @@
@Override
public String getWeiXinQrCode(String scene, String path) {
try {
- File file = wxMaService.getQrcodeService().createWxaCodeUnlimit(scene, path);
- FileInputStream input = new FileInputStream(file);
- MultipartFile multipartFile = new MyMultipartFile("file", file.getName(), "text/plain", IOUtils.toByteArray(input));
-
- SysFile sysFile = remoteFileService.upload(multipartFile).getData();
- return sysFile.getUrl();
+ File file = wxMaService.getQrcodeService().createQrcode(path + "?" + scene);
+ String url = OBSUploadUtils.uploadLocalFile(file);
+ return url;
} catch (Exception e) {
e.printStackTrace();
}
--
Gitblit v1.7.1