diff --git a/src/main/java/com/dsic/gj_erp/bean/jhgk/DmSygdMx.java b/src/main/java/com/dsic/gj_erp/bean/jhgk/DmSygdMx.java index 736891b..a40f32f 100644 --- a/src/main/java/com/dsic/gj_erp/bean/jhgk/DmSygdMx.java +++ b/src/main/java/com/dsic/gj_erp/bean/jhgk/DmSygdMx.java @@ -235,6 +235,7 @@ public class DmSygdMx implements Serializable { this.qjgrq=date; break; case 打磨: + this.dmrq=date; break; case 号料: break; diff --git a/src/main/java/com/dsic/gj_erp/service/jhgk/impl/DmYdjhServiceImpl.java b/src/main/java/com/dsic/gj_erp/service/jhgk/impl/DmYdjhServiceImpl.java index 3a43474..84ca794 100644 --- a/src/main/java/com/dsic/gj_erp/service/jhgk/impl/DmYdjhServiceImpl.java +++ b/src/main/java/com/dsic/gj_erp/service/jhgk/impl/DmYdjhServiceImpl.java @@ -3,6 +3,7 @@ package com.dsic.gj_erp.service.jhgk.impl; import cn.hutool.core.date.DateTime; import cn.hutool.core.date.DateUtil; +import cn.hutool.core.util.StrUtil; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; @@ -15,9 +16,11 @@ import com.dsic.gj_erp.service.jhgk.DmQfxqService; import com.dsic.gj_erp.service.jhgk.DmYdjhService; import com.dsic.gj_erp.service.jiuzhou.SljhService; import com.dsic.gj_erp.service.pgd.*; +import io.swagger.models.auth.In; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.ApplicationEventPublisher; +import org.springframework.data.redis.core.RedisTemplate; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; @@ -232,24 +235,42 @@ public class DmYdjhServiceImpl extends ServiceImpl impleme @Resource private ApplicationEventPublisher publisher; + @Autowired + private RedisTemplate redisTemplate; + //下发 派工单状态改为编制 生成零件信息 @Override + @Transactional(rollbackFor = Exception.class) public void xf(List ydjhList, HttpServletRequest request) { String bzry= (String) request.getAttribute("yhms"); String bzrq= DateUtil.format(DateUtil.date(), "yyyy/MM/dd"); - //修改状态 + + //工单号 + List updateList = ydjhList.stream().map(item -> { + Long increment = redisTemplate.opsForHash().increment("ZYJH_GDH::", item.getSljhrq(), 1); + DmYdjh dmYdjh = new DmYdjh(); + dmYdjh.setId(item.getId()); + dmYdjh.setZt("2"); + dmYdjh.setDjh(StrUtil.format("{}{}",item.getSljhrq().replace("/",""), String.format("%03d",increment))); + return dmYdjh; + }).collect(Collectors.toList()); + + this.updateBatchById(updateList); + List idList = ydjhList.stream().map(DmYdjh::getId).collect(Collectors.toList()); if (idList.size() > 100) { List list = idList.subList(idList.size() / 100 * 100, idList.size()); AtomicInteger index = new AtomicInteger(idList.size() / 100 + 1); - this.update(new UpdateWrapper().set("zt", "2") - .in("id", list) - ); + +// this.update(new UpdateWrapper().set("zt", "2") +// .in("id", list) +// ); // 生成 数据 baseMapper.getTzjh(list,bzry,bzrq); + //作业计划零件数据 baseMapper.tqlj(list); do { int i = index.decrementAndGet(); @@ -259,23 +280,22 @@ public class DmYdjhServiceImpl extends ServiceImpl impleme ); baseMapper.getTzjh(list1,bzry,bzrq); + //作业计划零件数据 baseMapper.tqlj(list1); }while (index.get()>1); }else { - this.update(new UpdateWrapper().set("zt", "2") - .in("id", idList) - ); +// this.update(new UpdateWrapper().set("zt", "2") +// .in("id", idList) +// ); // //修改汇总状态 改为 编制 // baseMapper.xfbc(idList); // //生成对应零件信息 bom->tzjhLj // baseMapper.tqlj(idList); // baseMapper.xfbc(idList); baseMapper.getTzjh(idList,bzry,bzrq); - baseMapper.getSljh(idList,bzry,bzrq); - baseMapper.getPwjh(idList,bzry,bzrq); - baseMapper.getQgjh(idList,bzry,bzrq); + //作业计划零件数据 baseMapper.tqlj(idList); } diff --git a/src/main/resources/mappers/jhgk/DmQfxqMapper.xml b/src/main/resources/mappers/jhgk/DmQfxqMapper.xml index 7f58f8a..83d1cbe 100644 --- a/src/main/resources/mappers/jhgk/DmQfxqMapper.xml +++ b/src/main/resources/mappers/jhgk/DmQfxqMapper.xml @@ -54,7 +54,10 @@ dm_sygd_mx.bcqpyld, dm_sygd_mx.ylbhgg, dm_sygd_mx.xxr, - dm_qfxq.dzglxq as gjjs_dz + dm_sygd_mx.pkrq, + dm_sygd_mx.qjgrq, + dm_sygd_mx.dmrq + dm_qfxq.dzglxq as gjjs_dz from (SELECT * from ( SELECT