文档章节

项目实训-千寻-核心业务逻辑_业务流程处理

 手指点点-千寻
发布于 2017/06/03 13:37
字数 995
阅读 5
收藏 0

本文将对核心业务流程进行分析,并讨论其实现。
1.业务流程分析
业务流程其实类似于淘宝的订单,逻辑上虽然比较容易理解,但是中间涉及多次相互确认,使得整个业务逻辑的处理变得相对麻烦起来。
-->发单者发布需求
-->接单者承接需求
-->发单者筛选并确定人选
-->接单者确认并开始执行任务
-->接单者完成任务并提交
-->发单者确认任务完成并给予酬劳
-->双方互评并可选择分享

2.用户接单请求
上一次已经把附近的需求显示出来了,这一次继续流程上的处理。关于接单,在接口上主要是接单请求的发送,如下:

// 报名
public String signUp() {
    String result = "failed";
    Object user = session.get("user");
    System.out.println("user is " + user);
    if (user == null) {
        result = "-6";// 未登录
        System.out.println("signUp-result:" + result);
        inputStream = MsgUtil.sendString(result);
        return SUCCESS;
    }
    JSONObject js = JSONObject.fromObject(jsonObj);
    String name = js.getString("username");
    String requestId = js.getString("requestId");
    System.out.println("signUp-jsonObj:" + jsonObj);
    int status = -1;
    List<User> list = null;
    try {
        int userReqeustId = Integer.parseInt(requestId);
        long username = Long.parseLong(name);
        UserRequest userRequest = userRequestService.getUserRequestById(userReqeustId);
        if (userRequest.getUser().getUsername() == username) {
            status = -4;// 不能自己报自己的名!
        } else {
            list = userRequestService.getReceiversByReqId(userReqeustId);
            boolean flag = false;
            for (User u : list) {
                System.out.println(u.getUsername() + "," + u.getId());
                if (u.getUsername() == username) {
                    flag = true;
                    break;
                }
            }
            if (flag) {// 如果已经报名
                status = -3;
            } else {
                if (list.size() < 8) {
                    // 能报名,则保存
                    UserRequest ur = userRequestService.getUserRequestById(userReqeustId);
                    Set<User> receivers = ur.getReceivers();
                    System.out.println("r1:" + receivers.size());
                    User u = userService.findByUsername(username);
                    receivers.add(u);
                    Set<UserRequest> receivedRequests = u.getReceivedRequest();
                    receivedRequests.add(ur);
                    ur.setReceivers(receivers);
                    u.setReceivedRequest(receivedRequests);

                    System.out.println("r2:" + ur.getReceivers().size());
                    userRequestService.update(ur);
                    userService.update(u);
                    list.add(u);
                    try {
                        // 发推送
                        String context = "[需求报名]您发的需求有人报名!点击查看";
                        String detail = "[需求报名]您的需求"
                                + (userRequest.getRequest_content().length() > 6 ? userRequest.getRequest_content()
                                        .substring(0, 6) : userRequest.getRequest_content()) + "...有用户 "
                                + u.getNickName() + "报名了!";
                        BaiChuanUtils.pushJson(ur.getUser().getId(), BaiChuanUtils.MY_REQUEST, context, detail);
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                    status = 1;
                }
            }
        }
    } catch (Exception e) {
        status = -2;
        list = null;
        e.printStackTrace();
    }
    JSONObject jsResp = new JSONObject();
    JsonConfig jsonConfig = new JsonConfig();
    jsonConfig.setCycleDetectionStrategy(CycleDetectionStrategy.LENIENT);
    jsonConfig.setExcludes(new String[] { "receivedRequest", "concernedPeople", "todoRequest", "userRequest",
            "userComment", "favoriteServices", "services" });
    JSONArray listJs = JSONArray.fromObject(list, jsonConfig);
    jsResp.put("status", status);
    jsResp.put("list", listJs);
    result = jsResp.toString();
    System.out.println("signUp-result:" + result);
    inputStream = MsgUtil.sendString(result);
    return SUCCESS;
}

3.发单者筛选确定人选
多人报名时,需要发单者确定最佳人选。此时,发单者需要在显示的报名者中,选出一人执行任务。

public String takeOrder() {
    String result = "failed";
    int status = -1;
    Object user = session.get("user");
    System.out.println("user is " + user);
    if (user == null) {
        result = "-6";// 未登录
        System.out.println("reminder-result:" + result);
        inputStream = MsgUtil.sendString(result);
        return SUCCESS;
    }
    System.out.println("takeOrder-username:" + username);
    System.out.println("takeOrder-requestId:" + requestId);
    long username = Long.parseLong(this.username);
    int requestId = Integer.parseInt(this.requestId);
    UserRequest userRequest = userRequestService.getUserRequestById(requestId);
    if (userRequest.getFinalReceiver() != null) {
        status = -3; // 已经有人接单
    } else {
        try {
            if (username == userRequest.getUser().getUsername()) {
                status = -4;// 不能自己接自己的单!
            } else {
                User finalReceiver = userService.findByUsername(username);
                userRequest.setFinalReceiver(finalReceiver);
                userRequest.setStatus(1);
                userRequestService.update(userRequest);
                status = 1;
                try {
                    // 给那些已经报名但是没选为接单的用户发推送。
                    String context = "[接单啦]恭喜!需求方已选择您接单!点击查看!";
                    String detail = "[接单啦]恭喜!需求方已选择您接 " + userRequest.getRequest_content().substring(0, 6)
                            + "...这个单子,赶紧去查看详情吧!";
                    BaiChuanUtils.pushJson(finalReceiver.getId(), BaiChuanUtils.HIS_REQUEST, context, detail);
                    List<User> list = userRequestService.getReceiversByReqId(requestId);
                    for (User u : list) {
                        if (u.getUsername() != username) {
                            context = "[接单失败]亲,橙子" + userRequest.getUser().getNickName() + "...已被他人接单,点击查看详情";
                            detail = "[接单失败]亲,需求"
                                    + (userRequest.getRequest_content().length() > 6 ? userRequest
                                            .getRequest_content().substring(0, 6) : userRequest
                                            .getRequest_content()) + "...已被他人接单,赶快去寻找其他订单吧";
                            BaiChuanUtils.pushJson(u.getId(), BaiChuanUtils.HIS_REQUEST, context, detail);
                        }
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                }

            }
        } catch (Exception e) {
            status = -2;
            e.printStackTrace();
        }
    }
    result = status + "";
    System.out.println("takeOrder-result:" + result);
    inputStream = MsgUtil.sendString(result);
    return SUCCESS;
}

4.接单者完成任务并接受验收
确定人选后,接单者将会去完成该任务,与此同时,两者可以通过即时通讯功能进行聊天,并且可以相互发送位置便于确认。本来我们想实时共享双方的位置,但是后来考虑到双方的隐私,就放弃了这个想法。
接单者完成任务后,就可以提交任务,设置任务为完成状态了。

5.用户评价与分享
任务完成了,怎么也少不了评价与分享。这就是用户晒单。用户可以分享自己的订单到我们的宣传,去为自己积累“赞”。至此,整套业务流程就圆满完成了。
 

© 著作权归作者所有

共有 人打赏支持
粉丝 0
博文 14
码字总数 9640
作品 0
济南
私信 提问
哈尔滨大数据培训课程哪个好?从内容教你如何判断

导读 随着大数据飞速发展,大数据将对人类生活产生深远影响,大数据是未来科技浪潮发展不容忽视的巨大推动力量,加上人工智能对大数据技术的需要,使越来越多的人想要从事大数据,但却不知道哈...

hxl0009
04/16
0
0
MoPaaS鲁为民:从云计算到人工智能,释放PaaS的价值

注:本文转载自科技云报道对鲁为民博士的专访,感谢科技云报道对MoPaaS的认可与支持。 五年前,他从硅谷回到中国,创立了一家基于企业级PaaS服务的云计算企业,如今他又凭借自己的兴趣和业务...

mopaas
2017/10/23
155
0
翻译:1.1. What is jBPM?

小弟不才。刚刚开始学习jBPM。翻译的水平也不佳。欢迎指正,共同学习。 原文地址 jBPM是一套使用java开发出的灵活的,轻量级的,完全开源的业务流程管理组件。在业务流程的整个生命周期中,你...

李渊
2012/03/08
316
4
哈,好久没喷了,喷下设计该谁做。。。

哈,不多说别的,正好手上有个需求案子。简单说说,就是从多个业务流中抽取数据,每个业务流可以看作专门的信息系统吧,然后根据企业的管理要求,进行数据分析,分析后的信息,按照一定形式展...

中山野鬼
2014/01/28
971
12
系统架构师-基础到企业应用架构-业务逻辑层

一、上章回顾 上章我们主要讲述了系统设计规范与原则中的具体原则与规范及如何实现满足规范的设计,我们也讲述了通过分离功能点的方式来实现,而在软件开发过程中的具 体实现方式简单的分为面...

wbf961127
2017/11/12
0
0

没有更多内容

加载失败,请刷新页面

加载更多

搭建git服务器————gitlab

github毕竟是公开的,而私有仓库又得花钱买。所以我们可以想办法搭建一个私有的,只自己公司使用的。Gitlab是个不错的选择。在介绍它之前,先讲述一下命令行的git服务器 找一台服务器,首先要...

chencheng-linux
6分钟前
1
0
用Redis实现“秒杀”系统

导论 曾经被问过好多次怎样实现秒杀系统的问题。昨天又在CSDN架构师微信群被问到了。因此这里把我设想的实现秒杀系统的价格设计分享出来。供大家参考。 秒杀系统的架构设计 秒杀系统,是典型...

小刀爱编程
20分钟前
7
0
GO redis 相关操作

在gopath 目录下安装 go get github.com/garyburd/redigo/redis package mainimport ("fmt""github.com/garyburd/redigo/redis")//定义一个全局链接池变量var pool *redis.Pool//......

汤汤圆圆
58分钟前
20
0
java8性特性,常用的lambda表达式

1、抽取多个对象中的某个属性,用数组接收 List<Student> students = new ArrayList<>(); List<String> names =students.stream().map(Student::getName).collect(Collectors.toList()); 2、......

Boss-x
59分钟前
19
0
flutter 子组件与父组件

无论是子组件还是父组件,任何时候initState()只执行一次,如果需要判断 就在build里面进行,不然无效的。

大灰狼wow
今天
9
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部