ps-inquiry/src/main/java/com/uas/ps/inquiry/controller/PublicInquiryController.java

package com.uas.ps.inquiry.controller;

import com.alibaba.fastjson.JSONObject;
import com.uas.ps.httplog.annotation.HttpLog;
import com.uas.ps.inquiry.domain.IPage;
import com.uas.ps.inquiry.entity.Constant;
import com.uas.ps.inquiry.entity.InquiryMessage;
import com.uas.ps.inquiry.entity.InquirySource;
import com.uas.ps.inquiry.entity.OrderStatus;
import com.uas.ps.inquiry.model.Attach;
import com.uas.ps.inquiry.model.PublicInquiryItemInfo;
import com.uas.ps.inquiry.model.PurcInquiry;
import com.uas.ps.inquiry.model.PurcInquiryItemInfo;
import com.uas.ps.inquiry.page.PageInfo;
import com.uas.ps.inquiry.page.SearchFilter;
import com.uas.ps.inquiry.page.criteria.PredicateUtils;
import com.uas.ps.inquiry.service.AttachService;
import com.uas.ps.inquiry.service.InquiryForSaleService;
import com.uas.ps.inquiry.service.PublicInquiryService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.Sort;
import org.springframework.ui.ModelMap;
import org.springframework.util.StringUtils;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;

import java.rmi.AccessException;
import java.util.List;
import java.util.Map;


/**
 * 公共询价接口路径
 * <p>
 * Created by hejq on 2018-01-13.
 */
@RestController
@RequestMapping("/inquiry/public")
public class PublicInquiryController {

    @Autowired
    private PublicInquiryService publicInquiryService;

    @Autowired
    private AttachService attachService;

    @Autowired
    private InquiryForSaleService saleService;

    private final static Logger log = LoggerFactory.getLogger(PublicInquiryController.class);


    /**
     * 通过分页参数和过滤条件查询公共询价列表信息
     *                                B2B\B2C\IM
     * @param pageInfo     分页参数
     * @param searchFilter 过滤条件
     * @return
     * @author hejq
     * @date 2018-01-17 10:27
     */
    @HttpLog
    @RequestMapping(method = RequestMethod.GET)
    public IPage<PurcInquiryItemInfo> getInquiry(PageInfo pageInfo, SearchFilter searchFilter, String distributes) {
        long start = System.currentTimeMillis();
        if (!StringUtils.isEmpty(distributes)) {
            List<Long> distribute = JSONObject.parseArray(distributes, Long.class);
            searchFilter.setDistribute(distribute);
        }
        // 询价单主列表接口，默认限制询价单为有效状态
        if (null != searchFilter.getValid()) {
            pageInfo.expression(PredicateUtils.eq("valid", searchFilter.getValid(), false));
        } else {
            pageInfo.expression(PredicateUtils.eq("valid", Constant.YES, false));
        }
        IPage<PurcInquiryItemInfo> page = publicInquiryService.findTodoByPageInfo(pageInfo, searchFilter);
        log.info("公共询价, 查询公共询价信息, UserUU: {}, EnUU: {}, 报价的应用来源: {}",  searchFilter.getUserUU(), searchFilter.getEnUU(), InquirySource.PLAIN.name());
        log.info("/inquiry/public 耗时:{}", (System.currentTimeMillis() - start));
        return page;
    }

    /**
     * 针对商城，查询已发布的公共询价信息
     *                        暂无
     * @param pageInfo     分页信息
     * @param searchFilter 过滤条件
     * @return
     */
    @HttpLog
    @RequestMapping(value = "/inquiryList", method = RequestMethod.GET)
    public IPage<PurcInquiryItemInfo> getInquiryList(PageInfo pageInfo, SearchFilter searchFilter) {
        long start = System.currentTimeMillis();
        if (null != searchFilter.getUserUU()) {
            pageInfo.filter("userUU", searchFilter.getUserUU());
        }
        if (null != searchFilter.getEnUU()) {
            pageInfo.filter("inquiry.enUU", searchFilter.getEnUU());
        }
        IPage<PurcInquiryItemInfo> infoIPage = publicInquiryService.findTodoByPageInfo(pageInfo, searchFilter);
        log.info("公共询价, 查询公共询价信息, UserUU: {}, EnUU: {}, 报价的应用来源: {}",  searchFilter.getUserUU(), searchFilter.getEnUU(), InquirySource.MALL.name());
        log.info("/inquiry/public/inquiryList 耗时:{}", (System.currentTimeMillis() - start));
        return infoIPage;
    }


