SSH物流开发系统设计:业务受理逻辑实现

妖狐艹你老母 2022-06-14 02:46 180阅读 0赞

## 一、实现业务受理 ##

### 1、在crm中提供根据手机号查询客户信息方法 ###

CustomerService接口：

//根据手机号查询客户信息
        public Customer findCustomerByPhoneNumber(String phoneNumber);

CustomerServiceImpl实现类：

public Customer findCustomerByPhoneNumber(String phoneNumber) {
            Session session = HibernateUtils.openSession();
            session.beginTransaction();
            String hql = "from Customer where telephone = ?";
            List<Customer> customers = session.createQuery(hql).setParameter(0, phoneNumber).list();
            Customer c=null;
            if(customers!=null&&customers.size()>0){
                c=customers.get(0);
            }
            session.getTransaction().commit();
            session.close();
            return c;
        }

### 2、在bos中实现业务受理 ###

注意：需要将crm中接口扩展的方法复制到bos的接口中

//根据手机号查询客户信息
        public Customer findCustomerByPhoneNumber(String phoneNumber);

第一步：前端页面逻辑  
为手机号输入框绑定离焦事件，发送ajax请求，提交输入的手机号到Action，在Action中调用crm的代理对象，访问crm服务，根据手机号查询客户信息，返回json。

第二步：创建NoticebillAction，提供findCustomerByTelephone方法  
首先来看一下相关的pojo类：Noticebill

package com.crm.bos.domain;
    
    import java.util.Date;
    import java.util.HashSet;
    import java.util.Set;
    /**
     * 业务通知单
     *
     */
    
    public class Noticebill implements java.io.Serializable {
        
    
        // Fields
    
        private String id;
        private User user;//业务员
        private Staff staff;//当前业务通知单对应的取派员
        private String customerId;//客户id
        private String customerName;//客户姓名
        private String delegater;//联系人
        private String telephone;//电话
        private String pickaddress;//取件地址
        private String arrivecity;//到达城市
        private String product;//产品
        private Date pickdate;//取件时间
        private Integer num;//数量
        private Double weight;//重量
        private String volume;//体积
        private String remark;//备注
        private String ordertype;//分单类型：自动、人工
        private Set workbills = new HashSet(0);//当前业务通知单对应的工单
    
        // Constructors
    
        /** default constructor */
        public Noticebill() {
        }
    
        /** minimal constructor */
        public Noticebill(String id) {
            this.id = id;
        }
    
        /** full constructor */
        public Noticebill(String id, User user, Staff staff, String customerId,
                String customerName, String delegater, String telephone,
                String pickaddress, String arrivecity, String product,
                Date pickdate, Integer num, Double weight, String volume,
                String remark, String ordertype, Set workbills) {
            this.id = id;
            this.user = user;
            this.staff = staff;
            this.customerId = customerId;
            this.customerName = customerName;
            this.delegater = delegater;
            this.telephone = telephone;
            this.pickaddress = pickaddress;
            this.arrivecity = arrivecity;
            this.product = product;
            this.pickdate = pickdate;
            this.num = num;
            this.weight = weight;
            this.volume = volume;
            this.remark = remark;
            this.ordertype = ordertype;
            this.workbills = workbills;
        }
    
        // Property accessors
    
        public String getId() {
            return this.id;
        }
    
        public void setId(String id) {
            this.id = id;
        }
    
        public User getUser() {
            return this.user;
        }
    
        public void setUser(User user) {
            this.user = user;
        }
    
        public Staff getStaff() {
            return this.staff;
        }
    
        public void setStaff(Staff staff) {
            this.staff = staff;
        }
    
        public String getCustomerId() {
            return this.customerId;
        }
    
        public void setCustomerId(String customerId) {
            this.customerId = customerId;
        }
    
        public String getCustomerName() {
            return this.customerName;
        }
    
        public void setCustomerName(String customerName) {
            this.customerName = customerName;
        }
    
        public String getDelegater() {
            return this.delegater;
        }
    
        public void setDelegater(String delegater) {
            this.delegater = delegater;
        }
    
        public String getTelephone() {
            return this.telephone;
        }
    
        public void setTelephone(String telephone) {
            this.telephone = telephone;
        }
    
        public String getPickaddress() {
            return this.pickaddress;
        }
    
        public void setPickaddress(String pickaddress) {
            this.pickaddress = pickaddress;
        }
    
        public String getArrivecity() {
            return this.arrivecity;
        }
    
        public void setArrivecity(String arrivecity) {
            this.arrivecity = arrivecity;
        }
    
        public String getProduct() {
            return this.product;
        }
    
        public void setProduct(String product) {
            this.product = product;
        }
    
        public Date getPickdate() {
            return this.pickdate;
        }
    
        public void setPickdate(Date pickdate) {
            this.pickdate = pickdate;
        }
    
        public Integer getNum() {
            return this.num;
        }
    
        public void setNum(Integer num) {
            this.num = num;
        }
    
        public Double getWeight() {
            return this.weight;
        }
    
        public void setWeight(Double weight) {
            this.weight = weight;
        }
    
        public String getVolume() {
            return this.volume;
        }
    
        public void setVolume(String volume) {
            this.volume = volume;
        }
    
        public String getRemark() {
            return this.remark;
        }
    
        public void setRemark(String remark) {
            this.remark = remark;
        }
    
        public String getOrdertype() {
            return this.ordertype;
        }
    
        public void setOrdertype(String ordertype) {
            this.ordertype = ordertype;
        }
    
        public Set getWorkbills() {
            return this.workbills;
        }
    
        public void setWorkbills(Set workbills) {
            this.workbills = workbills;
        }
    
    }

