package com.xzx.gc.system.controller;


import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.StrUtil;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.xzx.gc.common.Result;
import com.xzx.gc.common.constant.BusinessEnum;
import com.xzx.gc.common.constant.CommonEnum;
import com.xzx.gc.common.constant.Constants;
import com.xzx.gc.common.dto.SimplePage;
import com.xzx.gc.common.dto.log.OperationAppLog;
import com.xzx.gc.common.request.BaseController;
import com.xzx.gc.entity.SysStorage;
import com.xzx.gc.model.FileExportDTO;
import com.xzx.gc.model.JsonResult;
import com.xzx.gc.model.admin.ExportParamModel;
import com.xzx.gc.model.admin.OrderModel;
import com.xzx.gc.model.admin.StorageModel;
import com.xzx.gc.model.admin.SysStorageApiModel;
import com.xzx.gc.system.mapper.SysStorageMapper;
import com.xzx.gc.system.service.CityPartnerService;
import com.xzx.gc.system.service.OtherUserService;
import com.xzx.gc.system.service.SysStorageService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;

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

@Api(tags = "仓库管理")
@RestController
@Validated
@Slf4j
public class StorageController extends BaseController {


    @Autowired
    private SysStorageMapper sysStorageMapper;

    @Autowired
    private SysStorageService sysStorageService;

    @Autowired
    private OtherUserService otherUserService;

    @Autowired
    private CityPartnerService cityPartnerService;

    @ApiOperation(value = "分页查看所有仓库")
    @PostMapping(value = "/sysStorage/select")
    public Result<PageInfo<SysStorage>> select(HttpServletRequest request, @RequestBody SimplePage simplePage){
        PageHelper.startPage(simplePage.getPageNo(),simplePage.getPageSize());

        SysStorage sysStorage=new SysStorage();
        sysStorage.setDelFlag(Constants.DEL_NOT_FLAG);
        String userId = getUserId(request);
        String partnerId = otherUserService.findById(userId).getPartnerId();
        sysStorage.setPartnerId(partnerId);
        List<SysStorage> select = sysStorageMapper.select(sysStorage);
        PageInfo<SysStorage> pageInfo=new PageInfo<>(select);
        return Result.success(pageInfo);
    }

