|
@@ -1,19 +1,37 @@
|
|
|
package com.management.platform.service.impl;
|
|
|
|
|
|
+import com.alibaba.fastjson.JSON;
|
|
|
+import com.alibaba.fastjson.JSONArray;
|
|
|
+import com.alibaba.fastjson.JSONObject;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
-import com.management.platform.entity.Product;
|
|
|
+import com.management.platform.entity.*;
|
|
|
import com.management.platform.mapper.ProductMapper;
|
|
|
+import com.management.platform.mapper.SysDictMapper;
|
|
|
+import com.management.platform.mapper.SysFormMapper;
|
|
|
+import com.management.platform.mapper.UserMapper;
|
|
|
import com.management.platform.service.ProductService;
|
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
|
+import com.management.platform.service.WxCorpInfoService;
|
|
|
+import com.management.platform.util.ExcelUtil;
|
|
|
import com.management.platform.util.HttpRespMsg;
|
|
|
+import org.apache.poi.hssf.usermodel.HSSFCell;
|
|
|
+import org.apache.poi.hssf.usermodel.HSSFRow;
|
|
|
+import org.apache.poi.hssf.usermodel.HSSFSheet;
|
|
|
+import org.apache.poi.hssf.usermodel.HSSFWorkbook;
|
|
|
+import org.apache.poi.ss.usermodel.CellType;
|
|
|
+import org.springframework.beans.factory.annotation.Value;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
import org.springframework.util.StringUtils;
|
|
|
+import org.springframework.web.multipart.MultipartFile;
|
|
|
|
|
|
import javax.annotation.Resource;
|
|
|
-import java.util.HashMap;
|
|
|
-import java.util.Map;
|
|
|
+import javax.servlet.http.HttpServletRequest;
|
|
|
+import java.io.*;
|
|
|
+import java.lang.reflect.InvocationTargetException;
|
|
|
+import java.lang.reflect.Method;
|
|
|
+import java.util.*;
|
|
|
|
|
|
/**
|
|
|
* <p>
|
|
@@ -28,12 +46,27 @@ public class ProductServiceImpl extends ServiceImpl<ProductMapper, Product> impl
|
|
|
|
|
|
@Resource
|
|
|
private ProductMapper productMapper;
|
|
|
+ @Resource
|
|
|
+ private HttpServletRequest request;
|
|
|
+ @Resource
|
|
|
+ private UserMapper userMapper;
|
|
|
+ @Resource
|
|
|
+ private SysFormMapper sysFormMapper;
|
|
|
+ @Value(value = "${upload.path}")
|
|
|
+ private String path;
|
|
|
+ @Resource
|
|
|
+ private WxCorpInfoService wxCorpInfoService;
|
|
|
+ @Resource
|
|
|
+ private SysDictMapper sysDictMapper;
|
|
|
|
|
|
@Override
|
|
|
public HttpRespMsg getList(Integer companyId,String userId, String productName, String productCode, Integer pageIndex, Integer pageSize) {
|
|
|
HttpRespMsg msg=new HttpRespMsg();
|
|
|
LambdaQueryWrapper<Product> queryWrapper = new LambdaQueryWrapper<>();
|
|
|
queryWrapper.eq(Product::getCompanyId,companyId);
|
|
|
+ List<User> userList = userMapper.selectList(new LambdaQueryWrapper<User>().eq(User::getCompanyId, companyId));
|
|
|
+ List<SysDict> sysDictOfProductType = sysDictMapper.selectList(new LambdaQueryWrapper<SysDict>().eq(SysDict::getCompanyId, companyId).eq(SysDict::getCode, "ProductType"));
|
|
|
+ List<SysDict> sysDictOfProductUnit = sysDictMapper.selectList(new LambdaQueryWrapper<SysDict>().eq(SysDict::getCompanyId, companyId).eq(SysDict::getCode, "ProductUnit"));
|
|
|
if(!StringUtils.isEmpty(userId)){
|
|
|
queryWrapper.eq(Product::getCreatorId,userId);
|
|
|
}
|
|
@@ -44,10 +77,227 @@ public class ProductServiceImpl extends ServiceImpl<ProductMapper, Product> impl
|
|
|
queryWrapper.like(Product::getProductCode,productCode);
|
|
|
}
|
|
|
IPage<Product> productIPage = productMapper.selectPage(new Page<>(pageIndex, pageSize), queryWrapper);
|
|
|
+ List<Product> records = productIPage.getRecords();
|
|
|
+ records.forEach(r->{
|
|
|
+ Optional<User> user = userList.stream().filter(u -> u.getId().equals(r.getCreatorId())).findFirst();
|
|
|
+ if(user.isPresent()){
|
|
|
+ r.setInchargerName(user.get().getName());
|
|
|
+ }
|
|
|
+ Optional<SysDict> unit = sysDictOfProductUnit.stream().filter(u -> u.getId().equals(r.getUnit())).findFirst();
|
|
|
+ if(unit.isPresent()){
|
|
|
+ r.setUnitName(unit.get().getName());
|
|
|
+ }
|
|
|
+ Optional<SysDict> type = sysDictOfProductType.stream().filter(u -> u.getId().equals(r.getCreatorId())).findFirst();
|
|
|
+ if(type.isPresent()){
|
|
|
+ r.setTypeName(type.get().getName());
|
|
|
+ }
|
|
|
+ });
|
|
|
Map map=new HashMap();
|
|
|
- map.put("record",productIPage.getRecords());
|
|
|
+ map.put("record",records);
|
|
|
map.put("total",productIPage.getTotal());
|
|
|
msg.setData(map);
|
|
|
return msg;
|
|
|
}
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public HttpRespMsg importData(MultipartFile multipartFile) {
|
|
|
+ HttpRespMsg msg=new HttpRespMsg();
|
|
|
+ String fileName = multipartFile.getOriginalFilename();
|
|
|
+ File file = new File(fileName == null ? "file" : fileName);
|
|
|
+ User user = userMapper.selectById(request.getHeader("token"));
|
|
|
+ Integer companyId = user.getCompanyId();
|
|
|
+ WxCorpInfo wxCorpInfo = wxCorpInfoService.getOne(new LambdaQueryWrapper<WxCorpInfo>().eq(WxCorpInfo::getCompanyId, companyId));
|
|
|
+ List<Product> productList = productMapper.selectList(new LambdaQueryWrapper<Product>().eq(Product::getCompanyId, companyId));
|
|
|
+ List<User> userList = userMapper.selectList(new LambdaQueryWrapper<User>().eq(User::getCompanyId, companyId));
|
|
|
+ List<SysDict> sysDictOfProductType = sysDictMapper.selectList(new LambdaQueryWrapper<SysDict>().eq(SysDict::getCompanyId, companyId).eq(SysDict::getCode, "ProductType"));
|
|
|
+ List<SysDict> sysDictOfProductUnit = sysDictMapper.selectList(new LambdaQueryWrapper<SysDict>().eq(SysDict::getCompanyId, companyId).eq(SysDict::getCode, "ProductUnit"));
|
|
|
+ InputStream inputStream = null;
|
|
|
+ OutputStream outputStream = null;
|
|
|
+ try {
|
|
|
+ inputStream = multipartFile.getInputStream();
|
|
|
+ outputStream = new FileOutputStream(file);
|
|
|
+ byte[] buffer = new byte[4096];
|
|
|
+ int temp = 0;
|
|
|
+ while ((temp = inputStream.read(buffer, 0, 4096)) != -1) {
|
|
|
+ outputStream.write(buffer, 0, temp);
|
|
|
+ }
|
|
|
+ inputStream.close();
|
|
|
+ outputStream.close();
|
|
|
+ //解析表格
|
|
|
+ HSSFWorkbook workbook = new HSSFWorkbook(new FileInputStream(file));
|
|
|
+ //我们只需要第一个sheet
|
|
|
+ HSSFSheet sheet = workbook.getSheetAt(0);
|
|
|
+ //由于第一行需要指明列对应的标题
|
|
|
+ int rowNum = sheet.getLastRowNum();
|
|
|
+ //获取当前表单模板 校验规则
|
|
|
+ SysForm sysForm = sysFormMapper.selectOne(new LambdaQueryWrapper<SysForm>().eq(SysForm::getCode, "Product").eq(SysForm::getCompanyId, companyId).eq(SysForm::getIsCurrent, 1));
|
|
|
+ if(sysForm==null){
|
|
|
+ msg.setError("当前模块未配置自定义模板,需先完成配置");
|
|
|
+ return msg;
|
|
|
+ }
|
|
|
+ String config = sysForm.getConfig();
|
|
|
+ JSONObject configOb = JSON.parseObject(config);
|
|
|
+ JSONArray configObJSONArray = configOb.getJSONArray("list");
|
|
|
+ List<Product> importProductList=new ArrayList<>();
|
|
|
+ List<String> userNameList=new ArrayList<>();
|
|
|
+ HttpRespMsg respMsg=new HttpRespMsg();
|
|
|
+ for (int rowIndex = 0; rowIndex <= rowNum; rowIndex++) {
|
|
|
+ HSSFRow row = sheet.getRow(rowIndex);
|
|
|
+ if (row == null) {
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ //跳过空行
|
|
|
+ if (ExcelUtil.isRowEmpty(row)) {
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ //获取到当前行的列数据
|
|
|
+ int cellNum = row.getLastCellNum();
|
|
|
+ for (int i = 0; i < cellNum; i++) {
|
|
|
+ JSONObject item = configObJSONArray.getJSONObject(i);
|
|
|
+ String modelName = item.getString("model");
|
|
|
+ HSSFCell cell = row.getCell(i);
|
|
|
+ if(cell!=null){
|
|
|
+ switch (item.getString("type")){
|
|
|
+ case "time":cell.setCellType(CellType.NUMERIC);
|
|
|
+ break;
|
|
|
+ default:cell.setCellType(CellType.STRING);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if(modelName.equals("inchargerId")){
|
|
|
+ if(!StringUtils.isEmpty(cell.getStringCellValue())){
|
|
|
+ userNameList.add(cell.getStringCellValue());
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ }
|
|
|
+ System.out.println("参与搜素的人员列表"+userNameList + userNameList.size());
|
|
|
+ if(wxCorpInfo!=null&&wxCorpInfo.getSaasSyncContact()==1&&userNameList.size()>0){
|
|
|
+ respMsg = wxCorpInfoService.getBatchSearchUserInfo(wxCorpInfo, userNameList,null);
|
|
|
+ if(respMsg.code.equals("0")){
|
|
|
+ msg.setError("姓名为["+String.valueOf(respMsg.data)+"]的人员存在重复,请使用工号!");
|
|
|
+ return msg;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ List<User> targetUserList= (List<User>) respMsg.data;
|
|
|
+ for (int rowIndex = 0; rowIndex <= rowNum; rowIndex++) {
|
|
|
+ HSSFRow row = sheet.getRow(rowIndex);
|
|
|
+ if (row == null) {
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ //跳过空行
|
|
|
+ if (ExcelUtil.isRowEmpty(row)) {
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ //获取到当前行的列数据
|
|
|
+ int cellNum = row.getLastCellNum();
|
|
|
+ Product product=new Product();
|
|
|
+ product.setCompanyId(companyId);
|
|
|
+ product.setCreatorId(user.getId());
|
|
|
+ for (int i = 0; i < cellNum; i++) {
|
|
|
+ JSONObject item = configObJSONArray.getJSONObject(i);
|
|
|
+ String modelName = item.getString("model");
|
|
|
+ String className = modelName.substring(0, 1).toUpperCase() + modelName.substring(1);
|
|
|
+ String getter="get"+className;
|
|
|
+ String setter="set"+className;
|
|
|
+ HSSFCell cell = row.getCell(i);
|
|
|
+ if(cell!=null){
|
|
|
+ switch (item.getString("type")){
|
|
|
+ case "time":cell.setCellType(CellType.NUMERIC);
|
|
|
+ break;
|
|
|
+ default:cell.setCellType(CellType.STRING);
|
|
|
+ }
|
|
|
+ }
|
|
|
+// Class<?> productClass = Class.forName("com.management.platform.entity.Product");
|
|
|
+ Class<Product> productClass = Product.class;
|
|
|
+ Method method = productClass.getMethod(setter, String.class);
|
|
|
+ //校验当前列是否为必填
|
|
|
+ JSONObject options = item.getJSONObject("options");
|
|
|
+ JSONObject rules = options.getJSONObject("rules");
|
|
|
+ Boolean required = rules.getBoolean("required");
|
|
|
+ if(required){
|
|
|
+ if(StringUtils.isEmpty(cell.getStringCellValue())){
|
|
|
+ msg.setError(item.getString("label")+"值不能为空值");
|
|
|
+ return msg;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if(modelName.equals("productCode")){
|
|
|
+ if(!StringUtils.isEmpty(cell.getStringCellValue())){
|
|
|
+ //系统中同公司已存在的产品编码 更新
|
|
|
+ Optional<Product> first = productList.stream().filter(p ->p.getProductCode()!=null&& p.getProductCode().equals(cell.getStringCellValue())).findFirst();
|
|
|
+ if(first.isPresent()){
|
|
|
+ product.setId(first.get().getId());
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if(modelName.equals("inchargerId")){
|
|
|
+ if(!StringUtils.isEmpty(cell.getStringCellValue())){
|
|
|
+ String userName = cell.getStringCellValue();
|
|
|
+ Optional<User> first;
|
|
|
+ if(wxCorpInfo!=null&&wxCorpInfo.getSaasSyncContact()==1){
|
|
|
+ Optional<User> optional = targetUserList.stream().filter(tl -> tl.getName().equals(userName)).findFirst();
|
|
|
+ first= userList.stream().filter(u ->(u.getJobNumber()!=null&&u.getJobNumber().equals(userName))||(optional.isPresent()&&u.getCorpwxUserid()!=null&&u.getCorpwxUserid().equals(optional.get().getCorpwxUserid()))).findFirst();
|
|
|
+ }else {
|
|
|
+ first= userList.stream().filter(u -> u.getName().equals(userName)||(u.getJobNumber()!=null&&u.getJobNumber().equals(userName))).findFirst();
|
|
|
+ }
|
|
|
+ if (first.isPresent()) {
|
|
|
+ product.setInchargerId(first.get().getId());
|
|
|
+ } else {
|
|
|
+ throw new Exception("["+userName+"]在系统中不存在");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if(modelName.equals("status")){
|
|
|
+ if(!StringUtils.isEmpty(cell.getStringCellValue())){
|
|
|
+ switch (cell.getStringCellValue()){
|
|
|
+ case "下架":product.setStatus(0);
|
|
|
+ break;
|
|
|
+ case "上架":product.setStatus(1);
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if(modelName.equals("type")){
|
|
|
+ if(!StringUtils.isEmpty(cell.getStringCellValue())){
|
|
|
+ Optional<SysDict> first = sysDictOfProductType.stream().filter(s -> s.getName().equals(cell.getStringCellValue())).findFirst();
|
|
|
+ if(first.isPresent()){
|
|
|
+ product.setType(first.get().getId());
|
|
|
+ }else {
|
|
|
+ throw new Exception("产品类型["+cell.getStringCellValue()+"不存在,请在系统字典中增加");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if(modelName.equals("unit")){
|
|
|
+ if(!StringUtils.isEmpty(cell.getStringCellValue())){
|
|
|
+ Optional<SysDict> first = sysDictOfProductUnit.stream().filter(s -> s.getName().equals(cell.getStringCellValue())).findFirst();
|
|
|
+ if(first.isPresent()){
|
|
|
+ product.setUnit(first.get().getId());
|
|
|
+ }else {
|
|
|
+ throw new Exception("产品单位["+cell.getStringCellValue()+"不存在,请在系统字典中增加");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if(!StringUtils.isEmpty(cell.getStringCellValue())){
|
|
|
+ method.invoke(product,cell.getStringCellValue());
|
|
|
+ }
|
|
|
+ }
|
|
|
+ importProductList.add(product);
|
|
|
+ }
|
|
|
+ if(importProductList.size()>0){
|
|
|
+ if(!saveOrUpdateBatch(importProductList)){
|
|
|
+ msg.setError("验证失败");
|
|
|
+ return msg;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ } catch (IOException | NoSuchMethodException e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ } catch (IllegalAccessException e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ } catch (InvocationTargetException e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ } catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
+ return msg;
|
|
|
+ }
|
|
|
}
|