mcwl-admin/src/main/java/com/mcwl/web/controller/communityCenter/PublishController.java

@@ -119,4 +119,14 @@ public class PublishController {
         return R.ok();
     }
 
+    /**
+     * 举报
+     */
+    @ApiOperation(value = "举报")
+    @PostMapping("report")
+    public R<Object> reportPublish(@RequestBody @Valid PublishReportRes publishReportRes) {
+        publishService.reportPublish(publishReportRes);
+        return R.ok();
+    }
+
 }

mcwl-admin/src/main/java/com/mcwl/web/controller/communityCenter/PublishReportController.java

@@ -1,54 +0,0 @@
-package com.mcwl.web.controller.communityCenter;
-
-import com.mcwl.common.core.domain.R;
-import com.mcwl.common.core.page.PageDomain;
-import com.mcwl.common.core.page.TableDataInfo;
-import com.mcwl.communityCenter.domain.dto.PublishReportRes;
-import com.mcwl.communityCenter.service.PublishReportService;
-import com.mcwl.communityCenter.service.PublishService;
-import io.swagger.annotations.Api;
-import io.swagger.annotations.ApiOperation;
-import lombok.RequiredArgsConstructor;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-import javax.validation.Valid;
-
-/**
- * 发布举报
- */
-@Api(tags = "发布举报")
-@RestController
-@RequestMapping("publishReport")
-@RequiredArgsConstructor
-public class PublishReportController {
-
-    private final PublishService publishService;
-
-    private final PublishReportService publishReportService;
-
-
-    /**
-     * 举报
-     */
-    @ApiOperation(value = "举报")
-    @PostMapping("report")
-    public R<Object> reportPublish(@RequestBody @Valid PublishReportRes publishReportRes) {
-        publishService.reportPublish(publishReportRes);
-        return R.ok();
-    }
-
-    /**
-     * 获取举报列表
-     */
-    @ApiOperation(value = "获取举报列表")
-    @PostMapping("list")
-    public TableDataInfo getReportList(@RequestBody @Valid PageDomain pageDomain) {
-        return publishReportService.getReportList(pageDomain);
-    }
-
-
-
-}

mcwl-communityCenter/src/main/java/com/mcwl/communityCenter/domain/IncomeInfo.java

