1:新增MQ 推送订单到客服 开发中

common/pom.xml

@@ -43,6 +43,11 @@
         </dependency>
 
         <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-amqp</artifactId>
+        </dependency>
+
+        <dependency>
             <groupId>org.apache.httpcomponents</groupId>
             <artifactId>httpclient</artifactId>
             <version>4.3.5</version>

common/src/main/java/com/jumeirah/common/mq/Queue.java

+package com.jumeirah.common.mq;
+
+
+import com.jumeirah.common.entity.Stroke;
+import org.springframework.amqp.core.AmqpTemplate;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author: JJww
+ * @Date:2019-07-19
+ */
+
+@Component
+public class Queue {
+
+    @Autowired
+    private AmqpTemplate rabbitTemplate;
+
+    @Value("${spring.rabbitmq.user-queue-name}")
+    private String userQueueName;
+
+    @Value("${spring.rabbitmq.order-queue-name}")
+    private String orderQueueName;
+
+
+    /**
+     * 推送订单状态到客服系统
+     *
+     * @param orderInteractionModel
+     */
+    public void pushOrder(Stroke stroke) {
+        rabbitTemplate.convertAndSend(orderQueueName, stroke);
+    }
+
+    /**
+     * 禁用用户
+     *
+     * @param userId
+     */
+    public void disableUserQueue(String userId) {
+        rabbitTemplate.convertAndSend(userQueueName, userId);
+    }
+
+
+}
\ No newline at end of file

common/src/main/java/com/jumeirah/common/service/impl/StrokeServiceImpl.java

@@ -6,6 +6,7 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.jumeirah.common.entity.Stroke;
 import com.jumeirah.common.enums.StrokeStatusEnum;
 import com.jumeirah.common.mapper.StrokeMapper;
+import com.jumeirah.common.mq.Queue;
 import com.jumeirah.common.param.McStrokePageParam;
 import com.jumeirah.common.param.McStrokePaymentPageParam;
 import com.jumeirah.common.param.StrokePageParam;
