生产实体类

src/main/java/com/usky/dxtop/MysqlGenerator.java

@@ -43,7 +43,7 @@
 //        strategy.setColumnNaming(NamingStrategy.underline_to_camel);
 //        // strategy.setTablePrefix("t_"); // 表名前缀
 //        strategy.setEntityLombokModel(true); //使用lombok
-//        strategy.setInclude("top_radio","top_channel","qr_code","order","call_api_log");  // 逆向工程使用的表   如果要生成多个,这里可以传入String[]
+//        strategy.setInclude("charge","dish");  // 逆向工程使用的表   如果要生成多个,这里可以传入String[]
 //        mpg.setStrategy(strategy);
 //
 //        //5、执行

src/main/java/com/usky/dxtop/controller/web/ChargeController.java

@@ -0,0 +1,20 @@
+package com.usky.dxtop.controller.web;
+
+
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.RequestMapping;
+
+/**
+ * <p>
+ *  前端控制器
+ * </p>
+ *
+ * @author yq
+ * @since 2021-09-09
+ */
+@Controller
+@RequestMapping("/dxtop/charge")
+public class ChargeController {
+
+}
+

src/main/java/com/usky/dxtop/controller/web/DishController.java

@@ -0,0 +1,20 @@
+package com.usky.dxtop.controller.web;
+
+
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.RequestMapping;
+
+/**
+ * <p>
+ *  前端控制器
+ * </p>
+ *
+ * @author yq
+ * @since 2021-09-09
+ */
+@Controller
+@RequestMapping("/dxtop/dish")
+public class DishController {
+
+}
+

src/main/java/com/usky/dxtop/mapper/ChargeMapper.java

@@ -0,0 +1,17 @@
+package com.usky.dxtop.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.usky.dxtop.model.Charge;
+
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author yq
+ * @since 2021-09-09
+ */
+public interface ChargeMapper extends BaseMapper<Charge> {
+
+}

src/main/java/com/usky/dxtop/mapper/DishMapper.java

@@ -0,0 +1,17 @@
+package com.usky.dxtop.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.usky.dxtop.model.Dish;
+
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author yq
+ * @since 2021-09-09
+ */
+public interface DishMapper extends BaseMapper<Dish> {
+
+}

src/main/java/com/usky/dxtop/model/Charge.java

@@ -0,0 +1,50 @@
+package com.usky.dxtop.model;
+
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author yq
+ * @since 2021-09-09
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+public class Charge implements Serializable {
+
+    private static final long serialVersionUID=1L;
+
+    private Long seq;
+
+    private LocalDateTime createTime;
+
+    private String card;
+
+    private String cardNo;
+
+    private Integer type;
+
+    private Integer term;
+
+    private Integer shop;
+
+    private String termName;
+
+    private String shopName;
+
+    private Double amt;
+
+    private Double balance;
+
+    private Integer account;
+
+
+}

src/main/java/com/usky/dxtop/model/Dish.java

@@ -0,0 +1,71 @@
+package com.usky.dxtop.model;
+
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.time.LocalDateTime;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author yq
+ * @since 2021-09-09
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+public class Dish implements Serializable {
+
+    private static final long serialVersionUID=1L;
+
+    private Long seq;
+
+    private LocalDateTime createTime;
+
+    private String card;
+
+    private String cardNo;
+
+    private Integer type;
+
+    private Integer term;
+
+    private Integer shop;
+
+    private String termName;
+
+    private String shopName;
+
+    private Double amt;
+
+    private Double balance;
+
+    private Integer account;
+
+    private Integer part;
+
+    private String name;
+
+    private String mob;
+
+    private Integer pId;
+
+    private String pName;
+
+    private BigDecimal pPrice;
+
+    private BigDecimal pAmt;
+
+    private Integer paymentType;
+
+    private BigDecimal paymentAmt;
+
+    private BigDecimal paymentBalance;
+
+
+}

src/main/java/com/usky/dxtop/service/ChargeService.java

@@ -0,0 +1,17 @@
+package com.usky.dxtop.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.usky.dxtop.model.Charge;
+
+
+/**
+ * <p>
+ *  服务类
+ * </p>
+ *
+ * @author yq
+ * @since 2021-09-09
+ */
+public interface ChargeService extends IService<Charge> {
+
+}

src/main/java/com/usky/dxtop/service/DishService.java

@@ -0,0 +1,17 @@
+package com.usky.dxtop.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.usky.dxtop.model.Dish;
+
+
+/**
+ * <p>
+ *  服务类
+ * </p>
+ *
+ * @author yq
+ * @since 2021-09-09
+ */
+public interface DishService extends IService<Dish> {
+
+}

src/main/java/com/usky/dxtop/service/config/MqProperties.java

