iamberry-common-tooth/tooth-wechat-web/src/main/java/com/iamberry/wechat/handles/channel/ChannelAdminHandler.java

package com.iamberry.wechat.handles.channel;

import com.iamberry.wechat.core.entity.ResultMsg;
import com.iamberry.wechat.core.entity.WechatUtils;
import com.iamberry.wechat.core.entity.channel.ChannelAdmin;
import com.iamberry.wechat.core.entity.channel.ChannelPrice;
import com.iamberry.wechat.core.entity.channel.ChildChannel;
import com.iamberry.wechat.core.entity.member.Member;
import com.iamberry.wechat.core.entity.order.Order;
import com.iamberry.wechat.core.entity.order.OrderItem;
import com.iamberry.wechat.core.entity.page.PageRequest;
import com.iamberry.wechat.core.entity.page.PagedResult;
import com.iamberry.wechat.core.entity.product.Product;
import com.iamberry.wechat.core.entity.receive.ChargerReceive;
import com.iamberry.wechat.face.channel.ChannelAdminService;
import com.iamberry.wechat.face.channel.ChannelPriceService;
import com.iamberry.wechat.face.channel.MainChannelService;
import com.iamberry.wechat.face.member.MemberService;
import com.iamberry.wechat.face.order.AdminOrderService;
import com.iamberry.wechat.face.porduct.ProductService;
import com.iamberry.wechat.tools.ResultInfo;
import com.iamberry.wechat.utils.StitchAttrUtil;
import com.sun.org.apache.xpath.internal.operations.Bool;
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.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;

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

@Controller
@RequestMapping("/wechat/channelAdmin")
public class ChannelAdminHandler {

    private Logger logger = LoggerFactory.getLogger(ChannelAdminHandler.class);

    @Autowired
    private MemberService memberService;

    @Autowired
    private ChannelAdminService channelAdminService;

    @Autowired
    private MainChannelService mainChannelService;

    @Autowired
    private AdminOrderService adminOrderService;

    @Autowired
    private ChannelPriceService channelPriceService;

    @Autowired
    private ProductService productService;

    /**
     * 获取当前渠道管理员下面的代理产品-以产品展示
     * @param request
     * @return
     * @throws Exception
     */
    @ResponseBody
    @RequestMapping(value = "/getProductList")
    public ResultMsg getProductList(HttpServletRequest request,
                                    @RequestParam(value= "channelType",defaultValue= "0" ,required=false) Integer channelType,
                                    @RequestParam(value= "channelId",defaultValue= "0" ,required=false) Integer channelId
    ) throws Exception {
        ResultMsg msg = ResultMsg.getError();

        if(channelType == 0 || channelId == 0){
            msg.setMessage("网络错误，请重试！");
            return msg;
        }

        ChannelPrice channelPrice = new ChannelPrice();
        channelPrice.setChannelType(channelType);
        channelPrice.setChannelId(channelId);
        channelPrice.setChannelPriceStatus(1);
        List<ChannelPrice> channelPriceList = channelPriceService.getChannelProductList(channelPrice);

        List<Product> productList = new ArrayList<>();
        for (ChannelPrice cp : channelPriceList){
            Product product = productService.selectProductByProductId(cp.getProductId());
            product.setColorId(cp.getColorId());
            product.setProductDiscount(cp.getChannelPriceOffer());
            product.setProductPrice(cp.getChannelOriginalPrice());
            productList.add(product);
        }

        msg = ResultMsg.getSuccess();
        msg.setData(productList);
        return msg;
    }