@@ -30,11 +30,6 @@ public class IncomeInfo extends BaseEntity {
      */
     private Long communityId;
 
-    /**
-     * 用户id
-     */
-    private Long userId;
-
     /**
      * 类型 0付费加入 1付费问答
      */

mcwl-communityCenter/src/main/java/com/mcwl/communityCenter/domain/PublishReport.java

@@ -41,17 +41,17 @@ public class PublishReport extends BaseEntity {
     /**
      * 举报类型 字典值
      */
-    private Integer reportType;
+    private Long reportType;
 
     /**
      * 举报内容
      */
-    private String content;
+    private Long content;
 
     /**
      * 状态（0未处理 1已处理 )
      */
-    private Integer status;
+    private Long status;
 
 
 }

mcwl-communityCenter/src/main/java/com/mcwl/communityCenter/domain/vo/CommunityDetailVo.java

@@ -41,12 +41,6 @@ public class CommunityDetailVo {
     @ApiModelProperty(value = "社区名称")
     private String communityName;
 
-    /**
-     * 社区标签
-     */
-    @ApiModelProperty(value = "社区标签")
-    private Integer communityTag;
-
     /**
      * 价格
      */
@@ -59,18 +53,6 @@ public class CommunityDetailVo {
     @ApiModelProperty(value = "描述")
     private String description;
 
-    /**
-     * 社区类型
-     */
-    @ApiModelProperty(value = "社区类型")
-    private Integer type;
-
-    /**
-     * 有效期天数
-     */
-    @ApiModelProperty(value = "有效期天数")
-    private Integer validityDay;
-
     /**
      * 创建天数
      */

mcwl-communityCenter/src/main/java/com/mcwl/communityCenter/mapper/IncomeInfoMapper.java

@@ -25,7 +25,7 @@ public interface IncomeInfoMapper extends BaseMapper<IncomeInfo> {
     @InterceptorIgnore(tenantLine = "true")
     IncomeAmountVo questionIncome(@Param("userId") Long userId);
 
-    Double totalIncome(@Param("userId") Long userId);
+    Double totalIncome();
 
     @InterceptorIgnore(tenantLine = "true")
     List<IncomeInfoListVo> incomeList(Page<IncomeInfo> page,

mcwl-communityCenter/src/main/java/com/mcwl/communityCenter/service/PublishReportService.java

@@ -3,7 +3,6 @@ package com.mcwl.communityCenter.service;
 import com.baomidou.mybatisplus.annotation.InterceptorIgnore;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.mcwl.common.core.domain.R;
-import com.mcwl.common.core.page.PageDomain;
 import com.mcwl.common.core.page.TableDataInfo;
 import com.mcwl.communityCenter.domain.Publish;
 import com.mcwl.communityCenter.domain.PublishReport;
@@ -15,6 +14,4 @@ import javax.validation.Valid;
 public interface PublishReportService extends IService<PublishReport> {
 
     void saveReport(PublishReport publishReport);
-
-    TableDataInfo getReportList(@Valid PageDomain pageDomain);
 }

mcwl-communityCenter/src/main/java/com/mcwl/communityCenter/service/impl/CommunityServiceImpl.java

@@ -14,7 +14,10 @@ import com.mcwl.common.exception.ServiceException;
 import com.mcwl.common.utils.SecurityUtils;
 import com.mcwl.common.utils.StringUtils;
 import com.mcwl.communityCenter.constant.AdviceConstant;
-import com.mcwl.communityCenter.domain.*;
+import com.mcwl.communityCenter.domain.Community;
+import com.mcwl.communityCenter.domain.CommunityAdvice;
+import com.mcwl.communityCenter.domain.CommunityUser;
+import com.mcwl.communityCenter.domain.Publish;
 import com.mcwl.communityCenter.domain.dto.*;
 import com.mcwl.communityCenter.domain.vo.CommunityDetailVo;
 import com.mcwl.communityCenter.domain.vo.CommunityVo;
@@ -22,19 +25,15 @@ import com.mcwl.communityCenter.mapper.CommunityAdviceMapper;
 import com.mcwl.communityCenter.mapper.CommunityMapper;
 import com.mcwl.communityCenter.mapper.CommunityUserMapper;
 import com.mcwl.communityCenter.service.CommunityService;
-import com.mcwl.communityCenter.service.IncomeInfoService;
 import com.mcwl.communityCenter.service.PublishService;
-import com.mcwl.myInvitation.domain.CommissionRatio;
 import com.mcwl.myInvitation.domain.Consume;
 import com.mcwl.myInvitation.mapper.ConsumeMapper;
-import com.mcwl.myInvitation.service.CommissionRatioService;
 import com.mcwl.system.service.ISysUserService;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
 import java.math.BigDecimal;
-import java.math.RoundingMode;
 import java.time.LocalDate;
 import java.time.ZoneId;
 import java.time.temporal.ChronoUnit;
@@ -59,10 +58,6 @@ public class CommunityServiceImpl extends ServiceImpl<CommunityMapper, Community
 
     private final ConsumeMapper consumeMapper;
 
-    private final IncomeInfoService incomeInfoService;
-
-    private final CommissionRatioService commissionRatioService;
-
 
 
     @Override
@@ -147,29 +142,6 @@ public class CommunityServiceImpl extends ServiceImpl<CommunityMapper, Community
 
         sysUserService.updateUser(user);
 
-
-
-        // 从redis获取提成比例
-        // 抽取社区比例
-        String commissionRationCommunity = redisCache.getCacheObject("CommissionRationCommunity");
-        if (Objects.isNull(commissionRationCommunity)) {
-            CommissionRatio commissionRatio = commissionRatioService.lambdaQuery()
-                    .eq(CommissionRatio::getType, 2)
-                    .one();
-            commissionRationCommunity = commissionRatio.getRatio().toString();
-            redisCache.setCacheObject("CommissionRationCommunity", commissionRationCommunity);
-        }
-
-        SysUser tenantUser = sysUserService.selectUserById(tenantId);
-        BigDecimal getWallet = priceBigDecimal
-                .multiply(new BigDecimal("1").subtract(new BigDecimal(commissionRationCommunity)));
-        tenantUser.setWallet(getWallet
-                .add(new BigDecimal(tenantUser.getWallet().toString()))
-                .setScale(2, RoundingMode.HALF_UP)
-                .doubleValue());
-        sysUserService.updateUser(tenantUser);
-
-
         Calendar now = Calendar.getInstance();
         Date startTime = now.getTime();
         now.add(Calendar.YEAR, community.getValidityDay());
@@ -198,7 +170,7 @@ public class CommunityServiceImpl extends ServiceImpl<CommunityMapper, Community
         communityAdvice.setAdviceType(AdviceConstant.COMMUNITY_NOTICE);
         communityAdvice.setUserId(tenantId);
         communityAdvice.setContent(StringUtils.format("{}加入{}社区，金币+{}",
-                SecurityUtils.getLoginUser().getUser().getNickName(), community.getCommunityName(), getWallet));
+                SecurityUtils.getLoginUser().getUser().getNickName(), community.getCommunityName(), price));
         communityAdviceMapper.insert(communityAdvice);
 
         Consume consume = new Consume();
@@ -211,20 +183,12 @@ public class CommunityServiceImpl extends ServiceImpl<CommunityMapper, Community
 
         consume = new Consume();
         consume.setUserId(community.getTenantId());
-        consume.setAmount(getWallet.doubleValue());
+        consume.setAmount(price);
         consume.setProductId(communityId);
         consume.setType(3);
         consume.setWallet(sysUserService.selectUserById(community.getTenantId()).getWallet());
         consumeMapper.insert(consume);
 
-        IncomeInfo incomeInfo = new IncomeInfo();
-        incomeInfo.setTenantId(tenantId);
-        incomeInfo.setCommunityId(communityId);
-        incomeInfo.setUserId(tenantId);
-        incomeInfo.setType(0);
-        incomeInfo.setAmount(getWallet.doubleValue());
-        incomeInfoService.save(incomeInfo);
-
         redisCache.deleteObject("communityJoinNumMap");
 
 
@@ -335,7 +299,7 @@ public class CommunityServiceImpl extends ServiceImpl<CommunityMapper, Community
 
         List<Community> myJoinCommunityList = baseMapper.getMyJoinCommunity(new Page<>(1, 100),
                 SecurityUtils.getUserId(),
-                JoinCommunityListPageRes.builder().isMyCreate(1).build());
+                new JoinCommunityListPageRes());
 
         Map<Long, Community> myJoinCommunityMap = myJoinCommunityList.stream()
                 .collect(Collectors.toMap(Community::getId, Function.identity()));

mcwl-communityCenter/src/main/java/com/mcwl/communityCenter/service/impl/IncomeInfoServiceImpl.java

@@ -49,7 +49,7 @@ public class IncomeInfoServiceImpl extends ServiceImpl<IncomeInfoMapper, IncomeI
         IncomeAmountVo questionIncome = baseMapper.questionIncome(SecurityUtils.getUserId());
 
         // 累计收益
-        Double totalIncome = baseMapper.totalIncome(SecurityUtils.getUserId());
+        Double totalIncome = baseMapper.totalIncome();
 
         IncomeInfoVo incomeInfoVo = IncomeInfoVo.builder()
                 .communityIncome(communityIncome)

mcwl-communityCenter/src/main/java/com/mcwl/communityCenter/service/impl/PublishReportServiceImpl.java

@@ -1,7 +1,6 @@
 package com.mcwl.communityCenter.service.impl;
 
 import cn.hutool.core.bean.BeanUtil;
-import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.OrderItem;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
@@ -42,17 +41,4 @@ public class PublishReportServiceImpl extends ServiceImpl<PublishReportMapper, P
         baseMapper.insertReport(publishReport);
 
     }
-
-    @Override
-    public TableDataInfo getReportList(PageDomain pageDomain) {
-        Page<PublishReport> page = new Page<>(pageDomain.getPageNum(), pageDomain.getPageSize());
-        baseMapper.selectPage(page, new LambdaQueryWrapper<PublishReport>());
-        List<PublishReport> records = page.getRecords();
-        TableDataInfo tableDataInfo = new TableDataInfo();
-        tableDataInfo.setRows(records);
-        tableDataInfo.setTotal(page.getTotal());
-        tableDataInfo.setCode(HttpStatus.SUCCESS);
-        tableDataInfo.setMsg("查询成功");
-        return tableDataInfo;
-    }
 }

