部门资产报表-查询与导出

ruoyi-admin/src/main/java/com/ruoyi/inventory/controller/TbAssetInventoryController.java

@@ -10,6 +10,7 @@ import javax.servlet.http.HttpServletResponse;
 import com.ruoyi.common.code.QRCodeUtils;
 import com.ruoyi.common.code.QrDTO;
 import com.ruoyi.common.utils.file.Folder2ZipUtils;
+import com.ruoyi.inventory.domain.dto.DepAssetLossResultDto;
 import com.ruoyi.inventory.domain.dto.TakeStockDTO;
 import com.ruoyi.inventory.domain.dto.TbAssetInventoryDTO;
 import com.ruoyi.inventory.domain.enums.InventoryPlanResult;
@@ -30,7 +31,7 @@ import com.ruoyi.common.core.page.TableDataInfo;
 
 /**
  * 资产盘点记录Controller
- * 
+ *
  * @author ydl
  * @date 2023-06-01
  */
@@ -169,4 +170,25 @@ public class TbAssetInventoryController extends BaseController
         qrDTO.setValue(tbAssetInventory.getOrderNumber());
         QRCodeUtils.createCodeToOutputStream(qrDTO, response.getOutputStream());
     }
+
+    /**
+     * 查询部门资产报表（两次盘点间的资产损耗）
+     * @param depId 部门ID
+     * @return
+     */
+//    我粘贴过来的 @PreAuthorize("@ss.hasPermi('inventory:inventory:query')")
+    @GetMapping("/getDepAssetLossTb")
+    public AjaxResult getDepAssetLossTb(String depId){
+
+        return success(tbAssetInventoryService.inventoryDepAssetById(depId));
+    }
+
+    @GetMapping("/exportDepAssetLossTb")
+    public void exportDepAssetLossTb(HttpServletResponse response, String depId){
+
+        List<DepAssetLossResultDto> results = tbAssetInventoryService.inventoryDepAssetById(depId);
+        ExcelUtil<DepAssetLossResultDto> util = new ExcelUtil<DepAssetLossResultDto>(DepAssetLossResultDto.class);
+        util.exportExcel(response, results, "近两次资产盘点损耗统计");
+
+    }
 }

ruoyi-admin/src/main/java/com/ruoyi/inventory/domain/dto/DepAssetLossDto.java

@@ -0,0 +1,38 @@
+package com.ruoyi.inventory.domain.dto;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.List;
+
+/**
+ * 部门资产损耗数据对象
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class DepAssetLossDto  {
+
+    /** 资产名称 */
+    private String assetName;
+
+    /** 位置 */
+    private List<String> locations;
+
+    /** 类别 */
+    private String category;
+
+    /** 现存数量 */
+    private int nowQuantity;
+
+    /** 损耗数量 */
+    private int lossQuantity;
+
+    /** 损耗值 */
+    private double lossVal;
+
+    /** 最近一次盘点时间 */
+    private String time;
+
+}

ruoyi-admin/src/main/java/com/ruoyi/inventory/domain/dto/DepAssetLossResultDto.java

@@ -0,0 +1,26 @@
+package com.ruoyi.inventory.domain.dto;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.List;
+
+@NoArgsConstructor
+@AllArgsConstructor
+@Data
+public class DepAssetLossResultDto {
+
+    /**
+     * 此次盘点计算出的损耗总值
+     */
+    private double totalLossVal;
+
+    /**
+     * 资产盘点结果集
+     */
+    private List<DepAssetLossDto> assetResultList;
+
+
+
+}

ruoyi-admin/src/main/java/com/ruoyi/inventory/mapper/TbAssetInventoryMapper.java

@@ -2,20 +2,22 @@ package com.ruoyi.inventory.mapper;
 
 import java.util.List;
 import com.ruoyi.inventory.domain.TbAssetInventory;
+import com.ruoyi.inventory.domain.TbInventoryDetail;
+import com.ruoyi.inventory.domain.dto.DepAssetLossDto;
 import com.ruoyi.inventory.domain.dto.TbAssetInventoryDTO;
 import org.apache.ibatis.annotations.Param;
 
 /**
  * 资产盘点记录Mapper接口
- * 
+ *
  * @author ydl
  * @date 2023-06-01
  */
