package com.fzzy.igds.timer;
|
|
import com.fzzy.igds.constant.Constant;
|
import com.fzzy.igds.data.IgdsBaseParam;
|
import com.fzzy.igds.domain.*;
|
import com.fzzy.igds.service.*;
|
import com.fzzy.igds.utils.ContextUtil;
|
import com.fzzy.igds.utils.DateUtil;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.time.DateFormatUtils;
|
import org.apache.commons.lang3.time.DateUtils;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import java.text.ParseException;
|
import java.time.LocalDate;
|
import java.util.*;
|
|
/**
|
* @Description 库存定时统计入口：通过框架定时任务调用，默认每天凌晨1点执行，统计昨天的库存信息
|
* @Author CZT
|
* @Date 2026/1/14 10:42
|
*/
|
@Slf4j
|
@Service
|
public class JobDepotStoreService {
|
|
@Resource
|
private CoreDeptService deptService;
|
@Resource
|
private InoutRecordService inoutRecordService;
|
@Resource
|
private InoutStockChangeService stockChangeService;
|
@Resource
|
private InoutLossOverService lossOverService;
|
@Resource
|
private DepotStoreService depotStoreService;
|
@Resource
|
private DepotService depotService;
|
|
@Scheduled(cron = "0 0 1 * * ?")
|
public void timer() {
|
doExe();
|
}
|
|
|
/**
|
* 手动执行库存统计
|
* @param timeStr
|
* @throws ParseException
|
*/
|
public void doExeHand(String timeStr) throws ParseException {
|
|
log.info("===============手动统计库存信息===============");
|
//获取所有的库区信息
|
List<Dept> listDept = deptService.listDept(null, ContextUtil.getCompanyId(), null);
|
if (null == listDept || listDept.isEmpty()) {
|
log.info("-----未获取到库区，不执行库存定时统计-----");
|
return;
|
}
|
|
Date startTime = DateUtils.parseDate(timeStr, "yyyy-MM-dd");
|
|
Date endTime = new Date();
|
for (Dept dept : listDept) {
|
|
//多天循环统计
|
sumMoreDepotStore(startTime, endTime, dept);
|
}
|
}
|
|
/**
|
* 开始执行库存统计
|
*/
|
public void doExe() {
|
|
Date time = DateUtil.getNewByDay(new Date(), -1);
|
log.info("===============系统定时统计库存信息===============");
|
//获取所有的库区信息
|
List<Dept> listDept = deptService.listDept(null, ContextUtil.getCompanyId(), null);
|
|
if (null == listDept || listDept.isEmpty()) {
|
log.info("-----未获取到库区，不执行库存定时统计-----");
|
return;
|
}
|
|
Date startTime = null; //出入库最早时间
|
for (Dept dept : listDept) {
|
|
startTime = getStartTime(time, dept);
|
if (null == startTime) {
|
log.info("-----{}在{}未有库存相关数量更新，不执行库存统计-----", dept.getKqmc(), DateFormatUtils.format(time, "yyyy-MM-dd"));
|
continue;
|
}
|
|
//多天循环统计
|
sumMoreDepotStore(startTime, time, dept);
|
}
|
}
|
|
/**
|
* 多天循环遍历统计库存信息
|
*
|
* @param startTime
|
* @param endTime
|
* @param dept
|
*/
|
public void sumMoreDepotStore(Date startTime, Date endTime, Dept dept) {
|
|
log.info("-----统计库存信息，库区={}，时间={}--->{}-----", dept.getKqmc(), DateFormatUtils.format(startTime, "yyyy-MM-dd"), DateFormatUtils.format(endTime, "yyyy-MM-dd"));
|
|
//获取两个时间相差的天数
|
LocalDate startDate = LocalDate.parse(DateFormatUtils.format(startTime, "yyyy-MM-dd"));
|
LocalDate endDate = LocalDate.parse(DateFormatUtils.format(endTime, "yyyy-MM-dd"));
|
|
//从最早天开始循环统计库存到当前天
|
while (!startDate.isAfter(endDate)) {
|
|
//统计库区库存
|
sumDepotStore(startTime, dept);
|
//对应时间加1天
|
startTime = DateUtils.addDays(startTime, 1);
|
//将日期加1天
|
startDate = startDate.plusDays(1);
|
}
|
|
}
|
|
/**
|
* 根据时间，统计更新当天的库存信息
|
*
|
* @param time
|
* @param dept
|
*/
|
public void sumDepotStore(Date time, Dept dept) {
|
//更改为当天的23点50分
|
time = DateUtils.addMinutes(DateUtil.getNextZero(time), -10);
|
|
log.info("-----统计库存信息，库区={}，时间={}-----", dept.getKqmc(), DateFormatUtils.format(time, "yyyy-MM-dd"));
|
//设置参数
|
IgdsBaseParam param = new IgdsBaseParam();
|
param.setStart(DateUtil.getCurZero(time));
|
param.setEnd(DateUtil.getNextZero(time));
|
param.setDeptId(dept.getId());
|
|
//用于存放数量变动的仓库
|
Set<String> set = new HashSet<>();
|
|
//统计仓库的数量
|
Map<String, Double> map1 = new HashMap<>();
|
Map<String, Double> map2 = new HashMap<>();
|
Map<String, Double> map3 = new HashMap<>();
|
|
boolean inTag = false;
|
boolean outTag = false;
|
//获取出入库信息统计仓库数量
|
List<InoutRecord> inoutRecords = inoutRecordService.getCompleteInoutByTime("complete_time", param);
|
if (null != inoutRecords && !inoutRecords.isEmpty()) {
|
for (InoutRecord inoutRecord : inoutRecords) {
|
set.add(inoutRecord.getDepotId());
|
|
map1.putIfAbsent(inoutRecord.getDepotId(), 0.0);
|
|
//统计数量
|
if (Constant.TYPE_IN.equals(inoutRecord.getType())) {
|
inTag = true;
|
map1.put(inoutRecord.getDepotId(), map1.get(inoutRecord.getDepotId()) + inoutRecord.getRecordWeight());
|
}
|
if (Constant.TYPE_OUT.equals(inoutRecord.getType())) {
|
outTag = true;
|
map1.put(inoutRecord.getDepotId(), map1.get(inoutRecord.getDepotId()) - inoutRecord.getRecordWeight());
|
}
|
}
|
}
|
|
//获取倒仓信息统计仓库数量
|
List<InoutStockChange> stockChanges = stockChangeService.getDataByTime("change_date", param);
|
if (null != stockChanges && !stockChanges.isEmpty()) {
|
for (InoutStockChange stockChange : stockChanges) {
|
set.add(stockChange.getDepotIdIn());
|
set.add(stockChange.getDepotIdOut());
|
|
map2.putIfAbsent(stockChange.getDepotIdIn(), 0.0);
|
map2.putIfAbsent(stockChange.getDepotIdOut(), 0.0);
|
|
//统计数量
|
map2.put(stockChange.getDepotIdIn(), map2.get(stockChange.getDepotIdIn()) + stockChange.getNumber());
|
map2.put(stockChange.getDepotIdOut(), map2.get(stockChange.getDepotIdOut()) - stockChange.getNumber());
|
}
|
}
|
|
//获取损益信息统计仓库数量
|
List<InoutLossOver> lossOvers = lossOverService.getDataByTime("loss_time", param);
|
if (null != lossOvers && !lossOvers.isEmpty()) {
|
for (InoutLossOver lossOver : lossOvers) {
|
set.add(lossOver.getDepotId());
|
|
map3.putIfAbsent(lossOver.getDepotId(), 0.0);
|
|
//统计数量
|
if (Constant.TYPE_LOSS.equals(lossOver.getType())) {
|
map1.put(lossOver.getDepotId(), map1.get(lossOver.getDepotId()) - lossOver.getAmount());
|
}
|
if (Constant.TYPE_OVER.equals(lossOver.getType())) {
|
map1.put(lossOver.getDepotId(), map1.get(lossOver.getDepotId()) + lossOver.getAmount());
|
}
|
}
|
}
|
|
Double sum = 0.0;
|
Depot depot;
|
for (String s : set) {
|
sum = 0.0;
|
if (null != map1.get(s)) {
|
sum += map1.get(s);
|
}
|
if (null != map2.get(s)) {
|
sum += map2.get(s);
|
}
|
if (null != map3.get(s)) {
|
sum += map3.get(s);
|
}
|
|
//获取上一条数据
|
DepotStore lastData = depotStoreService.getLastData(s, time);
|
|
if (null == lastData) {
|
lastData = new DepotStore();
|
|
lastData.setStorageReal(0.0);
|
|
if (inTag) {
|
//设置入库时间
|
lastData.setStoreDate(time);
|
}
|
if (outTag) {
|
//设置出库时间
|
lastData.setOutDate(time);
|
}
|
}
|
|
//主键ID规则：yyyyMMddHHmm_仓库编码
|
lastData.setId(DateFormatUtils.format(time, "yyyyMMddHHmm") + "_" + s);
|
|
lastData.setCompanyId(dept.getCompanyId());
|
lastData.setDeptId(dept.getId());
|
lastData.setDepotId(s);
|
|
lastData.setUpdateTime(time);
|
lastData.setUpdateBy("系统定时统计");
|
|
//获取仓库信息
|
depot = depotService.getCacheDepot(dept.getCompanyId(), s);
|
if (null != depot) {
|
lastData.setDepotStatus(depot.getDepotStatus());
|
lastData.setFoodVariety(depot.getFoodVariety());
|
lastData.setFoodLevel(depot.getFoodLevel());
|
lastData.setFoodLocation(depot.getFoodLocation());
|
lastData.setFoodLocationId(depot.getFoodLocationId());
|
lastData.setFoodType(depot.getFoodType());
|
lastData.setFoodYear(depot.getFoodYear());
|
}
|
|
lastData.setStorageReal(lastData.getStorageReal() + sum);
|
lastData.setCreateTime(new Date()); //设置为最新时间，其他系统可以通过此时间查询数据是否有更新修改，同步到省平台接口。
|
lastData.setCreateBy("系统定时统计");
|
lastData.setRemark("系统统计" + DateFormatUtils.format(time, "yyyy-MM-dd") + "日库存");
|
|
depotStoreService.updateAndSave(lastData);
|
|
}
|
|
}
|
|
|
/**
|
* 根据时间，统计更新当天的库存信息
|
*
|
* @param dept
|
*/
|
public Date getStartTime(Date time, Dept dept) {
|
|
Date startTime = time; //出入库最早时间
|
Date time1 = null; //出入库最早时间
|
Date time2 = null; //倒仓最早时间
|
Date time3 = null; //损益最早时间
|
|
//获取当天有更新的出入库信息
|
IgdsBaseParam param = new IgdsBaseParam();
|
param.setStart(DateUtil.getCurZero(time));
|
param.setEnd(DateUtil.getNextZero(time));
|
//获取当天有更新的出入库信息
|
param.setDeptId(dept.getId());
|
List<InoutRecord> inoutRecords = inoutRecordService.getCompleteInoutByTime("update_time", param);
|
if (null != inoutRecords && !inoutRecords.isEmpty()) {
|
time1 = inoutRecords.get(0).getCompleteTime();
|
}
|
|
//获取当天有更新的倒仓数据
|
List<InoutStockChange> stockChanges = stockChangeService.getDataByTime("update_time", param);
|
if (null != stockChanges && !stockChanges.isEmpty()) {
|
time2 = stockChanges.get(0).getChangeDate();
|
}
|
|
//获取当天有更新的损益数据
|
List<InoutLossOver> lossOvers = lossOverService.getDataByTime("update_time", param);
|
if (null != lossOvers && !lossOvers.isEmpty()) {
|
time3 = lossOvers.get(0).getLossTime();
|
}
|
|
if (null == time1 && null == time2 && null == time3) {
|
return null;
|
}
|
if (null != time1 && time1.before(startTime)) {
|
startTime = time1;
|
}
|
if (null != time2 && time2.before(startTime)) {
|
startTime = time2;
|
}
|
if (null != time3 && time3.before(startTime)) {
|
startTime = time3;
|
}
|
return startTime;
|
}
|
|
}
|
