feats

pom.xml

@@ -10,7 +10,7 @@
 	</parent>
 	<groupId>com.huiju.welcome</groupId>
 	<artifactId>mainbiz</artifactId>
-	<version>v4.0.1</version>
+	<version>v5.2.0</version>
 	<name>mainbiz</name>
 	<description>com.huiju.welcome main service</description>
 

src/main/java/com.huiju.welcome/config/SMSProperties.java

@@ -11,6 +11,7 @@ public class SMSProperties {
     String method;
     String contentType;
     Captcha captcha;
+    Visitor visitor;
 
     @Data
     public static class Template {
@@ -26,4 +27,9 @@ public class SMSProperties {
         Integer size;
         String sign;
     }
+
+    @Data
+    public static class Visitor {
+        String code;
+    }
 }

src/main/java/com.huiju.welcome/controller/CameraController.java

@@ -1,202 +1,203 @@
-package com.huiju.welcome.controller;
-
-import com.alibaba.fastjson.JSONObject;
-import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
-import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
-import com.huiju.welcome.common.Action;
-import com.huiju.welcome.common.WebSocketServer;
-import com.huiju.welcome.common.base.ResponseBean;
-import com.huiju.welcome.model.*;
-import com.huiju.welcome.service.*;
-import com.huiju.welcome.utils.AliFaceUtils;
-import com.huiju.welcome.utils.AliOSSUtils;
-import com.huiju.welcome.utils.StatusUtils;
-import com.huiju.welcome.utils.XFYun;
-import io.swagger.annotations.ApiOperation;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.apache.http.HttpStatus;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Value;
-import org.springframework.transaction.annotation.Transactional;
-import org.springframework.web.bind.annotation.*;
-import org.springframework.web.multipart.MultipartFile;
-import org.springframework.web.multipart.MultipartHttpServletRequest;
-
-import javax.annotation.PostConstruct;
-import javax.servlet.http.HttpServletRequest;
-import javax.websocket.server.PathParam;
-import java.io.File;
-import java.io.FileOutputStream;
-import java.io.IOException;
-import java.nio.ByteBuffer;
-import java.nio.channels.FileChannel;
-import java.time.Duration;
-import java.time.LocalDateTime;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
-/**
- * @author FXF
- * @date 2019-03-13
- */
-@RestController
-@RequestMapping("/")
-@Transactional(rollbackFor = Exception.class)
-public class CameraController {
-	private Logger log = LoggerFactory.getLogger(XFYun.class);
-
-	@Autowired
-	ITaDeviceService taDeviceService;
-	
-	@Autowired
-	private ISysParamService iSysParamService;
-
-	@Autowired
-	private ITaCarRecordService iTaCarRecordService;
-
-	@Autowired
-	private ICameraService cameraService;
-
-	@Autowired
-	private AliFaceUtils aliFaceUtils;
-
-	@GetMapping("/ping")
-	public String ping() {
-		return "pong";
-	}
-
-	@ApiOperation(value = "人脸对比结果上传", notes = "人脸对比结果上传")
-	@PostMapping(value = "/camera/{deviceId}/person")
-	public ResponseBean person(
-			@PathVariable String deviceId,
-			MultipartFile snapshot,
-			TaSnapshotPerson taSnapshotPerson,
-			HttpServletRequest request) {
-		ResponseBean responseBean = new ResponseBean();
-
-		if (null == deviceId || null == taSnapshotPerson) {
-			responseBean.addError(HttpStatus.SC_BAD_REQUEST, "设备ID 或者 抓拍参数传入方式不正确");
-			return responseBean;
-		}
-
-		if (!deviceId.equals(taSnapshotPerson.getDeviceId())) {
-			responseBean.addError(HttpStatus.SC_BAD_REQUEST, "设备ID 或者 抓拍参数传入不正确");
-			return responseBean;
-		}
-
-		taSnapshotPerson.setAvatar(getMultipartFile(snapshot));
-
-		// 抓拍时间为当前时间
-		taSnapshotPerson.setCreateDate(LocalDateTime.now());
-
-		cameraService.newPersonByDevice(taSnapshotPerson);
-		return responseBean;
-	}
-
-	@PostMapping("/camera/{deviceId}/face")
-	public ResponseBean face(
-			@PathVariable("deviceId") String deviceId,
-			@RequestParam(value = "avatar", required = false) MultipartFile avatar,
-			@RequestParam(value = "score", defaultValue = "0") Integer score
-	) {
-		if (avatar.isEmpty()) {
-			return ResponseBean.error("没有找到人脸信息", HttpStatus.SC_BAD_REQUEST);
-		}
-
-		// 上传阿里云OSS
-		String avatarURL = getMultipartFile(avatar);
-
-		// 人像质量最低值, 低于这个值的认为人脸抓拍失败, 取值范围 1 - 100
-		Float faceMinScore = iSysParamService.getFaceMinScore();
-		if (score < faceMinScore) {
-			log.error("人脸质量过低, 放弃本次抓拍人脸 {}", avatarURL);
-			return ResponseBean.success("");
-		}
-
-		TaSnapshotPerson taSnapshotPerson = new TaSnapshotPerson();
-
-		// 人脸比对检索
-		JSONObject result = null;
-		try {
-			result = aliFaceUtils.searchFace(avatarURL);
-		} catch (Exception e) {
-			log.error("比对人脸失败: {}", e.getMessage());
-			e.printStackTrace();
-			return ResponseBean.error("比对人脸失败", HttpStatus.SC_INTERNAL_SERVER_ERROR);
-		}
-
-		if (null != result) {
-			Float rate = result.getFloat("rate");
-			if (null == rate) {
-				log.error("比对人脸异常, 比对阈值结果为空");
-				rate = 0.0f;
-			} else {
-				rate *= 100;
-			}
-			Integer matchPerson = result.getInteger("personId");
-
-			taSnapshotPerson.setSimilarity(rate);
-			taSnapshotPerson.setMatchPerson(matchPerson);
-		} else {
-			taSnapshotPerson.setSimilarity(0f);
-		}
-
-		taSnapshotPerson.setCreateDate(LocalDateTime.now());
-		taSnapshotPerson.setStatus(StatusUtils.Normal);
-		taSnapshotPerson.setAvatar(avatarURL);
-		taSnapshotPerson.setDeviceId(deviceId);
-		taSnapshotPerson.setScore(score);
-
-		cameraService.newPersonByDevice(taSnapshotPerson);
-		return ResponseBean.success("");
-	}
-
-	@PostMapping(value = "/camera/{deviceId}/car")
-	public ResponseBean car(
-			@PathVariable("deviceId") String deviceId,
-			@RequestParam("sceneImage") MultipartFile carImage,
-			@RequestParam("licenseImage") MultipartFile licenseImage,
-			@RequestParam(value = "driverImage", required = false) MultipartFile driverImage,
-			@RequestParam(value = "copilotImage", required = false) MultipartFile copilotImage,
-			@RequestParam("plateNumber") String plateNumber,
-			@RequestParam("color") String color,
-			@RequestParam("carModel") String carModel
-			) {
-
-		TaCarRecord taCarRecord = new TaCarRecord();
-		taCarRecord.setPlateNumber(plateNumber);
-		taCarRecord.setColor(color);
-		taCarRecord.setCarModel(carModel);
-		taCarRecord.setCreateDate(LocalDateTime.now());
-
-		if (null != carImage && !carImage.isEmpty()) {
-			taCarRecord.setCarImage(getMultipartFile(carImage));
-		}
-		if (null != licenseImage && !licenseImage.isEmpty()) {
-			taCarRecord.setLicenseImage(getMultipartFile(licenseImage));
-		}
-		if (null != driverImage && !driverImage.isEmpty()) {
-			taCarRecord.setDriverImage(getMultipartFile(driverImage));
-		}
-		if (null != copilotImage && !copilotImage.isEmpty()) {
-			taCarRecord.setCopilotImage(getMultipartFile(copilotImage));
-		}
-
-		iTaCarRecordService.newRecordByDevice(taCarRecord);
-
-		return ResponseBean.success("");
-	}
-
-	// 获取上传单文件
-	private String getMultipartFile(MultipartFile f) {
-		try {
-			return AliOSSUtils.putObject(f);
-		} catch (IOException e) {
-			e.printStackTrace();
-			log.error("上传人脸至阿里云失败: " + e.getMessage());
-			return null;
-		}
-	}
-}
+package com.huiju.welcome.controller;
+
+import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
+import com.huiju.welcome.common.Action;
+import com.huiju.welcome.common.WebSocketServer;
+import com.huiju.welcome.common.base.ResponseBean;
+import com.huiju.welcome.model.*;
+import com.huiju.welcome.service.*;
+import com.huiju.welcome.utils.AliFaceUtils;
+import com.huiju.welcome.utils.AliOSSUtils;
+import com.huiju.welcome.utils.StatusUtils;
+import com.huiju.welcome.utils.XFYun;
+import io.swagger.annotations.ApiOperation;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.apache.http.HttpStatus;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
+import org.springframework.web.multipart.MultipartHttpServletRequest;
+
+import javax.annotation.PostConstruct;
+import javax.servlet.http.HttpServletRequest;
+import javax.websocket.server.PathParam;
+import java.io.File;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.nio.ByteBuffer;
+import java.nio.channels.FileChannel;
+import java.time.Duration;
+import java.time.LocalDateTime;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @author FXF
+ * @date 2019-03-13
+ */
+@RestController
+@RequestMapping("/")
+@Transactional(rollbackFor = Exception.class)
+public class CameraController {
+	private Logger log = LoggerFactory.getLogger(XFYun.class);
+
+	@Autowired
+	ITaDeviceService taDeviceService;
+	
+	@Autowired
+	private ISysParamService iSysParamService;
+
+	@Autowired
+	private ITaCarRecordService iTaCarRecordService;
+
+	@Autowired
+	private ICameraService cameraService;
+
+	@Autowired
+	private AliFaceUtils aliFaceUtils;
+
+	@GetMapping("/ping")
+	public String ping() {
+		return "pong";
+	}
+
+	@ApiOperation(value = "人脸对比结果上传", notes = "人脸对比结果上传")
+	@PostMapping(value = "/camera/{deviceId}/person")
+	public ResponseBean person(
+			@PathVariable String deviceId,
+			MultipartFile snapshot,
+			TaSnapshotPerson taSnapshotPerson,
+			HttpServletRequest request) {
+		ResponseBean responseBean = new ResponseBean();
+
+		if (null == deviceId || null == taSnapshotPerson) {
+			responseBean.addError(HttpStatus.SC_BAD_REQUEST, "设备ID 或者 抓拍参数传入方式不正确");
+			return responseBean;
+		}
+
+		if (!deviceId.equals(taSnapshotPerson.getDeviceId())) {
+			responseBean.addError(HttpStatus.SC_BAD_REQUEST, "设备ID 或者 抓拍参数传入不正确");
+			return responseBean;
+		}
+
+		taSnapshotPerson.setAvatar(getMultipartFile(snapshot));
+
+		// 抓拍时间为当前时间
+		taSnapshotPerson.setCreateDate(LocalDateTime.now());
+
+		cameraService.newPersonByDevice(taSnapshotPerson);
+		return responseBean;
+	}
+
+	@PostMapping("/camera/{deviceId}/face")
+	public ResponseBean face(
+			@PathVariable("deviceId") String deviceId,
+			@RequestParam(value = "avatar", required = false) MultipartFile avatar,
+			@RequestParam(value = "score", defaultValue = "0") Integer score
+	) {
+		if (avatar.isEmpty()) {
+			return ResponseBean.error("没有找到人脸信息", HttpStatus.SC_BAD_REQUEST);
+		}
+
+		// 上传阿里云OSS
+		String avatarURL = getMultipartFile(avatar);
+
+		// 人像质量最低值, 低于这个值的认为人脸抓拍失败, 取值范围 1 - 100
+		Float faceMinScore = iSysParamService.getFaceMinScore();
+		if (score < faceMinScore) {
+			log.error("人脸质量过低, 放弃本次抓拍人脸 {}", avatarURL);
+			return ResponseBean.success("");
+		}
+
+		TaSnapshotPerson taSnapshotPerson = new TaSnapshotPerson();
+
+		// 人脸比对检索
+		JSONObject result = null;
+		try {
+			result = aliFaceUtils.searchFace(avatarURL);
+		} catch (Exception e) {
+			log.error("比对人脸失败: {}", e.getMessage());
+			e.printStackTrace();
+			return ResponseBean.error("比对人脸失败", HttpStatus.SC_INTERNAL_SERVER_ERROR);
+		}
+
+		if (null != result) {
+			Float rate = result.getFloat("rate");
+			if (null == rate) {
+				log.error("比对人脸异常, 比对阈值结果为空");
+				rate = 0.0f;
+			}
+//			else {
+//				rate *= 100;
+//			}
+			Integer matchPerson = result.getInteger("personId");
+
+			taSnapshotPerson.setSimilarity(rate);
+			taSnapshotPerson.setMatchPerson(matchPerson);
+		} else {
+			taSnapshotPerson.setSimilarity(0f);
+		}
+
+		taSnapshotPerson.setCreateDate(LocalDateTime.now());
+		taSnapshotPerson.setStatus(StatusUtils.Normal);
+		taSnapshotPerson.setAvatar(avatarURL);
+		taSnapshotPerson.setDeviceId(deviceId);
+		taSnapshotPerson.setScore(score);
+
+		cameraService.newPersonByDevice(taSnapshotPerson);
+		return ResponseBean.success("");
+	}
+
+	@PostMapping(value = "/camera/{deviceId}/car")
+	public ResponseBean car(
+			@PathVariable("deviceId") String deviceId,
+			@RequestParam("sceneImage") MultipartFile carImage,
+			@RequestParam("licenseImage") MultipartFile licenseImage,
+			@RequestParam(value = "driverImage", required = false) MultipartFile driverImage,
+			@RequestParam(value = "copilotImage", required = false) MultipartFile copilotImage,
+			@RequestParam("plateNumber") String plateNumber,
+			@RequestParam("color") String color,
+			@RequestParam("carModel") String carModel
+			) {
+
+		TaCarRecord taCarRecord = new TaCarRecord();
+		taCarRecord.setPlateNumber(plateNumber);
+		taCarRecord.setColor(color);
+		taCarRecord.setCarModel(carModel);
+		taCarRecord.setCreateDate(LocalDateTime.now());
+
+		if (null != carImage && !carImage.isEmpty()) {
+			taCarRecord.setCarImage(getMultipartFile(carImage));
+		}
+		if (null != licenseImage && !licenseImage.isEmpty()) {
+			taCarRecord.setLicenseImage(getMultipartFile(licenseImage));
+		}
+		if (null != driverImage && !driverImage.isEmpty()) {
+			taCarRecord.setDriverImage(getMultipartFile(driverImage));
+		}
+		if (null != copilotImage && !copilotImage.isEmpty()) {
+			taCarRecord.setCopilotImage(getMultipartFile(copilotImage));
+		}
+
+		iTaCarRecordService.newRecordByDevice(taCarRecord);
+
+		return ResponseBean.success("");
+	}
+
+	// 获取上传单文件
+	private String getMultipartFile(MultipartFile f) {
+		try {
+			return AliOSSUtils.putObject(f);
+		} catch (IOException e) {
+			e.printStackTrace();
+			log.error("上传人脸至阿里云失败: " + e.getMessage());
+			return null;
+		}
+	}
+}

src/main/java/com.huiju.welcome/controller/TaCustomerController.java

@@ -293,7 +293,7 @@ public class TaCustomerController extends BaseController {
         @RequestParam(defaultValue = "1") int pageNumber,
         @RequestParam(defaultValue = "10") int pageSize,
         @RequestParam(defaultValue = "false") boolean mine,
-        @RequestParam(defaultValue = "") String nameOrPhone,
+        @RequestParam(defaultValue = "", name = "nameOrPhone") String nameOrPhoneOrReceiver,
         @RequestParam(defaultValue = "" ) Integer consultant,
         HttpServletRequest request
     ){
@@ -308,7 +308,7 @@ public class TaCustomerController extends BaseController {
                 consultantId = consultant;
             }
 
-            IPage<TaCustomer> result = iTaCustomerService.getCustomerListOfFront(pageNumber, pageSize, consultantId, nameOrPhone);
+            IPage<TaCustomer> result = iTaCustomerService.getCustomerListOfFront(pageNumber, pageSize, consultantId, nameOrPhoneOrReceiver);
             List<TaCustomer> custs = result.getRecords();
 
             if (null != custs && custs.size() > 0) {

src/main/java/com.huiju.welcome/controller/TaFirstUsherRecordController.java

@@ -59,6 +59,7 @@ public class TaFirstUsherRecordController extends BaseController {
                 responseBean.addError("fail");
             }
         }catch (Exception e){
+            e.printStackTrace();
             logger.error("taFirstUsherRecordAdd -=- {}",e.toString());
             responseBean.addError(e.getMessage());
         }

src/main/java/com.huiju.welcome/controller/TaMainUsherRecordController.java

@@ -98,7 +98,7 @@ public class TaMainUsherRecordController extends BaseController {
     public ResponseBean update(@RequestBody TaMainUsherRecord taMainUsherRecord, @PathVariable Integer id){
         ResponseBean responseBean = new ResponseBean();
         try {
-            iTaMainUsherRecordService.updateByMiniapp(taMainUsherRecord);
+            iTaMainUsherRecordService.updateByMiniapp(taMainUsherRecord, null);
         }catch (Exception e){
             logger.error("taMainUsherRecordUpdate -=- {}",e.toString());
             responseBean.addError(e.getMessage());
@@ -148,6 +148,17 @@ public class TaMainUsherRecordController extends BaseController {
         return ResponseBean.success("");
     }
 
+    @RequestMapping(value="/miniapp/today/mainUsherRecord",method= RequestMethod.GET)
+    public ResponseBean getTodayList() {
+        QueryWrapper<TaMainUsherRecord> queryWrapper = new QueryWrapper<>();
+        queryWrapper.ge("visite_date", DateUtils.morning());
+        queryWrapper.isNotNull("customer_id");
+        queryWrapper.orderByDesc("visite_date");
+
+        List<TaMainUsherRecord> result = iTaMainUsherRecordService.list(queryWrapper);
+        return ResponseBean.success(result);
+    }
+
     /**
      * 分页查询
      */
@@ -167,6 +178,7 @@ public class TaMainUsherRecordController extends BaseController {
         queryWrapper.ge(today, "visite_date", DateUtils.morning());
         queryWrapper.gt("rec_id", fromRec);
         queryWrapper.eq(null != customer && !"".equals(customer), "customer_id", customer);
+        queryWrapper.orderByDesc("visite_date");
 
         if (onlyNew) {
             queryWrapper.eq("status", StatusUtils.Ready);

src/main/java/com.huiju.welcome/mapper/SysUserMapper.java

@@ -27,4 +27,6 @@ public interface SysUserMapper extends BaseMapper<SysUser> {
     void fireUser(@Param("userId") Integer userId);
 	
 	List<SysUser> selectConsultManagerList(@Param("identityConsultantManager") String identityConsultantManager);
+
+    String getPhoneByOpenid(@Param("openid") String openid);
 }

src/main/java/com.huiju.welcome/mapper/TaCustomerMapper.java

@@ -24,7 +24,7 @@ public interface TaCustomerMapper extends BaseMapper<TaCustomer> {
 
     List<TaCustomer> getSomeCustMayBe(@Param("plateNumber") String plateNumber, @Param("phone") String phone);
 
-    IPage<TaCustomer> getCustomerListOfFront(IPage<TaCustomer> page,@Param("consultantId") Integer consultantId,@Param("nameOrPhone") String nameOrPhone);
+    IPage<TaCustomer> getCustomerListOfFront(IPage<TaCustomer> page,@Param("consultantId") Integer consultantId,@Param("nameOrPhoneOrReceiver") String nameOrPhoneOrReceiver);
     
     IPage<TaCustomer> getAttributionList(IPage<TaCustomer> page);
     

src/main/java/com.huiju.welcome/model/TaCustomer.java

@@ -219,4 +219,8 @@ public class TaCustomer implements Serializable {
      */
     @TableField(exist = false)
     private String carImage;
+
+    private String customerType;
+
+    private String receiver;
 }

src/main/java/com.huiju.welcome/model/TaMainUsherRecord.java

@@ -79,4 +79,6 @@ public class TaMainUsherRecord implements Serializable {
     
     @TableField(exist = false)
     private boolean newCustomer;
+
+    private String receiver;
 }

src/main/java/com.huiju.welcome/service/ITaCustomerService.java

@@ -45,7 +45,7 @@ public interface ITaCustomerService extends IService<TaCustomer> {
 
     TaCustomer getWithLastVisit(Integer id);
 
-    IPage<TaCustomer> getCustomerListOfFront(int pageNumber, int pageSize, Integer consultantId, String nameOrPhone);
+    IPage<TaCustomer> getCustomerListOfFront(int pageNumber, int pageSize, Integer consultantId, String nameOrPhoneOrReceiver);
 	
 	IPage<TaCustomer> getAttributionList(int pageNumber, int pageSize);
     

src/main/java/com.huiju.welcome/service/ITaMainUsherRecordService.java

@@ -38,7 +38,7 @@ public interface ITaMainUsherRecordService extends IService<TaMainUsherRecord> {
 
     boolean newRecordByMiniapp(TaMainUsherRecord taMainUsherRecord) throws Exception;
 
-    boolean updateByMiniapp(TaMainUsherRecord taMainUsherRecord) throws Exception;
+    boolean updateByMiniapp(TaMainUsherRecord taMainUsherRecord, TaCustomer taCustomer) throws Exception;
 
     boolean deleteRecord(Integer id);
 
@@ -51,4 +51,6 @@ public interface ITaMainUsherRecordService extends IService<TaMainUsherRecord> {
     boolean updateMainUsherRecord(TaMainUsherRecord taMainUsherRecord, Integer customerId, String subject);
 
     TaMainUsherRecord newRecordByFirstUsher(TaFirstUsherRecord taFirstUsherRecord, TaCustomer taCustomer);
+
+    TaMainUsherRecord mergeAndDelete(TaMainUsherRecord source, TaMainUsherRecord target);
 }

src/main/java/com.huiju.welcome/service/impl/CameraServiceImpl.java

@@ -199,7 +199,7 @@ public class CameraServiceImpl implements ICameraService {
 
         //二号岗设备推送
         TaDevice taDevice = taDeviceService.getById(taSnapshotPerson.getDeviceId());
-        if(taDevice.getAfr().equals(CommConstant.DEVICE_AFR_UNFACE)){
+        if(!taDevice.getAfr().equals(CommConstant.DEVICE_AFR_UNFACE)){
             sendMessageToConsult(taPerson);
             
     

src/main/java/com.huiju.welcome/service/impl/TaCarRecordServiceImpl.java

@@ -224,10 +224,12 @@ public class TaCarRecordServiceImpl extends ServiceImpl<TaCarRecordMapper, TaCar
         //自动关联成功
         if (null != taCustomer){
             iTaCustomerService.sendMessageToConsultManager(taCustomer);
+            // 发送吧台 - 人数未知就是 0
+            iTaCustomerService.sendMessageToBar(taCustomer, 0);
         }
         
-        //推送websocket消息。统一推送。
-        iTaCustomerService.sendMessageAll(taFirstUsherRecord,taCustomer,null);
+        //推送websocket消息。车辆垃圾数据太多，不推送消息
+//        iTaCustomerService.sendMessageAll(taFirstUsherRecord,taCustomer,null);
 
         return true;
     }

src/main/java/com.huiju.welcome/service/impl/TaCustomerServiceImpl.java

@@ -10,10 +10,7 @@ import com.huiju.welcome.common.WebSocketServer;
 import com.huiju.welcome.mapper.*;
 import com.huiju.welcome.model.*;
 import com.huiju.welcome.service.*;
-import com.huiju.welcome.utils.CommConstant;
-import com.huiju.welcome.utils.MiniApp;
-import com.huiju.welcome.utils.StatusUtils;
-import com.huiju.welcome.utils.StringUtils;
+import com.huiju.welcome.utils.*;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -80,6 +77,9 @@ public class TaCustomerServiceImpl extends ServiceImpl<TaCustomerMapper, TaCusto
     @Autowired
     ICameraService cameraService;
 
+    @Autowired
+    SMSUtils smsUtils;
+
     @Override
     public List<TaPerson> getGroup(Integer customerId) {
         return taCustomerMapMapper.getGroup(customerId);
@@ -185,7 +185,13 @@ public class TaCustomerServiceImpl extends ServiceImpl<TaCustomerMapper, TaCusto
             add("您有客户来访, 请及时接待!");
         }};
 
-        miniApp.sendTPLMessage(tpl, openid, page, data);
+        if (miniApp.sendTPLMessage(tpl, openid, page, data).getCode() == -1) {
+            // 没有 formid 发短信
+            String phone = sysUserMapper.getPhoneByOpenid(openid);
+            if (null != phone) {
+                smsUtils.sendVisitor(phone, null == taCustomer ? "": StringUtils.ifNull(taCustomer.getCustomerName(), ""));
+            }
+        }
     }
     
     /**
@@ -222,7 +228,14 @@ public class TaCustomerServiceImpl extends ServiceImpl<TaCustomerMapper, TaCusto
             if (null == openid) {
                 return;
             }
-            miniApp.sendTPLMessage(tpl, openid, page, data);
+//            miniApp.sendTPLMessage(tpl, openid, page, data);
+            if (miniApp.sendTPLMessage(tpl, openid, page, data).getCode() == -1) {
+                // 没有 formid 发短信
+                String phone = sysUserMapper.getPhoneByOpenid(openid);
+                if (null != phone) {
+                    smsUtils.sendVisitor(phone, null == taCustomer ? "": StringUtils.ifNull(taCustomer.getCustomerName(), ""));
+                }
+            }
         });
     }
     
@@ -278,8 +291,10 @@ public class TaCustomerServiceImpl extends ServiceImpl<TaCustomerMapper, TaCusto
             taMainUsherRecord.setCustomerId(cust.getCustomerId());
         } else {
             cust = taCustomerMapper.selectById(custId);
+            cust.setReceiver(taMainUsherRecord.getReceiver());
+            taCustomerMapper.updateById(cust);
         }
-        
+
         TaCustomerMap taCustomerMap = taCustomerMapMapper.getCustomerOf(personId);
         if (null == taCustomerMap) {
             TaCustomerMap custMap = new TaCustomerMap();
@@ -340,10 +355,10 @@ public class TaCustomerServiceImpl extends ServiceImpl<TaCustomerMapper, TaCusto
         if (notify){
             //通知吧台来人了
             sendMessageAll(taFirstUsherRecord,cust,null);
-            
+
             //通知吧台人数等信息
             sendMessageToBar(cust,taFirstUsherRecord.getPersonNum());
-            
+
             //推送置业经理
             sendMessageToConsultManager(cust);
         }
@@ -514,9 +529,9 @@ public class TaCustomerServiceImpl extends ServiceImpl<TaCustomerMapper, TaCusto
     }
 
     @Override
-    public IPage<TaCustomer> getCustomerListOfFront(int pageNumber, int pageSize, Integer consultantId, String nameOrPhone) {
+    public IPage<TaCustomer> getCustomerListOfFront(int pageNumber, int pageSize, Integer consultantId, String nameOrPhoneOrReceiver) {
         IPage<TaCustomer> page = new Page<>(pageNumber, pageSize);
-        return taCustomerMapper.getCustomerListOfFront(page, consultantId, nameOrPhone);
+        return taCustomerMapper.getCustomerListOfFront(page, consultantId, nameOrPhoneOrReceiver);
     }
     
     @Override
@@ -575,6 +590,7 @@ public class TaCustomerServiceImpl extends ServiceImpl<TaCustomerMapper, TaCusto
         taCustomer.setRealtyConsultant(taMainUsherRecord.getRealtyConsultant());
         taCustomer.setStatus(StatusUtils.Normal);
         taCustomer.setCreateDate(LocalDateTime.now());
+        taCustomer.setReceiver(taMainUsherRecord.getReceiver());
 
         return taCustomer;
     }
@@ -628,7 +644,14 @@ public class TaCustomerServiceImpl extends ServiceImpl<TaCustomerMapper, TaCusto
                 add("您有客户来访, 请及时接待!");
             }};
             
-            miniApp.sendTPLMessage(tpl, openid, page, data);
+//            miniApp.sendTPLMessage(tpl, openid, page, data);
+            if (miniApp.sendTPLMessage(tpl, openid, page, data).getCode() == -1) {
+                // 没有 formid 发短信
+                String phone = sysUserMapper.getPhoneByOpenid(openid);
+                if (null != phone) {
+                    smsUtils.sendVisitor(phone, null == taCustomer ? "": StringUtils.ifNull(taCustomer.getCustomerName(), ""));
+                }
+            }
         });
     }
     

src/main/java/com.huiju.welcome/service/impl/TaFirstUsherRecordServiceImpl.java

@@ -132,7 +132,16 @@ public class TaFirstUsherRecordServiceImpl extends ServiceImpl<TaFirstUsherRecor
     private boolean updateOtherInfo(TaFirstUsherRecord taFirstUsherRecord) {
         // 更新车辆信息
         TaCar taCar = iTaCarService.getById(taFirstUsherRecord.getPlateNumber());
-        if (null != taFirstUsherRecord.getCarModel()) {
+        if (null == taCar) {
+            taCar = new TaCar();
+            taCar.setPlateNumber(taFirstUsherRecord.getPlateNumber());
+            taCar.setColor(taFirstUsherRecord.getColor());
+            taCar.setCarModel(taFirstUsherRecord.getCarModel());
+            taCar.setCarImage(taFirstUsherRecord.getCarImage());
+            taCar.setStatus(StatusUtils.Normal);
+            taCar.setTypeId(CommConstant.TYPE_CAR_NORMAL);
+            iTaCarService.save(taCar);
+        } else if (null != taFirstUsherRecord.getCarModel()) {
             taCar.setCarModel(taFirstUsherRecord.getCarModel());
             taCar.setColor(taFirstUsherRecord.getColor());
             iTaCarService.updateById(taCar);
@@ -234,6 +243,8 @@ public class TaFirstUsherRecordServiceImpl extends ServiceImpl<TaFirstUsherRecor
                 iTaCustomerService.sendMessageAll(taFirstUsherRecord,taCustomer,null);
                 //通知置业经理车辆信息
                 iTaCustomerService.notifyConsultant(taCustomer);
+                // 通知吧台
+                iTaCustomerService.sendMessageToBar(taCustomer, taFirstUsherRecord.getPersonNum());
             } catch (Exception e) {}
         }else if(StringUtils.isEmpty(taFirstUsherRecord.getPhone())){
             //有手机号的情况下会新建customer，推送后置

src/main/java/com.huiju.welcome/service/impl/TaMainUsherRecordServiceImpl.java

@@ -39,6 +39,7 @@ import java.util.List;
 @Slf4j
 @Service
 public class TaMainUsherRecordServiceImpl extends ServiceImpl<TaMainUsherRecordMapper, TaMainUsherRecord> implements ITaMainUsherRecordService {
+
     @Autowired
     private TaMainUsherRecordMapper taMainUsherRecordMapper;
 
@@ -72,6 +73,9 @@ public class TaMainUsherRecordServiceImpl extends ServiceImpl<TaMainUsherRecordM
     @Autowired
     ICameraService cameraService;
 
+    @Autowired
+    SMSUtils smsUtils;
+
     @Override
     public boolean updateNormal(List<TaMainUsherRecord> records) {
         if (records == null || records.size() == 0) return true;
@@ -205,7 +209,14 @@ public class TaMainUsherRecordServiceImpl extends ServiceImpl<TaMainUsherRecordM
                 add("您有新客户来访, 请及时接待!");
             }};
 
-            miniApp.sendTPLMessage(tplId, openid, page, data);
+//            miniApp.sendTPLMessage(tplId, openid, page, data);
+            if (miniApp.sendTPLMessage(tplId, openid, page, data).getCode() == -1) {
+                // 没有 formid 发短信
+                String tel = sysUserMapper.getPhoneByOpenid(openid);
+                if (null != tel) {
+                    smsUtils.sendVisitor(tel, StringUtils.ifNull(visitorName, ""));
+                }
+            }
         } else {
             // 否则, 给原置业发消息, 给接待置业发消息
 
@@ -221,9 +232,14 @@ public class TaMainUsherRecordServiceImpl extends ServiceImpl<TaMainUsherRecordM
                 add(phone);
                 add("您有新客户来访, 已被安排给 " + usr1.getUsername() + " 接待!");
             }};
-            miniApp.sendTPLMessage(tplId, rcOpenid, page, dt1);
-
-
+//            miniApp.sendTPLMessage(tplId, rcOpenid, page, dt1);
+            if (miniApp.sendTPLMessage(tplId, rcOpenid, page, dt1).getCode() == -1) {
+                // 没有 formid 发短信
+                String tel = sysUserMapper.getPhoneByOpenid(rcOpenid);
+                if (null != tel) {
+                    smsUtils.sendVisitor(tel, StringUtils.ifNull(visitorName, ""));
+                }
+            }
 
             // 代理置业
             SysUser usr2 = sysUserMapper.selectById(realConsultant);
@@ -232,7 +248,14 @@ public class TaMainUsherRecordServiceImpl extends ServiceImpl<TaMainUsherRecordM
                 add(phone);
                 add(usr2.getUsername() + " 有新客户来访, 请协助接待一下!");
             }};
-            miniApp.sendTPLMessage(tplId, openid, page, dt2);
+//            miniApp.sendTPLMessage(tplId, openid, page, dt2);
+            if (miniApp.sendTPLMessage(tplId, openid, page, dt2).getCode() == -1) {
+                // 没有 formid 发短信
+                String tel = sysUserMapper.getPhoneByOpenid(openid);
+                if (null != tel) {
+                    smsUtils.sendVisitor(tel, StringUtils.ifNull(visitorName, ""));
+                }
+            }
         }
     }
 
@@ -247,7 +270,7 @@ public class TaMainUsherRecordServiceImpl extends ServiceImpl<TaMainUsherRecordM
 
     @Override
     public boolean newRecordByMiniapp(TaMainUsherRecord taMainUsherRecord) throws Exception {
-        Integer consultantId = taMainUsherRecord.getConsultantId();
+//        Integer consultantId = taMainUsherRecord.getConsultantId();
         //if (null == consultantId || consultantId < 1) {
         //    throw new Exception("置业顾问不能为空");
         //}
@@ -256,149 +279,82 @@ public class TaMainUsherRecordServiceImpl extends ServiceImpl<TaMainUsherRecordM
             throw new Exception("客户电话不能为空");
         }
 
+        TaCustomer taCustomer = getOrNewCustomerBy(taMainUsherRecord);
         taMainUsherRecord.setStatus(StatusUtils.Normal);
-    
-        // 是否更新了置业
-        TaCustomer taCustomer = null;
-        if (null != taMainUsherRecord.getCustomerId()) {
-            taCustomer = iTaCustomerService.getById(taMainUsherRecord.getCustomerId());
-        } else if (null != taMainUsherRecord.getPhone() || null != taMainUsherRecord.getPlateNumber()) {
-            // 尝试使用手机号去查找
-            taCustomer = iTaCustomerService.getByPhoneOrPlate(taMainUsherRecord.getPhone(), taMainUsherRecord.getPlateNumber());
-        } else if (null != taMainUsherRecord.getAvatar()) {
-            // 依据人脸查询
-            JSONObject result = aliFaceUtils.searchFace(taMainUsherRecord.getAvatar());
-            if (null != result) {
-                Integer personId = Integer.valueOf(result.getString("personId"));
-                taCustomer = iTaCustomerService.getSameByPerson(personId);
+        taMainUsherRecord.setVisiteDate(LocalDateTime.now());
+        taMainUsherRecord.setCustomerId(taCustomer.getCustomerId());
+
+        TaMainUsherRecord taMainUsherRecordToday = getTodayRecord(taCustomer.getCustomerId());
+
+        if (null == taMainUsherRecordToday) {
+            int row = taMainUsherRecordMapper.insert(taMainUsherRecord);
+            if (row < 1) {
+                log.error("新增跟进记录失败");
+                return false;
             }
-        }
-        
-        if (null == taCustomer){
-            // 新增客户
-            TaCustomer taCustomerNew = iTaCustomerService.newCustByMainUsher(taMainUsherRecord, true);
-    
-            taMainUsherRecord.setVisiteDate(LocalDateTime.now());
-            taMainUsherRecord.setCustomerId(taCustomerNew.getCustomerId());
-            return taMainUsherRecordMapper.insert(taMainUsherRecord) > 0;
+            return updateByMiniapp(taMainUsherRecord, taCustomer);
         }else {
-    
-            TaMainUsherRecord taMainUsherRecordToday = getTodayRecord(taCustomer.getCustomerId());
-            
-            if (null == taMainUsherRecordToday) {
-                int row = taMainUsherRecordMapper.insert(taMainUsherRecord);
-                if (row < 1) {
-                    log.error("新增跟进记录失败");
-                    return false;
-                }
-                return updateByMiniapp(taMainUsherRecord);
-            }else {
-                taMainUsherRecordToday = newRecordByCust(taCustomer, sysUserMapper.selectById(taCustomer.getConsultantId()));
-    
-                if (!StringUtils.isEmpty(taMainUsherRecord.getPhone())){
-                    taMainUsherRecordToday.setPhone(taMainUsherRecord.getPhone());
-                }
-    
-                if (!StringUtils.isEmpty(taMainUsherRecord.getPersonName())){
-                    taMainUsherRecordToday.setPersonName(taMainUsherRecord.getPersonName());
-                }
-                if (!StringUtils.isEmpty(taMainUsherRecord.getPurpose())){
-                    taMainUsherRecordToday.setPurpose(taMainUsherRecord.getPurpose());
-                }
-                if (!taMainUsherRecord.getAppointment()){
-                    taMainUsherRecordToday.setAppointment(taMainUsherRecord.getAppointment());
-                    taMainUsherRecordToday.setAppointmentId(taMainUsherRecord.getAppointmentId());
-                }
-                if (null != taMainUsherRecord.getPersonNum()){
-                    taMainUsherRecordToday.setPersonNum(taMainUsherRecord.getPersonNum());
-                }
-                if (!StringUtils.isEmpty(taMainUsherRecord.getCarModel())){
-                    taMainUsherRecordToday.setCarModel(taMainUsherRecord.getCarModel());
-                }
-                if (!StringUtils.isEmpty(taMainUsherRecord.getPlateNumber())){
-                    taMainUsherRecordToday.setPlateNumber(taMainUsherRecord.getPlateNumber());
-                }
-                if (!StringUtils.isEmpty(taMainUsherRecord.getColor())){
-                    taMainUsherRecordToday.setColor(taMainUsherRecord.getColor());
-                }
-                if (!StringUtils.isEmpty(taMainUsherRecord.getAvatar())){
-                    taMainUsherRecordToday.setAvatar(taMainUsherRecord.getAvatar());
-                }
-                return updateByMiniapp(taMainUsherRecordToday);
+//            taMainUsherRecordToday = newRecordByCust(taCustomer, sysUserMapper.selectById(taCustomer.getConsultantId()));
+            if (!StringUtils.isEmpty(taMainUsherRecord.getPhone())){
+                taMainUsherRecordToday.setPhone(taMainUsherRecord.getPhone());
+            }
+
+            if (!StringUtils.isEmpty(taMainUsherRecord.getPersonName())){
+                taMainUsherRecordToday.setPersonName(taMainUsherRecord.getPersonName());
+            }
+            if (!StringUtils.isEmpty(taMainUsherRecord.getPurpose())){
+                taMainUsherRecordToday.setPurpose(taMainUsherRecord.getPurpose());
+            }
+            if (!taMainUsherRecord.getAppointment()){
+                taMainUsherRecordToday.setAppointment(taMainUsherRecord.getAppointment());
+                taMainUsherRecordToday.setAppointmentId(taMainUsherRecord.getAppointmentId());
+            }
+            if (null != taMainUsherRecord.getPersonNum()){
+                taMainUsherRecordToday.setPersonNum(taMainUsherRecord.getPersonNum());
             }
+            if (!StringUtils.isEmpty(taMainUsherRecord.getCarModel())){
+                taMainUsherRecordToday.setCarModel(taMainUsherRecord.getCarModel());
+            }
+            if (!StringUtils.isEmpty(taMainUsherRecord.getPlateNumber())){
+                taMainUsherRecordToday.setPlateNumber(taMainUsherRecord.getPlateNumber());
+            }
+            if (!StringUtils.isEmpty(taMainUsherRecord.getColor())){
+                taMainUsherRecordToday.setColor(taMainUsherRecord.getColor());
+            }
+            if (!StringUtils.isEmpty(taMainUsherRecord.getAvatar())){
+                taMainUsherRecordToday.setAvatar(taMainUsherRecord.getAvatar());
+            }
+
+            // todo 可能有问题
+            taMainUsherRecordToday.setReceiver(taMainUsherRecord.getReceiver());
+
+            return updateByMiniapp(taMainUsherRecordToday, taCustomer);
         }
-        
-        
     }
 
     @Override
-    public boolean updateByMiniapp(TaMainUsherRecord taMainUsherRecord) throws Exception {
-        Integer consultantId = taMainUsherRecord.getConsultantId();
-        //if (null == consultantId || consultantId < 1) {
-        //    throw new Exception("置业顾问不能为空");
-        //}
-
+    public boolean updateByMiniapp(TaMainUsherRecord taMainUsherRecord, TaCustomer taCustomer) throws Exception {
         if (StringUtils.isEmpty(taMainUsherRecord.getPhone())) {
             throw new Exception("客户电话不能为空");
         }
 
-        taMainUsherRecord.setStatus(StatusUtils.Normal);
-
-        // 是否更新了置业
-        TaCustomer taCustomer = null;
-        if (null != taMainUsherRecord.getCustomerId()) {
-            taCustomer = iTaCustomerService.getById(taMainUsherRecord.getCustomerId());
-        } else if (null != taMainUsherRecord.getPhone() || null != taMainUsherRecord.getPlateNumber()) {
-            // 尝试使用手机号去查找
-            taCustomer = iTaCustomerService.getByPhoneOrPlate(taMainUsherRecord.getPhone(), taMainUsherRecord.getPlateNumber());
-        } else if (null != taMainUsherRecord.getAvatar()) {
-            // 依据人脸查询
-            JSONObject result = aliFaceUtils.searchFace(taMainUsherRecord.getAvatar());
-            if (null != result) {
-                Integer personId = Integer.valueOf(result.getString("personId"));
-                taCustomer = iTaCustomerService.getSameByPerson(personId);
-            }
+        if (null == taCustomer) {
+            taCustomer = getOrNewCustomerBy(taMainUsherRecord);
         }
 
-        if (null == taCustomer && null == taMainUsherRecord.getCustomerId()) {
-            taCustomer = iTaCustomerService.newCustByMainUsher(taMainUsherRecord, false);
+        taMainUsherRecord.setStatus(StatusUtils.Normal);
+        taMainUsherRecord.setVisiteDate(LocalDateTime.now());
+        taMainUsherRecord.setCustomerId(taCustomer.getCustomerId());
+        int row = 0;
+        if (null == taMainUsherRecord.getRecId()) {
+            row = taMainUsherRecordMapper.insert(taMainUsherRecord);
+        } else {
+            row = taMainUsherRecordMapper.updateById(taMainUsherRecord);
         }
 
+        Integer consultantId = taMainUsherRecord.getConsultantId();
         Integer originConsultant = taCustomer.getConsultantId();
 
-        // 是否需要更新客户信息
-        // 只更新空内容
-        if (StringUtils.isEmpty(taCustomer.getCustomerName()) || StringUtils.isEmpty(taCustomer.getPhone()) || StringUtils.isEmpty(taCustomer.getAvatar())
-             || StringUtils.isEmpty(taCustomer.getPlateNumber() )) {
-            if (StringUtils.isEmpty(taCustomer.getCustomerName())) {
-                taCustomer.setCustomerName(taMainUsherRecord.getPersonName());
-            }
-
-            if (StringUtils.isEmpty(taCustomer.getPhone())) {
-                taCustomer.setPhone(taMainUsherRecord.getPhone());
-            }
-
-            if (null == taCustomer.getSex()) {
-                taCustomer.setSex(taMainUsherRecord.getSex());
-            }
-
-            if (StringUtils.isEmpty(taCustomer.getAvatar())) {
-                taCustomer.setAvatar(taMainUsherRecord.getAvatar());
-            }
-
-            if (StringUtils.isEmpty(taCustomer.getPlateNumber())) {
-                taCustomer.setPlateNumber(taMainUsherRecord.getPlateNumber());
-            }
-
-            if (StringUtils.isEmpty(taCustomer.getCarModel())) {
-                taCustomer.setCarModel(taMainUsherRecord.getCarModel());
-            }
-
-            iTaCustomerService.updateById(taCustomer);
-        }
-
-        int row = taMainUsherRecordMapper.updateById(taMainUsherRecord);
-
         // 更新人员信息
         iTaPersonService.updateByMainUsher(taMainUsherRecord);
 
@@ -431,7 +387,13 @@ public class TaMainUsherRecordServiceImpl extends ServiceImpl<TaMainUsherRecordM
             dt1.add(taCustomer.getPhone());
             dt1.add("您有新客户来访, 已被安排给 " + proxyUser.getUsername() + " 接待!");
 
-            miniApp.sendTPLMessage(tplId, rcOpenid, page, dt1);
+//            miniApp.sendTPLMessage(tplId, rcOpenid, page, dt1);
+            if (miniApp.sendTPLMessage(tplId, rcOpenid, page, dt1).getCode() == -1) {                // 没有 formid 发短信
+                String phone = sysUserMapper.getPhoneByOpenid(rcOpenid);
+                if (null != phone) {
+                    smsUtils.sendVisitor(phone, StringUtils.ifNull(taCustomer.getCustomerName(), ""));
+                }
+            }
 
             // 通知临时置业
             List<Object> dt2 = new ArrayList<Object>();
@@ -439,7 +401,13 @@ public class TaMainUsherRecordServiceImpl extends ServiceImpl<TaMainUsherRecordM
             dt2.add(taCustomer.getPhone());
             dt2.add(rcUser.getUsername() + " 有新客户来访, 请协助接待一下!");
 
-            miniApp.sendTPLMessage(tplId, proxyOpenid, page, dt2);
+//            miniApp.sendTPLMessage(tplId, proxyOpenid, page, dt2);
+            if (miniApp.sendTPLMessage(tplId, proxyOpenid, page, dt2).getCode() == -1) {                // 没有 formid 发短信
+                String phone = sysUserMapper.getPhoneByOpenid(proxyOpenid);
+                if (null != phone) {
+                    smsUtils.sendVisitor(phone, StringUtils.ifNull(taCustomer.getCustomerName(), ""));
+                }
+            }
         }
     
         //通知前端
@@ -451,6 +419,65 @@ public class TaMainUsherRecordServiceImpl extends ServiceImpl<TaMainUsherRecordM
         return row > 0;
     }
 
+    private TaCustomer getOrNewCustomerBy(TaMainUsherRecord taMainUsherRecord) throws Exception {
+        // 是否更新了置业
+        TaCustomer taCustomer = null;
+        if (null != taMainUsherRecord.getCustomerId()) {
+            taCustomer = iTaCustomerService.getById(taMainUsherRecord.getCustomerId());
+        } else if (null != taMainUsherRecord.getPhone() || null != taMainUsherRecord.getPlateNumber()) {
+            // 尝试使用手机号去查找
+            taCustomer = iTaCustomerService.getByPhoneOrPlate(taMainUsherRecord.getPhone(), taMainUsherRecord.getPlateNumber());
+        } else if (null != taMainUsherRecord.getPersonId()) {
+            // 依据人员ID 查询
+            TaPerson taPerson = iTaPersonService.getById(taMainUsherRecord.getPersonId());
+            taCustomer = taCustomerMapper.getCustomerOf(taPerson.getPersonId(), taPerson.getRealId());
+        }
+
+        if (null != taMainUsherRecord.getAvatar() && null == taCustomer) {
+            // 依据人脸查询
+            JSONObject result = aliFaceUtils.searchFace(taMainUsherRecord.getAvatar());
+            if (null != result) {
+                Integer personId = Integer.valueOf(result.getString("personId"));
+                taCustomer = iTaCustomerService.getSameByPerson(personId);
+            }
+        }
+
+        if (null == taCustomer) {
+            taCustomer = iTaCustomerService.newCustByMainUsher(taMainUsherRecord, true);
+        } else {
+            // 是否需要更新客户信息
+            // 只更新空内容
+            taCustomer.setReceiver(taMainUsherRecord.getReceiver());
+            if (StringUtils.isEmpty(taCustomer.getCustomerName())) {
+                taCustomer.setCustomerName(taMainUsherRecord.getPersonName());
+            }
+
+            if (StringUtils.isEmpty(taCustomer.getPhone())) {
+                taCustomer.setPhone(taMainUsherRecord.getPhone());
+            }
+
+            if (null == taCustomer.getSex()) {
+                taCustomer.setSex(taMainUsherRecord.getSex());
+            }
+
+            if (StringUtils.isEmpty(taCustomer.getAvatar())) {
+                taCustomer.setAvatar(taMainUsherRecord.getAvatar());
+            }
+
+            if (StringUtils.isEmpty(taCustomer.getPlateNumber())) {
+                taCustomer.setPlateNumber(taMainUsherRecord.getPlateNumber());
+            }
+
+            if (StringUtils.isEmpty(taCustomer.getCarModel())) {
+                taCustomer.setCarModel(taMainUsherRecord.getCarModel());
+            }
+
+            iTaCustomerService.updateById(taCustomer);
+        }
+
+        return taCustomer;
+    }
+
     @Override
     public boolean deleteRecord(Integer id) {
         UpdateWrapper<TaMainUsherRecord> updateWrapper = new UpdateWrapper<>();
@@ -615,6 +642,28 @@ public class TaMainUsherRecordServiceImpl extends ServiceImpl<TaMainUsherRecordM
         return taMainUsherRecord;
     }
 
+    /**
+     * 合并 source 到 target, 并且删除 source
+     * @param source
+     * @param target
+     * @return
+     */
+    @Override
+    public TaMainUsherRecord mergeAndDelete(TaMainUsherRecord source, TaMainUsherRecord target) {
+        if (null == source) return target;
+        if (null == target) return source;
+
+        // 合并为空的字段
+        target.setPersonId(ifIntNvl(target.getPersonId(), source.getPersonId()));
+        target.setPersonName(StringUtils.ifNull(target.getPersonName(), source.getPersonName()));
+
+        return null;
+    }
+
+    private Integer ifIntNvl(Integer a, Integer b) {
+        return null == a ? b : a;
+    }
+
     private TaMainUsherRecord newRecordByPerson(TaPerson taPerson) {
         TaMainUsherRecord taMainUsherRecord = new TaMainUsherRecord();
         taMainUsherRecord.setPersonName(taPerson.getName());

src/main/java/com.huiju.welcome/utils/MiniApp.java

@@ -65,7 +65,8 @@ public class MiniApp {
 
         String formId = iTaMiniFormidsService.getFormidBy(toUser, true);
         if (null == formId) {
-            return ResponseBean.error("发送模板消息失败, 没有可用的 formid ", HttpStatus.SC_INTERNAL_SERVER_ERROR);
+            return ResponseBean.error("没有可用的 formid", -1);
+//            return ResponseBean.error("发送模板消息失败, 没有可用的 formid ", HttpStatus.SC_INTERNAL_SERVER_ERROR);
         }
 
         String api = String.format("/api/%s/tpl/%s/form/%s/to/%s", appid, tplId, formId, toUser);

src/main/java/com.huiju.welcome/utils/SMSUtils.java

@@ -79,6 +79,13 @@ public class SMSUtils {
         return true;
     }
 
+    public boolean sendVisitor(String tel, String name) {
+        log.info("发送手机 {} 客户名称 {}", tel, name);
+
+        String[] params = { name };
+        return sendMessage(smsProperties.getVisitor().getCode(), tel, params);
+    }
+
     private String genCaptcha(int length) {
         List<String> nums = new ArrayList<>();
         for (int i = 0; i < length; i ++) {

src/main/resources/application.yml

@@ -1,12 +1,12 @@
 spring:
   datasource:
     driver-class-name: com.mysql.cj.jdbc.Driver
-#    url: jdbc:mysql://rm-uf6z3z6jq11x653d77o.mysql.rds.aliyuncs.com:3306/welcome3?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true&serverTimezone=GMT%2B8&zeroDateTimeBehavior=convertToNull
-#    username: welcome
-#    password: s190QU2#z%hdU%^FPkY9qjls
-    url: jdbc:mysql://47.101.36.130:3306/welcome3?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true&serverTimezone=GMT%2B8&zeroDateTimeBehavior=convertToNull
-    username: root
-    password: Wt4q*/9}i00q@0a4jM{z6O#h129@F/
+    url: jdbc:mysql://rm-uf6z3z6jq11x653d77o.mysql.rds.aliyuncs.com:3306/welcome3?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true&serverTimezone=GMT%2B8&zeroDateTimeBehavior=convertToNull
+    username: welcome
+    password: s190QU2#z%hdU%^FPkY9qjls
+#    url: jdbc:mysql://47.101.36.130:3306/welcome3?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true&serverTimezone=GMT%2B8&zeroDateTimeBehavior=convertToNull
+#    username: root
+#    password: Wt4q*/9}i00q@0a4jM{z6O#h129@F/
   servlet:
     multipart:
       max-file-size: 1024MB
@@ -95,4 +95,7 @@ sms:
     # 验证码长度
     size: 4
     # 短信签名
-    sign: AI智慧案场
+    sign: AI智慧案场
+
+  visitor:
+    code: "0501"

src/main/resources/mapper/SysUserMapper.xml

@@ -32,4 +32,15 @@
             AND s.user_identity = #{identityConsultantManager}
             AND s.STATUS = 1
     </select>
+
+    <select id="getPhoneByOpenid" resultType="String">
+      SELECT
+        t.phone
+      FROM
+        sys_user t
+        JOIN ta_wechat_user s ON s.person_id = t.user_id
+      WHERE
+        s.openid = #{openid}
+        LIMIT 1
+    </select>
 </mapper>

src/main/resources/mapper/TaCustomerMapper.xml

@@ -60,18 +60,29 @@
 
     <select id="getCustomerListOfFront" resultType="com.huiju.welcome.model.TaCustomer">
         SELECT
-            *
+            t.*,
+            s.visite_date
         FROM
             ta_customer t
+        LEFT JOIN (
+            SELECT
+                a.customer_id,
+                max( b.visite_date ) as visite_date
+            FROM
+              ta_customer a
+            LEFT JOIN ta_main_usher_record b USING ( customer_id )
+            GROUP BY
+              a.customer_id
+            ) s USING ( customer_id )
         WHERE t.status &gt; 0
             <if test="consultantId !=null">
               AND t.consultant_id = #{consultantId}
             </if>
-            <if test="nameOrPhone !=null and nameOrPhone != ''">
-              AND ( t.customer_name LIKE CONCAT('%',#{nameOrPhone},'%') OR t.phone LIKE CONCAT('%',#{nameOrPhone},'%') )
+            <if test="nameOrPhoneOrReceiver !=null and nameOrPhoneOrReceiver != ''">
+              AND ( t.customer_name LIKE CONCAT('%',#{nameOrPhoneOrReceiver},'%') OR t.phone LIKE CONCAT('%',#{nameOrPhoneOrReceiver},'%') OR t.receiver LIKE CONCAT('%',#{nameOrPhoneOrReceiver},'%'))
             </if>
         ORDER BY
-            t.create_date DESC
+          IFNULL( s.visite_date, t.create_date ) DESC
     </select>
 
     <select id="getAttributionList" resultType="com.huiju.welcome.model.TaCustomer">