iamberry-common-parent/watero-rst-web/src/main/java/com/iamberry/rst/controllers/cm/AdminSignclosedController.java

package com.iamberry.rst.controllers.cm;

import com.iamberry.rst.core.cm.CompanyInfo;
import com.iamberry.rst.core.fm.*;
import com.iamberry.rst.core.order.Product;
import com.iamberry.rst.core.page.PageRequest;
import com.iamberry.rst.core.page.PagedResult;
import com.iamberry.rst.core.pts.PtsMachine;
import com.iamberry.rst.core.tools.LogisticsInfo;
import com.iamberry.rst.faces.cm.CompanyInfoService;
import com.iamberry.rst.faces.fm.AwaitingSignclosedProductInfoService;
import com.iamberry.rst.faces.fm.ComplaintDetectInfoService;
import com.iamberry.rst.faces.fm.ComplaintSignclosedInfoService;
import com.iamberry.rst.faces.fm.ComplaintSignclosedProductInfoService;
import com.iamberry.rst.faces.order.LogisticsInfoService;
import com.iamberry.rst.faces.product.ProductService;
import com.iamberry.rst.faces.pts.MachineService;
import com.iamberry.rst.service.fm.mapper.ComplaintSignclosedProductInfoMapper;
import com.iamberry.rst.utils.StitchAttrUtil;
import com.iamberry.wechat.tools.ResponseJson;
import net.sf.json.JSONArray;
import net.sf.json.JSONObject;
import org.apache.shiro.authz.annotation.RequiresPermissions;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.servlet.ModelAndView;

import javax.servlet.http.HttpServletRequest;
import java.text.SimpleDateFormat;
import java.util.*;

/**
 * Created by wxm on 2017/8/29.
 */
@Controller
@RequestMapping("/admin/signclosed")
public class AdminSignclosedController {

   // private
    @Autowired
    private ComplaintDetectInfoService complaintDetectInfoService;
    @Autowired
    private ProductService productService;
    @Autowired
    private ComplaintSignclosedInfoService complaintSignclosedInfoService;
    @Autowired
    private MachineService machineService;
    @Autowired
    private LogisticsInfoService logisticsInfoService;
    @Autowired
    private CompanyInfoService companyInfoService;
    @Autowired
    private ComplaintSignclosedProductInfoService complaintSignclosedProductInfoService;

    /**
     * 跳转到添加签收记录页面
     *
     * @return
     */
    @RequiresPermissions("signclosed:add:signclosed")
    @RequestMapping(value = "/to_add_signclosed")
    public ModelAndView toAddDetect(HttpServletRequest request) {
        ModelAndView mv = new ModelAndView("cm/signclosed/add_signclosed");
        //获取所有产品及其颜色，配件
        Product product = new Product();
        List<Product> productList = productService.listProductAndColorAndfittings(product);
        mv.addObject("productList",productList);
        List<LogisticsInfo> logisticsInfoList =  logisticsInfoService.getLogisticsInfoList(new LogisticsInfo());
        mv.addObject("logisticsInfoList",logisticsInfoList);
        List<CompanyInfo> companyInfoList =  companyInfoService.listCompanyInfo(new CompanyInfo());
        mv.addObject("companyInfoList",companyInfoList);
        return mv;
    }



    /**
     * 客诉 - 查询签收/仓储列表
     * @param request
     * @return
     */
    @RequiresPermissions("signclosed:select:signclosed")
    @RequestMapping("/select_signclosed_list")
    public ModelAndView selectDetectList(HttpServletRequest request,
                                        @RequestParam(value = "pageNO", defaultValue = "1", required = false) int pageNO,
                                        @RequestParam(value = "pageTotal", required = false) Integer pageTotal,
                                        @RequestParam(value = "pageSize", defaultValue = "10", required = false) int pageSize,
                                         ComplaintSignclosedInfo signclosedInfo) {
        ModelAndView mv = new ModelAndView("cm/signclosed/signclosed_list");
        if(signclosedInfo.getIsBinding() != null && signclosedInfo.getIsBinding() == 1){
            mv = new ModelAndView("cm/signclosed/customer_signclosed_list");
        }

        StringBuilder url = new StringBuilder("/admin/signclosed/select_signclosed_list?pageSize=" + pageSize);
        // 封装请求数据
        PageRequest<ComplaintSignclosedInfo> pageRequest = new PageRequest<>(signclosedInfo, pageNO, pageSize, pageTotal == null);
        // 查询订单列表
        PagedResult<ComplaintSignclosedInfo> result = complaintSignclosedInfoService.listSignclosed(pageRequest);
        long total = 0;
        if (pageTotal == null) {
            total = result.getPages();
        } else {
            total = pageTotal;
            result.setPages(total);
        }

       /* url.append("&pageTotal=").append(total).append("&pageNO=");
        mv.addObject("page", result);
        mv.addObject("url", url.toString());*/
         StitchAttrUtil.getSa().setModelAndView(signclosedInfo, mv, "/admin/signclosed/select_signclosed_list", result);
        return mv;
    }


