Merge remote-tracking branch 'origin/master'

hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/video/entity/VideoPlatformEntity.java

@@ -1,7 +1,5 @@
 package com.hnac.hzims.operational.video.entity;
 
-import com.baomidou.mybatisplus.annotation.IdType;
-import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.annotation.TableName;
 import com.fasterxml.jackson.databind.annotation.JsonSerialize;
 import com.fasterxml.jackson.databind.ser.std.ToStringSerializer;
@@ -11,7 +9,6 @@ import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
-import org.hibernate.validator.constraints.Length;
 import org.springblade.core.tenant.mp.TenantEntity;
 
 import javax.validation.constraints.NotBlank;
@@ -19,7 +16,10 @@ import javax.validation.constraints.NotNull;
 import javax.validation.constraints.Size;
 import java.io.Serializable;
 
-@EqualsAndHashCode
+/**
+ * @author ysj
+ */
+@EqualsAndHashCode(callSuper = true)
 @Data
 @TableName("HZIMS_VIDEO_PLATFORM")
 @ApiModel(value = "视频平台实体类",description = "视频平台实体类")
@@ -40,11 +40,13 @@ public class VideoPlatformEntity extends TenantEntity implements Serializable {
     @Size(min = 1,max = 50,groups = Create.class)
     private String videoHost;
 
+
     @ApiModelProperty("秘钥appKey")
     @NotBlank
     @Size(min = 1,max = 50,groups = Create.class)
     private String appKey;
 
+
     @ApiModelProperty("秘钥appSecret")
     @NotBlank
     @Size(min = 1,max = 100,groups = Create.class)

hzims-service-api/safeproduct-api/src/main/java/com/hnac/hzims/safeproduct/dto/HygieneTemplateDTO.java

@@ -0,0 +1,25 @@
+package com.hnac.hzims.safeproduct.dto;
+
+import com.hnac.hzims.safeproduct.entity.HygieneTemplateDetailEntity;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @date 2024-04-28
+ */
+@Data
+@ApiModel(value = "卫生自查模板DTO类")
+public class HygieneTemplateDTO {
+
+    @ApiModelProperty("模板id")
+    private Long templateId;
+
+    @ApiModelProperty("模板名称")
+    private String templateName;
+
+    @ApiModelProperty("模板详情列表")
+    private List<HygieneTemplateDetailEntity> templateDetailList;
+}

hzims-service-api/safeproduct-api/src/main/java/com/hnac/hzims/safeproduct/entity/HygieneTemplateDetailEntity.java

@@ -0,0 +1,30 @@
+package com.hnac.hzims.safeproduct.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.mp.base.BaseEntity;
+
+import javax.validation.constraints.Size;
+
+/**
+ * @date 2024-04-28
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@TableName("hzims_hygiene_template_detail")
+@ApiModel(value = "卫生自查模板详情表")
+public class HygieneTemplateDetailEntity extends BaseEntity {
+
+    @ApiModelProperty("模板id")
+    private Long templateId;
+
+    @Size(max = 50, message = "责任区字段长度不能超过50")
+    @ApiModelProperty("责任区")
+    private String zone;
+
+    @ApiModelProperty("检查项")
+    private String checkItem;
+}

hzims-service-api/safeproduct-api/src/main/java/com/hnac/hzims/safeproduct/entity/HygieneTemplateEntity.java

@@ -0,0 +1,21 @@
+package com.hnac.hzims.safeproduct.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.mp.base.BaseEntity;
+
+/**
+ * @date 2024-04-28
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@TableName("hzims_hygiene_template")
+@ApiModel(value = "卫生自查模板表")
+public class HygieneTemplateEntity extends BaseEntity {
+
+    @ApiModelProperty("模板名称")
+    private String templateName;
+}

hzims-service-api/safeproduct-api/src/main/java/com/hnac/hzims/safeproduct/vo/HygieneTemplateDetailVO.java

@@ -0,0 +1,26 @@
+package com.hnac.hzims.safeproduct.vo;
+
+import com.hnac.hzims.safeproduct.entity.HygieneTemplateDetailEntity;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @author liwen
+ * @date 2024-04-30
+ */
+@Data
+@ApiModel(value = "卫生自查模板详情VO类")
+public class HygieneTemplateDetailVO {
+
+    @ApiModelProperty("模板id")
+    private Long id;
+
+    @ApiModelProperty("模板名称")
+    private String templateName;
+
+    @ApiModelProperty("模板详情列表")
+    private List<HygieneTemplateDetailEntity> templateDetailList;
+}

hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/service/inspect/impl/TaskServiceImpl.java

@@ -4,6 +4,7 @@ import com.baomidou.dynamic.datasource.annotation.DS;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.hnac.hzims.scheduled.mapper.inspect.TaskMapper;
 import com.hnac.hzims.scheduled.service.inspect.TaskService;
+import com.hnac.hzinfo.inspect.task.TaskContants;
 import com.hnac.hzinfo.inspect.task.entity.TaskEntity;
 import com.hnac.hzinfo.inspect.task.vo.DutyInspectTaskVO;
 import lombok.AllArgsConstructor;
@@ -49,7 +50,7 @@ public class TaskServiceImpl extends BaseServiceImpl<TaskMapper, TaskEntity> imp
         task.setInspectTaskIds(tasks.stream().map(TaskEntity::getId).map(Object::toString).collect(Collectors.joining(",")));
         task.setInspectTaskSum(tasks.size());
         // 所有处理完成巡检任务
-        List<TaskEntity> finshList = tasks.stream().filter(o-> null != o.getStatus() && o.getStatus().equals(4)).collect(Collectors.toList());
+        List<TaskEntity> finshList = tasks.stream().filter(o-> null != o.getStatus() &&  TaskContants.TaskStatusEnum.FINISH_STATUS.getStatus().equals(String.valueOf(o.getStatus()))).collect(Collectors.toList());
         if(CollectionUtil.isEmpty(finshList)){
             return task;
         }

hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/service/operation/business/impl/DutyServiceImpl.java

@@ -16,6 +16,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.springblade.core.mp.base.BaseServiceImpl;
 import org.springblade.core.tool.utils.CollectionUtil;
 import org.springblade.core.tool.utils.ObjectUtil;
+import org.springblade.core.tool.utils.StringUtil;
 import org.springblade.system.user.cache.UserCache;
 import org.springblade.system.user.entity.User;
 import org.springframework.stereotype.Service;
@@ -97,12 +98,16 @@ public class DutyServiceImpl extends BaseServiceImpl<DutyMapper, ImsDutyMainEnti
                 eq(ImsDutyMainPersonEntity::getDutyMainId, dutyMainInfoVo.getId());
                 last(" LIMIT 1");
             }});
