From 72b971c98c46531064d74b68fc8fe8864ed0b544 Mon Sep 17 00:00:00 2001
From: guoshilong <123456>
Date: Tue, 08 Nov 2022 09:04:56 +0800
Subject: [PATCH] 大屏溯源统计次数sql修改

---
 src/main/java/org/springblade/modules/farmplant/controller/FarmPlantController.java |  254 ++++++++++++++++++++++++++++++++++++++++++++++----
 1 files changed, 233 insertions(+), 21 deletions(-)

diff --git a/src/main/java/org/springblade/modules/farmplant/controller/FarmPlantController.java b/src/main/java/org/springblade/modules/farmplant/controller/FarmPlantController.java
index bfc863e..3dd4c46 100644
--- a/src/main/java/org/springblade/modules/farmplant/controller/FarmPlantController.java
+++ b/src/main/java/org/springblade/modules/farmplant/controller/FarmPlantController.java
@@ -19,26 +19,40 @@
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiImplicitParams;
 import io.swagger.annotations.ApiOperation;
 import io.swagger.annotations.ApiParam;
 import lombok.AllArgsConstructor;
 import org.springblade.core.boot.ctrl.BladeController;
 import org.springblade.core.mp.support.Condition;
 import org.springblade.core.mp.support.Query;
+import org.springblade.core.secure.BladeUser;
+import org.springblade.core.secure.annotation.PreAuth;
 import org.springblade.core.tool.api.R;
+import org.springblade.core.tool.constant.BladeConstant;
+import org.springblade.core.tool.constant.RoleConstant;
 import org.springblade.core.tool.utils.Func;
+import org.springblade.core.tool.utils.StringUtil;
 import org.springblade.modules.farm.entity.FarmingRecord;
 import org.springblade.modules.farm.service.FarmingRecordService;
 import org.springblade.modules.farmplant.entity.FarmPlant;
+import org.springblade.modules.farmplant.entity.Strain;
 import org.springblade.modules.farmplant.service.FarmPlantService;
+import org.springblade.modules.farmplant.service.StrainService;
 import org.springblade.modules.farmplant.vo.FarmPlantVO;
 import org.springblade.modules.farmplant.vo.StrainVO;
 import org.springblade.modules.lang.entity.Land;
 import org.springblade.modules.lang.service.ILandService;
+import org.springblade.modules.system.entity.User;
+import org.springblade.modules.system.vo.UserVO;
+import org.springblade.modules.system.wrapper.UserWrapper;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.bind.annotation.*;
+import springfox.documentation.annotations.ApiIgnore;
 
 import javax.validation.Valid;
+import java.math.BigDecimal;
 import java.text.DecimalFormat;
 import java.text.SimpleDateFormat;
 import java.util.*;
@@ -61,6 +75,8 @@
 
 
 	private final ILandService landService;
+
+	private final StrainService strainService;
 
 	/**
 	 * 详情
@@ -96,6 +112,89 @@
 	}
 
 	/**
+	 *首页当前种养产品总和
+	 */
+	@GetMapping("/strainCount")
+	@ApiOperationSupport(order = 3)
+	@ApiOperation(value = "分页", notes = "传入farmPlant")
+	public R<IPage<FarmPlantVO>> strainCount(FarmPlantVO farmPlant, Query query) {
+		IPage<FarmPlantVO> pages = farmplantService.selectFarmPlantPageCount(Condition.getPage(query), farmPlant);
+		return R.data(pages);
+	}
+
+	/**
+	 * 首页秧苗产品总和
+	 */
+	@GetMapping("/strainCountYM")
+	public R<IPage<FarmPlantVO>> strainCountYM(FarmPlantVO farmPlant, Query query) {
+		IPage<FarmPlantVO> pages = farmplantService.selectFarmPlantPageCountYM(Condition.getPage(query), farmPlant);
+		return R.data(pages);
+	}
+
+
+
+	/**
+	 * 查询种养记录列表(不分页)
+	 * @param farmPlant
+	 * @return
+	 */
+	@GetMapping("/getFarmPlantList")
+	public R getFarmPlantList(FarmPlantVO farmPlant) {
+		return R.data(farmplantService.getFarmPlantList(farmPlant));
+	}
+
+	/**
+	 * 查询种养记录列表(秧苗)(不分页)
+	 * @param farmPlant
+	 * @return
+	 */
+	@GetMapping("/getFarmPlantYMList")
+	public R getFarmPlantYMList(FarmPlantVO farmPlant) {
+		return R.data(farmplantService.getFarmPlantYMList(farmPlant));
+	}
+
+
+	/**
+	 * 分页统计
+	 */
+	@GetMapping("/pageCount")
+	@ApiOperationSupport(order = 3)
+	@ApiOperation(value = "分页", notes = "传入farmPlant")
+	public R<List<FarmPlantVO>> pageCount(FarmPlantVO farmPlant, Query query) {
+		IPage<FarmPlantVO> pages = farmplantService.selectFarmPlantPage(Condition.getPage(query), farmPlant);
+		List<FarmPlantVO> res = pages.getRecords();
+		List<FarmPlantVO> count = new ArrayList<>();
+		//按种类合并种植物
+		for (int i = 0; i < res.size(); i++) {
+			if (i == 0){
+				count.add(res.get(0));
+			}else {
+				boolean type = false;
+				for (int j = 0; j < count.size(); j++) {
+					if (res.get(i).getStrainId().equals(count.get(j).getStrainId())){
+						FarmPlantVO data = new FarmPlantVO();
+						data.setStrainId(res.get(i).getStrainId());
+						BigDecimal b1 = new BigDecimal(res.get(i).getArea());
+						BigDecimal b2 = new BigDecimal(count.get(j).getArea());
+						data.setArea(b1.add(b2).doubleValue()+"");
+						data.setStrainName(res.get(i).getStrainName());
+						count.set(j,data);
+						type = false;
+						break;
+					}else{
+						type = true;
+					}
+				}
+				if (type){
+					count.add(res.get(i));
+				}
+			}
+		}
+
+		return R.data(count);
+	}
+
+	/**
 	 * 新增
 	 */
 	@PostMapping("/save")
