From 44c1da90d18396b4c78c588571e71eaa8e49c8d6 Mon Sep 17 00:00:00 2001 From: Lius <Lius2225@163.com> Date: 星期一, 18 十二月 2023 16:57:35 +0800 Subject: [PATCH] mdc修改 --- lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/system/controller/SysUserController.java | 3 + lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/mapper/xml/MdcEquipmentMapper.xml | 31 +++++++++++++++ lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/impl/MdcEquipmentRunningSectionServiceImpl.java | 2 lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/system/service/impl/SysUserServiceImpl.java | 2 + lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/controller/MdcEquipmentController.java | 8 +-- lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/impl/MdcEquipmentServiceImpl.java | 6 +++ lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/mapper/MdcEquipmentMapper.java | 6 +++ lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/IMdcEquipmentService.java | 6 +++ lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/impl/ProcessCountServiceImpl.java | 44 ++++++++++++--------- lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/vo/MdcEquipmentVo.java | 4 ++ 10 files changed, 86 insertions(+), 26 deletions(-) diff --git a/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/controller/MdcEquipmentController.java b/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/controller/MdcEquipmentController.java index b3bcf11..31fb7bc 100644 --- a/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/controller/MdcEquipmentController.java +++ b/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/controller/MdcEquipmentController.java @@ -1,6 +1,5 @@ package org.jeecg.modules.mdc.controller; -import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import io.swagger.annotations.Api; @@ -11,7 +10,6 @@ import org.jeecg.common.api.vo.Result; import org.jeecg.common.aspect.annotation.AutoLog; import org.jeecg.common.system.base.controller.JeecgController; -import org.jeecg.common.system.query.QueryGenerator; import org.jeecg.common.system.vo.LoginUser; import org.jeecg.modules.mdc.dto.MdcEquipmentDto; import org.jeecg.modules.mdc.entity.MdcEquipment; @@ -67,13 +65,13 @@ @AutoLog(value = "璁惧琛�-鍒嗛〉鍒楄〃鏌ヨ") @ApiOperation(value = "璁惧琛�-鍒嗛〉鍒楄〃鏌ヨ", notes = "璁惧琛�-鍒嗛〉鍒楄〃鏌ヨ") @GetMapping(value = "/list") - public Result<IPage<MdcEquipment>> queryPageList(MdcEquipment mdcEquipment, + public Result<IPage<MdcEquipment>> queryPageList(MdcEquipmentVo mdcEquipment, @RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo, @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize, HttpServletRequest req) { - QueryWrapper<MdcEquipment> queryWrapper = QueryGenerator.initQueryWrapper(mdcEquipment, req.getParameterMap()); + //QueryWrapper<MdcEquipment> queryWrapper = QueryGenerator.initQueryWrapper(mdcEquipment, req.getParameterMap()); Page<MdcEquipment> page = new Page<MdcEquipment>(pageNo, pageSize); - IPage<MdcEquipment> pageList = mdcEquipmentService.page(page, queryWrapper); + IPage<MdcEquipment> pageList = mdcEquipmentService.pageList(page, mdcEquipment, req); //鎵归噺鏌ヨ璁惧鐨勬墍灞為儴闂ㄥ拰浜х嚎 //step.1 鍏堟嬁鍒板叏閮ㄧ殑 equipmentIds diff --git a/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/mapper/MdcEquipmentMapper.java b/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/mapper/MdcEquipmentMapper.java index f78b623..0fa0195 100644 --- a/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/mapper/MdcEquipmentMapper.java +++ b/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/mapper/MdcEquipmentMapper.java @@ -10,6 +10,7 @@ import org.jeecg.modules.mdc.entity.MdcEquipmentMonitor; import org.jeecg.modules.mdc.vo.MdcEquipmentDepVo; import org.jeecg.modules.mdc.vo.MdcEquipmentProVo; +import org.jeecg.modules.mdc.vo.MdcEquipmentVo; import org.jeecg.modules.mdc.vo.WorkshopEquipmentVo; import java.util.List; @@ -87,4 +88,9 @@ * 鏍规嵁澶у睆杞﹂棿id鏌ヨ璁惧鍒楄〃 */ IPage<MdcEquipment> getEquipmentByWorkshopId(Page<MdcEquipment> page, @Param("workshopEquipmentVo") WorkshopEquipmentVo workshopEquipmentVo); + + /** + * 鍒嗛〉鍒楄〃 + */ + IPage<MdcEquipment> pageList(Page<MdcEquipment> page, @Param("mdcEquipment") MdcEquipmentVo mdcEquipment); } diff --git a/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/mapper/xml/MdcEquipmentMapper.xml b/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/mapper/xml/MdcEquipmentMapper.xml index 945127c..893762f 100644 --- a/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/mapper/xml/MdcEquipmentMapper.xml +++ b/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/mapper/xml/MdcEquipmentMapper.xml @@ -210,5 +210,36 @@ ORDER BY me.equipment_id </select> + <!--鍒嗛〉鍒楄〃--> + <select id="pageList" resultType="org.jeecg.modules.mdc.entity.MdcEquipment"> + SELECT + t1.* + FROM + mdc_equipment t1 + LEFT JOIN mdc_production_equipment t2 ON t1.id = t2.equipment_id + LEFT JOIN mdc_production t3 ON t2.production_id = t3.id + <where> + <if test="mdcEquipment.equipmentId != null and mdcEquipment.equipmentId != '' "> + AND t1.equipment_id LIKE CONCAT(CONCAT('%',#{mdcEquipment.equipmentId}),'%') + </if> + <if test="mdcEquipment.equipmentName != null and mdcEquipment.equipmentName != '' "> + AND t1.equipment_name LIKE CONCAT(CONCAT('%',#{mdcEquipment.equipmentName}),'%') + </if> + <if test="mdcEquipment.equipmentModel != null and mdcEquipment.equipmentModel != '' "> + AND t1.equipment_name = #{mdcEquipment.equipmentModel} + </if> + <if test="mdcEquipment.equipmentType != null and mdcEquipment.equipmentType != '' "> + AND t1.equipmentType = #{mdcEquipment.equipmentType} + </if> + <if test="mdcEquipment.driveType != null and mdcEquipment.driveType != '' "> + AND t1.drive_type = #{mdcEquipment.driveType} + </if> + <if test="mdcEquipment.productionName != null and mdcEquipment.productionName != '' "> + AND t3.production_name LIKE CONCAT(CONCAT('%',#{mdcEquipment.productionName}),'%') + </if> + </where> + order by t1.sort_no + </select> + </mapper> \ No newline at end of file diff --git a/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/IMdcEquipmentService.java b/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/IMdcEquipmentService.java index ad938b7..aa0caac 100644 --- a/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/IMdcEquipmentService.java +++ b/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/IMdcEquipmentService.java @@ -12,6 +12,7 @@ import org.jeecg.modules.mdc.vo.MdcEquipmentVo; import org.jeecg.modules.mdc.vo.WorkshopEquipmentVo; +import javax.servlet.http.HttpServletRequest; import java.util.List; import java.util.Map; @@ -170,4 +171,9 @@ IPage<MdcEquipment> getEquipmentByWorkshopId(Page<MdcEquipment> page, WorkshopEquipmentVo workshopEquipmentVo); List<String> listEquipmentId(String equipmentType, List<String> equipmentIdList); + + /** + * 鍒楄〃鏌ヨ + */ + IPage<MdcEquipment> pageList(Page<MdcEquipment> page, MdcEquipmentVo mdcEquipment, HttpServletRequest req); } diff --git a/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/impl/MdcEquipmentRunningSectionServiceImpl.java b/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/impl/MdcEquipmentRunningSectionServiceImpl.java index 2b48ae6..791d84e 100644 --- a/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/impl/MdcEquipmentRunningSectionServiceImpl.java +++ b/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/impl/MdcEquipmentRunningSectionServiceImpl.java @@ -74,7 +74,7 @@ for (MdcEquipmentRunningSection entity : running) { dto = new MdcEquipmentRunningSectionDto(); BeanUtils.copyProperties(entity, dto); - if (entity.getStatus() == 3 && StringUtils.isBlank(entity.getSequenceNumber()) && isTableExist) { + if (entity.getStatus() == 3 && StringUtils.isBlank(entity.getSequenceNumber()) && isTableExist && !"ZUOLAN".equals(equip.getDrivetype())) { List<EquipmentMachingDto> esList = equipmentWorkLineService.getEquipmentSequencenumber(tableName, entity.getStartTime(), entity.getEndTime()); if (esList != null && esList.size() > 1) { dto.setSequenceNumber(esList.get(0).getSequencenumber()); diff --git a/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/impl/MdcEquipmentServiceImpl.java b/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/impl/MdcEquipmentServiceImpl.java index bde0eee..50c1d48 100644 --- a/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/impl/MdcEquipmentServiceImpl.java +++ b/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/impl/MdcEquipmentServiceImpl.java @@ -35,6 +35,7 @@ import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; +import javax.servlet.http.HttpServletRequest; import java.math.BigDecimal; import java.math.RoundingMode; import java.util.*; @@ -685,4 +686,9 @@ return list.stream().map(MdcEquipment::getEquipmentId).collect(Collectors.toList()); } + @Override + public IPage<MdcEquipment> pageList(Page<MdcEquipment> page, MdcEquipmentVo mdcEquipment, HttpServletRequest req) { + return this.baseMapper.pageList(page, mdcEquipment); + } + } diff --git a/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/impl/ProcessCountServiceImpl.java b/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/impl/ProcessCountServiceImpl.java index 7db1dce..745a902 100644 --- a/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/impl/ProcessCountServiceImpl.java +++ b/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/impl/ProcessCountServiceImpl.java @@ -52,6 +52,7 @@ @Transactional(rollbackFor = {Exception.class}) public void runningProcessCount() { // 鑾峰彇鎵�鏈夎澶� + //List<MdcEquipment> mdcEquipmentList = mdcEquipmentService.list(new LambdaQueryWrapper<MdcEquipment>().eq(MdcEquipment::getEquipmentId, "2240074")); List<MdcEquipment> mdcEquipmentList = mdcEquipmentService.list(); List<MdcProcessCount> result = new ArrayList<>(); for (MdcEquipment mdcEquipment : mdcEquipmentList) { @@ -138,7 +139,7 @@ } // 鑾峰彇璁惧鐝淇℃伅 Map<String, List<MdcDeviceCalendarVo>> listMap = this.mdcDeviceCalendarMap(mdcEquipment.getEquipmentId(), stringDates); - if (listMap.isEmpty()) { + if (listMap == null || listMap.isEmpty()) { listMap = new HashMap<>(); } List<MdcProcessCount> resultList = new ArrayList<>(); @@ -194,27 +195,32 @@ mdcProcessCount.setStartTime(startDate); } if ("FANUC".equals(mdcEquipment.getDriveType())) { - // 娉曞叞鍏嬭澶囨牴鎹甈roductCount瀛楁鍒ゆ柇 - String productCount = mdcEquipmentDtoList.get(0).get("ProductCount").toString(); - for (int i = 0; i < mdcEquipmentDtoList.size(); i++) { - if (!productCount.equals(mdcEquipmentDtoList.get(i).get("ProductCount").toString())) { - productCount = mdcEquipmentDtoList.get(i).get("ProductCount").toString(); - if (mdcEquipmentDtoList.get(i - 1).get("CollectTime") != null) { - mdcProcessCount.setEndTime(DateUtils.toDate(mdcEquipmentDtoList.get(i - 1).get("CollectTime").toString(), DateUtils.STR_DATE_TIME)); - mdcProcessCount.setDuration(TimeFieldUtils.duration(mdcProcessCount.getStartTime(), mdcProcessCount.getEndTime())); - mdcProcessCount.setSequenceNumber(mdcEquipmentDtoList.get(i - 1).get("Sequencenumber").toString()); - resultList.add(mdcProcessCount); - if (TimeFieldUtils.duration(mdcProcessCount.getEndTime(), mdcEquipmentRunningSection.getEndTime()) > 60) { - //mdcProcessCount.setStartTime(mdcProcessCount.getEndTime()); - startDate = mdcProcessCount.getEndTime(); - } else if (j + 1 < equipmentRunningSectionList.size()) { - //mdcProcessCount.setStartTime(equipmentRunningSectionList.get(j + 1).getStartTime()); - startDate = equipmentRunningSectionList.get(j + 1).getStartTime(); - } else { - startDate = null; + try { + // 娉曞叞鍏嬭澶囨牴鎹甈roductCount瀛楁鍒ゆ柇 + String productCount = mdcEquipmentDtoList.get(0).get("ProductCount").toString(); + for (int i = 0; i < mdcEquipmentDtoList.size(); i++) { + if (!productCount.equals(mdcEquipmentDtoList.get(i).get("ProductCount").toString())) { + productCount = mdcEquipmentDtoList.get(i).get("ProductCount").toString(); + if (mdcEquipmentDtoList.get(i - 1).get("CollectTime") != null) { + mdcProcessCount.setEndTime(DateUtils.toDate(mdcEquipmentDtoList.get(i - 1).get("CollectTime").toString(), DateUtils.STR_DATE_TIME)); + mdcProcessCount.setDuration(TimeFieldUtils.duration(mdcProcessCount.getStartTime(), mdcProcessCount.getEndTime())); + mdcProcessCount.setSequenceNumber(mdcEquipmentDtoList.get(i - 1).get("Sequencenumber").toString()); + resultList.add(mdcProcessCount); + if (TimeFieldUtils.duration(mdcProcessCount.getEndTime(), mdcEquipmentRunningSection.getEndTime()) > 60) { + //mdcProcessCount.setStartTime(mdcProcessCount.getEndTime()); + startDate = mdcProcessCount.getEndTime(); + } else if (j + 1 < equipmentRunningSectionList.size()) { + //mdcProcessCount.setStartTime(equipmentRunningSectionList.get(j + 1).getStartTime()); + startDate = equipmentRunningSectionList.get(j + 1).getStartTime(); + } else { + startDate = null; + } } } } + } catch (Exception e) { + log.error("璁$畻鍔犲伐宸ヤ欢绠楁硶澶辫触锛佽澶囩紪鍙凤細" + mdcEquipment.getEquipmentId(), e); + //System.out.println("璁$畻鍔犲伐宸ヤ欢绠楁硶澶辫触锛佽澶囩紪鍙凤細" + mdcEquipment.getEquipmentId()); } } } diff --git a/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/vo/MdcEquipmentVo.java b/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/vo/MdcEquipmentVo.java index 0a286fd..19ec3ef 100644 --- a/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/vo/MdcEquipmentVo.java +++ b/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/vo/MdcEquipmentVo.java @@ -12,4 +12,8 @@ private String productionId; private String equipmentId; private String equipmentName; + private String equipmentModel; + private String equipmentType; + private String driveType; + private String productionName; } diff --git a/lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/system/controller/SysUserController.java b/lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/system/controller/SysUserController.java index 87c3052..6be0483 100644 --- a/lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/system/controller/SysUserController.java +++ b/lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/system/controller/SysUserController.java @@ -15,6 +15,7 @@ import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang.StringUtils; import org.apache.shiro.SecurityUtils; +import org.apache.shiro.authz.annotation.RequiresRoles; import org.jeecg.common.api.vo.Result; import org.jeecg.common.aspect.annotation.AutoLog; import org.jeecg.common.aspect.annotation.PermissionData; @@ -354,7 +355,7 @@ /** * 淇敼瀵嗙爜 */ - //@RequiresRoles({"admin"}) + @RequiresRoles({"admin"}) @RequestMapping(value = "/changePassword", method = RequestMethod.PUT) public Result<?> changePassword(@RequestBody SysUser sysUser) { SysUser u = this.sysUserService.getOne(new LambdaQueryWrapper<SysUser>().eq(SysUser::getUsername, sysUser.getUsername())); diff --git a/lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/system/service/impl/SysUserServiceImpl.java b/lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/system/service/impl/SysUserServiceImpl.java index 9028b88..4decd8a 100644 --- a/lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/system/service/impl/SysUserServiceImpl.java +++ b/lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/system/service/impl/SysUserServiceImpl.java @@ -110,6 +110,8 @@ sysUser.setSalt(salt); //璁剧疆瀵嗙爜鏇存柊鏃堕棿 sysUser.setPasswordTime(new Date()); + //绠$悊鍛樹慨鏀瑰瘑鐮侊紝璁剧疆鐢ㄦ埛棣栨鐧诲綍 + //sysUser.setPasswordFlag(); String password = sysUser.getPassword(); String passwordEncode = PasswordUtil.encrypt(sysUser.getUsername(), password, salt); sysUser.setPassword(passwordEncode); -- Gitblit v1.9.3