From b7e17826ac39797f0962dc6efe5d00613de2753b Mon Sep 17 00:00:00 2001 From: liuyingfang <1357764963@qq.com> Date: Thu, 7 Sep 2023 14:09:29 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8B=89=E5=8D=A1=E6=8B=89=E8=BF=9B=E4=BB=B6?= =?UTF-8?q?=E9=80=9A=E7=9F=A5=E5=8A=A0=E5=85=A5mcc?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../platform/task/LklMerAuditHandler.java | 20 ++++++++++++------- 1 file changed, 13 insertions(+), 7 deletions(-) diff --git a/pluss-service-bundle/src/main/java/cn/pluss/platform/task/LklMerAuditHandler.java b/pluss-service-bundle/src/main/java/cn/pluss/platform/task/LklMerAuditHandler.java index 0957121..f1b6b63 100644 --- a/pluss-service-bundle/src/main/java/cn/pluss/platform/task/LklMerAuditHandler.java +++ b/pluss-service-bundle/src/main/java/cn/pluss/platform/task/LklMerAuditHandler.java @@ -20,6 +20,7 @@ import cn.pluss.platform.user.impl.GeneralPushUtil; import cn.pluss.platform.userApp.UserAppService; import cn.pluss.platform.util.IpUtils; import cn.pluss.platform.util.LogExceptionUtils; +import cn.pluss.platform.util.ParametersUtil; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; @@ -39,10 +40,7 @@ import org.springframework.web.client.RestTemplate; import javax.annotation.Resource; import java.io.UnsupportedEncodingException; import java.net.URLEncoder; -import java.util.Collections; -import java.util.Date; -import java.util.HashMap; -import java.util.Map; +import java.util.*; @Slf4j @Component @@ -364,14 +362,21 @@ public class LklMerAuditHandler { UserInfo userInfo = userInfoMapper.selectById(userApp.getUserId()); log.info("==============>当前需要同步的用户进件数据为：:{}<===================", JSONObject.toJSONString(merchantChannelStatus)); if (userInfo != null) { - MerchantStore merchantStore = new MerchantStore().setMerchantCode(merchantChannelStatus.getMerchantCode()); - merchantStore = merchantStoreMapper.selectOne(new QueryWrapper<>(merchantStore)); + QueryWrapper storQueryWrapper= new QueryWrapper<>(); + storQueryWrapper.eq("merchantCode",merchantChannelStatus.getMerchantCode()); + MerchantStore merchantStore = merchantStoreMapper.selectOne(storQueryWrapper); MerchantBaseInfo merchantBaseInfo = merchantBaseInfoService.getMerchantBaseInfoByMerchantCode(merchantChannelStatus.getMerchantCode()); QueryWrapper queryWrapper = new QueryWrapper() .eq("merchantCode", merchantChannelStatus.getMerchantCode()).eq("photoType", "06"); MerchantImage merchantImage = merchantImageMapper.selectOne(queryWrapper); //String baseUrl = "https://life.sxczgkj.cn/web/wmerchant.php?c=site&a=entry&ctrl=store&ac=oauth&op=add_merchan&do=web&m=we7_wmall&i=1"; - String baseUrl = "https://kysh.sxczgkj.cn/javaApi/java-api/add-store"; + List mccList = ParametersUtil.url; + if(ObjectUtil.isEmpty(mccList)||mccList.size()<=0){ + log.error("没有配置对应的通之地址"); + return; + } + mccList.stream().parallel().forEach(it->{ + String baseUrl = it.toString(); StringBuilder sb = new StringBuilder(baseUrl); sb.append("?title=").append(merchantBaseInfo.getAlias()); sb.append("&password=").append(userInfo.getPassword().toLowerCase()); @@ -402,6 +407,7 @@ public class LklMerAuditHandler { // 请求生成店铺j String result = restTemplate.getForObject(sb.toString(), String.class); log.info("=============>请求生成店铺URL：{}，请求响应返回的参数为:{}<===============", sb.toString(), result); + }); } }