修改bug

liquidnet-bus-do/liquidnet-service-kylin-do/src/main/resources/com.liquidnet.service.kylin.mapper/KylinOrderTicketsMapper.xml

@@ -147,8 +147,7 @@
 
     </select>
     <select id="getUserSellDetail" parameterType="String" resultType="java.util.Map">
-    /*DATE_FORMAT(o.created_at,'%Y-%m-%d %H:%i:%s')*/
-    select o.user_mobile as 'mobile',o.order_tickets_id as 'orderId',(o.number-refund_number) as 'number',o.created_at as 'createTime' from kylin_order_tickets as o
+    select o.user_mobile as 'mobile',o.order_code as 'orderId',(o.number-refund_number) as 'number',o.created_at as 'createTime' from kylin_order_tickets as o
 		LEFT JOIN kylin_order_ticket_status as s ON o.order_tickets_id=s.order_id
 		LEFT JOIN kylin_order_ticket_relations as r on o.order_tickets_id=r.order_id
     where  r.agent_id=#{agentId} and s.pay_status='1' and r.ticket_id=#{ticketId} and (o.number-refund_number)>0

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/smile/SellDataInfoImpl.java

@@ -13,10 +13,13 @@ import com.liquidnet.service.smile.entity.SmileUser;
 import com.liquidnet.service.smile.mapper.SmileUserMapper;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
+import org.bson.Document;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.mongodb.core.MongoTemplate;
+import org.springframework.data.mongodb.core.convert.MongoConverter;
 import org.springframework.data.mongodb.core.query.Criteria;
 import org.springframework.data.mongodb.core.query.Query;
+import org.springframework.data.mongodb.core.query.Update;
 import org.springframework.stereotype.Service;
 
 import java.math.BigDecimal;
@@ -46,6 +49,9 @@ public class SellDataInfoImpl {
     private KylinOrderTicketsMapper orderTicketsMapper;
     @Autowired
     private MongoTemplate mongoTemplate;
+    @Autowired
+    private MongoConverter mongoConverter;
+
 
     public static void main(String[] args) {
     }
@@ -112,11 +118,16 @@ public class SellDataInfoImpl {
                             smileSellDataVO.setUpdateTime(LocalDateTime.now());
                             //redis 里面放入
                             redisDataSourceUtil.getRedisSweetUtil().set(SmileRedisConst.SELL_DATA.concat(smileUser.getUid()).concat(performanceId), smileSellDataVO);
+                            Query query = Query.query(Criteria.where("sellDataId").is(smileSellDataVO.getSellDataId()));
+                            Document document = (Document)mongoConverter.convertToMongoType(smileSellDataVO);
+                            Update update = Update.fromDocument(document);
+                            mongoTemplate.upsert(query, update, SmileSellDataVO.class, SmileSellDataVO.class.getSimpleName());
+/*
                             if(mongoTemplate.exists(Query.query(Criteria.where("sellDataId").is(smileSellDataVO.getSellDataId())), SmileSellDataVO.class, SmileSellDataVO.class.getSimpleName())){
                                 mongoTemplate.remove(Query.query(Criteria.where("sellDataId").is(smileSellDataVO.getSellDataId())), SmileSellDataVO.class, SmileSellDataVO.class.getSimpleName());
                             }
                             //mongodb 里面放入
-                            mongoTemplate.insert(smileSellDataVO, SmileSellDataVO.class.getSimpleName());
+                            mongoTemplate.insert(smileSellDataVO, SmileSellDataVO.class.getSimpleName());*/
                         }
 
                     }
@@ -138,7 +149,11 @@ public class SellDataInfoImpl {
        smileSellDataDetailVO.setDataId(agentId+ticketId);
        smileSellDataDetailVO.setList(list);
        // mongodb
-       mongoTemplate.insert(smileSellDataDetailVO, SmileSellDataDetailVO.class.getSimpleName());
+       Query query = Query.query(Criteria.where("dataId").is(smileSellDataDetailVO.getDataId()));
+       Document document = (Document)mongoConverter.convertToMongoType(smileSellDataDetailVO);
+       Update update = Update.fromDocument(document);
+       mongoTemplate.upsert(query, update, SmileSellDataDetailVO.class, SmileSellDataDetailVO.class.getSimpleName());
+      /* mongoTemplate.insert(smileSellDataDetailVO, SmileSellDataDetailVO.class.getSimpleName());*/
    }
 
     /**