chenw 7 лет назад
Родитель
Сommit
14f6b38f6f

+ 3 - 3
applications/transfers/transfers-server/src/main/java/com/usoftchina/saas/transfers/task/SendProductTask.java

@@ -1,8 +1,8 @@
 package com.usoftchina.saas.transfers.task;
 package com.usoftchina.saas.transfers.task;
 
 
+import com.alibaba.fastjson.JSON;
 import com.usoftchina.saas.inquiry.api.PublicProductApi;
 import com.usoftchina.saas.inquiry.api.PublicProductApi;
 import com.usoftchina.saas.account.api.CompanyApi;
 import com.usoftchina.saas.account.api.CompanyApi;
-import com.usoftchina.saas.context.BaseContextHolder;
 import com.usoftchina.saas.document.api.ProductApi;
 import com.usoftchina.saas.document.api.ProductApi;
 import com.usoftchina.saas.document.dto.ProductUploadDTO;
 import com.usoftchina.saas.document.dto.ProductUploadDTO;
 import com.usoftchina.saas.transfers.dto.MessageInfo;
 import com.usoftchina.saas.transfers.dto.MessageInfo;
@@ -65,7 +65,7 @@ public class SendProductTask extends Executable{
                             }
                             }
                             List<ProductUploadDTO> subList = productUploadDTOList.subList(startPoint, endPoint);
                             List<ProductUploadDTO> subList = productUploadDTOList.subList(startPoint, endPoint);
                             try {
                             try {
-                                publicProductApi.saveProducts(JsonUtils.toJsonString(subList), enUU);
+                                publicProductApi.saveProducts(JSON.toJSONString(subList), enUU);
                                 subList.forEach(ProductUploadDTO -> successIds.add(ProductUploadDTO.getPr_id()));
                                 subList.forEach(ProductUploadDTO -> successIds.add(ProductUploadDTO.getPr_id()));
                                 LOGGER.info("本批次第{}至{},物料上传成功, 发起时间 {}",startPoint, endPoint, DateUtils.format(new Date(System.currentTimeMillis()), "yyyy-MM-dd hh:mm:ss"));
                                 LOGGER.info("本批次第{}至{},物料上传成功, 发起时间 {}",startPoint, endPoint, DateUtils.format(new Date(System.currentTimeMillis()), "yyyy-MM-dd hh:mm:ss"));
                             }catch (Exception e){
                             }catch (Exception e){
@@ -110,7 +110,7 @@ public class SendProductTask extends Executable{
                 }
                 }
                 String failedStr = failed.substring(0, failed.length() - 1);
                 String failedStr = failed.substring(0, failed.length() - 1);
                 MessageInfo newMessageInfo = new MessageInfo(messageInfo.getUserId(), messageInfo.getBizType(), failedStr, messageInfo.getCompanyId());
                 MessageInfo newMessageInfo = new MessageInfo(messageInfo.getUserId(), messageInfo.getBizType(), failedStr, messageInfo.getCompanyId());
-                sendService.sendMessage(newMessageInfo);
+                sendService.sendDelayMessage(newMessageInfo, "上传失败");
             }
             }
         }
         }
     }
     }