仓储数据分析

src/main/java/com/chinaitop/depot/intelligent/basicData/controller/WarehouseDataAnalysisController.java

@@ -0,0 +1,45 @@
+package com.chinaitop.depot.intelligent.basicData.controller;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.chinaitop.depot.intelligent.basicData.param.WarehouseDataAnalysis;
+import com.chinaitop.depot.intelligent.basicData.param.WarehouseDataAnalysisChart;
+import com.chinaitop.depot.intelligent.basicData.param.WarehouseDataAnalysisPageParam;
+import com.chinaitop.depot.intelligent.basicData.service.WarehouseDataAnalysisService;
+import com.chinaitop.depot.intelligent.common.ResponseEntity;
+import com.chinaitop.depot.intelligent.devData.model.TLqDataPageParam;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.annotation.Resource;
+import java.util.List;
+
+/**
+ * @author qingsong.han
+ * @description:
+ * @create 2024-07-16 15:39
+ */
+@RestController
+@RequestMapping("/warehouseDataAnalysis")
+@Api(tags = "仓储数据分析")
+public class WarehouseDataAnalysisController {
+    @Resource
+    private WarehouseDataAnalysisService warehouseDataAnalysisService;
+
+    @GetMapping("/getPageList")
+    @ApiOperation(value = "仓储数据分析分页列表", notes = "支持分页")
+    public ResponseEntity<Page<WarehouseDataAnalysis>> getPageList(@Validated WarehouseDataAnalysisPageParam param) {
+        return ResponseEntity.ok(warehouseDataAnalysisService.getPageList(param));
+    }
+
+    @GetMapping("/getChartList/{orgId}")
+    @ApiOperation(value = "仓储数据分析分页列表", notes = "图表数据")
+    public ResponseEntity<List<WarehouseDataAnalysisChart>> getChartList(@PathVariable("orgId") Integer orgId) {
+        return ResponseEntity.ok(warehouseDataAnalysisService.getChartList(orgId));
+    }
+
+}

src/main/java/com/chinaitop/depot/intelligent/basicData/mapper/WarehouseDataAnalysisMapper.java

@@ -0,0 +1,21 @@
+package com.chinaitop.depot.intelligent.basicData.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.chinaitop.depot.intelligent.basicData.param.WarehouseDataAnalysis;
+import com.chinaitop.depot.intelligent.basicData.param.WarehouseDataAnalysisChart;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @author qingsong.han
+ * @description:
+ * @create 2024-07-16 16:02
+ */
+public interface WarehouseDataAnalysisMapper extends BaseMapper<WarehouseDataAnalysis> {
+    Page<WarehouseDataAnalysis> getPageList(Page<WarehouseDataAnalysis> objectPage, @Param("map") Map<String, Object> map);
+
+    List<WarehouseDataAnalysisChart> getChartList(@Param("orgId") Integer orgId);
+}

src/main/java/com/chinaitop/depot/intelligent/basicData/param/WarehouseDataAnalysis.java

@@ -0,0 +1,35 @@
+package com.chinaitop.depot.intelligent.basicData.param;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @author qingsong.han
+ * @description:
+ * @create 2024-07-16 15:54
+ */
+@Data
+public class WarehouseDataAnalysis implements Serializable {
+    private static final long serialVersionUID = 4911550786144931845L;
+
+    @ApiModelProperty(value = "主键id")
+    private String id;
+
+    @ApiModelProperty(value = "库区id")
+    private String orgId;
+
+    @ApiModelProperty(value = "库区名称")
+    private String orgName;
+
+    @ApiModelProperty(value = "违规类型")
+    private String warnType;
+
+    @ApiModelProperty(value = "违规行为")
+    private String warnAct;
+
+    @ApiModelProperty(value = "预警时间")
+    private Date warnTime;
+}

src/main/java/com/chinaitop/depot/intelligent/basicData/param/WarehouseDataAnalysisChart.java