-public interface TbAssetInventoryMapper 
+public interface TbAssetInventoryMapper
 {
     /**
      * 查询资产盘点记录
-     * 
+     *
      * @param id 资产盘点记录主键
      * @return 资产盘点记录
      */
@@ -27,7 +29,7 @@ public interface TbAssetInventoryMapper
 
     /**
      * 查询资产盘点记录列表
-     * 
+     *
      * @param tbAssetInventory 资产盘点记录
      * @return 资产盘点记录集合
      */
@@ -35,7 +37,7 @@ public interface TbAssetInventoryMapper
 
     /**
      * 新增资产盘点记录
-     * 
+     *
      * @param tbAssetInventory 资产盘点记录
      * @return 结果
      */
@@ -43,7 +45,7 @@ public interface TbAssetInventoryMapper
 
     /**
      * 修改资产盘点记录
-     * 
+     *
      * @param tbAssetInventory 资产盘点记录
      * @return 结果
      */
@@ -51,7 +53,7 @@ public interface TbAssetInventoryMapper
 
     /**
      * 删除资产盘点记录
-     * 
+     *
      * @param id 资产盘点记录主键
      * @return 结果
      */
@@ -59,7 +61,7 @@ public interface TbAssetInventoryMapper
 
     /**
      * 批量删除资产盘点记录
-     * 
+     *
      * @param ids 需要删除的数据主键集合
      * @return 结果
      */
@@ -72,4 +74,8 @@ public interface TbAssetInventoryMapper
      * @return 资产盘点记录集合
      */
     public List<TbAssetInventoryDTO> selectTbAssetInventoryDTOList(TbAssetInventoryDTO dto);
+
+    public List<String> getDepAssetByOrderNumber(String orderNumber);
+
+    public String getOrderNumberByDepId(String depId, String whichOne);
 }

ruoyi-admin/src/main/java/com/ruoyi/inventory/service/ITbAssetInventoryService.java

@@ -9,15 +9,15 @@ import javax.servlet.http.HttpServletResponse;
 
 /**
  * 资产盘点记录Service接口
- * 
+ *
  * @author ydl
  * @date 2023-06-01
  */
-public interface ITbAssetInventoryService 
+public interface ITbAssetInventoryService
 {
     /**
      * 查询资产盘点记录
-     * 
+     *
      * @param id 资产盘点记录主键
      * @return 资产盘点记录
      */
@@ -26,7 +26,7 @@ public interface ITbAssetInventoryService
     TbAssetInventory selectTbAssetInventoryByNumber(String num);
     /**
      * 查询资产盘点记录列表
-     * 
+     *
      * @param tbAssetInventory 资产盘点记录
      * @return 资产盘点记录集合
      */
@@ -34,7 +34,7 @@ public interface ITbAssetInventoryService
 
     /**
      * 新增资产盘点记录
-     * 
+     *
      * @param tbAssetInventory 资产盘点记录
      * @return 结果
      */
@@ -50,7 +50,7 @@ public interface ITbAssetInventoryService
 
     /**
      * 修改资产盘点记录
-     * 
+     *
      * @param tbAssetInventory 资产盘点记录
      * @return 结果
      */
@@ -58,7 +58,7 @@ public interface ITbAssetInventoryService
 
     /**
      * 批量删除资产盘点记录
-     * 
+     *
      * @param ids 需要删除的资产盘点记录主键集合
      * @return 结果
      */
@@ -66,7 +66,7 @@ public interface ITbAssetInventoryService
 
     /**
      * 删除资产盘点记录信息
-     * 
+     *
      * @param id 资产盘点记录主键
      * @return 结果
      */
@@ -79,4 +79,7 @@ public interface ITbAssetInventoryService
      * @return 资产盘点记录集合
      */
     public List<TbAssetInventoryDTO> selectTbAssetInventoryDTOList(TbAssetInventoryDTO dto);
+
+
+    List inventoryDepAssetById(String depId);
 }

ruoyi-admin/src/main/java/com/ruoyi/inventory/service/impl/TbAssetInventoryServiceImpl.java

