广电激活判断状态

kxs-product/kxs-product-biz/src/main/java/com/kxs/product/biz/service/impl/KxsGdServiceImpl.java

@@ -4,6 +4,7 @@ import cn.hutool.core.bean.BeanUtil;
 import cn.hutool.core.date.DatePattern;
 import cn.hutool.core.date.LocalDateTimeUtil;
 import cn.hutool.core.lang.TypeReference;
+import cn.hutool.core.util.StrUtil;
 import cn.hutool.http.Header;
 import cn.hutool.http.HttpRequest;
 import cn.hutool.json.JSONUtil;
@@ -112,8 +113,10 @@ public class KxsGdServiceImpl implements KxsGdService {
             if(status != 6){
                 continue;
             }
-
             String gdMobile = orderData.getString("mobile");
+            if(StrUtil.isBlank(gdMobile)){
+                continue;
+            }
             KxsGdReport kxsGdReport = kxsGdReportMapper.selectOne(Wrappers.<KxsGdReport>lambdaQuery()
                     .eq(KxsGdReport::getIsCheck, GdReportEnum.CHECK_NO.getType())
                     .eq(KxsGdReport::getGdMobile, gdMobile));
@@ -126,6 +129,10 @@ public class KxsGdServiceImpl implements KxsGdService {
             msgEntity.setPhoneNo(orderData.getString("mobile"));
             msgEntity.setProductName(orderData.getString("productName"));
             msgEntity.setActivationStatusName("已激活");
+            msgEntity.setPromotionName(orderData.getString("offerName"));
+            msgEntity.setProvince(orderData.getString("province"));
+            msgEntity.setCity(orderData.getString("city"));
+            msgEntity.setOrderCreateTime(orderData.getString("createTime"));
             msgEntity.setActivationTime(LocalDateTimeUtil.format(LocalDateTime.now(), DatePattern.NORM_DATETIME_PATTERN));
 
             mqSender.send(RabbitGdActQueueMQ.build(msgEntity));