|
|
@@ -628,11 +628,22 @@ async def send_emergency_plan_task_by_yzy(
|
|
|
if row_exists is not None:
|
|
|
continue
|
|
|
|
|
|
+ # 通过预案人员管理匹配负责人
|
|
|
+ user_id = 0
|
|
|
+ user_name = ''
|
|
|
+ contact_row = db.query(EmergencyContactInfo).filter(EmergencyContactInfo.unit_id == dept_id).first()
|
|
|
+ yzy_account = contact_row.yue_gov_ease_phone
|
|
|
+ nick_name = contact_row.contact_name
|
|
|
+
|
|
|
+ yzy_user_row = db.query(YzyOrgUserEntity).filter(YzyOrgUserEntity.telephonenumber == yzy_account).first()
|
|
|
+ yzy_user_id = yzy_user_row.userid
|
|
|
+
|
|
|
+
|
|
|
# 通过通讯录匹配相关负责人
|
|
|
- user_row = db.query(SysUser).filter(SysUser.user_id == 1).first()
|
|
|
- user_id = user_row.user_id
|
|
|
- user_name = user_row.user_name
|
|
|
- nick_name = user_row.nick_name
|
|
|
+ # user_row = db.query(SysUser).filter(SysUser.user_id == 1).first()
|
|
|
+ # user_id = user_row.user_id
|
|
|
+ # user_name = user_row.user_name
|
|
|
+ # nick_name = user_row.nick_name
|
|
|
yzy_user_id = "eb4kehgy6wj4qn0jhx1dk6" # 暂时写死梦梅的账号
|
|
|
yzy_content = "{}，您好！《{}》现已全面启动，特此通知您单位迅速响应，全力做好预案工作要点：{}".format(row.dept_name, plan_info['plan_name'], row.content)
|
|
|
|
