订单绑定接口修改

liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/java/com/liquidnet/service/goblin/service/impl/GoblinAppZhengzaiServiceImpl.java

@@ -3,6 +3,7 @@ package com.liquidnet.service.goblin.service.impl;
 import com.liquidnet.commons.lang.util.CollectionUtil;
 import com.liquidnet.commons.lang.util.CurrentUtil;
 import com.liquidnet.service.adam.dto.vo.AdamUserInfoVo;
+import com.liquidnet.service.adam.dto.vo.AdamUserMemberVo;
 import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.base.SqlMapping;
 import com.liquidnet.service.base.constant.MQConst;
@@ -238,11 +239,21 @@ public class GoblinAppZhengzaiServiceImpl implements IGoblinAppZhengzaiService {
                     continue;
                 }
                 AdamUserInfoVo userInfoVo = adamRedisUtils.getUserInfoVoByUid(uid);
+                AdamUserMemberVo adamUserMemberVo = adamRedisUtils.getUserMemberVoByUid(uid);
                 if (userInfoVo == null) {
                     return ResponseDto.failure("用户不存在");
                 }
                 String userMobile = userInfoVo.getMobile();
+                String userName = userInfoVo.getNickname();
+                Integer isMember = 0;
+                if(adamUserMemberVo==null || "INVALID".equals(adamUserMemberVo.getState())) {
+                    isMember = 0;
+                }else{
+                    isMember = 1;
+                }
                 storeOrderVo.setUserMobile(userMobile);
+                storeOrderVo.setUserName(userName);
+                storeOrderVo.setIsMember(isMember);
                 storeOrderVo.setUserId(uid);
                 priceActual = priceActual.add(storeOrderVo.getPriceActual());
                 //mongo
@@ -253,7 +264,7 @@ public class GoblinAppZhengzaiServiceImpl implements IGoblinAppZhengzaiService {
                 //mysql
                 queueUtils.sendMsgByRedis(MQConst.GoblinQueue.GOBLIN_STORE_ORDER_OPERA.getKey(),
                         SqlMapping.get("goblin_order.zhengzai.bind",
-                                userMobile, uid, now, storeOrderVo.getOrderId(), now, now));
+                                isMember,userName,userMobile, uid, now, storeOrderVo.getOrderId(), now, now));
             }
             if (priceActual.compareTo(BigDecimal.ZERO) != 0) {
                 goblinOrderUtils.integral(uid, priceActual, "购买商品", 1);

liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/java/com/liquidnet/service/goblin/util/AdamRedisUtils.java

@@ -3,10 +3,13 @@ package com.liquidnet.service.goblin.util;
 import com.liquidnet.common.cache.redis.util.RedisUtil;
 import com.liquidnet.service.adam.constant.AdamRedisConst;
 import com.liquidnet.service.adam.dto.vo.AdamUserInfoVo;
+import com.liquidnet.service.adam.dto.vo.AdamUserMemberVo;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
+import java.time.LocalDateTime;
+
 @Slf4j
 @Component
 public class AdamRedisUtils {
@@ -20,4 +23,15 @@ public class AdamRedisUtils {
         log.debug("#RDM耗时:{}ms", System.currentTimeMillis() - s);
         return vo;
     }
+
+    public AdamUserMemberVo getUserMemberVoByUid(String uid) {
+        String rk = AdamRedisConst.INFO_USER_MEMBER.concat(uid);
+        long s = System.currentTimeMillis();
+        AdamUserMemberVo vo = (AdamUserMemberVo) redisUtil.get(rk);
+        if (null != vo) {
+            vo.setState(vo.getState() == 1 ? (vo.getExpiryAt().isAfter(LocalDateTime.now()) ? 1 : 2) : vo.getState());
+        }
+        log.debug("#RDM耗时:{}ms", System.currentTimeMillis() - s);
+        return vo;
+    }
 }

liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/resources/sqlmap.properties

@@ -89,7 +89,7 @@ goblin.self.market.insertRelation=INSERT INTO goblin_marketing_zhengzai (`zhengz
 goblin.self.market.updateRelation=UPDATE goblin_marketing_zhengzai SET price_marketing=? ,stock_marketing=? , buy_factor=?,buy_roster=?,buy_limit=?,updated_at=? WHERE self_market_id =? and store_id =? and sku_id = ?
 goblin.self.market.delSpuRelation=UPDATE goblin_marketing_zhengzai SET del_flag = ?,updated_at = ? WHERE self_market_id =? and store_id =? and spu_id=?
 #----                   \u8BA2\u5355\u7ED1\u5B9A[\u6B63\u5728\u4E0B\u5355] \u51FA\u8D27
-goblin_order.zhengzai.bind=UPDATE goblin_store_order SET user_mobile = ? , user_id = ? ,updated_at = ? WHERE order_id = ? and (updated_at <= ? or created_at = ? or updated_at is null)
+goblin_order.zhengzai.bind=UPDATE goblin_store_order SET is_member = ? ,user_name = ? , user_mobile = ? , user_id = ? ,updated_at = ? WHERE order_id = ? and (updated_at <= ? or created_at = ? or updated_at is null)
 goblin_order.zhengzai.push=UPDATE goblin_store_order SET zhengzai_status = ? ,status = ?,updated_at = ? WHERE order_id = ? and (updated_at <= ? or created_at = ? or updated_at is null)
 #----                   \u5546\u94FA\u8BA2\u5355\u64CD\u4F5C
 goblin_order.store.cancel=UPDATE goblin_store_order SET status = ? ,cancel_time = ? , cancel_reason = ? , updated_at = ? WHERE order_id = ? and (updated_at <= ? or created_at = ? or updated_at is null)