wms-cloud.git - Gitblit

			@@ -9,15 +9,20 @@
			import org.springframework.beans.factory.annotation.Autowired;
			import org.springframework.stereotype.Service;
			import org.springframework.transaction.annotation.Transactional;
			import zy.cloud.wms.common.model.BillDto;
			import zy.cloud.wms.common.model.OrderStoDto;
			import zy.cloud.wms.common.service.MainService;
			import zy.cloud.wms.common.service.asrs.AsrsService;
			import zy.cloud.wms.common.service.erp.ErpService;
			import zy.cloud.wms.common.utils.VersionUtils;
			import zy.cloud.wms.manager.entity.*;
			import zy.cloud.wms.manager.entity.param.*;
			import zy.cloud.wms.manager.entity.result.StoPrintVo;
			import zy.cloud.wms.manager.service.*;

			import java.util.ArrayList;
			import java.util.Date;
			import java.util.Iterator;
			import java.util.List;

			/**
			@@ -42,6 +47,12 @@
			private SnowflakeIdWorker snowflakeIdWorker;
			@Autowired
			private MatService matService;
			@Autowired
			private AsrsService asrsService;
			@Autowired
			private ErpService erpService;
			@Autowired
			private CheckService checkService;

			@Override
			@Transactional
			@@ -55,6 +66,17 @@
			return R.error("物料不存在");
			}
			Date now = new Date();
			String docNum = String.valueOf(snowflakeIdWorker.nextId());
			switch (param.getDocType()) {
			case 34: // 采购单
			docNum = "PU-" + String.valueOf(snowflakeIdWorker.nextId()).substring(0, 15);
			break;
			case 45: // 销售退货单
			docNum = "SR-" + String.valueOf(snowflakeIdWorker.nextId()).substring(0, 15);
			break;
			default:
			break;
			}
			for (Comb comb : combs) {
			// 改变组托档状态
			comb.setIoStatus(4);
			@@ -73,6 +95,8 @@
			locDetl.setZpallet(param.getZpallet());
			locDetl.setAnfme(comb.getAnfme());
			VersionUtils.setLocDetl(locDetl, comb);
			locDetl.setDocId(param.getDocType().longValue());
			locDetl.setDocNum(docNum);
			locDetl.setStatus(1);
			locDetl.setCreateBy(userId);
			locDetl.setCreateTime(now);
			@@ -90,6 +114,19 @@
			}

			}

			// 上报给erp
			List<BillDto> dtos = new ArrayList<>();
			for (Comb comb : combs) {
			BillDto billDto = new BillDto();
			billDto.setMatnr(comb.getMatnr());
			billDto.setQty(comb.getAnfme());
			dtos.add(billDto);
			}
			if (!erpService.uploadBill(dtos, param.getDocType(), docNum)) {
			throw new CoolException("无法上报至erp");
			}

			return R.ok();
			}

			@@ -170,6 +207,21 @@
			// 修改单据状态
			if (!custOrderService.updateStatus(param.getNumber(), 4)) {
			throw new CoolException("修改单据状态失败");
			}
			// 采购退货单
			if (param.getNumber().startsWith("PR-")) {
			List<BillDto> dtos = new ArrayList<>();
			for (Pakout pakout : pakouts) {
			BillDto billDto = new BillDto();
			billDto.setMatnr(pakout.getMatnr());
			billDto.setQty(pakout.getAnfme());
			dtos.add(billDto);
			}
			// erp单据上传 -- 采购退货单
			if (!erpService.uploadBill(dtos, 6, pakouts.get(0).getDocNum())) {
			throw new CoolException("无法上报至erp");
			}

			}
			return R.ok();
			}
			@@ -313,6 +365,7 @@
			null, // 经手人编号[空]
			dto.getMatnr(), // 商品编号
			dto.getCount(), // 商品数量
			dto.getCount(), // 总数量
			Cools.isEmpty(mat.getName())?0.0D:Double.parseDouble(mat.getName()), // 商品单价
			null, // 商品备注[空]
			1, // 状态
			@@ -327,4 +380,165 @@
			return R.ok("生成销售订单" + param.getNumber() + "成功");
			}

			@Override
			@Transactional
			public R stockTransfer(String number, Long userId) {
			List<CustOrder> custOrders = custOrderService.selectList(new EntityWrapper<CustOrder>().eq("number", number).eq("status", 1));
			boolean asrs = false;
			List<StockTransferParam> params = new ArrayList<>();
			for (CustOrder custOrder : custOrders) {
			Double count = locDetlService.selectCountByMatnr(custOrder.getUserCode());
			if (count == null) {
			count = 0.0D;
			}
			if (count < custOrder.getQty()) {
			if (!asrs) { asrs = true; }
			StockTransferParam param = new StockTransferParam();
			param.setMatnr(custOrder.getUserCode());
			param.setAnfme(custOrder.getQty() - count);
			params.add(param);
			}
			}
			if (asrs) {
			// if (asrsService.stockTransfer(params)) {
			// for (StockTransferParam param : params) {
			// // 修改销售订单待出数量
			// if (!custOrderService.updateQty(number, param.getMatnr(), param.getAnfme())) {
			// throw new CoolException("修改销售订单待出数量失败");
			// }
			// }
			// return R.ok("库存调拨成功");
			// } else {
			// return R.error("立库调拨失败，请联系管理员");
			// }
			}
			return R.error("暂不缺货，不需要立库调拨");
			}

			@Override
			public R stockCheck(StoCheckParam param, Long userId) {
			if (Cools.isEmpty(param.getLocNo())) {
			return R.error("请选择货位");
			}
			Node node = nodeService.selectByUuid(param.getLocNo());
			if (Cools.isEmpty(node)) {
			return R.error("货位异常,请联系管理员");
			}
			// 准备数据
			Date now = new Date();
			List<LocDetl> locDetls = locDetlService.selectList(new EntityWrapper<LocDetl>().eq("node_id", node.getId()));
			List<String> locDetlMatnrs = new ArrayList<>();
			locDetls.forEach(locDetl -> locDetlMatnrs.add(locDetl.getMatnr()));
			Iterator<LocDetl> detlIterator = locDetls.iterator();
			List<PakinMatDto> dtos = param.getDtos();

			// 1.盈亏修改数量
			while (detlIterator.hasNext()){
			LocDetl locDetl = detlIterator.next();
			for (PakinMatDto dto : dtos) {
			if (locDetl.getMatnr().equals(dto.getMatnr())) {
			if (!locDetl.getAnfme().equals(dto.getCount())) {
			Check check = new Check(
			String.valueOf(snowflakeIdWorker.nextId()), // 盘点编号
			node.getId(), // 盘点货位
			node.getUuid(), // 货位编号
			node.getName(), // 货位名称
			locDetl.getMatnr(), // 商品编号
			locDetl.getMaktx(), // 商品名称
			locDetl.getUnit(), // 单位
			null, // 单据类型
			null, // 单据编号
			locDetl.getAnfme(), // 账面数量
			dto.getCount(), // 实盘数量
			dto.getCount() - locDetl.getAnfme(), // 差值
			locDetl.getAnfme() < dto.getCount() ? 1 : 2, // 盈亏
			1, // 状态
			userId, // 添加人员
			now, // 添加时间
			userId, // 修改人员
			now, // 修改时间
			null // 备注
			);
			if (!checkService.insert(check)) {
			throw new CoolException("保存盘点记录失败");
			}
			}
			detlIterator.remove();
			break;
			}
			}
			}

			// 2.盘亏删除库存
			for (LocDetl locDetl : locDetls) {
			Check check = new Check(
			String.valueOf(snowflakeIdWorker.nextId()), // 盘点编号
			node.getId(), // 盘点货位
			node.getUuid(), // 货位编号
			node.getName(), // 货位名称
			locDetl.getMatnr(), // 商品编号
			locDetl.getMaktx(), // 商品名称
			locDetl.getUnit(), // 单位
			null, // 单据类型
			null, // 单据编号
			locDetl.getAnfme(), // 账面数量
			0D, // 实盘数量
			0D - locDetl.getAnfme(), // 差值
			2, // 盈亏
			1, // 状态
			userId, // 添加人员
			now, // 添加时间
			userId, // 修改人员
			now, // 修改时间
			null // 备注
			);
			if (!checkService.insert(check)) {
			throw new CoolException("保存盘点记录失败");
			}

			}

			// 3.盘盈新增库存
			for (PakinMatDto dto : dtos) {
			if (!locDetlMatnrs.contains(dto.getMatnr())) {
			Mat mat = matService.selectByMatnr(dto.getMatnr());
			Check check = new Check(
			String.valueOf(snowflakeIdWorker.nextId()), // 盘点编号
			node.getId(), // 盘点货位
			node.getUuid(), // 货位编号
			node.getName(), // 货位名称
			mat.getMatnr(), // 商品编号
			mat.getMaktx(), // 商品名称
			mat.getUnit(), // 单位
			null, // 单据类型
			null, // 单据编号
			0D, // 账面数量
			dto.getCount(), // 实盘数量
			dto.getCount() - 0D, // 差值
			1, // 盈亏
			1, // 状态
			userId, // 添加人员
			now, // 添加时间
			userId, // 修改人员
			now, // 修改时间
			null // 备注
			);
			if (!checkService.insert(check)) {
			throw new CoolException("保存盘点记录失败");
			}

			}
			}

			return R.ok();
			}

			@Override
			public R stockCheckAuditing(Long checkId, Long userId) {



			return R.ok();
			}

			}