瀏覽代碼

2021/7/14 疫苗疾病管理耳标检查

yinhao 4 年之前
父節點
當前提交
1728b7021c

+ 14 - 0
huimv-smart-management/src/main/java/com/huimv/management/controller/HealthMedicalRecordController.java

@@ -6,8 +6,12 @@ import java.util.Map;
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.huimv.common.exception.RRException;
+import com.huimv.management.entity.YearPigBaseEntity;
 import com.huimv.management.entity.dto.DiseaseDto;
+import com.huimv.management.service.YearPigBaseService;
 import io.swagger.annotations.Api;
+import org.aspectj.weaver.ast.Var;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.PathVariable;
 import org.springframework.web.bind.annotation.RequestBody;
@@ -33,9 +37,13 @@ import com.huimv.common.utils.R;
 @RestController
 @RequestMapping("management/healthmedicalrecord")
 public class HealthMedicalRecordController {
+
     @Autowired
     private HealthMedicalRecordService healthMedicalRecordService;
 
+    @Autowired
+    private YearPigBaseService yearPigBaseService;
+
     /**
      * 列表
      */
@@ -66,6 +74,12 @@ public class HealthMedicalRecordController {
      */
     @RequestMapping("/save")
     public R save(@RequestBody HealthMedicalRecordEntity healthMedicalRecord){
+
+        String earTag = healthMedicalRecord.getPigId();
+        YearPigBaseEntity yearPigBaseEntity = yearPigBaseService.getOne(Wrappers.<YearPigBaseEntity>lambdaQuery().eq(YearPigBaseEntity::getEartag, earTag));
+        if (yearPigBaseEntity == null) {
+            throw new RRException("耳标号为:" + earTag + " 的耳标信息不存在,请检查输入的耳标号是否有误!");
+        }
 		healthMedicalRecordService.save(healthMedicalRecord);
 
         return R.ok();

+ 24 - 0
huimv-smart-management/src/main/java/com/huimv/management/service/impl/HealthImmuneRecordServiceImpl.java

@@ -1,11 +1,19 @@
 package com.huimv.management.service.impl;
 
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.huimv.common.exception.RRException;
+import com.huimv.management.dao.YearPigBaseDao;
 import com.huimv.management.entity.HealthMedicalRecordEntity;
+import com.huimv.management.entity.YearPigBaseEntity;
+import com.huimv.management.service.YearPigBaseService;
 import org.apache.commons.lang.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import java.util.List;
 import java.util.Map;
+import java.util.StringJoiner;
+
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
@@ -20,6 +28,9 @@ import com.huimv.management.service.HealthImmuneRecordService;
 @Service("healthImmuneRecordService")
 public class HealthImmuneRecordServiceImpl extends ServiceImpl<HealthImmuneRecordDao, HealthImmuneRecordEntity> implements HealthImmuneRecordService {
 
+    @Autowired
+    private YearPigBaseDao yearPigBaseDao;
+
     @Override
     public PageUtils queryPage(Map<String, Object> params) {
         //根据牧场查询
@@ -42,6 +53,19 @@ public class HealthImmuneRecordServiceImpl extends ServiceImpl<HealthImmuneRecor
 
     @Override
     public void saveAll(String[] eartags, String vaccineName, Integer farmId, String manName, Integer manId) {
+
+        StringJoiner sj = new StringJoiner(",","未找到耳标号为:","的信息,请检查输入的耳标号是否有误!");
+        int originLength = sj.length();
+        for (String eartag : eartags) {
+            YearPigBaseEntity yearPigBaseEntity = yearPigBaseDao.selectOne(Wrappers.<YearPigBaseEntity>lambdaQuery().eq(YearPigBaseEntity::getEartag, eartag));
+            if (yearPigBaseEntity == null) {
+                sj.add(eartag);
+            }
+        }
+        if (sj.length() > originLength) {
+            throw new RRException(sj.toString(), 1001);
+        }
+
         HealthImmuneRecordEntity healthImmuneRecordEntity = new HealthImmuneRecordEntity();
         healthImmuneRecordEntity.setFarmId(farmId);
         healthImmuneRecordEntity.setManId(manId);