skums资料库数据修改

data-base/base-sync-sku/src/main/java/com/bailuntec/job/SkuMSSyncJob.java

@@ -28,6 +28,7 @@ import org.apache.commons.lang3.StringUtils;
 import java.io.IOException;
 import java.time.LocalDateTime;
 import java.util.List;
+import java.util.stream.Collectors;
 
 @Slf4j
 public class SkuMSSyncJob extends PointJob {
@@ -37,8 +38,7 @@ public class SkuMSSyncJob extends PointJob {
     @Override
     public void executeJob(ShardingContext shardingContext, JobPointLog jobPointLog) {
         SkumsRequest skumsRequest = new SkumsRequest();
-     //   skumsRequest.setConditionJson(JSON.toJSONString(new SkuCondition(jobPointLog.getStartTime().minusMinutes(3), jobPointLog.getEndTime())));
-        skumsRequest.setSearchKeyWord("946357605");
+        skumsRequest.setConditionJson(JSON.toJSONString(new SkuCondition(jobPointLog.getStartTime().minusMinutes(3), jobPointLog.getEndTime())));
         skumsRequest.setPageNumber(jobPointLog.getPageSize());
         do {
             MediaType mediaType = MediaType.parse("application/json");
@@ -130,7 +130,10 @@ public class SkuMSSyncJob extends PointJob {
                         dcBaseSkuTag.setTagValuesName(gmtProductTag.getTagValuesName() == null ? "" : gmtProductTag.getTagValuesName());
                         dcBaseSkuTagMapper.upsertSelective(dcBaseSkuTag);
                     }
-                    if(skuInfo.getTags() != null) dcBaseSku.setTags(JSONObject.toJSONString(skuInfo.getTags()));
+                    if(skuInfo.getTags() != null) {
+                        String tagName = skuInfo.getTags().stream().map(GmtProductTag::getTagValuesName).collect(Collectors.joining(","));
+                        dcBaseSku.setTags(tagName);
+                    }
                     dcBaseSku.setGmtModified(LocalDateTime.now());
                     if(dcBaseSku.getPushTime().isBefore(LocalDateTime.of(1991, 01, 01, 00, 00, 00))) {
                         dcBaseSku.setPushTime(LocalDateTime.of(1991, 01, 01, 00, 00, 00));