增加推荐业务逻辑

quality-doctor/common/sql_utils.py

+# -*- coding:UTF-8 -*-
+
+
+# 数组转换成逗号分割字符串
+def to_sql_in(data_list):
+    return ','.join(["'%s'" % item for item in data_list])
\ No newline at end of file

quality-doctor/dao/recommend_product_dao.py

+from db.mod_db import Database
+from common.sql_utils import to_sql_in
+
+
+class qualificationsProductDao:
+    def __init__(self, db=None):
+        if db is None:
+            self.dataBase = Database()
+        else:
+            self.dataBase = db
+    def get_recommend(self,product_list):
+        print("select * from ent_recommend_product join ent_product_comments on "
+                                       "ent_recommend_product.recommendation_business_code = ent_product_comments.product where qualification_comments in (%s)" % to_sql_in(product_list))
+        return self.dataBase.sqlResult("select * from ent_recommend_product join ent_product_comments on "
+                                       "ent_recommend_product.recommendation_business = ent_product_comments.product where qualification_comments in (%s)" % to_sql_in(product_list))
+
+    def random_recommend(self):
+        return self.dataBase.sqlResult("select * from ent_product_comments where status = 1 order by rand() limit 4")
\ No newline at end of file

quality-doctor/main.py

@@ -32,4 +32,4 @@ def RecommendationBusinessMain():
         return result
 
 if __name__ == '__main__':
-    server.run(debug=True,host='0.0.0.0',port=8080)
\ No newline at end of file
+    server.run(debug=True,host='0.0.0.0',port=8081)
\ No newline at end of file

quality-doctor/service/recommend_info.py

 from dao.ent_qualification import qualificationsDao
+from dao.recommend_product_dao import qualificationsProductDao
 
 qualificationsdao = qualificationsDao()
+qualificationsproductdao = qualificationsProductDao()
 def recommend_function(select_data):
     isImports = select_data['isImports']
     if isImports:
@@ -38,16 +40,34 @@ def recommend_function(select_data):
             have_use.append(nust_use_item)
 
     print("have_use============",have_use)
-
+    product_result = []
     result_data = {"isPass": False, "recommend": []}
     #检测不通过
     if len(have_use) != 0:
         result_data['isPass'] = False
-
+        product_result_data = qualificationsproductdao.get_recommend(have_use)
+        for product_item in product_result_data:
+            data = {
+                "id":product_item['product_id'],
+                "name":product_item['product'],
+                "describe":product_item['product_describe'],
+                "price":product_item['product_price']
+            }
+            product_result.append(data)
+        result_data['recommend'] = product_result
     #检测通过
     if len(have_use) == 0:
         result_data['isPass'] = True
-
+        product_result_data = qualificationsproductdao.random_recommend()
+        for product_item in product_result_data:
+            data = {
+                "id":product_item['product_id'],
+                "name":product_item['product'],
+                "describe":product_item['product_describe'],
+                "price":product_item['product_price']
+            }
+            product_result.append(data)
+        result_data['recommend'] = product_result
     return result_data