From 5b26077c6b895dc72e7a80e6d2ddccc7b754da8e Mon Sep 17 00:00:00 2001
From: zhaozhengjie <237651143@qq.com>
Date: 星期日, 09 十月 2022 13:59:42 +0800
Subject: [PATCH] Merge branch '20221008' into huacheng_test

---
 springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/service/impl/UserServiceImpl.java |   73 +++++++++++++++++++++++++++++++++++-
 1 files changed, 71 insertions(+), 2 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 9108508..2bb3093 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
@@ -22,6 +22,7 @@
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.panzhihua.common.model.dtos.community.microCommercialStreet.BindUserPhoneDTO;
+import com.panzhihua.common.model.dtos.partybuilding.ComPbCheckUserDTO;
 import com.panzhihua.common.model.vos.community.ComAreaTownCommunityVO;
 import com.panzhihua.common.model.vos.community.acid.ComActAcidCheckRecordVO;
 import com.panzhihua.common.model.vos.community.acid.ComActAcidMemberVO;
@@ -780,6 +781,17 @@
             loginUserInfoVO.setLevel(2);
         }else if (isNull(loginUserInfoVO.getLevel())){
             loginUserInfoVO.setLevel(1);
+        }
+        loginUserInfoVO.setBackstageType(1);
+        String[] account={"dongqu","xiqu","yanbianxian","miyixian","renhequ","fantaixinqu"};
+        if("zuzhibu".equals(sysUserDO.getAccount())){
+            loginUserInfoVO.setBackstageType(2);
+        }
+        if(ArrayUtil.contains(account,sysUserDO.getAccount())){
+            loginUserInfoVO.setBackstageType(3);
+        }
+        if(sysUserDO.getBindingCheckUnitId()!=null){
+            loginUserInfoVO.setBackstageType(4);
         }
         return R.ok(loginUserInfoVO);
     }
@@ -3597,6 +3609,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,"sU18zbyzxFldHAdOREaQCR5uq_uMvCKTmGtklO1xw-w");
+                        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,"k1aV97H3pDNNcNcDTeZBD9jQemNDADnRE801HhTXweI");
+                        break;
+                    case 9 : status="订单已取消";
+                        WxUtil.sendUuWash(sysUserDO.getOpenid(),accessToken,status,washName,washPhone,phone,"9_2FhQPDxZoUqmAuIZ1L1zjjYXokdNvu7A0gzKfvruI");
+                        break;
+                }
+            }
+        }
+        return R.ok();
+    }
     @Override
     public R getCommunityList(String name,Long id) {
         //区级账号名
@@ -3708,6 +3752,31 @@
         return R.ok();
     }
 
+    @Override
+    @Transactional
+    public R addComPbCheckUser(ComPbCheckUserDTO comPbCheckUserDTO) {
+        SysUserDO sysUserDO=userDao.selectOne(new QueryWrapper<SysUserDO>().lambda().eq(SysUserDO::getAccount,comPbCheckUserDTO.getAccount()).eq(SysUserDO::getType,3).eq(SysUserDO::getAppId,"wx118de8a734d269f0"));
+        if(sysUserDO!=null){
+            return R.fail("账户名已存在");
+        }
+        SysUserDO sysUserDO1=new SysUserDO();
+        sysUserDO1.setUserId(Snowflake.getId());
+        sysUserDO1.setAccount(comPbCheckUserDTO.getAccount());
+        sysUserDO1.setPassword(new BCryptPasswordEncoder().encode(comPbCheckUserDTO.getPassword()));
+        sysUserDO1.setType(3);
+        sysUserDO1.setAppId("wx118de8a734d269f0");
+        sysUserDO1.setCommunityId(0L);
+        sysUserDO1.setBindingCheckUnitId(comPbCheckUserDTO.getCheckUnitId());
+        int restlt=userDao.insert(sysUserDO1);
+        if(restlt>0){
+            SysUserRoleDO sysUserRoleDO=new SysUserRoleDO();
+            sysUserRoleDO.setRoleId(123321L);
+            sysUserRoleDO.setUserId(sysUserDO1.getUserId());
+            sysUserRoleDAO.insert(sysUserRoleDO);
+        }
+        return R.ok();
+    }
+
     /**
      * 三说会堂新增业务中心或专家账号
      * */
@@ -3720,7 +3789,7 @@
             sysUserDO.setCreateAt(new Date());
             sysUserDO.setUserId(administratorsUserVO.getUserId());
             sysUserDO.setAccount(administratorsUserVO.getAccount());
-            sysUserDO.setPassword(administratorsUserVO.getPassword());
+            sysUserDO.setPassword(new BCryptPasswordEncoder().encode(administratorsUserVO.getPassword()));
             sysUserDO.setName(administratorsUserVO.getName());
             if (nonNull(administratorsUserVO.getImageUrl())){
                 sysUserDO.setImageUrl(administratorsUserVO.getImageUrl());
@@ -3751,7 +3820,7 @@
     public R resetPassExpertOrIndustryCenter(String account,String password) {
         SysUserDO sysUserDO = userDao.selectOne(new QueryWrapper<SysUserDO>().eq("account", account));
         if (nonNull(sysUserDO)){
-            sysUserDO.setPassword(password);
+            sysUserDO.setPassword(new BCryptPasswordEncoder().encode(password));
             userDao.updateById(sysUserDO);
             return R.ok();
         }

--
Gitblit v1.7.1