@@ -35,12 +36,19 @@ import org.springframework.transaction.annotation.Transactional;
 public class StrokeServiceImpl extends BaseServiceImpl<StrokeMapper, Stroke> implements StrokeService {
 
     @Autowired
+    private Queue queue;
+
+    @Autowired
     private StrokeMapper strokeMapper;
 
-    @Transactional(rollbackFor = Exception.class)
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public boolean saveStroke(Stroke stroke) throws Exception {
-        return super.save(stroke);
+        final boolean save = super.save(stroke);
+        if (save) {//推送订单到客服系统
+            queue.pushOrder(stroke);
+        }
+        return save;
     }
 
     @Transactional(rollbackFor = Exception.class)
@@ -93,7 +101,7 @@ public class StrokeServiceImpl extends BaseServiceImpl<StrokeMapper, Stroke> imp
         Page<StrokeQueryVo> page = new PageInfo<>(strokePageParam, OrderItem.desc("s.create_time"));
         JwtToken jwtToken = (JwtToken) SecurityUtils.getSubject().getPrincipal();
         // 查询已完成 需要额外查询已取消状态
-        if (strokePageParam.getStatus().equals(StrokeStatusEnum.COMPLETED.getCode())){
+        if (strokePageParam.getStatus().equals(StrokeStatusEnum.COMPLETED.getCode())) {
             IPage<StrokeQueryVo> iPage = strokeMapper.getStrokePageListWithFinish(page, strokePageParam, jwtToken.getUserId());
             return new Paging<StrokeQueryVo>(iPage);
         }

config/src/main/resources/config/application-dev.yml

@@ -25,6 +25,14 @@ spring:
     password: 123456
     port: 6379
 
+  rabbitmq:
+    host: 47.99.47.225
+    port: 5672
+    username: root
+    password: root
+    user-queue-name: disable.user.dev
+    order-queue-name: push.order
+
 # 打印SQL语句和结果集，本地开发环境可开启，线上注释掉
 mybatis-plus:
   configuration:

customer-service/src/main/java/com/ym/im/entity/Stroke.java

+package com.ym.im.entity;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.sql.Timestamp;
+
+/**
+ * 行程表
+ *
+ * @author wei
+ * @since 2020-09-29
+ */
+@Data
+@Accessors(chain = true)
+public class Stroke implements Serializable {
+    private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty("主键ID")
+    private Long id;
+
+    @ApiModelProperty("出发城市id")
+    private Long cityOutsetId;
+
+    @ApiModelProperty("逻辑删除，0：未删除，1：已删除")
+    private Integer deleted;
+
+    @ApiModelProperty("出发城市名称")
+    private String cityOutsetName;
+
+    @ApiModelProperty("到达城市id")
+    private Long cityArriveId;
+
+    @ApiModelProperty("到达城市名称")
+    private String cityArriveName;
+
+    @ApiModelProperty("人数")
+    private Integer peopleNum;
+
+    @ApiModelProperty("飞机型号ID")
+    private Long plainTypeId;
+
+    @ApiModelProperty("出发时间")
+    private Timestamp outsetTime;
+
+    @ApiModelProperty("返程时间")
+    private Timestamp returnTime;
+
+    @ApiModelProperty("行程类型，0-单程，1-往返行程，2-货运，3-医疗")
+    private Integer type;
+
+    @ApiModelProperty("状态，0-审核中，1-进行中，2-已完成，99-取消")
+    private Integer status;
+
+    @ApiModelProperty("创建时间")
+    private Timestamp createTime;
+
+    @ApiModelProperty("更新时间")
+    private Timestamp updateTime;
+
+    @ApiModelProperty("付款时间")
+    private Timestamp userRechargeTime;
+
+    @ApiModelProperty("货物名称")
+    private String goodsName;
+
+    @ApiModelProperty("货物体积（长*宽*高） 单位：CM，例如：100*102*120")
+    private String goodsSize;
+
+    @ApiModelProperty("货物重量，单位：吨")
+    private String goodsWeight;
+
+    @ApiModelProperty("病人疾病名称")
+    private String diseaseName;
+
+    @ApiModelProperty("病人病情诊断书")
+    private String medicalCertificateUrl;
+
+    @ApiModelProperty("配备器械（格式：1,2,3）逗号分隔")
+    private String instruments;
+
+    @ApiModelProperty("医护人员，0-医生，1-护士，2-护工（格式：0,1,2）逗号分隔")
+    private String medicalPersons;
+
+    @ApiModelProperty("备注")
+    private String remarks;
+
+    @ApiModelProperty("价格")
+    private BigDecimal money;
+
+    @ApiModelProperty("用户ID")
+    private Long userId;
+
+    @ApiModelProperty("出发机场名称")
+    private String outsetAirportName;
+
+    @ApiModelProperty("到达机场名称")
+    private String arriveAirportName;
+
+    @ApiModelProperty("返程飞机型号ID")
+    private Long arrivePlainTypeId;
+
+    @ApiModelProperty("返程出发机场名称")
+    private String backOutsetAirportName;
+
+    @ApiModelProperty("返程到达机场名称")
+    private String backArriveAirportName;
+
+    @ApiModelProperty("商家id")
+    private Long mcId;
+
+    @ApiModelProperty("用户选择机型")
+    private String choosePlainType;
+
+    @ApiModelProperty("付款状态，0-未付款，1-付款中，2-已付款，3-退款中，99-已退款")
+    private Integer paymentStatus;
+
+    @ApiModelProperty("审核状态,0审核中,1审核通过,2审核未通过")
+    private Integer auditStatus;
+
+    @ApiModelProperty("用户充值金额")
+    private BigDecimal userRechargeMoney;
+
+    @ApiModelProperty("用户充值银行名称")
+    private String userRechargeBank;
+
+    @ApiModelProperty("用户充值账户名")
+    private String userRechargeName;
+
+    @ApiModelProperty("用户充值卡号")
+    private String userRechargeBankNumber;
+
+    @ApiModelProperty("用户充值截图证据,  传入数组")
+    private String userRechargeCredentialsUrl;
+
+    @ApiModelProperty("是否是优惠调机，0-否，1-是")
+    private Boolean isDiscount;
+
+}