From 981a3d85848753a799da2d909089c2fe4fcd3ccf Mon Sep 17 00:00:00 2001
From: zhongrj <123456>
Date: Mon, 18 Jul 2022 14:53:15 +0800
Subject: [PATCH] 农产品库存，操作人列表查询修改，溯源码详情查询修改，
---
src/main/java/org/springblade/modules/traceability/service/impl/TraceabilityServiceImpl.java | 197 +++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 197 insertions(+), 0 deletions(-)
diff --git a/src/main/java/org/springblade/modules/traceability/service/impl/TraceabilityServiceImpl.java b/src/main/java/org/springblade/modules/traceability/service/impl/TraceabilityServiceImpl.java
index 1cef9ad..b1ada12 100644
--- a/src/main/java/org/springblade/modules/traceability/service/impl/TraceabilityServiceImpl.java
+++ b/src/main/java/org/springblade/modules/traceability/service/impl/TraceabilityServiceImpl.java
@@ -1,12 +1,41 @@
package org.springblade.modules.traceability.service.impl;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.google.zxing.WriterException;
+import org.springblade.common.config.TraceabilityCodeConfig;
+import org.springblade.common.utils.QRCodeUtil;
+import org.springblade.modules.farm.entity.Farm;
+import org.springblade.modules.farm.entity.FarmPaper;
+import org.springblade.modules.farm.entity.FarmingRecord;
+import org.springblade.modules.farm.service.FarmPaperService;
+import org.springblade.modules.farm.service.FarmService;
+import org.springblade.modules.farm.service.FarmingRecordService;
+import org.springblade.modules.farm.vo.FarmPaperVO;
+import org.springblade.modules.farm.vo.FarmVO;
+import org.springblade.modules.farm.vo.FarmingRecordVO;
+import org.springblade.modules.lang.entity.Land;
+import org.springblade.modules.lang.service.ILandService;
+import org.springblade.modules.lang.vo.LandVO;
+import org.springblade.modules.recovery.service.RecoveryService;
+import org.springblade.modules.recovery.vo.RecoveryVO;
+import org.springblade.modules.traceability.dto.TraceabilityDTO;
+import org.springblade.modules.traceability.dto.TraceabilityDetailDTO;
+import org.springblade.modules.traceability.entity.SweepRecord;
import org.springblade.modules.traceability.entity.Traceability;
import org.springblade.modules.traceability.mapper.TraceabilityMapper;
+import org.springblade.modules.traceability.service.SweepRecordService;
import org.springblade.modules.traceability.service.TraceabilityService;
import org.springblade.modules.traceability.vo.TraceabilityVO;
+import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
+import sun.misc.BASE64Encoder;
+import javax.sound.midi.Receiver;
+import java.io.IOException;
+import java.io.UnsupportedEncodingException;
+import java.net.URLEncoder;
+import java.util.Date;
import java.util.List;
/**
@@ -16,6 +45,24 @@
*/
@Service
public class TraceabilityServiceImpl extends ServiceImpl<TraceabilityMapper, Traceability> implements TraceabilityService {
+
+ @Autowired
+ private RecoveryService recoveryService;
+
+ @Autowired
+ private FarmingRecordService farmingRecordService;
+
+ @Autowired
+ private FarmService farmService;
+
+ @Autowired
+ private FarmPaperService farmPaperService;
+
+ @Autowired
+ private ILandService landService;
+
+ @Autowired
+ private SweepRecordService sweepRecordService;
/**
* 自定义分页
@@ -28,4 +75,154 @@
public IPage<TraceabilityVO> selectTraceabilityPage(IPage<TraceabilityVO> page, TraceabilityVO traceability) {
return page.setRecords(baseMapper.selectTraceabilityPage(page, traceability));
}
+
+ @Override
+ public String selectRevorid(String code) {
+ return baseMapper.selectRevorid(code);
+ }
+
+ /**
+ * 获取溯源简介信息
+ * @param traceability
+ * @return
+ */
+ @Override
+ public TraceabilityDTO getSimpleInfo(Traceability traceability) {
+ TraceabilityDTO simpleInfo = baseMapper.getSimpleInfo(traceability);
+ simpleInfo.setCode(traceability.getCode());
+ //获取二维码信息
+ String url = TraceabilityCodeConfig.getCodeUrl();
+ String encoded = null;
+ try {
+ encoded = URLEncoder.encode(traceability.getCode(),"UTF-8");
+ } catch (UnsupportedEncodingException e) {
+ e.printStackTrace();
+ }
+ String content = url + "?code=" + encoded;
+ byte[] qrCodeImage = new byte[0];
+ try {
+ qrCodeImage = QRCodeUtil.getQRCodeImage(content, 350, 350);
+ } catch (WriterException e) {
+ e.printStackTrace();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ String encode = new BASE64Encoder().encode(qrCodeImage);
+ simpleInfo.setQrcode("data:image/png;base64,"+encode);
+ //返回
+ return simpleInfo;
+ }
+
+ /**
+ * 获取溯源详情信息（包含农产品信息，认证检测信息，产地（地块信息），农事记录，企业信息）
+ * @param traceability
+ * @return
+ */
+ @Override
+ public TraceabilityDetailDTO getTraceabilityDetailInfo(Traceability traceability) {
+
+ TraceabilityDetailDTO dto = new TraceabilityDetailDTO();
+ int count = 0;
+ //根据溯源码编号查询溯源信息
+ Traceability traceability1 = baseMapper.selectOne(new QueryWrapper<>(traceability));
+ //记录扫描记录
+ if (null!=traceability.getBind() && traceability.equals("0")){
+ //插入扫描记录
+ SweepRecord sweepRecord = new SweepRecord();
+ sweepRecord.setCreateTime(new Date());
+ sweepRecord.setCode(traceability1.getId().toString());
+ sweepRecord.setDeptId(traceability1.getDeptId());
+ //新增
+ sweepRecordService.save(sweepRecord);
+ }
+ //1. 查询农产品采收记录信息
+ RecoveryVO recoveryVO = recoveryService.getRecoveryDetail(traceability1.getRecoveryId());
+ //2. 查询相关检测信息
+ List<FarmPaperVO> farmPaperList = farmPaperService.getFarmPaperList(traceability1.getDeptId());
+ //3. 查询产地（地块）信息
+ LandVO land = new LandVO();
+ land.setId(Long.parseLong(recoveryVO.getLandId()));
+ LandVO landInfo = (LandVO)landService.getLandInfo(land);
+ //4. 查询农事记录信息(种植开始起)
+ List<FarmingRecordVO> farmingRecordVOList = farmingRecordService.getFarmingRecordByFarmPlantId(recoveryVO);
+ //5. 查询农场信息
+ Farm farm = farmService.getById(recoveryVO.getFarmId());
+ //6. 数据封装
+ dto.setRecoveryVO(recoveryVO);
+ dto.setFarm(farm);
+ dto.setRecordVOList(farmingRecordVOList);
+ dto.setPaperVOList(farmPaperList);
+ dto.setLandVO(landInfo);
+ //计算百分比
+ if (null!=recoveryVO){
+ count = count + 20;
+ }
+ if (null!=farm){
+ count = count + 20;
+ }
+ if (null==landInfo){
+ count = count + 20;
+ }
+ if (farmingRecordVOList.size()>0){
+ count = count + 20;
+ }
+ if (farmPaperList.size()>0){
+ count = count + 20;
+ }
+ dto.setNum(count);
+ //返回数据
+ return dto;
+ }
+
+ /**
+ * 自定义查询，不分页
+ * @param traceability
+ * @return
+ */
+ @Override
+ public List<TraceabilityVO> getTraceabilityList(TraceabilityVO traceability) {
+ return baseMapper.getTraceabilityList(traceability);
+ }
+
+ /**
+ * 获取溯源详情信息（包含农产品信息，认证检测信息，产地（地块信息），农事记录，企业信息）扫码
+ * @param traceability
+ * @return
+ */
+ @Override
+ public TraceabilityDetailDTO getTraceabilityDetailInfos(Traceability traceability) {
+ TraceabilityDetailDTO dto = new TraceabilityDetailDTO();
+ int count = 0;
+ //根据溯源码编号查询溯源信息
+ Traceability traceability1 = baseMapper.selectOne(new QueryWrapper<>(traceability));
+ //记录扫描记录
+ SweepRecord sweepRecord = new SweepRecord();
+ sweepRecord.setCreateTime(new Date());
+ sweepRecord.setCode(traceability1.getId().toString());
+ sweepRecord.setDeptId(traceability1.getDeptId());
+ //新增
+ sweepRecordService.save(sweepRecord);
+ //1. 查询农产品采收记录信息
+ RecoveryVO recoveryVO = recoveryService.getRecoveryDetail(traceability1.getRecoveryId());
+ //2. 查询相关检测信息
+ List<FarmPaperVO> farmPaperList = farmPaperService.getFarmPaperList(traceability1.getDeptId());
+ //3. 查询产地（地块）信息
+ LandVO land = new LandVO();
+ land.setId(Long.parseLong(recoveryVO.getLandId()));
+ LandVO landInfo = (LandVO)landService.getLandInfo(land);
+ //4. 查询农事记录信息(种植开始起)
+ List<FarmingRecordVO> farmingRecordVOList = farmingRecordService.getFarmingRecordByFarmPlantId(recoveryVO);
+ //5. 查询企业信息
+ Farm farm = new Farm();
+ farm.setDeptId(traceability1.getDeptId());
+ Farm farmVO = farmService.getOne(new QueryWrapper<>(farm));
+ //6. 数据封装
+ dto.setRecoveryVO(recoveryVO);
+ dto.setFarm(farmVO);
+ dto.setRecordVOList(farmingRecordVOList);
+ dto.setPaperVOList(farmPaperList);
+ dto.setLandVO(landInfo);
+ //返回
+ return dto;
+ }
}
--
Gitblit v1.9.3