@@ -11,6 +11,8 @@ import com.ruoyi.asset.domain.TbLocation;
 import com.ruoyi.asset.mapper.TbAssetInformationMapper;
 import com.ruoyi.asset.mapper.TbLocationMapper;
 import com.ruoyi.inventory.domain.TbInventoryDetail;
+import com.ruoyi.inventory.domain.dto.DepAssetLossDto;
+import com.ruoyi.inventory.domain.dto.DepAssetLossResultDto;
 import com.ruoyi.inventory.domain.dto.TakeStockDTO;
 import com.ruoyi.inventory.domain.dto.TbAssetInventoryDTO;
 import com.ruoyi.inventory.mapper.TbInventoryDetailMapper;
@@ -20,6 +22,7 @@ import org.springframework.stereotype.Service;
 import com.ruoyi.inventory.mapper.TbAssetInventoryMapper;
 import com.ruoyi.inventory.domain.TbAssetInventory;
 import com.ruoyi.inventory.service.ITbAssetInventoryService;
+import org.springframework.web.bind.annotation.RequestMapping;
 
 import static com.ruoyi.inventory.domain.enums.InventoryPlanResult.*;
 import static com.ruoyi.inventory.domain.enums.InventoryPlanStatus.PLAN_FINISH;
@@ -29,7 +32,7 @@ import static com.ruoyi.inventory.domain.enums.InventoryStatus.UNCOUNTED;
 
 /**
  * 资产盘点记录Service业务层处理
- * 
+ *
  * @author ydl
  * @date 2023-06-01
  */
@@ -50,7 +53,7 @@ public class TbAssetInventoryServiceImpl implements ITbAssetInventoryService
 
     /**
      * 查询资产盘点记录
-     * 
+     *
      * @param id 资产盘点记录主键
      * @return 资产盘点记录
      */
@@ -75,7 +78,7 @@ public class TbAssetInventoryServiceImpl implements ITbAssetInventoryService
 
     /**
      * 查询资产盘点记录列表
-     * 
+     *
      * @param tbAssetInventory 资产盘点记录
      * @return 资产盘点记录
      */
@@ -111,7 +114,7 @@ public class TbAssetInventoryServiceImpl implements ITbAssetInventoryService
 
     /**
      * 新增资产盘点记录
-     * 
+     *
      * @param tbAssetInventory 资产盘点记录
      * @return 结果
      */
@@ -358,7 +361,7 @@ public class TbAssetInventoryServiceImpl implements ITbAssetInventoryService
 
     /**
      * 修改资产盘点记录
-     * 
+     *
      * @param tbAssetInventory 资产盘点记录
      * @return 结果
      */
@@ -412,7 +415,7 @@ public class TbAssetInventoryServiceImpl implements ITbAssetInventoryService
 
     /**
      * 批量删除资产盘点记录
-     * 
+     *
      * @param ids 需要删除的资产盘点记录主键
      * @return 结果
      */
@@ -426,7 +429,7 @@ public class TbAssetInventoryServiceImpl implements ITbAssetInventoryService
 
     /**
      * 删除资产盘点记录信息
-     * 
+     *
      * @param id 资产盘点记录主键
      * @return 结果
      */
@@ -458,4 +461,138 @@ public class TbAssetInventoryServiceImpl implements ITbAssetInventoryService
         String locationName = Arrays.toString(tbLocations.stream().map(TbLocation::getName).toArray());
         tbAssetInventoryDTO.setInventoryLocationName(locationName);
     }
