|
@@ -2,6 +2,7 @@ package com.ruoyi.web.v2.v1.service.impl;
|
|
|
|
|
|
|
|
import cn.hutool.core.util.ObjectUtil;
|
|
import cn.hutool.core.util.ObjectUtil;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
|
|
+import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
import com.ruoyi.app.model.EntranceBatch;
|
|
import com.ruoyi.app.model.EntranceBatch;
|
|
@@ -24,6 +25,7 @@ import org.springframework.stereotype.Service;
|
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
|
|
|
|
|
import java.nio.ByteBuffer;
|
|
import java.nio.ByteBuffer;
|
|
|
|
|
+import java.time.LocalDate;
|
|
|
import java.time.format.DateTimeFormatter;
|
|
import java.time.format.DateTimeFormatter;
|
|
|
import java.util.*;
|
|
import java.util.*;
|
|
|
import java.util.stream.Collectors;
|
|
import java.util.stream.Collectors;
|
|
@@ -89,7 +91,8 @@ public class JsDistributionServiceImpl extends ServiceImpl<JsDistributionMapper,
|
|
|
String[] seriesNoGroup = distribution.getSeriesNoGroup().split(",");
|
|
String[] seriesNoGroup = distribution.getSeriesNoGroup().split(",");
|
|
|
List<JsDivideCircle> circles = circleMapper.selectList(
|
|
List<JsDivideCircle> circles = circleMapper.selectList(
|
|
|
Wrappers.<JsDivideCircle>lambdaQuery().in(JsDivideCircle::getSeriesNo, seriesNoGroup));
|
|
Wrappers.<JsDivideCircle>lambdaQuery().in(JsDivideCircle::getSeriesNo, seriesNoGroup));
|
|
|
- return circles.size() > 0 ? distribution.getSeriesNoGroup() : "";
|
|
|
|
|
|
|
+ String result = seriesNoGroup == null ? "" : Arrays.stream(seriesNoGroup).distinct().collect(Collectors.joining(","));
|
|
|
|
|
+ return circles.size() > 0 ? result : "";
|
|
|
}else {
|
|
}else {
|
|
|
//如果提交的表单未带有分圈的批次序列号,那么根据入场id或者检疫证号查分圈批次序列号集,进行设置
|
|
//如果提交的表单未带有分圈的批次序列号,那么根据入场id或者检疫证号查分圈批次序列号集,进行设置
|
|
|
if(ObjectUtil.isNotEmpty(distribution.getEntranceBatchId())) {
|
|
if(ObjectUtil.isNotEmpty(distribution.getEntranceBatchId())) {
|
|
@@ -104,7 +107,7 @@ public class JsDistributionServiceImpl extends ServiceImpl<JsDistributionMapper,
|
|
|
return circles.stream().map(
|
|
return circles.stream().map(
|
|
|
item -> entranceBatch.getAnimalCertNo() +
|
|
item -> entranceBatch.getAnimalCertNo() +
|
|
|
item.getPigpenId() +
|
|
item.getPigpenId() +
|
|
|
- entranceBatch.getEntranceTime().format(DateTimeFormatter.ofPattern("yyyyMMdd")))
|
|
|
|
|
|
|
+ entranceBatch.getEntranceTime().format(DateTimeFormatter.ofPattern("yyyyMMdd"))).distinct()
|
|
|
.collect(Collectors.joining(","));
|
|
.collect(Collectors.joining(","));
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
@@ -160,12 +163,12 @@ public class JsDistributionServiceImpl extends ServiceImpl<JsDistributionMapper,
|
|
|
public PaginationUtil.PageResult<JsProduction> productionPage(Integer pageNum, Integer pageSize, String startTime, String endTime, String animalCertNo) {
|
|
public PaginationUtil.PageResult<JsProduction> productionPage(Integer pageNum, Integer pageSize, String startTime, String endTime, String animalCertNo) {
|
|
|
QueryWrapper<JsDistribution> queryWrapper = new QueryWrapper<>();
|
|
QueryWrapper<JsDistribution> queryWrapper = new QueryWrapper<>();
|
|
|
queryWrapper.eq(StringUtils.isNotEmpty(animalCertNo), "animal_cert_no", animalCertNo)
|
|
queryWrapper.eq(StringUtils.isNotEmpty(animalCertNo), "animal_cert_no", animalCertNo)
|
|
|
- .groupBy("supplier_name,purchaser_name,DATE(distribution_time)")
|
|
|
|
|
|
|
+ .groupBy("supplier_name,purchaser_name,animal_cert_no, DATE(distribution_time)")
|
|
|
.orderByDesc("distribution_time");
|
|
.orderByDesc("distribution_time");
|
|
|
if ("".equals(startTime) || null == startTime) {
|
|
if ("".equals(startTime) || null == startTime) {
|
|
|
|
|
|
|
|
} else {
|
|
} else {
|
|
|
- queryWrapper.between("distribution_time", startTime + " 00:00:00", endTime + " 23:59:59");
|
|
|
|
|
|
|
+ queryWrapper.between("distribution_time", LocalDate.parse(startTime), LocalDate.parse(endTime));
|
|
|
}
|
|
}
|
|
|
queryWrapper.orderByDesc("distribution_time");
|
|
queryWrapper.orderByDesc("distribution_time");
|
|
|
List<JsDistribution> jsDistributions = distributionMapper.selectList(queryWrapper);
|
|
List<JsDistribution> jsDistributions = distributionMapper.selectList(queryWrapper);
|
|
@@ -206,17 +209,23 @@ public class JsDistributionServiceImpl extends ServiceImpl<JsDistributionMapper,
|
|
|
@Override
|
|
@Override
|
|
|
public AjaxResult editProduce(JsProduceCode jsProduceCode) {
|
|
public AjaxResult editProduce(JsProduceCode jsProduceCode) {
|
|
|
QueryWrapper<JsProduceCode> queryWrapper1 = new QueryWrapper<>();
|
|
QueryWrapper<JsProduceCode> queryWrapper1 = new QueryWrapper<>();
|
|
|
- queryWrapper1.eq("purchaser_name",jsProduceCode.getPurchaserName()).eq("supplier_name",jsProduceCode.getSupplierName());
|
|
|
|
|
|
|
+ //queryWrapper1.eq("purchaser_name",jsProduceCode.getPurchaserName()).eq("supplier_name",jsProduceCode.getSupplierName());
|
|
|
|
|
+ //将查询条件由供应商名称和肉商名称调整为one_code
|
|
|
|
|
+ queryWrapper1.eq("one_code", jsProduceCode.getOneCode());
|
|
|
List<JsProduceCode> jsProduceCodes = produceCodeMapper.selectList(queryWrapper1);
|
|
List<JsProduceCode> jsProduceCodes = produceCodeMapper.selectList(queryWrapper1);
|
|
|
for (JsProduceCode produceCode : jsProduceCodes) {
|
|
for (JsProduceCode produceCode : jsProduceCodes) {
|
|
|
- if ("".equals(produceCode.getAnimalCert()) || null == produceCode.getAnimalCert()) {
|
|
|
|
|
-
|
|
|
|
|
- } else {
|
|
|
|
|
- produceCode.setAnimalCert(jsProduceCode.getAnimalCert());
|
|
|
|
|
- produceCode.setMeatCert(jsProduceCode.getMeatCert());
|
|
|
|
|
- produceCodeMapper.updateById(produceCode);
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
|
|
+// if ("".equals(produceCode.getAnimalCert()) || null == produceCode.getAnimalCert()) {
|
|
|
|
|
+//
|
|
|
|
|
+// } else {
|
|
|
|
|
+// produceCode.setAnimalCert(jsProduceCode.getAnimalCert());
|
|
|
|
|
+// produceCode.setMeatCert(jsProduceCode.getMeatCert());
|
|
|
|
|
+// produceCodeMapper.updateById(produceCode);
|
|
|
|
|
+// }
|
|
|
|
|
+ UpdateWrapper<JsProduceCode> updateWrapper = new UpdateWrapper<>();
|
|
|
|
|
+ updateWrapper.eq("one_code", jsProduceCode.getOneCode())
|
|
|
|
|
+ .set("animal_cert", jsProduceCode.getAnimalCert())
|
|
|
|
|
+ .set("meat_cert", jsProduceCode.getMeatCert());
|
|
|
|
|
+ produceCodeMapper.update(null, updateWrapper);
|
|
|
}
|
|
}
|
|
|
return success();
|
|
return success();
|
|
|
}
|
|
}
|