package com.ld.igds.inout.service;
|
|
import com.bstek.bdf2.core.orm.jdbc.JdbcDao;
|
import com.ld.igds.constant.Constant;
|
import com.ld.igds.constant.DepotType;
|
import com.ld.igds.constant.FoodVariety;
|
import com.ld.igds.constant.TransType;
|
import com.ld.igds.inout.InoutConstant;
|
import com.ld.igds.inout.dto.*;
|
import com.ld.igds.models.Depot;
|
import com.ld.igds.util.ContextUtil;
|
import com.ld.igds.util.DateUtil;
|
import com.ld.igds.view.service.HDepotService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.StringUtils;
|
import org.apache.commons.lang3.time.DateUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.util.*;
|
|
/**
|
* @author vince
|
*/
|
@Slf4j
|
@Component(JInoutReportService.BEAN_ID)
|
public class JInoutReportService extends JdbcDao {
|
|
public static final String BEAN_ID = "jdbcInoutReportServiceImpl";
|
|
@Autowired
|
private HDepotService depotService;
|
|
public List<ReportInoutDepotData> getInoutDepotData(
|
Map<String, Object> parameter) {
|
// 时间条件必须
|
Date start = (Date) parameter.get("start");
|
Date end = (Date) parameter.get("end");
|
String deptId = (String) parameter.get("deptId");
|
|
if (start == null || end == null || StringUtils.isEmpty(deptId))
|
return null;
|
|
StringBuffer sql = new StringBuffer();
|
sql.append("SELECT ");
|
sql.append("d.ID_ AS depotId, ");
|
sql.append("d.NAME_ AS depotName, ");
|
sql.append("d.FOOD_TYPE_ AS foodType, ");
|
sql.append("d.FOOD_VARIETY_ AS foodVariety, ");
|
sql.append("0 as cqkc, ");
|
sql.append("d.STORAGE_REAL_ as qmkc, ");
|
sql.append("a.inNum, ");
|
sql.append("a.outNum, ");
|
sql.append("a.lossNum, ");
|
sql.append("a.overNum, ");
|
sql.append("( ");
|
sql.append("IFNULL(a.inNum, 0) + IFNULL(a.overNum, 0) ");
|
sql.append(") AS inSum, ");
|
sql.append("( ");
|
sql.append("IFNULL(a.outNum, 0) + IFNULL(a.lossNum, 0) ");
|
sql.append(") AS outSum ");
|
sql.append("FROM ");
|
sql.append("d_depot d ");
|
sql.append("LEFT JOIN ( ");
|
sql.append("SELECT ");
|
sql.append("a.DEPOT_ID_, ");
|
sql.append("SUM( ");
|
sql.append("IF ( ");
|
sql.append("a.TYPE_ = :typeIn, ");
|
sql.append("a.SETTLE_WEIGHT_, ");
|
sql.append("0 ");
|
sql.append(") ");
|
sql.append(") AS inNum, ");
|
sql.append("SUM( ");
|
sql.append("IF ( ");
|
sql.append("a.TYPE_ = :typeOut, ");
|
sql.append("a.SETTLE_WEIGHT_, ");
|
sql.append("0 ");
|
sql.append(") ");
|
sql.append(") AS outNum, ");
|
sql.append("SUM( ");
|
sql.append("IF ( ");
|
sql.append("a.TYPE_ = :typeLoss, ");
|
sql.append("a.SETTLE_WEIGHT_, ");
|
sql.append("0 ");
|
sql.append(") ");
|
sql.append(") AS lossNum, ");
|
sql.append("SUM( ");
|
sql.append("IF ( ");
|
sql.append("a.TYPE_ = :typeOver, ");
|
sql.append("a.SETTLE_WEIGHT_, ");
|
sql.append("0 ");
|
sql.append(") ");
|
sql.append(") AS overNum ");
|
sql.append("FROM ");
|
sql.append("( ");
|
sql.append("SELECT ");
|
sql.append("DEPOT_ID_, ");
|
sql.append("SETTLE_WEIGHT_, ");
|
sql.append("TYPE_, ");
|
sql.append("CUR_STORAGE_ ");
|
sql.append("FROM ");
|
sql.append("d_inout_record ");
|
sql.append("WHERE ");
|
sql.append("COMPANY_ID_ = :companyId ");
|
sql.append("AND PROGRESS_ = :progress ");
|
sql.append("AND RECORD_STATUS_ <> :recordStatusDel ");
|
sql.append("AND COMPLETE_TIME_ >= :start ");
|
sql.append("AND COMPLETE_TIME_ <= :end ");
|
sql.append("AND DEPT_ID_ = :deptId ");
|
sql.append(") a ");
|
sql.append("GROUP BY a.DEPOT_ID_ ");
|
sql.append(") a ON d.ID_ = a.DEPOT_ID_ ");
|
sql.append("WHERE d.COMPANY_ID_ = :companyId ");
|
sql.append("AND d.DEPOT_TYPE_ <> :depotTypeOther ");
|
sql.append("AND d.DEPT_ID_ = :deptId ");
|
sql.append("ORDER BY d.ID_");
|
|
Map<String, Object> args = new HashMap<>();
|
args.put("deptId", deptId);
|
args.put("companyId", ContextUtil.getCompanyId());
|
args.put("typeIn", InoutConstant.TYPE_IN);
|
args.put("typeOut", InoutConstant.TYPE_OUT);
|
args.put("typeLoss", Constant.LOSS_OVER_LOSS);
|
args.put("typeOver", Constant.LOSS_OVER_OVER);
|
args.put("progress", InoutConstant.PROGRESS_RECORD);
|
args.put("recordStatusDel", InoutConstant.RECORD_STATUS_DEL);
|
|
args.put("start", DateUtil.getCurZero(start));
|
args.put("end", DateUtil.getNextZero(end));
|
args.put("depotTypeOther", DepotType.TYPE_99.getCode());
|
|
log.debug("====执行SLQ1={}", sql.toString());
|
|
List<ReportInoutDepotData> data = this.getNamedParameterJdbcTemplate()
|
.query(sql.toString(), args, new ReportInoutDepotRowMapper());
|
|
if (null == data || data.isEmpty())
|
return data;
|
|
// 根据开始时间获取距离最近的车辆信息，获取初期库存
|
sql = new StringBuffer();
|
args = new HashMap<>();
|
sql.append("SELECT ");
|
sql.append("DEPOT_ID_, ");
|
sql.append("SETTLE_WEIGHT_, ");
|
sql.append("TYPE_, ");
|
sql.append("CUR_STORAGE_, ");
|
sql.append("FOOD_VARIETY_, ");
|
sql.append("COMPLETE_TIME_ ");
|
sql.append("FROM ");
|
sql.append("( ");
|
sql.append("SELECT ");
|
sql.append("DEPOT_ID_, ");
|
sql.append("SETTLE_WEIGHT_, ");
|
sql.append("TYPE_, ");
|
sql.append("CUR_STORAGE_, ");
|
sql.append("COMPANY_ID_, ");
|
sql.append("PROGRESS_, ");
|
sql.append("RECORD_STATUS_, ");
|
sql.append("DEPT_ID_, ");
|
sql.append("FOOD_VARIETY_, ");
|
sql.append("COMPLETE_TIME_ ");
|
sql.append("FROM ");
|
sql.append("d_inout_record ");
|
sql.append("WHERE ");
|
sql.append("COMPANY_ID_ =:companyId ");
|
sql.append("AND PROGRESS_ =:progress ");
|
sql.append("AND RECORD_STATUS_ <> :recordStatusDel ");
|
sql.append("AND DEPT_ID_ = :deptId ");
|
sql.append("AND COMPLETE_TIME_ < :start ");
|
sql.append("ORDER BY COMPLETE_TIME_ DESC ");
|
sql.append("LIMIT 9999 ");
|
sql.append(") AS a ");
|
sql.append("GROUP BY ");
|
sql.append("a.DEPOT_ID_ ");
|
|
args.put("deptId", deptId);
|
args.put("companyId", ContextUtil.getCompanyId());
|
args.put("progress", InoutConstant.PROGRESS_RECORD);
|
args.put("recordStatusDel", InoutConstant.RECORD_STATUS_DEL);
|
// 获取距离开始时间久最近的数据，当前天的第五分钟
|
Date date = DateUtil.getCurZero(start);
|
args.put("start", DateUtils.addMinutes(date, 5));
|
|
log.debug("====执行SLQ2={}", sql.toString());
|
List<ReportInoutStorageData> list1 = this
|
.getNamedParameterJdbcTemplate().query(sql.toString(), args,
|
new ReportInoutStorageRowMapper());
|
|
// 获取期末库存，获取距离结束时间最近的一条数据
|
sql = new StringBuffer();
|
args = new HashMap<>();
|
sql.append("SELECT ");
|
sql.append("DEPOT_ID_, ");
|
sql.append("SETTLE_WEIGHT_, ");
|
sql.append("TYPE_, ");
|
sql.append("CUR_STORAGE_, ");
|
sql.append("FOOD_VARIETY_, ");
|
sql.append("COMPLETE_TIME_ ");
|
sql.append("FROM ");
|
sql.append("( ");
|
sql.append("SELECT ");
|
sql.append("DEPOT_ID_, ");
|
sql.append("SETTLE_WEIGHT_, ");
|
sql.append("TYPE_, ");
|
sql.append("CUR_STORAGE_, ");
|
sql.append("COMPANY_ID_, ");
|
sql.append("PROGRESS_, ");
|
sql.append("RECORD_STATUS_, ");
|
sql.append("DEPT_ID_, ");
|
sql.append("FOOD_VARIETY_, ");
|
sql.append("COMPLETE_TIME_ ");
|
sql.append("FROM ");
|
sql.append("d_inout_record ");
|
sql.append("WHERE ");
|
sql.append("COMPANY_ID_ =:companyId ");
|
sql.append("AND PROGRESS_ =:progress ");
|
sql.append("AND RECORD_STATUS_ <> :recordStatusDel ");
|
sql.append("AND DEPT_ID_ = :deptId ");
|
sql.append("AND COMPLETE_TIME_ <:end ");
|
sql.append("ORDER BY COMPLETE_TIME_ DESC ");
|
sql.append("LIMIT 9999 ");
|
sql.append(") AS a ");
|
sql.append("GROUP BY ");
|
sql.append("a.DEPOT_ID_ ");
|
|
args.put("deptId", deptId);
|
args.put("companyId", ContextUtil.getCompanyId());
|
args.put("progress", InoutConstant.PROGRESS_RECORD);
|
args.put("recordStatusDel", InoutConstant.RECORD_STATUS_DEL);
|
args.put("end", DateUtil.getNextZero(end));
|
|
log.debug("====执行SLQ3={}", sql.toString());
|
|
List<ReportInoutStorageData> list2 = this
|
.getNamedParameterJdbcTemplate().query(sql.toString(), args,
|
new ReportInoutStorageRowMapper());
|
|
// 调整期末库存和初期库存以及合计信息
|
updateDepotReport(data, list1, list2);
|
|
return data;
|
}
|
|
private void updateDepotReport(List<ReportInoutDepotData> data,
|
List<ReportInoutStorageData> list1,
|
List<ReportInoutStorageData> list2) {
|
ReportInoutDepotData sum = new ReportInoutDepotData();
|
int index = 1;
|
for (ReportInoutDepotData d : data) {
|
// 设置序号
|
d.setRemarks(String.valueOf(index));
|
// 当前数据添加初期库存
|
d = this.updateDepotReportCqkc(d, list1);
|
// d = this.updateDepotReportQmkc(d, list2);
|
|
// 合计信息
|
sum.setCqkc(sum.getCqkc() + d.getCqkc());
|
sum.setInNum(sum.getInNum() + d.getInNum());
|
sum.setOverNum(sum.getOverNum() + d.getOverNum());
|
sum.setInSum(sum.getInSum() + d.getInSum());
|
sum.setOutNum(sum.getOutNum() + d.getOutNum());
|
sum.setLossNum(sum.getLossNum() + d.getLossNum());
|
sum.setOutSum(sum.getOutSum() + d.getOutSum());
|
sum.setQmkc(sum.getQmkc() + d.getQmkc());
|
index++;
|
}
|
sum.setDepotName("合计");
|
data.add(sum);
|
}
|
|
// 注意：如果期末库存没有临近数据，则表示获取最新的库存
|
public ReportInoutDepotData updateDepotReportQmkc(ReportInoutDepotData d,
|
List<ReportInoutStorageData> list2) {
|
ReportInoutStorageData inoutStorageData = null;
|
for (ReportInoutStorageData storageData : list2) {
|
if (storageData.getDepotId().equals(d.getDepotId())) {
|
inoutStorageData = storageData;
|
break;
|
}
|
}
|
if (null == inoutStorageData) {
|
Depot depot = depotService.getDepotById(ContextUtil.getCompanyId(),
|
d.getDepotId());
|
d.setQmkc(null == depot.getStorageReal() ? 0.0 : depot
|
.getStorageReal());
|
return d;
|
}
|
|
double cmkc = inoutStorageData.getCurStorage();
|
if (InoutConstant.TYPE_IN.equals(inoutStorageData.getType())) {
|
cmkc = inoutStorageData.getCurStorage()
|
+ inoutStorageData.getSettleWeight();
|
}
|
if (InoutConstant.TYPE_OUT.equals(inoutStorageData.getType())) {
|
cmkc = inoutStorageData.getCurStorage()
|
- inoutStorageData.getSettleWeight();
|
}
|
if (Constant.LOSS_OVER_OVER.equals(inoutStorageData.getType())) {
|
cmkc = inoutStorageData.getCurStorage()
|
+ inoutStorageData.getSettleWeight();
|
}
|
if (Constant.LOSS_OVER_LOSS.equals(inoutStorageData.getType())) {
|
cmkc = inoutStorageData.getCurStorage()
|
- inoutStorageData.getSettleWeight();
|
}
|
d.setQmkc(cmkc);
|
|
return d;
|
}
|
|
private ReportInoutDepotData updateDepotReportCqkc(ReportInoutDepotData d,
|
List<ReportInoutStorageData> list1) {
|
ReportInoutStorageData inoutStorageData = null;
|
for (ReportInoutStorageData storageData : list1) {
|
if (storageData.getDepotId().equals(d.getDepotId())) {
|
inoutStorageData = storageData;
|
break;
|
}
|
}
|
if (null == inoutStorageData) {
|
d.setCqkc(0.0);
|
return d;
|
}
|
|
double cqkc = inoutStorageData.getCurStorage();
|
if (InoutConstant.TYPE_IN.equals(inoutStorageData.getType())) {
|
cqkc = inoutStorageData.getCurStorage()
|
+ inoutStorageData.getSettleWeight();
|
}
|
|
if (InoutConstant.TYPE_OUT.equals(inoutStorageData.getType())) {
|
cqkc = inoutStorageData.getCurStorage()
|
- inoutStorageData.getSettleWeight();
|
}
|
|
if (Constant.LOSS_OVER_OVER.equals(inoutStorageData.getType())) {
|
cqkc = inoutStorageData.getCurStorage()
|
+ inoutStorageData.getSettleWeight();
|
}
|
|
if (Constant.LOSS_OVER_LOSS.equals(inoutStorageData.getType())) {
|
cqkc = inoutStorageData.getCurStorage()
|
- inoutStorageData.getSettleWeight();
|
}
|
d.setCqkc(cqkc);
|
if (StringUtils.isEmpty(d.getFoodVarietyName()) && d.getCqkc() > 0) {
|
d.setFoodVarietyName(FoodVariety.getMsg(inoutStorageData
|
.getFoodVariety()));
|
d.setFoodVariety(inoutStorageData.getFoodVariety());
|
}
|
return d;
|
}
|
|
public List<ReportInoutDepotData> getFoodVarietyData(
|
Map<String, Object> parameter) {
|
|
// 时间条件必须
|
Date start = (Date) parameter.get("start");
|
Date end = (Date) parameter.get("end");
|
String deptId = (String) parameter.get("deptId");
|
|
if (start == null || end == null)
|
return null;
|
|
StringBuffer sql = new StringBuffer();
|
sql.append("SELECT ");
|
sql.append("'NONE' as foodType, ");
|
sql.append("0 as cqkc, ");
|
sql.append("0 as qmkc, ");
|
sql.append("0 as inSum, ");
|
sql.append("0 as outSum, ");
|
sql.append("a.FOOD_VARIETY_ as foodVariety, ");
|
sql.append("SUM( ");
|
sql.append("IF ( ");
|
sql.append("a.TYPE_ =:typeIn, ");
|
sql.append("a.SETTLE_WEIGHT_, ");
|
sql.append("0 ");
|
sql.append(") ");
|
sql.append(") AS inNum, ");
|
sql.append("SUM( ");
|
sql.append("IF ( ");
|
sql.append("a.TYPE_ =:typeOut, ");
|
sql.append("a.SETTLE_WEIGHT_, ");
|
sql.append("0 ");
|
sql.append(") ");
|
sql.append(") AS outNum, ");
|
sql.append("SUM( ");
|
sql.append("IF ( ");
|
sql.append("a.TYPE_ =:typeLoss, ");
|
sql.append("a.SETTLE_WEIGHT_, ");
|
sql.append("0 ");
|
sql.append(") ");
|
sql.append(") AS lossNum, ");
|
sql.append("SUM( ");
|
sql.append("IF ( ");
|
sql.append("a.TYPE_ =:typeOver, ");
|
sql.append("a.SETTLE_WEIGHT_, ");
|
sql.append("0 ");
|
sql.append(") ");
|
sql.append(") AS overNum ");
|
sql.append("FROM ");
|
sql.append("( ");
|
sql.append("SELECT ");
|
sql.append("FOOD_VARIETY_, ");
|
sql.append("SETTLE_WEIGHT_, ");
|
sql.append("TYPE_, ");
|
sql.append("CUR_STORAGE_ ");
|
sql.append("FROM ");
|
sql.append("d_inout_record ");
|
sql.append("WHERE ");
|
sql.append("COMPANY_ID_ =:companyId ");
|
sql.append("AND PROGRESS_ =:progress ");
|
sql.append("AND RECORD_STATUS_ <> :recordStatusDel ");
|
sql.append("AND COMPLETE_TIME_ >= :start ");
|
sql.append("AND COMPLETE_TIME_ <= :end ");
|
sql.append("AND DEPT_ID_ = :deptId ");
|
sql.append("ORDER BY COMPLETE_TIME_ DESC ");
|
sql.append(") a ");
|
sql.append("GROUP BY a.FOOD_VARIETY_ ");
|
|
Map<String, Object> args = new HashMap<>();
|
args.put("deptId", deptId);
|
args.put("companyId", ContextUtil.getCompanyId());
|
args.put("typeIn", InoutConstant.TYPE_IN);
|
args.put("typeOut", InoutConstant.TYPE_OUT);
|
args.put("typeLoss", Constant.LOSS_OVER_LOSS);
|
args.put("typeOver", Constant.LOSS_OVER_OVER);
|
args.put("progress", InoutConstant.PROGRESS_RECORD);
|
args.put("recordStatusDel", InoutConstant.RECORD_STATUS_DEL);
|
args.put("start", DateUtil.getCurZero(start));
|
args.put("end", DateUtil.getNextZero(end));
|
|
log.debug("====执行SLQ1={}，参数={}", sql.toString(), args);
|
|
List<ReportInoutDepotData> data = this.getNamedParameterJdbcTemplate()
|
.query(sql.toString(), args, new ReportFoodVarietyRowMapper());
|
|
|
// 根据开始时间获取距离最近的车辆信息，获取初期库存
|
sql = new StringBuffer();
|
args = new HashMap<>();
|
sql.append("SELECT ");
|
sql.append("DEPOT_ID_, ");
|
sql.append("SETTLE_WEIGHT_, ");
|
sql.append("TYPE_, ");
|
sql.append("CUR_STORAGE_, ");
|
sql.append("FOOD_VARIETY_, ");
|
sql.append("COMPLETE_TIME_ ");
|
sql.append("FROM ");
|
sql.append("( ");
|
sql.append("SELECT ");
|
sql.append("DEPOT_ID_, ");
|
sql.append("SETTLE_WEIGHT_, ");
|
sql.append("TYPE_, ");
|
sql.append("CUR_STORAGE_, ");
|
sql.append("COMPANY_ID_, ");
|
sql.append("PROGRESS_, ");
|
sql.append("RECORD_STATUS_, ");
|
sql.append("DEPT_ID_, ");
|
sql.append("FOOD_VARIETY_, ");
|
sql.append("COMPLETE_TIME_ ");
|
sql.append("FROM ");
|
sql.append("d_inout_record ");
|
sql.append("WHERE ");
|
sql.append("COMPANY_ID_ =:companyId ");
|
sql.append("AND PROGRESS_ =:progress ");
|
sql.append("AND RECORD_STATUS_ <> :recordStatusDel ");
|
sql.append("AND DEPT_ID_ = :deptId ");
|
sql.append("AND COMPLETE_TIME_ < :start ");
|
sql.append("ORDER BY COMPLETE_TIME_ DESC ");
|
sql.append("LIMIT 9999 ");
|
sql.append(") AS a ");
|
sql.append("GROUP BY ");
|
sql.append("a.DEPOT_ID_ ");
|
|
args.put("deptId", deptId);
|
args.put("companyId", ContextUtil.getCompanyId());
|
args.put("progress", InoutConstant.PROGRESS_RECORD);
|
args.put("recordStatusDel", InoutConstant.RECORD_STATUS_DEL);
|
// 获取距离开始时间久最近的数据，当前天的第五分钟
|
Date date = DateUtil.getCurZero(start);
|
args.put("start", DateUtils.addMinutes(date, 5));
|
|
log.debug("====执行SLQ2={}", sql.toString());
|
|
List<ReportInoutStorageData> list1 = this
|
.getNamedParameterJdbcTemplate().query(sql.toString(), args,
|
new ReportInoutStorageRowMapper());
|
|
// 获取期末库存，获取距离结束时间最近的一条数据
|
sql = new StringBuffer();
|
args = new HashMap<>();
|
sql.append("SELECT ");
|
sql.append("DEPOT_ID_, ");
|
sql.append("SETTLE_WEIGHT_, ");
|
sql.append("TYPE_, ");
|
sql.append("CUR_STORAGE_, ");
|
sql.append("FOOD_VARIETY_, ");
|
sql.append("COMPLETE_TIME_ ");
|
sql.append("FROM ");
|
sql.append("( ");
|
sql.append("SELECT ");
|
sql.append("DEPOT_ID_, ");
|
sql.append("SETTLE_WEIGHT_, ");
|
sql.append("TYPE_, ");
|
sql.append("CUR_STORAGE_, ");
|
sql.append("COMPANY_ID_, ");
|
sql.append("PROGRESS_, ");
|
sql.append("RECORD_STATUS_, ");
|
sql.append("DEPT_ID_, ");
|
sql.append("FOOD_VARIETY_, ");
|
sql.append("COMPLETE_TIME_ ");
|
sql.append("FROM ");
|
sql.append("d_inout_record ");
|
sql.append("WHERE ");
|
sql.append("COMPANY_ID_ =:companyId ");
|
sql.append("AND PROGRESS_ =:progress ");
|
sql.append("AND RECORD_STATUS_ <> :recordStatusDel ");
|
sql.append("AND DEPT_ID_ = :deptId ");
|
sql.append("AND COMPLETE_TIME_ < :end ");
|
sql.append("ORDER BY COMPLETE_TIME_ DESC ");
|
sql.append("LIMIT 9999 ");
|
sql.append(") AS a ");
|
sql.append("GROUP BY ");
|
sql.append("a.DEPOT_ID_ ");
|
|
args.put("deptId", deptId);
|
args.put("companyId", ContextUtil.getCompanyId());
|
args.put("progress", InoutConstant.PROGRESS_RECORD);
|
args.put("recordStatusDel", InoutConstant.RECORD_STATUS_DEL);
|
args.put("end", DateUtil.getNextZero(end));
|
|
log.debug("====执行SLQ3={}", sql.toString());
|
|
List<ReportInoutStorageData> list2 = this
|
.getNamedParameterJdbcTemplate().query(sql.toString(), args,
|
new ReportInoutStorageRowMapper());
|
|
return updateFoodVarietySum(data, list1, list2);
|
|
}
|
|
@SuppressWarnings("unused")
|
private List<ReportInoutDepotData> updateFoodVarietySum(
|
List<ReportInoutDepotData> datas,
|
List<ReportInoutStorageData> list1,
|
List<ReportInoutStorageData> list2) {
|
|
// 调整初期库存
|
Map<String, Double> map1 = new HashMap<>();
|
if (null != list1) {
|
for (ReportInoutStorageData data : list1) {
|
if (null == map1.get(data.getFoodVariety())) {
|
map1.put(data.getFoodVariety(), 0.0);
|
}
|
double cqkc = data.getCurStorage();
|
if (InoutConstant.TYPE_IN.equals(data.getType())) {
|
cqkc = data.getCurStorage() + data.getSettleWeight();
|
}
|
if (InoutConstant.TYPE_OUT.equals(data.getType())) {
|
cqkc = data.getCurStorage() - data.getSettleWeight();
|
}
|
if (Constant.LOSS_OVER_OVER.equals(data.getType())) {
|
cqkc = data.getCurStorage() + data.getSettleWeight();
|
}
|
if (Constant.LOSS_OVER_LOSS.equals(data.getType())) {
|
cqkc = data.getCurStorage() - data.getSettleWeight();
|
}
|
map1.put(data.getFoodVariety(), map1.get(data.getFoodVariety())
|
+ cqkc);
|
}
|
}
|
|
// 调整期末库存
|
Map<String, Double> map2 = new HashMap<String, Double>();
|
if (null != list2) {
|
Depot depot = null;
|
for (ReportInoutStorageData data : list2) {
|
if (null == map2.get(data.getFoodVariety())) {
|
map2.put(data.getFoodVariety(), 0.0);
|
}
|
double cmkc = data.getCurStorage();
|
if (InoutConstant.TYPE_IN.equals(data.getType())) {
|
cmkc = data.getCurStorage() + data.getSettleWeight();
|
}
|
if (InoutConstant.TYPE_OUT.equals(data.getType())) {
|
cmkc = data.getCurStorage() - data.getSettleWeight();
|
}
|
if (Constant.LOSS_OVER_OVER.equals(data.getType())) {
|
cmkc = data.getCurStorage() + data.getSettleWeight();
|
}
|
if (Constant.LOSS_OVER_LOSS.equals(data.getType())) {
|
cmkc = data.getCurStorage() - data.getSettleWeight();
|
}
|
map2.put(data.getFoodVariety(), map2.get(data.getFoodVariety())
|
+ cmkc);
|
}
|
}
|
|
//判断初期库存粮食种类数是否跟出入库粮食种类数相等
|
if (datas.size() != map1.size()) {
|
ReportInoutDepotData report;
|
for (String s : map1.keySet()) {
|
boolean flag = true;
|
for (ReportInoutDepotData data : datas) {
|
if (StringUtils.isNotEmpty(data.getFoodVariety()) && data.getFoodVariety().equals(s)) {
|
flag = false;
|
break;
|
}
|
}
|
if (flag) {
|
report = new ReportInoutDepotData();
|
report.setFoodType("NONE");
|
report.setFoodVariety(s);
|
report.setFoodVarietyName(FoodVariety.getMsg(s));
|
datas.add(report);
|
}
|
}
|
}
|
|
if (null == datas || datas.isEmpty()) {
|
return datas;
|
}
|
|
ReportInoutDepotData sum = new ReportInoutDepotData();
|
sum.setFoodVarietyName("合计");
|
int index = 1;
|
for (ReportInoutDepotData data : datas) {
|
if (StringUtils.isNotEmpty(data.getFoodVariety())) {
|
// 设置序号
|
data.setRemarks(String.valueOf(index));
|
index++;
|
data.setOutSum(data.getOutNum() + data.getLossNum());
|
data.setInSum(data.getInNum() + data.getOverNum());
|
|
// 调整期末库存和期初库存
|
data.setCqkc(map1.get(data.getFoodVariety()) == null ? 0.0 : map1.get(data.getFoodVariety()));
|
data.setQmkc(map2.get(data.getFoodVariety()) == null ? 0.0 : map2.get(data.getFoodVariety()));
|
|
// 初期库存
|
sum.setCqkc(sum.getCqkc() + data.getCqkc());
|
// 期末库存
|
sum.setQmkc(sum.getQmkc() + data.getQmkc());
|
sum.setInNum(sum.getInNum() + data.getInNum());
|
sum.setOutNum(sum.getOutNum() + data.getOutNum());
|
sum.setInSum(sum.getInSum() + data.getInSum());
|
sum.setOutSum(sum.getOutSum() + data.getOutSum());
|
sum.setLossNum(sum.getLossNum() + data.getLossNum());
|
sum.setOverNum(sum.getOverNum() + data.getOverNum());
|
}
|
}
|
datas.add(sum);
|
|
return datas;
|
}
|
|
public List<ReportInoutShipData> listShipDetail(Map<String, Object> parameter) {
|
|
// 时间条件必须
|
Date start = (Date) parameter.get("start");
|
Date end = (Date) parameter.get("end");
|
if (start == null || end == null) {
|
return null;
|
}
|
|
StringBuffer sql = new StringBuffer();
|
sql.append("SELECT ");
|
sql.append("ID_, ");
|
sql.append("PLATE_NUM_, ");
|
sql.append("CUSTOMER_ID_, ");
|
sql.append("CUSTOMER_NAME_, ");
|
sql.append("FOOD_VARIETY_, ");
|
sql.append("DEPOT_ID_, ");
|
sql.append("TYPE_, ");
|
sql.append("PROGRESS_, ");
|
sql.append("FULL_WEIGHT_, ");
|
sql.append("EMPTY_WEIGHT_, ");
|
sql.append("NET_WEIGHT_, ");
|
sql.append("DE_SUM_, ");
|
sql.append("SETTLE_WEIGHT_, ");
|
sql.append("COMPLETE_TIME_ ");
|
sql.append("FROM ");
|
sql.append("d_inout_record ");
|
sql.append("WHERE ");
|
sql.append("TRANS_TYPE_ =:transType ");
|
sql.append("AND RECORD_STATUS_ <> :recordStatusDel ");
|
sql.append("AND TYPE_ <> :typeNone ");
|
sql.append("AND TYPE_ <> :typeLoss ");
|
sql.append("AND TYPE_ <> :typeOver ");
|
sql.append("AND COMPANY_ID_ =:companyId ");
|
sql.append("AND REGISTER_TIME_ >= :start ");
|
sql.append("AND REGISTER_TIME_ <= :end ");
|
|
Map<String, Object> args = new HashMap<>();
|
args.put("transType", TransType.TYPE_3.getCode());
|
args.put("recordStatusDel", InoutConstant.RECORD_STATUS_DEL);
|
args.put("typeNone", InoutConstant.TYPE_NONE);
|
args.put("typeLoss", Constant.LOSS_OVER_LOSS);
|
args.put("typeOver", Constant.LOSS_OVER_OVER);
|
args.put("companyId", ContextUtil.getCompanyId());
|
args.put("start", DateUtil.getCurZero(start));
|
args.put("end", DateUtil.getNextZero(end));
|
|
String str = (String) parameter.get("deptId");
|
if (StringUtils.isNotEmpty(str)) {
|
sql.append("AND DEPT_ID_ =:deptId ");
|
args.put("deptId", str);
|
}
|
str = (String) parameter.get("type");
|
if (StringUtils.isNotEmpty(str)) {
|
sql.append("AND TYPE_ =:type ");
|
args.put("type", str);
|
}
|
str = (String) parameter.get("customerId");
|
if (StringUtils.isNotEmpty(str)) {
|
sql.append("AND CUSTOMER_ID_ =:customerId ");
|
args.put("customerId", str);
|
}
|
str = (String) parameter.get("plateNum");
|
if (StringUtils.isNotEmpty(str)) {
|
sql.append("AND PLATE_NUM_ like:plateNum ");
|
args.put("plateNum", "%" + str + "%");
|
}
|
sql.append("ORDER BY ID_ DESC ");
|
|
log.debug("====执行SLQ，查询流水主表信息={}，参数={}", sql.toString(), args);
|
|
List<ReportInoutShipData> list1 = this.getNamedParameterJdbcTemplate().query(sql.toString(), args, new ReportInoutShipRowMapper1());
|
|
if (null == list1 || list1.isEmpty()) {
|
return null;
|
}
|
String depotId = (String) parameter.get("depotId");
|
String carNum = (String) parameter.get("carNum");
|
List<ReportInoutShipData> list = new ArrayList<>();
|
List<ReportInoutShipData> list2;
|
int index = 1;
|
//合计信息
|
ReportInoutShipData hj = new ReportInoutShipData();
|
hj.setId("合计");
|
for (ReportInoutShipData shipData : list1) {
|
list2 = this.listShipRecordItem(shipData.getId(), depotId, carNum);
|
if (null == list2 || list2.isEmpty()) {
|
continue;
|
}
|
if (!InoutConstant.PROGRESS_RECORD.equals(shipData.getProgress())) {
|
//流程未完成，统计重量信息
|
for (ReportInoutShipData shipItem : list2) {
|
shipData.setFullWeight(shipData.getFullWeight() + shipItem.getFullWeight());
|
shipData.setEmptyWeight(shipData.getEmptyWeight() + shipItem.getEmptyWeight());
|
shipData.setNetWeight(shipData.getNetWeight() + shipItem.getNetWeight());
|
shipData.setDeSum(shipData.getDeSum() + shipItem.getDeSum());
|
shipData.setSettleWeight(shipData.getSettleWeight() + shipItem.getSettleWeight());
|
}
|
}
|
|
list.addAll(list2);
|
shipData.setIndex(index + "");
|
list.add(shipData);
|
index++;
|
|
//统计合计信息
|
hj.setFullWeight(hj.getFullWeight() + shipData.getFullWeight());
|
hj.setEmptyWeight(hj.getEmptyWeight() + shipData.getEmptyWeight());
|
hj.setNetWeight(hj.getNetWeight() + shipData.getNetWeight());
|
hj.setDeSum(hj.getDeSum() + shipData.getDeSum());
|
hj.setSettleWeight(hj.getSettleWeight() + shipData.getSettleWeight());
|
}
|
list.add(hj);
|
return list;
|
}
|
|
public List<ReportInoutShipData> listShipRecordItem(String recordId, String depotId, String carNum) {
|
|
if (StringUtils.isEmpty(recordId)) {
|
return null;
|
}
|
|
StringBuffer sql = new StringBuffer();
|
sql.append("SELECT ");
|
sql.append("DEPOT_ID_, ");
|
sql.append("CAR_NUM_, ");
|
sql.append("CAR_NAME_, ");
|
sql.append("TYPE_, ");
|
sql.append("PROGRESS_, ");
|
sql.append("FULL_WEIGHT_, ");
|
sql.append("EMPTY_WEIGHT_, ");
|
sql.append("NET_WEIGHT_, ");
|
sql.append("DE_, ");
|
sql.append("SETTLE_WEIGHT_, ");
|
sql.append("CREATE_TIME_ AS COMPLETE_TIME_ ");
|
sql.append("FROM ");
|
sql.append("d_inout_record_item ");
|
sql.append("WHERE RECORD_STATUS_ <> :recordStatusDel ");
|
sql.append("AND PROGRESS_ =:progressRecord ");
|
Map<String, Object> args = new HashMap<>();
|
args.put("recordStatusDel", InoutConstant.RECORD_STATUS_DEL);
|
args.put("progressRecord", InoutConstant.PROGRESS_RECORD);
|
if (StringUtils.isNotEmpty(recordId)) {
|
sql.append("AND RECORD_ID_ =:recordId ");
|
args.put("recordId", recordId);
|
}
|
if (StringUtils.isNotEmpty(depotId)) {
|
sql.append("AND DEPOT_ID_ =:depotId ");
|
args.put("depotId", depotId);
|
}
|
if (StringUtils.isNotEmpty(carNum)) {
|
sql.append("AND CAR_NUM_ like:carNum ");
|
args.put("carNum", "%" + carNum + "%");
|
}
|
sql.append("ORDER BY CREATE_TIME_ ASC ");
|
log.debug("====执行SLQ1={}，参数={}", sql.toString(), args);
|
|
List<ReportInoutShipData> data = this.getNamedParameterJdbcTemplate()
|
.query(sql.toString(), args, new ReportInoutShipRowMapper2());
|
|
return data;
|
}
|
}
|