@@ -0,0 +1,37 @@
+package com.chinaitop.depot.intelligent.basicData.param;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @author qingsong.han
+ * @description:
+ * @create 2024-07-16 15:56
+ */
+@Data
+public class WarehouseDataAnalysisChart implements Serializable {
+    private static final long serialVersionUID = 8206246671256299046L;
+
+    @ApiModelProperty(value = "1-12月份")
+    private String months;
+
+    @ApiModelProperty(value = "在库时间异常-月份")
+    private String currentYearMonth_1;
+
+    @ApiModelProperty(value = "在库时间异常-异常数/月(1-12)")
+    private String monthCount_1;
+
+    @ApiModelProperty(value = "临近轮换期-月份")
+    private String currentYearMonth_2;
+
+    @ApiModelProperty(value = "临近轮换期-异常数/月(1-12)")
+    private String monthCount_2;
+
+    @ApiModelProperty(value = "超架空期-月份")
+    private String currentYearMonth_3;
+
+    @ApiModelProperty(value = "超架空期-异常数/月(1-12)")
+    private String monthCount_3;
+}

src/main/java/com/chinaitop/depot/intelligent/basicData/param/WarehouseDataAnalysisPageParam.java

@@ -0,0 +1,26 @@
+package com.chinaitop.depot.intelligent.basicData.param;
+
+import com.chinaitop.depot.intelligent.common.PageParam;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Getter;
+import lombok.Setter;
+
+import javax.validation.constraints.NotNull;
+
+/**
+ * @author qingsong.han
+ * @description:
+ * @create 2024-07-16 15:42
+ */
+@Getter
+@Setter
+public class WarehouseDataAnalysisPageParam extends PageParam {
+    private static final long serialVersionUID = 4244633669674123132L;
+
+    @ApiModelProperty(value = "库区编码", required = true)
+    @NotNull(message = "库区编码不能为空")
+    private Integer orgId;
+
+    @ApiModelProperty(value = "预警类型")
+    private String warnType;
+}

src/main/java/com/chinaitop/depot/intelligent/basicData/service/WarehouseDataAnalysisService.java

@@ -0,0 +1,20 @@
+package com.chinaitop.depot.intelligent.basicData.service;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.chinaitop.depot.intelligent.basicData.param.WarehouseDataAnalysis;
+import com.chinaitop.depot.intelligent.basicData.param.WarehouseDataAnalysisChart;
+import com.chinaitop.depot.intelligent.basicData.param.WarehouseDataAnalysisPageParam;
+
+import java.util.List;
+
+/**
+ * @author qingsong.han
+ * @description:
+ * @create 2024-07-16 15:49
+ */
+public interface WarehouseDataAnalysisService extends IService<WarehouseDataAnalysis> {
+    Page<WarehouseDataAnalysis> getPageList(WarehouseDataAnalysisPageParam param);
+
+    List<WarehouseDataAnalysisChart> getChartList(Integer orgId);
+}

src/main/java/com/chinaitop/depot/intelligent/basicData/service/impl/WarehouseDataAnalysisServiceImpl.java

@@ -0,0 +1,42 @@
+package com.chinaitop.depot.intelligent.basicData.service.impl;
+
+import com.baomidou.mybatisplus.core.toolkit.StringUtils;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.chinaitop.depot.intelligent.basicData.mapper.WarehouseDataAnalysisMapper;
+import com.chinaitop.depot.intelligent.basicData.param.WarehouseDataAnalysis;
+import com.chinaitop.depot.intelligent.basicData.param.WarehouseDataAnalysisChart;
+import com.chinaitop.depot.intelligent.basicData.param.WarehouseDataAnalysisPageParam;
+import com.chinaitop.depot.intelligent.basicData.service.WarehouseDataAnalysisService;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @author qingsong.han
+ * @description:
+ * @create 2024-07-16 15:50
+ */
+@Service
+public class WarehouseDataAnalysisServiceImpl extends ServiceImpl<WarehouseDataAnalysisMapper, WarehouseDataAnalysis> implements WarehouseDataAnalysisService {
+    @Resource
+    private WarehouseDataAnalysisMapper warehouseDataAnalysisMapper;
+
+    @Override
+    public Page<WarehouseDataAnalysis> getPageList(WarehouseDataAnalysisPageParam param) {
+        Map<String, Object> map = new HashMap<>();
+        map.put("orgId", param.getOrgId());
+        if (StringUtils.isNotBlank(param.getWarnType())) {
+            map.put("warnType", param.getWarnType());
+        }
+        return warehouseDataAnalysisMapper.getPageList(new Page<>(param.getCurrent(), param.getSize()), map);
+    }
+
+    @Override
+    public List<WarehouseDataAnalysisChart> getChartList(Integer orgId) {
+        return warehouseDataAnalysisMapper.getChartList(orgId);
+    }
+}

