订单已处理不在处理

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/dao/mapper/contact/TabContactOrderMapper.java

@@ -23,6 +23,13 @@ public interface TabContactOrderMapper {
     TabContactOrder queryById(Long id);
 
     /**
+     * 根据订单id查询
+     * @param orderId
+     * @return
+     */
+    TabContactOrder queryByOrderId(String orderId);
+
+    /**
      * 通过ID列表查询多条数据
      * @param ids
      * @return

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/contact/impl/ContactOrderServiceImpl.java

@@ -60,6 +60,11 @@ public class ContactOrderServiceImpl implements ContactOrderService {
         if (platformChannelEnum == null) {
             return;
         }
+        TabContactOrder oldContactOrder = contactOrderMapper.queryByOrderId(orderInfoResp.getOrderId());
+        if (oldContactOrder != null) {
+            logger.info("订单已处理,订单id:{}", orderInfoResp.getOrderId());
+            return;
+        }
         Date receiptsDate = orderInfoResp.getReceiptsDate();
         Date contactBeginTime = null;
         String channelCode = platformChannelEnum.getChannelCode();

haoban-manage3-service/src/main/resources/mapper/contact/TabContactOrderMapper.xml

@@ -40,6 +40,13 @@
         WHERE id = #{id}
     </select>
 
+    <select id="queryByOrderId" resultMap="BaseResultMap">
+        SELECT
+        <include refid="Base_Column_List" />
+        FROM tab_contact_order
+        WHERE order_id = #{orderId} and delete_flag = 0
+    </select>
+
     <select id="queryByIds" resultMap="BaseResultMap">
         SELECT
         <include refid="Base_Column_List" />
@@ -56,7 +63,7 @@
         FROM
         tab_contact_order
         WHERE
-        enterprise_id = #{enterpriseId}
+        enterprise_id = #{enterpriseId} and delete_flag = 0
         <if test="search.memberId != null and search.memberId != ''">
             AND member_id = #{search.memberId}
         </if>