package doumeemes.api.ext;

import doumeemes.api.BaseController;
import doumeemes.core.annotation.excel.ExcelExporter;
import doumeemes.core.annotation.pr.PreventRepeat;
import doumeemes.core.model.ApiResponse;
import doumeemes.core.model.PageData;
import doumeemes.core.model.PageWrap;
import doumeemes.core.utils.Constants;
import doumeemes.dao.business.dto.QueryUnitExtDTO;
import doumeemes.dao.business.model.Bom;
import doumeemes.dao.business.model.BomDetail;
import doumeemes.dao.business.model.Material;
import doumeemes.dao.business.model.MaterialDistribute;
import doumeemes.dao.business.vo.UnitExtListVO;
import doumeemes.dao.ext.bean.MaterialDetailBean;
import doumeemes.dao.ext.dto.QueryCategoryUnionExtDTO;
import doumeemes.dao.ext.dto.QueryMaterialExtDTO;
import doumeemes.dao.ext.vo.MaterialExtListVO;
import doumeemes.service.business.*;
import doumeemes.service.ext.CategoryUnionExtService;
import doumeemes.service.ext.MaterialDistributeExtService;
import doumeemes.service.ext.MaterialExtService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import org.apache.commons.lang3.StringUtils;
import org.apache.shiro.authz.annotation.RequiresPermissions;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
import org.springframework.web.multipart.MultipartHttpServletRequest;
import org.springframework.web.multipart.commons.CommonsMultipartResolver;

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

/**
 * 物料基本信息接口
 * @author 江蹄蹄
 * @date 2022/04/20 10:59
 */
@RestController
@RequestMapping("/ext/materialExt")
@Api(tags = "物料基本信息接口")
public class MaterialExtController extends BaseController {

    @Autowired
    private MaterialExtService materialExtService;
    
    @Autowired
    private MaterialService materialService;

    @Autowired
    private CategoryUnionExtService categoryUnionExtService;

    @Autowired
    private UnitExtService unitExtService;

    @Autowired
    private MaterialDistributeService materialDistributeService;


    @Autowired
    private MaterialDistributeExtService materialDistributeExtService;


    @Autowired
    private BomService bomService;

    @Autowired
    private BomDetailService bomDetailService;



    @PreventRepeat
    @ApiOperation("新建")
    @PostMapping("/create")
    @RequiresPermissions("ext:materialext:create")
    public ApiResponse create(@RequestBody Material material) {
        Integer result=materialService.create(material);
        if(result==-1){
            return ApiResponse.failed("主组织内物料编码不能重复");
        }else if(result==-2){
            return ApiResponse.failed("主组织内物料名称不能重复");
        }
        return ApiResponse.success(result);
    }

    @ApiOperation("根据ID删除")
    @GetMapping("/delete/{id}")
    @RequiresPermissions("ext:materialext:delete")
    public ApiResponse deleteById(@PathVariable Integer id) {
        Material material=   materialService.findById(id);
        material.setDeleted(Constants.ONE);
        materialService.updateById(material);
        return ApiResponse.success(null);
    }

    @ApiOperation("批量删除")
    @GetMapping("/delete/batch")
    @RequiresPermissions("ext:materialext:delete")
    public ApiResponse deleteByIds(@RequestParam String ids) {
        String [] idArray = ids.split(",");
        List<Material> idList = new ArrayList<>();
        for (String id : idArray) {
            Material material=   materialService.findById(Integer.valueOf(id));
            material.setDeleted(Constants.ONE);
            idList.add(material);
        }
        materialService.updateByIdInBatch(idList);
        return ApiResponse.success(null);
    }

    @ApiOperation("根据ID修改")
    @PostMapping("/updateById")
    @RequiresPermissions("ext:materialext:update")
    public ApiResponse updateById(@RequestBody Material material) {
        Integer result=materialService.updateById(material);

        if(result==-1){
            return ApiResponse.failed("主组织内物料编码不能重复");
        }else if(result==-2){
            return ApiResponse.failed("主组织内物料名称不能重复");
        }
        return ApiResponse.success(result);
    }

    @ApiOperation("分页查询")
    @PostMapping("/page")
    @RequiresPermissions("ext:materialext:query")
    public ApiResponse<PageData<MaterialExtListVO>> findPage (@RequestBody PageWrap<QueryMaterialExtDTO> pageWrap) {
        return ApiResponse.success(materialExtService.findPage(pageWrap));
    }

    @ApiOperation("导出Excel")
    @PostMapping("/exportExcel")
    @RequiresPermissions("ext:materialext:exportExcel")
    public void exportExcel (@RequestBody PageWrap<QueryMaterialExtDTO> pageWrap, HttpServletResponse response) {
        ExcelExporter.build(MaterialExtListVO.class).export(materialExtService.findPage(pageWrap).getRecords(), "物料基本信息", response);
    }

    @ApiOperation("根据ID查询")
    @GetMapping("/{id}")
    @RequiresPermissions("ext:materialext:query")
    public ApiResponse<MaterialDetailBean> findById(@PathVariable Integer id) {
        return ApiResponse.success(materialExtService.findDetailById(id));
    }


    @ApiOperation("获取当前主组织分类为物料的数据集合")
    @GetMapping("/getCategoryUnionListByOrg")
    public ApiResponse getCategoryUnionListByOrg() {
        QueryCategoryUnionExtDTO categoryUnion=new QueryCategoryUnionExtDTO();
        categoryUnion.setDeleted(Constants.ZERO);
        categoryUnion.setRootDepartId(getLoginUser().getRootDepartment().getId());
        categoryUnion.setBmodelCateType("0");
       // categoryUnion.setMmodelCateType("0");
      //  categoryUnion.setCmodelCateType("0");
        return ApiResponse.success(categoryUnionExtService.getCategoryUnionListByOrg(categoryUnion));
    }