+
+    /**
+     * 根据部门id统计最近两次盘点间的部门资产损耗情况
+     * @param depId
+     * @return
+     */
+    public List<DepAssetLossResultDto> inventoryDepAssetById(String depId){
+
+       /* 本想这样写sql的：
+        select inventory_metadata metadata
+        from tb_inventory_detail
+        where order_number in
+            (select order_number
+            from tb_asset_inventory
+            where inventory_status = 2 and inventory_department = 206
+            order by inventory_date desc
+            limit 0,2)
+        但是，语法不支持，会报错：This version of MySQL doesn't yet support 'LIMIT & IN/ALL/ANY/SOME subquery'
+        暂时选择以下方法解决，但要连接四次数据库，很可能需要优化
+        */
+        //前前一次盘点计划编码
+        String old_num = tbAssetInventoryMapper.getOrderNumberByDepId(depId, "0");
+        //前一次盘点计划编码
+        String new_num = tbAssetInventoryMapper.getOrderNumberByDepId(depId, "1");
+
+        //前两次盘点资产详细信息-元数据
+        List<String> old_asset_list = tbAssetInventoryMapper.getDepAssetByOrderNumber(old_num);
+        List<String> new_asset_list = tbAssetInventoryMapper.getDepAssetByOrderNumber(new_num);
+
+        List<TbAssetInformation> old_assetInfos = new ArrayList<>();
+        List<TbAssetInformation> new_assetInfos = new ArrayList<>();
+
+        //json数据 --> java对象
+        for (String asset : old_asset_list) {
+            System.out.println(asset);
+            old_assetInfos.add(JSONUtil.toBean(asset, TbAssetInformation.class));
+        }
+        for (String asset : new_asset_list) {
+            System.out.println(asset);
+            new_assetInfos.add(JSONUtil.toBean(asset, TbAssetInformation.class));
+        }
+
+        Map<String, DepAssetLossDto> old_assetMap = new HashMap<>();
+        Map<String, DepAssetLossDto> new_assetMap = new HashMap<>();
+        //各资产损耗值map
+        HashMap<String, Double> old_lossValMap = new HashMap<>();
+        HashMap<String, Double> new_lossValMap = new HashMap<>();
+
+        //统计两次盘点计划每一样资产（同资产名）的相关信息
+        handleAssetInfo(old_assetInfos,old_assetMap,old_lossValMap);
+        handleAssetInfo(new_assetInfos,new_assetMap,new_lossValMap);
+
+        //将map中统计好的资产信息转到list
+        ArrayList<DepAssetLossDto> old_assetResultList = new ArrayList<>();
+        ArrayList<DepAssetLossDto> new_assetResultList = new ArrayList<>();
+
+        Set<Map.Entry<String, DepAssetLossDto>> old_entrySet = old_assetMap.entrySet();
+        Set<Map.Entry<String, DepAssetLossDto>> new_entrySet = new_assetMap.entrySet();
+        for (Map.Entry<String, DepAssetLossDto> entry : old_entrySet) {
+            DepAssetLossDto dto = entry.getValue();
+            dto.setLossVal(old_lossValMap.get(dto.getAssetName()));
+            old_assetResultList.add(dto);
+        }
+        for (Map.Entry<String, DepAssetLossDto> entry : new_entrySet) {
+            DepAssetLossDto dto = entry.getValue();
+            dto.setLossVal(new_lossValMap.get(dto.getAssetName()));
+            new_assetResultList.add(dto);
+        }
+
+        //计算损耗总值
+        Set<Map.Entry<String, Double>> oldLossValSet = old_lossValMap.entrySet();
+        Set<Map.Entry<String, Double>> newLossValSet = new_lossValMap.entrySet();
+        double oldLossVal = 0.0;
+        double newLossVal = 0.0;
+        for (Map.Entry<String, Double> entry : oldLossValSet) {
+            oldLossVal+=entry.getValue();
+        }
+        for (Map.Entry<String, Double> entry : newLossValSet) {
+            newLossVal+=entry.getValue();
+        }
+
+
+
+        //封装结果
+        DepAssetLossResultDto old_resultDto = new DepAssetLossResultDto();
+        old_resultDto.setTotalLossVal(oldLossVal);
+        old_resultDto.setAssetResultList(old_assetResultList);
+
+        DepAssetLossResultDto new_resultDto = new DepAssetLossResultDto();
+        new_resultDto.setTotalLossVal(newLossVal);
+        new_resultDto.setAssetResultList(new_assetResultList);
+
+        List<DepAssetLossResultDto> results = new ArrayList<>();
+        results.add(old_resultDto);
+        results.add(new_resultDto);
+        return results;
+    }
+
+
+    private void handleAssetInfo(List<TbAssetInformation> assetInfos,
+                                 Map<String, DepAssetLossDto> assetMap,
+                                 Map<String, Double> lossValMap){
+        for (TbAssetInformation asset : assetInfos) {
+            if (!assetMap.containsKey(asset.getName())){
+
+                DepAssetLossDto lossDto = new DepAssetLossDto();
+                lossDto.setAssetName(asset.getName());
+                lossDto.setCategory(asset.getCategoryName());
+                lossDto.setNowQuantity(asset.getQuantity());
+
+                List<String> locations = new ArrayList<>();
+                if (asset.getManageStatus()==7) {
+                    lossDto.setLossQuantity(asset.getQuantity());
+                    locations.add(asset.getAncestorLocationName()+asset.getParentLocationName()+asset.getLocationName());
+                    lossDto.setLocations(locations);
+                    lossValMap.put(asset.getName(),(asset.getOriginalValue()-asset.getNetValue())*asset.getQuantity());
+                }
+                assetMap.put(asset.getName(),lossDto);
+            } else {
+                DepAssetLossDto lossDto = assetMap.get(asset.getName());
+                lossDto.setNowQuantity(lossDto.getNowQuantity()+asset.getQuantity());
+                if (asset.getManageStatus()==7) {
+                    lossDto.setLossQuantity(lossDto.getLossQuantity()+asset.getQuantity());
+                    lossDto.getLocations()
+                            .add(asset.getAncestorLocationName()+asset.getParentLocationName()+asset.getLocationName());
+                    lossValMap.put(asset.getName(),lossValMap.get(asset.getName())
+                            +(asset.getOriginalValue()-asset.getNetValue())*asset.getQuantity());
+                }
+            }
+
+        }
+    }
+
+
 }