    /**
     * 通过分页信息和过滤条件查询已转报价的信息
     *                          B2B\B2C
     * @param pageInfo 分页参数
     * @param filter   过滤条件
     * @return
     * @author hejq
     * @date 2018-01-18 15:36
     */
    @HttpLog
    @RequestMapping(value = "/quotation/list", method = RequestMethod.GET)
    public IPage<PublicInquiryItemInfo> getQuotation(PageInfo pageInfo, String filter, String _state, Short overdue) {
        long start = System.currentTimeMillis();
        SearchFilter searchFilter = JSONObject.parseObject(filter, SearchFilter.class);
        if (null != searchFilter) {
            if (null != searchFilter.getVendUU()) {
                pageInfo.filter("vendUU", searchFilter.getVendUU());
            } else if (null != searchFilter.getEnUU()) {
                pageInfo.filter("inquiry.enUU", searchFilter.getEnUU());
                // 已报价未传vendUU时，抛出异常
            }
        } else if (null != _state && _state.equals(OrderStatus.done.name())) {
            throw new IllegalAccessError("请先传入企业信息");
        }
        if (null != _state) {
            pageInfo = publicInquiryService.covert(pageInfo, _state, overdue);
        }
        log.info("公共询价, 查询已转报价询价列表信息, 状态:{}, UserUU: {}, EnUU: {}, 报价的应用来源: {}",  (_state == null ? "all" : _state), searchFilter != null ? searchFilter.getUserUU() : null, searchFilter != null ? searchFilter.getEnUU() : null, InquirySource.PLAIN.name());
        IPage<PublicInquiryItemInfo> inquiryItemInfoIPage = publicInquiryService.findByPageInfo(pageInfo, searchFilter);
        log.info("/inquiry/public/quotation/list 耗时:{}", (System.currentTimeMillis() - start));
        return inquiryItemInfoIPage;
    }

    /**
     * 通过id查询单个已转报价的信息
     *                      B2C
     * @param id
     * @return
     */
    @HttpLog
    @RequestMapping(value = "/quotation/one", method = RequestMethod.GET)
    public PublicInquiryItemInfo getQuotationById(Long id, Long enuu, Long useruu) throws AccessException {
        long start = System.currentTimeMillis();
        if (StringUtils.isEmpty(enuu) || StringUtils.isEmpty(useruu)) {
            throw new IllegalAccessError("暂无访问权限");
        }
        PublicInquiryItemInfo info = publicInquiryService.findOneInfo(id, enuu, useruu);
        log.info("/inquiry/public/quotation/one 耗时:{}", (System.currentTimeMillis() - start));
        return info;
    }

    /**
     * 商城获取采纳列表
     *                  B2C
     * @param pageInfo
     * @param filter
     * @param _state
     * @return
     */
    @HttpLog
    @RequestMapping(value = "/quotationList", method = RequestMethod.GET)
    public Page<PublicInquiryItemInfo> getQuotationList(PageInfo pageInfo, String filter, String _state, Short overdue) {
        long start = System.currentTimeMillis();
        SearchFilter searchFilter = JSONObject.parseObject(filter, SearchFilter.class);
        if (null != _state) {
            pageInfo = publicInquiryService.covert(pageInfo, _state, overdue);
        }
        Page<PublicInquiryItemInfo> itemInfoPage = publicInquiryService.findListByPageInfo(pageInfo, searchFilter);
        log.info("/inquiry/public/quotationList 耗时:{}", (System.currentTimeMillis() - start));
        return itemInfoPage;
    }

    /**
     * 获取最新的公共询价列表
     *                      B2B
     * @param enuu 当前企业UU号
     * @param size 大小
     * @return
     */
    @HttpLog
    @RequestMapping(value = "/messageList", method = RequestMethod.GET)
    public List<InquiryMessage> getList(Long enuu, Integer size) {
        long start = System.currentTimeMillis();
        log.info("公共询价, 获取最新的公共询价, size:{}, Constant: {}, EnUU: {}, 报价的应用来源: {}", size, Constant.UU, enuu, InquirySource.PLAIN.name());
        List<InquiryMessage> messages = publicInquiryService.getMessageList(enuu, size);
        log.info("/inquiry/public/messageList 耗时:{}", (System.currentTimeMillis() - start));
        return messages;
    }

