74 changed files with 1909 additions and 145 deletions
@ -0,0 +1,41 @@
|
||||
package com.logpm.report.entity; |
||||
|
||||
|
||||
import com.baomidou.mybatisplus.annotation.TableName; |
||||
import io.swagger.annotations.ApiModelProperty; |
||||
import lombok.AllArgsConstructor; |
||||
import lombok.Data; |
||||
import lombok.EqualsAndHashCode; |
||||
import org.springblade.core.tenant.mp.TenantEntity; |
||||
|
||||
import java.util.Map; |
||||
|
||||
@Data |
||||
@TableName("logpm_large_screen_data") |
||||
@EqualsAndHashCode(callSuper = true) |
||||
@AllArgsConstructor |
||||
public class LargeScreenDataEntity extends TenantEntity { |
||||
|
||||
/** 预留1 */ |
||||
@ApiModelProperty(name = "预留1",notes = "") |
||||
private String reserve1 ; |
||||
/** 预留2 */ |
||||
@ApiModelProperty(name = "预留2",notes = "") |
||||
private String reserve2 ; |
||||
/** 预留3 */ |
||||
@ApiModelProperty(name = "预留3",notes = "") |
||||
private String reserve3 ; |
||||
/** 预留4 */ |
||||
@ApiModelProperty(name = "预留4",notes = "") |
||||
private String reserve4 ; |
||||
/** 预留5 */ |
||||
@ApiModelProperty(name = "预留5",notes = "") |
||||
private String reserve5 ; |
||||
|
||||
@ApiModelProperty(name = "数据",notes = "") |
||||
private Map<String, Object> data; |
||||
|
||||
public LargeScreenDataEntity(Map<String, Object> data) { |
||||
this.data = data; |
||||
} |
||||
} |
||||
@ -0,0 +1,70 @@
|
||||
package com.logpm.report.job; |
||||
|
||||
|
||||
import com.logpm.report.entity.LargeScreenDataEntity; |
||||
import com.logpm.report.mapper.largeScreen.LargeScreenDataMapper; |
||||
import com.logpm.report.service.largeScreen.*; |
||||
import com.logpm.report.vo.largeScreen.XxlJobQueryVO; |
||||
import com.xxl.job.core.handler.annotation.XxlJob; |
||||
import lombok.AllArgsConstructor; |
||||
import lombok.extern.log4j.Log4j2; |
||||
import org.springframework.stereotype.Component; |
||||
|
||||
import java.util.HashMap; |
||||
|
||||
/** |
||||
* 大屏数据查询job |
||||
*/ |
||||
@AllArgsConstructor |
||||
@Component |
||||
@Log4j2 |
||||
public class LargeScreenQueryXxlJob { |
||||
|
||||
private final IMapWarehouseService mapWarehouseService; |
||||
private final IBillingDataService billingDataService; |
||||
private final ICarsLoadDataService CarsLoad; |
||||
private final INodeDataService nodeData; |
||||
private final IBinLocationService BinLocation; |
||||
private final ITrunkDataService trunkData; |
||||
private final IDeliveryDataService deliveryDataService; |
||||
private final IBusinessRationService businessRatio; |
||||
|
||||
private final LargeScreenDataMapper largeScreenDataMapper; |
||||
|
||||
/** |
||||
* 数据查询 |
||||
*/ |
||||
@XxlJob("LargeScreenQuery") |
||||
public void query() |
||||
{ |
||||
XxlJobQueryVO xxlJobQueryVO = new XxlJobQueryVO(); |
||||
xxlJobQueryVO.setMapWarehouse(mapWarehouseService.list()); |
||||
xxlJobQueryVO.setBillingData(billingDataService.getBillingData()); |
||||
xxlJobQueryVO.setCareerLineDeliveryData(CarsLoad.getCareerLineData(1)); |
||||
xxlJobQueryVO.setCareerLineData(CarsLoad.getCareerLineData(0)); |
||||
xxlJobQueryVO.setNodeData(nodeData.getNodeData()); |
||||
xxlJobQueryVO.setBinLocationData(BinLocation.getBinLocationData()); |
||||
xxlJobQueryVO.setTrunkData(trunkData.getTrunkData()); |
||||
xxlJobQueryVO.setDeliveryData(deliveryDataService.getDeliveryAllData(0)); |
||||
xxlJobQueryVO.setDeliveryYearData(deliveryDataService.getDeliveryAllData(1)); |
||||
xxlJobQueryVO.setBusinessRatio(businessRatio.getBusinessRatioData()); |
||||
xxlJobQueryVO.setWarehouseBillingData(billingDataService.getWarehouseBillingData()); |
||||
xxlJobQueryVO.setMonthBillingData(billingDataService.getMonthBillingData()); |
||||
|
||||
HashMap<String, Object> data = new HashMap<>(); |
||||
data.put("mapWarehouse", xxlJobQueryVO.getMapWarehouse()); |
||||
data.put("billingData", xxlJobQueryVO.getBillingData()); |
||||
data.put("warehouseBillingData", xxlJobQueryVO.getWarehouseBillingData()); |
||||
data.put("monthBillingData", xxlJobQueryVO.getMonthBillingData()); |
||||
data.put("careerLineData", xxlJobQueryVO.getCareerLineData()); |
||||
data.put("careerLineDeliveryData", xxlJobQueryVO.getCareerLineDeliveryData()); |
||||
data.put("nodeData", xxlJobQueryVO.getNodeData()); |
||||
data.put("binLocationData", xxlJobQueryVO.getBinLocationData()); |
||||
data.put("trunkData", xxlJobQueryVO.getTrunkData()); |
||||
data.put("deliveryData", xxlJobQueryVO.getDeliveryData()); |
||||
data.put("deliveryYearData", xxlJobQueryVO.getDeliveryYearData()); |
||||
data.put("businessRatio", xxlJobQueryVO.getBusinessRatio()); |
||||
|
||||
largeScreenDataMapper.insert(new LargeScreenDataEntity(data)); |
||||
} |
||||
} |
||||
@ -0,0 +1,17 @@
|
||||
package com.logpm.report.mapper.largeScreen; |
||||
|
||||
|
||||
import org.apache.ibatis.annotations.Mapper; |
||||
|
||||
@Mapper |
||||
public interface BinLocationMapper { |
||||
// 在库订单数
|
||||
Integer getOrderNum(); |
||||
// 包裹数
|
||||
Integer getPackageNum(); |
||||
// 货柜数
|
||||
Integer getBinLocationNum(); |
||||
// 使用货柜数
|
||||
// 空闲货柜数
|
||||
Integer getIdleBinLocationNum(); |
||||
} |
||||
@ -0,0 +1,16 @@
|
||||
<?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.logpm.report.mapper.largeScreen.BinLocationMapper"> |
||||
<select id="getOrderNum" resultType="java.lang.Integer"> |
||||
select count(distinct order_code) from logpm_platform.logpm_distribution_parcel_list where order_package_status = '20' |
||||
</select> |
||||
<select id="getPackageNum" resultType="java.lang.Integer"> |
||||
select count(distinct order_package_code) from logpm_platform.logpm_distribution_parcel_list where order_package_status = '20' |
||||
</select> |
||||
<select id="getBinLocationNum" resultType="java.lang.Integer"> |
||||
select count(id) from logpm_platform.logpm_warehouse_goods_allocation where enable_status = 1 |
||||
</select> |
||||
<select id="getIdleBinLocationNum" resultType="java.lang.Integer"> |
||||
select count(*) from logpm_platform.logpm_warehouse_goods_allocation where enable_status = 1 AND allocation_status = 1 |
||||
</select> |
||||
</mapper> |
||||
@ -0,0 +1,15 @@
|
||||
package com.logpm.report.mapper.largeScreen; |
||||
|
||||
|
||||
import com.logpm.report.vo.largeScreen.BusinessRatio.ItemDataVO; |
||||
import org.apache.ibatis.annotations.Mapper; |
||||
|
||||
import java.util.List; |
||||
|
||||
@Mapper |
||||
public interface BusinessRatioMapper { |
||||
|
||||
List<ItemDataVO> getTypeData(String startTime, String endTime); |
||||
|
||||
List<ItemDataVO> getBrandData(String startTime, String endTime); |
||||
} |
||||
@ -0,0 +1,20 @@
|
||||
<?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.logpm.report.mapper.largeScreen.BusinessRatioMapper"> |
||||
<select id="getTypeData" resultType="com.logpm.report.vo.largeScreen.BusinessRatio.ItemDataVO"> |
||||
select |
||||
service_type as name, |
||||
SUM(total_count) as value |
||||
from logpm_platform.logpm_warehouse_waybill |
||||
where create_time between #{startTime} and #{endTime} |
||||
group by service_type |
||||
</select> |
||||
<select id="getBrandData" resultType="com.logpm.report.vo.largeScreen.BusinessRatio.ItemDataVO"> |
||||
select |
||||
brand as name, |
||||
SUM(total_count) as value |
||||
from logpm_platform.logpm_warehouse_waybill |
||||
where create_time between #{startTime} and #{endTime} |
||||
group by brand |
||||
</select> |
||||
</mapper> |
||||
@ -1,14 +1,19 @@
|
||||
package com.logpm.report.mapper.largeScreen; |
||||
|
||||
|
||||
import com.logpm.report.vo.largeScreen.CareerLineData.CareerLineInfoVO; |
||||
import com.logpm.report.vo.largeScreen.CareerLineData.DeptInfoVO; |
||||
import com.logpm.report.vo.largeScreen.CareerLineData.VehicleStowageDataVO; |
||||
import com.logpm.report.vo.largeScreen.CareerLineData.WarehouseDeptVO; |
||||
import org.apache.ibatis.annotations.Mapper; |
||||
|
||||
import java.util.List; |
||||
|
||||
@Mapper |
||||
public interface CarsLoadDataMapper { |
||||
public List<CareerLineInfoVO> getCareerLineInfo(); |
||||
public List<DeptInfoVO> getDeptInfo(); |
||||
|
||||
public List<VehicleStowageDataVO> getVehicleStowageData(String startTime, String endTime); |
||||
public List<VehicleStowageDataVO> getDeliveryData(String startTime, String endTime); |
||||
|
||||
public List<WarehouseDeptVO> getWarehouseDept(); |
||||
} |
||||
|
||||
@ -1,11 +1,35 @@
|
||||
<?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.logpm.report.mapper.largeScreen.CarsLoadDataMapper"> |
||||
<select id="getCareerLineInfo" |
||||
resultType="com.logpm.report.vo.largeScreen.CareerLineData.CareerLineInfoVO"> |
||||
<select id="getDeptInfo" |
||||
resultType="com.logpm.report.vo.largeScreen.CareerLineData.DeptInfoVO"> |
||||
SELECT id, |
||||
dept_name as deptName |
||||
dept_name as deptName, |
||||
parent_id as parentId |
||||
FROM logpm.blade_dept |
||||
WHERE dept_category = 2 AND dept_name like '%事业线%' |
||||
</select> |
||||
<select id="getVehicleStowageData" |
||||
resultType="com.logpm.report.vo.largeScreen.CareerLineData.VehicleStowageDataVO"> |
||||
|
||||
select DATE_FORMAT(create_time, '%Y-%m') as createMonth, |
||||
SUBSTRING_INDEX(end_warehouse_ids, ',', -1) as warehouseId, |
||||
SUM(real_loading_number) as total |
||||
from logpm_platform.logpm_trunkline_cars_load |
||||
where create_time between #{startTime} and #{endTime} |
||||
group by createMonth, warehouseId |
||||
</select> |
||||
<select id="getWarehouseDept" resultType="com.logpm.report.vo.largeScreen.CareerLineData.WarehouseDeptVO"> |
||||
select |
||||
id as warehouseId, |
||||
department as dept |
||||
from logpm_platform.logpm_warehouse_warehouse |
||||
</select> |
||||
<select id="getDeliveryData" resultType="com.logpm.report.vo.largeScreen.CareerLineData.VehicleStowageDataVO"> |
||||
select DATE_FORMAT(create_time, '%Y-%m') as createMonth, |
||||
warehouse_id as warehouseId, |
||||
SUM(delivery_number) as total |
||||
from logpm_platform.logpm_distribution_delivery_list |
||||
where create_time between #{startTime} and #{endTime} |
||||
group by createMonth, warehouseId |
||||
</select> |
||||
</mapper> |
||||
|
||||
@ -0,0 +1,11 @@
|
||||
package com.logpm.report.mapper.largeScreen; |
||||
|
||||
import com.logpm.report.vo.largeScreen.DeliveryDataVO; |
||||
import org.apache.ibatis.annotations.Mapper; |
||||
|
||||
@Mapper |
||||
public interface DeliveryDataMapper { |
||||
public DeliveryDataVO getDeliveryAllData(String startTime, String endTime); |
||||
public DeliveryDataVO getDelivery2BData(String startTime, String endTime); |
||||
public DeliveryDataVO getDelivery2CData(String startTime, String endTime); |
||||
} |
||||
@ -0,0 +1,33 @@
|
||||
<?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.logpm.report.mapper.largeScreen.DeliveryDataMapper"> |
||||
<select id="getDeliveryAllData" resultType="com.logpm.report.vo.largeScreen.DeliveryDataVO"> |
||||
select |
||||
count(*) as total, |
||||
sum(case when delivery_status = '3' then 0 else 1 end) as toBeSigned |
||||
from logpm_platform.logpm_distribution_delivery_list |
||||
<if test="startTime != null"> |
||||
where create_time between #{startTime} and #{endTime} |
||||
</if> |
||||
</select> |
||||
<select id="getDelivery2BData" resultType="com.logpm.report.vo.largeScreen.DeliveryDataVO"> |
||||
select |
||||
count(*) as total2B, |
||||
sum(case when delivery_status = '3' then 0 else 1 end) as toBeSigned2B |
||||
from logpm_platform.logpm_distribution_delivery_list |
||||
where type = '1' |
||||
<if test="startTime != null"> |
||||
and create_time between #{startTime} and #{endTime} |
||||
</if> |
||||
</select> |
||||
<select id="getDelivery2CData" resultType="com.logpm.report.vo.largeScreen.DeliveryDataVO"> |
||||
select |
||||
count(*) as total2C, |
||||
sum(case when delivery_status = '3' then 0 else 1 end) as toBeSigned2C |
||||
from logpm_platform.logpm_distribution_delivery_list |
||||
where type = '2' |
||||
<if test="startTime != null"> |
||||
and create_time between #{startTime} and #{endTime} |
||||
</if> |
||||
</select> |
||||
</mapper> |
||||
@ -0,0 +1,10 @@
|
||||
package com.logpm.report.mapper.largeScreen; |
||||
|
||||
import com.baomidou.mybatisplus.core.mapper.BaseMapper; |
||||
import com.logpm.report.entity.LargeScreenDataEntity; |
||||
import org.apache.ibatis.annotations.Mapper; |
||||
|
||||
@Mapper |
||||
public interface LargeScreenDataMapper extends BaseMapper<LargeScreenDataEntity> { |
||||
|
||||
} |
||||
@ -0,0 +1,13 @@
|
||||
package com.logpm.report.mapper.largeScreen; |
||||
|
||||
|
||||
import org.apache.ibatis.annotations.Mapper; |
||||
|
||||
@Mapper |
||||
public interface NodeDataMapper { |
||||
public Integer getWaybill(String startTime, String endTime); |
||||
public Integer getCarsLoadLoading(String startTime, String endTime); |
||||
public Integer getDeliveryLading(String startTime, String endTime); |
||||
public Integer getArrival(String startTime, String endTime); |
||||
public Integer getSign(String startTime, String endTime); |
||||
} |
||||
@ -0,0 +1,24 @@
|
||||
<?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.logpm.report.mapper.largeScreen.NodeDataMapper"> |
||||
<select id="getWaybill" resultType="java.lang.Integer"> |
||||
select SUM(total_count) from logpm_platform.logpm_warehouse_waybill where create_time between #{startTime} and #{endTime} |
||||
</select> |
||||
<select id="getCarsLoadLoading" resultType="java.lang.Integer"> |
||||
select SUM(real_loading_number) from logpm_platform.logpm_trunkline_cars_load where create_time between #{startTime} and #{endTime} |
||||
</select> |
||||
<select id="getDeliveryLading" resultType="java.lang.Integer"> |
||||
select SUM(loaded_number) + SUM(loadedin_number) from logpm_platform.logpm_distribution_signfor where create_time between #{startTime} and #{endTime} |
||||
</select> |
||||
<select id="getArrival" resultType="java.lang.Integer"> |
||||
select |
||||
count(*) |
||||
from logpm_platform.logpm_warehouse_waybill w |
||||
INNER JOIN logpm_platform.logpm_trunkline_cars_unload_log l on l.waybill_id = w.id |
||||
where l.create_time between #{startTime} and #{endTime} |
||||
</select> |
||||
<select id="getSign" resultType="java.lang.Integer"> |
||||
select SUM(received_quantity) + SUM(receivedin_quantity) from logpm_platform.logpm_distribution_signfor where create_time between #{startTime} and #{endTime} |
||||
</select> |
||||
|
||||
</mapper> |
||||
@ -0,0 +1,10 @@
|
||||
package com.logpm.report.mapper.largeScreen; |
||||
|
||||
import org.apache.ibatis.annotations.Mapper; |
||||
|
||||
@Mapper |
||||
public interface TrunkDataMapper { |
||||
public Integer getTotal(String startTime, String endTime); |
||||
public Integer getOnTheWay(); |
||||
public Integer getArrival(String startTime, String endTime); |
||||
} |
||||
@ -0,0 +1,25 @@
|
||||
<?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.logpm.report.mapper.largeScreen.TrunkDataMapper"> |
||||
<select id="getTotal" resultType="java.lang.Integer"> |
||||
select count(*) |
||||
from logpm_platform.logpm_trunkline_cars_load |
||||
where |
||||
create_time between #{startTime} and #{endTime} |
||||
and load_status in ('0', '10', '20', '30', '40', '80') |
||||
</select> |
||||
<select id="getOnTheWay" resultType="java.lang.Integer"> |
||||
select |
||||
count(*) |
||||
from logpm_platform.logpm_trunkline_cars_load |
||||
where load_status in ('10', '20', '30') |
||||
</select> |
||||
<select id="getArrival" resultType="java.lang.Integer"> |
||||
select |
||||
count(*) |
||||
from logpm_platform.logpm_trunkline_cars_load |
||||
where |
||||
create_time between #{startTime} and #{endTime} |
||||
and load_status in ('40', '80') |
||||
</select> |
||||
</mapper> |
||||
@ -0,0 +1,7 @@
|
||||
package com.logpm.report.service.largeScreen; |
||||
|
||||
import com.logpm.report.vo.largeScreen.BinLocationDataVO; |
||||
|
||||
public interface IBinLocationService { |
||||
BinLocationDataVO getBinLocationData(); |
||||
} |
||||
@ -0,0 +1,8 @@
|
||||
package com.logpm.report.service.largeScreen; |
||||
|
||||
import com.logpm.report.vo.largeScreen.BusinessRatioDataVO; |
||||
|
||||
public interface IBusinessRationService { |
||||
|
||||
BusinessRatioDataVO getBusinessRatioData(); |
||||
} |
||||
@ -0,0 +1,8 @@
|
||||
package com.logpm.report.service.largeScreen; |
||||
|
||||
|
||||
import com.logpm.report.vo.largeScreen.DeliveryDataVO; |
||||
|
||||
public interface IDeliveryDataService { |
||||
DeliveryDataVO getDeliveryAllData(Integer isYear); |
||||
} |
||||
@ -0,0 +1,7 @@
|
||||
package com.logpm.report.service.largeScreen; |
||||
|
||||
import com.logpm.report.vo.largeScreen.NodeDataVO; |
||||
|
||||
public interface INodeDataService { |
||||
NodeDataVO getNodeData(); |
||||
} |
||||
@ -0,0 +1,8 @@
|
||||
package com.logpm.report.service.largeScreen; |
||||
|
||||
import com.logpm.report.vo.largeScreen.TrunkDataVO; |
||||
|
||||
public interface ITrunkDataService { |
||||
|
||||
public TrunkDataVO getTrunkData(); |
||||
} |
||||
@ -0,0 +1,63 @@
|
||||
package com.logpm.report.service.largeScreen.httpImpl; |
||||
|
||||
import cn.hutool.core.date.DateUtil; |
||||
import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
||||
import com.logpm.report.entity.LargeScreenDataEntity; |
||||
import com.logpm.report.mapper.largeScreen.BillingDataMapper; |
||||
import com.logpm.report.mapper.largeScreen.LargeScreenDataMapper; |
||||
import com.logpm.report.mapper.largeScreen.MapWarehouseMapper; |
||||
import com.logpm.report.service.largeScreen.IBillingDataService; |
||||
import com.logpm.report.vo.largeScreen.BillingDataVO; |
||||
import com.logpm.report.vo.largeScreen.MapWarehouse.WarehouseInfoVO; |
||||
import com.logpm.report.vo.largeScreen.MonthBillingDataVO; |
||||
import com.logpm.report.vo.largeScreen.WarehouseBillingDataVO; |
||||
import com.logpm.report.vo.largeScreen.XxlJobQueryVO; |
||||
import com.logpm.report.vo.largeScreen.billingData.BillingDataInfoVO; |
||||
import lombok.AllArgsConstructor; |
||||
import lombok.extern.log4j.Log4j2; |
||||
import org.springframework.stereotype.Service; |
||||
|
||||
import java.util.ArrayList; |
||||
import java.util.Date; |
||||
import java.util.List; |
||||
import java.util.Map; |
||||
import java.util.stream.Collectors; |
||||
|
||||
@Service("billingDataServiceHttp") |
||||
@Log4j2 |
||||
@AllArgsConstructor |
||||
public class BillingDataServiceImpl implements IBillingDataService { |
||||
|
||||
private final LargeScreenDataMapper largeScreenDataMapper; |
||||
|
||||
@Override |
||||
public BillingDataVO getBillingData() { |
||||
|
||||
LargeScreenDataEntity largeScreenDataEntity = largeScreenDataMapper.selectOne(Wrappers.<LargeScreenDataEntity>lambdaQuery().orderByDesc(LargeScreenDataEntity::getCreateTime)); |
||||
|
||||
XxlJobQueryVO init = XxlJobQueryVO.init(largeScreenDataEntity.getData()); |
||||
|
||||
return init.getBillingData(); |
||||
} |
||||
|
||||
@Override |
||||
public List<WarehouseBillingDataVO> getWarehouseBillingData() { |
||||
LargeScreenDataEntity largeScreenDataEntity = largeScreenDataMapper.selectOne(Wrappers.<LargeScreenDataEntity>lambdaQuery().orderByDesc(LargeScreenDataEntity::getCreateTime)); |
||||
|
||||
XxlJobQueryVO init = XxlJobQueryVO.init(largeScreenDataEntity.getData()); |
||||
|
||||
return init.getWarehouseBillingData(); |
||||
} |
||||
|
||||
@Override |
||||
public List<MonthBillingDataVO> getMonthBillingData() { |
||||
LargeScreenDataEntity largeScreenDataEntity = largeScreenDataMapper.selectOne(Wrappers.<LargeScreenDataEntity>lambdaQuery().orderByDesc(LargeScreenDataEntity::getCreateTime)); |
||||
|
||||
if (largeScreenDataEntity == null) { |
||||
return new ArrayList<>(); |
||||
} |
||||
XxlJobQueryVO init = XxlJobQueryVO.init(largeScreenDataEntity.getData()); |
||||
|
||||
return init.getMonthBillingData(); |
||||
} |
||||
} |
||||
@ -0,0 +1,32 @@
|
||||
package com.logpm.report.service.largeScreen.httpImpl; |
||||
|
||||
import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
||||
import com.logpm.report.entity.LargeScreenDataEntity; |
||||
import com.logpm.report.mapper.largeScreen.BinLocationMapper; |
||||
import com.logpm.report.mapper.largeScreen.LargeScreenDataMapper; |
||||
import com.logpm.report.service.largeScreen.IBinLocationService; |
||||
import com.logpm.report.vo.largeScreen.BinLocationDataVO; |
||||
import com.logpm.report.vo.largeScreen.XxlJobQueryVO; |
||||
import lombok.AllArgsConstructor; |
||||
import lombok.extern.log4j.Log4j2; |
||||
import org.springframework.stereotype.Service; |
||||
|
||||
|
||||
@AllArgsConstructor |
||||
@Service("binLocationServiceHttp") |
||||
@Log4j2 |
||||
public class BinLocationServiceImpl implements IBinLocationService { |
||||
private final LargeScreenDataMapper largeScreenDataMapper; |
||||
|
||||
public BinLocationDataVO getBinLocationData() { |
||||
|
||||
LargeScreenDataEntity largeScreenDataEntity = largeScreenDataMapper.selectOne(Wrappers.<LargeScreenDataEntity>lambdaQuery().orderByDesc(LargeScreenDataEntity::getCreateTime)); |
||||
|
||||
if (largeScreenDataEntity == null) { |
||||
return new BinLocationDataVO(); |
||||
} |
||||
XxlJobQueryVO init = XxlJobQueryVO.init(largeScreenDataEntity.getData()); |
||||
|
||||
return init.getBinLocationData(); |
||||
} |
||||
} |
||||
@ -0,0 +1,34 @@
|
||||
package com.logpm.report.service.largeScreen.httpImpl; |
||||
|
||||
import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
||||
import com.logpm.report.entity.LargeScreenDataEntity; |
||||
import com.logpm.report.mapper.largeScreen.BusinessRatioMapper; |
||||
import com.logpm.report.mapper.largeScreen.LargeScreenDataMapper; |
||||
import com.logpm.report.service.largeScreen.IBusinessRationService; |
||||
import com.logpm.report.vo.largeScreen.BusinessRatioDataVO; |
||||
import com.logpm.report.vo.largeScreen.XxlJobQueryVO; |
||||
import lombok.AllArgsConstructor; |
||||
import lombok.extern.log4j.Log4j2; |
||||
import org.springframework.stereotype.Service; |
||||
|
||||
import java.time.LocalDateTime; |
||||
import java.time.format.DateTimeFormatter; |
||||
|
||||
@AllArgsConstructor |
||||
@Service("businessRationServiceHttp") |
||||
@Log4j2 |
||||
public class BusinessRationServiceImpl implements IBusinessRationService { |
||||
|
||||
private final LargeScreenDataMapper largeScreenDataMapper; |
||||
|
||||
@Override |
||||
public BusinessRatioDataVO getBusinessRatioData() { |
||||
LargeScreenDataEntity largeScreenDataEntity = largeScreenDataMapper.selectOne(Wrappers.<LargeScreenDataEntity>lambdaQuery().orderByDesc(LargeScreenDataEntity::getCreateTime)); |
||||
if (largeScreenDataEntity == null) { |
||||
return new BusinessRatioDataVO(); |
||||
} |
||||
XxlJobQueryVO init = XxlJobQueryVO.init(largeScreenDataEntity.getData()); |
||||
|
||||
return init.getBusinessRatio(); |
||||
} |
||||
} |
||||
@ -0,0 +1,48 @@
|
||||
package com.logpm.report.service.largeScreen.httpImpl; |
||||
|
||||
import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
||||
import com.logpm.report.entity.LargeScreenDataEntity; |
||||
import com.logpm.report.mapper.largeScreen.CarsLoadDataMapper; |
||||
import com.logpm.report.mapper.largeScreen.LargeScreenDataMapper; |
||||
import com.logpm.report.service.largeScreen.ICarsLoadDataService; |
||||
import com.logpm.report.vo.largeScreen.CareerLineData.DeptInfoVO; |
||||
import com.logpm.report.vo.largeScreen.CareerLineData.VehicleStowageDataVO; |
||||
import com.logpm.report.vo.largeScreen.CareerLineData.VehicleStowageMonthDataVo; |
||||
import com.logpm.report.vo.largeScreen.CareerLineData.WarehouseDeptVO; |
||||
import com.logpm.report.vo.largeScreen.CareerLineDataVO; |
||||
import com.logpm.report.vo.largeScreen.XxlJobQueryVO; |
||||
import lombok.AllArgsConstructor; |
||||
import lombok.extern.log4j.Log4j2; |
||||
import org.springframework.stereotype.Service; |
||||
|
||||
import java.time.LocalDate; |
||||
import java.time.format.DateTimeFormatter; |
||||
import java.util.ArrayList; |
||||
import java.util.HashMap; |
||||
import java.util.List; |
||||
import java.util.Map; |
||||
import java.util.stream.Collectors; |
||||
|
||||
@AllArgsConstructor |
||||
@Service("carsLoadDataServiceHttp") |
||||
@Log4j2 |
||||
public class CarsLoadDataServiceImpl implements ICarsLoadDataService { |
||||
|
||||
|
||||
private final LargeScreenDataMapper largeScreenDataMapper; |
||||
|
||||
@Override |
||||
public List<CareerLineDataVO> getCareerLineData(Integer isDelivery) { |
||||
LargeScreenDataEntity largeScreenDataEntity = largeScreenDataMapper.selectOne(Wrappers.<LargeScreenDataEntity>lambdaQuery().orderByDesc(LargeScreenDataEntity::getCreateTime)); |
||||
|
||||
if (largeScreenDataEntity == null) { |
||||
return new ArrayList<>(); |
||||
} |
||||
|
||||
XxlJobQueryVO init = XxlJobQueryVO.init(largeScreenDataEntity.getData()); |
||||
|
||||
return isDelivery.equals(1) |
||||
? init.getCareerLineDeliveryData() |
||||
: init.getCareerLineData(); |
||||
} |
||||
} |
||||
@ -0,0 +1,38 @@
|
||||
package com.logpm.report.service.largeScreen.httpImpl; |
||||
|
||||
import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
||||
import com.logpm.report.entity.LargeScreenDataEntity; |
||||
import com.logpm.report.mapper.largeScreen.DeliveryDataMapper; |
||||
import com.logpm.report.mapper.largeScreen.LargeScreenDataMapper; |
||||
import com.logpm.report.service.largeScreen.IDeliveryDataService; |
||||
import com.logpm.report.vo.largeScreen.DeliveryDataVO; |
||||
import com.logpm.report.vo.largeScreen.XxlJobQueryVO; |
||||
import lombok.AllArgsConstructor; |
||||
import lombok.extern.log4j.Log4j2; |
||||
import org.springframework.stereotype.Service; |
||||
|
||||
import java.time.LocalDateTime; |
||||
import java.time.format.DateTimeFormatter; |
||||
|
||||
@AllArgsConstructor |
||||
@Service("deliveryDataServiceHttp") |
||||
@Log4j2 |
||||
public class DeliveryDataServiceImpl implements IDeliveryDataService { |
||||
|
||||
private final LargeScreenDataMapper largeScreenDataMapper; |
||||
|
||||
@Override |
||||
public DeliveryDataVO getDeliveryAllData(Integer isYear) { |
||||
LargeScreenDataEntity largeScreenDataEntity = largeScreenDataMapper.selectOne(Wrappers.<LargeScreenDataEntity>lambdaQuery().orderByDesc(LargeScreenDataEntity::getCreateTime)); |
||||
|
||||
if (largeScreenDataEntity == null) { |
||||
return new DeliveryDataVO(); |
||||
} |
||||
|
||||
XxlJobQueryVO init = XxlJobQueryVO.init(largeScreenDataEntity.getData()); |
||||
|
||||
return isYear.equals(1) |
||||
? init.getDeliveryYearData() |
||||
: init.getDeliveryData(); |
||||
} |
||||
} |
||||
@ -0,0 +1,42 @@
|
||||
package com.logpm.report.service.largeScreen.httpImpl; |
||||
|
||||
|
||||
import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
||||
import com.logpm.report.entity.LargeScreenDataEntity; |
||||
import com.logpm.report.mapper.largeScreen.LargeScreenDataMapper; |
||||
import com.logpm.report.mapper.largeScreen.MapWarehouseMapper; |
||||
import com.logpm.report.service.largeScreen.IMapWarehouseService; |
||||
import com.logpm.report.vo.largeScreen.MapWarehouse.LineInfoVO; |
||||
import com.logpm.report.vo.largeScreen.MapWarehouse.WarehouseInfoVO; |
||||
import com.logpm.report.vo.largeScreen.MapWarehouseVO; |
||||
import com.logpm.report.vo.largeScreen.XxlJobQueryVO; |
||||
import lombok.AllArgsConstructor; |
||||
import lombok.extern.slf4j.Slf4j; |
||||
import org.springframework.stereotype.Service; |
||||
|
||||
import java.time.LocalDateTime; |
||||
import java.time.format.DateTimeFormatter; |
||||
import java.util.ArrayList; |
||||
import java.util.List; |
||||
import java.util.Map; |
||||
import java.util.stream.Collectors; |
||||
|
||||
@AllArgsConstructor |
||||
@Service("mapWarehouseServiceHttp") |
||||
@Slf4j |
||||
public class MapWarehouseServiceImpl implements IMapWarehouseService { |
||||
|
||||
private final LargeScreenDataMapper largeScreenDataMapper; |
||||
|
||||
@Override |
||||
public List<MapWarehouseVO> list() { |
||||
LargeScreenDataEntity largeScreenDataEntity = largeScreenDataMapper.selectOne(Wrappers.<LargeScreenDataEntity>lambdaQuery().orderByDesc(LargeScreenDataEntity::getCreateTime)); |
||||
|
||||
if (largeScreenDataEntity == null) { |
||||
return new ArrayList<>(); |
||||
} |
||||
XxlJobQueryVO init = XxlJobQueryVO.init(largeScreenDataEntity.getData()); |
||||
|
||||
return init.getMapWarehouse(); |
||||
} |
||||
} |
||||
@ -0,0 +1,32 @@
|
||||
package com.logpm.report.service.largeScreen.httpImpl; |
||||
|
||||
import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
||||
import com.logpm.report.entity.LargeScreenDataEntity; |
||||
import com.logpm.report.mapper.largeScreen.LargeScreenDataMapper; |
||||
import com.logpm.report.service.largeScreen.INodeDataService; |
||||
import com.logpm.report.vo.largeScreen.NodeDataVO; |
||||
import com.logpm.report.vo.largeScreen.XxlJobQueryVO; |
||||
import lombok.AllArgsConstructor; |
||||
import lombok.extern.log4j.Log4j2; |
||||
import org.springframework.stereotype.Service; |
||||
|
||||
@AllArgsConstructor |
||||
@Log4j2 |
||||
@Service("nodeDataServiceHttp") |
||||
public class NodeDataServiceImpl implements INodeDataService { |
||||
|
||||
private final LargeScreenDataMapper largeScreenDataMapper; |
||||
|
||||
@Override |
||||
public NodeDataVO getNodeData() { |
||||
|
||||
LargeScreenDataEntity largeScreenDataEntity = largeScreenDataMapper.selectOne(Wrappers.<LargeScreenDataEntity>lambdaQuery().orderByDesc(LargeScreenDataEntity::getCreateTime)); |
||||
|
||||
if (largeScreenDataEntity == null) { |
||||
return new NodeDataVO(); |
||||
} |
||||
XxlJobQueryVO init = XxlJobQueryVO.init(largeScreenDataEntity.getData()); |
||||
|
||||
return init.getNodeData(); |
||||
} |
||||
} |
||||
@ -0,0 +1,37 @@
|
||||
package com.logpm.report.service.largeScreen.httpImpl; |
||||
|
||||
import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
||||
import com.logpm.report.entity.LargeScreenDataEntity; |
||||
import com.logpm.report.mapper.largeScreen.LargeScreenDataMapper; |
||||
import com.logpm.report.mapper.largeScreen.TrunkDataMapper; |
||||
import com.logpm.report.service.largeScreen.ITrunkDataService; |
||||
import com.logpm.report.vo.largeScreen.TrunkDataVO; |
||||
import com.logpm.report.vo.largeScreen.XxlJobQueryVO; |
||||
import lombok.AllArgsConstructor; |
||||
import lombok.extern.log4j.Log4j2; |
||||
import org.springframework.stereotype.Service; |
||||
|
||||
import java.time.LocalDateTime; |
||||
import java.time.format.DateTimeFormatter; |
||||
|
||||
|
||||
@AllArgsConstructor |
||||
@Service("trunkDataServiceHttp") |
||||
@Log4j2 |
||||
public class TrunkDataServiceImpl implements ITrunkDataService { |
||||
|
||||
private final LargeScreenDataMapper largeScreenDataMapper; |
||||
|
||||
@Override |
||||
public TrunkDataVO getTrunkData() { |
||||
LargeScreenDataEntity largeScreenDataEntity = largeScreenDataMapper.selectOne(Wrappers.<LargeScreenDataEntity>lambdaQuery().orderByDesc(LargeScreenDataEntity::getCreateTime)); |
||||
|
||||
if (largeScreenDataEntity == null) { |
||||
return new TrunkDataVO(); |
||||
} |
||||
|
||||
XxlJobQueryVO init = XxlJobQueryVO.init(largeScreenDataEntity.getData()); |
||||
|
||||
return init.getTrunkData(); |
||||
} |
||||
} |
||||
@ -0,0 +1,30 @@
|
||||
package com.logpm.report.service.largeScreen.impl; |
||||
|
||||
import com.logpm.report.mapper.largeScreen.BinLocationMapper; |
||||
import com.logpm.report.service.largeScreen.IBinLocationService; |
||||
import com.logpm.report.vo.largeScreen.BinLocationDataVO; |
||||
import lombok.AllArgsConstructor; |
||||
import lombok.extern.log4j.Log4j2; |
||||
import org.springframework.context.annotation.Primary; |
||||
import org.springframework.stereotype.Service; |
||||
|
||||
|
||||
@AllArgsConstructor |
||||
@Service |
||||
@Log4j2 |
||||
@Primary |
||||
public class BinLocationServiceImpl implements IBinLocationService { |
||||
private BinLocationMapper binLocationMapper; |
||||
|
||||
public BinLocationDataVO getBinLocationData() { |
||||
|
||||
BinLocationDataVO binLocationDataVO = new BinLocationDataVO(); |
||||
binLocationDataVO.setOrderNum(binLocationMapper.getOrderNum()); |
||||
binLocationDataVO.setPackageNum(binLocationMapper.getPackageNum()); |
||||
binLocationDataVO.setBinLocationNum(binLocationMapper.getBinLocationNum()); |
||||
binLocationDataVO.setUseBinLocationNum(binLocationMapper.getBinLocationNum() - binLocationMapper.getIdleBinLocationNum()); |
||||
binLocationDataVO.setIdleBinLocationNum(binLocationMapper.getIdleBinLocationNum()); |
||||
|
||||
return binLocationDataVO; |
||||
} |
||||
} |
||||
@ -0,0 +1,33 @@
|
||||
package com.logpm.report.service.largeScreen.impl; |
||||
|
||||
import com.logpm.report.mapper.largeScreen.BusinessRatioMapper; |
||||
import com.logpm.report.service.largeScreen.IBusinessRationService; |
||||
import com.logpm.report.vo.largeScreen.BusinessRatioDataVO; |
||||
import lombok.AllArgsConstructor; |
||||
import lombok.extern.log4j.Log4j2; |
||||
import org.springframework.context.annotation.Primary; |
||||
import org.springframework.stereotype.Service; |
||||
|
||||
import java.time.LocalDateTime; |
||||
import java.time.format.DateTimeFormatter; |
||||
|
||||
@AllArgsConstructor |
||||
@Service |
||||
@Log4j2 |
||||
@Primary |
||||
public class BusinessRationServiceImpl implements IBusinessRationService { |
||||
|
||||
private final BusinessRatioMapper businessRatioMapper; |
||||
|
||||
@Override |
||||
public BusinessRatioDataVO getBusinessRatioData() { |
||||
String startTime = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-01-01 00:00:00")); |
||||
String endTime = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-12-31 23:59:59")); |
||||
|
||||
BusinessRatioDataVO businessRatioDataVO = new BusinessRatioDataVO(); |
||||
businessRatioDataVO.setType(businessRatioMapper.getTypeData(startTime, endTime)); |
||||
businessRatioDataVO.setBrand(businessRatioMapper.getBrandData(startTime, endTime)); |
||||
|
||||
return businessRatioDataVO; |
||||
} |
||||
} |
||||
@ -0,0 +1,47 @@
|
||||
package com.logpm.report.service.largeScreen.impl; |
||||
|
||||
import com.logpm.report.mapper.largeScreen.DeliveryDataMapper; |
||||
import com.logpm.report.service.largeScreen.IDeliveryDataService; |
||||
import com.logpm.report.vo.largeScreen.DeliveryDataVO; |
||||
import lombok.AllArgsConstructor; |
||||
import lombok.extern.log4j.Log4j2; |
||||
import org.springframework.context.annotation.Primary; |
||||
import org.springframework.stereotype.Service; |
||||
|
||||
import java.time.LocalDateTime; |
||||
import java.time.format.DateTimeFormatter; |
||||
|
||||
@AllArgsConstructor |
||||
@Service |
||||
@Log4j2 |
||||
@Primary |
||||
public class DeliveryDataServiceImpl implements IDeliveryDataService { |
||||
|
||||
private final DeliveryDataMapper deliveryDataMapper; |
||||
|
||||
@Override |
||||
public DeliveryDataVO getDeliveryAllData(Integer isYear) { |
||||
|
||||
DeliveryDataVO deliveryDataVO = new DeliveryDataVO(); |
||||
String startTime = isYear.equals(1) ? LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-01-01 00:00:00")) : null; |
||||
String endTime = isYear.equals(1) ? LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-12-31 23:59:59")) : null; |
||||
|
||||
DeliveryDataVO deliveryAllData = deliveryDataMapper.getDeliveryAllData(startTime, endTime); |
||||
DeliveryDataVO delivery2CData = deliveryDataMapper.getDelivery2CData(startTime, endTime); |
||||
DeliveryDataVO delivery2BData = deliveryDataMapper.getDelivery2BData(startTime, endTime); |
||||
|
||||
deliveryDataVO.setTotal(deliveryAllData.getTotal()); |
||||
deliveryDataVO.setToBeSigned(deliveryAllData.getToBeSigned()); |
||||
deliveryDataVO.setSigned(deliveryAllData.getTotal() - deliveryAllData.getToBeSigned()); |
||||
|
||||
deliveryDataVO.setTotal2B(delivery2BData.getTotal2B()); |
||||
deliveryDataVO.setToBeSigned2B(delivery2BData.getToBeSigned2B()); |
||||
deliveryDataVO.setSigned2B(delivery2BData.getTotal2B() - delivery2BData.getToBeSigned2B()); |
||||
|
||||
deliveryDataVO.setTotal2C(delivery2CData.getTotal2C()); |
||||
deliveryDataVO.setToBeSigned2C(delivery2CData.getToBeSigned2C()); |
||||
deliveryDataVO.setSigned2C(delivery2CData.getTotal2C() - delivery2CData.getToBeSigned2C()); |
||||
|
||||
return deliveryDataVO; |
||||
} |
||||
} |
||||
@ -0,0 +1,37 @@
|
||||
package com.logpm.report.service.largeScreen.impl; |
||||
|
||||
import com.logpm.report.mapper.largeScreen.NodeDataMapper; |
||||
import com.logpm.report.service.largeScreen.INodeDataService; |
||||
import com.logpm.report.vo.largeScreen.NodeDataVO; |
||||
import lombok.AllArgsConstructor; |
||||
import lombok.extern.log4j.Log4j2; |
||||
import org.springframework.context.annotation.Primary; |
||||
import org.springframework.stereotype.Service; |
||||
|
||||
import java.time.LocalDateTime; |
||||
import java.time.format.DateTimeFormatter; |
||||
|
||||
@AllArgsConstructor |
||||
@Log4j2 |
||||
@Service |
||||
@Primary |
||||
public class NodeDataServiceImpl implements INodeDataService { |
||||
|
||||
private final NodeDataMapper nodeDataMapper; |
||||
|
||||
@Override |
||||
public NodeDataVO getNodeData() { |
||||
|
||||
String startTime = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-01-01 00:00:00")); |
||||
String endTime = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-12-31 23:59:59")); |
||||
|
||||
NodeDataVO nodeDataVO = new NodeDataVO(); |
||||
nodeDataVO.setWaybill(nodeDataMapper.getWaybill(startTime, endTime)); |
||||
nodeDataVO.setCarsLoadLoading(nodeDataMapper.getCarsLoadLoading(startTime, endTime)); |
||||
nodeDataVO.setDeliveryLading(nodeDataMapper.getDeliveryLading(startTime, endTime)); |
||||
nodeDataVO.setArrival(nodeDataMapper.getArrival(startTime, endTime)); |
||||
nodeDataVO.setSign(nodeDataMapper.getSign(startTime, endTime)); |
||||
|
||||
return nodeDataVO; |
||||
} |
||||
} |
||||
@ -0,0 +1,35 @@
|
||||
package com.logpm.report.service.largeScreen.impl; |
||||
|
||||
import com.logpm.report.mapper.largeScreen.TrunkDataMapper; |
||||
import com.logpm.report.service.largeScreen.ITrunkDataService; |
||||
import com.logpm.report.vo.largeScreen.TrunkDataVO; |
||||
import lombok.AllArgsConstructor; |
||||
import lombok.extern.log4j.Log4j2; |
||||
import org.springframework.context.annotation.Primary; |
||||
import org.springframework.stereotype.Service; |
||||
|
||||
import java.time.LocalDateTime; |
||||
import java.time.format.DateTimeFormatter; |
||||
|
||||
|
||||
@AllArgsConstructor |
||||
@Service |
||||
@Log4j2 |
||||
@Primary |
||||
public class TrunkDataServiceImpl implements ITrunkDataService { |
||||
|
||||
private final TrunkDataMapper trunkDataMapper; |
||||
|
||||
@Override |
||||
public TrunkDataVO getTrunkData() { |
||||
String startTime = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-01-01 00:00:00")); |
||||
String endTime = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-12-31 23:59:59")); |
||||
|
||||
TrunkDataVO trunkDataVO = new TrunkDataVO(); |
||||
trunkDataVO.setTotal(trunkDataMapper.getTotal(startTime, endTime)); |
||||
trunkDataVO.setOnTheWay(trunkDataMapper.getOnTheWay()); |
||||
trunkDataVO.setArrival(trunkDataMapper.getArrival(startTime, endTime)); |
||||
|
||||
return trunkDataVO; |
||||
} |
||||
} |
||||
@ -0,0 +1,11 @@
|
||||
package com.logpm.report.vo.largeScreen.BusinessRatio; |
||||
|
||||
|
||||
import lombok.Data; |
||||
|
||||
@Data |
||||
public class ItemDataVO { |
||||
private String name; |
||||
|
||||
private Integer value; |
||||
} |
||||
@ -0,0 +1,14 @@
|
||||
package com.logpm.report.vo.largeScreen; |
||||
|
||||
import com.logpm.report.vo.largeScreen.BusinessRatio.ItemDataVO; |
||||
import lombok.Data; |
||||
|
||||
import java.util.List; |
||||
|
||||
@Data |
||||
public class BusinessRatioDataVO { |
||||
|
||||
private List<ItemDataVO> type; |
||||
|
||||
private List<ItemDataVO> brand; |
||||
} |
||||
@ -0,0 +1,15 @@
|
||||
package com.logpm.report.vo.largeScreen.CareerLineData; |
||||
|
||||
|
||||
import lombok.Data; |
||||
|
||||
import java.util.List; |
||||
|
||||
@Data |
||||
public class VehicleStowageDataVO { |
||||
private Long warehouseId; |
||||
|
||||
private String createMonth; |
||||
|
||||
private Integer total; |
||||
} |
||||
@ -0,0 +1,17 @@
|
||||
package com.logpm.report.vo.largeScreen.CareerLineData; |
||||
|
||||
|
||||
import lombok.Data; |
||||
|
||||
@Data |
||||
public class VehicleStowageMonthDataVo { |
||||
|
||||
private String createMonth; |
||||
|
||||
private Integer total; |
||||
|
||||
public VehicleStowageMonthDataVo(String createMonth, Integer total){ |
||||
this.createMonth = createMonth; |
||||
this.total = total; |
||||
} |
||||
} |
||||
@ -0,0 +1,11 @@
|
||||
package com.logpm.report.vo.largeScreen.CareerLineData; |
||||
|
||||
|
||||
import lombok.Data; |
||||
|
||||
@Data |
||||
public class WarehouseDeptVO { |
||||
private Long dept; |
||||
|
||||
private Long warehouseId; |
||||
} |
||||
@ -1,7 +1,22 @@
|
||||
package com.logpm.report.vo.largeScreen; |
||||
|
||||
import com.logpm.report.vo.largeScreen.CareerLineData.VehicleStowageMonthDataVo; |
||||
import lombok.Data; |
||||
|
||||
import java.util.List; |
||||
|
||||
/** |
||||
* 事业线车辆配载数据 |
||||
*/ |
||||
@Data |
||||
public class CareerLineDataVO { |
||||
|
||||
private String careerLineName; |
||||
|
||||
private List<VehicleStowageMonthDataVo> monthData; |
||||
|
||||
public CareerLineDataVO(String careerLineName, List<VehicleStowageMonthDataVo> monthData) { |
||||
this.careerLineName = careerLineName; |
||||
this.monthData = monthData; |
||||
} |
||||
} |
||||
|
||||
@ -0,0 +1,66 @@
|
||||
package com.logpm.report.vo.largeScreen; |
||||
|
||||
import lombok.Data; |
||||
|
||||
import java.util.List; |
||||
import java.util.Map; |
||||
|
||||
@Data |
||||
public class XxlJobQueryVO { |
||||
List<MapWarehouseVO> mapWarehouse; |
||||
BillingDataVO billingData; |
||||
List<WarehouseBillingDataVO> warehouseBillingData; |
||||
List<MonthBillingDataVO> monthBillingData; |
||||
List<CareerLineDataVO> careerLineData; |
||||
List<CareerLineDataVO> careerLineDeliveryData; |
||||
NodeDataVO nodeData; |
||||
BinLocationDataVO binLocationData; |
||||
TrunkDataVO trunkData; |
||||
DeliveryDataVO deliveryData; |
||||
DeliveryDataVO deliveryYearData; |
||||
BusinessRatioDataVO businessRatio; |
||||
|
||||
public static XxlJobQueryVO init(Map<String, Object> data){ |
||||
XxlJobQueryVO xxlJobQueryVO = new XxlJobQueryVO(); |
||||
data.forEach((k,v) -> { |
||||
if (k.equals("mapWarehouse")) { |
||||
xxlJobQueryVO.setMapWarehouse((List<MapWarehouseVO>) v); |
||||
} |
||||
if (k.equals("billingData")) { |
||||
xxlJobQueryVO.setBillingData((BillingDataVO) v); |
||||
} |
||||
if (k.equals("warehouseBillingData")) { |
||||
xxlJobQueryVO.setWarehouseBillingData((List<WarehouseBillingDataVO>) v); |
||||
} |
||||
if (k.equals("monthBillingData")) { |
||||
xxlJobQueryVO.setMonthBillingData((List<MonthBillingDataVO>) v); |
||||
} |
||||
if (k.equals("careerLineData")) { |
||||
xxlJobQueryVO.setCareerLineData((List<CareerLineDataVO>) v); |
||||
} |
||||
if (k.equals("careerLineDeliveryData")) { |
||||
xxlJobQueryVO.setCareerLineDeliveryData((List<CareerLineDataVO>) v); |
||||
} |
||||
if (k.equals("nodeData")) { |
||||
xxlJobQueryVO.setNodeData((NodeDataVO) v); |
||||
} |
||||
if (k.equals("binLocationData")) { |
||||
xxlJobQueryVO.setBinLocationData((BinLocationDataVO) v); |
||||
} |
||||
if (k.equals("trunkData")) { |
||||
xxlJobQueryVO.setTrunkData((TrunkDataVO) v); |
||||
} |
||||
if (k.equals("deliveryData")) { |
||||
xxlJobQueryVO.setDeliveryData((DeliveryDataVO) v); |
||||
} |
||||
if (k.equals("deliveryYearData")) { |
||||
xxlJobQueryVO.setDeliveryYearData((DeliveryDataVO) v); |
||||
} |
||||
if (k.equals("businessRatio")) { |
||||
xxlJobQueryVO.setBusinessRatio((BusinessRatioDataVO) v); |
||||
} |
||||
}); |
||||
|
||||
return xxlJobQueryVO; |
||||
} |
||||
} |
||||
Loading…
Reference in new issue