From 3af254f1b36e7722673fcebe110da524b276105c Mon Sep 17 00:00:00 2001
From: jiangping <jp@doumee.com>
Date: 星期一, 30 十二月 2024 17:56:04 +0800
Subject: [PATCH] 最新版本541200007

---
 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/SmsEmailServiceImpl.java |   64 ++++++++++++++++++++++++++++----
 1 files changed, 56 insertions(+), 8 deletions(-)

diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/SmsEmailServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/SmsEmailServiceImpl.java
index 914e063..502ea87 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/SmsEmailServiceImpl.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/SmsEmailServiceImpl.java
@@ -13,15 +13,19 @@
 import com.doumee.core.utils.*;
 import com.doumee.core.wx.wxPlat.WxPlatNotice;
 import com.doumee.dao.business.*;
+import com.doumee.dao.business.dao.MemberMapper;
 import com.doumee.dao.business.dao.SmsConfigMapper;
 import com.doumee.dao.business.dao.SmsEmailMapper;
 import com.doumee.dao.business.join.VisitsJoinMapper;
 import com.doumee.dao.business.model.*;
 import com.doumee.dao.business.model.vo.ValidPhoneCodeVO;
+import com.doumee.dao.business.model.Member;
+import com.doumee.dao.system.SystemUserMapper;
 import com.doumee.dao.system.model.SystemUser;
 import com.doumee.service.business.SmsEmailService;
 import com.doumee.service.business.third.EmayService;
 import com.github.yulichang.wrapper.MPJLambdaWrapper;
+import org.apache.commons.lang3.RandomStringUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
@@ -42,6 +46,10 @@
 
     @Autowired
     private SmsEmailMapper smsEmailMapper;
+    @Autowired
+    private SystemUserMapper systemUserMapper;
+    @Autowired
+    private MemberMapper memberMapper;
     @Autowired
     private SystemDictDataBiz systemDictDataBiz;
     @Autowired
@@ -84,6 +92,45 @@
     public     void validPhoneCaptcha(ValidPhoneCodeVO param){
        isCaptcheValide(smsEmailMapper,param.getPhone(),param.getCode());
     }
+    @Override
+    public   SystemUser validDriverPhone(ValidPhoneCodeVO param){
+          isCaptcheValide(smsEmailMapper,param.getPhone(),param.getCode());
+
+        SystemUser systemUser = systemUserMapper.selectOne(new QueryWrapper<SystemUser>().lambda()
+                .eq(SystemUser::getDeleted,Constants.ZERO)
+                .and(i->i.eq(SystemUser::getMobile,param.getPhone()).or().eq(SystemUser::getUsername,param.getPhone()))
+                .last("limit 1"));
+       if(systemUser !=null){
+           return  systemUser;
+       }
+        String salt = RandomStringUtils.randomAlphabetic(6);
+        Member member = new Member();
+        member.setCreateDate(new Date());
+        member.setIsdeleted(Constants.ZERO);
+        member.setType(Constants.memberType.driver);
+        member.setPhone(param.getPhone());
+        member.setStatus(Constants.ZERO);
+        member.setOpenid(param.getOpenId());
+        member.setPassward(Utils.Secure.encryptPassword(systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.INITIAL_PASSWORD).getCode(), salt));
+        memberMapper.insert(member);
+
+        systemUser = new SystemUser();
+        systemUser.setCreateTime(new Date());
+        systemUser.setDeleted(Boolean.FALSE);
+        systemUser.setUsername(param.getPhone());
+        systemUser.setRealname(null);
+        systemUser.setMemberId(member.getId());
+        systemUser.setMobile(param.getPhone());
+        systemUser.setSalt(salt);
+        systemUser.setPassword(member.getPassward());
+        systemUser.setStatus(Constants.ZERO);
+        systemUser.setType(Constants.memberType.driver);
+        systemUser.setSource(Constants.TWO);
+        systemUser.setOpenid(param.getOpenId());
+        systemUserMapper.insert(systemUser);
+        return systemUser;
+    }
+
     @Override
     public Integer create(SmsEmail smsEmail) {
         smsEmailMapper.insert(smsEmail);
@@ -228,7 +275,10 @@
             queryWrapper.lambda().eq(SmsEmail::getContent, pageWrap.getModel().getContent());
         }
         if (pageWrap.getModel().getPhone() != null) {
-            queryWrapper.lambda().eq(SmsEmail::getPhone, pageWrap.getModel().getPhone());
+            queryWrapper.lambda().and(wr ->{
+                wr.like(SmsEmail::getPhone, pageWrap.getModel().getPhone())
+                        .or().like(SmsEmail::getEmail, pageWrap.getModel().getPhone());
+            });
         }
         if (pageWrap.getModel().getEmail() != null) {
             queryWrapper.lambda().eq(SmsEmail::getEmail, pageWrap.getModel().getEmail());
@@ -245,13 +295,11 @@
         if (pageWrap.getModel().getObjType() != null) {
             queryWrapper.lambda().eq(SmsEmail::getObjType, pageWrap.getModel().getObjType());
         }
-        for(PageWrap.SortData sortData: pageWrap.getSorts()) {
-            if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) {
-                queryWrapper.orderByDesc(sortData.getProperty());
-            } else {
-                queryWrapper.orderByAsc(sortData.getProperty());
-            }
-        }
+        queryWrapper.lambda().ge(Objects.nonNull(pageWrap.getModel().getStartTime()),
+                SmsEmail::getCreateDate, pageWrap.getModel().getStartTime())
+                .le(Objects.nonNull(pageWrap.getModel().getEndTime()),
+                        SmsEmail::getCreateDate, pageWrap.getModel().getEndTime())
+                .orderByDesc(SmsEmail::getCreateDate);
         return PageData.from(smsEmailMapper.selectPage(page, queryWrapper));
     }
 

--
Gitblit v1.9.3