    /**
     * 将客户的公共询价列表中一条数据转成询价报价单数据
     *                                  暂无
     * @param id     公共询价明细id
     * @param enuu   报价企业UU
     * @param useruu 报价个人UU
     * @return
     * @author hejq
     * @date 2018-01-14 15:20
     */
    @HttpLog
    @RequestMapping(value = "/turntoInquiry", method = RequestMethod.POST)
    private ModelMap transtoInquiry(Long id, Long enuu, Long useruu) {
        long start = System.currentTimeMillis();
        ModelMap map = publicInquiryService.transtoInquiry(id, enuu, useruu);
        log.info("/inquiry/public/turntoInquiry post 耗时:{}", (System.currentTimeMillis() - start));
        return map;
    }

    /**
     * 获取附件信息
     *              B2B
     * @param id 附件id
     * @return
     */
    @HttpLog
    @RequestMapping(value = "/attachUrl", method = RequestMethod.GET)
    public com.uas.ps.inquiry.model.Attach getAttach(Long id) {
        long start = System.currentTimeMillis();
        Attach attach = attachService.findById(id);
        log.info("/inquiry/public/atatchUrl 耗时:{}", (System.currentTimeMillis() - start));
        return attach;
    }

    /**
     * 通过询价主表id查询主表信息
     *                      B2C
     * @param id 主表id
     * @return
     */
    @HttpLog
    @RequestMapping(value = "/findInquiryById", method = RequestMethod.GET)
    public PurcInquiry findById(Long id, Long enuu) {
        long start = System.currentTimeMillis();
        log.info("公共询价, 获取询价信息, id:{}, Constant: {}, EnUU: {}, 报价的应用来源: {}", id, Constant.UU, enuu, InquirySource.PLAIN.name());
        PurcInquiry inquiry = publicInquiryService.findInquiryById(id);
        inquiry = publicInquiryService.getQuotedDetail(inquiry);
        log.info("/inquiry/public/findInquiryById 耗时:{}", (System.currentTimeMillis() - start));
        return inquiry;
    }

    /**
     * 商城-采购排行榜
     *                  B2C
     * @return
     */
    @HttpLog
    @RequestMapping(value = "/findCodeRankingList", method = RequestMethod.GET)
    public List<Map<String, Object>> findCodeRankingList() {
        long start = System.currentTimeMillis();
        List<Map<String, Object>> list = publicInquiryService.findCodeRankingList();
        log.info("/inquiry/public/findCodeRankingList 耗时:{}", (System.currentTimeMillis() - start));
        return list;
    }

    /**
     * 通过明细id查询该条询价的详情
     *                      B2B\B2C
     * @param itemId 明细id
     * @param enuu   enuu
     * @return
     */
    @HttpLog
    @RequestMapping(value = "/findItemByItemId", method = RequestMethod.GET)
    public PurcInquiryItemInfo findItemByItemId(Long itemId, Long enuu) {
        long start = System.currentTimeMillis();
        PurcInquiryItemInfo itemInfo = publicInquiryService.findItemByItemId(itemId, enuu);
        log.info("公共询价, 获取询价信息, id:{}, Constant: {}, EnUU: {}, 报价的应用来源: {}", itemId, Constant.UU, enuu, InquirySource.B2B.name());
        log.info("/inquiry/public/findItemByItemId 耗时:{}", (System.currentTimeMillis() - start));
        return itemInfo;
    }

    /**
     * 公共询价单明细总数
     *                zanwu
     * @return
     */
    @RequestMapping(value = "/getPurcInquiryItemCount", method = RequestMethod.GET)
    public ModelMap getPurcInquiryItemCount() {
        long start = System.currentTimeMillis();
        ModelMap map = publicInquiryService.getPurcInquiryItemCount();
        log.info("/inquiry/public/getPurcInquiryItemCount 耗时:{}", (System.currentTimeMillis() - start));
        return map;
    }

