From 0e37cd6c9c9b3f5000447c54311d759ffeae0ed7 Mon Sep 17 00:00:00 2001 From: caoqianming Date: Tue, 21 Dec 2021 09:26:08 +0800 Subject: [PATCH 1/7] =?UTF-8?q?=E5=B7=A5=E4=BD=9C=E6=B5=81=E5=BC=95?= =?UTF-8?q?=E6=93=8E=E6=B5=8B=E8=AF=95=E6=9C=AA=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../wf/migrations/0019_auto_20211221_0923.py | 43 ++++++ hb_server/apps/wf/models.py | 5 +- hb_server/apps/wf/scripts.py | 54 ++++++- hb_server/apps/wf/serializers.py | 8 +- hb_server/apps/wf/services.py | 107 ++++++++++++-- hb_server/apps/wf/views.py | 134 +++--------------- .../wpm/migrations/0036_auto_20211221_0923.py | 23 +++ 7 files changed, 240 insertions(+), 134 deletions(-) create mode 100644 hb_server/apps/wf/migrations/0019_auto_20211221_0923.py create mode 100644 hb_server/apps/wpm/migrations/0036_auto_20211221_0923.py diff --git a/hb_server/apps/wf/migrations/0019_auto_20211221_0923.py b/hb_server/apps/wf/migrations/0019_auto_20211221_0923.py new file mode 100644 index 0000000..6e96c47 --- /dev/null +++ b/hb_server/apps/wf/migrations/0019_auto_20211221_0923.py @@ -0,0 +1,43 @@ +# Generated by Django 3.2.9 on 2021-12-21 01:23 + +from django.db import migrations, models + + +class Migration(migrations.Migration): + + dependencies = [ + ('wf', '0018_workflow_key'), + ] + + operations = [ + migrations.AddField( + model_name='ticket', + name='script_run_last_result', + field=models.BooleanField(default=True, verbose_name='脚本最后一次执行结果'), + ), + migrations.AddField( + model_name='ticketflow', + name='participant_str', + field=models.CharField(blank=True, help_text='非人工处理的处理人相关信息', max_length=200, null=True, verbose_name='处理人'), + ), + migrations.AlterField( + model_name='state', + name='state_fields', + field=models.JSONField(default=dict, help_text='json格式字典存储,包括读写属性1：只读，2：必填，3：可选, 4:隐藏 示例：{"create_time":1,"title":2, "sn":1}, 内置特殊字段participant_info.participant_name:当前处理人信息(部门名称、角色名称)，state.state_name:当前状态的状态名,workflow.workflow_name:工作流名称', verbose_name='表单字段'), + ), + migrations.AlterField( + model_name='ticket', + name='title', + field=models.CharField(blank=True, help_text='工单标题', max_length=500, null=True, verbose_name='标题'), + ), + migrations.AlterField( + model_name='ticketflow', + name='participant_type', + field=models.IntegerField(choices=[(0, '无处理人'), (1, '个人'), (2, '多人'), (4, '角色'), (6, '脚本'), (7, '工单的字段'), (9, '代码获取')], default=0, help_text='0.无处理人,1.个人,2.多人等', verbose_name='处理人类型'), + ), + migrations.AlterField( + model_name='workflow', + name='description', + field=models.CharField(blank=True, max_length=200, null=True, verbose_name='描述'), + ), + ] diff --git a/hb_server/apps/wf/models.py b/hb_server/apps/wf/models.py index 34eb8ec..be20e37 100644 --- a/hb_server/apps/wf/models.py +++ b/hb_server/apps/wf/models.py @@ -206,7 +206,7 @@ class Ticket(CommonBModel): ticket_data = models.JSONField('工单数据', default=dict, help_text='工单自定义字段内容') in_add_node = models.BooleanField('加签状态中', default=False, help_text='是否处于加签状态下') add_node_man = models.ForeignKey(User, verbose_name='加签人', on_delete=models.SET_NULL, null=True, blank=True, help_text='加签操作的人，工单当前处理人处理完成后会回到该处理人，当处于加签状态下才有效') - + script_run_last_result = models.BooleanField(u'脚本最后一次执行结果', default=True) participant_type = models.IntegerField('当前处理人类型', default=0, help_text='0.无处理人,1.个人,2.多人', choices=State.state_participanttype_choices) participant = models.JSONField('当前处理人', default=list, blank=True, help_text='可以为空(无处理人的情况，如结束状态)、userid、userid列表') act_state = models.IntegerField('进行状态', default=1, help_text='当前工单的进行状态', choices=act_state_choices) @@ -228,8 +228,9 @@ class TicketFlow(BaseModel): ticket = models.ForeignKey(Ticket, on_delete=models.CASCADE, verbose_name='关联工单', related_name='ticketflow_ticket') transition = models.ForeignKey(Transition, verbose_name='流转id', help_text='与worklow.Transition关联， 为空时表示认为干预的操作', on_delete=models.CASCADE, null=True, blank=True) suggestion = models.CharField('处理意见', max_length=10000, default='', blank=True) - participant_type = models.IntegerField('处理人类型', default=0, help_text='0.无处理人,1.个人,2.多人', choices=State.state_participanttype_choices) + participant_type = models.IntegerField('处理人类型', default=0, help_text='0.无处理人,1.个人,2.多人等', choices=State.state_participanttype_choices) participant = models.ForeignKey(User, verbose_name='处理人', on_delete=models.SET_NULL, null=True, blank=True, related_name='ticketflow_participant') + participant_str = models.CharField('处理人', max_length=200, null=True, blank=True, help_text='非人工处理的处理人相关信息') state = models.ForeignKey(State, verbose_name='当前状态', default=0, blank=True, on_delete=models.CASCADE) ticket_data = models.JSONField('工单数据', default=dict, blank=True, help_text='可以用于记录当前表单数据，json格式') intervene_type = models.IntegerField('干预类型', default=0, help_text='流转类型', choices=Transition.intervene_type_choices) diff --git a/hb_server/apps/wf/scripts.py b/hb_server/apps/wf/scripts.py index e96502f..3ce706f 100644 --- a/hb_server/apps/wf/scripts.py +++ b/hb_server/apps/wf/scripts.py @@ -1,3 +1,8 @@ +from apps.system.models import User +from apps.wf.models import State, Ticket, TicketFlow, Transition +from apps.wpm.models import WProduct + + class GetParticipants: all_funcs = [ @@ -9,7 +14,7 @@ class GetParticipants: # return [(func, getattr(self, func).__doc__) for func in dir(self) if callable(getattr(self, func)) and func.startswith('get_')] @classmethod - def get_create_by(cls, state:dict={}, ticket:dict={}, ticket_data:dict={}, request={}): + def get_create_by(cls, state:dict={}, ticket:dict={}, new_ticket_data:dict={}, handler:User={}): """工单创建人""" participant = ticket.create_by.id return participant @@ -18,12 +23,51 @@ class HandleScripts: all_funcs = [ {'func': 'handle_wproduct', 'name':'处理不合格品'} ] + + @classmethod - def handle_wproduct(cls, ticket:dict={}): + def to_next(cls, ticket:Ticket, by_timer:bool=False, by_task:bool=False, by_hook:bool=False, script_str:str=''): + # 获取信息 + transition_obj = Transition.objects.filter(source_state=ticket.state, is_deleted=False).first() + + TicketFlow.objects.create(ticket=ticket, state=ticket.state, + participant_type=State.PARTICIPANT_TYPE_ROBOT, + participant_str='func:{}'.format(script_str), + transition=transition_obj) + from .services import WfService + + # 自动执行流转 + WfService.handle_ticket(ticket=ticket, transition=transition_obj, new_ticket_data=ticket.ticket_data, by_task=True) + + return ticket + + @classmethod + def handle_wproduct(cls, ticket:Ticket): """处理不合格品""" + # 任务处理 + ticket_data = ticket.ticket_data - wp = ticket.wt_ticket - wp = ticket_data + wt = ticket.wt_ticket + wp = wt.wproduct if 'shenli2' in ticket_data and ticket_data['shenli2']: + wt.decision = ticket_data['shenli2'] if ticket_data['shenli2'] in ['返工', '返修']: - pass \ No newline at end of file + pass + elif ticket_data['shenli2'] in ['让步接收']: + wp.act_state = WProduct.WPR_ACT_STATE_OK + elif 'shenli1' in ticket_data and ticket_data['shenli1']: + wp.decision = ticket_data['shenli1'] + if ticket_data['shenli1'] in ['返工', '返修']: + pass + elif ticket_data['shenli1'] in ['让步接收']: + wp.act_state = WProduct.WPR_ACT_STATE_OK + wt.save() + wp.save() + + # 调用自动流转 + ticket = cls.to_next(ticket=ticket, by_task=True, script_str= 'handle_wproduct') + if ticket.act_state == Ticket.TICKET_ACT_STATE_FINISH: + # 如果工单完成 + wp.ticket = None + wp.save() + diff --git a/hb_server/apps/wf/serializers.py b/hb_server/apps/wf/serializers.py index ae3bf88..3c3a730 100644 --- a/hb_server/apps/wf/serializers.py +++ b/hb_server/apps/wf/serializers.py @@ -1,3 +1,4 @@ +from apps.system.models import User from apps.system.serializers import UserSimpleSerializer import rest_framework from rest_framework import serializers @@ -55,7 +56,6 @@ class TicketCreateSerializer(serializers.ModelSerializer): fields=['title','workflow', 'ticket_data', 'transition'] def create(self, validated_data): - validated_data.pop('transition') return super().create(validated_data) class TicketSerializer(serializers.ModelSerializer): @@ -124,7 +124,7 @@ class TicketFlowSimpleSerializer(serializers.ModelSerializer): class TicketHandleSerializer(serializers.Serializer): - transition = serializers.IntegerField(label="流转id") + transition = serializers.PrimaryKeyRelatedField(queryset=Transition.objects.all(), label="流转id") ticket_data = serializers.JSONField(label="表单数据json") suggestion = serializers.CharField(label="处理意见", required = False) @@ -136,10 +136,10 @@ class TicketCloseSerializer(serializers.Serializer): class TicketAddNodeSerializer(serializers.Serializer): suggestion = serializers.CharField(label="加签说明", required = False) - toadd_user = serializers.IntegerField(label='发送给谁去加签') + toadd_user = serializers.PrimaryKeyRelatedField(queryset=User.objects.all(), label='发送给谁去加签') class TicketAddNodeEndSerializer(serializers.Serializer): suggestion = serializers.CharField(label="加签意见", required = False) class TicketDestorySerializer(serializers.Serializer): - ids = serializers.ListField(child=serializers.IntegerField(), label='工单ID列表') \ No newline at end of file + ids = serializers.ListField(child=serializers.PrimaryKeyRelatedField(queryset=Ticket.objects.all()), label='工单ID列表') \ No newline at end of file diff --git a/hb_server/apps/wf/services.py b/hb_server/apps/wf/services.py index 17d9c63..bf83291 100644 --- a/hb_server/apps/wf/services.py +++ b/hb_server/apps/wf/services.py @@ -2,12 +2,12 @@ from apps.wf.serializers import CustomFieldSerializer from apps.wf.serializers import TicketSerializer, TicketSimpleSerializer from typing import Tuple from apps.system.models import User -from apps.wf.models import CustomField, State, Ticket, Transition, Workflow -from rest_framework.exceptions import APIException +from apps.wf.models import CustomField, State, Ticket, TicketFlow, Transition, Workflow +from rest_framework.exceptions import APIException, PermissionDenied from django.utils import timezone from datetime import timedelta import random -from .scripts import GetParticipants +from .scripts import GetParticipants, HandleScripts from utils.queryset import get_parent_queryset class WfService(object): @@ -113,14 +113,14 @@ class WfService(object): @classmethod - def get_next_state_by_transition_and_ticket_info(cls, ticket:Ticket, transition: Transition, ticket_data:dict={}, request:dict={})->object: + def get_next_state_by_transition_and_ticket_info(cls, ticket:Ticket, transition: Transition, new_ticket_data:dict={})->object: """ 获取下个节点状态 """ source_state = ticket.state destination_state = transition.destination_state ticket_all_value = cls.get_ticket_all_field_value(ticket) - ticket_all_value.update(**ticket_data) + ticket_all_value.update(**new_ticket_data) for key, value in ticket_all_value.items(): if isinstance(ticket_all_value[key], str): ticket_all_value[key] = "'" + ticket_all_value[key] + "'" @@ -133,7 +133,7 @@ class WfService(object): return destination_state @classmethod - def get_ticket_state_participant_info(cls, state:State, ticket:Ticket, ticket_data:dict={}, request={}): + def get_ticket_state_participant_info(cls, state:State, ticket:Ticket, new_ticket_data:dict={}, handler:User=None): """ 获取工单目标状态实际的处理人, 处理人类型 """ @@ -154,11 +154,12 @@ class WfService(object): multi_all_person_dict = {} destination_participant_type, destination_participant = state.participant_type, state.participant if destination_participant_type == State.PARTICIPANT_TYPE_FIELD: - destination_participant = ticket_data.get(destination_participant, 0) if destination_participant in ticket_data \ + destination_participant = new_ticket_data.get(destination_participant, 0) if destination_participant in new_ticket_data \ else Ticket.ticket_data.get(destination_participant, 0) elif destination_participant_type == State.PARTICIPANT_TYPE_FORMCODE:#代码获取 - destination_participant = getattr(GetParticipants, destination_participant)(state=state, ticket=ticket, ticket_data=ticket_data, request=request) + destination_participant = getattr(GetParticipants, destination_participant)( + state=state, ticket=ticket, new_ticket_data=new_ticket_data, hander=handler) elif destination_participant_type == State.PARTICIPANT_TYPE_DEPT:#部门 destination_participant = list(User.objects.filter(dept__in=destination_participant).values_list('id', flat=True)) @@ -173,7 +174,7 @@ class WfService(object): depts = get_parent_queryset(ticket.create_by.dept) user_queryset = user_queryset.filter(dept__in=depts) elif state.filter_policy == 3: - depts = get_parent_queryset(request.user.dept) + depts = get_parent_queryset(handler.dept) user_queryset = user_queryset.filter(dept__in=depts) destination_participant = list(user_queryset.values_list('id', flat=True)) if type(destination_participant) == list: @@ -256,5 +257,93 @@ class WfService(object): field_info_dict[i.field_key] = ticket.ticket_data.get(i.field_key, None) return field_info_dict + @classmethod + def handle_ticket(cls, ticket:Ticket, transition: Transition, new_ticket_data:dict={}, handler:User=None, + suggestion:str='', created:bool=False, by_timer:bool=False, by_task:bool=False, by_hook:bool=False): + source_state = ticket.state + source_ticket_data = ticket.ticket_data + + # 校验处理权限 + if not handler or not created: # 没有处理人意味着系统触发不校验处理权限 + result = WfService.ticket_handle_permission_check(ticket, handler) + if result.get('permission') is False: + raise PermissionDenied(result.get('msg')) + + # 校验表单必填项目 + if transition.field_require_check or not created: + for key, value in ticket.state.state_fields.items(): + if value == State.STATE_FIELD_REQUIRED: + if key not in new_ticket_data or not new_ticket_data[key]: + raise APIException('字段{}必填'.format(key)) + + destination_state = cls.get_next_state_by_transition_and_ticket_info(ticket, transition, new_ticket_data) + multi_all_person = ticket.multi_all_person + if multi_all_person: + multi_all_person[handler.id] =dict(transition=transition.id) + # 判断所有人处理结果是否一致 + if WfService.check_dict_has_all_same_value(multi_all_person): + participant_info = WfService.get_ticket_state_participant_info(destination_state, ticket, new_ticket_data) + destination_participant_type = participant_info.get('destination_participant_type', 0) + destination_participant = participant_info.get('destination_participant', 0) + multi_all_person = {} + else: + # 处理人没有没有全部处理完成或者处理动作不一致 + destination_participant_type = ticket.participant_type + destination_state = ticket.state # 保持原状态 + destination_participant = [] + for key, value in multi_all_person.items(): + if not value: + destination_participant.append(key) + else: + # 当前处理人类型非全部处理 + participant_info = WfService.get_ticket_state_participant_info(destination_state, ticket, new_ticket_data) + destination_participant_type = participant_info.get('destination_participant_type', 0) + destination_participant = participant_info.get('destination_participant', 0) + multi_all_person = participant_info.get('multi_all_person', {}) + + # 更新工单信息：基础字段及自定义字段， add_relation字段 需要下个处理人是部门、角色等的情况 + ticket.state = destination_state + ticket.participant_type = destination_participant_type + ticket.participant = destination_participant + ticket.multi_all_person = multi_all_person + if destination_state.type == State.STATE_TYPE_END: + ticket.act_state = Ticket.TICKET_ACT_STATE_FINISH + elif destination_state.type == State.STATE_TYPE_START: + ticket.act_state = Ticket.TICKET_ACT_STATE_DRAFT + else: + ticket.act_state = Ticket.TICKET_ACT_STATE_ONGOING + + if transition.attribute_type == Transition.TRANSITION_ATTRIBUTE_TYPE_REFUSE: + ticket.act_state = Ticket.TICKET_ACT_STATE_BACK + + # 只更新必填和可选的字段 + if not created: + for key, value in source_state.state_fields.items(): + if value in (State.STATE_FIELD_REQUIRED, State.STATE_FIELD_OPTIONAL): + source_ticket_data[key] = new_ticket_data[key] + ticket.ticket_data = source_ticket_data + ticket.save() + + # 更新工单流转记录 + if not by_task: + TicketFlow.objects.create(ticket=ticket, state=source_state, ticket_data=WfService.get_ticket_all_field_value(ticket), + suggestion=suggestion, participant_type=State.PARTICIPANT_TYPE_PERSONAL, + participant=handler, transition=transition) + + if created: + if source_state.participant_cc: + TicketFlow.objects.create(ticket=ticket, state=source_state, + participant_type=0, intervene_type=Transition.TRANSITION_INTERVENE_TYPE_CC, + participant=None, participant_cc=source_state.participant_cc) + + # 目标状态需要抄送 + if destination_state.participant_cc: + TicketFlow.objects.create(ticket=ticket, state=destination_state, + participant_type=0, intervene_type=Transition.TRANSITION_INTERVENE_TYPE_CC, + participant=None, participant_cc=destination_state.participant_cc) + + # 如果目标状态是脚本则执行 + if destination_state.participant_type == State.PARTICIPANT_TYPE_ROBOT: + getattr(HandleScripts, destination_state.participant)(ticket) diff --git a/hb_server/apps/wf/views.py b/hb_server/apps/wf/views.py index d9c586b..ed9ec46 100644 --- a/hb_server/apps/wf/views.py +++ b/hb_server/apps/wf/views.py @@ -1,3 +1,4 @@ +from django.db import transaction from django.db.models import query from rest_framework.utils import serializer_helpers from rest_framework.views import APIView @@ -17,7 +18,7 @@ from apps.wf.services import WfService from rest_framework.exceptions import APIException, PermissionDenied from rest_framework import status from django.db.models import Count -from .scripts import GetParticipants +from .scripts import GetParticipants, HandleScripts # Create your views here. @@ -135,6 +136,7 @@ class TicketViewSet(OptimizationMixin, CreateUpdateCustomMixin, CreateModelMixin raise APIException('请指定查询分类') return super().get_queryset() + @transaction.atomic def create(self, request, *args, **kwargs): """ 新建工单 @@ -148,7 +150,7 @@ class TicketViewSet(OptimizationMixin, CreateUpdateCustomMixin, CreateModelMixin ticket_data = vdata['ticket_data'] save_ticket_data = {} - #校验必填项 + # 校验必填项 if transition.field_require_check: for key, value in start_state.state_fields.items(): if value == State.STATE_FIELD_REQUIRED: @@ -163,47 +165,18 @@ class TicketViewSet(OptimizationMixin, CreateUpdateCustomMixin, CreateModelMixin act_state=Ticket.TICKET_ACT_STATE_DRAFT, belong_dept=request.user.dept, ticket_data=save_ticket_data) # 先创建出来 - - next_state = WfService.get_next_state_by_transition_and_ticket_info(ticket=ticket, transition=transition) - participant_info = WfService.get_ticket_state_participant_info(state=next_state, ticket=ticket, ticket_data=ticket.ticket_data) - destination_participant_type = participant_info.get('destination_participant_type', 0) - destination_participant = participant_info.get('destination_participant', 0) - multi_all_person = participant_info.get('multi_all_person', {}) # 多人需要全部处理情况 - sn = WfService.get_ticket_sn(ticket.workflow) # 流水号 - if next_state.type == State.STATE_TYPE_END: - act_state = Ticket.TICKET_ACT_STATE_FINISH - elif next_state.type == State.STATE_TYPE_START: - act_state = Ticket.TICKET_ACT_STATE_DRAFT - else: - act_state = Ticket.TICKET_ACT_STATE_ONGOING - title = vdata['title'] + # 更新title和sn + title = vdata.get('title', '') title_template = ticket.workflow.title_template if title_template: - all_ticket_data = {**rdata, **rdata['ticket_data']} + all_ticket_data = {**rdata, **ticket_data} title = title_template.format(**all_ticket_data) - # 更新一下信息 - ticket.sn=sn - ticket.title=title - ticket.state=next_state - ticket.participant=destination_participant - ticket.participant_type=destination_participant_type - ticket.act_state=act_state - ticket.multi_all_person=multi_all_person + sn = WfService.get_ticket_sn(ticket.workflow) # 流水号 + ticket.sn = sn + ticket.title = title ticket.save() - # 新增流转记录 - TicketFlow.objects.create(ticket=ticket, state=start_state, ticket_data=WfService.get_ticket_all_field_value(ticket), - suggestion=rdata.get('suggestion',''), participant_type=State.PARTICIPANT_TYPE_PERSONAL, - participant=ticket.create_by, transition=transition) - # 开始状态需要抄送 - if start_state.participant_cc: - TicketFlow.objects.create(ticket=ticket, state=ticket.start_state, - participant_type=0, intervene_type=Transition.TRANSITION_INTERVENE_TYPE_CC, - participant=None, participant_cc=start_state.participant_cc) - # 目标状态需要抄送 - if next_state.participant_cc: - TicketFlow.objects.create(ticket=ticket, state=next_state, - participant_type=0, intervene_type=Transition.TRANSITION_INTERVENE_TYPE_CC, - participant=None, participant_cc=next_state.participant_cc) + ticket = WfService.handle_ticket(ticket=ticket, transition=transition, new_ticket_data=ticket_data, + handler=request.user) return Response(TicketSerializer(instance=ticket).data) @action(methods=['get'], detail=False, perms_map={'get':'*'}) @@ -219,85 +192,18 @@ class TicketViewSet(OptimizationMixin, CreateUpdateCustomMixin, CreateModelMixin return Response(ret) @action(methods=['post'], detail=True, perms_map={'post':'*'}) + @transaction.atomic def handle(self, request, pk=None): """ 处理工单 """ - try: - ticket = Ticket.objects.get(pk=pk) - except: - raise APIException('工单不存在') - data = request.data - result = WfService.ticket_handle_permission_check(ticket, request.user) - source_state = ticket.state - source_ticket_data = ticket.ticket_data - if result.get('permission') is False: - raise PermissionDenied(result.get('msg')) - # 校验表单必填项目 - transition = Transition.objects.get(pk=data['transition']) - ticket_data = data['ticket_data'] - if transition.field_require_check: - for key, value in ticket.state.state_fields.items(): - if value == State.STATE_FIELD_REQUIRED: - if key not in ticket_data or not ticket_data[key]: - raise APIException('字段{}必填'.format(key)) - - destination_state = WfService.get_next_state_by_transition_and_ticket_info(ticket, transition, ticket_data, request) - multi_all_person = ticket.multi_all_person - if multi_all_person: - multi_all_person[request.user.id] =dict(transition=transition.id) - # 判断所有人处理结果是否一致 - if WfService.check_dict_has_all_same_value(multi_all_person): - participant_info = WfService.get_ticket_state_participant_info(destination_state, ticket, data['ticket_data']) - destination_participant_type = participant_info.get('destination_participant_type', 0) - destination_participant = participant_info.get('destination_participant', 0) - multi_all_person = {} - else: - # 处理人没有没有全部处理完成或者处理动作不一致 - destination_participant_type = ticket.participant_type - destination_state = ticket.state # 保持原状态 - destination_participant = [] - for key, value in multi_all_person.items(): - if not value: - destination_participant.append(key) - else: - # 当前处理人类型非全部处理 - participant_info = WfService.get_ticket_state_participant_info(destination_state, ticket, data['ticket_data']) - destination_participant_type = participant_info.get('destination_participant_type', 0) - destination_participant = participant_info.get('destination_participant', 0) - multi_all_person = participant_info.get('multi_all_person', {}) - - # 更新工单信息：基础字段及自定义字段， add_relation字段 需要下个处理人是部门、角色等的情况 - ticket.state = destination_state - ticket.participant_type = destination_participant_type - ticket.participant = destination_participant - ticket.multi_all_person = multi_all_person - if destination_state.type == State.STATE_TYPE_END: - ticket.act_state = Ticket.TICKET_ACT_STATE_FINISH - elif destination_state.type == State.STATE_TYPE_START: - ticket.act_state = Ticket.TICKET_ACT_STATE_DRAFT - else: - ticket.act_state = Ticket.TICKET_ACT_STATE_ONGOING - - if transition.attribute_type == Transition.TRANSITION_ATTRIBUTE_TYPE_REFUSE: - ticket.act_state = Ticket.TICKET_ACT_STATE_BACK - - # 只更新必填和可选的字段 - for key, value in source_state.state_fields.items(): - if value in (State.STATE_FIELD_REQUIRED, State.STATE_FIELD_OPTIONAL): - source_ticket_data[key] = ticket_data[key] - ticket.ticket_data = source_ticket_data - ticket.save() - - # 更新工单流转记录 - TicketFlow.objects.create(ticket=ticket, state=source_state, ticket_data=WfService.get_ticket_all_field_value(ticket), - suggestion=data.get('suggestion',''), participant_type=State.PARTICIPANT_TYPE_PERSONAL, - participant=request.user, transition=transition) - # 目标状态需要抄送 - if destination_state.participant_cc: - TicketFlow.objects.create(ticket=ticket, state=destination_state, - participant_type=0, intervene_type=Transition.TRANSITION_INTERVENE_TYPE_CC, - participant=None, participant_cc=destination_state.participant_cc) + ticket = self.get_object() + serializer = TicketHandleSerializer(data=request.data) + serializer.is_valid(raise_exception=True) + vdata = serializer.validated_data + new_ticket_data = ticket.ticket_data.update(**vdata['ticket_data']) + ticket = WfService.handle_ticket(ticket=ticket, transition=vdata['transition'], + new_ticket_data=new_ticket_data, handler=request.user, suggestion=vdata['suggestion']) return Response(TicketSerializer(instance=ticket).data) diff --git a/hb_server/apps/wpm/migrations/0036_auto_20211221_0923.py b/hb_server/apps/wpm/migrations/0036_auto_20211221_0923.py new file mode 100644 index 0000000..a8b1312 --- /dev/null +++ b/hb_server/apps/wpm/migrations/0036_auto_20211221_0923.py @@ -0,0 +1,23 @@ +# Generated by Django 3.2.9 on 2021-12-21 01:23 + +from django.db import migrations, models + + +class Migration(migrations.Migration): + + dependencies = [ + ('wpm', '0035_alter_operationrecorditem_field_value'), + ] + + operations = [ + migrations.AddField( + model_name='wprouctticket', + name='decision', + field=models.CharField(blank=True, max_length=100, null=True, verbose_name='最终决定'), + ), + migrations.AlterField( + model_name='wproduct', + name='act_state', + field=models.IntegerField(choices=[(6, '待复检'), (8, '操作准备中'), (10, '操作进行中'), (20, '待检验'), (26, '待夹层检验'), (30, '已合格'), (40, '已入库'), (50, '不合格'), (60, '待成品检验'), (70, '已报废')], default=0, verbose_name='进行状态'), + ), + ] From 0bd5516cef0e0e3aec9c83ea77f1a51ac5b899f7 Mon Sep 17 00:00:00 2001 From: caoqianming Date: Tue, 21 Dec 2021 10:04:19 +0800 Subject: [PATCH 2/7] =?UTF-8?q?handleticket=20bug=E4=BF=AE=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- hb_server/apps/wf/models.py | 2 +- hb_server/apps/wf/serializers.py | 2 +- hb_server/apps/wf/services.py | 4 +++- hb_server/apps/wf/views.py | 12 ++++++++---- 4 files changed, 13 insertions(+), 7 deletions(-) diff --git a/hb_server/apps/wf/models.py b/hb_server/apps/wf/models.py index be20e37..0aebb03 100644 --- a/hb_server/apps/wf/models.py +++ b/hb_server/apps/wf/models.py @@ -206,7 +206,7 @@ class Ticket(CommonBModel): ticket_data = models.JSONField('工单数据', default=dict, help_text='工单自定义字段内容') in_add_node = models.BooleanField('加签状态中', default=False, help_text='是否处于加签状态下') add_node_man = models.ForeignKey(User, verbose_name='加签人', on_delete=models.SET_NULL, null=True, blank=True, help_text='加签操作的人，工单当前处理人处理完成后会回到该处理人，当处于加签状态下才有效') - script_run_last_result = models.BooleanField(u'脚本最后一次执行结果', default=True) + script_run_last_result = models.BooleanField('脚本最后一次执行结果', default=True) participant_type = models.IntegerField('当前处理人类型', default=0, help_text='0.无处理人,1.个人,2.多人', choices=State.state_participanttype_choices) participant = models.JSONField('当前处理人', default=list, blank=True, help_text='可以为空(无处理人的情况，如结束状态)、userid、userid列表') act_state = models.IntegerField('进行状态', default=1, help_text='当前工单的进行状态', choices=act_state_choices) diff --git a/hb_server/apps/wf/serializers.py b/hb_server/apps/wf/serializers.py index 3c3a730..e7987ec 100644 --- a/hb_server/apps/wf/serializers.py +++ b/hb_server/apps/wf/serializers.py @@ -126,7 +126,7 @@ class TicketFlowSimpleSerializer(serializers.ModelSerializer): class TicketHandleSerializer(serializers.Serializer): transition = serializers.PrimaryKeyRelatedField(queryset=Transition.objects.all(), label="流转id") ticket_data = serializers.JSONField(label="表单数据json") - suggestion = serializers.CharField(label="处理意见", required = False) + suggestion = serializers.CharField(label="处理意见", required = False, allow_blank=True) class TicketRetreatSerializer(serializers.Serializer): suggestion = serializers.CharField(label="撤回原因", required = False) diff --git a/hb_server/apps/wf/services.py b/hb_server/apps/wf/services.py index bf83291..beb9724 100644 --- a/hb_server/apps/wf/services.py +++ b/hb_server/apps/wf/services.py @@ -201,7 +201,7 @@ class WfService(object): transitions = cls.get_state_transitions(ticket.state) if not transitions: return dict(permission=True, msg="工单当前状态无需操作") - current_participant_count = 1 + current_participant_count = 0 participant_type = ticket.participant_type participant = ticket.participant state = ticket.state @@ -346,4 +346,6 @@ class WfService(object): # 如果目标状态是脚本则执行 if destination_state.participant_type == State.PARTICIPANT_TYPE_ROBOT: getattr(HandleScripts, destination_state.participant)(ticket) + + return ticket diff --git a/hb_server/apps/wf/views.py b/hb_server/apps/wf/views.py index ed9ec46..7dfa9c2 100644 --- a/hb_server/apps/wf/views.py +++ b/hb_server/apps/wf/views.py @@ -1,3 +1,4 @@ +from django.utils import timezone from django.db import transaction from django.db.models import query from rest_framework.utils import serializer_helpers @@ -146,7 +147,7 @@ class TicketViewSet(OptimizationMixin, CreateUpdateCustomMixin, CreateModelMixin serializer.is_valid(raise_exception=True) vdata = serializer.validated_data #校验之后的数据 start_state = WfService.get_workflow_start_state(vdata['workflow']) - transition = vdata['transition'] + transition = vdata.pop('transition') ticket_data = vdata['ticket_data'] save_ticket_data = {} @@ -154,7 +155,7 @@ class TicketViewSet(OptimizationMixin, CreateUpdateCustomMixin, CreateModelMixin if transition.field_require_check: for key, value in start_state.state_fields.items(): if value == State.STATE_FIELD_REQUIRED: - if key not in ticket_data or not ticket_data[key]: + if key not in ticket_data and not ticket_data[key]: raise APIException('字段{}必填'.format(key)) save_ticket_data[key] = ticket_data[key] elif value == State.STATE_FIELD_OPTIONAL: @@ -162,6 +163,7 @@ class TicketViewSet(OptimizationMixin, CreateUpdateCustomMixin, CreateModelMixin ticket = serializer.save(state=start_state, create_by=request.user, + create_time=timezone.now(), act_state=Ticket.TICKET_ACT_STATE_DRAFT, belong_dept=request.user.dept, ticket_data=save_ticket_data) # 先创建出来 @@ -176,7 +178,7 @@ class TicketViewSet(OptimizationMixin, CreateUpdateCustomMixin, CreateModelMixin ticket.title = title ticket.save() ticket = WfService.handle_ticket(ticket=ticket, transition=transition, new_ticket_data=ticket_data, - handler=request.user) + handler=request.user, created=True) return Response(TicketSerializer(instance=ticket).data) @action(methods=['get'], detail=False, perms_map={'get':'*'}) @@ -201,7 +203,9 @@ class TicketViewSet(OptimizationMixin, CreateUpdateCustomMixin, CreateModelMixin serializer = TicketHandleSerializer(data=request.data) serializer.is_valid(raise_exception=True) vdata = serializer.validated_data - new_ticket_data = ticket.ticket_data.update(**vdata['ticket_data']) + new_ticket_data = ticket.ticket_data + new_ticket_data.update(**vdata['ticket_data']) + ticket = WfService.handle_ticket(ticket=ticket, transition=vdata['transition'], new_ticket_data=new_ticket_data, handler=request.user, suggestion=vdata['suggestion']) return Response(TicketSerializer(instance=ticket).data) From d892a0651d8cf625d4674c0b5bf61f228dcbb3cd Mon Sep 17 00:00:00 2001 From: caoqianming Date: Tue, 21 Dec 2021 16:20:20 +0800 Subject: [PATCH 3/7] =?UTF-8?q?=E6=8A=A5=E5=BA=9F=E6=93=8D=E4=BD=9C?= =?UTF-8?q?=E9=92=88=E5=AF=B9=E5=86=B7=E5=8A=A0=E5=B7=A5=E8=BF=9B=E8=A1=8C?= =?UTF-8?q?=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- hb_server/apps/wpm/models.py | 11 ++++++++ hb_server/apps/wpm/serializers.py | 6 +++- hb_server/apps/wpm/views.py | 46 +++++++++++++++++++++++++------ 3 files changed, 53 insertions(+), 10 deletions(-) diff --git a/hb_server/apps/wpm/models.py b/hb_server/apps/wpm/models.py index 4b10902..2b4b897 100644 --- a/hb_server/apps/wpm/models.py +++ b/hb_server/apps/wpm/models.py @@ -48,6 +48,16 @@ class WProduct(CommonAModel): (WPR_ACT_STATE_TOFINALTEST, '待成品检验'), (WPR_ACT_STATE_SCRAP, '已报废') ) + SCRAP_REASON_QIPAO = 10 + SCRAP_REASON_PODIAN = 20 + SCRAP_REASON_HUA = 30 + SCRAP_REASON_OTHER = 40 + scrap_reason_choices = ( + (10, '气泡'), + (20, '破点'), + (30, '划伤'), + (40, '其他') + ) number = models.CharField('物品编号', unique=True, null=True, blank=True, max_length=50) material = models.ForeignKey(Material, verbose_name='所属物料状态', on_delete=models.CASCADE) pre_step = models.ForeignKey(Step, verbose_name='已执行到', help_text='已执行完的步骤', null=True, blank=True, on_delete=models.CASCADE, related_name='w_pre_step') @@ -58,6 +68,7 @@ class WProduct(CommonAModel): remark = models.CharField('备注', max_length=200, null=True, blank=True) subproduction_plan = models.ForeignKey(SubProductionPlan, verbose_name='当前子生产计划', on_delete=models.CASCADE, related_name='wproduct_subplan') + scrap_reason = models.IntegerField('报废原因', choices=scrap_reason_choices, null=True, blank=True) warehouse = models.ForeignKey(WareHouse, verbose_name='所在仓库', on_delete=models.SET_NULL, null=True, blank=True) operation = models.ForeignKey('wpm.operation', verbose_name='当前操作', on_delete=models.SET_NULL, null=True, blank=True, related_name='wp_operation') diff --git a/hb_server/apps/wpm/serializers.py b/hb_server/apps/wpm/serializers.py index bf91387..01c6315 100644 --- a/hb_server/apps/wpm/serializers.py +++ b/hb_server/apps/wpm/serializers.py @@ -414,4 +414,8 @@ class OperationRecordDetailSerializer(serializers.ModelSerializer): fields = '__all__' def get_record_data(self, obj): - return OperationRecordItemSerializer(instance=obj.item_operation_record.order_by('form_field__sort'), many=True).data \ No newline at end of file + return OperationRecordItemSerializer(instance=obj.item_operation_record.order_by('form_field__sort'), many=True).data + +class ScrapSerializer(serializers.Serializer): + scrap_reason = serializers.ChoiceField(choices=WProduct.scrap_reason_choices, required=False) + # wproducts = serializers.ListField(child=serializers.PrimaryKeyRelatedField(queryset=WProduct.objects.all()), label='半成品ID列表') \ No newline at end of file diff --git a/hb_server/apps/wpm/views.py b/hb_server/apps/wpm/views.py index eb2e601..ed32da0 100644 --- a/hb_server/apps/wpm/views.py +++ b/hb_server/apps/wpm/views.py @@ -21,7 +21,7 @@ from apps.wf.serializers import WorkflowSimpleSerializer from apps.wpm.filters import WMaterialFilterSet from apps.wpm.models import OperationEquip, OperationWproduct, Pick, PickWproduct, WMaterial, WProduct, Operation, OperationMaterial, OperationRecord, OperationRecordItem -from apps.wpm.serializers import OperationEquipListSerializer, OperationEquipUpdateSerializer, OperationMaterialCreate1ListSerailizer, OperationMaterialCreate1Serailizer, OperationMaterialCreate2ListSerailizer, OperationMaterialCreate2Serailizer, OperationMaterialCreate3Serializer, OperationMaterialListSerializer, OperationRecordDetailSerializer, OperationRecordListSerializer, OperationRecordSubmitSerializer, OperationUpdateSerializer, OperationWproductListSerializer, OperationCreateSerializer, OperationDetailSerializer, OperationListSerializer, PickHalfSerializer, PickHalfsSerializer, PickSerializer, OperationInitSerializer, OperationSubmitSerializer, WMaterialListSerializer, WProductListSerializer, WplanPutInSerializer, WpmTestFormInitSerializer, WpmTestRecordCreateSerializer, WproductPutInSerializer, WproductPutInsSerializer +from apps.wpm.serializers import OperationEquipListSerializer, OperationEquipUpdateSerializer, OperationMaterialCreate1ListSerailizer, OperationMaterialCreate1Serailizer, OperationMaterialCreate2ListSerailizer, OperationMaterialCreate2Serailizer, OperationMaterialCreate3Serializer, OperationMaterialListSerializer, OperationRecordDetailSerializer, OperationRecordListSerializer, OperationRecordSubmitSerializer, OperationUpdateSerializer, OperationWproductListSerializer, OperationCreateSerializer, OperationDetailSerializer, OperationListSerializer, PickHalfSerializer, PickHalfsSerializer, PickSerializer, OperationInitSerializer, OperationSubmitSerializer, ScrapSerializer, WMaterialListSerializer, WProductListSerializer, WplanPutInSerializer, WpmTestFormInitSerializer, WpmTestRecordCreateSerializer, WproductPutInSerializer, WproductPutInsSerializer from rest_framework.response import Response from django.db import transaction from rest_framework import exceptions, serializers @@ -332,26 +332,54 @@ class WProductViewSet(ListModelMixin, GenericViewSet): wproduct.save() return Response() - @action(methods=['post'], detail=True, perms_map={'post':'*'}) + @action(methods=['post'], detail=False, perms_map={'post':'*'}, serializer_class=ScrapSerializer) def scrap(self, request, pk=None): """ 报废操作 """ obj = self.get_object() - if Operation.objects.filter(ow_operation__wproduct=obj, is_submited=True).count() >4 or obj.act_state != WProduct.WPR_ACT_STATE_NOTOK: - raise exceptions.APIException('该产品不支持直接报废') + serializer = ScrapSerializer(data=request.data) + vdata = serializer.validated_data + if obj.act_state == WProduct.WPR_ACT_STATE_NOTOK: + pass + elif obj.step.process == 1: # 如果是冷加工可直接报废 + if vdata.get('scrap_reason', None): + obj.scrap_reason = vdata['scrap_reason'] + else: + raise exceptions.APIException('请填写报废原因') + else: + raise exceptions.APIException('该产品不可报废') obj.act_state = WProduct.WPR_ACT_STATE_SCRAP obj.update_by = request.user obj.save() return Response() - @action(methods=['get'], detail=False, perms_map={'get':'*'}) - def workflows(self, request, pk=None): + # @action(methods=['get'], detail=False, perms_map={'get':'*'}) + # def workflows(self, request, pk=None): + # """ + # 可发起的工作流 + # """ + # wfs = Workflow.objects.filter(key__startswith= 'wp_') + # return WorkflowSimpleSerializer(instance=wfs, many=True).data + + @action(methods=['get'], detail=True, perms_map={'get':'*'}) + def bhg_wf(self, request, pk=None): """ - 可发起的工作流 + 发起不合格审理单 """ - wfs = Workflow.objects.filter(key__startswith= 'wp') - return WorkflowSimpleSerializer(instance=wfs, many=True).data + obj = self.get_object() + if obj.act_state != WProduct.WPR_ACT_STATE_NOTOK: + raise exceptions.APIException('非检验不合格产品不可发起不合格审理') + ret = { + 'sys_wproduct':obj.id, + 'sys_name':obj.material.name, + 'sys_specification':obj.material.specification, + 'sys_finder':request.user.id, + 'sys_process':obj.step.process.id, + } + return Response(ret) + + From 71e00d8455019d74569da92a7539ebf06dc29f17 Mon Sep 17 00:00:00 2001 From: caoqianming Date: Tue, 21 Dec 2021 16:32:38 +0800 Subject: [PATCH 4/7] =?UTF-8?q?=E6=8A=A5=E5=BA=9F=E6=8E=A5=E5=8F=A3?= =?UTF-8?q?=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- hb_server/apps/wpm/filters.py | 12 ++++++++++++ hb_server/apps/wpm/views.py | 6 +++--- 2 files changed, 15 insertions(+), 3 deletions(-) diff --git a/hb_server/apps/wpm/filters.py b/hb_server/apps/wpm/filters.py index eac725e..231a858 100644 --- a/hb_server/apps/wpm/filters.py +++ b/hb_server/apps/wpm/filters.py @@ -20,4 +20,16 @@ class WMaterialFilterSet(filters.FilterSet): else: subplans = WpmServies.get_subplans_queyset_from_step(step) queryset = queryset.filter(subproduction_plan__in=subplans).exclude(material__type=Material.MA_TYPE_HALFGOOD) + return queryset + + +class WProductFilterSet(filters.FilterSet): + tag = filters.CharFilter(method='filter_tag') + class Meta: + model = WProduct + fields = ['step', 'subproduction_plan', 'material', 'step__process', 'act_state', 'material__type'] + + def filter_tag(self, queryset, name, value): + if value == 'no_scrap': + queryset = queryset.exclude(act_state=WProduct.WPR_ACT_STATE_SCRAP) return queryset \ No newline at end of file diff --git a/hb_server/apps/wpm/views.py b/hb_server/apps/wpm/views.py index ed32da0..4d62249 100644 --- a/hb_server/apps/wpm/views.py +++ b/hb_server/apps/wpm/views.py @@ -18,7 +18,7 @@ from apps.system.mixins import CreateUpdateModelAMixin, OptimizationMixin from rest_framework.decorators import action from apps.wf.models import Workflow from apps.wf.serializers import WorkflowSimpleSerializer -from apps.wpm.filters import WMaterialFilterSet +from apps.wpm.filters import WMaterialFilterSet, WProductFilterSet from apps.wpm.models import OperationEquip, OperationWproduct, Pick, PickWproduct, WMaterial, WProduct, Operation, OperationMaterial, OperationRecord, OperationRecordItem from apps.wpm.serializers import OperationEquipListSerializer, OperationEquipUpdateSerializer, OperationMaterialCreate1ListSerailizer, OperationMaterialCreate1Serailizer, OperationMaterialCreate2ListSerailizer, OperationMaterialCreate2Serailizer, OperationMaterialCreate3Serializer, OperationMaterialListSerializer, OperationRecordDetailSerializer, OperationRecordListSerializer, OperationRecordSubmitSerializer, OperationUpdateSerializer, OperationWproductListSerializer, OperationCreateSerializer, OperationDetailSerializer, OperationListSerializer, PickHalfSerializer, PickHalfsSerializer, PickSerializer, OperationInitSerializer, OperationSubmitSerializer, ScrapSerializer, WMaterialListSerializer, WProductListSerializer, WplanPutInSerializer, WpmTestFormInitSerializer, WpmTestRecordCreateSerializer, WproductPutInSerializer, WproductPutInsSerializer @@ -181,7 +181,7 @@ class WProductViewSet(ListModelMixin, GenericViewSet): perms_map={'*':'*'} queryset = WProduct.objects.select_related('step', 'material', 'subproduction_plan').filter(is_hidden=False) serializer_class = WProductListSerializer - filterset_fields = ['step', 'subproduction_plan', 'material', 'step__process', 'act_state', 'material__type'] + filterset_class = WProductFilterSet search_fields = ['number'] ordering_fields = ['id'] ordering = ['id'] @@ -332,7 +332,7 @@ class WProductViewSet(ListModelMixin, GenericViewSet): wproduct.save() return Response() - @action(methods=['post'], detail=False, perms_map={'post':'*'}, serializer_class=ScrapSerializer) + @action(methods=['post'], detail=True, perms_map={'post':'*'}, serializer_class=ScrapSerializer) def scrap(self, request, pk=None): """ 报废操作 From ac2dd89df4122e049a4e494ef0fe8bf9107b0781 Mon Sep 17 00:00:00 2001 From: shijing Date: Tue, 21 Dec 2021 17:01:16 +0800 Subject: [PATCH 5/7] ganttchange --- hb_client/src/components/customForm/index.vue | 45 +++++++------------ .../src/components/customForm/review.vue | 22 ++++----- hb_client/src/views/pm/gantt.vue | 11 +++-- hb_client/src/views/wpm/need.vue | 17 ++++--- 4 files changed, 40 insertions(+), 55 deletions(-) diff --git a/hb_client/src/components/customForm/index.vue b/hb_client/src/components/customForm/index.vue index 6231f8f..9155cde 100644 --- a/hb_client/src/components/customForm/index.vue +++ b/hb_client/src/components/customForm/index.vue @@ -59,7 +59,6 @@ style="width: 100%" @change="keyChange($index,item.field_key)" /> - - - 说明：{{item.help_text}} - 合格 + 合格 不合格 @@ -137,20 +134,15 @@
标记
文字
回退
- +
保存
- - 检查合格 检查不合格 @@ -160,7 +152,6 @@ 提交 - @@ -202,6 +193,11 @@ formData.forEach(item => { let obj = new Object(); obj = item; + if(item.field_type === 'draw'){ + obj.is_testok = true; + }else{ + obj.is_testok = null; + } that.formData.push(obj) }); that.formData=[...formData]; @@ -270,10 +266,8 @@ }, methods:{ filterBlock(parent,rule,index,field_key){ - debugger; let that = this; if(parent!==''&&parent!==null&&parent!==undefined){ - debugger; if(rule!==''&&rule!==null&&rule!==undefined){ let reg = /\{(.+?)\}/g; //let str = rule.replace(temp,'').replace('$','');//=='有' @@ -515,7 +509,6 @@ if(v != '' && v != ' '){ this.imgData=ctx3.getImageData(0,0,canvas3.width,canvas3.height); let img = ctx3.getImageData(0,0,canvas3.width,canvas3.height); - // debugger; preDrawAry.push(img); ctx3.moveTo(oldX,oldY); ctx3.fillStyle="#e42343"; @@ -586,10 +579,7 @@ let formData = new FormData(); formData.append('file', file); upFile(formData).then((res) => { - debugger; - console.log(res); - that.imgUrl=res.data.field; - // console.log(res); + that.imgUrl=res.data.path; }) }, //base64ToFile @@ -632,7 +622,6 @@ //替换变量 a = a.replace(ky, 'yyy'); let yyy = "'"+that.checkForm[ky]+"'"; - // debugger; if(eval(eval( a))){ str += 'true'; }else{ @@ -684,8 +673,8 @@ upFile(formData).then((res) => { if(res){ let key = drawArr[0].field_key; - that.imgUrl=res.data.file; - that.checkForm[key] = res.data.file; + that.imgUrl=res.data.path; + that.checkForm[key] = res.data.path; that.fieldData(isSubmit); } }); @@ -698,14 +687,12 @@ that.field = []; //检查项目 let submit = isSubmit=='1'?false:true; that.formData.forEach((item) => { - if(!item.is_hidden){ - that.field.push({ - id: item.id, - field_value: that.checkForm[item.field_key], - is_testok: item.is_testok,//单项检查结果 - is_hidden: item.is_hidden - }); - } + that.field.push({ + id: item.id, + field_value: that.checkForm[item.field_key], + is_testok: item.is_testok,//单项检查结果 + is_hidden: item.is_hidden + }); }); that.testrecord.record_data = that.field;//检查项列表 that.testrecord.is_testok = that.is_testok;//检查表检查结果 diff --git a/hb_client/src/components/customForm/review.vue b/hb_client/src/components/customForm/review.vue index 78cadc0..23b69fb 100644 --- a/hb_client/src/components/customForm/review.vue +++ b/hb_client/src/components/customForm/review.vue @@ -677,10 +677,7 @@ let formData = new FormData(); formData.append('file', file); upFile(formData).then((res) => { - debugger; - console.log(res); - that.imgUrl=res.data.field; - // console.log(res); + that.imgUrl=res.data.path; }) }, //base64ToFile @@ -775,7 +772,7 @@ upFile(formData).then((res) => { if(res){ let key = drawArr[0].field_key; - that.imgUrl=res.data.file; + that.imgUrl=res.data.path; that.checkForm[key] = that.imgUrl; that.fieldData(); } @@ -789,14 +786,12 @@ that.field = []; //检查项目 let submit = isSubmit=='1'?false:true; that.formData.forEach((item) => { - if(!item.is_hidden){ - that.field.push({ - id: item.id, - field_value: that.checkForm[item.field_key], - is_testok: item.is_testok,//单项检查结果 - is_hidden: item.is_hidden - }); - } + that.field.push({ + id: item.id, + field_value: that.checkForm[item.field_key], + is_testok: item.is_testok,//单项检查结果 + is_hidden: item.is_hidden + }); }); // that.testrecord.form = that.formID;//检查表 that.testrecord.record_data = that.field;//检查项列表 @@ -804,7 +799,6 @@ // that.testrecord.wproduct = that.wproductId;//半成品ID // that.testrecord.is_submited = true; that.testrecord.id = that.recordId; - debugger; if(submit){//提交 this.$emit('recordSubmit',that.testrecord); }else {//保存 diff --git a/hb_client/src/views/pm/gantt.vue b/hb_client/src/views/pm/gantt.vue index 564d3b3..6c2b376 100644 --- a/hb_client/src/views/pm/gantt.vue +++ b/hb_client/src/views/pm/gantt.vue @@ -392,9 +392,14 @@ let that = this; getPlanGantt({}).then(res=>{ if(res.code===200){ - // debugger; - let arr =[]; - let list = res.data.results; + let arr =[],list=[]; + let li = res.data.results; + li.forEach((item,index)=>{ + if(index===1){ + list.push(item) + } + }); + // let list = res.data.results[1]; list.forEach(item => { if (!item.children || item.children.length < 1) { let startTime = new Date(item.start_date).getTime(); diff --git a/hb_client/src/views/wpm/need.vue b/hb_client/src/views/wpm/need.vue index 5d73c0f..47712ff 100644 --- a/hb_client/src/views/wpm/need.vue +++ b/hb_client/src/views/wpm/need.vue @@ -711,7 +711,7 @@ //点击检验:如果有一个直接进入，如果有多个表再进行选择 handleInspection(scope,index) { //调该物料对应的检查表 - debugger; + // debugger; let that = this; this.innerIndex = index; // this.outerVisible = true; @@ -761,7 +761,7 @@ }, //点击记录里的检验 handleInspectionRecord(scope){ - debugger; + // debugger; let that =this; that.recordVisible = false; that.recordId = scope.row.id; @@ -780,7 +780,7 @@ that.hasPicture = true; } getTestRecordItem(scope.row.id).then((res) => { - debugger; + // debugger; let arr = []; let fieldList = res.data.record_data; for(let i=0;i { if (response.data) { - debugger; + // debugger; that.hasPicture = false; that.recordId = response.data.id; that.formName = response.data.form_.name; @@ -868,7 +868,7 @@ //根据选择的表，渲染检查项目 submitrecordform(index) { - debugger; + // debugger; let that = this; this.outerVisible = false; if (that.recordform != "") { @@ -894,7 +894,7 @@ } }); }else if(index==='2'){//复检 - debugger; + // debugger; that.handleReview(); } } else this.$message.error("请选择检查表！"); @@ -953,14 +953,13 @@ }, //保存检查项目 recordSave(value) { - debugger; let that = this; let id = value.id; let params = {}; params.record_data = value.record_data; params.is_testok = value.is_testok; putTestRecordItem(id,params).then((res) => { - debugger; + // debugger; if (res.code >= 200) { that.recordVisible = false; that.limitedReview = false; From b104a9382834de28854a1720ae39f03f72f14516 Mon Sep 17 00:00:00 2001 From: caoqianming Date: Wed, 22 Dec 2021 08:35:21 +0800 Subject: [PATCH 6/7] =?UTF-8?q?=E6=8A=A5=E5=BA=9F=E6=93=8D=E4=BD=9Cbug?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- hb_server/apps/wpm/views.py | 17 +++++++++++++---- 1 file changed, 13 insertions(+), 4 deletions(-) diff --git a/hb_server/apps/wpm/views.py b/hb_server/apps/wpm/views.py index 4d62249..b2c6911 100644 --- a/hb_server/apps/wpm/views.py +++ b/hb_server/apps/wpm/views.py @@ -339,6 +339,7 @@ class WProductViewSet(ListModelMixin, GenericViewSet): """ obj = self.get_object() serializer = ScrapSerializer(data=request.data) + serializer.is_valid(raise_exception=True) vdata = serializer.validated_data if obj.act_state == WProduct.WPR_ACT_STATE_NOTOK: pass @@ -363,21 +364,29 @@ class WProductViewSet(ListModelMixin, GenericViewSet): # return WorkflowSimpleSerializer(instance=wfs, many=True).data @action(methods=['get'], detail=True, perms_map={'get':'*'}) - def bhg_wf(self, request, pk=None): + def wf_bhg(self, request, pk=None): """ 发起不合格审理单 """ obj = self.get_object() if obj.act_state != WProduct.WPR_ACT_STATE_NOTOK: raise exceptions.APIException('非检验不合格产品不可发起不合格审理') - ret = { + workflow = Workflow.objects.filter(name='不合格品审理单', is_deletd=False).first() + if workflow: + exist_data = { 'sys_wproduct':obj.id, 'sys_name':obj.material.name, 'sys_specification':obj.material.specification, 'sys_finder':request.user.id, 'sys_process':obj.step.process.id, - } - return Response(ret) + } + ret = {'workflow':workflow.id} + ret['exist_data'] = exist_data + return Response(ret) + else: + raise exceptions.APIException('未找到对应工作流程') + + From 5fed3d5ad869f8a2f1bc642c10d5eda9c618ddf5 Mon Sep 17 00:00:00 2001 From: caoqianming Date: Wed, 22 Dec 2021 09:02:51 +0800 Subject: [PATCH 7/7] =?UTF-8?q?=E6=8A=A5=E5=BA=9F=E6=93=8D=E4=BD=9Cbug?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- hb_server/apps/wpm/views.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hb_server/apps/wpm/views.py b/hb_server/apps/wpm/views.py index b2c6911..ae855e7 100644 --- a/hb_server/apps/wpm/views.py +++ b/hb_server/apps/wpm/views.py @@ -343,7 +343,7 @@ class WProductViewSet(ListModelMixin, GenericViewSet): vdata = serializer.validated_data if obj.act_state == WProduct.WPR_ACT_STATE_NOTOK: pass - elif obj.step.process == 1: # 如果是冷加工可直接报废 + elif obj.step.process.id == 1: # 如果是冷加工可直接报废 if vdata.get('scrap_reason', None): obj.scrap_reason = vdata['scrap_reason'] else: