| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831 |
- package com.dk.mdm.service.ivt.inbound;
- import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
- import com.dk.common.exception.BaseBusinessException;
- import com.dk.common.infrastructure.annotaiton.Pagination;
- import com.dk.common.infrastructure.constant.Constant;
- import com.dk.common.infrastructure.enums.ErrorCodeEnum;
- import com.dk.common.mapper.BaseMapper;
- import com.dk.common.model.pojo.PageList;
- import com.dk.common.response.ResponseCodeEnum;
- import com.dk.common.response.ResponseResultUtil;
- import com.dk.common.response.ResponseResultVO;
- import com.dk.common.service.BaseService;
- import com.dk.mdm.infrastructure.convert.ivt.InboundConvert;
- import com.dk.mdm.infrastructure.convert.ivt.InboundItemConvert;
- import com.dk.mdm.mapper.common.CommonMapper;
- import com.dk.mdm.mapper.ivt.InOutRecordMapper;
- import com.dk.mdm.mapper.ivt.InboundItemMapper;
- import com.dk.mdm.mapper.ivt.InboundMapper;
- import com.dk.mdm.model.pojo.ivt.Inbound;
- import com.dk.mdm.model.pojo.ivt.InboundItem;
- import com.dk.mdm.model.pojo.ivt.Outbound;
- import com.dk.mdm.model.pojo.ivt.OutboundItem;
- import com.dk.mdm.model.pojo.pur.Purchase;
- import com.dk.mdm.model.pojo.pur.PurchaseItem;
- import com.dk.mdm.model.query.ivt.InboundItemQuery;
- import com.dk.mdm.model.query.ivt.InboundQuery;
- import com.dk.mdm.model.response.ivt.InboundItemResponse;
- import com.dk.mdm.model.response.ivt.InboundResponse;
- import com.dk.mdm.model.vo.ivt.InboundItemVO;
- import com.dk.mdm.model.vo.ivt.InboundVO;
- import com.dk.mdm.model.vo.ivt.OutboundItemVO;
- import com.dk.mdm.service.common.CommonService;
- import com.dk.mdm.service.ivt.inventory.InventoryService;
- import io.swagger.annotations.ApiOperation;
- import org.springframework.beans.factory.annotation.Autowired;
- import org.springframework.stereotype.Service;
- import org.springframework.transaction.annotation.Transactional;
- import org.springframework.web.bind.annotation.PostMapping;
- import org.springframework.web.bind.annotation.RequestBody;
- import javax.validation.Valid;
- import java.math.BigDecimal;
- import java.util.HashMap;
- import java.util.List;
- import java.util.Map;
- import java.util.UUID;
- import java.util.stream.Collectors;
- /**
- * @author : 寇珊珊
- * @desc : 其他入库业务层
- * @date : 2024/3/7 14:11
- */
- @Service
- public class InboundOtherService extends BaseService<Inbound> {
- @Override
- public BaseMapper<Inbound> getRepository() {
- return inboundMapper;
- }
- @Autowired
- private InboundMapper inboundMapper;
- @Autowired
- private InboundConvert inboundConvert;
- @Autowired
- private InboundItemMapper inboundItemMapper;
- @Autowired
- private InboundItemConvert inboundItemConvert;
- @Autowired
- private CommonService commonService;
- @Autowired
- private CommonMapper commonMapper;
- @Autowired
- private InventoryService inventoryService;
- /**
- * @desc : 条件查询
- * @date : 2024/3/7 14:12
- * @author : 寇珊珊
- */
- @Pagination
- public ResponseResultVO<PageList<InboundResponse>> selectByCond(InboundQuery inboundQuery) {
- return super.mergeListWithCount(inboundQuery, inboundMapper.selectByCond(inboundQuery),
- inboundMapper.countByCond(inboundQuery));
- }
- /**
- * @desc : 查询明细
- * @date : 2024/3/9 15:43
- * @author : 寇珊珊
- */
- @Pagination
- public ResponseResultVO<Map<String, Object>> selectOtherInboundItemInfoById(String id) {
- Map<String, Object> result = new HashMap<>();
- // 商品明细
- List<InboundItemResponse> inboundItemResponses = inboundItemMapper.selectByCond(new InboundItemQuery().setIntoId(id));
- result.put("itemList", inboundItemResponses);
- // 收款
- // 附件
- return ResponseResultUtil.success(result);
- }
- /**
- * @desc : 查询入库价
- * @date : 2024/7/1 11:29
- * @author : 寇珊珊
- */
- @Transactional(rollbackFor = {Exception.class})
- public InboundItemResponse selectPriceInto(InboundItemVO inboundItemVO) {
- List<InboundItemResponse> inboundItemResponses = inboundItemMapper.selectPriceInto(new InboundItemQuery().setSkuId(inboundItemVO.getSkuId())
- .setNonStdCode(inboundItemVO.getNonStdCode())
- .setWhId(inboundItemVO.getWhId()));
- if (inboundItemResponses != null && inboundItemResponses.size() > 0) {
- return inboundItemResponses.get(0);
- }
- return null;
- }
- /**
- * @desc : 其他入库新建
- * @date : 2024/3/7 14:13
- * @author : 寇珊珊
- */
- @Transactional(rollbackFor = {Exception.class})
- public ResponseResultVO<?> otherInboundInsert(InboundVO inboundVO) {
- //校验明细
- if (inboundVO.getItemList().size() == 0) {
- throw new BaseBusinessException(ErrorCodeEnum.INBOUND_ITEM_NOT_EXIST.getCode(),
- ErrorCodeEnum.INBOUND_ITEM_NOT_EXIST.getMessage());
- }
- //region 查询当前入库明细中是否存在未空或者0的入库价,如果存在去库存流水差最近一条有价格的数据赋值到当前明细
- Boolean priceIntoFlag = false;
- for (InboundItemVO inboundItemVO : inboundVO.getItemList()) {
- if(inboundItemVO.getCostPrice()==null || inboundItemVO.getCostPrice().compareTo(BigDecimal.ZERO)==0){
- priceIntoFlag = true;
- //查询库存批次最近一条入库价
- InboundItemResponse inboundItemResponse = this.selectPriceInto(inboundItemVO);
- //todo 2024年7月5日15:57:01 priceOut和outingAmt 前台传 z确认修改
- //todo 2024年7月9日08:52:55 入库价和入库价总和后台计算 z确认修改
- inboundItemVO.setCostPrice(inboundItemResponse != null ? inboundItemResponse.getCostPrice() : BigDecimal.ZERO);
- inboundItemVO.setCostAmt(inboundItemResponse != null ? inboundItemResponse.getCostPrice().multiply(inboundItemVO.getIntoingQty()).setScale(2, BigDecimal.ROUND_HALF_UP) : BigDecimal.ZERO);
- inboundItemVO.setPriceInto(inboundItemResponse != null ? inboundItemResponse.getCostPrice() : BigDecimal.ZERO);
- inboundItemVO.setIntoingAmt(inboundItemResponse != null ? inboundItemResponse.getPriceInto().multiply(inboundItemVO.getIntoingQty()).setScale(2, BigDecimal.ROUND_HALF_UP) : BigDecimal.ZERO);
- }
- }
- if(priceIntoFlag){
- BigDecimal intoingAmt = inboundVO.getItemList().stream().map(InboundItemVO::getIntoingAmt).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(6, BigDecimal.ROUND_HALF_UP);
- inboundVO.setIntoingAmt(intoingAmt);
- }
- //endregion
- //region 查询当前公司的系统参数 自动办理信息 并赋值
- Map<String, Object> map = new HashMap<>();
- map.put("cpId", inboundVO.getCpId());
- map.put("code", Constant.SystemConstant.IVT_001.getValue());
- //自动办理标识
- String flgHandleSetting = commonMapper.getSettingValue(map);
- //自动办理标识为1 自动办理入库
- if (Constant.FlgAutoHandleStringType.ONE.getValue().equals(flgHandleSetting)) {
- inboundVO.setFlgAutoHandle(Constant.FlgAutoHandle.TRUE.getValue());
- }
- //endregion
- //region 总单
- //获取 id/单号
- Map<String, Object> codeMap = commonService.getUniqueNoteCode(Constant.docNameConstant.OTHERINBOUND.getName(), false);
- inboundVO.setIntoId(codeMap.get("outId").toString()).
- setIntoNo(codeMap.get("outNote").toString());
- //入库类型
- inboundVO.setIntoType(Constant.IntoType.OTHER.getName());
- //自动入库标识
- if (inboundVO.getFlgAutoHandle()) {
- //已入库
- inboundVO.setIntoStatus(Constant.IntoStatus.YIRUKU.getName());
- } else {
- //入库中
- inboundVO.setIntoStatus(Constant.IntoStatus.RUKUZHONG.getName());
- }
- //入库状态等于已入库 更新合计入库数量/金额 = 入库中数量/入库中金额
- if (Constant.IntoStatus.YIRUKU.getName().equals(inboundVO.getIntoStatus())) {
- inboundVO.setIntoQty(inboundVO.getIntoingQty())
- .setIntoAmt(inboundVO.getIntoingAmt())
- .setIntoingQty(BigDecimal.ZERO)
- .setIntoingAmt(BigDecimal.ZERO)
- ;
- } else {
- inboundVO.setIntoQty(BigDecimal.ZERO)
- .setIntoAmt(BigDecimal.ZERO)
- ;
- }
- //实体转换
- Inbound inbound = inboundConvert.convertToPo(inboundVO);
- inboundMapper.insert(inbound);
- //endregion
- //region 明细
- for (InboundItemVO inboundItemVO : inboundVO.getItemList()) {
- //region 将库存需要的参数赋值
- inboundItemVO.setInventoryType(Constant.InventoryType.INBOUND.getName());
- inboundItemVO.setInventoryDocCode(Constant.InventoryDocCode.OTHER_INBOUND.getValue());
- inboundItemVO.setAddOrEditFlag(true);
- //endregion
- //总单id
- inboundItemVO.setIntoId(inboundVO.getIntoId());
- //入库类型
- inboundItemVO.setIntoType(inboundVO.getIntoType());
- //出库数量
- inboundItemVO.setOutQty(BigDecimal.ZERO);
- //入库状态等于已入库 更新合计入库数量/金额 = 入库中数量/入库中金额
- if (Constant.IntoStatus.YIRUKU.getName().equals(inboundVO.getIntoStatus())) {
- inboundItemVO
- .setIntoQty(inboundItemVO.getIntoingQty())
- .setIntoAmt(inboundItemVO.getIntoingAmt())
- .setIntoingQty(BigDecimal.ZERO)
- .setIntoingAmt(BigDecimal.ZERO)
- ;
- } else {
- inboundItemVO
- .setIntoQty(BigDecimal.ZERO)
- .setIntoAmt(BigDecimal.ZERO);
- }
- //入库状态
- inboundItemVO.setIntoStatus(inboundVO.getIntoStatus());
- //实体转换
- InboundItem inboundItem = inboundItemConvert.convertToPo(inboundItemVO);
- inboundItemMapper.insert(inboundItem);
- inboundItemVO.setItemId(inboundItem.getItemId());
- }
- //endregion
- //region 库存
- if (Constant.IntoStatus.YIRUKU.getName().equals(inboundVO.getIntoStatus())) {
- Map<String, Object> invMap = new HashMap<>();
- invMap.put("intoDetail", inboundVO.getItemList());
- inventoryService.operatingInventoryInformation(invMap);
- }
- //endregion
- return ResponseResultUtil.success(inboundVO);
- }
- /**
- * @desc : 其他入库编辑
- * @date : 2024/3/25 16:25
- * @author : 寇珊珊
- */
- @Transactional(rollbackFor = {Exception.class})
- public ResponseResultVO<?> otherInboundUpdate(InboundVO inboundVO) {
- //region 小编辑
- if (!inboundVO.getLimitEdit()) {
- Inbound inbound = new Inbound();
- inbound.setIntoId(inboundVO.getIntoId());
- inbound.setRemarks(inboundVO.getRemarks());
- inbound.setAnnexPaths(inboundVO.getAnnexPaths());
- inboundMapper.update(inbound,
- new UpdateWrapper<Inbound>().lambda()
- .eq(Inbound::getIntoId, UUID.fromString(inbound.getIntoId()))
- );
- for (InboundItemVO inboundItemVO : inboundVO.getItemList()) {
- InboundItem inboundItem = new InboundItem();
- inboundItem.setItemId(inboundItemVO.getItemId());
- inboundItem.setRemarks(inboundItemVO.getRemarks());
- inboundItemMapper.update(inboundItem,
- new UpdateWrapper<InboundItem>().lambda()
- .eq(InboundItem::getItemId, UUID.fromString(inboundItem.getItemId()))
- );
- }
- }
- //endregion
- //region 大编辑
- else {
- //region 明细数量金额 求和
- BigDecimal sumQty = inboundVO.getItemList().stream().map(InboundItemVO::getIntoingQty).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(6, BigDecimal.ROUND_HALF_UP);
- BigDecimal sumAmt = inboundVO.getItemList().stream().map(InboundItemVO::getIntoingAmt).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(2, BigDecimal.ROUND_HALF_UP);
- //endregion
- //region 已入库编辑
- if (Constant.IntoStatus.YIRUKU.getName().equals(inboundVO.getIntoStatus())) {
- //region 修改明细
- List<InboundItemVO> itemList = inboundVO.getItemList();
- for (InboundItemVO inboundItemVO : itemList) {
- //region 编辑明细赋值
- if (inboundItemVO.getItemId() != null) {
- //根据id查询
- InboundItemResponse inboundItemResponse = inboundItemMapper.selectById(inboundItemVO.getItemId());
- //region 将库存需要的参数赋值
- inboundItemVO.setInventoryType(Constant.InventoryType.INBOUND.getName());
- inboundItemVO.setInventoryDocCode(Constant.InventoryDocCode.OTHER_INBOUND.getValue());
- //编辑之前的数
- inboundItemVO.setQtyBeforeUpdate(inboundItemResponse.getIntoQty());
- inboundItemVO.setAmtBeforeUpdate(inboundItemResponse.getIntoAmt());
- //编辑之后的数
- inboundItemVO.setIntoQty(inboundItemVO.getIntoingQty());
- inboundItemVO.setIntoAmt(inboundItemVO.getIntoingAmt());
- inboundItemVO.setAddOrEditFlag(false);
- //endregion
- InboundItem inboundItem = new InboundItem();
- inboundItem.setItemId(inboundItemVO.getItemId());
- inboundItem.setIntoQty(inboundItemVO.getIntoingQty());
- inboundItem.setIntoAmt(inboundItemVO.getIntoingAmt());
- //修改
- inboundItemMapper.update(inboundItem,
- new UpdateWrapper<InboundItem>().lambda()
- .eq(InboundItem::getItemId, UUID.fromString(inboundItem.getItemId()))
- );
- }
- //endregion
- //region 新建明细
- else {
- inboundItemVO
- .setIntoQty(inboundItemVO.getIntoingQty())
- .setIntoAmt(inboundItemVO.getIntoingAmt())
- .setIntoingQty(BigDecimal.ZERO)
- .setIntoingAmt(BigDecimal.ZERO)
- ;
- inboundItemVO.setIntoId(inboundVO.getIntoId());
- //入库状态
- inboundItemVO.setIntoStatus(inboundVO.getIntoStatus());
- inboundItemVO.setIntoType(Constant.IntoType.OTHER.getName());
- //实体转换
- InboundItem inboundItem = inboundItemConvert.convertToPo(inboundItemVO);
- inboundItemMapper.insert(inboundItem);
- inboundItemVO.setItemId(inboundItem.getItemId());
- //region 将库存需要的参数赋值
- inboundItemVO.setInventoryType(Constant.InventoryType.INBOUND.getName());
- inboundItemVO.setInventoryDocCode(Constant.InventoryDocCode.OTHER_INBOUND.getValue());
- inboundItemVO.setIntoQty(inboundItemVO.getIntoQty());
- inboundItemVO.setIntoAmt(inboundItemVO.getIntoAmt());
- inboundItemVO.setAddOrEditFlag(true);
- //endregion
- }
- //endregion
- }
- //endregion
- //region 删除明细
- if (inboundVO.getDeleteItemList() != null && inboundVO.getDeleteItemList().size() > 0) {
- for (InboundItemVO inboundItemVO : inboundVO.getDeleteItemList()) {
- //region 将库存需要的参数赋值
- inboundItemVO.setInventoryType(Constant.InventoryType.INBOUND.getName());
- inboundItemVO.setInventoryDocCode(Constant.InventoryDocCode.OTHER_INBOUND.getValue());
- //endregion
- if (inboundItemVO.getItemId() != null) {
- InboundItem inboundItem = inboundItemConvert.convertToPo(inboundItemVO);
- inboundItem.setFlgValid(false);
- //修改
- inboundItemMapper.update(inboundItem,
- new UpdateWrapper<InboundItem>().lambda()
- .eq(InboundItem::getItemId, UUID.fromString(inboundItem.getItemId()))
- );
- }
- }
- }
- //endregion
- //region 修改入库总单
- Inbound inbound = new Inbound();
- inbound.setIntoId(inboundVO.getIntoId());
- inbound.setIntoQty(sumQty);
- inbound.setIntoAmt(sumAmt);
- //修改
- inboundMapper.update(inbound,
- new UpdateWrapper<Inbound>().lambda().eq(Inbound::getIntoId, UUID.fromString(inbound.getIntoId()))
- );
- //endregion
- //region todo调用库存
- Map<String, Object> map = new HashMap<>();
- map.put("intoDetail", inboundVO.getItemList());
- map.put("delIntoDetail", inboundVO.getDeleteItemList());
- inventoryService.operatingInventoryInformation(map);
- //endregion
- }
- //endregion
- //region 入库中编辑
- if (Constant.IntoStatus.RUKUZHONG.getName().equals(inboundVO.getIntoStatus()) ||
- Constant.IntoStatus.DAIRUKU.getName().equals(inboundVO.getIntoStatus())) {
- //region 修改明细
- List<InboundItemVO> itemList = inboundVO.getItemList();
- for (InboundItemVO inboundItemVO : itemList) {
- if (inboundItemVO.getItemId() != null) {
- //region 编辑赋值
- InboundItem inboundItem = new InboundItem();
- inboundItem.setItemId(inboundItemVO.getItemId());
- inboundItem.setIntoingQty(inboundItemVO.getIntoingQty());
- inboundItem.setIntoingAmt(inboundItemVO.getIntoingAmt());
- //修改
- inboundItemMapper.update(inboundItem,
- new UpdateWrapper<InboundItem>().lambda()
- .eq(InboundItem::getItemId, UUID.fromString(inboundItem.getItemId()))
- );
- }
- //endregion
- //region 新建明细
- else {
- inboundItemVO
- .setIntoQty(BigDecimal.ZERO)
- .setIntoAmt(BigDecimal.ZERO)
- ;
- inboundItemVO.setIntoId(inboundVO.getIntoId());
- //入库状态
- inboundItemVO.setIntoStatus(inboundVO.getIntoStatus());
- inboundItemVO.setIntoType(Constant.IntoType.OTHER.getName());
- //实体转换
- InboundItem inboundItem = inboundItemConvert.convertToPo(inboundItemVO);
- inboundItemMapper.insert(inboundItem);
- inboundItemVO.setItemId(inboundItem.getItemId());
- }
- //endregion
- }
- //endregion
- //region 删除明细
- if (inboundVO.getDeleteItemList() != null && inboundVO.getDeleteItemList().size() > 0) {
- for (InboundItemVO inboundItemVO : inboundVO.getDeleteItemList()) {
- if (inboundItemVO.getItemId() != null) {
- InboundItem inboundItem = inboundItemConvert.convertToPo(inboundItemVO);
- inboundItem.setFlgValid(false);
- //修改
- inboundItemMapper.update(inboundItem,
- new UpdateWrapper<InboundItem>().lambda()
- .eq(InboundItem::getItemId, UUID.fromString(inboundItem.getItemId()))
- );
- }
- }
- }
- //endregion
- //region 修改入库总单
- Inbound inbound = new Inbound();
- inbound.setIntoId(inboundVO.getIntoId());
- inbound.setIntoingQty(sumQty);
- inbound.setIntoingAmt(sumAmt);
- //修改
- inboundMapper.update(inbound,
- new UpdateWrapper<Inbound>().lambda().eq(Inbound::getIntoId, UUID.fromString(inbound.getIntoId()))
- );
- //endregion
- }
- //endregion
- }
- //endregion
- return ResponseResultUtil.success(inboundVO);
- }
- /**
- * @desc : 其他入库作废
- * @date : 2024/3/25 16:25
- * @author : 寇珊珊
- */
- @Transactional(rollbackFor = {Exception.class})
- public ResponseResultVO<?> otherInboundRepeal(String intoId) {
- //region 查询总单 查询明细
- //根据id查询 此条入库单的数据还未更改前的数据
- InboundResponse inboundResponse = inboundMapper.selectById(intoId);
- //根据总单id查询
- List<InboundItemResponse> inboundItemResponseList = inboundItemMapper.selectByCond(new InboundItemQuery().setIntoId(inboundResponse.getIntoId()));
- //endregion
- //region 已入库作废
- if (Constant.IntoStatus.YIRUKU.getName().equals(inboundResponse.getIntoStatus())) {
- //region todo 退账 当单据红的账款id不为空说明有账, 要先退账才能进行操作
- if (inboundResponse.getReceivableId() != null) {
- }
- //endregion
- //region 修改明细
- for (InboundItemResponse inboundItemResponse : inboundItemResponseList) {
- //region 将库存需要的参数赋值
- inboundItemResponse.setInventoryType(Constant.InventoryType.INBOUND.getName());
- inboundItemResponse.setInventoryDocCode(Constant.InventoryDocCode.OTHER_INBOUND.getValue());
- inboundItemResponse.setIntoQty(inboundItemResponse.getIntoQty());
- inboundItemResponse.setIntoAmt(inboundItemResponse.getIntoAmt());
- //endregion
- //赋值 赋值明细 防止作废的单据查不到明细 故注掉下面代码
- // InboundItem inboundItem = new InboundItem();
- // inboundItem.setItemId(inboundItemResponse.getItemId());
- // inboundItem.setFlgValid(false);
- // //修改
- // inboundItemMapper.update(inboundItem,
- // new UpdateWrapper<InboundItem>().lambda()
- // .eq(InboundItem::getItemId, UUID.fromString(inboundItem.getItemId()))
- // );
- }
- //endregion
- //region 修改入库总单
- Inbound inbound = new Inbound();
- inbound.setIntoId(inboundResponse.getIntoId());
- inbound.setFlgValid(false);
- //修改
- inboundMapper.update(inbound,
- new UpdateWrapper<Inbound>().lambda().eq(Inbound::getIntoId, UUID.fromString(inbound.getIntoId()))
- );
- //endregion
- //region 库存
- Map<String, Object> map = new HashMap<>();
- map.put("delIntoDetail", inboundItemResponseList);
- inventoryService.operatingInventoryInformation(map);
- //endregion
- }
- //endregion
- //region 入库中、待入库作废
- if (Constant.IntoStatus.RUKUZHONG.getName().equals(inboundResponse.getIntoStatus()) ||
- Constant.IntoStatus.DAIRUKU.getName().equals(inboundResponse.getIntoStatus())) {
- //region 修改明细
- for (InboundItemResponse inboundItemResponse : inboundItemResponseList) {
- //赋值
- InboundItem inboundItem = new InboundItem();
- inboundItem.setItemId(inboundItemResponse.getItemId());
- inboundItem.setIntoingQty(BigDecimal.ZERO);
- inboundItem.setIntoingAmt(BigDecimal.ZERO);
- // inboundItem.setFlgValid(false);
- //修改
- inboundItemMapper.update(inboundItem,
- new UpdateWrapper<InboundItem>().lambda()
- .eq(InboundItem::getItemId, UUID.fromString(inboundItem.getItemId()))
- );
- }
- //endregion
- //region 修改入库总单
- Inbound inbound = new Inbound();
- inbound.setIntoId(inboundResponse.getIntoId());
- inbound.setIntoingQty(BigDecimal.ZERO);
- inbound.setIntoAmt(BigDecimal.ZERO);
- inbound.setFlgValid(false);
- //修改
- inboundMapper.update(inbound,
- new UpdateWrapper<Inbound>().lambda().eq(Inbound::getIntoId, UUID.fromString(inbound.getIntoId()))
- );
- //endregion
- }
- //endregion
- return ResponseResultUtil.success();
- }
- /**
- * @desc : 其他入库办理
- * @date : 2024/3/7 15:47
- * @author : 寇珊珊
- */
- @Transactional(rollbackFor = {Exception.class})
- public ResponseResultVO<?> otherHandleInbound(InboundVO inboundVO) {
- //region 编辑明细
- //校验明细
- if (inboundVO.getItemList().size() == 0) {
- throw new BaseBusinessException(ErrorCodeEnum.INBOUND_ITEM_NOT_EXIST.getCode(),
- ErrorCodeEnum.INBOUND_ITEM_NOT_EXIST.getMessage());
- }
- for (InboundItemVO inboundItemVO : inboundVO.getItemList()) {
- //region 修改明细
- if (inboundItemVO.getIntoId() != null) {
- InboundItemResponse inboundItemResponse = inboundItemMapper.selectById(inboundItemVO.getItemId());
- //region 校验数量是否超出
- if (inboundItemVO.getIntoingQty().compareTo(inboundItemResponse.getIntoingQty()) > 0) {
- throw new BaseBusinessException(ErrorCodeEnum.CANNOT_EXCEED_THE_QUANTITY_IN_THE_OUTBOUND_SHIPMENT.getCode(),
- ErrorCodeEnum.CANNOT_EXCEED_THE_QUANTITY_IN_THE_OUTBOUND_SHIPMENT.getMessage());
- }
- //endregion
- //region 编辑明细
- inboundItemVO
- .setIntoQty(inboundItemResponse.getIntoQty().add(inboundItemVO.getIntoingQty()))
- .setIntoAmt(inboundItemResponse.getIntoAmt().add(inboundItemVO.getIntoingAmt()))
- .setIntoingQty(BigDecimal.ZERO)
- .setIntoingAmt(BigDecimal.ZERO)
- ;
- //入库状态
- String intoStatus = this.setIntoStatus(inboundItemVO.getIntoingQty(), inboundItemVO.getIntoQty());
- inboundItemVO.setIntoStatus(intoStatus);
- //实体转换
- InboundItem inboundItem = inboundItemConvert.convertToPo(inboundItemVO);
- //修改
- inboundItemMapper.update(inboundItem,
- new UpdateWrapper<InboundItem>().lambda()
- .eq(InboundItem::getItemId, UUID.fromString(inboundItem.getItemId()))
- );
- //endregion
- //region 将库存需要的参数赋值
- inboundItemVO.setInventoryType(Constant.InventoryType.INBOUND.getName());
- inboundItemVO.setInventoryDocCode(Constant.InventoryDocCode.OTHER_INBOUND.getValue());
- //编辑之前的数
- if (inboundItemResponse.getIntoQty().compareTo(BigDecimal.ZERO) > 0) {
- inboundItemVO.setQtyBeforeUpdate(inboundItemResponse.getIntoQty());
- inboundItemVO.setAmtBeforeUpdate(inboundItemResponse.getIntoAmt());
- }
- inboundItemVO.setAddOrEditFlag(true);
- //endregion
- }
- //endregion
- //region 新建明细
- else {
- inboundItemVO
- .setIntoQty(inboundItemVO.getIntoingQty())
- .setIntoAmt(inboundItemVO.getIntoingAmt())
- .setIntoId(inboundVO.getIntoId())
- .setIntoType(Constant.IntoType.OTHER.getName())
- .setIntoingQty(BigDecimal.ZERO)
- .setIntoingAmt(BigDecimal.ZERO)
- ;
- //入库状态
- String intoStatus = this.setIntoStatus(inboundItemVO.getIntoingQty(), inboundItemVO.getIntoQty());
- inboundItemVO.setIntoStatus(intoStatus);
- //实体转换
- InboundItem inboundItem = inboundItemConvert.convertToPo(inboundItemVO);
- //新建
- inboundItemMapper.insert(inboundItem);
- inboundItemVO.setItemId(inboundItem.getItemId());
- //region 将库存需要的参数赋值
- inboundItemVO.setInventoryType(Constant.InventoryType.INBOUND.getName());
- inboundItemVO.setInventoryDocCode(Constant.InventoryDocCode.OTHER_INBOUND.getValue());
- inboundItemVO.setAddOrEditFlag(true);
- //endregion
- }
- //endregion
- }
- //endregion
- //region 删除明细
- if (inboundVO.getDeleteItemList() != null && inboundVO.getDeleteItemList().size() > 0) {
- for (InboundItemVO inboundItemVO : inboundVO.getDeleteItemList()) {
- //region 将库存需要的参数赋值
- inboundItemVO.setInventoryType(Constant.InventoryType.INBOUND.getName());
- inboundItemVO.setInventoryDocCode(Constant.InventoryDocCode.OTHER_INBOUND.getValue());
- //endregion
- if (inboundItemVO.getItemId() != null) {
- InboundItem inboundItem = inboundItemConvert.convertToPo(inboundItemVO);
- inboundItem.setFlgValid(false);
- //修改
- inboundItemMapper.update(inboundItem,
- new UpdateWrapper<InboundItem>().lambda()
- .eq(InboundItem::getItemId, UUID.fromString(inboundItem.getItemId()))
- );
- }
- }
- }
- //endregion
- //region 编辑总单
- BigDecimal sumIntoQty = inboundVO.getItemList().stream().map(InboundItemVO::getIntoQty).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(6, BigDecimal.ROUND_HALF_UP);
- BigDecimal sumIntoAmt = inboundVO.getItemList().stream().map(InboundItemVO::getIntoAmt).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(2, BigDecimal.ROUND_HALF_UP);
- inboundVO.setIntoQty(sumIntoQty);
- inboundVO.setIntoAmt(sumIntoAmt);
- inboundVO.setIntoingQty(BigDecimal.ZERO);
- inboundVO.setIntoingAmt(BigDecimal.ZERO);
- //入库状态
- String intoStatus = this.setIntoStatus(inboundVO.getIntoingQty(), inboundVO.getIntoQty());
- inboundVO.setIntoStatus(intoStatus);
- //实体转换
- //修改
- Inbound inbound = inboundConvert.convertToPo(inboundVO);
- inboundMapper.update(inbound,
- new UpdateWrapper<Inbound>().lambda()
- .eq(Inbound::getIntoId, UUID.fromString(inbound.getIntoId()))
- );
- //endregion
- //region 修改库存
- Map<String, Object> map = new HashMap<>();
- map.put("intoDetail", inboundVO.getItemList());
- map.put("delIntoDetail", inboundVO.getDeleteItemList());
- inventoryService.operatingInventoryInformation(map);
- //endregion
- return ResponseResultUtil.success(inboundVO);
- }
- /**
- * @desc : 其它入库撤销
- * @date : 2024/3/7 17:06
- * @author : 寇珊珊
- */
- @Transactional(rollbackFor = {Exception.class})
- public ResponseResultVO<?> otherInboundCancel(InboundVO inboundVO) {
- //region 总单数据信息
- InboundResponse inboundResponse = inboundMapper.selectById(inboundVO.getIntoId());
- Inbound inbound = new Inbound();
- inbound.setIntoId(inboundResponse.getIntoId())
- .setIntoDate(null)
- .setIntoStatus(Constant.IntoStatus.RUKUZHONG.getName())
- .setIntoingQty(inboundResponse.getIntoQty())
- .setIntoingAmt(inboundResponse.getIntoAmt())
- .setIntoQty(BigDecimal.ZERO)
- .setIntoAmt(BigDecimal.ZERO);
- //修改
- inboundMapper.update(inbound,
- new UpdateWrapper<Inbound>().lambda()
- .eq(Inbound::getIntoId, UUID.fromString(inbound.getIntoId()))
- );
- //endregion
- //region 明细数据
- InboundItemQuery inboundItemQuery = new InboundItemQuery().setIntoId(inbound.getIntoId());
- //根据总单查明细
- List<InboundItemResponse> inboundItemResponseList = inboundItemMapper.selectByCond(inboundItemQuery);
- for (InboundItemResponse inboundItemResponse : inboundItemResponseList) {
- //region 将库存需要的参数赋值
- inboundItemResponse.setInventoryType(Constant.InventoryType.INBOUND.getName());
- inboundItemResponse.setInventoryDocCode(Constant.InventoryDocCode.OTHER_INBOUND.getValue());
- inboundItemResponse.setIntoQty(inboundItemResponse.getIntoQty().negate());
- inboundItemResponse.setIntoAmt(inboundItemResponse.getIntoAmt().negate());
- //region
- InboundItem inboundItem = new InboundItem();
- inboundItem
- .setIntoId(inbound.getIntoId())
- .setIntoStatus(Constant.IntoStatus.RUKUZHONG.getName())
- .setIntoingQty(inboundItemResponse.getInvQty())
- .setIntoingAmt(inboundItemResponse.getIntoAmt())
- .setIntoQty(BigDecimal.ZERO)
- .setIntoAmt(BigDecimal.ZERO)
- .setCostPrice(BigDecimal.ZERO)
- .setCostAmt(BigDecimal.ZERO)
- .setItemId(inboundItemResponse.getItemId());
- //修改
- inboundItemMapper.update(inboundItem,
- new UpdateWrapper<InboundItem>().lambda()
- .eq(InboundItem::getItemId, UUID.fromString(inboundItem.getItemId()))
- );
- //数量金额取反 用于给库存使用
- inboundItemResponse.setIntoQty(inboundItemResponse.getIntoQty().negate());
- inboundItemResponse.setIntoAmt(inboundItemResponse.getIntoAmt().negate());
- }
- //endregion
- //region 修改库存
- Map<String, Object> map = new HashMap<>();
- map.put("delIntoDetail", inboundItemResponseList);
- inventoryService.operatingInventoryInformation(map);
- //endregion
- return ResponseResultUtil.success();
- }
- /**
- * @desc : 入库状态通用(目前本页面)
- * @date : 2024/3/9 8:59
- * @author : 寇珊珊
- */
- @Transactional(rollbackFor = {Exception.class})
- public String setIntoStatus(BigDecimal intoingQty, BigDecimal intoQty) {
- //入库状态
- String intoStatus = null;
- //已入库数量>=0 入库中数量>0
- if (intoQty.compareTo(BigDecimal.ZERO) >= 0 && intoingQty.compareTo(BigDecimal.ZERO) > 0) {
- //入库中
- intoStatus = Constant.IntoStatus.RUKUZHONG.getName();
- }
- //已入库数量=0 入库中数量=0
- else if (intoQty.compareTo(BigDecimal.ZERO) == 0 && intoingQty.compareTo(BigDecimal.ZERO) == 0) {
- //待入库
- intoStatus = Constant.IntoStatus.DAIRUKU.getName();
- }
- //已入库数量>0 入库中数量=0
- else if (intoQty.compareTo(BigDecimal.ZERO) > 0 && intoingQty.compareTo(BigDecimal.ZERO) == 0) {
- //已入库
- intoStatus = Constant.IntoStatus.YIRUKU.getName();
- }
- return intoStatus;
- }
- /**
- * @desc : 条件查询 --- web端入库办理用
- * @date : 2024/3/23 9:24
- * @author : 寇珊珊
- */
- @Pagination
- public ResponseResultVO<PageList<InboundResponse>> selectInbound(InboundQuery inboundQuery) {
- return super.mergeListWithCount(inboundQuery, inboundMapper.selectInbound(inboundQuery),
- inboundMapper.selectInboundCond(inboundQuery));
- }
- /**
- * @desc : 查询明细查询 --- web端入库办理用
- * @date : 2024/3/9 15:43
- * @author : 寇珊珊
- */
- public ResponseResultVO<Map<String, Object>> selectInboundItem(String id) {
- Map<String, Object> result = new HashMap<>();
- // 商品明细
- List<InboundItemResponse> inboundItemResponses = inboundItemMapper.selectInboundItem(new InboundItemQuery().setIntoId(id));
- result.put("itemList", inboundItemResponses);
- // 收款
- // 附件
- return ResponseResultUtil.success(result);
- }
- /**
- * @desc : 查询待入库数量(小程序(我的))
- * @date : 2024/4/9 15:43
- * @author : 周兴
- */
- public ResponseResultVO<?> selectWaitInboundCount(InboundQuery inboundQuery) {
- return ResponseResultUtil.success(inboundMapper.selectInboundCond(inboundQuery));
- }
- }
|