companybase 字段添加

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/biz/CompanyBaseBiz.java

@@ -2,21 +2,149 @@ package com.xxfc.platform.vehicle.biz;
 
 
 import com.github.wxiaoqi.security.common.biz.BaseBiz;
-import com.xxfc.platform.vehicle.entity.CompanyBase;
+import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
+import com.github.wxiaoqi.security.common.util.process.ResultCode;
+import com.xxfc.platform.vehicle.entity.*;
+import com.xxfc.platform.vehicle.mapper.BranchCompanyStockInfoMapper;
 import com.xxfc.platform.vehicle.mapper.CompanyBaseMapper;
 import com.xxfc.platform.vehicle.pojo.dto.CompanyBaseDetailDTO;
 import com.xxfc.platform.vehicle.pojo.vo.CompanyBaseVo;
+import com.xxfc.platform.vehicle.pojo.vo.CompanyVo;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 
+import java.math.BigDecimal;
+import java.util.List;
+
 @Service
 @Slf4j
 public class CompanyBaseBiz extends BaseBiz<CompanyBaseMapper, CompanyBase>  {
+
+
+     @Autowired
+     BranchCompanyStockRightBiz stockRightBiz;
+
+     @Autowired
+     BranchCompanyStockInfoMapper stockInfoMapper;
+
+    @Value("${branchCompanyPic.url}")
+    private  String companyUrl;
+
+    //临时数据同步
+    public ObjectRestResponse synchro(){
+       List<BranchCompanyStockInfo> list= stockInfoMapper.selectAll();
+       if (list.size()>0){
+           for (BranchCompanyStockInfo companyStockInfo:list){
+                int num=0;
+               String companyName=companyStockInfo.getCompanyName();
+               Integer balance=companyStockInfo.getBalance();
+               Integer total=companyStockInfo.getTotal();
+               BigDecimal price=companyStockInfo.getPrice();
+               CompanyBase companyBase=new CompanyBase();
+               companyBase.setAddrCity(companyStockInfo.getAddrCity());
+               companyBase.setAddrProvince(companyStockInfo.getAddrProvince());
+               companyBase.setName(companyName);
+               companyBase.setCover(companyUrl+"/image/admin/upload"+companyStockInfo.getCompanyPic());
+               companyBase.setImages(companyUrl+"/image/admin/upload"+companyStockInfo.getCompanyPic());
+               insertSelective(companyBase);
+               Integer companyBaseId=companyBase.getId();
+               if (companyBaseId!=null){
+                    BranchCompanyStockRight branchCompanyStockRight=new BranchCompanyStockRight();
+                   branchCompanyStockRight.setBalance(balance);
+                   branchCompanyStockRight.setPrice(price);
+                   branchCompanyStockRight.setTotal(total);
+                   branchCompanyStockRight.setCompanyBaseId(companyBaseId);
+                   branchCompanyStockRight.setStockState(2);
+                   stockRightBiz.insertSelective(branchCompanyStockRight);
+               }
+               num++;
+               log.info("----成功---num=="+num+"---companyBaseId==="+companyBaseId);
+           }
+       }
+
+        return  ObjectRestResponse.succ();
+    }
+    //设置基础信息
+    public  ObjectRestResponse updCompany(CompanyVo companyVo){
+        if (companyVo==null|| StringUtils.isBlank(companyVo.getCompanyName())|| StringUtils.isBlank(companyVo.getName())||
+                companyVo.getZoneId()==null||companyVo.getZoneId()==0|| companyVo.getAddrProvince()==null||companyVo.getAddrProvince()==0
+                || companyVo.getAddrCity()==null||companyVo.getAddrCity()==0){
+            return  ObjectRestResponse.createFailedResult(ResultCode.NULL_CODE,"参数不能为空");
+        }
+        Integer state=companyVo.getState()==null?2:companyVo.getState();
+        if (state==1&&(StringUtils.isBlank(companyVo.getAddrDetail())||StringUtils.isBlank(companyVo.getImages())||StringUtils.isBlank(companyVo.getDescribes())||StringUtils.isBlank(companyVo.getContent())
+                ||StringUtils.isBlank(companyVo.getLeader())||StringUtils.isBlank(companyVo.getLeaderContactInfo())||StringUtils.isBlank(companyVo.getTourServicePhone())||StringUtils.isBlank(companyVo.getVehiceServicePhone()))){
+            return  ObjectRestResponse.createFailedResult(ResultCode.NULL_CODE,"上架时参数不能为空");
+        }
+        CompanyBase companyBase=new CompanyBase();
+        BeanUtils.copyProperties(companyVo,companyBase);
+        Integer companyBaseId=companyVo.getId();
+        if (companyBaseId==null||companyBaseId==0){
+            insertSelective(companyBase);
+            companyBaseId=companyBase.getId();
+        }else {
+            updateSelectiveById(companyBase);
+        }
+        BranchCompany branchCompany=new BranchCompany();
+        BeanUtils.copyProperties(companyVo,branchCompany);
+        branchCompany.setCompanyBaseId(companyBaseId);
+        branchCompany.setName(companyVo.getCompanyName());
+        Integer companyId=companyVo.getCompanyId();
+        if (companyId==null||companyId==0){
+            branchCompany.setId(null);
+            insertSelective(companyBase);
+        }else {
+            branchCompany.setId(companyId);
+            updateSelectiveById(companyBase);
+        }
+        return  ObjectRestResponse.succ();
+    }
+
+    //设置股权信息
+    public  ObjectRestResponse updStockInfo(CompanyVo companyVo){
+        if (companyVo==null|| StringUtils.isBlank(companyVo.getCompanyName())|| StringUtils.isBlank(companyVo.getName())||
+                companyVo.getZoneId()==null||companyVo.getZoneId()==0|| companyVo.getAddrProvince()==null||companyVo.getAddrProvince()==0
+                || companyVo.getAddrCity()==null||companyVo.getAddrCity()==0){
+            return  ObjectRestResponse.createFailedResult(ResultCode.NULL_CODE,"参数不能为空");
+        }
+        Integer state=companyVo.getState()==null?2:companyVo.getState();
+        if (state==1&&(StringUtils.isBlank(companyVo.getAddrDetail())||StringUtils.isBlank(companyVo.getImages())||StringUtils.isBlank(companyVo.getDescribes())||StringUtils.isBlank(companyVo.getContent())
+                ||StringUtils.isBlank(companyVo.getLeader())||StringUtils.isBlank(companyVo.getLeaderContactInfo())||StringUtils.isBlank(companyVo.getTourServicePhone())||StringUtils.isBlank(companyVo.getVehiceServicePhone()))){
+            return  ObjectRestResponse.createFailedResult(ResultCode.NULL_CODE,"上架时参数不能为空");
+        }
+        CompanyBase companyBase=new CompanyBase();
+        BeanUtils.copyProperties(companyVo,companyBase);
+        Integer companyBaseId=companyVo.getId();
+        if (companyBaseId==null||companyBaseId==0){
+            insertSelective(companyBase);
+            companyBaseId=companyBase.getId();
+        }else {
+            updateSelectiveById(companyBase);
+        }
+        BranchCompany branchCompany=new BranchCompany();
+        BeanUtils.copyProperties(companyVo,branchCompany);
+        branchCompany.setCompanyBaseId(companyBaseId);
+        branchCompany.setName(companyVo.getCompanyName());
+        Integer companyId=companyVo.getCompanyId();
+        if (companyId==null||companyId==0){
+            branchCompany.setId(null);
+            insertSelective(companyBase);
+        }else {
+            branchCompany.setId(companyId);
+            updateSelectiveById(companyBase);
+        }
+        return  ObjectRestResponse.succ();
+    }
+
     public CompanyBaseVo findCompanyDetailById(Integer id) {
         CompanyBaseVo companyBaseVo = new CompanyBaseVo();
         CompanyBaseDetailDTO companyBaseDetailDTO = mapper.findCompanyBaseById(id);
         BeanUtils.copyProperties(companyBaseDetailDTO,companyBaseVo);
         return companyBaseVo;
     }
+
 }