package com.chinaztt.mes.plan.service.impl; import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.date.DateUtil; import cn.hutool.core.io.FileUtil; import cn.hutool.core.io.IoUtil; import cn.hutool.core.util.BooleanUtil; import cn.hutool.core.util.StrUtil; import cn.hutool.http.HttpRequest; import com.alibaba.excel.EasyExcel; import com.alibaba.excel.ExcelWriter; import com.alibaba.excel.write.metadata.WriteSheet; import com.alibaba.excel.write.style.column.LongestMatchColumnWidthStyleStrategy; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.serializer.SerializerFeature; import com.anji.captcha.service.CaptchaCacheService; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.toolkit.StringUtils; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.chinaztt.ifs.api.feign.IfsFeignClient; import com.chinaztt.mes.basic.entity.Part; import com.chinaztt.mes.basic.mapper.PartMapper; import com.chinaztt.mes.basic.mapper.StaffMapper; import com.chinaztt.mes.basic.mapper.UserServiceMapper; import com.chinaztt.mes.basic.util.RedisUtils; import com.chinaztt.mes.common.handler.StateMachineHandler; import com.chinaztt.mes.common.numgen.NumberGenerator; import com.chinaztt.mes.common.oa.OAProcess; import com.chinaztt.mes.common.oa.OAProperty; import com.chinaztt.mes.common.oa.OAResult; import com.chinaztt.mes.common.util.StateResult; import com.chinaztt.mes.common.util.WechatMsgTips; import com.chinaztt.mes.common.wechat.WechatProperty; import com.chinaztt.mes.plan.dto.*; import com.chinaztt.mes.plan.entity.*; import com.chinaztt.mes.plan.excel.CustomerOrderData; import com.chinaztt.mes.plan.mapper.*; import com.chinaztt.mes.plan.service.*; import com.chinaztt.mes.plan.state.auditstate.constant.AuditStateStringValues; import com.chinaztt.mes.plan.state.orderstate.CustomerOrderStateMachineConfig; import com.chinaztt.mes.plan.state.orderstate.constant.CustomerOrderEvents; import com.chinaztt.mes.plan.state.orderstate.constant.CustomerOrderStateStringValues; import com.chinaztt.mes.plan.state.orderstate.constant.CustomerOrderStates; import com.chinaztt.mes.plan.util.CustomerOrderClientConfigure; import com.chinaztt.mes.plan.util.CustomerOrderUnitWhiteListConfig; import com.chinaztt.mes.plan.util.CustomerOrderUtil; import com.chinaztt.mes.plan.util.FileSaveUtil; import com.chinaztt.mes.plan.vo.CustomerOrderVO1; import com.chinaztt.mes.quality.dto.CustomOrderSyncDTO; import com.chinaztt.mes.technology.entity.*; import com.chinaztt.mes.technology.mapper.*; import com.chinaztt.mes.technology.service.DocumentService; import com.chinaztt.mes.technology.state.bom.constant.BomStates; import com.chinaztt.mes.technology.state.document.constant.DocumentStateStringValues; import com.chinaztt.mes.technology.state.document.constant.DocumentStates; import com.chinaztt.mes.technology.state.routing.constant.RoutingStates; import com.chinaztt.mes.warehouse.dto.PackagingDTO; import com.chinaztt.mes.warehouse.entity.Packaging; import com.chinaztt.mes.warehouse.entity.Stock; import com.chinaztt.mes.warehouse.mapper.PackagingMapper; import com.chinaztt.ztt.admin.api.feign.RemoteParamService; import com.chinaztt.ztt.common.core.constant.SecurityConstants; import com.chinaztt.ztt.common.core.util.R; import com.chinaztt.ztt.common.oss.OssProperties; import com.chinaztt.ztt.common.oss.service.OssTemplate; import com.chinaztt.ztt.common.security.util.SecurityUtils; import com.google.gson.Gson; import com.xxl.job.core.context.XxlJobHelper; import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.apache.http.HttpEntity; import org.apache.http.client.methods.CloseableHttpResponse; import org.apache.http.client.methods.HttpPost; import org.apache.http.entity.ContentType; import org.apache.http.entity.StringEntity; import org.apache.http.impl.client.CloseableHttpClient; import org.apache.http.impl.client.HttpClientBuilder; import org.apache.http.util.EntityUtils; import org.springframework.beans.BeanUtils; import org.springframework.core.env.Environment; import org.springframework.dao.DuplicateKeyException; import org.springframework.messaging.Message; import org.springframework.messaging.support.MessageBuilder; import org.springframework.scheduling.annotation.Async; import org.springframework.statemachine.config.StateMachineFactory; import org.springframework.statemachine.persist.StateMachinePersister; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.interceptor.TransactionAspectSupport; import org.springframework.web.multipart.MultipartFile; import javax.servlet.http.HttpServletResponse; import java.io.File; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.math.BigDecimal; import java.math.RoundingMode; import java.net.URLEncoder; import java.time.LocalDateTime; import java.time.ZoneId; import java.time.format.DateTimeFormatter; import java.util.*; import java.util.regex.Pattern; import java.util.stream.Collectors; /** * 客户订单表 * * @author cxf * @date 2020-09-14 16:35:26 */ @Slf4j @Service @AllArgsConstructor @Transactional(rollbackFor = Exception.class) public class CustomerOrderServiceImpl extends ServiceImpl implements CustomerOrderService { private BomComponentMapper bomComponentMapper; private BomMapper bomMapper; private CustomerOrderUnitWhiteListConfig customerOrderUnitWhiteListConfig; private CustomerOrderParamMapper customerOrderParamMapper; private CustomerOrderParamJointStockCompanyMapper customerOrderParamJointStockCompanyMapper; private CustomerOrderUtil customerOrderUtil; private CustomerMapper customerMapper; private DocumentMapper documentMapper; private DocumentService documentService; private OrderParamMapper orderParamMapper; private OAProperty oaProperty; private OrderParamService orderParamService; private OperationTaskProduceMapper operationTaskProduceMapper; private IfsFeignClient ifsFeignClient; private JoinModelCustomerMapper joinModelCustomerMapper; private JoinDocumentBomRoutingMapper joinDocumentBomRoutingMapper; private MpsRequirementsMapper mpsRequirementsMapper; private MasterProductionScheduleMapper masterProductionScheduleMapper; private MasterProductionScheduleTheoryQuantityMapper masterProductionScheduleTheoryQuantityMapper; private NumberGenerator numberGenerator; private NumberGenerator scheduleNumberGenerator; private PartMapper partMapper; private PlanJoinOrderRequirementsMapper planJoinOrderRequirementsMapper; private RoutingMapper routingMapper; private StateMachineFactory customerOrderStateMachineFactory; private StateMachinePersister persister; private CustomerOrderClientConfigure customerOrderClientConfigure; private CaptchaCacheService captchaCacheService; private CustomerForJointStockCompanyMapper customerForJointStockCompanyMapper; private CustomerOrderForJointStockCompanyMapper customerOrderForJointStockCompanyMapper; private OrderProcessConfigFileMapper orderProcessConfigFileMapper; private ProcessConfigFileOrderMappingMapper processConfigFileOrderMappingMapper; private ProcessConfigFileOrderMappingService processConfigFileOrderMappingService; private CustomerOrderMapper customerOrderMapper; private RedisUtils redisUtils; private ProcessConfigService processConfigService; private ProcessConfigMapper processConfigMapper; private DocumentJgtMapper documentJgtMapper; private PackageCodeCustomerOrderRelationService packageCodeCustomerOrderRelationService; private PackageCodeCustomerOrderRelationMapper packageCodeCustomerOrderRelationMapper; private PackagingMapper packagingMapper; private RemoteParamService remoteParamService; private StaffMapper staffMapper; private WechatProperty wechatProperty; private UserServiceMapper userServiceMapper; private final OssProperties ossProperties; private final OssTemplate minioTemplate; private final String PART_PROPERTY = "PART_PROPERTY"; private final static String MO_RETURN_STAFF = "MO_RETURN_STAFF"; private Environment environment; private final static String OTC_MAIN_STATUS_CANCEL = "已取消"; private final static String OTC_MAIN_STATUS_TRANSMIT = "已下达"; private final static String AFFILIATED_CONTRACT = "中天注塑厂"; //private FileSaveUtil fileSaveUtil; @Override public void otcDownload(Long id, HttpServletResponse response) { customerOrderUtil.otcDownLoadFiles(id, response); } @Override public boolean createMpsRequirements(List mpsRequirementsList) { try { for (MpsRequirementsDTO mpsRequirementsDTO : mpsRequirementsList) { // 1.保存主生产计划需求计划 mpsRequirementsDTO.setIndeRequNo(numberGenerator.generateNumberWithPrefix(MpsRequirements.DIGIT, MpsRequirements.PREFIX, MpsRequirements::getIndeRequNo)); mpsRequirementsDTO.setSourceType("02"); mpsRequirementsMapper.insert(mpsRequirementsDTO); // 2.保存关联表 planJoinOrderRequirementsMapper.insert(new PlanJoinOrderRequirements(mpsRequirementsDTO.getCustomerOrderId(), mpsRequirementsDTO.getId())); } } catch (Exception e) { throw new RuntimeException("创建主计划失败"); } return true; } @Override public IPage getCustomerOrderPage(Page page, QueryWrapper planCustomerOrder, String type) { //ZttUser currentUser = SecurityUtils.getUser(); ////获取员工id //Long staffId = userServiceMapper.selectById(currentUser.getId()).getStaffId(); return customerOrderMapper.getCustomerOrderPage(page, planCustomerOrder); } @Override public boolean changeMarkPlanned(List ids, String coState) { // changeCoState(ids, event); for (Long id : ids) { CustomerOrder customerOrder = baseMapper.selectById(id); customerOrder.setCoState(coState); if (coState.equals(CustomerOrderStateStringValues.CANCEL)) { if (!CustomerOrderStateStringValues.CANCEL.equals(customerOrder.getCoState())) { List joinModelCustomers = joinModelCustomerMapper.selectList(Wrappers.lambdaQuery() .eq(JoinModelCustomer::getModel, "plan_master_production_schedule") .eq(JoinModelCustomer::getCustomerOrderId, customerOrder.getId())); if (CollectionUtil.isNotEmpty(joinModelCustomers)) { throw new RuntimeException(customerOrder.getCustomerOrderNo() + "已存在生产计划，作废失败"); } } } baseMapper.updateById(customerOrder); } return true; } /** * 改变状态 * * @param customerOrder * @param */ private void changeAudit(CustomerOrder customerOrder, String isAudit) { //审核状态 通过 订单状态待计划 if (isAudit.equals(AuditStateStringValues.ACCEPTED)) { //TODO: 要加零件id参数 Document document = documentMapper.selectById(customerOrder.getTechnologyDocumentId()); Part part = partMapper.selectOne(Wrappers.lambdaQuery().eq(Part::getEngChgLevel, "1").eq(Part::getId,customerOrder.getPartId() )); if (null == part) { throw new RuntimeException("根据零件编号 = 【" + customerOrder.getPartNo() + "】MES本地查无匹配零件对象"); } if (!part.getMaterialType().equals("3") && null == document) { throw new RuntimeException("缺少工艺文件"); } customerOrder.setCoState(CustomerOrderStateStringValues.PLAN); docAccept(customerOrder, document); } //审核状态 草稿 订单状态待计划 if (isAudit.equals(AuditStateStringValues.DRAFT)) { if (!CustomerOrderStateStringValues.CANCEL.equals(customerOrder.getCoState())) { List joinModelCustomers = joinModelCustomerMapper.selectList(Wrappers.lambdaQuery() .eq(JoinModelCustomer::getModel, "plan_master_production_schedule") .eq(JoinModelCustomer::getCustomerOrderId, customerOrder.getId())); if (CollectionUtil.isNotEmpty(joinModelCustomers)) { throw new RuntimeException(customerOrder.getCustomerOrderNo() + "已存在生产计划，取消失败"); } } customerOrder.setIsAudit(isAudit); customerOrder.setCoState(CustomerOrderStateStringValues.PLAN); baseMapper.updateById(customerOrder); } } @Override public R fullUpdate(CustomerOrderVO1 customerOrderVO1) { CustomerOrder customerOrder = new CustomerOrder(); BeanUtils.copyProperties(customerOrderVO1,customerOrder); customerOrder.setId(customerOrderVO1.getId()); customerOrderMapper.updateById(customerOrder); Customer customer = new Customer(); BeanUtils.copyProperties(customerOrderVO1,customer); customer.setId(customerOrderMapper.selectById(customerOrderVO1.getId()).getCustomerId()); customerMapper.updateById(customer); return R.ok("修改成功!"); } @Override public boolean updateOrderDescription(CustomerOrderDTO customerOrderDTO) { CustomerOrder customerOrder = baseMapper.selectById(customerOrderDTO.getId()); customerOrder.setOrderDescription(customerOrderDTO.getOrderDescription()); if (customerOrder.getCoState().equals(CustomerOrderStateStringValues.UNIEDIT)) { customerOrder.setCoState(CustomerOrderStateStringValues.PARTUNCHECKED); } baseMapper.updateById(customerOrder); return true; } @Override public CustomerOrderVO1 getCustomerOrderById(Long id) { CustomerOrderVO1 customerOrderVO1 = new CustomerOrderVO1(); //销售产品单(客户行表) CustomerOrder customerOrder = baseMapper.selectById(id); BeanUtils.copyProperties(customerOrder, customerOrderVO1); //客户主表 Customer customer = customerMapper.selectById(customerOrder.getCustomerId()); BeanUtils.copyProperties(customer,customerOrderVO1); if (customerOrder.getTechnologyDocumentId() != null) { Document document = documentMapper.selectById(customerOrder.getTechnologyDocumentId()); if (document != null) { //工艺文件编号 customerOrderVO1.setDocNumber(document.getNumber()); //工艺文件名称 customerOrderVO1.setDocName(document.getName()); } } customerOrderVO1.setId(id); return customerOrderVO1; } @Override public R createScheduleCheck(List customerOrderDTOList) { for (CustomerOrderDTO customerOrder : customerOrderDTOList) { if (!customerOrder.getBuyQtyDue().equals(customerOrder.getQtyPlaned())) { return R.ok(CreateScheduleDTO.builder().success(Boolean.FALSE).message("计划数量与需求数量不一致").build()); } } return R.ok(CreateScheduleDTO.builder().success(Boolean.TRUE).build()); } @Override public boolean createMasterProductionSchedule(List customerOrderDTOList) { List ids = customerOrderDTOList.stream().map(CustomerOrderDTO::getId).collect(Collectors.toList()); Integer count = getBaseMapper().selectCount(Wrappers.lambdaQuery() .ne(CustomerOrder::getIsAudit, AuditStateStringValues.ACCEPTED) .in(CustomerOrder::getId, ids)); if (count > 0) { throw new RuntimeException("未通过订单不可创建生产计划"); } if (CollectionUtil.isEmpty(customerOrderDTOList)) { throw new RuntimeException("请选择客户订单"); } int check = this.count(Wrappers.lambdaQuery().in(CustomerOrder::getId, ids) .eq(CustomerOrder::getCoState, CustomerOrderStateStringValues.PLANED)); if (check > 0) { throw new RuntimeException("已下发的订单不可重复创建主计划"); } for (CustomerOrderDTO customerOrderDTO : customerOrderDTOList) { BigDecimal qta = customerOrderDTO.getQtyPlaned(); //修改工单分段SN号数据 （2023-03-17 旧分段逻辑不再使用） // List operationTaskProduceList = customerOrderDTO.getOutPutBatchList(); // if (CollectionUtil.isNotEmpty(operationTaskProduceList)) { // qta = operationTaskProduceList.stream().map(OperationTaskProduce::getQty).reduce(BigDecimal.ZERO, BigDecimal::add); // } //保存主生产计划 MasterProductionSchedule masterProductionSchedule = new MasterProductionSchedule(); //主生产计划号 masterProductionSchedule.setMpsNo(scheduleNumberGenerator.generateNumberWithPrefix(MasterProductionSchedule.DIGIT, MasterProductionSchedule.PREFIX, MasterProductionSchedule::getMpsNo)); Part part = partMapper.selectOne(Wrappers.lambdaQuery().eq(Part::getPartNo, customerOrderDTO.getPartNo())); //零件id masterProductionSchedule.setPartId(part.getId()); //将审核状态和工艺文件的id同步给生产计划 masterProductionSchedule.setIsAudit(customerOrderDTO.getIsAudit()); masterProductionSchedule.setTechnologyDocumentId(customerOrderDTO.getTechnologyDocumentId()); masterProductionSchedule.setManufactureAttr(customerOrderDTO.getManufactureAttr()); masterProductionSchedule.setDocNumber(customerOrderDTO.getDocNumber()); //需求数量 masterProductionSchedule.setQtyRequired(qta); //需求日期 masterProductionSchedule.setRequiredDate(customerOrderDTO.getDeliveryDate()); //备注 masterProductionSchedule.setRemark(customerOrderDTO.getRemark()); masterProductionSchedule.setQtyRequired(qta); masterProductionSchedule.setRequiredDate(customerOrderDTO.getWantedDeliveryDate()); masterProductionSchedule.setRemark(customerOrderDTO.getRemark()); masterProductionSchedule.setSource("销售订单"); masterProductionScheduleMapper.insert(masterProductionSchedule); customerOrderDTO.setRequireNumber(customerOrderDTO.getQtyPlaned()); // if (CollectionUtil.isNotEmpty(operationTaskProduceList)) { // for (OperationTaskProduce operationTaskProduce : operationTaskProduceList) { // operationTaskProduce.setMpsId(masterProductionSchedule.getId()); // operationTaskProduceMapper.updateById(operationTaskProduce); // } // } //更新客户订单的下发数量 customerOrderDTO.setRequireNumber(customerOrderDTO.getRequireNumber().add(customerOrderDTO.getQtyPlaned())); if (customerOrderDTO.getRequireNumber().compareTo(customerOrderDTO.getBuyQtyDue()) >= 0) {//已下发数量等于销售数量（小于销售数量不能更改状态），状态应该更新为已计划。目前状态依旧为待计划。 customerOrderDTO.setCoState(CustomerOrderStateStringValues.PLANED); } baseMapper.updateById(customerOrderDTO); //计算半成品用量 calPlanTheory(masterProductionSchedule); //保存主计划与客户订单的关系 JoinModelCustomer joinModelCustomer = new JoinModelCustomer(); joinModelCustomer.setCustomerOrderId(customerOrderDTO.getId()); joinModelCustomer.setModel("plan_master_production_schedule"); joinModelCustomer.setModelId(masterProductionSchedule.getId()); joinModelCustomerMapper.insert(joinModelCustomer); } return true; } //多个销售订单创建一个主生产计划 @Override public MasterProductionSchedule createOneMasterProductionScheduleByCustomerOrders(List customerOrders) { List ids = customerOrders.stream().map(CustomerOrderDTO::getId).collect(Collectors.toList()); Integer count = getBaseMapper().selectCount(Wrappers.lambdaQuery() .ne(CustomerOrder::getIsAudit, AuditStateStringValues.ACCEPTED) .in(CustomerOrder::getId, ids)); if (count > 0) { throw new RuntimeException("未通过订单不可创建生产计划"); } if (CollectionUtil.isEmpty(customerOrders)) { throw new RuntimeException("请选择客户订单"); } //保存主生产计划 MasterProductionSchedule masterProductionSchedule = new MasterProductionSchedule(); masterProductionSchedule.setMpsNo(scheduleNumberGenerator.generateNumberWithPrefix(MasterProductionSchedule.DIGIT, MasterProductionSchedule.PREFIX, MasterProductionSchedule::getMpsNo)); BigDecimal qta = BigDecimal.ZERO; List updateOperationTaskProduceList = new ArrayList<>(); for (CustomerOrderDTO customerOrderDTO : customerOrders) { updateOperationTaskProduceList.addAll(customerOrderDTO.getOutPutBatchList()); qta = qta.add(customerOrderDTO.getQtyPlaned()); masterProductionSchedule.setPartId(customerOrderDTO.getPartId()); //将审核状态和工艺文件的id同步给生产计划 masterProductionSchedule.setIsAudit(customerOrderDTO.getIsAudit()); masterProductionSchedule.setTechnologyDocumentId(customerOrderDTO.getTechnologyDocumentId()); masterProductionSchedule.setManufactureAttr(customerOrderDTO.getManufactureAttr()); // 查询工艺文件编号 Document document = this.documentMapper.selectById(customerOrderDTO.getTechnologyDocumentId()); masterProductionSchedule.setDocNumber(document.getNumber()); // 取最近的交货日期 if (masterProductionSchedule.getRequiredDate() == null) { masterProductionSchedule.setRequiredDate(customerOrderDTO.getWantedDeliveryDate()); } else { if (masterProductionSchedule.getRequiredDate().compareTo(customerOrderDTO.getWantedDeliveryDate()) > 0) { masterProductionSchedule.setRequiredDate(customerOrderDTO.getWantedDeliveryDate()); } } // 订单备注进行拼接 if (masterProductionSchedule.getRemark() == null) { masterProductionSchedule.setRemark(customerOrderDTO.getRemark()); } else { masterProductionSchedule.setRemark(masterProductionSchedule.getRemark() + " " + customerOrderDTO.getRemark()); } masterProductionSchedule.setSource("销售订单"); // 更新销售订单状态为已下发 customerOrderDTO.setCoState(CustomerOrderStateStringValues.PLANED); baseMapper.updateById(customerOrderDTO); } masterProductionSchedule.setQtyRequired(qta); masterProductionScheduleMapper.insert(masterProductionSchedule); // 更新批次表的生产计划id if (CollectionUtil.isNotEmpty(updateOperationTaskProduceList)) { for (OperationTaskProduce operationTaskProduce : updateOperationTaskProduceList) { operationTaskProduce.setMpsId(masterProductionSchedule.getId()); operationTaskProduceMapper.updateById(operationTaskProduce); } } //计算半成品用量 calPlanTheory(masterProductionSchedule); // 这里只生成一个关联关系 // 保存主计划与客户订单的关系 JoinModelCustomer joinModelCustomer = new JoinModelCustomer(); joinModelCustomer.setCustomerOrderId(customerOrders.get(0).getId()); joinModelCustomer.setModel("plan_master_production_schedule"); joinModelCustomer.setModelId(masterProductionSchedule.getId()); joinModelCustomerMapper.insert(joinModelCustomer); return masterProductionSchedule; } /** * 创建生产计划半成品用量 * * @param masterProductionSchedule 生产计划 */ @Override public void calPlanTheory(MasterProductionSchedule masterProductionSchedule) { if (null == masterProductionSchedule.getTechnologyDocumentId()) { return; } Document document = documentMapper.selectById(masterProductionSchedule.getTechnologyDocumentId()); if (null == document) { return; } Long docId = document.getId(); //查询成品的BOM JoinDocumentBomRouting joinDocumentBomRouting = joinDocumentBomRoutingMapper.selectOne(Wrappers.lambdaQuery() .eq(JoinDocumentBomRouting::getDocumentId, docId).isNull(JoinDocumentBomRouting::getParentId)); MasterProductionScheduleTheoryQuantity masterProductionScheduleTheoryQuantity = new MasterProductionScheduleTheoryQuantity(); masterProductionScheduleTheoryQuantity.setPartId(masterProductionSchedule.getPartId()); masterProductionScheduleTheoryQuantity.setQuantity(masterProductionSchedule.getQtyRequired()); masterProductionScheduleTheoryQuantity.setMid(masterProductionSchedule.getId()); masterProductionScheduleTheoryQuantity.setBomId(joinDocumentBomRouting.getBomId()); masterProductionScheduleTheoryQuantity.setRoutingId(joinDocumentBomRouting.getRoutingId()); masterProductionScheduleTheoryQuantity.setJoinDocBomRoutingId(joinDocumentBomRouting.getId()); masterProductionScheduleTheoryQuantity.setIsMaster(true); masterProductionScheduleTheoryQuantityMapper.insert(masterProductionScheduleTheoryQuantity); List joinDocumentBomRoutingChildList = joinDocumentBomRoutingMapper.selectList(Wrappers.lambdaQuery() .eq(JoinDocumentBomRouting::getParentId, joinDocumentBomRouting.getId())); calPlanTheory(masterProductionScheduleTheoryQuantity, joinDocumentBomRoutingChildList, joinDocumentBomRouting.getBomId()); } /** * @param mfather 新增父产品的理论用量数据 * @param joinDocumentBomRoutingChildList 子节点半成品 * @param bomId 父节点的bomId */ private void calPlanTheory(MasterProductionScheduleTheoryQuantity mfather, List joinDocumentBomRoutingChildList, Long bomId) { //查询半成品的子节点 for (JoinDocumentBomRouting jchild : joinDocumentBomRoutingChildList) { // 根据父bom的id 和 当前零件的partid 查询零件用量 List bomComponentList = bomComponentMapper.selectList(Wrappers.lambdaQuery() .eq(BomComponent::getBomId, bomId).eq(BomComponent::getPartId, jchild.getPartId())); if (bomComponentList.size() > 0) { BomComponent bomComponent = bomComponentList.get(0); if (bomComponent.getQpa() != null) { MasterProductionScheduleTheoryQuantity mchild = new MasterProductionScheduleTheoryQuantity(); mchild.setPartId(bomComponent.getPartId()); mchild.setRoutingId(jchild.getRoutingId()); mchild.setBomId(jchild.getBomId()); mchild.setQuantity(bomComponent.getQpa().multiply(mfather.getQuantity())); mchild.setMid(mfather.getMid()); mchild.setJoinDocBomRoutingId(jchild.getId()); masterProductionScheduleTheoryQuantityMapper.insert(mchild); List list = joinDocumentBomRoutingMapper.selectList(Wrappers.lambdaQuery().eq(JoinDocumentBomRouting::getParentId, jchild.getId())); calPlanTheory(mchild, list, jchild.getBomId()); } } } } @Override public void changeCoState(List ids, String event) { for (Long id : ids) { CustomerOrder customerOrder = baseMapper.selectById(id); Message message = MessageBuilder.withPayload(CustomerOrderEvents.valueOf(event)).setHeader("customerOrder", customerOrder).build(); StateMachineHandler handler = new StateMachineHandler(customerOrderStateMachineFactory, persister, CustomerOrderStateMachineConfig.MACHINE_ID, customerOrder); StateResult res = handler.sendEvent(message, customerOrder.getId()); if (!res.isSuccess()) { throw new RuntimeException(res.getMsg()); } } } @Override public R handleDocument(List ids, Long docId) { Document document = documentMapper.selectById(docId); if (document == null) { return R.failed("工艺文件缺失"); } List customerOrderList = baseMapper.selectBatchIds(ids); customerOrderList.forEach(l->{ log.info("关联数据==============================>"+l); }); String msg = ""; for (CustomerOrder customerOrder : customerOrderList) { if (BooleanUtil.isTrue(customerOrder.getIsDocument())) { msg += customerOrder.getCustomerOrderNo() + "已关联工艺文件！"; } if (StringUtils.isBlank(customerOrder.getPartNo())) { msg += customerOrder.getCustomerOrderNo() + "未选择销售件！"; } //if (StringUtils.isBlank(customerOrder.getPartNo())) { // customerOrder.setPartNo(document.getPartNo()); //} customerOrder.setIsDocument(true); customerOrder.setCoState(CustomerOrderStateStringValues.PLAN); customerOrder.setTechnologyDocumentId(docId); } if (StringUtils.isBlank(msg)) { saveOrUpdateBatch(customerOrderList); return R.ok().setMsg("OK"); } else { return R.failed(msg); } } /** * 取消关联 * * @param ids * @return */ @Override public R rejectHandleDocument(List ids) { for (Long id : ids) { CustomerOrder customerOrder = baseMapper.selectById(id); if (customerOrder.getIsAudit() != null) { if (customerOrder.getIsAudit().equals(AuditStateStringValues.ACCEPTED) || customerOrder.getIsAudit().equals(AuditStateStringValues.PENDING)) { return R.failed("合同号：" + customerOrder.getCustomerOrderNo() + "行号：" + customerOrder.getCoLineNo() + "已在流程中不可解除关联"); } } baseMapper.rejectHandleDocument(id); } return R.ok(); } /** * 根据时间获取otc订单数据 * * @return */ @Override public R otcCustomerOrderSyncAuto() { String param = XxlJobHelper.getJobParam(); LocalDateTime dateTime = null; if (StringUtils.isNotBlank(param)) { dateTime = LocalDateTime.now().minusHours(Long.parseLong(param)); } else { dateTime = LocalDateTime.now().minusHours(1); } DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); return otcCustomerOrderSync(dateTime.format(formatter), "0"); } /** * 根据时间获取otc订单数据 * * @param selectTime * @return */ @Override @Transactional(rollbackFor = Exception.class) public R otcCustomerOrderSync(String selectTime, String pathCode) { try { if (StringUtils.isBlank(selectTime)) { return R.failed("缺少查询时间"); } String token = customerOrderUtil.getToken(); return addCustomerFromOtc(selectTime, token); } catch (Exception e) { return R.failed(e.getMessage()); } } /** * 添加主表信息 * * @param selectTime 时间 * @param token token * @return */ private R addCustomerFromOtc(String selectTime, String token) { try { Map map = new HashMap<>(); if (StringUtils.isNotBlank(selectTime)) { map.put("selectTime", selectTime); } String str = HttpRequest.get(customerOrderClientConfigure.getOtcHost() + customerOrderClientConfigure.getOtcCustomerUrl()) .contentType("application/json") .header("Authorization", "Bearer " + token).form(map).execute().body(); JSONObject result = JSONObject.parseObject(str); //主表参数表 List orderParams = orderParamService.list(); if (result.getInteger("code") == 0) { int num = 0; int detailNum = 0; JSONArray jsonArray = result.getJSONArray("data"); for (Object obj : jsonArray) { JSONObject customerJSONObject = JSONObject.parseObject(obj.toString()); //合同编号 String contractNo = customerJSONObject.getString("orderNo"); //主表在OTC中的状态 String otcMainStatus = customerJSONObject.getString("status"); //所属公司 String affiliatedCompany = customerJSONObject.getString("affiliatedCompany"); //所属工厂 String affiliatedContract=customerJSONObject.getString("affiliatedContract"); //只拉取所属公司为中天海洋系统有限公司的数据 if (!AFFILIATED_CONTRACT.equals(affiliatedContract)){ continue; } // 不在这几个状态中的数据就跳过 if (!Arrays.asList(CustomerOrderStateStringValues.GETOTCSTATE).contains(otcMainStatus)) { continue; } Customer customer = customerMapper.selectOne(Wrappers.lambdaQuery().eq(Customer::getContractNo, contractNo)); if (customer == null) { customer = new Customer(); } //如果OTC中主表状态是取消那就跳过或者删除已经同步的数据 if (OTC_MAIN_STATUS_CANCEL.equals(otcMainStatus)) { if (customer.getId() != null) { customerMapper.deleteById(customer.getId()); baseMapper.delete(Wrappers.lambdaQuery().eq(CustomerOrder::getCustomerId, customer.getId())); } continue; } if (!OTC_MAIN_STATUS_TRANSMIT.equals(otcMainStatus)) {//null == affiliatedCompany || !Arrays.asList("已下达").contains(otcMainStatus) /*|| affiliatedCompany.equals("江苏中天科技股份有限公司")*/) { continue;//只获取OTC中已审核及已下达的订单， } //客户编号 customer.setCustomerNo(customerJSONObject.getString("customerNo")); //合同号 customer.setContractNo(contractNo); //客户合同号 customer.setCustomerContractNo(customerJSONObject.getString("customerContractNumber")); //客户名称 customer.setCustomerName(customerJSONObject.getString("customerName")); //工程名称 customer.setEntityName(customerJSONObject.getString("projectName")); //交货日期 customer.setDeliveryDate(customerJSONObject.get("wantedDeliveryDate") != null ? customerJSONObject.getDate("wantedDeliveryDate").toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime() : null); //事业部 customer.setSalesDepartment(customerJSONObject.getString("division")); //省份 customer.setProvince(customerJSONObject.getString("province")); //业务员名称 customer.setSalesMan(customerJSONObject.getString("salesmanName")); //业务员编号 customer.setSalerWorkCode(customerJSONObject.getString("salesmanNo")); //正本状态 customer.setOriginalContractStatus(customerJSONObject.getString("originalStatus")); //合同正本状态 customer.setReturnStatus(customerJSONObject.getString("returnStatus")); //项目性质 customer.setIsCp(customerJSONObject.getString("natureOfProjectExecution")); //下单日期 customer.setPlaceOrderDate(customerJSONObject.getDate("orderDate").toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime()); //审核日期 customer.setVerifyDate(customerJSONObject.get("reviewTime") != null ? customerJSONObject.getDate("reviewTime").toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime() : null); //工厂下单日期 customer.setFactoryPlaceOrderDate(customerJSONObject.get("factoryOrderDate") != null ? customerJSONObject.getDate("factoryOrderDate").toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime() : null); //备注 customer.setComment(customerJSONObject.getString("comment")); if (customer.getId() == null) { customerMapper.insert(customer); } else { customerMapper.updateById(customer); } num += 1; detailNum += addCustomerOrderFromOtc(customerJSONObject, customer, token, orderParams, otcMainStatus); } return R.ok().setMsg("同步或更新合同主体" + num + "条,合同明细" + detailNum + "条！"); } else { return R.failed("订单主体获取失败"); } } catch (Exception e) { throw new RuntimeException(e.getMessage()); } } /** * 添加子表信息 * * @param customer * @param otcMainStatus * @throws Exception */ private int addCustomerOrderFromOtc(JSONObject customerJSONObject, Customer customer, String token, List orderParamList, String otcMainStatus) { Map productTypeGroupMap = customerOrderUnitWhiteListConfig.getProductTypeGroupMap(); int num = 0; try { Map map = new HashMap<>(); map.put("orderNo", customer.getContractNo()); map.put("selectTime", "1899-12-31 23:59:59"); JSONObject result = JSONObject.parseObject(HttpRequest.get(customerOrderClientConfigure.getOtcHost() + customerOrderClientConfigure.getOtcCustomerOrderUrl()) .contentType("application/json") .header("Authorization", "Bearer " + token).form(map).execute().body()); if (result.getInteger("code") == 0) { JSONArray jsonArray = result.getJSONArray("data"); for (Object obj : jsonArray) { JSONObject customerOrderJSONObject = JSONObject.parseObject(obj.toString()); String otcLoneId = customerOrderJSONObject.getLong("id").toString(); //OTC的订单状态 String otcOrderStatus = customerOrderJSONObject.getString("lineStatus").toString(); CustomerOrder customerOrder = baseMapper.selectOne(Wrappers.lambdaQuery() .eq(CustomerOrder::getOtcLineNo, otcLoneId)); if (customerOrder == null) { customerOrder = new CustomerOrder(); } //如果这个单子在OTC中取消状态 那就删除 if (otcOrderStatus.equals(OTC_MAIN_STATUS_CANCEL)) { if (customerOrder.getId() != null) { baseMapper.deleteById(customerOrder.getId()); } continue; } //OTC合同号主表id customerOrder.setOtcOrderId(customerOrderJSONObject.getLong("orderId")); //otc行号 customerOrder.setOtcLineNo(otcLoneId); //零件号 customerOrder.setPartNo(customerOrderJSONObject.getString("partNo")); //来源 0:自动 customerOrder.setSourceId("0"); //合同号 customerOrder.setCustomerOrderNo(customer.getContractNo()); //客户号 customerOrder.setCustomerNo(customer.getCustomerNo()); //客户名称 customerOrder.setCustomerName(customer.getCustomerName()); //工程名称 customerOrder.setEntityName(customer.getEntityName()); //数量 customerOrder.setBuyQtyDue(customerOrderJSONObject.getBigDecimal("quantity")); //OTC单位 customerOrder.setOtcUnit(customerOrderJSONObject.getString("unit")); //期望交货日期 customerOrder.setWantedDeliveryDate(customer.getDeliveryDate()); //主表id customerOrder.setCustomerId(customer.getId()); //电压等级 customerOrder.setVoltAgeClass(customerOrderJSONObject.getString("voltageLevel")); //外呼颜色 customerOrder.setOuterColor(customerOrderJSONObject.getString("outerSheathColor")); //客户零件名称 customerOrder.setProductName(customerOrderJSONObject.getString("productName")); //客户零件规格 customerOrder.setCustomerPartSpec(customerOrderJSONObject.getString("specificationModel")); //订单版本 customerOrder.setVersion(customerOrderJSONObject.getInteger("version")); //事业部 customerOrder.setDivision(customerOrderJSONObject.getString("division")); //印字类型 customerOrder.setPrintType(customerOrderJSONObject.getString("printType")); //印字内容 customerOrder.setPrintContent(customerOrderJSONObject.getString("printContent")); //印字要求 customerOrder.setPrintingRequirements(customerOrderJSONObject.getString("printingRequirements")); //包装要求 customerOrder.setPackageRequire(customerOrderJSONObject.getString("packageRequire")); //质量要求 customerOrder.setQualityRequire(customerOrderJSONObject.getString("qualityRequire")); //生产需求说明 customerOrder.setOtherProductRequire(customerOrderJSONObject.getString("otherProductRequire")); //系统 customerOrder.setDivisionSystem(customerOrderJSONObject.getString("divisionSystem")); //收货地址 customerOrder.setShippingAddress(customerOrderJSONObject.getString("shippingAddress")); //业务员 customerOrder.setSalesmanName(customer.getSalesMan()); //盘长要求 customerOrder.setLengthRequirement(customerOrderJSONObject.getString("lengthRequirement")); //产品备注Ï customerOrder.setRemark(customerOrderJSONObject.getString("orderComment")); //产品类型 customerOrder.setProductType(customerOrderJSONObject.getString("productType")); //产品分组 customerOrder.setProductGroup(productTypeGroupMap.get(customerOrderJSONObject.getString("productType"))); //采集性质 customerOrder.setCentralizedMiningProperty(customerJSONObject.getString("centralizedMiningProperty")); //最终客户名称 customerOrder.setFinalCustomerName(customerJSONObject.getString("finalCustomerName")); //销售件描述 customerOrder.setSalesPartName(customerOrderJSONObject.getString("partDesc")); if (customerOrder.getId() == null) { // 零件是否推送 customerOrder.setOtcPartSync(false); // 默认为N 数据字典为：N：普通，S：样品，D：研发 customerOrder.setManufactureAttr("N"); //是否关联工艺文件为否 customerOrder.setIsDocument(false); //状态为 如果采集性质 非采集和 省采集 状态位编辑 否则为 零件待选 if (customerOrder.getCentralizedMiningProperty().equals("非集采") || customerOrder.getCentralizedMiningProperty().equals("省集采")) { customerOrder.setCoState(CustomerOrderStateStringValues.UNIEDIT); } else { customerOrder.setCoState(CustomerOrderStateStringValues.PARTUNCHECKED); } if (org.apache.commons.lang3.StringUtils.equals(OTC_MAIN_STATUS_TRANSMIT, otcMainStatus)) { customerOrder.setCoState(CustomerOrderStateStringValues.TECHNOLOGYUNCHECK); customerOrder.setOtcPartSync(Boolean.TRUE); } // 如果状态为零件待选，且零件号不为空，更新状态 if (StrUtil.isNotBlank(customerOrder.getPartNo()) && CustomerOrderStateStringValues.PARTUNCHECKED.equals(customerOrder.getCoState())) { customerOrder.setCoState(CustomerOrderStateStringValues.TECHNOLOGYUNCHECK); customerOrder.setOtcPartSync(Boolean.TRUE); } //审核状态为 03accepted 通过 customerOrder.setIsAudit(AuditStateStringValues.ACCEPTED); baseMapper.insert(customerOrder); } addCustomerPara(customerJSONObject, customerOrderJSONObject, customerOrder, orderParamList); num += 1; } } } catch (Exception e) { throw new RuntimeException("订单行数据获取失败，原因：" + e.getMessage()); } return num; } ///** // * 添加主表信息 // * // * @param selectTime 时间 // * @param token token // * @return // */ //private R addCustomerFromOtc(String selectTime, String token) { // try { // Map map = new HashMap<>(); // if (StringUtils.isNotBlank(selectTime)) { // map.put("selectTime", selectTime); // } // String str = HttpRequest.get(customerOrderClientConfigure.getOtcHost() + customerOrderClientConfigure.getOtcCusomerUrl()) // .contentType("application/json") // .header("Authorization", "Bearer " + token).form(map).execute().body(); // JSONObject result = JSONObject.parseObject(str); // //主表参数表 // List orderParams = orderParamService.list(); // if (result.getInteger("code") == 0) { // int num = 0; // int detailNum = 0; // JSONArray jsonArray = result.getJSONArray("data"); // for (Object obj : jsonArray) { // JSONObject customerJSONObject = JSONObject.parseObject(obj.toString()); // //合同编号 // String contractNo = customerJSONObject.getString("orderNo"); // //主表在OTC中的状态 // String otcMainStatus = customerJSONObject.getString("status"); // //所属公司 // String affiliatedCompany = customerJSONObject.getString("affiliatedCompany"); // // 不在这几个状态中的数据就跳过 // if (!Arrays.asList(CustomerOrderStateStringValues.GETOTCSTATE).contains(otcMainStatus)) { // continue; // } // Customer customer = customerMapper.selectOne(Wrappers.lambdaQuery().eq(Customer::getContractNo, contractNo)); // if (customer == null) { // customer = new Customer(); // } // //如果OTC中主表状态是取消那就跳过或者删除已经同步的数据 // if (otcMainStatus.equals("已取消")) { // if (customer.getId() != null) { // customerMapper.deleteById(customer.getId()); // baseMapper.delete(Wrappers.lambdaQuery().eq(CustomerOrder::getCustomerId, customer.getId())); // } // continue; // } // if (null == affiliatedCompany || !Arrays.asList("已审核", "已下达").contains(otcMainStatus) || affiliatedCompany.equals("江苏中天科技股份有限公司")) { // continue;//只获取OTC中已审核及已下达的订单，且所属公司不是中天科技 // } // //客户编号 // customer.setCustomerNo(customerJSONObject.getString("customerNo")); // //合同号 // customer.setContractNo(contractNo); // //客户合同号 // customer.setCustomerContractNo(customerJSONObject.getString("customerContractNumber")); // //客户名称 // customer.setCustomerName(customerJSONObject.getString("customerName")); // //工程名称 // customer.setEntityName(customerJSONObject.getString("projectName")); // //交货日期 // customer.setDeliveryDate(customerJSONObject.get("wantedDeliveryDate") != null ? // customerJSONObject.getDate("wantedDeliveryDate").toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime() : null); // //事业部 // customer.setSalesDepartment(customerJSONObject.getString("division")); // //省份 // customer.setProvince(customerJSONObject.getString("province")); // //业务员名称 // customer.setSalesMan(customerJSONObject.getString("salesmanName")); // //业务员编号 // customer.setSalerWorkCode(customerJSONObject.getString("salesmanNo")); // //正本状态 // customer.setOriginalContractStatus(customerJSONObject.getString("originalStatus")); // //合同正本状态 // customer.setReturnStatus(customerJSONObject.getString("returnStatus")); // //项目性质 // customer.setIsCp(customerJSONObject.getString("natureOfProjectExecution")); // //下单日期 // customer.setPlaceOrderDate(customerJSONObject.getDate("orderDate").toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime()); // //审核日期 // customer.setVerifyDate(customerJSONObject.get("reviewTime") != null ? // customerJSONObject.getDate("reviewTime").toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime() : null); // //工厂下单日期 // customer.setFactoryPlaceOrderDate(customerJSONObject.get("factoryOrderDate") != null ? // customerJSONObject.getDate("factoryOrderDate").toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime() : null); // //备注 // customer.setComment(customerJSONObject.getString("comment")); // if (customer.getId() == null) { // customerMapper.insert(customer); // } else { // customerMapper.updateById(customer); // } // num += 1; // // detailNum += addCustomerOrderFromOtc(customerJSONObject, customer, token, orderParams, otcMainStatus); // } // return R.ok().setMsg("同步或更新合同主体" + num + "条,合同明细" + detailNum + "条！"); // } else { // return R.failed("订单主体获取失败"); // } // } catch (Exception e) { // throw new RuntimeException(e.getMessage()); // } //} // /** * 添加子表信息 * * @param customer * @param otcMainStatus * @throws Exception */ //private int addCustomerOrderFromOtc(JSONObject customerJSONObject, Customer customer, String token, List orderParamList, String otcMainStatus) { // Map productTypeGroupMap = customerOrderUnitWhiteListConfig.getProductTypeGroupMap(); // int num = 0; // try { // Map map = new HashMap<>(); // map.put("orderNo", customer.getContractNo()); // map.put("selectTime", "1899-12-31 23:59:59"); // JSONObject result = JSONObject.parseObject(HttpRequest.get(customerOrderClientConfigure.getOtcHost() + customerOrderClientConfigure.getOtcCustomerOrderUrl()) // .contentType("application/json") // .header("Authorization", "Bearer " + token).form(map).execute().body()); // if (result.getInteger("code") == 0) { // JSONArray jsonArray = result.getJSONArray("data"); // for (Object obj : jsonArray) { // JSONObject customerOrderJSONObject = JSONObject.parseObject(obj.toString()); // String otcLoneId = customerOrderJSONObject.getLong("id").toString(); // //OTC的订单状态 // String otcOrderStatus = customerOrderJSONObject.getString("lineStatus").toString(); // CustomerOrder customerOrder = baseMapper.selectOne(Wrappers.lambdaQuery() // .eq(CustomerOrder::getOtcLineNo, otcLoneId)); // if (customerOrder == null) { // customerOrder = new CustomerOrder(); // } // //如果这个单子在OTC中取消状态 那就删除 // if (otcOrderStatus.equals("已取消")) { // if (customerOrder.getId() != null) { // baseMapper.deleteById(customerOrder.getId()); // } // continue; // } // //OTC合同号主表id // customerOrder.setOtcOrderId(customerOrderJSONObject.getLong("orderId")); // //otc行号 // customerOrder.setOtcLineNo(otcLoneId); // //零件号 // customerOrder.setSalesPartNo(customerOrderJSONObject.getString("partNo")); // //来源 // customerOrder.setSourceId("OTC"); // //合同号 // customerOrder.setCustomerOrderNo(customer.getContractNo()); // //客户号 // customerOrder.setCustomerNo(customer.getCustomerNo()); // //客户名称 // customerOrder.setCustomerName(customer.getCustomerName()); // //销售数量原先OTC的单位 // customerOrder.setOtcQuantity(customerOrderJSONObject.getBigDecimal("quantity")); // //OTC单位 // customerOrder.setOtcUnit(customerOrderJSONObject.getString("unit")); // //期望交货日期 // customerOrder.setWantedDeliveryDate(customer.getDeliveryDate()); // //主表id // customerOrder.setCustomerId(customer.getId()); // //电压等级 // customerOrder.setVoltAgeClass(customerOrderJSONObject.getString("voltageLevel")); // //外呼颜色 // customerOrder.setOuterColor(customerOrderJSONObject.getString("outerSheathColor")); // //客户零件名称 // customerOrder.setProductName(customerOrderJSONObject.getString("productName")); // //客户零件规格 // customerOrder.setCustomerPartSpec(customerOrderJSONObject.getString("specificationModel")); // //订单版本 // customerOrder.setVersion(customerOrderJSONObject.getInteger("version")); // //事业部 // customerOrder.setDivision(customerOrderJSONObject.getString("division")); // //印字类型 // customerOrder.setPrintType(customerOrderJSONObject.getString("printType")); // //印字内容 // customerOrder.setPrintContent(customerOrderJSONObject.getString("printContent")); // //印字要求 // customerOrder.setPrintingRequirements(customerOrderJSONObject.getString("printingRequirements")); // //包装要求 // customerOrder.setPackageRequire(customerOrderJSONObject.getString("packageRequire")); // //质量要求 // customerOrder.setQualityRequire(customerOrderJSONObject.getString("qualityRequire")); // //生产需求说明 // customerOrder.setOtherProductRequire(customerOrderJSONObject.getString("otherProductRequire")); // //系统 // customerOrder.setDivisionSystem(customerOrderJSONObject.getString("divisionSystem")); // //收货地址 // customerOrder.setShippingAddress(customerOrderJSONObject.getString("shippingAddress")); // //业务员 // customerOrder.setSalesmanName(customer.getSalesMan()); // //盘长要求 // customerOrder.setLengthRequirement(customerOrderJSONObject.getString("lengthRequirement")); // //备注Ï // customerOrder.setRemark(customerOrderJSONObject.getString("comment")); // //产品类型 // customerOrder.setProductType(customerOrderJSONObject.getString("productType")); // //产品分组 // customerOrder.setProductGroup(productTypeGroupMap.get(customerOrderJSONObject.getString("productType"))); // //采集性质 // customerOrder.setCentralizedMiningProperty(customerJSONObject.getString("centralizedMiningProperty")); // //最终客户名称 // customerOrder.setFinalCustomerName(customerJSONObject.getString("finalCustomerName")); // //销售件描述 // customerOrder.setSalesPartName(customerOrderJSONObject.getString("partDesc")); // // if (customerOrder.getId() == null) { // // 零件是否推送 // customerOrder.setOtcPartSync(false); // // 默认为N 数据字典为：N：普通，S：样品，D：研发 // customerOrder.setManufactureAttr("N"); // //是否关联工艺文件为否 // customerOrder.setIsDocument(false); // //状态为 如果采集性质 非采集和 省采集 状态位编辑 否则为 零件待选 // if (customerOrder.getCentralizedMiningProperty().equals("非集采") || customerOrder.getCentralizedMiningProperty().equals("省集采")) { // customerOrder.setCoState(CustomerOrderStateStringValues.UNIEDIT); // } else { // customerOrder.setCoState(CustomerOrderStateStringValues.PARTUNCHECKED); // } // if (org.apache.commons.lang3.StringUtils.equals("已下达", otcMainStatus)) { // customerOrder.setCoState(CustomerOrderStateStringValues.TECHNOLOGYUNCHECK); // customerOrder.setOtcPartSync(Boolean.TRUE); // } // //审核状态为 01draft 草稿 // customerOrder.setIsAudit(AuditStateStringValues.DRAFT); // baseMapper.insert(customerOrder); // } else { // // 如果状态为零件待选，且销售件号不为空，更新状态 // if (StrUtil.isNotBlank(customerOrder.getSalesPartNo()) && CustomerOrderStateStringValues.PARTUNCHECKED.equals(customerOrder.getCoState())) { // customerOrder.setCoState(CustomerOrderStateStringValues.TECHNOLOGYUNCHECK); // customerOrder.setOtcPartSync(Boolean.TRUE); // } // baseMapper.updateById(customerOrder); // } // addCustomerPara(customerJSONObject, customerOrderJSONObject, customerOrder, orderParamList); // num += 1; // } // } // } catch (Exception e) { // throw new RuntimeException("订单行数据获取失败，原因：" + e.getMessage()); // } // return num; //} /** * @param jsonObjMain 主表的jsonObj * @param jsonObjDetail 子表的jsonObj * @param customerOrder 客户订单（股份公司） * @param orderParamList */ private void addCustomerPara(JSONObject jsonObjMain, JSONObject jsonObjDetail, CustomerOrder customerOrder, List orderParamList) { //先删除再次新增 customerOrderParamMapper.delete(Wrappers.lambdaQuery().eq(CustomerOrderParam::getOrderId, customerOrder.getId())); //新增参数 for (OrderParam orderParam : orderParamList) { String field = orderParam.getField(); CustomerOrderParam customerOrderParam = new CustomerOrderParam(); customerOrderParam.setField(orderParam.getField()); customerOrderParam.setOrderId(customerOrder.getId()); customerOrderParam.setOrderParamId(orderParam.getId()); if (orderParam.getDistinguish().equals("主表")) { customerOrderParam.setValue(jsonObjMain.getString(field)); } else { customerOrderParam.setValue(jsonObjDetail.getString(field)); } customerOrderParamMapper.insert(customerOrderParam); } } /** * @param jsonObjMain 主表的jsonObj * @param jsonObjDetail 子表的jsonObj * @param customerOrder 客户订单 * @param orderParamList */ private void addCustomerParaForJointStockCompany(JSONObject jsonObjMain, JSONObject jsonObjDetail, CustomerOrderForJointStockCompany customerOrder, List orderParamList) { //先删除再次新增 customerOrderParamJointStockCompanyMapper.delete(Wrappers.lambdaQuery().eq(CustomerOrderParamJointStockCompany::getOrderId, customerOrder.getId())); //新增参数 for (OrderParam orderParam : orderParamList) { String field = orderParam.getField(); CustomerOrderParamJointStockCompany customerOrderParam = new CustomerOrderParamJointStockCompany(); customerOrderParam.setField(orderParam.getField()); customerOrderParam.setOrderId(customerOrder.getId()); customerOrderParam.setOrderParamId(orderParam.getId()); if (orderParam.getDistinguish().equals("主表")) { customerOrderParam.setValue(jsonObjMain.getString(field)); } else { customerOrderParam.setValue(jsonObjDetail.getString(field)); } customerOrderParamJointStockCompanyMapper.insert(customerOrderParam); } } @Override public R querySalesPartStd(SalesPartDTO salesPartDTO) { JSONObject jsonObject = new JSONObject(); if (StringUtils.isNotBlank(salesPartDTO.getSalesPartNo())) { jsonObject.put("CATALOG_NO", salesPartDTO.getSalesPartNo()); } // String catalogDesc = "TRUE"; // if (StringUtils.isNotBlank(salesPartDTO.getSalesPartDesc())) { // catalogDesc += "%" + salesPartDTO.getSalesPartDesc() + "%;"; // } // if (StringUtils.isNotBlank(salesPartDTO.getModel())) { // catalogDesc += "%" + salesPartDTO.getModel() + "%;"; // } // if (StringUtils.isNotBlank(salesPartDTO.getSpecification())) { // catalogDesc += "%" + salesPartDTO.getSpecification() + "%;"; // } // if (StringUtils.isNotBlank(salesPartDTO.getVoltageLevel())) { // catalogDesc += "%" + salesPartDTO.getVoltageLevel() + "%;"; // } // if (catalogDesc.contains("%")) { // jsonObject.put("CATALOG_DESC", catalogDesc); // } jsonObject.put("ACTIVE", "Y"); if (StringUtils.isNotBlank(salesPartDTO.getSalesPartDesc())) { jsonObject.put("CATALOG_DESC", salesPartDTO.getSalesPartDesc()); } R result = ifsFeignClient.querySalesPartStd(jsonObject, true); if (result.getCode() == 0) { JSONObject data = (JSONObject) JSON.toJSON(result.getData()); return R.ok(data.getJSONArray("LIST_INFO"), "OK"); } else { return R.failed("IFS错误——" + result.getMsg()); } } @Override public R syncIfsLineNo(List ids) { List customerOrderList = baseMapper.selectList(Wrappers.lambdaQuery().in(CustomerOrder::getId, ids)); return queryCoInfoStd(customerOrderList); } @Override public R syncIfsLineNoAuto() { List customerOrderList = baseMapper.selectList(Wrappers.lambdaQuery() .isNotNull(CustomerOrder::getOtcLineNo).and(wapper -> wapper .isNull(CustomerOrder::getIfsDeliveryNo).or() .isNull(CustomerOrder::getIfsLineItemNo).or() .isNull(CustomerOrder::getIfsLineNo))); return queryCoInfoStd(customerOrderList); } @Override public boolean batchUpdateSalePartNo(CustomerOrderDTO customerOrderDTO) { List ids = customerOrderDTO.getUpdateIds(); if (CollectionUtil.isEmpty(ids)) { throw new RuntimeException("请选择客户订单行"); } List unitWhitMapList = customerOrderUnitWhiteListConfig.getUnitWhitListMap(); for (Long id : ids) { CustomerOrder customerOrder = baseMapper.selectById(id); customerOrder.setSalesPartNo(customerOrderDTO.getSalesPartNo()); customerOrder.setPartNo(customerOrderDTO.getPartNo()); customerOrder.setSalesPartName(customerOrderDTO.getSalesPartName()); customerOrder.setIfsSalesUnit(customerOrderDTO.getIfsSalesUnit()); customerOrder.setIfsDeliveryNo(customerOrderDTO.getIfsDeliveryNo()); customerOrder.setUnit(customerOrderDTO.getUnit()); String unitConcat = customerOrder.getOtcUnit() + "_" + customerOrderDTO.getIfsSalesUnit(); if (!customerOrder.getOtcUnit().equals(customerOrderDTO.getIfsSalesUnit()) && !unitWhitMapList.contains(unitConcat)) { //如果销售单位和ifs中销售单位不一样则不给保存A throw new RuntimeException("订单行销售单位和销售件销售计量单位不一致并且白名单中不存在对应关系"); } else { customerOrder.setOtcPartSync(false); customerOrder.setBuyQtyDue(customerOrderDTO.getIfsConvFactor().multiply(customerOrder.getOtcQuantity())); if (BooleanUtil.isTrue(customerOrder.getIsDocument())) { customerOrder.setCoState(CustomerOrderStateStringValues.PLAN); } else { customerOrder.setCoState(CustomerOrderStateStringValues.TECHNOLOGYUNCHECK); } updateById(customerOrder); } } return true; } /** * 查询ifs行号的数据 * * @param customerOrderList * @return */ private R queryCoInfoStd(List customerOrderList) { Map customerOrderMap = customerOrderList.stream().collect(Collectors.toMap(CustomerOrder::getOtcLineNo, a -> a, (k1, k2) -> k1)); String otcLineNos = ""; for (CustomerOrder customerOrder : customerOrderList) { otcLineNos += new Long(customerOrder.getOtcLineNo()) + ";"; } if (StringUtils.isBlank(otcLineNos)) { return R.ok().setMsg("同步0条"); } R result = ifsFeignClient.queryCoInfoStd(new JSONObject().fluentPut("OTC_LINE_NO", otcLineNos), true); if (result.getCode() == 0) { int i = 0; JSONObject data = (JSONObject) JSON.toJSON(result.getData()); JSONArray listInfo = data.getJSONArray("LIST_INFO"); for (Object obj : listInfo) { JSONObject info = JSONObject.parseObject(obj.toString()); String otcLineNo = info.getString("OTC_LINE_NO"); if (customerOrderMap.get(otcLineNo) == null) { continue; } CustomerOrder customerOrder = customerOrderMap.get(otcLineNo); customerOrder.setIfsDeliveryNo(info.getString("REL_NO")); customerOrder.setIfsLineItemNo("LINE_ITEM_NO"); customerOrder.setIfsLineNo("LINE_NO"); i += 1; baseMapper.updateById(customerOrder); } return R.ok().setMsg("同步" + i + "条"); } else { return R.failed("IFS错误——" + result.getMsg()); } } /** * @param ids * @return */ @Override public String oa(List ids) { String msg = ""; Map mainFields = new HashMap<>(); List> detailFieldList = new ArrayList<>(); List cpfzList = new ArrayList<>(); Long customerId = null; List customerOrderDTOList = baseMapper.selectOrderDocAndPart(ids); for (CustomerOrderDTO customerOrderDTO : customerOrderDTOList) { if (!customerOrderDTO.getIsDocument() || customerOrderDTO.getTechnologyDocumentId() == null) { msg = "【otc行号:" + customerOrderDTO.getOtcLineNo() + "缺少工艺文件】"; return msg; } if (StringUtils.isBlank(customerOrderDTO.getSalesPartNo())) { msg = "【otc行号:" + customerOrderDTO.getOtcLineNo() + "请先选择销售件】"; return msg; } if (StringUtils.isBlank(customerOrderDTO.getDocName())) { msg = "【otc行号:" + customerOrderDTO.getOtcLineNo() + "工艺文件丢失】"; return msg; } if (StringUtils.isBlank(customerOrderDTO.getPartName())) { msg = "【otc行号:" + customerOrderDTO.getOtcLineNo() + "工艺文件的零件丟失】"; return msg; } Map detailField = new HashMap<>(); //合同otc行号 detailField.put("otcxh", Objects.toString(customerOrderDTO.getOtcLineNo(), org.apache.commons.lang3.StringUtils.EMPTY)); //零件编号 detailField.put("ljh", Objects.toString(customerOrderDTO.getPartNo(), org.apache.commons.lang3.StringUtils.EMPTY)); //零件名称 detailField.put("ljmc", Objects.toString(customerOrderDTO.getPartName(), org.apache.commons.lang3.StringUtils.EMPTY)); //产品分组 detailField.put("cpfz", customerOrderDTO.getProductGroup()); //产品名称 detailField.put("cpmc", Objects.toString(customerOrderDTO.getProductName(), org.apache.commons.lang3.StringUtils.EMPTY)); //规格型号 detailField.put("cpgg", Objects.toString(customerOrderDTO.getSpecs(), org.apache.commons.lang3.StringUtils.EMPTY)); //下单数量 detailField.put("xssl", Objects.toString(customerOrderDTO.getBuyQtyDue(), org.apache.commons.lang3.StringUtils.EMPTY)); DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); //希望交货日期 detailField.put("qwjhrq", customerOrderDTO.getWantedDeliveryDate() != null ? formatter.format(customerOrderDTO.getWantedDeliveryDate()) : ""); //电压等级 detailField.put("dydj", Objects.toString(customerOrderDTO.getVoltAgeClass(), org.apache.commons.lang3.StringUtils.EMPTY)); //外护颜色 detailField.put("whys", Objects.toString(customerOrderDTO.getOuterColor(), org.apache.commons.lang3.StringUtils.EMPTY)); //单位 detailField.put("dw", Objects.toString(customerOrderDTO.getUnit(), org.apache.commons.lang3.StringUtils.EMPTY)); customerId = customerOrderDTO.getCustomerId(); cpfzList.add(customerOrderDTO.getProductGroup()); detailFieldList.add(detailField); } Customer customer = customerMapper.selectById(customerId); //工艺文件展示连接 mainFields.put("technology_document_id", "工艺详情"); mainFields.put("contract_no", Objects.toString(customer.getContractNo(), org.apache.commons.lang3.StringUtils.EMPTY)); mainFields.put("customer_no", Objects.toString(customer.getCustomerNo(), org.apache.commons.lang3.StringUtils.EMPTY)); mainFields.put("customer_name", Objects.toString(customer.getCustomerName(), org.apache.commons.lang3.StringUtils.EMPTY)); mainFields.put("cpfz", org.apache.commons.lang3.StringUtils.join(cpfzList, ",")); mainFields.put("source", "customerOrder"); String requestName = "工艺审批流程"; String createrId = SecurityUtils.getUser().getUsername(); String workflowId = oaProperty.getCustomerOrderOaId(); try { OAResult oaResult = OAProcess.start(mainFields, detailFieldList, requestName, workflowId, createrId); //OA流程发起成功，状态变成待审批 ，订单和工艺文件同步进行 if (oaResult.success()) { List CustomerOrderList = new ArrayList<>(); for (Long id : ids) { CustomerOrder customerOrder = new CustomerOrder(); customerOrder.setId(id); customerOrder.setOaWorkflowId(oaResult.getAddWorkflowResult()); customerOrder.setIsAudit(AuditStateStringValues.PENDING); CustomerOrderList.add(customerOrder); } updateBatchById(CustomerOrderList); return "【客户订单号:" + customer.getCustomerNo() + "提交成功！】"; } else { return "【客户订单号:" + customer.getCustomerNo() + "提交失败】" + oaResult.getErrorMsg(); } } catch (Exception e) { return "【客户订单号:" + customer.getCustomerNo() + "提交失败】"; } } /** * oa回调 * * @param data * @return */ @Override public OACallBackResult oaResultCallBack(String data) { OACallBackResult oaCallBackResult = new OACallBackResult(); oaCallBackResult.setMessage(oaReturnMsg(0, "success")); try { JSONObject jsonObject = JSONObject.parseObject(data); String requestId = jsonObject.getLong("requestId").toString(); String checkResult = jsonObject.getString("CHECKRESULT"); String source = jsonObject.getString("source"); oaCallBackResult.setResult(checkResult); oaCallBackResult.setSource(source); oaCallBackResult.setWorkflowId(requestId); docAuditChange(requestId, checkResult, source); } catch (Exception e) { oaCallBackResult.setMessage(oaReturnMsg(1, e.getMessage())); } finally { return oaCallBackResult; } } private String oaReturnMsg(int code, String msg) { return "" + code + "" + msg + ""; } /** * 主需求的OA回调 0 ：退回 1 ：通过 * source = customerOrder 客户订单工艺审批 * source = masterProductionSchedule 生产计划工艺审批 * * @return */ private void docAuditChange(String oaWorkflowId, String checkResult, String source) { try { //通过的话客户订单 if (source.equals("customerOrder")) { List customerOrderList = getBaseMapper().selectList(Wrappers.lambdaQuery().eq(CustomerOrder::getOaWorkflowId, oaWorkflowId)); for (CustomerOrder customerOrder : customerOrderList) { Document document = documentMapper.selectById(customerOrder.getTechnologyDocumentId()); if (checkResult.equals("1")) { //通过 customerOrderDocAccept(customerOrder, document); } else { //不通过的话 customerOrderDocReject(customerOrder, document); } } } //生产计划 if (source.equals("masterProductionSchedule")) { MasterProductionSchedule masterProductionSchedule = masterProductionScheduleMapper.selectOne(Wrappers.lambdaQuery().eq(MasterProductionSchedule::getOaWorkflowId, oaWorkflowId)); Document document = documentMapper.selectById(masterProductionSchedule.getTechnologyDocumentId()); if (checkResult.equals("1")) { masterProductionScheduleDocAccept(masterProductionSchedule, document); } else { //不通过的话 masterProductionScheduleDocReject(masterProductionSchedule, document); } } } catch (Exception e) { throw new RuntimeException("回调异常：" + e.getMessage()); } } /** * 客户订单工艺审批通过后执行 * * @param customerOrder * @param document */ @Async public void customerOrderDocAccept(CustomerOrder customerOrder, Document document) { customerOrder = customerOrderUtil.updateCustomerOrderLine(customerOrder); // pushPartNoToOtc(customerOrder); docAccept(customerOrder, document); } /** * 根据工艺文件id 将工艺文件改为接口，将BOM和工艺路线都改为已接收 * * @param document document */ @Override public void docAccept(CustomerOrder customerOrder, Document document) { if (null != document) { changeAllDocState(customerOrder, document); } else { customerOrder.setIsAudit(AuditStateStringValues.ACCEPTED); baseMapper.updateById(customerOrder); } } private void changeAllDocState(CustomerOrder customerOrder, Document document) { //修改主表的状态 customerOrder.setIsAudit(AuditStateStringValues.ACCEPTED); baseMapper.updateById(customerOrder); //document.setState(DocumentStateStringValues.ACCEPTED); //documentService.saveOrUpdate(document); //将工艺文件BOM和工艺路线的状态都改为已接收 List joinDocumentBomRoutingList = joinDocumentBomRoutingMapper.selectList(Wrappers.lambdaQuery().eq(JoinDocumentBomRouting::getDocumentId, document.getId())); joinDocumentBomRoutingList.forEach(joinDocumentBomRouting -> { //将BOM改为已接收 if (joinDocumentBomRouting.getBomId() != null) { Bom bom = bomMapper.selectById(joinDocumentBomRouting.getBomId()); bom.setState(BomStates.ACCEPTED.getValue()); bomMapper.updateById(bom); } //将工艺路线改为已接收 if (joinDocumentBomRouting.getRoutingId() != null) { Routing routing = routingMapper.selectById(joinDocumentBomRouting.getRoutingId()); routing.setState(RoutingStates.ACCEPTED.getValue()); routingMapper.updateById(routing); } }); } private void expectionCustomerOrder(CustomerOrder customerOrder, Document document) { //修改主表的状态 customerOrder.setIsAudit(AuditStateStringValues.EXPECT); baseMapper.updateById(customerOrder); document.setState(DocumentStateStringValues.REJECT); documentService.saveOrUpdate(document); } private void expectionMasterSchdule(MasterProductionSchedule masterProductionSchedule, Document document) { //修改主表的状态 masterProductionSchedule.setIsAudit(AuditStateStringValues.EXPECT); masterProductionScheduleMapper.updateById(masterProductionSchedule); document.setState(DocumentStateStringValues.REJECT); documentService.saveOrUpdate(document); } /** * 客户订单工艺审批退回后执行 * * @param customerOrder * @param document */ @Async public void customerOrderDocReject(CustomerOrder customerOrder, Document document) { customerOrder.setIsAudit(AuditStateStringValues.REJECT); document.setState(DocumentStates.REJECT.getValue()); baseMapper.updateById(customerOrder); documentMapper.updateById(document); } @Override public boolean pushotc(List ids, String pathCode) { if (pathCode.equals("0")) { for (Long id : ids) { CustomerOrder customerOrder = baseMapper.selectById(id); pushotc(customerOrder); } } else if (pathCode.equals("1")) { for (Long id : ids) { CustomerOrderForJointStockCompany customerOrderForJointStockCompany = customerOrderForJointStockCompanyMapper.selectById(id); pushotc(customerOrderForJointStockCompany); } } else { throw new RuntimeException("业务路径码 = 【" + pathCode + "】非法"); } return true; } @Override public boolean pushotc(CustomerOrder customerOrder) { if (StringUtils.isBlank(customerOrder.getSalesPartNo())) { throw new RuntimeException(customerOrder.getOtcLineNo() + " 请选择销售件号"); } String token = customerOrderUtil.getToken(); customerOrder = customerOrderUtil.updateCustomerOrderLine(customerOrder); JSONArray jsonArray = new JSONArray().fluentAdd(new JSONObject() .fluentPut("orderId", customerOrder.getOtcOrderId()) .fluentPut("lineId", new Long(customerOrder.getOtcLineNo())) .fluentPut("partNo", customerOrder.getSalesPartNo()) .fluentPut("version", customerOrder.getVersion())); String str = HttpRequest.post(customerOrderClientConfigure.getOtcHost() + customerOrderClientConfigure.getOtcPushPartNoUrl()) .contentType("application/json") .header("Authorization", "Bearer " + token).body(JSONArray.toJSONString(jsonArray)).execute().body(); JSONObject result = JSONObject.parseObject(str); if (result.getInteger("code") != 0) { throw new RuntimeException(customerOrder.getOtcLineNo() + " OTC推送失败:错误编号" + result.getInteger("code") + " 错误信息：" + result.getString("msg")); } else { customerOrder.setOtcPartSync(true); baseMapper.updateById(customerOrder); } return true; } @Override public boolean pushotc(CustomerOrderForJointStockCompany customerOrder) { if (StringUtils.isBlank(customerOrder.getSalesPartNo())) { throw new RuntimeException(customerOrder.getOtcLineNo() + " 请选择销售件号"); } String token = customerOrderUtil.getToken(); customerOrder = customerOrderUtil.updateCustomerOrderLineForJointStockCompany(customerOrder); JSONArray jsonArray = new JSONArray().fluentAdd(new JSONObject() .fluentPut("orderId", customerOrder.getOtcOrderId()) .fluentPut("lineId", new Long(customerOrder.getOtcLineNo())) .fluentPut("partNo", customerOrder.getSalesPartNo()) .fluentPut("version", customerOrder.getVersion())); String str = HttpRequest.post(customerOrderClientConfigure.getOtcHost() + customerOrderClientConfigure.getOtcPushPartNoUrl()) .contentType("application/json") .header("Authorization", "Bearer " + token).body(JSONArray.toJSONString(jsonArray)).execute().body(); JSONObject result = JSONObject.parseObject(str); if (result.getInteger("code") != 0) { throw new RuntimeException(customerOrder.getOtcLineNo() + " OTC推送失败:错误编号" + result.getInteger("code")); } else { customerOrder.setOtcPartSync(true); customerOrderForJointStockCompanyMapper.updateById(customerOrder); } return true; } /** * 零件编号推送到订单 * * @param customerOrder */ private void pushPartNoToOtc(CustomerOrder customerOrder) { try { if (StringUtils.isNotBlank(customerOrder.getSalesPartNo())) { String token = customerOrderUtil.getToken(); JSONArray jsonArray = new JSONArray().fluentAdd(new JSONObject() .fluentPut("lineId", new Long(customerOrder.getOtcLineNo())) .fluentPut("orderId", customerOrder.getOtcOrderId()) .fluentPut("partNo", customerOrder.getSalesPartNo()) .fluentPut("version", customerOrder.getVersion())); String str = HttpRequest.post(customerOrderClientConfigure.getOtcHost() + customerOrderClientConfigure.getOtcPushPartNoUrl()) .contentType("application/json") .header("Authorization", "Bearer " + token).body(JSONArray.toJSONString(jsonArray)).execute().body(); JSONObject result = JSONObject.parseObject(str); if (result.getInteger("code") == 0) { customerOrder.setOtcPartSync(true); baseMapper.updateById(customerOrder); } } } catch (Exception e) { throw new RuntimeException("token获取异常"); } } /** * 生产计划工艺审批通过后执行 * * @param masterProductionSchedule * @param document */ @Async public void masterProductionScheduleDocAccept(MasterProductionSchedule masterProductionSchedule, Document document) { //修改主表的状态 masterProductionSchedule.setIsAudit(AuditStateStringValues.ACCEPTED); masterProductionScheduleMapper.updateById(masterProductionSchedule); document.setState(DocumentStateStringValues.ACCEPTED); documentService.saveOrUpdate(document); //将工艺文件BOM和工艺路线的状态都改为已接收 List joinDocumentBomRoutingList = joinDocumentBomRoutingMapper.selectList(Wrappers.lambdaQuery().eq(JoinDocumentBomRouting::getDocumentId, document.getId())); joinDocumentBomRoutingList.forEach(joinDocumentBomRouting -> { //将BOM改为已接收 if (joinDocumentBomRouting.getBomId() != null) { Bom bom = bomMapper.selectById(joinDocumentBomRouting.getBomId()); bom.setState(BomStates.ACCEPTED.getValue()); bomMapper.updateById(bom); } //将工艺路线改为已接收 if (joinDocumentBomRouting.getRoutingId() != null) { Routing routing = routingMapper.selectById(joinDocumentBomRouting.getRoutingId()); routing.setState(RoutingStates.ACCEPTED.getValue()); routingMapper.updateById(routing); } }); } /** * 生产计划工艺审批退回后执行 * * @param masterProductionSchedule * @param document */ @Async public void masterProductionScheduleDocReject(MasterProductionSchedule masterProductionSchedule, Document document) { masterProductionSchedule.setIsAudit(AuditStateStringValues.REJECT); document.setState(DocumentStates.REJECT.getValue()); masterProductionScheduleMapper.updateById(masterProductionSchedule); documentMapper.updateById(document); } @Override public R getOtcCustomerOrderFileList(String customerOrderNo) { return customerOrderUtil.getOtcCustomerOrderFileList(customerOrderNo); } @Override public boolean changeAudit(List ids, String isAudit) { List customerOrderList = baseMapper.selectList(Wrappers.lambdaQuery().in(CustomerOrder::getId, ids)); for (CustomerOrder customerOrder : customerOrderList) { if (isAudit.equals(customerOrder.getIsAudit())) { continue; } changeAudit(customerOrder, isAudit); } return true; } @Override public void export(HttpServletResponse response, QueryWrapper wrapper) throws IOException { response.setContentType("application/vnd.ms-excel"); response.setCharacterEncoding("UTF-8"); // 这里URLEncoder.encode可以防止中文乱码 当然和easyexcel没有关系 String fileName = URLEncoder.encode("客户订单导出", "UTF-8"); response.setHeader("Content-disposition", "attachment;filename=" + fileName + ".xlsx"); try { //新建ExcelWriter ExcelWriter excelWriter = EasyExcel.write(response.getOutputStream()).registerWriteHandler(new LongestMatchColumnWidthStyleStrategy()).build(); //获取sheet0对象 WriteSheet mainSheet = EasyExcel.writerSheet(0, "导出").head(CustomerOrderData.class).build(); //向sheet0写入数据 传入空list这样只导出表头 List customerOrderDataList = getExcelData(wrapper); excelWriter.write(customerOrderDataList, mainSheet); //关闭流 excelWriter.finish(); } catch (IOException e) { throw new RuntimeException("导出失败"); } } private List getExcelData(QueryWrapper wrapper) { List customerOrderDataList = baseMapper.getExport(wrapper); for (CustomerOrderData customerOrderData : customerOrderDataList) { List customerOrderParamList = customerOrderParamMapper.selectList(Wrappers.lambdaQuery() .isNotNull(CustomerOrderParam::getField) .isNotNull(CustomerOrderParam::getValue) .eq(CustomerOrderParam::getOrderId, customerOrderData.getId())); Map map = customerOrderParamList.stream().collect(Collectors.toMap(CustomerOrderParam::getField, CustomerOrderParam::getValue)); customerOrderData.setCoState(getCoStateValue(customerOrderData.getCoState())); customerOrderData.setIsAudit(getIsAuditValue(customerOrderData.getIsAudit())); customerOrderData.setContractEntity(map.get("contractEntity")); customerOrderData.setProductType(map.get("productType")); customerOrderData.setUnitPrice(map.get("unitPrice")); customerOrderData.setAmount(map.get("amount")); customerOrderData.setReceivingContact(map.get("receivingContact")); customerOrderData.setReceivingContactPhone(map.get("receivingContactPhone")); } return customerOrderDataList; } private String getIsAuditValue(String key) { switch (key) { case AuditStateStringValues.ACCEPTED: return "通过"; case AuditStateStringValues.DRAFT: return "草稿"; case AuditStateStringValues.PENDING: return "审核中"; case AuditStateStringValues.REJECT: return "退回"; case AuditStateStringValues.EXPECT: return "异常"; default: return ""; } } private String getCoStateValue(String key) { switch (key) { case CustomerOrderStateStringValues.PARTUNCHECKED: return "零件待选"; case CustomerOrderStateStringValues.TECHNOLOGYUNCHECK: return "工艺文件待选"; case CustomerOrderStateStringValues.PLAN: return "待计划"; case CustomerOrderStateStringValues.PLANED: return "已下发"; case CustomerOrderStateStringValues.CANCEL: return "已作废"; case CustomerOrderStateStringValues.UNIEDIT: return "零件编辑"; default: return ""; } } /** * 查询属性 * * @param key * @param value * @return */ @Override public List queryPartPropertiesStd(String key, String value) { List answer2 = new ArrayList<>(); Pattern regex = Pattern.compile(value); if (!captchaCacheService.exists(PART_PROPERTY + "_" + key)) { cachePartProperty(); } List stringList = new ArrayList<>(); String str = captchaCacheService.get(PART_PROPERTY + "_" + key); if (str == null || str.equals("")) { return null; } stringList = Arrays.asList(str.split(",")); for (String revalue : stringList) { if (regex.matcher(revalue).find()) { answer2.add(revalue); } if (answer2.size() > 19) { break; } } return answer2; } @Override public R uploadProcessConfigFile(MultipartFile file, String orderNumber, String lineNumber) { String fileName = FileUtil.extName(file.getOriginalFilename()); try { OrderProcessConfigFile configFile = new OrderProcessConfigFile(); configFile.setFileName(fileName); configFile.setOriginalFileName(file.getOriginalFilename()); configFile.setOrderNumber(orderNumber); configFile.setLineNumber(lineNumber); configFile.setBucketName(FileSaveUtil.StoreFile(file)); orderProcessConfigFileMapper.insert(configFile); ProcessConfigFileOrderMapping mapping = ProcessConfigFileOrderMapping.builder().configFileId(configFile.getId()) .orderNumber(orderNumber).lineNumber(lineNumber).build(); processConfigFileOrderMappingMapper.insert(mapping); return R.ok(); } catch (Exception e) { log.error("上传失败", e); TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return R.failed(e.getLocalizedMessage()); } } @Override public List getProcessConfigFiles(String orderNumber, String lineNumber) { return orderProcessConfigFileMapper.getProcessConfigFiles(orderNumber, lineNumber); } @Deprecated @Override public boolean updateRange(Long id, String range) { orderProcessConfigFileMapper.updateRange(id, range); return true; } @Override public void getFile(String bucket, String fileName, HttpServletResponse response) { try { String path = FileSaveUtil.FILE_PATH + bucket; InputStream inputStream = new FileInputStream(path); response.setContentType("application/octet-stream; charset=UTF-8"); IoUtil.copy(inputStream, response.getOutputStream()); } catch (Exception e) { log.error("文件读取异常: {}", e.getLocalizedMessage()); } } @Override public R deleteProcessConfigFile(Long id) { try { OrderProcessConfigFile configFile = orderProcessConfigFileMapper.selectById(id); String filePath=FileSaveUtil.FILE_PATH+"//"+configFile.getBucketName(); boolean del = FileUtil.del(new File(filePath)); //minioTemplate.removeObject(configFile.getBucketName(), configFile.getFileName()); orderProcessConfigFileMapper.deleteById(id); processConfigFileOrderMappingMapper.delete(Wrappers.lambdaQuery().eq(ProcessConfigFileOrderMapping::getConfigFileId, id)); return R.ok(); } catch (Exception e) { log.error(e.getMessage(), e); return R.failed(e.getMessage()); } } @Override public Boolean fileAssociatedOrder(FileAssociatedOrderDTO fileAssociatedOrderDTO) { Long configFileId = fileAssociatedOrderDTO.getConfigFileId(); List mappingList = fileAssociatedOrderDTO.getCustomerOrderList().stream().map(s -> ProcessConfigFileOrderMapping.builder().configFileId(configFileId) .orderNumber(s.getCustomerOrderNo()).lineNumber(s.getOtcLineNo()).build()).collect(Collectors.toList()); processConfigFileOrderMappingMapper.delete(Wrappers.lambdaQuery() .eq(ProcessConfigFileOrderMapping::getConfigFileId, configFileId)); return processConfigFileOrderMappingService.saveBatch(mappingList); } @Override public List processConfigMapping(Long id) { return processConfigFileOrderMappingMapper.selectList(Wrappers.lambdaQuery() .eq(ProcessConfigFileOrderMapping::getConfigFileId, id)); } @Override public void exportCustomerOrderSplit(HttpServletResponse response, CustomerOrderExportDTO customerOrderExportDTO) throws IOException { response.setContentType("application/vnd.ms-excel"); response.setCharacterEncoding("UTF-8"); // 这里URLEncoder.encode可以防止中文乱码 当然和easyexcel没有关系 String fileName = URLEncoder.encode("客户订单箱码导出", "UTF-8"); response.setHeader("Content-disposition", "attachment;filename=" + fileName + ".xls"); try { //新建ExcelWriter ExcelWriter excelWriter = EasyExcel.write(response.getOutputStream()).registerWriteHandler(new LongestMatchColumnWidthStyleStrategy()).build(); //获取sheet0对象 WriteSheet mainSheet = EasyExcel.writerSheet(0, "TM").head(CustomerOrderExportDTO.class).build(); //向sheet0写入数据 传入空list这样只导出表头 List customerOrderExportDTOList = getCustomerOrderExportList(customerOrderExportDTO); excelWriter.write(customerOrderExportDTOList, mainSheet); //关闭流 excelWriter.finish(); } catch (IOException e) { throw new RuntimeException("导出失败"); } } private List getCustomerOrderExportList(CustomerOrderExportDTO customerOrderExportDTO) { CustomerOrderExportData exportData = customerOrderMapper.getCustomerOrderExportData(customerOrderExportDTO.getId()); String currentDate = DateUtil.format(new Date(), "yyyy/MM/dd"); String dateCode = DateUtil.format(new Date(), "yyMM"); if (exportData.getOtcQuantity() == null) { throw new RuntimeException("没有OTC销售数量"); } BigDecimal count = exportData.getOtcQuantity().divide(customerOrderExportDTO.getSplitQuantity(), 0, RoundingMode.CEILING); List resultList = new ArrayList<>(); List relationList = new ArrayList<>(); Integer tail = 1; // 查询目前最大的箱码数 Integer maxTail = packageCodeCustomerOrderRelationMapper.getMaxTail(customerOrderExportDTO.getTitle() + dateCode); if (maxTail != null) { tail = maxTail + 1; } for (int i = 0; i < count.intValue(); i++) { BigDecimal splitQuantity = customerOrderExportDTO.getSplitQuantity().stripTrailingZeros(); if (i == count.intValue() - 1) { splitQuantity = exportData.getOtcQuantity().subtract(customerOrderExportDTO.getSplitQuantity().multiply(count.subtract(BigDecimal.ONE))).stripTrailingZeros(); } CustomerOrderExportDTO exportDTO = CustomerOrderExportDTO.builder() .orderNo(exportData.getCustomerOrderNo()) .currentDate(currentDate) .dateCode(dateCode) .spec(StringUtils.isNotBlank(exportData.getPartName()) ? exportData.getPartName().replace( "馈线跳线", StringUtils.EMPTY).trim() : StringUtils.EMPTY) .quantity(String.format("%02d", splitQuantity.longValue())) .title(customerOrderExportDTO.getTitle()) .tail(tail.toString()) .packageCode(customerOrderExportDTO.getTitle() + dateCode + String.format("%02d", splitQuantity.longValue()) + tail) .build(); PackagingExportQrCodeData qrCodeData = PackagingExportQrCodeData.builder() .partNo(exportData.getPartNo()).lotBatchNo("*").qtyArrived(splitQuantity.toPlainString()) .wdr(exportDTO.getPackageCode()).unitMeas(exportData.getOtcUnit()).packageCode(exportDTO.getPackageCode()) .materialCode(exportData.getCusMaterialCode()).build(); exportDTO.setQrCode(JSON.toJSONString(qrCodeData, SerializerFeature.WriteNullStringAsEmpty)); resultList.add(exportDTO); PackageCodeCustomerOrderRelation orderRelation = PackageCodeCustomerOrderRelation.builder().customerOrderId(customerOrderExportDTO.getId()).customerOrderNo(exportData.getCustomerOrderNo()) .otcLineNo(exportData.getOtcLineNo()).packageCode(exportDTO.getPackageCode()).build(); relationList.add(orderRelation); tail++; } try { packageCodeCustomerOrderRelationService.saveBatch(relationList); } catch (DuplicateKeyException e) { throw new RuntimeException("箱码重复，请重新导出"); } return resultList; } public void cachePartProperty() { JSONObject jsonObject = new JSONObject(); jsonObject.put("ATTRIBUTE", "规格;型号;电压等级"); //设置缓存时间 Long seconds = new Long(600); R result = ifsFeignClient.queryPartPropertiesStd(jsonObject, true); if (result.getCode() == 0) { JSONObject data = (JSONObject) JSON.toJSON(result.getData()); JSONArray jsonArray = data.getJSONArray("LIST_INFO"); Map> map = new HashMap<>(); if (CollectionUtil.isNotEmpty(jsonArray)) { List jsonObjects = JSONObject.parseArray(jsonArray.toJSONString(), JSONObject.class); map = jsonObjects.stream().collect(Collectors.groupingBy(item -> item.getString("ATTRIBUTE"), Collectors.mapping(a -> a.getString("ATTRIBUTE_VALUE"), Collectors.toList()))); } if (CollectionUtil.isNotEmpty(map.get("规格"))) { List list = map.get("规格").stream().distinct().collect(Collectors.toList()); captchaCacheService.set(PART_PROPERTY + "_规格", list.toString(), seconds); } if (CollectionUtil.isNotEmpty(map.get("型号"))) { List list = map.get("型号").stream().distinct().collect(Collectors.toList()); captchaCacheService.set(PART_PROPERTY + "_型号", list.toString(), seconds); } if (CollectionUtil.isNotEmpty(map.get("电压等级"))) { List list = map.get("电压等级").stream().distinct().collect(Collectors.toList()); captchaCacheService.set(PART_PROPERTY + "_电压等级", list.toString(), seconds); } } } /** * 添加主表信息(股份公司) * * @param selectTime 时间 * @param token token * @return */ private R addCustomerFromOtcForJointStockCompany(String selectTime, String token) { try { Map map = new HashMap<>(); if (StringUtils.isNotBlank(selectTime)) { map.put("selectTime", selectTime); } String str = HttpRequest.get(customerOrderClientConfigure.getOtcHost() + customerOrderClientConfigure.getOtcCustomerUrl()) .contentType("application/json") .header("Authorization", "Bearer " + token).form(map).execute().body(); JSONObject result = JSONObject.parseObject(str); //主表参数表 List orderParams = orderParamService.list(); if (result.getInteger("code") == 0) { int num = 0; int detailNum = 0; JSONArray jsonArray = result.getJSONArray("data"); for (Object obj : jsonArray) { JSONObject customerJSONObject = JSONObject.parseObject(obj.toString()); //合同编号 String contractNo = customerJSONObject.getString("orderNo"); //主表在OTC中的状态 String otcMainStatus = customerJSONObject.getString("status"); //所属公司 String affiliatedCompany = customerJSONObject.getString("affiliatedCompany"); // 不在这几个状态中的数据就跳过 if (!Arrays.asList(CustomerOrderStateStringValues.GETOTCSTATE).contains(otcMainStatus)) { continue; } CustomerForJointStockCompany customer = customerForJointStockCompanyMapper.selectOne(Wrappers.lambdaQuery().eq(CustomerForJointStockCompany::getContractNo, contractNo)); if (customer == null) { customer = new CustomerForJointStockCompany(); } //如果OTC中主表状态是取消那就跳过或者删除已经同步的数据 if (otcMainStatus.equals("已取消")) { if (customer.getId() != null) { customerForJointStockCompanyMapper.deleteById(customer.getId()); customerOrderForJointStockCompanyMapper.delete(Wrappers.lambdaQuery().eq(CustomerOrderForJointStockCompany::getCustomerId, customer.getId())); } continue; } if (null == affiliatedCompany || !Arrays.asList("已审核", "已下达").contains(otcMainStatus) || !affiliatedCompany.equals("江苏中天科技股份有限公司")) { continue;//只获取OTC中已审核的，且所属公司为股份公司的 } //客户编号 customer.setCustomerNo(customerJSONObject.getString("customerNo")); //合同号 customer.setContractNo(contractNo); //客户合同号 customer.setCustomerContractNo(customerJSONObject.getString("customerContractNumber")); //客户名称 customer.setCustomerName(customerJSONObject.getString("customerName")); //工程名称 customer.setEntityName(customerJSONObject.getString("projectName")); //交货日期 customer.setDeliveryDate(customerJSONObject.get("wantedDeliveryDate") != null ? customerJSONObject.getDate("wantedDeliveryDate").toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime() : null); //事业部 customer.setSalesDepartment(customerJSONObject.getString("division")); //省份 customer.setProvince(customerJSONObject.getString("province")); //业务员名称 customer.setSalesMan(customerJSONObject.getString("salesmanName")); //业务员编号 customer.setSalerWorkCode(customerJSONObject.getString("salesmanNo")); //正本状态 customer.setOriginalContractStatus(customerJSONObject.getString("originalStatus")); //合同正本状态 customer.setReturnStatus(customerJSONObject.getString("returnStatus")); //项目性质 customer.setIsCp(customerJSONObject.getString("natureOfProjectExecution")); //下单日期 customer.setPlaceOrderDate(customerJSONObject.getDate("orderDate").toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime()); //审核日期 customer.setVerifyDate(customerJSONObject.get("reviewTime") != null ? customerJSONObject.getDate("reviewTime").toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime() : null); //工厂下单日期 customer.setFactoryPlaceOrderDate(customerJSONObject.get("factoryOrderDate") != null ? customerJSONObject.getDate("factoryOrderDate").toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime() : null); //备注 customer.setComment(customerJSONObject.getString("comment")); if (customer.getId() == null) { customerForJointStockCompanyMapper.insert(customer); } else { customerForJointStockCompanyMapper.updateById(customer); } num += 1; detailNum += addCustomerOrderFromOtcForJointStockCompany(customerJSONObject, customer, token, orderParams); } return R.ok().setMsg("同步或更新合同主体" + num + "条,合同明细" + detailNum + "条！"); } else { return R.failed("订单主体获取失败"); } } catch (Exception e) { throw new RuntimeException(e.getMessage()); } } /** * 添加子表信息(股份公司) * * @param customer * @throws */ private int addCustomerOrderFromOtcForJointStockCompany(JSONObject customerJSONObject, CustomerForJointStockCompany customer, String token, List orderParamList) { int num = 0; try { Map map = new HashMap<>(); map.put("orderNo", customer.getContractNo()); map.put("selectTime", "1899-12-31 23:59:59"); JSONObject result = JSONObject.parseObject(HttpRequest.get(customerOrderClientConfigure.getOtcHost() + customerOrderClientConfigure.getOtcCustomerOrderUrl()) .contentType("application/json") .header("Authorization", "Bearer " + token).form(map).execute().body()); if (result.getInteger("code") == 0) { JSONArray jsonArray = result.getJSONArray("data"); for (Object obj : jsonArray) { JSONObject customerOrderJSONObject = JSONObject.parseObject(obj.toString()); String otcLoneId = customerOrderJSONObject.getLong("id").toString(); //OTC的订单状态 String otcOrderStatus = customerOrderJSONObject.getString("lineStatus").toString(); CustomerOrderForJointStockCompany customerOrder = customerOrderForJointStockCompanyMapper.selectOne(Wrappers.lambdaQuery() .eq(CustomerOrderForJointStockCompany::getOtcLineNo, otcLoneId)); if (customerOrder == null) { customerOrder = new CustomerOrderForJointStockCompany(); } //如果这个单子在OTC中取消状态 那就删除 if (otcOrderStatus.equals("已取消")) { if (customer.getId() != null) { customerOrderForJointStockCompanyMapper.deleteById(customer.getId()); } continue; } //OTC合同号主表id customerOrder.setOtcOrderId(customerOrderJSONObject.getLong("orderId")); //otc行号 customerOrder.setOtcLineNo(otcLoneId); //零件号 customerOrder.setSalesPartNo(customerOrderJSONObject.getString("partNo")); //来源 customerOrder.setSourceId("OTC"); //合同号 customerOrder.setCustomerOrderNo(customer.getContractNo()); //客户号 customerOrder.setCustomerNo(customer.getCustomerNo()); //客户名称 customerOrder.setCustomerName(customer.getCustomerName()); //销售数量原先OTC的单位 customerOrder.setOtcQuantity(customerOrderJSONObject.getBigDecimal("quantity")); //OTC单位 customerOrder.setOtcUnit(customerOrderJSONObject.getString("unit")); //期望交货日期 customerOrder.setWantedDeliveryDate(customer.getDeliveryDate()); //主表id customerOrder.setCustomerId(customer.getId()); //电压等级 customerOrder.setVoltAgeClass(customerOrderJSONObject.getString("voltageLevel")); //外呼颜色 customerOrder.setOuterColor(customerOrderJSONObject.getString("outerSheathColor")); //客户零件名称 customerOrder.setProductName(customerOrderJSONObject.getString("productName")); //客户零件规格 customerOrder.setCustomerPartSpec(customerOrderJSONObject.getString("specificationModel")); //订单版本 customerOrder.setVersion(customerOrderJSONObject.getInteger("version")); //事业部 customerOrder.setDivision(customerOrderJSONObject.getString("division")); //印字类型 customerOrder.setPrintType(customerOrderJSONObject.getString("printType")); //印字要求 customerOrder.setPrintingRequirements(customerOrderJSONObject.getString("printingRequirements")); //包装要求 customerOrder.setPackageRequire(customerOrderJSONObject.getString("packageRequire")); //质量要求 customerOrder.setQualityRequire(customerOrderJSONObject.getString("qualityRequire")); //生产需求说明 customerOrder.setOtherProductRequire(customerOrderJSONObject.getString("otherProductRequire")); //系统 customerOrder.setDivisionSystem(customerOrderJSONObject.getString("divisionSystem")); //收货地址 customerOrder.setShippingAddress(customerOrderJSONObject.getString("shippingAddress")); //业务员 customerOrder.setSalesmanName(customer.getSalesMan()); //盘长要求 customerOrder.setLengthRequirement(customerOrderJSONObject.getString("lengthRequirement")); //备注 customerOrder.setRemark(customerOrderJSONObject.getString("comment")); //零件是否推送 customerOrder.setOtcPartSync(false); // 默认为N 数据字典为：N：普通，S：样品，D：研发 customerOrder.setManufactureAttr("N"); if (customerOrder.getId() == null) { //是否关联工艺文件为否 customerOrder.setIsDocument(false); //状态为 01plan customerOrder.setCoState(CustomerOrderStateStringValues.PARTUNCHECKED); //审核状态为 01draft 草稿 customerOrder.setIsAudit(AuditStateStringValues.DRAFT); customerOrderForJointStockCompanyMapper.insert(customerOrder); } else { customerOrderForJointStockCompanyMapper.updateById(customerOrder); } addCustomerParaForJointStockCompany(customerJSONObject, customerOrderJSONObject, customerOrder, orderParamList); num += 1; } } } catch (Exception e) { throw new RuntimeException("订单行数据获取失败，原因：" + e.getMessage()); } return num; } @Override public R checkOA(List ids) { List customerOrderListByAudit = baseMapper.selectList(Wrappers.lambdaQuery() .in(CustomerOrder::getId, ids) .and(i -> i.eq(CustomerOrder::getIsAudit, AuditStateStringValues.PENDING) .or().eq(CustomerOrder::getIsAudit, AuditStateStringValues.ACCEPTED))); if (CollectionUtil.isNotEmpty(customerOrderListByAudit)) { throw new RuntimeException("审核状态不可以是审核中和通过"); } List customerOrderListByIds = baseMapper.selectBatchIds(ids); Set orderNoSet = customerOrderListByIds.stream().map(CustomerOrder::getCustomerOrderNo).collect(Collectors.toSet()); List otcLineNoList = customerOrderListByIds.stream().map(CustomerOrder::getOtcLineNo).collect(Collectors.toList()); if (orderNoSet.size() != 1) { throw new RuntimeException("订单号不唯一"); } Iterator iterator = orderNoSet.iterator(); String orderNo = (String) iterator.next(); List customerOrderList = baseMapper.selectList(Wrappers.lambdaQuery().eq(CustomerOrder::getCustomerOrderNo, orderNo)); List otcLineNoBySearchList = customerOrderList.stream().map(CustomerOrder::getOtcLineNo).collect(Collectors.toList()); if (otcLineNoList.size() == otcLineNoBySearchList.size()) { return R.ok(CheckOADTO.builder().success(Boolean.TRUE).build()); } else { otcLineNoBySearchList.removeAll(otcLineNoList); if (CollectionUtil.isNotEmpty(otcLineNoBySearchList)) { return R.ok(CheckOADTO.builder().success(Boolean.FALSE).message("以下行号未勾选，是否继续提交" + otcLineNoBySearchList.toString()).build()); } return R.ok(CheckOADTO.builder().success(Boolean.TRUE).build()); } } @Override public List getOADetailDTO(List ids) { return baseMapper.getOADetail(ids); } @Override public R getProcessConfigFiles(String customerOrderNo) { List configFiles = orderProcessConfigFileMapper.getProcessConfigFilesByOrderNo(customerOrderNo); return R.ok(configFiles); } @Override public R getTechnologyDocument(Long technologyDocumentId) { return R.ok(documentMapper.getBomRoutingDtoByDocId(technologyDocumentId)); } @Override public R getDocumentJgt(Long technologyDocumentId) { return R.ok(documentJgtMapper.selectList(Wrappers.lambdaQuery() .eq(DocumentJgt::getDocumentId, technologyDocumentId))); } @Override public Boolean validatePackageCodeSnCustomerOrder(PackagingDTO packagingDTO) { Packaging packaging = packagingMapper.selectById(packagingDTO.getId()); PackageCodeCustomerOrderRelation relation = packageCodeCustomerOrderRelationMapper.selectOne(Wrappers.lambdaQuery() .eq(PackageCodeCustomerOrderRelation::getPackageCode, packaging.getNo())); if (null == relation) { return Boolean.TRUE; } if (CollectionUtil.isNotEmpty(packagingDTO.getStockList())) { for (Stock stock : packagingDTO.getStockList()) { CustomerOrder customerOrder = customerOrderMapper.getCustomerOrderByProductOutput(stock.getPartBatchNo()); if (null == customerOrder) { continue; } if (!relation.getCustomerOrderId().equals(customerOrder.getId())) { throw new RuntimeException("当前SN与箱码对应销售订单不一致"); } } } return Boolean.TRUE; } @Override public void pushPartNoToOtc(OACallBackResult callBackResult) { if (org.apache.commons.lang3.StringUtils.equals("customerOrder", callBackResult.getSource()) && org.apache.commons.lang3.StringUtils.equals("1", callBackResult.getResult())) { List customerOrderList = getBaseMapper().selectList(Wrappers.lambdaQuery().eq(CustomerOrder::getOaWorkflowId , callBackResult.getWorkflowId())); for (CustomerOrder customerOrder : customerOrderList) { try { if (StringUtils.isNotBlank(customerOrder.getSalesPartNo())) { String token = customerOrderUtil.getToken(); JSONArray jsonArray = new JSONArray().fluentAdd(new JSONObject() .fluentPut("lineId", new Long(customerOrder.getOtcLineNo())) .fluentPut("orderId", customerOrder.getOtcOrderId()) .fluentPut("partNo", customerOrder.getSalesPartNo()) .fluentPut("version", customerOrder.getVersion())); String str = HttpRequest.post(customerOrderClientConfigure.getOtcHost() + customerOrderClientConfigure.getOtcPushPartNoUrl()) .contentType("application/json") .header("Authorization", "Bearer " + token).body(JSONArray.toJSONString(jsonArray)).execute().body(); JSONObject result = JSONObject.parseObject(str); if (result.getInteger("code") == 0) { customerOrder.setOtcPartSync(true); baseMapper.updateById(customerOrder); } } } catch (Exception e) { throw new RuntimeException("token获取异常"); } } } } @Override public void pushCustomersToOtc(List ids, String isAudit) { List customerOrderList = baseMapper.selectList(Wrappers.lambdaQuery().in(CustomerOrder::getId, ids).eq(CustomerOrder::getOtcPartSync, false)); if (StrUtil.equals(isAudit, AuditStateStringValues.ACCEPTED)) { for (CustomerOrder customerOrder : customerOrderList) { if (StrUtil.equals(customerOrder.getSourceId(), "OTC")) { pushotc(customerOrder); } } } } @Override public void sendWxMsgAuto() { List customerOrderList = baseMapper.selectList(Wrappers.lambdaQuery() .eq(CustomerOrder::getCoState, "01partUnCheck") .eq(CustomerOrder::getIsSend, false)); String commonString = "您好，以下销售订单行状态为零件待选，请及时处理：
"; String[] split; if (CollectionUtil.isNotEmpty(customerOrderList)) { List signList = customerOrderList.stream().filter(a -> "信号".equals(a.getProductGroup())).collect(Collectors.toList()); List radioList = customerOrderList.stream().filter(a -> "射频".equals(a.getProductGroup())).collect(Collectors.toList()); List assemblyList = customerOrderList.stream().filter(a -> "组件".equals(a.getProductGroup())).collect(Collectors.toList()); List electricList = customerOrderList.stream().filter(a -> "光电".equals(a.getProductGroup())).collect(Collectors.toList()); List fixtureList = customerOrderList.stream().filter(a -> "卡具".equals(a.getProductGroup())).collect(Collectors.toList()); List temperatureList = customerOrderList.stream().filter(a -> "高温".equals(a.getProductGroup())).collect(Collectors.toList()); List engineList = customerOrderList.stream().filter(a -> "机车".equals(a.getProductGroup())).collect(Collectors.toList()); List otherList = customerOrderList.stream().filter(a -> "其他".equals(a.getProductGroup())).collect(Collectors.toList()); //根据分组发送给对应负责人 sendMsgByGroup(signList, wechatProperty.getSign()); sendMsgByGroup(radioList, wechatProperty.getRadio()); sendMsgByGroup(assemblyList, wechatProperty.getAssembly()); sendMsgByGroup(electricList, wechatProperty.getElectric()); sendMsgByGroup(fixtureList, wechatProperty.getFixture()); sendMsgByGroup(temperatureList, wechatProperty.getTemperature()); sendMsgByGroup(engineList, wechatProperty.getEngine()); sendMsgByGroup(otherList, wechatProperty.getOther()); //更新发送状态 for (CustomerOrder customerOrder : customerOrderList) { customerOrder.setIsSend(true); } updateBatchById(customerOrderList); } } /** * 根据分组发送给对应负责人 * * @param groupList * @param chargePeople * @return */ void sendMsgByGroup(List groupList, String chargePeople) { String commonString = "您好，以下销售订单行状态为零件待选，请及时处理：
"; String[] split; if (groupList.size() != 0) { int num = groupList.size() / 20; //发送数量超过20条 for (int i = 0; i < num; i++) { StringBuilder builder = new StringBuilder(commonString); for (int j = 0; j < 20; j++) { builder.append("订单号:").append(groupList.get(j + i * 20).getCustomerOrderNo()).append("
") .append("OTC行号:").append(groupList.get(j + i * 20).getOtcLineNo()).append("
") .append("产品分组:").append(groupList.get(j + i * 20).getProductGroup()).append("
") .append("产品类型:").append(groupList.get(j + i * 20).getProductType()).append("
"); } if (StringUtils.isNotBlank(chargePeople)) { split = chargePeople.split(","); List userList = Arrays.asList(split); WechatMsgTips.sendOaNotice(userList, builder.toString(), "MES消息提醒："); } } //小于20条数据或者20条成倍数后多出来的数据 StringBuilder builder = new StringBuilder(commonString); for (int j = 20 * num; j < groupList.size(); j++) { builder.append("订单号:").append(groupList.get(j).getCustomerOrderNo()).append("
") .append("OTC行号:").append(groupList.get(j).getOtcLineNo()).append("
") .append("产品分组:").append(groupList.get(j).getProductGroup()).append("
") .append("产品类型:").append(groupList.get(j).getProductType()).append("
"); } if (StringUtils.isNotBlank(chargePeople)) { split = chargePeople.split(","); List userList = Arrays.asList(split); WechatMsgTips.sendOaNotice(userList, builder.toString(), "MES消息提醒："); } } } /** * 同步更新工艺配置单订单行待选列表 * * @param customerOrderNo * @param id * @return */ @Override public List getBeSelectedLineNoList(String customerOrderNo, Long id) { //查询该订单号下除原本编辑订单行外的其他订单行记录 List customerOrderList = baseMapper.getByCustomerOrderNo(customerOrderNo, id); if (CollectionUtil.isNotEmpty(customerOrderList)) { //查询该订单号下已经配置过的订单行id List processConfigList = processConfigMapper.selectList(Wrappers.lambdaQuery() .eq(ProcessConfig::getOrderNumber, customerOrderNo)); if (CollectionUtil.isNotEmpty(processConfigList)) { List configuredIdList = processConfigList.stream().map(ProcessConfig::getOrderId).collect(Collectors.toList()); for (CustomerOrderDTO customerOrderDTO : customerOrderList) { if (configuredIdList.contains(customerOrderDTO.getId())) { customerOrderDTO.setExistProcessConfig(true); } else { customerOrderDTO.setExistProcessConfig(false); } } } else { customerOrderList.stream().forEach(o -> o.setExistProcessConfig(false)); } //是否提交字段为前端使用判断 customerOrderList.stream().forEach(o -> o.setCommonChecked(false)); return customerOrderList; } return null; } @Override public boolean returnOrder(CustomerOrderDTO customerOrderDTO) { if (CollectionUtil.isNotEmpty(customerOrderDTO.getCustomerOrderIds())) { String staffNos = remoteParamService.getByKey(MO_RETURN_STAFF, SecurityConstants.FROM_IN).getData(); if (StringUtils.isBlank(staffNos)) { throw new RuntimeException("请先在系统参数管理中配置退回通知人员"); } List customerOrderList = baseMapper.selectList(Wrappers.lambdaQuery().in(CustomerOrder::getId, customerOrderDTO.getCustomerOrderIds())); this.baseMapper.update(null, Wrappers.lambdaUpdate() .set(CustomerOrder::getReturnUser, customerOrderDTO.getReturnUser()) .set(CustomerOrder::getReturnReason, customerOrderDTO.getReturnReason()) .in(CustomerOrder::getId, customerOrderDTO.getCustomerOrderIds())); StringBuilder content = new StringBuilder("您好，技术部有如下订单退回，请登录OTC系统进行处理：
"); for (CustomerOrder customerOrder : customerOrderList) { content.append("
") .append("订单编号：").append(customerOrder.getCustomerOrderNo()).append("
") .append("OTC行号：").append(customerOrder.getOtcLineNo()).append("
") .append("客户名称：").append(customerOrder.getCustomerName()).append("
") .append("退回原因：").append(customerOrderDTO.getReturnReason()).append("
") .append("退回人员：").append(customerOrderDTO.getReturnUser()).append("
") .append("退回时间：").append(DateUtil.now()).append("
"); } WechatMsgTips.sendOaNotice(Arrays.asList(staffNos), content.toString(), "MES消息提醒："); } return true; } @Override public boolean changeCheckState(List ids, String isAudit) { boolean isSuccess = false; try { isSuccess = changeAudit(ids, isAudit); if (BooleanUtil.isTrue(isSuccess)) { pushCustomersToOtc(ids, isAudit); } } catch (Exception e) { log.error(e.getMessage(), e); throw new RuntimeException(e.getMessage()); } return isSuccess; } @Override public long syncOrder(CustomOrderSyncDTO customOrderSyncDTO) { CloseableHttpClient httpClient = HttpClientBuilder.create().build(); String syncErpUrl = environment.getProperty("erpUrl"); HttpPost httpPost = new HttpPost(syncErpUrl); long count = 0; // 将参数转换为JSON字符串 Map params = new HashMap<>(); params.put("startTime", customOrderSyncDTO.getStartTime()); params.put("endTime", customOrderSyncDTO.getEndTime()); String jsonParams = new Gson().toJson(params); // 设置请求体为JSON格式 StringEntity requestEntity = new StringEntity(jsonParams, ContentType.APPLICATION_JSON); httpPost.setEntity(requestEntity); String responseString = null; try { CloseableHttpResponse response = httpClient.execute(httpPost); HttpEntity entity = response.getEntity(); responseString = EntityUtils.toString(entity, "UTF-8"); log.info(responseString); if (StringUtils.isNotBlank(responseString)) { R r = new Gson().fromJson(responseString, R.class); if (r.getCode() == 0) { count = ((Double) r.getData()).longValue(); }else{ throw new RuntimeException(r.getMsg()); } } response.close(); } catch (IOException e) { e.printStackTrace(); throw new RuntimeException(e.getMessage()); } finally { try { httpClient.close(); } catch (IOException e) { e.printStackTrace(); } } return count; } @Override public IPage getAuditedOrderNoPage(String customerOrderNo, Page page) { return this.baseMapper.getAuditedOrderNoPage(customerOrderNo, page); } @Override public void dropByContractNo(String contractNo) { //1、删主表 customerMapper.delete(new LambdaQueryWrapper().eq(Customer::getContractNo, contractNo)); //2、删子表 customerOrderMapper.delete(new LambdaQueryWrapper().eq(CustomerOrder::getCustomerOrderNo, contractNo)); } }