@@ -0,0 +1,58 @@
+package com.usky.dxtop.service.config;
+
+import lombok.Data;
+import org.springframework.amqp.core.*;
+import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory;
+import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
+import org.springframework.amqp.rabbit.connection.ConnectionFactory;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.autoconfigure.amqp.RabbitProperties;
+import org.springframework.boot.autoconfigure.amqp.SimpleRabbitListenerContainerFactoryConfigurer;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author yq
+ * @date 2021/9/7 17:14
+ */
+@Data
+@Configuration
+public class MqProperties {
+
+    @Autowired
+    private RabbitProperties rabbitProperties;
+    public ConnectionFactory connectionFactory(String vHost) {
+        CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
+        connectionFactory.setHost(rabbitProperties.getHost());
+        connectionFactory.setPort(rabbitProperties.getPort());
+        connectionFactory.setUsername(rabbitProperties.getUsername());
+        connectionFactory.setPassword(rabbitProperties.getPassword());
+        connectionFactory.setVirtualHost(vHost);
+        return connectionFactory;
+    }
+
+    public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
+        return new RabbitTemplate(connectionFactory);
+    }
+
+    public SimpleRabbitListenerContainerFactory listenerFactory(
+            SimpleRabbitListenerContainerFactoryConfigurer configurer,
+            ConnectionFactory connectionFactory) {
+        SimpleRabbitListenerContainerFactory listenerContainerFactory = new SimpleRabbitListenerContainerFactory();
+        //设置手动ack
+        listenerContainerFactory.setAcknowledgeMode(AcknowledgeMode.MANUAL);
+        configurer.configure(listenerContainerFactory, connectionFactory);
+        return listenerContainerFactory;
+    }
+
+    public Jackson2JsonMessageConverter messageConverter() {
+        return new Jackson2JsonMessageConverter();
+    }
+
+}

src/main/java/com/usky/dxtop/service/impl/ChargeServiceImpl.java

@@ -0,0 +1,21 @@
+package com.usky.dxtop.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+
+import com.usky.dxtop.mapper.ChargeMapper;
+import com.usky.dxtop.model.Charge;
+import com.usky.dxtop.service.ChargeService;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ *  服务实现类
+ * </p>
+ *
+ * @author yq
+ * @since 2021-09-09
+ */
+@Service
+public class ChargeServiceImpl extends ServiceImpl<ChargeMapper, Charge> implements ChargeService {
+
+}

src/main/java/com/usky/dxtop/service/impl/DishServiceImpl.java

@@ -0,0 +1,21 @@
+package com.usky.dxtop.service.impl;
+
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.usky.dxtop.mapper.DishMapper;
+import com.usky.dxtop.model.Dish;
+import com.usky.dxtop.service.DishService;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ *  服务实现类
+ * </p>
+ *
+ * @author yq
+ * @since 2021-09-09
+ */
+@Service
+public class DishServiceImpl extends ServiceImpl<DishMapper, Dish> implements DishService {
+
+}

src/main/resources/mapper/ChargeMapper.xml

@@ -0,0 +1,21 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.usky.dxtop.dxtop.mapper.ChargeMapper">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="BaseResultMap" type="com.usky.dxtop.model.Charge">
+        <id column="seq" property="seq" />
+        <result column="create_time" property="createTime" />
+        <result column="card" property="card" />
+        <result column="crad_no" property="cradNo" />
+        <result column="type" property="type" />
+        <result column="term" property="term" />
+        <result column="shop" property="shop" />
+        <result column="term_name" property="termName" />
+        <result column="shop_name" property="shopName" />
+        <result column="amt" property="amt" />
+        <result column="balance" property="balance" />
+        <result column="account" property="account" />
+    </resultMap>
+
+</mapper>

src/main/resources/mapper/DishMapper.xml

@@ -0,0 +1,31 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.usky.dxtop.dxtop.mapper.DishMapper">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="BaseResultMap" type="com.usky.dxtop.model.Dish">
+        <id column="seq" property="seq" />
+        <result column="create_time" property="createTime" />
+        <result column="card" property="card" />
+        <result column="crad_no" property="cradNo" />
+        <result column="type" property="type" />
+        <result column="term" property="term" />
+        <result column="shop" property="shop" />
+        <result column="term_name" property="termName" />
+        <result column="shop_name" property="shopName" />
+        <result column="amt" property="amt" />
+        <result column="balance" property="balance" />
+        <result column="account" property="account" />
+        <result column="part" property="part" />
+        <result column="name" property="name" />
+        <result column="mob" property="mob" />
+        <result column="p_id" property="pId" />
+        <result column="p_name" property="pName" />
+        <result column="p_price" property="pPrice" />
+        <result column="p_amt" property="pAmt" />
+        <result column="payment_type" property="paymentType" />
+        <result column="payment_amt" property="paymentAmt" />
+        <result column="payment_balance" property="paymentBalance" />
+    </resultMap>
+
+</mapper>