    /**
     * 公共询价单明细某年某月总数
     *                  B2C
     * @param month 月份
     * @return
     */
    @RequestMapping(value = "/getPurcInquiryItemCountByMonth", method = RequestMethod.GET)
    public ModelMap getPurcInquiryItemCountByMonth(Integer year, Integer month) {
        long start = System.currentTimeMillis();
        ModelMap map = publicInquiryService.countByMonth(year, month);
        log.info("/inquiry/public/getPurcInquiryItemCountByMonth 耗时:{}", (System.currentTimeMillis() - start));
        return map;
    }

    /**
     * 公共询价单明细本月数量和上月数量
     *                  B2C
     * @return
     */
    @RequestMapping(value = "/getCountOfLastAndThisMonth", method = RequestMethod.GET)
    public ModelMap getPurcInquiryItemCountByMonth() {
        long start = System.currentTimeMillis();
        ModelMap map = publicInquiryService.getCountOfLastAndThisMonth();
        log.info("/inquiry/public/getCountOfLastAndThisMonth 耗时:{}", (System.currentTimeMillis() - start));
        return map;
    }

    /**
     * 公共询价单明细设置禁用或反禁用
     *                  B2C-admin
     * @param id 询价明细id
     * @param valid 是否生效状态 1为是，0为否
     * @return
     */
    @RequestMapping(value = "/deleteItem", method = RequestMethod.POST)
    public ModelMap deleteItems(Long id, Integer valid) {
        long start = System.currentTimeMillis();
        if (null == valid) {
            valid = 0;
        }
        ModelMap map = publicInquiryService.deleteItems(id, valid);
        log.info("/inquiry/public/deleteItems 耗时:{}", (System.currentTimeMillis() - start));
        return map;
    }

    /* ===========================================app接口start============================================================ */

    /**
     * 移动端查询公共询价列表信息
     *
     * @param page     页码
     * @param size     每页大小
     * @param en_uu    企业UU
     * @param _state   过滤状态
     * @param keyword  搜索词
     * @param user_tel 电话
     * @param fromDate 开始日期
     * @param endDate  截止日期
     * @return
     */
    @Deprecated
    @HttpLog
    @RequestMapping(value = "/mobile", method = RequestMethod.GET)
    public ModelMap publincInquiry(Integer page, Integer size, Long en_uu, String _state,
                                   String keyword, String user_tel, Long fromDate, Long endDate) {
        long start = System.currentTimeMillis();
        ModelMap map = new ModelMap();
        PageInfo pageInfo = setPageInfo(page, size);
        SearchFilter filter = new SearchFilter();
        filter.setFromDate(fromDate);
        filter.setEndDate(endDate);
        filter.setKeyword(keyword);
        if (StringUtils.hasText(_state)) {
            if (_state.equals(OrderStatus.end.name())) {
                log.info("公共询价, 查询公共询价信息, tel:{}, Constant: {}, EnUU: {}, 报价的应用来源: {}", user_tel, Constant.UU, en_uu, InquirySource.UU.name());
                pageInfo.filter("overdue", Constant.YES);
                map.put("content", publicInquiryService.findTodoByPageInfo(pageInfo, filter).getContent());
                return map;
            } else if (_state.equals(OrderStatus.invalid.name())) {
                log.info("公共询价, 查询公共询价信息, tel:{}, Constant: {}, EnUU: {}, 报价的应用来源: {}", user_tel, Constant.UU, en_uu, InquirySource.UU.name());
                pageInfo.filter("invalid", Constant.YES);
                map.put("content", publicInquiryService.findTodoByPageInfo(pageInfo, filter).getContent());
                return map;
            } else if (_state.equals(OrderStatus.done.name())) {
                log.info("公共询价, 查询已转报价询价列表信息, tel:{}, Constant: {}, EnUU: {}, 报价的应用来源: {}", user_tel, Constant.UU, en_uu, InquirySource.UU.name());
                pageInfo.filter("vendUU", en_uu);
                filter.setKeyword(keyword);
                map.put("content", publicInquiryService.findByPageInfo(pageInfo, filter).getContent());
                return map;
            }
        } else {
            filter.setEnUU(en_uu);
            log.info("公共询价, 查询公共询价信息, tel:{}, Constant: {}, EnUU: {}, 报价的应用来源: {}", user_tel, Constant.UU, en_uu, InquirySource.UU.name());
            map.put("content", publicInquiryService.findTodoByPageInfo(pageInfo, filter).getContent());
            return map;
        }
        log.info("/inquiry/mobile 耗时:{}", (System.currentTimeMillis() - start));
        return map;
    }

