待办信息

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/notify/impl/PendingTaskServiceImpl.java

@@ -36,7 +36,7 @@ public class PendingTaskServiceImpl implements PendingTaskService {
             tabPendingTask.setId(pendingTask.getId());
             pendingTaskMapper.updateByPrimaryKey(tabPendingTask);
         } else {
-            pendingTaskMapper.insert(tabPendingTask);
+            pendingTaskMapper.insertSelective(tabPendingTask);
         }
         return true;
     }

haoban-manage3-service/src/test/java/ServiceTest.java

@@ -6,9 +6,13 @@ import com.gic.haoban.base.api.common.ServiceResponse;
 import com.gic.haoban.manage.api.dto.FlushStoreMqDTO;
 import com.gic.haoban.manage.api.dto.MaterialDTO;
 import com.gic.haoban.manage.api.dto.MemberUnionidRelatedDTO;
+import com.gic.haoban.manage.api.dto.notify.qdto.PendingTaskQDTO;
 import com.gic.haoban.manage.api.enums.ChannelCodeEnum;
+import com.gic.haoban.manage.api.enums.PendingTaskTypeEnum;
 import com.gic.haoban.manage.api.service.*;
+import com.gic.haoban.manage.api.service.notify.PendingTaskApiService;
 import com.gic.haoban.manage.service.service.MemberUnionRelatedService;
+import com.gic.haoban.task.api.enums.TaskTypeEnum;
 import com.gic.mq.sdk.GicMQClient;
 import com.gic.wechat.api.service.qywx.QywxDepartmentApiService;
 import com.gic.wechat.api.service.qywx.QywxSuiteApiService;
@@ -20,6 +24,7 @@ import org.springframework.test.context.ContextConfiguration;
 import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
 
 import java.util.ArrayList;
+import java.util.Date;
 import java.util.List;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
@@ -62,40 +67,24 @@ public class ServiceTest {
     @Autowired
     private HandoverOperationApiService handoverOperationApiService;
 
+    @Autowired
+    private PendingTaskApiService pendingTaskApiService;
+
 
     private final ExecutorService pools = Executors.newFixedThreadPool(50);
 
     @Test
     public void test11() {
-//        FlushStoreMqDTO flushStoreMqDTO = new FlushStoreMqDTO();
-//        flushStoreMqDTO.setEnterpriseId("testEnteroriseId");
-//        int i = 2;
-//        while (i-- > 0) {
-//            try {
-//                Thread.sleep(1000);
-//            } catch (InterruptedException e) {
-//                e.printStackTrace();
-//            }
-//            wxEnterpriseRelatedApiService.flushBindStoreByEnterpriseId("ff8080815dacd3a2015dacd3ef5c0000",
-//                    "-1", "-1", ChannelCodeEnum.SYNC_UNBIND.getCode());
-//        }
-
-        checkQywxSettingApiService.setFriendSetting("ca66a01b79474c40b3e7c7f93daf1a3b", "宿命の战");
-
-//        MemberUnionidRelatedDTO dto = new MemberUnionidRelatedDTO();
-//        dto.setSuiteid("selfSuiteId");
-//        checkQywxSettingApiService.saveFriendCallback("ca66a01b79474c40b3e7c7f93daf1a3b", null, dto);
-//        wxEnterpriseRelatedApiService.flushBindStoreByEnterpriseId("ff808081593917d90159398ec6340012",
-//                "ca66a01b79474c40b3e7c7f93daf1a3b", "-1", ChannelCodeEnum.SYNC_UNBIND.getCode());
-
-//        List<String> ids = new ArrayList<>();
-//        ids.add("8f5ddb9df0a54332acfa2d5804e90c64");
-//        List<MaterialDTO> materialDTOS = materialApiService.listMaterialByIds(ids);
-//
-//        System.out.println(JSONObject.toJSONString(materialDTOS));
-//        ServiceResponse response = wxEnterpriseRelatedApiService.flushBindStoreByEnterpriseId("ff8080815dacd3a2015dacd3ef5c0000"
-//                , "ca66a01b79474c40b3e7c7f93daf1a3b", "-1", ChannelCodeEnum.SYNC_UNBIND.getCode());
-//        System.out.println(JSONObject.toJSONString(response));
+        PendingTaskQDTO pendingTaskDTO = new PendingTaskQDTO();
+        pendingTaskDTO.setRelationId("relatrionId");
+        pendingTaskDTO.setTaskType(1 == TaskTypeEnum.TEL.getValue() ? PendingTaskTypeEnum.TEL_TASK.getType() : PendingTaskTypeEnum.PERFORMANCE.getType());
+        pendingTaskDTO.setTitle("标题");
+        pendingTaskDTO.setDescription("内容");
+        pendingTaskDTO.setStoreId("storeId");
+        pendingTaskDTO.setClerkId("clerkId");
+        pendingTaskDTO.setEnterpriseId("eid");
+        pendingTaskDTO.setOverdueTime(new Date());
+        pendingTaskApiService.addPendingTask(pendingTaskDTO);
     }
 
     @Test