库存详情新增入库数量与出库数量，方便后续分组统计查询

src/main/java/com/glxp/api/entity/inv/InvPreInProductDetailEntity.java

@@ -95,6 +95,14 @@ public class InvPreInProductDetailEntity {
     @TableField(value = "reCount")
     private int reCount;
 
+    @TableField(value = "inCount")
+    private int inCount;
+
+
+    @TableField(value = "outCount")
+    private int outCount;
+
+
     /**
      * 部门编码
      */
@@ -126,7 +134,6 @@ public class InvPreInProductDetailEntity {
     private Date updateTime;
 
 
-
     public static final String COL_ID = "id";
 
     public static final String COL_CODE = "code";

src/main/java/com/glxp/api/entity/inv/InvPreProductDetailEntity.java

@@ -95,6 +95,15 @@ public class InvPreProductDetailEntity {
     @TableField(value = "reCount")
     private int reCount;
 
+
+    @TableField(value = "inCount")
+    private int inCount;
+
+
+    @TableField(value = "outCount")
+    private int outCount;
+
+
     /**
      * 部门编码
      */

src/main/java/com/glxp/api/entity/inv/InvProductDetailEntity.java

@@ -80,6 +80,14 @@ public class InvProductDetailEntity {
     @TableField(value = "reCount")
     private int reCount;
 
+
+    @TableField(value = "inCount")
+    private int inCount;
+
+
+    @TableField(value = "outCount")
+    private int outCount;
+
     /**
      * 部门编码
      */

src/main/java/com/glxp/api/service/inout/IoGenInvService.java

@@ -102,6 +102,12 @@ public class IoGenInvService {
             invProductDetailEntity.setRelId(codeEntity.getRelId());
             invProductDetailEntity.setUpdateTime(new Date());
             invProductDetailEntity.setPurchaseType(ConstantStatus.PRUCHASE_COMMON);
+            if (invProductDetailEntity.getMainAction().equals(ConstantType.TYPE_PUT)) {
+                invProductDetailEntity.setInCount(invProductDetailEntity.getReCount());
+            } else if (invProductDetailEntity.getMainAction().equals(ConstantType.TYPE_OUT)) {
+                invProductDetailEntity.setOutCount(invProductDetailEntity.getReCount());
+            }
+
             invProductDetailEntities.add(invProductDetailEntity);
         }
         BasicBusTypePreEntity basicBusTypePreEntity = basicBusTypePreService.findByOriginAction(orderEntity.getAction());
@@ -166,6 +172,12 @@ public class IoGenInvService {
             invProductDetailEntity.setRelId(codeEntity.getRelId());
             invProductDetailEntity.setUpdateTime(new Date());
             invProductDetailEntity.setPurchaseType(ConstantStatus.PRUCHASE_COMMON);
+            if (invProductDetailEntity.getMainAction().equals(ConstantType.TYPE_PUT)) {
+                invProductDetailEntity.setInCount(invProductDetailEntity.getReCount());
+            } else if (invProductDetailEntity.getMainAction().equals(ConstantType.TYPE_OUT)) {
+                invProductDetailEntity.setOutCount(invProductDetailEntity.getReCount());
+            }
+
             invProductDetailEntities.add(invProductDetailEntity);
         }
         invPreProductDetailService.insertList(invProductDetailEntities);
@@ -241,6 +253,12 @@ public class IoGenInvService {
             invProductDetailEntity.setRelId(codeEntity.getRelId());
             invProductDetailEntity.setUpdateTime(new Date());
             invProductDetailEntity.setPurchaseType(ConstantStatus.PRUCHASE_COMMON);
+            if (invProductDetailEntity.getMainAction().equals(ConstantType.TYPE_PUT)) {
+                invProductDetailEntity.setInCount(invProductDetailEntity.getReCount());
+            } else if (invProductDetailEntity.getMainAction().equals(ConstantType.TYPE_OUT)) {
+                invProductDetailEntity.setOutCount(invProductDetailEntity.getReCount());
+            }
+
             invProductDetailEntities.add(invProductDetailEntity);
         }
         invPreinProductDetailService.insertList(invProductDetailEntities);

src/main/java/com/glxp/api/service/inv/impl/InvPreInProductDetailServiceImpl.java

@@ -45,6 +45,12 @@ public class InvPreInProductDetailServiceImpl implements InvPreinProductDetailSe
 
     @Override
     public int insert(InvPreInProductDetailEntity invPreInProductDetailEntity) {
+        if (invPreInProductDetailEntity.getMainAction().equals(ConstantType.TYPE_PUT)) {
+            invPreInProductDetailEntity.setInCount(invPreInProductDetailEntity.getReCount());
+        } else if (invPreInProductDetailEntity.getMainAction().equals(ConstantType.TYPE_OUT)) {
+            invPreInProductDetailEntity.setOutCount(invPreInProductDetailEntity.getReCount());
+        }
+
         return invPreInProductDetailDao.insert(invPreInProductDetailEntity);
     }
 
@@ -79,6 +85,12 @@ public class InvPreInProductDetailServiceImpl implements InvPreinProductDetailSe
 
     @Override
     public boolean update(InvPreInProductDetailEntity invPreInProductDetailEntity) {
+        if (invPreInProductDetailEntity.getMainAction().equals(ConstantType.TYPE_PUT)) {
+            invPreInProductDetailEntity.setInCount(invPreInProductDetailEntity.getReCount());
+        } else if (invPreInProductDetailEntity.getMainAction().equals(ConstantType.TYPE_OUT)) {
+            invPreInProductDetailEntity.setOutCount(invPreInProductDetailEntity.getReCount());
+        }
+
         return invPreInProductDetailDao.updateById(invPreInProductDetailEntity) == 1 ? true : false;
     }
 

src/main/java/com/glxp/api/service/inv/impl/InvPreProductDetailServiceImpl.java

@@ -45,6 +45,12 @@ public class InvPreProductDetailServiceImpl implements InvPreProductDetailServic
 
     @Override
     public int insert(InvPreProductDetailEntity invPreProductDetailEntity) {
+        if (invPreProductDetailEntity.getMainAction().equals(ConstantType.TYPE_PUT)) {
+            invPreProductDetailEntity.setInCount(invPreProductDetailEntity.getReCount());
+        } else if (invPreProductDetailEntity.getMainAction().equals(ConstantType.TYPE_OUT)) {
+            invPreProductDetailEntity.setOutCount(invPreProductDetailEntity.getReCount());
+        }
+
         return invPreProductDetailDao.insert(invPreProductDetailEntity);
     }
 
@@ -73,6 +79,12 @@ public class InvPreProductDetailServiceImpl implements InvPreProductDetailServic
 
     @Override
     public boolean update(InvPreProductDetailEntity invPreProductDetailEntity) {
+        if (invPreProductDetailEntity.getMainAction().equals(ConstantType.TYPE_PUT)) {
+            invPreProductDetailEntity.setInCount(invPreProductDetailEntity.getReCount());
+        } else if (invPreProductDetailEntity.getMainAction().equals(ConstantType.TYPE_OUT)) {
+            invPreProductDetailEntity.setOutCount(invPreProductDetailEntity.getReCount());
+        }
+
         return invPreProductDetailDao.updateById(invPreProductDetailEntity) == 1 ? true : false;
     }
 

src/main/java/com/glxp/api/service/inv/impl/InvProductDetailServiceImpl.java

@@ -40,6 +40,11 @@ public class InvProductDetailServiceImpl implements InvProductDetailService {
     @Override
     public int insert(InvProductDetailEntity invProductDetailEntity) {
         invProductDetailEntity.setId(null);
+        if (invProductDetailEntity.getMainAction().equals(ConstantType.TYPE_PUT)) {
+            invProductDetailEntity.setInCount(invProductDetailEntity.getReCount());
+        } else if (invProductDetailEntity.getMainAction().equals(ConstantType.TYPE_OUT)) {
+            invProductDetailEntity.setOutCount(invProductDetailEntity.getReCount());
+        }
         return invProductDetailDao.insert(invProductDetailEntity);
     }
 
@@ -73,6 +78,13 @@ public class InvProductDetailServiceImpl implements InvProductDetailService {
 
     @Override
     public int update(InvProductDetailEntity invProductDetailEntity) {
+
+        if (invProductDetailEntity.getMainAction().equals(ConstantType.TYPE_PUT)) {
+            invProductDetailEntity.setInCount(invProductDetailEntity.getReCount());
+        } else if (invProductDetailEntity.getMainAction().equals(ConstantType.TYPE_OUT)) {
+            invProductDetailEntity.setOutCount(invProductDetailEntity.getReCount());
+        }
+
         return invProductDetailDao.updateById(invProductDetailEntity);
     }
 

src/main/resources/schemas/schema_v2.1.sql

@@ -1,9 +1,13 @@
 #   字段新增   （表名，字段名，字段类型，修改方式（1：新增，2：修改，3：删除）
 
-CALL Pro_Temp_ColumnWork('auth_user_bustype', 'updateTime', 'datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP', 1);
+CALL Pro_Temp_ColumnWork('auth_user_bustype', 'updateTime',
-CALL Pro_Temp_ColumnWork('auth_warehouse_bustype', 'updateTime', 'datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP', 1);
+                         'datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP', 1);
-CALL Pro_Temp_ColumnWork('auth_warehouse_user', 'updateTime', 'datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP', 1);
+CALL Pro_Temp_ColumnWork('auth_warehouse_bustype', 'updateTime',
-CALL Pro_Temp_ColumnWork('auth_dept_user', 'updateTime', 'datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP', 1);
+                         'datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP', 1);
+CALL Pro_Temp_ColumnWork('auth_warehouse_user', 'updateTime',
+                         'datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP', 1);
+CALL Pro_Temp_ColumnWork('auth_dept_user', 'updateTime',
+                         'datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP', 1);
 
 CALL Pro_Temp_ColumnWork('sync_data_set', 'department', 'tinyint ', 1);
 CALL Pro_Temp_ColumnWork('sync_data_set', 'warehouseDict', 'tinyint ', 1);
@@ -176,6 +180,13 @@ CALL Pro_Temp_ColumnWork('inv_product', 'planOutCount', 'int ', 1);
 CALL Pro_Temp_ColumnWork('inv_product', 'onWayCount', 'int ', 1);
 CALL Pro_Temp_ColumnWork('inv_product', 'availableStock', 'int ', 1);
 
+CALL Pro_Temp_ColumnWork('inv_product_detail', 'inCount', 'int ', 1);
+CALL Pro_Temp_ColumnWork('inv_product_detail', 'outCount', 'int ', 1);
+CALL Pro_Temp_ColumnWork('inv_prein_product_detail', 'inCount', 'int ', 1);
+CALL Pro_Temp_ColumnWork('inv_prein_product_detail', 'outCount', 'int ', 1);
+CALL Pro_Temp_ColumnWork('inv_pre_product_detail', 'inCount', 'int ', 1);
+CALL Pro_Temp_ColumnWork('inv_pre_product_detail', 'outCount', 'int ', 1);
+
 CALL Pro_Temp_ColumnWork('auth_warehouse', 'updateTime', 'datetime ', 1);
 
 CALL Pro_Temp_ColumnWork('sync_data_set', 'basicType', 'tinyint', 1);