    /**
     * 设置分页信息
     * @param page  页码
     * @param size  条数
     * @return
     */
    private PageInfo setPageInfo(Integer page, Integer size) {
        PageInfo pageInfo = new PageInfo();
        if (page == null || page == 0) {
            pageInfo.setPageNumber(1);
        } else {
            pageInfo.setPageNumber(page);
        }
        if (size == null || size == 0) {
            pageInfo.setPageSize(5);
        } else {
            pageInfo.setPageSize(size);
        }
        pageInfo.setOffset(pageInfo.getPageSize() * (pageInfo.getPageNumber() - 1));
        Sort sort = new Sort(Sort.Direction.DESC, "date");
        pageInfo.setSort(sort);
        return pageInfo;
    }

    /**
     * 移动端查询公共询价列表信息
     *                     2018年7月10日 16:24:35 此接口实际是将获取全部、获取已报价、获取未报价接口整合到一起，供UU互联只调用一个接口，
     *                     可以修改为去调用对应的列表方法，这样，UU只用调用一个接口，公共服务也不用重复维护。
     * @param page     页码
     * @param size     每页大小
     * @param en_uu    企业UU
     * @param _state   过滤状态
     * @param keyword  搜索词
     * @param user_tel 电话
     * @param fromDate 开始日期
     * @param endDate  截止日期
     * @return
     */
    @Deprecated
    @HttpLog
    @RequestMapping(value = "/mobile/v2", method = RequestMethod.GET)
    public ModelMap publicInquiry(Integer page, Integer size, Long en_uu, String _state,
                                  String keyword, String user_tel, Long fromDate, Long endDate) {
        long start = System.currentTimeMillis();
        ModelMap map = new ModelMap();
        PageInfo pageInfo = setPageInfo(page, size);
        SearchFilter filter = new SearchFilter();
        filter.setFromDate(fromDate);
        filter.setEndDate(endDate);
        filter.setKeyword(keyword);
        if (StringUtils.hasText(_state)) {
            if (_state.equals(OrderStatus.end.name())) {
                log.info("公共询价, 查询公共询价信息, tel:{}, Constant: {}, EnUU: {}, 报价的应用来源: {}", user_tel, Constant.UU, en_uu, InquirySource.UU.name());
                pageInfo.filter("overdue", Constant.YES);
                map.put("content", publicInquiryService.findTodoByPageInfo(pageInfo, filter).getContent());
                return map;
            } else if (_state.equals(OrderStatus.invalid.name())) {
                log.info("公共询价, 查询公共询价信息, tel:{}, Constant: {}, EnUU: {}, 报价的应用来源: {}", user_tel, Constant.UU, en_uu, InquirySource.UU.name());
                pageInfo.filter("invalid", Constant.YES);
                map.put("content", publicInquiryService.findTodoByPageInfo(pageInfo, filter).getContent());
                return map;
            } else if (_state.equals(OrderStatus.done.name())) {
                log.info("公共询价, 查询已转报价询价列表信息, tel:{}, Constant: {}, EnUU: {}, 报价的应用来源: {}", user_tel, Constant.UU, en_uu, InquirySource.UU.name());
                pageInfo.filter("vendUU", en_uu);
                filter.setKeyword(keyword);
                map.put("content", publicInquiryService.findByPageInfo(pageInfo, filter).getContent());
                return map;
            }
        } else {
            log.info("公共询价, 查询公共询价信息, tel:{}, Constant: {}, EnUU: {}, 报价的应用来源: {}", user_tel, Constant.UU, en_uu, InquirySource.UU.name());
            pageInfo.filter("vendUU", en_uu);
            map.put("content", publicInquiryService.covertRemindToInquiry(saleService.findRemindByPageInfo(pageInfo, filter).getContent()));
            return map;
        }
        log.info("/inquiry/public/mobile/v2 耗时:{}", (System.currentTimeMillis() - start));
        return map;
    }
    /* ===========================================app接口end============================================================ */

}