    /**
     * 查询仓库列表
     * @param sysStorageApiModel
     * @return
     */
    @PostMapping("/admin/front/sysStorage/querySysStorageList.do")
    @ApiOperation(value="运营管理-仓库管理", notes="test: 仅0有正确返回")
    public JsonResult<Map<String, Object>> querySysStorageList(@RequestBody SysStorageApiModel sysStorageApiModel){
        Map<String, Object> map = sysStorageService.querySysStorageList(sysStorageApiModel);
        return JsonResult.success(map);

    }
    /**
     * 查询仓库列表
     * @param sysStorageApiModel
     * @return
     */
    @PostMapping("/admin/front/sysStorage/addSysStorageApi.json")
    @ApiOperation(value="运营管理-新增仓库", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name = "storageName", value = "名称", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "storageArea", value = "面积", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "detailAddress", value = "详细地址", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "partnerId", value = "合伙人ID", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "area", value = "区域Id", required = true, dataType = "String")
    })
    public JsonResult<Map<String, Object>> addSysStorageApi(@RequestBody SysStorageApiModel sysStorageApiModel,HttpServletRequest request){
        int num = sysStorageService.addSysStorageApi(sysStorageApiModel);
        Map<String,Object> map = new HashMap<>();
        map.put("code",0);
        map.put("num",num);
        OperationAppLog build = OperationAppLog.builder().appPrograme(CommonEnum.后台.getValue()).opreateName(getAdminName(request))
                .methodName(Constants.ORDER_MODUL_NAME).operateAction("新增仓库-"+sysStorageApiModel.getId()).build();
        mqUtil.sendApp(build);
        return JsonResult.success(map);
    }

    @PostMapping("/admin/front/sysStorage/updateSysStorageApi.json")
    @ApiOperation(value="运营管理-修改仓库", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name = "storageName", value = "名称", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "storageArea", value = "面积", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "detailAddress", value = "详细地址", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "id", value = "仓库Id", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "partnerId", value = "合伙人ID", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "area", value = "区域Id", required = true, dataType = "String")
    })
    public JsonResult<Map<String, Object>> updateSysStorageApi(@RequestBody SysStorageApiModel sysStorageApiModel, HttpServletRequest request){
        int num = sysStorageService.updateSysStorageApi(sysStorageApiModel);
        Map<String,Object> map = new HashMap<>();
        map.put("code",0);
        map.put("num",num);
        OperationAppLog build = OperationAppLog.builder().appPrograme(CommonEnum.后台.getValue()).opreateName(getAdminName(request))
                .methodName(Constants.ORDER_MODUL_NAME).operateAction("修改仓库-"+sysStorageApiModel.getId()).build();
        mqUtil.sendApp(build);
        return JsonResult.success(map);
    }

    @PostMapping("/admin/front/sysStorage/delSysStorageApi.json")
    @ApiOperation(value="运营管理-删除仓库", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name = "id", value = "仓库Id", required = true, dataType = "String")
    })
    public JsonResult<Map<String, Object>> delSysStorageApi(@RequestBody SysStorageApiModel sysStorageApiModel,HttpServletRequest request){
        int num = sysStorageService.delSysStorageApi(sysStorageApiModel);
        Map<String,Object> map = new HashMap<>();
        map.put("code",0);
        map.put("num",num);
        OperationAppLog build = OperationAppLog.builder().appPrograme(CommonEnum.后台.getValue()).opreateName(getAdminName(request))
                .methodName(Constants.ORDER_MODUL_NAME).operateAction("删除仓库-"+sysStorageApiModel.getId()).build();
        mqUtil.sendApp(build);
        return JsonResult.success(map);
    }

    @PostMapping( "/admin/front/sysStorage/querySysStorageApi.json")
    @ApiOperation(value="运营管理-仓库列表", notes="test: 仅0有正确返回")
    public JsonResult<List<Map<String, Object>>> querySysStorageApi(){
        List<String> partnerIds = cityPartnerService.queryPartnerByCurrent();
        List<Map<String, Object>> result = sysStorageMapper.queryAllStorage(partnerIds);
        for (Map<String, Object> map:result) {
            map.put("storagename",map.get("storageName"));
        }
        return JsonResult.success(result);
    }

    @PostMapping("/admin/front/sysStorage/querySysStrangeList.json")
    @ApiOperation(value="查询仓库下拉列表", notes="test: 仅0有正确返回")
    public JsonResult<List<Map<String,Object>>> querySysStrangeList(){
        List<Map<String, Object>> list = sysStorageService.querySysStrangeList();
        return JsonResult.success(list);
    }

    /**
     * 查询仓库数据
     * @param storageModel
     * @return
     */
    @PostMapping( "/admin/front/sysStorage/data/querySysStorageList.do")
    @ApiOperation(value="数据统计-仓库数据", notes="test: 仅0有正确返回")
    public JsonResult<Map<String, Object>> querySysStorageList(@RequestBody StorageModel storageModel){
        Map<String,Object> resultMap = sysStorageService.querySysStorageListData(storageModel);
        return JsonResult.success(resultMap);
    }

    /**
     * 查询仓库列表
     * @param storageModel
     * @return
     */
    @PostMapping( "/admin/front/sysStorage/data/querySysStorageDetail.json")
    @ApiOperation(value="数据统计-仓库列表", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name = "timeType", value = "时间类型(week(周),month(月))", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "sysStorageId", value = "仓库Id(上一个页面的id)", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "imageType", value = "统计图的时间类型(具体类别的图，week(周),month(月))", required = true, dataType = "String")

    })
    public JsonResult<Map<String, Object>> querySysStorageDetail(@RequestBody StorageModel storageModel){
        Map<String,Object> resultMap = sysStorageService.querySysStorageDetail(storageModel);
        return JsonResult.success(resultMap);
    }

    @ApiOperation(value = "仓库导出",produces = MediaType.APPLICATION_OCTET_STREAM_VALUE)
    @PostMapping(value = "/admin/front/sysStorage/export")
    public void fileExport(@RequestBody ExportParamModel exportParamModel, HttpServletRequest request, HttpServletResponse response) {
        List<List<String>> rows = new ArrayList<>();
        //标题
        List<String> header = CollUtil.newArrayList("所属地区", "仓库名称", "累计订单量", "总入库重量（吨）", "日均入库重量（吨）", "总入库金额（万元）", "日均入库金额（万元）");
        rows.add(header);

        //组装数据
        StorageModel storageModel = new StorageModel(exportParamModel);
        Map<String, Object> result = sysStorageService.querySysStorageListData(storageModel);
        List<Map<String,Object>> storageApiModelList = (List<Map<String,Object>>) result.get("data");
        if (CollUtil.isNotEmpty(storageApiModelList)) {
            for(Map<String,Object> m : storageApiModelList){
                List<String> list = new ArrayList<>();
                list.add(m.get("areaName").toString());
                if(null!=m.get("delFlag")){
                    if(m.get("delFlag").toString().equals("1")){
                        m.put("storageName",m.get("storageName").toString()+"(已删除)");
                    }
                }
                list.add(m.get("storageName").toString());
                list.add(m.get("orderNum").toString());
                list.add(m.get("storageWeight").toString());
                list.add(m.get("dayStorageWeight").toString());
                list.add(m.get("storageMoney").toString());
                list.add(m.get("dayStorageMoney").toString());
                rows.add(list);
            }
        }

        //导出
        export(rows,response);

        OperationAppLog build = OperationAppLog.builder().appPrograme(CommonEnum.后台.getValue()).opreateName(getAdminName(request))
                .methodName(Constants.SYS_MODUL_NAME).operateAction("仓库导出").build();
        mqUtil.sendApp(build);
    }
}