|
@ -21,27 +21,32 @@ import com.alibaba.fastjson.JSON; |
|
|
import com.alibaba.fastjson.JSONObject; |
|
|
import com.alibaba.fastjson.JSONObject; |
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|
|
import com.baomidou.mybatisplus.core.metadata.IPage; |
|
|
import com.baomidou.mybatisplus.core.metadata.IPage; |
|
|
import com.baomidou.mybatisplus.extension.api.R; |
|
|
|
|
|
import com.epmet.commons.mybatis.service.impl.BaseServiceImpl; |
|
|
import com.epmet.commons.mybatis.service.impl.BaseServiceImpl; |
|
|
import com.epmet.commons.tools.constant.FieldConstant; |
|
|
import com.epmet.commons.tools.constant.FieldConstant; |
|
|
|
|
|
import com.epmet.commons.tools.constant.NumConstant; |
|
|
import com.epmet.commons.tools.enums.EnvEnum; |
|
|
import com.epmet.commons.tools.enums.EnvEnum; |
|
|
import com.epmet.commons.tools.exception.RenException; |
|
|
import com.epmet.commons.tools.exception.RenException; |
|
|
import com.epmet.commons.tools.page.PageData; |
|
|
import com.epmet.commons.tools.page.PageData; |
|
|
import com.epmet.commons.tools.utils.ConvertUtils; |
|
|
import com.epmet.commons.tools.utils.ConvertUtils; |
|
|
import com.epmet.commons.tools.utils.HttpClientManager; |
|
|
import com.epmet.commons.tools.utils.HttpClientManager; |
|
|
import com.epmet.commons.tools.utils.Result; |
|
|
import com.epmet.commons.tools.utils.Result; |
|
|
import com.epmet.dto.form.UploadBytesFormDTO; |
|
|
import com.epmet.dto.form.UserResiInfoListFormDTO; |
|
|
import com.epmet.dto.result.CustomerTokensResultDTO; |
|
|
import com.epmet.dto.result.CustomerTokensResultDTO; |
|
|
import com.epmet.dto.result.UploadImgResultDTO; |
|
|
import com.epmet.dto.result.UploadImgResultDTO; |
|
|
|
|
|
import com.epmet.dto.result.UserResiInfoResultDTO; |
|
|
|
|
|
import com.epmet.feign.EpmetUserOpenFeignClient; |
|
|
import com.epmet.feign.OssFeignClient; |
|
|
import com.epmet.feign.OssFeignClient; |
|
|
import com.epmet.modules.group.dao.ResiGroupCodeDao; |
|
|
import com.epmet.modules.group.dao.ResiGroupCodeDao; |
|
|
import com.epmet.modules.group.entity.ResiGroupCodeEntity; |
|
|
import com.epmet.modules.group.entity.ResiGroupCodeEntity; |
|
|
import com.epmet.modules.group.redis.ResiGroupCodeRedis; |
|
|
import com.epmet.modules.group.redis.ResiGroupCodeRedis; |
|
|
import com.epmet.modules.group.service.ResiGroupCodeService; |
|
|
import com.epmet.modules.group.service.ResiGroupCodeService; |
|
|
import com.epmet.modules.utils.ModuleConstant; |
|
|
import com.epmet.modules.utils.ModuleConstant; |
|
|
|
|
|
import com.epmet.resi.group.dto.QRCodeMultipartFileDTO; |
|
|
import com.epmet.resi.group.dto.group.ResiGroupCodeDTO; |
|
|
import com.epmet.resi.group.dto.group.ResiGroupCodeDTO; |
|
|
import com.epmet.resi.group.dto.group.form.CreateGroupCodeFormDTO; |
|
|
import com.epmet.resi.group.dto.group.form.CreateGroupCodeFormDTO; |
|
|
import com.epmet.resi.group.dto.group.form.GetGroupCodeFormDTO; |
|
|
import com.epmet.resi.group.dto.group.form.GetGroupCodeFormDTO; |
|
|
|
|
|
import com.epmet.resi.group.dto.group.form.GroupCodeBasicInfoFormDTO; |
|
|
|
|
|
import com.epmet.resi.group.dto.group.result.GroupCodeBasicInfoResultDTO; |
|
|
import org.apache.commons.lang3.StringUtils; |
|
|
import org.apache.commons.lang3.StringUtils; |
|
|
import org.slf4j.Logger; |
|
|
import org.slf4j.Logger; |
|
|
import org.slf4j.LoggerFactory; |
|
|
import org.slf4j.LoggerFactory; |
|
@ -51,10 +56,7 @@ import org.springframework.stereotype.Service; |
|
|
import org.springframework.transaction.annotation.Transactional; |
|
|
import org.springframework.transaction.annotation.Transactional; |
|
|
|
|
|
|
|
|
import java.io.UnsupportedEncodingException; |
|
|
import java.io.UnsupportedEncodingException; |
|
|
import java.util.Arrays; |
|
|
import java.util.*; |
|
|
import java.util.HashMap; |
|
|
|
|
|
import java.util.List; |
|
|
|
|
|
import java.util.Map; |
|
|
|
|
|
|
|
|
|
|
|
/** |
|
|
/** |
|
|
* 小组二维码 小组唯一二维码,海报码和小组码是同一个二维码,长期有效的 |
|
|
* 小组二维码 小组唯一二维码,海报码和小组码是同一个二维码,长期有效的 |
|
@ -73,6 +75,9 @@ public class ResiGroupCodeServiceImpl extends BaseServiceImpl<ResiGroupCodeDao, |
|
|
@Autowired |
|
|
@Autowired |
|
|
private OssFeignClient ossFeignClient; |
|
|
private OssFeignClient ossFeignClient; |
|
|
|
|
|
|
|
|
|
|
|
@Autowired |
|
|
|
|
|
private EpmetUserOpenFeignClient epmetUserOpenFeignClient; |
|
|
|
|
|
|
|
|
@Override |
|
|
@Override |
|
|
public PageData<ResiGroupCodeDTO> page(Map<String, Object> params) { |
|
|
public PageData<ResiGroupCodeDTO> page(Map<String, Object> params) { |
|
|
IPage<ResiGroupCodeEntity> page = baseDao.selectPage( |
|
|
IPage<ResiGroupCodeEntity> page = baseDao.selectPage( |
|
@ -170,10 +175,10 @@ public class ResiGroupCodeServiceImpl extends BaseServiceImpl<ResiGroupCodeDao, |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
//上传
|
|
|
//上传
|
|
|
UploadBytesFormDTO uploadBytesFormDTO = new UploadBytesFormDTO(); |
|
|
QRCodeMultipartFileDTO qrCodeMultipartFile = new QRCodeMultipartFileDTO(); |
|
|
uploadBytesFormDTO.setBytes(buffer); |
|
|
qrCodeMultipartFile.setBytes(buffer); |
|
|
uploadBytesFormDTO.setExtension("jpg"); |
|
|
qrCodeMultipartFile.setOriginalFilename("qrcode.jpg"); |
|
|
Result<UploadImgResultDTO> uploadResult = ossFeignClient.uploadBytes(uploadBytesFormDTO); |
|
|
Result<UploadImgResultDTO> uploadResult = ossFeignClient.uploadQrCode(qrCodeMultipartFile); |
|
|
if (uploadResult.success()) { |
|
|
if (uploadResult.success()) { |
|
|
result = uploadResult.getData().getUrl(); |
|
|
result = uploadResult.getData().getUrl(); |
|
|
//存表
|
|
|
//存表
|
|
@ -252,4 +257,32 @@ public class ResiGroupCodeServiceImpl extends BaseServiceImpl<ResiGroupCodeDao, |
|
|
} |
|
|
} |
|
|
return resiAccessToken; |
|
|
return resiAccessToken; |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
/** |
|
|
|
|
|
* @param formDTO |
|
|
|
|
|
* @Description 获取生成海报(小组码)信息 |
|
|
|
|
|
* @author sun |
|
|
|
|
|
*/ |
|
|
|
|
|
@Override |
|
|
|
|
|
public GroupCodeBasicInfoResultDTO groupCodeBasicInfo(GroupCodeBasicInfoFormDTO formDTO) { |
|
|
|
|
|
//1.获取小组基本信息
|
|
|
|
|
|
GroupCodeBasicInfoResultDTO resultDTO = baseDao.selectGroupCodeBasicInfo(formDTO); |
|
|
|
|
|
if (null == resultDTO) { |
|
|
|
|
|
logger.error(String.format("获取小组码基本信息失败,小组Id:%s", formDTO.getGroupId())); |
|
|
|
|
|
throw new RenException("获取小组码基本信息失败"); |
|
|
|
|
|
} |
|
|
|
|
|
//2.获取小组创建人称谓信息
|
|
|
|
|
|
UserResiInfoListFormDTO userResiInfoListFormDTO = new UserResiInfoListFormDTO(); |
|
|
|
|
|
List<String> userIdList = new ArrayList<>(); |
|
|
|
|
|
userIdList.add(resultDTO.getGroupUserId()); |
|
|
|
|
|
userResiInfoListFormDTO.setUserIdList(userIdList); |
|
|
|
|
|
Result<List<UserResiInfoResultDTO>> resultList = epmetUserOpenFeignClient.getUserResiInfoList(userResiInfoListFormDTO); |
|
|
|
|
|
if (!resultList.success() || null == resultList.getData() || resultList.getData().size() < NumConstant.ONE) { |
|
|
|
|
|
logger.error(String.format("调用user服务,查询用户基本信息失败,userId:%s", resultDTO.getGroupUserId())); |
|
|
|
|
|
throw new RenException("获取小组创建人基本信息失败"); |
|
|
|
|
|
} |
|
|
|
|
|
resultDTO.setShowName(resultList.getData().get(NumConstant.ZERO).getShowName()); |
|
|
|
|
|
return resultDTO; |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
} |
|
|
} |
|
|