|
@@ -10,12 +10,14 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
|
import com.huimv.common.utils.Result;
|
|
|
import com.huimv.common.utils.ResultCode;
|
|
|
+import com.huimv.eartag.entity.BizFirstInspecEartag;
|
|
|
import com.huimv.eartag.entity.BizSellPigApply;
|
|
|
import com.huimv.eartag.entity.BizSellPigApplyEartag;
|
|
|
import com.huimv.eartag.entity.EartagRegisterEntity;
|
|
|
import com.huimv.eartag.entity.vo.BizSellPigApplyVo;
|
|
|
import com.huimv.eartag.entity.vo.EartagNoVo;
|
|
|
import com.huimv.eartag.entity.vo.InspecVo;
|
|
|
+import com.huimv.eartag.mapper.BizFirstInspecEartagMapper;
|
|
|
import com.huimv.eartag.mapper.BizSellPigApplyEartagMapper;
|
|
|
import com.huimv.eartag.mapper.BizSellPigApplyMapper;
|
|
|
import com.huimv.eartag.mapper.EartagRegisterMapper;
|
|
@@ -51,6 +53,9 @@ public class BizSellPigApplyServiceImpl extends ServiceImpl<BizSellPigApplyMappe
|
|
|
@Autowired
|
|
|
private EartagRegisterMapper eartagRegisterMapper;
|
|
|
|
|
|
+ @Autowired
|
|
|
+ private BizFirstInspecEartagMapper bizFirstInspecEartagMapper;
|
|
|
+
|
|
|
@Override
|
|
|
public Result sellPigRecord(Map<String,String> map) {
|
|
|
String farmId = map.get("farmId");
|
|
@@ -222,12 +227,19 @@ public class BizSellPigApplyServiceImpl extends ServiceImpl<BizSellPigApplyMappe
|
|
|
inspecVo.setAccomplishNum(count);
|
|
|
|
|
|
|
|
|
- wrapper.eq("real_eartag_num",4);
|
|
|
+
|
|
|
+ wrapper.clear();
|
|
|
+ wrapper.eq("inspec_org_id",farmId);
|
|
|
+ wrapper.eq("inspec_flow_status",1);
|
|
|
+ int count2 = this.count(wrapper);
|
|
|
+
|
|
|
+
|
|
|
+ wrapper.eq("record_status",4);
|
|
|
int count1 = this.count(wrapper);
|
|
|
inspecVo.setUnQualifiedNum(count1);
|
|
|
|
|
|
|
|
|
- inspecVo.setQualifiedNum(count -count);
|
|
|
+ inspecVo.setQualifiedNum(count2 - count1);
|
|
|
|
|
|
return new Result(ResultCode.SUCCESS,inspecVo);
|
|
|
}
|
|
@@ -291,39 +303,158 @@ public class BizSellPigApplyServiceImpl extends ServiceImpl<BizSellPigApplyMappe
|
|
|
List<String> inspecNos1 = inspecNos.stream().map(BizSellPigApplyEartag::getEarmark).collect(Collectors.toList());
|
|
|
List<String> eartagRegister1 = eartagRegisterEntities.stream().map(EartagRegisterEntity::getEartagNo).collect(Collectors.toList());
|
|
|
int inspecNos1Size = inspecNos1.size();
|
|
|
- int artagRegister1Size = eartagRegister1.size();
|
|
|
|
|
|
List<EartagNoVo> list = new ArrayList<>();
|
|
|
inspecNos1.stream().forEach( s -> list.add(new EartagNoVo(s,0)));
|
|
|
endMap.put("total",inspecNos1Size);
|
|
|
- if (inspecNos1Size == artagRegister1Size){
|
|
|
-
|
|
|
|
|
|
- endMap.put("abnormal",0);
|
|
|
+ inspecNos1.removeAll(eartagRegister1);
|
|
|
|
|
|
- }else if (inspecNos1Size > artagRegister1Size){
|
|
|
- List<String> inspecNos2 = ObjectUtil.clone(inspecNos1);
|
|
|
- inspecNos2.removeAll(eartagRegister1);
|
|
|
- for (String s : inspecNos2) {
|
|
|
+ endMap.put("eartagNos",list);
|
|
|
+ BizSellPigApply bizSellPigApply = this.getOne(new QueryWrapper<BizSellPigApply>().eq("batch_no", batchNo));
|
|
|
|
|
|
- list.stream().filter( o -> o.getEartagNo().equals(s)).forEach( e ->e.setStatus(1));
|
|
|
+ endMap.put("realEartagNum",bizSellPigApply.getRealEartagNum());
|
|
|
+ endMap.put("autoEartagNum",bizSellPigApply.getAutoEartagNum());
|
|
|
+ if (inspecNos1.size() == 0){
|
|
|
+ for (String s : inspecNos1) {
|
|
|
+ list.stream().filter(o -> o.getEartagNo().equals(s)).forEach(eartagNoVo -> eartagNoVo.setStatus(1));
|
|
|
}
|
|
|
+ endMap.put("inspecAutoNum",inspecNos1Size);
|
|
|
+ }else {
|
|
|
+ inspecNos1Size = inspecNos1Size - inspecNos1.size();
|
|
|
+ endMap.put("inspecAutoNum", inspecNos1Size);
|
|
|
|
|
|
- endMap.put("abnormal",inspecNos2.size());
|
|
|
- } else{
|
|
|
+ }
|
|
|
|
|
|
- List<String> eartagRegister2 = ObjectUtil.clone(eartagRegister1);
|
|
|
- eartagRegister2.removeAll(inspecNos1);
|
|
|
- for (String s : eartagRegister2) {
|
|
|
|
|
|
- list.stream().filter( o -> o.getEartagNo().equals(s)).forEach( e ->e.setStatus(1));
|
|
|
- }
|
|
|
+ bizSellPigApply.setInspecAutoNum(inspecNos1Size);
|
|
|
+
|
|
|
+ this.updateById(bizSellPigApply);
|
|
|
+ return new Result(ResultCode.SUCCESS,endMap);
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ //屠宰检疫
|
|
|
+ @Override
|
|
|
+ public Result getBatchCollect(String farmId) {
|
|
|
+ InspecVo inspecVo = new InspecVo();
|
|
|
+ QueryWrapper<BizSellPigApply> wrapper = new QueryWrapper<>();
|
|
|
+ wrapper.eq("butcher_org_id",farmId);
|
|
|
+ wrapper.in("inspec_flow_status",1,2);
|
|
|
+ inspecVo.setInspecNum(this.count(wrapper));
|
|
|
+
|
|
|
+
|
|
|
+ wrapper.clear();
|
|
|
+ wrapper.eq("butcher_org_id",farmId);
|
|
|
+ wrapper.eq("inspec_flow_status",1);
|
|
|
+ int count = this.count(wrapper);
|
|
|
+ inspecVo.setAccomplishNum(count);
|
|
|
+
|
|
|
+
|
|
|
+ wrapper.clear();
|
|
|
+ wrapper.eq("butcher_org_id",farmId);
|
|
|
+ wrapper.eq("inspec_flow_status",2);
|
|
|
+ int count2 = this.count(wrapper);
|
|
|
+
|
|
|
+ wrapper.eq("inspec_flow_status",5);
|
|
|
+ int count1 = this.count(wrapper);
|
|
|
+ inspecVo.setUnQualifiedNum(count1);
|
|
|
+
|
|
|
+
|
|
|
+ inspecVo.setQualifiedNum(count2 -count1);
|
|
|
+
|
|
|
+ return new Result(ResultCode.SUCCESS,inspecVo);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public Result getBatchRecord(Map<String, String> map) {
|
|
|
+ String farmId = map.get("farmId");
|
|
|
+ String type = map.get("type");
|
|
|
+
|
|
|
+ String current = map.get("current");
|
|
|
+ String size = map.get("size");
|
|
|
+ Page<BizSellPigApply> bizSellPigApplyPage ;
|
|
|
+ if (StringUtils.isBlank(current) || StringUtils.isBlank(size)){
|
|
|
+ bizSellPigApplyPage = new Page<>(1, 10);
|
|
|
+ }else {
|
|
|
+ bizSellPigApplyPage =new Page<>(Integer.parseInt(current), Integer.parseInt(size));
|
|
|
+ }
|
|
|
|
|
|
- endMap.put("abnormal",eartagRegister2.size());
|
|
|
+
|
|
|
+ QueryWrapper<BizSellPigApply> wrapper = new QueryWrapper<>();
|
|
|
+ wrapper.eq("butcher_org_id",farmId);
|
|
|
+ wrapper.orderByDesc("sell_time");
|
|
|
+ wrapper.ne("record_status",4);
|
|
|
+ //未审批
|
|
|
+ if ("1".equals(type)){
|
|
|
+ wrapper.eq("inspec_flow_status",1);
|
|
|
+
|
|
|
+ }
|
|
|
+ //合格
|
|
|
+ else if ("2".equals(type)){
|
|
|
+ wrapper.eq("inspec_flow_status",2);
|
|
|
+ wrapper.ne("record_status",5);
|
|
|
+ }
|
|
|
+
|
|
|
+ //不合格
|
|
|
+ else if ("3".equals(type)){
|
|
|
+ wrapper.eq("inspec_flow_status",2);
|
|
|
+ wrapper.eq("record_status",5);
|
|
|
+ }
|
|
|
+ //全部
|
|
|
+ else {
|
|
|
+ wrapper.in("inspec_flow_status",1,2);
|
|
|
}
|
|
|
|
|
|
|
|
|
+
|
|
|
+ Page<BizSellPigApply> page = this.page(bizSellPigApplyPage, wrapper);
|
|
|
+ return new Result(ResultCode.SUCCESS,page);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public Result batchCheck(Map<String, String> map) {
|
|
|
+ Map endMap = new HashMap();
|
|
|
+
|
|
|
+ String batchNo = map.get("batchNo");
|
|
|
+ String farmId = map.get("farmId");
|
|
|
+ List<BizFirstInspecEartag> inspecNos = bizFirstInspecEartagMapper.selectList(new QueryWrapper<BizFirstInspecEartag>().eq("batch_no", batchNo));
|
|
|
+ // DOTO
|
|
|
+ List<EartagRegisterEntity> eartagRegisterEntities = eartagRegisterMapper.selectList(new QueryWrapper<EartagRegisterEntity>().eq("stage", 12).eq("butcher_id", farmId));
|
|
|
+
|
|
|
+ List<String> inspecNos1 = inspecNos.stream().map(BizFirstInspecEartag::getEarmark).collect(Collectors.toList());
|
|
|
+ List<String> eartagRegister1 = eartagRegisterEntities.stream().map(EartagRegisterEntity::getEartagNo).collect(Collectors.toList());
|
|
|
+ int inspecNos1Size = inspecNos1.size();
|
|
|
+
|
|
|
+ List<EartagNoVo> list = new ArrayList<>();
|
|
|
+ inspecNos1.stream().forEach( s -> list.add(new EartagNoVo(s,0)));
|
|
|
+ endMap.put("total",inspecNos1Size);
|
|
|
+
|
|
|
+ inspecNos1.removeAll(eartagRegister1);
|
|
|
+
|
|
|
endMap.put("eartagNos",list);
|
|
|
+ BizSellPigApply bizSellPigApply = this.getOne(new QueryWrapper<BizSellPigApply>().eq("batch_no", batchNo));
|
|
|
+
|
|
|
+ endMap.put("realEartagNum",bizSellPigApply.getInspecRealNum());
|
|
|
+ endMap.put("autoEartagNum",bizSellPigApply.getInspecAutoNum());
|
|
|
+
|
|
|
+
|
|
|
+ if (inspecNos1.size() == 0){
|
|
|
+ endMap.put("inspecAutoNum",inspecNos1Size);
|
|
|
+ }else {
|
|
|
+ for (String s : inspecNos1) {
|
|
|
+ list.stream().filter(o -> o.getEartagNo().equals(s)).forEach(eartagNoVo -> eartagNoVo.setStatus(1));
|
|
|
+ }
|
|
|
+ inspecNos1Size = inspecNos1Size - inspecNos1.size();
|
|
|
+ endMap.put("inspecAutoNum", inspecNos1Size);
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ bizSellPigApply.setButcherAutoNum(inspecNos1Size);
|
|
|
+
|
|
|
+ this.updateById(bizSellPigApply);
|
|
|
return new Result(ResultCode.SUCCESS,endMap);
|
|
|
}
|
|
|
}
|