From 971023df5fd3795e24d10d4d4d03ee112df12297 Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期四, 24 三月 2022 12:17:41 +0800
Subject: [PATCH] 优化查询为空问题

---
 service-store/src/main/java/com/java110/store/api/PurchaseApi.java |  353 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 345 insertions(+), 8 deletions(-)

diff --git a/service-store/src/main/java/com/java110/store/api/PurchaseApi.java b/service-store/src/main/java/com/java110/store/api/PurchaseApi.java
old mode 100644
new mode 100755
index f62077b..252f7a1
--- a/service-store/src/main/java/com/java110/store/api/PurchaseApi.java
+++ b/service-store/src/main/java/com/java110/store/api/PurchaseApi.java
@@ -1,22 +1,30 @@
 package com.java110.store.api;
 
-
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.java110.core.factory.GenerateCodeFactory;
+import com.java110.dto.allocationStorehouse.AllocationStorehouseDto;
+import com.java110.dto.allocationStorehouseApply.AllocationStorehouseApplyDto;
 import com.java110.dto.purchaseApply.PurchaseApplyDto;
+import com.java110.dto.resourceStore.ResourceStoreDto;
+import com.java110.dto.storehouse.StorehouseDto;
+import com.java110.intf.store.*;
 import com.java110.po.purchase.PurchaseApplyDetailPo;
 import com.java110.po.purchase.PurchaseApplyPo;
 import com.java110.po.purchase.ResourceStorePo;
 import com.java110.store.bmo.purchase.IPurchaseApplyBMO;
+import com.java110.store.bmo.purchase.IResourceEnterBMO;
+import com.java110.utils.cache.MappingCache;
 import com.java110.utils.util.Assert;
 import com.java110.utils.util.BeanConvertUtil;
+import com.java110.utils.util.DateUtil;
+import com.java110.utils.util.StringUtil;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.*;
 
-import java.util.ArrayList;
-import java.util.List;
+import java.math.BigDecimal;
+import java.util.*;
 
 @RestController
 @RequestMapping(value = "/purchase")
@@ -24,6 +32,30 @@
 
     @Autowired
     private IPurchaseApplyBMO purchaseApplyBMOImpl;
