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

package com.iamberry.rst.controllers.cm;

import com.iamberry.rst.core.cm.*;
import com.iamberry.rst.core.order.ProductColor;
import com.iamberry.rst.faces.cm.ComplaintQuestionInfoService;
import com.iamberry.rst.faces.cm.CustomerCommonService;
import com.iamberry.rst.faces.cm.RelationOrderService;
import com.iamberry.rst.faces.cm.SalesOrderService;
import com.iamberry.rst.faces.order.EfastOrderService;
import com.iamberry.rst.faces.product.ProductService;
import com.iamberry.rst.service.cm.CustomerServiceImpl;
import com.iamberry.rst.service.cm.mapper.FittingsInfoMapper;
import com.iamberry.wechat.tools.DateTimeUtil;
import com.iamberry.wechat.tools.ResponseJson;
import net.sf.json.JSONArray;
import net.sf.json.JSONObject;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.servlet.ModelAndView;

import javax.servlet.http.HttpServletRequest;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

/**
 * Created by wxm
 * 问题
 */
@Controller
public class AppComplaintQuestionInfoController {
    private static Logger logger = LoggerFactory.getLogger(CustomerServiceImpl.class);
    private Object lock = new Object();

    /**
     *  邮寄地址id
     */
    private Integer backOutQuestionId = 5;

    @Autowired
    private ComplaintQuestionInfoService complaintQuestionInfoService;
    @Autowired
    private CustomerCommonService customerCommonService;
    @Autowired
    private RelationOrderService relationOrderService;
    @Autowired
    private SalesOrderService salesOrderService;
    @Autowired
    private EfastOrderService efastOrderService;
    @Autowired
    private ProductService productService;
    @Autowired
    private FittingsInfoMapper fittingsInfoMapper;


    /**
     * 进入客诉问题描述
     *
     * @param request
     * @return
     * @throws Exception
     */
    @RequestMapping("/QA/{id}/{type}")
    public ModelAndView problem( @PathVariable("id") Integer id,@PathVariable("type") Integer type, HttpServletRequest request) throws Exception {
        if(id == backOutQuestionId){
            ModelAndView mv = new ModelAndView("wap/cm/send_message");
            return mv;
        }else{
            ModelAndView mv = new ModelAndView("wap/cm/request_message");
            mv.addObject("questionId", id);
            mv.addObject("type", type);
            return mv;
        }
    }

    /**
     * 进入客诉问题描述
     *
     * @param request
     * @return
     * @throws Exception
     */
//    @RequestMapping("/address")
//    public ModelAndView adress(HttpServletRequest request) throws Exception {
//        ModelAndView mv = new ModelAndView("wap/cm/send_message");
//        return mv;
//    }

    /**
     * 查询退回短信客诉问题
     *
     * @return
     */
    @ResponseBody
    @RequestMapping(value = "/get_back_out_question")
    public ResponseJson getBackOutQuestion(HttpServletRequest request){
        ResponseJson msg = new ResponseJson();
        ComplaintQuestionInfo complaintQuestionInfo = complaintQuestionInfoService.getQuestionById(backOutQuestionId);
        if (complaintQuestionInfo  == null) {
            msg.setResultCode(500);
            msg.setReturnCode(500);
        } else {
            msg.setResultCode(200);
            msg.setReturnCode(200);
            msg.addResponseKeyValue("complaintQuestionInfo",complaintQuestionInfo);
        }
        return msg;
    }

    /**
     * 查询客诉问题
     *
     * @return
     */
    @ResponseBody
    @RequestMapping(value = "/get_question")
    public ResponseJson getQuestion(HttpServletRequest request, Integer questionId){
        ResponseJson msg = new ResponseJson();
        if(questionId == null){
            msg.setResultCode(500);
            msg.setReturnCode(500);
            return msg;
        }
        ComplaintQuestionInfo complaintQuestionInfo = complaintQuestionInfoService.getQuestionById(questionId);
        if (complaintQuestionInfo  == null) {
            msg.setResultCode(500);
            msg.setReturnCode(500);
        } else {
            msg.setResultCode(200);
            msg.setReturnCode(200);
            msg.addResponseKeyValue("complaintQuestionInfo",complaintQuestionInfo);
        }
        return msg;
    }