mcwl-communityCenter/src/main/java/com/mcwl/communityCenter/service/impl/QuestionCommentServiceImpl.java

@@ -17,7 +17,6 @@ import com.mcwl.communityCenter.domain.dto.*;
 import com.mcwl.communityCenter.domain.vo.QuestionCommentVo;
 import com.mcwl.communityCenter.domain.vo.QuestionVo;
 import com.mcwl.communityCenter.mapper.*;
-import com.mcwl.communityCenter.service.IncomeInfoService;
 import com.mcwl.communityCenter.service.QuestionCommentService;
 import com.mcwl.communityCenter.service.QuestionService;
 import com.mcwl.myInvitation.domain.Consume;
@@ -47,8 +46,6 @@ public class QuestionCommentServiceImpl extends ServiceImpl<QuestionCommentMappe
 
     private final ConsumeMapper consumeMapper;
 
-    private final IncomeInfoService incomeInfoService;
-
     @Override
     @Transactional(rollbackFor = Exception.class)
     public R<Object> comment(QuestionCommentRes questionCommentRes) {
@@ -160,7 +157,7 @@ public class QuestionCommentServiceImpl extends ServiceImpl<QuestionCommentMappe
         questionMapper.updateById(question);
 
 
-        SysUser sysUser = sysUserService.selectUserById(questionComment.getUserId());
+        SysUser sysUser = sysUserService.selectUserById(tenantId);
         BigDecimal sysWallet = new BigDecimal(sysUser.getWallet().toString());
         BigDecimal amount = new BigDecimal(question.getAmount().toString());
         // 添加钱包
@@ -170,20 +167,12 @@ public class QuestionCommentServiceImpl extends ServiceImpl<QuestionCommentMappe
 
 
         Consume consume = new Consume();
-        consume.setUserId(questionComment.getUserId());
+        consume.setUserId(SecurityUtils.getUserId());
         consume.setAmount(question.getAmount());
         consume.setType(4);
         consume.setWallet(sysUser.getWallet());
         consumeMapper.insert(consume);
 
-        IncomeInfo incomeInfo = new IncomeInfo();
-        incomeInfo.setTenantId(tenantId);
-        incomeInfo.setCommunityId(communityId);
-        incomeInfo.setUserId(questionComment.getUserId());
-        incomeInfo.setType(1);
-        incomeInfo.setAmount(question.getAmount());
-        incomeInfoService.save(incomeInfo);
-
 
         return R.ok();
     }

