集成

src/main/java/com/steerinfo/dil/controller/WmsInboundResultController.java

@@ -16,9 +16,11 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.bind.annotation.*;
 
-
 import java.math.BigDecimal;
-import java.util.*;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
 //import java.util.*;
 /**
  * @author luobang
@@ -66,7 +68,8 @@ public class WmsInboundResultController extends BaseRESTfulController {
     ICommonService commonService;
     @Autowired
     WmsInboundScanResultServiceImpl wmsInboundScanResultService;
-
+    @Autowired
+    WmspSendReceiveServiceImpl wmspSendReceiveService;
     /**
      * 展示入库实绩
      * @param mapValue
@@ -210,9 +213,17 @@ public class WmsInboundResultController extends BaseRESTfulController {
                         int status2= wmsInboundResultServiceImpl.updateInboundStatus(wmspInboundDistribute.getDistributeId());
                     }
 
+                    //获取物资大类id
+                    BigDecimal materialSteelId = DataChange.dataToBigDecimal(item.get("materialId"));
+                    BigDecimal materialId = wmspSendReceiveService.getMaterialId(materialSteelId);
+                    Map<String,Object> map4 = new HashMap<>();
+                    map4.put("materialId",materialId);
+                    map4.put("warehouseId",3);
+                    wmspSendReceiveService.addInBoundSendReceive(map4);
+                    wmspSendReceiveService.addThisdayInventorySendReceive(map4);
                 }
                 int status3= wmspInboundDistributeService.updateDistributeStatus(wmspInboundDistribute.getDistributeId().toString());
-
+               // wmspSendReceiveService.addInBoundSendReceive();
             }
             return success("下发成功");
         }

src/main/java/com/steerinfo/dil/controller/WmspOutboundResultController.java

@@ -24,6 +24,11 @@ import org.springframework.web.bind.annotation.*;
 
 import java.math.BigDecimal;
 import java.util.*;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
 
 /**
  * WmspOutboundResult RESTful接口：
@@ -177,6 +182,8 @@ public class WmspOutboundResultController extends BaseRESTfulController {
         return success(i);
     }
 
+
+
     /**
      * 编写人：yanghaiming
      * 装卸工PDA前端扫描钢材吊牌二维码，新增出库单扫描实绩并返回已扫描并稽核成功的物资信息
@@ -186,7 +193,7 @@ public class WmspOutboundResultController extends BaseRESTfulController {
      *   list：出库单实绩
      * */
     @Transactional
-    @PostMapping(value = "/insertwmspOutboundScanResult")
+    @PostMapping(value = "/insertwmspOutboundScanResult6")
     public synchronized RESTfulResult insertwmspOutboundScanResult(@RequestBody(required = false) Map<String, Object> map){
         //判断物资是否满足要求,目前一下三种不做处理的判断
         //获取装卸工扫描吊牌结果   HRB400-14-21706854-9-3049-280-20211001015115-7a63cd87a4095e7f-08010103010100003-4
@@ -453,5 +460,11 @@ public class WmspOutboundResultController extends BaseRESTfulController {
         return success();
     }
 
+    //创建一个删除实时库的接口
+    @PostMapping("/deleteGridMaterial")
+    public RESTfulResult deleteGridMaterial(@RequestParam String materialOnlyCode){
+        int result = wmspOutboundResultService.deleteGridMaterial(materialOnlyCode);
+        return success(result);
+    }
 }
 

src/main/java/com/steerinfo/dil/controller/WmspSendReceiveController.java