-            dutyMainInfoVo.setManagerId(imsDutyMainPersonEntity.getDutyChargePerson().toString());
+            if(ObjectUtil.isNotEmpty(imsDutyMainPersonEntity)){
+                dutyMainInfoVo.setManagerId(imsDutyMainPersonEntity.getDutyChargePerson().toString());
+            }
         } else {
             ImsDutyGroupEntity imsDutyGroupEntity = dutyGroupMapper.selectById(dutyMainInfoVo.getDutyGroupId());
-            dutyMainInfoVo.setGroupName(imsDutyGroupEntity.getGroupName());
+            if(ObjectUtil.isNotEmpty(imsDutyGroupEntity)){
-            dutyMainInfoVo.setDutyGroupId(imsDutyGroupEntity.getId());
+                dutyMainInfoVo.setGroupName(imsDutyGroupEntity.getGroupName());
-            dutyMainInfoVo.setManagerId(imsDutyGroupEntity.getManagerId().toString());
+                dutyMainInfoVo.setDutyGroupId(imsDutyGroupEntity.getId());
+                dutyMainInfoVo.setManagerId(imsDutyGroupEntity.getManagerId().toString());
+            }
         }
         if (ObjectUtil.isEmpty(dutyMainInfoVo)) {
             return null;
@@ -140,11 +145,13 @@ public class DutyServiceImpl extends BaseServiceImpl<DutyMapper, ImsDutyMainEnti
         NextDutyInfoVo dutyInfoVo = new NextDutyInfoVo();
         dutyInfoVo.setGroupName(dutyMainInfoVo.getGroupName());
         dutyInfoVo.setClassName(dutyMainInfoVo.getClassName());
-        // 负责人
+        if(StringUtil.isNotBlank(dutyMainInfoVo.getManagerId())){
-        User user = UserCache.getUser(Long.valueOf(dutyMainInfoVo.getManagerId()));
+            // 负责人
-        if (ObjectUtil.isNotEmpty(user)) {
+            User user = UserCache.getUser(Long.valueOf(dutyMainInfoVo.getManagerId()));
-            dutyInfoVo.setManagerName(user.getRealName());
+            if (ObjectUtil.isNotEmpty(user)) {
-            dutyInfoVo.setManagerPhone(user.getPhone());
+                dutyInfoVo.setManagerName(user.getRealName());
+                dutyInfoVo.setManagerPhone(user.getPhone());
+            }
         }
         dutyInfoVo.setGeneratingCapacity(0);
         return dutyInfoVo;
@@ -165,12 +172,16 @@ public class DutyServiceImpl extends BaseServiceImpl<DutyMapper, ImsDutyMainEnti
                 eq(ImsDutyMainPersonEntity::getDutyMainId, dutyMainInfoVo.getId());
                 last("limit 1");
             }});