    /**
     * 获取机器信息
     * @param
     * @return
     * @throws Exception
     */
    @ResponseBody
    @RequiresPermissions("signclosed:add:signclosed")
    @RequestMapping("/get_machine_id")
    public ResponseJson getMachineId(@RequestParam(value = "pageSize", defaultValue = "10", required = false) Integer pageSize,
                                     @RequestParam(value = "pageNO", defaultValue = "1", required = false) Integer pageNO,
                                     @RequestParam(value = "pageTotal", required = false) Integer pageTotal,
                                     PtsMachine ptsMachine) throws Exception {
        ResponseJson rj = new ResponseJson();
        List<PtsMachine> ptsMachineList = machineService.ListPtsMachineToSignclosed(ptsMachine);

        List results = new ArrayList();
        for (PtsMachine machine : ptsMachineList){
            Map<String,Object> m = new HashMap<String,Object>();
            m.put("id",machine.getMachineId());
            m.put("text",machine.getMachineBarcode());
            results.add(m);
        }

//        Map<String,Object> paginationMap = new HashMap<String,Object>();
//        paginationMap.put("more",true);
//
//        Map<String,Object> map = new HashMap<String,Object>();
//        map.put("results",results);
//        map.put("pagination",paginationMap);
//
//        rj.addResponseKeyValue("map",map);
        rj.addResponseKeyValue("results",results);
        return rj;
    }

    /**
     * 添加签收信息
     * @param request
     * @return
     * @throws Exception
     */
    @RequiresPermissions("signclosed:add:signclosed")
    @ResponseBody
    @RequestMapping("/add_signclosed")
    public ResponseJson addSignclosed(HttpServletRequest request,ComplaintSignclosedInfo signclosedInfo,String orderItemString) throws Exception {
        ResponseJson msg = new ResponseJson();
        if(signclosedInfo == null){
            msg.setResultCode(200);
            msg.setReturnCode(500);
            return msg;
        }

        if(orderItemString == null){
            msg.setResultCode(200);
            msg.setReturnCode(502);
            return msg;
        }
        JSONArray jsonArray = JSONArray.fromObject(orderItemString);
        JSONObject jsonArray2  = jsonArray.getJSONObject(0);
        if(jsonArray2.get("itemNum").equals("")){
            msg.setResultCode(200);
             msg.setReturnCode(503);
            return msg;
        }
        //获取签收图片
        String[] componentsImgs = request.getParameterValues("componentsImg");
        String signclosedDate = request.getParameter("signclosed_date");
        if(signclosedDate != null){
            SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");
            signclosedInfo.setSignclosedDate(format.parse(signclosedDate));
        }
        signclosedInfo.setSignclosedCreateTime(new Date());
        signclosedInfo.setSignclosedIsReceiving(2);
        boolean num = complaintSignclosedInfoService.insert(signclosedInfo,orderItemString,componentsImgs);


        if (!num) {
            msg.setResultCode(200);
            msg.setReturnCode(500);
        } else {
            msg.setResultCode(200);
            msg.setReturnCode(200);
        }
        return msg;
    }

    /**
     * 跳转到完成签收记录页面
     *
     * @return
     */
    @RequiresPermissions("signclosed:update:signclosed")
    @RequestMapping(value = "/to_complete_signclosed")
    public ModelAndView toCompleteDetect(HttpServletRequest request,Integer signclosedId) {
        ModelAndView mv = new ModelAndView("cm/signclosed/complete_signclosed");
        if(signclosedId == null){
            return mv;
        }
        Product product = new Product();
        List<Product> productList = productService.listProductAndColorAndfittings(product);
        mv.addObject("productList",productList);
        List<LogisticsInfo> logisticsInfoList =  logisticsInfoService.getLogisticsInfoList(new LogisticsInfo());
        mv.addObject("logisticsInfoList",logisticsInfoList);
        List<CompanyInfo> companyInfoList =  companyInfoService.listCompanyInfo(new CompanyInfo());
        mv.addObject("companyInfoList",companyInfoList);
        ComplaintSignclosedInfo complaintSignclosedInfo = complaintSignclosedInfoService.getSignclosedById(signclosedId);
        complaintSignclosedInfo.setSignclosedDate(new Date());
        mv.addObject("complaintSignclosedInfo",complaintSignclosedInfo);
        return mv;
    }


