From 712c080180b9e8511b4e1c26d707882a557b26c7 Mon Sep 17 00:00:00 2001
From: jiangping <jp@doumee.com>
Date: 星期三, 16 七月 2025 18:26:30 +0800
Subject: [PATCH] 前端

---
 server/services/src/main/java/com/doumee/service/business/impl/MemberServiceImpl.java |   62 ++++++++++++++++++++----------
 1 files changed, 41 insertions(+), 21 deletions(-)

diff --git a/server/services/src/main/java/com/doumee/service/business/impl/MemberServiceImpl.java b/server/services/src/main/java/com/doumee/service/business/impl/MemberServiceImpl.java
index ec42cb3..9620e6f 100644
--- a/server/services/src/main/java/com/doumee/service/business/impl/MemberServiceImpl.java
+++ b/server/services/src/main/java/com/doumee/service/business/impl/MemberServiceImpl.java
@@ -16,6 +16,7 @@
 import com.doumee.dao.business.OrdersMapper;
 import com.doumee.dao.business.model.IdentityInfo;
 import com.doumee.dao.business.model.Member;
+import com.doumee.dao.business.model.MemberRevenue;
 import com.doumee.dao.business.model.Orders;
 import com.doumee.dao.dto.WxPhoneRequest;
 import com.doumee.dao.vo.AccountResponse;
@@ -106,7 +107,16 @@
 
     @Override
     public Member findById(Integer id) {
-        return memberMapper.selectById(id);
+        Member member = memberMapper.selectById(id);
+        if(Objects.isNull(member)){
+            throw new BusinessException(ResponseStatus.DATA_EMPTY);
+        }
+        if(StringUtils.isNotBlank(member.getCoverImage())){
+            String path  = systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.RESOURCE_PATH).getCode()
+                    +systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.MEMBER_FILES).getCode();
+            member.setFullCoverImage(path + member.getCoverImage());
+        }
+        return member;
     }
 
     @Override
@@ -126,6 +136,7 @@
         IPage<Member> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
         QueryWrapper<Member> queryWrapper = new QueryWrapper<>();
         Utils.MP.blankToNull(pageWrap.getModel());
+        pageWrap.getModel().setDeleted(Constants.ZERO);
         if (pageWrap.getModel().getId() != null) {
             queryWrapper.lambda().eq(Member::getId, pageWrap.getModel().getId());
         }
@@ -153,16 +164,16 @@
             queryWrapper.lambda().eq(Member::getCoverImage, pageWrap.getModel().getCoverImage());
         }
         if (pageWrap.getModel().getOpenid() != null) {
-            queryWrapper.lambda().eq(Member::getOpenid, pageWrap.getModel().getOpenid());
+            queryWrapper.lambda().like(Member::getOpenid, pageWrap.getModel().getOpenid());
         }
         if (pageWrap.getModel().getNickName() != null) {
-            queryWrapper.lambda().eq(Member::getNickName, pageWrap.getModel().getNickName());
+            queryWrapper.lambda().like(Member::getNickName, pageWrap.getModel().getNickName());
         }
         if (pageWrap.getModel().getTelephone() != null) {
-            queryWrapper.lambda().eq(Member::getTelephone, pageWrap.getModel().getTelephone());
+            queryWrapper.lambda().like(Member::getTelephone, pageWrap.getModel().getTelephone());
         }
         if (pageWrap.getModel().getName() != null) {
-            queryWrapper.lambda().eq(Member::getName, pageWrap.getModel().getName());
+            queryWrapper.lambda().like(Member::getName, pageWrap.getModel().getName());
         }
         if (pageWrap.getModel().getWorkerIdentity() != null) {
             queryWrapper.lambda().eq(Member::getWorkerIdentity, pageWrap.getModel().getWorkerIdentity());
@@ -210,6 +221,15 @@
         if (pageWrap.getModel().getArea() != null) {
             queryWrapper.lambda().eq(Member::getArea, pageWrap.getModel().getArea());
         }
+        //濡傛灉鏌ヨ鎺ュ崟鏂�
+        queryWrapper.lambda().and(Constants.equalsInteger(pageWrap.getModel().getType(),Constants.ONE ),w1->{
+            w1.eq(Member::getWorkerIdentity,Constants.TWO )
+                    .or().eq(Member::getChefIdentity,Constants.TWO )
+                    .or().eq(Member::getDriverIdentity,Constants.TWO );
+        });
+        queryWrapper.lambda().ge(pageWrap.getModel().getStartTime()!=null, Member::getCreateTime,pageWrap.getModel().getStartTime());
+        queryWrapper.lambda().ne(pageWrap.getModel().getEndTime()!=null,Member::getCreateTime,pageWrap.getModel().getEndTime());
+
         for(PageWrap.SortData sortData: pageWrap.getSorts()) {
             if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) {
                 queryWrapper.orderByDesc(sortData.getProperty());
@@ -241,15 +261,15 @@
         if(StringUtils.isBlank(code)){
             throw new BusinessException(ResponseStatus.BAD_REQUEST);
         }
-        try {
+//        try {
             //鑾峰彇寰俊鏁忔劅鏁版嵁
-            WxMaJscode2SessionResult session = WxMiniConfig.wxMaService.getUserService().getSessionInfo(code);
-            String openId = session.getOpenid();
-            String unionId = session.getUnionid();
+//            WxMaJscode2SessionResult session = WxMiniConfig.wxMaService.getUserService().getSessionInfo(code);
+            String openId = code ;//session.getOpenid();
+//            String unionId = session.getUnionid();
             if (StringUtils.isBlank(openId)) {
                 throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "鑾峰彇openid澶辫触锛佽鑱旂郴绠$悊鍛�");
             }
-            Member member = memberMapper.selectOne(new QueryWrapper<Member>().eq("openid", openId).eq("isdeleted", Constants.ZERO).last("limit 1"));
+            Member member = memberMapper.selectOne(new QueryWrapper<Member>().eq("openid", openId).eq("DELETED", Constants.ZERO).last("limit 1"));
             AccountResponse accountResponse = new AccountResponse();
             accountResponse.setOpenid(openId);
             if(Objects.isNull(member)){
@@ -258,9 +278,9 @@
             accountResponse.setToken(jwtTokenUtil.generateToken(member));
             accountResponse.setMember(member);
             return accountResponse;
-        } catch (WxErrorException e) {
-            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "寰俊鐧诲綍寮傚父锛佽鑱旂郴绠$悊鍛�");
-        }
+//        } catch (WxErrorException e) {
+//            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "寰俊鐧诲綍寮傚父锛佽鑱旂郴绠$悊鍛�");
+//        }
     }
 
 