    /**
     * 修改是否已解决总数
     *
     * @return
     */
    @ResponseBody
    @RequestMapping(value = "/update_question_num")
    public ResponseJson updateQuestionNum(HttpServletRequest request, ComplaintQuestionInfo complaintQuestionInfo){
        ResponseJson msg = new ResponseJson();
        if(complaintQuestionInfo == null){
            msg.setResultCode(500);
            msg.setReturnCode(500);
            return msg;
        }
        Integer num = complaintQuestionInfoService.updateQuestionById(complaintQuestionInfo);
        if (num < 1) {
            msg.setResultCode(500);
            msg.setReturnCode(500);
        } else {
            msg.setResultCode(200);
            msg.setReturnCode(200);
        }
        return msg;
    }


    /**
     * 处理一个客诉对应多个订单
     * @return
     */
//    @ResponseBody
//    @RequestMapping(value = "")
//    public ResponseJson processCustomerOrder(HttpServletRequest request){
//        ResponseJson msg = new ResponseJson();
//        List<RelationOrder>  relationOrderList = new ArrayList<>();
//        CustomerCommon customerCommon  = new CustomerCommon();
//        List<CustomerCommon> customerCommonList = customerCommonService.listCustomerCommon(customerCommon);
//        for (int i=0; i<customerCommonList.size(); i++){
//            RelationOrder relationOrder = new RelationOrder();
//            relationOrder.setRelationId(customerCommonList.get(i).getRelationId());
//            relationOrder.setRelationType(customerCommonList.get(i).getCustomerIsSolve());
//            relationOrder.setSalesId(customerCommonList.get(i).getOrderId());
//            relationOrderList.add(relationOrder);
//        }
//        relationOrderService.saveList(relationOrderList);
//        return msg;
//    }

    /**
     * 清理所有没有订单项的订单
     * 并重新拉去订单
     * @param request
     * @return
     */
//    @ResponseBody
//    @RequestMapping(value = "/delOrder")
//    public ResponseJson processCustomerOrder(HttpServletRequest request){
//        ResponseJson msg = new ResponseJson();
//        List<String> orderId = new ArrayList<>();
//        StringBuffer delOrderId = new StringBuffer();
//        List<SalesOrder> salesOrderList = salesOrderService.listSalesOrder(new SalesOrder());
//        for (int i=0;i<salesOrderList.size();i++){
//            SalesOrder so = salesOrderList.get(i);
//            SalesOrderItem soi = new SalesOrderItem();
//            soi.setItemOrderId(so.getSalesId());
//            List<SalesOrderItem> salesOrderItemList = salesOrderService.listSalesOrderItem(soi);
//            if(salesOrderItemList == null || salesOrderItemList.size() < 1){
//                if(so.getSalesOrderId() != null && !"".equals(so.getSalesOrderId()) ){
//                    orderId.add(so.getSalesOrderId());
//                    delOrderId.append(so.getSalesOrderId());
//                    salesOrderService.delOrder(so.getSalesOrderId());
//                    System.out.println("------------------------订单无订单项-订单id为："+ so.getSalesOrderId() +"-----------------------");
//                }else{
//                    System.out.println("----订单号为空--");
//                }
//            }
//        }
//        if(orderId != null && orderId.size()>0 ){
//            System.out.println("未检测到没有产品的订单了");
//        }
//        System.out.println("------------------------总共有 " + orderId.size() + "订单无订单项，------------------------");
//        StringBuffer delOrderIdError = new StringBuffer();
//        for(Integer k=0; k<orderId.size() ; k++){
//            String id = orderId.get(k);
//            System.out.println("--------同步第 "+k+" 个订单，订单编号："+id+"----------");
//            try{
//                //获取订单详情
//                JSONObject orderInfo = efastOrderService.getOrderFormEfastByOrderId(id);
//                //添加订单和订单项
//                boolean flag = true;
//                try {
//                    flag = salesOrderService.syncEfastOrder(orderInfo);
//                }catch (Exception e){
//                    return new ResponseJson(500, e.getMessage(), 500);
//                }
//                if (flag) {
//                    return new ResponseJson(200, "同步成功!", 200);
//                } else {
//                    return new ResponseJson(500, "同步订单错误！", 500);
//                }
//            }catch (Exception e){
//                e.printStackTrace();
//                System.out.println("--------订单同步出错，订单号为：" + id);
//                delOrderIdError.append(id+",");
//            }
//        }
//        System.out.println("-----------------同步失败的id"+delOrderIdError.toString());
//        return msg;
//    }

/**
 * 清理所有没有订单项的订单
 * 并重新拉去订单
 * @param request
 * @return
 */
//    @ResponseBody
//    @RequestMapping(value = "/synOrder")
//    public ResponseJson synCustomerOrder(HttpServletRequest request){
//        ResponseJson msg = new ResponseJson();
//            List<SalesOrder> salesOrderList = salesOrderService.listSalesOrder(new SalesOrder());
//            for (int i=0;i<salesOrderList.size();i++){
//                SalesOrder so = salesOrderList.get(i);
//                SalesOrderItem soi = new SalesOrderItem();
//                soi.setItemOrderId(so.getSalesId());
//            List<SalesOrderItem> salesOrderItemList = salesOrderService.listSalesOrderItem(soi);
//            if(salesOrderItemList != null && salesOrderItemList.size() > 1){
//               if(so.getSalesDealCode() != null && !"".equals(so.getSalesDealCode()) ){
//                   //获取订单详情
//                   JSONObject orderInfo = null;
//                   try{
//                       orderInfo = efastOrderService.getOrderFormEfast(so.getSalesDealCode());
//                   }catch (Exception e){
//                       logger.info("获取订单失败；异常编号：505;失败原因："+ e.getMessage() +"--获取失败交易号：" + so.getSalesDealCode()+"订单id"+so.getSalesId());
//                   }
//                   if (orderInfo == null) {
//                       logger.info("1获取订单失败；异常编号：--获取失败交易号：" + so.getSalesDealCode()+"订单id"+so.getSalesId());
//                       continue;
//                   }
//                   if (!orderInfo.has("orders")) {
//                       logger.info("2获取订单失败；异常编号：--获取失败交易号：" + so.getSalesDealCode()+"订单id"+so.getSalesId());
//                       continue;
//                   }
//                   //获取订单项集合
//                   JSONArray itemArray = null;
//                   try{
//                       itemArray = orderInfo.getJSONArray("orders");
//                   }catch (Exception e){
//                       e.printStackTrace();
//                       logger.info("1解析订单项失败"+so.getSalesId());
//                   }
//                   if (itemArray == null || itemArray.size() == 0) {
//                       logger.info("2解析订单项失败"+so.getSalesId());
//                       continue;
//                   }
//                   for (int j = 0;j < itemArray.size();j++) {
//                       JSONObject itemJson = itemArray.getJSONObject(j);
//                       SalesOrderItem item = new SalesOrderItem();
//                       item.setItemColorBar(itemJson.getString("goods_sn"));//商品69码
//                       item.setItemNum(itemJson.getInt("goods_number"));//商品数量
//                       item.setItemOrderId(so.getSalesId());
//                       salesOrderService.updateOrderItem(item);
//                   }
//                }else{
//                   logger.info("----交易号为空--订单id为"+so.getSalesId());
//                }
//            }
//        }
//
//        return msg;
//    }

    /**
     * 订单关联表，新增客诉id
     * @param request
     * @return
     */
//    @ResponseBody
//    @RequestMapping(value = "/synRelatedOrder")
//    public ResponseJson synRelatedOrder(HttpServletRequest request){
//        ResponseJson msg = new ResponseJson();
//        List<RelationOrder>  relationOrderList = relationOrderService.getRelationOrderList(new RelationOrder());
//        for (int i=0;i<relationOrderList.size();i++) {
//            RelationOrder ro = relationOrderList.get(i);
//            CustomerCommon customerCommon = new CustomerCommon();
//            customerCommon.setRelationId(ro.getRelationId());
//            customerCommon.setCustomerIsSolve(ro.getRelationType());  //customerIsSolve
//            List<CustomerCommon> customerCommonList = customerCommonService.listCustomerCommon(customerCommon);
//
//            RelationOrder newRo = new RelationOrder();
//            newRo.setRelationOrderId(ro.getRelationOrderId());
//            newRo.setRelationCustomerId(customerCommonList.get(0).getCustomerId());
//            relationOrderService.update(newRo);
//        }
//        logger.info("----交易号为空--订单id为"+1);
//        return msg;
//    }



}