new searchfile

databaseConn/mysqlOperation.py

@@ -72,5 +72,5 @@ def concatSql(sql,**kwargs):
     return sql+' where '+temp[:-4]
 
 if __name__ == '__main__':
-    print(mysqlInfo('test1'))
-    #print(execmysl('qa',"select sku_name from kdsp.t_sku_info where  sku_name like '%%口红%%'"))
\ No newline at end of file
+    #print(mysqlInfo('test1'))
+    print(execmysl('qa',"select * from kdsp.t_brands limit 1"))
\ No newline at end of file

recommend/cid3brandname_group_recommend.py

@@ -185,8 +185,8 @@ if __name__ == '__main__':
     #print(clickTopic('179240378044417'))
     #print(allrun())
     gid='479610b6-f346-474f-8d3a-e4de04db8f6e-002'
-    gid1='479610b6-f346-474f-8d3a-e4de04db8f6e-001'
-    print('批次:',backBatch(gid,isuuid=0))
+    gid1='2f2a0320-210e-4e47-b814-a8b564dc2332'
+    #print('批次:',backBatch(gid,isuuid=0))
     print("***"*50)
     print('批次:',backBatch(gid1,isuuid=1))
     #skuno='201782177569280'

recommend/payTopic.py

+import requests
+
 from recommend import *
 
 
@@ -10,22 +12,26 @@ def dealData(t):
     return temp
 
 
-def payRecall(skuno,num=100):
+def payRecall(skuno,num=50):
     temp=defaultdict(list)
     print("支付图关联表召回start")
     pay_product_change_redis=pay_product_redis.strip().format(sku_no=skuno)
     #print(pay_product_change_redis)
     pay_result=getRedisValue(pay_product_change_redis)
+    #print(pay_result)
+
     from recommend.publicFunc import skuinfo
     skuno_info=skuinfo(skuno)
     pay_skus=dealData(pay_result.get(pay_product_change_redis))
+    print(pay_skus)
     if pay_result :
-        skuss_change_sql=concatSql(skuinfo_sql,**{"sku_no":pay_skus}) +" and cid3!='{}'".format(skuno_info.get('cid3'))
+        skuss_change_sql=concatSql(skuinfo_sql,**{"sku_no":pay_skus}) +" and cid3!='{}'".format(skuno_info.get('cid3')) \
+                         +" and status=3 and stock>0 order by sku_no"
         skdss=execmysl('nearly',skuss_change_sql)
         if not skdss.empty :
             final_skus=skdss['sku_no'].to_list()
             temp['70011']=final_skus[:num]
-
+            print(final_skus[:num])
             print("支付图关联表召回stop",len(final_skus),skuss_change_sql)
             #return temp
 
@@ -34,19 +40,22 @@ def payRecall(skuno,num=100):
     order_result=getRedisValue(order_product_change_redis)
     order_skus=dealData(order_result.get(order_product_change_redis))
     if order_result :
-        skuss_change_sql=concatSql(skuinfo_sql,**{"sku_no":order_skus}) +' and cid3!={}'.format(skuno_info.get('cid3'))
+        skuss_change_sql=concatSql(skuinfo_sql,**{"sku_no":order_skus}) +' and cid3!={}'.format(skuno_info.get('cid3'))  +" and status=3 and stock>0 order by sku_no"
         skdss=execmysl('nearly',skuss_change_sql)
         if not skdss.empty :
             final_skus=skdss['sku_no'].to_list()
+            #print("redis===",final_skus)
             chaji=subtraction(final_skus,temp.get('70011'))
             temp['70012']=chaji[:num]
+            #print( temp['70012'])
             print("下单图关联表召回stop",len(final_skus),skuss_change_sql)
             #return temp
     print("加购图关联表召回start",'**'*50)
+
     product_change_redis=product_redis.format(sku_no=skuno).strip()
     product_result=getRedisValue(product_change_redis)
     if product_result :#and len(product_result.get(product_change_redis))>=num:
-        skuss_change_sql=concatSql(skuinfo_sql,**{"sku_no":product_result.get(product_change_redis)}) +' and cid3!={}'.format(skuno_info.get('cid3'))
+        skuss_change_sql=concatSql(skuinfo_sql,**{"sku_no":product_result.get(product_change_redis)}) +' and cid3!={}'.format(skuno_info.get('cid3')) +" and status=3 and stock>0 order by sku_no"
         skdss=execmysl('nearly',skuss_change_sql)
         if not skdss.empty :#and skdss.shape>num:
             final_skus=skdss['sku_no'].to_list()
@@ -60,7 +69,7 @@ def payRecall(skuno,num=100):
     als_correlation_result=getRedisValue(als_correlation_change_redis)
 
     if als_correlation_result :#and len(als_correlation_result.get(als_correlation_change_redis))>=num:
-        skuss_change_sql=concatSql(skuinfo_sql,**{"sku_no":als_correlation_result.get(als_correlation_change_redis)}) +' and cid3!={}'.format(skuno_info.get('cid3'))
+        skuss_change_sql=concatSql(skuinfo_sql,**{"sku_no":als_correlation_result.get(als_correlation_change_redis)}) +' and cid3!={}'.format(skuno_info.get('cid3')) +" and status=3 and stock>0"
         skdss=execmysl('nearly',skuss_change_sql)
         if not skdss.empty: #and skdss.shape>num:
             final_skus=skdss['sku_no'].to_list()
@@ -100,9 +109,10 @@ def payDapanbu(skuno):
 def all(skuno,uuid):
     temp=defaultdict()
     sku_temp=[]
-    #back_recall_skus=backRecall(uuid)
+    back_recall_skus=backRecall(uuid)
+    print("上一批次数据:",back_recall_skus)
     #temp.append(back_recall_skus)
-    pay_recall_skus=payRecall(skuno,num=100)
+    pay_recall_skus=payRecall(skuno,num=50)
     temp.update(pay_recall_skus)
 
     dapan_result=payDapanbu(skuno)
@@ -141,9 +151,10 @@ recall_reason=70011
 
 if __name__ == '__main__':
     skuno='179240378044417'
-    uuid='1e51cf78-e12c-4f17-9d5b-b25404303a66-5'
-    t=all(skuno,uuid)
+    uuid='2f2a0320-210e-4e47-b814-a8b564dc2332'
+    #t=all(skuno,uuid)
     print(t)
+    #requests.post().t
     #print(payDapanbu(skuno))
     #print(deal_all())
     #print(checkresult())

search/searchCompare.py

@@ -5,7 +5,7 @@ from search.abSearch import requestsend
 
 def fileData():
     fcolums=['id','query','expect_cid3','commit']
-    filename=os.path.join(data_file_path,'Top1000关键词测评.xlsx')
+    filename=os.path.join(data_file_path,'Top1-1000关键词测评3.xlsx')
     df=readRenameColums(filename,fcolums)
     df['commit']=df['commit'].fillna(9999)
     return df

tools/publicFun.py

@@ -5,7 +5,7 @@ def genUuidDeviceid():
     :return:
     """
     uuid,deviced=codeuuid.uuid4().urn.split(':')[-1],codeuuid.uuid4().urn.split(':')[-1]
-    uuid='94d0e54c-9564-44bd-8c7e-abd8308081af'
+    uuid='87f491d2-527f-4386-9bb1-3d67017cb6d8'
     deviced='guiqiuyue_'+str(deviced)
     return uuid,deviced