Merge branch 'bugfix_20231219_weimo_order' into 'master'

feature: 微盟销售线索 校验是否有内容权限

See merge request !1590

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/out/impl/content/MallOrderStatusChangeApiServiceImpl.java

@@ -9,6 +9,9 @@ import com.gic.business.order.enums.OrderEnum;
 import com.gic.business.order.qdto.ordermanage.OrderInfoQDTO;
 import com.gic.business.order.service.ordermanage.OrderInfoOutApiService;
 import com.gic.commons.util.GICMQClientUtil;
+import com.gic.enterprise.api.constant.EnterpriseServiceEnum;
+import com.gic.enterprise.api.dto.enterprise.EnterpriseUsingStatusDTO;
+import com.gic.enterprise.api.service.EnterpriseUseForbidService;
 import com.gic.haoban.manage.api.enums.content.MaterialInteractRecordEventType;
 import com.gic.haoban.manage.api.enums.content.ShareBizType;
 import com.gic.haoban.manage.api.service.content.MallOrderStatusChangeApiService;
@@ -23,12 +26,16 @@ import com.gic.order.api.dto.OrderDTO;
 import com.gic.order.api.dto.req.MemberOrderOptional;
 import com.gic.order.api.service.member.MemberOrderReadApiService;
 import com.gic.orderecommerce.api.service.EcommerceOrderOutputApiService;
+import com.gic.redis.data.util.RedisUtil;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
 import java.util.Date;
+import java.util.List;
+import java.util.concurrent.TimeUnit;
 
 /**
  * @Author MUSI
@@ -47,11 +54,13 @@ public class MallOrderStatusChangeApiServiceImpl implements MallOrderStatusChang
     InteractRecordMessageService interactRecordMessageService;
     @Autowired
     private MaterialDataAdaptor materialDataAdaptor;
-
-
+    @Autowired
+    private EnterpriseUseForbidService enterpriseUseForbidService;
 
     private static final String ORDER_EVENT_RETRY = "orderEventRetryMQ";
 
+    private static final Long cache_hour_sec = 300L;
+
     /***
      * 订单状态变更事件
      * @param params
@@ -174,6 +183,31 @@ public class MallOrderStatusChangeApiServiceImpl implements MallOrderStatusChang
             return ServiceResponse.success();
         }
         String enterpriseId = memberOrderBo.getEnterpriseId();
+
+        String key = "haoban_enterprise_content_deal_weimob:" + enterpriseId;
+        String cache = RedisUtil.getCache(key, String.class);
+        if (StringUtils.isBlank(cache)) {
+            cache = "0";
+            ServiceResponse<List<EnterpriseUsingStatusDTO>> tempServiceResponse = enterpriseUseForbidService.getUseEnterpriseByCode(EnterpriseServiceEnum.CONTENT.getRightMenuCode(), enterpriseId);
+            if (!tempServiceResponse.isSuccess() || CollectionUtils.isEmpty(tempServiceResponse.getResult())) {
+                log.info("企业 {} 没有内容权限 {}", enterpriseId, JSON.toJSONString(tempServiceResponse));
+                RedisUtil.setCache(key, cache, cache_hour_sec, TimeUnit.SECONDS);
+                return ServiceResponse.success();
+            }
+            EnterpriseUsingStatusDTO enterpriseUsingStatusDTO = tempServiceResponse.getResult().get(0);
+            if (!Boolean.TRUE.equals(enterpriseUsingStatusDTO.getVaild())) {
+                log.info("企业 {} 内容权限已失效 {}", enterpriseId, JSON.toJSONString(tempServiceResponse));
+                RedisUtil.setCache(key, cache, cache_hour_sec, TimeUnit.SECONDS);
+                return ServiceResponse.success();
+            }
+            cache = "1";
+            RedisUtil.setCache(key, cache, cache_hour_sec, TimeUnit.SECONDS);
+        }
+        if (!StringUtils.equals(cache, "1")) {
+            log.info("企业 {} 没有内容权限", enterpriseId);
+            return ServiceResponse.success();
+        }
+
         String memberId = memberOrderBo.getMemberId();
         String orderId = memberOrderBo.getOrderId();
         String orderNumber = memberOrderBo.getOrderNumber();