【业务功能篇20】Springboot java逻辑实现动态行转列需求

淩亂°似流年 2024-03-16 15:22 49阅读 0赞

> 在此前，我也写过一个行转列的文章，是用存储过程sql处理的一个动态的逻辑
> 
> [Mysql 存储过程\\Mybatis框架call调用 实现动态行转列][Mysql _Mybatis_call_]
> 
> 那么后面我们同样又接收了业务的一个新需求，针对的是不同的业务数据，做的同样的一个展示数据报表，同样还是产品归属信息表头，拼接查询年月表头列，动态展示多个查询年月的产品产量数据。

*  这里我们具体分析下业务需求：
 *  首先是一个业务产量表，记录着每个产品编码的产量数，产量时间
 *  另外是一个编码归属表，记录着每个产品编码的归属信息，属于哪个产品，哪个项目等的归属信息

一般情况下，我们先设计后台表，然后先进行数据的sql处理，那么我们这里就从dao层开始来展开：

参数就是基于前台请求的参数类来传递，比如前端传递查询对象： 开始时间：2022-06，结束时间：2023-06， 只有时间，或者说还带上了一些 产品：产品A等

### 参数类： ###

package xxx.vo;
    
    import java.util.List;
    
    
    @Data
    public class ProductionShipmentVO implements Serializable {
    
    	private static final long serialVersionUID = 952332486490268095L;
    
    	private String label;
    	private String value;
    	private List<String> proList;
    	private List<String> itemList;
    	private List<String> codeList;
    	private List<String> taskNoList;
    	private List<String> customerList;
    	private List<String> contractList;
    	private List<String> subList;
    	private String isFlag;
    	private String startTime;
    	private String endTime;
    	private String code;
    	private Integer num;
    	private String date;
    	
    	private String product;									//产品名
    	private String project;                                 //项目
    	private String jobNum;                                 //任务令号
    	private String planStarttime;                          //计划开工时间 plan_starttime
    	private String planEndtime;                            //计划完工时间 plan_endtime
    	private String releaseTime;                            //释放时间 release_time
    	private String jobStatus;                              //任务令状态 job_status
    	private String itemcode;                                //编码 
    	private String transactionQuantity;                    //交易数量 transaction_quantity
    	private String transactionTime;                        //交易时间 transaction_time
    	private String transactionDate;                        //交易日期 transaction_date
    	private String transactionType;                        //交易类型 transaction_type
    	private String groupId;                                //组织ID group_id
    	private String subinventory;                            //子库
    	private String supplierName;                           //供应商名称 supplier_name
    	private String itemcodeCout;                           //单板点数 itemcode_cout
    	private String processingLocationcode;                 //加工地代码 processing_locationcode
    	private String processingLocationname;                 //加工地名称 processing_locationname
    	private String productFamily;                          //产品族 product_family
    	private String productSmall;                           //产品小类 product_small
    	private String productBig;                             //产品大类 product_big
    	private String smtLine;                                //SMT线体 smt_line
    	private String itemcodeLine;                           //模块线体 itemcode_line
    	private String system;                                  //系统源
    	private String lastUpdatetime;                         //最后更新时间 last_updatetime
    	private String lv1;                                     //l1部门
    	private String lv2;                                     //l2部门
    	private String lv3;                                     //l3部门
    	private String lv4;                                     //l4部门
    	private String type;                                    //类型
    	private String locator;                                 //货位
    	
    
    }

### dao层 mapper接口 ###

public interface IProductionShipmentDao {
        public List<ProductionShipmentVO> getYieldTabelProduct(ProductionShipmentVO productionShipmentVO);
    }

### dao层 xml文件映射 ###

> 1. <sql id="yieldTabel"> 标签语句
> 
> 我们把产量明细表 左联 编码归属表 的结果语句sql抽象出来放到一个sql标签中，作为共用调用的作用，可以结合业务场景判断，如果这个基础连表查询后续会多个地方需要调用，那么代码sql就可以抽出来一个sql标签中，避免重复代码过多
> 
> 2.<sql id="listWhere"> 标签语句
> 
> 同理与第一点，目前还是抽象出公共的语句，避免多处的接口sql重复代码过多，这里是一个参数的请求条件，也是极具通用的 多处地方可能会用到，所以就单独定义一个sql标签进行调用
> 
> 3.<select id="getYieldTabelProduct" resultType="com.xxx.vo.ProductionShipmentVO">
> 
> 调用标签1 作为临时表，然后根据产品 时间分组，对产量数求和，先得到一个表，每天数据表示： 产品A | 年月| 产量 的一个结果表，当然这里还需要将我们的年月的具体时间给转成列，并且对于的字段内容就是对应产品对应年月的产量。这个操作我们在service层再进行处理

