Merge branch 'develop' into validate-employee-dates
This commit is contained in:
@@ -2311,7 +2311,7 @@ def get_due_date(term, posting_date=None, bill_date=None):
|
|||||||
elif term.due_date_based_on == "Day(s) after the end of the invoice month":
|
elif term.due_date_based_on == "Day(s) after the end of the invoice month":
|
||||||
due_date = add_days(get_last_day(date), term.credit_days)
|
due_date = add_days(get_last_day(date), term.credit_days)
|
||||||
elif term.due_date_based_on == "Month(s) after the end of the invoice month":
|
elif term.due_date_based_on == "Month(s) after the end of the invoice month":
|
||||||
due_date = add_months(get_last_day(date), term.credit_months)
|
due_date = get_last_day(add_months(date, term.credit_months))
|
||||||
return due_date
|
return due_date
|
||||||
|
|
||||||
|
|
||||||
@@ -2323,7 +2323,7 @@ def get_discount_date(term, posting_date=None, bill_date=None):
|
|||||||
elif term.discount_validity_based_on == "Day(s) after the end of the invoice month":
|
elif term.discount_validity_based_on == "Day(s) after the end of the invoice month":
|
||||||
discount_validity = add_days(get_last_day(date), term.discount_validity)
|
discount_validity = add_days(get_last_day(date), term.discount_validity)
|
||||||
elif term.discount_validity_based_on == "Month(s) after the end of the invoice month":
|
elif term.discount_validity_based_on == "Month(s) after the end of the invoice month":
|
||||||
discount_validity = add_months(get_last_day(date), term.discount_validity)
|
discount_validity = get_last_day(add_months(date, term.discount_validity))
|
||||||
return discount_validity
|
return discount_validity
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -217,7 +217,7 @@ class SalesPipelineAnalytics(object):
|
|||||||
|
|
||||||
def check_for_assigned_to(self, period, value, count_or_amount, assigned_to, info):
|
def check_for_assigned_to(self, period, value, count_or_amount, assigned_to, info):
|
||||||
if self.filters.get("assigned_to"):
|
if self.filters.get("assigned_to"):
|
||||||
for data in json.loads(info.get("opportunity_owner")):
|
for data in json.loads(info.get("opportunity_owner") or "[]"):
|
||||||
if data == self.filters.get("assigned_to"):
|
if data == self.filters.get("assigned_to"):
|
||||||
self.set_formatted_data(period, data, count_or_amount, assigned_to)
|
self.set_formatted_data(period, data, count_or_amount, assigned_to)
|
||||||
else:
|
else:
|
||||||
|
|||||||
@@ -318,3 +318,4 @@ erpnext.patches.v13_0.update_schedule_type_in_loans
|
|||||||
erpnext.patches.v14_0.create_accounting_dimensions_for_asset_capitalization
|
erpnext.patches.v14_0.create_accounting_dimensions_for_asset_capitalization
|
||||||
erpnext.patches.v14_0.update_partial_tds_fields
|
erpnext.patches.v14_0.update_partial_tds_fields
|
||||||
erpnext.patches.v14_0.create_incoterms_and_migrate_shipment
|
erpnext.patches.v14_0.create_incoterms_and_migrate_shipment
|
||||||
|
erpnext.patches.v14_0.setup_clear_repost_logs
|
||||||
8
erpnext/patches/v14_0/setup_clear_repost_logs.py
Normal file
8
erpnext/patches/v14_0/setup_clear_repost_logs.py
Normal file
@@ -0,0 +1,8 @@
|
|||||||
|
# Copyright (c) 2022, Frappe Technologies Pvt. Ltd. and Contributors
|
||||||
|
# License: MIT. See LICENSE
|
||||||
|
|
||||||
|
from erpnext.setup.install import setup_log_settings
|
||||||
|
|
||||||
|
|
||||||
|
def execute():
|
||||||
|
setup_log_settings()
|
||||||
@@ -30,6 +30,7 @@ def after_install():
|
|||||||
add_company_to_session_defaults()
|
add_company_to_session_defaults()
|
||||||
add_standard_navbar_items()
|
add_standard_navbar_items()
|
||||||
add_app_name()
|
add_app_name()
|
||||||
|
setup_log_settings()
|
||||||
frappe.db.commit()
|
frappe.db.commit()
|
||||||
|
|
||||||
|
|
||||||
@@ -197,3 +198,10 @@ def add_standard_navbar_items():
|
|||||||
|
|
||||||
def add_app_name():
|
def add_app_name():
|
||||||
frappe.db.set_value("System Settings", None, "app_name", "ERPNext")
|
frappe.db.set_value("System Settings", None, "app_name", "ERPNext")
|
||||||
|
|
||||||
|
|
||||||
|
def setup_log_settings():
|
||||||
|
log_settings = frappe.get_single("Log Settings")
|
||||||
|
log_settings.append("logs_to_clear", {"ref_doctype": "Repost Item Valuation", "days": 60})
|
||||||
|
|
||||||
|
log_settings.save(ignore_permissions=True)
|
||||||
|
|||||||
@@ -596,7 +596,9 @@ def make_stock_entry(source_name, target_doc=None):
|
|||||||
if source.material_request_type == "Customer Provided":
|
if source.material_request_type == "Customer Provided":
|
||||||
target.purpose = "Material Receipt"
|
target.purpose = "Material Receipt"
|
||||||
|
|
||||||
target.set_missing_values()
|
target.set_transfer_qty()
|
||||||
|
target.set_actual_qty()
|
||||||
|
target.calculate_rate_and_amount(raise_error_if_no_rate=False)
|
||||||
target.set_stock_entry_type()
|
target.set_stock_entry_type()
|
||||||
target.set_job_card_data()
|
target.set_job_card_data()
|
||||||
|
|
||||||
|
|||||||
@@ -5,6 +5,8 @@ import frappe
|
|||||||
from frappe import _
|
from frappe import _
|
||||||
from frappe.exceptions import QueryDeadlockError, QueryTimeoutError
|
from frappe.exceptions import QueryDeadlockError, QueryTimeoutError
|
||||||
from frappe.model.document import Document
|
from frappe.model.document import Document
|
||||||
|
from frappe.query_builder import DocType, Interval
|
||||||
|
from frappe.query_builder.functions import Now
|
||||||
from frappe.utils import cint, get_link_to_form, get_weekday, getdate, now, nowtime
|
from frappe.utils import cint, get_link_to_form, get_weekday, getdate, now, nowtime
|
||||||
from frappe.utils.user import get_users_with_role
|
from frappe.utils.user import get_users_with_role
|
||||||
from rq.timeouts import JobTimeoutException
|
from rq.timeouts import JobTimeoutException
|
||||||
@@ -21,6 +23,18 @@ RecoverableErrors = (JobTimeoutException, QueryDeadlockError, QueryTimeoutError)
|
|||||||
|
|
||||||
|
|
||||||
class RepostItemValuation(Document):
|
class RepostItemValuation(Document):
|
||||||
|
@staticmethod
|
||||||
|
def clear_old_logs(days=None):
|
||||||
|
days = days or 90
|
||||||
|
table = DocType("Repost Item Valuation")
|
||||||
|
frappe.db.delete(
|
||||||
|
table,
|
||||||
|
filters=(
|
||||||
|
(table.modified < (Now() - Interval(days=days)))
|
||||||
|
& (table.status.isin(["Completed", "Skipped"]))
|
||||||
|
),
|
||||||
|
)
|
||||||
|
|
||||||
def validate(self):
|
def validate(self):
|
||||||
self.set_status(write=False)
|
self.set_status(write=False)
|
||||||
self.reset_field_values()
|
self.reset_field_values()
|
||||||
|
|||||||
@@ -6,8 +6,7 @@ from unittest.mock import MagicMock, call
|
|||||||
|
|
||||||
import frappe
|
import frappe
|
||||||
from frappe.tests.utils import FrappeTestCase
|
from frappe.tests.utils import FrappeTestCase
|
||||||
from frappe.utils import nowdate
|
from frappe.utils import add_days, add_to_date, now, nowdate, today
|
||||||
from frappe.utils.data import add_to_date, today
|
|
||||||
|
|
||||||
from erpnext.accounts.doctype.sales_invoice.test_sales_invoice import create_sales_invoice
|
from erpnext.accounts.doctype.sales_invoice.test_sales_invoice import create_sales_invoice
|
||||||
from erpnext.accounts.utils import repost_gle_for_stock_vouchers
|
from erpnext.accounts.utils import repost_gle_for_stock_vouchers
|
||||||
@@ -86,6 +85,33 @@ class TestRepostItemValuation(FrappeTestCase, StockTestMixin):
|
|||||||
msg=f"Exepcted false from : {case}",
|
msg=f"Exepcted false from : {case}",
|
||||||
)
|
)
|
||||||
|
|
||||||
|
def test_clear_old_logs(self):
|
||||||
|
# create 10 logs
|
||||||
|
for i in range(1, 20):
|
||||||
|
repost_doc = frappe.get_doc(
|
||||||
|
doctype="Repost Item Valuation",
|
||||||
|
item_code="_Test Item",
|
||||||
|
warehouse="_Test Warehouse - _TC",
|
||||||
|
based_on="Item and Warehouse",
|
||||||
|
posting_date=nowdate(),
|
||||||
|
status="Skipped",
|
||||||
|
posting_time="00:01:00",
|
||||||
|
).insert(ignore_permissions=True)
|
||||||
|
|
||||||
|
repost_doc.load_from_db()
|
||||||
|
repost_doc.modified = add_days(now(), days=-i * 10)
|
||||||
|
repost_doc.db_update_all()
|
||||||
|
|
||||||
|
logs = frappe.get_all("Repost Item Valuation", filters={"status": "Skipped"})
|
||||||
|
self.assertTrue(len(logs) > 10)
|
||||||
|
|
||||||
|
from erpnext.stock.doctype.repost_item_valuation.repost_item_valuation import RepostItemValuation
|
||||||
|
|
||||||
|
RepostItemValuation.clear_old_logs(days=1)
|
||||||
|
|
||||||
|
logs = frappe.get_all("Repost Item Valuation", filters={"status": "Skipped"})
|
||||||
|
self.assertTrue(len(logs) == 0)
|
||||||
|
|
||||||
def test_create_item_wise_repost_item_valuation_entries(self):
|
def test_create_item_wise_repost_item_valuation_entries(self):
|
||||||
pr = make_purchase_receipt(
|
pr = make_purchase_receipt(
|
||||||
company="_Test Company with perpetual inventory",
|
company="_Test Company with perpetual inventory",
|
||||||
|
|||||||
@@ -659,6 +659,13 @@ class StockEntry(StockController):
|
|||||||
|
|
||||||
if d.allow_zero_valuation_rate:
|
if d.allow_zero_valuation_rate:
|
||||||
d.basic_rate = 0.0
|
d.basic_rate = 0.0
|
||||||
|
frappe.msgprint(
|
||||||
|
_(
|
||||||
|
"Row {0}: Item rate has been updated to zero as Allow Zero Valuation Rate is checked for item {1}"
|
||||||
|
).format(d.idx, d.item_code),
|
||||||
|
alert=1,
|
||||||
|
)
|
||||||
|
|
||||||
elif d.is_finished_item:
|
elif d.is_finished_item:
|
||||||
if self.purpose == "Manufacture":
|
if self.purpose == "Manufacture":
|
||||||
d.basic_rate = self.get_basic_rate_for_manufactured_item(
|
d.basic_rate = self.get_basic_rate_for_manufactured_item(
|
||||||
|
|||||||
@@ -2,12 +2,10 @@
|
|||||||
# License: GNU General Public License v3. See license.txt
|
# License: GNU General Public License v3. See license.txt
|
||||||
|
|
||||||
|
|
||||||
from collections import defaultdict
|
|
||||||
|
|
||||||
import frappe
|
import frappe
|
||||||
from frappe import _, throw
|
from frappe import _, throw
|
||||||
from frappe.contacts.address_and_contact import load_address_and_contact
|
from frappe.contacts.address_and_contact import load_address_and_contact
|
||||||
from frappe.utils import cint, flt
|
from frappe.utils import cint
|
||||||
from frappe.utils.nestedset import NestedSet
|
from frappe.utils.nestedset import NestedSet
|
||||||
from pypika.terms import ExistsCriterion
|
from pypika.terms import ExistsCriterion
|
||||||
|
|
||||||
@@ -166,60 +164,7 @@ def get_children(doctype, parent=None, company=None, is_root=False):
|
|||||||
["company", "in", (company, None, "")],
|
["company", "in", (company, None, "")],
|
||||||
]
|
]
|
||||||
|
|
||||||
warehouses = frappe.get_list(doctype, fields=fields, filters=filters, order_by="name")
|
return frappe.get_list(doctype, fields=fields, filters=filters, order_by="name")
|
||||||
|
|
||||||
company_currency = ""
|
|
||||||
if company:
|
|
||||||
company_currency = frappe.get_cached_value("Company", company, "default_currency")
|
|
||||||
|
|
||||||
warehouse_wise_value = get_warehouse_wise_stock_value(company)
|
|
||||||
|
|
||||||
# return warehouses
|
|
||||||
for wh in warehouses:
|
|
||||||
wh["balance"] = warehouse_wise_value.get(wh.value)
|
|
||||||
if company_currency:
|
|
||||||
wh["company_currency"] = company_currency
|
|
||||||
return warehouses
|
|
||||||
|
|
||||||
|
|
||||||
def get_warehouse_wise_stock_value(company):
|
|
||||||
warehouses = frappe.get_all(
|
|
||||||
"Warehouse", fields=["name", "parent_warehouse"], filters={"company": company}
|
|
||||||
)
|
|
||||||
parent_warehouse = {d.name: d.parent_warehouse for d in warehouses}
|
|
||||||
|
|
||||||
filters = {"warehouse": ("in", [data.name for data in warehouses])}
|
|
||||||
bin_data = frappe.get_all(
|
|
||||||
"Bin",
|
|
||||||
fields=["sum(stock_value) as stock_value", "warehouse"],
|
|
||||||
filters=filters,
|
|
||||||
group_by="warehouse",
|
|
||||||
)
|
|
||||||
|
|
||||||
warehouse_wise_stock_value = defaultdict(float)
|
|
||||||
for row in bin_data:
|
|
||||||
if not row.stock_value:
|
|
||||||
continue
|
|
||||||
|
|
||||||
warehouse_wise_stock_value[row.warehouse] = row.stock_value
|
|
||||||
update_value_in_parent_warehouse(
|
|
||||||
warehouse_wise_stock_value, parent_warehouse, row.warehouse, row.stock_value
|
|
||||||
)
|
|
||||||
|
|
||||||
return warehouse_wise_stock_value
|
|
||||||
|
|
||||||
|
|
||||||
def update_value_in_parent_warehouse(
|
|
||||||
warehouse_wise_stock_value, parent_warehouse_dict, warehouse, stock_value
|
|
||||||
):
|
|
||||||
parent_warehouse = parent_warehouse_dict.get(warehouse)
|
|
||||||
if not parent_warehouse:
|
|
||||||
return
|
|
||||||
|
|
||||||
warehouse_wise_stock_value[parent_warehouse] += flt(stock_value)
|
|
||||||
update_value_in_parent_warehouse(
|
|
||||||
warehouse_wise_stock_value, parent_warehouse_dict, parent_warehouse, stock_value
|
|
||||||
)
|
|
||||||
|
|
||||||
|
|
||||||
@frappe.whitelist()
|
@frappe.whitelist()
|
||||||
|
|||||||
@@ -17,11 +17,4 @@ frappe.treeview_settings['Warehouse'] = {
|
|||||||
description: __("Child nodes can be only created under 'Group' type nodes")}
|
description: __("Child nodes can be only created under 'Group' type nodes")}
|
||||||
],
|
],
|
||||||
ignore_fields:["parent_warehouse"],
|
ignore_fields:["parent_warehouse"],
|
||||||
onrender: function(node) {
|
|
||||||
if (node.data && node.data.balance!==undefined) {
|
|
||||||
$('<span class="balance-area pull-right">'
|
|
||||||
+ format_currency((node.data.balance), node.data.company_currency)
|
|
||||||
+ '</span>').insertBefore(node.$ul);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user