From 4ea6bf2330af533909af39da3d0736ad32657120 Mon Sep 17 00:00:00 2001 From: cuikaidong <ckd2942379034@163.com> Date: 星期五, 23 五月 2025 09:05:57 +0800 Subject: [PATCH] 设备封存功能 --- lxzn-module-eam/src/main/java/org/jeecg/modules/eam/controller/EamEquipmentSealUpController.java | 322 ++++++++++++---------- lxzn-module-eam/src/main/java/org/jeecg/modules/eam/request/EamEquipmentSealUpQuery.java | 23 + lxzn-module-eam-common/src/main/java/org/jeecg/modules/eam/constant/BusinessCodeConst.java | 2 lxzn-module-eam/src/main/java/org/jeecg/modules/eam/mapper/EamEquipmentSealUpMapper.java | 14 lxzn-module-eam/src/main/java/org/jeecg/modules/eam/service/IEamEquipmentSealUpService.java | 48 +++ lxzn-module-eam-common/src/main/java/org/jeecg/modules/eam/constant/EquipmentSealUpStatusEnum.java | 23 + lxzn-module-eam/src/main/java/org/jeecg/modules/eam/entity/EamEquipmentSealUp.java | 19 + lxzn-module-eam/src/main/java/org/jeecg/modules/eam/service/impl/EamEquipmentSealUpServiceImpl.java | 250 +++++++++++++++++ lxzn-module-eam/src/main/java/org/jeecg/modules/eam/mapper/xml/EamEquipmentSealUpMapper.xml | 7 lxzn-module-eam/src/main/java/org/jeecg/modules/eam/request/EamEquipmentSealUpRequest.java | 86 ++++++ 10 files changed, 639 insertions(+), 155 deletions(-) diff --git a/lxzn-module-eam-common/src/main/java/org/jeecg/modules/eam/constant/BusinessCodeConst.java b/lxzn-module-eam-common/src/main/java/org/jeecg/modules/eam/constant/BusinessCodeConst.java index b5575e9..034a747 100644 --- a/lxzn-module-eam-common/src/main/java/org/jeecg/modules/eam/constant/BusinessCodeConst.java +++ b/lxzn-module-eam-common/src/main/java/org/jeecg/modules/eam/constant/BusinessCodeConst.java @@ -21,6 +21,8 @@ String THIRD_MAINTENANCE_CODE_RULE = "ThirdMaintenanceCodeRule"; //璁惧鍊熷嚭褰掕繕 String LEAN_OUT_CODE_RULE = "EquipmentLeanOutCodeRule"; + //璁惧灏佸瓨鍚皝 + String SEAL_UP_CODE_RULE = "EquipmentSealUpCodeRule"; /** * 澶囦欢璇疯喘鍗曠姸鎬� 1:宸插垱寤� 2:宸叉彁浜� 3:宸查�氳繃 4:宸查┏鍥� 5:宸插畬鎴� */ diff --git a/lxzn-module-eam-common/src/main/java/org/jeecg/modules/eam/constant/EquipmentSealUpStatusEnum.java b/lxzn-module-eam-common/src/main/java/org/jeecg/modules/eam/constant/EquipmentSealUpStatusEnum.java new file mode 100644 index 0000000..7685601 --- /dev/null +++ b/lxzn-module-eam-common/src/main/java/org/jeecg/modules/eam/constant/EquipmentSealUpStatusEnum.java @@ -0,0 +1,23 @@ +package org.jeecg.modules.eam.constant; + +/** + * @author cuikaidong + * @date 2025/5/22 + */ +public enum EquipmentSealUpStatusEnum { + WAIT_SUBMIT, //寰呮彁浜� + WAIT_CHECK, //寰呭鏍� + SEALED, //宸插皝瀛� + COMPLETE, //宸插畬鎴� + ; + + public static EquipmentSealUpStatusEnum getInstance(String code) { + EquipmentSealUpStatusEnum[] values = EquipmentSealUpStatusEnum.values(); + for (EquipmentSealUpStatusEnum value : values) { + if (value.name().equals(code)) { + return value; + } + } + return null; + } +} diff --git a/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/controller/EamEquipmentSealUpController.java b/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/controller/EamEquipmentSealUpController.java index 779e871..f4ecc06 100644 --- a/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/controller/EamEquipmentSealUpController.java +++ b/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/controller/EamEquipmentSealUpController.java @@ -1,167 +1,193 @@ package org.jeecg.modules.eam.controller; -import java.util.Arrays; -import java.util.List; -import java.util.Map; -import java.io.IOException; -import java.io.UnsupportedEncodingException; -import java.net.URLDecoder; -import javax.servlet.http.HttpServletRequest; -import javax.servlet.http.HttpServletResponse; -import org.jeecg.common.api.vo.Result; -import org.jeecg.common.system.query.QueryGenerator; -import org.jeecg.common.aspect.annotation.AutoLog; -import org.jeecg.common.util.oConvertUtils; -import org.jeecg.modules.eam.entity.EamEquipmentSealUp; -import org.jeecg.modules.eam.service.IEamEquipmentSealUpService; -import java.util.Date; -import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.alibaba.fastjson.JSONObject; +import com.alibaba.fastjson.parser.Feature; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import lombok.extern.slf4j.Slf4j; -import org.jeecg.common.system.base.controller.JeecgController; -import org.jeecgframework.poi.excel.ExcelImportUtil; -import org.jeecgframework.poi.excel.def.NormalExcelConstants; -import org.jeecgframework.poi.excel.entity.ExportParams; -import org.jeecgframework.poi.excel.entity.ImportParams; -import org.jeecgframework.poi.excel.view.JeecgEntityExcelView; - -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.web.bind.annotation.*; -import org.springframework.web.multipart.MultipartFile; -import org.springframework.web.multipart.MultipartHttpServletRequest; -import org.springframework.web.servlet.ModelAndView; -import com.alibaba.fastjson.JSON; +import com.fasterxml.jackson.core.JsonProcessingException; +import com.fasterxml.jackson.databind.ObjectMapper; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; +import lombok.extern.slf4j.Slf4j; +import org.jeecg.common.api.vo.Result; +import org.jeecg.common.aspect.annotation.AutoLog; +import org.jeecg.common.constant.CommonConstant; +import org.jeecg.common.system.base.controller.JeecgController; +import org.jeecg.common.util.TranslateDictTextUtils; +import org.jeecg.modules.eam.constant.BusinessCodeConst; +import org.jeecg.modules.eam.constant.EquipmentSealUpStatusEnum; +import org.jeecg.modules.eam.entity.EamEquipmentSealUp; +import org.jeecg.modules.eam.request.EamEquipmentSealUpQuery; +import org.jeecg.modules.eam.service.IEamEquipmentSealUpService; +import org.jeecg.modules.system.service.ISysBusinessCodeRuleService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.*; - /** +import javax.servlet.http.HttpServletRequest; +import java.util.Arrays; +import java.util.List; + +/** * @Description: 璁惧灏佸瓨鍚皝 * @Author: jeecg-boot - * @Date: 2025-05-13 + * @Date: 2025-05-13 * @Version: V1.0 */ @Slf4j -@Api(tags="璁惧灏佸瓨鍚皝") +@Api(tags = "璁惧灏佸瓨鍚皝") @RestController @RequestMapping("/eam/eamEquipmentSealUp") public class EamEquipmentSealUpController extends JeecgController<EamEquipmentSealUp, IEamEquipmentSealUpService> { - @Autowired - private IEamEquipmentSealUpService eamEquipmentSealUpService; - - /** - * 鍒嗛〉鍒楄〃鏌ヨ - * - * @param eamEquipmentSealUp - * @param pageNo - * @param pageSize - * @param req - * @return - */ - @AutoLog(value = "璁惧灏佸瓨鍚皝-鍒嗛〉鍒楄〃鏌ヨ") - @ApiOperation(value="璁惧灏佸瓨鍚皝-鍒嗛〉鍒楄〃鏌ヨ", notes="璁惧灏佸瓨鍚皝-鍒嗛〉鍒楄〃鏌ヨ") - @GetMapping(value = "/list") - public Result<?> queryPageList(EamEquipmentSealUp eamEquipmentSealUp, - @RequestParam(name="pageNo", defaultValue="1") Integer pageNo, - @RequestParam(name="pageSize", defaultValue="10") Integer pageSize, - HttpServletRequest req) { - QueryWrapper<EamEquipmentSealUp> queryWrapper = QueryGenerator.initQueryWrapper(eamEquipmentSealUp, req.getParameterMap()); - Page<EamEquipmentSealUp> page = new Page<EamEquipmentSealUp>(pageNo, pageSize); - IPage<EamEquipmentSealUp> pageList = eamEquipmentSealUpService.page(page, queryWrapper); - return Result.OK(pageList); - } - - /** - * 娣诲姞 - * - * @param eamEquipmentSealUp - * @return - */ - @AutoLog(value = "璁惧灏佸瓨鍚皝-娣诲姞") - @ApiOperation(value="璁惧灏佸瓨鍚皝-娣诲姞", notes="璁惧灏佸瓨鍚皝-娣诲姞") - @PostMapping(value = "/add") - public Result<?> add(@RequestBody EamEquipmentSealUp eamEquipmentSealUp) { - eamEquipmentSealUpService.save(eamEquipmentSealUp); - return Result.OK("娣诲姞鎴愬姛锛�"); - } - - /** - * 缂栬緫 - * - * @param eamEquipmentSealUp - * @return - */ - @AutoLog(value = "璁惧灏佸瓨鍚皝-缂栬緫") - @ApiOperation(value="璁惧灏佸瓨鍚皝-缂栬緫", notes="璁惧灏佸瓨鍚皝-缂栬緫") - @RequestMapping(value = "/edit", method = {RequestMethod.PUT,RequestMethod.POST}) - public Result<?> edit(@RequestBody EamEquipmentSealUp eamEquipmentSealUp) { - eamEquipmentSealUpService.updateById(eamEquipmentSealUp); - return Result.OK("缂栬緫鎴愬姛!"); - } - - /** - * 閫氳繃id鍒犻櫎 - * - * @param id - * @return - */ - @AutoLog(value = "璁惧灏佸瓨鍚皝-閫氳繃id鍒犻櫎") - @ApiOperation(value="璁惧灏佸瓨鍚皝-閫氳繃id鍒犻櫎", notes="璁惧灏佸瓨鍚皝-閫氳繃id鍒犻櫎") - @DeleteMapping(value = "/delete") - public Result<?> delete(@RequestParam(name="id",required=true) String id) { - eamEquipmentSealUpService.removeById(id); - return Result.OK("鍒犻櫎鎴愬姛!"); - } - - /** - * 鎵归噺鍒犻櫎 - * - * @param ids - * @return - */ - @AutoLog(value = "璁惧灏佸瓨鍚皝-鎵归噺鍒犻櫎") - @ApiOperation(value="璁惧灏佸瓨鍚皝-鎵归噺鍒犻櫎", notes="璁惧灏佸瓨鍚皝-鎵归噺鍒犻櫎") - @DeleteMapping(value = "/deleteBatch") - public Result<?> deleteBatch(@RequestParam(name="ids",required=true) String ids) { - this.eamEquipmentSealUpService.removeByIds(Arrays.asList(ids.split(","))); - return Result.OK("鎵归噺鍒犻櫎鎴愬姛锛�"); - } - - /** - * 閫氳繃id鏌ヨ - * - * @param id - * @return - */ - @AutoLog(value = "璁惧灏佸瓨鍚皝-閫氳繃id鏌ヨ") - @ApiOperation(value="璁惧灏佸瓨鍚皝-閫氳繃id鏌ヨ", notes="璁惧灏佸瓨鍚皝-閫氳繃id鏌ヨ") - @GetMapping(value = "/queryById") - public Result<?> queryById(@RequestParam(name="id",required=true) String id) { - EamEquipmentSealUp eamEquipmentSealUp = eamEquipmentSealUpService.getById(id); - return Result.OK(eamEquipmentSealUp); - } + @Autowired + private IEamEquipmentSealUpService eamEquipmentSealUpService; + @Autowired + private ISysBusinessCodeRuleService businessCodeRuleService; + @Autowired + private ObjectMapper objectMapper; + @Autowired + private TranslateDictTextUtils translateDictTextUtils; - /** - * 瀵煎嚭excel - * - * @param request - * @param eamEquipmentSealUp - */ - @RequestMapping(value = "/exportXls") - public ModelAndView exportXls(HttpServletRequest request, EamEquipmentSealUp eamEquipmentSealUp) { - return super.exportXls(request, eamEquipmentSealUp, EamEquipmentSealUp.class, "璁惧灏佸瓨鍚皝"); - } + /** + * 鍒嗛〉鍒楄〃鏌ヨ + * + * @param query + * @param pageNo + * @param pageSize + * @param req + * @return + */ + @AutoLog(value = "璁惧灏佸瓨鍚皝-鍒嗛〉鍒楄〃鏌ヨ") + @ApiOperation(value = "璁惧灏佸瓨鍚皝-鍒嗛〉鍒楄〃鏌ヨ", notes = "璁惧灏佸瓨鍚皝-鍒嗛〉鍒楄〃鏌ヨ") + @GetMapping(value = "/list") + public Result<?> queryPageList(EamEquipmentSealUpQuery query, + @RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo, + @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize, + HttpServletRequest req) { + Page<EamEquipmentSealUp> page = new Page<EamEquipmentSealUp>(pageNo, pageSize); + IPage<EamEquipmentSealUp> pageList = eamEquipmentSealUpService.queryPageList(page, query); + return Result.OK(pageList); + } - /** - * 閫氳繃excel瀵煎叆鏁版嵁 - * - * @param request - * @param response - * @return - */ - @RequestMapping(value = "/importExcel", method = RequestMethod.POST) - public Result<?> importExcel(HttpServletRequest request, HttpServletResponse response) { - return super.importExcel(request, response, EamEquipmentSealUp.class); - } + /** + * 娣诲姞 + * + * @param request + * @return + */ + @AutoLog(value = "璁惧灏佸瓨鍚皝-娣诲姞") + @ApiOperation(value = "璁惧灏佸瓨鍚皝-娣诲姞", notes = "璁惧灏佸瓨鍚皝-娣诲姞") + @PostMapping(value = "/add") + public Result<?> add(@RequestBody EamEquipmentSealUp request) { + if (request == null) { + return Result.error("娣诲姞鐨勫璞′笉鑳戒负绌猴紒"); + } + request.setCode(businessCodeRuleService.generateBusinessCodeSeq(BusinessCodeConst.SEAL_UP_CODE_RULE)); + request.setSealStatus(EquipmentSealUpStatusEnum.WAIT_SUBMIT.name()); + request.setDelFlag(CommonConstant.DEL_FLAG_0); + boolean b = eamEquipmentSealUpService.addSealUp(request); + if (!b) { + return Result.error("娣诲姞澶辫触锛�"); + } + return Result.OK("娣诲姞鎴愬姛锛�"); + } + /** + * 缂栬緫 + * + * @param request + * @return + */ + @AutoLog(value = "璁惧灏佸瓨鍚皝-缂栬緫") + @ApiOperation(value = "璁惧灏佸瓨鍚皝-缂栬緫", notes = "璁惧灏佸瓨鍚皝-缂栬緫") + @RequestMapping(value = "/edit", method = {RequestMethod.PUT, RequestMethod.POST}) + public Result<?> edit(@RequestBody EamEquipmentSealUp request) { + if (request == null) { + return Result.error("缂栬緫鐨勫璞′笉鑳戒负绌猴紒"); + } + boolean b = eamEquipmentSealUpService.editSealUp(request); + if (!b) { + return Result.error("缂栬緫澶辫触锛�"); + } + return Result.OK("缂栬緫鎴愬姛!"); + } + + /** + * 閫氳繃id鍒犻櫎 + * + * @param id + * @return + */ + @AutoLog(value = "璁惧灏佸瓨鍚皝-閫氳繃id鍒犻櫎") + @ApiOperation(value = "璁惧灏佸瓨鍚皝-閫氳繃id鍒犻櫎", notes = "璁惧灏佸瓨鍚皝-閫氳繃id鍒犻櫎") + @DeleteMapping(value = "/delete") + public Result<?> delete(@RequestParam(name = "id", required = true) String id) { + EamEquipmentSealUp entity = eamEquipmentSealUpService.getById(id); + if (entity != null) { + entity.setDelFlag(CommonConstant.DEL_FLAG_1); + eamEquipmentSealUpService.updateById(entity); + } + return Result.OK("鍒犻櫎鎴愬姛!"); + } + + /** + * 鎵归噺鍒犻櫎 + * + * @param ids + * @return + */ + @AutoLog(value = "璁惧灏佸瓨鍚皝-鎵归噺鍒犻櫎") + @ApiOperation(value = "璁惧灏佸瓨鍚皝-鎵归噺鍒犻櫎", notes = "璁惧灏佸瓨鍚皝-鎵归噺鍒犻櫎") + @DeleteMapping(value = "/deleteBatch") + public Result<?> deleteBatch(@RequestParam(name = "ids", required = true) String ids) { + List<String> list = Arrays.asList(ids.split(",")); + list.forEach(id -> { + EamEquipmentSealUp entity = eamEquipmentSealUpService.getById(id); + if (entity != null) { + entity.setDelFlag(CommonConstant.DEL_FLAG_1); + eamEquipmentSealUpService.updateById(entity); + } + }); + return Result.OK("鎵归噺鍒犻櫎鎴愬姛锛�"); + } + + /** + * 閫氳繃id鏌ヨ + * + * @param id + * @return + */ + @AutoLog(value = "璁惧灏佸瓨鍚皝-閫氳繃id鏌ヨ") + @ApiOperation(value = "璁惧灏佸瓨鍚皝-閫氳繃id鏌ヨ", notes = "璁惧灏佸瓨鍚皝-閫氳繃id鏌ヨ") + @GetMapping(value = "/queryById") + public Result<?> queryById(@RequestParam(name = "id", required = true) String id) { + EamEquipmentSealUp eamEquipmentSealUp = eamEquipmentSealUpService.getById(id); + if (eamEquipmentSealUp == null) { + return Result.error("鏈壘鍒板搴旀暟鎹�"); + } + try { + String json = objectMapper.writeValueAsString(eamEquipmentSealUp); + JSONObject item = JSONObject.parseObject(json, Feature.OrderedField); + translateDictTextUtils.translateField("reportUser", eamEquipmentSealUp.getReportUser(), item, "sys_user,realname,username"); + return Result.OK(item); + } catch (JsonProcessingException e) { + return Result.error("鏁版嵁杞瘧澶辫触锛�"); + } + } + + /** + * 鎻愪氦 + * + * @param id + * @return + */ + @AutoLog(value = "璁惧灏佸瓨鍚皝-鎻愪氦") + @ApiOperation(value = "璁惧灏佸瓨鍚皝-鎻愪氦", notes = "璁惧灏佸瓨鍚皝-鎻愪氦") + @GetMapping(value = "/submit") + public Result<?> submit(@RequestParam(name = "id", required = true) String id) { + boolean b = eamEquipmentSealUpService.submit(id); + if (!b) { + return Result.error("鎿嶄綔澶辫触锛�"); + } + return Result.OK("鎿嶄綔鎴愬姛!"); + } } diff --git a/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/entity/EamEquipmentSealUp.java b/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/entity/EamEquipmentSealUp.java index 2b257af..5c78c33 100644 --- a/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/entity/EamEquipmentSealUp.java +++ b/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/entity/EamEquipmentSealUp.java @@ -1,14 +1,18 @@ package org.jeecg.modules.eam.entity; import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableName; +import com.fasterxml.jackson.annotation.JsonFormat; import io.swagger.annotations.ApiModel; import io.swagger.annotations.ApiModelProperty; import lombok.Data; import lombok.EqualsAndHashCode; import lombok.experimental.Accessors; +import org.jeecg.common.aspect.annotation.Dict; import org.jeecgframework.poi.excel.annotation.Excel; +import org.springframework.format.annotation.DateTimeFormat; import java.io.Serializable; import java.util.Date; @@ -58,12 +62,17 @@ /**鐢宠浜�*/ @Excel(name = "鐢宠浜�", width = 15) @ApiModelProperty(value = "鐢宠浜�") + @Dict(dicCode = "sys_user, realname, username") private String reportUser; /**灏佸瓨寮�濮嬫椂闂�*/ @ApiModelProperty(value = "灏佸瓨寮�濮嬫椂闂�") + @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss") + @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss") private Date sealStartTime; /**灏佸瓨缁撴潫鏃堕棿*/ @ApiModelProperty(value = "灏佸瓨缁撴潫鏃堕棿") + @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss") + @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss") private Date sealEndTime; /**灏佸瓨鍘熷洜*/ @Excel(name = "灏佸瓨鍘熷洜", width = 15) @@ -72,6 +81,7 @@ /**灏佸瓨鐘舵��*/ @Excel(name = "灏佸瓨鐘舵��", width = 15) @ApiModelProperty(value = "灏佸瓨鐘舵��") + @Dict(dicCode = "equipment_seal_up_status") private String sealStatus; /**瀹℃牳浜�*/ @Excel(name = "瀹℃牳浜�", width = 15) @@ -79,9 +89,18 @@ private String approvalUser; /**瀹℃牳鏃堕棿*/ @ApiModelProperty(value = "瀹℃牳鏃堕棿") + @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss") + @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss") private Date approvalTime; /**澶囨敞*/ @Excel(name = "澶囨敞", width = 15) @ApiModelProperty(value = "澶囨敞") private String remark; + + //鍒楄〃灞曠ず + @TableField(exist = false) + private String equipmentCode; + @TableField(exist = false) + private String equipmentName; + } diff --git a/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/mapper/EamEquipmentSealUpMapper.java b/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/mapper/EamEquipmentSealUpMapper.java index 292016f..284dce0 100644 --- a/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/mapper/EamEquipmentSealUpMapper.java +++ b/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/mapper/EamEquipmentSealUpMapper.java @@ -2,7 +2,12 @@ import java.util.List; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.core.toolkit.Constants; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import org.apache.ibatis.annotations.Param; +import org.jeecg.modules.eam.entity.EamEquipmentLeanOut; import org.jeecg.modules.eam.entity.EamEquipmentSealUp; import com.baomidou.mybatisplus.core.mapper.BaseMapper; @@ -13,5 +18,12 @@ * @Version: V1.0 */ public interface EamEquipmentSealUpMapper extends BaseMapper<EamEquipmentSealUp> { - + /** + * 鍒嗛〉鏌ヨ + * + * @param page + * @param queryWrapper + * @return + */ + IPage<EamEquipmentSealUp> queryPageList(Page<EamEquipmentSealUp> page, @Param(Constants.WRAPPER) QueryWrapper<EamEquipmentSealUp> queryWrapper); } diff --git a/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/mapper/xml/EamEquipmentSealUpMapper.xml b/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/mapper/xml/EamEquipmentSealUpMapper.xml index b36f9a2..57fade4 100644 --- a/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/mapper/xml/EamEquipmentSealUpMapper.xml +++ b/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/mapper/xml/EamEquipmentSealUpMapper.xml @@ -2,4 +2,11 @@ <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <mapper namespace="org.jeecg.modules.eam.mapper.EamEquipmentSealUpMapper"> + <select id="queryPageList" resultType="org.jeecg.modules.eam.entity.EamEquipmentSealUp"> + select wmo.*, e.equipment_code, e.equipment_name + from eam_equipment_seal_up wmo + inner join eam_equipment e + on wmo.equipment_id = e.id + ${ew.customSqlSegment} + </select> </mapper> \ No newline at end of file diff --git a/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/request/EamEquipmentSealUpQuery.java b/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/request/EamEquipmentSealUpQuery.java new file mode 100644 index 0000000..e1aa10e --- /dev/null +++ b/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/request/EamEquipmentSealUpQuery.java @@ -0,0 +1,23 @@ +package org.jeecg.modules.eam.request; + +import com.fasterxml.jackson.annotation.JsonFormat; +import lombok.Data; +import org.springframework.format.annotation.DateTimeFormat; + +import java.util.Date; + +@Data +public class EamEquipmentSealUpQuery { + private String code; + private String equipmentId; + @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd") + @DateTimeFormat(pattern = "yyyy-MM-dd") + private Date leanDateBegin; + @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd") + @DateTimeFormat(pattern = "yyyy-MM-dd") + private Date leanDateEnd; + private String sealStatus; + + private String column; + private String order; +} diff --git a/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/request/EamEquipmentSealUpRequest.java b/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/request/EamEquipmentSealUpRequest.java new file mode 100644 index 0000000..33700de --- /dev/null +++ b/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/request/EamEquipmentSealUpRequest.java @@ -0,0 +1,86 @@ +package org.jeecg.modules.eam.request; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import com.fasterxml.jackson.annotation.JsonFormat; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.experimental.Accessors; +import org.jeecg.common.aspect.annotation.Dict; +import org.jeecg.modules.flowable.domain.vo.FlowTaskVo; +import org.jeecgframework.poi.excel.annotation.Excel; +import org.springframework.format.annotation.DateTimeFormat; + +import java.io.Serializable; +import java.util.Date; + +/** + * @Description: 璁惧灏佸瓨鍚皝 + * @Author: jeecg-boot + * @Date: 2025-05-13 + * @Version: V1.0 + */ +@Data +@EqualsAndHashCode(callSuper = false) +@Accessors(chain = true) +public class EamEquipmentSealUpRequest extends FlowTaskVo implements Serializable { + + /**涓婚敭*/ + @ApiModelProperty(value = "涓婚敭") + private String id; + /**鍒涘缓浜�*/ + @ApiModelProperty(value = "鍒涘缓浜�") + private String createBy; + /**鍒涘缓鏃堕棿*/ + @ApiModelProperty(value = "鍒涘缓鏃堕棿") + private Date createTime; + /**鏇存柊浜�*/ + @ApiModelProperty(value = "鏇存柊浜�") + private String updateBy; + /**鏇存柊鏃堕棿*/ + @ApiModelProperty(value = "鏇存柊鏃堕棿") + private Date updateTime; + /**鍒犻櫎鏍囪*/ + @ApiModelProperty(value = "鍒犻櫎鏍囪") + private Integer delFlag; + /**璁惧ID*/ + @ApiModelProperty(value = "璁惧ID") + private String equipmentId; + /**鍗曟嵁鍙�*/ + @ApiModelProperty(value = "鍗曟嵁鍙�") + private String code; + /**鐢宠浜�*/ + @ApiModelProperty(value = "鐢宠浜�") + private String reportUser; + /**灏佸瓨寮�濮嬫椂闂�*/ + @ApiModelProperty(value = "灏佸瓨寮�濮嬫椂闂�") + @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss") + @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss") + private Date sealStartTime; + /**灏佸瓨缁撴潫鏃堕棿*/ + @ApiModelProperty(value = "灏佸瓨缁撴潫鏃堕棿") + @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss") + @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss") + private Date sealEndTime; + /**灏佸瓨鍘熷洜*/ + @ApiModelProperty(value = "灏佸瓨鍘熷洜") + private String sealUpReason; + /**灏佸瓨鐘舵��*/ + @ApiModelProperty(value = "灏佸瓨鐘舵��") + @Dict(dicCode = "equipment_seal_up_status") + private String sealStatus; + /**瀹℃牳浜�*/ + @ApiModelProperty(value = "瀹℃牳浜�") + private String approvalUser; + /**瀹℃牳鏃堕棿*/ + @ApiModelProperty(value = "瀹℃牳鏃堕棿") + @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss") + @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss") + private Date approvalTime; + /**澶囨敞*/ + @ApiModelProperty(value = "澶囨敞") + private String remark; +} diff --git a/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/service/IEamEquipmentSealUpService.java b/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/service/IEamEquipmentSealUpService.java index d3c8070..fcf8915 100644 --- a/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/service/IEamEquipmentSealUpService.java +++ b/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/service/IEamEquipmentSealUpService.java @@ -1,14 +1,58 @@ package org.jeecg.modules.eam.service; -import org.jeecg.modules.eam.entity.EamEquipmentSealUp; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.IService; +import org.jeecg.modules.eam.entity.EamEquipmentSealUp; +import org.jeecg.modules.eam.request.EamEquipmentSealUpQuery; +import org.jeecg.modules.eam.request.EamEquipmentSealUpRequest; /** * @Description: 璁惧灏佸瓨鍚皝 * @Author: jeecg-boot - * @Date: 2025-05-13 + * @Date: 2025-05-13 * @Version: V1.0 */ public interface IEamEquipmentSealUpService extends IService<EamEquipmentSealUp> { + /** + * 鍒嗛〉鏌ヨ + * + * @param page + * @param query + * @return + */ + IPage<EamEquipmentSealUp> queryPageList(Page<EamEquipmentSealUp> page, EamEquipmentSealUpQuery query); + + /** + * 娣诲姞灏佸瓨璁板綍 + * + * @param request + * @return + */ + boolean addSealUp(EamEquipmentSealUp request); + + /** + * 缂栬緫 + * + * @param request + * @return + */ + boolean editSealUp(EamEquipmentSealUp request); + + /** + * 鎻愪氦鐢宠 + * + * @param id + * @return + */ + boolean submit(String id); + + /** + * 瀹℃壒娴佺▼鎺у埗 + * + * @param request + * @return + */ + EamEquipmentSealUp approval(EamEquipmentSealUpRequest request); } diff --git a/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/service/impl/EamEquipmentSealUpServiceImpl.java b/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/service/impl/EamEquipmentSealUpServiceImpl.java index 978500f..90afff0 100644 --- a/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/service/impl/EamEquipmentSealUpServiceImpl.java +++ b/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/service/impl/EamEquipmentSealUpServiceImpl.java @@ -1,19 +1,261 @@ package org.jeecg.modules.eam.service.impl; +import cn.hutool.core.collection.CollectionUtil; +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.core.metadata.IPage; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import org.apache.commons.lang3.StringUtils; +import org.apache.shiro.SecurityUtils; +import org.flowable.engine.TaskService; +import org.jeecg.common.api.vo.Result; +import org.jeecg.common.constant.CommonConstant; +import org.jeecg.common.constant.DataBaseConstant; +import org.jeecg.common.exception.JeecgBootException; +import org.jeecg.common.system.vo.LoginUser; +import org.jeecg.common.util.oConvertUtils; +import org.jeecg.modules.eam.constant.AssetStatusEnum; +import org.jeecg.modules.eam.constant.BusinessCodeConst; +import org.jeecg.modules.eam.constant.EquipmentLeanOutStatusEnum; +import org.jeecg.modules.eam.constant.EquipmentSealUpStatusEnum; +import org.jeecg.modules.eam.entity.EamEquipment; import org.jeecg.modules.eam.entity.EamEquipmentSealUp; import org.jeecg.modules.eam.mapper.EamEquipmentSealUpMapper; +import org.jeecg.modules.eam.request.EamEquipmentSealUpQuery; +import org.jeecg.modules.eam.request.EamEquipmentSealUpRequest; import org.jeecg.modules.eam.service.IEamEquipmentSealUpService; +import org.jeecg.modules.eam.service.IEamEquipmentService; +import org.jeecg.modules.flowable.apithird.business.entity.FlowMyBusiness; +import org.jeecg.modules.flowable.apithird.business.service.IFlowMyBusinessService; +import org.jeecg.modules.flowable.apithird.service.FlowCallBackServiceI; +import org.jeecg.modules.flowable.apithird.service.FlowCommonService; +import org.jeecg.modules.flowable.service.IFlowDefinitionService; +import org.jeecg.modules.flowable.service.IFlowTaskService; +import org.jeecg.modules.system.service.ISysUserService; +import org.jeecg.modules.system.vo.UserSelector; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; -import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import javax.annotation.Resource; +import java.util.*; +import java.util.stream.Collectors; /** * @Description: 璁惧灏佸瓨鍚皝 * @Author: jeecg-boot - * @Date: 2025-05-13 + * @Date: 2025-05-13 * @Version: V1.0 */ -@Service -public class EamEquipmentSealUpServiceImpl extends ServiceImpl<EamEquipmentSealUpMapper, EamEquipmentSealUp> implements IEamEquipmentSealUpService { +@Service("IEamEquipmentSealUpService") +public class EamEquipmentSealUpServiceImpl extends ServiceImpl<EamEquipmentSealUpMapper, EamEquipmentSealUp> implements IEamEquipmentSealUpService, FlowCallBackServiceI { + @Resource + private EamEquipmentSealUpMapper equipmentSealUpMapper; + @Autowired + private IEamEquipmentService eamEquipmentService; + @Autowired + private FlowCommonService flowCommonService; + @Autowired + private IFlowDefinitionService flowDefinitionService; + @Autowired + private IFlowMyBusinessService flowMyBusinessService; + @Autowired + private TaskService taskService; + @Autowired + private IFlowTaskService flowTaskService; + + @Autowired + private ISysUserService sysUserService; + + + @Override + public IPage<EamEquipmentSealUp> queryPageList(Page<EamEquipmentSealUp> page, EamEquipmentSealUpQuery query) { + QueryWrapper<EamEquipmentSealUp> queryWrapper = new QueryWrapper<>(); + queryWrapper.eq("wmo.del_flag", CommonConstant.DEL_FLAG_0); + //鐢ㄦ埛鏁版嵁鏉冮檺 + LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal(); + if (sysUser == null) { + return page; + } + if (StringUtils.isNotBlank(sysUser.getEquipmentIds())) { + //閫夋嫨浜嗚澶囷紝鏍规嵁璁惧id杩囨护璁惧 + List<String> equipArr = Arrays.asList(sysUser.getEquipmentIds().split(",")); + queryWrapper.in("e.equipment_code", equipArr); + } else { + //娌℃湁閫夋嫨璁惧锛屾牴鎹溅闂磋繃婊よ澶� + queryWrapper.exists("select 1 from mdc_user_production t where t.user_id={0} and t.pro_id=e.org_id ", sysUser.getId()); + } + //鎺у埗寰呮彁浜ょ姸鎬佺殑鏁版嵁鍙兘鏈汉鏌ョ湅 + queryWrapper.and(i -> i.ne("wmo.seal_status", EquipmentSealUpStatusEnum.WAIT_SUBMIT).or().eq("wmo.report_user", sysUser.getUsername())); + //鏌ヨ鏉′欢杩囨护 + if (query != null) { + if (StringUtils.isNotBlank(query.getEquipmentId())) { + queryWrapper.eq("wmo.equipment_id", query.getEquipmentId()); + } + if (StringUtils.isNotBlank(query.getCode())) { + queryWrapper.like("wmo.code", query.getCode()); + } + if (StringUtils.isNotBlank(query.getSealStatus())) { + queryWrapper.eq("wmo.seal_status", query.getSealStatus()); + } + if (query.getLeanDateBegin() != null && query.getLeanDateEnd() != null) { + queryWrapper.between("wmo.lean_start_time", query.getLeanDateBegin(), query.getLeanDateEnd()); + } + //鎺掑簭 + if (StringUtils.isNotBlank(query.getColumn()) && StringUtils.isNotBlank(query.getOrder())) { + String column = query.getColumn(); + if (column.endsWith(CommonConstant.DICT_TEXT_SUFFIX)) { + column = column.substring(0, column.lastIndexOf(CommonConstant.DICT_TEXT_SUFFIX)); + } + if (DataBaseConstant.SQL_ASC.equalsIgnoreCase(query.getOrder())) { + queryWrapper.orderByAsc("wmo." + oConvertUtils.camelToUnderline(column)); + } else { + queryWrapper.orderByDesc("wmo." + oConvertUtils.camelToUnderline(column)); + } + } else { + queryWrapper.orderByDesc("wmo.create_time"); + } + } else { + queryWrapper.orderByDesc("wmo.create_time"); + } + + return equipmentSealUpMapper.queryPageList(page, queryWrapper); + } + + @Override + @Transactional(rollbackFor = Exception.class) + public boolean addSealUp(EamEquipmentSealUp request) { + //妫�鏌ヨ澶� + EamEquipment equipment = eamEquipmentService.getById(request.getEquipmentId()); + if (equipment == null) { + throw new JeecgBootException("璁惧涓嶅瓨鍦紒"); + } + if (!AssetStatusEnum.NORMAL.name().equals(equipment.getAssetStatus())) { + throw new JeecgBootException("姝よ澶囧綋鍓嶈祫浜х姸鎬佷笉鍏佽鍊熷嚭锛�"); + } + LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal(); + if (sysUser == null) { + throw new JeecgBootException("褰撳墠鐢ㄦ埛鏃犳硶娣诲姞鍊熺敤璁板綍锛�"); + } + request.setReportUser(sysUser.getUsername()); + return equipmentSealUpMapper.insert(request) > 0; + } + + @Override + @Transactional(rollbackFor = Exception.class) + public boolean editSealUp(EamEquipmentSealUp request) { + EamEquipmentSealUp entity = equipmentSealUpMapper.selectById(request.getId()); + if (entity == null) { + throw new JeecgBootException("瑕佺紪杈戠殑鏁版嵁涓嶅瓨鍦紝璇峰埛鏂伴噸璇曪紒"); + } + if (!EquipmentSealUpStatusEnum.WAIT_SUBMIT.name().equals(entity.getSealStatus())) { + throw new JeecgBootException("褰撳墠鏁版嵁鐘舵�佷笉鍏佽缂栬緫锛�"); + } + //妫�鏌ヨ澶� + EamEquipment equipment = eamEquipmentService.getById(request.getEquipmentId()); + if (equipment == null) { + throw new JeecgBootException("璁惧涓嶅瓨鍦紒"); + } + LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal(); + if (sysUser == null) { + throw new JeecgBootException("褰撳墠鐢ㄦ埛鏃犳硶缂栬緫鍊熺敤璁板綍锛�"); + } + UpdateWrapper<EamEquipmentSealUp> updateWrapper = new UpdateWrapper<>(); + updateWrapper.set("equipment_id", request.getEquipmentId()); + updateWrapper.set("remark", request.getRemark()); + updateWrapper.set("seal_up_reason", request.getSealUpReason()); + updateWrapper.eq("id", request.getId()); + updateWrapper.eq("report_user", sysUser.getUsername()); + return super.update(updateWrapper); + } + + @Override + @Transactional(rollbackFor = Exception.class) + public boolean submit(String id) { + EamEquipmentSealUp entity = equipmentSealUpMapper.selectById(id); + if (entity == null) { + throw new JeecgBootException("瑕佹彁浜ょ殑鏁版嵁涓嶅瓨鍦紝璇峰埛鏂伴噸璇曪紒"); + } + if (!EquipmentLeanOutStatusEnum.WAIT_SUBMIT.name().equals(entity.getSealStatus())) { + throw new JeecgBootException("褰撳墠鏁版嵁鐘舵�佷笉鍏佽缂栬緫锛�"); + } + //妫�鏌ヨ澶� + EamEquipment equipment = eamEquipmentService.getById(entity.getEquipmentId()); + if (equipment == null) { + throw new JeecgBootException("璁惧涓嶅瓨鍦紒"); + } + LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal(); + if (sysUser == null) { + throw new JeecgBootException("褰撳墠鐢ㄦ埛鏃犳硶缂栬緫灏佸瓨璁板綍锛�"); + } + UpdateWrapper<EamEquipmentSealUp> updateWrapper = new UpdateWrapper<>(); + updateWrapper.set("seal_status", EquipmentSealUpStatusEnum.WAIT_SUBMIT.name()); + updateWrapper.eq("id", id); + updateWrapper.eq("report_user", sysUser.getUsername()); + boolean success = super.update(updateWrapper); + if (success) { + equipment.setAssetStatus(AssetStatusEnum.SEAL_UP.name()); // 璁惧灏佸瓨 + eamEquipmentService.updateById(equipment); + } + //鍚姩瀹℃壒娴佺▼ + flowCommonService.initActBusiness("宸ュ崟鍙�:" + entity.getCode() + ";璁惧缂栧彿: " + equipment.getEquipmentCode() + ";杩涜璁惧灏佸瓨", + entity.getId(), "IEamEquipmentSealUpService", "equipment_seal_up", null); + Map<String, Object> variables = new HashMap<>(); + variables.put("dataId", entity.getId()); + if (StrUtil.isEmpty(entity.getSealUpReason())) { + variables.put("organization", "鏂板灏佸瓨榛樿鍚姩娴佺▼"); + variables.put("comment", "鏂板灏佸瓨宸ュ崟榛樿鍚姩娴佺▼"); + } else { + variables.put("organization", entity.getSealUpReason()); + variables.put("comment", entity.getSealUpReason()); + } + variables.put("proofreading", true); + // 鍒嗛厤缁欒澶囩鐞嗗憳 + List<UserSelector> userSelectors = sysUserService.selectOperatorList(equipment.getEquipmentCode(), equipment.getOrgId(), BusinessCodeConst.PCR0004); + if (CollectionUtil.isEmpty(userSelectors)) { + throw new JeecgBootException("璁惧鏈垎閰嶇粰璁惧绠$悊鍛橈紝鏃犳硶杩涘叆涓嬬骇瀹℃壒锛�"); + } + List<String> usernames = userSelectors.stream().map(UserSelector::getUsername).collect(Collectors.toList()); + variables.put("NextAssignee", usernames); + Result result = flowDefinitionService.startProcessInstanceByKey("equipment_seal_up", variables); + if (result != null) { + entity.setSealStartTime(new Date()); + entity.setSealStatus(EquipmentSealUpStatusEnum.WAIT_CHECK.name()); + //淇濆瓨宸ュ崟 + equipmentSealUpMapper.updateById(entity); + return result.isSuccess(); + } + return true; + } + + @Override + @Transactional(rollbackFor = Exception.class) + public EamEquipmentSealUp approval(EamEquipmentSealUpRequest request) { + return null; + } + + @Override + public void afterFlowHandle(FlowMyBusiness business) { + business.getTaskNameId();//鎺ヤ笅鏉ュ鎵圭殑鑺傜偣 + business.getValues();//鍓嶇浼犺繘鏉ョ殑鍙傛暟 + business.getActStatus(); + } + + @Override + public Object getBusinessDataById(String dataId) { + return this.getById(dataId); + } + + @Override + public Map<String, Object> flowValuesOfTask(String taskNameId, Map<String, Object> values) { + return null; + } + + @Override + public List<String> flowCandidateUsernamesOfTask(String taskNameId, Map<String, Object> values) { + return null; + } } -- Gitblit v1.9.3