From 901b2ab3e0e7c592602848cfa256f34c5b0c7bb8 Mon Sep 17 00:00:00 2001
From: Junjie <540245094@qq.com>
Date: 星期四, 11 一月 2024 09:57:01 +0800
Subject: [PATCH] #
---
zy-asrs-openapi/src/main/java/com/zy/asrs/openapi/task/ReportApiScheduler.java | 28 ++++++++++++++++++++++++++++
1 files changed, 28 insertions(+), 0 deletions(-)
diff --git a/zy-asrs-openapi/src/main/java/com/zy/asrs/openapi/task/ReportApiScheduler.java b/zy-asrs-openapi/src/main/java/com/zy/asrs/openapi/task/ReportApiScheduler.java
index 147f4bf..7df4a01 100644
--- a/zy-asrs-openapi/src/main/java/com/zy/asrs/openapi/task/ReportApiScheduler.java
+++ b/zy-asrs-openapi/src/main/java/com/zy/asrs/openapi/task/ReportApiScheduler.java
@@ -2,7 +2,10 @@
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
+import com.alibaba.fastjson.serializer.SerializerFeature;
+import com.alibaba.fastjson.support.config.FastJsonConfig;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.zy.asrs.common.domain.dto.ReportStockDto;
import com.zy.asrs.common.domain.enums.ApiType;
import com.zy.asrs.common.domain.enums.OrderSettleType;
import com.zy.asrs.common.openapi.entity.ApiList;
@@ -12,6 +15,7 @@
import com.zy.asrs.common.utils.HttpHandler;
import com.zy.asrs.common.wms.entity.Order;
import com.zy.asrs.common.wms.entity.OrderDetl;
+import com.zy.asrs.common.wms.service.LocDetlService;
import com.zy.asrs.common.wms.service.OrderDetlService;
import com.zy.asrs.common.wms.service.OrderService;
import org.apache.commons.codec.digest.DigestUtils;
@@ -35,6 +39,8 @@
private OrderDetlService orderDetlService;
@Autowired
private HostKeyService hostKeyService;
+ @Autowired
+ private LocDetlService locDetlService;
@Scheduled(cron = "0/3 * * * * ? ")
public void orderComplete() {
@@ -138,7 +144,29 @@
.eq(ApiList::getType, ApiType.REPORT_STOCK.type)
.eq(ApiList::getStatus, 1));
for (ApiList apiList : list) {
+ List<ReportStockDto> reportStockDto = locDetlService.getReportStockDto(apiList.getHostId());
+ //灏佽鏁版嵁
+ HashMap<String, Object> data = new HashMap<>();
+ data.put("stock", reportStockDto);
+ getSign(data, apiList.getHostId());//鑾峰彇绛惧悕
+ //淇濈暀null鍊�
+ FastJsonConfig fastJsonConfig = new FastJsonConfig();
+ fastJsonConfig.setSerializerFeatures(SerializerFeature.WriteMapNullValue, SerializerFeature.WriteNullListAsEmpty, SerializerFeature.WriteNullStringAsEmpty);
+ String paramData = JSON.toJSONString(data, fastJsonConfig.getSerializeConfig(), fastJsonConfig.getSerializerFeatures());
+ try {
+ String response = new HttpHandler.Builder()
+ .setUri(apiList.getUrl())
+ .setJson(JSON.toJSONString(paramData))
+ .build()
+ .doPost();
+ JSONObject result = JSON.parseObject(response);
+ if (result.getOrDefault("code", 0).equals(200)) {
+
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
}
}
--
Gitblit v1.9.1