package com.zy.asrs.task.handler; import com.core.common.DateUtils; import com.core.exception.CoolException; import com.zy.asrs.entity.DocType; import com.zy.asrs.entity.Order; import com.zy.asrs.entity.OrderDetl; import com.zy.asrs.service.ApiLogService; import com.zy.asrs.service.DocTypeService; import com.zy.asrs.service.OrderDetlService; import com.zy.asrs.service.OrderService; import com.zy.asrs.task.AbstractHandler; import com.zy.asrs.task.core.ReturnT; import com.zy.third.entity.ExdInstockTarget; import com.zy.third.entity.ExdOutstockTarget; import com.zy.third.service.ExdInstockTargetService; import com.zy.third.service.ExdOutstockTargetService; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.util.List; /** * Created by vincent on 2020/7/7 */ @Slf4j @Service public class OrderSyncHandler extends AbstractHandler { @Autowired private OrderService orderService; @Autowired private OrderDetlService orderDetlService; @Autowired private ApiLogService apiLogService; @Autowired private DocTypeService docTypeService; @Autowired private ExdInstockTargetService exdInstockTargetService; @Autowired private ExdOutstockTargetService exdOutstockTargetService; @Transactional public ReturnT start(Order order) { DocType docType = docTypeService.selectById(order.getDocType()); if (null == docType) { return SUCCESS; } List orderDetls = orderDetlService.selectByOrderId(order.getId()); // 入库完成上报 if (docType.getPakin() == 1) { ExdInstockTarget exdInstockTarge = null; for (OrderDetl orderDetl : orderDetls) { exdInstockTarge = new ExdInstockTarget(); exdInstockTarge.setFinterid(orderDetl.getDeadWarn()); exdInstockTarge.setFbillno(orderDetl.getOrderNo()); exdInstockTarge.setFtrantype(order.getDocType().intValue()); exdInstockTarge.setFdate(DateUtils.convert(order.getOrderTime())); exdInstockTarge.setFrob(orderDetl.getInspect()); exdInstockTarge.setFuserid(Integer.getInteger(orderDetl.getColor())); exdInstockTargetService.insert(exdInstockTarge); if (!orderService.updateSettle(order.getId(), 6L, null)) { throw new CoolException("服务器内部错误,请联系管理员"); } } } else if (docType.getPakout() == 1) { // 出库完成上报 ExdOutstockTarget exdOutstockTarget = null; for (OrderDetl orderDetl : orderDetls) { exdOutstockTarget = new ExdOutstockTarget(); exdOutstockTargetService.insert(exdOutstockTarget); if (!orderService.updateSettle(order.getId(), 6L, null)) { throw new CoolException("服务器内部错误,请联系管理员"); } } } return SUCCESS; } }