feat:添加接口

supply-demand-engine-core/src/main/java/com/tzld/piaoquan/sde/service/impl/ContentProfileServiceImpl.java

@@ -144,7 +144,7 @@ public class ContentProfileServiceImpl implements ContentProfileService {
                 "        ,content_title\n" +
                 "        ,type\n" +
                 "        ,type_desc\n" +
-                "FROM    loghubods.content_deconstruction_result_structuring" +
+                "FROM    loghubods.content_deconstruction_result_structuring\n" +
                 "WHERE   dt = (\n" +
                 "            SELECT  MAX(dt)\n" +
                 "            FROM    loghubods.content_deconstruction_result_structuring\n" +
@@ -157,7 +157,8 @@ public class ContentProfileServiceImpl implements ContentProfileService {
                 "                        FROM    loghubods.content_deconstruction_result_structuring\n" +
                 "                    ) \n" +
                 "        ) \n" +
-                "AND     type_desc LIKE CONCAT('%%', '%s','%%');";
+                "AND     type_desc LIKE CONCAT('%%','%s','%%')\n" +
+                ";";
 
         Map<String, List<ContentDescontructionResultVo>> result = new HashMap<>(queryDTO.getKeywords().size());
         for (String keyword : queryDTO.getKeywords()) {
@@ -168,7 +169,6 @@ public class ContentProfileServiceImpl implements ContentProfileService {
                 continue;
             }
 
-            String contentTitle = records.get(0).getString("content_title");
             Map<String, List<Record>> contentIdAndRecordMap = records.stream()
                     .collect(Collectors.groupingBy(i -> i.getString("content_id")));
 
@@ -187,6 +187,7 @@ public class ContentProfileServiceImpl implements ContentProfileService {
                             descriptionInfo.setTypeDesc(i.getString("type_desc"));
                             return descriptionInfo;
                         }).collect(Collectors.toList());
+                String contentTitle = contentRecord.get(0).getString("content_title");
 
                 ContentDescontructionResultVo contentDescontructionResultVo = new ContentDescontructionResultVo();
                 contentDescontructionResultVo.setContentId(contentId);

supply-demand-engine-core/src/main/java/com/tzld/piaoquan/sde/util/OdpsManager.java

@@ -21,6 +21,8 @@ public class OdpsManager {
     private final static String ENDPOINT = "http://service.cn.maxcompute.aliyun.com/api";
 
     public List<Record> query(String sql) {
+        log.info("query sql: {}", sql);
+
         Account account = new AliyunAccount(ACCESSID, ACCESSKEY);
         Odps odps = new Odps(account);
         odps.setEndpoint(ENDPOINT);