+
+    @Autowired
+    private IResourceEnterBMO resourceEnterBMOImpl;
+
+    @Autowired
+    private IResourceStoreInnerServiceSMO resourceStoreInnerServiceSMOImpl;
+
+    @Autowired
+    private IStorehouseInnerServiceSMO storehouseInnerServiceSMOImpl;
+
+    @Autowired
+    private IAllocationStorehouseInnerServiceSMO allocationStorehouseInnerServiceSMOImpl;
+
+    @Autowired
+    private IAllocationStorehouseApplyInnerServiceSMO allocationStorehouseApplyInnerServiceSMOImpl;
+
+    @Autowired
+    private IPurchaseApplyInnerServiceSMO purchaseApplyInnerServiceSMOImpl;
+
+    //鍩�
+    public static final String DOMAIN_COMMON = "DOMAIN.COMMON";
+
+    //閿�
+    public static final String URGRNT_NUMBER = "URGRNT_NUMBER";
 
     /**
      * 閲囪喘鐢宠
@@ -40,11 +72,9 @@
                                                 @RequestHeader(value = "user-id") String userId,
                                                 @RequestHeader(value = "user-name") String userName,
                                                 @RequestHeader(value = "store-id") String storeId) {
-
         Assert.hasKeyAndValue(reqJson, "resourceStores", "蹇呭~锛岃濉啓鐢宠閲囪喘鐨勭墿璧�");
         Assert.hasKeyAndValue(reqJson, "description", "蹇呭~锛岃濉啓閲囪喘鐢宠璇存槑");
         Assert.hasKeyAndValue(reqJson, "resOrderType", "蹇呭~锛岃濉啓鐢宠绫诲瀷");
-
         PurchaseApplyPo purchaseApplyPo = new PurchaseApplyPo();
         purchaseApplyPo.setApplyOrderId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_applyOrderId));
         purchaseApplyPo.setDescription(reqJson.getString("description"));
@@ -55,18 +85,325 @@
         purchaseApplyPo.setStoreId(storeId);
         purchaseApplyPo.setResOrderType(PurchaseApplyDto.RES_ORDER_TYPE_ENTER);
         purchaseApplyPo.setState(PurchaseApplyDto.STATE_WAIT_DEAL);
-
+        purchaseApplyPo.setCreateTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A));
+        purchaseApplyPo.setCreateUserId(userId);
+        purchaseApplyPo.setCreateUserName(userName);
+        purchaseApplyPo.setWarehousingWay(PurchaseApplyDto.WAREHOUSING_TYPE_APPLY);
+        purchaseApplyPo.setCommunityId(reqJson.getString("communityId"));
         JSONArray resourceStores = reqJson.getJSONArray("resourceStores");
-
         List<PurchaseApplyDetailPo> purchaseApplyDetailPos = new ArrayList<>();
-
         for (int resourceStoreIndex = 0; resourceStoreIndex < resourceStores.size(); resourceStoreIndex++) {
             JSONObject resourceStore = resourceStores.getJSONObject(resourceStoreIndex);
+            resourceStore.remove("price");//閲囪喘浠锋牸榛樿绌�
+            resourceStore.put("originalStock", resourceStore.getString("stock"));
             PurchaseApplyDetailPo purchaseApplyDetailPo = BeanConvertUtil.covertBean(resourceStore, PurchaseApplyDetailPo.class);
+            purchaseApplyDetailPo.setId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_applyOrderId));
             purchaseApplyDetailPos.add(purchaseApplyDetailPo);
         }
         purchaseApplyPo.setPurchaseApplyDetailPos(purchaseApplyDetailPos);
+        return purchaseApplyBMOImpl.apply(purchaseApplyPo);
+    }
 
+    @RequestMapping(value = "/resourceEnter", method = RequestMethod.POST)
+    public ResponseEntity<String> resourceEnter(@RequestBody JSONObject reqJson) {
+        Assert.hasKeyAndValue(reqJson, "applyOrderId", "璁㈠崟ID涓虹┖");
+        PurchaseApplyDto purchaseApplyDto = new PurchaseApplyDto();
+        purchaseApplyDto.setApplyOrderId(reqJson.getString("applyOrderId"));
+        purchaseApplyDto.setStatusCd("0");
+        List<PurchaseApplyDto> purchaseApplyDtoList = purchaseApplyInnerServiceSMOImpl.queryPurchaseApplys(purchaseApplyDto);
+        if(purchaseApplyDtoList!=null && PurchaseApplyDto.STATE_AUDITED.equals(purchaseApplyDtoList.get(0).getState())){
+            throw new IllegalArgumentException("璇ヨ鍗曞凡缁忓鐞嗭紝璇峰埛鏂扮‘璁よ鍗曠姸鎬侊紒");
+        }
+        JSONArray purchaseApplyDetails = reqJson.getJSONArray("purchaseApplyDetailVo");
+        List<PurchaseApplyDetailPo> purchaseApplyDetailPos = new ArrayList<>();
+        for (int detailIndex = 0; detailIndex < purchaseApplyDetails.size(); detailIndex++) {
+            JSONObject purchaseApplyDetail = purchaseApplyDetails.getJSONObject(detailIndex);
+            Assert.hasKeyAndValue(purchaseApplyDetail, "purchaseQuantity", "閲囪喘鏁伴噺鏈~鍐�");
+            Assert.hasKeyAndValue(purchaseApplyDetail, "price", "閲囪喘鍗曚环鏈~鍐�");
+            Assert.hasKeyAndValue(purchaseApplyDetail, "id", "鏄庣粏ID涓虹┖");
+            PurchaseApplyDetailPo purchaseApplyDetailPo = BeanConvertUtil.covertBean(purchaseApplyDetail, PurchaseApplyDetailPo.class);
+            purchaseApplyDetailPos.add(purchaseApplyDetailPo);
+        }
+        PurchaseApplyPo purchaseApplyPo = new PurchaseApplyPo();
+        purchaseApplyPo.setApplyOrderId(reqJson.getString("applyOrderId"));
+        purchaseApplyPo.setPurchaseApplyDetailPos(purchaseApplyDetailPos);
+        return resourceEnterBMOImpl.enter(purchaseApplyPo);
+    }
+
+    /**
+     * 鐩存帴鍏ュ簱鎿嶄綔
+     * <p>
+     * {"resourceStores":[{"resId":"852020061636590016","resName":"姗$毊鎿�","resCode":"003","price":"100.00","stock":"0","description":"ada","quantity":"1"},
+     * {"resId":"852020061729120031","resName":"鏂囨。鏌�","resCode":"002","price":"33.00","stock":"0","description":"钃濊壊","quantity":"1"}],
+     * "description":"123123","endUserName":"1","endUserTel":"17797173942","file":"","resOrderType":"10000","staffId":"","staffName":""}
+     *
+     * @param reqJson
+     * @return
+     */
+    @RequestMapping(value = "/purchaseStorage", method = RequestMethod.POST)
+    public ResponseEntity<String> purchaseStorage(@RequestBody JSONObject reqJson,
+                                                  @RequestHeader(value = "user-id") String userId,
+                                                  @RequestHeader(value = "user-name") String userName,
+                                                  @RequestHeader(value = "store-id") String storeId) {
+        Assert.hasKeyAndValue(reqJson, "resourceStores", "蹇呭~锛岃濉啓鐢宠閲囪喘鐨勭墿璧�");
+        Assert.hasKeyAndValue(reqJson, "description", "蹇呭~锛岃濉啓閲囪喘鐢宠璇存槑");
+        Assert.hasKeyAndValue(reqJson, "resOrderType", "蹇呭~锛岃濉啓鐢宠绫诲瀷");
+        PurchaseApplyPo purchaseApplyPo = new PurchaseApplyPo();
+        purchaseApplyPo.setApplyOrderId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_applyOrderId));
+        purchaseApplyPo.setDescription(reqJson.getString("description"));
+        purchaseApplyPo.setUserId(userId);
+        purchaseApplyPo.setUserName(userName);
+        purchaseApplyPo.setEndUserName(reqJson.getString("endUserName"));
+        purchaseApplyPo.setEndUserTel(reqJson.getString("endUserTel"));
+        purchaseApplyPo.setStoreId(storeId);
+        purchaseApplyPo.setResOrderType(PurchaseApplyDto.RES_ORDER_TYPE_ENTER);
+        purchaseApplyPo.setState(PurchaseApplyDto.STATE_END);
+        purchaseApplyPo.setCreateTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A));
+        purchaseApplyPo.setDescription("鐩存帴閲囪喘鍏ュ簱");
+        purchaseApplyPo.setCreateUserId(userId);
+        purchaseApplyPo.setCreateUserName(userName);
+        purchaseApplyPo.setWarehousingWay(PurchaseApplyDto.WAREHOUSING_TYPE_DIRECT);
+        purchaseApplyPo.setCommunityId(reqJson.getString("communityId"));
+        JSONArray resourceStores = reqJson.getJSONArray("resourceStores");
+        List<PurchaseApplyDetailPo> purchaseApplyDetailPos = new ArrayList<>();
+        for (int resourceStoreIndex = 0; resourceStoreIndex < resourceStores.size(); resourceStoreIndex++) {
+            JSONObject resourceStore = resourceStores.getJSONObject(resourceStoreIndex);
+            PurchaseApplyDetailPo purchaseApplyDetailPo = BeanConvertUtil.covertBean(resourceStore, PurchaseApplyDetailPo.class);
+            purchaseApplyDetailPo.setId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_applyOrderId));
+            purchaseApplyDetailPo.setRemark("鐩存帴閲囪喘鍏ュ簱");
+            purchaseApplyDetailPo.setOriginalStock(resourceStore.getString("stock"));
+            purchaseApplyDetailPo.setQuantity(purchaseApplyDetailPo.getPurchaseQuantity());
+            purchaseApplyDetailPos.add(purchaseApplyDetailPo);
+            //澧炲姞搴撳瓨
+            ResourceStorePo resourceStorePo = new ResourceStorePo();
+            resourceStorePo.setPurchasePrice(purchaseApplyDetailPo.getPrice());
+            resourceStorePo.setResId(purchaseApplyDetailPo.getResId());
+            resourceStorePo.setStock(purchaseApplyDetailPo.getPurchaseQuantity());
+            resourceStorePo.setResOrderType(PurchaseApplyDto.RES_ORDER_TYPE_ENTER);
+            //鑾峰彇閲囪喘鏁伴噺
+            BigDecimal purchaseQuantity = new BigDecimal(purchaseApplyDetailPo.getPurchaseQuantity());
+            //鑾峰彇鍘熸湁鏈�灏忚閲忔�绘暟
+            BigDecimal miniStock = new BigDecimal(resourceStore.getString("miniStock"));
+            //鑾峰彇鏈�灏忓崟浣嶆暟閲�
+            BigDecimal newMiniStock = new BigDecimal(0);
+            if (StringUtil.isEmpty(resourceStore.getString("miniUnitStock"))) {
+                throw new IllegalArgumentException("鏈�灏忚閲忓崟浣嶆暟閲忎笉鑳戒负绌猴紒");
+            }
+            BigDecimal miniUnitStock = new BigDecimal(resourceStore.getString("miniUnitStock"));
+            //璁$畻鏈�灏忚閲忔�绘暟
+            if (StringUtil.isEmpty(resourceStore.getString("miniStock"))) {
+                newMiniStock = purchaseQuantity.multiply(miniUnitStock);
+            } else {
+                newMiniStock = (purchaseQuantity.multiply(miniUnitStock)).add(miniStock);
+            }
+            resourceStorePo.setMiniStock(String.valueOf(newMiniStock));
+            resourceStoreInnerServiceSMOImpl.updateResourceStore(resourceStorePo);
+        }
+        purchaseApplyPo.setPurchaseApplyDetailPos(purchaseApplyDetailPos);
+        return purchaseApplyBMOImpl.apply(purchaseApplyPo);
+    }
+
+    /**
+     * 绱ф�ラ噰璐叆搴�
+     *
+     * @author fqz
+     * @date 2021-07-07 15:46
+     */
+    @RequestMapping(value = "/urgentPurchaseApply", method = RequestMethod.POST)
+    public ResponseEntity<String> urgentPurchaseApply(@RequestBody JSONObject reqJson,
+                                                      @RequestHeader(value = "user-id") String userId,
+                                                      @RequestHeader(value = "user-name") String userName,
+                                                      @RequestHeader(value = "store-id") String storeId) {
+        Assert.hasKeyAndValue(reqJson, "resourceStores", "蹇呭~锛岃濉啓鐢宠閲囪喘鐨勭墿璧�");
+        Assert.hasKeyAndValue(reqJson, "description", "蹇呭~锛岃濉啓閲囪喘鐢宠璇存槑");
+        Assert.hasKeyAndValue(reqJson, "resOrderType", "蹇呭~锛岃濉啓鐢宠绫诲瀷");
+        PurchaseApplyDto purchaseApplyDto = new PurchaseApplyDto();
+        purchaseApplyDto.setResOrderType(reqJson.getString("resOrderType"));
+        //绱ф�ラ噰璐叆搴�
+        purchaseApplyDto.setWarehousingWay(PurchaseApplyDto.WAREHOUSING_TYPE_URGENT);
+        purchaseApplyDto.setCommunityId(reqJson.getString("communityId"));
+        purchaseApplyDto.setUserId(userId);
+        //鏌ヨ褰撴湀鏁版嵁鏍囪瘑锛屽綋鍊间负1鏃舵煡璇㈠綋鏈堟暟鎹�
+        purchaseApplyDto.setUrgentFlag("1");
+        //鏌ヨ褰撴湀绱ф�ラ噰璐殑娆℃暟
+        int count = purchaseApplyInnerServiceSMOImpl.queryPurchaseApplysCount(purchaseApplyDto);
+        //鍙栧嚭寮�鍏虫槧灏勭殑鍊�
+        String value = MappingCache.getValue(DOMAIN_COMMON, URGRNT_NUMBER);
+        if (StringUtil.isEmpty(value)) {
+            throw new IllegalArgumentException("鏄犲皠鍊间负绌猴紒");
+        }
+        int number = Integer.parseInt(value);
+        if (count >= number) {
+            throw new IllegalArgumentException("鏈湀绱ф�ラ噰璐鏁板凡瓒呰繃" + number + "娆★紝璇蜂笅鏈堝啀浣跨敤锛�");
+        }
+        PurchaseApplyPo purchaseApplyPo = new PurchaseApplyPo();
+        purchaseApplyPo.setApplyOrderId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_applyOrderId));
+        purchaseApplyPo.setDescription(reqJson.getString("description"));
+        purchaseApplyPo.setUserId(userId);
+        purchaseApplyPo.setUserName(userName);
+        purchaseApplyPo.setEndUserName(reqJson.getString("endUserName"));
+        purchaseApplyPo.setEndUserTel(reqJson.getString("endUserTel"));
+        purchaseApplyPo.setStoreId(storeId);
+        purchaseApplyPo.setResOrderType(PurchaseApplyDto.RES_ORDER_TYPE_ENTER);
+        purchaseApplyPo.setState(PurchaseApplyDto.STATE_END);
+        purchaseApplyPo.setCreateTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A));
+        purchaseApplyPo.setDescription(reqJson.getString("description"));
+        purchaseApplyPo.setCreateUserId(userId);
+        purchaseApplyPo.setCreateUserName(userName);
+        purchaseApplyPo.setWarehousingWay(PurchaseApplyDto.WAREHOUSING_TYPE_URGENT);
+        purchaseApplyPo.setCommunityId(reqJson.getString("communityId"));
+        //鑾峰彇閲囪喘鐗╁搧淇℃伅
+        JSONArray resourceStores = reqJson.getJSONArray("resourceStores");
+        List<PurchaseApplyDetailPo> purchaseApplyDetailPos = new ArrayList<>();
+        for (int resourceStoreIndex = 0; resourceStoreIndex < resourceStores.size(); resourceStoreIndex++) {
+            JSONObject resourceStore = resourceStores.getJSONObject(resourceStoreIndex);
+            PurchaseApplyDetailPo purchaseApplyDetailPo = BeanConvertUtil.covertBean(resourceStore, PurchaseApplyDetailPo.class);
+            purchaseApplyDetailPo.setId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_applyOrderId));
+            purchaseApplyDetailPo.setPurchaseQuantity(resourceStore.get("quantity").toString());
+            purchaseApplyDetailPo.setPurchaseRemark(resourceStore.get("remark").toString());
+            purchaseApplyDetailPo.setOriginalStock(resourceStore.getString("stock"));
+            purchaseApplyDetailPo.setPrice(resourceStore.getString("urgentPrice"));
+            purchaseApplyDetailPos.add(purchaseApplyDetailPo);
+            //鏌ヨ褰撳墠灏忓尯浠撳簱涓嬭鐗╁搧淇℃伅
+            ResourceStoreDto resourceStoreDto = new ResourceStoreDto();
+            resourceStoreDto.setResCode(resourceStore.getString("resCode"));
+            resourceStoreDto.setShId(resourceStore.getString("shzId"));//灏忓尯鐩爣浠撳簱
+            List<ResourceStoreDto> resourceStoreDtos = resourceStoreInnerServiceSMOImpl.queryResourceStores(resourceStoreDto);
+            //璋冩暣闆嗗洟浠撳簱鐗╁搧淇℃伅
+            ResourceStorePo resourceStorePo = new ResourceStorePo();
+            resourceStorePo.setResId(purchaseApplyDetailPo.getResId());
+            resourceStorePo.setPurchasePrice(resourceStore.getString("urgentPrice"));
+            resourceStorePo.setStock(purchaseApplyDetailPo.getQuantity());
+            resourceStorePo.setResOrderType(PurchaseApplyDto.WAREHOUSING_TYPE_URGENT);
+            resourceStorePo.setOperationType(PurchaseApplyDto.WEIGHTED_MEAN_TRUE);
+            resourceStoreInnerServiceSMOImpl.updateResourceStore(resourceStorePo);
+            if (resourceStoreDtos != null && resourceStoreDtos.size() == 1) {
+                //鐢熸垚璋冩嫧璁板綍
+                AllocationStorehouseDto allocationStorehouseDto = new AllocationStorehouseDto();
+                allocationStorehouseDto.setAsId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_allocationStorehouseId));
+                allocationStorehouseDto.setbId("-1");
+                allocationStorehouseDto.setShIda(resourceStore.getString("shId"));
+                allocationStorehouseDto.setShIdz(resourceStore.getString("shzId"));//灏忓尯浠撳簱
+                allocationStorehouseDto.setResId(resourceStoreDtos.get(0).getResId());
+                allocationStorehouseDto.setResName(resourceStoreDtos.get(0).getResName());
+                allocationStorehouseDto.setStoreId(storeId);
+                allocationStorehouseDto.setStock(purchaseApplyDetailPo.getQuantity());
+                allocationStorehouseDto.setStartUserId(userId);
+                allocationStorehouseDto.setStartUserName(userName);
+                allocationStorehouseDto.setCreateTime(new Date());
+                allocationStorehouseDto.setRemark("绱ф�ラ噰璐叆搴撳苟璋冩嫧");
+                allocationStorehouseDto.setApplyId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_applyId));
+                allocationStorehouseDto.setOriginalStock(resourceStoreDtos.get(0).getStock());
+                allocationStorehouseInnerServiceSMOImpl.saveAllocationStorehouses(allocationStorehouseDto);
+                //鐢熸垚璋冩嫧鐢宠璁板綍
+                AllocationStorehouseApplyDto allocationStorehouseApplyDto = new AllocationStorehouseApplyDto();
+                allocationStorehouseApplyDto.setApplyId(allocationStorehouseDto.getApplyId());
+                allocationStorehouseApplyDto.setbId("-1");
+                allocationStorehouseApplyDto.setStartUserId(allocationStorehouseDto.getStartUserId());
+                allocationStorehouseApplyDto.setStartUserName(allocationStorehouseDto.getStartUserName());
+                allocationStorehouseApplyDto.setRemark("绱ф�ラ噰璐叆搴撳苟璋冩嫧");
+                allocationStorehouseApplyDto.setApplyCount(purchaseApplyDetailPo.getQuantity());
+                allocationStorehouseApplyDto.setStoreId(storeId);
+                allocationStorehouseApplyDto.setCreateTime(new Date());
+                allocationStorehouseApplyDto.setState(AllocationStorehouseDto.STATE_SUCCESS);
+                allocationStorehouseApplyDto.setCommunityId(reqJson.getString("communityId"));
+                //璋冩嫧
+                allocationStorehouseApplyDto.setApplyType("30000");
+                allocationStorehouseApplyInnerServiceSMOImpl.saveAllocationStorehouseApplys(allocationStorehouseApplyDto);
+
+                //璋冩暣灏忓尯浠撳簱鐗╁搧鍧囦环銆佹暟閲�
+
+                //闆嗗洟浠撳簱鍟嗗搧淇℃伅
+                ResourceStoreDto resourceStoreDto2 = new ResourceStoreDto();
+                resourceStoreDto2.setResCode(resourceStore.getString("resCode"));
+                resourceStoreDto2.setResId(purchaseApplyDetailPo.getResId());
+                List<ResourceStoreDto> resourceStoreDtoList = resourceStoreInnerServiceSMOImpl.queryResourceStores(resourceStoreDto2);
+
+                ResourceStorePo resourceStorePo1 = new ResourceStorePo();
+                resourceStorePo1.setPurchasePrice(resourceStore.getString("urgentPrice"));
+                resourceStorePo1.setResId(resourceStoreDtos.get(0).getResId());
+                resourceStorePo1.setStock(purchaseApplyDetailPo.getQuantity());
+                resourceStorePo1.setAveragePrice(resourceStoreDtoList.get(0).getAveragePrice());
+                resourceStorePo1.setPrice(resourceStoreDtoList.get(0).getPrice());
+                resourceStorePo1.setResOrderType(PurchaseApplyDto.WAREHOUSING_TYPE_URGENT);
+                resourceStorePo1.setOperationType(PurchaseApplyDto.WEIGHTED_MEAN_FALSE);
+                //鑾峰彇绱ф�ラ噰璐暟閲�
+                BigDecimal purchaseQuantity = new BigDecimal(purchaseApplyDetailPo.getQuantity());
+                //鑾峰彇鍘熸湁鏈�灏忚閲忔�绘暟
+                if (StringUtil.isEmpty(resourceStoreDtos.get(0).getMiniStock())) {
+                    throw new IllegalArgumentException("鏈�灏忚閲忔�绘暟涓嶈兘涓虹┖锛�");
+                }
+                BigDecimal miniStock = new BigDecimal(resourceStoreDtos.get(0).getMiniStock());
+                //鑾峰彇鏈�灏忚閲忓崟浣嶆暟閲�
+                if (StringUtil.isEmpty(resourceStoreDtos.get(0).getMiniUnitStock())) {
+                    throw new IllegalArgumentException("鏈�灏忚閲忓崟浣嶆暟閲忎笉鑳戒负绌猴紒");
+                }
+                BigDecimal miniUnitStock = new BigDecimal(resourceStoreDtos.get(0).getMiniUnitStock());
+                //璁$畻鏈�灏忚閲忔�绘暟
+                BigDecimal newMiniStock = purchaseQuantity.multiply(miniUnitStock).add(miniStock);
+                resourceStorePo1.setMiniStock(String.valueOf(newMiniStock));
+                resourceStoreInnerServiceSMOImpl.updateResourceStore(resourceStorePo1);
+            } else if (resourceStoreDtos != null && resourceStoreDtos.size() > 1) {
+                throw new IllegalArgumentException("鏌ヨ鍟嗗搧閿欒锛�");
+            } else {
+                //鐢熸垚璋冩嫧璁板綍
+                AllocationStorehouseDto allocationStorehouseDto = new AllocationStorehouseDto();
+                allocationStorehouseDto.setAsId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_allocationStorehouseId));
+                allocationStorehouseDto.setbId("-1");
+                allocationStorehouseDto.setShIda(resourceStore.getString("shId"));
+                allocationStorehouseDto.setShIdz(resourceStore.getString("shzId"));//灏忓尯鐩爣浠撳簱
+                allocationStorehouseDto.setResId(resourceStore.getString("resId"));
+                allocationStorehouseDto.setResName(resourceStore.getString("resName"));
+                allocationStorehouseDto.setStoreId(storeId);
+                allocationStorehouseDto.setStock(purchaseApplyDetailPo.getQuantity());
+                allocationStorehouseDto.setStartUserId(userId);
+                allocationStorehouseDto.setStartUserName(userName);
+                allocationStorehouseDto.setCreateTime(new Date());
+                allocationStorehouseDto.setRemark("绱ф�ラ噰璐叆搴撳苟璋冩嫧");
+                allocationStorehouseDto.setApplyId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_applyId));
+                allocationStorehouseDto.setOriginalStock("0");
+                allocationStorehouseInnerServiceSMOImpl.saveAllocationStorehouses(allocationStorehouseDto);
+                //鐢熸垚璋冩嫧鐢宠璁板綍
+                AllocationStorehouseApplyDto allocationStorehouseApplyDto = new AllocationStorehouseApplyDto();
+                allocationStorehouseApplyDto.setApplyId(allocationStorehouseDto.getApplyId());
+                allocationStorehouseApplyDto.setbId("-1");
+                allocationStorehouseApplyDto.setStartUserId(allocationStorehouseDto.getStartUserId());
+                allocationStorehouseApplyDto.setStartUserName(allocationStorehouseDto.getStartUserName());
+                allocationStorehouseApplyDto.setRemark("绱ф�ラ噰璐叆搴撳苟璋冩嫧");
+                allocationStorehouseApplyDto.setApplyCount(purchaseApplyDetailPo.getQuantity());
+                allocationStorehouseApplyDto.setStoreId(storeId);
+                allocationStorehouseApplyDto.setCreateTime(new Date());
+                allocationStorehouseApplyDto.setState(AllocationStorehouseDto.STATE_SUCCESS);
+                allocationStorehouseApplyDto.setCommunityId(reqJson.getString("communityId"));
+                //璋冩嫧
+                allocationStorehouseApplyDto.setApplyType("30000");
+                allocationStorehouseApplyInnerServiceSMOImpl.saveAllocationStorehouseApplys(allocationStorehouseApplyDto);
+                //灏忓尯浠撳簱杩涜鍏ュ簱鎻掑叆
+                //闆嗗洟浠撳簱鍟嗗搧淇℃伅
+                ResourceStoreDto resourceStoreDto2 = new ResourceStoreDto();
+                resourceStoreDto2.setResCode(resourceStore.getString("resCode"));
+                resourceStoreDto2.setResId(purchaseApplyDetailPo.getResId());
+                List<ResourceStoreDto> resourceStoreDtoList = resourceStoreInnerServiceSMOImpl.queryResourceStores(resourceStoreDto2);
+                ResourceStoreDto resourceStoreDto1 = BeanConvertUtil.covertBean(resourceStoreDtoList.get(0), ResourceStoreDto.class);
+                resourceStoreDto1.setResId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_resId));
+                resourceStoreDto1.setShId(resourceStore.getString("shzId"));
+                resourceStoreDto1.setbId("-1");
+                resourceStoreDto1.setStock(purchaseApplyDetailPo.getQuantity());
+                resourceStoreDto1.setCreateTime(new Date());
+                //鑾峰彇绱ф�ラ噰璐暟閲�
+                BigDecimal purchaseQuantity = new BigDecimal(purchaseApplyDetailPo.getQuantity());
+                //鑾峰彇鏈�灏忚閲忓崟浣嶆暟閲�
+                if (StringUtil.isEmpty(resourceStore.getString("miniUnitStock"))) {
+                    throw new IllegalArgumentException("鏈�灏忚閲忓崟浣嶆暟閲忎笉鑳戒负绌猴紒");
+                }
+                BigDecimal miniUnitStock = new BigDecimal(resourceStore.getString("miniUnitStock"));
+                //璁$畻鏈�灏忚閲忔�绘暟
+                BigDecimal miniStock = purchaseQuantity.multiply(miniUnitStock);
+                resourceStoreDto1.setMiniStock(String.valueOf(miniStock));
+                resourceStoreInnerServiceSMOImpl.saveResourceStore(resourceStoreDto1);
+            }
+        }
+        purchaseApplyPo.setPurchaseApplyDetailPos(purchaseApplyDetailPos);
         return purchaseApplyBMOImpl.apply(purchaseApplyPo);
     }
 }

--
Gitblit v1.8.0