hj

entprofile/dao/re_status_dao.py

@@ -14,5 +14,8 @@ class rec_status_Dao:
             self.dataBase = DataBase()
         else:
             self.dataBase = db
-    def select_sql_1(self,recommend_id,status_name,remark):
-        return self.dataBase.update('update tj_recommend_do_status set status_name = "%s",remark = "%s" where recommend_id = "%s"' % (status_name,remark,recommend_id),None)
\ No newline at end of file
+    def select_sql_1(self,recommend_id,status_name):
+        return self.dataBase.update('update tj_recommend_do_status set status_name = "%s" where recommend_id = "%s"' % (status_name,recommend_id),None)
+
+    def select_sql_2(self,recommend_id,remark):
+        return self.dataBase.update('update tj_recommend_do_status set remark = "%s" where recommend_id = "%s"' % (remark,recommend_id),None)
\ No newline at end of file

entprofile/main.py

@@ -15,7 +15,7 @@ from service.company_basic import CompanyBase
 from service.Image_status import imageInfo
 from service.trade import selectcyle,insertcycle
 from service.GetImageFromSql import getImageInfo
-from service.rec_status import tj_rec_status
+from service.rec_status import tj_rec_status,tj_rec_remark
 from service.online_GetLicenseImage import getlicenceInfo
 from service.tf_member import gaoguan,gudong,nianbao
 from service.talking import talking,talking_product
@@ -63,6 +63,7 @@ businessApi(server)
 assigned_opportunity(server)
 app_website(server)
 consultingInfo(server)
+tj_rec_remark(server)
 
 
 #基本信息

entprofile/service/rec_status.py

@@ -13,12 +13,12 @@ from flask import request
 
 
 #更新状态表的结果
-def WriteRecStatusToSql(recommend_id,status_name,remark):
+def WriteRecStatusToSql(recommend_id,status_name):
     # json写入数据库
     db_info = DataBase()
     try:
         rec_status = rec_status_Dao()
-        rec_status.select_sql_1(recommend_id,status_name,remark)
+        rec_status.select_sql_1(recommend_id,status_name)
     except Exception as e:
 
         print(e)
@@ -26,6 +26,22 @@ def WriteRecStatusToSql(recommend_id,status_name,remark):
     # 关闭数据库连接
     # db_info.close()
     return "状态表已更新"
+
+#更新状态表的结果
+def WriteRecRemarksToSql(recommend_id,remarks):
+    # json写入数据库
+    db_info = DataBase()
+    try:
+        rec_status = rec_status_Dao()
+        rec_status.select_sql_2(recommend_id,remarks)
+    except Exception as e:
+
+        print(e)
+        db_info.roll_back()
+    # 关闭数据库连接
+    # db_info.close()
+    return "状态表备注已更新"
+
 def tj_rec_status(server):
     @server.route('/gsb/api/tj_rec_status', methods=['POST'])
     def tj_rec_status():
@@ -37,8 +53,22 @@ def tj_rec_status(server):
                 print(requestdata)
                 recommend_id = requestdata.get('recommendId')
                 status_name = requestdata.get('stateName')
-                remark = requestdata.get('remark')
-                WriteRecStatusToSql(recommend_id, status_name,remark)
+                WriteRecStatusToSql(recommend_id, status_name)
+                return json.dumps({"status": 0, "msg": "成功", "data": recommend_id}, ensure_ascii=False)
+            except:
+                return json.dumps({"status": -1, "msg": "失败", "data": {}}, ensure_ascii=False)
+
+def tj_rec_remark(server):
+    @server.route('/gsb/api/statusRemarks', methods=['POST'])
+    def tj_rec_remark():
+        print("接口调用--------更新状态表")
+        if request.method == 'POST':
+            try:
+                # requestdata = request.values
+                requestdata = request.json
+                recommend_id = requestdata.get('recommendId')
+                remarks = requestdata.get('remarks')
+                WriteRecRemarksToSql(recommend_id, remarks)
                 return json.dumps({"status": 0, "msg": "成功", "data": recommend_id}, ensure_ascii=False)
             except:
                 return json.dumps({"status": -1, "msg": "失败", "data": {}}, ensure_ascii=False)