zy-asrs.git - Gitblit

			@@ -6,10 +6,7 @@
			import com.core.common.SnowflakeIdWorker;
			import com.core.exception.CoolException;
			import com.zy.asrs.entity.*;
			import com.zy.asrs.entity.param.OpenOrderCompleteParam;
			import com.zy.asrs.entity.param.OpenOrderPakinParam;
			import com.zy.asrs.entity.param.OpenOrderPakoutParam;
			import com.zy.asrs.entity.param.PackParam;
			import com.zy.asrs.entity.param.*;
			import com.zy.asrs.entity.result.OpenOrderCompeteResult;
			import com.zy.asrs.entity.result.StockVo;
			import com.zy.asrs.mapper.TagMapper;
			@@ -51,7 +48,8 @@
			private TagService tagService;
			@Autowired
			private TagMapper tagMapper;

			@Autowired
			private WrkDetlService wrkDetlService;
			@Override
			@Transactional
			public void pakinOrderCreate(OpenOrderPakinParam param) {
			@@ -184,10 +182,15 @@
			}

			@Override
			@Transactional
			public void pakoutOrderCreate(OpenOrderPakoutParam param) {
			Order order = orderService.selectByNo(param.getOrderNo());
			// 如果单据不存在则添加；如果单据存在，作业中无法修改，反之则修改单据
			if (!Cools.isEmpty(order)) {
			throw new CoolException(param.getOrderNo() + "单据已存在，请勿重复提交");
			if (order.getSettle() > 1L) {
			throw new CoolException(param.getOrderNo() + "正在出库，无法修改单据");
			}
			orderService.remove(order.getId());
			}
			DocType docType = docTypeService.selectOrAdd(param.getOrderType(), Boolean.FALSE);
			Date now = new Date();
			@@ -333,7 +336,7 @@
			pack = new Pack(
			param.getBarcode(), // 条码[非空]
			analyse.getMatnr(), // 商品编号
			analyse.getBarcode(), // 批号
			analyse.getBarcode(), // 序列码
			1L, // 订单状态
			1, // 状态
			now, // 添加时间
			@@ -380,7 +383,7 @@
			null // 备注
			);
			if (tagMapper.insert(priTag) == 0) {
			throw new CoolException("保存一级分类失败");
			throw new CoolException("服务器内部错误，请联系管理员");
			}
			}
			// 二级分类
			@@ -410,7 +413,7 @@
			null // 备注
			);
			if (tagMapper.insert(secTag) == 0) {
			throw new CoolException("保存二级分类失败");
			throw new CoolException("服务器内部错误，请联系管理员");
			}
			}
			tagId = secTag.getId();
			@@ -433,4 +436,151 @@
			}
			}

			@Override
			@Transactional
			public void syncMat(MatSyncParam param) {
			if (Cools.isEmpty(param.getMatDetails()) \|\| param.getMatDetails().size() <=0 ) {
			throw new CoolException("商品数据为空");
			}

			for(MatSyncParam.MatParam matParam : param.getMatDetails()){
			if(Cools.isEmpty(matParam.getMatnr())){
			throw new CoolException("商品编码不能为空");
			}

			Date now = new Date();
			Mat mat = matService.selectByMatnr(matParam.getMatnr());
			if (mat == null) {
			mat = new Mat();
			// 分类
			Long tagId;
			// 一级分类
			if (!Cools.isEmpty(matParam.getGroupCode()) && !Cools.isEmpty(matParam.getGroupName())) {
			Tag priTag = tagService.selectByName(matParam.getGroupCode(), 2);
			if (priTag == null) {
			Tag top = tagService.getTop();
			NodeUtils nodeUtils = new NodeUtils();
			nodeUtils.executePath(top.getId());
			priTag = new Tag(
			null, // 编号
			matParam.getGroupCode(), // 名称
			top.getId(), // 父级
			top.getName(), // 父级名称
			nodeUtils.path.toString(), // 关联路径
			nodeUtils.pathName.toString(), // 关联路径名
			0, // 类型
			null, // 负责人
			null, // 图片
			null, // 简要描述
			null, // 数量
			2, // 等级
			null, // 排序
			1, // 状态
			now, // 添加时间
			null, // 添加人员
			now, // 修改时间
			null, // 修改人员
			null // 备注
			);
			if (tagMapper.insert(priTag) == 0) {
			throw new CoolException("服务器内部错误，请联系管理员");
			}
			}
			// 二级分类
			Tag secTag = tagService.selectByName(matParam.getGroupName(), 3);
			if (secTag == null) {
			NodeUtils nodeUtils = new NodeUtils();
			nodeUtils.executePath(priTag.getId());
			secTag = new Tag(
			null, // 编号
			matParam.getGroupName(), // 名称
			priTag.getId(), // 父级
			priTag.getName(), // 父级名称
			nodeUtils.path.toString(), // 关联路径
			nodeUtils.pathName.toString(), // 关联路径名
			0, // 类型
			null, // 负责人
			null, // 图片
			null, // 简要描述
			null, // 数量
			3, // 等级
			null, // 排序
			1, // 状态
			now, // 添加时间
			null, // 添加人员
			now, // 修改时间
			null, // 修改人员
			null // 备注
			);
			if (tagMapper.insert(secTag) == 0) {
			throw new CoolException("服务器内部错误，请联系管理员");
			}
			}
			tagId = secTag.getId();
			} else {
			tagId = tagService.getTop().getId();
			}
			mat.sync(param);
			// mat.setMatnr(param.getMatnr());
			// mat.setMaktx(param.getMaktx());
			// mat.setSpecs(param.getSpecs());
			// mat.setModel(param.getModel());

			mat.setTagId(tagId);
			mat.setStatus(1);
			mat.setCreateTime(now);
			mat.setUpdateTime(now);
			if (!matService.insert(mat)) {
			throw new CoolException("服务器内部错误，请联系管理员");
			} else {
			log.info("同步新物料[商品编号：{}]", mat.getMatnr());
			}
			} else {
			mat.sync(param);
			if (!matService.update(mat, new EntityWrapper<Mat>().eq("matnr",matParam.getMatnr()))) {
			throw new CoolException("更新已存在商品信息失败，请联系管理员");
			}
			}
			}

			}
			@Override
			@Transactional
			public List<PickWrkDetlListParam> getPickList(PdaPickListParam param) {
			List<WrkDetl> wrkDetls = wrkDetlService.findByBarcode(param.getBarcode());
			List<PickWrkDetlListParam> result = new ArrayList<>();
			wrkDetls.forEach(wrkDetl -> {
			Double total;
			EntityWrapper<LocDetl> wrapper = new EntityWrapper<>();
			LocDetl locDetl = locDetlService.selectOne(
			wrapper.eq("zpallet", wrkDetl.getZpallet())
			.eq("matnr", wrkDetl.getMatnr())
			);
			// 可拣总量：优先取库存表，否则取作业数量
			if (Cools.isEmpty(locDetl)) {
			total = wrkDetl.getAnfme();
			} else {
			total = locDetl.getAnfme();
			}
			// ===== 组装返回对象 =====
			PickWrkDetlListParam dto = new PickWrkDetlListParam();
			dto.setMatnr(wrkDetl.getMatnr());
			dto.setMaknx(wrkDetl.getMaktx());
			dto.setOrderNo(wrkDetl.getOrderNo());
			// dto.setBoxType3(wrkDetl.getBoxType3());
			// dto.setStandby1(wrkDetl.getStandby1());
			// dto.setStandby2(wrkDetl.getStandby2());
			// dto.setStandby3(wrkDetl.getStandby3());
			dto.setManu(wrkDetl.getManu());
			dto.setMemo(wrkDetl.getMemo());
			// 当前拣货数量
			dto.setCount(wrkDetl.getAnfme());
			// 可拣总数量
			dto.setTotal(total);
			result.add(dto);
			});

			return result;
			}

			}