@@ -16,7 +16,9 @@ import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
-import java.util.*;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
 
 /**
  * @author luobang
@@ -32,8 +34,10 @@ public class WmspSendReceiveController extends BaseRESTfulController {
     @Autowired
     ESFeign esFeign;
 
+
     @Autowired
-    WmspSendReceiveServiceImpl wmspSendReceiveServiceImpl;
+    WmspSendReceiveServiceImpl iWmspSendReceiveService;
+
     @PostMapping("/getSendReceive")
     @ApiOperation(value = "展示收发存报表信息")
     @ApiImplicitParams({
@@ -54,7 +58,7 @@ public class WmspSendReceiveController extends BaseRESTfulController {
         List<Map<String,Object>>sendReceiveList = null;
         if(mapValue.size() == 0){
             //将查询结果存入索引中
-            sendReceiveList = wmspSendReceiveServiceImpl.getWmspSendReceiveService(mapValue);
+            sendReceiveList = iWmspSendReceiveService.getWmspSendReceiveService(mapValue);
             Map<String, Object> sendReceiveMap = new HashMap<>();
             //添加索引
             sendReceiveMap.put("index","get_wms_SendReceive");
@@ -67,13 +71,19 @@ public class WmspSendReceiveController extends BaseRESTfulController {
             sendReceiveList.remove(sendReceiveList.size() -1);
         }
         if(sendReceiveList == null) {
-            sendReceiveList = wmspSendReceiveServiceImpl.getWmspSendReceiveService(mapValue);
+            sendReceiveList =iWmspSendReceiveService.getWmspSendReceiveService(mapValue);
         }
         /*分页*/
         PageHelper.startPage(pageNum, pageSize);
-        List<Map<String,Object>> columnList = wmspSendReceiveServiceImpl.getWmspSendReceiveService(mapValue);
+        List<Map<String,Object>> columnList = iWmspSendReceiveService.getWmspSendReceiveService(mapValue);
         PageListAdd pageList = columnDataUtil.tableColumnData(apiId,sendReceiveList,columnList);
         return success(pageList);
     }
 
+    //初始化收发层
+    @PostMapping("addSendReceive")
+    public RESTfulResult addSendReceive(){
+        int result = iWmspSendReceiveService.addSendReceive();
+        return success(result);
+    }
 }

src/main/java/com/steerinfo/dil/mapper/RmsWarehouseMapper.java

@@ -13,4 +13,5 @@ public interface RmsWarehouseMapper extends IBaseMapper<RmsWarehouse, BigDecimal
     //下拉框：仓库
     List<Map<String, Object>> getWarehouse();
 
+    List<Map<String, Object>> getWarehouseName();
 }

src/main/java/com/steerinfo/dil/mapper/WmspGridMaterialMapper.java

@@ -2,13 +2,11 @@ package com.steerinfo.dil.mapper;
 
 import com.steerinfo.dil.model.WmspGridMaterial;
 import com.steerinfo.framework.mapper.IBaseMapper;
-import org.apache.ibatis.annotations.MapKey;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 import org.apache.ibatis.annotations.Select;
 
 import java.math.BigDecimal;
-import java.text.ParseException;
 import java.util.List;
 import java.util.Map;
 
@@ -51,4 +49,8 @@ public interface WmspGridMaterialMapper extends IBaseMapper<WmspGridMaterial, Bi
   BigDecimal slelectGridIdByMaterialOnlyCode(@Param("materialOnlyCode")String materialOnlyCode);
 
 
+  int updateByMaterialId(BigDecimal materialId);
+
+  //查询id
+    List<Map<String,Object>> getMaterialId(BigDecimal warehouseId);
 }

src/main/java/com/steerinfo/dil/mapper/WmspInboundResultMapper.java

@@ -2,14 +2,14 @@ package com.steerinfo.dil.mapper;
 
 import com.steerinfo.dil.model.WmspInboundResult;
 import com.steerinfo.framework.mapper.IBaseMapper;
-import java.math.*;
-import java.util.List;
-import java.util.Map;
-
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 import org.apache.ibatis.annotations.Select;
 
+import java.math.BigDecimal;
+import java.util.List;
+import java.util.Map;
+
 @Mapper
 public interface WmspInboundResultMapper extends IBaseMapper<WmspInboundResult, BigDecimal> {
 
@@ -54,4 +54,6 @@ public interface WmspInboundResultMapper extends IBaseMapper<WmspInboundResult,
     List<Map<String,Object>> getResultMaterialByResultId(Integer resultId);
 //    根据resultMaterialId获取相对应入库实绩和仓储网格
     List<Map<String,Object>> getInboundResult(String resultMaterial);
+    //查询今日入库件数
+    BigDecimal getInbountNumber();
 }

src/main/java/com/steerinfo/dil/mapper/WmspOutboundScanResultMapper.java

