diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/auToTask/bean/AutoCreateLubricate.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/auToTask/bean/AutoCreateLubricate.java index f9436315..a92863a9 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/auToTask/bean/AutoCreateLubricate.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/auToTask/bean/AutoCreateLubricate.java @@ -76,6 +76,11 @@ public class AutoCreateLubricate { if (num <= 3) { this.createMain(param); } + // 周期为周 :当前日期-保养计划日期 <= 1 天时,新增保养单 + } else if (StrUtil.equals(maintenancecycle,"04")) { + if (num <= 1) { + this.createMain(param); + } } } } else { @@ -114,6 +119,11 @@ public class AutoCreateLubricate { if (num >= 3) { this.createMain(param); } + // 周期为日 :当前日期-保养实际结束 <= 1 天时,新增保养单 + } else if (StrUtil.equals(maintenancecycle,"04")) { + if (num >= 1) { + this.createMain(param); + } } } } diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/auToTask/bean/AutoCreateRepair.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/auToTask/bean/AutoCreateRepair.java index 2e069ec6..4f47b2c4 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/auToTask/bean/AutoCreateRepair.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/auToTask/bean/AutoCreateRepair.java @@ -81,6 +81,11 @@ public class AutoCreateRepair { if (num <= 3) { this.createRepair(param); } + // 周期为日 : 维修计划日期 - 当前日期 <= 1 天时,新增维修单 + } else if (StrUtil.equals(maintenancecycle,"05")) { + if (num <= 1) { + this.createRepair(param); + } } } } else { @@ -122,6 +127,11 @@ public class AutoCreateRepair { if (num >= 3) { this.createRepair(param); } + // 周期为日 :当前日期-维修实际结束 <= 1 天时,新增维修单 + } else if (StrUtil.equals(maintenancecycle,"05")) { + if (num >= 1) { + this.createRepair(param); + } } } } diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/auToTask/bean/AutoCreateSportCheck.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/auToTask/bean/AutoCreateSportCheck.java index c5476508..c06a6c9b 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/auToTask/bean/AutoCreateSportCheck.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/auToTask/bean/AutoCreateSportCheck.java @@ -76,6 +76,10 @@ public class AutoCreateSportCheck { if (num <= 3) { this.createMain(param); } + } else if (StrUtil.equals(maintenancecycle,"04")) { + if (num <= 1) { + this.createMain(param); + } } } } else { @@ -114,6 +118,10 @@ public class AutoCreateSportCheck { if (num >= 3) { this.createMain(param); } + } else if (StrUtil.equals(maintenancecycle,"04")) { + if (num >= 1) { + this.createMain(param); + } } } } diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/auToTask/bean/AutoCreateUpkeep.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/auToTask/bean/AutoCreateUpkeep.java index cf018f87..ff0b10e8 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/auToTask/bean/AutoCreateUpkeep.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/auToTask/bean/AutoCreateUpkeep.java @@ -76,6 +76,10 @@ public class AutoCreateUpkeep { if (num <= 3) { this.createMain(param); } + } else if (StrUtil.equals(maintenancecycle,"04")) { + if (num <= 1) { + this.createMain(param); + } } } } else { @@ -114,6 +118,10 @@ public class AutoCreateUpkeep { if (num >= 3) { this.createMain(param); } + } else if (StrUtil.equals(maintenancecycle,"04")) { + if (num >= 1) { + this.createMain(param); + } } } } diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/lubricate/service/impl/DevicelubricateplanmstServiceImpl.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/lubricate/service/impl/DevicelubricateplanmstServiceImpl.java index 942c10d8..93551633 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/lubricate/service/impl/DevicelubricateplanmstServiceImpl.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/lubricate/service/impl/DevicelubricateplanmstServiceImpl.java @@ -100,7 +100,11 @@ public class DevicelubricateplanmstServiceImpl implements Devicelubricateplanmst Date next_end_date = DateUtil.offsetWeek(real_end_date2,1); jo.put("next_end_date", DateUtil.formatDate(next_end_date)); ja2.add(jo); - }else{ + }else if (maintenancecycle2.equals("04")) { // 日 + Date next_end_date = DateUtil.offsetDay(real_end_date2,1); + jo.put("next_end_date", DateUtil.formatDate(next_end_date)); + ja2.add(jo); + } else{ jo.put("next_end_date",""); ja2.add(jo); } diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/repair/service/impl/DevicerepairplanmstServiceImpl.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/repair/service/impl/DevicerepairplanmstServiceImpl.java index 3ddbadcd..93239952 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/repair/service/impl/DevicerepairplanmstServiceImpl.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/repair/service/impl/DevicerepairplanmstServiceImpl.java @@ -99,7 +99,11 @@ public class DevicerepairplanmstServiceImpl implements DevicerepairplanmstServic Date next_end_date = DateUtil.offsetWeek(real_end_date2,1); jo.put("next_end_date", DateUtil.formatDate(next_end_date)); ja2.add(jo); - }else{ + }else if (maintenancecycle2.equals("05")) { // 日 + Date next_end_date = DateUtil.offsetDay(real_end_date2,1); + jo.put("next_end_date", DateUtil.formatDate(next_end_date)); + ja2.add(jo); + } else{ jo.put("next_end_date",""); ja2.add(jo); } diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/sportcheck/service/impl/DevicesportcheckplanmstServiceImpl.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/sportcheck/service/impl/DevicesportcheckplanmstServiceImpl.java index 5b812f6d..270c5f8a 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/sportcheck/service/impl/DevicesportcheckplanmstServiceImpl.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/sportcheck/service/impl/DevicesportcheckplanmstServiceImpl.java @@ -100,6 +100,10 @@ public class DevicesportcheckplanmstServiceImpl implements Devicesportcheckplanm Date next_end_date = DateUtil.offsetWeek(real_end_date2,1); jo.put("next_end_date", DateUtil.formatDate(next_end_date)); ja2.add(jo); + }else if (maintenancecycle2.equals("04")) { // 日 + Date next_end_date = DateUtil.offsetDay(real_end_date2,1); + jo.put("next_end_date", DateUtil.formatDate(next_end_date)); + ja2.add(jo); }else{ jo.put("next_end_date",""); ja2.add(jo); diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/upkeep/service/impl/DevicemaintenanceplanmstServiceImpl.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/upkeep/service/impl/DevicemaintenanceplanmstServiceImpl.java index b4e3a01a..dfcdb900 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/upkeep/service/impl/DevicemaintenanceplanmstServiceImpl.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/device_manage/upkeep/service/impl/DevicemaintenanceplanmstServiceImpl.java @@ -100,7 +100,11 @@ public class DevicemaintenanceplanmstServiceImpl implements Devicemaintenancepla Date next_end_date = DateUtil.offsetWeek(real_end_date2,1); jo.put("next_end_date", DateUtil.formatDate(next_end_date)); ja2.add(jo); - }else{ + } else if (maintenancecycle2.equals("04")) { // 日 + Date next_end_date = DateUtil.offsetDay(real_end_date2,1); + jo.put("next_end_date", DateUtil.formatDate(next_end_date)); + ja2.add(jo); + } else{ jo.put("next_end_date",""); ja2.add(jo); } diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/controller/em/EmBiRepairDeviceController.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/controller/em/EmBiRepairDeviceController.java new file mode 100644 index 00000000..640b95df --- /dev/null +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/controller/em/EmBiRepairDeviceController.java @@ -0,0 +1,113 @@ + +package org.nl.wms.masterdata_manage.controller.em; + + +import cn.hutool.core.util.ObjectUtil; +import com.alibaba.fastjson.JSONObject; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.github.pagehelper.Page; +import com.github.pagehelper.PageHelper; +import io.jsonwebtoken.lang.Assert; +import io.swagger.annotations.Api; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.nl.common.TableDataInfo; +import org.nl.common.anno.Log; +import org.nl.common.domain.query.PageQuery; +import org.nl.common.utils.IdUtil; +import org.nl.modules.common.exception.BadRequestException; +import org.nl.wms.device_manage.service.userdevice.dto.DeviceUserQuery; +import org.nl.wms.masterdata_manage.service.em.EmBiRepairDeviceService; +import org.nl.wms.masterdata_manage.service.em.dao.EmBiRepairDevice; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.http.HttpStatus; +import org.springframework.http.ResponseEntity; +import org.springframework.web.bind.annotation.*; + +import java.util.Arrays; +import java.util.List; +import java.util.Map; + +/** +* @author Liu xy +* @date 2022-05-26 +**/ +@RestController +@RequiredArgsConstructor +@Api(tags = "维修人与设备档案维护") +@RequestMapping("/api/embirepairdevice") +@Slf4j +public class EmBiRepairDeviceController { + + @Autowired + private EmBiRepairDeviceService emBiRepairDeviceService; + + @GetMapping + @Log("查询人员设备维护") + public ResponseEntity query(DeviceUserQuery query, PageQuery page){ + Page result = PageHelper.startPage(page.getPage() + 1, page.getSize()); + List list = emBiRepairDeviceService.queryAll(query); + TableDataInfo build = TableDataInfo.build(list); + build.setTotalElements(result.getTotal()); + return new ResponseEntity<>(build,HttpStatus.OK); + } + + @GetMapping("/device") + @Log("查询设备") + //("查询设备") + public ResponseEntity device(DeviceUserQuery query, PageQuery page){ + Page result = PageHelper.startPage(page.getPage() + 1, page.getSize()); + List list = emBiRepairDeviceService.queryAllDevice(query); + TableDataInfo build = TableDataInfo.build(list); + build.setTotalElements(result.getTotal()); + return new ResponseEntity<>(build,HttpStatus.OK); + } + + @PostMapping + @Log("新增人员设备维护") + public ResponseEntity create(@RequestBody JSONObject entity){ + Assert.notNull(entity,"请求参数不能为空"); + + EmBiRepairDevice one = emBiRepairDeviceService.getOne( + new QueryWrapper().lambda() + .eq(EmBiRepairDevice::getUser_id, entity.getString("user_id")) + .eq(EmBiRepairDevice::getDevice_code, entity.getString("device_code")) + ); + + if (ObjectUtil.isNotEmpty(one)) throw new BadRequestException("设备重复"); + + EmBiRepairDevice emBiRepairDevice = entity.toJavaObject(EmBiRepairDevice.class); + emBiRepairDevice.setPerson_id(IdUtil.getStringId()); + emBiRepairDeviceService.save(emBiRepairDevice); + return new ResponseEntity<>(HttpStatus.CREATED); + } + + @PutMapping + @Log("修改人员设备维护") + public ResponseEntity update(@RequestBody JSONObject entity){ + + EmBiRepairDevice one = emBiRepairDeviceService.getOne( + new QueryWrapper().lambda() + .eq(EmBiRepairDevice::getUser_id, entity.getString("user_id")) + .eq(EmBiRepairDevice::getDevice_code, entity.getString("device_code")) + ); + + if (ObjectUtil.isNotEmpty(one)) throw new BadRequestException("设备重复"); + + EmBiRepairDevice emBiRepairDevice = emBiRepairDeviceService.getById(entity.getString("person_id")); + emBiRepairDevice.setDevice_code(entity.getString("device_code")); + emBiRepairDeviceService.updateById(emBiRepairDevice); + return new ResponseEntity<>(HttpStatus.CREATED); + } + + + @Log("删除人员设备维护") + @DeleteMapping + public ResponseEntity delete(@RequestBody String[] ids) { + if (ids != null && ids.length>0){ + emBiRepairDeviceService.removeByIds(Arrays.asList(ids)); + } + return new ResponseEntity<>(HttpStatus.OK); + } + +} diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/master/controller/measureunit/MdPbMeasureunitController.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/master/controller/measureunit/MdPbMeasureunitController.java index 44a4b860..2753673e 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/master/controller/measureunit/MdPbMeasureunitController.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/master/controller/measureunit/MdPbMeasureunitController.java @@ -9,8 +9,10 @@ import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; +import org.nl.common.TableDataInfo; import org.nl.common.anno.Log; import org.nl.common.domain.query.PageQuery; +import org.nl.common.utils.MapOf; import org.nl.wms.masterdata_manage.service.master.IMdPbMeasureunitService; import org.nl.wms.masterdata_manage.service.master.dao.MdPbMeasureunit; import org.nl.wms.masterdata_manage.service.master.dto.UnitQuery; @@ -22,7 +24,9 @@ import org.springframework.http.HttpStatus; import org.springframework.http.ResponseEntity; import org.springframework.web.bind.annotation.*; +import java.util.ArrayList; import java.util.List; +import java.util.Map; /** * @author loujf @@ -45,6 +49,17 @@ public class MdPbMeasureunitController { return new ResponseEntity<>(measureunitService.pageQuery(query, page), HttpStatus.OK); } + @GetMapping("/select") + @Log("查询单位下拉列表设备") + public ResponseEntity selectAll(){ + List list = measureunitService.list(); + List result = new ArrayList<>(); + for (MdPbMeasureunit item : list) { + result.add(MapOf.of("label",item.getUnit_name(),"value",item.getMeasure_unit_id())); + } + return new ResponseEntity<>(TableDataInfo.build(result),HttpStatus.OK); + } + @PostMapping("/add") @Log("新增计量单位") //("新增计量单位") diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/service/em/EmBiRepairDeviceService.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/service/em/EmBiRepairDeviceService.java new file mode 100644 index 00000000..e6d12660 --- /dev/null +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/service/em/EmBiRepairDeviceService.java @@ -0,0 +1,28 @@ +package org.nl.wms.masterdata_manage.service.em; + +import com.baomidou.mybatisplus.extension.service.IService; +import org.nl.wms.device_manage.service.userdevice.dto.DeviceUserQuery; +import org.nl.wms.masterdata_manage.service.em.dao.EmBiRepairDevice; + +import java.util.List; +import java.util.Map; + +/** + *

+ * 人员设备关系表 服务类 + *

+ * + * @author generator + * @since 2023-06-06 + */ +public interface EmBiRepairDeviceService extends IService { + + /** + * 查询数据分页 + * @param whereJson 条件 + * @return Map + */ + List queryAll(DeviceUserQuery whereJson); + + List queryAllDevice(DeviceUserQuery whereJson); +} diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/service/em/dao/EmBiRepairDevice.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/service/em/dao/EmBiRepairDevice.java new file mode 100644 index 00000000..b62a7abd --- /dev/null +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/service/em/dao/EmBiRepairDevice.java @@ -0,0 +1,38 @@ +package org.nl.wms.masterdata_manage.service.em.dao; + +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import lombok.Data; +import lombok.EqualsAndHashCode; + +import java.io.Serializable; + +/** + *

+ * 人员设备关系表 + *

+ * + * @author generator + * @since 2023-06-06 + */ +@Data +@EqualsAndHashCode(callSuper = false) +@TableName("em_bi_repairpersondevice") +public class EmBiRepairDevice implements Serializable { + + private static final long serialVersionUID = 1L; + + @TableId + private String person_id; + /** + * 用户id + */ + private String user_id; + + /** + * 设备编码 + */ + private String device_code; + + +} diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/service/em/dao/mapper/EmBiRepairDeviceMapper.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/service/em/dao/mapper/EmBiRepairDeviceMapper.java new file mode 100644 index 00000000..8f4b0751 --- /dev/null +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/service/em/dao/mapper/EmBiRepairDeviceMapper.java @@ -0,0 +1,24 @@ +package org.nl.wms.masterdata_manage.service.em.dao.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import org.apache.ibatis.annotations.Param; +import org.nl.wms.device_manage.service.userdevice.dto.DeviceUserQuery; +import org.nl.wms.masterdata_manage.service.em.dao.EmBiRepairDevice; + +import java.util.List; +import java.util.Map; + +/** + *

+ * 人员设备关系表 Mapper 接口 + *

+ * + * @author generator + * @since 2023-06-06 + */ +public interface EmBiRepairDeviceMapper extends BaseMapper { + + List queryAll(@Param("query") DeviceUserQuery query); + + List queryAllDevice(@Param("query") DeviceUserQuery query); +} diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/service/em/dao/mapper/EmBiRepairDeviceMapper.xml b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/service/em/dao/mapper/EmBiRepairDeviceMapper.xml new file mode 100644 index 00000000..8ec68568 --- /dev/null +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/service/em/dao/mapper/EmBiRepairDeviceMapper.xml @@ -0,0 +1,34 @@ + + + + + + + + diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/service/em/impl/EmBiRepairDeviceServiceImpl.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/service/em/impl/EmBiRepairDeviceServiceImpl.java new file mode 100644 index 00000000..764dd3bd --- /dev/null +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/service/em/impl/EmBiRepairDeviceServiceImpl.java @@ -0,0 +1,33 @@ +package org.nl.wms.masterdata_manage.service.em.impl; + +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import org.nl.wms.device_manage.service.userdevice.dto.DeviceUserQuery; +import org.nl.wms.masterdata_manage.service.em.EmBiRepairDeviceService; +import org.nl.wms.masterdata_manage.service.em.dao.EmBiRepairDevice; +import org.nl.wms.masterdata_manage.service.em.dao.mapper.EmBiRepairDeviceMapper; +import org.springframework.stereotype.Service; + +import java.util.List; +import java.util.Map; + +/** + *

+ * 人员设备关系表 服务实现类 + *

+ * + * @author generator + * @since 2023-06-06 + */ +@Service +public class EmBiRepairDeviceServiceImpl extends ServiceImpl implements EmBiRepairDeviceService { + + @Override + public List queryAll(DeviceUserQuery query) { + return this.baseMapper.queryAll(query); + } + + @Override + public List queryAllDevice(DeviceUserQuery query) { + return this.baseMapper.queryAllDevice(query); + } +} diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/storage/controller/dailyStructivt/StIvtStructivtDailyController.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/storage/controller/dailyStructivt/StIvtStructivtDailyController.java new file mode 100644 index 00000000..02452e41 --- /dev/null +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/storage/controller/dailyStructivt/StIvtStructivtDailyController.java @@ -0,0 +1,51 @@ +package org.nl.wms.masterdata_manage.storage.controller.dailyStructivt; + + +import cn.dev33.satoken.annotation.SaIgnore; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import org.nl.common.TableDataInfo; +import org.nl.common.anno.Log; +import org.nl.common.domain.query.PageQuery; +import org.nl.wms.masterdata_manage.storage.service.dailyStructivt.IStIvtStructivtDailyService; +import org.nl.wms.masterdata_manage.storage.service.dailyStructivt.dto.DailyStructivtQuery; +import org.nl.wms.masterdata_manage.storage.service.storage.dao.StIvtSectattr; +import org.nl.wms.masterdata_manage.storage.service.storage.dto.SectattrQuery; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.http.HttpStatus; +import org.springframework.http.ResponseEntity; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.RequestMapping; + +import org.springframework.web.bind.annotation.RestController; + +/** + *

+ * 日库存统计表 前端控制器 + *

+ * + * @author generator + * @since 2023-09-18 + */ +@RestController +@RequestMapping("api/structivtDaily") +@SaIgnore +public class StIvtStructivtDailyController { + + @Autowired + private IStIvtStructivtDailyService stIvtStructivtDailyService; + + @GetMapping + @Log("查询日库区") + @SaIgnore + public ResponseEntity query(DailyStructivtQuery query, PageQuery page){ + return new ResponseEntity<>(TableDataInfo.build(stIvtStructivtDailyService.page(page.build(),query.build())),HttpStatus.OK); + } + @GetMapping("/sync") + @Log("同步日库区") + @SaIgnore + public ResponseEntity sync(String[] structivts){ + stIvtStructivtDailyService.dailyStructivt(structivts); + return new ResponseEntity<>(HttpStatus.OK); + } +} + diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/storage/service/dailyStructivt/IStIvtStructivtDailyService.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/storage/service/dailyStructivt/IStIvtStructivtDailyService.java new file mode 100644 index 00000000..00e3c076 --- /dev/null +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/storage/service/dailyStructivt/IStIvtStructivtDailyService.java @@ -0,0 +1,21 @@ +package org.nl.wms.masterdata_manage.storage.service.dailyStructivt; + +import com.baomidou.mybatisplus.extension.service.IService; +import org.nl.wms.masterdata_manage.storage.service.dailyStructivt.dao.StIvtStructivtDaily; + +/** + *

+ * 日库存统计表 服务类 + *

+ * + * @author generator + * @since 2023-09-18 + */ +public interface IStIvtStructivtDailyService extends IService { + + /** + * 统计日常数据 + */ + void dailyStructivt(String...structivts); + +} diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/storage/service/dailyStructivt/dao/StIvtStructivtDaily.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/storage/service/dailyStructivt/dao/StIvtStructivtDaily.java new file mode 100644 index 00000000..b96c40ed --- /dev/null +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/storage/service/dailyStructivt/dao/StIvtStructivtDaily.java @@ -0,0 +1,116 @@ +package org.nl.wms.masterdata_manage.storage.service.dailyStructivt.dao; + +import java.math.BigDecimal; + +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import java.io.Serializable; +import lombok.Data; +import lombok.EqualsAndHashCode; + +/** + *

+ * 日库存统计表 + *

+ * + * @author generator + * @since 2023-09-18 + */ +@Data +@EqualsAndHashCode(callSuper = false) +@TableName("st_ivt_structivt_daily") +public class StIvtStructivtDaily implements Serializable { + + private static final long serialVersionUID = 1L; + + /** + * 库存记录标识 + */ + @TableId + private String id; + + /** + * 仓库标识 + */ + private String stor_id; + + + /** + * 仓库名称 + */ + private String stor_name; + + /** + * 库区标识 + */ + private String sect_id; + /** + * 库区名称 + */ + private String sect_name; + + /** + * 仓库表 + */ + private String table_name; + + /** + * 车间标识 + */ + private String product_area; + + /** + * 货位集合 + */ + private String struct_code; + + /** + * 计量单位标识 + */ + private String qty_unit_id; + + /** + * 创建时间 + */ + private String create_time; + + /** + * 物料标识 + */ + private String material_id; + + + /** + * 物料标识 + */ + private String material_code; + + /** + * 物料标识 + */ + private String material_spec; + + /** + * 可用数 + */ + private BigDecimal canuse_qty; + + /** + * 冻结数 + */ + private BigDecimal frozen_qty; + + /** + * 库存数 + */ + private BigDecimal ivt_qty; + + /** + * 待入数 + */ + private BigDecimal warehousing_qty; + + + + +} diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/storage/service/dailyStructivt/dao/mapper/StIvtStructivtDailyMapper.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/storage/service/dailyStructivt/dao/mapper/StIvtStructivtDailyMapper.java new file mode 100644 index 00000000..4ac6e96c --- /dev/null +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/storage/service/dailyStructivt/dao/mapper/StIvtStructivtDailyMapper.java @@ -0,0 +1,24 @@ +package org.nl.wms.masterdata_manage.storage.service.dailyStructivt.dao.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import org.apache.ibatis.annotations.Param; +import org.apache.ibatis.annotations.Select; +import org.nl.wms.masterdata_manage.storage.service.dailyStructivt.dao.StIvtStructivtDaily; + +import java.util.List; +import java.util.Map; + +/** + *

+ * 日库存统计表 Mapper 接口 + *

+ * + * @author generator + * @since 2023-09-18 + */ +public interface StIvtStructivtDailyMapper extends BaseMapper { + + @Select("SELECT #{table} AS table_name,GROUP_CONCAT(a.struct_code) struct_code, 'A1' AS product_area, st_ivt_structattr.stor_id,st_ivt_structattr.stor_name , st_ivt_structattr.sect_id,st_ivt_structattr.sect_name , UUID_SHORT( ) id,a.material_id,md_me_materialbase.material_code,md_me_materialbase.material_spec, sum( canuse_qty ) canuse_qty, sum( frozen_qty ) frozen_qty, sum( ivt_qty ) ivt_qty, sum( warehousing_qty ) warehousing_qty, qty_unit_id, CURDATE( ) create_time FROM ${table} as a left join st_ivt_structattr on a.struct_code = st_ivt_structattr.struct_code left join md_me_materialbase on a.material_id = md_me_materialbase.material_id GROUP BY material_id") + List selectStructivt(@Param("table") String table); +} + diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/storage/service/dailyStructivt/dao/mapper/xml/StIvtStructivtDailyMapper.xml b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/storage/service/dailyStructivt/dao/mapper/xml/StIvtStructivtDailyMapper.xml new file mode 100644 index 00000000..fd4511cc --- /dev/null +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/storage/service/dailyStructivt/dao/mapper/xml/StIvtStructivtDailyMapper.xml @@ -0,0 +1,5 @@ + + + + + diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/storage/service/dailyStructivt/dto/DailyStructivtQuery.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/storage/service/dailyStructivt/dto/DailyStructivtQuery.java new file mode 100644 index 00000000..ef977809 --- /dev/null +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/storage/service/dailyStructivt/dto/DailyStructivtQuery.java @@ -0,0 +1,26 @@ +package org.nl.wms.masterdata_manage.storage.service.dailyStructivt.dto; + +import lombok.Data; +import org.nl.common.domain.query.BaseQuery; +import org.nl.common.domain.query.QParam; +import org.nl.common.enums.QueryTEnum; +import org.nl.wms.masterdata_manage.storage.service.dailyStructivt.dao.StIvtStructivtDaily; + +/* + * @author ZZQ + * @Date 2023/5/14 17:13 + */ +@Data +public class DailyStructivtQuery extends BaseQuery { + + + private String stor_id; + private String sect_id; + private String struct_code; + private String blurry; + + @Override + public void paramMapping() { + super.doP.put("blurry", QParam.builder().k(new String[]{"material_code","material_spec"}).type(QueryTEnum.ORLK).build()); + } +} diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/storage/service/dailyStructivt/impl/StIvtStructivtDailyServiceImpl.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/storage/service/dailyStructivt/impl/StIvtStructivtDailyServiceImpl.java new file mode 100644 index 00000000..5fc32c93 --- /dev/null +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/storage/service/dailyStructivt/impl/StIvtStructivtDailyServiceImpl.java @@ -0,0 +1,64 @@ +package org.nl.wms.masterdata_manage.storage.service.dailyStructivt.impl; + + +import cn.hutool.core.date.DateUtil; +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONArray; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import org.apache.commons.lang3.StringUtils; +import org.nl.modules.common.exception.BadRequestException; +import org.nl.wms.masterdata_manage.storage.service.dailyStructivt.IStIvtStructivtDailyService; +import org.nl.wms.masterdata_manage.storage.service.dailyStructivt.dao.StIvtStructivtDaily; +import org.nl.wms.masterdata_manage.storage.service.dailyStructivt.dao.mapper.StIvtStructivtDailyMapper; +import org.springframework.stereotype.Service; +import org.springframework.util.CollectionUtils; + +import javax.transaction.Transactional; +import java.util.ArrayList; +import java.util.List; +import java.util.Map; +import java.util.Set; +import java.util.function.Function; +import java.util.function.Predicate; +import java.util.stream.Collectors; + +/** + *

+ * 日库存统计表 服务实现类 + *

+ * + * @author generator + * @since 2023-09-18 + */ +@Service +public class StIvtStructivtDailyServiceImpl extends ServiceImpl implements IStIvtStructivtDailyService { + + @Override + @Transactional + public void dailyStructivt(String... structivts) { + if (structivts.length == 0){ + return; + } + ArrayList list = new ArrayList<>(); + for (String structivt : structivts) { + List maps = this.baseMapper.selectStructivt(structivt); + if (!CollectionUtils.isEmpty(maps)){ + List dailyList = JSONArray.parseArray(JSON.toJSONString(maps), StIvtStructivtDaily.class); + list.addAll(dailyList); + } + } + if (!CollectionUtils.isEmpty(list)){ + List errorData = list.stream().filter(stIvtStructivtDaily -> StringUtils.isEmpty(stIvtStructivtDaily.getStor_id()) || StringUtils.isEmpty(stIvtStructivtDaily.getMaterial_id())).collect(Collectors.toList()); + if (!CollectionUtils.isEmpty(errorData)){ + throw new BadRequestException("表存在异常数据没有仓库跟物料信息:"+errorData + .stream() + .map(stIvtStructivtDaily-> stIvtStructivtDaily.getTable_name()+".仓位:"+stIvtStructivtDaily.getStruct_code()+".物料"+stIvtStructivtDaily.getMaterial_id()) + .distinct().collect(Collectors.joining(","))); + } + Set collect = list.stream().map(StIvtStructivtDaily::getStor_id).collect(Collectors.toSet()); + this.remove(new QueryWrapper().in("stor_id",collect).eq("create_time", DateUtil.now())); + this.saveBatch(list); + } + } +} diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/storage/service/storage/dao/mapper/xml/StIvtStructivtDailyMapper.xml b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/storage/service/storage/dao/mapper/xml/StIvtStructivtDailyMapper.xml new file mode 100644 index 00000000..317a035a --- /dev/null +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/storage/service/storage/dao/mapper/xml/StIvtStructivtDailyMapper.xml @@ -0,0 +1,5 @@ + + + + + diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/quality_manage/service/report/impl/QlTestInspectionsheetmstServiceImpl.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/quality_manage/service/report/impl/QlTestInspectionsheetmstServiceImpl.java index bd12848b..a1edc3fc 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/quality_manage/service/report/impl/QlTestInspectionsheetmstServiceImpl.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/quality_manage/service/report/impl/QlTestInspectionsheetmstServiceImpl.java @@ -134,8 +134,8 @@ public class QlTestInspectionsheetmstServiceImpl extends ServiceImpl code; diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/productmanage/service/moveInv/impl/StIvtMoveinvCpServiceImpl.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/productmanage/service/moveInv/impl/StIvtMoveinvCpServiceImpl.java index 6b73fcc9..264f1c42 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/productmanage/service/moveInv/impl/StIvtMoveinvCpServiceImpl.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/productmanage/service/moveInv/impl/StIvtMoveinvCpServiceImpl.java @@ -284,7 +284,8 @@ public class StIvtMoveinvCpServiceImpl extends ServiceImpl @@ -29,31 +36,29 @@ public class StIvtStructivtYlController { @Autowired private IStIvtStructivtYlService structivtYlService; + @Autowired + private IStIvtIostorinvOutYlService iostorinvOutYlService; @GetMapping("/getRawIvt") @Log("查询可用的原料库存") - //("查询可用的原料库存") public ResponseEntity getRawIvt(StructIvtYLQuery query, PageQuery page) { return new ResponseEntity<>(structivtYlService.getRawIvt(query, page), HttpStatus.OK); } @GetMapping("/getProductIvt") @Log("查询可用的成品库存") - //("查询可用的成品库存") public ResponseEntity getProductIvt(StructIvtYLQuery query, PageQuery page) { return new ResponseEntity<>(structivtYlService.getProductIvt(query,page), HttpStatus.OK); } @PostMapping("/getStructIvt") @Log("查询库存") - //("查询库存") public ResponseEntity getStructIvt(StructIvtYLQuery query) { return new ResponseEntity<>(structivtYlService.getStructIvt(query), HttpStatus.OK); } @PostMapping("/getSemiProductIvt") @Log("查询可用的半成品库存") - //("查询可用的半成品库存") public ResponseEntity getSemiProductIvt(StructIvtYLQuery query) { return new ResponseEntity<>(structivtYlService.getSemiProductIvt(query), HttpStatus.OK); } @@ -61,16 +66,22 @@ public class StIvtStructivtYlController { @GetMapping("/getSemiProductIvt2") @Log("查询可用的半成品库存") - //("查询可用的半成品库存") public ResponseEntity getSemiProductIvt2(StructIvtYLQuery query, PageQuery page) { return new ResponseEntity<>(structivtYlService.getSemiProductIvt(query,page), HttpStatus.OK); } @GetMapping("/getAllRawIvt") @Log("查询原料库存") - //("查询原料库存") public ResponseEntity getAllRawIvt(StructIvtYLQuery query, PageQuery page) { return new ResponseEntity<>(structivtYlService.getAllRawIvt(query, page), HttpStatus.OK); } + @PostMapping("/update") + @Log("更新原料库存") + public ResponseEntity update(@RequestBody JSONObject form) { + + iostorinvOutYlService.updateIvt(form); + + return new ResponseEntity<>(HttpStatus.OK); + } } diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/rawmanage/service/iostorInv/IStIvtIostorinvOutYlService.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/rawmanage/service/iostorInv/IStIvtIostorinvOutYlService.java index 513db65d..5762c4b1 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/rawmanage/service/iostorInv/IStIvtIostorinvOutYlService.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/rawmanage/service/iostorInv/IStIvtIostorinvOutYlService.java @@ -63,4 +63,10 @@ public interface IStIvtIostorinvOutYlService extends IService */ void confirm(JSONObject form); + /** + * 手动修改库存 + * @param form + */ + void updateIvt(JSONObject form); + } diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/rawmanage/service/iostorInv/impl/StIvtIostorinvOutYlServiceImpl.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/rawmanage/service/iostorInv/impl/StIvtIostorinvOutYlServiceImpl.java index 3a445077..6de56470 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/rawmanage/service/iostorInv/impl/StIvtIostorinvOutYlServiceImpl.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/rawmanage/service/iostorInv/impl/StIvtIostorinvOutYlServiceImpl.java @@ -299,4 +299,35 @@ public class StIvtIostorinvOutYlServiceImpl extends ServiceImpl() + .eq("material_id", form.getString("material_id")) + .eq("stor_id", form.getString("stor_id")) + .eq("canuse_qty", form.getBigDecimal("old_qty")) + ); + if (ivt==null){ + throw new BadRequestException("当前物料库存已变更,请重新操作"); + } + double change_qty = NumberUtil.sub(form.getBigDecimal("ivt_qty"),form.getBigDecimal("old_qty")).doubleValue(); + if (change_qty==0){ + return; + } + ivt.setCanuse_qty(form.getBigDecimal("ivt_qty")); + ivt.setIvt_qty(ivt.getCanuse_qty()); + structivtYlService.updateById(ivt); + // 插入库存变动记 + JSONObject param = JSONObject.parseObject(JSON.toJSONString(ivt)); + param.put("change_type", change_qty>0?ChangeIvtUtil.SUBWAREHOUSING_ADDIVT_QTY:ChangeIvtUtil.SUBFROZEN_SUBIVT_QTY); + param.put("change_qty",Math.abs(change_qty)); + param.put("result_qty", form.getBigDecimal("ivt_qty")); + param.put("bill_code",""); + param.put("inv_id",""); + param.put("bill_type_scode",""); + iStIvtStructivtflowYlService.insetIvtChange(param); + } + } diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/rawmanage/service/iostorInv/impl/StIvtIostorinvYlServiceImpl.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/rawmanage/service/iostorInv/impl/StIvtIostorinvYlServiceImpl.java index de36dd87..1a45c564 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/rawmanage/service/iostorInv/impl/StIvtIostorinvYlServiceImpl.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/rawmanage/service/iostorInv/impl/StIvtIostorinvYlServiceImpl.java @@ -161,6 +161,7 @@ public class StIvtIostorinvYlServiceImpl extends ServiceImpl + order by instorage_time desc