Commit a86f0983 by lijingjing

修改问题编号字段名称

parent 8139ba66
...@@ -7,6 +7,7 @@ import com.baomidou.mybatisplus.plugins.Page; ...@@ -7,6 +7,7 @@ import com.baomidou.mybatisplus.plugins.Page;
import com.fasterxml.jackson.core.type.TypeReference; import com.fasterxml.jackson.core.type.TypeReference;
import com.patzn.cloud.commons.service.impl.BaseServiceImpl; import com.patzn.cloud.commons.service.impl.BaseServiceImpl;
import com.patzn.cloud.commons.toolkit.CollectionUtils; import com.patzn.cloud.commons.toolkit.CollectionUtils;
import com.patzn.cloud.commons.toolkit.JacksonUtils;
import com.patzn.cloud.service.hmhj.dto.WmsStockDTO; import com.patzn.cloud.service.hmhj.dto.WmsStockDTO;
import com.patzn.cloud.service.hmhj.entity.WmsStock; import com.patzn.cloud.service.hmhj.entity.WmsStock;
import com.patzn.cloud.service.hmhj.model.WmsRespResult; import com.patzn.cloud.service.hmhj.model.WmsRespResult;
...@@ -71,17 +72,23 @@ public class WmsStockServiceImpl extends BaseServiceImpl<WmsStockMapper, WmsStoc ...@@ -71,17 +72,23 @@ public class WmsStockServiceImpl extends BaseServiceImpl<WmsStockMapper, WmsStoc
String url = serviceProperties.buildWmsUrl(HttpConst.WMS_SYNC_GET_UNIT_LOADS); String url = serviceProperties.buildWmsUrl(HttpConst.WMS_SYNC_GET_UNIT_LOADS);
// 设置请求参数 // 设置请求参数
HashMap<String, Object> map = new HashMap<>(2); HashMap<String, Object> map = new HashMap<>(2);
logger.info("==== WmsStockServiceImpl ==== syncWmsStockData ====> url: {}", url);
List<WmsStockData> dataList = WmsRequest.sendPost(url, map, new TypeReference<WmsRespResult<List<WmsStockData>>>() { List<WmsStockData> dataList = WmsRequest.sendPost(url, map, new TypeReference<WmsRespResult<List<WmsStockData>>>() {
}); });
logger.info("==== WmsStockServiceImpl ==== syncWmsStockData ====> dataList: {}", JacksonUtils.toJSONString(dataList));
if (CollectionUtils.isEmpty(dataList)) { if (CollectionUtils.isEmpty(dataList)) {
logger.error("==== WmsStockServiceImpl ==== syncWmsStockData ====> 出入库数据为空!"); logger.error("==== WmsStockServiceImpl ==== syncWmsStockData ====> 出入库数据为空!");
return; return;
} }
// 同步更新WMS库存数据 // 同步更新WMS库存数据
logger.debug("==== WmsStockServiceImpl ==== syncWmsStockData ====> 开始同步WMS数据!"); logger.info("==== WmsStockServiceImpl ==== syncWmsStockData ====> 开始同步WMS数据!");
try { try {
List<WmsStock> stockList = convertList(dataList); List<WmsStock> stockList = convertList(dataList);
Optional.ofNullable(stockList).ifPresent(this::saveOrUpdateBatch); logger.info("==== WmsStockServiceImpl ==== syncWmsStockData ====> stockList: {}", JacksonUtils.toJSONString(stockList));
if (CollectionUtils.isNotEmpty(stockList)) {
saveOrUpdateBatch(stockList);
}
} catch (Exception e) { } catch (Exception e) {
logger.error("==== WmsStockServiceImpl ==== syncUpdateWmsStockData ====> 转换数据失败:", e); logger.error("==== WmsStockServiceImpl ==== syncUpdateWmsStockData ====> 转换数据失败:", e);
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment