提交更新异常状态的接口

app/cross_eva_views.py

@@ -58,5 +58,10 @@ def cross_problems_detail_api():
     return query_cross_examine_records_detail(request.json)
 
 
+@app.route('/api/update_cross_examine_state', methods=['POST'])
+def update_cross_examine_record_state_api():
+    return update_cross_examine_record_state(request.json)
+
+
 if __name__ == '__main__':
     pass

app/cross_evaluate_worker.py

@@ -369,3 +369,40 @@ def query_cross_examine_records_detail(params):
     res['data'] = days_records
     return json.dumps(res, ensure_ascii=False)
 
+
+def update_cross_examine_record_state(params):
+    crossid = check_param(params, 'crossid')
+    if not crossid:
+        return json.dumps(make_common_res(1, '缺少crossid， 请刷新后重试'))
+    nodeid = check_param(params, 'nodeid')
+    if not nodeid:
+        return json.dumps(make_common_res(2, '缺少nodeid， 请刷新后重试'))
+    area_id = check_param(params, 'area_id')
+    if not area_id:
+        return json.dumps(make_common_res(3, '缺少area_id， 请刷新后重试'))
+    userid = check_param(params, 'userid')
+    if not userid:
+        return json.dumps(make_common_res(4, '缺少userid， 请刷新后重试'))
+    area_list = db_user.query_user_areas(userid)
+    if not area_list or len(area_list) < 1:
+        return json.dumps(make_common_res(5, '用户信息异常'))
+    area_list = [int(row['area_id']) for row in area_list]
+    if int(area_id) not in area_list:
+        return json.dumps(make_common_res(6, '用户信息异常'))
+    final_state = check_param(params, 'final_state')
+    if not final_state:
+        return json.dumps(make_common_res(7, '缺少需要修改的状态， 请刷新后重试'))
+    if int(final_state) not in [4, 5]:
+        return json.dumps(make_common_res(8, '最终状态信息异常，清检查后重试'))
+    first_date = check_param(params, 'first_date')
+    if not first_date:
+        return json.dumps(make_common_res(9, '缺少开始时间， 请刷新后重试'))
+    time_range = check_param(params, 'time_range')
+    if not time_range:
+        return json.dumps(make_common_res(10, '缺少时段范围， 请刷新后重试'))
+    tp_start = int(str(time_range.split('-')[0]).split(':')[0]) * 100 + int(str(time_range.split('-')[0]).split(':')[1])
+    ret = db_cross.update_cross_examine_record_state(crossid, first_date, tp_start, final_state)
+    if ret == 1:
+        return json.dumps(make_common_res(0, 'ok'))
+    return json.dumps(make_common_res(11, '修改失败，请检查后重试'))
+

app/db_cross_delay.py

@@ -35,4 +35,10 @@ class CrossDbHelper(TableDbHelperBase):
         sql = """
             select * from cross_doctor_matedata.cross_phase_problems_record where crossid = '%s' and start_hm = '%s' and first_date <= %s and (end_date >= '%s' or end_date is null)
         """ % (crossid, start_hm, first_date, end_date)
-        return self.do_select(sql)
+        return self.do_select(sql)
+
+    def update_cross_examine_record_state(self, crossid, first_date, start_hm, state):
+        sql = """
+            update cross_doctor_matedata.cross_phase_problems_record set state = '%s' where crossid = '%s' and first_date = '%s' and start_hm = %s
+        """ % (state, crossid, first_date, start_hm)
+        return self.do_update(sql)