@@ -19,4 +19,7 @@ public interface WmspOutboundScanResultMapper extends IBaseMapper<WmspOutboundSc
     List<OutBoundMaterialDetailedInfo> getOutBoundMaterialDetailedInfos(List<String> onlyCodes);
 
     List<String> getResultStrs(BigDecimal resultId);
+    //通过物资唯一编码查询钢材物资唯一id
+    List<Map<String, Object>> getMaterialSteelId(String materialOnlyCode);
+
 }

src/main/java/com/steerinfo/dil/mapper/WmspSendReceiveMapper.java

@@ -3,6 +3,7 @@ package com.steerinfo.dil.mapper;
 import com.steerinfo.dil.model.WmspSendReceive;
 import com.steerinfo.framework.mapper.IBaseMapper;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Select;
 
 import java.math.BigDecimal;
 import java.util.List;
@@ -14,4 +15,23 @@ public interface WmspSendReceiveMapper extends IBaseMapper<WmspSendReceive, BigD
 
     List<Map<String, Object>> selectWmspSendReceive(Map<String, Object> mapValue);
 
+    @Select("select seq_WMSP_SEND_RECEIVE.nextval from dual")
+    BigDecimal getSendReceiveId();
+
+    //更改今天的入库
+    int updateSendReceiveThisdayInbound(Map<String,Object> map);
+
+    //查询昨天的库存
+    BigDecimal getSendReceiveLastdayInventory(Map<String, Object> map);
+
+    //更改今天出库
+    int updateSendReceiveThisdayOutbound(Map<String, Object> map);
+    //今天入库
+    BigDecimal selectSendReceiveThisdayInbound(Map<String,Object> map);
+    //今天出库
+    BigDecimal selectSendReceiveThisdayOutbound(Map<String,Object> map);
+    //根据物资钢材id查询物资大类id
+    BigDecimal getMaterialId(BigDecimal materialSteelId);
+    //实时更改库存
+    int updateSendReceiveThisdayInventory(Map<String,Object> map);
 }

src/main/java/com/steerinfo/dil/model/WmspSendReceive.java