src/main/resources/mapper/basicData/WarehouseDataAnalysisMapper.xml

@@ -0,0 +1,88 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.chinaitop.depot.intelligent.basicData.mapper.WarehouseDataAnalysisMapper">
+    <select id="getPageList" parameterType="map" resultType="com.chinaitop.depot.intelligent.basicData.param.WarehouseDataAnalysis">
+        SELECT
+            t1.id,
+            t1.orgId,
+            t1.orgName,
+            t1.warnType,
+            t1.warnAct,
+            t1.warnTime
+        FROM
+        (
+        SELECT
+            pv.id,
+            pv.org_id orgId,
+            oi.org_name orgName,
+            CASE WHEN pv.violation_type = 1 THEN '疑转圈粮预警' ELSE '' END AS warnType,
+            pv.subject_type warnAct,
+            pv.publish_time warnTime
+        FROM
+            storage_pre_violation pv
+        LEFT JOIN org_info oi ON pv.org_id = oi.org_id
+        WHERE
+            pv.violation_type = 1
+        AND pv.org_id = #{map.orgId}
+        UNION ALL
+        SELECT
+            rw.id,
+            rw.org_id orgId,
+            oi.org_name orgName,
+            CASE WHEN rw.bjlx=0 THEN '轮换预警' ELSE '应轮未轮' END AS warnType,
+            CASE WHEN rw.bjlx=0 THEN '轮换预警' ELSE '应轮未轮' END AS warnAct,
+            rw.scsj warnTime
+        FROM
+            storage_rotation_warning rw
+        LEFT JOIN org_info oi ON rw.org_id = oi.org_id
+        WHERE rw.org_id = #{map.orgId}
+        UNION ALL
+        SELECT
+            jw.id,
+            jw.org_id orgId,
+            oi.org_name orgName,
+            '架空期预警' AS warnType,
+            '架空期预警' AS warnAct,
+            jw.yjrq warnTime
+        FROM
+        storage_jkq_warning jw
+        LEFT JOIN org_info oi ON jw.org_id = oi.org_id
+        WHERE
+            jw.jkqzt = 1
+        AND jw.org_id = #{map.orgId}
+        ) t1
+        <where>
+            <if test="map.warnType!=null and map.warnType!=''">
+                t1.warnType LIKE CONCAT("%",#{map.warnType},"%")
+            </if>
+        </where>
+    </select>
+    <select id="getChartList" parameterType="integer" resultType="com.chinaitop.depot.intelligent.basicData.param.WarehouseDataAnalysisChart">
+        SELECT
+            t1.months,
+            t2.currentYearMonth_1,
+            t2.monthCount_1,
+            t2.currentYearMonth_2,
+            t2.monthCount_2,
+            t2.currentYearMonth_3,
+            t2.monthCount_3
+        FROM
+        (SELECT 1 AS months UNION SELECT 2 UNION SELECT 3 UNION SELECT 4 UNION SELECT 5 UNION SELECT 6 UNION SELECT 7 UNION SELECT 8 UNION SELECT 9 UNION SELECT 10 UNION SELECT 11 UNION SELECT 12) AS t1
+        LEFT JOIN
+        (
+        SELECT
+            MONTH (sa.alarm_date) currentYearMonth_1,
+            COUNT(sa.id) monthCount_1,
+            MONTH (rw.scsj) currentYearMonth_2,
+            COUNT(rw.id) monthCount_2,
+            MONTH (jw.jkqjzr) currentYearMonth_3,
+            COUNT(jw.id) monthCount_3
+        FROM
+            province_all.biz_pss_storage_anomaly sa
+        INNER JOIN storage_rotation_warning rw ON sa.org_id = rw.org_id
+        INNER JOIN storage_jkq_warning jw ON sa.org_id = jw.org_id
+        WHERE
+            sa.org_id = #{orgId}
+        ) t2 ON t1.months = t2.currentYearMonth_1
+    </select>
+</mapper>