feat(增加格式化客户来源渠道码id的定时任务)

src/main/java/com/mokamrp/privates/mapper/WorkContactEmployeeMapper.java

@@ -29,4 +29,6 @@ public interface WorkContactEmployeeMapper extends BaseMapper<WorkContactEmploye
     List<WorkContactEmployeeVo> getAllVoList(@Param("ew") QueryWrapper<WorkContactEmployeeVo> queryWrapper);
     Integer getVoListTotal(@Param("ew") QueryWrapper<WorkContactEmployeeVo> queryWrapper);
     List<HashMap<String, Object>> getContactTagList(@Param("ew") QueryWrapper<WorkContactEmployeeVo> queryWrapper);
+    void updateChannelCode(@Param("id") Integer id,@Param("codeId") Integer codeId);
+
 }

src/main/java/com/mokamrp/privates/mapper/WorkContactEmployeeMapper.xml

@@ -85,4 +85,10 @@
         </where>
         GROUP BY a.contact_id,a.employee_id;
     </select>
+
+    <update id="updateChannelCode" >
+        update mc_work_contact_employee
+        set channel_code_id = #{codeId}
+        where id = #{id}
+    </update>
 </mapper>

src/main/java/com/mokamrp/privates/mapper/pojo/WorkContactEmployee.java

@@ -4,6 +4,8 @@ import com.baomidou.mybatisplus.annotation.IdType;
 import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.annotation.TableName;
 import com.baomidou.mybatisplus.extension.activerecord.Model;
+import org.springframework.stereotype.Component;
+
 import java.util.Date;
 import java.io.Serializable;
 
@@ -15,6 +17,7 @@ import java.io.Serializable;
  * @author gengyang
  * @since 2021-04-17
  */
+@Component
 @TableName("mc_work_contact_employee")
 public class WorkContactEmployee extends Model<WorkContactEmployee> {
 

src/main/java/com/mokamrp/privates/service/WorkContactEmployeeService.java

@@ -22,8 +22,9 @@ import java.util.Map;
  */
 public interface WorkContactEmployeeService extends IService<WorkContactEmployee> {
 
+    public Map<String, Object> getPageList(GetWorkContactEmployeeHandle handle);
 
-    Map<String, Object> getPageList(GetWorkContactEmployeeHandle handle);
+    public void export(Downfile downFile,GetWorkContactEmployeeHandle handle);
 
-    void export(Downfile downFile,GetWorkContactEmployeeHandle handle);
+    public void formatChanelCode();
 }

src/main/java/com/mokamrp/privates/service/impl/WorkContactEmployeeServiceImpl.java

@@ -2,6 +2,7 @@ package com.mokamrp.privates.service.impl;
 
 import com.aliyun.oss.OSS;
 import com.aliyun.oss.model.PutObjectRequest;
+import com.baomidou.mybatisplus.core.conditions.Wrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.mokamrp.privates.config.OSSConfiguration;
@@ -70,6 +71,26 @@ public class WorkContactEmployeeServiceImpl extends ServiceImpl<WorkContactEmplo
     }
 
     @Override
+    public void formatChanelCode(){
+
+        QueryWrapper<WorkContactEmployee> obj = new QueryWrapper<WorkContactEmployee>();
+        obj.eq("channel_code_id",0);
+        obj.like("state","%channelCode%");
+        obj.last("limit 50");
+
+        List<WorkContactEmployee> list = mapperObj.selectList(obj);
+        int j = list.size();
+        Integer codeId;
+        for (int i = 0 ; i <j ; i++){
+            codeId = Integer.parseInt(list.get(i).getState().replaceAll("channelCode-",""));
+            if(codeId.equals(0)){
+                continue;
+            }
+            mapperObj.updateChannelCode(list.get(i).getId(),codeId);
+        }
+    }
+
+    @Override
     public void export(Downfile downFile, GetWorkContactEmployeeHandle handle) {
 
         List<Object> tempObj;

src/main/java/com/mokamrp/privates/tast/ContactJobTask.java

@@ -0,0 +1,34 @@
+package com.mokamrp.privates.tast;
+
+import com.mokamrp.privates.entity.JobRedis;
+import com.mokamrp.privates.entity.JobRoomJobRedis;
+import com.mokamrp.privates.entity.JobWorkContactEmployeeRedis;
+import com.mokamrp.privates.entity.JobWorkEmployeeJobRedis;
+import com.mokamrp.privates.mapper.pojo.Downfile;
+import com.mokamrp.privates.mapper.pojo.WorkContactEmployee;
+import com.mokamrp.privates.service.WorkContactEmployeeService;
+import com.mokamrp.privates.service.WorkEmployeeService;
+import com.mokamrp.privates.service.WorkRoomService;
+import com.mokamrp.privates.utils.RedisUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+import java.util.Date;
+
+@Component
+public class ContactJobTask {
+
+    @Autowired
+    private WorkContactEmployeeService workContactEmployeeService;
+
+    /**
+     * 导出任务，单进程
+     */
+    @Scheduled(fixedDelay = 30000)
+    public void execute() {
+        workContactEmployeeService.formatChanelCode();
+    }
+
+}