对应的Hibernate映射文件：

<?xml version="1.0" encoding="utf-8"?>
    <!DOCTYPE hibernate-mapping PUBLIC 
        "-//Hibernate/Hibernate Mapping DTD 3.0//EN"
        "http://www.hibernate.org/dtd/hibernate-mapping-3.0.dtd">
    <hibernate-mapping>
        <class name="com.crm.bos.domain.Noticebill" table="qp_noticebill" catalog="bos19">
            <id name="id" type="java.lang.String">
                <column name="id" length="32" />
                <generator class="uuid" />
            </id>
            <many-to-one name="user" class="com.crm.bos.domain.User" fetch="select">
                <column name="user_id" length="32" />
            </many-to-one>
            <many-to-one name="staff" class="com.crm.bos.domain.Staff" fetch="select">
                <column name="staff_id" length="32" />
            </many-to-one>
            <property name="customerId" type="java.lang.String">
                <column name="customer_id" length="32" />
            </property>
            <property name="customerName" type="java.lang.String">
                <column name="customer_name" length="20" />
            </property>
            <property name="delegater" type="java.lang.String">
                <column name="delegater" length="20" />
            </property>
            <property name="telephone" type="java.lang.String">
                <column name="telephone" length="20" />
            </property>
            <property name="pickaddress" type="java.lang.String">
                <column name="pickaddress" length="200" />
            </property>
            <property name="arrivecity" type="java.lang.String">
                <column name="arrivecity" length="20" />
            </property>
            <property name="product" type="java.lang.String">
                <column name="product" length="20" />
            </property>
            <property name="pickdate" type="java.util.Date">
                <column name="pickdate" length="0" />
            </property>
            <property name="num" type="java.lang.Integer">
                <column name="num" />
            </property>
            <property name="weight" type="java.lang.Double">
                <column name="weight" precision="22" scale="0" />
            </property>
            <property name="volume" type="java.lang.String">
                <column name="volume" length="20" />
            </property>
            <property name="remark" type="java.lang.String">
                <column name="remark" />
            </property>
            <property name="ordertype" type="java.lang.String">
                <column name="ordertype" length="20" />
            </property>
            <set name="workbills" inverse="true">
                <key>
                    <column name="noticebill_id" length="32" />
                </key>
                <one-to-many class="com.crm.bos.domain.Workbill" />
            </set>
        </class>
    </hibernate-mapping>

