SsdbGendanController.java

package com.fadu.jeefw.controller.ssdb;

import com.fadu.app.service.CommonService;
import com.fadu.app.util.PageList;
import com.fadu.core.support.ExtJSBaseParameter;
import com.fadu.core.support.JqGridPageView;
import com.fadu.jeefw.core.JavaEEFrameworkBaseController;
import com.fadu.jeefw.model.sys.SysUser;
import com.fadu.jeefw.service.sys.SysUserService;
import com.fadu.jeefw.web.ssdb.bean.SsdbKefuUser;
import com.fadu.jeefw.web.ssdb.bean.SsdbOrderKefu;
import com.fadu.jeefw.web.ssdb.bean.SsdbOrderKefuBean;
import com.fadu.model.ssdb.SsdbOrder;
import com.fadu.model.sys.DataDict;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.text.DecimalFormat;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

@Controller
@RequestMapping(value = "/ssdb/gendan")
public class SsdbGendanController extends
        JavaEEFrameworkBaseController<ExtJSBaseParameter> {

    @Autowired
    private CommonService commonService;

    @Autowired
    private SysUserService sysUserService;

    private DecimalFormat df = new DecimalFormat("#.##");


    //获取客服信息
    @RequestMapping(value = "/getKefuUser")
    public void getKefuUser(HttpServletRequest request, HttpServletResponse response
    ) throws Exception {
        int page = Integer.parseInt(request.getParameter("page"));
        int rows = Integer.parseInt(request.getParameter("rows"));
        String hql = "from SysUser where departmentKey = 'KFB-Z' ";
        PageList<SysUser> pageList = commonService.findPageList(hql,page,rows);
        JqGridPageView<SsdbKefuUser> pageView = new JqGridPageView<>();
        pageView.setMaxResults(pageList.getRows());
        pageView.setRows(getPageList(pageList.getList()));
        pageView.setRecords(pageList.getTotal());
        writeJSON(response, pageView);
    }
    //获取客服信息
    @RequestMapping(value = "/getSoudong")
    public void getSoudong(HttpServletRequest request, HttpServletResponse response
    ) throws Exception {
        int page = Integer.parseInt(request.getParameter("page"));
        int rows = Integer.parseInt(request.getParameter("rows"));
        String sql = "SELECT a.orderId , a.createDate , c.`loginName` , d.`name` as courtName ,  " +
                "       b.`real_name` as lawyerName , b.`phone` , a.`bf` , a.`documentaryUser`" +
                "       FROM ssdb_order a" +
                "       LEFT JOIN lawyer b ON a.`lawyer_id` = b.`id`" +
                "       LEFT JOIN ssdb_company c ON a.`company_id` = c.`id`" +
                "       LEFT JOIN court d ON a.court_id = d.id " +
                "      WHERE a.`documentaryUser` = '待分配'";

        try {
            PageList<SsdbOrderKefu> pageList = commonService.findSqlPageList(sql,page,rows, SsdbOrderKefu.class);
            JqGridPageView<SsdbOrderKefuBean> pageView = new JqGridPageView<>();
            pageView.setMaxResults(pageList.getRows());
            pageView.setRows(getKefuPageList(pageList.getList()));
            pageView.setRecords(pageList.getTotal());
            writeJSON(response, pageView);
        }catch (Exception e){
            e.printStackTrace();
        }
    }

    //获取客服信息
    @RequestMapping(value = "/getKefuList")
    public void getKefuList(HttpServletRequest request, HttpServletResponse response
    ) throws Exception {
        try {
            String sql = "select real_name from sys_user where " +
                    "department_Key = 'KFB-Z' and STATUS = 'false'";
            List<String> list = commonService.findListBySql(sql);
            writeJSON(response, list);
        }catch (Exception e){
            e.printStackTrace();
        }

    }
    //进行手动分配
    @RequestMapping(value = "/fenpei")
    public void fenpei(HttpServletRequest request, HttpServletResponse response,
    String orderId ,String documentaryUser) throws Exception {
        Map<String , String> mm = new HashMap<>();
        try {
            String hql = "from SsdbOrder where orderId = ?";
            SsdbOrder ssd = commonService.findObject(hql , orderId);
            ssd.setDocumentaryUser(documentaryUser);
            commonService.saveOrUpdateObject(ssd);
            mm.put("isOk","您已成功分配！");
        }catch (Exception e){
            e.printStackTrace();
            mm.put("isOk","分配失败！");
        }
        writeJSON(response, mm);
    }

    //获得分配方式
    @RequestMapping(value = "/getfp")
    public void getfp(HttpServletRequest request, HttpServletResponse response) throws Exception {
        Map<String , String> mm = new HashMap<>();
        try {
            String hql = " from DataDict where dataKey = 'isOpen' ";
            DataDict d = commonService.findObject(hql);
            mm.put("message",d.getDataValue());
        }catch (Exception e){
            e.printStackTrace();
        }
        writeJSON(response, mm);
    }
    //修改分配方式
    @RequestMapping(value = "/changeFp")
    public void changeFp(HttpServletRequest request, HttpServletResponse response,String fp) throws Exception {
        Map<String , String> mm = new HashMap<>();
        String hql = " from DataDict where dataKey = 'isOpen' ";
        DataDict d = commonService.findObject(hql);
        try {
            d.setDataValue(fp);
            commonService.saveOrUpdateObject(d);
            mm.put("succ","true");
            mm.put("message","修改成功！");
        }catch (Exception e){
            e.printStackTrace();
            mm.put("succ","false");
            mm.put("message","修改失败！");
        }
        writeJSON(response,mm);
    }

    private List<SsdbKefuUser> getPageList(List<SysUser> list){
        List <SsdbKefuUser> sslist = new ArrayList<>();
        for (SysUser ss : list){
            SsdbKefuUser sk = new SsdbKefuUser();
            sk.setId(ss.getId().toString());
            sk.setUserName(ss.getUserName());
            sk.setRealName(ss.getRealName());
            sk.setSexCn(getSex(ss.getSex()));
            sk.setEmail(ss.getEmail());
            sk.setPhone(ss.getPhone());
            sk.setBirthday(ss.getBirthday().toString());
            sk.setDepartmentValue(getSwitchCase(ss.getDepartmentKey()));
            sk.setRoleCn(getRole(ss.getRoleKey()));
            sk.setStatusCn(ss.getStatus() ? "是" : "否");
            if (ss.getLastLoginTime() != null){
                sk.setLastLoginTime(ss.getLastLoginTime().toString());
            }else{
                sk.setLastLoginTime("暂无记录");
            }
            sslist.add(sk);
        }
        return sslist;
    }


    private List<SsdbOrderKefuBean> getKefuPageList(List<SsdbOrderKefu> list){
        List <SsdbOrderKefuBean> sslist = new ArrayList<>();
        for (SsdbOrderKefu ss : list){
            SsdbOrderKefuBean sk = new SsdbOrderKefuBean();
            sk.setOrderId(ss.getOrderId());
            sk.setCreateDate(ss.getCreateDate().toString());
            sk.setLoginName(ss.getLoginName());
            sk.setCourtName(ss.getCourtName());
            sk.setLawyerName(ss.getLawyerName());
            sk.setPhone(ss.getPhone());
            sk.setBf(ss.getBf().toString());
            sk.setDocumentaryUser(ss.getDocumentaryUser());
            sslist.add(sk);
        }
        return sslist;
    }

    private String  getSwitchCase(String v) {
        String dep;
        switch (v) {
            case "YFB":
                dep = "研发部";
                break;
            case "KFB":
                dep = "客服部";
                break;
            case "XZB":
                dep = "律师部";
                break;
            case "SCB":
                dep = "运营部";
                break;
            case "CPB":
                dep = "产品部";
                break;
            case "CWB":
                dep = "财务部";
                break;
            case "JRB":
                dep = "金融部";
                break;
            case "KFB-Z":
                dep = "保险科技部";
                break;
            default:
                dep = "状态出错";
                break;
        }
        return dep;
    }
    private String  getRole(String v) {
        String dep;
        switch (v) {
            case "ROLE_ADMIN":
                dep = "超级管理员";
                break;
            case "ROLE_RESTRICTED_ADMIN":
                dep = "普通管理员";
                break;
            case "ROLE_USER":
                dep = "普通用户";
                break;
            case "ROLE_FS":
                dep = "财务";
                break;
            case "KEFU":
                dep = "客服";
                break;
            case "KEFU-Z":
                dep = "客服子账号";
                break;
            default:
                dep = "状态出错";
                break;
        }
        return dep;
    }
    private String  getSex(short v) {
        String sex;
        switch (v) {
            case 1:
                sex = "男";
                break;
            case 2:
                sex = "女";
                break;
            default:
                sex = "状态出错";
                break;
        }
        return sex;
    }
}