    /**
     *  获取提货列表
     *  主渠道下面所有的提货
     *  主渠道下面所有子渠道的
     * @param request
     * @return
     * @throws Exception
     */
    @ResponseBody
    @RequestMapping(value = "/getChannelList")
    public ResultMsg getChannelList(HttpServletRequest request,Order order,
       @RequestParam(value= "pageSize",defaultValue= "10" ,required=false) Integer pageSize,
       @RequestParam(value = "pageNO", defaultValue = "1",required=false) Integer pageNO,
       @RequestParam(value = "totalNum", defaultValue = "0", required = false) Integer totalNum
    ) throws Exception {
        ResultMsg msg = ResultMsg.getError();

        Integer status = order.getSalesStatus();

        // 用户信息
        String openId  = WechatUtils.getUserBySession(request).getUserOpenid();

        ChannelAdmin channelAdmin = new ChannelAdmin();
        channelAdmin.setChannelAdminOpenId(openId);
        channelAdmin.setChannelAdminStatus(1);
        channelAdmin.setChannelType(1); //主渠道
        List<ChannelAdmin> channelAdminList = channelAdminService.getChannelAdminList(channelAdmin);

        if(channelAdminList == null || channelAdminList.size() < 1){
            logger.info("====="+openId+"不是主渠道的管理员！");
            msg.setMessage("您还不是主渠道的管理员，请联系上朵！");
            return msg;
        }

        List<Integer> ids = new ArrayList<>();
        for (int i=0;i<channelAdminList.size();i++){
            ids.add(channelAdminList.get(i).getChannelId());
        }
        order.setChannelIds(ids);

        if(order.getSalesStatus() == 99){
            order.setSalesStatus(null);
            order.setSalesTransportationType(null);
        }else{
            order.setSalesTransportationType(2);
        }

        // 封装请求数据
        PageRequest<Order> pageRequest = new PageRequest<>(order, pageNO, pageSize, totalNum == 0);
        // 查询订单列表
        PagedResult<Order> result = channelAdminService.listOrderPage(pageRequest);
        Boolean lastPage = StitchAttrUtil.getSa().getLastPage(result);

        List<Order> orderList = result.getDataList();
        for (Order or :orderList) {
            if(status == 99 && or.getSalesTransportationType() == 1){
                String name = or.getSalesAddressName();
                name = name.substring(0,1) + "**";
                String tel = or.getSalesAddressTel();
                tel = tel.substring(0,3) + "****" + tel.substring(7,11) ;
                or.setSalesAddressName(name);
                or.setSalesAddressTel(tel);
            }
            List<OrderItem>orderItemList = adminOrderService.getShopOrderItemByOrderId(or.getSalesOrderid());
            or.setOrderItemList(orderItemList);
        }

        Order or = new Order();
        or.setChannelIds(ids);
        or.setSalesTransportationType(2);
        or.setSalesStatus(2);
        Integer dfStatus = channelAdminService.listOrderCount(or);
        or.setSalesStatus(5);
        Integer yfStatus = channelAdminService.listOrderCount(or);
        or.setSalesStatus(null);
        or.setSalesTransportationType(null);
        Integer allStatus = channelAdminService.listOrderCount(or);

        Map<String,Object> map = new HashMap<>();
        map.put("orderList",orderList);
        map.put("lastPage",lastPage);
        map.put("dfStatus",dfStatus);
        map.put("yfStatus",yfStatus);
        map.put("allStatus",allStatus);

        msg = ResultMsg.getSuccess();
        msg.setData(map);
        return msg;
    }

    /**
     *  修改订单状态为已提货
     *  订单状态：  已付款 --> 已发货
     * @param request
     * @return
     * @throws Exception
     */
    @ResponseBody
    @RequestMapping(value = "/updateStatus")
    public ResultMsg updateStatus(HttpServletRequest request,String salesOrderid) throws Exception {
        ResultMsg msg = ResultMsg.getError();

        if(salesOrderid == null || "".equals(salesOrderid)){
            msg.setMessage("订单号不能为空");
            return msg;
        }
        Order order = adminOrderService.getShopOrderByOrderId(salesOrderid);
        if(order.getSalesStatus() != 2){
            msg.setMessage("该订单无法修改为已提货");
            return msg;
        }

        order = new Order();
        order.setSalesOrderid(salesOrderid);
        order.setSalesStatus(5);
        order.setOldStatus(2);
        boolean flag = adminOrderService.updateOrderStatusByOrderId(order);

        if(flag){
            msg = ResultMsg.getSuccess();
            return msg;
        }else{
            msg.setMessage("修改订单状态失败！");
            return msg;
        }
    }


}