package com.vincent.rsf.server.manager.service.impl; import cn.afterturn.easypoi.excel.ExcelImportUtil; import cn.afterturn.easypoi.excel.entity.result.ExcelImportResult; import com.alibaba.fastjson.JSONObject; 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.vincent.rsf.framework.common.R; import com.vincent.rsf.framework.exception.CoolException; import com.vincent.rsf.server.common.domain.BaseParam; import com.vincent.rsf.server.common.domain.PageParam; import com.vincent.rsf.server.common.utils.ExcelUtil; import com.vincent.rsf.server.manager.entity.AsnOrder; import com.vincent.rsf.server.manager.entity.excel.AsnOrderTemplate; import com.vincent.rsf.server.manager.mapper.AsnOrderItemMapper; import com.vincent.rsf.server.manager.entity.AsnOrderItem; import com.vincent.rsf.server.manager.mapper.AsnOrderMapper; import com.vincent.rsf.server.manager.service.AsnOrderItemService; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.vincent.rsf.server.system.service.FieldsItemService; import com.vincent.rsf.server.system.service.FieldsService; import com.vincent.rsf.server.system.utils.ExtendFieldsUtils; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.web.multipart.MultipartFile; import javax.annotation.Resource; import java.util.*; @Service("asnOrderItemService") public class AsnOrderItemServiceImpl extends ServiceImpl implements AsnOrderItemService { @Resource private AsnOrderMapper asnOrderMapper; @Autowired private FieldsService fieldsService; @Autowired private FieldsItemService fieldsItemService; @Override @Transactional(rollbackFor = Exception.class) public R excelImport(MultipartFile file, HashMap hashMap) throws Exception { ExcelImportResult result = ExcelImportUtil.importExcelMore(file.getInputStream(), AsnOrderTemplate.class, ExcelUtil.getDefaultImportParams()); if (result.getList().isEmpty()) { throw new CoolException("物料导入失败!!"); } if (!Objects.isNull(hashMap.get("asnId"))) { throw new CoolException("主单ID为空,无法操作!!"); } AsnOrder order = asnOrderMapper.selectOne(new LambdaQueryWrapper().eq(AsnOrder::getId, hashMap.get("asnId"))); if (Objects.isNull(order)) { throw new CoolException("ASN单据不存在!!"); } List itemList = new ArrayList<>(); result.getList().forEach(template -> { AsnOrderItem orderItem = new AsnOrderItem(); BeanUtils.copyProperties(template, orderItem); orderItem.setAsnId(order.getId()) .setAsnCode(order.getCode()); itemList.add(orderItem); }); if (!this.saveBatch(itemList)) { throw new CoolException("保存失败!!"); } return R.ok("操作成功!!"); } @Override public boolean fieldsSave(Map params) { //保存扩展字段 ExtendFieldsUtils.saveFields(params); AsnOrderItem asnOrderItem = JSONObject.parseObject(JSONObject.toJSONString(params), AsnOrderItem.class); if (!this.saveOrUpdate(asnOrderItem)) { throw new CoolException("收货通知单明细保存失败!!"); } return true; } @Override public IPage> listByAsnId(PageParam pageParam, QueryWrapper buildWrapper) { IPage> hsahMap = this.baseMapper.resultForMap(pageParam, buildWrapper); if (hsahMap.getRecords().isEmpty()) { return hsahMap.setRecords(new ArrayList<>()); } hsahMap.setRecords(ExtendFieldsUtils.getExtendFields(hsahMap.getRecords())); return hsahMap; } }