mcwl-communityCenter/src/main/resources/mapper/communityCenter/CommunityMapper.xml

@@ -15,7 +15,7 @@
     </resultMap>
     <update id="quitCommunity">
         update cc_community_user
-        set del_flag = '2'
+        set del_flag = '1'
         where tenant_id = #{tenantId}
           and community_id = #{communityId}
           and user_id = #{userId}
@@ -24,7 +24,7 @@
 
     <update id="deleteCommunity">
         update cc_community
-        set del_flag = '2'
+        set del_flag = '1'
         where tenant_id = #{tenantId}
           and id = #{communityId}
           and del_flag = '0';
@@ -47,8 +47,6 @@
         select cu.community_id as id, COALESCE(count(*), 0) as join_num
         from cc_community_user cu
         where cu.del_flag = '0'
-          and ((CONVERT_TZ(NOW(), 'SYSTEM', '+08:00') &gt;= start_time
-            AND CONVERT_TZ(NOW(), 'SYSTEM', '+08:00') &lt;= end_time) or (start_time is null and end_time is null))
         group by cu.community_id
     </select>
 
@@ -104,8 +102,6 @@
             and (c.community_name like concat('%', #{joinCommunityListPageRes.searchContent}, '%')
             or c.description like concat('%', #{joinCommunityListPageRes.searchContent}, '%'))
         </if>
-        and ((CONVERT_TZ(NOW(), 'SYSTEM', '+08:00') &gt;= start_time
-        AND CONVERT_TZ(NOW(), 'SYSTEM', '+08:00') &lt;= end_time) or (start_time is null and end_time is null))
     </select>
     <select id="getCommunity" resultType="com.mcwl.communityCenter.domain.Community">
         select *

mcwl-communityCenter/src/main/resources/mapper/communityCenter/CommunityUserMapper.xml

@@ -103,6 +103,7 @@
           and user_id = #{userId}
           and ((CONVERT_TZ(NOW(), 'SYSTEM', '+08:00') >= start_time
             AND CONVERT_TZ(NOW(), 'SYSTEM', '+08:00') <= end_time) or (start_time is null and end_time is null))
+          and (black_end_time is null or NOW() >= black_end_time)
           and del_flag = '0';
     </select>
     <select id="getAllCommunityUser" resultType="com.mcwl.communityCenter.domain.CommunityUser">

mcwl-communityCenter/src/main/resources/mapper/communityCenter/IncomeInfoMapper.xml

@@ -9,7 +9,7 @@
         SELECT SUM(IF(DATE(create_time) = CURDATE(), amount, 0))                  AS today_income,
                SUM(IF(DATE(create_time) = CURDATE() - INTERVAL 1 DAY, amount, 0)) AS yesterday_income
         FROM cc_income_info
-        WHERE user_id = #{userId}
+        WHERE tenant_id = #{userId}
           AND type = 0
           AND del_flag = '0'
     </select>
@@ -18,14 +18,14 @@
         SELECT SUM(IF(DATE(create_time) = CURDATE(), amount, 0))                  AS today_income,
                SUM(IF(DATE(create_time) = CURDATE() - INTERVAL 1 DAY, amount, 0)) AS yesterday_income
         FROM cc_income_info
-        WHERE user_id = #{userId}
+        WHERE tenant_id = #{userId}
           AND type = 1
           AND del_flag = '0'
     </select>
     <select id="totalIncome" resultType="java.lang.Double">
         SELECT SUM(amount)
         FROM cc_income_info
-        WHERE del_flag = '0' and user_id = #{userId}
+        WHERE del_flag = '0'
     </select>
     <select id="incomeList" resultType="com.mcwl.communityCenter.domain.vo.IncomeInfoListVo">
         SELECT u.nick_name as user_name,
@@ -39,7 +39,7 @@
         on ii.tenant_id = c.tenant_id
         and ii.community_id = c.id
         left join sys_user u on c.tenant_id = u.user_id
-        where ii.user_id = #{userId}
+        where ii.tenant_id = #{userId}
         <if test="incomeInfoListPageRes.type != null ">
             and ii.type = #{incomeInfoListPageRes.type}
         </if>

mcwl-myInvitation/src/main/java/com/mcwl/myInvitation/domain/CommissionRatio.java

@@ -34,10 +34,6 @@ public class CommissionRatio extends BaseEntity {
      * 类型 0邀请人-被邀请人 1公司-商家
      */
     private Integer type;
-    /**
-     * 描述
-     */
-    private String description;
 
 
 }

mcwl-myInvitation/src/main/java/com/mcwl/myInvitation/domain/vo/CommissionRatioVo.java

@@ -31,7 +31,7 @@ public class CommissionRatioVo {
      */
     private Double ratio;
     /**
-     * 提成类型，平台手续费、邀请人提成、星球手续费
+     * 提成类型，平台手续费、邀请人提成
      */
     private String ratioName;
 

mcwl-myInvitation/src/main/java/com/mcwl/myInvitation/service/impl/CommissionRatioServiceImpl.java

@@ -49,7 +49,6 @@ public class CommissionRatioServiceImpl extends ServiceImpl<CommissionRatioMappe
 
         redisCache.deleteObject("CommissionRationInviterUser");
         redisCache.deleteObject("CommissionRationMerchant");
-        redisCache.deleteObject("CommissionRationCommunity");
 
         return this.getCommissionRatioVo(commissionRatio);
     }
@@ -67,7 +66,11 @@ public class CommissionRatioServiceImpl extends ServiceImpl<CommissionRatioMappe
     private CommissionRatioVo getCommissionRatioVo(CommissionRatio commissionRatio) {
         CommissionRatioVo vo = new CommissionRatioVo();
         BeanUtil.copyProperties(commissionRatio, vo);
-        vo.setRatioName(commissionRatio.getDescription());
+        if (commissionRatio.getType() == 0) {
+            vo.setRatioName("平台手续费");
+        } else if (commissionRatio.getType() == 1) {
+            vo.setRatioName("邀请人提成");
+        }
         return vo;
     }