code重复同步数据

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

@@ -3,6 +3,7 @@ package com.xxfc.platform.vehicle.biz;
 import cn.hutool.core.bean.BeanUtil;
 import com.ace.cache.annotation.Cache;
 import com.ace.cache.annotation.CacheClear;
+import com.alibaba.fastjson.JSONObject;
 import com.github.pagehelper.PageHelper;
 import com.github.pagehelper.PageInfo;
 import com.github.wxiaoqi.security.admin.feign.UserFeign;
@@ -393,4 +394,8 @@ public class BranchCompanyBiz extends BaseBiz<BranchCompanyMapper, BranchCompany
         pageDataVO.setTotalCount(dataVO.getTotalCount());
         return pageDataVO;
     }
+    public  List<JSONObject> getList(){
+     return  mapper.getList();
+    }
+
 }

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

@@ -2,6 +2,7 @@ package com.xxfc.platform.vehicle.biz;
 
 
 import com.ace.cache.annotation.CacheClear;
+import com.alibaba.fastjson.JSONObject;
 import com.github.wxiaoqi.security.common.biz.BaseBiz;
 import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
 import com.github.wxiaoqi.security.common.util.RandomUtil;
@@ -25,6 +26,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 import org.springframework.web.multipart.MultipartFile;
+import tk.mybatis.mapper.entity.Example;
 
 import javax.servlet.http.HttpServletRequest;
 import java.math.BigDecimal;
@@ -124,6 +126,36 @@ public class CompanyBaseBiz extends BaseBiz<CompanyBaseMapper, CompanyBase>  {
 
         return  ObjectRestResponse.succ();
     }
+    //临时数据同步5(添加车辆)
+    public ObjectRestResponse synchro5(){
+        List<JSONObject> list= branchCompanyBiz.getList();
+        Integer number=10000;
+        if (list.size()>0){
+
+            for (JSONObject obj:list){
+                Integer code= obj.getInteger("code");
+                if (code==null||code==0){
+                    continue;
+                }
+                Example example=new Example(Vehicle.class);
+                example.createCriteria().andEqualTo("code",code);
+                List<Vehicle> vehicles=vehicleBiz.selectByExample(example);
+                int num=0;
+                for (Vehicle vehicle:vehicles){
+                    num++;
+                    if (num==1){
+                        continue;
+                    }
+                    number++;
+                    vehicle.setCode(number);
+                    vehicleBiz.updateSelectiveById(vehicle);
+                }
+            }
+
+        }
+        return  ObjectRestResponse.succ();
+    }
+
 
     public  String  getNumberPlate(int number){
         String str=number+"";

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/mapper/BranchCompanyMapper.java

 package com.xxfc.platform.vehicle.mapper;
 
+import com.alibaba.fastjson.JSONObject;
 import com.xxfc.platform.vehicle.entity.BranchCompany;
 import com.xxfc.platform.vehicle.pojo.dto.BranchCompanyListDTO;
 import com.xxfc.platform.vehicle.pojo.vo.BranchCompanyListVO;
 import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
 import tk.mybatis.mapper.additional.idlist.SelectByIdListMapper;
 import tk.mybatis.mapper.common.Mapper;
 
@@ -17,4 +19,8 @@ public interface BranchCompanyMapper extends Mapper<BranchCompany>, SelectByIdLi
     List<Integer> findCompanyIdsByAreaId(@Param("areaId") Integer areaId);
 
     List<BranchCompanyListDTO > findBranchCompanys(@Param("provinceCode") Integer provinceCode,@Param("cityCode") Integer cityCode);
+
+
+    @Select("SELECT `code`,count(id) cd FROM `vehicle` WHERE is_del=0 and number_plate LIKE '%测试%' GROUP  BY code HAVING cd>=2")
+    List<JSONObject> getList();
 }
\ No newline at end of file

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/rest/admin/CompanyController.java

@@ -33,8 +33,8 @@ public class CompanyController extends BaseController<CompanyBaseBiz> {
 
     @ApiOperation("同步股权3")
     @PostMapping("synchro3")
-    public ObjectRestResponse<String> synchro3() {
-        return baseBiz.synchro3();
+    public ObjectRestResponse synchro3() {
+        return baseBiz.synchro5();
     }