From ab99ebf6ccca795c1f002b49dcde790d6c075729 Mon Sep 17 00:00:00 2001 From: ty <1577900710@qq.com> Date: Wed, 17 Jan 2024 16:16:26 +0800 Subject: [PATCH 1/3] =?UTF-8?q?=E4=BF=AE=E6=AD=A3=E4=BA=A4=E6=8E=A5?= =?UTF-8?q?=E7=8F=ADbug?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../hzims/operational/OperationalConstants.java | 23 ++- .../operational/duty/entity/ImsDutyLogEntity.java | 110 ++++++++++++ .../operational/duty/entity/ImsDutyRecEntity.java | 4 + .../hzims/operational/duty/vo/ImsDutyRecVO.java | 4 + .../workTicket/entity/WorkTicketInfoEntity.java | 2 + .../ticket/workTicket/feign/ITicketInfoClient.java | 20 +++ .../workTicket/feign/TicketInfoClientFallback.java | 10 ++ hzims-service/operational/pom.xml | 4 +- .../duty/controller/ImsDutyRecController.java | 91 +++++++++- .../operational/duty/mapper/ImsDutyLogMapper.java | 15 ++ .../operational/duty/mapper/ImsDutyLogMapper.xml | 4 + .../duty/service/IImsDutyLogService.java | 16 ++ .../duty/service/IImsDutyRecService.java | 3 + .../duty/service/impl/ImsDutyLogServiceImpl.java | 179 ++++++++++++++++++ .../duty/service/impl/ImsDutyRecServiceImpl.java | 199 +++++++++++++++++++-- .../main/resources/template/dutyLogTemplate.docx | Bin 0 -> 14351 bytes .../ticket/workTicket/feign/TicketInfoClient.java | 34 ++++ 17 files changed, 693 insertions(+), 25 deletions(-) create mode 100644 hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/duty/entity/ImsDutyLogEntity.java create mode 100644 hzims-service/operational/src/main/java/com/hnac/hzims/operational/duty/mapper/ImsDutyLogMapper.java create mode 100644 hzims-service/operational/src/main/java/com/hnac/hzims/operational/duty/mapper/ImsDutyLogMapper.xml create mode 100644 hzims-service/operational/src/main/java/com/hnac/hzims/operational/duty/service/IImsDutyLogService.java create mode 100644 hzims-service/operational/src/main/java/com/hnac/hzims/operational/duty/service/impl/ImsDutyLogServiceImpl.java create mode 100644 hzims-service/operational/src/main/resources/template/dutyLogTemplate.docx diff --git a/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/OperationalConstants.java b/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/OperationalConstants.java index 93810fc..145e762 100644 --- a/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/OperationalConstants.java +++ b/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/OperationalConstants.java @@ -373,6 +373,27 @@ public class OperationalConstants { this.name = name; } } + public enum DutyLogLevel { + /** + * 水电站 + */ + importLevel("1", "重要"), + /** + * 风电 + */ + generalLevel("2", "一般"), + ordinaryLevel("3", "普通"); + /** + * 泵站 + */ + @Getter + private String val; + @Getter + private String name; - + private DutyLogLevel(String val, String name) { + this.val = val; + this.name = name; + } + } } diff --git a/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/duty/entity/ImsDutyLogEntity.java b/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/duty/entity/ImsDutyLogEntity.java new file mode 100644 index 0000000..d8a3792 --- /dev/null +++ b/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/duty/entity/ImsDutyLogEntity.java @@ -0,0 +1,110 @@ +package com.hnac.hzims.operational.duty.entity; + +import com.baomidou.mybatisplus.annotation.TableName; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; +import lombok.EqualsAndHashCode; +import org.springblade.core.tenant.mp.TenantEntity; + +import java.io.Serializable; + + +/** + * 实体类 + * + * @author Chill + */ +@Data +@TableName("hz_ims_duty_log") +@ApiModel(value = "ImsDutyLog对象", description = "值班日志") +@EqualsAndHashCode(callSuper = true) +public class ImsDutyLogEntity extends TenantEntity implements Serializable{ + + private static final long serialVersionUID = -2877981299088576156L; + /** + * 值班ID + */ + @ApiModelProperty(value = "值班ID") + private Long dutyId; + /** + * 日期 + */ + @ApiModelProperty(value = "日期") + private String time; + /** + * 值班时间 + */ + private String dutyTime; + /** + * 班类 + */ + @ApiModelProperty(value = "班类") + private String classType; + /** + * 已执行操作票 + */ + private String operationFinish="0"; + /** + * 未执行操作票 + */ + private String operationUnFinish="0"; + /** + * 作废操作票 + */ + private String operationCancel="0"; + /** + * 执行中工作票 + */ + private String workDoing="0"; + /** + * 未执行工作票 + */ + private String workUnFinish="0"; + /** + * 终结工作票 + */ + private String workFinish="0"; + /** + * 作废工作票 + */ + private String workCancel="0"; + /** + * 交班值班长 + */ + private String handMaster; + /** + * 交班值班员 + */ + private String handNumber; + /** + * 交班时间 + */ + private String handTime; + /** + * 接班值班长 + */ + private String carryMaster; + /** + * 接班值班员 + */ + private String carryNumber; + /** + * 接班时间 + */ + private String carryTime; + /** + * 交接班会照片 + */ + private String dutyPic; + /** + * 值班情况 + */ + private String dutyStatus; + /** + * 上级通知及注意事项 + */ + private String notice; + + +} diff --git a/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/duty/entity/ImsDutyRecEntity.java b/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/duty/entity/ImsDutyRecEntity.java index 7fd2b1c..0735f33 100644 --- a/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/duty/entity/ImsDutyRecEntity.java +++ b/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/duty/entity/ImsDutyRecEntity.java @@ -1,6 +1,7 @@ package com.hnac.hzims.operational.duty.entity; import com.baomidou.mybatisplus.annotation.SqlCondition; +import com.baomidou.mybatisplus.annotation.TableField; import com.baomidou.mybatisplus.annotation.TableName; import com.fasterxml.jackson.annotation.JsonFormat; import com.fasterxml.jackson.databind.annotation.JsonSerialize; @@ -102,5 +103,8 @@ public class ImsDutyRecEntity extends TenantEntity { @QueryField(condition = SqlCondition.LIKE) private String dealChain; + @ApiModelProperty(value = "值班日志") + @TableField(exist=false) + private ImsDutyLogEntity imsDutyLogEntity; } diff --git a/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/duty/vo/ImsDutyRecVO.java b/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/duty/vo/ImsDutyRecVO.java index 38f9302..6fb1a04 100644 --- a/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/duty/vo/ImsDutyRecVO.java +++ b/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/duty/vo/ImsDutyRecVO.java @@ -2,6 +2,7 @@ package com.hnac.hzims.operational.duty.vo; import com.fasterxml.jackson.databind.annotation.JsonSerialize; import com.fasterxml.jackson.databind.ser.std.NullSerializer; +import com.hnac.hzims.operational.duty.entity.ImsDutyLogEntity; import com.hnac.hzims.operational.duty.entity.ImsDutyRecEntity; import io.swagger.annotations.ApiModelProperty; import io.swagger.annotations.ApiOperation; @@ -42,4 +43,7 @@ public class ImsDutyRecVO extends ImsDutyRecEntity { @ApiModelProperty(value = "站点名称") private String stationName; + + @ApiModelProperty(value = "值班日志") + private ImsDutyLogEntity imsDutyLogEntity; } diff --git a/hzims-service-api/ticket-api/src/main/java/com/hnac/hzims/ticket/workTicket/entity/WorkTicketInfoEntity.java b/hzims-service-api/ticket-api/src/main/java/com/hnac/hzims/ticket/workTicket/entity/WorkTicketInfoEntity.java index 5fda1e0..785d20c 100644 --- a/hzims-service-api/ticket-api/src/main/java/com/hnac/hzims/ticket/workTicket/entity/WorkTicketInfoEntity.java +++ b/hzims-service-api/ticket-api/src/main/java/com/hnac/hzims/ticket/workTicket/entity/WorkTicketInfoEntity.java @@ -499,5 +499,7 @@ public class WorkTicketInfoEntity extends TenantEntity implements Serializable { @ApiModelProperty("是否线下 ： 1-线下，0-线上") private Boolean isOffline; + @ApiModelProperty + private Integer implementStatus; } diff --git a/hzims-service-api/ticket-api/src/main/java/com/hnac/hzims/ticket/workTicket/feign/ITicketInfoClient.java b/hzims-service-api/ticket-api/src/main/java/com/hnac/hzims/ticket/workTicket/feign/ITicketInfoClient.java index 96f07b1..ae992f7 100644 --- a/hzims-service-api/ticket-api/src/main/java/com/hnac/hzims/ticket/workTicket/feign/ITicketInfoClient.java +++ b/hzims-service-api/ticket-api/src/main/java/com/hnac/hzims/ticket/workTicket/feign/ITicketInfoClient.java @@ -33,6 +33,8 @@ public interface ITicketInfoClient { String GET_TICKET_PASS_BY_IDS = API_PREFIX + "/getTicketPassByIds"; String GET_WORK_TICKET_TRANSFER = API_PREFIX + "/getWorkTicketTransfer"; String GET_WORK_TICKET_STATISTIC = API_PREFIX + "/getWorkTicketStatistic"; + String GET_WORK_TICKET_INFO = API_PREFIX + "/getWorkTicketInfo"; + String GET_OPERATE_TICKET_INFO = API_PREFIX + "/getOperateTicketInfo"; String GET_OPERATE_TICKET_STATISTIC = API_PREFIX + "/getOperateTicketStatistic"; String GET_OPERATE_WORK_STATISTIC = API_PREFIX + "/getOperateWorkStatistic"; String GET_WORK_TICKET_CHECK = API_PREFIX + "/getWorkTicketCheck"; @@ -90,6 +92,24 @@ public interface ITicketInfoClient { @PostMapping(GET_WORK_TICKET_STATISTIC) R getWorkTicketStatistic(@RequestBody Map params); + + /** + * 根据时间，和机构获取对应工作票 + * @param params startDate endDate deptList + * @return + */ + @PostMapping(GET_WORK_TICKET_INFO) + R> getWorkTicketInfo(@RequestBody Map params); + + + /** + * 根据时间，和机构获取对应操作票 + * @param params startDate endDate deptList + * @return + */ + @PostMapping(GET_OPERATE_TICKET_INFO) + R> getOperateTicketInfo(@RequestBody Map params); + /** * 获取首页操作票统计结果 * @return diff --git a/hzims-service-api/ticket-api/src/main/java/com/hnac/hzims/ticket/workTicket/feign/TicketInfoClientFallback.java b/hzims-service-api/ticket-api/src/main/java/com/hnac/hzims/ticket/workTicket/feign/TicketInfoClientFallback.java index aa58b72..bc833cf 100644 --- a/hzims-service-api/ticket-api/src/main/java/com/hnac/hzims/ticket/workTicket/feign/TicketInfoClientFallback.java +++ b/hzims-service-api/ticket-api/src/main/java/com/hnac/hzims/ticket/workTicket/feign/TicketInfoClientFallback.java @@ -51,6 +51,16 @@ public class TicketInfoClientFallback implements ITicketInfoClient { } @Override + public R> getWorkTicketInfo(Map params) { + return R.fail("查询失败！"); + } + + @Override + public R> getOperateTicketInfo(Map params) { + return R.fail("查询失败！"); + } + + @Override public R getOperateTicketStatistic(Map paramMap) { return null; } diff --git a/hzims-service/operational/pom.xml b/hzims-service/operational/pom.xml index fbb805c..7f60701 100644 --- a/hzims-service/operational/pom.xml +++ b/hzims-service/operational/pom.xml @@ -106,12 +106,12 @@ cn.afterturn easypoi-base - 3.2.0 + 4.4.0 cn.afterturn easypoi-annotation - 3.2.0 + 4.4.0 diff --git a/hzims-service/operational/src/main/java/com/hnac/hzims/operational/duty/controller/ImsDutyRecController.java b/hzims-service/operational/src/main/java/com/hnac/hzims/operational/duty/controller/ImsDutyRecController.java index 07d391a..166bad4 100644 --- a/hzims-service/operational/src/main/java/com/hnac/hzims/operational/duty/controller/ImsDutyRecController.java +++ b/hzims-service/operational/src/main/java/com/hnac/hzims/operational/duty/controller/ImsDutyRecController.java @@ -1,17 +1,17 @@ package com.hnac.hzims.operational.duty.controller; +import cn.afterturn.easypoi.word.WordExportUtil; import com.baomidou.mybatisplus.core.metadata.IPage; import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport; import com.hnac.hzims.common.logs.annotation.OperationAnnotation; import com.hnac.hzims.common.logs.enums.BusinessType; import com.hnac.hzims.common.logs.enums.OperatorType; +import com.hnac.hzims.common.logs.utils.StringUtils; import com.hnac.hzims.operational.duty.dto.ImsDutyRecDTO; -import com.hnac.hzims.operational.duty.entity.AnalyseExample; -import com.hnac.hzims.operational.duty.entity.ImsDutyEmergencyEntity; -import com.hnac.hzims.operational.duty.entity.ImsDutyMainEntity; -import com.hnac.hzims.operational.duty.entity.ImsDutyRecEntity; +import com.hnac.hzims.operational.duty.entity.*; import com.hnac.hzims.operational.duty.service.IImsAnalyseExampleService; import com.hnac.hzims.operational.duty.service.IImsDutyEmergencyService; +import com.hnac.hzims.operational.duty.service.IImsDutyLogService; import com.hnac.hzims.operational.duty.service.IImsDutyRecService; import com.hnac.hzims.operational.duty.vo.ImsDutyEmergencyVo; import com.hnac.hzims.operational.duty.vo.ImsDutyRecVO; @@ -21,7 +21,10 @@ import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiParam; import lombok.AllArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.apache.poi.xwpf.usermodel.XWPFDocument; import org.springblade.core.boot.ctrl.BladeController; +import org.springblade.core.log.exception.ServiceException; import org.springblade.core.mp.support.Condition; import org.springblade.core.mp.support.Query; import org.springblade.core.secure.utils.AuthUtil; @@ -32,8 +35,11 @@ import org.springblade.flow.core.entity.BladeFlow; import org.springframework.web.bind.annotation.*; import javax.annotation.Resource; +import javax.servlet.ServletOutputStream; import javax.servlet.http.HttpServletResponse; import javax.validation.Valid; +import java.net.URLEncoder; +import java.util.HashMap; /** @@ -45,13 +51,16 @@ import javax.validation.Valid; @AllArgsConstructor @RequestMapping("/imsDutyRec") @Api(value = "值班交接controller", tags = "值班交接相关操作（交接班管理）") +@Slf4j public class ImsDutyRecController extends BladeController { - - private final IImsDutyRecService imsDutyRecService; + @Resource + private IImsDutyRecService imsDutyRecService; @Resource private IImsDutyEmergencyService iImsDutyEmergencyService; @Resource private IImsAnalyseExampleService iImsAnalyseExampleService; + @Resource + private IImsDutyLogService imsDutyLogService; /** * 详情 @@ -147,7 +156,6 @@ public class ImsDutyRecController extends BladeController { if(null == deptId){ deptId = Long.valueOf(AuthUtil.getDeptId()); } - return imsDutyRecService.getTheManinGroupRec(deptId); } @@ -335,7 +343,76 @@ public class ImsDutyRecController extends BladeController { public R changeShift(@Valid @RequestBody ImsDutyRecDTO imsDutyRecDTO) { return R.status(imsDutyRecService.changeShift(imsDutyRecDTO)); } +// /** +// * 查询交接班值班日志 +// */ +// @GetMapping("/getDutyLog") +// @ApiOperationSupport(order = 1) +// @ApiOperation(value = "查询交接班值班日志", notes = "传入imsDutyRec") +// public R getDutyLog(ImsDutyLogEntity imsDutyLogEntity) { +// R res=imsDutyLogService.getDutyLog(imsDutyLogEntity); +// return res; +// } + /** + * 新增交接班值班日志 + */ + @GetMapping("/saveDutyLog") + @ApiOperationSupport(order = 1) + @ApiOperation(value = "新增交接班值班日志", notes = "传入imsDutyRec") + public R saveDutyLog(@RequestBody ImsDutyLogEntity imsDutyLogEntity) { + boolean b = imsDutyLogService.saveOrUpdate(imsDutyLogEntity); + if (b){ + return R.success("保存成功"); + }else { + return R.fail("保存失败"); + } + } + /** + * 查询值班日志列表-分页 + */ + @GetMapping("/queryDutyLogList") + @ApiOperationSupport(order = 1) + @ApiOperation(value = "查询值班日志列表-分页", notes = "传入imsDutyRec") + public R> queryDutyLogList(ImsDutyLogEntity imsDutyLogEntity, Query query) { + IPage page = imsDutyLogService.page(Condition.getPage(query), Condition.getQueryWrapper(imsDutyLogEntity)); + return R.data(page); + } + /** + * 导出交接班值班日志 + */ + @GetMapping("/exportDutyLog") + @ApiOperationSupport(order = 1) + @ApiOperation(value = "导出交接班值班日志", notes = "传入imsDutyRec") + public void exportDutyLog(HttpServletResponse response, @ApiParam(value = "當前排班Id", required = true) String dutyId){ + HashMap map = new HashMap<>(); + imsDutyLogService.exportDutyLog(dutyId,map); + String dutyTime =""; + if (StringUtils.isNotBlank(map.get("dutyTime").toString())) { + dutyTime = map.get("dutyTime").toString(); + } + // 下载导出 + String filename = dutyTime+"值班日志"; + // 设置头信息 + response.setCharacterEncoding("UTF-8"); + response.setContentType("application/vnd.ms-excel"); + ServletOutputStream outputStream = null; + try { + //设置xlsx格式 + response.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(filename + ".docx", "UTF-8")); + //创建一个输出流 + outputStream = response.getOutputStream(); + XWPFDocument xwpfDocument = WordExportUtil.exportWord07("template/dutyLogTemplate.docx", map); + //写入数据 + xwpfDocument.write(outputStream); + // 关闭 + outputStream.close(); + xwpfDocument.close(); + } catch (Exception e) { + e.printStackTrace(); + log.error("转换对象失败！"); + } + } } diff --git a/hzims-service/operational/src/main/java/com/hnac/hzims/operational/duty/mapper/ImsDutyLogMapper.java b/hzims-service/operational/src/main/java/com/hnac/hzims/operational/duty/mapper/ImsDutyLogMapper.java new file mode 100644 index 0000000..2fb9f65 --- /dev/null +++ b/hzims-service/operational/src/main/java/com/hnac/hzims/operational/duty/mapper/ImsDutyLogMapper.java @@ -0,0 +1,15 @@ +package com.hnac.hzims.operational.duty.mapper; + + +import com.hnac.hzims.operational.duty.entity.ImsDutyLogEntity; +import org.springblade.core.datascope.mapper.UserDataScopeBaseMapper; + +/** + * Mapper 接口 + * + * @author Chill + */ +public interface ImsDutyLogMapper extends UserDataScopeBaseMapper { + + +} diff --git a/hzims-service/operational/src/main/java/com/hnac/hzims/operational/duty/mapper/ImsDutyLogMapper.xml b/hzims-service/operational/src/main/java/com/hnac/hzims/operational/duty/mapper/ImsDutyLogMapper.xml new file mode 100644 index 0000000..013468b --- /dev/null +++ b/hzims-service/operational/src/main/java/com/hnac/hzims/operational/duty/mapper/ImsDutyLogMapper.xml @@ -0,0 +1,4 @@ + + + + diff --git a/hzims-service/operational/src/main/java/com/hnac/hzims/operational/duty/service/IImsDutyLogService.java b/hzims-service/operational/src/main/java/com/hnac/hzims/operational/duty/service/IImsDutyLogService.java new file mode 100644 index 0000000..6213480 --- /dev/null +++ b/hzims-service/operational/src/main/java/com/hnac/hzims/operational/duty/service/IImsDutyLogService.java @@ -0,0 +1,16 @@ +package com.hnac.hzims.operational.duty.service; + +import com.hnac.hzims.operational.duty.entity.ImsDutyLogEntity; +import org.springblade.core.mp.base.BaseService; +import java.util.HashMap; + +/** + * 服务类 + * + * @author Chill + */ +public interface IImsDutyLogService extends BaseService { + + void exportDutyLog(String dutyId, HashMap map); + +} diff --git a/hzims-service/operational/src/main/java/com/hnac/hzims/operational/duty/service/IImsDutyRecService.java b/hzims-service/operational/src/main/java/com/hnac/hzims/operational/duty/service/IImsDutyRecService.java index 35c4d6e..67e1e50 100644 --- a/hzims-service/operational/src/main/java/com/hnac/hzims/operational/duty/service/IImsDutyRecService.java +++ b/hzims-service/operational/src/main/java/com/hnac/hzims/operational/duty/service/IImsDutyRecService.java @@ -5,6 +5,7 @@ import com.hnac.hzims.operational.duty.dto.ChangeShiftsReqDTO; import com.hnac.hzims.operational.duty.dto.ChangeShiftsRspDTO; import com.hnac.hzims.operational.duty.dto.ImsDutyRecDTO; import com.hnac.hzims.operational.duty.entity.ImsDutyClassEntity; +import com.hnac.hzims.operational.duty.entity.ImsDutyLogEntity; import com.hnac.hzims.operational.duty.entity.ImsDutyMainEntity; import com.hnac.hzims.operational.duty.entity.ImsDutyRecEntity; import com.hnac.hzims.operational.duty.vo.ImsDutyRecVO; @@ -135,4 +136,6 @@ public interface IImsDutyRecService extends BaseService { * @return */ Boolean dealDutyRecFlow(ImsDutyRecDTO recDTO); + + R getDutyLog(ImsDutyLogEntity imsDutyLogEntity); } diff --git a/hzims-service/operational/src/main/java/com/hnac/hzims/operational/duty/service/impl/ImsDutyLogServiceImpl.java b/hzims-service/operational/src/main/java/com/hnac/hzims/operational/duty/service/impl/ImsDutyLogServiceImpl.java new file mode 100644 index 0000000..f6ace80 --- /dev/null +++ b/hzims-service/operational/src/main/java/com/hnac/hzims/operational/duty/service/impl/ImsDutyLogServiceImpl.java @@ -0,0 +1,179 @@ +package com.hnac.hzims.operational.duty.service.impl; + +import cn.afterturn.easypoi.entity.ImageEntity; +import com.alibaba.fastjson.JSONObject; +import com.alibaba.fastjson.TypeReference; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.toolkit.StringUtils; +import com.hnac.hzims.operational.OperationalConstants; +import com.hnac.hzims.operational.duty.entity.*; +import com.hnac.hzims.operational.duty.mapper.ImsDutyLogMapper; +import com.hnac.hzims.operational.duty.service.*; +import lombok.extern.slf4j.Slf4j; +import org.apache.commons.io.IOUtils; +import org.springblade.core.log.exception.ServiceException; +import org.springblade.core.mp.base.BaseServiceImpl; +import org.springblade.core.tool.utils.Func; +import org.springframework.stereotype.Service; +import java.io.*; +import java.net.HttpURLConnection; +import java.net.URL; +import java.util.*; + + +/** + * 服务实现类 + * + * @author Chill + */ +@Slf4j +@Service +public class ImsDutyLogServiceImpl extends BaseServiceImpl implements IImsDutyLogService { + + @Override + public void exportDutyLog(String dutyId, HashMap map) { + ImsDutyLogEntity res = this.baseMapper.selectOne(new LambdaQueryWrapper() {{ + eq(ImsDutyLogEntity::getDutyId, dutyId) + .last(" limit 1");}}); +// ImsDutyLogEntity res=new ImsDutyLogEntity(); + if (Func.isNotEmpty(res)){ + map.put("time",res.getTime()); + map.put("dutyTime",res.getDutyTime()); + map.put("classType",res.getClassType()); + + String dutyStatus = res.getDutyStatus(); + if (StringUtils.isNotBlank(dutyStatus)){ + List> dutyStatusList = JSONObject.parseObject(dutyStatus, + new TypeReference< List>>() { + }); + + for (HashMap stringStringHashMap : dutyStatusList) { + for (OperationalConstants.DutyLogLevel value : OperationalConstants.DutyLogLevel.values()) { + if (value.getVal().equals(stringStringHashMap.get("level"))){ + stringStringHashMap.replace("level",value.getName()); + } + } + } + + map.put("dutyStatus",dutyStatusList); + }else { + ArrayList> dutyStatusList = new ArrayList<>(); + HashMap temp = new HashMap<>(); + temp.put("name", ""); + temp.put("status",""); + temp.put("level", ""); + dutyStatusList.add(temp); + map.put("dutyStatus",dutyStatusList); + } + + + map.put("operationFinish",res.getOperationFinish()); + map.put("operationUnFinish",res.getOperationUnFinish()); + map.put("operationCancel",res.getOperationCancel()); + map.put("workDoing",res.getWorkDoing()); + map.put("workUnFinish",res.getWorkUnFinish()); + map.put("workFinish",res.getWorkFinish()); + map.put("workCancel",res.getWorkCancel()); + + String notice = res.getNotice(); + if (StringUtils.isNotBlank(notice)){ + List> noticeItemList = JSONObject.parseObject(notice, + new TypeReference< List>>() { + }); + for (HashMap stringStringHashMap : noticeItemList) { + for (OperationalConstants.DutyLogLevel value : OperationalConstants.DutyLogLevel.values()) { + if (value.getVal().equals(stringStringHashMap.get("level"))){ + stringStringHashMap.replace("level",value.getName()); + } + } + } + map.put("notice",noticeItemList); + }else { + ArrayList> noticeItemList = new ArrayList<>(2); + HashMap temp = new HashMap<>(); + temp.put("item", ""); + temp.put("level",""); + noticeItemList.add(temp); + map.put("notice",noticeItemList); + } + map.put("handMaster",res.getHandMaster()); + map.put("handNumber",res.getHandNumber()); + map.put("handTime",res.getHandTime()); + map.put("carryMaster",res.getCarryMaster()); + map.put("carryNumber",res.getCarryNumber()); + map.put("carryTime",res.getCarryTime()); + map.put("carryMaster",res.getCarryMaster()); + List imageEntityList = new ArrayList<>(); + if (StringUtils.isNotBlank(res.getDutyPic())) { + String[] dutyPicSplit = res.getDutyPic().split(","); + for (String string : dutyPicSplit) { + ImageEntity imageEntity = new ImageEntity(imgToByte("/template/img" + downloadFileByUrl(string, "/template/img")), 225, 163); + imageEntity.setUrl(string); + imageEntityList.add(imageEntity); + } + map.put("dutyPic",imageEntityList); + } + } + + } + + + private byte[] imgToByte(String tempImgPath) { + File file = new File(tempImgPath); + byte[] buffer = null; + try { + FileInputStream fis = new FileInputStream(file); + ByteArrayOutputStream bos = new ByteArrayOutputStream(1000); + byte[] b = new byte[1000]; + int n; + while ((n = fis.read(b)) != -1) { + bos.write(b, 0, n); + } + fis.close(); + bos.close(); + buffer = bos.toByteArray(); + } catch (IOException e) { + log.error(e.getMessage()); + } + //删除临时文件 + file.delete(); + return buffer; + } + + private String downloadFileByUrl(String fileUrl, String downloadFileDir){ + URL url = null; + String fileName = null; + try { + url = new URL(fileUrl); + HttpURLConnection connection = (HttpURLConnection)url.openConnection(); + connection.setConnectTimeout(5000); + connection.setReadTimeout(5000); + connection.connect(); + + int responseCode = connection.getResponseCode(); + if (responseCode == 200) { + + InputStream inputStream = connection.getInputStream(); + + int lastSlashIndex = fileUrl.lastIndexOf("/"); + if (lastSlashIndex > 0){ + fileName = fileUrl.substring(lastSlashIndex+1); + String filePath = downloadFileDir + fileName; + File file = new File(filePath); + if (file.exists()){ + file.delete(); + } + OutputStream outputStream = new FileOutputStream(file); + // 将文件流拷贝到本地处理 + IOUtils.copy(inputStream, outputStream); + }else { + throw new ServiceException("下载文件路径异常:" + downloadFileDir); + } + } + } catch (Exception e) { + throw new ServiceException("文件图片下载失败！"); + } + return fileName; + } + +} diff --git a/hzims-service/operational/src/main/java/com/hnac/hzims/operational/duty/service/impl/ImsDutyRecServiceImpl.java b/hzims-service/operational/src/main/java/com/hnac/hzims/operational/duty/service/impl/ImsDutyRecServiceImpl.java index 38179d0..83fbfed 100644 --- a/hzims-service/operational/src/main/java/com/hnac/hzims/operational/duty/service/impl/ImsDutyRecServiceImpl.java +++ b/hzims-service/operational/src/main/java/com/hnac/hzims/operational/duty/service/impl/ImsDutyRecServiceImpl.java @@ -34,6 +34,10 @@ import com.hnac.hzims.operational.duty.vo.ImsRecVo; import com.hnac.hzims.operational.duty.vo.ImsSchedulingVo; import com.hnac.hzims.operational.duty.wrapper.ImsDutyRecWrapper; import com.hnac.hzims.operational.station.service.IStationService; +import com.hnac.hzims.ticket.allTicket.dto.TicketStatisticDTO; +import com.hnac.hzims.ticket.standardTicket.entity.StandardTicketInfoEntity; +import com.hnac.hzims.ticket.workTicket.entity.WorkTicketInfoEntity; +import com.hnac.hzims.ticket.workTicket.feign.ITicketInfoClient; import com.hnac.hzinfo.inspect.plan.PlanContants; import com.hnac.hzinfo.inspect.plan.feign.IInspectPlanClient; import com.hnac.hzinfo.inspect.plan.vo.PlanVO; @@ -49,6 +53,7 @@ import org.springblade.flow.core.entity.BladeFlow; import org.springblade.flow.core.feign.IFlowClient; import org.springblade.flow.core.utils.TaskUtil; import org.springblade.system.feign.ISysClient; +import org.springblade.system.user.cache.UserCache; import org.springblade.system.user.entity.User; import org.springblade.system.user.feign.IUserClient; import org.springframework.beans.factory.annotation.Autowired; @@ -57,6 +62,7 @@ import org.springframework.transaction.annotation.Transactional; import org.springframework.util.Assert; import org.springframework.util.ObjectUtils; +import javax.annotation.Resource; import java.math.BigDecimal; import java.sql.Time; import java.text.SimpleDateFormat; @@ -65,6 +71,8 @@ import java.time.format.DateTimeFormatter; import java.util.*; import java.util.stream.Collectors; +import static org.springblade.core.tool.utils.DateUtil.PATTERN_DATETIME; + /** * 服务实现类 @@ -74,12 +82,15 @@ import java.util.stream.Collectors; @Slf4j @Service public class ImsDutyRecServiceImpl extends BaseServiceImpl implements IImsDutyRecService { - + @Resource + private ITicketInfoClient ticketInfoClient; @Autowired private ImsDutyMainMapper imsDutyMainMapper; @Autowired private IImsDutyMainService imsDutyMainService; @Autowired + private IImsDutyLogService imsDutyLogService; + @Autowired private IImsDutyClassService imsDutyClassService; @Autowired private IImsDutyGroupService imsDutyGroupService; @@ -228,7 +239,11 @@ public class ImsDutyRecServiceImpl extends BaseServiceImpl() {{ + eq(ImsDutyLogEntity::getDutyId, dutyId); + }}); + imsDutyRecVO.setImsDutyLogEntity(dutyLogEntity); } imsDutyRecVOIPage.setRecords(records); return imsDutyRecVOIPage; @@ -505,7 +524,13 @@ public class ImsDutyRecServiceImpl extends BaseServiceImpl dutyLog = this.getDutyLog(imsDutyLogEntity); + if(dutyLog.isSuccess()&&ObjectUtil.isNotEmpty(dutyLog.getData())){ + ImsDutyLogEntity data = dutyLog.getData(); + vo.setImsDutyLogEntity(data); + } ImsDutyRecEntity dutyRecEntity = this.baseMapper.selectOne(new LambdaQueryWrapper() {{ eq(ImsDutyRecEntity::getDutyId, entity.getPreDutyId()); }}); @@ -824,12 +849,17 @@ public class ImsDutyRecServiceImpl extends BaseServiceImpl() {{ + eq(ImsDutyClassEntity::getId, mainEntityById.getClassId()); + last("limit 1"); + }}); + String dutyTime = DateUtil.format(mainEntityById.getDutyDate(), DateUtil.PATTERN_DATE) + " " +DateUtil.format(classEntity.getStartTime(), DateUtil.PATTERN_TIME); + Date dutyDate = DateUtil.parse(dutyTime, PATTERN_DATETIME); if (dutyDate.getTime() > parse.getTime()) { - return R.fail("值班时间不能大于当前时间"); + return R.fail("指定的值班开始时间不能晚于当前时间"); } - ImsDutyMainEntity mainEntityById = imsDutyMainService.getById(id); //获取当前值班 ImsDutyMainEntity mainEntity = imsDutyMainService.getOne(new LambdaQueryWrapper() {{ @@ -998,7 +1028,7 @@ public class ImsDutyRecServiceImpl extends BaseServiceImpl() {{ @@ -1019,7 +1049,7 @@ public class ImsDutyRecServiceImpl extends BaseServiceImpl parse.getTime()) { bool = true; strDate = calculateDutyDate(parse); @@ -1051,7 +1081,7 @@ public class ImsDutyRecServiceImpl extends BaseServiceImpl parse.getTime()) { strDate = calculateDutyDate(parse); } @@ -1085,7 +1115,7 @@ public class ImsDutyRecServiceImpl extends BaseServiceImpllambdaUpdate() + .set(ImsDutyLogEntity::getCarryTime, DateUtil.format(new Date(), PATTERN_DATETIME)) + .eq(ImsDutyLogEntity::getDutyId,imsDutyLogEntity.getDutyId()) + ); + log.info("更新值班日志"); } ImsDutyRecEntity dutyRec = BeanUtil.copy(recDTO, ImsDutyRecEntity.class); // 更新交班值班 @@ -1464,4 +1499,138 @@ public class ImsDutyRecServiceImpl extends BaseServiceImpl getDutyLog(ImsDutyLogEntity imsDutyLogEntity) { + String deptId = AuthUtil.getUser().getDeptId(); + if (com.baomidou.mybatisplus.core.toolkit.ObjectUtils.isNotEmpty(imsDutyLogEntity)&& com.baomidou.mybatisplus.core.toolkit.ObjectUtils.isNotEmpty(imsDutyLogEntity.getDutyId())) { + ImsDutyLogEntity res = imsDutyLogService.getOne(new LambdaQueryWrapper() {{ + eq(ImsDutyLogEntity::getDutyId, imsDutyLogEntity.getDutyId()) + .last(" limit 1");}}); + if (Func.isNotEmpty(res)){ + return R.data(res); + } + } + ImsDutyMainEntity mainEntity = imsDutyMainMapper.selectOne(new LambdaQueryWrapper() {{ + eq(ImsDutyMainEntity::getId, imsDutyLogEntity.getDutyId()) + .last(" limit 1"); + }}); + if (cn.hutool.core.util.ObjectUtil.isEmpty(mainEntity)) { + return R.success("您当前未值班"); + } + Long mainId = mainEntity.getId(); + ImsDutyMainEntity carryEntity = imsDutyMainMapper.selectOne(new LambdaQueryWrapper() {{ + eq(ImsDutyMainEntity::getPreDutyId, mainId) + .last(" limit 1"); + }}); + if (cn.hutool.core.util.ObjectUtil.isEmpty(carryEntity)) { + return R.success("没有接班计划，请到排班计划进行排班"); + } + + ImsDutyLogEntity dutyLogEntity=new ImsDutyLogEntity(); + dutyLogEntity.setDutyId(mainId); + //值班-交接班基本信息 + dutyLogEntity.setTime(DateUtil.format(new Date(), "yyyy-MM-dd")); + ImsDutyClassEntity classEntity = imsDutyClassService.getById(mainEntity.getClassId()); + dutyLogEntity.setClassType(classEntity.getClassName()); + String startTime = DateUtil.format(mainEntity.getDutyDate(), "yyyy-MM-dd") + " " +DateUtil.format(classEntity.getStartTime(), "HH:mm:ss"); + String endTime = DateUtil.format(carryEntity.getDutyDate(), "yyyy-MM-dd")+ " " + DateUtil.format(classEntity.getEndTime(), "HH:mm:ss"); + String dutyTime = startTime + "至" +endTime; + dutyLogEntity.setDutyTime(dutyTime); + ImsDutyRecEntity rec = this.getOne(Wrappers.lambdaQuery() + .eq(ImsDutyRecEntity::getDutyId, mainId) + .last("limit 1;")); + dutyLogEntity.setHandMaster(getManagerName(mainEntity)); + dutyLogEntity.setHandNumber(getManagerNumber(mainEntity)); + dutyLogEntity.setCarryMaster(getManagerName(carryEntity)); + dutyLogEntity.setCarryNumber(getManagerNumber(carryEntity)); + if (ObjectUtil.isNotEmpty(rec)) { + dutyLogEntity.setHandTime(DateUtil.format(rec.getExecTime(), "yyyy-MM-dd HH:mm:ss")); + dutyLogEntity.setCarryTime(DateUtil.format(rec.getAcceptTime(), "yyyy-MM-dd HH:mm:ss")); + } + //工作票 + Map paramMap = new HashMap<>(); + paramMap.put("startDate", startTime); + paramMap.put("endDate", endTime); + paramMap.put("deptList", deptId); + R> workTicketInfo = ticketInfoClient.getWorkTicketInfo(paramMap); + if(workTicketInfo.isSuccess()&& cn.hutool.core.util.ObjectUtil.isNotEmpty(workTicketInfo.getData())){ + List ticketInfoData = workTicketInfo.getData(); + // 工作票终结数量 + Integer ticketInfoCompleteNum = ticketInfoData.stream().filter(item -> "结束".equals(item.getFlowTaskName())) + .collect(Collectors.toList()).size(); + dutyLogEntity.setWorkFinish(ticketInfoCompleteNum.toString()); + //工作票作废 + List invalidList = ticketInfoData.stream().filter(item -> "废票".equals(item.getFlowTaskName())) + .collect(Collectors.toList()); + dutyLogEntity.setWorkCancel(String.valueOf(invalidList.size())); + Integer i=0; + //工作票未执行数量 + List unExecutedList = ticketInfoData.stream() + .filter(item -> i.equals(item.getImplementStatus())) + .collect(Collectors.toList()); + dutyLogEntity.setWorkUnFinish(String.valueOf(unExecutedList.size())); + // 工作票执行数量 + Integer ticketInfoStartNum = ticketInfoData.size() - ticketInfoCompleteNum-ticketInfoCompleteNum-invalidList.size()-unExecutedList.size(); + dutyLogEntity.setWorkDoing(ticketInfoStartNum.toString()); + } + R> operateTicketInfo = ticketInfoClient.getOperateTicketInfo(paramMap); + if(operateTicketInfo.isSuccess()&& cn.hutool.core.util.ObjectUtil.isNotEmpty(operateTicketInfo.getData())){ + List operateTicketInfoData = operateTicketInfo.getData(); + Integer finishSize = operateTicketInfoData.stream().filter(item -> "结束".equals(item.getFlowTaskName())) + .collect(Collectors.toList()).size(); + dutyLogEntity.setOperationFinish(finishSize.toString()); + Integer invalidSize= operateTicketInfoData.stream().filter(item -> "废票".equals(item.getFlowTaskName())) + .collect(Collectors.toList()).size(); + dutyLogEntity.setOperationCancel(invalidSize.toString()); + Integer doingNum = operateTicketInfoData.size() - finishSize - invalidSize; + dutyLogEntity.setOperationUnFinish(doingNum.toString()); + } + TicketStatisticDTO ticketStatisticDTO=new TicketStatisticDTO(); + ticketStatisticDTO.setStartDate(DateUtil.format(classEntity.getStartTime(),"yyyy-MM-dd HH:mm:ss")); + ticketStatisticDTO.setEndDate(DateUtil.format(classEntity.getEndTime(),"yyyy-MM-dd HH:mm:ss")); + ticketStatisticDTO.setDeptIds(deptId); + return R.data(dutyLogEntity); + } + + + private String getManagerName(ImsDutyMainEntity mainEntity) { + String managerName=""; + if (cn.hutool.core.util.ObjectUtil.isNotEmpty(mainEntity.getDutyGroupId())){ + Long dutyGroupId = mainEntity.getDutyGroupId(); + ImsDutyGroupEntity groupEntity = imsDutyGroupService.getById(dutyGroupId); + User manager = UserCache.getUser(groupEntity.getManagerId()); + if (cn.hutool.core.util.ObjectUtil.isNotEmpty(manager)){ + managerName=manager.getName(); + } + }else { + ImsDutyMainPersonEntity dutyMainPerson = imsDutyMainPersonService.getOne(new LambdaQueryWrapper() {{ + eq(ImsDutyMainPersonEntity::getDutyMainId, mainEntity.getId()) + .last(" limit 1"); + }}); + User manager = UserCache.getUser(dutyMainPerson.getDutyChargePerson()); + if (cn.hutool.core.util.ObjectUtil.isNotEmpty(manager)){ + managerName=manager.getName(); + } + } + return managerName; + } + + private String getManagerNumber(ImsDutyMainEntity mainEntity) { + String handNumber=""; + String[] split = mainEntity.getDutyPersonIds().split("\\^"); + if (null != split && split.length > 0) { + for (int j = 0; j < split.length; j++) { + User user = UserCache.getUser(Long.valueOf(split[j])); + if (org.springblade.core.tool.utils.ObjectUtil.isNotEmpty(user)) { + if (j == split.length - 1) { + handNumber= handNumber + user.getName(); + } else { + handNumber= handNumber + user.getName()+ "、"; + } + } + } + } + return handNumber; + } } diff --git a/hzims-service/operational/src/main/resources/template/dutyLogTemplate.docx b/hzims-service/operational/src/main/resources/template/dutyLogTemplate.docx new file mode 100644 index 0000000000000000000000000000000000000000..24dea455ef6e421e3082931abe82a8b72ab3da0b GIT binary patch literal 14351 zcma)j19WH0vUi+`ZEIrNwvCBx+Y`;iwr$%^Cbn&RVttu&?!D)ndH22b^;-GwUcKwr zRb91rrFV6eoFp&^B*3rsO=g?#*Y)2G;-h0|V<2a5W9vXG_d$mIG4SaRGVw3^KQ#dX z0PKJO0O0>lre|wQ<7#D@9zAC5PX`}x5&s1HopUiNvmly4LfoNbSuAQFUELV4RQF2* z5{ZqDVo89u$4YX&XePIz(~-sn^s+5EA}?h1#aG>$-5i-0uWA_74ihRA603aQzD~a@ z)uSEYC9`6_FR%j+2tCB!2IU%rhHAh#%-LU{8jJJJi<}e|#8gmBs-jP4zgCeAxJGR1 z^T)}79itw?1&`Fe+L)57Pnht8mfClblV>SX*GF~SvstN0tROf#3`NZAPJhqR!v`;x zjMeuG`f3O>7pHzN+s>}A8xG|%lia%*!&J_!JQm5WkQbHE0D6(d>xD*aQWrS7Re)jz z1MkTC^pmz$HE{LkW#@C}{`a#kt60imuq@8KAEXxf8skMyUWMPZ&b?k7?ZdVwFW8%M;C5JhxC2f%rhh71&&E9bvSp4JWCBz$+=9(lGYwZ4g}=K z6;rv^99MK?$9Wdq#gHT^6ecGSwxBbO!@(t%>MxtMt&jv=-q+<4jrnX$Aq-`q99FFd z1wRWiPLR$DpZRhPUlVH@+XG~&Aku?ddC+EEUmZBRA<;4~&S z7{S}M#$?aS(j=LOO!P{0QGc%UWQ5+ z3MiyD9hSNK{vjT~e;NaK;=3IAhcOU7jDhqIV>mfD+F1QEM}G8#?j3p^@xlZluJU_Hec+hIKm*8UOIi*iw5Yq?o znd_y&mf@Zuu)?2+}ccTr{9St&^9L7vNu-{qKGW^h2{QHui?U`K0H#Y-n95003|+006ju zlQ=lKSsFR~QhdACn)6B%LdONW7dWnVJz4|FmjwMxG7m(~3Ws@_wfI^OnCPfL81X7% zqb0XM?K|!#Ft5}*ZVmwckOVO?Z2J@}QN%|t|L)OmctCy6nc6*FZu{aChD=W127wp0 zqDj3FxTV)@B3VT*G)c$Qc5C@WJdZoBXJ3zc@!l`Jy^@V90cCLjzE6)#rnZbwh0@B( zDA)`MCg6@FiC*pqd?py#G`My|tl530;JG$Luaz1V#;;k3o$1y+#YAU!QWbYJ!;cWy zB4LORm0GhWM}yk3yD4lUVh>>LywPwkjS@{Z<`Q=WVEI9&6~ab6DL{pZY^UzawE}sC z4c6~;BKTvT;c7?7ol81frU##u$B>XhFDMr$YuavbvnjUiffN$b8V~m8JB2eeI7?{w z%G?^L5#}k~{H(KfsEd9^6>+8UC*P1YJNJ4CMhxxRuz1&#+b36?!a;4r(TdsS%To~V z<<(t|Y?sG9@)(FzaQL*7tsk!d(MOUODYT0eKNN21-NZ&kZ^Yl5qvaDgP9ziD1*FzQ z5d`Rb_ACz2Fc@slpX?v$B~E;{sK$5-fXd!3I^V7`eclzd&hlIFN%7V*P2aX{`Xid^ zC_2qYOh3tdnp4j(@TF0eXK|7pjLMSZ>v&iRA1^Kb;(0}_0h#&UushWl_Z&5{--7|y zUw-LTalPVse>NgWXb7~#>O@O3n&>k9JpQT<)(5G~PA>L3L5mxyoB?pQ0VNY&yG%G6 zRMrQk?h~zYc#DPr1^8ZC!(*F$7)K>J9v8#jEBL*EdIE+TU#3+s&FLGu(>JyYSo(8V z`Xkt@3eG-ZYN5g|)aVHvOrQ$z%_q83z$P9x4}c1|C0ySV;O38^%kz(+!;c}^KwMu4 zMB-RnVRte$zg@X1km77z2t>hd#JoU15-~_n$tXm~1bhNyDt?Y#9D)NVCM@}RABVaq zhET(S^sr9&uG&vsw{#)j`J6gk1$NLNSKA(0(+4za8#$(K+hrn;cwDIYNYy81#fGAx zOb9YmAfWe8+&9zFU4M=Oqr-5F-hcItA=ttgMg6H0z+i^hu?aEy?edMCB3bYU;`i^I zQxs{6eeRFasUt}g-=9)m#Rl_-tc@LRr`0tf>_M`dfg^GF<-B#3O_Z)#`_nx`z zet6n!7XRz-#H({o{gh$niLAyq3(o;X>{d6&hdC*@@H_u|#kz5r!8L>yBj^QJRRA{$ zl{Uw*IN$r7Pt05CjTpl*MfOloxW-IH7cHU2oGRY|uCHQO?2&*tUp_PmU_474$nEiD zG3>dXWdX-!;~0^pR17oMMRNH*MmWHjTGenN{?mk>D}y-vYwFK-1PDis;(hO9H?rxo z(iA;~uR_y^mc#s$;_JRhMSWmgl?IR-7q)V7M7}1yW8vzN9Cpu`Hz3B;9ru}|tPG!a zQ=Xkea7P$M5SJzykE8b-&}r2vrr&U!t>#DA?y1i4UI~2b@yF=rimjeKL7=382G;{m z`*aJ=-hX0czBl`9tn#dHu;b|&le)tcPZk@S)Ss#P!ZV z&F6>Y&T$fdC#Cj@7K;b)B&xYmKL#0LdILQv`motMUcZM*y@ELX8V#hEVZ>})-`OX; z+@ZOCsc{1$N7CYAE^;x|n~i2sI<>h1f9;atd{>Tlu*@v9`;Q;sxE&o(XcfH}Djioz zzWwYRkX;%=bObE4A->O{%6w?~s-VDH)X30|bNK$s==pgv(;#s?(;q}RVM9cxOCr_3zkb?cQ$j6b1jDNjPoYwsPpE3|l%yA;BzfTmNe z*Pj_)RZI$Z!7gWZao&Tqg zK3y?PYAq%nlYucaX2zD)vTF&nM?iY+Z7idQ0q+L-g6?CwtA_Eo<ev(H$aTYyA~!cbMk^98Y&?%jPdK_l_~&f~ox_ zLturgNbG_)_=zpgeTXtIHHZDnDNKv2=7eSPX3B^{%Q@^(amsMiE#qs-%d}qSMf6+k zamwnof?-kDDulpGZB%pojhZN@y4_c!59##ICG-^o71qN9T=r_r1c&DQKS^6&%OT!o z3zqj|tw2;M&s4Y?s9U1cQLd|@emP?bW=()1T34%>-wr1+r(Rdf`Fn@hoOE3cF_j{Y zqmg7?jV6^PPE+}60C8zIo46!|HRkX#I5cNXFro@Jt^06TzcfqhY9OIsg;RPve6Qy_ zYeH$gt3j|vC~HE|-#SFW%O5;JK6w6`FGT~zhALVbS0bmx_2W(`>ovKR-g4;^%W$URa3lV70n!Ot-ETTBtf z$DOyd1zAb!csVnxPW zPqD5>n93C=qsX1 zuNW^~i{>oMi_7LNNh8f;_FGxY7cdTp8fyU)$|^D+ujp;(>z;$T zxi*ab3TpIDK2(tv9VM0fe9TVj_Ds*F66K*#`3uZ7U%ss)QcNj+ao9Q!;^12N2BvfZ z@2pfhT;a7eEt77Inuw#(Kelh|PHSCTY{FTPg7fMgZJ`ZucJ|db6WndF%csH>ew7hN zC^@VfmF-fHw|Jtq$48G{whK-D?Zh@~&h^CQlQbJi?&F(KrS;sU6ToI(3H_s}kzwuq zIEb{rVVYnaliY2kX*rLdg^lp+TgVQnAdJS~d`N3Kk(21mQ6j*) zQ^_bN;mt8em=E7*EFtW?3j%+c8t;)j7lDsoG z-rosLa(imR)Ityum%mS-2yJPd)SVpzdP3moq*ki5D!y6q>0irW1niZ64}%Q}#6TR8M6Ueopj$!29QykbpZZ{T2uS zK+DI5{MTpcANzF&BS%LwYm+~=&yA}$d~9V-@XF_mL)k#$iU3<#-Z=t;C$eR`kryIm!b zgR4=M0~Esq#8q1Bi7Mfv!JR4E_0bmhO{HLfiq9)X8sJ5Qpb1*^Z95q0VlkYTGQ21I zETOXdSk5qiAf?4V$TQ|NBDI!48V{(1Oy(GpWJhK27B)@xP-~@rp=+{&RFC1pN3AUO zh001TZ$@53cFwvJjCKT_*av4`Aq*aPPY+_BGR`4KIDq`IV>OV~r&2(Wq!XJyI!gH{ z8I2G7**%$n5T!tkKMS5>!9a~hjVcQtyIV`4G`~3tg6+pJ@|vtnyNeI|kVcL-`gCwXfIT z73Q+DZ_PC-v$t-F;!arW_@%L!>hz?0!7a~i?7onT^b=L=KA9d_3?+>cG#3RM9KaM) z2~>yC2#?l)z~i$GJt+i$Wll8ojO9M>`26qjiw~Fhr$2NwHL^1LEsC*Lk9iFV1_02C z4gi4iPr^UQ>3_vC&eX>ukyw#CRgd54QaDeEcMa5|g;OJqpjxX40sE$g*cgqucYZiK z50(2FrT@o(r;T6l9?{2t&(Y*MAuVEKC@rSkqj;Z!74C|)0h<4Qzr;eSfJ;d3i^>wQ?-{F zuoa4cQblzAuJdhW6eY-ZZb?QgX|MgXM!B}dY1|XD@369F<&wou%zPdgzFdSRGfO*1 zYZi-i=dbmA`%}5Cjq2s+9Ile@fhegirDy3y$D7PQ4lBzyQ*WIc_qUmUY@Sd)K*^Ju zFJQl78eWE@cvfnk%zD6T`zuIX=b|_wD`U00f2AQX5V>!=G_I^^ouS@@LaxfrOGwcl zwLc=!2s)?lfYLz;Ar!yn8~^MYCc?J@n`8Jxyh=7ksf2wJRb<|UkqMDf(7c5&j4k0Ah8qUNZPZy8cJKW{N|e)wA$u=+K!JHq2#4*$$Bu;txT6z9UM z%ufd9(hY0CxEI+(M=(J8+x1_SQ9#2WOV`GlkxVLf%qxCt+*s!ZLm)u+$;n! zUJX6V>Ksr#*xDMvX2*?BG!B9_vPlE6{M}WM0blT&G*mWs48OK94=}-oj3ul!xRr>P zw#!v@Xg~?yticO_B59cFq*Bgkp}jAIIk+d@(5#7}&wwaP1u3y1M|T`(J37=>Y;$+F z4&~88*4Kv_Z$6Xc(A^m9N5^xb0ZYR~94Cc1Y0pKTAw{g`U^bwToXse4ycgeQl$><} zI5M5o^A!-zBc4{QRljw!)H?j{PYin*n%do?TQ)u-gP%@RfW6j^7BPkWwaJx66~;^F`WW8&@+p!v=TPF2=Q(#^C6Y`;I?8q1b&)$G1E-(iY}! zR&0hsX`o>=tiZ;!zg)C2z7Kdvk)4fT^gjz+w1ZM{UC}^O5O@vu?U7r?^yE?)OrCEd zMo1(JA*UcBNG18!>NTmvKk*eVg^!j$tE5e9BUf&W3w(CGk>PQ zsH$W7bO!)Pr?89~>BP_U-j0g(qK8^U1M7ev4CkH5;eu5u`wMBkMq_VqPKsBvV_18ru1DAKk%O+pR>m4cAyE7E zrp%U*bw`C);&ge6-bjGTl=Au6Y}iPEChzVbjtaE4s>+opbDjA1UCC{NhRd>3Am>=) zhiczt6by@?6w8WFr-{?SMl@{aPD1XS`WYhzk%0ggf^2!4a(|M>m2%Z;J3V8&`L;y-|R-NGi&oEXb}skFPggtaA3^`Xc5AoTxob)>1TW$&tf% z?b~nMl(SHtvp?KiZ!ivhGhP$791@}4j6IGv!?r6w8N&E-N1fg{K6} z%F~6|c}bwKHhkjWI)GKKapXy=E9yqB8#;tN6W4#kr%^yHqBXM*3xu|M*;0^R|Ed-u zWKiKuZvEat4S+SQ6wjGh<5IrS?7PZfp=Zjq@n+U=_>O$~?8DLqu2leaU#>_Icm#l1 z_X_vVUH5R1FxK$Ld0gQqz`u6gA4hmjRz}v2fBfUnI&>@NigbQ>_%nTxHh%eGjI)(_kv z5I=yB{s=0qTnfGn=*0j6v5jI>M@SqPO&zY)ON9wS%B514@#+4l%ABpFEbZd(%JsGA zac9BZ!!u3Vh51p~N_>$iG%m_B!~Qsk@R>1LndvO1i#>h}S;{k4-08rt8Z@nOJIi~TPir`fEqD1S6S=}fymG+`#pm@hQOuTN@oNH;>+WNj*Bb3_Zu2aLD+Fdf4&UGOm#pT3;%QvhVg*Sxm)DlIm@!w936e zYlQOWQRbYV5(x>SZiu4FMAQ+LYST<8hX)jkP1MHR3v{c(V3pgm9PjabmNbugxWl_e zm>>Z+rL zueEZEfoWyWLk*Zo0{B^R#1}#~fUAIc0=(^P_2Rj2KA5%;ec5dBmP724)KXV{l%$U2 zhKG}v{Yft8zny(%)hx!c;6DEv&V4&~j;INUKL{7{q8I@_G1ATJb1Z!Ft(#v5&M~3_ zAV}n7L_&tlJOCELD?Fp}dQ{P$(n}l(+XQC2upFM313y*x`xGFA{L_;yl@Yr9O?&oB z=|!D0H^Q#i18IgXU=3~$FNDw*g<-rBp%D5DhJd+TVB34uV7w{AYBY3S6D_=I4pAqf z6(Ydd4rbbQD;B`(&a(&J%R&FRs0Zi8Ik(5%NxREkr|bLW)J}Wl2Is>KIIZ*fJ;1d3 zn*_I*=s2F+_&qk2KUyru%Vq6GhugvC(X0Q#28)TC(9ZV(3nXoik&o1kFcb*V97mWi zTkJI=317#ZH^oZ8Qi3q8;#KK|r(Ww^JrmJ{ zp3?uGa4k&&m&75rMjg<^8~OC0p$jjIF(d0ExcnX8GLlL#0TM(}**~8%wIw@H*u*YD zci48&q&EiJbZjammznq6`gvTcXX!dIU6^wU`Fl2VVLgLugd*=Xw}w7V-F{M)-8BSO z5)XGty~AV*ob=bc1ZSXfc3O9**n4+NHrYxeY+^8&vNdZ0`15@g2Bgx<;tzWTa9|9mZ267nyIbq#Z37_BRu%pfCfM7 z;JV(N>h|M-fCNLDi`Kd%hQcFix|$v(!%};TVdB%H*OVo!?em7FmgUuoap`t+ttP?N z>?zEK{N;=E?w1z8Wjj_n-_LAxyjmuPnVDqUMXAGZr(^G<3UW_v$z6P&lIMHQ8vJ0) z%%Re_S%?b*e-Z`ed6)w%rZ2z0)UIXX`I~!J-zHdXeh%mz)72M{CI=FO#Gy2mm z?a4qiwZjbZE}zCp5@TU=&2}eq?+vAWHi7bkQQUnKr4%#v%Zd4RL#0=6sE~5DhB*ME z`MSlW7KMg1nh+mNil&=BSFeW@D5yc~X;*i5pGANYDW(TZtkLc4mKO zCR-_uB{KzLOz2S7?1A}+Rg9t9l}0(G>F4s?kz{RRZFQ5omo~G(m!XmV`ux*982wR1 zyFGKIW;1JTm=o5)#_5z=XM?TbGfK31R3VbobV{uj*R%2fFCzBw6sLf&^3`FhbqZwV zK`MI+&^JDf>63&{pH0@<6KjfjVSdzEO&nk6zZR`>hLHF|8j1R5A2u$@3x|($#Y)z( z4%V@T5aiY${m_jqCQALr4a~h<2&bUFy7KrOnl5{f_YPcL3*O8L{FQm}vE=LWY0@(E z6yw_B9LB|C70eW4&cV(%$fw#}iyCv0pQjmutI3B%?&s$Ldj+K|LKEp4SV9v_+=cR9 zH3R!-_)Y+H%xnes89qzGc7xsF20sV+X7SDYX3|4UkXl1r-McR9h|yzmZg<0jmR)kF z`eL?hxlj{gCHk>&;KoLSrZ>Z70*ng;j~)|b4uxn))+3B^i&GO5mAs5j3O>_7sxZ9H z4}@POk1;jlYpQizh-$d9!QNw3lZlHd<>pY4hMk=UeQcX$z9p z?L0!Y2?{>tlB9m;>^Y>-b4&;(N=Y_I!3da2M}*gNWJH%vpY%<7S0M_67vI@~FoR!{ z=5C{Q<3Mxpi->FP{SFqn$0xMYDf^O!k2|~QbypWu9~7tZ+KuLjqQY`^tFFj=jm~1x zb~#vuQAsmr1x6&xo_iXIP&=MjD2>lsamh(aATmm~0d1RixHV{CU2zmiZcTXKG<#uR z9QkOByW)asVA#fXuQ6}l#IzXTnN8s}_eeNmzZi1VBmZgtCfb}ZlZ65={WVd~{3PaS) z2(U9I;#Td=E%qrDBf(;G%>DI6rXHBfa?Ct@`l7;TKa@YiD9a`kFf-e@vcf!dPZ#R& z#T+9yP73Kj38cUM_{xa&Oat__>%2A+F2l#e^vE>iH$MxAJX4 zlgOc6>b+$tLmR@5>#Ev*d*^84+03r3FgD^ypBJ#m?qSQM)9Yrud*-?8W^4%y5IiBG zoOzEFkZl^8F$`e6OPX-a67j2afq*;_vMl8IBsTfdm$k*SGgW(Lb62s(fHdEH1&+cI zGP_a31H&tO3K4-A=-8qdMEvwvlei{h=phBRM6H4j(5?m+ojPU+I>*>#Rt~P?ub z$nAwa$O?}7gvCOLTUBwXQ8U3QJ;-v%80IvEf-}*RQY}V$kOcJ6YHbY}8S82Y#$yZH z*CJcnPUJZ{+VJ7YSkVm0G@2Q6dnD|cvScI2DYbEN<-txv8H#9?(i0Mttk>7aLf$l; zDy}E9kcwfjvMdOjG(-Wpg0u|6pwQC%g9TZ}g%D1kuhgVU89~5j0T-wh z=h<$&^8j%43z>$(=6dnkfes#*Ym18w_#3YG6%@8`Q@a*C^dn*yM87rYWopW*8sSjH zy(JMQJ*(MC+)c}J@W78Pim=ZuN9xQq)%S^=Pc_w=v;Epez1&X?;g-_$8uBkwqC2{LF_(>?AnZlC0$VLq5}VL_HCdC)y3+oo>!5vQ z5a))Px2s0_M%J|i{aY1eY%<2W(@J{G=5%IVuve1g`-fg6!ssVxJ*)_zQ#cmJjQV95TBNg)WsA}iRZ0C z?1qS{4c>}n2mfc_gT}g)5DORpVErSuj`;7Wxv`D4qmrJ!B=Q4!}N8$P*%W zHAz_VgjVd3*!jj8j4quor>~IKJL2jrk|6`y`1}LAdelj6*^7BkU|SyS6xI7sJAN}w zIMD#C8*BKxy>@Ki$LZhbm@l?N_IEe~YrA;|c>oXadO57XOQ=mUNA7g;biHCRd6+Ox z7Ow6v;}MFGgTSh*G}NOq$jBj(kJEQ;c}K{rX3Xpik8pU%irBt-gw6w40>u6^ehdg* z3FlTaqH<-BpTIK=ZUWo`jc)irZitJHa=bIOK+9WK&*wLl&y_Ifo?X71x3A`nwHrO~ zw^k1ubcey_^A^zj*ege0=q#YKbbu>SfeojKUl5^nCxdSr;Cemab7=&WC3CEhEZ-Jl z__~M04j(H(;JV`tGMkdyJY%pGBv-%jnHAbn3pd>@*2$AOO#Z-mxsSkQ&mO#r9FemxTnJpcLzs**X%f} zOUMLe7{4~yfhU>nn{z!oC_+Yef5FSVO(6`HvAzDMV6a_=I1j8^G8!Jr!{nXxkL>(i zI#q%g+H@A;Z<@oiL*LyaafXz&Hh%n^0Zxf7T*L%5v#8)dm8rITTj8uLpL4|f*&Tfl zjACC#HlDIZF~V(i2-c9AF{8U}`u4;ze1AD@P}5_8Hbr{_jB@u)=) zUdM%J>iMF?vG|GiIz$WT=nmSJye-i#Zc>6E?PMG)7K@VK`xBE|d*-eMji==B0WGzH<`yP<_BpF~y zVvVfGf-Kj|wMfzg$@XmA3r;)VGrHY|Cl8=QD+xnD`iGvOy8~a0ova~|>0@b}81Mlz zBAyE}{MP4-AHd#>X?mR9FE_B;l> zO)gw+1iS9=0+<^Wk9oh3&|>BA3_iE$=|UrPL<45M>&;DCUM0d}OMoN*^}^Wpmj0Bm zl?FhiKx^X^u2=gRn4q>S>22S(NK>##MR;>*gdPWtKa{8Mr1rVQ=eN9i&mnPd{g1qQ z%+!xoxbrX=x(zn|YDS?=R{Po` znt)t~9E&SXACyd__oTGj5CxD?`>Yz7G3NoFVZbrD1rcDAQ5;n{zS=#= z5-xjUVumUwp5b|d?#IiDT;toNK6VA$14b8?vXvyAo=$<1l#T^0t!1a!0cH!n-JLVb zYH8=;hw~!rlJ?u8M>?6=Z?A$EoH(b!mbtPL`0&+S+Anx_*e$y=kaabectBR?;#^la zz%^cXwAR_-M^QEHGeH}2l7K+S0Dsj0{ce;Gy8r+J;D7ukF#J~&{W-yZ&*}f=Y5r`# z%87vJ{_RtKXZpM6`GxtD>F57o{&-LRFJ`|AoBnLSnEh&hD|7niB7ZM*`bGRFKhnR$ z{#Ew$yR^R-=lq4P{&<@I!}Q;!I={nzFDLm6&hxR?`3wG^;*$Ss(Z8xD{%pS%o%E5L z^{*O=Ukm>4M)~Em{%pS>QuP1uOuq~JyA%5b{8Lj-{{;RIm-hQizn^0LHB$%HzeM=^ z9KXYV-wXZ)Z>0Jc{2x2R-|@evuKk4<`%uIGNM!pR{(Bk9U+~s{>-?{xlt01$KiXIO uNCx?X_rH@y{`s8#o;LCq*RTHs{*^=`Ckgt;TL=G9!8iHwJdrc~0{uT2(G+k1 literal 0 HcmV?d00001 diff --git a/hzims-service/ticket/src/main/java/com/hnac/hzims/ticket/workTicket/feign/TicketInfoClient.java b/hzims-service/ticket/src/main/java/com/hnac/hzims/ticket/workTicket/feign/TicketInfoClient.java index bf60416..3c9d3f5 100644 --- a/hzims-service/ticket/src/main/java/com/hnac/hzims/ticket/workTicket/feign/TicketInfoClient.java +++ b/hzims-service/ticket/src/main/java/com/hnac/hzims/ticket/workTicket/feign/TicketInfoClient.java @@ -183,6 +183,40 @@ public class TicketInfoClient implements ITicketInfoClient { return R.data(workTicketStatisticVO); } + @Override + @PostMapping("/getWorkTicketInfo") + public R> getWorkTicketInfo(@RequestBody Map params) { + String startDate = (String) params.get("startDate"); + String endDate = (String) params.get("endDate"); + List deptList = (List) params.get("deptList"); + log.info("查询工作票"); + List infoList = infoService.list(new LambdaQueryWrapper() {{ + ge(WorkTicketInfoEntity::getPlanStartTime, startDate); + le(WorkTicketInfoEntity::getPlanStartTime, endDate); + in(WorkTicketInfoEntity::getCreateDept, deptList); + }}); + return R.data(infoList); + } + /** + * 获取首页操作票统计结果 + * + * @param params + * @return + */ + @Override + @PostMapping("/getOperateTicketInfo") + public R> getOperateTicketInfo(@RequestBody Map params) { + String startDate = (String) params.get("startDate"); + String endDate = (String) params.get("endDate"); + List deptList = (List) params.get("deptList"); + List standardTicketList = standardService.list(new LambdaQueryWrapper() {{ + ge(StandardTicketInfoEntity::getStartTime, startDate); + le(StandardTicketInfoEntity::getStartTime, endDate); + in(StandardTicketInfoEntity::getCreateDept, deptList); + }}); + return R.data(standardTicketList); + } + /** * 获取首页操作票统计结果 * From eff45e90df35d548526be269511ced798f81dd76 Mon Sep 17 00:00:00 2001 From: yang_shj <1069818635@QQ.com> Date: Wed, 17 Jan 2024 17:09:54 +0800 Subject: [PATCH 2/3] =?UTF-8?q?#=E4=B8=9A=E5=8A=A1=E9=A2=84=E8=AD=A6?= =?UTF-8?q?=E5=8A=9F=E8=83=BD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../hzims/business/entity/BusinessEarlyEntity.java | 39 ++++++++++++++++++++++ .../feign/BusinessEarlyClientFallback.java | 17 ++++++++++ .../hzims/business/feign/IBusinessEarlyClient.java | 25 ++++++++++++++ .../main/java/com/hnac/hzims/AlarmApplication.java | 33 ++++++++++++++++++ .../com/hnac/hzims/alarm/AlarmApplication.java | 32 ------------------ .../business/early/feign/BusinessEarlyClient.java | 33 ++++++++++++++++++ .../business/early/mapper/BusinessEarlyMapper.java | 11 ++++++ .../business/early/mapper/BusinessEarlyMapper.xml | 6 ++++ .../early/service/BusinessEarlyService.java | 11 ++++++ .../service/impl/BusinessEarlyServiceImpl.java | 19 +++++++++++ .../hnac/hzims/alarm/MiddleApplicationTests.java | 1 + 11 files changed, 195 insertions(+), 32 deletions(-) create mode 100644 hzims-service-api/alarm-api/src/main/java/com/hnac/hzims/business/entity/BusinessEarlyEntity.java create mode 100644 hzims-service-api/alarm-api/src/main/java/com/hnac/hzims/business/feign/BusinessEarlyClientFallback.java create mode 100644 hzims-service-api/alarm-api/src/main/java/com/hnac/hzims/business/feign/IBusinessEarlyClient.java create mode 100644 hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/AlarmApplication.java delete mode 100644 hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/alarm/AlarmApplication.java create mode 100644 hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/business/early/feign/BusinessEarlyClient.java create mode 100644 hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/business/early/mapper/BusinessEarlyMapper.java create mode 100644 hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/business/early/mapper/BusinessEarlyMapper.xml create mode 100644 hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/business/early/service/BusinessEarlyService.java create mode 100644 hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/business/early/service/impl/BusinessEarlyServiceImpl.java diff --git a/hzims-service-api/alarm-api/src/main/java/com/hnac/hzims/business/entity/BusinessEarlyEntity.java b/hzims-service-api/alarm-api/src/main/java/com/hnac/hzims/business/entity/BusinessEarlyEntity.java new file mode 100644 index 0000000..13719eb --- /dev/null +++ b/hzims-service-api/alarm-api/src/main/java/com/hnac/hzims/business/entity/BusinessEarlyEntity.java @@ -0,0 +1,39 @@ +package com.hnac.hzims.business.entity; + +import com.baomidou.mybatisplus.annotation.TableName; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; +import lombok.EqualsAndHashCode; +import org.springblade.core.tenant.mp.TenantEntity; + +import javax.validation.constraints.NotNull; + + +/** + * @author ysj + */ +@Data +@TableName("hzims_alarm") +@EqualsAndHashCode(callSuper = true) +@ApiModel(value = "告警对象", description = "各告警数据源保存对象") +public class BusinessEarlyEntity extends TenantEntity { + + private static final long serialVersionUID = 1L; + + @ApiModelProperty("任务ID") + @NotNull + private Long taskId; + + @ApiModelProperty("业务类型 ：0 - 固定资产 1 - 日常维护 2 - 安全工器- 具 3 - 巡检 4 - 检修 5 - 缺陷 6 - 值班") + @NotNull + private Integer businessType; + + @ApiModelProperty("预警内容") + @NotNull + private String content; + + @ApiModelProperty("机构Id") + private Long deptId; + +} \ No newline at end of file diff --git a/hzims-service-api/alarm-api/src/main/java/com/hnac/hzims/business/feign/BusinessEarlyClientFallback.java b/hzims-service-api/alarm-api/src/main/java/com/hnac/hzims/business/feign/BusinessEarlyClientFallback.java new file mode 100644 index 0000000..8bf7032 --- /dev/null +++ b/hzims-service-api/alarm-api/src/main/java/com/hnac/hzims/business/feign/BusinessEarlyClientFallback.java @@ -0,0 +1,17 @@ +package com.hnac.hzims.business.feign; + +import com.hnac.hzims.business.entity.BusinessEarlyEntity; +import org.springblade.core.tool.api.R; +import org.springframework.stereotype.Component; + +/** + * @author hx + */ +@Component +public class BusinessEarlyClientFallback implements IBusinessEarlyClient { + + @Override + public R save(BusinessEarlyEntity entity) { + return R.status(false); + } +} \ No newline at end of file diff --git a/hzims-service-api/alarm-api/src/main/java/com/hnac/hzims/business/feign/IBusinessEarlyClient.java b/hzims-service-api/alarm-api/src/main/java/com/hnac/hzims/business/feign/IBusinessEarlyClient.java new file mode 100644 index 0000000..cfb3b93 --- /dev/null +++ b/hzims-service-api/alarm-api/src/main/java/com/hnac/hzims/business/feign/IBusinessEarlyClient.java @@ -0,0 +1,25 @@ +package com.hnac.hzims.business.feign; + +import com.hnac.hzims.alarm.config.constants.AlarmConstants; +import com.hnac.hzims.business.entity.BusinessEarlyEntity; +import org.springblade.core.tool.api.R; +import org.springframework.cloud.openfeign.FeignClient; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; + +/** + * @author ysj + */ +@FeignClient( + value = AlarmConstants.APP_NAME, + fallback = BusinessEarlyClientFallback.class +) +public interface IBusinessEarlyClient { + + String API_PREFIX = "/feign/businessEarly"; + + String BUSINESS_EARLY_SAVE = API_PREFIX + "/save"; + + @PostMapping(BUSINESS_EARLY_SAVE) + R save(@RequestBody BusinessEarlyEntity entity); +} diff --git a/hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/AlarmApplication.java b/hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/AlarmApplication.java new file mode 100644 index 0000000..4e7c270 --- /dev/null +++ b/hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/AlarmApplication.java @@ -0,0 +1,33 @@ +package com.hnac.hzims; + +import com.hnac.hzims.alarm.config.constants.AlarmConstants; +import org.mybatis.spring.annotation.MapperScan; +import org.springblade.core.cloud.feign.EnableBladeFeign; +import org.springblade.core.launch.BladeApplication; +import org.springframework.boot.builder.SpringApplicationBuilder; +import org.springframework.boot.web.servlet.support.SpringBootServletInitializer; +import org.springframework.cloud.client.SpringCloudApplication; +import org.springframework.context.annotation.ComponentScan; + +import javax.annotation.Resource; + +/** + * @author ysj + */ +@EnableBladeFeign +@SpringCloudApplication +@MapperScan("com.hnac.hzims.**.mapper.**") +@ComponentScan(basePackages = {"com.hnac.hzims.alarm.*","com.hnac.hzims.business.*"}) +@Resource +public class AlarmApplication extends SpringBootServletInitializer { + + public static void main(String[] args) { + BladeApplication.run(AlarmConstants.APP_NAME, AlarmApplication.class, args); + } + + @Override + protected SpringApplicationBuilder configure(SpringApplicationBuilder builder) { + return BladeApplication.createSpringApplicationBuilder(builder, AlarmConstants.APP_NAME, AlarmApplication.class); + } + +} diff --git a/hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/alarm/AlarmApplication.java b/hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/alarm/AlarmApplication.java deleted file mode 100644 index 9aa90e1..0000000 --- a/hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/alarm/AlarmApplication.java +++ /dev/null @@ -1,32 +0,0 @@ -package com.hnac.hzims.alarm; - -import com.hnac.hzims.alarm.config.constants.AlarmConstants; -import org.mybatis.spring.annotation.MapperScan; -import org.springblade.core.cloud.feign.EnableBladeFeign; -import org.springblade.core.launch.BladeApplication; -import org.springframework.boot.builder.SpringApplicationBuilder; -import org.springframework.boot.web.servlet.support.SpringBootServletInitializer; -import org.springframework.cloud.client.SpringCloudApplication; -import org.springframework.context.annotation.ComponentScan; - -import javax.annotation.Resource; - -/** - * @author ysj - */ -@EnableBladeFeign -@SpringCloudApplication -@MapperScan("com.hnac.hzims.**.mapper.**") -@ComponentScan(basePackages = {"com.hnac.hzims.alarm.*"}) -@Resource -public class AlarmApplication extends SpringBootServletInitializer { - public static void main(String[] args) { - BladeApplication.run(AlarmConstants.APP_NAME, AlarmApplication.class, args); - } - - @Override - protected SpringApplicationBuilder configure(SpringApplicationBuilder builder) { - return BladeApplication.createSpringApplicationBuilder(builder, AlarmConstants.APP_NAME, AlarmApplication.class); - } - -} diff --git a/hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/business/early/feign/BusinessEarlyClient.java b/hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/business/early/feign/BusinessEarlyClient.java new file mode 100644 index 0000000..6a60e98 --- /dev/null +++ b/hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/business/early/feign/BusinessEarlyClient.java @@ -0,0 +1,33 @@ +package com.hnac.hzims.business.early.feign; + +import com.hnac.hzims.business.early.service.BusinessEarlyService; +import com.hnac.hzims.business.entity.BusinessEarlyEntity; +import com.hnac.hzims.business.feign.IBusinessEarlyClient; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springblade.core.tool.api.R; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RestController; + +/** + * @author ysj + */ +@RestController +@Slf4j +@RequiredArgsConstructor +public class BusinessEarlyClient implements IBusinessEarlyClient { + + private final BusinessEarlyService businessEarlyService; + + /** + * 业务预警信息保存 + * @param entity + * @return + */ + @Override + @PostMapping(BUSINESS_EARLY_SAVE) + public R save(@RequestBody BusinessEarlyEntity entity) { + return R.status(businessEarlyService.save(entity)); + } +} \ No newline at end of file diff --git a/hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/business/early/mapper/BusinessEarlyMapper.java b/hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/business/early/mapper/BusinessEarlyMapper.java new file mode 100644 index 0000000..0cbe996 --- /dev/null +++ b/hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/business/early/mapper/BusinessEarlyMapper.java @@ -0,0 +1,11 @@ +package com.hnac.hzims.business.early.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.hnac.hzims.business.entity.BusinessEarlyEntity; + +/** + * @author ysj + */ +public interface BusinessEarlyMapper extends BaseMapper { + +} diff --git a/hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/business/early/mapper/BusinessEarlyMapper.xml b/hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/business/early/mapper/BusinessEarlyMapper.xml new file mode 100644 index 0000000..7ccae0f --- /dev/null +++ b/hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/business/early/mapper/BusinessEarlyMapper.xml @@ -0,0 +1,6 @@ + + + + + + diff --git a/hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/business/early/service/BusinessEarlyService.java b/hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/business/early/service/BusinessEarlyService.java new file mode 100644 index 0000000..6d31eda --- /dev/null +++ b/hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/business/early/service/BusinessEarlyService.java @@ -0,0 +1,11 @@ +package com.hnac.hzims.business.early.service; + +import com.hnac.hzims.business.entity.BusinessEarlyEntity; +import org.springblade.core.mp.base.BaseService; + +/** + * @author ysj + */ +public interface BusinessEarlyService extends BaseService { + +} diff --git a/hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/business/early/service/impl/BusinessEarlyServiceImpl.java b/hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/business/early/service/impl/BusinessEarlyServiceImpl.java new file mode 100644 index 0000000..7281828 --- /dev/null +++ b/hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/business/early/service/impl/BusinessEarlyServiceImpl.java @@ -0,0 +1,19 @@ +package com.hnac.hzims.business.early.service.impl; + +import com.hnac.hzims.business.early.mapper.BusinessEarlyMapper; +import com.hnac.hzims.business.early.service.BusinessEarlyService; +import com.hnac.hzims.business.entity.BusinessEarlyEntity; +import lombok.AllArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springblade.core.mp.base.BaseServiceImpl; +import org.springframework.stereotype.Service; + +/** + * @author ysj + */ +@AllArgsConstructor +@Service +@Slf4j +public class BusinessEarlyServiceImpl extends BaseServiceImpl implements BusinessEarlyService { + +} \ No newline at end of file diff --git a/hzims-service/hzims-alarm/src/test/java/com/hnac/hzims/alarm/MiddleApplicationTests.java b/hzims-service/hzims-alarm/src/test/java/com/hnac/hzims/alarm/MiddleApplicationTests.java index ffa0e00..0d3f950 100644 --- a/hzims-service/hzims-alarm/src/test/java/com/hnac/hzims/alarm/MiddleApplicationTests.java +++ b/hzims-service/hzims-alarm/src/test/java/com/hnac/hzims/alarm/MiddleApplicationTests.java @@ -1,5 +1,6 @@ package com.hnac.hzims.alarm; +import com.hnac.hzims.AlarmApplication; import org.junit.jupiter.api.Test; import org.springframework.boot.test.context.SpringBootTest; From 3b30cddec7b74a8471dd8e66bda8d0858c9be8bb Mon Sep 17 00:00:00 2001 From: yang_shj <1069818635@QQ.com> Date: Wed, 17 Jan 2024 17:16:52 +0800 Subject: [PATCH 3/3] =?UTF-8?q?#=E4=B8=9A=E5=8A=A1=E9=A2=84=E8=AD=A6?= =?UTF-8?q?=E5=8A=9F=E8=83=BD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../hzims/business/entity/BusinessEarlyEntity.java | 4 +-- .../hnac/hzims/business/vo/BusinessEarlyVo.java | 20 +++++++++++ .../early/controller/BusinessEarlyController.java | 41 ++++++++++++++++++++++ .../early/service/BusinessEarlyService.java | 4 +++ .../service/impl/BusinessEarlyServiceImpl.java | 6 ++++ 5 files changed, 73 insertions(+), 2 deletions(-) create mode 100644 hzims-service-api/alarm-api/src/main/java/com/hnac/hzims/business/vo/BusinessEarlyVo.java create mode 100644 hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/business/early/controller/BusinessEarlyController.java diff --git a/hzims-service-api/alarm-api/src/main/java/com/hnac/hzims/business/entity/BusinessEarlyEntity.java b/hzims-service-api/alarm-api/src/main/java/com/hnac/hzims/business/entity/BusinessEarlyEntity.java index 13719eb..c0b0596 100644 --- a/hzims-service-api/alarm-api/src/main/java/com/hnac/hzims/business/entity/BusinessEarlyEntity.java +++ b/hzims-service-api/alarm-api/src/main/java/com/hnac/hzims/business/entity/BusinessEarlyEntity.java @@ -14,9 +14,9 @@ import javax.validation.constraints.NotNull; * @author ysj */ @Data -@TableName("hzims_alarm") +@TableName("hzims_business_early") @EqualsAndHashCode(callSuper = true) -@ApiModel(value = "告警对象", description = "各告警数据源保存对象") +@ApiModel(value = "业务预警", description = "业务预警对象") public class BusinessEarlyEntity extends TenantEntity { private static final long serialVersionUID = 1L; diff --git a/hzims-service-api/alarm-api/src/main/java/com/hnac/hzims/business/vo/BusinessEarlyVo.java b/hzims-service-api/alarm-api/src/main/java/com/hnac/hzims/business/vo/BusinessEarlyVo.java new file mode 100644 index 0000000..7cda295 --- /dev/null +++ b/hzims-service-api/alarm-api/src/main/java/com/hnac/hzims/business/vo/BusinessEarlyVo.java @@ -0,0 +1,20 @@ +package com.hnac.hzims.business.vo; + +import com.hnac.hzims.business.entity.BusinessEarlyEntity; +import io.swagger.annotations.ApiModel; +import lombok.Data; +import lombok.EqualsAndHashCode; + + +/** + * @author ysj + */ +@Data +@EqualsAndHashCode(callSuper = true) +@ApiModel(value = "告警对象", description = "各告警数据源保存对象") +public class BusinessEarlyVo extends BusinessEarlyEntity { + + private static final long serialVersionUID = 1L; + + +} \ No newline at end of file diff --git a/hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/business/early/controller/BusinessEarlyController.java b/hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/business/early/controller/BusinessEarlyController.java new file mode 100644 index 0000000..f696b61 --- /dev/null +++ b/hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/business/early/controller/BusinessEarlyController.java @@ -0,0 +1,41 @@ +package com.hnac.hzims.business.early.controller; + + +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport; +import com.hnac.hzims.business.early.service.BusinessEarlyService; +import com.hnac.hzims.business.entity.BusinessEarlyEntity; +import com.hnac.hzims.business.vo.BusinessEarlyVo; +import com.hnac.hzims.common.logs.annotation.OperationAnnotation; +import com.hnac.hzims.common.logs.enums.BusinessType; +import com.hnac.hzims.common.logs.enums.OperatorType; +import com.hnac.hzims.operational.access.vo.ConstructionVo; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import lombok.AllArgsConstructor; +import org.springblade.core.boot.ctrl.BladeController; +import org.springblade.core.mp.support.Condition; +import org.springblade.core.mp.support.Query; +import org.springblade.core.tool.api.R; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +/** + * @author ysj + */ +@Api(tags = {"业务预警"}) +@RestController +@AllArgsConstructor +@RequestMapping("/business/early") +public class BusinessEarlyController extends BladeController { + + private final BusinessEarlyService businessEarlyService; + + @GetMapping("/list") + @ApiOperationSupport(order = 4) + @ApiOperation(value = "分页查询") + public R> list(BusinessEarlyVo early, Query query) { + return R.data(businessEarlyService.pageCondition(Condition.getPage(query), early)); + } +} diff --git a/hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/business/early/service/BusinessEarlyService.java b/hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/business/early/service/BusinessEarlyService.java index 6d31eda..507af9d 100644 --- a/hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/business/early/service/BusinessEarlyService.java +++ b/hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/business/early/service/BusinessEarlyService.java @@ -1,6 +1,9 @@ package com.hnac.hzims.business.early.service; +import com.baomidou.mybatisplus.core.metadata.IPage; import com.hnac.hzims.business.entity.BusinessEarlyEntity; +import com.hnac.hzims.business.vo.BusinessEarlyVo; +import com.hnac.hzims.operational.access.vo.ConstructionVo; import org.springblade.core.mp.base.BaseService; /** @@ -8,4 +11,5 @@ import org.springblade.core.mp.base.BaseService; */ public interface BusinessEarlyService extends BaseService { + IPage pageCondition(IPage page, BusinessEarlyVo early); } diff --git a/hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/business/early/service/impl/BusinessEarlyServiceImpl.java b/hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/business/early/service/impl/BusinessEarlyServiceImpl.java index 7281828..de0f0ad 100644 --- a/hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/business/early/service/impl/BusinessEarlyServiceImpl.java +++ b/hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/business/early/service/impl/BusinessEarlyServiceImpl.java @@ -1,8 +1,10 @@ package com.hnac.hzims.business.early.service.impl; +import com.baomidou.mybatisplus.core.metadata.IPage; import com.hnac.hzims.business.early.mapper.BusinessEarlyMapper; import com.hnac.hzims.business.early.service.BusinessEarlyService; import com.hnac.hzims.business.entity.BusinessEarlyEntity; +import com.hnac.hzims.business.vo.BusinessEarlyVo; import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springblade.core.mp.base.BaseServiceImpl; @@ -16,4 +18,8 @@ import org.springframework.stereotype.Service; @Slf4j public class BusinessEarlyServiceImpl extends BaseServiceImpl implements BusinessEarlyService { + @Override + public IPage pageCondition(IPage page, BusinessEarlyVo early) { + return null; + } } \ No newline at end of file