|
|
@@ -447,7 +447,7 @@ async def modify_institution_controller(
|
|
|
else:
|
|
|
log.warning(f"未找到可修改的标准规则: institution_id={institution_id}")
|
|
|
|
|
|
- # 周期发放制度：更新发放规则金额
|
|
|
+ # 周期发放制度：更新发放规则金额 — 独立调 issuerule.modify
|
|
|
if grant_mode == "period" and new_amount is not None and detail_dict:
|
|
|
issue_rule_list = detail_dict.get("issue_rule_info_list") or []
|
|
|
if not isinstance(issue_rule_list, list):
|
|
|
@@ -456,14 +456,18 @@ async def modify_institution_controller(
|
|
|
rule_dict = _to_dict(rule)
|
|
|
issue_rule_id = rule_dict.get("issue_rule_id", "")
|
|
|
if issue_rule_id:
|
|
|
- data["modify_issue_rule_detail_info"] = {
|
|
|
- "modify_issue_rule_list": {
|
|
|
- "issue_rule_id": issue_rule_id,
|
|
|
- "issue_amount_value": str(new_amount),
|
|
|
- }
|
|
|
- }
|
|
|
- log.info(f"已构建发放规则金额变更: issue_rule_id={issue_rule_id}, amount={new_amount}")
|
|
|
- break
|
|
|
+ try:
|
|
|
+ await IssueruleService.modify_issuerule_service(
|
|
|
+ auth=auth,
|
|
|
+ institution_id=institution_id,
|
|
|
+ issue_rule_id=issue_rule_id,
|
|
|
+ enterprise_id=enterprise_id,
|
|
|
+ issue_amount_value=str(new_amount),
|
|
|
+ )
|
|
|
+ log.info(f"已同步发放规则金额: issue_rule_id={issue_rule_id}, amount={new_amount}")
|
|
|
+ break
|
|
|
+ except Exception as e:
|
|
|
+ log.warning(f"同步发放规则失败(不影响制度修改): {e}")
|
|
|
else:
|
|
|
log.warning(f"未查询到制度详情，跳过金额同步: institution_id={institution_id}")
|
|
|
except Exception as e:
|
