From ac33a3140ef8ef20dfd2537fce2dfdd0f374f30e Mon Sep 17 00:00:00 2001
From: MrShi <1878285526@qq.com>
Date: 星期四, 26 二月 2026 17:42:10 +0800
Subject: [PATCH] 调试
---
server/dmmall_service/src/main/java/com/doumee/service/business/impl/ShopServiceImpl.java | 234 +++++++++++++++++++++++++++++++++++-----------------------
1 files changed, 142 insertions(+), 92 deletions(-)
diff --git a/server/dmmall_service/src/main/java/com/doumee/service/business/impl/ShopServiceImpl.java b/server/dmmall_service/src/main/java/com/doumee/service/business/impl/ShopServiceImpl.java
index 0a5ea0a..e09e475 100644
--- a/server/dmmall_service/src/main/java/com/doumee/service/business/impl/ShopServiceImpl.java
+++ b/server/dmmall_service/src/main/java/com/doumee/service/business/impl/ShopServiceImpl.java
@@ -43,6 +43,7 @@
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationEventPublisher;
+import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils;
@@ -116,6 +117,9 @@
private MemberCouponService memberCouponService;
@Autowired
+ private InviteRecordService inviteRecordService;
+
+ @Autowired
private ShopNewsService shopNewsService;
@Autowired
private LabelsMapper labelsMapper;
@@ -126,9 +130,12 @@
@Autowired
private IntegralMapper integralMapper;
+ @Autowired
+ private RedisTemplate<String,Object> redisTemplate;
+
@Override
- public Integer create(Shop shop) {
+ public Integer create(Shop shop) throws Exception {
LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
isCreateParamValid(shop,user);
shop.setCreator(user.getId());
@@ -147,6 +154,20 @@
shop.setPassword(Utils.Secure.encryptPassword(shop.getPassword(), salt));
shop.setSalt(salt);
shopMapper.insert(shop);
+ //鍒嗕韩鐮�
+ String url = inviteRecordService.createShopMiniProgramCode(shop.getId());
+ if(StringUtils.isNotBlank(url)){
+ shopMapper.update(null,new UpdateWrapper<Shop>().lambda()
+ .set(Shop::getProgramCode,url)
+ .eq(Shop::getId,shop.getId()));
+ }
+ //鍒嗕韩娴锋姤
+ String posterUrl = inviteRecordService.createShareImg(Constants.ONE,shop.getId(),shop.getPosterImg());
+ if(StringUtils.isNotBlank(posterUrl)){
+ shopMapper.update(null,new UpdateWrapper<Shop>().lambda()
+ .set(Shop::getPosterImgCode,posterUrl)
+ .eq(Shop::getId,shop.getId()));
+ }
return shop.getId();
}
@@ -225,7 +246,7 @@
@Override
@Transactional
- public void updateById(Shop shop) {
+ public void updateById(Shop shop) throws Exception {
LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
if(shop.getId()==null ){
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), ResponseStatus.BAD_REQUEST.getMessage());
@@ -238,6 +259,20 @@
shop.setEditor(user.getId());
shop.setEditDate(new Date());
+ if(StringUtils.isBlank(model.getProgramCode())){
+ //鍒嗕韩鐮�
+ String url = inviteRecordService.createShopMiniProgramCode(shop.getId());
+ if(StringUtils.isNotBlank(url)){
+ shop.setProgramCode(url);
+ }
+ }
+ if(StringUtils.isNotBlank(shop.getPosterImg())){
+ //鍒嗕韩娴锋姤
+ String posterUrl = inviteRecordService.createShareImg(Constants.ONE,shop.getId(),shop.getPosterImg());
+ if(StringUtils.isNotBlank(posterUrl)){
+ shop.setPosterImgCode(posterUrl);
+ }
+ }
shopMapper.updateById(shop);
if(shop.getSaleType() !=null && !Constants.equalsInteger(shop.getSaleType(),model.getSaleType())){
//濡傛灉閿�鍞ā寮忓彂鐢熺紪鐮侊紝璁板綍鍙樻洿璁板綍
@@ -264,15 +299,15 @@
}
- @Override
- public void updateByIdInBatch(List<Shop> shops) {
- if (CollectionUtils.isEmpty(shops)) {
- return;
- }
- for (Shop shop: shops) {
- this.updateById(shop);
- }
- }
+// @Override
+// public void updateByIdInBatch(List<Shop> shops) {
+// if (CollectionUtils.isEmpty(shops)) {
+// return;
+// }
+// for (Shop shop: shops) {
+// this.updateById(shop);
+// }
+// }
@Transactional(rollbackFor = {Exception.class,BusinessException.class})
@Override
@@ -666,20 +701,20 @@
&& StringUtils.isNotBlank(dto.getLgt())){
isArea = true;
}
-
- List<Shop> shopList = shopJoinMapper.selectList(new MPJLambdaWrapper<Shop>()
+ List<Shop> shopList = shopJoinMapper.selectJoinList(Shop.class,new MPJLambdaWrapper<Shop>()
.selectAll(Shop.class)
- .select(" CONVERT( ST_Distance_Sphere ( POINT ( LONGITUDE, LATITUDE ), POINT ( "+dto.getLgt()+", "+dto.getLat()+" )) /1000,DECIMAL(15,2))",Shop::getDistance)
- .leftJoin(Areas.class,Areas::getId,Shop::getAreaId)
- .eq(Objects.nonNull(dto.getCityId()),Areas::getParentId,dto.getCityId())
- .like(Objects.nonNull(dto.getShopName()),Shop::getName,dto.getShopName())
+ .select(" CONVERT( ST_Distance_Sphere ( POINT ( LONGITUDE, LATITUDE ), POINT ( '"+dto.getLgt()+"' , '"+dto.getLat()+"' )) /1000,DECIMAL(15,2))",Shop::getDistance)
+ .leftJoin(SystemUser.class,SystemUser::getId,Shop::getCreator)
+ .like(StringUtils.isNotBlank(dto.getCityName()),Shop::getAddr,dto.getCityName())
+ .like(StringUtils.isNotBlank(dto.getShopName()),Shop::getName,dto.getShopName())
.orderByDesc(!isArea,Shop::getId)
- .orderByAsc(isArea,Shop::getDistance)
+ .orderByAsc(isArea," distance ")
);
String path = systemDictDataBiz.queryByCode(Constants.OSS, Constants.RESOURCE_PATH).getCode()
+ systemDictDataBiz.queryByCode(Constants.OSS, Constants.SHOP_FILE).getCode();
for(Shop model:shopList){
- model.setImgFullUrl(path+model.getImgurl());
+
+ model.setImgFullUrl(StringUtils.isNotBlank(model.getImgurl())?path+model.getImgurl():null);
}
return shopList;
@@ -694,6 +729,11 @@
*/
@Override
public AccountResponse shopOpenidLogin(ShopLoginDTO dto){
+ if(Objects.isNull(dto)
+ || StringUtils.isBlank(dto.getOpenid())
+ ){
+ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"闈欓粯鐧诲綍澶辫触锛岃鑱旂郴绠＄悊鍛�");
+ }
Shop shop = shopMapper.selectOne(new QueryWrapper<Shop>().lambda().eq(Shop::getOpenId, dto.getOpenid())
.eq(Shop::getIsdeleted,Constants.ZERO)
.last("limit 1")
@@ -701,17 +741,9 @@
AccountResponse accountResponse = new AccountResponse();
accountResponse.setOpenid(dto.getOpenid());
if(Objects.nonNull(shop)){
- if(Objects.isNull(dto.getMemberId())
- && ( Objects.isNull(shop.getMemberId())
- || !Constants.equalsInteger(shop.getMemberId(),dto.getMemberId()))){
- shopMapper.update(null,new UpdateWrapper<Shop>().lambda()
- .set(Shop::getMemberId,dto.getMemberId())
- .eq(Shop::getId,shop.getId())
- );
- }
- JwtPayLoad payLoad = new JwtPayLoad(Constants.SHOP_PREFIX+shop.getId());
- String token = JwtTokenUtil.generateToken(payLoad);
+ String token = JwtTokenUtil.generateTokenForRedis(shop.getId(), Constants.ONE, JSONObject.toJSONString(shop), redisTemplate);
accountResponse.setToken(token);
+ accountResponse.setShop(this.getShopResponseInfo(shop));
}
return accountResponse;
}
@@ -726,7 +758,6 @@
public AccountResponse shopPasswordLogin(ShopLoginDTO dto){
if(StringUtils.isBlank(dto.getUserName())
|| StringUtils.isBlank(dto.getPassword())
- || StringUtils.isBlank(dto.getOpenid())
){
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鐢ㄦ埛鍚嶆垨瀵嗙爜涓嶈兘涓虹┖");
}
@@ -743,20 +774,24 @@
throw new BusinessException(ResponseStatus.ACCOUNT_INCORRECT);
}
//鍒涘缓token
- JwtPayLoad payLoad = new JwtPayLoad(Constants.SHOP_PREFIX+shop.getId());
- String token = JwtTokenUtil.generateToken(payLoad);
+// JwtPayLoad payLoad = new JwtPayLoad(Constants.SHOP_PREFIX+shop.getId());
+// String token = JwtTokenUtil.generateToken(payLoad);
+ String token = JwtTokenUtil.generateTokenForRedis(shop.getId(), Constants.ONE, JSONObject.toJSONString(shop), redisTemplate);
AccountResponse accountResponse = new AccountResponse();
accountResponse.setToken(token);
- shopMapper.update(null,new UpdateWrapper<Shop>().lambda()
- .set(Shop::getOpenId,dto.getOpenid())
- .set(Shop::getMemberId,dto.getMemberId())
- .eq(Shop::getId,shop.getId())
- );
- shopMapper.update(null,new UpdateWrapper<Shop>().lambda()
- .set(Shop::getOpenId,null)
- .eq(Shop::getOpenId,dto.getOpenid())
- .ne(Shop::getId,shop.getId())
- );
+ accountResponse.setShop(this.getShopResponseInfo(shop));
+
+ if(StringUtils.isNotBlank(dto.getOpenid())){
+ shopMapper.update(null,new UpdateWrapper<Shop>().lambda()
+ .set(Shop::getOpenId,dto.getOpenid())
+ .eq(Shop::getId,shop.getId())
+ );
+ shopMapper.update(null,new UpdateWrapper<Shop>().lambda()
+ .set(Shop::getOpenId,null)
+ .eq(Shop::getOpenId,dto.getOpenid())
+ .ne(Shop::getId,shop.getId())
+ );
+ }
return accountResponse;
}
@@ -765,49 +800,62 @@
@Override
public ShopInfoResponse getShopInfo(Integer shopId){
- ShopInfoResponse response = new ShopInfoResponse();
+
Shop shop = shopMapper.selectById(shopId);
if(Objects.isNull(shop)){
throw new BusinessException(ResponseStatus.DATA_EMPTY);
}
- String path = systemDictDataBiz.queryByCode(Constants.OSS, Constants.RESOURCE_PATH).getCode()
- + systemDictDataBiz.queryByCode(Constants.OSS, Constants.SHOP_FILE).getCode();
- BeanUtils.copyProperties(shop,response);
- response.setImgurl(path + shop.getImgurl());
- response.setIdcardImg(path + shop.getIdcardImg());
- response.setIdcardImgBack(path + shop.getIdcardImgBack());
- response.setBusinessImg(path + shop.getBusinessImg());
+ return this.getShopResponseInfo(shop) ;
+ }
+
+ public ShopInfoResponse getShopResponseInfo(Shop shop){
+ ShopInfoResponse response = new ShopInfoResponse();
+ String path = systemDictDataBiz.queryByCode(Constants.OSS, Constants.RESOURCE_PATH).getCode() ;
+ String shopFile = systemDictDataBiz.queryByCode(Constants.OSS, Constants.SHOP_FILE).getCode();
+ BeanUtils.copyProperties(shop,response);
+ response.setImgurl(StringUtils.isNotBlank(shop.getImgurl())?(path + shopFile + shop.getImgurl()):"");
+ response.setIdcardImg(StringUtils.isNotBlank(shop.getIdcardImg())?(path + shopFile + shop.getIdcardImg()):"");
+ response.setIdcardImgBack(StringUtils.isNotBlank(shop.getIdcardImgBack())?(path + shopFile + shop.getIdcardImgBack()):"");
+ response.setBusinessImg(StringUtils.isNotBlank(shop.getBusinessImg())?(path + shopFile + shop.getBusinessImg()):"");
+ response.setAreas(AreasServiceImpl.getAddressByAreaId(shop.getAreaId()));
+ if(StringUtils.isNotBlank(shop.getProgramCode())){
+ String sharesFile = systemDictDataBiz.queryByCode(Constants.OSS, Constants.SHARES_FILE).getCode();
+ response.setProgramCode(path + sharesFile + shop.getProgramCode());
+ }
+ if(StringUtils.isNotBlank(shop.getPosterImgCode())){
+ String sharesFile = systemDictDataBiz.queryByCode(Constants.OSS, Constants.SHARES_FILE).getCode();
+ response.setPosterImgCode(path + sharesFile + shop.getPosterImgCode());
+ }
return response;
}
+
+
@Override
- public List<MyCustomerResponse> myCustomer(MyCustomerRequest request, Integer shopId){
- List<Member> memberList = memberJoinMapper.selectJoinList(Member.class,
- new MPJLambdaWrapper<Member>()
- .selectAll(Member.class)
- .eq(Member::getIsdeleted,Constants.ZERO)
- .eq(Member::getBindShopId,shopId)
- .and(StringUtils.isNotBlank(request.getMemberIfo()),i->i.like(Member::getPhone,request.getMemberIfo()).or().like(Member::getNickname,request.getMemberIfo()))
+ public PageData<Member> myCustomer(PageWrap<MyCustomerRequest> pageWrap, Integer shopId){
+ IPage<Member> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
+ Utils.MP.blankToNull(pageWrap.getModel());
+ MyCustomerRequest model = pageWrap.getModel();
+
+ IPage<Member> result = memberJoinMapper.selectJoinPage(page,Member.class, new MPJLambdaWrapper<Member>()
+ .selectAll(Member.class)
+ .eq(Member::getIsdeleted,Constants.ZERO)
+ .eq(Member::getBindShopId,shopId)
+ .and(StringUtils.isNotBlank(model.getMemberInfo()),i->i.like(Member::getPhone,model.getMemberInfo()).or().like(Member::getNickname,model.getMemberInfo()))
);
- List<MyCustomerResponse> responseList = new ArrayList<>();
- if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(memberList)){
+
+ if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(result.getRecords())){
String path = systemDictDataBiz.queryByCode(Constants.OSS, Constants.RESOURCE_PATH).getCode()
+ systemDictDataBiz.queryByCode(Constants.OSS, Constants.MEMBER_FILE).getCode();
- memberList.forEach(member -> {
- MyCustomerResponse response = new MyCustomerResponse();
- response.setNickName(member.getNickname());
- response.setPhone(member.getPhone().replaceAll("(\\d{3})\\d{4}(\\d{4})","$1****$2"));
- response.setBindShopDate(member.getBindShopDate());
- response.setImgFullUrl(StringUtils.isNotBlank(member.getImgurl())?path + member.getImgurl():"");
- responseList.add(response);
+ result.getRecords().forEach(member -> {
+ member.setPhone(member.getPhone().replaceAll("(\\d{3})\\d{4}(\\d{4})","$1****$2"));
+ member.setImgFullUrl(StringUtils.isNotBlank(member.getImgurl())?path + member.getImgurl():"");
});
}
- return responseList;
+ return PageData.from(result);
}
-
-
@Override
public SaleReportResponse saleReport(SaleReportRequest request,Integer shopId){
@@ -825,39 +873,23 @@
.eq(Goodsorder::getIsdeleted,Constants.ZERO)
.eq(Goodsorder::getDistributionShopId,shopId)
//浠婃棩
- .apply(Constants.equalsInteger(request.getDateType(),Constants.ZERO), " DATE(t.CREATE_DATE) = DATE(NOW()) ")
+ .apply(Objects.nonNull(request.getDateType())&&Constants.equalsInteger(request.getDateType(),Constants.ZERO), " DATE(t.CREATE_DATE) = DATE(NOW()) ")
//褰撴湀
- .apply(Constants.equalsInteger(request.getDateType(),Constants.ONE), " DATE_FORMAT(t.CREATE_DATE, '%Y-%m') = DATE_FORMAT(NOW(), '%Y-%m')")
+ .apply(Objects.nonNull(request.getDateType())&&Constants.equalsInteger(request.getDateType(),Constants.ONE), " DATE_FORMAT(t.CREATE_DATE, '%Y-%m') = DATE_FORMAT(NOW(), '%Y-%m')")
//涓婃湀
- .apply(Constants.equalsInteger(request.getDateType(),Constants.TWO), " DATE_FORMAT(t.CREATE_DATE, '%Y-%m') = DATE_FORMAT(DATE_SUB(CURDATE(), INTERVAL 1 MONTH), '%Y-%m') ")
+ .apply(Objects.nonNull(request.getDateType())&&Constants.equalsInteger(request.getDateType(),Constants.TWO), " DATE_FORMAT(t.CREATE_DATE, '%Y-%m') = DATE_FORMAT(DATE_SUB(CURDATE(), INTERVAL 1 MONTH), '%Y-%m') ")
//鍥哄畾鏈堜唤
- .apply(Constants.equalsInteger(request.getDateType(),Constants.THREE)&&StringUtils.isNotBlank(request.getStartDate()), " DATE_FORMAT(t.CREATE_DATE, '%Y-%m') = DATE_FORMAT(DATE_SUB('"+request.getStartDate()+"', INTERVAL 1 MONTH), '%Y-%m') ")
+ .apply(Objects.nonNull(request.getDateType())&&Constants.equalsInteger(request.getDateType(),Constants.THREE)&&StringUtils.isNotBlank(request.getStartDate()), " DATE_FORMAT(t.CREATE_DATE, '%Y-%m') = DATE_FORMAT(DATE_SUB('"+request.getStartDate()+"', INTERVAL 1 MONTH), '%Y-%m') ")
//鑷畾涔夋棩鏈�
- .apply(Constants.equalsInteger(request.getDateType(),Constants.FOUR)&&StringUtils.isNotBlank(request.getStartDate()), " t.CREATE_DATE >= '"+request.getStartDate()+" 00:00:00'")
- .apply(Constants.equalsInteger(request.getDateType(),Constants.FOUR)&&StringUtils.isNotBlank(request.getEndDate()), " t.CREATE_DATE <= '"+request.getEndDate()+" 23:59:59'")
+ .apply(Objects.nonNull(request.getDateType())&&Constants.equalsInteger(request.getDateType(),Constants.FOUR)&&StringUtils.isNotBlank(request.getStartDate()), " t.CREATE_DATE >= '"+request.getStartDate()+" 00:00:00'")
+ .apply(Objects.nonNull(request.getDateType())&&Constants.equalsInteger(request.getDateType(),Constants.FOUR)&&StringUtils.isNotBlank(request.getEndDate()), " t.CREATE_DATE <= '"+request.getEndDate()+" 23:59:59'")
.ne(Goodsorder::getStatus,Constants.OrderStatus.CLOSE.getKey())
.orderByDesc(Goodsorder::getId)
);
+
if (com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(goodsorderList)) {
saleReportResponse.setSaleTotal(goodsorderList.stream().map(i->i.getPrice().subtract(i.getMailPrice())).reduce(BigDecimal.ZERO, BigDecimal::add));
saleReportResponse.setOrderNum(goodsorderList.size());
- if(Constants.equalsInteger(request.getQueryType(),Constants.ONE)){
- List<SaleReportOrderResponse> list = new ArrayList<>();
- goodsorderList.stream().forEach(goodsorder -> {
- SaleReportOrderResponse response = new SaleReportOrderResponse();
- response.setId(goodsorder.getId());
- response.setCode(goodsorder.getCode());
- response.setPrice(goodsorder.getPrice());
- response.setMailPrice(goodsorder.getMailPrice());
- response.setCreateDate(goodsorder.getCreateDate());
- response.setNickName(goodsorder.getNickName());
- response.setPhone(goodsorder.getPhone().replaceAll("(\\d{3})\\d{4}(\\d{4})", "$1****$2"));
- response.setShopSettlement(goodsorder.getShopSettlement());
- list.add(response);
- });
-
- saleReportResponse.setSaleReportOrderResponseList(list);
- }
}
List<Integral> integralList = integralMapper.selectList(new QueryWrapper<Integral>().lambda()
.eq(Integral::getIsdeleted,Constants.ZERO)
@@ -923,4 +955,22 @@
shopGoodsRelationMapper.insert(add);
return "鎿嶄綔鎴愬姛";
}
+
+
+ @Override
+ public void logOut(String token,Integer shopId){
+ Shop shop = shopMapper.selectById(shopId);
+ if(Objects.nonNull(shop)&&StringUtils.isNotBlank(shop.getOpenId())){
+ shopMapper.update(new UpdateWrapper<Shop>().lambda()
+ .set(Shop::getOpenId,null)
+ .eq(Shop::getId,shop.getId())
+ );
+ }
+ redisTemplate.delete(token);
+ }
+
+
+
+
+
}
--
Gitblit v1.9.3