diff --git a/mall-common/src/main/java/com/suisung/mall/common/enums/DicEnum.java b/mall-common/src/main/java/com/suisung/mall/common/enums/DicEnum.java index e73df516..b52a7332 100644 --- a/mall-common/src/main/java/com/suisung/mall/common/enums/DicEnum.java +++ b/mall-common/src/main/java/com/suisung/mall/common/enums/DicEnum.java @@ -34,6 +34,23 @@ public enum DicEnum { ES_SEARCH_TYPE_1("1", "高亮查询","esSearchType","es查询方式","精准查询"), ES_SEARCH_TYPE_2("2", "模糊查询","esSearchType","es查询方式","模糊查询"), + + /** + * 举报类型 + */ + REPORT_TYPE_1("1", "垃圾信息","reportType","举报类型","垃圾信息"), + REPORT_TYPE_2("2", "骚扰辱骂","reportType","举报类型","骚扰辱骂"), + REPORT_TYPE_3("3", "色情低俗","reportType","举报类型","色情低俗"), + REPORT_TYPE_4("4", "诈骗","reportType","举报类型","诈骗"), + REPORT_TYPE_5("5", "其他","reportType","举报类型","其他"), + + /** + * 处理状态 + */ + PROCESSING_STATUS_0("0", "待处理","processingStatus","处理状态","垃圾信息"), + PROCESSING_STATUS_1("1", "已受理","processingStatus","处理状态","骚扰辱骂"), + PROCESSING_STATUS_2("2", "已驳回","processingStatus","处理状态","色情低俗"), + PROCESSING_STATUS_3("3", "处理已完结","processingStatus","处理状态","诈骗"), ; ; private String code; diff --git a/mall-common/src/main/java/com/suisung/mall/common/feignService/ShopService.java b/mall-common/src/main/java/com/suisung/mall/common/feignService/ShopService.java index 60287686..94068c03 100644 --- a/mall-common/src/main/java/com/suisung/mall/common/feignService/ShopService.java +++ b/mall-common/src/main/java/com/suisung/mall/common/feignService/ShopService.java @@ -23,10 +23,9 @@ import com.suisung.mall.common.modules.store.ShopStoreEmployee; import com.suisung.mall.common.modules.store.ShopStoreEmployeeKefu; import com.suisung.mall.common.modules.store.ShopStoreEmployeeRightsGroup; import org.springframework.cloud.openfeign.FeignClient; -import org.springframework.web.bind.annotation.GetMapping; -import org.springframework.web.bind.annotation.PostMapping; -import org.springframework.web.bind.annotation.RequestBody; -import org.springframework.web.bind.annotation.RequestParam; +import org.springframework.http.MediaType; +import org.springframework.web.bind.annotation.*; +import org.springframework.web.multipart.MultipartFile; import java.math.BigDecimal; import java.util.List; @@ -300,5 +299,9 @@ public interface ShopService { @PostMapping(value = "/mobile/shop/orderlkl/pay/notify/update/order") boolean lklPayNotifyUpdateShopOrderLkl(@RequestBody JSONObject lklPayNotifyDataJson); + + @PostMapping(value = "/mobile/shop/oss/upload",consumes = MediaType.MULTIPART_FORM_DATA_VALUE) + CommonResult uploadFile(@RequestPart(name = "upfile") MultipartFile file); + } diff --git a/mall-common/src/main/java/com/suisung/mall/common/modules/sns/SnsUserReport.java b/mall-common/src/main/java/com/suisung/mall/common/modules/sns/SnsUserReport.java new file mode 100644 index 00000000..b958e8bf --- /dev/null +++ b/mall-common/src/main/java/com/suisung/mall/common/modules/sns/SnsUserReport.java @@ -0,0 +1,114 @@ +package com.suisung.mall.common.modules.sns; + +import com.baomidou.mybatisplus.annotation.*; +import com.fasterxml.jackson.annotation.JsonFormat; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.experimental.Accessors; + +import javax.validation.constraints.NotEmpty; +import javax.validation.constraints.NotNull; +import java.util.Date; + +@Data +@EqualsAndHashCode(callSuper = false) +@Accessors(chain = true) +@TableName("sns_user_report") +@ApiModel("社交平台用户举报记录表（含审计跟踪）") +public class SnsUserReport { + @TableId(value = "id", type = IdType.AUTO) + @ApiModelProperty(value = "自增主键ID", example = "1") + private Long id; + + @TableField(value = "reporter_user_id",updateStrategy =FieldStrategy.NOT_EMPTY) + @ApiModelProperty(value = "举报人用户ID", required = true, example = "10001") + private Long reporterUserId; + + @TableField(value = "reporter_nickname",updateStrategy =FieldStrategy.NOT_EMPTY) + @ApiModelProperty(value = "举报人用户名（昵称）", required = true, example = "用户A") + private String reporterNickname; + + @TableField(value = "reported_user_id",updateStrategy = FieldStrategy.NOT_EMPTY) + @ApiModelProperty(value = "被举报人用户ID", required = true, example = "20002") + @NotNull(message = "被举报人用户ID不能为空") + private Long reportedUserId; + + @TableField(value = "reported_nickname",updateStrategy = FieldStrategy.NOT_EMPTY) + @NotEmpty(message = "被举报人用户名不能为空") + @ApiModelProperty(value = "被举报人用户名（昵称）", required = true, example = "用户B") + private String reportedNickname; + + + @TableField(value = "reported_phone",updateStrategy = FieldStrategy.NOT_EMPTY) + @ApiModelProperty(value = "被举报人手机号（可为空，根据隐私设置显示）", example = "13800138000") + private String reportedPhone; + + @TableField(value = "reporter_phone",updateStrategy = FieldStrategy.NOT_EMPTY) + @ApiModelProperty(value = "举报人手机号（匿名举报可为空）", example = "13800138000") + private String reporterPhone; + + @TableField(value = "report_category",updateStrategy = FieldStrategy.NOT_EMPTY) + @ApiModelProperty( + value = "举报类别：1-垃圾信息 2-骚扰辱骂 3-色情低俗 4-诈骗 5-其他", + required = true, + example = "2" + ) + @NotNull(message = "举报类型不能为空") + private Integer reportCategory; + + @TableField(value = "report_content",updateStrategy = FieldStrategy.NOT_EMPTY) + @ApiModelProperty(value = "举报详细内容", required = true, example = "该用户多次发送骚扰信息") + @NotEmpty(message = "举报内容不能为空") + private String reportContent; + + @TableField(value = "evidence_images",updateStrategy = FieldStrategy.NOT_EMPTY) + @ApiModelProperty( + value = "举报图片佐证，JSON格式：[{url: \"\", description: \"\"}, ...]", + example = "[{\"url\":\"https://example.com/1.jpg\",\"description\":\"骚扰截图\"}]" + ) + @NotEmpty(message = "举报图片佐证不能为空") + private String evidenceImages; + + @TableField(value = "processing_status",updateStrategy = FieldStrategy.NOT_EMPTY) + @ApiModelProperty( + value = "处理状态：0-待处理 1-已受理 2-已驳回 3-处理已完结", + example = "0" + ) + private Integer processingStatus; + + @TableField(value = "processing_result",updateStrategy = FieldStrategy.NOT_EMPTY) + @ApiModelProperty(value = "管理员处理结果描述", example = "已核实并封禁账号7天") + private String processingResult; + + @TableField(value = "processing_evidence_images",updateStrategy = FieldStrategy.NOT_EMPTY) + @ApiModelProperty( + value = "处理结果佐证图片，JSON格式：[{url: \"\", description: \"\"}, ...]", + example = "[{\"url\":\"https://example.com/admin.jpg\",\"description\":\"处理记录截图\"}]" + ) + private String processingEvidenceImages; + + @TableField(value = "created_by",updateStrategy = FieldStrategy.NOT_EMPTY) + @ApiModelProperty(value = "创建人用户ID（通常与举报人ID一致）", required = true, example = "10001") + private Long createdBy; + + @TableField(value = "updated_by",updateStrategy = FieldStrategy.NOT_EMPTY) + @ApiModelProperty(value = "最后修改人用户ID（管理员）", example = "90001") + private Long updatedBy; + + @TableField(value = "deleted_at",updateStrategy = FieldStrategy.NOT_EMPTY) + @ApiModelProperty(value = "逻辑删除时间戳（NULL表示未删除）", example = "2023-01-01T00:00:00") + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") + private Date deletedAt; + + @TableField(value = "created_at", updateStrategy = FieldStrategy.NOT_EMPTY) + @ApiModelProperty(value = "记录创建时间", example = "2023-01-01T00:00:00") + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") + private Date createdAt; + + @TableField(value = "updated_at", updateStrategy = FieldStrategy.NOT_EMPTY) + @ApiModelProperty(value = "记录最后更新时间", example = "2023-01-02T00:00:00") + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") + private Date updatedAt; +} diff --git a/mall-common/src/main/java/com/suisung/mall/common/modules/store/ShopStoreMember.java b/mall-common/src/main/java/com/suisung/mall/common/modules/store/ShopStoreMember.java new file mode 100644 index 00000000..b5514235 --- /dev/null +++ b/mall-common/src/main/java/com/suisung/mall/common/modules/store/ShopStoreMember.java @@ -0,0 +1,54 @@ +package com.suisung.mall.common.modules.store; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.experimental.Accessors; + +import java.math.BigDecimal; +import java.util.Date; + +@Data +@EqualsAndHashCode(callSuper = false) +@Accessors(chain = true) +@TableName("shop_store_member") +@ApiModel(value = "ShopStoreMember", description = "店铺会员表") +public class ShopStoreMember { + @TableId(value = "store_member_id", type = IdType.AUTO) + @ApiModelProperty(value = "店铺会员ID", example = "10001") + private Integer storeMemberId; + + @ApiModelProperty(value = "用户ID", example = "20001") + private Integer userId; + + @ApiModelProperty(value = "店铺ID", example = "30001") + private Integer storeId; + + @ApiModelProperty(value = "店铺名称", example = "旗舰店") + private String storeName; + + @ApiModelProperty(value = "首次消费时间") + private Date firstPurchaseTime; + + @ApiModelProperty(value = "累计消费金额", example = "1500.00") + private BigDecimal totalConsumption; + + @ApiModelProperty(value = "最近消费时间") + private Date lastPurchaseTime; + + @ApiModelProperty(value = "会员等级ID", example = "2") + private Integer memberLevelId; + + @ApiModelProperty(value = "等级名称", example = "铂金会员") + private String memberLevelName; + + @ApiModelProperty(value = "创建时间") + private Date createdAt; + + @ApiModelProperty(value = "更新时间") + private Date updatedAt; +} diff --git a/mall-common/src/main/java/com/suisung/mall/common/modules/store/ShopStoreMemberLevel.java b/mall-common/src/main/java/com/suisung/mall/common/modules/store/ShopStoreMemberLevel.java new file mode 100644 index 00000000..d09d1173 --- /dev/null +++ b/mall-common/src/main/java/com/suisung/mall/common/modules/store/ShopStoreMemberLevel.java @@ -0,0 +1,42 @@ +package com.suisung.mall.common.modules.store; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.experimental.Accessors; + +import java.math.BigDecimal; +import java.util.Date; + +@Data +@EqualsAndHashCode(callSuper = false) +@Accessors(chain = true) +@TableName("shop_store_member_level") +@ApiModel(value = "ShopStoreMemberLevel", description = "店铺会员等级表") +public class ShopStoreMemberLevel { + @TableId(value = "user_level_id", type = IdType.AUTO) + @ApiModelProperty(value = "等级编号", example = "1") + private Integer userLevelId; + + @ApiModelProperty(value = "等级名称", example = "黄金会员") + private String userLevelName; + + @ApiModelProperty(value = "累计消费额度", example = "1000.00") + private BigDecimal userLevelSpend; + + @ApiModelProperty(value = "折扣率百分比", example = "95.00") + private BigDecimal userLevelRate; + + @ApiModelProperty(value = "等级修改时间") + private Date userLevelTime; + + @ApiModelProperty(value = "创建时间") + private Date createdAt; + + @ApiModelProperty(value = "更新时间") + private Date updatedAt; +} diff --git a/mall-sns/src/main/java/com/suisung/mall/sns/Converter/StringToSnsUserReportConverter.java b/mall-sns/src/main/java/com/suisung/mall/sns/Converter/StringToSnsUserReportConverter.java new file mode 100644 index 00000000..f2788933 --- /dev/null +++ b/mall-sns/src/main/java/com/suisung/mall/sns/Converter/StringToSnsUserReportConverter.java @@ -0,0 +1,20 @@ +package com.suisung.mall.sns.Converter; + +import com.fasterxml.jackson.databind.ObjectMapper; +import com.suisung.mall.common.modules.sns.SnsUserReport; +import org.springframework.core.convert.converter.Converter; +import org.springframework.stereotype.Component; + +@Component +public class StringToSnsUserReportConverter implements Converter { + private final ObjectMapper objectMapper = new ObjectMapper(); + + @Override + public SnsUserReport convert(String source) { + try { + return objectMapper.readValue(source, SnsUserReport.class); + } catch (Exception e) { + throw new IllegalArgumentException("JSON 解析失败: " + source, e); + } + } +} diff --git a/mall-sns/src/main/java/com/suisung/mall/sns/config/FeignConfig.java b/mall-sns/src/main/java/com/suisung/mall/sns/config/FeignConfig.java index 55688eec..b533e4b2 100644 --- a/mall-sns/src/main/java/com/suisung/mall/sns/config/FeignConfig.java +++ b/mall-sns/src/main/java/com/suisung/mall/sns/config/FeignConfig.java @@ -3,12 +3,13 @@ package com.suisung.mall.sns.config; import com.suisung.mall.common.constant.AuthConstant; import feign.RequestInterceptor; import feign.RequestTemplate; +import feign.form.spring.SpringFormEncoder; import lombok.extern.slf4j.Slf4j; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.web.context.request.RequestContextHolder; import org.springframework.web.context.request.ServletRequestAttributes; - +import feign.codec.Encoder; import javax.servlet.http.HttpServletRequest; @Configuration @@ -28,4 +29,9 @@ public class FeignConfig { } }; } + + @Bean + public Encoder feignFormEncoder() { + return new SpringFormEncoder(); + } } \ No newline at end of file diff --git a/mall-sns/src/main/java/com/suisung/mall/sns/config/I18nConfig.java b/mall-sns/src/main/java/com/suisung/mall/sns/config/I18nConfig.java index 16e17c2d..c2409d45 100644 --- a/mall-sns/src/main/java/com/suisung/mall/sns/config/I18nConfig.java +++ b/mall-sns/src/main/java/com/suisung/mall/sns/config/I18nConfig.java @@ -1,9 +1,11 @@ package com.suisung.mall.sns.config; +import com.suisung.mall.sns.Converter.StringToSnsUserReportConverter; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.context.support.ResourceBundleMessageSource; +import org.springframework.format.FormatterRegistry; import org.springframework.web.servlet.LocaleResolver; import org.springframework.web.servlet.config.annotation.InterceptorRegistry; import org.springframework.web.servlet.config.annotation.WebMvcConfigurer; @@ -17,6 +19,8 @@ import java.util.Locale; */ @Configuration public class I18nConfig implements WebMvcConfigurer { + private final StringToSnsUserReportConverter stringToSnsUserReportConverter; + /** * session区域解析器 * @return @@ -81,4 +85,15 @@ public class I18nConfig implements WebMvcConfigurer { resourceBundleMessageSource.setBasenames("i18n/messages"); return resourceBundleMessageSource; } + + public I18nConfig(StringToSnsUserReportConverter stringToSnsUserReportConverter) { + this.stringToSnsUserReportConverter = stringToSnsUserReportConverter; + } + + + @Override + public void addFormatters(FormatterRegistry registry) { + // 注册自定义转换器 + registry.addConverter(stringToSnsUserReportConverter); + } } \ No newline at end of file diff --git a/mall-sns/src/main/java/com/suisung/mall/sns/controller/admin/SnsUserReportController.java b/mall-sns/src/main/java/com/suisung/mall/sns/controller/admin/SnsUserReportController.java new file mode 100644 index 00000000..c4b358e5 --- /dev/null +++ b/mall-sns/src/main/java/com/suisung/mall/sns/controller/admin/SnsUserReportController.java @@ -0,0 +1,62 @@ +package com.suisung.mall.sns.controller.admin; + +import com.suisung.mall.common.api.CommonResult; +import com.suisung.mall.common.modules.sns.SnsUserReport; +import com.suisung.mall.sns.service.SnsUserReportService; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import org.springframework.validation.annotation.Validated; +import org.springframework.web.bind.annotation.*; +import org.springframework.web.multipart.MultipartFile; + +import javax.annotation.Resource; +import java.util.List; + +@Api(tags = "社交平台用户举报记录控制器") +@RequestMapping("/admin/sns/snsUserReport") +@RestController +public class SnsUserReportController { + + @Resource + private SnsUserReportService snsUserReportService; + + /** + * 分页列表查询 + * + * @param pageNum + * @param pageSize + * @return + */ + @ApiOperation(value = "举报记录表-分页列表查询", notes = "举报记录表-分页列表查询") + @RequestMapping(value = "/list", method = RequestMethod.GET) + public CommonResult list(@RequestParam(name = "pageNum", defaultValue = "1") Integer pageNum, + @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize) { + + return snsUserReportService.findPageSnsUserReport(pageNum, pageSize); + } + + /** + * 举报提交 + * + * @param snsUserReport + * @return + */ + @ApiOperation(value = "举报记录表-举报提交", notes = "举报记录表-举报提交") + @RequestMapping(value = "/submitReport", method = RequestMethod.POST) + public CommonResult submitReport(@Validated @RequestParam("snsUserReport") SnsUserReport snsUserReport,@RequestParam("files") List files) { + return snsUserReportService.submitReport(snsUserReport,files); + } + + /** + * 举报处理 + * @param snsUserReport + * @return + */ + @ApiOperation(value = "举报处理-分页列表查询", notes = "举报处理-分页列表查询") + @RequestMapping(value = "/dealReport", method = RequestMethod.POST) + public CommonResult dealReport(@RequestBody SnsUserReport snsUserReport) { + return snsUserReportService.dealReport(snsUserReport); + } + + +} diff --git a/mall-sns/src/main/java/com/suisung/mall/sns/mapper/SnsUserReportMapper.java b/mall-sns/src/main/java/com/suisung/mall/sns/mapper/SnsUserReportMapper.java new file mode 100644 index 00000000..498da652 --- /dev/null +++ b/mall-sns/src/main/java/com/suisung/mall/sns/mapper/SnsUserReportMapper.java @@ -0,0 +1,19 @@ +package com.suisung.mall.sns.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.suisung.mall.common.modules.sns.SnsUserReport; +import org.springframework.stereotype.Repository; + +/** + *

+ * 主播表 Mapper 接口 + *

+ * + * @author Xinze + * @since 2021-04-14 + */ + +@Repository +public interface SnsUserReportMapper extends BaseMapper { + +} diff --git a/mall-sns/src/main/java/com/suisung/mall/sns/pojo/dto/ReportImageData.java b/mall-sns/src/main/java/com/suisung/mall/sns/pojo/dto/ReportImageData.java new file mode 100644 index 00000000..938e7dbb --- /dev/null +++ b/mall-sns/src/main/java/com/suisung/mall/sns/pojo/dto/ReportImageData.java @@ -0,0 +1,12 @@ +package com.suisung.mall.sns.pojo.dto; + +import com.google.gson.annotations.SerializedName; +import lombok.Data; + +@Data +public class ReportImageData { + @SerializedName("url") + private String url; + @SerializedName("description") + private String description; +} diff --git a/mall-sns/src/main/java/com/suisung/mall/sns/service/SnsUserReportService.java b/mall-sns/src/main/java/com/suisung/mall/sns/service/SnsUserReportService.java new file mode 100644 index 00000000..e7880cce --- /dev/null +++ b/mall-sns/src/main/java/com/suisung/mall/sns/service/SnsUserReportService.java @@ -0,0 +1,24 @@ +package com.suisung.mall.sns.service; + +import com.suisung.mall.common.api.CommonResult; +import com.suisung.mall.common.modules.sns.SnsUserReport; +import com.suisung.mall.core.web.service.IBaseService; +import org.springframework.web.multipart.MultipartFile; + +import java.util.List; + +/** + *

+ * 群组 服务类 + *

+ * + * @author Xinze + * @since 2022-04-01 + */ +public interface SnsUserReportService extends IBaseService { + CommonResult findPageSnsUserReport(int pageNo,int pageSize); + + CommonResult submitReport(SnsUserReport snsUserReport, List files); + + CommonResult dealReport(SnsUserReport snsUserReport); +} diff --git a/mall-sns/src/main/java/com/suisung/mall/sns/service/impl/SnsUserReportServiceImpl.java b/mall-sns/src/main/java/com/suisung/mall/sns/service/impl/SnsUserReportServiceImpl.java new file mode 100644 index 00000000..65709f43 --- /dev/null +++ b/mall-sns/src/main/java/com/suisung/mall/sns/service/impl/SnsUserReportServiceImpl.java @@ -0,0 +1,262 @@ +package com.suisung.mall.sns.service.impl; + +import cn.hutool.core.util.ObjectUtil; +import cn.hutool.core.util.PhoneUtil; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.google.gson.Gson; +import com.google.gson.GsonBuilder; +import com.google.gson.reflect.TypeToken; +import com.suisung.mall.common.api.CommonResult; +import com.suisung.mall.common.domain.UserDto; +import com.suisung.mall.common.enums.DicEnum; +import com.suisung.mall.common.exception.ApiException; +import com.suisung.mall.common.feignService.ShopService; +import com.suisung.mall.common.modules.sns.SnsUserReport; +import com.suisung.mall.common.utils.ContextUtil; +import com.suisung.mall.common.utils.StringUtils; +import com.suisung.mall.core.web.service.impl.BaseServiceImpl; +import com.suisung.mall.sns.mapper.SnsUserReportMapper; +import com.suisung.mall.sns.pojo.dto.ReportImageData; +import com.suisung.mall.sns.service.SnsUserReportService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; +import org.springframework.web.multipart.MultipartFile; + +import java.util.*; + + +@Service +public class SnsUserReportServiceImpl extends BaseServiceImpl implements SnsUserReportService { + + @Autowired + private ShopService shopService; + + private final static Set processingStatusList= Collections.unmodifiableSet(new HashSet<>( + Arrays.asList(1,2,3) + )); + + private final static Set reportCategorys= Collections.unmodifiableSet(new HashSet<>( + Arrays.asList(1,2,3, 4,5) + )); + private final static List domains=Arrays.asList("https://static.gpxscs.cn","https://media-mall-prod");//本系统静态路径 + + private final static Integer limtFiels=3; + + @Override + public CommonResult findPageSnsUserReport(int pageNo, int pageSize) { + SnsUserReport snsUserReport = new SnsUserReport(); + UserDto userDto= ContextUtil.getCurrentUser(); + assert userDto != null; + if(userDto.getRole_id()!=9){ + snsUserReport.setReporterUserId(Long.valueOf(userDto.getId())); + } + String reporterPhone= getParameter("reporterPhone"); + String reportedPhone= getParameter("reportedPhone"); + String reporterNickname= getParameter("reporterNickname"); + String reportedNickname= getParameter("reportedNickname"); + String reportedUserId= getParameter("reportedUserId"); + if(StringUtils.isNotBlank(reporterPhone)){ + snsUserReport.setReporterPhone(reporterPhone); + } + if(StringUtils.isNotBlank(reportedPhone)){ + snsUserReport.setReportedPhone(reportedPhone); + } + if(StringUtils.isNotBlank(reporterNickname)){ + snsUserReport.setReporterNickname(reporterNickname); + } + if(StringUtils.isNotEmpty(reportedNickname)){ + snsUserReport.setReportedNickname(reportedNickname); + } + if(StringUtils.isNotEmpty(reportedUserId)){ + snsUserReport.setReportedUserId(Long.valueOf(reportedUserId)); + } + QueryWrapper queryWrapper = new QueryWrapper<>(snsUserReport); + return CommonResult.success(this.lists(queryWrapper,pageNo,pageSize)); + } + + @Override + @Transactional(rollbackFor = RuntimeException.class) + public CommonResult submitReport(SnsUserReport snsUserReport,List files) { + + if(files.isEmpty()){ + return CommonResult.failed("举报佐证材料不能为空"); + } + + if(files.size()>limtFiels){ + return CommonResult.failed("文件数量不能超过3个"); + } + List reportImageDatas = new ArrayList<>(); + int i=1;//佐证材料编号 + for(MultipartFile file:files){ + int index=0; + while (index<3){ + try { + CommonResult commonResult= shopService.uploadFile(file); + Map data = (Map) commonResult.getData(); + ReportImageData reportImageData=new ReportImageData(); + if(ObjectUtil.isNotEmpty(data.get("url"))){ + reportImageData.setUrl(String.valueOf(data.get("url"))); + reportImageData.setDescription("举报佐证材料"+i); + reportImageDatas.add(reportImageData); + i++; + } + break; + }catch (Exception e){ + index++; + if(index==3){ + throw new ApiException(e.getMessage()); + } + } + } + } + Gson gson = new Gson(); + String evedenceImageDatas= gson.toJson(reportImageDatas); + + UserDto userDto= ContextUtil.getCurrentUser(); + assert userDto != null; + long userId = userDto.getId(); + if(StringUtils.isNotEmpty(snsUserReport.getReporterPhone())){ + if(!PhoneUtil.isMobile(snsUserReport.getReporterPhone())){ + throw new ApiException("举报人手机号码格式不正确"); + } + } + if(StringUtils.isNotEmpty(snsUserReport.getReportedPhone())){ + if(!PhoneUtil.isMobile(snsUserReport.getReportedPhone())){ + throw new ApiException("被举报人手机号码格式不正确"); + } + } + Integer reportCategory= snsUserReport.getReportCategory(); + if(!reportCategorys.contains(reportCategory)){ + return CommonResult.failed("不存在该举报类型"); + } + SnsUserReport saveSnsUserReport = new SnsUserReport(); + saveSnsUserReport.setReportedPhone(snsUserReport.getReportedPhone()); + saveSnsUserReport.setReporterPhone(snsUserReport.getReporterPhone()); + saveSnsUserReport.setReportedNickname(snsUserReport.getReportedNickname()); + saveSnsUserReport.setReportCategory(snsUserReport.getReportCategory()); + saveSnsUserReport.setReportedUserId(snsUserReport.getReportedUserId()); + saveSnsUserReport.setEvidenceImages(evedenceImageDatas); + saveSnsUserReport.setReportContent(snsUserReport.getReportContent()); + saveSnsUserReport.setCreatedBy(userId); + saveSnsUserReport.setReporterUserId(Long.valueOf(userDto.getId())); + saveSnsUserReport.setReporterNickname(userDto.getUser_nickname()); + saveSnsUserReport.setProcessingStatus(Integer.valueOf(DicEnum.PROCESSING_STATUS_0.getCode())); + saveSnsUserReport.setCreatedAt(new Date()); + saveSnsUserReport.setUpdatedAt(new Date()); + if(!this.save(saveSnsUserReport)){ + return CommonResult.success("提交失败，请联系管理员"); + } + return CommonResult.success("提交成功"); + } + + @Override + @Transactional(rollbackFor = Exception.class) + public CommonResult dealReport(SnsUserReport snsUserReport) { + //校验参数 + UserDto userDto= ContextUtil.getCurrentUser(); + assert userDto != null; + if(userDto.getRole_id()!=9){ + return CommonResult.failed("权限不足"); + } + if(ObjectUtil.isEmpty(snsUserReport.getId())){ + return CommonResult.failed("缺少唯一值"); + } + QueryWrapper queryWrapper = new QueryWrapper<>(); + queryWrapper.eq("id", snsUserReport.getId()); + SnsUserReport userReport = this.findOne(queryWrapper); + if(userReport == null){ + return CommonResult.failed("不存在该举报内容"); + } + Integer resultStatus=userReport.getProcessingStatus(); + if(ObjectUtil.equals(resultStatus,Integer.valueOf(DicEnum.PROCESSING_STATUS_2.getCode()))|| + ObjectUtil.equals(resultStatus,Integer.valueOf(DicEnum.PROCESSING_STATUS_3.getCode()))){ + return CommonResult.failed("该举报已处理，无需处理"); + } + //处理业务 + Integer processingStatus= snsUserReport.getProcessingStatus(); + if(!processingStatusList.contains(processingStatus)){ + return CommonResult.failed("不存在该受理类型"); + } + SnsUserReport saveSnsUserReport=new SnsUserReport(); + saveSnsUserReport.setUpdatedBy(Long.valueOf(userDto.getId())); + saveSnsUserReport.setUpdatedAt(new Date()); + saveSnsUserReport.setId(userReport.getId()); + saveSnsUserReport.setProcessingResult(snsUserReport.getProcessingResult()); + saveSnsUserReport.setProcessingEvidenceImages(snsUserReport.getProcessingEvidenceImages()); + String processingStatusStr=String.valueOf(processingStatus); + if(ObjectUtil.equals(DicEnum.PROCESSING_STATUS_1.getCode(),processingStatusStr)){//受理 + saveSnsUserReport.setProcessingStatus(Integer.valueOf(DicEnum.PROCESSING_STATUS_1.getCode())); + } + if(ObjectUtil.equals(DicEnum.PROCESSING_STATUS_2.getCode(),processingStatusStr)){//已驳回 + if(StringUtils.isEmpty(saveSnsUserReport.getProcessingResult())){ + return CommonResult.failed("驳回需要填写结果描述"); + } + saveSnsUserReport.setProcessingStatus(Integer.valueOf(DicEnum.PROCESSING_STATUS_2.getCode())); + saveSnsUserReport.setProcessingResult(snsUserReport.getProcessingResult()); + } + if(ObjectUtil.equals(DicEnum.PROCESSING_STATUS_3.getCode(),processingStatusStr)){//处理已完结 + if(StringUtils.isEmpty(saveSnsUserReport.getProcessingResult())){ + return CommonResult.failed("处理已完结需要填写结果描述"); + } + if(StringUtils.isEmpty(saveSnsUserReport.getProcessingEvidenceImages())){ + return CommonResult.failed("处理已完结需要填写佐证材料"); + } + Gson gson=new Gson(); + List reportImageData= gson.fromJson(saveSnsUserReport.getProcessingEvidenceImages(), new TypeToken>(){}.getType()); + String evedenceImageDatas= gson.toJson(reportImageData); + if(!checkoutImageUrl(reportImageData)){ + return CommonResult.failed("处理佐证材料格式不正确"); + } + saveSnsUserReport.setProcessingStatus(Integer.valueOf(DicEnum.PROCESSING_STATUS_3.getCode())); + saveSnsUserReport.setProcessingResult(snsUserReport.getProcessingResult()); + saveSnsUserReport.setProcessingEvidenceImages(evedenceImageDatas); + } + if(this.edit(saveSnsUserReport)){ + return CommonResult.success("处理成功"); + } + return CommonResult.success("处理失败"); + } + + /** + * 校验佐证材料格式 + * @param reportImageDatas + * @return + */ + private boolean checkoutImageUrl(List reportImageDatas){ + if(reportImageDatas==null){ + return false; + } + if(reportImageDatas.isEmpty()){ + return false; + } + for(ReportImageData reportImageData:reportImageDatas){ + if(StringUtils.isEmpty(reportImageData.getUrl())){ + return false; + } + boolean flag=false; + for(String domain:domains){//校验https地址 + if(reportImageData.getUrl().contains(domain)){ + flag=true; + } + } + if(!flag){ + return false; + } + if(StringUtils.isEmpty(reportImageData.getDescription())){ + return false; + } + } + return true; + } + + public static void main(String[] args) { + System.out.println(PhoneUtil.isMobile("18278596806")); + + Gson gson=new GsonBuilder().serializeNulls().create(); + List reportImageData= gson.fromJson("[{\"url\": \"https://example.com/image.jpg\", \"description\": \"实例描述\"}]", new TypeToken>(){}.getType()); + + System.out.println(new SnsUserReportServiceImpl().checkoutImageUrl(reportImageData)); + } + +}