合并分支 'dxy' 到 'qa'

src/main/java/com/wangxiaolu/promotion/controller/user/tem/TemporaryInfoCoreController.java

@@ -11,6 +11,7 @@ import com.wangxiaolu.promotion.pojo.user.vo.WxTemporaryEnrollVo;
 import com.wangxiaolu.promotion.result.basedata.R;
 import com.wangxiaolu.promotion.result.basedata.RCode;
 import com.wangxiaolu.promotion.service.wechat.WeChatUserCoreService;
+import com.wangxiaolu.promotion.service.wechat.WeChatUserQueryService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -19,6 +20,7 @@ import org.springframework.web.bind.annotation.*;
 
 import java.time.LocalDate;
 import java.time.LocalDateTime;
+import java.util.Map;
 
 /**
  * @author : liqiulin
@@ -33,6 +35,8 @@ public class TemporaryInfoCoreController {
     @Autowired
     private WeChatUserCoreService weChatUserCoreService;
     @Autowired
+    private WeChatUserQueryService weChatUserQueryService;
+    @Autowired
     private RedisCache redisCache;
     @Autowired
     private EnvUtil envUtil;
@@ -75,6 +79,13 @@ public class TemporaryInfoCoreController {
         if (wxTemporaryEnrollVo.getOpenId() == null) {
             throw new ParamException(RCode.WX_OPENID_PARAM_ERROR, null);
         }
+        Map<String, Object> temporaryWorkStore = weChatUserQueryService.findTemporaryWorkStore(wxTemporaryEnrollVo.getOpenId(), LocalDate.now().toString());
+        if (temporaryWorkStore.get("storeName") ==  null || temporaryWorkStore.get("storeCode") == null ) {
+            WxTemporaryInfoDto temporaryDto = new WxTemporaryInfoDto();
+            BeanUtils.copyProperties(wxTemporaryEnrollVo, temporaryDto);
+            weChatUserCoreService.saveWxUserStoreInfoTemporary(temporaryDto);
+        }
+
         // 转换为延迟表实体
         WxTemporaryInfoDelayDtO delayEntity = new WxTemporaryInfoDelayDtO();
         BeanUtils.copyProperties(wxTemporaryEnrollVo, delayEntity);