Merge branch 'feature/0721-tenant' into develop

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/mapper/SysUserMapper.java

@@ -50,4 +50,6 @@ public interface SysUserMapper extends BaseMapper<SysUser> {
      * @return List<CustomerService.MessageReceives>
      */
     List<CustomerService.MessageReceives> selectMessageReceives(@Param("param") CustomerService.NotifyMessage message);
+
+    com.yonge.cooleshow.auth.api.entity.SysUser findUserByPhone(@Param("phone") String phone);
 }

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/SysUserService.java

@@ -28,4 +28,6 @@ public interface SysUserService{
     IdcardInfoExtractor updateUserCard(RealnameAuthReq realNameAuthDto, SysUser sysUser, ClientEnum client);
 
     Map<Long,com.yonge.cooleshow.biz.dal.entity.SysUser> getMapByIds(List<Long> userIds);
+
+    SysUser findUserByPhone(String phone);
 }

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/impl/SysUserServiceImpl.java

@@ -123,4 +123,10 @@ public class SysUserServiceImpl implements SysUserService {
         }
         return sysUsers.stream().collect(HashMap::new, (m, v) -> m.put(v.getId(), v), HashMap::putAll);
     }
+
+    @Override
+    public SysUser findUserByPhone(String phone) {
+
+        return sysUserMapper.findUserByPhone(phone);
+    }
 }

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/impl/TenantAlbumMusicServiceImpl.java

@@ -114,6 +114,11 @@ public class TenantAlbumMusicServiceImpl extends ServiceImpl<TenantAlbumMusicMap
         musicSheetQuery.setMusicTagId(query.getMusicTagId());
         musicSheetQuery.setSubjectId(query.getSubjectId());
         musicSheetQuery.setKeyword(query.getKeyword());
+        //把集合转为字符串
+        String collect1 = musicSheetIds.stream()
+                .map(String::valueOf)
+                .collect(Collectors.joining(", "));
+        musicSheetQuery.setCollect(collect1);
 
         List<TenantAlbumMusicWrapper.StudentTenantAlbumMusic> musicSheets = tenantAlbumMusicMapper.selectPage(page, musicSheetQuery);
 

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/impl/TenantApplyRecordServiceImpl.java

@@ -1,6 +1,7 @@
 package com.yonge.cooleshow.biz.dal.service.impl;
 
 import com.alibaba.fastjson.JSON;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.microsvc.toolkit.common.webportal.exception.BizException;
@@ -59,7 +60,7 @@ public class TenantApplyRecordServiceImpl extends ServiceImpl<TenantApplyRecordM
     private SysConfigService sysConfigService;
 
     @Autowired
