更新白名单功能

menduner/menduner-system-biz/src/main/java/com/citu/module/menduner/system/dal/mysql/enterprise/EnterpriseEntitlementMapper.java

@@ -10,6 +10,8 @@ import com.citu.module.menduner.system.dal.dataobject.enterprise.EnterpriseDO;
 import com.citu.module.menduner.system.dal.dataobject.enterprise.EnterpriseEntitlementDO;
 import com.citu.module.menduner.system.enums.MendunerStatusEnum;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Update;
 
 import java.util.List;
 
@@ -42,4 +44,6 @@ public interface EnterpriseEntitlementMapper extends BaseMapperX<EnterpriseEntit
         return selectJoinList(EnterpriseEntitlementDO.class,wrapper);
     }
 
+    @Update("update mde_enterprise_entitlement set publish_job_count = publish_job_count + #{publishJobCount},tmp_publish_job_count=tmp_publish_job_count+#{publishJobCount} where enterprise_id = #{enterpriseId}")
+    void addPublishJobCount(@Param("enterpriseId") Long enterpriseId,@Param("publishJobCount") int publishJobCount);
 }

menduner/menduner-system-biz/src/main/java/com/citu/module/menduner/system/mq/consumer/PublishJobConsumer.java

@@ -8,10 +8,13 @@ import com.citu.module.menduner.system.service.order.TradeOrderService;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
 import org.apache.rocketmq.spring.core.RocketMQListener;
+import org.springframework.beans.factory.InitializingBean;
 import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
 import java.time.LocalDateTime;
+import java.util.Arrays;
+import java.util.List;
 
 /**
  * 职位完成支付 消费
@@ -22,7 +25,7 @@ import java.time.LocalDateTime;
         topic = TradeOrderTypeMq.PUBLISH_JOB_ORDER_TOPIC,
         consumerGroup = TradeOrderTypeMq.PUBLISH_JOB_ORDER_TOPIC + "_CONSUMER"
 )
-public class PublishJobConsumer implements RocketMQListener<Long> {
+public class PublishJobConsumer implements RocketMQListener<Long>, InitializingBean {
 
     @Resource
     private TradeOrderService tradeOrderService;
@@ -39,4 +42,18 @@ public class PublishJobConsumer implements RocketMQListener<Long> {
         LocalDateTime newExpireTime = updateTime.plusDays(120);
         service.enableAndUpdateExpireTime(order.getSpuId(), newExpireTime);
     }
+
+    @Override
+    public void afterPropertiesSet() throws Exception {
+//        List<Long> orderIds = Arrays.asList(1917056564511010817L,1917054375080128514L,1917050820629786625L,1917040901570588674L,1915679688345415681L);
+//        for (Long orderId : orderIds) {
+//            log.info("人工处理 消息[{}]", orderId);
+//            TradeOrderDO order = tradeOrderService.getOrder(orderId);
+//            // 计算新的过期时间,支付时间+120天
+//            LocalDateTime updateTime = order.getPayTime();
+//            LocalDateTime newExpireTime = updateTime.plusDays(120);
+//            service.enableAndUpdateExpireTime(order.getSpuId(), newExpireTime);
+//        }
+
+    }
 }

menduner/menduner-system-biz/src/main/java/com/citu/module/menduner/system/service/enterprise/vip/EnterpriseEntitlementService.java

@@ -105,4 +105,5 @@ public interface EnterpriseEntitlementService {
      */
      boolean checkPermissionRetBol(String type);
 
+    void addPublishJobCount(Long enterpriseId, int publishJobCount);
 }

menduner/menduner-system-biz/src/main/java/com/citu/module/menduner/system/service/enterprise/vip/EnterpriseEntitlementServiceImpl.java

@@ -340,4 +340,9 @@ public class EnterpriseEntitlementServiceImpl implements EnterpriseEntitlementSe
         }
         return false;
     }
+
+    @Override
+    public void addPublishJobCount(Long enterpriseId, int publishJobCount) {
+        mapper.addPublishJobCount(enterpriseId, publishJobCount);
+    }
 }

menduner/menduner-system-biz/src/main/java/com/citu/module/menduner/system/service/fair/FairWhiteServiceImpl.java

@@ -1,5 +1,6 @@
 package com.citu.module.menduner.system.service.fair;
 
+import cn.hutool.core.io.FileUtil;
 import com.baomidou.dynamic.datasource.annotation.DSTransactional;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
@@ -12,6 +13,9 @@ import com.citu.module.menduner.system.dal.mysql.fair.FairDetailMapper;
 import com.citu.module.menduner.system.dal.mysql.fair.FairWhiteMapper;
 import com.citu.module.menduner.system.enums.MendunerStatusEnum;
 import com.citu.module.menduner.system.enums.fair.JobFairWhiteSourceEnum;
+import com.citu.module.menduner.system.service.enterprise.vip.EnterpriseEntitlementService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Service;
 import org.springframework.validation.annotation.Validated;
@@ -32,6 +36,7 @@ import static com.citu.module.menduner.system.enums.ErrorCodeConstants.*;
 @Validated
 public class FairWhiteServiceImpl implements FairWhiteService {
 
+    private static final Logger log = LoggerFactory.getLogger(FairWhiteServiceImpl.class);
     @Resource
     private FairWhiteMapper mapper;
 
@@ -39,6 +44,9 @@ public class FairWhiteServiceImpl implements FairWhiteService {
     @Lazy
     private FairDetailMapper fairDetailMapper;
 
+    @Resource
+    private EnterpriseEntitlementService enterpriseEntitlementService;
+
     @Override
     public PageResult<FairWhiteDetailRespVO> selectPage(FairWhitePageReqVO reqVO) {
         return mapper.selectPage(reqVO);
@@ -63,6 +71,11 @@ public class FairWhiteServiceImpl implements FairWhiteService {
                     .sort(sort)
                     .first(false)
                     .build());
+            // TODO 临时增加企业 可招聘职位数量
+            enterpriseEntitlementService.addPublishJobCount(enterpriseId, 99999999);
+            // 记录 添加的企业ID信息
+            log.info("添加企业招聘会白名单 {} {},并且增加可发布职位数量{}", enterpriseId, jobFairId,99999999);
+
         }
     }