    /**
     * 完成签收信息
     * @param request
     * @return
     * @throws Exception
     */
    @RequiresPermissions("signclosed:update:signclosed")
    @ResponseBody
    @RequestMapping("/complete_signclosed")
    public ResponseJson completeSignclosed(HttpServletRequest request,ComplaintSignclosedInfo signclosedInfo,String orderItemString) throws Exception {
        ResponseJson msg = new ResponseJson();
        if(signclosedInfo == null){
            msg.setResultCode(200);
            msg.setReturnCode(500);
            return msg;
        }

        if(orderItemString == null){
            msg.setResultCode(200);
            msg.setReturnCode(502);
            return msg;
        }
        JSONArray jsonArray = JSONArray.fromObject(orderItemString);
        JSONObject jsonArray2  = jsonArray.getJSONObject(0);
        if(jsonArray2.get("itemNum").equals("")){
            msg.setResultCode(200);
            msg.setReturnCode(503);
            return msg;
        }
        //获取签收图片
        String[] componentsImgs = request.getParameterValues("componentsImg");
        String signclosedDate = request.getParameter("signclosed_date");
        if(signclosedDate != null){
            SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");
            signclosedInfo.setSignclosedDate(format.parse(signclosedDate));
        }
        signclosedInfo.setSignclosedCreateTime(new Date());
        signclosedInfo.setSignclosedIsReceiving(2);
        boolean num = complaintSignclosedInfoService.updateSignclosedById(signclosedInfo,orderItemString,componentsImgs);


        if (!num) {
            msg.setResultCode(200);
            msg.setReturnCode(500);
        } else {
            msg.setResultCode(200);
            msg.setReturnCode(200);
        }
        return msg;
    }

    /**
     * 跳转到修改备注页面
     *
     * @return
     */
    @RequiresPermissions("signclosed:update:signclosed")
    @RequestMapping(value = "/to_update_remark")
    public ModelAndView toUpdateRemark(HttpServletRequest request,Integer signclosedId) {
        ModelAndView mv = new ModelAndView("cm/signclosed/update_remark");
        ComplaintSignclosedInfo complaintSignclosedInfo = complaintSignclosedInfoService.getSignclosedById(signclosedId);
        mv.addObject("signclosedId",signclosedId);
        mv.addObject("complaintSignclosedInfo",complaintSignclosedInfo);
        return mv;
    }
    /**
     * 跳转到客服修改备注页面
     *
     * @return
     */
    @RequiresPermissions("signclosed:update:signclosed")
    @RequestMapping(value = "/to_update_customer_remark")
    public ModelAndView toUpdateCustomerRemark(HttpServletRequest request,Integer signclosedId) {
        ModelAndView mv = new ModelAndView("cm/signclosed/update_customer_remark");
        ComplaintSignclosedInfo complaintSignclosedInfo = complaintSignclosedInfoService.getSignclosedById(signclosedId);
        mv.addObject("signclosedId",signclosedId);
        mv.addObject("complaintSignclosedInfo",complaintSignclosedInfo);
        return mv;
    }
    /**
     * 修改备注
     *
     * @return
     */
    @ResponseBody
    @RequiresPermissions("signclosed:update:signclosed")
    @RequestMapping(value = "/update_remark")
    public ResponseJson updateRemark(HttpServletRequest request,ComplaintSignclosedInfo signclosedInfo){
        ResponseJson msg = new ResponseJson();
        if(signclosedInfo == null){
            msg.setResultCode(500);
            msg.setReturnCode(500);
            return msg;
        }
        Integer num = complaintSignclosedInfoService.updateSignclosedById(signclosedInfo);
        if (num < 1) {
            msg.setResultCode(500);
            msg.setReturnCode(500);
        } else {
            msg.setResultCode(200);
            msg.setReturnCode(200);
        }
        return msg;
    }