-    private SysUserMapper sysUserMapper;
+    private SysUserMapper  sysUserMapper;
 
     /**
      * 查询详情
@@ -125,7 +126,14 @@ public class TenantApplyRecordServiceImpl extends ServiceImpl<TenantApplyRecordM
         // 根据手机号 判断是否已经有机构账户
         TenantStaff tenantStaff = tenantStaffService.getByPhone(tenantApply.getPhone());
         if (tenantStaff != null) {
-            throw new BizException("该手机号已经有机构账户");
+            throw new BizException("该手机号已经有机构账号");
+        }
+
+        QueryWrapper<SysUser> sysUserQueryWrapper = new QueryWrapper<>();
+        sysUserQueryWrapper.lambda().eq(SysUser::getPhone, tenantApply.getPhone());
+        List<SysUser> sysUsers = sysUserMapper.selectList(sysUserQueryWrapper);
+        if (!sysUsers.isEmpty() && sysUsers.stream().anyMatch(next -> next.getUserType().contains(ClientEnum.SYSTEM.getCode()))) {
+            throw new BizException("该手机号已经有系统员工账户");
         }
 
         // 查询申请记录 是否存在正在申请中的

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/impl/UserOrderServiceImpl.java

@@ -228,13 +228,20 @@ public class UserOrderServiceImpl extends ServiceImpl<UserOrderDao, UserOrder> i
     public UserOrderVo detail(Long id) {
         UserOrderVo userOrderVo = baseMapper.detailById(id);
         if (null != userOrderVo) {
-            userOrderVo.setOrderDetailList(orderDetailService.getOrderDetilListByOrderNo(userOrderVo.getOrderNo()));
+            List<UserOrderDetailVo> orderDetilListByOrderNo = orderDetailService.getOrderDetilListByOrderNo(userOrderVo.getOrderNo());
+            userOrderVo.setOrderDetailList(orderDetilListByOrderNo);
             if (userOrderVo.getTenantId() != null) {
                 TenantInfo tenantInfo = tenantInfoService.getById(userOrderVo.getTenantId());
                 if (tenantInfo != null) {
                     userOrderVo.setTenantName(tenantInfo.getName());
                 }
             }
+            for (UserOrderDetailVo userOrderDetailVo : orderDetilListByOrderNo) {
+                if (userOrderDetailVo.getGoodType().equals(GoodTypeEnum.TENANT_ALBUM)) {
+                    TenantAlbum tenantAlbum = tenantAlbumService.getById(userOrderDetailVo.getBizId());
+                    userOrderDetailVo.setGoodUrl(tenantAlbum.getCoverImg());
+                }
+            }
         }
         return userOrderVo;
     }

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/impl/UserPaymentCoreServiceImpl.java

@@ -523,6 +523,7 @@ public class UserPaymentCoreServiceImpl implements UserPaymentCoreService {
             item.setActivityId(orderReq.getActivityId());
             item.setUserId(orderReq.getUserId());
             item.setPaymentClient(orderReq.getPaymentClient());
+            item.setRecomUserId(orderReq.getRecomUserId());
 
 
             BigDecimal couponAmount = BigDecimal.ZERO;
@@ -531,7 +532,6 @@ public class UserPaymentCoreServiceImpl implements UserPaymentCoreService {
                 // 填充商品基础信息，校验参数合法以性
                 orderGoodsCreate.get(item.getGoodType()).accept(item);
                 UserOrderDetail userOrderDetail = item.getUserOrderDetail();
-                userOrderDetail.setMerchId(orderReq.getRecomUserId());
                 orderDetails.add(userOrderDetail);
                 // 根据优惠券计算实际优惠金额
                 // 计算优惠券金额

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/wrapper/TenantAlbumMusicWrapper.java

@@ -163,8 +163,8 @@ public class TenantAlbumMusicWrapper {
         @ApiModelProperty("机构id")
         private Long tenantId;
 
-
-
+        @ApiModelProperty(name = "集合")
+        private String collect;
 
 
         public String getKeyword() {
@@ -256,6 +256,9 @@ public class TenantAlbumMusicWrapper {
         @ApiModelProperty("关键词")
         private String keyword;
 
+        @ApiModelProperty(name = "集合")
+        private String collect;
+
 
 
 

cooleshow-user/user-biz/src/main/resources/config/mybatis/SysUserMapper.xml

@@ -107,5 +107,9 @@
         </where>
         LIMIT 1500
     </select>
+
+    <select id="findUserByPhone" resultType="com.yonge.cooleshow.auth.api.entity.SysUser">
+        SELECT * FROM sys_user WHERE phone_ = #{phone} AND del_flag_ = 0
+    </select>
     <!--客服消息接收者-->
 </mapper>

cooleshow-user/user-biz/src/main/resources/config/mybatis/TenantAlbumMusicMapper.xml

@@ -50,6 +50,9 @@
                 and m.music_sheet_name_ LIKE CONCAT('%',#{param.keyword},'%')
             </if>
         </where>
+        <if test="param.musicSheetIds != null and param.musicSheetIds.size != 0">
+            order by field(m.id_,${param.collect})
+        </if>
 	</select>
     <select id="selectMusicSheetIds" resultType="java.lang.Long">
         select

cooleshow-user/user-tenant/src/main/java/com/yonge/cooleshow/tenant/controller/open/OpenTenantController.java

@@ -111,7 +111,7 @@ public class OpenTenantController {
         } else {
             // 判断当前账号是否已绑定
             if (StringUtils.isNotBlank(tenantStaff.getWxOpenid()) && !openId.equals(tenantStaff.getWxOpenid())) {
-                throw new BizException("当前账号已绑定");
+                throw new BizException("请登录您所绑定的机构");
             }
         }