add ant image upload

src/main/java/com/huiju/estateagents/center/sysUser/controller/SysUserController.java

 import com.huiju.estateagents.common.CommConstant;
 import com.huiju.estateagents.common.JWTUtils;
 import com.huiju.estateagents.common.MD5Utils;
+import com.huiju.estateagents.common.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
         }
         return responseBean;
     }
+
+    /**
+     * 根据id查询对象
+     * @param id  实体ID
+     */
+    @RequestMapping(value="/center/current",method=RequestMethod.GET)
+    public ResponseBean currentUser(HttpServletRequest request){
+        String userName = JWTUtils.getSubject(request);
+        QueryWrapper<SysUser> sysUserQueryWrapper = new QueryWrapper<>();
+        sysUserQueryWrapper.eq("user_name",userName);
+        SysUser sysUser = iSysUserService.getOne(sysUserQueryWrapper);
+        sysUser.setPassword(null);
+
+        return ResponseBean.success(sysUser);
+    }
     
     @PostMapping("/center/signin")
     public ResponseBean signin(@RequestBody String paramStr) {

src/main/java/com/huiju/estateagents/center/taUser/controller/TaUserController.java

     public ResponseBean taUserAdd(@RequestBody TaUser taUser){
         ResponseBean responseBean = new ResponseBean();
         try {
-            if (iTaUserService.save(taUser)){
-                responseBean.addSuccess(taUser);
-            }else {
-                responseBean.addError("fail");
-            }
+            responseBean.addSuccess(iTaUserService.newUserAndOrg(taUser));
         }catch (Exception e){
             e.printStackTrace();
             logger.error("taUserAdd -=- {}",e.toString());
      * @param taUser 实体对象
      * @return
      */
-    @RequestMapping(value="/taUser/{id}",method= RequestMethod.PUT)
+    @RequestMapping(value="/center/taUser/{id}",method= RequestMethod.PUT)
     public ResponseBean taUserUpdate(@PathVariable Integer id,
                                         @RequestBody TaUser taUser){
         ResponseBean responseBean = new ResponseBean();
         try {
-            if (iTaUserService.updateById(taUser)){
-                responseBean.addSuccess(taUser);
-            }else {
-                responseBean.addError("fail");
-            }
+            iTaUserService.updateInfoWithOrg(taUser);
         }catch (Exception e){
             e.printStackTrace();
             logger.error("taUserUpdate -=- {}",e.toString());
         }
         return responseBean;
     }
-
     /**
      * 根据id查询对象
      * @param id  实体ID
      */
-    @RequestMapping(value="/taUser/{id}",method= RequestMethod.GET)
+    @RequestMapping(value="/center/taUser/{id}",method= RequestMethod.GET)
     public ResponseBean taUserGet(@PathVariable Integer id){
         ResponseBean responseBean = new ResponseBean();
         try {
-            responseBean.addSuccess(iTaUserService.getById(id));
+            responseBean.addSuccess(iTaUserService.getInfoWithOrg(id));
         }catch (Exception e){
             e.printStackTrace();
             logger.error("taUserDelete -=- {}",e.toString());

src/main/java/com/huiju/estateagents/center/taUser/entity/TaUser.java

 package com.huiju.estateagents.center.taUser.entity;
 
 import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
 import com.baomidou.mybatisplus.annotation.TableId;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
      * 是否管理员
      */
     private Boolean isAdmin;
+
+    /**
+     * 公司名称
+     */
+    @TableField(exist = false)
+    private String orgName;
+
+    /**
+     * 公司水印
+     */
+    @TableField(exist = false)
+    private String waterMark;
 }

src/main/java/com/huiju/estateagents/center/taUser/service/ITaUserService.java

 public interface ITaUserService extends IService<TaUser> {
 	
 	IPage<Map<String,Object>> getPageList(IPage<TaUser> pg);
+
+    TaUser newUserAndOrg(TaUser taUser) throws Exception;
+
+    TaUser getInfoWithOrg(Integer id);
+
+    void updateInfoWithOrg(TaUser taUser) throws Exception;
 }

src/main/java/com/huiju/estateagents/center/taUser/service/impl/TaUserServiceImpl.java

 package com.huiju.estateagents.center.taUser.service.impl;
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.huiju.estateagents.center.taUser.entity.TaUser;
 import com.huiju.estateagents.center.taUser.mapper.TaUserMapper;
 import com.huiju.estateagents.center.taUser.service.ITaUserService;
+import com.huiju.estateagents.common.CommConstant;
+import com.huiju.estateagents.common.StringUtils;
+import com.huiju.estateagents.entity.TaOrg;
+import com.huiju.estateagents.mapper.TaOrgMapper;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.time.LocalDateTime;
 import java.util.List;
 import java.util.Map;
 
 	
 	@Autowired
 	private TaUserMapper taUserMapper;
+
+	@Autowired
+	private TaOrgMapper taOrgMapper;
 	
 	@Override
 	public IPage<Map<String,Object>> getPageList(IPage pg) {
 		pg.setRecords(taUserList);
 		return pg;
 	}
+
+	@Override
+	public TaUser newUserAndOrg(TaUser taUser) throws Exception {
+		if (StringUtils.isEmpty(taUser.getPhone())) {
+			throw new Exception("电话号码不能为空");
+		}
+		if (StringUtils.isEmpty(taUser.getUserName())) {
+			throw new Exception("用户名称不能为空");
+		}
+
+		if (StringUtils.isEmpty(taUser.getLoginName())) {
+			taUser.setLoginName(taUser.getPhone());
+		}
+
+		QueryWrapper<TaUser> wrapper = new QueryWrapper<>();
+		wrapper.eq("phone", taUser.getPhone()).or().eq("login_Name", taUser.getLoginName());
+		List<TaUser> taUserList = this.list(wrapper);
+		if (null != taUserList && taUserList.size() > 0) {
+			throw new Exception("电话号码或登录名重复");
+		}
+
+		// 先插入 org
+		TaOrg taOrg = new TaOrg();
+		taOrg.setName(taUser.getOrgName());
+		taOrg.setWaterMark(taUser.getWaterMark());
+		taOrg.setCreateDate(LocalDateTime.now());
+		if (taOrgMapper.insert(taOrg) < 1) {
+			throw new Exception("生成用户公司信息失败");
+		}
+
+		taUser.setOrgId(taOrg.getOrgId());
+		taUser.setIsAdmin(true);
+		taUser.setStatus(CommConstant.STATUS_NORMAL);
+		taUser.setCreateDate(LocalDateTime.now());
+		if (!this.save(taUser)) {
+			throw new Exception("生成用户信息失败");
+		}
+
+		return taUser;
+	}
+
+	@Override
+	public TaUser getInfoWithOrg(Integer id) {
+		TaUser taUser = this.getById(id);
+		if (null == taUser) {
+			return taUser;
+		}
+
+		TaOrg taOrg = taOrgMapper.selectById(taUser.getOrgId());
+		if (null != taOrg) {
+			taUser.setOrgName(taOrg.getName());
+			taUser.setWaterMark(taOrg.getWaterMark());
+		}
+
+		taUser.setLoginPassword(null);
+		return taUser;
+	}
+
+	@Override
+	public void updateInfoWithOrg(TaUser taUser) throws Exception {
+		TaOrg taOrg = taOrgMapper.selectById(taUser.getOrgId());
+		if (null != taOrg) {
+			taOrg.setName(taUser.getOrgName());
+			taOrg.setWaterMark(taUser.getWaterMark());
+
+			if (taOrgMapper.updateById(taOrg) < 1) {
+				throw new Exception("更新用户公司信息失败");
+			}
+		}
+
+		if (taUserMapper.updateById(taUser) < 1) {
+			throw new Exception("更新用户信息失败");
+		}
+	}
 }

src/main/java/com/huiju/estateagents/controller/CommonController.java

 import com.huiju.estateagents.base.ResponseBean;
 import com.huiju.estateagents.common.AliOSSUtils;
 import com.huiju.estateagents.common.CommConstant;
+import com.huiju.estateagents.common.StringUtils;
 import org.apache.ibatis.annotations.Mapper;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.multipart.MultipartFile;
         }
     }
 
+    /**
+     * 为适应 ANTD 特制的图片上传
+     * plat 中心端传 center 管理端传 admin
+     * @param multipartFile
+     * @return
+     */
+    @PostMapping("/{plat}/antd/image")
+    public Map<String, String> uploadImageForAntd(@RequestParam("file") MultipartFile multipartFile) {
+        Map<String, String> result = new HashMap<>();
+
+        try {
+            String img = AliOSSUtils.putObject(multipartFile, CommConstant.ALIOSS_DEFAULT_UPLOAD);
+
+            result.put("name", StringUtils.ifNull(multipartFile.getOriginalFilename(), multipartFile.getName()));
+            result.put("status", "done");
+            result.put("thumbUrl", img + "?x-oss-process=style/thumbnail");
+            result.put("url", img);
+
+        } catch (IOException e) {
+            result.put("status", "error");
+            result.put("message", e.getMessage());
+        }
+
+        return result;
+    }
+
     @GetMapping("/wx/awesome/dict/{typeFor}")
     public ResponseBean dicts(@PathVariable String typeFor) {
 

src/main/java/com/huiju/estateagents/entity/TaOrg.java

      */
     private LocalDateTime createDate;
 
-
+    private String waterMark;
 }