diff --git a/src/main/java/com/dsic/gj_erp/bean/kc/ImCkwpkwp.java b/src/main/java/com/dsic/gj_erp/bean/kc/ImCkwpkwp.java new file mode 100644 index 0000000..5f074f6 --- /dev/null +++ b/src/main/java/com/dsic/gj_erp/bean/kc/ImCkwpkwp.java @@ -0,0 +1,32 @@ +package com.dsic.gj_erp.bean.kc; + +import com.baomidou.mybatisplus.annotation.TableName; +import com.github.jeffreyning.mybatisplus.anno.MppMultiId; +import lombok.Getter; +import lombok.Setter; + +/** + * 库存信息 + */ +@Getter +@Setter +@TableName("IM_CKWPKWP") +public class ImCkwpkwp { + @MppMultiId + private String ckh; + @MppMultiId + private String wph; + @MppMultiId + private String kwh;//垛位 + @MppMultiId + private String nbsbm; + + private String cfcs1;//层数 + + private String dcCh; + private String dcFd; + + private String qxkcl;//物品数量 + private String wpzt;//ky:可用;dy:代用 + +} diff --git a/src/main/java/com/dsic/gj_erp/controller/jhgk/DmYdjhController.java b/src/main/java/com/dsic/gj_erp/controller/jhgk/DmYdjhController.java index 90649c8..0837250 100644 --- a/src/main/java/com/dsic/gj_erp/controller/jhgk/DmYdjhController.java +++ b/src/main/java/com/dsic/gj_erp/controller/jhgk/DmYdjhController.java @@ -1,23 +1,33 @@ package com.dsic.gj_erp.controller.jhgk; +import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.date.DateUtil; import cn.hutool.core.util.StrUtil; 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.dsic.gj_erp.annotation.AuthFunction; import com.dsic.gj_erp.bean.ResultBean; +import com.dsic.gj_erp.bean.jcsj.DmCzplpNew; import com.dsic.gj_erp.bean.jhgk.DmYdjh; +import com.dsic.gj_erp.bean.kc.ImCkwpkwp; +import com.dsic.gj_erp.service.jcsj.DmCzplpNewService; +import com.dsic.gj_erp.service.jcsj.DmCzplpService; import com.dsic.gj_erp.service.jhgk.DmYdjhService; +import com.dsic.gj_erp.service.kc.ImCkwpkwpService; +import org.mapstruct.factory.Mappers; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; +import java.util.ArrayList; import java.util.List; import java.util.Map; import java.util.concurrent.atomic.AtomicInteger; import java.util.stream.Collectors; +import java.util.stream.Stream; /** *

@@ -33,6 +43,11 @@ public class DmYdjhController { @Autowired private DmYdjhService service; + @Autowired + private ImCkwpkwpService kcService; + + @Autowired + private DmCzplpNewService czplpNewService; @RequestMapping("/getList") @AuthFunction @@ -44,7 +59,34 @@ public class DmYdjhController { .le(StrUtil.isNotEmpty(map.get("yf")), "jssj", DateUtil.endOfMonth(DateUtil.parseDate(map.get("yf"))).toString("yyyy/MM/dd")) .orderByAsc("jssj,dc_ch,dc_pl,zl,lqlb") ); - return new ResultBean(list); + + Map> collect = list.stream().collect(Collectors.groupingBy(DmYdjh::getDcCh)); + List> resultMap=new ArrayList<>(); + //验证数据获取方法,后续可以都在这里进行获取 + collect.forEach((key,val)->{ + List bcKcxx = kcService.getBcKcxx(key); + List czplpNewList = czplpNewService.list(Wrappers.lambdaQuery() + .eq(DmCzplpNew::getDcCh, key) + ); + val.forEach(item->{ + Map itemMap = BeanUtil.beanToMap(item); + resultMap.add(itemMap); + bcKcxx.forEach(kc->{ + if (item.getDcCh().equals(kc.getDcCh())&&item.getDcFd().equals(kc.getDcFd())){ + itemMap.put("kc",kc); + } + }); + czplpNewList.forEach(czplpNew->{ + if (item.getDcCh().equals(czplpNew.getDcCh())&&item.getDcPl().equals(czplpNew.getDcPl())){ + itemMap.put("czplpNew",czplpNew); + } + }); + }); + + + }); + + return new ResultBean(resultMap); } diff --git a/src/main/java/com/dsic/gj_erp/mapper/kc/ImCkwpkwpMapper.java b/src/main/java/com/dsic/gj_erp/mapper/kc/ImCkwpkwpMapper.java new file mode 100644 index 0000000..a815f9f --- /dev/null +++ b/src/main/java/com/dsic/gj_erp/mapper/kc/ImCkwpkwpMapper.java @@ -0,0 +1,7 @@ +package com.dsic.gj_erp.mapper.kc; + +import com.dsic.gj_erp.bean.kc.ImCkwpkwp; +import com.github.jeffreyning.mybatisplus.base.MppBaseMapper; + +public interface ImCkwpkwpMapper extends MppBaseMapper { +} diff --git a/src/main/java/com/dsic/gj_erp/service/kc/ImCkwpkwpService.java b/src/main/java/com/dsic/gj_erp/service/kc/ImCkwpkwpService.java new file mode 100644 index 0000000..d42c7b0 --- /dev/null +++ b/src/main/java/com/dsic/gj_erp/service/kc/ImCkwpkwpService.java @@ -0,0 +1,31 @@ +package com.dsic.gj_erp.service.kc; + +import com.baomidou.mybatisplus.core.toolkit.Wrappers; +import com.dsic.gj_erp.bean.kc.ImCkwpkwp; +import com.dsic.gj_erp.mapper.kc.ImCkwpkwpMapper; +import com.github.jeffreyning.mybatisplus.service.MppServiceImpl; +import org.springframework.stereotype.Service; + +import java.util.List; + +@Service +public class ImCkwpkwpService extends MppServiceImpl { + + /** + * 根据船只,分段获取板材库存信息 + */ + public List getBcKcxx(String dcCh){ + return this.getByDcch(dcCh,"01"); + } + + /** + * 根据仓库号,船只,分段获取板材/型材库存信息 + */ + public List getByDcch(String dcCh,String ckh){ + return this.list(Wrappers.lambdaQuery() + .eq(ImCkwpkwp::getCkh,ckh) + .eq(ImCkwpkwp::getDcCh,dcCh) + .eq(ImCkwpkwp::getWpzt,"KY") + ); + } +} diff --git a/src/main/resources/mappers/kc/ImCkwpkwp.xml b/src/main/resources/mappers/kc/ImCkwpkwp.xml new file mode 100644 index 0000000..c3f14ba --- /dev/null +++ b/src/main/resources/mappers/kc/ImCkwpkwp.xml @@ -0,0 +1,5 @@ + + + + +