添加用户判断

ad-platform-manage/ad-platform-management/src/main/java/com/baiye/timed/DeliveryBalanceTask.java

@@ -12,11 +12,13 @@ import cn.hutool.core.util.ObjectUtil;
 import com.baiye.config.properties.DeliveryProperties;
 import com.baiye.constant.DefaultNumberConstants;
 import com.baiye.constant.FileConstant;
+import com.baiye.model.dto.UserDto;
 import com.baiye.modules.platform.domain.Company;
 import com.baiye.modules.platform.domain.TaskImei;
 import com.baiye.modules.platform.service.*;
 import com.baiye.modules.platform.service.dto.ImeiDTO;
 import com.baiye.modules.platform.service.dto.TaskTagDto;
+import com.baiye.modules.system.service.UserService;
 import com.baiye.util.*;
 import com.google.common.collect.Lists;
 import lombok.RequiredArgsConstructor;
@@ -45,11 +47,12 @@ public class DeliveryBalanceTask {
 
     private final TaskService taskService;
 
+    private final UserService userService;
+
     private final CompanyService companyService;
 
     private final TaskImeiService taskImeiService;
 
-
     private final DownRecordService downRecordService;
 
     private final DeliveryProperties deliveryProperties;
@@ -75,9 +78,12 @@ public class DeliveryBalanceTask {
                 log.info("=================== the task Id as {},upload size as {} ====================", taskId, list.size());
                 Long userId = list.get(DefaultNumberConstants.ZERO_NUMBER).getUserId();
                 Company companyByUserId = companyService.findCompanyByUserId(userId);
-                if (ObjectUtil.isNotNull(companyByUserId) &&
+                UserDto userInfo = userService.findUserInfo(userId);
+                if (ObjectUtil.isNotNull(userInfo)
+                        && Boolean.TRUE.equals(userInfo.getEnabled())
+                                && ObjectUtil.isNotNull(companyByUserId)
                         // 判断价格
-                        ObjectUtil.isNotNull(companyByUserId.getDmpDeliveryFee())) {
+                        && ObjectUtil.isNotNull(companyByUserId.getDmpDeliveryFee())) {
                     Integer dmpLimitNum = companyByUserId.getDmpLimitNum();
                     // 判断余额
                     if (ObjectUtil.isNull(companyByUserId.getUserBalance())

ad-platform-services/ad-platform-source/src/main/java/com/baiye/module/service/dto/ABMessageDTO.java

@@ -79,7 +79,7 @@ public class ABMessageDTO {
     /**
      * 业务名称 这个字段是用Base64进行加密
      */
-    @SerializedName("app_id")
+    @SerializedName("act_name")
     private String actName;
 
 
@@ -90,4 +90,11 @@ public class ABMessageDTO {
     private String audioUrl;
 
 
+    /**
+     * 人工评级分类
+     */
+    @SerializedName("emp_client_type_name")
+    private String empClientTypeName;
+
+
 }

ad-platform-services/ad-platform-source/src/main/java/com/baiye/module/service/impl/AbMessageServiceImpl.java

@@ -18,7 +18,6 @@ import com.baiye.util.MobileUtil;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
-import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -45,8 +44,9 @@ public class AbMessageServiceImpl implements AbMessageService {
     @Transactional(rollbackFor = Exception.class)
     public Boolean receiveDate(ABMessageDTO abMessageDTO) {
         String mobile = Base64.decodeStr(abMessageDTO.getMobile());
+        String typeName = abMessageDTO.getEmpClientTypeName();
         String jobNumber = abMessageDTO.getJobNumber();
-        if (StringUtils.isBlank(jobNumber) || StringUtils.isBlank(mobile) || !MobileUtil.checkPhone(mobile)) {
+        if (StringUtils.isBlank(jobNumber) || StringUtils.isBlank(mobile) || !MobileUtil.checkPhone(mobile) || !"A".equalsIgnoreCase(typeName)) {
             return Boolean.FALSE;
         }
         Long userId = userClient.findByJobNumber(jobNumber, SecurityConstants.FROM_IN);