    @ApiOperation("主单位集合")
    @PostMapping("/getUnitListByOrg")
    public ApiResponse<List<UnitExtListVO>> getUnitListByOrg () {
        QueryUnitExtDTO pageWrap=new QueryUnitExtDTO();
        pageWrap.setDeleted(Constants.ZERO);
        pageWrap.setRootDepartId(getLoginUser().getRootDepartment().getId());
        pageWrap.setType(Constants.ZERO);
        pageWrap.setStatus(Constants.ONE);
        return ApiResponse.success(unitExtService.getUnitListByOrg(pageWrap));
    }

    @ApiOperation("物料分配")
    @ApiImplicitParams({
            @ApiImplicitParam(value = "物料ids,逗号分割", name = "materialIds", paramType = "query", required = true, dataType = "Integer"),
            @ApiImplicitParam(value = "公司级组织ids", name = "departIds", paramType = "query", required = true, dataType = "Integer")
    })
    @GetMapping("/distributionMaterial")
    @RequiresPermissions("ext:materialext:distributionMaterial")
    public ApiResponse distributionMaterial(@RequestParam String materialIds, @RequestParam String departIds) {
        if(StringUtils.isEmpty(materialIds)||StringUtils.isEmpty(departIds)){
            return ApiResponse.failed("参数不正确！");
        }
       return materialDistributeService.insert(materialIds,departIds);
    }



    @ApiOperation("物料状态变更（失效）")
    @ApiImplicitParams({
            @ApiImplicitParam(value = "物料ids", name = "ids", paramType = "query", required = true, dataType = "String"),
            @ApiImplicitParam(value = "状态0.无效 1.有效", name = "status", paramType = "query", required = true, dataType = "String")
    })
    @GetMapping("/updateMateriaStatus")
    @RequiresPermissions("ext:materialext:updateMateriaStatus")
    public ApiResponse updateMateriaStatus (@RequestParam String ids,@RequestParam String status) {
        if(StringUtils.isEmpty(ids)||StringUtils.isEmpty(status)){
           return ApiResponse.failed("参数不正确");
        }
        return materialService.updateMateriaStatus(ids ,status);
    }


    @ApiOperation("物料详情子组织状态变更")
    @ApiImplicitParams({
            @ApiImplicitParam(value = "id", name = "id", paramType = "query", required = true, dataType = "String"),
            @ApiImplicitParam(value = "状态0.无效 1.有效", name = "status", paramType = "query", required = true, dataType = "String")
    })
    @GetMapping("/updateChildMateriaStatus")
    @RequiresPermissions("ext:materialext:updateChildMateriaStatus")
    public ApiResponse updateChildMateriaStatus (@RequestParam String id,@RequestParam String status) {
        if(StringUtils.isEmpty(id)||StringUtils.isEmpty(status)){
            return ApiResponse.failed("参数不正确");
        }


        MaterialDistribute materialDistribute=  materialDistributeService.findById(Integer.valueOf(id));
        materialDistribute.setStatus(Integer.valueOf(status));
        materialDistribute.setMaterialId(Integer.valueOf(id));
        if(StringUtils.equals(status,"0")){
            //无效
            materialDistribute.setInvalidTime(new Date());
        }
        if(StringUtils.equals(status,"1")){
            //有效
            materialDistribute.setValidTime(new Date());
        }

        if(StringUtils.equals(status,"0")){
            //查询BOM是否关联物料已关联不允许失效
            BomDetail bomDetail=new BomDetail();
            bomDetail.setDeleted(Constants.ZERO);
            bomDetail.setMaterialId(materialDistribute.getMaterialId());
            List<BomDetail> bdList= bomDetailService.findList(bomDetail);
            Bom bom=new Bom();
            bom.setStatus(1);
            bom.setDeleted(Constants.ZERO);
            List<Bom> blist= bomService.findList(bom);
            if(bdList.size()>0||blist.size()>0){
                return ApiResponse.failed("已关联BOM不允许失效");
            }
        }
        materialDistributeService.updateById(materialDistribute);
        return ApiResponse.success(null);
    }


    @ApiOperation("查询所有的物料")
    @PostMapping("/getListByCondition")
    @RequiresPermissions("ext:materialext:query")
    public ApiResponse<List<MaterialExtListVO>> getListByCondition (@RequestBody QueryMaterialExtDTO queryMaterialExtDTO ) {
        return ApiResponse.success(materialExtService.getListByCondition(queryMaterialExtDTO));
    }




    /**
     * 导入物料
     *
     * @param request
     * @param response
     * @throws Exception
     */
    @ApiOperation(value = "导入物料", notes = "导入物料", httpMethod = "POST", position = 6)
    @ApiImplicitParams({
            @ApiImplicitParam(name = "folder", value = "文件夹", required = true, paramType = "query", dataType = "String", dataTypeClass = String.class),
    })
    @PostMapping(value = "/importmaterial", headers = "content-type=multipart/form-data")
    public ApiResponse importmaterial(String folder, HttpServletRequest request, HttpServletResponse response) throws Exception {
        CommonsMultipartResolver multipartResovler = new CommonsMultipartResolver();
        if (multipartResovler.isMultipart(request)) {
            MultipartHttpServletRequest multipartRequest = (MultipartHttpServletRequest) request;
            Iterator<String> it = multipartRequest.getFileNames();
            while (it.hasNext()) {
                MultipartFile file = multipartRequest.getFile((String) it.next());// file
                materialExtService.importmaterial(file);
                break;
            }
        }

        return ApiResponse.success( null);
    }
}