| | |
| | | |
| | | import com.fzzy.igds.constant.Constant; |
| | | import com.fzzy.igds.data.BaseResp; |
| | | import com.fzzy.igds.data.PledgeReminders; |
| | | import com.fzzy.igds.domain.InoutNoticeIn; |
| | | import com.fzzy.igds.domain.InoutNoticeOut; |
| | | import com.fzzy.igds.domain.PledgeContract; |
| | | import com.fzzy.igds.utils.ContextUtil; |
| | | import com.fzzy.work.data.WorkStatus; |
| | | import com.fzzy.work.data.WorkBizType; |
| | | import com.fzzy.work.data.WorkNode; |
| | | import com.fzzy.work.data.WorkStatus; |
| | | import com.fzzy.work.domain.WorkOrder; |
| | | import com.fzzy.work.domain.WorkOrderConf; |
| | | import com.fzzy.work.domain.WorkOrderProcess; |
| | |
| | | import org.springframework.stereotype.Service; |
| | | |
| | | import javax.annotation.Resource; |
| | | import java.text.DecimalFormat; |
| | | import java.util.Date; |
| | | import java.util.List; |
| | | |
| | | /** |
| | | * @Desc: 工单业务接口 |
| | |
| | | @Slf4j |
| | | @Service |
| | | public class BizWorkService { |
| | | |
| | | @Resource |
| | | private WorkOrderConfService confService; |
| | | @Resource |
| | |
| | | |
| | | /** |
| | | * 获取流程配置信息 |
| | | * |
| | | * @param deptId 库区ID |
| | | * @param type 业务类型 |
| | | * @param type 业务类型 |
| | | * @return 配置信息 |
| | | */ |
| | | public WorkOrderConf getConfByDeptId(String deptId, WorkBizType type) { |
| | |
| | | /** |
| | | * |
| | | * 根据出入库通知单启动审批工单 |
| | | * |
| | | * @param data 出入库工单数据 |
| | | * @return 响应结果 |
| | | */ |
| | |
| | | work.setDeptId(data.getDeptId()); |
| | | work.setCompanyId(data.getCompanyId()); |
| | | work.setUpdateTime(new Date()); |
| | | work.setTitle("入库通知单审批"); |
| | | work.setTitle(data.getName() + "-审批"); |
| | | work.setConfId(conf.getId()); |
| | | work.setStatus(WorkStatus.STATUS_30.getCode()); |
| | | work.setReceiveTime(new Date()); |
| | |
| | | /** |
| | | * |
| | | * 根据出出库通知单启动审批工单 |
| | | * |
| | | * @param data 出入库工单数据 |
| | | * @return 响应结果 |
| | | */ |
| | |
| | | work.setDeptId(data.getDeptId()); |
| | | work.setCompanyId(data.getCompanyId()); |
| | | work.setUpdateTime(new Date()); |
| | | work.setTitle("出库通知单审批"); |
| | | work.setTitle(data.getName() + "-审批"); |
| | | work.setConfId(conf.getId()); |
| | | work.setStatus(WorkStatus.STATUS_30.getCode()); |
| | | work.setReceiveTime(new Date()); |
| | |
| | | |
| | | /** |
| | | * 根据当前节点获取下一个节点 |
| | | * |
| | | * @param curNode |
| | | * @param conf |
| | | * @return |
| | |
| | | /** |
| | | * |
| | | * 根据出入库通知单启动审批工单 |
| | | * |
| | | * @param data 出入库工单数据 |
| | | * @return 响应结果 |
| | | */ |
| | | public BaseResp startByBackMoney(PledgeContract data, WorkOrderConf conf) { |
| | | public BaseResp startByBackMoney(PledgeContract data, WorkOrderConf conf, List<PledgeReminders> remindersList) { |
| | | |
| | | if (null == conf) conf = confService.getByDeptId(data.getPledgeDept(), WorkBizType.TYPE_10); |
| | | |
| | | if (Constant.YN_N.equals(conf.getValTag())) return BaseResp.error("流程未启用"); |
| | | |
| | | //创建工单 |
| | | StringBuilder description = new StringBuilder("当前合同<" + data.getName() + ">下"); |
| | | if (!remindersList.isEmpty()) { |
| | | Double sumMoneyNum = 0.0; |
| | | DecimalFormat df = new DecimalFormat("0.00"); |
| | | |
| | | for (PledgeReminders reminders : remindersList) { |
| | | description.append(",仓库<").append(reminders.getDepotName()).append(">,质押物<").append(reminders.getFoodVarietyName()).append(">库存量为").append(df.format(reminders.getStorageReal())).append("kg,单价").append(reminders.getFoodPrice()).append("元,"); |
| | | sumMoneyNum += reminders.getStorageReal() * reminders.getFoodPrice(); |
| | | } |
| | | description.append("库存量总金额为").append(df.format(sumMoneyNum)).append("元,达到合同待还款金额的110%,请提醒企业进款还款"); |
| | | } else { |
| | | description.append("质押仓库<").append(data.getDepotNames()).append(">库存量金额高于待还款金额,需要进行还款"); |
| | | } |
| | | WorkOrder work = new WorkOrder(); |
| | | work.setId(ContextUtil.generateOrderId("WARN")); |
| | | work.setBizType(WorkBizType.TYPE_50.getCode()); |
| | |
| | | work.setConfId(conf.getId()); |
| | | work.setStatus(WorkStatus.STATUS_30.getCode()); |
| | | work.setReceiveTime(new Date()); |
| | | |
| | | work.setDescription("当前合同<"+ data.getName() + ">下质押仓库<"+data.getDepotNames()+">库存量金额低于待还款金额,需要进行还款!"); |
| | | |
| | | work.setDescription(description.toString()); |
| | | work.setCreateBy("系统生成"); |
| | | work.setCreateById("sys"); |
| | | work.setUpdateBy("系统生成"); |
| | |
| | | |
| | | /** |
| | | * 获取待处理工单 |
| | | * |
| | | * @return 处理结果 |
| | | */ |
| | | public BaseResp todoByProcess(WorkOrderProcess process) { |
| | |
| | | return BaseResp.error("当前工单已处理,请刷新页面重试!!"); |
| | | } |
| | | |
| | | |
| | | //判断是不是指定处理人 |
| | | SysUser user = ContextUtil.getLoginUser(); |
| | | if (StringUtils.isNotEmpty(work.getAssigneeId())) { |
| | |
| | | WorkOrderConf conf = confService.selectById(work.getConfId()); |
| | | if (null == conf) return BaseResp.error("当前工单未配置流程"); |
| | | |
| | | |
| | | //添加记录 |
| | | process.setId(ContextUtil.UUID()); |
| | | process.setCreateTime(new Date()); |
| | |
| | | |
| | | WorkNode nextNode = this.getNextNode(work.getNode(), conf); |
| | | |
| | | log.info("工单审批:{},当前节点:{},下一节点:{}", work.getTitle(), work.getNode(), nextNode); |
| | | log.info("工单审批:{},执行动作:{},当前节点:{},下一节点:{}", work.getTitle(), action, work.getNode(), nextNode); |
| | | |
| | | //通过操作 |
| | | if ("pass".equals(action)) { |
| | |
| | | work.setAssigneeId(process.getAssigneeId()); |
| | | work.setNode(nextNode.getCode()); |
| | | orderService.complete(work); |
| | | } else { |
| | | work.setNode(nextNode.getCode()); |
| | | work.setStatus(WorkStatus.STATUS_30.getCode()); |
| | | orderService.updateData(work); |
| | | } |
| | | |
| | | //增加审批记录 |
| | |
| | | //拒绝操作 |
| | | if ("refuse".equals(action)) { |
| | | process.setAction("拒绝"); |
| | | process.setNode(WorkNode.NODE_END.getCode()); |
| | | process.setNode(work.getNode()); |
| | | |
| | | work.setStatus(WorkStatus.STATUS_60.getCode()); |
| | | |
| | | orderService.complete(work); |
| | | |
| | | //增加审批记录 |
| | | orderProcessService.addData(process, true); |
| | | |
| | | return BaseResp.success(); |
| | | } |
| | | |
| | | //异常处理 |
| | | if ("error".equals(action)) { |
| | | process.setAction("异常处理"); |
| | | process.setNode(work.getNode()); |
| | | work.setStatus(WorkStatus.STATUS_50.getCode()); |
| | | |
| | | // work.setAssigneeName(process.getAssigneeName()); |
| | | // work.setAssigneeId(process.getAssigneeId()); |
| | | |
| | | orderService.complete(work); |
| | | |
| | | //增加审批记录 |
| | | orderProcessService.addData(process, true); |
| | | |