@@ -105,11 +204,15 @@
 		farmPlant.setCreateTime(new Date());
 		boolean save = farmplantService.save(farmPlant);
 		if (save) {
+			Strain strain = strainService.getById(farmPlant.getStrainId());
 			//同时生成农事记录
 			FarmingRecord record = new FarmingRecord();
 			record.setCreateTime(new Date());
 			record.setJobWay(farmPlant.getJobWay());
 			record.setTime(farmPlant.getTransplanTime());
+			record.setDeptId(farmPlant.getDeptId());
+			record.setTenantId(farmPlant.getTenantId());
+			record.setStrainId(farmPlant.getStrainId());
 			if (farmPlant.getPlantingWay().equals("0")) {
 				//移栽
 				record.setType("10");
@@ -118,9 +221,17 @@
 				//直播
 				record.setType("11");
 			}
+			if(farmPlant.getPlantingWay().equals("2")){
+				//秧苗
+				record.setType("13");
+			}
 			record.setLandId(farmPlant.getLandId());
 			record.setOperator(farmPlant.getCreateUser());
-			record.setRemarks("品种: " + farmPlant.getVarieties());
+			if (StringUtil.isBlank(farmPlant.getVarieties())){
+				record.setContent("品种: " + strain.getStrainName());
+			}else {
+				record.setContent("品种: " + strain.getStrainName()+"-"+farmPlant.getVarieties());
+			}
 			//新增
 			farmingRecordService.save(record);
 
@@ -165,6 +276,32 @@
 		}
 		//更新并返回
 		return R.status(status);
+	}
+
+	@PostMapping("/overAll")
+	public R overAll(@RequestBody FarmPlantVO farmPlantVO){
+		boolean status = false;
+		for (int i=0;i<farmPlantVO.getIds().length;i++){
+			FarmPlant farmPlant = new FarmPlant();
+			farmPlant.setId(farmPlantVO.getIds()[i]);
+			farmPlant.setEndPlantTime(farmPlantVO.getEndPlantTime());
+			farmPlant.setStatus("2");
+			status = farmplantService.updateById(farmPlant);
+			//判断该地块是否还有种植的农产品
+			FarmPlant farmPlant2 = farmplantService.getById(farmPlant.getId());
+			FarmPlant farmPlant1 = new FarmPlant();
+			farmPlant1.setLandId(farmPlant2.getLandId());
+			farmPlant1.setStatus("1");
+			List<FarmPlant> list = farmplantService.list(new QueryWrapper<>(farmPlant1));
+			if (list.size() < 1) {
+				//更新该地块的耕种状态
+				Land land = new Land();
+				land.setType(1);
+				land.setId(Long.parseLong(farmPlant2.getLandId()));
+				landService.updateById(land);
+			}
+		}
+		return R.data(status);
 	}
 
 	/**
@@ -233,11 +370,41 @@
 	 */
 	@GetMapping("/pagePalnt")
 	public R pagePalnt(FarmPlantVO farmPlant, Query query) {
-		int i = farmplantService.selectCount();
+		int num = farmplantService.selectCount(farmPlant);
 		IPage<FarmPlantVO> pages = farmplantService.selectFarmPlantPage(Condition.getPage(query), farmPlant);
+		List<FarmPlantVO> res = pages.getRecords();
+		List<FarmPlantVO> count = new ArrayList<>();
+		//按种类合并种植物
+		for (int i = 0; i < res.size(); i++) {
+			if (i == 0){
+				count.add(res.get(0));
+			}else {
+				boolean type = false;
+				for (int j = 0; j < count.size(); j++) {
+					if (res.get(i).getStrainId().equals(count.get(j).getStrainId())){
+						FarmPlantVO data = new FarmPlantVO();
+						data.setStrainId(res.get(i).getStrainId());
+						BigDecimal b1 = new BigDecimal(res.get(i).getArea());
+						BigDecimal b2 = new BigDecimal(count.get(j).getArea());
+						data.setArea(b1.add(b2).doubleValue()+"");
+						data.setStrainName(res.get(i).getStrainName());
+						data.setUrl(res.get(i).getUrl());
+						count.set(j,data);
+						type = false;
+						break;
+					}else{
+						type = true;
+					}
+				}
+				if (type){
+					count.add(res.get(i));
+				}
+			}
+		}
+
 		Map map = new HashMap<>();
-		map.put("num", i);
-		map.put("page", pages);
+		map.put("num", num);
+		map.put("page", count);
 		return R.data(map);
 	}
 
@@ -294,24 +461,69 @@
 	 */
 	@GetMapping("/getFarmPlantStatisticsCountx")
 	public R getFarmPlantStatisticsCountx(FarmPlantVO farmPlant, Query query) {
-		Double num = 0.0;
+//		Double num = 0.0;
 		IPage<FarmPlantVO> pages = farmplantService.getFarmPlantStatisticsCountz(Condition.getPage(query), farmPlant);
-		for (int i = 0; i < pages.getRecords().size(); i++) {
-			String area = pages.getRecords().get(i).getArea();
-			Double a = Double.parseDouble(area);
-			DecimalFormat df = new DecimalFormat("#.00");
-			String format = df.format(a);
-			pages.getRecords().get(i).setArea(format);
-			num += a;
-		}
-		Map map = new HashMap();
-		List list = new ArrayList();
-		DecimalFormat df = new DecimalFormat("#.00");
-		String format = df.format(num);
-		map.put("znum", format);
-		list.add(map);
-		list.add(pages);
-		return R.data(list);
+//		for (int i = 0; i < pages.getRecords().size(); i++) {
+//			String area = pages.getRecords().get(i).getArea();
+//			Double a = Double.parseDouble(area);
+//			DecimalFormat df = new DecimalFormat("#.00");
+//			String format = df.format(a);
+//			pages.getRecords().get(i).setArea(format);
+//			num += a;
+//		}
+//		Map map = new HashMap();
+//		List list = new ArrayList();
+//		DecimalFormat df = new DecimalFormat("#.00");
+//		String format = df.format(num);
+//		map.put("znum", format);
+//		list.add(map);
+//		list.add(pages);
+//		return R.data(list);
+		return R.data(pages);
 	}
 
+
+	/**
+	 * 自定义分页
+	 */
+	@GetMapping("/pagex")
+	@ApiOperationSupport(order = 3)
+	@ApiOperation(value = "分页", notes = "传入farmPlant")
+	public R<IPage<FarmPlantVO>> pagex(FarmPlantVO farmPlant, Query query) {
+		IPage<FarmPlantVO> pages = farmplantService.selectFarmPlantPage(Condition.getPage(query), farmPlant);
+		for (int i = 0; i < pages.getRecords().size(); i++) {
+			//修改种养类型
+			String plantingWay = pages.getRecords().get(i).getPlantingWay();
+			if (plantingWay.equals("0")) {
+				pages.getRecords().get(i).setTy("移栽");
+			}
+			else if (plantingWay.equals("1")) {
+				pages.getRecords().get(i).setTy("直播");
+			} else {
+				pages.getRecords().get(i).setTy("秧苗");
+			}
+			//计算天数
+			Date transplanTime = pages.getRecords().get(i).getTransplanTime();
+			Date date = new Date();
+			Integer integer = daysBetween(transplanTime, date);
+			pages.getRecords().get(i).setFate(integer);
+		}
+		return R.data(pages);
+	}
+
+	/**
+	 * 根据时间阶段计算天数
+	 * @param smdate    开始时间
+	 * @param bdate     结束时间
+	 * @return
+	 */
+	public static Integer daysBetween(Date smdate,Date bdate){
+		Calendar cal = Calendar.getInstance();
+		cal.setTime(smdate);
+		long time1 = cal.getTimeInMillis();
+		cal.setTime(bdate);
+		long time2 = cal.getTimeInMillis();
+		long between_days=(time2-time1)/(1000*3600*24);
+		return Integer.parseInt(String.valueOf(between_days))+1;
+	}
 }

--
Gitblit v1.9.3