@@ -37,25 +37,25 @@ public class WmspSendReceive implements IBasePO<BigDecimal> {
      * 昨天库存(SEND_RECEIVE_LASTDAY_INVENTORY,DECIMAL,0)
      */
     @ApiModelProperty(value="昨天库存",required=false)
-    private Short sendReceiveLastdayInventory;
+    private BigDecimal sendReceiveLastdayInventory;
 
     /**
      * 今天入库(今天生产入库+今天退货入库+今天盘盈 = 今天入库)(SEND_RECEIVE_THISDAY_INBOUND,DECIMAL,0)
      */
     @ApiModelProperty(value="今天入库(今天生产入库+今天退货入库+今天盘盈 = 今天入库)",required=false)
-    private Short sendReceiveThisdayInbound;
+    private BigDecimal sendReceiveThisdayInbound;
 
     /**
      * 今天出库(今天出库+今天盘亏=今天出库)(SEND_RECEIVE_THISDAY_OUTBOUND,DECIMAL,0)
      */
     @ApiModelProperty(value="今天出库(今天出库+今天盘亏=今天出库)",required=false)
-    private Short sendReceiveThisdayOutbound;
+    private BigDecimal sendReceiveThisdayOutbound;
 
     /**
      * 今天库存(昨天库存 + 今天入库 — 今天出库 = 今天库存)(SEND_RECEIVE_THISDAY_INVENTORY,DECIMAL,0)
      */
     @ApiModelProperty(value="今天库存(昨天库存 + 今天入库 — 今天出库 = 今天库存)",required=false)
-    private Short sendReceiveThisdayInventory;
+    private BigDecimal sendReceiveThisdayInventory;
 
     /**
      * 记录创建人(INSERT_USERNAME,VARCHAR,20)
@@ -137,35 +137,35 @@ public class WmspSendReceive implements IBasePO<BigDecimal> {
         this.materialId = materialId;
     }
 
-    public Short getSendReceiveLastdayInventory() {
+    public BigDecimal getSendReceiveLastdayInventory() {
         return sendReceiveLastdayInventory;
     }
 
-    public void setSendReceiveLastdayInventory(Short sendReceiveLastdayInventory) {
+    public void setSendReceiveLastdayInventory(BigDecimal sendReceiveLastdayInventory) {
         this.sendReceiveLastdayInventory = sendReceiveLastdayInventory;
     }
 
-    public Short getSendReceiveThisdayInbound() {
+    public BigDecimal getSendReceiveThisdayInbound() {
         return sendReceiveThisdayInbound;
     }
 
-    public void setSendReceiveThisdayInbound(Short sendReceiveThisdayInbound) {
+    public void setSendReceiveThisdayInbound(BigDecimal sendReceiveThisdayInbound) {
         this.sendReceiveThisdayInbound = sendReceiveThisdayInbound;
     }
 
-    public Short getSendReceiveThisdayOutbound() {
+    public BigDecimal getSendReceiveThisdayOutbound() {
         return sendReceiveThisdayOutbound;
     }
 
-    public void setSendReceiveThisdayOutbound(Short sendReceiveThisdayOutbound) {
+    public void setSendReceiveThisdayOutbound(BigDecimal sendReceiveThisdayOutbound) {
         this.sendReceiveThisdayOutbound = sendReceiveThisdayOutbound;
     }
 
-    public Short getSendReceiveThisdayInventory() {
+    public BigDecimal getSendReceiveThisdayInventory() {
         return sendReceiveThisdayInventory;
     }
 
-    public void setSendReceiveThisdayInventory(Short sendReceiveThisdayInventory) {
+    public void setSendReceiveThisdayInventory(BigDecimal sendReceiveThisdayInventory) {
         this.sendReceiveThisdayInventory = sendReceiveThisdayInventory;
     }
 

src/main/java/com/steerinfo/dil/service/IWmspOutboundResultService.java

@@ -82,4 +82,6 @@ public interface IWmspOutboundResultService {
     OutBoundDetailed getInitOutboundScanResultMaterialInfo(BigDecimal resultId);
 
     int createOutboundScanResult(String subResultMaterial, BigDecimal personnelId, BigDecimal resultId);
+    //删除实时库存
+    int deleteGridMaterial(String materialOnlyCode);
 }

src/main/java/com/steerinfo/dil/service/IWmspSendReceiveService.java

@@ -1,5 +1,6 @@
 package com.steerinfo.dil.service;
 
+import java.math.BigDecimal;
 import java.util.List;
 import java.util.Map;
 
@@ -9,6 +10,9 @@ import java.util.Map;
  */
 public interface IWmspSendReceiveService {
 
+   int addSendReceive();
+
+
     /**
      * 1.展示库存结转基本信息
      * @param mapValue
@@ -21,4 +25,6 @@ public interface IWmspSendReceiveService {
      * @return
      */
     int count();
+    //物资大类id
+    BigDecimal getMaterialId(BigDecimal materialSteelId);
 }

src/main/java/com/steerinfo/dil/service/impl/WmspOutboundResultServiceImpl.java

@@ -3,6 +3,7 @@ package com.steerinfo.dil.service.impl;
 import com.steerinfo.dil.feign.TmstruckFeign;
 import com.steerinfo.dil.mapper.CommonSeq;
 import com.steerinfo.dil.mapper.WmspInboundScanResultMapper;
+import com.steerinfo.dil.mapper.WmspGridMaterialMapper;
 import com.steerinfo.dil.mapper.WmspOutboundResultMapper;
 import com.steerinfo.dil.mapper.WmspOutboundScanResultMapper;
 import com.steerinfo.dil.model.WmspOutboundResult;
@@ -12,6 +13,7 @@ import com.steerinfo.dil.service.IWmspOutboundResultService;
 import com.steerinfo.dil.vo.OutBoundDetailed;
 import com.steerinfo.dil.vo.OutBoundMaterialDetailedInfo;
 import com.steerinfo.dil.vo.OutBoundTypeDetailedInfo;
+import com.steerinfo.dil.util.DataChange;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
@@ -54,6 +56,10 @@ public class WmspOutboundResultServiceImpl  implements IWmspOutboundResultServic
     CommonSeq commonSeq;
     @Autowired
     private TmstruckFeign tmstruckFeign;
+
+    @Autowired
+    private WmspGridMaterialMapper wmspGridMaterialMapper;
+
     @Override
     public List<Map<String, Object>> selectResultNumber(Map<String, Object> mapval) {
         return wmspOutboundResultMapper.selectResultNumber(mapval);
@@ -338,7 +344,7 @@ public class WmspOutboundResultServiceImpl  implements IWmspOutboundResultServic
         //截取扫描结果，得到物资唯一编码
         String[] split = resultMaterial.split("-");
         //唯一编码
-        String MaterialOnlyCode=split[7];
+        String MaterialOnlyCode = split[7];
         //通过物资物资唯一编码查询钢材物资表的物资Id
         BigDecimal SteelMaterialId = getSteelMaterialIdByMaterialOnlyCode(MaterialOnlyCode);
         //通过出库实绩Id查询物资Id
@@ -352,11 +358,11 @@ public class WmspOutboundResultServiceImpl  implements IWmspOutboundResultServic
         //插入主键id
         wmspOutboundScanResult.setResultId(new BigDecimal(seq_wmspOutboundScanResult));
         //根据物资id查询相对应的入库实绩ID，并将其赋值给相对应的入库扫描实绩表
-        List<Map<String, Object>> list= wmspInboundScanResultMapper.getInboundResultIdByMaterial(resultMaterial);
+        List<Map<String, Object>> list = wmspInboundScanResultMapper.getInboundResultIdByMaterial(resultMaterial);
         //默认以获取到的第一个值作为入库实绩Id
-        Map<String ,Object> map1 = list.get(0);
+        Map<String, Object> map1 = list.get(0);
         //如果等于0说明该物资没有录入系统
-        if (list.size()==0){
+        if (list.size() == 0) {
 
         }
         wmspOutboundScanResult.setInboundResultId((BigDecimal) map1.get("inboundResultId"));
@@ -381,4 +387,24 @@ public class WmspOutboundResultServiceImpl  implements IWmspOutboundResultServic
         //插入扫描实绩
         return scanResultInsert(wmspOutboundScanResult);
     }
+    public int deleteGridMaterial(String materialOnlyCode) {
+        //获取扫描的物资
+       // List<Map<String,Object>> scanList = wmspOutboundScanResultMapper.getResultMaterial(resultId);
+        //根据扫描的吊牌数据查询钢材物资id
+      /*  List<Map<String,Object>> listMap = null;
+        int i=0;
+        for(Map<String,Object> scanMaterial:scanList){
+            String materialOnlyCode = scanMaterial.get("RESULT_MATERIAL").toString();*/
+            int i=0;
+            String[] tag1 = materialOnlyCode.split("\\-");
+            List<Map<String,Object>> listMap  = wmspOutboundScanResultMapper.getMaterialSteelId(tag1[7]);
+            for(Map<String,Object> map:listMap) {
+                BigDecimal materialId = DataChange.dataToBigDecimal(map.get("materialId"));
+
+                //将这些物资钢材id进行逻辑删除
+                i += wmspGridMaterialMapper.updateByMaterialId(materialId);
+            }
+
+        return i;
+    }
 }

src/main/java/com/steerinfo/dil/service/impl/WmspSendReceiveServiceImpl.java

@@ -1,10 +1,19 @@
 package com.steerinfo.dil.service.impl;
 
+import com.steerinfo.dil.mapper.RmsWarehouseMapper;
+import com.steerinfo.dil.mapper.WmspGridMaterialMapper;
+import com.steerinfo.dil.mapper.WmspInboundResultMapper;
 import com.steerinfo.dil.mapper.WmspSendReceiveMapper;
+import com.steerinfo.dil.model.WmspSendReceive;
 import com.steerinfo.dil.service.IWmspSendReceiveService;
+import com.steerinfo.dil.util.DataChange;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Service;
 
+import java.math.BigDecimal;
+import java.util.Date;
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
@@ -18,6 +27,15 @@ public class WmspSendReceiveServiceImpl implements IWmspSendReceiveService {
     @Autowired
     WmspSendReceiveMapper wmspSendReceiveMapper;
 
+    @Autowired
+    RmsWarehouseMapper rmsWarehouseMapper;
+
+    @Autowired
+    WmspGridMaterialMapper wmspGridMaterialMapper;
+
+    @Autowired
+    WmspInboundResultMapper wmspInboundResultMapper;
+
     @Override
     public List<Map<String, Object>> getWmspSendReceiveService(Map<String, Object> mapValue) {
         List<Map<String, Object>> maps = wmspSendReceiveMapper.selectWmspSendReceive(mapValue);
@@ -28,4 +46,106 @@ public class WmspSendReceiveServiceImpl implements IWmspSendReceiveService {
     public int count() {
         return 0;
     }
+
+    @Override
+    public BigDecimal getMaterialId(BigDecimal materialSteelId) {
+        return wmspSendReceiveMapper.getMaterialId(materialSteelId);
+    }
+
+    @Override
+    //针对每一个仓库中的每一个物资类型新增一个收发层（初始化收发层）
+    @Scheduled(cron =  "0 0 0 * * ?")
+    public int addSendReceive() {
+        int i=0;
+        WmspSendReceive wmspSendReceive = new WmspSendReceive();
+        //高线库，一棒库，二棒库，配送库
+        List<Map<String, Object>> mapList = rmsWarehouseMapper.getWarehouseName();
+        //遍历四个仓库
+        for(Map<String,Object> map:mapList){
+            BigDecimal warehouseId = DataChange.dataToBigDecimal(map.get("id"));
+            //查询去重实时库存中的物资id
+            List<Map<String,Object>> materialIdList = wmspGridMaterialMapper.getMaterialId(warehouseId);
+            for(Map<String,Object> map1:materialIdList){
+                //收发层主键自增
+                BigDecimal sendReceiveId = wmspSendReceiveMapper.getSendReceiveId();
+                wmspSendReceive.setSendReceiveId(sendReceiveId);
+                //仓库id
+                wmspSendReceive.setWarehouseId(warehouseId);
+                //收发层日期
+                wmspSendReceive.setSendReceiveDate(new Date());
+                //物资id
+                BigDecimal materialId = DataChange.dataToBigDecimal(map1.get("materialId"));
+                wmspSendReceive.setMaterialId(materialId);
+                //今天入库(今天生产入库+今天退货入库+今天盘盈 = 今天入库)暂只管出入库
+                //从零点开始每入库一件就增加一件
+                //sendReceiveThisdayInbound = wmspSendReceiveMapper.updateSendReceiveThisdayInbound(materialId);
+                //初始化今日入库为零
+                wmspSendReceive.setSendReceiveThisdayInbound(new BigDecimal(0));
+                //今天出库(今天出库+今天盘亏=今天出库)
+                //初始化出库为0
+                wmspSendReceive.setSendReceiveThisdayOutbound(new BigDecimal(0));
+                //昨天库存
+                //查询昨天库存
+                Map<String,Object> map2 = new HashMap<>();
+                map2.put("warehouseId",warehouseId);
+                map2.put("materialId",materialId);
+                BigDecimal sendReceiveLastdayInventory = wmspSendReceiveMapper.getSendReceiveLastdayInventory(map2);
+                if(sendReceiveLastdayInventory == null){
+                    wmspSendReceive.setSendReceiveLastdayInventory(new BigDecimal(0));
+                }else{
+                    wmspSendReceive.setSendReceiveLastdayInventory(sendReceiveLastdayInventory);
+                }
+                //今天库存
+//                BigDecimal sendReceiveLastdayInventory1 = wmspSendReceive.getSendReceiveLastdayInventory();
+//               if(sendReceiveLastdayInventory1.intValue()==0 || sendReceiveLastdayInventory1 == null){
+//                   wmspSendReceive.setSendReceiveThisdayInventory(new BigDecimal(0));
+//               }else {
+//                   addThisdayInventorySendReceive(map2);
+//               }
+                wmspSendReceive.setSendReceiveThisdayInventory(wmspSendReceive.getSendReceiveLastdayInventory());
+                wmspSendReceive.setInsertUsername("admin");
+                wmspSendReceive.setInsertTime(new Date());
+                wmspSendReceive.setDeleted(new BigDecimal(1));
+                i+=wmspSendReceiveMapper.insertSelective(wmspSendReceive);
+            }
+        }
+        return i;
+    }
+
+    //入库的时候调用收发层
+    //传入一个map进来warehouseId，materialId
+    public int addInBoundSendReceive(Map<String,Object> map){
+        //今天入库(今天生产入库+今天退货入库+今天盘盈 = 今天入库)暂只管入库
+        return wmspSendReceiveMapper.updateSendReceiveThisdayInbound(map);
+    }
+
+    //出库的时候调用收发层
+    public int addOutBoundSendReceive(Map<String,Object> map){
+        //今天出库(今天出库+今天盘亏=今天出库)暂只管出库
+        return wmspSendReceiveMapper.updateSendReceiveThisdayOutbound(map);
+    }
+
+    //计算今天库存(昨天库存 + 今天入库 — 今天出库 = 今天库存),实时变动
+    public int addThisdayInventorySendReceive(Map<String,Object> map){
+        BigDecimal materialId = DataChange.dataToBigDecimal(map.get("materialId"));
+        BigDecimal warehouseId = DataChange.dataToBigDecimal(map.get("warehouseId"));
+        //今天入库
+       BigDecimal sendReceiveThisdayInbound = wmspSendReceiveMapper.selectSendReceiveThisdayInbound(map);
+       //今天出库
+        BigDecimal sendReceiveThisdayOutbound = wmspSendReceiveMapper.selectSendReceiveThisdayOutbound(map);
+       // 昨天库存
+        BigDecimal sendReceiveLastdayInventory = wmspSendReceiveMapper.getSendReceiveLastdayInventory(map);
+        if(sendReceiveLastdayInventory == null){
+             sendReceiveLastdayInventory=new BigDecimal(0);
+        }
+        //今天库存
+        BigDecimal sendReceiveThisdayInventory = new BigDecimal(sendReceiveLastdayInventory.intValue()
+                +sendReceiveThisdayInbound.intValue()-sendReceiveThisdayOutbound.intValue());
+        Map<String,Object> map1 = new HashMap<>();
+        map1.put("materialId",materialId);
+        map1.put("warehouseId",warehouseId);
+        map1.put("sendReceiveThisdayInventory",sendReceiveThisdayInventory);
+        return wmspSendReceiveMapper.updateSendReceiveThisdayInventory(map1);
+
+    }
 }

src/main/resources/com/steerinfo/dil/mapper/RmsWarehouseMapper.xml

@@ -401,4 +401,14 @@ rw.warehouse_id "value",
 rw.warehouse_name "label"
  from rms_warehouse rw
   </select>
+
+ <select id="getWarehouseName" resultType="java.util.Map">
+    select
+        rw.WAREHOUSE_ID "id",
+        rw.WAREHOUSE_NAME "name"
+    from
+        RMS_WAREHOUSE rw
+    where
+        rw.WAREHOUSE_TYPE_ID=1
+  </select>
 </mapper>

src/main/resources/com/steerinfo/dil/mapper/WmspGridMaterialMapper.xml

@@ -713,6 +713,21 @@
    WHERE  RMS.MATERIAL_ONLY_CODE=#{materialOnlyCode}
   </select>
 
+  <update id="updateByMaterialId" parameterType="java.math.BigDecimal">
+    update WMSP_GRID_MATERIAL WGM set WGM.DELETED = 1
+    where WGM.MATERIAL_ID = #{materialId}
+  </update>
   
-  
+ <select id="getMaterialId" resultType="java.util.Map" parameterType="java.math.BigDecimal">
+   select distinct
+        rm.MATERIAL_ID "materialId"
+        from RMS_MATERIAL rm
+				left join RMS_MATERIAL_STEEL rms
+				on rms.MATERIAL_ID = rm.MATERIAL_ID
+    left join WMSP_GRID_MATERIAL wgm
+    on wgm.MATERIAL_ID = rms.MATERIAL_STEEL_ID
+    left join RMS_PWAREHOUSE_GRID wpg
+    on wgm.GRID_ID = wpg.GRID_ID
+    where wpg.WAREHOUSE_ID = #{warehouseId}
+ </select>
 </mapper>

src/main/resources/com/steerinfo/dil/mapper/WmspInboundResultMapper.xml

@@ -1196,6 +1196,8 @@
        update WMSP_INBOUND_RESULT set RESULT_STATUS= 2 where INBOUND_DISTRIBUTE_ID =  #{distributeId}
     </update>
 
-
+    <select id="getInbountNumber" resultType="java.math.BigDecimal">
+        select count(*) from WMSP_INBOUND_RESULT wir
+    </select>
 
 </mapper>

src/main/resources/com/steerinfo/dil/mapper/WmspOutboundScanResultMapper.xml

@@ -466,4 +466,12 @@
      select RESULT_MATERIAL "resultMaterial" from  WMSP_OUTBOUND_SCAN_RESULT where OUTBOUND_RESULT_ID=#{resultId}
   </select>
 
+  <select id="getMaterialSteelId" resultType="java.util.LinkedHashMap" parameterType="String">
+    SELECT
+       gcwz.MATERIAL_STEEL_ID "materialId"
+    FROM RMS_MATERIAL_STEEL gcwz
+    LEFT JOIN WMSP_GRID_MATERIAL wgm
+    ON gcwz.MATERIAL_STEEL_ID = wgm.MATERIAL_ID
+    WHERE gcwz.MATERIAL_ONLY_CODE = #{materialOnlyCode}
+  </select>
 </mapper>

src/main/resources/com/steerinfo/dil/mapper/WmspSendReceiveMapper.xml

@@ -512,4 +512,49 @@
       </if>
     </if>
   </sql>
+
+
+  <update id="updateSendReceiveThisdayInbound" parameterType="java.util.Map">
+    update  WMSP_SEND_RECEIVE wsr
+    set wsr.SEND_RECEIVE_THISDAY_INBOUND = wsr.SEND_RECEIVE_THISDAY_INBOUND+1
+    where wsr.MATERIAL_ID = #{materialId} and wsr.WAREHOUSE_ID = #{warehouseId}
+  </update>
+
+  <select id="getSendReceiveLastdayInventory" parameterType="java.util.Map" resultType="java.math.BigDecimal">
+    select wsr.SEND_RECEIVE_THISDAY_INVENTORY from WMSP_SEND_RECEIVE wsr
+     where wsr.MATERIAL_ID = #{materialId} and wsr.WAREHOUSE_ID = #{warehouseId}
+       and trunc(wsr.INSERT_TIME) = trunc(sysdate-1)
+  </select>
+
+  <update id="updateSendReceiveThisdayOutbound" parameterType="java.util.Map">
+    update WMSP_SEND_RECEIVE wsr
+    set wsr.SEND_RECEIVE_THISDAY_OUTBOUND = wsr.SEND_RECEIVE_THISDAY_OUTBOUND+1
+    where wsr.MATERIAL_ID = #{materialId} and wsr.WAREHOUSE_ID = #{warehouseId}
+  </update>
+
+  <select id="selectSendReceiveThisdayInbound" parameterType="java.util.Map" resultType="java.math.BigDecimal">
+    select wsr.SEND_RECEIVE_THISDAY_INBOUND
+    from WMSP_SEND_RECEIVE wsr
+    where wsr.MATERIAL_ID = #{materialId} and wsr.WAREHOUSE_ID = #{warehouseId}
+  </select>
+
+  <select id="selectSendReceiveThisdayOutbound" parameterType="java.util.Map" resultType="java.math.BigDecimal">
+    select wsr.SEND_RECEIVE_THISDAY_OUTBOUND
+    from WMSP_SEND_RECEIVE wsr
+    where wsr.MATERIAL_ID = #{materialId} and wsr.WAREHOUSE_ID = #{warehouseId}
+  </select>
+
+  <select id="getMaterialId" parameterType="java.math.BigDecimal" resultType="java.math.BigDecimal">
+    select rm.MATERIAL_ID
+    from RMS_MATERIAL rm
+    left join RMS_MATERIAL_STEEL rms
+    on rms.MATERIAL_ID = rm.MATERIAL_ID
+    where rms.MATERIAL_STEEL_ID = #{materialSteelId}
+  </select>
+
+  <update id="updateSendReceiveThisdayInventory" parameterType="java.util.Map">
+    update WMSP_SEND_RECEIVE wsr
+    set wsr.SEND_RECEIVE_THISDAY_INVENTORY = #{sendReceiveThisdayInventory}
+    where wsr.MATERIAL_ID = #{materialId} and wsr.WAREHOUSE_ID = #{warehouseId}
+  </update>
 </mapper>