<sql id="yieldTabel">
    		select A.*,IFNULL(B.PRODUCT_SERIES,'') PRODUCT_SERIES,IFNULL(B.MODEL,'') MODEL, IFNULL(B.MASS_DATE,'2500-01-01') MASS_DATE from txny.dwr_quality_xxx_proces_f A
    		left join txny.dwr_mt_xxx_report_attr_f B on A.ITEM_CODE = B.PRODUCT_CODE where substr(A.JOB_NUM,3,1)='Z'  
    	</sql>
    	
    	<sql id="listWhere">
    		<where>
    			<if test='isFlag == "1"'>
    				and date_format(TIME_PERIOD,'%Y-%m-%d') > MASS_DATE 	
    			</if>
    			<if test='isFlag == "0"'>
    				and date_format(TIME_PERIOD,'%Y-%m-%d')  <![CDATA[ <= ]]>  MASS_DATE 	
    			</if>
    			<if test="startTime != null and endTime != null">
    				and date_format(TIME_PERIOD,'%Y-%m-%d') between #{startTime} and #{endTime} 	
    			</if>
    			<if test="proList != null and proList.size > 0">
    				and PRODUCT_SERIES in 
    				<foreach collection='proList' item="item" open="(" separator="," close=")">
    					#{item}
    				</foreach>
    			</if>
    			<if test="itemList != null and itemList.size > 0">
    				and MODEL in 
    				<foreach collection='itemList' item="item" open="(" separator="," close=")">
    					#{item}
    				</foreach>
    			</if>
    			<if test="codeList != null and codeList.size > 0">
    				and ITEM_CODE in 
    				<foreach collection='codeList' item="item" open="(" separator="," close=")">
    					#{item}
    				</foreach>
    			</if>
    		</where>
    	</sql>
    	
    	<select id="getYieldTabelProduct" resultType="com.xxx.vo.ProductionShipmentVO">
    		with table1 as (
    			<include refid="yieldTabel"/>
    		)
    		select sum(QUANTITY) num,PRODUCT_SERIES product,date_format(TIME_PERIOD,'%Y-%m') date from  table1 
    		<include refid="listWhere"/>
    		group by PRODUCT_SERIES,date_format(TIME_PERIOD,'%Y-%m') order by PRODUCT_SERIES,date_format(TIME_PERIOD,'%Y-%m')
    	</select>

### service层 impl实现类 ###

通过运用java8新特性的 stream流处理数据转换，将dao层的接口方法返回的结果表：产品A | 年月| 产量 转换成一个 List<Map<String,Object>>集合，集合中每个元素Map就是一条横线的数据，比如：产品有多少个，list就有多少个元素，查询时间有多少个月，分别就会展示每个月该产品的产量以及合计产量

从而完成了数据年月的行转列

![f7f90f692f9742e2bc78486a28671e3a.png][]

@Named
    public class ProductionShipmentService implements IProductionShipmentService {
    	
    	@Inject
    	private IProductionShipmentDao iProductionShipmentDao;
    	
    	@Override
    	public List<Map<String, Object>> getYieldTabelProduct(ProductionShipmentVO productionShipmentVO) {
    
            //取出前端传参的日期 格式为 yyyy-mm-dd 取出 起始年 月  截止年 月
    		String[] sArr = productionShipmentVO.getStartTime().split("-");
    		String[] eArr = productionShipmentVO.getEndTime().split("-");
    		Integer sYear = Integer.valueOf(sArr[0]);
    		Integer eYear = Integer.valueOf(eArr[0]);
    		Integer sMonth = Integer.valueOf(sArr[1]);
    		Integer eMonth = Integer.valueOf(eArr[1]);
    		final List<Map<String, Object>> result = new ArrayList<Map<String, Object>>();
    		List<ProductionShipmentVO> totaList = iProductionShipmentDao.getYieldTabelProduct(productionShipmentVO);
    		totaList.stream().collect(Collectors.groupingBy(ProductionShipmentVO::getProduct,Collectors.collectingAndThen(Collectors.toList(), m ->{
    			Map<String, Object> map = new HashMap<String,Object>();
                //遍历从起始到截止的查询年月 转换出区间内的每个年月 比如是23年6-9月 那么
                //date 就是表示 2023-06  2023-07 2023-08 2023-09 四个日期
    			for (int i = sYear; i <= eYear; i++) {
    				for (int j = 1; j <= 12; j++) {
    					if((i== eYear && j> eMonth) || (i== sYear && j < sMonth)){
    						continue;
    					}
    					String date =  String.valueOf(i)+"-"+(j < 10 ? "0"+String.valueOf(j): String.valueOf(j));
    
    //anyMatch 有一个或一个以上的元素满足函数参数计算结果为true那整个方法返回值为true
    //判断组内的数据中是否有该日期的数据 有则将其一条数据取出 
    					if(m.stream().anyMatch(f->f.getDate().equals(date))){
    						ProductionShipmentVO res = m.stream().filter(f->f.getDate().equals(date)).findFirst().get();
    
                            //map中插入日期 对应的产量  以及产品名称
    						map.put(res.getDate(), res.getNum());
    						map.put("product", res.getProduct());
    					}else {
                            //如果没有该日期数据 就插入产量null
    						map.put(date, null);
    					}
    				}
    			}
                
                //每个年月数据取好之后，最后就是插入总累计产量
    			Integer sum =  m.stream().mapToInt(ProductionShipmentVO::getNum).sum();
    			map.put("num", sum);
    
                //把该产品的一条记录map插入list集合  依次将不同产品的map遍历插入
    			result.add(map);
    			return null;
    		})));
    		
    		return result;
    	}
    }

那么前端框架，通过获取得到返回的数据，根据list中的元素map的键值对数，就能判断表头需要动态加载几列，比如前面展示的 查询3-6个月的数据那么表头展示就是这样：动态赋值获取表列数

![44eeb97734c945339f252bcb6be087e8.png][]

[Mysql _Mybatis_call_]: https://blog.csdn.net/studyday1/article/details/1280543
[f7f90f692f9742e2bc78486a28671e3a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/ec4e982565084d73a222c5e4dbd745ee.png
[44eeb97734c945339f252bcb6be087e8.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/02f71d9719284fa28870911b53883398.png