-            dutyMainInfoVo.setManagerId(imsDutyMainPersonEntity.getDutyChargePerson().toString());
+            if(ObjectUtil.isNotEmpty(imsDutyMainPersonEntity)){
+                dutyMainInfoVo.setManagerId(imsDutyMainPersonEntity.getDutyChargePerson().toString());
+            }
         } else {
             ImsDutyGroupEntity imsDutyGroupEntity = dutyGroupMapper.selectById(dutyMainInfoVo.getDutyGroupId());
-            dutyMainInfoVo.setGroupName(imsDutyGroupEntity.getGroupName());
+            if(ObjectUtil.isNotEmpty(imsDutyGroupEntity)){
-            dutyMainInfoVo.setDutyGroupId(imsDutyGroupEntity.getId());
+                dutyMainInfoVo.setGroupName(imsDutyGroupEntity.getGroupName());
-            dutyMainInfoVo.setManagerId(imsDutyGroupEntity.getManagerId().toString());
+                dutyMainInfoVo.setDutyGroupId(imsDutyGroupEntity.getId());
+                dutyMainInfoVo.setManagerId(imsDutyGroupEntity.getManagerId().toString());
+            }
         }
         if (ObjectUtil.isEmpty(dutyMainInfoVo)) {
             return null;
@@ -180,11 +191,13 @@ public class DutyServiceImpl extends BaseServiceImpl<DutyMapper, ImsDutyMainEnti
         dutyMainInfoVo.setDateTime(dutyMainInfoVo.getDateTime());
         dutyMainInfoVo.setStartTime(dutyMainInfoVo.getStartTime());
         dutyMainInfoVo.setEndTime(dutyMainInfoVo.getEndTime());
-        // 负责人
+        if(StringUtil.isNotBlank(dutyMainInfoVo.getManagerId())){
-        User user = UserCache.getUser(Long.valueOf(dutyMainInfoVo.getManagerId()));
+            // 负责人
-        if (ObjectUtil.isNotEmpty(user)) {
+            User user = UserCache.getUser(Long.valueOf(dutyMainInfoVo.getManagerId()));
-            dutyMainInfoVo.setManagerName(user.getRealName());
+            if (ObjectUtil.isNotEmpty(user)) {
-            dutyMainInfoVo.setManagerPhone(user.getPhone());
+                dutyMainInfoVo.setManagerName(user.getRealName());
+                dutyMainInfoVo.setManagerPhone(user.getPhone());
+            }
         }
         return dutyMainInfoVo;
     }

hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/service/operation/plate/DataService.java

@@ -8,6 +8,7 @@ import com.hnac.hzinfo.sdk.analyse.po.MultiAnalyzeCodePO;
 import org.springblade.core.tool.api.R;
 
 import java.util.List;
+import java.util.Map;
 import java.util.function.Function;
 
 
@@ -26,5 +27,7 @@ public interface DataService {
 
 	List<AnalyzeDataConditionVO> periodTargetSignages(String startTime, String endTime, Integer accessRules, Integer cycleType, String deviceCode, List<String> signages);
 
+	List<Map<String, String>>  lastFirstBySignage(String startTime, String endTime, Integer accessRules, Integer cycleType, String deviceCode, String signages);
+
 	Float  periodTargetFloat(String startTime, String endTime, Integer accessRules, Integer cycleType, String deviceCode, Double ride ,String signages);
 }

hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/service/operation/plate/impl/DataServiceImpl.java

@@ -11,10 +11,14 @@ import com.hnac.hzinfo.datasearch.analyse.vo.AnalyzeCodeBySignagesVO;
 import com.hnac.hzinfo.datasearch.analyse.vo.AnalyzeDataConditionVO;
 import com.hnac.hzinfo.datasearch.real.po.RealDataSearchPO;
 import com.hnac.hzinfo.sdk.analyse.po.MultiAnalyzeCodePO;
+import com.hnac.hzinfo.sdk.core.response.Result;
 import com.hnac.hzinfo.sdk.v5.device.DeviceDataClient;
-import com.hnac.hzinfo.sdk.v5.device.dto.HisDataDeviceDTO;
+import com.hnac.hzinfo.sdk.v5.device.dto.ReductionAttrDataDTO;
+import com.hnac.hzinfo.sdk.v5.device.dto.ReductionDataDTO;
+import com.hnac.hzinfo.sdk.v5.device.vo.ReductionDataVO;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.collections4.MapUtils;
 import org.springblade.core.tool.api.R;
 import org.springblade.core.tool.utils.CollectionUtil;
 import org.springblade.core.tool.utils.DateUtil;
@@ -27,7 +31,7 @@ import java.time.format.DateTimeFormatter;
 import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
-import java.util.Optional;
+import java.util.Map;
 import java.util.function.Function;
 import java.util.stream.Collectors;
 
@@ -151,6 +155,44 @@ public class DataServiceImpl implements DataService {
 		return result.getData();
 	}
 
+	/**
+	 * 最后值减最初值
+	 * @param startTime 开始时间
+	 * @param endTime 结束时间
+	 * @param accessRules  取数规则 : 0=最早值  1=最大值  2=最小值  3=平均值 4=和值 5=差值  6=最新值 7=最后值减最初值
+	 * @param cycleType 间隔周期 : 0-> 秒  1-> 分 2-> 小时 3->天 4-> 周  5-> 月 6-> 年
+	 * @param deviceCode 设备编号
+	 * @param signage 属性
+	 * @return
+	 */
+	@Override
+	public List<Map<String, String>> lastFirstBySignage(String startTime, String endTime, Integer accessRules, Integer cycleType, String deviceCode, String signage) {
+		ReductionDataDTO  reduction = new ReductionDataDTO();
+		reduction.setFull(1);
+		reduction.setDeviceCode(deviceCode);
+		reduction.setSaveTimeType(cycleType);
+		reduction.setTimeInterval(1);
+		reduction.setNeedPage(false);
+		reduction.setBeginTime(LocalDateTime.parse(DateUtil.format(new Date(), startTime), DateTimeFormatter.ofPattern(DateUtil.PATTERN_DATETIME)));
+		reduction.setEndTime(LocalDateTime.parse(DateUtil.format(new Date(), endTime), DateTimeFormatter.ofPattern(DateUtil.PATTERN_DATETIME)));
+		// 属性列表
+		List<ReductionAttrDataDTO> atts = new ArrayList<>();
+		ReductionAttrDataDTO attr = new ReductionAttrDataDTO();
+		attr.setAccessRules(accessRules);
+		attr.setKeepFigures(4);
+		attr.setSignage(signage);
+		atts.add(attr);
+		reduction.setDtos(atts);
+		Result<ReductionDataVO> result = deviceDataClient.pageDeviceCodeAndSignages(reduction);
+		if (!result.isSuccess() || ObjectUtil.isEmpty(result.getData())) {
+			return new ArrayList<>();
+		}
+		if(MapUtils.isEmpty(result.getData().getFieldMap()) || CollectionUtil.isEmpty(result.getData().getDataList())){
+			return new ArrayList<>();
+		}
+		return result.getData().getDataList();
+	}
+
 	/***
 	 * 指标数据列表查询
 	 * @param startTime 开始时间

hzims-service/operational/src/main/java/com/hnac/hzims/operational/census/service/impl/TargetServiceImpl.java

@@ -1217,6 +1217,7 @@ public class TargetServiceImpl implements TargetService {
 			}
 		}};
 		IPage pages = accessTaskService.page(page, queryWrapper);
+
 		pages.setRecords(OperAccessTaskWrapper.build().listVOExtras(pages.getRecords()));
 		return pages;
 	}

hzims-service/safeproduct/src/main/java/com/hnac/hzims/safeproduct/controller/HygieneController.java

@@ -2,16 +2,17 @@ package com.hnac.hzims.safeproduct.controller;
 
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
+import com.hnac.hzims.common.utils.Condition;
 import com.hnac.hzims.safeproduct.Constants;
 import com.hnac.hzims.safeproduct.dto.HygienePlanDTO;
 import com.hnac.hzims.safeproduct.dto.HygieneRecordDTO;
+import com.hnac.hzims.safeproduct.dto.HygieneTemplateDTO;
 import com.hnac.hzims.safeproduct.entity.HygienePlanEntity;
+import com.hnac.hzims.safeproduct.entity.HygieneTemplateEntity;
 import com.hnac.hzims.safeproduct.service.IHygienePlanService;
 import com.hnac.hzims.safeproduct.service.IHygieneRecordService;
-import com.hnac.hzims.safeproduct.vo.HygienePlanDetailVO;
+import com.hnac.hzims.safeproduct.service.IHygieneTemplateService;
-import com.hnac.hzims.safeproduct.vo.HygieneMonthVO;
+import com.hnac.hzims.safeproduct.vo.*;
-import com.hnac.hzims.safeproduct.vo.HygieneRecordDetailVO;
-import com.hnac.hzims.safeproduct.vo.HygieneRecordPageVO;
 import com.hnac.hzinfo.log.annotation.Business;
 import com.hnac.hzinfo.log.annotation.Operate;
 import com.hnac.hzinfo.log.contants.BusinessType;
@@ -47,6 +48,8 @@ public class HygieneController extends BladeController {
 
     private final IHygieneRecordService hygieneRecordService;
 
+    private final IHygieneTemplateService hygieneTemplateService;
+
     @PostMapping("/savePlan")
     @ApiOperation(value = "新增卫生自查计划")
     @ApiOperationSupport(order = 1)
@@ -183,4 +186,50 @@ public class HygieneController extends BladeController {
     public void exportHygienePlanData(@ApiIgnore @RequestParam Map<String, Object> param, HttpServletResponse response) {
         hygienePlanService.exportHygienePlanData(param, response);
     }
+
+    @PostMapping("/saveHygieneTemplate")
+    @ApiOperation(value = "新增卫生自查模板")
+    @ApiOperationSupport(order = 15)
+    @Operate(label = "新增卫生自查模板", type = BusinessType.INSERT, ignore = false)
+    public R saveHygieneTemplate(@RequestBody HygieneTemplateDTO hygieneTemplateDTO) {
+        boolean save = hygieneTemplateService.saveHygieneTemplate(hygieneTemplateDTO);
+        return R.status(save);
+    }
+
+    @PostMapping("/updateHygieneTemplate")
+    @ApiOperation(value = "修改卫生自查模板")
+    @ApiOperationSupport(order = 16)
+    @Operate(label = "修改卫生自查模板", type = BusinessType.UPDATE, ignore = false)
+    public R updateHygieneTemplate(@RequestBody HygieneTemplateDTO hygieneTemplateDTO) {
+        boolean update = hygieneTemplateService.updateHygieneTemplate(hygieneTemplateDTO);
+        return R.status(update);
+    }
+
+    @PostMapping("/removeHygieneTemplate")
+    @ApiOperation(value = "删除卫生自查模板")
+    @ApiOperationSupport(order = 17)
+    @Operate(label = "删除卫生自查模板", type = BusinessType.DELETE, ignore = false)
+    public R removeHygieneTemplate(@RequestParam Long id) {
+        boolean remove = hygieneTemplateService.removeHygieneTemplate(id);
+        return R.status(remove);
+    }
+
+    @GetMapping("/hygieneTemplateDetail")
+    @ApiOperation(value = "卫生自查模板详情")
+    @ApiOperationSupport(order = 18)
+    @Operate(label = "卫生自查模板详情", type = BusinessType.QUERY, ignore = false)
+    public R hygieneTemplateDetail(@RequestParam Long id) {
+        HygieneTemplateDetailVO detail = hygieneTemplateService.getHygieneTemplateDetail(id);
+        return R.data(detail);
+    }
+
+    @GetMapping("/hygieneTemplatePage")
+    @ApiOperation(value = "卫生自查模板分页")
+    @ApiOperationSupport(order = 19)
+    @Operate(label = "卫生自查模板分页", type = BusinessType.QUERY, ignore = false)
+    public R hygieneTemplatePage(@ApiIgnore @RequestParam Map<String, Object> param, Query query) {
+        IPage<HygieneTemplateEntity> page = hygieneTemplateService.page(Condition.getPage(query), Condition.getQueryWrapper(
+                param, HygieneTemplateEntity.class));
+        return R.data(page);
+    }
 }

hzims-service/safeproduct/src/main/java/com/hnac/hzims/safeproduct/mapper/HygieneTemplateDetailMapper.java

@@ -0,0 +1,15 @@
+package com.hnac.hzims.safeproduct.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.hnac.hzims.safeproduct.entity.HygieneTemplateDetailEntity;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 卫生自查模板详情Mapper类
+ *
+ * @date 2024-04-29
+ */
+@Mapper
+public interface HygieneTemplateDetailMapper extends BaseMapper<HygieneTemplateDetailEntity> {
+
+}

hzims-service/safeproduct/src/main/java/com/hnac/hzims/safeproduct/mapper/HygieneTemplateDetailMapper.xml

@@ -0,0 +1,4 @@
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.hnac.hzims.safeproduct.mapper.HygieneTemplateDetailMapper">
+
+</mapper>

hzims-service/safeproduct/src/main/java/com/hnac/hzims/safeproduct/mapper/HygieneTemplateMapper.java

@@ -0,0 +1,15 @@
+package com.hnac.hzims.safeproduct.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.hnac.hzims.safeproduct.entity.HygieneTemplateEntity;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 卫生自查模板Mapper类
+ *
+ * @date 2024-04-29
+ */
+@Mapper
+public interface HygieneTemplateMapper extends BaseMapper<HygieneTemplateEntity> {
+
+}

hzims-service/safeproduct/src/main/java/com/hnac/hzims/safeproduct/mapper/HygieneTemplateMapper.xml

@@ -0,0 +1,4 @@
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.hnac.hzims.safeproduct.mapper.HygieneTemplateMapper">
+
+</mapper>

hzims-service/safeproduct/src/main/java/com/hnac/hzims/safeproduct/service/IHygieneTemplateDetailService.java

@@ -0,0 +1,21 @@
+package com.hnac.hzims.safeproduct.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.hnac.hzims.safeproduct.entity.HygieneTemplateDetailEntity;
+
+import java.util.List;
+
+/**
+ * 卫生自查模板详情服务类
+ *
+ * @date 2024-04-29
+ */
+public interface IHygieneTemplateDetailService extends IService<HygieneTemplateDetailEntity> {
+
+    /**
+     * 根据模板id查找模板详情数据
+     * @param templateId 模板id
+     * @return 模板详情列表
+     */
+    List<HygieneTemplateDetailEntity> getListByTemplateId(Long templateId);
+}

hzims-service/safeproduct/src/main/java/com/hnac/hzims/safeproduct/service/IHygieneTemplateService.java

@@ -0,0 +1,42 @@
+package com.hnac.hzims.safeproduct.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.hnac.hzims.safeproduct.dto.HygieneTemplateDTO;
+import com.hnac.hzims.safeproduct.entity.HygieneTemplateEntity;
+import com.hnac.hzims.safeproduct.vo.HygieneTemplateDetailVO;
+
+/**
+ * 卫生自查模板服务类
+ *
+ * @date 2024-04-29
+ */
+public interface IHygieneTemplateService extends IService<HygieneTemplateEntity> {
+
+    /**
+     * 新增卫生自查模板
+     * @param hygieneTemplateDTO 卫生自查模板DTO类
+     * @return true-成功，false-失败
+     */
+    boolean saveHygieneTemplate(HygieneTemplateDTO hygieneTemplateDTO);
+
+    /**
+     * 修改卫生自查模板
+     * @param hygieneTemplateDTO 卫生自查模板DTO类
+     * @return true-成功，false-失败
+     */
+    boolean updateHygieneTemplate(HygieneTemplateDTO hygieneTemplateDTO);
+
+    /**
+     * 删除卫生自查模板
+     * @param id 卫生自查模板id
+     * @return true-成功，false-失败
+     */
+    boolean removeHygieneTemplate(Long id);
+
+    /**
+     * 卫生自查模板详情
+     * @param id 卫生自查模板id
+     * @return 详情
+     */
+    HygieneTemplateDetailVO getHygieneTemplateDetail(Long id);
+}

hzims-service/safeproduct/src/main/java/com/hnac/hzims/safeproduct/service/impl/HygieneTemplateDetailServiceImpl.java

@@ -0,0 +1,30 @@
+package com.hnac.hzims.safeproduct.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.hnac.hzims.safeproduct.entity.HygieneTemplateDetailEntity;
+import com.hnac.hzims.safeproduct.mapper.HygieneTemplateDetailMapper;
+import com.hnac.hzims.safeproduct.service.IHygieneTemplateDetailService;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * 卫生自查模板详情服务实现类
+ *
+ * @date 2024-04-29
+ */
+@Service
+public class HygieneTemplateDetailServiceImpl extends ServiceImpl<HygieneTemplateDetailMapper, HygieneTemplateDetailEntity>
+        implements IHygieneTemplateDetailService {
+
+    /**
+     * 根据模板id查找模板详情数据
+     */
+    @Override
+    public List<HygieneTemplateDetailEntity> getListByTemplateId(Long templateId) {
+        QueryWrapper<HygieneTemplateDetailEntity> queryWrapper = new QueryWrapper<>();
+        queryWrapper.lambda().eq(HygieneTemplateDetailEntity::getTemplateId, templateId);
+        return this.list(queryWrapper);
+    }
+}

hzims-service/safeproduct/src/main/java/com/hnac/hzims/safeproduct/service/impl/HygieneTemplateServiceImpl.java

@@ -0,0 +1,107 @@
+package com.hnac.hzims.safeproduct.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.hnac.hzims.safeproduct.dto.HygieneTemplateDTO;
+import com.hnac.hzims.safeproduct.entity.HygieneTemplateDetailEntity;
+import com.hnac.hzims.safeproduct.entity.HygieneTemplateEntity;
+import com.hnac.hzims.safeproduct.mapper.HygieneTemplateMapper;
+import com.hnac.hzims.safeproduct.service.IHygieneTemplateDetailService;
+import com.hnac.hzims.safeproduct.service.IHygieneTemplateService;
+import com.hnac.hzims.safeproduct.vo.HygieneTemplateDetailVO;
+import org.springblade.core.log.exception.ServiceException;
+import org.springblade.core.tool.utils.CollectionUtil;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+import java.util.stream.Collectors;
+
+/**
+ * 卫生自查模板服务实现类
+ *
+ * @date 2024-04-29
+ */
+@Service
+public class HygieneTemplateServiceImpl extends ServiceImpl<HygieneTemplateMapper, HygieneTemplateEntity> implements IHygieneTemplateService {
+
+    @Autowired
+    IHygieneTemplateDetailService hygieneTemplateDetailService;
+
+    /**
+     * 新增卫生自查模板
+     */
+    @Transactional(rollbackFor = Exception.class)
+    @Override
+    public boolean saveHygieneTemplate(HygieneTemplateDTO hygieneTemplateDTO) {
+        String templateName = hygieneTemplateDTO.getTemplateName();
+        QueryWrapper<HygieneTemplateEntity> queryWrapper = new QueryWrapper<>();
+        queryWrapper.lambda().eq(HygieneTemplateEntity::getTemplateName, templateName);
+        List<HygieneTemplateEntity> list = this.list(queryWrapper);
+        if (CollectionUtil.isNotEmpty(list)) {
+            throw new ServiceException("模板名不可重复");
+        }
+        HygieneTemplateEntity hygieneTemplate = new HygieneTemplateEntity();
+        hygieneTemplate.setTemplateName(templateName);
+        boolean saveTemplate = this.save(hygieneTemplate);
+        if (!saveTemplate) {
+            throw new ServiceException("卫生自查模板新增失败");
+        }
+        return hygieneTemplateDetailService.saveBatch(hygieneTemplateDTO.getTemplateDetailList());
+    }
+
+    /**
+     * 修改卫生自查模板
+     */
+    @Transactional(rollbackFor = Exception.class)
+    @Override
+    public boolean updateHygieneTemplate(HygieneTemplateDTO hygieneTemplateDTO) {
+        String templateName = hygieneTemplateDTO.getTemplateName();
+        Long templateId = hygieneTemplateDTO.getTemplateId();
+        QueryWrapper<HygieneTemplateEntity> queryWrapper = new QueryWrapper<>();
+        queryWrapper.lambda().eq(HygieneTemplateEntity::getTemplateName, templateName);
+        queryWrapper.lambda().ne(HygieneTemplateEntity::getId, templateId);
+        List<HygieneTemplateEntity> list = this.list(queryWrapper);
+        if (CollectionUtil.isNotEmpty(list)) {
+            throw new ServiceException("模板名不可重复");
+        }
+        HygieneTemplateEntity hygieneTemplate = new HygieneTemplateEntity();
+        hygieneTemplate.setId(templateId);
+        hygieneTemplate.setTemplateName(templateName);
+        boolean updateTemplate = this.updateById(hygieneTemplate);
+        if (!updateTemplate) {
+            throw new ServiceException("卫生自查模板修改失败");
+        }
+        return hygieneTemplateDetailService.updateBatchById(hygieneTemplateDTO.getTemplateDetailList());
+    }
+
+    /**
+     * 删除卫生自查模板
+     */
+    @Transactional(rollbackFor = Exception.class)
+    @Override
+    public boolean removeHygieneTemplate(Long id) {
+        boolean removeTemplate = this.removeById(id);
+        if (!removeTemplate) {
+            throw new ServiceException("卫生自查模板删除失败");
+        }
+        List<HygieneTemplateDetailEntity> details = hygieneTemplateDetailService.getListByTemplateId(id);
+        List<Long> ids = details.stream().map(HygieneTemplateDetailEntity::getId).collect(Collectors.toList());
+        return hygieneTemplateDetailService.removeByIds(ids);
+    }
+
+    /**
+     * 卫生自查模板详情
+     */
+    @Override
+    public HygieneTemplateDetailVO getHygieneTemplateDetail(Long id) {
+        HygieneTemplateDetailVO hygieneTemplateDetailVO = new HygieneTemplateDetailVO();
+        HygieneTemplateEntity hygieneTemplate = this.getById(id);
+        BeanUtils.copyProperties(hygieneTemplate, hygieneTemplateDetailVO);
+        List<HygieneTemplateDetailEntity> details = hygieneTemplateDetailService.getListByTemplateId(id);
+        hygieneTemplateDetailVO.setTemplateDetailList(details);
+        return hygieneTemplateDetailVO;
+    }
+}

hzims-service/safeproduct/src/main/resources/db/2.0.1.sql

@@ -11,3 +11,33 @@ ALTER TABLE hzims_rehearsal_plan
 -- 特种设备表：添加单位字段
 ALTER TABLE hzims_device
     ADD COLUMN unit varchar(50) NOT NULL COMMENT '单位';
+
+-- 新增卫生自查模板表
+CREATE TABLE IF NOT EXISTS `hzims_hygiene_template` (
+    `id` bigint(20) NOT NULL COMMENT '主键ID',
+    `template_name` varchar(50) NOT NULL COMMENT '模板名称',
+    `create_user` bigint(20) NOT NULL DEFAULT '-1' COMMENT '创建人',
+    `create_dept` bigint(20) NOT NULL DEFAULT '-1' COMMENT '创建部门',
+    `create_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+    `update_user` bigint(20) DEFAULT '-1' COMMENT '更新人',
+    `update_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '最后更新时间',
+    `status` int(2) NOT NULL DEFAULT '1' COMMENT '状态',
+    `is_deleted` int(2) NOT NULL DEFAULT '0' COMMENT '逻辑删除状态：0-未删除，1-删除',
+    PRIMARY KEY (`id`) USING BTREE
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC COMMENT='卫生自查模板表';
+
+-- 新增卫生自查模板详情表
+CREATE TABLE IF NOT EXISTS `hzims_hygiene_template_detail` (
+    `id` bigint(20) NOT NULL COMMENT '主键ID',
+    `template_id` bigint(20) NOT NULL COMMENT '模板id',
+    `zone` varchar(50) NOT NULL COMMENT '责任区',
+    `check_item` mediumtext NOT NULL COMMENT '检查项',
+    `create_user` bigint(20) NOT NULL DEFAULT '-1' COMMENT '创建人',
+    `create_dept` bigint(20) NOT NULL DEFAULT '-1' COMMENT '创建部门',
+    `create_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+    `update_user` bigint(20) DEFAULT '-1' COMMENT '更新人',
+    `update_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '最后更新时间',
+    `status` int(2) NOT NULL DEFAULT '1' COMMENT '状态',
+    `is_deleted` int(2) NOT NULL DEFAULT '0' COMMENT '逻辑删除状态：0-未删除，1-删除',
+    PRIMARY KEY (`id`) USING BTREE
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC COMMENT='卫生自查模板详情表';