|
@@ -29,6 +29,7 @@ import java.security.spec.InvalidKeySpecException;
|
|
|
import java.security.spec.PKCS8EncodedKeySpec;
|
|
|
import java.text.ParseException;
|
|
|
import java.util.*;
|
|
|
+import java.util.stream.Collectors;
|
|
|
|
|
|
/**
|
|
|
* 大宗仓库接⼝
|
|
@@ -76,44 +77,70 @@ public class BulkWareHouseController extends BaseController {
|
|
|
/**
|
|
|
* 获取仓库详细信息
|
|
|
*/
|
|
|
- @PostMapping("/inventory/queriesV2")
|
|
|
- public void queries(HttpServletRequest request, HttpServletResponse response) throws InvalidKeySpecException, SignatureException, NoSuchAlgorithmException, InvalidKeyException {
|
|
|
+ @PostMapping("/inventory/query")
|
|
|
+ public void queries(HttpServletRequest request, HttpServletResponse response) throws InvalidKeySpecException, SignatureException, NoSuchAlgorithmException, InvalidKeyException, IOException {
|
|
|
|
|
|
- String bizContentStr = (String) request.getAttribute("bizContentStr");
|
|
|
|
|
|
- JSONObject jsonObject = JSONObject.parseObject(bizContentStr);
|
|
|
+// String bizContentStr = (String) request.getAttribute("bizContentStr");
|
|
|
+ String test = request.getReader().lines().collect(Collectors.joining(System.lineSeparator()));
|
|
|
+
|
|
|
+ JSONObject jsonObject = JSONObject.parseObject(test);
|
|
|
String ownerName = jsonObject.getString("currentOwnerName");//现存货人名称
|
|
|
String identifier = jsonObject.getString("currentOwnerSocialIdentifier");//现存货人识别号
|
|
|
|
|
|
- JSONArray jsonArray = jsonObject.getJSONArray("warehouseSerialNumbers");//仓库编号
|
|
|
+ JSONArray jsonArray = jsonObject.getJSONArray("warehouseCodes");//仓库编号
|
|
|
|
|
|
JSONArray jsonArrayBlNos = jsonObject.getJSONArray("blNos");//提单号
|
|
|
|
|
|
- List<String> numbersList = new ArrayList<>();
|
|
|
- for (int i = 0; i < jsonArray.size(); i++) {
|
|
|
- String numbers = jsonArray.getString(i);
|
|
|
- numbersList.add(numbers);
|
|
|
- System.out.println(numbers);
|
|
|
+ // 现存货人名称不允许为空
|
|
|
+ if (ownerName == null || "".equals(ownerName)) {
|
|
|
+ sendRequest(null, response);
|
|
|
+ return;
|
|
|
}
|
|
|
|
|
|
- List<String> blNosList = new ArrayList<>();
|
|
|
- for (int i = 0; i < jsonArrayBlNos.size(); i++) {
|
|
|
- String numbers = jsonArrayBlNos.getString(i);
|
|
|
- blNosList.add(numbers);
|
|
|
- System.out.println(numbers);
|
|
|
+ // 现存货人识别号不允许为空
|
|
|
+ if (identifier == null || "".equals(identifier)) {
|
|
|
+ sendRequest(null, response);
|
|
|
+ return;
|
|
|
+ }
|
|
|
+
|
|
|
+ // 仓库编号和提单号只允许一个为空
|
|
|
+ if (!(jsonArray != null && jsonArray.size() > 0) && !(jsonArrayBlNos != null && jsonArrayBlNos.size() > 0)) {
|
|
|
+ sendRequest(null, response);
|
|
|
+ return;
|
|
|
+ }
|
|
|
+
|
|
|
+ List<String> numbersList = null;
|
|
|
+ if (jsonArray != null && jsonArray.size() > 0) {
|
|
|
+ numbersList = new ArrayList<>();
|
|
|
+ for (int i = 0; i < jsonArray.size(); i++) {
|
|
|
+ String numbers = jsonArray.getString(i);
|
|
|
+ numbersList.add(numbers);
|
|
|
+ System.out.println(numbers);
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
- if (numbersList.size() > 0 && blNosList.size() > 0) {
|
|
|
- numbersList = null;
|
|
|
+ List<String> blNosList = null;
|
|
|
+ if (jsonArrayBlNos != null && jsonArrayBlNos.size() > 0) {
|
|
|
+ blNosList = new ArrayList<>();
|
|
|
+ for (int i = 0; i < jsonArrayBlNos.size(); i++) {
|
|
|
+ String numbers = jsonArrayBlNos.getString(i);
|
|
|
+ blNosList.add(numbers);
|
|
|
+ System.out.println(numbers);
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
+// if (numbersList.size() > 0 && blNosList.size() > 0) {
|
|
|
+// numbersList = null;
|
|
|
+// }
|
|
|
+
|
|
|
InventoryQueryRequest inventoryQueryRequest = new InventoryQueryRequest();
|
|
|
inventoryQueryRequest.setCurrentOwnerName(ownerName);
|
|
|
inventoryQueryRequest.setCurrentOwnerSocialIdentifier(identifier);
|
|
|
inventoryQueryRequest.setWarehouseSerialNumbers(numbersList);
|
|
|
inventoryQueryRequest.setBlNosList(blNosList);
|
|
|
|
|
|
- List<InventoryQueryResponse> list = foreignHttpService.inventoryQueriesV2(inventoryQueryRequest);
|
|
|
+ List<InventoryQueryTwoResponse> list = foreignHttpService.inventoryQueriesV2(inventoryQueryRequest);
|
|
|
|
|
|
sendRequest(list, response);
|
|
|
|