@@ -328,7 +348,7 @@
                 .set(StringUtils.isNotBlank(member.getNickName()),Member::getNickName,member.getNickName())
                 .set(StringUtils.isNotBlank(member.getName()),Member::getName,member.getName())
                 .set(StringUtils.isNotBlank(member.getCoverImage()),Member::getCoverImage,member.getCoverImage())
-                .set(Objects.nonNull(member.getAutoReceiveStatus()),Member::getCoverImage,member.getAutoReceiveStatus())
+                .set(Objects.nonNull(member.getAutoReceiveStatus()),Member::getAutoReceiveStatus,member.getAutoReceiveStatus())
                         .set(Member::getUpdateTime,new Date())
                 .eq(Member::getId,member.getId()));
     }
@@ -369,18 +389,18 @@
         userCenterVO.setTaskingTotal(Constants.ZERO);
         userCenterVO.setDoneTotal(Constants.ZERO);
         userCenterVO.setReceiveTotal(Constants.ZERO);
-        List<Orders> releaseOrders = ordersMapper.selectList(new QueryWrapper<Orders>().lambda().eq(Orders::getDeleted,Constants.ZERO).eq(Orders::getReleaseMemberId,member));
+        List<Orders> releaseOrders = ordersMapper.selectList(new QueryWrapper<Orders>().lambda().eq(Orders::getDeleted,Constants.ZERO).eq(Orders::getReleaseMemberId,member.getId()));
         if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(releaseOrders)){
             userCenterVO.setReleaseTaskTotal(releaseOrders.size());
-            userCenterVO.setWaitCommentTotal(releaseOrders.stream().filter(i->Constants.equalsInteger(i.getStatus(),Constants.ZERO)).collect(Collectors.toList()).size());
-            userCenterVO.setDoingTotal(releaseOrders.stream().filter(i->Constants.equalsInteger(i.getStatus(),Constants.TWO)).collect(Collectors.toList()).size());
-            userCenterVO.setWaitCommentTotal(releaseOrders.stream().filter(i->Constants.equalsInteger(i.getStatus(),Constants.THREE)&&Constants.equalsInteger(i.getCommentStatus(),Constants.ZERO)).collect(Collectors.toList()).size());
+            userCenterVO.setWaitCommentTotal(releaseOrders.stream().filter(i->Constants.equalsInteger(i.getStatus(),Constants.ordersStatus.waitPay.getKey())).collect(Collectors.toList()).size());
+            userCenterVO.setDoingTotal(releaseOrders.stream().filter(i->Constants.equalsInteger(i.getStatus(),Constants.ordersStatus.accept.getKey())).collect(Collectors.toList()).size());
+            userCenterVO.setWaitCommentTotal(releaseOrders.stream().filter(i->Constants.equalsInteger(i.getStatus(),Constants.ordersStatus.doing.getKey())&&Constants.equalsInteger(i.getCommentStatus(),Constants.ZERO)).collect(Collectors.toList()).size());
         }
-        List<Orders> acceptOrders = ordersMapper.selectList(new QueryWrapper<Orders>().lambda().eq(Orders::getDeleted,Constants.ZERO).eq(Orders::getAcceptMemberId,member));
+        List<Orders> acceptOrders = ordersMapper.selectList(new QueryWrapper<Orders>().lambda().eq(Orders::getDeleted,Constants.ZERO).eq(Orders::getAcceptMemberId,member.getId()));
         if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(acceptOrders)){
             userCenterVO.setReceiveTotal(acceptOrders.size());
-            userCenterVO.setTaskingTotal(acceptOrders.stream().filter(i->Constants.equalsInteger(i.getStatus(),Constants.TWO)).collect(Collectors.toList()).size());
-            userCenterVO.setDoneTotal(releaseOrders.stream().filter(i->Constants.equalsInteger(i.getStatus(),Constants.THREE)).collect(Collectors.toList()).size());
+            userCenterVO.setTaskingTotal(acceptOrders.stream().filter(i->Constants.equalsInteger(i.getStatus(),Constants.ordersStatus.accept.getKey())).collect(Collectors.toList()).size());
+            userCenterVO.setDoneTotal(releaseOrders.stream().filter(i->Constants.equalsInteger(i.getStatus(),Constants.ordersStatus.doing.getKey())).collect(Collectors.toList()).size());
         }
 
         userCenterVO.setAboutUs(StringUtils.trimToNull(systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.ABOUT_US).getCode()));

--
Gitblit v1.9.3