From d1169af7e268c6b38f441f549a042267fb77412d Mon Sep 17 00:00:00 2001
From: 张天森 <1292933220@qq.com>
Date: 星期二, 11 十月 2022 17:56:07 +0800
Subject: [PATCH] 三说会堂登陆账号处理

---
 springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/service/impl/UserServiceImpl.java |   47 +++++++++++++++++++++++++++++++++++++++++++----
 1 files changed, 43 insertions(+), 4 deletions(-)

diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/service/impl/UserServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/service/impl/UserServiceImpl.java
index 74194bf..03fb117 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/service/impl/UserServiceImpl.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/service/impl/UserServiceImpl.java
@@ -28,6 +28,7 @@
 import com.panzhihua.common.model.vos.community.acid.ComActAcidMemberVO;
 import com.panzhihua.common.model.vos.community.acid.ComActAcidRecordVO;
 import com.panzhihua.common.model.vos.community.microCommercialStreet.McsLoginUserInfoVO;
+import com.panzhihua.common.model.vos.sanshuo.ComSanshuoExpertVO;
 import com.panzhihua.common.model.vos.user.*;
 import com.panzhihua.common.service.community.CommunityService;
 import com.panzhihua.common.utlis.*;
@@ -160,8 +161,6 @@
     private SysTemplateConfigDao sysTemplateConfigDao;
     @Resource
     private ObjectMapper objectMapper;
-    @Resource
-    private CommunityService communityService;
     private static final Integer ALLCOUNTY=1;
     private static final Integer ALLSTREET=2;
     private static final Integer ALLCOMMUNITY=3;
@@ -305,10 +304,16 @@
      */
     @Override
     public R<LoginUserInfoVO> getUserInfo(String name, int type,String appId) {
+        //是否为三说会堂行业分中心或专家后台账号
         SysUserDO sysUserDO = null;
+        Boolean isIndustryOrExpertAccount=(userDao.isIndustryCenterAccount(name)>0 || userDao.isExpertAccount(name)>0);
         if (1 == type) {
             sysUserDO = userDao.selectOne(
                 new QueryWrapper<SysUserDO>().lambda().eq(SysUserDO::getType, type).eq(SysUserDO::getOpenid, name));
+        }else if(isIndustryOrExpertAccount){
+            //三说会堂行业分中心或专家后台账号登陆
+            sysUserDO=userDao.selectOne(
+                    new QueryWrapper<SysUserDO>().lambda().eq(SysUserDO::getAccount, name).eq(SysUserDO::getAppId,appId ));
         } else {
             LambdaQueryWrapper<SysUserDO> wrapper = new QueryWrapper<SysUserDO>().lambda().eq(SysUserDO::getType, type);
             if (type == 11) {
@@ -497,12 +502,14 @@
             loginUserInfoVO.setLevel(1);
         }
         //是否为三说会堂专家
-        R expert = communityService.isExpert(loginUserInfoVO.getPhone());
-        if (R.isOk(expert)){
+        ComSanshuoExpertVO expertVO=userDao.isExpert(loginUserInfoVO.getPhone());
+        if (nonNull(expertVO)){
             loginUserInfoVO.setType(13);
         }
         return R.ok(loginUserInfoVO);
     }
+
+
 
     /**
      * 修改用户登录密码
@@ -3617,6 +3624,38 @@
         }
         return R.ok();
     }
+
+    @Override
+    public R wsPush(String washPhone,String phone,String washName,Integer orderStatus) {
+        if(StringUtils.isNotEmpty(phone)){
+            SysUserDO sysUserDO=userDao.selectOne(new QueryWrapper<SysUserDO>().lambda().eq(SysUserDO::getPhone,phone).eq(SysUserDO::getAppId,"wx98d62711dfbd8425").orderByDesc(SysUserDO::getCreateAt).last("limit 1"));
+            if(sysUserDO!=null&&StringUtils.isNotEmpty(sysUserDO.getOpenid())){
+                String status="";
+                String accessToken="";
+                WxXCXTempSend util = new WxXCXTempSend();
+                try {
+                    accessToken = util.getWsAccessToken();
+                } catch (Exception e) {
+                    e.printStackTrace();
+                }
+                switch (orderStatus){
+                    case 3 : status="已分配车美";
+                        WxUtil.sendUuWash3(sysUserDO.getOpenid(),accessToken,status,washName,washPhone,phone,"sNj6m-JBvW6rOokKGDX9X3-XH1AD0GY5_X0jA9JSLwc");
+                        break;
+                    case 4 : status="车美已开始服务";
+                        WxUtil.sendUuWash4(sysUserDO.getOpenid(),accessToken,status,washName,washPhone,phone,"Eft5ksvsnOQANy2uNOGY43CC3pb33eDGA_lgCEoxuiw");
+                        break;
+                    case 6 : status="订单确认完成";
+                        WxUtil.sendUuWash6(sysUserDO.getOpenid(),accessToken,status,washName,washPhone,phone,"iPS8yrsGDqy76hiP8bIbxkosveoX1xTFhdusSiGp-XM");
+                        break;
+                    case 9 : status="订单已取消";
+                        WxUtil.sendUuWash(sysUserDO.getOpenid(),accessToken,status,washName,washPhone,phone,"z_ysGXz9JWBc2rXuYZzVCXKJTyLf0w0WerrohuNoEng");
+                        break;
+                }
+            }
+        }
+        return R.ok();
+    }
     @Override
     public R getCommunityList(String name,Long id) {
         //区级账号名

--
Gitblit v1.7.1