    /**
     * 跳转到修改寄件人信息页面
     *
     * @return
     */
    @RequiresPermissions("signclosed:update:signclosed")
    @RequestMapping(value = "/to_update_sender")
    public ModelAndView toUpdateSender(HttpServletRequest request,Integer signclosedId) {
        ModelAndView mv = new ModelAndView("cm/signclosed/update_sender");
        ComplaintSignclosedInfo complaintSignclosedInfo = complaintSignclosedInfoService.getSignclosedById(signclosedId);
        mv.addObject("signclosedId",signclosedId);
        mv.addObject("complaintSignclosedInfo",complaintSignclosedInfo);
        return mv;
    }

    /**
     * 跳转到转入品质页面
     *
     * @return
     */
    @RequiresPermissions("signclosed:update:signclosed")
    @RequestMapping(value = "/to_into_complaint")
    public ModelAndView tointoComplaint(HttpServletRequest request,Integer signclosedId) {
        ModelAndView mv = new ModelAndView("cm/signclosed/init_complaint");
        ComplaintSignclosedInfo complaintSignclosedInfo = complaintSignclosedInfoService.getSignclosedById(signclosedId);
        List<SignclosedProductInfo> listProductInfo = complaintSignclosedInfoService.listSignclosedById(signclosedId);
        mv.addObject("signclosedId",signclosedId);
        mv.addObject("customerId",complaintSignclosedInfo.getSignclosedCustomerId());
        mv.addObject("listProductInfo",listProductInfo);
        return mv;
    }


    /**
     * 根据产品名称查询产品数据
     *
     * @return
     */
    @ResponseBody
    @RequiresPermissions("signclosed:select:signclosed")
    @RequestMapping(value = "/select_product")
    public ResponseJson selectProduct(HttpServletRequest request,String productName){
        ResponseJson msg = new ResponseJson();
        if(productName == null){
            msg.setResultCode(500);
            msg.setReturnCode(500);
            return msg;
        }
        //获取所有产品及其颜色，配件
        Product product = new Product();
        product.setProductName(productName);
        List<Product> productList = productService.listProductAndColorAndfittings(product);
        if (productList.size() == 0) {
            msg.setResultCode(500);
            msg.setReturnCode(500);
        } else {
            msg.setResultCode(200);
            msg.setReturnCode(200);
            msg.addResponseKeyValue("productList",productList);
        }
        return msg;
    }

    /**
     * 获取仓储信息
     *
     * @return
     */
    @ResponseBody
    @RequiresPermissions("signclosed:select:signclosed")
    @RequestMapping(value = "/select_signclosed_info")
    public ResponseJson selectProduct(HttpServletRequest request,Integer signclosedId){
        if(signclosedId == null){
            return new ResponseJson(500, "未获取到仓储信息!", 500);
        }
        ComplaintSignclosedInfo complaintSignclosedInfo = complaintSignclosedInfoService.getSignclosedById(signclosedId);
        return new ResponseJson(500, "未获取到仓储信息!", 500);
    }

    /**
     * 跳转到关联客诉页面
     *
     * @return
     */
    @RequiresPermissions("signclosed:update:signclosed")
    @RequestMapping(value = "/to_associated_customer")
    public ModelAndView toAssociatedCustomer(HttpServletRequest request,Integer signclosedId) {
        ModelAndView mv = new ModelAndView("cm/signclosed/associated_customer");
        ComplaintSignclosedInfo complaintSignclosedInfo = complaintSignclosedInfoService.getSignclosedById(signclosedId);
        mv.addObject("signclosedId",signclosedId);
        mv.addObject("complaintSignclosedInfo",complaintSignclosedInfo);
        return mv;
    }
    /**
     * 关联客诉
     *
     * @return
     */
    @ResponseBody
    @RequiresPermissions("signclosed:update:signclosed")
    @RequestMapping(value = "/associated_customer")
    public ResponseJson associatedCustomer(HttpServletRequest request,ComplaintSignclosedInfo signclosedInfo){
        ResponseJson msg = new ResponseJson();
        if(signclosedInfo == null){
            msg.setResultCode(500);
            msg.setReturnCode(500);
            return msg;
        }
        if(signclosedInfo.getSignclosedCustomerId() == null){
            msg.setResultCode(500);
            msg.setReturnCode(500);
            return msg;
        }

        int num = complaintSignclosedInfoService.addDetect(signclosedInfo);
        if (num < 1) {
            msg.setResultCode(500);
            msg.setReturnCode(500);
        } else {
            msg.setResultCode(200);
            msg.setReturnCode(200);
        }
        return msg;
    }
}