NoticebillAction定义如下：

public class NoticebillAction extends BaseAction<Noticebill> {
        
    
        //注入CustomerService远程访问的代理对象
        @Autowired
        private CustomerService customerService;
    
        public String findCustomerByTelephone() throws IOException{
            Customer customer = customerService.findCustomerByPhoneNumber(model.getTelephone());
            String[] excludes=new String[]{};
            this.writeObject2Json(customer, excludes);
            return NONE;
        }

第三步：完善页面中ajax方法的回调函数

<input type="text" class="easyui-validatebox" name="telephone"
                            required="true" />
                            <script type="text/javascript">
                                $(function(){
         
                                    $("input[name=telephone]").blur(function(){
         
                                        var telephone = this.value;
                                        //发送ajax请求，提交手机号
                                        var url = "${pageContext.request.contextPath}/noticebillAction_findCustomerByTelephone.action";
                                        $.post(url,{
        "telephone":telephone},function(data){
         
                                            if(data != null){
                                                //查到客户信息，可以回显
                                                var cid = data.id;
                                                var name = data.name;
                                                var address = data.address;
                                                $("input[name=customerId]").val(cid);
                                                $("input[name=customerName]").val(name);
                                                $("input[name=delegater]").val(name);
                                                $("input[name=pickaddress]").val(address);
                                            }else{
                                                //清理数据 
                                                $("input[name=customerId]").val("");
                                                $("input[name=customerName]").val("");
                                                $("input[name=delegater]").val("");
                                                $("input[name=pickaddress]").val("");
                                            }
                                        },'json');
                                    });
                                });
                            </script>

第四步：为“新单”按钮绑定事件

## 二、实现自动分单 ##

第一步：在NoticebillAction中提供add方法，保存一个业务通知单数据，根据取件地址尝试自动分单。

//添加业务通知单,尝试自动分单
        public String add(){
            noticebillService.save(model);
            return "addUI";
        }

第二步：在crm服务中扩展方法，根据取件地址获取定区id

public String findDecidedzoneIdByAddress(String address) {
            Session session = HibernateUtils.openSession();
            session.beginTransaction();
            String hql = "select decidedzone_id from Customer where address = ?";
            List<String> list = session.createQuery(hql).setParameter(0, address).list();
            String addr=null;
            if(list!=null&&list.size()>0){
                addr=list.get(0);
            }
            session.getTransaction().commit();
            session.close();
            return addr;
        }

第三步：在NoticebillService中提供save方法

//注入代理对象
        @Autowired
        private CustomerService customerService;
    
        //保存业务通知单并尝试自动分单
        public void save(Noticebill model) {
            User user = BOSContext.getLoginUser();
            model.setUser(user);//当前登录用户
            noticebillDao.save(model);
    
            String pickaddress = model.getPickaddress();//获取取件地址
            //调用crm根据取件地址匹配定区id
            String decidedzoneId = customerService.findDecidedzoneIdByAddress(pickaddress);
            if(decidedzoneId!=null){
                //查询到id，可以自动分单
                model.setOrdertype("自动分单");
                //根据定区id查询定区和取派员
                Decidedzone decidedzone = decidedzoneDao.findById(decidedzoneId);
                Staff staff = decidedzone.getStaff();
                //业务通知单关联取派员
                model.setStaff(staff);
                //为取派员创建一个工单
                Workbill workbill=new Workbill();
                workbill.setAttachbilltimes(0);
                workbill.setBuildtime(new Timestamp(System.currentTimeMillis()));
                workbill.setNoticebill(model);
                workbill.setPickstate("未取件");
                workbill.setRemark(model.getRemark());
                workbill.setStaff(staff);
                workbill.setType("新单");
                workbillDao.save(workbill);
                //调用短信服务，给派送员发送短信
            }else {
                //未查询到，转入人工调度
                model.setOrdertype("人工分单");
            }
        }

## 三、源码[点我][Link 1] ##

[Link 1]: https://github.com/xiaokangjack/SSH_Logistics