ruoyi-admin/src/main/resources/mapper/inventory/TbAssetInventoryMapper.xml

@@ -3,7 +3,7 @@
 PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
 "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.ruoyi.inventory.mapper.TbAssetInventoryMapper">
-    
+
     <resultMap type="TbAssetInventory" id="TbAssetInventoryResult">
         <result property="id"    column="id"    />
         <result property="orderNumber"    column="order_number"    />
@@ -46,7 +46,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
 
     <select id="selectTbAssetInventoryList" parameterType="TbAssetInventory" resultType="TbAssetInventory">
         <include refid="selectTbAssetInventory"/>
-        <where>  
+        <where>
             <if test="orderNumber != null  and orderNumber != ''"> and a.order_number = #{orderNumber}</if>
             <if test="name != null  and name != ''"> and a.name like concat('%', #{name}, '%')</if>
             <if test="inventoryDepartment != null  and inventoryDepartment != ''"> and a.inventory_department = #{inventoryDepartment} OR a.inventory_department in (
@@ -60,7 +60,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
             <if test="recordStatus != null "> and a.record_status = #{recordStatus}</if>
         </where>
     </select>
-    
+
     <select id="selectTbAssetInventoryById" parameterType="Long" resultType="TbAssetInventory">
         <include refid="selectTbAssetInventory"/>
         where a.id = #{id}
@@ -78,7 +78,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         <include refid="selectTbAssetInventory"/>
         where a.order_number = #{orderNumber}
     </select>
-        
+
     <insert id="insertTbAssetInventory" parameterType="TbAssetInventory" useGeneratedKeys="true" keyProperty="id">
         insert into tb_asset_inventory
         <trim prefix="(" suffix=")" suffixOverrides=",">
@@ -135,7 +135,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
     </delete>
 
     <delete id="deleteTbAssetInventoryByIds" parameterType="String">
-        delete from tb_asset_inventory where id in 
+        delete from tb_asset_inventory where id in
         <foreach item="id" collection="array" open="(" separator="," close=")">
             #{id}
         </foreach>
@@ -181,4 +181,21 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
             <if test="recordStatus != null "> and a.record_status = #{recordStatus}</if>
         </where>
     </select>
-</mapper>
+
+
+
+    <select id="getDepAssetByOrderNumber" parameterType="String" resultType="String">
+        select inventory_metadata metadata
+        from tb_inventory_detail
+        where order_number = #{orderNumber}
+    </select>
+
+    <select id="getOrderNumberByDepId" parameterType="String" resultType="String">
+        select order_number
+        from tb_asset_inventory
+        where inventory_status = 2 and inventory_department = #{depId}
+        order by inventory_date desc
+        limit #{whichOne},1
+    </select>
+
+</mapper>