332 lines
17 KiB
Python
332 lines
17 KiB
Python
# -*- coding:utf-8 -*-
|
||
"""
|
||
人员当日jira任务、故事状态流转
|
||
"""
|
||
import os, sys
|
||
|
||
file_dir = os.path.dirname(__file__)
|
||
project_dir = os.path.abspath(os.path.join(file_dir, "..", "..", ".."))
|
||
sys.path.append(project_dir)
|
||
|
||
from jira import JIRA
|
||
from base_framework.public_tools.utils import Tools
|
||
from base_framework.public_tools.read_config import ReadConfig
|
||
from base_framework.platform_tools.Message_service.Feishu_api import FeiShuMessage,get_user_name_by_email_prefix,get_feishu_config_value
|
||
from configparser import ConfigParser
|
||
from base_framework.base_config.current_pth import *
|
||
import datetime
|
||
|
||
tools = Tools()
|
||
ReadConfig = ReadConfig(filename=la_config_path)
|
||
FS_INFO = [{"team": "TO", "users": "wuyonggang,xuwenjun,luohong"},
|
||
{"team": "TO-RD", "users": "fengtian,guosongchao,zhaoxiaofang,"
|
||
"zhuliang,majincheng,gaozhijun,liuxuegang,"
|
||
"zhangxiong"},
|
||
{"team": "USER-FE", "users": "zhaofei,liuxinlin,qingchen,yefei,xiangming,jianghao,jianglingmin,xuchangle,"
|
||
"libaicheng,gouyuheng,jixiang.dong,baiyang01"}
|
||
]
|
||
|
||
|
||
class JiraApi:
|
||
def __init__(self):
|
||
self.jira = JIRA(server='https://jira.bg.huohua.cn/',
|
||
basic_auth=("wuyonggang", "Mima@123"))
|
||
|
||
def close_jira_subtask(self, user_name):
|
||
"""
|
||
功能: 关闭指定人员名下当天结束的子任务
|
||
请求参数 user_name （指定人员jira登录名，type: list）
|
||
"""
|
||
bad_name = []
|
||
right_name = []
|
||
for j in user_name:
|
||
if j not in ReadConfig.get_sections():
|
||
bad_name.append(j)
|
||
elif j in ReadConfig.get_sections():
|
||
right_name.append(j)
|
||
success = []
|
||
false = []
|
||
today_time = tools.get_format_date(r_type=1)
|
||
work_start_time = datetime.datetime.strptime('{0} 10:00:00'.format(today_time), '%Y-%m-%d %H:%M:%S')
|
||
for name in right_name:
|
||
jira = JIRA(server='https://jira.bg.huohua.cn/', basic_auth=(name, ReadConfig.get_value(name, 'password')))
|
||
jql = 'project = HHC AND issuetype = 子任务 AND status in (重新打开, 启动, 需求池, 暂停, 计划, 产品需求设计,' \
|
||
' 产品需求内审, 需求评审, 排期, 执行, 开发, 待测试, QA测试, SIM验证, 验证中, 待办, 处理中, 关闭) AND resolution = Unresolved' \
|
||
' AND (QA in ({0}) OR assignee in ({1})) ORDER BY priority DESC, updated DESC'.format(name,name)
|
||
issues = jira.search_issues(jql, fields='')
|
||
# if len(issues) == 0: break
|
||
not_need_closed = 0
|
||
for i in issues:
|
||
s = list(jira.transitions(i))
|
||
close_status_id = [x['id'] for x in s if x['name'] == '关闭']
|
||
if str(i.fields.status) == '处理中':
|
||
if i.fields.aggregatetimeestimate != None:
|
||
if i.fields.aggregatetimeestimate > 28800:
|
||
jira.add_worklog(i, timeSpent='7', started=work_start_time)
|
||
elif 0 < i.fields.aggregatetimeestimate <= 28800:
|
||
jira.add_worklog(i, timeSpent='{0}'.format(i.fields.aggregatetimeestimate / 3600),
|
||
started=work_start_time)
|
||
else:
|
||
jira.add_worklog(i, timeSpent='8', started=work_start_time)
|
||
if str(i.fields.status) == '处理中' and str(i.fields.customfield_13406) == today_time:
|
||
jira.transition_issue(i, int(close_status_id[0]))
|
||
else:
|
||
not_need_closed += 1
|
||
issues2 = jira.search_issues(jql, fields='')
|
||
if not_need_closed == len(issues2):
|
||
success.append(name)
|
||
else:
|
||
false.append(name)
|
||
return "{0}今日结束的子任务已关闭成功； {1}今日结束的子任务关闭失败; {2}没有进行账号配置".format(success, false, bad_name)
|
||
|
||
def start_jira_subtask(self, user_name):
|
||
"""
|
||
功能: 将待开始为今天的子任务状态流转为“处理中”
|
||
请求参数 user_name （指定人员jira登录名，type: list）
|
||
"""
|
||
bad_name = []
|
||
right_name = []
|
||
for j in user_name:
|
||
if j not in ReadConfig.get_sections():
|
||
bad_name.append(j)
|
||
elif j in ReadConfig.get_sections():
|
||
right_name.append(j)
|
||
success = []
|
||
false = []
|
||
for name in right_name:
|
||
jira = JIRA(server='https://jira.bg.huohua.cn/', basic_auth=(name, ReadConfig.get_value(name, 'password')))
|
||
jql = 'project = HHC AND issuetype = 子任务 AND status in (重新打开, 启动, 需求池, 暂停, 计划, 产品需求设计, 产品需求内审, 需求评审, ' \
|
||
'排期, 执行, 开发, 待测试, QA测试, SIM验证, 验证中, 待办, 关闭) AND resolution = Unresolved' \
|
||
' AND (QA in ({0}) OR assignee in ({1})) ORDER BY priority DESC, updated DESC'.format(name,name)
|
||
today_time = tools.get_format_date(r_type=1)
|
||
issues = jira.search_issues(jql, fields='')
|
||
# if len(issues) == 0: break
|
||
not_need_update = 0
|
||
for i in issues:
|
||
s = list(jira.transitions(i))
|
||
start_status_id = [x['id'] for x in s if x['name'] == '处理中']
|
||
if str(i.fields.status) == '待办' and str(i.fields.customfield_12700) == today_time:
|
||
jira.transition_issue(i, int(start_status_id[0]))
|
||
else:
|
||
not_need_update += 1
|
||
issues2 = jira.search_issues(jql, fields='')
|
||
if not_need_update == len(issues2):
|
||
success.append(name)
|
||
else:
|
||
false.append(name)
|
||
return "{0}今日开始的子任务已将状态修改为“处理中”‘； {1}今日开始的子任务状态修改失败; {2}没有进行账号配置".format(success, false, bad_name)
|
||
|
||
def change_story(self, user_name, type):
|
||
"""
|
||
功能: 将提测时间为今天的指定人员名下的故事状态修改至“QA测试”
|
||
请求参数 user_name （指定人员jira登录名，type: list）
|
||
type (故事需要修改至的状态 1：提测日为今天，状态修改至【QA测试】 2：上线日为今天，状态修改至【关闭】)
|
||
"""
|
||
bad_name = []
|
||
right_name = []
|
||
for j in user_name:
|
||
if j not in ReadConfig.get_sections():
|
||
bad_name.append(j)
|
||
elif j in ReadConfig.get_sections():
|
||
right_name.append(j)
|
||
success = []
|
||
false = []
|
||
for name in right_name:
|
||
jira = JIRA(server='https://jira.bg.huohua.cn/', basic_auth=(name, ReadConfig.get_value(name, 'password')))
|
||
jql = "project = HHC AND issuetype = 故事 AND " \
|
||
"status in (重新打开, 启动, 需求池, 暂停, 计划, 产品需求设计, 产品需求内审, 需求评审, 排期, 执行, 开发, 待测试, 验证中, 待办, QA测试, SIM验证, 处理中, 关闭)" \
|
||
" AND resolution = Unresolved AND QA in ({0}) ORDER BY priority DESC, updated DESC".format(name)
|
||
today_time = tools.get_format_date(r_type=1)
|
||
issues = jira.search_issues(jql, fields='')
|
||
# if len(issues) == 0 : break
|
||
x = 0
|
||
need_update = 0
|
||
if type == 1: # 将故事状态一直流转至“QA测试”
|
||
for i in issues:
|
||
if str(i.fields.status) == 'QA测试' or str(i.fields.status) == 'SIM验证': need_update += 1
|
||
if str(i.fields.customfield_10504) == today_time:
|
||
if str(i.fields.status) != 'QA测试' and str(i.fields.status) != 'SIM验证':
|
||
need_update += 1
|
||
for j in range(8):
|
||
jira.transition_issue(i, int(jira.transitions(i)[2]['id']))
|
||
issues_2 = jira.search_issues(jql, fields='') # 重新获取所有故事
|
||
status_now = issues_2[x].fields.status
|
||
print(status_now)
|
||
if str(status_now) == 'QA测试' or str(status_now) == 'SIM验证':
|
||
break
|
||
x += 1
|
||
jql2 = "project = HHC AND issuetype = 故事 AND " \
|
||
"status in (重新打开, 启动, 需求池, 暂停, 计划, 产品需求设计, 产品需求内审, 需求评审, 排期, 执行, 开发, 待测试, 验证中, 待办, 处理中, 关闭)" \
|
||
" AND resolution = Unresolved AND QA in ({0}) ORDER BY priority DESC, updated DESC".format(name)
|
||
issues2 = jira.search_issues(jql2, fields='')
|
||
if len(issues2) == len(issues) - need_update:
|
||
success.append(name)
|
||
else:
|
||
false.append(name)
|
||
elif type == 2: # 直接将故事关闭
|
||
for i in issues:
|
||
if str(i.fields.customfield_10606) == today_time:
|
||
jira.transition_issue(i, int(jira.transitions(i)[1]['id']), comment="已上线") # 将故事修改为关闭状态
|
||
need_update += 1
|
||
issues2 = jira.search_issues(jql, fields='')
|
||
if len(issues2) + need_update == len(issues):
|
||
success.append(name)
|
||
else:
|
||
false.append(name)
|
||
|
||
return "{0}今日的故事已将状态修改成功！； {1}今日的故事状态修改失败; {2}没有进行账号配置".format(success, false, bad_name)
|
||
|
||
def change_jira_status(self, user_name):
|
||
"""
|
||
功能: 判断当前时间是否在下午18:00点以前，来选择打开或关闭【子任务】和【故事】
|
||
请求参数 user_name （指定人员jira登录名，type: list）
|
||
"""
|
||
time_now = tools.get_format_date(r_type=4)
|
||
time_now2 = '{0} 18:00:00'.format(time_now[0:10:1])
|
||
if time_now < '{0} 18:00:00'.format(time_now2):
|
||
a = self.start_jira_subtask(user_name)
|
||
b = self.change_story(user_name, type=1)
|
||
return a + '\n' + b
|
||
elif time_now >= '{0} 18:00:00'.format(time_now2):
|
||
a = self.close_jira_subtask(user_name)
|
||
b = self.change_story(user_name, type=2)
|
||
return a + '\n' + b
|
||
|
||
def query_jira_subtask(self, user_name, begin_date=0, end_date=0):
|
||
"""
|
||
| 功能 | 查询用户对应的jira子任务 |
|
||
| 入参 | user_name | 用户名字 |
|
||
| | begin_date | 开始时间：0-今天，X-未来X天，-X-过去的X天 |
|
||
| | end_date | 开始时间：0-今天，X-未来X天，-X-过去的X天 |
|
||
"""
|
||
b_date = tools.get_format_date(r_type=1, add_days=int(begin_date))
|
||
e_date = tools.get_format_date(r_type=1, add_days=int(end_date))
|
||
jql = "issuetype = 子任务 AND 计划开始时间 <= {} AND 计划结束时间 >= {} AND assignee in ({}) ORDER BY cf[12700] ASC"\
|
||
.format(b_date, e_date, user_name)
|
||
issues = self.jira.search_issues(jql, fields='')
|
||
# print(jql)
|
||
return issues
|
||
# for item in issues:
|
||
# print("{0}:{1}, 当前状态:{2}".format(item.key, item.fields.summary, item.fields.status))
|
||
|
||
def query_jira_by_id(self, jira_id):
|
||
"""
|
||
| 功能 | 跟进jira的id查询具体详情 |
|
||
| 入参 | jira_id | jira的id |
|
||
"""
|
||
jql = "id={}".format(jira_id)
|
||
issues = self.jira.search_issues(jql, fields='')
|
||
if len(issues) == 0:
|
||
raise Exception("根据jira_id未查询到对应的jira信息，请检查....")
|
||
rd = issues[0].fields.assignee.displayName
|
||
qa = issues[0].fields.reporter.displayName
|
||
title = issues[0].fields.summary
|
||
status = issues[0].fields.status
|
||
j_time = issues[0].fields.created
|
||
j_time = j_time[0:10] + ' ' + j_time[11:19]
|
||
return {"jira_rd": rd,
|
||
"jira_qa": qa,
|
||
"jira_title": title,
|
||
"jira_time": j_time,
|
||
"jira_status": str(status)}
|
||
|
||
def query_overdue_issues(self, user_name):
|
||
"""
|
||
| 功能 | 查询逾期的子任务和故事 |
|
||
| 入参 | 无 |
|
||
"""
|
||
today = tools.get_format_date()
|
||
check_time = tools.get_format_date(r_type=4)
|
||
if check_time < "{} 17:00:00".format(today):
|
||
jql = "issuetype in (故事,子任务) AND (计划结束时间<now() OR 计划上线时间<now()) AND status!=关闭 AND " \
|
||
"(assignee={0} OR QA={0})".format(user_name)
|
||
else:
|
||
jql = "issuetype in (故事,子任务) AND (计划结束时间<=now() OR 计划上线时间<=now()) AND status!=关闭 AND " \
|
||
"(assignee={0} OR QA={0})".format(user_name)
|
||
issues = self.jira.search_issues(jql, fields='')
|
||
return issues
|
||
|
||
def check_overdue_issues(self):
|
||
"""检查预期未关闭的故事和子任务"""
|
||
today = tools.get_format_date()
|
||
fs = FS_INFO[0]
|
||
user_list = fs['users'].split(',')
|
||
remind_info = []
|
||
for user in user_list:
|
||
issues = self.query_overdue_issues(user_name=user)
|
||
if issues:
|
||
for issue in issues:
|
||
issue_info = [user, issue.key]
|
||
remind_info.append(issue_info)
|
||
if remind_info:
|
||
msg = "【JIRA任务延期提醒{}】：\n".format(today)
|
||
for info in remind_info:
|
||
user_name = get_user_name_by_email_prefix(email_prefix=info[0])
|
||
open_id = get_feishu_config_value(option_key=user_name)
|
||
at_msg = " |--<at user_id='{}'>{}</at>".format(open_id, user_name)
|
||
msg = msg + at_msg + ": https://jira.bg.huohua.cn/browse/{}\n".format(info[1])
|
||
msg = msg + " |--请及时关闭以上逾期任务..."
|
||
print(msg)
|
||
fs = FeiShuMessage(team=fs['team'])
|
||
fs.send_text(msg=msg)
|
||
else:
|
||
print("++++++++++++++++++++++")
|
||
print("| 所有任务或故事均已关闭 |")
|
||
print("++++++++++++++++++++++")
|
||
|
||
def check_pdp_standard(self):
|
||
"""查找当天有无子任务，没有则发送飞书消息提醒"""
|
||
# 非工作日构建
|
||
today = tools.get_format_date()
|
||
if not tools.check_the_date_is_a_working_day(today):
|
||
print("### 非工作日，不检查....")
|
||
return False
|
||
|
||
for fs in FS_INFO:
|
||
user_list = fs['users'].split(',')
|
||
need_remind_user = []
|
||
for user in user_list:
|
||
issues = self.query_jira_subtask(user_name=user)
|
||
if not issues:
|
||
need_remind_user.append(user)
|
||
if need_remind_user:
|
||
msg = "【JIRA子任务提醒{}】：\n |--".format(today)
|
||
for user in need_remind_user:
|
||
user_name = get_user_name_by_email_prefix(email_prefix=user)
|
||
open_id = get_feishu_config_value(option_key=user_name)
|
||
at_msg = "<at user_id='{}'>{}</at>".format(open_id, user_name)
|
||
msg = msg + at_msg
|
||
msg = msg + "\n |--请及时添加与今日工作对应的子任务哦..."
|
||
print(msg)
|
||
fs = FeiShuMessage(team=fs['team'])
|
||
fs.send_text(msg=msg)
|
||
else:
|
||
print("++++++++++++++++++++++++++++++++")
|
||
print("| {} 满足pdp规范，无须提示 |".format(fs['team']))
|
||
print("++++++++++++++++++++++++++++++++")
|
||
|
||
|
||
if __name__ == '__main__':
|
||
|
||
# 关闭自动修改jira的代码，不要再打开了...
|
||
# lp = Jira_About()
|
||
# print(lp.change_jira_status(['liupeng', 'zhourenhua', 'xuwenjun', 'lichao04', 'wanggang02', 'baoli']))
|
||
|
||
# 以下内容若有修改，请勿上传，否则会影响jira监控的每日构建
|
||
# 1.获取命令行参数
|
||
cmd_params = sys.argv
|
||
try:
|
||
index = cmd_params.index('-t')
|
||
except ValueError:
|
||
raise Exception("类型参数必填：pdp-检查PDP规范，overdue-检查预期未关闭的故事和子任务....")
|
||
else:
|
||
check_type = cmd_params[index + 1]
|
||
if check_type.lower() not in ("pdp", "overdue"):
|
||
raise Exception("目前仅支持pdp和overdue，但你输入的是：{}".format(check_type))
|
||
|
||
jira = JiraApi()
|
||
if check_type.lower() == "pdp":
|
||
jira.check_pdp_standard()
|
||
elif check_type.lower() == "overdue":
|
||
jira.check_overdue_issues()
|