fix

apps/import_project/view.py

@@ -35,24 +35,35 @@ def adds():
     tProjectFlows = req_dic['tProjectFlows']
     try:
         obj = TKeyproject(
-            advance_requirement=req_dic["advanceRequirement"],
-            clogging_point=req_dic["cloggingPoint"],
             construction_address=req_dic["constructionAddress"],
-            county=req_dic["county"],
-            deadline_completion=req_dic["deadlineCompletion"],
             floor_space=req_dic["floorSpace"],
             investment_commitment=req_dic["investmentCommitment"],
             investment_entity=req_dic["investmentEntity"],
             leading_department=req_dic["leadingDepartment"],
             policy_statement=req_dic["policyStatement"],
-            project_day=req_dic["projectDay"],
             project_introduce=req_dic["projectIntroduce"],
             project_leader=req_dic["projectLeader"],
             project_name=req_dic["projectName"],
             project_progress=req_dic["projectProgress"],
-            project_status=req_dic["projectStatus"],
-            responsible_department=req_dic["responsibleDepartment"],
-            total_money=req_dic["totalMoney"])
+            total_money=req_dic["totalMoney"],
+            # clogging_point=req_dic["cloggingPoint"],
+            # construction_address=req_dic["constructionAddress"],
+            # county=req_dic["county"],
+            # deadline_completion=req_dic["deadlineCompletion"],
+            # floor_space=req_dic["floorSpace"],
+            # investment_commitment=req_dic["investmentCommitment"],
+            # investment_entity=req_dic["investmentEntity"],
+            # leading_department=req_dic["leadingDepartment"],
+            # policy_statement=req_dic["policyStatement"],
+            # project_day=req_dic["projectDay"],
+            # project_introduce=req_dic["projectIntroduce"],
+            # project_leader=req_dic["projectLeader"],
+            # project_name=req_dic["projectName"],
+            # project_progress=req_dic["projectProgress"],
+            # project_status=req_dic["projectStatus"],
+            # responsible_department=req_dic["responsibleDepartment"],
+            # total_money=req_dic["totalMoney"]
+            )
         db.session.add(obj)
         db.session.commit()
         project_id = obj.id
@@ -64,24 +75,28 @@ def adds():
                 process_schedule=i["processSchedule"],
                 project_id=project_id,
                 start_time=i["startTime"],
-                status=i["status"])
+                # status=i["status"]
+            )
             db.session.add(flow_obj)
             db.session.commit()
             flow_id = flow_obj.id
             print(flow_id)
 
-            if len(i) == 14 and i["tProjectFlowStopList"]:
-                flow_stop_li = i["tProjectFlowStopList"]
-                for flow_stop in flow_stop_li:
-                    stop_obj = TProjectFlowStop(
-                        f_id=flow_id,
-                        content=flow_stop["content"],
-                        department=flow_stop["department"],
-                        requirements=flow_stop["requirements"],
-                        success_time=flow_stop["successTime"]
-                    )
-                    db.session.add(stop_obj)
-                    db.session.commit()
+            try:
+                if i["tProjectFlowStopList"]:
+                    flow_stop_li = i["tProjectFlowStopList"]
+                    for flow_stop in flow_stop_li:
+                        stop_obj = TProjectFlowStop(
+                            f_id=flow_id,
+                            content=flow_stop["content"],
+                            department=flow_stop["department"],
+                            requirements=flow_stop["requirements"],
+                            success_time=flow_stop["successTime"]
+                        )
+                        db.session.add(stop_obj)
+                        db.session.commit()
+            except:
+                continue
 
         record_log(token, "项目台账新增了{}".format(req_dic['projectName']))
         return jsonify(msg="操作成功", code=200)