update

src/main/java/com/zhiqiyun/open/core/mapper/statistics/HyMonitorMapper.java

@@ -0,0 +1,9 @@
+package com.zhiqiyun.open.core.mapper.statistics;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.zhiqiyun.open.core.models.statistics.HyMonitor;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface HyMonitorMapper extends BaseMapper<HyMonitor> {
+}

src/main/java/com/zhiqiyun/open/core/models/statistics/HyMonitor.java

@@ -0,0 +1,58 @@
+package com.zhiqiyun.open.core.models.statistics;
+
+import com.baomidou.mybatisplus.annotation.*;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.util.Date;
+
+/**
+ * 文旅行业-产业监测系统(HyMonitorEntity)实体类
+ *
+ * @author 唐旺
+ * @since 2022-02-07 17:39:22
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@TableName("hy_monitor")
+public class HyMonitor {
+
+	@TableId(type = IdType.AUTO)
+	private Long id;
+
+	private Long authId;
+	/**
+	 * 文化场所
+	 */
+	private Long mechanismId;
+	/**
+	 * 监测类型（1.客流量监测  2.车流量监测  3.文保场所客流监测  4.文旅交通监测  5.文旅消费监测）
+	 */
+	private Integer type;
+
+	/**
+	 * 客流量
+	 */
+	private Integer quantity;
+
+	private Integer mechanismType;
+
+
+	/**
+	 * 创建者
+	 */
+	@TableField(fill = FieldFill.INSERT)
+	private Long creator;
+
+	/**
+	 * 是否删除 0 否 1 是
+	 */
+	private Integer isDeleted;
+
+	/**
+	 * 创建时间
+	 */
+	@TableField(fill = FieldFill.INSERT)
+	private Date createDate;
+}
+

src/main/java/com/zhiqiyun/open/core/service/HyMonitorService.java

@@ -0,0 +1,7 @@
+package com.zhiqiyun.open.core.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.zhiqiyun.open.core.models.statistics.HyMonitor;
+
+public interface HyMonitorService extends IService<HyMonitor> {
+}

src/main/java/com/zhiqiyun/open/core/service/impl/HyMonitorServiceImpl.java

@@ -0,0 +1,11 @@
+package com.zhiqiyun.open.core.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.zhiqiyun.open.core.mapper.statistics.HyMonitorMapper;
+import com.zhiqiyun.open.core.models.statistics.HyMonitor;
+import com.zhiqiyun.open.core.service.HyMonitorService;
+import org.springframework.stereotype.Service;
+
+@Service
+public class HyMonitorServiceImpl extends ServiceImpl<HyMonitorMapper, HyMonitor> implements HyMonitorService {
+}

src/main/java/com/zhiqiyun/open/router/apis/MonitorApi.java

@@ -0,0 +1,38 @@
+package com.zhiqiyun.open.router.apis;
+
+import com.dliyun.oap.framework.annotation.ServiceMethod;
+import com.dliyun.oap.framework.annotation.ServiceMethodBean;
+import com.dliyun.oap.framework.response.OapResponse;
+import com.zhiqiyun.open.core.models.statistics.HyMonitor;
+import com.zhiqiyun.open.core.service.HyMonitorService;
+import com.zhiqiyun.open.core.service.SequenceService;
+import com.zhiqiyun.open.router.request.statistics.SaveHyMonitorRequest;
+import com.zhiqiyun.open.utils.DateUtil;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+
+@Slf4j
+@ServiceMethodBean
+public class MonitorApi {
+
+	@Autowired
+	private HyMonitorService hyMonitorService;
+
+	@Autowired
+	private SequenceService sequenceService;
+
+	@ServiceMethod(method = "hy.monitor.add", title = "各机构客流量提交")
+	public OapResponse save(SaveHyMonitorRequest request) {
+
+		HyMonitor entity = new HyMonitor();
+		BeanUtils.copyProperties(request, entity);
+
+		entity.setCreateDate(DateUtil.current());
+		entity.setId(this.sequenceService.nextId());
+
+		this.hyMonitorService.save(entity);
+
+		return OapResponse.success().setBody(entity);
+	}
+}

src/main/java/com/zhiqiyun/open/router/request/statistics/SaveHyMonitorRequest.java

@@ -0,0 +1,47 @@
+package com.zhiqiyun.open.router.request.statistics;
+
+import com.dliyun.oap.framework.annotation.ServiceParamField;
+import com.dliyun.oap.framework.request.AbstractOapRequest;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+@EqualsAndHashCode(callSuper = true)
+@Data
+public class SaveHyMonitorRequest extends AbstractOapRequest {
+
+	@ServiceParamField(describe = "认证ID")
+	private Long authId;
+
+	/**
+	 * 文化场所
+	 */
+	@ServiceParamField(describe = "文化场所")
+	private Long mechanismId;
+	/**
+	 * 监测类型（1.客流量监测  2.车流量监测  3.文保场所客流监测  4.文旅交通监测  5.文旅消费监测）
+	 */
+	@ServiceParamField(describe = "监测类型（1.客流量监测  2.车流量监测  3.文保场所客流监测  4.文旅交通监测  5.文旅消费监测）")
+	private Integer type;
+
+	/**
+	 * 客流量
+	 */
+	@ServiceParamField(describe = "客流量")
+	private Integer quantity;
+
+	@ServiceParamField(describe = "机构类型1、景区2、文保场所3、高速收费站")
+	private Integer mechanismType;
+
+
+	/**
+	 * 创建者
+	 */
+	@ServiceParamField(describe = "创建者")
+	private Long creator;
+
+	/**
+	 * 是否删除 0 否 1 是
+	 */
+	@ServiceParamField(describe = "是否删除 0 否 1 是")
+	private Integer isDeleted;
+}

src/main/resources/db/migration/V1.2.1__hy_monitor.sql

@@ -0,0 +1,17 @@
+DROP TABLE IF EXISTS `hy_monitor`;
+CREATE TABLE `hy_monitor`
+(
+    `id`             bigint(20) NOT NULL AUTO_INCREMENT,
+    `auth_id`        bigint(20) NULL DEFAULT NULL,
+    `mechanism_id`   bigint(20) NULL DEFAULT NULL COMMENT '机构ID',
+    `type`           tinyint(2) NULL DEFAULT NULL COMMENT '监测类型 1.客流量监测 ',
+    `quantity`       int(11) NULL DEFAULT NULL COMMENT '客流量',
+    `mechanism_type` tinyint(2) NULL DEFAULT 1 COMMENT '机构类型 1、景区 2、文保场所 3、高速收费站',
+    `creator`        bigint(20) NULL DEFAULT NULL COMMENT '创建者',
+    `create_date`    datetime NULL DEFAULT NULL COMMENT '创建时间',
+    `is_deleted`     tinyint(4) NULL DEFAULT 0 COMMENT '是否已删除 0 否 1 是',
+    PRIMARY KEY (`id`) USING BTREE,
+    INDEX            `mechanism_id`(`mechanism_id`) USING BTREE,
+    INDEX            `auth_id, type, create_date`(`auth_id`, `type`, `create_date`, `mechanism_id`) USING BTREE,
+    INDEX            `create_date`(`create_date`) USING BTREE
+) ENGINE=InnoDB COMMENT='文旅行业-产业监测系统';