| | |
| | | import io.swagger.annotations.*; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.apache.poi.ss.usermodel.Workbook; |
| | | import org.apache.shardingsphere.transaction.annotation.ShardingSphereTransactionType; |
| | | import org.apache.shardingsphere.transaction.core.TransactionType; |
| | | import org.springframework.context.MessageSource; |
| | | import org.springframework.context.i18n.LocaleContextHolder; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | |
| | | import java.util.*; |
| | | import java.util.stream.Collectors; |
| | | import java.util.regex.Pattern; |
| | | import com.xiaopeng.common.log.annotation.AdminOperationLog; |
| | | import com.xiaopeng.common.log.enums.AdminBusinessType; |
| | | import com.xiaopeng.common.log.enums.AdminOperationType; |
| | | |
| | | /** |
| | | * <p> |
| | |
| | | @PostMapping("/api/v1/invitation/add") |
| | | @ResponseBody |
| | | @ApiOperation(value = "生成邀请码") |
| | | @Transactional |
| | | @AdminOperationLog( |
| | | businessType = AdminBusinessType.INVITATION_CODE_MANAGEMENT, |
| | | operationType = AdminOperationType.ADD, |
| | | content = "生成邀请码", |
| | | appendRequestData = true |
| | | ) |
| | | public R add(@RequestBody InvitationAddDto dto){ |
| | | long existing = xpInvitationCodeService.count(); |
| | | long incoming = Arrays.stream(Optional.ofNullable(dto.getPhones()).orElse("").split(",")) |
| | |
| | | @ApiImplicitParams({ |
| | | @ApiImplicitParam(value = "id", name = "id", dataType = "Long", required = true) |
| | | }) |
| | | @AdminOperationLog( |
| | | businessType = AdminBusinessType.INVITATION_CODE_MANAGEMENT, |
| | | operationType = AdminOperationType.EDIT, |
| | | contentExpression = "'解绑邀请码,id=' + #p0", |
| | | appendRequestData = false |
| | | ) |
| | | public R unbind(@RequestParam("id") Long id){ |
| | | UpdateWrapper<XpInvitationCode> xpInvitationCodeUpdateWrapper = new UpdateWrapper<>(); |
| | | xpInvitationCodeUpdateWrapper.eq("id",id); |
| | |
| | | } |
| | | @ApiOperation(value = "邀请码导入") |
| | | @PostMapping("/base/v1/invitation/importExcel") |
| | | @AdminOperationLog( |
| | | businessType = AdminBusinessType.INVITATION_CODE_MANAGEMENT, |
| | | operationType = AdminOperationType.IMPORT, |
| | | content = "导入邀请码", |
| | | appendRequestData = false |
| | | ) |
| | | public R<String> importExcel(@RequestParam("file") MultipartFile file) { |
| | | ImportParams params = new ImportParams(); |
| | | params.setHeadRows(1); //表头行数 |
| | |
| | | |
| | | if (!StringUtils.hasLength(bindAccount)) { |
| | | errors.add(messageSource.getMessage(I18nKeyConstant.INVITATION_IMPORT_ACCOUNT_EMPTY, new Object[]{rowNum}, I18nKeyConstant.INVITATION_IMPORT_ACCOUNT_EMPTY, LocaleContextHolder.getLocale())); |
| | | } else if (!PhoneUtil.isPhone(bindAccount)) { |
| | | } else if (!PhoneUtil.isMobile(bindAccount)) { |
| | | errors.add(messageSource.getMessage(I18nKeyConstant.INVITATION_IMPORT_ACCOUNT_INVALID, new Object[]{rowNum, bindAccount}, I18nKeyConstant.INVITATION_IMPORT_ACCOUNT_INVALID, LocaleContextHolder.getLocale())); |
| | | } |
| | | |
| | |
| | | } |
| | | @ApiOperation(value = "邀请码导出") |
| | | @PostMapping(value = "/api/v1/invitation/exportExcel") |
| | | @AdminOperationLog( |
| | | businessType = AdminBusinessType.INVITATION_CODE_MANAGEMENT, |
| | | operationType = AdminOperationType.EXPORT, |
| | | content = "导出邀请码", |
| | | appendRequestData = true |
| | | ) |
| | | public void exportExcel(@RequestBody InvitationPageListQuery query) { |
| | | List<XpInvitationCode> list = xpInvitationCodeService.exportList(query); |
| | | List<XpInvitationCodeExportExcel> xpWhitelistExportExcels = new ArrayList<>(); |
| | |
| | | @GetMapping("/api/v1/invitation/deleteByIds") |
| | | @ResponseBody |
| | | @ApiOperation(value = "批量删除") |
| | | @AdminOperationLog( |
| | | businessType = AdminBusinessType.INVITATION_CODE_MANAGEMENT, |
| | | operationType = AdminOperationType.DELETE, |
| | | contentExpression = "'批量删除邀请码,ids=' + #p0", |
| | | appendRequestData = false |
| | | ) |
| | | public R deleteByIds(String ids){ |
| | | // 再转化为Long类型 |
| | | List<Long> longs = Arrays.stream(ids.split(",")).map(Long::parseLong).collect(Collectors.toList()); |
| | |
| | | } |
| | | |
| | | @ApiOperation(value = "校验生成邀请码的手机号是否合法") |
| | | @PostMapping("/api/v1/invitation/validateCode") |
| | | public R<Boolean> validateCode(@RequestParam String phone){ |
| | | if (!PhoneUtil.isMobile(phone)){ |
| | | return R.ok(false); |
| | | } |
| | | List<XpInvitationCode> existsList = xpInvitationCodeService.lambdaQuery() |
| | | .in(XpInvitationCode::getBindAccount, phone) |
| | | .list(); |
| | | return R.ok(CollUtil.isEmpty(existsList)); |
| | | @GetMapping("/api/v1/invitation/validateCode") |
| | | public R<List<String>> validateCode(@RequestParam String phone){ |
| | | List<String> phoneList = Arrays.asList(phone.split(",")); |
| | | List<String> existPhones = phoneList.stream().filter(item -> xpInvitationCodeService.lambdaQuery() |
| | | .in(XpInvitationCode::getBindAccount, item) |
| | | .count() > 0).collect(Collectors.toList()); |
| | | return R.ok(existPhones); |
| | | } |
| | | } |